Oracle連接池工具類OJDBCUtils

Oraclejdbc.properties

 OJDBCUtils.java

 1 package com.yidu.demo.util;
 2 
 3 import oracle.jdbc.pool.OracleDataSource;
 4 import javax.sql.DataSource;
 5 import java.io.IOException;
 6 import java.io.InputStream;
 7 import java.sql.Connection;
 8 import java.sql.ResultSet;
 9 import java.sql.SQLException;
10 import java.sql.Statement;
11 import java.util.Properties;
12 
13 
14 /*
15     1. 聲明靜態數據源成員變數
16     2. 創建連接池對象
17     3. 定義公有的得到數據源的方法
18     4. 定義得到連接對象的方法
19     5. 定義關閉資源的方法
20 */
21 public class OJDBCUtils {
22     // 1.    聲明靜態數據源成員變數
23     private static OracleDataSource ds;
24     // 2. 創建連接池對象
25     static {
26         // 載入配置文件中的數據
27         InputStream is = OJDBCUtils.class.getClassLoader().getResourceAsStream("Oraclejdbc.properties");
28         Properties pp = new Properties();
29         try {
30             pp.load(is);
31             // 創建連接池，使用配置文件中的參數
32             ds = new OracleDataSource();
33             ds.setDriverType(pp.getProperty("driverClassName"));
34             ds.setURL(pp.getProperty("url"));
35             ds.setUser(pp.getProperty("username"));
36             ds.setPassword(pp.getProperty("password"));
37         } catch (IOException e) {
38             e.printStackTrace();
39         } catch (Exception e) {
40             e.printStackTrace();
41         }
42     }
43     // 3. 定義公有的得到數據源的方法
44     public static DataSource getDataSource() {
45         return ds;
46     }
47     // 4. 定義得到連接對象的方法
48     public static Connection getConnection() throws SQLException {
49         return ds.getConnection();
50     }
51     // 5.定義關閉資源的方法
52     public static void close(Connection conn, Statement stmt, ResultSet rs) {
53         if (rs != null) {
54             try {
55                 rs.close();
56             } catch (SQLException e) {}
57         }
58         if (stmt != null) {
59             try {
60                 stmt.close();
61             } catch (SQLException e) {}
62         }
63         if (conn != null) {
64             try {
65                 conn.close();
66             } catch (SQLException e) {}
67         }
68     }
69     // 6.重載關閉方法
70     public static void close(Connection conn, Statement stmt) {
71         close(conn, stmt, null);
72     }
73 }