源码分析MySQL mysql_real_query函数

野性酷女 2022-03-21 12:10 461阅读 0赞

# **目录** #

目录 1

1. 前言 1

2. 调用路径 2

3. MAX\_PACKET\_LENGTH宏 2

4. DBUG\_RETURN宏 3

5. COM\_QUERY枚举值 3

6. mysql\_query函数 3

7. mysql\_real\_query函数 3

8. mysql\_send\_query函数 4

9. simple\_command宏 5

10. MYSQL\_METHODS结构体 5

11. cli\_advanced\_command函数 6

12. int3store函数 7

13. net\_write\_command函数 8

14. net\_write\_buff函数 10

15. net\_write\_packet函数 11

16. net\_write\_raw\_loop函数 12

17. Vio结构体 13

18. vio\_write函数 14

19. inline\_mysql\_socket\_send函数 15

20. net\_realloc函数 15

21. net\_read\_packet函数 16

22. mysql\_real\_connect函数 16

23. mysql\_init函数 18

24. Packet Too Large 19

25. 分析结论 19

# **1. 前言** #

Review一同事的C++代码，发现其中有一个拼接而成的多记录INSERT语句可能超大（预计最大可超过1M，甚至10M也有可能，视实际记录条数而定）。担心包大存隐患，所以特意分析一下mysql\_real\_query函数的实现，以确保使用是否安全。研究对象为MySQL-8.0.14，其它版本可能有小许差异，但估计差异不会太大。

# **2. 调用路径** #

1) mysql\_real\_query调用路径

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> &nbsp;&nbsp;&nbsp;mysql_real_query -&gt;&nbsp;mysql_send_query -&gt;&nbsp;simple_command -&gt;&nbsp;cli_advanced_command -&gt;&nbsp;net_write_command -&gt;&nbsp;net_write_buff -&gt;&nbsp;net_write_packet -&gt;&nbsp;net_write_raw_loop -&gt;&nbsp;vio_write -&gt;&nbsp;struct&nbsp;Vio::write(...) -&gt;&nbsp;io_write -&gt;&nbsp;inline_mysql_socket_send -&gt;&nbsp;send&nbsp;//&nbsp;系统调用 </td> 
 </tr> 
 </tbody> 
</table>

2) mysql\_real\_connect调用路径

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> &nbsp;&nbsp;&nbsp;//&nbsp;在调用mysql_real_connect之前， &nbsp;&nbsp;&nbsp;//&nbsp;需要先调用mysql_init完成MYSQL结构的初始化 &nbsp;&nbsp;&nbsp;mysql_real_connect(MYSQL*) -&gt;&nbsp;my_net_init -&gt;&nbsp;my_net_local_init&nbsp;//&nbsp;初始化包大小max_packet_size </td> 
 </tr> 
 </tbody> 
</table>

# **3. MAX\_PACKET\_LENGTH宏** #

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;Maximum&nbsp;length&nbsp;of&nbsp;protocol&nbsp;packet. //&nbsp;@ref&nbsp;page_protocol_basic_ok_packet&nbsp;length&nbsp;limit&nbsp;also&nbsp;restricted&nbsp;to&nbsp;this&nbsp;value //&nbsp;as&nbsp;any&nbsp;length&nbsp;greater&nbsp;than&nbsp;this&nbsp;value&nbsp;will&nbsp;have&nbsp;first&nbsp;byte&nbsp;of //&nbsp;@ref&nbsp;page_protocol_basic_ok_packet&nbsp;to&nbsp;be&nbsp;254&nbsp;thus&nbsp;does&nbsp;not //&nbsp;provide&nbsp;a&nbsp;means&nbsp;to&nbsp;identify&nbsp;if&nbsp;this&nbsp;is&nbsp;@ref&nbsp;page_protocol_basic_ok_packet&nbsp;or //&nbsp;@ref&nbsp;page_protocol_basic_eof_packet. // //&nbsp;定义一个包的最大字节数（值为16MB）， //&nbsp;因为是个宏，所以无法编译期修改。 //&nbsp;但是否意味着只能向MySQL&nbsp;server发送小于16M的包了？ //&nbsp;答案是否，如果包大小超过这个值， //&nbsp;则返回错误CR_NET_PACKET_TOO_LARGE（ER_NET_PACKET_TOO_LARGE） //&nbsp;CR_NET_PACKET_TOO_LARGE的值为2020 #define&nbsp;MAX_PACKET_LENGTH&nbsp;(256L&nbsp;*&nbsp;256L&nbsp;*&nbsp;256L&nbsp;-&nbsp;1)&nbsp;//&nbsp;16MB </td> 
 </tr> 
 </tbody> 
</table>

# **4. DBUG\_RETURN宏** #

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;process&nbsp;exit&nbsp;from&nbsp;user&nbsp;function #define&nbsp;DBUG_LEAVE&nbsp;\ &nbsp;&nbsp;&nbsp;&nbsp;_db_return_(__LINE__,&nbsp;&amp;_db_stack_frame_) #define&nbsp;DBUG_RETURN(a1)&nbsp;\ &nbsp;&nbsp;do&nbsp;{&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;\ &nbsp;&nbsp;&nbsp;&nbsp;DBUG_LEAVE;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;\ &nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;(a1);&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;\ &nbsp;&nbsp;}&nbsp;while&nbsp;(0) </td> 
 </tr> 
 </tbody> 
</table>

# **5. COM\_QUERY枚举值** #

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;A&nbsp;list&nbsp;of&nbsp;all&nbsp;MySQL&nbsp;protocol&nbsp;commands //&nbsp;These&nbsp;are&nbsp;the&nbsp;top&nbsp;level&nbsp;commands&nbsp;the&nbsp;server&nbsp;can&nbsp;receive //&nbsp;while&nbsp;it&nbsp;listens&nbsp;for&nbsp;a&nbsp;new&nbsp;command&nbsp;in&nbsp;::dispatch_command enum&nbsp;enum_server_command { &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;COM_QUERY为mysql_real_query对应的命令字 &nbsp;&nbsp;&nbsp;&nbsp;COM_QUERY&nbsp;//&nbsp;See&nbsp;@ref&nbsp;page_protocol_com_query &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 }; </td> 
 </tr> 
 </tbody> 
</table>

# **6. mysql\_query函数** #

