MySQL でコミットされていないトランザクションを見つけるための SQL の例の簡単な分析

mysql> テーブル kkk(id int 、 name varchar(12)) を作成します。
クエリは正常、影響を受けた行は 0 行 (0.34 秒)
 
mysql> kkk 値に挿入します (1、'kerry')。
クエリは正常、1 行が影響を受けました (0.01 秒)
 
mysql> kkk 値に挿入します (2、'jerry')。
クエリは正常、1 行が影響を受けました (0.00 秒)
 
mysql> kkk 値に挿入します (3、'ken')。
クエリは正常、1 行が影響を受けました (0.00 秒)
 
マイSQL> 
 
mysql> テーブル t(varchar(10)) を作成します。
クエリは正常、影響を受けた行は 0 行 (0.47 秒)
 
mysql> t 値に挿入します('test');
クエリは正常、1 行が影響を受けました (0.00 秒)

mysql> デュアルから connection_id() を選択します。
+-----------------+
| 接続ID() |
+-----------------+
| 38 |
+-----------------+
セット内の 1 行 (0.00 秒)
 
mysql> セッションの自動コミットを 0 に設定します。
クエリは正常、影響を受けた行は 0 行 (0.00 秒)
 
mysql> id =1 の kkk から削除します。
クエリは正常、1 行が影響を受けました (0.00 秒)
 
マイSQL>

mysql> t.trx_mysql_thread_idを選択します
 -> 、t.trx_id
 -> 、t.trx_state
 -> 、t.trx_tables_in_use
 -> 、t.trx_tables_locked
 -> 、t.trx_クエリ
 -> 、t.trx_rows_locked 
 -> 、t.trx_rows_modified
 -> 、t.trx_lock_structs
 -> 、t.trx_started
 -> 、t.trx_isolation_level
 -> 、p.時間 
 -> 、p.ユーザー
 -> 、p.ホスト
 -> 、p.db
 -> 、p.コマンド
 -> information_schema.innodb_trx から 
 -> INNER JOIN information_schema.processlist p 
 -> ON t.trx_mysql_thread_id = p.id 
 -> t.trx_state = 'RUNNING' の場合 
 -> かつ p.time > 4 
 -> AND p.command = 'Sleep'\G 
************************** 1. 行 ****************************
trx_mysql_スレッドID: 38
  トランザクションID: 7981581
  trx_state: 実行中
 使用中のtrxテーブル: 0
 trx_tables_locked: 1
  trx_query: NULL
 ロックされた行数: 4
 trx_rows_modified: 1
 trx_lock_structs: 2
 開始日時: 2020-12-03 15:39:37
trx_isolation_level: 繰り返し読み取り
  時間: 23
  ユーザー: ルート
  ホスト: ローカルホスト
   db: マイDB
  コマンド: スリープ
セット内の 1 行 (0.00 秒)

t.trx_mysql_thread_id を connection_id として選択します
 ,t.trx_id AS trx_id  
 ,t.trx_state は trx_state として 
 ,t.trx_started AS trx_started 
 ,TIMESTAMPDIFF(SECOND,t.trx_started, now()) AS "trx_run_time(s)" 
 ,t.trx_requested_lock_id AS trx_requested_lock_id
 ,t.trx_operation_state は trx_operation_state として
 ,t.trx_tables_in_use は trx_tables_in_use として
 ,t.trx_tables_locked は trx_tables_locked として
 ,t.trx_rows_locked は trx_rows_locked として
 ,t.trx_isolation_level AS trx_isolation_level
 ,t.trx_is_read_only は trx_is_read_only です
 ,t.trx_autocommit_non_locking は trx_autocommit_non_locking として
 ,e.イベント名 AS イベント名
 ,e.timer_wait / 1000000000000 AS timer_wait
 ,e.sql_text 
information_schema.innodb_trx から、 
 performance_schema.events_statements_current e、 
 パフォーマンススキーマ.スレッド c 
ここで、t.trx_mysql_thread_id = c.processlist_id 
 かつ、e.thread_id = c.thread_id\G;

mysql> セッションの自動コミットを 0 に設定します。
クエリは正常、影響を受けた行は 0 行 (0.01 秒)
 
