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

Changed output table to only use table name and exclude the schema

pull/1/head
Xavier Stevens 2015-01-16 14:43:34 -08:00
parent ec818d7d58
commit 5d4368bbca
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/decoderbufs.c
View File

@ -417,9 +417,7 @@ static void pg_decode_change(LogicalDecodingContext *ctx, ReorderBufferTXN *txn,
/* set common fields */ /* set common fields */
rmsg.commit_time = TIMESTAMPTZ_TO_USEC_SINCE_EPOCH(txn->commit_time); rmsg.commit_time = TIMESTAMPTZ_TO_USEC_SINCE_EPOCH(txn->commit_time);
rmsg.has_commit_time = true; rmsg.has_commit_time = true;
rmsg.table = quote_qualified_identifier( rmsg.table = pstrdup(NameStr(class_form->relname));
get_namespace_name(get_rel_namespace(RelationGetRelid(relation))),
NameStr(class_form->relname));
/* decode different operation types */ /* decode different operation types */
switch (change->action) { switch (change->action) {