mysql 集群分库

// 引入ShardingSphere依赖
<dependency>
    <groupId>org.apache.shardingsphere</groupId>
    <artifactId>sharding-jdbc-core</artifactId>
    <version>4.1.1</version>
</dependency>

// 配置分库分表规则
Map<String, DataSource> dataSourceMap = new HashMap<>();
dataSourceMap.put("ds0", createDataSource("jdbc:mysql://localhost:3306/db0"));
dataSourceMap.put("ds1", createDataSource("jdbc:mysql://localhost:3306/db1"));

TableRuleConfiguration tableRuleConfig = new TableRuleConfiguration("t_order", "ds${0..1}.t_order${0..1}");
tableRuleConfig.setDatabaseShardingStrategyConfig(new InlineShardingStrategyConfiguration("user_id", "ds${user_id % 2}"));
tableRuleConfig.setTableShardingStrategyConfig(new InlineShardingStrategyConfiguration("order_id", "t_order${order_id % 2}"));

ShardingDataSource dataSource = new ShardingDataSource(dataSourceMap, Collections.singletonList(tableRuleConfig), new Properties());

// 使用分片数据源进行数据库操作
try (Connection conn = dataSource.getConnection();
     PreparedStatement ps = conn.prepareStatement("SELECT * FROM t_order WHERE user_id = ?")) {
    ps.setInt(1, 123);
    try (ResultSet rs = ps.executeQuery()) {
        while (rs.next()) {
            // 处理查询结果
        }
    }
}