messagedao.java

企业宣传网站

package s2jsp.bysj.dao;

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

import s2jsp.bysj.entity.Message;

public class MessageDao extends BaseDao {
	private Connection conn = null;

	private PreparedStatement pstmt = null;

	private ResultSet rs = null;

	public int insertMessage(Message message) {
		String sql = "insert into message values(?,?,?,?,0) ";
		String[] param = new String[] { message.getTitle(),
				message.getContent(), message.getWriter(),
				message.getWriteDate() };
		
		return this.executeSQL(sql, param);
	}

	public List selectMessage() {
		List list = new ArrayList();
		String sql = "select * from message ";
		try {
			conn = this.getConn();
			pstmt = conn.prepareStatement(sql);
			rs = pstmt.executeQuery();
			while (rs.next()) {
				Message message = new Message();
				message.setMessageID(rs.getInt("messageID"));
				message.setTitle(rs.getString("title"));
				message.setContent(rs.getString("content"));
				message.setWriter(rs.getString("writer"));
				message.setWriteDate(rs.getString("writeDate"));
				message.setCount(rs.getInt("count"));

				list.add(message);
			}
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			this.closeAll(conn, pstmt, rs);
		}
		return list;
	}

	public Message selectMessageByID(String messageID) {
		Message message = null;
		String sql = "select * from message where messageID = ? ";
		try {
			conn = this.getConn();
			pstmt = conn.prepareStatement(sql);
			pstmt.setString(1, messageID);
			rs = pstmt.executeQuery();
			if (rs.next()) {
				message = new Message();
				message.setMessageID(rs.getInt("messageID"));
				message.setTitle(rs.getString("title"));
				message.setContent(rs.getString("content"));
				message.setWriter(rs.getString("writer"));
				message.setWriteDate(rs.getString("writeDate"));
				message.setCount(rs.getInt("count"));

			}
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			this.closeAll(conn, pstmt, rs);
		}
		return message;
	}
	
	public int updateCount(String messageID){
		int count=0;
		String sql="update message set count=count+1 where messageID= ? ";
		try{
			conn = this.getConn();
			pstmt = conn.prepareStatement(sql);
			pstmt.setString(1, messageID);
			count=pstmt.executeUpdate();
		}catch(Exception e){
			e.printStackTrace();
		}
		return count;
	}
}