Projekt

Allgemein

Profil

« Zurück | Weiter » 

Revision a06633f7

Von Christian Ehringfeld vor fast 9 Jahren hinzugefügt

  • ID a06633f73a998711394336c55170748b701801eb
  • Vorgänger 9070a496
  • Nachfolger 2d9fab10

wip

Unterschiede anzeigen:

src/entity.cpp
return QString(this->metaObject()->className());
}
QHash<QString, Relation> Entity::getRelations() {
const QHash<QString, Relation> Entity::getRelations() const {
return QHash<QString, Relation>();
}
QStringList Entity::getTransientAttributes() {
const QStringList Entity::getTransientAttributes() const {
return QStringList();
}
QStringList Entity::getBLOBColumns() {
const QStringList Entity::getBLOBColumns() const {
return QStringList();
}
......
return "id";
}
QHash<QString, QMetaProperty> Entity::getMetaProperties() const {
QHash<QString, QMetaProperty> h = QHash<QString, QMetaProperty>();
const QHash<QString, QMetaProperty> Entity::getMetaProperties() const {
auto h = QHash<QString, QMetaProperty>();
for (int var = 0; var < this->metaObject()->propertyCount(); ++var) {
QMetaProperty m = this->metaObject()->property(var);
if (m.name() != QString("objectName") && m.isValid()) {
if (m.isValid() && m.name() != QString("objectName")) {
h.insert(m.name(), m);
}
}
return h;
}
const QHash<QString, QMetaProperty> Entity::getRelationProperties() const {
auto h = QHash<QString, QMetaProperty>();
auto relations = this->getRelations();
for (int var = 0; var < this->metaObject()->propertyCount(); ++var) {
QMetaProperty m = this->metaObject()->property(var);
if (m.isValid() && relations.contains(QString(m.name()))) {
h.insert(m.name(), m);
}
}
......
}
void Entity::setId(const qint64 &value) {
if(value != this->id) {
if (value != this->id) {
id = value;
emit idChanged();
}
src/entity.h
* @brief getRelations
* @return
*/
virtual QHash<QString, Relation> getRelations();
virtual QStringList getTransientAttributes();
virtual QStringList getBLOBColumns();
virtual const QHash<QString, Relation> getRelations() const;
virtual const QStringList getTransientAttributes() const;
virtual const QStringList getBLOBColumns() const;
//return value must be the exact name defined in Q_PROPERTY
virtual QString getPrimaryKey();
QHash<QString, QMetaProperty> getMetaProperties() const;
const char* getClassname() const;
const QHash<QString, QMetaProperty> getMetaProperties() const;
const QHash<QString, QMetaProperty> getRelationProperties() const;
const char *getClassname() const;
qint64 getId() const;
void setId(const qint64 &value);
src/entitymanager.cpp
return list;
}
void EntityManager::manyToOne(const QSharedPointer<Entity> &entity, const QVariant &id, const QMetaProperty &property) {
qint64 convertedId = -1;
bool ok = false;
if((convertedId == id.toLongLong(&ok)) && ok && convertedId > -1) {
//property.t
}
}
void EntityManager::oneToMany(const QSharedPointer<Entity> &entity, const Relation &r, const QMetaProperty &property) {
}
void EntityManager::manyToMany(const QSharedPointer<Entity> &entity, const Relation &r, const QMetaProperty &property) {
}
void EntityManager::oneToOne(const QSharedPointer<Entity> &entity, const Relation &r, const QMetaProperty &property,
const QVariant &id) {
}
QList<QSharedPointer<Entity> > EntityManager::findEntityByAttributes(const QSharedPointer<Entity> &entity,
bool ignoreID) {
auto maps = this->findAllByAttributes(entity, ignoreID);
......
return this->convertQueryResult(q);
}
void EntityManager::resolveRelations(const QSharedPointer<Entity> &entity, const QHash<QString, QVariant> &map) {
auto relations = entity.data()->getRelations();
auto props = entity.data()->getRelationProperties();
auto iterator = relations.constBegin();
while (iterator != relations.constEnd()) {
const Relation r = iterator.value();
const QMetaProperty property = props.value(r.getPropertyName());
switch (r.getType()) {
case MANY_TO_ONE:
if (map.contains(r.getPropertyName()) + "_id") {
this->manyToOne(entity, property.read(entity.data()), property);
}
break;
case MANY_TO_MANY:
this->manyToMany(entity, r, property);
break;
case ONE_TO_MANY:
this->oneToMany(entity, r, property);
break;
case ONE_TO_ONE:
this->oneToOne(entity, r, property, property.read(entity.data()));
break;
}
++iterator;
}
}
bool EntityManager::save(QSharedPointer<Entity> &entity) {
if (entity.data()->getId() > -1) {
return this->merge(entity);
src/entitymanager.cpp.autosave
/*
* 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/>.
*/
#include "entitymanager.h"
#include "enums/databasetype.h"
#include "databasemigration.h"
using namespace CuteEntityManager;
QStringList EntityManager::connectionNames = QStringList();
void EntityManager::init() {
auto schema = Database::getSchema(Database::getDatabaseType(
this->db.data()->getDatabase().driverName()), this->db);
this->schema = QSharedPointer<Schema>(schema);
this->schema.data()->setTables(this->schema.data()->getTableSchemas());
}
EntityManager::EntityManager(QSqlDatabase database) {
auto db = new Database(database);
this->db = QSharedPointer<Database>(db);
this->init();
}
bool EntityManager::startup(QString version, QStringList toInitialize) {
DatabaseMigration *dbm = new DatabaseMigration();
QSharedPointer<Entity> ptrDbm = QSharedPointer<Entity>(dbm);
QHash<QString, QVariant> map = QHash<QString, QVariant>();
bool ok = true;
map.insert("version", version);
if (this->findAllByAttributes(map, dbm->getTablename()).isEmpty()) {
for (int var = 0; var < toInitialize.size(); ++var) {
if (ok) {
QString c = toInitialize.at(var);
ok = this->createTable(QSharedPointer<Entity>(EntityInstanceFactory::createInstance(c)));
} else {
break;
}
}
if (ok) {
dbm->setVersion(version);
dbm->setApplyTime(QDateTime::currentDateTime());
this->create(ptrDbm);
}
}
delete dbm;
return ok;
}
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();
}
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;
}
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);
}
QSharedPointer<Entity> EntityManager::convert(const QHash<QString, QVariant> &map, const char *classname) {
auto ptr = QSharedPointer<Entity>(EntityInstanceFactory::createInstance(classname, map));
this->cache.insert(ptr);
return ptr;
}
QList<QSharedPointer<Entity> > EntityManager::convert(QList<QHash<QString, QVariant> > maps, const char *classname) {
auto list = QList<QSharedPointer<Entity> >();
for (int var = 0; var < maps.size(); ++var) {
auto ptr = this->convert(maps.at(var), classname);
list.append(ptr);
this->cache.insert(ptr);
}
return list;
}
void EntityManager::manyToOne(const QSharedPointer<Entity> &entity, const QVariant &id, const QMetaProperty &property) {
qint64 convertedId = -1;
bool ok = false;
if((convertedId == id.toLongLong(&ok)) && ok && convertedId > -1) {
//property.t
}
}
void EntityManager::oneToMany(const QSharedPointer<Entity> &entity, const Relation &r, const QMetaProperty &property) {
}
void EntityManager::manyToMany(const QSharedPointer<Entity> &entity, const Relation &r, const QMetaProperty &property) {
}
void EntityManager::oneToOne(const QSharedPointer<Entity> &entity, const Relation &r, const QMetaProperty &property,
const QVariant &id) {
}
QList<QSharedPointer<Entity> > EntityManager::findEntityByAttributes(const QSharedPointer<Entity> &entity,
bool ignoreID) {
auto maps = this->findAllByAttributes(entity, ignoreID);
return this->convert(maps, entity.data()->getClassname());
}
/**
* @todo should be an insert statement with much values
* not really usefull atm
* @brief EntityManager::create
* @param entities
* @return
*/
bool EntityManager::create(QList<QSharedPointer<Entity> > entities) {
bool ok = true;
foreach (QSharedPointer<Entity> ent, entities) {
ok = this->create(ent);
if (!ok) {
break;
}
}
return ok;
}
/**
* @TODO insert Relations
* @brief EntityManager::create
* @param entity
* @return
*/
bool EntityManager::create(QSharedPointer<Entity> &entity) {
bool rc = false;
if (this->checkTable(entity) && this->count(entity) == 0) {
QSqlQuery q = this->schema.data()->getQueryBuilder().data()->create(entity);
rc = this->db->transaction(q);
if (rc) {
entity.data()->setId(this->schema.data()->getLastInsertID().toLongLong(&rc));
this->cache.insert(entity);
}
}
return rc;
}
EntityManager::~EntityManager() {
EntityManager::removeConnectionName(this->db->getConnectionName());
}
QStringList EntityManager::getConnectionNames() {
return EntityManager::connectionNames;
}
QHash<QString, QVariant> EntityManager::findById(qint64 id, QString tblname) {
QSqlQuery q = this->schema.data()->getQueryBuilder().data()->find(id, tblname);
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) {
QVariant variant = rec.value(var);
if (variant.isValid()) {
map.insert(rec.fieldName(var), variant);
}
}
}
return map;
}
QList<QHash<QString, QVariant> > EntityManager::findAllByAttributes(const QSharedPointer<Entity> &entity,
bool ignoreID) {
QSqlQuery q = this->schema.data()->getQueryBuilder().data()->findByAttributes(entity, ignoreID);
return this->convertQueryResult(q);
}
QList<QHash <QString, QVariant> > EntityManager::findAllByAttributes(const QHash<QString, QVariant> &m,
const QString &tblname,
bool ignoreID) {
QSqlQuery q = this->schema.data()->getQueryBuilder().data()->findByAttributes(m,
tblname, ignoreID);
return this->convertQueryResult(q);
}
/**
* @TODO insert Relations
* @brief EntityManager::merge
* @param entity
* @param withRelations
* @return
*/
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);
return this->db->transaction(q);
} else {
return false;
}
}
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->schema.data()->getQueryBuilder().data()->findAll(tblname);
return this->convertQueryResult(q);
}
void EntityManager::resolveRelations(const QSharedPointer<Entity> &entity, const QHash<QString, QVariant> &map) {
auto relations = entity.data()->getRelations();
auto props = entity.data()->getRelationProperties();
auto iterator = relations.constBegin();
while (iterator != relations.constEnd()) {
const Relation r = iterator.value();
const QMetaProperty property = props.value(r.getPropertyName());
switch (r.getType()) {
case MANY_TO_ONE:
if (map.contains(r.getPropertyName()) + "_id") {
this->manyToOne(entity, property.read(entity.data()), property);
}
break;
case MANY_TO_MANY:
this->manyToMany(entity, r, property);
break;
case ONE_TO_MANY:
this->oneToMany(entity, r, property);
break;
case ONE_TO_ONE:
this->oneToOne(entity, r, property, property.read(entity.data()));
break;
}
++iterator;
}
}
bool EntityManager::save(QSharedPointer<Entity> &entity) {
if (entity.data()->getId() > -1) {
return this->merge(entity);
} else {
return this->create(entity);
}
}
qint64 EntityManager::findId(QSharedPointer<Entity> &entity) {
qint64 r = -1;
QSqlQuery q = this->schema.data()->getQueryBuilder().data()->findId(entity);
this->db->select(q);
if (q.next()) {
r = q.value(0).toLongLong();
}
return r;
}
bool EntityManager::remove(QSharedPointer<Entity> &entity) {
bool rc = false;
QSqlQuery q = this->schema.data()->getQueryBuilder().data()->remove(entity);
if (this->db->transaction(q)) {
this->cache.remove(entity);
entity.clear();
rc = true;
}
return rc;
}
bool EntityManager::createTable(const QSharedPointer<Entity> &entity) {
return this->schema.data()->getQueryBuilder().data()->createTable(entity);
}
qint8 EntityManager::count(const QSharedPointer<Entity> &entity, bool ignoreID) {
qint8 rc = -1;
QSqlQuery q = this->schema.data()->getQueryBuilder().data()->count(entity, ignoreID);
this->db->select(q);
if (q.next()) {
rc = q.value(0).toInt();
}
return rc;
}
qint8 EntityManager::count(const QString &tableName) {
qint8 rc = -1;
QSqlQuery q = this->schema.data()->getQueryBuilder().data()->count(tableName);
this->db->select(q);
if (q.next()) {
rc = q.value(0).toInt();
}
return rc;
}
void EntityManager::setConnectionNames(QStringList list) {
EntityManager::connectionNames = list;
}
src/entitymanager.h
protected:
void init();
QList<QHash<QString, QVariant> > findAll(QString tblname);
void resolveRelations(const QSharedPointer<Entity> &entity, const QHash<QString, QVariant> &map);
QHash<QString, QVariant> findById(qint64 id, QString tblname);
QSharedPointer<Entity> convert(const QHash<QString, QVariant> &map, const char *classname);
QList<QSharedPointer<Entity>> convert(QList<QHash<QString, QVariant> > maps, const char *classname);
void manyToOne(const QSharedPointer<Entity> &entity, const QVariant &id, const QMetaProperty &property);
void oneToMany(const QSharedPointer<Entity> &entity, const Relation &r, const QMetaProperty &property);
void manyToMany(const QSharedPointer<Entity> &entity, const Relation &r, const QMetaProperty &property);
void oneToOne(const QSharedPointer<Entity> &entity, const Relation &r, const QMetaProperty &property,
const QVariant &id = "");
QList<QHash<QString, QVariant> > findAllByAttributes(const QSharedPointer<Entity> &entity, bool ignoreID = false);
QList<QHash<QString, QVariant> > findAllByAttributes(const QHash<QString, QVariant> &m, const QString &tblname,
bool ignoreID = false);
src/querybuilder.cpp
entity->getTablename()) + " SET " + this->attributes(
values) + " WHERE " + this->schema.data()->quoteColumnName("id") + "=:id;");
this->bindValues(values, q);
//q.bindValue(":idM", entity->getId());
return q;
}

Auch abrufbar als: Unified diff