aboutsummaryrefslogtreecommitdiff
path: root/src/backend
diff options
context:
space:
mode:
Diffstat (limited to 'src/backend')
-rw-r--r--src/backend/replication/logical/worker.c18
1 files changed, 18 insertions, 0 deletions
diff --git a/src/backend/replication/logical/worker.c b/src/backend/replication/logical/worker.c
index 2bd61d9d201..32437202fe5 100644
--- a/src/backend/replication/logical/worker.c
+++ b/src/backend/replication/logical/worker.c
@@ -27,6 +27,7 @@
#include "pgstat.h"
#include "funcapi.h"
+#include "access/sysattr.h"
#include "access/xact.h"
#include "access/xlog_internal.h"
@@ -706,6 +707,8 @@ apply_handle_update(StringInfo s)
bool has_oldtup;
TupleTableSlot *localslot;
TupleTableSlot *remoteslot;
+ RangeTblEntry *target_rte;
+ int i;
bool found;
MemoryContext oldctx;
@@ -735,6 +738,21 @@ apply_handle_update(StringInfo s)
RelationGetDescr(rel->localrel));
EvalPlanQualInit(&epqstate, estate, NULL, NIL, -1);
+ /*
+ * Populate updatedCols so that per-column triggers can fire. This could
+ * include more columns than were actually changed on the publisher
+ * because the logical replication protocol doesn't contain that
+ * information. But it would for example exclude columns that only exist
+ * on the subscriber, since we are not touching those.
+ */
+ target_rte = list_nth(estate->es_range_table, 0);
+ for (i = 0; i < remoteslot->tts_tupleDescriptor->natts; i++)
+ {
+ if (newtup.changed[i])
+ target_rte->updatedCols = bms_add_member(target_rte->updatedCols,
+ i + 1 - FirstLowInvalidHeapAttributeNumber);
+ }
+
PushActiveSnapshot(GetTransactionSnapshot());
ExecOpenIndices(estate->es_result_relation_info, false);