Compare commits

...

2 Commits

Author SHA1 Message Date
ChenYi
743af2a4d4 更新子模块 2025-07-01 15:47:50 +08:00
ChenYi
46bae0e9ed 更新子模块 2025-07-01 10:16:57 +08:00
2 changed files with 5 additions and 4 deletions

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

View File

@ -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<IIoTDbSchemaMigrator> _dbSchemaMigrators;
private readonly ITenantRepository _tenantRepository;
private readonly ICurrentTenant _currentTenant;
private readonly IIoTDBSessionPoolProvider _ioTDBSessionPoolProvider;
private readonly ITableSessionPoolProvider _ioTDBSessionPoolProvider;
public IoTDbMigrationService(
IDataSeeder dataSeeder,
IEnumerable<IIoTDbSchemaMigrator> 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)