import org.apache.commons.pool.ObjectPool;
import org.apache.commons.pool.impl.GenericObjectPool;
import org.apache.commons.dbcp.ConnectionFactory;
import org.apache.commons.dbcp.PoolingDriver;
import org.apache.commons.dbcp.PoolableConnectionFactory;
import org.apache.commons.dbcp.DriverManagerConnectionFactory;
import java.sql.*;
public class DBConn {
private Connection conn = null;
private Statement stmt = null;
private static String sqlJdbc = "";
private static String sqlUser = "";
private static String sqlPwd = "";
private static Class driverClass=null;
private static ObjectPool connectionPool=null;
public DBConn() {
if("".equals(sqlJdbc)){
sqlJdbc = "jdbc:mysql://192.168.1.117:3306/test";
//sqlserver: jdbc:microsoft:sqlserver://IP;DatabaseName=lordeDAS
//oracle: jdbc:oracle:thin:@ip:1521:myordb
}
if("".equals(sqlUser)){
sqlUser = "root";
}
if("".equals(sqlPwd)){
sqlPwd = "";
}
initDataSource();
}
public synchronized static void initDataSource(){
if(driverClass==null){
try {
//oracle: oracle.jdbc.driver.OracleDriver
//sqlserver: com.microsoft.jdbc.sqlserver.SQLServerDriver
driverClass=Class.forName("org.gjt.mm.mysql.Driver");
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
if(connectionPool==null){
try {
setupDriver(sqlJdbc);
} catch (Exception e) {
e.printStackTrace();
}
}
// Display some pool statistics
try {
printDriverStats();
} catch (Exception e) {
e.printStackTrace();
}
}
//获取一个连接
private Connection getDbPollConnection(){
try {
conn = DriverManager.getConnection("jdbc:apache:commons:dbcp:auxdbpoll");
} catch(SQLException e) {
e.printStackTrace();
}
return conn;
}
// 获得记录集
public ResultSet executeQuery(String SQL) {
try {
stmt=getDbPollConnection().createStatement();
ResultSet rs = stmt.executeQuery(SQL);
return rs;
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
// 执行SQL
public boolean execute(String SQL) {
try {
stmt=getDbPollConnection().createStatement();
stmt.execute(SQL);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}finally{
close();
}
}
// 执行SQL
public boolean executeUpdate(String SQL) {
try {
stmt=getDbPollConnection().createStatement();
stmt.executeUpdate(SQL);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}finally{
close();
}
}
public void close(){
if(stmt!=null){
try{
stmt.close();
stmt=null;
}catch(Exception e){
System.out.println(e);
}
}
if(conn!=null){
try{
conn.close();
conn=null;
}catch(Exception e){
System.out.println(e);
}
}
}
public static void printDriverStats() throws Exception {
PoolingDriver driver = (PoolingDriver) DriverManager.getDriver("jdbc:apache:commons:dbcp:");
ObjectPool connectionPool = driver.getConnectionPool("auxdbpoll");
System.out.println("活动的连接: " + connectionPool.getNumActive());
System.out.println("空闲的连接: " + connectionPool.getNumIdle());
}
public static void shutdownDriver() throws Exception {
PoolingDriver driver = (PoolingDriver) DriverManager.getDriver("jdbc:apache:commons:dbcp:");
driver.closePool("auxdbpoll");
}
public static void setupDriver(String connectURI) throws Exception {
System.out.println(connectURI);
connectionPool = new GenericObjectPool(null);
ConnectionFactory connectionFactory = new DriverManagerConnectionFactory(connectURI,sqlUser,sqlPwd);
PoolableConnectionFactory poolableConnectionFactory = new PoolableConnectionFactory(connectionFactory,connectionPool,null,null,false,true);
Class.forName("org.apache.commons.dbcp.PoolingDriver");
PoolingDriver driver = (PoolingDriver) DriverManager.getDriver("jdbc:apache:commons:dbcp:");
driver.registerPool("auxdbpoll",connectionPool);
}
//测试
public void testQuery(){
String sql="select * from table_user";
try {
ResultSet rs=executeQuery(sql);
while(rs.next()){
System.out.println(rs.getString("user"));
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
close();
}
}
public static void main(String[] args){
DBConn dbConn=new DBConn();
dbConn.testQuery();
}
}
分享到:
相关推荐
DBCP配置数据库连接池实现对数据库的连接并附上增删改查
该例子中主要是通过dbcp连接数据库 详见: http://blog.csdn.net/renlei0109/article/details/32711943
包含jdbc连接数据库与dbcp连接数据库代码,方便基础学习与深入理解数据库连接池
这个是dbcp所需的高版本的jar包,
DBCP 数据库连接池 DBCP 数据库连接池 DBCP 数据库连接池 里面是DBCP的jar,导进去就可以用了
利用dbcp实现数据库连接池,附带两个jar包,本人已测试通过
dbcp数据库连接池需要用到的jar,包括源码和api文档,javadoc
DBCP数据库连接池的完整jar包
java web开发 dbcp数据库连接池 所用jar包。java web开发 dbcp数据库连接池 所用jar包。
利用dbcp建立数据库连接池的功能所需要的两个jar包:commons-pool.jar,commons-dbcp-1.2.jar
包含jdbc连接数据库与dbcp连接数据库代码,方便基础学习与深入理解数据库连接池
DBCP(DataBase Connection Pool)数据库连接池,是java数据库连接池的一种,由Apache开发,通过数据库连接池,可以让程序自动管理数据库连接的释放和断开。
dbcp数据库连接池用到的jar包,在spring4整合过程中测试通过。
由于commons-dbcp2所用的连接池出现版本升级,因此commons-dbcp2中的数据库池连接配置也发生了变化,具体的参数配置说明
掌握DBCP连接池,里面有需要用到dbcp连接池的jar包
适合学习练习用jar包
HibernateADDSpring(hibernate和spring整合,使用dbcp连接池方式连接数据库)
Apache的DBCP数据库连接池,好用的压缩包。凑字数凑字数
NULL 博文链接:https://xiongjiajia.iteye.com/blog/1295094
dbcp连接池的jar包,希望能给大家带来帮助。