Mybatis注解开发(超详细)

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
简介: Mybatis注解开发(超详细)

mybatis的常用注解

image.png


使用 Mybatis 注解实现基本 CRUD


项目目录结构

15.png


编写实体类


User:


package com.keafmd.domain;
import java.io.Serializable;
import java.util.Date;
/**
 * Keafmd
 *
 * @ClassName: User
 * @Description: User实体类
 * @author: 牛哄哄的柯南
 * @date: 2021-02-16 20:28
 */
public class User implements Serializable {
    private Integer id;
    private String username;
    private String address;
    private String sex;
    private Date birthday;
    public Integer getId() {
        return id;
    }
    public void setId(Integer id) {
        this.id = id;
    }
    public String getUsername() {
        return username;
    }
    public void setUsername(String username) {
        this.username = username;
    }
    public String getAddress() {
        return address;
    }
    public void setAddress(String address) {
        this.address = address;
    }
    public String getSex() {
        return sex;
    }
    public void setSex(String sex) {
        this.sex = sex;
    }
    public Date getBirthday() {
        return birthday;
    }
    public void setBirthday(Date birthday) {
        this.birthday = birthday;
    }
    @Override
    public String toString() {
        return "User{" +
                "id=" + id +
                ", username='" + username + '\'' +
                ", address='" + address + '\'' +
                ", sex='" + sex + '\'' +
                ", birthday=" + birthday +
                '}';
    }
}

使用注解方式开发持久层接口


IUserDao:


package com.keafmd.dao;
import com.keafmd.domain.User;
import org.apache.ibatis.annotations.Delete;
import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Select;
import org.apache.ibatis.annotations.Update;
import java.util.List;
/**
 * Keafmd
 *
 * @ClassName: IUserDao
 * @Description:
 * @author: 牛哄哄的柯南
 * @date: 2021-02-16 20:30
 */
/**
 * 在mybatis中针对CRUD一共有四个注解
 * @Select @Insert @Update @Delete
 */
public interface IUserDao {
    /**
     * 查询所有用户
     * @return
     */
    @Select("select * from user")
    List<User> findAll();
    /**
     * 保存用户
     * @param user
     */
    @Insert("insert into user(username,address,sex,birthday)values(#{username},#{address},#{sex},#{birthday})")
    void saveUser(User user);
    /**
     * 更新用户
     * @param user
     */
    @Update("update user set username=#{username},sex=#{sex},birthday=#{birthday},address=#{address} where id=#{id}")
    void updateUser(User user);
    /**
     * 删除用户
     * @param userId
     */
    @Delete("delete from user where id=#{id}")
    void deleteUser(Integer userId);
    /**
     * 根据id查询用户
     * @param userId
     * @return
     */
    @Select("select * from user where id=#{id}")
    User findById(Integer userId);
    /**
     * 根据用户名称模糊查询
     * @param username
     * @return
     */
    //@Select("select * from user where username like #{username}") //占位符
    @Select("select * from user where username like '%${value}%'")  //字符串拼接
    List<User> findByName(String username);
    /**
     * 查询总数量
     * @return
     */
    @Select("select count(*) from user")
    int findTotal();
}

通过注解方式,就不需要再去编写 UserDao.xml 映射文件了。


编写 SqlMapConfig.xml 配置文件


SqlMapConfig.xml:


<?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>
    <!--引入外部配置文件-->
    <properties resource="jdbcConfig.properties"></properties>
    <!--配置别名-->
    <typeAliases>
        <package name="com.keafmd.domain"/>
    </typeAliases>
    <!--配置环境-->
    <environments default="mysql">
        <environment id="mysql">
            <transactionManager type="JDBC"></transactionManager>
            <dataSource type="POOLED">
                <property name="driver" value="${jdbc.driver}"></property>
                <property name="url" value="${jdbc.url}"></property>
                <property name="username" value="${jdbc.username}"></property>
                <property name="password" value="${jdbc.password}"></property>
            </dataSource>
        </environment>
    </environments>
    <!--指定带有注解的dao接口所在位置-->
    <mappers>
        <package name="com.keafmd.dao"></package>
    </mappers>
</configuration>

编写测试代码


AnnotationCRUDTest:


package com.keafmd.test;
import com.keafmd.dao.IUserDao;
import com.keafmd.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;
/**
 * Keafmd
 *
 * @ClassName: AnnotationCRUDTest
 * @Description: 注解开发CRUD测试
 * @author: 牛哄哄的柯南
 * @date: 2021-02-16 21:05
 */
public class AnnotationCRUDTest {
    private InputStream in;
    private SqlSessionFactory factory;
    private SqlSession session;
    private IUserDao userDao;
    @Before
    public void init() throws Exception{
        in = Resources.getResourceAsStream("SqlMapConfig.xml");
        factory = new SqlSessionFactoryBuilder().build(in);
        session = factory.openSession();
        userDao = session.getMapper(IUserDao.class);
    }
    @After
    public void destory() throws Exception{
        session.commit();
        session.close();
        in.close();
    }
    @Test
    public void testSave(){
        User user = new User();
        user.setUsername("mybatis annotation");
        user.setAddress("北京");
        userDao.saveUser(user);
    }
    @Test
    public void testUpdate(){
        User user = new User();
        user.setId(55);
        user.setUsername("mybatis annotation");
        user.setAddress("北京");
        user.setSex("男");
        user.setBirthday(new Date());
        userDao.updateUser(user);
    }
    @Test
    public void testDelete(){
        userDao.deleteUser(54);
    }
    @Test
    public void testFindOne(){
        User user = userDao.findById(55);
        System.out.println(user);
    }
    @Test
    public void testFindByName(){
        //List<User> users = userDao.findByName("%Keafmd%");
        List<User> users = userDao.findByName("Keafmd");
        for (User user : users) {
            System.out.println(user);
        }
    }
    @Test
    public void testFindTotal(){
       int total = userDao.findTotal();
        System.out.println(total);
    }
}

