I hereby agree to the terms of the CLA available at: https://docs.databend.com/dev/policies/cla/

Summary

• The consuming (with consume) of stream should respect the semantics of transactions: if transaction is aborted, the stream should roll back to its original state.

• Only the usage of WITH CONSUME in queries is allowed. Statements like INSERT INTO t SELECT * FROM s WITH CONSUME will fail with errors.

• Fixes bug: select ... from stream with consume not work as expected in non auto commit mode #15581

Tests

• Unit Test
• Logic Test
• Benchmark Test
• No Test - Explain why

Type of change

• Bug Fix (non-breaking change which fixes an issue)
• New Feature (non-breaking change which adds functionality)
• Breaking Change (fix or feature that could cause existing functionality not to work as expected)
• Documentation Update
• Refactoring
• Performance Improvement
• Other (please describe):

This change is