/// Returns JIDs of all buddies in user's roster.

		/// \param id id of user - UserInfo.id

		/// \param roster string list used to store user's roster

		/// \return true if user has been found in database and roster has been fetched

		bool getBuddies(long id, std::list<BuddyInfo> &roster);

		bool getOnlineUsers(std::vector<std::string> &users);

		long addBuddy(long userId, const BuddyInfo &buddyInfo);

		void updateBuddy(long userId, const BuddyInfo &buddyInfo);

		void getUserSetting(long userId, const std::string &variable, int &type, std::string &value);

		void updateUserSetting(long userId, const std::string &variable, const std::string &value);

		void beginTransaction();

		void commitTransaction();

	private:

		bool exec(const std::string &query);

		class Statement {

			public:

		// statements

// 		MYSQL_STMT *m_setUser;

		Statement *m_setUser;

		Statement *m_getUser;

		Statement *m_getUserSetting;

		Statement *m_setUserSetting;

		Statement *m_updateUserSetting;

		Statement *m_removeUser;

		Statement *m_removeUserBuddies;

		Statement *m_removeUserSettings;

		Statement *m_removeUserBuddiesSettings;

		Statement *m_addBuddy;

		Statement *m_updateBuddy;

		Statement *m_updateBuddySetting;

		Statement *m_getBuddies;

		Statement *m_getBuddiesSettings;

		Statement *m_setUserOnline;

		Statement *m_getOnlineUsers;

};

}

#endif

server = 127.0.0.1

port = 5222

server_mode = 1

backend_host=localhost

pidfile=./test.pid

# < this option doesn't work yet

#backend_port=10001

#admin_jid=admin@localhost

admin_password=test

#cert=server.pfx #patch to PKCS#12 certificate

#cert_password=test #password to that certificate if any

users_per_backend=10

protocol=prpl-jabber

#protocol=prpl-msn

#protocol=any

#protocol=prpl-icq

working_dir=./

portfile=$jid.port

[backend]

#default_avatar=catmelonhead.jpg

#no_vcard_fetch=true

[logging]

	disconnect();

}

void MySQLBackend::disconnect() {

	LOG4CXX_INFO(logger, "Disconnecting");

	delete m_setUser;

	delete m_getUser;

	delete m_removeUser;

	delete m_removeUserBuddies;

	delete m_removeUserSettings;

	delete m_removeUserBuddiesSettings;

	delete m_addBuddy;

	delete m_updateBuddy;

	delete m_getBuddies;

	delete m_getBuddiesSettings;

	delete m_getUserSetting;

	delete m_setUserSetting;

	delete m_updateUserSetting;

	delete m_updateBuddySetting;

	delete m_setUserOnline;

	delete m_getOnlineUsers;

	mysql_close(&m_conn);

}

