使用MyBatis的动态SQL注解实现实体的CRUD操作

2024-06-21 23:28
文章标签 sql 动态 实现 使用 操作 注解 mybatis database crud 实体

本文主要是介绍使用MyBatis的动态SQL注解实现实体的CRUD操作，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

使用MyBatis的动态SQL注解实现实体的CRUD操作

  • 1. 引言
  • 2. 准备工作
    • 2.1 创建数据表
    • 2.2 创建实体类 `Book`
    • 2.3 修改Mapper接口 `BookMapper`
  • 3. 测试CRUD操作
    • 3.1 配置日志
    • 3.2 查询操作
    • 3.3 新增操作
    • 3.4 修改操作
    • 3.5 删除操作
  • 4. 与MyBatis Plus的对比
  • 5. 动态SQL注解的适用场景
    • 5.1 动态查询条件
    • 5.2 动态插入和更新
    • 5.3 复杂的业务逻辑
    • 5.4 查询结果动态列的聚合
  • 6. 小结

1. 引言

在使用MyBatis进行数据库操作时，动态SQL注解提供了一种优雅的方式来编写动态SQL语句。MyBatis 3.x 版本提供了以下四个CRUD的高级注解：

  • @SelectProvider：用于构建动态查询SQL。
  • @InsertProvider：用于构建动态新增SQL。
  • @UpdateProvider：用于构建动态更新SQL。
  • @DeleteProvider：用于构建动态删除SQL。

这些注解可以帮助开发者在Mapper接口中动态地构建SQL语句，避免了在XML配置文件中编写大量的SQL代码，使代码更加简洁和易于维护。本文将详细介绍如何使用这些动态SQL注解来实现书籍信息的查询、新增、修改和删除操作。

此外，我们将与MyBatis Plus中的@Select注解进行对比，展示MyBatis动态SQL注解的优势和灵活性。

2. 准备工作

2.1 创建数据表

首先，需要创建一个代表书籍信息的表 tb_book。

-- 判断数据表是否存在，存在则删除
DROP TABLE IF EXISTS tb_book;-- 创建“书籍信息”数据表
CREATE TABLE IF NOT EXISTS tb_book
(book_id INT AUTO_INCREMENT PRIMARY KEY COMMENT '书籍编号',book_name VARCHAR(50) NOT NULL COMMENT '书名',author VARCHAR(50) NOT NULL COMMENT '作者',publisher VARCHAR(50) COMMENT '出版社',publish_date DATE COMMENT '出版日期'
) COMMENT = '书籍信息表';-- 添加数据
INSERT INTO tb_book(book_name, author, publisher, publish_date) VALUES ('书籍1', '作者1', '出版社1', '2023-01-01');

2.2 创建实体类 Book

在 com.zhouquan.entity 包中创建 Book 类，使用 @Data 注解来自动生成getter和setter方法。

package com.zhouquan.entity;
import lombok.Data;
import java.util.Date;/*** 书籍信息实体类*/
@Data
public class Book {/*** 书籍编号*/private int bookId;/*** 书名*/private String bookName;/*** 作者*/private String author;/*** 出版社*/private String publisher;/*** 出版日期*/private Date publishDate;
}

2.3 修改Mapper接口 BookMapper

在 com.zhouquan.mapper 包中创建 BookMapper 接口，并使用动态SQL注解来实现CRUD操作。

