c3p0导包c3p0-0.9.1.2.jar
package cn.pool;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import com.mchange.v2.c3p0.ComboPooledDataSource;
/**
* C3P0连接池 1.导包 2.书写代码
*/
public class C3P0Demo1 {
public static void main(String[] args) throws Exception {
Connection conn = null;
Statement stat = null;
ResultSet rs = null;
ComboPooledDataSource cpds = new ComboPooledDataSource();
/*
* cpds.setDriverClass( "com.mysql.jdbc.Driver" ); //loads the jdbc
* driver cpds.setJdbcUrl( "jdbc:mysql://localhost/db_test" );
* cpds.setUser("root"); cpds.setPassword("root");
*/
try {
conn = cpds.getConnection();
stat = conn.createStatement();
rs = stat.executeQuery("select *from emp");
while (rs.next()) {
int id = rs.getInt(1);
String name = rs.getString(2);
System.out.println(id + ":" + name);
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
if (rs != null) {
try {
rs.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
rs = null;
}
}
if (stat != null) {
try {
stat.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
stat = null;
}
}
}
}
}
c3p0配置文件
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://localhost/db_test</property>
<property name="user">root</property>
<property name="password">root</property>
</default-config>
<!-- This app is massive! -->
</c3p0-config>
dbcp需要导包commons-pool-1.5.6.jar
commons-dbcp-1.4.jar
package cn.pool;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;
import javax.sql.DataSource;
import org.apache.commons.dbcp.BasicDataSource;
import org.apache.commons.dbcp.BasicDataSourceFactory;
/**
* DBCP连接池的使用 1.导包 2.书写代码
*/
public class DBCPDemo01 {
public static void main(String[] args) throws Exception {
Connection conn = null;
Statement stat = null;
ResultSet rs = null;
/*
* BasicDataSource source=new BasicDataSource();
* source.setDriverClassName("com.mysql.jdbc.Driver");
* source.setUrl("jdbc:mysql://localhost:3306/db_test");
* source.setUsername("root"); source.setPassword("root");
*/
// 创建一个数据源的工厂对象
BasicDataSourceFactory factory = new BasicDataSourceFactory();
// 利用工厂对象创建数据源
Properties pro = new Properties();
pro.load(new FileInputStream(
new File(DBCPDemo01.class.getClassLoader().getResource("dbcp.properties").getPath())));
DataSource source = factory.createDataSource(pro);
try {
conn = source.getConnection();
stat = conn.createStatement();
rs = stat.executeQuery("select *from emp");
while (rs.next()) {
int id = rs.getInt(1);
String name = rs.getString(2);
System.out.println(id + ":" + name);
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
if (rs != null) {
try {
rs.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
rs = null;
}
}
if (stat != null) {
try {
stat.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
stat = null;
}
}
}
}
}
配置文件conf.properties
driver=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/db_test
username=root
password=root