bool MySQLBackend::connect() {

	LOG4CXX_INFO(logger, "Connecting MySQL server " << CONFIG_STRING(m_config, "database.server") << ", user " <<

		CONFIG_STRING(m_config, "database.user") << ", database " << CONFIG_STRING(m_config, "database.database") <<

		", port " << CONFIG_INT(m_config, "database.port")

	);

	if (!mysql_real_connect(&m_conn, CONFIG_STRING(m_config, "database.server").c_str(),

	createDatabase();

	m_setUser = new Statement(&m_conn, "sssssbss", "INSERT INTO " + m_prefix + "users (jid, uin, password, language, encoding, last_login, vip) VALUES (?, ?, ?, ?, ?, NOW(), ?) ON DUPLICATE KEY UPDATE uin=?, password=?");

	m_getUser = new Statement(&m_conn, "s|isssssb", "SELECT id, jid, uin, password, encoding, language, vip FROM " + m_prefix + "users WHERE jid=?");

	m_removeUser = new Statement(&m_conn, "i", "DELETE FROM " + m_prefix + "users WHERE id=?");

	m_removeUserBuddies = new Statement(&m_conn, "i", "DELETE FROM " + m_prefix + "buddies WHERE user_id=?");

	m_removeUserSettings = new Statement(&m_conn, "i", "DELETE FROM " + m_prefix + "users_settings WHERE user_id=?");

	m_removeUserBuddiesSettings = new Statement(&m_conn, "i", "DELETE FROM " + m_prefix + "buddies_settings WHERE user_id=?");

	m_addBuddy = new Statement(&m_conn, "issssi", "INSERT INTO " + m_prefix + "buddies (user_id, uin, subscription, groups, nickname, flags) VALUES (?, ?, ?, ?, ?, ?)");

	m_updateBuddy = new Statement(&m_conn, "ssisis", "UPDATE " + m_prefix + "buddies SET groups=?, nickname=?, flags=?, subscription=? WHERE user_id=? AND uin=?");

	m_getBuddies = new Statement(&m_conn, "i|issssi", "SELECT id, uin, subscription, nickname, groups, flags FROM " + m_prefix + "buddies WHERE user_id=? ORDER BY id ASC");

	m_getBuddiesSettings = new Statement(&m_conn, "i|iiss", "SELECT buddy_id, type, var, value FROM " + m_prefix + "buddies_settings WHERE user_id=? ORDER BY buddy_id ASC");

	m_updateBuddySetting = new Statement(&m_conn, "iisiss", "INSERT INTO " + m_prefix + "buddies_settings (user_id, buddy_id, var, type, value) VALUES (?, ?, ?, ?, ?) ON DUPLICATE KEY UPDATE value=?");

	m_getUserSetting = new Statement(&m_conn, "is|is", "SELECT type, value FROM " + m_prefix + "users_settings WHERE user_id=? AND var=?");

	m_setUserSetting = new Statement(&m_conn, "isis", "INSERT INTO " + m_prefix + "users_settings (user_id, var, type, value) VALUES (?,?,?,?)");

	m_updateUserSetting = new Statement(&m_conn, "sis", "UPDATE " + m_prefix + "users_settings SET value=? WHERE user_id=? AND var=?");

	m_setUserOnline = new Statement(&m_conn, "bi", "UPDATE " + m_prefix + "users SET online=?, last_login=NOW()  WHERE id=?");

	m_getOnlineUsers = new Statement(&m_conn, "|s", "SELECT jid FROM " + m_prefix + "users WHERE online=1");

	return true;

}

bool MySQLBackend::createDatabase() {

	long id = (long) mysql_insert_id(&m_conn);

// 	INSERT OR REPLACE INTO " + m_prefix + "buddies_settings (user_id, buddy_id, var, type, value) VALUES (?, ?, ?, ?, ?)

	if (buddyInfo.settings.find("icon_hash") != buddyInfo.settings.end() && !buddyInfo.settings.find("icon_hash")->second.s.empty()) {

		*m_updateBuddySetting << userId << id << buddyInfo.settings.find("icon_hash")->first << (int) TYPE_STRING << buddyInfo.settings.find("icon_hash")->second.s << buddyInfo.settings.find("icon_hash")->second.s;

		EXEC(m_updateBuddySetting, addBuddy(userId, buddyInfo));

	}

	return id;

}

void MySQLBackend::updateBuddy(long userId, const BuddyInfo &buddyInfo) {

// 	"UPDATE " + m_prefix + "buddies SET groups=?, nickname=?, flags=?, subscription=? WHERE user_id=? AND uin=?"

	std::string groups = Util::serializeGroups(buddyInfo.groups);

	*m_updateBuddy << groups;

	*m_updateBuddy << buddyInfo.alias << buddyInfo.flags << buddyInfo.subscription;

	*m_updateBuddy << userId << buddyInfo.legacyName;

	EXEC(m_updateBuddy, updateBuddy(userId, buddyInfo));

}

bool MySQLBackend::getBuddies(long id, std::list<BuddyInfo> &roster) {

//	SELECT id, uin, subscription, nickname, groups, flags FROM " + m_prefix + "buddies WHERE user_id=? ORDER BY id ASC