Java之dao模式详解及代码示例
什么是dao模式?
DAO(Data Access Object)顾名思义是一个为数据库或其他持久化机制提供了抽象接口的对象,在不暴露底层持久化方案实现细节的前提下提供了各种数据访问操作。在实际的开发中,应该将所有对数据源的访问操作进行抽象化后封装在一个公共API中。用程序设计语言来说,就是建立一个接口,接口中定义了此应用程序中将会用到的所有事务方法。在这个应用程序中,当需要和数据源进行交互的时候则使用这个接口,并且编写一个单独的类来实现这个接口,在逻辑上该类对应一个特定的数据存储。DAO模式实际上包含了两个模式,一是Data Accessor(数据访问器),二是Data Object(数据对象),前者要解决如何访问数据的问题,而后者要解决的是如何用对象封装数据。
一、信息系统的开发架构
客户层-------显示层-------业务层---------数据层---------数据库
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只负责显示的效果。
//对应 String sql = "INSERT INTO emp_table(ename,job,sal,hiredate) VALUES(?,?,?,?)"; stat = (PreparedStatement) con.prepareStatement(sql); stat.setString(1,emp.getEname()); stat.setString(2,emp.getJob()); stat.setFloat(3,emp.getSal());
总结
以上就是本文关于Java之dao模式详解及代码示例的全部内容,希望对大家有所帮助,欢迎参阅:Java设计模式笔记之抽象工厂代码示例、Java多线程之线程通信生产者消费者模式及等待唤醒机制代码详解、Java单例模式实现静态内部类方法示例等,有什么问题可以随时留言,感谢大家!
- 设置输出延迟
- 设置输入延时约束
- MySQL 死锁与日志二三事
- 一千个不用 Null 的理由
- TensorFlow强化学习入门(1.5)——上下文赌博机
- 以太坊·代币开发详解
- JSON Web Token - 在Web应用间安全地传递信息
- TensorFlow强化学习入门(2)——基于策略的Agents
- 用ABAP 生成二维码 QR Code
- CDS view注解解析 - @Environment.systemField
- Document flow API in SAP CRM and C4C
- Python基础知识4:文件操作
- Python基础知识6:格式化字符、颜色
- 给自定义控件(Web Control)添加事件的几种方法。前两种方法可以不实现IPostBackEventHandler
- java教程
- Java快速入门
- Java 开发环境配置
- Java基本语法
- Java 对象和类
- Java 基本数据类型
- Java 变量类型
- Java 修饰符
- Java 运算符
- Java 循环结构
- Java 分支结构
- Java Number类
- Java Character类
- Java String类
- Java StringBuffer和StringBuilder类
- Java 数组
- Java 日期时间
- Java 正则表达式
- Java 方法
- Java 流(Stream)、文件(File)和IO
- Java 异常处理
- Java 继承
- Java 重写(Override)与重载(Overload)
- Java 多态
- Java 抽象类
- Java 封装
- Java 接口
- Java 包(package)
- Java 数据结构
- Java 集合框架
- Java 泛型
- Java 序列化
- Java 网络编程
- Java 发送邮件
- Java 多线程编程
- Java Applet基础
- Java 文档注释
- 听说MongoDB你很豪横?-------------MongoDB 部署分片群集以及管理分片
- SAP Spartacus和product相关的标准normalizer
- 【Rust 日报】2020-09-09 引入“auditable”
- 听说MongoDB你很豪横?-------------MongoDB复制集以及管理优化
- 听说Memcache你很豪横?-------------深入剖析Memcache 安装及管理数据库操作
- 听说Memcache你很豪横?-------------深入剖析Memcache+keepalive高可用群集
- 排障集锦:九九八十一难之第十四难!------------- 安装magent时make编译报错
- 【Rust日报】2020-09-06 Evil_DLL 用来测试注入方法的DLL
- 【Rust日报】2020-09-05 微软在c++静态分析工具实现了一些rust的安全规则
- 一起来玩玩WebGL
- 自研网关:多项目的swagger聚合功能
- Prometheus 如何做到“活学活用”,大牛总结的避坑指南
- 文档驱动 —— 表单组件(一):表单元素组件 优点缺点选择文本类的Inputcheck 多选value的类型问题
- Vue3.0源码结构分析
- 【每周一库】- cached - 缓存结构型、辅助函数记忆化