Revision afde9013
Von Christian Ehringfeld vor fast 9 Jahren hinzugefügt
| src/entitymanager.cpp | ||
|---|---|---|
|
|
||
|
QStringList EntityManager::connectionNames = QStringList();
|
||
|
|
||
|
QStringList EntityManager::getConnectionNames() {
|
||
|
return EntityManager::connectionNames;
|
||
|
}
|
||
|
|
||
|
EntityManager::EntityManager(QSqlDatabase database) : QObject() {
|
||
|
auto db = new Database(database);
|
||
|
this->db = QSharedPointer<Database>(db);
|
||
|
this->init();
|
||
|
}
|
||
|
|
||
|
EntityManager::EntityManager(const QString &databaseType, QString databasename ,
|
||
|
QString hostname,
|
||
|
QString username,
|
||
|
QString password, QString port) : QObject() {
|
||
|
auto db = new Database(databaseType, this->createConnection(), hostname,
|
||
|
databasename, username,
|
||
|
password,
|
||
|
port.toInt());
|
||
|
this->db = QSharedPointer<Database>(db);
|
||
|
this->init();
|
||
|
}
|
||
|
|
||
|
void EntityManager::init() {
|
||
|
auto schema = Database::getSchema(Database::getDatabaseType(
|
||
|
this->db.data()->getDatabase().driverName()), this->db);
|
||
| ... | ... | |
|
this->schema.data()->setTables(this->schema.data()->getTableSchemas());
|
||
|
}
|
||
|
|
||
|
EntityManager::EntityManager(QSqlDatabase database) : QObject() {
|
||
|
auto db = new Database(database);
|
||
|
this->db = QSharedPointer<Database>(db);
|
||
|
this->init();
|
||
|
EntityManager::~EntityManager() {
|
||
|
EntityManager::removeConnectionName(this->db->getConnectionName());
|
||
|
}
|
||
|
|
||
|
bool EntityManager::startup(QString version, QStringList toInitialize) {
|
||
| ... | ... | |
|
return this->db.data()->transaction(query);
|
||
|
}
|
||
|
|
||
|
EntityManager::EntityManager(const QString &databaseType, QString databasename ,
|
||
|
QString hostname,
|
||
|
QString username,
|
||
|
QString password, QString port) : QObject() {
|
||
|
auto db = new Database(databaseType, this->createConnection(), hostname,
|
||
|
databasename, username,
|
||
|
password,
|
||
|
port.toInt());
|
||
|
this->db = QSharedPointer<Database>(db);
|
||
|
this->init();
|
||
|
}
|
||
|
|
||
|
bool EntityManager::checkTable(const QSharedPointer<Entity> &entity) {
|
||
|
bool rc = true;
|
||
|
if (!this->schema.data()->containsTable(entity.data()->getTablename())) {
|
||
| ... | ... | |
|
}
|
||
|
|
||
|
void EntityManager::refresh(QSharedPointer<Entity> &entity) {
|
||
|
entity = this->findById(entity.data()->getId(),
|
||
|
entity = this->findById(entity.data()->property(
|
||
|
entity.data()->getPrimaryKey()).toLongLong(),
|
||
|
QString(entity.data()->getClassname()));
|
||
|
}
|
||
|
|
||
| ... | ... | |
|
property.typeName());
|
||
|
QSharedPointer<Entity> ptr = QSharedPointer<Entity>();
|
||
|
if (refresh || !(this->cache.contains(convertedId, className)
|
||
|
&& (ptr = this->cache.get(convertedId, className)) && ptr.data())) {
|
||
|
&& (ptr = this->cache.get(convertedId, className)) && ptr)) {
|
||
|
ptr = this->findById(convertedId, className);
|
||
|
}
|
||
|
this->setProperty(entity, ptr, property);
|
||
| ... | ... | |
|
property.typeName()));
|
||
|
QSqlQuery q = this->schema.data()->getQueryBuilder().data()->oneToMany(
|
||
|
e->getTablename(),
|
||
|
r.getMappedBy() + "_id", entity.data()->getId());
|
||
|
this->schema.data()->getQueryBuilder().data()->generateColumnNameID(
|
||
|
r.getMappedBy()), entity.data()->getId());
|
||
|
auto listMap = this->convertQueryResult(q);
|
||
|
auto entities = this->convert(listMap, e->getClassname(), refresh);
|
||
|
delete e;
|
||
| ... | ... | |
|
property.typeName()));
|
||
|
QSqlQuery q = this->schema.data()->getQueryBuilder().data()->oneToMany(
|
||
|
e->getTablename(),
|
||
|
r.getMappedBy() + "_id", entity.data()->getId(), 1);
|
||
|
this->schema.data()->getQueryBuilder().data()->generateColumnNameID(
|
||
|
r.getMappedBy()),
|
||
|
entity.data()->property(entity.data()->getPrimaryKey()).toLongLong(), 1);
|
||
|
auto listMap = this->convertQueryResult(q);
|
||
|
auto entities = this->convert(listMap, e->getClassname(), refresh);
|
||
|
if (!entities.isEmpty()) {
|
||
| ... | ... | |
|
prop = props.value(r.getMappedBy());
|
||
|
}
|
||
|
}
|
||
|
if (ptr.data()->getId() > -1) {
|
||
|
q.bindValue(1, ptr.data()->getId());
|
||
|
if (ptr.data()->property(ptr.data()->getPrimaryKey()).toLongLong() > -1) {
|
||
|
q.bindValue(1, ptr.data()->property(ptr.data()->getPrimaryKey()));
|
||
|
q.exec();
|
||
|
if (prop.isValid()) {
|
||
|
this->addEntityToListProperty(entity, ptr, prop);
|
||
| ... | ... | |
|
|
||
|
bool EntityManager::shouldBeSaved(QSharedPointer<Entity> &entity,
|
||
|
const Relation &r) {
|
||
|
return entity.data() && (r.getCascadeType().contains(ALL)
|
||
|
|| (entity.data()->getId() > -1 && r.getCascadeType().contains(MERGE))
|
||
|
|| (entity.data()->getId() <= -1 && r.getCascadeType().contains(PERSIST)));
|
||
|
return entity && (r.getCascadeType().contains(ALL)
|
||
|
|| (entity.data()->property(entity.data()->getPrimaryKey()) > -1
|
||
|
&& r.getCascadeType().contains(MERGE))
|
||
|
|| (entity.data()->property(entity.data()->getPrimaryKey()) <= -1
|
||
|
&& r.getCascadeType().contains(PERSIST)));
|
||
|
}
|
||
|
|
||
|
void EntityManager::removeRelations(const QSharedPointer<Entity> &entity) {
|
||
| ... | ... | |
|
if (this->schema.data()->getTables().contains(tblName)) {
|
||
|
QSqlQuery q = builder.data()->manyToManyDelete(
|
||
|
tblName, builder.data()->generateManyToManyColumnName(e),
|
||
|
e.data()->getId());
|
||
|
e.data()->property(e.data()->getPrimaryKey()).toLongLong());
|
||
|
bool refresh = r.getCascadeType().contains(REFRESH)
|
||
|
|| r.getCascadeType().contains(ALL);
|
||
|
bool remove = r.getCascadeType().contains(REMOVE)
|
||
| ... | ... | |
|
if (this->schema.data()->getTables().contains(tblName)) {
|
||
|
QSqlQuery q = builder.data()->manyToManyDelete(
|
||
|
tblName, builder.data()->generateManyToManyColumnName(entity),
|
||
|
entity.data()->getId());
|
||
|
entity.data()->property(entity.data()->getPrimaryKey()).toLongLong());
|
||
|
if (this->db.data()->transaction(q)) {
|
||
|
this->persistMappedByRelation(list, q, entity, r, tblName);
|
||
|
}
|
||
| ... | ... | |
|
|
||
|
|
||
|
void EntityManager::manyToMany(const QSharedPointer<Entity> &entity,
|
||
|
const Relation &r,
|
||
|
const QMetaProperty &property, const bool refresh) {
|
||
|
Entity *secEntity = EntityInstanceFactory::createInstance(
|
||
|
EntityInstanceFactory::extractEntityType(
|
||
| ... | ... | |
|
*/
|
||
|
if (this->schema.data()->getTables().contains(tblName)) {
|
||
|
QSqlQuery q = builder.data()->manyToMany(tblName,
|
||
|
builder.data()->generateManyToManyColumnName(entity), entity.data()->getId(),
|
||
|
builder.data()->generateManyToManyColumnName(entity),
|
||
|
entity.data()->property(entity.data()->getPrimaryKey()).toLongLong(),
|
||
|
builder.data()->generateManyToManyColumnName(secEntityPtr),
|
||
|
secEntityPtr.data()->getTablename());
|
||
|
auto listMap = this->convertQueryResult(q);
|
||
| ... | ... | |
|
|
||
|
/**
|
||
|
* @todo should be an insert statement with many values
|
||
|
* not really usefull atm
|
||
|
* @brief EntityManager::create
|
||
|
* @param entities
|
||
|
* @return
|
||
| ... | ... | |
|
bool first = true;
|
||
|
for (int var = 0; var < q.size(); ++var) {
|
||
|
auto query = q.at(var);
|
||
|
query.exec();
|
||
|
rc = query.exec();
|
||
|
if (!rc) {
|
||
|
qDebug() << "Query failed:" << query.lastError().text();
|
||
|
break;
|
||
|
}
|
||
|
if (first) {
|
||
|
entity.data()->setProperty(entity.data()->getPrimaryKey(),
|
||
|
query.lastInsertId().toLongLong(&rc));
|
||
|
first = false;
|
||
|
}
|
||
|
}
|
||
|
if (!this->db->commitTransaction() || !rc) {
|
||
|
if (!rc || !this->db->commitTransaction()) {
|
||
|
this->db->rollbackTransaction();
|
||
|
entity.data()->setId(-1);
|
||
|
rc = false;
|
||
| ... | ... | |
|
return rc;
|
||
|
}
|
||
|
|
||
|
EntityManager::~EntityManager() {
|
||
|
EntityManager::removeConnectionName(this->db->getConnectionName());
|
||
|
}
|
||
|
|
||
|
QStringList EntityManager::getConnectionNames() {
|
||
|
return EntityManager::connectionNames;
|
||
|
bool EntityManager::merge(QSharedPointer<Entity> &entity, bool withRelations) {
|
||
|
if (entity->getId() > -1 && this->count(entity) == 1) {
|
||
|
this->db->startTransaction();
|
||
|
QList<QSqlQuery> q = this->schema.data()->getQueryBuilder().data()->merge(
|
||
|
entity);
|
||
|
bool ok = true;
|
||
|
for (int var = 0; var < q.size(); ++var) {
|
||
|
auto query = q.at(var);
|
||
|
ok = query.exec();
|
||
|
if (!ok) {
|
||
|
qDebug() << query.lastError().text();
|
||
|
break;
|
||
|
}
|
||
|
}
|
||
|
if (!ok || !this->db->commitTransaction()) {
|
||
|
this->db->rollbackTransaction();
|
||
|
return false;
|
||
|
} else if (ok && withRelations) {
|
||
|
this->saveRelations(entity);
|
||
|
}
|
||
|
}
|
||
|
return false;
|
||
|
}
|
||
|
|
||
|
QHash<QString, QVariant> EntityManager::findByPk(qint64 id,
|
||
|
const QSharedPointer<Entity>
|
||
|
&e) {
|
||
|
QSqlQuery q = this->schema.data()->getQueryBuilder().data()->find(id, e);
|
||
|
QSqlQuery q = this->schema.data()->getQueryBuilder().data()->find(id, e, 0,
|
||
|
e.data()->getPrimaryKey());
|
||
|
auto listMap = this->convertQueryResult(q);
|
||
|
if (!listMap.isEmpty()) {
|
||
|
return listMap.at(0);
|
||
| ... | ... | |
|
return this->convertQueryResult(q);
|
||
|
}
|
||
|
|
||
|
bool EntityManager::merge(QSharedPointer<Entity> &entity, bool withRelations) {
|
||
|
if (this->count(entity) == 0 && entity->getId() != -1) {
|
||
|
QSqlQuery q = this->schema.data()->getQueryBuilder().data()->merge(entity);
|
||
|
bool ok = this->db->transaction(q);
|
||
|
if (ok && withRelations) {
|
||
|
this->saveRelations(entity);
|
||
|
}
|
||
|
return ok;
|
||
|
} else {
|
||
|
return false;
|
||
|
}
|
||
|
}
|
||
|
|
||
|
QList<QHash<QString, QVariant> > EntityManager::convertQueryResult(
|
||
|
QSqlQuery &q) {
|
||
|
QList<QHash <QString, QVariant> > listmap = QList<QHash <QString, QVariant> >();
|
||
| ... | ... | |
|
const QMetaProperty property = iterator.value();
|
||
|
switch (r.getType()) {
|
||
|
case MANY_TO_ONE:
|
||
|
if (map.contains(r.getPropertyName()) + "_id") {
|
||
|
if (map.contains(
|
||
|
this->schema.data()->getQueryBuilder().data()->generateColumnNameID(
|
||
|
r.getPropertyName()))) {
|
||
|
this->manyToOne(entity, property.read(entity.data()), property, refresh);
|
||
|
}
|
||
|
break;
|
||
|
case MANY_TO_MANY:
|
||
|
this->manyToMany(entity, r, property, refresh);
|
||
|
this->manyToMany(entity, property, refresh);
|
||
|
break;
|
||
|
case ONE_TO_MANY:
|
||
|
this->oneToMany(entity, r, property, refresh);
|
||
| ... | ... | |
|
|
||
|
bool EntityManager::save(QSharedPointer<Entity> &entity,
|
||
|
const bool persistRelations) {
|
||
|
if (entity.data()->getId() > -1) {
|
||
|
if (entity.data()->property(entity.data()->getPrimaryKey()) > -1) {
|
||
|
return this->merge(entity, persistRelations);
|
||
|
} else {
|
||
|
return this->create(entity, persistRelations);
|
||
| src/entitymanager.h | ||
|---|---|---|
|
const QMetaProperty &property, const bool refresh = false);
|
||
|
void oneToMany(const QSharedPointer<Entity> &entity, const Relation &r,
|
||
|
const QMetaProperty &property, const bool refresh = false);
|
||
|
void manyToMany(const QSharedPointer<Entity> &entity, const Relation &r,
|
||
|
void manyToMany(const QSharedPointer<Entity> &entity,
|
||
|
const QMetaProperty &property, const bool refresh = false);
|
||
|
void oneToOne(const QSharedPointer<Entity> &entity, const Relation &r,
|
||
|
const QMetaProperty &property, const bool refresh = false,
|
||
| ... | ... | |
|
/**
|
||
|
*@TODO use conditions
|
||
|
*/
|
||
|
/**
|
||
|
* @TODO Inheritance at merge
|
||
|
*/
|
||
|
template<class T> qint8 count(QHash<QString, QString> condition =
|
||
|
QHash<QString, QString>()) {
|
||
|
Entity *e = EntityInstanceFactory::createInstance<T>();
|
||
| src/querybuilder.cpp | ||
|---|---|---|
|
}
|
||
|
|
||
|
QSqlQuery QueryBuilder::find(const qint64 &id,
|
||
|
const QSharedPointer<Entity> &entity, qint64 offset) const {
|
||
|
const QSharedPointer<Entity> &entity, qint64 offset, QString pk) const {
|
||
|
QSqlQuery q = this->database.data()->getQuery(this->selectBase(QStringList(
|
||
|
entity.data()->getTablename())) + this->joinSuperClasses(
|
||
|
entity) + " WHERE id= :id" + this->limit(1, offset));
|
||
|
entity) + " WHERE " + pk + "= :id" + this->limit(1, offset));
|
||
|
q.bindValue(":id", id);
|
||
|
return q;
|
||
|
}
|
||
| ... | ... | |
|
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(
|
||
|
entity->getTablename()) + " SET " + this->attributes(
|
||
|
values) + " WHERE " + this->schema.data()->quoteColumnName(
|
||
|
entity.data()->getPrimaryKey()) + "=:id;");
|
||
|
this->bindValues(values, q);
|
||
|
return q;
|
||
|
//@TODO Looks like create() - Refactor code
|
||
|
QList<QSqlQuery> QueryBuilder::merge(const QSharedPointer<Entity> &entity)
|
||
|
const {
|
||
|
auto attrs = this->inheritedAttributes(entity);
|
||
|
auto queries = QList<QSqlQuery>();
|
||
|
for (int var = 0; var < attrs.size(); ++var) {
|
||
|
auto attr = attrs.at(var);
|
||
|
auto attrHash = attr.getAttributes();
|
||
|
queries.append(this->update(attr.getName(), attrHash, attr.getPk()));
|
||
|
}
|
||
|
return queries;
|
||
|
}
|
||
|
|
||
|
QList<QSqlQuery> QueryBuilder::create(const QSharedPointer<Entity> &entity)
|
||
| ... | ... | |
|
return q;
|
||
|
}
|
||
|
|
||
|
QSqlQuery QueryBuilder::update(const QString &tableName,
|
||
|
QHash<QString, QVariant> &attributes, const QString &primaryKey) const {
|
||
|
QSqlQuery q = this->database.data()->getQuery("UPDATE " +
|
||
|
this->schema.data()->quoteTableName(tableName) + " SET " + this->attributes(
|
||
|
attributes) + " WHERE " + this->schema.data()->quoteColumnName(
|
||
|
primaryKey) + "=:id;");
|
||
|
this->bindValues(attributes, q);
|
||
|
return q;
|
||
|
}
|
||
|
|
||
|
|
||
|
QSqlQuery QueryBuilder::oneToMany(const QString &tableName,
|
||
|
const QString &attribute,
|
||
| src/querybuilder.h | ||
|---|---|---|
|
QString getColumnType(const QString &type) const;
|
||
|
QSqlQuery find(const qint64 &id, const QString &tableName) const;
|
||
|
QSqlQuery find(const qint64 &id, const QSharedPointer<Entity> &entity,
|
||
|
qint64 offset = 0) const;
|
||
|
qint64 offset = 0, QString pk = "id") const;
|
||
|
QSqlQuery findByAttributes(const QHash<QString, QVariant> &m,
|
||
|
const QString &tableName,
|
||
|
const bool &ignoreID = true, const qint64 limit = 0,
|
||
| ... | ... | |
|
QSqlQuery findId(const QSharedPointer<Entity> &entity) const;
|
||
|
QSqlQuery count(const QSharedPointer<Entity> &entity, bool ignoreID) const;
|
||
|
QSqlQuery count(const QString &tableName) const;
|
||
|
QSqlQuery merge(const QSharedPointer<Entity> &entity) const;
|
||
|
QList<QSqlQuery> merge(const QSharedPointer<Entity> &entity) const;
|
||
|
QList<QSqlQuery> create(const QSharedPointer<Entity> &entity) const;
|
||
|
QSqlQuery oneToMany(const QString &tableName, const QString &attribute,
|
||
|
const qint64 &id,
|
||
| ... | ... | |
|
QHash<QString, QVariant> attributes;
|
||
|
};
|
||
|
|
||
|
|
||
|
QSqlQuery remove(const QString &tableName, const qint64 &id,
|
||
|
const QString &primaryKey = "id") const;
|
||
|
QSqlQuery insert(const QString &tableName, QHash<QString, QVariant> &attributes,
|
||
|
const QString &primaryKey = "id") const;
|
||
|
QSqlQuery update(const QString &tableName, QHash<QString, QVariant> &attributes,
|
||
|
const QString &primaryKey = "id") const;
|
||
|
virtual void createRelationFK(QStringList &queries,
|
||
|
const QSharedPointer<Entity> &entity, const Relation &relation,
|
||
|
const QMetaProperty &metaProperty, const QString &update,
|
||
| ... | ... | |
|
virtual QString countFunction(const QString &distinctColumn = "") const;
|
||
|
virtual QString distinct() const;
|
||
|
|
||
|
|
||
|
QSharedPointer<Schema> schema;
|
||
|
QSharedPointer<Database> database;
|
||
|
};
|
||
Auch abrufbar als: Unified diff
inheritance merge