阿里云RDS数据库Statement Concurrency Control-云淘科技

前提条件

实例版本如下：

• MySQL 8.0

• MySQL 5.7

注意事项

• CCL的操作不产生日志，所以CCL的操作只影响当前实例。例如主实例进行CCL操作，不会同步到备实例、只读实例或灾备实例。

• CCL提供超时机制以应对DML导致事务锁死锁，等待中的线程也会响应事务超时和线程KILL操作以应对死锁。

功能设计

CCL规则定义了如下四个维度的特征：

• SQL command

  SQL命令类型，例如SELECT、UPDATE、INSERT、DELETE等。

• Object

  SQL命令操作的对象，例如TABLE、VIEW等。

• keywords

  SQL命令的关键字。

• Template

  SQL命令的模板。

创建CCL规则表

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'

管理CCL规则

为了便捷地管理CCL规则，AliSQL在DBMS_CCL中定义了四个本地存储规则。详细说明如下：

• add_ccl_rule

  增加规则。命令如下：

  dbms_ccl.add_ccl_rule('','','',,'');
  示例：
  增加规则，SELECT语句的并发数为10。
  mysql> call dbms_ccl.add_ccl_rule('SELECT', '', '', 10, '');
  增加规则，SELECT语句中出现关键字key1的并发数为20。
  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('','','
  ',,'');
  说明 
  
  
  Table_name、Keywords无需填写。SQL query不能为空并且只能填一条SQL。
  
  
  仅适用于MySQL 8.0版本（小版本为20230630及之后版本）。
  
  示例：
  增加模板规则，test库模板为'SELECT c FROM t1 WHERE id=?'的SQL并发数为30。
  mysql> call dbms_ccl.add_ccl_rule('SELECT', 'test', '', 30, SELECT c FROM t1 WHERE id=4');
  
  del_ccl_rule 
  删除规则。命令如下： 
  dbms_ccl.del_ccl_rule();
  示例：
  删除规则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的说明如下。
  
  
  
  
  
  
  参数
  
  
  说明
  
  
  
  
  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)​