MyBatisPlus 15个高级用法详解

// 简单查询，用 Service 的 lambdaQuery
List<User> users = userService.lambdaQuery()
                .eq(User::getStatus, 1)
                .like(User::getName, "张")
                .list();
// 复杂查询，用 Mapper + XML 或注解！
// 在 UserMapper.java 中
@Select("SELECT u.*, d.dept_name FROM user u LEFT JOIN dept d ON u.dept_id = d.id WHERE u.id = #{userId}")
UserVO selectUserDetail(@Param("userId") Long userId);

// 【错误姿势】字段名是字符串，容易拼错，编译器不报错
userService.lambdaQuery().eq("naem", "张三"); // 运行才报错，哭死！
// 【正确姿势】使用方法引用，安全又优雅
userService.lambdaQuery().eq(User::getName, "张三"); 
// 编译不通过，立马改正！

// 创建分页参数，并指定排序
Page<User> page = new Page<>(1, 20); // 查第1页，每页20条
page.addOrder(OrderItem.desc("create_time")); // 按创建时间倒序
// 执行分页查询
Page<User> userPage = userService.page(page,
        Wrappers.<User>lambdaQuery()
                .eq(User::getDeptId, 2)
);
// 直接转换为 VO 分页对象，一步到位
Page<UserVO> voPage = userPage.convert(user -> {
    UserVO vo = new UserVO();
    BeanUtils.copyProperties(user, vo); // 使用 Spring 的工具类
    // 或者用 MapStruct 等更专业的工具
    return vo;
});

// 批量插入，分批提交
List<User> hugeUserList = ... // 一个巨大的列表
userService.saveBatch(hugeUserList, 1000); // 每1000条批量提交一次
// 批量更新（自己控制事务）
@Transactional(rollbackFor = Exception.class)
public void batchUpdateStatus(List<Long> ids, Integer status) {
    List<User> updateList = ids.stream().map(id -> {
        User user = new User();
        user.setId(id);
        user.setStatus(status);
        return user;
    }).collect(Collectors.toList());
    userService.updateBatchById(updateList);
}

// 复杂的 AND-OR 组合查询
List<User> users = userService.lambdaQuery()
    .eq(User::getStatus, 1)
    .and(wrapper -> wrapper // 这是一个 AND 嵌套
        .like(User::getName, "张")
        .or()
        .like(User::getEmail, "zhang") // name LIKE '%张%' OR email LIKE '%zhang%'
    )
    .between(User::getCreateTime, startTime, endTime)
    .list();
// 【性能技巧】只查需要的字段，避免 SELECT *
List<User> userList = userService.lambdaQuery()
    .select(User::getId, User::getName) // 只查询 ID 和 Name 字段
    .eq(User::getStatus, 1)
    .list();

@Component
public class MyMetaObjectHandler implements MetaObjectHandler {
    @Override
    public void insertFill(MetaObject metaObject) {
        // 插入时自动填充
        this.strictInsertFill(metaObject, "createTime", LocalDateTime.class, LocalDateTime.now());
        this.strictInsertFill(metaObject, "createBy", String.class, getCurrentUser());
    }
    @Override
    public void updateFill(MetaObject metaObject) {
        // 更新时自动填充
        this.strictUpdateFill(metaObject, "updateTime", LocalDateTime.class, LocalDateTime.now());
    }
}
// 实体类字段上需要加注解
public class User {
    @TableField(fill = FieldFill.INSERT)
    private LocalDateTime createTime;
    @TableField(fill = FieldFill.INSERT_UPDATE)
    private LocalDateTime updateTime;
}

# 在 application.yml 中配置
mybatis-plus:
  global-config:
    db-config:
      logic-delete-field: deleted  # 全局逻辑删除实体字段名
      logic-delete-value: 1        # 逻辑已删除值（默认为 1）
      logic-not-delete-value: 0    # 逻辑未删除值（默认为 0）

@Getter
public enum UserStatus {
    ENABLED(1, "启用"),
    DISABLED(0, "禁用");
    private final int code;
    private final String desc;
    UserStatus(int code, String desc) {
        this.code = code;
        this.desc = desc;
    }
}
// 实体类中直接使用枚举类型
public class User {
    private UserStatus status;
}
// 配置枚举处理器（Spring Boot 基本不用配了，开箱即用）