mysql> id =1 の kkk から削除します。
クエリは正常、1 行が影響を受けました (0.00 秒)
 
mysql> t から * を選択します。
+------+
| ア |
+------+
| テスト |
+------+
セット内の 1 行 (0.00 秒)
 
マイSQL>

mysql> t.trx_mysql_thread_id を connection_id として選択します
 -> 、t.trx_id は trx_id として  
 -> 、t.trx_state は trx_state として 
 -> ,t.trx_started は trx_started として 
 -> ,TIMESTAMPDIFF(SECOND,t.trx_started, now()) AS "trx_run_time(s)" 
 -> 、t.trx_requested_lock_id は trx_requested_lock_id として
 -> 、t.trx_operation_state は trx_operation_state として
 -> 、t.trx_tables_in_use は trx_tables_in_use として
 -> 、t.trx_tables_locked は trx_tables_locked として
 -> 、t.trx_rows_locked は trx_rows_locked として
 -> 、t.trx_isolation_level は trx_isolation_level として
 -> 、t.trx_is_read_only は trx_is_read_only です
 -> 、t.trx_autocommit_non_locking は trx_autocommit_non_locking として
 -> ,e.event_name AS イベント名
 -> 、e.timer_wait / 1000000000000 AS timer_wait
 -> ,e.sql_text 
 -> information_schema.innodb_trx t から、 
 -> performance_schema.events_statements_current e、 
 -> performance_schema.threads c 
 -> ここで t.trx_mysql_thread_id = c.processlist_id 
 -> かつ e.thread_id = c.thread_id\G; 
************************** 1. 行 ****************************
  接続ID: 38
   トランザクションID: 7981581
   trx_state: 実行中
  開始日時: 2020-12-03 15:39:37
  trx_run_time(秒): 237
 trx_requested_lock_id: NULL
 trx_operation_state: NULL
  使用中のtrxテーブル: 0
  trx_tables_locked: 1
  ロックされた行数: 4
 trx_isolation_level: 繰り返し読み取り
  trx_is_read_only: 0
trx_autocommit_non_locking: 0
  イベント名: ステートメント/SQL/選択
  タイマー待機: 0.0002
   sql_text: t から * を選択
セット内の 1 行 (0.00 秒)
 
エラー： 
クエリが指定されていません

trx.trx_mysql_thread_id を processlist_id として選択します
 ,sc.スレッドID
 ,trx.trx_開始
 、TO_SECONDS(now())-TO_SECONDS(trx_started) AS trx_last_time 
 、pc1.ユーザー
 ,pc1.ホスト
 ,pc1.db
 ,sc.SQL_TEXT を現在の SQL テキストとして
 ,sh.history_sql_test
INFORMATION_SCHEMA.INNODB_TRX trx から
INNER JOIN INFORMATION_SCHEMA.processlist pc1 ON trx.trx_mysql_thread_id=pc1.id
th.processlist_id = trx.trx_mysql_thread_id の performance_schema.threads th の内部結合
内部結合 performance_schema.events_statements_current sc ON sc.THREAD_ID = th.THREAD_ID
内部結合（
  SELECT thread_id AS thread_id, GROUP_CONCAT(SQL_TEXT SEPARATOR ';') AS history_sql_test
  performance_schema.events_statements_history から 
  スレッドIDでグループ化 
  ) sh ON sh.thread_id = th.thread_id
ここで、trx_mysql_thread_id != connection_id()
 TO_SECONDS(now())-TO_SECONDS(trx_started) >= 0; です。

@dt_ts を選択:=UNIX_TIMESTAMP(NOW());
選択 
 @dt_timer:=MAX(sh.TIMER_START)
