IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> 大数据 -> Mybatis进阶 -> 正文阅读

[大数据]Mybatis进阶

1.配置解析

1.1核心配置文件

mybatis-config.xml,有固定顺序如下:

configuration(配置)

  • properties(属性)
  • settings(设置)
  • typeAliases(类型别名)
  • typeHandlers(类型处理器)
  • objectFactory(对象工厂)
  • plugins(插件)
  • environments(环境配置)
    • environment(环境变量)
      • transactionManager(事务管理器)
      • dataSource(数据源)
  • databaseIdProvider(数据库厂商标识)
  • mappers(映射器)

?

1.2环境配置(environments)

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

?

1.environments 元素定义了如何配置环境:
在这里插入图片描述

注意一些关键点:

  • 默认使用的环境 ID(比如:default=“development”)。
  • 每个 environment 元素定义的环境 ID(比如:id=“development”)。
  • 事务管理器的配置(比如:type=“JDBC”)。
  • 数据源的配置(比如:type=“POOLED”)。

默认环境和环境 ID 顾名思义。 环境可以随意命名,但务必保证默认的环境 ID 要匹配其中一个环境 ID。

?
2.事务管理器(transactionManager)

在 MyBatis 中有两种类型的事务管理器(也就是 type=“JDBC|MANAGED”):

  • JDBC – 这个配置直接使用了 JDBC 的提交和回滚设施。

  • MANAGED – 这个配置几乎没做什么。默认情况下它会关闭连接,但一些容器并不希望连接被关闭,因此需要

    <transactionManager type="MANAGED">
      <property name="closeConnection" value="false"/>
    </transactionManager>
    

3.数据源(dataSource)

  • 用来连接数据库,dbcp、c3p0、druid,池即用完可以回收的。

  • 有三种内建的数据源类型(也就是 type=“UNPOOLED|POOLED|JNDI”)

?

1.3属性(properties)

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

  • 编写一个配置文件db.properties:

    driver=com.mysql.cj.jdbc.Driver
    url=jdbc:mysql://localhost:3306/mybatis?useSSL=true&useUnicode=true&characterEncoding=UTF-8&serverTimezone=CTT
    username=root
    password=1234
    

    然后用properties引用到核心配置文件mybatis-config.xml中:

    <!--引入外部配置文件-->
    <properties resource="db.properties">
      <property name="username" value="root"/>
      <property name="password" value="1234"/>
    </properties>
    
  • 通过方法参数传递的属性具有最高优先级,resource/url 属性中指定的配置文件次之,最低优先级的则是 properties 元素中指定的属性。

?

1.4类型别名(typeAliases)

  • 为 Java 类型设置一个缩写名字,可降低冗余的全限定类名书写
<!--可以给实体类起别名-->
<typeAliases>
    <typeAlias type="moli.pojo.User" alias="User"/>
</typeAliases>
  • 也可以指定一个包名,MyBatis 会在包名下面搜索需要的 Java Bean,使用 Bean 的首字母小写类名来作为它的别名。

    <!--可以给实体类起别名-->
    <typeAliases>
        <package name="moli.pojo"/>
    </typeAliases>
    
  • 如果在实体类比较少的时候可以使用第一种,实体类比较多那就用第二种

  • 区别:第一种可以DIY别名,第二种不可以,如果非要改可以在实体类上增加注解
    在这里插入图片描述

?

1.5设置(settings)

这是 MyBatis 中极为重要的调整设置,它们会改变 MyBatis 的运行时行为。

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

?

1.6插件(plugins)

在这里插入图片描述

  • plus---->mybatis的简化版
  • 通用mapper

?

1.7映射器(mappers)

方式一:推荐使用,没有注意点

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

方式二:用class文件绑定注册

<mappers>
  <mapper class="moli.dao.UserMapper "/>
</mappers>

方式三:使用扫面包进行注入绑定

<mappers>
  <package name="moli.dao"/>
</mappers>

使用包注册和class注意点:

  • 接口和他的mapper配置文件必须同名
  • 接口和他的mapper配置文件必须在同一个包下

?

1.8生命周期和作用域

在这里插入图片描述

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

SqlSessionFactoryBuilder

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

SqlSessionFactory

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

SqlSession

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

在这里插入图片描述

这里的每一个Mapper就相当于一个业务。

?
?

2.解决属性名和字段名不一致的问题

2.1问题

数据库中的字段:

在这里插入图片描述

实体类中的属性名:

