jdbc-DAO的實現

什么是 DAO

DAO(Data Access Object)是一個數據訪問接口，夾在業務邏輯與數據庫資源中間。

在核心J2EE模式中是這樣介紹DAO模式的：為了建立一個健壯的J2EE應用，應該將所有對數據源的訪問操作抽象封裝在一個公共API中。用程序設計的語言來說，就是建立一個接口，接口中定義了此應用程序中將會用到的所有事務方法。在這個應用程序中，當需要和數據源進行交互的時候則使用這個接口，並且編寫一個單獨的類來實現這個接口在邏輯上對應這個特定的數據存儲。DAO中的主要操作:增刪改查(CRUD).

DAO的實現

實現的步驟一般是：

• 先建立模型的對象domain
• 編寫DAO接口
• 定義DAO實現類
• 生產DAO測試類
• 在DAO測試類中測試方法

一般的規范是分domain包和dao包，dao包中有DAO接口，接口名為IXxxDAO,實現類為XxxDAO,創建實現類對象賦給接口，體現多態。還有一個測試類名為XxxTestDAOTest.如：

DAO接口：

public interface IStudentDAO {
    /**
     * 保存學生對象
     * @param stu 需要保存的學生
     */
    void save(Student stu);

    /**
     * 刪除指定id的學生
     * @param id  需要刪除的學生的id
     */
    void delete(int id);

    /**
     * 更改操作
     * @param newStu 更改后的學生對象，根據id更改
     */
    void update(Student newStu);

    /**
     * 根據id查詢單個學生對象信息
     * @param id  需要查詢學生的id
     * @return  存在該學生返回學生對象  不存在則返回null
     */
    Student get(long id );

    /**
     * 查詢所有學生
     * @return  返回一個學生對象的集合
     */
    List<Student> list();
}

實現類：

public void save(Student stu) {
        String sql = "INSERT INTO s_student(name,age) VALUES('狗哲',21)";
        Connection conn = null;
        Statement st = null
        try {
            Class.forName("com.mysql.jdbc.Driver");
            conn = DriverManager.getConnection("jdbc:mysql:///demo","root","admin");
            st = conn.createStatement();
            st.executeUpdate(sql);
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            try{
                if(st != null){
                    st.close();
                }
            }catch (Exception e){
                e.printStackTrace();
            }finally {
                try{
                    if(conn != null){
                        conn.close();
                    }
                }catch (Exception e){
                    e.printStackTrace();
                }
            }
        }
    }
增刪改只有sql語句不一樣，省略
····
····
public List<Student> list() {
    String sql = "SELECT * FROM s_student";
    Connection conn = null;
    Statement st = null;
    ResultSet rs = null;
    List<Student> list = new ArrayList<>();
    try {
        Class.forName("com.mysql.jdbc.Driver");
        conn = DriverManager.getConnection("jdbc:mysql:///demo","root","admin");
        st = conn.createStatement();
        rs = st.executeQuery(sql);
        while(rs.next()){
            String name = rs.getString("name");
            Integer age = rs.getInt("age");
            list.add(new Student(name,age));
        }

    } catch (Exception e) {
        e.printStackTrace();
    }finally {
        try{
            if(st != null){
                st.close();
            }
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            try{
                if(conn != null){
                    conn.close();
                }
            }catch (Exception e){
                e.printStackTrace();
            }
        }
    }
    return  list;
}

DAO實現的重構

可以看出代碼重復非常之多，尤其是增刪改只有sql語句不一樣

• 1、定義一個JdbcUtil類，把加載注冊驅動放到靜態代碼塊中，因為沒有必要每次都去加載。
• 2、把url，classDriverName,username,password ,放在一個資源文件中，用加載資源文件的方式獲取這些值，保證了代碼的可維護性
• 3、異常處理代碼也放在工具類中，異常處理及其麻煩，影響代碼的美觀

public class JdbcUtil {
	private static Properties p = new Properties();
	//加載資源文件
	static{
		ClassLoader loader = Thread.currentThread().getContextClassLoader();
		InputStream inStream = loader.getResourceAsStream("db.properties");
		try {
			p.load(inStream);
			Class.forName(p.getProperty("classDriver"));
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	//獲取連接對象
	public static Connection getConn(){
		Connection conn = null;
		try {
			 conn = DriverManager.getConnection(p.getProperty("url"),p.getProperty("username"), p.getProperty("password"));
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return conn;
	}
	//關閉資源
	public static void close(Connection conn,Statement st,ResultSet rs){
		try{
			if(rs != null){
				rs.close();
			}
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			try{
				if(st != null){
					st.close();
				}
			}catch(Exception e){
				e.printStackTrace();
			}finally{
				try{
					if(conn != null){
						conn.close();
					}
				}catch(Exception e){
					e.printStackTrace();
				}
			}
		}
	}
}