@@ -37,13 +37,13 @@ CREATE STREAM s_append_only ON TABLE t_append_only APPEND_ONLY=true;
3737使用 [ SHOW FULL STREAMS] ( /sql/sql-commands/ddl/stream/show-streams ) 命令可以查看已创建的 Stream 及其模式:
3838
3939``` sql
40- SHOW FULL STREAMS;
40+ SHOW FULL STREAMS WHERE name IN ( ' s_standard ' , ' s_append_only ' ) ;
4141
4242┌─────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────┐
4343│ created_on │ name │ database │ catalog │ table_on │ owner │ comment │ mode │ invalid_reason │
4444├────────────────────────────┼───────────────┼──────────┼─────────┼───────────────────────┼──────────────────┼─────────┼─────────────┼────────────────┤
45- │ 2024 - 02 - 18 16 : 39 : 58 . 996763 │ s_append_only │ default │ default │ default .t_append_only │ NULL │ │ append_only │ │
46- │ 2024 - 02 - 18 16 : 39 : 58 . 966942 │ s_standard │ default │ default │ default .t_standard │ NULL │ │ standard │ │
45+ │ 2025 - 11 - 03 13 : 05 : 21 . 873473 │ s_append_only │ default │ default │ default .t_append_only │ NULL │ │ append_only │ │
46+ │ 2025 - 11 - 03 13 : 05 : 20 . 663258 │ s_standard │ default │ default │ default .t_standard │ NULL │ │ standard │ │
4747└─────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────┘
4848```
4949
@@ -59,17 +59,17 @@ SELECT * FROM s_standard;
5959┌────────────────────────────────────────────────────────────────────────────────────────────────┐
6060│ a │ change$action │ change$row_id │ change$is_update │
6161├─────────────────┼──────────────────┼────────────────────────────────────────┼──────────────────┤
62- │ 2 │ INSERT │ 8cd000827f8140d9921f897016e5a88e000000 │ false │
63- │ 3 │ INSERT │ 8cd000827f8140d9921f897016e5a88e000001 │ false │
62+ │ 2 │ INSERT │ 019a4ef92ca4795d983d81745cf7642d000000 │ false │
63+ │ 3 │ INSERT │ 019a4ef92ca4795d983d81745cf7642d000001 │ false │
6464└────────────────────────────────────────────────────────────────────────────────────────────────┘
6565
6666SELECT * FROM s_append_only;
6767
6868┌─────────────────────────────────────────────────────────────────────────────────────────────┐
6969│ a │ change$action │ change$is_update │ change$row_id │
7070├─────────────────┼───────────────┼──────────────────┼────────────────────────────────────────┤
71- │ 2 │ INSERT │ false │ 63dc9b84fe0a43528808c3304969b317000000 │
72- │ 3 │ INSERT │ false │ 63dc9b84fe0a43528808c3304969b317000001 │
71+ │ 2 │ INSERT │ false │ 019a4ef9321a7160a8f0ffd072e89f10000000 │
72+ │ 3 │ INSERT │ false │ 019a4ef9321a7160a8f0ffd072e89f10000001 │
7373└─────────────────────────────────────────────────────────────────────────────────────────────┘
7474```
7575
@@ -174,14 +174,14 @@ UPDATE t_standard SET a = 4 WHERE a = 3;
174174UPDATE t_append_only SET a = 4 WHERE a = 3 ;
175175
176176
177- SELECT * FROM s_standard;
177+ SELECT * FROM s_standard ORDER BY change$action DESC , a ;
178178
179179┌────────────────────────────────────────────────────────────────────────────────────────────────┐
180180│ a │ change$action │ change$row_id │ change$is_update │
181181│ Nullable(Int32) │ Nullable(String) │ Nullable(String) │ Boolean │
182182├─────────────────┼──────────────────┼────────────────────────────────────────┼──────────────────┤
183- │ 3 │ DELETE │ 1dd5cab0b1b64328a112db89d602ca04000001 │ true │
184- │ 4 │ INSERT │ 1dd5cab0b1b64328a112db89d602ca04000001 │ true │
183+ │ 4 │ INSERT │ 019a4ef92ca4795d983d81745cf7642d000001 │ true │
184+ │ 3 │ DELETE │ 019a4ef92ca4795d983d81745cf7642d000001 │ true │
185185└────────────────────────────────────────────────────────────────────────────────────────────────┘
186186
187187-- 空结果
@@ -198,13 +198,13 @@ SELECT * FROM s_append_only;
198198DELETE FROM t_standard WHERE a = 4 ;
199199DELETE FROM t_append_only WHERE a = 4 ;
200200
201- SELECT * FROM s_standard;
201+ SELECT * FROM s_standard ORDER BY change$action, a ;
202202
203203┌────────────────────────────────────────────────────────────────────────────────────────────────┐
204204│ a │ change$action │ change$row_id │ change$is_update │
205205│ Nullable(Int32) │ Nullable(String) │ Nullable(String) │ Boolean │
206206├─────────────────┼──────────────────┼────────────────────────────────────────┼──────────────────┤
207- │ 3 │ DELETE │ 1dd5cab0b1b64328a112db89d602ca04000001 │ false │
207+ │ 3 │ DELETE │ 019a4ef92ca4795d983d81745cf7642d000001 │ false │
208208└────────────────────────────────────────────────────────────────────────────────────────────────┘
209209
210210-- 空结果
278278┌───────────┬──────────────────┬─────────────────────────────────────────────┬───────────────────────┐
279279│ a │ _origin_version │ _origin_block_id │ _origin_block_row_num │
280280├───────────┼──────────────────┼─────────────────────────────────────────────┼───────────────────────┤
281- │ 3 │ 2317 │ 132795849016460663684755265365603707394 │ 0 │
282- │ 1 │ NULL │ NULL │ NULL │
281+ │ 3 │ 227840139 │ 2130443572288719791821140981563066043 │ 0 │
282+ │ 1 │ 227840175 │ 2130443569213242557249235987258451000 │ 0 │
283283└───────────┴──────────────────┴─────────────────────────────────────────────┴───────────────────────┘
284284```
285285
@@ -304,7 +304,7 @@ SELECT * FROM s;
304304┌─────────────────────────────────────────────────────────────────────────────────────────────┐
305305│ a │ change$action │ change$is_update │ change$row_id │
306306├─────────────────┼───────────────┼──────────────────┼────────────────────────────────────────┤
307- │ 2 │ INSERT │ false │ a577745c6a404f3384fa95791eb43f22000000 │
307+ │ 2 │ INSERT │ false │ 019a4efaa45d7a23b0062ec959c24748000000 │
308308└─────────────────────────────────────────────────────────────────────────────────────────────┘
309309
310310-- 若新增行后更新该行
@@ -315,7 +315,7 @@ SELECT * FROM s;
315315┌─────────────────────────────────────────────────────────────────────────────────────────────┐
316316│ a │ change$action │ change$is_update │ change$row_id │
317317├─────────────────┼───────────────┼──────────────────┼────────────────────────────────────────┤
318- │ 3 │ INSERT │ false │ a577745c6a404f3384fa95791eb43f22000000 │
318+ │ 3 │ INSERT │ false │ 019a4efaa45d7a23b0062ec959c24748000000 │
319319└─────────────────────────────────────────────────────────────────────────────────────────────┘
320320```
321321
@@ -413,15 +413,17 @@ SELECT
413413 *
414414FROM
415415 user_activity_profiles
416+ ORDER BY
417+ activity_timestamp;
416418
417419┌────────────────────────────────────────────────────────────────────────────────────────────────┐
418420│ user_id │ username │ location │ activity │ activity_timestamp │
419421├─────────────────┼──────────────────┼──────────────────┼──────────────────┼─────────────────────┤
422+ │ 102 │ Bob │ San Francisco │ logout │ 2023 - 12 - 19 09 :00 :00 │
420423│ 103 │ Charlie │ Los Angeles │ view_profile │ 2023 - 12 - 19 09 :15 :00 │
421424│ 104 │ Dana │ Chicago │ edit_profile │ 2023 - 12 - 19 10 :00 :00 │
422425│ 101 │ Alice │ New York │ purchase │ 2023 - 12 - 19 10 :30 :00 │
423426│ 102 │ Bob │ San Francisco │ login │ 2023 - 12 - 19 11 :00 :00 │
424- │ 102 │ Bob │ San Francisco │ logout │ 2023 - 12 - 19 09 :00 :00 │
425427└────────────────────────────────────────────────────────────────────────────────────────────────┘
426428```
427429
0 commit comments