Continue fixing multi tests

velioglu/tmpfuncprop
Burak Velioglu 2022-02-10 13:31:05 +03:00
parent cb4e53ad6e
commit c78ca8cbad
No known key found for this signature in database
GPG Key ID: F6827E620F6549C6
8 changed files with 22 additions and 2 deletions

View File

@ -284,6 +284,7 @@ INSERT INTO test_nested VALUES (200,'twohundred');
INSERT INTO test_nested VALUES (300,'threehundred'); INSERT INTO test_nested VALUES (300,'threehundred');
INSERT INTO test_nested VALUES (400,'fourhundred'); INSERT INTO test_nested VALUES (400,'fourhundred');
INSERT INTO test_nested VALUES (512,'fivetwelve'); INSERT INTO test_nested VALUES (512,'fivetwelve');
SET citus.enable_metadata_sync TO OFF;
CREATE OR REPLACE FUNCTION inner_force_delegation_function(int) CREATE OR REPLACE FUNCTION inner_force_delegation_function(int)
RETURNS NUMERIC AS $$ RETURNS NUMERIC AS $$
DECLARE ret_val NUMERIC; DECLARE ret_val NUMERIC;
@ -293,6 +294,7 @@ BEGIN
RETURN ret_val; RETURN ret_val;
END; END;
$$ LANGUAGE plpgsql; $$ LANGUAGE plpgsql;
RESET citus.enable_metadata_sync;
CREATE OR REPLACE FUNCTION func_calls_forcepush_func() CREATE OR REPLACE FUNCTION func_calls_forcepush_func()
RETURNS NUMERIC AS $$ RETURNS NUMERIC AS $$
DECLARE incremented_val NUMERIC; DECLARE incremented_val NUMERIC;
@ -350,6 +352,7 @@ PL/pgSQL function func_calls_forcepush_func() line XX at SQL statement
101 101
(1 row) (1 row)
SET citus.enable_metadata_sync TO OFF;
CREATE OR REPLACE FUNCTION get_val() CREATE OR REPLACE FUNCTION get_val()
RETURNS INT AS $$ RETURNS INT AS $$
BEGIN BEGIN
@ -363,7 +366,6 @@ $$ LANGUAGE plpgsql;
-- select res into var from fn(); -- select res into var from fn();
-- } -- }
-- --
SET citus.enable_metadata_sync TO OFF;
CREATE OR REPLACE FUNCTION func_calls_forcepush_func_infrom() CREATE OR REPLACE FUNCTION func_calls_forcepush_func_infrom()
RETURNS NUMERIC AS $$ RETURNS NUMERIC AS $$
DECLARE incremented_val NUMERIC; DECLARE incremented_val NUMERIC;

View File

@ -67,6 +67,7 @@ DEBUG: Plan XXX query after replacing subqueries and CTEs: SELECT table1.id, ta
(1 row) (1 row)
-- a function that returns a set of integers -- a function that returns a set of integers
SET citus.enable_metadata_sync TO OFF;
CREATE OR REPLACE FUNCTION next_k_integers(IN first_value INTEGER, CREATE OR REPLACE FUNCTION next_k_integers(IN first_value INTEGER,
IN k INTEGER DEFAULT 3, IN k INTEGER DEFAULT 3,
OUT result INTEGER) OUT result INTEGER)
@ -75,6 +76,7 @@ BEGIN
RETURN QUERY SELECT x FROM generate_series(first_value, first_value+k-1) f(x); RETURN QUERY SELECT x FROM generate_series(first_value, first_value+k-1) f(x);
END; END;
$$ LANGUAGE plpgsql; $$ LANGUAGE plpgsql;
RESET citus.enable_metadata_sync;
SELECT * SELECT *
FROM table1 JOIN next_k_integers(3,2) next_integers ON (id = next_integers.result) FROM table1 JOIN next_k_integers(3,2) next_integers ON (id = next_integers.result)
ORDER BY id ASC; ORDER BY id ASC;
@ -219,8 +221,10 @@ SELECT raise_failed_execution_func_join($$
$$); $$);
ERROR: Task failed to execute ERROR: Task failed to execute
-- a user-defined immutable function -- a user-defined immutable function
SET citus.enable_metadata_sync TO OFF;
CREATE OR REPLACE FUNCTION the_answer_to_life() CREATE OR REPLACE FUNCTION the_answer_to_life()
RETURNS INTEGER IMMUTABLE AS 'SELECT 42' LANGUAGE SQL; RETURNS INTEGER IMMUTABLE AS 'SELECT 42' LANGUAGE SQL;
RESET citus.enable_metadata_sync;
SELECT raise_failed_execution_func_join($$ SELECT raise_failed_execution_func_join($$
SELECT * FROM table1 JOIN the_answer_to_life() the_answer ON (id = the_answer); SELECT * FROM table1 JOIN the_answer_to_life() the_answer ON (id = the_answer);
$$); $$);

