admin/JiShe.IOT.Admin
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: admin:743af2a4d4b0f23d353f80fbe54e619cf8b9b881
Branches Tags
admin:master
admin:物模型服务调用
admin:master_net9_Pomelo
..
compare: admin:0a4d9fa422e63bc6b1be5975a3ef9c3dc2329bb0
Branches Tags
admin:master
admin:物模型服务调用
admin:master_net9_Pomelo

No commits in common. "743af2a4d4b0f23d353f80fbe54e619cf8b9b881" and "0a4d9fa422e63bc6b1be5975a3ef9c3dc2329bb0" have entirely different histories.
743af2a4d4 ... 0a4d9fa422

2 changed files with 4 additions and 5 deletions
Show Stats Expand all files Collapse all files

2
JiShe.ServicePro

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

7
src/JiShe.IoT.Domain/Data/IoTDbMigrationService.cs
View File

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