DAO

gaozhennan 2015-04-22

DAO(数据访问对象)数据层组织结构,大致包括以下对象。

IDAO
ImplDAO:具体数据的增删改查。
ProxyDAO:负责ImplDAO所用的数据库打开与关闭。
DatabaseConnection:数据库打开与关闭的执行者。
VO:属性与表中的字段相对应,一个vo类就是表中的一条记录。

Factory:生产IDAO下的代理的


DAO
 

一、信息系统的开发架构

 

客户层-------显示层-------业务层---------数据层---------数据库

1.客户层:客户层就是客户端,简单的来说就是浏览器。

2.显示层:JSP/Servlet,用于给浏览器显示。

3.业务层:对于数据层的原子操作进行整合

4.数据层:对于数据库进行的原子操作,增加、删除等;

二、DAO(Data Access Object)介绍

 

DAO应用在数据层那块,用于访问数据库,对数据库进行操作的类。

三、DAO设计模式的结构

 

DAO设计模式一般分为几个类:

1.VO(Value Object):一个用于存放网页的一行数据即一条记录的类,比如网页要显示一个用户的信息,则这个类就是用户的类。

2.DatabaseConnection:用于打开和关闭数据库。

3.DAO接口:用于声明对于数据库的操作。

4.DAOImpl:必须实现DAO接口,真实实现DAO接口的函数,但是不包括数据库的打开和关闭。

5.DAOProxy:也是实现DAO接口,但是只需要借助DAOImpl即可,但是包括数据库的打开和关闭。

6.DAOFactory:工厂类,含有getInstance()创建一个Proxy类。

四、DAO的好处

 

DAO的好处就是提供给用户的接口只有DAO的接口,所以如果用户想添加数据,只需要调用create函数即可,不需要数据库的操作。

五、DAO包命名

 

对于DAO,包的命名和类的命名一定要有层次。

六、实例解析

 

1.Emp.java

package org.vo;  
import java.util.*;  
public class Emp{  
    private int empno;  
    private String ename;  
    private String job;  
    private Date hireDate;  
    private float sal;  
    public Emp(){  
          
    }  
    public int getEmpno(){  
        return empno;  
    }  
    public void setEmpno(int empno){  
        this.empno = empno;  
    }  
    public String getEname(){  
        return ename;  
    }  
    public void setEname(String ename){  
        this.ename = ename;  
    }  
    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 String getJob(){  
        return job;  
    }  
    public void setJob(String job){  
        this.job = job;  
    }  
}  

2.DatabaseConnection.java

package org.dbc;  
import java.sql.*;  
public class DatabaseConnection{  
    private Connection con = null;  
    private static final String DRIVER = "com.mysql.jdbc.Driver";  
    private static final String USER = "root";  
    private static final String URL = "jdbc:mysql://localhost:3306/mldn";  
    private static final String PASS = "12345";  
    public DatabaseConnection()throws Exception{  
        Class.forName(DRIVER);  
        con = DriverManager.getConnection(URL,USER,PASS);  
    }  
    public Connection getConnection()throws Exception{  
        return con;  
    }  
    public void close()throws Exception{  
        if(con!=null){  
            con.close();  
        }  
    }  
}  

3.IEmpDAO.java

package org.dao;  
import java.util.List;  
import org.vo.*;  
public interface IEmpDAO{  
    public boolean doCreate(Emp emp)throws Exception;  
    public List<Emp> findAll()throws Exception;  
    public Emp findById(int empno)throws Exception;  
}  

4.EmpDAOImpl.java

