用户必须具有以下 MySQL 权限：

要在 Auto Parallel Load"normal" 模式下运行，HeatWave Cluster 必须处于活动状态。

mode：定义自动并行加载操作模式。允许的值为：

output：定义自动并行加载如何产生输出。允许的值为：

sql_mode：定义加载表时使用的 SQL 模式。自动并行加载不支持 MySQL 全局或会话 sql_mode变量。要使用非 oci-default SQL 模式配置运行自动并行加载，请使用自动并行加载sql_mode选项指定配置作为字符串值。如果未指定 SQL 模式，则使用默认的 OCI SQL 模式配置。

有关 SQL 模式的信息，请参阅 服务器 SQL 模式。

policy：定义用于处理包含具有不受支持的数据类型的列的表的策略。允许的值为：

exclude_list：定义要从加载脚本中排除的数据库对象（模式、表和列）的列表。名称必须是不带反引号的完全限定，如以下示例所示：

CALL sys.heatwave_load(JSON_ARRAY("tpch","airportdb"), 
JSON_OBJECT("exclude_list",JSON_ARRAY("tpch.orders","airportdb.employee.salary")));

Auto Parallel Load 自动排除无法卸载的数据库对象（根据默认policy设置）。这些对象不需要在排除列表中明确指定。系统架构、非InnoDB 表、已经加载到 HeatWave 中的表以及明确定义为的列将NOT SECONDARY被自动排除。

set_load_parallelism：默认启用。innodb_parallel_read_threads 通过在加载每个表之前优化变量设置， 基于机器学习模型优化加载并行性 。

auto_enc：检查是否有足够的内存用于字符串列编码。设置包括：

查看错误信息以防自动并行加载意外停止：

SELECT log FROM sys.heatwave_load_report WHERE type="error";

查看警告以找出无法加载表的原因：

SELECT log FROM sys.heatwave_load_report WHERE type="warn";

"normal"查看生成的加载脚本以查看自动并行加载模式下 将执行的命令 ：

SELECT log->>"$.sql" AS "Load Script" FROM sys.heatwave_load_report 
WHERE type = "sql" ORDER BY id;

查看生成的加载命令数：

SELECT Count(*) AS "Total Load Commands Generated" FROM sys.heatwave_load_report 
WHERE type = "sql" ORDER BY id;

查看特定表的加载脚本数据：

SELECT log->>"$.sql" FROM sys.heatwave_load_report  
WHERE type="sql" AND log->>"$.schema_name" = "db0" AND log->>"$.table_name" = "tbl" 
ORDER BY id;

将自动并行加载生成的 DDL 语句连接到一个可以复制和粘贴以执行的字符串中。该 group_concat_max_len 变量以字节为单位设置 GROUP_CONCAT()函数的结果长度，以容纳可能很长的字符串。（默认 group_concat_max_len 设置为 1024 字节。）

SET SESSION group_concat_max_len = 1000000;
SELECT GROUP_CONCAT(log->>"$.sql" SEPARATOR ' ') FROM sys.heatwave_load_report 
  WHERE type = "sql" ORDER BY id;

加载多个模式。没有指定选项，这意味着使用默认选项。

CALL sys.heatwave_load(JSON_ARRAY("tpch","airportdb","employees","sakila"),NULL);

使用该策略加载多个模式 not_disable_unsupported_columns ，这会导致包含不受支持的列的表被排除在加载操作之外。不受支持的列是那些具有不受支持的数据类型的列。

CALL sys.heatwave_load(JSON_ARRAY("tpch","airportdb","employees","sakila"), 
JSON_OBJECT("policy","not_disable_unsupported_columns"));

加载多个模式，不包括指定的表和特定列：

CALL sys.heatwave_load(JSON_ARRAY("tpch","airportdb"), 
JSON_OBJECT("exclude_list",JSON_ARRAY("tpch.orders","airportdb.employee.salary")));

从名为的模式加载以“ hw ”前缀 开头的表schema_customer_1。

SET @exc_list = (SELECT JSON_OBJECT('exclude_list',
                 JSON_ARRAYAGG(CONCAT(table_schema,'.',table_name))) 
                 FROM information_schema.tables 
                 WHERE table_schema = 'schema_customer_1' 
                 AND table_name NOT LIKE 'hw%');
CALL sys.heatwave_load(JSON_ARRAY('schema_customer_1'), @exc_list);

使用以“ hw ”前缀 开头的表加载所有模式 。

SET @db_list = (SELECT json_arrayagg(schema_name) FROM information_schema.schemata);
SET @exc_list = (SELECT JSON_OBJECT('exclude_list',
                 JSON_ARRAYAGG(CONCAT(table_schema,'.',table_name))) 
                 FROM information_schema.tables 
                 WHERE table_schema NOT IN
                 ('mysql','information_schema', 'performance_schema','sys') 
                 AND table_name NOT LIKE 'hw%');
CALL sys.heatwave_load(@db_list, @exc_list);

您可以检查db_list并 exc_list使用SELECT JSON_PRETTY(@db_list);和SELECT JSON_PRETTY(@exc_list);

从存储过程调用自动并行加载：

DROP PROCEDURE IF EXISTS auto_load_wrapper;
DELIMITER //
CREATE PROCEDURE auto_load_wrapper()
BEGIN
  -- AUTOMATED INPUT
  SET @db_list = (SELECT JSON_ARRAYAGG(schema_name) FROM information_schema.schemata);
  SET @exc_list = (SELECT JSON_ARRAYAGG(CONCAT(table_schema,'.',table_name)) 
  FROM information_schema.tables WHERE table_schema = "db0");

  CALL sys.heatwave_load(@db_list, JSON_OBJECT("output","silent","exclude_list", 
  CAST(@exc_list AS JSON)));

  -- CUSTOM OUTPUT
  SELECT log as 'Unsupported objects' FROM sys.heatwave_load_report WHERE type="warn" 
  AND stage="VERIFICATION" and log like "%Unsupported%";
  SELECT Count(*) AS "Total Load commands Generated" 
  FROM sys.heatwave_load_report WHERE type = "sql" ORDER BY id;

END //
DELIMITER ;

CALL auto_load_wrapper();