大資料專案實戰之八:8.JDBC元件開發
/**
* JDBC輔助元件
* 在正式的專案的程式碼編寫過程中，是完全嚴格按照大公司的coding標準來的
* 也就是說，在程式碼中，是不能出現任何hard code（硬編碼）的字元
* 比如“張三”、“com.mysql.jdbc.Driver”
* 所有這些東西，都需要通過常量來封裝和使用
*/
public class JDBCHelper {
// 第一步：在靜態程式碼塊中，直接載入資料庫的驅動
// 載入驅動，不是直接簡單的，使用com.mysql.jdbc.Driver就可以了
// 之所以說，不要硬編碼，他的原因就在於這裡
//
// com.mysql.jdbc.Driver只代表了MySQL資料庫的驅動
// 那麼，如果有一天，我們的專案底層的資料庫要進行遷移，比如遷移到Oracle
// 或者是DB2、SQLServer
// 那麼，就必須很費勁的在程式碼中，找，找到硬編碼了com.mysql.jdbc.Driver的地方，然後改成
// 其他資料庫的驅動類的類名
// 所以正規專案，是不允許硬編碼的，那樣維護成本很高
//
// 通常，我們都是用一個常量介面中的某個常量，來代表一個值
// 然後在這個值改變的時候，只要改變常量介面中的常量對應的值就可以了
//
// 專案，要儘量做成可配置的
// 就是說，我們的這個資料庫驅動，更進一步，也不只是放在常量介面中就可以了
// 最好的方式，是放在外部的配置檔案中，跟程式碼徹底分離
// 常量介面中，只是包含了這個值對應的key的名字
static { try { String driver = ConfigurationManager.getProperty(Constants.JDBC_DRIVER); Class.forName(driver); } catch (Exception e) { e.printStackTrace(); } }
// 第二步，實現JDBCHelper的單例化
// 為什麼要實現單例化呢？因為它的內部要封裝一個簡單的內部的資料庫連線池
// 為了保證資料庫連線池有且僅有一份，所以就通過單例的方式
// 保證JDBCHelper只有一個例項，例項中只有一份資料庫連線池
private static JDBCHelper instance = null; /**
* 獲取單例
*
* @return 單例
*/
public static JDBCHelper getInstance() {
if (instance == null) {
synchronized (JDBCHelper.class) {
if (instance == null) {
instance = new JDBCHelper();
}
}
}
return instance;
} // 資料庫連線池
private LinkedList<Connection> datasource = new LinkedList<Connection>(); /**
* 第三步：實現單例的過程中，建立唯一的資料庫連線池
* <p>
* 私有化構造方法
* <p>
* JDBCHelper在整個程式執行宣告週期中，只會建立一次例項
* 在這一次建立例項的過程中，就會呼叫JDBCHelper()構造方法
* 此時，就可以在構造方法中，去建立自己唯一的一個數據庫連線池
*/
private JDBCHelper() {
// 首先第一步，獲取資料庫連線池的大小，就是說，資料庫連線池中要放多少個數據庫連線
// 這個，可以通過在配置檔案中配置的方式，來靈活的設定
int datasourceSize = ConfigurationManager.getInteger(
Constants.JDBC_DATASOURCE_SIZE);
// 然後建立指定數量的資料庫連線，並放入資料庫連線池中
for (int i = 0; i < datasourceSize; i++) {
String url = ConfigurationManager.getProperty(Constants.JDBC_URL);
String user = ConfigurationManager.getProperty(Constants.JDBC_USER);
String password = ConfigurationManager.getProperty(Constants.JDBC_PASSWORD);
try {
Connection conn = DriverManager.getConnection(url, user, password);
datasource.push(conn);
} catch (Exception e) {
e.printStackTrace();
}
}
} /**
* 第四步，提供獲取資料庫連線的方法
* 有可能，你去獲取的時候，這個時候，連線都被用光了，你暫時獲取不到資料庫連線
* 所以我們要自己編碼實現一個簡單的等待機制，去等待獲取到資料庫連線
*/
public synchronized Connection getConnection() {
while (datasource.size() == 0) {
try {
Thread.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
return datasource.poll();
}/**
* 第五步：開發增刪改查的方法
* 1、執行增刪改SQL語句的方法
* 2、執行查詢SQL語句的方法
* 3、批量執行SQL語句的方法
*/ /**
* 執行增刪改SQL語句
*
* @param sql
* @param params
* @return 影響的行數
*/
public int executeUpdate(String sql, Object[] params) {
int rtn = 0;
Connection conn = null;
PreparedStatement pstmt = null;
try {
conn = getConnection();
pstmt = conn.prepareStatement(sql);
for (int i = 0; i < params.length; i++) {
pstmt.setObject(i + 1, params[i]);
}
rtn = pstmt.executeUpdate();
} catch (Exception e) {
e.printStackTrace();
} finally {
if (conn != null) {
datasource.push(conn);
}
}
return rtn;
} /**
* 執行查詢SQL語句
*
* @param sql
* @param params
* @param callback
*/
public void executeQuery(String sql, Object[] params,
QueryCallback callback) {
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
try {
conn = getConnection();
pstmt = conn.prepareStatement(sql);
for (int i = 0; i < params.length; i++) {
pstmt.setObject(i + 1, params[i]);
}
rs = pstmt.executeQuery();
callback.process(rs);
} catch (Exception e) {
e.printStackTrace();
} finally {
if (conn != null) {
datasource.push(conn);
}
}
} /**
* 批量執行SQL語句
* <p>
* 批量執行SQL語句，是JDBC中的一個高階功能
* 預設情況下，每次執行一條SQL語句，就會通過網路連線，向MySQL傳送一次請求
* <p>
* 但是，如果在短時間內要執行多條結構完全一模一樣的SQL，只是引數不同
* 雖然使用PreparedStatement這種方式，可以只編譯一次SQL，提高效能，但是，還是對於每次SQL
* 都要向MySQL傳送一次網路請求
* <p>
* 可以通過批量執行SQL語句的功能優化這個效能
* 一次性通過PreparedStatement傳送多條SQL語句，比如100條、1000條，甚至上萬條
* 執行的時候，也僅僅編譯一次就可以
* 這種批量執行SQL語句的方式，可以大大提升效能
*
* @param sql
* @param paramsList
* @return 每條SQL語句影響的行數
*/
public int[] executeBatch(String sql, List<Object[]> paramsList) {
int[] rtn = null;
Connection conn = null;
PreparedStatement pstmt = null;
try {
conn = getConnection();
// 第一步：使用Connection物件，取消自動提交
conn.setAutoCommit(false);
pstmt = conn.prepareStatement(sql);
// 第二步：使用PreparedStatement.addBatch()方法加入批量的SQL引數
for (Object[] params : paramsList) {
for (int i = 0; i < params.length; i++) {
pstmt.setObject(i + 1, params[i]);
}
pstmt.addBatch();
}
// 第三步：使用PreparedStatement.executeBatch()方法，執行批量的SQL語句
rtn = pstmt.executeBatch();
// 最後一步：使用Connection物件，提交批量的SQL語句
conn.commit();
} catch (Exception e) {
e.printStackTrace();
}
return rtn;
}
/**
* 靜態內部類：查詢回撥介面
*
* @author Administrator
*/
public static interface QueryCallback {
/**
* 處理查詢結果
*
* @param rs
* @throws Exception
*/
void process(ResultSet rs) throws Exception;
}}