messagebean.java

购物网站

package com;
import java.sql.*;
import java.util.*;
import java.io.*;
/**
 *MessageBean包含和TABLE_CUSTOMER_MESSAGE表相关的操作
 */
public class MessageBean{
	private Connection con;
	//构造方法，获得数据库的连接。
	public MessageBean(){
		this.con=DataBaseConnection.getConnection();
	}
	
	/*搜索所有的留言信息。
	 *返回由Message值对象组成的Collection
	 */
 public Collection getAllMessage()throws Exception
	{
		Statement stmt=con.createStatement();
		ResultSet rst=stmt.executeQuery("select * from TABLE_CUSTOMER_MESSAGE");
		Collection ret=new ArrayList();
		while(rst.next()){
			Message temp=new Message();
			temp.setMessageId(rst.getString("MESSAGE_ID"));
			temp.setCustomerId(rst.getInt("CUSTOMER_ID"));
			temp.setMovieId(rst.getString("MOVIE_ID"));
			temp.setMessageRevert(rst.getString("MESSAGE_REVERT"));
			temp.setMessageTime(rst.getString("MESSAGE_SEND_TIME"));
			ret.add(temp);
		}
		con.close();
		return ret;
	}
	/**
	 *删除留言，指定留言的ID
	 */
	public void deleteMessage(String messageId)throws Exception
	{
		Statement stmt=con.createStatement();
		stmt.execute("delete from TABLE_CUSTOMER_MESSAGE where MESSAGE_ID='"+messageId+"'");
	}
	
	/**
	 *按照MovieId查找，
	 *返回由Message值对象组成的Collection
	 */
	public Collection getMessageByMovieId(String movieId)throws Exception
	{
		Statement stmt=con.createStatement();
		ResultSet rst=stmt.executeQuery("select * from TABLE_CUSTOMER_MESSAGE where MOVIE_ID='"+movieId+"'");
		Collection ret=new ArrayList();
		while(rst.next())
		{
			Message temp=new Message();
			temp.setMessageId(rst.getString("MESSAGE_ID"));
			temp.setCustomerId(rst.getInt("CUSTOMER_ID"));
			temp.setMovieId(rst.getString("MOVIE_ID"));
			temp.setMessageRevert(rst.getString("MESSAGE_REVERT"));
			temp.setMessageTime(rst.getString("MESSAGE_SEND_TIME"));
			ret.add(temp);
		}
		con.close();
		return ret;
	}
}