オンライン統計情報収集

オンライン統計情報収集とは、INSERT ステートメントの実行時にデータベースオプティマイザーが統計情報を収集できる機能であり、システムパッケージを手動で呼び出す必要はありません。一括データインポート処理中にリアルタイムで統計情報を収集でき、追加の収集タスクを開始する必要がなく、運用作業を削減し、統計情報収集のパフォーマンスを向上させます。

OceanBaseデータベースでは、GATHER_OPTIMIZER_STATISTICS/NO_GATHER_OPTIMIZER_STATISTICS ヒントおよびシステム変数 _optimizer_gather_stats_on_load（デフォルトで有効）を使用してオンライン統計情報収集を行うことができます。また、ダイレクトロード機能の APPEND ヒントを使用してオンライン統計情報収集を実現することも可能です。

オンライン統計情報収集の主なトリガーシナリオは以下のとおりです：

• CREATE TABLE...AS SELECT (CTAS)

  システム変数 _optimizer_gather_stats_on_load が True の場合、CTAS はデフォルトでオンライン統計情報収集機能を有効にします。この機能を無効にするには、NO_GATHER_OPTIMIZER_STATISTICS ヒントを使用します。例：

  CREATE TABLE table_name AS SELECT /*+NO_GATHER_OPTIMIZER_STATISTICS*/* FROM...
  

• INSERT INTO SELECT

  システム変数 _optimizer_gather_stats_on_load が True の場合、GATHER_OPTIMIZER_STATISTICS ヒントまたは APPEND ヒントを使用してオンライン統計情報収集機能を有効にします。 例：

  INSERT /*+GATHER_OPTIMIZER_STATISTICS*/ INTO table_name SELECT * FROM table_name
  

  注意

  OceanBaseデータベースは、INSERT /*+GATHER_OPTIMIZER_STATISTICS*/ INTO table_name VALUES()... ステートメントを使用したオンライン統計情報収集を現在サポートしていません。

