Mybatis Plus ActiveRecord 模式

Mybatis Plus ActiveRecord 模式 使用

DEMO源码地址 https://gitee.com/JackSong2019/demo-mybatis3.git

前言

ActiveRecord 模式 简介
  • ActiveRecord 是一种设计模式,它是一种在软件开发中用于管理关系数据库的模式,他简化了数据库操作的流程,使得开发人员可以更专注于业务逻辑而非数据库细节。它提供了一种面向对象的方法来处理数据库,使得数据库操作变得更加直观、易于维护和扩展。
    • 关于 ActiveRecord 模式的一些重要概念和特点
      1、对象关系映射 (ORM):ActiveRecord 是一种对象关系映射 (ORM) 模式的实现。它将数据库中的表格(或集合)映射到应用程序中的对象。
    每个数据库表格对应于一个 ActiveRecord 模型类,而表格中的每一行数据则对应于该模型类的一个实例对象。2、模型类(Model Class):在 ActiveRecord 中,模型类是应用程序中操作数据库的主要组件。每个模型类代表一个数据库表格,
    并且可以用于查询、插入、更新和删除表格中的数据。模型类通常继承自框架提供的 ActiveRecord 基类,
    这个基类提供了许多用于数据库操作的方法和功能。3、数据表与字段映射:ActiveRecord 模式通过约定俗成的方式将数据表中的字段映射到模型类的属性。
    例如,一个数据库表格中的 users 表可能会映射到一个 User 模型类,表中的每个字段(如 id、name、email 等)
    则对应于模型类中的属性。4、CRUD 操作:ActiveRecord 模式使得执行 CRUD 操作变得简单和直观。通过模型类,我们可以轻松地执行
    创建(Create)、读取(Read)、更新(Update)和删除(Delete)这些基本的数据库操作,
    而无需编写复杂的 SQL 查询语句。5、关联和查询:ActiveRecord 支持定义和使用关联关系,比如一对一、一对多、多对多等关系。
    这使得在处理复杂的数据模型时更加便捷。同时,ActiveRecord 提供了强大的查询接口,
    允许开发人员使用链式调用的方式构建复杂的数据库查询,而无需直接编写 SQL。6、数据验证和回调:ActiveRecord 提供了内置的数据验证功能,可以确保数据的完整性和一致性。
    开发人员可以在模型类中定义验证规则,以确保数据符合预期的格式和约束。此外,
    ActiveRecord 还支持回调机制,允许在数据保存、更新等操作前后执行特定的代码。
    

一、前置条件 JDK版本 Springboot版本 MybatisPlus版本

  • JDK 17 以上
  • SpringBoot 3.+ 以上
  • MybatisPlus 3.+ 以上
  • 说明: 实体类只需继承 Model 类即可进行强大的 CRUD 操作 ; 需要项目中已注入对应实体的BaseMapper

二、示例数据脚本 将脚本数据脚本导入到数据库中

-- user 表Schema 脚本
DROP TABLE IF EXISTS `user`;
CREATE TABLE `user`
(id BIGINT NOT NULL AUTO_INCREMENT COMMENT '主键ID',name VARCHAR(30) NULL DEFAULT NULL COMMENT '姓名',age INT NULL DEFAULT NULL COMMENT '年龄',email VARCHAR(50) NULL DEFAULT NULL COMMENT '邮箱',PRIMARY KEY (id)
);--  Data 脚本
DELETE FROM `user`;
INSERT INTO `user` (id, name, age, email) VALUES
(1, 'Jone', 18, 'test1@baomidou.com'),
(2, 'Jack', 20, 'test2@baomidou.com'),
(3, 'Tom', 28, 'test3@baomidou.com'),
(4, 'Sandy', 21, 'test4@baomidou.com'),
(5, 'Billie', 24, 'test5@baomidou.com');

三、初始化工程

  • 1、 创建一个空的 Spring Boot 工程
  提示 :a、可以使用 Spring Initializer (opens new window)快速初始化一个 Spring Boot 工程b、也可以创建一个maven空工程,然后按需要引入依赖

