介绍

  C3P0是一个开源的JDBC连接池,它实现了数据源和JNDI绑定,支持JDBC3规范和JDBC2的标准扩展。目前使用它的开源项目有Hibernate,Spring等

XML文件配置

  配置文件名称:c3p0-config.xml(固定)
  配置文件位置:src下(类路径)
  配置文件内容:命名配置

  c3p0-config.xml示例:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config>

<default-config>
<property name="driverClass">com.mysql.jdbc.Driver</property>
<property name="jdbcUrl">jdbc:mysql://localhost:3306/java</property>
<property name="user">root</property>
<property name="password">root</property>
<property name="initialPoolSize">5</property>
<property name="maxPoolSize">20</property>
</default-config>

<named-config name="zidingyimingcheng">
<property name="driverClass">com.mysql.jdbc.Driver</property>
<property name="jdbcUrl">jdbc:mysql://localhost:3306/java</property>
<property name="user">root</property>
<property name="password">root</property>
</named-config>


</c3p0-config>

comboPooledDataSource对象读取配置文件

  1. 获取comboPooledDataSource对象
    ComboPooledDataSource combo = new ComboPooledDataSource();   
    或者 ComboPooledDataSource combo = new ComboPooledDataSource(“zidingyimingcheng”);
  2. 获取连接
    Connection conn = combo.getConnection();
  3. 编写SQL
    String sql = “select * from user where id=?”;
  4. 获取到执行sql的对象
    PreparedStatement prep = conn.prepareStatement(sql);
  5. 为sql语句添加参数
    prep.setInt(1, 1);
  6. 执行sql语句
    ResultSet re = prep.executeQuery();

简单代码示例

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
package com.rexyan.c3p0;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

import org.junit.Test;

import com.mchange.v2.c3p0.ComboPooledDataSource;

public class C3P0Test {
@Test
public void JDBC_POOL_C3P0(){
try {
//加载c3p0-config.xml配置文件,实例化可以加名称,不加名称则加载默认配置
ComboPooledDataSource combo = new ComboPooledDataSource("zidingyimingcheng");
//根据配置文件的信息,连接数据库
Connection conn = combo.getConnection();
//书写sql语句
String sql = "select * from user where id=?";
//获取到执行sql的对象
PreparedStatement prep = conn.prepareStatement(sql);
//为sql语句添加参数
prep.setInt(1, 1);
//执行sql语句
ResultSet re = prep.executeQuery();
System.out.println(re.next());

} catch (Exception e) {
throw new RuntimeException(e);
}
}
}

进行封装

工具类

  如果每次操作都需要写代码来建立数据的连接的释放连接的话,那么开发的速度和效率会很低。这时我们应该考虑将数据的连接和释放进行封装。这样就不必每次都编写连接和释放的代码了,只需调用已经编写好的即可。

普通的抽取

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
public class ToolsV1 {
/**
* 公共连接数据库
* @return Connection
*/
public static Connection Conn(){
Connection conn = null;
try {
// 1,注册驱动
Class.forName("com.mysql.jdbc.Driver");
// 2,获取Connection连接
conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/java", "root", "root");
} catch (Exception e) {
e.printStackTrace();
}
//3,返回获取到的连接
return conn;
}

/**
* 公共释放数据库连接
*/
public static void release(Connection conn, PreparedStatement prep, ResultSet re){
try {
if (re!=null){re.close();}
if (prep!=null){prep.close();}
if (conn!=null){conn.close();}
} catch (Exception e) {
e.printStackTrace();
}
}
}

使用配置文件

使用ResourceBundle

编写配置文件

 在src下新建db.propertie文件,【注意文件后缀要为.propertie的文件】。内容如下:

driver=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/java?useUnicode=true&characterEncoding=utf8
username=root
password=root

具体实现

 具体实现如下:

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
public class ToolsV2 {
/**
* 公共连接数据库
* @return Connection
*/

private static String driver = null;
private static String url = null;
private static String username = null;
private static String password = null;

//静态代码块加载配置文件
static{
//载入配置文件
ResourceBundle bund = ResourceBundle.getBundle("db");
driver = bund.getString("driver");
url = bund.getString("url");
username = bund.getString("username");
password = bund.getString("password");
}

public static Connection Conn(){
Connection conn = null;

try {
// 注册驱动
Class.forName(driver);
// 获取Connection连接
conn = DriverManager.getConnection(url, username, password);
} catch (Exception e) {
e.printStackTrace();
}
//返回获取到的连接
return conn;
}

/**
* 公共释放数据库连接
*/
public static void release(Connection conn, PreparedStatement prep, ResultSet re){
try {
if (re!=null){re.close();}
if (prep!=null){prep.close();}
if (conn!=null){conn.close();}
} catch (Exception e) {
e.printStackTrace();
}
}
}

使用Properties文件流

编写配置文件

 在src下新建db.propertie文件,【注意文件后缀要为.propertie的文件】。内容如下:

driver=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/java?useUnicode=true&characterEncoding=utf8
username=root
password=root

具体实现

 具体实现如下:

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
public class ToolsV3 {
/**
* 公共连接数据库
* @return Connection
*/

private static String driver = null;
private static String url = null;
private static String username = null;
private static String password = null;

//静态代码块加载配置文件
static{
//通过类加载器
try {
//获取当前类的类加载器
ClassLoader classLoader = ToolsV3.class.getClassLoader();
//通过类加载器的方法获取到一个输入流
InputStream is = classLoader.getResourceAsStream("db.properties");
//实例化一个Properties对象
Properties pro = new Properties();
//加载一个输入流
pro.load(is);
//获取相关参数的值
driver = pro.getProperty("driver");
url = pro.getProperty("url");
username = pro.getProperty("username");
password = pro.getProperty("password");
} catch (Exception e) {
e.printStackTrace();
}
}

public static Connection Conn(){
Connection conn = null;

try {
// 注册驱动
Class.forName(driver);
// 获取Connection连接
conn = DriverManager.getConnection(url, username, password);
} catch (Exception e) {
e.printStackTrace();
}
//返回获取到的连接
return conn;
}

/**
* 公共释放数据库连接
*/
public static void release(Connection conn, PreparedStatement prep, ResultSet re){
try {
if (re!=null){re.close();}
if (prep!=null){prep.close();}
if (conn!=null){conn.close();}
} catch (Exception e) {
e.printStackTrace();
}
}
}

调用

 将其中的ToolsV3根据情况具体对应调用就行。例如,使用普通抽取就使用ToolsV1,使用ResourceBundle就调用ToolsV2

具体实现
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
public class JDBC_Tools_Test {
@Test
public void JDBC_Test(){
Connection conn = null;
PreparedStatement prep = null;
ResultSet result = null;
try {
//1,调用刚刚写好的工具类,获取连接
conn = ToolsV3.Conn();
//2,编写SQL模版
prep = conn.prepareStatement("select * from user where id=?");
//3,为sql赋值
prep.setInt(1, 1);
//4,执行sql
result = prep.executeQuery();
if (result.next()){
System.out.println(result.getString(1));
}
//5,获取结果集
} catch (SQLException e) {
e.printStackTrace();
}finally{
ToolsV3.release(conn, prep, result);
}


}
}

PreparedStatement

  使用Connection的prepareStatement(String sql):即创建它时就让它与一条SQL模板绑定;调用PreparedStatement的setXXX()系列方法为问号设置值调用executeUpdate()或executeQuery()方法,但要注意,调用没有参数的方法;
  在使用Connection创建PreparedStatement对象时需要给出一个SQL模板,所谓SQL模板就是有“?”的SQL语句,其中“?”就是参数。

阅读全文 »