基于Struts 框架的BBS论坛系统

package com.exm.dao; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; import com.exm.struts.form.*; import com.exm.tools.Change; public class OpDB { private boolean mark = false; private int perR = 5; private String currentP = "1"; private String gowhich = ""; public List<ClassForm> OpClassListShow() { List<ClassForm> listshow = null; String sql = "select * from tb_class"; DB mydb = new DB(); mydb.doPstm(sql, null); ResultSet rs = mydb.getRs(); if (rs != null) { try { listshow = new ArrayList<ClassForm>(); while (rs.next()) { ClassForm classSingle = new ClassForm(); classSingle.setClassId(String.valueOf(rs.getInt(1))); classSingle.setClassName(rs.getString(2)); classSingle.setClassIntro(rs.getString(3)); listshow.add(classSingle); } } catch (SQLException e) { System.out.println("调用OpDB类中OpClassListShow()方法出错！"); e.printStackTrace(); } } return listshow; } /** * * @param sql * @param params * @return */ public ClassForm OpClassShow(String sql,Object[] params){ DB mydb=new DB(); mydb.doPstm(sql,params); ResultSet rs=mydb.getRs(); ClassForm classform=null; if (rs!=null){ try { while(rs.next()){ classform=new ClassForm(); classform.setClassId(String.valueOf(rs.getInt(1))); classform.setClassName(rs.getString(2)); classform.setClassIntro(rs.getString(3)); } }catch (SQLException e) { e.printStackTrace(); } } return classform; } /** * * @param sql * @param params * @return */ public ClassForm OpClassList(String sql,Object[] params){ DB mydb=new DB(); mydb.doPstm(sql,params); ResultSet rs=mydb.getRs(); ClassForm classform=null; if (rs!=null){ try { while(rs.next()){ classform=new ClassForm(); classform.setBoardId(String.valueOf(rs.getInt(1))); classform.setClassId(String.valueOf(rs.getInt(2))); classform.setBoardName(rs.getString(3)); classform.setManager(rs.getString(4)); classform.setBoardbulletin(rs.getString(5)); } }catch (SQLException e) { e.printStackTrace(); } } return classform; } public List<ClassForm> OpClassListShow(String sql,Object[] params){ List<ClassForm> listshow=null; DB mydb=new DB(); mydb.doPstm(sql, params); ResultSet rs=mydb.getRs(); if(rs!=null){ try{ listshow=new ArrayList<ClassForm>(); while(rs.next()){ ClassForm classSingle=new ClassForm(); classSingle.setClassId(String.valueOf(rs.getInt(1))); classSingle.setBoardName(rs.getString(2)); classSingle.setManager(rs.getString(3)); classSingle.setBoardbulletin(rs.getString(4)); listshow.add(classSingle); } } catch (SQLException e) { System.out.println("调用OpDB类中OpClassListShow()方法出错！"); e.printStackTrace(); } } return listshow; } public List<EboardForm> OpBoardList(String sql,Object[] params){ List<EboardForm> listshow=null; DB mydb=new DB(); mydb.doPstm(sql,params); ResultSet rs=mydb.getRs(); if(rs!=null){ try { listshow=new ArrayList<EboardForm>(); while(rs.next()){ EboardForm boardSingle=new EboardForm(); boardSingle.setBoardId(String.valueOf(rs.getInt(1))); boardSingle.setClassId(String.valueOf(rs.getInt(2))); boardSingle.setBoardName(rs.getString(3)); boardSingle.setManager(rs.getString(4)); boardSingle.setBoardbulletin(rs.getString(5)); listshow.add(boardSingle); } } catch (SQLException e) { System.out.println("调用OpDB类中OpBoardList()方法出错！"); e.printStackTrace(); } } return listshow; } /** * * @param sql * @param params * @return */ public EboardForm OpBoardShow( String sql,Object[] params){ DB mydb=new DB(); mydb.doPstm(sql,params); ResultSet rs=mydb.getRs(); EboardForm boardform=null; if (rs!=null){ try { while(rs.next()){ boardform=new EboardForm(); boardform.setBoardId(String.valueOf(rs.getInt(1))); boardform.setClassId(String.valueOf(rs.getString(2))); boardform.setBoardName(rs.getString(3)); boardform.setManager(rs.getString(4)); boardform.setBoardbulletin(rs.getString(5)); } }catch (SQLException e) { e.printStackTrace(); } } return boardform; } public List<BoardForm> OpBoardListShow(String sql,Object[] params){ List<BoardForm> listshow=null; DB mydb=new DB(); mydb.doPstm(sql,params); ResultSet rs=mydb.getRs(); if(rs!=null){ try { listshow=new ArrayList<BoardForm>(); while(rs.next()){ BoardForm boardSingle=new BoardForm(); boardSingle.setBoardId(String.valueOf(rs.getInt(1))); boardSingle.setBoardClassID(String.valueOf(rs.getInt(2))); boardSingle.setBoardName(rs.getString(3)); boardSingle.setBoardMaster(rs.getString(4)); boardSingle.setBoardPcard(rs.getString(5)); String bbsNum=""; String undoNum=""; String goodNum=""; String sql1=""; Object[] params1={boardSingle.getBoardId()}; ResultSet rs1; // 查询该版面中所有的根帖数 sql1="select count(bbsId) from tb_bbs where bbsBoardID=?"; mydb.doPstm(sql1, params1); rs1=mydb.getRs(); if(rs1!=null&&rs1.next()){ bbsNum=String.valueOf(rs1.getInt(1)); } // 查询该版面中所有未处理的根帖数 sql1="SELECT COUNT(bbsId) AS num FROM tb_bbs WHERE (bbsBoardID = ?) AND (bbsId NOT IN (SELECT rootID FROM tb_bbsAnswer))"; mydb.doPstm(sql1, params1); rs1=mydb.getRs(); if(rs1!=null&&rs1.next()){ undoNum=String.valueOf(rs1.getInt(1)); } // 查询该版面中所有精华根帖数 sql1="select count(bbsId) from tb_bbs where bbsBoardID=? and bbsIsGood='1'"; mydb.doPstm(sql1, params1); rs1=mydb.getRs(); if(rs1!=null&&rs1.next()){ goodNum=String.valueOf(rs1.getInt(1)); } // 设置根帖数、未处理根帖数、精华帖数 boardSingle.setBoardBbsnum(bbsNum); boardSingle.setBoardBbsundonum(undoNum); boardSingle.setBoardBbsgoodnum(goodNum); listshow.add(boardSingle); } } catch (SQLException e) { System.out.println("调用OpDB类中OpBoardListShow()方法出错！"); e.printStackTrace(); } } return listshow; } public List<BbsForm> OpBbsListShow(String sql,Object[] params){ // ResultSet rs=getRs(sql,params); DB mydb=new DB(); mydb.doPstm(sql,params); ResultSet rs=mydb.getRs(); List<BbsForm> listshow=null; int i=1; if(rs!=null){ listshow=new ArrayList<BbsForm>(); try { while(rs.next()&&(!mark||i<=perR)){ BbsForm bbsform=new BbsForm(); bbsform.setBbsId(String.valueOf(rs.getInt(1))); bbsform.setBbsBoardID(String.valueOf(rs.getInt(2))); bbsform.setBbsTitle(rs.getString(3)); bbsform.setBbsContent(rs.getString(4)); bbsform.setBbsSender(rs.getString(5)); bbsform.setBbsSendTime(Change.dateTimeChange(rs.getTimestamp(6))); bbsform.setBbsFace(rs.getString(7)); bbsform.setBbsAnswerNum(rs.getString(8)); bbsform.setBbsOpTime(Change.dateTimeChange(rs.getTimestamp(9))); bbsform.setBbsIsTop(rs.getString(10)); bbsform.setBbsToTopTime(Change.dateTimeChange(rs.getTimestamp(11))); bbsform.setBbsIsGood(rs.getString(12)); bbsform.setBbsToGoodTime(Change.dateTimeChange(rs.getTimestamp(13))); /* 以下代码，查询tb_bbsAnswer数据表，查询出当前帖子的回复数、最后回复者、最后回复时间 */