JDBC-day05(DAO及相关实现类)

七：DAO及相关实现类

1. DAO介绍

  • DAO：Data Access Object访问数据信息的类和接口，包括了对数据的CRUD（Create、Retrival、Update、Delete），而不包含任何业务相关的信息。有时也称作：BaseDAO
  • 作用：为了实现功能的模块化，更有利于代码的维护和升级。在实际生产中，也是使用DAO的样式进行编写。

2. BaseDAO

  • 把用到的通用操作写在此类中，用作父类供子类调用

例：把之前编写的增删查改的具体方法代码放入其中，还可以添加一些其他方法

import java.lang.reflect.Field;
import java.sql.Connection;    
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;import com.jdbc1.util.JDBC_Utils;/**** * @author Cat God 007 封装了数据表的基本通用操作**/
public abstract class BaseDAO {// 通用的增删改操作---version2.0public int update(Connection conn, String sql, Object... args) {PreparedStatement ps = null;try {ps = conn.prepareStatement(sql);for (int i = 0; i < args.length; i++) {ps.setObject(i + 1, args[i]);// 小心参数声明错误（从1开始）}return ps.executeUpdate();} catch (Exception e) {e.printStackTrace();} finally {JDBC_Utils.closeResource(null, ps);}return 0;}// 通用的查询操作，返回一条数据----version2.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();// 获取结果集的元数据ResultSetMetaData 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 columnName = rsmd.getColumnName(i + 1);// 获取每个列的别名（无别名就获取表的列名）：结果集元数据String columnLabel = rsmd.getColumnLabel(i + 1);// 给cust指定columnName属性赋值为columnvalue，通过反射Field field = clazz.getDeclaredField(columnLabel);field.setAccessible(true);field.set(t, columnvalue);}return t;}} catch (Exception e) {e.printStackTrace();} finally {JDBC_Utils.closeResource(null, ps, rs);}return null;}// 通用的查询操作，返回多条数据----version2.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();// 获取结果集的元数据ResultSetMetaData 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 columnName = rsmd.getColumnName(i + 1);// 获取每个列的别名（无别名就获取表的列名）：结果集元数据String columnLabel = rsmd.getColumnLabel(i + 1);// 给cust指定columnName属性赋值为columnvalue，通过反射Field field = clazz.getDeclaredField(columnLabel);field.setAccessible(true);field.set(t, columnvalue);}list.add(t);}return list;} catch (Exception e) {e.printStackTrace();} finally {JDBC_Utils.closeResource(null, ps, rs);}return null;}//新增：用于查询特殊值的通用方法,如：查询表中的总人数等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 {JDBC_Utils.closeResource(null, ps, rs);}		return null;}}

3.XxxDAO

  • 定义针对某一表或数据库的功能接口

例：
在此之前需要创建Customer类，有的话就直接调用就行，不需要再创建

package com.jdbc2.bean;import java.sql.Date;/*** * @author Cat God 007* 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 + "]";}}

定义针对Customer表的功能接口

import java.sql.Connection;        
import java.sql.Date;
import java.util.List;import com.jdbc2.bean.Customer;//此接口用于规范针对customers表的常用操作
public interface CustomerDAO {/*** 将cust对象添加到数据库中*/void insert(Connection conn,Customer cust);/***针对指定的id,删除表中的一条记录*/void deleteById(Connection conn,int id);/** 针对内存中的cust对象，去修改数据表中指定的记录*/void update(Connection conn,Customer cust);/** 针对指定的id查询对应的Customer对象(一条记录)*/Customer getCustomerById(Connection conn,int id);/** 查询表中的所有记录构成的集合*/List<Customer> getAll(Connection conn);/** 返回数据表中的数据条目数*/Long getCount(Connection conn);/** 返回数据表中最大的生日（即最小的人的生日）*/Date getMaxBirth(Connection conn);}

4.XxxDAOImpl

  • 继承BaseDAO，实现XxxDAO接口

例：

CustomerDAOImpl继承BaseDAO，实现CustomerDAO接口

import java.sql.Connection;        
import java.sql.Date;
import java.util.List;import com.jdbc2.bean.Customer;public class CustomerDAOImpl extends BaseDAO implements CustomerDAO{@Overridepublic void insert(Connection conn, Customer cust) {String sql = "insert into customers(name,email,birth)values(?,?,?)";update(conn,sql,cust.getName(),cust.getEmail(),cust.getBirth());}@Overridepublic void deleteById(Connection conn, int id) {String sql = "delete from customers where id = ?";update(conn,sql,id);}@Overridepublic void update(Connection conn, Customer cust) {String sql = "update customers set name = ?,email = ?,birth = ? where id = ?";update(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);}}

