GZ/nwyj/.svn/pristine/5f/5f5e3846a8743c6afeaa295752f57e220d8d764b.svn-base

package com.sinosoft.em.evaluate;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import com.persistence.DbConnection;



/**
 * 用于数据库操作
 * @author len
 * 
 */
public class DbHander {
	
	private static Log	log	= LogFactory.getLog(DbHander.class);
	private DbConnection dbConn = new DbConnection();
	private Connection conn = null;
	private PreparedStatement prst = null;
	
	public DbHander(){
		//createDbConn();
		
	}
	public void createDbConn(){
		try {
			if(conn==null || conn.isClosed())
				conn = dbConn.getConnection();
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		} catch (SQLException e) {
			e.printStackTrace();
			log.error("DbHander 连接数据失败", e);
		}
	}
	
	public void destroyDbConn() {
		try {
			if(prst!=null)
				prst.close();
			if(conn!=null && !conn.isClosed())
				conn.close();
		} catch (SQLException e) {
			e.printStackTrace();
			log.error("DbHander 连接关闭失败", e);
		}
	}
	public List<Map<String,String>> queryForList(String sql,Object [] args0){
		createDbConn();
		List<Map<String,String>> result = new  ArrayList<Map<String,String>>();
		try {
			prst = conn.prepareStatement(sql);
			for(int i=0;i<args0.length;i++){
				prst.setString(i+1,String.valueOf(args0[i]));
			}
			ResultSet rs = prst.executeQuery();
			ResultSetMetaData rsmd = rs.getMetaData();
			int count = rsmd.getColumnCount();
			//String field = rsmd.getColumnName(1);
			while(rs.next()){
				Map<String,String> map = new HashMap<String, String>();
				for(int i=0;i<count;i++){
					map.put(rsmd.getColumnName(i+1), rs.getString(rsmd.getColumnName(i+1)));
				}
				result.add(map);
			}
			rs.close();
			destroyDbConn();
		} catch (SQLException e) {
			log.error("数据库查询失败！");
			e.printStackTrace();
		}
		return result;
	}
	
	public List<Map<String,String>> queryForList(String sql){
		createDbConn();
		List<Map<String,String>> result = new  ArrayList<Map<String,String>>();
		try {
			prst = conn.prepareStatement(sql);
			ResultSet rs = prst.executeQuery();
			ResultSetMetaData rsmd = rs.getMetaData();
			int count = rsmd.getColumnCount();
			//String field = rsmd.getColumnName(1);
			while(rs.next()){
				Map<String,String> map = new HashMap<String, String>();
				for(int i=0;i<count;i++){
					map.put(rsmd.getColumnName(i+1), rs.getString(rsmd.getColumnName(i+1)));
				}
				result.add(map);
			}
			rs.close();
			destroyDbConn();
		} catch (SQLException e) {
			log.error("数据库查询失败！");
			e.printStackTrace();
		}
		return result;
	}
	
	public ResultSet query(String sql,Object [] args){
		createDbConn();
		ResultSet rs = null;
		try {
			prst = conn.prepareStatement(sql);
			for(int i=0;i<args.length;i++){
				prst.setString(i+1,String.valueOf(args[i]));
			}
			rs = prst.executeQuery();
		} catch (SQLException e) {
			log.error("数据库查询失败！");
			e.printStackTrace();
		}
		return rs;
	}
	public ResultSet query(String sql){
		createDbConn();
		ResultSet rs = null;
		try {
			prst = conn.prepareStatement(sql);
			rs = prst.executeQuery();
		} catch (SQLException e) {
			log.error("数据库查询失败！");
			e.printStackTrace();
		}
		return rs;
	}
	
	public int update(String sql,Object [] args){
		createDbConn();
		int result = 0;
		try {
			prst = conn.prepareStatement(sql);
			for(int i=0;i<args.length;i++){
				prst.setString(i+1,String.valueOf(args[i]));
			}
			result = prst.executeUpdate();
		} catch (SQLException e) {
			log.error("数据库更新失败！");
			e.printStackTrace();
		}finally{
			destroyDbConn();
		}
		return result;
	}
	public int update(String sql){
		createDbConn();
		int result = 0;
		try {
			prst = conn.prepareStatement(sql);
			result = prst.executeUpdate();
		} catch (SQLException e) {
			log.error("数据库更新失败！");
			e.printStackTrace();
		}finally{
			destroyDbConn();
		}
		return result;
	}
	
	public int insert(String sql,Object [] args){
		createDbConn();
		int result = 0;
		try {
			prst = conn.prepareStatement(sql);
			for(int i=0;i<args.length;i++){
				prst.setString(i+1,String.valueOf(args[i]));
			}
			result = prst.executeUpdate();
		} catch (SQLException e) {
			log.error("数据库更新失败！");
			e.printStackTrace();
		}finally{
			destroyDbConn();
		}
		return result;
	}
	public int insert(String sql){
		createDbConn();
		int result = 0;
		try {
			prst = conn.prepareStatement(sql);
			result = prst.executeUpdate();
		} catch (SQLException e) {
			log.error("数据库更新失败！");
			e.printStackTrace();
		}finally{
			destroyDbConn();
		}
		return result;
	}

	
}