src/org/bs/dao/impl/MessageDaoImpl.java

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

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

package org.bs.dao.impl;

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

import org.bs.dao.MessageDao;
import org.bs.model.Message;
import org.bs.utils.ConnContext;
import org.bs.utils.DB;
import org.bs.utils.PageContext;

public class MessageDaoImpl extends BaseDao implements MessageDao {

	public void save(Message message) {
		Connection conn = ConnContext.getConn();
		PreparedStatement pstmt = null;
		String sql = "insert into t_message(content,send_time,publisher,ip,is_forbiden,article_id)" +
				" values(?,now(),?,?,0,?) ";
		try {
			pstmt = conn.prepareStatement(sql);
			pstmt.setString(1, message.getContent());
			pstmt.setString(2,	message.getPublisher());
			pstmt.setString(3, message.getIp());
			pstmt.setInt(4, message.getArticleId());
			pstmt.executeUpdate();
		} catch (Exception e) {
			throw new RuntimeException(e);
		} finally{
			DB.close(pstmt);
		}
	}

	public void delete(int id) {
		Connection conn = ConnContext.getConn();
		PreparedStatement pstmt = null;
		String sql = "delete from t_message where id = ?";
		try {
			pstmt = conn.prepareStatement(sql);
			pstmt.setInt(1, id);
			pstmt.executeUpdate();
		} catch (Exception e) {
			throw new RuntimeException(e);
		} finally{
			DB.close(pstmt);
		}
	}

	public List<Message> query(int id) {
		Connection conn = ConnContext.getConn();
		PreparedStatement pstmt = null;
		ResultSet result = null;
		List<Message> list = new ArrayList<Message>();
		String sql = "select * from t_message where article_id="+id;
		String allRecordsSql="select count(*) "+sql.substring(sql.indexOf("from"));
		sql+=" order by send_time desc";
		sql+=" limit ?,?";
		PageContext.getPage().setRecordsCount(getRecordsCount(allRecordsSql, new Class[]{}, new Object[]{}));