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;
   }
}