package org.dao.impl;  
import org.dao.*;  
import java.sql.*;  
import org.vo.*;  
import java.util.*;  
public class EmpDAOImpl implements IEmpDAO{  
    private Connection con;  
    private PreparedStatement stat = null;  
    public EmpDAOImpl(Connection con){  
        this.con = con;  
    }  
    public boolean doCreate(Emp emp)throws Exception{  
        String sql = "INSERT INTO emp(empno,ename,job,hiredate,sal) VALUES(?,?,?,?,?)";  
        stat = con.prepareStatement(sql);  
        stat.setInt(1,emp.getEmpno());  
        stat.setString(2,emp.getEname());  
        stat.setString(3,emp.getJob());  
        stat.setDate(4,new java.sql.Date(emp.getHireDate().getTime()));  
        stat.setFloat(5,emp.getSal());  
        int update = stat.executeUpdate();  
        if(update>0){  
            return true;  
        }  
        else{  
            return false;  
        }  
    }  
    public List<Emp> findAll()throws Exception{  
        String sql = "SELECT empno,ename,job,hiredate,sal FROM emp";  
        stat = con.prepareStatement(sql);  
        ResultSet rs = stat.executeQuery();  
        Emp emp = null;  
        List<Emp> list = new ArrayList<Emp>();  
        while(rs.next()){  
            int empno = rs.getInt(1);  
            String ename = rs.getString(2);  
            String job = rs.getString(3);  
            float sal = rs.getFloat(5);  
            emp = new Emp();  
            emp.setEmpno(empno);  
            emp.setEname(ename);  
            emp.setJob(job);  
            emp.setHireDate(rs.getDate(4));  
            emp.setSal(sal);  
            list.add(emp);  
        }  
        return list;  
    }  
    public Emp findById(int empno)throws Exception{  
        String sql = "SELECT empno,ename,job,hiredate,sal FROM emp WHERE empno=?";  
        stat = con.prepareStatement(sql);  
        stat.setInt(1,empno);  
        ResultSet rs = stat.executeQuery();  
        Emp emp = null;  
        if(rs.next()){  
            String ename = rs.getString(2);  
            String job = rs.getString(3);  
            float sal = rs.getFloat(5);  
            emp = new Emp();  
            emp.setEmpno(empno);  
            emp.setEname(ename);  
            emp.setJob(job);  
            emp.setHireDate(rs.getDate(4));  
            emp.setSal(sal);  
        }  
        return emp;  
    }  
}  


5.EmpDAOProxy.java

package org.dao.impl;  
import org.dao.*;  
import java.sql.*;  
import org.vo.*;  
import java.util.*;  
import org.dbc.*;  
public class EmpDAOProxy implements IEmpDAO{  
    private DatabaseConnection dbc;  
    private IEmpDAO dao = null;  
    public EmpDAOProxy()throws Exception{  
        dbc = new DatabaseConnection();  
        dao = new EmpDAOImpl(dbc.getConnection());  
    }  
    public boolean doCreate(Emp emp)throws Exception{  
        boolean flag = false;  
        if(dao.findById(emp.getEmpno())==null){  
            flag = dao.doCreate(emp);  
        }  
        dbc.close();  
        return flag;  
    }  
    public List<Emp> findAll()throws Exception{  
        List<Emp>list = dao.findAll();  
        dbc.close();  
        return list;  
    }  
    public Emp findById(int empno)throws Exception{  
        Emp emp = dao.findById(empno);  
        dbc.close();  
        return emp;  
    }  
}  

6.DAOFactory.java

package org.dao.factory;  
import org.dao.*;  
import java.sql.*;  
import org.vo.*;  
import java.util.*;  
import org.dbc.*;  
import org.dao.impl.*;  
public class DAOFactory{  
    public static IEmpDAO getInstance(){  
        IEmpDAO dao = null;  
        try{  
            dao = new EmpDAOProxy();      
        }  
        catch(Exception e){  
            e.printStackTrace();  
        }  
        return dao;  
    }  
}  


7.TestDAO.java

package org.dao.test;  
import org.dao.factory.*;  
import org.vo.*;  
import org.dao.*;  
public class TestDAO{  
    public static void main(String args[])throws Exception{  
        Emp emp = null;  
        for(int i=0;i<5;i++){  
            emp = new Emp();  
            emp.setEmpno(i);  
            emp.setEname("xiazdong-"+i);  
            emp.setJob("stu-"+i);  
            emp.setHireDate(new java.util.Date());  
            emp.setSal(500*i);  
            DAOFactory.getInstance().doCreate(emp);  
        }  
    }  
}  


通过DAO设计模式,可以在JSP中屏蔽了数据库连接的操作,达到JSP只负责显示的效果。

相关推荐