摘要：在代理類(lèi)完成以后，最后還需要編寫(xiě)工廠類(lèi)，以降低代碼間的耦合度。工廠類(lèi)工廠類(lèi)的功能就是直接返回接口的實(shí)例化對(duì)象這樣客戶(hù)端就可以直接通過(guò)工廠類(lèi)取得接口的實(shí)例化對(duì)象。

DAO的開(kāi)發(fā)完全圍繞著數(shù)據(jù)進(jìn)行，先在數(shù)據(jù)庫(kù)中準(zhǔn)備幾個(gè)要用到的表：

sqlcreate table emp (
    empno int(4)    PRIMARY KEY,
    ename varchar(10),
    job varchar(9),
    hiredate    date,
    sal float(7,2)
    );

javapackage temp.vo;

import java.util.Date;

/**
 * Created by mcbird on 14/11/20.
 */
public class Emp {
    private int empno;
    private String ename;
    private String job;
    private Date hiredate;
    private float sal;

    public String getEname() {
        return ename;
    }

    public void setEname(String ename) {
        this.ename = ename;
    }

    public String getJob() {
        return job;
    }

    public void setJob(String job) {
        this.job = job;
    }

    public Date getHiredate() {
        return hiredate;
    }

    public void setHiredate(Date hiredate) {
        this.hiredate = hiredate;
    }

    public float getSal() {
        return sal;
    }

    public void setSal(float sal) {
        this.sal = sal;
    }

    public int getEmpno() {
        return empno;

    }

    public void setEmpno(int empno) {
        this.empno = empno;
    }
}

javapackage temp.dbc;


import java.sql.Connection;

/**
 * Created by mcbird on 14/11/20.
 */
public interface DatebaseConnection {
    public Connection getConnection() throws Exception;  // 取得數(shù)據(jù)庫(kù)連接
    public void close() throws Exception;                //關(guān)閉數(shù)據(jù)庫(kù)連接
}

javapackage temp.dbc.impl;

import temp.dbc.DatebaseConnection;

import java.sql.Connection;
import java.sql.DriverManager;

/**
 * Created by mcbird on 14/11/20.
 */
public class MySQLDatabaseConnection implements DatebaseConnection {
    private static final String DBDRIVER = "org.gjt.mm.mysql.Driver";
    private static final String DBURL = "jdbc://localhost:3306/temp";
    private static final String DBUSER = "root";
    private static final String DBPASSWORD = "cloudSoft@Skybility";
    private Connection conn = null;


    @Override
    public Connection getConnection() throws Exception {
        try {
            Class.forName(DBDRIVER);
            this.conn = DriverManager.getConnection(DBURL, DBUSER, DBPASSWORD);
        }catch (Exception e) {
            throw e;
        }
        return this.conn;
    }

    @Override
    public void close() throws Exception {
        if(this.conn != null) {
            try {
                this.conn.close();
            } catch (Exception e) {
                throw e;
            }
        }
    }
}

javapackage temp.dao;

import temp.vo.Emp;

import java.util.List;

/**
 * Created by mcbird on 14/11/20.
 */
public interface IEmpDAO {
    /**
     * 數(shù)據(jù)的增加操作
     * @param emp 要增加的數(shù)據(jù)對(duì)象
     * @return 是否成功增加標(biāo)志
     */
    public boolean doCreate(Emp emp) throws Exception;


    /**
     * 查詢(xún)?nèi)繑?shù)據(jù)
     * @param keyWord
     * @return
     * @throws Exception
     */
    public List findAll(String keyWord) throws Exception;

    /**
     * 根據(jù)編號(hào)查詢(xún)雇員信息
     * @param empno
     * @return
     * @throws Exception
     */
    public Emp findById(int empno) throws Exception;
}

javapackage temp.dao.impl;

import temp.dao.IEmpDAO;
import temp.vo.Emp;

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

/**
 * Created by mcbird on 14/11/20.
 */
public class EmpDAOImpl implements IEmpDAO {
    private Connection conn = null;
    private PreparedStatement pstmt = null;     //數(shù)據(jù)庫(kù)操作對(duì)象

    public EmpDAOImpl(Connection conn) {
        this.conn = conn;
    }

