Project

General

Profile

1 2094 aaronmk
--
2
-- PostgreSQL database dump
3
--
4
5
SET statement_timeout = 0;
6 11667 aaronmk
SET lock_timeout = 0;
7 2094 aaronmk
SET client_encoding = 'UTF8';
8 6213 aaronmk
SET standard_conforming_strings = on;
9 2094 aaronmk
SET check_function_bodies = false;
10
SET client_min_messages = warning;
11
12
--
13 8183 aaronmk
-- Name: util; Type: SCHEMA; Schema: -; Owner: -
14 2094 aaronmk
--
15
16 8183 aaronmk
CREATE SCHEMA util;
17 2094 aaronmk
18
19 4982 aaronmk
--
20 8183 aaronmk
-- Name: SCHEMA util; Type: COMMENT; Schema: -; Owner: -
21 4982 aaronmk
--
22
23 12235 aaronmk
COMMENT ON SCHEMA util IS '
24
IMPORTANT: Functions must always return NULL in place of '''' (the empty string). This ensures that empty strings do not find their way into VegBIEN.
25 4982 aaronmk
26 12447 aaronmk
NOTE: SQL-language functions should never be declared STRICT, because this prevents them from being inlined. inlining can create a significant speed improvement (7x+), by avoiding function calls and enabling additional constant folding. avoiding use of STRICT also makes functions *much* easier to troubleshoot, because they won''t mysteriously do nothing if called with only NULL arguments, even when you have added debug-print statements.
27 12235 aaronmk
';
28 4982 aaronmk
29 10378 aaronmk
30 8183 aaronmk
SET search_path = util, pg_catalog;
31 2107 aaronmk
32 2094 aaronmk
--
33 8183 aaronmk
-- Name: col_cast; Type: TYPE; Schema: util; Owner: -
34 8107 aaronmk
--
35
36
CREATE TYPE col_cast AS (
37
	col_name text,
38
	type regtype
39
);
40
41
42
--
43 8183 aaronmk
-- Name: col_ref; Type: TYPE; Schema: util; Owner: -
44 8106 aaronmk
--
45
46
CREATE TYPE col_ref AS (
47
	table_ regclass,
48
	name text
49
);
50
51
52
--
53 8183 aaronmk
-- Name: compass_dir; Type: TYPE; Schema: util; Owner: -
54 7673 aaronmk
--
55
56
CREATE TYPE compass_dir AS ENUM (
57
    'N',
58
    'E',
59
    'S',
60
    'W'
61
);
62
63
64
--
65 8183 aaronmk
-- Name: datatype; Type: TYPE; Schema: util; Owner: -
66 2610 aaronmk
--
67
68
CREATE TYPE datatype AS ENUM (
69
    'str',
70
    'float'
71
);
72
73
74
--
75 13491 aaronmk
-- Name: db_item; Type: TYPE; Schema: util; Owner: -
76
--
77
78
CREATE TYPE db_item AS (
79
	path text,
80
	def text
81
);
82
83
84
--
85 13488 aaronmk
-- Name: restore_views_info; Type: TYPE; Schema: util; Owner: -
86
--
87
88
CREATE TYPE restore_views_info AS (
89 13491 aaronmk
	views db_item[]
90 13488 aaronmk
);
91
92
93
--
94 12423 aaronmk
-- Name: %==(anyelement, anyelement); Type: FUNCTION; Schema: util; Owner: -
95
--
96
97
CREATE FUNCTION "%=="(left_ anyelement, right_ anyelement) RETURNS boolean
98 12443 aaronmk
    LANGUAGE sql STABLE
99 12423 aaronmk
    AS $_$
100 12436 aaronmk
SELECT keys($1) = keys($2)
101 12423 aaronmk
$_$;
102
103
104
--
105 12443 aaronmk
-- Name: FUNCTION "%=="(left_ anyelement, right_ anyelement); Type: COMMENT; Schema: util; Owner: -
106
--
107
108
COMMENT ON FUNCTION "%=="(left_ anyelement, right_ anyelement) IS '
109
needs to be declared STABLE instead of IMMUTABLE because it depends on the search_path (as described at http://vegpath.org/links/#PostgreSQL:%20Documentation:%209.3:%20Function%20Volatility%20Categories%20**)
110
';
111
112
113
--
114 8183 aaronmk
-- Name: _alt(anyelement, anyelement, anyelement, anyelement, anyelement, anyelement, anyelement, anyelement, anyelement, anyelement, anyelement, anyelement, anyelement); Type: FUNCTION; Schema: util; Owner: -
115 2596 aaronmk
--
116
117 4501 aaronmk
CREATE FUNCTION _alt("0" anyelement DEFAULT NULL::unknown, "1" anyelement DEFAULT NULL::unknown, "2" anyelement DEFAULT NULL::unknown, "3" anyelement DEFAULT NULL::unknown, "4" anyelement DEFAULT NULL::unknown, "5" anyelement DEFAULT NULL::unknown, "6" anyelement DEFAULT NULL::unknown, "7" anyelement DEFAULT NULL::unknown, "8" anyelement DEFAULT NULL::unknown, "9" anyelement DEFAULT NULL::unknown, "10" anyelement DEFAULT NULL::unknown, "11" anyelement DEFAULT NULL::unknown, "12" anyelement DEFAULT NULL::unknown) RETURNS anyelement
118 3422 aaronmk
    LANGUAGE sql IMMUTABLE
119
    AS $_$
120 4501 aaronmk
SELECT coalesce($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13)
121 3422 aaronmk
$_$;
122
123
124
--
125 8183 aaronmk
-- Name: _and(boolean, boolean, boolean, boolean, boolean); Type: FUNCTION; Schema: util; Owner: -
126 5937 aaronmk
--
127
128 5956 aaronmk
CREATE FUNCTION _and("0" boolean DEFAULT NULL::boolean, "1" boolean DEFAULT NULL::boolean, "2" boolean DEFAULT NULL::boolean, "3" boolean DEFAULT NULL::boolean, "4" boolean DEFAULT NULL::boolean) RETURNS boolean
129 5937 aaronmk
    LANGUAGE sql IMMUTABLE
130
    AS $_$
131
SELECT bool_and(value)
132
FROM
133
(VALUES
134
      ($1)
135
    , ($2)
136 5956 aaronmk
    , ($3)
137
    , ($4)
138
    , ($5)
139 5937 aaronmk
)
140
AS v (value)
141
$_$;
142
143
144
--
145 8183 aaronmk
-- Name: FUNCTION _and("0" boolean, "1" boolean, "2" boolean, "3" boolean, "4" boolean); Type: COMMENT; Schema: util; Owner: -
146 5937 aaronmk
--
147
148 12235 aaronmk
COMMENT ON FUNCTION _and("0" boolean, "1" boolean, "2" boolean, "3" boolean, "4" boolean) IS '
149
_and() ignores NULL values, while AND combines them with the other values to potentially convert true to NULL. AND should be used with required fields, and _and() with optional fields.
150
';
151 5937 aaronmk
152
153
--
154 8183 aaronmk
-- Name: _avg(double precision, double precision, double precision, double precision, double precision); Type: FUNCTION; Schema: util; Owner: -
155 7704 aaronmk
--
156
157
CREATE FUNCTION _avg("0" double precision DEFAULT NULL::double precision, "1" double precision DEFAULT NULL::double precision, "2" double precision DEFAULT NULL::double precision, "3" double precision DEFAULT NULL::double precision, "4" double precision DEFAULT NULL::double precision) RETURNS double precision
158
    LANGUAGE sql IMMUTABLE
159
    AS $_$
160
SELECT avg(value)
161
FROM
162
(VALUES
163
      ($1)
164
    , ($2)
165
    , ($3)
166
    , ($4)
167
    , ($5)
168
)
169
AS v (value)
170
$_$;
171
172
173
--
174 8183 aaronmk
-- Name: _dms_to_dd(text); Type: FUNCTION; Schema: util; Owner: -
175 7679 aaronmk
--
176
177
CREATE FUNCTION _dms_to_dd(value text DEFAULT NULL::text) RETURNS double precision
178 12441 aaronmk
    LANGUAGE sql IMMUTABLE
179 7679 aaronmk
    AS $_$
180 8183 aaronmk
SELECT (g[1]||'1')::integer*util._dms_to_dd(deg := g[2]::double precision, min := g[3]::double precision, sec := g[4]::double precision, dir := g[5]::util.compass_dir)
181 7698 aaronmk
FROM
182
(
183
    SELECT regexp_matches($1, '^ *(-?)(\d{1,3}(?:\.\d*)?)(?:(?:deg|[°º])(?: *([\d.]+)(?:min|[''’]))?(?: *([\d.]+)(?:sec|["”]))?)? *([NESW])? *$')
184
    UNION ALL
185 7702 aaronmk
    SELECT ARRAY[g[1], g[2], g[3]||'.'||g[4], NULL, g[5]]
186
    FROM regexp_matches($1, '^ *(-?)(\d{2,3})(\d{2})(\d{3}) *([NESW])? *$') matches (g) -- [D]DDMMmmm, where MMmmm = MM.mmm
187 7698 aaronmk
)
188
matches (g)
189 7679 aaronmk
$_$;
190
191
192
--
193 8183 aaronmk
-- Name: _dms_to_dd(double precision, double precision, double precision, compass_dir); Type: FUNCTION; Schema: util; Owner: -
194 7672 aaronmk
--
195
196 7674 aaronmk
CREATE FUNCTION _dms_to_dd(deg double precision DEFAULT NULL::double precision, min double precision DEFAULT NULL::double precision, sec double precision DEFAULT NULL::double precision, dir compass_dir DEFAULT NULL::compass_dir) RETURNS double precision
197 7672 aaronmk
    LANGUAGE sql IMMUTABLE
198
    AS $_$
199 8183 aaronmk
SELECT sum(value)*COALESCE(util._map('N=>1,E=>1,S=>-1,W=>-1', $4::text)::integer, 1)
200 7672 aaronmk
FROM
201
(VALUES
202 7677 aaronmk
      ($1)
203 7672 aaronmk
    , ($2/60)
204
    , ($3/60/60)
205
)
206
AS v (value)
207
$_$;
208
209
210
--
211 8183 aaronmk
-- Name: _dms_to_dd(text, text, text, text); Type: FUNCTION; Schema: util; Owner: -
212 7723 aaronmk
--
213
214
CREATE FUNCTION _dms_to_dd(deg text DEFAULT NULL::text, min text DEFAULT NULL::text, sec text DEFAULT NULL::text, dir text DEFAULT NULL::text) RETURNS double precision
215
    LANGUAGE sql IMMUTABLE
216
    AS $_$
217 8183 aaronmk
SELECT util._dms_to_dd($1::double precision, $2::double precision, $3::double precision, $4::util.compass_dir)
218 7723 aaronmk
$_$;
219
220
221
--
222 8183 aaronmk
-- Name: _eq(anyelement, anyelement); Type: FUNCTION; Schema: util; Owner: -
223 4142 aaronmk
--
224
225
CREATE FUNCTION _eq("left" anyelement DEFAULT NULL::unknown, "right" anyelement DEFAULT NULL::unknown) RETURNS boolean
226
    LANGUAGE sql IMMUTABLE
227
    AS $_$
228
SELECT $1 = $2
229
$_$;
230
231
232
--
233 8183 aaronmk
-- Name: _fix_date(date, date); Type: FUNCTION; Schema: util; Owner: -
234 7396 aaronmk
--
235
236
CREATE FUNCTION _fix_date(value date DEFAULT NULL::date, threshold date DEFAULT NULL::date) RETURNS date
237
    LANGUAGE sql IMMUTABLE
238
    AS $_$
239
-- Fix dates after threshold date
240
-- This fixes e.g. 2-digit years before 1970 misinterpreted as 20xx
241
SELECT (CASE WHEN $1 > COALESCE($2, now()) THEN ($1 - '100 years'::interval)::date ELSE $1 END)
242
$_$;
243
244
245
--
246 8183 aaronmk
-- Name: _if(boolean, anyelement, anyelement); Type: FUNCTION; Schema: util; Owner: -
247 4147 aaronmk
--
248
249
CREATE FUNCTION _if(cond boolean DEFAULT NULL::boolean, "then" anyelement DEFAULT NULL::unknown, "else" anyelement DEFAULT NULL::unknown) RETURNS anyelement
250
    LANGUAGE sql IMMUTABLE
251
    AS $_$
252
SELECT (CASE WHEN $1 THEN $2 ELSE $3 END)
253
$_$;
254
255
256
--
257 8183 aaronmk
-- Name: _if(text, anyelement, anyelement); Type: FUNCTION; Schema: util; Owner: -
258 4147 aaronmk
--
259
260
CREATE FUNCTION _if(cond text DEFAULT NULL::text, "then" anyelement DEFAULT NULL::unknown, "else" anyelement DEFAULT NULL::unknown) RETURNS anyelement
261
    LANGUAGE sql IMMUTABLE
262
    AS $_$
263 8183 aaronmk
SELECT util._if($1 != '', $2, $3)
264 4147 aaronmk
$_$;
265
266
267
--
268 10699 aaronmk
-- Name: _join(text, text, text, text, text, text, text, text, text, text); Type: FUNCTION; Schema: util; Owner: -
269 4325 aaronmk
--
270
271 10699 aaronmk
CREATE FUNCTION _join("0" text DEFAULT NULL::text, "1" text DEFAULT NULL::text, "2" text DEFAULT NULL::text, "3" text DEFAULT NULL::text, "4" text DEFAULT NULL::text, "5" text DEFAULT NULL::text, "6" text DEFAULT NULL::text, "7" text DEFAULT NULL::text, "8" text DEFAULT NULL::text, "9" text DEFAULT NULL::text) RETURNS text
272 4325 aaronmk
    LANGUAGE sql IMMUTABLE
273
    AS $_$
274 7848 aaronmk
SELECT NULLIF(concat_ws('; ', $1, $2, $3, $4, $5, $6, $7, $8, $9, $10), '')
275 4325 aaronmk
$_$;
276
277
278
--
279 10699 aaronmk
-- Name: _join_words(text, text, text, text, text, text, text, text, text, text); Type: FUNCTION; Schema: util; Owner: -
280 5009 aaronmk
--
281
282 10699 aaronmk
CREATE FUNCTION _join_words("0" text DEFAULT NULL::text, "1" text DEFAULT NULL::text, "2" text DEFAULT NULL::text, "3" text DEFAULT NULL::text, "4" text DEFAULT NULL::text, "5" text DEFAULT NULL::text, "6" text DEFAULT NULL::text, "7" text DEFAULT NULL::text, "8" text DEFAULT NULL::text, "9" text DEFAULT NULL::text) RETURNS text
283 5009 aaronmk
    LANGUAGE sql IMMUTABLE
284
    AS $_$
285 7848 aaronmk
SELECT NULLIF(concat_ws(' ', $1, $2, $3, $4, $5, $6, $7, $8, $9, $10), '')
286 5009 aaronmk
$_$;
287
288
289
--
290 13355 aaronmk
-- Name: _km_to_m(double precision); Type: FUNCTION; Schema: util; Owner: -
291
--
292
293
CREATE FUNCTION _km_to_m(value double precision) RETURNS double precision
294
    LANGUAGE sql IMMUTABLE
295
    AS $_$
296
SELECT $1*1000.
297
$_$;
298
299
300
--
301 10699 aaronmk
-- Name: _label(text, text); Type: FUNCTION; Schema: util; Owner: -
302 3422 aaronmk
--
303
304 10699 aaronmk
CREATE FUNCTION _label(label text, value text) RETURNS text
305 4682 aaronmk
    LANGUAGE sql IMMUTABLE
306
    AS $_$
307
SELECT coalesce($1 || ': ', '') || $2
308
$_$;
309 2596 aaronmk
310
311
--
312 8825 aaronmk
-- Name: _lowercase(text); Type: FUNCTION; Schema: util; Owner: -
313
--
314
315
CREATE FUNCTION _lowercase(value text) RETURNS text
316 10388 aaronmk
    LANGUAGE sql IMMUTABLE
317 8825 aaronmk
    AS $_$
318
SELECT lower($1)
319
$_$;
320
321
322
--
323 11667 aaronmk
-- Name: _map(hstore, anyelement); Type: FUNCTION; Schema: util; Owner: -
324
--
325
326
CREATE FUNCTION _map(map hstore, value anyelement) RETURNS anyelement
327
    LANGUAGE plpgsql IMMUTABLE STRICT
328
    AS $$
329
DECLARE
330
    result value%TYPE := util._map(map, value::text)::unknown;
331
BEGIN
332
    RETURN result;
333
END;
334
$$;
335
336
337
--
338 8183 aaronmk
-- Name: _map(hstore, text); Type: FUNCTION; Schema: util; Owner: -
339 6222 aaronmk
--
340
341
CREATE FUNCTION _map(map hstore, value text) RETURNS text
342 7820 aaronmk
    LANGUAGE plpgsql IMMUTABLE STRICT
343 6222 aaronmk
    AS $$
344
DECLARE
345 6271 aaronmk
    match text := map -> value;
346 6222 aaronmk
BEGIN
347 6271 aaronmk
    IF match IS NULL AND NOT map ? value THEN -- no match rather than NULL match
348
        match := map -> '*'; -- use default entry
349
        IF match IS NULL AND NOT map ? '*' THEN match := '!'; -- no default
350
        END IF;
351
    END IF;
352
353
    -- Interpret result
354 6243 aaronmk
    IF match = '!' THEN RAISE 'Value not in map: %', value USING ERRCODE = 'data_exception';
355
    ELSIF match = '*' THEN RETURN value;
356
    ELSE RETURN match;
357 6222 aaronmk
    END IF;
358
END;
359
$$;
360
361
362
--
363 8183 aaronmk
-- Name: _max(anyelement, anyelement, anyelement, anyelement, anyelement, anyelement, anyelement, anyelement, anyelement, anyelement); Type: FUNCTION; Schema: util; Owner: -
364 5408 aaronmk
--
365
366
CREATE FUNCTION _max("0" anyelement DEFAULT NULL::unknown, "1" anyelement DEFAULT NULL::unknown, "2" anyelement DEFAULT NULL::unknown, "3" anyelement DEFAULT NULL::unknown, "4" anyelement DEFAULT NULL::unknown, "5" anyelement DEFAULT NULL::unknown, "6" anyelement DEFAULT NULL::unknown, "7" anyelement DEFAULT NULL::unknown, "8" anyelement DEFAULT NULL::unknown, "9" anyelement DEFAULT NULL::unknown) RETURNS anyelement
367
    LANGUAGE sql IMMUTABLE
368
    AS $_$
369 7289 aaronmk
SELECT GREATEST($1, $2, $3, $4, $5, $6, $7, $8, $9, $10)
370 5408 aaronmk
$_$;
371
372
373
--
374 8183 aaronmk
-- Name: _merge(anyelement, anyelement, anyelement, anyelement, anyelement, anyelement, anyelement, anyelement, anyelement, anyelement); Type: FUNCTION; Schema: util; Owner: -
375 2940 aaronmk
--
376
377 4150 aaronmk
CREATE FUNCTION _merge("0" anyelement DEFAULT NULL::unknown, "1" anyelement DEFAULT NULL::unknown, "2" anyelement DEFAULT NULL::unknown, "3" anyelement DEFAULT NULL::unknown, "4" anyelement DEFAULT NULL::unknown, "5" anyelement DEFAULT NULL::unknown, "6" anyelement DEFAULT NULL::unknown, "7" anyelement DEFAULT NULL::unknown, "8" anyelement DEFAULT NULL::unknown, "9" anyelement DEFAULT NULL::unknown) RETURNS anyelement
378 2940 aaronmk
    LANGUAGE sql IMMUTABLE
379
    AS $_$
380 8183 aaronmk
SELECT util.join_strs(value, '; ')
381 2940 aaronmk
FROM
382
(
383
    SELECT *
384
    FROM
385
    (
386
        SELECT
387
        DISTINCT ON (value)
388
        *
389
        FROM
390
        (VALUES
391 4012 aaronmk
              (1, $1)
392
            , (2, $2)
393
            , (3, $3)
394
            , (4, $4)
395
            , (5, $5)
396
            , (6, $6)
397
            , (7, $7)
398
            , (8, $8)
399
            , (9, $9)
400
            , (10, $10)
401 2940 aaronmk
        )
402
        AS v (sort_order, value)
403 4011 aaronmk
        WHERE value IS NOT NULL
404 2940 aaronmk
    )
405
    AS v
406
    ORDER BY sort_order
407
)
408
AS v
409
$_$;
410
411
412
--
413 8183 aaronmk
-- Name: _merge_prefix(text, text); Type: FUNCTION; Schema: util; Owner: -
414 7140 aaronmk
--
415
416
CREATE FUNCTION _merge_prefix(prefix text DEFAULT NULL::text, value text DEFAULT NULL::text) RETURNS text
417
    LANGUAGE sql IMMUTABLE
418
    AS $_$
419
SELECT _join_words((CASE WHEN $2 ~ ('^'||$1||E'\\y') THEN NULL ELSE $1 END), $2)
420
$_$;
421
422
423
--
424 8183 aaronmk
-- Name: _merge_words(anyelement, anyelement, anyelement, anyelement, anyelement, anyelement, anyelement, anyelement, anyelement, anyelement); Type: FUNCTION; Schema: util; Owner: -
425 6354 aaronmk
--
426
427
CREATE FUNCTION _merge_words("0" anyelement DEFAULT NULL::unknown, "1" anyelement DEFAULT NULL::unknown, "2" anyelement DEFAULT NULL::unknown, "3" anyelement DEFAULT NULL::unknown, "4" anyelement DEFAULT NULL::unknown, "5" anyelement DEFAULT NULL::unknown, "6" anyelement DEFAULT NULL::unknown, "7" anyelement DEFAULT NULL::unknown, "8" anyelement DEFAULT NULL::unknown, "9" anyelement DEFAULT NULL::unknown) RETURNS anyelement
428
    LANGUAGE sql IMMUTABLE
429
    AS $_$
430 8183 aaronmk
SELECT util.join_strs(value, ' ')
431 6354 aaronmk
FROM
432
(
433
    SELECT *
434
    FROM
435
    (
436
        SELECT
437
        DISTINCT ON (value)
438
        *
439
        FROM
440
        (VALUES
441
              (1, $1)
442
            , (2, $2)
443
            , (3, $3)
444
            , (4, $4)
445
            , (5, $5)
446
            , (6, $6)
447
            , (7, $7)
448
            , (8, $8)
449
            , (9, $9)
450
            , (10, $10)
451
        )
452
        AS v (sort_order, value)
453
        WHERE value IS NOT NULL
454
    )
455
    AS v
456
    ORDER BY sort_order
457
)
458
AS v
459
$_$;
460
461
462
--
463 8183 aaronmk
-- Name: _min(anyelement, anyelement, anyelement, anyelement, anyelement, anyelement, anyelement, anyelement, anyelement, anyelement); Type: FUNCTION; Schema: util; Owner: -
464 5408 aaronmk
--
465
466
CREATE FUNCTION _min("0" anyelement DEFAULT NULL::unknown, "1" anyelement DEFAULT NULL::unknown, "2" anyelement DEFAULT NULL::unknown, "3" anyelement DEFAULT NULL::unknown, "4" anyelement DEFAULT NULL::unknown, "5" anyelement DEFAULT NULL::unknown, "6" anyelement DEFAULT NULL::unknown, "7" anyelement DEFAULT NULL::unknown, "8" anyelement DEFAULT NULL::unknown, "9" anyelement DEFAULT NULL::unknown) RETURNS anyelement
467
    LANGUAGE sql IMMUTABLE
468
    AS $_$
469 7289 aaronmk
SELECT LEAST($1, $2, $3, $4, $5, $6, $7, $8, $9, $10)
470 5408 aaronmk
$_$;
471
472
473
--
474 8183 aaronmk
-- Name: _not(boolean); Type: FUNCTION; Schema: util; Owner: -
475 6316 aaronmk
--
476
477
CREATE FUNCTION _not(value boolean) RETURNS boolean
478 10388 aaronmk
    LANGUAGE sql IMMUTABLE
479 6316 aaronmk
    AS $_$
480
SELECT NOT $1
481
$_$;
482
483
484
--
485 8183 aaronmk
-- Name: _now(); Type: FUNCTION; Schema: util; Owner: -
486 7104 aaronmk
--
487
488
CREATE FUNCTION _now() RETURNS timestamp with time zone
489
    LANGUAGE sql STABLE
490
    AS $$
491
SELECT now()
492
$$;
493
494
495
--
496 11667 aaronmk
-- Name: _nullIf(anyelement, text, text); Type: FUNCTION; Schema: util; Owner: -
497
--
498
499
CREATE FUNCTION "_nullIf"(value anyelement, "null" text, type text) RETURNS anyelement
500
    LANGUAGE sql IMMUTABLE
501
    AS $_$
502
SELECT util."_nullIf"($1, $2, $3::util.datatype)
503
$_$;
504
505
506
--
507 8183 aaronmk
-- Name: _nullIf(anyelement, text, datatype); Type: FUNCTION; Schema: util; Owner: -
508 2949 aaronmk
--
509
510 4475 aaronmk
CREATE FUNCTION "_nullIf"(value anyelement, "null" text, type datatype DEFAULT 'str'::datatype) RETURNS anyelement
511 2949 aaronmk
    LANGUAGE plpgsql IMMUTABLE
512
    AS $$
513
DECLARE
514 8183 aaronmk
    type util.datatype NOT NULL := type; -- add NOT NULL
515 2949 aaronmk
BEGIN
516 4475 aaronmk
    IF type = 'str' THEN RETURN nullif(value::text, "null");
517 2722 aaronmk
    -- Invalid value is ignored, but invalid null value generates error
518 2949 aaronmk
    ELSIF type = 'float' THEN
519 2722 aaronmk
        DECLARE
520
            -- Outside the try block so that invalid null value generates error
521 2949 aaronmk
            "null" double precision := "null"::double precision;
522 2722 aaronmk
        BEGIN
523 2949 aaronmk
            RETURN nullif(value::double precision, "null");
524 2722 aaronmk
        EXCEPTION
525 2949 aaronmk
            WHEN data_exception THEN RETURN value; -- ignore invalid value
526 2722 aaronmk
        END;
527 2610 aaronmk
    END IF;
528
END;
529
$$;
530
531
532
--
533 8183 aaronmk
-- Name: _or(boolean, boolean, boolean, boolean, boolean); Type: FUNCTION; Schema: util; Owner: -
534 6355 aaronmk
--
535
536
CREATE FUNCTION _or("0" boolean DEFAULT NULL::boolean, "1" boolean DEFAULT NULL::boolean, "2" boolean DEFAULT NULL::boolean, "3" boolean DEFAULT NULL::boolean, "4" boolean DEFAULT NULL::boolean) RETURNS boolean
537
    LANGUAGE sql IMMUTABLE
538
    AS $_$
539
SELECT bool_or(value)
540
FROM
541
(VALUES
542
      ($1)
543
    , ($2)
544
    , ($3)
545
    , ($4)
546
    , ($5)
547
)
548
AS v (value)
549
$_$;
550
551
552
--
553 8183 aaronmk
-- Name: FUNCTION _or("0" boolean, "1" boolean, "2" boolean, "3" boolean, "4" boolean); Type: COMMENT; Schema: util; Owner: -
554 6437 aaronmk
--
555
556 12235 aaronmk
COMMENT ON FUNCTION _or("0" boolean, "1" boolean, "2" boolean, "3" boolean, "4" boolean) IS '
557
_or() ignores NULL values, while OR combines them with the other values to potentially convert false to NULL. OR should be used with required fields, and _or() with optional fields.
558
';
559 6437 aaronmk
560
561
--
562 8183 aaronmk
-- Name: _range(double precision, double precision); Type: FUNCTION; Schema: util; Owner: -
563 7706 aaronmk
--
564
565
CREATE FUNCTION _range("from" double precision DEFAULT NULL::double precision, "to" double precision DEFAULT NULL::double precision) RETURNS double precision
566
    LANGUAGE sql IMMUTABLE
567
    AS $_$
568
SELECT $2 - $1
569
$_$;
570
571
572
--
573 8183 aaronmk
-- Name: _split(text, text); Type: FUNCTION; Schema: util; Owner: -
574 6793 aaronmk
--
575
576
CREATE FUNCTION _split(value text DEFAULT NULL::text, separator text DEFAULT '; '::text) RETURNS SETOF text
577 10388 aaronmk
    LANGUAGE sql IMMUTABLE
578 6793 aaronmk
    AS $_$
579
SELECT regexp_split_to_table($1, $2)
580
$_$;
581
582
583
--
584 10594 aaronmk
-- Name: added_cols(regclass, regclass); Type: FUNCTION; Schema: util; Owner: -
585
--
586
587
CREATE FUNCTION added_cols(table_ regclass, names regclass) RETURNS SETOF text
588 12446 aaronmk
    LANGUAGE sql STABLE
589 10594 aaronmk
    AS $_$
590
SELECT util.derived_cols($1, $2)
591
UNION
592
SELECT util.eval2set($$
593
SELECT col
594
FROM util.col_names($$||quote_nullable($1)||$$::regclass) f (col)
595
JOIN $$||$2||$$ ON "to" = col
596
WHERE "from" LIKE ':%'
597
$$, NULL::text)
598
$_$;
599
600
601
--
602
-- Name: FUNCTION added_cols(table_ regclass, names regclass); Type: COMMENT; Schema: util; Owner: -
603
--
604
605 12235 aaronmk
COMMENT ON FUNCTION added_cols(table_ regclass, names regclass) IS '
606
gets table_''s added columns (all the columns not in the original data)
607
';
608 10594 aaronmk
609
610
--
611 9959 aaronmk
-- Name: all_same_final(anyarray); Type: FUNCTION; Schema: util; Owner: -
612
--
613
614
CREATE FUNCTION all_same_final(state anyarray) RETURNS boolean
615
    LANGUAGE sql IMMUTABLE
616
    AS $_$
617
SELECT $1 IS NULL/*no rows*/ OR util.not_empty($1)/*not no_match_sentinel*/
618
$_$;
619
620
621
--
622
-- Name: all_same_transform(anyarray, anyelement); Type: FUNCTION; Schema: util; Owner: -
623
--
624
625
CREATE FUNCTION all_same_transform(state anyarray, value anyelement) RETURNS anyarray
626
    LANGUAGE plpgsql IMMUTABLE
627
    AS $$
628
DECLARE
629
	value_cmp         state%TYPE = ARRAY[value];
630
	state             state%TYPE = COALESCE(state, value_cmp);
631
	no_match_sentinel state%TYPE = value_cmp[1:0]/*=ARRAY[]::state%TYPE*/;
632
BEGIN
633
	RETURN (CASE WHEN value_cmp IS NOT DISTINCT FROM state THEN state ELSE no_match_sentinel END);
634
END;
635
$$;
636
637
638
--
639 12320 aaronmk
-- Name: analyze_(regclass); Type: FUNCTION; Schema: util; Owner: -
640
--
641
642
CREATE FUNCTION analyze_(table_ regclass) RETURNS void
643
    LANGUAGE sql
644
    AS $_$
645
SELECT util.eval($$ANALYZE VERBOSE $$||$1)
646
$_$;
647
648
649
--
650 12369 aaronmk
-- Name: append_comment(regclass, text); Type: FUNCTION; Schema: util; Owner: -
651
--
652
653
CREATE FUNCTION append_comment(table_ regclass, comment text) RETURNS void
654 12446 aaronmk
    LANGUAGE sql
655 12369 aaronmk
    AS $_$
656
SELECT util.set_comment($1, concat(util.comment($1), $2))
657
$_$;
658
659
660
--
661
-- Name: FUNCTION append_comment(table_ regclass, comment text); Type: COMMENT; Schema: util; Owner: -
662
--
663
664
COMMENT ON FUNCTION append_comment(table_ regclass, comment text) IS '
665
comment: must start and end with a newline
666
';
667
668
669
--
670 10305 aaronmk
-- Name: array_fill(anyelement, integer); Type: FUNCTION; Schema: util; Owner: -
671
--
672
673
CREATE FUNCTION array_fill(value anyelement, length integer) RETURNS anyarray
674
    LANGUAGE sql IMMUTABLE
675
    AS $_$
676
SELECT pg_catalog.array_fill($1, ARRAY[$2])
677
$_$;
678
679
680
--
681 10303 aaronmk
-- Name: array_length(anyarray); Type: FUNCTION; Schema: util; Owner: -
682
--
683
684
CREATE FUNCTION array_length("array" anyarray) RETURNS integer
685 10354 aaronmk
    LANGUAGE sql IMMUTABLE
686 10303 aaronmk
    AS $_$
687 10321 aaronmk
SELECT util.array_length($1, 1)
688 10303 aaronmk
$_$;
689
690
691
--
692 10304 aaronmk
-- Name: array_length(anyarray, integer); Type: FUNCTION; Schema: util; Owner: -
693
--
694
695
CREATE FUNCTION array_length("array" anyarray, dimension integer) RETURNS integer
696 10354 aaronmk
    LANGUAGE sql IMMUTABLE
697 10304 aaronmk
    AS $_$
698 10354 aaronmk
SELECT CASE WHEN $1 IS NULL THEN NULL ELSE COALESCE(pg_catalog.array_length($1, $2), 0) END
699 10304 aaronmk
$_$;
700
701
702
--
703
-- Name: FUNCTION array_length("array" anyarray, dimension integer); Type: COMMENT; Schema: util; Owner: -
704
--
705
706 12235 aaronmk
COMMENT ON FUNCTION array_length("array" anyarray, dimension integer) IS '
707
returns 0 instead of NULL for empty arrays
708
';
709 10304 aaronmk
710
711
--
712 13453 aaronmk
-- Name: array_reverse(anyarray); Type: FUNCTION; Schema: util; Owner: -
713
--
714
715
CREATE FUNCTION array_reverse("array" anyarray) RETURNS anyarray
716
    LANGUAGE sql IMMUTABLE
717
    AS $_$
718 13489 aaronmk
SELECT array(SELECT elem FROM util.in_reverse($1) elem)
719 13453 aaronmk
$_$;
720
721
722
--
723 12662 aaronmk
-- Name: auto_rm_freq(regclass[], text); Type: FUNCTION; Schema: util; Owner: -
724 12655 aaronmk
--
725
726 12662 aaronmk
CREATE FUNCTION auto_rm_freq(tables regclass[], freq_col text DEFAULT 'copies'::text) RETURNS void
727 12655 aaronmk
    LANGUAGE sql
728
    AS $_$
729 12662 aaronmk
SELECT CASE WHEN util.freq_always_1($1, $2)
730 13097 aaronmk
THEN util.rm_freq($1, $2)
731 12685 aaronmk
ELSE util.try_create($$ALTER TABLE $$||util.parent($1[1])||$$ ADD COLUMN $$||quote_ident($2)||$$ bigint NOT NULL$$)
732 12662 aaronmk
END
733 12655 aaronmk
$_$;
734
735
736
--
737 13134 aaronmk
-- Name: cast(text, anyelement); Type: FUNCTION; Schema: util; Owner: -
738
--
739
740
CREATE FUNCTION "cast"(value text, ret_type_null anyelement) RETURNS anyelement
741
    LANGUAGE plpgsql IMMUTABLE
742
    AS $$
743
/* must use LANGUAGE plpgsql because LANGUAGE sql does not assignment-cast the
744
return value, causing a type mismatch */
745
BEGIN
746
	-- will then be assignment-cast to return type via INOUT
747
	RETURN value::cstring;
748
END;
749
$$;
750
751
752
--
753
-- Name: FUNCTION "cast"(value text, ret_type_null anyelement); Type: COMMENT; Schema: util; Owner: -
754
--
755
756
COMMENT ON FUNCTION "cast"(value text, ret_type_null anyelement) IS '
757
allows casting to an arbitrary type without eval()
758
759
usage:
760
SELECT util.cast(''value'', NULL::integer);
761
762
note that there does *not* need to be a cast from text to the output type,
763
because an INOUT cast is used instead
764
(http://www.postgresql.org/docs/9.3/static/sql-createcast.html#AEN69507)
765
766
ret_type_null: NULL::ret_type
767
';
768
769
770
--
771 8183 aaronmk
-- Name: cluster_index(regclass); Type: FUNCTION; Schema: util; Owner: -
772 8104 aaronmk
--
773
774
CREATE FUNCTION cluster_index(table_ regclass) RETURNS regclass
775 12446 aaronmk
    LANGUAGE sql STABLE
776 8104 aaronmk
    AS $_$
777
SELECT indexrelid FROM pg_index WHERE indrelid = $1 AND indisclustered
778
$_$;
779
780
781
--
782 8183 aaronmk
-- Name: cluster_once(regclass, regclass); Type: FUNCTION; Schema: util; Owner: -
783 8105 aaronmk
--
784
785
CREATE FUNCTION cluster_once(table_ regclass, index regclass) RETURNS void
786
    LANGUAGE plpgsql STRICT
787
    AS $_$
788
BEGIN
789
    -- not yet clustered (ARRAY[] compares NULLs literally)
790 8183 aaronmk
    IF ARRAY[util.cluster_index(table_)] != ARRAY[index] THEN
791 8105 aaronmk
        EXECUTE $$CLUSTER $$||table_||$$ USING $$||index;
792
    END IF;
793
END;
794
$_$;
795
796
797
--
798 8183 aaronmk
-- Name: FUNCTION cluster_once(table_ regclass, index regclass); Type: COMMENT; Schema: util; Owner: -
799 8105 aaronmk
--
800
801 12235 aaronmk
COMMENT ON FUNCTION cluster_once(table_ regclass, index regclass) IS '
802
idempotent
803
';
804 8105 aaronmk
805
806
--
807 12683 aaronmk
-- Name: coalesce(anyarray); Type: FUNCTION; Schema: util; Owner: -
808
--
809
810
CREATE FUNCTION "coalesce"(VARIADIC values_ anyarray) RETURNS anyelement
811
    LANGUAGE sql IMMUTABLE
812
    AS $_$
813
SELECT value
814
FROM unnest($1) value
815
WHERE value IS NOT NULL
816
LIMIT 1
817
$_$;
818
819
820
--
821
-- Name: FUNCTION "coalesce"(VARIADIC values_ anyarray); Type: COMMENT; Schema: util; Owner: -
822
--
823
824
COMMENT ON FUNCTION "coalesce"(VARIADIC values_ anyarray) IS '
825
uses:
826
* coalescing array elements or rows together
827
* forcing evaluation of all values of a COALESCE()
828
';
829
830
831
--
832 10986 aaronmk
-- Name: col__min(col_ref); Type: FUNCTION; Schema: util; Owner: -
833
--
834
835
CREATE FUNCTION col__min(col col_ref) RETURNS integer
836
    LANGUAGE sql STABLE
837
    AS $_$
838
SELECT util.eval2val($$
839
SELECT $$||quote_ident($1.name)||$$
840
FROM $$||$1.table_||$$
841
ORDER BY $$||quote_ident($1.name)||$$ ASC
842
LIMIT 1
843
$$, NULL::integer)
844
$_$;
845
846
847
--
848 10136 aaronmk
-- Name: col_comment(col_ref); Type: FUNCTION; Schema: util; Owner: -
849
--
850
851
CREATE FUNCTION col_comment(col col_ref) RETURNS text
852
    LANGUAGE plpgsql STABLE STRICT
853
    AS $$
854
DECLARE
855
	comment text;
856
BEGIN
857
	SELECT description
858
	FROM pg_attribute
859
	LEFT JOIN pg_description ON objoid = attrelid
860
		AND classoid = 'pg_class'::regclass AND objsubid = attnum
861
	WHERE attrelid = col.table_ AND attname = col.name
862
	INTO STRICT comment
863
	;
864
	RETURN comment;
865
EXCEPTION
866
	WHEN no_data_found THEN PERFORM util.raise_undefined_column(col);
867
END;
868
$$;
869
870
871
--
872 10130 aaronmk
-- Name: col_default_sql(col_ref); Type: FUNCTION; Schema: util; Owner: -
873
--
874
875
CREATE FUNCTION col_default_sql(col col_ref) RETURNS text
876
    LANGUAGE plpgsql STABLE STRICT
877
    AS $$
878
DECLARE
879
	default_sql text;
880
BEGIN
881
	SELECT adsrc
882
	FROM pg_attribute
883
	LEFT JOIN pg_attrdef ON adrelid = attrelid AND adnum = attnum
884
	WHERE attrelid = col.table_ AND attname = col.name
885
	INTO STRICT default_sql
886
	;
887
	RETURN default_sql;
888
EXCEPTION
889
	WHEN no_data_found THEN PERFORM util.raise_undefined_column(col);
890
END;
891
$$;
892
893
894
--
895 10134 aaronmk
-- Name: col_default_value(col_ref, anyelement); Type: FUNCTION; Schema: util; Owner: -
896
--
897
898
CREATE FUNCTION col_default_value(col col_ref, ret_type_null anyelement DEFAULT NULL::text) RETURNS anyelement
899
    LANGUAGE sql STABLE
900
    AS $_$
901
SELECT util.eval_expr_passthru(util.col_default_sql($1), $2)
902
$_$;
903
904
905
--
906
-- Name: FUNCTION col_default_value(col col_ref, ret_type_null anyelement); Type: COMMENT; Schema: util; Owner: -
907
--
908
909 12235 aaronmk
COMMENT ON FUNCTION col_default_value(col col_ref, ret_type_null anyelement) IS '
910
ret_type_null: NULL::ret_type
911
';
912 10134 aaronmk
913
914
--
915 8183 aaronmk
-- Name: col_exists(col_ref); Type: FUNCTION; Schema: util; Owner: -
916 8180 aaronmk
--
917
918
CREATE FUNCTION col_exists(col col_ref) RETURNS boolean
919
    LANGUAGE plpgsql STRICT
920
    AS $$
921
BEGIN
922 8183 aaronmk
    PERFORM util.col_type(col);
923 8180 aaronmk
    RETURN true;
924
EXCEPTION
925
    WHEN undefined_column THEN RETURN false;
926
END;
927
$$;
928
929
930
--
931 8183 aaronmk
-- Name: col_global_names(regtype); Type: FUNCTION; Schema: util; Owner: -
932 8084 aaronmk
--
933
934
CREATE FUNCTION col_global_names(type regtype, OUT name text, OUT global_name text) RETURNS SETOF record
935 8097 aaronmk
    LANGUAGE plpgsql STABLE STRICT
936 8084 aaronmk
    AS $$
937
DECLARE
938 8183 aaronmk
    prefix text := util.name(type)||'.';
939 8084 aaronmk
BEGIN
940
    RETURN QUERY
941 8183 aaronmk
        SELECT name_, (CASE WHEN util.contains(search_for:='.', in_str:=name_) THEN '' ELSE prefix END)||name_
942
        FROM util.col_names(type) f (name_);
943 8084 aaronmk
END;
944
$$;
945
946
947
--
948 8183 aaronmk
-- Name: col_names(regclass); Type: FUNCTION; Schema: util; Owner: -
949 8151 aaronmk
--
950
951
CREATE FUNCTION col_names(table_ regclass) RETURNS SETOF text
952 12446 aaronmk
    LANGUAGE sql STABLE
953 8151 aaronmk
    AS $_$
954
SELECT attname::text
955
FROM pg_attribute
956 10158 aaronmk
WHERE attrelid = $1 AND attnum >= 1 AND NOT attisdropped
957 8151 aaronmk
ORDER BY attnum
958
$_$;
959
960
961
--
962 11667 aaronmk
-- Name: col_names(regtype); Type: FUNCTION; Schema: util; Owner: -
963
--
964
965
CREATE FUNCTION col_names(type regtype) RETURNS SETOF text
966
    LANGUAGE plpgsql STABLE STRICT
967
    AS $_$
968
BEGIN
969
    RETURN QUERY EXECUTE $$SELECT skeys(hstore(NULL::$$||type||$$))$$;
970
END;
971
$_$;
972
973
974
--
975 8183 aaronmk
-- Name: col_type(col_ref); Type: FUNCTION; Schema: util; Owner: -
976 8106 aaronmk
--
977
978
CREATE FUNCTION col_type(col col_ref) RETURNS regtype
979 8169 aaronmk
    LANGUAGE plpgsql STABLE STRICT
980
    AS $$
981
DECLARE
982
    type regtype;
983
BEGIN
984
    SELECT atttypid FROM pg_attribute
985
    WHERE attrelid = col.table_ AND attname = col.name
986
    INTO STRICT type
987
    ;
988
    RETURN type;
989
EXCEPTION
990 8171 aaronmk
    WHEN no_data_found THEN
991 8181 aaronmk
        RAISE undefined_column USING MESSAGE =
992
            concat('undefined column: ', col.name);
993 8169 aaronmk
END;
994
$$;
995 8106 aaronmk
996
997
--
998 12368 aaronmk
-- Name: comment(oid); Type: FUNCTION; Schema: util; Owner: -
999
--
1000
1001
CREATE FUNCTION comment(element oid) RETURNS text
1002 12446 aaronmk
    LANGUAGE sql STABLE
1003 12368 aaronmk
    AS $_$
1004
SELECT description FROM pg_description WHERE objoid = $1
1005
$_$;
1006
1007
1008
--
1009 11005 aaronmk
-- Name: concat_esc(text, text); Type: FUNCTION; Schema: util; Owner: -
1010
--
1011
1012
CREATE FUNCTION concat_esc("left" text, "right" text) RETURNS text
1013
    LANGUAGE sql IMMUTABLE
1014
    AS $_$
1015
SELECT util.esc_name__append($2, $1)
1016
$_$;
1017
1018
1019
--
1020 8183 aaronmk
-- Name: contains(text, text); Type: FUNCTION; Schema: util; Owner: -
1021 8095 aaronmk
--
1022
1023
CREATE FUNCTION contains(search_for text, in_str text) RETURNS boolean
1024 10388 aaronmk
    LANGUAGE sql IMMUTABLE
1025 8095 aaronmk
    AS $_$
1026
SELECT position($1 in $2) > 0 /*1-based offset*/
1027
$_$;
1028
1029
1030
--
1031 13599 aaronmk
-- Name: copy(regclass, text); Type: FUNCTION; Schema: util; Owner: -
1032
--
1033
1034
CREATE FUNCTION copy(from_ regclass, to_ text) RETURNS void
1035
    LANGUAGE sql
1036
    AS $_$
1037
SELECT util.copy_struct($1, $2);
1038
SELECT util.copy_data($1, $2);
1039
$_$;
1040
1041
1042
--
1043 13598 aaronmk
-- Name: copy_data(regclass, regclass); Type: FUNCTION; Schema: util; Owner: -
1044
--
1045
1046
CREATE FUNCTION copy_data(from_ regclass, to_ regclass) RETURNS void
1047
    LANGUAGE sql
1048
    AS $_$
1049
SELECT util.eval($$INSERT INTO $$||$2||$$ SELECT * FROM $$||$1)
1050
$_$;
1051
1052
1053
--
1054 12288 aaronmk
-- Name: copy_struct(regclass, text); Type: FUNCTION; Schema: util; Owner: -
1055
--
1056
1057
CREATE FUNCTION copy_struct(from_ regclass, to_ text) RETURNS void
1058
    LANGUAGE sql
1059
    AS $_$
1060
SELECT util.eval($$CREATE TABLE $$||$2||$$ (LIKE $$||$1||$$ INCLUDING ALL)$$)
1061
$_$;
1062
1063
1064
--
1065 12649 aaronmk
-- Name: copy_types_and_data(regclass, text); Type: FUNCTION; Schema: util; Owner: -
1066
--
1067
1068
CREATE FUNCTION copy_types_and_data(from_ regclass, to_ text) RETURNS void
1069
    LANGUAGE sql
1070
    AS $_$
1071
SELECT util.materialize_view($2, $1)
1072
$_$;
1073
1074
1075
--
1076 13495 aaronmk
-- Name: create_if_not_exists(text, text); Type: FUNCTION; Schema: util; Owner: -
1077 8094 aaronmk
--
1078
1079 13495 aaronmk
CREATE FUNCTION create_if_not_exists(sql text, relation text DEFAULT NULL::text) RETURNS void
1080
    LANGUAGE plpgsql
1081 8094 aaronmk
    AS $$
1082
BEGIN
1083 13495 aaronmk
	/* always generate standard exception if exists, even if table definition
1084
	would be invalid (which generates a variety of exceptions) */
1085 13529 aaronmk
	IF util.relation_exists(relation) THEN
1086
		PERFORM util.raise('NOTICE', relation||' already exists, skipping');
1087
		RAISE duplicate_table;
1088
	END IF;
1089 12595 aaronmk
	PERFORM util.eval(sql);
1090 8094 aaronmk
EXCEPTION
1091 12676 aaronmk
WHEN   duplicate_table
1092
	OR duplicate_object -- eg. constraint
1093
	OR duplicate_column
1094
	OR duplicate_function
1095
THEN NULL;
1096 12595 aaronmk
WHEN invalid_table_definition THEN
1097
	IF SQLERRM LIKE 'multiple primary keys for table % are not allowed' THEN NULL;
1098
	ELSE RAISE;
1099
	END IF;
1100 8094 aaronmk
END;
1101
$$;
1102
1103
1104
--
1105 13495 aaronmk
-- Name: FUNCTION create_if_not_exists(sql text, relation text); Type: COMMENT; Schema: util; Owner: -
1106 8094 aaronmk
--
1107
1108 13495 aaronmk
COMMENT ON FUNCTION create_if_not_exists(sql text, relation text) IS '
1109 12235 aaronmk
idempotent
1110
';
1111 8094 aaronmk
1112
1113
--
1114 12378 aaronmk
-- Name: curr_func(text, anyelement); Type: FUNCTION; Schema: util; Owner: -
1115
--
1116
1117
CREATE FUNCTION curr_func(func text, schema_anchor anyelement) RETURNS text
1118 12590 aaronmk
    LANGUAGE sql STABLE
1119 12378 aaronmk
    AS $$
1120
SELECT util.schema_esc(schema_anchor)||'.'||quote_ident(func)
1121
$$;
1122
1123
1124
--
1125 12668 aaronmk
-- Name: debug_print_func_call(text); Type: FUNCTION; Schema: util; Owner: -
1126
--
1127
1128
CREATE FUNCTION debug_print_func_call(func_call text) RETURNS void
1129
    LANGUAGE sql IMMUTABLE
1130
    AS $_$
1131
SELECT util.raise('NOTICE', $$SELECT $$||$1)
1132
$_$;
1133
1134
1135
--
1136 12433 aaronmk
-- Name: debug_print_return_value(anyelement, boolean); Type: FUNCTION; Schema: util; Owner: -
1137 12430 aaronmk
--
1138
1139 12433 aaronmk
CREATE FUNCTION debug_print_return_value(value anyelement, encode boolean DEFAULT false) RETURNS anyelement
1140 12430 aaronmk
    LANGUAGE sql IMMUTABLE
1141
    AS $_$
1142 13447 aaronmk
SELECT util.debug_print_value('returns: ', $1, $2);
1143 12430 aaronmk
SELECT $1;
1144
$_$;
1145
1146
1147
--
1148 12250 aaronmk
-- Name: debug_print_sql(text); Type: FUNCTION; Schema: util; Owner: -
1149
--
1150
1151
CREATE FUNCTION debug_print_sql(sql text) RETURNS void
1152
    LANGUAGE sql IMMUTABLE
1153
    AS $_$
1154
/* newline before so the query starts at the beginning of the line.
1155
newline after to visually separate queries from one another. */
1156 12534 aaronmk
SELECT util.raise('NOTICE', $$
1157 12474 aaronmk
$$||util.runnable_sql($1)||$$
1158 12464 aaronmk
$$||COALESCE(util.explain2notice_msg_if_can($1), ''))
1159 12250 aaronmk
$_$;
1160
1161
1162
--
1163 13446 aaronmk
-- Name: debug_print_value(text, anyelement, boolean); Type: FUNCTION; Schema: util; Owner: -
1164
--
1165
1166
CREATE FUNCTION debug_print_value(label text, value anyelement, encode boolean DEFAULT false) RETURNS void
1167
    LANGUAGE sql IMMUTABLE
1168
    AS $_$
1169
SELECT util.raise('NOTICE', concat($1,
1170 13449 aaronmk
(CASE WHEN $3 THEN util.quote_typed($2) ELSE $2::text END))||$$
1171
$$)
1172 13446 aaronmk
$_$;
1173
1174
1175
--
1176 13448 aaronmk
-- Name: debug_print_var(text, anyelement, boolean); Type: FUNCTION; Schema: util; Owner: -
1177
--
1178
1179
CREATE FUNCTION debug_print_var(var text, value anyelement, encode boolean DEFAULT false) RETURNS void
1180
    LANGUAGE sql IMMUTABLE
1181
    AS $_$
1182
/* can't use EXECUTE in the caller because "No substitution of PL/pgSQL
1183
variables is done on the computed command string"
1184
(http://www.postgresql.org/docs/9.3/static/plpgsql-statements.html#PLPGSQL-STATEMENTS-EXECUTING-DYN) */
1185
SELECT util.debug_print_value($1||' = ', $2, $3)
1186
$_$;
1187
1188
1189
--
1190 10364 aaronmk
-- Name: derived_cols(regclass, regclass); Type: FUNCTION; Schema: util; Owner: -
1191
--
1192
1193
CREATE FUNCTION derived_cols(table_ regclass, names regclass) RETURNS SETOF text
1194 12446 aaronmk
    LANGUAGE sql STABLE
1195 10364 aaronmk
    AS $_$
1196
SELECT util.eval2set($$
1197
SELECT col
1198
FROM util.col_names($$||quote_nullable($1)||$$::regclass) f (col)
1199
LEFT JOIN $$||$2||$$ ON "to" = col
1200
WHERE "from" IS NULL
1201
$$, NULL::text)
1202
$_$;
1203
1204
1205
--
1206
-- Name: FUNCTION derived_cols(table_ regclass, names regclass); Type: COMMENT; Schema: util; Owner: -
1207
--
1208
1209 12235 aaronmk
COMMENT ON FUNCTION derived_cols(table_ regclass, names regclass) IS '
1210
gets table_''s derived columns (all the columns not in the names table)
1211
';
1212 10364 aaronmk
1213
1214
--
1215 12298 aaronmk
-- Name: diff(regclass, regclass, anyelement); Type: FUNCTION; Schema: util; Owner: -
1216 12044 aaronmk
--
1217
1218 12298 aaronmk
CREATE FUNCTION diff(left_table regclass, right_table regclass, col_type_null anyelement, OUT left_ anyelement, OUT right_ anyelement) RETURNS SETOF record
1219 12427 aaronmk
    LANGUAGE sql
1220 12044 aaronmk
    AS $_$
1221 12653 aaronmk
-- create a diff when the # of copies of a row differs between the tables
1222
SELECT util.to_freq($1);
1223
SELECT util.to_freq($2);
1224 12663 aaronmk
SELECT util.auto_rm_freq(ARRAY[$1, $2]);
1225 12653 aaronmk
1226
SELECT * FROM util.diff($1, $2, $3, has_freq := true)
1227 12298 aaronmk
$_$;
1228
1229
1230
--
1231
-- Name: FUNCTION diff(left_table regclass, right_table regclass, col_type_null anyelement, OUT left_ anyelement, OUT right_ anyelement); Type: COMMENT; Schema: util; Owner: -
1232
--
1233
1234
COMMENT ON FUNCTION diff(left_table regclass, right_table regclass, col_type_null anyelement, OUT left_ anyelement, OUT right_ anyelement) IS '
1235
usage:
1236
SELECT * FROM util.diff(''"left_table"''::regclass, ''"right_table"''::regclass, NULL::shared_base_type)
1237 12653 aaronmk
1238
col_type_null (*required*): NULL::shared_base_type
1239 12298 aaronmk
';
1240
1241
1242
--
1243 12491 aaronmk
-- Name: diff(text, text, anyelement, boolean); Type: FUNCTION; Schema: util; Owner: -
1244 12298 aaronmk
--
1245
1246 12491 aaronmk
CREATE FUNCTION diff(left__ text, right__ text, col_type_null anyelement, single_row boolean DEFAULT false, OUT left_ anyelement, OUT right_ anyelement) RETURNS SETOF record
1247 12429 aaronmk
    LANGUAGE plpgsql
1248
    SET search_path TO pg_temp
1249 12298 aaronmk
    AS $_$
1250 12429 aaronmk
/* must use LANGUAGE plpgsql because LANGUAGE sql does not support runtime
1251
changes of search_path (schema elements are bound at inline time rather than
1252
runtime) */
1253
/* function option search_path is needed to limit the effects of
1254 12492 aaronmk
`SET LOCAL search_path` to the current function */
1255 12429 aaronmk
BEGIN
1256 12491 aaronmk
	PERFORM util.use_schema($3); -- includes util.%== as default/fallback
1257 12429 aaronmk
1258 12565 aaronmk
	PERFORM util.mk_keys_func(pg_typeof($3));
1259 12429 aaronmk
	RETURN QUERY
1260 12554 aaronmk
		SELECT * FROM util.eval2col_pair(util.mk_diff_query($1, $2,
1261 12479 aaronmk
$$/* need to explicitly cast each side to the return type because this does not
1262 12284 aaronmk
happen automatically even when an implicit cast is available */
1263 12479 aaronmk
  left_::$$||util.typeof($3)||$$
1264
, right_::$$||util.typeof($3)
1265 12496 aaronmk
/* when using the util.%==(anyelement, anyelement) operator, you must cast to
1266
the *same* base type, *even though* this is optional when using a custom %== */
1267 12553 aaronmk
, util._if($4, $$true/*= CROSS JOIN*/$$,
1268
$$ left_::$$||util.typeof($3)||$$
1269 12496 aaronmk
%== right_::$$||util.typeof($3)||$$
1270
	-- refer to EXPLAIN output for expansion of %==$$
1271 12657 aaronmk
)
1272
,     $$         left_::$$||util.typeof($3)||$$
1273
IS DISTINCT FROM right_::$$||util.typeof($3)
1274
), $3)
1275 12429 aaronmk
	;
1276
END;
1277 12044 aaronmk
$_$;
1278
1279
1280
--
1281 12491 aaronmk
-- Name: FUNCTION diff(left__ text, right__ text, col_type_null anyelement, single_row boolean, OUT left_ anyelement, OUT right_ anyelement); Type: COMMENT; Schema: util; Owner: -
1282 12280 aaronmk
--
1283
1284 12491 aaronmk
COMMENT ON FUNCTION diff(left__ text, right__ text, col_type_null anyelement, single_row boolean, OUT left_ anyelement, OUT right_ anyelement) IS '
1285 12280 aaronmk
col_type_null (*required*): NULL::col_type
1286 12299 aaronmk
single_row: whether the tables consist of a single row, which should be
1287
	displayed side-by-side
1288 12282 aaronmk
1289 12498 aaronmk
to match up rows using a subset of the columns, create a custom keys() function
1290
which returns this subset as a record:
1291
-- note that OUT parameters for the returned fields are *not* needed
1292
CREATE OR REPLACE FUNCTION [schema].keys(value [schema].[base_type])
1293
  RETURNS record AS
1294
$BODY$
1295
SELECT ($1.key_field_0, $1.key_field_1)
1296
$BODY$
1297
  LANGUAGE sql IMMUTABLE
1298
  COST 100;
1299
1300
1301 12282 aaronmk
to run EXPLAIN on the FULL JOIN query:
1302
# run this function
1303
# look for a NOTICE containing the expanded query that it ran
1304
# run EXPLAIN on this expanded query
1305 12280 aaronmk
';
1306
1307
1308
--
1309 12653 aaronmk
-- Name: diff(regclass, regclass, anyelement, boolean); Type: FUNCTION; Schema: util; Owner: -
1310
--
1311
1312
CREATE FUNCTION diff(left_table regclass, right_table regclass, col_type_null anyelement, has_freq boolean, OUT left_ anyelement, OUT right_ anyelement) RETURNS SETOF record
1313
    LANGUAGE sql
1314
    AS $_$
1315
SELECT * FROM util.diff($1::text, $2::text, $3,
1316
	single_row := util.has_single_row($1) AND util.has_single_row($2))
1317
$_$;
1318
1319
1320
--
1321
-- Name: FUNCTION diff(left_table regclass, right_table regclass, col_type_null anyelement, has_freq boolean, OUT left_ anyelement, OUT right_ anyelement); Type: COMMENT; Schema: util; Owner: -
1322
--
1323
1324
COMMENT ON FUNCTION diff(left_table regclass, right_table regclass, col_type_null anyelement, has_freq boolean, OUT left_ anyelement, OUT right_ anyelement) IS '
1325
helper function used by diff(regclass, regclass)
1326
1327
usage:
1328
SELECT * FROM util.diff(''"left_freq_table"''::regclass, ''"right_freq_table"''::regclass, NULL::shared_base_type, has_freq := true)
1329
1330
col_type_null (*required*): NULL::shared_base_type
1331
';
1332
1333
1334
--
1335 8200 aaronmk
-- Name: do_optionally_ignore(text, boolean); Type: FUNCTION; Schema: util; Owner: -
1336
--
1337
1338
CREATE FUNCTION do_optionally_ignore(sql text, ignore boolean) RETURNS void
1339 12446 aaronmk
    LANGUAGE sql
1340 8200 aaronmk
    AS $_$
1341
SELECT CASE WHEN $2 THEN util.try_create($1) ELSE util.create_if_not_exists($1) END
1342
$_$;
1343
1344
1345
--
1346
-- Name: FUNCTION do_optionally_ignore(sql text, ignore boolean); Type: COMMENT; Schema: util; Owner: -
1347
--
1348
1349 12235 aaronmk
COMMENT ON FUNCTION do_optionally_ignore(sql text, ignore boolean) IS '
1350
idempotent
1351
';
1352 8200 aaronmk
1353
1354
--
1355 12292 aaronmk
-- Name: drop_column(col_ref, boolean); Type: FUNCTION; Schema: util; Owner: -
1356 10362 aaronmk
--
1357
1358 12292 aaronmk
CREATE FUNCTION drop_column(col col_ref, force boolean DEFAULT false) RETURNS void
1359 12446 aaronmk
    LANGUAGE sql
1360 10362 aaronmk
    AS $_$
1361
SELECT util.eval($$ALTER TABLE $$||$1.table_||$$ DROP COLUMN IF EXISTS $$||
1362 12292 aaronmk
quote_ident($1.name)||util._if($2, $$ CASCADE$$, ''::text))
1363 10362 aaronmk
$_$;
1364
1365
1366
--
1367 12292 aaronmk
-- Name: FUNCTION drop_column(col col_ref, force boolean); Type: COMMENT; Schema: util; Owner: -
1368 10362 aaronmk
--
1369
1370 12292 aaronmk
COMMENT ON FUNCTION drop_column(col col_ref, force boolean) IS '
1371 12235 aaronmk
idempotent
1372
';
1373 10362 aaronmk
1374
1375
--
1376 12660 aaronmk
-- Name: drop_column(regclass[], text, boolean); Type: FUNCTION; Schema: util; Owner: -
1377
--
1378
1379
CREATE FUNCTION drop_column(tables regclass[], col text, force boolean DEFAULT false) RETURNS void
1380
    LANGUAGE sql
1381
    AS $_$
1382 12686 aaronmk
SELECT util.drop_column((table_, $2), $3) FROM unnest($1) table_;
1383
SELECT NULL::void; -- don't fold away functions called in previous query
1384 12660 aaronmk
$_$;
1385
1386
1387
--
1388
-- Name: FUNCTION drop_column(tables regclass[], col text, force boolean); Type: COMMENT; Schema: util; Owner: -
1389
--
1390
1391
COMMENT ON FUNCTION drop_column(tables regclass[], col text, force boolean) IS '
1392
idempotent
1393
';
1394
1395
1396
--
1397 12587 aaronmk
-- Name: drop_relation(anyelement, boolean); Type: FUNCTION; Schema: util; Owner: -
1398 12331 aaronmk
--
1399
1400 12587 aaronmk
CREATE FUNCTION drop_relation(relation anyelement, force boolean DEFAULT false) RETURNS void
1401 12331 aaronmk
    LANGUAGE sql
1402
    AS $_$
1403 12353 aaronmk
/* use util.qual_name() instead of ::text so that the schema qualifier is always
1404
included in the debug SQL */
1405
SELECT util.drop_relation(util.relation_type($1), util.qual_name($1), $2)
1406 12331 aaronmk
$_$;
1407
1408
1409
--
1410 12343 aaronmk
-- Name: drop_relation(text, text, boolean); Type: FUNCTION; Schema: util; Owner: -
1411
--
1412
1413 12364 aaronmk
CREATE FUNCTION drop_relation(type text, relation_esc text, force boolean DEFAULT false) RETURNS void
1414 12343 aaronmk
    LANGUAGE sql
1415
    AS $_$
1416 12347 aaronmk
SELECT util.eval($$DROP $$||$1||$$ IF EXISTS $$||$2
1417 12343 aaronmk
||util._if($3, $$ CASCADE$$, ''::text))
1418
$_$;
1419
1420
1421
--
1422 12364 aaronmk
-- Name: FUNCTION drop_relation(type text, relation_esc text, force boolean); Type: COMMENT; Schema: util; Owner: -
1423 12343 aaronmk
--
1424
1425 12364 aaronmk
COMMENT ON FUNCTION drop_relation(type text, relation_esc text, force boolean) IS '
1426 12343 aaronmk
idempotent
1427
';
1428
1429
1430
--
1431 12413 aaronmk
-- Name: drop_relations_like(text, anyelement, boolean); Type: FUNCTION; Schema: util; Owner: -
1432
--
1433
1434
CREATE FUNCTION drop_relations_like(name_regexp text, schema_anchor anyelement, force boolean DEFAULT false) RETURNS void
1435
    LANGUAGE sql
1436
    AS $_$
1437 12502 aaronmk
SELECT util.drop_relations_like($1, util.schema_regexp($2), $3)
1438 12413 aaronmk
$_$;
1439
1440
1441
--
1442
-- Name: drop_relations_like(text, text, boolean); Type: FUNCTION; Schema: util; Owner: -
1443
--
1444
1445
CREATE FUNCTION drop_relations_like(name_regexp text, schema_regexp text DEFAULT ''::text, force boolean DEFAULT false) RETURNS void
1446
    LANGUAGE sql
1447
    AS $_$
1448 12668 aaronmk
SELECT util.debug_print_func_call(util.quote_func_call(
1449
'util.drop_relations_like', util.quote_typed($1), util.quote_typed($2),
1450
util.quote_typed($3)))
1451 12667 aaronmk
;
1452 12413 aaronmk
SELECT util.drop_relation(relation, $3)
1453
FROM util.show_relations_like($1, $2) relation
1454
;
1455
SELECT NULL::void; -- don't fold away functions called in previous query
1456
$_$;
1457
1458
1459
--
1460 12292 aaronmk
-- Name: drop_table(text, boolean); Type: FUNCTION; Schema: util; Owner: -
1461 10150 aaronmk
--
1462
1463 12292 aaronmk
CREATE FUNCTION drop_table(table_ text, force boolean DEFAULT false) RETURNS void
1464 12446 aaronmk
    LANGUAGE sql
1465 10150 aaronmk
    AS $_$
1466 12347 aaronmk
SELECT util.drop_relation('TABLE', $1, $2)
1467 10150 aaronmk
$_$;
1468
1469
1470
--
1471 12292 aaronmk
-- Name: FUNCTION drop_table(table_ text, force boolean); Type: COMMENT; Schema: util; Owner: -
1472 10150 aaronmk
--
1473
1474 12292 aaronmk
COMMENT ON FUNCTION drop_table(table_ text, force boolean) IS '
1475 12235 aaronmk
idempotent
1476
';
1477 10150 aaronmk
1478
1479
--
1480 12292 aaronmk
-- Name: drop_view(text, boolean); Type: FUNCTION; Schema: util; Owner: -
1481 12229 aaronmk
--
1482
1483 12292 aaronmk
CREATE FUNCTION drop_view(view_ text, force boolean DEFAULT false) RETURNS void
1484 12446 aaronmk
    LANGUAGE sql
1485 12229 aaronmk
    AS $_$
1486 12347 aaronmk
SELECT util.drop_relation('VIEW', $1, $2)
1487 12229 aaronmk
$_$;
1488
1489
1490
--
1491 12292 aaronmk
-- Name: FUNCTION drop_view(view_ text, force boolean); Type: COMMENT; Schema: util; Owner: -
1492 12229 aaronmk
--
1493
1494 12292 aaronmk
COMMENT ON FUNCTION drop_view(view_ text, force boolean) IS '
1495 12235 aaronmk
idempotent
1496
';
1497 12229 aaronmk
1498
1499
--
1500 10322 aaronmk
-- Name: empty_array(anyelement); Type: FUNCTION; Schema: util; Owner: -
1501
--
1502
1503
CREATE FUNCTION empty_array(elem_type_null anyelement DEFAULT NULL::text) RETURNS anyarray
1504
    LANGUAGE sql IMMUTABLE
1505
    AS $_$
1506
SELECT util.array_fill($1, 0)
1507
$_$;
1508
1509
1510
--
1511
-- Name: FUNCTION empty_array(elem_type_null anyelement); Type: COMMENT; Schema: util; Owner: -
1512
--
1513
1514 12235 aaronmk
COMMENT ON FUNCTION empty_array(elem_type_null anyelement) IS '
1515
constructs proper empty 1-dimensional array whose dimensions are not NULL ( ''{}''::text[] does not do this)
1516
';
1517 10322 aaronmk
1518
1519
--
1520 8183 aaronmk
-- Name: ensure_prefix(text, text); Type: FUNCTION; Schema: util; Owner: -
1521 8086 aaronmk
--
1522
1523
CREATE FUNCTION ensure_prefix(prefix text, str text) RETURNS text
1524 10388 aaronmk
    LANGUAGE sql IMMUTABLE
1525 8086 aaronmk
    AS $_$
1526 8183 aaronmk
SELECT (CASE WHEN util.has_prefix($1, $2) THEN $2 ELSE $1||$2 END)
1527 8086 aaronmk
$_$;
1528
1529
1530
--
1531 10987 aaronmk
-- Name: esc_name__append(text, text); Type: FUNCTION; Schema: util; Owner: -
1532
--
1533
1534
CREATE FUNCTION esc_name__append(suffix text, esc_name text) RETURNS text
1535
    LANGUAGE sql IMMUTABLE
1536
    AS $_$
1537
SELECT regexp_replace($2, '("?)$', $1||'\1')
1538
$_$;
1539
1540
1541
--
1542 13455 aaronmk
-- Name: eval(text[]); Type: FUNCTION; Schema: util; Owner: -
1543
--
1544
1545
CREATE FUNCTION eval(queries text[]) RETURNS void
1546
    LANGUAGE sql
1547
    AS $_$
1548
SELECT util.eval(query) FROM unnest($1) query;
1549
SELECT NULL::void; -- don't fold away functions called in previous query
1550
$_$;
1551
1552
1553
--
1554 12531 aaronmk
-- Name: eval(text, boolean); Type: FUNCTION; Schema: util; Owner: -
1555 9824 aaronmk
--
1556
1557 12531 aaronmk
CREATE FUNCTION eval(sql text, verbose_ boolean DEFAULT true) RETURNS void
1558 12558 aaronmk
    LANGUAGE plpgsql
1559 9824 aaronmk
    AS $$
1560
BEGIN
1561 12531 aaronmk
	IF verbose_ THEN PERFORM util.debug_print_sql(sql); END IF;
1562 12251 aaronmk
	EXECUTE sql;
1563 9824 aaronmk
END;
1564
$$;
1565
1566
1567
--
1568 12181 aaronmk
-- Name: eval2col_pair(text, anyelement); Type: FUNCTION; Schema: util; Owner: -
1569
--
1570
1571
CREATE FUNCTION eval2col_pair(sql text, col_type_null anyelement, OUT left_ anyelement, OUT right_ anyelement) RETURNS SETOF record
1572
    LANGUAGE plpgsql
1573
    AS $$
1574
BEGIN
1575 12251 aaronmk
	PERFORM util.debug_print_sql(sql);
1576 12181 aaronmk
	RETURN QUERY EXECUTE sql;
1577
END;
1578
$$;
1579
1580
1581
--
1582
-- Name: FUNCTION eval2col_pair(sql text, col_type_null anyelement, OUT left_ anyelement, OUT right_ anyelement); Type: COMMENT; Schema: util; Owner: -
1583
--
1584
1585 12235 aaronmk
COMMENT ON FUNCTION eval2col_pair(sql text, col_type_null anyelement, OUT left_ anyelement, OUT right_ anyelement) IS '
1586
col_type_null (*required*): NULL::col_type
1587
';
1588 12181 aaronmk
1589
1590
--
1591 12301 aaronmk
-- Name: eval2records(text); Type: FUNCTION; Schema: util; Owner: -
1592
--
1593
1594
CREATE FUNCTION eval2records(sql text) RETURNS SETOF record
1595
    LANGUAGE plpgsql
1596
    AS $$
1597
BEGIN
1598
	PERFORM util.debug_print_sql(sql);
1599
	RETURN QUERY EXECUTE sql;
1600
END;
1601
$$;
1602
1603
1604
--
1605 12458 aaronmk
-- Name: eval2set(text, anyelement, boolean); Type: FUNCTION; Schema: util; Owner: -
1606 10363 aaronmk
--
1607
1608 12458 aaronmk
CREATE FUNCTION eval2set(sql text, ret_type_null anyelement DEFAULT NULL::text, verbose_ boolean DEFAULT true) RETURNS SETOF anyelement
1609 10363 aaronmk
    LANGUAGE plpgsql
1610
    AS $$
1611
BEGIN
1612 12458 aaronmk
	IF verbose_ THEN PERFORM util.debug_print_sql(sql); END IF;
1613 10363 aaronmk
	RETURN QUERY EXECUTE sql;
1614
END;
1615
$$;
1616
1617
1618
--
1619 10129 aaronmk
-- Name: eval2val(text, anyelement); Type: FUNCTION; Schema: util; Owner: -
1620 10128 aaronmk
--
1621
1622 10129 aaronmk
CREATE FUNCTION eval2val(sql text, ret_type_null anyelement DEFAULT NULL::text) RETURNS anyelement
1623 12514 aaronmk
    LANGUAGE plpgsql STABLE
1624 10128 aaronmk
    AS $$
1625
DECLARE
1626
	ret_val ret_type_null%TYPE;
1627
BEGIN
1628 12251 aaronmk
	PERFORM util.debug_print_sql(sql);
1629 10128 aaronmk
	EXECUTE sql INTO STRICT ret_val;
1630
	RETURN ret_val;
1631
END;
1632
$$;
1633
1634
1635
--
1636 10129 aaronmk
-- Name: FUNCTION eval2val(sql text, ret_type_null anyelement); Type: COMMENT; Schema: util; Owner: -
1637 10128 aaronmk
--
1638
1639 12235 aaronmk
COMMENT ON FUNCTION eval2val(sql text, ret_type_null anyelement) IS '
1640
ret_type_null: NULL::ret_type
1641
';
1642 10128 aaronmk
1643
1644
--
1645 10131 aaronmk
-- Name: eval_expr(text, anyelement); Type: FUNCTION; Schema: util; Owner: -
1646
--
1647
1648
CREATE FUNCTION eval_expr(sql text, ret_type_null anyelement DEFAULT NULL::text) RETURNS anyelement
1649
    LANGUAGE sql
1650
    AS $_$
1651 10132 aaronmk
SELECT util.eval2val($$SELECT $$||$1, $2)
1652 10131 aaronmk
$_$;
1653
1654
1655
--
1656
-- Name: FUNCTION eval_expr(sql text, ret_type_null anyelement); Type: COMMENT; Schema: util; Owner: -
1657
--
1658
1659 12235 aaronmk
COMMENT ON FUNCTION eval_expr(sql text, ret_type_null anyelement) IS '
1660
ret_type_null: NULL::ret_type
1661
';
1662 10131 aaronmk
1663
1664
--
1665 10133 aaronmk
-- Name: eval_expr_passthru(text, anyelement); Type: FUNCTION; Schema: util; Owner: -
1666
--
1667
1668
CREATE FUNCTION eval_expr_passthru(sql text, ret_type_null anyelement DEFAULT NULL::text) RETURNS anyelement
1669
    LANGUAGE sql
1670
    AS $_$
1671
SELECT CASE WHEN $1 IS NULL THEN NULL ELSE util.eval_expr($1, $2) END
1672
$_$;
1673
1674
1675
--
1676
-- Name: FUNCTION eval_expr_passthru(sql text, ret_type_null anyelement); Type: COMMENT; Schema: util; Owner: -
1677
--
1678
1679 12235 aaronmk
COMMENT ON FUNCTION eval_expr_passthru(sql text, ret_type_null anyelement) IS '
1680
sql: can be NULL, which will be passed through
1681
ret_type_null: NULL::ret_type
1682
';
1683 10133 aaronmk
1684
1685
--
1686 8183 aaronmk
-- Name: existing_cols(regclass, text[]); Type: FUNCTION; Schema: util; Owner: -
1687 8182 aaronmk
--
1688
1689
CREATE FUNCTION existing_cols(table_ regclass, VARIADIC col_names text[]) RETURNS SETOF text
1690 12446 aaronmk
    LANGUAGE sql STABLE
1691 8182 aaronmk
    AS $_$
1692
SELECT col_name
1693
FROM unnest($2) s (col_name)
1694 8183 aaronmk
WHERE util.col_exists(($1, col_name))
1695 8182 aaronmk
$_$;
1696
1697
1698
--
1699 11830 aaronmk
-- Name: explain(text); Type: FUNCTION; Schema: util; Owner: -
1700
--
1701
1702
CREATE FUNCTION explain(sql text) RETURNS SETOF text
1703
    LANGUAGE sql
1704 13496 aaronmk
    SET client_min_messages TO 'error'
1705 11830 aaronmk
    AS $_$
1706 13496 aaronmk
/* `client_min_messages = ERROR`: EXPLAIN apparently runs IMMUTABLE functions in
1707
the query, so this prevents displaying any log messages printed by them */
1708 12459 aaronmk
SELECT util.eval2set($$EXPLAIN $$||$1, verbose_ := false)
1709 11830 aaronmk
$_$;
1710
1711
1712
--
1713 11833 aaronmk
-- Name: explain2notice(text); Type: FUNCTION; Schema: util; Owner: -
1714
--
1715
1716
CREATE FUNCTION explain2notice(sql text) RETURNS void
1717 12449 aaronmk
    LANGUAGE sql
1718
    AS $_$
1719 12534 aaronmk
SELECT util.raise('NOTICE', util.explain2notice_msg($1))
1720 12449 aaronmk
$_$;
1721 12448 aaronmk
1722
1723
--
1724
-- Name: explain2notice_msg(text); Type: FUNCTION; Schema: util; Owner: -
1725
--
1726
1727
CREATE FUNCTION explain2notice_msg(sql text) RETURNS text
1728
    LANGUAGE sql
1729
    AS $_$
1730 12464 aaronmk
-- newline before and after to visually separate it from other debug info
1731 12756 aaronmk
SELECT COALESCE($$
1732 12464 aaronmk
EXPLAIN:
1733 12756 aaronmk
$$||util.fold_explain_msg(util.explain2str($1))||$$
1734
$$, '')
1735 11833 aaronmk
$_$;
1736
1737
1738
--
1739 12452 aaronmk
-- Name: explain2notice_msg_if_can(text); Type: FUNCTION; Schema: util; Owner: -
1740
--
1741
1742
CREATE FUNCTION explain2notice_msg_if_can(sql text) RETURNS text
1743 13403 aaronmk
    LANGUAGE plpgsql
1744
    AS $$
1745
BEGIN
1746
	RETURN util.explain2notice_msg(sql);
1747
EXCEPTION
1748 13601 aaronmk
WHEN   syntax_error
1749
	OR invalid_cursor_definition -- "cannot open multi-query plan as cursor"
1750
	THEN RETURN NULL; -- non-explainable query
1751 13403 aaronmk
	/* don't use util.is_explainable() because the list provided by Postgres
1752
	(http://www.postgresql.org/docs/9.3/static/sql-explain.html#AEN77691)
1753
	excludes some query types that are in fact EXPLAIN-able */
1754
END;
1755
$$;
1756 12452 aaronmk
1757
1758
--
1759 11832 aaronmk
-- Name: explain2str(text); Type: FUNCTION; Schema: util; Owner: -
1760
--
1761
1762
CREATE FUNCTION explain2str(sql text) RETURNS text
1763
    LANGUAGE sql
1764
    AS $_$
1765
SELECT util.join_strs(explain, $$
1766
$$) FROM util.explain($1)
1767
$_$;
1768
1769
1770 11835 aaronmk
SET default_tablespace = '';
1771
1772
SET default_with_oids = false;
1773
1774 11832 aaronmk
--
1775 11835 aaronmk
-- Name: explain; Type: TABLE; Schema: util; Owner: -; Tablespace:
1776 11831 aaronmk
--
1777
1778 11835 aaronmk
CREATE TABLE explain (
1779
    line text NOT NULL
1780
);
1781
1782
1783
--
1784
-- Name: explain2table(text, regclass); Type: FUNCTION; Schema: util; Owner: -
1785
--
1786
1787
CREATE FUNCTION explain2table(sql text, table_ regclass DEFAULT 'explain'::regclass) RETURNS void
1788 11831 aaronmk
    LANGUAGE sql
1789
    AS $_$
1790 11835 aaronmk
SELECT util.eval($$INSERT INTO $$||$2||$$ SELECT util.explain(
1791
$$||quote_nullable($1)||$$
1792 11831 aaronmk
)$$)
1793
$_$;
1794
1795
1796
--
1797 11836 aaronmk
-- Name: FUNCTION explain2table(sql text, table_ regclass); Type: COMMENT; Schema: util; Owner: -
1798
--
1799
1800 12235 aaronmk
COMMENT ON FUNCTION explain2table(sql text, table_ regclass) IS '
1801
usage:
1802 11836 aaronmk
PERFORM util.explain2table($$
1803
query
1804 12235 aaronmk
$$);
1805
';
1806 11836 aaronmk
1807
1808
--
1809 12450 aaronmk
-- Name: first_word(text); Type: FUNCTION; Schema: util; Owner: -
1810
--
1811
1812
CREATE FUNCTION first_word(str text) RETURNS text
1813
    LANGUAGE sql IMMUTABLE
1814
    AS $_$
1815 12461 aaronmk
SELECT match[1] FROM regexp_matches(util.ltrim_nl($1), '^(\S*)') match
1816 12450 aaronmk
$_$;
1817
1818
1819
--
1820 10323 aaronmk
-- Name: fix_array(anyarray); Type: FUNCTION; Schema: util; Owner: -
1821
--
1822
1823
CREATE FUNCTION fix_array("array" anyarray) RETURNS anyarray
1824 10355 aaronmk
    LANGUAGE sql IMMUTABLE
1825 10323 aaronmk
    AS $_$
1826 10355 aaronmk
SELECT CASE WHEN $1 IS NULL THEN NULL ELSE (
1827
	CASE WHEN pg_catalog.array_ndims($1) IS NULL THEN util.empty_array($1[1]) ELSE $1 END
1828
) END
1829 10323 aaronmk
$_$;
1830
1831
1832
--
1833
-- Name: FUNCTION fix_array("array" anyarray); Type: COMMENT; Schema: util; Owner: -
1834
--
1835
1836 12235 aaronmk
COMMENT ON FUNCTION fix_array("array" anyarray) IS '
1837
ensures that an array will always have proper non-NULL dimensions
1838
';
1839 10323 aaronmk
1840
1841
--
1842 12755 aaronmk
-- Name: fold_explain_msg(text); Type: FUNCTION; Schema: util; Owner: -
1843
--
1844
1845
CREATE FUNCTION fold_explain_msg(explain text) RETURNS text
1846
    LANGUAGE sql IMMUTABLE
1847
    AS $_$
1848
SELECT (CASE WHEN util.first_word($1) = 'Result' THEN NULL ELSE $1 END)
1849
$_$;
1850
1851
1852
--
1853 8321 aaronmk
-- Name: force_update_view(text, text); Type: FUNCTION; Schema: util; Owner: -
1854
--
1855
1856
CREATE FUNCTION force_update_view(view_ text, query text) RETURNS void
1857
    LANGUAGE plpgsql STRICT
1858
    AS $_$
1859
DECLARE
1860
	mk_view text = $$CREATE OR REPLACE VIEW $$||view_||$$ AS
1861
$$||query;
1862
BEGIN
1863
	EXECUTE mk_view;
1864
EXCEPTION
1865
WHEN invalid_table_definition THEN
1866 8323 aaronmk
	IF SQLERRM = 'cannot drop columns from view'
1867
	OR SQLERRM LIKE 'cannot change name of view column "%" to "%"'
1868
	THEN
1869 8321 aaronmk
		EXECUTE $$DROP VIEW $$||view_||$$ CASCADE$$;
1870
		EXECUTE mk_view;
1871
	ELSE RAISE USING ERRCODE = SQLSTATE, MESSAGE = SQLERRM;
1872
	END IF;
1873
END;
1874
$_$;
1875
1876
1877
--
1878
-- Name: FUNCTION force_update_view(view_ text, query text); Type: COMMENT; Schema: util; Owner: -
1879
--
1880
1881 12235 aaronmk
COMMENT ON FUNCTION force_update_view(view_ text, query text) IS '
1882
idempotent
1883
';
1884 8321 aaronmk
1885
1886
--
1887 12654 aaronmk
-- Name: freq_always_1(regclass, text); Type: FUNCTION; Schema: util; Owner: -
1888
--
1889
1890
CREATE FUNCTION freq_always_1(table_ regclass, freq_col text DEFAULT 'copies'::text) RETURNS boolean
1891
    LANGUAGE sql STABLE
1892
    AS $_$
1893
SELECT util.eval2val(
1894
$$SELECT NOT EXISTS( -- there is no row that is != 1
1895
	SELECT NULL
1896
	FROM $$||$1||$$
1897
	WHERE $$||quote_ident(freq_col)||$$ IS DISTINCT FROM 1
1898
	LIMIT 1
1899
)
1900
$$, NULL::boolean)
1901
$_$;
1902
1903
1904
--
1905 12661 aaronmk
-- Name: freq_always_1(regclass[], text); Type: FUNCTION; Schema: util; Owner: -
1906
--
1907
1908
CREATE FUNCTION freq_always_1(tables regclass[], freq_col text DEFAULT 'copies'::text) RETURNS boolean
1909
    LANGUAGE sql STABLE
1910
    AS $_$
1911
SELECT bool_and(util.freq_always_1(table_, $2)) FROM unnest($1) table_
1912
$_$;
1913
1914
1915
--
1916 11655 aaronmk
-- Name: grants_users(); Type: FUNCTION; Schema: util; Owner: -
1917
--
1918
1919
CREATE FUNCTION grants_users() RETURNS SETOF text
1920
    LANGUAGE sql IMMUTABLE
1921
    AS $$
1922
VALUES ('bien_read'), ('public_')
1923
$$;
1924
1925
1926
--
1927 8183 aaronmk
-- Name: has_prefix(text, text); Type: FUNCTION; Schema: util; Owner: -
1928 8085 aaronmk
--
1929
1930
CREATE FUNCTION has_prefix(prefix text, str text) RETURNS boolean
1931 10388 aaronmk
    LANGUAGE sql IMMUTABLE
1932 8085 aaronmk
    AS $_$
1933
SELECT substring($2 for length($1)) = $1
1934
$_$;
1935
1936
1937
--
1938 12296 aaronmk
-- Name: has_single_row(regclass); Type: FUNCTION; Schema: util; Owner: -
1939
--
1940
1941
CREATE FUNCTION has_single_row(table_ regclass) RETURNS boolean
1942
    LANGUAGE sql STABLE
1943
    AS $_$
1944
SELECT util.eval2val($$SELECT COUNT(*) = 1 FROM $$||$1, NULL::boolean)
1945
$_$;
1946
1947
1948
--
1949 10307 aaronmk
-- Name: hstore(text[], text); Type: FUNCTION; Schema: util; Owner: -
1950
--
1951
1952
CREATE FUNCTION hstore(keys text[], value text) RETURNS hstore
1953
    LANGUAGE sql IMMUTABLE
1954
    AS $_$
1955 10324 aaronmk
SELECT hstore(util.fix_array($1), util.array_fill($2, util.array_length($1)))
1956 10307 aaronmk
$_$;
1957
1958
1959
--
1960
-- Name: FUNCTION hstore(keys text[], value text); Type: COMMENT; Schema: util; Owner: -
1961
--
1962
1963 12235 aaronmk
COMMENT ON FUNCTION hstore(keys text[], value text) IS '
1964
avoids repeating the same value for each key
1965
';
1966 10307 aaronmk
1967
1968
--
1969 12218 aaronmk
-- Name: ifnull(anyelement, anyelement); Type: FUNCTION; Schema: util; Owner: -
1970
--
1971
1972
CREATE FUNCTION ifnull(value anyelement, null_ anyelement) RETURNS anyelement
1973
    LANGUAGE sql IMMUTABLE
1974
    AS $_$
1975 12222 aaronmk
SELECT COALESCE($1, $2)
1976 12218 aaronmk
$_$;
1977
1978
1979
--
1980
-- Name: FUNCTION ifnull(value anyelement, null_ anyelement); Type: COMMENT; Schema: util; Owner: -
1981
--
1982
1983 12235 aaronmk
COMMENT ON FUNCTION ifnull(value anyelement, null_ anyelement) IS '
1984
equivalent to MySQL''s IFNULL() (Postgres auto-lowercases the name)
1985
';
1986 12218 aaronmk
1987
1988
--
1989 13452 aaronmk
-- Name: in_reverse(anyarray); Type: FUNCTION; Schema: util; Owner: -
1990
--
1991
1992
CREATE FUNCTION in_reverse("array" anyarray) RETURNS SETOF anyelement
1993
    LANGUAGE sql IMMUTABLE
1994
    AS $_$
1995 13490 aaronmk
SELECT elem FROM unnest($1) elem ORDER BY row_number() OVER () DESC
1996 13452 aaronmk
$_$;
1997
1998
1999
--
2000 12285 aaronmk
-- Name: inherit(regclass, regclass); Type: FUNCTION; Schema: util; Owner: -
2001
--
2002
2003
CREATE FUNCTION inherit(derived regclass, base regclass) RETURNS void
2004
    LANGUAGE sql
2005
    AS $_$
2006
SELECT util.eval($$ALTER TABLE $$||$1||$$ INHERIT $$||$2)
2007
$_$;
2008
2009
2010
--
2011 13136 aaronmk
-- Name: is_castable(text, anyelement); Type: FUNCTION; Schema: util; Owner: -
2012
--
2013
2014
CREATE FUNCTION is_castable(value text, ret_type_null anyelement) RETURNS boolean
2015
    LANGUAGE plpgsql IMMUTABLE
2016
    AS $$
2017
BEGIN
2018
	PERFORM util.cast(value, ret_type_null);
2019 13139 aaronmk
	-- must happen *after* cast check, because NULL is not valid for some types
2020
	IF value IS NULL THEN RETURN NULL; END IF; -- pass NULL through
2021 13136 aaronmk
	RETURN true;
2022
EXCEPTION
2023 13493 aaronmk
WHEN   data_exception
2024 13564 aaronmk
	OR invalid_schema_name -- eg. 'pg_temp.__'::regclass
2025 13493 aaronmk
	OR syntax_error_or_access_rule_violation -- eg. ::regclass
2026
	THEN
2027
	RETURN false;
2028 13136 aaronmk
END;
2029
$$;
2030
2031
2032
--
2033
-- Name: FUNCTION is_castable(value text, ret_type_null anyelement); Type: COMMENT; Schema: util; Owner: -
2034
--
2035
2036
COMMENT ON FUNCTION is_castable(value text, ret_type_null anyelement) IS '
2037 13139 aaronmk
passes NULL through. however, if NULL is not valid for the type, false will be
2038
returned instead.
2039
2040 13136 aaronmk
ret_type_null: NULL::ret_type
2041
';
2042
2043
2044
--
2045 10137 aaronmk
-- Name: is_constant(col_ref); Type: FUNCTION; Schema: util; Owner: -
2046
--
2047
2048
CREATE FUNCTION is_constant(col col_ref) RETURNS boolean
2049 12446 aaronmk
    LANGUAGE sql STABLE
2050 10137 aaronmk
    AS $_$
2051 12789 aaronmk
SELECT COALESCE(util.col_comment($1) LIKE '
2052
constant
2053
%', false)
2054 10137 aaronmk
$_$;
2055
2056
2057
--
2058 11659 aaronmk
-- Name: is_empty(anyarray); Type: FUNCTION; Schema: util; Owner: -
2059
--
2060
2061
CREATE FUNCTION is_empty("array" anyarray) RETURNS boolean
2062
    LANGUAGE sql IMMUTABLE
2063
    AS $_$
2064
SELECT util.array_length($1) = 0
2065
$_$;
2066
2067
2068
--
2069 12457 aaronmk
-- Name: is_explain(text); Type: FUNCTION; Schema: util; Owner: -
2070
--
2071
2072
CREATE FUNCTION is_explain(sql text) RETURNS boolean
2073
    LANGUAGE sql IMMUTABLE
2074
    AS $_$
2075
SELECT upper(util.first_word($1)) = 'EXPLAIN'
2076
$_$;
2077
2078
2079
--
2080 12451 aaronmk
-- Name: is_explainable(text); Type: FUNCTION; Schema: util; Owner: -
2081
--
2082
2083
CREATE FUNCTION is_explainable(sql text) RETURNS boolean
2084
    LANGUAGE sql IMMUTABLE
2085
    AS $_$
2086
SELECT upper(util.first_word($1)) = ANY(
2087
'{SELECT,INSERT,UPDATE,DELETE,VALUES,EXECUTE,DECLARE}'::text[]
2088
/*from http://www.postgresql.org/docs/9.3/static/sql-explain.html#AEN77691*/
2089
)
2090
$_$;
2091
2092
2093
--
2094 10391 aaronmk
-- Name: is_more_complete_than(anyelement, anyelement); Type: FUNCTION; Schema: util; Owner: -
2095
--
2096
2097
CREATE FUNCTION is_more_complete_than("left" anyelement, "right" anyelement) RETURNS boolean
2098
    LANGUAGE sql IMMUTABLE
2099
    AS $_$
2100
SELECT $1 IS NOT DISTINCT FROM $2 OR ($1 IS NOT NULL AND $2 IS NULL)
2101
$_$;
2102
2103
2104
--
2105 10613 aaronmk
-- Name: is_populated_more_often_than(anyelement, anyelement); Type: FUNCTION; Schema: util; Owner: -
2106
--
2107
2108
CREATE FUNCTION is_populated_more_often_than("left" anyelement, "right" anyelement) RETURNS boolean
2109
    LANGUAGE sql IMMUTABLE
2110
    AS $_$
2111
SELECT $1 IS NOT NULL >= $2 IS NOT NULL -- true > false
2112
$_$;
2113
2114
2115
--
2116 12480 aaronmk
-- Name: is_set_stmt(text); Type: FUNCTION; Schema: util; Owner: -
2117
--
2118
2119
CREATE FUNCTION is_set_stmt(sql text) RETURNS boolean
2120
    LANGUAGE sql IMMUTABLE
2121
    AS $_$
2122
SELECT upper(util.first_word($1)) = 'SET'
2123
$_$;
2124
2125
2126
--
2127 12330 aaronmk
-- Name: is_table(regclass); Type: FUNCTION; Schema: util; Owner: -
2128
--
2129
2130
CREATE FUNCTION is_table(relation regclass) RETURNS boolean
2131 12332 aaronmk
    LANGUAGE sql STABLE
2132 12330 aaronmk
    AS $_$
2133
SELECT relkind = 'r' FROM pg_class WHERE oid = $1
2134
$_$;
2135
2136
2137
--
2138 12329 aaronmk
-- Name: is_view(regclass); Type: FUNCTION; Schema: util; Owner: -
2139
--
2140
2141
CREATE FUNCTION is_view(relation regclass) RETURNS boolean
2142 12332 aaronmk
    LANGUAGE sql STABLE
2143 12329 aaronmk
    AS $_$
2144
SELECT relkind = 'v' FROM pg_class WHERE oid = $1
2145
$_$;
2146
2147
2148
--
2149 8183 aaronmk
-- Name: join_strs_transform(text, text, text); Type: FUNCTION; Schema: util; Owner: -
2150 4009 aaronmk
--
2151
2152 4053 aaronmk
CREATE FUNCTION join_strs_transform(state text, value text, delim text) RETURNS text
2153 12444 aaronmk
    LANGUAGE sql IMMUTABLE STRICT
2154 4009 aaronmk
    AS $_$
2155 4054 aaronmk
SELECT $1 || $3 || $2
2156 2595 aaronmk
$_$;
2157
2158
2159
--
2160 12444 aaronmk
-- Name: FUNCTION join_strs_transform(state text, value text, delim text); Type: COMMENT; Schema: util; Owner: -
2161
--
2162
2163
COMMENT ON FUNCTION join_strs_transform(state text, value text, delim text) IS '
2164
must be declared STRICT to use the special handling of STRICT aggregating functions
2165
';
2166
2167
2168
--
2169 12436 aaronmk
-- Name: keys(anyelement); Type: FUNCTION; Schema: util; Owner: -
2170
--
2171
2172
CREATE FUNCTION keys(value anyelement) RETURNS anyelement
2173
    LANGUAGE sql IMMUTABLE
2174
    AS $_$
2175
SELECT $1 -- compare on the entire value
2176
$_$;
2177
2178
2179
--
2180 10989 aaronmk
-- Name: limit2row_num(integer, integer, integer); Type: FUNCTION; Schema: util; Owner: -
2181 10985 aaronmk
--
2182
2183 10989 aaronmk
CREATE FUNCTION limit2row_num(limit_ integer, offset_ integer DEFAULT NULL::integer, min_row_num integer DEFAULT 1) RETURNS integer
2184 10985 aaronmk
    LANGUAGE sql IMMUTABLE
2185
    AS $_$
2186 10989 aaronmk
SELECT COALESCE(util.offset2row_num($2, $3) + $1 - 1, 2147483647)
2187 10985 aaronmk
$_$;
2188
2189
2190
--
2191 13384 aaronmk
-- Name: loop_ignore_errors(text, text, anyelement); Type: FUNCTION; Schema: util; Owner: -
2192
--
2193
2194
CREATE FUNCTION loop_ignore_errors(iter_sql text, loop_body_sql text, loop_type_null anyelement DEFAULT NULL::text) RETURNS void
2195
    LANGUAGE plpgsql
2196
    AS $$
2197
DECLARE
2198
	errors_ct integer = 0;
2199
	loop_var loop_type_null%TYPE;
2200
BEGIN
2201
	FOR loop_var IN SELECT * FROM util.eval2set(iter_sql, loop_type_null)
2202
	LOOP
2203
		BEGIN
2204
			EXECUTE loop_body_sql USING loop_var;
2205
		EXCEPTION
2206
		WHEN OTHERS THEN
2207
			errors_ct = errors_ct+1;
2208
			PERFORM util.raise_error_warning(SQLERRM);
2209
		END;
2210
	END LOOP;
2211
	IF errors_ct > 0 THEN
2212
		-- can't raise exception because this would roll back the transaction
2213
		PERFORM util.raise_error_warning('there were '||errors_ct
2214
			||' errors: see the WARNINGs for details');
2215
	END IF;
2216
END;
2217
$$;
2218
2219
2220
--
2221 12275 aaronmk
-- Name: ltrim_nl(text); Type: FUNCTION; Schema: util; Owner: -
2222
--
2223
2224
CREATE FUNCTION ltrim_nl(str text) RETURNS text
2225
    LANGUAGE sql IMMUTABLE
2226
    AS $_$
2227
SELECT ltrim($1, $$
2228
$$)
2229
$_$;
2230
2231
2232
--
2233 10110 aaronmk
-- Name: map_filter_insert(); Type: FUNCTION; Schema: util; Owner: -
2234
--
2235
2236
CREATE FUNCTION map_filter_insert() RETURNS trigger
2237
    LANGUAGE plpgsql
2238
    AS $$
2239
BEGIN
2240
	IF new."from" LIKE ':%' THEN RETURN NULL; END IF; -- exclude metadata values
2241
	RETURN new;
2242
END;
2243
$$;
2244
2245
2246
--
2247 8183 aaronmk
-- Name: map_get(regclass, text); Type: FUNCTION; Schema: util; Owner: -
2248 8146 aaronmk
--
2249
2250
CREATE FUNCTION map_get(map regclass, key text) RETURNS text
2251
    LANGUAGE plpgsql STABLE STRICT
2252
    AS $_$
2253
DECLARE
2254
    value text;
2255
BEGIN
2256
    EXECUTE $$SELECT "to" FROM $$||map||$$ WHERE "from" = $1$$
2257 8149 aaronmk
        INTO value USING key;
2258 8146 aaronmk
    RETURN value;
2259
END;
2260
$_$;
2261
2262
2263
--
2264 10358 aaronmk
-- Name: map_nulls(text[], anyelement); Type: FUNCTION; Schema: util; Owner: -
2265 10325 aaronmk
--
2266
2267 10358 aaronmk
CREATE FUNCTION map_nulls(nulls text[], value anyelement) RETURNS anyelement
2268 10353 aaronmk
    LANGUAGE sql IMMUTABLE
2269 10325 aaronmk
    AS $_$
2270 10374 aaronmk
SELECT util._map(util.nulls_map($1), $2)
2271 10325 aaronmk
$_$;
2272
2273
2274
--
2275 10359 aaronmk
-- Name: FUNCTION map_nulls(nulls text[], value anyelement); Type: COMMENT; Schema: util; Owner: -
2276
--
2277
2278 12235 aaronmk
COMMENT ON FUNCTION map_nulls(nulls text[], value anyelement) IS '
2279
due to dynamic inlining[1], this is just as fast as util._map() which it wraps[2].
2280 10359 aaronmk
2281
[1] inlining of function calls, which is different from constant folding
2282
[2] _map()''s profiling query
2283
SELECT util._map(''"1"=>NULL, "2"=>NULL, "3"=>NULL, *=>*'', v) FROM unnest(array_fill(1, array[100000])) f (v)
2284
and map_nulls()''s profiling query
2285
SELECT util.map_nulls(array[1, 2, 3]::text[], v) FROM unnest(array_fill(1, array[100000])) f (v)
2286 10375 aaronmk
both take ~920 ms.
2287 12235 aaronmk
also, /inputs/REMIB/Specimen/postprocess.sql > country takes the same amount of time (56000 ms) to build with map_nulls() as with a literal hstore.
2288
';
2289 10359 aaronmk
2290
2291
--
2292 8183 aaronmk
-- Name: map_values(regclass); Type: FUNCTION; Schema: util; Owner: -
2293 8150 aaronmk
--
2294
2295
CREATE FUNCTION map_values(map regclass) RETURNS SETOF text
2296
    LANGUAGE plpgsql STABLE STRICT
2297
    AS $_$
2298
BEGIN
2299
    RETURN QUERY EXECUTE $$SELECT "to" FROM $$||map;
2300
END;
2301
$_$;
2302
2303
2304
--
2305 12228 aaronmk
-- Name: materialize_query(text, text); Type: FUNCTION; Schema: util; Owner: -
2306
--
2307
2308 12262 aaronmk
CREATE FUNCTION materialize_query(table_esc text, sql text) RETURNS void
2309 12228 aaronmk
    LANGUAGE sql
2310
    AS $_$
2311 12262 aaronmk
SELECT util.create_if_not_exists($$CREATE TABLE $$||$1||$$ AS
2312 12321 aaronmk
$$||util.ltrim_nl($2));
2313
-- make sure the created table has the correct estimated row count
2314
SELECT util.analyze_($1);
2315 12470 aaronmk
2316
SELECT util.append_comment($1, '
2317
contents generated from:
2318 13397 aaronmk
'||util.ltrim_nl(util.runnable_sql($2))||';
2319 12470 aaronmk
');
2320 12228 aaronmk
$_$;
2321
2322
2323
--
2324 12262 aaronmk
-- Name: FUNCTION materialize_query(table_esc text, sql text); Type: COMMENT; Schema: util; Owner: -
2325 12228 aaronmk
--
2326
2327 12262 aaronmk
COMMENT ON FUNCTION materialize_query(table_esc text, sql text) IS '
2328 12235 aaronmk
idempotent
2329
';
2330 12228 aaronmk
2331
2332
--
2333 12234 aaronmk
-- Name: materialize_view(text, regclass); Type: FUNCTION; Schema: util; Owner: -
2334
--
2335
2336 12262 aaronmk
CREATE FUNCTION materialize_view(table_esc text, view_ regclass) RETURNS void
2337 12234 aaronmk
    LANGUAGE sql
2338
    AS $_$
2339
SELECT util.materialize_query($1, $$SELECT * FROM $$||$2)
2340
$_$;
2341
2342
2343
--
2344 12262 aaronmk
-- Name: FUNCTION materialize_view(table_esc text, view_ regclass); Type: COMMENT; Schema: util; Owner: -
2345 12234 aaronmk
--
2346
2347 12262 aaronmk
COMMENT ON FUNCTION materialize_view(table_esc text, view_ regclass) IS '
2348 12235 aaronmk
idempotent
2349
';
2350 12234 aaronmk
2351
2352
--
2353 8190 aaronmk
-- Name: mk_const_col(col_ref, anyelement); Type: FUNCTION; Schema: util; Owner: -
2354
--
2355
2356
CREATE FUNCTION mk_const_col(col col_ref, value anyelement) RETURNS void
2357 12446 aaronmk
    LANGUAGE sql
2358 8190 aaronmk
    AS $_$
2359 10135 aaronmk
SELECT util.create_if_not_exists($$
2360
ALTER TABLE $$||$1.table_||$$ ADD COLUMN $$
2361 8190 aaronmk
||quote_ident($1.name)||$$ $$||pg_typeof($2)||util.type_qual($2)||$$ DEFAULT $$
2362 10135 aaronmk
||quote_literal($2)||$$;
2363 12235 aaronmk
COMMENT ON COLUMN $$||$1.table_||$$.$$||quote_ident($1.name)||$$ IS '
2364
constant
2365
';
2366 10135 aaronmk
$$)
2367 8190 aaronmk
$_$;
2368
2369
2370
--
2371
-- Name: FUNCTION mk_const_col(col col_ref, value anyelement); Type: COMMENT; Schema: util; Owner: -
2372
--
2373
2374 12235 aaronmk
COMMENT ON FUNCTION mk_const_col(col col_ref, value anyelement) IS '
2375
idempotent
2376
';
2377 8190 aaronmk
2378
2379
--
2380 10296 aaronmk
-- Name: mk_derived_col(col_ref, text, boolean); Type: FUNCTION; Schema: util; Owner: -
2381 8187 aaronmk
--
2382
2383 10296 aaronmk
CREATE FUNCTION mk_derived_col(col col_ref, expr text, overwrite boolean DEFAULT false) RETURNS void
2384 8187 aaronmk
    LANGUAGE plpgsql STRICT
2385
    AS $_$
2386
DECLARE
2387
    type regtype = util.typeof(expr, col.table_::text::regtype);
2388
    col_name_sql text = quote_ident(col.name);
2389
BEGIN
2390 10296 aaronmk
    PERFORM util.create_if_not_exists((CASE WHEN overwrite THEN '' ELSE $$
2391
ALTER TABLE $$||col.table_||$$ ADD   COLUMN $$||col_name_sql||$$      $$||type||$$;$$ END)||$$
2392 8187 aaronmk
ALTER TABLE $$||col.table_||$$ ALTER COLUMN $$||col_name_sql||$$ TYPE $$||type||$$ USING
2393
$$||expr||$$;
2394
$$);
2395
END;
2396
$_$;
2397
2398
2399
--
2400 10296 aaronmk
-- Name: FUNCTION mk_derived_col(col col_ref, expr text, overwrite boolean); Type: COMMENT; Schema: util; Owner: -
2401 8188 aaronmk
--
2402
2403 12235 aaronmk
COMMENT ON FUNCTION mk_derived_col(col col_ref, expr text, overwrite boolean) IS '
2404
idempotent
2405
';
2406 8188 aaronmk
2407
2408
--
2409 12554 aaronmk
-- Name: mk_diff_query(text, text, text, text, text); Type: FUNCTION; Schema: util; Owner: -
2410 12475 aaronmk
--
2411
2412 12554 aaronmk
CREATE FUNCTION mk_diff_query(left_ text, right_ text, cols text DEFAULT 'left_, right_'::text, join_cond text DEFAULT 'left_ %== right_ -- refer to EXPLAIN output for expansion of %=='::text, filter text DEFAULT 'left_ IS DISTINCT FROM right_'::text) RETURNS text
2413 12475 aaronmk
    LANGUAGE sql IMMUTABLE
2414
    AS $_$
2415
SELECT
2416 12478 aaronmk
$$SELECT
2417 12554 aaronmk
$$||$3||$$
2418 12555 aaronmk
FROM      $$||$1||$$ left_
2419 12554 aaronmk
FULL JOIN $$||$2||$$ right_
2420
ON $$||$4||$$
2421
WHERE $$||$5||$$
2422 12475 aaronmk
ORDER BY left_, right_
2423
$$
2424
$_$;
2425
2426
2427
--
2428 13515 aaronmk
-- Name: mk_drop_from_create(text); Type: FUNCTION; Schema: util; Owner: -
2429
--
2430
2431
CREATE FUNCTION mk_drop_from_create(create_cmd text) RETURNS text
2432
    LANGUAGE sql IMMUTABLE
2433
    AS $_$
2434 13516 aaronmk
SELECT $$DROP $$||(util.regexp_match($1,
2435 13603 aaronmk
-- match first CREATE, *if* no DROP came before it
2436 13608 aaronmk
'(?m)\A(?:^(?!DROP\y).*\n)*?^CREATE(?: OR REPLACE)? ((?:)??[[:upper:]]+ .*?)(?: AS(?: (?:SELECT\y.*)?)?)?$'
2437 13515 aaronmk
	/* (?:)?? makes the surrounding () group non-greedy, so that (?: AS ?)?
2438
	works properly (due to nonstandard Postgres regexp behavior:
2439
	http://www.postgresql.org/docs/9.3/static/functions-matching.html#POSIX-MATCHING-RULES) */
2440 13603 aaronmk
))[1]||$$;$$
2441 13515 aaronmk
$_$;
2442
2443
2444
--
2445 12564 aaronmk
-- Name: mk_keys_func(regtype); Type: FUNCTION; Schema: util; Owner: -
2446
--
2447
2448
CREATE FUNCTION mk_keys_func(type regtype) RETURNS void
2449 12591 aaronmk
    LANGUAGE sql
2450 12564 aaronmk
    AS $_$
2451 12570 aaronmk
-- keys()
2452 12564 aaronmk
SELECT util.mk_keys_func($1, ARRAY(
2453
SELECT col FROM util.typed_cols($1) col
2454
WHERE (col).type != ANY('{bigint}'::regtype[]) -- not a count col
2455 12570 aaronmk
));
2456
2457 12571 aaronmk
-- values_()
2458 12570 aaronmk
SELECT util.mk_keys_func($1, COALESCE(
2459
	NULLIF(ARRAY(
2460
	SELECT col FROM util.typed_cols($1) col
2461
	WHERE (col).type = ANY('{bigint}'::regtype[]) -- is a count col
2462
	), ARRAY[]::util.col_cast[])
2463
, ARRAY(SELECT util.typed_cols($1))) -- no count cols, so use all cols
2464 12571 aaronmk
, 'values_');
2465 12564 aaronmk
$_$;
2466
2467
2468
--
2469 12569 aaronmk
-- Name: mk_keys_func(regtype, col_cast[], text); Type: FUNCTION; Schema: util; Owner: -
2470 12561 aaronmk
--
2471
2472 12569 aaronmk
CREATE FUNCTION mk_keys_func(type regtype, cols col_cast[], name text DEFAULT 'keys'::text) RETURNS void
2473 12591 aaronmk
    LANGUAGE sql
2474 12561 aaronmk
    AS $_$
2475 12567 aaronmk
SELECT util.create_if_not_exists($$
2476 12577 aaronmk
CREATE TYPE $$||util.prefixed_name($3||'_', $1)||$$ AS
2477
($$||util.mk_typed_cols_list($2)||$$);
2478 12671 aaronmk
COMMENT ON TYPE $$||util.prefixed_name($3||'_', $1)||$$ IS '
2479
autogenerated
2480
';
2481 12594 aaronmk
$$);
2482 12577 aaronmk
2483 12594 aaronmk
SELECT util.mk_keys_func($1, util.prefixed_name($3||'_', $1)::regtype, $3);
2484
$_$;
2485
2486
2487
--
2488
-- Name: mk_keys_func(regtype, regtype, text); Type: FUNCTION; Schema: util; Owner: -
2489
--
2490
2491
CREATE FUNCTION mk_keys_func(type regtype, return_type regtype, name text DEFAULT 'keys'::text) RETURNS void
2492
    LANGUAGE sql
2493
    AS $_$
2494
SELECT util.create_if_not_exists($$
2495 12581 aaronmk
CREATE FUNCTION $$||util.qual_name(util.schema($1), $3)||$$(value $$
2496 12577 aaronmk
||util.qual_name($1)||$$)
2497 12594 aaronmk
  RETURNS $$||util.qual_name($2)||$$ AS
2498 12561 aaronmk
$BODY1$
2499 12577 aaronmk
SELECT ROW($$||
2500 12594 aaronmk
(SELECT COALESCE(string_agg($$$1.$$||quote_ident((col).col_name), ', '), '')
2501
FROM util.typed_cols($2) col) ||$$)::$$||util.qual_name($2)||$$
2502 12561 aaronmk
$BODY1$
2503
  LANGUAGE sql IMMUTABLE
2504
  COST 100;
2505 12594 aaronmk
$$);
2506 12561 aaronmk
$_$;
2507
2508
2509
--
2510 8183 aaronmk
-- Name: mk_map_table(text); Type: FUNCTION; Schema: util; Owner: -
2511 8139 aaronmk
--
2512
2513
CREATE FUNCTION mk_map_table(table_ text) RETURNS void
2514 12446 aaronmk
    LANGUAGE sql
2515 8139 aaronmk
    AS $_$
2516 8183 aaronmk
SELECT util.create_if_not_exists($$
2517 8141 aaronmk
CREATE TABLE $$||$1||$$
2518 8139 aaronmk
(
2519 8183 aaronmk
    LIKE util.map INCLUDING ALL
2520 10110 aaronmk
);
2521
2522
CREATE TRIGGER map_filter_insert
2523
  BEFORE INSERT
2524
  ON $$||$1||$$
2525
  FOR EACH ROW
2526
  EXECUTE PROCEDURE util.map_filter_insert();
2527 8141 aaronmk
$$)
2528 8139 aaronmk
$_$;
2529
2530
2531
--
2532 12725 aaronmk
-- Name: mk_not_null(text); Type: FUNCTION; Schema: util; Owner: -
2533
--
2534
2535
CREATE FUNCTION mk_not_null(text) RETURNS text
2536
    LANGUAGE sql IMMUTABLE
2537
    AS $_$
2538
SELECT COALESCE($1, '<NULL>')
2539
$_$;
2540
2541
2542
--
2543 12556 aaronmk
-- Name: mk_out_params(col_cast[]); Type: FUNCTION; Schema: util; Owner: -
2544
--
2545
2546
CREATE FUNCTION mk_out_params(cols col_cast[]) RETURNS text
2547
    LANGUAGE sql IMMUTABLE
2548
    AS $_$
2549 12559 aaronmk
SELECT COALESCE(string_agg($$, OUT $$||(unnest).col_name||$$ $$||
2550
util.qual_name((unnest).type), ''), '')
2551 12556 aaronmk
FROM unnest($1)
2552
$_$;
2553
2554
2555
--
2556 12236 aaronmk
-- Name: mk_search_path(text[]); Type: FUNCTION; Schema: util; Owner: -
2557
--
2558
2559
CREATE FUNCTION mk_search_path(VARIADIC schemas text[]) RETURNS text
2560
    LANGUAGE sql IMMUTABLE
2561
    AS $_$
2562 12486 aaronmk
SELECT string_agg(quote_ident(unnest), ', ') FROM unnest($1||'util'::text)
2563 12236 aaronmk
$_$;
2564
2565
2566
--
2567 12486 aaronmk
-- Name: FUNCTION mk_search_path(VARIADIC schemas text[]); Type: COMMENT; Schema: util; Owner: -
2568
--
2569
2570
COMMENT ON FUNCTION mk_search_path(VARIADIC schemas text[]) IS '
2571
auto-appends util to the search_path to enable use of util operators
2572
';
2573
2574
2575
--
2576 13474 aaronmk
-- Name: mk_set_comment(regclass, text); Type: FUNCTION; Schema: util; Owner: -
2577
--
2578
2579
CREATE FUNCTION mk_set_comment(table_ regclass, comment text) RETURNS text
2580
    LANGUAGE sql STABLE
2581
    AS $_$
2582 13483 aaronmk
SELECT COALESCE($$COMMENT ON $$||util.relation_type($1)||$$ $$||$1||$$ IS $$
2583 13481 aaronmk
||quote_literal($2)/*pass NULL through*/||$$;$$, ''/*no comment*/)
2584 13474 aaronmk
$_$;
2585
2586
2587
--
2588 13504 aaronmk
-- Name: mk_set_relation_metadata(regclass); Type: FUNCTION; Schema: util; Owner: -
2589
--
2590
2591
CREATE FUNCTION mk_set_relation_metadata(relation regclass) RETURNS text
2592
    LANGUAGE sql STABLE
2593
    AS $_$
2594
SELECT util.show_grants_for($1)
2595
||util.show_set_comment($1)||$$
2596
$$
2597
$_$;
2598
2599
2600
--
2601 12467 aaronmk
-- Name: mk_set_search_path(boolean); Type: FUNCTION; Schema: util; Owner: -
2602
--
2603
2604
CREATE FUNCTION mk_set_search_path(for_printing boolean DEFAULT false) RETURNS text
2605
    LANGUAGE sql IMMUTABLE
2606
    AS $_$
2607
SELECT util.mk_set_search_path(current_setting('search_path'), $1)
2608
$_$;
2609
2610
2611
--
2612 12466 aaronmk
-- Name: mk_set_search_path(text, boolean); Type: FUNCTION; Schema: util; Owner: -
2613 12270 aaronmk
--
2614
2615 12466 aaronmk
CREATE FUNCTION mk_set_search_path(search_path text, for_printing boolean DEFAULT false) RETURNS text
2616 12270 aaronmk
    LANGUAGE sql IMMUTABLE
2617
    AS $_$
2618 12432 aaronmk
/* debug_print_return_value() needed because this function is used with EXECUTE
2619
rather than util.eval() (in order to affect the calling function), so the
2620
search_path would not otherwise be printed */
2621 12487 aaronmk
SELECT $$SET$$||util._if($2, $$ /*LOCAL*/$$::text, $$ LOCAL$$)
2622
||$$ search_path TO $$||$1
2623 12270 aaronmk
$_$;
2624
2625
2626
--
2627 10113 aaronmk
-- Name: mk_source_col(regclass); Type: FUNCTION; Schema: util; Owner: -
2628
--
2629
2630
CREATE FUNCTION mk_source_col(table_ regclass) RETURNS void
2631 12446 aaronmk
    LANGUAGE sql
2632 10113 aaronmk
    AS $_$
2633 12240 aaronmk
SELECT util.mk_const_col(($1, 'source'), util.schema($1))
2634 10113 aaronmk
$_$;
2635
2636
2637
--
2638
-- Name: FUNCTION mk_source_col(table_ regclass); Type: COMMENT; Schema: util; Owner: -
2639
--
2640
2641 12235 aaronmk
COMMENT ON FUNCTION mk_source_col(table_ regclass) IS '
2642
idempotent
2643
';
2644 10113 aaronmk
2645
2646
--
2647 11011 aaronmk
-- Name: mk_subset_by_row_num_func(regclass); Type: FUNCTION; Schema: util; Owner: -
2648
--
2649
2650
CREATE FUNCTION mk_subset_by_row_num_func(view_ regclass) RETURNS void
2651
    LANGUAGE plpgsql STRICT
2652
    AS $_$
2653
DECLARE
2654
	view_qual_name text = util.qual_name(view_);
2655
BEGIN
2656
	EXECUTE $$
2657
CREATE OR REPLACE FUNCTION $$||view_||$$(limit_ integer DEFAULT NULL::integer, offset_ integer DEFAULT NULL)
2658
  RETURNS SETOF $$||view_||$$ AS
2659
$BODY1$
2660
SELECT * FROM $$||view_qual_name||$$
2661
ORDER BY sort_col
2662
LIMIT $1 OFFSET $2
2663
$BODY1$
2664
  LANGUAGE sql STABLE
2665
  COST 100
2666
  ROWS 1000
2667
$$;
2668
2669
	PERFORM util.mk_subset_by_row_num_no_sort_func(view_);
2670
END;
2671
$_$;
2672
2673
2674
--
2675 8325 aaronmk
-- Name: mk_subset_by_row_num_func(regclass, text); Type: FUNCTION; Schema: util; Owner: -
2676
--
2677
2678
CREATE FUNCTION mk_subset_by_row_num_func(view_ regclass, row_num_col text) RETURNS void
2679
    LANGUAGE plpgsql STRICT
2680
    AS $_$
2681 10990 aaronmk
DECLARE
2682
	view_qual_name text = util.qual_name(view_);
2683
	row_num__min__fn text = util.esc_name__append('__row_num__min', view_qual_name);
2684 8325 aaronmk
BEGIN
2685
	EXECUTE $$
2686 10990 aaronmk
CREATE OR REPLACE FUNCTION $$||row_num__min__fn||$$()
2687
  RETURNS integer AS
2688
$BODY1$
2689
SELECT $$||quote_ident(row_num_col)||$$
2690
FROM $$||view_qual_name||$$
2691
ORDER BY $$||quote_ident(row_num_col)||$$ ASC
2692
LIMIT 1
2693
$BODY1$
2694
  LANGUAGE sql STABLE
2695
  COST 100;
2696
$$;
2697
2698
	EXECUTE $$
2699 8325 aaronmk
CREATE OR REPLACE FUNCTION $$||view_||$$(limit_ integer DEFAULT NULL::integer, offset_ integer DEFAULT NULL)
2700
  RETURNS SETOF $$||view_||$$ AS
2701
$BODY1$
2702 10990 aaronmk
SELECT * FROM $$||view_qual_name||$$
2703
WHERE $$||quote_ident(row_num_col)||$$ BETWEEN
2704
	util.offset2row_num(    $2, $$||row_num__min__fn||$$())
2705
AND util.limit2row_num ($1, $2, $$||row_num__min__fn||$$())
2706 10991 aaronmk
ORDER BY $$||quote_ident(row_num_col)||$$
2707 8325 aaronmk
$BODY1$
2708
  LANGUAGE sql STABLE
2709
  COST 100
2710
  ROWS 1000
2711
$$;
2712 11010 aaronmk
2713
	PERFORM util.mk_subset_by_row_num_no_sort_func(view_);
2714
END;
2715
$_$;
2716
2717
2718
--
2719
-- Name: mk_subset_by_row_num_no_sort_func(regclass); Type: FUNCTION; Schema: util; Owner: -
2720
--
2721
2722
CREATE FUNCTION mk_subset_by_row_num_no_sort_func(view_ regclass) RETURNS void
2723
    LANGUAGE plpgsql STRICT
2724
    AS $_$
2725
DECLARE
2726
	view_qual_name text = util.qual_name(view_);
2727
BEGIN
2728 8326 aaronmk
	EXECUTE $$
2729
CREATE OR REPLACE FUNCTION $$||view_||$$(no_sort boolean, limit_ integer DEFAULT NULL::integer, offset_ integer DEFAULT NULL)
2730
  RETURNS SETOF $$||view_||$$
2731
  SET enable_sort TO 'off'
2732
  AS
2733
$BODY1$
2734 10990 aaronmk
SELECT * FROM $$||view_qual_name||$$($2, $3)
2735 8326 aaronmk
$BODY1$
2736
  LANGUAGE sql STABLE
2737
  COST 100
2738
  ROWS 1000
2739
;
2740
COMMENT ON FUNCTION $$||view_||$$(no_sort boolean, limit_ integer, offset_ integer) IS '
2741
Use this for limit values greater than ~100,000 to avoid unwanted slow sorts.
2742
If you want to run EXPLAIN and get expanded output, use the regular subset
2743
function instead. (When a config param is set on a function, EXPLAIN produces
2744
just a function scan.)
2745
';
2746
$$;
2747 8325 aaronmk
END;
2748
$_$;
2749
2750
2751
--
2752 11010 aaronmk
-- Name: FUNCTION mk_subset_by_row_num_no_sort_func(view_ regclass); Type: COMMENT; Schema: util; Owner: -
2753
--
2754
2755 12235 aaronmk
COMMENT ON FUNCTION mk_subset_by_row_num_no_sort_func(view_ regclass) IS '
2756
creates subset function which turns off enable_sort
2757
';
2758 11010 aaronmk
2759
2760
--
2761 12576 aaronmk
-- Name: mk_typed_cols_list(col_cast[]); Type: FUNCTION; Schema: util; Owner: -
2762
--
2763
2764
CREATE FUNCTION mk_typed_cols_list(cols col_cast[]) RETURNS text
2765
    LANGUAGE sql IMMUTABLE
2766
    AS $_$
2767 12579 aaronmk
SELECT COALESCE(string_agg(quote_ident((unnest).col_name)||$$ $$||
2768 12576 aaronmk
util.qual_name((unnest).type), ', '), '')
2769
FROM unnest($1)
2770
$_$;
2771
2772
2773
--
2774 12242 aaronmk
-- Name: name(regclass); Type: FUNCTION; Schema: util; Owner: -
2775
--
2776
2777
CREATE FUNCTION name(table_ regclass) RETURNS text
2778
    LANGUAGE sql STABLE
2779
    AS $_$
2780
SELECT relname::text FROM pg_class WHERE oid = $1
2781
$_$;
2782
2783
2784
--
2785 8183 aaronmk
-- Name: name(regtype); Type: FUNCTION; Schema: util; Owner: -
2786 8083 aaronmk
--
2787
2788
CREATE FUNCTION name(type regtype) RETURNS text
2789 12446 aaronmk
    LANGUAGE sql STABLE
2790 8083 aaronmk
    AS $_$
2791
SELECT typname::text FROM pg_type WHERE oid = $1
2792
$_$;
2793
2794
2795
--
2796 12360 aaronmk
-- Name: name_was_truncated(text, integer); Type: FUNCTION; Schema: util; Owner: -
2797 12355 aaronmk
--
2798
2799 12360 aaronmk
CREATE FUNCTION name_was_truncated(name_ text, max_prefix_len integer DEFAULT 0) RETURNS boolean
2800 12355 aaronmk
    LANGUAGE sql IMMUTABLE
2801
    AS $_$
2802 12360 aaronmk
SELECT octet_length($1) >= util.namedatalen() - $2
2803 12355 aaronmk
$_$;
2804
2805
2806
--
2807 12354 aaronmk
-- Name: namedatalen(); Type: FUNCTION; Schema: util; Owner: -
2808
--
2809
2810
CREATE FUNCTION namedatalen() RETURNS integer
2811
    LANGUAGE sql IMMUTABLE
2812
    AS $$
2813
SELECT octet_length(repeat('_', 1024/*>63*/)::name::text)
2814
$$;
2815
2816
2817
--
2818 9958 aaronmk
-- Name: not_empty(anyarray); Type: FUNCTION; Schema: util; Owner: -
2819
--
2820
2821
CREATE FUNCTION not_empty(value anyarray) RETURNS boolean
2822
    LANGUAGE sql IMMUTABLE
2823
    AS $_$
2824 10329 aaronmk
SELECT $1 IS NOT NULL AND util.array_length($1) > 0
2825 9958 aaronmk
$_$;
2826
2827
2828
--
2829 9956 aaronmk
-- Name: not_null(anyelement); Type: FUNCTION; Schema: util; Owner: -
2830
--
2831
2832
CREATE FUNCTION not_null(value anyelement) RETURNS boolean
2833 9957 aaronmk
    LANGUAGE sql IMMUTABLE
2834 9956 aaronmk
    AS $_$
2835
SELECT $1 IS NOT NULL
2836
$_$;
2837
2838
2839
--
2840 10373 aaronmk
-- Name: nulls_map(text[]); Type: FUNCTION; Schema: util; Owner: -
2841
--
2842
2843
CREATE FUNCTION nulls_map(nulls text[]) RETURNS hstore
2844
    LANGUAGE sql IMMUTABLE
2845
    AS $_$
2846
SELECT util.hstore($1, NULL) || '*=>*'
2847
$_$;
2848
2849
2850
--
2851
-- Name: FUNCTION nulls_map(nulls text[]); Type: COMMENT; Schema: util; Owner: -
2852
--
2853
2854 12235 aaronmk
COMMENT ON FUNCTION nulls_map(nulls text[]) IS '
2855
for use with _map()
2856
';
2857 10373 aaronmk
2858
2859
--
2860 10989 aaronmk
-- Name: offset2row_num(integer, integer); Type: FUNCTION; Schema: util; Owner: -
2861 10984 aaronmk
--
2862
2863 10989 aaronmk
CREATE FUNCTION offset2row_num(offset_ integer, min_row_num integer DEFAULT 1) RETURNS integer
2864 10984 aaronmk
    LANGUAGE sql IMMUTABLE
2865
    AS $_$
2866 10989 aaronmk
SELECT $2 + COALESCE($1, 0)
2867 10984 aaronmk
$_$;
2868
2869
2870
--
2871 12659 aaronmk
-- Name: parent(regclass); Type: FUNCTION; Schema: util; Owner: -
2872
--
2873
2874
CREATE FUNCTION parent(table_ regclass) RETURNS regclass
2875
    LANGUAGE sql STABLE
2876
    AS $_$
2877
SELECT inhparent FROM pg_inherits WHERE inhrelid = $1
2878
$_$;
2879
2880
2881
--
2882 13637 aaronmk
-- Name: pg_get_viewdef(regclass); Type: FUNCTION; Schema: util; Owner: -
2883
--
2884
2885
CREATE FUNCTION pg_get_viewdef(view_ regclass) RETURNS text
2886
    LANGUAGE sql IMMUTABLE
2887
    AS $_$
2888
/* unexpand expanded * expressions. any list of 5+ cols from the same table is
2889
treated as a * expression. */
2890
SELECT regexp_replace(pg_catalog.pg_get_viewdef($1),
2891
'\y((?:"[^"]+"|\w+)\.)(?:"[^"]+"|\w+)'|| --1st col, which lacks separator before
2892
'(,[[:blank:]]*
2893
[[:blank:]]*)\1(?:"[^"]+"|\w+)'|| -- 2nd col, which has separator before
2894
'(?:\2\1(?:"[^"]+"|\w+)){4,}', -- later cols, w/ same table name and separator
2895
'\1*'/*prefix w/ table*/, 'g')
2896
$_$;
2897
2898
2899
--
2900 12651 aaronmk
-- Name: populate_table(regclass, text); Type: FUNCTION; Schema: util; Owner: -
2901
--
2902
2903
CREATE FUNCTION populate_table(table_ regclass, sql text) RETURNS void
2904
    LANGUAGE sql
2905
    AS $_$
2906
SELECT util.eval($$INSERT INTO $$||$1||$$
2907
$$||util.ltrim_nl($2));
2908
-- make sure the created table has the correct estimated row count
2909
SELECT util.analyze_($1);
2910
$_$;
2911
2912
2913
--
2914 12575 aaronmk
-- Name: prefixed_name(text, anyelement); Type: FUNCTION; Schema: util; Owner: -
2915
--
2916
2917
CREATE FUNCTION prefixed_name(prefix text, type anyelement) RETURNS text
2918
    LANGUAGE sql IMMUTABLE
2919
    AS $_$
2920
SELECT util.qual_name(util.schema($2), $1||util.name($2))
2921
$_$;
2922
2923
2924
--
2925 12494 aaronmk
-- Name: prepend_comment(regclass, text); Type: FUNCTION; Schema: util; Owner: -
2926
--
2927
2928
CREATE FUNCTION prepend_comment(table_ regclass, comment text) RETURNS void
2929
    LANGUAGE sql
2930
    AS $_$
2931
SELECT util.set_comment($1, concat($2, util.comment($1)))
2932
$_$;
2933
2934
2935
--
2936
-- Name: FUNCTION prepend_comment(table_ regclass, comment text); Type: COMMENT; Schema: util; Owner: -
2937
--
2938
2939
COMMENT ON FUNCTION prepend_comment(table_ regclass, comment text) IS '
2940
comment: must start and end with a newline
2941
';
2942
2943
2944
--
2945 12260 aaronmk
-- Name: qual_name(text[]); Type: FUNCTION; Schema: util; Owner: -
2946
--
2947
2948
CREATE FUNCTION qual_name(VARIADIC elems text[]) RETURNS text
2949
    LANGUAGE sql IMMUTABLE
2950
    AS $_$
2951
SELECT string_agg(quote_ident(unnest), '.') FROM unnest($1)
2952
$_$;
2953
2954
2955
--
2956 10988 aaronmk
-- Name: qual_name(regclass); Type: FUNCTION; Schema: util; Owner: -
2957
--
2958
2959
CREATE FUNCTION qual_name(table_ regclass) RETURNS text
2960 12446 aaronmk
    LANGUAGE sql STABLE
2961 12267 aaronmk
    SET search_path TO pg_temp
2962 10988 aaronmk
    AS $_$
2963 12267 aaronmk
SELECT $1::text
2964 10988 aaronmk
$_$;
2965
2966
2967
--
2968 12267 aaronmk
-- Name: qual_name(regtype); Type: FUNCTION; Schema: util; Owner: -
2969
--
2970
2971
CREATE FUNCTION qual_name(type regtype) RETURNS text
2972 12446 aaronmk
    LANGUAGE sql STABLE
2973 12267 aaronmk
    SET search_path TO pg_temp
2974
    AS $_$
2975
SELECT $1::text
2976
$_$;
2977
2978
2979
--
2980
-- Name: FUNCTION qual_name(type regtype); Type: COMMENT; Schema: util; Owner: -
2981
--
2982
2983
COMMENT ON FUNCTION qual_name(type regtype) IS '
2984
a type''s schema-qualified name
2985
';
2986
2987
2988
--
2989 12268 aaronmk
-- Name: qual_name(unknown); Type: FUNCTION; Schema: util; Owner: -
2990
--
2991
2992
CREATE FUNCTION qual_name(type unknown) RETURNS text
2993 12446 aaronmk
    LANGUAGE sql STABLE
2994 12268 aaronmk
    AS $_$
2995
SELECT util.qual_name($1::text::regtype)
2996
$_$;
2997
2998
2999
--
3000 12376 aaronmk
-- Name: quote_func_call(regprocedure, text[]); Type: FUNCTION; Schema: util; Owner: -
3001
--
3002
3003
CREATE FUNCTION quote_func_call(func regprocedure, VARIADIC args_esc text[]) RETURNS text
3004
    LANGUAGE sql IMMUTABLE
3005
    AS $_$
3006
SELECT util.quote_func_call($1::regproc::text, VARIADIC $2)
3007
$_$;
3008
3009
3010
--
3011
-- Name: quote_func_call(text, text[]); Type: FUNCTION; Schema: util; Owner: -
3012
--
3013
3014
CREATE FUNCTION quote_func_call(func_esc text, VARIADIC args_esc text[]) RETURNS text
3015
    LANGUAGE sql IMMUTABLE
3016
    AS $_$
3017
SELECT $1||'('||concat_ws(', ', VARIADIC $2)||')'
3018
$_$;
3019
3020
3021
--
3022 12371 aaronmk
-- Name: quote_typed(anyelement); Type: FUNCTION; Schema: util; Owner: -
3023
--
3024
3025
CREATE FUNCTION quote_typed(value anyelement) RETURNS text
3026
    LANGUAGE sql IMMUTABLE
3027
    AS $_$
3028 12437 aaronmk
SELECT quote_nullable($1)||$$::$$||util.qual_name(pg_typeof($1))
3029 12371 aaronmk
$_$;
3030
3031
3032
--
3033 12530 aaronmk
-- Name: raise(text, text); Type: FUNCTION; Schema: util; Owner: -
3034
--
3035
3036
CREATE FUNCTION raise(type text, msg text) RETURNS void
3037
    LANGUAGE sql IMMUTABLE
3038 12560 aaronmk
    AS $_X$
3039 12530 aaronmk
SELECT util.eval($$
3040
CREATE OR REPLACE FUNCTION pg_temp.__raise()
3041
  RETURNS void AS
3042 12560 aaronmk
-- $__BODY1$ in case msg contains $BODY1$ (in SQL)
3043
$__BODY1$
3044 12530 aaronmk
BEGIN
3045
	RAISE $$||$1||$$ USING MESSAGE = $$||quote_nullable($2)||$$;
3046
END;
3047 12560 aaronmk
$__BODY1$
3048 12530 aaronmk
  LANGUAGE plpgsql IMMUTABLE
3049
  COST 100;
3050 12532 aaronmk
$$, verbose_ := false);
3051 12530 aaronmk
3052 12532 aaronmk
SELECT util.eval($$SELECT pg_temp.__raise()$$, verbose_ := false);
3053 12560 aaronmk
$_X$;
3054 12530 aaronmk
3055
3056
--
3057 12533 aaronmk
-- Name: FUNCTION raise(type text, msg text); Type: COMMENT; Schema: util; Owner: -
3058
--
3059
3060
COMMENT ON FUNCTION raise(type text, msg text) IS '
3061
type: a log level from
3062
http://www.postgresql.org/docs/9.3/static/plpgsql-errors-and-messages.html
3063
or a condition name from
3064
http://www.postgresql.org/docs/9.3/static/errcodes-appendix.html
3065
';
3066
3067
3068
--
3069 12536 aaronmk
-- Name: raise_error_warning(text); Type: FUNCTION; Schema: util; Owner: -
3070 12311 aaronmk
--
3071
3072 12536 aaronmk
CREATE FUNCTION raise_error_warning(msg text) RETURNS void
3073 12441 aaronmk
    LANGUAGE sql IMMUTABLE
3074 12311 aaronmk
    AS $_$
3075 12536 aaronmk
SELECT util.raise('WARNING', 'ERROR:  '||$1)
3076 12311 aaronmk
$_$;
3077
3078
3079
--
3080 10116 aaronmk
-- Name: raise_undefined_column(col_ref); Type: FUNCTION; Schema: util; Owner: -
3081
--
3082
3083
CREATE FUNCTION raise_undefined_column(col col_ref) RETURNS text
3084
    LANGUAGE plpgsql IMMUTABLE STRICT
3085
    AS $$
3086
BEGIN
3087
	RAISE undefined_column USING MESSAGE = concat('undefined column: ', col.name);
3088
END;
3089
$$;
3090
3091
3092
--
3093 13512 aaronmk
-- Name: recreate(text, text[]); Type: FUNCTION; Schema: util; Owner: -
3094
--
3095
3096
CREATE FUNCTION recreate(cmd text, users text[] DEFAULT NULL::text[]) RETURNS void
3097
    LANGUAGE plpgsql
3098
    AS $_$
3099
DECLARE
3100
	PG_EXCEPTION_DETAIL text;
3101
	restore_views_info util.restore_views_info;
3102
BEGIN
3103
	restore_views_info = util.save_drop_views(users);
3104 13517 aaronmk
3105
	-- trigger the dependent_objects_still_exist exception
3106 13604 aaronmk
	PERFORM util.eval(COALESCE(util.mk_drop_from_create(cmd), '')||cmd);
3107 13517 aaronmk
		-- *not* CASCADE; it must trigger an exception
3108
3109 13512 aaronmk
	PERFORM util.restore_views(restore_views_info);
3110
EXCEPTION
3111
WHEN dependent_objects_still_exist THEN
3112
	IF users IS NOT NULL THEN RAISE; END IF; -- save_drop_views() didn't fix it
3113
	GET STACKED DIAGNOSTICS PG_EXCEPTION_DETAIL = PG_EXCEPTION_DETAIL;
3114
	users = array(SELECT * FROM util.regexp_matches_group(
3115
		PG_EXCEPTION_DETAIL, '(?m)^view (.*) depends on [[:lower:]]+ .*$'));
3116
		-- will be in forward dependency order
3117
	PERFORM util.debug_print_var('PG_EXCEPTION_DETAIL', PG_EXCEPTION_DETAIL);
3118
	PERFORM util.debug_print_var('users', users);
3119
	IF util.is_empty(users) THEN RAISE; END IF;
3120
	PERFORM util.recreate(cmd, users);
3121
END;
3122
$_$;
3123
3124
3125
--
3126
-- Name: FUNCTION recreate(cmd text, users text[]); Type: COMMENT; Schema: util; Owner: -
3127
--
3128
3129
COMMENT ON FUNCTION recreate(cmd text, users text[]) IS '
3130 13517 aaronmk
the appropriate drop statement will be added automatically.
3131
3132 13512 aaronmk
usage:
3133
SELECT util.recreate($$
3134 13524 aaronmk
CREATE VIEW schema.main_view AS _;
3135 13512 aaronmk
3136
-- manually restore views that need to be updated for the changes
3137 13524 aaronmk
CREATE VIEW schema.dependent_view AS _;
3138 13512 aaronmk
$$);
3139
3140
idempotent
3141
3142
users: not necessary to provide this because it will be autopopulated
3143
';
3144
3145
3146
--
3147 13525 aaronmk
-- Name: recreate_view(regclass, text, text); Type: FUNCTION; Schema: util; Owner: -
3148
--
3149
3150 13606 aaronmk
CREATE FUNCTION recreate_view(view_ regclass, view_query text DEFAULT NULL::text, dependent_view_changes text DEFAULT ''::text) RETURNS void
3151 13525 aaronmk
    LANGUAGE sql
3152
    AS $_$
3153
SELECT util.recreate($$
3154
CREATE VIEW $$||$1||$$ AS
3155 13606 aaronmk
$$||COALESCE($2, pg_get_viewdef($1))||$$;
3156 13525 aaronmk
$$||util.mk_set_relation_metadata($1)||$$
3157
3158
-- manually restore views that need to be updated for the changes
3159
$$||$3||$$
3160
$$);
3161
$_$;
3162
3163
3164
--
3165
-- Name: FUNCTION recreate_view(view_ regclass, view_query text, dependent_view_changes text); Type: COMMENT; Schema: util; Owner: -
3166
--
3167
3168
COMMENT ON FUNCTION recreate_view(view_ regclass, view_query text, dependent_view_changes text) IS '
3169
usage:
3170
SELECT util.recreate_view(''schema.main_view'', $$
3171
SELECT __
3172
$$, $$
3173
CREATE VIEW schema.dependent_view AS
3174
__;
3175
$$||util.mk_set_relation_metadata(''schema.dependent_view'')||$$
3176
$$);
3177
3178 13606 aaronmk
if view has already been modified:
3179
SELECT util.recreate_view(''schema.main_view'', dependent_view_changes := $$
3180
CREATE VIEW schema.dependent_view AS
3181
__;
3182
$$||util.mk_set_relation_metadata(''schema.dependent_view'')||$$
3183
$$);
3184
3185 13525 aaronmk
idempotent
3186
';
3187
3188
3189
--
3190 13514 aaronmk
-- Name: regexp_match(text, text); Type: FUNCTION; Schema: util; Owner: -
3191
--
3192
3193
CREATE FUNCTION regexp_match(str text, re text) RETURNS text[]
3194
    LANGUAGE sql IMMUTABLE
3195
    AS $_$
3196
SELECT match FROM regexp_matches($1, $2) match LIMIT 1/*only 1st match*/
3197
$_$;
3198
3199
3200
--
3201 11657 aaronmk
-- Name: regexp_matches_group(text, text, integer); Type: FUNCTION; Schema: util; Owner: -
3202
--
3203
3204
CREATE FUNCTION regexp_matches_group(str text, re text, group_ integer DEFAULT 1) RETURNS SETOF text
3205
    LANGUAGE sql IMMUTABLE
3206
    AS $_$
3207
SELECT regexp_matches[$3] FROM regexp_matches($1, $2, 'g')
3208
$_$;
3209
3210
3211
--
3212 12333 aaronmk
-- Name: regexp_quote(text); Type: FUNCTION; Schema: util; Owner: -
3213
--
3214
3215
CREATE FUNCTION regexp_quote(str text) RETURNS text
3216
    LANGUAGE sql IMMUTABLE
3217
    AS $_$
3218
SELECT regexp_replace($1, '\W', /*\char*/'\\\&', 'g')
3219
$_$;
3220
3221
3222
--
3223 12375 aaronmk
-- Name: regprocedure(text); Type: FUNCTION; Schema: util; Owner: -
3224
--
3225
3226
CREATE FUNCTION regprocedure(func text) RETURNS regprocedure
3227
    LANGUAGE sql IMMUTABLE
3228
    AS $_$
3229
SELECT (CASE WHEN right($1, 1) = ')'
3230 12377 aaronmk
THEN $1::regprocedure ELSE $1::regproc::regprocedure END)
3231 12375 aaronmk
$_$;
3232
3233
3234
--
3235 13492 aaronmk
-- Name: relation_exists(text); Type: FUNCTION; Schema: util; Owner: -
3236
--
3237
3238
CREATE FUNCTION relation_exists(relation text) RETURNS boolean
3239
    LANGUAGE sql STABLE
3240
    AS $_$
3241
SELECT $1 IS NOT NULL AND util.is_castable($1, NULL::regclass)
3242
$_$;
3243
3244
3245
--
3246 12344 aaronmk
-- Name: relation_type(regclass); Type: FUNCTION; Schema: util; Owner: -
3247
--
3248
3249
CREATE FUNCTION relation_type(relation regclass) RETURNS text
3250
    LANGUAGE sql STABLE
3251
    AS $_$
3252
SELECT util.relation_type(util.relation_type_char($1))
3253
$_$;
3254
3255
3256
--
3257 12340 aaronmk
-- Name: relation_type("char"); Type: FUNCTION; Schema: util; Owner: -
3258 12339 aaronmk
--
3259
3260 12340 aaronmk
CREATE FUNCTION relation_type(relation_type_char "char") RETURNS text
3261 12339 aaronmk
    LANGUAGE sql IMMUTABLE
3262
    AS $_$
3263 12593 aaronmk
SELECT 'c=>TYPE, r=>TABLE, v=>VIEW'::hstore -> $1
3264 12339 aaronmk
$_$;
3265
3266
3267
--
3268 12588 aaronmk
-- Name: relation_type(regtype); Type: FUNCTION; Schema: util; Owner: -
3269
--
3270
3271
CREATE FUNCTION relation_type(type regtype) RETURNS text
3272
    LANGUAGE sql IMMUTABLE
3273
    AS $$
3274
SELECT 'TYPE'::text
3275
$$;
3276
3277
3278
--
3279 12341 aaronmk
-- Name: relation_type_char(regclass); Type: FUNCTION; Schema: util; Owner: -
3280
--
3281
3282
CREATE FUNCTION relation_type_char(relation regclass) RETURNS "char"
3283
    LANGUAGE sql STABLE
3284
    AS $_$
3285
SELECT relkind FROM pg_class WHERE oid = $1
3286
$_$;
3287
3288
3289
--
3290 12293 aaronmk
-- Name: remake_diff_table(text, regclass, regclass, text); Type: FUNCTION; Schema: util; Owner: -
3291
--
3292
3293
CREATE FUNCTION remake_diff_table(diff_table text, left_table regclass, right_table regclass, type_table text) RETURNS void
3294
    LANGUAGE sql
3295
    AS $_$
3296
/* can't have in_table/out_table inherit from *each other*, because inheritance
3297
also causes the rows of the parent table to be included in the child table.
3298
instead, they need to inherit from a common, empty table. */
3299 12382 aaronmk
SELECT util.create_if_not_exists($$SELECT $$||util.quote_func_call(
3300
'util.copy_struct', util.quote_typed($2), util.quote_typed($4)));
3301 13098 aaronmk
SELECT util.rm_freq(ARRAY[$4]); -- left/right_table don't have freq yet
3302 12293 aaronmk
SELECT util.inherit($2, $4);
3303
SELECT util.inherit($3, $4);
3304
3305
SELECT util.rematerialize_query($1, $$
3306
SELECT * FROM util.diff(
3307 12419 aaronmk
  $$||util.quote_typed($2)||$$
3308
, $$||util.quote_typed($3)||$$
3309 12293 aaronmk
, NULL::$$||$4||$$)
3310
$$);
3311 12303 aaronmk
3312
/* the table unfortunately cannot be *materialized* in human-readable form,
3313
because this would create column name collisions between the two sides */
3314 12495 aaronmk
SELECT util.prepend_comment($1, '
3315 12303 aaronmk
to view this table in human-readable form (with each side''s tuple column
3316
expanded to its component fields):
3317 12572 aaronmk
SELECT (left_).*, ('||util.schema($4::regclass)||'.values_(right_)).* FROM '||$1||';
3318 13092 aaronmk
3319
to display NULL values that are extra or missing:
3320
SELECT * FROM '||$1||';
3321 12303 aaronmk
');
3322 12293 aaronmk
$_$;
3323
3324
3325
--
3326
-- Name: FUNCTION remake_diff_table(diff_table text, left_table regclass, right_table regclass, type_table text); Type: COMMENT; Schema: util; Owner: -
3327
--
3328
3329
COMMENT ON FUNCTION remake_diff_table(diff_table text, left_table regclass, right_table regclass, type_table text) IS '
3330
type_table (*required*): table to create as the shared base type
3331
';
3332
3333
3334
--
3335 12265 aaronmk
-- Name: rematerialize_query(text, text); Type: FUNCTION; Schema: util; Owner: -
3336
--
3337
3338
CREATE FUNCTION rematerialize_query(table_esc text, sql text) RETURNS void
3339
    LANGUAGE sql
3340
    AS $_$
3341
SELECT util.drop_table($1);
3342
SELECT util.materialize_query($1, $2);
3343
$_$;
3344
3345
3346
--
3347
-- Name: FUNCTION rematerialize_query(table_esc text, sql text); Type: COMMENT; Schema: util; Owner: -
3348
--
3349
3350
COMMENT ON FUNCTION rematerialize_query(table_esc text, sql text) IS '
3351
idempotent, but repeats action each time
3352
';
3353
3354
3355
--
3356 12247 aaronmk
-- Name: rematerialize_view(text, regclass); Type: FUNCTION; Schema: util; Owner: -
3357
--
3358
3359 12262 aaronmk
CREATE FUNCTION rematerialize_view(table_esc text, view_ regclass) RETURNS void
3360 12247 aaronmk
    LANGUAGE sql
3361
    AS $_$
3362
SELECT util.drop_table($1);
3363
SELECT util.materialize_view($1, $2);
3364
$_$;
3365
3366
3367
--
3368 12262 aaronmk
-- Name: FUNCTION rematerialize_view(table_esc text, view_ regclass); Type: COMMENT; Schema: util; Owner: -
3369 12247 aaronmk
--
3370
3371 12262 aaronmk
COMMENT ON FUNCTION rematerialize_view(table_esc text, view_ regclass) IS '
3372 12247 aaronmk
idempotent, but repeats action each time
3373
';
3374
3375
3376
--
3377 8183 aaronmk
-- Name: rename_cols(regclass, anyelement); Type: FUNCTION; Schema: util; Owner: -
3378 8137 aaronmk
--
3379
3380 8148 aaronmk
CREATE FUNCTION rename_cols(table_ regclass, renames anyelement) RETURNS void
3381 12446 aaronmk
    LANGUAGE sql
3382 8137 aaronmk
    AS $_$
3383 8212 aaronmk
SELECT util.try_create($$ALTER TABLE $$||$1||$$ RENAME $$
3384 8137 aaronmk
||quote_ident(name)||$$ TO $$||quote_ident($2 -> name))
3385 10309 aaronmk
FROM util.col_names($1::text::regtype) f (name);
3386
SELECT NULL::void; -- don't fold away functions called in previous query
3387 8137 aaronmk
$_$;
3388
3389
3390
--
3391 8183 aaronmk
-- Name: FUNCTION rename_cols(table_ regclass, renames anyelement); Type: COMMENT; Schema: util; Owner: -
3392 8137 aaronmk
--
3393
3394 12235 aaronmk
COMMENT ON FUNCTION rename_cols(table_ regclass, renames anyelement) IS '
3395
idempotent
3396
';
3397 8137 aaronmk
3398
3399
--
3400 12349 aaronmk
-- Name: rename_relation(regclass, text); Type: FUNCTION; Schema: util; Owner: -
3401
--
3402
3403
CREATE FUNCTION rename_relation(from_ regclass, to_ text) RETURNS void
3404
    LANGUAGE sql
3405
    AS $_$
3406 12353 aaronmk
/* use util.qual_name() instead of ::text so that the schema qualifier is always
3407
included in the debug SQL */
3408
SELECT util.rename_relation(util.qual_name($1), $2)
3409 12349 aaronmk
$_$;
3410
3411
3412
--
3413
-- Name: rename_relation(text, text); Type: FUNCTION; Schema: util; Owner: -
3414
--
3415
3416 12364 aaronmk
CREATE FUNCTION rename_relation(from_esc text, to_name text) RETURNS void
3417 12349 aaronmk
    LANGUAGE sql
3418
    AS $_$
3419
/* 'ALTER TABLE can be used with views too'
3420
(http://www.postgresql.org/docs/9.3/static/sql-alterview.html) */
3421 12363 aaronmk
SELECT util.eval($$ALTER TABLE IF EXISTS $$||$1||$$ RENAME TO $$
3422
||quote_ident($2))
3423 12349 aaronmk
$_$;
3424
3425
3426
--
3427 12364 aaronmk
-- Name: FUNCTION rename_relation(from_esc text, to_name text); Type: COMMENT; Schema: util; Owner: -
3428 12349 aaronmk
--
3429
3430 12364 aaronmk
COMMENT ON FUNCTION rename_relation(from_esc text, to_name text) IS '
3431 12349 aaronmk
idempotent
3432
';
3433
3434
3435
--
3436 12358 aaronmk
-- Name: replace_suffix(text, text, text, integer); Type: FUNCTION; Schema: util; Owner: -
3437 12350 aaronmk
--
3438
3439 12358 aaronmk
CREATE FUNCTION replace_suffix(str text, old_suffix text, new_suffix text, max_prefix_len integer DEFAULT 0) RETURNS text
3440 12350 aaronmk
    LANGUAGE sql IMMUTABLE
3441
    AS $_$
3442 12358 aaronmk
SELECT regexp_replace($1, util.truncated_prefixed_name_regexp($2, $4), '\1'||$3)
3443 12350 aaronmk
$_$;
3444
3445
3446
--
3447 12358 aaronmk
-- Name: FUNCTION replace_suffix(str text, old_suffix text, new_suffix text, max_prefix_len integer); Type: COMMENT; Schema: util; Owner: -
3448
--
3449
3450
COMMENT ON FUNCTION replace_suffix(str text, old_suffix text, new_suffix text, max_prefix_len integer) IS '
3451
max_prefix_len: when str may have been truncated (eg. as a table name) due to the prepending of a prefix, support prefixes up to this length
3452
';
3453
3454
3455
--
3456 10297 aaronmk
-- Name: reset_col_names(regclass, regclass); Type: FUNCTION; Schema: util; Owner: -
3457
--
3458
3459
CREATE FUNCTION reset_col_names(table_ regclass, names regclass) RETURNS void
3460 12446 aaronmk
    LANGUAGE sql
3461 10297 aaronmk
    AS $_$
3462 10596 aaronmk
SELECT util.eval($$DELETE FROM $$||$2||$$ WHERE "from" LIKE ':%'$$);
3463
SELECT util.mk_derived_col(($2, 'to'), $$"from"$$, overwrite := true);
3464 10297 aaronmk
SELECT util.set_col_names($1, $2);
3465
$_$;
3466
3467
3468
--
3469
-- Name: FUNCTION reset_col_names(table_ regclass, names regclass); Type: COMMENT; Schema: util; Owner: -
3470
--
3471
3472 12235 aaronmk
COMMENT ON FUNCTION reset_col_names(table_ regclass, names regclass) IS '
3473
idempotent.
3474
alters the names table, so it will need to be repopulated after running this function.
3475
';
3476 10297 aaronmk
3477
3478
--
3479 8183 aaronmk
-- Name: reset_map_table(text); Type: FUNCTION; Schema: util; Owner: -
3480 8143 aaronmk
--
3481
3482
CREATE FUNCTION reset_map_table(table_ text) RETURNS void
3483 12446 aaronmk
    LANGUAGE sql
3484 8143 aaronmk
    AS $_$
3485 10152 aaronmk
SELECT util.drop_table($1);
3486 8183 aaronmk
SELECT util.mk_map_table($1);
3487 8143 aaronmk
$_$;
3488
3489
3490
--
3491 13488 aaronmk
-- Name: restore_views(restore_views_info); Type: FUNCTION; Schema: util; Owner: -
3492 13486 aaronmk
--
3493
3494 13488 aaronmk
CREATE FUNCTION restore_views(restore_views_info) RETURNS void
3495 13486 aaronmk
    LANGUAGE sql
3496
    AS $_$
3497
SELECT util.debug_print_var('views', $1);
3498 13497 aaronmk
SELECT util.create_if_not_exists((view_).def, (view_).path)
3499
	/* need to specify view name for manual existence check, in case view def
3500
	becomes invalid, which would produce nonstandard (uncatchable) exception */
3501 13491 aaronmk
FROM unnest($1.views) view_; -- in forward dependency order
3502 13486 aaronmk
	/* create_if_not_exists() rather than eval(), because cmd might manually
3503
	re-create a deleted dependent view, causing it to already exist */
3504
SELECT NULL::void; -- don't fold away functions called in previous query
3505
$_$;
3506
3507
3508
--
3509 13096 aaronmk
-- Name: rm_freq(regclass[], text); Type: FUNCTION; Schema: util; Owner: -
3510
--
3511
3512
CREATE FUNCTION rm_freq(tables regclass[], freq_col text DEFAULT 'copies'::text) RETURNS void
3513
    LANGUAGE sql
3514
    AS $_$
3515
SELECT util.drop_column($1, $2, force := true)
3516
$_$;
3517
3518
3519
--
3520 12356 aaronmk
-- Name: rtrim_n(text, integer); Type: FUNCTION; Schema: util; Owner: -
3521
--
3522
3523
CREATE FUNCTION rtrim_n(str text, count integer) RETURNS text
3524
    LANGUAGE sql IMMUTABLE
3525
    AS $_$
3526
SELECT (CASE WHEN $2 <= 0 THEN $1 ELSE left($1, -$2) END)
3527
$_$;
3528
3529
3530
--
3531 12473 aaronmk
-- Name: runnable_sql(text); Type: FUNCTION; Schema: util; Owner: -
3532
--
3533
3534
CREATE FUNCTION runnable_sql(sql text) RETURNS text
3535
    LANGUAGE sql IMMUTABLE
3536
    AS $_$
3537 12481 aaronmk
SELECT (CASE WHEN util.is_set_stmt($1) THEN ''
3538
ELSE util.mk_set_search_path(for_printing := true)||$$;
3539
$$ END)||$1
3540 12473 aaronmk
$_$;
3541
3542
3543
--
3544 11652 aaronmk
-- Name: save_drop_view(text); Type: FUNCTION; Schema: util; Owner: -
3545
--
3546
3547
CREATE FUNCTION save_drop_view(view_ text) RETURNS text
3548
    LANGUAGE plpgsql STRICT
3549 13467 aaronmk
    AS $$
3550 11652 aaronmk
DECLARE
3551
	result text = NULL;
3552
BEGIN
3553
	BEGIN
3554 13470 aaronmk
		result = util.show_create_view(view_, replace := false);
3555
			/* replace: no `OR REPLACE` because that causes nonuniform errors
3556
			(eg. invalid_table_definition), instead of the standard
3557
			duplicate_table exception caught by util.create_if_not_exists() */
3558 13467 aaronmk
		PERFORM util.drop_view(view_);
3559 11652 aaronmk
	EXCEPTION
3560
		WHEN undefined_table THEN NULL;
3561
	END;
3562
	RETURN result;
3563
END;
3564 13467 aaronmk
$$;
3565 11652 aaronmk
3566
3567
--
3568 11660 aaronmk
-- Name: save_drop_views(text[]); Type: FUNCTION; Schema: util; Owner: -
3569
--
3570
3571 13488 aaronmk
CREATE FUNCTION save_drop_views(views text[]) RETURNS restore_views_info
3572 11660 aaronmk
    LANGUAGE sql
3573
    AS $_$
3574 13488 aaronmk
SELECT ROW(/*return in forward dependency order*/util.array_reverse(array(
3575 13491 aaronmk
SELECT (view_, util.save_drop_view(view_))::util.db_item
3576 13485 aaronmk
FROM unnest(/*drop in reverse dependency order*/util.array_reverse($1)) view_
3577 13488 aaronmk
)))::util.restore_views_info
3578 11660 aaronmk
$_$;
3579
3580
3581
--
3582 12244 aaronmk
-- Name: schema(oid); Type: FUNCTION; Schema: util; Owner: -
3583
--
3584
3585
CREATE FUNCTION schema(pg_namespace_oid oid) RETURNS text
3586
    LANGUAGE sql STABLE
3587
    AS $_$
3588
SELECT nspname::text FROM pg_namespace WHERE pg_namespace.oid = $1
3589
$_$;
3590
3591
3592
--
3593 12242 aaronmk
-- Name: schema(regclass); Type: FUNCTION; Schema: util; Owner: -
3594
--
3595
3596
CREATE FUNCTION schema(table_ regclass) RETURNS text
3597
    LANGUAGE sql STABLE
3598
    AS $_$
3599 12245 aaronmk
SELECT util.schema(relnamespace) FROM pg_class WHERE oid = $1
3600 12242 aaronmk
$_$;
3601
3602
3603
--
3604 10794 aaronmk
-- Name: schema(regtype); Type: FUNCTION; Schema: util; Owner: -
3605
--
3606
3607
CREATE FUNCTION schema(type regtype) RETURNS text
3608
    LANGUAGE sql STABLE
3609
    AS $_$
3610 12245 aaronmk
SELECT util.schema(typnamespace) FROM pg_type WHERE oid = $1
3611 10794 aaronmk
$_$;
3612
3613
3614
--
3615
-- Name: schema(anyelement); Type: FUNCTION; Schema: util; Owner: -
3616
--
3617
3618
CREATE FUNCTION schema(type_null anyelement) RETURNS text
3619
    LANGUAGE sql STABLE
3620
    AS $_$
3621
SELECT util.schema(pg_typeof($1))
3622
$_$;
3623
3624
3625
--
3626 12134 aaronmk
-- Name: schema_bundle_get_schemas(text); Type: FUNCTION; Schema: util; Owner: -
3627
--
3628
3629
CREATE FUNCTION schema_bundle_get_schemas(schema_bundle text) RETURNS SETOF text
3630
    LANGUAGE sql STABLE
3631
    AS $_$
3632
SELECT nspname::text FROM pg_namespace WHERE nspname ~ ('^'||$1||'(?=\y|_)')
3633
$_$;
3634
3635
3636
--
3637 12135 aaronmk
-- Name: FUNCTION schema_bundle_get_schemas(schema_bundle text); Type: COMMENT; Schema: util; Owner: -
3638
--
3639
3640 12235 aaronmk
COMMENT ON FUNCTION schema_bundle_get_schemas(schema_bundle text) IS '
3641
a schema bundle is a group of schemas with a common prefix
3642
';
3643 12135 aaronmk
3644
3645
--
3646
-- Name: schema_bundle_rename(text, text); Type: FUNCTION; Schema: util; Owner: -
3647
--
3648
3649
CREATE FUNCTION schema_bundle_rename(old text, new text) RETURNS void
3650
    LANGUAGE sql
3651
    AS $_$
3652
SELECT util.schema_rename(old_schema,
3653
	overlay(old_schema placing new from 1 for length(old))) -- replace prefix
3654
FROM util.schema_bundle_get_schemas($1) f (old_schema);
3655
SELECT NULL::void; -- don't fold away functions called in previous query
3656
$_$;
3657
3658
3659
--
3660
-- Name: schema_bundle_replace(text, text); Type: FUNCTION; Schema: util; Owner: -
3661
--
3662
3663
CREATE FUNCTION schema_bundle_replace(replace text, with_ text) RETURNS void
3664
    LANGUAGE plpgsql
3665
    AS $$
3666
BEGIN
3667
	-- don't schema_bundle_rm() the schema_bundle to keep!
3668
	IF replace = with_ THEN RETURN; END IF;
3669
3670
	PERFORM util.schema_bundle_rm(replace);
3671
	PERFORM util.schema_bundle_rename(with_, replace);
3672
END;
3673
$$;
3674
3675
3676
--
3677
-- Name: schema_bundle_rm(text); Type: FUNCTION; Schema: util; Owner: -
3678
--
3679
3680
CREATE FUNCTION schema_bundle_rm(schema_bundle text) RETURNS void
3681
    LANGUAGE sql
3682
    AS $_$
3683
SELECT util.schema_rm(schema)
3684
FROM util.schema_bundle_get_schemas($1) f (schema);
3685
SELECT NULL::void; -- don't fold away functions called in previous query
3686
$_$;
3687
3688
3689
--
3690 12238 aaronmk
-- Name: schema_esc(anyelement); Type: FUNCTION; Schema: util; Owner: -
3691 10795 aaronmk
--
3692
3693 12238 aaronmk
CREATE FUNCTION schema_esc(type_null anyelement) RETURNS text
3694 10795 aaronmk
    LANGUAGE sql STABLE
3695
    AS $_$
3696
SELECT quote_ident(util.schema($1))
3697
$_$;
3698
3699
3700
--
3701 12324 aaronmk
-- Name: schema_matches(text, text); Type: FUNCTION; Schema: util; Owner: -
3702
--
3703
3704
CREATE FUNCTION schema_matches(schema text, schema_regexp text) RETURNS boolean
3705 12334 aaronmk
    LANGUAGE sql IMMUTABLE
3706 12324 aaronmk
    AS $_$
3707
SELECT $1 ~ $2 AND /*in userspace*/$1 !~ '^(?:information_schema|pg_.*)$'
3708
$_$;
3709
3710
3711
--
3712 12304 aaronmk
-- Name: schema_oid(text); Type: FUNCTION; Schema: util; Owner: -
3713
--
3714
3715
CREATE FUNCTION schema_oid(schema text) RETURNS oid
3716
    LANGUAGE sql STABLE
3717
    AS $_$
3718
SELECT oid FROM pg_namespace WHERE nspname = $1
3719
$_$;
3720
3721
3722
--
3723 12504 aaronmk
-- Name: schema_regexp(regclass); Type: FUNCTION; Schema: util; Owner: -
3724
--
3725
3726
CREATE FUNCTION schema_regexp(relation regclass) RETURNS text
3727
    LANGUAGE sql IMMUTABLE
3728
    AS $_$
3729
SELECT util.schema_regexp(schema_anchor := $1)
3730
$_$;
3731
3732
3733
--
3734 12501 aaronmk
-- Name: schema_regexp(anyelement); Type: FUNCTION; Schema: util; Owner: -
3735
--
3736
3737
CREATE FUNCTION schema_regexp(schema_anchor anyelement) RETURNS text
3738
    LANGUAGE sql IMMUTABLE
3739
    AS $_$
3740
SELECT util.str_equality_regexp(util.schema($1))
3741
$_$;
3742
3743
3744
--
3745 12132 aaronmk
-- Name: schema_rename(text, text); Type: FUNCTION; Schema: util; Owner: -
3746
--
3747
3748
CREATE FUNCTION schema_rename(old text, new text) RETURNS void
3749
    LANGUAGE sql
3750
    AS $_$
3751
SELECT util.eval($$ALTER SCHEMA $$||quote_ident($1)||$$ RENAME TO $$||quote_ident($2));
3752
$_$;
3753
3754
3755
--
3756 12133 aaronmk
-- Name: schema_replace(text, text); Type: FUNCTION; Schema: util; Owner: -
3757
--
3758
3759
CREATE FUNCTION schema_replace(replace text, with_ text) RETURNS void
3760
    LANGUAGE plpgsql
3761
    AS $$
3762
BEGIN
3763
	-- don't schema_rm() the schema to keep!
3764
	IF replace = with_ THEN RETURN; END IF;
3765
3766
	PERFORM util.schema_rm(replace);
3767
	PERFORM util.schema_rename(with_, replace);
3768
END;
3769
$$;
3770
3771
3772
--
3773 12132 aaronmk
-- Name: schema_rm(text); Type: FUNCTION; Schema: util; Owner: -
3774
--
3775
3776
CREATE FUNCTION schema_rm(schema text) RETURNS void
3777
    LANGUAGE sql
3778
    AS $_$
3779
SELECT util.eval($$DROP SCHEMA IF EXISTS $$||quote_ident($1)||$$ CASCADE$$);
3780
$_$;
3781
3782
3783
--
3784 9825 aaronmk
-- Name: search_path_append(text); Type: FUNCTION; Schema: util; Owner: -
3785
--
3786
3787
CREATE FUNCTION search_path_append(schemas text) RETURNS void
3788 12446 aaronmk
    LANGUAGE sql
3789 9825 aaronmk
    AS $_$
3790
SELECT util.eval(
3791
$$SET search_path TO $$||current_setting('search_path')||$$, $$||$1);
3792
$_$;
3793
3794
3795
--
3796 13565 aaronmk
-- Name: seq__create(text, integer); Type: FUNCTION; Schema: util; Owner: -
3797
--
3798
3799
CREATE FUNCTION seq__create(seq text, start integer DEFAULT 0) RETURNS void
3800
    LANGUAGE sql
3801
    AS $_$
3802
SELECT util.create_if_not_exists($$CREATE SEQUENCE $$||$1||$$ MINVALUE $$||$2,
3803
$1)
3804
$_$;
3805
3806
3807
--
3808
-- Name: FUNCTION seq__create(seq text, start integer); Type: COMMENT; Schema: util; Owner: -
3809
--
3810
3811
COMMENT ON FUNCTION seq__create(seq text, start integer) IS '
3812
idempotent
3813
';
3814
3815
3816
--
3817 13566 aaronmk
-- Name: seq__reset(text, integer); Type: FUNCTION; Schema: util; Owner: -
3818
--
3819
3820
CREATE FUNCTION seq__reset(seq text, start integer DEFAULT 0) RETURNS void
3821
    LANGUAGE sql
3822
    AS $_$
3823
SELECT util.seq__create($1, $2);
3824
SELECT util.eval($$ALTER SEQUENCE $$||$1||$$ RESTART$$);
3825
$_$;
3826
3827
3828
--
3829
-- Name: FUNCTION seq__reset(seq text, start integer); Type: COMMENT; Schema: util; Owner: -
3830
--
3831
3832
COMMENT ON FUNCTION seq__reset(seq text, start integer) IS '
3833
creates sequence if doesn''t exist
3834
3835
idempotent
3836
3837
start: *note*: only used if sequence doesn''t exist
3838
';
3839
3840
3841
--
3842 8183 aaronmk
-- Name: set_col_names(regclass, regclass); Type: FUNCTION; Schema: util; Owner: -
3843 8153 aaronmk
--
3844
3845
CREATE FUNCTION set_col_names(table_ regclass, names regclass) RETURNS void
3846
    LANGUAGE plpgsql STRICT
3847
    AS $_$
3848
DECLARE
3849 8183 aaronmk
    old text[] = ARRAY(SELECT util.col_names(table_));
3850
    new text[] = ARRAY(SELECT util.map_values(names));
3851 8153 aaronmk
BEGIN
3852
    old = old[1:array_length(new, 1)]; -- truncate to same length
3853 10345 aaronmk
    PERFORM util.eval($$ALTER TABLE $$||$1||$$ RENAME $$||quote_ident(key)
3854
||$$ TO $$||quote_ident(value))
3855 10149 aaronmk
    FROM each(hstore(old, new))
3856
    WHERE value != key -- not same name
3857
    ;
3858 8153 aaronmk
END;
3859
$_$;
3860
3861
3862
--
3863 8183 aaronmk
-- Name: FUNCTION set_col_names(table_ regclass, names regclass); Type: COMMENT; Schema: util; Owner: -
3864 8153 aaronmk
--
3865
3866 12235 aaronmk
COMMENT ON FUNCTION set_col_names(table_ regclass, names regclass) IS '
3867
idempotent
3868
';
3869 8153 aaronmk
3870
3871
--
3872 10145 aaronmk
-- Name: set_col_names_with_metadata(regclass, regclass); Type: FUNCTION; Schema: util; Owner: -
3873
--
3874
3875
CREATE FUNCTION set_col_names_with_metadata(table_ regclass, names regclass) RETURNS void
3876
    LANGUAGE plpgsql STRICT
3877
    AS $_$
3878
DECLARE
3879
	row_ util.map;
3880
BEGIN
3881 10715 aaronmk
	-- rename any metadata cols rather than re-adding them with new names
3882
	BEGIN
3883
		PERFORM util.set_col_names(table_, names);
3884
	EXCEPTION
3885
		WHEN array_subscript_error THEN -- selective suppress
3886
			IF SQLERRM LIKE 'arrays must have same bounds' THEN NULL;
3887
				-- metadata cols not yet added
3888 12568 aaronmk
			ELSE RAISE;
3889 10715 aaronmk
			END IF;
3890
	END;
3891
3892 10157 aaronmk
	FOR row_ IN EXECUTE $$SELECT * FROM $$||names||$$ WHERE "from" LIKE ':%'$$
3893 10145 aaronmk
	LOOP
3894 10147 aaronmk
		PERFORM util.mk_const_col((table_, row_."to"),
3895
			substring(row_."from" from 2));
3896 10145 aaronmk
	END LOOP;
3897
3898
	PERFORM util.set_col_names(table_, names);
3899
END;
3900
$_$;
3901
3902
3903
--
3904
-- Name: FUNCTION set_col_names_with_metadata(table_ regclass, names regclass); Type: COMMENT; Schema: util; Owner: -
3905
--
3906
3907 12235 aaronmk
COMMENT ON FUNCTION set_col_names_with_metadata(table_ regclass, names regclass) IS '
3908
idempotent.
3909
the metadata mappings must be *last* in the names table.
3910
';
3911 10145 aaronmk
3912
3913
--
3914 8183 aaronmk
-- Name: set_col_types(regclass, col_cast[]); Type: FUNCTION; Schema: util; Owner: -
3915 8107 aaronmk
--
3916
3917
CREATE FUNCTION set_col_types(table_ regclass, col_casts col_cast[]) RETURNS void
3918 12733 aaronmk
    LANGUAGE sql
3919 8107 aaronmk
    AS $_$
3920 12734 aaronmk
SELECT util.eval(COALESCE(
3921
$$ALTER TABLE $$||$1||$$
3922 12732 aaronmk
$$||(
3923
	SELECT
3924
	string_agg($$ALTER COLUMN $$||col_name_sql||$$ TYPE $$||target_type
3925
	||$$ USING $$||col_name_sql||$$::$$||target_type, $$
3926
, $$)
3927
	FROM
3928
	(
3929
		SELECT
3930
		  quote_ident(col_name) AS col_name_sql
3931 12733 aaronmk
		, util.col_type(($1, col_name)) AS curr_type
3932 12732 aaronmk
		, type AS target_type
3933 12733 aaronmk
		FROM unnest($2)
3934 12732 aaronmk
	) s
3935
	WHERE curr_type != target_type
3936 12734 aaronmk
), ''))
3937 8107 aaronmk
$_$;
3938
3939
3940
--
3941 8183 aaronmk
-- Name: FUNCTION set_col_types(table_ regclass, col_casts col_cast[]); Type: COMMENT; Schema: util; Owner: -
3942 8107 aaronmk
--
3943
3944 12235 aaronmk
COMMENT ON FUNCTION set_col_types(table_ regclass, col_casts col_cast[]) IS '
3945
idempotent
3946
';
3947 8107 aaronmk
3948
3949
--
3950 12302 aaronmk
-- Name: set_comment(regclass, text); Type: FUNCTION; Schema: util; Owner: -
3951
--
3952
3953
CREATE FUNCTION set_comment(table_ regclass, comment text) RETURNS void
3954 12446 aaronmk
    LANGUAGE sql
3955 12302 aaronmk
    AS $_$
3956 13477 aaronmk
SELECT util.eval(util.mk_set_comment($1, $2))
3957 12302 aaronmk
$_$;
3958
3959
3960
--
3961 12482 aaronmk
-- Name: set_search_path(text, boolean); Type: FUNCTION; Schema: util; Owner: -
3962
--
3963
3964
CREATE FUNCTION set_search_path(search_path text, for_session boolean DEFAULT false) RETURNS void
3965
    LANGUAGE sql
3966
    AS $_$
3967
SELECT util.eval(util.mk_set_search_path($1, $2))
3968
$_$;
3969
3970
3971
--
3972 13468 aaronmk
-- Name: show_create_view(regclass, boolean); Type: FUNCTION; Schema: util; Owner: -
3973 11651 aaronmk
--
3974
3975 13468 aaronmk
CREATE FUNCTION show_create_view(view_ regclass, replace boolean DEFAULT true) RETURNS text
3976 11651 aaronmk
    LANGUAGE sql STABLE
3977
    AS $_$
3978 13468 aaronmk
SELECT $$CREATE$$||(CASE WHEN $2 THEN $$ OR REPLACE$$ ELSE '' END)||$$ VIEW $$
3979
||$1||$$ AS
3980 13482 aaronmk
$$||pg_get_viewdef($1)/*no ; because pg_get_viewdef() includes one*/||$$
3981 13505 aaronmk
$$||util.mk_set_relation_metadata($1)
3982 11651 aaronmk
$_$;
3983
3984
3985
--
3986 11655 aaronmk
-- Name: show_grants_for(regclass); Type: FUNCTION; Schema: util; Owner: -
3987
--
3988
3989
CREATE FUNCTION show_grants_for(table_ regclass) RETURNS text
3990
    LANGUAGE sql STABLE
3991
    AS $_$
3992 12269 aaronmk
SELECT string_agg(cmd, '')
3993 11655 aaronmk
FROM
3994
(
3995
	SELECT (CASE WHEN has_table_privilege(user_, $1, 'SELECT') THEN
3996
$$GRANT SELECT ON TABLE $$||$1||$$ TO $$||quote_ident(user_)||$$;
3997
$$ ELSE '' END) AS cmd
3998
	FROM util.grants_users() f (user_)
3999
) s
4000
$_$;
4001
4002
4003
--
4004 12325 aaronmk
-- Name: show_relations_like(text, text, character[]); Type: FUNCTION; Schema: util; Owner: -
4005
--
4006
4007 12670 aaronmk
CREATE FUNCTION show_relations_like(name_regexp text, schema_regexp text DEFAULT ''::text, types character[] DEFAULT ARRAY['c'::text, 'r'::text, 'v'::text]) RETURNS SETOF regclass
4008 12325 aaronmk
    LANGUAGE sql STABLE
4009
    AS $_$
4010
SELECT oid FROM pg_class
4011
WHERE relkind = ANY($3) AND relname ~ $1
4012
AND util.schema_matches(util.schema(relnamespace), $2)
4013
ORDER BY relname
4014
$_$;
4015
4016
4017
--
4018 13478 aaronmk
-- Name: show_set_comment(regclass); Type: FUNCTION; Schema: util; Owner: -
4019
--
4020
4021
CREATE FUNCTION show_set_comment(table_ regclass) RETURNS text
4022
    LANGUAGE sql STABLE
4023
    AS $_$
4024 13480 aaronmk
SELECT util.mk_set_comment($1, util.comment($1))
4025 13478 aaronmk
$_$;
4026
4027
4028
--
4029 12592 aaronmk
-- Name: show_types_like(text, text); Type: FUNCTION; Schema: util; Owner: -
4030
--
4031
4032
CREATE FUNCTION show_types_like(name_regexp text DEFAULT ''::text, schema_regexp text DEFAULT ''::text) RETURNS SETOF regtype
4033
    LANGUAGE sql STABLE
4034
    AS $_$
4035
SELECT oid
4036
FROM pg_type
4037
WHERE typname ~ $1 AND util.schema_matches(util.schema(typnamespace), $2)
4038
ORDER BY typname
4039
$_$;
4040
4041
4042
--
4043 12305 aaronmk
-- Name: show_views_like(text, text); Type: FUNCTION; Schema: util; Owner: -
4044
--
4045
4046 12385 aaronmk
CREATE FUNCTION show_views_like(name_regexp text, schema_regexp text DEFAULT ''::text) RETURNS SETOF regclass
4047 12305 aaronmk
    LANGUAGE sql STABLE
4048
    AS $_$
4049 12385 aaronmk
SELECT * FROM util.show_relations_like($1, $2, ARRAY['v'])
4050 12305 aaronmk
$_$;
4051
4052
4053
--
4054 12384 aaronmk
-- Name: str_equality_regexp(text); Type: FUNCTION; Schema: util; Owner: -
4055
--
4056
4057
CREATE FUNCTION str_equality_regexp(literal text) RETURNS text
4058
    LANGUAGE sql IMMUTABLE
4059
    AS $_$
4060
SELECT '^'||util.regexp_quote($1)||'$'
4061
$_$;
4062
4063
4064
--
4065 8183 aaronmk
-- Name: table2hstore(regclass); Type: FUNCTION; Schema: util; Owner: -
4066 8144 aaronmk
--
4067
4068
CREATE FUNCTION table2hstore(table_ regclass) RETURNS hstore
4069 8145 aaronmk
    LANGUAGE plpgsql STABLE STRICT
4070 8144 aaronmk
    AS $_$
4071
DECLARE
4072
    hstore hstore;
4073
BEGIN
4074
    EXECUTE $$SELECT hstore(ARRAY(SELECT unnest(ARRAY["from", "to"]) FROM $$||
4075
        table_||$$))$$ INTO STRICT hstore;
4076
    RETURN hstore;
4077
END;
4078
$_$;
4079
4080
4081
--
4082 10184 aaronmk
-- Name: table_flag__get(regclass, text); Type: FUNCTION; Schema: util; Owner: -
4083
--
4084
4085
CREATE FUNCTION table_flag__get(table_ regclass, flag text) RETURNS boolean
4086 12446 aaronmk
    LANGUAGE sql STABLE
4087 10184 aaronmk
    AS $_$
4088
SELECT COUNT(*) > 0 FROM pg_constraint
4089
WHERE conrelid = $1 AND contype = 'c' AND conname = $2
4090
$_$;
4091
4092
4093
--
4094
-- Name: FUNCTION table_flag__get(table_ regclass, flag text); Type: COMMENT; Schema: util; Owner: -
4095
--
4096
4097 12235 aaronmk
COMMENT ON FUNCTION table_flag__get(table_ regclass, flag text) IS '
4098
gets whether a status flag is set by the presence of a table constraint
4099
';
4100 10184 aaronmk
4101
4102
--
4103 10182 aaronmk
-- Name: table_flag__set(regclass, text); Type: FUNCTION; Schema: util; Owner: -
4104
--
4105
4106
CREATE FUNCTION table_flag__set(table_ regclass, flag text) RETURNS void
4107 12446 aaronmk
    LANGUAGE sql
4108 10182 aaronmk
    AS $_$
4109
SELECT util.create_if_not_exists($$ALTER TABLE $$||$1||$$ ADD CONSTRAINT $$
4110
||quote_ident($2)||$$ CHECK (true)$$)
4111
$_$;
4112
4113
4114
--
4115
-- Name: FUNCTION table_flag__set(table_ regclass, flag text); Type: COMMENT; Schema: util; Owner: -
4116
--
4117
4118 12235 aaronmk
COMMENT ON FUNCTION table_flag__set(table_ regclass, flag text) IS '
4119
stores a status flag by the presence of a table constraint.
4120
idempotent.
4121
';
4122 10182 aaronmk
4123
4124
--
4125 10185 aaronmk
-- Name: table_nulls_mapped__get(regclass); Type: FUNCTION; Schema: util; Owner: -
4126
--
4127
4128
CREATE FUNCTION table_nulls_mapped__get(table_ regclass) RETURNS boolean
4129 12446 aaronmk
    LANGUAGE sql STABLE
4130 10185 aaronmk
    AS $_$
4131
SELECT util.table_flag__get($1, 'nulls_mapped')
4132
$_$;
4133
4134
4135
--
4136
-- Name: FUNCTION table_nulls_mapped__get(table_ regclass); Type: COMMENT; Schema: util; Owner: -
4137
--
4138
4139 12235 aaronmk
COMMENT ON FUNCTION table_nulls_mapped__get(table_ regclass) IS '
4140
gets whether a table''s NULL-equivalent strings have been replaced with NULL
4141
';
4142 10185 aaronmk
4143
4144
--
4145 10183 aaronmk
-- Name: table_nulls_mapped__set(regclass); Type: FUNCTION; Schema: util; Owner: -
4146
--
4147
4148
CREATE FUNCTION table_nulls_mapped__set(table_ regclass) RETURNS void
4149 12446 aaronmk
    LANGUAGE sql
4150 10183 aaronmk
    AS $_$
4151
SELECT util.table_flag__set($1, 'nulls_mapped')
4152
$_$;
4153
4154
4155
--
4156
-- Name: FUNCTION table_nulls_mapped__set(table_ regclass); Type: COMMENT; Schema: util; Owner: -
4157
--
4158
4159 12235 aaronmk
COMMENT ON FUNCTION table_nulls_mapped__set(table_ regclass) IS '
4160
sets that a table''s NULL-equivalent strings have been replaced with NULL.
4161
idempotent.
4162
';
4163 10183 aaronmk
4164
4165
--
4166 12652 aaronmk
-- Name: to_freq(regclass); Type: FUNCTION; Schema: util; Owner: -
4167
--
4168
4169
CREATE FUNCTION to_freq(table_ regclass) RETURNS void
4170
    LANGUAGE sql
4171
    AS $_$
4172
-- save data before truncating main table
4173
SELECT util.copy_types_and_data($1, 'pg_temp.__copy');
4174
4175
-- repopulate main table w/ copies column
4176
SELECT util.truncate($1);
4177
SELECT util.eval($$ALTER TABLE $$||$1||$$ ADD COLUMN copies bigint NOT NULL$$);
4178
SELECT util.populate_table($1, $$
4179
SELECT (table_).*, copies
4180
FROM (
4181
	SELECT table_, COUNT(*) AS copies
4182
	FROM pg_temp.__copy table_
4183
	GROUP BY table_
4184
) s
4185
$$);
4186
4187
-- delete temp table so it doesn't stay around until end of connection
4188
SELECT util.drop_table('pg_temp.__copy');
4189
$_$;
4190
4191
4192
--
4193 8183 aaronmk
-- Name: to_global_col_names(regclass); Type: FUNCTION; Schema: util; Owner: -
4194 8088 aaronmk
--
4195
4196
CREATE FUNCTION to_global_col_names(table_ regclass) RETURNS void
4197
    LANGUAGE plpgsql STRICT
4198
    AS $_$
4199
DECLARE
4200
    row record;
4201
BEGIN
4202 8183 aaronmk
    FOR row IN SELECT * FROM util.col_global_names(table_::text::regtype)
4203 8088 aaronmk
    LOOP
4204
        IF row.global_name != row.name THEN
4205
            EXECUTE $$ALTER TABLE $$||table_||$$ RENAME $$
4206
                ||quote_ident(row.name)||$$ TO $$||quote_ident(row.global_name);
4207
        END IF;
4208
    END LOOP;
4209
END;
4210
$_$;
4211
4212
4213
--
4214 8183 aaronmk
-- Name: FUNCTION to_global_col_names(table_ regclass); Type: COMMENT; Schema: util; Owner: -
4215 8088 aaronmk
--
4216
4217 12235 aaronmk
COMMENT ON FUNCTION to_global_col_names(table_ regclass) IS '
4218
idempotent
4219
';
4220 8088 aaronmk
4221
4222
--
4223 12874 aaronmk
-- Name: trim(regclass, regclass, boolean); Type: FUNCTION; Schema: util; Owner: -
4224 10365 aaronmk
--
4225
4226 12874 aaronmk
CREATE FUNCTION "trim"(table_ regclass, names regclass, force boolean DEFAULT true) RETURNS void
4227 12446 aaronmk
    LANGUAGE sql
4228 10365 aaronmk
    AS $_$
4229 12874 aaronmk
SELECT util.drop_column(($1, col), $3) FROM util.added_cols($1, $2) f (col);
4230 10365 aaronmk
SELECT NULL::void; -- don't fold away functions called in previous query
4231
$_$;
4232
4233
4234
--
4235 12874 aaronmk
-- Name: FUNCTION "trim"(table_ regclass, names regclass, force boolean); Type: COMMENT; Schema: util; Owner: -
4236 10365 aaronmk
--
4237
4238 12874 aaronmk
COMMENT ON FUNCTION "trim"(table_ regclass, names regclass, force boolean) IS '
4239
trims table_ to include only columns in the original data
4240
4241
by default, cascadingly drops dependent columns so that they don''t prevent
4242
trim() from succeeding. note that this requires the dependent columns to then be
4243
manually re-created.
4244
4245
idempotent
4246 12235 aaronmk
';
4247 10365 aaronmk
4248
4249
--
4250 8183 aaronmk
-- Name: truncate(regclass); Type: FUNCTION; Schema: util; Owner: -
4251 8142 aaronmk
--
4252
4253
CREATE FUNCTION truncate(table_ regclass) RETURNS void
4254
    LANGUAGE plpgsql STRICT
4255
    AS $_$
4256
BEGIN
4257
    EXECUTE $$TRUNCATE $$||table_||$$ CASCADE$$;
4258
END;
4259
$_$;
4260
4261
4262
--
4263 8183 aaronmk
-- Name: FUNCTION truncate(table_ regclass); Type: COMMENT; Schema: util; Owner: -
4264 8142 aaronmk
--
4265
4266 12235 aaronmk
COMMENT ON FUNCTION truncate(table_ regclass) IS '
4267
idempotent
4268
';
4269 8142 aaronmk
4270
4271
--
4272 12357 aaronmk
-- Name: truncated_prefixed_name_regexp(text, integer); Type: FUNCTION; Schema: util; Owner: -
4273
--
4274
4275
CREATE FUNCTION truncated_prefixed_name_regexp(name text, max_prefix_len integer) RETURNS text
4276
    LANGUAGE sql IMMUTABLE
4277
    AS $_$
4278 12361 aaronmk
SELECT '^(.*)'||util._if(util.name_was_truncated($1, $2),
4279 12362 aaronmk
util.regexp_quote(util.rtrim_n($1, $2))||'.*', util.regexp_quote($1)) ||'$'
4280 12357 aaronmk
$_$;
4281
4282
4283
--
4284 13135 aaronmk
-- Name: try_cast(text, anyelement); Type: FUNCTION; Schema: util; Owner: -
4285
--
4286
4287
CREATE FUNCTION try_cast(value text, ret_type_null anyelement) RETURNS anyelement
4288
    LANGUAGE plpgsql IMMUTABLE
4289
    AS $$
4290
BEGIN
4291
	/* need explicit cast because some types not implicitly-castable, and also
4292
	to make the cast happen inside the try block. (*implicit* casts to the
4293
	return type happen at the end of the function, outside any block.) */
4294
	RETURN util.cast(value, ret_type_null);
4295
EXCEPTION
4296 13493 aaronmk
WHEN   data_exception
4297 13564 aaronmk
	OR invalid_schema_name -- eg. 'pg_temp.__'::regclass
4298 13493 aaronmk
	OR syntax_error_or_access_rule_violation -- eg. ::regclass
4299
	THEN
4300 13135 aaronmk
	PERFORM util.raise('WARNING', SQLERRM);
4301
	RETURN NULL;
4302
END;
4303
$$;
4304
4305
4306
--
4307
-- Name: FUNCTION try_cast(value text, ret_type_null anyelement); Type: COMMENT; Schema: util; Owner: -
4308
--
4309
4310
COMMENT ON FUNCTION try_cast(value text, ret_type_null anyelement) IS '
4311
ret_type_null: NULL::ret_type
4312
';
4313
4314
4315
--
4316 8199 aaronmk
-- Name: try_create(text); Type: FUNCTION; Schema: util; Owner: -
4317
--
4318
4319
CREATE FUNCTION try_create(sql text) RETURNS void
4320
    LANGUAGE plpgsql STRICT
4321
    AS $$
4322
BEGIN
4323 12658 aaronmk
	PERFORM util.eval(sql);
4324 8199 aaronmk
EXCEPTION
4325 12676 aaronmk
WHEN   not_null_violation
4326
		/* trying to add NOT NULL column to parent table, which cascades to
4327
		child table whose values for the new column will be NULL */
4328
	OR wrong_object_type -- trying to alter a view's columns
4329
	OR undefined_column
4330
	OR duplicate_column
4331
THEN NULL;
4332 12684 aaronmk
WHEN datatype_mismatch THEN
4333
	IF SQLERRM LIKE 'child table is missing column %' THEN NULL;
4334
	ELSE RAISE; -- rethrow
4335
	END IF;
4336 8199 aaronmk
END;
4337
$$;
4338
4339
4340
--
4341
-- Name: FUNCTION try_create(sql text); Type: COMMENT; Schema: util; Owner: -
4342
--
4343
4344 12235 aaronmk
COMMENT ON FUNCTION try_create(sql text) IS '
4345
idempotent
4346
';
4347 8199 aaronmk
4348
4349
--
4350 8209 aaronmk
-- Name: try_mk_derived_col(col_ref, text); Type: FUNCTION; Schema: util; Owner: -
4351
--
4352
4353
CREATE FUNCTION try_mk_derived_col(col col_ref, expr text) RETURNS void
4354 12446 aaronmk
    LANGUAGE sql
4355 8209 aaronmk
    AS $_$
4356
SELECT util.try_create($$SELECT util.mk_derived_col($$||quote_literal($1)||$$, $$||quote_literal($2)||$$)$$)
4357
$_$;
4358
4359
4360
--
4361
-- Name: FUNCTION try_mk_derived_col(col col_ref, expr text); Type: COMMENT; Schema: util; Owner: -
4362
--
4363
4364 12235 aaronmk
COMMENT ON FUNCTION try_mk_derived_col(col col_ref, expr text) IS '
4365
idempotent
4366
';
4367 8209 aaronmk
4368
4369
--
4370 8189 aaronmk
-- Name: type_qual(anyelement); Type: FUNCTION; Schema: util; Owner: -
4371
--
4372
4373
CREATE FUNCTION type_qual(value anyelement) RETURNS text
4374
    LANGUAGE sql IMMUTABLE
4375
    AS $_$
4376
SELECT CASE WHEN $1 IS NULL THEN '' ELSE $$ NOT NULL$$ END
4377
$_$;
4378
4379
4380
--
4381 10161 aaronmk
-- Name: FUNCTION type_qual(value anyelement); Type: COMMENT; Schema: util; Owner: -
4382
--
4383
4384 12235 aaronmk
COMMENT ON FUNCTION type_qual(value anyelement) IS '
4385
a type''s NOT NULL qualifier
4386
';
4387 10161 aaronmk
4388
4389
--
4390 12562 aaronmk
-- Name: typed_cols(regtype); Type: FUNCTION; Schema: util; Owner: -
4391
--
4392
4393
CREATE FUNCTION typed_cols(type regtype) RETURNS SETOF col_cast
4394 12590 aaronmk
    LANGUAGE sql STABLE
4395 12562 aaronmk
    AS $_$
4396
SELECT (attname::text, atttypid)::util.col_cast
4397
FROM pg_attribute
4398
WHERE attrelid = $1::text::regclass AND attnum >= 1 AND NOT attisdropped
4399
ORDER BY attnum
4400
$_$;
4401
4402
4403
--
4404 12438 aaronmk
-- Name: typeof(anyelement); Type: FUNCTION; Schema: util; Owner: -
4405
--
4406
4407
CREATE FUNCTION typeof(value anyelement) RETURNS text
4408
    LANGUAGE sql IMMUTABLE
4409
    AS $_$
4410
SELECT util.qual_name(pg_typeof($1))
4411
$_$;
4412
4413
4414
--
4415 8185 aaronmk
-- Name: typeof(text, regtype); Type: FUNCTION; Schema: util; Owner: -
4416
--
4417
4418 10160 aaronmk
CREATE FUNCTION typeof(expr text, table_ regtype DEFAULT NULL::regtype) RETURNS regtype
4419
    LANGUAGE plpgsql STABLE
4420 8185 aaronmk
    AS $_$
4421
DECLARE
4422
    type regtype;
4423
BEGIN
4424 10160 aaronmk
    EXECUTE $$SELECT pg_typeof($$||expr||$$)$$||
4425
COALESCE($$ FROM (SELECT (NULL::$$||table_||$$).*) _s$$, '') INTO STRICT type;
4426 8185 aaronmk
    RETURN type;
4427
END;
4428
$_$;
4429
4430
4431
--
4432 12490 aaronmk
-- Name: use_schema(anyelement); Type: FUNCTION; Schema: util; Owner: -
4433 12483 aaronmk
--
4434
4435 12490 aaronmk
CREATE FUNCTION use_schema(schema_anchor anyelement) RETURNS void
4436 12483 aaronmk
    LANGUAGE sql
4437
    AS $_$
4438 12488 aaronmk
SELECT util.set_search_path(util.mk_search_path(util.schema($1)))
4439 12483 aaronmk
$_$;
4440
4441
4442
--
4443 12490 aaronmk
-- Name: FUNCTION use_schema(schema_anchor anyelement); Type: COMMENT; Schema: util; Owner: -
4444 12488 aaronmk
--
4445
4446 12490 aaronmk
COMMENT ON FUNCTION use_schema(schema_anchor anyelement) IS '
4447 12488 aaronmk
auto-appends util to the search_path to enable use of util operators
4448
';
4449
4450
4451
--
4452 9959 aaronmk
-- Name: all_same(anyelement); Type: AGGREGATE; Schema: util; Owner: -
4453
--
4454
4455
CREATE AGGREGATE all_same(anyelement) (
4456
    SFUNC = all_same_transform,
4457
    STYPE = anyarray,
4458
    FINALFUNC = all_same_final
4459
);
4460
4461
4462
--
4463
-- Name: AGGREGATE all_same(anyelement); Type: COMMENT; Schema: util; Owner: -
4464
--
4465
4466 12235 aaronmk
COMMENT ON AGGREGATE all_same(anyelement) IS '
4467
includes NULLs in comparison
4468
';
4469 9959 aaronmk
4470
4471
--
4472 8183 aaronmk
-- Name: join_strs(text, text); Type: AGGREGATE; Schema: util; Owner: -
4473 2595 aaronmk
--
4474
4475
CREATE AGGREGATE join_strs(text, text) (
4476 4052 aaronmk
    SFUNC = join_strs_transform,
4477 4010 aaronmk
    STYPE = text
4478 2595 aaronmk
);
4479
4480
4481 8147 aaronmk
--
4482 12423 aaronmk
-- Name: %==; Type: OPERATOR; Schema: util; Owner: -
4483
--
4484
4485
CREATE OPERATOR %== (
4486
    PROCEDURE = "%==",
4487
    LEFTARG = anyelement,
4488
    RIGHTARG = anyelement
4489
);
4490
4491
4492
--
4493
-- Name: OPERATOR %== (anyelement, anyelement); Type: COMMENT; Schema: util; Owner: -
4494
--
4495
4496
COMMENT ON OPERATOR %== (anyelement, anyelement) IS '
4497
returns whether the map-keys of the compared values are the same
4498
(mnemonic: % is the Perl symbol for a hash map)
4499
4500
should be overridden for types that store both keys and values
4501
4502
used in a FULL JOIN to select which columns to join on
4503
';
4504
4505
4506
--
4507 8183 aaronmk
-- Name: ->; Type: OPERATOR; Schema: util; Owner: -
4508 8147 aaronmk
--
4509
4510
CREATE OPERATOR -> (
4511
    PROCEDURE = map_get,
4512
    LEFTARG = regclass,
4513
    RIGHTARG = text
4514
);
4515
4516
4517 10308 aaronmk
--
4518
-- Name: =>; Type: OPERATOR; Schema: util; Owner: -
4519
--
4520
4521
CREATE OPERATOR => (
4522
    PROCEDURE = hstore,
4523 10357 aaronmk
    LEFTARG = text[],
4524 10608 aaronmk
    RIGHTARG = text
4525 10308 aaronmk
);
4526
4527
4528
--
4529 10608 aaronmk
-- Name: OPERATOR => (text[], text); Type: COMMENT; Schema: util; Owner: -
4530 10308 aaronmk
--
4531
4532 12235 aaronmk
COMMENT ON OPERATOR => (text[], text) IS '
4533
usage: array[''key1'', ...]::text[] => ''value''
4534
';
4535 10308 aaronmk
4536
4537 10391 aaronmk
--
4538 10613 aaronmk
-- Name: ?*>=; Type: OPERATOR; Schema: util; Owner: -
4539
--
4540
4541
CREATE OPERATOR ?*>= (
4542
    PROCEDURE = is_populated_more_often_than,
4543
    LEFTARG = anyelement,
4544
    RIGHTARG = anyelement
4545
);
4546
4547
4548
--
4549 10391 aaronmk
-- Name: ?>=; Type: OPERATOR; Schema: util; Owner: -
4550
--
4551
4552
CREATE OPERATOR ?>= (
4553
    PROCEDURE = is_more_complete_than,
4554
    LEFTARG = anyelement,
4555
    RIGHTARG = anyelement
4556
);
4557
4558
4559 11005 aaronmk
--
4560
-- Name: ||%; Type: OPERATOR; Schema: util; Owner: -
4561
--
4562
4563
CREATE OPERATOR ||% (
4564
    PROCEDURE = concat_esc,
4565
    LEFTARG = text,
4566
    RIGHTARG = text
4567
);
4568
4569
4570
--
4571
-- Name: OPERATOR ||% (text, text); Type: COMMENT; Schema: util; Owner: -
4572
--
4573
4574 12235 aaronmk
COMMENT ON OPERATOR ||% (text, text) IS '
4575
% indicates an identifier, as in Perl hashes and one of the x86 assembler syntaxes for registers
4576
';
4577 11005 aaronmk
4578
4579 2107 aaronmk
--
4580 8183 aaronmk
-- Name: map; Type: TABLE; Schema: util; Owner: -; Tablespace:
4581 8140 aaronmk
--
4582
4583
CREATE TABLE map (
4584
    "from" text NOT NULL,
4585 8158 aaronmk
    "to" text,
4586
    filter text,
4587
    notes text
4588 8140 aaronmk
);
4589
4590
4591
--
4592 11834 aaronmk
-- Data for Name: explain; Type: TABLE DATA; Schema: util; Owner: -
4593
--
4594
4595
4596
4597
--
4598 8183 aaronmk
-- Data for Name: map; Type: TABLE DATA; Schema: util; Owner: -
4599 8140 aaronmk
--
4600
4601
4602
4603
--
4604 10342 aaronmk
-- Name: map__unique__from; Type: CONSTRAINT; Schema: util; Owner: -; Tablespace:
4605 8140 aaronmk
--
4606
4607
ALTER TABLE ONLY map
4608 10342 aaronmk
    ADD CONSTRAINT map__unique__from UNIQUE ("from");
4609 8140 aaronmk
4610
4611
--
4612 10343 aaronmk
-- Name: map__unique__to; Type: CONSTRAINT; Schema: util; Owner: -; Tablespace:
4613
--
4614
4615
ALTER TABLE ONLY map
4616
    ADD CONSTRAINT map__unique__to UNIQUE ("to");
4617
4618
4619
--
4620 10110 aaronmk
-- Name: map_filter_insert; Type: TRIGGER; Schema: util; Owner: -
4621
--
4622
4623
CREATE TRIGGER map_filter_insert BEFORE INSERT ON map FOR EACH ROW EXECUTE PROCEDURE map_filter_insert();
4624
4625
4626
--
4627 2136 aaronmk
-- PostgreSQL database dump complete
4628
--