if(!_connectionPool.contains(QThread::currentThread()))
addConnectionToPool();
- qDebug() << "using logDb" << _connectionPool[QThread::currentThread()]->name() << QThread::currentThread();
return QSqlDatabase::database(_connectionPool[QThread::currentThread()]->name());
}
int connectionId = _nextConnectionId++;
Connection *connection = new Connection(QLatin1String(QString("quassel_connection_%1").arg(connectionId).toLatin1()));
- qDebug() << "new connection" << connection->name() << currentThread << QLatin1String(QString("quassel_connection_%1").arg(connectionId).toLatin1());
connection->moveToThread(currentThread);
connect(this, SIGNAL(destroyed()), connection, SLOT(deleteLater()));
connect(currentThread, SIGNAL(destroyed()), connection, SLOT(deleteLater()));
void SqliteStorage::createBuffer(UserId user, const NetworkId &networkId, BufferInfo::Type type, const QString &buffer) {
- // QSqlQuery &query = cachedQuery("insert_buffer");
QSqlQuery query(logDb());
query.prepare(queryString("insert_buffer"));
query.bindValue(":userid", user.toInt());
}
BufferInfo SqliteStorage::getBufferInfo(UserId user, const NetworkId &networkId, BufferInfo::Type type, const QString &buffer) {
- // QSqlQuery &query = cachedQuery("select_bufferByName");
QSqlQuery query(logDb());
query.prepare(queryString("select_bufferByName"));
query.bindValue(":networkid", networkId.toInt());
}
void SqliteStorage::setBufferLastSeenMsg(UserId user, const BufferId &bufferId, const MsgId &msgId) {
- // QSqlQuery &query = cachedQuery("update_buffer_lastseen");
QSqlQuery query(logDb());
query.prepare(queryString("update_buffer_lastseen"));
}
MsgId SqliteStorage::logMessage(Message msg) {
- // QSqlQuery &logMessageQuery = cachedQuery("insert_message");
QSqlQuery logMessageQuery(logDb());
logMessageQuery.prepare(queryString("insert_message"));
if(logMessageQuery.lastError().isValid()) {
// constraint violation - must be NOT NULL constraint - probably the sender is missing...
if(logMessageQuery.lastError().number() == 19) {
- // QSqlQuery &addSenderQuery = cachedQuery("insert_sender");
QSqlQuery addSenderQuery(logDb());
addSenderQuery.prepare(queryString("insert_sender"));
addSenderQuery.bindValue(":sender", msg.sender());
offset = 0;
} else {
// we have to determine the real offset first
- // QSqlQuery &offsetQuery = cachedQuery("select_messagesOffset");
QSqlQuery offsetQuery(logDb());
offsetQuery.prepare(queryString("select_messagesOffset"));
}
// now let's select the messages
- // QSqlQuery &msgQuery = cachedQuery("select_messages");
QSqlQuery msgQuery(logDb());
msgQuery.prepare(queryString("select_messages"));
return messagelist;
// we have to determine the real offset first
- // QSqlQuery &offsetQuery = cachedQuery("select_messagesSinceOffset");
QSqlQuery offsetQuery(logDb());
offsetQuery.prepare(queryString("select_messagesSinceOffset"));
offset = offsetQuery.value(0).toInt();
// now let's select the messages
- // QSqlQuery &msgQuery = cachedQuery("select_messagesSince");
QSqlQuery msgQuery(logDb());
msgQuery.prepare(queryString("select_messagesSince"));
msgQuery.bindValue(":bufferid", bufferId.toInt());
if(!bufferInfo.isValid())
return messagelist;
- // QSqlQuery &rangeQuery = cachedQuery("select_messageRange");
QSqlQuery rangeQuery(logDb());
rangeQuery.prepare(queryString("select_messageRange"));
rangeQuery.bindValue(":bufferid", bufferId.toInt());