Add COPY test

pallavisontakke · pallavisontakke · commit b240a48b22e6 · 2015-12-24T09:53:01.000+05:30
Fixes #50
diff --git a/Makefile b/Makefile
@@ -18,7 +18,7 @@ SCRIPTS_built = pglogical_create_subscriber
 PG_CPPFLAGS = -I$(libpq_srcdir)
 SHLIB_LINK = $(libpq)
 
-REGRESS = preseed infofuncs init_fail init preseed_check basic extended toasted replication_set add_table matview bidirectional primary_key foreign_key functions drop
+REGRESS = preseed infofuncs init_fail init preseed_check basic extended toasted replication_set add_table matview bidirectional primary_key foreign_key functions copy drop
 
 EXTRA_CLEAN += pglogical.control
 
diff --git a/expected/copy.out b/expected/copy.out
@@ -0,0 +1,73 @@
+--test COPY
+\c regression
+SELECT pglogical.replicate_ddl_command($$
+     CREATE TABLE public.x (
+	a serial primary key,
+	b int,
+	c text not null default 'stuff',
+	d text,
+	e text
+     );
+$$);
+ replicate_ddl_command 
+-----------------------
+ t
+(1 row)
+
+SELECT * FROM pglogical.replication_set_add_table('default', 'x');
+ replication_set_add_table 
+---------------------------
+ t
+(1 row)
+
+SELECT pg_xlog_wait_remote_apply(pg_current_xlog_location(), 0);
+ pg_xlog_wait_remote_apply 
+---------------------------
+ 
+(1 row)
+
+COPY x (a, b, c, d, e) from stdin;
+COPY x (b, d) from stdin;
+COPY x (b, d) from stdin;
+COPY x (a, b, c, d, e) from stdin;
+SELECT * FROM x ORDER BY a;
+   a   | b  |   c   |   d    | e  
+-------+----+-------+--------+----
+     1 |  1 | stuff | test_1 | 
+     2 |  2 | stuff | test_2 | 
+     3 |  3 | stuff | test_3 | 
+     4 |  4 | stuff | test_4 | 
+     5 |  5 | stuff | test_5 | 
+  9999 |    | \N    | NN     | 
+ 10000 | 21 | 31    | 41     | 51
+ 10001 | 22 | 32    | 42     | 52
+ 10002 | 23 | 33    | 43     | 53
+ 10003 | 24 | 34    | 44     | 54
+ 10004 | 25 | 35    | 45     | 55
+ 10005 | 26 | 36    | 46     | 56
+(12 rows)
+
+SELECT pg_xlog_wait_remote_apply(pg_current_xlog_location(), 0);
+ pg_xlog_wait_remote_apply 
+---------------------------
+ 
+(1 row)
+
+\c postgres
+SELECT * FROM x ORDER BY a;
+   a   | b  |   c   |   d    | e  
+-------+----+-------+--------+----
+     1 |  1 | stuff | test_1 | 
+     2 |  2 | stuff | test_2 | 
+     3 |  3 | stuff | test_3 | 
+     4 |  4 | stuff | test_4 | 
+     5 |  5 | stuff | test_5 | 
+  9999 |    | \N    | NN     | 
+ 10000 | 21 | 31    | 41     | 51
+ 10001 | 22 | 32    | 42     | 52
+ 10002 | 23 | 33    | 43     | 53
+ 10003 | 24 | 34    | 44     | 54
+ 10004 | 25 | 35    | 45     | 55
+ 10005 | 26 | 36    | 46     | 56
+(12 rows)
+
diff --git a/sql/copy.sql b/sql/copy.sql
@@ -0,0 +1,46 @@
+--test COPY
+\c regression
+
+SELECT pglogical.replicate_ddl_command($$
+     CREATE TABLE public.x (
+	a serial primary key,
+	b int,
+	c text not null default 'stuff',
+	d text,
+	e text
+     );
+$$);
+
+SELECT * FROM pglogical.replication_set_add_table('default', 'x');
+
+SELECT pg_xlog_wait_remote_apply(pg_current_xlog_location(), 0);
+
+COPY x (a, b, c, d, e) from stdin;
+9999	\N	\\N	\NN	\N
+10000	21	31	41	51
+\.
+
+COPY x (b, d) from stdin;
+1	test_1
+\.
+
+COPY x (b, d) from stdin;
+2	test_2
+3	test_3
+4	test_4
+5	test_5
+\.
+
+COPY x (a, b, c, d, e) from stdin;
+10001	22	32	42	52
+10002	23	33	43	53
+10003	24	34	44	54
+10004	25	35	45	55
+10005	26	36	46	56
+\.
+
+SELECT * FROM x ORDER BY a;
+SELECT pg_xlog_wait_remote_apply(pg_current_xlog_location(), 0);
+
+\c postgres
+SELECT * FROM x ORDER BY a;