package com.zhouquan.mapper;import com.zhouquan.entity.Book;
import org.apache.ibatis.annotations.*;
import org.apache.ibatis.jdbc.SQL;
import org.springframework.stereotype.Repository;@Mapper
@Repository
public interface BookMapper {@SelectProvider(type = BookSqlBuilder.class, method = "buildGetBookByIdSql")public Book getBookById(@Param("bookId") int bookId);@InsertProvider(type = BookSqlBuilder.class, method = "buildInsertBookSql")@Options(useGeneratedKeys = true, keyColumn = "book_id", keyProperty = "bookId")public int insertBook(Book book);@UpdateProvider(type = BookSqlBuilder.class, method = "buildUpdateBookSql")public int updateBook(Book book);@DeleteProvider(type = BookSqlBuilder.class, method = "buildDeleteBookSql")public int deleteBook(@Param("bookId") int bookId);class BookSqlBuilder {public String buildGetBookByIdSql(@Param("bookId") int bookId) {return new SQL() {{SELECT("*");FROM("tb_book");WHERE("book_id = #{bookId}");}}.toString();}public String buildInsertBookSql(Book book) {return new SQL() {{INSERT_INTO("tb_book");VALUES("book_name", "#{bookName}");VALUES("author", "#{author}");VALUES("publisher", "#{publisher}");VALUES("publish_date", "#{publishDate}");}}.toString();}public String buildUpdateBookSql(Book book) {return new SQL() {{UPDATE("tb_book");SET("book_name = #{bookName}", "author = #{author}", "publisher = #{publisher}", "publish_date = #{publishDate}");WHERE("book_id = #{bookId}");}}.toString();}public String buildDeleteBookSql(@Param("bookId") int bookId) {return new SQL() {{DELETE_FROM("tb_book");WHERE("book_id = #{bookId}");}}.toString();}}
}

3. 测试CRUD操作

为了测试CRUD操作，我们将使用JUnit进行单元测试，并通过日志记录操作的结果。

3.1 配置日志

在Maven的pom.xml文件中引入SLF4J和Logback的依赖：

<dependencies><!-- MyBatis 依赖 --><dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId><version>2.1.4</version></dependency><!-- SLF4J 依赖 --><dependency><groupId>org.slf4j</groupId><artifactId>slf4j-api</artifactId><version>1.7.30</version></dependency></dependencies>

3.2 查询操作

import com.zhouquan.entity.Book;
import com.zhouquan.mapper.BookMapper;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;public class BookMapperTest {private static final Logger logger = LoggerFactory.getLogger(BookMapperTest.class);@Autowiredprivate BookMapper bookMapper;/*** 根据书籍ID，获取书籍信息*/@Testpublic void getBookById() {Book book = bookMapper.getBookById(1);logger.info("书籍编号：{}", book.getBookId());logger.info("书名：{}", book.getBookName());logger.info("作者：{}", book.getAuthor());logger.info("出版社：{}", book.getPublisher());logger.info("出版日期：{}", book.getPublishDate());}
}

3.3 新增操作

@Autowired
private BookMapper bookMapper;/*** 新增书籍，并获取自增主键*/
@Test
public void insertBook() {Book book = new Book();book.setBookName("新书");book.setAuthor("新作者");book.setPublisher("新出版社");book.setPublishDate(new Date());bookMapper.insertBook(book);logger.info("新增书籍ID：{}", book.getBookId());
}

3.4 修改操作

@Autowired
private BookMapper bookMapper;/*** 更新书籍信息*/
@Test
public void updateBook() {Book book = bookMapper.getBookById(1);book.setBookName("更新后的书名");bookMapper.updateBook(book);logger.info("更新后的书名：{}", book.getBookName());
}

3.5 删除操作

@Autowired
private BookMapper bookMapper;/*** 删除书籍*/
@Test
public void deleteBook() {bookMapper.deleteBook(1);logger.info("删除书籍ID为1的记录");
}

4. 与MyBatis Plus的对比

MyBatis Plus提供了一种更加简洁的方式来编写SQL语句，例如，使用@Select注解可以直接在Mapper接口中编写SQL语句，而无需单独定义SQL构建器类。

例如，使用MyBatis Plus可以这样定义BookMapper接口：

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.zhouquan.entity.Book;
import org.apache.ibatis.annotations.Select;public interface BookMapper extends BaseMapper<Book> {@Select("SELECT * FROM tb_book WHERE book_id = #{bookId}")Book getBookById(int bookId);
}

