当前位置:Gxlcms > 数据库问题 > 数据库连接池

数据库连接池

时间:2021-07-01 10:21:17 帮助过:4人阅读

     //增强 close方法,conn.close()
  在实际开发,发现对象的方法满足不了开发需求时,有三种方式对其进行增强
  1.写一个connecton子类,覆盖close方法,增强close方法
  2.用包装设计模式
  3.用动态代理 aop 面向切面编程

这里不可以用子类的方法来做,因为connection里面封装了很多其他信息,程序中还会用到connection的其他信息,所以如果用子类的方法基本不可能,等同于要重新写jdbc的驱动了。

 

包装设计模式增强close方法步骤:

   1.定义一个类,实现与被增强相同的接口
   2.在类中定义一个变量,记住被增强对象
   3.定义一个构造函数,接收被增强对象
   4.覆盖想增强的方法
   5.对于不想增强的方法,直接调用目标对象(被增强对象)的方法

 

class MyConnection implements Connection{
        private Connection conn;
        public MyConnection(Connection conn){
            this.conn = conn;
        }
        public void close(){
            list.add(this.conn);
        }
        public void clearWarnings() throws SQLException {
            this.conn.clearWarnings();
            
        }

.......

 

最好的解决办法是动态代理。采用拦截技术。AOP,面向切面编程

 

开源数据库连接池:数据库连接池也叫数据源

现在很多WEB服务器(Weblogic, WebSphere, Tomcat)都提供了DataSoruce的实现,即连接池的实现。

通常我们把DataSource的实现,按其英文含义称之为数据源,数据源中都包含了数据库连接池的实现。


也有一些开源组织提供了数据源的独立实现:
  DBCP 数据库连接池
  C3P0 数据库连接池

实际应用时不需要编写连接数据库代码,直接从数据源获得数据库的连接。程序员编程时也应尽量使用这些数据源的实现,以提升程序的数据库访问性能。

TOMCAT内置的连接池就是DBCP,tomcat是Apache的,dbcp也是apache的。

 

 

DBCP数据源:

DBCP 是 Apache 软件基金组织下的开源连接池实现,使用DBCP数据源,应用程序应在系统中增加如下两个 jar 文件:

  Commons-dbcp.jar:连接池的实现

  Commons-pool.jar:连接池实现的依赖库

Tomcat 的连接池正是采用该连接池来实现的。该数据库连接池既可以与应用服务器整合使用,也可由应用程序独立使用。

 

dbcpconfig.properties封装了DBCP数据源的一些配置信息,包括数据库连接,连接数等。
一般放在src文件夹下
public class JdbcUtils_DBCP {
    
    private static DataSource ds = null;
    static{
        try{
            InputStream in = JdbcUtils_DBCP.class.getClassLoader().getResourceAsStream("dbcpconfig.properties");
            Properties prop = new Properties();
            prop.load(in);
            
            BasicDataSourceFactory factory = new BasicDataSourceFactory();
            ds = factory.createDataSource(prop);
        }catch (Exception e) {
            throw new ExceptionInInitializerError(e);
        }
    }

    public static Connection getConnection() throws SQLException{
        return ds.getConnection();//从连接池中拿连接,这个连接肯定也是增强过的,因为该连接用完还要还给连接池。
    }
    
    
    public static void release(Connection conn,Statement st,ResultSet rs){
        
        if(rs!=null){
            try{
                rs.close();   //throw new 
            }catch (Exception e) {
                e.printStackTrace();
            }
            rs = null;
        }
        if(st!=null){
            try{
                st.close();
            }catch (Exception e) {
                e.printStackTrace();
            }
            st = null;
        }
        if(conn!=null){
            try{
                conn.close();
            }catch (Exception e) {
                e.printStackTrace();
            }
        }
        
        
    }
}    

在开发中可以通过上面的连接池来获取连接,释放连接。

 

 

C3P0数据源:Spring内置的连接池就是C3P0

导入C3P0的两个jar包