View File

@ -127,6 +127,7 @@ WHERE
user_id < 0; user_id < 0;
NOTICE: evaluating on master NOTICE: evaluating on master
-- make sure we don't evaluate stable functions with column arguments -- make sure we don't evaluate stable functions with column arguments
SET citus.enable_metadata_sync TO OFF;
CREATE OR REPLACE FUNCTION evaluate_on_master(x int) CREATE OR REPLACE FUNCTION evaluate_on_master(x int)
RETURNS int LANGUAGE plpgsql STABLE RETURNS int LANGUAGE plpgsql STABLE
AS $function$ AS $function$
@ -135,6 +136,7 @@ BEGIN
RETURN x; RETURN x;
END; END;
$function$; $function$;
RESET citus.enable_metadata_sync;
INSERT INTO raw_events_second (user_id, value_1) INSERT INTO raw_events_second (user_id, value_1)
SELECT SELECT
user_id, evaluate_on_master(value_1) user_id, evaluate_on_master(value_1)

View File

@ -142,12 +142,14 @@ SELECT * FROM text_table ORDER BY 1;
-- Test that we don't propagate base types -- Test that we don't propagate base types
CREATE TYPE myvarchar; CREATE TYPE myvarchar;
SET citus.enable_metadata_sync TO OFF;
CREATE FUNCTION myvarcharin(cstring, oid, integer) RETURNS myvarchar CREATE FUNCTION myvarcharin(cstring, oid, integer) RETURNS myvarchar
LANGUAGE internal IMMUTABLE PARALLEL SAFE STRICT AS 'varcharin'; LANGUAGE internal IMMUTABLE PARALLEL SAFE STRICT AS 'varcharin';
NOTICE: return type myvarchar is only a shell NOTICE: return type myvarchar is only a shell
CREATE FUNCTION myvarcharout(myvarchar) RETURNS cstring CREATE FUNCTION myvarcharout(myvarchar) RETURNS cstring
LANGUAGE internal IMMUTABLE PARALLEL SAFE STRICT AS 'varcharout'; LANGUAGE internal IMMUTABLE PARALLEL SAFE STRICT AS 'varcharout';
NOTICE: argument type myvarchar is only a shell NOTICE: argument type myvarchar is only a shell
RESET citus.enable_metadata_sync;
CREATE TYPE myvarchar ( CREATE TYPE myvarchar (
input = myvarcharin, input = myvarcharin,
output = myvarcharout, output = myvarcharout,

View File

@ -159,6 +159,7 @@ INSERT INTO test_nested VALUES (300,'threehundred');
INSERT INTO test_nested VALUES (400,'fourhundred'); INSERT INTO test_nested VALUES (400,'fourhundred');
INSERT INTO test_nested VALUES (512,'fivetwelve'); INSERT INTO test_nested VALUES (512,'fivetwelve');
SET citus.enable_metadata_sync TO OFF;
CREATE OR REPLACE FUNCTION inner_force_delegation_function(int) CREATE OR REPLACE FUNCTION inner_force_delegation_function(int)
RETURNS NUMERIC AS $$ RETURNS NUMERIC AS $$
DECLARE ret_val NUMERIC; DECLARE ret_val NUMERIC;
@ -168,6 +169,7 @@ BEGIN
RETURN ret_val; RETURN ret_val;
END; END;
$$ LANGUAGE plpgsql; $$ LANGUAGE plpgsql;
RESET citus.enable_metadata_sync;
CREATE OR REPLACE FUNCTION func_calls_forcepush_func() CREATE OR REPLACE FUNCTION func_calls_forcepush_func()
RETURNS NUMERIC AS $$ RETURNS NUMERIC AS $$
@ -189,6 +191,7 @@ COMMIT;
SELECT func_calls_forcepush_func(); SELECT func_calls_forcepush_func();
SET citus.enable_metadata_sync TO OFF;
CREATE OR REPLACE FUNCTION get_val() CREATE OR REPLACE FUNCTION get_val()
RETURNS INT AS $$ RETURNS INT AS $$
BEGIN BEGIN
@ -203,7 +206,6 @@ $$ LANGUAGE plpgsql;
-- select res into var from fn(); -- select res into var from fn();
-- } -- }
-- --
SET citus.enable_metadata_sync TO OFF;
CREATE OR REPLACE FUNCTION func_calls_forcepush_func_infrom() CREATE OR REPLACE FUNCTION func_calls_forcepush_func_infrom()
RETURNS NUMERIC AS $$ RETURNS NUMERIC AS $$
DECLARE incremented_val NUMERIC; DECLARE incremented_val NUMERIC;

