SpringBoot 项目中使用 ShardingSphere-JDBC 实现订单表按月份分表

以下是一个使用 ShardingSphere-JDBC 完成对订单表按照月份分表的 Spring Boot 配置示例：

1. 在 pom.xml 文件中添加 ShardingSphere-JDBC 的依赖：

<dependency>
    <groupId>org.apache.shardingsphere</groupId>
    <artifactId>shardingsphere-jdbc-core</artifactId>
    <version>5.0.0-alpha</version>
</dependency>

2. 在 application.properties 文件中添加 ShardingSphere-JDBC 的配置，包括数据源、分片规则、分表策略等。

# 数据源配置
spring.datasource.url=jdbc:mysql://localhost:3306/order
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

# 分片规则配置
sharding.jdbc.config.sharding.tables.order.actual-data-nodes=order_0${1..12}.order_${1..31}
sharding.jdbc.config.sharding.tables.order.table-strategy.standard.sharding-column=month
sharding.jdbc.config.sharding.tables.order.table-strategy.standard.precise-algorithm-class-name=org.apache.shardingsphere.shardingalgorithm.sharding.standard.PreciseModuloShardingAlgorithm

# 其他配置
spring.shardingsphere.props.sql.show=true

其中，上述配置中，

• spring.datasource.url、spring.datasource.username、spring.datasource.password、spring.datasource.driver-class-name 是数据源的配置信息，这里使用的是 MySQL 数据库。
• sharding.jdbc.config.sharding.tables.order.actual-data-nodes 指定了分片后的表名，这里使用了两位数和两位数以下的数字作为后缀，共 12 * 31 个表，对应了 12 个月份，每个月份 31 天。
• sharding.jdbc.config.sharding.tables.order.table-strategy.standard.sharding-column 指定了分片策略所需要的列，这里使用了订单的月份作为分片键。
• sharding.jdbc.config.sharding.tables.order.table-strategy.standard.precise-algorithm-class-name 指定了分表策略的实现类，这里使用了取模的算法。

3. 在代码中使用 DataSource 对象来进行数据库操作，ShardingSphere-JDBC 会自动帮助我们路由到正确的分片。

@Autowired
private DataSource dataSource;

public void insertOrder(Order order) {
    String sql = "INSERT INTO order (order_id, user_id, amount, month) VALUES (?, ?, ?, ?)";
    try (Connection conn = dataSource.getConnection();
         PreparedStatement ps = conn.prepareStatement(sql)) {
        ps.setInt(1, order.getOrderId());
        ps.setInt(2, order.getUserId());
        ps.setDouble(3, order.getAmount());
        ps.setInt(4, order.getMonth());
        ps.executeUpdate();
    } catch (SQLException e) {
        e.printStackTrace();
    }
}

public List<Order> getOrdersByMonth(int month) {
    String sql = "SELECT * FROM order WHERE month=?";
    List<Order> orders = new ArrayList<>();
    try (Connection conn = dataSource.getConnection();
         PreparedStatement ps = conn.prepareStatement(sql)) {
        ps.setInt(1, month);
        ResultSet rs = ps.executeQuery();
        while (rs.next()) {
            Order order = new Order();
            order.setOrderId(rs.getInt("order_id"));
            order.setUserId(rs.getInt("user_id"));
            order.setAmount(rs.getDouble("amount"));
            order.setMonth(rs.getInt("month"));
            orders.add(order);
        }
    } catch (SQLException e) {
        e.printStackTrace();
    }
    return orders;
}

这里我们定义了两个方法，一个用于插入订单，一个用于查询某个月份的所有订单。在这两个方法中，我们都是通过获取 DataSource 对象来进行数据库操作的。ShardingSphere-JDBC 会自动帮助我们路由到正确的分片，我们无需关心具体是哪个分片。