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

DBZ-4983 Use correct Java encoding Charset in AbstractMysqlFieldReader

Browse Source
This commit is contained in:
LarsWerkman 2022-04-12 16:11:11 +02:00 committed by Jiri Pechanec
parent b7eab5f160
commit fec5aef1ec
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/AbstractMysqlFieldReader.java
View File

@ -28,6 +28,7 @@ public abstract class AbstractMysqlFieldReader implements MysqlFieldReader {
protected final Logger logger = LoggerFactory.getLogger(getClass());
private static final Set<String> TEXT_DATATYPES = Collect.unmodifiableSet("CHAR", "VARCHAR", "TEXT");
private static final MySqlValueConverters.CharsetMappingWrapper CHARSET_MAPPING_WRAPPER = new MySqlValueConverters.CharsetMappingWrapper();
private final MySqlConnectorConfig connectorConfig;
@ -71,7 +72,7 @@ public Object readField(ResultSet rs, int columnIndex, Column column, Table tabl
try {
String columnData = rs.getString(columnIndex);
if (columnData != null) {
return columnData.getBytes(column.charsetName());
return columnData.getBytes(CHARSET_MAPPING_WRAPPER.getJavaEncodingForMysqlCharSet(column.charsetName()));
}
}
catch (UnsupportedEncodingException e) {

2
debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlValueConverters.java
View File

@ -77,7 +77,7 @@ public static interface ParsingErrorHandler {
/**
* Helper to gain access to protected method
*/
private final static class CharsetMappingWrapper extends CharsetMapping {
public final static class CharsetMappingWrapper extends CharsetMapping {
String getJavaEncodingForMysqlCharSet(String mySqlCharsetName) {
return CharsetMapping.getStaticJavaEncodingForMysqlCharset(mySqlCharsetName);
}