软件架构-Sharding-Sphere特性详解
上次通过源码的方式演示了sharding-sphere，分库分表的实现，还有他的原理，不知道老铁拿到代码后跑一下看看。如果试过的老铁，麻烦在评论里面回复下。这次围绕上次分库分表，继续说下shardingShpere是如何做到的代码层面是如何实现的。分库分表写入的都是逻辑表，很多语句都是要进行改写的。
JDBC规范重写
SQL解析（一）
1.数据库类型dbType；2.分库分表规则shardingRule；3.词法分析器引擎lexerEngine；
SQL语句
SELECT
a.id
a.name
FROM order a
WHERE a.id = 1
解析成
实例代码
@Test
public void assertParseWithoutParameter() throws SQLException {
ShardingRule shardingRule = createShardingRule();//创建分片规则
SQLParsingEngine statementParser = new SQLParsingEngine(DatabaseType.MySQL, "INSERT INTO `TABLE_XXX` (`field1`, `field2`) VALUES (10, 1)", shardingRule);//解析sql引擎
InsertStatement insertStatement = (InsertStatement) statementParser.parse();//解析sql开始
System.out.println("sql解析tables："+insertStatement.getTables());
List<SQLToken> list=insertStatement.getSqlTokens();
for(SQLToken sqlToken:list){
System.out.println(sqlToken);
}
System.out.println("toString:"+insertStatement.toString());
}
SQL语句拆解成TokenType的对象，
SQL路由（二）
路由方式分为：单表（single）、联表（binding） 混合（mix） 经过 SQL解析、SQL路由后，产生SQL路由结果，即 SQLRouteResult。根据路由结果，生成SQL，执行SQL。io.shardingjdbc.core.routing.router.SQLRouter#parse 解析接口 io.shardingjdbc.core.routing.router.SQLRouter#route 路由接口
DatabaseHintSQLRouter，基于数据库提示的路由器 ParsingSQLRouter，需要解析的SQL路由器
<sharding:props>
<prop key="sql.show">true</prop>
</sharding:props>•① 单表
全表查询
通过查询指定路由到表
•② 联表
联表-单库
•③ 混合
SQL改写（三）
SQLRewriteEngine，SQL重写引擎，实现 SQL 改写、生成功能
SQL执行（四）
解析完成sql、路由也完成了，现在进行真正执行的时候了。
• ① ExecutorEngine> sql执行引擎
com.google.common.util.concurrent.ListeningExecutorService 线程池
•② PreparedStatementExecutor>预编译sql执行器
io.shardingjdbc.core.executor.ExecutorEngine#executePreparedStatement
•③ EventBus>Sql执行事件
io.shardingjdbc.core.executor.event.EventExecutionType 三种类型事件
结果归集（五）
改写sql会变成多条，这个时候我们就需要把每个库查出来的结果合并。主要是：分页、分组、排序、聚合、迭代。
PS：这篇写的比较琐碎，没说太多源码只是通过图片的方式说明流程：sql语句，sql路由，sql改写，sql执行这几种方式来针对sql进行分库分表，到实战的时候好好说下吧。目前的shardingjdbc里面有个proxy，nativecat可以直接访问proxy的形式来操作逻辑表的方式，来底层操作物理表。如果分库分表比较多的话，不通过proxy来完成的话，真是一场灾难。