shardingJdbc进行条件查询

ShardingJDBC 是一个基于 JDBC 的 Java 框架，它可以将 SQL 解析和路由到不同的数据库实例中，并且支持水平扩展。进行条件查询时，可以使用 ShardingJDBC 提供的 API 或配置文件的方式来指定表的分片策略和对应的数据库实例，从而实现对分片表的查询操作。

下面是一个使用 ShardingJDBC 进行条件查询的示例：

1. 配置数据源和分片规则

spring:
  sharding:
    jdbc:
      datasource:
        names: ds0,ds1
        ds0:
          driver-class-name: com.mysql.jdbc.Driver
          jdbcUrl: jdbc:mysql://localhost:3306/db0?useUnicode=true&characterEncoding=utf8&useSSL=false
          username: root
          password: root
        ds1:
          driver-class-name: com.mysql.jdbc.Driver
          jdbcUrl: jdbc:mysql://localhost:3306/db1?useUnicode=true&characterEncoding=utf8&useSSL=false
          username: root
          password: root
      config:
        sharding:
          tables:
            user:
              actual-data-nodes: ds$->{0..1}.user_$->{0..2}
              table-strategy:
                inline:
                  sharding-column: id
                  algorithm-expression: user_$->{id % 3}
              key-generator:
                column: id
                type: SNOWFLAKE

2. 进行条件查询

@Autowired
private DataSource dataSource;

@Test
public void testSelect() throws SQLException {
    String sql = "SELECT * FROM user WHERE id = ?";
    try (Connection conn = dataSource.getConnection();
         PreparedStatement ps = conn.prepareStatement(sql)) {
        ps.setLong(1, 1);
        try (ResultSet rs = ps.executeQuery()) {
            while (rs.next()) {
                System.out.println(rs.getLong("id"));
                System.out.println(rs.getString("name"));
            }
        }
    }
}

在上述示例中，我们首先配置了两个数据源 ds0 和 ds1，然后指定了 user 表的分片策略和对应的数据库实例。最后，在进行条件查询时，我们使用了 ShardingJDBC 提供的 DataSource 来获取连接，并执行了相应的 SQL 语句。