其他分享
首页 > 其他分享> > MyBatis_狂神

MyBatis_狂神

作者:互联网

MyBatis

SSM框架,关于配置文件的,最好的学习方式:看官方文档

1. 简介

1.1 初识MyBatis

什么是MyBatis?

如何获得MyBatis

1.2 持久化

数据持久化

为什么需要持久化?

1.3 持久层

什么是持久层?

1.4 为什么需要MyBatis?

优点

 

2. 第一个MyBatis程序

思路:搭建环境--》导入MyBatis所需jar包--》编写代码--》运行测试

2.1 搭建环境

创建数据库

 CREATE DATABASE `mybatis`;
 ​
 USE `mybatis`
 ​
 CREATE TABLE `user`(
  `id` INT(10) NOT NULL AUTO_INCREMENT,
  `username` VARCHAR(20) NOT NULL,
  `password` VARCHAR(10) NOT NULL,
  PRIMARY KEY(`id`)
 )ENGINE=INNODB DEFAULT CHARSET=utf8;
 ​
 INSERT INTO `user`(`username`,`password`) VALUES
 ('张三','123456'),
 ('胖丫','333666'),
 ('Tom','789321')

创建maven项目,导入所需依赖

 <dependencies>
     <!--MyBatis依赖-->
     <!-- https://mvnrepository.com/artifact/org.mybatis/mybatis -->
     <dependency>
         <groupId>org.mybatis</groupId>
         <artifactId>mybatis</artifactId>
         <version>3.5.6</version>
     </dependency>
     <!--数据库依赖-->
     <dependency>
         <groupId>mysql</groupId>
         <artifactId>mysql-connector-java</artifactId>
         <version>5.1.47</version>
     </dependency>
     <!--Junit依赖-->
     <!-- https://mvnrepository.com/artifact/junit/junit -->
     <dependency>
         <groupId>junit</groupId>
         <artifactId>junit</artifactId>
         <version>4.13.1</version>
         <scope>test</scope>
     </dependency>
 </dependencies>

需要在pom.xml末加上配置resources,防止资源导出失败(maven约定大于配置,mapper.xml文件应该是写在resources目录下,但我们为了看起来简单方便,写在java目录下,会导致所写的mapper.xml不被识别,解决方案就是加上下方代码)

 <!--在build中配置resources,防止资源导出失败问题-->
 <build>
     <resources>
         <resource>
             <directory>src/main/resources</directory>
             <includes>
                 <include>**/*.properties</include>
                 <include>**/*.xml</include>
             </includes>
             <filtering>false</filtering>
         </resource>
         <resource>
             <directory>src/main/java</directory>
             <includes>
                 <include>**/*.properties</include>
                 <include>**/*.xml</include>
             </includes>
             <filtering>false</filtering>
         </resource>
     </resources>
 </build>

2.2 编写代码

编写工具类 : MybatisUtils ,获取sqlsession

 package com.zcc.utils;
 ​
 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 java.io.IOException;
 import java.io.InputStream;
 ​
 //mybatis工具类 SqlSessionFactory-->SqlSession
 public class MybatisUtils {
 ​
     private static SqlSessionFactory sqlSessionFactory;
 ​
     static {
         try {
             //使用MyBatis第一步,获取SqlSessionFactory对象
             String resource = "mybatis-config.xml";
             InputStream inputStream = Resources.getResourceAsStream(resource);
             sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
        } catch (IOException e) {
             e.printStackTrace();
        }
    }
     //已经有了 SqlSessionFactory,顾名思义,我们可以从中获得 SqlSession 的实例。
     //SqlSession 提供了在数据库执行 SQL 命令所需的所有方法
     public static SqlSession getSqlSession(){
         SqlSession sqlSession = sqlSessionFactory.openSession();
         return sqlSession;
    }
 }
 ​

编写mybatis配置文件:mybatis-config.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:核心配置文件-->
 <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>
 ​
     <!--每一个mapper.xml都需要在mybatis核心配置文件中注册-->
     <mappers>
         <mapper resource="com/zcc/mapper/UserMapper.xml"/>
     </mappers>
 </configuration>

 

