原文鏈接
前言：在講解Web開發模式的時候，曾經寫過XML版的用戶登陸注冊案例！現在在原有的項目上，使用數據庫版來完成用戶的登陸注冊！
本來使用的是XML文件作為小型數據庫，現在使用Mysql數據庫，代碼究竟要改多少呢？？
使用C3P0--數據庫連接池
導入C3P0的開發包和導入配置文件
開發包導入的是這個：c3p0-0.9.2-pre1和mchange-commons-0.2.jar.
<dependency> <groupId>com.mchange</groupId> <artifactId>c3p0</artifactId> <version>0.9.5.2</version> </dependency> <dependency> <groupId>com.mchange</groupId> <artifactId>mchange-commons-java</artifactId> <version>0.2.15</version> </dependency>
C3P0不僅性能好，而且配置文件可以使用XML文檔來配置！
類似的配置文件可以在官方文檔上找得到！
我們來改造一下：
<?xml version="1.0" encoding="UTF-8"?> <c3p0-config> <default-config> <property name="driverClass">com.mysql.cj.jdbc.Driver</property> <property name="jdbcUrl">jdbc:mysql://localhost:3306/first?&serverTimezone=UTC</property> <property name="user">root</property> <property name="password">root</property> <property name="acquireIncrement">5</property> <property name="initialPoolSize">10</property> <property name="minPoolSize">5</property> <property name="maxPoolSize">20</property> </default-config> <named-config name="mysql"> <property name="driverClass">com.mysql.cj.jdbc.Driver</property> <property name="jdbcUrl">jdbc:mysql://localhost:3306/first?&serverTimezone=UTC</property> <property name="user">root</property> <property name="password">root</property> <property name="acquireIncrement">5</property> <property name="initialPoolSize">10</property> <property name="minPoolSize">5</property> <property name="maxPoolSize">20</property> </named-config> <named-config name="oracle"> <property name="driverClass">oracle.jdbc.driver.OracleDriver</property> <property name="jdbcUrl">jdbc:oracle:thin:@//localhost:1521/事例名...</property> <property name="user">用戶名</property> <property name="password">密碼</property> <property name="acquireIncrement">5</property> <property name="initialPoolSize">10</property> <property name="minPoolSize">5</property> <property name="maxPoolSize">20</property> </named-config> </c3p0-config>
注意：使用高版本MySQL8.0和mysql-connector-java:8.0.15驅動(用Maven導包)時:
1、driverClass為com.mysql.cj.jdbc.Driver，而不是com.mysql.jdbc.Driver。
2、jdbcUrl后面一定要設置時區：serverTimezone（如果用IDEA直連MySQL數據庫也要設置！如下圖）
3、如果直連時提示沒有驅動，而IDEA自動下載失敗時(Class那一欄也要改成com.mysql.cj.jdbc.Driver，雖然我還是自動下載失敗)，可以手動導入(如果Maven過，在本地倉庫找包)
4.查看官方文檔，mysql-connector-java:8.0.15驅動需要JDK1.8.x。
| Connector/J version | JDBC version | MySQL Server version | JRE Supported | JDK Required for Compilation | Status |
|---|---|---|---|---|---|
| 8.0 | 4.2 | 5.6, 5.7, 8.0 | 1.8.x | 1.8.x | General availability. Recommended version. |
| 5.1 | 3.0, 4.0, 4.1, 4.2 | 5.6*, 5.7*, 8.0* | 1.5.x, 1.6.x, 1.7.x, 1.8.x* | 1.5.x and 1.8.x | General availability |
* JRE 1.8.x is required for Connector/J 5.1 to connect to MySQL 5.6, 5.7, and 8.0 with SSL/TLS when using some cipher suites.
寫獲取連接的工具類DBUtils
public class DBUtils { private static ComboPooledDataSource comboPooledDataSource = null; static { //它會自動尋找配置文件，節點為mysql的數據庫【如果沒有指定，就使用默認的！】 comboPooledDataSource = new ComboPooledDataSource("mysql"); } public static DataSource getDataSource() { return comboPooledDataSource ; } public static Connection getConnection() { try { return comboPooledDataSource.getConnection(); } catch (SQLException e) { e.printStackTrace(); throw new RuntimeException("數據庫初始化失敗了！"); } } }
設計數據庫表
根據實體表來設計就好了！(如果直連了IDEA就直接new Table，否則用navicat，當然命令行也行)
CREATE TABLE user ( id VARCHAR(20) PRIMARY KEY, username VARCHAR(20) UNIQUE NOT NULL, password VARCHAR(20) NOT NULL, email VARCHAR(20), birthday DATE );
寫一個操作數據庫的Dao實現
public class UserImplDataBase implements UserDao { public User find(String username, String password) { return null; } public void register(User user) { } }
下面我們就直接使用dbutils框架了
-
導入dbutils的開發包
<dependency> <groupId>commons-dbutils</groupId> <artifactId>commons-dbutils</artifactId> <version>1.6</version> </dependency>
具體的代碼如下
@Override public User find(String username, String password) { QueryRunner queryRunner = new QueryRunner(DBUtils.getDataSource()); String sql = "SELECT * FROM user WHERE username=? AND password=?"; try { User user = (User) queryRunner.query(sql, new BeanHandler(User.class), new Object[]{username, password}); return user; } catch (SQLException e) { e.printStackTrace(); throw new RuntimeException("登陸失敗了！"); } } @Override public void register(User user) { QueryRunner queryRunner = new QueryRunner(DBUtils.getDataSource()); String sql = "INSERT INTO user (id, username, password, email,birthday) VALUES (?,?,?,?,?);"; String id = user.getId(); String username = user.getUsername(); String password = user.getPassword(); String email = user.getEmail(); Date date = user.getBirthday(); try { queryRunner.update(sql, new Object[]{id, username, password, email,date}); } catch (SQLException e) { e.printStackTrace(); throw new RuntimeException("注冊失敗了"); } } }
開發DaoFactory
我們的Dao實現已經有了XML版和JDBC版的，BusinessService調用Dao層方法的時候還是要new出具體的Dao實現，也就是以下的代碼：
UserDao userDao = new UserImplXML(); //或者 UserDao userDao= new UserImplDataBase();
這樣做有點不夠靈活，也就有點不夠專業！下面我們來說一下為什么需要DaoFactory？
-
為什么需要DaoFactory？
參考博文：http://blog.sina.com.cn/s/blog_4ca34d0501008tpc.html
摘抄重點：
優點：
透明化:商業對象可以在完全不知道數據源如何具體實現的情況下來使用數據源. 訪問數據源是透明的,因為實現細節已經被隱藏進了DAO.
遷移簡單化:DAO 層的出現,使得應用程序向不同的數據庫實現進行遷移變的容易.商業對象可以對底層數據實現一無所知.這樣,遷移只涉及到了對DAO層的修改. 另外,如果使用工廠策略,則使為每一種底層數據實現提供一個具體的工廠實現成為可能.在這種情況下,遷移到一種不同的數據實現,其實就相當於為這個應用程序再提供一個新的工廠實現.
減少在商業對象中的編程難度:由於DAO管理着所有的數據訪問細節,因而大大簡化了在商業對象和其他使用DAO的數據客戶端里的代碼.所有的實現細節相關的代碼比如(SQL 語句)都包含在DAO而不在商業對象中. 這樣使得代碼變的更加健壯而且大大提高了開發效率.
將所有的數據訪問都單獨集中到一層中去：因為所有的數據訪問操作現在都已經被DAO所代理,所以這個單獨的數據訪問層可以被看作可以是將數據訪問實現和其余應用程序相互隔離的一層. 這樣的集中,使得應用程序可以更加容易的來維護和管理.
缺點：
增加了多余的層：由於DAO在數據客戶端和數據源之外多創建了一層對象,因而,需要對他進行設計和實現,來均衡這個設計模式的利弊. 但是,一般來說,采用此設計模式還是利大於弊的.
需要對類的相互繼承關系進行設計：當使用工廠策略的時候,具體工廠類的繼承關系和由這些工廠類生成的產品需要進行設計和實現. 我們需要仔細考慮這些多付出的工作是否真的可以產生出來更高的靈活性. 使用這個策略會使設計變的更加復雜,然而,你可以先從工廠方法模式開始來實現這個策略,然后在需要的情況下再轉向抽象工廠
-
設計DaoFactory
首先，我們把DaoFactory設計成單例的【工廠有一個就夠了！】
public class DaoFactory { private DaoFactory() { } private static final DaoFactory DAO_FACTORY = new DaoFactory(); //暴露公開方法獲取工廠對象 public static DaoFactory newInstance() { return DAO_FACTORY; } }
目前我們操作的是User，所以工廠造UserDao對象，而UserDao對象是JDBC版呢，還是XML版呢，我們通過配置文件來定（這樣就更靈活了）！
-
-
在resources目錄下加入配置文件
-
注意：不要加""字符串的符號！
-
#class需要的是完整的對象名稱(包括包)
userClass=dao.UserImplDataBase
#userClass=dao.UserImplXML
讀取配置文件的信息，創建相對應的UserDao對象，直接在構造函數做就行了（其實就是個初始化的操作罷了）
private static UserDao userDao = null; private DaoFactory() { try { //讀取配置文件的信息 InputStream inputStream = DaoFactory.class.getClassLoader().getResourceAsStream("UserDao.properties"); Properties properties = new Properties(); properties.load(inputStream); String userClass = properties.getProperty("userClass"); //利用反射機制創建相對應的對象 userDao = (UserDao) Class.forName(userClass).newInstance(); } catch (IOException e) { e.printStackTrace(); throw new RuntimeException("讀取文件失敗了！"); } catch (IllegalAccessException e) { e.printStackTrace(); throw new RuntimeException("反射失敗了！"); } catch (InstantiationException e) { e.printStackTrace(); throw new RuntimeException("反射失敗了！"); } catch (ClassNotFoundException e) { e.printStackTrace(); throw new RuntimeException("反射失敗了！"); } } public static UserDao createUserDao() { return userDao; }
在Service層中改用DaoFactory獲取UserDao對象
UserDao userDao = DaoFactory.newInstance().createUserDao();