tencent cloud

TDSQL-C for MySQL

ドキュメントTDSQL-C for MySQL操作ガイドパラレルクエリパラレルクエリの設定パラレルクエリの表示

パラレルクエリの表示

ダウンロード
フォーカスモード
フォントサイズ
最終更新日: 2025-12-30 16:39:26
TDSQL-C for MySQLはパラレルクエリの実行計画を確認でき、どのスレッドがパラレルクエリ計画を実行しているかを把握できます。これにより、パラレルクエリがデータベース内で安定的に有効化される仕組みを明確に理解できるほか、パラレルクエリ実行中に問題が発生した場合の迅速な特定が可能となります。 本稿ではパラレルクエリを確認する2つの主要な方法についてご紹介します。

方法1：EXPLAINステートメントの使用

テーブル作成の例：
CREATE TABLE lineitem (
  L_ORDERKEY INTEGER NOT NULL,
  L_PARTKEY INTEGER NOT NULL,
  L_SUPPKEY INTEGER NOT NULL,
  L_LINENUMBER INTEGER NOT NULL,
  L_QUANTITY DECIMAL(15, 2) NOT NULL,
  L_EXTENDEDPRICE DECIMAL (15, 2) NOT NULL,
  L_DISCOUNT DECIMAL(15, 2) NOT NULL,
  L_TAX DECIMAL(15, 2) NOT NULL,
  L_RETURNFLAG CHAR(1) NOT NULL,
  L_LINESTATUS CHAR(1) NOT NULL,
  L_SHIPDATE DATE NOT NULL,
  L_COMMITDATE DATE NOT NULL,
  L_RECEIPTDATE DATE NOT NULL,
  L_SHIPINSTRUCT CHAR(25) NOT NULL,
  L_SHIPMODE CHAR(10) NOT NULL,
  L_COMMENT VARCHAR(44) NOT NULL
  );
挿入されたデータセットはTPC-Hからです。
SQL文の例：
SELECT l_returnflag, l_linestatus, sum(l_quantity) as sum_qty
FROM lineitem
WHERE l_shipdate <= '1998-09-02'
GROUP BY l_returnflag, l_linestatus
ORDER BY l_returnflag, l_linestatus;
本サンプルはTPC-H Q1の簡略版であり、典型的なレポート処理です。
実行計画出力文（EXPLAIN）：
EXPLAIN  SELECT l_returnflag, l_linestatus, sum(l_quantity) as sum_qty
FROM lineitem
WHERE l_shipdate <= '1998-09-02'
GROUP BY l_returnflag, l_linestatus
ORDER BY l_returnflag, l_linestatus;
クエリ結果：
MySQL [tpch100g]> explain SELECT l_returnflag, l_linestatus, sum(l_quantity) as sum_qty FROM lineitem WHERE l_shipdate <= '1998-09-02' GROUP BY l_returnflag, l_linestatus ORDER BY l_returnflag, l_linestatus;
+----+-------------+-------------+------------+------+---------------+------+---------+------+-----------+----------+-----------------------------------------------------------+
| id | select_type | table       | partitions | type | possible_keys | key  | key_len | ref  | rows      | filtered | Extra                                                     |
+----+-------------+-------------+------------+------+---------------+------+---------+------+-----------+----------+-----------------------------------------------------------+
|  1 | SIMPLE      | lineitem    | NULL       | ALL  | i_l_shipdate  | NULL | NULL    | NULL | 593184480 |    50.00 | Parallel scan (4 workers); Using where; Using temporary   |
|  1 | SIMPLE      | <sender1>   | NULL       | ALL  | NULL          | NULL | NULL    | NULL |         0 |     0.00 | Send to (<receiver1>)                                     |
|  1 | SIMPLE      | <receiver1> | NULL       | ALL  | NULL          | NULL | NULL    | NULL |         0 |     0.00 | Receive from (<sender1>); Using temporary; Using filesort |
+----+-------------+-------------+------------+------+---------------+------+---------+------+-----------+----------+-----------------------------------------------------------+
3 rows in set, 1 warning (0.00 sec)
ツリー状実行計画出力文（EXPLAIN format=tree）：
EXPLAIN format=tree query  SELECT l_returnflag, l_linestatus, sum(l_quantity) as sum_qty
FROM lineitem
WHERE l_shipdate <= '1998-09-02'
GROUP BY l_returnflag, l_linestatus
ORDER BY l_returnflag, l_linestatus;
クエリ結果：
MySQL [tpch100g]> explain format=tree SELECT l_returnflag, l_linestatus, sum(l_quantity) as sum_qty FROM lineitem WHERE l_shipdate <= '1998-09-02' GROUP BY l_returnflag, l_linestatus ORDER BY l_returnflag, l_linestatus\\G
*************************** 1. row ***************************
EXPLAIN: -> Sort: lineitem.L_RETURNFLAG, lineitem.L_LINESTATUS
    -> Table scan on <temporary>
        -> Final Aggregate using temporary table
            -> PX Receiver (slice: 0; workers: 1)
                -> PX Sender (slice: 1; workers: 4)
                    -> Table scan on <temporary>
                        -> Aggregate using temporary table
                            -> Filter: (lineitem.L_SHIPDATE <= DATE'1998-09-02')  (cost=65449341.10 rows=296592240)
                                -> Parallel table scan on lineitem  (cost=65449341.10 rows=593184480)

