美文网首页
数据库连接池

数据库连接池

作者: 打死你的小乌龟 | 来源:发表于2018-09-07 18:26 被阅读0次

DataSource接口
为了获取数据库连接对象(Connection)JDBC提供了javax.sql.DataSource接口,他负责与数据库建立连接 并定义了返回值为Connection对象方法
Connection getConnection();
Connection getConnection(String username, String password);
实现了javax.sql.DataSource接口的类称为数据源(数据的来源)
DBCP数据源
DBCP是数据库连接池(DataBase Connection Pool)
单独使用JDBC数据源时需要在应用程序中导入两个jar包
1.commons-dbcp.jar
是数据源的实现包,包含所有操作数据库连接信息和数据库链接库初始化信息的方法,实现了DataSource接口的 getConnection()方法
包含两个核心类
BasicDataSourceFactory
BasicDataSource
都包含获取DBCP的数据源对象的方法
2.commons-pool.jar
数据库连接池的实现包的依赖包为.commons-dbcp.jar包中的方法提供了支持

1、DBCP:
Apache组织开发的。DBCP:DataBase Connection Pool,对数据源的一种实现。
a、拷贝jar包
b、编写配置文件
c、使用即可

2、C3P0:
开源数据源的实现。
a、拷贝jar包
b、编写配置文件
c、使用即可



driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/test
username=root
password=222222


initialSize=10

maxActive=50

maxIdle=20

minIdle=5

maxWait=60000


connectionProperties=useUnicode=true;characterEncoding=utf8

defaultAutoCommit=true

defaultReadOnly=

defaultTransactionIsolation=REPEATABLE_READ
package com.itheima.util;

import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Properties;

import javax.sql.DataSource;

import org.apache.commons.dbcp.BasicDataSourceFactory;

public class DBCPUtil {
    private static DataSource dataSource;
    static{
        try {
            InputStream in = DBCPUtil.class.getClassLoader().getResourceAsStream("dbcpconfig.properties");
            Properties props = new Properties();
            props.load(in);
            dataSource = BasicDataSourceFactory.createDataSource(props);
        } catch (Exception e) {
            throw new ExceptionInInitializerError(e);
        }
    }
    
    public static DataSource getDataSource(){
        return dataSource;
    }
    
    public static Connection getConnection(){
        try {
            return dataSource.getConnection();
        } catch (SQLException e) {
            throw new RuntimeException(e);
        }
    }
}

c3p0

是目前最流行的开源数据库连接池之一
他实现了DataSource数据源接口
DataSource接口的实现类ComboPoolDataSource它是C3P0的核心类
1.通过ComboPoolDataSource类直接创建数据源对象


2.通过读取配置文件接创建数据源对象c3p0-config.xml

<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config>
    <default-config>
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql:///test</property>
        <property name="user">root</property>
        <property name="password">sorry</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="day15">
        <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>
    </named-config>
</c3p0-config>
public class C3P0Util {
    private static ComboPooledDataSource dataSource = new ComboPooledDataSource();
    
    public static DataSource getDataSource(){
        return dataSource;
    }
    
    public static Connection getConnection(){
        try {
            return dataSource.getConnection();
        } catch (SQLException e) {
            throw new RuntimeException(e);
        }
    }
}
JNDI
数据库元信息的获取
//数据库元信息的获取
public class Demo {
    //数据库本身信息的获取
    @Test
    public void test1() throws Exception{
        Connection conn = DBCPUtil.getConnection();
        DatabaseMetaData dmd = conn.getMetaData();
        String name = dmd.getDatabaseProductName();//能知道说什么方言
        System.out.println(name);
        int isolation = dmd.getDefaultTransactionIsolation();
        System.out.println(isolation);
    }
    //参数元数据信息:PreparedStatement时
    @Test
    public void test2() throws Exception{
        Connection conn = DBCPUtil.getConnection();
        PreparedStatement stmt = conn.prepareStatement("??????????");
        
        ParameterMetaData pmd = stmt.getParameterMetaData();
        int count = pmd.getParameterCount();
        System.out.println(count);//统计语句中的占位符个数
    }
    //结果集元数据信息:
    @Test
    public void test3()throws Exception{
        Connection conn = DBCPUtil.getConnection();
        PreparedStatement stmt = conn.prepareStatement("select * from account");
        ResultSet rs = stmt.executeQuery();
        ResultSetMetaData rsmd = rs.getMetaData();
        int count = rsmd.getColumnCount();//有几列
        System.out.println(count);
        
        for(int i=0;i<count;i++){
            String fieldName = rsmd.getColumnName(i+1);
            int type = rsmd.getColumnType(i+1);
            System.out.println(fieldName+":"+type);
        }
    }

相关文章

网友评论

      本文标题:数据库连接池

      本文链接:https://www.haomeiwen.com/subject/lkzcgftx.html