ApsaraDB RDS:ステートメント同時実行制御

RDSインスタンスは、次のいずれかのMySQLバージョンを実行します。

• MySQL 8.0

• MySQL 5.7

CCLは、次の寸法に基づいて機能を提供します。

• SQLコマンド

  SELECT、UPDATE、INSERT、DELETEなどのSQL文の種類。

• オブジェクト

  テーブルやビューなど、SQL文によって管理されるオブジェクト。

• キーワード

  SQL文のキーワード。

• テンプレート

  SQL文のテンプレート。

AliSQLは、concurrency_controlという名前のシステムテーブルを使用してCCLルールを格納します。 システムが起動すると、システムは自動的にテーブルを作成します。 次のステートメントを実行して、テーブルを作成できます。

CREATE TABLE `concurrency_control` (
  `Id` bigint NOT NULL AUTO_INCREMENT,
  `Type` enum('SELECT','UPDATE','INSERT','DELETE','TEMPLATE') CHARACTER SET utf8mb3 COLLATE utf8mb3_general_ci NOT NULL DEFAULT 'SELECT',
  `Schema_name` varchar(64) COLLATE utf8mb3_bin DEFAULT NULL,
  `Table_name` varchar(64) COLLATE utf8mb3_bin DEFAULT NULL,
  `Concurrency_count` bigint NOT NULL,
  `Keywords` text COLLATE utf8mb3_bin,
  `State` enum('N','Y') CHARACTER SET utf8mb3 COLLATE utf8mb3_general_ci NOT NULL DEFAULT 'Y',
  `Ordered` enum('N','Y') CHARACTER SET utf8mb3 COLLATE utf8mb3_general_ci NOT NULL DEFAULT 'N',
  `Digest` varchar(64) COLLATE utf8mb3_bin DEFAULT NULL,
  `SQL_template` longtext COLLATE utf8mb3_bin,
  PRIMARY KEY (`Id`)
) /*!50100 TABLESPACE `mysql` */ ENGINE=InnoDB DEFAULT CHARSET=utf8mb3 COLLATE=utf8mb3_bin STATS_PERSISTENT=0 COMMENT='Concurrency control'

AliSQLは、DBMS_CCLパッケージに4つの管理インターフェイスを提供します。 次のリストは、インターフェイスについて説明します。

• add_ccl_rule

  ルールを作成します。 サンプルコマンド:

  dbms_ccl.add_ccl_rule('<Type>','<Schema_name>','<Table_name>',<Concurrency_count>,'<Keywords>');

  例：

  SELECT文の同時スレッド数が10のルールを作成します。

  mysql> call dbms_ccl.add_ccl_rule('SELECT', '', '', 10, '');

  SELECTステートメントの同時スレッド数が20で、ステートメントのキーワードがkey1であるルールを作成します。

  mysql> call dbms_ccl.add_ccl_rule('SELECT', '', '', 20, 'key1');

  test.t表のSELECT文の同時スレッド数が20のルールを作成します。

  mysql> call dbms_ccl.add_ccl_rule('SELECT', 'test', 't', 20, '');

  説明

  Id値が大きいルールの優先度は高くなります。

• add_ccl_template_rule

  テンプレートルールを作成します。 サンプルコマンド:

  dbms_ccl.add_ccl_rule('<Type>','<Schema_name>','<Table_name>',<Concurrency_count>,'', 'Template_sql');

  説明

  • Table_nameパラメーターを指定する必要はありません。 Template_sqlパラメーターに1つのSQL文を指定する必要があります。

  • このルールは、MySQL 8.0を実行し、20230630以降のマイナーエンジンバージョンを実行するRDSインスタンスでのみサポートされます。

  例：

  テストデータベース内の 'SELECT c FROM t1 WHERE id=? テンプレートを持つSQL文の同時スレッド数が30であるテンプレートルールを作成します。

  call dbms_ccl.add_ccl_rule('TEMPLATE', 'test', '', 30, '', 'SELECT c FROM t1 WHERE id=4');

• del_ccl_rule

  ルールを削除します。 サンプルコマンド:

  dbms_ccl.del_ccl_rule(<Id>);

  例：

  IDが15のCCLルールを削除します。

  mysql> call dbms_ccl.del_ccl_rule(15);

  説明

  削除するルールが存在しない場合、システムはエラーを報告します。 SHOW WARNINGS; ステートメントを実行して、エラーメッセージを表示できます。

  mysql> call dbms_ccl.del_ccl_rule(100);
    Query OK, 0 rows affected, 2 warnings (0.00 sec)
  
  mysql> show warnings;
  +---------+------+----------------------------------------------------+
  | Level   | Code | Message                                            |
  +---------+------+----------------------------------------------------+
  | Warning | 7514 | Concurrency control rule 100 is not found in table |
  | Warning | 7514 | Concurrency control rule 100 is not found in cache |
  +---------+------+----------------------------------------------------+

• show_ccl_rule

  メモリ内の有効なルールを表示します。 サンプルコマンド:

  dbms_ccl.show_ccl_rule();

  例：

  ​mysql> call dbms_ccl.show_ccl_rule();
  +------+--------+--------+-------+-------+-------+-------------------+---------+---------+----------+----------+
  | ID   | TYPE   | SCHEMA | TABLE | STATE | ORDER | CONCURRENCY_COUNT | MATCHED | RUNNING | WAITTING | KEYWORDS |
  +------+--------+--------+-------+-------+-------+-------------------+---------+---------+----------+----------+
  |   17 | SELECT | test   | t     | Y     | N     |                30 |       0 |       0 |        0 |          |
  |   16 | SELECT |        |       | Y     | N     |                20 |       0 |       0 |        0 | key1     |
  |   18 | SELECT |        |       | Y     | N     |                10 |       0 |       0 |        0 |          |
  +------+--------+--------+-------+-------+-------+-------------------+---------+---------+----------+----------+​

  次の表に、MATCHED、RUNNING、およびWAITTINGパラメーターを示します。

  パラメーター	説明
  マッチした	ルールが一致する回数。
  ランニング	ルールの下で同時に実行されているスレッドの数。
  待っている	ルールの下で実行されるスレッドの数。

• flush_ccl_rule

  concurrency_controlテーブルのルールを変更する場合は、ルールを再度有効にする必要があります。 サンプルコマンド:

  dbms_ccl.flush_ccl_rule();

  例:

  ​mysql> update mysql.concurrency_control set CONCURRENCY_COUNT = 15 where Id = 18;
  Query OK, 1 row affected (0.00 sec)
  Rows matched: 1  Changed: 1  Warnings: 0
  
  mysql> call dbms_ccl.flush_ccl_rule();
  Query OK, 0 rows affected (0.00 sec)​