Skip to content

Commit 25a8c2e

Browse files
committed
针对迁移分表tails为空的情况判断[#195]
1 parent e6d9864 commit 25a8c2e

File tree

2 files changed

+6
-1
lines changed

2 files changed

+6
-1
lines changed

src/ShardingCore/Helpers/MigrationHelper.cs

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -66,10 +66,13 @@ List<MigrationCommand> addCmds
6666
{
6767
if (migrationResult.CommandType == MigrationCommandTypeEnum.TableCommand)
6868
{
69+
if (migrationResult.IsShardingCommand)
70+
{
71+
migrationCommands.Remove(aAddCmd);
72+
}
6973
//如果是分表
7074
if (shardingCmds.IsNotEmpty())
7175
{
72-
migrationCommands.Remove(aAddCmd);
7376
//针对builder的原始表进行移除
7477
shardingCmds.ForEach(aShardingCmd =>
7578
{
@@ -154,6 +157,7 @@ private static (MigrationResult migrationResult, List<string>) BuildDataSourceSh
154157
if (migrationResult.InDataSource && !string.IsNullOrWhiteSpace(absTableName) &&
155158
existsShardingTables.ContainsKey(absTableName))
156159
{
160+
migrationResult.IsShardingCommand = true;
157161
var shardings = existsShardingTables[absTableName];
158162
shardings.ForEach(aShardingTable =>
159163
{

src/ShardingCore/Helpers/MigrationResult.cs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,5 +5,6 @@ public class MigrationResult
55
{
66
public MigrationCommandTypeEnum CommandType { get; set; } = MigrationCommandTypeEnum.OtherCommand;
77
public bool InDataSource { get; set; } = true;
8+
public bool IsShardingCommand { get; set; }
89
}
910
}

0 commit comments

Comments
 (0)