dbbean.java

用java实现的一个bbs的portal

/**
 * Created by IntelliJ IDEA.
 * User: Administrator
 * Date: Jul 20, 2003
 * Time: 8:37:42 PM
 * To change this template use Options | File Templates.
 */
package DBConnection;

import Kernel.TradeInfo;
import Kernel.comTool;

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

public class DBBean {

    TradeInfo tradeInfo = new TradeInfo();

    public DBBean(){
    }

    public boolean insertKind(String kind,String name){
        try{
            DBBridge bridge = new DBBridge();
            kind = comTool.getChineseStr(kind);
            name = comTool.getChineseStr(name);
            String sql = "INSERT INTO KIND" +
                    "(KIND,NAME) " +
                    "VALUES ('"+kind+"','"+name+"') ";
            bridge.getStmt().execute(sql);
            bridge.setConnectionSwitch("off");
            return true;
        }catch(Exception ex){
            ex.printStackTrace();
        }
        return false;
    }

    public boolean delKind(String kind){
        try{
            DBBridge bridge = new DBBridge();
            String sql = "DELETE FROM KIND WHERE KIND='" +kind+"'";
            bridge.getStmt().execute(sql);
            bridge.setConnectionSwitch("off");
            return true;
        }catch(Exception ex){
            ex.printStackTrace();
        }
        return false;
    }

    public boolean insertCommodity(String commodityNo,String commodity,String kind,String keywords){
        commodityNo =  comTool.getChineseStr(commodityNo);
        commodity =  comTool.getChineseStr(commodity);
        kind =  comTool.getChineseStr(kind);
        keywords = comTool.getChineseStr(keywords);

        try{
            DBBridge bridge = new DBBridge();
            String sql = "INSERT INTO COMMODITY" +
                    "(COMMODITYNO,COMMODITY,KIND) " +
                    "VALUES ('"+commodityNo+"','"+commodity+"','"+kind+"') ";
            bridge.getStmt().execute(sql);
             bridge.setConnectionSwitch("off");
            if (insertKeyword(commodityNo,keywords))
                return true;
            else return false;
        }catch(Exception ex){
            ex.printStackTrace();
        }
        return false;
    }

    private boolean insertKeyword(String commodityNo,String keywords){
        //System.out.println("keywords : "+keywords);
        StringTokenizer st = new StringTokenizer(keywords," ");
        while (st.hasMoreTokens()) {
            String keyword = st.nextToken();
            if (!insertKeywordItem(commodityNo,keyword))
                return false;
        }
        return true;
    }

    public boolean delCommodity(String commodityNo){

        try{
            DBBridge bridge = new DBBridge();
            String sql = "DELETE FROM COMMODITY WHERE COMMODITYNO='" +commodityNo+"'";
            bridge.getStmt().execute(sql);
            bridge.setConnectionSwitch("off");
            delKeyword(commodityNo);
            return true;
        }catch(Exception ex){
            ex.printStackTrace();
        }
        return false;
    }

    public Vector getCommodityItem(String commodityNo){
        Vector vec = new Vector();
        try{
            //select * from KEYWORD where COMMODITYNO='"+commodityNo+"' order by LENGTH desc
            DBBridge bridge = new DBBridge();
            String sql = "select * from COMMODITY,KEYWORD WHERE COMMODITY.COMMODITYNO = '"+commodityNo+"' "+
                    "AND KEYWORD.COMMODITYNO='"+commodityNo+"' order by KEYWORD.LENGTH desc";
            System.out.println(sql);
            ResultSet rs = bridge.getStmt().executeQuery(sql);
            bridge.setConnectionSwitch("off");
            String kind = "";
            String keywords = "";
            String CommodityNo = "";
            String Commodity = "";
            while (rs.next()){
                CommodityNo = comTool.getChineseStr(rs.getString("COMMODITYNO"));
                Commodity = comTool.getChineseStr(rs.getString("COMMODITY"));
                kind = comTool.getChineseStr(rs.getString("KIND"));
                String keyword = comTool.getChineseStr(rs.getString("KEYWORD"));
                keywords = keywords+" "+ keyword;
            }
            if (!keywords.equals(""))
                keywords = keywords.substring(1,keywords.length());
            vec.add(kind);
            vec.add(CommodityNo);
            vec.add(Commodity);
            vec.add(keywords);
            System.out.println(keywords);
            return vec;
        }catch(Exception ex){
            ex.printStackTrace();
        }
        return null;
    }

