投稿
  1. 极客之音首页
  2. 后端漫谈

Mybatis之延迟加载策略与缓存（六）

飞熊 • • 后端漫谈 • 阅读 218

生活中，最使人疲惫的往往不是道路的遥远，而是心中的郁闷;最使人痛苦的往往不是生活的不幸，而是希望的破灭;最使人颓废的往往不是前途的坎坷，而是自信的丧失;最使人绝望的往往不是挫折的打击，而是心灵的死亡。所以我们要有自己的梦想，让梦想的星光指引着我们走出落漠，走出惆怅，带着我们走进自己的理想。

导读：本篇文章讲解 Mybatis之延迟加载策略与缓存（六），希望对大家有帮助，欢迎收藏，转发！站点地址：www.bmabk.com，来源：原文

Mybatis之延迟加载策略与缓存（六）

一、Mybatis的延迟加载策略

在需要用到数据时才进行加载，不需要用到数据时就不加载数据。延迟加载也称懒加载。

好处：
          先从单表查询，需要时再从关联表去关联查询，大大提高数据库性能，毕竟查询单表要比关联查询多张表速度要快。

坏处 ：
          只有当需要用到数据时，才会进行数据库查询，在大批量数据查询时，因为查询工作也要消耗时间，所以可能造成用户等待时间变长，造成用户体验下降。

二、使用assocation实现延迟加载

1.创建User 与Account 实体类

public class Account implements Serializable {

    private Integer id;
    private Integer uid;
    private Double money;

    //从表实体包含主表实体的对象引用
    private User user;
}

public class User implements Serializable {

    private Integer id;
    private String username;
    private String address;
    private String sex;
    private Date birthday;
}

2.创建IAccountDao接口与映射配置

public interface IAccountDao {
	/**
	* 查询所有账户，同时查询用户信息
	* @return
	*/
	List<Account> findAll();
}


<?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="cn.ybzy.dao.IAccountDao">

    <!-- 定义封装account和user的resultMap -->
    <resultMap id="accountUserMap" type="account">
        <id property="id" column="id"></id>
        <result property="uid" column="uid"></result>
        <result property="money" column="money"></result>
        <!-- 一对一的关系映射：配置封装user的内容
        select属性指定的内容：要调用的select映射的id,查询用户的唯一标识：
        column属性指定的内容：递给select映射的参数,用户根据id查询时，所需要的参数的值
        -->
        <association property="user" column="uid" javaType="user" select="cn.ybzy.dao.IUserDao.findById"></association>
    </resultMap>

    <!-- 查询所有 -->
    <select id="findAll" resultMap="accountUserMap">
        select * from account
    </select>
</mapper>

3.创建IUserDao接口与映射配置

public interface IUserDao {
	/**
	* 根据id查询用户
	* @param userId
	* @return
	*/
	User findById(Integer userId);

<?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="cn.ybzy.dao.IUserDao">

    <!-- 根据id查询用户 -->
    <select id="findById" parameterType="INT" resultType="user">
        select * from user where id = #{uid}
    </select>

</mapper>

4.测试不开启延迟加载策略时

Mybatis之延迟加载策略与缓存（六）

5.开启Mybatis的延迟加载策略

在这里插入图片描述

	<!-- 开启延迟加载的支持 -->
    <settings>
        <!--开启Mybatis支持延迟加载-->
        <setting name="lazyLoadingEnabled" value="true"/>
        <setting name="aggressiveLazyLoading" value="false"></setting>
    </settings>

6.测试只查账户信息不查用户信息

    @Test
    public void testFindAll(){
        List<Account> accounts = accountDao.findAll();
    }

在这里插入图片描述

7.测试延迟加载效果，使用时查询

    @Test
    public void testFindAll(){
        List<Account> accounts = accountDao.findAll();
        for(Account account : accounts){
	            System.out.println(account);
	            System.out.println(account.getUser());
	        }
    }

在这里插入图片描述

三、使用Collection实现延迟加载

1.创建User与Account实体类

public class User implements Serializable {
	private Integer id;
	private String username;
	private Date birthday;
	private String sex;
	private String address;
	private List<Account> accounts;
}

public class Account implements Serializable {
    private Integer id;
    private Integer uid;
    private Double money;
}

2.创建IUserDao 接口与映射配置

public interface IUserDao {

