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

Merge pull request #6 from nacivida/DBZ-223 

DBZ-223 Handles dropped columns correctly.
pull/1/merge
Randall Hauch 2017-05-19 06:36:49 -05:00 committed by GitHub
parent d9415fc78f dbfe1fbbd5
commit 8a6a8305c3
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,
TupleDesc tupdesc) {
int natt;
int valid_attr_cnt = 0;
elog(DEBUG1, "processing tuple with %d columns", tupdesc->natts);
/* build column names and values */
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);
}
tmsg[natt] = palloc(sizeof(datum_msg));
memcpy(tmsg[natt], &datum_msg, sizeof(datum_msg));
tmsg[valid_attr_cnt] = palloc(sizeof(datum_msg));
memcpy(tmsg[valid_attr_cnt], &datum_msg, sizeof(datum_msg));
valid_attr_cnt++;
}
}