diff --git a/src/JiShe.IoT.Domain/Data/IoTDbMigrationService.cs b/src/JiShe.IoT.Domain/Data/IoTDbMigrationService.cs index 3174626..f67266e 100644 --- a/src/JiShe.IoT.Domain/Data/IoTDbMigrationService.cs +++ b/src/JiShe.IoT.Domain/Data/IoTDbMigrationService.cs @@ -40,41 +40,41 @@ namespace JiShe.IoT.Data Logger.LogInformation("Started database migrations..."); - //await MigrateDatabaseSchemaAsync(); - //await SeedDataAsync(); + await MigrateDatabaseSchemaAsync(); + await SeedDataAsync(); await InitIoTDBTable(); - //Logger.LogInformation($"Successfully completed host database migrations."); + Logger.LogInformation($"Successfully completed host database migrations."); - //var tenants = await _tenantRepository.GetListAsync(includeDetails: true); + var tenants = await _tenantRepository.GetListAsync(includeDetails: true); - //var migratedDatabaseSchemas = new HashSet(); - //foreach (var tenant in tenants) - //{ - // using (_currentTenant.Change(tenant.Id)) - // { - // if (tenant.ConnectionStrings.Any()) - // { - // var tenantConnectionStrings = tenant.ConnectionStrings - // .Select(x => x.Value) - // .ToList(); + var migratedDatabaseSchemas = new HashSet(); + foreach (var tenant in tenants) + { + using (_currentTenant.Change(tenant.Id)) + { + if (tenant.ConnectionStrings.Any()) + { + var tenantConnectionStrings = tenant.ConnectionStrings + .Select(x => x.Value) + .ToList(); - // if (!migratedDatabaseSchemas.IsSupersetOf(tenantConnectionStrings)) - // { - // await MigrateDatabaseSchemaAsync(tenant); + if (!migratedDatabaseSchemas.IsSupersetOf(tenantConnectionStrings)) + { + await MigrateDatabaseSchemaAsync(tenant); - // migratedDatabaseSchemas.AddIfNotContains(tenantConnectionStrings); - // } - // } + migratedDatabaseSchemas.AddIfNotContains(tenantConnectionStrings); + } + } - // await SeedDataAsync(tenant); - // } + await SeedDataAsync(tenant); + } - // Logger.LogInformation($"Successfully completed {tenant.Name} tenant database migrations."); - //} + Logger.LogInformation($"Successfully completed {tenant.Name} tenant database migrations."); + } - //Logger.LogInformation("Successfully completed all database migrations."); - //Logger.LogInformation("You can safely end this process..."); + Logger.LogInformation("Successfully completed all database migrations."); + Logger.LogInformation("You can safely end this process..."); } private async Task MigrateDatabaseSchemaAsync(Tenant tenant = null)