PolarDB:ホット行の最適化

カスタムパラメーター構成

PolarDBコンソールでは、次のパラメーターを変更できません。変更するには、Quota Center に移動します。[PolarDB Hotspot Row Parameter Adjustment] という名前のクォータを見つけ、[アクション] 列の [適用] をクリックします。

パラメーター構成の表示

次のコマンドを実行して、ホット行の最適化機能のパラメーター構成を表示します。

SHOW variables LIKE "hotspot%";

結果の例：

+------------------------------+-------+
|Variable_name                 | Value |
+------------------------------+-------+
|hotspot                       | OFF   |
|hotspot_for_autocommit        | OFF   |
|hotspot_lock_type             | OFF   |
|hotspot_update_max_wait_time  | 100   |
+------------------------------+-------+

使用状況の表示

次のコマンドを実行して、ホット行の最適化機能の使用状況を表示します。

SHOW GLOBAL status LIKE 'Group_update%';

テストツール

Sysbench は、オープンソースのクロスプラットフォームパフォーマンステストツールです。主に MySQL などのデータベースベンチマークや、CPU、メモリ、I/O、スレッドなどのコンポーネントのシステムパフォーマンステストに使用されます。マルチスレッドテストをサポートし、Lua スクリプトを使用してテストロジックを柔軟に制御します。データベースのパフォーマンス評価やストレステストなどのシナリオに適しています。

テストデータテーブルとテストステートメント

• テーブル定義

  CREATE TABLE sbtest (id INT UNSIGNED NOT NULL, c BIGINT UNSIGNED NOT NULL, PRIMARY KEY (id));

• テストステートメント

  UPDATE /*+ COMMIT_ON_SUCCESS ROLLBACK_ON_FAIL TARGET_AFFECT_ROW(1) */ sbtest SET c = c + 1 WHERE id = 1;

テスト結果

付録: パフォーマンステストの手順

1. ECS インスタンスを準備し、Sysbench をインストールします。

2. 次の oltp_inventory.lua を Sysbench ソースコードの src/lua フォルダに配置します。

   #!/usr/bin/env sysbench
   -- 在庫ホットスポットのパフォーマンスをテストするためのものです
   
   sysbench.cmdline.options= {
       inventory_hotspot = {"ali 在庫ホットスポットを有効にする", 'off'},
       tables = {"テーブル数", 1},
       table_size = {"テーブルサイズ", 1},
       oltp_skip_trx = {'trx をスキップ', true},
       hotspot_rows = {'ホットスポット行数', 1}
   }
   
   
   function cleanup()
       drv = sysbench.sql.driver()
       con = drv:connect()
       for i = 1, sysbench.opt.tables do
           print(string.format("テーブル sbtest%d をドロップしています...", i))
           drop_table(drv, con, i)
       end
   end
   
   function drop_table(drv, con, table_id)
       local query
       query = string.format("drop table if exists sbtest%d ", table_id)
       con:query(query)
   end
   
   function create_table(drv, con, table_id)
       local query
       query = string.format("CREATE TABLE sbtest%d (id INT UNSIGNED NOT NULL, c BIGINT UNSIGNED NOT NULL, PRIMARY KEY (id))", table_id)
       con:query(query)
       for i=1, sysbench.opt.table_size do
           con:query("INSERT INTO sbtest" .. table_id .. "(id, c) values (" ..i.. ", 1)")
       end
   end
   
   function prepare()
       drv = sysbench.sql.driver()
       con = drv:connect()
       for i = 1, sysbench.opt.tables do
           print(string.format("テーブル sbtest%d を作成しています...", i))
           create_table(drv, con, i)
       end
   end
   
   function thread_init()
       drv = sysbench.sql.driver()
       con = drv:connect()
       begin_query = 'BEGIN'
       commit_query = 'COMMIT'
   end
   
   function event()
       local table_name
       table_name = "sbtest" .. sysbench.rand.uniform(1, sysbench.opt.tables)
       local min_line = math.min(sysbench.opt.table_size, sysbench.opt.hotspot_rows)
       local row_id = sysbench.rand.uniform(1, min_line)
   
       if not sysbench.opt.oltp_skip_trx then
           con:query(begin_query)
       end
   
       if (sysbench.opt.inventory_hotspot == "on") then
           con:query("UPDATE COMMIT_ON_SUCCESS ROLLBACK_ON_FAIL TARGET_AFFECT_ROW 1 " .. table_name .. " SET c=c+1 WHERE id =" .. row_id)
       else
           con:query("UPDATE " .. table_name .. " SET c=c+1 WHERE id = " .. row_id)
       end
   
       if not sysbench.opt.oltp_skip_trx then
           if (sysbench.opt.inventory_hotspot == "on") then
               con:query(commit_query)
           end
       end
   end
   
   function thread_done()
      con:disconnect()
   end

3. コマンドラインを使用してクラスターに接続します。

4. Sysbench テストを実行します。

   1. データを準備します。

      sysbench --hotspot_rows=1 --histogram=on --mysql-user=<user> --inventory_hotspot=on --mysql-host=<host> --threads=1 --report-interval=1 --mysql-password=<password> --tables=1 --table-size=1 --oltp_skip_trx=true --db-driver=mysql --percentile=95 --time=300 --mysql-port=<port> --events=0 --mysql-db=<database> oltp_inventory prepare

   2. テストを実行します。

      sysbench --db-driver=mysql --mysql-host=<host> --mysql-port=<port> --mysql-user=<user> --mysql-password=<password> --mysql-db=<database> --range-selects=0 --table_size=25000 --tables=250 --events=0 --time=600 --rand-type=uniform --threads=<threads> oltp_read_only run

   入力パラメーター

   パラメーター	説明
   mysql-host	クラスターエンドポイント。
   mysql-port	クラスターエンドポイントのポート。
   mysql-user	クラスターのユーザー名。
   mysql-password	クラスターユーザーのパスワード。
   mysql-db	データベース名。

   出力パラメーター

   パラメーター	表示内容	説明
   tables	データテーブルの数	テストで使用されるデータテーブルの総数。
   table_size	データテーブルの行数	各テーブルのレコード数。
   	データサイズ	テーブル内のデータのサイズ。MB や GB などのストレージ単位で表示されます。
   threads	同時実行スレッド数	構成されたスレッドの数。
   	スレッドステータス	スレッドのリアルタイム実行ステータス。