copyALTER ENCRYPTING RULE

copyALTER ENCRYPTING RULE (
READ(
  WORKER_THREAD=20,
  BATCH_SIZE=1000,
  SHARDING_SIZE=10000000,
  RATE_LIMITER (TYPE(NAME='QPS',PROPERTIES('qps'='500')))
),
WRITE(
  WORKER_THREAD=20,
  BATCH_SIZE=1000,
  RATE_LIMITER (TYPE(NAME='TPS',PROPERTIES('tps'='2000')))
),
STREAM_CHANNEL (TYPE(NAME='MEMORY',PROPERTIES('block-queue-size'='2000')))
);

copyALTER ENCRYPTING RULE (
READ( -- 数据读取配置。如果不配置则部分参数默认生效。
  WORKER_THREAD=20, -- 从源端摄取全量数据的线程池大小。如果不配置则使用默认值。
  BATCH_SIZE=1000, -- 一次查询操作返回的最大记录数。如果不配置则使用默认值。
  SHARDING_SIZE=10000000, -- 全量数据分片大小。如果不配置则使用默认值。
  RATE_LIMITER ( -- 限流算法。如果不配置则不限流。
  TYPE( -- 算法类型。可选项：QPS
  NAME='QPS',
  PROPERTIES( -- 算法属性
  'qps'='500'
  )))
),
WRITE( -- 数据写入配置。如果不配置则部分参数默认生效。
  WORKER_THREAD=20, -- 数据写入到目标端的线程池大小。如果不配置则使用默认值。
  BATCH_SIZE=1000, -- 一次批量写入操作的最大记录数。如果不配置则使用默认值。
  RATE_LIMITER ( -- 限流算法。如果不配置则不限流。
  TYPE( -- 算法类型。可选项：TPS
  NAME='TPS',
  PROPERTIES( -- 算法属性
  'tps'='2000'
  )))
),
STREAM_CHANNEL ( -- 数据通道，连接生产者和消费者，用于 read 和 write 环节。如果不配置则默认使用 MEMORY 类型。
TYPE( -- 算法类型。可选项：MEMORY
NAME='MEMORY',
PROPERTIES( -- 算法属性
'block-queue-size'='2000' -- 属性：阻塞队列大小
)))
);

copySHOW ENCRYPTING RULE

copySHOW ENCRYPTING RULE

copyENCRYPT TABLE tableName;

copyENCRYPT TABLE t_user;

copyENCRYPT TABLE t_user (password);

copyENCRYPT TABLE t_user (username(LIKE_QUERY));

copySHOW ENCRYPTING LIST;

copySHOW ENCRYPTING LIST;

copySHOW ENCRYPTING STATUS jobId;

copymysql> SHOW ENCRYPTING STATUS j5202p0000e2af8bea809d29f6ab4b3ac4c99b5789;
+-------------+----------+--------+-------------------------+-------------------------------+---------------+
| table_name  | status   | active | processed_records_count | inventory_finished_percentage | error_message |
+-------------+----------+--------+-------------------------+-------------------------------+---------------+
| t_user      | FINISHED | true   | 3                       | 100                           |               |
| t_user_info | FINISHED | true   | 3                       | 100                           |               |
+-------------+----------+--------+-------------------------+-------------------------------+---------------+

copyCOMMIT ENCRYPTING jobId;

copyCOMMIT ENCRYPTING 'j51017f973ac82cb1edea4f5238a258c25e89';

copyROLLBACK ENCRYPTING jobId;

copyROLLBACK ENCRYPTING  'j51017f973ac82cb1edea4f5238a258c25e89';

copyALTER DECRYPTING RULE

copyALTER DECRYPTING RULE (
READ(
  WORKER_THREAD=20,
  BATCH_SIZE=1000,
  SHARDING_SIZE=10000000,
  RATE_LIMITER (TYPE(NAME='QPS',PROPERTIES('qps'='500')))
),
WRITE(
  WORKER_THREAD=20,
  BATCH_SIZE=1000,
  RATE_LIMITER (TYPE(NAME='TPS',PROPERTIES('tps'='2000')))
),
STREAM_CHANNEL (TYPE(NAME='MEMORY',PROPERTIES('block-queue-size'='2000')))
);

copySHOW DECRYPTING RULE

copySHOW DECRYPTING RULE

copyDECRYPT TABLE tableName;

copyDECRYPT TABLE t_user;

copyDECRYPT TABLE t_user;

copyDECRYPT TABLE t_user (password);

copySHOW DECRYPTING LIST;

copySHOW DECRYPTING LIST;

copySHOW DECRYPTING STATUS jobId;

copymysql> SHOW DECRYPTING STATUS j5302p0000e2af8bea809d29f6ab4b3ac4c99b5789;
+------+-------------+----------+--------+---------------------+---------------+
| item | data_source | status   | active | finished_percentage | error_message |
+------+-------------+----------+--------+---------------------+---------------+
| 0    | testdb      | FINISHED | true   | 100                 |               |
+------+-------------+----------+--------+---------------------+---------------+

copyCOMMIT DECRYPTING jobId;

copyCOMMIT DECRYPTING  'j51017f973ac82cb1edea4f5238a258c25e89';

copyROLLBACK DECRYPTING jobId;

copyROLLBACK DECRYPTING  'j51017f973ac82cb1edea4f5238a258c25e89';

copyREENCRYPT TABLE WITH RULE tableName 

copyREENCRYPT TABLE WITH RULE t_encrypt (
COLUMNS(
(NAME=user_id,PLAIN=user_plain,CIPHER=user_cipher,ASSISTED_QUERY_COLUMN=user_assisted,LIKE_QUERY_COLUMN=user_like,ENCRYPT_ALGORITHM(TYPE(NAME='AES',PROPERTIES('aes-key-value'='665544aaa'))),ASSISTED_QUERY_ALGORITHM(TYPE(NAME='AES',PROPERTIES('aes-key-value'='523234abc'))), LIKE_QUERY_ALGORITHM(TYPE(NAME='CHAR_DIGEST_LIKE'))),
(NAME=order_id, PLAIN=order_plain,CIPHER =order_cipher, ENCRYPT_ALGORITHM(TYPE(NAME='AES',PROPERTIES('aes-key-value'='445533ccc'))))
), QUERY_WITH_CIPHER_COLUMN=true);

copySTART REENCRYPTING jobId;

copySTART REENCRYPTING j54014fb26631db0f7149741422d86cc5dfe6;

copySTOP ENCRYPTING jobId;

copySTOP ENCRYPTING 'j51017f973ac82cb1edea4f5238a258c25e89';

copySTART ENCRYPTING jobId;

copySTART ENCRYPTING 'j51017f973ac82cb1edea4f5238a258c25e89';

copySTOP ENCRYPTING jobId;

copySTOP DECRYPTING 'j51017f973ac82cb1edea4f5238a258c25e89';

copySTART DECRYPTING jobId;

copySTART DECRYPTING 'j51017f973ac82cb1edea4f5238a258c25e89';

copySTOP REENCRYPTING jobId;

copySTOP REENCRYPTING 'j51017f973ac82cb1edea4f5238a258c25e89';