java常用工具類之數(shù)據(jù)庫連接類（可以連接多種數(shù)據(jù)庫）
更新時間：2014年07月05日 12:52:17 投稿：junjie
這篇文章主要介紹了java常用工具類之數(shù)據(jù)庫連接類,可以連接多種數(shù)據(jù)庫,代碼中包含詳細注釋,需要的朋友可以參考下
依賴包下載：http://xiazai.jb51.net/201407/tools/java-db-dependency(jb51.net).rar
數(shù)據(jù)庫連接類源碼：
package com.itjh.javaUtil;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.apache.commons.dbcp.ConnectionFactory;
import org.apache.commons.dbcp.DriverManagerConnectionFactory;
import org.apache.commons.dbcp.PoolableConnectionFactory;
import org.apache.commons.dbcp.PoolingDriver;
import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.MapListHandler;
import org.apache.commons.pool.ObjectPool;
import org.apache.commons.pool.impl.GenericObjectPool;
/**
* 連接數(shù)據(jù)庫的綜合類。</br>
* 依賴jar包：commons.dbcp-1.4，commons.dbutils-1.3，commons.pool-1.5.4包。
*
* @author 宋立君
* @date 2014年07月03日
*/
public class DBUtil {
private String dri = null;
private String url = null;
private String username = null;
private String password = null;
private String poolName = null; // 連接池名稱
private ObjectPool connectionPool = null; // 連接池
// 對應(yīng)的定時查詢類
private QueryThread queryThread = null;
/**
* 功能：構(gòu)造函數(shù)
*
* @author 宋立君
* @date 2014年07月03日
* @param dri
* 驅(qū)動全類名，例如：com.mysql.jdbc.Driver。
* @param url
* 數(shù)據(jù)庫url連接，例如：
* "jdbc:mysql://127.0.0.1:3306/test?autoReconnect=true&useUnicode=true&characterEncoding=UTF-8"
* @param userName
* 數(shù)據(jù)庫用戶名，例如：root
* @param password
* 數(shù)據(jù)庫密碼，例如：abc
* @param poolName
* 創(chuàng)建的數(shù)據(jù)庫連接池的名稱，例如mypool，注意一個web容器此名稱不能重復(fù)。
*/
public DBUtil(String dri, String url, String userName, String password,
String poolName) {
this.dri = dri;
this.url = url;
this.username = userName;
this.password = password;
this.poolName = poolName;
}
/**
* 執(zhí)行sql。
*
* @param conn
* 連接
* @param pstm
* PreparedStatement
* @return int 執(zhí)行sql對應(yīng)的影響行。
* @throws SQLException
* @author 宋立君
* @date 2014年07月03日
*/
public int execute(Connection conn, PreparedStatement pstm)
throws SQLException {
try {
return pstm.executeUpdate();
} finally {
Close(conn);
}
}
/**
* 查詢sql。
*
* @param conn
* 連接
* @param pstm
* PreparedStatement
* @return List<Map<String,Object>> 查詢的結(jié)果集
* @throws SQLException
* @author 宋立君
* @date 2014年07月03日
*/
public List<Map<String, Object>> query(Connection conn,
PreparedStatement pstm) throws SQLException {
try {
return resultSetToList(pstm.executeQuery());
} finally {
Close(conn);
}
}
/**
* 功能：ResultSet 轉(zhuǎn)為List<Map<String,Object>>
*
*
* @param rs
* ResultSet 原始數(shù)據(jù)集
* @return List<Map<String,Object>>
* @throws java.sql.SQLException
* @author 宋立君
* @date 2014年07月03日
*/
private List<Map<String, Object>> resultSetToList(ResultSet rs)
throws java.sql.SQLException {
if (rs == null)
return Collections.EMPTY_LIST;
ResultSetMetaData md = rs.getMetaData(); // 得到結(jié)果集(rs)的結(jié)構(gòu)信息，比如字段數(shù)、字段名等
int columnCount = md.getColumnCount(); // 返回此 ResultSet 對象中的列數(shù)
List<Map<String, Object>> list = new ArrayList<Map<String, Object>>();
Map<String, Object> rowData = new HashMap<String, Object>();
while (rs.next()) {
rowData = new HashMap<String, Object>(columnCount);
for (int i = 1; i <= columnCount; i++) {
rowData.put(md.getColumnName(i), rs.getObject(i));
}
list.add(rowData);
}
return list;
}
/**
* 查詢sql語句。
*
* @param sql
* 被執(zhí)行的sql語句
* @return List<Map<String,Object>>
* @throws SQLException
* @author 宋立君
* @date 2014年07月03日
*/
public List<Map<String, Object>> query(String sql) throws SQLException {
List<Map<String, Object>> results = null;
Connection conn = null;
try {
conn = getConnection();
QueryRunner qr = new QueryRunner();
results = qr.query(conn, sql, new MapListHandler());
} finally {
Close(conn);
}
return results;
}
/**
* 根據(jù)參數(shù)查詢sql語句
*
* @param sql
* sql語句
* @param param
* 參數(shù)
* @return List<Map<String,Object>>
* @throws SQLException
* @author 宋立君
* @date 2014年07月03日
*/
public List<Map<String, Object>> query(String sql, Object param)
throws SQLException {
List<Map<String, Object>> results = null;
Connection conn = null;
try {
conn = getConnection();
QueryRunner qr = new QueryRunner();
results = (List<Map<String, Object>>) qr.query(conn, sql, param,
new MapListHandler());
} catch (SQLException e) {
e.printStackTrace();
} finally {
Close(conn);
}
return results;
}
/**
* 執(zhí)行sql語句
*
* @param sql
* 被執(zhí)行的sql語句
* @return 受影響的行
* @throws Exception
* @author 宋立君
* @date 2014年07月03日
*/
public int execute(String sql) throws Exception {
Connection conn = getConnection();
int rows = 0;
try {
QueryRunner qr = new QueryRunner();
rows = qr.update(conn, sql);
} finally {
Close(conn);
}
return rows;
}
/**
* 執(zhí)行含參數(shù)的sql語句
*
* @param sql
* 被執(zhí)行的sql語句
* @param params
* 參數(shù)
* @return 返回受影響的行
* @throws Exception
* @author 宋立君
* @date 2014年07月03日
*/
public int execute(String sql, Object[] params) throws Exception {
Connection conn = getConnection();
int rows = 0;
try {
QueryRunner qr = new QueryRunner();
rows = qr.update(conn, sql, params);
} finally {
Close(conn);
}
return rows;
}
/**
* 關(guān)閉連接
*
* @param conn
* @throws SQLException
* @author 宋立君
* @date 2014年07月03日
*/
public void Close(Connection conn) throws SQLException {
if (conn != null) {
conn.close();
}
DbUtils.closeQuietly(conn);
}
/**
* 啟動連接池
*
* @author 宋立君
* @date 2014年07月03日
*/
private void StartPool() {
try {
Class.forName(dri);
} catch (ClassNotFoundException e1) {
e1.printStackTrace();
}
if (connectionPool != null) {
ShutdownPool();
}
try {
connectionPool = new GenericObjectPool(null);
ConnectionFactory connectionFactory = new DriverManagerConnectionFactory(
url, username, password);
PoolableConnectionFactory poolableConnectionFactory = new PoolableConnectionFactory(
connectionFactory, connectionPool, null, "SELECT 1", false,
true);
Class.forName("org.apache.commons.dbcp.PoolingDriver");
PoolingDriver driver = (PoolingDriver) DriverManager
.getDriver("jdbc:apache:commons:dbcp:");
driver.registerPool(poolName, poolableConnectionFactory.getPool());
} catch (Exception e) {
e.printStackTrace();
}
// 開啟查詢程序
queryThread = new QueryThread(this);
queryThread.start();
}
/**
* 關(guān)閉連接池
*
* @author 宋立君
* @date 2014年07月03日
*/
private void ShutdownPool() {
try {
PoolingDriver driver = (PoolingDriver) DriverManager
.getDriver("jdbc:apache:commons:dbcp:");
driver.closePool(poolName);
// 關(guān)閉定時查詢
queryThread.setStartQuery(false);
} catch (SQLException e) {
e.printStackTrace();
}
}
/**
* 得到一個連接
*
* @return
* @author 宋立君
* @date 2014年07月03日
*/
public synchronized Connection getConnection() {
Connection conn = null;
try {
if (connectionPool == null)
StartPool();
conn = DriverManager.getConnection("jdbc:apache:commons:dbcp:"
+ poolName);
} catch (Exception e) {
e.printStackTrace();
}
return conn;
}
}
/**
* 當連接池啟動后會自動定時查詢數(shù)據(jù)庫，防止數(shù)據(jù)庫連接超時。
*
* @author 宋立君
* @date 2014年07月03日
*/
class QueryThread extends Thread {
private DBUtil dbUtil = null;
// 是否開啟查詢
private boolean startQuery = true;
/**
* 功能：對應(yīng)的數(shù)據(jù)庫連接。
*
* @author 宋立君
* @date 2014年07月03日
* @param dbUtil
* 數(shù)據(jù)庫連接
*/
public QueryThread(DBUtil dbUtil) {
this.dbUtil = dbUtil;
}
public void run() {
while (true) {
try {
if (startQuery) {
this.dbUtil.query("select 1");
}
// System.out.println(startQuery+" 123");
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
Thread.sleep(120000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
public void setStartQuery(boolean startQuery) {
// System.out.println("startQuery shut:"+startQuery);
this.startQuery = startQuery;
}
}
您可能感興趣的文章:
- java配置dbcp連接池(數(shù)據(jù)庫連接池)示例分享
- Java開發(fā)Oracle數(shù)據(jù)庫連接JDBC Thin Driver 的三種方法
- Java數(shù)據(jù)庫連接池的幾種配置方法(以MySQL數(shù)據(jù)庫為例)
- java實現(xiàn)mongodb的數(shù)據(jù)庫連接池
- Java 數(shù)據(jù)庫連接池詳解及簡單實例
- Java實現(xiàn)數(shù)據(jù)庫連接池簡易教程
- Java數(shù)據(jù)庫連接_jdbc-odbc橋連接方式(詳解)
- javaweb中mysql數(shù)據(jù)庫連接步驟方法及其實例
- java jdbc連接mysql數(shù)據(jù)庫實現(xiàn)增刪改查操作
- Java語言實現(xiàn)對MySql數(shù)據(jù)庫中數(shù)據(jù)的增刪改查操作的代碼
- Java連接MySQL數(shù)據(jù)庫增刪改查的通用方法(推薦)
- java 數(shù)據(jù)庫連接與增刪改查操作實例詳解
相關(guān)文章
這篇文章主要介紹了SpringBoot如何讀取resources目錄下的文件問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2023-07-07
java實現(xiàn)1M圖片壓縮優(yōu)化到100kb實現(xiàn)示例
這篇文章主要為大家介紹了java實現(xiàn)1M圖片壓縮優(yōu)化到100kb示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2022-07-07
今天我要和大家分享一些東西，舉例來說這個在JavaScript中用的很多。我要講講回調(diào)（callbacks）。你知道什么時候用，怎么用這個嗎？你真的理解了它在java環(huán)境中的用法了嗎？當我也問我自己這些問題，這也是我開始研究這些的原因2014-10-10
Java實現(xiàn)的打地鼠小游戲完整示例【附源碼下載】
這篇文章主要介紹了Java實現(xiàn)的打地鼠小游戲,結(jié)合完整實例形式分析了Java多線程操作及鍵盤按鍵響應(yīng)實現(xiàn)的打地鼠游戲功能相關(guān)操作技巧,需要的朋友可以參考下2018-07-07
下面小編就為大家?guī)硪黄狹yBatis攔截器:給參數(shù)對象屬性賦值的實例。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-04-04
這篇文章主要介紹了Java通過Scanner了解if...else if語句,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2020-01-01
這篇文章主要介紹了Java中多態(tài)的實現(xiàn)原理詳細解析,多態(tài)是面向?qū)ο缶幊陶Z言的重要特性,它允許基類的指針或引用指向派生類的對象,而在具體訪問時實現(xiàn)方法的動態(tài)綁定,需要的朋友可以參考下2024-01-01
java實現(xiàn)切圖并且判斷圖片是不是純色/彩色圖片
本篇文章主要介紹了java實現(xiàn)切圖并且判斷圖片是否是純色/彩色圖片，具有一定的參考價值，有興趣的可以了解一下2017-08-08
Spring+SpringMVC+MyBatis整合詳細教程(SSM)
Spring是一個開源框架，Spring是于2003 年興起的一個輕量級的Java 開發(fā)框架。這篇文章主要介紹了Spring+SpringMVC+MyBatis整合詳細教程(SSM),需要的朋友可以參考下2017-10-10
JAVA技術(shù)實現(xiàn)上傳下載文件到FTP服務(wù)器(完整)
這篇文章主要介紹了JAVA技術(shù)實現(xiàn)上傳下載文件到FTP服務(wù)器(完整)，本文使用 Apache Jakarta Commons Net（commons-net-3.3.jar） 基于FileZilla Server服務(wù)器實現(xiàn)FTP服務(wù)器上文件的上傳/下載/刪除等操作,需要的朋友可以參考下2015-07-07