association 实现MyBatis分步查询与延迟加载

落日映苍穹つ 2022-05-28 22:16 210阅读 0赞

### 一、分步查询 ###

#### 1.1什么时候可以用到分步查询 ####

有的时候需要我们对数据库进行关联查询，比如`Employee` 持有另一个`Department`对象的一个引用，我们希望在查询`Employee` 的时候把`Department`也一同查询出来。这时候我们可以编写关联表的SQL 语句，从而将查询出来的数据使用`resultMap`进行映射。

我们也可以使用其他的方式将关联的信息查询出来，MyBatis 提供了分步查询的机制，把复杂的SQL 语句简单化。

关于MyBatis关联查询可参考博文：  
[MyBatis使用resultMap自定义映射规则与关联映射][MyBatis_resultMap]

#### 1.2分步查询完成JavaBean 之间关联 ####

需求：在查询`Employee`信息的时候，把其对应的`Department`信息也一并查询出来，这里使用分步查询的方法。使用关联映射的方法可以参考上面链接内的博文。

过程分析：

>  1根据员工id 向员工数据库中查询信息，获得员工的信息与部门的id。  
>   
>   
> 2.根据部门的id 查询部门的信息。  
>   
>   
> 3.对查询的信息进行封装。

由此可见，实现分步查询的方法就是将复杂的SQL 语句拆分成简单的多个SQL 语句，在某个SQL 执行结果的基础上再进行数据查询。

1.数据库表结构：

`t_employee` 数据库表结构(其中`d_id`用于关联`t_dept`表 中的`id`)：

DROP TABLE IF EXISTS `t_employee`;
    CREATE TABLE `t_employee` (
      `id` int(11) unsigned zerofill NOT NULL AUTO_INCREMENT,
      `username` varchar(30) DEFAULT NULL,
      `gender` char(1) DEFAULT NULL,
      `email` varchar(20) DEFAULT NULL,
      `d_id` int(11) DEFAULT NULL,
      PRIMARY KEY (`id`)
    ) ENGINE=InnoDB AUTO_INCREMENT=19 DEFAULT CHARSET=utf8;

`t_dept`数据库表结构：

DROP TABLE IF EXISTS `t_dept`;
    CREATE TABLE `t_dept` (
      `id` int(11) NOT NULL AUTO_INCREMENT,
      `dept_name` varchar(20) DEFAULT NULL,
      PRIMARY KEY (`id`)
    ) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8;

2.定义JavaBean

`Employee`类：

package com.jas.mybatis.bean;
    
    public class Employee { 
        private Integer id;
        private String username;
        private Character gender;
        private String email;
        private Department department;
        // 省略set、get 与toString 方法
    }

`Department`类：

package com.jas.mybatis.bean;
    
    public class Department { 
        private Integer id;
        private String departmentName;
        // 省略set、get 与toString 方法
    }

3.定义mapper 接口

`EmployeeMapper` 接口：

package com.jas.mybatis.mapper;
    
    import com.jas.mybatis.bean.Employee;
    
    public interface EmployeeMapper { 
    
        /** * 根据员工id 获取员工信息以及对应的部门信息 * * @param id * @return */
        Employee getEmpAndDeptById(Integer id);
    }

`DepatmentMapper` 接口：

package com.jas.mybatis.mapper;
    
    import com.jas.mybatis.bean.Department;
    
    public interface DepatmentMapper { 
    
        /** * 根据部门id 获得部门信息 * * @param id * @return */
        Department getDeptById(Integer id);
    }

4.编写SQL 语句

`DepartmentMpper.xml`SQL 映射文件：

<mapper namespace="com.jas.mybatis.mapper.DepatmentMapper">
    	
        <select id="getDeptById" resultType="com.jas.mybatis.bean.Department">
            SELECT id, dept_name departmentName FROM t_dept WHERE id = #{id}
        </select>
    </mapper>

`EmployeeMapper.xml`SQL 映射文件：

<mapper namespace="com.jas.mybatis.mapper.EmployeeMapper">
        <resultMap type="com.jas.mybatis.bean.Employee" id="BaseEmployeeResultMap">
            
            <id column="id" property="id"/>
            <result column="username" property="username"/>
            <result column="gender" property="gender"/>
            <result column="email" property="email"/>
            
            
            <association property="department" column="d_id" select="com.jas.mybatis.mapper.DepatmentMapper.getDeptById">
                
                <id column="d_id" property="id"/>
                <result column="dept_name" property="departmentName"/>
            </association>
        </resultMap>
    
        <select id="getEmpAndDeptById" resultMap="BaseEmployeeResultMap">
            SELECT * FROM t_employee WHERE id = #{id}
        </select>
    </mapper>

5.测试代码：

