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

Merge pull request #5591 from citusdata/unify_tests 

Make sure that the community and enterprise tests produce the same output
pull/5543/head
Önder Kalacı 2022-01-04 14:11:24 +01:00 committed by GitHub
parent 0a8b0b06c6 22b5175fd1
commit afd53e4c54
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 30 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
src/test/regress/expected/distributed_functions.out
View File

@ -1,14 +1,14 @@
SET citus.next_shard_id TO 20020000; SET citus.next_shard_id TO 20020000;
SET client_min_messages TO ERROR;
CREATE USER functionuser; CREATE USER functionuser;
NOTICE: not propagating CREATE ROLE/USER commands to worker nodes SELECT 1 FROM run_command_on_workers($$CREATE USER functionuser;$$);
HINT: Connect to worker nodes directly to manually create all necessary users and roles. ?column?
SELECT run_command_on_workers($$CREATE USER functionuser;$$);
run_command_on_workers
--------------------------------------------------------------------- ---------------------------------------------------------------------
(localhost,57637,t,"CREATE ROLE") 1
(localhost,57638,t,"CREATE ROLE") 1
(2 rows) (2 rows)
RESET client_min_messages;
CREATE SCHEMA function_tests AUTHORIZATION functionuser; CREATE SCHEMA function_tests AUTHORIZATION functionuser;
CREATE SCHEMA function_tests2 AUTHORIZATION functionuser; CREATE SCHEMA function_tests2 AUTHORIZATION functionuser;
SET search_path TO function_tests; SET search_path TO function_tests;
@ -1089,12 +1089,13 @@ SET client_min_messages TO error; -- suppress cascading objects dropping
DROP SCHEMA function_tests CASCADE; DROP SCHEMA function_tests CASCADE;
DROP SCHEMA function_tests2 CASCADE; DROP SCHEMA function_tests2 CASCADE;
\c - - - :master_port \c - - - :master_port
SET client_min_messages TO ERROR;
DROP USER functionuser; DROP USER functionuser;
SELECT run_command_on_workers($$DROP USER functionuser$$); SELECT 1 FROM run_command_on_workers($$DROP USER functionuser$$);
run_command_on_workers ?column?
--------------------------------------------------------------------- ---------------------------------------------------------------------
(localhost,57637,t,"DROP ROLE") 1
(localhost,57638,t,"DROP ROLE") 1
(2 rows) (2 rows)
-- sync metadata again -- sync metadata again

20
src/test/regress/expected/distributed_procedure.out
View File

@ -1,14 +1,14 @@
SET citus.next_shard_id TO 20030000; SET citus.next_shard_id TO 20030000;
SET client_min_messages TO ERROR;
CREATE USER procedureuser; CREATE USER procedureuser;
NOTICE: not propagating CREATE ROLE/USER commands to worker nodes SELECT 1 FROM run_command_on_workers($$CREATE USER procedureuser;$$);
HINT: Connect to worker nodes directly to manually create all necessary users and roles. ?column?
SELECT run_command_on_workers($$CREATE USER procedureuser;$$);
run_command_on_workers
--------------------------------------------------------------------- ---------------------------------------------------------------------
(localhost,57637,t,"CREATE ROLE") 1
(localhost,57638,t,"CREATE ROLE") 1
(2 rows) (2 rows)
RESET client_min_messages;
CREATE SCHEMA procedure_tests AUTHORIZATION procedureuser; CREATE SCHEMA procedure_tests AUTHORIZATION procedureuser;
CREATE SCHEMA procedure_tests2 AUTHORIZATION procedureuser; CREATE SCHEMA procedure_tests2 AUTHORIZATION procedureuser;
SET search_path TO procedure_tests; SET search_path TO procedure_tests;
@ -189,10 +189,10 @@ SELECT run_command_on_workers($$DROP SCHEMA procedure_tests2 CASCADE;$$);
(2 rows) (2 rows)
DROP USER procedureuser; DROP USER procedureuser;
SELECT run_command_on_workers($$DROP USER procedureuser;$$); SELECT 1 FROM run_command_on_workers($$DROP USER procedureuser;$$);
run_command_on_workers ?column?
--------------------------------------------------------------------- ---------------------------------------------------------------------
(localhost,57637,t,"DROP ROLE") 1
(localhost,57638,t,"DROP ROLE") 1
(2 rows) (2 rows)

7
src/test/regress/sql/distributed_functions.sql
View File

@ -1,7 +1,9 @@
SET citus.next_shard_id TO 20020000; SET citus.next_shard_id TO 20020000;
SET client_min_messages TO ERROR;
CREATE USER functionuser; CREATE USER functionuser;
SELECT run_command_on_workers($$CREATE USER functionuser;$$); SELECT 1 FROM run_command_on_workers($$CREATE USER functionuser;$$);
RESET client_min_messages;
CREATE SCHEMA function_tests AUTHORIZATION functionuser; CREATE SCHEMA function_tests AUTHORIZATION functionuser;
CREATE SCHEMA function_tests2 AUTHORIZATION functionuser; CREATE SCHEMA function_tests2 AUTHORIZATION functionuser;
@ -692,8 +694,9 @@ DROP SCHEMA function_tests CASCADE;
DROP SCHEMA function_tests2 CASCADE; DROP SCHEMA function_tests2 CASCADE;
\c - - - :master_port \c - - - :master_port
SET client_min_messages TO ERROR;
DROP USER functionuser; DROP USER functionuser;
SELECT run_command_on_workers($$DROP USER functionuser$$); SELECT 1 FROM run_command_on_workers($$DROP USER functionuser$$);
-- sync metadata again -- sync metadata again
SELECT start_metadata_sync_to_node(nodename,nodeport) FROM pg_dist_node WHERE isactive AND noderole = 'primary'; SELECT start_metadata_sync_to_node(nodename,nodeport) FROM pg_dist_node WHERE isactive AND noderole = 'primary';

6
src/test/regress/sql/distributed_procedure.sql
View File

@ -1,7 +1,9 @@
SET citus.next_shard_id TO 20030000; SET citus.next_shard_id TO 20030000;
SET client_min_messages TO ERROR;
CREATE USER procedureuser; CREATE USER procedureuser;
SELECT run_command_on_workers($$CREATE USER procedureuser;$$); SELECT 1 FROM run_command_on_workers($$CREATE USER procedureuser;$$);
RESET client_min_messages;
CREATE SCHEMA procedure_tests AUTHORIZATION procedureuser; CREATE SCHEMA procedure_tests AUTHORIZATION procedureuser;
CREATE SCHEMA procedure_tests2 AUTHORIZATION procedureuser; CREATE SCHEMA procedure_tests2 AUTHORIZATION procedureuser;
@ -81,5 +83,5 @@ SELECT run_command_on_workers($$DROP SCHEMA procedure_tests CASCADE;$$);
DROP SCHEMA procedure_tests2 CASCADE; DROP SCHEMA procedure_tests2 CASCADE;
SELECT run_command_on_workers($$DROP SCHEMA procedure_tests2 CASCADE;$$); SELECT run_command_on_workers($$DROP SCHEMA procedure_tests2 CASCADE;$$);
DROP USER procedureuser; DROP USER procedureuser;
SELECT run_command_on_workers($$DROP USER procedureuser;$$); SELECT 1 FROM run_command_on_workers($$DROP USER procedureuser;$$);