1 row in set (0.00 sec)
上記の結果から、次のように見て取れます：
パラレルクエリプランは4つのワーカースレッドに文を分散します。
集計演算を上位段階と下位段階に分割され、ユーザースレッドとパラレルスレッドがそれぞれが実行します。
lineitemテーブルに対して並列走査オペレータを採用しました。
この例では、ツリー状実行計画の出力（EXPLAIN format=tree query）は、従来の実行計画の出力（EXPLAIN）より効果的です。

方法2：スレッドリスト表示

show processlistコマンドの出力結果は、どのスレッドが実行中であるかを表示し、現在のすべての接続数を確認できるだけでなく、現在の接続状態を確認することで問題のあるクエリ文の識別に役立ちます。 show processlistコマンドに基づき、TDSQL-C for MySQLはshow parallel processlist文を独自開発し、スレッド内の非並列クエリスレッドのフィルタリングに役立ちます。このコマンドを使用すると、並列クエリに関連するスレッドのみが表示されます。 例 SQL文：
SELECT l_returnflag, l_linestatus, sum(l_quantity) as sum_qty
FROM lineitem
WHERE l_shipdate <= '1998-09-02'
GROUP BY l_returnflag, l_linestatus
ORDER BY l_returnflag, l_linestatus;
本サンプルはTPC-H Q1の簡略版であり、典型的なレポート処理です。 show processlist クエリ結果：
mysql> show processlist;
+--------+-------------+-----------------+-----------+---------+-------+------------+------------------------------------------------------------------------------------------------------+
| Id     | User        | Host            | db        | Command | Time  | State      | Info                                                                                                 |
+--------+-------------+-----------------+-----------+---------+-------+------------+------------------------------------------------------------------------------------------------------+
|      7 | tencentroot | 127.0.0.1:49238 | NULL      | Sleep   |     0 |            | NULL                                                                                                 |
|     11 | tencentroot | 127.0.0.1:49262 | NULL      | Sleep   |     0 |            | NULL                                                                                                 |
|     13 | tencentroot | 127.0.0.1:49288 | NULL      | Sleep   |     1 |            | NULL                                                                                                 |
| 237062 | tencentroot | localhost       | tpch100g  | Query   |    24 | Scheduling | SELECT l_returnflag, l_linestatus, sum(l_quantity) as sum_qty FROM lineitem WHERE l_shipdate <= '199 |
| 237107 | tencentroot | localhost       | NULL      | Query   |     0 | init       | show processlist                                                                                     |
+--------+-------------+-----------------+-----------+---------+-------+------------+------------------------------------------------------------------------------------------------------+
6 rows in set (0.00 sec)
show parallel processlist クエリ結果：
mysql> show parallel processlist;
+--------+-------------+-----------+----------+---------+------+-------------+------------------------------------------------------------------------------------------------------+
| Id     | User        | Host      | db       | Command | Time | State       | Info                                                                                                 |
+--------+-------------+-----------+----------+---------+------+-------------+------------------------------------------------------------------------------------------------------+
| 237062 | tencentroot | localhost | tpch100g | Query   |   18 | Scheduling  | SELECT l_returnflag, l_linestatus, sum(l_quantity) as sum_qty FROM lineitem WHERE l_shipdate <= '199 |
| 237110 |             |           |          | Task    |   18 | Task runing | connection 237062, worker 0, task 1                                                                  |
| 237111 |             |           |          | Task    |   18 | Task runing | connection 237062, worker 1, task 1                                                                  |
| 237112 |             |           |          | Task    |   18 | Task runing | connection 237062, worker 2, task 1                                                                  |
| 237113 |             |           |          | Task    |   18 | Task runing | connection 237062, worker 3, task 1                                                                  |
+--------+-------------+-----------+----------+---------+------+-------------+------------------------------------------------------------------------------------------------------+
5 rows in set (0.00 sec)
上記の結果から、次のように見て取れます：
上記のクエリはパラレルプランによって4つのワーカースレッドに分散実行されます：userには1行のみ表示されており、ID 237062がユーザースレッドであることを示しています。このスレッドはSQL文の実行計画を下記の4つのワーカースレッドにプッシュダウンし、info列から確認できるように、これら4つのワーカースレッドは全てtask1を実行中です。
各スレッドをクエリ可能で、正確に特定できます。
show parallel processlist は show processlist と比較して、すべてのパラレルクエリを実行中のスレッドを正確にクエリ可能であり、他のスレッドの影響を受けません。

関連ドキュメント

パラレルクエリを有効化または無効化する
ヒントステートメント制御
パラレルクエリ指標
前の記事へ: hint ステートメント制御次の記事へ: パラレルクエリ指標

ヘルプとサポート

この記事はお役に立ちましたか？

フィードバック