performance_schema.threads から t へ
内部結合 performance_schema.events_statements_history AS sh
ON t.`THREAD_ID`=sh.`THREAD_ID`
ここで、t.PROCESSLIST_ID=CONNECTION_ID();
 
 
sh.current_schema AS database_name を選択
 ,t.スレッドID
 ,it.trx_mysql_thread_id AS connection_id
 ,it.trx_id
 ,sh.イベントID
 ,it.trx_state
 ,REPLACE(REPLACE(REPLACE(sh.`SQL_TEXT`,'\n',' '),'\r',' '),'\t',' ') AS 実行されたSQL
 ,it.trx_started
 、FROM_UNIXTIME(@dt_ts-CAST((@dt_timer-sh.TIMER_START)/1000000000000 AS SIGNED)) AS start_time
 、FROM_UNIXTIME(@dt_ts-CAST((@dt_timer-sh.TIMER_END) /1000000000000 AS SIGNED)) AS end_time
 ,(sh.TIMER_END-sh.TIMER_START)/1000000000000 AS used_seconds
 ,sh.TIMER_WAIT/1000000000000 AS wait_seconds
 ,sh.LOCK_TIME/1000000000000 AS lock_seconds
 ,sh.ROWS_AFFECTED AS 影響を受ける行
 ,sh.ROWS_SENT は send_rows として
performance_schema.threads から t へ
INNER JOIN information_schema.innodb_trx it ON it.trx_mysql_thread_id = t.processlist_id 
内部結合 performance_schema.events_statements_history AS sh
 ON t.`THREAD_ID`=sh.`THREAD_ID`
t.PROCESSLIST_ID IN ( ) のWHERE
  選択 
   p.ID AS conn_id
  `information_schema`.`INNODB_TRX` から t
  INNER JOIN `information_schema`.`PROCESSLIST` p
   オン t.trx_mysql_thread_id=p.id
  t.trx_state='RUNNING' の場合
   かつ p.COMMAND='スリープ'
   かつp.TIME>2
  ）
そして、sh.TIMER_START<@dt_timer
AND FROM_UNIXTIME(@dt_ts-CAST((@dt_timer-sh.TIMER_START)/1000000000000 AS SIGNED)) >=it.trx_started
it.trx_id ASC、sh.TIMER_START ASC で順序付けします。 

sh.current_schema AS database_name を選択
 ,t.スレッドID
 ,it.trx_mysql_thread_id AS connection_id
 ,it.trx_id
 ,sh.イベントID
 ,it.trx_state
 ,REPLACE(REPLACE(REPLACE(sh.`SQL_TEXT`,'\n',' '),'\r',' '),'\t',' ') AS 実行されたSQL
 ,it.trx_started
 ,DATE_SUB(NOW(), INTERVAL (SELECT VARIABLE_VALUE FROM performance_schema.global_status WHERE VARIABLE_NAME='UPTIME') - sh.TIMER_START*10e-13 秒) AS start_time
 ,DATE_SUB(NOW(), INTERVAL (SELECT VARIABLE_VALUE FROM performance_schema.global_status WHERE VARIABLE_NAME='UPTIME') - sh.TIMER_END*10e-13 秒) AS end_time
 ,(sh.TIMER_END-sh.TIMER_START)/1000000000000 AS used_seconds
 ,sh.TIMER_WAIT/1000000000000 AS wait_seconds
 ,sh.LOCK_TIME/1000000000000 AS lock_seconds
 ,sh.ROWS_AFFECTED AS 影響を受ける行
 ,sh.ROWS_SENT は send_rows として
performance_schema.threads から t へ
INNER JOIN information_schema.innodb_trx it ON it.trx_mysql_thread_id = t.processlist_id 
内部結合 performance_schema.events_statements_history AS sh
 ON t.`THREAD_ID`=sh.`THREAD_ID`
t.PROCESSLIST_ID IN ( ) のWHERE
  選択 
   p.ID AS conn_id
  `information_schema`.`INNODB_TRX` から t
  INNER JOIN `information_schema`.`PROCESSLIST` p
   オン t.trx_mysql_thread_id=p.id
  t.trx_state='RUNNING' の場合
   かつ p.COMMAND='スリープ'
   かつp.TIME>2
  ）
AND sh.TIMER_START<(SELECT VARIABLE_VALUE*10000000000000 FROM performance_schema.global_status WHERE VARIABLE_NAME='UPTIME')
AND DATE_SUB(NOW(), INTERVAL (SELECT VARIABLE_VALUE FROM performance_schema.global_status WHERE VARIABLE_NAME='UPTIME') - sh.TIMER_START*10e-13 秒) >= it.trx_started
it.trx_id ASC、sh.TIMER_START ASC で順序付けします。