stream - 如何使用流但仍保留数据而不偏移

Question

我们需要在第一个事务使用它之后将数据保留在流中。我们如何做到这一点？第二个事务将再次消耗并抵消流。在第一个 DML 完成后，需要第二个 DML 的解决方案来查看流数据。两个 DML 都需要流中的相同数据。

Answer 1

建议用户为表的每个更改记录接收者创建一个单独的流。

请注意，流本身不包含任何表数据。

参考：流的多个消费者

Answer 2

Sergiu 的评论将是更受欢迎的选项，但另一种方法可能是首先使用简单的 SELECT 语句查询流，然后根据最后一个查询结果使用 DML 语句跟进它

SELECT * FROM my_stream;


INSERT INTO my_table select * from table(result_scan(last_query_id()));