#include "sqlitestorage.h"
#include <QCryptographicHash>
-
#include <QtSql>
+#include "network.h"
+
SqliteStorage::SqliteStorage(QObject *parent)
: AbstractSqlStorage(parent)
{
emit userRemoved(user);
}
-void SqliteStorage::createBuffer(UserId user, const QString &network, const QString &buffer) {
- QSqlQuery *createBufferQuery = cachedQuery("insert_buffer");
- createBufferQuery->bindValue(":userid", user.toInt());
- createBufferQuery->bindValue(":userid2", user.toInt()); // Qt can't handle same placeholder twice (maybe sqlites fault)
- createBufferQuery->bindValue(":networkname", network);
- createBufferQuery->bindValue(":buffername", buffer);
- createBufferQuery->exec();
-
- if(createBufferQuery->lastError().isValid()) {
- if(createBufferQuery->lastError().number() == 19) { // Null Constraint violation
- QSqlQuery *createNetworkQuery = cachedQuery("insert_network");
- createNetworkQuery->bindValue(":userid", user.toInt());
- createNetworkQuery->bindValue(":networkname", network);
- createNetworkQuery->exec();
- Q_ASSERT(watchQuery(createNetworkQuery));
- createBufferQuery->exec();
- Q_ASSERT(watchQuery(createBufferQuery));
- } else {
- // do panic!
- qDebug() << "failed to create Buffer: ErrNo:" << createBufferQuery->lastError().number() << "ErrMsg:" << createBufferQuery->lastError().text();
- Q_ASSERT(false);
- }
+NetworkId SqliteStorage::createNetworkId(UserId user, const NetworkInfo &info) {
+ NetworkId networkId;
+ QSqlQuery query(logDb());
+ query.prepare(queryString("insert_network"));
+ query.bindValue(":userid", user.toInt());
+ query.bindValue(":networkname", info.networkName);
+ query.exec();
+
+ networkId = getNetworkId(user, info.networkName);
+ if(!networkId.isValid()) {
+ watchQuery(&query);
}
+ return networkId;
}
NetworkId SqliteStorage::getNetworkId(UserId user, const QString &network) {
if(query.first())
return query.value(0).toInt();
- else {
- createBuffer(user, network, "");
- query.exec();
- if(query.first())
- return query.value(0).toInt();
- else {
- qWarning() << "NETWORK NOT FOUND:" << network << "for User:" << user;
- return 0;
- }
- }
+ else
+ return NetworkId();
+}
+
+void SqliteStorage::createBuffer(UserId user, const NetworkId &networkId, const QString &buffer) {
+ QSqlQuery *query = cachedQuery("insert_buffer");
+ query->bindValue(":userid", user.toInt());
+ query->bindValue(":networkid", networkId.toInt());
+ query->bindValue(":buffername", buffer);
+ query->exec();
+
+ watchQuery(query);
}
-BufferInfo SqliteStorage::getBufferInfo(UserId user, const QString &network, const QString &buffer) {
- BufferInfo bufferid;
- // TODO: get rid of this hackaround
- NetworkId networkId = getNetworkId(user, network);
-
- QSqlQuery *getBufferInfoQuery = cachedQuery("select_bufferByName");
- getBufferInfoQuery->bindValue(":networkid", networkId.toInt());
- getBufferInfoQuery->bindValue(":userid", user.toInt());
- getBufferInfoQuery->bindValue(":buffername", buffer);
- getBufferInfoQuery->exec();
-
- if(!getBufferInfoQuery->first()) {
- createBuffer(user, network, buffer);
- getBufferInfoQuery->exec();
- if(getBufferInfoQuery->first()) {
- bufferid = BufferInfo(getBufferInfoQuery->value(0).toInt(), networkId, 0, network, buffer);
- emit bufferInfoUpdated(user, bufferid);
+BufferInfo SqliteStorage::getBufferInfo(UserId user, const NetworkId &networkId, const QString &buffer) {
+ QSqlQuery *query = cachedQuery("select_bufferByName");
+ query->bindValue(":networkid", networkId.toInt());
+ query->bindValue(":userid", user.toInt());
+ query->bindValue(":buffername", buffer);
+ query->exec();
+
+ if(!query->first()) {
+ createBuffer(user, networkId, buffer);
+ query->exec();
+ if(!query->first()) {
+ watchQuery(query);
+ qWarning() << "unable to create BufferInfo for:" << user << networkId << buffer;
+ return BufferInfo();
}
- } else {
- bufferid = BufferInfo(getBufferInfoQuery->value(0).toInt(), networkId, 0, network, buffer);
}
- Q_ASSERT(!getBufferInfoQuery->next());
+ BufferInfo bufferInfo = BufferInfo(query->value(0).toInt(), networkId, 0, buffer);
+ if(query->next()) {
+ qWarning() << "SqliteStorage::getBufferInfo(): received more then one Buffer!";
+ qWarning() << " Query:" << query->lastQuery();
+ qWarning() << " bound Values:" << query->boundValues();
+ Q_ASSERT(false);
+ }
- return bufferid;
+ return bufferInfo;
}
QList<BufferInfo> SqliteStorage::requestBuffers(UserId user, QDateTime since) {
query.exec();
watchQuery(&query);
while(query.next()) {
- bufferlist << BufferInfo(query.value(0).toInt(), query.value(2).toInt(), 0, query.value(3).toString(), query.value(1).toString());
+ bufferlist << BufferInfo(query.value(0).toInt(), query.value(2).toInt(), 0, query.value(1).toString());
}
return bufferlist;
}
QList<Message> SqliteStorage::requestMsgs(BufferInfo buffer, int lastmsgs, int offset) {
QList<Message> messagelist;
// we have to determine the real offset first
- QSqlQuery *requestMsgsOffsetQuery = cachedQuery("select_messagesOffset");
- requestMsgsOffsetQuery->bindValue(":bufferid", buffer.uid().toInt());
- requestMsgsOffsetQuery->bindValue(":messageid", offset);
- requestMsgsOffsetQuery->exec();
- requestMsgsOffsetQuery->first();
- offset = requestMsgsOffsetQuery->value(0).toInt();
+ QSqlQuery *offsetQuery = cachedQuery("select_messagesOffset");
+ offsetQuery->bindValue(":bufferid", buffer.uid().toInt());
+ offsetQuery->bindValue(":messageid", offset);
+ offsetQuery->exec();
+ offsetQuery->first();
+ offset = offsetQuery->value(0).toInt();
// now let's select the messages
- QSqlQuery *requestMsgsQuery = cachedQuery("select_messages");
- requestMsgsQuery->bindValue(":bufferid", buffer.uid().toInt());
- requestMsgsQuery->bindValue(":bufferid2", buffer.uid().toInt()); // Qt can't handle the same placeholder used twice
- requestMsgsQuery->bindValue(":limit", lastmsgs);
- requestMsgsQuery->bindValue(":offset", offset);
- requestMsgsQuery->exec();
- while(requestMsgsQuery->next()) {
- Message msg(QDateTime::fromTime_t(requestMsgsQuery->value(1).toInt()),
+ QSqlQuery *msgQuery = cachedQuery("select_messages");
+ msgQuery->bindValue(":bufferid", buffer.uid().toInt());
+ msgQuery->bindValue(":limit", lastmsgs);
+ msgQuery->bindValue(":offset", offset);
+ msgQuery->exec();
+
+ watchQuery(msgQuery);
+
+ while(msgQuery->next()) {
+ Message msg(QDateTime::fromTime_t(msgQuery->value(1).toInt()),
buffer,
- (Message::Type)requestMsgsQuery->value(2).toUInt(),
- requestMsgsQuery->value(5).toString(),
- requestMsgsQuery->value(4).toString(),
- requestMsgsQuery->value(3).toUInt());
- msg.setMsgId(requestMsgsQuery->value(0).toInt());
+ (Message::Type)msgQuery->value(2).toUInt(),
+ msgQuery->value(5).toString(),
+ msgQuery->value(4).toString(),
+ msgQuery->value(3).toUInt());
+ msg.setMsgId(msgQuery->value(0).toInt());
messagelist << msg;
}
return messagelist;
QList<Message> SqliteStorage::requestMsgs(BufferInfo buffer, QDateTime since, int offset) {
QList<Message> messagelist;
// we have to determine the real offset first
- QSqlQuery *requestMsgsSinceOffsetQuery = cachedQuery("select_messagesSinceOffset");
- requestMsgsSinceOffsetQuery->bindValue(":bufferid", buffer.uid().toInt());
- requestMsgsSinceOffsetQuery->bindValue(":since", since.toTime_t());
- requestMsgsSinceOffsetQuery->exec();
- requestMsgsSinceOffsetQuery->first();
- offset = requestMsgsSinceOffsetQuery->value(0).toInt();
+ QSqlQuery *offsetQuery = cachedQuery("select_messagesSinceOffset");
+ offsetQuery->bindValue(":bufferid", buffer.uid().toInt());
+ offsetQuery->bindValue(":since", since.toTime_t());
+ offsetQuery->exec();
+ offsetQuery->first();
+ offset = offsetQuery->value(0).toInt();
// now let's select the messages
- QSqlQuery *requestMsgsSinceQuery = cachedQuery("select_messagesSince");
- requestMsgsSinceQuery->bindValue(":bufferid", buffer.uid().toInt());
- requestMsgsSinceQuery->bindValue(":bufferid2", buffer.uid().toInt());
- requestMsgsSinceQuery->bindValue(":since", since.toTime_t());
- requestMsgsSinceQuery->bindValue(":offset", offset);
- requestMsgsSinceQuery->exec();
-
- while(requestMsgsSinceQuery->next()) {
- Message msg(QDateTime::fromTime_t(requestMsgsSinceQuery->value(1).toInt()),
+ QSqlQuery *msgQuery = cachedQuery("select_messagesSince");
+ msgQuery->bindValue(":bufferid", buffer.uid().toInt());
+ msgQuery->bindValue(":since", since.toTime_t());
+ msgQuery->bindValue(":offset", offset);
+ msgQuery->exec();
+
+ watchQuery(msgQuery);
+
+ while(msgQuery->next()) {
+ Message msg(QDateTime::fromTime_t(msgQuery->value(1).toInt()),
buffer,
- (Message::Type)requestMsgsSinceQuery->value(2).toUInt(),
- requestMsgsSinceQuery->value(5).toString(),
- requestMsgsSinceQuery->value(4).toString(),
- requestMsgsSinceQuery->value(3).toUInt());
- msg.setMsgId(requestMsgsSinceQuery->value(0).toInt());
+ (Message::Type)msgQuery->value(2).toUInt(),
+ msgQuery->value(5).toString(),
+ msgQuery->value(4).toString(),
+ msgQuery->value(3).toUInt());
+ msg.setMsgId(msgQuery->value(0).toInt());
messagelist << msg;
}
QList<Message> SqliteStorage::requestMsgRange(BufferInfo buffer, int first, int last) {
QList<Message> messagelist;
- QSqlQuery *requestMsgRangeQuery = cachedQuery("select_messageRange");
- requestMsgRangeQuery->bindValue(":bufferid", buffer.uid().toInt());
- requestMsgRangeQuery->bindValue(":bufferid2", buffer.uid().toInt());
- requestMsgRangeQuery->bindValue(":firstmsg", first);
- requestMsgRangeQuery->bindValue(":lastmsg", last);
-
- while(requestMsgRangeQuery->next()) {
- Message msg(QDateTime::fromTime_t(requestMsgRangeQuery->value(1).toInt()),
+ QSqlQuery *rangeQuery = cachedQuery("select_messageRange");
+ rangeQuery->bindValue(":bufferid", buffer.uid().toInt());
+ rangeQuery->bindValue(":firstmsg", first);
+ rangeQuery->bindValue(":lastmsg", last);
+ rangeQuery->exec();
+
+ watchQuery(rangeQuery);
+
+ while(rangeQuery->next()) {
+ Message msg(QDateTime::fromTime_t(rangeQuery->value(1).toInt()),
buffer,
- (Message::Type)requestMsgRangeQuery->value(2).toUInt(),
- requestMsgRangeQuery->value(5).toString(),
- requestMsgRangeQuery->value(4).toString(),
- requestMsgRangeQuery->value(3).toUInt());
- msg.setMsgId(requestMsgRangeQuery->value(0).toInt());
+ (Message::Type)rangeQuery->value(2).toUInt(),
+ rangeQuery->value(5).toString(),
+ rangeQuery->value(4).toString(),
+ rangeQuery->value(3).toUInt());
+ msg.setMsgId(rangeQuery->value(0).toInt());
messagelist << msg;
}
projects / quassel.git / blobdiff