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

Improve tests

pull/3388/head
Onder Kalaci 2020-01-17 12:47:41 +01:00
parent 0bf1e81e33
commit fd17e4578e
2 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/test/regress/expected/local_shard_execution.out
View File

@ -1509,6 +1509,7 @@ NOTICE: executing the command locally: SELECT count(*) AS count FROM ((SELECT f
RESET client_min_messages; RESET client_min_messages;
RESET citus.log_local_commands; RESET citus.log_local_commands;
\c - - - :master_port \c - - - :master_port
SET citus.next_shard_id TO 1480000;
-- local execution with custom type -- local execution with custom type
SET citus.replication_model TO "streaming"; SET citus.replication_model TO "streaming";
SET citus.shard_replication_factor TO 1; SET citus.shard_replication_factor TO 1;
@ -1579,16 +1580,16 @@ CALL register_for_event(19, 1, 'yes');
SET citus.log_local_commands TO ON; SET citus.log_local_commands TO ON;
SET client_min_messages TO DEBUG2; SET client_min_messages TO DEBUG2;
CALL register_for_event(19, 1, 'yes'); CALL register_for_event(19, 1, 'yes');
NOTICE: executing the command locally: INSERT INTO public.event_responses_1330001 AS citus_table_alias (event_id, user_id, response) VALUES (19, 1, 'yes'::public.invite_resp) ON CONFLICT(event_id, user_id) DO UPDATE SET response = excluded.response NOTICE: executing the command locally: INSERT INTO public.event_responses_1480001 AS citus_table_alias (event_id, user_id, response) VALUES (19, 1, 'yes'::public.invite_resp) ON CONFLICT(event_id, user_id) DO UPDATE SET response = excluded.response
NOTICE: executing the command locally: SELECT count(*) AS count FROM public.event_responses_1330001 event_responses WHERE (event_id OPERATOR(pg_catalog.=) 19) NOTICE: executing the command locally: SELECT count(*) AS count FROM public.event_responses_1480001 event_responses WHERE (event_id OPERATOR(pg_catalog.=) 19)
NOTICE: executing the command locally: SELECT count(*) AS count FROM (SELECT NULL::integer AS event_id, NULL::integer AS user_id, NULL::public.invite_resp AS response WHERE false) event_responses(event_id, user_id, response) WHERE ((event_id OPERATOR(pg_catalog.=) 19) AND false) NOTICE: executing the command locally: SELECT count(*) AS count FROM (SELECT NULL::integer AS event_id, NULL::integer AS user_id, NULL::public.invite_resp AS response WHERE false) event_responses(event_id, user_id, response) WHERE ((event_id OPERATOR(pg_catalog.=) 19) AND false)
NOTICE: executing the command locally: UPDATE public.event_responses_1330001 event_responses SET response = 'yes'::public.invite_resp WHERE (event_id OPERATOR(pg_catalog.=) 19) NOTICE: executing the command locally: UPDATE public.event_responses_1480001 event_responses SET response = 'yes'::public.invite_resp WHERE (event_id OPERATOR(pg_catalog.=) 19)
-- should be fine even if no parameters exists in the query -- should be fine even if no parameters exists in the query
SELECT count(*) FROM event_responses WHERE event_id = 16; SELECT count(*) FROM event_responses WHERE event_id = 16;
DEBUG: Distributed planning for a fast-path router query DEBUG: Distributed planning for a fast-path router query
DEBUG: Creating router plan DEBUG: Creating router plan
DEBUG: Plan is router executable DEBUG: Plan is router executable
NOTICE: executing the command locally: SELECT count(*) AS count FROM public.event_responses_1330001 event_responses WHERE (event_id OPERATOR(pg_catalog.=) 16) NOTICE: executing the command locally: SELECT count(*) AS count FROM public.event_responses_1480001 event_responses WHERE (event_id OPERATOR(pg_catalog.=) 16)
count count
--------------------------------------------------------------------- ---------------------------------------------------------------------
1 1
@ -1598,7 +1599,7 @@ SELECT count(*) FROM event_responses WHERE event_id = 16;
DEBUG: Distributed planning for a fast-path router query DEBUG: Distributed planning for a fast-path router query
DEBUG: Creating router plan DEBUG: Creating router plan
DEBUG: Plan is router executable DEBUG: Plan is router executable
NOTICE: executing the command locally: SELECT count(*) AS count FROM public.event_responses_1330001 event_responses WHERE (event_id OPERATOR(pg_catalog.=) 16) NOTICE: executing the command locally: SELECT count(*) AS count FROM public.event_responses_1480001 event_responses WHERE (event_id OPERATOR(pg_catalog.=) 16)
count count
--------------------------------------------------------------------- ---------------------------------------------------------------------
1 1
@ -1608,13 +1609,13 @@ UPDATE event_responses SET response = 'no' WHERE event_id = 16;
DEBUG: Distributed planning for a fast-path router query DEBUG: Distributed planning for a fast-path router query
DEBUG: Creating router plan DEBUG: Creating router plan
DEBUG: Plan is router executable DEBUG: Plan is router executable
NOTICE: executing the command locally: UPDATE public.event_responses_1330001 event_responses SET response = 'no'::public.invite_resp WHERE (event_id OPERATOR(pg_catalog.=) 16) NOTICE: executing the command locally: UPDATE public.event_responses_1480001 event_responses SET response = 'no'::public.invite_resp WHERE (event_id OPERATOR(pg_catalog.=) 16)
INSERT INTO event_responses VALUES (16, 666, 'maybe') INSERT INTO event_responses VALUES (16, 666, 'maybe')
ON CONFLICT (event_id, user_id) ON CONFLICT (event_id, user_id)
DO UPDATE SET response = EXCLUDED.response RETURNING *; DO UPDATE SET response = EXCLUDED.response RETURNING *;
DEBUG: Creating router plan DEBUG: Creating router plan
DEBUG: Plan is router executable DEBUG: Plan is router executable
NOTICE: executing the command locally: INSERT INTO public.event_responses_1330001 AS citus_table_alias (event_id, user_id, response) VALUES (16, 666, 'maybe'::public.invite_resp) ON CONFLICT(event_id, user_id) DO UPDATE SET response = excluded.response RETURNING citus_table_alias.event_id, citus_table_alias.user_id, citus_table_alias.response NOTICE: executing the command locally: INSERT INTO public.event_responses_1480001 AS citus_table_alias (event_id, user_id, response) VALUES (16, 666, 'maybe'::public.invite_resp) ON CONFLICT(event_id, user_id) DO UPDATE SET response = excluded.response RETURNING citus_table_alias.event_id, citus_table_alias.user_id, citus_table_alias.response
event_id | user_id | response event_id | user_id | response
--------------------------------------------------------------------- ---------------------------------------------------------------------
16 | 666 | maybe 16 | 666 | maybe
@ -1626,7 +1627,7 @@ ON CONFLICT (event_id, user_id)
DO UPDATE SET response = EXCLUDED.response RETURNING *; DO UPDATE SET response = EXCLUDED.response RETURNING *;
DEBUG: Creating router plan DEBUG: Creating router plan
DEBUG: Plan is router executable DEBUG: Plan is router executable
NOTICE: executing the command locally: INSERT INTO public.event_responses_1330001 AS citus_table_alias (event_id, user_id, response) VALUES (16,666,'maybe'::public.invite_resp), (17,777,'no'::public.invite_resp) ON CONFLICT(event_id, user_id) DO UPDATE SET response = excluded.response RETURNING citus_table_alias.event_id, citus_table_alias.user_id, citus_table_alias.response NOTICE: executing the command locally: INSERT INTO public.event_responses_1480001 AS citus_table_alias (event_id, user_id, response) VALUES (16,666,'maybe'::public.invite_resp), (17,777,'no'::public.invite_resp) ON CONFLICT(event_id, user_id) DO UPDATE SET response = excluded.response RETURNING citus_table_alias.event_id, citus_table_alias.user_id, citus_table_alias.response
event_id | user_id | response event_id | user_id | response
--------------------------------------------------------------------- ---------------------------------------------------------------------
16 | 666 | maybe 16 | 666 | maybe

2
src/test/regress/sql/local_shard_execution.sql
View File

@ -773,7 +773,7 @@ RESET client_min_messages;
RESET citus.log_local_commands; RESET citus.log_local_commands;
\c - - - :master_port \c - - - :master_port
SET citus.next_shard_id TO 1480000;
-- local execution with custom type -- local execution with custom type
SET citus.replication_model TO "streaming"; SET citus.replication_model TO "streaming";
SET citus.shard_replication_factor TO 1; SET citus.shard_replication_factor TO 1;