alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-5874 Making sure trace message gets logged

Browse Source
This commit is contained in:
Gunnar Morling 2022-11-23 19:00:32 +01:00 committed by Jiri Pechanec
parent d42b5480a3
commit e7aba47a24
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/connection/pgoutput/PgOutputMessageDecoder.java
View File

@ -733,6 +733,8 @@ private static List<Column> resolveColumnsFromStreamTupleData(ByteBuffer buffer,
final String typeExpression = column.typeExpression();
final boolean optional = column.isOptional();
final Column replicationMessageColumn;
// Read the sub-message type
// 't' : Value is represented as text
// 'u' : An unchanged TOAST-ed value, actual value is not sent.
@ -740,7 +742,7 @@ private static List<Column> resolveColumnsFromStreamTupleData(ByteBuffer buffer,
char type = (char) buffer.get();
if (type == 't') {
final String valueStr = readColumnValueAsString(buffer);
columns.add(
replicationMessageColumn =
new AbstractReplicationMessageColumn(columnName, columnType, typeExpression, optional) {
@Override
public Object getValue(PgConnectionSupplier connection, boolean includeUnknownDatatypes) {
@ -755,7 +757,7 @@ public String toString() {
});
}
else if (type == 'u') {
columns.add(
replicationMessageColumn =
new UnchangedToastedReplicationMessageColumn(columnName, columnType, typeExpression, optional) {
@Override
public String toString() {
@ -764,7 +766,7 @@ public String toString() {
});
}
else if (type == 'n') {
columns.add(
replicationMessageColumn =
new AbstractReplicationMessageColumn(columnName, columnType, typeExpression, true) {
@Override
public Object getValue(PgConnectionSupplier connection, boolean includeUnknownDatatypes) {
@ -772,9 +774,11 @@ public Object getValue(PgConnectionSupplier connection, boolean includeUnknownDa
}
});
}
columns.add(replicationMessageColumn);
LOGGER.trace("Column: {}", replicationMessageColumn));
}
columns.forEach(c -> LOGGER.trace("Column: {}", c));
return columns;
}