这种方式相对于MyBatis动态SQL注解而言，更加直接和易读。但是，MyBatis动态SQL注解在处理复杂SQL语句时具有更高的灵活性和可维护性，特别是当需要根据不同条件动态生成SQL时，MyBatis动态SQL注解显得更为强大和适用

5. 动态SQL注解的适用场景

5.1 动态查询条件

在一些应用中，查询条件是动态的，可能根据不同的用户输入或业务逻辑生成不同的查询条件。使用动态SQL注解可以在运行时根据这些条件动态构建查询语句，避免了硬编码查询条件的问题。

public String buildDynamicQuerySql(Map<String, Object> params) {return new SQL() {{SELECT("*");FROM("tb_book");if (params.get("author") != null) {WHERE("author = #{author}");}if (params.get("publisher") != null) {WHERE("publisher = #{publisher}");}if (params.get("publishDate") != null) {WHERE("publish_date = #{publishDate}");}}}.toString();
}

5.2 动态插入和更新

在一些情况下，插入或更新的数据字段可能不是固定的，而是根据业务需求动态变化的。使用动态SQL注解可以根据传入的实体对象构建动态插入或更新语句。

public String buildDynamicInsertSql(Book book) {return new SQL() {{INSERT_INTO("tb_book");if (book.getBookName() != null) {VALUES("book_name", "#{bookName}");}if (book.getAuthor() != null) {VALUES("author", "#{author}");}if (book.getPublisher() != null) {VALUES("publisher", "#{publisher}");}if (book.getPublishDate() != null) {VALUES("publish_date", "#{publishDate}");}}}.toString();
}public String buildDynamicUpdateSql(Book book) {return new SQL() {{UPDATE("tb_book");if (book.getBookName() != null) {SET("book_name = #{bookName}");}if (book.getAuthor() != null) {SET("author = #{author}");}if (book.getPublisher() != null) {SET("publisher = #{publisher}");}if (book.getPublishDate() != null) {SET("publish_date = #{publishDate}");}WHERE("book_id = #{bookId}");}}.toString();
}

5.3 复杂的业务逻辑

在一些复杂的业务场景中，SQL语句的构建逻辑可能非常复杂，涉及多个表的联接、多种条件的判断等。使用动态SQL注解可以在Java代码中使用条件逻辑来构建复杂的SQL语句，使代码更加清晰和易于维护。

public String buildComplexQuerySql(Book book) {return new SQL() {{SELECT("b.*, a.author_name, p.publisher_name");FROM("tb_book b");JOIN("tb_author a ON b.author_id = a.author_id");JOIN("tb_publisher p ON b.publisher_id = p.publisher_id");if (book.getBookName() != null) {WHERE("b.book_name LIKE CONCAT('%', #{bookName}, '%')");}if (book.getAuthor() != null) {WHERE("a.author_name LIKE CONCAT('%', #{author}, '%')");}if (book.getPublisher() != null) {WHERE("p.publisher_name LIKE CONCAT('%', #{publisher}, '%')");}}}.toString();
}

5.4 查询结果动态列的聚合

需求类似于下，根据专题聚合出不同的资料类型，select中的列需要动态的拼接，显然MP的mapper对于此种需求的支持并不友好

