我有一个具有 oledb 数据源的数据流。然后我有一个执行三个 Web 服务调用的脚本组件,它有两个输出(实际上)与输入行同步(每个输入行一个输出行),一个异步输出(每个输入输出很多行排)。每个输出都转到一个 sql update 命令。还有一个错误日志输出(也是异步的)。
我希望以某种方式将输出包装在事务中,以便对于每个输入行,如果该行没有完全处理和更新,那么该输入行的更新都不会成功。
据我所知,它的工作方式是脚本处理每个输入行并将所有内容输出到缓冲区,然后再继续执行更新命令。相反,我希望在每行的基础上执行所有更新,在处理和更新每个输入行时提交更改。
我如何构建我的数据流来实现这一点?
我可能正在考虑执行源代码,然后通过 foreach 容器运行记录,但我不确定如何通过 ForEach 容器将多个 DataFlow 链接在一起。