Mulesoft Snowflake 连接器参数化查询

Question

在Mulesoft Anypoint studio中，如何引用SQL字符串中的输入参数（参见屏幕截图）？我尝试过使用

#[payload.x]

，但这不会被插值并导致错误。不确定使用的正确语法是什么。

为了方便起见，这是 SQL 字符串：

INSERT INTO adoit_capability_relationships ("capabilityId", "itemType", "itemId", "itemName", "dataLoadDate") VALUES(capabilityId, itemType, itemId, itemName, CURRENT_TIMESTAMP());

这是我尝试使用的输入参数：

{
    "capabilityId": payload.capabilityId,
    "itemType": payload.itemType,
    "itemId": payload.itemId,
    "itemName": payload.itemName,
    "dataLoadDate": "CURRENT_TIMESTAMP()"
}

Answer 1

使用

:param_name

和

INSERT INTO ... SELECT

：

INSERT INTO adoit_capability_relationships 
            ("capabilityId", "itemType", "itemId", "itemName", "dataLoadDate") 
SELECT :capabilityId, :itemType, :itemId, :itemName, CURRENT_TIMESTAMP();