MySql geometry fix

borisdj · Jan 11, 2024 · 1289ab4 · 1289ab4
1 parent 337f4e8
commit 1289ab4
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/EFCore.BulkExtensions/SqlAdapters/MySql/MySqlAdapter.cs b/EFCore.BulkExtensions/SqlAdapters/MySql/MySqlAdapter.cs
@@ -489,7 +489,7 @@ private static DataTable InnerGetDataTable<T>(DbContext context, ref Type type,
 
                 if (isMySql && (propertyType == typeof(Geometry) || propertyType.IsSubclassOf(typeof(Geometry))))
                 {
-                    propertyType = typeof(byte[]);
+                    propertyType = typeof(MySqlGeometry);
                     tableInfo.HasSpatialType = true;
                     if (tableInfo.BulkConfig.PropertiesToIncludeOnCompare != null || tableInfo.BulkConfig.PropertiesToIncludeOnCompare != null)
                     {
@@ -686,8 +686,16 @@ private static DataTable InnerGetDataTable<T>(DbContext context, ref Type type,
                     string columnName = tableInfo.ConvertiblePropertyColumnDict[property.Name];
                     propertyValue = tableInfo.ConvertibleColumnConverterDict[columnName].ConvertToProvider.Invoke(propertyValue);
                 }
+
                 //TODO: Hamdling special types
 
+                if (tableInfo.HasSpatialType && propertyValue is Geometry geometryValue)
+                {
+                    geometryValue.SRID = tableInfo.BulkConfig.SRID;
+                    var wkb = geometryValue.ToBinary();
+                    propertyValue = MySqlGeometry.FromWkb(geometryValue.SRID, wkb);
+                }
+
                 if (propertyValue is HierarchyId hierarchyValue && isMySql)
                 {
                     using MemoryStream memStream = new();