DAO设计模式及其实现类

DAO(Data Access Object ，数据访问对象)设计模式。设计访问数据信息的类和接口，包括了对数据的CRUD（Create、Retrival、Update、Delete），而不包含任何业务相关的信息。有时也称作：BaseDAO。
作用：为了实现功能的模块化，更有利于代码的维护和升级。

DAO由以下6部分组成

在整个DAO中实际上都是以接口为操作标准的，即：客户端依靠DAO实现的接口进行操作，而服务端要将接口进行具体的实现。DAO由以下几个部分组成。
1）、DatabaseConnection数据库连接类: 专门负责数据库打开与关闭的类，即连接数据库并获取连接对象。
2）、VO实体类：主要由属性、setter、getter方法组成，VO类中的属性与表中的字段相对应，每一个VO类的对象都表示表中的每一条记录，即包含属性和表中字段完全对应的类。
3）、DAO接口：主要定义操作的接口，定义一系列数据库的原子性操作，例如：增加、修改、删除、按ID查询等，即提供了用户所有的操作方法（就如老师给学生提供一些学习方法）。
4）、Impl(DAO实现类)： DAO接口的真实实现类，完成具体的数据库操作，但是不负责数据库的打开和关闭，即实现DAO中所有的方法（就如老师给提供的方法看你如何去完成）；
5）、Proxy ：代理实现类，主要完成数据库的打开和关闭，并且调用真实实现类对象的操作
6）、Factory(DAO工厂类)：通过工厂类取得一个DAO的实例化对象，为程序提供方法，如果要替换DAO实现类，只需要修改该Dao工厂类中的方法代码，而不必邀修改所有的操作数据库代码（如代理人专门为需要的公司提供人才，也叫做服务层）。

1.BaseDAO抽象类

设计一个抽象类BaseDAO，这个类中封装了通用的方法，而不是针对某个具体类。

