Revision 94bf67c7
Von Christian Ehringfeld vor fast 9 Jahren hinzugefügt
| src/querybuilder.cpp | ||
|---|---|---|
|
if (!rc) {
|
||
|
QSqlQuery q = this->database->getQuery(this->createTable(tableName,
|
||
|
tableDefinition));
|
||
|
if (this->database->transaction(q)) {
|
||
|
if (this->database->exec(q)) {
|
||
|
if (createRelationTables) {
|
||
|
auto relTables = this->generateRelationTables(entity);
|
||
|
auto i = relTables.constBegin();
|
||
| ... | ... | |
|
first = false;
|
||
|
}
|
||
|
p1 += this->schema->quoteColumnName(i.key());
|
||
|
p2 += ":" + i.key();
|
||
|
p2 += this->placeHolder(i.key());
|
||
|
++i;
|
||
|
}
|
||
|
p1 += ")";
|
||
| ... | ... | |
|
* @return
|
||
|
*/
|
||
|
QSqlQuery QueryBuilder::find(const qint64 &id, const QString &tableName) const {
|
||
|
QString pk = "id";
|
||
|
QSqlQuery q = this->database->getQuery(this->selectBase(QStringList(
|
||
|
tableName)) + " WHERE id= :id LIMIT 1;");
|
||
|
q.bindValue(":id", id);
|
||
|
tableName)) + " WHERE " + pk + " = " + this->placeHolder(pk) + " LIMIT 1;");
|
||
|
this->bindValue(pk, id, q);
|
||
|
return q;
|
||
|
}
|
||
|
|
||
| ... | ... | |
|
QSqlQuery q = this->database->getQuery(this->selectBase(QStringList(
|
||
|
entity->getTablename())) + this->joinSuperClasses(
|
||
|
entity) + " WHERE " + this->schema->quoteColumnName(
|
||
|
pk) + "= :id" + this->limit(1, offset));
|
||
|
q.bindValue(":id", id);
|
||
|
pk) + "= " + this->placeHolder(pk) + this->limit(1, offset));
|
||
|
this->bindValue(pk, id, q);
|
||
|
return q;
|
||
|
}
|
||
|
|
||
| ... | ... | |
|
QSqlQuery q = this->database->getQuery("DELETE FROM " +
|
||
|
this->schema->quoteTableName(
|
||
|
tableName) + " WHERE " +
|
||
|
this->schema->quoteColumnName(primaryKey) + "=:id;");
|
||
|
q.bindValue(":id", id);
|
||
|
this->schema->quoteColumnName(primaryKey) + "=" + this->placeHolder(
|
||
|
primaryKey) + ";");
|
||
|
this->bindValue(primaryKey, id, q);
|
||
|
return q;
|
||
|
}
|
||
|
|
||
| ... | ... | |
|
&entity, bool insert) const {
|
||
|
const QList<ClassAttributes> attrs = this->inheritedAttributes(entity);
|
||
|
auto queries = QList<QSqlQuery>();
|
||
|
bool first = true;
|
||
|
for (int var = 0; var < attrs.size(); ++var) {
|
||
|
auto attr = attrs.at(var);
|
||
|
auto attrHash = attr.getAttributes();
|
||
|
queries.append(insert ? this->insert(attr.getName(), attrHash,
|
||
|
attr.getPk()) : this->update(attr.getName(), attrHash, attr.getPk()));
|
||
|
attr.getPk(), !first) : this->update(attr.getName(), attrHash, attr.getPk()));
|
||
|
if (first) {
|
||
|
first = false;
|
||
|
}
|
||
|
}
|
||
|
return queries;
|
||
|
}
|
||
| ... | ... | |
|
}
|
||
|
|
||
|
QSqlQuery QueryBuilder::insert(const QString &tableName,
|
||
|
QHash<QString, QVariant> &attributes, const QString &primaryKey) const {
|
||
|
//if(attributes.size() == 1) {
|
||
|
// attributes.insert(primaryKey,QVariant("null"));
|
||
|
// } else {
|
||
|
attributes.remove(primaryKey);
|
||
|
// }
|
||
|
QHash<QString, QVariant> &attributes, const QString &primaryKey,
|
||
|
bool withId) const {
|
||
|
if (!withId) {
|
||
|
attributes.remove(primaryKey);
|
||
|
}
|
||
|
QSqlQuery q = this->database->getQuery();
|
||
|
QString p1 = "INSERT INTO " + this->schema->quoteTableName(
|
||
|
tableName) + "(";
|
||
| ... | ... | |
|
|
||
|
QSqlQuery QueryBuilder::update(const QString &tableName,
|
||
|
QHash<QString, QVariant> &attributes, const QString &primaryKey) const {
|
||
|
QSqlQuery q = this->database->getQuery("UPDATE " +
|
||
|
this->schema->quoteTableName(tableName) + " SET " + this->attributes(
|
||
|
attributes) + " WHERE " + this->schema->quoteColumnName(
|
||
|
primaryKey) + "=:id;");
|
||
|
QSqlQuery q = this->database->getQuery("UPDATE " + this->schema->quoteTableName(
|
||
|
tableName) + " SET " + this->attributes(attributes) + " WHERE " +
|
||
|
this->schema->quoteColumnName(primaryKey) + " = " + this->placeHolder(
|
||
|
primaryKey) + ";");
|
||
|
this->bindValues(attributes, q);
|
||
|
return q;
|
||
|
}
|
||
| ... | ... | |
|
const qint64 &id) {
|
||
|
QSqlQuery q = this->database->getQuery();
|
||
|
QString sql = this->selectBase(QStringList(tableName), QStringList("*"));
|
||
|
QString pk = "id";
|
||
|
sql += " WHERE ";
|
||
|
sql += this->schema->quoteColumnName(
|
||
|
attribute);
|
||
|
sql += " = :id;";
|
||
|
sql += " = " + this->placeHolder(pk) + ";";
|
||
|
q.prepare(sql);
|
||
|
q.bindValue(":id", id);
|
||
|
this->bindValue(pk, id, q);
|
||
|
return q;
|
||
|
}
|
||
|
|
||
|
QSqlQuery QueryBuilder::manyToManyDelete(const QString &tableName,
|
||
|
const QString &attribute, const qint64 &id) {
|
||
|
QSqlQuery q = this->database->getQuery();
|
||
|
QString pkCol = "id";
|
||
|
QString sql = "DELETE FROM " + this->schema->quoteTableName(
|
||
|
tableName) + " WHERE " + this->schema->quoteColumnName(
|
||
|
attribute) + "=:id";
|
||
|
attribute) + "=" + this->placeHolder(pkCol);
|
||
|
q.prepare(sql);
|
||
|
q.bindValue(":id", id);
|
||
|
this->bindValue(pkCol, id, q);
|
||
|
return q;
|
||
|
}
|
||
|
|
||
| ... | ... | |
|
QHash<QString, QVariant>::const_iterator i = h.constBegin();
|
||
|
while (i != h.constEnd()) {
|
||
|
if (!ignoreID || (ignoreID && !(i.key() == primaryKey))) {
|
||
|
q.bindValue(":" + i.key(), i.value());
|
||
|
this->bindValue(i.key(), i.value(), q);
|
||
|
}
|
||
|
++i;
|
||
|
}
|
||
|
}
|
||
|
|
||
|
void QueryBuilder::bindValue(const QString &key, const QVariant &value,
|
||
|
QSqlQuery &q) const {
|
||
|
q.bindValue(this->placeHolder(key), value);
|
||
|
}
|
||
|
|
||
|
QString QueryBuilder::placeHolder(const QString &key) const {
|
||
|
return QString(":" + key);
|
||
|
}
|
||
|
|
||
|
QString QueryBuilder::where(const QSharedPointer<Entity> &entity,
|
||
|
QString conjunction,
|
||
|
bool ignoreID) const {
|
||
| ... | ... | |
|
if (!(rc == "")) {
|
||
|
rc += " " + conjunction + " ";
|
||
|
}
|
||
|
rc += this->schema->quoteColumnName(i.key()) + "=:" + i.key();
|
||
|
rc += this->schema->quoteColumnName(i.key()) + "=" + this->placeHolder(i.key());
|
||
|
}
|
||
|
++i;
|
||
|
}
|
||
Auch abrufbar als: Unified diff
improvements