  c3p0.....jar

  mchang-commons.jar

c3p0-config.xml 连接池的配置文件,一般放在src目录下,详情查看c3p0的文档

 

<?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/day16</property>
        <property name="user">root</property>
        <property name="password">root</property>
        
        <property name="acquireIncrement">5</property>
        <property name="initialPoolSize">10</property>
        <property name="minPoolSize">5</property>
        <property name="maxPoolSize">20</property>
        
        
    </default-config>

    <named-config name="flx">
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/day16</property>
        <property name="user">root</property>
        <property name="password">root</property>
        <property name="acquireIncrement">5</property>
        <property name="initialPoolSize">10</property>
        <property name="minPoolSize">5</property>
        <property name="maxPoolSize">20</property>
    </named-config>

</c3p0-config>

 

public class JdbcUtils_C3P0 {
    
    private static ComboPooledDataSource ds = null;
    static{
        try{
            ds = new ComboPooledDataSource();
        }catch (Exception e) {
            throw new ExceptionInInitializerError(e);
        }
    }

    public static Connection getConnection() throws SQLException{
        return ds.getConnection();
    }
    
    
    public static void release(Connection conn,Statement st,ResultSet rs){
        
        if(rs!=null){
            try{
                rs.close();   //throw new 
            }catch (Exception e) {
                e.printStackTrace();
            }
            rs = null;
        }
        if(st!=null){
            try{
                st.close();
            }catch (Exception e) {
                e.printStackTrace();
            }
            st = null;
        }
        if(conn!=null){
            try{
                conn.close();
            }catch (Exception e) {
                e.printStackTrace();
            }
        }
        
        
    }
}    

 

 

配置TOMCAT数据库连接池:

使用tomcat的时候,可以不必要加入第三方连接池,tomcat内置了一个连接池, 如果希望tomcat

为你的应用程序创建连接池,需要对tomcat做配置。

<Context>
  <Resource name="jdbc/datasource" auth="Container"
            type="javax.sql.DataSource" username="root" password="root"
            driverClassName="com.mysql.jdbc.Driver" 
           url="jdbc:mysql://localhost:3306/jdbc"
            maxActive="8" maxIdle="4"/>
</Context>

只要对tomcat做了上面的配置,tomcat启动的时候就会为你的应用程序创建连接池,并且tomcat会把创建的连接池以JNDI的形式绑定到一个uri上面去,

name="jdbc/datasource",只要用的时候使用这个名称在JNDI中检索就可以啦。

以上配置可以在tomcat-config里的server.xml里

也可以在WebRoot-META-INF文件夹下新建一个context.xml里配置

可以参考tomcat的主页里的JNDI-COnfigration

 

在程序中就可以使用JNDI的方式去向连接池要连接了。

 

Context initCtx = new InitialContext();
Context envCtx = (Context) initCtx.lookup("java:comp/env");
dataSource = (DataSource)envCtx.lookup("jdbc/datasource");

特别提醒:此种配置下,驱动jar文件需放置在tomcat的lib下

 

JNDI(Java Naming and Directory Interface),Java命名和目录接口,它对应于J2SE中的javax.naming包,

这套API的主要作用在于:它可以把Java对象放在一个容器中(JNDI容器),并为容器中的java对象取一个名称,以后程序想获得Java对象,只需通过名称检索即可。

其核心API为Context,它代表JNDI容器,其lookup方法为检索容器中对应名称的对象。

 

public class JdbcUtils_Tomcat {
    private static DataSource ds;
    static {
        try {
            Context initCtx = new InitialContext();
            Context envCtx = (Context) initCtx.lookup("java:comp/env");
            ds = (DataSource) envCtx.lookup("jdbc/EmployeeDB");
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }
    public static Connection getConnection() throws SQLException{
        return ds.getConnection();
    }
}

在程序中就可以使用上面的工具类来向tomcat内置的数据源要连接。

 

数据库连接池

标签:

人气教程排行