msgpolloptiondb.java

cwbbs 云网论坛源码

package com.redmoon.forum;

import com.cloudwebsoft.framework.base.*;
import java.util.Vector;
import com.cloudwebsoft.framework.db.JdbcTemplate;
import cn.js.fan.cache.jcs.RMCache;
import com.cloudwebsoft.framework.util.LogUtil;
import java.sql.SQLException;
import cn.js.fan.db.PrimaryKey;


public class MsgPollOptionDb extends QObjectDb {
    public static final String OPTS = "opts_";

    public MsgPollOptionDb() {
    }

    public MsgPollOptionDb getMsgPollOptionDb(long msgId, int order) {
        PrimaryKey pk = (PrimaryKey)primaryKey.clone();
        pk.setKeyValue("msg_id", new Long(msgId));
        pk.setKeyValue("orders", new Integer(order));
        MsgPollOptionDb mpod = (MsgPollOptionDb)getQObjectDb(pk.getKeys());
        return mpod;
    }

    public boolean save(JdbcTemplate jt, Object[] params) throws SQLException {
        

        boolean re = super.save(jt, params);
        long msgId = getLong("msg_id");
        
        try {
            RMCache.getInstance().remove(OPTS + msgId, cacheGroup);
        }
        catch (Exception e) {
            LogUtil.getLog(getClass()).error("getOptionsOfMsg1:" + e.getMessage());
        }
        return re;
    }

    public Vector getOptions(long msgId) {
        String sql = "select msg_id,orders from " + table.getName() + " where msg_id=? order by orders asc";
        Vector v = null;
        try {
            v = (Vector)RMCache.getInstance().getFromGroup(OPTS + msgId, cacheGroup);
        }
        catch (Exception e) {
            LogUtil.getLog(getClass()).error("getOptionsOfMsg1:" + e.getMessage());
        }
        if (v==null) {
            v = list(new JdbcTemplate(), sql, new Object[] {new Long(msgId)});
            try {
                RMCache.getInstance().putInGroup(OPTS + msgId, cacheGroup, v);
            }
            catch (Exception e) {
                LogUtil.getLog(getClass()).error("getOptionsOfMsg2:" + e.getMessage());
            }
        }
        return v;
    }


}