public abstract class BaseDAO {//通用的增删改方法---version 2.0（考虑上事务）public int testGeneralMethod(Connection conn, String sql, Object...args){ //sql中占位符的个数与可变形参的个数相同PreparedStatement ps = null;try {//1.预编译sql语句，返回PreparedStatement的实例ps = conn.prepareStatement(sql);//2.填充占位符for(int i = 0 ; i<args.length ; i++){ps.setObject(i + 1 ,args[i]);}//3.执行,返回影响了几条记录return ps.executeUpdate();} catch (Exception e) {e.printStackTrace();} finally{
//					//4.恢复每次DML操作的自动提交功能
//					try {
//						conn.setAutoCommit(true);
//					} catch (SQLException e) {
//						e.printStackTrace();
//					}//5.关闭资源,Connection定义在外面就外面关，里面别关JDBCUtils.closeResource(null, ps);		}return 0;}//通用的查询操作，用于返回表中的一条记录(version 2.0,考虑上事务)public <T> T getInstance(Connection conn, Class<T> clazz, String sql, Object...args){PreparedStatement ps = null;ResultSet rs = null;try {ps = conn.prepareStatement(sql);//填充占位符for(int i=0 ; i < args.length ; i++){ps.setObject(i+1, args[i]);}rs = ps.executeQuery();//获取结果集的元数据：ResultSetMetaDataResultSetMetaData rsmd = rs.getMetaData();//通过ResultSetMetaData获取结果集中的列数int columnCount = rsmd.getColumnCount();if(rs.next()){T t = clazz.newInstance();//处理结果集一行数据中的每一个列for(int i = 0; i < columnCount ; i++){//获取列值Object columnValue = rs.getObject(i + 1);//获取每个列的别名，如果没有就是列名String columnLabel = rsmd.getColumnLabel(i + 1);//给t对象指定的某个属性，赋值为columnValue:通过反射			Field field = t.getClass().getDeclaredField(columnLabel);//或者//Field field = clazz.getDeclaredField(columnLabel);field.setAccessible(true);field.set(t, columnValue);}return t;	}} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();}finally{JDBCUtils.closeResource(null, ps, rs);			}return null;}	//通用的查询操作，用于返回表中的多条记录构成的集合(version 2.0,考虑上事务)public <T> List<T> getForList(Connection conn, Class<T> clazz, String sql, Object...args){PreparedStatement ps = null;ResultSet rs = null;try {ps = conn.prepareStatement(sql);//填充占位符for(int i=0 ; i < args.length ; i++){ps.setObject(i+1, args[i]);}rs = ps.executeQuery();//获取结果集的元数据：ResultSetMetaDataResultSetMetaData rsmd = rs.getMetaData();//通过ResultSetMetaData获取结果集中的列数int columnCount = rsmd.getColumnCount();//创建集合对象ArrayList<T> list = new ArrayList<T>();while(rs.next()){T t = clazz.newInstance();// 处理结果集一行数据中的每一个列: 给t对象指定的属性赋值for(int i = 0; i < columnCount ; i++){//获取列值Object columnValue = rs.getObject(i + 1);//获取每个列的别名，如果没有就是列名String columnLabel = rsmd.getColumnLabel(i + 1);//给t对象指定的某个属性，赋值为columnValue:通过反射			Field field = t.getClass().getDeclaredField(columnLabel);//或者//Field field = clazz.getDeclaredField(columnLabel);field.setAccessible(true);field.set(t, columnValue);}list.add(t);}return list;} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();}finally{JDBCUtils.closeResource(null, ps, rs);			}return null;}//用于查询一个特殊值的通用方法，比如：select count(*)public <E> E getValue(Connection conn, String sql, Object...args){PreparedStatement ps = null;ResultSet rs = null;try {ps = conn.prepareStatement(sql);for(int i = 0; i < args.length ; i++){ps.setObject(i + 1, args[i]);}rs = ps.executeQuery();if(rs.next()){return (E) rs.getObject(1);}} catch (Exception e) {e.printStackTrace();} finally{JDBCUtils.closeResource(null, ps, rs);}return null;}}

2.VO实现类

假设要操作的类是Customer类

/** ORM的编程思想（object relational mapping）* 一个数据表对应一个Java类* 表中的一条记录对应Java类的一个对象* 表中的一个字段对应Java类的一个属性* */public class Customer {private int id;private String name;private String email;private Date birth;public Customer() {super();}public Customer(int id, String name, String email, Date birth) {super();this.id = id;this.name = name;this.email = email;this.birth = birth;}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 String getEmail() {return email;}public void setEmail(String email) {this.email = email;}public Date getBirth() {return birth;}public void setBirth(Date birth) {this.birth = birth;}@Overridepublic String toString() {return "Customer [id=" + id + ", name=" + name + ", email=" + email + ", birth=" + birth + "]";}}

3.定义CustomerDAO接口

/** 此接口用于规范针对于Customers表的常用操作* */public interface CustomerDAO {/*** * @Description 将cust对象添加到数据库中* @author baiyexing* @version * @date2020年12月4日下午4:20:35*/void insert(Connection conn, Customer cust);/*** * @Description 根据指定的Id删除表中的一条记录* @author baiyexing* @version * @date2020年12月4日下午4:30:03*/void deleteById(Connection conn, int id);/*** * @Description 针对于内存中的cust对象，去修改数据表中的记录* @author baiyexing* @version * @date2020年12月4日下午4:31:50*/void update(Connection conn, Customer cust);/*** * @Description 针对指定的id查询对应的Customer对象* @author baiyexing* @version * @date2020年12月4日下午4:32:47*/Customer getCustomerById(Connection conn, int id);/*** * @Description 查询表中所有记录构成的集合* @author baiyexing* @version * @date2020年12月4日下午4:34:26*/List<Customer> getAll(Connection conn);/*** * @Description 返回数据表中数据的条目数* @author baiyexing* @version * @date2020年12月4日下午4:35:38*/Long getCount(Connection conn);/*** * @Description 返回数据表中最大生日* @author baiyexing* @version * @date2020年12月4日下午4:36:42*/Date getMaxBirth(Connection conn);}

4.用CustomerDAOImpl类实现接口中的操作

public class CustomerDAOImpl extends BaseDAO implements CustomerDAO{@Overridepublic void insert(Connection conn, Customer cust) {String sql = "insert into customers(name,email,birth) values(?,?,?)";		testGeneralMethod(conn, sql, cust.getName(), cust.getEmail(), cust.getBirth());}@Overridepublic void deleteById(Connection conn, int id) {String sql = "delete from customers where id = ?";testGeneralMethod(conn, sql, id);}@Overridepublic void update(Connection conn, Customer cust) {String sql = "update customers set name = ?,email = ?,birth = ? where id = ?";testGeneralMethod(conn, sql, cust.getName(), cust.getEmail(), cust.getBirth(), cust.getId());}@Overridepublic Customer getCustomerById(Connection conn, int id) {String sql = "select id,name,email,birth from customers where id = ?";Customer customer = getInstance(conn, Customer.class, sql, id);return customer;}@Overridepublic List<Customer> getAll(Connection conn) {String sql = "select id,name,email,birth from customers";List<Customer> list = getForList(conn, Customer.class, sql);return list;}@Overridepublic Long getCount(Connection conn) {String sql = "select count(*) from customers";return getValue(conn, sql);}@Overridepublic Date getMaxBirth(Connection conn) {String sql = "select MAX(birth) from customers";return getValue(conn, sql);}}

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！