Revision b0bf458e
Von Christian Ehringfeld vor etwa 9 Jahren hinzugefügt
src/querybuilder.cpp | ||
---|---|---|
#include "querybuilder.h"
|
||
#include "database.h"
|
||
#include <QMetaObject>
|
||
#include <QMetaProperty>
|
||
#include "entity.h"
|
||
using namespace CuteEntityManager;
|
||
|
||
QueryBuilder::QueryBuilder() {
|
||
//bool QueryBuilder::createTable(QString tablename, QHash<QString, QString> tableDefinition) {
|
||
//// QHash<QString, QString> Artikel::getProperties(DatabaseType type) {
|
||
//// QHash<QString, QString> h = QHash<QString, QString>();
|
||
//// h.insert("id",this->idColumnSQL());
|
||
//// h.insert("preis","DOUBLE");
|
||
//// h.insert("name","TEXT");
|
||
//// return h;
|
||
//// }
|
||
//}
|
||
|
||
QueryBuilder::QueryBuilder(QSharedPointer<Schema> schema, QSharedPointer<Database> database) {
|
||
this->schema = schema;
|
||
this->database = database;
|
||
}
|
||
|
||
QueryBuilder::~QueryBuilder() {
|
||
bool QueryBuilder::createTable(const QSharedPointer<Entity> &entity) const {
|
||
return this->createTable(entity.data()->getTablename(), this->generateTableDefinition(entity));
|
||
}
|
||
|
||
bool QueryBuilder::createTable(const QString &tableName, const QHash<QString, QString> &tableDefinition) const {
|
||
bool rc = false;
|
||
this->schema.data()->containsTable(tableName) ? rc = true : rc = false;
|
||
if (!rc) {
|
||
QSqlQuery q = this->database.data()->getQuery(this->createTableQuery(tableName, tableDefinition));
|
||
if (this->database.data()->transaction(q)) {
|
||
this->schema.data()->getTableSchema(tableName);
|
||
rc = true;
|
||
}
|
||
}
|
||
return rc;
|
||
}
|
||
|
||
QString QueryBuilder::createTableQuery(const QString &tableName, const QHash<QString, QString> &tableDefinition) const {
|
||
bool first = true;
|
||
QString s = "CREATE TABLE ";
|
||
s.append(this->schema.data()->quoteTableName(tableName).append(" (\n"));
|
||
QHash<QString, QString>::const_iterator i = tableDefinition.constBegin();
|
||
while (i != tableDefinition.constEnd()) {
|
||
if (first) {
|
||
first = false;
|
||
} else {
|
||
s.append(',');
|
||
}
|
||
s.append(this->schema.data()->quoteColumnName(i.key())).append(" " + i.value());
|
||
++i;
|
||
}
|
||
s.append("\n);");
|
||
return s;
|
||
}
|
||
|
||
QSharedPointer<Database> QueryBuilder::getDatabase() const {
|
||
return database;
|
||
}
|
||
|
||
void QueryBuilder::setDatabase(const QSharedPointer<Database> &value) {
|
||
database = value;
|
||
}
|
||
|
||
bool QueryBuilder::createTable(QString tablename, QHash<QString, QString> tableDefinition) {
|
||
// QHash<QString, QString> Artikel::getProperties(DatabaseType type) {
|
||
// QHash<QString, QString> h = QHash<QString, QString>();
|
||
// h.insert("id",this->idColumnSQL());
|
||
// h.insert("preis","DOUBLE");
|
||
// h.insert("name","TEXT");
|
||
// return h;
|
||
// }
|
||
QHash<QString, QString> QueryBuilder::generateTableDefinition(const QSharedPointer<Entity> &entity) const {
|
||
auto map = QHash<QString, QString>();
|
||
auto o = entity.data()->metaObject();
|
||
for (int var = 0; var < o->propertyCount(); ++var) {
|
||
auto m = o->property(var);
|
||
if (m.isReadable() && !entity.data()->getTransientAttributes().contains(m.name())) {
|
||
m.typeName();
|
||
/**
|
||
@TODO
|
||
*/
|
||
}
|
||
}
|
||
return map;
|
||
}
|
||
|
||
QHash<QString, QVariant> QueryBuilder::getEntityAttributes(const QSharedPointer<Entity> &entity) {
|
||
Entity *e = entity.data();
|
||
auto map = QHash<QString, QVariant>();
|
||
auto metaObject = e->metaObject();
|
||
auto transientAttrs = e->getTransientAttributes();
|
||
for (int var = 0; var < metaObject->propertyCount(); ++var) {
|
||
auto p = metaObject->property(var);
|
||
QString name = QString(p.name());
|
||
if (p.isValid() && !transientAttrs.contains(name)) {
|
||
QVariant v = p.read(e);
|
||
//Relation
|
||
if (v.canConvert<Entity *>()) {
|
||
this->insertRelationId(qvariant_cast<Entity *>(v), map, name);
|
||
} else if (v.canConvert<QSharedPointer<Entity>>()) {
|
||
this->insertRelationId(qvariant_cast<QSharedPointer<Entity>>(v).data(), map, name);
|
||
} else if (QString(p.typeName()).contains("QList")) {
|
||
/**
|
||
@TODO
|
||
//List and/or ManyToManyRelation
|
||
*/
|
||
auto n = static_cast<QList<CuteEntityManager::Entity *>*>(v.data());
|
||
for (int var = 0; var < n->size(); ++var) {
|
||
CuteEntityManager::Entity *entity = n->at(var);
|
||
qDebug() << entity->toString();
|
||
}
|
||
} else {
|
||
map.insert(name, v);
|
||
}
|
||
}
|
||
}
|
||
return map;
|
||
}
|
||
|
||
void QueryBuilder::insertRelationId(const Entity *e, QHash<QString, QVariant> &map, QString relName) {
|
||
if (e && e->getId() > -1) {
|
||
map.insert(relName + "_id", e->getId());
|
||
}
|
||
}
|
||
|
||
QSharedPointer<Schema> QueryBuilder::getSchema() const {
|
||
return schema;
|
||
}
|
||
|
||
void QueryBuilder::setSchema(const QSharedPointer<Schema> &value) {
|
||
schema = value;
|
||
}
|
||
|
Auch abrufbar als: Unified diff
wip