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

Changes localhosts with nodeids to worker hosts

connection-string-tests-9.2-include
Halil Ozan Akgul 2020-03-24 17:09:27 +03:00
parent 13c7c1ad6d
commit b79e5b5287
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/test/regress/sql/multi_mx_node_metadata.sql
View File

@ -68,7 +68,7 @@ SELECT verify_metadata(:'worker_1_host', :worker_1_port);
-- a unwriteable node. -- a unwriteable node.
BEGIN TRANSACTION ISOLATION LEVEL REPEATABLE READ; BEGIN TRANSACTION ISOLATION LEVEL REPEATABLE READ;
SELECT nodeid, nodename, nodeport, hasmetadata, metadatasynced FROM pg_dist_node; SELECT nodeid, nodename, nodeport, hasmetadata, metadatasynced FROM pg_dist_node;
SELECT 1 FROM master_update_node(:nodeid_1, 'localhost', 12345); SELECT 1 FROM master_update_node(:nodeid_1, :'worker_1_host', 12345);
SELECT nodeid, nodename, nodeport, hasmetadata, metadatasynced FROM pg_dist_node; SELECT nodeid, nodename, nodeport, hasmetadata, metadatasynced FROM pg_dist_node;
END; END;
@ -97,13 +97,13 @@ SELECT mark_node_readonly(:'worker_2_host', :worker_2_port, TRUE);
-- Now updating the other node will mark worker 2 as not synced. -- Now updating the other node will mark worker 2 as not synced.
BEGIN; BEGIN;
SELECT 1 FROM master_update_node(:nodeid_1, 'localhost', 12345); SELECT 1 FROM master_update_node(:nodeid_1, :'worker_1_host', 12345);
SELECT nodeid, hasmetadata, metadatasynced FROM pg_dist_node ORDER BY nodeid; SELECT nodeid, hasmetadata, metadatasynced FROM pg_dist_node ORDER BY nodeid;
COMMIT; COMMIT;
-- worker_2 is out of sync, so further updates aren't sent to it and -- worker_2 is out of sync, so further updates aren't sent to it and
-- we shouldn't see the warnings. -- we shouldn't see the warnings.
SELECT 1 FROM master_update_node(:nodeid_1, 'localhost', 23456); SELECT 1 FROM master_update_node(:nodeid_1, :'worker_1_host', 23456);
SELECT nodeid, hasmetadata, metadatasynced FROM pg_dist_node ORDER BY nodeid; SELECT nodeid, hasmetadata, metadatasynced FROM pg_dist_node ORDER BY nodeid;
-- Make the node writeable. -- Make the node writeable.
@ -133,7 +133,7 @@ SELECT verify_metadata(:'worker_1_host', :worker_1_port),
-- Test that master_update_node rolls back properly -- Test that master_update_node rolls back properly
-------------------------------------------------------------------------- --------------------------------------------------------------------------
BEGIN; BEGIN;
SELECT 1 FROM master_update_node(:nodeid_1, 'localhost', 12345); SELECT 1 FROM master_update_node(:nodeid_1, :'worker_1_host', 12345);
ROLLBACK; ROLLBACK;
SELECT verify_metadata(:'worker_1_host', :worker_1_port), SELECT verify_metadata(:'worker_1_host', :worker_1_port),
@ -143,7 +143,7 @@ SELECT verify_metadata(:'worker_1_host', :worker_1_port),
-- Test that master_update_node can appear in a prepared transaction. -- Test that master_update_node can appear in a prepared transaction.
-------------------------------------------------------------------------- --------------------------------------------------------------------------
BEGIN; BEGIN;
SELECT 1 FROM master_update_node(:nodeid_1, 'localhost', 12345); SELECT 1 FROM master_update_node(:nodeid_1, :'worker_1_host', 12345);
PREPARE TRANSACTION 'tx01'; PREPARE TRANSACTION 'tx01';
COMMIT PREPARED 'tx01'; COMMIT PREPARED 'tx01';
@ -176,7 +176,7 @@ SELECT verify_metadata(:'worker_1_host', :worker_1_port);
------------------------------------------------------------------------------------ ------------------------------------------------------------------------------------
-- Test master_disable_node() when the node that is being disabled is actually down -- Test master_disable_node() when the node that is being disabled is actually down
------------------------------------------------------------------------------------ ------------------------------------------------------------------------------------
SELECT master_update_node(:nodeid_2, 'localhost', 1); SELECT master_update_node(:nodeid_2, :'worker_2_host', 1);
SELECT wait_until_metadata_sync(); SELECT wait_until_metadata_sync();
-- set metadatasynced so we try porpagating metadata changes -- set metadatasynced so we try porpagating metadata changes
@ -202,7 +202,7 @@ SELECT verify_metadata(:'worker_1_host', :worker_1_port);
-- Test master_disable_node() when the other node is down -- Test master_disable_node() when the other node is down
------------------------------------------------------------------------------------ ------------------------------------------------------------------------------------
-- node 1 is down. -- node 1 is down.
SELECT master_update_node(:nodeid_1, 'localhost', 1); SELECT master_update_node(:nodeid_1, :'worker_1_host', 1);
SELECT wait_until_metadata_sync(); SELECT wait_until_metadata_sync();
-- set metadatasynced so we try porpagating metadata changes -- set metadatasynced so we try porpagating metadata changes