数据分片插件 - 项目介绍

项目简介

基于 Spring Boot + MyBatis + SQLite 的数据分片插件项目，实现了一个强大的 MyBatis 分片插件。通过 @Sharding 注解声明式标记需要分片的 Mapper 方法，配合 ThreadLocal 管理的分片上下文，由 MyBatis 拦截器在 SQL 执行前自动改写 SQL，将分片条件拼接到原始 SQL 中，实现透明的数据分片查询。

工作流程

1

Service 层设置分片上下文（分片总数 + 当前分片索引）

↓

2

调用带 @Sharding 注解的 Mapper 方法

↓

3

ShardingInterceptor 拦截 SQL 执行，读取分片上下文

↓

4

自动将分片条件（如 MOD(id, 3) = 0）拼接到原始 SQL 中

↓

5

执行改写后的 SQL 并返回结果，Service 层清除上下文

核心功能

@Sharding 注解 — 声明式标记需要分片的 Mapper 方法，支持 {totalShards} 和 {currentShard} 占位符
ThreadLocal 分片上下文 — ShardingContextHolder 管理分片总数和当前分片索引
SQL 自动改写 — ShardingInterceptor 拦截器根据分片参数动态改写 SQL
防 ThreadLocal 泄漏 — Service 层查询后自动清除上下文
带条件分片查询 — 支持在分片基础上叠加业务查询条件
内置 CRUD 示例 — 完整的 User 模块演示分片与非分片查询的使用方式

技术栈一览

Java 17 Spring Boot 3.2 MyBatis 3.0.3 SQLite 3.45 ThreadLocal Lombok