/**

* 自定义的连接池

*/

public class MyPool {

//连接参数

private static String url = "jdbc:mysql://localhost:3306/day19";

private static String user = "root";

private static String password = "root";

private static String driverClass = "com.mysql.jdbc.Driver";

//使用集合存储多个连接对象

LinkedList<Connection> pool = new LinkedList<Connection>();

/**

* 连接池的初始连接数

*/

private int initSize = 5;

/**

* 连接池的最大连接数

*/

private int maxSize = 8;

/**

* 连接池中的当前连接数,用于记录连接中有几个连接对象？

*/

private int currentSize = 0;

public MyPool(){

/**

* 创建若干个连接对象，放入到集合中

*/

for(int i=1;i<=initSize;i++){

pool.addLast(createConnection());

currentSize++;

}

}

static{

try {

//注册驱动

Class.forName(driverClass);

} catch (ClassNotFoundException e) {

e.printStackTrace();

throw new RuntimeException(e);

}

}

/**

* 创建连接方法

*/

private Connection createConnection(){

try {

Connection conn = DriverManager.getConnection(url, user, password);

return conn;

} catch (SQLException e) {

e.printStackTrace();

throw new RuntimeException(e);

}

}

/**

* 对外提供获取连接的方法

*/

public Connection getConnection(){

/**

* 1)判断连接池中是否还有连接对象，池中有连接，直接取出池中连接

*/

if(pool.size()>0){

/**

* 直接返回连接池中的一个连接对象

*/

return pool.removeFirst();

}

/**

* 2）如果初始连接数不足的情况下，需要获取新的连接对象。但不能超过最大连接数

*/

if(currentSize<maxSize){

Connection conn = createConnection();

currentSize++;

return conn;

}

/**

* 3)超过最大连接数时，需要处理（抛出异常或让用户等待）

*/

throw new RuntimeException("超过了最大连接数，请稍后再来");

}

/**

* 对外提供释放连接的方法

*/

public void releaseConnection(Connection conn){

/**

* 把用完的连接对象放回到连接池中

*/

pool.addLast(conn);

}

}

@Test

public void test1(){

try {

//1.创建连接池对象

BasicDataSource ds = new BasicDataSource();

//2.设置连接参数

ds.setUrl("jdbc:mysql://localhost:3306/day19");

ds.setUsername("root");

ds.setPassword("root");

ds.setDriverClassName("com.mysql.jdbc.Driver");

//3.设置连接池参数

ds.setInitialSize(5);//初始连接数

ds.setMaxActive(8);//最大连接数

ds.setMaxWait(3000);//超过最大连接数时，最大等待时间

ds.setMaxIdle(3000);//最大空闲时间

//4.获取连接

for(int i=1;i<=9;i++){

Connection conn = ds.getConnection();

System.out.println(conn.hashCode());

if(i==5){

//释放连接(不是真正的关闭连接对象，而是把连接对象放回连接池)

conn.close();

}

}

} catch (SQLException e) {

e.printStackTrace();

}

}

url=jdbc:mysql://localhost:3306/day19

username=root

password=root

driverClassName=com.mysql.jdbc.Driver

initialSize=5

maxActive=8

maxWait=3000

maxIdle=3000

@Test

public void test2(){

try {

Properties prop = new Properties();

prop.load(Demo.class.getResourceAsStream("/dbcp.properties"));

//1.创建连接池对象

BasicDataSource ds = (BasicDataSource)BasicDataSourceFactory.createDataSource(prop);

//2.获取连接

for(int i=1;i<=9;i++){

Connection conn = ds.getConnection();

System.out.println(conn.hashCode());

if(i==5){

//释放连接(不是真正的关闭连接对象，而是把连接对象放回连接池)

conn.close();

}

}

}catch (Exception e) {

e.printStackTrace();

}

}

/**

* 使用C3p0连接池

* 注意： DataSource接口是Sun公司设计的用于规范连接池实现的接口。

*/

