From ecee2d77f26eb31c0d2a1151c55fc36a1904b325 Mon Sep 17 00:00:00 2001 From: Sait Talha Nisanci Date: Fri, 3 Jul 2020 15:09:59 +0300 Subject: [PATCH] test --- src/test/regress/multi_mx_schedule | 2 +- src/test/regress/sql/connection_count.sql | 137 ++++++++++++++++++ .../sql/multi_mx_repartition_udt_prepare.sql | 2 + 3 files changed, 140 insertions(+), 1 deletion(-) create mode 100644 src/test/regress/sql/connection_count.sql diff --git a/src/test/regress/multi_mx_schedule b/src/test/regress/multi_mx_schedule index 4b14811cf..3140ebe89 100644 --- a/src/test/regress/multi_mx_schedule +++ b/src/test/regress/multi_mx_schedule @@ -34,7 +34,7 @@ test: multi_mx_add_coordinator #test: ch_bench_having_mx #test: recursive_dml_queries_mx multi_mx_truncate_from_worker test: multi_mx_repartition_udt_prepare -test: multi_mx_repartition_join_w1 multi_mx_repartition_join_w2 multi_mx_repartition_udt_w1 multi_mx_repartition_udt_w2 +test: multi_mx_repartition_join_w1 multi_mx_repartition_join_w2 multi_mx_repartition_udt_w1 multi_mx_repartition_udt_w2 connection_count #test: multi_mx_metadata #test: master_evaluation master_evaluation_modify master_evaluation_select #test: multi_mx_call diff --git a/src/test/regress/sql/connection_count.sql b/src/test/regress/sql/connection_count.sql new file mode 100644 index 000000000..2bb759db6 --- /dev/null +++ b/src/test/regress/sql/connection_count.sql @@ -0,0 +1,137 @@ + +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); +select pg_sleep(0.05); + + + diff --git a/src/test/regress/sql/multi_mx_repartition_udt_prepare.sql b/src/test/regress/sql/multi_mx_repartition_udt_prepare.sql index 7c64e6897..3c3100dcc 100644 --- a/src/test/regress/sql/multi_mx_repartition_udt_prepare.sql +++ b/src/test/regress/sql/multi_mx_repartition_udt_prepare.sql @@ -184,6 +184,8 @@ INSERT INTO repartition_udt_other values (12, '(2,3)'::test_udt, 'foo'); SET client_min_messages = LOG; SET citus.task_executor_type = 'task-tracker'; +SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$); + -- -- Query that should result in a repartition -- -- join on int column, and be empty. -- SELECT * FROM repartition_udt JOIN repartition_udt_other