messagedao.java

简单的企业宣传的网站

package dao;
import java.sql.*;

import entity.*;
import java.util.*;
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.excuteSQL(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 (ClassNotFoundException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			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();
			while(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 (ClassNotFoundException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			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 (ClassNotFoundException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}
		return count;
	}
}