浅谈DAO设计模式(示例)

唔仄lo咚锵

发布于 2020-09-15 14:29:21

1K0

发布于 2020-09-15 14:29:21

文章被收录于专栏：blog(为什么会重名，真的醉了)blog(为什么会重名，真的醉了)

什么是DAO？
DAO模式组成
- DatabaseConnection
- VO
- DAO
- Impl
- Factory
示例
- cn.wzl.dao.ConnectionManager：连接数据库(MySql)
- cn.wzl.vo.Person：Person值类
- cn.wzl.dao.IPersonDAO：实现对Person表的操作接口
- cn.wzl.dao.impl.PersonDAOImpl：Person表操作实例化
- cn.wzl.factory.DAOFactory：工厂类
- 前端调用代码片段
小结

什么是DAO？

DAO（Data Access Object）数据访问接口。废话不多说（官方定义什么的写了也没人看?），其实就是一种数据设计范化模式，打个比方，我们写的第一个java程序可能把主函数，方法，变量定义等全部写在一个.java文件中，在后续的规范学习中才拆分成不同的包，类等，测试类主函数相应调用即可。同样的，所有JDBC代码都写在JSP页面之中，维护困难，JSP应该只关注于数据的显示，而不关心数据从哪里来，或向哪里存储。 JavaEE的组件层次：客户端–>表示层–>业务层–>数据层–>数据库 DAO属于JavaEE数据层的操作。即：在DAO中封装了一个数据库中的表在一个项目中所应具有的全部操作。

DAO模式组成

DatabaseConnection 数据库连接：专门负责数据库的打开与关闭操作的类命名规范：xxx.dbc.ConnectionManager
VO 值类：主要由属性、setter、getter方法组成，VO类中的属性与表中的字段相对应，每一个VO类的对象都表示表中的每一条记录命名规范：xxx.vo.Xxx(与数据库的表名一致)
DAO DAO接口：主要定义操作的接口，定义一系列数据库的原子操作，如增加、修改、删除、按ID查询等命名规范：xxx.dao.XxxDAO
Impl DAO接口真实实现类：DAO接口的真实实现类，完成具体的数据库操作，但是不负责数据库的打开和关闭命名规范：xxx.dao.impl.XxxDAOImpl
Factory 工厂类：通过工厂类取得一个DAO的实例化对象，有了工厂类，前端代码不必知道具体的子类名字，只需要统一使用实例的各个操作命名规范：xxx.factory.XxxDAOFactory

示例

cn.wzl.dao.ConnectionManager：连接数据库(MySql)

