package?cn.itbaizhan.tyut.exam.common;

import?java.sql.Connection;
import?java.sql.DriverManager;
import?java.sql.SQLException;
import?java.util.List;

import?org.apache.commons.dbutils.DbUtils;
import?org.apache.commons.dbutils.QueryRunner;
import?org.apache.commons.dbutils.handlers.BeanListHandler;
import?org.apache.commons.dbutils.handlers.ScalarHandler;

public?class?DBUnitHelper?{

	/**
	?*?獲取數據庫鏈接
	?*?@return
	?*/
	public?static?Connection?getConn（）{
		Connection?conn?=?null;	
		try?{
			
			DbUtils.loadDriver（“com.mysql.jdbc.Driver“）;
			conn?=?DriverManager.getConnection（
					“jdbc:mysql://localhost:3306/exam“?“root“?“123456“）;
			
		}?catch?（SQLException?e）?{
			e.printStackTrace（）;
		}
		return?conn;
	}
	
	public?static?Integer?executeUpdate（String?sqlobject?...objects）{
		
		Connection?conn?=?getConn（）;
		QueryRunner?qr?=?new?QueryRunner（）;
		Integer?rtn?=?0;
		try?{
			if（objects?==?null）{
				rtn?=?qr.update（conn?sql）;
			}else{
				rtn?=?qr.update（conn?sql?objects）;
			}
		}?catch?（Exception?e）?{
			e.printStackTrace（）;
		}finally{
			try?{
				DbUtils.close（conn）;
			}?catch?（Exception?e）?{
				e.printStackTrace（）;
			}
		}		
		return?rtn;
	}
	
	public?static?Integer?executeUpdate（String?sql）{
		return?executeUpdate（sql?null）;
	}
	
	public?static??List?executeQuery（String?sqlClass?clsobject?...objects）{
		Connection?conn?=?getConn（）;
		List?list?=?null;
		try{
			QueryRunner?rq?=?new?QueryRunner（）;
			if（objects?==?null）{
				list?=?rq.query（conn?sqlnew?BeanListHandler（cls））;?
			}else{
				list?=?rq.query（conn?sqlnew?BeanListHandler（cls）objects）;?
			}
		}catch（Exception?e）{
			e.printStackTrace（）;
		}finally{
			try?{
				DbUtils.close（conn）;
			}?catch?（SQLException?e）?{
				e.printStackTrace（）;
			}
		}

		return?list;
	}
	
	public?static??List?executeQuery（String?sqlClass?cls）{
		return?executeQuery（sqlclsnull）;
	}
	
	/**
	?*?帶分頁的查詢
	?*?@param?sql?SQL語句
	?*?@param?map?SQL參數
	?*?@param?pc?分頁控制對象，需要傳遞參數：當前第幾頁（currentindex）每頁顯示多少行：（pagesize）
	?*?分頁控件顯示多少也：showpcount
	?*?@return
	?*/
	public?static??Pager?execlist（String?sqlPageControl?pcClass?clsString?pkobject...object）{

		//獲取總記錄數sql		?
		String?sqlcount?=?“select?count（*）?as?count?from?（“+sql+“）?a“;
		//獲取具體數據的SQL語句
		Integer?min?=?（pc.getCurrentindex（）-1）*pc.getPagesize（）;
		Integer?max?=?pc.getPagesize（）;
		String?sqllist?=?“select?*?from?（“+sql+“）?a?where?a.“+pk+“?limit?“+min+““+max;
		System.out.println（“執行的sql：“?+?sqllist）;
		Connection?conn?=?getConn（）;
		Pager?pager?=?new?Pager（）;
		try?{
			
			QueryRunner?rq?=?new?QueryRunner（）;
			object?count?=?rq.query（conn?sqlcount?new?ScalarHandlerject>（“count“）?object）;
			List?list?=?executeQuery（sqllistclsobject）;
			//設置總記錄數
			Integer?c?=?0;
			if（count!=null）{
				c=Integer.parseInt（count.toString（））;
			}
			pc.setRscount（c）;