Separate existing ANZ tables into two databases #11633

3 Answer(s)

• 

  0

  ismcagdas created one year ago

  Support Team

  Hi,

  I'm not sure if this scenario is fully supported or not but those tables are defined in https://github.com/aspnetboilerplate/aspnetboilerplate/blob/dev/src/Abp.ZeroCore.EntityFrameworkCore/Zero/EntityFrameworkCore/AbpZeroDbContext.cs and some of them are defined in https://github.com/aspnetboilerplate/aspnetboilerplate/blob/dev/src/Abp.ZeroCore.EntityFrameworkCore/Zero/EntityFrameworkCore/AbpZeroCommonDbContext.cs

  So, you can try removing base class from your DbContext and manually add entities to your DbContext.

  Save Cancel
• 

  0

  dschnitt created one year ago

  Hi,

  I'm not sure if this scenario is fully supported or not but those tables are defined in https://github.com/aspnetboilerplate/aspnetboilerplate/blob/dev/src/Abp.ZeroCore.EntityFrameworkCore/Zero/EntityFrameworkCore/AbpZeroDbContext.cs and some of them are defined in https://github.com/aspnetboilerplate/aspnetboilerplate/blob/dev/src/Abp.ZeroCore.EntityFrameworkCore/Zero/EntityFrameworkCore/AbpZeroCommonDbContext.cs

  So, you can try removing base class from your DbContext and manually add entities to your DbContext.

  Hi ismcagdas,

  Thank you for your immediate response. Your advice really helped. However, I can't use the below definition, it says 'TUser' could not be found. I know I should not use the 'TUser', but I'm not sure what to use instead. Same for the TRoles and TTenants

  public virtual DbSet<TUser> Users { get; set; }

  public virtual DbSet<TRole> Roles { get; set; }

  public virtual DbSet<TTenant> Tenants { get; set; }

  Please help us again. Thank you.

  Save Cancel
• 

  0

  sedulen created one year ago

  Hi @dschnitt,

  While I'm on an older version of ANZ and not running 10.2, I had looked into doing something like this a year ago for the AbpAuditLogs table, as well as another table that I have defined.

  While I never ended up taking this to production, I built a proof-of-concept that used AmbientDataContext

  I had to do a couple of things:

  1. for the tables that I wanted to move, I had to create concrete repository classes for
  2. I had to define my own ConnectionStringResolver

  Here is my concrete repository class

  using Abp.Auditing;
  using Abp.EntityFrameworkCore;
  using Abp.Runtime;
  using Abp.Domain.Repositories;
  using Microsoft.Extensions.Logging;
  using Brian.EntityFrameworkCore.Repositories;
  using Brian.EntityFrameworkCore;
  
  namespace Brian.MultiTenancy.Auditing
  {
      public class AbpAuditLogsRepository : BrianRepositoryBase<AuditLog, long>, IRepository<AuditLog, long>
      {
          private readonly ILogger<AbpAuditLogsRepository> _logger;
          public AbpAuditLogsRepository(IDbContextProvider<BrianDbContext> dbContextProvider, IAmbientDataContext ambientDataContext, ILogger<AbpAuditLogsRepository> logger)
              : base(dbContextProvider)
          {
              _logger = logger;
  
              _logger.LogDebug("[AbpAuditLogsRepository] : setting AmbientDataContext 'DBCONTEXT' to 'AuditLog'");
              ambientDataContext.SetData("DBCONTEXT", "AuditLog");
          }
      }
  }
  
  

  here is my ConnectionStringResolver

  using System;
  using Abp.Configuration.Startup;
  using Abp.Domain.Uow;
  using Microsoft.Extensions.Configuration;
  using Brian.Configuration;
  using Abp.Reflection.Extensions;
  using Abp.Zero.EntityFrameworkCore;
  using Abp.MultiTenancy;
  using Abp.Runtime;
  using Microsoft.Extensions.Logging;
  
  namespace Brian.EntityFrameworkCore
  {
      public class BrianDbConnectionStringResolver : DbPerTenantConnectionStringResolver
      {
          private readonly IConfigurationRoot _appConfiguration;
          private readonly ILogger<BrianDbConnectionStringResolver> _logger;
          private readonly IAmbientDataContext _ambientDataContext;
  
          public BrianDbConnectionStringResolver(IAbpStartupConfiguration configuration,
              ICurrentUnitOfWorkProvider currentUnitOfWorkProvider,
              ITenantCache tenantCache,
              IAppConfigurationAccessor configurationAccessor,
              IAmbientDataContext ambientDataContext,
              ILogger<BrianDbConnectionStringResolver> logger)
              : base(configuration, currentUnitOfWorkProvider, tenantCache)
          {
              _ambientDataContext = ambientDataContext;
              _appConfiguration = configurationAccessor.Configuration;
              _logger = logger;
          }
  
          public override string GetNameOrConnectionString(ConnectionStringResolveArgs args)
          {
              var s = base.GetNameOrConnectionString(args);
              object dbContext = null;
              try
              {
                  dbContext = _ambientDataContext.GetData("DBCONTEXT");
                  if(dbContext != null && dbContext.GetType().Equals(typeof(string)))
                  {
                      var context = (string)dbContext;
                      _logger.LogDebug($"[BrianDbConnectionStringResolver.GetNameOrConnectionString] : Found 'DBCONTEXT' of '{context}'");
                      //how do we ensure that there _is_ a connectionString defined for the given Context
                      var connectionString = _appConfiguration.GetConnectionString(context);
                      if(!string.IsNullOrEmpty(connectionString))
                      {
                          _logger.LogDebug($"[BrianDbConnectionStringResolver.GetNameOrConnectionString] : Found connectionString defined for 'DBCONTEXT' of '{context}'");
                          s = connectionString;
                      }
                  }
              }
              catch (Exception ex)
              {
                  //can we log this
                  _logger.LogError(ex, "[BrianDbConnectionStringResolver.GetNameOrConnectionString] : An unexpected error has occurred.");
              }
              return s;
          }
      }
  }
  

  Then in my WebCoreModule, in the PreInitialize method:

      public override void PreInitialize()
      {
          Configuration.ReplaceService<IConnectionStringResolver, BrianDbConnectionStringResolver>();
          Configuration.ReplaceService<IRepository<AuditLog, long>, AbpAuditLogsRepository>();
          ...
  

  Disclaimer: this code was written against a much older version of ABP & ANZ, and written in just a few hours as part of a rapid proof-of-concept just to see if this was even feasible. It's definitely not my cleanest work, and it was never code reviewed or tested for production readiness. Additionally, I never looked into how this would be handled in for data migrations within EntityFrameworkCore, so it's possible that doing this could cause issues running the .Migrator project or running your EF migrations either code-first or via SQL scripts.

  I don't know if ABP / ANZ still supports or recommends using DbPerTenantConnectionStringResolver or IAmbientDataContext.

  I hope this helps. Good luck! -Brian

  Save Cancel