package org.yeeku.dao.esql;

import java.util.List;
import java.util.ArrayList;
import java.util.Iterator;



import org.yeeku.model.*;
import org.yeeku.dao.*;

public class UserDaoEsql extends BaseDao implements UserDao  
{
    /**
     * 根據(jù)id查找用戶
     * @param id 需要查找的用戶id
     */  
    public User get(int id) throws Exception
    {
        String sql = "select id,username,password,lasttime from user_message where id="+id;
	return esql.query(User.class, sql);
       
    }

    /**
     * 增加用戶
     * @param user 需要增加的用戶
     */       
    public void save(User user) throws Exception
    {  
        esql.update("insert into user_message(username,password,lasttime)values(?,?,?)",user.getUsername(),user.getPassword(),user.getLasttime());

    }

    /**
     * 修改用戶
     * @param user 需要修改的用戶
     */  
    public void update(User user) throws Exception
    {
         esql.update("insert into user_message(username,password,lasttime)values(?,?,?)",user.getUsername(),user.getPassword(),user.getLasttime());
    }

    /**
     * 刪除用戶
     * @param id 需要刪除的用戶id
     */  
    public void delete(int id) throws Exception
    {
         String sql = "delete from user_message where id="+id;
	 esql.update(sql);
    }

    /**
     * 刪除用戶
     * @param user 需要刪除的用戶
     */  
    public void delete(User user) throws Exception
    {
        int id=user.getId();
         String sql = "delete from user_message where id="+id;
	 esql.update(sql);
    }

    /**
     * 查詢?nèi)坑脩?     * @return 獲得全部用戶
     */ 
    public List<User> findAll() throws Exception
    {
        String sql = "select id,username,password,lasttime from user_message";
	return esql.list(User.class, sql);
    }

    /**
     * 根據(jù)用戶名，密碼查找用戶
     * @param username 查詢所需的用戶名
     * @param pass 查詢所需的密碼
     * @return 對應(yīng)的用戶
     */ 
    public User findUserByNameAndPass(String user , String pass) throws Exception
    {
         
        List ul=esql.list(User.class,"select id,username,password,lasttime from user_message au where au.username = ? and au.password = ?",user,pass);
        if (ul != null && ul.size() >= 1)
        {
            return (User)ul.get(0);
        }
        return null;
    }

    /**
     * 根據(jù)用戶名查找用戶
     * @param user 查詢所需的用戶名
     * @return 對應(yīng)的用戶
     */ 
    public User findUserByName(String user) throws Exception
	{
          List ul=esql.list(User.class,"select id,username,password,lasttime from user_message au where au.user = ?",user);
          if (ul != null && ul.size() >= 1)
           {
             return (User)ul.get(0);
           }
          return null;
	}
   
    public List<Message> checkNewMessage(String name) throws Exception
     {
        return esql.list(Message.class,"select id,fromUser,toUser,content,messageTime,isnew from message au where au.toUser = ? and au.isnew=1",name);
       
      }
    public  List<Message> getMessageByName(String name) throws Exception 
      {
         return esql.list(Message.class,"select id,fromUser,toUser,content,messageTime,isnew from message au where au.toUser = ? order by id",name);
        
      }
    public List<Message> getMessageFrom(String fromname,String username) throws Exception
       {
          return esql.list(Message.class,"select id,fromUser,toUser,content,messageTime,isnew from message au where au.fromUser = ? and au.toUser= ? order by id",fromname,username);
        
       }
    public void saveMessage(Message message) throws Exception
      {            
         esql.update("insert into message(fromUser,toUser,messageTime,isnew,content)values(?,?,?,?,?)",message.getFromuser(),message.getTouser(),message.getMessagetime(),message.getIsnew(),message.getContent());
      }
      public void deleteMessage(int id) throws Exception
      {
          String sql = "delete from message where id="+id;
	  esql.update(sql);
      }
}