diff --git a/JiShe.ServicePro b/JiShe.ServicePro index b558ed2..4d8e8f0 160000 --- a/JiShe.ServicePro +++ b/JiShe.ServicePro @@ -1 +1 @@ -Subproject commit b558ed2c47d6d0279cc944c4ec8922a43bdd1e9d +Subproject commit 4d8e8f01ec67375b2106691ae76dd9463e8f7b20 diff --git a/src/JiShe.IoT.Domain/Data/IoTDbMigrationService.cs b/src/JiShe.IoT.Domain/Data/IoTDbMigrationService.cs index 0681d62..f67266e 100644 --- a/src/JiShe.IoT.Domain/Data/IoTDbMigrationService.cs +++ b/src/JiShe.IoT.Domain/Data/IoTDbMigrationService.cs @@ -1,4 +1,5 @@ using JiShe.ServicePro.ApacheIoTDB.Provider.ISessionPools; +using JiShe.ServicePro.ApacheIoTDB.Provider.SessionPools; namespace JiShe.IoT.Data { @@ -10,14 +11,14 @@ namespace JiShe.IoT.Data private readonly IEnumerable _dbSchemaMigrators; private readonly ITenantRepository _tenantRepository; private readonly ICurrentTenant _currentTenant; - private readonly IIoTDBSessionPoolProvider _ioTDBSessionPoolProvider; + private readonly ITableSessionPoolProvider _ioTDBSessionPoolProvider; public IoTDbMigrationService( IDataSeeder dataSeeder, IEnumerable dbSchemaMigrators, ITenantRepository tenantRepository, ICurrentTenant currentTenant, - IIoTDBSessionPoolProvider ioTDBSessionPoolProvider) + ITableSessionPoolProvider ioTDBSessionPoolProvider) { _dataSeeder = dataSeeder; _dbSchemaMigrators = dbSchemaMigrators; @@ -94,7 +95,7 @@ namespace JiShe.IoT.Data private async Task InitIoTDBTable() { //初始化IoTDB表模型 - await _ioTDBSessionPoolProvider.GetSessionPool(true).InitTableSessionModelAsync(); + await _ioTDBSessionPoolProvider.InitTableSessionModelAsync(); } private async Task SeedDataAsync(Tenant tenant = null)