springboot shardingsphere分表

在Spring Boot项目中使用ShardingSphere实现分表功能，主要依赖于ShardingSphere-JDBC模块。该模块提供了轻量级的Java库，可以直接集成到Spring Boot项目中，并通过配置文件或编程方式进行分表策略的定义。 ### 配置方式 #### 1. 添加Maven依赖 首先，在项目的`pom.xml`文件中添加ShardingSphere-JDBC的Spring Boot Starter依赖。以下是一个典型的依赖配置示例： ```xml <dependency> <groupId>org.apache.shardingsphere</groupId> <artifactId>sharding-jdbc-spring-boot-starter</artifactId> <version>5.3.0</version> <!-- 注意根据实际情况选择最新版本 --> </dependency> ``` 这个依赖会自动引入相关的类和配置支持，使得分表功能可以通过简单的YAML或properties文件进行配置[^2]。 --- ### 2. 分表规则配置 在`application.yml`中配置数据源以及分表规则。例如，假设我们需要对`user`表按用户ID（`user_id`）进行水平分片，分为两个子表：`user_0` 和 `user_1`，可以如下配置： ```yaml spring: shardingsphere: datasource: names: ds0 ds0: driver-class-name: com.mysql.cj.jdbc.Driver url: jdbc:mysql://localhost:3306/ds0?useSSL=false&serverTimezone=UTC username: root password: root rules: sharding: tables: user: actual-data-nodes: ds0.user_$->{0..1} table-strategy: standard: sharding-column: user_id sharding-algorithm-name: user-table-inline key-generator: column: user_id type: SNOWFLAKE sharding-algorithms: user-table-inline: type: INLINE props: algorithm-expression: user_$->{user_id % 2} ``` 上述配置表示： - 数据源为单个数据库实例`ds0`。 - 对`user`表按照`user_id`字段进行分片，采用模2的方式决定数据进入哪个子表。 - 使用内联表达式`INLINE`来定义分片逻辑，`algorithm-expression`中的`$->{user_id % 2}`决定了具体的分片规则。 - 主键生成策略为`SNOWFLAKE`算法，适用于分布式系统环境下的唯一主键生成[^3]。 --- ### 3. 自定义分片算法（可选） 如果内置的分片算法不能满足业务需求，还可以通过实现`StandardShardingAlgorithm`接口来自定义分片逻辑。例如，以下是一个基于年份的订单分片算法示例： ```java import org.apache.shardingsphere.api.sharding.standard.PreciseShardingAlgorithm; import org.apache.shardingsphere.api.sharding.standard.PreciseShardingValue; import java.util.Collection; public class YearPreciseShardingAlgorithm implements PreciseShardingAlgorithm<Integer> { @Override public String doSharding(Collection<String> availableTargetNames, PreciseShardingValue<Integer> shardingValue) { Integer year = shardingValue.getValue(); for (String each : availableTargetNames) { if (each.endsWith(year.toString())) { return each; } } throw new IllegalArgumentException(); } } ``` 然后在配置文件中引用该算法： ```yaml spring: shardingsphere: rules: sharding: sharding-algorithms: order-year-algorithm: type: CLASS_BASED props: strategy: STANDARD algorithm-class: com.example.YearPreciseShardingAlgorithm ``` 此方法允许开发者根据业务场景灵活地控制数据分布策略[^5]。 --- ### 4. 测试与验证 完成配置后，可以通过编写测试代码来验证分表是否生效。例如，创建一个简单的Controller用于插入和查询数据： ```java @RestController @RequestMapping("/users") public class UserController { @Autowired private UserService userService; @PostMapping("/save") public void saveUser(@RequestBody List<User> users) { userService.insertForeach(users); } @GetMapping("/list") public List<User> listUsers() { return userService.list(); } } ``` 调用`/save`接口插入一批数据后，检查各个子表中数据分布情况，确保符合预期的分片规则。同时也可以通过SQL日志观察实际执行的SQL语句，确认分片效果[^3]。 --- ###