external
/
postgres-decoderbufs
mirror of https://github.com/debezium/postgres-decoderbufs.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

DBZ-223 Handles dropped columns correctly.

pull/6/head
Naci Ishakbeyoglu 2017-05-04 23:29:18 -07:00
parent d9415fc78f
commit dbfe1fbbd5
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/decoderbufs.c
View File

@ -563,6 +563,7 @@ static void tuple_to_tuple_msg(Decoderbufs__DatumMessage **tmsg,
Relation relation, HeapTuple tuple, Relation relation, HeapTuple tuple,
TupleDesc tupdesc) { TupleDesc tupdesc) {
int natt; int natt;
int valid_attr_cnt = 0;
elog(DEBUG1, "processing tuple with %d columns", tupdesc->natts); elog(DEBUG1, "processing tuple with %d columns", tupdesc->natts);
/* build column names and values */ /* build column names and values */
for (natt = 0; natt < tupdesc->natts; natt++) { for (natt = 0; natt < tupdesc->natts; natt++) {
@ -611,8 +612,10 @@ static void tuple_to_tuple_msg(Decoderbufs__DatumMessage **tmsg,
elog(DEBUG1, "column %s is null, ignoring value", attrName); elog(DEBUG1, "column %s is null, ignoring value", attrName);
} }
tmsg[natt] = palloc(sizeof(datum_msg)); tmsg[valid_attr_cnt] = palloc(sizeof(datum_msg));
memcpy(tmsg[natt], &datum_msg, sizeof(datum_msg)); memcpy(tmsg[valid_attr_cnt], &datum_msg, sizeof(datum_msg));
valid_attr_cnt++;
} }
} }