hcq/openGauss-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix bugs for logical replication

Browse Source
This commit is contained in:
Zelin Zheng
2020-08-18 23:42:14 +08:00
parent 3112740754
commit b51172de8c
3 changed files with 61 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
contrib/mppdb_decoding/mppdb_decoding.cpp
View File

@ -241,6 +241,7 @@ static void print_literal(StringInfo s, Oid typid, char* outputstr)
const char* valptr = NULL;
switch (typid) {
case INT1OID:
case INT2OID:
case INT4OID:
case INT8OID:
@ -366,6 +367,7 @@ static void pg_decode_change(
MemoryContext old;
char* res = NULL;
data = (TestDecodingData*)ctx->output_plugin_private;
u_sess->attr.attr_common.extra_float_digits = 0;
/* output BEGIN if we haven't yet */
if (data->skip_empty_xacts && !data->xact_wrote_changes) {