@Configuration
public class MybatisPlusConfig {
    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor() {
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        // 租户插件
        TenantLineInnerInterceptor tenantInterceptor = new TenantLineInnerInterceptor();
        tenantInterceptor.setTenantLineHandler(new TenantLineHandler() {
            @Override
            public Expression getTenantId() {
                // 从当前上下文中获取租户ID，比如从 JWT Token 中
                return new StringValue(TenantContext.getCurrentTenantId());
            }
            @Override
            public String getTenantIdColumn() {
                return "tenant_id"; // 数据库中的租户ID列名
            }
            @Override
            public boolean ignoreTable(String tableName) {
                // 忽略不需要租户隔离的表，如全局配置表
                return "system_config".equals(tableName);
            }
        });
        interceptor.addInnerInterceptor(tenantInterceptor);
        return interceptor;
    }
}

public class CodeGenerator {
    public static void main(String[] args) {
        AutoGenerator generator = new AutoGenerator();
        // 数据源配置
        DataSourceConfig dataSourceConfig = new DataSourceConfig();
        dataSourceConfig.setUrl("jdbc:mysql://localhost:3306/test");
        dataSourceConfig.setDriverName("com.mysql.cj.jdbc.Driver");
        dataSourceConfig.setUsername("root");
        dataSourceConfig.setPassword("123456");
        generator.setDataSource(dataSourceConfig);
        // 全局配置
        GlobalConfig globalConfig = new GlobalConfig();
        globalConfig.setOutputDir(System.getProperty("user.dir") + "/src/main/java");
        globalConfig.setAuthor("大华");
        globalConfig.setOpen(false);
        globalConfig.setSwagger2(true); // 实体属性 Swagger2 注解
        generator.setGlobalConfig(globalConfig);
        // 包配置
        PackageConfig packageConfig = new PackageConfig();
        packageConfig.setParent("com.laomao.demo");
        packageConfig.setEntity("domain.entity");
        packageConfig.setMapper("dao.mapper");
        packageConfig.setService("service");
        packageConfig.setServiceImpl("service.impl");
        generator.setPackageInfo(packageConfig);
        generator.execute(); // 执行生成
    }
}

@Component
@Slf4j
public class SqlLogInterceptor implements InnerInterceptor {
    @Override
    public void beforeQuery(Executor executor, MappedStatement ms, Object parameter, BoundSql boundSql) {
        long start = System.currentTimeMillis();
        // 将开始时间存入当前线程上下文
    }
    @Override
    public void afterQuery(Executor executor, MappedStatement ms, Object parameter, BoundSql boundSql, List<Object> result) {
        long end = System.currentTimeMillis();
        long cost = end - start;
        if (cost > 1000) { // 超过1秒算慢SQL
            log.warn("慢SQL警告: {}, 执行耗时: {}ms", boundSql.getSql(), cost);
            // 可以接入告警系统，通知开发人员
        }
    }
}

public class User {
    // 指定主键类型为 ASSIGN_ID（雪花算法）
    @TableId(type = IdType.ASSIGN_ID)
    private Long id; // 注意是 Long，不是 Integer
    // ...
}

// 实体类中增加版本号字段
public class User {
    @Version
    private Integer version;
}
// 更新时，MP会自动带上版本号条件
User user = userService.getById(1L);
user.setName("新名字");
userService.updateById(user); // SQL: UPDATE user SET name=?, version=? WHERE id=? AND version=?

// 在 Mapper 方法上使用复杂结果映射
@Select("SELECT u.*, d.name as dept_name FROM user u LEFT JOIN department d ON u.dept_id = d.id WHERE u.id = #{id}")
@Results({
    @Result(column = "id", property = "id"),
    @Result(column = "dept_name", property = "deptName"),
    @Result(column = "id", property = "roles", 
            many = @Many(select = "com.laomao.mapper.RoleMapper.findByUserId"))
})
UserVO findUserWithDept(Long id);

@Service
public class UserService {
    @Transactional(rollbackFor = Exception.class) // 注意：默认只回滚 RuntimeException
    public void createUserWithInitData(User user) {
        // 1. 保存用户基本信息
        userService.save(user);
        // 2. 初始化用户账户
        Account account = new Account();
        account.setUserId(user.getId());
        accountService.save(account);
        // 3. 发送欢迎消息（如果消息发送失败，希望用户创建也回滚）
        messageService.sendWelcomeMessage(user.getId());
        // 任何一个步骤出错，所有操作都会回滚
    }
}