public class User {
    private int id;
    private String name;
    private String password;
}
select * from mybatis.user where id = #{id}
<!--类型处理器-->
select id,name,pwd from mybatis.uer where id = #{id}

出现问题:
查询出来的结果密码为null

?

2.2解决

1.起别名

select id,name,pwd as password from mybatis.user where id = #{id}

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>
<!--原来的resultType="user"-->
<select id="getUserById" resultMap="userMap">
    select * from mybatis.user where id = #{id}
</select>

注意点:

  • resultMap 元素是 MyBatis 中最重要最强大的元素

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

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

  • 然后在引用它的语句中设置 resultMap 属性就行了(注意我们去掉了 resultType 属性)

?
?

3.日志

3.1日志工厂

如果一个数据库操作,出现了异常,我们就需要排错,日志就是最好的助手!

  • 曾经:sout,debug

  • 现在:日志工厂:在MyBatis 中具体使用哪一个日志实现,在设置(setting)中设定,未指定时将自动查找。

    • SLF4J
    • LOG4
    • LOG4J2
    • JDK_LOGGING
    • COMMONS_LOGGING
    • STDOUT_LOGGING √ 标准日志输出
    • NO_LOGGING

?

在mybatis核心配置文件中配置我们的日志:

<settings>
    <setting name="logImpl" value="STDOUT_LOGGING"/>
</settings>

在这里插入图片描述

若是要设置其它日志,需要导包;报错要检查是否空格、类名、包名等问题。

?

3.2LOG4J

  • Log4j是Apache的一个开源项目,通过使用Log4j,我们可以控制日志信息输送的目的地是控制台、文件、GUI组件

  • 我们也可以控制每一条日志的输出格式

    在这里插入图片描述

  • 通过定义每一条日志信息的级别,我们能够更加细致地控制日志的生成过程

  • 这些可以通过一个配置文件来灵活地进行配置,而不需要修改应用的代码

?

3.2.1导包

<!-- https://mvnrepository.com/artifact/log4j/log4j -->
<dependency>
	<groupId>log4j</groupId>
    <artifactId>log4j</artifactId>
	<version>1.2.17</version>
</dependency>

?

3.2.2log4j.properties

#将等级为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/moli.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.2.3配置log4j为日志的实现

<settings>
    <setting name="logImpl" value="LOG4J"/>
</settings>

?

3.2.4简单使用

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

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

```java
static Logger logger = Logger.getLogger(UserMapper.class);
```

3.级别

@Test
public void log4jTest(){
    logger.info("info:进入了log4jTest");
    logger.debug("debug:进入了log4jTest");
    logger.error("error:进入了log4jTest");
}

在这里插入图片描述

以后就使用日志就可以,相当于替代了sout。

?
?

4.分页

  • 减少数据的处理量

  • 回顾

    select * from user limit 0,2;
    

4.1limit分页

1.接口

public interface UserMapper {
    //分页
    List<User> getUserByLimit(Map<String,Integer> map);
}

2.Mapper.xml

<select id="getUserByLimit" parameterType="map" resultMap="userMap">
    select * from mybatis.user limit #{startIndex},#{pageSize}
</select>

3.测试

@Test
public void getUserByLimitTest(){
    SqlSession sqlSession = MybatisUtils.getSqlSession();
    UserMapper mapper = sqlSession.getMapper(UserMapper.class);
    HashMap<String, Integer> map = new HashMap<>();
    map.put("startIndex",0);
    map.put("pageSize",2);
    List<User> userList = mapper.getUserByLimit(map);
    for (User user : userList) {
        System.out.println(user);
    }
    sqlSession.close();
}

?

4.2RowsBounds分页

不使用sql进行分页。

1.接口

public interface UserMapper {
    //分页
    List<User> getUserByRowBounds();
}

2.Mapper.xml

<select id="getUserByRowBounds" resultMap="userMap">
     select * from mybatis.user 
</select>

3.测试

public void getUserByRowBoundsTest(){
    SqlSession sqlSession = MybatisUtils.getSqlSession();
    //通过java代码层面实现分页,rowbounds
    RowBounds rowBounds = new RowBounds(1,2);
    List<User> list = sqlSession.selectList("moli.dao.UserMapper.getUserByRowBounds",null,rowBounds);
    for (User user : list) {
      System.out.println(user);
    }
    sqlSession.close();
}

?

4.3分页插件

在这里插入图片描述

?
?

5.使用注解开发

5.1面向接口编程

大家之前都学过面向对象编程,也学习过接口,但在真正的开发中,很多时候我们会选择面向接口编程。

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