使用注解实现复杂关系映射开发


实现复杂关系映射之前我们可以在映射文件中通过配置<resultMap>来实现,在使用注解开发时我们需要借助@Results 注解,@Result 注解,@One 注解,@Many 注解。


复杂关系映射的注解说明


@Results 注解

代替的是标签<resultMap>

该注解中可以使用单个@Result 注解,也可以使用@Result 集合

@Results({@Result(),@Result()})或@Results(@Result())


@Resutl 注解

代替了<id> 标签和<result>标签

@Result 中的属性介绍:

image.png

@One 注解(一对一)

代替了<assocation>标签,是多表查询的关键,在注解中用来指定子查询返回单一对象。

@One 注解属性介绍:

select 指定用来多表查询的 sqlmapper

fetchType 会覆盖全局的配置参数 lazyLoadingEnabled。

使用格式:@Result(column=" “,property=”",one=@One(select=""))


@Many 注解(多对一)

代替了<collection>标签,是是多表查询的关键,在注解中用来指定子查询返回对象集合。

注意:聚集元素用来处理“一对多”的关系。需要指定映射的 Java 实体类的属性,属性的 javaType(一般为 ArrayList)但是注解中可以不定义。

使用格式:@Result(property="",column="",many=@Many(select=""))


项目目录

16.png


使用注解实现一对一复杂关系映射及立即加载


需求:加载账户信息时并且加载该账户的用户信息,根据情况可实现立即加载。(注解方式实现)


添加 User 实体类及 Account 实体类


User:


package com.keafmd.domain;
import java.io.Serializable;
import java.util.Date;
import java.util.List;
/**
 * Keafmd
 *
 * @ClassName: User
 * @Description: User实体类
 * @author: 牛哄哄的柯南
 * @date: 2021-02-16 20:28
 */
public class User implements Serializable {
    private Integer userId;
    private String userName;
    private String userAddress;
    private String userSex;
    private Date userBirthday;
    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 String getUserAddress() {
        return userAddress;
    }
    public void setUserAddress(String userAddress) {
        this.userAddress = userAddress;
    }
    public String getUserSex() {
        return userSex;
    }
    public void setUserSex(String userSex) {
        this.userSex = userSex;
    }
    public Date getUserBirthday() {
        return userBirthday;
    }
    public void setUserBirthday(Date userBirthday) {
        this.userBirthday = userBirthday;
    }
    @Override
    public String toString() {
        return "User{" +
                "userId=" + userId +
                ", userName='" + userName + '\'' +
                ", userAddress='" + userAddress + '\'' +
                ", userSex='" + userSex + '\'' +
                ", userBirthday=" + userBirthday +
                '}';
    }
}

Account:


package com.keafmd.domain;
import java.io.Serializable;
/**
 * Keafmd
 *
 * @ClassName: Account
 * @Description: 账户实体类
 * @author: 牛哄哄的柯南
 * @date: 2021-02-16 22:51
 */
public class Account implements Serializable {
    private Integer id;
    private Integer uid;
    private Double money;
    //多对一(mybatis中称之为一对一)的映射,一个账户只能属于一个用户 *
    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 +
                '}';
    }
}

添加账户的持久层接口并使用注解配置


IAccountDao:


package com.keafmd.dao;
import com.keafmd.domain.Account;
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;
/**
 * Keafmd
 *
 * @ClassName: IAccountDao
 * @Description:
 * @author: 牛哄哄的柯南
 * @date: 2021-02-16 22:54
 */
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(property = "user",column = "uid",one=@One(select="com.keafmd.dao.IUserDao.findById",fetchType= FetchType.EAGER))
    })
    List<Account> findAll();
}

添加用户的持久层接口并使用注解配置


package com.keafmd.dao;
import com.keafmd.domain.User;
import org.apache.ibatis.annotations.*;
import org.apache.ibatis.mapping.FetchType;
import java.util.List;
/**
 * Keafmd
 *
 * @ClassName: IUserDao
 * @Description:
 * @author: 牛哄哄的柯南
 * @date: 2021-02-16 20:30
 */
/**
 * 在mybatis中针对CRUD一共有四个注解
 * @Select @Insert @Update @Delete
 */
public interface IUserDao {
    /**
     * 查询所有用户
     * @return
     */
    @Select("select * from user")
    @Results(id="userMap",value={
            @Result(id = true,column = "id",property = "userId"),
            @Result(column = "id",property = "userId"),
            @Result(column = "username",property = "userName"),
            @Result(column = "sex",property = "userSex"),
            @Result(column = "birthday",property = "userBirthday")
    })
    List<User> findAll();
    /**
     * 根据id查询用户
     * @param userId
     * @return
     */
    @Select("select * from user where id=#{id}")
    //@ResultMap(value={"userMap"})
    @ResultMap("userMap")
    User findById(Integer userId);
    /**
     * 根据用户名称模糊查询
     * @param username
     * @return
     */
    @Select("select * from user where username like #{username}") //占位符
    @ResultMap("userMap")
    List<User> findByName(String username);
}

测试一对一关联及立即加载


package com.keafmd.test;
import com.keafmd.dao.IAccountDao;
import com.keafmd.dao.IUserDao;
import com.keafmd.domain.Account;
import com.keafmd.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.List;
/**
 * Keafmd
 *
 * @ClassName: AnnotationCRUDTest
 * @Description: 注解开发CRUD测试
 * @author: 牛哄哄的柯南
 * @date: 2021-02-16 21:05
 */
