azexcy commented on code in PR #22685:
URL: https://github.com/apache/shardingsphere/pull/22685#discussion_r1040622074
##########
kernel/data-pipeline/dialect/opengauss/src/main/java/org/apache/shardingsphere/data/pipeline/opengauss/ingest/wal/decode/MppdbDecodingPlugin.java:
##########
@@ -59,30 +68,46 @@ public final class MppdbDecodingPlugin implements
DecodingPlugin {
private final BaseTimestampUtils timestampUtils;
+ private final boolean decodeWithXid;
+
+ public MppdbDecodingPlugin(final BaseTimestampUtils timestampUtils) {
+ this.timestampUtils = timestampUtils;
+ decodeWithXid = false;
+ }
+
@Override
public AbstractWALEvent decode(final ByteBuffer data, final
BaseLogSequenceNumber logSequenceNumber) {
AbstractWALEvent result;
- char eventType = readOneChar(data);
- result = '{' == eventType ? readTableEvent(readMppData(data)) : new
PlaceholderEvent();
+ String dataText = StandardCharsets.UTF_8.decode(data).toString();
Review Comment:
org.opengauss.core.v3.QueryExecutorImpl#startCopy
```
Utils.encodeUTF8(statementName);
```
seem the client always use the utf-8, and tested succeed at local when
contain chinese characters
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