    @Override
    public boolean doCreate(Emp emp) throws Exception {
        boolean flag = false;
        String sql = "insert int emp (empno,ename,job,hiredate,sal) values (?,?,?,?,?)";
        this.pstmt = this.conn.prepareStatement(sql);
        this.pstmt.setInt(1, emp.getEmpno());
        this.pstmt.setString(2, emp.getEname());
        this.pstmt.setString(3, emp.getJob());
        this.pstmt.setDate(4, new Date(emp.getHiredate().getTime()));
        this.pstmt.setFloat(5, emp.getSal());

        if(this.pstmt.executeUpdate() > 0) {    //更新記錄的行數(shù)大于0
            flag = true;
        }
        this.pstmt.close();
        return flag;
    }

    @Override
    public List findAll(String keyWord) throws Exception {
        List all = new ArrayList();
        String sql = "select empno,ename,job,hiredate,sal from emp where ename like ? or job like ?";
        this.pstmt = this.conn.prepareStatement(sql);
        this.pstmt.setString(1, "%" + keyWord + "%");
        this.pstmt.setString(2, "%" + keyWord + "%");
        ResultSet rs = this.pstmt.executeQuery();
        Emp emp = null;
        while (rs.next()) {
            emp = new Emp();
            emp.setEmpno(rs.getInt(1));
            emp.setEname(rs.getString(2));
            emp.setJob(rs.getString(3));
            emp.setHiredate(rs.getDate(4));
            emp.setSal(rs.getFloat(5));
            all.add(emp);
        }
        this.pstmt.close();
        return all;
    }

    @Override
    public Emp findById(int empno) throws Exception {
        Emp emp = null;
        String sql = "select empno,ename,job,hiredate,sal from emp where empno=?";
        this.pstmt = this.conn.prepareStatement(sql);
        this.pstmt.setInt(1, empno);
        ResultSet rs = this.pstmt.executeQuery();
        if(rs.next()) {
            emp = new Emp();
            emp.setEmpno(rs.getInt(1));
            emp.setEname(rs.getString(2));
            emp.setJob(rs.getString(3));
            emp.setHiredate(rs.getDate(4));
            emp.setSal(rs.getFloat(5));
        }
        this.pstmt.close();
        return emp;
    }
}

javapackage temp.dao.proxy;

import temp.dao.IEmpDAO;
import temp.dao.impl.EmpDAOImpl;
import temp.dbc.DatebaseConnection;
import temp.dbc.impl.MySQLDatabaseConnection;
import temp.vo.Emp;

import java.util.List;

/**
 * Created by mcbird on 14/11/20.
 */
public class EmpDAOProxy implements IEmpDAO {
    private DatebaseConnection dbc = null;
    private IEmpDAO dao = null;
    public EmpDAOProxy() throws Exception {
        this.dbc = new MySQLDatabaseConnection();
        this.dao = new EmpDAOImpl(this.dbc.getConnection());
    }

    @Override
    public boolean doCreate(Emp emp) throws Exception {
        boolean flag = false;
        try {
            if (this.dao.findById(emp.getEmpno()) == null) {
                flag = this.dao.doCreate(emp);
            }
        } catch (Exception e) {
            throw e;
        } finally {
            this.dbc.close();
        }
        return flag;
    }

    @Override
    public List findAll(String keyWord) throws Exception {
        List all = null;
        try {
            all = this.findAll(keyWord);
        } catch (Exception e) {
            throw e;
        } finally {
            this.dbc.close();
        }
        return all;
    }

    @Override
    public Emp findById(int empno) throws Exception {
        Emp emp = null;
        try {
            emp = this.dao.findById(empno);
        } catch (Exception e) {
            throw e;
        } finally {
            this.dbc.close();
        }
        return emp;
    }
}

javapackage temp.dao.factory;

import temp.dao.IEmpDAO;
import temp.dao.proxy.EmpDAOProxy;

/**
 * Created by mcbird on 14/11/20.
 */
public class DAOFactory {
    public static IEmpDAO getIEmpDAOInstance() throws Exception {
        return new EmpDAOProxy();
    }
}

javapackage temp.test;

import temp.dao.factory.DAOFactory;
import temp.vo.Emp;

import java.util.Date;

/**
 * Created by mcbird on 14/11/20.
 */
public class TestDAOInsert {
    public static void main(String[] args) throws Exception {
        Emp emp = null;
        for(int x = 0; x < 5; x++) {
            emp = new Emp();
            emp.setEmpno(1000 + x);
            emp.setEname("McBird_" + x);
            emp.setJob("Singer_" + x);
            emp.setHiredate(new Date());
            emp.setSal(100 * x);

            DAOFactory.getIEmpDAOInstance().doCreate(emp);
        }
    }
}