public class AccountTest {
    private InputStream in;
    private SqlSessionFactory factory;
    private SqlSession session;
    private IAccountDao accountDao;
    @Before
    public void init() throws Exception{
        in = Resources.getResourceAsStream("SqlMapConfig.xml");
        factory = new SqlSessionFactoryBuilder().build(in);
        session = factory.openSession();
        accountDao = session.getMapper(IAccountDao.class);
    }
    @After
    public void destory() throws Exception{
        session.commit();
        session.close();
        in.close();
    }
    @Test
    public void testFindAll(){
        List<Account> accounts = accountDao.findAll();
        for (Account account : accounts) {
            System.out.println("-----每个账户信息-----");
            System.out.println(account);
            System.out.println(account.getUser());
        }
    }
}

运行结果:


2021-02-17 03:04:39,939 163    [           main] DEBUG ansaction.jdbc.JdbcTransaction  - Opening JDBC Connection
2021-02-17 03:04:40,190 414    [           main] DEBUG source.pooled.PooledDataSource  - Created connection 1176735295.
2021-02-17 03:04:40,190 414    [           main] DEBUG ansaction.jdbc.JdbcTransaction  - Setting autocommit to false on JDBC Connection [com.mysql.jdbc.JDBC4Connection@46238e3f]
2021-02-17 03:04:40,195 419    [           main] DEBUG keafmd.dao.IAccountDao.findAll  - ==>  Preparing: select * from account
2021-02-17 03:04:40,226 450    [           main] DEBUG keafmd.dao.IAccountDao.findAll  - ==> Parameters: 
2021-02-17 03:04:40,267 491    [           main] DEBUG m.keafmd.dao.IUserDao.findById  - ====>  Preparing: select * from user where id=?
2021-02-17 03:04:40,268 492    [           main] DEBUG m.keafmd.dao.IUserDao.findById  - ====> Parameters: 41(Integer)
2021-02-17 03:04:40,270 494    [           main] DEBUG m.keafmd.dao.IUserDao.findById  - <====      Total: 1
2021-02-17 03:04:40,271 495    [           main] DEBUG m.keafmd.dao.IUserDao.findById  - ====>  Preparing: select * from user where id=?
2021-02-17 03:04:40,271 495    [           main] DEBUG m.keafmd.dao.IUserDao.findById  - ====> Parameters: 45(Integer)
2021-02-17 03:04:40,272 496    [           main] DEBUG m.keafmd.dao.IUserDao.findById  - <====      Total: 1
2021-02-17 03:04:40,273 497    [           main] DEBUG keafmd.dao.IAccountDao.findAll  - <==      Total: 3
-----每个账户信息-----
Account{id=1, uid=41, money=1000.0}
User{userId=41, userName='update user clear cache', userAddress='null', userSex='男', userBirthday=Tue Feb 27 17:47:08 CST 2018}
-----每个账户信息-----
Account{id=2, uid=45, money=1000.0}
User{userId=45, userName='新一', userAddress='null', userSex='男', userBirthday=Sun Mar 04 12:04:06 CST 2018}
-----每个账户信息-----
Account{id=3, uid=41, money=2000.0}
User{userId=41, userName='update user clear cache', userAddress='null', userSex='男', userBirthday=Tue Feb 27 17:47:08 CST 2018}
2021-02-17 03:04:40,274 498    [           main] DEBUG ansaction.jdbc.JdbcTransaction  - Resetting autocommit to true on JDBC Connection [com.mysql.jdbc.JDBC4Connection@46238e3f]
2021-02-17 03:04:40,274 498    [           main] DEBUG ansaction.jdbc.JdbcTransaction  - Closing JDBC Connection [com.mysql.jdbc.JDBC4Connection@46238e3f]
2021-02-17 03:04:40,274 498    [           main] DEBUG source.pooled.PooledDataSource  - Returned connection 1176735295 to pool.
Process finished with exit code 0

使用注解实现一对多复杂关系映射及延迟加载


需求:查询用户信息时,也要查询他的账户列表。使用注解方式实现。

分析:一个用户具有多个账户信息,所以形成了用户(User)与账户(Account)之间的一对多关系。


User 实体类加入 List<Account>


User:


package com.keafmd.domain;
import java.io.Serializable;
import java.util.Date;
import java.util.List;
/**
 * Keafmd
 *
 * @ClassName: User
 * @Description: User实体类
 * @author: 牛哄哄的柯南
 * @date: 2021-02-16 20:28
 */
public class User implements Serializable {
    private Integer userId;
    private String userName;
    private String userAddress;
    private String userSex;
    private Date userBirthday;
    //一对多关系映射:一个用户对应多个账户
    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 String getUserAddress() {
        return userAddress;
    }
    public void setUserAddress(String userAddress) {
        this.userAddress = userAddress;
    }
    public String getUserSex() {
        return userSex;
    }
    public void setUserSex(String userSex) {
        this.userSex = userSex;
    }
    public Date getUserBirthday() {
        return userBirthday;
    }
    public void setUserBirthday(Date userBirthday) {
        this.userBirthday = userBirthday;
    }
    @Override
    public String toString() {
        return "User{" +
                "userId=" + userId +
                ", userName='" + userName + '\'' +
                ", userAddress='" + userAddress + '\'' +
                ", userSex='" + userSex + '\'' +
                ", userBirthday=" + userBirthday +
                '}';
    }
}

编写用户的持久层接口并使用注解配置


package com.keafmd.dao;
import com.keafmd.domain.User;
import org.apache.ibatis.annotations.*;
import org.apache.ibatis.mapping.FetchType;
import java.util.List;
/**
 * Keafmd
 *
 * @ClassName: IUserDao
 * @Description:
 * @author: 牛哄哄的柯南
 * @date: 2021-02-16 20:30
 */
