add

mxsm · Jan 24, 2024 · 2edbd64 · 2edbd64
1 parent 1f42f70
commit 2edbd64
Show file tree

Hide file tree

Showing 9 changed files with 48 additions and 1 deletion.
diff --git a/.../src/main/java/org/apache/eventmesh/connector/jdbc/type/mysql/GeometryCollectionType.java b/.../src/main/java/org/apache/eventmesh/connector/jdbc/type/mysql/GeometryCollectionType.java
@@ -17,12 +17,13 @@
 
 package org.apache.eventmesh.connector.jdbc.type.mysql;
 
+import org.apache.eventmesh.connector.jdbc.dialect.DatabaseDialect;
 import org.apache.eventmesh.connector.jdbc.table.catalog.Column;
 
 import java.util.Arrays;
 import java.util.List;
 
-public class  GeometryCollectionType extends SpatialDataType {
+public class GeometryCollectionType extends SpatialDataType {
 
     public static final GeometryCollectionType INSTANCE = new GeometryCollectionType();
 
@@ -39,4 +40,9 @@ public List<String> ofRegistrationKeys() {
     public String getTypeName(Column<?> column) {
         return "geometrycollection";
     }
+
+    @Override
+    public String getQueryBindingWithValue(DatabaseDialect<?> databaseDialect, Column<?> column) {
+        return "ST_GeomCollFromWKB(?,?)";
+    }
 }
diff --git a/...ector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/type/mysql/GeometryType.java b/...ector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/type/mysql/GeometryType.java
@@ -45,4 +45,8 @@ public String getTypeName(Column<?> column) {
     public String getDefaultValue(DatabaseDialect<?> databaseDialect, Column<?> column) {
         return "";
     }
+
+    public String getQueryBindingWithValue(DatabaseDialect<?> databaseDialect, Column<?> column) {
+        return "ST_GeomFromWKB(?,?)";
+    }
 }
diff --git a/...tor-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/type/mysql/LineStringType.java b/...tor-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/type/mysql/LineStringType.java
@@ -17,6 +17,7 @@
 
 package org.apache.eventmesh.connector.jdbc.type.mysql;
 
+import org.apache.eventmesh.connector.jdbc.dialect.DatabaseDialect;
 import org.apache.eventmesh.connector.jdbc.table.catalog.Column;
 
 import java.util.Arrays;
@@ -39,4 +40,9 @@ public List<String> ofRegistrationKeys() {
     public String getTypeName(Column<?> column) {
         return "linestring";
     }
+
+    @Override
+    public String getQueryBindingWithValue(DatabaseDialect<?> databaseDialect, Column<?> column) {
+        return "ST_LineFromWKB(?,?)";
+    }
 }
diff --git a/...dbc/src/main/java/org/apache/eventmesh/connector/jdbc/type/mysql/MultiLineStringType.java b/...dbc/src/main/java/org/apache/eventmesh/connector/jdbc/type/mysql/MultiLineStringType.java
@@ -17,6 +17,7 @@
 
 package org.apache.eventmesh.connector.jdbc.type.mysql;
 
+import org.apache.eventmesh.connector.jdbc.dialect.DatabaseDialect;
 import org.apache.eventmesh.connector.jdbc.table.catalog.Column;
 
 import java.util.Arrays;
@@ -39,4 +40,9 @@ public List<String> ofRegistrationKeys() {
     public String getTypeName(Column<?> column) {
         return "multilinestring";
     }
+
+    @Override
+    public String getQueryBindingWithValue(DatabaseDialect<?> databaseDialect, Column<?> column) {
+        return "ST_MLineFromWKB(?,?)";
+    }
 }
diff --git a/...tor-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/type/mysql/MultiPointType.java b/...tor-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/type/mysql/MultiPointType.java
@@ -17,6 +17,7 @@
 
 package org.apache.eventmesh.connector.jdbc.type.mysql;
 
+import org.apache.eventmesh.connector.jdbc.dialect.DatabaseDialect;
 import org.apache.eventmesh.connector.jdbc.table.catalog.Column;
 
 import java.util.Arrays;
@@ -39,4 +40,9 @@ public List<String> ofRegistrationKeys() {
     public String getTypeName(Column<?> column) {
         return "multipoint";
     }
+
+    @Override
+    public String getQueryBindingWithValue(DatabaseDialect<?> databaseDialect, Column<?> column) {
+        return "ST_MPointFromWKB(?,?)";
+    }
 }
diff --git a/...r-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/type/mysql/MultiPolygonType.java b/...r-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/type/mysql/MultiPolygonType.java
@@ -17,6 +17,7 @@
 
 package org.apache.eventmesh.connector.jdbc.type.mysql;
 
+import org.apache.eventmesh.connector.jdbc.dialect.DatabaseDialect;
 import org.apache.eventmesh.connector.jdbc.table.catalog.Column;
 
 import java.util.Arrays;
@@ -39,4 +40,9 @@ public List<String> ofRegistrationKeys() {
     public String getTypeName(Column<?> column) {
         return "multipolygon";
     }
+
+    @Override
+    public String getQueryBindingWithValue(DatabaseDialect<?> databaseDialect, Column<?> column) {
+        return "ST_MPolyFromWKB(?,?)";
+    }
 }
diff --git a/...onnector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/type/mysql/PointType.java b/...onnector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/type/mysql/PointType.java
@@ -17,6 +17,7 @@
 
 package org.apache.eventmesh.connector.jdbc.type.mysql;
 
+import org.apache.eventmesh.connector.jdbc.dialect.DatabaseDialect;
 import org.apache.eventmesh.connector.jdbc.table.catalog.Column;
 
 import java.util.Arrays;
@@ -39,4 +40,9 @@ public List<String> ofRegistrationKeys() {
     public String getTypeName(Column<?> column) {
         return "point";
     }
+
+    @Override
+    public String getQueryBindingWithValue(DatabaseDialect<?> databaseDialect, Column<?> column) {
+        return "ST_PointFromWKB(?,?)";
+    }
 }
diff --git a/...nector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/type/mysql/PolygonType.java b/...nector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/type/mysql/PolygonType.java
@@ -17,6 +17,7 @@
 
 package org.apache.eventmesh.connector.jdbc.type.mysql;
 
+import org.apache.eventmesh.connector.jdbc.dialect.DatabaseDialect;
 import org.apache.eventmesh.connector.jdbc.table.catalog.Column;
 
 import java.util.Arrays;
@@ -39,4 +40,9 @@ public List<String> ofRegistrationKeys() {
     public String getTypeName(Column<?> column) {
         return "polygon";
     }
+
+    @Override
+    public String getQueryBindingWithValue(DatabaseDialect<?> databaseDialect, Column<?> column) {
+        return "ST_PolyFromWKB(?,?)";
+    }
 }
diff --git a/...or-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/type/mysql/SpatialDataType.java b/...or-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/type/mysql/SpatialDataType.java
@@ -28,6 +28,7 @@
  * The SpatialDataType class provides constructors for specifying the type class,
  * SQL type, and name of the spatial data type.
  * </p>
+ * <a href="https://dev.mysql.com/doc/refman/8.0/en/gis-wkb-functions.html">mysql gis-wkb-functions</a>
  *
  */
 public abstract class SpatialDataType extends AbstractType<byte[]> {