From 3ea9d5b3a4fb0377a4062a9aa3dabbfa2dc3b51c Mon Sep 17 00:00:00 2001
From: Kexiang Wang <kx.wang@hotmail.com>
Date: Thu, 18 Jul 2024 22:35:26 -0400
Subject: [PATCH] add test

---
 e2e_test/source/cdc/cdc.check.slt        |  5 +++++
 e2e_test/source/cdc/cdc.load.slt         | 17 +++++++++++++++++
 e2e_test/source/cdc/cdc.share_stream.slt | 10 ++++++++++
 e2e_test/source/cdc/postgres_cdc.sql     |  6 ++++++
 4 files changed, 38 insertions(+)

diff --git a/e2e_test/source/cdc/cdc.check.slt b/e2e_test/source/cdc/cdc.check.slt
index 3d6ea0e17939..446fc7f04b09 100644
--- a/e2e_test/source/cdc/cdc.check.slt
+++ b/e2e_test/source/cdc/cdc.check.slt
@@ -75,3 +75,8 @@ select * from enum_to_varchar order by id;
 ----
 1 happy
 2 ok
+
+query II
+select * from orders order by id;
+----
+1 happy
diff --git a/e2e_test/source/cdc/cdc.load.slt b/e2e_test/source/cdc/cdc.load.slt
index 2c372cbd3ffd..fb3d1b1d0d0c 100644
--- a/e2e_test/source/cdc/cdc.load.slt
+++ b/e2e_test/source/cdc/cdc.load.slt
@@ -242,3 +242,20 @@ create table enum_to_varchar (
  table.name = 'enum_table',
  slot.name = 'enum_to_varchar'
 );
+
+
+statement ok
+create table orders (
+  id int,
+  name varchar,
+  PRIMARY KEY (id)
+) with (
+ connector = 'postgres-cdc',
+ hostname = '${PGHOST:localhost}',
+ port = '${PGPORT:5432}',
+ username = '${PGUSER:$USER}',
+ password = '${PGPASSWORD:}',
+ database.name = '${PGDATABASE:postgres}',
+ table.name = 'Order',
+ slot.name = 'orders'
+);
diff --git a/e2e_test/source/cdc/cdc.share_stream.slt b/e2e_test/source/cdc/cdc.share_stream.slt
index 3dc26d98c628..6091d8b3bc48 100644
--- a/e2e_test/source/cdc/cdc.share_stream.slt
+++ b/e2e_test/source/cdc/cdc.share_stream.slt
@@ -250,6 +250,11 @@ CREATE TABLE person_new (
     city varchar
 ) FROM pg_source TABLE 'person';
 
+CREATE TABLE orders_shared (
+    id int PRIMARY KEY,
+    name varchar,
+) FROM pg_source TABLE 'Orders';
+
 statement ok
 CREATE TABLE person_new (
     id int,
@@ -491,3 +496,8 @@ select * from enum_to_varchar_shared order by id;
 ----
 1 happy
 2 ok
+
+query II
+select * from orders_shared order by id;
+----
+1 happy
diff --git a/e2e_test/source/cdc/postgres_cdc.sql b/e2e_test/source/cdc/postgres_cdc.sql
index 43a120a19d50..2831dac183da 100644
--- a/e2e_test/source/cdc/postgres_cdc.sql
+++ b/e2e_test/source/cdc/postgres_cdc.sql
@@ -106,3 +106,9 @@ CREATE TABLE list_with_null(id int primary key, my_int int[], my_num numeric[],
 INSERT INTO list_with_null VALUES (1, '{1,2,NULL}', '{1.1,inf,NULL}', '{1.1,inf,NULL}', '{1.1,inf,NULL}', '{happy,ok,NULL}', '{bb488f9b-330d-4012-b849-12adeb49e57e,bb488f9b-330d-4012-b849-12adeb49e57f, NULL}', '{\\x00,\\x01,NULL}');
 INSERT INTO list_with_null VALUES (2, '{NULL,3,4}', '{2.2,0,NULL}' , '{2.2,0,NULL}', '{2.2,0,NULL}', '{happy,ok,sad}', '{2de296df-eda7-4202-a81f-1036100ef4f6,2977afbc-0b12-459c-a36f-f623fc9e9840}', '{\\x00,\\x01,\\x02}');
 INSERT INTO list_with_null VALUES (5, NULL, NULL, NULL, NULL, NULL, NULL, NULL);
+
+CREATE TABLE "Orders" (
+    id int PRIMARY KEY,
+    name varchar,
+);
+INSERT INTO "Orders" VALUES (1, 'happy');
\ No newline at end of file