/**
 * 在mybatis中针对CRUD一共有四个注解
 * @Select @Insert @Update @Delete
 */
public interface IUserDao {
    /**
     * 查询所有用户
     * @return
     */
    @Select("select * from user")
    @Results(id="userMap",value={
            @Result(id = true,column = "id",property = "userId"),
            @Result(column = "id",property = "userId"),
            @Result(column = "username",property = "userName"),
            @Result(column = "sex",property = "userSex"),
            @Result(column = "birthday",property = "userBirthday"),
            @Result(property = "accounts" ,column = "id",
                    many = @Many(select = "com.keafmd.dao.IAccountDao.findAccountByUid",
                            fetchType = FetchType.LAZY))
    })
    List<User> findAll();
    /**
     * 根据id查询用户
     * @param userId
     * @return
     */
    @Select("select * from user where id=#{id}")
    //@ResultMap(value={"userMap"})
    @ResultMap("userMap")
    User findById(Integer userId);
    /**
     * 根据用户名称模糊查询
     * @param username
     * @return
     */
    @Select("select * from user where username like #{username}") //占位符
    @ResultMap("userMap")
    List<User> findByName(String username);
}

编写账户的持久层接口并使用注解配置


package com.keafmd.dao;
import com.keafmd.domain.Account;
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;
/**
 * Keafmd
 *
 * @ClassName: IAccountDao
 * @Description:
 * @author: 牛哄哄的柯南
 * @date: 2021-02-16 22:54
 */
public interface IAccountDao {
    /**
     * 查询所有账户,并且获取每个账户下的用户信息,一对一 ,* 这里用不到这个findAll()
     * @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(property = "user",column = "uid",one=@One(select="com.keafmd.dao.IUserDao.findById",fetchType= FetchType.EAGER))
    })
    List<Account> findAll();
    /**
     * 根据用户id查询账户信息
     * @param userId
     * @return
     */
    @Select("select * from account where uid = #{userId}")
    List<Account> findAccountByUid(Integer userId);
}

编写测试代码


package com.keafmd.test;
import com.keafmd.dao.IUserDao;
import com.keafmd.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;
/**
 * Keafmd
 *
 * @ClassName: AnnotationCRUDTest
 * @Description: 注解开发CRUD测试
 * @author: 牛哄哄的柯南
 * @date: 2021-02-16 21:05
 */
public class UserTest {
    private InputStream in;
    private SqlSessionFactory factory;
    private SqlSession session;
    private IUserDao userDao;
    @Before
    public void init() throws Exception{
        in = Resources.getResourceAsStream("SqlMapConfig.xml");
        factory = new SqlSessionFactoryBuilder().build(in);
        session = factory.openSession();
        userDao = session.getMapper(IUserDao.class);
    }
    @After
    public void destory() throws Exception{
        session.commit();
        session.close();
        in.close();
    }
    @Test
    public void testFindAll(){
        List<User> users = userDao.findAll();
        for (User user : users) {
            System.out.println("-----每个用户的信息");
            System.out.println(user);
            System.out.println(user.getAccounts());
        }
    }
}

运行testFindAll()的结果:


