+QString SqliteStorage::displayName() const {
+ // We identify the backend to use for the monolithic core by its displayname.
+ // so only change this string if you _really_ have to and make sure the core
+ // setup for the mono client still works ;)
+ return QString("SQLite");
+}
+
+QString SqliteStorage::description() const {
+ return tr("SQLite is a file-based database engine that does not require any setup. It is suitable for small and medium-sized "
+ "databases that do not require access via network. Use SQLite if your Quassel Core should store its data on the same machine "
+ "it is running on, and if you only expect a few users to use your core.");
+}
+
+int SqliteStorage::installedSchemaVersion() {
+ // only used when there is a singlethread (during startup)
+ // so we don't need locking here
+ QSqlQuery query = logDb().exec("SELECT value FROM coreinfo WHERE key = 'schemaversion'");
+ if(query.first())
+ return query.value(0).toInt();
+
+ // maybe it's really old... (schema version 0)
+ query = logDb().exec("SELECT MAX(version) FROM coreinfo");
+ if(query.first())
+ return query.value(0).toInt();
+
+ return AbstractSqlStorage::installedSchemaVersion();
+}
+
+bool SqliteStorage::updateSchemaVersion(int newVersion) {
+ // only used when there is a singlethread (during startup)
+ // so we don't need locking here
+ QSqlQuery query(logDb());
+ query.prepare("UPDATE coreinfo SET value = :version WHERE key = 'schemaversion'");
+ query.bindValue(":version", newVersion);
+ query.exec();
+
+ bool success = true;
+ if(query.lastError().isValid()) {
+ qCritical() << "SqliteStorage::updateSchemaVersion(int): Updating schema version failed!";
+ success = false;
+ }
+ return success;
+}
+
+bool SqliteStorage::setupSchemaVersion(int version) {
+ // only used when there is a singlethread (during startup)
+ // so we don't need locking here
+ QSqlQuery query(logDb());
+ query.prepare("INSERT INTO coreinfo (key, value) VALUES ('schemaversion', :version)");
+ query.bindValue(":version", version);
+ query.exec();
+
+ bool success = true;
+ if(query.lastError().isValid()) {
+ qCritical() << "SqliteStorage::setupSchemaVersion(int): Updating schema version failed!";
+ success = false;
+ }
+ return success;
+}
+
+UserId SqliteStorage::addUser(const QString &user, const QString &password) {
+ QSqlDatabase db = logDb();
+ UserId uid;
+
+ db.transaction();
+ // this scope ensures that the query is freed in sqlite before we call unlock()
+ // this ensures that our thread doesn't hold a internal after unlock is called
+ // (see sqlites doc on implicit locking for details)
+ {
+ QSqlQuery query(db);
+ query.prepare(queryString("insert_quasseluser"));
+ query.bindValue(":username", user);
+ query.bindValue(":password", cryptedPassword(password));
+ lockForWrite();
+ safeExec(query);
+ if(query.lastError().isValid() && query.lastError().number() == 19) { // user already exists - sadly 19 seems to be the general constraint violation error...
+ db.rollback();
+ } else {
+ uid = query.lastInsertId().toInt();
+ db.commit();
+ }
+ }
+ unlock();
+
+ if(uid.isValid())
+ emit userAdded(uid, user);
+ return uid;
+}
+
+bool SqliteStorage::updateUser(UserId user, const QString &password) {
+ QSqlDatabase db = logDb();
+ bool success = false;
+
+ db.transaction();
+ {
+ QSqlQuery query(db);
+ query.prepare(queryString("update_userpassword"));
+ query.bindValue(":userid", user.toInt());
+ query.bindValue(":password", cryptedPassword(password));
+ lockForWrite();
+ safeExec(query);
+ success = query.numRowsAffected() != 0;
+ db.commit();
+ }
+ unlock();
+ return success;
+}
+
+void SqliteStorage::renameUser(UserId user, const QString &newName) {
+ QSqlDatabase db = logDb();
+ db.transaction();
+ {
+ QSqlQuery query(db);
+ query.prepare(queryString("update_username"));
+ query.bindValue(":userid", user.toInt());
+ query.bindValue(":username", newName);
+ lockForWrite();
+ safeExec(query);
+ db.commit();
+ }
+ unlock();
+ emit userRenamed(user, newName);
+}
+
+UserId SqliteStorage::validateUser(const QString &user, const QString &password) {
+ UserId userId;
+
+ {
+ QSqlQuery query(logDb());
+ query.prepare(queryString("select_authuser"));
+ query.bindValue(":username", user);
+ query.bindValue(":password", cryptedPassword(password));
+
+ lockForRead();
+ safeExec(query);
+
+ if(query.first()) {
+ userId = query.value(0).toInt();
+ }
+ }
+ unlock();
+
+ return userId;
+}
+
+UserId SqliteStorage::getUserId(const QString &username) {
+ UserId userId;
+
+ {
+ QSqlQuery query(logDb());
+ query.prepare(queryString("select_userid"));
+ query.bindValue(":username", username);
+
+ lockForRead();
+ safeExec(query);
+
+ if(query.first()) {
+ userId = query.value(0).toInt();
+ }
+ }
+ unlock();
+
+ return userId;
+}
+
+UserId SqliteStorage::internalUser() {
+ UserId userId;
+
+ {
+ QSqlQuery query(logDb());
+ query.prepare(queryString("select_internaluser"));
+ lockForRead();
+ safeExec(query);
+
+ if(query.first()) {
+ userId = query.value(0).toInt();
+ }
+ }
+ unlock();
+
+ return userId;
+}
+
+void SqliteStorage::delUser(UserId user) {
+ QSqlDatabase db = logDb();
+ db.transaction();
+
+ lockForWrite();
+ {
+ QSqlQuery query(db);
+ query.prepare(queryString("delete_backlog_by_uid"));
+ query.bindValue(":userid", user.toInt());
+ safeExec(query);
+
+ query.prepare(queryString("delete_buffers_by_uid"));
+ query.bindValue(":userid", user.toInt());
+ safeExec(query);
+
+ query.prepare(queryString("delete_networks_by_uid"));
+ query.bindValue(":userid", user.toInt());
+ safeExec(query);
+
+ query.prepare(queryString("delete_quasseluser"));
+ query.bindValue(":userid", user.toInt());
+ safeExec(query);
+ // I hate the lack of foreign keys and on delete cascade... :(
+ db.commit();
+ }
+ unlock();
+
+ emit userRemoved(user);
+}
+
+void SqliteStorage::setUserSetting(UserId userId, const QString &settingName, const QVariant &data) {
+ QByteArray rawData;
+ QDataStream out(&rawData, QIODevice::WriteOnly);
+ out.setVersion(QDataStream::Qt_4_2);
+ out << data;
+
+ QSqlDatabase db = logDb();
+ db.transaction();
+ {
+ QSqlQuery query(db);
+ query.prepare(queryString("insert_user_setting"));
+ query.bindValue(":userid", userId.toInt());
+ query.bindValue(":settingname", settingName);
+ query.bindValue(":settingvalue", rawData);
+ lockForWrite();
+ safeExec(query);
+
+ if(query.lastError().isValid()) {
+ QSqlQuery updateQuery(db);
+ updateQuery.prepare(queryString("update_user_setting"));
+ updateQuery.bindValue(":userid", userId.toInt());
+ updateQuery.bindValue(":settingname", settingName);
+ updateQuery.bindValue(":settingvalue", rawData);
+ safeExec(updateQuery);
+ }
+ db.commit();
+ }
+ unlock();
+}
+
+QVariant SqliteStorage::getUserSetting(UserId userId, const QString &settingName, const QVariant &defaultData) {
+ QVariant data = defaultData;
+ {
+ QSqlQuery query(logDb());
+ query.prepare(queryString("select_user_setting"));
+ query.bindValue(":userid", userId.toInt());
+ query.bindValue(":settingname", settingName);
+ lockForRead();
+ safeExec(query);
+
+ if(query.first()) {
+ QByteArray rawData = query.value(0).toByteArray();
+ QDataStream in(&rawData, QIODevice::ReadOnly);
+ in.setVersion(QDataStream::Qt_4_2);
+ in >> data;
+ }
+ }
+ unlock();
+ return data;
+}
+
+IdentityId SqliteStorage::createIdentity(UserId user, CoreIdentity &identity) {
+ IdentityId identityId;
+
+ QSqlDatabase db = logDb();
+ db.transaction();
+
+ {
+ QSqlQuery query(db);
+ query.prepare(queryString("insert_identity"));
+ query.bindValue(":userid", user.toInt());
+ query.bindValue(":identityname", identity.identityName());
+ query.bindValue(":realname", identity.realName());
+ query.bindValue(":awaynick", identity.awayNick());
+ query.bindValue(":awaynickenabled", identity.awayNickEnabled() ? 1 : 0);
+ query.bindValue(":awayreason", identity.awayReason());
+ query.bindValue(":awayreasonenabled", identity.awayReasonEnabled() ? 1 : 0);
+ query.bindValue(":autoawayenabled", identity.awayReasonEnabled() ? 1 : 0);
+ query.bindValue(":autoawaytime", identity.autoAwayTime());
+ query.bindValue(":autoawayreason", identity.autoAwayReason());
+ query.bindValue(":autoawayreasonenabled", identity.autoAwayReasonEnabled() ? 1 : 0);
+ query.bindValue(":detachawayenabled", identity.detachAwayEnabled() ? 1 : 0);
+ query.bindValue(":detachawayreason", identity.detachAwayReason());
+ query.bindValue(":detachawayreasonenabled", identity.detachAwayReasonEnabled() ? 1 : 0);
+ query.bindValue(":ident", identity.ident());
+ query.bindValue(":kickreason", identity.kickReason());
+ query.bindValue(":partreason", identity.partReason());
+ query.bindValue(":quitreason", identity.quitReason());
+#ifdef HAVE_SSL
+ query.bindValue(":sslcert", identity.sslCert().toPem());
+ query.bindValue(":sslkey", identity.sslKey().toPem());
+#else
+ query.bindValue(":sslcert", QByteArray());
+ query.bindValue(":sslkey", QByteArray());
+#endif
+
+ lockForWrite();
+ safeExec(query);
+
+ identityId = query.lastInsertId().toInt();
+ if(!identityId.isValid()) {
+ watchQuery(query);
+ } else {
+ QSqlQuery deleteNickQuery(db);
+ deleteNickQuery.prepare(queryString("delete_nicks"));
+ deleteNickQuery.bindValue(":identityid", identityId.toInt());
+ safeExec(deleteNickQuery);
+
+ QSqlQuery insertNickQuery(db);
+ insertNickQuery.prepare(queryString("insert_nick"));
+ foreach(QString nick, identity.nicks()) {
+ insertNickQuery.bindValue(":identityid", identityId.toInt());
+ insertNickQuery.bindValue(":nick", nick);
+ safeExec(insertNickQuery);
+ }
+ }
+ db.commit();
+ }
+ unlock();
+ identity.setId(identityId);
+ return identityId;
+}
+
+bool SqliteStorage::updateIdentity(UserId user, const CoreIdentity &identity) {
+ QSqlDatabase db = logDb();
+ bool error = false;
+ db.transaction();
+
+ {
+ QSqlQuery checkQuery(db);
+ checkQuery.prepare(queryString("select_checkidentity"));
+ checkQuery.bindValue(":identityid", identity.id().toInt());
+ checkQuery.bindValue(":userid", user.toInt());
+ lockForRead();
+ safeExec(checkQuery);
+
+ // there should be exactly one identity for the given id and user
+ error = (!checkQuery.first() || checkQuery.value(0).toInt() != 1);
+ }
+ if(error) {
+ unlock();
+ return false;
+ }
+
+ {
+ QSqlQuery query(db);
+ query.prepare(queryString("update_identity"));
+ query.bindValue(":identityname", identity.identityName());
+ query.bindValue(":realname", identity.realName());
+ query.bindValue(":awaynick", identity.awayNick());
+ query.bindValue(":awaynickenabled", identity.awayNickEnabled() ? 1 : 0);
+ query.bindValue(":awayreason", identity.awayReason());
+ query.bindValue(":awayreasonenabled", identity.awayReasonEnabled() ? 1 : 0);
+ query.bindValue(":autoawayenabled", identity.awayReasonEnabled() ? 1 : 0);
+ query.bindValue(":autoawaytime", identity.autoAwayTime());
+ query.bindValue(":autoawayreason", identity.autoAwayReason());
+ query.bindValue(":autoawayreasonenabled", identity.autoAwayReasonEnabled() ? 1 : 0);
+ query.bindValue(":detachawayenabled", identity.detachAwayEnabled() ? 1 : 0);
+ query.bindValue(":detachawayreason", identity.detachAwayReason());
+ query.bindValue(":detachawayreasonenabled", identity.detachAwayReasonEnabled() ? 1 : 0);
+ query.bindValue(":ident", identity.ident());
+ query.bindValue(":kickreason", identity.kickReason());
+ query.bindValue(":partreason", identity.partReason());
+ query.bindValue(":quitreason", identity.quitReason());
+#ifdef HAVE_SSL
+ query.bindValue(":sslcert", identity.sslCert().toPem());
+ query.bindValue(":sslkey", identity.sslKey().toPem());
+#else
+ query.bindValue(":sslcert", QByteArray());
+ query.bindValue(":sslkey", QByteArray());
+#endif
+ query.bindValue(":identityid", identity.id().toInt());
+ safeExec(query);
+ watchQuery(query);
+
+ QSqlQuery deleteNickQuery(db);
+ deleteNickQuery.prepare(queryString("delete_nicks"));
+ deleteNickQuery.bindValue(":identityid", identity.id().toInt());
+ safeExec(deleteNickQuery);
+ watchQuery(deleteNickQuery);
+
+ QSqlQuery insertNickQuery(db);
+ insertNickQuery.prepare(queryString("insert_nick"));
+ foreach(QString nick, identity.nicks()) {
+ insertNickQuery.bindValue(":identityid", identity.id().toInt());
+ insertNickQuery.bindValue(":nick", nick);
+ safeExec(insertNickQuery);
+ watchQuery(insertNickQuery);
+ }
+ db.commit();
+ }
+ unlock();
+ return true;
+}
+
+void SqliteStorage::removeIdentity(UserId user, IdentityId identityId) {
+ QSqlDatabase db = logDb();
+ db.transaction();
+
+ bool error = false;
+ {
+ QSqlQuery checkQuery(db);
+ checkQuery.prepare(queryString("select_checkidentity"));
+ checkQuery.bindValue(":identityid", identityId.toInt());
+ checkQuery.bindValue(":userid", user.toInt());
+ lockForRead();
+ safeExec(checkQuery);
+
+ // there should be exactly one identity for the given id and user
+ error = (!checkQuery.first() || checkQuery.value(0).toInt() != 1);
+ }
+ if(error) {
+ unlock();
+ return;
+ }
+
+ {
+ QSqlQuery deleteNickQuery(db);
+ deleteNickQuery.prepare(queryString("delete_nicks"));
+ deleteNickQuery.bindValue(":identityid", identityId.toInt());
+ safeExec(deleteNickQuery);
+
+ QSqlQuery deleteIdentityQuery(db);
+ deleteIdentityQuery.prepare(queryString("delete_identity"));
+ deleteIdentityQuery.bindValue(":identityid", identityId.toInt());
+ deleteIdentityQuery.bindValue(":userid", user.toInt());
+ safeExec(deleteIdentityQuery);
+ db.commit();
+ }
+ unlock();