X-Git-Url: https://git.quassel-irc.org/?a=blobdiff_plain;f=src%2Fcore%2Fsqlitestorage.h;h=1c759ab9a7689458e1c32102280f9a3c81caabcf;hb=2633dc0cbc05936ad551e2c2b871478b32514aaa;hp=3f213067a1b860e36e8b69a9dedc5f39c7093778;hpb=698bd631332040f9a988ae8f31a80688893ca6f3;p=quassel.git diff --git a/src/core/sqlitestorage.h b/src/core/sqlitestorage.h index 3f213067..1c759ab9 100644 --- a/src/core/sqlitestorage.h +++ b/src/core/sqlitestorage.h @@ -34,12 +34,15 @@ public: SqliteStorage(QObject *parent = 0); virtual ~SqliteStorage(); + virtual AbstractSqlMigrationReader *createMigrationReader(); + public slots: /* General */ bool isAvailable() const; QString displayName() const; - inline QVariantMap setupKeys() const { return QVariantMap(); } + virtual inline QStringList setupKeys() const { return QStringList(); } + virtual inline QVariantMap setupDefaults() const { return QVariantMap(); } QString description() const; // TODO: Add functions for configuring the backlog handling, i.e. defining auto-cleanup settings etc @@ -125,16 +128,6 @@ class SqliteMigrationReader : public SqliteStorage, public AbstractSqlMigrationR public: SqliteMigrationReader(); -// virtual bool readUser(QuasselUserMO &user); -// virtual bool readSender(SenderMO &sender); -// virtual bool readIdentity(IdentityMO &identity); -// virtual bool readIdentityNick(IdentityNickMO &identityNick); -// virtual bool readNetwork(NetworkMO &network); -// virtual bool readBuffer(BufferMO &buffer); -// virtual bool readBacklog(BacklogMO &backlog); -// virtual bool readIrcServer(IrcServerMO &ircserver); -// virtual bool readUserSetting(UserSettingMO &userSetting); - virtual bool readMo(QuasselUserMO &user); virtual bool readMo(SenderMO &sender); virtual bool readMo(IdentityMO &identity); @@ -147,12 +140,20 @@ public: virtual bool prepareQuery(MigrationObject mo); + inline int stepSize() { return 50000; } + protected: virtual inline bool transaction() { return logDb().transaction(); } virtual inline void rollback() { logDb().rollback(); } virtual inline bool commit() { return logDb().commit(); } -}; +private: + void setMaxId(MigrationObject mo); + int _maxId; +}; +inline AbstractSqlMigrationReader *SqliteStorage::createMigrationReader() { + return new SqliteMigrationReader(); +} #endif