2021-02-17 03:14:19,655 378    [           main] DEBUG ansaction.jdbc.JdbcTransaction  - Opening JDBC Connection
2021-02-17 03:14:20,124 847    [           main] DEBUG source.pooled.PooledDataSource  - Created connection 1176735295.
2021-02-17 03:14:20,124 847    [           main] DEBUG ansaction.jdbc.JdbcTransaction  - Setting autocommit to false on JDBC Connection [com.mysql.jdbc.JDBC4Connection@46238e3f]
2021-02-17 03:14:20,135 858    [           main] DEBUG om.keafmd.dao.IUserDao.findAll  - ==>  Preparing: select * from user
2021-02-17 03:14:20,183 906    [           main] DEBUG om.keafmd.dao.IUserDao.findAll  - ==> Parameters: 
2021-02-17 03:14:20,471 1194   [           main] DEBUG om.keafmd.dao.IUserDao.findAll  - <==      Total: 9
-----每个用户的信息
2021-02-17 03:14:20,473 1196   [           main] DEBUG o.IAccountDao.findAccountByUid  - ==>  Preparing: select * from account where uid = ?
2021-02-17 03:14:20,474 1197   [           main] DEBUG o.IAccountDao.findAccountByUid  - ==> Parameters: 41(Integer)
2021-02-17 03:14:20,475 1198   [           main] DEBUG o.IAccountDao.findAccountByUid  - <==      Total: 2
User{userId=41, userName='update user clear cache', userAddress='null', userSex='男', userBirthday=Tue Feb 27 17:47:08 CST 2018}
[Account{id=1, uid=41, money=1000.0}, Account{id=3, uid=41, money=2000.0}]
-----每个用户的信息
2021-02-17 03:14:20,476 1199   [           main] DEBUG o.IAccountDao.findAccountByUid  - ==>  Preparing: select * from account where uid = ?
2021-02-17 03:14:20,476 1199   [           main] DEBUG o.IAccountDao.findAccountByUid  - ==> Parameters: 42(Integer)
2021-02-17 03:14:20,477 1200   [           main] DEBUG o.IAccountDao.findAccountByUid  - <==      Total: 0
User{userId=42, userName='update', userAddress='null', userSex='男', userBirthday=Mon Feb 08 19:37:31 CST 2021}
[]
-----每个用户的信息
2021-02-17 03:14:20,479 1202   [           main] DEBUG o.IAccountDao.findAccountByUid  - ==>  Preparing: select * from account where uid = ?
2021-02-17 03:14:20,480 1203   [           main] DEBUG o.IAccountDao.findAccountByUid  - ==> Parameters: 43(Integer)
2021-02-17 03:14:20,481 1204   [           main] DEBUG o.IAccountDao.findAccountByUid  - <==      Total: 0
User{userId=43, userName='小二王', userAddress='null', userSex='女', userBirthday=Sun Mar 04 11:34:34 CST 2018}
[]
-----每个用户的信息
2021-02-17 03:14:20,481 1204   [           main] DEBUG o.IAccountDao.findAccountByUid  - ==>  Preparing: select * from account where uid = ?
2021-02-17 03:14:20,482 1205   [           main] DEBUG o.IAccountDao.findAccountByUid  - ==> Parameters: 45(Integer)
2021-02-17 03:14:20,483 1206   [           main] DEBUG o.IAccountDao.findAccountByUid  - <==      Total: 1
User{userId=45, userName='新一', userAddress='null', userSex='男', userBirthday=Sun Mar 04 12:04:06 CST 2018}
[Account{id=2, uid=45, money=1000.0}]
-----每个用户的信息
2021-02-17 03:14:20,484 1207   [           main] DEBUG o.IAccountDao.findAccountByUid  - ==>  Preparing: select * from account where uid = ?
2021-02-17 03:14:20,484 1207   [           main] DEBUG o.IAccountDao.findAccountByUid  - ==> Parameters: 50(Integer)
2021-02-17 03:14:20,484 1207   [           main] DEBUG o.IAccountDao.findAccountByUid  - <==      Total: 0
User{userId=50, userName='Keafmd', userAddress='null', userSex='男', userBirthday=Mon Feb 08 15:44:01 CST 2021}
[]
-----每个用户的信息
2021-02-17 03:14:20,485 1208   [           main] DEBUG o.IAccountDao.findAccountByUid  - ==>  Preparing: select * from account where uid = ?
2021-02-17 03:14:20,485 1208   [           main] DEBUG o.IAccountDao.findAccountByUid  - ==> Parameters: 51(Integer)
2021-02-17 03:14:20,486 1209   [           main] DEBUG o.IAccountDao.findAccountByUid  - <==      Total: 0
User{userId=51, userName='update DAO', userAddress='null', userSex='男', userBirthday=Tue Feb 09 11:31:38 CST 2021}
[]
-----每个用户的信息
2021-02-17 03:14:20,488 1211   [           main] DEBUG o.IAccountDao.findAccountByUid  - ==>  Preparing: select * from account where uid = ?
2021-02-17 03:14:20,489 1212   [           main] DEBUG o.IAccountDao.findAccountByUid  - ==> Parameters: 52(Integer)
2021-02-17 03:14:20,491 1214   [           main] DEBUG o.IAccountDao.findAccountByUid  - <==      Total: 0
User{userId=52, userName='Keafmd DAO', userAddress='null', userSex='男', userBirthday=Tue Feb 09 11:29:41 CST 2021}
[]
-----每个用户的信息
2021-02-17 03:14:20,491 1214   [           main] DEBUG o.IAccountDao.findAccountByUid  - ==>  Preparing: select * from account where uid = ?
2021-02-17 03:14:20,492 1215   [           main] DEBUG o.IAccountDao.findAccountByUid  - ==> Parameters: 53(Integer)
2021-02-17 03:14:20,493 1216   [           main] DEBUG o.IAccountDao.findAccountByUid  - <==      Total: 0
User{userId=53, userName='Keafmd laset insertid 1', userAddress='null', userSex='男', userBirthday=Fri Feb 12 20:53:46 CST 2021}
[]
-----每个用户的信息
2021-02-17 03:14:20,493 1216   [           main] DEBUG o.IAccountDao.findAccountByUid  - ==>  Preparing: select * from account where uid = ?
2021-02-17 03:14:20,493 1216   [           main] DEBUG o.IAccountDao.findAccountByUid  - ==> Parameters: 55(Integer)
2021-02-17 03:14:20,494 1217   [           main] DEBUG o.IAccountDao.findAccountByUid  - <==      Total: 0
User{userId=55, userName='mybatis annotation', userAddress='null', userSex='男', userBirthday=Tue Feb 16 22:15:36 CST 2021}
[]
2021-02-17 03:14:20,495 1218   [           main] DEBUG ansaction.jdbc.JdbcTransaction  - Resetting autocommit to true on JDBC Connection [com.mysql.jdbc.JDBC4Connection@46238e3f]
2021-02-17 03:14:20,495 1218   [           main] DEBUG ansaction.jdbc.JdbcTransaction  - Closing JDBC Connection [com.mysql.jdbc.JDBC4Connection@46238e3f]
2021-02-17 03:14:20,495 1218   [           main] DEBUG source.pooled.PooledDataSource  - Returned connection 1176735295 to pool.
Process finished with exit code 0

可以看出来延迟加载,在每次加载每个用户时都会查询一次。


修改测试代码:


@Test
public void testFindAll(){
    List<User> users = userDao.findAll();
    /*for (User user : users) {
        System.out.println("-----每个用户的信息");
        System.out.println(user);
        System.out.println(user.getAccounts());
    }*/
}

运行结果:


