mirror of
https://github.com/postgres/postgres.git
synced 2025-07-28 23:42:10 +03:00
Make contrib modules' installation scripts more secure.
Hostile objects located within the installation-time search_path could
capture references in an extension's installation or upgrade script.
If the extension is being installed with superuser privileges, this
opens the door to privilege escalation. While such hazards have existed
all along, their urgency increases with the v13 "trusted extensions"
feature, because that lets a non-superuser control the installation path
for a superuser-privileged script. Therefore, make a number of changes
to make such situations more secure:
* Tweak the construction of the installation-time search_path to ensure
that references to objects in pg_catalog can't be subverted; and
explicitly add pg_temp to the end of the path to prevent attacks using
temporary objects.
* Disable check_function_bodies within installation/upgrade scripts,
so that any security gaps in SQL-language or PL-language function bodies
cannot create a risk of unwanted installation-time code execution.
* Adjust lookup of type input/receive functions and join estimator
functions to complain if there are multiple candidate functions. This
prevents capture of references to functions whose signature is not the
first one checked; and it's arguably more user-friendly anyway.
* Modify various contrib upgrade scripts to ensure that catalog
modification queries are executed with secure search paths. (These
are in-place modifications with no extension version changes, since
it is the update process itself that is at issue, not the end result.)
Extensions that depend on other extensions cannot be made fully secure
by these methods alone; therefore, revert the "trusted" marking that
commit eb67623c9
applied to earthdistance and hstore_plperl, pending
some better solution to that set of issues.
Also add documentation around these issues, to help extension authors
write secure installation scripts.
Patch by me, following an observation by Andres Freund; thanks
to Noah Misch for review.
Security: CVE-2020-14350
This commit is contained in:
@ -8,56 +8,72 @@
|
||||
-- wherein the signatures have been updated already. In that case to_regprocedure() will
|
||||
-- return NULL and no updates will happen.
|
||||
|
||||
DO LANGUAGE plpgsql
|
||||
$$
|
||||
DECLARE
|
||||
my_schema pg_catalog.text := pg_catalog.quote_ident(pg_catalog.current_schema());
|
||||
old_path pg_catalog.text := pg_catalog.current_setting('search_path');
|
||||
BEGIN
|
||||
-- for safety, transiently set search_path to just pg_catalog+pg_temp
|
||||
PERFORM pg_catalog.set_config('search_path', 'pg_catalog, pg_temp', true);
|
||||
|
||||
UPDATE pg_catalog.pg_proc SET
|
||||
proargtypes = pg_catalog.array_to_string(newtypes::pg_catalog.oid[], ' ')::pg_catalog.oidvector,
|
||||
pronargs = pg_catalog.array_length(newtypes, 1)
|
||||
FROM (VALUES
|
||||
(NULL::pg_catalog.text, NULL::pg_catalog.regtype[]), -- establish column types
|
||||
(NULL::pg_catalog.text, NULL::pg_catalog.text[]), -- establish column types
|
||||
('gbt_oid_distance(internal,oid,int2,oid)', '{internal,oid,int2,oid,internal}'),
|
||||
('gbt_oid_union(bytea,internal)', '{internal,internal}'),
|
||||
('gbt_oid_same(internal,internal,internal)', '{gbtreekey8,gbtreekey8,internal}'),
|
||||
('gbt_oid_same(internal,internal,internal)', '{SCH.gbtreekey8,SCH.gbtreekey8,internal}'),
|
||||
('gbt_int2_distance(internal,int2,int2,oid)', '{internal,int2,int2,oid,internal}'),
|
||||
('gbt_int2_union(bytea,internal)', '{internal,internal}'),
|
||||
('gbt_int2_same(internal,internal,internal)', '{gbtreekey4,gbtreekey4,internal}'),
|
||||
('gbt_int2_same(internal,internal,internal)', '{SCH.gbtreekey4,SCH.gbtreekey4,internal}'),
|
||||
('gbt_int4_distance(internal,int4,int2,oid)', '{internal,int4,int2,oid,internal}'),
|
||||
('gbt_int4_union(bytea,internal)', '{internal,internal}'),
|
||||
('gbt_int4_same(internal,internal,internal)', '{gbtreekey8,gbtreekey8,internal}'),
|
||||
('gbt_int4_same(internal,internal,internal)', '{SCH.gbtreekey8,SCH.gbtreekey8,internal}'),
|
||||
('gbt_int8_distance(internal,int8,int2,oid)', '{internal,int8,int2,oid,internal}'),
|
||||
('gbt_int8_union(bytea,internal)', '{internal,internal}'),
|
||||
('gbt_int8_same(internal,internal,internal)', '{gbtreekey16,gbtreekey16,internal}'),
|
||||
('gbt_int8_same(internal,internal,internal)', '{SCH.gbtreekey16,SCH.gbtreekey16,internal}'),
|
||||
('gbt_float4_distance(internal,float4,int2,oid)', '{internal,float4,int2,oid,internal}'),
|
||||
('gbt_float4_union(bytea,internal)', '{internal,internal}'),
|
||||
('gbt_float4_same(internal,internal,internal)', '{gbtreekey8,gbtreekey8,internal}'),
|
||||
('gbt_float4_same(internal,internal,internal)', '{SCH.gbtreekey8,SCH.gbtreekey8,internal}'),
|
||||
('gbt_float8_distance(internal,float8,int2,oid)', '{internal,float8,int2,oid,internal}'),
|
||||
('gbt_float8_union(bytea,internal)', '{internal,internal}'),
|
||||
('gbt_float8_same(internal,internal,internal)', '{gbtreekey16,gbtreekey16,internal}'),
|
||||
('gbt_float8_same(internal,internal,internal)', '{SCH.gbtreekey16,SCH.gbtreekey16,internal}'),
|
||||
('gbt_ts_distance(internal,timestamp,int2,oid)', '{internal,timestamp,int2,oid,internal}'),
|
||||
('gbt_tstz_distance(internal,timestamptz,int2,oid)', '{internal,timestamptz,int2,oid,internal}'),
|
||||
('gbt_ts_union(bytea,internal)', '{internal,internal}'),
|
||||
('gbt_ts_same(internal,internal,internal)', '{gbtreekey16,gbtreekey16,internal}'),
|
||||
('gbt_ts_same(internal,internal,internal)', '{SCH.gbtreekey16,SCH.gbtreekey16,internal}'),
|
||||
('gbt_time_distance(internal,time,int2,oid)', '{internal,time,int2,oid,internal}'),
|
||||
('gbt_time_union(bytea,internal)', '{internal,internal}'),
|
||||
('gbt_time_same(internal,internal,internal)', '{gbtreekey16,gbtreekey16,internal}'),
|
||||
('gbt_time_same(internal,internal,internal)', '{SCH.gbtreekey16,SCH.gbtreekey16,internal}'),
|
||||
('gbt_date_distance(internal,date,int2,oid)', '{internal,date,int2,oid,internal}'),
|
||||
('gbt_date_union(bytea,internal)', '{internal,internal}'),
|
||||
('gbt_date_same(internal,internal,internal)', '{gbtreekey8,gbtreekey8,internal}'),
|
||||
('gbt_date_same(internal,internal,internal)', '{SCH.gbtreekey8,SCH.gbtreekey8,internal}'),
|
||||
('gbt_intv_distance(internal,interval,int2,oid)', '{internal,interval,int2,oid,internal}'),
|
||||
('gbt_intv_union(bytea,internal)', '{internal,internal}'),
|
||||
('gbt_intv_same(internal,internal,internal)', '{gbtreekey32,gbtreekey32,internal}'),
|
||||
('gbt_intv_same(internal,internal,internal)', '{SCH.gbtreekey32,SCH.gbtreekey32,internal}'),
|
||||
('gbt_cash_distance(internal,money,int2,oid)', '{internal,money,int2,oid,internal}'),
|
||||
('gbt_cash_union(bytea,internal)', '{internal,internal}'),
|
||||
('gbt_cash_same(internal,internal,internal)', '{gbtreekey16,gbtreekey16,internal}'),
|
||||
('gbt_cash_same(internal,internal,internal)', '{SCH.gbtreekey16,SCH.gbtreekey16,internal}'),
|
||||
('gbt_macad_union(bytea,internal)', '{internal,internal}'),
|
||||
('gbt_macad_same(internal,internal,internal)', '{gbtreekey16,gbtreekey16,internal}'),
|
||||
('gbt_macad_same(internal,internal,internal)', '{SCH.gbtreekey16,SCH.gbtreekey16,internal}'),
|
||||
('gbt_text_union(bytea,internal)', '{internal,internal}'),
|
||||
('gbt_text_same(internal,internal,internal)', '{gbtreekey_var,gbtreekey_var,internal}'),
|
||||
('gbt_text_same(internal,internal,internal)', '{SCH.gbtreekey_var,SCH.gbtreekey_var,internal}'),
|
||||
('gbt_bytea_union(bytea,internal)', '{internal,internal}'),
|
||||
('gbt_bytea_same(internal,internal,internal)', '{gbtreekey_var,gbtreekey_var,internal}'),
|
||||
('gbt_bytea_same(internal,internal,internal)', '{SCH.gbtreekey_var,SCH.gbtreekey_var,internal}'),
|
||||
('gbt_numeric_union(bytea,internal)', '{internal,internal}'),
|
||||
('gbt_numeric_same(internal,internal,internal)', '{gbtreekey_var,gbtreekey_var,internal}'),
|
||||
('gbt_numeric_same(internal,internal,internal)', '{SCH.gbtreekey_var,SCH.gbtreekey_var,internal}'),
|
||||
('gbt_bit_union(bytea,internal)', '{internal,internal}'),
|
||||
('gbt_bit_same(internal,internal,internal)', '{gbtreekey_var,gbtreekey_var,internal}'),
|
||||
('gbt_bit_same(internal,internal,internal)', '{SCH.gbtreekey_var,SCH.gbtreekey_var,internal}'),
|
||||
('gbt_inet_union(bytea,internal)', '{internal,internal}'),
|
||||
('gbt_inet_same(internal,internal,internal)', '{gbtreekey16,gbtreekey16,internal}')
|
||||
) AS update_data (oldproc, newtypes)
|
||||
WHERE oid = pg_catalog.to_regprocedure(oldproc);
|
||||
('gbt_inet_same(internal,internal,internal)', '{SCH.gbtreekey16,SCH.gbtreekey16,internal}')
|
||||
) AS update_data (oldproc, newtypestext),
|
||||
LATERAL (
|
||||
SELECT array_agg(replace(typ, 'SCH', my_schema)::regtype) as newtypes FROM unnest(newtypestext) typ
|
||||
) ls
|
||||
WHERE oid = to_regprocedure(my_schema || '.' || replace(oldproc, 'SCH', my_schema));
|
||||
|
||||
PERFORM pg_catalog.set_config('search_path', old_path, true);
|
||||
END
|
||||
$$;
|
||||
|
@ -41,14 +41,28 @@ ALTER FUNCTION replace(citext, citext, citext) PARALLEL SAFE;
|
||||
ALTER FUNCTION split_part(citext, citext, int) PARALLEL SAFE;
|
||||
ALTER FUNCTION translate(citext, citext, text) PARALLEL SAFE;
|
||||
|
||||
UPDATE pg_proc SET proparallel = 's'
|
||||
WHERE oid = 'min(citext)'::pg_catalog.regprocedure;
|
||||
-- We have to update aggregates the hard way for lack of ALTER support
|
||||
DO LANGUAGE plpgsql
|
||||
$$
|
||||
DECLARE
|
||||
my_schema pg_catalog.text := pg_catalog.quote_ident(pg_catalog.current_schema());
|
||||
old_path pg_catalog.text := pg_catalog.current_setting('search_path');
|
||||
BEGIN
|
||||
-- for safety, transiently set search_path to just pg_catalog+pg_temp
|
||||
PERFORM pg_catalog.set_config('search_path', 'pg_catalog, pg_temp', true);
|
||||
|
||||
UPDATE pg_proc SET proparallel = 's'
|
||||
WHERE oid = 'max(citext)'::pg_catalog.regprocedure;
|
||||
WHERE oid = (my_schema || '.min(' || my_schema || '.citext)')::pg_catalog.regprocedure;
|
||||
|
||||
UPDATE pg_aggregate SET aggcombinefn = 'citext_smaller'
|
||||
WHERE aggfnoid = 'max(citext)'::pg_catalog.regprocedure;
|
||||
UPDATE pg_proc SET proparallel = 's'
|
||||
WHERE oid = (my_schema || '.max(' || my_schema || '.citext)')::pg_catalog.regprocedure;
|
||||
|
||||
UPDATE pg_aggregate SET aggcombinefn = 'citext_larger'
|
||||
WHERE aggfnoid = 'max(citext)'::pg_catalog.regprocedure;
|
||||
UPDATE pg_aggregate SET aggcombinefn = (my_schema || '.citext_smaller')::regproc
|
||||
WHERE aggfnoid = (my_schema || '.max(' || my_schema || '.citext)')::pg_catalog.regprocedure;
|
||||
|
||||
UPDATE pg_aggregate SET aggcombinefn = (my_schema || '.citext_larger')::regproc
|
||||
WHERE aggfnoid = (my_schema || '.max(' || my_schema || '.citext)')::pg_catalog.regprocedure;
|
||||
|
||||
PERFORM pg_catalog.set_config('search_path', old_path, true);
|
||||
END
|
||||
$$;
|
||||
|
@ -3,5 +3,19 @@
|
||||
-- complain if script is sourced in psql, rather than via ALTER EXTENSION
|
||||
\echo Use "ALTER EXTENSION citext UPDATE TO '1.3'" to load this file. \quit
|
||||
|
||||
UPDATE pg_aggregate SET aggcombinefn = 'citext_smaller'
|
||||
WHERE aggfnoid = 'min(citext)'::pg_catalog.regprocedure;
|
||||
-- We have to update aggregates the hard way for lack of ALTER support
|
||||
DO LANGUAGE plpgsql
|
||||
$$
|
||||
DECLARE
|
||||
my_schema pg_catalog.text := pg_catalog.quote_ident(pg_catalog.current_schema());
|
||||
old_path pg_catalog.text := pg_catalog.current_setting('search_path');
|
||||
BEGIN
|
||||
-- for safety, transiently set search_path to just pg_catalog+pg_temp
|
||||
PERFORM pg_catalog.set_config('search_path', 'pg_catalog, pg_temp', true);
|
||||
|
||||
UPDATE pg_aggregate SET aggcombinefn = (my_schema || '.citext_smaller')::regproc
|
||||
WHERE aggfnoid = (my_schema || '.min(' || my_schema || '.citext)')::pg_catalog.regprocedure;
|
||||
|
||||
PERFORM pg_catalog.set_config('search_path', old_path, true);
|
||||
END
|
||||
$$;
|
||||
|
@ -89,8 +89,17 @@ ALTER EXTENSION citext ADD function translate(citext,citext,text);
|
||||
-- default collation is pinned.
|
||||
--
|
||||
|
||||
DO LANGUAGE plpgsql
|
||||
$$
|
||||
DECLARE
|
||||
my_schema pg_catalog.text := pg_catalog.quote_ident(pg_catalog.current_schema());
|
||||
old_path pg_catalog.text := pg_catalog.current_setting('search_path');
|
||||
BEGIN
|
||||
-- for safety, transiently set search_path to just pg_catalog+pg_temp
|
||||
PERFORM pg_catalog.set_config('search_path', 'pg_catalog, pg_temp', true);
|
||||
|
||||
WITH RECURSIVE typeoids(typoid) AS
|
||||
( SELECT 'citext'::pg_catalog.regtype UNION
|
||||
( SELECT (my_schema || '.citext')::pg_catalog.regtype UNION
|
||||
SELECT oid FROM pg_catalog.pg_type, typeoids
|
||||
WHERE typelem = typoid OR typbasetype = typoid )
|
||||
UPDATE pg_catalog.pg_type SET typcollation = 100
|
||||
@ -98,7 +107,7 @@ FROM typeoids
|
||||
WHERE oid = typeoids.typoid;
|
||||
|
||||
WITH RECURSIVE typeoids(typoid) AS
|
||||
( SELECT 'citext'::pg_catalog.regtype UNION
|
||||
( SELECT (my_schema || '.citext')::pg_catalog.regtype UNION
|
||||
SELECT oid FROM pg_catalog.pg_type, typeoids
|
||||
WHERE typelem = typoid OR typbasetype = typoid )
|
||||
UPDATE pg_catalog.pg_attribute SET attcollation = 100
|
||||
@ -113,7 +122,7 @@ UPDATE pg_catalog.pg_index SET indcollation =
|
||||
pg_catalog.regexp_replace(indcollation::pg_catalog.text, '^0', '100')::pg_catalog.oidvector
|
||||
WHERE indclass[0] IN (
|
||||
WITH RECURSIVE typeoids(typoid) AS
|
||||
( SELECT 'citext'::pg_catalog.regtype UNION
|
||||
( SELECT (my_schema || '.citext')::pg_catalog.regtype UNION
|
||||
SELECT oid FROM pg_catalog.pg_type, typeoids
|
||||
WHERE typelem = typoid OR typbasetype = typoid )
|
||||
SELECT oid FROM pg_catalog.pg_opclass, typeoids
|
||||
@ -124,7 +133,7 @@ UPDATE pg_catalog.pg_index SET indcollation =
|
||||
pg_catalog.regexp_replace(indcollation::pg_catalog.text, E'^(\\d+) 0', E'\\1 100')::pg_catalog.oidvector
|
||||
WHERE indclass[1] IN (
|
||||
WITH RECURSIVE typeoids(typoid) AS
|
||||
( SELECT 'citext'::pg_catalog.regtype UNION
|
||||
( SELECT (my_schema || '.citext')::pg_catalog.regtype UNION
|
||||
SELECT oid FROM pg_catalog.pg_type, typeoids
|
||||
WHERE typelem = typoid OR typbasetype = typoid )
|
||||
SELECT oid FROM pg_catalog.pg_opclass, typeoids
|
||||
@ -135,7 +144,7 @@ UPDATE pg_catalog.pg_index SET indcollation =
|
||||
pg_catalog.regexp_replace(indcollation::pg_catalog.text, E'^(\\d+ \\d+) 0', E'\\1 100')::pg_catalog.oidvector
|
||||
WHERE indclass[2] IN (
|
||||
WITH RECURSIVE typeoids(typoid) AS
|
||||
( SELECT 'citext'::pg_catalog.regtype UNION
|
||||
( SELECT (my_schema || '.citext')::pg_catalog.regtype UNION
|
||||
SELECT oid FROM pg_catalog.pg_type, typeoids
|
||||
WHERE typelem = typoid OR typbasetype = typoid )
|
||||
SELECT oid FROM pg_catalog.pg_opclass, typeoids
|
||||
@ -146,7 +155,7 @@ UPDATE pg_catalog.pg_index SET indcollation =
|
||||
pg_catalog.regexp_replace(indcollation::pg_catalog.text, E'^(\\d+ \\d+ \\d+) 0', E'\\1 100')::pg_catalog.oidvector
|
||||
WHERE indclass[3] IN (
|
||||
WITH RECURSIVE typeoids(typoid) AS
|
||||
( SELECT 'citext'::pg_catalog.regtype UNION
|
||||
( SELECT (my_schema || '.citext')::pg_catalog.regtype UNION
|
||||
SELECT oid FROM pg_catalog.pg_type, typeoids
|
||||
WHERE typelem = typoid OR typbasetype = typoid )
|
||||
SELECT oid FROM pg_catalog.pg_opclass, typeoids
|
||||
@ -157,7 +166,7 @@ UPDATE pg_catalog.pg_index SET indcollation =
|
||||
pg_catalog.regexp_replace(indcollation::pg_catalog.text, E'^(\\d+ \\d+ \\d+ \\d+) 0', E'\\1 100')::pg_catalog.oidvector
|
||||
WHERE indclass[4] IN (
|
||||
WITH RECURSIVE typeoids(typoid) AS
|
||||
( SELECT 'citext'::pg_catalog.regtype UNION
|
||||
( SELECT (my_schema || '.citext')::pg_catalog.regtype UNION
|
||||
SELECT oid FROM pg_catalog.pg_type, typeoids
|
||||
WHERE typelem = typoid OR typbasetype = typoid )
|
||||
SELECT oid FROM pg_catalog.pg_opclass, typeoids
|
||||
@ -168,7 +177,7 @@ UPDATE pg_catalog.pg_index SET indcollation =
|
||||
pg_catalog.regexp_replace(indcollation::pg_catalog.text, E'^(\\d+ \\d+ \\d+ \\d+ \\d+) 0', E'\\1 100')::pg_catalog.oidvector
|
||||
WHERE indclass[5] IN (
|
||||
WITH RECURSIVE typeoids(typoid) AS
|
||||
( SELECT 'citext'::pg_catalog.regtype UNION
|
||||
( SELECT (my_schema || '.citext')::pg_catalog.regtype UNION
|
||||
SELECT oid FROM pg_catalog.pg_type, typeoids
|
||||
WHERE typelem = typoid OR typbasetype = typoid )
|
||||
SELECT oid FROM pg_catalog.pg_opclass, typeoids
|
||||
@ -179,7 +188,7 @@ UPDATE pg_catalog.pg_index SET indcollation =
|
||||
pg_catalog.regexp_replace(indcollation::pg_catalog.text, E'^(\\d+ \\d+ \\d+ \\d+ \\d+ \\d+) 0', E'\\1 100')::pg_catalog.oidvector
|
||||
WHERE indclass[6] IN (
|
||||
WITH RECURSIVE typeoids(typoid) AS
|
||||
( SELECT 'citext'::pg_catalog.regtype UNION
|
||||
( SELECT (my_schema || '.citext')::pg_catalog.regtype UNION
|
||||
SELECT oid FROM pg_catalog.pg_type, typeoids
|
||||
WHERE typelem = typoid OR typbasetype = typoid )
|
||||
SELECT oid FROM pg_catalog.pg_opclass, typeoids
|
||||
@ -190,7 +199,7 @@ UPDATE pg_catalog.pg_index SET indcollation =
|
||||
pg_catalog.regexp_replace(indcollation::pg_catalog.text, E'^(\\d+ \\d+ \\d+ \\d+ \\d+ \\d+ \\d+) 0', E'\\1 100')::pg_catalog.oidvector
|
||||
WHERE indclass[7] IN (
|
||||
WITH RECURSIVE typeoids(typoid) AS
|
||||
( SELECT 'citext'::pg_catalog.regtype UNION
|
||||
( SELECT (my_schema || '.citext')::pg_catalog.regtype UNION
|
||||
SELECT oid FROM pg_catalog.pg_type, typeoids
|
||||
WHERE typelem = typoid OR typbasetype = typoid )
|
||||
SELECT oid FROM pg_catalog.pg_opclass, typeoids
|
||||
@ -198,3 +207,7 @@ WHERE indclass[7] IN (
|
||||
);
|
||||
|
||||
-- somewhat arbitrarily, we assume no citext indexes have more than 8 columns
|
||||
|
||||
PERFORM pg_catalog.set_config('search_path', old_path, true);
|
||||
END
|
||||
$$;
|
||||
|
@ -7,16 +7,31 @@
|
||||
-- We use to_regprocedure() so that query doesn't fail if run against 9.6beta1 definitions,
|
||||
-- wherein the signatures have been updated already. In that case to_regprocedure() will
|
||||
-- return NULL and no updates will happen.
|
||||
DO LANGUAGE plpgsql
|
||||
$$
|
||||
DECLARE
|
||||
my_schema pg_catalog.text := pg_catalog.quote_ident(pg_catalog.current_schema());
|
||||
old_path pg_catalog.text := pg_catalog.current_setting('search_path');
|
||||
BEGIN
|
||||
-- for safety, transiently set search_path to just pg_catalog+pg_temp
|
||||
PERFORM pg_catalog.set_config('search_path', 'pg_catalog, pg_temp', true);
|
||||
|
||||
UPDATE pg_catalog.pg_proc SET
|
||||
proargtypes = pg_catalog.array_to_string(newtypes::pg_catalog.oid[], ' ')::pg_catalog.oidvector,
|
||||
pronargs = pg_catalog.array_length(newtypes, 1)
|
||||
FROM (VALUES
|
||||
(NULL::pg_catalog.text, NULL::pg_catalog.regtype[]), -- establish column types
|
||||
('g_cube_consistent(internal,cube,int4,oid,internal)', '{internal,cube,int2,oid,internal}'),
|
||||
('g_cube_distance(internal,cube,smallint,oid)', '{internal,cube,smallint,oid,internal}')
|
||||
) AS update_data (oldproc, newtypes)
|
||||
WHERE oid = pg_catalog.to_regprocedure(oldproc);
|
||||
(NULL::pg_catalog.text, NULL::pg_catalog.text[]), -- establish column types
|
||||
('g_cube_consistent(internal,SCH.cube,int4,oid,internal)', '{internal,SCH.cube,int2,oid,internal}'),
|
||||
('g_cube_distance(internal,SCH.cube,smallint,oid)', '{internal,SCH.cube,smallint,oid,internal}')
|
||||
) AS update_data (oldproc, newtypestext),
|
||||
LATERAL (
|
||||
SELECT array_agg(replace(typ, 'SCH', my_schema)::regtype) as newtypes FROM unnest(newtypestext) typ
|
||||
) ls
|
||||
WHERE oid = to_regprocedure(my_schema || '.' || replace(oldproc, 'SCH', my_schema));
|
||||
|
||||
PERFORM pg_catalog.set_config('search_path', old_path, true);
|
||||
END
|
||||
$$;
|
||||
|
||||
ALTER FUNCTION cube_in(cstring) PARALLEL SAFE;
|
||||
ALTER FUNCTION cube(float8[], float8[]) PARALLEL SAFE;
|
||||
|
@ -12,6 +12,15 @@
|
||||
-- bound into a particular opclass. There's no SQL command for that,
|
||||
-- so fake it with a manual update on pg_depend.
|
||||
--
|
||||
DO LANGUAGE plpgsql
|
||||
$$
|
||||
DECLARE
|
||||
my_schema pg_catalog.text := pg_catalog.quote_ident(pg_catalog.current_schema());
|
||||
old_path pg_catalog.text := pg_catalog.current_setting('search_path');
|
||||
BEGIN
|
||||
-- for safety, transiently set search_path to just pg_catalog+pg_temp
|
||||
PERFORM pg_catalog.set_config('search_path', 'pg_catalog, pg_temp', true);
|
||||
|
||||
UPDATE pg_catalog.pg_depend
|
||||
SET deptype = 'a'
|
||||
WHERE classid = 'pg_catalog.pg_amproc'::pg_catalog.regclass
|
||||
@ -20,26 +29,30 @@ WHERE classid = 'pg_catalog.pg_amproc'::pg_catalog.regclass
|
||||
FROM pg_catalog.pg_depend
|
||||
WHERE classid = 'pg_catalog.pg_amproc'::pg_catalog.regclass
|
||||
AND refclassid = 'pg_catalog.pg_proc'::pg_catalog.regclass
|
||||
AND (refobjid = 'g_cube_compress(pg_catalog.internal)'::pg_catalog.regprocedure))
|
||||
AND (refobjid = (my_schema || '.g_cube_compress(pg_catalog.internal)')::pg_catalog.regprocedure))
|
||||
AND refclassid = 'pg_catalog.pg_opclass'::pg_catalog.regclass
|
||||
AND deptype = 'i';
|
||||
|
||||
UPDATE pg_catalog.pg_depend
|
||||
SET deptype = 'a'
|
||||
WHERE classid = 'pg_catalog.pg_amproc'::pg_catalog.regclass
|
||||
AND objid =
|
||||
(SELECT objid
|
||||
FROM pg_catalog.pg_depend
|
||||
WHERE classid = 'pg_catalog.pg_amproc'::pg_catalog.regclass
|
||||
AND refclassid = 'pg_catalog.pg_proc'::pg_catalog.regclass
|
||||
AND (refobjid = (my_schema || '.g_cube_decompress(pg_catalog.internal)')::pg_catalog.regprocedure))
|
||||
AND refclassid = 'pg_catalog.pg_opclass'::pg_catalog.regclass
|
||||
AND deptype = 'i';
|
||||
|
||||
PERFORM pg_catalog.set_config('search_path', old_path, true);
|
||||
END
|
||||
$$;
|
||||
|
||||
ALTER OPERATOR FAMILY gist_cube_ops USING gist drop function 3 (cube);
|
||||
ALTER EXTENSION cube DROP function g_cube_compress(pg_catalog.internal);
|
||||
DROP FUNCTION g_cube_compress(pg_catalog.internal);
|
||||
|
||||
UPDATE pg_catalog.pg_depend
|
||||
SET deptype = 'a'
|
||||
WHERE classid = 'pg_catalog.pg_amproc'::pg_catalog.regclass
|
||||
AND objid =
|
||||
(SELECT objid
|
||||
FROM pg_catalog.pg_depend
|
||||
WHERE classid = 'pg_catalog.pg_amproc'::pg_catalog.regclass
|
||||
AND refclassid = 'pg_catalog.pg_proc'::pg_catalog.regclass
|
||||
AND (refobjid = 'g_cube_decompress(pg_catalog.internal)'::pg_catalog.regprocedure))
|
||||
AND refclassid = 'pg_catalog.pg_opclass'::pg_catalog.regclass
|
||||
AND deptype = 'i';
|
||||
|
||||
ALTER OPERATOR FAMILY gist_cube_ops USING gist drop function 4 (cube);
|
||||
ALTER EXTENSION cube DROP function g_cube_decompress(pg_catalog.internal);
|
||||
DROP FUNCTION g_cube_decompress(pg_catalog.internal);
|
||||
|
@ -31,7 +31,7 @@ CREATE DOMAIN earth AS cube
|
||||
CONSTRAINT not_point check(cube_is_point(value))
|
||||
CONSTRAINT not_3d check(cube_dim(value) <= 3)
|
||||
CONSTRAINT on_surface check(abs(cube_distance(value, '(0)'::cube) /
|
||||
earth() - 1) < '10e-7'::float8);
|
||||
earth() - '1'::float8) < '10e-7'::float8);
|
||||
|
||||
CREATE FUNCTION sec_to_gc(float8)
|
||||
RETURNS float8
|
||||
|
@ -9,10 +9,13 @@
|
||||
-- dependent on the extension.
|
||||
|
||||
DO LANGUAGE plpgsql
|
||||
|
||||
$$
|
||||
|
||||
DECLARE
|
||||
my_schema pg_catalog.text := pg_catalog.quote_ident(pg_catalog.current_schema());
|
||||
old_path pg_catalog.text := pg_catalog.current_setting('search_path');
|
||||
BEGIN
|
||||
-- for safety, transiently set search_path to just pg_catalog+pg_temp
|
||||
PERFORM pg_catalog.set_config('search_path', 'pg_catalog, pg_temp', true);
|
||||
|
||||
PERFORM 1
|
||||
FROM pg_proc p
|
||||
@ -27,6 +30,7 @@ BEGIN
|
||||
|
||||
IF NOT FOUND
|
||||
THEN
|
||||
PERFORM pg_catalog.set_config('search_path', old_path, true);
|
||||
|
||||
CREATE FUNCTION hstore_to_json(hstore)
|
||||
RETURNS json
|
||||
@ -43,6 +47,7 @@ BEGIN
|
||||
|
||||
END IF;
|
||||
|
||||
PERFORM pg_catalog.set_config('search_path', old_path, true);
|
||||
END;
|
||||
|
||||
$$;
|
||||
|
@ -7,23 +7,38 @@
|
||||
-- We use to_regprocedure() so that query doesn't fail if run against 9.6beta1 definitions,
|
||||
-- wherein the signatures have been updated already. In that case to_regprocedure() will
|
||||
-- return NULL and no updates will happen.
|
||||
DO LANGUAGE plpgsql
|
||||
$$
|
||||
DECLARE
|
||||
my_schema pg_catalog.text := pg_catalog.quote_ident(pg_catalog.current_schema());
|
||||
old_path pg_catalog.text := pg_catalog.current_setting('search_path');
|
||||
BEGIN
|
||||
-- for safety, transiently set search_path to just pg_catalog+pg_temp
|
||||
PERFORM pg_catalog.set_config('search_path', 'pg_catalog, pg_temp', true);
|
||||
|
||||
UPDATE pg_catalog.pg_proc SET
|
||||
proargtypes = pg_catalog.array_to_string(newtypes::pg_catalog.oid[], ' ')::pg_catalog.oidvector,
|
||||
pronargs = pg_catalog.array_length(newtypes, 1)
|
||||
FROM (VALUES
|
||||
(NULL::pg_catalog.text, NULL::pg_catalog.regtype[]), -- establish column types
|
||||
('ghstore_same(internal,internal,internal)', '{ghstore,ghstore,internal}'),
|
||||
('ghstore_consistent(internal,internal,int4,oid,internal)', '{internal,hstore,int2,oid,internal}'),
|
||||
('gin_extract_hstore(internal,internal)', '{hstore,internal}'),
|
||||
('gin_extract_hstore_query(internal,internal,int2,internal,internal)', '{hstore,internal,int2,internal,internal}'),
|
||||
('gin_consistent_hstore(internal,int2,internal,int4,internal,internal)', '{internal,int2,hstore,int4,internal,internal}')
|
||||
) AS update_data (oldproc, newtypes)
|
||||
WHERE oid = pg_catalog.to_regprocedure(oldproc);
|
||||
(NULL::pg_catalog.text, NULL::pg_catalog.text[]), -- establish column types
|
||||
('ghstore_same(internal,internal,internal)', '{SCH.ghstore,SCH.ghstore,internal}'),
|
||||
('ghstore_consistent(internal,internal,int4,oid,internal)', '{internal,SCH.hstore,int2,oid,internal}'),
|
||||
('gin_extract_hstore(internal,internal)', '{SCH.hstore,internal}'),
|
||||
('gin_extract_hstore_query(internal,internal,int2,internal,internal)', '{SCH.hstore,internal,int2,internal,internal}'),
|
||||
('gin_consistent_hstore(internal,int2,internal,int4,internal,internal)', '{internal,int2,SCH.hstore,int4,internal,internal}')
|
||||
) AS update_data (oldproc, newtypestext),
|
||||
LATERAL (
|
||||
SELECT array_agg(replace(typ, 'SCH', my_schema)::regtype) as newtypes FROM unnest(newtypestext) typ
|
||||
) ls
|
||||
WHERE oid = to_regprocedure(my_schema || '.' || replace(oldproc, 'SCH', my_schema));
|
||||
|
||||
UPDATE pg_catalog.pg_proc SET
|
||||
prorettype = 'ghstore'::pg_catalog.regtype
|
||||
WHERE oid = pg_catalog.to_regprocedure('ghstore_union(internal,internal)');
|
||||
prorettype = (my_schema || '.ghstore')::pg_catalog.regtype
|
||||
WHERE oid = pg_catalog.to_regprocedure((my_schema || '.ghstore_union(internal,internal)'));
|
||||
|
||||
PERFORM pg_catalog.set_config('search_path', old_path, true);
|
||||
END
|
||||
$$;
|
||||
|
||||
ALTER FUNCTION hstore_in(cstring) PARALLEL SAFE;
|
||||
ALTER FUNCTION hstore_out(hstore) PARALLEL SAFE;
|
||||
|
@ -6,6 +6,18 @@
|
||||
ALTER FUNCTION int_agg_state(internal, int4) PARALLEL SAFE;
|
||||
ALTER FUNCTION int_agg_final_array(internal) PARALLEL SAFE;
|
||||
ALTER FUNCTION int_array_enum(int4[]) PARALLEL SAFE;
|
||||
DO LANGUAGE plpgsql
|
||||
$$
|
||||
DECLARE
|
||||
my_schema pg_catalog.text := pg_catalog.quote_ident(pg_catalog.current_schema());
|
||||
old_path pg_catalog.text := pg_catalog.current_setting('search_path');
|
||||
BEGIN
|
||||
-- for safety, transiently set search_path to just pg_catalog+pg_temp
|
||||
PERFORM pg_catalog.set_config('search_path', 'pg_catalog, pg_temp', true);
|
||||
|
||||
UPDATE pg_proc SET proparallel = 's'
|
||||
WHERE oid = 'int_array_aggregate(int4)'::pg_catalog.regprocedure;
|
||||
WHERE oid = (my_schema || '.int_array_aggregate(int4)')::pg_catalog.regprocedure;
|
||||
|
||||
PERFORM pg_catalog.set_config('search_path', old_path, true);
|
||||
END
|
||||
$$;
|
||||
|
@ -7,23 +7,38 @@
|
||||
-- We use to_regprocedure() so that query doesn't fail if run against 9.6beta1 definitions,
|
||||
-- wherein the signatures have been updated already. In that case to_regprocedure() will
|
||||
-- return NULL and no updates will happen.
|
||||
DO LANGUAGE plpgsql
|
||||
$$
|
||||
DECLARE
|
||||
my_schema pg_catalog.text := pg_catalog.quote_ident(pg_catalog.current_schema());
|
||||
old_path pg_catalog.text := pg_catalog.current_setting('search_path');
|
||||
BEGIN
|
||||
-- for safety, transiently set search_path to just pg_catalog+pg_temp
|
||||
PERFORM pg_catalog.set_config('search_path', 'pg_catalog, pg_temp', true);
|
||||
|
||||
UPDATE pg_catalog.pg_proc SET
|
||||
proargtypes = pg_catalog.array_to_string(newtypes::pg_catalog.oid[], ' ')::pg_catalog.oidvector,
|
||||
pronargs = pg_catalog.array_length(newtypes, 1)
|
||||
FROM (VALUES
|
||||
(NULL::pg_catalog.text, NULL::pg_catalog.regtype[]), -- establish column types
|
||||
(NULL::pg_catalog.text, NULL::pg_catalog.text[]), -- establish column types
|
||||
('g_int_consistent(internal,_int4,int4,oid,internal)', '{internal,_int4,int2,oid,internal}'),
|
||||
('g_intbig_consistent(internal,internal,int4,oid,internal)', '{internal,_int4,int2,oid,internal}'),
|
||||
('g_intbig_same(internal,internal,internal)', '{intbig_gkey,intbig_gkey,internal}'),
|
||||
('g_intbig_same(internal,internal,internal)', '{SCH.intbig_gkey,SCH.intbig_gkey,internal}'),
|
||||
('ginint4_queryextract(internal,internal,int2,internal,internal,internal,internal)', '{_int4,internal,int2,internal,internal,internal,internal}'),
|
||||
('ginint4_consistent(internal,int2,internal,int4,internal,internal,internal,internal)', '{internal,int2,_int4,int4,internal,internal,internal,internal}')
|
||||
) AS update_data (oldproc, newtypes)
|
||||
WHERE oid = pg_catalog.to_regprocedure(oldproc);
|
||||
) AS update_data (oldproc, newtypestext),
|
||||
LATERAL (
|
||||
SELECT array_agg(replace(typ, 'SCH', my_schema)::regtype) as newtypes FROM unnest(newtypestext) typ
|
||||
) ls
|
||||
WHERE oid = to_regprocedure(my_schema || '.' || replace(oldproc, 'SCH', my_schema));
|
||||
|
||||
UPDATE pg_catalog.pg_proc SET
|
||||
prorettype = 'intbig_gkey'::pg_catalog.regtype
|
||||
WHERE oid = pg_catalog.to_regprocedure('g_intbig_union(internal,internal)');
|
||||
prorettype = (my_schema || '.intbig_gkey')::pg_catalog.regtype
|
||||
WHERE oid = pg_catalog.to_regprocedure(my_schema || '.g_intbig_union(internal,internal)');
|
||||
|
||||
PERFORM pg_catalog.set_config('search_path', old_path, true);
|
||||
END
|
||||
$$;
|
||||
|
||||
ALTER FUNCTION bqarr_in(cstring) PARALLEL SAFE;
|
||||
ALTER FUNCTION bqarr_out(query_int) PARALLEL SAFE;
|
||||
|
@ -84,13 +84,23 @@ ALTER EXTENSION intarray ADD function ginint4_consistent(internal,smallint,inter
|
||||
-- entries. This is ugly as can be, but there's no other way to do it
|
||||
-- while preserving the identities (OIDs) of the functions.
|
||||
|
||||
DO LANGUAGE plpgsql
|
||||
$$
|
||||
DECLARE
|
||||
my_schema_unquoted pg_catalog.text := pg_catalog.current_schema();
|
||||
my_schema pg_catalog.text := pg_catalog.quote_ident(pg_catalog.current_schema());
|
||||
old_path pg_catalog.text := pg_catalog.current_setting('search_path');
|
||||
BEGIN
|
||||
-- for safety, transiently set search_path to just pg_catalog+pg_temp
|
||||
PERFORM pg_catalog.set_config('search_path', 'pg_catalog, pg_temp', true);
|
||||
|
||||
UPDATE pg_catalog.pg_proc
|
||||
SET pronargs = 7, proargtypes = '2281 2281 21 2281 2281 2281 2281'
|
||||
WHERE oid = 'ginint4_queryextract(internal,internal,smallint,internal,internal)'::pg_catalog.regprocedure;
|
||||
WHERE oid = (my_schema || '.ginint4_queryextract(internal,internal,smallint,internal,internal)')::pg_catalog.regprocedure;
|
||||
|
||||
UPDATE pg_catalog.pg_proc
|
||||
SET pronargs = 8, proargtypes = '2281 21 2281 23 2281 2281 2281 2281'
|
||||
WHERE oid = 'ginint4_consistent(internal,smallint,internal,integer,internal,internal)'::pg_catalog.regprocedure;
|
||||
WHERE oid = (my_schema || '.ginint4_consistent(internal,smallint,internal,integer,internal,internal)')::pg_catalog.regprocedure;
|
||||
|
||||
-- intarray also relies on the core function ginarrayextract, which changed
|
||||
-- signature in 9.1. To support upgrading, pg_catalog contains entries
|
||||
@ -104,8 +114,12 @@ SET amproc = 'pg_catalog.ginarrayextract(anyarray,internal,internal)'::pg_catalo
|
||||
WHERE amprocfamily =
|
||||
(SELECT oid FROM pg_catalog.pg_opfamily WHERE opfname = 'gin__int_ops' AND
|
||||
opfnamespace = (SELECT oid FROM pg_catalog.pg_namespace
|
||||
WHERE nspname = pg_catalog.current_schema()))
|
||||
WHERE nspname = my_schema_unquoted))
|
||||
AND amproclefttype = 'integer[]'::pg_catalog.regtype
|
||||
AND amprocrighttype = 'integer[]'::pg_catalog.regtype
|
||||
AND amprocnum = 2
|
||||
AND amproc = 'pg_catalog.ginarrayextract(anyarray,internal)'::pg_catalog.regprocedure;
|
||||
|
||||
PERFORM pg_catalog.set_config('search_path', old_path, true);
|
||||
END
|
||||
$$;
|
||||
|
@ -7,26 +7,41 @@
|
||||
-- We use to_regprocedure() so that query doesn't fail if run against 9.6beta1 definitions,
|
||||
-- wherein the signatures have been updated already. In that case to_regprocedure() will
|
||||
-- return NULL and no updates will happen.
|
||||
DO LANGUAGE plpgsql
|
||||
$$
|
||||
DECLARE
|
||||
my_schema pg_catalog.text := pg_catalog.quote_ident(pg_catalog.current_schema());
|
||||
old_path pg_catalog.text := pg_catalog.current_setting('search_path');
|
||||
BEGIN
|
||||
-- for safety, transiently set search_path to just pg_catalog+pg_temp
|
||||
PERFORM pg_catalog.set_config('search_path', 'pg_catalog, pg_temp', true);
|
||||
|
||||
UPDATE pg_catalog.pg_proc SET
|
||||
proargtypes = pg_catalog.array_to_string(newtypes::pg_catalog.oid[], ' ')::pg_catalog.oidvector,
|
||||
pronargs = pg_catalog.array_length(newtypes, 1)
|
||||
FROM (VALUES
|
||||
(NULL::pg_catalog.text, NULL::pg_catalog.regtype[]), -- establish column types
|
||||
('ltree_consistent(internal,internal,int2,oid,internal)', '{internal,ltree,int2,oid,internal}'),
|
||||
('ltree_same(internal,internal,internal)', '{ltree_gist,ltree_gist,internal}'),
|
||||
('_ltree_consistent(internal,internal,int2,oid,internal)', '{internal,_ltree,int2,oid,internal}'),
|
||||
('_ltree_same(internal,internal,internal)', '{ltree_gist,ltree_gist,internal}')
|
||||
) AS update_data (oldproc, newtypes)
|
||||
WHERE oid = pg_catalog.to_regprocedure(oldproc);
|
||||
(NULL::pg_catalog.text, NULL::pg_catalog.text[]), -- establish column types
|
||||
('ltree_consistent(internal,internal,int2,oid,internal)', '{internal,SCH.ltree,int2,oid,internal}'),
|
||||
('ltree_same(internal,internal,internal)', '{SCH.ltree_gist,SCH.ltree_gist,internal}'),
|
||||
('_ltree_consistent(internal,internal,int2,oid,internal)', '{internal,SCH._ltree,int2,oid,internal}'),
|
||||
('_ltree_same(internal,internal,internal)', '{SCH.ltree_gist,SCH.ltree_gist,internal}')
|
||||
) AS update_data (oldproc, newtypestext),
|
||||
LATERAL (
|
||||
SELECT array_agg(replace(typ, 'SCH', my_schema)::regtype) as newtypes FROM unnest(newtypestext) typ
|
||||
) ls
|
||||
WHERE oid = to_regprocedure(my_schema || '.' || replace(oldproc, 'SCH', my_schema));
|
||||
|
||||
UPDATE pg_catalog.pg_proc SET
|
||||
prorettype = 'ltree_gist'::pg_catalog.regtype
|
||||
WHERE oid = pg_catalog.to_regprocedure('ltree_union(internal,internal)');
|
||||
prorettype = (my_schema || '.ltree_gist')::pg_catalog.regtype
|
||||
WHERE oid = pg_catalog.to_regprocedure(my_schema || '.ltree_union(internal,internal)');
|
||||
|
||||
UPDATE pg_catalog.pg_proc SET
|
||||
prorettype = 'ltree_gist'::pg_catalog.regtype
|
||||
WHERE oid = pg_catalog.to_regprocedure('_ltree_union(internal,internal)');
|
||||
prorettype = (my_schema || '.ltree_gist')::pg_catalog.regtype
|
||||
WHERE oid = pg_catalog.to_regprocedure(my_schema || '._ltree_union(internal,internal)');
|
||||
|
||||
PERFORM pg_catalog.set_config('search_path', old_path, true);
|
||||
END
|
||||
$$;
|
||||
|
||||
ALTER FUNCTION ltree_in(cstring) PARALLEL SAFE;
|
||||
ALTER FUNCTION ltree_out(ltree) PARALLEL SAFE;
|
||||
|
@ -7,21 +7,36 @@
|
||||
-- We use to_regprocedure() so that query doesn't fail if run against 9.6beta1 definitions,
|
||||
-- wherein the signatures have been updated already. In that case to_regprocedure() will
|
||||
-- return NULL and no updates will happen.
|
||||
DO LANGUAGE plpgsql
|
||||
$$
|
||||
DECLARE
|
||||
my_schema pg_catalog.text := pg_catalog.quote_ident(pg_catalog.current_schema());
|
||||
old_path pg_catalog.text := pg_catalog.current_setting('search_path');
|
||||
BEGIN
|
||||
-- for safety, transiently set search_path to just pg_catalog+pg_temp
|
||||
PERFORM pg_catalog.set_config('search_path', 'pg_catalog, pg_temp', true);
|
||||
|
||||
UPDATE pg_catalog.pg_proc SET
|
||||
proargtypes = pg_catalog.array_to_string(newtypes::pg_catalog.oid[], ' ')::pg_catalog.oidvector,
|
||||
pronargs = pg_catalog.array_length(newtypes, 1)
|
||||
FROM (VALUES
|
||||
(NULL::pg_catalog.text, NULL::pg_catalog.regtype[]), -- establish column types
|
||||
(NULL::pg_catalog.text, NULL::pg_catalog.text[]), -- establish column types
|
||||
('gtrgm_consistent(internal,text,int4,oid,internal)', '{internal,text,int2,oid,internal}'),
|
||||
('gtrgm_distance(internal,text,int4,oid)', '{internal,text,int2,oid,internal}'),
|
||||
('gtrgm_union(bytea,internal)', '{internal,internal}')
|
||||
) AS update_data (oldproc, newtypes)
|
||||
WHERE oid = pg_catalog.to_regprocedure(oldproc);
|
||||
) AS update_data (oldproc, newtypestext),
|
||||
LATERAL (
|
||||
SELECT array_agg(replace(typ, 'SCH', my_schema)::regtype) as newtypes FROM unnest(newtypestext) typ
|
||||
) ls
|
||||
WHERE oid = to_regprocedure(my_schema || '.' || replace(oldproc, 'SCH', my_schema));
|
||||
|
||||
UPDATE pg_catalog.pg_proc SET
|
||||
prorettype = 'gtrgm'::pg_catalog.regtype
|
||||
WHERE oid = pg_catalog.to_regprocedure('gtrgm_union(internal,internal)');
|
||||
prorettype = (my_schema || '.gtrgm')::pg_catalog.regtype
|
||||
WHERE oid = pg_catalog.to_regprocedure(my_schema || '.gtrgm_union(internal,internal)');
|
||||
|
||||
PERFORM pg_catalog.set_config('search_path', old_path, true);
|
||||
END
|
||||
$$;
|
||||
|
||||
ALTER FUNCTION set_limit(float4) PARALLEL UNSAFE;
|
||||
ALTER FUNCTION show_limit() PARALLEL SAFE;
|
||||
|
@ -57,13 +57,26 @@ LANGUAGE C IMMUTABLE STRICT;
|
||||
-- entries. This is ugly as can be, but there's no other way to do it
|
||||
-- while preserving the identities (OIDs) of the functions.
|
||||
|
||||
DO LANGUAGE plpgsql
|
||||
$$
|
||||
DECLARE
|
||||
my_schema pg_catalog.text := pg_catalog.quote_ident(pg_catalog.current_schema());
|
||||
old_path pg_catalog.text := pg_catalog.current_setting('search_path');
|
||||
BEGIN
|
||||
-- for safety, transiently set search_path to just pg_catalog+pg_temp
|
||||
PERFORM pg_catalog.set_config('search_path', 'pg_catalog, pg_temp', true);
|
||||
|
||||
UPDATE pg_catalog.pg_proc
|
||||
SET pronargs = 7, proargtypes = '25 2281 21 2281 2281 2281 2281'
|
||||
WHERE oid = 'gin_extract_query_trgm(text,internal,int2,internal,internal)'::pg_catalog.regprocedure;
|
||||
WHERE oid = (my_schema || '.gin_extract_query_trgm(text,internal,int2,internal,internal)')::pg_catalog.regprocedure;
|
||||
|
||||
UPDATE pg_catalog.pg_proc
|
||||
SET pronargs = 8, proargtypes = '2281 21 25 23 2281 2281 2281 2281'
|
||||
WHERE oid = 'gin_trgm_consistent(internal,smallint,text,integer,internal,internal)'::pg_catalog.regprocedure;
|
||||
WHERE oid = (my_schema || '.gin_trgm_consistent(internal,smallint,text,integer,internal,internal)')::pg_catalog.regprocedure;
|
||||
|
||||
PERFORM pg_catalog.set_config('search_path', old_path, true);
|
||||
END
|
||||
$$;
|
||||
|
||||
|
||||
-- These were not in 9.0:
|
||||
|
@ -7,15 +7,30 @@
|
||||
-- We use to_regprocedure() so that query doesn't fail if run against 9.6beta1 definitions,
|
||||
-- wherein the signatures have been updated already. In that case to_regprocedure() will
|
||||
-- return NULL and no updates will happen.
|
||||
DO LANGUAGE plpgsql
|
||||
$$
|
||||
DECLARE
|
||||
my_schema pg_catalog.text := pg_catalog.quote_ident(pg_catalog.current_schema());
|
||||
old_path pg_catalog.text := pg_catalog.current_setting('search_path');
|
||||
BEGIN
|
||||
-- for safety, transiently set search_path to just pg_catalog+pg_temp
|
||||
PERFORM pg_catalog.set_config('search_path', 'pg_catalog, pg_temp', true);
|
||||
|
||||
UPDATE pg_catalog.pg_proc SET
|
||||
proargtypes = pg_catalog.array_to_string(newtypes::pg_catalog.oid[], ' ')::pg_catalog.oidvector,
|
||||
pronargs = pg_catalog.array_length(newtypes, 1)
|
||||
FROM (VALUES
|
||||
(NULL::pg_catalog.text, NULL::pg_catalog.regtype[]), -- establish column types
|
||||
('gseg_consistent(internal,seg,int4,oid,internal)', '{internal,seg,int2,oid,internal}')
|
||||
) AS update_data (oldproc, newtypes)
|
||||
WHERE oid = pg_catalog.to_regprocedure(oldproc);
|
||||
(NULL::pg_catalog.text, NULL::pg_catalog.text[]), -- establish column types
|
||||
('gseg_consistent(internal,SCH.seg,int4,oid,internal)', '{internal,SCH.seg,int2,oid,internal}')
|
||||
) AS update_data (oldproc, newtypestext),
|
||||
LATERAL (
|
||||
SELECT array_agg(replace(typ, 'SCH', my_schema)::regtype) as newtypes FROM unnest(newtypestext) typ
|
||||
) ls
|
||||
WHERE oid = to_regprocedure(my_schema || '.' || replace(oldproc, 'SCH', my_schema));
|
||||
|
||||
PERFORM pg_catalog.set_config('search_path', old_path, true);
|
||||
END
|
||||
$$;
|
||||
|
||||
ALTER FUNCTION seg_in(cstring) PARALLEL SAFE;
|
||||
ALTER FUNCTION seg_out(seg) PARALLEL SAFE;
|
||||
|
@ -12,6 +12,15 @@
|
||||
-- bound into a particular opclass. There's no SQL command for that,
|
||||
-- so fake it with a manual update on pg_depend.
|
||||
--
|
||||
DO LANGUAGE plpgsql
|
||||
$$
|
||||
DECLARE
|
||||
my_schema pg_catalog.text := pg_catalog.quote_ident(pg_catalog.current_schema());
|
||||
old_path pg_catalog.text := pg_catalog.current_setting('search_path');
|
||||
BEGIN
|
||||
-- for safety, transiently set search_path to just pg_catalog+pg_temp
|
||||
PERFORM pg_catalog.set_config('search_path', 'pg_catalog, pg_temp', true);
|
||||
|
||||
UPDATE pg_catalog.pg_depend
|
||||
SET deptype = 'a'
|
||||
WHERE classid = 'pg_catalog.pg_amproc'::pg_catalog.regclass
|
||||
@ -20,26 +29,30 @@ WHERE classid = 'pg_catalog.pg_amproc'::pg_catalog.regclass
|
||||
FROM pg_catalog.pg_depend
|
||||
WHERE classid = 'pg_catalog.pg_amproc'::pg_catalog.regclass
|
||||
AND refclassid = 'pg_catalog.pg_proc'::pg_catalog.regclass
|
||||
AND (refobjid = 'gseg_compress(pg_catalog.internal)'::pg_catalog.regprocedure))
|
||||
AND (refobjid = (my_schema || '.gseg_compress(internal)')::pg_catalog.regprocedure))
|
||||
AND refclassid = 'pg_catalog.pg_opclass'::pg_catalog.regclass
|
||||
AND deptype = 'i';
|
||||
|
||||
UPDATE pg_catalog.pg_depend
|
||||
SET deptype = 'a'
|
||||
WHERE classid = 'pg_catalog.pg_amproc'::pg_catalog.regclass
|
||||
AND objid =
|
||||
(SELECT objid
|
||||
FROM pg_catalog.pg_depend
|
||||
WHERE classid = 'pg_catalog.pg_amproc'::pg_catalog.regclass
|
||||
AND refclassid = 'pg_catalog.pg_proc'::pg_catalog.regclass
|
||||
AND (refobjid = (my_schema || '.gseg_decompress(internal)')::pg_catalog.regprocedure))
|
||||
AND refclassid = 'pg_catalog.pg_opclass'::pg_catalog.regclass
|
||||
AND deptype = 'i';
|
||||
|
||||
PERFORM pg_catalog.set_config('search_path', old_path, true);
|
||||
END
|
||||
$$;
|
||||
|
||||
ALTER OPERATOR FAMILY gist_seg_ops USING gist drop function 3 (seg);
|
||||
ALTER EXTENSION seg DROP function gseg_compress(pg_catalog.internal);
|
||||
DROP function gseg_compress(pg_catalog.internal);
|
||||
|
||||
UPDATE pg_catalog.pg_depend
|
||||
SET deptype = 'a'
|
||||
WHERE classid = 'pg_catalog.pg_amproc'::pg_catalog.regclass
|
||||
AND objid =
|
||||
(SELECT objid
|
||||
FROM pg_catalog.pg_depend
|
||||
WHERE classid = 'pg_catalog.pg_amproc'::pg_catalog.regclass
|
||||
AND refclassid = 'pg_catalog.pg_proc'::pg_catalog.regclass
|
||||
AND (refobjid = 'gseg_decompress(pg_catalog.internal)'::pg_catalog.regprocedure))
|
||||
AND refclassid = 'pg_catalog.pg_opclass'::pg_catalog.regclass
|
||||
AND deptype = 'i';
|
||||
|
||||
ALTER OPERATOR FAMILY gist_seg_ops USING gist drop function 4 (seg);
|
||||
ALTER EXTENSION seg DROP function gseg_decompress(pg_catalog.internal);
|
||||
DROP function gseg_decompress(pg_catalog.internal);
|
||||
|
Reference in New Issue
Block a user