IlyaSobolev/DocSpace-client
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #420 from ONLYOFFICE/feature/dbcontextmanager-optimization

Browse Source 
Feature/dbcontextmanager optimization
This commit is contained in:
Pavel Bannov 2021-10-27 12:16:17 +03:00 committed by GitHub
commit 7ca1af82e7
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 29 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
common/ASC.Core.Common/EF/Context/DbContextManager.cs
View File

@ -11,16 +11,19 @@ namespace ASC.Core.Common.EF
public class BaseDbContextManager<T> : OptionsManager<T>, IDisposable where T : class, IDisposable, IAsyncDisposable, new()
{
private Dictionary<string, T> Pairs { get; set; }
private MigrationHistory MigrationHistory { get; set; }
private List<T> AsyncList { get; set; }
private IOptionsFactory<T> Factory { get; }
private IConfiguration Configuration { get; }
public BaseDbContextManager(IOptionsFactory<T> factory, IConfiguration configuration) : base(factory)
public BaseDbContextManager(IOptionsFactory<T> factory, IConfiguration configuration,
MigrationHistory migrationHistory) : base(factory)
{
Pairs = new Dictionary<string, T>();
AsyncList = new List<T>();
Factory = factory;
Configuration = configuration;
MigrationHistory = migrationHistory;
}
public override T Get(string name)
@ -32,7 +35,8 @@ namespace ASC.Core.Common.EF
if (t is BaseDbContext dbContext)
{
if (Configuration["migration:enabled"] == "true")
if (Configuration["migration:enabled"] == "true"
&& MigrationHistory.TryAddMigratedContext(t.GetType()))
{
dbContext.Migrate();
}
@ -68,14 +72,16 @@ namespace ASC.Core.Common.EF
[Scope(typeof(ConfigureDbContext<>))]
public class DbContextManager<T> : BaseDbContextManager<T> where T : BaseDbContext, new()
{
public DbContextManager(IOptionsFactory<T> factory, IConfiguration configuration) : base(factory, configuration)
public DbContextManager(IOptionsFactory<T> factory, IConfiguration configuration,
MigrationHistory migrationHistory) : base(factory, configuration, migrationHistory)
{
}
}
public class MultiRegionalDbContextManager<T> : BaseDbContextManager<MultiRegionalDbContext<T>> where T : BaseDbContext, new()
{
public MultiRegionalDbContextManager(IOptionsFactory<MultiRegionalDbContext<T>> factory, IConfiguration configuration) : base(factory, configuration)
public MultiRegionalDbContextManager(IOptionsFactory<MultiRegionalDbContext<T>> factory, IConfiguration configuration,
MigrationHistory migrationHistory) : base(factory, configuration, migrationHistory)
{
}
}

19
common/ASC.Core.Common/EF/MigrationHistory.cs Normal file
View File

@ -0,0 +1,19 @@
using System;
using System.Collections.Concurrent;
using ASC.Common;
namespace ASC.Core.Common.EF
{
[Singletone]
public class MigrationHistory
{
private ConcurrentDictionary<Type, bool> _historyStore
= new ConcurrentDictionary<Type, bool>();
public bool TryAddMigratedContext(Type contextType)
{
return _historyStore.TryAdd(contextType, true);
}
}
}