云数据库 MySQL 加速 ETL 回写（特色功能）

一、使用场景

推荐在以下场景使用此功能：当查询条件复杂、SQL 语句执行时间较长但查询结果集的数据量较小时。在这种场景下，使用此功能可以显著提高性能，因为只读分析引擎会加速 SELECT 查询的执行效率。

使用此功能并不是在所有场景下都能带来性能收益，在某些场景下性能可能会下降。例如：

·INSERT…SELECT… 语句中的 SELECT 查询比较简单时，从只读分析引擎读取数据并回写到读写实例会带来额外的网络开销。对比直接从读写实例读取数据的优势并不明显。

·INSERT…SELECT… 语句中的 SELECT 查询结果集数据量大的情况下，此时主要的性能瓶颈在于结果集通过网络传输并写入读写实例的过程。此场景无法使用此功能来优化性能。

二、前提条件

·只读分析引擎实例和读写实例的运行状态均为正常运行中。

·执行的用户需拥有对应对象的 INSERT 权限。

·仅支持 INSERT…SELECT… 的 SQL 执行场景。

三、功能参数说明

四、执行示例

1. 使用客户端工具登录至只读分析引擎。例如使用 MySQL 客户端通过数据库账号密码登录至只读分析引擎。

2. 执行如下 SQL，即可开启加速 ETL 回写功能（通过只读分析引擎回写读写实例功能）。

通过在 session 中设置参数执行：

set libra_etl_to_rw=on;set libra_concurrent_etl=on;set libra_etl_concurrency=4;INSERT INTO database1.table1 select a.t1,b.t2,a.t2,b.t3 from a,b where a.t1=b.t1 and a.t5='x';set libra_concurrent_etl=off;set libra_etl_to_rw=off;

通过在 SQL 中添加 Hint 参数执行：

INSERT /*+ SET_VAR(libra_etl_to_rw=ON) SET_VAR(libra_concurrent_etl=ON) SET_VAR(libra_etl_concurrency=4)*/ INTO database1.table1 select a.t1,b.t2,a.t2,b.t3 from a,b where a.t1=b.t1 and a.t5='x';

注意：如果使用 mysql 客户端执行“添加 Hint 参数的方法执行”，需要在 MySQL 客户端登录只读分析引擎时添加 -c 参数，否则 hint 将不会生效。

五、测试环境

·主实例：16核64GB。

·只读分析引擎：16核64GB。

六、测试数据

使用 TPC-H 10GB数据集。

七、测试复杂 SQL 及结果

set libra_etl_to_rw=on;set libra_concurrent_etl=off;set libra_etl_concurrency=1;create table t1 ( supp_nation VARCHAR(50), cust_nation VARCHAR(50), l_year INT, revenue DECIMAL);INSERT INTO t1 SELECTsupp_nation, cust_nation, l_year, sum(volume) as revenue from (select n1.n_name as supp_nation, n2.n_name as cust_nation, extract(year from l_shipdate) as l_year, l_extendedprice * (1 – l_discount) as volume from supplier, lineitem, orders, customer, nation n1, nation n2 where s_suppkey = l_suppkey and o_orderkey = l_orderkey and c_custkey = o_custkey and s_nationkey = n1.n_nationkey and c_nationkey = n2.n_nationkey and ((n1.n_name = 'JAPAN' and n2.n_name = 'INDIA') or (n1.n_name = 'INDIA' and n2.n_name = 'JAPAN')) and l_shipdate between '1995-01-01' and '1996-12-31') as shipping group by supp_nation, cust_nation, l_year order by supp_nation, cust_nation, l_year;

查询结果为4行数据时，测试结果如下（单位：秒）。

set libra_etl_to_rw=on;set libra_concurrent_etl=off;set libra_etl_concurrency=1;CREATE TABLE t2 ( p_brand VARCHAR(10), p_type VARCHAR(25), p_size INTEGER, supplier_cnt INTEGER);INSERT INTO t2 SELECT p_brand, p_type, p_size, count(distinct ps_suppkey) as supplier_cntfrom partsupp, partwhere p_partkey = ps_partkey and p_brand <> 'Brand#45' and p_type not like 'MEDIUM POLISHED%' and p_size in (49, 14, 23, 45, 19, 3, 36, 9) and ps_suppkey not in ( select s_suppkey from supplier where s_comment like '%Customer%Complaints%' )group by p_brand, p_type, p_sizeorder by supplier_cnt desc, p_brand, p_type, p_size;

查询结果为27840行数据时，测试结果如下（单位：秒）。

八、测试简单 SQL 及结果

set libra_etl_to_rw=on;set libra_concurrent_etl=on;set libra_etl_concurrency=8;CREATE TABLE IF NOT EXISTS lineitem ( L_ORDERKEY INTEGER NOT NULL,L_PARTKEY INTEGER NOT NULL,L_SUPPKEY INTEGER NOT NULL,L_LINENUMBER INTEGER NOT NULL,L_QUANTITY DECIMAL(15,2) NOT NULL,L_EXTENDEDPRICE DECIMAL(15,2) NOT NULL,L_DISCOUNT DECIMAL(15,2) NOT NULL,L_TAX DECIMAL(15,2) NOT NULL,L_RETURNFLAG CHAR(1) NOT NULL,L_LINESTATUS CHAR(1) NOT NULL,L_SHIPDATE DATE NOT NULL,L_COMMITDATE DATE NOT NULL,L_RECEIPTDATE DATE NOT NULL,L_SHIPINSTRUCT CHAR(25) NOT NULL,L_SHIPMODE CHAR(10) NOT NULL,L_COMMENT VARCHAR(44) NOT NULL , primary key(L_ORDERKEY, L_LINENUMBER));INSERT INTO lineitem_t SELECT *from lineitem;

查询结果为59986051行数据时，测试结果如下（单位：秒）。