subjectmgmt.java

论坛元程序

package yy;

import yy.DataBaseConnection;
import yy.Subject;
import yy.Reply;
import yy.ReplyMgmt;
import java.io.*;
import java.util.*;
import java.sql.*;

public class SubjectMgmt {
  private Connection con;

  //构造函数
  public SubjectMgmt() {
    con = DataBaseConnection.getConnection();
  }

  //返回当前社区的所有帖子
  public Collection getSubjectByCommunityId(int communityId) throws Exception {
    Statement stmt = con.createStatement();
    ResultSet rst = stmt.executeQuery(
        "select * from Subject where community_id=" + communityId +
        " order by publish_time desc");
    Collection ret = new ArrayList();
    while (rst.next()) {
      Subject temp = new Subject();
      temp.setSubjectId(rst.getInt("subject_id"));
      temp.setCommunityId(rst.getInt("community_id"));
      temp.setSubjectTitle(rst.getString("subject_title"));
      temp.setSubjectContent(rst.getString("subject_content"));
      java.sql.Date date = rst.getDate("publish_time");
      temp.setPublishTime(date);
      //temp.setPublishTime(rst.getString("publish_time"));
      temp.setAuthor(rst.getString("author"));
      temp.setNumOfSee(rst.getInt("numofsee"));
      temp.setNumOfReply(rst.getInt("numofreply"));
      temp.setSubjectPic(rst.getString("subject_pic"));
      temp.setLastReplier(rst.getString("last_replier"));
      date = rst.getDate("last_replytime");
      temp.setLastReplyTime(date);
      //temp.setPublishTime(rst.getString("last_replytime"));
      temp.setSubjectTopic(rst.getString("subject_topic"));
      ret.add(temp);

    }
    //rst.close();
    //stmt.close();
    con.close();
    return ret;
  }

  //返回指定ID的一条帖子
  public Subject getOneSubject(int subjectId) throws Exception {
    Statement stmt = con.createStatement();
    ResultSet rst = stmt.executeQuery("select * from Subject where subject_id=" +
                                      subjectId);

    Subject temp = new Subject();
    if (rst.next()) {
      temp.setSubjectId(rst.getInt("subject_id"));
      temp.setCommunityId(rst.getInt("community_id"));
      temp.setSubjectTitle(rst.getString("subject_title"));
      temp.setSubjectContent(rst.getString("subject_content"));
      java.sql.Date date = rst.getDate("publish_time");
      temp.setPublishTime(date);
      //temp.setPublishTime(rst.getString("publish_time"));
      temp.setAuthor(rst.getString("author"));
      temp.setNumOfSee(rst.getInt("numofsee"));
      temp.setNumOfReply(rst.getInt("numofreply"));
      temp.setSubjectPic(rst.getString("subject_pic"));
      temp.setLastReplier(rst.getString("last_replier"));
      date = rst.getDate("last_replytime");
      temp.setLastReplyTime(date);
      //temp.setPublishTime(rst.getString("last_replytime"));
      temp.setSubjectTopic(rst.getString("subject_topic"));
    }
    //rst.close();
    //stmt.close();
    con.close();
    return temp;

  }

  //删除一条帖子
  public void deleteOneSubject(int subjectId) throws Exception {
    Statement stmt = con.createStatement();
    ReplyMgmt delReply = new ReplyMgmt();
    delReply.deleteReplyBySubjectId(subjectId); //删除此帖子包含的所有回复
    stmt.execute("delete from Subject where subject_id=" + subjectId);
    //stmt.close();

  }

}