一、c3p0的介绍及使用
C3P0是一个开源的JDBC连接池,它实现了数据源和JNDI绑定,支持JDBC3规范和JDBC2的标准扩展。目前使用它的开源项目有Hibernate,Spring等。
牵涉的jar包:c3p0-0.9.1.2.jar、jdbc对应的驱动包(例如mysql的驱动包等)
c3p0的使用
1、导入所需要的jar包:c3p0-0.9.1.2.jar和jdbc对应的驱动包
2、在src下创建配置文件(c3p0-config.xml 或者 c3p0.properties)
其中:c3p0-config.xml为xml配置文件,而c3p0.properties为key/value类型的配置文件
c3p0-config.xml配置文件示例如下:
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 <c3p0-config>
<!-- 默认配置,如果没有指定则使用这个配置 -->
<default-config>
<!-- 基本配置 -->
<property name="driverClass">com.mysql.jdbc.Driver</property>
<property name="jdbcUrl">jdbc:mysql://localhost:3306/数据库名</property>
<property name="user">用户名</property>
<property name="password">密码</property>
<!--扩展配置-->
<property name="checkoutTimeout">30000</property>
<property name="idleConnectionTestPeriod">30</property>
<property name="initialPoolSize">10</property>
<property name="maxIdleTime">30</property>
<property name="maxPoolSize">100</property>
<property name="minPoolSize">10</property>
<property name="maxStatements">200</property>
</default-config>
<!-- 命名的配置 -->
<named-config name="lanting">
<property name="driverClass">com.mysql.jdbc.Driver</property>
<property name="jdbcUrl">jdbc:mysql://localhost:3306/数据库名</property>
<property name="user">用户名</property>
<property name="password">密码</property>
<!-- 如果池中数据连接不够时一次增长多少个 -->
<property name="acquireIncrement">5</property>
<property name="initialPoolSize">20</property>
<property name="minPoolSize">10</property>
<property name="maxPoolSize">40</property>
<property name="maxStatements">20</property>
<property name="maxStatementsPerConnection">5</property>
</named-config>
</c3p0-config>
c3p0.properties和xml配置文件很相似,仅仅是格式改成了1
2
3
4
5```
c3p0.driverClass=com.mysql.jdbc.Driver
c3p0.jdbcUrl=jdbc:mysql://localhost:3306/数据库名
c3p0.user=用户名
c3p0.password=密码
3、创建连接池实例并使用1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19// 使用默认的配置
//ComboPooledDataSource ds = new ComboPooledDataSource();
// 采用指定的带名字的配置(若找不到,使用默认的)
ComboPooledDataSource ds =new ComboPooledDataSource("lanting");
// 获取连接
Connection conn=ds.getConnection();
// sql语句
String sql="insert into category values(?,?);";
// 创建执行器
PreparedStatement st=conn.prepareStatement(sql);
//设置参数
st.setString(1, "c124");
st.setString(2, "解药");
// 执行语句
int i = st.executeUpdate();
System.out.println(i);
// 省略释放资源的代码....
二、DBUtils的使用
是apache组织的一个工具类,jdbc的框架,更方便我们使用。
牵涉到的jar(解压获取):commons-dbutils-1.4-bin.jar
核心类或接口
1、QueryRunner(类)
作用: 操作sql语句
构造器: new QueryRunner(Datasource ds);
【注意: 底层帮我们创建连接,创建语句执行者 ,释放资源. 】
常用方法:
query(..):
update(..):
2、DbUtils(类)
作用: 释放资源,控制事务
closeQuietly(conn):内部处理了异常
commitAndClose(Connection conn):提交事务并释放连接
….
ResultSetHandler:(接口)
作用: 封装结果集
子类:
ArrayHandler, ArrayListHandler, BeanHandler, BeanListHandler, ColumnListHandler, KeyedHandler, MapHandler, MapListHandler, ScalarHandler
(了解)ArrayHandler, 将查询结果的第一条记录封装成数组,返回
(了解)ArrayListHandler, 将查询结果的每一条记录封装成数组,将每一个数组放入list中返回
★★BeanHandler,将查询结果的第一条记录封装成指定的bean对象,返回
★★BeanListHandler, 将查询结果的每一条记录封装成指定的bean对象,将每一个bean对象放入list中 返回.
(了解)ColumnListHandler, 将查询结果的指定一列放入list中返回
(了解)MapHandler, 将查询结果的第一条记录封装成map,字段名作为key,值为value 返回
★MapListHandler, 将查询结果的每一条记录封装map集合,将每一个map集合放入list中返回
★ScalarHandler,针对于聚合函数 例如:count(*) 返回的是一个Long值
更新及插入的实例代码:1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
public class CURDDemo {
// 连接池对象
private static ComboPooledDataSource ds=new ComboPooledDataSource();
public void insert() throws SQLException{
//1.创建queryrunner类
QueryRunner qr = new QueryRunner(ds);
//2.编写sql
String sql="insert into category values(?,?)";
//3.执行sql
qr.update(sql, "c201","厨房电器");
}
public void update() throws SQLException{
QueryRunner qr=new QueryRunner(ds);
String sql="update category set cname = ? where cid = ?";
qr.update(sql, "达电器","c000");
}
}
查询及处理结果集的示例代码: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
81
82
83
84
public class ResultHandleDemo {
// 连接池对象
private static ComboPooledDataSource ds=new ComboPooledDataSource();
public void arrayHandler() throws SQLException{
QueryRunner qr=new QueryRunner(ds);
String sql="select * from category";
Object[] query = qr.query(sql, new ArrayHandler());
System.out.println(Arrays.toString(query));
}
public void arrayListHandler() throws SQLException{
QueryRunner qr=new QueryRunner(ds);
String sql="select * from category";
List<Object[]> list = qr.query(sql, new ArrayListHandler());
for (Object[] obj : list) {
System.out.println(Arrays.toString(obj));
}
}
public void beanHandler() throws SQLException{
QueryRunner qr=new QueryRunner(ds);
String sql="select * from category";
Category bean = qr.query(sql, new BeanHandler<>(Category.class));
System.out.println(bean);
}
public void beanListHandler() throws SQLException{
QueryRunner qr=new QueryRunner(ds);
String sql="select * from category";
List<Category> list = qr.query(sql, new BeanListHandler<>(Category.class));
for (Category bean : list) {
System.out.println(bean);
}
}
public void mapHandler() throws SQLException{
QueryRunner qr=new QueryRunner(ds);
String sql="select * from category";
Map<String, Object> map = qr.query(sql, new MapHandler());
System.out.println(map);
}
public void mapListHandler() throws SQLException{
QueryRunner qr=new QueryRunner(ds);
String sql="select * from category";
List<Map<String, Object>> list = qr.query(sql, new MapListHandler());
for (Map<String, Object> map : list) {
System.out.println(map);
}
}
public void scalarHandler() throws SQLException{
QueryRunner qr=new QueryRunner(ds);
String sql="select count(*) from category";
Object obj = qr.query(sql, new ScalarHandler());
System.out.println(obj.getClass().getName());
}
}