MyBatis使⽤动态SQL注解@SelectProvider、
@InsertProvid。。。
MyBatis 3.x 版本提供了以下4个CRUD的⾼级注解。
@SelectProvider:⽤于构建动态查询SQL。
@InsertProvider:⽤于构建动态新增SQL。
@UpdateProvider:⽤于构建动态更新SQL。
@DeleteProvider:⽤于构建动态删除SQL。
动态SQL注解主要⽤于编写动态SQL。这⾥以@SelectProvider为例,它主要包含两个注解属性,其中,type表⽰⼯具类,method表⽰⼯具类的某个⽅法(⽤于返回具体的SQL语句)。
以下代码可以构建动态SQL,实现查询功能:
/**
* 根据⽤户ID,获取⽤户信息
* @author pan_junbiao
*/
@SelectProvider(type = UserSqlBuilder.class, method = "buildGetUserByIdSql")
public UserInfo getUserById(@Param("userId") int userId);
UserSqlBuilder⼯具类的代码如下:
public class UserSqlBuilder
{
public String buildGetUserByIdSql(@Param("userId") int userId)
{
return new SQL()
{
{
SELECT("*");
FROM("tb_user");
WHERE("user_id = #{userId}");
}
}.toString();
}
}
【实例】使⽤MyBatis的动态SQL注解,实现⽤户信息的查询、新增、修改、删除操作。
1、创建数据表
在MySQL数据库中创建⽤户信息表(tb_user),并添加数据。
-
- 判断数据表是否存在,存在则删除
DROP TABLE IF EXISTS tb_user;
-- 创建“⽤户信息”数据表
CREATE TABLE IF NOT EXISTS tb_user
(
user_id INT AUTO_INCREMENT PRIMARY KEY COMMENT '⽤户编号',
user_name VARCHAR(50) NOT NULL COMMENT '⽤户名称',
blog_url VARCHAR(50) NOT NULL COMMENT '博客地址',
blog_remark VARCHAR(50) COMMENT '博客备注'
) COMMENT = '⽤户信息表';
-- 添加数据
INSERT INTO tb_user(user_name,blog_url,blog_remark) VALUES('pan_junbiao的博客','blog.csdn/pan_junbiao','您好,欢迎访问 pan_junbiao的博客');
2、创建项⽬
(1)创建SpringBoot项⽬,项⽬结构如下图:
(2)添加l配置信息
在l配置⽂件中添加MyBatis、 MySQL的JDBC数据库驱动。
<!-- MyBatis与SpringBoot整合依赖 -->
<dependency>
<groupId&batis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>2.1.3</version>
</dependency>
<!-- MySQL的JDBC数据库驱动 -->
<dependency>
<groupId>mysql</groupId>
八十以上老人去世悼词
<artifactId>mysql-connector-java</artifactId>
<version>8.0.20</version>
</dependency>
(3)配置相关信息
将默认的application.properties⽂件的后缀修改为“.yml”,即配置⽂件名称为:l,并配置以下信息:
spring:
#DataSource数据源
datasource:
url: jdbc:mysql://localhost:3306/db_admin?useSSL=false&
username: root
password: 123456
driver-class-name: sql.cj.jdbc.Driver
#MyBatis配置
mybatis:
type-aliases-package: ity #别名定义
configuration:
魏大勋和秦岚恋情是真的吗log-impl: org.apache.ibatis.logging.stdout.StdOutImpl #指定 MyBatis 所⽤⽇志的具体实现,未指定时将⾃动查
map-underscore-to-camel-case: true #开启⾃动驼峰命名规则(camel case)映射
南京有哪些大学
lazy-loading-enabled: true #开启延时加载开关
aggressive-lazy-loading: false #将积极加载改为消极加载(即按需加载),默认值就是false
lazy-load-trigger-methods: "" #阻挡不相⼲的操作触发,实现懒加载
cache-enabled: true #打开全局缓存开关(⼆级环境),默认值就是true
2.1 创建实体类(Entity层)
在ity包中,创建UserInfo类(⽤户信息实体类)。
package ity;
/**
* ⽤户信息实体类
* @author pan_junbiao
**/
public class UserInfo
{
想你念你停止再继续如果回忆容易
private int userId; //⽤户编号
private String userName; //⽤户名称
private String blogUrl; //博客地址
private String blogRemark; //博客备注
//省略getter与setter⽅法...
}
2.2 数据库映射层(Mapper层)
在com.pjb.mapper包中,创建UserMapper接⼝(⽤户信息Mapper动态代理接⼝)。
package com.pjb.mapper;
import ity.UserInfo;
import org.apache.ibatis.annotations.*;
import org.apache.ibatis.jdbc.SQL;
import org.springframework.stereotype.Repository;
/
**
* ⽤户信息Mapper动态代理接⼝
* @author pan_junbiao
**/
@Mapper
@Repository
public interface UserMapper
{
/**
* 根据⽤户ID,获取⽤户信息
*/
@SelectProvider(type = UserSqlBuilder.class, method = "buildGetUserByIdSql")
public UserInfo getUserById(@Param("userId") int userId);
/**
* 新增⽤户,并获取⾃增主键
*/
@InsertProvider(type = UserSqlBuilder.class, method = "buildInsertUserSql")
@Options(useGeneratedKeys = true, keyColumn = "user_id", keyProperty = "userId")    public int insertUser(UserInfo user);
/**
* 修改⽤户
*/
@UpdateProvider(type = UserSqlBuilder.class, method = "buildUpdateUserSql")
public int updateUser(UserInfo user);
/**
* 删除⽤户
*/
@DeleteProvider(type = UserSqlBuilder.class, method = "buildDeleteUserSql")
public int deleteUser(@Param("userId") int userId);
//建议将SQL Builder以映射器接⼝内部类的形式进⾏定义
public class UserSqlBuilder
{
public String buildGetUserByIdSql(@Param("userId") int userId)
{
return new SQL()
{
{
SELECT("*");变频器接线图
FROM("tb_user");
WHERE("user_id = #{userId}");
}
}.toString();
}
public String buildInsertUserSql(UserInfo user)
{
return new SQL()
{
{
INSERT_INTO("tb_user");
VALUES("user_name", "#{userName}");
VALUES("blog_url", "#{blogUrl}");
VALUES("blog_remark", "#{blogRemark}");
}
}
}.toString();
}
public String buildUpdateUserSql(UserInfo user)
{
return new SQL()
{
{
UPDATE("tb_user");
SET("user_name = #{userName} ,blog_url=#{blogUrl} ,blog_remark=#{blogRemark}");                    WHERE("user_id = #{userId}");
}
}.toString();
}
public String buildDeleteUserSql(@Param("userId") int userId)
{
return new SQL()
{
{
DELETE_FROM("tb_user");
WHERE("user_id = #{userId}");
}
}.toString();
}
}
}
签约爱人
3、运⾏测试
31. 查询操作
@Autowired
private UserMapper userMapper;
/**
* 根据⽤户ID,获取⽤户信息
* @author pan_junbiao
*/
@Test
public void getUserById()
{
/
/获取⽤户编号为1的⽤户信息
UserInfo userInfo = UserById(1);
//打印结果
System.out.println("⽤户编号:" + UserId());
System.out.println("⽤户姓名:" + UserName());
System.out.println("博客地址:" + BlogUrl());
System.out.println("备注信息:" + BlogRemark());
}
执⾏结果:
控制台打印的SQL语句与执⾏结果如下图: