源码：DruidDataSourceFactory创建数据库连接DataSource

package com.common.common.util.mysql; import java.util.Properties; import javax.sql.DataSource; import com.alibaba.druid.pool.DruidDataSourceFactory; public class DataSourceUtil { /** 使用配置文件构建Druid数据源. */ public static final int DRUID_MYSQL_MASTER = 1; /** 使用配置文件构建Druid数据源. */ public static final int DRUID_MYSQL_SALVE = 2; public static final DataSource getDataSource(int sourceType) throws Exception { DataSource dataSource = null; Properties p =new Properties(); p.put("initialSize", "1"); p.put("minIdle", "1"); p.put("maxActive", "20"); p.put("maxWait", "60000"); p.put("timeBetweenEvictionRunsMillis", "60000"); p.put("minEvictableIdleTimeMillis", "300000"); p.put("validationQuery", "SELECT 'x' from dual"); p.put("testWhileIdle", "true"); p.put("testOnBorrow", "false"); p.put("testOnReturn", "false"); p.put("poolPreparedStatements", "true"); p.put("maxPoolPreparedStatementPerConnectionSize", "20"); p.put("filters", "stat"); switch (sourceType) { case DRUID_MYSQL_MASTER: p.put("url", "jdbc:mysql://***?useUnicode=true&characterEncoding=utf8"); p.put("username", "***"); p.put("password", "***"); dataSource = DruidDataSourceFactory.createDataSource(p); break; case DRUID_MYSQL_SALVE: p.put("url", "jdbc:mysql://***?useUnicode=true&characterEncoding=utf8"); p.put("username", "***"); p.put("password", "***"); dataSource = DruidDataSourceFactory.createDataSource(p); break; } return dataSource; } }

package com.common.common.util.mysql; import java.sql.CallableStatement; import java.sql.Connection; import java.sql.DriverManager; 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; public class ConnectionDB { /** * 创建数据库连接对象 */ private Connection connnection = null; /** * 创建PreparedStatement对象 */ private PreparedStatement preparedStatement = null; /** * 创建CallableStatement对象 */ private CallableStatement callableStatement = null; /** * 创建结果集对象 */ private ResultSet resultSet = null; /** * 建立数据库连接 * @return 数据库连接 * @throws Exception */ public Connection getConnection(int type) throws Exception { try {// 获取连接 connnection =DataSourceUtil.getDataSource(type).getConnection(); } catch (SQLException e) { System.out.println(e.getMessage()); } return connnection; }/** * insert update delete SQL语句的执行的统一方法 * @param sql SQL语句 * @param params 参数数组，若没有参数则为null * @return 受影响的行数 * @throws Exception */ public int executeUpdate(String sql, Object[] params){ // 受影响的行数 int affectedLine = 0; try { // 获得连接 connnection = this.getConnection(1); // 调用SQL preparedStatement = connnection.prepareStatement(sql); // 参数赋值 if (params != null) { for (int i = 0; i < params.length; i++) { preparedStatement.setObject(i + 1, params[i]); } }// 执行 affectedLine = preparedStatement.executeUpdate(); } catch (Exception e) { System.out.println(e.getMessage()); } finally { // 释放资源 closeAll(); } return affectedLine; }/** * SQL 查询将查询结果直接放入ResultSet中 * @param sql SQL语句 * @param params 参数数组，若没有参数则为null * @return 结果集 * @throws Exception */ private ResultSet executeQueryRS(String sql, Object[] params){ try { // 获得连接 connnection = this.getConnection(2); // 调用SQL preparedStatement = connnection.prepareStatement(sql); // 参数赋值 if (params != null) { for (int i = 0; i < params.length; i++) { preparedStatement.setObject(i + 1, params[i]); } }// 执行 resultSet = preparedStatement.executeQuery(); } catch (Exception e) { System.out.println(e.getMessage()); }return resultSet; }/** * 获取结果集，并将结果放在List中 * * @param sql *SQL语句 * @return List *结果集 * @throws Exception */ public List