userleveldb.java

cwbbs 云网论坛源码

package com.redmoon.forum.setup;

import java.sql.*;
import java.util.*;

import cn.js.fan.base.*;
import cn.js.fan.db.*;
import cn.js.fan.util.*;


public class UserLevelDb extends ObjectDb {

    public UserLevelDb() {
        super();
    }

    public UserLevelDb(int level) {
        this.level = level;
        init();
        load();
    }

    
    public UserLevelDb getUserLevelDbByLevel(int levelCompare) {
        
        
        Vector v = getAllLevel();

        int len = v.size();
        UserLevelDb myuld = (UserLevelDb) v.get(0);
        if(levelCompare < (myuld.getLevel()))
            return myuld;
        int i = 0;
        while (i < len) {
            myuld = (UserLevelDb) v.get(i);
            int lv = myuld.getLevel();
            if ((i + 1) < len) {
                UserLevelDb uld1 = (UserLevelDb) v.get(i + 1);
                int lv1 = uld1.getLevel();
                if (levelCompare >= lv && levelCompare < lv1) {
                    break;
                }
            } else {
                break;
            }
            i++;
        }
        return myuld;
    }

    public UserLevelDb getUserLevelDb(int level) {
        return (UserLevelDb)getObjectDb(new Integer(level));
    }

    public ObjectDb getObjectRaw(PrimaryKey pk) {
        return new UserLevelDb(pk.getIntValue());
    }

    public Vector getAllLevel() {
        UserLevelCache ulc = new UserLevelCache();
        return ulc.getAllLevel();
    }

    public void initDB() {
        this.tableName = "sq_setup_user_level";
        primaryKey = new PrimaryKey("levelAmount", PrimaryKey.TYPE_INT);
        objectCache = new UserLevelCache(this);

        this.QUERY_DEL =
                "delete FROM " + tableName + " WHERE levelAmount=?";
        this.QUERY_CREATE =
                "INSERT into " + tableName + " (levelAmount, description, levelPicPath, groupCode) VALUES (?,?,?,?)";
        this.QUERY_LOAD =
                "SELECT description, levelPicPath, groupCode FROM " + tableName + " WHERE levelAmount=?";
        this.QUERY_SAVE =
                "UPDATE " + tableName + " SET levelAmount=?,description=?,levelPicPath=?,groupCode=? WHERE levelAmount=?";
        this.QUERY_LIST = "select levelAmount from " + tableName + " order by levelAmount asc";
        isInitFromConfigDB = false;
    }

    public boolean save() throws ErrMsgException {
        
        Conn conn = new Conn(connname);
        PreparedStatement pstmt = null;
        try {
            pstmt = conn.prepareStatement(this.QUERY_SAVE);
            pstmt.setInt(1, newLevel);
            pstmt.setString(2, desc);
            pstmt.setString(3, levelPicPath);
            pstmt.setString(4, groupCode);
            pstmt.setInt(5, level);
            if (conn.executePreUpdate() == 1) {
                UserLevelCache mc = new UserLevelCache(this);
                primaryKey.setValue(new Integer(level));
                mc.refreshSave(primaryKey);
                mc.refreshCreate();
                return true;
            }
            else
                return false;
        } catch (SQLException e) {
            logger.error(e.getMessage());
            throw new ErrMsgException("保存时出错，请检查级别是否有重复！");
        } finally {
            if (pstmt!=null) {
                try { pstmt.close(); } catch (Exception e) {}
                pstmt = null;
            }
            if (conn != null) {
                conn.close();
                conn = null;
            }

            UserLevelCache uc = new UserLevelCache(this);
            primaryKey.setValue(new Integer(level));
            uc.refreshSave(primaryKey);
        }
    }

    public void load() {
        
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        Conn conn = new Conn(connname);
        try {
            pstmt = conn.prepareStatement(this.QUERY_LOAD);
            pstmt.setInt(1, level);
            
            rs = conn.executePreQuery();
            if (rs.next()) {
                this.desc = StrUtil.getNullString(rs.getString(1));
                this.levelPicPath = StrUtil.getNullString(rs.getString(2));
                groupCode = StrUtil.getNullString(rs.getString(3));
                primaryKey.setValue(new Integer(level));
            }
        } catch (SQLException e) {
            logger.error(e.getMessage());
        } finally {
            if (rs != null) {
                try {
                    rs.close();
                } catch (Exception e) {}
                rs = null;
            }
            if (pstmt != null) {
                try {
                    pstmt.close();
                } catch (Exception e) {}
                pstmt = null;
            }
            if (conn != null) {
                conn.close();
                conn = null;
            }
        }
    }

    public boolean del() throws ErrMsgException {
        Conn conn = null;
        PreparedStatement pstmt = null;
        try {
            conn = new Conn(connname);
            pstmt = conn.prepareStatement(this.QUERY_DEL);
            pstmt.setInt(1, level);
            if (conn.executePreUpdate()==1) {
                UserLevelCache mc = new UserLevelCache(this);
                mc.refreshDel(primaryKey);
                return true;
            }
            else
                return false;
        } catch (SQLException e) {
            logger.error(e.getMessage());
            throw new ErrMsgException("删除出错！");
        } finally {
            if (pstmt != null) {
                try {
                    pstmt.close();
                } catch (Exception e) {}
                pstmt = null;
            }
            if (conn != null) {
                conn.close();
                conn = null;
            }
        }
    }

    public boolean create() throws ErrMsgException {
        Conn conn = null;
        boolean re = false;
        PreparedStatement pstmt = null;
        try {
            conn = new Conn(connname);
            pstmt = conn.prepareStatement(this.QUERY_CREATE);
            pstmt.setInt(1, level);
            pstmt.setString(2, desc);
            pstmt.setString(3, levelPicPath);
            pstmt.setString(4, groupCode);
            re = conn.executePreUpdate() == 1 ? true : false;
            if (re) {
                UserLevelCache mc = new UserLevelCache(this);
                mc.refreshCreate();
            }
        } catch (SQLException e) {
            logger.error("create:" + e.getMessage());
            throw new ErrMsgException("插入等级时出错！");
        } finally {
            if (pstmt != null) {
                try {
                    pstmt.close();
                } catch (Exception e) {}
                pstmt = null;
            }
            if (conn != null) {
                conn.close();
                conn = null;
            }
        }
        return re;
    }

    public void setLevel(int level) {
        this.level = level;
    }

    public void setDesc(String desc) {
        this.desc = desc;
    }

    public int getLevel() {
        return level;
    }

    public String getDesc() {
        return desc;
    }

    public String getLevelPicPath() {
        return levelPicPath;
    }

    public String getGroupCode() {
        return groupCode;
    }

    public void setNewLevel(int newLevel) {
        this.newLevel = newLevel;
    }

    public void setLevelPicPath(String levelPicPath) {
        this.levelPicPath = levelPicPath;
    }

    public void setGroupCode(String groupCode) {
        this.groupCode = groupCode;
    }

    private int level;
    private String desc;
    private int newLevel;
    private String levelPicPath;
    private String groupCode;

}