mirror of https://github.com/citusdata/citus.git
Split propagate extension test and add alternative output (#3314)
* Split extension name tests from propagate_extension_commands.sql * Add alternative output for escape_extension_name.sqlpull/3301/head
parent
5aec71855a
commit
8092529a2c
|
@ -0,0 +1,71 @@
|
||||||
|
CREATE SCHEMA "extension'test";
|
||||||
|
-- use a schema name with escape character
|
||||||
|
SET search_path TO "extension'test";
|
||||||
|
-- test if citus can escape the extension name
|
||||||
|
-- this output will help us to understand why we have alternative outputs for this test
|
||||||
|
-- print true if uuid-ossp is available false otherwise
|
||||||
|
SELECT CASE WHEN COUNT(*) > 0
|
||||||
|
THEN 'CREATE EXTENSION "uuid-ossp"'
|
||||||
|
ELSE 'SELECT false AS uuid_ossp_present'
|
||||||
|
END AS uuid_present_command
|
||||||
|
FROM pg_available_extensions()
|
||||||
|
WHERE name = 'uuid-ossp'
|
||||||
|
\gset
|
||||||
|
:uuid_present_command;
|
||||||
|
-- show that the extension is created on both nodes
|
||||||
|
SELECT run_command_on_workers($$SELECT count(*) FROM pg_extension WHERE extname = 'uuid-ossp'$$);
|
||||||
|
run_command_on_workers
|
||||||
|
------------------------
|
||||||
|
(localhost,57637,t,1)
|
||||||
|
(localhost,57638,t,1)
|
||||||
|
(2 rows)
|
||||||
|
|
||||||
|
SET client_min_messages TO WARNING;
|
||||||
|
DROP EXTENSION "uuid-ossp";
|
||||||
|
RESET client_min_messages;
|
||||||
|
-- show that the extension is dropped from both nodes
|
||||||
|
SELECT run_command_on_workers($$SELECT count(*) FROM pg_extension WHERE extname = 'uuid-ossp'$$);
|
||||||
|
run_command_on_workers
|
||||||
|
------------------------
|
||||||
|
(localhost,57637,t,0)
|
||||||
|
(localhost,57638,t,0)
|
||||||
|
(2 rows)
|
||||||
|
|
||||||
|
-- show that extension recreation on new nodes works also fine with extension names that require escaping
|
||||||
|
SELECT 1 from master_remove_node('localhost', :worker_2_port);
|
||||||
|
?column?
|
||||||
|
----------
|
||||||
|
1
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
-- this output will help us to understand why we have alternative outputs for this test
|
||||||
|
-- print true if uuid-ossp is available false otherwise
|
||||||
|
SELECT CASE WHEN COUNT(*) > 0
|
||||||
|
THEN 'CREATE EXTENSION "uuid-ossp"'
|
||||||
|
ELSE 'SELECT false AS uuid_ossp_present'
|
||||||
|
END AS uuid_present_command
|
||||||
|
FROM pg_available_extensions()
|
||||||
|
WHERE name = 'uuid-ossp'
|
||||||
|
\gset
|
||||||
|
:uuid_present_command;
|
||||||
|
-- and add the other node
|
||||||
|
SELECT 1 from master_add_node('localhost', :worker_2_port);
|
||||||
|
?column?
|
||||||
|
----------
|
||||||
|
1
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
-- show that the extension exists on both nodes
|
||||||
|
SELECT run_command_on_workers($$SELECT count(*) FROM pg_extension WHERE extname = 'uuid-ossp'$$);
|
||||||
|
run_command_on_workers
|
||||||
|
------------------------
|
||||||
|
(localhost,57637,t,1)
|
||||||
|
(localhost,57638,t,1)
|
||||||
|
(2 rows)
|
||||||
|
|
||||||
|
SET client_min_messages TO WARNING;
|
||||||
|
DROP EXTENSION "uuid-ossp";
|
||||||
|
RESET client_min_messages;
|
||||||
|
-- drop the schema and all the objects
|
||||||
|
SET client_min_messages TO WARNING;
|
||||||
|
DROP SCHEMA "extension'test" CASCADE;
|
|
@ -0,0 +1,83 @@
|
||||||
|
CREATE SCHEMA "extension'test";
|
||||||
|
-- use a schema name with escape character
|
||||||
|
SET search_path TO "extension'test";
|
||||||
|
-- test if citus can escape the extension name
|
||||||
|
-- this output will help us to understand why we have alternative outputs for this test
|
||||||
|
-- print true if uuid-ossp is available false otherwise
|
||||||
|
SELECT CASE WHEN COUNT(*) > 0
|
||||||
|
THEN 'CREATE EXTENSION "uuid-ossp"'
|
||||||
|
ELSE 'SELECT false AS uuid_ossp_present'
|
||||||
|
END AS uuid_present_command
|
||||||
|
FROM pg_available_extensions()
|
||||||
|
WHERE name = 'uuid-ossp'
|
||||||
|
\gset
|
||||||
|
:uuid_present_command;
|
||||||
|
uuid_ossp_present
|
||||||
|
-------------------
|
||||||
|
f
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
-- show that the extension is created on both nodes
|
||||||
|
SELECT run_command_on_workers($$SELECT count(*) FROM pg_extension WHERE extname = 'uuid-ossp'$$);
|
||||||
|
run_command_on_workers
|
||||||
|
------------------------
|
||||||
|
(localhost,57637,t,0)
|
||||||
|
(localhost,57638,t,0)
|
||||||
|
(2 rows)
|
||||||
|
|
||||||
|
SET client_min_messages TO WARNING;
|
||||||
|
DROP EXTENSION "uuid-ossp";
|
||||||
|
ERROR: extension "uuid-ossp" does not exist
|
||||||
|
RESET client_min_messages;
|
||||||
|
-- show that the extension is dropped from both nodes
|
||||||
|
SELECT run_command_on_workers($$SELECT count(*) FROM pg_extension WHERE extname = 'uuid-ossp'$$);
|
||||||
|
run_command_on_workers
|
||||||
|
------------------------
|
||||||
|
(localhost,57637,t,0)
|
||||||
|
(localhost,57638,t,0)
|
||||||
|
(2 rows)
|
||||||
|
|
||||||
|
-- show that extension recreation on new nodes works also fine with extension names that require escaping
|
||||||
|
SELECT 1 from master_remove_node('localhost', :worker_2_port);
|
||||||
|
?column?
|
||||||
|
----------
|
||||||
|
1
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
-- this output will help us to understand why we have alternative outputs for this test
|
||||||
|
-- print true if uuid-ossp is available false otherwise
|
||||||
|
SELECT CASE WHEN COUNT(*) > 0
|
||||||
|
THEN 'CREATE EXTENSION "uuid-ossp"'
|
||||||
|
ELSE 'SELECT false AS uuid_ossp_present'
|
||||||
|
END AS uuid_present_command
|
||||||
|
FROM pg_available_extensions()
|
||||||
|
WHERE name = 'uuid-ossp'
|
||||||
|
\gset
|
||||||
|
:uuid_present_command;
|
||||||
|
uuid_ossp_present
|
||||||
|
-------------------
|
||||||
|
f
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
-- and add the other node
|
||||||
|
SELECT 1 from master_add_node('localhost', :worker_2_port);
|
||||||
|
?column?
|
||||||
|
----------
|
||||||
|
1
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
-- show that the extension exists on both nodes
|
||||||
|
SELECT run_command_on_workers($$SELECT count(*) FROM pg_extension WHERE extname = 'uuid-ossp'$$);
|
||||||
|
run_command_on_workers
|
||||||
|
------------------------
|
||||||
|
(localhost,57637,t,0)
|
||||||
|
(localhost,57638,t,0)
|
||||||
|
(2 rows)
|
||||||
|
|
||||||
|
SET client_min_messages TO WARNING;
|
||||||
|
DROP EXTENSION "uuid-ossp";
|
||||||
|
ERROR: extension "uuid-ossp" does not exist
|
||||||
|
RESET client_min_messages;
|
||||||
|
-- drop the schema and all the objects
|
||||||
|
SET client_min_messages TO WARNING;
|
||||||
|
DROP SCHEMA "extension'test" CASCADE;
|
|
@ -385,54 +385,6 @@ SELECT run_command_on_workers($$SELECT count(*) FROM pg_extension WHERE extname
|
||||||
(localhost,57638,t,2)
|
(localhost,57638,t,2)
|
||||||
(2 rows)
|
(2 rows)
|
||||||
|
|
||||||
-- test if citus can escape the extension name
|
|
||||||
CREATE EXTENSION "uuid-ossp";
|
|
||||||
-- show that the extension is created on both nodes
|
|
||||||
SELECT run_command_on_workers($$SELECT count(*) FROM pg_extension WHERE extname = 'uuid-ossp'$$);
|
|
||||||
run_command_on_workers
|
|
||||||
------------------------
|
|
||||||
(localhost,57637,t,1)
|
|
||||||
(localhost,57638,t,1)
|
|
||||||
(2 rows)
|
|
||||||
|
|
||||||
SET client_min_messages TO WARNING;
|
|
||||||
DROP EXTENSION "uuid-ossp";
|
|
||||||
RESET client_min_messages;
|
|
||||||
-- show that the extension is dropped from both nodes
|
|
||||||
SELECT run_command_on_workers($$SELECT count(*) FROM pg_extension WHERE extname = 'uuid-ossp'$$);
|
|
||||||
run_command_on_workers
|
|
||||||
------------------------
|
|
||||||
(localhost,57637,t,0)
|
|
||||||
(localhost,57638,t,0)
|
|
||||||
(2 rows)
|
|
||||||
|
|
||||||
-- show that extension recreation on new nodes works also fine with extension names that require escaping
|
|
||||||
SELECT 1 from master_remove_node('localhost', :worker_2_port);
|
|
||||||
?column?
|
|
||||||
----------
|
|
||||||
1
|
|
||||||
(1 row)
|
|
||||||
|
|
||||||
CREATE EXTENSION "uuid-ossp";
|
|
||||||
-- and add the other node
|
|
||||||
SELECT 1 from master_add_node('localhost', :worker_2_port);
|
|
||||||
NOTICE: Replicating reference table "t3" to the node localhost:57638
|
|
||||||
?column?
|
|
||||||
----------
|
|
||||||
1
|
|
||||||
(1 row)
|
|
||||||
|
|
||||||
-- show that the extension exists on both nodes
|
|
||||||
SELECT run_command_on_workers($$SELECT count(*) FROM pg_extension WHERE extname = 'uuid-ossp'$$);
|
|
||||||
run_command_on_workers
|
|
||||||
------------------------
|
|
||||||
(localhost,57637,t,1)
|
|
||||||
(localhost,57638,t,1)
|
|
||||||
(2 rows)
|
|
||||||
|
|
||||||
SET client_min_messages TO WARNING;
|
|
||||||
DROP EXTENSION "uuid-ossp";
|
|
||||||
RESET client_min_messages;
|
|
||||||
-- drop the schema and all the objects
|
-- drop the schema and all the objects
|
||||||
SET client_min_messages TO WARNING;
|
SET client_min_messages TO WARNING;
|
||||||
DROP SCHEMA "extension'test" CASCADE;
|
DROP SCHEMA "extension'test" CASCADE;
|
||||||
|
|
|
@ -24,6 +24,7 @@ test: multi_703_upgrade
|
||||||
test: multi_cluster_management
|
test: multi_cluster_management
|
||||||
test: alter_role_propagation
|
test: alter_role_propagation
|
||||||
test: propagate_extension_commands
|
test: propagate_extension_commands
|
||||||
|
test: escape_extension_name
|
||||||
test: multi_test_helpers
|
test: multi_test_helpers
|
||||||
test: multi_test_catalog_views
|
test: multi_test_catalog_views
|
||||||
test: multi_table_ddl
|
test: multi_table_ddl
|
||||||
|
|
|
@ -0,0 +1,56 @@
|
||||||
|
CREATE SCHEMA "extension'test";
|
||||||
|
|
||||||
|
-- use a schema name with escape character
|
||||||
|
SET search_path TO "extension'test";
|
||||||
|
|
||||||
|
-- test if citus can escape the extension name
|
||||||
|
|
||||||
|
-- this output will help us to understand why we have alternative outputs for this test
|
||||||
|
-- print true if uuid-ossp is available false otherwise
|
||||||
|
SELECT CASE WHEN COUNT(*) > 0
|
||||||
|
THEN 'CREATE EXTENSION "uuid-ossp"'
|
||||||
|
ELSE 'SELECT false AS uuid_ossp_present'
|
||||||
|
END AS uuid_present_command
|
||||||
|
FROM pg_available_extensions()
|
||||||
|
WHERE name = 'uuid-ossp'
|
||||||
|
\gset
|
||||||
|
:uuid_present_command;
|
||||||
|
|
||||||
|
-- show that the extension is created on both nodes
|
||||||
|
SELECT run_command_on_workers($$SELECT count(*) FROM pg_extension WHERE extname = 'uuid-ossp'$$);
|
||||||
|
|
||||||
|
SET client_min_messages TO WARNING;
|
||||||
|
DROP EXTENSION "uuid-ossp";
|
||||||
|
RESET client_min_messages;
|
||||||
|
|
||||||
|
-- show that the extension is dropped from both nodes
|
||||||
|
SELECT run_command_on_workers($$SELECT count(*) FROM pg_extension WHERE extname = 'uuid-ossp'$$);
|
||||||
|
|
||||||
|
-- show that extension recreation on new nodes works also fine with extension names that require escaping
|
||||||
|
SELECT 1 from master_remove_node('localhost', :worker_2_port);
|
||||||
|
|
||||||
|
-- this output will help us to understand why we have alternative outputs for this test
|
||||||
|
-- print true if uuid-ossp is available false otherwise
|
||||||
|
SELECT CASE WHEN COUNT(*) > 0
|
||||||
|
THEN 'CREATE EXTENSION "uuid-ossp"'
|
||||||
|
ELSE 'SELECT false AS uuid_ossp_present'
|
||||||
|
END AS uuid_present_command
|
||||||
|
FROM pg_available_extensions()
|
||||||
|
WHERE name = 'uuid-ossp'
|
||||||
|
\gset
|
||||||
|
:uuid_present_command;
|
||||||
|
|
||||||
|
-- and add the other node
|
||||||
|
SELECT 1 from master_add_node('localhost', :worker_2_port);
|
||||||
|
|
||||||
|
-- show that the extension exists on both nodes
|
||||||
|
SELECT run_command_on_workers($$SELECT count(*) FROM pg_extension WHERE extname = 'uuid-ossp'$$);
|
||||||
|
|
||||||
|
SET client_min_messages TO WARNING;
|
||||||
|
DROP EXTENSION "uuid-ossp";
|
||||||
|
RESET client_min_messages;
|
||||||
|
|
||||||
|
-- drop the schema and all the objects
|
||||||
|
SET client_min_messages TO WARNING;
|
||||||
|
DROP SCHEMA "extension'test" CASCADE;
|
||||||
|
|
|
@ -229,34 +229,6 @@ SELECT 1 from master_add_node('localhost', :worker_2_port);
|
||||||
SELECT count(*) FROM citus.pg_dist_object WHERE objid IN (SELECT oid FROM pg_extension WHERE extname IN ('seg', 'isn'));
|
SELECT count(*) FROM citus.pg_dist_object WHERE objid IN (SELECT oid FROM pg_extension WHERE extname IN ('seg', 'isn'));
|
||||||
SELECT run_command_on_workers($$SELECT count(*) FROM pg_extension WHERE extname IN ('seg', 'isn')$$);
|
SELECT run_command_on_workers($$SELECT count(*) FROM pg_extension WHERE extname IN ('seg', 'isn')$$);
|
||||||
|
|
||||||
-- test if citus can escape the extension name
|
|
||||||
CREATE EXTENSION "uuid-ossp";
|
|
||||||
|
|
||||||
-- show that the extension is created on both nodes
|
|
||||||
SELECT run_command_on_workers($$SELECT count(*) FROM pg_extension WHERE extname = 'uuid-ossp'$$);
|
|
||||||
|
|
||||||
SET client_min_messages TO WARNING;
|
|
||||||
DROP EXTENSION "uuid-ossp";
|
|
||||||
RESET client_min_messages;
|
|
||||||
|
|
||||||
-- show that the extension is dropped from both nodes
|
|
||||||
SELECT run_command_on_workers($$SELECT count(*) FROM pg_extension WHERE extname = 'uuid-ossp'$$);
|
|
||||||
|
|
||||||
-- show that extension recreation on new nodes works also fine with extension names that require escaping
|
|
||||||
SELECT 1 from master_remove_node('localhost', :worker_2_port);
|
|
||||||
|
|
||||||
CREATE EXTENSION "uuid-ossp";
|
|
||||||
|
|
||||||
-- and add the other node
|
|
||||||
SELECT 1 from master_add_node('localhost', :worker_2_port);
|
|
||||||
|
|
||||||
-- show that the extension exists on both nodes
|
|
||||||
SELECT run_command_on_workers($$SELECT count(*) FROM pg_extension WHERE extname = 'uuid-ossp'$$);
|
|
||||||
|
|
||||||
SET client_min_messages TO WARNING;
|
|
||||||
DROP EXTENSION "uuid-ossp";
|
|
||||||
RESET client_min_messages;
|
|
||||||
|
|
||||||
-- drop the schema and all the objects
|
-- drop the schema and all the objects
|
||||||
SET client_min_messages TO WARNING;
|
SET client_min_messages TO WARNING;
|
||||||
DROP SCHEMA "extension'test" CASCADE;
|
DROP SCHEMA "extension'test" CASCADE;
|
||||||
|
|
Loading…
Reference in New Issue