一区二区三区在线-一区二区三区亚洲视频-一区二区三区亚洲-一区二区三区午夜-一区二区三区四区在线视频-一区二区三区四区在线免费观看

服務器之家：專注于服務器技術及軟件下載分享
分類導航

PHP教程|ASP.NET教程|JAVA教程|ASP教程|

服務器之家 - 編程語言 - JAVA教程 - java常用工具類之數據庫連接類（可以連接多種數據庫）

java常用工具類之數據庫連接類（可以連接多種數據庫）

2019-11-24 15:25junjie JAVA教程

這篇文章主要介紹了java常用工具類之數據庫連接類,可以連接多種數據庫,代碼中包含詳細注釋,需要的朋友可以參考下

依賴包下載

數據庫連接類源碼：

  1. package com.itjh.javaUtil; 
  2.   
  3. import java.sql.Connection; 
  4. import java.sql.DriverManager; 
  5. import java.sql.PreparedStatement; 
  6. import java.sql.ResultSet; 
  7. import java.sql.ResultSetMetaData; 
  8. import java.sql.SQLException; 
  9. import java.util.ArrayList; 
  10. import java.util.Collections; 
  11. import java.util.HashMap; 
  12. import java.util.List; 
  13. import java.util.Map; 
  14.   
  15. import org.apache.commons.dbcp.ConnectionFactory; 
  16. import org.apache.commons.dbcp.DriverManagerConnectionFactory; 
  17. import org.apache.commons.dbcp.PoolableConnectionFactory; 
  18. import org.apache.commons.dbcp.PoolingDriver; 
  19. import org.apache.commons.dbutils.DbUtils; 
  20. import org.apache.commons.dbutils.QueryRunner; 
  21. import org.apache.commons.dbutils.handlers.MapListHandler; 
  22. import org.apache.commons.pool.ObjectPool; 
  23. import org.apache.commons.pool.impl.GenericObjectPool; 
  24.   
  25. /** 
  26.  * 連接數據庫的綜合類。</br> 
  27.  * 依賴jar包：commons.dbcp-1.4，commons.dbutils-1.3，commons.pool-1.5.4包。 
  28.  *  
  29.  * @author 宋立君 
  30.  * @date 2014年07月03日 
  31.  */ 
  32.   
  33. public class DBUtil { 
  34.   
  35.     private String dri = null; 
  36.     private String url = null; 
  37.     private String username = null; 
  38.     private String password = null; 
  39.     private String poolName = null; // 連接池名稱 
  40.     private ObjectPool connectionPool = null; // 連接池 
  41.     // 對應的定時查詢類 
  42.     private QueryThread queryThread = null; 
  43.   
  44.     /** 
  45.      * 功能：構造函數 
  46.      *  
  47.      * @author 宋立君 
  48.      * @date 2014年07月03日 
  49.      * @param dri 
  50.      *      驅動全類名，例如：com.mysql.jdbc.Driver。 
  51.      * @param url 
  52.      *      數據庫url連接，例如： 
  53.      *      "jdbc:mysql://127.0.0.1:3306/test?autoReconnect=true&useUnicode=true&characterEncoding=UTF-8" 
  54.      * @param userName 
  55.      *      數據庫用戶名，例如：root 
  56.      * @param password 
  57.      *      數據庫密碼，例如：abc 
  58.      * @param poolName 
  59.      *      創建的數據庫連接池的名稱，例如mypool，注意一個web容器此名稱不能重復。 
  60.      */ 
  61.     public DBUtil(String dri, String url, String userName, String password, 
  62.             String poolName) { 
  63.         this.dri = dri; 
  64.         this.url = url; 
  65.         this.username = userName; 
  66.         this.password = password; 
  67.         this.poolName = poolName; 
  68.     } 
  69.   
  70.     /** 
  71.      * 執行sql。 
  72.      *  
  73.      * @param conn 
  74.      *      連接 
  75.      * @param pstm 
  76.      *      PreparedStatement 
  77.      * @return int 執行sql對應的影響行。 
  78.      * @throws SQLException 
  79.      * @author 宋立君 
  80.      * @date 2014年07月03日 
  81.      */ 
  82.     public int execute(Connection conn, PreparedStatement pstm) 
  83.             throws SQLException { 
  84.         try { 
  85.             return pstm.executeUpdate(); 
  86.         } finally { 
  87.             Close(conn); 
  88.         } 
  89.     } 
  90.   
  91.     /** 
  92.      * 查詢sql。 
  93.      *  
  94.      * @param conn 
  95.      *      連接 
  96.      * @param pstm 
  97.      *      PreparedStatement 
  98.      * @return List<Map<String,Object>> 查詢的結果集 
  99.      * @throws SQLException 
  100.      * @author 宋立君 
  101.      * @date 2014年07月03日 
  102.      */ 
  103.     public List<Map<String, Object>> query(Connection conn, 
  104.             PreparedStatement pstm) throws SQLException { 
  105.         try { 
  106.             return resultSetToList(pstm.executeQuery()); 
  107.         } finally { 
  108.             Close(conn); 
  109.         } 
  110.     } 
  111.   
  112.     /** 
  113.      * 功能：ResultSet 轉為List<Map<String,Object>> 
  114.      *  
  115.      *  
  116.      * @param rs 
  117.      *      ResultSet 原始數據集 
  118.      * @return List<Map<String,Object>> 
  119.      * @throws java.sql.SQLException 
  120.      * @author 宋立君 
  121.      * @date 2014年07月03日 
  122.      */ 
  123.     private List<Map<String, Object>> resultSetToList(ResultSet rs) 
  124.             throws java.sql.SQLException { 
  125.         if (rs == null) 
  126.             return Collections.EMPTY_LIST; 
  127.   
  128.         ResultSetMetaData md = rs.getMetaData(); // 得到結果集(rs)的結構信息，比如字段數、字段名等 
  129.         int columnCount = md.getColumnCount(); // 返回此 ResultSet 對象中的列數 
  130.         List<Map<String, Object>> list = new ArrayList<Map<String, Object>>(); 
  131.         Map<String, Object> rowData = new HashMap<String, Object>(); 
  132.         while (rs.next()) { 
  133.             rowData = new HashMap<String, Object>(columnCount); 
  134.             for (int i = 1; i <= columnCount; i++) { 
  135.                 rowData.put(md.getColumnName(i), rs.getObject(i)); 
  136.             } 
  137.             list.add(rowData); 
  138.         } 
  139.         return list; 
  140.     } 
  141.   
  142.     /** 
  143.      * 查詢sql語句。 
  144.      *  
  145.      * @param sql 
  146.      *      被執行的sql語句 
  147.      * @return List<Map<String,Object>> 
  148.      * @throws SQLException 
  149.      * @author 宋立君 
  150.      * @date 2014年07月03日 
  151.      */ 
  152.     public List<Map<String, Object>> query(String sql) throws SQLException { 
  153.         List<Map<String, Object>> results = null; 
  154.         Connection conn = null; 
  155.         try { 
  156.             conn = getConnection(); 
  157.             QueryRunner qr = new QueryRunner(); 
  158.             results = qr.query(conn, sql, new MapListHandler()); 
  159.         } finally { 
  160.             Close(conn); 
  161.         } 
  162.         return results; 
  163.     } 
  164.   
  165.     /** 
  166.      * 根據參數查詢sql語句 
  167.      *  
  168.      * @param sql 
  169.      *      sql語句 
  170.      * @param param 
  171.      *      參數 
  172.      * @return List<Map<String,Object>> 
  173.      * @throws SQLException 
  174.      * @author 宋立君 
  175.      * @date 2014年07月03日 
  176.      */ 
  177.     public List<Map<String, Object>> query(String sql, Object param) 
  178.             throws SQLException { 
  179.         List<Map<String, Object>> results = null; 
  180.         Connection conn = null; 
  181.         try { 
  182.             conn = getConnection(); 
  183.             QueryRunner qr = new QueryRunner(); 
  184.             results = (List<Map<String, Object>>) qr.query(conn, sql, param, 
  185.                     new MapListHandler()); 
  186.         } catch (SQLException e) { 
  187.             e.printStackTrace(); 
  188.         } finally { 
  189.             Close(conn); 
  190.         } 
  191.         return results; 
  192.     } 
  193.   
  194.     /** 
  195.      * 執行sql語句 
  196.      *  
  197.      * @param sql 
  198.      *      被執行的sql語句 
  199.      * @return 受影響的行 
  200.      * @throws Exception 
  201.      * @author 宋立君 
  202.      * @date 2014年07月03日 
  203.      */ 
  204.     public int execute(String sql) throws Exception { 
  205.         Connection conn = getConnection(); 
  206.         int rows = 0; 
  207.         try { 
  208.             QueryRunner qr = new QueryRunner(); 
  209.             rows = qr.update(conn, sql); 
  210.         } finally { 
  211.             Close(conn); 
  212.         } 
  213.         return rows; 
  214.     } 
  215.   
  216.     /** 
  217.      * 執行含參數的sql語句 
  218.      *  
  219.      * @param sql 
  220.      *      被執行的sql語句 
  221.      * @param params 
  222.      *      參數 
  223.      * @return 返回受影響的行 
  224.      * @throws Exception 
  225.      * @author 宋立君 
  226.      * @date 2014年07月03日 
  227.      */ 
  228.     public int execute(String sql, Object[] params) throws Exception { 
  229.         Connection conn = getConnection(); 
  230.         int rows = 0; 
  231.         try { 
  232.             QueryRunner qr = new QueryRunner(); 
  233.             rows = qr.update(conn, sql, params); 
  234.         } finally { 
  235.             Close(conn); 
  236.         } 
  237.         return rows; 
  238.     } 
  239.   
  240.     /** 
  241.      * 關閉連接 
  242.      *  
  243.      * @param conn 
  244.      * @throws SQLException 
  245.      * @author 宋立君 
  246.      * @date 2014年07月03日 
  247.      */ 
  248.     public void Close(Connection conn) throws SQLException { 
  249.         if (conn != null) { 
  250.             conn.close(); 
  251.         } 
  252.         DbUtils.closeQuietly(conn); 
  253.     } 
  254.   
  255.     /** 
  256.      * 啟動連接池 
  257.      *  
  258.      * @author 宋立君 
  259.      * @date 2014年07月03日 
  260.      */ 
  261.     private void StartPool() { 
  262.         try { 
  263.             Class.forName(dri); 
  264.         } catch (ClassNotFoundException e1) { 
  265.             e1.printStackTrace(); 
  266.         } 
  267.         if (connectionPool != null) { 
  268.             ShutdownPool(); 
  269.         } 
  270.         try { 
  271.             connectionPool = new GenericObjectPool(null); 
  272.             ConnectionFactory connectionFactory = new DriverManagerConnectionFactory( 
  273.                     url, username, password); 
  274.             PoolableConnectionFactory poolableConnectionFactory = new PoolableConnectionFactory( 
  275.                     connectionFactory, connectionPool, null, "SELECT 1", false, 
  276.                     true); 
  277.             Class.forName("org.apache.commons.dbcp.PoolingDriver"); 
  278.             PoolingDriver driver = (PoolingDriver) DriverManager 
  279.                     .getDriver("jdbc:apache:commons:dbcp:"); 
  280.             driver.registerPool(poolName, poolableConnectionFactory.getPool()); 
  281.   
  282.         } catch (Exception e) { 
  283.             e.printStackTrace(); 
  284.         } 
  285.         // 開啟查詢程序 
  286.         queryThread = new QueryThread(this); 
  287.         queryThread.start(); 
  288.     } 
  289.   
  290.     /** 
  291.      * 關閉連接池 
  292.      *  
  293.      * @author 宋立君 
  294.      * @date 2014年07月03日 
  295.      */ 
  296.     private void ShutdownPool() { 
  297.         try { 
  298.             PoolingDriver driver = (PoolingDriver) DriverManager 
  299.                     .getDriver("jdbc:apache:commons:dbcp:"); 
  300.             driver.closePool(poolName); 
  301.             // 關閉定時查詢 
  302.             queryThread.setStartQuery(false); 
  303.         } catch (SQLException e) { 
  304.             e.printStackTrace(); 
  305.         } 
  306.     } 
  307.   
  308.     /** 
  309.      * 得到一個連接 
  310.      *  
  311.      * @return 
  312.      * @author 宋立君 
  313.      * @date 2014年07月03日 
  314.      */ 
  315.     public synchronized Connection getConnection() { 
  316.         Connection conn = null; 
  317.         try { 
  318.             if (connectionPool == null) 
  319.                 StartPool(); 
  320.             conn = DriverManager.getConnection("jdbc:apache:commons:dbcp:" 
  321.                     + poolName); 
  322.         } catch (Exception e) { 
  323.             e.printStackTrace(); 
  324.         } 
  325.         return conn; 
  326.     } 
  327. } 
  328.   
  329. /** 
  330.  * 當連接池啟動后會自動定時查詢數據庫，防止數據庫連接超時。 
  331.  *  
  332.  * @author 宋立君 
  333.  * @date 2014年07月03日 
  334.  */ 
  335. class QueryThread extends Thread { 
  336.   
  337.     private DBUtil dbUtil = null; 
  338.     // 是否開啟查詢 
  339.     private boolean startQuery = true; 
  340.   
  341.     /** 
  342.      * 功能：對應的數據庫連接。 
  343.      *  
  344.      * @author 宋立君 
  345.      * @date 2014年07月03日 
  346.      * @param dbUtil 
  347.      *      數據庫連接 
  348.      */ 
  349.     public QueryThread(DBUtil dbUtil) { 
  350.         this.dbUtil = dbUtil; 
  351.     } 
  352.   
  353.     public void run() { 
  354.         while (true) { 
  355.             try { 
  356.                 if (startQuery) { 
  357.                     this.dbUtil.query("select 1"); 
  358.                 } 
  359.                 // System.out.println(startQuery+"  123"); 
  360.             } catch (Exception e) { 
  361.                 e.printStackTrace(); 
  362.             } finally { 
  363.                 try { 
  364.                     Thread.sleep(120000); 
  365.                 } catch (InterruptedException e) { 
  366.                     e.printStackTrace(); 
  367.                 } 
  368.             } 
  369.         } 
  370.     } 
  371.   
  372.     public void setStartQuery(boolean startQuery) { 
  373.         // System.out.println("startQuery shut:"+startQuery); 
  374.         this.startQuery = startQuery; 
  375.     } 
  376. } 

