我尝试在查询中使用trigger_start_time变量作为查找活动函数的第二个参数。我该怎么做呢？
pxy2qtax1#
请在添加动态内容中尝试@concat('select schema.fn_up_watermark(',Parameter_name,',',variable_name, ') from dual')。我只是用你提供给我的查询来做这个例子。你可以测试一下，不使用参数和变量来检查缺少右括号的地方。现在，我很高兴听到这个问题已经解决了。
@concat('select schema.fn_up_watermark(',Parameter_name,',',variable_name, ') from dual')
00jrzges2#
你可以去掉这个变量，简单地写：select schema.fn_up_watermark('@{item().table_name}','@{pipeline().TriggerTime}') from dual假设两个参数都是字符串。如果您可以影响为ForEach块提供数据的外部查找，您仍然可以执行SQL注入--您可以在进入此循环时清除table_name s。
select schema.fn_up_watermark('@{item().table_name}','@{pipeline().TriggerTime}') from dual
table_name
2条答案
按热度按时间pxy2qtax1#
请在添加动态内容中尝试
@concat('select schema.fn_up_watermark(',Parameter_name,',',variable_name, ') from dual')。我只是用你提供给我的查询来做这个例子。你可以测试一下，不使用参数和变量来检查缺少右括号的地方。
现在，我很高兴听到这个问题已经解决了。
00jrzges2#
你可以去掉这个变量，简单地写：
select schema.fn_up_watermark('@{item().table_name}','@{pipeline().TriggerTime}') from dual假设两个参数都是字符串。
如果您可以影响为ForEach块提供数据的外部查找，您仍然可以执行SQL注入--您可以在进入此循环时清除
table_names。