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

[polish] remove redundant Geometry type checking code

Browse Source
This commit is contained in:
gongzhongqiang 2023-12-07 22:47:01 +08:00 committed by Jiri Pechanec
parent 5130ba7bc5
commit 018ecfe9f6
1 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -670,12 +670,8 @@ protected Object convertGeometry(Column column, Field fieldDefn, Object data) {
if (data instanceof byte[]) {
// The binlog utility sends a byte array for any Geometry type, we will use our own binaryParse to parse the byte to WKB, hence
// to the suitable class
if (data instanceof byte[]) {
// The binlog utility sends a byte array for any Geometry type, we will use our own binaryParse to parse the byte to WKB, hence
// to the suitable class
MySqlGeometry mySqlGeometry = MySqlGeometry.fromBytes((byte[]) data);
r.deliver(io.debezium.data.geometry.Geometry.createValue(fieldDefn.schema(), mySqlGeometry.getWkb(), mySqlGeometry.getSrid()));
}
MySqlGeometry mySqlGeometry = MySqlGeometry.fromBytes((byte[]) data);
r.deliver(io.debezium.data.geometry.Geometry.createValue(fieldDefn.schema(), mySqlGeometry.getWkb(), mySqlGeometry.getSrid()));
}
});
}