如何在ADF中创建带主键的目标表并实现数据 ingestion

排查与修复步骤 #

1. 检查「执行脚本」活动的有效性 #

• 确认脚本活动的数据库连接和创建目标表的连接完全一致，避免误操作到其他库或实例。
• 核对添加主键的脚本语法是否匹配目标数据库：
  以SQL Server为例：

  ALTER TABLE Table1 ADD CONSTRAINT PK_Table1_ID PRIMARY KEY (ID);
  

  MySQL则用：

  ALTER TABLE Table1 ADD PRIMARY KEY (ID);
  

• 开启脚本活动的日志记录，查看执行日志是否存在报错（比如表不存在、字段为空、权限不足）——多数情况下主键未生成是因为脚本执行失败但未被发现。

2. 验证活动的依赖关系 #

• 确保「创建表」和「执行脚本」活动之间设置成功依赖：只有创建表活动执行成功后，才触发脚本活动。若依赖设置为“完成”而非“成功”，可能出现创建表失败但脚本仍执行的情况。
• 确认「执行脚本」完成后再触发「数据导入」活动，避免数据导入时表结构未完成更新。

3. 检查目标表结构兼容性 #

• 确认目标表的ID字段非空且数据类型与源表一致：主键字段必须非空，若创建表时ID字段允许为空，添加主键会失败。需先修改字段属性：

  ALTER TABLE Table1 ALTER COLUMN ID INT NOT NULL;
  ALTER TABLE Table1 ADD CONSTRAINT PK_Table1_ID PRIMARY KEY (ID);
  

4. 确认ADF账号的数据库权限 #

• 确保ADF使用的数据库账号拥有ALTER TABLE权限，部分数据库在权限不足时不会返回明显报错，导致脚本静默失败。可手动用该账号登录数据库执行主键脚本，验证权限是否足够。

5. 替代方案：建表时直接定义主键 #

若分步操作易出问题，可跳过单独的脚本活动，直接在创建表的DDL中包含主键：

• 在「复制数据」活动中选择“自动创建表”，并自定义DDL语句，直接写入带主键的建表逻辑。
• 用「查找」活动查询源表的主键元数据（比如SQL Server的INFORMATION_SCHEMA.KEY_COLUMN_USAGE），动态拼接带主键的建表脚本，一次性完成表结构创建。

内容的提问来源于stack exchange，提问作者Rutika Khaire