JiShe.ServicePro

@@ -1 +1 @@
-Subproject commit 4d8e8f01ec67375b2106691ae76dd9463e8f7b20
+Subproject commit a8b64ffa94b6a63d9c2de771523c919e36768175

src/JiShe.IoT.Domain/Data/IoTDbMigrationService.cs

@@ -1,5 +1,4 @@
 using JiShe.ServicePro.ApacheIoTDB.Provider.ISessionPools;
-using JiShe.ServicePro.ApacheIoTDB.Provider.SessionPools;
 
 namespace JiShe.IoT.Data
 {
@@ -11,14 +10,14 @@ namespace JiShe.IoT.Data
         private readonly IEnumerable<IIoTDbSchemaMigrator> _dbSchemaMigrators;
         private readonly ITenantRepository _tenantRepository;
         private readonly ICurrentTenant _currentTenant;
-        private readonly ITableSessionPoolProvider _ioTDBSessionPoolProvider;
+        private readonly IIoTDBSessionPoolProvider _ioTDBSessionPoolProvider;
 
         public IoTDbMigrationService(
             IDataSeeder dataSeeder,
             IEnumerable<IIoTDbSchemaMigrator> dbSchemaMigrators,
             ITenantRepository tenantRepository,
             ICurrentTenant currentTenant,
-            ITableSessionPoolProvider ioTDBSessionPoolProvider)
+            IIoTDBSessionPoolProvider ioTDBSessionPoolProvider)
         {
             _dataSeeder = dataSeeder;
             _dbSchemaMigrators = dbSchemaMigrators;
@@ -95,7 +94,7 @@ namespace JiShe.IoT.Data
         private async Task InitIoTDBTable()
         {
             //³õʼ»¯IoTDB±íÄ£ÐÍ
-            await _ioTDBSessionPoolProvider.InitTableSessionModelAsync();
+            await _ioTDBSessionPoolProvider.GetSessionPool(true).InitTableSessionModelAsync();
         }
 
         private async Task SeedDataAsync(Tenant tenant = null)