数据连接池&jdbc

其好处是易于扩展，代码的重用性极高。具有很高的移植性

它需要配置一个.properties的属性文件 

例如：

driver=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/ysj
user=root
password=a
很简单吧  你也试下吧

 

 

 

package com.icss.dao;

import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
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.List;

import org.apache.commons.dbcp.BasicDataSource;

public class DBHelper {
 private Connection con = null;
 private PreparedStatement pstmt;
 private ResultSet rs;
 private ResultSetMetaData metaData;

 public Connection getCon() {

  try {
   if (con == null) {
    BasicDataSource ds = new BasicDataSource();
    // 基本参数
    ds.setDriverClassName(Env.getInstance().getProperty("driver"));
    ds.setUsername(Env.getInstance().getProperty("user"));
    ds.setPassword(Env.getInstance().getProperty("password"));
    ds.setUrl(Env.getInstance().getProperty("url"));
    // 池属性
    ds.setInitialSize(5);// 初始化连接池时,创建连接个数
    ds.setMinIdle(10);// 最小空闲连接数
    ds.setMaxIdle(100);// 最大空闲连接数
    ds.setMaxActive(100);// 连接池最大并发容量
    con = ds.getConnection();
   }
  } catch (SQLException e) {
   e.printStackTrace();
  }

  return con;
 }

 protected void fillParameter(PreparedStatement pstmt, String[] params) {
  if (pstmt != null && params != null && params.length > 0) {
   for (int i = 0; i < params.length; i++) {
    try {
     pstmt.setString(i + 1, params[i]);
    } catch (SQLException e) {
     e.printStackTrace();
    }
   }
  }
 }

 public void closeAll(Connection con, PreparedStatement pstmt, ResultSet rs) {
  if (rs != null) {
   try {
    rs.close();
   } catch (SQLException e) {
    e.printStackTrace();
   }
  }
  if (pstmt != null) {
   try {
    pstmt.close();
   } catch (SQLException e) {
    e.printStackTrace();
   }
  }
  if (con != null) {
   try {
    con.close();
   } catch (SQLException e) {
    e.printStackTrace();
   }
  }
 }

 public int doUpdate(String sql, String[] params) {
  int result = -1;
  con = getCon();
  try {
   pstmt = con.prepareStatement(sql);
   fillParameter(pstmt, params);
   result = pstmt.executeUpdate();
  } catch (SQLException e) {
   e.printStackTrace();
  } finally {
   closeAll(con, pstmt, null);
  }
  return result;
 }

 public int getUniqueResult(String sql, String[] params) {
  int result = -1;
  con = this.getCon();
  try {
   pstmt = con.prepareStatement(sql);
   fillParameter(pstmt, params);
   rs = pstmt.executeQuery();
   while (rs.next()) {
    result = rs.getInt(1);
   }
  } catch (SQLException e) {
   e.printStackTrace();
  } finally {
   closeAll(con, pstmt, rs);
  }

  return result;

 }

 public <T> List<T> findAll(String sql, String[] params, Class<T> t) {
  List<T> list = new ArrayList<T>();
  // 通过反射取出Class中所有的方法
  Method[] methods = t.getMethods();

  con = this.getCon();
  try {
   pstmt = con.prepareStatement(sql);
   fillParameter(pstmt, params);

   // 获取数据库中要查询的表的信息
   int columnCount = getColumnCount(pstmt);
   // 定义一个字符串数组用来存所有的数据表中的列名
   String[] columnNames = new String[columnCount];
   // 将所有的列名都按顺序存到这个数组中去
   restoreAllColumnNames(columnNames);

   // 继续执行rs操作
   rs = pstmt.executeQuery();
   while (rs.next()) {
    // 实例化一个对象
    T instance = t.newInstance();

    // 循环方法数组和columnNames组
    for (Method m : methods) {
     for (int i = 0; i < columnNames.length; i++) {
      // 取出columnNames中的名字在前面加上set
      String mname = "set" + columnNames[i];
      //System.out.println("数据库列:" + columnNames[i]);
      //System.out.println("方法是:" + m.getName());
      //System.out.println("类型为:"
      //  + rs.getObject(columnNames[i]).getClass()
      //    .getName());
      if (m.getName().equalsIgnoreCase(mname)) {
       if ("java.math.BigDecimal".equals(rs.getObject(
         columnNames[i]).getClass().getName())) {
        m
          .invoke(instance, rs
            .getDouble(columnNames[i]));
       } else {
        m
          .invoke(instance, rs
            .getObject(columnNames[i]));
       }
      }
     }
    }

    list.add(instance);
   }
  } catch (IllegalArgumentException e) {
   e.printStackTrace();
  } catch (SQLException e) {
   e.printStackTrace();
  } catch (InstantiationException e) {
   e.printStackTrace();
  } catch (IllegalAccessException e) {
   e.printStackTrace();
  } catch (InvocationTargetException e) {
   e.printStackTrace();
  }
  return list;

 }

 /**
  * 将所有的列名都按顺序存到这个数组中去
  *
  * @param pstmt2
  * @param columnNames
  * @throws SQLException
  */
 private void restoreAllColumnNames(String[] columnNames)
   throws SQLException {
  for (int i = 0; i < columnNames.length; i++) {
   columnNames[i] = metaData.getColumnName(i + 1);
  }
 }

 /**
  * 获取数据库中要查询的表的所有的列的数量
  *
  * @param pstmt2
  * @return
  * @throws SQLException
  */
 private int getColumnCount(PreparedStatement pstmt) throws SQLException {
  int count = 0;
  metaData = pstmt.getMetaData();
  count = metaData.getColumnCount();
  return count;
 }

}