1 /***************************************************************************
2 * Copyright (C) 2005-07 by the Quassel Project *
3 * devel@quassel-irc.org *
5 * This program is free software; you can redistribute it and/or modify *
6 * it under the terms of the GNU General Public License as published by *
7 * the Free Software Foundation; either version 2 of the License, or *
8 * (at your option) version 3. *
10 * This program is distributed in the hope that it will be useful, *
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of *
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
13 * GNU General Public License for more details. *
15 * You should have received a copy of the GNU General Public License *
16 * along with this program; if not, write to the *
17 * Free Software Foundation, Inc., *
18 * 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. *
19 ***************************************************************************/
21 #include "sqlitestorage.h"
29 int SqliteStorage::_maxRetryCount = 150; // yes this is a large number... only other way to "handle" this is bailing out...
31 SqliteStorage::SqliteStorage(QObject *parent)
32 : AbstractSqlStorage(parent)
36 SqliteStorage::~SqliteStorage() {
39 bool SqliteStorage::isAvailable() const {
40 if(!QSqlDatabase::isDriverAvailable("QSQLITE")) return false;
44 QString SqliteStorage::displayName() const {
45 return QString("SQLite");
48 QString SqliteStorage::description() const {
49 return tr("SQLite is a file-based database engine that does not require any setup. It is suitable for small and medium-sized "
50 "databases that do not require access via network. Use SQLite if your Quassel Core should store its data on the same machine "
51 "it is running on, and if you only expect a few users to use your core.");
54 int SqliteStorage::installedSchemaVersion() {
55 QSqlQuery query = logDb().exec("SELECT value FROM coreinfo WHERE key = 'schemaversion'");
57 return query.value(0).toInt();
59 // maybe it's really old... (schema version 0)
60 query = logDb().exec("SELECT MAX(version) FROM coreinfo");
62 return query.value(0).toInt();
64 return AbstractSqlStorage::installedSchemaVersion();
67 bool SqliteStorage::updateSchemaVersion(int newVersion) {
68 QSqlQuery query(logDb());
69 query.prepare("UPDATE coreinfo SET value = :version WHERE key = 'schemaversion'");
70 query.bindValue(":version", newVersion);
74 if(query.lastError().isValid()) {
75 qCritical() << "SqliteStorage::updateSchemaVersion(int): Updating schema version failed!";
81 bool SqliteStorage::setupSchemaVersion(int version) {
82 QSqlQuery query(logDb());
83 query.prepare("INSERT INTO coreinfo (key, value) VALUES ('schemaversion', :version)");
84 query.bindValue(":version", version);
88 if(query.lastError().isValid()) {
89 qCritical() << "SqliteStorage::setupSchemaVersion(int): Updating schema version failed!";
95 UserId SqliteStorage::addUser(const QString &user, const QString &password) {
96 QSqlQuery query(logDb());
97 query.prepare(queryString("insert_quasseluser"));
98 query.bindValue(":username", user);
99 query.bindValue(":password", cryptedPassword(password));
101 if(query.lastError().isValid() && query.lastError().number() == 19) { // user already exists - sadly 19 seems to be the general constraint violation error...
105 query.prepare(queryString("select_userid"));
106 query.bindValue(":username", user);
109 UserId uid = query.value(0).toInt();
110 emit userAdded(uid, user);
114 void SqliteStorage::updateUser(UserId user, const QString &password) {
115 QSqlQuery query(logDb());
116 query.prepare(queryString("update_userpassword"));
117 query.bindValue(":userid", user.toInt());
118 query.bindValue(":password", cryptedPassword(password));
122 void SqliteStorage::renameUser(UserId user, const QString &newName) {
123 QSqlQuery query(logDb());
124 query.prepare(queryString("update_username"));
125 query.bindValue(":userid", user.toInt());
126 query.bindValue(":username", newName);
128 emit userRenamed(user, newName);
131 UserId SqliteStorage::validateUser(const QString &user, const QString &password) {
132 QSqlQuery query(logDb());
133 query.prepare(queryString("select_authuser"));
134 query.bindValue(":username", user);
135 query.bindValue(":password", cryptedPassword(password));
139 return query.value(0).toInt();
145 UserId SqliteStorage::internalUser() {
146 QSqlQuery query(logDb());
147 query.prepare(queryString("select_internaluser"));
151 return query.value(0).toInt();
157 void SqliteStorage::delUser(UserId user) {
158 QSqlQuery query(logDb());
159 query.prepare(queryString("delete_backlog_by_uid"));
160 query.bindValue(":userid", user.toInt());
163 query.prepare(queryString("delete_buffers_by_uid"));
164 query.bindValue(":userid", user.toInt());
167 query.prepare(queryString("delete_networks_by_uid"));
168 query.bindValue(":userid", user.toInt());
171 query.prepare(queryString("delete_quasseluser"));
172 query.bindValue(":userid", user.toInt());
174 // I hate the lack of foreign keys and on delete cascade... :(
175 emit userRemoved(user);
178 void SqliteStorage::setUserSetting(UserId userId, const QString &settingName, const QVariant &data) {
180 QDataStream out(&rawData, QIODevice::WriteOnly);
181 out.setVersion(QDataStream::Qt_4_2);
184 QSqlQuery query(logDb());
185 query.prepare(queryString("insert_user_setting"));
186 query.bindValue(":userid", userId.toInt());
187 query.bindValue(":settingname", settingName);
188 query.bindValue(":settingvalue", rawData);
191 if(query.lastError().isValid()) {
192 QSqlQuery updateQuery(logDb());
193 updateQuery.prepare(queryString("update_user_setting"));
194 updateQuery.bindValue(":userid", userId.toInt());
195 updateQuery.bindValue(":settingname", settingName);
196 updateQuery.bindValue(":settingvalue", rawData);
197 safeExec(updateQuery);
202 QVariant SqliteStorage::getUserSetting(UserId userId, const QString &settingName, const QVariant &defaultData) {
203 QSqlQuery query(logDb());
204 query.prepare(queryString("select_user_setting"));
205 query.bindValue(":userid", userId.toInt());
206 query.bindValue(":settingname", settingName);
211 QByteArray rawData = query.value(0).toByteArray();
212 QDataStream in(&rawData, QIODevice::ReadOnly);
213 in.setVersion(QDataStream::Qt_4_2);
221 IdentityId SqliteStorage::createIdentity(UserId user, CoreIdentity &identity) {
222 IdentityId identityId;
224 QSqlQuery query(logDb());
225 query.prepare(queryString("insert_identity"));
226 query.bindValue(":userid", user.toInt());
227 query.bindValue(":identityname", identity.identityName());
228 query.bindValue(":realname", identity.realName());
229 query.bindValue(":awaynick", identity.awayNick());
230 query.bindValue(":awaynickenabled", identity.awayNickEnabled() ? 1 : 0);
231 query.bindValue(":awayreason", identity.awayReason());
232 query.bindValue(":awayreasonenabled", identity.awayReasonEnabled() ? 1 : 0);
233 query.bindValue(":autoawayenabled", identity.awayReasonEnabled() ? 1 : 0);
234 query.bindValue(":autoawaytime", identity.autoAwayTime());
235 query.bindValue(":autoawayreason", identity.autoAwayReason());
236 query.bindValue(":autoawayreasonenabled", identity.autoAwayReasonEnabled() ? 1 : 0);
237 query.bindValue(":detachawayenabled", identity.detachAwayEnabled() ? 1 : 0);
238 query.bindValue(":detachawayreason", identity.detachAwayReason());
239 query.bindValue(":detachawayreasonenabled", identity.detachAwayReasonEnabled() ? 1 : 0);
240 query.bindValue(":ident", identity.ident());
241 query.bindValue(":kickreason", identity.kickReason());
242 query.bindValue(":partreason", identity.partReason());
243 query.bindValue(":quitreason", identity.quitReason());
245 query.bindValue(":sslcert", identity.sslCert().toPem());
246 query.bindValue(":sslkey", identity.sslKey().toPem());
248 query.bindValue(":sslcert", QByteArray());
249 query.bindValue(":sslkey", QByteArray());
254 identityId = query.lastInsertId().toInt();
255 if(!identityId.isValid()) {
258 QSqlQuery deleteNickQuery(logDb());
259 deleteNickQuery.prepare(queryString("delete_nicks"));
260 deleteNickQuery.bindValue(":identityid", identityId.toInt());
261 safeExec(deleteNickQuery);
263 QSqlQuery insertNickQuery(logDb());
264 insertNickQuery.prepare(queryString("insert_nick"));
265 foreach(QString nick, identity.nicks()) {
266 insertNickQuery.bindValue(":identityid", identityId.toInt());
267 insertNickQuery.bindValue(":nick", nick);
268 safeExec(insertNickQuery);
271 identity.setId(identityId);
275 bool SqliteStorage::updateIdentity(UserId user, const CoreIdentity &identity) {
276 QSqlQuery checkQuery(logDb());
277 checkQuery.prepare(queryString("select_checkidentity"));
278 checkQuery.bindValue(":identityid", identity.id().toInt());
279 checkQuery.bindValue(":userid", user.toInt());
280 safeExec(checkQuery);
282 if(!checkQuery.first() || checkQuery.value(0).toInt() != 1) // there should be exactly one identity for the given id and user
285 QSqlQuery query(logDb());
286 query.prepare(queryString("update_identity"));
287 query.bindValue(":identityname", identity.identityName());
288 query.bindValue(":realname", identity.realName());
289 query.bindValue(":awaynick", identity.awayNick());
290 query.bindValue(":awaynickenabled", identity.awayNickEnabled() ? 1 : 0);
291 query.bindValue(":awayreason", identity.awayReason());
292 query.bindValue(":awayreasonenabled", identity.awayReasonEnabled() ? 1 : 0);
293 query.bindValue(":autoawayenabled", identity.awayReasonEnabled() ? 1 : 0);
294 query.bindValue(":autoawaytime", identity.autoAwayTime());
295 query.bindValue(":autoawayreason", identity.autoAwayReason());
296 query.bindValue(":autoawayreasonenabled", identity.autoAwayReasonEnabled() ? 1 : 0);
297 query.bindValue(":detachawayenabled", identity.detachAwayEnabled() ? 1 : 0);
298 query.bindValue(":detachawayreason", identity.detachAwayReason());
299 query.bindValue(":detachawayreasonenabled", identity.detachAwayReasonEnabled() ? 1 : 0);
300 query.bindValue(":ident", identity.ident());
301 query.bindValue(":kickreason", identity.kickReason());
302 query.bindValue(":partreason", identity.partReason());
303 query.bindValue(":quitreason", identity.quitReason());
305 query.bindValue(":sslcert", identity.sslCert().toPem());
306 query.bindValue(":sslkey", identity.sslKey().toPem());
308 query.bindValue(":sslcert", QByteArray());
309 query.bindValue(":sslkey", QByteArray());
311 query.bindValue(":identityid", identity.id().toInt());
315 QSqlQuery deleteNickQuery(logDb());
316 deleteNickQuery.prepare(queryString("delete_nicks"));
317 deleteNickQuery.bindValue(":identityid", identity.id().toInt());
318 safeExec(deleteNickQuery);
319 watchQuery(deleteNickQuery);
321 QSqlQuery insertNickQuery(logDb());
322 insertNickQuery.prepare(queryString("insert_nick"));
323 foreach(QString nick, identity.nicks()) {
324 insertNickQuery.bindValue(":identityid", identity.id().toInt());
325 insertNickQuery.bindValue(":nick", nick);
326 safeExec(insertNickQuery);
327 watchQuery(insertNickQuery);
333 void SqliteStorage::removeIdentity(UserId user, IdentityId identityId) {
334 QSqlQuery checkQuery(logDb());
335 checkQuery.prepare(queryString("select_checkidentity"));
336 checkQuery.bindValue(":identityid", identityId.toInt());
337 checkQuery.bindValue(":userid", user.toInt());
338 safeExec(checkQuery);
340 if(!checkQuery.first() || checkQuery.value(0).toInt() != 1) // there should be exactly one identity for the given id and user
343 QSqlQuery deleteNickQuery(logDb());
344 deleteNickQuery.prepare(queryString("delete_nicks"));
345 deleteNickQuery.bindValue(":identityid", identityId.toInt());
346 safeExec(deleteNickQuery);
348 QSqlQuery deleteIdentityQuery(logDb());
349 deleteIdentityQuery.prepare(queryString("delete_identity"));
350 deleteIdentityQuery.bindValue(":identityid", identityId.toInt());
351 deleteIdentityQuery.bindValue(":userid", user.toInt());
352 safeExec(deleteIdentityQuery);
355 QList<CoreIdentity> SqliteStorage::identities(UserId user) {
356 QList<CoreIdentity> identities;
358 QSqlQuery query(logDb());
359 query.prepare(queryString("select_identities"));
360 query.bindValue(":userid", user.toInt());
362 QSqlQuery nickQuery(logDb());
363 nickQuery.prepare(queryString("select_nicks"));
367 while(query.next()) {
368 CoreIdentity identity(IdentityId(query.value(0).toInt()));
370 identity.setIdentityName(query.value(1).toString());
371 identity.setRealName(query.value(2).toString());
372 identity.setAwayNick(query.value(3).toString());
373 identity.setAwayNickEnabled(!!query.value(4).toInt());
374 identity.setAwayReason(query.value(5).toString());
375 identity.setAwayReasonEnabled(!!query.value(6).toInt());
376 identity.setAutoAwayEnabled(!!query.value(7).toInt());
377 identity.setAutoAwayTime(query.value(8).toInt());
378 identity.setAutoAwayReason(query.value(9).toString());
379 identity.setAutoAwayReasonEnabled(!!query.value(10).toInt());
380 identity.setDetachAwayEnabled(!!query.value(11).toInt());
381 identity.setDetachAwayReason(query.value(12).toString());
382 identity.setDetachAwayReasonEnabled(!!query.value(13).toInt());
383 identity.setIdent(query.value(14).toString());
384 identity.setKickReason(query.value(15).toString());
385 identity.setPartReason(query.value(16).toString());
386 identity.setQuitReason(query.value(17).toString());
388 identity.setSslCert(query.value(18).toByteArray());
389 identity.setSslKey(query.value(19).toByteArray());
392 nickQuery.bindValue(":identityid", identity.id().toInt());
393 QList<QString> nicks;
395 watchQuery(nickQuery);
396 while(nickQuery.next()) {
397 nicks << nickQuery.value(0).toString();
399 identity.setNicks(nicks);
400 identities << identity;
405 NetworkId SqliteStorage::createNetwork(UserId user, const NetworkInfo &info) {
407 QSqlQuery query(logDb());
408 query.prepare(queryString("insert_network"));
409 query.bindValue(":userid", user.toInt());
410 query.bindValue(":networkname", info.networkName);
413 networkId = getNetworkId(user, info.networkName);
414 if(!networkId.isValid()) {
417 NetworkInfo newNetworkInfo = info;
418 newNetworkInfo.networkId = networkId;
419 updateNetwork(user, newNetworkInfo);
424 bool SqliteStorage::updateNetwork(UserId user, const NetworkInfo &info) {
425 if(!isValidNetwork(user, info.networkId))
428 QSqlQuery updateQuery(logDb());
429 updateQuery.prepare(queryString("update_network"));
430 updateQuery.bindValue(":networkname", info.networkName);
431 updateQuery.bindValue(":identityid", info.identity.toInt());
432 updateQuery.bindValue(":usecustomencoding", info.useCustomEncodings ? 1 : 0);
433 updateQuery.bindValue(":encodingcodec", QString(info.codecForEncoding));
434 updateQuery.bindValue(":decodingcodec", QString(info.codecForDecoding));
435 updateQuery.bindValue(":servercodec", QString(info.codecForServer));
436 updateQuery.bindValue(":userandomserver", info.useRandomServer ? 1 : 0);
437 updateQuery.bindValue(":perform", info.perform.join("\n"));
438 updateQuery.bindValue(":useautoidentify", info.useAutoIdentify ? 1 : 0);
439 updateQuery.bindValue(":autoidentifyservice", info.autoIdentifyService);
440 updateQuery.bindValue(":autoidentifypassword", info.autoIdentifyPassword);
441 updateQuery.bindValue(":useautoreconnect", info.useAutoReconnect ? 1 : 0);
442 updateQuery.bindValue(":autoreconnectinterval", info.autoReconnectInterval);
443 updateQuery.bindValue(":autoreconnectretries", info.autoReconnectRetries);
444 updateQuery.bindValue(":unlimitedconnectretries", info.unlimitedReconnectRetries ? 1 : 0);
445 updateQuery.bindValue(":rejoinchannels", info.rejoinChannels ? 1 : 0);
446 updateQuery.bindValue(":networkid", info.networkId.toInt());
447 safeExec(updateQuery);
448 if(!watchQuery(updateQuery))
451 QSqlQuery dropServersQuery(logDb());
452 dropServersQuery.prepare("DELETE FROM ircserver WHERE networkid = :networkid");
453 dropServersQuery.bindValue(":networkid", info.networkId.toInt());
454 safeExec(dropServersQuery);
455 if(!watchQuery(dropServersQuery))
458 QSqlQuery insertServersQuery(logDb());
459 insertServersQuery.prepare(queryString("insert_server"));
460 foreach(Network::Server server, info.serverList) {
461 insertServersQuery.bindValue(":userid", user.toInt());
462 insertServersQuery.bindValue(":networkid", info.networkId.toInt());
463 insertServersQuery.bindValue(":hostname", server.host);
464 insertServersQuery.bindValue(":port", server.port);
465 insertServersQuery.bindValue(":password", server.password);
466 insertServersQuery.bindValue(":ssl", server.useSsl ? 1 : 0);
467 insertServersQuery.bindValue(":sslversion", server.sslVersion);
468 insertServersQuery.bindValue(":useproxy", server.useProxy ? 1 : 0);
469 insertServersQuery.bindValue(":proxytype", server.proxyType);
470 insertServersQuery.bindValue(":proxyhost", server.proxyHost);
471 insertServersQuery.bindValue(":proxyport", server.proxyPort);
472 insertServersQuery.bindValue(":proxyuser", server.proxyUser);
473 insertServersQuery.bindValue(":proxypass", server.proxyPass);
475 safeExec(insertServersQuery);
476 if(!watchQuery(insertServersQuery))
483 bool SqliteStorage::removeNetwork(UserId user, const NetworkId &networkId) {
484 if(!isValidNetwork(user, networkId))
487 bool withTransaction = logDb().driver()->hasFeature(QSqlDriver::Transactions);
488 if(withTransaction) {
490 if(!logDb().transaction()) {
491 qWarning() << "SqliteStorage::removeNetwork(): cannot start transaction. continuing with out rollback support!";
492 withTransaction = false;
496 QSqlQuery deleteBacklogQuery(logDb());
497 deleteBacklogQuery.prepare(queryString("delete_backlog_for_network"));
498 deleteBacklogQuery.bindValue(":networkid", networkId.toInt());
499 safeExec(deleteBacklogQuery);
500 if(!watchQuery(deleteBacklogQuery)) {
506 QSqlQuery deleteBuffersQuery(logDb());
507 deleteBuffersQuery.prepare(queryString("delete_buffers_for_network"));
508 deleteBuffersQuery.bindValue(":networkid", networkId.toInt());
509 safeExec(deleteBuffersQuery);
510 if(!watchQuery(deleteBuffersQuery)) {
516 QSqlQuery deleteServersQuery(logDb());
517 deleteServersQuery.prepare(queryString("delete_ircservers_for_network"));
518 deleteServersQuery.bindValue(":networkid", networkId.toInt());
519 safeExec(deleteServersQuery);
520 if(!watchQuery(deleteServersQuery)) {
526 QSqlQuery deleteNetworkQuery(logDb());
527 deleteNetworkQuery.prepare(queryString("delete_network"));
528 deleteNetworkQuery.bindValue(":networkid", networkId.toInt());
529 safeExec(deleteNetworkQuery);
530 if(!watchQuery(deleteNetworkQuery)) {
540 QList<NetworkInfo> SqliteStorage::networks(UserId user) {
541 QList<NetworkInfo> nets;
543 QSqlQuery networksQuery(logDb());
544 networksQuery.prepare(queryString("select_networks_for_user"));
545 networksQuery.bindValue(":userid", user.toInt());
547 QSqlQuery serversQuery(logDb());
548 serversQuery.prepare(queryString("select_servers_for_network"));
550 safeExec(networksQuery);
551 if(!watchQuery(networksQuery))
554 while(networksQuery.next()) {
556 net.networkId = networksQuery.value(0).toInt();
557 net.networkName = networksQuery.value(1).toString();
558 net.identity = networksQuery.value(2).toInt();
559 net.codecForServer = networksQuery.value(3).toString().toAscii();
560 net.codecForEncoding = networksQuery.value(4).toString().toAscii();
561 net.codecForDecoding = networksQuery.value(5).toString().toAscii();
562 net.useRandomServer = networksQuery.value(6).toInt() == 1 ? true : false;
563 net.perform = networksQuery.value(7).toString().split("\n");
564 net.useAutoIdentify = networksQuery.value(8).toInt() == 1 ? true : false;
565 net.autoIdentifyService = networksQuery.value(9).toString();
566 net.autoIdentifyPassword = networksQuery.value(10).toString();
567 net.useAutoReconnect = networksQuery.value(11).toInt() == 1 ? true : false;
568 net.autoReconnectInterval = networksQuery.value(12).toUInt();
569 net.autoReconnectRetries = networksQuery.value(13).toInt();
570 net.unlimitedReconnectRetries = networksQuery.value(14).toInt() == 1 ? true : false;
571 net.rejoinChannels = networksQuery.value(15).toInt() == 1 ? true : false;
573 serversQuery.bindValue(":networkid", net.networkId.toInt());
574 safeExec(serversQuery);
575 if(!watchQuery(serversQuery))
578 Network::ServerList servers;
579 while(serversQuery.next()) {
580 Network::Server server;
581 server.host = serversQuery.value(0).toString();
582 server.port = serversQuery.value(1).toUInt();
583 server.password = serversQuery.value(2).toString();
584 server.useSsl = serversQuery.value(3).toInt() == 1 ? true : false;
585 server.sslVersion = serversQuery.value(4).toInt();
586 server.useProxy = serversQuery.value(5).toInt() == 1 ? true : false;
587 server.proxyType = serversQuery.value(6).toInt();
588 server.proxyHost = serversQuery.value(7).toString();
589 server.proxyPort = serversQuery.value(8).toUInt();
590 server.proxyUser = serversQuery.value(9).toString();
591 server.proxyPass = serversQuery.value(10).toString();
594 net.serverList = servers;
600 bool SqliteStorage::isValidNetwork(UserId user, const NetworkId &networkId) {
601 QSqlQuery query(logDb());
602 query.prepare(queryString("select_networkExists"));
603 query.bindValue(":userid", user.toInt());
604 query.bindValue(":networkid", networkId.toInt());
607 watchQuery(query); // there should not occur any errors
611 Q_ASSERT(!query.next());
615 bool SqliteStorage::isValidBuffer(const UserId &user, const BufferId &bufferId) {
616 QSqlQuery query(logDb());
617 query.prepare(queryString("select_bufferExists"));
618 query.bindValue(":userid", user.toInt());
619 query.bindValue(":bufferid", bufferId.toInt());
626 Q_ASSERT(!query.next());
630 NetworkId SqliteStorage::getNetworkId(UserId user, const QString &network) {
631 QSqlQuery query(logDb());
632 query.prepare("SELECT networkid FROM network "
633 "WHERE userid = :userid AND networkname = :networkname");
634 query.bindValue(":userid", user.toInt());
635 query.bindValue(":networkname", network);
639 return query.value(0).toInt();
644 QList<NetworkId> SqliteStorage::connectedNetworks(UserId user) {
645 QList<NetworkId> connectedNets;
646 QSqlQuery query(logDb());
647 query.prepare(queryString("select_connected_networks"));
648 query.bindValue(":userid", user.toInt());
652 while(query.next()) {
653 connectedNets << query.value(0).toInt();
656 return connectedNets;
659 void SqliteStorage::setNetworkConnected(UserId user, const NetworkId &networkId, bool isConnected) {
660 QSqlQuery query(logDb());
661 query.prepare(queryString("update_network_connected"));
662 query.bindValue(":userid", user.toInt());
663 query.bindValue(":networkid", networkId.toInt());
664 query.bindValue(":connected", isConnected ? 1 : 0);
669 QHash<QString, QString> SqliteStorage::persistentChannels(UserId user, const NetworkId &networkId) {
670 QHash<QString, QString> persistentChans;
671 QSqlQuery query(logDb());
672 query.prepare(queryString("select_persistent_channels"));
673 query.bindValue(":userid", user.toInt());
674 query.bindValue(":networkid", networkId.toInt());
678 while(query.next()) {
679 persistentChans[query.value(0).toString()] = query.value(1).toString();
682 return persistentChans;
685 void SqliteStorage::setChannelPersistent(UserId user, const NetworkId &networkId, const QString &channel, bool isJoined) {
686 QSqlQuery query(logDb());
687 query.prepare(queryString("update_buffer_persistent_channel"));
688 query.bindValue(":userid", user.toInt());
689 query.bindValue(":networkId", networkId.toInt());
690 query.bindValue(":buffercname", channel.toLower());
691 query.bindValue(":joined", isJoined ? 1 : 0);
696 void SqliteStorage::setPersistentChannelKey(UserId user, const NetworkId &networkId, const QString &channel, const QString &key) {
697 QSqlQuery query(logDb());
698 query.prepare(queryString("update_buffer_set_channel_key"));
699 query.bindValue(":userid", user.toInt());
700 query.bindValue(":networkId", networkId.toInt());
701 query.bindValue(":buffercname", channel.toLower());
702 query.bindValue(":key", key);
707 QString SqliteStorage::awayMessage(UserId user, NetworkId networkId) {
708 QSqlQuery query(logDb());
709 query.prepare(queryString("select_network_awaymsg"));
710 query.bindValue(":userid", user.toInt());
711 query.bindValue(":networkid", networkId.toInt());
716 awayMsg = query.value(0).toString();
720 void SqliteStorage::setAwayMessage(UserId user, NetworkId networkId, const QString &awayMsg) {
721 QSqlQuery query(logDb());
722 query.prepare(queryString("update_network_set_awaymsg"));
723 query.bindValue(":userid", user.toInt());
724 query.bindValue(":networkid", networkId.toInt());
725 query.bindValue(":awaymsg", awayMsg);
730 QString SqliteStorage::userModes(UserId user, NetworkId networkId) {
731 QSqlQuery query(logDb());
732 query.prepare(queryString("select_network_usermode"));
733 query.bindValue(":userid", user.toInt());
734 query.bindValue(":networkid", networkId.toInt());
739 modes = query.value(0).toString();
743 void SqliteStorage::setUserModes(UserId user, NetworkId networkId, const QString &userModes) {
744 QSqlQuery query(logDb());
745 query.prepare(queryString("update_network_set_usermode"));
746 query.bindValue(":userid", user.toInt());
747 query.bindValue(":networkid", networkId.toInt());
748 query.bindValue(":usermode", userModes);
753 void SqliteStorage::createBuffer(UserId user, const NetworkId &networkId, BufferInfo::Type type, const QString &buffer) {
754 QSqlQuery query(logDb());
755 query.prepare(queryString("insert_buffer"));
756 query.bindValue(":userid", user.toInt());
757 query.bindValue(":networkid", networkId.toInt());
758 query.bindValue(":buffertype", (int)type);
759 query.bindValue(":buffername", buffer);
760 query.bindValue(":buffercname", buffer.toLower());
766 BufferInfo SqliteStorage::bufferInfo(UserId user, const NetworkId &networkId, BufferInfo::Type type, const QString &buffer, bool create) {
767 QSqlQuery query(logDb());
768 query.prepare(queryString("select_bufferByName"));
769 query.bindValue(":networkid", networkId.toInt());
770 query.bindValue(":userid", user.toInt());
771 query.bindValue(":buffercname", buffer.toLower());
778 createBuffer(user, networkId, type, buffer);
782 qWarning() << "unable to create BufferInfo for:" << user << networkId << buffer;
787 BufferInfo bufferInfo = BufferInfo(query.value(0).toInt(), networkId, (BufferInfo::Type)query.value(1).toInt(), 0, buffer);
789 qCritical() << "SqliteStorage::getBufferInfo(): received more then one Buffer!";
790 qCritical() << " Query:" << query.lastQuery();
791 qCritical() << " bound Values:";
792 QList<QVariant> list = query.boundValues().values();
793 for (int i = 0; i < list.size(); ++i)
794 qCritical() << i << ":" << list.at(i).toString().toAscii().data();
801 BufferInfo SqliteStorage::getBufferInfo(UserId user, const BufferId &bufferId) {
802 QSqlQuery query(logDb());
803 query.prepare(queryString("select_buffer_by_id"));
804 query.bindValue(":userid", user.toInt());
805 query.bindValue(":bufferid", bufferId.toInt());
807 if(!watchQuery(query))
813 BufferInfo bufferInfo(query.value(0).toInt(), query.value(1).toInt(), (BufferInfo::Type)query.value(2).toInt(), 0, query.value(4).toString());
814 Q_ASSERT(!query.next());
819 QList<BufferInfo> SqliteStorage::requestBuffers(UserId user) {
820 QList<BufferInfo> bufferlist;
821 QSqlQuery query(logDb());
822 query.prepare(queryString("select_buffers"));
823 query.bindValue(":userid", user.toInt());
827 while(query.next()) {
828 bufferlist << BufferInfo(query.value(0).toInt(), query.value(1).toInt(), (BufferInfo::Type)query.value(2).toInt(), query.value(3).toInt(), query.value(4).toString());
833 QList<BufferId> SqliteStorage::requestBufferIdsForNetwork(UserId user, NetworkId networkId) {
834 QList<BufferId> bufferList;
835 QSqlQuery query(logDb());
836 query.prepare(queryString("select_buffers_for_network"));
837 query.bindValue(":networkid", networkId.toInt());
838 query.bindValue(":userid", user.toInt());
842 while(query.next()) {
843 bufferList << BufferId(query.value(0).toInt());
848 bool SqliteStorage::removeBuffer(const UserId &user, const BufferId &bufferId) {
849 if(!isValidBuffer(user, bufferId))
852 QSqlQuery delBacklogQuery(logDb());
853 delBacklogQuery.prepare(queryString("delete_backlog_for_buffer"));
854 delBacklogQuery.bindValue(":bufferid", bufferId.toInt());
855 safeExec(delBacklogQuery);
856 if(!watchQuery(delBacklogQuery))
859 QSqlQuery delBufferQuery(logDb());
860 delBufferQuery.prepare(queryString("delete_buffer_for_bufferid"));
861 delBufferQuery.bindValue(":bufferid", bufferId.toInt());
862 safeExec(delBufferQuery);
863 if(!watchQuery(delBufferQuery))
869 bool SqliteStorage::renameBuffer(const UserId &user, const BufferId &bufferId, const QString &newName) {
870 if(!isValidBuffer(user, bufferId))
873 QSqlQuery query(logDb());
874 query.prepare(queryString("update_buffer_name"));
875 query.bindValue(":buffername", newName);
876 query.bindValue(":buffercname", newName.toLower());
877 query.bindValue(":bufferid", bufferId.toInt());
879 if(query.lastError().isValid()) {
880 // unexepcted error occured (19 == constraint violation)
881 if(query.lastError().number() != 19)
889 bool SqliteStorage::mergeBuffersPermanently(const UserId &user, const BufferId &bufferId1, const BufferId &bufferId2) {
890 if(!isValidBuffer(user, bufferId1) || !isValidBuffer(user, bufferId2))
893 QSqlQuery query(logDb());
894 query.prepare(queryString("update_backlog_bufferid"));
895 query.bindValue(":oldbufferid", bufferId2.toInt());
896 query.bindValue(":newbufferid", bufferId1.toInt());
898 if(!watchQuery(query))
901 QSqlQuery delBufferQuery(logDb());
902 delBufferQuery.prepare(queryString("delete_buffer_for_bufferid"));
903 delBufferQuery.bindValue(":bufferid", bufferId2.toInt());
904 safeExec(delBufferQuery);
905 watchQuery(delBufferQuery);
910 void SqliteStorage::setBufferLastSeenMsg(UserId user, const BufferId &bufferId, const MsgId &msgId) {
911 QSqlQuery query(logDb());
912 query.prepare(queryString("update_buffer_lastseen"));
914 query.bindValue(":userid", user.toInt());
915 query.bindValue(":bufferid", bufferId.toInt());
916 query.bindValue(":lastseenmsgid", msgId.toInt());
921 QHash<BufferId, MsgId> SqliteStorage::bufferLastSeenMsgIds(UserId user) {
922 QHash<BufferId, MsgId> lastSeenHash;
923 QSqlQuery query(logDb());
924 query.prepare(queryString("select_buffer_lastseen_messages"));
925 query.bindValue(":userid", user.toInt());
927 if(!watchQuery(query))
930 while(query.next()) {
931 lastSeenHash[query.value(0).toInt()] = query.value(1).toInt();
936 MsgId SqliteStorage::logMessage(Message msg) {
937 QSqlQuery logMessageQuery(logDb());
938 logMessageQuery.prepare(queryString("insert_message"));
940 logMessageQuery.bindValue(":time", msg.timestamp().toTime_t());
941 logMessageQuery.bindValue(":bufferid", msg.bufferInfo().bufferId().toInt());
942 logMessageQuery.bindValue(":type", msg.type());
943 logMessageQuery.bindValue(":flags", (int)msg.flags());
944 logMessageQuery.bindValue(":sender", msg.sender());
945 logMessageQuery.bindValue(":message", msg.contents());
946 safeExec(logMessageQuery);
948 if(logMessageQuery.lastError().isValid()) {
949 // constraint violation - must be NOT NULL constraint - probably the sender is missing...
950 if(logMessageQuery.lastError().number() == 19) {
951 QSqlQuery addSenderQuery(logDb());
952 addSenderQuery.prepare(queryString("insert_sender"));
953 addSenderQuery.bindValue(":sender", msg.sender());
954 safeExec(addSenderQuery);
955 safeExec(logMessageQuery);
956 if(!watchQuery(logMessageQuery))
959 watchQuery(logMessageQuery);
963 MsgId msgId = logMessageQuery.lastInsertId().toInt();
964 Q_ASSERT(msgId.isValid());
968 QList<Message> SqliteStorage::requestMsgs(UserId user, BufferId bufferId, MsgId first, MsgId last, int limit) {
969 QList<Message> messagelist;
971 BufferInfo bufferInfo = getBufferInfo(user, bufferId);
972 if(!bufferInfo.isValid())
975 QSqlQuery query(logDb());
977 if(last == -1 && first == -1) {
978 query.prepare(queryString("select_messagesNewestK"));
979 } else if(last == -1) {
980 query.prepare(queryString("select_messagesNewerThan"));
981 query.bindValue(":firstmsg", first.toInt());
983 query.prepare(queryString("select_messages"));
984 query.bindValue(":lastmsg", last.toInt());
985 query.bindValue(":firstmsg", first.toInt());
988 query.bindValue(":bufferid", bufferId.toInt());
989 query.bindValue(":limit", limit);
994 while(query.next()) {
995 Message msg(QDateTime::fromTime_t(query.value(1).toInt()),
997 (Message::Type)query.value(2).toUInt(),
998 query.value(5).toString(),
999 query.value(4).toString(),
1000 (Message::Flags)query.value(3).toUInt());
1001 msg.setMsgId(query.value(0).toInt());
1007 QList<Message> SqliteStorage::requestAllMsgs(UserId user, MsgId first, MsgId last, int limit) {
1008 QList<Message> messagelist;
1010 QHash<BufferId, BufferInfo> bufferInfoHash;
1011 foreach(BufferInfo bufferInfo, requestBuffers(user)) {
1012 bufferInfoHash[bufferInfo.bufferId()] = bufferInfo;
1015 QSqlQuery query(logDb());
1017 query.prepare(queryString("select_messagesAllNew"));
1019 query.prepare(queryString("select_messagesAll"));
1020 query.bindValue(":lastmsg", last.toInt());
1022 query.bindValue(":userid", user.toInt());
1023 query.bindValue(":firstmsg", first.toInt());
1024 query.bindValue(":limit", limit);
1029 while(query.next()) {
1030 Message msg(QDateTime::fromTime_t(query.value(2).toInt()),
1031 bufferInfoHash[query.value(1).toInt()],
1032 (Message::Type)query.value(3).toUInt(),
1033 query.value(6).toString(),
1034 query.value(5).toString(),
1035 (Message::Flags)query.value(4).toUInt());
1036 msg.setMsgId(query.value(0).toInt());
1043 QString SqliteStorage::backlogFile() {
1044 return Quassel::configDirPath() + "quassel-storage.sqlite";
1047 bool SqliteStorage::safeExec(QSqlQuery &query, int retryCount) {
1050 if(!query.lastError().isValid())
1053 switch(query.lastError().number()) {
1054 case 5: // SQLITE_BUSY 5 /* The database file is locked */
1055 case 6: // SQLITE_LOCKED 6 /* A table in the database is locked */
1056 if(retryCount < _maxRetryCount)
1057 return safeExec(query, retryCount + 1);