【MyBatis】MyBatis 操作数据库
https://i-blog.csdnimg.cn/direct/fd7b15b8105349f7a0d86902e10bed35.png本篇文章，重要包罗以下几部分：
1. 使用MyBatis完成简单的增删改查操作, 参数传递.
2. 把握MyBatis的两种写法: 注解和XML方式
3. 把握MyBatis相干的日志配置
前言
在应用分层学习时, 我们了解到web应用程序⼀般分为三层，即：Controller、Service、Dao . 之前的案例中，请求流程如下: 欣赏器发起请求, 先请求Controller, Controller接收到请求之后, 调用Service进行业务逻辑处置惩罚, Service再调用Dao, 但是Dao层的数据是Mock的, 真实的数据应该从数据库中读取. 我们学习MySQL数据库时，已经学习了JDBC来操作数据库, 但是JDBC操作太复杂了
JDBC 操作示例回顾
[*]创建数据库毗连池 DataSource
[*]通过 DataSource 获取数据库毗连 Connection
[*]编写要执行带 ? 占位符的 SQL 语句
[*]通过 Connection 及 SQL 创建操作下令对象 Statement
[*]更换占位符：指定要更换的数据库字段类型，占位符索引及要更换的值
[*]使⽤ Statement 执行 SQL 语句
[*]查询操作：返回结果集 ResultSet，更新操作：返回更新的数量
[*]处置惩罚结果集
[*]释放资源
下⾯的⼀个完存案例，展示了通过 JDBC 的 API 向数据库中添加⼀条记录，修改⼀条记录，查询⼀条记录的操作。
-- 创建数据库
create database if not exists library default character set utf8mb4;
-- 使⽤数据库
use library;
-- 创建表
create table if not exists soft_bookrack (
book_name varchar(32) NOT NULL,
book_author varchar(32) NOT NULL,
book_isbn varchar(32) NOT NULL primary key
);
以下是 JDBC 操作的具体实现代码：
package com.example.demo.mapper;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class SimpleJdbcOperation {
private final DataSource dataSource;
public SimpleJdbcOperation(DataSource dataSource) {
this.dataSource = dataSource;
}
/**
* 添加⼀本书
*/
public void addBook() {
Connection connection = null;
PreparedStatement stmt = null;
try {
//获取数据库连接
connection = dataSource.getConnection();
//创建语句
stmt = connection.prepareStatement(
"insert into soft_bookrack (book_name, book_author,
book_isbn) values( ?,?,?);
"
);
//参数绑定
stmt.setString(1, "Spring in Action");
stmt.setString(2, "Craig Walls");
stmt.setString(3, "9787115417305");
//执⾏语句
stmt.execute();
} catch (SQLException e) {
//处理异常信息
} finally {
//清理资源
try {
if (stmt != null) {
stmt.close();
}
if (connection != null) {
connection.close();
}
} catch (SQLException e) {
//
}
}
}
/**
* 更新⼀本书
*/
public void updateBook() {
Connection connection = null;
PreparedStatement stmt = null;
try {
//获取数据库连接 connection = dataSource.getConnection();
//创建语句 stmt = connection.prepareStatement(
"update soft_bookrack set book_author=? where book_isbn=?;"
);
//参数绑定 stmt.setString(1, "张卫滨");
stmt.setString(2, "9787115417305");
//执⾏语句 stmt.execute(); } catch (SQLException e) {
//处理异常信息 } finally {
//清理资源
try {
if (stmt != null) {
stmt.close();
}
if (connection != null) {
connection.close();
}
} catch (SQLException e) {
//
}
}
}
/**
* 查询⼀本书
*/
public void queryBook() {
Connection connection = null;
PreparedStatement stmt = null;
ResultSet rs = null;
Book book = null;
try {
//获取数据库连接
connection = dataSource.getConnection();
//创建语句
stmt = connection.prepareStatement(
"select book_name, book_author, book_isbn from
soft_bookrack where book_isbn = ? "
);
//参数绑定
stmt.setString(1, "9787115417305");
//执⾏语句
rs = stmt.executeQuery();
if (rs.next()) {
book = new Book();
book.setName(rs.getString("book_name"));
book.setAuthor(rs.getString("book_author"));
book.setIsbn(rs.getString("book_isbn"));
}
System.out.println(book);
} catch (SQLException e) {
//处理异常信息
} finally {
//清理资源
try {
if (rs != null) {
rs.close();
}
if (stmt != null) {
stmt.close();
}
if (connection != null) {
connection.close();
}
} catch (SQLException e) {
//处理异常信息
}
}
}
public static class Book {
private String name;
private String author;
private String isbn;
//省略 setter getter ⽅法
}
}
从上述代码和操作流程可以看出，对于 JDBC 来说，整个操作⾮常的繁琐，我们不但要拼接每⼀个参 数，⽽且还要按照模板代码的⽅式，一步步的操作数据库，而且在每次操作完，还要⼿动关闭毗连 等，而所有的这些操作步调都必要在每个⽅法中重复书写. 那有没有⼀种⽅法，可以更简单、更⽅便的 操作数据库呢？ 答案是肯定的，这就是我们要学习 MyBatis 的真正缘故原由，它可以帮助我们更方便、更快速的操作数据库.
一、什么是MyBatis？
• MyBatis是⼀款良好的 持久层框架，用于简化JDBC的开发。
• MyBatis本是 Apache的⼀个开源项目iBatis，2010年这个项目由apache迁移到了google code，而且改名为MyBatis 。2013年11月迁移到Github。
在上⾯我们提到⼀个词：持久层
• 持久层：指的就是持久化操作的层, 通常指数据访问层(dao), 是用来操作数据库的.
https://i-blog.csdnimg.cn/direct/bb7cb31c8f354cc0909effedde9984ba.png
简单来说 MyBatis 是更简单完成程序和数据库交互的框架，也就是更简单的操作和读取数据库工具接下来，我们就通过⼀个入门程序，让各人感受⼀下通过Mybatis如何来操作数据库
二、MyBatis入门
Mybatis操作数据库的步调：
[*]准备工作(创建springboot工程、数据库表准备、实体类)
[*]引入Mybatis的相干依靠，配置Mybatis(数据库毗连信息)
[*]编写SQL语句(注解/XML)
[*]测试
2.1、准备工作
2.1.1 创建工程
创建springboot工程，并导入mybatis的起步依靠、mysql的驱动包
https://i-blog.csdnimg.cn/direct/c97b3326f2264737b13688f80c5f71bb.png
Mybatis 是⼀个持久层框架, 具体的数据存储和数据操作还是在MySQL中操作的, 所以必要添加MySQL驱动
项目工程创建完成后，主动在pom.xml⽂件中，导⼊Mybatis依靠和MySQL驱动依靠
<!--Mybatis 依赖包-->
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>2.3.1</version>
</dependency>
<!--mysql驱动包-->
<dependency>
<groupId>com.mysql</groupId>
<artifactId>mysql-connector-j</artifactId>
<scope>runtime</scope>
</dependency>
2.1.2、数据准备
-- 创建数据库
DROP DATABASE IF EXISTS mybatis_test;
CREATE DATABASE mybatis_test DEFAULT CHARACTER SET utf8mb4;
-- 使⽤数据数据
USE mybatis_test;
-- 创建表[⽤⼾表]
DROP TABLE IF EXISTS userinfo;
CREATE TABLE `userinfo` (
`id` INT ( 11 ) NOT NULL AUTO_INCREMENT,
`username` VARCHAR ( 127 ) NOT NULL,
`password` VARCHAR ( 127 ) NOT NULL,
`age` TINYINT ( 4 ) NOT NULL, `gender` TINYINT ( 4 ) DEFAULT '0' COMMENT '1-男 2-⼥ 0-默认',
`phone` VARCHAR ( 15 ) DEFAULT NULL,
`delete_flag` TINYINT ( 4 ) DEFAULT 0 COMMENT '0-正常, 1-删除',
`create_time` DATETIME DEFAULT now(),
`update_time` DATETIME DEFAULT now(),
PRIMARY KEY ( `id` )
) ENGINE = INNODB DEFAULT CHARSET = utf8mb4;
-- 添加⽤⼾信息
INSERT INTO mybatis_test.userinfo ( username, `password`, age, gender, phone )
VALUES ( 'admin', 'admin', 18, 1, '18612340001' );
INSERT INTO mybatis_test.userinfo ( username, `password`, age, gender, phone )
VALUES ( 'zhangsan', 'zhangsan', 18, 1, '18612340002' );
INSERT INTO mybatis_test.userinfo ( username, `password`, age, gender, phone )
VALUES ( 'lisi', 'lisi', 18, 1, '18612340003' );
INSERT INTO mybatis_test.userinfo ( username, `password`, age, gender, phone )
VALUES ( 'wangwu', 'wangwu', 18, 1, '18612340004' );
创建对应的实体类 UserInfo
实体类的属性名与表中的字段名⼀⼀对应
import lombok.Data;
import java.util.Date;
@Data
public class UserInfo {
private Integer id;
private String username;
private String password;
private Integer age;
private Integer gender;
private String phone;
private Integer deleteFlag;
private Date createTime;
private Date updateTime;
}
2.2、配置数据库毗连字符串
Mybatis中要毗连数据库，必要数据库相干参数配置
• MySQL驱动类
• 登录名
• 密码
• 数据库毗连字符串
如果是application.yml⽂件, 配置内容如下
# 数据库连接配置
spring:
datasource:
url: jdbc:mysql://127.0.0.1:3306/mybatis_test?
characterEncoding=utf8&useSSL=false
username: root
password: root
driver-class-name: com.mysql.cj.jdbc.Driver
留意事项： 如果使用MySQL 是 5.x 之前的使用的是"com.mysql.jdbc.Driver"，如果是⼤于 5.x 使用的是“com.mysql.cj.jdbc.Driver”.
如果是application.properties文件, 配置内容如下:
#驱动类名称
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
#数据库连接的url
spring.datasource.url=jdbc:mysql://127.0.0.1:3306/mybatis_test?
characterEncoding=utf8&useSSL=false
#连接数据库的⽤⼾名
spring.datasource.username=root
#连接数据库的密码
spring.datasource.password=root
2.3、写持久层代码
在项目中, 创建持久层接口UserInfoMapper
https://i-blog.csdnimg.cn/direct/10a8927f497e445db009ed8d6ebce5ac.png
在UserInfo接口中编写以下代码
import com.example.demo.model.UserInfo;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Select;
import java.util.List;
@Mapper
public interface UserInfoMapper {
//查询所有⽤⼾
@Select("select username, `password`, age, gender, phone from userinfo")
public List<UserInfo> queryAllUser();
}
Mybatis的持久层接口规范⼀般都叫 XxxMapper
@Mapper注解：表示是MyBatis中的Mapper接口
• 程序运行时, 框架会主动生成接口的实现类对象(代理对象)，并给交Spring的IOC容器管理
• @Select注解：代表的就是select查询，也就是注解对应方法的具体实现内容
2.4 单位测试
在创建出来的SpringBoot⼯程中，在src下的test目录下，已经目动帮我们创建好了测试类 ，我们可以直接使用这个测试类来进行测试
import com.example.demo.mapper.UserInfoMapper;
import com.example.demo.model.UserInfo;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import java.util.List;
@SpringBootTest
class DemoApplicationTests {
@Autowired
private UserInfoMapper userInfoMapper;
@Test
void contextLoads() {
List<UserInfo> userInfoList = userInfoMapper.queryAllUser();
System.out.println(userInfoList);
}
}
测试类上添加了注解 @SpringBootTest，该测试类在运⾏时，就会⾃动加载Spring的运行情况. 我们通过@Autowired这个注解, 注入我们要测试的类, 就可以开始进行测试了
运行结果如下:
https://i-blog.csdnimg.cn/direct/fe6eea3debe249cb9449f288ebf1326f.png
返回结果中, 可以看到, 只有SQL语句中查询的列对应的属性才有赋值
三、MyBatis的基础操作
上⾯我们学习了Mybatis的查询操作, 接下来我们学习MyBatis的增, 删, 改操作
在学习这些操作之前, 我们先来学习MyBatis日志打印
3.1 打印日志
在Mybatis当中我们可以借助日志, 查看到sql语句的执行、执行传递的参数以及执行结果 在配置文件中进行配置即可
mybatis:
configuration: # 配置打印 MyBatis⽇志
log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
如果是application.properties, 配置内容如下:
#指定mybatis输出⽇志的位置, 输出控制台
mybatis.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl
留意: 后续配置项, 默认只提供⼀种, 请自行进行配置项转换
重新运行程序, 可以看到SQL执行内容, 以及传递参数和执行结果
https://i-blog.csdnimg.cn/direct/db049c70dfa94cd09826d108bc75a095.png
①: 查询语句
②: 传递参数及类型
③: SQL执行结果
3.2、参数传递
需求: 查找id=4的用户,对应的SQL就是: select * from userinfo where id=4
@Select("select username, `password`, age, gender, phone from userinfo where id= 4 ")
UserInfo queryById();
但是这样的话, 只能查找id=4 的数据, 所以SQL语句中的id值不能写成固定数值，必要变为动态的数值解决方案：在queryById方法中添加⼀个参数(id)，将⽅法中的参数，传给SQL语句 使用 #{} 的方式获取方法中的参数
@Select("select username, `password`, age, gender, phone from userinfo where id= #{id} ")
UserInfo queryById(Integer id);
如果mapper接口方法形参只有⼀个普通类型的参数，#{…} ⾥⾯的属性名可以随便写，如：#{id}、#{value}。建媾和参数名保持一致
添加测试用例
@Test
void queryById() {
UserInfo userInfo = userInfoMapper.queryById(4);
System.out.println(userInfo);
}
运行结果：
https://i-blog.csdnimg.cn/direct/93bd1e64ce94495883de625526b1c71b.png
也可以通过 @Param , 设置参数的别名, 如果使用@Param 设置别名, #{…}内里的属性名必须和@Param 设置的⼀样
@Select("select username, `password`, age, gender, phone from userinfo where id= #{userid} ")
UserInfo queryById(@Param("userid") Integer id);
3.3、增(Insert)
SQL 语句:
insert into userinfo (username, `password`, age, gender, phone) values("zhaoliu","zhaoliu",19,1,"18700001234")
把SQL中的常量更换为动态的参数
Mapper接口：
@Insert("insert into userinfo (username, `password`, age, gender, phone) values (#{username},#{password},#{age},#{gender},#{phone})")
Integer insert(UserInfo userInfo);
直接使用UserInfo对象的属性名来获取参数
测试代码：
@Test
void insert() {
UserInfo userInfo = new UserInfo();
userInfo.setUsername("zhaoliu");
userInfo.setPassword("zhaoliu");
userInfo.setGender(2);
userInfo.setAge(21);
userInfo.setPhone("18612340005");
userInfoMapper.insert(userInfo);
}
运行后, 观察数据库执行结果
如果设置了 @Param 属性, #{…} 必要使用参数属性来获取
@Insert("insert into userinfo (username, `password`, age, gender, phone) values (#{userinfo.username},#{userinfo.password},#{userinfo.age},#{userinfo.gender},#{userinfo.phone})")
Integer insert(@Param("userinfo") UserInfo userInfo);
返回主键
Insert 语句默认返回的是受影响的行数，但有些情况下, 数据插入之后, 还必要有后续的关联操作, 必要获取到新插入数据的id
⽐如订单体系
当我们下完订单之后, 必要关照物流体系, 库存体系, 结算体系等, 这时间就必要拿到订单ID
如果想要拿到自增id, 必要在Mapper接⼝的⽅法上添加⼀个Options的注解
@Options(useGeneratedKeys = true, keyProperty = "id")
@Insert("insert into userinfo (username, age, gender, phone) values (#{userinfo.username},#{userinfo.age},#{userinfo.gender},#{userinfo.phone})")
Integer insert(@Param("userinfo") UserInfo userInfo);
• useGeneratedKeys：这会令MyBatis使用JDBC 的 getGeneratedKeys 方法来取出由数据库内部生成的主键（好比：像 MySQL 和 SQL Server 这样的关系型数据库管理体系的主动递增字段），默认值：false.
• keyProperty：指定可以或许唯⼀识别对象的属性，MyBatis 会使用getGeneratedKeys 的返回值或insert 语句的 selectKey 子元素设置它的值，默认值：未设置（unset）
测试数据：
@Test
void insert() {
UserInfo userInfo = new UserInfo();
userInfo.setUsername("zhaoliu");
userInfo.setPassword("zhaoliu");
userInfo.setGender(2);
userInfo.setAge(21);
userInfo.setPhone("18612340005");
Integer count = userInfoMapper.insert(userInfo);
System.out.println("添加数据条数:" + count + ", 数据ID:" + userInfo.getId());
}
运行结果:
https://i-blog.csdnimg.cn/direct/b0d3436c5c59494a9422a0e026c5a0ca.png
留意: 设置 useGeneratedKeys=true 之后, 方法返回值依然是受影响的行数, 自增id 会设置在上述 keyProperty 指定的属性中.
3.4、 删(Delete)
SQL语句：
delete from userinfo where id=6
把SQL中的常量更换为动态的参数
Mapper接口：
@Delete("delete from userinfo where id = #{id}")
void delete(Integer id);
3.5、改(Update)
SQL 语句:
update userinfo set username="zhaoliu" where id=5
把SQL中的常量更换为动态的参数
Mapper接口：
@Update("update userinfo set username=#{username} where id=#{id}")
void update(UserInfo userInfo);
3.6、查(Select)
我们在上⾯查询时发现, 有几个字段是没有赋值的, 只有Java对象属性和数据库字段⼀模⼀样时, 才会进行赋值 接下来我们多查询⼀些数据
@Select("select id, username, `password`, age, gender, phone, delete_flag, create_time, update_time from userinfo")
List<UserInfo> queryAllUser();
查询结果：
https://i-blog.csdnimg.cn/direct/d581c8a317a640efbc24db29f7aa3a9a.png
从运行结果上可以看到, 我们SQL语句中, 查询了delete_flag, create_time, update_time, 但是这几个属性却没有赋值
MyBatis 会根据方法的返回结果进行赋值.
方法用对象 UserInfo接收返回结果, MySQL 查询出来数据为⼀条, 就会主动赋值给对象.
方法用List接收返回结果, MySQL 查询出来数据为⼀条或多条时, 也会主动赋值给List.
但如果MySQL 查询返回多条, 但是方法使⽤UserInfo接收, MyBatis执行就会报错
缘故原由分析:
当主动映射查询结果时，MyBatis 会获取结果中返回的列名并在 Java 类中查找相同名字的属性（忽略巨细写）。这意味着如果发现了 ID 列和 id 属性，MyBatis 会将列 ID 的值赋给 id 属性
解决办法:
[*]起别名
[*]结果映射
[*]开启驼峰命名
3.6.1、起别名
在SQL语句中，给列名起别名，保持别名和实体类属性名⼀样
@Select("select id, username, `password`, age, gender, phone, delete_flag as deleteFlag,create_time as createTime, update_time as updateTime from userinfo")
public List<UserInfo> queryAllUser();
3.6.2 结果映射
@Select("select id, username, `password`, age, gender, phone, delete_flag,
create_time, update_time from userinfo")
@Results({
@Result(column = "delete_flag", property = "deleteFlag"),
@Result(column = "create_time", property = "createTime"),
@Result(column = "update_time", property = "updateTime")
})
List<UserInfo> queryAllUser();
如果其他SQL, 也盼望可以复用这个映射关系, 可以给这个Results界说⼀个名称
@Select("select id, username, `password`, age, gender, phone, delete_flag,
create_time, update_time from userinfo")
@Results(id = "resultMap",value = {
@Result(column = "delete_flag",property = "deleteFlag"),
@Result(column = "create_time",property = "createTime"),
@Result(column = "update_time",property = "updateTime")
})
List<UserInfo> queryAllUser();
@Select("select id, username, `password`, age, gender, phone, delete_flag, create_time, update_time " +
"from userinfo where id= #{userid} ")
@ResultMap(value = "resultMap")
UserInfo queryById(@Param("userid") Integer id);
3.6.3 开启驼峰命名
通常数据库列使用蛇形命名法进行命名(下划线分割各个单词), 而Java 属性⼀般遵照驼峰命名法约定.为了在这两种命名方式之间启用主动映射，必要将 mapUnderscoreToCamelCase 设置为 true。
mybatis:
configuration:
map-underscore-to-camel-case: true #配置驼峰⾃动转换
驼峰命名规则： abc_xyz => abcXyz
• 表中字段名：abc_xyz
• 类中属性名：abcXyz
Java 代码不做任那边置惩罚
@Select("select id, username, `password`, age, gender, phone, delete_flag as deleteFlag, create_time as createTime, update_time as updateTime from userinfo")
public List<UserInfo> queryAllUser();
添加上述配置, 运行代码：
https://i-blog.csdnimg.cn/direct/c256b714b97d434a9e0279e52dde0d5b.png
四、MaBatis XML配置文件
Mybatis的开发有两种方式：
[*]注解
[*]XML
上面学习了注解的方式, 接下来我们学习XML的方式
使用Mybatis的注解方式，重要是来完成⼀些简单的增删改查功能. 如果必要实现复杂的SQL功能，建议使用XML来配置映射语句，也就是将SQL语句写在XML配置文件中.
MyBatis XML的方式必要以下两步:
[*]配置数据库毗连字符串和MyBatis
[*]写持久层代码
4.1、配置毗连字符串和MyBatis
此步调必要进行两项设置，数据库毗连字符串设置和 MyBatis 的XML文件配置。
如果是application.yml文件, 配置内容如下:
# 数据库连接配置
spring:
datasource:
url: jdbc:mysql://127.0.0.1:3306/mybatis_test?
characterEncoding=utf8&useSSL=false
username: root
password: root
driver-class-name: com.mysql.cj.jdbc.Driver
# 配置 mybatis xml 的⽂件路径，在 resources/mapper 创建所有表的 xml ⽂件
mybatis:
mapper-locations: classpath:mapper/**Mapper.xml
如果是application.properties⽂件, 配置内容如下:
#驱动类名称
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
#数据库连接的url
spring.datasource.url=jdbc:mysql://127.0.0.1:3306/mybatis_test?
characterEncoding=utf8&useSSL=false
#连接数据库的⽤⼾名
spring.datasource.username=root
#连接数据库的密码
spring.datasource.password=root
# 配置 mybatis xml 的⽂件路径，在 resources/mapper 创建所有表的 xml ⽂件mybatis.mapper-locations=classpath:mapper/**Mapper.xml 4.2、写持久层代码
持久层代码分两部分
[*]⽅法界说 Interface
[*]⽅法实现: XXX.xml
https://i-blog.csdnimg.cn/direct/da421d51bbdb4c61bff4fb84d823751f.png
4.2.1、添加 mapper 接口
数据持久层的接口界说：
import com.example.demo.model.UserInfo;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
@Mapper
public interface UserInfoXMlMapper {
List<UserInfo> queryAllUser();
}
4.2.1、添加 UserInfoXMLMapper.xml
数据持久成的实现，MyBatis 的固定 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.example.demo.mapper.UserInfoMapper">
</mapper>
创建UserInfoXMLMapper.xml, 路径参考yml中的配置
https://i-blog.csdnimg.cn/direct/dadb77b8d0c04f42a4aad5ce4f982432.png
查询所有用户的具体实现 ：
<?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.example.demo.mapper.UserInfoXMlMapper">
<select id="queryAllUser" resultType="com.example.demo.model.UserInfo">
select username,`password`,age,gender,phone from userinfo
</select>
</mapper>
以下是对以上标签的阐明：
• 标签：必要指定 namespace 属性，表示命名空间，值为 mapper 接⼝的全限定名，包括全包名.类名。
• 查询标签：是用来执行数据库的查询操作的：
◦ id ：是和 Interface （接口）中界说的方法名称⼀样的，表示对接口的具体实现方法。
◦ resultType ：是返回的数据类型，也就是开头我们界说的实体类
https://i-blog.csdnimg.cn/direct/9488c90925924687bdbd382539e27da0.png
4.2.3、单位测试
@SpringBootTest
class UserInfoMapperTest {
@Autowired
private UserInfoMapper userInfoMapper;
@Test
void queryAllUser() {
List<UserInfo> userInfoList = userInfoMapper.queryAllUser();
System.out.println(userInfoList);
}
}
运行结果如下:
https://i-blog.csdnimg.cn/direct/1762e470bf044361aa0552dae3a3e4a2.png
4.3 增删改查操作
接下来，我们来实现⼀下用户的增长、删除和修改的操作.
4.3.1、增(Insert)
UserInfoMapper接口:
Integer insertUser(UserInfo userInfo);
UserInfoMapper.xml实现:
<insert id="insertUser">
insert into userinfo (username, `password`, age, gender, phone) values (#
{username}, #{password}, #{age},#{gender},#{phone})
</insert>
如果使用@Param设置参数名称的话, 使用方法和注解类似
UserInfoMapper接口:
Integer insertUser(@Param("userinfo") UserInfo userInfo)
UserInfoMapper.xml实现:
<insert id="insertUser">
insert into userinfo (username, `password`, age, gender, phone) values(#{userinfo.username},#{userinfo.password},#{userinfo.age},
#{userinfo.gender},#{userinfo.phone})
</insert>
返回自增 id
接口界说稳定, Mapper.xml 实现 设置useGeneratedKeys 和keyProperty属性
<insert id="insertUser" useGeneratedKeys="true" keyProperty="id">
insert into userinfo (username, `password`, age, gender, phone) values
(#{userinfo.username},#{userinfo.password},#{userinfo.age},#
{userinfo.gender},#{userinfo.phone})
</insert>
4.3.2 删(Delete)
UserInfoMapper接口:
Integer deleteUser(Integer id);
UserInfoMapper.xml实现:
<delete id="deleteUser">
delete from userinfo where id = #{id}
</delete>
4.3.3 改(Update)
UserInfoMapper接口:
Integer updateUser(UserInfo userInfo);
UserInfoMapper.xml实现:
<update id="updateUser">
update userinfo set username=#{username} where id=#{id}
</update>
4.3.4 查(Select)
同样的, 使用XML 的方式进行查询, 也存在数据封装的问题 我们把SQL语句进行简单修改, 查询更多的字段内容
<select id="queryAllUser" resultType="com.example.demo.model.UserInfo">
select id, username,`password`, age, gender, phone, delete_flag,
create_time, update_time from userinfo
</select>
运行结果:
https://i-blog.csdnimg.cn/direct/960bbc753c9e4a558bde133919c72636.png
结果表现: deleteFlag, createTime, updateTime 也没有进行赋值
解决办法和注解类似:
. 起别名
. 结果映射
. 开启驼峰命名
此中1,3的解决办法和注解⼀样,不再多说, 接下来看下xml如果来写结果映射：
Mapper.xml：
<resultMap id="BaseMap" type="com.example.demo.model.UserInfo">
<id column="id" property="id"></id>
<result column="delete_flag" property="deleteFlag"></result>
<result column="create_time" property="createTime"></result>
<result column="update_time" property="updateTime"></result>
</resultMap><select id="queryAllUser" resultMap="BaseMap">
select id,username,`password`,age,gender,phone,delete_flag,
create_time,update_time from userinfo
</select>
https://i-blog.csdnimg.cn/direct/e29d83134a5a4eeea52d00b34afddf4d.png
五、其他查询操作
5.1 多表查询
多表查询和单表查询类似, 只是SQL差别而已
5.1.1、准备工作
上面建了⼀张用户表, 我们再来建⼀张文章表, 进行多表关联查询. 文章表的uid, 对应用户表的id.
数据准备：
-- 创建⽂章表
DROP TABLE IF EXISTS articleinfo;
CREATE TABLE articleinfo (
id INT PRIMARY KEY auto_increment,
title VARCHAR ( 100 ) NOT NULL,
content TEXT NOT NULL,
uid INT NOT NULL,
delete_flag TINYINT ( 4 ) DEFAULT 0 COMMENT '0-正常, 1-删除',
create_time DATETIME DEFAULT now(),
update_time DATETIME DEFAULT now()
) DEFAULT charset 'utf8mb4';
-- 插⼊测试数据
INSERT INTO articleinfo ( title, content, uid ) VALUES ( 'Java', 'Java正⽂', 1
);
对应Model:
import lombok.Data;
import java.util.Date;
@Data
public class ArticleInfo {
private Integer id;
private String title;
private String content;
private Integer uid;
private Integer deleteFlag;
private Date createTime;
private Date updateTime;
}
5.1.2、数据查询
需求: 根据uid查询作者的名称等相干信息
SQL:
SELECT
ta.id,
ta.title,
ta.content,
ta.uid,
tb.username,
tb.age,
tb.gender
FROM
articleinfo ta
LEFT JOIN userinfo tb ON ta.uid = tb.id
WHERE
ta.id =1
补充实体类:
@Data
public class ArticleInfo {
private Integer id;
private String title;
private String content;
private Integer uid;
private Integer deleteFlag;
private Date createTime;
private Date updateTime;
//⽤⼾相关信息
private String username;
private Integer age;
private Integer gender;
}
接口界说:
import com.example.demo.model.ArticleInfo;
import org.apache.ibatis.annotations.Mapper;
@Mapper
public interface ArticleInfoMapper {
@Select("SELECT
ta.id, ta.title, ta.content, ta.uid, tb.username, tb.age, tb.gender" +
"FROM articleinfo ta LEFT JOIN userinfo tb ON ta.uid = tb.id "+
"WHERE ta.id = #{id}")
ArticleInfo queryUserByUid(Integer id);
}
如果名称不⼀致的, 接纳ResultMap, 大概别名的⽅式解决, 和单表查询⼀样Mybatis 不分单表还是多表, 重要就是三部分: SQL, 映射关系和实体类
通过映射关系, 把SQL运行结果和实体类关联起来.
5.2、#{} 和 ${}
MyBatis 参数赋值有两种方式, 咱们前⾯使用了 #{} 进行赋值, 接下来我们看下二者的区别
5.2.1 #{} 和${} 使用
[*]先看Interger类型的参数
@Select("select username, `password`, age, gender, phone from userinfo where id= #{id} ")
UserInfo queryById(Integer id);
观察我们打印的日志
https://i-blog.csdnimg.cn/direct/da88a8d823454ac2b740aca5bed9df44.png
发现我们输出的SQL语句：
select username, `password`, age, gender, phone from userinfo where id= ?
我们输⼊的参数并没有在后面拼接，id的值是使用 ? 进行占位. 这种SQL 我们称之为"预编译SQL"
MySQL 课程 JDBC编程使用的就是预编译SQL, 此处不再多说.
我们把 #{} 改成 ${} 再观察打印的日志:
@Select("select username, `password`, age, gender, phone from userinfo where id= ${id} ")
UserInfo queryById(Integer id);
https://i-blog.csdnimg.cn/direct/07c5959b2cc94932bc1b868047d39b59.png
可以看到, 这次的参数是直接拼接在SQL语句中了.
2. 接下来我们再看String类型的参数
@Select("select username, `password`, age, gender, phone from userinfo where username= #{name} ")
UserInfo queryByName(String name);
观察我们打印的日志, 结果正常返回：
https://i-blog.csdnimg.cn/direct/cc59aad70bb5404cb171dbe759d45c67.png
我们把 #{} 改成 ${} 再观察打印的日志:
@Select("select username, `password`, age, gender, phone from userinfo where username= ${name} ")
UserInfo queryByName(String name);
https://i-blog.csdnimg.cn/direct/41aba2bbdbb14296956ccfaa6759d346.png
可以看到, 这次的参数依然是直接拼接在SQL语句中了, 但是字符串作为参数时, 必要添加引号 ‘’ , 使 ⽤ ${} 不会拼接引号 ‘’ , 导致程序报错.
修改代码如下：
@Select("select username, `password`, age, gender, phone from userinfo where username= '${name}' ")
UserInfo queryByName(String name);
再次运行, 结果正常返回
https://i-blog.csdnimg.cn/direct/57016fb455cf4f389500dc9f4b580cc7.png
从上面两个例子可以看出:
#{} 使用的是预编译SQL, 通过 ? 占位的方式, 提前对SQL进行编译, 然后把参数填充到SQL语句 中. #{} 会根据参数类型, 主动拼接引号 ‘’ .
${} 会直接进行字符更换, ⼀起对SQL进行编译. 如果参数为字符串, 必要加上引号 ‘’
参数为数字类型时, 也可以加上, 查询结果稳定, 但是大概会导致索引失效, 性能降落
5.2.2、#{} 和 ${}区别
#{} 和 ${} 的区别就是预编译SQL和即时SQL的区别
简单回顾:
当客户发送⼀条SQL语句给服务器后, 大致流程如下:
1.解析语法和语义, 校验SQL语句是否正确
2.优化SQL语句, 订定执行操持
3.执行并返回结果 、
⼀条 SQL如果走上述流程处置惩罚, 我们称之为 Immediate Statements(即时 SQL)
[*]性能更高
绝⼤多数情况下, 某⼀条 SQL 语句大概会被反复调用执行, 大概每次执行的时间只有个别的值差别(好比 select 的 where ⼦句值差别, update 的 set 子句值差别, insert 的 values 值差别). 如果每次都必要 经过上面的语法解析, SQL优化、SQL编译等，则服从就明显不可了
https://i-blog.csdnimg.cn/direct/b0448ec09f284496835390a342e26516.png
预编译SQL，编译⼀次之后会将编译后的SQL语句缓存起来，后⾯再次执行这条语句时，不会再次编译 (只是输入的参数差别), 省去了解析优化等过程, 以此来提高服从
[*]更安全(防止SQL注入)
SQL注入：是通过操作输入的数据来修改事先界说好的SQL语句，以达到执行代码对服务器进行攻击的方法。
由于没有对用户输⼊进行充实检查，而SQL⼜是拼接而成，在用户输入参数时，在参数中添加⼀些SQL关键字，达到改变SQL运行结果的目的，也可以完成恶意攻击
sql 注⼊代码： ’ or 1='1
先来看看SQL注入的例子：
@Select("select username, `password`, age, gender, phone from userinfo where username= '${name}' ")
List<UserInfo> queryByName(String name);
测试代码:
正常访问情况：
@Test
void queryByName() {
List<UserInfo> userInfos = userInfoMapper.queryByName("admin");
System.out.println(userInfos);
}
结果运行正常
https://i-blog.csdnimg.cn/direct/70866b4d4bbb4000946c2b336b613987.png
SQL注入场景:
@Test
void queryByName() {
List<UserInfo> userInfos = userInfoMapper.queryByName("' or 1='1");
System.out.println(userInfos);
}
结果依然被正确查询出来了, 此中参数 or被当做了SQL语句的⼀部分
https://i-blog.csdnimg.cn/direct/56d3cbb6699a4dda86e2a3a8e6cc4daa.png
可以看出来, 查询的数据并不是自己想要的数据. 所以用于查询的字段，只管使用 #{} 预查询的方式
SQL注⼊是⼀种⾮常常见的数据库攻击本事, SQL注入漏洞也是网络世界中最普遍的漏洞之⼀. 如果发生在用户登录的场景中, 密码输人为 ’ or 1='1 , 就大概完成登录(不是⼀定会发生的场景, 必要看登录代码如何写)
5.3、排序功能
从上面的例子中, 可以得出结论: ${} 会有SQL注⼊的风险, 所以我们只管使用#{}完成查询
既然云云, 是不是 ${} 就没有存在的必要性了呢?
当然不是
接下来我们看下${}的使⽤场景
https://i-blog.csdnimg.cn/direct/e1e1566cbfe6418e937d3e3d973fa35f.png
Mapper实现
@Select("select id, username, age, gender, phone, delete_flag, create_time,
update_time " +
"from userinfo order by id ${sort} ")
List<UserInfo> queryAllUserBySort(String sort);
使用 ${sort} 可以实现排序查询, 而使用 #{sort} 就不能实现排序查询了.
留意: 此处 sort 参数为String类型, 但是SQL语句中, 排序规则是不必要加引号 ‘’ 的, 所以此时的${sort} 也不加引号
我们把 ${} 改成 #{}
@Select("select id, username, age, gender, phone, delete_flag, create_time,
update_time " +
"from userinfo order by id #{sort} ")
List<UserInfo> queryAllUserBySort(String sort);
运行结果:https://i-blog.csdnimg.cn/direct/2f1ff767cfc5412aa54613209eca3651.png
可以发现, 当使用 #{sort} 查询时, asc 前后主动给加了引号, 导致 sql 错误
#{} 会根据参数类型判断是否拼接引号 ‘’
如果参数类型为String, 就会加上引号
除此之外, 还有表名作为参数时, 也只能使用 ${}
5.4、like查询
like 使用 #{} 报错
@Select("select id, username, age, gender, phone, delete_flag, create_time,
update_time " +
"from userinfo where username like '%#{key}%' ")
List<UserInfo> queryAllUserByLike(String key);
把 #{} 改成 $ {} 可以正确查出来, 但是${}存在SQL注入的问题, 所以不能直接使用 ${}.
解决办法: 使用 mysql 的内置函数 concat() 来处置惩罚，实现代码如下：
@Select("select id, username, age, gender, phone, delete_flag, create_time,
update_time " +
"from userinfo where username like concat('%',#{key},'%')")
List<UserInfo> queryAllUserByLike(String key);
六、数据库毗连池
在上⾯Mybatis的讲解中, 我们使⽤了数据库毗连池技术, 避免频繁的创建毗连, 烧毁毗连 ，下面我们来了解下数据库毗连池
6.1、介绍
数据库毗连池负责分配、管理和释放数据库毗连，它允许应⽤程序重复使⽤⼀个现有的数据库毗连，而不是再重新建立⼀个.
https://i-blog.csdnimg.cn/direct/a8cf833c8c754893b94620c89e4a4eed.png
没有使用数据库毗连池的情况: 每次执行SQL语句, 要先创建⼀个新的毗连对象, 然后执行SQL语句, SQL语句执行完, 再关闭毗连对象释放资源. 这种重复的创建毗连, 烧毁毗连比较消耗资源
使用数据库毗连池的情况: 程序启动时, 会在数据库毗连池中创建⼀定数量的Connection对象, 当客户请求数据库毗连池, 会从数据库毗连池中获取Connection对象, 然后执行SQL, SQL语句执行完, 再把Connection归还给毗连池
优点:
[*]减少了网络开销
[*]资源重用
[*]提升了体系的性能
6.2 使用
常见的数据库毗连池：
• C3P0
• DBCP
• Druid
• Hikari
目前比较流行的是 Hikari, Druid
[*] Hikari : SpringBoot默认使用的数据库毗连池
https://i-blog.csdnimg.cn/direct/0657be3914fc45459e2eff09ddb4c322.png
[*] Druid
如果我们想把默认的数据库毗连池切换为Druid数据库毗连池, 只必要引⼊相干依靠即可
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.1.17</version>
</dependency>
运行结果:
https://i-blog.csdnimg.cn/direct/eb173da69e0641bf8025a4325c261f28.png
• Druid毗连池是阿里巴巴开源的数据库毗连池项目
• 功能强大，性能良好，是Java语言最好的数据库毗连池之⼀
七、动态SQL
动态 SQL 是Mybatis的强大特性之⼀，可以或许完成差别条件下差别的 sql 拼接。
7.1、< if >标签
在注册用户的时间，大概会有这样⼀个问题，如下图所示：
https://i-blog.csdnimg.cn/direct/b5fd0d7d851d403580b72dc28380ce6a.png
注册分为两种字段：必填字段和非必填字段，那如果在添加用户的时间有不确定的字段传入，程序应该如何实现呢？ 这个时间就必要使用动态标签来判断了，好比添加的时间性别 gender 为⾮必填字段，具体实现如下：
接口界说:
Integer insertUserByCondition(UserInfo userInfo);
Mapper.xml实现：
<insert id="insertUserByCondition">
INSERT INTO userinfo (
username,
`password`,
age,
<if test="gender != null">
gender,
</if>
phone)
VALUES (
#{username},
#{age},
<if test="gender != null">
#{gender},
</if>
#{phone})
</insert>
留意 test 中的 gender，是传⼊对象中的属性，不是数据库字段
Q: 可不可以不进行判断, 直接把字段设置为null呢?
A: 不可以, 这种情况下, 如果gender字段有默认值, 就会设置为默认值
7.2 、< trim >标签
之前的插入用户功能，只是有⼀个 gender 字段大概是选填项，如果有多个字段，⼀般考虑使用标签结合标签，对多个字段都采取动态生成的方式。
标签中有如部属性：
• prefix：表示整个语句块，以prefix的值作为前缀
• suffix：表示整个语句块，以suffix的值作为后缀
• prefixOverrides：表示整个语句块要去撤除的前缀
• suffixOverrides：表示整个语句块要去撤除的后缀
调整 Mapper.xml 的插入语句为：
<insert id="insertUserByCondition">
INSERT INTO userinfo
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="username !=null">
username,
</if>
<if test="password !=null">
`password`,
</if>
<if test="age != null">
age,
</if>
<if test="gender != null">
gender,
</if>
<if test="phone != null">
phone,
</if>
</trim>
VALUES
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="username !=null">
#{username},
</if>
<if test="password !=null">
#{password},
</if>
<if test="age != null">
#{age},
</if>
<if test="gender != null">
#{gender},
</if>
<if test="phone != null">
#{phone}
</if>
</trim>
</insert>
在以上 sql 动态解析时，会将第⼀个部分做如下处置惩罚：
• 基于 prefix 配置，开始部分加上 (
• 基于 suffix 配置，结束部分加上 )
• 多个构造的语句都以 , 结尾，在末了拼接好的字符串还会以 , 结尾，会基于
suffixOverrides 配置去掉末了⼀个 ,
• 留意 < if test=“username !=null” > 中的 username 是传⼊对象的属性
7.3、< where >标签
看下面这个场景, 体系会根据我们的筛选条件, 动态组装where 条件
https://i-blog.csdnimg.cn/direct/4c1548b7faae4c6ca6686daf50042155.png
这种如何实现呢?
接下来我们看代码实现:
需求: 传入的用户对象，根据属性做where条件查询，用户对象中属性不为 null 的，都为查询条件. 如username 为 “a”，则查询条件为 where username=“a”
原有SQL
SELECT
*
FROM
userinfo
WHERE
age = 18
AND gender = 1
AND delete_flag =0
接口界说:
List<UserInfo> queryByCondition();
Mapper.xml实现：
<select id="queryByCondition" resultType="com.example.demo.model.UserInfo">
select id, username, age, gender, phone, delete_flag, create_time,
update_time
from userinfo
<where>
<if test="age != null">
and age = #{age}
</if>
<if test="gender != null">
and gender = #{gender}
</if>
<if test="deleteFlag != null">
and delete_flag = #{deleteFlag}
</if>
</where>
</select>
< where > 只会在子元素有内容的情况下才插⼊where⼦句，而且会主动去除子句的开头的AND或OR
以上标签也可以使⽤ < trim prefix=“where” prefixOverrides=“and” > 更换, 但是此种 情况下, 当子元素都没有内容时, where关键字也会保存
1.4 、< set >标签
需求: 根据传入的用户对象属性来更新用户数据，可以使用标签来指定动态内容. 接口界说: 根据传⼊的用户id 属性，修改其他不为 null 的属性
Integer updateUserByCondition(UserInfo userInfo);
Mapper.xml
<update id="updateUserByCondition">
update userinfo
<set>
<if test="username != null">
username = #{username},
</if>
<if test="age != null">
age = #{age},
</if>
<if test="deleteFlag != null">
delete_flag = #{deleteFlag},
</if>
</set>
where id = #{id}
</update>
：动态的在SQL语句中插⼊set关键字，并会删掉额外的逗号. (用于update语句中) 以上标签也可以使用 < trim prefix=“set” suffixOverrides=“,” > 更换。
7.5 < foreach>标签
对聚集进行遍历时可以使用该标签。标签有如部属性：
• collection：绑定方法参数中的聚集，如 List，Set，Map或数组对象
• item：遍历时的每⼀个对象
• open：语句块开头的字符串
• close：语句块结束的字符串
• separator：每次遍历之间间隔的字符串需求: 根据多个userid, 删除用户数据
接口方法:
void deleteByIds(List<Integer> ids);
ArticleMapper.xml 中新增删除 sql：
<delete id="deleteByIds">
delete from userinfo
where id in
<foreach collection="ids" item="id" separator="," open="(" close=")">
#{id}
</foreach>
</delete>
7.6 < include >标签
问题分析： • 在xml映射文件中配置的SQL，偶然大概会存在许多重复的片断，此时就会存在许多冗余的代码
https://i-blog.csdnimg.cn/direct/f361f8590b04443985ae35110d2f05b4.png
我们可以对重复的代码片断进行抽取，将其通过 < sql > 标签封装到⼀个SQL片断，然后再通过
< include > 标签进行引用。
• < sql> ：界说可重用的SQL片断
• < include> ：通过属性refid，指定包罗的SQL片断
<sql id="allColumn">
id, username, age, gender, phone, delete_flag, create_time, update_time
</sql
通过 < include > 标签在原来抽取的地方进行引用。操作如下：
<select id="queryAllUser" resultMap="BaseMap">
select
<include refid="allColumn"></include>
from userinfo
</select>
<select id="queryById" resultType="com.example.demo.model.UserInfo">
select
<include refid="allColumn"></include>
from userinfo where id= #{id}
</select>
八、 总结
7.1 MySQL 开发企业规范
[*]表名, 字段名使用小写字目或数字, 单词之间以下划线分割. 只管避免出现数字开头大概两个下划线 中间只出现数字. 数据库字段名的修改代价很大, 所以字段名称必要慎重考虑。
MySQL 在 Windows 下不区分巨细写, 但在 Linux 下默认是区分巨细写. 因此, 数据库名, 表名, 字段名都不允许出现任何大写字母, 避免添枝加叶
正例： aliyun_admin， rdc_config， level3_name
反例： AliyunAdmin， rdcConfig， level_3_name
[*]表必备三字段: id, create_time, update_time
id 必为主键, 类型为 bigint unsigned, 单表时⾃增, 步⻓为 1
create_time, update_time 的类型均为 datetime 类型, create_time表⽰创建时间,
update_time表⽰更新时间 有同等含义的字段即可, 字段名不做强制要求
[*]在表查询中, 避免使⽤ * 作为查询的字段列表, 标明必要哪些字段
[*]增长查询分析器解析成本
2.增减字段容易与 resultMap 配置不⼀致
3.无用字段增长网络络消耗, 尤其是 text 类型的字段
7.2 #{} 和${} 区别
[*]#{}：预编译处置惩罚, ${}：字符直接更换
[*]#{} 可以防止SQL注入, ${}存在SQL注⼊的风险, 查询语句中, 可以使用 #{} ,推荐使用 #{}
[*]但是⼀些场景, #{} 不能完成, 好比 排序功能, 表名, 字段名作为参数时, 这些情况必要使⽤${}
[*]模糊查询虽然${}可以完成, 但因为存在SQL注入的问题,所以通常使用mysql内置函数concat来完成
以上就是本文全部内容，感谢各位可以或许看到末了，盼望各人可以有所收获！创作不易，盼望各人多多支持！
末了，各人再见！祝好！我们下期见！
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。
页:
[1]