    /**
     * 查询所有用户
     * @return
     */
    List<User> findAll();
}

<?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="cn.ybzy.dao.IUserDao">

    <!-- 定义User的resultMap-->
    <resultMap id="userAccountMap" type="user">
        <id property="id" column="id"></id>
        <result property="username" column="username"></result>
        <result property="address" column="address"></result>
        <result property="sex" column="sex"></result>
        <result property="birthday" column="birthday"></result>
        <!-- 配置user对象中accounts集合的映射 -->
        <!-- collection 是用于建立一对多中集合属性的对应关系
		ofType 用于指定集合元素的数据类型
		select 是用于指定查询账户的唯一标识，填写的是该sql映射的 id
		column 是用于指定使用哪个字段的值作为条件查询，指定select属性的 sql 语句的参数来源
		-->
        <collection property="accounts" ofType="account" select="cn.ybzy.dao.IAccountDao.findAccountByUid" column="id"></collection>
    </resultMap>

    <!-- 查询所有 -->
    <select id="findAll" resultMap="userAccountMap">
        select * from user
    </select>

</mapper>

3.创建IAccountDao接口与映射配置

public interface IAccountDao {
    /**
     * 根据用户id查询账户信息
     * @param uid
     * @return
     */
    List<Account> findAccountByUid(Integer uid);
}

<?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="cn.ybzy.dao.IAccountDao">

    <!-- 根据用户id查询账户列表 -->
    <select id="findAccountByUid" resultType="account">
        select * from account where uid = #{uid}
    </select>

</mapper>

4.测试不开启延迟加载

    @Test
    public void testFindAll(){
        List<User> users = userDao.findAll();
    }

在这里插入图片描述

5.开启Mybatis的延迟加载策略

	<!-- 开启延迟加载的支持 -->
    <settings>
        <!--开启Mybatis支持延迟加载-->
        <setting name="lazyLoadingEnabled" value="true"/>
        <setting name="aggressiveLazyLoading" value="false"></setting>
    </settings>

6.测试只查询用户信息不查询账户信息

    @Test
    public void testFindAll(){
        List<User> users = userDao.findAll();
    }

在这里插入图片描述

7.测试延迟加载效果，使用时查询

    @Test
    public void testFindAll(){
        List<User> users = userDao.findAll();
        for(User user : users){
            System.out.println(user);
            System.out.println(user.getAccounts());
        }
    }

在这里插入图片描述

四、Mybatis缓存

Mybatis 缓存分为一级缓存，二级缓存。

Mybatis一级缓存

一级缓存是 SqlSession 级别的缓存，只要 SqlSession 没有 flush 或 close，它就存在。

一级缓存是 SqlSession 范围的缓存，当调用 SqlSession的修改，添加，删除，commit()，close()等方法时，就会清空一级缓存。

一级缓存执行过程：

1.第一次发起查询用户id为 1 的用户信息时，会先从缓存中查找是否有 id 为 1 的用户信息，如果没有，再从数据库查询用户信息。

2.将从数据库中查询得到的用户信息，存储到一级缓存中。

3.如果 sqlSession 去执行 commit 操作（执行插入、更新、删除），会清空 SqlSession 中的一级缓存，这样做的目的为了让缓存中存储的是最新的信息，避免脏读。

4.第二次发起查询用户 id 为 1 的用户信息，先去找缓存中是否有 id 为 1 的用户信息，缓存中有，直接从缓存中获取用户信息。

1.创建IUserDao接口及映射配置

public interface IUserDao {
    /**
     * 根据id查询用户信息
     * @param userId
     * @return
     */
    User findById(Integer userId);
    
     /**
     * 更新用户信息
     * @param user
     */
    void updateUser(User user);
    }

<?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="cn.ybzy.dao.IUserDao">

    <!-- 根据id查询用户 -->
    <select id="findById" parameterType="INT" resultType="user" >
        select * from user where id = #{uid}
    </select>
    
	  <!-- 更新用户信息-->
	    <update id="updateUser" parameterType="user">
	        update user set username=#{username},address=#{address} where id=#{id}
	    </update>
</mapper>

2.测试验证一级缓存

