Sha256: f492240cb21665911da1a62d46ee0e9f9c3a21f64587a6ef0d7418ec3fefa8d6
Contents?: true
Size: 1.71 KB
Versions: 9
Compression:
Stored size: 1.71 KB
Contents
# frozen_string_literal: true
FUNC_FIX_SERIAL_SEQUENCE = <<~SQL
CREATE OR REPLACE FUNCTION fix_serial_sequence(_table regclass, _newtable text)
RETURNS void AS
$func$
DECLARE
_sql text;
BEGIN
-- Update serial columns to ensure copied table doesn't follow same sequence as primary table
SELECT INTO _sql
string_agg('CREATE SEQUENCE ' || seq, E';\n') || E';\n'
|| string_agg(format('ALTER SEQUENCE %s OWNED BY %I.%I'
, seq, _newtable, a.attname), E';\n') || E';\n'
|| 'ALTER TABLE ' || quote_ident(_newtable) || E'\n '
|| string_agg(format($$ALTER %I SET DEFAULT nextval('%s'::regclass)$$
, a.attname, seq), E'\n, ')
FROM pg_attribute a
JOIN pg_attrdef ad ON ad.adrelid = a.attrelid
AND ad.adnum = a.attnum
, quote_ident(_newtable || '_' || a.attname || '_seq') AS seq
WHERE a.attrelid = _table
AND a.attnum > 0
AND NOT a.attisdropped
AND a.atttypid = ANY ('{int,int8,int2}'::regtype[])
AND pg_get_expr(ad.adbin, ad.adrelid) = 'nextval('''
|| (pg_get_serial_sequence (a.attrelid::regclass::text, a.attname))::regclass
|| '''::regclass)'
;
IF _sql IS NOT NULL THEN
EXECUTE _sql;
END IF;
END
$func$ LANGUAGE plpgsql VOLATILE;
SQL
FUNC_CREATE_TABLE_ALL = <<~SQL
CREATE OR REPLACE FUNCTION create_table_all(source_table text, newsource_table text)
RETURNS void language plpgsql
as $$
declare
rec record;
begin
EXECUTE format(
'CREATE TABLE %s (LIKE %s including all) WITH (autovacuum_enabled = false)',
newsource_table, source_table);
END
$$;
SQL
Version data entries
9 entries across 9 versions & 1 rubygems