jsp客户交流系统（BBS）源码

package com.chrysler.dao.impl; import java.util.ArrayList; import java.util.List; import com.chrysler.dao.ITopicDao; import com.chrysler.entity.Channel; import com.chrysler.entity.Topic; /** * 对主题表数据进行操作 * @author Administrator * */ public class TopicDaoImpl extends DataBaseDao implements ITopicDao{ /** * 根据频道ID 查询主题 * @param channel * @return */ public List<Topic> findTopic(Channel channel,int page,int row){ List<Topic> list =new ArrayList<Topic>(); try { int num=(page-1)*row; String sql="select top "+row+" * from Topic where topId not in (select top "+num+" topId from Topic where " + " chanId=? order by topLastTime desc) and chanId=? order by topLastTime desc"; ps=this.getCon().prepareStatement(sql); ps.setString(1, Integer.toString(channel.getChanId())); ps.setString(2, Integer.toString(channel.getChanId())); //传入频道ID rs=ps.executeQuery(); while(rs.next()){ Topic topic = new Topic(); topic.setTopId(rs.getInt(1)); topic.setChanId(rs.getInt(2)); topic.setUserId(rs.getInt(3)); topic.setTopTitle(rs.getString(4)); topic.setTopContent(rs.getString(5)); topic.setTopReplyCount(rs.getInt(6)); topic.setTopClickCount(rs.getInt(7)); topic.setTopTime(rs.getString(8)); topic.setTopLastTime(rs.getString(9)); list.add(topic); } return list; } catch (Exception e) { e.printStackTrace(); return null; }finally{ this.closeDB(con, ps, rs); } } /** * 根据频道ID 查询主题个数 * @param channel * @return */ public int findTopicCount(Channel channel){ try { String sql="select count(topId) from Topic where chanId=?"; ps=this.getCon().prepareStatement(sql); ps.setString(1, channel.getChanId()+""); rs=ps.executeQuery(); if(rs.next()){ return rs.getInt(1); }else{ return 0; } } catch (Exception e) { e.printStackTrace(); return 0; }finally{ this.closeDB(con, ps, rs); } } /** * 根据主题ID 查询该主题信息 * @param topic * @return */ public Topic findOneTopic(Topic topic){ try { String sql="select * from Topic where topId=?"; ps=this.getCon().prepareStatement(sql); ps.setString(1, Integer.toString(topic.getTopId())); //传入主题ID rs=ps.executeQuery(); if(rs.next()){ topic.setTopId(rs.getInt(1)); topic.setChanId(rs.getInt(2)); topic.setUserId(rs.getInt(3)); topic.setTopTitle(rs.getString(4)); topic.setTopContent(rs.getString(5)); topic.setTopReplyCount(rs.getInt(6)); topic.setTopClickCount(rs.getInt(7)); topic.setTopTime(rs.getString(8)); topic.setTopLastTime(rs.getString(9)); topic.setTopImage(rs.getString(10)); return topic; }else{ return null; } } catch (Exception e) { e.printStackTrace(); return null; }finally{ this.closeDB(con, ps, rs); } } /** * 增加主题浏览量 * @param topic */ public void addClickCount(Topic topic){ String sql="update Topic set topClickCount=topClickCount+1 where topId=?"; String []parm={Integer.toString(topic.getTopId())}; this.executeSQL(sql, parm); } /** * 增加主题回复量 * @param topic */ public void addTopReplyCount(Topic topic){ String sql="update Topic set topReplyCount=topReplyCount+1 where topId=?"; String []parm={Integer.toString(topic.getTopId())}; this.executeSQL(sql, parm); } /** * 增加主题 * @param topic * @return */ public int insertTopic(Topic topic){ String sql="insert into Topic values(?,?,?,?,0,0,?,?,?)"; String []parm={Integer.toString(topic.getChanId()),topic.getUserId()+"",topic.getTopTitle(),topic.getTopContent(),topic.getTopTime(),topic.getTopTime(),topic.getTopImage()}; return this.executeSQL(sql, parm); } /** * 更新主题最后回复时间 * @param topic * @return */ public int updateTime(Topic topic){ String sql="update Topic set topLastTime=? where topId=?"; String []parm={topic.getTopLastTime(),Integer.toString(topic.getTopId())}; return this.executeSQL(sql, parm); } /** * 根据主题ID 删除主题记录（跟帖记录一并删除） * @param topic * @return */ public int delTopic(Topic topic){ String []parm={Integer.toString(topic.getTopId())}; String sql="delete follow where topId=?"; this.executeSQL(sql, parm); sql="delete Topic where topId=?"; return this.executeSQL(sql, parm); } /** * 根据频道Id 删除所以主题 * @param channel * @return */ public int delTopicAll(Channel channel){ String sql="delete Topic where chanId=?"; String []parm={Integer.toString(channel.getChanId())}; return this.executeSQL(sql, parm); } }