新版架构师系列-ShardingJDBC分库分表mysql数据库实战-当你的单表数据突破千万级，查询从毫秒级堕落到秒级，CPU常年95%

应用发起 SQL
    ↓
① SQL 解析 —— 词法解析 + 语法解析 → 生成抽象语法树（AST）
    ↓
② 分片路由 —— 根据分片策略计算目标库/表（单片路由 / 多片路由 / 广播路由）
    ↓
③ SQL 改写 —— 将逻辑表名改写为真实表名（如 t_order → t_order_3）
    ↓
④ 执行引擎 —— 并行/串行发送到目标数据源执行
    ↓
⑤ 结果归并 —— 聚合、排序、分页 → 返回统一结果

xml<dependency>
    <groupId>org.apache.shardingsphere</groupId>
    <artifactId>shardingsphere-jdbc-core-spring-boot-starter</artifactId>
    <version>5.3.2</version>
</dependency>
<dependency>
    <groupId>com.mysql</groupId>
    <artifactId>mysql-connector-j</artifactId>
    <scope>runtime</scope>
</dependency>

sql-- 创建 2 个数据库
CREATE DATABASE order_db_0;
CREATE DATABASE order_db_1;

-- 每个库创建 4 张表（2库 × 4表 = 8个物理表）
-- order_db_0: t_order_0, t_order_1, t_order_2, t_order_3
-- order_db_1: t_order_0, t_order_1, t_order_2, t_order_3

yamlspring:
  shardingsphere:
    datasource:
      names: ds0, ds1
    ds0:
      type: com.zaxxer.hikari.HikariDataSource
      driver-class-name: com.mysql.cj.jdbc.Driver
      jdbc-url: jdbc:mysql://localhost:3306/order_db_0?useSSL=false&serverTimezone=UTC
      username: root
      password: 123456
    ds1:
      type: com.zaxxer.hikari.HikariDataSource
      driver-class-name: com.mysql.cj.jdbc.Driver
      jdbc-url: jdbc:mysql://localhost:3306/order_db_1?useSSL=false&serverTimezone=UTC
      username: root
      password: 123456

    rules:
      sharding:
        tables:
          t_order:
            actual-data-nodes: ds$->{0..1}.t_order_$->{0..3}
            #           ↓ 分库（ds0, ds1）  ↓ 分表（0~3）
            database-strategy:
              standard:
                sharding-column: user_id
                sharding-algorithm-name: db-hash-mod
            table-strategy:
              standard:
                sharding-column: order_id
                sharding-algorithm-name: table-hash-mod
        sharding-algorithms:
          db-hash-mod:
            type: HASH_MOD
            props:
              sharding-count: 2
          table-hash-mod:
            type: HASH_MOD
            props:
              sharding-count: 4
        props:
          sql-show: true  # 打印真实 SQL，调试必备

java@Data
@TableName("t_order")  // 逻辑表名，Sharding-JDBC 自动路由
public class Order {
    private Long orderId;
    private Long userId;
    private BigDecimal amount;
    private String status;
}

@Mapper
public interface OrderMapper {
    @Insert("INSERT INTO t_order (order_id, user_id, amount, status) VALUES (#{orderId}, #{userId}, #{amount}, #{status})")
    void insert(Order order);

    @Select("SELECT * FROM t_order WHERE user_id = #{userId}")
    List<Order> findByUserId(@Param("userId") Long userId);
}

// 调用——就像操作单表一样简单！
@Autowired
private OrderMapper orderMapper;

public void createOrder() {
    Order order = new Order();
    order.setOrderId(20260520001L);
    order.setUserId(1001L);
    order.setAmount(new BigDecimal("99.99"));
    order.setStatus("PAID");
    orderMapper.insert(order);  // 自动路由到 ds1.t_order_1
}