Skip to content

Commit 6f8a8ba

Browse files
committed
support for ENABLE TRIGGER renamed to enable_trigger from alter_table
1 parent 532be6e commit 6f8a8ba

File tree

2 files changed

+8
-8
lines changed

2 files changed

+8
-8
lines changed

bin/pg_repack.c

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ typedef struct repack_table
6161
const char *create_pktype; /* CREATE TYPE pk */
6262
const char *create_log; /* CREATE TABLE log */
6363
const char *create_trigger; /* CREATE TRIGGER z_repack_trigger */
64-
const char *alter_table; /* ALTER TABLE ENABLE ALWAYS TRIGGER z_repack_trigger */
64+
const char *enable_trigger; /* ALTER TABLE ENABLE ALWAYS TRIGGER z_repack_trigger */
6565
const char *create_table; /* CREATE TABLE table AS SELECT */
6666
const char *drop_columns; /* ALTER TABLE DROP COLUMNs */
6767
const char *delete_log; /* DELETE FROM log */
@@ -302,7 +302,7 @@ repack_one_database(const char *orderby, const char *table)
302302
table.create_pktype = getstr(res, i, c++);
303303
table.create_log = getstr(res, i, c++);
304304
table.create_trigger = getstr(res, i, c++);
305-
table.alter_table = getstr(res, i, c++);
305+
table.enable_trigger = getstr(res, i, c++);
306306

307307
create_table = getstr(res, i, c++);
308308
table.drop_columns = getstr(res, i, c++);
@@ -399,7 +399,7 @@ repack_one_table(const repack_table *table, const char *orderby)
399399
elog(DEBUG2, "create_pktype : %s", table->create_pktype);
400400
elog(DEBUG2, "create_log : %s", table->create_log);
401401
elog(DEBUG2, "create_trigger : %s", table->create_trigger);
402-
elog(DEBUG2, "alter_table : %s", table->alter_table);
402+
elog(DEBUG2, "enable_trigger : %s", table->enable_trigger);
403403
elog(DEBUG2, "create_table : %s", table->create_table);
404404
elog(DEBUG2, "drop_columns : %s", table->drop_columns ? table->drop_columns : "(skipped)");
405405
elog(DEBUG2, "delete_log : %s", table->delete_log);
@@ -433,7 +433,7 @@ repack_one_table(const repack_table *table, const char *orderby)
433433
command(table->create_pktype, 0, NULL);
434434
command(table->create_log, 0, NULL);
435435
command(table->create_trigger, 0, NULL);
436-
command(table->alter_table, 0, NULL);
436+
command(table->enable_trigger, 0, NULL);
437437
printfStringInfo(&sql, "SELECT repack.disable_autovacuum('repack.log_%u')", table->target_oid);
438438
command(sql.data, 0, NULL);
439439
command("COMMIT", 0, NULL);

lib/pg_repack.sql.in

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -72,11 +72,11 @@ $$
7272
$$
7373
LANGUAGE sql STABLE STRICT;
7474

75-
CREATE FUNCTION repack.get_alter_table(relid oid)
75+
CREATE FUNCTION repack.get_enable_trigger(relid oid)
7676
RETURNS text AS
7777
$$
7878
SELECT 'ALTER TABLE ' || repack.oid2text($1) ||
79-
' ENABLE ALWAYS TRIGGER z_repack_trigger';
79+
' ENABLE ALWAYS TRIGGER z_repack_trigger';
8080
$$
8181
LANGUAGE sql STABLE STRICT;
8282

@@ -171,9 +171,9 @@ CREATE VIEW repack.tables AS
171171
repack.get_create_index_type(PK.indexrelid, 'repack.pk_' || R.oid) AS create_pktype,
172172
'CREATE TABLE repack.log_' || R.oid || ' (id bigserial PRIMARY KEY, pk repack.pk_' || R.oid || ', row ' || repack.oid2text(R.oid) || ')' AS create_log,
173173
repack.get_create_trigger(R.oid, PK.indexrelid) AS create_trigger,
174-
repack.get_alter_table(R.oid) as alter_table,
174+
repack.get_enable_trigger(R.oid) as enable_trigger,
175175
'CREATE TABLE repack.table_' || R.oid || ' WITH (' || array_to_string(array_append(R.reloptions, 'oids=' || CASE WHEN R.relhasoids THEN 'true' ELSE 'false' END), ',') || ') TABLESPACE ' || coalesce(quote_ident(S.spcname), 'pg_default') || ' AS SELECT ' || repack.get_columns_for_create_as(R.oid) || ' FROM ONLY ' || repack.oid2text(R.oid) AS create_table,
176-
repack.get_drop_columns(R.oid, 'repack.table_' || R.oid) AS drop_columns,
176+
repack.get_drop_columns(R.oid, 'repack.table_' || R.oid) AS drop_columns,
177177
'DELETE FROM repack.log_' || R.oid AS delete_log,
178178
'LOCK TABLE ' || repack.oid2text(R.oid) || ' IN ACCESS EXCLUSIVE MODE' AS lock_table,
179179
repack.get_index_keys(CK.indexrelid, R.oid) AS ckey,

0 commit comments

Comments
 (0)