wip: postgres data types [skil ci]

This commit is contained in:
Hamed Masafi 2019-02-10 20:03:14 +03:30
parent af64d3f24f
commit 177fb6808c
6 changed files with 85 additions and 27 deletions

View File

@ -69,7 +69,8 @@ bool DatabasePrivate::open(bool update)
db = QSqlDatabase::addDatabase(driver, connectionName); db = QSqlDatabase::addDatabase(driver, connectionName);
db.setHostName(hostName); db.setHostName(hostName);
db.setPort(port); if (port)
db.setPort(port);
db.setDatabaseName(databaseName); db.setDatabaseName(databaseName);
db.setUserName(userName); db.setUserName(userName);
db.setPassword(password); db.setPassword(password);

View File

@ -18,6 +18,8 @@
** **
**************************************************************************/ **************************************************************************/
#include <QDateTime>
#include "postgresqlgenerator.h" #include "postgresqlgenerator.h"
#include "../table.h" #include "../table.h"
#include "../tablemodel.h" #include "../tablemodel.h"
@ -34,62 +36,95 @@ QString PostgreSqlGenerator::fieldType(FieldModel *field)
QString dbType; QString dbType;
switch (field->type) { switch (field->type) {
case QVariant::Bool: case QMetaType::Bool:
dbType = "BOOLEAN"; dbType = "BOOLEAN";
break; break;
case QVariant::ByteArray: case QMetaType::QByteArray:
dbType = "BYTEA"; dbType = "BYTEA";
break; break;
case QVariant::Date: case QMetaType::QDate:
dbType = "DATE"; dbType = "DATE";
break; break;
case QVariant::DateTime: case QMetaType::QDateTime:
dbType = "TIMESTAMP"; dbType = "TIMESTAMP";
break; break;
case QVariant::Time: case QMetaType::QTime:
dbType = "TIME"; dbType = "TIME";
break; break;
case QVariant::Int: case QMetaType::SChar:
case QVariant::UInt: case QMetaType::UChar:
case QMetaType::Short:
case QMetaType::UShort:
dbType = "SMALLINT";
break;
case QMetaType::Float:
dbType = "FLOAT";
break;
case QMetaType::Double:
dbType = "REAL";
break;
case QMetaType::Int:
case QMetaType::UInt:
if(field->isAutoIncrement) if(field->isAutoIncrement)
dbType = "SERIAL"; dbType = "SERIAL";
else else
dbType = "INTEGER"; dbType = "INTEGER";
break; break;
case QVariant::ULongLong: case QMetaType::ULongLong:
case QVariant::LongLong: case QMetaType::LongLong:
if(field->isAutoIncrement) if(field->isAutoIncrement)
dbType = "BIGSERIAL"; dbType = "BIGSERIAL";
else else
dbType = "BIGINT"; dbType = "BIGINT";
break; break;
case QVariant::Double: case QMetaType::QString:
dbType = "REAL";
break;
case QVariant::String:
if(field->length) if(field->length)
dbType = QString("VARCHAR(%1)").arg(field->length); dbType = QString("VARCHAR(%1)").arg(field->length);
else else
dbType = "TEXT"; dbType = "TEXT";
break; break;
case QVariant::Point: case QMetaType::QPoint:
case QVariant::PointF: case QMetaType::QPointF:
dbType="POINT"; dbType="POINT";
break; break;
case QVariant::Uuid: case QMetaType::QUuid:
dbType = "UUID"; dbType = "UUID";
break; break;
case QVariant::Polygon: case QMetaType::QPolygon:
case QVariant::PolygonF: case QMetaType::QPolygonF:
dbType = "POLYGON"; dbType = "POLYGON";
break; break;
case QMetaType::QLine:
case QMetaType::QLineF:
return "LINE";
case QMetaType::QRect:
case QMetaType::QRectF:
return "BOX";
case QMetaType::QJsonArray:
case QMetaType::QJsonValue:
case QMetaType::QJsonObject:
case QMetaType::QJsonDocument:
return "JSON";
case QMetaType::QStringList:
return "TEXT[]";
case QMetaType::QUrl:
case QMetaType::QColor:
return "TEXT";
default: default:
qDebug() << "Type for " << (int)field->type << field->type << "(" << QMetaType::typeName(field->type) << ")" << "nut supported"; qDebug() << "Type for " << (int)field->type << field->type << "(" << QMetaType::typeName(field->type) << ")" << "nut supported";
dbType = QString(); dbType = QString();
@ -122,5 +157,21 @@ QString PostgreSqlGenerator::diff(FieldModel *oldField, FieldModel *newField)
return sql; return sql;
} }
QString PostgreSqlGenerator::escapeValue(const QVariant &v) const
{
if (v.type() == QVariant::DateTime)
return "'" + v.toDateTime().toString("yyyy-MM-dd HH:mm:ss") + "'";
return SqlGeneratorBase::escapeValue(v);
}
QVariant PostgreSqlGenerator::readValue(const QMetaType::Type &type, const QVariant &dbValue)
{
if (type == QMetaType::QDateTime)
return dbValue.toDateTime();// QDateTime::fromString(dbValue.toString(), "yyyy-MM-dd HH:mm:ss");
return SqlGeneratorBase::readValue(type, dbValue);
}
NUT_END_NAMESPACE NUT_END_NAMESPACE

