PolarDB:ホット行の最適化

テスト環境

• ツール： Sysbench — Lua ベースのテストスクリプトをサポートするオープンソースのマルチスレッドベンチマークツール

• テストシナリオ： 1 行のホット行、8 コア CPU

• テーブル定義：

  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. Sysbench のソースコードの src/lua フォルダに、oltp_inventory.lua という名前のファイルを作成します。

   #!/usr/bin/env sysbench
   -- it is to test inventory_hotspot performance
   
   sysbench.cmdline.options= {
       inventory_hotspot = {"enable ali inventory hotspot", 'off'},
       tables = {"table number", 1},
       table_size = {"table size", 1},
       oltp_skip_trx = {'skip trx', true},
       hotspot_rows = {'hotspot row number', 1}
   }
   
   
   function cleanup()
       drv = sysbench.sql.driver()
       con = drv:connect()
       for i = 1, sysbench.opt.tables do
           print(string.format("drop table 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("Creating table 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 --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

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

   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

入力パラメーター

出力パラメーター