Herunterladen als
root/src/entitymanager.cpp @ a47954c0
81c23b56 | Christian Ehringfeld | /*
|
|
6899f814 | Christian Ehringfeld | * Copyright (C) 2015 Christian Ehringfeld <c.ehringfeld@t-online.de>
|
|
*
|
|||
* This program is free software; you can redistribute it and/or modify it
|
|||
* under the terms of the GNU Lesser General Public License as published by
|
|||
* the Free Software Foundation.
|
|||
*
|
|||
* This program is distributed in the hope that it will be useful, but
|
|||
* WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
|
|||
* or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
|
|||
* for more details.
|
|||
*
|
|||
* You should have received a copy of the GNU Lesser General Public License
|
|||
* along with this program; if not, see <http://www.gnu.org/licenses/>.
|
|||
*/
|
|||
81c23b56 | Christian Ehringfeld | ||
#include "entitymanager.h"
|
|||
7e233492 | Christian Ehringfeld | #include "enums/databasetype.h"
|
|
4d58ef6a | Christian Ehringfeld | using namespace CuteEntityManager;
|
|
81c23b56 | Christian Ehringfeld | /**
|
|
* Relationen fehlen noch
|
|||
* Fehlermeldungen erstellen am besten eine Exception Klasse diesbzgl. erstellen
|
|||
*/
|
|||
QStringList EntityManager::connectionNames = QStringList();
|
|||
7e233492 | Christian Ehringfeld | void EntityManager::init() {
|
|
auto schema = CuteEntityManager::getSchema(CuteEntityManager::getDatabaseType(
|
|||
this->db.data()->getDatabase().driverName()), this->db);
|
|||
this->schema = QSharedPointer<Schema>(schema);
|
|||
b0bf458e | Christian Ehringfeld | this->schema.data()->setTables(this->schema.data()->getTableSchemas());
|
|
7e233492 | Christian Ehringfeld | }
|
|
EntityManager::EntityManager(QSqlDatabase database) {
|
|||
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) {
|
|||
auto db = new Database(databaseType, this->createConnection(), hostname, databasename, username, password,
|
|||
port.toInt());
|
|||
this->db = QSharedPointer<Database>(db);
|
|||
this->init();
|
|||
}
|
|||
81c23b56 | Christian Ehringfeld | ||
b0bf458e | Christian Ehringfeld | bool EntityManager::checkTable(const QSharedPointer<Entity> &entity) {
|
|
bool rc = true;
|
|||
if (!this->schema.data()->containsTable(entity.data()->getTablename())) {
|
|||
if (this->schema.data()->getQueryBuilder().data()->createTable(entity)) {
|
|||
this->schema.data()->getTableSchema(entity.data()->getTablename(), true);
|
|||
rc = this->schema.data()->getTables().contains(entity.data()->getTablename());
|
|||
}
|
|||
}
|
|||
return rc;
|
|||
}
|
|||
9d05e414 | Christian Ehringfeld | ||
7e233492 | Christian Ehringfeld | QSharedPointer<Database> EntityManager::getDb() const {
|
|
return db;
|
|||
}
|
|||
void EntityManager::setDb(const QSharedPointer<Database> &value) {
|
|||
db = value;
|
|||
}
|
|||
QSharedPointer<Schema> EntityManager::getSchema() const {
|
|||
return schema;
|
|||
}
|
|||
void EntityManager::setSchema(const QSharedPointer<Schema> &value) {
|
|||
schema = value;
|
|||
}
|
|||
QString EntityManager::createConnection() {
|
|||
QStringList l = EntityManager::getConnectionNames();
|
|||
QString conName = "";
|
|||
bool ok = false;
|
|||
qint16 i = 0;
|
|||
while (!ok) {
|
|||
if (l.contains("con" + QString::number(i))) {
|
|||
++i;
|
|||
} else {
|
|||
l.append("con" + QString::number(i));
|
|||
ok = true;
|
|||
conName = "con" + QString::number(i);
|
|||
EntityManager::setConnectionNames(l);
|
|||
}
|
|||
}
|
|||
return conName;
|
|||
}
|
|||
void EntityManager::removeConnectionName(const QString &name) {
|
|||
EntityManager::connectionNames.removeOne(name);
|
|||
}
|
|||
586bb527 | Christian Ehringfeld | bool EntityManager::create(QSharedPointer<Entity> &entity) {
|
|
}
|
|||
7e233492 | Christian Ehringfeld | EntityManager::~EntityManager() {
|
|
EntityManager::removeConnectionName(this->db->getConnectionName());
|
|||
}
|
|||
QStringList EntityManager::getConnectionNames() {
|
|||
return EntityManager::connectionNames;
|
|||
}
|
|||
586bb527 | Christian Ehringfeld | void EntityManager::bindValues(const QHash<QString, QVariant> &h, QSqlQuery &q, bool ignoreID) {
|
|
QHash<QString, QVariant>::const_iterator i = h.constBegin();
|
|||
while (i != h.constEnd()) {
|
|||
7e233492 | Christian Ehringfeld | if (!ignoreID || (ignoreID && !(i.key() == "id"))) {
|
|
q.bindValue(":" + i.key(), i.value());
|
|||
}
|
|||
++i;
|
|||
}
|
|||
}
|
|||
9d05e414 | Christian Ehringfeld | ||
//qint8 EntityManager::count(Entity *entity, bool ignoreID) {
|
|||
b0b8dac3 | Christian Ehringfeld | // qint8 rc = 0;
|
|
9d05e414 | Christian Ehringfeld | // QSqlQuery q = this->db->getQuery("SELECT COUNT(*) FROM " + entity->getTablename() + this->where(
|
|
// entity->getAttributeValues(), "AND", ignoreID));
|
|||
// this->bindValues(entity->getAttributeValues(), q);
|
|||
b0b8dac3 | Christian Ehringfeld | // this->db->select(q);
|
|
9d05e414 | Christian Ehringfeld | // if (q.next()) {
|
|
b0b8dac3 | Christian Ehringfeld | // rc = q.value(0).toInt();
|
|
// }
|
|||
// return rc;
|
|||
//}
|
|||
7e233492 | Christian Ehringfeld | QString EntityManager::buildCreateQuery(QHash<QString, QVariant>::const_iterator i,
|
|
QHash<QString, QVariant>::const_iterator end, QString &p1, QString &p2) {
|
|||
bool first = true;
|
|||
while (i != end) {
|
|||
if (!first) {
|
|||
p1 += ",";
|
|||
p2 += ",";
|
|||
} else {
|
|||
first = false;
|
|||
}
|
|||
p1 += i.key();
|
|||
p2 += ":" + i.key();
|
|||
++i;
|
|||
}
|
|||
p1 += ")";
|
|||
p2 += ");";
|
|||
return p1 + p2;
|
|||
}
|
|||
b0b8dac3 | Christian Ehringfeld | ||
586bb527 | Christian Ehringfeld | //bool EntityManager::create(QSharedPointer<Entity> &entity) {
|
|
b0b8dac3 | Christian Ehringfeld | // bool rc = false;
|
|
9d05e414 | Christian Ehringfeld | // if (this->checkTable(entity) && this->count(entity) == 0) {
|
|
b0b8dac3 | Christian Ehringfeld | // QSqlQuery q = this->db->getQuery();
|
|
// QString p1 = "INSERT INTO " + entity->getTablename() + "(";
|
|||
// QString p2 = "VALUES(";
|
|||
// entity->setId(this->db->getLastId());
|
|||
9d05e414 | Christian Ehringfeld | // if (!entity->getAttributeValues()->isEmpty()) {
|
|
// q.prepare(this->buildCreateQuery(entity->getAttributeValues()->constBegin(), entity->getAttributeValues()->constEnd(),
|
|||
// p1, p2));
|
|||
b0b8dac3 | Christian Ehringfeld | // }
|
|
9d05e414 | Christian Ehringfeld | // this->bindValues(entity->getAttributeValues(), q);
|
|
b0b8dac3 | Christian Ehringfeld | // }
|
|
// return rc;
|
|||
//}
|
|||
7e233492 | Christian Ehringfeld | QHash<QString, QVariant> EntityManager::find(qint64 id, QString tblname) {
|
|
QSqlQuery q = this->db->getQuery("SELECT * FROM " + tblname + " WHERE id= :id LIMIT 1;");
|
|||
q.bindValue(":id", id);
|
|||
this->db->select(q);
|
|||
QSqlRecord rec = q.record();
|
|||
QHash<QString, QVariant> map = QHash<QString, QVariant>();
|
|||
if (q.next()) {
|
|||
for (int var = 0; var < rec.count(); ++var) {
|
|||
map.insert(rec.fieldName(var), q.value(rec.indexOf(rec.fieldName(
|
|||
var)))); // parameters of q.value can maybe replaced with var
|
|||
}
|
|||
}
|
|||
return map;
|
|||
}
|
|||
586bb527 | Christian Ehringfeld | QList<QHash <QString, QVariant> > EntityManager::findByAttributes(const QHash<QString, QVariant> &m,
|
|
const QString &tblname,
|
|||
7e233492 | Christian Ehringfeld | bool ignoreID) {
|
|
QSqlQuery q = this->db->getQuery("SELECT * FROM " + tblname + this->where(m, "AND", ignoreID));
|
|||
this->bindValues(m, q, true);
|
|||
return this->convertQueryResult(q);
|
|||
}
|
|||
586bb527 | Christian Ehringfeld | bool EntityManager::merge(QSharedPointer<Entity> &entity) {
|
|
}
|
|||
7e233492 | Christian Ehringfeld | QList<QHash<QString, QVariant> > EntityManager::convertQueryResult(QSqlQuery &q) {
|
|
QList<QHash <QString, QVariant> > listmap = QList<QHash <QString, QVariant> >();
|
|||
this->db->select(q);
|
|||
QSqlRecord rec = q.record();
|
|||
QStringList l = QStringList();
|
|||
qint16 field_count = rec.count();
|
|||
for (int var = 0; var < field_count; ++var) {
|
|||
l.append(rec.fieldName(var));
|
|||
}
|
|||
QHash<QString, QVariant> map = QHash<QString, QVariant>();
|
|||
while (q.next()) {
|
|||
for (int var = 0; var < field_count; ++var) {
|
|||
map.insert(l.at(var), q.value(rec.indexOf(l.at(var))));
|
|||
}
|
|||
listmap.append(map);
|
|||
}
|
|||
return listmap;
|
|||
}
|
|||
QList<QHash <QString, QVariant> > EntityManager::findAll(QString tblname) {
|
|||
QSqlQuery q = this->db->getQuery("SELECT * FROM " + tblname + ";");
|
|||
return this->convertQueryResult(q);
|
|||
}
|
|||
b0b8dac3 | Christian Ehringfeld | ||
//bool EntityManager::merge(Entity *entity) {
|
|||
9d05e414 | Christian Ehringfeld | // if (this->count(entity) == 0 && entity->getId() != -1) {
|
|
// QSqlQuery q = this->db->getQuery("UPDATE " + entity->getTablename() + " SET " + this->attributes(
|
|||
// entity->getAttributeValues()) + " WHERE id=:idM;");
|
|||
// this->bindValues(entity->getAttributeValues(), q);
|
|||
// q.bindValue(":idM", entity->getId());
|
|||
b0b8dac3 | Christian Ehringfeld | // return this->db->transaction(q);
|
|
// } else {
|
|||
// return false;
|
|||
// }
|
|||
//}
|
|||
//qint64 EntityManager::findId(Entity *entity) {
|
|||
// qint64 r = -1;
|
|||
9d05e414 | Christian Ehringfeld | // QSqlQuery q = this->db->getQuery("SELECT id FROM " + entity->getTablename() + this->where(entity->getAttributeValues(),
|
|
// "AND", true) + " LIMIT 1");
|
|||
// this->bindValues(entity->getAttributeValues(), q);
|
|||
b0b8dac3 | Christian Ehringfeld | // this->db->select(q);
|
|
9d05e414 | Christian Ehringfeld | // if (q.next()) {
|
|
b0b8dac3 | Christian Ehringfeld | // r = q.value(0).toInt();
|
|
// }
|
|||
// return r;
|
|||
//}
|
|||
586bb527 | Christian Ehringfeld | QString EntityManager::attributes(const QHash<QString, QVariant> &m, const QString &conjunction, bool ignoreID) {
|
|
7e233492 | Christian Ehringfeld | QString rc = "";
|
|
586bb527 | Christian Ehringfeld | if (!m.isEmpty()) {
|
|
QHash<QString, QVariant>::const_iterator i = m.constBegin();
|
|||
while (i != m.constEnd()) {
|
|||
7e233492 | Christian Ehringfeld | if (!ignoreID || (ignoreID && !(i.key() == "id"))) {
|
|
if (!(rc == "")) {
|
|||
rc += " " + conjunction + " ";
|
|||
}
|
|||
rc += i.key() + "= :" + i.key();
|
|||
}
|
|||
++i;
|
|||
}
|
|||
}
|
|||
return rc;
|
|||
}
|
|||
586bb527 | Christian Ehringfeld | QString EntityManager::where(const QHash<QString, QVariant> &m, const QString &conjunction, bool ignoreID) {
|
|
if (m.size() == 0 || (ignoreID && m.contains("id") && m.size() == 1)) {
|
|||
7e233492 | Christian Ehringfeld | return "";
|
|
}
|
|||
return " WHERE " + this->attributes(m, conjunction, ignoreID);
|
|||
}
|
|||
b0b8dac3 | Christian Ehringfeld | ||
//QString EntityManager::where(Entity *entity, QString conjunction, bool ignoreID) {
|
|||
9d05e414 | Christian Ehringfeld | // return this->where(entity->getAttributeValues(), conjunction, ignoreID);
|
|
b0b8dac3 | Christian Ehringfeld | //}
|
|
9d05e414 | Christian Ehringfeld | //QList<QHash <QString, QVariant> > EntityManager::findByAttributes(Entity *entity, bool ignoreID) {
|
|
// return this->findByAttributes(entity->getAttributeValues(), entity->getTablename(), ignoreID);
|
|||
b0b8dac3 | Christian Ehringfeld | //}
|
|
586bb527 | Christian Ehringfeld | bool EntityManager::save(QSharedPointer<Entity> &entity) {
|
|
if (entity.data()->getId() > -1) {
|
|||
7e233492 | Christian Ehringfeld | return this->merge(entity);
|
|
} else {
|
|||
return this->create(entity);
|
|||
}
|
|||
}
|
|||
586bb527 | Christian Ehringfeld | bool EntityManager::remove(QSharedPointer<Entity> &entity) {
|
|
7e233492 | Christian Ehringfeld | bool rc = false;
|
|
586bb527 | Christian Ehringfeld | QSqlQuery q = this->db->getQuery("DELETE FROM " + entity.data()->getTablename() + " WHERE id= :id;");
|
|
q.bindValue(":id", entity.data()->getId());
|
|||
7e233492 | Christian Ehringfeld | if (this->db->transaction(q)) {
|
|
586bb527 | Christian Ehringfeld | entity.clear();
|
|
7e233492 | Christian Ehringfeld | rc = true;
|
|
}
|
|||
return rc;
|
|||
}
|
|||
b0b8dac3 | Christian Ehringfeld | ||
586bb527 | Christian Ehringfeld | void EntityManager::setConnectionNames(QStringList list) {
|
|
EntityManager::connectionNames = list;
|
|||
}
|