2021-02-17 03:17:26,203 166    [           main] DEBUG ansaction.jdbc.JdbcTransaction  - Opening JDBC Connection
2021-02-17 03:17:26,500 463    [           main] DEBUG source.pooled.PooledDataSource  - Created connection 1176735295.
2021-02-17 03:17:26,500 463    [           main] DEBUG ansaction.jdbc.JdbcTransaction  - Setting autocommit to false on JDBC Connection [com.mysql.jdbc.JDBC4Connection@46238e3f]
2021-02-17 03:17:26,505 468    [           main] DEBUG om.keafmd.dao.IUserDao.findAll  - ==>  Preparing: select * from user
2021-02-17 03:17:26,540 503    [           main] DEBUG om.keafmd.dao.IUserDao.findAll  - ==> Parameters: 
2021-02-17 03:17:26,613 576    [           main] DEBUG om.keafmd.dao.IUserDao.findAll  - <==      Total: 9
2021-02-17 03:17:26,614 577    [           main] DEBUG ansaction.jdbc.JdbcTransaction  - Resetting autocommit to true on JDBC Connection [com.mysql.jdbc.JDBC4Connection@46238e3f]
2021-02-17 03:17:26,614 577    [           main] DEBUG ansaction.jdbc.JdbcTransaction  - Closing JDBC Connection [com.mysql.jdbc.JDBC4Connection@46238e3f]
2021-02-17 03:17:26,614 577    [           main] DEBUG source.pooled.PooledDataSource  - Returned connection 1176735295 to pool.
Process finished with exit code 0

这样通过对比就可以很明显的看出来延迟加载的效果。


回顾下一级缓存


运行代码:


@Test
public void testFindOne(){
    User user = userDao.findById(55);
    System.out.println(user);
    User user2 = userDao.findById(55);
    System.out.println(user2);
    System.out.println(user==user2);
}

运行结果:


2021-02-17 03:26:22,736 164    [           main] DEBUG ansaction.jdbc.JdbcTransaction  - Opening JDBC Connection
2021-02-17 03:26:22,970 398    [           main] DEBUG source.pooled.PooledDataSource  - Created connection 85445963.
2021-02-17 03:26:22,971 399    [           main] DEBUG ansaction.jdbc.JdbcTransaction  - Setting autocommit to false on JDBC Connection [com.mysql.jdbc.JDBC4Connection@517cd4b]
2021-02-17 03:26:22,975 403    [           main] DEBUG m.keafmd.dao.IUserDao.findById  - ==>  Preparing: select * from user where id=?
2021-02-17 03:26:23,001 429    [           main] DEBUG m.keafmd.dao.IUserDao.findById  - ==> Parameters: 55(Integer)
2021-02-17 03:26:23,054 482    [           main] DEBUG m.keafmd.dao.IUserDao.findById  - <==      Total: 1
2021-02-17 03:26:23,055 483    [           main] DEBUG o.IAccountDao.findAccountByUid  - ==>  Preparing: select * from account where uid = ?
2021-02-17 03:26:23,055 483    [           main] DEBUG o.IAccountDao.findAccountByUid  - ==> Parameters: 55(Integer)
2021-02-17 03:26:23,056 484    [           main] DEBUG o.IAccountDao.findAccountByUid  - <==      Total: 0
User{userId=55, userName='mybatis annotation', userAddress='null', userSex='男', userBirthday=Tue Feb 16 22:15:36 CST 2021}
User{userId=55, userName='mybatis annotation', userAddress='null', userSex='男', userBirthday=Tue Feb 16 22:15:36 CST 2021}
true
2021-02-17 03:26:23,056 484    [           main] DEBUG ansaction.jdbc.JdbcTransaction  - Resetting autocommit to true on JDBC Connection [com.mysql.jdbc.JDBC4Connection@517cd4b]
2021-02-17 03:26:23,056 484    [           main] DEBUG ansaction.jdbc.JdbcTransaction  - Closing JDBC Connection [com.mysql.jdbc.JDBC4Connection@517cd4b]
2021-02-17 03:26:23,057 485    [           main] DEBUG source.pooled.PooledDataSource  - Returned connection 85445963 to pool.
Process finished with exit code 0

mybatis 基于注解的二级缓存


在 SqlMapConfig.xml 中开启二级缓存支持


<!--配置开启二级缓存-->
<settings>
    <setting name="cacheEnabled" value="true"/>
</settings>

在持久层接口中使用注解配置二级缓存


package com.keafmd.dao;
import com.keafmd.domain.User;
import org.apache.ibatis.annotations.*;
import org.apache.ibatis.mapping.FetchType;
import java.util.List;
/**
 * Keafmd
 *
 * @ClassName: IUserDao
 * @Description:
 * @author: 牛哄哄的柯南
 * @date: 2021-02-16 20:30
 */
/**
 * 在mybatis中针对CRUD一共有四个注解
 * @Select @Insert @Update @Delete
 */
@CacheNamespace(blocking = true) //mybatis 基于注解方式实现配置二级缓存 *这里*
public interface IUserDao {
    /**
     * 查询所有用户
     * @return
     */
    @Select("select * from user")
    @Results(id="userMap",value={
            @Result(id = true,column = "id",property = "userId"),
            @Result(column = "id",property = "userId"),
            @Result(column = "username",property = "userName"),
            @Result(column = "sex",property = "userSex"),
            @Result(column = "birthday",property = "userBirthday"),
            @Result(property = "accounts" ,column = "id",
                    many = @Many(select = "com.keafmd.dao.IAccountDao.findAccountByUid",
                            fetchType = FetchType.LAZY))
    })
    List<User> findAll();
    /**
     * 根据id查询用户
     * @param userId
     * @return
     */
    @Select("select * from user where id=#{id}")
    //@ResultMap(value={"userMap"})
    @ResultMap("userMap")
    User findById(Integer userId);
    /**
     * 根据用户名称模糊查询
     * @param username
     * @return
     */
    @Select("select * from user where username like #{username}") //占位符
    @ResultMap("userMap")
    List<User> findByName(String username);
}

编写测试二级缓存的测试类


package com.keafmd.test;
import com.keafmd.dao.IUserDao;
import com.keafmd.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.List;
/**
 * Keafmd
 *
 * @ClassName: SecondLevelCatchTest
 * @Description: 二级缓存测试
 * @author: 牛哄哄的柯南
 * @date: 2021-02-16 23:37
 */