# **7. mysql\_real\_query函数** #

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;Do&nbsp;a&nbsp;query.&nbsp;If&nbsp;query&nbsp;returned&nbsp;rows,&nbsp;free&nbsp;old&nbsp;rows. //&nbsp;Read&nbsp;data&nbsp;by&nbsp;mysql_store_result&nbsp;or //&nbsp;by&nbsp;repeat&nbsp;call&nbsp;of&nbsp;mysql_fetch_row //&nbsp;client.cc int&nbsp;STDCALL&nbsp;mysql_real_query( &nbsp;&nbsp;&nbsp;&nbsp;MYSQL&nbsp;*mysql, &nbsp;&nbsp;&nbsp;&nbsp;const&nbsp;char&nbsp;*query,&nbsp;ulong&nbsp;length) { &nbsp;&nbsp;int&nbsp;retval; &nbsp;&nbsp; &nbsp;&nbsp;//&nbsp;可以看到MySQL的日志记录十分详细， &nbsp;&nbsp;//&nbsp;这样十分有利于分析和定位问题。 &nbsp;&nbsp;DBUG_ENTER("mysql_real_query");&nbsp;//&nbsp;跟踪日志 &nbsp;&nbsp;DBUG_PRINT("enter",&nbsp;("handle:&nbsp;%p",&nbsp;mysql)); &nbsp;&nbsp;DBUG_PRINT("query",&nbsp;("Query&nbsp;=&nbsp;'%-.*s'",&nbsp;(int)length,&nbsp;query)); &nbsp;&nbsp;DBUG_EXECUTE_IF("inject_ER_NET_READ_INTERRUPTED", &nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;mysql-&gt;net.last_errno&nbsp;=&nbsp;ER_NET_READ_INTERRUPTED; &nbsp;&nbsp;&nbsp;&nbsp;DBUG_SET("-d,inject_ER_NET_READ_INTERRUPTED"); &nbsp;&nbsp;&nbsp;&nbsp;DBUG_RETURN(1); &nbsp;&nbsp;}); &nbsp; &nbsp;&nbsp;//&nbsp;调用mysql_send_query &nbsp;&nbsp;if&nbsp;(mysql_send_query(mysql,&nbsp;query,&nbsp;length))&nbsp;DBUG_RETURN(1); &nbsp; &nbsp;&nbsp;//&nbsp;read_query_result指向cli_read_query_result &nbsp;&nbsp;//&nbsp;read_query_result的初始化，参见《<a rel="nofollow">MYSQL_METHODS结构体</a>》一节 &nbsp;&nbsp;retval&nbsp;=&nbsp;(int)(*mysql-&gt;methods-&gt;read_query_result)(mysql); &nbsp;&nbsp;DBUG_RETURN(retval); } </td> 
 </tr> 
 </tbody> 
</table>

# **8. mysql\_send\_query函数** #

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;Send&nbsp;the&nbsp;query&nbsp;and&nbsp;return&nbsp;so&nbsp;we&nbsp;can&nbsp;do&nbsp;something&nbsp;else. //&nbsp;Needs&nbsp;to&nbsp;be&nbsp;followed&nbsp;by&nbsp;mysql_read_query_result() //&nbsp;when&nbsp;we&nbsp;want&nbsp;to&nbsp;finish&nbsp;processing&nbsp;it. //&nbsp;client.cc int&nbsp;STDCALL&nbsp;mysql_send_query( &nbsp;&nbsp;&nbsp;&nbsp;MYSQL&nbsp;*mysql, &nbsp;&nbsp;&nbsp;&nbsp;const&nbsp;char&nbsp;*query, &nbsp;&nbsp;&nbsp;&nbsp;ulong&nbsp;length) { &nbsp;&nbsp;STATE_INFO&nbsp;*info; &nbsp;&nbsp;DBUG_ENTER("mysql_send_query"); &nbsp; &nbsp;&nbsp;if&nbsp;((info&nbsp;=&nbsp;STATE_DATA(mysql))) &nbsp;&nbsp;&nbsp;&nbsp;free_state_change_info( &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;static_cast&lt;MYSQL_EXTENSION&nbsp;*&gt;( &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;mysql-&gt;extension)); &nbsp;&nbsp;//&nbsp;转为对simple_command的调用， &nbsp;&nbsp;//&nbsp;simple_command实际为一个指向 &nbsp;&nbsp;//&nbsp;cli_advanced_command的宏。 &nbsp;&nbsp;DBUG_RETURN(simple_command( &nbsp;&nbsp;&nbsp;&nbsp;mysql,&nbsp;COM_QUERY,&nbsp;(uchar&nbsp;*)query,&nbsp;length,&nbsp;1));&nbsp;//&nbsp;最后一个参数值1表示跳过检查 } </td> 
 </tr> 
 </tbody> 
</table>

# **9. simple\_command宏** #

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;注意传递给advanced_command的第3个和第4个参数值均为0， //&nbsp;第3个和第4个参数分别为包头和包头长度 //&nbsp;advanced_command是指向的cli_advanced_command函数指针 //&nbsp;注：mysql_real_query是一个simple&nbsp;command //&nbsp;特点是：advanced_command的第3个和第4个参数为空。 #define&nbsp;simple_command(mysql,command,arg,length,skip_check)&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;\ &nbsp;&nbsp;((mysql)-&gt;methods&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;\ &nbsp;&nbsp;?(*(mysql)-&gt;methods-&gt;advanced_command)(mysql,command,0,0,arg,&nbsp;&nbsp;\ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;length,skip_check,NULL)&nbsp;\ &nbsp;&nbsp;:(set_mysql_error(mysql,CR_COMMANDS_OUT_OF_SYNC,unknown_sqlstate),1)) &nbsp; //&nbsp;类似的： #define&nbsp;stmt_command(mysql,&nbsp;command,&nbsp;arg,&nbsp;length,&nbsp;stmt)&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;\ &nbsp;&nbsp;((mysql)-&gt;methods&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;\ &nbsp;&nbsp;&nbsp;&nbsp;?(*(mysql)-&gt;methods-&gt;advanced_command)(mysql,command,0,0,arg,&nbsp;\ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;length,1,stmt)&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;\ &nbsp;&nbsp;&nbsp;&nbsp;:(set_mysql_error(mysql,CR_COMMANDS_OUT_OF_SYNC,unknown_sqlstate),1)) </td> 
 </tr> 
 </tbody> 
</table>

# **10. MYSQL\_METHODS结构体** #

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> static&nbsp;MYSQL_METHODS&nbsp;client_methods&nbsp;=&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;mysql_real_query调用mysql_send_query发送请求， &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;调用cli_read_query_result接收请求结果， &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;而mysql_send_query又调用了cli_advanced_command &nbsp;&nbsp;&nbsp;&nbsp;cli_read_query_result,&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;read_query_result&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;将结构体MYSQL_METHODS的advanced_command初始化为cli_advanced_command &nbsp;&nbsp;&nbsp;&nbsp;cli_advanced_command,&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;advanced_command&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;cli_read_rows,&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;read_rows&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;cli_use_result,&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;use_result&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;cli_fetch_lengths,&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;fetch_lengths&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;cli_flush_use_result,&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;flush_use_result&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;cli_read_change_user_result&nbsp;/*&nbsp;read_change_user_result&nbsp;*/ #ifndef&nbsp;MYSQL_SERVER &nbsp;&nbsp;&nbsp;&nbsp;, &nbsp;&nbsp;&nbsp;&nbsp;cli_list_fields,&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;list_fields&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;cli_read_prepare_result,&nbsp;/*&nbsp;read_prepare_result&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;cli_stmt_execute,&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;stmt_execute&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;cli_read_binary_rows,&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;read_binary_rows&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;cli_unbuffered_fetch,&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;unbuffered_fetch&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;cli_read_statistics,&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;read_statistics&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;cli_read_query_result,&nbsp;&nbsp;&nbsp;/*&nbsp;next_result&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;cli_read_binary_rows,&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;read_rows_from_cursor&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;free_rows #endif }; </td> 
 </tr> 
 </tbody> 
</table>

