external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Shorten insert_select_connection_leak_test

pull/4168/head
Ahmet Gedemenli 2020-09-16 13:22:45 +03:00
parent 8d3f353746
commit 1cf11b4632
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/test/regress/expected/insert_select_connection_leak.out
View File

@ -23,7 +23,7 @@ SELECT create_distributed_table('target_table', 'a');
(1 row) (1 row)
INSERT INTO source_table SELECT i, 2 * i FROM generate_series(1, 10000) i; INSERT INTO source_table SELECT i, 2 * i FROM generate_series(1, 100) i;
EXPLAIN (costs off) INSERT INTO target_table SELECT * FROM source_table; EXPLAIN (costs off) INSERT INTO target_table SELECT * FROM source_table;
QUERY PLAN QUERY PLAN
--------------------------------------------------------------------- ---------------------------------------------------------------------
@ -81,7 +81,7 @@ INSERT INTO target_table SELECT * FROM source_table;
SELECT worker_connection_count(:worker_1_port) AS worker_1_connections, SELECT worker_connection_count(:worker_1_port) AS worker_1_connections,
worker_connection_count(:worker_2_port) AS worker_2_connections \gset worker_connection_count(:worker_2_port) AS worker_2_connections \gset
SAVEPOINT s1; SAVEPOINT s1;
INSERT INTO target_table SELECT a, CASE WHEN a < 5000 THEN b ELSE null END FROM source_table; INSERT INTO target_table SELECT a, CASE WHEN a < 50 THEN b ELSE null END FROM source_table;
ERROR: null value in column "b" violates not-null constraint ERROR: null value in column "b" violates not-null constraint
ROLLBACK TO SAVEPOINT s1; ROLLBACK TO SAVEPOINT s1;
SELECT worker_connection_count(:worker_1_port) - :worker_1_connections AS leaked_worker_1_connections, SELECT worker_connection_count(:worker_1_port) - :worker_1_connections AS leaked_worker_1_connections,

4
src/test/regress/sql/insert_select_connection_leak.sql
View File

@ -18,7 +18,7 @@ SELECT create_distributed_table('source_table', 'a');
CREATE TABLE target_table(a numeric, b int not null); CREATE TABLE target_table(a numeric, b int not null);
SELECT create_distributed_table('target_table', 'a'); SELECT create_distributed_table('target_table', 'a');
INSERT INTO source_table SELECT i, 2 * i FROM generate_series(1, 10000) i; INSERT INTO source_table SELECT i, 2 * i FROM generate_series(1, 100) i;
EXPLAIN (costs off) INSERT INTO target_table SELECT * FROM source_table; EXPLAIN (costs off) INSERT INTO target_table SELECT * FROM source_table;
@ -57,7 +57,7 @@ INSERT INTO target_table SELECT * FROM source_table;
SELECT worker_connection_count(:worker_1_port) AS worker_1_connections, SELECT worker_connection_count(:worker_1_port) AS worker_1_connections,
worker_connection_count(:worker_2_port) AS worker_2_connections \gset worker_connection_count(:worker_2_port) AS worker_2_connections \gset
SAVEPOINT s1; SAVEPOINT s1;
INSERT INTO target_table SELECT a, CASE WHEN a < 5000 THEN b ELSE null END FROM source_table; INSERT INTO target_table SELECT a, CASE WHEN a < 50 THEN b ELSE null END FROM source_table;
ROLLBACK TO SAVEPOINT s1; ROLLBACK TO SAVEPOINT s1;
SELECT worker_connection_count(:worker_1_port) - :worker_1_connections AS leaked_worker_1_connections, SELECT worker_connection_count(:worker_1_port) - :worker_1_connections AS leaked_worker_1_connections,
worker_connection_count(:worker_2_port) - :worker_2_connections AS leaked_worker_2_connections; worker_connection_count(:worker_2_port) - :worker_2_connections AS leaked_worker_2_connections;