tradeinfo.java

用java实现的一个bbs的portal

                String Boardname = comTool.getChineseStr(rs.getString("BOARDNAME"));
                String Author = comTool.getChineseStr(rs.getString("AUTHOR"));
                String Alias = comTool.getChineseStr(rs.getString("ALIAS"));
                String Ip = comTool.getChineseStr(rs.getString("IP"));
                String tradeinfo = "TRADEINFO"+"%"+Trade+"%"+Commodity+"%"+Description+"%"+Contact+"%"+PostDate+"%"+XMLFile
                        +"%"+Bbsname+"%"+Boardname+"%"+Author+"%"+Alias+"%"+Ip;
                count ++;
                if ( count == 1)
                    recentDate = PostDate;
                vec.add(tradeinfo);
            }
        }catch(Exception ex){
            ex.printStackTrace();
        }
        bridge.setConnectionSwitch("off");
        setQueryCache(tradetype,commodity,vec,recentDate);
        return vec;
    }
*/
    //******
    public Vector getTradeInfo(String tradetype,String kind, String commodity, String keywords){
        DBBridge bridge = new DBBridge();
        Vector vec = new Vector();
        String recentDate = null;
        Vector cachevec = checkQueryCache(tradetype,kind,commodity,keywords);
        if (cachevec != null){
            return cachevec;
        }
        try{
            String sql = "";
            if((kind.equals("")) && (commodity.equals(""))) {
            //if ((kind == null)&&(commodity == null)){   //query in BBS
                StringTokenizer keywordVec = null;
                if (keywords != null){
                    keywordVec = new StringTokenizer(keywords, "|");
                    String keywordStr = "%";
                    while (keywordVec.hasMoreTokens()){
                        keywordStr = keywordStr + keywordVec.nextToken().trim() + "%";
                    }
                    sql = "select TRADE,COMMODITY,DESCRIPTION,CONTACT,JIAOYIXINXI.POSTDATE,JIAOYIXINXI.XMLFILE,BBSNAME,BOARDNAME,AUTHOR,ALIAS,TITLE,CONTENT,IP"+
                            " from JIAOYIXINXI,BBSXINXI WHERE (TRADE = "+tradetype+")AND (TITLE like '"+keywordStr+"')AND (CONTENT like '"+keywordStr+"') " +
                            "and (JIAOYIXINXI.XMLFILE = BBSXINXI.XMLFILE) order by JIAOYIXINXI.POSTDATE desc";
                }else{
                    System.err.println("ERROR: No Keyword Found !");
                    return null;
                }
            }else{   //queey in Trade
                StringTokenizer keywordVec = null;
                if (!(keywords.equals(""))){
                    keywordVec = new StringTokenizer(keywords, "|");
                    String keywordStr = "%";
                    while (keywordVec.hasMoreTokens()){
                        keywordStr = keywordStr + keywordVec.nextToken().trim() + "%";
                    }
                    sql = "select TRADE,COMMODITY,DESCRIPTION,CONTACT,JIAOYIXINXI.POSTDATE,JIAOYIXINXI.XMLFILE,BBSNAME,BOARDNAME,AUTHOR,ALIAS,TITLE,CONTENT,IP"+
                            " from JIAOYIXINXI,BBSXINXI WHERE (TRADE = "+
                            tradetype+") AND (COMMODITY = '"+commodity+"') AND (TITLE like '"+keywordStr+"')AND (CONTENT like '"+keywordStr+"') and (JIAOYIXINXI.XMLFILE = BBSXINXI.XMLFILE) order by JIAOYIXINXI.POSTDATE desc";
                }else{
                    sql = "select TRADE,COMMODITY,DESCRIPTION,CONTACT,JIAOYIXINXI.POSTDATE,JIAOYIXINXI.XMLFILE,BBSNAME,BOARDNAME,AUTHOR,ALIAS,TITLE,CONTENT,IP"+
                            " from JIAOYIXINXI,BBSXINXI WHERE (TRADE = "+
                            tradetype+") AND (COMMODITY = '"+commodity+"') and (JIAOYIXINXI.XMLFILE = BBSXINXI.XMLFILE) order by JIAOYIXINXI.POSTDATE desc";

                }
            }
            System.err.println(sql);
            ResultSet rs = bridge.getStmt().executeQuery(sql);
            int count = 0;
            while ((rs != null)&&(rs.next())){
                //TRADEINFO%tradetype%commodity$description%contact%postdata% xmlfile%BBSName%BoardName%Author%Alais%IP
                int Trade = rs.getInt("TRADE");
                String Commodity = comTool.getChineseStr(rs.getString("COMMODITY"));
                String Description = comTool.getChineseStr(rs.getString("DESCRIPTION"));
                String Contact = comTool.getChineseStr(rs.getString("CONTACT"));
                String PostDate = comTool.getChineseStr(rs.getString("POSTDATE"));
                PostDate = PostDate.substring(0,PostDate.length()-2);
                String XMLFile = rs.getString("XMLFILE");
                String Bbsname = comTool.getChineseStr(rs.getString("BBSNAME"));
                String Boardname = comTool.getChineseStr(rs.getString("BOARDNAME"));
                String Author = comTool.getChineseStr(rs.getString("AUTHOR"));
                String Alias = comTool.getChineseStr(rs.getString("ALIAS"));
                String Ip = comTool.getChineseStr(rs.getString("IP"));
                String tradeinfo = "TRADEINFO"+"%"+Trade+"%"+Commodity+"%"+Description+"%"+Contact+"%"+PostDate+"%"+XMLFile
                        +"%"+Bbsname+"%"+Boardname+"%"+Author+"%"+Alias+"%"+Ip;
                count ++;
                if ( count == 1)
                    recentDate = PostDate;
                vec.add(tradeinfo);
            }
        }catch(Exception ex){
            ex.printStackTrace();
        }
        bridge.setConnectionSwitch("off");
        setQueryCache(tradetype,kind,commodity,keywords,vec,recentDate);
        return vec;
    }


    public Vector getTradeInfoNum(String userid,String tradetype,String commodity,String recentvisit){
        Vector vec = new Vector();
        DBBridge bridge = new DBBridge();
        int count = 0;
        String newRecentVisit = recentvisit;
        try{
            String sql = "select POSTDATE from JIAOYIXINXI WHERE (TRADE = "+
                    tradetype+") AND (COMMODITY = '"+commodity+"') and (JIAOYIXINXI.POSTDATE>'"+recentvisit+"') ORDER BY POSTDATE DESC";
            System.out.println(sql);
            ResultSet rs = bridge.getStmt().executeQuery(sql);
            if (rs.next()){
                newRecentVisit = rs.getString("POSTDATE");
                if (rs.last())
                    count = rs.getRow();
            }
        }catch(Exception ex){
            ex.printStackTrace();
        }
        vec.add(String.valueOf(count));
        vec.add(newRecentVisit);
        bridge.setConnectionSwitch("off");
        return vec;
    }

    public  Vector getAllTradeInfo(){
        DBBridge bridge = new DBBridge();
        Vector vec = new Vector();
        try{
            String sql = "select * from JIAOYIXINXI order by COMMODITY";
            //ResultSet rs = DBConnector.getInstance().stmt.executeQuery(sql);
            ResultSet rs = bridge.getStmt().executeQuery(sql);
            while (rs.next()){
                short Trade = rs.getShort("TRADE");
                String Commodity = comTool.getChineseStr(rs.getString("COMMODITY"));
                String Description = comTool.getChineseStr(rs.getString("DESCRIPTION"));
                String Contact = comTool.getChineseStr(rs.getString("CONTACT"));
                String PostDate = rs.getString("POSTDATE");
                String XMLFile = rs.getString("XMLFILE");
                String tradeinfo = Trade+"#"+Commodity+"#"+Description+"#"+Contact+"#"+PostDate+"#"+XMLFile;
                vec.add(tradeinfo);
            }
            bridge.setConnectionSwitch("off");
            return vec;
        }catch(Exception ex){
            ex.printStackTrace();
        }
        bridge.setConnectionSwitch("off");
        return null;
    }

    public static void delTradeInfo(String xmlfile){
        DBBridge bridge = new DBBridge();
        try{
            String sql = "delete from JIAOYIXINXI where XMLFILE = '"+xmlfile+"'";
            //ResultSet rs = DBConnector.getInstance().stmt.executeQuery(sql);
            bridge.getStmt().execute(sql);
        }catch(Exception ex){
            ex.printStackTrace();
        }
        bridge.setConnectionSwitch("off");
    }


    public short getType() {
        return Type;
    }

    public String getCommodity() {
        return Commodity;
    }

    public String getDescription() {
        return Description;
    }

    public String getContact() {
        return Contact;
    }

    public String getDate() {
        return Date;
    }

    public String getXMLFile() {
        return XMLFile;
    }

    public  void TryDBBridge(){

    }

    public static void main(String[] args) {
        TradeInfo.delTradeInfo("adf");
    }

}

