Tomcat 动态数据库连接池


package com.boguan.bte.util;

import java.sql.Connection;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

import org.apache.tomcat.jdbc.pool.DataSource;
import org.apache.tomcat.jdbc.pool.PoolProperties;

import com.boguan.bte.constant.IDBConstants;

/**
* 数据库工具类 名称: DBToolKit.java<br>
* 描述: <br>
* 类型: JAVA<br>
* 最近修改时间:2016年6月23日 下午6:02:50<br>
*
* @since 2016年6月23日
* @author
*/
public class DBToolKit {

/**
* 数据库用户
*/
public static String user;

/**
* 数据库密码
*/
public static String password;

/**
* 数据库驱动
*/
private static String url;

/**
* 驱动
*/
private static String driver;

/**
* 数据库连接池名称
*/
private static String JNDI;

/**
* 数据库连接池资源对象
*/
private static PoolProperties p = new PoolProperties();

/**
* 多库数据库连接池集合
*/
private static Map<String,Object> dataSources = new HashMap<String,Object>();

/**
* 构造器实现多例模式
*/
private DBToolKit(){
}

/**
* 动态获取数据库连接池
* @param dataBase
* @return
* @throws SQLException
*/
public static Connection getDynamicConnection(String dataBase) throws SQLException{
Connection conn = null;
DataSource datasource = null;
if(dataSources.containsKey(dataBase)){
datasource = (DataSource) dataSources.get(dataBase);
}else{
datasource = new DataSource();
p.setUrl(url + dataBase);
datasource.setPoolProperties(p);
dataSources.put(dataBase, datasource);
}
conn = datasource.getConnection();
return conn;
}

/**
* 初始化资源
*/
static {
user = PropertiesUtil.getDbProperty(IDBConstants.DBUSER);
password = PropertiesUtil.getDbProperty(IDBConstants.PASSWORD);
url = PropertiesUtil.getDbProperty(IDBConstants.URL);
driver = PropertiesUtil.getDbProperty(IDBConstants.DRIVER);
JNDI = PropertiesUtil.getDbProperty(IDBConstants.JNDI);
// 初始化数据库连接池资源文件对象
p.setDriverClassName(driver);
p.setUsername(user);
p.setPassword(password);
p.setJmxEnabled(true);
p.setTestWhileIdle(false);
p.setTestOnBorrow(true);
// p.setValidationQuery("SELECT 1");
p.setTestOnReturn(false);
p.setValidationInterval(30000);
p.setTimeBetweenEvictionRunsMillis(30000);
p.setMaxActive(100);
p.setInitialSize(10);
p.setMaxWait(10000);
p.setRemoveAbandonedTimeout(60);
p.setMinEvictableIdleTimeMillis(30000);
p.setMinIdle(10);
p.setLogAbandoned(true);
p.setRemoveAbandoned(true);
p.setJdbcInterceptors("org.apache.tomcat.jdbc.pool.interceptor.ConnectionState;"
+ "org.apache.tomcat.jdbc.pool.interceptor.StatementFinalizer");
}

/**
* 获取数据库连接池
*
* @return Connection
* @throws NamingException
* @throws SQLException
*/
public static Connection getConnection() throws NamingException, SQLException {
Context initCtx = new InitialContext();
DataSource ds = (DataSource) initCtx.lookup(JNDI);
Connection conn = ds.getConnection();
return conn;
}

/**
* 获取默认的数据库连接池配置
*
* @return Connection
* @throws NamingException
* @throws SQLException
*/
public static Connection getDefaultConnection() throws NamingException, SQLException {
Connection conn = getDynamicConnection(IDBConstants.BASEDATABASE);
return conn;
}


}

优质内容筛选与推荐>>
1、数学建模python matlab 编程(喷泉模拟)
2、nginx的安装及启动
3、(int&)a和(int)a的区别
4、js中的prototype原型对象
5、[BZOJ 2118] 墨墨的等式


长按二维码向我转账

受苹果公司新规定影响,微信 iOS 版的赞赏功能被关闭,可通过二维码转账支持公众号。

    阅读
    好看
    已推荐到看一看
    你的朋友可以在“发现”-“看一看”看到你认为好看的文章。
    已取消,“好看”想法已同步删除
    已推荐到看一看 和朋友分享想法
    最多200字,当前共 发送

    已发送

    朋友将在看一看看到

    确定
    分享你的想法...
    取消

    分享想法到看一看

    确定
    最多200字,当前共

    发送中

    网络异常,请稍后重试

    微信扫一扫
    关注该公众号