ShardingJdbc分表

ShardingJdbc 是一种分表解决方案，它可以将数据库的大表拆分为多个小表，以提高数据库的性能。以下是一个使用 ShardingJdbc 进行分表的简单示例：

1. 添加 Maven 依赖：

<dependency>
    <groupId>org.apache.shardingsphere</groupId>
    <artifactId>sharding-jdbc-core</artifactId>
    <version>您的版本号</version>
</dependency>

2. 配置分片规则（例如，按照用户 ID 分表）：

// 配置数据源
Map<String, DataSource> dataSourceMap = new HashMap<>();
dataSourceMap.put("ds0", dataSource0);
dataSourceMap.put("ds1", dataSource1);
 
// 配置分表规则
ShardingRuleConfiguration shardingRuleConfig = new ShardingRuleConfiguration();
shardingRuleConfig.getTables().add(new ShardingTableRuleConfiguration("user", "ds0.user_0", "ds1.user_1"));
// 分片键为user_id
shardingRuleConfig.getBindingTableGroups().add("user_list");
 
// 分片键生成策略
shardingRuleConfig.setDefaultDatabaseShardingStrategyConfig(new InlineShardingStrategyConfiguration("user_id", "ds${user_id % 2}"));
shardingRuleConfig.setDefaultTableShardingStrategyConfig(new InlineShardingStrategyConfiguration("user_id", "user_${user_id % 2}"));
 
// 获取分片规则
ShardingRule shardingRule = ShardingRule.create(shardingRuleConfig, dataSourceMap);

3. 使用 ShardingJdbc 进行数据库操作：

// 获取ShardingDataSource
DataSource dataSource = ShardingDataSourceFactory.createDataSource(shardingRule, dataSourceMap, new Properties());
 
// 使用ShardingDataSource进行操作
try (Connection conn = dataSource.getConnection();
     PreparedStatement pstmt = conn.prepareStatement("INSERT INTO user (user_id, name) VALUES (?, ?)")) {
    pstmt.setInt(1, 1);
    pstmt.setString(2, "Alice");
    pstmt.executeUpdate();
}

在这个例子中，我们配置了基于用户 ID 的分表规则，并且通过 ShardingDataSourceFactory 创建了一个 ShardingDataSource 实例，用于代替原始的 DataSource。当执行 SQL 插入语句时，ShardingJdbc 会根据用户 ID 的值自动路由到正确的分表中。