MySQL數據庫學習筆記（十一）----DAO設計模式實現數據庫的增刪改查（進一步封裝JDBC工具類）

【聲明】 

歡迎轉載，但請保留文章原始出處→_→ 

生命壹號：http://www.cnblogs.com/smyhvae/

文章來源：http://www.cnblogs.com/smyhvae/p/4059514.html

 

【正文】

一、DAO模式簡介

DAO即Data Access Object，數據訪問接口。數據訪問：故名思義就是與數據庫打交道。夾在業務邏輯與數據庫資源中間。

DAO模式實際上是兩個模式的組合，即Data Accessor (數據訪問者)模式和 Active Domain Object(領域對象)模式。Data Accessor 模式實現了數據訪問和業務邏輯的分離；Active Domain Object 模式實現了業務數據的對象化封裝。

需要注意的是，DAO設計模式是Java EE中的設計模式，而非Java SE中的23種設計模式。

 

二、實現DAO模式

一個典型的DAO實現有下列幾個組件：

• 一個DAO接口;
• 一個實現DAO接口的具體類; 
• 數據傳遞對象(DTO)：有些時候叫做值對象(VO)或領域模型（domain）

這種實現模式就是一個套路，記熟就好了。不過在這之前，如果有不明白的地方，還是要回顧一下之前幾篇博文中的知識：PreparedStatement接口重構增刪改查、封裝JDBC工具類。好了，下面直接上代碼。

 

三、代碼實現

我們一下面的這張數據表為例：

新建Java工程文件DaoTest01，最終的工程文件結構如下：

• DBUtils：初步封裝的JDBC工具類；
• db-config.properties：屬性文件，方便修改配置信息；
• Person類就是領域模型，表示是對它（數據庫表）進行增刪改查。
• PersonDao接口：專門對Person類進行操作（例如增刪改查）的接口。注：這里不直接寫操作類，是因為接口利於維護，可以在這里寫上公共的代碼。一個領域模型對應一個Dao接口。
• PeronDaoImpl類：實現上面的PeronDao接口

步驟如下：

注：第（1）、（2）步操作和上一篇博文是一模一樣的，這里只是為了保證本篇文章的完整性，所以重新寫一下。

（1）先新建一個DBUtils工具類：（package com.util.db）

package com.util.db;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ResourceBundle;

/**
 * 數據庫操作工具類
 * @author lamp
 *
 */
public class DBUtils {
    
    //數據庫連接地址
    public static String URL;
    //用戶名
    public static String USERNAME;
    //密碼
    public static String PASSWORD;
    //mysql的驅動類
    public static String DRIVER;
    
    private static ResourceBundle rb = ResourceBundle.getBundle("com.util.db.db-config");
    
    private DBUtils(){}
    
