在Server层实现KillIdleTransaction

本文内容遵从CC版权协议, 可以随意转载, 但必须以超链接形式标明文章原始出处和作者信息及版权声明网址: http://www.penglixun.com/tech/database/server_kill_idle_transaction.html 在上一篇文章里我们写了如何针对InnoDB清理空闲事务《如何杀掉空闲事务》

本文内容遵从CC版权协议, 可以随意转载, 但必须以超链接形式标明文章原始出处和作者信息及版权声明网址: http://www.penglixun.com/tech/database/server_kill_idle_transaction.html

在上一篇文章里我们写了如何针对InnoDB清理空闲事务《如何杀掉空闲事务》，在@sleebin9 的提示下，这个功能不仅可以针对InnoDB，也可以用于所有MySQL的事务引擎。

如何在Server层实现呢，sql/sql_parse.cc的do_command()函数是个好函数，连接线程会循环调用do_command()来读取并执行命令，在do_command()函数中，会调用my_net_set_read_timeout(net, thd->variables.net_wait_timeout)来设置线程socket连接超时时间，于是在这里可以下手。
主要代码：

830   /*
 831     This thread will do a blocking read from the client which
 832     will be interrupted when the next command is received from
 833     the client, the connection is closed or "net_wait_timeout"
 834     number of seconds has passed
 835   */
 836   /* Add For Kill Idle Transaction By P.Linux */
 837   if &＃40;thd->active_transaction&＃40;&＃41;&＃41;
 838   &＃123;
 839     if &＃40;thd->variables.trx_idle_timeout > 0&＃41;
 840     &＃123;
 841       my_net_set_read_timeout&＃40;net, thd->variables.trx_idle_timeout&＃41;;
 842     &＃125; else if &＃40;thd->variables.trx_readonly_idle_timeout > 0 && thd->is_readonly_trx&＃41;
 843     &＃123;
 844       my_net_set_read_timeout&＃40;net, thd->variables.trx_readonly_idle_timeout&＃41;;
 845     &＃125; else if &＃40;thd->variables.trx_changes_idle_timeout > 0 && !thd->is_readonly_trx&＃41;
 846     &＃123;
 847       my_net_set_read_timeout&＃40;net, thd->variables.trx_changes_idle_timeout&＃41;;
 848     &＃125; else &＃123;
 849       my_net_set_read_timeout&＃40;net, thd->variables.net_wait_timeout&＃41;;
 850     &＃125;
 851   &＃125; else &＃123;
 852     my_net_set_read_timeout&＃40;net, thd->variables.net_wait_timeout&＃41;;
 853   &＃125;
 854   /* End */

大家看明白了吗？其实这是偷梁换柱，本来在这里是要设置wait_timeout的，先判断线程是不是在事务里，就可以转而实现空闲事务的超时。

trx_idle_timeout 控制所有事务的超时，优先级最高
trx_changes_idle_timeout 控制非只读事务的超时
trx_readonly_idle_timeout 控制只读事务的超时

效果：

root@localhost : &＃40;none&＃41; 08:39:49> set autocommit = 0 ;
Query OK, 0 rows affected &＃40;0.00 sec&＃41;
 
root@localhost : &＃40;none&＃41; 08:39:56> set trx_idle_timeout = 5;
Query OK, 0 rows affected &＃40;0.00 sec&＃41;
 
root@localhost : &＃40;none&＃41; 08:40:17> use perf 
Database changed
root@localhost : perf 08:40:19> insert into perf &＃40;info &＃41; values&＃40;'11'&＃41;;
Query OK, 1 row affected &＃40;0.00 sec&＃41;
 
root@localhost : perf 08:40:26> select * from perf;
ERROR 2006 &＃40;HY000&＃41;: MySQL server has gone away
No connection. Trying to reconnect...
Connection id:    6
Current database: perf
 
+----+------+
| id | info |
+----+------+
|  7 | aaaa |
|  9 | aaaa |
| 11 | aaaa |
+----+------+
3 rows in set &＃40;0.00 sec&＃41;

完整的patch这里下载：
Note: There is a file embedded within this post, please visit this post to download the file.