当前位置：首页 > news >正文

Spring Boot 3 + MyBatis-Plus + SelectDB整合方案

news 2025/9/22 10:18:48

生产级Spring Boot 3 + MyBatis-Plus + SelectDB整合方案，满足高并发、高可用、高性能要求的完整实现：

pom.xml<?xml version="1.0" encoding="UTF-8"?>
<project><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>3.1.5</version></parent><dependencies><!-- SelectDB核心依赖 --><dependency><groupId>com.selectdb</groupId><artifactId>selectdb-jdbc-driver</artifactId><version>2.0.12</version></dependency><!-- Spring Boot基础组件 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId></dependency><!-- MyBatis-Plus增强组件 --><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>3.5.3.2</version></dependency><!-- 连接池与监控 --><dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-starter</artifactId><version>1.2.18</version></dependency><!-- 其他生产级组件 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-cache</artifactId></dependency><dependency><groupId>org.redisson</groupId><artifactId>redisson-spring-boot-starter</artifactId><version>3.23.2</version></dependency></dependencies>
</project>application.ymlspring:datasource:type: com.alibaba.druid.pool.DruidDataSourceurl: jdbc:mysql://selectdb-cluster:9030/prod_db?useSSL=false&useServerPrepStmts=trueusername: ${SELECTDB_USER}password: ${SELECTDB_PWD}driver-class-name: com.mysql.jdbc.Driverdruid:initial-size: 5max-active: 50min-idle: 5max-wait: 60000validation-query: SELECT 1test-while-idle: truetime-between-eviction-runs-millis: 60000mybatis-plus:configuration:cache-enabled: truedefault-executor-type: REUSEglobal-config:db-config:logic-delete-field: deletedlogic-not-delete-value: 0logic-delete-value: 1management:endpoints:web:exposure:include: health,metrics,prometheus@Configuration
@EnableCaching
public class SelectDBConfig {@Beanpublic MybatisPlusInterceptor mybatisPlusInterceptor() {MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));return interceptor;}@Beanpublic RedissonClient redissonClient() {Config config = new Config();config.useSingleServer().setAddress("redis://redis-cluster:6379").setConnectionMinimumIdleSize(10).setConnectionPoolSize(64);return Redisson.create(config);}@Beanpublic CacheManager cacheManager(RedissonClient redissonClient) {return new RedissonSpringCacheManager(redissonClient);}
}public interface BaseMapperExt<T> extends BaseMapper<T> {@Select("${sql}")List<Map<String, Object>> selectByDynamicSQL(@Param("sql") String sql);@Update("${sql}")int executeUpdate(@Param("sql") String sql);@Options(useGeneratedKeys = true, keyProperty = "id")@Insert("${sql}")int executeInsert(@Param("sql") String sql);
}@Service
@Slf4j
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {@Autowiredprivate RedissonClient redissonClient;@Cacheable(value = "userCache", key = "#id")@Overridepublic User getByIdWithCache(Long id) {return getById(id);}@Override@Transactional(rollbackFor = Exception.class)public boolean batchInsertWithPipe(List<User> users) {RLock lock = redissonClient.getLock("batch_insert_lock");try {lock.lock(10, TimeUnit.SECONDS);// 使用SelectDB Pipe特性批量写入String pipeSQL = "INSERT INTO user VALUES " + users.stream().map(u -> String.format("(%d,'%s')", u.getId(), u.getName())).collect(Collectors.joining(","));return baseMapper.executeUpdate(pipeSQL) > 0;} finally {lock.unlock();}}
}@Component
public class SelectDBHealthIndicator implements HealthIndicator {@Autowiredprivate DataSource dataSource;@Overridepublic Health health() {try (Connection conn = dataSource.getConnection()) {boolean valid = conn.isValid(5);return valid ? Health.up().build() : Health.down().withDetail("error", "Connection test failed").build();} catch (Exception e) {return Health.down(e).build();}}
}

代码说明：