加入DBCP连接池
加入dbcp连接池:
1.导入jar包:
commons-dbcp-1.2.1.jar
下载地址:http://pan.baidu.com/s/1bnpIqez
commons-pool-1.2.jar
下载地址:http://pan.baidu.com/s/1qWlUbOK
2.在类目录下添加配置文件
src文件夹中添加dbcpconfig.properties文件
3.在BaseDaoPool的静态代码块中创建池
import javax.sql.DataSource;
import org.apache.commons.dbcp.BasicDataSourceFactory;
private static DataSource ds=null;
static{
InputStream in=BaseDaoPool.class.getClassLoader().
getResourceAsStream("dbcpconfig.properties");
Properties pro=new Properties();
try {
pro.load(in);
BasicDataSourceFactory factory=new BasicDataSourceFactory();
ds=factory.createDataSource(pro);
} catch (Exception e) {
throw new ExceptionInInitializerError(e);
}
}
4.使用连接池获得连接:
public Connection getConnection() throws SQLException{
return ds.getConnection();
}
附:
import java.io.InputStream;
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.BasicDataSourceFactory;
@SuppressWarnings("static-access")
public class BaseDaoPool {
private static DataSource ds=null;
static{
InputStream is=BaseDaoPool.class.getClassLoader().
getResourceAsStream("dbcpconfig.properties");
Properties properties=new Properties();
try {
properties.load(is);
BasicDataSourceFactory factory=new BasicDataSourceFactory();
ds=factory.createDataSource(properties);
} catch (Exception e) {
throw new ExceptionInInitializerError(e);
}
}
public Connection getConnection() throws SQLException{
return ds.getConnection();
}
public void closeAll(Connection con,Statement stmt,ResultSet rs){
if(rs!=null){
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
rs=null;
}
if(stmt!=null){
try {
stmt.close();
} catch (SQLException e) {
e.printStackTrace();
}
stmt=null;
}
if(con!=null){
try {
con.close();
} catch (SQLException e) {
e.printStackTrace();
}
con=null;
}
}
}
1.导入jar包:
commons-dbcp-1.2.1.jar
下载地址:http://pan.baidu.com/s/1bnpIqez
commons-pool-1.2.jar
下载地址:http://pan.baidu.com/s/1qWlUbOK
2.在类目录下添加配置文件
src文件夹中添加dbcpconfig.properties文件
3.在BaseDaoPool的静态代码块中创建池
import javax.sql.DataSource;
import org.apache.commons.dbcp.BasicDataSourceFactory;
private static DataSource ds=null;
static{
InputStream in=BaseDaoPool.class.getClassLoader().
getResourceAsStream("dbcpconfig.properties");
Properties pro=new Properties();
try {
pro.load(in);
BasicDataSourceFactory factory=new BasicDataSourceFactory();
ds=factory.createDataSource(pro);
} catch (Exception e) {
throw new ExceptionInInitializerError(e);
}
}
4.使用连接池获得连接:
public Connection getConnection() throws SQLException{
return ds.getConnection();
}
附:
import java.io.InputStream;
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.BasicDataSourceFactory;
@SuppressWarnings("static-access")
public class BaseDaoPool {
private static DataSource ds=null;
static{
InputStream is=BaseDaoPool.class.getClassLoader().
getResourceAsStream("dbcpconfig.properties");
Properties properties=new Properties();
try {
properties.load(is);
BasicDataSourceFactory factory=new BasicDataSourceFactory();
ds=factory.createDataSource(properties);
} catch (Exception e) {
throw new ExceptionInInitializerError(e);
}
}
public Connection getConnection() throws SQLException{
return ds.getConnection();
}
public void closeAll(Connection con,Statement stmt,ResultSet rs){
if(rs!=null){
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
rs=null;
}
if(stmt!=null){
try {
stmt.close();
} catch (SQLException e) {
e.printStackTrace();
}
stmt=null;
}
if(con!=null){
try {
con.close();
} catch (SQLException e) {
e.printStackTrace();
}
con=null;
}
}
}
> 我来回应