messagebean.java

教师办公管理系统

package to.model.Message;


import java.sql.Connection;
import java.sql.Date;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.Collection;
import java.util.Vector;
import to.model.*;

public class MessageBean 
{
  
    Connection con=null;
    PreparedStatement ps=null;
    ResultSet rs=null;
    DBConnection db=new DBConnection("PeoplePool",500);
    public String insertMessage(MessageItem mi)
    {
        try
        {
           con=db.getConnection();
           ps=con.prepareStatement("insert into kjc_Message values(?,?,?,?,?,?)");
           ps.setString(1,mi.getMessageName());
           ps.setString(2,mi.getMessageD());
           ps.setString(3,mi.getMessageS());
           ps.setString(4,mi.getMessageMail());
           ps.setString(5,mi.getMessageAddr());
           ps.setInt(6,mi.getPeopleID());
           ps.executeUpdate();
           return "添加成功";
        }//end block try
        catch(Exception e)
        {
          e.printStackTrace();
          return "添加失败";
        }//end block catch
    }//end method insertMessage
    
    
    
    public Collection getMessage(int id)
    {
        Vector v=new Vector();    
        try
        {
          con=db.getConnection();
          ps=con.prepareStatement("select * from kjc_Message where PeopleID=?");
          ps.setInt(1,id);
          rs=ps.executeQuery();
          while(rs.next())
          {
            MessageItem mi=new MessageItem();
            mi.setMessageID(rs.getInt("MessageID"));
            mi.setMessageName(rs.getString("MessageName"));
            mi.setMessageD(rs.getString("MessageD"));
            mi.setMessageS(rs.getString("MessageS"));
            mi.setMessageMail(rs.getString("MessageMail"));
            mi.setMessageAddr(rs.getString("MessageAddr"));
            mi.setPeopleID(rs.getInt("PeopleID"));
            v.add(mi);
          }
          return v;
        }//end block try
        catch(Exception e)
        {
          e.printStackTrace();
          return null;
        }//end block catch
    }//end method getMessage()
    
    
    public String deleteMessage(int id)
    {
        try
        {
          con=db.getConnection();
          ps=con.prepareStatement("delete kjc_Message where MessageID=?");
          ps.setInt(1,id);
          ps.executeUpdate();
          return "删除成功";
        }//end block try
        catch(Exception e)
        {
          e.printStackTrace();
          return "删除失败";
        }//end block catch
    } //end method deleteMessage() 
    
    
    
    public MessageItem getMessageID(int id)
    {
      try
        {
          con=db.getConnection();
          ps=con.prepareStatement("select * from kjc_Message where MessageID=?");
          ps.setInt(1,id);
          rs=ps.executeQuery();
          MessageItem mi=new MessageItem();
          while(rs.next())
          {
            
            mi.setMessageID(rs.getInt("MessageID"));
            mi.setMessageName(rs.getString("MessageName"));
            mi.setMessageD(rs.getString("MessageD"));
            mi.setMessageS(rs.getString("MessageS"));
            mi.setMessageMail(rs.getString("MessageMail"));
            mi.setMessageAddr(rs.getString("MessageAddr"));
            mi.setPeopleID(rs.getInt("PeopleID"));
          }
          return mi;
        }//end block try
        catch(Exception e)
        {
          e.printStackTrace();
          return null;
        }//end block catch
    }//end method getMessageID
    
    
    public String updateMessage(MessageItem mi)
    {
          try
          {
            con=db.getConnection();
            ps=con.prepareStatement("update kjc_Message set MessageD=?,MessageS=?,MessageMail=?,MessageAddr=? where MessageID=?");
            ps.setString(1,mi.getMessageD());
            ps.setString(2,mi.getMessageS());
            ps.setString(3,mi.getMessageMail());
            ps.setString(4,mi.getMessageAddr());
            ps.setInt(5,mi.getMessageID());
            ps.executeUpdate();
            return "修改成功";
          }//end block try
          catch(Exception e)
          {
            e.printStackTrace();
            return "修改失败";
          }//end block catch
    }//end method updateMessage()
    
    
    public MessageItem getMessageName(String name)
    {
        try
        {
          con=db.getConnection();
          ps=con.prepareStatement("select * from kjc_Message where MessageName like '%"+name+"%'");
          //ps.setString(1,"%"+name+"%");
          rs=ps.executeQuery();
          MessageItem mi=new MessageItem();
          while(rs.next())
          {
            
            mi.setMessageID(rs.getInt("MessageID"));
            mi.setMessageName(rs.getString("MessageName"));
            mi.setMessageD(rs.getString("MessageD"));
            mi.setMessageS(rs.getString("MessageS"));
            mi.setMessageMail(rs.getString("MessageMail"));
            mi.setMessageAddr(rs.getString("MessageAddr"));
            mi.setPeopleID(rs.getInt("PeopleID"));
          }
          return mi;
        }//end block try
        catch(Exception e)
        {
          e.printStackTrace();
          return null;
        }//end block catch
    }//end method getMessageName()
  
}//end class MessageBean