/*
public  synchronized static Vector getTradeInfo(String tradetype,String commodity){
DBBridge bridge = new DBBridge();
Vector vec = new Vector();
try{
String sql = "select * from JIAOYIXINXI,BBSXINXI WHERE (TRADE = "+
tradetype+") AND (COMMODITY = '"+commodity+"') and (JIAOYIXINXI.XMLFILE = BBSXINXI.XMLFILE) order by JIAOYIXINXI.POSTDATE desc";
System.out.println(sql);
//ResultSet rs = DBConnector.getInstance().stmt.executeQuery(sql);
ResultSet rs = bridge.getStmt().executeQuery(sql);
while (rs.next()){
int Trade = rs.getInt("TRADE");
String Commodity = comTool.getChineseStr(rs.getString("COMMODITY"));
String Description = comTool.getChineseStr(rs.getString("DESCRIPTION"));
String Contact = comTool.getChineseStr(rs.getString("CONTACT"));
String PostDate = comTool.getChineseStr(rs.getString("POSTDATE"));
PostDate = PostDate.substring(0,PostDate.length()-2);
String XMLFile = comTool.getChineseStr(rs.getString("XMLFILE"));
String Bbsname = comTool.getChineseStr(rs.getString("BBSNAME"));
String Boardname = comTool.getChineseStr(rs.getString("BOARDNAME"));
String Author = comTool.getChineseStr(rs.getString("AUTHOR"));
String Alias = comTool.getChineseStr(rs.getString("ALIAS"));
String Ip = comTool.getChineseStr(rs.getString("IP"));
String tradeinfo = "TRADEINFO"+"%"+Trade+"%"+Commodity+"%"+Description+"%"+Contact+"%"+PostDate+"%"+XMLFile
+"%"+Bbsname+"%"+Boardname+"%"+Author+"%"+Alias+"%"+Ip;
vec.add(tradeinfo);
}
bridge.setConnectionSwitch("off");
return vec;
}catch(Exception ex){
ex.printStackTrace();
}
bridge.setConnectionSwitch("off");
return null;
}
*/
/*
public  Vector  getTradeInfo(String tradetype,String commodity){
Vector vec = new Vector();
try{
SQLBridge bridge = new SQLBridge();
bridge.setConnectionSwitch("on");
String sql = "select * from JIAOYIXINXI,BBSXINXI WHERE (TRADE = "+
tradetype+") AND (COMMODITY = '"+commodity+"') and (JIAOYIXINXI.XMLFILE = BBSXINXI.XMLFILE) order by JIAOYIXINXI.POSTDATE desc";
//System.out.println(sql);
bridge.execSQL(sql);
long starttime = (new Date()).getTime();
while ((bridge.getResultSet() != null)&&(bridge.getResultSet().next())&&(bridge.getResultSet().getRow()<=500)){
String Trade = bridge.getFieldString("TRADE");
String Commodity = comTool.getChineseStr(bridge.getFieldString("COMMODITY"));
String Description = comTool.getChineseStr(bridge.getFieldString("DESCRIPTION"));
String Contact = comTool.getChineseStr(bridge.getFieldString("CONTACT"));
String PostDate = comTool.getChineseStr(bridge.getFieldString("POSTDATE"));
PostDate = PostDate.substring(0,PostDate.length()-2);
String XMLFile = comTool.getChineseStr(bridge.getFieldString("XMLFILE"));
String Bbsname = comTool.getChineseStr(bridge.getFieldString("BBSNAME"));
String Boardname = comTool.getChineseStr(bridge.getFieldString("BOARDNAME"));
String Author = comTool.getChineseStr(bridge.getFieldString("AUTHOR"));
String Alias = comTool.getChineseStr(bridge.getFieldString("ALIAS"));
String Ip = comTool.getChineseStr(bridge.getFieldString("IP"));
String tradeinfo = "TRADEINFO"+"%"+Trade+"%"+Commodity+"%"+Description+"%"+Contact+"%"+PostDate+"%"+XMLFile
+"%"+Bbsname+"%"+Boardname+"%"+Author+"%"+Alias+"%"+Ip;
vec.add(tradeinfo);
}
bridge.setConnectionSwitch("off");
long endtime = (new Date()).getTime();
comTool.ServerAdapterLog.info("######### RS.next : "+(endtime-starttime));
}catch(Exception ex){
ex.printStackTrace();
}
return vec;
}
*/