Navicat for MySQL 执行 sql 文件过程分析（导入数据），中软国际 Java 笔试题

INSERT INTO es_goods_community (id, goods_id, community_id, status, seller_id) VALUES (8741, 424, 4, 1, 24);

INSERT INTO es_goods_community (id, goods_id, community_id, status, seller_id) VALUES (8742, 424, 5, 1, 24);

Nativeca t 客户端会发送如下包给到 mycat。

• COM_QUERY 类型，，命令为：SET?NAMES?utf8;

《Android学习笔记总结+最新移动架构视频+大厂安卓面试真题+项目实战源码讲义》
浏览器打开：qq.cn.hn/FTe 免费领取

• COM_QUERY 类型，，命令为：SET AUTOCOMMIT=0;

• COM_QUERY 类型，，命令为：

INSERT INTO es_goods_community (id, goods_id, community_id, status, seller_id) VALUES (8741, 424, 4, 1, 24);

INSERT INTO es_goods_community (id, goods_id, community_id, status, seller_id) VALUES (8742, 424, 5, 1, 24);

这里有话说，如果文件内容比较多，会分包处理。但这里是多 multi_statement。

• COM_QUERY 类型，，命令为：COMMIT; 或 rollback;

• COM_QUERY 类型，，命令为：SET AUTOCOMMIT=1;

1、SET 命令执行

SET 命令执行，主要是与 mycat 前端连接打交道，也就是 mysql 客户端---》mycat 前端连接，设置前端连接相应的属性，然后返回设置成功（OK 数据包）即可。

2、COM_QUERY multi_statment ?insert 语句的执行流程

首先进行 SQL 语句解析，将多 insert 语句 转换成单条语句，计算路由，得出在哪些分片上，然后将语句在相应分片上执行，，这个步骤有一个重要的操作，会在本次连接的 NonBlockingSession 中记录在哪些分片上执行过语句，方便对 commit 语句的处理。路由解析在这里暂无深入分析，请关注我后续博文《路由解析篇

3、COMMIT;命令执行

该命令的处理，就是根据第 2 步在哪些分片节点上执行了语句，就在相应分片上执行 commit 命令，达到提交事务的目的。

这里简单阐述一下关键所在，commit 语句没有包含路由信息，那 mycat 是如何将 commit 转发到合适 datanode 上去执行的呢？mycat 是这样处理这个问题的，每一个前端连接(ServerConnection)会有持有一个查询 Hander(QueryHandler),每一个 QueryHanlder 里面会持有一个 NonBlockingSession,在一次完整的命令处理过程中，NonBlockingSession 会保存每个路由节点（执行过的分片节点）与后端连接的 BackConnection 的对应关系（ConcurrentHashMap<RouteResultsetNode,?BackendConnection>?target;）该数据结构在?方法时添加数据，追踪到源头（PhysicalDatasource.getConnection 中方法，关键在内部调用 createNewConnection，其回调方法 connectionAcquired），前端连接使用后端连接的时候，会调用该方法完成该关系的维护，这样能确保 commit 命令到来后，发送到正确的后端连接执行。

/**

*?@return?previous?bound?connection

*/

public?BackendConnection?bindConnection(RouteResultsetNode?key,

BackendConnection?conn)?{

//?System.out.println("bind?connection?"+conn+