数据库连接池工具的分析
程序员文章站
2022-06-07 08:33:52
...
两种开源的数据库连接池
JDBC 的数据库连接池使用 javax.sql.DataSource 来表示,DataSource 只是一个接口,该接口通常由服务器(Weblogic, WebSphere, Tomcat)提供实现,也有一些开源组织提供实现:
DBCP 数据库连接池
C3P0 数据库连接池
DataSource 通常被称为数据源,它包含连接池和连接池管理两个部分,习惯上也经常把 DataSource 称为连接池
DBCP 数据源
DBCP 是 Apache 软件基金组织下的开源连接池实现,该连接池依赖该组织下的另一个开源系统:Common-pool. 如需使用该连接池实现,应在系统中增加如下两个 jar 文件:
Commons-dbcp.jar:连接池的实现
Commons-pool.jar:连接池实现的依赖库
使用cbcp数据源,当数据库访问结束后,程序还是像以前一样关闭数据库连接:conn.close(); 但上面的代码并没有关闭数据库的物理连接,它仅仅把数据库连接释放,归还给了数据库连接池。
具体的使用代码例子如下:
所有数据库连接在一个xml文件中配置,文件内容如下
username=root
password=1234
#初始化连接
initialSize=10
#最大连接数量
maxActive=50
#最大空闲连接
maxIdle=20
#最小空闲连接
minIdle=5
#超时等待时间以毫秒为单位 6000毫秒/1000等于60秒
maxWait=60000
#指定由连接池所创建的连接的自动提交(auto-commit)状态。
defaultAutoCommit=true
#JDBC驱动建立连接时附带的连接属性属性的格式必须为这样:[属性名=property;]
#注意:"user" 与 "password" 两个属性会被明确地传递,因此这里不需要包含他们。
connectionProperties=useUnicode=true;characterEncoding=gbk
#driver default 指定由连接池所创建的连接的只读(read-only)状态。
#如果没有设置该值,则“setReadOnly”方法将不被调用。(某些驱动并不支持只读模式,如:Informix)
defaultReadOnly=
#driver default 指定由连接池所创建的连接的事务级别(TransactionIsolation)。
#可用值为下列之一:(详情可见javadoc。)NONE,READ_UNCOMMITTED, READ_COMMITTED, REPEATABLE_READ, SERIALIZABLE
defaultTransactionIsolation=READ_COMMITTED
而具体获得连接的代码:
Properties props = new Properties();
从上面的xml文档中读取数据库连接需要的各种数据props.load(TestDBCP.class.getClassLoader().getResourceAsStream("dbcpconfig.properties"));
获得DataSource对象
DataSource ds = BasicDataSourceFactory.createDataSource(props);
从数据库连接池中获得连接
Connection conn = ds.getConnection();
并没有关闭数据库的物理连接,它仅仅把数据库连接释放,归还给了数据库连接池。
conn.close();
使用c3p0数据源
首先,加载“c3p0-0.9.1.2.jar”
然后具体的使用代码示范如下:
ComboPooledDataSource cpds = new ComboPooledDataSource();
cpds.setUser("root");
cpds.setPassword("123");
cpds.setJdbcUrl("jdbc:mysql://localhost:3306/test");
cpds.setDriverClass("com.mysql.jdbc.Driver");
//设置初始化连接数
cpds.setInitialPoolSize(10);
//最大连接数量
cpds.setMaxPoolSize(50);
//最小连接
cpds.setMinPoolSize(20);
//超时等待时间以毫秒为单位 6000毫秒/1000等于60秒
cpds.setMaxIdleTime(60000);
Connection conn = cpds.getConnection();
Tomcat数据库连接池的配置
DataSource对象可由容器(Tomcat)提供,不能使用创建实例的方法来生成DataSource对象,要采用JAVA的JNDI。
JNDI(Java Naming and Directory Interface,Java命名和目录接口)是一些标准API接口,Java程序通过这些API可以访问命名目录服务。而命名目录服务将名称和对象联系起来,使得可以用名称访问对象。
JNDI的定义不依赖于任何独立的命名目录服务器,对于各种命名目录服务器,都可通过统一的JNDI接口调用。
JNDI在系统运行时会在内存中构建这个一个层次结构。通过程序访问到这个JNDI管理器的InitialContext对象就拥有了这个JNDI的上下文,就可以查找要用的对象,并使用它
JNDI接口概述
Context:javax.naming的核心接口,指定了命名上下文。定义了基本的操作,例如添加一个名称-对象的绑定,查找绑定到特定名称的对象,显示绑定列表,移除名称-对象绑定,创建或者销毁相同类型的上下文等
//从服务器上连接
Context ctx=new InitialContext()
Context.lookup():检索指定的对象
为了使用JNDI,需要实现做两个工作
1.写context.xml文档,并放置到META-INF目下
2.在tomcat服务器的lib目录下复制上数据库驱动的jar包
<?xml version="1.0" encoding="UTF-8"?>
<Context>
<Resource
指定Resource的JNDI的名字
name="testdatasource"
Container:表示由容器来负责创建和管理 Application:表示由web应用来创建和管理
auth="Container"
type="javax.sql.DataSource"
maxActive="100"
maxIdle="30"
maxWait="10000"
username="root"
password="5131"
driverClassName="com.mysql.jdbc.Driver"
url="jdbc:mysql://localhost:3306/itcast"/>
</Context>
Tomcat提供了一个与JavaEE应用服务相兼容的JNDI--InitialContext实现实例(把DataSource作为一种可配置的JNDI资源来处理)。所有的入口和资源都放在JNDI命名空间里的java:comp/env段里。
获得数据库连接的具体代码:(注意,这个时候数据库连接只能通过tomcat服务器来获取,所以这些代码只能写在tomcat可以访问到的部分,比如jsp页面或者servlet)
Context context = new InitialContext();
后面红色部分要和context.xml中配置的“name”属性一致
DataSource ds =(DataSource)context.lookup("java:comp/env/testdatasource");
Org.apache.commons.dbutils的使用
先解释一段代码:
import org.apache.commons.dbutils.QueryRunner;
QueryRunner run = new QueryRunner();
list = (List) run.query(conn, sql, new BeanListHandler(clazz));
这里的run.query(conn, sql, new BeanListHandler(clazz))就可以返回一个查询对象的list,其中的“new BeanListHandler(clazz)”是一个实现了ResultSetHandler接口的对象。其中传入的clazz对象是需要被放入List的实体对象的JavaBean对象。比如下面的使用方法
//param 1: 数据库连接
// 2: 查询数据库用的 sql
// 3: 替换 sql 中的参数数组
// 4: 如何处理得到的结果集
List list = (List) run.query(conn, sql, params, new BeanListHandler(Customer.class));
最后得到的List就是一个Customer对象集合,dbutils会自动把查询到的结果放置到Customer类的对象中。
关于ResultSetHandler接口,前面看到的 BeanListHandler(Customer.class)实际上就是实现了这个接口,在这个接口内部只有一个方法:
public Object handle(ResultSet rs) throws SQLException
可以看到,这个方法中传入的参数就是执行sql后的结果集合,而我们用的这个BeanListHandler类其实就是实现了这个方法,拿到处理的结果集以后,根据传入的javaBean的class对象利用内省把查询到的数据放置到这个javabean的对象中。
作为示范,我们自己实现一个
//使用自定义的 ResultSetHandler 对象
list = (List) run.query(conn, sql, params,
自定义一个实现ResultSetHandler接口的匿名对象
new ResultSetHandler(){
实现接口中的方法,获得结果集中的数据,自己装入对象并装入list中。
public Object handle(ResultSet rs) throws SQLException {
List list = new ArrayList();
while(rs.next()){
int id = rs.getInt(1);
String name = rs.getString(2);
String address = rs.getString(3);
String phone = rs.getString(4);
Customer cust = new Customer();
cust.setAddress(address);
cust.setId1(id);
cust.setName(name);
cust.setPhone(phone);
list.add(cust);
}
return list;
}
});
利用Org.apache.commons.dbutils中的方法,我们可以非常方便的进行JDBC的操作。
比如
下面代码可以执行所有的数据修改操作,只需要传入sql和参数,还有connection就可以了
public void update(Connection conn, String sql, Object [] params, String exceptionMsg){
QueryRunner run = new QueryRunner();
try {
run.update(conn, sql, params);
} catch (SQLException e) {
e.printStackTrace();
throw new RuntimeException(exceptionMsg);
}
}
public Object getObject(Connection conn, String sql, Object [] prams, Class clazz, String exceptionMsg){
List list = null;
QueryRunner run = new QueryRunner();
try {
list = (List) run.query(conn, sql, prams, new BeanListHandler(clazz));
} catch (SQLException e) {
e.printStackTrace();
throw new RuntimeException(exceptionMsg);
}
if(list != null)
return list.get(0);
else
return null;
}
public List getConditionObjects(Connection conn, String sql, Object [] prams, Class clazz, String exceptionMsg){
List list = null;
QueryRunner run = new QueryRunner();
try {
list = (List) run.query(conn, sql, prams, new BeanListHandler(clazz));
} catch (SQLException e) {
e.printStackTrace();
throw new RuntimeException(exceptionMsg);
}
return list;
}
JDBC 的数据库连接池使用 javax.sql.DataSource 来表示,DataSource 只是一个接口,该接口通常由服务器(Weblogic, WebSphere, Tomcat)提供实现,也有一些开源组织提供实现:
DBCP 数据库连接池
C3P0 数据库连接池
DataSource 通常被称为数据源,它包含连接池和连接池管理两个部分,习惯上也经常把 DataSource 称为连接池
DBCP 数据源
DBCP 是 Apache 软件基金组织下的开源连接池实现,该连接池依赖该组织下的另一个开源系统:Common-pool. 如需使用该连接池实现,应在系统中增加如下两个 jar 文件:
Commons-dbcp.jar:连接池的实现
Commons-pool.jar:连接池实现的依赖库
使用cbcp数据源,当数据库访问结束后,程序还是像以前一样关闭数据库连接:conn.close(); 但上面的代码并没有关闭数据库的物理连接,它仅仅把数据库连接释放,归还给了数据库连接池。
具体的使用代码例子如下:
所有数据库连接在一个xml文件中配置,文件内容如下
username=root
password=1234
#初始化连接
initialSize=10
#最大连接数量
maxActive=50
#最大空闲连接
maxIdle=20
#最小空闲连接
minIdle=5
#超时等待时间以毫秒为单位 6000毫秒/1000等于60秒
maxWait=60000
#指定由连接池所创建的连接的自动提交(auto-commit)状态。
defaultAutoCommit=true
#JDBC驱动建立连接时附带的连接属性属性的格式必须为这样:[属性名=property;]
#注意:"user" 与 "password" 两个属性会被明确地传递,因此这里不需要包含他们。
connectionProperties=useUnicode=true;characterEncoding=gbk
#driver default 指定由连接池所创建的连接的只读(read-only)状态。
#如果没有设置该值,则“setReadOnly”方法将不被调用。(某些驱动并不支持只读模式,如:Informix)
defaultReadOnly=
#driver default 指定由连接池所创建的连接的事务级别(TransactionIsolation)。
#可用值为下列之一:(详情可见javadoc。)NONE,READ_UNCOMMITTED, READ_COMMITTED, REPEATABLE_READ, SERIALIZABLE
defaultTransactionIsolation=READ_COMMITTED
而具体获得连接的代码:
Properties props = new Properties();
从上面的xml文档中读取数据库连接需要的各种数据props.load(TestDBCP.class.getClassLoader().getResourceAsStream("dbcpconfig.properties"));
获得DataSource对象
DataSource ds = BasicDataSourceFactory.createDataSource(props);
从数据库连接池中获得连接
Connection conn = ds.getConnection();
并没有关闭数据库的物理连接,它仅仅把数据库连接释放,归还给了数据库连接池。
conn.close();
使用c3p0数据源
首先,加载“c3p0-0.9.1.2.jar”
然后具体的使用代码示范如下:
ComboPooledDataSource cpds = new ComboPooledDataSource();
cpds.setUser("root");
cpds.setPassword("123");
cpds.setJdbcUrl("jdbc:mysql://localhost:3306/test");
cpds.setDriverClass("com.mysql.jdbc.Driver");
//设置初始化连接数
cpds.setInitialPoolSize(10);
//最大连接数量
cpds.setMaxPoolSize(50);
//最小连接
cpds.setMinPoolSize(20);
//超时等待时间以毫秒为单位 6000毫秒/1000等于60秒
cpds.setMaxIdleTime(60000);
Connection conn = cpds.getConnection();
Tomcat数据库连接池的配置
DataSource对象可由容器(Tomcat)提供,不能使用创建实例的方法来生成DataSource对象,要采用JAVA的JNDI。
JNDI(Java Naming and Directory Interface,Java命名和目录接口)是一些标准API接口,Java程序通过这些API可以访问命名目录服务。而命名目录服务将名称和对象联系起来,使得可以用名称访问对象。
JNDI的定义不依赖于任何独立的命名目录服务器,对于各种命名目录服务器,都可通过统一的JNDI接口调用。
JNDI在系统运行时会在内存中构建这个一个层次结构。通过程序访问到这个JNDI管理器的InitialContext对象就拥有了这个JNDI的上下文,就可以查找要用的对象,并使用它
JNDI接口概述
Context:javax.naming的核心接口,指定了命名上下文。定义了基本的操作,例如添加一个名称-对象的绑定,查找绑定到特定名称的对象,显示绑定列表,移除名称-对象绑定,创建或者销毁相同类型的上下文等
//从服务器上连接
Context ctx=new InitialContext()
Context.lookup():检索指定的对象
为了使用JNDI,需要实现做两个工作
1.写context.xml文档,并放置到META-INF目下
2.在tomcat服务器的lib目录下复制上数据库驱动的jar包
<?xml version="1.0" encoding="UTF-8"?>
<Context>
<Resource
指定Resource的JNDI的名字
name="testdatasource"
Container:表示由容器来负责创建和管理 Application:表示由web应用来创建和管理
auth="Container"
type="javax.sql.DataSource"
maxActive="100"
maxIdle="30"
maxWait="10000"
username="root"
password="5131"
driverClassName="com.mysql.jdbc.Driver"
url="jdbc:mysql://localhost:3306/itcast"/>
</Context>
Tomcat提供了一个与JavaEE应用服务相兼容的JNDI--InitialContext实现实例(把DataSource作为一种可配置的JNDI资源来处理)。所有的入口和资源都放在JNDI命名空间里的java:comp/env段里。
获得数据库连接的具体代码:(注意,这个时候数据库连接只能通过tomcat服务器来获取,所以这些代码只能写在tomcat可以访问到的部分,比如jsp页面或者servlet)
Context context = new InitialContext();
后面红色部分要和context.xml中配置的“name”属性一致
DataSource ds =(DataSource)context.lookup("java:comp/env/testdatasource");
Org.apache.commons.dbutils的使用
先解释一段代码:
import org.apache.commons.dbutils.QueryRunner;
QueryRunner run = new QueryRunner();
list = (List) run.query(conn, sql, new BeanListHandler(clazz));
这里的run.query(conn, sql, new BeanListHandler(clazz))就可以返回一个查询对象的list,其中的“new BeanListHandler(clazz)”是一个实现了ResultSetHandler接口的对象。其中传入的clazz对象是需要被放入List的实体对象的JavaBean对象。比如下面的使用方法
//param 1: 数据库连接
// 2: 查询数据库用的 sql
// 3: 替换 sql 中的参数数组
// 4: 如何处理得到的结果集
List list = (List) run.query(conn, sql, params, new BeanListHandler(Customer.class));
最后得到的List就是一个Customer对象集合,dbutils会自动把查询到的结果放置到Customer类的对象中。
关于ResultSetHandler接口,前面看到的 BeanListHandler(Customer.class)实际上就是实现了这个接口,在这个接口内部只有一个方法:
public Object handle(ResultSet rs) throws SQLException
可以看到,这个方法中传入的参数就是执行sql后的结果集合,而我们用的这个BeanListHandler类其实就是实现了这个方法,拿到处理的结果集以后,根据传入的javaBean的class对象利用内省把查询到的数据放置到这个javabean的对象中。
作为示范,我们自己实现一个
//使用自定义的 ResultSetHandler 对象
list = (List) run.query(conn, sql, params,
自定义一个实现ResultSetHandler接口的匿名对象
new ResultSetHandler(){
实现接口中的方法,获得结果集中的数据,自己装入对象并装入list中。
public Object handle(ResultSet rs) throws SQLException {
List list = new ArrayList();
while(rs.next()){
int id = rs.getInt(1);
String name = rs.getString(2);
String address = rs.getString(3);
String phone = rs.getString(4);
Customer cust = new Customer();
cust.setAddress(address);
cust.setId1(id);
cust.setName(name);
cust.setPhone(phone);
list.add(cust);
}
return list;
}
});
利用Org.apache.commons.dbutils中的方法,我们可以非常方便的进行JDBC的操作。
比如
下面代码可以执行所有的数据修改操作,只需要传入sql和参数,还有connection就可以了
public void update(Connection conn, String sql, Object [] params, String exceptionMsg){
QueryRunner run = new QueryRunner();
try {
run.update(conn, sql, params);
} catch (SQLException e) {
e.printStackTrace();
throw new RuntimeException(exceptionMsg);
}
}
public Object getObject(Connection conn, String sql, Object [] prams, Class clazz, String exceptionMsg){
List list = null;
QueryRunner run = new QueryRunner();
try {
list = (List) run.query(conn, sql, prams, new BeanListHandler(clazz));
} catch (SQLException e) {
e.printStackTrace();
throw new RuntimeException(exceptionMsg);
}
if(list != null)
return list.get(0);
else
return null;
}
public List getConditionObjects(Connection conn, String sql, Object [] prams, Class clazz, String exceptionMsg){
List list = null;
QueryRunner run = new QueryRunner();
try {
list = (List) run.query(conn, sql, prams, new BeanListHandler(clazz));
} catch (SQLException e) {
e.printStackTrace();
throw new RuntimeException(exceptionMsg);
}
return list;
}
上一篇: [插件]使用Gradle打可执行jar包
下一篇: 使用GRADLE给老项目打WAR包