mysql table ensure manager添加null判断处理

samples/Sample.SqlServer/Controllers/ValuesController.cs

@@ -41,6 +41,7 @@ namespace Sample.SqlServer.Controllers
         [HttpGet]
         public async Task<IActionResult> Get2x()
         {
+            _defaultTableDbContext.ChangeTracker.HasChanges()
             //var queryable = _defaultTableDbContext.Set<SysUserMod>().Where(o=>true);
 
             //var tableRouteRuleEngineFactory = ShardingContainer.GetService<ITableRouteRuleEngineFactory<DefaultShardingDbContext>>();

samples/Sample.SqlServer/Domain/Entities/SysUserMod.cs

@@ -1,4 +1,6 @@
 using System;
+using System.ComponentModel.DataAnnotations.Schema;
+using Microsoft.EntityFrameworkCore;
 using ShardingCore.Core;
 
 namespace Sample.SqlServer.Domain.Entities
@@ -12,6 +14,7 @@ namespace Sample.SqlServer.Domain.Entities
     /// <summary>
     /// 用户表
     /// </summary>
+    //[Index("Name")]
     public class SysUserMod
     {
         /// <summary>

samples/Sample.SqlServer/Domain/Maps/SysUserModMap.cs

@@ -14,8 +14,8 @@ namespace Sample.SqlServer.Domain.Maps
     {
         public void Configure(EntityTypeBuilder<SysUserMod> builder)
         {
-            //builder.HasKey(o => o.Id);
-            builder.HasNoKey();
+            builder.HasKey(o => o.Id);
+            //builder.HasNoKey();
             builder.Property(o => o.Id).IsRequired().HasMaxLength(128);
             builder.Property(o => o.Name).HasMaxLength(128);
             builder.ToTable(nameof(SysUserMod));

src/ShardingCore/EFCores/ShardingChangeTracker.cs

@@ -0,0 +1,30 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.ChangeTracking;
+using Microsoft.EntityFrameworkCore.ChangeTracking.Internal;
+using Microsoft.EntityFrameworkCore.Metadata;
+using ShardingCore.Exceptions;
+using ShardingCore.Sharding.Abstractions;
+
+namespace ShardingCore.EFCores
+{
+    public class ShardingChangeTracker: ChangeTracker
+    {
+        private readonly ICurrentDbContextDiscover _contextDiscover;
+
+        public ShardingChangeTracker(DbContext context, IStateManager stateManager, IChangeDetector changeDetector, IModel model, IEntityEntryGraphIterator graphIterator) : base(context, stateManager, changeDetector, model, graphIterator)
+        {
+            _contextDiscover = context as ICurrentDbContextDiscover?? throw new ShardingCoreNotSupportException($"{context.GetType()} not impl {nameof(ICurrentDbContextDiscover)}");
+        }
+
+        public override bool HasChanges()
+        {
+            return _contextDiscover.GetCurrentDbContexts().Any(o =>
+                o.Value.GetCurrentContexts().Any(r => r.Value.ChangeTracker.HasChanges()));
+        }
+    }
+}

src/ShardingCore/Sharding/AbstractShardingDbContext.cs

@@ -27,7 +27,7 @@ namespace ShardingCore.Sharding
     /// <summary>
     /// 分表分库的dbcontext
     /// </summary>
-    public abstract class AbstractShardingDbContext : DbContext, IShardingDbContext, ISupportShardingTransaction, ISupportShardingReadWrite
+    public abstract class AbstractShardingDbContext : DbContext, IShardingDbContext, ISupportShardingTransaction, ISupportShardingReadWrite//,ICurrentDbContextDiscover
     {
         protected IShardingDbContextExecutor ShardingDbContextExecutor { get; }
 
@@ -505,5 +505,9 @@ namespace ShardingCore.Sharding
             ShardingDbContextExecutor.Commit();
         }
 
+        //public IDictionary<string, IDataSourceDbContext> GetCurrentDbContexts()
+        //{
+        //    return ShardingDbContextExecutor.GetCurrentDbContexts();
+        //}
     }
 }

src/ShardingCore/Sharding/Abstractions/ICurrentDbContextDiscover.cs

@@ -0,0 +1,14 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using ShardingCore.Sharding.ShardingDbContextExecutors;
+
+namespace ShardingCore.Sharding.Abstractions
+{
+    public interface ICurrentDbContextDiscover
+    {
+        IDictionary<string, IDataSourceDbContext> GetCurrentDbContexts();
+    }
+}

src/ShardingCore/TableExists/MySqlTableEnsureManager.cs

@@ -24,8 +24,12 @@ namespace ShardingCore.TableExists
             {
                 for (int i = 0; i < dataTable.Rows.Count; i++)
                 {
-                    if (database.Equals(dataTable.Rows[i][TABLE_SCHEMA]?.ToString()??String.Empty,StringComparison.OrdinalIgnoreCase))
-                        result.Add(dataTable.Rows[i][TABLE_NAME].ToString());
+                    var schema = dataTable.Rows[i][TABLE_SCHEMA];
+                    if (database.Equals($"{schema}", StringComparison.OrdinalIgnoreCase))
+                    {
+                        var tableName = dataTable.Rows[i][TABLE_NAME];
+                        result.Add($"{tableName}");
+                    }
                 }
             }
             return result;