From 743af2a4d4b0f23d353f80fbe54e619cf8b9b881 Mon Sep 17 00:00:00 2001 From: ChenYi <296215406@outlook.com> Date: Tue, 1 Jul 2025 15:47:50 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0=E5=AD=90=E6=A8=A1=E5=9D=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- JiShe.ServicePro | 2 +- src/JiShe.IoT.Domain/Data/IoTDbMigrationService.cs | 7 ++++--- 2 files changed, 5 insertions(+), 4 deletions(-) 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)