stv0g/spectrum2
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

begin/commit transaction, update buddy statement

Browse source
This commit is contained in:
Jan Kaluza 2011-04-07 14:51:34 +02:00
parent ebebf04f69
commit 5855e6608c
2 changed files with 26 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
include/transport/sqlite3backend.h
View file

@ -81,11 +81,11 @@ class SQLite3Backend : public StorageBackend
long addBuddy(long userId, const BuddyInfo &buddyInfo);
void updateBuddy(long userId, const BuddyInfo &buddyInfo) {}
void updateBuddy(long userId, const BuddyInfo &buddyInfo);
void removeBuddy(long id) {}
void beginTransaction() {}
void commitTransaction() {}
void beginTransaction();
void commitTransaction();
private:
bool exec(const std::string &query);
@ -102,6 +102,7 @@ class SQLite3Backend : public StorageBackend
sqlite3_stmt *m_removeUserSettings;
sqlite3_stmt *m_removeUserBuddiesSettings;
sqlite3_stmt *m_addBuddy;
sqlite3_stmt *m_updateBuddy;
};
}

24
src/sqlite3backend.cpp
View file

@ -94,6 +94,7 @@ bool SQLite3Backend::connect() {
PREP_STMT(m_removeUserBuddiesSettings, "DELETE FROM " + m_prefix + "buddies_settings WHERE user_id=?");
PREP_STMT(m_addBuddy, "INSERT INTO " + m_prefix + "buddies (user_id, uin, subscription, groups, nickname, flags) VALUES (?, ?, ?, ?, ?, ?)");
PREP_STMT(m_updateBuddy, "UPDATE " + m_prefix + "buddies SET groups=?, nickname=?, flags=?, subscription=? WHERE user_id=? AND uin=?");
return true;
}
@ -218,8 +219,6 @@ long SQLite3Backend::addBuddy(long userId, const BuddyInfo &buddyInfo) {
BIND_STR(m_addBuddy, buddyInfo.alias);
BIND_INT(m_addBuddy, buddyInfo.flags);
EXECUTE_STATEMENT(m_addBuddy, "addBuddy query");
if(sqlite3_step(m_addBuddy) != SQLITE_DONE) {
onStorageError("addBuddy query", (sqlite3_errmsg(m_db) == NULL ? "" : sqlite3_errmsg(m_db)));
return -1;
@ -227,6 +226,19 @@ long SQLite3Backend::addBuddy(long userId, const BuddyInfo &buddyInfo) {
return (long) sqlite3_last_insert_rowid(m_db);
}
void SQLite3Backend::updateBuddy(long userId, const BuddyInfo &buddyInfo) {
// UPDATE " + m_prefix + "buddies SET groups=?, nickname=?, flags=?, subscription=? WHERE user_id=? AND uin=?
BEGIN(m_updateBuddy);
BIND_STR(m_updateBuddy, buddyInfo.groups[0]); // TODO: serialize groups
BIND_STR(m_updateBuddy, buddyInfo.alias);
BIND_INT(m_updateBuddy, buddyInfo.flags);
BIND_STR(m_updateBuddy, buddyInfo.subscription);
BIND_INT(m_updateBuddy, userId);
BIND_STR(m_updateBuddy, buddyInfo.legacyName);
EXECUTE_STATEMENT(m_updateBuddy, "updateBuddy query");
}
bool SQLite3Backend::getBuddies(long id, std::list<std::string> &roster) {
return true;
}
@ -263,4 +275,12 @@ bool SQLite3Backend::removeUser(long id) {
return true;
}
void SQLite3Backend::beginTransaction() {
exec("BEGIN TRANSACTION;");
}
void SQLite3Backend::commitTransaction() {
exec("COMMIT TRANSACTION;");
}
}