java使用dbcp2數(shù)據(jù)庫連接池
更新時間：2016年10月21日 11:43:26 作者：修煉中的菜鳥
這篇文章主要為大家詳細(xì)介紹了java使用dbcp2數(shù)據(jù)庫連接池的相關(guān)資料,具有一定的參考價值，感興趣的小伙伴們可以參考一下
在開發(fā)中中我們經(jīng)常會使用到數(shù)據(jù)庫連接池，比如dbcp數(shù)據(jù)庫連接池，本章將講解java連接dbcp數(shù)據(jù)庫庫連接池的簡單使用。
開發(fā)工具myeclipse2014
1、首先創(chuàng)建一個web項目，我把項目名取名為testjdbc，需要帶有web.xml的配置文件，進(jìn)行servlet的配置，創(chuàng)建完成以后的項目結(jié)構(gòu)如下：
2、創(chuàng)建包，我創(chuàng)建的包名是com.szkingdom.db
3、創(chuàng)建幫助類CastUtil，代碼如下：
package com.szkingdom.db;
/**
* Created by jack on 2015/12/26.
* 轉(zhuǎn)型操作工具類
*/
public class CastUtil {
/*
* 轉(zhuǎn)為String型
* */
public static String castString(Object obj) {
return CastUtil.castString(obj, "");
}
/*
* 轉(zhuǎn)為String型（提供默認(rèn)值）
* */
public static String castString(Object obj, String defaultValue) {
return obj != null ? String.valueOf(obj) : defaultValue;
}
/*
* 轉(zhuǎn)為double型
* */
public static double castDouble(Object obj) {
return castDouble(obj, (double)0);
}
/*
* 轉(zhuǎn)為double型（提供默認(rèn)值）
* */
public static double castDouble(Object obj, Double defaultValue) {
double doubleValue = defaultValue;
if (obj != null) {
String strValue = castString(obj);
if (StringUtil.isNotEmpty(strValue)) {
try {
doubleValue = Double.parseDouble(strValue);
} catch (NumberFormatException e) {
defaultValue = defaultValue;
}
}
}
return doubleValue;
}
/*
* 轉(zhuǎn)為long型
* */
public static long castLong(Object obj) {
return castLong(obj, 0);
}
/*
* 轉(zhuǎn)為long型（提供默認(rèn)值）
* */
public static long castLong(Object obj, long defaultValue) {
long longValue = defaultValue;
if (obj != null) {
String strValue = castString(obj);
if (StringUtil.isNotEmpty(strValue)) {
try {
longValue = Long.parseLong(strValue);
}catch (NumberFormatException e){
longValue=defaultValue;
}
}
}
return longValue;
}
/*
* 轉(zhuǎn)為int型
* */
public static int castInt(Object obj){
return castInt(obj,0);
}
/*
* 轉(zhuǎn)為int型(提供默值)
* */
public static int castInt(Object obj,int defaultValue){
int intValue=defaultValue;
if (obj!=null){
String strValue=castString(obj);
if(StringUtil.isNotEmpty(strValue)){
try {
intValue=Integer.parseInt(strValue);
}catch (NumberFormatException e){
intValue=defaultValue;
}
}
}
return intValue;
}
/*
* 轉(zhuǎn)為boolean型
* */
public static boolean castBoolean(Object obj){
return castBoolean(obj,false);
}
/*
* 轉(zhuǎn)為boolean型(提供默認(rèn)值)
* */
public static boolean castBoolean(Object obj,boolean defaultValue){
boolean booleanValue=defaultValue;
if(obj!=null){
booleanValue=Boolean.parseBoolean(castString(obj));
}
return booleanValue;
}
}
4、創(chuàng)建屬性文件讀取幫助類PropsUtil，代碼如下：
package com.szkingdom.db;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;
/**
* Created by jack on 2015/12/26.
* 屬性文件工具類
*/
public class PropsUtil {
//private static final Logger LOGGER = LoggerFactory.getLogger(PropsUtil.class);
/*
* 加載屬性文件
*
* */
public static Properties loadProps(String fileName) {
Properties properties = null;
InputStream inputStream = null;
try {
inputStream = Thread.currentThread().getContextClassLoader().getResourceAsStream(fileName);
if (inputStream == null) {
throw new FileNotFoundException(fileName + " file is not found!");
}
properties = new Properties();
properties.load(inputStream);
} catch (IOException e) {
//LOGGER.error("load properties file failure", e);
System.out.println("load properties file failure:"+e);
} finally {
if (inputStream != null) {
try {
inputStream.close();
} catch (IOException e) {
//LOGGER.error("close input stream failure", e);
System.out.println("close input stream failure:"+e);
}
}
}
return properties;
}
/*
* 獲取字符型屬性（默認(rèn)為空字符串）
*
* */
public static String getString(Properties props, String key) {
return getString(props, key, "");
}
/*
* 獲取字符型屬性（可指定默認(rèn)值）
* */
public static String getString(Properties props, String key, String
defaultValue) {
String value = defaultValue;
if (props.containsKey(key)) {
value = props.getProperty(key);
}
return value;
}
/*
* 獲取數(shù)值類型屬性（默認(rèn)為0）
* */
public static int getInt(Properties props, String key) {
return getInt(props, key, 0);
}
/*
* 獲取數(shù)值類型屬性（可指定默認(rèn)值）
* */
public static int getInt(Properties props, String key, int defaultValue) {
int value = defaultValue;
if (props.containsKey(key)) {
value = CastUtil.castInt(props.getProperty(key));
}
return value;
}
/*
* 獲取布爾型屬性（默認(rèn)值為false）
* */
public static boolean getBoolean(Properties props, String key) {
return getBoolean(props, key, false);
}
/*
* 獲取布爾型屬性（可指定默認(rèn)值）
* */
public static boolean getBoolean(Properties props, String key, Boolean defaultValue) {
boolean value = defaultValue;
if (props.containsKey(key)) {
value = CastUtil.castBoolean(props.getProperty(key));
}
return value;
}
}
5、創(chuàng)建一個字符串幫助類StringUtil，代碼如下：
package com.szkingdom.db;
/**
* Created by jack on 2015/12/26.
* 字符串工具類
*/
public class StringUtil {
/*
* 判斷字符串是否為空
* */
public static boolean isEmpty(String str){
if(str != null){
str=str.trim();
}
//return StringUtils.isEmpty(str);
return "".equals(str);
}
/*
* 判斷字符串是否非空
* */
public static boolean isNotEmpty(String str){
return !isEmpty(str);
}
}
6、在src目錄下創(chuàng)建一個數(shù)據(jù)庫連接的屬性文件dbconfig.properties
<span style="color:#333333;">jdbc.driver=com.mysql.jdbc.Driver jdbc.url=jdbc:mysql://</span><span style="color:#ff6666;background-color: rgb(255, 0, 0);">127.0.0.1:3306/****</span><span style="color:#333333;"> jdbc.username=**** jdbc.password=****</span>
7、把必備的jar包放到lib目錄下：
8、使用dbcp創(chuàng)建數(shù)據(jù)庫幫助類
package com.szkingdom.db;
import java.io.ByteArrayInputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Properties;
import org.apache.commons.dbcp2.BasicDataSource;
/**
* Created by jack on 2015/12/26. 數(shù)據(jù)庫操作助手類
*/
public class DatabaseHelper {
// private static final Logger LOGGER=
// LoggerFactory.getLogger(DatabaseHelper.class);
private static final String DRIVER;
private static final String URL;
private static final String USERNAME;
private static final String PASSWORD;
//保證一個線程一個Connection，線程安全
private static final ThreadLocal<Connection> CONNECTION_HOLDER ;
//線程池
private static final BasicDataSource DATA_SOURCE;
static {
CONNECTION_HOLDER = new ThreadLocal<Connection>();
Properties conf = PropsUtil.loadProps("dbconfig.properties");
DRIVER = conf.getProperty("jdbc.driver");
URL = conf.getProperty("jdbc.url");
USERNAME = conf.getProperty("jdbc.username");
PASSWORD = conf.getProperty("jdbc.password");
String driver = conf.getProperty("jdbc.driver");
String url = conf.getProperty("jdbc.url");
String username = conf.getProperty("jdbc.username");
String passwrod = conf.getProperty("jdbc.password");
DATA_SOURCE=new BasicDataSource();
DATA_SOURCE.setDriverClassName(driver);
DATA_SOURCE.setUrl(url);
DATA_SOURCE.setUsername(username);
DATA_SOURCE.setPassword(passwrod);
//數(shù)據(jù)庫連接池參數(shù)配置：http://www.cnblogs.com/xdp-gacl/p/4002804.html
//http://greemranqq.iteye.com/blog/1969273
//http://blog.csdn.net/j903829182/article/details/50190337
//http://blog.csdn.net/jiutianhe/article/details/39670817
//http://bsr1983.iteye.com/blog/2092467
//http://blog.csdn.net/kerafan/article/details/50382998
//http://blog.csdn.net/a9529lty/article/details/43021801
///設(shè)置空閑和借用的連接的最大總數(shù)量，同時可以激活。
DATA_SOURCE.setMaxTotal(60);
//設(shè)置初始大小
DATA_SOURCE.setInitialSize(10);
//最小空閑連接
DATA_SOURCE.setMinIdle(8);
//最大空閑連接
DATA_SOURCE.setMaxIdle(16);
//超時等待時間毫秒
DATA_SOURCE.setMaxWaitMillis(2*10000);
//只會發(fā)現(xiàn)當(dāng)前連接失效，再創(chuàng)建一個連接供當(dāng)前查詢使用
DATA_SOURCE.setTestOnBorrow(true);
//removeAbandonedTimeout ：超過時間限制，回收沒有用(廢棄)的連接（默認(rèn)為 300秒，調(diào)整為180）
DATA_SOURCE.setRemoveAbandonedTimeout(180);
//removeAbandoned ：超過removeAbandonedTimeout時間后，是否進(jìn) 行沒用連接（廢棄）的回收（默認(rèn)為false，調(diào)整為true)
//DATA_SOURCE.setRemoveAbandonedOnMaintenance(removeAbandonedOnMaintenance);
DATA_SOURCE.setRemoveAbandonedOnBorrow(true);
//testWhileIdle
DATA_SOURCE.setTestOnReturn(true);
//testOnReturn
DATA_SOURCE.setTestOnReturn(true);
//setRemoveAbandonedOnMaintenance
DATA_SOURCE.setRemoveAbandonedOnMaintenance(true);
//記錄日志
DATA_SOURCE.setLogAbandoned(true);
//設(shè)置自動提交
DATA_SOURCE.setDefaultAutoCommit(true);
// DATA_SOURCE.setEnableAutoCommitOnReturn(true);
System.out.println("完成設(shè)置數(shù)據(jù)庫連接池DATA_SOURCE的參數(shù)！！");
/*try {
Class.forName(DRIVER);
System.out.println("load jdbc driver success");
} catch (ClassNotFoundException e) {
// LOGGER.error("can not load jdbc driver",e);
System.out.println("can not load jdbc driver:" + e);
}finally{
}*/
}
//private static final ThreadLocal<Connection> CONNECTION_HOLDER = new ThreadLocal<Connection>();
/**
* 獲取數(shù)據(jù)庫連接
*/
public static Connection getConnection() {
Connection conn = CONNECTION_HOLDER.get();// 1
if (conn == null) {
try {
//conn = DriverManager.getConnection(URL, USERNAME, PASSWORD);
conn = DATA_SOURCE.getConnection();
System.out.println("get connection success");
} catch (SQLException e) {
// LOGGER.error("get connection failure", e);
System.out.println("get connection failure:" + e);
} finally {
/*System.out.println(" 最小空閑連接MinIdle="+DATA_SOURCE.getMinIdle());
System.out.println(" 最大空閑連接MaxIdle="+DATA_SOURCE.getMaxIdle());
System.out.println(" 最大連接數(shù)量MaxTotal="+DATA_SOURCE.getMaxTotal());
System.out.println(" 初始大小InitialSize="+DATA_SOURCE.getInitialSize());
System.out.println(" 超時等待時間MaxWaitMillis="+(DATA_SOURCE.getMaxWaitMillis()/1000));
System.out.println(" 獲取活動的連接數(shù)getNumActive()="+DATA_SOURCE.getNumActive());
System.out.println(" 獲取連接數(shù)getNumIdle="+DATA_SOURCE.getNumIdle());*/
CONNECTION_HOLDER.set(conn);
}
}
return conn;
}
/**
* 關(guān)閉數(shù)據(jù)庫連接
*/
public static void closeConnection() {
Connection conn = CONNECTION_HOLDER.get();// 1
if (conn != null) {
try {
conn.close();
System.out.println("close connection success");
} catch (SQLException e) {
// LOGGER.error("close connection failure", e);
System.out.println("close connection failure:" + e);
throw new RuntimeException(e);
} finally {
CONNECTION_HOLDER.remove();
}
}
}
//進(jìn)行數(shù)據(jù)庫操作
public static synchronized void update(int thlsh,String ltnr) {
Connection conn = getConnection();
if(conn==null){
System.out.println("update方法里面的()connection為null!!");
}
PreparedStatement pstmt=null;
System.out.println("update開始!");
int ltlsh=0;
try {
//String sql="update message set CONTENT = ? where id=?";
//String sql1="select ltlsh from t_zxthlsk where lsh = ?";
String sql="update t_wx_ltnrk b set b.LTNR = ? where b.lsh = "+
"( select a.ltlsh from t_zxthlsk a where a.lsh = ? )";
System.out.println("更新的sql語句為：sql->"+sql);
pstmt = conn.prepareStatement(sql);
pstmt.setBlob(1, new ByteArrayInputStream(ltnr.getBytes()));
pstmt.setInt(2, thlsh);
/*pstmt.setString(1, "this is dbcp2 test 2222");
pstmt.setInt(2, 6);*/
if(pstmt.executeUpdate()>0){
//System.out.println("更新id=1的數(shù)據(jù)成功!");
System.out.println("更新thlsh="+thlsh+"的聊天內(nèi)容數(shù)據(jù)成功!\n聊天內(nèi)容為："+ltnr);
}
//conn.commit();
/*while(rs1.next()){
ltlsh = rs1.getInt("ltlsh");
System.out.println("查詢聊天流水號成功，聊天流水號為ltlsh->"+ltlsh);
}*/
//pstmt.setString(1, "精彩內(nèi)容update1");
//pstmt.setInt(2, 1);
//pstmt.setBlob(1, new ByteArrayInputStream("12345中國".getBytes()));
//pstmt.setInt(2, 76732);
/*if(pstmt.executeUpdate()>0){
//System.out.println("更新id=1的數(shù)據(jù)成功!");
System.out.println("更新id=76732的數(shù)據(jù)成功!");
}
conn.commit();*/
System.out.println("update t_wx_ltnrk success");
} catch (SQLException e) {
//LOGGER.error("query entity list failure", e);
System.out.println("更新數(shù)據(jù)異常connection="+conn);
System.out.println("update t_wx_ltnrk failure:" + e);
throw new RuntimeException(e);
} finally {
//closeConnection();
//closeConnection();
if(pstmt!=null){
try {
pstmt.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
System.out.println("PreparedStatement失敗");
}
}
if(conn!=null){
try {
conn.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
//移除線程里面的Connection，不移除會導(dǎo)致connection關(guān)閉以后，獲取的connection是 關(guān)閉狀態(tài)，不能進(jìn)行數(shù)據(jù)操作
CONNECTION_HOLDER.remove();
//closeConnection();
}
//return entityList;
}
}
9、基本的數(shù)據(jù)庫連接池就創(chuàng)建完畢了，之后就可以通過DatabaseHelper的update方法來模擬獲取數(shù)據(jù)庫連接進(jìn)行數(shù)據(jù)庫的操作，可根據(jù)自己的需求進(jìn)行數(shù)據(jù)的操作。
以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
本篇文章主要介紹了Spring-cloud 注冊服務(wù)提供者搭建方法，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2018-04-04
Lombok使用@Tolerate實(shí)現(xiàn)沖突兼容問題
這篇文章主要介紹了Lombok使用@Tolerate實(shí)現(xiàn)沖突兼容問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-08-08
使用MyBatisPlus自動生成代碼后tomcat運(yùn)行報錯的問題及解決方法
這篇文章主要介紹了使用MyBatisPlus自動生成代碼后tomcat運(yùn)行報錯的問題及解決方法，本文給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下2020-08-08
OpenTelemetry初識及調(diào)用鏈Trace詳解
這篇文章主要為為大家介紹了OpenTelemetry初識及調(diào)用鏈Trace詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2022-12-12
這篇文章主要為大家介紹了基于jvm-sandbox的imock開發(fā)指南詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-08-08
SpringBoot項目中Druid自動登錄功能實(shí)現(xiàn)
Druid是Java語言中最好的數(shù)據(jù)庫連接池,Druid能夠提供強(qiáng)大的監(jiān)控和擴(kuò)展功能,這篇文章主要介紹了SpringBoot項目中Druid自動登錄功能實(shí)現(xiàn),需要的朋友可以參考下2024-08-08
Java將對象寫入文件讀出_序列化與反序列化的實(shí)例
下面小編就為大家?guī)硪黄狫ava將對象寫入文件讀出_序列化與反序列化的實(shí)例。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-08-08
Spring?AOP實(shí)現(xiàn)多數(shù)據(jù)源動態(tài)切換
本文主要介紹了Spring?AOP實(shí)現(xiàn)多數(shù)據(jù)源動態(tài)切換，文中通過示例代碼介紹的非常詳細(xì)，具有一定的參考價值，感興趣的小伙伴們可以參考一下2022-03-03
這篇文章主要介紹了如何利用泛型封裝通用的service層，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-06-06
這篇文章主要介紹了JAVA記住密碼功能的實(shí)現(xiàn)代碼,代碼簡單易懂，非常不錯，具有一定的參考借鑒價值，需要的朋友可以參考下2020-01-01