    //使用靜態塊加載驅動程序
    static{
        URL = rb.getString("jdbc.url");
        USERNAME = rb.getString("jdbc.username");
        PASSWORD = rb.getString("jdbc.password");
        DRIVER = rb.getString("jdbc.driver");
        try {
            Class.forName(DRIVER);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }
    //定義一個獲取數據庫連接的方法
    public static Connection getConnection(){
        Connection conn = null;
        try {
            conn = DriverManager.getConnection(URL, USERNAME, PASSWORD);
        } catch (SQLException e) {
            e.printStackTrace();
            System.out.println("獲取連接失敗");
        }
        return conn;
    }
    
    /**
     * 關閉數據庫連接
     * @param rs
     * @param stat
     * @param conn
     */
    public static void close(ResultSet rs,Statement stat,Connection conn){
            try {
                if(rs!=null)rs.close();
                if(stat!=null)stat.close();
                if(conn!=null)conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
    }
    
}

注意：26行中，注意獲取屬性文件的包名是否正確。稍后會定義這個屬性文件。

28行：既然是工具類，一般不要實例化，此時可以采用單例設計模式，或者將構造方法私有化。

26行：很明顯可以看到，我們是將連接數據庫的URL、用戶名，密碼等信息編寫在一個屬性文件（jdbc.properties）中，稍后再來定義這個屬性文件。

31行：為避免重復代碼，使用靜態代碼塊：只會在類加載的時候執行一次。

42行：定義一個獲取數據庫連接的方法

60行：關閉數據庫連接

（2）接下來新建一個屬性文件，new-->file，命名為：db-config.properties，代碼如下：

jdbc.url=jdbc:mysql://localhost:3306/jdbcdb
jdbc.username=root
jdbc.password=smyh
jdbc.driver=com.mysql.jdbc.Driver

以后如果需要修改配置信息，只需要在這里改就行了。注意在上面的DBUtils類中是怎么來調用這個配置信息的。

緊接着新建文件，定義好Person類：(package com.vae.domain)

package com.vae.domain;

public class Person {
    private int id;
    private String name;
    private int age;
    private String description;
    public int getId() {
        return id;
    }
    public void setId(int id) {
        this.id = id;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public int getAge() {
        return age;
    }
    public void setAge(int age) {
        this.age = age;
    }
    public String getDescription() {
        return description;
    }
    public void setDescription(String description) {
        this.description = description;
    }
    public Person(int id, String name, int age, String description) {
        super();
        this.id = id;
        this.name = name;
        this.age = age;
        this.description = description;
    }
    public Person(String name, int age, String description) {
        super();
        this.name = name;
        this.age = age;
        this.description = description;
    }
    public Person() {
        super();
        // TODO Auto-generated constructor stub
    }
    @Override
    public String toString() {
        return "Person [id=" + id + ", name=" + name + ", age=" + age
                + ", description=" + description + "]";
    }
    
    
}

這個Person類就是領域模型，表示是對它進行增刪改查。

（3）定義PersonDao接口：專門對Person類進行操作（例如增刪改查）的接口(package com.vae.dao)

package com.vae.dao;

import java.sql.SQLException;
import java.util.List;

import com.vae.domain.Person;

public interface PersonDao {
    //添加方法
    public void add(Person p)throws SQLException;
    
    //更新方法
    public void update(Person p)throws SQLException;
    
    //刪除方法
    public void delete(int id)throws SQLException;
    
    //查找方法
    public Person findById(int id)throws SQLException;
    
    //查找所有
    public List<Person> findAll()throws SQLException;
    
} 

（4）定義PeronDaoImpl實現類 ，實現上面的PeronDao接口（package com.vae.dao.impl）

package com.vae.dao.impl;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import com.util.db.DBUtils;
import com.vae.dao.PersonDao;
import com.vae.domain.Person;

/**
 * PersonDao的具體實現類
 * @author lamp
 *
 */
public class PersonDaoImpl implements PersonDao{

    /**
     * 實現添加方法
     */
    @Override
    public void add(Person p) throws SQLException {
        Connection conn = null;
        PreparedStatement ps = null;
        String sql = "insert into person(name,age,description)values(?,?,?)";
        try{
            conn = DBUtils.getConnection();
            ps = conn.prepareStatement(sql);
            ps.setString(1, p.getName());
            ps.setInt(2, p.getAge());
            ps.setString(3, p.getDescription());
            ps.executeUpdate();
        }catch(SQLException e){
            e.printStackTrace();
            throw new SQLException("添加數據失敗");
        }finally{
            DBUtils.close(null, ps, conn);
        }
    }

    /**
     * 更新方法
     */
    @Override
    public void update(Person p) throws SQLException {
        Connection conn = null;
        PreparedStatement ps = null;
        String sql = "update person set name=?,age=?,description=? where id=?";
        try{
            conn = DBUtils.getConnection();
            ps = conn.prepareStatement(sql);
            ps.setString(1, p.getName());
            ps.setInt(2, p.getAge());
            ps.setString(3, p.getDescription());
            ps.setInt(4, p.getId());
            ps.executeUpdate();
        }catch(SQLException e){
            e.printStackTrace();
            throw new SQLException("更新數據失敗");
        }finally{
            DBUtils.close(null, ps, conn);
        }        
    }

    /**
     * 刪除方法
     */
    @Override
    public void delete(int id) throws SQLException {
        Connection conn = null;
        PreparedStatement ps = null;
        String sql = "delete from person where id=?";
        try{
            conn = DBUtils.getConnection();
            ps = conn.prepareStatement(sql);
            ps.setInt(1,id);
            ps.executeUpdate();
        }catch(SQLException e){
            e.printStackTrace();
            throw new SQLException(" 刪除數據失敗");
        }finally{
            DBUtils.close(null, ps, conn);
        }        
    }

    /**
     * 根據ID查詢一個對象
     */
    @Override
    public Person findById(int id) throws SQLException {
        Connection conn = null;
        PreparedStatement ps = null;
        ResultSet rs = null;
        Person p = null;
        String sql = "select name,age,description from person where id=?";
        try{
            conn = DBUtils.getConnection();
            ps = conn.prepareStatement(sql);
            ps.setInt(1, id);
            rs = ps.executeQuery();
            if(rs.next()){
                p = new Person();
                p.setId(id);
                p.setName(rs.getString(1));
                p.setAge(rs.getInt(2));
                p.setDescription(rs.getString(3));
            }
        }catch(SQLException e){
            e.printStackTrace();
            throw new SQLException("根據ID查詢數據失敗");
        }finally{
            DBUtils.close(rs, ps, conn);
        }
        return p;
    }

    /**
     * 查詢所有數據
     */
    @Override
    public List<Person> findAll() throws SQLException {
        Connection conn = null;
        PreparedStatement ps = null;
        ResultSet rs = null;
        Person p = null;
        List<Person> persons = new ArrayList<Person>();
        String sql = "select id,name,age,description from person";
        try{
            conn = DBUtils.getConnection();
            ps = conn.prepareStatement(sql);
            rs = ps.executeQuery();
            while(rs.next()){
                p = new Person();
                p.setId(rs.getInt(1));
                p.setName(rs.getString(2));
                p.setAge(rs.getInt(3));
                p.setDescription(rs.getString(4));
                persons.add(p);
            }
        }catch(SQLException e){
            e.printStackTrace();
            throw new SQLException("查詢所有數據失敗");
        }finally{
            DBUtils.close(rs, ps, conn);
        }
        return persons;
    }

}

我們在各自的增刪改查里都拋出了異常，如果出現異常，就會拋出相應的錯誤信息。

總結：這樣的話，我們就封裝好了JDBC的工具類。以后如果要用的話，可以直接在主方法里調用這個類就行了。

【工程文件】

鏈接：http://pan.baidu.com/s/1qW6tew8

密碼：t98s