5. XxxDAOImplTest测试

  • 对具体的XxxDAOImpl实现类i，进行测试

例：


import static org.junit.Assert.*;import java.sql.Connection;        
import java.sql.Date;
import java.util.List;import org.junit.Test;import com.jdbc1.util.JDBC_Utils;
import com.jdbc2.bean.Customer;
import com.jdbc4.dao.CustomerDAOImpl;public class CustomerDAOImplTest {private CustomerDAOImpl dao = new CustomerDAOImpl();@Testpublic void testInsert() {Connection conn = null;try {conn = JDBC_Utils.getConnection();Customer cust = new Customer(1,"猫神","catgod007@186.com",new Date(6323453234L));dao.insert(conn, cust);System.out.println("插入成功");} catch (Exception e) {e.printStackTrace();}finally {JDBC_Utils.closeResource(conn, null);}}@Testpublic void testDeleteById() {Connection conn = null;try {conn = JDBC_Utils.getConnection();dao.deleteById(conn, 16);System.out.println("删除成功");} catch (Exception e) {e.printStackTrace();}finally {JDBC_Utils.closeResource(conn, null);}}@Testpublic void testUpdateConnectionCustomer() {Connection conn = null;try {conn = JDBC_Utils.getConnection();Customer cust = new Customer(18,"马云","mayun@123.com",new Date(567865437L));dao.update(conn, cust);			System.out.println("修改成功");} catch (Exception e) {e.printStackTrace();}finally {JDBC_Utils.closeResource(conn, null);}}@Testpublic void testGetCustomerById() {Connection conn = null;try {conn = JDBC_Utils.getConnection(); Customer customer = dao.getCustomerById(conn,10);System.out.println(customer);} catch (Exception e) {e.printStackTrace();}finally {JDBC_Utils.closeResource(conn, null);}}@Testpublic void testGetAll() {Connection conn = null;try {conn = JDBC_Utils.getConnection();List<Customer> list = dao.getAll(conn);list.forEach(System.out::println);//注意遍历对象的方法} catch (Exception e) {e.printStackTrace();}finally {JDBC_Utils.closeResource(conn, null);}}@Testpublic void testGetCount() {Connection conn = null;try {conn = JDBC_Utils.getConnection();Long count = dao.getCount(conn);System.out.println("表中的数据共有：" + count + "条");} catch (Exception e) {e.printStackTrace();}finally {JDBC_Utils.closeResource(conn, null);}}@Testpublic void testGetMaxBirth() {Connection conn = null;try {conn = JDBC_Utils.getConnection();Date maxBirth = dao.getMaxBirth(conn);System.out.println("数据表中最年轻的人的生日是： " + maxBirth);} catch (Exception e) {e.printStackTrace();}finally {JDBC_Utils.closeResource(conn, null);}}
}

6. 创建测试文件测试多个方法（可略过）

  • 在要创建的包下，右键点击想要测试的java类，点击new------->Other
  • 搜索 Junit test case，如果不行就需要导入Junit 包
  • 在这里插入图片描述
  • 在这里插入图片描述
  • 在这里插入图片描述

到处DAO就结束了，如果需要编写针对Order表的DAO层，就需要编写OrderDAO,OrderDAOImpl即可

其中可能会出现不少的小问题，请多多包含
感谢大家的支持，关注，评论，点赞！
参考资料：尚硅谷_宋红康_JDBC核心技术

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.rhkb.cn/news/160469.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

websocket+node+vite(vue)实现一个简单的聊天

websocket+node+vite(vue)实现一个简单的聊天

1.前端逻辑 本项目基于之前搭建的vite环境&#xff1a;https://blog.csdn.net/beekim/article/details/128083106?spm1001.2014.3001.5501 新增一个登录页和聊天室页面 <template><div>登录页</div><div>用户名:<input type"text" pl…
阅读更多...
React create-react-app 里配置代理（解决跨域）

React create-react-app 里配置代理（解决跨域）

配置代理&#xff1a; creact-react-app v5 当然不是v5 下面的方法也适用。 方式一&#xff1a;package.json里配置 其实 cra里给了个简单的配置代理 就是在package.json里加上proxy就行了。 修改时需要 npm start重新运行一下&#xff0c;要不然可能不生效。 proxy只能以 h…
阅读更多...
Leetcode学习记录（1）

Leetcode学习记录（1）

1.unordered_map C关联容器&#xff0c;内部hash表结构&#xff08;检索&#xff09; 通过key来检索value&#xff0c;不是通过绝对地址&#xff0c;内部无序&#xff0c;Map对应唯一值&#xff0c;动态管理 unordered_map<const Key, T> map; 如上述代码表述&#x…
阅读更多...
主机jvisualvm连接到tomcat服务器查看jvm状态

主机jvisualvm连接到tomcat服务器查看jvm状态

​使用JMX方式连接到tomcat&#xff0c;连接后能够查看前边的部分内容&#xff0c;但是不能查看Visual GC&#xff0c;显示不受此JVM支持&#xff0c; 对了&#xff0c;要显示Visual GC&#xff0c;首先要安装visualvm工具&#xff0c;具体安装方式就是根据自己的jdk版本下载…
阅读更多...
第二证券：10家央企集体行动！9月至今逾百家公司回购增持

第二证券：10家央企集体行动！9月至今逾百家公司回购增持

10月16日&#xff0c;10家央企连续公告&#xff0c;掀起了新一轮回购增持潮。其间&#xff0c;5家上市公司发布新增增持方案&#xff0c;约5亿&#xff5e;16.3亿元&#xff1b;2家上市公司发布增持打开&#xff0c;估计约23.43亿元&#xff1b;1家上市公司新增回购方案&#x…
阅读更多...
服务器数据恢复-RAID5常见故障的数据恢复方案

服务器数据恢复-RAID5常见故障的数据恢复方案

raid5阵列常见故障&#xff1a; 1、服务器硬件故障或者RAID阵列卡故障&#xff1b; 2、服务器意外断电导致的磁盘阵列故障&#xff1b; 3、服务器RAID阵列阵列磁盘出现物理故障&#xff0c;如&#xff1a;电路板坏、磁头损坏、盘面划伤、坏扇区、固件坏等&#xff1b; 4、误操作…
阅读更多...
25项，2023年国家优青(港澳)入选者完整名单公布！

25项，2023年国家优青(港澳)入选者完整名单公布！

国家优秀青年科学基金项目&#xff08;港澳&#xff09;旨在支持香港特别行政区、澳门特别行政区&#xff08;以下简称港澳特区&#xff09;科技创新发展&#xff0c;鼓励爱国爱港爱澳高素质科技人才参与中央财政科技计划&#xff0c;为建设科技强国贡献力量&#xff0c;2023 年…
阅读更多...
MyBatisPlus（十九）自动填充

MyBatisPlus（十九）自动填充

说明 自动填充指的是&#xff0c;当数据被 插入 或者 更新 的时候&#xff0c;会为指定字段进行一些默认的数据填充。 比如&#xff0c;插入时&#xff0c;会自动填充数据的创建时间和更新时间&#xff1b;更新时&#xff0c;会自动填充数据的更新时间。 实现方式 配置处理器…
阅读更多...
Centos中如何删除带有特殊符号的乱码文件_rz命令产生的乱码文件如何删除_使用文件号删除乱码文件---Linux运维工作笔记058

Centos中如何删除带有特殊符号的乱码文件_rz命令产生的乱码文件如何删除_使用文件号删除乱码文件---Linux运维工作笔记058

在使用rz命令进行文件上传的时候,偶尔会产生一堆的乱码文件,比如: 可以看到有一堆的乱码文件. 普通的乱码文件,直接rm -rf 文件名就可以删除了,但是有一些不行,包含特殊符号的,比如: 这个文件报错了,可以看到用rm -rf 根本删除不掉. 这个文件后面包含了一个.对吧 那该怎么解决…
阅读更多...
python基于django的留学生服务管理平台

python基于django的留学生服务管理平台

留学服务管理平台的用户是系统最根本使用者&#xff0c;按需要分析系统包括三类用户&#xff1a;学生、教师、管理员。这三类用户对系统的需求简要如下。技术栈 后端&#xff1a;pythondjango 前端&#xff1a;vueCSSJavaScriptjQueryelementui 开发语言&#xff1a;Python 框架…
阅读更多...
69. x 的平方根

69. x 的平方根

69. x 的平方根 原题链接&#xff1a;完成情况&#xff1a;解题思路&#xff1a;参考代码&#xff1a;1. log换底2. 二分查找3. 牛顿迭代法 原题链接&#xff1a; 69. x 的平方根 https://leetcode.cn/problems/sqrtx/description/ 完成情况&#xff1a; 解题思路&#xff…
阅读更多...
2023年中国乳胶制品产量、需求量及市场规模分析[图]

2023年中国乳胶制品产量、需求量及市场规模分析[图]

乳胶泛指聚合物微粒分散于水中形成的胶体乳液&#xff0c;又称胶乳。习惯上将橡胶微粒的水分散体称为胶乳&#xff0c;而将树脂微粒的水分散体称为乳液。以乳胶为原料制成的制品称乳胶制品&#xff0c;常见的如海绵、手套、玩具、胶管等。 我国乳胶制品细分主要分为避孕套、乳胶…
阅读更多...
idea不识别yaml文件导致,配置文件点击跳转不了类

idea不识别yaml文件导致,配置文件点击跳转不了类

文章目录 场景确认的idea安装了ymal插件,确认你的配置文件是yml格式的还是ymal格式的然后在项目配置中看看是否有对应的后缀.最后看看在项目模块里面有没有spring模块跟对应的配置文件,如果没有就要添加这样点击配置文件就能跳转到对应的实体类了 场景 在使用idea时&#xff0…
阅读更多...
网络社区挖掘-图论部分的基本知识笔记

网络社区挖掘-图论部分的基本知识笔记

1 网络社区挖掘定义 网络社区挖掘是指利用数据挖掘技术和机器学习算法&#xff0c;分析社交网络、在线社区或互联网上的各种交互数据&#xff0c;以揭示其中隐藏的模式、关系和信息。这些社区可以是社交媒体平台、在线论坛、博客、微博等&#xff0c;人们在这些平台上进行交流…
阅读更多...
智慧公厕：打破传统，解决城市痛点@中期科技

智慧公厕：打破传统，解决城市痛点@中期科技

近年来&#xff0c;随着城市化进程的加速推进&#xff0c;智慧公厕成为人民生活质量提升的重要组成部分。作为一个富有创新和科技感的解决方案&#xff0c;智慧公厕不仅满足了人们对公共环境的要求&#xff0c;还提供了一系列便利的服务&#xff0c;让人们的生活更加舒适、便捷…
阅读更多...
【vr】【unity】白马VR课堂系列-VR开发核心基础05-主体设置-手柄对象的引入和设置

【vr】【unity】白马VR课堂系列-VR开发核心基础05-主体设置-手柄对象的引入和设置

【视频教学】 【白马VR课堂系列-VR开发核心基础05-主体设置-手柄对象的引入和设置】 https://www.bilibili.com/video/BV19D4y1N73i/?share_source=copy_web&vd_source=7f5c96f5a58b7542fc6b467a9824b04e 【内容】 上一节引入了XR Origin并进行了初步设置，运行测试时V…
阅读更多...
短视频剪辑矩阵系统开发解决的市场工具难点？

短视频剪辑矩阵系统开发解决的市场工具难点？

短视频剪辑矩阵系统开发源码----源头搭建 一、源码技术构建源码部署搭建交付之---- 1.需要协助系统完成部署、接口全部正常接入、系统正常运行多久&#xff1f;7个工作日 2.需要准备好服务器以及备案域名 3.短视频SEO模块一年项目带宽&#xff0c;带宽最低要求10M&#xff0c;…
阅读更多...
实验笔记之——可见光通信调制驱动芯片模组

实验笔记之——可见光通信调制驱动芯片模组

本博文记录本团队研发出的VLC驱动调制芯片模组&#xff08;如下图所示&#xff09;的驱动调制代码烧录过程。 实物模组正面 实物模组反面 首先需要安装keil5&#xff0c;其安装与编译过程请参考博客&#xff1a;实验笔记之——单片机烧录的实验过程_烧录程序的基本步骤-CSDN博客…
阅读更多...
Python 函数用法和底层分析

Python 函数用法和底层分析

目录 1 函数简介1.1 函数的基本概念1.2 Python函数的分类 2 函数的定义和调用2.1 核心要点2.2 形参和实参2.3 文档字符串(函数的注释)2.4 返回值 3 函数也是对象&#xff0c;内存底层分析4 变量的作用域(全局变量和局部变量)5 局部变量和全局变量效率测试6 参数的传递6.1 传递可…
阅读更多...
数据库：Hive转Presto（五）

数据库：Hive转Presto（五）

此篇将所有代码都补充完了&#xff0c;之前发现有的代码写错了&#xff0c;以这篇为准&#xff0c;以下为完整代码&#xff0c;如果发现我有什么考虑不周的地方&#xff0c;可以评论提建议&#xff0c;感谢。代码是想哪写哪&#xff0c;可能比较繁琐&#xff0c;还需要优化。 …
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023