messagebean.java

小商品管理系统

package b;
import java.sql.*;
import java.util.*;
public class MessageBean
{
	private Connection con;
	public MessageBean()
	{
		String driver="com.microsoft.jdbc.sqlserver.SQLServerDriver";
		String url="jdbc:microsoft:sqlserver://127.0.0.1:1433;DatabaseName=sea";
		String user="sa";
		String pwd="sa";
		try
		{
			Class.forName(driver);
			con=DriverManager.getConnection(url,user,pwd);
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
	}

	public void addMessage(MessageVO msg)
	{
		try
		{
			PreparedStatement pstmt=con.prepareStatement("insert into message values(?,?,?,?,?)");
			pstmt.setString(1,msg.getTitle());
			pstmt.setString(2,msg.getName());
			pstmt.setString(3,msg.getEmail());
			pstmt.setString(4,msg.getContent());
			pstmt.setDate(5,new java.sql.Date(new java.util.Date().getTime()));
	      
			pstmt.executeUpdate();
			//pstmt.close();
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
	}
	public Collection getMessage()
	{
		Collection ret=new ArrayList();
		try
		{
			Statement stmt=con.createStatement();
			ResultSet result=stmt.executeQuery("select count(*)from message");
			int message_count=0;
			if(result.next())
			{
				message_count=result.getInt(1);
				//result.close();
			}
			if(message_count>0)
			{
				 ResultSet result1=stmt.executeQuery("select*from message order by date desc");
				
				while(result1.next())
				{
					String title=result1.getString("title");
					String name=result1.getString("name");
					String email=result1.getString("email");
					String content=result1.getString("content");
					java.sql.Date date=result1.getDate("date");
					
					MessageVO message=new MessageVO();
					message.setTitle(title);
					message.setName(name);
					message.setEmail(email);
					message.setContent(content);
					message.setDate(date);
					ret.add(message);
				}
				//result.close();
				//stmt.close();
			}
			//con.close();
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
		return ret;
	}
}