编写实体类:User

 package com.zcc.pojo;
 ​
 public class User {
     private int id;
     private String username;
     private String password;
 ​
   //省略get/set方法、有参无参构造器、toString()方法
 }
 ​

编写Usermapper接口

 package com.zcc.mapper;
 ​
 import com.zcc.pojo.User;
 ​
 import java.util.List;
 ​
 public interface UserMapper {
     List<User> getUserList();
 }

编写UserMapper.xml文件,写sql语句

 <?xml version="1.0" encoding="UTF-8" ?>
 <!DOCTYPE mapper
         PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 ​
 <mapper namespace="com.zcc.mapper.UserMapper">
 ​
     <select id="getUserList" resultType="com.zcc.pojo.User">
    SELECT * FROM `user`
   </select>
 ​
 </mapper>

2.3 测试

编写测试代码

 package com.zcc.mapper;
 ​
 import com.zcc.pojo.User;
 import com.zcc.utils.MybatisUtils;
 import org.apache.ibatis.session.SqlSession;
 import org.junit.Test;
 ​
 import java.util.List;
 ​
 public class UserMapperTest {
     @Test
     public void Test01(){
         // 1. 获取sqlSession对象
         SqlSession sqlSession = MybatisUtils.getSqlSession();
 ​
         // 2. getMapper
         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中的包名要和mapper接口的包名一致

3.2 select

选择、查询语句

UserMapper

 //通过id查找用户
 User selectUserById(int id);

UserMapper.xml

 <select id="selectUserById" parameterType="int" resultType="com.zcc.pojo.User">
    select * from `user` where id=#{id}
 </select>

测试类:

 @Test
 public void selectUserById(){
     SqlSession sqlSession = MybatisUtils.getSqlSession();
 ​
     UserMapper mapper = sqlSession.getMapper(UserMapper.class);
     User user = mapper.selectUserById(1);
     System.out.println(user);
 ​
     sqlSession.close();
 }

 

3.3 insert

UserMapper

 //添加用户
 int addUser(User user);

UserMapper.xml

 <insert id="addUser" parameterType="com.zcc.pojo.User">
    INSERT INTO `user`(`username`,`password`) VALUES(#{username},#{password})
 </insert>

测试类:

 @Test
 public void addUser(){
     SqlSession sqlSession = MybatisUtils.getSqlSession();
     UserMapper mapper = sqlSession.getMapper(UserMapper.class);
 ​
     User user = new User();
     user.setUsername("菲菲");
     user.setPassword("123123");
 ​
     mapper.addUser(user);
 ​
     //注意:增删改需要提交事务
     sqlSession.commit();
     sqlSession.close();
 }

 

3.4 update

UserMapper

 //修改用户
 int updateUserById(User user);

UserMapper.xml

 <update id="updateUserById" parameterType="com.zcc.pojo.User">
    update `user` set username=#{username},password=#{password}where id=#{id}
 </update>

测试类:

 ​
 @Test
 public void updateUserById(){
     SqlSession sqlSession = MybatisUtils.getSqlSession();
 ​
     UserMapper mapper = sqlSession.getMapper(UserMapper.class);
 ​
     User user = new User();
     user.setId(4);
     user.setUsername("肥肥");
     user.setPassword("123789");
 ​
     mapper.updateUserById(user);
     sqlSession.commit();
     sqlSession.close();
 }

 

3.5 delete

UserMapper

 //删除用户
 int deleteUserByUsername(String username);

UserMapper.xml

 <delete id="deleteUserByUsername" parameterType="String">
    delete from `user` where username=#{username}
 </delete>

测试类:

 @Test
 public void deleteUserByUsername(){
     SqlSession sqlSession = MybatisUtils.getSqlSession();
 ​
     UserMapper mapper = sqlSession.getMapper(UserMapper.class);
     mapper.deleteUserByUsername("肥肥");
 ​
     sqlSession.commit();
     sqlSession.close();
 }

 

注意:增删改都需要提交事务

3.6. 万能map

假设我们的实体类或者数据库中的表,参数或者字段过多,我应该考虑使用map

map的使用,案例:通过username,修改用户的username和password

UserMapper

 //使用map通过username修改用户信息
 int updateUserByUsername(Map<String,Object> map);

UserMapper.xml

 <update id="updateUserByUsername" parameterType="map">
    update user set username=#{newUsername},password=#{newPassword} where username=#{oldUsername}
 </update>

Test:

 @Test
 public void updateUserByUsername(){
     SqlSession sqlSession = MybatisUtils.getSqlSession();
 ​
     UserMapper mapper = sqlSession.getMapper(UserMapper.class);
     
     HashMap<String, Object> hashMap = new HashMap<String, Object>();
     hashMap.put("oldUsername","李四");
     hashMap.put("newUsername","张三");
     hashMap.put("newPassword","123123");
 ​
     mapper.updateUserByUsername(hashMap);
 ​
     sqlSession.commit();
     sqlSession.close();
 }

Map传递参数,直接在sql中取出key即可

3.7 模糊查询

两种方式

第一种: 此种方式需要在调用处(java代码执行时)手动的去添加“%”通配符

UserMapper

 //模糊查询方式1
 List<User> selectUserLike(Map<String,Object> map);

UserMapper.xml

 <select id="selectUserLike" parameterType="map" resultType="com.zcc.pojo.User">
    select * from user where username like #{like}
 </select>

Test:

 @Test
 public void selectUserLike(){
     SqlSession sqlSession = MybatisUtils.getSqlSession();
 ​
     UserMapper mapper = sqlSession.getMapper(UserMapper.class);
 ​
     HashMap<String, Object> hashMap = new HashMap<String, Object>();
     hashMap.put("like", "%胖%");
     List<User> users = mapper.selectUserLike(hashMap);
     for (User user : users) {
         System.out.println(user);
    }
 ​
     sqlSession.close();
 }

 

第二种:在SQL拼接中使用通配符

UserMapper

 //模糊查询方式2
 List<User> selectUserLike2(Map<String,Object> map);

UserMapper.xml

 <select id="selectUserLike2" parameterType="map" resultType="com.zcc.pojo.User">
    select * from user where username like "%"#{like}"%"
 </select>

Test:

 @Test
 public void selectUserLike2(){
     SqlSession sqlSession = MybatisUtils.getSqlSession();
 ​
     UserMapper mapper = sqlSession.getMapper(UserMapper.class);
 ​
     HashMap<String, Object> hashMap = new HashMap<String, Object>();
     hashMap.put("like", "胖");
     List<User> users = mapper.selectUserLike2(hashMap);
     for (User user : users) {
         System.out.println(user);
    }
 ​
     sqlSession.close();
 }

 

小区分:

#{ }是预编译处理,MyBatis在处理#{ }时,它会将sql中的#{ }替换为?,然后调用PreparedStatement的set方法来赋值,传入字符串后,会在值两边加上单引号,使用占位符的方式提高效率,可以防止sql注入。${}:表示拼接sql串,将接收到参数的内容不加任何修饰拼接在sql中,可能引发sql注入。

 

4. 配置解析

4.1 核心配置文件

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

4.2 环境配置 environments

MyBatis 可以配置成适应多种环境,这种机制有助于将 SQL 映射应用于多种数据库之中

不过要记住:尽管可以配置多个环境,但每个 SqlSessionFactory 实例只能选择一种环境

学会使用配置多套运行环境

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

4.3 属性 properties

我们可以通过properties属性来实现引用配置文件

这些属性都是可外部配置且可动态替换的,既可以在典型的Java属性文件中配置,也可以通过properties元素的子元素来传递【properties】

注意一个问题:在mybatis配置文件中,所有的标签都已经规定好了顺序,我们必须按照顺序编写

 

 

编写配置文件:db.properties

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

在mybatis核心配置文件中映入

 <properties resource="db.properties"></properties>

4.4 类型别名(typeAliases)

两种方式:

第一种:

 <!--给实体类起别名  指定为User-->
 <typeAliases>
     <typeAlias type="com.zcc.pojo2.User" alias="User"></typeAlias>
 </typeAliases>

第二种:

也可以指定一个包名,Mybatis会在包名下面搜索需要的JavaBean,比如:扫描实体类的包,它的默认别名就是这个类的类名的首字母小写

 <typeAliases>
     <package name="com.zcc.pojo2"/>
 </typeAliases>

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

如果实体类十分多,推荐使用第二种方式

第一种可以DIY别名 第二种不行,但如果使用第二种方式非要改别名,需要在实体类上增加注解

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

4.5 设置(setting)

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

 

 

 

 

4.6 其他配置

4.7 映射器(mappers)

MapperRegistry:注册绑定我们的mapper文件

这些配置会告诉 MyBatis 去哪里找映射文件

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

 <mappers>
     <mapper resource="com/zcc/mapper2/UserMapper.xml"/>
 </mappers>

方式二:使用映射器接口实现类的完全限定类名

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

方式二的注意点:

4.8 生命周期和作用域

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

流程:

 

 

SqlSessionFactoryBuilder:

SqlSessionFactory:

SqlSession:

 

这里面的每一个mapper,都代表一个具体的业务

 

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

5.1 问题

数据库中的字段:

 

 

实体类属性名:(密码与数据库中字段不一致)

 public class User {
     private int id;
     private String username;
     private String pwd;
 }

直接测试:出现问题

 

 

5.2 ResultMap

结果集映射

 id  name  password
 id  name  pwd

 

 <!--结果集映射-->
 <!--column是数据库字段名   property是实体类属性名-->
 <resultMap id="user" type="user">
     <result column="id" property="id"></result>
     <result column="username" property="username"></result>
     <result column="password" property="pwd"></result>
 </resultMap>

6. 日志

6.1 日志工厂

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

从前用:sout输出sql语句、debug

在SQL mapper里 使用日志工厂

 

Mybatis 通过使用内置的日志工厂提供日志功能。内置日志工厂将会把日志工作委托给下面的实现之一:

在mybatis中具体使用哪一个实现,在设置中设定

STDOUT_LOGGING 标准日志输出 ()

在mabatis-config.xml中,配置我们的日志

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

 

 

6.2 Log4j

什么是Log4j?

Log4j的使用步骤

  1. 先导入 Log4j的包

     <!-- https://mvnrepository.com/artifact/log4j/log4j -->
     <dependency>
         <groupId>log4j</groupId>
         <artifactId>log4j</artifactId>
         <version>1.2.17</version>
     </dependency>
  2. 编写Log4j.properties (Log4j的配置,网上都有)

     #将等级为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/zcc.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. 在mybatis核心配置文件添加对日志的设置

     <settings>
         <setting name="logImpl" value="LOG4J"/>
     </settings>
  4. 运行测试,查看输出日志

     

    生成的日志文件 :

     

 

简单使用

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

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

static Logger logger = Logger.getLogger(UserDaoTest.class); //UserDaoTest为相关的类

  1. 日志级别

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

 

6.3 日志级别

日志记录器(Logger)的行为是分等级的。分为OFF、FATAL、ERROR、WARN、INFO、DEBUG、ALL或者自定义的级别

Log4j建议只使用四个级别,优先级从高到低分别是 ERROR、WARN、INFO、DEBUG。通过在这里定义的级别,您可以控制到应用程序中相应级别的日志信息的开关。比如在这里定义了INFO级别,则应用程序中所有DEBUG级别的日志信息将不被打印出来,也是说大于等于的级别的日志才输出。

 

说明:

7. 分页

分页的原因:减少数据的处理量

使用limit分页

SQL:SELECT * FROM 表名 LIMIT startIndex,pageSize

使用mybatis实现分页,核心SQL

  1. 接口

     List<User> selectUserByLimit(Map<String,Integer> map);
  2. Mapper.xml

     <select id="selectUserByLimit" parameterType="map" resultMap="user">
        select * from `user` limit #{startIndex},#{pageSize}
     </select>
  3. 测试

     @Test
     public void selectUserByLimit(){
         SqlSession sqlSession = MyBatisUtils.getSqlSession();
         UserMapper mapper = sqlSession.getMapper(UserMapper.class);
     ​
         HashMap<String, Integer> hashMap = new HashMap<String, Integer>();
         hashMap.put("startIndex",0);
         hashMap.put("pageSize",2);
         List<User> users = mapper.selectUserByLimit(hashMap);
         for (User user : users) {
             System.out.println(user);
        }
         sqlSession.close();
     }
  4. 结果:

     

 

分页插件:了解

 

8. 使用注解开发

8. 1 面向接口编程

大家之前都学过面向对象编程,也学习过接口,但在真正的开发中,很多时候我们会选择面向接口编程,根本原因:解耦,可拓展,提高复用,分层开发中,上层不用管具体的实现,大家都遵守共同的标准,使得开发变得更容易,规范性更好 在一个面向对象的系统中,系统的各种功能是由许许多多的不同对象协作完成的。在这种情况下,各个对象内部是如何实现自己的,对系统设计人员来讲就不那么重要了;而各个对象之前的协作关系则成为系统设计的关键,小到不同类之间的通信,大到各模块之间的交互,在系统设计之初都是要着重考虑的,这也是系统设计的主要工作内容,面向接口编程就是指按照这种思想来编程。

关于接口的理解

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

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

接口应有两类:

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

三个面向区别

面向对象是指,我们考虑问题时,以对象为单位,考虑它的属性及方法 面向过程是指,我们考虑问题时,以一个具体的流程(事务过程)为单位,考虑它的实现。 接口设计与非接口设计是针对复用技术而言的,与面向对象(过程)不是一个问题,更多的体现就是对系统整体的架构

8.2 使用注解编程

 

步骤:

  1. 注解在接口上实现

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

     <mappers>
         <mapper class="com.zcc.mapper2.UserMapper"/>
     </mappers>
  3. 测试

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

注解:

底层实现机制:反射

底层:动态代理

8.3 MyBatis详细的执行流程

 

 

8.4 注解 CRUD

小技巧:自动提交事务

在mybatis工具类中 将openSession设置为true即自动替提交

 public static SqlSession getSqlSession(){
     SqlSession sqlSession = sqlSessionFactory.openSession(true);
     return sqlSession;
 }

CRUE以添加为例:

  1. 编写接口,增加注解

     //添加用户
     @Insert("insert into `user` values(#{id},#{username},#{password})")
     int addUser(User user);
  2. 测试(需要先将接口绑定注册到核心配置文件mybatis-config.xml中)

     @Test
     public void addUser(){
         SqlSession sqlSession = MyBatisUtils.getSqlSession();
     ​
         UserMapper mapper = sqlSession.getMapper(UserMapper.class);
         mapper.addUser(new User(6,"马汉","123321"));
     ​
         sqlSession.commit();   //手动提交事务
         sqlSession.close();
     }

8.5 关于@param注解

作用:

用注解来简化xml配置的时候(比如Mybatis的Mapper.xml中的sql参数引入),@Param注解的作用是给参数命名,参数命名后就能根据名字得到参数值,正确的将参数传入sql语句中,(一般通过#{}的方式,${}会有sql注入的问题)。

 

9. Lombok

Lombok是一个java库,它可以自动插入编辑器和构建工具,使java更加丰富多彩。永远不要再编写另一个getter或equals方法,使用一个注释,你的类就有了一个功能齐全的构建器,自动化你的日志变量,等等。

使用步骤:

  1. 在idea中安装Lombok插件

     

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

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

     

10. 多对一处理

 

 

 

搭建环境:

 CREATE TABLE `teacher` (
  `id` INT(10) NOT NULL AUTO_INCREMENT,
  `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 AUTO_INCREMENT,
  `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');
  1. 新建实体类 Teacher、Student

 package com.zcc.pojo;
 ​
 import lombok.AllArgsConstructor;
 import lombok.Data;
 import lombok.NoArgsConstructor;
 ​
 @NoArgsConstructor
 @AllArgsConstructor
 @Data
 public class Teacher {
     private int id;
     private String name;
 ​
 }
 package com.zcc.pojo;
 ​
 import lombok.AllArgsConstructor;
 import lombok.Data;
 import lombok.NoArgsConstructor;
 ​
 @NoArgsConstructor
 @AllArgsConstructor
 @Data
 public class Student {
     private int id;
     private String name;
     private Teacher teacher;
 ​
 }
 ​
  1. 建立接口 TeacherMapper

 public interface TeacherMapper {
     //根据id查询
     Teacher selectById(int id);
 }

建立TeacherMapper.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="com.zcc.mapper.TeacherMapper">
 ​
     <select id="selectById" resultType="teacher" parameterType="_int">
        select * from `teacher` where id=#{id}
     </select>
 ​
 </mapper>

在核心配置文件中绑定注册的TeacherMapper.xml

 <mappers>
     <mapper resource="mappers/TeacherMapper.xml"></mapper>
 </mappers>

测试:

 @Test
 public void selectById(){
     SqlSession sqlSession = MyBatisUtils.getSqlSession();
     TeacherMapper mapper = sqlSession.getMapper(TeacherMapper.class);
     Teacher teacher = mapper.selectById(1);
     System.out.println(teacher);
 ​
     sqlSession.close();
 }

 

 

 

复杂的SQL查询:

要求:

 //查出所有学生信息即对应老师的信息
 List<Student> getStudent();

 

按照查询嵌套处理:

 <select id="getStudent" resultMap="student">
    select * from student
 </select>
 ​
 <resultMap id="student" type="Student">
     <result property="id" column="id"></result>
     <result property="name" column="name"></result>
     <association property="teacher" column="tid" javaType="Teacher" select="getTeacher"></association>
 </resultMap>
 ​
 <select id="getTeacher" resultType="Teacher">
    select * from teacher where id=#{tid}
 </select>

 

按照结果查询处理:【推荐使用】

 <select id="getStudent" resultMap="StudentTeacher">
    SELECT s.id sid,s.name sname,t.id tid,t.name tname
    FROM student s ,teacher t
    WHERE s.tid=t.id
 </select>
 ​
 <resultMap id="StudentTeacher" type="Student">
     <result property="id" column="sid"></result>
     <result property="name" column="sname"></result>
     
     <!--复杂的属性\对象使用 association\集合使用 collection-->
     
     <association property="teacher" javaType="Teacher">
         <result property="id" column="tid"></result>
         <result property="name" column="tname"></result>
     </association>
 </resultMap>

 

 

 

11. 一对多处理

比如:一个老师有多个学生,就是一对多的关系

实体类:

 @NoArgsConstructor
 @AllArgsConstructor
 @Data
 public class Student {
     private int id;
     private String name;
     private int tid;
 ​
 }
 @NoArgsConstructor
 @AllArgsConstructor
 @Data
 public class Teacher {
     private int id;
     private String name;
 ​
     private List<Student> student;
 ​
 }

TeacherMapper接口

 //根据教师id 查询该教师及对应的所有学生
 Teacher getTeacher(@Param("tid") int id);

TeacherMapper.xml :按结果查询处理 【推荐使用】

 <select id="getTeacher" parameterType="_int" resultMap="TeacherStudent">
    SELECT t.id tid, t.name tname,s.id sid,s.name sname,s.tid stid
    FROM teacher t,student s
    WHERE t.id=s.tid AND t.id=#{tid}
 </select>
 ​
 <resultMap id="TeacherStudent" type="Teacher">
     <result property="id" column="tid"></result>
     <result property="name" column="tname"></result>
     <collection property="student" ofType="Student">
         <result property="id" column="sid"></result>
         <result property="name" column="sname"></result>
         <result property="tid" column="stid"></result>
     </collection>
 </resultMap>

TeacherMapper.xml :按嵌套查询处理

 <select id="getTeacher" resultMap="TeacherStudent">
    select * from teacher where id=#{tid}
 </select>
 <resultMap id="TeacherStudent" type="Teacher">
     <collection property="student" javaType="ArrayList" ofType="Student" select="getStudent" column="id"></collection>
 </resultMap>
 ​
 <select id="getStudent" resultType="Student">
    select * from student where tid=#{tid}
 </select>

 

在核心配置文件中绑定注册的TeacherMapper.xml

 <mappers>
     <mapper resource="mappers/TeacherMapper.xml"></mapper>
 </mappers>

测试:

 @Test
 public void getTeacher(){
     SqlSession sqlSession = MyBatisUtils.getSqlSession();
     TeacherMapper mapper = sqlSession.getMapper(TeacherMapper.class);
     Teacher teacher = mapper.getTeacher(1);
     System.out.println(teacher);
     sqlSession.close();
 }

 

 

小结:

  1. 关联: association 【多对一】

  2. 集合: collection 【一对多】

  3. JavaType OfType

    • JavaType 用来指定属性实体类中的类型

    • OfType 用来指定映射到List或者集合中的pojo类型,泛型中的约束类型

注意点:

面试高频问题:

 

12. 动态SQL

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

如果你之前用过 JSTL 或任何基于类 XML 语言的文本处理器,你对动态 SQL 元素可能会感觉似曾相识。在 MyBatis 之前的版本中,需要花时间了解大量的元素。借助功能强大的基于 OGNL 的表达式,MyBatis 3 替换了之前的大部分元素,大大精简了元素种类,现在要学习的元素种类比原来的一半还要少。

搭建环境

数据表:

 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 '浏览量',
  PRIMARY KEY (`id`)
 ) ENGINE=InnoDB DEFAULT CHARSET=utf8
 ​

创建一个基础工程:

  1. 导包

  2. 编写配置文件、绑定mapper文件等

  3. 编写实体类Blog

     @NoArgsConstructor
     @AllArgsConstructor
     @Data
     public class Blog {
         private String id;
         private String title;
         private String author;
         private Date createTime;
         private int views;
     }
  4. BlogMapper

     //插入数据
     int addBlog(Blog blog);
  5. BlogMapper.xml

     <insert id="addBlog" parameterType="blog">
        insert into `Blog` values(#{id},#{title},#{author},#{createTime},#{views})
     </insert>
  6. 编写工具类,生成随机ID 保证ID不重复 更规范,符合企业开发标准

     package com.zcc.utils;
     import java.util.UUID;
     ​
     public class IdUtils {
         public static String getId(){
             return UUID.randomUUID().toString().replaceAll("-","");
        }
     }
     ​
     ​
     ​
  7. 测试:插入数据

     @Test
     public void addBlog(){
         SqlSession sqlSession = MyBatisUtils.getSqlSession();
         BlogMapper mapper = sqlSession.getMapper(BlogMapper.class);
     ​
         Blog blog = new Blog();
         blog.setId(IdUtils.getId());
         blog.setTitle("我爱java");
         blog.setAuthor("李四");
         blog.setCreateTime(new Date());
         blog.setViews(100);
     ​
         mapper.addBlog(blog);
     ​
         sqlSession.commit();
         sqlSession.close();
     }

     

 

IF

动态 SQL 最常见情景是根据条件包含 where 子句的一部分

比如:根据不同条件查询Blog

 //查找
 List<Blog> selectBlogIf(Map map);

编写BlogMapper.xml需注意,用resultMap,因为实体类属性careteTime与数据库create_time字段不匹配

 <select id="selectBlogIf" parameterType="map" resultMap="blog">
    select * from `blog`
     <where>
         <if test="views!=null">
            views>#{views}
         </if>
         <if test="author!=null">
            and author=#{author}
         </if>
     </where>
 </select>
 <resultMap id="blog" type="blog">
     <result property="createTime" column="create_time"></result>
 </resultMap>

测试:查找浏览量大于80的

 @Test
 public void selectBlogIf(){
     SqlSession sqlSession = MyBatisUtils.getSqlSession();
     BlogMapper mapper = sqlSession.getMapper(BlogMapper.class);
     HashMap<String, Object> hashMap = new HashMap<String, Object>();
     hashMap.put("views",80);
     List<Blog> blogs = mapper.selectBlogIf(hashMap);
     for (Blog blog : blogs) {
         System.out.println(blog);
    }
     sqlSession.close();
 }

 

 

choose 、when,、otherwise

 

 

trim、where、set

 

 

 

 

foreach

 

案例:使用foreach

BlogMapper

 //查找指定多个id的Blog
 List<Blog> selectBlogForEach(Map map);

BlogMapper.xml

 <select id="selectBlogForEach" parameterType="map" resultMap="blog">
    SELECT * FROM blog
     <where>
         <foreach collection="ids" item="id" open="" separator="or" close="">
            id=#{id}
         </foreach>
     </where>
 </select>

测试:

 @Test
 public void selectBlogForEach(){
     SqlSession sqlSession = MyBatisUtils.getSqlSession();
     BlogMapper mapper = sqlSession.getMapper(BlogMapper.class);
     HashMap<String, ArrayList> map = new HashMap<String, ArrayList>();
     ArrayList<String> list = new ArrayList();
     list.add("09c01355e9d34b889d55c901eccc50e2");
     list.add("ac1dfa17adbb4204a676cce0881bba93");
     map.put("ids",list);
 ​
     List<Blog> blogs = mapper.selectBlogForEach(map);
     for (Blog blog : blogs) {
         System.out.println(blog);
    }
 ​
     sqlSession.close();
 }

 

 

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

 

13. 缓存

简介

 查询:连接数据,耗资源!
 一次查询的结果,给他暂存在一个可以取到的地方! ---> 内存 : 缓存
 ​
 我们再次查询相同数据的时候,直接走缓存,就不用走数据库了。
  1. 什么是缓存[Cache]?

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

  1. 为什么使用缓存?

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

  1. 什么样的数据能使用缓存?

经常查询并且不经常改变的数据【可以使用缓存】

MyBatis缓存

Mybatis包含一个非常强大的查询缓存特性,它可以非常方便的定制和配置缓存。缓存可以极大的提升查询效率。

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

 

一级缓存

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

测试步骤:

  1. 开启日志

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

     import org.apache.ibatis.session.SqlSession;
     import org.junit.Test;
     import xiaoqi.dao.UserMapper;
     import xiaoqi.pojo.User;
     import xiaoqi.utils.MybatisUtils;
     ​
     public class MyTest {
         @Test
         public void test(){
             SqlSession sqlSession = MybatisUtils.getSqlSession();
             UserMapper mapper = sqlSession.getMapper(UserMapper.class);
             User user = mapper.queryUser(1);
             System.out.println(user);
             System.out.println("=============");
             User user1 = mapper.queryUser(1);
             System.out.println(user1);
             System.out.println(user == user1);
             sqlSession.close();
        }
     }
     ​
  3. 查看日志输出

     

缓存失效的情况:

 

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

二级缓存

 

 

 

 

 

步骤:

  1. 开启全局缓存

     <!--显式的开启全局缓存-->
     <setting name="cacheEnable" value="true"/>
  2. 在要使用二级缓存的Mapper中开启

     <cache/>

    也可以自定义参数

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

    • 我们需要将实体类序列化!否则就会报错 Cause: java.io.NotSerializableException: xiaoqi.pojo.User

    •  public class MyTest {
           @Test
           public void test(){
               SqlSession sqlSession = MybatisUtils.getSqlSession();
               SqlSession sqlSession1 = MybatisUtils.getSqlSession();
       ​
               UserMapper mapper = sqlSession.getMapper(UserMapper.class);
               User user = mapper.queryUser(1);
               System.out.println(user);
               sqlSession.close();
         
               //关掉第一个sqlsession才会将一级缓存中的数据保存到二级缓存中
               UserMapper mapper1 = sqlSession1.getMapper(UserMapper.class);
               User user1 = mapper1.queryUser(1);
               System.out.println(user1);
               System.out.println(user == user1);
               sqlSession1.close();
          }
       }
       ​
    •  

     

小结:

  1. 只要开启了二级缓存,只在同一个Mapper下有效

  2. 所有的数据都会先放在一级缓存中;只有当会话提交或者关闭的时候,才会提交到二级缓存中

 

缓存原理

 

自定义缓存-ehcache

Ehcache是一种广泛使用的开源Java分布式缓存,主要面向通用缓存

要在程序中使用ehcache:

  1. 导包

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

     

  2. ehcache的配置文件

     <?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
             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>
         <!--
             defaultCache:默认缓存策略,当cache找不到定义的缓存时,则使用这个缓存策略,只能定义一个
         -->
         <!--
            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:内存数量最大时是否清除。
         -->
     ​

     

  3. 使用ehchache

     <!--自定义缓存,用第三方缓存覆盖-->
     <cache type = "org.mybatis.caches.ehcache.EhcacheCache"/>
     ​

     

 

 

 

 

 

标签:mapper,缓存,UserMapper,sqlSession,user,MyBatis,狂神,id
来源: https://www.cnblogs.com/zccjy/p/16308907.html