messagedao.java

法改革开放的离开概率地方了过了的开始了开放个蒂法个饭店抒发个

package dboprartion;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.ArrayList;
import entity.Message;
public class MessageDao extends BaseDao{

	public MessageDao() {}
	Connection cn=null;
	PreparedStatement ps=null;
	ResultSet rs=null;
	/**
	 * 保存记录.
	 * @param message
	 * @return
	 */
	public int save(Message message){
		String str="insert into Message(note,sendUname,receiveUname,postTime,readSign)values(?,?,?,?,0)";
		String[] parm={message.getNote(),message.getSendUname(),message.getSendUname(),message.getPostTime()};
		return super.executeSQL(str, parm);
	}
	/**
	 * 删除记录.
	 * @param id
	 * @return
	 */
   public int del(int id){
	   String str="delete from Message where id="+id;
	   return super.executeSQL(str, null);
   }
   /**
    * 更新记录
    * @param message
    * @return
    */
   public int update(Message message){
	   String str="update Message set readSign=1 where id="+message.getId();
	   return super.executeSQL(str, null);
   }
   /**
    * 通过用户名查找信息
    * @param name
    * @return
    */
   public ArrayList listrecivemessage(String name){
	   ArrayList<Message> list=new ArrayList<Message>();
	   try{
	      cn=BaseDao.dbCn();
	      ps=cn.prepareStatement("select * from Message where receiveUname='"+name+"'");
	      rs=ps.executeQuery();
	      while(rs.next()){
	    	  Message message=new Message();
	    	  message.setId(rs.getInt("id"));
	    	  message.setNote(rs.getString("note"));
	    	  message.setSendUname(rs.getString("sendUname"));
	    	  message.setReceiveUname(rs.getString("receiveUname"));
	    	  message.setPostTime(rs.getString("postTime"));
	    	  message.setReadSign(rs.getShort("readsign"));
	    	  list.add(message);
	      }
	   }catch(Exception e){
		   System.out.print(e);
	   }
	   return list;
   }
   /**
    * 查找每条信息
    * @param id
    * @return
    */
   public Message findmessage(int id){
	   Message message=null;
	   try{
	      cn=BaseDao.dbCn();
	      ps=cn.prepareStatement("select * from Message where receiveUname="+id);
	      rs=ps.executeQuery();
	      while(rs.next()){
	    	 message=new Message();
	    	  message.setId(rs.getInt("id"));
	    	  message.setNote(rs.getString("note"));
	    	  message.setSendUname(rs.getString("sendUname"));
	    	  message.setReceiveUname(rs.getString("receiveUname"));
	    	  message.setPostTime(rs.getString("postTime"));
	    	  message.setReadSign(rs.getShort("readsign"));
	    	  
	      }
	   }catch(Exception e){
		   System.out.print(e);
	   }
	   return message;
   }
}