#include "quassel.h"
PostgreSqlStorage::PostgreSqlStorage(QObject *parent)
- : AbstractSqlStorage(parent),
- _port(-1)
-{
-}
-
-
-PostgreSqlStorage::~PostgreSqlStorage()
+ : AbstractSqlStorage(parent)
{
}
safeExec(query);
if (!watchQuery(query)) {
db.rollback();
- return IdentityId();
+ return {};
}
query.first();
if (!identityId.isValid()) {
db.rollback();
- return IdentityId();
+ return {};
}
QSqlQuery insertNickQuery(db);
safeExec(insertNickQuery);
if (!watchQuery(insertNickQuery)) {
db.rollback();
- return IdentityId();
+ return {};
}
}
if (!db.commit()) {
qWarning() << "PostgreSqlStorage::createIdentity(): committing data failed!";
qWarning() << " -" << qPrintable(db.lastError().text());
- return IdentityId();
+ return {};
}
return identityId;
}
safeExec(query);
if (!watchQuery(query)) {
db.rollback();
- return NetworkId();
+ return {};
}
query.first();
if (!networkId.isValid()) {
db.rollback();
- return NetworkId();
+ return {};
}
QSqlQuery insertServersQuery(db);
safeExec(insertServersQuery);
if (!watchQuery(insertServersQuery)) {
db.rollback();
- return NetworkId();
+ return {};
}
}
if (!db.commit()) {
qWarning() << "PostgreSqlStorage::createNetwork(): committing data failed!";
qWarning() << " -" << qPrintable(db.lastError().text());
- return NetworkId();
+ return {};
}
return networkId;
}
if (!beginTransaction(db)) {
qWarning() << "PostgreSqlStorage::bufferInfo(): cannot start read only transaction!";
qWarning() << " -" << qPrintable(db.lastError().text());
- return BufferInfo();
+ return {};
}
QSqlQuery query(db);
if (!create) {
db.rollback();
- return BufferInfo();
+ return {};
}
QSqlQuery createQuery(db);
query.bindValue(":bufferid", bufferId.toInt());
safeExec(query);
if (!watchQuery(query))
- return BufferInfo();
+ return {};
if (!query.first())
- return BufferInfo();
+ return {};
BufferInfo bufferInfo(query.value(0).toInt(), query.value(1).toInt(), (BufferInfo::Type)query.value(2).toInt(), 0, query.value(4).toString());
Q_ASSERT(!query.next());
query.bindValue(":lastseenmsgid", lastSeenMsgId.toQint64());
safeExec(query);
watchQuery(query);
- int result = int(0);
+ auto result = int(0);
if (query.first())
result = query.value(0).toInt();
return result;