java 分库分表的中间件

Java分库分表中间件有很多，比如ShardingSphere、MyCAT、TDDL(Taobao Distributed Data Layer)等。

以ShardingSphere为例，以下是一个简单的使用示例：

1. 添加依赖到你的项目中（以Maven为例）：

<dependency>
    <groupId>org.apache.shardingsphere</groupId>
    <artifactId>sharding-jdbc-core</artifactId>
    <version>4.0.0-RC1</version>
</dependency>

2. 配置数据源：

// 配置真实数据源
Map<String, DataSource> dataSourceMap = new HashMap<>();
 
// 配置第一个数据源
BasicDataSource dataSource1 = new BasicDataSource();
dataSource1.setDriverClassName("com.mysql.jdbc.Driver");
dataSource1.setUrl("jdbc:mysql://localhost:3306/ds0");
dataSource1.setUsername("root");
dataSource1.setPassword("");
dataSourceMap.put("ds0", dataSource1);
 
// 配置第二个数据源
BasicDataSource dataSource2 = new BasicDataSource();
dataSource2.setDriverClassName("com.mysql.jdbc.Driver");
dataSource2.setUrl("jdbc:mysql://localhost:3306/ds1");
dataSource2.setUsername("root");
dataSource2.setPassword("");
dataSourceMap.put("ds1", dataSource2);
 
// 配置Order表规则，指定数据源ds0和ds1
ShardingRuleConfig shardingRuleConfig = new ShardingRuleConfig();
shardingRuleConfig.getTables().add(new ShardingTableRuleConfig("t_order", "ds${0..1}.t_order_${0..1}"));
 
// 配置分片键生成策略
shardingRuleConfig.setDefaultDatabaseShardingStrategyConfig(new InlineShardingStrategyConfig("user_id", "ds${user_id % 2}"));
shardingRuleConfig.setDefaultTableShardingStrategyConfig(new InlineShardingStrategyConfig("order_id", "t_order_${order_id % 2}"));
 
// 获取ShardingDataSource
DataSource dataSource = ShardingDataSourceFactory.createDataSource(dataSourceMap, shardingRuleConfig, new ConcurrentHashMap(), new Properties());

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

// 获取连接
Connection conn = dataSource.getConnection();
 
// 创建Statement
Statement statement = conn.createStatement();
 
// 执行SQL
statement.executeUpdate("INSERT INTO t_order (user_id, order_id) VALUES (10, 1000)");
 
// 关闭连接
conn.close();

以上代码展示了如何配置ShardingSphere的数据源，并定义了分库和分表的规则。在实际使用时，你需要根据自己的数据库配置、分片键和分片策略进行相应的调整。