#include "network.h"
#include "util.h"
+#include "logger.h"
SqliteStorage::SqliteStorage(QObject *parent)
: AbstractSqlStorage(parent)
if(withTransaction) {
sync();
if(!logDb().transaction()) {
- qWarning() << "SqliteStorage::removeNetwork(): cannot start transaction. continuing with out rollback support!";
+ quWarning() << "SqliteStorage::removeNetwork(): cannot start transaction. continuing with out rollback support!";
withTransaction = false;
}
}
query->exec();
if(!query->first()) {
watchQuery(query);
- qWarning() << "unable to create BufferInfo for:" << user << networkId << buffer;
+ quWarning() << "unable to create BufferInfo for:" << user << networkId << buffer;
return BufferInfo();
}
}
BufferInfo bufferInfo = BufferInfo(query->value(0).toInt(), networkId, (BufferInfo::Type)query->value(1).toInt(), 0, buffer);
if(query->next()) {
- qWarning() << "SqliteStorage::getBufferInfo(): received more then one Buffer!";
- qWarning() << " Query:" << query->lastQuery();
- qWarning() << " bound Values:" << query->boundValues();
+ quError() << "SqliteStorage::getBufferInfo(): received more then one Buffer!";
+ quError() << " Query:" << query->lastQuery();
+ quError() << " bound Values:";
+ QList<QVariant> list = query->boundValues().values();
+ for (int i = 0; i < list.size(); ++i)
+ quError() << i << ":" << list.at(i).toString().toAscii().data();
Q_ASSERT(false);
}
return bufferlist;
}
+QList<BufferId> SqliteStorage::requestBufferIdsForNetwork(UserId user, NetworkId networkId) {
+ QList<BufferId> bufferList;
+ QSqlQuery query(logDb());
+ query.prepare(queryString("select_buffers_for_network"));
+ query.bindValue(":networkid", networkId.toInt());
+ query.bindValue(":userid", user.toInt());
+
+ query.exec();
+ watchQuery(&query);
+ while(query.next()) {
+ bufferList << BufferId(query.value(0).toInt());
+ }
+ return bufferList;
+}
+
bool SqliteStorage::removeBuffer(const UserId &user, const BufferId &bufferId) {
if(!isValidBuffer(user, bufferId))
return false;
logMessageQuery->bindValue(":type", msg.type());
logMessageQuery->bindValue(":flags", (int)msg.flags());
logMessageQuery->bindValue(":sender", msg.sender());
- logMessageQuery->bindValue(":message", msg.text());
+ logMessageQuery->bindValue(":message", msg.contents());
logMessageQuery->exec();
if(logMessageQuery->lastError().isValid()) {
getPasswordsQuery.exec();
if(!watchQuery(&getPasswordsQuery)) {
- qWarning() << "unable to migrate to new password format!";
+ quError() << "unable to migrate to new password format!";
return false;
}
watchQuery(&setPasswordsQuery);
}
- qDebug() << "successfully migrated passwords!";
+ quDebug() << "successfully migrated passwords!";
return true;
}