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

DBZ-1064 Use geometry instead of point for empty

Browse Source
This commit is contained in:
Jiri Pechanec 2019-01-15 13:19:17 +01:00 committed by Gunnar Morling
parent ceb6c62721
commit a638d5599b
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -538,7 +538,7 @@ protected String convertSetValue(Column column, long indexes, List<String> optio
*/
protected Object convertPoint(Column column, Field fieldDefn, Object data){
final MySqlGeometry empty = MySqlGeometry.createEmpty();
return convertValue(column, fieldDefn, data, io.debezium.data.geometry.Point.createValue(fieldDefn.schema(), empty.getWkb(), empty.getSrid()), (r) -> {
return convertValue(column, fieldDefn, data, io.debezium.data.geometry.Geometry.createValue(fieldDefn.schema(), empty.getWkb(), empty.getSrid()), (r) -> {
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
@ -563,7 +563,7 @@ protected Object convertPoint(Column column, Field fieldDefn, Object data){
*/
protected Object convertGeometry(Column column, Field fieldDefn, Object data) {
final MySqlGeometry empty = MySqlGeometry.createEmpty();
return convertValue(column, fieldDefn, data, io.debezium.data.geometry.Point.createValue(fieldDefn.schema(), empty.getWkb(), empty.getSrid()), (r) -> {
return convertValue(column, fieldDefn, data, io.debezium.data.geometry.Geometry.createValue(fieldDefn.schema(), empty.getWkb(), empty.getSrid()), (r) -> {
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