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);
}
}
网友评论