DBCP连接池

DBCP连接池

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
/**
* 所有的连接池必须遵循 javax.sql.DataSource接口
*
* 在DBCP连接池中
* 实现 javax.sql.DataSource接口的实现类是:
* BasicDataSource
* 使用:
* 创建BasicDataSource对象,并且给他设置数据库连接的四大要素即可
* private static BasicDataSource ds = new BasicDataSource();
* //设置数据库连接四大要素
* ds.setDriverClassName(driverName);
* ds.setUrl(url);
* ds.setUsername(username);
* ds.setPassword(password);
* 带有配置文件的DBCP的使用
* 核心类:BasicDataSourceFactory(工厂)
* public static DataSource createDataSource(Properties对象);
*
*
*
*/

public class DBCPUtils {
// private static String driverName = "com.mysql.jdbc.Driver";
// private static String url = "jdbc:mysql://localhost:3306/day04";
// private static String username = "root";
// private static String password = "123";

private static DataSource ds = null;
//静态代码块,设置ds的四大要素
static{
try {
Properties ps = new Properties();

//两种配置方法(建议第二种)
//ps.load(new FileInputStream("D:\\JAVA\\DBCP\\dbcpconfig.properties"));
ps.load(DBCPUtils.class.getClassLoader().getResourceAsStream("dbcpconfig.properties"));

ds = BasicDataSourceFactory.createDataSource(ps);
} catch (Exception e) {
e.printStackTrace();
}
// ds.setDriverClassName(driverName);
// ds.setUrl(url);
// ds.setUsername(username);
// ds.setPassword(password);
}

public static Connection getConnection() throws SQLException {
//返回一个连接对象,不要用DriverManager获取,而是连接池中获取
return ds.getConnection();
}

//关闭所有资源的统一代码
public static void closeAll(Connection conn, Statement st, ResultSet rs){
//负责关闭
if(conn != null){
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(st != null){
try {
st.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(rs != null){
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}

}