update test

risingwavelabs · Sep 22, 2023 · ed0cf7c · ed0cf7c
1 parent 746a793
commit ed0cf7c
Showing 1 changed file with 26 additions and 1 deletion.
diff --git a/integration_tests/citus-cdc/create_source.sql b/integration_tests/citus-cdc/create_source.sql
@@ -20,5 +20,30 @@ CREATE TABLE orders_rw (
     schema.name = 'public',
     table.name = 'orders',
     slot.name = 'orders_dbz_slot',
-    publication.create.enable = 'true'
 );
+
+DROP TABLE orders_rw;
+
+CREATE TABLE orders_rw (
+    o_orderkey bigint,
+    o_custkey bigint,
+    o_orderstatus varchar,
+    o_totalprice decimal,
+    o_orderdate date,
+    o_orderpriority varchar,
+    o_clerk varchar,
+    o_shippriority bigint,
+    o_comment varchar,
+    PRIMARY KEY (o_orderkey)
+) WITH (
+   connector = 'citus-cdc',
+   hostname = 'citus-master',
+   port = '5432',
+   username = 'myuser',
+   password = '123456',
+   database.servers = 'citus-worker-1:5432,citus-worker-2:5432',
+   database.name = 'mydb',
+   schema.name = 'public',
+   table.name = 'orders',
+   slot.name = 'orders_dbz_slot'
+);