public class Demo {

@Test

public void test1(){

try {

//1.创建连接池对象

ComboPooledDataSource ds = new ComboPooledDataSource();

//2.设置连接参数

ds.setDriverClass("com.mysql.jdbc.Driver");

ds.setJdbcUrl("jdbc:mysql://localhost:3306/day19");

ds.setUser("root");

ds.setPassword("root");

//3.设置连接池参数

ds.setInitialPoolSize(5);// 初始化连接数

ds.setMaxPoolSize(8);//最大连接数

ds.setCheckoutTimeout(3000);//最大等待时间

//4.获取连接

for(int i=1;i<=9;i++){

Connection conn = ds.getConnection();

System.out.println(conn);

if(i==5){

/**

* 把连接对象放回连接池

*/

conn.close();

}

}

} catch (Exception e) {

e.printStackTrace();

}

}

/**

* 使用配置文件方式读取参数信息

* 注意： c3p0会默认查询类路径的c3p0-config.xml文件，文件名不能错！！

*/

@Test

public void test2(){

try {

//1.创建连接池对象（方式一： 使用默认配置（default-config））

//ComboPooledDataSource ds = new ComboPooledDataSource();

//2.创建连接池对象（方式二： 使用命名配置（named-config：mysql_day18））

ComboPooledDataSource ds = new ComboPooledDataSource("mysql_day18");

//2.获取连接

for(int i=1;i<=9;i++){

Connection conn = ds.getConnection();

System.out.println(conn);

if(i==5){

/**

* 把连接对象放回连接池

*/

conn.close();

}

}

} catch (SQLException e) {

e.printStackTrace();

}

}

}

/**

* jdbc的工具方法

* @author APPle

*/

public class DBUtil {

private static ComboPooledDataSource ds = new ComboPooledDataSource();

/**

* 通用的更新方法

* 不同更新操作的不同点：

* 1）sql语句不同

* 2）参数列表不同

*/

public static void update(String sql,Object[] values){

Connection conn = null;

PreparedStatement stmt = null;

try {

//获取连接

conn = ds.getConnection();

//预编译sql

stmt = conn.prepareStatement(sql);

//设置参数

ParameterMetaData md = stmt.getParameterMetaData();

//得到参数数量

int count = md.getParameterCount();

if(values!=null){

for(int i=1;i<=count;i++){

stmt.setObject(i, values[i-1]);

}

}

//执行sql

stmt.executeUpdate();

} catch (SQLException e) {

e.printStackTrace();

throw new RuntimeException(e);

} finally{

if(stmt!=null)

try {

stmt.close();

} catch (SQLException e) {

e.printStackTrace();

throw new RuntimeException(e);

}

if(conn!=null)

try {

conn.close();

} catch (SQLException e) {

e.printStackTrace();

throw new RuntimeException(e);

}

}

}

/**

* 通用的查询方法

* 不同点：

* 1）sql语句不同

* 2）参数不同

* 3）List集合中的对象不同

*/

public static List find(String sql,Object[] values,Class clazz){

Connection conn = null;

PreparedStatement stmt = null;

ResultSet rs = null;

List list = new ArrayList();

try {

//获取连接

conn = ds.getConnection();

//预编译sql

stmt = conn.prepareStatement(sql);

//设置参数

ParameterMetaData md = stmt.getParameterMetaData();

int count = md.getParameterCount();

if(values!=null){

for(int i=1;i<=count;i++){

stmt.setObject(i, values[i-1]);

}

}

//执行sql

rs = stmt.executeQuery();

//得到结果集的元数据

ResultSetMetaData rsmd = rs.getMetaData();

//得到列数据

int columnCount = rsmd.getColumnCount();

//遍历结果集

while(rs.next()){

//创建一个javabean对象

Object obj = clazz.newInstance();

//把每行的结果放入javabean对象

//遍历每列

for(int i=1;i<=columnCount;i++){

//得到列名称

String columnName = rsmd.getColumnName(i);

//得到列内容

Object value = rs.getObject(columnName);

//把列内容赋值给javabean

/**

* 约定前提： 数据库表的字段名称和javabean的属性名称保持一致！！！！

*/

BeanUtils.copyProperty(obj, columnName, value);

}

//把javabean放入list集合

list.add(obj);

}

return list;

} catch (Exception e) {

e.printStackTrace();

throw new RuntimeException(e);

} finally{

if(stmt!=null)

try {

stmt.close();

} catch (SQLException e) {

e.printStackTrace();

throw new RuntimeException(e);

}

if(conn!=null)

try {

conn.close();

} catch (SQLException e) {

e.printStackTrace();

throw new RuntimeException(e);

}

}

}

}