boardmanagerdb.java

cwbbs 云网论坛源码

package com.redmoon.forum;

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

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


public class BoardManagerDb extends ObjectDb {
    private String boardCode;
    public BoardManagerDb() {
        init();
    }

    public BoardManagerDb(String boardCode, String name) {
        this.boardCode = boardCode;
        this.name = name;
        init();
        load();
    }

    public ObjectDb getObjectDb(Object primaryKeyValue) {
        BoardManagerCache fc = new BoardManagerCache(this);
        PrimaryKey pk = (PrimaryKey)primaryKey.clone();
        pk.setValue(primaryKeyValue);
        return (BoardManagerDb)fc.getObjectDb(pk);
    }

    
    public int delManager(String userName) {
        String sql = "select boardcode from sq_boardmanager where name=?";
        ResultSet rs = null;
        int count = 0;
        Conn conn = new Conn(connname);
        try {
            conn = new Conn(connname);
            PreparedStatement ps = conn.prepareStatement(sql);
            ps.setString(1, userName);
            rs = conn.executePreQuery();
            if (rs!=null) {
                while (rs.next()) {
                    getBoardManagerDb(rs.getString(1), userName).del();
                    count ++;
                }
            }
        } catch (SQLException e) {
            logger.error("delManager:" + e.getMessage());
        } finally {
            if (conn != null) {
                conn.close();
                conn = null;
            }
        }
        return count;
    }

    public boolean del() {
        int rowcount = 0;
        Conn conn = null;
        try {
            conn = new Conn(connname);
            PreparedStatement ps = conn.prepareStatement(this.QUERY_DEL);
            ps.setString(1, boardCode);
            ps.setString(2, name);
            rowcount = conn.executePreUpdate();
            BoardManagerCache uc = new BoardManagerCache(this);
            primaryKey.setKeyValue("boardCode", boardCode);
            primaryKey.setKeyValue("name", name);
            uc.refreshDel(primaryKey);

            BoardManagerCache bmc = new BoardManagerCache(this);
            bmc.refreshBoardManagers(boardCode);
        } catch (SQLException e) {
            logger.error("save:" + e.getMessage());
        } finally {
            if (conn != null) {
                conn.close();
                conn = null;
            }
        }
        return rowcount>0? true:false;
    }

    public int getObjectCount(String sql) {
        return 0;
    }

    public ObjectDb getObjectRaw(PrimaryKey pk) {
        return new BoardManagerDb(pk.getKeyStrValue("boardCode"), pk.getKeyStrValue("name"));
    }

    public void setQueryCreate() {
        this.QUERY_CREATE = "insert into sq_boardmanager (boardcode, name, sort, is_hide) values (?,?,?,?)";
    }

    public boolean create() {
        int rowcount = 0;
        Conn conn = null;
        try {
            conn = new Conn(connname);
            PreparedStatement ps = conn.prepareStatement(this.QUERY_CREATE);
            ps.setString(1, boardCode);
            ps.setString(2, name);
            ps.setInt(3, sort);
            ps.setInt(4, hide?1:0);
            rowcount = conn.executePreUpdate();
            if (rowcount>0) {
                BoardManagerCache bmc = new BoardManagerCache(this);
                bmc.refreshBoardManagers(boardCode);
            }
        } catch (SQLException e) {
            logger.error("create:" + e.getMessage());
        } finally {
            if (conn != null) {
                conn.close();
                conn = null;
            }
        }
        return rowcount>0? true:false;
    }

    public void setQuerySave() {
        this.QUERY_SAVE =
            "update sq_boardmanager set sort=?,is_hide=? where boardcode=? and name=?";
    }

    public void setQueryDel() {
        this.QUERY_DEL = "delete from sq_boardmanager where boardcode=? and name=?";
    }

    public void setQueryLoad() {
        this.QUERY_LOAD =
            "select sort,is_hide from sq_boardmanager where boardcode=? and name=?";
    }

    public void setQueryList() {
    }

    public boolean save() {
        int rowcount = 0;
        Conn conn = null;
        try {
            conn = new Conn(connname);
            PreparedStatement ps = conn.prepareStatement(this.QUERY_SAVE);
            ps.setInt(1, sort);
            ps.setInt(2, hide?1:0);
            ps.setString(3, boardCode);
            ps.setString(4, name);
            rowcount = conn.executePreUpdate();
            BoardManagerCache uc = new BoardManagerCache(this);

            primaryKey.setKeyValue("boardCode", boardCode);
            primaryKey.setKeyValue("name", name);
            uc.refreshSave(primaryKey);

            BoardManagerCache bmc = new BoardManagerCache(this);
            bmc.refreshBoardManagers(boardCode);
        } catch (SQLException e) {
            logger.error("save:" + e.getMessage());
        } finally {
            if (conn != null) {
                conn.close();
                conn = null;
            }
        }
        return rowcount>0? true:false;
    }

    public Vector getBoardManagers(String boardcode) {
        BoardManagerCache bmc = new BoardManagerCache(this);
        return bmc.getBoardManagers(boardcode);
    }

    public BoardManagerDb getBoardManagerDb(String boardCode, String name) {
        PrimaryKey pk = (PrimaryKey)primaryKey.clone();
        pk.setKeyValue("boardCode", boardCode);
        pk.setKeyValue("name", name);
        return (BoardManagerDb)getObjectDb(pk.getKeys());
    }

    public void load() {
        ResultSet rs = null;
        Conn conn = new Conn(connname);
        try {
            PreparedStatement ps = conn.prepareStatement(this.QUERY_LOAD);
            ps.setString(1, boardCode);
            ps.setString(2, name);
            primaryKey.setKeyValue("boardCode", boardCode);
            primaryKey.setKeyValue("name", name);
            rs = conn.executePreQuery();
            if (rs.next()) {
                sort = rs.getInt(1);
                hide = rs.getInt(2)==1;
                loaded = true;
            }
        } catch (SQLException e) {
            logger.error("load:" + e.getMessage());
        }
        finally {
            if (conn!=null) {
                conn.close();
                conn = null;
            }
        }
    }

    public Object[] getObjectBlock(String query, int startIndex) {
        return null;
    }

    public void setPrimaryKey() {
        HashMap key = new HashMap();
        
        key.put("boardCode", new KeyUnit(primaryKey.TYPE_STRING, 0));
        key.put("name", new KeyUnit(primaryKey.TYPE_STRING, 1));
        primaryKey = new PrimaryKey(key);
    }

    
    public boolean isUserManager(String name) {
        BoardManagerCache bmc = new BoardManagerCache(this);
        return bmc.isUserManager(name);
    }

    public void setBoardCode(String boardCode) {
        this.boardCode = boardCode;
    }

    public void setName(String name) {
        this.name = name;
    }

    public void setSort(int sort) {
        this.sort = sort;
    }

    public void setHide(boolean hide) {
        this.hide = hide;
    }

    public String getBoardCode() {
        return boardCode;
    }

    public String getName() {
        return name;
    }

    public int getSort() {
        return sort;
    }

    public boolean isHide() {
        return hide;
    }

    private String name;
    private int sort;
    private boolean hide = false;
}