大資料專案實戰之八: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;
}
}