修复事务

xuejmnet · xuejmnet · commit 89551d77dd17 · 2022-10-24T22:25:54.000+08:00
diff --git a/src/ShardingCore/EFCores/RelationTransactions/ShardingRelationalTransaction.cs b/src/ShardingCore/EFCores/RelationTransactions/ShardingRelationalTransaction.cs
@@ -32,6 +32,10 @@ public ShardingRelationalTransaction(IShardingDbContext shardingDbContext, IRela
         {
             _shardingDbContext =
  shardingDbContext ?? throw new ShardingCoreInvalidOperationException($"should implement {nameof(IShardingDbContext)}");
+            _shardingDbContextExecutor = shardingDbContext.GetShardingExecutor() ??
+                                         throw new ShardingCoreInvalidOperationException(
+                                             $"{shardingDbContext.GetType()} cant get {nameof(IShardingDbContextExecutor)} from {nameof(shardingDbContext.GetShardingExecutor)}");
+
         }
 
 #endif
@@ -55,6 +59,10 @@ public ShardingRelationalTransaction(IShardingDbContext shardingDbContext, IRela
         {
             _shardingDbContext =
  shardingDbContext??throw new ShardingCoreInvalidOperationException($"should implement {nameof(IShardingDbContext)}");
+            _shardingDbContextExecutor = shardingDbContext.GetShardingExecutor() ??
+                                         throw new ShardingCoreInvalidOperationException(
+                                             $"{shardingDbContext.GetType()} cant get {nameof(IShardingDbContextExecutor)} from {nameof(shardingDbContext.GetShardingExecutor)}");
+
         }
 
 #endif

Original file line number	Diff line number	Diff line change
`@@ -32,6 +32,10 @@ public ShardingRelationalTransaction(IShardingDbContext shardingDbContext, IRela`
`32`	`32`	`{`
`33`	`33`	`_shardingDbContext =`
`34`	`34`	`shardingDbContext ?? throw new ShardingCoreInvalidOperationException($"should implement {nameof(IShardingDbContext)}");`
	`35`	`+ _shardingDbContextExecutor = shardingDbContext.GetShardingExecutor() ??`
	`36`	`+ throw new ShardingCoreInvalidOperationException(`
	`37`	`+ $"{shardingDbContext.GetType()} cant get {nameof(IShardingDbContextExecutor)} from {nameof(shardingDbContext.GetShardingExecutor)}");`
	`38`	`+`
`35`	`39`	`}`
`36`	`40`
`37`	`41`	`#endif`
`@@ -55,6 +59,10 @@ public ShardingRelationalTransaction(IShardingDbContext shardingDbContext, IRela`
`55`	`59`	`{`
`56`	`60`	`_shardingDbContext =`
`57`	`61`	`shardingDbContext??throw new ShardingCoreInvalidOperationException($"should implement {nameof(IShardingDbContext)}");`
	`62`	`+ _shardingDbContextExecutor = shardingDbContext.GetShardingExecutor() ??`
	`63`	`+ throw new ShardingCoreInvalidOperationException(`
	`64`	`+ $"{shardingDbContext.GetType()} cant get {nameof(IShardingDbContextExecutor)} from {nameof(shardingDbContext.GetShardingExecutor)}");`
	`65`	`+`
`58`	`66`	`}`
`59`	`67`
`60`	`68`	`#endif`