public class SecondLevelCatchTest {
    private InputStream in;
    private SqlSessionFactory factory;
    @Before
    public void init() throws Exception{
        in = Resources.getResourceAsStream("SqlMapConfig.xml");
        factory = new SqlSessionFactoryBuilder().build(in);
    }
    @After
    public void destory() throws Exception{
        in.close();
    }
    @Test
    public void testFindOne(){
        SqlSession session = factory.openSession();
        IUserDao userDao = session.getMapper(IUserDao.class);
        User user = userDao.findById(55);
        System.out.println(user);
        session.close();//释放一级缓存
        SqlSession session1 = factory.openSession();//再次打开session
        IUserDao userDao1 = session1.getMapper(IUserDao.class);
        User user2 = userDao1.findById(55);
        System.out.println(user2);
        System.out.println(user==user2);
    }
}

不开启二级缓存配置的运行结果:


2021-02-17 03:31:32,119 320    [           main] DEBUG ansaction.jdbc.JdbcTransaction  - Opening JDBC Connection
2021-02-17 03:31:32,509 710    [           main] DEBUG source.pooled.PooledDataSource  - Created connection 85445963.
2021-02-17 03:31:32,510 711    [           main] DEBUG ansaction.jdbc.JdbcTransaction  - Setting autocommit to false on JDBC Connection [com.mysql.jdbc.JDBC4Connection@517cd4b]
2021-02-17 03:31:32,514 715    [           main] DEBUG m.keafmd.dao.IUserDao.findById  - ==>  Preparing: select * from user where id=?
2021-02-17 03:31:32,551 752    [           main] DEBUG m.keafmd.dao.IUserDao.findById  - ==> Parameters: 55(Integer)
2021-02-17 03:31:32,633 834    [           main] DEBUG m.keafmd.dao.IUserDao.findById  - <==      Total: 1
2021-02-17 03:31:32,634 835    [           main] DEBUG o.IAccountDao.findAccountByUid  - ==>  Preparing: select * from account where uid = ?
2021-02-17 03:31:32,634 835    [           main] DEBUG o.IAccountDao.findAccountByUid  - ==> Parameters: 55(Integer)
2021-02-17 03:31:32,635 836    [           main] DEBUG o.IAccountDao.findAccountByUid  - <==      Total: 0
User{userId=55, userName='mybatis annotation', userAddress='null', userSex='男', userBirthday=Tue Feb 16 22:15:36 CST 2021}
2021-02-17 03:31:32,635 836    [           main] DEBUG ansaction.jdbc.JdbcTransaction  - Resetting autocommit to true on JDBC Connection [com.mysql.jdbc.JDBC4Connection@517cd4b]
2021-02-17 03:31:32,636 837    [           main] DEBUG ansaction.jdbc.JdbcTransaction  - Closing JDBC Connection [com.mysql.jdbc.JDBC4Connection@517cd4b]
2021-02-17 03:31:32,636 837    [           main] DEBUG source.pooled.PooledDataSource  - Returned connection 85445963 to pool.
2021-02-17 03:31:32,636 837    [           main] DEBUG ansaction.jdbc.JdbcTransaction  - Opening JDBC Connection
2021-02-17 03:31:32,636 837    [           main] DEBUG source.pooled.PooledDataSource  - Checked out connection 85445963 from pool.
2021-02-17 03:31:32,636 837    [           main] DEBUG ansaction.jdbc.JdbcTransaction  - Setting autocommit to false on JDBC Connection [com.mysql.jdbc.JDBC4Connection@517cd4b]
2021-02-17 03:31:32,636 837    [           main] DEBUG m.keafmd.dao.IUserDao.findById  - ==>  Preparing: select * from user where id=?
2021-02-17 03:31:32,637 838    [           main] DEBUG m.keafmd.dao.IUserDao.findById  - ==> Parameters: 55(Integer)
2021-02-17 03:31:32,639 840    [           main] DEBUG m.keafmd.dao.IUserDao.findById  - <==      Total: 1
2021-02-17 03:31:32,641 842    [           main] DEBUG o.IAccountDao.findAccountByUid  - ==>  Preparing: select * from account where uid = ?
2021-02-17 03:31:32,641 842    [           main] DEBUG o.IAccountDao.findAccountByUid  - ==> Parameters: 55(Integer)
2021-02-17 03:31:32,642 843    [           main] DEBUG o.IAccountDao.findAccountByUid  - <==      Total: 0
User{userId=55, userName='mybatis annotation', userAddress='null', userSex='男', userBirthday=Tue Feb 16 22:15:36 CST 2021}
false
Process finished with exit code 0

开启二级缓存配置的运行结果:


