Mybatis

作者: 笺札code | 来源:发表于2020-03-24 15:51 被阅读0次

    1、简介

    1.1、什么是Mybatis

    • MyBatis 是一款优秀的持久层框架
    • 它支持自定义 SQL、存储过程以及高级映射。
    • MyBatis 免除了几乎所有的 JDBC 代码以及设置参数和获取结果集的工作。
    • MyBatis 可以通过简单的 XML 或注解来配置和映射原始类型、接口和 Java POJO(Plain Old Java Objects,普通老式 Java 对象)为数据库中的记录。

    1.2、持久化

    持久化就是将程序的数据在持久状态和瞬时状态转化的过程

    1.3、持久层

    • 完成持久化工作的代码块
    • 层界限十分明显

    1.4、为什么需要Mybatis

    • 简化代码

    2.、第一个Mybatis程序

    14png.png

    2.1、搭建环境

    • 编写mybatis的核心配置文件

      <?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>
          <environments default="development">
              <environment id="development">
                  <transactionManager type="JDBC"/>
                  <dataSource type="POOLED">
                      <property name="driver" value="com.mysql.jdbc.Driver" />
                      <property name="url" value="jdbc:mysql://localhost:3306/mybatis?useSSL=true&amp;useUnicode=true&amp;characterEncoding=UTF-8"/>
                      <property name="username" value="root"/>
                      <property name="password" value="root"/>
                  </dataSource>
              </environment>
          </environments>
          <mappers>
              <mapper resource="com/jz/mapper/UserMapper.xml"/>
          </mappers>
      </configuration>
      
    • 编写mybatis工具类

      /**
       * mybatis工具类
       */
      public class MybatisUtils {
      
          private static SqlSessionFactory sqlSessionFactory;
          /*
              获取sqlSessionFactory对象
           */
          static{
              try {
                  String resource = "mybatis-config.xml";
                  InputStream inputStream = Resources.getResourceAsStream(resource);
                  sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
              } catch (IOException e) {
                  e.printStackTrace();
              }
          }
      
          /*
              既然有了 SqlSessionFactory,顾名思义,我们可以从中获得 SqlSession 的实例。
           */
          public  static SqlSession getSqlSession(){
              return sqlSessionFactory.openSession();
          }
      }
      

    2.2 编写代码

    • 实体类

      public class User {
      
          private int id;
          private String name;
          private String pwd;
      
          public User() {
          }
      
          public User(int id, String name, String pwd) {
              this.id = id;
              this.name = name;
              this.pwd = pwd;
          }
      
          public int getId() {
              return id;
          }
      
          public void setId(int id) {
              this.id = id;
          }
      
          public String getName() {
              return name;
          }
      
          public void setName(String name) {
              this.name = name;
          }
      
          public String getPwd() {
              return pwd;
          }
      
          public void setPwd(String pwd) {
              this.pwd = pwd;
          }
      
          @Override
          public String toString() {
              return "User{" +
                      "id=" + id +
                      ", name='" + name + '\'' +
                      ", pwd='" + pwd + '\'' +
                      '}';
          }
      }
      
    • Mapper接口

      public interface UserMapper {
      
          List<User> getUserList();
      }
      
    • 接口实现类由原来的UserDaoImpl转换为一个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">
      
      <!-- namespace绑定一个对应的Dao/Mapper接口 -->
      <mapper namespace="com.jz.mapper.UserMapper">
          <select id="getUserList" resultType="com.jz.pojo.User">
              select * from user
          </select>
      </mapper>
      

    2.3 测试

    • junit测试

      package com.jz.test;
      
      import com.jz.mapper.UserMapper;
      import com.jz.pojo.User;
      import com.jz.utils.MybatisUtils;
      import org.apache.ibatis.session.SqlSession;
      import org.junit.Test;
      
      import java.util.List;
      
      public class MapperTest {
      
          @Test
          public void test(){
              SqlSession sqlSession = MybatisUtils.getSqlSession();
              UserMapper mapper = sqlSession.getMapper(UserMapper.class);
              List<User> userList = mapper.getUserList();
              for (User user : userList) {
                  System.out.println(user);
              }
      
              sqlSession.close();
          }
      }
      

    3、CRUD

    3.1、namespace

    namespace中的报名要和接口的包名一致

    3.2、 select

    选择,查询语句

    • id:对应的namespace中的方法名
    • resultType:Sql语句执行的返回值
    • parameterType:参数类型
    1. 编写接口

       /**
           * 根据id查询用户
           * @return
           */
          User getUserById(int id);
      
    2. 编写对应的mapper中的sql语句

           <!-- 根据id查询用户 -->
          <select id="getUserById" parameterType="int" resultType="com.jz.pojo.User">
              select * from user where id = #{id}
          </select>
      
    3. 测试

      /**
       * 根据id查询用户
       */
      @Test
      public void getUserById(){
          SqlSession sqlSession = MybatisUtils.getSqlSession();
          UserMapper mapper = sqlSession.getMapper(UserMapper.class);
          User user = mapper.getUserById(1);
          System.out.println(user);
      
          sqlSession.close();
      }
      

    3.3、insert

    <!-- 添加用户 -->
    <insert id="addUser" parameterType="com.jz.pojo.User">
        insert into user (id, name, pwd) values (#{id}, #{name}, #{pwd})
    </insert>
    

    3.4、update

    <!-- 修改用户 -->
    <update id="updateUser" parameterType="com.jz.pojo.User">
        update user set name = #{name}, pwd = #{pwd} where id = #{id}
    </update>
    

    3.5、delete

    <!-- 删除用户 -->
    <delete id="deleteUser" parameterType="int">
        delete from user where id = #{id}
    </delete>
    

    注意点:

    • 增删改需要提交事务

    3.6、万能Map

    假设,我们的实体类,或者数据库中的表,字段或者参数过多,可以使用Map!

    void addUser2(Map<String, Object> map);
    
    <!-- 添加用户 -->
    <insert id="addUser2" parameterType="map">
        insert into user (id, name, pwd) values (#{userId}, #{userName}, #{userPwd})
    </insert>
    
    /**
     * 添加用户
     */
    @Test
    public void addUser2(){
        SqlSession sqlSession = MybatisUtils.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        Map<String, Object> map = new HashMap<String, Object>();
        map.put("userId", null);
        map.put("userName", "笺札");
        map.put("userPwd", "admin");
        mapper.addUser2(map);
    
        sqlSession.commit();
        sqlSession.close();
    }
    

    Map传递参数,直接在sql中取出key即可! 【parameterType="map"】

    对象传递参数,直接在sql中取对象的属性即可! 【parameterType="Object"】

    只有一个基本类型参数的情况下, 可以直接在sql中取到! paramterType可以省略不写

    多个参数用Map,或者注解!

    3.7、模糊查询

    1. 在java代码执行时候,传递通配符 %%

      List<User> users = mapper.getUserLike("%李%");
      
    2. 在sql拼接中使用通配符!(不安全 sql注入)

      <!--模糊查询-->
      <select id="getUserLike" parameterType="String" resultType="com.jz.pojo.User" >
          select * from user where name like "%"#{name}"%"
      </select>
      

    4、配置解析

    4.1、核心配置文件

    1.png

    4.2、环境配置(environments)

    MyBatis 可以配置成适应多种环境

    尽管可以配置多个环境,但每个 SqlSessionFactory 实例只能选择一种环境。

    Mybatis默认的事务管理器就是JDBC, 连接池:POOLED

    4.3、属性(properties)

    这些属性可以在外部进行配置,并可以进行动态替换。你既可以在典型的 Java 属性文件中配置这些属性,也可以在 properties 元素的子元素中设置。 【db.properties】

    编写一个配置文件

    db.properties

    driver = com.mysql.jdbc.Driver
    url = jdbc:mysql://localhost:3306/mybatis?useSSL=true&useUnicode=true&characterEncoding=UTF-8
    

    在核心配置文件中映入

    <!-- 引入外部配置文件 -->
    <properties resource="db.properties">
        <property name="username" value="root"/>
        <property name="password" value="root"/>
    </properties>
    
    <environments default="development">
        <environment id="development">
            <transactionManager type="JDBC"/>
            <dataSource type="POOLED">
                <property name="driver" value="${driver}" />
                <property name="url" value="${url}"/>
                <property name="username" value="${username}"/>
                <property name="password" value="${password}"/>
            </dataSource>
        </environment>
    </environments>
    
    • 可以直接引入外部文件
    • 可以在其中增加一些属性配置
    • 如果两个文件有同一个字段,优先使用外部配置文件的

    4.4、类型别名(typeAliases)

    • 类型别名可为 Java 类型设置一个缩写名字
    • 仅用于 XML 配置,意在降低冗余的全限定类名书写
    <!-- 给实体类起别名 -->
    <typeAliases>
        <typeAlias type="com.jz.pojo.User" alias="User" />
    </typeAliases>
    

    可以指定一个包名,MyBatis 会在包名下面搜索需要的 Java Bean

    扫描实体类的包,它的默认别名就为这个类的 类名,首字母小写

    <!-- 给实体类起别名 -->
    <typeAliases>
        <package name="com.jz.pojo"/>
    </typeAliases>
    

    在实体类比较少的时候,使用第一种方式。

    如果一个包中实体类十分多,使用第二种方式

    第一种可以自定义别名,第二种 则不行,因为默认为 类名首字母小写, 如果非要改,需要在实体类上增加注解

    @Alias("user")
    public class User {}
    

    4.5、设置(settings)

    2.png 3.png 4.png

    4.6、映射器(mappers)

    方式一:使用相对于类路径的资源引用 【推荐使用】

    <!-- 每一个Mapper.xml都需要在Mybatis核心配置文件中注册! -->
    <mappers>
        <mapper resource="com/jz/mapper/UserMapper.xml"/>
    </mappers>
    

    方式二:使用class文件绑定注入 映射器接口实现类的完全限定类名

    <!-- 每一个Mapper.xml都需要在Mybatis核心配置文件中注册! -->
    <mappers>
        <mapper class="com.jz.mapper.UserMapper"/>
    </mappers>
    

    使用方式二:

    • 接口和它的Mapper配置文件必须同名
    • 接口和它的Mapper配置文件在 同一个包下 或 resources中目录结构一样

    方式三:使用扫描包进行注入绑定 将包内的映射器接口实现全部注册为映射器

    <!-- 每一个Mapper.xml都需要在Mybatis核心配置文件中注册! -->
    <mappers>
        <package name="com.jz.mapper"/>
    </mappers>
    
    • 接口和它的Mapper配置文件必须同名
    • 接口和它的Mapper配置文件在 同一个包下 或 resources中目录结构一样

    4.7、作用域(Scope)和声明周期

    不同作用域和生命周期类别是至关重要的,因为错误的使用会导致非常严重的并发问题

    流程

    5.jpg

    SqlSessionFactoryBuilder

    • 一旦创建了 SqlSessionFactory,就不再需要它了
    • 局部变量

    SqlSessionFactory

    • 可以想象成:数据库连接池
    • 一旦被创建就应该在应用的运行期间一直存在没有任何理由丢弃它或重新创建另一个实例。
    • SqlSessionFactory 的最佳作用域是应用作用域
    • 使用单例模式或者静态单例模式。

    SqlSession

    • 连接到连接池的一个请求!
    • SqlSession 的实例不是线程安全的,因此是不能被共享的,所以它的最佳的作用域是请求或方法作用域。
    • 用完之后需要赶紧关闭,否则资源被占用。
    6.png

    这里面每一个Mapper,就代表一个具体的业务。

    5、解决属性名和字段名不一致的问题

    5.1、问题

    当实体类中的成员变量与数据库中的字段名不同时

    7.png

    同名id查询用户时

    <select id="getUserById" parameterType="int" resultType="User">
        select * from user where id = #{id}
    </select>
    
    8.png

    解决方法:

    • 起别名, 修改SQL语句,查询时给字段起别名
    <select id="getUserById" parameterType="int" resultType="User">
        select id, name, pwd as password from user where id = #{id}
    </select>
    
    9.png

    5.2、ResultMap

    结果集映射

    <!-- 结果集映射 -->
    <resultMap id="UserMap" type="User">
        <!-- column数据库中的字段,property实体类中的属性 -->
        <result column="id" property="id"/>
        <result column="name" property="name"/>
        <result column="pwd" property="password"/>
    </resultMap>
    
    <select id="getUserById" parameterType="int" resultMap="UserMap">
        select * from user where id = #{id}
    </select>
    
    • resultMap 元素是 MyBatis 中最重要最强大的元素。

    • ResultMap 的设计思想是,对简单的语句做到零配置,对于复杂一点的语句,只需要描述语句之间的关系就行了。

    • ResultMap 的优秀之处——你完全可以不用显式地配置它们。

      <!-- 结果集映射 -->
      <resultMap id="UserMap" type="User">
          <!-- column数据库中的字段,property实体类中的属性 -->
          <!-- 如果 字段和属性名相同则可以不写
              <result column="id" property="id"/>
              <result column="name" property="name"/>
        -->
          <result column="pwd" property="password"/>
      </resultMap>
      
      <select id="getUserById" parameterType="int" resultMap="UserMap">
          select * from user where id = #{id}
      </select>
      

    6、日志

    6.1、日志工厂

    曾经:sout、debug

    现在:日志工厂

    3.png
    • SLF4J
    • LOG4J
    • LOG4J2
    • JDK_LOGGING :Java自带的日志
    • COMMONS_LOGGING :工具包
    • STDOUT_LOGGING :控制台输出
    • NO_LOGGING:没有输出

    在Mybatis中具体使用那个日志实现,在设置中设定!

    STDOUT_LOGGING 标准日志输出

    在mybatis核心配置文件中配置

    <!-- 设置 -->
    <settings>
        <!-- 标准的日志工厂实现 -->
        <setting name="logImpl" value="STDOUT_LOGGING"/>
    </settings>
    
    10.png

    6.2、Log4j

    简介:

    • Log4j是Apache的一个开源项目,通过使用Log4j,我们可以控制日志信息输送的目的地是控制台、文件、GUI组件。
    • 我们也可以控制每一条日志的输出格式
    • 通过定义每一条日志信息的级别,我们能够更加细致地控制日志的生成过程
    • 可以通过一个配置文件来灵活地进行配置,而不需要修改应用的代码。
    1. 先到入log4j的包

      <dependency>
          <groupId>log4j</groupId>
          <artifactId>log4j</artifactId>
          <version>1.2.17</version>
      </dependency>
      
    2. log4j.properites

      #将等级为DEBUG的日志信息输出到console和file这两个目的地,console和file的定义在下面的代码
      log4j.rootLogger=DEBUG,console,file
      
      #控制台输出的相关设置
      log4j.appender.console = org.apache.log4j.ConsoleAppender
      log4j.appender.console.Target = System.out
      log4j.appender.console.Threshold=DEBUG
      log4j.appender.console.layout = org.apache.log4j.PatternLayout
      log4j.appender.console.layout.ConversionPattern=[%c]-%m%n
      
      #文件输出的相关设置
      log4j.appender.file = org.apache.log4j.RollingFileAppender
      log4j.appender.file.File=./log/jz.log
      log4j.appender.file.MaxFileSize=10mb
      log4j.appender.file.Threshold=DEBUG
      log4j.appender.file.layout=org.apache.log4j.PatternLayout
      log4j.appender.file.layout.ConversionPattern=[%p][%d{yy-MM-dd}][%c]%m%n
      
      #日志输出级别
      log4j.logger.org.mybatis=DEBUG
      log4j.logger.java.sql=DEBUG
      log4j.logger.java.sql.Statement=DEBUG
      log4j.logger.java.sql.ResultSet=DEBUG
      log4j.logger.java.sql.PreparedStatement=DEBUG
      
    3. 配置Log4j为日志的实现

      <settings>
          <setting name="logImpl" value="LOG4J"/>
      </settings>
      
    4. Log4j的使用

    11.png

    简单使用:

    1. 在要使用Log4j的类中,导入包import org.apache.log4j.Logger;

    2. 日志对象,参数为当前类的class

      static Logger logger = Logger.getLogger(UserMapperTest.class);
      
    3. 日志级别

      logger.info("info:进入了testLog4j");
      logger.debug("debug:进入了testLog4j");
      logger.error("error:进入了testLog4j");
      

    7、分页

    为什么使用分页

    • 减少数据的处理量

    7.1、使用Limit分页

    语法:SELECT * FROM USER LIMIT startIndex, pageSize;
    SELECT * FROM USER LIMIT 3; #相当于[0, 3]
    

    使用Mybatis实现分页 Limit

    1. 接口

      /**
       * 分页查询
       * @param map
       * @return
       */
      List<User> getUserByLimit(Map<String, Integer> map);
      
    2. Mapper.xml

      <resultMap id="UserMap2" type="User">
          <result column="pwd" property="password"></result>
      </resultMap>
      <select id="getUserByLimit" parameterType="map" resultMap="UserMap2">
          select * from user limit #{startIndex},#{pageSize}
      </select>
      
    3. 测试

      /**
       * 分页查询
       */
      @Test
      public void getUserByLimit(){
          SqlSession sqlSession = MybatisUtils.getSqlSession();
          UserMapper mapper = sqlSession.getMapper(UserMapper.class);
          Map<String, Integer> map = new HashMap<String, Integer>();
          map.put("startIndex", 0);
          map.put("pageSize", 2);
          List<User> users = mapper.getUserByLimit(map);
          for (User user : users) {
              System.out.println(user);
          }
      }
      

    7.2、RowBounds分页

    不再使用SQL实现分页

    1. 接口

      List<User> getUserByRowBounds();
      
    2. mapper.xml

      <select id="getUserByRowBounds" resultMap="UserMap">
          select * from user
      </select>
      
    3. 测试

      @Test
      public void getUserByRowBounds(){
          SqlSession sqlSession = MybatisUtils.getSqlSession();
          RowBounds rowBounds = new RowBounds(1, 2);
          List<User> users = sqlSession.selectList("com.jz.mapper.UserMapper.getUserByRowBounds", null, rowBounds);
          for (User user : users) {
              System.out.println(user);
          }
          sqlSession.close();
      }
      

    7.3、分页插件

    MyBatis 分页插件 PageHelper

    8、使用注解开发

    8.1、面向接口编程

    根本原因:解耦, 可拓展, 提高复用, 分层开发中, 上层不用管具体的实现, 大家都遵守共同的标准,使得开发变得容易,规范性更好。

    8.2、使用注解开发

    底层使用反射技术

    1. 注解在接口上实现

      /**
       * 查询所有用户
       * @return
       */
      @Select("select * from user")
      List<User> getUsers();
      
    2. 需要在mybatis核心配置文件中绑定接口

      <mappers>
          <mapper class="com.jz.mapper.UserMapper"/>
      </mappers>
      
    3. 测试使用

      @Test
      public void getUsers(){
          SqlSession sqlSession = MybatisUtils.getSqlSession();
          UserMapper mapper = sqlSession.getMapper(UserMapper.class);
          List<User> users = mapper.getUsers();
          for (User user : users) {
              System.out.println(user);
          }
          sqlSession.close();
      }
      

    本质:反射机制实现

    底层:动态代理

    动态代理:

    12.png

    Mybatis执行流程:

    13.jpg

    8.3、CRUD

    可以在工具类创建的时候实现自动提交事务

    public static SqlSession getSqlSession(){
    
        return sqlSessionFactory.openSession(true); // true:允许自动提交事务
    }
    

    编写接口,添加注解

    /**
     * 查询所有用户
     * @return
     */
    @Select("select * from user")
    List<User> getUsers();
    
    /**
     * 通过id查询用户
     * @param id
     * @return
     */
    // 方法存在多个参数,所有参数前面必须使用 @Param("id")注解
    @Select("select * from user where id = #{aaa}")
    User getUserById(@Param("aaa") int id);
    
    /**
     * 添加用户
     * @param user
     */
    // #{password} 是因为实体类中属性名叫 password
    @Insert("insert into user values(#{id}, #{name}, #{password})")
    void addUser(User user);
    
    /**
     * 修改用户
     * @param user
     */
    @Update("update user set name = #{name}, pwd = #{password} where id = #{id}")
    void updateUser(User user);
    
    /**
     * 删除用户
     * @param id
     */
    @Delete("delete from user where id = #{uid}")
    void deleteUser(@Param("uid") int id);
    

    测试类

    @Test
    public void getUsers(){
        SqlSession sqlSession = MybatisUtils.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        /*List<User> users = mapper.getUsers();
        for (User user : users) {
            System.out.println(user);
        }*/
    
        /*User user = mapper.getUserById(1);
        System.out.println(user);*/
    
        /*User user = new User("菲菲", "admin");
        mapper.addUser(user);*/
    
        /*User user = new User(14, "嘿嘿嘿", "admin");
        mapper.updateUser(user);*/
    
        mapper.deleteUser(16);
        sqlSession.close();
    }
    

    注意:一定要将接口注册绑定到核心配置文件中

    <mappers>
        <mapper class="com.jz.mapper.UserMapper"/>
    </mappers>
    

    关于@Param()注解

    • 如果参数有多个必须要给没个参数加上
    • 如果参数是对象,就不用加
    • 如果就一个参数,也可以不加,但最好加上
    • 我们在SQL中引用的就是这里的@Param()中设定的属性名

    9、Lombok

    使用步骤:

    1. 在IDEA中安装Lombok插件

    2. 在项目中导入Lombok的jar包

      <!-- https://mvnrepository.com/artifact/org.projectlombok/lombok -->
      <dependency>
          <groupId>org.projectlombok</groupId>
          <artifactId>lombok</artifactId>
          <version>1.18.12</version>
          <scope>provided</scope>
      </dependency>
      
    3. 在实体类上加注解即可

      @Data // 无参构造、get、set、toString、hashCode、equals
      @AllArgsConstructor // 有参构造方法
      @NoArgsConstructor // 无参构造
      @EqualsAndHashCode // 重写equals 和 hashCode
      @ToString // 重写toString
      @Setter // setter
      @Getter // getter
      public class User {
      
          private int id;
          private String name;
          private String password;
      }
      

    10、多对一处理

    多对一:

    • 多个学生,对应一个老师
    • 对于学生而言,关联 多个学生,关联一个老师 【多对一】
    • 对于老师而言,集合 一个老师,有很多学生 【一对多】
    13.png

    SQL:

    CREATE TABLE teacher(
    id INT(10) NOT NULL,
    NAME VARCHAR(30) DEFAULT NULL,
    PRIMARY KEY(id)
    )ENGINE = INNODB DEFAULT CHARSET=utf8;
    
    
    INSERT INTO teacher VALUES(1, '秦老师');
    
    CREATE TABLE student(
    id INT(10) NOT NULL,
    NAME VARCHAR(30) DEFAULT NULL,
    tid INT(10) DEFAULT NULL,
    PRIMARY KEY (id),
    FOREIGN KEY (tid) REFERENCES teacher(id)
    )ENGINE = INNODB DEFAULT CHARSET = utf8;
    
    
    INSERT INTO student(id, NAME,tid) VALUES 
    ('1', '小明','1'),
    ('2', '小红','1'),
    ('3', '小张','1'),
    ('4', '小李','1'),
    ('5', '小王','1');
    

    测试环境搭建

    1. 导入Lombok
    2. 新建实体类 Teacher , Student
    3. 建立Mapper接口
    4. 建立Mapper.xml文件
    5. 在核心配置文件中绑定注册我们的Mapper接口或者文件
    6. 测试查询是否能够成功

    实体类

    public class Student {
    
        private int id;
        private String name;
    
        // 学生需要关联老师
        private Teacher teacher;
    }
    
    public class Teacher {
        private int id;
        private String name;
    }
    

    按照查询嵌套处理

    子查询

    <mapper namespace="com.jz.mapper.StudentMapper">
    
        <!--
            如果只写getStudents这一个方法,那么将查询不到Teacher类的信息
            解决思路:
                1.查询所有的学生信息
                2.根据查询出来的学生的tid,寻找对应的老师!  子查询
        -->
    
        <select id="getStudents" resultMap="StudentTeacher">
            select * from student
        </select>
    
        <resultMap id="StudentTeacher" type="Student">
            <id property="id" column="id"/>
            <result property="name" column="name"/>
            <!--
                复杂的属性,需要单独处理
                对象:association
                集合:collection
    
                javaType: property参数的类型
            -->
            <association property="teacher" column="tid" javaType="Teacher" select="getTeachers"/>
        </resultMap>
    
        <select id="getTeachers" resultType="Teacher">
            select * from teacher where id = #{id}
        </select>
    </mapper>
    

    按照结果嵌套处理

    联表查询

    <!-- 按照结果嵌套处理 -->
    <select id="getStudents2" resultMap="StudentTeacher2">
        SELECT s.id sid, s.name sname, t.name tname, t.id tid FROM student s, teacher t WHERE s.tid = t.id
    </select>
    
    <resultMap id="StudentTeacher2" type="Student">
        <id property="id" column="sid" />
        <result property="name" column="sname"/>
        <association property="teacher" javaType="Teacher">
            <id property="id" column="tid" />
            <result property="name" column="tname" />
        </association>
    </resultMap>
    

    Mysql多对一查询方式:

    • 子查询
    • 联表查询

    11、一对多处理

    比如:一个老师拥有多个学生!

    对于老师而言,就是一对多的关系!

    环境搭建

    1. 环境搭建,和刚才一样

    实体类

    public class Student {
        private int id;
        private String name;
        private int tid;
    }
    
    public class Teacher {
        private int id;
        private String name;
        // 一个老师可以拥有很多学生
        private List<Student> students;
    }
    

    按照查询嵌套处理

    <select id="getTeacherById2" resultMap="TeacherStudent2">
        select * from teacher
    </select>
    
    <resultMap id="TeacherStudent2" type="Teacher">
        <id property="id" column="id" />
        <result property="name" column="name" />
        <collection property="students" javaType="ArrayList" ofType="Student" select="getStudentByTeacherId" column="id"/>
    </resultMap>
    
    <select id="getStudentByTeacherId" resultType="Student">
        select * from student where tid = #{tid}
    </select>
    

    按照结果嵌套处理

    <!-- 按结果嵌套查询 -->
    <select id="getTeacherById" resultMap="TeacherStudent">
        select s.id sid, s.name sname,  t.id tid, t.name tname
        from student s, teacher t
        where s.tid = t.id and t.id = #{tid}
    </select>
    
    <resultMap id="TeacherStudent" type="Teacher">
        <id property="id" column="tid"/>
        <result property="name" column="tname"/>
        <!--
            复杂的属性,需要单独处理 对象:association  集合:collection
            javaType="" 指定属性的类型
            集合中的泛型信息,需要使用ofType获取
        -->
        <collection property="students" ofType="Student">
            <id property="id" column="sid"/>
            <result property="name" column="sname" />
            <result property="tid" column="tid"/>
        </collection>
    </resultMap>
    

    小结

    1. 关联 - association 【多对一】
    2. 集合 - collection 【一对多】
    3. javaType & ofType
      • javaType:用来指定实体类中属性的类型
      • ofType:用来指定映射到List或者集合的 pojo 类型,泛型中的约束类型

    注意点:

    • 保证SQL的可读性,尽量保证通俗易懂
    • 注意一对多和多对一中,属性名和字段的问题!
    • 如果问题不好排查错误,可以使用日志,建议使用 Log4j

    12、动态SQL

    ==动态SQL就是指根据不同的条件生成不同的SQL语句==

    搭建环境

    CREATE TABLE blog(
        id VARCHAR(50) NOT NULL COMMENT '博客id',
        title VARCHAR(100) NOT NULL COMMENT '博客标题',
        author VARCHAR(30) NOT NULL COMMENT '博客作者',
        create_time DATETIME NOT NULL COMMENT '创建时间',
        views INT(30) NOT NULL COMMENT '浏览量'
    ) ENGINE = INNODB DEFAULT CHARSET = utf8;
    

    创建一个基础工程

    1. 导包

    2. 编写配置文件

    3. 编写实体类

      @Data
      public class Blog {
          private String id;
          private String title;
          private String author;
          private Date createTime;
          private int views;
      }
      
    4. 编写实体类对一个Mapper接口 和 Mapper.xml文件

    IF

    <select id="queryBlogIF" parameterType="map" resultType="blog">
        select * from blog
        <where>
            <if test="title != null">
                title = #{title}
            </if>
            <if test="author != null">
                and author = #{author}
            </if>
        </where>
    </select>
    

    choose(when、otherwise)

    相当于Java中Switch语句

    <select id="queryBlogChoose" parameterType="map" resultType="blog">
        select * from blog
        <where>
            <choose>
                <when test="title != null">
                    title = #{title}
                </when>
                <when test="author != null">
                    and author = #{author}
                </when>
                <otherwise>
                    and views = #{views}
                </otherwise>
            </choose>
        </where>
    </select>
    

    trim(where、set)

    trim 表示可以自定义 mybatis官网

    where 元素只会在子元素返回任何内容的情况下才插入 “WHERE” 子句。而且,若子句的开头为 “AND” 或 “OR”,where 元素也会将它们去除。

    <select id="queryBlogIF" parameterType="map" resultType="blog">
        select * from blog
        <where>
            <if test="title != null">
                title = #{title}
            </if>
            <if test="author != null">
                and author = #{author}
            </if>
        </where>
    </select>
    

    set 元素会动态地在行首插入 SET 关键字,并会删掉额外的逗号(这些逗号是在使用条件语句给列赋值时引入的)。

    <update id="updateBlog" parameterType="map">
        update blog
        <set>
            <if test="title != null">
                title = #{title},
            </if>
            <if test="author != null">
                author = #{author}
            </if>
        </set>
        where id = #{id}
    </update>
    

    所谓的动态SQL,本质还是SQL语句,只是我们可以在SQL层面,去执行一个逻辑代码

    SQL片段

    有的时候,可能将一些功能的部分抽取出来,方便复用!

    1. 使用SQL标签抽取公共部分代码

      <sql id="if-title-author">
          <if test="title != null">
              title = #{title}
          </if>
          <if test="author != null">
              and author = #{author}
          </if>
      </sql>
      
    2. 在需要使用的地方使用Include标签引用即可

      <select id="queryBlogIF" parameterType="map" resultType="blog">
          select * from blog
          <where>
              <include refid="if-title-author"></include>
          </where>
      </select>
      

    注意事项:

    • 最好基于单表定义SQL片段
    • 在抽取的公共代码部分,不要包含where标签

    Foreach

    <select id="queryBlogForeach" parameterType="map" resultType="blog">
        select * from blog
        <where>
            <if test="id != null">
                id in
                <foreach collection="ids" item="id" separator="," open="(" close=")">
                    #{id}
                </foreach>
            </if>
        </where>
    </select>
    

    ==动态SQL就是在拼接SQL语句,我们只要保证SQL的正确性,按照SQL的格式,去排列组合就可以了!==

    13、缓存

    13.1、简介

    1. 什么是缓存
      • 解决高并发系统的问题
      • 存在内存中的临时数据
    2. 为什么使用缓存
      • 减少和数据库的交互次数,减少系统开销,提高系统效率
    3. 什么样的数据能使用缓存
      • 经常查询并且不经常改变的数据

    13.2、Mybatis缓存

    • Mybatis包含一个非常强大的查询缓存特性
    • Mybatis系统中默认定义了两级缓存:一级缓存二级缓存
      • 默认情况下, 只有一级缓存开启。(SqlSession级别的缓存,也称为本地缓存)
      • 二级缓存需要手动开启和配置,他是基于namespace级别的缓存
      • 为了提高扩展性,Mybatis定义了缓存接口Cache。我们可以通过实现Cache接口来自定义二级缓存。

    13.3、一级缓存

    • 一级缓存也叫本地缓存: SqlSession

      • 与数据库同一次会话期间查询到的数据会放在本地缓存中
      • 以后如果需要获取相同的数据,直接从缓存中拿,没必要再去查询数据库

    测试:

    1. 开启日志
    2. 测试在一个SqlSession中查询两次相同记录
    3. 查看日志输出
    @Test
    public void queryUserById(){
        SqlSession sqlSession = MybatisUtils.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
    
        User user = mapper.queryUserById(1);
        System.out.println(user);
    
        System.out.println("============");
    
        User user2 = mapper.queryUserById(1);
        System.out.println(user2);
    
        System.out.println(user == user2);
    
        sqlSession.close();
    }
    
    15.png
    • 映射语句文件中的所有 select 语句的结果将会被缓存。
    • 映射语句文件中的所有 insert、update 和 delete 语句会刷新缓存。
    • 缓存会使用最近最少使用算法(LRU, Least Recently Used)算法来清除不需要的缓存。
    • 缓存不会定时进行刷新(也就是说,没有刷新间隔)。
    • 缓存会保存列表或对象(无论查询方法返回哪种)的 1024 个引用。
    • 缓存会被视为读/写缓存,这意味着获取到的对象并不是共享的,可以安全地被调用者修改,而不干扰其他调用者或线程所做的潜在修改。

    缓存失效的情况:

    1. 两次查询不一样的记录

    2. insert、update 和 delete 语句会刷新缓存

    3. 查询不同的Mapper.xml

    4. 手动清理缓存

      sqlSession.clearCache();

    小结:一级缓存默认是开启的,只有一次SqlSession中有效,也就是拿到连接到关闭连接这个区间段。

    13.4、二级缓存

    • 二级缓存也叫全局缓存,一级缓存作用域太低,所以诞生了二级缓存
    • 基于namespace级别的缓存,一个名称空间,对应一个二级缓存
    • 工作机制
      • 一个会话查询一条数据,这个数据就会被放在当前会话的一级缓存中
      • 如果当前会话关闭了,这个会话对应的一级缓存就没了;但如果开启了二级缓存,当会话关闭时,一级缓存中的数据会被保存到二级缓存中。
      • 新的会话查询信息,会从二级缓存中查询
      • 不同的mapper查出的数据会放在自己对应的缓存(map)中

    步骤:

    1. 开启全局缓存
    16.png
    <!--开启全局缓存-->
    <setting name="cacheEnabled" value="true"/>
    
    1. 在要使用二级缓存的Mapper中开启

      <!--在当前Mapper中开启二级缓存-->
      <cache/>
      

      也可以自定义二级缓存

      <cache
        eviction="FIFO"
        flushInterval="60000"
        size="512"
        readOnly="true"/>
      
    2. 测试

      @Test
      public void queryUserById(){
          SqlSession sqlSession = MybatisUtils.getSqlSession();
          SqlSession sqlSession2 = MybatisUtils.getSqlSession();
      
          UserMapper mapper = sqlSession.getMapper(UserMapper.class);
          User user = mapper.queryUserById(1);
          System.out.println(user);
          sqlSession.close();
      
          UserMapper mapper2 = sqlSession2.getMapper(UserMapper.class);
          User user2 = mapper2.queryUserById(1);
          System.out.println(user2);
          sqlSession2.close();
      }
      
    17.png

    小结:

    • 只要开启了二级缓存,在同一个Mapper下就有效
    • 所有的数据都会先放到一级缓存中
    • 只有当会话提交,或者关闭时,才会提交到二级缓存中

    13.5、缓存原理

    缓存顺序:

    1. 先看二级缓存中有没有
    2. 如果二级缓存没有,再看一级缓存中有没有
    3. 如果一级缓存中也没有,就去数据库里查询

    13.6、自定义缓存-ehcache

    Ehcache是开源Java分布式缓存

    <cache type="com.domain.something.MyCustomCache"/>
    

    相关文章

      网友评论

          本文标题:Mybatis

          本文链接:https://www.haomeiwen.com/subject/etnoyhtx.html