开发变得更容易,规范性更好

?

关于接口的理解:

  • 接口从更深层次的理解,应是定义(规范,约束)与实现(名实分离)的分离。

  • 接口的本身反映了系统设计人员对系统的抽象理解。

  • 接口应有两类:

    • 第一类是对一个个体的抽象,它可对应为一个抽象体(abstract class);
    • 第二类是对一个个体某一方面的抽象,即形成一个抽象面(interface);

? (一个体有可能有多个抽象面,抽象体与抽象面是有区别的)

?

三个面向区别:

  • 面向对象是指,我们考虑问题时,以对象为单位,考虑它的属性及方法。

  • 面向过程是指,我们考虑问题时,以一个具体的流程(事务过程)为单位,考虑它的实现。

  • 接口设计与非接口设计是针对复用技术而言的,与面向对象(过程)不是一个问题,更多的体现就是对系统整体的架构。

?

5.2使用注解编程

1.注解在接口上实现

public interface UserMapper {
    @Select("select * from mybatis.user")
    List<User> getUsers();
}

2.需要在核心配置文件上绑定接口

<mappers>
    <mapper class="moli.dao.UserMapper"></mapper>
</mappers>

3.测试

@Test
public void test(){
    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();
}

本质:反射机制的实现

底层:动态代理

?

5.3mybatis详细流程

在这里插入图片描述

?

5.4使用注解CRUD

我们可以在工具类创建的时候实现自动提交事务:在MybatisUtils中的openSession 设置为true自动提交。

在这里插入图片描述

?
1.接口

public interface UserMapper {
    @Select("select * from mybatis.user")
    List<User> getUsers();
    @Select("select * from mybatis.user where id=#{id}")
    User getUserById(@Param("id") int id);
    @Insert("insert into mybatis.user(id,name,pwd) values(#{id},#{name},#{pwd})")
    int addUser(User user);
    @Update("update mybatis.user set name=#{name},pwd=#{pwd} where id=#{id}")
    int updateUser(User user);
    @Delete("delete from mybatis.user where id=#{uid}")
    int deleteUser(@Param("uid") int id);
}

2.测试(我们必须要将接口绑定注册到核心配置文件中mybatis-config.xml上)

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

    mapper.getUserById(2);

    mapper.addUser(new User(8,"花","123"));

    mapper.updateUser(new User(3,"啊啊哈","0987654"));
     */
    mapper.deleteUser(2);
    sqlSession.close();
}

?
关于@param注解:

  • 它是MyBatis所提供的作为Dao层的注解,作用是用于传递参数,从而可以与SQL中的的字段名相对应,一般在2=<参数数<=5时使用最佳
  • 基本类型的参数或者String类型,需要加上
  • 引用类型不需要加
  • 如果只有一个基本类型的话,可以忽略,但是建议都加上
  • 我们在SQL中引用的就是我们在@Param("")中设定的属性名

?
#{},KaTeX parse error: Expected 'EOF', got '#' at position 13: {}的区别:推荐使用的是#?{},因为{}会出现sql注入问题。

?
?

6.Lombok插件

使用步骤:

  • 在idea中安装Lombok插件

  • 在项目中导入lombok的jar包

    <!-- https://mvnrepository.com/artifact/org.projectlombok/lombok -->
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <version>1.18.20</version>
    </dependency>
    
  • 可以使用的注解,使用完注解之后就可以不用再写那些重复性代码,注解可以放在类上或者字段上:

    @Getter and @Setter:get、set
    @Data:get、set、equals、hashCode、无参构造器
    @ToString:toString
    @EqualsAndHashCode:equals、hashCode
    @AllArgsConstructor:有参构造器@RequiredArgsConstructor@NoArgsConstructor:无参构造器
    

测试:在这里插入图片描述

?
?

7.多对一处理

在这里插入图片描述

  • 对于学生而言,关联……多个学生关联一个老师【多对一】
  • 对于老师而言,集合……一个老师拥有很多学生【一对多】

?

7.1SQL语句

