mirror of
https://github.com/adjust/pg-base36.git
synced 2025-12-16 15:54:39 +00:00
Parallelism for 9.6 (#4)
1.0 for release on pgxn Adds parallelism for 9.6 and higher
This commit is contained in:
Chris Travers
39
META.json
Normal file
39
META.json
Normal file
@@ -0,0 +1,39 @@
|
||||
{
|
||||
"name": "base36",
|
||||
"abstract": "Integers represented in base36",
|
||||
"version": "1.0.0",
|
||||
"maintainer": [ "Chris Travers <chris.travers@adjust.com>", "Manuel Kniep <rapimo@adjust.com>" ],
|
||||
"license": {
|
||||
"PostgreSQL": "http://www.postgresql.org/about/licence"
|
||||
},
|
||||
"provides": {
|
||||
"base36": {
|
||||
"file": "sql/base36.sql",
|
||||
"version": "1.0.0",
|
||||
"abstract": "Integers represented in base36"
|
||||
}
|
||||
},
|
||||
"meta-spec": {
|
||||
"version": "1.0.0",
|
||||
"url": "http://pgxn.org/meta/spec.txt"
|
||||
},
|
||||
"description": "Integers represented in base36",
|
||||
"prereqs": {
|
||||
"runtime": {
|
||||
"requires": {
|
||||
"PostgreSQL": "9.3.0"
|
||||
}
|
||||
}
|
||||
},
|
||||
"resources": {
|
||||
"bugtracker": {
|
||||
"web": "http://github.com/adjust/pg-country/issues"
|
||||
},
|
||||
"repository": {
|
||||
"url": "git://github.com/adjust/pg-country.git",
|
||||
"web": "http://github.com/adjust/pg-country",
|
||||
"type": "git"
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
47
base36--0.0.1--1.0.0.sql
Normal file
47
base36--0.0.1--1.0.0.sql
Normal file
@@ -0,0 +1,47 @@
|
||||
|
||||
DO $$
|
||||
DECLARE version_num integer;
|
||||
BEGIN
|
||||
SELECT current_setting('server_version_num') INTO STRICT version_num;
|
||||
IF version_num > 90600 THEN
|
||||
EXECUTE $E$ ALTER FUNCTION base36_in(cstring) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_out(base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_recv(internal) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_send(base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36(text) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION text(base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_eq(base36, base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_ne(base36, base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_lt(base36, base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_le(base36, base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_gt(base36, base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_ge(base36, base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_cmp(base36, base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION hash_base36(base36) PARALLEL SAFE $E$;
|
||||
END IF;
|
||||
END;
|
||||
$$;
|
||||
|
||||
DO $$
|
||||
DECLARE version_num integer;
|
||||
BEGIN
|
||||
SELECT current_setting('server_version_num') INTO STRICT version_num;
|
||||
IF version_num > 90600 THEN
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_in(cstring) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_out(bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_recv(internal) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_send(bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36(text) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION text(bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_eq(bigbase36, bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_ne(bigbase36, bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_lt(bigbase36, bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_le(bigbase36, bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_gt(bigbase36, bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_ge(bigbase36, bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_cmp(bigbase36, bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION hash_bigbase36(bigbase36) PARALLEL SAFE $E$;
|
||||
END IF;
|
||||
END;
|
||||
$$;
|
||||
|
||||
338
base36--1.0.0.sql
Normal file
338
base36--1.0.0.sql
Normal file
@@ -0,0 +1,338 @@
|
||||
CREATE FUNCTION base36_in(cstring)
|
||||
RETURNS base36
|
||||
AS '$libdir/base36'
|
||||
LANGUAGE C IMMUTABLE STRICT;
|
||||
|
||||
CREATE FUNCTION base36_out(base36)
|
||||
RETURNS cstring
|
||||
AS '$libdir/base36'
|
||||
LANGUAGE C IMMUTABLE STRICT;
|
||||
|
||||
CREATE FUNCTION base36_recv(internal)
|
||||
RETURNS base36 LANGUAGE internal IMMUTABLE AS 'int4recv';
|
||||
|
||||
CREATE FUNCTION base36_send(base36)
|
||||
RETURNS bytea LANGUAGE internal IMMUTABLE AS 'int4send';
|
||||
|
||||
CREATE TYPE base36 (
|
||||
INPUT = base36_in,
|
||||
OUTPUT = base36_out,
|
||||
RECEIVE = base36_recv,
|
||||
SEND = base36_send,
|
||||
LIKE = integer,
|
||||
CATEGORY = 'N'
|
||||
);
|
||||
COMMENT ON TYPE base36 IS 'int written in base36: [0-9a-z]+';
|
||||
|
||||
CREATE FUNCTION base36(text)
|
||||
RETURNS base36
|
||||
AS '$libdir/base36', 'base36_cast_from_text'
|
||||
LANGUAGE C IMMUTABLE STRICT;
|
||||
|
||||
CREATE FUNCTION text(base36)
|
||||
RETURNS text
|
||||
AS '$libdir/base36', 'base36_cast_to_text'
|
||||
LANGUAGE C IMMUTABLE STRICT;
|
||||
|
||||
CREATE CAST (text as base36) WITH FUNCTION base36(text) AS IMPLICIT;
|
||||
CREATE CAST (base36 as text) WITH FUNCTION text(base36);
|
||||
|
||||
CREATE CAST (integer as base36) WITHOUT FUNCTION AS IMPLICIT;
|
||||
CREATE CAST (base36 as integer) WITHOUT FUNCTION AS IMPLICIT;
|
||||
|
||||
CREATE FUNCTION base36_eq(base36, base36)
|
||||
RETURNS boolean LANGUAGE internal IMMUTABLE AS 'int4eq';
|
||||
|
||||
CREATE FUNCTION base36_ne(base36, base36)
|
||||
RETURNS boolean LANGUAGE internal IMMUTABLE AS 'int4ne';
|
||||
|
||||
CREATE FUNCTION base36_lt(base36, base36)
|
||||
RETURNS boolean LANGUAGE internal IMMUTABLE AS 'int4lt';
|
||||
|
||||
CREATE FUNCTION base36_le(base36, base36)
|
||||
RETURNS boolean LANGUAGE internal IMMUTABLE AS 'int4le';
|
||||
|
||||
CREATE FUNCTION base36_gt(base36, base36)
|
||||
RETURNS boolean LANGUAGE internal IMMUTABLE AS 'int4gt';
|
||||
|
||||
CREATE FUNCTION base36_ge(base36, base36)
|
||||
RETURNS boolean LANGUAGE internal IMMUTABLE AS 'int4ge';
|
||||
|
||||
CREATE FUNCTION base36_cmp(base36, base36)
|
||||
RETURNS integer LANGUAGE internal IMMUTABLE AS 'btint4cmp';
|
||||
|
||||
CREATE FUNCTION hash_base36(base36)
|
||||
RETURNS integer LANGUAGE internal IMMUTABLE AS 'hashint4';
|
||||
|
||||
DO $$
|
||||
DECLARE version_num integer;
|
||||
BEGIN
|
||||
SELECT current_setting('server_version_num') INTO STRICT version_num;
|
||||
IF version_num > 90600 THEN
|
||||
EXECUTE $E$ ALTER FUNCTION base36_in(cstring) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_out(base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_recv(internal) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_send(base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36(text) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION text(base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_eq(base36, base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_ne(base36, base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_lt(base36, base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_le(base36, base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_gt(base36, base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_ge(base36, base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_cmp(base36, base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION hash_base36(base36) PARALLEL SAFE $E$;
|
||||
END IF;
|
||||
END;
|
||||
$$;
|
||||
|
||||
CREATE OPERATOR = (
|
||||
LEFTARG = base36,
|
||||
RIGHTARG = base36,
|
||||
PROCEDURE = base36_eq,
|
||||
COMMUTATOR = '=',
|
||||
NEGATOR = '<>',
|
||||
RESTRICT = eqsel,
|
||||
JOIN = eqjoinsel
|
||||
);
|
||||
COMMENT ON OPERATOR =(base36, base36) IS 'equals?';
|
||||
|
||||
CREATE OPERATOR <> (
|
||||
LEFTARG = base36,
|
||||
RIGHTARG = base36,
|
||||
PROCEDURE = base36_ne,
|
||||
COMMUTATOR = '<>',
|
||||
NEGATOR = '=',
|
||||
RESTRICT = neqsel,
|
||||
JOIN = neqjoinsel
|
||||
);
|
||||
COMMENT ON OPERATOR <>(base36, base36) IS 'not equals?';
|
||||
|
||||
CREATE OPERATOR < (
|
||||
LEFTARG = base36,
|
||||
RIGHTARG = base36,
|
||||
PROCEDURE = base36_lt,
|
||||
COMMUTATOR = > ,
|
||||
NEGATOR = >= ,
|
||||
RESTRICT = scalarltsel,
|
||||
JOIN = scalarltjoinsel
|
||||
);
|
||||
COMMENT ON OPERATOR <(base36, base36) IS 'less-than';
|
||||
|
||||
CREATE OPERATOR <= (
|
||||
LEFTARG = base36,
|
||||
RIGHTARG = base36,
|
||||
PROCEDURE = base36_le,
|
||||
COMMUTATOR = >= ,
|
||||
NEGATOR = > ,
|
||||
RESTRICT = scalarltsel,
|
||||
JOIN = scalarltjoinsel
|
||||
);
|
||||
COMMENT ON OPERATOR <=(base36, base36) IS 'less-than-or-equal';
|
||||
|
||||
CREATE OPERATOR > (
|
||||
LEFTARG = base36,
|
||||
RIGHTARG = base36,
|
||||
PROCEDURE = base36_gt,
|
||||
COMMUTATOR = < ,
|
||||
NEGATOR = <= ,
|
||||
RESTRICT = scalargtsel,
|
||||
JOIN = scalargtjoinsel
|
||||
);
|
||||
COMMENT ON OPERATOR >(base36, base36) IS 'greater-than';
|
||||
|
||||
CREATE OPERATOR >= (
|
||||
LEFTARG = base36,
|
||||
RIGHTARG = base36,
|
||||
PROCEDURE = base36_ge,
|
||||
COMMUTATOR = <= ,
|
||||
NEGATOR = < ,
|
||||
RESTRICT = scalargtsel,
|
||||
JOIN = scalargtjoinsel
|
||||
);
|
||||
COMMENT ON OPERATOR >=(base36, base36) IS 'greater-than-or-equal';
|
||||
|
||||
CREATE OPERATOR CLASS btree_base36_ops
|
||||
DEFAULT FOR TYPE base36 USING btree
|
||||
AS
|
||||
OPERATOR 1 < ,
|
||||
OPERATOR 2 <= ,
|
||||
OPERATOR 3 = ,
|
||||
OPERATOR 4 >= ,
|
||||
OPERATOR 5 > ,
|
||||
FUNCTION 1 base36_cmp(base36, base36);
|
||||
|
||||
CREATE OPERATOR CLASS hash_base36_ops
|
||||
DEFAULT FOR TYPE base36 USING hash AS
|
||||
OPERATOR 1 = ,
|
||||
FUNCTION 1 hash_base36(base36);
|
||||
CREATE FUNCTION bigbase36_in(cstring)
|
||||
RETURNS bigbase36
|
||||
AS '$libdir/base36'
|
||||
LANGUAGE C IMMUTABLE STRICT;
|
||||
|
||||
CREATE FUNCTION bigbase36_out(bigbase36)
|
||||
RETURNS cstring
|
||||
AS '$libdir/base36'
|
||||
LANGUAGE C IMMUTABLE STRICT;
|
||||
|
||||
CREATE FUNCTION bigbase36_recv(internal)
|
||||
RETURNS bigbase36 LANGUAGE internal IMMUTABLE AS 'int8recv';
|
||||
|
||||
CREATE FUNCTION bigbase36_send(bigbase36)
|
||||
RETURNS bytea LANGUAGE internal IMMUTABLE AS 'int8send';
|
||||
|
||||
CREATE TYPE bigbase36 (
|
||||
INPUT = bigbase36_in,
|
||||
OUTPUT = bigbase36_out,
|
||||
RECEIVE = bigbase36_recv,
|
||||
SEND = bigbase36_send,
|
||||
LIKE = bigint,
|
||||
CATEGORY = 'N'
|
||||
);
|
||||
COMMENT ON TYPE bigbase36 IS 'bigint written in bigbase36: [0-9a-z]+';
|
||||
|
||||
CREATE FUNCTION bigbase36(text)
|
||||
RETURNS bigbase36
|
||||
AS '$libdir/base36', 'bigbase36_cast_from_text'
|
||||
LANGUAGE C IMMUTABLE STRICT;
|
||||
|
||||
CREATE FUNCTION text(bigbase36)
|
||||
RETURNS text
|
||||
AS '$libdir/base36', 'bigbase36_cast_to_text'
|
||||
LANGUAGE C IMMUTABLE STRICT;
|
||||
|
||||
CREATE CAST (text as bigbase36) WITH FUNCTION bigbase36(text) AS IMPLICIT;
|
||||
CREATE CAST (bigbase36 as text) WITH FUNCTION text(bigbase36);
|
||||
|
||||
CREATE CAST (bigint as bigbase36) WITHOUT FUNCTION AS IMPLICIT;
|
||||
CREATE CAST (bigbase36 as bigint) WITHOUT FUNCTION AS IMPLICIT;
|
||||
|
||||
CREATE FUNCTION bigbase36_eq(bigbase36, bigbase36)
|
||||
RETURNS boolean LANGUAGE internal IMMUTABLE AS 'int8eq';
|
||||
|
||||
CREATE FUNCTION bigbase36_ne(bigbase36, bigbase36)
|
||||
RETURNS boolean LANGUAGE internal IMMUTABLE AS 'int8ne';
|
||||
|
||||
CREATE FUNCTION bigbase36_lt(bigbase36, bigbase36)
|
||||
RETURNS boolean LANGUAGE internal IMMUTABLE AS 'int8lt';
|
||||
|
||||
CREATE FUNCTION bigbase36_le(bigbase36, bigbase36)
|
||||
RETURNS boolean LANGUAGE internal IMMUTABLE AS 'int8le';
|
||||
|
||||
CREATE FUNCTION bigbase36_gt(bigbase36, bigbase36)
|
||||
RETURNS boolean LANGUAGE internal IMMUTABLE AS 'int8gt';
|
||||
|
||||
CREATE FUNCTION bigbase36_ge(bigbase36, bigbase36)
|
||||
RETURNS boolean LANGUAGE internal IMMUTABLE AS 'int8ge';
|
||||
|
||||
CREATE FUNCTION bigbase36_cmp(bigbase36, bigbase36)
|
||||
RETURNS integer LANGUAGE internal IMMUTABLE AS 'btint8cmp';
|
||||
|
||||
CREATE FUNCTION hash_bigbase36(bigbase36)
|
||||
RETURNS integer LANGUAGE internal IMMUTABLE AS 'hashint8';
|
||||
|
||||
DO $$
|
||||
DECLARE version_num integer;
|
||||
BEGIN
|
||||
SELECT current_setting('server_version_num') INTO STRICT version_num;
|
||||
IF version_num > 90600 THEN
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_in(cstring) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_out(bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_recv(internal) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_send(bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36(text) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION text(bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_eq(bigbase36, bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_ne(bigbase36, bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_lt(bigbase36, bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_le(bigbase36, bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_gt(bigbase36, bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_ge(bigbase36, bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_cmp(bigbase36, bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION hash_bigbase36(bigbase36) PARALLEL SAFE $E$;
|
||||
END IF;
|
||||
END;
|
||||
$$;
|
||||
|
||||
CREATE OPERATOR = (
|
||||
LEFTARG = bigbase36,
|
||||
RIGHTARG = bigbase36,
|
||||
PROCEDURE = bigbase36_eq,
|
||||
COMMUTATOR = '=',
|
||||
NEGATOR = '<>',
|
||||
RESTRICT = eqsel,
|
||||
JOIN = eqjoinsel
|
||||
);
|
||||
COMMENT ON OPERATOR =(bigbase36, bigbase36) IS 'equals?';
|
||||
|
||||
CREATE OPERATOR <> (
|
||||
LEFTARG = bigbase36,
|
||||
RIGHTARG = bigbase36,
|
||||
PROCEDURE = bigbase36_ne,
|
||||
COMMUTATOR = '<>',
|
||||
NEGATOR = '=',
|
||||
RESTRICT = neqsel,
|
||||
JOIN = neqjoinsel
|
||||
);
|
||||
COMMENT ON OPERATOR <>(bigbase36, bigbase36) IS 'not equals?';
|
||||
|
||||
CREATE OPERATOR < (
|
||||
LEFTARG = bigbase36,
|
||||
RIGHTARG = bigbase36,
|
||||
PROCEDURE = bigbase36_lt,
|
||||
COMMUTATOR = > ,
|
||||
NEGATOR = >= ,
|
||||
RESTRICT = scalarltsel,
|
||||
JOIN = scalarltjoinsel
|
||||
);
|
||||
COMMENT ON OPERATOR <(bigbase36, bigbase36) IS 'less-than';
|
||||
|
||||
CREATE OPERATOR <= (
|
||||
LEFTARG = bigbase36,
|
||||
RIGHTARG = bigbase36,
|
||||
PROCEDURE = bigbase36_le,
|
||||
COMMUTATOR = >= ,
|
||||
NEGATOR = > ,
|
||||
RESTRICT = scalarltsel,
|
||||
JOIN = scalarltjoinsel
|
||||
);
|
||||
COMMENT ON OPERATOR <=(bigbase36, bigbase36) IS 'less-than-or-equal';
|
||||
|
||||
CREATE OPERATOR > (
|
||||
LEFTARG = bigbase36,
|
||||
RIGHTARG = bigbase36,
|
||||
PROCEDURE = bigbase36_gt,
|
||||
COMMUTATOR = < ,
|
||||
NEGATOR = <= ,
|
||||
RESTRICT = scalargtsel,
|
||||
JOIN = scalargtjoinsel
|
||||
);
|
||||
COMMENT ON OPERATOR >(bigbase36, bigbase36) IS 'greater-than';
|
||||
|
||||
CREATE OPERATOR >= (
|
||||
LEFTARG = bigbase36,
|
||||
RIGHTARG = bigbase36,
|
||||
PROCEDURE = bigbase36_ge,
|
||||
COMMUTATOR = <= ,
|
||||
NEGATOR = < ,
|
||||
RESTRICT = scalargtsel,
|
||||
JOIN = scalargtjoinsel
|
||||
);
|
||||
COMMENT ON OPERATOR >=(bigbase36, bigbase36) IS 'greater-than-or-equal';
|
||||
|
||||
CREATE OPERATOR CLASS btree_bigbase36_ops
|
||||
DEFAULT FOR TYPE bigbase36 USING btree
|
||||
AS
|
||||
OPERATOR 1 < ,
|
||||
OPERATOR 2 <= ,
|
||||
OPERATOR 3 = ,
|
||||
OPERATOR 4 >= ,
|
||||
OPERATOR 5 > ,
|
||||
FUNCTION 1 bigbase36_cmp(bigbase36, bigbase36);
|
||||
|
||||
CREATE OPERATOR CLASS hash_bigbase36_ops
|
||||
DEFAULT FOR TYPE bigbase36 USING hash AS
|
||||
OPERATOR 1 = ,
|
||||
FUNCTION 1 hash_bigbase36(bigbase36);
|
||||
@@ -1,5 +1,5 @@
|
||||
# base36 extension
|
||||
comment = 'my awesome extension'
|
||||
default_version = '0.0.1'
|
||||
comment = 'Integer Base36 types'
|
||||
default_version = '1.0.0'
|
||||
relocatable = true
|
||||
requires = ''
|
||||
|
||||
@@ -64,6 +64,29 @@ RETURNS integer LANGUAGE internal IMMUTABLE AS 'btint4cmp';
|
||||
CREATE FUNCTION hash_base36(base36)
|
||||
RETURNS integer LANGUAGE internal IMMUTABLE AS 'hashint4';
|
||||
|
||||
DO $$
|
||||
DECLARE version_num integer;
|
||||
BEGIN
|
||||
SELECT current_setting('server_version_num') INTO STRICT version_num;
|
||||
IF version_num > 90600 THEN
|
||||
EXECUTE $E$ ALTER FUNCTION base36_in(cstring) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_out(base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_recv(internal) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_send(base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36(text) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION text(base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_eq(base36, base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_ne(base36, base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_lt(base36, base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_le(base36, base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_gt(base36, base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_ge(base36, base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_cmp(base36, base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION hash_base36(base36) PARALLEL SAFE $E$;
|
||||
END IF;
|
||||
END;
|
||||
$$;
|
||||
|
||||
CREATE OPERATOR = (
|
||||
LEFTARG = base36,
|
||||
RIGHTARG = base36,
|
||||
|
||||
@@ -64,6 +64,29 @@ RETURNS integer LANGUAGE internal IMMUTABLE AS 'btint8cmp';
|
||||
CREATE FUNCTION hash_bigbase36(bigbase36)
|
||||
RETURNS integer LANGUAGE internal IMMUTABLE AS 'hashint8';
|
||||
|
||||
DO $$
|
||||
DECLARE version_num integer;
|
||||
BEGIN
|
||||
SELECT current_setting('server_version_num') INTO STRICT version_num;
|
||||
IF version_num > 90600 THEN
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_in(cstring) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_out(bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_recv(internal) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_send(bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36(text) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION text(bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_eq(bigbase36, bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_ne(bigbase36, bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_lt(bigbase36, bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_le(bigbase36, bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_gt(bigbase36, bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_ge(bigbase36, bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_cmp(bigbase36, bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION hash_bigbase36(bigbase36) PARALLEL SAFE $E$;
|
||||
END IF;
|
||||
END;
|
||||
$$;
|
||||
|
||||
CREATE OPERATOR = (
|
||||
LEFTARG = bigbase36,
|
||||
RIGHTARG = bigbase36,
|
||||
|
||||
47
sql/parallel.sql
Normal file
47
sql/parallel.sql
Normal file
@@ -0,0 +1,47 @@
|
||||
|
||||
DO $$
|
||||
DECLARE version_num integer;
|
||||
BEGIN
|
||||
SELECT current_setting('server_version_num') INTO STRICT version_num;
|
||||
IF version_num > 90600 THEN
|
||||
EXECUTE $E$ ALTER FUNCTION base36_in(cstring) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_out(base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_recv(internal) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_send(base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36(text) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION text(base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_eq(base36, base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_ne(base36, base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_lt(base36, base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_le(base36, base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_gt(base36, base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_ge(base36, base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION base36_cmp(base36, base36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION hash_base36(base36) PARALLEL SAFE $E$;
|
||||
END IF;
|
||||
END;
|
||||
$$;
|
||||
|
||||
DO $$
|
||||
DECLARE version_num integer;
|
||||
BEGIN
|
||||
SELECT current_setting('server_version_num') INTO STRICT version_num;
|
||||
IF version_num > 90600 THEN
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_in(cstring) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_out(bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_recv(internal) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_send(bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36(text) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION text(bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_eq(bigbase36, bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_ne(bigbase36, bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_lt(bigbase36, bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_le(bigbase36, bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_gt(bigbase36, bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_ge(bigbase36, bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION bigbase36_cmp(bigbase36, bigbase36) PARALLEL SAFE $E$;
|
||||
EXECUTE $E$ ALTER FUNCTION hash_bigbase36(bigbase36) PARALLEL SAFE $E$;
|
||||
END IF;
|
||||
END;
|
||||
$$;
|
||||
|
||||
Reference in New Issue
Block a user