shardingjdbc 大体流程

DriverJDBCExecutor#executeQuery

KernelProcessor创建内核处理器

ExecutorEngine#execute

RouteSQLRewriteEngine#rewrite

KernelProcessor#createExecutionContext创建执行器的上下文

如果在事务中会使用序列化的执行方式，否则使用并行的方式

ResultMerger#merge把多条语句的返回值合并

处理 orderBy limit distinct 等语句以及一些数据库信息查询有分为内存处理和流式处理。分页就是使用一个堆进行排序

ShardingStrategy#doSharding调用分片算法进行分片

调用真实的数据源进行执行

ShardingSpherePreparedStatement直接 new 

ShardingSphereDataSource#createContextManager

JDBCExecutor#execute

ShardingSpherePreparedStatement#executeQuery0

DriverStateContext#getConnection

StandaloneContextManagerBuilder#build管理数据库，表的信息

ShardingSpherePreparedStatement#doExecuteQuery

SQLRouter#createRouteContext

commit/rollback

SQLHintUtils#extractHint从 sql 的注释里面解析参数

audit.SQLAuditEngine#audit审计

ShardingSphereResultSet封装一下

MergeEngine#merge

如果有 join order limit则使用 UNION ALL 合并一下

kernel.KernelProcessor#rewrite

MergeEngine#executeMerge

PartialSQLRouteExecutor#findDataSourceByHint如果配置了Hint 这直接返回数据源名称

Connection#prepareStatement

kernel.KernelProcessor#route

SQLParserExecutor#parse使用 antlr 解析sql

ShardingSpherePreparedStatement#createExecutionContext

KernelProcessor#generateExecutionContext

SQLRouteEngine#route

kernel.KernelProcessor#logSQL如果配置了就打印

ShardingSphereConnection直接new出来

如果是 Traffic 类型的则使用 TrafficExecutor开启限流的情况下

ShardingSpherePreparedStatement#executeFederationQuery如果是联邦查询实验性功能

ShardingSpherePreparedStatement#clearPrevious清理之前的数据

ShardingStandardRoutingEngine#route0

JDBCExecutorCallback#execute

ShardingStandardRoutingEngine#routeDataSources

ShardingSphereDataSource#getConnection()

DriverExecutorJDBCExecutorBatchPreparedStatementExecutor创建执行器

ShardingSphereSQLParserEngine#parse解析sql

ShardingSpherePreparedStatement#executeQuery

ShardingAuditAlgorithm#check执行所有配置的审计算法

ShardingSpherePreparedStatement#mergeQuery

OKDriverState#getConnection

ShardingSphereDataSourceFactory#createDataSource

ShardingSphereDataSource

ShardingSpherePreparedStatement#handleAutoCommit开启事务