Revision e0e1ead8
Von Christian Ehringfeld vor fast 9 Jahren hinzugefügt
| src/querybuilder.cpp | ||
|---|---|---|
|
|
||
|
using namespace CuteEntityManager;
|
||
|
|
||
|
QueryBuilder::QueryBuilder(QSharedPointer<Schema> schema, QSharedPointer<Database> database) {
|
||
|
QueryBuilder::QueryBuilder(QSharedPointer<Schema> schema,
|
||
|
QSharedPointer<Database> database) {
|
||
|
this->schema = schema;
|
||
|
this->database = database;
|
||
|
}
|
||
| ... | ... | |
|
}
|
||
|
|
||
|
bool QueryBuilder::createTable(const QSharedPointer<Entity> &entity) const {
|
||
|
return this->createTable(entity.data()->getTablename(), this->generateTableDefinition(entity));
|
||
|
return this->createTable(entity.data()->getTablename(),
|
||
|
this->generateTableDefinition(entity));
|
||
|
}
|
||
|
|
||
|
bool QueryBuilder::createTable(const QString &tableName, const QHash<QString, QString> &tableDefinition) const {
|
||
|
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));
|
||
|
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 {
|
||
|
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"));
|
||
| ... | ... | |
|
} else {
|
||
|
s.append(", ");
|
||
|
}
|
||
|
s.append(this->schema.data()->quoteColumnName(i.key())).append(" " + this->getColumnType(i.value()));
|
||
|
s.append(this->schema.data()->quoteColumnName(i.key())).append(" " +
|
||
|
this->getColumnType(
|
||
|
i.value()));
|
||
|
++i;
|
||
|
}
|
||
|
s.append("\n);");
|
||
| ... | ... | |
|
}
|
||
|
|
||
|
QString QueryBuilder::renameTable(QString tableName, QString newName) const {
|
||
|
return "RENAME TABLE " + this->schema.data()->quoteTableName(tableName) + " TO " + this->schema.data()->quoteTableName(
|
||
|
return "RENAME TABLE " + this->schema.data()->quoteTableName(
|
||
|
tableName) + " TO " +
|
||
|
this->schema.data()->quoteTableName(
|
||
|
newName);
|
||
|
}
|
||
|
|
||
| ... | ... | |
|
return "TRUNCATE TABLE " + this->schema.data()->quoteTableName(tableName);
|
||
|
}
|
||
|
|
||
|
QString QueryBuilder::addColumn(QString tableName, QString columnName, QString columnType) const {
|
||
|
return "ALTER TABLE " + this->schema.data()->quoteTableName(tableName) + " ADD " + this->schema.data()->quoteColumnName(
|
||
|
QString QueryBuilder::addColumn(QString tableName, QString columnName,
|
||
|
QString columnType) const {
|
||
|
return "ALTER TABLE " + this->schema.data()->quoteTableName(
|
||
|
tableName) + " ADD " +
|
||
|
this->schema.data()->quoteColumnName(
|
||
|
columnName) + " " + this->getColumnType(columnType);
|
||
|
}
|
||
|
|
||
|
QString QueryBuilder::dropColumn(QString tableName, QString columName) const {
|
||
|
return "ALTER TABLE " + this->schema.data()->quoteTableName(tableName) + " DROP COLUMN " +
|
||
|
return "ALTER TABLE " + this->schema.data()->quoteTableName(
|
||
|
tableName) + " DROP COLUMN " +
|
||
|
this->schema.data()->quoteColumnName(columName);
|
||
|
}
|
||
|
|
||
|
QString QueryBuilder::renameColumn(QString tableName, QString oldName, QString newName) const {
|
||
|
return "ALTER TABLE " + this->schema.data()->quoteTableName(tableName) + " RENAME COLUMN " +
|
||
|
this->schema.data()->quoteColumnName(oldName) + " TO " + this->schema.data()->quoteColumnName(newName);
|
||
|
QString QueryBuilder::renameColumn(QString tableName, QString oldName,
|
||
|
QString newName) const {
|
||
|
return "ALTER TABLE " + this->schema.data()->quoteTableName(
|
||
|
tableName) + " RENAME COLUMN " +
|
||
|
this->schema.data()->quoteColumnName(oldName) + " TO " +
|
||
|
this->schema.data()->quoteColumnName(
|
||
|
newName);
|
||
|
}
|
||
|
|
||
|
QString QueryBuilder::alterColumn(QString tableName, QString columnName, QString newType) const {
|
||
|
return "ALTER TABLE " + this->schema.data()->quoteTableName(tableName) + " CHANGE " +
|
||
|
QString QueryBuilder::alterColumn(QString tableName, QString columnName,
|
||
|
QString newType) const {
|
||
|
return "ALTER TABLE " + this->schema.data()->quoteTableName(
|
||
|
tableName) + " CHANGE " +
|
||
|
this->schema.data()->quoteColumnName(columnName) + " " +
|
||
|
this->schema.data()->quoteColumnName(columnName) + this->getColumnType(newType);
|
||
|
}
|
||
|
|
||
|
QString QueryBuilder::addPrimaryKey(QString name, QString tableName, QStringList columns) const {
|
||
|
return "ALTER TABLE " + this->schema.data()->quoteTableName(tableName) + " ADD CONSTRAINT " +
|
||
|
this->schema.data()->quoteColumnName(name) + "PRIMARY KEY (" + this->buildColumns(columns) + " )";
|
||
|
QString QueryBuilder::addPrimaryKey(QString name, QString tableName,
|
||
|
QStringList columns) const {
|
||
|
return "ALTER TABLE " + this->schema.data()->quoteTableName(
|
||
|
tableName) + " ADD CONSTRAINT " +
|
||
|
this->schema.data()->quoteColumnName(name) + "PRIMARY KEY (" +
|
||
|
this->buildColumns(columns) + " )";
|
||
|
}
|
||
|
|
||
|
QString QueryBuilder::dropPrimaryKey(QString name, QString tableName) const {
|
||
|
return "ALTER TABLE " + this->schema.data()->quoteTableName(tableName) + " DROP CONSTRAINT " +
|
||
|
return "ALTER TABLE " + this->schema.data()->quoteTableName(
|
||
|
tableName) + " DROP CONSTRAINT " +
|
||
|
this->schema.data()->quoteColumnName(name);
|
||
|
}
|
||
|
|
||
|
QString QueryBuilder::addForeignKey(QString name, QString tableName, QStringList columns, QString refTableName,
|
||
|
QStringList refColumns, QString deleteConstraint, QString updateConstraint) const {
|
||
|
QString r = "ALTER TABLE " + this->schema.data()->quoteTableName(tableName) + "ADD CONSTRAINT " +
|
||
|
QString QueryBuilder::addForeignKey(QString name, QString tableName,
|
||
|
QStringList columns,
|
||
|
QString refTableName,
|
||
|
QStringList refColumns, QString deleteConstraint,
|
||
|
QString updateConstraint) const {
|
||
|
QString r = "ALTER TABLE " + this->schema.data()->quoteTableName(
|
||
|
tableName) + "ADD CONSTRAINT " +
|
||
|
this->schema.data()->quoteColumnName(name)
|
||
|
+ " FOREIGN KEY (" + this->buildColumns(columns) + ")" + " REFERENCES " + this->schema.data()->quoteTableName(
|
||
|
+ " FOREIGN KEY (" + this->buildColumns(columns) + ")" + " REFERENCES " +
|
||
|
this->schema.data()->quoteTableName(
|
||
|
refTableName) +
|
||
|
" (" + this->buildColumns(refColumns) + ")";
|
||
|
if (!deleteConstraint.isEmpty()) {
|
||
| ... | ... | |
|
}
|
||
|
|
||
|
QString QueryBuilder::dropForeignKey(QString name, QString tableName) const {
|
||
|
return "ALTER TABLE " + this->schema.data()->quoteTableName(tableName) + " DROP CONSTRAINT " +
|
||
|
return "ALTER TABLE " + this->schema.data()->quoteTableName(
|
||
|
tableName) + " DROP CONSTRAINT " +
|
||
|
this->schema.data()->quoteColumnName(name);
|
||
|
}
|
||
|
|
||
|
QString QueryBuilder::createIndex(QString name, QString tableName, QStringList columns, bool unique) const {
|
||
|
QString s = (unique ? "CREATE UNIQUE INDEX " : "CREATE INDEX ") + this->schema.data()->quoteTableName(
|
||
|
QString QueryBuilder::createIndex(QString name, QString tableName,
|
||
|
QStringList columns,
|
||
|
bool unique) const {
|
||
|
QString s = (unique ? "CREATE UNIQUE INDEX " : "CREATE INDEX ") +
|
||
|
this->schema.data()->quoteTableName(
|
||
|
name) + " ON " + this->schema.data()->quoteTableName(tableName) + " (";
|
||
|
s.append(this->buildColumns(columns));
|
||
|
s.append(");");
|
||
| ... | ... | |
|
}
|
||
|
|
||
|
QString QueryBuilder::dropIndex(QString name, QString tableName) const {
|
||
|
return "DROP INDEX " + this->schema.data()->quoteTableName(name) + " ON " + this->schema.data()->quoteTableName(
|
||
|
return "DROP INDEX " + this->schema.data()->quoteTableName(name) + " ON " +
|
||
|
this->schema.data()->quoteTableName(
|
||
|
tableName);
|
||
|
}
|
||
|
|
||
| ... | ... | |
|
database = value;
|
||
|
}
|
||
|
|
||
|
QString QueryBuilder::buildCreateQuery(QHash<QString, QVariant>::const_iterator i,
|
||
|
QString QueryBuilder::buildCreateQuery(QHash<QString, QVariant>::const_iterator
|
||
|
i,
|
||
|
QHash<QString, QVariant>::const_iterator end,
|
||
|
QString &p1, QString &p2) const {
|
||
|
bool first = true;
|
||
| ... | ... | |
|
return p1 + p2;
|
||
|
}
|
||
|
|
||
|
QHash<QString, QString> QueryBuilder::generateTableDefinition(const QSharedPointer<Entity> &entity) const {
|
||
|
QHash<QString, QString> QueryBuilder::generateTableDefinition(
|
||
|
const QSharedPointer<Entity> &entity)
|
||
|
const {
|
||
|
auto map = QHash<QString, QString>();
|
||
|
auto o = entity.data()->metaObject();
|
||
|
QHash<QString, Relation> relations = entity.data()->getRelations();
|
||
| ... | ... | |
|
if (m.name() != QString("objectName") && m.isReadable()
|
||
|
&& !entity.data()->getTransientAttributes().contains(m.name())) {
|
||
|
if (m.isEnumType()) {
|
||
|
map.insert(m.name(), this->schema.data()->getTypeMap().data()->value(this->schema.data()->TYPE_INTEGER));
|
||
|
map.insert(m.name(), this->schema.data()->getTypeMap().data()->value(
|
||
|
this->schema.data()->TYPE_INTEGER));
|
||
|
} else if (relations.contains(m.name())) {
|
||
|
Relation r = relations.value(m.name());
|
||
|
if (r.getType() == RelationType::MANY_TO_ONE || (r.getType() == RelationType::ONE_TO_ONE
|
||
|
&& r.getMappedBy().isEmpty())) {
|
||
|
if (r.getType() == RelationType::MANY_TO_ONE
|
||
|
|| (r.getType() == RelationType::ONE_TO_ONE
|
||
|
&& r.getMappedBy().isEmpty())) {
|
||
|
map.insert(QString(m.name()) + "_id", this->schema.data()->TYPE_BIGINT);
|
||
|
}
|
||
|
} else if (entity.data()->getBLOBColumns().contains(m.name())) {
|
||
|
map.insert(m.name(), this->schema.data()->getTypeMap().data()->value(this->schema.data()->TYPE_BINARY));
|
||
|
map.insert(m.name(), this->schema.data()->getTypeMap().data()->value(
|
||
|
this->schema.data()->TYPE_BINARY));
|
||
|
} else {
|
||
|
map.insert(m.name(), this->transformAbstractTypeToRealDbType(this->transformTypeToAbstractDbType(m.typeName())));
|
||
|
map.insert(m.name(), this->transformAbstractTypeToRealDbType(
|
||
|
this->transformTypeToAbstractDbType(
|
||
|
m.typeName())));
|
||
|
}
|
||
|
}
|
||
|
}
|
||
| ... | ... | |
|
return map;
|
||
|
}
|
||
|
|
||
|
QString QueryBuilder::generateManyToManyTableName(const QSharedPointer<Entity> &firstEntity,
|
||
|
QString QueryBuilder::generateManyToManyTableName(const QSharedPointer<Entity>
|
||
|
&firstEntity,
|
||
|
const QSharedPointer<Entity> &secondEntity) const {
|
||
|
return QString(firstEntity.data()->metaObject()->className()).toLower() + "_" + QString(
|
||
|
return QString(firstEntity.data()->metaObject()->className()).toLower() + "_" +
|
||
|
QString(
|
||
|
secondEntity.data()->metaObject()->className()).toLower();
|
||
|
}
|
||
|
|
||
|
QHash<QString, QHash<QString, QString>> QueryBuilder::generateRelationTables(const QSharedPointer<Entity> &entity)
|
||
|
QHash<QString, QHash<QString, QString>> QueryBuilder::generateRelationTables(
|
||
|
const QSharedPointer<Entity> &entity)
|
||
|
const {
|
||
|
auto relations = QHash<QString, QHash<QString, QString>>();
|
||
|
QHash<QString, Relation> m = entity.data()->getRelations();
|
||
| ... | ... | |
|
if (r.getType() == MANY_TO_MANY && r.getMappedBy().isEmpty()) {
|
||
|
QHash<QString, QString> h = QHash<QString, QString>();
|
||
|
h.insert("id", this->schema.data()->TYPE_BIGPK);
|
||
|
h.insert(this->generateManyToManyColumnName(entity), this->schema.data()->TYPE_BIGINT);
|
||
|
h.insert(this->generateManyToManyColumnName(entity),
|
||
|
this->schema.data()->TYPE_BIGINT);
|
||
|
auto m = props.value(r.getPropertyName());
|
||
|
Entity *e = EntityInstanceFactory::createInstance(m.type());
|
||
|
QSharedPointer<Entity> ptr = QSharedPointer<Entity>(e);
|
||
| ... | ... | |
|
return this->schema.data()->TYPE_TEXT;
|
||
|
}
|
||
|
|
||
|
QString QueryBuilder::transformAbstractTypeToRealDbType(QString typeName) const {
|
||
|
QString QueryBuilder::transformAbstractTypeToRealDbType(
|
||
|
QString typeName) const {
|
||
|
return this->schema.data()->getTypeMap().data()->value(typeName);
|
||
|
}
|
||
|
|
||
| ... | ... | |
|
}
|
||
|
//cant believe that this could work in Qt
|
||
|
//https://github.com/yiisoft/yii2/blob/master/framework/db/QueryBuilder.php
|
||
|
QRegularExpression reg = QRegularExpression(QRegularExpression::escape("/^(\\w+)\((.+?)\\)(.*)$/"));
|
||
|
QRegularExpression reg = QRegularExpression(
|
||
|
QRegularExpression::escape("/^(\\w+)\((.+?)\\)(.*)$/"));
|
||
|
reg.optimize();
|
||
|
QRegularExpressionMatchIterator i = reg.globalMatch(type, 0, QRegularExpression::PartialPreferFirstMatch);
|
||
|
QRegularExpressionMatchIterator i = reg.globalMatch(type, 0,
|
||
|
QRegularExpression::PartialPreferFirstMatch);
|
||
|
short s = 0;
|
||
|
bool ok = false;
|
||
|
QString before = "";
|
||
| ... | ... | |
|
ok = true;
|
||
|
}
|
||
|
if (ok) {
|
||
|
return before.replace(QRegularExpression::escape("/\\(.+\\)/"), "(" + i.next().captured() + ")");
|
||
|
return before.replace(QRegularExpression::escape("/\\(.+\\)/"),
|
||
|
"(" + i.next().captured() + ")");
|
||
|
}
|
||
|
s++;
|
||
|
}
|
||
| ... | ... | |
|
* @return
|
||
|
*/
|
||
|
QSqlQuery QueryBuilder::find(const qint64 &id, const QString &tableName) const {
|
||
|
QSqlQuery q = this->database.data()->getQuery("SELECT * FROM " + this->schema.data()->quoteTableName(
|
||
|
QSqlQuery q = this->database.data()->getQuery("SELECT * FROM " +
|
||
|
this->schema.data()->quoteTableName(
|
||
|
tableName) + " WHERE id= :id LIMIT 1;");
|
||
|
q.bindValue(":id", id);
|
||
|
return q;
|
||
| ... | ... | |
|
* @param ignoreID
|
||
|
* @return
|
||
|
*/
|
||
|
QSqlQuery QueryBuilder::findByAttributes(const QHash<QString, QVariant> &m, const QString &tableName,
|
||
|
QSqlQuery QueryBuilder::findByAttributes(const QHash<QString, QVariant> &m,
|
||
|
const QString &tableName,
|
||
|
const bool &ignoreID, const qint64 limit, const qint64 offset) const {
|
||
|
QSqlQuery q = this->database.data()->getQuery("SELECT * FROM " + this->schema.data()->quoteTableName(
|
||
|
QSqlQuery q = this->database.data()->getQuery("SELECT * FROM " +
|
||
|
this->schema.data()->quoteTableName(
|
||
|
tableName) + this->where(m, "AND", ignoreID) + this->limit(limit, offset));
|
||
|
this->bindValues(m, q, ignoreID);
|
||
|
return q;
|
||
|
}
|
||
|
|
||
|
QSqlQuery QueryBuilder::findByAttributes(const QSharedPointer<Entity> &e, bool ignoreID, const qint64 limit,
|
||
|
QSqlQuery QueryBuilder::findByAttributes(const QSharedPointer<Entity> &e,
|
||
|
bool ignoreID,
|
||
|
const qint64 limit,
|
||
|
const qint64 offset) {
|
||
|
QHash<QString, QVariant> values = this->getEntityAttributes(e.data()->getMetaProperties(), e);
|
||
|
return this->findByAttributes(values, e.data()->getTablename(), ignoreID, limit, offset);
|
||
|
QHash<QString, QVariant> values = this->getEntityAttributes(
|
||
|
e.data()->getMetaProperties(), e);
|
||
|
return this->findByAttributes(values, e.data()->getTablename(), ignoreID, limit,
|
||
|
offset);
|
||
|
}
|
||
|
|
||
|
QSqlQuery QueryBuilder::findAll(const QString &tableName) const {
|
||
|
return this->database->getQuery("SELECT * FROM " + this->schema.data()->quoteTableName(
|
||
|
return this->database->getQuery("SELECT * FROM " +
|
||
|
this->schema.data()->quoteTableName(
|
||
|
tableName) + ";");
|
||
|
}
|
||
|
|
||
|
QSqlQuery QueryBuilder::remove(const QSharedPointer<Entity> &entity) const {
|
||
|
QSqlQuery q = this->database->getQuery("DELETE FROM " + this->schema.data()->quoteTableName(
|
||
|
entity.data()->getTablename()) + " WHERE " + this->schema.data()->quoteColumnName("id") + "=:id;");
|
||
|
QSqlQuery q = this->database->getQuery("DELETE FROM " +
|
||
|
this->schema.data()->quoteTableName(
|
||
|
entity.data()->getTablename()) + " WHERE " +
|
||
|
this->schema.data()->quoteColumnName("id") + "=:id;");
|
||
|
q.bindValue(":id", entity.data()->getId());
|
||
|
return q;
|
||
|
}
|
||
|
|
||
|
QSqlQuery QueryBuilder::findId(const QSharedPointer<Entity> &entity) const {
|
||
|
QHash<QString, QVariant> values = this->getEntityAttributes(entity.data()->getMetaProperties(), entity);
|
||
|
QSqlQuery q = this->database.data()->getQuery("SELECT " + this->schema.data()->quoteColumnName("id") + " FROM " +
|
||
|
QHash<QString, QVariant> values = this->getEntityAttributes(
|
||
|
entity.data()->getMetaProperties(),
|
||
|
entity);
|
||
|
QSqlQuery q = this->database.data()->getQuery("SELECT " +
|
||
|
this->schema.data()->quoteColumnName("id")
|
||
|
+ " FROM " +
|
||
|
this->schema.data()->quoteTableName(
|
||
|
entity.data()->getTablename()) + this->where(values,
|
||
|
"AND", true) + " LIMIT 1");
|
||
| ... | ... | |
|
return q;
|
||
|
}
|
||
|
|
||
|
QSqlQuery QueryBuilder::count(const QSharedPointer<Entity> &entity, bool ignoreID) const {
|
||
|
QHash<QString, QVariant> values = this->getEntityAttributes(entity.data()->getMetaProperties(), entity);
|
||
|
QSqlQuery q = this->database.data()->getQuery("SELECT COUNT(*) FROM " + this->schema.data()->quoteTableName(
|
||
|
QSqlQuery QueryBuilder::count(const QSharedPointer<Entity> &entity,
|
||
|
bool ignoreID) const {
|
||
|
QHash<QString, QVariant> values = this->getEntityAttributes(
|
||
|
entity.data()->getMetaProperties(),
|
||
|
entity);
|
||
|
QSqlQuery q = this->database.data()->getQuery("SELECT COUNT(*) FROM " +
|
||
|
this->schema.data()->quoteTableName(
|
||
|
entity.data()->getTablename()) + this->where(
|
||
|
values, "AND", ignoreID));
|
||
|
this->bindValues(values, q, ignoreID);
|
||
| ... | ... | |
|
}
|
||
|
|
||
|
QSqlQuery QueryBuilder::count(const QString &tableName) const {
|
||
|
QSqlQuery q = this->database.data()->getQuery("SELECT COUNT(*) FROM " + this->schema.data()->quoteTableName(
|
||
|
QSqlQuery q = this->database.data()->getQuery("SELECT COUNT(*) FROM " +
|
||
|
this->schema.data()->quoteTableName(
|
||
|
tableName) + ";");
|
||
|
return q;
|
||
|
}
|
||
|
|
||
|
QSqlQuery QueryBuilder::merge(const QSharedPointer<Entity> &entity) const {
|
||
|
QHash<QString, QVariant> values = this->saveAttributes(entity);
|
||
|
QSqlQuery q = this->database.data()->getQuery("UPDATE " + this->schema.data()->quoteTableName(
|
||
|
QSqlQuery q = this->database.data()->getQuery("UPDATE " +
|
||
|
this->schema.data()->quoteTableName(
|
||
|
entity->getTablename()) + " SET " + this->attributes(
|
||
|
values) + " WHERE " + this->schema.data()->quoteColumnName("id") + "=:id;");
|
||
|
this->bindValues(values, q);
|
||
| ... | ... | |
|
QHash<QString, QVariant> values = this->saveAttributes(entity);
|
||
|
values.remove("id");
|
||
|
QSqlQuery q = this->database.data()->getQuery();
|
||
|
QString p1 = "INSERT INTO " + this->schema.data()->quoteTableName(entity->getTablename()) + "(";
|
||
|
QString p1 = "INSERT INTO " + this->schema.data()->quoteTableName(
|
||
|
entity->getTablename()) + "(";
|
||
|
QString p2 = "VALUES(";
|
||
|
if (!values.isEmpty()) {
|
||
|
q.prepare(this->buildCreateQuery(values.constBegin(), values.constEnd(),
|
||
| ... | ... | |
|
return q;
|
||
|
}
|
||
|
|
||
|
QSqlQuery QueryBuilder::oneToMany(const QString &tableName, const QString &attribute, const qint64 &id,
|
||
|
QSqlQuery QueryBuilder::oneToMany(const QString &tableName,
|
||
|
const QString &attribute,
|
||
|
const qint64 &id,
|
||
|
const qint64 &limit) {
|
||
|
QHash<QString, QVariant> values = QHash<QString, QVariant>();
|
||
|
values.insert(attribute, id);
|
||
|
return this->findByAttributes(values, tableName, false, limit);
|
||
|
}
|
||
|
|
||
|
QSqlQuery QueryBuilder::manyToMany(const QString &tableName, const QString &attribute, const qint64 &id,
|
||
|
QSqlQuery QueryBuilder::manyToMany(const QString &tableName,
|
||
|
const QString &attribute,
|
||
|
const qint64 &id,
|
||
|
const QString &foreignKey, const QString &foreignTable) {
|
||
|
QSqlQuery q = this->database.data()->getQuery();
|
||
|
QString sql = "SELECT " + this->schema.data()->quoteTableName(foreignTable) + ".* FROM " +
|
||
|
this->schema.data()->quoteTableName(tableName) + " " + this->leftJoin(foreignTable, tableName,
|
||
|
foreignKey) + " WHERE " + this->schema.data()->quoteColumnName(attribute) + "=:id;";
|
||
|
QString sql = "SELECT " + this->schema.data()->quoteTableName(
|
||
|
foreignTable) + ".* FROM " +
|
||
|
this->schema.data()->quoteTableName(tableName) + " " + this->leftJoin(
|
||
|
foreignTable, tableName,
|
||
|
foreignKey) + " WHERE " + this->schema.data()->quoteColumnName(
|
||
|
attribute) + "=:id;";
|
||
|
q.prepare(sql);
|
||
|
q.bindValue(":id", id);
|
||
|
return q;
|
||
|
}
|
||
|
|
||
|
|
||
|
QString QueryBuilder::leftJoin(const QString &foreignTable, const QString &tableName, const QString &foreignKey) {
|
||
|
return "LEFT JOIN " + this->schema.data()->quoteTableName(foreignTable) + " ON " +
|
||
|
this->schema.data()->quoteColumnName(foreignTable + ".id") + "=" + this->schema.data()->quoteColumnName(
|
||
|
QString QueryBuilder::leftJoin(const QString &foreignTable,
|
||
|
const QString &tableName,
|
||
|
const QString &foreignKey) {
|
||
|
return "LEFT JOIN " + this->schema.data()->quoteTableName(
|
||
|
foreignTable) + " ON " +
|
||
|
this->schema.data()->quoteColumnName(foreignTable + ".id") + "=" +
|
||
|
this->schema.data()->quoteColumnName(
|
||
|
tableName + "." + foreignKey);
|
||
|
}
|
||
|
|
||
| ... | ... | |
|
return s;
|
||
|
}
|
||
|
|
||
|
QString QueryBuilder::generateManyToManyColumnName(const QSharedPointer<Entity> &entity) const {
|
||
|
QString QueryBuilder::generateManyToManyColumnName(const QSharedPointer<Entity>
|
||
|
&entity) const {
|
||
|
return QString(entity.data()->metaObject()->className()) + QString("_id");
|
||
|
}
|
||
|
|
||
| ... | ... | |
|
return this->database.data()->getQuery();
|
||
|
}
|
||
|
|
||
|
QHash<QString, QVariant> QueryBuilder::saveAttributes(const QSharedPointer<Entity> &entity) const {
|
||
|
QHash<QString, QVariant> QueryBuilder::saveAttributes(const
|
||
|
QSharedPointer<Entity> &entity) const {
|
||
|
auto props = entity.data()->getMetaProperties();
|
||
|
auto values = this->getEntityAttributes(props, entity);
|
||
|
auto relValues = this->getManyToOneAttributes(props, entity);
|
||
| ... | ... | |
|
return values;
|
||
|
}
|
||
|
|
||
|
QHash<QString, QVariant> QueryBuilder::getEntityAttributes(const QHash<QString, QMetaProperty> &props,
|
||
|
const QSharedPointer<Entity> &entity) const {
|
||
|
QHash<QString, QVariant> QueryBuilder::getEntityAttributes(
|
||
|
const QHash<QString, QMetaProperty>
|
||
|
&props,
|
||
|
const QSharedPointer<Entity> &entity) const {
|
||
|
Entity *e = entity.data();
|
||
|
auto map = QHash<QString, QVariant>();
|
||
|
auto transientAttrs = e->getTransientAttributes();
|
||
| ... | ... | |
|
return map;
|
||
|
}
|
||
|
|
||
|
QHash<QString, QVariant> QueryBuilder::getManyToOneAttributes(const QHash<QString, QMetaProperty> &props,
|
||
|
const QSharedPointer<Entity> &entity) const {
|
||
|
QHash<QString, QVariant> QueryBuilder::getManyToOneAttributes(
|
||
|
const QHash<QString, QMetaProperty>
|
||
|
&props,
|
||
|
const QSharedPointer<Entity> &entity) const {
|
||
|
Entity *e = entity.data();
|
||
|
auto map = QHash<QString, QVariant>();
|
||
|
auto relations = e->getRelations();
|
||
| ... | ... | |
|
if (v.canConvert<Entity *>()) {
|
||
|
this->insertRelationId(qvariant_cast<Entity *>(v), map, i.key());
|
||
|
} else if (v.canConvert<QSharedPointer<Entity>>()) {
|
||
|
this->insertRelationId(qvariant_cast<QSharedPointer<Entity>>(v).data(), map, i.key());
|
||
|
this->insertRelationId(qvariant_cast<QSharedPointer<Entity>>(v).data(), map,
|
||
|
i.key());
|
||
|
} else if (v.canConvert<QPointer<Entity>>()) {
|
||
|
this->insertRelationId(qvariant_cast<QPointer<Entity>>(v).data(), map, i.key());
|
||
|
}
|
||
| ... | ... | |
|
return map;
|
||
|
}
|
||
|
|
||
|
void QueryBuilder::insertRelationId(const Entity *e, QHash<QString, QVariant> &map, QString relName) const {
|
||
|
void QueryBuilder::insertRelationId(const Entity *e,
|
||
|
QHash<QString, QVariant> &map,
|
||
|
QString relName) const {
|
||
|
if (e && e->getId() > -1) {
|
||
|
map.insert(relName + "_id", e->getId());
|
||
|
}
|
||
| ... | ... | |
|
return r;
|
||
|
}
|
||
|
|
||
|
void QueryBuilder::bindValues(const QHash<QString, QVariant> &h, QSqlQuery &q, bool ignoreID) const {
|
||
|
void QueryBuilder::bindValues(const QHash<QString, QVariant> &h, QSqlQuery &q,
|
||
|
bool ignoreID) const {
|
||
|
QHash<QString, QVariant>::const_iterator i = h.constBegin();
|
||
|
while (i != h.constEnd()) {
|
||
|
if (!ignoreID || (ignoreID && !(i.key() == "id"))) {
|
||
| ... | ... | |
|
}
|
||
|
}
|
||
|
|
||
|
QString QueryBuilder::where(const QSharedPointer<Entity> &entity, QString conjunction, bool ignoreID) const {
|
||
|
return this->where(this->getEntityAttributes(entity.data()->getMetaProperties(), entity), conjunction, ignoreID);
|
||
|
QString QueryBuilder::where(const QSharedPointer<Entity> &entity,
|
||
|
QString conjunction,
|
||
|
bool ignoreID) const {
|
||
|
return this->where(this->getEntityAttributes(entity.data()->getMetaProperties(),
|
||
|
entity),
|
||
|
conjunction, ignoreID);
|
||
|
}
|
||
|
|
||
|
QString QueryBuilder::where(const QHash<QString, QVariant> &m, const QString &conjunction, bool ignoreID) const {
|
||
|
QString QueryBuilder::where(const QHash<QString, QVariant> &m,
|
||
|
const QString &conjunction,
|
||
|
bool ignoreID) const {
|
||
|
if (m.size() == 0 || (ignoreID && m.contains("id") && m.size() == 1)) {
|
||
|
return "";
|
||
|
}
|
||
|
return " WHERE " + this->attributes(m, conjunction, ignoreID);
|
||
|
}
|
||
|
|
||
|
QString QueryBuilder::attributes(const QHash<QString, QVariant> &m, const QString &conjunction, bool ignoreID) const {
|
||
|
QString QueryBuilder::attributes(const QHash<QString, QVariant> &m,
|
||
|
const QString &conjunction,
|
||
|
bool ignoreID) const {
|
||
|
QString rc = "";
|
||
|
if (!m.isEmpty()) {
|
||
|
QHash<QString, QVariant>::const_iterator i = m.constBegin();
|
||
Auch abrufbar als: Unified diff
formatting