src/com/sanqing/daoImpl/ReplyDAOImpl.java

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

package com.sanqing.daoImpl;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.List;

import sun.awt.RepaintArea;

import com.sanqing.bean.Message;
import com.sanqing.bean.Reply;
import com.sanqing.dao.ReplyDAO;
import com.sanqing.util.DBConnection;
import com.sanqing.util.Page;

public class ReplyDAOImpl implements ReplyDAO {
public void addReplay(Reply replay) {
	Connection conn = DBConnection.getConnection();		//获得连接对象
	String addSQL = "insert into tb_reply(replyContent," +
			"employeeID,replyTime,messageID) values(?,?,?,?)";
	PreparedStatement pstmt = null;						//声明预处理对象
	try {
		pstmt = conn.prepareStatement(addSQL);			//获得预处理对象并赋值
		pstmt.setString(1, replay.getReplyContent());	//设置回复内容
		pstmt.setInt(2, replay.getEmployeeID());		//设置回复人
		pstmt.setTimestamp(3,new Timestamp(
				replay.getReplyTime().getTime()));		//设置回复时间
		pstmt.setInt(4, replay.getMessageID());			//设置消息编号
		pstmt.executeUpdate();								//执行更新
	} catch (SQLException e) {
		e.printStackTrace();
	} finally{
		DBConnection.close(pstmt);							//关闭预处理对象
		DBConnection.close(conn);							//关闭连接对象
	}
}

public int findCountByMsgID(int messageID) {
	Connection conn = DBConnection.getConnection();	//获得连接对象
	String findSQL = "select count(*) from tb_reply where messageID = ?";
	PreparedStatement pstmt = null;					//声明预处理对象
	ResultSet rs = null;
	int count = 0;
	try {
		pstmt = conn.prepareStatement(findSQL);		//获得预处理对象并赋值
		pstmt.setInt(1, messageID);
		rs = pstmt.executeQuery();				//执行查询
		if(rs.next()) {
			count = rs.getInt(1);
		}
	} catch (SQLException e) {
		e.printStackTrace();
	} finally{
		DBConnection.close(rs);								//关闭结果集对象
		DBConnection.close(pstmt);							//关闭预处理对象
		DBConnection.close(conn);							//关闭连接对象
	}