SpringCloud中怎么利用MyBatis-Plus实现CRUD

# SpringCloud中怎么利用MyBatis-Plus实现CRUD

## 一、前言

在现代微服务架构中，SpringCloud作为Java生态的主流框架，与MyBatis-Plus这一强大的ORM工具结合，能够显著提升开发效率。本文将详细介绍如何在SpringCloud项目中整合MyBatis-Plus，并实现基础的CRUD（Create, Read, Update, Delete）操作。

---

## 二、环境准备

### 1. 技术栈版本
- JDK 1.8+
- SpringBoot 2.7.x
- SpringCloud 2021.x
- MyBatis-Plus 3.5.x
- MySQL 8.0

### 2. 项目初始化
通过Spring Initializr创建项目，勾选以下依赖：
```xml
<dependencies>
    <!-- SpringCloud Alibaba Nacos 服务发现 -->
    <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
    </dependency>
    
    <!-- MyBatis-Plus 核心依赖 -->
    <dependency>
        <groupId>com.baomidou</groupId>
        <artifactId>mybatis-plus-boot-starter</artifactId>
        <version>3.5.3</version>
    </dependency>
    
    <!-- MySQL 驱动 -->
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
    </dependency>
</dependencies>

---

三、MyBatis-Plus基础配置

1. 数据源配置

在application.yml中配置数据源和MyBatis-Plus：

spring:
  datasource:
    url: jdbc:mysql://localhost:3306/mp_demo?useSSL=false
    username: root
    password: 123456
    driver-class-name: com.mysql.cj.jdbc.Driver

mybatis-plus:
  configuration:
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl # 开启SQL日志
  global-config:
    db-config:
      logic-delete-field: deleted # 逻辑删除字段
      logic-delete-value: 1
      logic-not-delete-value: 0

2. 主启动类配置

添加@MapperScan注解扫描Mapper接口：

@SpringBootApplication
@MapperScan("com.example.mapper")
public class UserServiceApplication {
    public static void main(String[] args) {
        SpringApplication.run(UserServiceApplication.class, args);
    }
}

---

四、实体类与Mapper设计

1. 实体类定义

使用Lombok简化代码，通过注解实现字段映射：

@Data
@TableName("sys_user") // 指定表名
public class User {
    @TableId(type = IdType.AUTO) // 主键自增
    private Long id;
    
    private String username;
    private Integer age;
    
    @TableField(fill = FieldFill.INSERT) // 自动填充
    private LocalDateTime createTime;
    
    @TableLogic // 逻辑删除标记
    private Integer deleted;
}

2. Mapper接口开发

继承MyBatis-Plus的BaseMapper获得基础CRUD能力：

public interface UserMapper extends BaseMapper<User> {
    // 自定义查询方法
    @Select("SELECT * FROM sys_user WHERE age > #{age}")
    List<User> selectUsersOlderThan(Integer age);
}

---

五、核心CRUD实现

1. 插入操作（Create）

@Service
public class UserServiceImpl implements UserService {
    @Autowired
    private UserMapper userMapper;

    public boolean addUser(User user) {
        return userMapper.insert(user) > 0;
    }
}

2. 查询操作（Read）

基础查询

// 根据ID查询
User user = userMapper.selectById(1L);

// 条件构造器查询
LambdaQueryWrapper<User> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(User::getUsername, "admin")
       .between(User::getAge, 20, 30);
List<User> users = userMapper.selectList(wrapper);

分页查询

需先配置分页插件：

@Configuration
public class MyBatisPlusConfig {
    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor() {
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        interceptor.addInnerInterceptor(new PaginationInnerInterceptor());
        return interceptor;
    }
}

使用示例：

Page<User> page = new Page<>(1, 10); // 当前页，每页数量
userMapper.selectPage(page, null);

3. 更新操作（Update）

// 根据ID更新
User user = new User();
user.setId(1L);
user.setAge(25);
userMapper.updateById(user);

// 条件更新
UpdateWrapper<User> wrapper = new UpdateWrapper<>();
wrapper.set("age", 30)
       .eq("username", "admin");
userMapper.update(null, wrapper);

4. 删除操作（Delete）

// 物理删除
userMapper.deleteById(1L);

// 逻辑删除（需配置逻辑删除字段）
userMapper.deleteById(1L); // 实际执行的是UPDATE语句

---

六、高级特性应用

1. 自动填充功能

实现MetaObjectHandler接口：

@Component
public class MyMetaObjectHandler implements MetaObjectHandler {
    @Override
    public void insertFill(MetaObject metaObject) {
        this.strictInsertFill(metaObject, "createTime", LocalDateTime.class, LocalDateTime.now());
    }
}

2. 乐观锁实现

1. 添加版本号字段并添加注解：

@Version
private Integer version;

1. 配置插件：

interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());

---

七、SpringCloud集成注意事项

1. 多数据源配置

在微服务场景下可能需要连接多个数据库：

@Configuration
@MapperScan(basePackages = "com.example.user.mapper", sqlSessionFactoryRef = "userSqlSessionFactory")
public class UserDataSourceConfig {
    
    @Bean
    @ConfigurationProperties("spring.datasource.user")
    public DataSource userDataSource() {
        return DataSourceBuilder.create().build();
    }
    
    @Bean
    public SqlSessionFactory userSqlSessionFactory(@Qualifier("userDataSource") DataSource dataSource) throws Exception {
        MybatisSqlSessionFactoryBean factoryBean = new MybatisSqlSessionFactoryBean();
        factoryBean.setDataSource(dataSource);
        factoryBean.setMapperLocations(new PathMatchingResourcePatternResolver()
                .getResources("classpath:mapper/user/*.xml"));
        return factoryBean.getObject();
    }
}

2. Feign客户端调用

在服务间调用时处理MyBatis-Plus的Page对象序列化问题：

@FeignClient(name = "user-service")
public interface UserClient {
    @PostMapping("/user/page")
    CommonResult<Page<User>> getUserPage(@RequestBody PageQuery query);
}

---

八、性能优化建议

1. 批量操作：使用saveBatch()方法提升插入效率
2. SQL打印控制：生产环境关闭mybatis-plus.configuration.log-impl
3. 索引优化：为高频查询字段添加数据库索引
4. 二级缓存：合理使用MyBatis二级缓存

---

九、总结

通过本文的实践，我们实现了： - SpringCloud与MyBatis-Plus的无缝整合 - 基础CRUD操作的标准化实现 - 分页查询、逻辑删除等企业级功能 - 微服务环境下的特殊配置处理

MyBatis-Plus的强大功能可以让我们在SpringCloud微服务体系中减少约70%的SQL编写工作量，同时保持代码的可维护性和扩展性。

最佳实践提示：建议将通用CRUD方法封装到BaseService中，各业务Service通过继承复用代码。

完整示例代码可访问：GitHub仓库链接 “`

（注：实际文章约2300字，此处为精简展示。完整版应包含更详细的代码注释、异常处理方案和性能对比数据）