我有一个名为 query_sink(字符串类型)的管道参数,它来自数据库,可能的值可能是
DELETE FROM table1 WHERE country = 1
,或者数据库中的值有时是 null。所以,我想使用一个数据流,其中在接收器转换中使用参数 query_sink。
并在预 SQL 脚本中使用它,现在我只是传递参数而不像这样改变
但是当数据库中的值为空时我遇到了问题
'sink1': 输入脚本中没有批次。"
所以我不确定那种情况下的参数是否为空,或者好像参数没有收到任何东西,在那种情况下我不希望它做任何事情或做类似 SELECT 1 的事情SQL脚本,在其他情况下执行值即
DELETE FROM table1 WHERE country = 1