变更记录

1 业务场景

在数据集成的过程中有时需要从源系统的视图取数（数据量巨大），并且还要将入参拼接到sql语句的中间进行传参，如：

SELECT orders.id, orders.order_date, orders.total
FROM orders
INNER JOIN users ON users.id = orders.user_id
WHERE users.username = ？ AND orders.order_date BETWEEN ？ AND ？
ORDER BY orders.order_date DESC;

2 解决方案

集成服务云提供了流式查询函数query_data_set，通过在数据集成方案中使用结构作为源对象，并在来源数据查询脚本中直接返回query_data_set的执行结果，以实现流式查询复杂sql的目的。

3 关键操作

• 步骤1

创建数据集成方案源对象的类型为结构

• 步骤2

填写来源数据查询脚本

query_data_set(cn, sql,params,types)
cn为系统连接，sql 为数据库脚本，params为 参数值列表，types 为参数值类型构成的列表。

var sql='select fid,fnumber,fname from T_ISC_DEMO_BASEDATA_1@EIP WHERE fnumber = ?';
var res=query_data_set($src, sql,[params.number],[VARCHAR]);
return  res;

注：此处必须直接返回查询的结果，不能对返回结果进行额外处理。

4 注意事项

• 需要结构类型的源对象和来源取数据脚本配合使用

• 需要在来源取数中直接返回query_data_set的执行结果