X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fcore%2Fabstractsqlstorage.h;h=e14abd929e100c05db181e4a81eef22f51a5abf1;hp=6fefb787ffda09ba094ca3733c2301ca7dafbd12;hb=0775b2fab5e91cbf3b40caa575d1ee44b6686350;hpb=59579d82e3a16a815a197a4300c8ef279275ccfc diff --git a/src/core/abstractsqlstorage.h b/src/core/abstractsqlstorage.h index 6fefb787..e14abd92 100644 --- a/src/core/abstractsqlstorage.h +++ b/src/core/abstractsqlstorage.h @@ -1,5 +1,5 @@ /*************************************************************************** - * Copyright (C) 2005-07 by the Quassel IRC Team * + * Copyright (C) 2005-07 by the Quassel Project * * devel@quassel-irc.org * * * * This program is free software; you can redistribute it and/or modify * @@ -24,8 +24,8 @@ #include "storage.h" #include - -class QSqlQuery; +#include +#include class AbstractSqlStorage : public Storage { Q_OBJECT @@ -34,21 +34,15 @@ public: AbstractSqlStorage(QObject *parent = 0); virtual ~AbstractSqlStorage(); - //! Returns the name of the storage backend engine - /** \return A virtual equivalent of displayName() */ - virtual QString engineName() { return ""; } - + virtual State init(const QVariantMap &settings = QVariantMap()); + protected: - bool init(const QVariantMap &settings = QVariantMap()); - virtual void sync(); - + inline virtual void sync() {}; + QSqlDatabase logDb(); - - QString queryString(const QString &queryName, int version); - QString queryString(const QString &queryName); - QSqlQuery *cachedQuery(const QString &queryName, int version); - QSqlQuery *cachedQuery(const QString &queryName); + QString queryString(const QString &queryName, int version); + inline QString queryString(const QString &queryName) { return queryString(queryName, 0); } QStringList setupQueries(); bool setup(const QVariantMap &settings = QVariantMap()); @@ -56,25 +50,254 @@ protected: QStringList upgradeQueries(int ver); bool upgradeDb(); - bool watchQuery(QSqlQuery *query); - + bool watchQuery(QSqlQuery &query); + int schemaVersion(); virtual int installedSchemaVersion() { return -1; }; + virtual bool updateSchemaVersion(int newVersion) = 0; + virtual bool setupSchemaVersion(int version) = 0; + virtual void setConnectionProperties(const QVariantMap &properties) = 0; virtual QString driverName() = 0; inline virtual QString hostName() { return QString(); } + inline virtual int port() { return -1; } virtual QString databaseName() = 0; inline virtual QString userName() { return QString(); } inline virtual QString password() { return QString(); } +private slots: + void connectionDestroyed(); + private: - bool openDb(); + void addConnectionToPool(); int _schemaVersion; - QHash, QSqlQuery *> _queryCache; + int _nextConnectionId; + QMutex _connectionPoolMutex; + // we let a Connection Object manage each actual db connection + // those objects reside in the thread the connection belongs to + // which allows us thread safe termination of a connection + class Connection; + QHash _connectionPool; +}; + +// ======================================== +// AbstractSqlStorage::Connection +// ======================================== +class AbstractSqlStorage::Connection : public QObject { + Q_OBJECT + +public: + Connection(const QString &name, QObject *parent = 0); + ~Connection(); + + inline QLatin1String name() const { return QLatin1String(_name); } + +private: + QByteArray _name; +}; + + +// ======================================== +// AbstractSqlMigrator +// ======================================== +class AbstractSqlMigrator { +public: + // migration objects + struct QuasselUserMO { + UserId id; + QString username; + QString password; + }; + + struct SenderMO { + int senderId; + QString sender; + }; + + struct IdentityMO { + IdentityId id; + UserId userid; + QString identityname; + QString realname; + QString awayNick; + bool awayNickEnabled; + QString awayReason; + bool awayReasonEnabled; + bool autoAwayEnabled; + int autoAwayTime; + QString autoAwayReason; + bool autoAwayReasonEnabled; + bool detachAwayEnabled; + QString detachAwayReason; + bool detchAwayReasonEnabled; + QString ident; + QString kickReason; + QString partReason; + QString quitReason; + QByteArray sslCert; + QByteArray sslKey; + }; + + struct IdentityNickMO { + int nickid; + IdentityId identityId; + QString nick; + }; + + struct NetworkMO { + NetworkId networkid; + UserId userid; + QString networkname; + IdentityId identityid; + QString encodingcodec; + QString decodingcodec; + QString servercodec; + bool userandomserver; + QString perform; + bool useautoidentify; + QString autoidentifyservice; + QString autoidentifypassword; + bool useautoreconnect; + int autoreconnectinterval; + int autoreconnectretries; + bool unlimitedconnectretries; + bool rejoinchannels; + bool connected; + QString usermode; + QString awaymessage; + QString attachperform; + QString detachperform; + }; + + struct BufferMO { + BufferId bufferid; + UserId userid; + int groupid; + NetworkId networkid; + QString buffername; + QString buffercname; + int buffertype; + int lastseenmsgid; + QString key; + bool joined; + }; + struct BacklogMO { + MsgId messageid; + QDateTime time; // has to be in UTC! + BufferId bufferid; + int type; + int flags; + int senderid; + QString message; + }; + + struct IrcServerMO { + int serverid; + UserId userid; + NetworkId networkid; + QString hostname; + int port; + QString password; + bool ssl; + int sslversion; + bool useproxy; + int proxytype; + QString proxyhost; + int proxyport; + QString proxyuser; + QString proxypass; + }; + + struct UserSettingMO { + UserId userid; + QString settingname; + QByteArray settingvalue; + }; + + enum MigrationObject { + QuasselUser, + Sender, + Identity, + IdentityNick, + Network, + Buffer, + Backlog, + IrcServer, + UserSetting + }; + + AbstractSqlMigrator(); + virtual ~AbstractSqlMigrator() {} + + static QString migrationObject(MigrationObject moType); + +protected: + void newQuery(const QString &query, QSqlDatabase db); + virtual void resetQuery(); + virtual bool prepareQuery(MigrationObject mo) = 0; + bool exec(); + inline bool next() { return _query->next(); } + inline QVariant value(int index) { return _query->value(index); } + inline void bindValue(const QString &placeholder, const QVariant &val) { _query->bindValue(placeholder, val); } + inline void bindValue(int pos, const QVariant &val) { _query->bindValue(pos, val); } + + inline QSqlError lastError() { return _query ? _query->lastError() : QSqlError(); } + void dumpStatus(); + inline QString executedQuery() { return _query ? _query->executedQuery() : QString(); } + inline QVariantList boundValues(); + + virtual bool transaction() = 0; + virtual void rollback() = 0; + virtual bool commit() = 0; + +private: + QSqlQuery *_query; +}; + +class AbstractSqlMigrationWriter; +class AbstractSqlMigrationReader : public AbstractSqlMigrator { +public: + AbstractSqlMigrationReader(); + + virtual bool readMo(QuasselUserMO &user) = 0; + virtual bool readMo(SenderMO &sender) = 0; + virtual bool readMo(IdentityMO &identity) = 0; + virtual bool readMo(IdentityNickMO &identityNick) = 0; + virtual bool readMo(NetworkMO &network) = 0; + virtual bool readMo(BufferMO &buffer) = 0; + virtual bool readMo(BacklogMO &backlog) = 0; + virtual bool readMo(IrcServerMO &ircserver) = 0; + virtual bool readMo(UserSettingMO &userSetting) = 0; + + bool migrateTo(AbstractSqlMigrationWriter *writer); + +private: + void abortMigration(const QString &errorMsg = QString()); + bool finalizeMigration(); + + template bool transferMo(MigrationObject moType, T &mo); + + AbstractSqlMigrationWriter *_writer; }; +class AbstractSqlMigrationWriter : public AbstractSqlMigrator { +public: + virtual bool writeMo(const QuasselUserMO &user) = 0; + virtual bool writeMo(const SenderMO &sender) = 0; + virtual bool writeMo(const IdentityMO &identity) = 0; + virtual bool writeMo(const IdentityNickMO &identityNick) = 0; + virtual bool writeMo(const NetworkMO &network) = 0; + virtual bool writeMo(const BufferMO &buffer) = 0; + virtual bool writeMo(const BacklogMO &backlog) = 0; + virtual bool writeMo(const IrcServerMO &ircserver) = 0; + virtual bool writeMo(const UserSettingMO &userSetting) = 0; + + inline bool migrateFrom(AbstractSqlMigrationReader *reader) { return reader->migrateTo(this); } + + friend class AbstractSqlMigrationReader; +}; #endif