#添加依赖

  • 2、 引入 Spring Boot Starter 父工程
      <parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><!-- 因为使用的mybatis plus 3.+ 所以需要指定springboot3.+以上的版本 --><version>3.1.5</version><relativePath/></parent>
    
  • 3、 引入 spring-boot-starter、spring-boot-starter-test、mybatis-plus-boot-starter、mysql 依赖:
  <dependencies><!-- SpringBoot --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><!-- lombok --><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><scope>provided</scope></dependency><!-- mybatis plus3 --><dependency><groupId>com.baomidou</groupId><!--3.5.4开始,支持SpringBoot3使用此版本--><artifactId>mybatis-plus-spring-boot3-starter</artifactId><version>3.5.4</version></dependency><!-- mysql --><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.33</version><scope>runtime</scope></dependency></dependencies>
  • 4、 配置application.yml 文件 主要是数据库连接信息
spring:datasource:url: jdbc:mysql://localhost:3306/test_db?serverTimezone=UTC&useSSL=false&allowPublicKeyRetrieval=trueusername: rootpassword: 123456driver-class-name: com.mysql.cj.jdbc.Driver
  • 5、 添加启动类,在 Spring Boot 启动类中添加 @MapperScan 注解,扫描 Mapper 文件夹
package org.example;import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
@MapperScan("org.example.mapper")
public class DemoMybatis3Application {public static void main(String[] args) {SpringApplication.run(DemoMybatis3Application.class, args);}
}
  • 6、编写 User 实体类 及 UserMapper 接口