2021-02-17 03:29:23,197 373    [           main] DEBUG ansaction.jdbc.JdbcTransaction  - Opening JDBC Connection
2021-02-17 03:29:23,605 781    [           main] DEBUG source.pooled.PooledDataSource  - Created connection 500179317.
2021-02-17 03:29:23,606 782    [           main] DEBUG ansaction.jdbc.JdbcTransaction  - Setting autocommit to false on JDBC Connection [com.mysql.jdbc.JDBC4Connection@1dd02175]
2021-02-17 03:29:23,617 793    [           main] DEBUG m.keafmd.dao.IUserDao.findById  - ==>  Preparing: select * from user where id=?
2021-02-17 03:29:23,668 844    [           main] DEBUG m.keafmd.dao.IUserDao.findById  - ==> Parameters: 55(Integer)
2021-02-17 03:29:23,777 953    [           main] DEBUG m.keafmd.dao.IUserDao.findById  - <==      Total: 1
2021-02-17 03:29:23,781 957    [           main] DEBUG o.IAccountDao.findAccountByUid  - ==>  Preparing: select * from account where uid = ?
2021-02-17 03:29:23,782 958    [           main] DEBUG o.IAccountDao.findAccountByUid  - ==> Parameters: 55(Integer)
2021-02-17 03:29:23,782 958    [           main] DEBUG o.IAccountDao.findAccountByUid  - <==      Total: 0
User{userId=55, userName='mybatis annotation', userAddress='null', userSex='男', userBirthday=Tue Feb 16 22:15:36 CST 2021}
2021-02-17 03:29:23,790 966    [           main] DEBUG ansaction.jdbc.JdbcTransaction  - Resetting autocommit to true on JDBC Connection [com.mysql.jdbc.JDBC4Connection@1dd02175]
2021-02-17 03:29:23,791 967    [           main] DEBUG ansaction.jdbc.JdbcTransaction  - Closing JDBC Connection [com.mysql.jdbc.JDBC4Connection@1dd02175]
2021-02-17 03:29:23,791 967    [           main] DEBUG source.pooled.PooledDataSource  - Returned connection 500179317 to pool.
2021-02-17 03:29:23,800 976    [           main] DEBUG        com.keafmd.dao.IUserDao  - Cache Hit Ratio [com.keafmd.dao.IUserDao]: 0.5
User{userId=55, userName='mybatis annotation', userAddress='null', userSex='男', userBirthday=Tue Feb 16 22:15:36 CST 2021}
false
Process finished with exit code 0

效果很明显,开启使用二级缓存时第二次并没有发起查询,证明使用的就是二级缓存。


以上就是Mybatis注解开发(超详细)的全部内容。

相关实践学习
如何在云端创建MySQL数据库
开始实验后,系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
相关文章
|
6天前
|
SQL XML Java
mybatis复习02,简单的增删改查,@Param注解多个参数,resultType与resultMap的区别,#{}预编译参数
文章介绍了MyBatis的简单增删改查操作,包括创建数据表、实体类、配置文件、Mapper接口及其XML文件,并解释了`#{}`预编译参数和`@Param`注解的使用。同时,还涵盖了resultType与resultMap的区别,并提供了完整的代码实例和测试用例。
mybatis复习02,简单的增删改查,@Param注解多个参数,resultType与resultMap的区别,#{}预编译参数
|
20天前
|
Java 数据库连接 数据格式
【Java笔记+踩坑】Spring基础2——IOC,DI注解开发、整合Mybatis,Junit
IOC/DI配置管理DruidDataSource和properties、核心容器的创建、获取bean的方式、spring注解开发、注解开发管理第三方bean、Spring整合Mybatis和Junit
【Java笔记+踩坑】Spring基础2——IOC,DI注解开发、整合Mybatis,Junit
|
2月前
|
SQL Java 数据库
5、Mybatis-Plus 常用注解
这篇文章详细介绍了Mybatis-Plus中常用的注解,包括解决实体类与数据库表名不一致、字段不匹配的问题,主键生成策略的配置,以及逻辑删除的实现方法。
5、Mybatis-Plus 常用注解
|
2月前
|
SQL Java 数据库连接
Spring Boot联手MyBatis,打造开发利器:从入门到精通,实战教程带你飞越编程高峰!
【8月更文挑战第29天】Spring Boot与MyBatis分别是Java快速开发和持久层框架的优秀代表。本文通过整合Spring Boot与MyBatis,展示了如何在项目中添加相关依赖、配置数据源及MyBatis,并通过实战示例介绍了实体类、Mapper接口及Controller的创建过程。通过本文,你将学会如何利用这两款工具提高开发效率,实现数据的增删查改等复杂操作,为实际项目开发提供有力支持。
61 0
|
2月前
|
SQL Java 数据库连接
后端框架的学习----mybatis框架(7、使用注解开发)
这篇文章讲述了如何使用MyBatis框架的注解方式进行开发,包括在接口上使用注解定义SQL语句,并通过动态代理实现对数据库的增删改查操作,同时强调了接口需要在核心配置文件中注册绑定。
|
4月前
|
Java 数据库连接 数据库
Springboot整合mybatis注解版(202005)
Springboot整合mybatis注解版(202005)
|
4月前
|
SQL XML Java
后端数据库开发JDBC编程Mybatis之用基于XML文件的方式映射SQL语句实操
后端数据库开发JDBC编程Mybatis之用基于XML文件的方式映射SQL语句实操
62 3
|
4月前
|
Java 数据库连接 API
后端开发之用Mybatis简化JDBC的开发快速入门2024及数据库连接池技术和lombok工具详解
后端开发之用Mybatis简化JDBC的开发快速入门2024及数据库连接池技术和lombok工具详解
54 3
|
4月前
|
SQL Java 数据库连接
2万字实操案例之在Springboot框架下基于注解用Mybatis开发实现基础操作MySQL之预编译SQL主键返回增删改查
2万字实操案例之在Springboot框架下基于注解用Mybatis开发实现基础操作MySQL之预编译SQL主键返回增删改查
58 2
|
4月前
|
缓存 NoSQL Java
在 SSM 架构(Spring + SpringMVC + MyBatis)中,可以通过 Spring 的注解式缓存来实现 Redis 缓存功能
【6月更文挑战第18天】在SSM(Spring+SpringMVC+MyBatis)中集成Redis缓存,涉及以下步骤:添加Spring Boot的`spring-boot-starter-data-redis`依赖;配置Redis连接池(如JedisPoolConfig)和连接工厂;在Service层使用`@Cacheable`注解标记缓存方法,指定缓存名和键生成策略;最后,在主配置类启用缓存注解。通过这些步骤,可以利用Spring的注解实现Redis缓存。
69 2