CREATE TABLE `teacher` (
  `id` INT(10) NOT NULL,
  `name` VARCHAR(30) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=INNODB DEFAULT CHARSET=utf8

INSERT INTO teacher(`id`, `name`) VALUES (1,'秦老师'); 

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

在这里插入图片描述

?

7.2测试环境搭建

1.pojo

package moli.pojo;
import lombok.Data;
@Data
public class Student {
    private int id;
    private String name;
    //学生需要关联一个老师
    private Teacher teacher;
}
package moli.pojo;
import lombok.Data;
@Data
public class Teacher {
    private int id;
    private String name;
}

2.dao层Mapper接口

package moli.dao;
public interface StudentMapper {}
package moli.dao;
import moli.pojo.Teacher;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;

public interface TeacherMapper {
    @Select("select * from school.teacher where id=#{tid}")
    Teacher getTeacher(@Param("tid") int id);
}

3.Mapper.xml

<?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="moli.dao.StudentMapper">

</mapper>
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="moli.dao.TeacherMapper">
    
</mapper>

4.在核心配置文件里绑定Mapper接口

<mappers>
    <mapper class="moli.dao.TeacherMapper"/>
    <mapper class="moli.dao.StudentMapper"/>
</mappers>

测试成功,环境搭建完毕。

?

7.3按照查询嵌套处理

package moli.dao;
import moli.pojo.Student;
import java.util.List;

public interface StudentMapper {
    //查询所有的学生信息,以及对应的老师信息
    public List<Student> getStudent();
}
<!--
思路:
1.查询所有学生信息
2.根据查询的学生的tid,查询对应的老师     子查询
-->
<select id="getStudent" resultMap="StudentTeacher">
    select * from school.student
</select>
<resultMap id="StudentTeacher" type="Student">
    <result property="id" column="id"/>
    <result property="name" column="name"/>
    <!--
     复杂的属性,我们需要单独处理:
     关联:association(对象)
     集合:collection
    -->
    <association property="teacher" column="tid" javaType="Teacher" select="getTeacher"/>
</resultMap>
<select id="getTeacher" resultType="Teacher">
    select * from school.teacher where id=#{tid}
</select>
@Test
public void getStudentTest(){
    SqlSession sqlSession = MybatisUtils.getSqlSession();
    StudentMapper mapper = sqlSession.getMapper(StudentMapper.class);
    List<Student> studentList = mapper.getStudent();
    for (Student student : studentList) {
        System.out.println(student);
    }
}

结果:在这里插入图片描述

?

7.4按照结果嵌套处理

<!--按照结果嵌套查询-->
<select id="getStudent1" resultMap="StudentTeacher1">
   select s.id sid,s.name sname,t.name tname
   from school.student s,school.teacher t
   where s.tid=t.id
</select>
<resultMap id="StudentTeacher1" type="Student">
    <result property="id" column="sid"/>
    <result property="name" column="sname"/>
    <association property="teacher" javaType="Teacher">
        <result property="name" column="tname"/>
    </association>
</resultMap>

?
?

8.一对多处理

8.1测试环境搭建

和多对一一样

package moli.pojo;
import lombok.Data;

@Data
public class Student {
    private int id;
    private String name;
    private int tid;
}
package moli.pojo;
import lombok.Data;
import java.util.List;

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

?

8.2按照查询嵌套处理

package moli.dao;
import moli.pojo.Teacher;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;

public interface TeacherMapper {
    //获取指定老师下的所有学生的信息,和老师自己的信息
    Teacher getTeacher1(@Param("tid") int id);
}
<select id="getTeacher1" resultMap="TeacherStudent1">
    select * from school.teacher where id=#{tid}
</select>
<resultMap id="TeacherStudent1" type="Teacher">
    <collection property="students"  javaType="ArrayList" ofType="Student" select="getStudentByTeacherId" column="id"/>
</resultMap>
<select id="getStudentByTeacherId" resultType="Student">
    select * from school.student where tid=#{tid}
</select>
@Test
public void getTeacherTest(){
    SqlSession sqlSession = MybatisUtils.getSqlSession();
    TeacherMapper mapper = sqlSession.getMapper(TeacherMapper.class);
    System.out.println(mapper.getTeacher1(1));
    sqlSession.close();
}

?

8.3按照结构嵌套处理

<select id="getTeacher" resultMap="TeacherStudent">
    select s.id sid,s.name sname,t.id tid,t.name tname
    from school.student s,school.teacher t
    where s.tid=t.id and t.id=#{tid}
</select>
<resultMap id="TeacherStudent" type="Teacher">
    <result property="id" column="tid"/>
    <result property="name" column="tname"/>
    <!--javaType指定属性的类型
    ofType用于获取集合中的泛型等-->
    <collection property="students" ofType="Student">
        <result property="id" column="sid"/>
        <result property="name" column="sname"/>
        <result property="tid" column="tid"/>
    </collection>
</resultMap>

面试高频问题:mysql引擎、InnoDB底层原理、索引、索引优化。

?
?

9.动态sql

  • 什么是动态sql:动态sql就是指根据不同的条件生成不同的sql语句

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

  • 建议:先在Mysql中写出完整的SQL,然后去修改成为我们的动态SQL实现通用即可

9.1基础工程

1.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;

在这里插入图片描述

?

2.导包
?

3.核心配置文件,注册绑定mapper文件

设置里加一个开启驼峰命名:在这里插入图片描述

<settings>
    <setting name="mapUnderscoreToCamelCase" value="true"/>
</settings>
<mappers>
       <mapper class="moli.dao.BlogMapper"/>
</mappers>

?

4.工具类

新加一个可以随机生成id的工具类

package moli.utils;
import org.junit.Test;
import java.util.UUID;

@SuppressWarnings("all")//抑制警告
//可以产生随机的id
public class IDutils {
    public static String getId(){
      return UUID.randomUUID().toString().replaceAll("-"," ");
    }
    @Test
    public void test(){
        System.out.println(IDutils.getId());
    }
}

?
5.实体类pojo

package moli.pojo;
import lombok.Data;
import java.util.Date;
@Data
public class Blog {
    private String id;
    private String title;
    private String author;
    private Date createTime//属性名和字段名不一致
    private int views;
}

?

6.Mapper接口和Mapper.xml

package moli.dao;
import moli.pojo.Blog;
public interface BlogMapper {
    //给sql插入数据
    int addBlog(Blog blog);
}
<mapper namespace="moli.dao.BlogMapper">
    <insert id="addBlog" parameterType="Blog">
        insert into mybatis.blog (id,title,author,create_time,views)
        values (#{id},#{title},#{author},#{createTime},#{views})
    </insert>
</mapper>

?

7.测试

@Test
public void addBlogTest() {
    SqlSession sqlSession = MybatisUtils.getSqlSession();
    BlogMapper mapper = sqlSession.getMapper(BlogMapper.class);
    Blog blog = new Blog();
    blog.setId(IDutils.getId());
    blog.setTitle("Mybatis");
    blog.setAuthor("狂神说");
    blog.setCreateTime(new Date());
    blog.setViews(9999);

    mapper.addBlog(blog);

    blog.setId(IDutils.getId());
    blog.setTitle("Java");
    mapper.addBlog(blog);

    blog.setId(IDutils.getId());
    blog.setTitle("Spring");
    mapper.addBlog(blog);

    blog.setId(IDutils.getId());
    blog.setTitle("微服务");
    mapper.addBlog(blog);

    sqlSession.close();
}

成功插入数据!

?

9.2IF

public interface BlogMapper {
    //查询博客
    List<Blog> queryBlogIf(Map map);
}
<select id="queryBlogIf" parameterType="map" resultType="Blog">
    select * from mybatis.blog where 1=1
    <if test="title!=null">
        and title=#{title}
    </if>
    <if test="author!=null">
        and author=#{author}
    </if>
</select>
@Test
public void queryBlogIf(){
    SqlSession sqlSession = MybatisUtils.getSqlSession();
    BlogMapper mapper = sqlSession.getMapper(BlogMapper.class);
    HashMap map = new HashMap();
    //map.put("title","Java");
    map.put("author","狂神说");
    List<Blog> blogList = mapper.queryBlogIf(map);
    for (Blog blog : blogList) {
        System.out.println(blog);
    }
    sqlSession.close();
}

?

9.3choose

  • choose(when、otherwise)

  • choose什么都不传入,查询为null

  • choose当条件有好几条时,第一个为true就会停止查询

public interface BlogMapper {
    //查询博客
    List<Blog> queryBlogChoose(Map map);
}
<select id="queryBlogChoose" parameterType="map" resultType="Blog">
    select * from mybatis.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>
@Test
public void queryBlogChoose(){
    SqlSession sqlSession = MybatisUtils.getSqlSession();
    BlogMapper mapper = sqlSession.getMapper(BlogMapper.class);
    HashMap map = new HashMap();
    map.put("views","9999");
    map.put("title","Java");
    map.put("author","狂神说");
    List<Blog> blogList = mapper.queryBlogChoose(map);
    for (Blog blog : blogList) {
        System.out.println(blog);
    }
    sqlSession.close();
}

查询结果:在这里插入图片描述

?

9.4trim

9.4.1where

  • where语句---->用来精进if语句

  • where元素只会在子元素返回任何内容的情况下才插入 “WHERE” 子句

  • 若子句的开头为 “AND” 或 “OR”,where 元素也会将它们去除

  • where什么都不传入会查询全部

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

select * from mybatis.blog
<where>
    <if test="title!=null">
        and title=#{title}
    </if>
    <if test="author!=null">
        and author=#{author}
    </if>
</where>

?

9.4.2set

  • 至少要有一个set语句,否则就会报错

    在这里插入图片描述

  • set 元素会动态地在行首插入 SET 关键字,并会删掉额外的逗号

public interface BlogMapper {
    //更新博客
    int updateBlog(Map map);
}
<update id="updateBlog" parameterType="map">
    update mybatis.blog
    <set>
        <if test="title!=null">
            title=#{title},
        </if>
        <if test="author!=null">
            author=#{author}
        </if>
        where id=#{id}
    </set>
</update>
@Test
public void updateBlog(){
    SqlSession sqlSession = MybatisUtils.getSqlSession();
    BlogMapper mapper = sqlSession.getMapper(BlogMapper.class);
    HashMap map = new HashMap();
    map.put("title","Java1");
    map.put("author","狂神说1");
    map.put("id","b0345f58 cf36 45e6 b649 8ba9e7aa15c8");
    mapper.updateBlog(map);
}

?

9.4.3trim

<trim prefix="WHERE" prefixOverrides="AND |OR ">
  ...
</trim>

移除所有 prefixOverrides(前缀) 属性中指定的内容,并且插入 prefix 属性中指定的内容。

?

<trim prefix="SET" suffixOverrides=",">
  ...
</trim>

我们覆盖了后缀值设置,并且自定义了前缀值。

?

9.5foreach

  • 动态 SQL 的另一个常见使用场景是对集合进行遍历(尤其是在构建 IN 条件语句的时候)

  • foreach允许你指定开头、结尾的字符串、集合项迭代之间的分隔符

  • item是指要遍历哪一项

  • 一般不用取下标(index)

在这里插入图片描述

public interface BlogMapper {
    //查询1,2号博客
    List<Blog> queryBlogForeach(Map map);
}
<!--  select * from blog where 1=1 and (id=1 or id=2 or id=3)
我们现在传递一个万能的map,这个map里可以存在一个集合!  -->
<select id="queryBlogForeach" parameterType="map" resultType="Blog">
    select * from mybatis.blog
    <where>
       <foreach collection="ids" item="id" open="and (" close=")" separator="or">
           id=#{id}
       </foreach>
    </where>
</select>
@Test
public void queryBlogForeachTest(){
    SqlSession sqlSession = MybatisUtils.getSqlSession();
    BlogMapper mapper = sqlSession.getMapper(BlogMapper.class);
    HashMap map = new HashMap();
    ArrayList<Integer> ids = new ArrayList<Integer>();
    ids.add(1);
    ids.add(2);
    map.put("ids",ids);
    List<Blog> blogList = mapper.queryBlogForeach(map);
    for (Blog blog : blogList) {
        System.out.println(blog);
    }
    sqlSession.close();
}

?

9.6sql片段

  • 将公共的部分,用sql标签抽取出来,实现复用

  • 在需要引用的时候,用include引用

<sql id="if-title-author">
    <if test="title!=null">
        and title=#{title}
    </if>
    <if test="author!=null">
        and author=#{author}
    </if>
</sql>
<select id="queryBlogIf" parameterType="map" resultType="Blog">
    select * from mybatis.blog
    <where>
        <include refid="if-title-author"></include>
    </where>
</select>

sql标签里面的注意事项:

  • 最好基于单表来定义sql片段
  • 不要包含where标签
  • 大多数是包含if标签的

?
?

10.缓存

10.1简介

在这里插入图片描述

查询需要连接数据,耗资源!但是一次查询的结果,给他暂存在一个可以取到的地方-------> 内存(缓存)

?
1.什么是缓存(Cache):

存在内存中的临时数据,将用户经常查询的数据放在缓存中,用户去查询数据就不用从磁盘上(关系型数据库数据文件)查询,从缓存中查询,从而提高查询效率,解决了高并发系统的性能问题。

2.为什么使用缓存:

减少和数据库的交互次数,减少系统开销,提高系统效率。

3.什么样的数据能使用缓存:

经常查询并且不经常改变的数据

?

10.2Mybatis缓存

  • Mybatis包含一个非常强大的查询缓存特性,它可以非常方便的定制和配置缓存

  • Mybatis系统默认定义了两级缓存:一级缓存和二级缓存

  • 默认情况下,只有一级缓存开启

  • 二级缓存需要手动开启和配置,它是基于namespace级别的缓存

  • 为了提高扩展性,Mybatis定义了缓存接口Cache,我们可以通过实现Cache接口来自定义二级缓存

在这里插入图片描述

?

缓存原理:在这里插入图片描述

?

10.3一级缓存

  • 一级缓存也叫本地缓存:SqlSession,只在一次Sqlsession中有效,也就是开启和关闭这个区间

  • 与数据库同一次会话期间查询到的数据会放在本地缓存中

  • 以后如果需要获取相同的数据,直接从缓存中拿,没有必要再去查询数据库

10.3.1测试步骤

  1. 开启日志(标准日志即可)

  2. 测试在一个Session中查询两次相同记录!

    public interface UserMapper {
        //根据用户id查询用户
        User queryUserById(@Param("id") int id);
    }
    
    <select id="queryUserById" resultType="user">
        select * from mybatis.user where id=#{id}
    </select>
    
    @Test
    public void queryUserById(){
        SqlSession sqlSession = MybatisUtils.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        User user = mapper.queryUserById(3);
        System.out.println(user);
        System.out.println("=============================");
        User user1 = mapper.queryUserById(3);
        System.out.println(user1);
        System.out.println(user==user1);
        sqlSession.close();
    }
    
  3. 查看日志输出:在这里插入图片描述

?

10.3.2缓存失效

在这里插入图片描述

?

  1. 查询不同的id

  2. 增删改操作,可能会改变原来的数据,所以必定会刷新缓存

    public interface UserMapper {
        int updateUser(User user);
    }
    
    <update id="updateUser" parameterType="user">
        update mybatis.user set user.name=#{name},pwd=#{pwd} where id=#{id}
    </update>
    
    @Test
    public void queryUserById(){
        SqlSession sqlSession = MybatisUtils.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        User user = mapper.queryUserById(3);
        System.out.println(user);
        System.out.println("============================");
        mapper.updateUser(new User(4,"啊","12345123456"));
        System.out.println("=============================");
        User user1 = mapper.queryUserById(3);
        System.out.println(user1);
        System.out.println(user==user1);
        sqlSession.close();
    }
    

    在这里插入图片描述

  3. 查询不同的Mapper.xml

  4. 手动清除缓存

    @Test
    public void queryUserById(){
        SqlSession sqlSession = MybatisUtils.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        User user = mapper.queryUserById(3);
        
        sqlSession.clearCache();
        
        User user1 = mapper.queryUserById(3);
        System.out.println(user==user1);
        sqlSession.close();
    }
    

    在这里插入图片描述

?

10.4二级缓存

默认情况下,只启用了本地的会话缓存,它仅仅对一个会话中的数据进行缓存。 要启用全局的二级缓存,只需要在你的 SQL 映射文件(Mapper.xml)中添加一行:

<cache/>

<--除此之外还要在核心配置文件(mybatis-config.xml)里开启缓存机制-->
<settings>
    <!--开启全局缓存-->
    <setting name="cacheEnabled" value="true"/>
</settings>
<cache
  eviction="FIFO"
  flushInterval="60000"
  size="512"
  readOnly="true"/>

这个更高级的配置创建了一个 FIFO 缓存,每隔 60 秒刷新,最多可以存储结果对象或列表的 512 个引用,而且返回的对象被认为是只读的,因此对它们进行修改可能会在不同线程中的调用者产生冲突。

?

  • 工作机制:一个会话所查询的数据,会放在当前会话的一级缓存中,一旦当前会话关闭,这个一级缓存就消失了。我们想要的是会话关闭,一级缓存的数据被保存在二级缓存之中,新的会话我们可以从二级缓存中获取数据。
  • 不同的mapper查出的数据会放在自己对应的缓存(map)中
  • 二级缓存也叫 全局缓存
  • 基于namespace级别的缓存,一个名称空间,对应一个二级缓存
  • 只要开启了二级缓存,只在同一个Mapper下有效
  • 所有的数据都会先放在一级缓存中,只有当会话提交或者关闭的时候,才会提交到二级缓存中

?
测试:

  • 只用cache不加参数,就需要实体类序列化,否则报错 java.io.NotSerializableException

    在这里插入图片描述

<mapper namespace="moli.dao.UserMapper">
    <!--使用二级缓存-->
    <cache
            eviction="FIFO"
            flushInterval="60000"
            size="512"
            readOnly="true"/>
    <select id="queryUserById" resultType="user" useCache="true">
        select * from mybatis.user where id=#{id}
    </select>
</mapper>
@Test
public void queryUserById(){
    SqlSession sqlSession = MybatisUtils.getSqlSession();
    SqlSession sqlSession1 = MybatisUtils.getSqlSession();
    UserMapper mapper = sqlSession.getMapper(UserMapper.class);
    User user = mapper.queryUserById(3);
    sqlSession.close();

    UserMapper mapper1 = sqlSession1.getMapper(UserMapper.class);
    User user1 = mapper1.queryUserById(3);
    System.out.println(user==user1);
    sqlSession1.close();
}

在这里插入图片描述

?

10.5自定义缓存-Ehcache

使用ehcache首先要导包:

<!-- https://mvnrepository.com/artifact/org.mybatis.caches/mybatis-ehcache -->
<dependency>
    <groupId>org.mybatis.caches</groupId>
    <artifactId>mybatis-ehcache</artifactId>
    <version>1.2.1</version>
</dependency>

然后配置xml文件:

<cache type="org.mybatis.caches.ehcache.EhcacheCache"/>
<?xml version="1.0" encoding="UTF8"?>
<ehcache xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:noNamespaceSchemaLocation="http://ehcache.org/ehcache.xsd"
         updateCheck="false">
    <!--
        diskStore :为缓存路径,ehcache分为内存和磁盘两级,此属性定义磁盘的缓存位置,参数解释如下:
            user.hoeme - 用户主目录
            user.dir -  用户当前工作目录
            javaio.tmpdir - 默认临时文件
    -->
    
    <diskStore path="./tmpdir/Tmp_EhCache/"/>
    
    <!--
        defaultCache:默认缓存策略,当cache找不到定义的缓存时,则使用这个缓存策略,只能定义一个
    -->
    <defaultCache
            eternal="false"
            maxElementsInMemory="10000"
            overflowToDisk="false"
            diskPersistent="false"
            timeToIdleSeconds="1800"
            timeToLiveSeconds="259200"
            memoryStoreEvictionPolicy="LRU"/>

    <cache
            name="cloud_user"
            eternal="false"
            maxElementsInMemory="5000"
            overflowToDisk="false"
            diskPersistent="false"
            timeToIdleSeconds="1800"
            timeToLiveSeconds="1800"
            memoryStoreEvictionPolicy="LRU"/>
</ehcache>
        <!--
           name:缓存名称。
           maxElementsInMemory:缓存最大个数。
           eternal:对象是否永久有效,一但设置了,timeout将不起作用。
           timeToIdleSeconds:设置对象在失效前的允许闲置时间(单位:秒)。仅当eternal=false对象不是永久有效时使用,可选属性,默认值是0,也就是可闲置时间无穷大。
           timeToLiveSeconds:设置对象在失效前允许存活时间(单位:秒)。最大时间介于创建时间和失效时间之间。仅当eternal=false对象不是永久有效时使用,默认是0.,也就是对象存活时间无穷大。
           overflowToDisk:当内存中对象数量达到maxElementsInMemory时,Ehcache将会对象写到磁盘中。
           diskSpoolBufferSizeMB:这个参数设置DiskStore(磁盘缓存)的缓存区大小。默认是30MB。每个Cache都应该有自己的一个缓冲区。
           maxElementsOnDisk:硬盘最大缓存个数。
           diskPersistent:是否缓存虚拟机重启期数据 Whether the disk store persists between restarts of the Virtual Machine. The default value is false.
           diskExpiryThreadIntervalSeconds:磁盘失效线程运行时间间隔,默认是120秒。
           memoryStoreEvictionPolicy:当达到maxElementsInMemory限制时,Ehcache将会根据指定的策略去清理内存。默认策略是LRU(最近最少使用)。你可以设置为FIFO(先进先出)或是LFU(较少使用)。
           clearOnFlush:内存数量最大时是否清除。
        -->

也可以自己写个自定义缓存,就是写个工具类,但是日后我们很少使用,因为效率太低,我们使用的是redis数据库来做缓存。

  大数据 最新文章
实现Kafka至少消费一次
亚马逊云科技:还在苦于ETL?Zero ETL的时代
初探MapReduce
【SpringBoot框架篇】32.基于注解+redis实现
Elasticsearch:如何减少 Elasticsearch 集
Go redis操作
Redis面试题
专题五 Redis高并发场景
基于GBase8s和Calcite的多数据源查询
Redis——底层数据结构原理
上一篇文章      下一篇文章      查看所有文章
加:2022-02-14 21:14:25  更:2022-02-14 21:14:42 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年11日历 -2024/11/24 13:46:14-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码