package com.hrsoft.ms;

import com.hrsoft.db.*;
import java.util.*;
import java.sql.*;
import com.hrsoft.ms.ValueObject.*;

public class user{

	//新增用戶
	public boolean InsertUser(userDto ud){

		dbinit db = null;
		boolean bSuccess; 
		String sql ="";

		try{

			db = new dbinit();
			sql = "insert into testuser(userCode,userName,userPass) values('" + ud.getUserCode() + "','" +ud.getUserName() + "','" +ud.getUserPass() + "')"; 
			db.executeUpdate(sql);
			bSuccess = true;

		}catch(Exception ex){
			System.out.println("插入用戶信息失敗:" + ex.getMessage());
			bSuccess = false;
		}finally{
			try{
				if(db!=null){
					db.close();
				}
			}catch(Exception ex){
				System.out.println(ex.getMessage());
			}
		}
		return bSuccess;

		}

		//刪除用戶
		public boolean DeleteUser(userDto ud){

		dbinit db = null;
		boolean bSuccess; 
		String sql ="";

		try{

			db = new dbinit();
			sql = "delete from testuser where id = '" + ud.getId() + "'";
			db.executeUpdate(sql);
			bSuccess = true;

		}catch(Exception ex){
			System.out.println("刪除用戶信息失敗:" + ex.getMessage());
			bSuccess = false;
		}finally{
			try{
				if(db!=null){
					db.close();
				}
			}catch(Exception ex){
				System.out.println(ex.getMessage());
			}
		}
		return bSuccess;

		}

		//修改用戶
		public boolean ModifyUser(userDto ud){

		dbinit db = null;
		boolean bSuccess; 
		String sql ="";

		try{

			db = new dbinit();
			sql = "update testuser set userCode = '" + ud.getUserCode() + "', userName='" + ud.getUserName() + "', userPass= '" + ud.getUserPass() + "' where id = '" + ud.getId() + "'";
			db.executeUpdate(sql);
			System.out.println("Modify sql==>" + sql );
			bSuccess = true;

		}catch(Exception ex){
			System.out.println("刪除用戶信息失敗:" + ex.getMessage());
			bSuccess = false;
		}finally{
			try{
				if(db!=null){
					db.close();
				}
			}catch(Exception ex){
				System.out.println(ex.getMessage());
			}
		}
		return bSuccess;

		}

		//查詢用戶
		public Collection ListUser(String Id){

		dbinit db = null;
		boolean bSuccess; 
		String sql ="";
		Collection list = null;

		try{
			list = new ArrayList();
			db = new dbinit();
			if(Id==null || Id.equals(""))
				sql = "select * from testUser order by id";
			else
				sql = "select * from testUser where id = '" + Id + "'";
			ResultSet rs = db.executeQuery(sql);
			while(rs.next()){
				userDto ud = new userDto();
				ud.setId(rs.getString("id"));
				ud.setUserCode(rs.getString("userCode"));
				ud.setUserName(rs.getString("userName"));
				ud.setUserPass(rs.getString("userPass"));
				list.add(ud);
			}

		}catch(Exception ex){
			System.out.println("刪除用戶信息失敗:" + ex.getMessage());
		}finally{
			try{
				if(db!=null){
					db.close();
				}
			}catch(Exception ex){
				System.out.println(ex.getMessage());
			}
		}
		return list;

		}

		//簡單的分頁查詢用戶
		//參數: itemCount:每頁顯示數量
		//       pageId:當前頁號
		//返回: 查詢頁的數據
		public Collection ListUser(int itemCount,int pageId){

		dbinit db = null;
		boolean bSuccess; 
		String sql ="";
		Collection list = null;

		try{
			list = new ArrayList();
			db = new dbinit();
			sql = "select top " + itemCount + " * from testUser where id not in(select top " + itemCount*(pageId-1) + " id from  testuser order by id) order by id";
			ResultSet rs = db.executeQuery(sql);
			while(rs.next()){
				userDto ud = new userDto();
				ud.setId(rs.getString("id"));
				ud.setUserCode(rs.getString("userCode"));
				ud.setUserName(rs.getString("userName"));
				ud.setUserPass(rs.getString("userPass"));
				list.add(ud);
			}

		}catch(Exception ex){
			System.out.println("刪除用戶信息失敗:" + ex.getMessage());
		}finally{
			try{
				if(db!=null){
					db.close();
				}
			}catch(Exception ex){
				System.out.println(ex.getMessage());
			}
		}
		return list;

		}

}