diff --git a/e2e_test/source/cdc/cdc.check_new_rows.slt b/e2e_test/source/cdc/cdc.check_new_rows.slt index 22c97f7f09e54..4e0991126f97e 100644 --- a/e2e_test/source/cdc/cdc.check_new_rows.slt +++ b/e2e_test/source/cdc/cdc.check_new_rows.slt @@ -344,6 +344,16 @@ SELECT * FROM postgres_timestamptz_types ORDER BY c_boolean, c_int; 18 t 2025-01-08 18:30:00 19 t 2025-07-09 07:10:00 +query TTT +SELECT * FROM postgres_timestamptz_types_2023 ORDER BY c_boolean, c_int; +---- +1 f 2023-02-01 10:30:00 +2 f 2023-05-15 11:45:00 +3 f 2023-11-03 12:15:00 +11 t 2023-02-01 10:30:00 +12 t 2023-05-15 11:45:00 +13 t 2023-11-03 12:15:00 + query TTT SELECT * FROM partitioned_timestamp_table_shared ORDER BY c_boolean, c_int; ---- @@ -365,3 +375,13 @@ SELECT * FROM partitioned_timestamp_table_shared ORDER BY c_boolean, c_int; 17 t 2024-09-07 16:45:00 18 t 2025-01-08 18:30:00 19 t 2025-07-09 07:10:00 + +query TTT +SELECT * FROM partitioned_timestamp_table_2023_shared ORDER BY c_boolean, c_int; +---- +1 f 2023-02-01 10:30:00 +2 f 2023-05-15 11:45:00 +3 f 2023-11-03 12:15:00 +11 t 2023-02-01 10:30:00 +12 t 2023-05-15 11:45:00 +13 t 2023-11-03 12:15:00 diff --git a/e2e_test/source/cdc/cdc.load.slt b/e2e_test/source/cdc/cdc.load.slt index 23b8d2fbcf3ee..9b4ac56c87081 100644 --- a/e2e_test/source/cdc/cdc.load.slt +++ b/e2e_test/source/cdc/cdc.load.slt @@ -275,4 +275,22 @@ WITH ( table.name = 'partitioned_timestamp_table', publication.name = 'rw_publication' slot.name = 'my_slot_partition' +); + +statement ok +CREATE TABLE IF NOT EXISTS partitioned_timestamp_table_2023( + c_int int, + c_boolean boolean, + c_timestamp timestamp, + PRIMARY KEY (c_int, c_timestamp) +WITH ( + hostname = '${PGHOST:localhost}', + port = '${PGPORT:5432}', + username = '${PGUSER:$USER}', + password = '${PGPASSWORD:}', + database.name = '${PGDATABASE:postgres}', + schema.name = 'public', + table.name = 'partitioned_timestamp_table_2023', + publication.name = 'rw_publication' + slot.name = 'my_slot_partition' ); \ No newline at end of file diff --git a/e2e_test/source/cdc/cdc.share_stream.slt b/e2e_test/source/cdc/cdc.share_stream.slt index 5b52ad634b76a..6b259fdf7bc1e 100644 --- a/e2e_test/source/cdc/cdc.share_stream.slt +++ b/e2e_test/source/cdc/cdc.share_stream.slt @@ -120,6 +120,14 @@ CREATE TABLE partitioned_timestamp_table_shared( PRIMARY KEY (c_int, c_timestamp) ) from pg_source table 'public.partitioned_timestamp_table'; +statement ok +CREATE TABLE partitioned_timestamp_table_2023_shared( + c_int int, + c_boolean boolean, + c_timestamp timestamp, + PRIMARY KEY (c_int, c_timestamp) +) from pg_source table 'public.partitioned_timestamp_table_2023_shared'; + statement ok create materialized view products_test_cnt as select count(*) as cnt from rw.products_test; diff --git a/e2e_test/source/cdc/postgres_cdc.sql b/e2e_test/source/cdc/postgres_cdc.sql index 5e78101fbf6e6..74eddc266b7ca 100644 --- a/e2e_test/source/cdc/postgres_cdc.sql +++ b/e2e_test/source/cdc/postgres_cdc.sql @@ -130,7 +130,7 @@ CREATE TABLE partitioned_timestamp_table_2024 PARTITION OF partitioned_timestamp CREATE TABLE partitioned_timestamp_table_2025 PARTITION OF partitioned_timestamp_table FOR VALUES FROM ('2025-01-01') TO ('2025-12-31'); -INSERT INTO partitioned_timestamp_table (c_int, c_boolean, c_timestamp) VALUES +INSERT INTO partitioned_timestamp_table (c_int, c_boolean, c_timestamp) VALUES (1, false, '2023-02-01 10:30:00'), (2, false, '2023-05-15 11:45:00'), (3, false, '2023-11-03 12:15:00'), diff --git a/e2e_test/source/cdc/postgres_cdc_insert.sql b/e2e_test/source/cdc/postgres_cdc_insert.sql index 069d9299e48da..8054ec1508778 100644 --- a/e2e_test/source/cdc/postgres_cdc_insert.sql +++ b/e2e_test/source/cdc/postgres_cdc_insert.sql @@ -32,7 +32,7 @@ INSERT INTO list_with_null VALUES (3, '{NULL,-3,-4}', '{NULL,nan,-inf}', '{NULL, INSERT INTO list_with_null VALUES (4, '{-4,-5,-6}', '{NULL,-99999999999999999.9999}', '{NULL,-99999999999999999.9999}', '{NULL,-99999999999999999.9999}', '{NULL,sad,ok}', '{b2e4636d-fa03-4ad4-bf16-029a79dca3e2}', '{\\x88,\\x99,\\xAA}'); INSERT INTO list_with_null VALUES (6, NULL, NULL, NULL, NULL, NULL, NULL, NULL); -INSERT INTO partitioned_timestamp_table (c_int, c_boolean, c_timestamp) VALUES +INSERT INTO partitioned_timestamp_table (c_int, c_boolean, c_timestamp) VALUES (11, true, '2023-02-01 10:30:00'), (12, true, '2023-05-15 11:45:00'), (13, true, '2023-11-03 12:15:00'),