主页 / coding / 问题 / 79318030
Accepted
Patterson
Asked: 2024-12-30 23:59:46 +0800 CST

如何在 Azure 数据工厂复制活动中参数化查询

  • 772

我在 ADF 复制活动中有以下查询

SELECT
  deltaTable.*
FROM Data.deltaTable
LEFT OUTER JOIN Data.targetTable
  ON deltaTable.signature = targetTable.signature
WHERE targetTable.signature IS NULL

有人能告诉我如何参数化查询吗？当我尝试参数化查询时，我收到错误：

Parameter schema was not found under EX_SourceToRaw_Single_Table

以下代码是我的尝试：

@concat('SELECT * FROM ',pipeline().parameters.schema,'.',pipeline().parameters.DeltaTable)
LEFT OUTER JOIN pipeline().parameters.schema,'.',pipeline().parameters.TargetTable)
  ON pipeline().parameters.DeltaTable).signature = pipeline().parameters.TargetTable).signature
WHERE pipeline().parameters.TargetTable).signature IS NULL

deltaTable 和 TargetTable 均如下所示：

==========================================================================================================
|    CountryName     |    CountryISO2     |    CountryISO3     |    SalesRegion     |     signature      |
==========================================================================================================
|      Belgium       |     CHA            |     10             |        EMEA        |800e559a27d68f0478b6|
|                    |                    |                    |                    |1c4c9f009e2418e86697|
|                    |                    |                    |                    |1b6e54b549b51b1367ab|
|                    |                    |                    |                    |        450d        |
----------------------------------------------------------------------------------------------------------
|       Wales        |     steveO         |     WAL            |       Welsh        |e8c5149d54986dfe9ac9|
|                    |                    |                    |                    |5a60a76b07603fe17c28|
|                    |                    |                    |                    |2b552ec8255f123b279a|
|                    |                    |                    |                    |        533a        |
----------------------------------------------------------------------------------------------------------
|      Germany       |     DE             |     deletedupd     |        EMEA        |1232b1bd91d14a87ed83|
|                    |                    |                    |                    |0f770d74cd8cabb87153|
|                    |                    |                    |                    |5c4c2b7ff5bcb873fa80|
|                    |                    |                    |                    |        d851        |
----------------------------------------------------------------------------------------------------------
|       Italy        |     IT             |     ITA            |        EMEA        |584cf66de2f4af9eb4db|
|                    |                    |                    |                    |febefea808b1b4e6a357|
|                    |                    |                    |                    |87fcac1061de88cfb798|
|                    |                    |                    |                    |        56df        |
----------------------------------------------------------------------------------------------------------

1 个回答

  1. Best Answer

    在 ADF 管道中创建schema、DeltaTable、TargetTable参数后，在复制活动的查询选项中使用以下表达式。 此处，为了举例，我使用了查找活动查询选项，其工作方式与复制活动查询选项相同。

    @concat('SELECT ',pipeline().parameters.DeltaTable,'.* FROM ',pipeline().parameters.schema,'.',pipeline().parameters.DeltaTable,' LEFT OUTER JOIN ',pipeline().parameters.schema,'.',pipeline().parameters.TargetTable,' ON ',pipeline().parameters.DeltaTable,'.signature = ',pipeline().parameters.TargetTable,'.signature WHERE ',pipeline().parameters.TargetTable,'.signature IS NULL')

    在查询中打开动态内容并给出上述表达式，如下所示。

    在此处输入图片描述

    要检查生成的查询，您可以转到管道运行->活动运行->输入。在这里，它将显示从上述表达式生成的查询。您可以看到它生成了所需的查询。

    在此处输入图片描述

    如果遇到任何错误，您可以在此处检查生成的查询并根据您的要求进行修改。

    • 1

相关问题