    public Vector getCommodity(String kind){
        Vector vec = new Vector();
        try{
            DBBridge bridge = new DBBridge();
            String sql = "select * from COMMODITY WHERE KIND = '"+kind+"' order by COMMODITYNO asc";
            //System.out.println(sql);
            ResultSet rs = bridge.getStmt().executeQuery(sql);
            bridge.setConnectionSwitch("off");
            Vector commodityNoList = new Vector();
            while (rs.next()){
                String CommodityNo = comTool.getChineseStr(rs.getString("COMMODITYNO"));
                String Commodity = comTool.getChineseStr(rs.getString("COMMODITY"));
                String commodityInfo =  kind+"@"+CommodityNo+"@"+Commodity+"@";
                vec.add(commodityInfo);
                commodityNoList.add(CommodityNo);
            }
            int commodityCount = 0;
            for (Enumeration e = commodityNoList.elements();e.hasMoreElements();){
                String CommodityNo = (String)e.nextElement();
                String Keyword = getKeyWord(CommodityNo);
                String commodityInfo = (String)vec.get(commodityCount)+Keyword;
                vec.set(commodityCount,commodityInfo);
                commodityCount++;
            }
            return vec;
        }catch(Exception ex){
            ex.printStackTrace();
        }
        return null;
    }

    public String getKeyWord(String commodityNo){
        String keywords = "";
        try{
            DBBridge bridge = new DBBridge();
            String sql = "select * from KEYWORD where COMMODITYNO='"+commodityNo+"' order by LENGTH desc";
            ResultSet rs = bridge.getStmt().executeQuery(sql);
            bridge.setConnectionSwitch("off");
            while (rs.next()){
                String keyword = comTool.getChineseStr(rs.getString("KEYWORD"));
                keywords = keywords+" "+ keyword;
            }
            if (!keywords.equals(""))
                keywords = keywords.substring(1,keywords.length());
            return keywords;
        }catch(Exception ex){
            ex.printStackTrace();
        }
        return null;
    }

    public Vector getKind(){
        Vector vec = new Vector();
        try{
            DBBridge bridge = new DBBridge();
            String sql = "select * from KIND order by KIND asc";
            ResultSet rs = bridge.getStmt().executeQuery(sql);
            bridge.setConnectionSwitch("off");
            while (rs.next()){
                String kind = comTool.getChineseStr(rs.getString("KIND"));
                String name = comTool.getChineseStr(rs.getString("NAME"));
                String kindInfo =  kind+"@"+name;
                vec.add(kindInfo);
            }
            return vec;
        }catch(Exception ex){
            ex.printStackTrace();
        }
        return null;
    }

    public Vector getAllTradeInfo(){
        return tradeInfo.getAllTradeInfo();
    }


    private boolean insertKeywordItem(String commodityNo,String keyword){
        try{
            DBBridge bridge = new DBBridge();
            String sql = "INSERT INTO KEYWORD" +
                    "(COMMODITYNO,KEYWORD,LENGTH) " +
                    "VALUES ('"+commodityNo+"','"+keyword+"',"+keyword.length()+") ";
            bridge.getStmt().execute(sql);
            bridge.setConnectionSwitch("off");
            return true;
        }catch(Exception ex){
            ex.printStackTrace();
        }
        return false;
    }

    public boolean delKeyword(String commodityNo){
        try{
            DBBridge bridge = new DBBridge();
            String sql = "delete from KEYWORD where COMMODITYNO='"+commodityNo+"'";
            bridge.getStmt().execute(sql);
            bridge.setConnectionSwitch("off");
            return true;
        }catch(Exception ex){
            ex.printStackTrace();
        }
        return false;
    }

    public Vector getKeyWordVec(String commodityNo){
        Vector vec = new Vector();
        try{
            DBBridge bridge = new DBBridge();
            String sql = "select KEYWORD from KEYWORD where COMMODITYNO='"+commodityNo+"' order by LENGTH desc";
            ResultSet rs = bridge.getStmt().executeQuery(sql);
            bridge.setConnectionSwitch("off");
            while (rs.next()){
                String keyword = comTool.getChineseStr(rs.getString("KEYWORD"));
                vec.add(keyword);
            }
            return vec;
        }catch(Exception ex){
            ex.printStackTrace();
        }
        return null;
    }