# **11. cli\_advanced\_command函数** #

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;client.cc bool&nbsp;cli_advanced_command( &nbsp;&nbsp;&nbsp;&nbsp;MYSQL&nbsp;*mysql, &nbsp;&nbsp;&nbsp;&nbsp;enum&nbsp;enum_server_command&nbsp;command,&nbsp;//&nbsp;COM_QUERY &nbsp;&nbsp;&nbsp;&nbsp;const&nbsp;uchar&nbsp;*header,&nbsp;size_t&nbsp;header_length, &nbsp;&nbsp;&nbsp;&nbsp;const&nbsp;uchar&nbsp;*arg,&nbsp;size_t&nbsp;arg_length, &nbsp;&nbsp;&nbsp;&nbsp;bool&nbsp;skip_check,&nbsp;MYSQL_STMT&nbsp;*stmt) { &nbsp;&nbsp;&nbsp;&nbsp;bool&nbsp;stmt_skip&nbsp;=&nbsp;stmt &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;?&nbsp;stmt-&gt;state&nbsp;!=&nbsp;MYSQL_STMT_INIT_DONE &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;:&nbsp;false; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;执行连接，如果需要 &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(mysql-&gt;net.vio&nbsp;==&nbsp;0)&nbsp;{&nbsp;//&nbsp;Do&nbsp;reconnect&nbsp;if&nbsp;possible &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(mysql_reconnect(mysql)&nbsp;||&nbsp;stmt_skip) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;DBUG_RETURN(1); &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;net_write_command只有发包，并没有收包， &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;而且没有发现有设置错误码ER_NET_PACKET_TOO_LARGE的地方 &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(net_write_command( &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;net,&nbsp;(uchar)command,&nbsp;//&nbsp;COM_QUERY &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;header,&nbsp;header_length, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;arg,&nbsp;arg_length)) &nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;如果包太大，返回包太大错误 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;走读代码，发现不可能出现错误ER_NET_PACKET_TOO_LARGE， &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;也许这是老的实现遗留的 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;// &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;唯一设置错误码为ER_NET_PACKET_TOO_LARGE的地方是net_serv.cc中的net_realloc函数 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(net-&gt;last_errno&nbsp;==&nbsp;ER_NET_PACKET_TOO_LARGE) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;set_mysql_error( &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;mysql, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;CR_NET_PACKET_TOO_LARGE, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;unknown_sqlstate); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;goto&nbsp;end; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;result&nbsp;=&nbsp;0; &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(!skip_check)&nbsp;{&nbsp;//&nbsp;如果skip_check值为0 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;result&nbsp;=&nbsp;((mysql-&gt;packet_length&nbsp;=&nbsp;cli_safe_read_with_ok(mysql,&nbsp;1,&nbsp;NULL))&nbsp;==&nbsp;packet_error &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;?&nbsp;1:&nbsp;0); &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 } </td> 
 </tr> 
 </tbody> 
</table>

# **12. int3store函数** #

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;Stores&nbsp;an&nbsp;unsinged&nbsp;integer&nbsp;in&nbsp;a&nbsp;platform&nbsp;independent&nbsp;way //&nbsp;@param&nbsp;T&nbsp;&nbsp;The&nbsp;destination&nbsp;buffer.&nbsp;Must&nbsp;be&nbsp;at&nbsp;least&nbsp;3&nbsp;bytes&nbsp;long //&nbsp;@param&nbsp;A&nbsp;&nbsp;The&nbsp;integer&nbsp;to&nbsp;store. //&nbsp;_Example:_ //&nbsp;A&nbsp;@ref&nbsp;a_protocol_type_int3&nbsp;"int&nbsp;\&lt;3\&gt;"&nbsp;with&nbsp;the&nbsp;value&nbsp;1&nbsp;is&nbsp;stored&nbsp;as: //&nbsp;~~~~~~~~~~~~~~~~~~~~~ //&nbsp;01&nbsp;00&nbsp;00 //&nbsp;~~~~~~~~~~~~~~~~~~~~~ //&nbsp;字节序转换 //&nbsp;将一个整数转换成与平台无关的字节存储， //&nbsp;因为只有双字节或以才有字节序的问题， //&nbsp;单字节是不存在字节序问题的。 //&nbsp;常规的做法一般是直接做主机字节序到 //&nbsp;网络字节序的转换，这里的目的是节省一个字节， //&nbsp;这可以通过net_write_command的实现看到， //&nbsp;T的第3个字节用作它途了。 static&nbsp;inline&nbsp;void&nbsp;int3store(uchar&nbsp;*T,&nbsp;uint&nbsp;A) { &nbsp;&nbsp;*(T)&nbsp;=&nbsp;(uchar)(A); &nbsp;&nbsp;*(T&nbsp;+&nbsp;1)&nbsp;=&nbsp;(uchar)(A&nbsp;&gt;&gt;&nbsp;8); &nbsp;&nbsp;*(T&nbsp;+&nbsp;2)&nbsp;=&nbsp;(uchar)(A&nbsp;&gt;&gt;&nbsp;16); } </td> 
 </tr> 
 </tbody> 
</table>

# **13. net\_write\_command函数** #

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;Send&nbsp;a&nbsp;command&nbsp;to&nbsp;the&nbsp;server. // //&nbsp;对于mysql_real_query是没有header部分的 //&nbsp;The&nbsp;reason&nbsp;for&nbsp;having&nbsp;both&nbsp;header&nbsp;and&nbsp;packet&nbsp;is&nbsp;so&nbsp;that&nbsp;libmysql //&nbsp;can&nbsp;easy&nbsp;add&nbsp;a&nbsp;header&nbsp;to&nbsp;a&nbsp;special&nbsp;command&nbsp;(like&nbsp;prepared&nbsp;statements) //&nbsp;without&nbsp;having&nbsp;to&nbsp;re-alloc&nbsp;the&nbsp;string. //&nbsp; //&nbsp;As&nbsp;the&nbsp;command&nbsp;is&nbsp;part&nbsp;of&nbsp;the&nbsp;first&nbsp;data&nbsp;packet,&nbsp; //&nbsp;we&nbsp;have&nbsp;to&nbsp;do&nbsp;some&nbsp;data //&nbsp;juggling&nbsp;to&nbsp;put&nbsp;the&nbsp;command&nbsp;in&nbsp;there, //&nbsp;without&nbsp;having&nbsp;to&nbsp;create&nbsp;a&nbsp;new //&nbsp;packet. //&nbsp; //&nbsp;This&nbsp;function&nbsp;will&nbsp;split&nbsp;big&nbsp;packets&nbsp;into&nbsp;sub-packets&nbsp;if&nbsp;needed. //&nbsp;(Each&nbsp;sub&nbsp;packet&nbsp;can&nbsp;only&nbsp;be&nbsp;2^24&nbsp;bytes) // //&nbsp;@param&nbsp;net NET&nbsp;handler //&nbsp;@param&nbsp;command Command&nbsp;in&nbsp;MySQL&nbsp;server&nbsp;(enum&nbsp;enum_server_command) //&nbsp;@param&nbsp;header Header&nbsp;to&nbsp;write&nbsp;after&nbsp;command //&nbsp;@param&nbsp;head_len Length&nbsp;of&nbsp;header //&nbsp;@param&nbsp;packet Query&nbsp;or&nbsp;parameter&nbsp;to&nbsp;query //&nbsp;@param&nbsp;len Length&nbsp;of&nbsp;packet //&nbsp; //&nbsp;@retval //&nbsp;0 ok //&nbsp;@retval //&nbsp;1 error // //&nbsp;net_serv.cc // //&nbsp;#define&nbsp;NET_HEADER_SIZE&nbsp;4&nbsp;//&nbsp;standard&nbsp;header&nbsp;size // //&nbsp;大包分解成子包发送 bool&nbsp;net_write_command( &nbsp;&nbsp;&nbsp;&nbsp;NET&nbsp;*net,&nbsp;uchar&nbsp;command,&nbsp;//&nbsp;COM_QUERY &nbsp;&nbsp;&nbsp;&nbsp;const&nbsp;uchar&nbsp;*header,&nbsp;size_t&nbsp;head_len,&nbsp;//&nbsp;注意mysql_real_query无header &nbsp;&nbsp;&nbsp;&nbsp;const&nbsp;uchar&nbsp;*packet,&nbsp;size_t&nbsp;len) { &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;1&nbsp;extra&nbsp;byte&nbsp;for&nbsp;command &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;多留出1个字节存储命令字 &nbsp;&nbsp;&nbsp;&nbsp;size_t&nbsp;length&nbsp;=&nbsp;len&nbsp;+&nbsp;1&nbsp;+&nbsp;head_len; &nbsp;&nbsp;&nbsp;&nbsp;uchar&nbsp;buff[NET_HEADER_SIZE&nbsp;+&nbsp;1];&nbsp;//&nbsp;5字节 &nbsp;&nbsp;&nbsp;&nbsp;uint&nbsp;header_size&nbsp;=&nbsp;NET_HEADER_SIZE&nbsp;+&nbsp;1;&nbsp;//&nbsp;5字节 &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;buff的第5个字节 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;For&nbsp;first&nbsp;packet&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;buff[4]&nbsp;=&nbsp;command;&nbsp;//&nbsp;命令字（对于mysql_real_query值为COM_QUERY） &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;从下面可以看出， &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;即使发送的包大于MAX_PACKET_LENGTH， &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;也是可以发送的， &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;函数net_write_command会将它按照 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;MAX_PACKET_LENGTH为边界拆分成多个子包（sub&nbsp;packet）。 &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(length&nbsp;&gt;=&nbsp;MAX_PACKET_LENGTH) &nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Take&nbsp;into&nbsp;account&nbsp;that&nbsp;we&nbsp;have&nbsp;the&nbsp;command&nbsp;in&nbsp;the&nbsp;first&nbsp;header &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;len&nbsp;=&nbsp;MAX_PACKET_LENGTH&nbsp;-&nbsp;1&nbsp;-&nbsp;head_len; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;do &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;由于int3store的实现限定， &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;因此MAX_PACKET_LENGTH的值不能超过3个字节 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;// &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;buff头3个字节存储了子包（sub&nbsp;packet）的长度，理论上最大可达：2^24字节， &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;但因为MAX_PACKET_LENGTH只是个宏，所以实际限定为16M。 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;int3store(buff,&nbsp;MAX_PACKET_LENGTH); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;int3store设置buff的前3个字节， &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;下面这条语句设置buff的第4个字节 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;buff[3]&nbsp;=&nbsp;(uchar)net-&gt;pkt_nr++; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(net_write_buff(net,&nbsp;buff,&nbsp;header_size)&nbsp;||&nbsp;//&nbsp;包头大小，加命令字 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;net_write_buff(net,&nbsp;header,&nbsp;head_len)&nbsp;||&nbsp;//&nbsp;对于mysql_real_query实际为空 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;net_write_buff(net,&nbsp;packet,&nbsp;len))&nbsp;//&nbsp;子包数据 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;DBUG_RETURN(1); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;length&nbsp;-=&nbsp;MAX_PACKET_LENGTH; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;while&nbsp;(length&nbsp;&gt;=&nbsp;MAX_PACKET_LENGTH); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Data&nbsp;left&nbsp;to&nbsp;be&nbsp;written &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;这里做法可能和一般人想法不一样， &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;一般的想法是if/else，而这里没有else， &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;所以while循环的终止条件为： &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;length&nbsp;&gt;=&nbsp;MAX_PACKET_LENGTH &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;而不是： &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;length&nbsp;&gt;&nbsp;0 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;len&nbsp;=&nbsp;length; &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;int3store(buff,&nbsp;static_cast&lt;uint&gt;(length)); &nbsp;&nbsp;&nbsp;&nbsp;buff[3]&nbsp;=&nbsp;(uchar)net-&gt;pkt_nr++; &nbsp;&nbsp;&nbsp;&nbsp;bool&nbsp;rc&nbsp;=&nbsp;net_write_buff(net,buff,header_size)&nbsp;|| &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;(head_len&nbsp;&amp;&amp;&nbsp;net_write_buff(net,header,head_len))&nbsp;|| &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;net_write_buff(net,packet,len)&nbsp;||&nbsp;net_flush(net); &nbsp;&nbsp;&nbsp;&nbsp;DBUG_RETURN(rc); } </td> 
 </tr> 
 </tbody> 
</table>

# **14. net\_write\_buff函数** #

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;Caching&nbsp;the&nbsp;data&nbsp;in&nbsp;a&nbsp;local&nbsp;buffer&nbsp;before&nbsp;sending&nbsp;it. //&nbsp;Fill&nbsp;up&nbsp;net-&gt;buffer&nbsp;and&nbsp;send&nbsp;it&nbsp;to&nbsp;the&nbsp;client&nbsp;when&nbsp;full. //&nbsp;If&nbsp;the&nbsp;rest&nbsp;of&nbsp;the&nbsp;to-be-sent-packet&nbsp;is&nbsp;bigger&nbsp;than&nbsp;buffer, //&nbsp;send&nbsp;it&nbsp;in&nbsp;one&nbsp;big&nbsp;block&nbsp;(to&nbsp;avoid&nbsp;copying&nbsp;to&nbsp;internal&nbsp;buffer). //&nbsp;If&nbsp;not,&nbsp;copy&nbsp;the&nbsp;rest&nbsp;of&nbsp;the&nbsp;data&nbsp;to //&nbsp;the&nbsp;buffer&nbsp;and&nbsp;return&nbsp;without&nbsp;sending&nbsp;data. // //&nbsp;Notes&nbsp;the&nbsp;cached&nbsp;buffer&nbsp;can&nbsp;be&nbsp;sent&nbsp;as&nbsp;it&nbsp;is&nbsp;with&nbsp;'net_flush()'. //&nbsp;In&nbsp;this&nbsp;code&nbsp;we&nbsp;have&nbsp;to&nbsp;be&nbsp;careful&nbsp;to&nbsp;not&nbsp;send&nbsp;a&nbsp;packet //&nbsp;longer&nbsp;than&nbsp;MAX_PACKET_LENGTH&nbsp;to&nbsp;net_write_packet() //&nbsp;if&nbsp;we&nbsp;are&nbsp;using&nbsp;the&nbsp;compressed&nbsp;protocol&nbsp;as&nbsp;we&nbsp;store //&nbsp;the&nbsp;length&nbsp;of&nbsp;the&nbsp;compressed&nbsp;packet&nbsp;in&nbsp;3&nbsp;bytes. // //&nbsp;@retval //&nbsp;&nbsp;&nbsp;0 ok //&nbsp;@retval //&nbsp;&nbsp;&nbsp;1 static&nbsp;bool&nbsp;net_write_buff( &nbsp;&nbsp;&nbsp;&nbsp;NET&nbsp;*net, &nbsp;&nbsp;&nbsp;&nbsp;const&nbsp;uchar&nbsp;*packet,&nbsp;size_t&nbsp;len) { &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;只有buff存不下了（len&nbsp;&gt;&nbsp;left_length）， &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;才调用net_write_packet真正发包。 &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(len&nbsp;&gt;&nbsp;left_length) &nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(net_write_packet(net,&nbsp;packet,&nbsp;left_length))&nbsp;return&nbsp;1; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;如果len&nbsp;&lt;=&nbsp;left_length， &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;则不会真发送，而是缓存到struct&nbsp;NET的buff中 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;struct&nbsp;NET&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;MYSQL_VIO&nbsp;vio; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;unsigned&nbsp;char&nbsp;*buff,*buff_end,*write_pos,*read_pos; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;对于mysql_real_query，这里的len值可能为0，因为没有头（head） &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(len&nbsp;&gt;&nbsp;0) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;memcpy(net-&gt;write_pos,&nbsp;packet,&nbsp;len); &nbsp;&nbsp;&nbsp;&nbsp;net-&gt;write_pos&nbsp;+=&nbsp;len; &nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;0; } </td> 
 </tr> 
 </tbody> 
</table>

# **15. net\_write\_packet函数** #

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;Write&nbsp;a&nbsp;MySQL&nbsp;protocol&nbsp;packet&nbsp;to&nbsp;the&nbsp;network&nbsp;handler. //&nbsp; //&nbsp;@param&nbsp;&nbsp;net&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;NET&nbsp;handler. //&nbsp;@param&nbsp;&nbsp;packet&nbsp;&nbsp;The&nbsp;packet&nbsp;to&nbsp;write. //&nbsp;@param&nbsp;&nbsp;length&nbsp;&nbsp;Length&nbsp;of&nbsp;the&nbsp;packet. //&nbsp; //&nbsp;@remark&nbsp;The&nbsp;packet&nbsp;might&nbsp;be&nbsp;encapsulated&nbsp;into&nbsp;a&nbsp;compressed&nbsp;packet. //&nbsp; //&nbsp;@return&nbsp;true&nbsp;on&nbsp;error,&nbsp;false&nbsp;on&nbsp;success. bool&nbsp;net_write_packet( &nbsp;&nbsp;&nbsp;&nbsp;NET&nbsp;*net, &nbsp;&nbsp;&nbsp;&nbsp;const&nbsp;uchar&nbsp;*packet,&nbsp;size_t&nbsp;length) { &nbsp;&nbsp;bool&nbsp;res; &nbsp; &nbsp;&nbsp;net-&gt;reading_or_writing&nbsp;=&nbsp;2; &nbsp;&nbsp;const&nbsp;bool&nbsp;do_compress&nbsp;=&nbsp;net-&gt;compress; &nbsp;&nbsp;if&nbsp;(do_compress)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;((packet&nbsp;=&nbsp;compress_packet(net,&nbsp;packet,&nbsp;&amp;length))&nbsp;==&nbsp;NULL)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;net-&gt;error&nbsp;=&nbsp;2; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;net-&gt;last_errno&nbsp;=&nbsp;ER_OUT_OF_RESOURCES; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;In&nbsp;the&nbsp;server,&nbsp;allocation&nbsp;failure&nbsp;raises&nbsp;a&nbsp;error.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;net-&gt;reading_or_writing&nbsp;=&nbsp;0; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;DBUG_RETURN(true); &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;} &nbsp; &nbsp;&nbsp;res&nbsp;=&nbsp;net_write_raw_loop(net,&nbsp;packet,&nbsp;length); &nbsp;&nbsp;if&nbsp;(do_compress)&nbsp;my_free((void&nbsp;*)packet); &nbsp;&nbsp;net-&gt;reading_or_writing&nbsp;=&nbsp;0; } </td> 
 </tr> 
 </tbody> 
</table>

# **16. net\_write\_raw\_loop函数** #

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;Write&nbsp;a&nbsp;determined&nbsp;number&nbsp;of&nbsp;bytes&nbsp;to&nbsp;a&nbsp;network&nbsp;handler. // //&nbsp;@param&nbsp;&nbsp;net&nbsp;&nbsp;&nbsp;NET&nbsp;handler. //&nbsp;@param&nbsp;&nbsp;buf&nbsp;&nbsp;&nbsp;Buffer&nbsp;containing&nbsp;the&nbsp;data&nbsp;to&nbsp;be&nbsp;written. //&nbsp;@param&nbsp;&nbsp;count&nbsp;The&nbsp;length,&nbsp;in&nbsp;bytes,&nbsp;of&nbsp;the&nbsp;buffer. // //&nbsp;@return&nbsp;true&nbsp;on&nbsp;error,&nbsp;false&nbsp;on&nbsp;success. // //&nbsp;#define&nbsp;vio_write(vio,&nbsp;buf,&nbsp;size)&nbsp;\ //&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;((vio)-&gt;write)(vio,&nbsp;buf,&nbsp;size) //&nbsp;#define&nbsp;vio_was_timeout(vio)&nbsp;(vio)-&gt;was_timeout(vio) // //&nbsp;#define&nbsp;MYSQL_VIO&nbsp;struct&nbsp;Vio&nbsp;* static&nbsp;bool&nbsp;net_write_raw_loop( &nbsp;&nbsp;&nbsp;&nbsp;NET&nbsp;*net, &nbsp;&nbsp;&nbsp;&nbsp;const&nbsp;uchar&nbsp;*buf,&nbsp;size_t&nbsp;count) { &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;同步阻塞方式发送，直到全部发完为止 &nbsp;&nbsp;&nbsp;&nbsp;while&nbsp;(count)&nbsp;{&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;size_t&nbsp;sentcnt&nbsp;=&nbsp;vio_write(net-&gt;vio,&nbsp;buf,&nbsp;count); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;VIO_SOCKET_ERROR&nbsp;(-1)&nbsp;indicates&nbsp;an&nbsp;error. &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(sentcnt&nbsp;==&nbsp;VIO_SOCKET_ERROR) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;A&nbsp;recoverable&nbsp;I/O&nbsp;error&nbsp;occurred? &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(net_should_retry(net,&nbsp;&amp;retry_count)) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;continue; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;else &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;break; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;count&nbsp;-=&nbsp;sentcnt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;buf&nbsp;+=&nbsp;sentcnt; &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(count) &nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Socket&nbsp;should&nbsp;be&nbsp;closed. &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;net-&gt;error&nbsp;=&nbsp;2; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Interrupted&nbsp;by&nbsp;a&nbsp;timeout? &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(vio_was_timeout(net-&gt;vio)) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;net-&gt;last_errno&nbsp;=&nbsp;ER_NET_WRITE_INTERRUPTED; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;else &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;net-&gt;last_errno&nbsp;=&nbsp;ER_NET_ERROR_ON_WRITE; &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;count&nbsp;!=&nbsp;0; } </td> 
 </tr> 
 </tbody> 
</table>

# **17. Vio结构体** #

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;&nbsp;This&nbsp;structure&nbsp;is&nbsp;for&nbsp;every&nbsp;connection&nbsp;on&nbsp;both&nbsp;sides. //&nbsp;Note&nbsp;that&nbsp;it&nbsp;has&nbsp;a&nbsp;non-default&nbsp;move&nbsp;assignment&nbsp;operator, //&nbsp;so&nbsp;if&nbsp;adding&nbsp;more&nbsp;members, //&nbsp;you'll&nbsp;need&nbsp;to&nbsp;update&nbsp;operator= // //&nbsp;Vio实际是一个C++11类，非C的struct //&nbsp;violite.h struct&nbsp;Vio { &nbsp;&nbsp;&nbsp;&nbsp;MYSQL_SOCKET&nbsp;mysql_socket;&nbsp;//&nbsp;Instrumented&nbsp;socket &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;MySQL客户端库调用write往MySQL&nbsp;server发包， &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;write是指向什么的函数指针了？答案在vio.cc文件中。 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;指向vio_ssl_write或vio_write，但编译后只可能指向其中一个， &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;但如果是WIN32，则可能指向vio_write_pipe或vio_write_shared_memory &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;这里，我们只关注非WIN32环境。 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;#ifdef&nbsp;HAVE_OPENSSL &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;if&nbsp;(type&nbsp;==&nbsp;VIO_TYPE_SSL)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;vio-&gt;write&nbsp;=&nbsp;vio_ssl_write; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;false; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;vio-&gt;write&nbsp;=&nbsp;vio_write; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;false; &nbsp;&nbsp;&nbsp;&nbsp;size_t&nbsp;(*write)(MYSQL_VIO,const&nbsp;uchar*,size_t)={nullptr}; &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Flag&nbsp;to&nbsp;indicate&nbsp;whether&nbsp;we&nbsp;are&nbsp;in&nbsp;poll&nbsp;or&nbsp;shutdown. &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;A&nbsp;true&nbsp;value&nbsp;of&nbsp;flag&nbsp;indicates&nbsp;either&nbsp;the&nbsp;socket &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;has&nbsp;called&nbsp;&nbsp;shutdown&nbsp;or&nbsp;it&nbsp;is&nbsp;sleeping&nbsp;on&nbsp;a&nbsp;poll&nbsp;call. &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;False&nbsp;value&nbsp;of&nbsp;this&nbsp;flag&nbsp;means&nbsp;that&nbsp;the&nbsp;socket&nbsp;is &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;not&nbsp;sleeping&nbsp;on&nbsp;a&nbsp;poll&nbsp;call. &nbsp;&nbsp;&nbsp;&nbsp;std::atomic_flag&nbsp;poll_shutdown_flag&nbsp;=&nbsp;ATOMIC_FLAG_INIT; &nbsp;&nbsp;&nbsp;&nbsp; private:&nbsp;//&nbsp;禁掉构造和析构函数 &nbsp;&nbsp;&nbsp;&nbsp;friend&nbsp;Vio&nbsp;*internal_vio_create(uint&nbsp;flags); &nbsp;&nbsp;&nbsp;&nbsp;explicit&nbsp;Vio(uint&nbsp;flags); &nbsp;&nbsp;&nbsp;&nbsp;~Vio(); &nbsp; public:&nbsp;//&nbsp;禁掉拷贝构造和拷贝赋值函数 &nbsp;&nbsp;&nbsp;&nbsp;Vio(const&nbsp;Vio&nbsp;&amp;)&nbsp;=&nbsp;delete; &nbsp;&nbsp;&nbsp;&nbsp;Vio&nbsp;&amp;operator=(const&nbsp;Vio&nbsp;&amp;)&nbsp;=&nbsp;delete; &nbsp;&nbsp;&nbsp;&nbsp;Vio&nbsp;&amp;operator=(Vio&nbsp;&amp;&amp;vio); }; </td> 
 </tr> 
 </tbody> 
</table>

# **18. vio\_write函数** #

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;#define&nbsp;mysql_socket_send(FD,&nbsp;B,&nbsp;N,&nbsp;FL)&nbsp;inline_mysql_socket_send(FD,&nbsp;B,&nbsp;N,&nbsp;FL) //&nbsp;viosocket.cc size_t&nbsp;vio_write(Vio&nbsp;*vio,const&nbsp;uchar&nbsp;*buf,size_t&nbsp;size) { &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;调用inline_mysql_socket_send发送 &nbsp;&nbsp;&nbsp;&nbsp;while&nbsp;((ret&nbsp;=&nbsp;mysql_socket_send( &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;vio-&gt;mysql_socket, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;(SOCKBUF_T&nbsp;*)buf,&nbsp;size, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;flags))&nbsp;==&nbsp;-1) &nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;error&nbsp;=&nbsp;socket_errno; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Wait&nbsp;for&nbsp;the&nbsp;output&nbsp;buffer&nbsp;to&nbsp;become&nbsp;writable &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;((ret=vio_socket_io_wait(vio,VIO_IO_EVENT_WRITE))) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;break; &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;DBUG_RETURN(ret); } </td> 
 </tr> 
 </tbody> 
</table>

# **19. inline\_mysql\_socket\_send函数** #

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> static&nbsp;inline&nbsp;ssize_t&nbsp;inline_mysql_socket_send( &nbsp;&nbsp;&nbsp;&nbsp;MYSQL_SOCKET&nbsp;mysql_socket, &nbsp;&nbsp;&nbsp;&nbsp;const&nbsp;SOCKBUF_T&nbsp;*buf,&nbsp;size_t&nbsp;n,&nbsp;int&nbsp;flags) { &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Non&nbsp;instrumented&nbsp;code &nbsp;&nbsp;&nbsp;&nbsp;result&nbsp;=&nbsp;send(mysql_socket.fd,&nbsp;buf,&nbsp;IF_WIN((int),&nbsp;)&nbsp;n,&nbsp;flags); &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;result; } </td> 
 </tr> 
 </tbody> 
</table>

# **20. net\_realloc函数** #

调用者：net\_**read**\_packet和my\_**realloc**\_str，**net\_realloc**会对包大小进行判断，如果超过大小，设置出错码为**ER\_NET\_PACKET\_****TOO\_LARGE**。

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;Realloc&nbsp;the&nbsp;packet&nbsp;buffer. //&nbsp;net_serv.cc bool&nbsp;net_realloc(NET&nbsp;*net,&nbsp;size_t&nbsp;length) { &nbsp;&nbsp;uchar&nbsp;*buff; &nbsp;&nbsp;size_t&nbsp;pkt_length; &nbsp;&nbsp;DBUG_ENTER("net_realloc"); &nbsp;&nbsp;DBUG_PRINT("enter",&nbsp;("length:&nbsp;%lu",&nbsp;(ulong)length)); &nbsp; &nbsp;&nbsp;if&nbsp;(length&nbsp;&gt;=&nbsp;net-&gt;max_packet_size)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;DBUG_PRINT("error", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;("Packet&nbsp;too&nbsp;large.&nbsp;Max&nbsp;size:&nbsp;%lu",&nbsp;net-&gt;max_packet_size)); &nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;@todo:&nbsp;1&nbsp;and&nbsp;2&nbsp;codes&nbsp;are&nbsp;identical.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;net-&gt;error&nbsp;=&nbsp;1; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;设置出错码ER_NET_PACKET_TOO_LARGE &nbsp;&nbsp;&nbsp;&nbsp;net-&gt;last_errno&nbsp;=&nbsp;ER_NET_PACKET_TOO_LARGE; #ifdef&nbsp;MYSQL_SERVER &nbsp;&nbsp;&nbsp;&nbsp;my_error(ER_NET_PACKET_TOO_LARGE,&nbsp;MYF(0)); #endif &nbsp;&nbsp;&nbsp;&nbsp;DBUG_RETURN(1); &nbsp;&nbsp;} &nbsp;&nbsp;。。。。。。 } </td> 
 </tr> 
 </tbody> 
</table>

# **21. net\_read\_packet函数** #

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;Read&nbsp;one&nbsp;(variable-length)&nbsp;MySQL&nbsp;protocol&nbsp;packet. //&nbsp;A&nbsp;MySQL&nbsp;packet&nbsp;consists&nbsp;of&nbsp;a&nbsp;header&nbsp;and&nbsp;a&nbsp;payload. //&nbsp; //&nbsp;@remark&nbsp;Reads&nbsp;one&nbsp;packet&nbsp;to&nbsp;net-&gt;buff&nbsp;+&nbsp;net-&gt;where_b. //&nbsp;@remark&nbsp;Long&nbsp;packets&nbsp;are&nbsp;handled&nbsp;by&nbsp;my_net_read(). //&nbsp;@remark&nbsp;The&nbsp;network&nbsp;buffer&nbsp;is&nbsp;expanded&nbsp;if&nbsp;necessary. //&nbsp; //&nbsp;@return&nbsp;The&nbsp;length&nbsp;of&nbsp;the&nbsp;packet,&nbsp;or&nbsp;@c&nbsp;packet_error&nbsp;on&nbsp;error. // //&nbsp;net_serv.cc static&nbsp;size_t&nbsp;net_read_packet(NET&nbsp;*net,&nbsp;size_t&nbsp;*complen) { &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(net_read_packet_header(net))&nbsp;goto&nbsp;error; &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Expand&nbsp;packet&nbsp;buffer&nbsp;if&nbsp;necessary &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;函数net_realloc可能触发错误ER_NET_PACKET_TOO_LARGE &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;((pkt_data_len&nbsp;&gt;=&nbsp;net-&gt;max_packet)&nbsp;&amp;&amp;&nbsp;net_realloc(net,&nbsp;pkt_data_len)) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;goto&nbsp;error; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Read&nbsp;the&nbsp;packet&nbsp;data&nbsp;(payload) &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(net_read_raw_loop(net,&nbsp;pkt_len))&nbsp;goto&nbsp;error; &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 } </td> 
 </tr> 
 </tbody> 
</table>

# **22. mysql\_real\_connect函数** #

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;client.cc MYSQL&nbsp;*STDCALL&nbsp;mysql_real_connect( &nbsp;&nbsp;&nbsp;&nbsp;MYSQL&nbsp;*mysql,&nbsp;//&nbsp;如果传NULL，则会自动创建 &nbsp;&nbsp;&nbsp;&nbsp;const&nbsp;char&nbsp;*host, &nbsp;&nbsp;&nbsp;&nbsp;const&nbsp;char&nbsp;*user,&nbsp;const&nbsp;char&nbsp;*passwd, &nbsp;&nbsp;&nbsp;&nbsp;const&nbsp;char&nbsp;*db,&nbsp;uint&nbsp;port, &nbsp;&nbsp;&nbsp;&nbsp;const&nbsp;char&nbsp;*unix_socket,&nbsp;ulong&nbsp;client_flag) { &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;NET&nbsp;*net&nbsp;=&nbsp;&amp;mysql-&gt;net; &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(my_net_init(net,&nbsp;net-&gt;vio))&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 } &nbsp; //&nbsp;Init&nbsp;with&nbsp;packet&nbsp;info //&nbsp;client.cc bool&nbsp;my_net_init(NET&nbsp;*net,&nbsp;Vio&nbsp;*vio) { &nbsp;&nbsp;&nbsp;&nbsp;net-&gt;vio&nbsp;=&nbsp;vio; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Set&nbsp;some&nbsp;limits &nbsp;&nbsp;&nbsp;&nbsp;my_net_local_init(net); &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 } &nbsp; //&nbsp;Functions&nbsp;called&nbsp;my&nbsp;my_net_init()&nbsp;to //&nbsp;set&nbsp;some&nbsp;application&nbsp;specific&nbsp;variables //&nbsp;libmysql.cc void&nbsp;my_net_local_init(NET&nbsp;*net) { &nbsp;&nbsp;&nbsp;&nbsp;(void)mysql_get_option(NULL,&nbsp;MYSQL_OPT_MAX_ALLOWED_PACKET, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&amp;local_max_allowed_packet); &nbsp;&nbsp;&nbsp;&nbsp;(void)mysql_get_option(NULL,&nbsp;MYSQL_OPT_NET_BUFFER_LENGTH, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&amp;local_net_buffer_length); &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;MY_MAX作用是取两者中的最大值 &nbsp;&nbsp;&nbsp;&nbsp;net-&gt;max_packet_size&nbsp;= &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;MY_MAX(local_net_buffer_length, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;local_max_allowed_packet); } &nbsp; int&nbsp;STDCALL&nbsp;mysql_get_option( &nbsp;&nbsp;&nbsp;&nbsp;MYSQL&nbsp;*mysql, &nbsp;&nbsp;&nbsp;&nbsp;enum&nbsp;mysql_option&nbsp;option, &nbsp;&nbsp;&nbsp;&nbsp;const&nbsp;void&nbsp;*arg) { &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(!arg)&nbsp;DBUG_RETURN(1); &nbsp;&nbsp;&nbsp;&nbsp;switch&nbsp;(option) &nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;client.cc &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;ulong&nbsp;g_net_buffer_length&nbsp;=&nbsp;8192;&nbsp;/&nbsp;8KB &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;ulong&nbsp;g_max_allowed_packet&nbsp;=&nbsp;1024L&nbsp;*&nbsp;1024L&nbsp;*&nbsp;1024L;&nbsp;//&nbsp;1GB &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;case&nbsp;MYSQL_OPT_MAX_ALLOWED_PACKET: &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(mysql) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*((ulong&nbsp;*)arg)&nbsp;=&nbsp;mysql-&gt;options.max_allowed_packet; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;else &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*((ulong&nbsp;*)arg)&nbsp;=&nbsp;g_max_allowed_packet; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;break; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;case&nbsp;MYSQL_OPT_NET_BUFFER_LENGTH: &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*((ulong&nbsp;*)arg)&nbsp;=&nbsp;g_net_buffer_length; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;break; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;default: &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;DBUG_RETURN(1); &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;DBUG_RETURN(0); } </td> 
 </tr> 
 </tbody> 
</table>

# **23. mysql\_init函数** #

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;Init&nbsp;MySQL&nbsp;structure&nbsp;or&nbsp;allocate&nbsp;one MYSQL&nbsp;*STDCALL&nbsp;mysql_init(MYSQL&nbsp;*mysql) { &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(mysql_server_init(0,&nbsp;NULL,&nbsp;NULL))&nbsp;return&nbsp;0; &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(!mysql) &nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(!(mysql=(MYSQL&nbsp;*)my_malloc( &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;key_memory_MYSQL,sizeof(*mysql), &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;MYF(MY_WME&nbsp;|&nbsp;MY_ZEROFILL)))) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;set_mysql_error(NULL,&nbsp;CR_OUT_OF_MEMORY,&nbsp;unknown_sqlstate); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;0; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;自己创建的，就需要负责释放， &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;否则如果是调用者创建的，就不用管释放， &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;注意，调用者可在栈上创建的。 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;mysql-&gt;free_me&nbsp;=&nbsp;1; &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;else &nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;memset(mysql,&nbsp;0,&nbsp;sizeof(*(mysql))); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;mysql-&gt;charset&nbsp;=&nbsp;default_client_charset_info; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;mysql-&gt;reconnect&nbsp;=&nbsp;0; &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;mysql; } </td> 
 </tr> 
 </tbody> 
</table>

# **24. Packet Too Large** #

MySQL-8.0对“[Packet Too Large][Packet_Too_Large]”的官方说明：

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> MySQL&nbsp;8.0的服务端和客户端可收和发的最大包大小为1GB。 包是指发送给服务端的单条SQL，或发送给客户端的单行数据，或master发给slave的binlog。 &nbsp;&nbsp;&nbsp;&nbsp;A&nbsp;communication&nbsp;packet&nbsp;is&nbsp;a&nbsp;single&nbsp;SQL&nbsp;statement&nbsp;sent&nbsp;to&nbsp;the&nbsp;MySQL&nbsp;server,&nbsp;a&nbsp;single&nbsp;row&nbsp;that&nbsp;is&nbsp;sent&nbsp;to&nbsp;the&nbsp;client,&nbsp;or&nbsp;a&nbsp;binary&nbsp;log&nbsp;event&nbsp;sent&nbsp;from&nbsp;a&nbsp;master&nbsp;replication&nbsp;server&nbsp;to&nbsp;a&nbsp;slave. &nbsp;&nbsp;&nbsp;&nbsp;The&nbsp;largest&nbsp;possible&nbsp;packet&nbsp;that&nbsp;can&nbsp;be&nbsp;transmitted&nbsp;to&nbsp;or&nbsp;from&nbsp;a&nbsp;MySQL&nbsp;8.0&nbsp;server&nbsp;or&nbsp;client&nbsp;is&nbsp;1GB. &nbsp;&nbsp;&nbsp;&nbsp;When&nbsp;a&nbsp;MySQL&nbsp;client&nbsp;or&nbsp;the&nbsp;mysqld&nbsp;server&nbsp;receives&nbsp;a&nbsp;packet&nbsp;bigger&nbsp;than&nbsp;max_allowed_packet&nbsp;bytes,&nbsp;it&nbsp;issues&nbsp;an&nbsp;ER_NET_PACKET_TOO_LARGE&nbsp;error&nbsp;and&nbsp;closes&nbsp;the&nbsp;connection. &nbsp;&nbsp;&nbsp;&nbsp;With&nbsp;some&nbsp;clients,&nbsp;you&nbsp;may&nbsp;also&nbsp;get&nbsp;a&nbsp;Lost&nbsp;connection&nbsp;to&nbsp;MySQL&nbsp;server&nbsp;during&nbsp;query&nbsp;error&nbsp;if&nbsp;the&nbsp;communication&nbsp;packet&nbsp;is&nbsp;too&nbsp;large. &nbsp;&nbsp;&nbsp;&nbsp;Both&nbsp;the&nbsp;client&nbsp;and&nbsp;the&nbsp;server&nbsp;have&nbsp;their&nbsp;own&nbsp;max_allowed_packet&nbsp;variable,&nbsp;so&nbsp;if&nbsp;you&nbsp;want&nbsp;to&nbsp;handle&nbsp;big&nbsp;packets,&nbsp;you&nbsp;must&nbsp;increase&nbsp;this&nbsp;variable&nbsp;both&nbsp;in&nbsp;the&nbsp;client&nbsp;and&nbsp;in&nbsp;the&nbsp;server. &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;If&nbsp;you&nbsp;are&nbsp;using&nbsp;the&nbsp;mysql&nbsp;client&nbsp;program,&nbsp;its&nbsp;default&nbsp;max_allowed_packet&nbsp;variable&nbsp;is&nbsp;16MB.&nbsp;To&nbsp;set&nbsp;a&nbsp;larger&nbsp;value,&nbsp;start&nbsp;mysql&nbsp;like&nbsp;this: shell&gt;&nbsp;mysql&nbsp;--max_allowed_packet=32M &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;The&nbsp;server's&nbsp;default&nbsp;max_allowed_packet&nbsp;value&nbsp;is&nbsp;64MB.&nbsp;You&nbsp;can&nbsp;increase&nbsp;this&nbsp;if&nbsp;the&nbsp;server&nbsp;needs&nbsp;to&nbsp;handle&nbsp;big&nbsp;queries&nbsp;(for&nbsp;example,&nbsp;if&nbsp;you&nbsp;are&nbsp;working&nbsp;with&nbsp;big&nbsp;BLOB&nbsp;columns).&nbsp;For&nbsp;example,&nbsp;to&nbsp;set&nbsp;the&nbsp;variable&nbsp;to&nbsp;128MB,&nbsp;start&nbsp;the&nbsp;server&nbsp;like&nbsp;this: shell&gt;&nbsp;mysqld&nbsp;--max_allowed_packet=128M &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;You&nbsp;can&nbsp;also&nbsp;use&nbsp;an&nbsp;option&nbsp;file&nbsp;to&nbsp;set&nbsp;max_allowed_packet.&nbsp;For&nbsp;example,&nbsp;to&nbsp;set&nbsp;the&nbsp;size&nbsp;for&nbsp;the&nbsp;server&nbsp;to&nbsp;128MB,&nbsp;add&nbsp;the&nbsp;following&nbsp;lines&nbsp;in&nbsp;an&nbsp;option&nbsp;file: [mysqld] max_allowed_packet=128M </td> 
 </tr> 
 </tbody> 
</table>

# **25. 分析结论** #

1) 包的最大限制为1GB；

2) 如果包大小超过16M，则会被分解为多个子包，每个子包大小小于16M；

**3) ****分包是函数****net\_write\_command****的行为；**

4) 即使被分解成了多个包，也并不立即发送；

5) 发送缓冲区满了才会立即发送；

6) 在函数**net\_read\_packet**中，调用net\_realloc会判断包大小，如果超过大小，则错误码（**last\_errno**）设置为ER\_NET\_PACKET\_TOO\_LARGE；

7) mysql\_real\_query并没有对要发送的大小进行判断，超过1G大小也是可以发的，但服务端会报错，这个由net\_realloc决定，而调用者是；

8) 只有收包的时候才知道包大小是否超过了。

[Packet_Too_Large]: https://dev.mysql.com/doc/refman/8.0/en/packet-too-large.html