View File

@ -46,6 +46,7 @@ $$ LANGUAGE plpgsql;
SELECT * FROM table1 JOIN increment(2) val ON (id = val) ORDER BY id ASC; SELECT * FROM table1 JOIN increment(2) val ON (id = val) ORDER BY id ASC;
-- a function that returns a set of integers -- a function that returns a set of integers
SET citus.enable_metadata_sync TO OFF;
CREATE OR REPLACE FUNCTION next_k_integers(IN first_value INTEGER, CREATE OR REPLACE FUNCTION next_k_integers(IN first_value INTEGER,
IN k INTEGER DEFAULT 3, IN k INTEGER DEFAULT 3,
OUT result INTEGER) OUT result INTEGER)
@ -54,6 +55,7 @@ BEGIN
RETURN QUERY SELECT x FROM generate_series(first_value, first_value+k-1) f(x); RETURN QUERY SELECT x FROM generate_series(first_value, first_value+k-1) f(x);
END; END;
$$ LANGUAGE plpgsql; $$ LANGUAGE plpgsql;
RESET citus.enable_metadata_sync;
SELECT * SELECT *
FROM table1 JOIN next_k_integers(3,2) next_integers ON (id = next_integers.result) FROM table1 JOIN next_k_integers(3,2) next_integers ON (id = next_integers.result)
ORDER BY id ASC; ORDER BY id ASC;
@ -148,8 +150,10 @@ SELECT raise_failed_execution_func_join($$
$$); $$);
-- a user-defined immutable function -- a user-defined immutable function
SET citus.enable_metadata_sync TO OFF;
CREATE OR REPLACE FUNCTION the_answer_to_life() CREATE OR REPLACE FUNCTION the_answer_to_life()
RETURNS INTEGER IMMUTABLE AS 'SELECT 42' LANGUAGE SQL; RETURNS INTEGER IMMUTABLE AS 'SELECT 42' LANGUAGE SQL;
RESET citus.enable_metadata_sync;
SELECT raise_failed_execution_func_join($$ SELECT raise_failed_execution_func_join($$
SELECT * FROM table1 JOIN the_answer_to_life() the_answer ON (id = the_answer); SELECT * FROM table1 JOIN the_answer_to_life() the_answer ON (id = the_answer);

View File

@ -106,6 +106,7 @@ WHERE
user_id < 0; user_id < 0;
-- make sure we don't evaluate stable functions with column arguments -- make sure we don't evaluate stable functions with column arguments
SET citus.enable_metadata_sync TO OFF;
CREATE OR REPLACE FUNCTION evaluate_on_master(x int) CREATE OR REPLACE FUNCTION evaluate_on_master(x int)
RETURNS int LANGUAGE plpgsql STABLE RETURNS int LANGUAGE plpgsql STABLE
AS $function$ AS $function$
@ -114,6 +115,7 @@ BEGIN
RETURN x; RETURN x;
END; END;
$function$; $function$;
RESET citus.enable_metadata_sync;
INSERT INTO raw_events_second (user_id, value_1) INSERT INTO raw_events_second (user_id, value_1)
SELECT SELECT

View File

@ -74,10 +74,12 @@ SELECT * FROM text_table ORDER BY 1;
-- Test that we don't propagate base types -- Test that we don't propagate base types
CREATE TYPE myvarchar; CREATE TYPE myvarchar;
SET citus.enable_metadata_sync TO OFF;
CREATE FUNCTION myvarcharin(cstring, oid, integer) RETURNS myvarchar CREATE FUNCTION myvarcharin(cstring, oid, integer) RETURNS myvarchar
LANGUAGE internal IMMUTABLE PARALLEL SAFE STRICT AS 'varcharin'; LANGUAGE internal IMMUTABLE PARALLEL SAFE STRICT AS 'varcharin';
CREATE FUNCTION myvarcharout(myvarchar) RETURNS cstring CREATE FUNCTION myvarcharout(myvarchar) RETURNS cstring
LANGUAGE internal IMMUTABLE PARALLEL SAFE STRICT AS 'varcharout'; LANGUAGE internal IMMUTABLE PARALLEL SAFE STRICT AS 'varcharout';
RESET citus.enable_metadata_sync;
CREATE TYPE myvarchar ( CREATE TYPE myvarchar (
input = myvarcharin, input = myvarcharin,
output = myvarcharout, output = myvarcharout,