Projekt

Allgemein

Profil

« Zurück | Weiter » 

Revision 426974c6

Von Christian Ehringfeld vor mehr als 10 Jahren hinzugefügt

  • ID 426974c6030a4b348d33f6481bf920a69d9f449a
  • Vorgänger a604a5a2
  • Nachfolger caea9141

...

Unterschiede anzeigen:

src/database.cpp
}
Database::Database(QString databaseType, QString connectionName, QString databasename) {
this->database = QSqlDatabase::addDatabase(databaseType,connectionName);
this->database = QSqlDatabase::addDatabase(databaseType, connectionName);
this->connectionName = connectionName;
this->database.setDatabaseName(databasename);
this->init();
}
Database::Database(QString databaseType, QString connectionName, QString hostname, QString databasename, QString username, QString password, qint64 port) {
this->database = QSqlDatabase::addDatabase(databaseType,connectionName);
Database::Database(QString databaseType, QString connectionName, QString hostname, QString databasename,
QString username, QString password, qint64 port) {
this->database = QSqlDatabase::addDatabase(databaseType, connectionName);
this->connectionName = connectionName;
this->database.setHostName(hostname);
this->database.setDatabaseName(databasename);
......
}
void Database::getTableListFromDatabase() {
if(this->database.open()) {
if (this->database.open()) {
QString q = "";
if(this->databasetype == CuteEntityManager::SQLITE) {
if (this->databasetype == CuteEntityManager::SQLITE) {
q = this->sqliteTableList();
} else if(this->databasetype == CuteEntityManager::MYSQL){
} else if (this->databasetype == CuteEntityManager::MYSQL) {
q = this->mysqlTableList();
} else if(this->databasetype == CuteEntityManager::PGSQL) {
} else if (this->databasetype == CuteEntityManager::PGSQL) {
q = this->pgsqlSeqTable();
}
QSqlQuery query = QSqlQuery(this->database);
......
}
void Database::setTableList(QSqlQuery &q) {
while(q.next()) {
while (q.next()) {
this->tableList->append(q.value(0).toString());
}
}
......
//}
Database::~Database() {
if(this->database.isOpen()) {
if (this->database.isOpen()) {
this->database.close();
}
QSqlDatabase::removeDatabase(this->connectionName);
......
QChar Database::escapeChar() {
QChar c = QChar();
if(this->databasetype == CuteEntityManager::SQLITE) {
if (this->databasetype == CuteEntityManager::SQLITE) {
c = '\'';
} else if(this->databasetype == CuteEntityManager::MYSQL) {
} else if (this->databasetype == CuteEntityManager::MYSQL) {
c = '`';
}
return c;
......
bool Database::transaction(const QString &query) {
bool rc = false;
if(supportTransactions) {
if (supportTransactions) {
this->database.transaction();
QSqlQuery sqlquery = QSqlQuery(this->database);
sqlquery.exec(query);
if(!this->database.commit()) {
if (!this->database.commit()) {
this->database.rollback();
}
} else {
......
bool Database::transaction(const QStringList &queries) {
bool ok = false;
if(this->supportTransactions) {
if (this->supportTransactions) {
this->database.transaction();
QSqlQuery sqlquery = QSqlQuery(this->database);
for (int var = 0; var < queries.size(); ++var) {
sqlquery.exec(queries.at(var));
}
if(!this->database.commit()) {
if (!this->database.commit()) {
this->database.rollback();
} else {
ok = true;
......
bool Database::transaction(QSqlQuery &query) {
this->database.transaction();
query.exec();
if(!this->database.commit()) {
if (!this->database.commit()) {
this->database.rollback();
return false;
}
......
q = queries.at(var);
q.exec();
}
if(!this->database.commit()) {
if (!this->database.commit()) {
this->database.rollback();
return false;
}
......
this->database.transaction();
QSqlQuery q = QSqlQuery(this->database);
q.exec(query);
if(!this->database.commit()) {
if (!this->database.commit()) {
this->database.rollback();
return false;
}
return true;
}
bool Database::exec(QStringList queries){
bool Database::exec(QStringList queries) {
QSqlQuery q = QSqlQuery(this->database);
bool ok = true;
for (int var = 0; var < queries.size() && ok; ++var) {
ok = q.exec(queries.at(var));
if(!ok) {
if (!ok) {
break;
}
}
......
for (int var = 0; var < queries.size() && ok; ++var) {
q = queries.at(var);
ok = q.exec();
if(!ok) {
if (!ok) {
break;
}
}
......
}
void Database::createSequenceTable() {
if(this->database.open() && this->getLastId() == -1) {
if (this->database.open() && this->getLastId() == -1) {
QString query = "";
QStringList l = QStringList();
if(this->databasetype == CuteEntityManager::MYSQL) {
if (this->databasetype == CuteEntityManager::MYSQL) {
query = this->mysqlSeqTable();
} else if(this->databasetype == CuteEntityManager::SQLITE) {
} else if (this->databasetype == CuteEntityManager::SQLITE) {
query = this->sqliteSeqTable();
} else if(this->databasetype == CuteEntityManager::PGSQL) {
} else if (this->databasetype == CuteEntityManager::PGSQL) {
query = this->pgsqlSeqTable();
}
l.append(query);
l.append(this->querySequenceCounter());
if(this->transaction(l)) {
if (this->transaction(l)) {
this->setSeqTable(true);
} else {
this->setSeqTable(false);
......
bool Database::updateSequenceCounter(QSqlQuery &q) {
QList<QSqlQuery> l = QList<QSqlQuery>();
l.append(QSqlQuery("UPDATE sequence SET SEQ_COUNT=(SEQ_COUNT+1);",this->database));
l.append(QSqlQuery("UPDATE sequence SET SEQ_COUNT=(SEQ_COUNT+1);", this->database));
l.append(q);
return this->transaction(l);
}
......
qint64 Database::getLastId() {
qint64 id = -1;
QSqlQuery q = this->select("SELECT SEQ_COUNT FROM sequence WHERE SEQ_NAME=\'id_count\';");
if(q.next()) {
if (q.next()) {
id = q.value(0).toInt();
}
return id;

Auch abrufbar als: Unified diff