Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commitc31516a

Browse files
committed
Preserve firing-on state when cloning row triggers to partitions
When triggers are cloned from partitioned tables to their partitions,the 'tgenabled' flag (origin/replica/always/disable) was not propagated.Make it so that the flag on the trigger on partition is initially set tothe same value as on the partitioned table.Add a test case to verify the behavior.Backpatch to 11, where this appeared in commit86f5759.Author: Álvaro Herrera <alvherre@alvh.no-ip.org>Reported-by: Justin Pryzby <pryzby@telsasoft.com>Discussion:https://postgr.es/m/20200930223450.GA14848@telsasoft.com
1 parent866237a commitc31516a

File tree

5 files changed

+121
-10
lines changed

5 files changed

+121
-10
lines changed

‎src/backend/commands/tablecmds.c

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -17083,10 +17083,10 @@ CloneRowTriggersToPartition(Relation parent, Relation partition)
1708317083
trigStmt->initdeferred = trigForm->tginitdeferred;
1708417084
trigStmt->constrrel = NULL; /* passed separately */
1708517085

17086-
CreateTrigger(trigStmt, NULL, RelationGetRelid(partition),
17087-
trigForm->tgconstrrelid, InvalidOid, InvalidOid,
17088-
trigForm->tgfoid, trigForm->oid, qual,
17089-
false, true);
17086+
CreateTriggerFiringOn(trigStmt, NULL, RelationGetRelid(partition),
17087+
trigForm->tgconstrrelid, InvalidOid, InvalidOid,
17088+
trigForm->tgfoid, trigForm->oid, qual,
17089+
false, true, trigForm->tgenabled);
1709017090

1709117091
MemoryContextSwitchTo(oldcxt);
1709217092
MemoryContextReset(perTupCxt);

‎src/backend/commands/trigger.c

