欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

数据库连接池工具的分析

程序员文章站 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;

    }