image-20240621171513659

 /*** 资源量统计-根据专题* 之所以使用此种方式是因为统计的列是不固定的，所以需要动态拼接select** @param resourceTypeNameList 资源名称列表* @param resourceTypeSidList  资源sid列表* @param start                加工开始时间* @param end                  加工结束时间* @return*/public String groupTopicDynamicSQL(final List<String> resourceTypeNameList, final List<String> resourceTypeSidList,final LocalDate start, final LocalDate end) {// 构建外部查询SQL outerQuery = new SQL();outerQuery.SELECT("COALESCE(topic_name, '总计') AS '专题'");if (resourceTypeNameList != null && !resourceTypeNameList.isEmpty()) {for (String rt : resourceTypeNameList) {outerQuery.SELECT(String.format("SUM(CASE WHEN resource_type_name = '%s' THEN count ELSE 0 END) AS " +"'%s'", rt, rt));}}// 构建子查询SQL subQuery = new SQL();subQuery.SELECT("rt.name AS resource_type_name, t.name AS topic_name, COUNT(*) AS count").FROM("works w").JOIN("works_topic wt ON w.sid = wt.work_sid").JOIN("topic t ON wt.topic_sid = t.sid").JOIN("resource_type rt ON w.type_leaf_sid = rt.sid").WHERE(" w.deleted=0 ");if (resourceTypeNameList != null && !resourceTypeNameList.isEmpty()) {String joinedResourceTypes = resourceTypeSidList.stream().map(rt -> "'" + rt + "'").collect(Collectors.joining(", "));subQuery.WHERE("w.type_leaf_sid IN (" + joinedResourceTypes + ")");}if (start != null) {subQuery.WHERE("w.update_time >= #{start}");}if (end != null) {subQuery.WHERE("w.update_time <= #{end}");}subQuery.GROUP_BY("rt.name, t.name");outerQuery.SELECT("SUM(count) AS '总计'").FROM("(" + subQuery + ") AS subQuery").GROUP_BY("topic_name WITH ROLLUP");return outerQuery.toString();}

/*** 统计分析-资源量统计** @param resourceTypeNameList* @param resourceTypeSidList* @param start* @param end* @return*/
@SelectProvider(type = WorksSqlProvider.class, method = "groupTopicDynamicSQL")
List<Map<String, Object>> staticByTopic(@Param("resourceTypeNameList") List<String> resourceTypeNameList,@Param("resourceTypeSidList") List<String> resourceTypeSidList,@Param("start") LocalDate start,@Param("end") LocalDate end);

6. 小结

MyBatis动态SQL注解通过提供更加灵活和动态的方式来构建SQL语句，使得代码更加简洁和易于维护。而MyBatis Plus通过简化SQL编写过程，提供了一种更加便捷的方式来进行数据库操作。根据具体项目的需求和复杂度，可以选择适合的工具来实现数据库操作。

通过上述介绍，可以看出动态SQL注解在处理动态查询条件、动态插入和更新以及复杂的业务逻辑时具有明显的优势和适用性。在实际开发中，合理使用动态SQL注解可以提高代码的灵活性和可维护性。

这篇关于使用MyBatis的动态SQL注解实现实体的CRUD操作的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1082636。

相关文章

C语言中联合体union的使用

C语言中联合体union的使用

本文编辑整理自： http://bbs.chinaunix.net/forum.php?mod=viewthread&tid=179471 一、前言 “联合体”(union）与“结构体”(struct)有一些相似之处。但两者有本质上的不同。在结构体中,各成员有各自的内存空间, 一个结构变量的总长度是各成员长度之和。而在“联合”中,各成员共享一段内存空间, 一个联合变量
阅读更多...
C++对象布局及多态实现探索之内存布局（整理的很多链接）

C++对象布局及多态实现探索之内存布局（整理的很多链接）

本文通过观察对象的内存布局，跟踪函数调用的汇编代码。分析了C++对象内存的布局情况，虚函数的执行方式，以及虚继承，等等 文章链接：http://dev.yesky.com/254/2191254.shtml      论C/C++函数间动态内存的传递 (2005-07-30)   当你涉及到C/C++的核心编程的时候，你会无止境地与内存管理打交道。 文章链接：http://dev.yesky
阅读更多...
Tolua使用笔记（上）

Tolua使用笔记（上）

目录   1.准备工作 2.运行例子 01.HelloWorld：在C#中，创建和销毁Lua虚拟机 和 简单调用。 02.ScriptsFromFile：在C#中，对一个lua文件的执行调用 03.CallLuaFunction：在C#中，对lua函数的操作 04.AccessingLuaVariables：在C#中，对lua变量的操作 05.LuaCoroutine：在Lua中，
阅读更多...
RedHat运维-Linux文本操作基础-AWK进阶

RedHat运维-Linux文本操作基础-AWK进阶

你不用整理，跟着敲一遍，有个印象，然后把它保存到本地，以后要用再去看，如果有了新东西，你自个再添加。这是我参考牛客上的shell编程专项题，只不过换成了问答的方式而已。不用背，就算是我自己亲自敲，我现在好多也记不住。 1. 输出nowcoder.txt文件第5行的内容 2. 输出nowcoder.txt文件第6行的内容 3. 输出nowcoder.txt文件第7行的内容 4. 输出nowcode
阅读更多...
Vim使用基础篇

Vim使用基础篇

本文内容大部分来自 vimtutor，自带的教程的总结。在终端输入vimtutor 即可进入教程。 先总结一下，然后再分别介绍正常模式，插入模式，和可视模式三种模式下的命令。 目录 看完以后的汇总 1.正常模式（Normal模式） 1.移动光标 2.删除 3.【:】输入符 4.撤销 5.替换 6.重复命令【. ; ,】 7.复制粘贴 8.缩进 2.插入模式 INSERT
阅读更多...
mysql索引四（组合索引）

mysql索引四（组合索引）

单列索引，即一个索引只包含单个列，一个表可以有多个单列索引，但这不是组合索引；组合索引，即一个索引包含多个列。 因为有事，下面内容全部转自：https://www.cnblogs.com/farmer-cabbage/p/5793589.html 为了形象地对比单列索引和组合索引，为表添加多个字段： 　　 CREATE TABLE mytable( ID INT NOT NULL, use
阅读更多...
mysql索引三（全文索引）

mysql索引三（全文索引）

前面分别介绍了mysql索引一（普通索引）、mysql索引二（唯一索引）。 本文学习mysql全文索引。 全文索引（也称全文检索）是目前搜索引擎使用的一种关键技术。它能够利用【分词技术】等多种算法智能分析出文本文字中关键词的频率和重要性，然后按照一定的算法规则智能地筛选出我们想要的搜索结果。 在MySql中，创建全文索引相对比较简单。例如：我们有一个文章表（article），其中有主键ID（
阅读更多...
mysql索引二（唯一索引）

mysql索引二（唯一索引）

前文中介绍了MySQL中普通索引用法，和没有索引的区别。mysql索引一（普通索引） 下面学习一下唯一索引。 创建唯一索引的目的不是为了提高访问速度，而只是为了避免数据出现重复。唯一索引可以有多个但索引列的值必须唯一，索引列的值允许有空值。如果能确定某个数据列将只包含彼此各不相同的值，在为这个数据列创建索引的时候就应该使用关键字UNIQUE，把它定义为一个唯一索引。 添加数据库唯一索引的几种
阅读更多...
mysql索引一（普通索引）

mysql索引一（普通索引）

mysql的索引分为两大类，聚簇索引、非聚簇索引。聚簇索引是按照数据存放的物理位置为顺序的，而非聚簇索引则不同。聚簇索引能够提高多行检索的速度、非聚簇索引则对单行检索的速度很快。         在这两大类的索引类型下，还可以降索引分为4个小类型：         1，普通索引：最基本的索引，没有任何限制，是我们经常使用到的索引。         2，唯一索引：与普通索引
阅读更多...
持久层 技术选型如何决策？JPA，Hibernate，ibatis(mybatis)

持久层 技术选型如何决策？JPA，Hibernate，ibatis(mybatis)

转自：http://t.51jdy.cn/thread-259-1-1.html 持久层 是一个项目 后台 最重要的部分。他直接 决定了 数据读写的性能，业务编写的复杂度，数据结构(对象结构)等问题。 因此 架构师在考虑 使用那个持久层框架的时候 要考虑清楚。 选择的 标准： 1，项目的场景。 2，团队的技能掌握情况。 3，开发周期(开发效率)。 传统的 业务系统，通常业
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2