用数据库读取和存储Smartfoxserver的好友列表(BuddyList)

import it.gotoandplay.smartfoxserver.SmartFoxServer;
import it.gotoandplay.smartfoxserver.data.buddylist.StorableBuddyItem;
import it.gotoandplay.smartfoxserver.data.buddylist.StorableBuddyList;
import it.gotoandplay.smartfoxserver.data.buddylist.persistence.AbstractBuddyPersister;
import it.gotoandplay.smartfoxserver.data.*;
import it.gotoandplay.smartfoxserver.db.*;
import it.gotoandplay.smartfoxserver.extensions.*;
 
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Map;
 
public class BuddyPersiter extends AbstractBuddyPersister 
{
	private ExtensionHelper helper;
	private Zone currentZone;
	private DbManager db;
 
	@Override
	public void init(Object param) 
	{
		helper = ExtensionHelper.instance();
		this.currentZone = helper.getZone(this.zoneName);
		info("CUSTOM Persister initialized.");
	}
 
	@Override
	public void destroy(Object param) 
	{
		info("CUSTOM Persister shutting down.");
	}
 
	@Override
	public StorableBuddyList loadList(String userName) 
	{
		return loadBuddys(userName);
	}
 
	// 从数据库读取好友列表
	@SuppressWarnings("unchecked")
	private StorableBuddyList loadBuddys(String userName)
	{
		db = this.currentZone.dbManager;
		StorableBuddyList buddyList = new StorableBuddyList(userName);
		buddyList.buddies = new ArrayList<storablebuddyitem>();
		if (userName.length() > 0)
		{
			String sql = "SELECT BUDDYNAME,ISBLACK FROM BUDDYS WHERE USERNAME='"+userName+"'";
			ArrayList<datarow> buddys = db.executeQuery(sql);
			if (buddys.size() > 0)
			{
				DataRow dr;
				for (int i = 0; i < buddys.size(); i++)
				{
					dr = buddys.get(i);
					StorableBuddyItem buddyItem = new StorableBuddyItem(dr.getItem("BUDDYNAME"));
					buddyItem.isBlocked = (dr.getItem("ISBLACK").equals("1")) ? true : false;
					buddyList.buddies.add(buddyItem);
				}
			}
		}
 
		info("Buddy List loaded for user: " + userName);
		return buddyList;
	}
 
	@Override
	public boolean saveList(String userName, StorableBuddyList buddyList) 
	{
		db = this.currentZone.dbManager;
 
		// 删除所有好友
		String sql = "DELETE FROM BUDDYS WHERE USERNAME='" + userName + "'";
		db.executeCommand(sql);
		db.executeCommand("commit");
		int isBlack = 0;
		info("Saving buddy list for user: " + userName);
		for (StorableBuddyItem buddyItem : buddyList.buddies)
		{
			System.out.println("\t> " + buddyItem.name);
			isBlack = buddyItem.isBlocked ? 1 : 0;
			db.executeCommand("INSERT INTO BUDDYS(ISBLACK, USERNAME, BUDDYNAME) VALUES("+isBlack+",'"+userName+"','"+buddyItem.name+"')");
			db.executeCommand("commit");
		}
		return true;
	}
 
	@Override
	public Map<string , String> getOfflineVariables(String userName) 
	{
		info("getOfflineVariables called for user: " + userName);
		return new HashMap</string><string , String>();
	}
 
	@Override
	public boolean removeOfflineBuddy(String owner, String buddyName) 
	{
		// Called when removing a buddy that is currently offline
		// and the mutualRemove is active 
 
		return true;
	}
 
	private void info(String msg)
	{
		SmartFoxServer.log.info(msg);
	}
}
</string></datarow></storablebuddyitem>