package cn.wzl.dbc;
import java.sql.*;
public class ConnectionManager {
	private static final String DRIVER_CLASS = "com.mysql.cj.jdbc.Driver";
	private static final String DATABASE_URL = "jdbc:mysql://localhost:3306/test? useUnicode=true & characterEncoding=utf-8 & rewriteBatchedStatements=true & useSSL=false & serverTimezone=UTC & allowPublicKeyRetrieval=true";
	private static final String DATABASE_USRE = "root";
	private static final String DATABASE_PASSWORD = "******";//密码
	/** 返回连接 */
	public static Connection getConnection() {
		Connection dbConnection = null;
		try {
			Class.forName(DRIVER_CLASS);
			dbConnection = DriverManager.getConnection(DATABASE_URL,
					DATABASE_USRE, DATABASE_PASSWORD);
		} catch (Exception e) {
			e.printStackTrace();
		}
		return dbConnection;
	}
	/** 关闭连接*/
	public static void closeConnection(Connection dbConnection) {
		try {
			if (dbConnection != null && (!dbConnection.isClosed())) {
				dbConnection.close();
			}
		} catch (SQLException sqlEx) {
			sqlEx.printStackTrace();
		}
	}
	/**关闭结果集*/
	public static void closeResultSet(ResultSet res) {
		try {
			if (res != null) {
				res.close();
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}
	/** 关闭语句*/
	public static void closeStatement(PreparedStatement pStatement) {
		try {
			if (pStatement != null) {
				pStatement.close();
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}
	public static void closeStatement(Statement statement) {
		try {
			if (statement != null) {
				statement.close();
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}
}

cn.wzl.vo.Person：Person值类

package cn.wzl.vo;
public class Person {
     private String id;
     private String name;
     private String password;
	public Person(String id, String name, String password) {
		super();
		this.id = id;
		this.name = name;
		this.password = password;
	}
	public String getId() {
		return id;
	}
	public void setId(String id) {
		this.id = id;
	}
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	public String getPassword() {
		return password;
	}
	public void setPassword(String password) {
		this.password = password;
	}
	@Override
	public String toString() {
		return "Person [id=" + id + ", name=" + name + ", password=" + password + "]";
	}
}

cn.wzl.dao.IPersonDAO：实现对Person表的操作接口

package cn.wzl.dao;
import java.util.List;
import cn.wzl.vo.Person;
public interface IPersonDAO {
	//插入
	public boolean doInsert(Person per) throws Exception;
	//修改
	public boolean doUpdate(Person per)throws Exception;
	//获取所有用户
	public List<Person> doQuery() throws Exception;
    //通过id查找
	public Person doQueryById(String id) throws Exception;
}

cn.wzl.dao.impl.PersonDAOImpl：Person表操作实例化

package cn.wzl.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 cn.wzl.dao.IPersonDAO;
import cn.wzl.dbc.ConnectionManager;
import cn.wzl.vo.Person;
public class PersonDAOImpl implements IPersonDAO {
	//插入用户记录
	@Override
	public boolean doInsert(Person per) throws Exception {
		   boolean flag=false;
		   String sql="insert into person(id,name,password) values(?,?,?)";
	       Connection conn=null;
		   PreparedStatement pstmt=null;
		   try{
			   conn=ConnectionManager.getConnection();
		       pstmt=conn.prepareStatement(sql);
		       pstmt.setString(1,per.getId());
		       pstmt.setString(2,per.getName());
		       pstmt.setString(3,per.getPassword());
		       if(pstmt.executeUpdate()>0){
			   flag=true;
		       }
		   }catch(Exception e){
			   System.out.println(e);
		   }finally{
				ConnectionManager.closeStatement(pstmt);
				ConnectionManager.closeConnection(conn);
		   }
		  return flag;
	}
	//修改用户记录
	@Override
	public boolean doUpdate(Person per) throws Exception {
		   boolean flag=false;
		   String sql="update person set name=?,password=? where id=?";
		   Connection conn=null;
		   PreparedStatement pstmt=null;
		   try{
			conn=ConnectionManager.getConnection();
		    pstmt=conn.prepareStatement(sql);
		    pstmt.setString(1,per.getName());
		    pstmt.setString(2,per.getPassword());
		    pstmt.setString(3,per.getId());
		   if(pstmt.executeUpdate()>0){
			   flag=true;
		   }
		   }catch(Exception e){
			   System.out.println(e);
		   }finally{
		   ConnectionManager.closeStatement(pstmt);
		   ConnectionManager.closeConnection(conn);
		   }
		  return flag;
	}
	//查询所有用户
	@Override
	public List<Person> doQuery() throws Exception{
		  List<Person> person = new ArrayList<Person>();
		    Connection con = null;
			PreparedStatement pstms = null;
			ResultSet res = null;
			try {
				con = ConnectionManager.getConnection();// 创建连接
				String sql = "select * from person";
				pstms = con.prepareStatement(sql);// 创建预处理语句总管
				res = pstms.executeQuery();// 语句总管执行查询
				while (res.next()) {
					String id = res.getString(1);
					String name = res.getString(2);
					String password = res.getString(3);
	                Person per = new Person(id,name,password);
					person.add(per);
				}
			} catch (SQLException e) {
				e.printStackTrace();
			} finally {
				ConnectionManager.closeResultSet(res);// 5.关闭结果集 对象、语句总管、连接
				ConnectionManager.closeStatement(pstms);
				ConnectionManager.closeConnection(con);
			}
		  return person;
	}
	@Override
	public Person doQueryById(String id) throws Exception{
		Person person = null;
		Connection con = null;
		PreparedStatement pstms = null;
		ResultSet res = null;
		try {
			con = ConnectionManager.getConnection(); // 创建连接
			String sql = "select * from person where id=?";
			pstms = con.prepareStatement(sql); // 创建预处理语句总管
			pstms.setString(1, id);
			res = pstms.executeQuery(); // 语句总管执行SQL语句
			if (res.next()) {
				String name = res.getString(2);
				String password = res.getString(3);
				person = new Person(id,name,password);
			}
		} catch (SQLException sqlE) {
			sqlE.printStackTrace();
		} finally {
			ConnectionManager.closeResultSet(res);// 关闭结果集 对象、语句总管、连接
			ConnectionManager.closeStatement(pstms);
			ConnectionManager.closeConnection(con);
		}
		return person;
	}
}

cn.wzl.factory.DAOFactory：工厂类

package cn.wzl.factory;
import cn.wzl.dao.IMessageDAO;
import cn.wzl.dao.IPersonDAO;
import cn.wzl.dao.IRevertDAO;
import cn.wzl.dao.impl.MessageDAOImpl;
import cn.wzl.dao.impl.PersonDAOImpl;
import cn.wzl.dao.impl.RevertDAOImpl;
public class DAOFactory {
     public static IPersonDAO getPersonDAOInstance(){
    	  return new PersonDAOImpl();
     }
     public static IMessageDAO getMessageDAOInstance(){	 
    	 return new MessageDAOImpl();
     }
     public static IRevertDAO getRevertDAOInstance(){
    	 return new RevertDAOImpl();
     }
}

前端调用代码片段

<%
		request.setCharacterEncoding("utf-8");
		String id =request.getParameter("id");
		String password =request.getParameter("password");
		Person person =DAOFactory.getPersonDAOInstance().doQueryById(id);
%>