private SqlSession getSqlSession() throws IOException { 
            String resource = "mybatis-config.xml";
            InputStream is = Resources.getResourceAsStream(resource);
            
            SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is);
            SqlSession sqlSession = sqlSessionFactory.openSession();
            
            return sqlSession;
        }
        
        @Test
        public void resultMapTest01() throws IOException { 
            
            SqlSession sqlSession = getSqlSession();
            
            EmployeeMapper employeeMapper = sqlSession.getMapper(EmployeeMapper.class);
            Employee employee = employeeMapper.getEmpAndDeptById(1);
            
            System.out.println(employee);
            sqlSession.close();
        }

6.查看结果：

![这里写图片描述][70]

从上面的执行结果可以看出在进行`Employee`查询结果信息封装的时候，向数据库发了两条SQL 语句，分别获得员工信息与部门信息。通过把复杂的关联SQL 语句进行分步，最终完成了分步查询。

一般情况下`Department getDeptById(Integer id);`方法在实际的开发过程中是必须要定义的一个方法，这样在进行关联查询的时候，我们只要使用现成的方法即可，不需要再定义复杂的关联SQL 语句。分步查询还有一个好处就是可以实现延迟加载，这个延迟加载功能在MyBatis 中可以说是一个非常重要的功能。

下面我们就来看看分步查询是如何完成延迟加载的。

### 二、延迟加载 ###

#### 2.1什么是延迟加载 ####

延迟加载也可以理解为按需加载。即在你需要的时候才进行的加载方式，才会向数据库发送SQL 语句，不需要的时候不会向数据库中发送SQL。这样做可以用于减轻数据库的压力。

比如上面的分步查询，我们通过分步查询分别查询出了员工信息与部门信息，并把这些信息封装成了一个`Employee`对象。如果我们并不需要查询员工的部门信息，在查询员工信息的时候，由于分步查询了部门信息，所以这时候部门信息也会被查出来，但是查询出来的部门信息是不需要的。本来向数据库发送一条SQL 语句就可以了，这时候发送了两条。显然这样做不是好的解决办法，这时候我们就可以使用延迟加载。

#### 2.2实现延迟加载 ####

其实在MyBais 中实现延迟加载的功能是很容易的，只需要在全局的配置文件中进行对应的`setting`设置即可。

你有没有觉得还需要点什么，其实只要配置了上面的两个属性，延迟加载就已经开启了。

#### 2.3测试： ####

如果我们只要获得员工的姓名：

// 省略了 getSqlSession() 方法
    	@Test
        public void resultMapTest01() throws IOException { 
            
            SqlSession sqlSession = getSqlSession();
            
            EmployeeMapper employeeMapper = sqlSession.getMapper(EmployeeMapper.class);
            Employee employee = employeeMapper.getEmpAndDeptById(1);
            
            System.out.println(employee.getUsername());
            sqlSession.close();      
        }

执行结果：  
![这里写图片描述][70 1]  
开启延迟加载后只发送了一条SQL 语句。

下面我们来看看在没有开启延迟加载的情况下获得员工的姓名：  
![这里写图片描述][70 2]  
发现即使你不想要获得员工的部门信息，由于执行的是分步查询，所以还是会发送两条SQL 语句，这显然不是我们想要的。

如果我们想要获得员工的部门信息：

@Test
        public void resultMapTest01() throws IOException { 
            
            SqlSession sqlSession = getSqlSession();
            
            EmployeeMapper employeeMapper = sqlSession.getMapper(EmployeeMapper.class);
            Employee employee = employeeMapper.getEmpAndDeptById(1);
            
            System.out.println(employee.getDepartment());
            sqlSession.close();
        }

执行结果：  
![这里写图片描述][70 3]  
因为要获得部门信息，必须先根据员工的id 获得员工的部门id ，在根据部门id 获得部门信息，因此发送了两条SQL，所以只有在你需要部门信息的时候才会发送查询部门信息的SQL。

### 三、总结 ###

这篇博文主要对`resultMap`中的`association`标签实现分步查询的方式进行了实现，并对分步查询中的延迟加载机制进行了实现。不管是分步查询还是延迟加载都是MyBatis 中很重要的知识，希望读者能够通过这篇博客学习到一些知识，这也是一直支持着我写博客的原因。

[MyBatis_resultMap]: http://blog.csdn.net/codejas/article/details/79527393
[70]: /images/20220529/40357858acc04c1d952c291cec5d255f.png
[70 1]: /images/20220529/5f6d8829ac754c67ad3cde0bb5f251fb.png
[70 2]: /images/20220529/432f3aaabdae4936ba586e9666d9928b.png
[70 3]: /images/20220529/ff50c822a5564ea2ae3724a01598ecf8.png