主要內(nèi)容
- Mybatis 延遲加載策略
- Mybatis 緩存
- Mybatis 注解開發(fā)
Mybatis 延遲加載策略
1.1 何為延遲加載?
延遲加載：就是在需要用到數(shù)據(jù)時(shí)才進(jìn)行加載，不需要用到數(shù)據(jù)時(shí)就不加載數(shù)據(jù)。延遲加載也稱懶加載.
好處：先從單表查詢，需要時(shí)再?gòu)年P(guān)聯(lián)表去關(guān)聯(lián)查詢，大大提高數(shù)據(jù)庫(kù)性能，因?yàn)椴樵儐伪硪汝P(guān)聯(lián)查詢多張表速度要快。
壞處：因?yàn)橹挥挟?dāng)需要用到數(shù)據(jù)時(shí)，才會(huì)進(jìn)行數(shù)據(jù)庫(kù)查詢，這樣在大批量數(shù)據(jù)查詢時(shí)，因?yàn)椴樵児ぷ饕惨臅r(shí)間，所以可能造成用戶等待時(shí)間變長(zhǎng)，造成用戶體驗(yàn)下降。
1.2 實(shí)現(xiàn)需求
需求：
查詢賬戶(Account)信息并且關(guān)聯(lián)查詢用戶(User)信息。如果先查詢賬戶(Account)信息即可滿足要
求，當(dāng)我們需要查詢用戶(User)信息時(shí)再查詢用戶(User)信息。把對(duì)用戶(User)信息的按需去查詢就是延遲加載。
mybatis第三天實(shí)現(xiàn)多表操作時(shí)，我們使用了 resultMap來(lái)實(shí)現(xiàn)一對(duì)一，一對(duì)多，多對(duì)多關(guān)系的操作。主要
是通過(guò) association、 collection 實(shí)現(xiàn)一對(duì)一及一對(duì)多映射。
association、 collection 具備延遲加載功能。
1.3 使用 assocation 實(shí)現(xiàn)延遲加載
需求：
查詢賬戶信息同時(shí)查詢用戶信息。
1.3.1 賬戶的持久層 DAO 接口
package com.ding.dao;
import com.ding.domain.Account;
import java.util.List;
public interface IAccountDao {
/**
* 查詢所有賬戶，同時(shí)獲取賬戶的所屬用戶名稱以及它的地址信息
* @return
*/
List<Account> findAll();
}
1.3.2 賬戶的持久層映射文件
<?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.ding.dao.IAccountDao">
<!-- 建立對(duì)應(yīng)關(guān)系 -->
<resultMap type="Account" id="accountMap">
<id column="aid" property="id"/>
<result column="uid" property="uid"/>
<result column="money" property="money"/>
<!-- 它是用于指定從表方的引用實(shí)體屬性的 -->
<association property="user" javaType="User"
select="com.ding.dao.IUserDao.findById"
column="uid">
</association>
</resultMap>
<select id="findAll" resultMap="accountMap">
select * from account
</select>
</mapper>
select： 填寫我們要調(diào)用的 select 映射的 id
column ： 填寫我們要傳遞給 select 映射的參數(shù)
1.3.3 用戶的持久層接口和映射文件
public interface IUserDao {
/**
* 根據(jù) id 查詢
* @param userId
* @return
*/
User findById(Integer userId);
}
<!-- 根據(jù) id 查詢 -->
<select id="findById" resultType="User" parameterType="int" >
select * from user where id = #{uid}
</select>
1.3.4 開啟 Mybatis 的延遲加載策略
進(jìn)入 Mybaits 的官方文檔，找到 settings 的說(shuō)明信息：
iShot2021-01-24 15.11.33.png
我們需要在 Mybatis 的配置文件 SqlMapConfig.xml 文件中添加延遲加載的配置。
<!-- 開啟延遲加載的支持 -->
<settings>
<setting name="lazyLoadingEnabled" value="true"/>
<setting name="aggressiveLazyLoading" value="false"/>
</settings>
1.3.5 編寫測(cè)試只查賬戶信息不查用戶信息。
package com.ding;
import com.ding.dao.IAccountDao;
import com.ding.domain.Account;
import com.ding.domain.AccountUser;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import org.apache.ibatis.io.Resources;
import java.io.InputStream;
import java.util.List;
public class AccountTest {
private InputStream in ;
private SqlSessionFactory factory;
private SqlSession session;
private IAccountDao accountDao;
@Before//在測(cè)試方法執(zhí)行之前執(zhí)行
public void init()throws Exception {
//1.讀取配置文件
in = Resources.getResourceAsStream("SqlMapConfig.xml");
//2.創(chuàng)建構(gòu)建者對(duì)象
SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
//3.創(chuàng)建 SqlSession 工廠對(duì)象
factory = builder.build(in);
//4.創(chuàng)建 SqlSession 對(duì)象
session = factory.openSession();
//5.創(chuàng)建 Dao 的代理對(duì)象
accountDao = session.getMapper(IAccountDao.class);
}
@After//在測(cè)試方法執(zhí)行完成之后執(zhí)行
public void destroy() throws Exception{
session.commit();
//7.釋放資源
session.close();
in.close();
}
@Test
public void testFindAll1() {
List<Account> accounts = accountDao.findAll();
// for(Account au : accounts) {
// System.out.println(au);
// System.out.println(au.getUser());
// }
}
}
測(cè)試結(jié)果如下：
iShot2021-01-24 15.16.18.png
因?yàn)楸敬沃皇菍?Account對(duì)象查詢出來(lái)放入 List 集合中，并沒(méi)有涉及到 User對(duì)象，所以就沒(méi)有
發(fā)出 SQL 語(yǔ)句查詢賬戶所關(guān)聯(lián)的 User 對(duì)象的查詢。
1.4 使用 Collection 實(shí)現(xiàn)延遲加載
同樣我們也可以在一對(duì)多關(guān)系配置的<collection>結(jié)點(diǎn)中配置延遲加載策略。
<collection>結(jié)點(diǎn)中也有 select 屬性， column 屬性。
需求：
完成加載用戶對(duì)象時(shí)，查詢?cè)撚脩羲鶕碛械馁~戶信息。
1.4.1 在 User 實(shí)體類中加入 List<Account>屬性
package com.ding.domain;
import java.io.Serializable;
import java.util.Date;
import java.util.List;
public class User implements Serializable {
private Integer id;
private String username;
private String address;
private Date birthday;
private String sex;
public List<Account> getAccounts() {
return accounts;
}
public void setAccounts(List<Account> accounts) {
this.accounts = accounts;
}
private List<Account> accounts;
public String getUsername() {
return username;
}
public void setUsername(String username) {
this.username = username;
}
public String getAddress() {
return address;
}
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public void setAddress(String address) {
this.address = address;
}
public Date getBirthday() {
return birthday;
}
public void setBirthday(Date birthday) {
this.birthday = birthday;
}
public String getSex() {
return sex;
}
public void setSex(String sex) {
this.sex = sex;
}
@Override
public String toString() {
return "User{" +
"id=" + id +
", username='" + username + '\'' +
", address='" + address + '\'' +
", birthday=" + birthday +
", sex='" + sex + '\'' +
", accounts=" + accounts +
'}';
}
}
1.4.2 編寫用戶和賬戶持久層接口的方法
package com.ding.dao;
import com.ding.domain.Account;
import com.ding.domain.User;
import java.util.List;
public interface IUserDao {
/**
* 查詢所有用戶，同時(shí)獲取出每個(gè)用戶下的所有賬戶信息
* @return
*/
List<User> findAll();
/**
* 根據(jù)用戶 id 查詢賬戶信息
* @param uid
* @return
*/
List<Account> findByUid(Integer uid);
}
1.4.3 編寫用戶持久層映射配置
<?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.ding.dao.IUserDao">
<resultMap type="User" id="userMap">
<id column="id" property="id"></id>
<result column="username" property="username"/>
<result column="address" property="address"/>
<result column="sex" property="sex"/>
<result column="birthday" property="birthday"/>
<!-- collection 是用于建立一對(duì)多中集合屬性的對(duì)應(yīng)關(guān)系
ofType 用于指定集合元素的數(shù)據(jù)類型
select 是用于指定查詢賬戶的唯一標(biāo)識(shí)（賬戶的 dao 全限定類名加上方法名稱）
column 是用于指定使用哪個(gè)字段的值作為條件查詢
-->
<collection property="accounts" ofType="Account"
select="com.ding.dao.IAccountDao.findByUid"
column="id">
</collection>
</resultMap>
<!-- 配置查詢所有操作 -->
<select id="findAll" resultMap="userMap">
select * from user
</select>
</mapper>
<collection>標(biāo)簽：
主要用于加載關(guān)聯(lián)的集合對(duì)象
select 屬性：
用于指定查詢 account 列表的 sql 語(yǔ)句，所以填寫的是該 sql 映射的 id
column 屬性：
用于指定 select 屬性的 sql 語(yǔ)句的參數(shù)來(lái)源，上面的參數(shù)來(lái)自于 user 的 id 列，所以就寫成 id 這一
個(gè)字段名了
1.4.4 編寫賬戶持久層映射配置
<!-- 根據(jù)用戶 id 查詢賬戶信息 -->
<select id="findByUid" resultType="Account" parameterType="int">
select * from account where uid = #{uid}
</select>
1.4.5 測(cè)試只加載用戶信息
package com.ding;
import com.ding.dao.IUserDao;
import com.ding.domain.User;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import java.io.InputStream;
import java.util.Date;
import java.util.List;
public class test {
private InputStream in ;
private SqlSessionFactory factory;
private SqlSession session;
private IUserDao userDao;
@Test
public void testFindAll() {
//6.執(zhí)行操作
List<User> users = userDao.findAll();
// for(User user : users) {
// System.out.println("-------每個(gè)用戶的內(nèi)容---------");
// System.out.println(user);
// System.out.println(user.getAccounts());
// }
}
@Before//在測(cè)試方法執(zhí)行之前執(zhí)行
public void init()throws Exception {
//1.讀取配置文件
in = Resources.getResourceAsStream("SqlMapConfig.xml");
//2.創(chuàng)建構(gòu)建者對(duì)象
SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
//3.創(chuàng)建 SqlSession 工廠對(duì)象
factory = builder.build(in);
//4.創(chuàng)建 SqlSession 對(duì)象
session = factory.openSession();
//5.創(chuàng)建 Dao 的代理對(duì)象
userDao = session.getMapper(IUserDao.class);
}
@After//在測(cè)試方法執(zhí)行完成之后執(zhí)行
public void destroy() throws Exception{
session.commit();
//7.釋放資源
session.close();
in.close();
}
}
測(cè)試結(jié)果如下：
iShot2021-01-24 15.44.00.png
我們發(fā)現(xiàn)并沒(méi)有加載 Account 賬戶信息。
Mybatis 緩存
像大多數(shù)的持久化框架一樣， Mybatis 也提供了緩存策略，通過(guò)緩存策略來(lái)減少數(shù)據(jù)庫(kù)的查詢次數(shù)， 從而提高性能。
Mybatis 中緩存分為一級(jí)緩存，二級(jí)緩存。
iShot2021-01-24 15.44.47.png
2.1 Mybatis 一級(jí)緩存
2.1.1 證明一級(jí)緩存的存在
一級(jí)緩存是 SqlSession 級(jí)別的緩存，只要 SqlSession 沒(méi)有 flush 或 close，它就存在。
2.1.2 一級(jí)緩存的分析
一級(jí)緩存是 SqlSession 范圍的緩存，當(dāng)調(diào)用 SqlSession 的修改，添加，刪除， commit()， close()等方法時(shí)，就會(huì)清空一級(jí)緩存。
iShot2021-01-24 15.46.42.png
第一次發(fā)起查詢用戶 id 為 1 的用戶信息，先去找緩存中是否有 id 為 1 的用戶信息，如果沒(méi)有，從數(shù)據(jù)庫(kù)查
詢用戶信息。
得到用戶信息，將用戶信息存儲(chǔ)到一級(jí)緩存中。
如果 sqlSession 去執(zhí)行 commit 操作（執(zhí)行插入、更新、刪除），清空 SqlSession 中的一級(jí)緩存，這樣
做的目的為了讓緩存中存儲(chǔ)的是最新的信息，避免臟讀。
第二次發(fā)起查詢用戶 id 為 1 的用戶信息，先去找緩存中是否有 id 為 1 的用戶信息，緩存中有，直接從緩存
中獲取用戶信息。
2.2 Mybatis 二級(jí)緩存
二級(jí)緩存是 mapper 映射級(jí)別的緩存，多個(gè) SqlSession 去操作同一個(gè) Mapper 映射的 sql 語(yǔ)句，多個(gè)
SqlSession 可以共用二級(jí)緩存，二級(jí)緩存是跨 SqlSession 的。
2.2.1 二級(jí)緩存結(jié)構(gòu)圖
iShot2021-01-24 15.47.51.png
首先開啟 mybatis 的二級(jí)緩存。
sqlSession1 去查詢用戶信息，查詢到用戶信息會(huì)將查詢數(shù)據(jù)存儲(chǔ)到二級(jí)緩存中。
如果 SqlSession3 去執(zhí)行相同 mapper 映射下 sql，執(zhí)行 commit 提交， 將會(huì)清空該 mapper 映射下的二
級(jí)緩存區(qū)域的數(shù)據(jù)。
sqlSession2 去查詢與 sqlSession1 相同的用戶信息， 首先會(huì)去緩存中找是否存在數(shù)據(jù)，如果存在直接從
緩存中取出數(shù)據(jù)。
2.2.2 二級(jí)緩存的開啟與關(guān)閉
2.2.2.1 第一步：在 SqlMapConfig.xml 文件開啟二級(jí)緩存
<settings>
<!-- 開啟二級(jí)緩存的支持 -->
<setting name="cacheEnabled" value="true"/>
</settings>
因?yàn)?cacheEnabled 的取值默認(rèn)就為 true，所以這一步可以省略不配置。為 true 代表開啟二級(jí)緩存；為
false 代表不開啟二級(jí)緩存。
2.2.2.2 第二步：配置相關(guān)的 Mapper 映射文件
<cache>標(biāo)簽表示當(dāng)前這個(gè) mapper 映射將使用二級(jí)緩存，區(qū)分的標(biāo)準(zhǔn)就看 mapper 的 namespace 值。
<?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.itheima.dao.IUserDao">
<!-- 開啟二級(jí)緩存的支持 -->
<cache></cache>
</mapper>
2.2.2.3 第三步： 配置 statement 上面的 useCache 屬性
<!-- 根據(jù) id 查詢 -->
<select id="findById" resultType="user" parameterType="int" useCache="true">
select * from user where id = #{uid}
</select>
將 UserDao.xml 映射文件中的<select>標(biāo)簽中設(shè)置 useCache=”true”代表當(dāng)前這個(gè) statement 要使用
二級(jí)緩存，如果不使用二級(jí)緩存可以設(shè)置為 false。
注意： 針對(duì)每次查詢都需要最新的數(shù)據(jù) sql，要設(shè)置成 useCache=false，禁用二級(jí)緩存。
2.2.4 二級(jí)緩存注意事項(xiàng)
當(dāng)我們?cè)谑褂枚?jí)緩存時(shí)，所緩存的類一定要實(shí)現(xiàn) java.io.Serializable 接口，這種就可以使用序列化
方式來(lái)保存對(duì)象。
Mybatis 注解開發(fā)
3.1 mybatis 的常用注解說(shuō)明
@Insert:實(shí)現(xiàn)新增
@Update:實(shí)現(xiàn)更新
@Delete:實(shí)現(xiàn)刪除
@Select:實(shí)現(xiàn)查詢
@Result:實(shí)現(xiàn)結(jié)果集封裝
@Results:可以與@Result 一起使用，封裝多個(gè)結(jié)果集
@ResultMap:實(shí)現(xiàn)引用@Results 定義的封裝
@One:實(shí)現(xiàn)一對(duì)一結(jié)果集封裝
@Many:實(shí)現(xiàn)一對(duì)多結(jié)果集封裝
@SelectProvider:實(shí)現(xiàn)動(dòng)態(tài) SQL 映射
@CacheNamespace:實(shí)現(xiàn)注解二級(jí)緩存的使用
3.2 使用 Mybatis 注解實(shí)現(xiàn)基本 CRUD
3.2.1 編寫實(shí)體類
注意：
此處我們故意和數(shù)據(jù)庫(kù)表的列名不一致。
package com.ding.domain;
import java.io.Serializable;
import java.util.Date;
import java.util.List;
public class User implements Serializable {
private Integer userId;
private String userName;
private Date userBirthday;
private String userSex;
private String userAddress;
public Integer getUserId() {
return userId;
}
public void setUserId(Integer userId) {
this.userId = userId;
}
public String getUserName() {
return userName;
}
public void setUserName(String userName) {
this.userName = userName;
}
public Date getUserBirthday() {
return userBirthday;
}
public void setUserBirthday(Date userBirthday) {
this.userBirthday = userBirthday;
}
public String getUserSex() {
return userSex;
}
public void setUserSex(String userSex) {
this.userSex = userSex;
}
public String getUserAddress() {
return userAddress;
}
public void setUserAddress(String userAddress) {
this.userAddress = userAddress;
}
@Override
public String toString() {
return "User{" +
"userId=" + userId +
", userName='" + userName + '\'' +
", userBirthday=" + userBirthday +
", userSex='" + userSex + '\'' +
", userAddress='" + userAddress + '\'' +
'}';
}
}
3.2.2 使用注解方式開發(fā)持久層接口
package com.ding.dao;
import com.ding.domain.Account;
import com.ding.domain.User;
import org.apache.ibatis.annotations.*;
import java.util.List;
public interface IUserDao {
/**
* 查詢所有用戶
* @return
*/
@Select("select * from user")
@Results(id="userMap",
value= {
@Result(id=true,column="id",property="userId"),
@Result(column="username",property="userName"),
@Result(column="sex",property="userSex"),
@Result(column="address",property="userAddress"),
@Result(column="birthday",property="userBirthday")
})
List<User> findAll();
/**
* 根據(jù) id 查詢一個(gè)用戶
* @param userId
* @return
*/
@Select("select * from user where id = #{uid} ")
@ResultMap("userMap")
User findById(Integer userId);
/**
* 保存操作
* @param user
* @return
*/
@Insert("insert into user(username,sex,birthday,address)values(#{username},#{sex},#{birthday},#{address})")
@SelectKey(keyColumn="id",keyProperty="id",resultType=Integer.class,before = false, statement = { "select last_insert_id()" })
int saveUser(User user);
/**
* 更新操作
* @param user
* @return
*/
@Update("update user set username=#{username},address=#{address},sex=#{sex},birthday=#{birthday} where id =#{id} ")
int updateUser(User user);
/**
* 刪除用戶
* @param userId
* @return
*/
@Delete("delete from user where id = #{uid} ")
int deleteUser(Integer userId);
/**
* 查詢使用聚合函數(shù)
* @return
*/
@Select("select count(*) from user ")
int findTotal();
/**
* 模糊查詢
* @param name
* @return
*/
@Select("select * from user where username like #{username} ")
List<User> findByName(String name);
}
通過(guò)注解方式，我們就不需要再去編寫 UserDao.xml 映射文件了。
3.2.3 編寫 SqlMapConfig 配置文件
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE configuration
PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
<!--使用typeAliases配置別名，它只能配置domain中類的別名 -->
<typeAliases>
<package name="com.ding.domain"></package>
</typeAliases>
<!-- 配置 mybatis 的環(huán)境 -->
<environments default="mysql">
<!-- 配置 mysql 的環(huán)境 -->
<environment id="mysql">
<!-- 配置事務(wù)的類型 -->
<transactionManager type="JDBC"></transactionManager>
<!-- 配置連接數(shù)據(jù)庫(kù)的信息：用的是數(shù)據(jù)源(連接池) -->
<dataSource type="POOLED">
<property name="driver" value="com.mysql.jdbc.Driver"/>
<property name="url" value="jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf8"/>
<property name="username" value="root"/>
<property name="password" value="root"/>
</dataSource>
</environment>
</environments>
<!-- 配置映射信息 -->
<mappers>
<!-- 配置 dao 接口的位置，它有兩種方式
第一種：使用 mapper 標(biāo)簽配置 class 屬性
第二種：使用 package 標(biāo)簽，直接指定 dao 接口所在的包
-->
<package name="com.ding.dao"/>
</mappers>
</configuration>
3.2.4 編寫測(cè)試方法
package com.ding;
import com.ding.dao.IUserDao;
import com.ding.domain.User;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import java.io.InputStream;
import java.util.Date;
import java.util.List;
public class MybatisAnnotationCRUDTest {
/**
* 測(cè)試查詢所有
*/
@Test
public void testFindAll() {
List<User> users = userDao.findAll();
for(User user : users) {
System.out.println(user);
}
}
/**
* 測(cè)試查詢一個(gè)
*/
@Test
public void testFindById() {
User user = userDao.findById(41);
System.out.println(user);
}
/**
* 測(cè)試保存
*/
@Test
public void testSave() {
User user = new User();
user.setUserName("mybatis annotation");
user.setUserSex("男");
user.setUserAddress("北京市順義區(qū)");
user.setUserBirthday(new Date());
int res = userDao.saveUser(user);
System.out.println("影響數(shù)據(jù)庫(kù)記錄的行數(shù)： "+res);
System.out.println("插入的主鍵值： "+user.getUserId());
}
/**
* 測(cè)試更新
*/
@Test
public void testUpdate() {
User user = userDao.findById(43);
user.setUserBirthday(new Date());
user.setUserSex("女");
int res = userDao.updateUser(user);
System.out.println(res);
}
/**
* 測(cè)試刪除
*/
@Test
public void testDelete() {
int res = userDao.deleteUser(63);
System.out.println(res);
}
/**
* 測(cè)試查詢使用聚合函數(shù)
*/
@Test
public void testFindTotal() {
int res = userDao.findTotal();
System.out.println(res);
}
/**
* 測(cè)試模糊查詢
*/
@Test
public void testFindByName() {
List<User> users = userDao.findByName("%m%");
for(User user : users) {
System.out.println(user);
}
}
private InputStream in;
private SqlSessionFactory factory;
private SqlSession session;
private IUserDao userDao;
@Before//junit 的注解
public void init()throws Exception{
//1.讀取配置文件
in = Resources.getResourceAsStream("SqlMapConfig.xml");
//2.創(chuàng)建工廠
SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
factory = builder.build(in);
//3.創(chuàng)建 session
session = factory.openSession();
//4.創(chuàng)建代理對(duì)象
userDao = session.getMapper(IUserDao.class);
}
@After//junit 的注解
public void destroy()throws Exception {
//提交事務(wù)
session.commit();
//釋放資源
session.close();
//關(guān)閉流
in.close();
}
}
3.3 使用注解實(shí)現(xiàn)復(fù)雜關(guān)系映射開發(fā)
實(shí)現(xiàn)復(fù)雜關(guān)系映射之前我們可以在映射文件中通過(guò)配置<resultMap>來(lái)實(shí)現(xiàn)， 在使用注解開發(fā)時(shí)我們需要借
助@Results 注解， @Result 注解， @One 注解， @Many 注解。
3.3.1 復(fù)雜關(guān)系映射的注解說(shuō)明
@Results 注解
代替的是標(biāo)簽<resultMap>
該注解中可以使用單個(gè)@Result 注解，也可以使用@Result 集合
@Results（ {@Result（）， @Result（） }）或@Results（ @Result（））
@Resutl 注解
代替了 <id>標(biāo)簽和<result>標(biāo)簽
@Result 中 屬性介紹：
- id 是否是主鍵字段
- column 數(shù)據(jù)庫(kù)的列名
- property 需要裝配的屬性名
- one 需要使用的@One 注解（ @Result（ one=@One）（）））
- many 需要使用的@Many 注解（ @Result（ many=@many）（）））
@One 注解（一對(duì)一）
代替了<assocation>標(biāo)簽，是多表查詢的關(guān)鍵，在注解中用來(lái)指定子查詢返回單一對(duì)象。
@One 注解屬性介紹：
select 指定用來(lái)多表查詢的 sqlmapper
fetchType 會(huì)覆蓋全局的配置參數(shù) lazyLoadingEnabled。。
使用格式：
@Result(column=" ",property="",one=@One(select=""))
@Many 注解（多對(duì)一）
代替了<Collection>標(biāo)簽,是是多表查詢的關(guān)鍵，在注解中用來(lái)指定子查詢返回對(duì)象集合。
注意：聚集元素用來(lái)處理“一對(duì)多”的關(guān)系。需要指定映射的 Java 實(shí)體類的屬性，屬性的 javaType （一般為 ArrayList）但是注解中可以不定義；
使用格式：
@Result(property="",column="",many=@Many(select=""))
3.3.2 使用注解實(shí)現(xiàn)一對(duì)一復(fù)雜關(guān)系映射及延遲加載
需求：
加載賬戶信息時(shí)并且加載該賬戶的用戶信息，根據(jù)情況可實(shí)現(xiàn)延遲加載。（注解方式實(shí)現(xiàn)）
3.3.2.1 添加 Account 實(shí)體類
package com.ding.domain;
import java.io.Serializable;
public class Account implements Serializable {
private Integer id;
private Integer uid;
private Double money;
private User user;
public User getUser() {
return user;
}
public void setUser(User user) {
this.user = user;
}
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public Integer getUid() {
return uid;
}
public void setUid(Integer uid) {
this.uid = uid;
}
public Double getMoney() {
return money;
}
public void setMoney(Double money) {
this.money = money;
}
@Override
public String toString() {
return "Account{" +
"id=" + id +
", uid=" + uid +
", money=" + money +
", user=" + user +
'}';
}
}
3.3.2.2 添加賬戶的持久層接口并使用注解配置
package com.ding.dao;
import com.ding.domain.Account;
import com.ding.domain.AccountUser;
import org.apache.ibatis.annotations.One;
import org.apache.ibatis.annotations.Result;
import org.apache.ibatis.annotations.Results;
import org.apache.ibatis.annotations.Select;
import org.apache.ibatis.mapping.FetchType;
import java.util.List;
public interface IAccountDao {
/**
* 查詢所有賬戶，采用延遲加載的方式查詢賬戶的所屬用戶
* @return
*/
@Select("select * from account")
@Results(id="accountMap",
value= {
@Result(id=true,column="id",property="id"),
@Result(column="uid",property="uid"),
@Result(column="money",property="money"),
@Result(column="uid",
property="user",
one=@One(select="com.itheima.dao.IUserDao.findById",
fetchType= FetchType.LAZY)
)
})
List<Account> findAll();
}
3.3.2.3 添加用戶的持久層接口并使用注解配置
package com.ding.dao;
import com.ding.domain.Account;
import com.ding.domain.User;
import org.apache.ibatis.annotations.*;
import java.util.List;
public interface IUserDao {
/**
* 查詢所有用戶
* @return
*/
@Select("select * from user")
@Results(id="userMap",
value= {
@Result(id=true,column="id",property="userId"),
@Result(column="username",property="userName"),
@Result(column="sex",property="userSex"),
@Result(column="address",property="userAddress"),
@Result(column="birthday",property="userBirthday")
})
List<User> findAll();
/**
* 根據(jù) id 查詢一個(gè)用戶
* @param userId
* @return
*/
@Select("select * from user where id = #{uid} ")
@ResultMap("userMap")
User findById(Integer userId);
}
3.3.2.4 測(cè)試一對(duì)一關(guān)聯(lián)及延遲加載
package com.ding;
import com.ding.dao.IAccountDao;
import com.ding.domain.Account;
import com.ding.domain.AccountUser;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import org.apache.ibatis.io.Resources;
import java.io.InputStream;
import java.util.List;
public class AccountTest {
private InputStream in ;
private SqlSessionFactory factory;
private SqlSession session;
private IAccountDao accountDao;
@Before//在測(cè)試方法執(zhí)行之前執(zhí)行
public void init()throws Exception {
//1.讀取配置文件
in = Resources.getResourceAsStream("SqlMapConfig.xml");
//2.創(chuàng)建構(gòu)建者對(duì)象
SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
//3.創(chuàng)建 SqlSession 工廠對(duì)象
factory = builder.build(in);
//4.創(chuàng)建 SqlSession 對(duì)象
session = factory.openSession();
//5.創(chuàng)建 Dao 的代理對(duì)象
accountDao = session.getMapper(IAccountDao.class);
}
@After//在測(cè)試方法執(zhí)行完成之后執(zhí)行
public void destroy() throws Exception{
session.commit();
//7.釋放資源
session.close();
in.close();
}
@Test
public void testFindAll1() {
List<Account> accounts = accountDao.findAll();
// for(Account au : accounts) {
// System.out.println(au);
// System.out.println(au.getUser());
// }
}
}
3.3.3 使用注解實(shí)現(xiàn)一對(duì)多復(fù)雜關(guān)系映射
需求：
查詢用戶信息時(shí)，也要查詢他的賬戶列表。使用注解方式實(shí)現(xiàn)。
分析：
一個(gè)用戶具有多個(gè)賬戶信息，所以形成了用戶(User)與賬戶(Account)之間的一對(duì)多關(guān)系。
3.3.3.1 User 實(shí)體類加入 List<Account>
package com.ding.domain;
import java.io.Serializable;
import java.util.Date;
import java.util.List;
public class User implements Serializable {
private Integer userId;
private String userName;
private Date userBirthday;
private String userSex;
private String userAddress;
//一對(duì)多關(guān)系映射：主表方法應(yīng)該包含一個(gè)從表方的集合引用
private List<Account> accounts;
public List<Account> getAccounts() {
return accounts;
}
public void setAccounts(List<Account> accounts) {
this.accounts = accounts;
}
public Integer getUserId() {
return userId;
}
public void setUserId(Integer userId) {
this.userId = userId;
}
public String getUserName() {
return userName;
}
public void setUserName(String userName) {
this.userName = userName;
}
public Date getUserBirthday() {
return userBirthday;
}
public void setUserBirthday(Date userBirthday) {
this.userBirthday = userBirthday;
}
public String getUserSex() {
return userSex;
}
public void setUserSex(String userSex) {
this.userSex = userSex;
}
public String getUserAddress() {
return userAddress;
}
public void setUserAddress(String userAddress) {
this.userAddress = userAddress;
}
@Override
public String toString() {
return "User{" +
"userId=" + userId +
", userName='" + userName + '\'' +
", userBirthday=" + userBirthday +
", userSex='" + userSex + '\'' +
", userAddress='" + userAddress + '\'' +
", accounts=" + accounts +
'}';
}
}
3.3.3.2 編寫用戶的持久層接口并使用注解配置
package com.ding.dao;
import com.ding.domain.Account;
import com.ding.domain.User;
import org.apache.ibatis.annotations.*;
import org.apache.ibatis.mapping.FetchType;
import java.util.List;
public interface IUserDao {
/**
* 查詢所有用戶
* @return
*/
@Select("select * from user")
@Results(id="userMap",
value= {
@Result(id=true,column="id",property="userId"),
@Result(column="username",property="userName"),
@Result(column="sex",property="userSex"),
@Result(column="address",property="userAddress"),
@Result(column="birthday",property="userBirthday"),
@Result(column="id",property="accounts",
many=@Many(
select="com.ding.dao.IAccountDao.findByUid",
fetchType= FetchType.LAZY
)
)
})
List<User> findAll();
}
@Many:
相當(dāng)于<collection>的配置
select 屬性：代表將要執(zhí)行的 sql 語(yǔ)句
fetchType 屬性：代表加載方式，一般如果要延遲加載都設(shè)置為 LAZY 的值
3.3.3.3 編寫賬戶的持久層接口并使用注解配置
package com.ding.dao;
import com.ding.domain.Account;
import com.ding.domain.AccountUser;
import org.apache.ibatis.annotations.One;
import org.apache.ibatis.annotations.Result;
import org.apache.ibatis.annotations.Results;
import org.apache.ibatis.annotations.Select;
import org.apache.ibatis.mapping.FetchType;
import java.util.List;
public interface IAccountDao {
@Select("select * from account where uid = #{uid} ")
List<Account> findByUid(Integer userId);
}
3.3.3.4 添加測(cè)試方法
package com.ding;
import com.ding.dao.IUserDao;
import com.ding.domain.User;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import java.io.InputStream;
import java.util.Date;
import java.util.List;
public class test {
private InputStream in ;
private SqlSessionFactory factory;
private SqlSession session;
private IUserDao userDao;
@Test
public void testFindAll() {
//6.執(zhí)行操作
List<User> users = userDao.findAll();
// for(User user : users) {
// System.out.println("-------每個(gè)用戶的內(nèi)容---------");
// System.out.println(user);
// System.out.println(user.getAccounts());
// }
}
@Before//在測(cè)試方法執(zhí)行之前執(zhí)行
public void init()throws Exception {
//1.讀取配置文件
in = Resources.getResourceAsStream("SqlMapConfig.xml");
//2.創(chuàng)建構(gòu)建者對(duì)象
SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
//3.創(chuàng)建 SqlSession 工廠對(duì)象
factory = builder.build(in);
//4.創(chuàng)建 SqlSession 對(duì)象
session = factory.openSession();
//5.創(chuàng)建 Dao 的代理對(duì)象
userDao = session.getMapper(IUserDao.class);
}
@After//在測(cè)試方法執(zhí)行完成之后執(zhí)行
public void destroy() throws Exception{
session.commit();
//7.釋放資源
session.close();
in.close();
}
}
3.4 mybatis 基于注解的二級(jí)緩存
3.4.1 在 SqlMapConfig 中開啟二級(jí)緩存支持
<!-- 配置二級(jí)緩存 -->
<settings>
<!-- 開啟二級(jí)緩存的支持 -->
<setting name="cacheEnabled" value="true"/>
</settings>
3.4.2 在持久層接口中使用注解配置二級(jí)緩存
/**
*
* <p>Title: IUserDao</p>
* <p>Description: 用戶的持久層接口</p>
* <p>Company: http://www.itheima.com/ </p>
*/
@CacheNamespace(blocking=true)//mybatis 基于注解方式實(shí)現(xiàn)配置二級(jí)緩存
public interface IUserDao {}