@Data
@TableName("`user`")
public class User extends Model<User>{private Long id;private String name;private Integer age;private String email;
}
public interface UserMapper  extends BaseMapper<User> {}
  • 7、 CRUD操作测试
 /*** 测试查询所有*/@Testpublic void testSelectAll() {System.out.println(("----- selectAll method test ------"));User user = new User();List<User> userList = user.selectAll();userList.forEach(System.out::println);}/*** 测试新增*/@Testpublic void add() {System.out.println(("----- add method test ------"));User user = new User();user.setName("赵六");user.setAge(30);user.setEmail("zhaoliu@163.com");user.insert();System.out.println(user.toString());}/*** 测试单条查询*/@Testpublic void getOne() {System.out.println(("----- getOne method test ------"));User user = new User();
//        user.setId(9L);
//        user = user.selectById();user = user.selectById(9L);System.out.println(user.toString());}/*** 测试修改*/@Testpublic void update() {System.out.println(("----- update method test ------"));User user = new User();user.setId(9L);user.setName("赵六六");user.setAge(33);user.setEmail("zhaoliu@163.com");user.updateById();System.out.println(user.toString());}/*** 测试删除*/@Testpublic void del() {System.out.println(("----- del method test ------"));User user = new User();
//        user.setId(9L);
//        user.deleteById();boolean b = user.deleteById(9L);System.out.println(b);}
  • 8、 SimpleQuery 工具类
说明:
对selectList查询后的结果用Stream流进行了一些封装,使其可以返回一些指定结果,简洁了api的调用
需要项目中已注入对应实体的BaseMapper

测试代码示例

 @Test
public void listOperate() {
System.out.println(("----- SimpleQuery listOperate method test ------"));
List<String> userNames = new java.util.ArrayList<>();
List<String> emails = new java.util.ArrayList<>();
// 该查询 追加了 获取id集,打印,获取name集,获取email集的操作
List<Long> ids = SimpleQuery.list(lambdaQuery(),User::getId, System.out::println, user -> userNames.add(user.getName()),user -> emails.add(user.getEmail()));
// 打印ids
ids.forEach(System.out::println);
// 打印userNames
userNames.forEach(System.out::println);
// 打印emails
emails.forEach(System.out::println);
}/**
* 测试查询 keyMap 返回为Map<属性,实体>
*/
@Test
public void keyMap() {
System.out.println(("----- SimpleQuery keyMap method test ------"));
// 查询表内记录,封装返回为Map<属性,实体>
//        Map<Long,User> userMap = SimpleQuery.keyMap(Wrappers.lambdaQuery(),
//                User::getId);
// 查询表内记录,封装返回为Map<属性,实体>,考虑了并行流的情况
Map<Long,User> userMap = SimpleQuery.keyMap(lambdaQuery(),User::getId,true);
userMap.forEach((k,v)->{System.out.println(k+"-->"+v);
});
}/**
* 测试查询 map  返回为Map<属性,属性>
*/
@Test
public void map() {
System.out.println(("----- SimpleQuery map method test ------"));
//  查询表内记录,封装返回为Map<属性,属性>
//        Map<Long,String> userMap = SimpleQuery.map(Wrappers.lambdaQuery(),
//                User::getId,User::getName);
// 查询表内记录,封装返回为Map<属性,属性>,考虑了并行流的情况
Map<Long,String> userMap = SimpleQuery.map(lambdaQuery(),User::getId,User::getEmail,true);
userMap.forEach((k,v)->{System.out.println(k+"-->"+v);
});
}/**
* 测试查询 group  返回为Map<属性,List<实体>>
*/
@Test
public void group() {
System.out.println(("----- SimpleQuery group method test ------"));
//  查询表内记录,封装返回为Map<属性,List<实体>>
//        Map<Integer,List<User>> userMap = SimpleQuery.group(Wrappers.lambdaQuery(),
//                User::getAge);
// 查询表内记录,封装返回为Map<属性,List<实体>>,考虑了并行流的情况
Map<Integer,List<User>> userMap = SimpleQuery.group(lambdaQuery(),User::getAge,true);
userMap.forEach((k,v)->{System.out.println(k+"-->"+v);
});
}/**
* 测试查询 group  返回为Map<属性,分组后对集合进行的下游收集器>
*/
@Test
public void groupM() {
System.out.println(("----- SimpleQuery groupM method test ------"));
//  查询表内记录,封装返回为Map<属性,List<实体>>
//        Map<Integer, Set<User>> group = SimpleQuery.group(Wrappers.lambdaQuery(),
//                User::getAge, Collectors.toSet());//        Map<Integer, Map<Long, String>> group = SimpleQuery.group(Wrappers.lambdaQuery(),
//                User::getAge, Collectors.toMap(User::getId, User::getName, (a, b) -> a));//        // 查询表内记录,封装返回为Map<属性,List<实体>>,考虑了并行流的情况
//        Map<Integer, Set<User>> group = SimpleQuery.group(Wrappers.lambdaQuery(),
//                User::getAge, Collectors.toSet(),true);
Map<Integer, Map<Long, String>> group = SimpleQuery.group(lambdaQuery(),User::getAge, Collectors.toMap(User::getId, User::getName, (a, b) -> a));
group.forEach((k,v)->{System.out.println(k+"-->"+v);
});
}/**
* 测试查询 list 返回为List<属性>
*/
@Test
public void list() {
System.out.println(("----- SimpleQuery list method test ------"));
// 查询表内记录,封装返回为List<属性>
//        List<String> names = SimpleQuery.list(Wrappers.lambdaQuery(), User::getName);
// 查询表内记录,封装返回为List<属性>,考虑了并行流的情况
List<String> names = SimpleQuery.list(lambdaQuery(), User::getName,true);
// 打印 names
names.forEach(System.out::println);
}@Test
void testList() {
// 我要这张表里的ids
List<Long> entityIds = SimpleQuery.list(lambdaQuery(), User::getId);
assertThat(entityIds).containsExactly(1L, 2L);// 可叠加后续操作
List<String> names = SimpleQuery.list(lambdaQuery(), User::getName,e -> Optional.ofNullable(e.getName()).map(String::toUpperCase).ifPresent(e::setName));
assertThat(names).containsExactly("RUBEN", null);
}
  • 9、Db类
说明:使用静态调用的方式,执行CRUD方法,避免Spring环境下Service循环注入、简洁代码,提升效率
需要项目中已注入对应实体的BaseMapper
对于参数为Wrapper的,需要在Wrapper中传入Entity或者EntityClass供寻找对应的Mapper
不建议在循环中调用,如果是批量保存,建议将数据构造好后使用 Db.saveBatch(数据) 保存

代码示例

 @Testvoid dbTest() {// 根据id查询List<User> list = Db.listByIds(Arrays.asList(1L, 2L), User.class);list.stream().forEach(System.out::println);// 根据条件构造器查询List<User> list1 = Db.list(Wrappers.lambdaQuery(User.class));list1.stream().forEach(System.out::println);// 批量根据id更新
//        boolean isSuccess = Db.updateBatchById(list);}

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

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

相关文章

docker八大架构之应用服务集群架构

应用服务集群架构 在之前&#xff0c;一个应用层要负责所有的用户操作&#xff0c;但是有时用户增加后就会导致供不应求的现象&#xff08;单个应用不足以支持海量的并发请求&#xff0c;高并发的时候站点响应变慢&#xff09;&#xff0c;这时就需要增加应用层服务器&#xf…

【STM32 |GPIO】GPIO结构、GPIO输出

目录 GPIO简介 GPIO的基本结构 GPIO位结构&#xff08;每一位的具体电路结构&#xff09; 输入 上拉和下拉电阻 斯密特触发器 ​编辑 输出 GPIO模式 ​编辑 浮空输入、上拉输入、下拉输入 模拟输入 开漏输出和推挽输出 复用开漏输出和复用推挽输出 LED和蜂鸣器…

简述线程同步和线程通信及如何实现线程间的同步

一、线程同步和线程通信是多线程编程中的两个重要概念。 线程同步&#xff1a; 线程同步是指当有一个线程在对内存进行操作时&#xff08;如读取、写入等&#xff09;&#xff0c;其他线程都不可以对该内存地址进行操作&#xff0c;直到该线程完成操作&#xff0c;其他线程才…

FFmpeg开发笔记(二十七)APP无法访问ZLMediaKit的HLS直播地址

上一篇文章介绍了如何通过ZLMediaKit实现视频推拉流&#xff0c;并使用VLC播放器验证视频直播地址。即使不用VLC播放器&#xff0c;直接在Qt工程的C代码中调用FFmpeg的API&#xff0c;也能访问ZLMediaKit的直播地址&#xff0c;并正常渲染视频画面。关于如何在Qt工程中引入FFmp…

【资源分享】完胜谷歌翻译的Deepl翻译

::: block-1 “时问桫椤”是一个致力于为本科生到研究生教育阶段提供帮助的不太正式的公众号。我们旨在在大家感到困惑、痛苦或面临困难时伸出援手。通过总结广大研究生的经验&#xff0c;帮助大家尽早适应研究生生活&#xff0c;尽快了解科研的本质。祝一切顺利&#xff01;—…

【数据结构与算法】力扣 111. 二叉树的最小深度

题目描述 给定一个二叉树&#xff0c;找出其最小深度。 最小深度是从根节点到最近叶子节点的最短路径上的节点数量。 说明&#xff1a; 叶子节点是指没有子节点的节点。 示例 1&#xff1a; 输入&#xff1a; root [3,9,20,null,null,15,7] 输出&#xff1a; 2示例 2&#…

长事务的理解和预防

我们常常听说数据库发生了“长事务”而导致很严重的后果。那么何为长事务&#xff1f;长事务是如何产生的&#xff1f;长事务对数据库有什么影响&#xff1f;如何防止长事务的产生&#xff1f;以下对这几方面进行阐述和说明&#xff0c;以加深对SinoDB长事务的理解。 1&#x…

Python-VBA函数之旅-super函数

目录 一、super函数的常见应用场景 二、super函数使用注意事项 三、如何用好super函数&#xff1f; 1、super函数&#xff1a; 1-1、Python&#xff1a; 1-2、VBA&#xff1a; 2、推荐阅读&#xff1a; 个人主页&#xff1a; https://myelsa1024.blog.csdn.net/ 一、su…

AI代理和AgentOps生态系统的剖析

1、AI代理的构成&#xff1a;AI代理能够根据用户的一般性指令自行做出决策和采取行动。 主要包含四个部分&#xff1a; &#xff08;1&#xff09;大模型&#xff08;LLM&#xff09; &#xff08;2&#xff09;工具&#xff1a;如网络搜索、代码执行等 &#xff08;3&#x…

探索未来:IT行业的革新脉动与明日图景

你眼中的IT行业现状与未来趋势 随着技术的不断进步&#xff0c;IT行业已成为推动全球经济和社会发展的关键力量。从云计算、大数据、人工智能到物联网、5G通信和区块链&#xff0c;这些技术正在重塑我们的生活和工作方式。你眼中IT行业的现状及未来发展趋势是怎么样的&#xf…

开散列哈希桶

通过上面这幅图&#xff0c;读者应该能较为直观地理解何为开散列&#xff0c;以及闭散列与开散列的区别在哪里 —— 数据的存储形式不同&#xff0c;至于其他的&#xff0c;如确定每个元素的哈希地址等一概相同。 与闭散列相比&#xff0c;开散列能够更好地处理发生冲突的元素 …

Taro + React + Tailwind 开发微信小程序问题汇总(持续更新中...)

搞小程序也有两周了&#xff0c;踩了很多坑&#xff0c;有些问题很难搜索到&#xff0c;在这里记录一下问题和自己的解决方案&#xff0c;希望能帮助到需要的小伙伴&#xff5e; 1. 真机调试报错&#xff1a;Error: module ‘babel/runtime/helpers/Arrayincludes.js’ is not …

Transformers 加速的一些常用技巧

Transformers 是一个强大的架构&#xff0c;但模型因其采用的自注意力机制&#xff0c;虽然能够有效地处理序列数据并捕获长距离依赖关系&#xff0c;但同时也容易导致在训练过程中出现OOM&#xff08;Out of Memory&#xff0c;内存不足&#xff09;或者达到GPU的运行时限制。…

AI大模型探索之路-训练篇22: ChatGLM3微调实战-从原理到应用的LoRA技术全解

系列篇章&#x1f4a5; AI大模型探索之路-训练篇1&#xff1a;大语言模型微调基础认知 AI大模型探索之路-训练篇2&#xff1a;大语言模型预训练基础认知 AI大模型探索之路-训练篇3&#xff1a;大语言模型全景解读 AI大模型探索之路-训练篇4&#xff1a;大语言模型训练数据集概…

MPLAB X IDE编译attiny1616工程报错却无报错信息

MPLAB X IDE(XC-8编译器)编译报错&#xff0c;无具体错误内容&#xff0c;仅显示需要xc-8 pro的警告。 内存占用率显示为81%&#xff0c;未超标。 原因&#xff1a;软件使用了microchip的bootloader功能。应用程序起始地址&#xff08;也是bootloader结束地址&#xff09;设置错…

社交巨头:探索Facebook的震撼力量

Facebook作为社交媒体领域的巨头&#xff0c;不仅在数字化社会中占据着重要地位&#xff0c;更是影响了人们的生活、工作和社交方式。本文将深入探索Facebook的震撼力量&#xff0c;从多个角度解读其在当今社会中的重要性和影响。 1. 全球用户覆盖的壮观规模 Facebook作为全球…

软件定义汽车七大典型应用场景

随着软件定义汽车典型应用场景的落地&#xff0c;用户将明显体验到汽车从交通工具向智能移动终端的转变。几十年前主要用高性能的底盘操稳与动力系统定义一台好车&#xff0c;几年前主要用智能化系统与智能交互满足终端用户的用车体验&#xff0c;未来将调度全车传感器与数据驱…

c 数组遍历

#include <stdio.h> #include <stdlib.h> int main() { printf(“指针数组练习&#xff01;&#xff01;&#xff01;\n”); /* 数组名就是数组的首地址 数组存在一段连续的内存空间中 */ double score[] {60, 70, 80, 90, 100}; double *ptr_score; i…

docker安装时报错:Error: Nothing to do

安装docker时报以下错误 解决方法&#xff1a; 1.下载关于docker的相关依赖环境 yum -y install yum-utils device-mapper-persistent-data lvm22.设置下载Docker的镜像源 yum-config-manager --add-repo http://mirrors.aliyun.com/docker-ce/linux/centos/docker-ce.repo3…