Sharding-JDBC--分库分表中间件

Sharding-JDBC是一款开源的分库分表中间件，由当当网开发并维护。它可以透明化数据库的分片操作，为用户提供标准的数据库访问方式。

以下是一个简单的使用Sharding-JDBC进行分库分表的示例：

1. 在项目的pom.xml中添加Sharding-JDBC依赖：

<dependency>
    <groupId>org.apache.shardingsphere</groupId>
    <artifactId>sharding-jdbc-core</artifactId>
    <version>最新版本</version>
</dependency>

2. 配置分片规则。在src/main/resources下创建配置文件 sharding-jdbc.yml：

shardingRule:
  tables:
    t_order:
      actualDataNodes: ds${0..1}.t_order_${0..1}
      tableStrategy:
        standard:
          shardingColumn: order_id
          shardingAlgorithmName: t_order_inline
      keyGenerateStrategy:
        column: order_id
        keyGeneratorName: snowflake
  bindingTables:
    - t_order,t_order_item
  defaultDatabaseStrategy:
    standard:
      shardingColumn: user_id
      shardingAlgorithmName: database_inline
  shardingAlgorithms:
    t_order_inline:
      type: INLINE
      props:
        algorithm-expression: t_order_${order_id % 2}
    database_inline:
      type: INLINE
      props:
        algorithm-expression: ds${user_id % 2}
  keyGenerators:
    snowflake:
      type: SNOWFLAKE

3. 使用Sharding-JDBC进行数据库操作：

// 加载配置文件
InputStream yamlConfig = YamlShardingRuleConfiguration.class.getResourceAsStream("/sharding-jdbc.yml");
// 获取数据源
DataSource dataSource = ShardingDataSourceFactory.createDataSource(yamlConfig, new Properties(), new NoOpLogEventListener());
// 使用数据源创建连接
Connection conn = dataSource.getConnection();
 
// 执行SQL
String sql = "INSERT INTO t_order (user_id, order_id) VALUES (?, ?)";
PreparedStatement preparedStatement = conn.prepareStatement(sql);
preparedStatement.setInt(1, 10);
preparedStatement.setInt(2, 1000);
preparedStatement.executeUpdate();
 
// 关闭连接
preparedStatement.close();
conn.close();

在这个例子中，我们配置了两个数据源ds0和ds1，以及t_order表根据order_id进行分片，分片结果是t_order_0和t_order_1，同时根据user_id进行数据库分片。在代码中，我们通过Sharding-JDBC提供的ShardingDataSourceFactory来创建数据源，并执行SQL语句。

注意：以上代码仅为示例，实际使用时需要根据实际情况配置数据源和分片规则。