• Mybatis SQL构建器

    上一篇我们介绍了在Mybatis映射器中使用@SelectProvider、@InsertProvider、@UpdateProvider、@DeleteProvider进行对数据的增删改查操作；本篇我们介绍如何使用SQL构建器在Provider中优雅的构建SQL语句。

    如果您对在Mybatis映射器中使用@SelectProvider、@InsertProvider、@UpdateProvider、@DeleteProvider进行对数据的增删改查操作不太了解，建议您先进行了解后再阅读本篇，可以参考：

    Mybatis 映射器中使用@InsertProvider,@UpdateProvider,@DeleteProvider,@SelectProvidericon-default.png?t=N7T8https://blog.csdn.net/m1729339749/article/details/133122304

    一、数据准备

    这里我们直接使用脚本初始化数据库中的数据

    1. -- 如果数据库不存在则创建数据库
    2. CREATE DATABASE IF NOT EXISTS demo DEFAULT CHARSET utf8;
    3. -- 切换数据库
    4. USE demo;
    5. -- 创建用户表
    6. CREATE TABLE IF NOT EXISTS T_USER(
    7.   ID INT PRIMARY KEY,
    8.   USERNAME VARCHAR(32) NOT NULL,
    9.   AGE INT NOT NULL 
    10. );
    11. -- 插入用户数据
    12. INSERT INTO T_USER(ID, USERNAME, AGE)
    13. VALUES(1, '张三', 20),(2, '李四', 22),(3, '王五', 24);

    创建了一个名称为demo的数据库；并在库里创建了名称为T_USER的用户表并向表中插入了数据

    二、创建实体类

    在cn.horse.demo下创建UserInfo、UserInfoQuery类

    UserInfo类：

    1. package cn.horse.demo;
    2.  
    3. public class UserInfo {
    4.  
    5.     private Integer id;
    6.     private String name;
    7.     private Integer age;
    8.  
    9.     public void setId(Integer id) {
    10.         this.id = id;
    11.     }
    12.  
    13.     public Integer getId() {
    14.         return id;
    15.     }
    16.  
    17.     public void setName(String name) {
    18.         this.name = name;
    19.     }
    20.  
    21.     public String getName() {
    22.         return name;
    23.     }
    24.  
    25.     public void setAge(Integer age) {
    26.         this.age = age;
    27.     }
    28.  
    29.     public Integer getAge() {
    30.         return age;
    31.     }
    32.  
    33.     @Override
    34.     public String toString() {
    35.         StringBuilder stringBuilder = new StringBuilder();
    36.         stringBuilder.append('{');
    37.         stringBuilder.append("id: " + this.id);
    38.         stringBuilder.append(", ");
    39.         stringBuilder.append("name: " + this.name);
    40.         stringBuilder.append(", ");
    41.         stringBuilder.append("age: " + this.age);
    42.         stringBuilder.append('}');
    43.         return stringBuilder.toString();
    44.     }
    45. }

    UserInfoQuery类：

    1. package cn.horse.demo;
    2.  
    3. public class UserInfoQuery {
    4.  
    5.     private Integer startAge;
    6.     private Integer endAge;
    7.  
    8.     public void setStartAge(Integer startAge) {
    9.         this.startAge = startAge;
    10.     }
    11.  
    12.     public Integer getStartAge() {
    13.         return startAge;
    14.     }
    15.  
    16.     public void setEndAge(Integer endAge) {
    17.         this.endAge = endAge;
    18.     }
    19.  
    20.     public Integer getEndAge() {
    21.         return endAge;
    22.     }
    23. }

    三、创建UserInfoMapper映射器、UserInfoSqlProvider类

    在cn.horse.demo下创建UserInfoMapper接口、UserInfoSqlProvider类

    UserInfoMapper接口：

    1. package cn.horse.demo;
    2.  
    3. import org.apache.ibatis.annotations.*;
    4.  
    5. import java.util.List;
    6.  
    7. public interface UserInfoMapper {
    8.  
    9.     @SelectProvider(type = UserInfoSqlProvider.class, method = "select")
    10.     List find(@Param("query") UserInfoQuery query);
    11.  
    12.     @InsertProvider(type = UserInfoSqlProvider.class, method = "insert")
    13.     Integer insert(@Param("userInfo") UserInfo userInfo);
    14.  
    15.     @UpdateProvider(type = UserInfoSqlProvider.class, method = "update")
    16.     Integer update(@Param("userInfo") UserInfo userInfo);
    17.  
    18.     @DeleteProvider(type = UserInfoSqlProvider.class, method = "delete")
    19.     Integer delete(@Param("id") Integer id);
    20. }

    在UserInfoMapper接口中我们把查询、新增、修改、删除数据的SQL语句的构建委托给了UserInfoSqlProvider类中的select、insert、update、delete方法

    UserInfoSqlProvider类：

    1. package cn.horse.demo;
    2.  
    3. import org.apache.ibatis.annotations.Param;
    4. import org.apache.ibatis.jdbc.SQL;
    5.  
    6. import java.util.*;
    7.  
    8. public class UserInfoSqlProvider {
    9.  
    10.     public String select(@Param("query") UserInfoQuery query) {
    11.         SQL sql = new SQL()
    12.                 .SELECT("ID", "USERNAME name", "AGE")
    13.                 .FROM("T_USER");
    14.         if(Objects.isNull(query)) {
    15.             return sql.toString();
    16.         }
    17.         if(Objects.nonNull(query.getStartAge())) {
    18.             sql.WHERE("AGE >= #{query.startAge}");
    19.         }
    20.         if(Objects.nonNull(query.getEndAge())) {
    21.             sql.WHERE("AGE <= #{query.endAge}");
    22.         }
    23.         return sql.toString();
    24.     }
    25.  
    26.     public String insert(@Param("userInfo") UserInfo userInfo) {
    27.         return new SQL()
    28.                 .INSERT_INTO("T_USER")
    29.                 .VALUES("ID, USERNAME, AGE", "#{userInfo.id},#{userInfo.name},#{userInfo.age}")
    30.                 .toString();
    31.     }
    32.  
    33.     public String update(@Param("userInfo") UserInfo userInfo) {
    34.  
    35.         SQL sql = new SQL()
    36.                 .UPDATE("T_USER");
    37.         sql.SET("ID = #{userInfo.id}");
    38.         if(Objects.nonNull(userInfo.getName())) {
    39.             sql.SET("USERNAME = #{userInfo.name}");
    40.         }
    41.         if(Objects.nonNull(userInfo.getAge())) {
    42.             sql.SET("AGE = #{userInfo.age}");
    43.         }
    44.         sql.WHERE("ID = #{userInfo.id}");
    45.         return sql.toString();
    46.     }
    47.  
    48.     public String delete(@Param("id") Integer id) {
    49.         return new SQL()
    50.                 .DELETE_FROM("T_USER")
    51.                 .WHERE("ID = #{id}")
    52.                 .toString();
    53.     }
    54. }

    在UserInfoSqlProvider类的select、insert、update、delete方法中我们使用SQL类进行构建SQL语句，其提供了一些常用的方法来帮助我们优雅的构建SQL语句。

    四、引入配置文件

    在resources下新建mybatis-config.xml配置文件，并引入UserInfoMapper映射器。

    1. "1.0" encoding="UTF-8" ?>
    2. configuration
    3.         PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
    4.         "http://mybatis.org/dtd/mybatis-3-config.dtd">
    5. <configuration>
    6.     <settings>
    7.         <setting name="logImpl" value="JDK_LOGGING"/>
    8.     settings>
    9.  
    10.     <environments default="development">
    11.         <environment id="development">
    12.             <transactionManager type="JDBC"/>
    13.             <dataSource type="POOLED">
    14.                 <property name="driver" value="org.gjt.mm.mysql.Driver"/>
    15.                 <property name="url" value="jdbc:mysql://localhost:3306/demo?useUnicode=true&useSSL=false&characterEncoding=utf8"/>
    16.                 <property name="username" value="root"/>
    17.                 <property name="password" value="horse"/>
    18.             dataSource>
    19.         environment>
    20.     environments>
    21.  
    22.     <mappers>
    23.         <mapper class="cn.horse.demo.UserInfoMapper" />
    24.     mappers>
    25. configuration>

    这里我们使用mapper引入映射器，只需要设置class属性为UserInfoMapper接口的全限类名。

    五、启动程序配置

    1、会话工具类

    在cn.horse.demo包下新建SqlSessionUtils工具类

    1. package cn.horse.demo;
    2.  
    3. import org.apache.ibatis.session.SqlSession;
    4. import org.apache.ibatis.session.SqlSessionFactory;
    5. import org.apache.ibatis.session.SqlSessionFactoryBuilder;
    6.  
    7. import java.io.InputStream;
    8. import java.util.Objects;
    9.  
    10. public class SqlSessionUtils {
    11.  
    12.     private static final SqlSessionFactory sqlSessionFactory;
    13.     static {
    14.         // 读取mybatis配置文件
    15.         InputStream inputStream = ClassLoader.getSystemClassLoader().getResourceAsStream("mybatis-config.xml");
    16.         // 根据配置创建SqlSession工厂
    17.         sqlSessionFactory = new SqlSessionFactoryBuilder()
    18.                 .build(inputStream);
    19.     }
    20.  
    21.     /**
    22.      * 开启会话
    23.      * @return
    24.      */
    25.     public static SqlSession openSession() {
    26.         return sqlSessionFactory.openSession();
    27.     }
    28.  
    29.     /**
    30.      * 关闭会话
    31.      * @param sqlSession
    32.      */
    33.     public static void closeSession(SqlSession sqlSession) {
    34.         if(Objects.nonNull(sqlSession)) {
    35.             sqlSession.close();
    36.         }
    37.     }
    38. }

    2、JDK 日志系统配置

    在resources的目录下新建logging.properties配置文件

    1. handlers=java.util.logging.ConsoleHandler
    2. .level=INFO
    3.  
    4. cn.horse.demo.UserInfoMapper.level=FINER
    5. java.util.logging.ConsoleHandler.level=ALL
    6. java.util.logging.ConsoleHandler.formatter=java.util.logging.SimpleFormatter
    7. java.util.logging.SimpleFormatter.format=%1$tY-%1$tm-%1$td %1$tT.%1$tL %4$s %3$s - %5$s%6$s%n

    在cn.horse.demo下创建JdkLogConfig类

    JdkLogConfig类：

    1. package cn.horse.demo;
    2.  
    3. import java.io.IOException;
    4. import java.io.InputStream;
    5. import java.util.logging.LogManager;
    6.  
    7. public class JdkLogConfig {
    8.  
    9.     public JdkLogConfig() {
    10.         try {
    11.             InputStream inputStream = ClassLoader.getSystemClassLoader().getResourceAsStream("logging.properties");
    12.             LogManager.getLogManager().readConfiguration(inputStream);
    13.         } catch (IOException e) {
    14.             throw new RuntimeException(e);
    15.         }
    16.     }
    17. }

    3、启动程序配置

    1. package cn.horse.demo;
    2.  
    3. import org.apache.ibatis.session.SqlSession;
    4.  
    5. import java.util.List;
    6. import java.util.function.Consumer;
    7.  
    8. public class Main {
    9.     public static void main(String[] args) {
    10.         // 引入JDK日志配置
    11.         System.setProperty("java.util.logging.config.class", "cn.horse.demo.JdkLogConfig");
    12.     }
    13.  
    14.     private static void execute(Consumer function) {
    15.         SqlSession sqlSession = null;
    16.         try {
    17.             sqlSession = SqlSessionUtils.openSession();
    18.             function.accept(sqlSession.getMapper(UserInfoMapper.class));
    19.             sqlSession.commit();
    20.         } finally {
    21.             SqlSessionUtils.closeSession(sqlSession);
    22.         }
    23.     }
    24. }

    execute方法用于执行操作，方法中使用sqlSession.getMapper方法获取映射器对象，然后将映射器对象具体的执行操作委托给了Consumer对象。

    六、查询数据

    1. // 引入JDK日志配置
    2. System.setProperty("java.util.logging.config.class", "cn.horse.demo.JdkLogConfig");
    3.  
    4. // 查询
    5. execute((UserInfoMapper userInfoMapper) -> {
    6.     UserInfoQuery query = new UserInfoQuery();
    7.     query.setEndAge(20);
    8.     List userInfoList = userInfoMapper.find(query);
    9.     for (UserInfo userInfo: userInfoList) {
    10.         System.out.println(userInfo);
    11.     }
    12. });

    执行后的结果如下：

    七、新增数据

    1. // 引入JDK日志配置
    2. System.setProperty("java.util.logging.config.class", "cn.horse.demo.JdkLogConfig");
    3.  
    4. // 插入
    5. execute((UserInfoMapper userInfoMapper) -> {
    6.     UserInfo userInfo = new UserInfo();
    7.     userInfo.setId(5);
    8.     userInfo.setName("王五1");
    9.     userInfo.setAge(5);
    10.     Integer total = userInfoMapper.insert(userInfo);
    11.     System.out.println("插入条数: " + total);
    12. });

    执行后的结果如下：

    八、修改数据

    1. // 引入JDK日志配置
    2. System.setProperty("java.util.logging.config.class", "cn.horse.demo.JdkLogConfig");
    3.  
    4. // 更新
    5. execute((UserInfoMapper userInfoMapper) -> {
    6.     UserInfo userInfo = new UserInfo();
    7.     userInfo.setId(5);
    8.     userInfo.setName("王五11");
    9.     Integer total = userInfoMapper.update(userInfo);
    10.     System.out.println("更新条数: " + total);
    11. });

    执行后的结果如下：

    九、删除数据

    1. // 引入JDK日志配置
    2. System.setProperty("java.util.logging.config.class", "cn.horse.demo.JdkLogConfig");
    3.  
    4. // 删除
    5. execute((UserInfoMapper userInfoMapper) -> {
    6.     Integer total = userInfoMapper.delete(5);
    7.     System.out.println("删除条数: " + total);
    8. });

    执行后的结果如下：

  • 相关阅读:
    vue视图响应-watch
    七周成为数据分析师 | 数据分析思维
    [基础服务] CentOS 7.x 安装NodeJS环境并搭建Hexo
    Android 编译错误：module xxx1 missing dependencies：xxx2
    【oceanbase】安装ocp，ocp部署oceanbase
    如何在VSCode中带有参数的Debug（name、program、$file、args、pickArgs、指定虚拟环境）
    信息学奥赛一本通（c++）：1128：图像模糊处理
    网络安全评估（网络安全评估）
    【HTML5高级第二篇】WebWorker多线程、EventSource事件推送、History历史操作
    Mybiosource丨Mybiosource胃泌素细胞抗体ELISA试剂盒方案
  • 原文地址：https://blog.csdn.net/m1729339749/article/details/133157020