MySQL数据库连接异常断开导致事务没提交的解决办法_commit时网络中断

static MYSQL_SYSVAR_LONG(idle_trx_timeout, srv_idle_trx_timeout,  PLUGIN_VAR_RQCMDARG,  "If zero then this function no effect, if no-zero then wait idle_trx_timeout seconds this transaction will be closed",  "Seconds of Idle-Transaction timeout",  NULL, NULL, 0, 0, LONG_MAX, 0);

MYSQL_SYSVAR(idle_trx_timeout),

    if (srv_idle_trx_timeout && trx_sys) {

        trx_t*  trx;

        time_t  now;

rescan_idle:

        now = time(NULL);

        mutex_enter(&kernel_mutex);

        trx = UT_LIST_GET_FIRST(trx_sys->mysql_trx_list); # 从当前事务列表里获取第一个事务

        while (trx) { # 依次循环每个事务进行检查

            if (trx->conc_state == TRX_ACTIVE

                && trx->mysql_thd

                && innobase_thd_is_idle(trx->mysql_thd)) { # 如果事务还活着并且它的状态时空闲的

                 ib_int64_t  start_time = innobase_thd_get_start_time(trx->mysql_thd); # 获取线程最后一个语句的开始时间

                ulong       thd_id = innobase_thd_get_thread_id(trx->mysql_thd); #获取线程ID，因为存储引擎内直接操作THD不安全

                 if (trx->last_stmt_start != start_time) { # 如果事务最后语句起始时间不等于线程最后语句起始时间说明事务是新起的

                    trx->idle_start = now; # 更新事务的空闲起始时间

                    trx->last_stmt_start = start_time; # 更新事务的最后语句起始时间

                } else if (difftime(now, trx->idle_start) # 如果事务不是新起的，已经执行了一部分则判断空闲时间有多长了

                       > srv_idle_trx_timeout) { # 如果空闲时间超过阈值则杀掉链接

                    /* kill the session */

                    mutex_exit(&kernel_mutex);

                    thd_kill(thd_id); # 杀链接

                    goto rescan_idle;

                }

            }

            trx = UT_LIST_GET_NEXT(mysql_trx_list, trx); # 检查下一个事务

        }

        mutex_exit(&kernel_mutex);

    }

struct trx_struct{...

    time_t      idle_start;

    ib_int64_t  last_stmt_start;

...

}

ibool      innobase_thd_is_idle(const void* thd);

ib_int64_t innobase_thd_get_start_time(const void* thd);

ulong      innobase_thd_get_thread_id(const void* thd);

extern "C"

ibool

innobase_thd_is_idle(

    const void* thd)

    /*!< in: thread handle (THD*) */

{

    return(((const THD*)thd)->command == COM_SLEEP);

}

extern "C"

ib_int64_t

innobase_thd_get_start_time(

    const void* thd)   

  /*!< in: thread handle (THD*) */

{

    return((ib_int64_t)((const THD*)thd)->start_time);

}

extern "C"

ulong

innobase_thd_get_thread_id(

        const void* thd)

{

    return(thd_get_thread_id((const THD*) thd));

}

void thd_kill(ulong id){

    THD *tmp;

    VOID(pthread_mutex_lock(&LOCK_thread_count));

    I_List_iterator<THD> it(threads);

    while ((tmp=it++))    {

        if (tmp->command == COM_DAEMON || tmp->is_have_lock_thd == 0 ) # 如果是DAEMON线程和不含锁的线程就不要kill了

            continue;

        if (tmp->thread_id == id)

        {

            pthread_mutex_lock(&tmp->LOCK_thd_data);

            break;

        }

    }

    VOID(pthread_mutex_unlock(&LOCK_thread_count));

    if (tmp)

    {

        tmp->awake(THD::KILL_CONNECTION);

        pthread_mutex_unlock(&tmp->LOCK_thd_data);

    }

}

void thd_kill(unsigned long id);

class THD :public Statement,           public Open_tables_state{....  uint16    is_have_lock_thd;....}

  switch (lex->sql_command) {

  case SQLCOM_REPLACE:

  case SQLCOM_REPLACE_SELECT:

  case SQLCOM_UPDATE:

  case SQLCOM_UPDATE_MULTI:

  case SQLCOM_DELETE:

  case SQLCOM_DELETE_MULTI:

  case SQLCOM_INSERT:

  case SQLCOM_INSERT_SELECT:

      thd->is_have_lock_thd = 1;

      break;

  case SQLCOM_COMMIT:

  case SQLCOM_ROLLBACK:

  case SQLCOM_XA_START:

  case SQLCOM_XA_END:

  case SQLCOM_XA_PREPARE:

  case SQLCOM_XA_COMMIT:

  case SQLCOM_XA_ROLLBACK:

  case SQLCOM_XA_RECOVER:

      thd->is_have_lock_thd = 0;

      break;

  }

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 (thd->active_transaction())

838   {

839     if (thd->variables.trx_idle_timeout > 0)

840     {

841       my_net_set_read_timeout(net, thd->variables.trx_idle_timeout);

842     } else if (thd->variables.trx_readonly_idle_timeout > 0 && thd->is_readonly_trx)

843     {

844       my_net_set_read_timeout(net, thd->variables.trx_readonly_idle_timeout);

845     } else if (thd->variables.trx_changes_idle_timeout > 0 && !thd->is_readonly_trx)

846     {

847       my_net_set_read_timeout(net, thd->variables.trx_changes_idle_timeout);

848     } else {

849       my_net_set_read_timeout(net, thd->variables.net_wait_timeout);

850     }

851   } else {

852     my_net_set_read_timeout(net, thd->variables.net_wait_timeout);

853   }

854   /* End */

root@localhost : (none) 08:39:49> set autocommit = 0 ;

Query OK, 0 rows affected (0.00 sec)

root@localhost : (none) 08:39:56> set trx_idle_timeout = 5;

Query OK, 0 rows affected (0.00 sec)

root@localhost : (none) 08:40:17> use perf

Database changed

root@localhost : perf 08:40:19> insert into perf (info ) values('11');

Query OK, 1 row affected (0.00 sec)

root@localhost : perf 08:40:26> select * from perf;

ERROR 2006 (HY000): MySQL server has gone awayNo connection.

Trying to reconnect...Connection id:    6

Current database: perf

+----+------+

| id | info |

+----+------+

|  7 | aaaa |

|  9 | aaaa |

| 11 | aaaa |

+----+------+

3 rows in set (0.00 sec)