View File

@ -34,6 +34,11 @@ public:
QString fieldType(FieldModel *field); QString fieldType(FieldModel *field);
QString diff(FieldModel *oldField, FieldModel *newField); QString diff(FieldModel *oldField, FieldModel *newField);
// SqlGeneratorBase interface
public:
QString escapeValue(const QVariant &v) const;
QVariant readValue(const QMetaType::Type &type, const QVariant &dbValue);
}; };
NUT_END_NAMESPACE NUT_END_NAMESPACE

View File

@ -103,7 +103,7 @@ QString SqlGeneratorBase::recordsPhrase(TableModel *table)
foreach (FieldModel *f, table->fields()) { foreach (FieldModel *f, table->fields()) {
if (!ret.isEmpty()) if (!ret.isEmpty())
ret.append(", "); ret.append(", ");
ret.append(QString("%1.%2 AS [%1.%2]").arg(table->name(), f->name)); ret.append(QString("%1.%2 AS \"%1.%2\"").arg(table->name(), f->name));
} }
return ret; return ret;
} }
@ -721,7 +721,7 @@ void SqlGeneratorBase::replaceTableNames(QString &command)
{ {
foreach (TableModel *m, TableModel::allModels()) foreach (TableModel *m, TableModel::allModels())
command = command command = command
.replace("[" + m->className() + "]", "`" + m->name() + "`"); .replace("[" + m->className() + "]", m->name());
} }
void SqlGeneratorBase::removeTableNames(QString &command) void SqlGeneratorBase::removeTableNames(QString &command)

View File

@ -8,11 +8,11 @@
.arg(timer.elapsed() / 1000.) \ .arg(timer.elapsed() / 1000.) \
.arg(__func__) .arg(__func__)
#define DRIVER "QSQLITE" #define DRIVER "QPSQL"
#define DATABASE QString(typeid(*this).name()) + ".db" #define DATABASE QString(metaObject()->className()).toLower() + "_db"
#define HOST "" #define HOST "127.0.0.1"
#define USERNAME "" #define USERNAME "postgres"
#define PASSWORD "" #define PASSWORD "856856"
#ifdef Q_OS_LINUX #ifdef Q_OS_LINUX
# define OS "Linux" # define OS "Linux"

View File

@ -102,7 +102,7 @@ void BasicTest::createPost2()
(Post::titleField() = "This is a sample") (Post::titleField() = "This is a sample")
& (Post::isPublicField() = true)); & (Post::isPublicField() = true));
QTEST_ASSERT(postIdVar.type() == QVariant::LongLong); QTEST_ASSERT(postIdVar.type() == QVariant::LongLong || postIdVar.type() == QVariant::ULongLong);
int postId = postIdVar.toInt(); int postId = postIdVar.toInt();
for(int i = 0 ; i < 3; i++){ for(int i = 0 ; i < 3; i++){
@ -217,6 +217,7 @@ void BasicTest::testDate()
->setWhere(Post::idField() == newPost->id()) ->setWhere(Post::idField() == newPost->id())
->first(); ->first();
qDebug() << q->saveDate() << d;
QTEST_ASSERT(q->saveDate() == d); QTEST_ASSERT(q->saveDate() == d);
} }