supabase-postgres.git / summary / log / commit / refs

commit    6866b48d9ea548b8085a91c9da69b459a0815e84
Author:   Oliver Rice <github@oliverrice.com>
Commit:   Div Arora <darora@users.noreply.github.com>
Date:     Wed Aug 21 16:10:58 2024 +0000

    add wal2json tests


 nix/tests/expected/wal2json.out | 42 +++++++++++++++++++++++++++++++++++++++++
 nix/tests/sql/wal2json.sql      | 32 +++++++++++++++++++++++++++++++
 2 files changed, 74 insertions(+)

diff --git a/nix/tests/expected/wal2json.out b/nix/tests/expected/wal2json.out
new file mode 100644
index 00000000..6edc359e
--- /dev/null
+++ b/nix/tests/expected/wal2json.out
@@ -0,0 +1,42 @@
+create schema v;
+create table v.foo(
+  id int primary key
+);
+select
+  1
+from
+  pg_create_logical_replication_slot('reg_test', 'wal2json', false);
+ ?column? 
+----------
+        1
+(1 row)
+
+insert into v.foo(id) values (1);
+select
+  data
+from
+  pg_logical_slot_get_changes(
+	'reg_test',
+    null,
+    null,
+	'include-pk', '1',
+	'include-transaction', 'false',
+	'include-timestamp', 'false',
+	'include-type-oids', 'false',
+	'format-version', '2',
+	'actions', 'insert,update,delete'
+  ) x;
+                                                                 data                                                                 
+--------------------------------------------------------------------------------------------------------------------------------------
+ {"action":"I","schema":"v","table":"foo","columns":[{"name":"id","type":"integer","value":1}],"pk":[{"name":"id","type":"integer"}]}
+(1 row)
+
+select
+  pg_drop_replication_slot('reg_test');
+ pg_drop_replication_slot 
+--------------------------
+ 
+(1 row)
+
+drop schema v cascade;
+NOTICE:  drop cascades to table v.foo
diff --git a/nix/tests/sql/wal2json.sql b/nix/tests/sql/wal2json.sql
new file mode 100644
index 00000000..6ec4a6de
--- /dev/null
+++ b/nix/tests/sql/wal2json.sql
@@ -0,0 +1,32 @@
+create schema v;
+
+create table v.foo(
+  id int primary key
+);
+
+select
+  1
+from
+  pg_create_logical_replication_slot('reg_test', 'wal2json', false);
+
+insert into v.foo(id) values (1);
+
+select
+  data
+from
+  pg_logical_slot_get_changes(
+	'reg_test',
+    null,
+    null,
+	'include-pk', '1',
+	'include-transaction', 'false',
+	'include-timestamp', 'false',
+	'include-type-oids', 'false',
+	'format-version', '2',
+	'actions', 'insert,update,delete'
+  ) x;
+
+select
+  pg_drop_replication_slot('reg_test');
+
+drop schema v cascade;


[parent: 5bab9d8eb3e6]