共计 21355 个字符,预计需要花费 54 分钟才能阅读完成。
欢送拜访我的 GitHub
https://github.com/zq2599/blog_demos
内容:所有原创文章分类汇总及配套源码,波及 Java、Docker、Kubernetes、DevOPS 等;
本篇概览
- 本文是《MyBatis 高级实战》系列的第五篇,从多表获取数据是个常见的场景,个别有以下两种形式:
- 联表查问:join 操作,一次查问实现
- 屡次查问:用第一次查问的后果作为条件,再做查问(MyBatis 中叫做嵌套查问)
- 本篇的内容就是学习 MyBatis 对上述两种查问的反对,全文由以下章节组成:
- 筹备数据;
- 本次实战的 java 工程
- 最简略的联表 (两个表的数据保留在一个实体类的不同字段);
- 一对一联表查问 (两个表的数据别离保留在不同实体类,假如是 A 和 B,A 是 B 的成员变量)
- 一对一嵌套查问 (两个表的数据别离保留在不同实体类,假如是 A 和 B,A 是 B 的成员变量)
源码下载
- 如果您不想编码,能够在 GitHub 下载所有源码,地址和链接信息如下表所示 (https://github.com/zq2599/blo…:
名称 | 链接 | 备注 |
---|---|---|
我的项目主页 | https://github.com/zq2599/blo… | 该我的项目在 GitHub 上的主页 |
git 仓库地址 (https) | https://github.com/zq2599/blo… | 该我的项目源码的仓库地址,https 协定 |
git 仓库地址 (ssh) | git@github.com:zq2599/blog_demos.git | 该我的项目源码的仓库地址,ssh 协定 |
- 这个 git 我的项目中有多个文件夹,本章的利用在 <font color=”blue”>mybatis</font> 文件夹下,如下图红框所示:
- mybatis 是个父工程,外面无数个子工程,本篇的源码在 <font color=”blue”>relatedoperation</font> 子工程中,如下图红框所示:
筹备数据
- 本次实战,在名为 mybatis 的数据库中建设两个表 (和后面几篇文章中的表构造截然不同):user 和 log 表;
- user 表记录用户信息,非常简单,只有三个字段:主键、名称、年龄
- log 表记录用户行为,四个字段:主键、用户 id、行为形容、行为工夫
- user 和 log 的关系如下图:
- 建表和增加数据的语句如下:
use mybatis;
DROP TABLE IF EXISTS `user`;
CREATE TABLE `user` (`id` int(32) NOT NULL AUTO_INCREMENT,
`name` varchar(32) NOT NULL,
`age` int(32) NOT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8;
DROP TABLE IF EXISTS `log`;
CREATE TABLE `log` (`id` int(32) NOT NULL AUTO_INCREMENT,
`user_id` int(32),
`action` varchar(255) NOT NULL,
`create_time` datetime not null,
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8;
INSERT INTO mybatis.user (id, name, age) VALUES (3, 'tom', 11);
INSERT INTO mybatis.log (id, user_id, action, create_time) VALUES (3, 3, 'read book', '2020-08-07 08:18:16');
INSERT INTO mybatis.log (id, user_id, action, create_time) VALUES (4, 3, 'go to the cinema', '2020-09-02 20:00:00');
INSERT INTO mybatis.log (id, user_id, action, create_time) VALUES (5, 3, 'have a meal', '2020-10-05 12:03:36');
INSERT INTO mybatis.log (id, user_id, action, create_time) VALUES (6, 3, 'have a sleep', '2020-10-06 13:00:12');
INSERT INTO mybatis.log (id, user_id, action, create_time) VALUES (7, 3, 'write', '2020-10-08 09:21:11');
本次实战的 java 工程
- 在父工程 mybatis 下新建子工程 <font color=”blue”>relatedoperation</font>,pom.xml 如下:
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.bolingcavalry</groupId>
<artifactId>mybatis</artifactId>
<version>1.0-SNAPSHOT</version>
<relativePath>../pom.xml</relativePath>
</parent>
<groupId>com.bolingcavalry</groupId>
<artifactId>relatedoperation</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>relatedoperation</name>
<description>Demo project for Mybatis related operation in Spring Boot</description>
<properties>
<java.version>1.8</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger2</artifactId>
</dependency>
<!-- swagger-ui -->
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger-ui</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
- 根本配置文件 application.yml:
server:
port: 8080
spring:
#1.JDBC 数据源
datasource:
username: root
password: 123456
url: jdbc:mysql://192.168.50.43:3306/mybatis?useUnicode=true&characterEncoding=utf-8&useSSL=true&serverTimezone=UTC
driver-class-name: com.mysql.cj.jdbc.Driver
#2. 连接池配置
druid:
#初始化连接池的连贯数量 大小,最小,最大
initial-size: 5
min-idle: 5
max-active: 20
#配置获取连贯期待超时的工夫
max-wait: 60000
#配置距离多久才进行一次检测,检测须要敞开的闲暇连贯,单位是毫秒
time-between-eviction-runs-millis: 60000
# 配置一个连贯在池中最小生存的工夫,单位是毫秒
min-evictable-idle-time-millis: 30000
# 配置一个连贯在池中最大生存的工夫,单位是毫秒
max-evictable-idle-time-millis: 300000
validation-query: SELECT 1 FROM user
test-while-idle: true
test-on-borrow: true
test-on-return: false
# 是否缓存 preparedStatement,也就是 PSCache 官网倡议 MySQL 下倡议敞开 集体倡议如果想用 SQL 防火墙 倡议关上
pool-prepared-statements: true
max-pool-prepared-statement-per-connection-size: 20
# 配置监控统计拦挡的 filters,去掉后监控界面 sql 无奈统计,'wall' 用于防火墙
filters: stat,wall,slf4j
filter:
stat:
merge-sql: true
slow-sql-millis: 5000
#3. 根底监控配置
web-stat-filter:
enabled: true
url-pattern: /*
#设置不统计哪些 URL
exclusions: "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*"
session-stat-enable: true
session-stat-max-count: 100
stat-view-servlet:
enabled: true
url-pattern: /druid/*
reset-enable: true
#设置监控页面的登录名和明码
login-username: admin
login-password: admin
allow: 127.0.0.1
#deny: 192.168.1.100
# mybatis 配置
mybatis:
# 配置文件所在位置
config-location: classpath:mybatis-config.xml
# 映射文件所在位置
mapper-locations: classpath:mappers/*Mapper.xml
# 日志配置
logging:
level:
root: INFO
com:
bolingcavalry:
relatedoperation:
mapper: debug
- 再筹备名为 <font color=”blue”>application-test.yml</font> 的配置文件,这是执行单元测试时用到的,和 application.yml 的不同之处是 <font color=”red”>spring.datasource.druid.web-stat-filter.enabled</font> 配置设置成 <font color=”red”>false</font>;
- mybatis 的配置文件 mybatis-config.xml 如下:
<!DOCTYPE configuration
PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
<typeAliases>
<!-- 映射文件中的类不必写全门路了 -->
<package name="com.bolingcavalry.relatedoperation.entity"/>
</typeAliases>
</configuration>
- 数据源配置类 DruidConfig.java:
package com.bolingcavalry.relatedoperation;
import com.alibaba.druid.pool.DruidDataSource;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class DruidConfig {private static final Logger logger = LoggerFactory.getLogger(DruidConfig.class);
@Value("${spring.datasource.url}")
private String dbUrl;
@Value("${spring.datasource.username}")
private String username;
@Value("${spring.datasource.password}")
private String password;
@Value("${spring.datasource.driver-class-name}")
private String driverClassName;
@Value("${spring.datasource.druid.initial-size}")
private int initialSize;
@Value("${spring.datasource.druid.max-active}")
private int maxActive;
@Value("${spring.datasource.druid.min-idle}")
private int minIdle;
@Value("${spring.datasource.druid.max-wait}")
private int maxWait;
@Value("${spring.datasource.druid.pool-prepared-statements}")
private boolean poolPreparedStatements;
@Value("${spring.datasource.druid.max-pool-prepared-statement-per-connection-size}")
private int maxPoolPreparedStatementPerConnectionSize;
@Value("${spring.datasource.druid.time-between-eviction-runs-millis}")
private int timeBetweenEvictionRunsMillis;
@Value("${spring.datasource.druid.min-evictable-idle-time-millis}")
private int minEvictableIdleTimeMillis;
@Value("${spring.datasource.druid.max-evictable-idle-time-millis}")
private int maxEvictableIdleTimeMillis;
@Value("${spring.datasource.druid.validation-query}")
private String validationQuery;
@Value("${spring.datasource.druid.test-while-idle}")
private boolean testWhileIdle;
@Value("${spring.datasource.druid.test-on-borrow}")
private boolean testOnBorrow;
@Value("${spring.datasource.druid.test-on-return}")
private boolean testOnReturn;
@Value("${spring.datasource.druid.filters}")
private String filters;
@Value("{spring.datasource.druid.connection-properties}")
private String connectionProperties;
/**
* Druid 连接池配置
*/
@Bean
public DruidDataSource dataSource() {DruidDataSource datasource = new DruidDataSource();
datasource.setUrl(dbUrl);
datasource.setUsername(username);
datasource.setPassword(password);
datasource.setDriverClassName(driverClassName);
datasource.setInitialSize(initialSize);
datasource.setMinIdle(minIdle);
datasource.setMaxActive(maxActive);
datasource.setMaxWait(maxWait);
datasource.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
datasource.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
datasource.setMaxEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
datasource.setValidationQuery(validationQuery);
datasource.setTestWhileIdle(testWhileIdle);
datasource.setTestOnBorrow(testOnBorrow);
datasource.setTestOnReturn(testOnReturn);
datasource.setPoolPreparedStatements(poolPreparedStatements);
datasource.setMaxPoolPreparedStatementPerConnectionSize(maxPoolPreparedStatementPerConnectionSize);
try {datasource.setFilters(filters);
} catch (Exception e) {logger.error("druid configuration initialization filter", e);
}
datasource.setConnectionProperties(connectionProperties);
return datasource;
}
}
- swagger 配置类:
package com.bolingcavalry.relatedoperation;
import springfox.documentation.service.Contact;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import springfox.documentation.builders.ApiInfoBuilder;
import springfox.documentation.builders.PathSelectors;
import springfox.documentation.builders.RequestHandlerSelectors;
import springfox.documentation.service.ApiInfo;
import springfox.documentation.service.Tag;
import springfox.documentation.spi.DocumentationType;
import springfox.documentation.spring.web.plugins.Docket;
import springfox.documentation.swagger2.annotations.EnableSwagger2;
@Configuration
@EnableSwagger2
public class SwaggerConfig {
@Bean
public Docket createRestApi() {return new Docket(DocumentationType.SWAGGER_2)
.apiInfo(apiInfo())
.tags(new Tag("UserController", "用户服务"), new Tag("LogController", "日志服务"))
.select()
// 以后包门路
.apis(RequestHandlerSelectors.basePackage("com.bolingcavalry.relatedoperation.controller"))
.paths(PathSelectors.any())
.build();}
// 构建 api 文档的详细信息函数, 留神这里的注解援用的是哪个
private ApiInfo apiInfo() {return new ApiInfoBuilder()
// 页面题目
.title("MyBatis CURD 操作")
// 创建人
.contact(new Contact("程序员欣宸", "https://github.com/zq2599/blog_demos", "zq2599@gmail.com"))
// 版本号
.version("1.0")
// 形容
.description("API 形容")
.build();}
}
- springboot 疏导类:
package com.bolingcavalry.relatedoperation;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
@MapperScan("com.bolingcavalry.relatedoperation.mapper")
public class RelatedOperationApplication {public static void main(String[] args) {SpringApplication.run(RelatedOperationApplication.class, args);
}
}
- 用户表的实体类:
package com.bolingcavalry.relatedoperation.entity;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@NoArgsConstructor
@ApiModel(description = "用户实体类")
public class User {@ApiModelProperty(value = "用户 ID")
private Integer id;
@ApiModelProperty(value = "用户名", required = true)
private String name;
@ApiModelProperty(value = "用户地址", required = false)
private Integer age;
}
- 日志表的实体类:
package com.bolingcavalry.relatedoperation.entity;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.sql.Date;
@Data
@NoArgsConstructor
@ApiModel(description = "日志实体类")
public class Log {@ApiModelProperty(value = "日志 ID")
private Integer id;
@ApiModelProperty(value = "用户 ID")
private Integer userId;
@ApiModelProperty(value = "日志内容")
private String action;
@ApiModelProperty(value = "创立工夫")
private Date createTime;
}
- 以上就是本篇的筹备代码,接下来在此基础上实现各种多表关联查问
最简略的联表
- 先实战的是最一般的联表,如下图所示,查问后果是名为 LogExtend 的实体类,这个类有 5 个字段,其中四个来自日志表 log,一个来自用户表 user:
- 下图是开发步骤:
- 实体类 LogExtend 的源码如下,可见和 Log 相比多了个 <font color=”blue”>userName</font> 字段:
package com.bolingcavalry.relatedoperation.entity;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@NoArgsConstructor
@ApiModel(description = "日志实体类 ( 含用户表的字段)")
public class LogExtend extends Log {@ApiModelProperty(value = "用户名")
private String userName;
}
- 新建 log 表对应的映射文件 <font color=”blue”>LogMapper.xml</font>,如下所示,外面是通过 <font color=”blue”>left join</font> 语法执行的简略的联表查问,以及查问后果对应的 resultMap 定义:
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.bolingcavalry.relatedoperation.mapper.LogMapper">
<!-- 联表查问,返回 log 对象,该对象有个 userName 字段,值是 user 表的 user_name 字段 -->
<select id="oneObjectSel" parameterType="int" resultMap="logExtendResultMap">
select l.id as id,
l.user_id as user_id,
l.action as action,
l.create_time as create_time,
u.name as user_name
from log as l
left join user as u
on l.user_id = u.id
where l.id = #{id}
</select>
<resultMap id="logExtendResultMap" type="logExtend">
<id property="id" column="id"/>
<result column="user_id" jdbcType="INTEGER" property="userId"/>
<result column="action" jdbcType="VARCHAR" property="action"/>
<result column="create_time" jdbcType="TIMESTAMP" property="createTime"/>
<result column="user_name" jdbcType="VARCHAR" property="userName"/>
</resultMap>
</mapper>
- mapper 接口代码:
package com.bolingcavalry.relatedoperation.mapper;
import com.bolingcavalry.relatedoperation.entity.LogAssociateUser;
import com.bolingcavalry.relatedoperation.entity.LogExtend;
import org.springframework.stereotype.Repository;
@Repository
public interface LogMapper {LogExtend oneObjectSel(int id);
}
- service 层的代码在 LogService.java 文件中:
package com.bolingcavalry.relatedoperation.service;
import com.bolingcavalry.relatedoperation.entity.LogAssociateUser;
import com.bolingcavalry.relatedoperation.entity.LogExtend;
import com.bolingcavalry.relatedoperation.mapper.LogMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
public class LogService {
@Autowired
LogMapper logMapper;
public LogExtend oneObjectSel(int id){return logMapper.oneObjectSel(id);
}
}
- controller 层的代码在 LogController.java 文件中:
@RestController
@RequestMapping("/log")
@Api(tags = {"LogController"})
public class LogController {
@Autowired
private LogService logService;
@ApiOperation(value = "依据 ID 查找日志记录,带 userName 字段,该字段通过联表查问实现", notes="依据 ID 查找日志记录,带 userName 字段,该字段通过联表查问实现")
@ApiImplicitParam(name = "id", value = "日志 ID", paramType = "path", required = true, dataType = "Integer")
@RequestMapping(value = "/aggregate/{id}", method = RequestMethod.GET)
public LogExtend oneObjectSel(@PathVariable int id){return logService.oneObjectSel(id);
}
- 编写单元测试的代码 ControllerTest.java,因为明天的测试波及到 user 和 log 两个表,因而在测试类 ControllerTest 的外部筹备了两个外部类,别离用于测试 user 和 log 表:
package com.bolingcavalry.relatedoperation.controller;
import lombok.extern.slf4j.Slf4j;
import org.junit.jupiter.api.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.autoconfigure.web.servlet.AutoConfigureMockMvc;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.http.MediaType;
import org.springframework.test.context.ActiveProfiles;
import org.springframework.test.web.servlet.MockMvc;
import org.springframework.test.web.servlet.request.MockMvcRequestBuilders;
import static org.springframework.test.web.servlet.result.MockMvcResultHandlers.print;
import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.jsonPath;
import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.status;
@SpringBootTest
@DisplayName("Web 接口的单元测试")
@AutoConfigureMockMvc
@ActiveProfiles("test")
@Slf4j
public class ControllerTest {
/**
* 查问形式:联表
*/
final static String SEARCH_TYPE_LEFT_JOIN = "leftjoin";
/**
* 查问形式:嵌套
*/
final static String SEARCH_TYPE_NESTED = "nested";
final static int TEST_USER_ID = 3;
final static String TEST_USER_NAME = "tom";
@Autowired MockMvc mvc;
@Nested
@TestMethodOrder(MethodOrderer.OrderAnnotation.class)
@DisplayName("用户服务")
class User { }
@Nested
@TestMethodOrder(MethodOrderer.OrderAnnotation.class)
@DisplayName("日志服务")
class Log {
final static int TEST_LOG_ID = 5;
@Test
@DisplayName("通过日志 ID 获取日志信息, 带 userName 字段,该字段通过联表查问实现")
@Order(1)
void oneObjectSel() throws Exception {mvc.perform(MockMvcRequestBuilders.get("/log/aggregate/" + TEST_LOG_ID)
.accept(MediaType.APPLICATION_JSON))
.andExpect(status().isOk())
.andExpect(jsonPath("$.id").value(TEST_LOG_ID))
.andExpect(jsonPath("$.userName").value(TEST_USER_NAME))
.andDo(print());
}
}
}
- 执行上述单元测试办法,后果如下图,红框中就是 controller 层返回的数据,可见已通过 Mybatis 胜利获得 LogExtend 实例:
- 下一站是一对一联表查问;
对于一对一关联的两种形式
- 后面的查问有个特点:只管查问了两个表,但后果都在同一实体类的不同字段,而更合乎业务逻辑的关系应该是 log 类中有个 user 类的成员变量,即如下模式:
@Data
@NoArgsConstructor
@ApiModel(description = "日志实体类")
public class LogAssociateUser {@ApiModelProperty(value = "日志 ID")
private Integer id;
@ApiModelProperty(value = "用户对象")
private User user;
@ApiModelProperty(value = "日志内容")
private String action;
@ApiModelProperty(value = "创立工夫")
private Date createTime;
}
- 接下来的实战就是如何用 MyBatis 查问失去上述 <font color=”blue”>LogAssociateUser</font> 类型的后果;
- 一对一关联的实现有 <font color=”blue”> 联表 </font> 和 <font color=”blue”> 嵌套查问 </font> 两种,它们的差别在 Mybatis 中体现在 association 的子节点上:
- 联表时,association 内应用 <font color=”red”>result</font> 子节点,将联表查问的后果映射到关联对象;
- 嵌套时,association 内应用 <font color=”red”>select</font> 子节点,触发一次新的查问;
一对一(联表)
所谓一对一,就是一个对象关联了另一个对象,例如一条 log 记录中,带有对应的 user 信息;
- 上面是新的实体类 LogAssociateUser,该类对应的是 log 表记录,有个 user 字段,类型是 User 对象:
@Data
@NoArgsConstructor
@ApiModel(description = "日志实体类")
public class LogAssociateUser {@ApiModelProperty(value = "日志 ID")
private Integer id;
@ApiModelProperty(value = "用户对象")
private User user;
@ApiModelProperty(value = "日志内容")
private String action;
@ApiModelProperty(value = "创立工夫")
private Date createTime;
}
- 映射文件 <font color=”blue”>LogMapper.xml</font> 中,sql 和 resultMap 如下,可见查问的时候将 user 表的字段都查出来了,而后在 resultMap 中用 association 节点去解决 sql 中查出的 user 表的数据,通过 <font color=”blue”>javaType</font> 属性转为 User 类的实例:
<!-- 联表查问,返回 log 对象,它的成员变量中有 user 对象 -->
<select id="leftJoinSel" parameterType="int" resultMap="leftJoinResultMap">
select l.id as log_id,
l.action as log_action,
l.create_time as log_create_time,
u.id as user_id,
u.name as user_name,
u.age as user_age
from log as l
left join user as u
on l.user_id = u.id
where l.id = #{id}
</select>
<resultMap id="leftJoinResultMap" type="LogAssociateUser">
<id property="id" column="log_id"/>
<result property="action" column="log_action" jdbcType="VARCHAR"/>
<result property="createTime" column="log_create_time" jdbcType="TIMESTAMP" />
<association property="user" javaType="User">
<id property="id" column="user_id"/>
<result property="name" column="user_name"/>
<result property="age" column="user_age"/>
</association>
</resultMap>
- 以上就是一对一(联表)的关键点,接下来循序渐进的在 LogMapper、LogService、LogController 中增加办法即可,上面是 LogController 中对应的 web 接口,稍后会在单元测试中调用这个接口进行验证:
@ApiOperation(value = "依据 ID 查找日志记录,带用户对象,联表查问实现", notes="依据 ID 查找日志记录,带用户对象,联表查问实现")
@ApiImplicitParam(name = "id", value = "日志 ID", paramType = "path", required = true, dataType = "Integer")
@RequestMapping(value = "/leftjoin/{id}", method = RequestMethod.GET)
public LogAssociateUser leftJoinSel(@PathVariable int id){return logService.leftJoinSel(id);
}
- 最初是单元测试的代码(ControllerTest.java 文件),用来测试上述代码是否无效,留神上面的 <font color=”red”>queryAndCheck</font> 公有办法,该办法中发动申请并验证后果:
/**
* 通过日志 ID 获取日志信息有两种形式:联表和嵌套查问,* 从客户端来看,仅一部分 path 不同,因而将申请和查看封装到一个通用办法中,* 调用办法只须要指定不同的那一段 path
* @param subPath
* @throws Exception
*/
private void queryAndCheck(String subPath) throws Exception {
String queryPath = "/log/" + subPath + "/" + TEST_LOG_ID;
log.info("query path [{}]", queryPath);
mvc.perform(MockMvcRequestBuilders.get(queryPath)
.accept(MediaType.APPLICATION_JSON))
.andExpect(status().isOk())
.andExpect(jsonPath("$.id").value(TEST_LOG_ID))
.andExpect(jsonPath("$.user.id").value(TEST_USER_ID))
.andDo(print());
}
@Test
@DisplayName("通过日志 ID 获取日志信息(关联了用户),联表查问")
@Order(2)
void leftJoinSel() throws Exception {queryAndCheck(SEARCH_TYPE_LEFT_JOIN);
}
- 执行单元测试后果如下,可见:外部嵌套了一个 json 对象,就是 user 表的数据:
一对一(嵌套)
- 接下来试试嵌套的形式;
- LogMapper.xml 中对应的 sql:
<!-- 嵌套 -->
<select id="nestedSel" parameterType="int" resultMap="nestedResultMap">
select
l.id as log_id,
l.user_id as log_user_id,
l.action as log_action,
l.create_time as log_create_time
from mybatis.log as l
where l.id = #{id}
</select>
- 上述 sql 对应的 resultMap 如下,可见 association 节点中有个 <font color=”blue”>select</font> 属性,这就是 MyBatis 反对嵌套查问的要害,该属性的值是个 select 节点:
<!-- association 节点的 select 属性会触发嵌套查问 -->
<resultMap id="nestedResultMap" type="LogAssociateUser">
<!-- column 属性中的 log_id,来自后面查问时的 "l.id as log_id" -->
<id property="id" column="log_id"/>
<!-- column 属性中的 log_action,来自后面查问时的 "l.action as log_action" -->
<result property="action" column="log_action" jdbcType="VARCHAR"/>
<!-- column 属性中的 log_create_time,来自后面查问时的 "l.create_time as log_create_time" -->
<result property="createTime" column="log_create_time" jdbcType="TIMESTAMP" />
<!-- select 属性,示意这里要执行嵌套查问,将 log_user_id 传给嵌套的查问 -->
<association property="user" column="log_user_id" select="selectUserByUserId"></association>
</resultMap>
- 上述节点中 select 属性的值,对应一个 select 节点,如下:
<select id="selectUserByUserId" parameterType="int" resultType="User">
select
u.id,
u.name,
u.age
from mybatis.user as u
where u.id = #{log_user_id}
</select>
- 以上就是一对一(嵌套)的关键点,接下来循序渐进的在 LogMapper、LogService、LogController 中增加办法即可,上面是 LogController 中对应的 web 接口,稍后会在单元测试中调用这个接口进行验证:
@ApiOperation(value = "依据 ID 查找日志记录,带用户对象,嵌套查问实现", notes="依据 ID 查找日志记录,带用户对象,嵌套查问实现")
@ApiImplicitParam(name = "id", value = "日志 ID", paramType = "path", required = true, dataType = "Integer")
@RequestMapping(value = "/nested/{id}", method = RequestMethod.GET)
public LogAssociateUser nestedSel(@PathVariable int id){return logService.nestedSel(id);
}
- 最初是单元测试的代码(ControllerTest.java 文件),用来测试上述代码是否无效,如下可见,间接调用了后面的 <font color=”blue”>queryAndCheck</font> 来验证:
@Test
@DisplayName("通过日志 ID 获取日志信息(关联了用户),嵌套查问")
@Order(3)
void nestedSel() throws Exception {queryAndCheck(SEARCH_TYPE_NESTED);
}
- 执行上述单元测试代码,后果如下,可见嵌套查问的形式也能将 user 表的数据胜利获取,放入 log 实例的成员变量中:
- 最初是比照联表和嵌套查问的差别,先看联表查问的 MyBatis 日志,如下图红框所示,只有一次 sql 查问:
- 再看嵌套查问的日志,如下图,红框是第一次查问,后果中的 userid 作为绿框中的第二次查问的条件:
- 至此,一对一的多表查问实战就实现了,本篇的逻辑是一条 log 记录关联一条 user 记录,下一篇文章,咱们学习一对多关联,即一个 user 有多条 log 记录;
你不孤独,欣宸原创一路相伴
- Java 系列
- Spring 系列
- Docker 系列
- kubernetes 系列
- 数据库 + 中间件系列
- DevOps 系列
欢送关注公众号:程序员欣宸
微信搜寻「程序员欣宸」,我是欣宸,期待与您一起畅游 Java 世界 …
https://github.com/zq2599/blog_demos
正文完