Lines changed: 24 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -148,6 +148,24 @@ CreateTrigger(CreateTrigStmt *stmt, const char *queryString,
148148
OidrelOid,OidrefRelOid,OidconstraintOid,OidindexOid,
149149
Oidfuncoid,OidparentTriggerOid,Node*whenClause,
150150
boolisInternal,boolin_partition)
151+
{
152+
return
153+
CreateTriggerFiringOn(stmt,queryString,relOid,refRelOid,
154+
constraintOid,indexOid,funcoid,
155+
parentTriggerOid,whenClause,isInternal,
156+
in_partition,TRIGGER_FIRES_ON_ORIGIN);
157+
}
158+
159+
/*
160+
* Like the above; additionally the firing condition
161+
* (always/origin/replica/disabled) can be specified.
162+
*/
163+
ObjectAddress
164+
CreateTriggerFiringOn(CreateTrigStmt*stmt,constchar*queryString,
165+
OidrelOid,OidrefRelOid,OidconstraintOid,
166+
OidindexOid,Oidfuncoid,OidparentTriggerOid,
167+
Node*whenClause,boolisInternal,boolin_partition,
168+
chartrigger_fires_when)
151169
{
152170
int16tgtype;
153171
intncolumns;
@@ -790,7 +808,7 @@ CreateTrigger(CreateTrigStmt *stmt, const char *queryString,
790808
CStringGetDatum(trigname));
791809
values[Anum_pg_trigger_tgfoid-1]=ObjectIdGetDatum(funcoid);
792810
values[Anum_pg_trigger_tgtype-1]=Int16GetDatum(tgtype);
793-
values[Anum_pg_trigger_tgenabled-1]=CharGetDatum(TRIGGER_FIRES_ON_ORIGIN);
811+
values[Anum_pg_trigger_tgenabled-1]=trigger_fires_when;
794812
values[Anum_pg_trigger_tgisinternal-1]=BoolGetDatum(isInternal||in_partition);
795813
values[Anum_pg_trigger_tgconstrrelid-1]=ObjectIdGetDatum(constrrelid);
796814
values[Anum_pg_trigger_tgconstrindid-1]=ObjectIdGetDatum(indexOid);
@@ -1120,11 +1138,11 @@ CreateTrigger(CreateTrigStmt *stmt, const char *queryString,
11201138
map_partition_varattnos((List*)qual,PRS2_NEW_VARNO,
11211139
childTbl,rel);
11221140

1123-
CreateTrigger(childStmt,queryString,
1124-
partdesc->oids[i],refRelOid,
1125-
InvalidOid,indexOnChild,
1126-
funcoid,trigoid,qual,
1127-
isInternal, true);
1141+
CreateTriggerFiringOn(childStmt,queryString,
1142+
partdesc->oids[i],refRelOid,
1143+
InvalidOid,indexOnChild,
1144+
funcoid,trigoid,qual,
1145+
isInternal, true,trigger_fires_when);
11281146

11291147
table_close(childTbl,NoLock);
11301148

‎src/include/commands/trigger.h

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -162,6 +162,11 @@ extern ObjectAddress CreateTrigger(CreateTrigStmt *stmt, const char *queryString
162162
OidrelOid,OidrefRelOid,OidconstraintOid,OidindexOid,
163163
Oidfuncoid,OidparentTriggerOid,Node*whenClause,
164164
boolisInternal,boolin_partition);
165+
externObjectAddressCreateTriggerFiringOn(CreateTrigStmt*stmt,constchar*queryString,
166+
OidrelOid,OidrefRelOid,OidconstraintOid,
167+
OidindexOid,Oidfuncoid,OidparentTriggerOid,
168+
Node*whenClause,boolisInternal,boolin_partition,
169+
chartrigger_fires_when);
165170

166171
externvoidRemoveTriggerById(OidtrigOid);
167172
externOidget_trigger_oid(Oidrelid,constchar*name,boolmissing_ok);

‎src/test/regress/expected/triggers.out

Lines changed: 56 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2661,6 +2661,62 @@ select tgrelid::regclass, tgname, tgenabled from pg_trigger
26612661
(2 rows)
26622662

26632663
drop table parent, child1;
2664+
-- Verify that firing state propagates correctly on creation, too
2665+
CREATE TABLE trgfire (i int) PARTITION BY RANGE (i);
2666+
CREATE TABLE trgfire1 PARTITION OF trgfire FOR VALUES FROM (1) TO (10);
2667+
CREATE OR REPLACE FUNCTION tgf() RETURNS trigger LANGUAGE plpgsql
2668+
AS $$ begin raise exception 'except'; end $$;
2669+
CREATE TRIGGER tg AFTER INSERT ON trgfire FOR EACH ROW EXECUTE FUNCTION tgf();
2670+
INSERT INTO trgfire VALUES (1);
2671+
ERROR: except
2672+
CONTEXT: PL/pgSQL function tgf() line 1 at RAISE
2673+
ALTER TABLE trgfire DISABLE TRIGGER tg;
2674+
INSERT INTO trgfire VALUES (1);
2675+
CREATE TABLE trgfire2 PARTITION OF trgfire FOR VALUES FROM (10) TO (20);
2676+
INSERT INTO trgfire VALUES (11);
2677+
CREATE TABLE trgfire3 (LIKE trgfire);
2678+
ALTER TABLE trgfire ATTACH PARTITION trgfire3 FOR VALUES FROM (20) TO (30);
2679+
INSERT INTO trgfire VALUES (21);
2680+
CREATE TABLE trgfire4 PARTITION OF trgfire FOR VALUES FROM (30) TO (40) PARTITION BY LIST (i);
2681+
CREATE TABLE trgfire4_30 PARTITION OF trgfire4 FOR VALUES IN (30);
2682+
INSERT INTO trgfire VALUES (30);
2683+
CREATE TABLE trgfire5 (LIKE trgfire) PARTITION BY LIST (i);
2684+
CREATE TABLE trgfire5_40 PARTITION OF trgfire5 FOR VALUES IN (40);
2685+
ALTER TABLE trgfire ATTACH PARTITION trgfire5 FOR VALUES FROM (40) TO (50);
2686+
INSERT INTO trgfire VALUES (40);
2687+
SELECT tgrelid::regclass, tgenabled FROM pg_trigger
2688+
WHERE tgrelid::regclass IN (SELECT oid from pg_class where relname LIKE 'trgfire%')
2689+
ORDER BY tgrelid::regclass::text;
2690+
tgrelid | tgenabled
2691+
-------------+-----------
2692+
trgfire | D
2693+
trgfire1 | D
2694+
trgfire2 | D
2695+
trgfire3 | D
2696+
trgfire4 | D
2697+
trgfire4_30 | D
2698+
trgfire5 | D
2699+
trgfire5_40 | D
2700+
(8 rows)
2701+
2702+
ALTER TABLE trgfire ENABLE TRIGGER tg;
2703+
INSERT INTO trgfire VALUES (1);
2704+
ERROR: except
2705+
CONTEXT: PL/pgSQL function tgf() line 1 at RAISE
2706+
INSERT INTO trgfire VALUES (11);
2707+
ERROR: except
2708+
CONTEXT: PL/pgSQL function tgf() line 1 at RAISE
2709+
INSERT INTO trgfire VALUES (21);
2710+
ERROR: except
2711+
CONTEXT: PL/pgSQL function tgf() line 1 at RAISE
2712+
INSERT INTO trgfire VALUES (30);
2713+
ERROR: except
2714+
CONTEXT: PL/pgSQL function tgf() line 1 at RAISE
2715+
INSERT INTO trgfire VALUES (40);
2716+
ERROR: except
2717+
CONTEXT: PL/pgSQL function tgf() line 1 at RAISE
2718+
DROP TABLE trgfire;
2719+
DROP FUNCTION tgf();
26642720
--
26652721
-- Test the interaction between transition tables and both kinds of
26662722
-- inheritance. We'll dump the contents of the transition tables in a

‎src/test/regress/sql/triggers.sql

Lines changed: 32 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1836,6 +1836,38 @@ select tgrelid::regclass, tgname, tgenabled from pg_trigger
18361836
order by tgrelid::regclass::text;
18371837
droptable parent, child1;
18381838

1839+
-- Verify that firing state propagates correctly on creation, too
1840+
CREATETABLEtrgfire (iint) PARTITION BY RANGE (i);
1841+
CREATETABLEtrgfire1 PARTITION OF trgfire FORVALUESFROM (1) TO (10);
1842+
CREATE OR REPLACEFUNCTIONtgf() RETURNS trigger LANGUAGE plpgsql
1843+
AS $$begin raise exception'except'; end $$;
1844+
CREATETRIGGERtg AFTER INSERTON trgfire FOR EACH ROW EXECUTE FUNCTION tgf();
1845+
INSERT INTO trgfireVALUES (1);
1846+
ALTERTABLE trgfire DISABLE TRIGGER tg;
1847+
INSERT INTO trgfireVALUES (1);
1848+
CREATETABLEtrgfire2 PARTITION OF trgfire FORVALUESFROM (10) TO (20);
1849+
INSERT INTO trgfireVALUES (11);
1850+
CREATETABLEtrgfire3 (LIKE trgfire);
1851+
ALTERTABLE trgfire ATTACH PARTITION trgfire3 FORVALUESFROM (20) TO (30);
1852+
INSERT INTO trgfireVALUES (21);
1853+
CREATETABLEtrgfire4 PARTITION OF trgfire FORVALUESFROM (30) TO (40) PARTITION BY LIST (i);
1854+
CREATETABLEtrgfire4_30 PARTITION OF trgfire4 FORVALUESIN (30);
1855+
INSERT INTO trgfireVALUES (30);
1856+
CREATETABLEtrgfire5 (LIKE trgfire) PARTITION BY LIST (i);
1857+
CREATETABLEtrgfire5_40 PARTITION OF trgfire5 FORVALUESIN (40);
1858+
ALTERTABLE trgfire ATTACH PARTITION trgfire5 FORVALUESFROM (40) TO (50);
1859+
INSERT INTO trgfireVALUES (40);
1860+
SELECT tgrelid::regclass, tgenabledFROM pg_trigger
1861+
WHERE tgrelid::regclassIN (SELECToidfrom pg_classwhere relnameLIKE'trgfire%')
1862+
ORDER BY tgrelid::regclass::text;
1863+
ALTERTABLE trgfire ENABLE TRIGGER tg;
1864+
INSERT INTO trgfireVALUES (1);
1865+
INSERT INTO trgfireVALUES (11);
1866+
INSERT INTO trgfireVALUES (21);
1867+
INSERT INTO trgfireVALUES (30);
1868+
INSERT INTO trgfireVALUES (40);
1869+
DROPTABLE trgfire;
1870+
DROPFUNCTION tgf();
18391871

18401872
--
18411873
-- Test the interaction between transition tables and both kinds of

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp