簡明入門教程，參考：https://www.cnblogs.com/CQY1183344265/p/5854418.html

進(jìn)行此章節(jié)之前，介紹一個JdbcUtils的再次的簡單封裝

　　（例如后面需要構(gòu)造QueryRunner時得到數(shù)據(jù)源等的簡便的操作）

package cn.itcast.jdbcutils;import java.sql.Connection; import java.sql.SQLException;import com.mchange.v2.c3p0.ComboPooledDataSource;public class JdbcUtils {//使用的是默認(rèn)的配置信息，注意給出c3p0-config.xml配置文件private static ComboPooledDataSource dataSource = new ComboPooledDataSource();//處理多線程的并發(fā)訪問問題，使用ThreadLocalprivate static ThreadLocal<Connection> tl = new ThreadLocal<Connection>();public static Connection getConnection() throws SQLException{//不為Null說明開啟了事務(wù)，返回連接//先獲取自己線程的ConnectionConnection con = tl.get();if(con != null) return con;return dataSource.getConnection();}/*** 大方一點，給出連接池對象給你*/public static ComboPooledDataSource getDataSource(){return dataSource;}//給出三個方法/*** 開啟事務(wù)* 創(chuàng)建一個Connection，設(shè)置為手動提交* 保證DAO使用的就是這個事務(wù)的連接* 同時還需要保證下面兩個提交與回滾是同一個連接* 通過創(chuàng)建一個本類的連接成員* @throws SQLException */public static void startTransaction() throws SQLException{Connection con = tl.get();//開啟事務(wù)后con不再為nullcon = getConnection();con.setAutoCommit(false);//保存連接 tl.set(con);}/*** 提交事務(wù)* @throws SQLException */public static void commitTransaction() throws SQLException{Connection con = tl.get();if(con == null) throw new SQLException("事務(wù)未開啟，請勿提交！");con.commit();con.close();//清空連接con = null;//移除事務(wù) tl.remove();}/*** 回滾事務(wù)* @throws SQLException */public static void rollbackTransaction() throws SQLException {Connection con = tl.get();if(con == null) throw new SQLException("事務(wù)未開啟，請勿回滾！");con.rollback();con.close();con = null;tl.remove();}/*** 用于釋放連接* @param connection* @throws SQLException */public static void releaseConnection(Connection connection) throws SQLException{//事務(wù)專用則不關(guān)閉，后續(xù)會有關(guān)閉//如果不是事務(wù)，則需要關(guān)閉Connection con = tl.get();//事務(wù)都沒有，直接關(guān)閉if(con == null) connection.close();//有事務(wù)，判斷是否相等，是否為專用連接if(con != connection) connection.close();} }

?

一、簡易的入門：

　　　　common-dbutils是Apache對Jdbc的一個簡單的封裝，其中主要涉及的類有：

　　　　　　QueryRunner

　　　　　　ResultSetHandler

　　　　　　DbUtils

　　　　使用的依賴如下：

　　　　

?

　　1.

　　重要類 QueryRunner （構(gòu)造時提供數(shù)據(jù)源）
　　重要方法：int update(String sql,Object...params);增刪改
　　重載版本 int update(Connection con,String sql,Object...params);本方法不再管理con，由外部提供（保證是同一個）
　　T query(String sql,ResultSetHandler rsh,Object...params);查詢
　　重載版本類同上

　　給出一個使用的小例子：

　　

package cn.itcast.demo;import java.sql.SQLException;import org.apache.commons.dbutils.QueryRunner; import org.junit.Test;import cn.itcast.jdbcutils.JdbcUtils;/*** 測試commons-dbutils* @author jiangbei01**/ public class Demo02 {@Testpublic void testfun1() throws SQLException{QueryRunner qr = new QueryRunner(JdbcUtils.getDataSource());String sql = "INSERT INTO ab VALUES(?,?)";Object[] params = {8,"肖恩"};qr.update(sql, params);} }

?

　　2.

　　給一張表對應(yīng)一個類，字段與屬性對應(yīng)起來

　　他會先得到ResultSet，然后調(diào)用handler方法轉(zhuǎn)換成需要的類型
　　接口ResultSetHandler，我們學(xué)習(xí)的實現(xiàn)類：
　　BeanHandler 構(gòu)造器需要一個class參數(shù)，返回指定類型的javabean對象 ?一行記錄
　　BeanListHandler 構(gòu)造器同上，由名稱知為多行，轉(zhuǎn)換成list對象，多個javabean ?多行記錄
　　MapHandler 把一行記錄轉(zhuǎn)換成一個map （如{name:zhangsan,age:20}） ?一行記錄
　　MapListHandler 同上對比，多個map的多行記錄，返回List<Map>，返回的也是一個List ?多行記錄
　　ScalarHandler 單行單列，通常與select count(*) from stu; 單行單列

　　這里使用裝飾者模式加上開頭改造的工具類，將QueryRunner稍加改造

　　

package cn.itcast.jdbcutils;import java.sql.Connection; import java.sql.SQLException;import org.apache.commons.dbutils.QueryRunner; import org.apache.commons.dbutils.ResultSetHandler; /*** 這個類可以自身自己處理連接問題，可以通過jdbcUtils釋放連接（類方法會處理是否關(guān)閉）* @author jiangbei01**/ public class TxQueryRunner extends QueryRunner {@Overridepublic int[] batch(String sql, Object[][] params) throws SQLException {/** 得到連接* 執(zhí)行父類方法* 釋放連接* 返回值*/Connection con = JdbcUtils.getConnection();int[] results = super.batch(con,sql, params);JdbcUtils.releaseConnection(con);return results;}@Overridepublic <T> T query(String sql, Object param, ResultSetHandler<T> rsh) throws SQLException {/** 得到連接* 執(zhí)行父類方法* 釋放連接* 返回值*/Connection con = JdbcUtils.getConnection();T results = super.query(con,sql, param,rsh);JdbcUtils.releaseConnection(con);return results;}@Overridepublic <T> T query(String sql, Object[] params, ResultSetHandler<T> rsh) throws SQLException {Connection con = JdbcUtils.getConnection();T results = super.query(con,sql, params,rsh);JdbcUtils.releaseConnection(con);return results;}@Overridepublic <T> T query(String sql, ResultSetHandler<T> rsh, Object... params) throws SQLException {Connection con = JdbcUtils.getConnection();T results = super.query(con,sql, rsh,params);JdbcUtils.releaseConnection(con);return results;}@Overridepublic <T> T query(String sql, ResultSetHandler<T> rsh) throws SQLException {Connection con = JdbcUtils.getConnection();T results = super.query(con,sql, rsh);JdbcUtils.releaseConnection(con);return results;}@Overridepublic int update(String sql, Object... params) throws SQLException {Connection con = JdbcUtils.getConnection();int results = super.update(con,sql,params);JdbcUtils.releaseConnection(con);return results;}@Overridepublic int update(String sql, Object param) throws SQLException {Connection con = JdbcUtils.getConnection();int results = super.update(con,sql,param);JdbcUtils.releaseConnection(con);return results;}@Overridepublic int update(String sql) throws SQLException {Connection con = JdbcUtils.getConnection();int results = super.update(con,sql);JdbcUtils.releaseConnection(con);return results;}}

給出一個使用改造類的小例子：

package cn.itcast.jdbcutils;import java.sql.Connection; import java.sql.SQLException;import org.apache.commons.dbutils.QueryRunner;public class AccountDAO {/*** 不能使用連接池* 要自己提供連接才能保證是同一個連接* @param name* @param money* @throws SQLException*/public static void update(String name, double money) throws SQLException{QueryRunner qr = new TxQueryRunner();String sql = "update account set balaence=balaence+? where name=?";Object[] params = {money,name};//給出參數(shù)并執(zhí)行 qr.update(sql,params);/** 以下代碼新寫的Tx類已經(jīng)完成，無需處理* Connection con = JdbcUtils.getConnection();* //釋放連接JdbcUtils.releaseConnection(con);*/} }

?

　　并發(fā)訪問時產(chǎn)生的問題，可以使用ThreadLocal類（待更新詳細(xì)）進(jìn)行解決，示例如下：

package cn.itcast.jdbcutils;import java.sql.Connection; import java.sql.SQLException;import com.mchange.v2.c3p0.ComboPooledDataSource;public class JdbcUtils {//使用的是默認(rèn)的配置信息，注意給出c3p0-config.xml配置文件private static ComboPooledDataSource dataSource = new ComboPooledDataSource();//處理多線程的并發(fā)訪問問題，使用ThreadLocalprivate static ThreadLocal<Connection> tl = new ThreadLocal<Connection>();public static Connection getConnection() throws SQLException{//不為Null說明開啟了事務(wù)，返回連接//先獲取自己線程的ConnectionConnection con = tl.get();if(con != null) return con;return dataSource.getConnection();}/*** 大方一點，給出連接池對象給你*/public static ComboPooledDataSource getDataSource(){return dataSource;}//給出三個方法/*** 開啟事務(wù)* 創(chuàng)建一個Connection，設(shè)置為手動提交* 保證DAO使用的就是這個事務(wù)的連接* 同時還需要保證下面兩個提交與回滾是同一個連接* 通過創(chuàng)建一個本類的連接成員* @throws SQLException */public static void startTransaction() throws SQLException{Connection con = tl.get();//開啟事務(wù)后con不再為nullcon = getConnection();con.setAutoCommit(false);//保存連接 tl.set(con);}/*** 提交事務(wù)* @throws SQLException */public static void commitTransaction() throws SQLException{Connection con = tl.get();if(con == null) throw new SQLException("事務(wù)未開啟，請勿提交！");con.commit();con.close();//清空連接con = null;//移除事務(wù) tl.remove();}/*** 回滾事務(wù)* @throws SQLException */public static void rollbackTransaction() throws SQLException {Connection con = tl.get();if(con == null) throw new SQLException("事務(wù)未開啟，請勿回滾！");con.rollback();con.close();con = null;tl.remove();}/*** 用于釋放連接* @param connection* @throws SQLException */public static void releaseConnection(Connection connection) throws SQLException{//事務(wù)專用則不關(guān)閉，后續(xù)會有關(guān)閉//如果不是事務(wù)，則需要關(guān)閉Connection con = tl.get();//事務(wù)都沒有，直接關(guān)閉if(con == null) connection.close();//有事務(wù)，判斷是否相等，是否為專用連接if(con != connection) connection.close();} }

?

轉(zhuǎn)載于:https://www.cnblogs.com/jiangbei/p/6704643.html

創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎勵來咯，堅持創(chuàng)作打卡瓜分現(xiàn)金大獎

總結(jié)

以上是生活随笔為你收集整理的JavaWeb基础—dbutils的简单入门的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。