messagecom.java

一个信息发布系统 基于jsp+servlet+tomcat 用户分管理员跟普通用户 普通用户有发布信息 查询信息 修改信息 回复信息 管理员拥有普通用户的功能 此外还具有删除信息 管理信息的回复的功能

package control;
import model.*;
import java.sql.*;
import java.util.Vector;

public class MessageCom 
{
	private Connection con;
    /**
     * 构造函数 取得与数据库的连接
     * @param url  数据库的url
     * @param database 数据库名
     * @param pasw 数据库的密码
     */
    public MessageCom(String url,String database,String pasw)
    {
    	con = new GetConnection(url,database,pasw).getConnection();
    }
    
    public void addMessage(String Title,String Content,String Sender,String Receiver,String Time)
    {
    	PreparedStatement pre;
    	String sql = "insert into message(标题,内容,发送者,接收者,发送时间) values(?,?,?,?,?)";
    	try
    	{
    		pre = con.prepareStatement(sql);
    		pre.setString(1, Title);
    		pre.setString(2, Content);
    		pre.setString(3, Sender);
    		pre.setString(3, Receiver);
    		pre.setString(5, Time);
    	}
    	catch(SQLException e){System.out.println("addMessage fail");}
    }
    
    public void delMessage(int ID)
    {
    	PreparedStatement pre;
    	String sql = "delete from message where ID = ?";
    	try
    	{
    		pre = con.prepareStatement(sql);
    		pre.setInt(1, ID);
    	}
    	catch(SQLException e){System.out.println("delMessage" + ID + " fail");}
    }
    
    public Vector getMessageBySender(String Sender)
    {
    	PreparedStatement pre;
    	Vector vc = new Vector();
    	
    	String sql = "select * from message where 发送者=?";
    	try
    	{
    		pre = con.prepareStatement(sql);
    		pre.setString(1, Sender);
    		ResultSet rs = pre.executeQuery();
    		while(rs.next())
    		{
    			Message message = new Message();
    			message.setID(rs.getInt("ID"));
    			message.setTitle(rs.getString("标题"));
    			message.setContent(rs.getString("内容"));
    			message.setSender(rs.getString("发送者"));
    			message.setReceiver(rs.getString("接收者"));
    			message.setTime(rs.getString("发送时间"));
    			message.setReadOrNot(rs.getBoolean("是否被阅读过"));
    			vc.add(message);
    		}
    		return vc;
    	}
    	catch(SQLException e){System.out.println("getMessageBySender" + Sender + " fail");return null;}
    }
    
    public Vector getMessageByReceiver(String Receiver)
    {
    	PreparedStatement pre;
    	Vector vc = new Vector();
    	
    	String sql = "select * from message where 接收者=?";
    	try
    	{
    		pre = con.prepareStatement(sql);
    		pre.setString(1, Receiver);
    		ResultSet rs = pre.executeQuery();
    		while(rs.next())
    		{
    			Message message = new Message();
    			message.setID(rs.getInt("ID"));
    			message.setTitle(rs.getString("标题"));
    			message.setContent(rs.getString("内容"));
    			message.setSender(rs.getString("发送者"));
    			message.setReceiver(rs.getString("接收者"));
    			message.setTime(rs.getString("发送时间"));
    			message.setReadOrNot(rs.getBoolean("是否被阅读过"));
    			vc.add(message);
    		}
    		return vc;
    	}
    	catch(SQLException e){System.out.println("getMessageBySender" + Receiver + " fail");return null;}
    }
}