    public Vector getAllKeywords(){
        Vector vec = new Vector();
        try{
            DBBridge bridge = new DBBridge();
            String sql = "select KEYWORD from KEYWORD order by LENGTH desc";
            ResultSet rs = bridge.getStmt().executeQuery(sql);
            bridge.setConnectionSwitch("off");
            while (rs.next()){
                String keyword = comTool.getChineseStr(rs.getString("KEYWORD"));
                vec.add(keyword);
            }
            return vec;
        }catch(Exception ex){
            ex.printStackTrace();
        }
        return null;
    }
    public Vector getHouseCommodityWords(String HouseKind){
        Vector vec = new Vector();
        try{
            DBBridge bridge = new DBBridge();
            String sql = "select COMMODITY from COMMODITY WHERE KIND = '"+HouseKind+"' order by COMMODITYNO";
            ResultSet rs = bridge.getStmt().executeQuery(sql);
            bridge.setConnectionSwitch("off");
            while (rs.next()){
                String keyword = comTool.getChineseStr(rs.getString("COMMODITY"));
                vec.add(keyword);
            }
            return vec;
        }catch(Exception ex){
            ex.printStackTrace();
        }
        return null;
    }

    public Hashtable getCommodityKeywords(){
        Properties CommodityKeyWords = new  Properties();
        Vector kindVec = getKind();
        for (Enumeration e = kindVec.elements();e.hasMoreElements();){
            String kindStr = (String)e.nextElement();
            StringTokenizer stt = new StringTokenizer(kindStr,"@");
            String kindNum = "";
            if (stt.hasMoreTokens()){
                kindNum = stt.nextToken();
            }
            Vector commodityVec = getCommodity(kindNum);
            for (Enumeration ee = commodityVec.elements();ee.hasMoreElements();){
                String commodityInfo = (String)ee.nextElement();
                StringTokenizer st = new StringTokenizer(commodityInfo,"@");
                if (st.hasMoreTokens()){
                    st.nextToken();
                    st.nextToken();
                    String commodity = st.nextToken();
                    String keyword = st.nextToken();
                    Vector KeyVec = new Vector();
                    st = new  StringTokenizer(keyword," ");
                    while(st.hasMoreTokens())
                        KeyVec.add(st.nextToken());
                    CommodityKeyWords.put(commodity,KeyVec);
                }
            }
        }
        return CommodityKeyWords;
    }

////////////////////////////////////////////////////
    public Properties getAllCommodityKey4DB(){
        Properties CommodityKeyWords = new  Properties();
        Vector kindVec = getKind();
        for (Enumeration e = kindVec.elements();e.hasMoreElements();){
            String kindStr = (String)e.nextElement();
            StringTokenizer stt = new StringTokenizer(kindStr,"@");
            String kindNum = "";
            if (stt.hasMoreTokens()){
                kindNum = stt.nextToken();
            }
            Vector commodityVec = getCommodity(kindNum);
            for (Enumeration ee = commodityVec.elements();ee.hasMoreElements();){
                String commodityInfo = (String)ee.nextElement();
                StringTokenizer st = new StringTokenizer(commodityInfo,"@");
                if (st.hasMoreTokens()){
                    st.nextToken();
                    String commodityNo = st.nextToken();
                    st.nextToken();
                    String keyword = st.nextToken();
                    Vector KeyVec = new Vector();
                    st = new  StringTokenizer(keyword,"#");
                    while(st.hasMoreTokens())
                        KeyVec.add(st.nextToken());
                    CommodityKeyWords.put(commodityNo,KeyVec);
                }
            }
        }
        return CommodityKeyWords;
    }

    public void changeKeyword(){
        Properties keywords =  getAllCommodityKey4DB();
        for   (Enumeration e = keywords.propertyNames();e.hasMoreElements();){
            String commodityNo = (String)e.nextElement();
            Vector keyVec = (Vector)keywords.get(commodityNo);
            for   (Enumeration ee = keyVec.elements();ee.hasMoreElements();){
                String keyword = (String)ee.nextElement();
                try{
                    DBBridge bridge = new DBBridge();
                    String sql = "INSERT INTO KEYWORD" +
                            "(COMMODITYNO,KEYWORD,LENGTH) " +
                            "VALUES ('"+commodityNo+"','"+keyword+"',"+keyword.length()+") ";
                    bridge.getStmt().execute(sql);
                    bridge.setConnectionSwitch("off");
                }catch(Exception ex){
                    ex.printStackTrace();
                }
            }
        }
    }

    public static void main(String args[]){
        DBBean bean = new DBBean();
        bean.getCommodityItem("001001");
    }
}