    @Test
    public void testFirstLevelCache(){
   		User user1 = userDao.findById(45);
  		userDao = sqlSession.getMapper(IUserDao.class);
        User user2 = userDao.findById(45);
        System.out.println(user1 == user2);
    }

在这里插入图片描述在这里插入图片描述

查询两次，但最后只执行一次数据库操作，这就是 Mybatis 提供的一级缓存起作用了。

由于一级缓存的存在，导致第二次查询id为45的记录时，并没有发出sql语句从数据库中查询数据，而是从一级缓存中查询。

3.测试一级缓存的清空

    @Test
    public void testFirstLevelCache(){
        User user1 = userDao.findById(45);
		//方式一:
        sqlSession.close();
        //再次获取SqlSession对象
        sqlSession = factory.openSession();
        
		//方式二:也可以清空缓存
        //sqlSession.clearCache();
        
   		userDao = sqlSession.getMapper(IUserDao.class);
        User user2 = userDao.findById(45);
        System.out.println(user1 == user2);
    }

在这里插入图片描述

4.测试缓存的同步更新

当查询用户信息后执行update方法后，再次查询User对象时，又重新执行了sql 语句，从数据库进行了查询操作。

    @Test
    public void testClearlCache(){
        //1.根据id查询用户
        User user1 = userDao.findById(45);

        //2.更新用户信息
        user1.setUsername("Test clear cache.");
        user1.setAddress("北京");
        userDao.updateUser(user1);

        //3.再次查询id为41的用户
        User user2 = userDao.findById(45);

        System.out.println(user1 == user2);
    }

在这里插入图片描述在这里插入图片描述

Mybatis二级缓存

二级缓存是 mapper 映射级别的缓存，多个 SqlSession 去操作同一个 Mapper 映射的 sql语句，多个SqlSession 可以共用二级缓存，二级缓存是跨 SqlSession 的。

使用二级缓存时，所缓存的类一定要实现 java.io.Serializable 接口。

二级缓存的执行过程：

1.第一个sqlSession1 去查询用户信息时，会将查询到用户信息的查询数据存储到二级缓存中。

2.第二个sqlSession2 去查询与 sqlSession1 相同的用户信息，首先会去缓存中找是否存在数据，如果存在直接从缓存中取出数据。

3.第三个SqlSession3 去执行相同mapper 映射下sql，执行commit提交，将会清空该mapper映射下的二级缓存区域的数据。

1.在SqlMapConfig.xml中开启二级缓存

由于 cacheEnabled 的取值默认就为 true，所以value取值可以省略不配置。

为 true 代表开启二级缓存；为false代表不开启二级缓存

在这里插入图片描述

<settings>
	<!-- 开启二级缓存的支持 -->
	<setting name="cacheEnabled" value="true"/>
</settings>

2.配置相关的Mapper映射文件

<?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="cn.ybzy.dao.IUserDao">
	<!-- 开启二级缓存的支持 -->
	<!--<cache>标签表示当前这个mapper映射将使用二级缓存，区分的标准就看mapper的 namespace值。-->
	<cache></cache>
</mapper>

3.配置statement上面的useCache属性

useCache=”true”代表当前 statement使用二级缓存，如果不使用二级缓存可以设置为 false,禁用二级缓存。

在这里插入图片描述

<?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="cn.ybzy.dao.IUserDao">
    <!--开启user支持二级缓存-->
    <cache/>
    <!-- 根据id查询用户 -->
    <select id="findById" parameterType="INT" resultType="user" useCache="true">
        select * from user where id = #{uid}
    </select>
</mapper>

4.测试二级缓存

 @Test
    public void testClearCache(){
        SqlSession sqlSession1 = factory.openSession();
        IUserDao dao1 = sqlSession1.getMapper(IUserDao.class);
        User user1 = dao1.findById(45);
        //清空一级缓存
        sqlSession1.close();

        SqlSession sqlSession2 = factory.openSession();
        IUserDao dao2 = sqlSession2.getMapper(IUserDao.class);
        User user2 = dao2.findById(45);

        System.out.println(user1 == user2);
    }

在这里插入图片描述在这里插入图片描述

执行两次查询，并且在执行第一次查询后，关闭一级缓存，再执行第二次查询时，并没有对数据库发出 sql语句，所以此时的数据就只能是来自于二级缓存。

版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。

文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/137111.html

赞 (0)
飞熊的头像飞熊bm
0 0

相关推荐

发表回复

登录后才能评论
极客之音——专业性很强的中文编程技术网站，欢迎收藏到浏览器，订阅我们！