PHP PDO 与分库分表结合实践

5次阅读

pdo本身不直接支持分库分表,需结合业务逻辑或中间件实现:手动路由(按分片键计算库表名、白名单校验拼接)、封装shardingpdo类解耦路由与执行、对接mycat等代理中间件透明分片,同时注意跨库事务限制、游标分页及聚合查询优化。

PHP PDO 与分库分表结合实践

php PDO 本身不直接支持分库分表,但可以作为底层数据库连接工具,配合业务逻辑或中间件实现分库分表。关键在于把路由逻辑(哪个表、哪个库)和数据操作解耦,让 PDO 专注执行 sql,路由由上层控制。

手动路由:在业务层决定库与表

这是最直接的方式,适合分片规则简单(如按用户 ID 取模、按时间分月表)的场景。你根据分片键(sharding key)计算目标库名和表名,再用 PDO 连接对应数据库并操作。

  • 维护一个数据库配置映射,例如:[‘db_user_0’ => $dsn0, ‘db_user_1’ => $dsn1]
  • 分表时,将原表名 user 替换为 user_001user_002 等,SQL 中写死或拼接
  • 注意预处理语句中的表名不能参数化(PDO 不允许),需白名单校验后字符串拼接,防止 SQL 注入
  • 事务跨库无法保证一致性,尽量避免跨库写操作;必须跨库时,用本地消息表 + 补偿机制替代分布式事务

封装 PDO 连接管理器

把“选库”“选表”“连接复用”逻辑封装成类,对外提供类似 PDO 的接口,降低业务代码侵入性。

  • 实现 ShardingPDO::prepare() 方法:接收原始 SQL 和分片键,内部解析并重写表名、选择连接实例
  • 连接池可基于 PDO 的持久连接(PDO::ATTR_PERSISTENT => true)或自行实现轻量连接缓存
  • 支持读写分离时,可在路由前判断是否为 select,并自动路由到从库(需结合 SQL 解析或注释提示)

配合代理中间件(如 MyCat、ShardingSphere-JDBC)

让中间件承担分片逻辑,PHP 层仍用标准 PDO 连接中间件地址,对分库分表无感。

立即学习PHP免费学习笔记(深入)”;

  • PDO 连接的是 MyCat 的 mysql 协议端口,SQL 写法保持原样(如 INSERT INTO user),由 MyCat 路由到实际物理库表
  • 需注意中间件限制:部分不支持子查询、复杂 JOIN 或事务嵌套,提前验证兼容性
  • 错误码可能被中间件转换,日志中要记录原始 SQL 和中间件返回信息,方便排查

分页与聚合查询的处理技巧

跨分片查询天然低效,应尽量避免全分片扫描。

  • 分页推荐用“游标分页”(基于上次查询最大 ID 或时间戳),而非 LIMIT offset, size,后者需合并所有分片结果再截取
  • 统计类需求(如 count、SUM)可先在各分片执行,PHP 层汇总;高频统计建议单独建汇总表或用 redis 缓存近似值
  • 关联查询尽量拆成多次单表查询,在 PHP 层组装,比跨库 JOIN 更可控、更易监控
text=ZqhQzanResources