Skip to content
Max / Knowledge

ShardingSphere

Difficulty
Advanced
Status
Stable
Last reviewed
2026年8月

This content is not available in your language yet.

ShardingSphere 把一个 JDBC SQL 请求拆成解析、路由、改写、执行和结果归并五个阶段，在不改变业务访问方式的前提下，把逻辑表映射到多个真实数据源。当前源码还把事务、SPI 扩展和 Mode 持久化作为独立边界，形成可组合的数据库中间件内核。

本册问题地图

Section titled “本册问题地图”

ShardingSphere 的主线是把一条逻辑 SQL 拆成“理解、定位、改写、执行、合并”的流水线：

  1. 为什么先解析 AST？ 只有先理解表、列、条件、排序和分页的结构，后续才能安全地做分片路由和 SQL 改写；字符串替换无法可靠处理嵌套查询和别名。
  2. 路由与改写谁先谁后？ 路由先决定访问哪些真实库表，改写再为每个目标节点生成可执行 SQL；路由错了，后面 SQL 写得再漂亮也只会查错数据。
  3. 归并为什么不是简单拼接？ 多节点结果需要重新排序、聚合、去重或截断分页，逻辑结果集必须恢复单库语义。
  4. 分布式事务覆盖哪一层？ 事务协调要覆盖多个真实连接的提交边界，不能只在代理层把一次逻辑调用标记为成功。
  5. 治理中心解决什么？ 它同步规则和元数据，不直接替代执行引擎；配置传播延迟仍可能让不同实例暂时使用不同路由规则。

版本快照

Section titled “版本快照”
项 值
仓库 apache/shardingsphere
本地路径 E:\source\java\storage\shardingsphere
分支 master
Commit 9b423bee2b930b3f0cd9b637682b5abaf4ebcd5c（2026-08-14）
最近 tag 4.0.0-RC2（浅克隆祖先参考，不代表当前 release）

本册坐标均基于上述 commit。上游演进后行号可能漂移，类名和阶段边界更稳定。

它解决什么问题

Section titled “它解决什么问题”
  • 应用只写逻辑表名，但真实表和数据源可能按分片规则展开成多个执行单元。
  • 一条 SQL 可能需要改写表名、补充参数、拆成多条 SQL，JDBC 结果又必须恢复成一个可迭代结果。
  • 本地事务、XA、Seata AT 和集群治理需要共享元数据，但不能把所有实现硬编码进 JDBC 类。

模块地图

Section titled “模块地图”
模块 职责 关键包
jdbc Driver、Connection、Statement 和执行门面 org.apache.shardingsphere.driver
infra/parser + parser/sql SQL/DistSQL 解析与 AST org.apache.shardingsphere.infra.parser
infra/route SPI 路由器与 RouteContext org.apache.shardingsphere.infra.route
infra/rewrite SQL Token、参数和方言改写 org.apache.shardingsphere.infra.rewrite
infra/executor + jdbc/executor 执行单元、连接和 JDBC 执行 org.apache.shardingsphere.infra.executor
infra/merge 多结果集归并和结果装饰 org.apache.shardingsphere.infra.merge
kernel/transaction + mode 分布式事务、状态和持久化 org.apache.shardingsphere.transaction

读码入口顺序

Section titled “读码入口顺序”
  1. ShardingSphereDriver#connect：JDBC URL 如何得到逻辑连接。
  2. ShardingSphereStatement#executeQuery：请求如何进入 DriverExecutorFacade。
  3. KernelProcessor#generateExecutionContext：解析后的上下文如何变成执行上下文。
  4. ShardingSphereSQLParserEngine#parse：数据库 SQL 与 DistSQL 的双路解析。
  5. SQLRouteEngine#route：规则 SPI 如何产出 RouteUnit。
  6. SQLRewriteEntry#rewrite：路由结果如何变成实际 SQL 和参数。
  7. MergeEngine#merge：多个 QueryResult 如何暴露成一个 MergedResult。
  8. DriverDatabaseConnectionManager#commit：跨物理连接事务如何收口。

本册目录

Section titled “本册目录”

横向对照

Section titled “横向对照”
对象 对照点
MyBatis 都保留 JDBC 边界；MyBatis 重点是 Mapper/Executor，ShardingSphere 重点是 SQL 物理化
Druid 都解析 SQL；Druid 更偏 Parser/连接池/防火墙，ShardingSphere 继续做分布式路由与结果语义
Seata 都处理分布式事务；ShardingSphere 将事务实现接入 JDBC 数据库连接和规则上下文
Section titled “Related”