• PDML

  ENABLE_PARALLEL_DML ヒント、または ALTER SESSION ENABLE PARALLEL DML; を使用してシステム並列モードを設定することで、挿入操作を並列的に実行します。

  例：

  CREATE TABLE t1(c1 INT) PARTITION BY HASH(c1) PARTITIONS 4;
  CREATE TABLE t2(c1 INT) PARTITION BY HASH(c1) PARTITIONS 4;
  INSERT INTO t1 VALUES (1),(2),(3),(4);
  
  obclient> EXPLAIN INSERT /*+ENABLE_PARALLEL_DML PARALLEL(4)*/ INTO t2 SELECT * FROM t1;
  +-----------------------------------------------------------------------------------------------------------------------------------------------------------------+
  | Query Plan                                                                                                                                                      |
  +-----------------------------------------------------------------------------------------------------------------------------------------------------------------+
  | ================================================================================                                                                                |
  | |ID|OPERATOR                             |NAME           |EST.ROWS|EST.TIME(us)|                                                                                |
  | --------------------------------------------------------------------------------                                                                                |
  | |0 |OPTIMIZER STATS MERGE                |               |1       |16          |                                                                                |
  | |1 | PX COORDINATOR                      |               |1       |16          |                                                                                |
  | |2 |  EXCHANGE OUT DISTR                 |:EX10001       |1       |16          |                                                                                |
  | |3 |   INSERT                            |               |1       |15          |                                                                                |
  | |4 |    EXCHANGE IN DISTR                |               |1       |2           |                                                                                |
  | |5 |     EXCHANGE OUT DISTR (PKEY RANDOM)|:EX10000       |1       |2           |                                                                                |
  | |6 |      OPTIMIZER STATS GATHER         |               |1       |2           |                                                                                |
  | |7 |       SUBPLAN SCAN                  |ANONYMOUS_VIEW1|1       |2           |                                                                                |
  | |8 |        PX BLOCK ITERATOR            |               |1       |2           |                                                                                |
  | |9 |         TABLE SCAN                  |T1             |1       |2           |                                                                                |
  | ================================================================================                                                                                |
  | Outputs & filters:                                                                                                                                              |
  | -------------------------------------                                                                                                                           |
  |   0 - output(nil), filter(nil), rowset=256                                                                                                                      |
  |   1 - output([column_conv(NUMBER,PS:(-1,0),NULL,ANONYMOUS_VIEW1.C1)]), filter(nil), rowset=256                                                                  |
  |   2 - output([column_conv(NUMBER,PS:(-1,0),NULL,ANONYMOUS_VIEW1.C1)]), filter(nil), rowset=256                                                                  |
  |       dop=4                                                                                                                                                     |
  |   3 - output([column_conv(NUMBER,PS:(-1,0),NULL,ANONYMOUS_VIEW1.C1)]), filter(nil)                                                                              |
  |       columns([{T2: ({T2: (T2.__pk_increment, T2.C1)})}]), partitions(p[0-3]),                                                                                  |
  |       column_values([T_HIDDEN_PK], [column_conv(NUMBER,PS:(-1,0),NULL,ANONYMOUS_VIEW1.C1)])                                                                     |
  |   4 - output([column_conv(NUMBER,PS:(-1,0),NULL,ANONYMOUS_VIEW1.C1)], [PARTITION_ID], [T_HIDDEN_PK]), filter(nil), rowset=256                                   |
  |   5 - output([column_conv(NUMBER,PS:(-1,0),NULL,ANONYMOUS_VIEW1.C1)], [PARTITION_ID], [T_HIDDEN_PK]), filter(nil), rowset=256                                   |
  |       (#keys=1, [column_conv(NUMBER,PS:(-1,0),NULL,ANONYMOUS_VIEW1.C1)]), dop=4                                                                                 |
  |   6 - output([column_conv(NUMBER,PS:(-1,0),NULL,ANONYMOUS_VIEW1.C1)], [calc_tablet_id(PARTITION_HASH(column_conv(NUMBER,PS:(-1,0),NULL,ANONYMOUS_VIEW1.C1)))]), |
  | filter(nil), rowset=256                                                                                                                                         |
  |   7 - output([ANONYMOUS_VIEW1.C1]), filter(nil), rowset=256                                                                                                     |
  |       access([ANONYMOUS_VIEW1.C1])                                                                                                                              |
  |   8 - output([T1.C1]), filter(nil), rowset=256                                                                                                                  |
  |   9 - output([T1.C1]), filter(nil), rowset=256                                                                                                                  |
  |       access([T1.C1]), partitions(p[0-3])                                                                                                                       |
  |       is_index_back=false, is_global_index=false,                                                                                                               |
  |       range_key([T1.__pk_increment]), range(MIN ; MAX)always true                                                                                               |
  +-----------------------------------------------------------------------------------------------------------------------------------------------------------------+
  35 rows in set
  

  上記の例では、OPTIMIZER_STATS MERGE 演算子が生成されており、オンライン統計情報収集が実行されたことを示しています。

ユーザーがオンラインで収集した統計情報は、対応するビューで確認できます。ビューの詳細については、統計情報収集方法の概要を参照してください。

例：

CREATE TABLE t1(c1 INT) PARTITION BY HASH(c1) PARTITIONS 4;
CREATE TABLE t2(c1 INT) PARTITION BY HASH(c1) PARTITIONS 4;
INSERT INTO t1 VALUES (1),(2),(3),(4);
INSERT /*+ENABLE_PARALLEL_DML PARALLEL(4)*/ INTO t2 SELECT * FROM t1;

-- Oracleモード
OceanBase(SYS@SYS)> SELECT table_name, partition_name, num_rows, avg_row_len FROM user_tab_statistics WHERE table_name='T2';
+------------+----------------+----------+-------------+
| TABLE_NAME | PARTITION_NAME | NUM_ROWS | AVG_ROW_LEN |
+------------+----------------+----------+-------------+
| T2         | NULL           |        4 |          20 |
| T2         | P0             |        1 |          20 |
| T2         | P1             |        2 |          20 |
| T2         | P2             |        1 |          20 |
| T2         | P3             |        0 |           0 |
+------------+----------------+----------+-------------+

-- MySQLモード
OceanBase(root@test)> SELECT table_name, partition_name, num_rows, avg_row_len FROM OCEANBASE.DBA_TAB_STATISTICS WHERE table_name='T2';
+------------+----------------+----------+-------------+
| table_name | partition_name | num_rows | avg_row_len |
+------------+----------------+----------+-------------+
| t2         | NULL           |        4 |          20 |
| t2         | p0             |        1 |          20 |
| t2         | p1             |        1 |          20 |
| t2         | p2             |        1 |          20 |
| t2         | p3             |        1 |          20 |
+------------+----------------+----------+-------------+