延伸 · 閱讀

精彩推薦
主站蜘蛛池模板： 母性本能在线观看 | 性色生活片在线观看 | 无限资源在线观看高清 | 91精品乱码一区二区三区 | 狠狠干快播 | 国产精品久久久久久久人人看 | 国产精品夜夜爽张柏芝 | 欧美日韩一区二区三区免费不卡 | 免费视频专区一国产盗摄 | 国产一级持黄大片99久久 | japan孕妇孕交freehd | 喜马拉雅听书免费版 | 精品视频一区二区三区 | 99热这里只有精品在线观看 | 午夜精品在线视频 | 青青草国产青春综合久久 | 成年人视频免费在线观看 | 欧美日韩一区二区综合 | 成人网欧美亚洲影视图片 | 国内在线播放 | 精品国产自在现线拍国语 | 国内精品视频一区二区三区 | 国产日韩欧美在线观看不卡 | 国产免费久久精品 | 日本免费一区二区三区 | 午夜理论电影在线观看亚洲 | 高清欧美videossexo免费 | 国产一区二区三区在线看 | 日本色频 | 久久五月综合婷婷中文云霸高清 | 亚洲欧美乱 | 欧美日韩亚洲综合久久久 | 极品美女aⅴ高清在线观看 极品ts赵恩静和直男激战啪啪 | 韩国丽卡三级作品 | 草草视频在线观看最新 | 精品国产自在天天线2019 | 国产精品最新资源网 | 亚洲妇熟xxxxx妇色黄 | 国产一级精品高清一级毛片 | 色综合久久丁香婷婷 | 午夜理论片日本中文在线 |