Constants.java
/**
* 常量接口
* @author Administrator
*
*/
public interface Constants {
/**
* 數(shù)據(jù)庫相關(guān)的常量
*/
String JDBC_DRIVER = "jdbc.driver";
String JDBC_DATASOURCE_SIZE = "jdbc.datasource.size";
String JDBC_URL = "jdbc.url";
String JDBC_USER = "jdbc.user";
String JDBC_PASSWORD = "jdbc.password";
}
JDBCHelper .java
import java.sql.Connection;
import java.sql.DriverManager;
import java.util.LinkedList;
import com.ibeifeng.sparkproject.conf.ConfigurationManager;
import com.ibeifeng.sparkproject.constant.Constants;
/**
* JDBC輔助組件
*
* 在正式的項目的代碼編寫過程中，是完全嚴格按照大公司的coding標準來的
* 也就是說，在代碼中，是不能出現(xiàn)任何hard code（硬編碼）的字符
* 比如“張三”澜搅、“com.mysql.jdbc.Driver”
* 所有這些東西背伴，都需要通過常量來封裝和使用
*
* @author Administrator
*
*/
public class JDBCHelper {
// 第一步：在靜態(tài)代碼塊中椭赋，直接加載數(shù)據(jù)庫的驅(qū)動
// 加載驅(qū)動茧痒，不是直接簡單的选侨，使用com.mysql.jdbc.Driver就可以了
// 之所以說良蛮，不要硬編碼抽碌，他的原因就在于這里
//
// com.mysql.jdbc.Driver只代表了MySQL數(shù)據(jù)庫的驅(qū)動
// 那么，如果有一天决瞳，我們的項目底層的數(shù)據(jù)庫要進行遷移货徙，比如遷移到Oracle
// 或者是DB2、SQLServer
// 那么皮胡，就必須很費勁的在代碼中痴颊，找，找到硬編碼了com.mysql.jdbc.Driver的地方屡贺，然后改成
// 其他數(shù)據(jù)庫的驅(qū)動類的類名
// 所以正規(guī)項目袱耽，是不允許硬編碼的，那樣維護成本很高
//
// 通常时甚，我們都是用一個常量接口中的某個常量，來代表一個值
// 然后在這個值改變的時候糕再，只要改變常量接口中的常量對應(yīng)的值就可以了
//
// 項目，要盡量做成可配置的
// 就是說玉转，我們的這個數(shù)據(jù)庫驅(qū)動突想，更進一步，也不只是放在常量接口中就可以了
// 最好的方式冤吨，是放在外部的配置文件中蒿柳，跟代碼徹底分離
// 常量接口中饶套，只是包含了這個值對應(yīng)的key的名字
static {
try {
String driver = ConfigurationManager.getProperty(Constants.JDBC_DRIVER);
Class.forName(driver);
} catch (Exception e) {
e.printStackTrace();
}
}
// 第二步漩蟆，實現(xiàn)JDBCHelper的單例化
// 為什么要實現(xiàn)代理化呢？因為它的內(nèi)部要封裝一個簡單的內(nèi)部的數(shù)據(jù)庫連接池
// 為了保證數(shù)據(jù)庫連接池有且僅有一份妓蛮，所以就通過單例的方式
// 保證JDBCHelper只有一個實例怠李，實例中只有一份數(shù)據(jù)庫連接池
private static JDBCHelper instance = null;
/**
* 獲取單例
* @return 單例
*/
public static JDBCHelper getInstance() {
if(instance == null) {
synchronized(JDBCHelper.class) {
if(instance == null) {
instance = new JDBCHelper();
}
}
}
return instance;
}
// 數(shù)據(jù)庫連接池
private LinkedList<Connection> datasource = new LinkedList<Connection>();
/**
*
* 第三步：實現(xiàn)單例的過程中，創(chuàng)建唯一的數(shù)據(jù)庫連接池
*
* 私有化構(gòu)造方法
*
* JDBCHelper在整個程序運行聲明周期中蛤克，只會創(chuàng)建一次實例
* 在這一次創(chuàng)建實例的過程中捺癞，就會調(diào)用JDBCHelper()構(gòu)造方法
* 此時，就可以在構(gòu)造方法中构挤，去創(chuàng)建自己唯一的一個數(shù)據(jù)庫連接池
*
*/
private JDBCHelper() {
// 首先第一步髓介，獲取數(shù)據(jù)庫連接池的大小，就是說筋现，數(shù)據(jù)庫連接池中要放多少個數(shù)據(jù)庫連接
// 這個唐础，可以通過在配置文件中配置的方式，來靈活的設(shè)定
int datasourceSize = ConfigurationManager.getInteger(
Constants.JDBC_DATASOURCE_SIZE);
// 然后創(chuàng)建指定數(shù)量的數(shù)據(jù)庫連接矾飞，并放入數(shù)據(jù)庫連接池中
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();
}
}
}
/**
* 第四步一膨，提供獲取數(shù)據(jù)庫連接的方法
* 有可能，你去獲取的時候洒沦，這個時候豹绪，連接都被用光了，你暫時獲取不到數(shù)據(jù)庫連接
* 所以我們要自己編碼實現(xiàn)一個簡單的等待機制申眼，去等待獲取到數(shù)據(jù)庫連接
*
*/
public synchronized Connection getConnection() {
while(datasource.size() == 0) {
try {
Thread.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
return datasource.poll();
}
}
