Error While Creating Tenant in Different Database #1556

4 Answer(s)

• 

  0

  maharatha created 7 years ago

  Any update on this ? I am really having a hard time figuring out the issue

  Save Cancel
• 

  0

  ismcagdas created 7 years ago

  Support Team

  Hi,

  We didn't have this error before ?

  Does it happen with same connectionString ? First you get error then after a few trials you manage to create tenant and database ?

  And is your Sql Server on a local server ?

  Save Cancel
• 

  0

  maharatha created 7 years ago

  Below is the code which we wrote for creating the Tenant. We copied from the existing code and made some modification. We are adding an Organization Id to the tenant.

  Also it's withing the same database and the database is not local.

  public async Task<int> CreateWithAdminUserAsync(string tenancyName, string name, string adminPassword, string adminEmailAddress, bool isActive, int? editionId, bool shouldChangePasswordOnNextLogin,
              bool sendActivationEmail, long? organizationId, int? sourcetenantId, List<string> entityList)
          {
              int newTenantId;
              long newAdminId;
  
              using (var uow = _unitOfWorkManager.Begin(TransactionScopeOption.RequiresNew))
              {
  
                  var connectionstringUnit = await (from org in _organizationRepository.GetAll()
                                                    join constr in _connectionStringRepository.GetAll() on org.ConnectionStringId equals
                                                        constr.Id
                                                    where org.Id == organizationId
                                                    select constr).FirstOrDefaultAsync();
  
                  //Create tenant
                  var tenant = new Tenant(tenancyName, name)
                  {
                      IsActive = isActive,
                      EditionId = editionId,
                      ConnectionString = ReferenceEquals(connectionstringUnit, null) ? null : connectionstringUnit.ConnectionString,
                      OrganizationUnitId = organizationId
                  };
  
                  CheckErrors(await CreateAsync(tenant));
                  await _unitOfWorkManager.Current.SaveChangesAsync(); //To get new tenant's id.
  
                  //Create tenant database
                  _abpZeroDbMigrator.CreateOrMigrateForTenant(tenant);
  
                  //We are working entities of new tenant, so changing tenant filter
                  using (_unitOfWorkManager.Current.SetTenantId(tenant.Id))
                  {
                      //Create static roles for new tenant
                      CheckErrors(await _roleManager.CreateStaticRoles(tenant.Id));
                      await _unitOfWorkManager.Current.SaveChangesAsync(); //To get static role ids
  
                      //grant all permissions to admin role
                      var adminRole = _roleManager.Roles.Single(r => r.Name == StaticRoleNames.Tenants.Admin);
                      await _roleManager.GrantAllPermissionsAsync(adminRole);
  
                      //User role should be default
                      var userRole = _roleManager.Roles.Single(r => r.Name == StaticRoleNames.Tenants.User);
                      userRole.IsDefault = true;
                      CheckErrors(await _roleManager.UpdateAsync(userRole));
  
                      //Create admin user for the tenant
                      if (adminPassword.IsNullOrEmpty())
                      {
                          adminPassword = User.CreateRandomPassword();
                      }
  
                      var adminUser = User.CreateTenantAdminUser(tenant.Id, adminEmailAddress, adminPassword);
                      adminUser.ShouldChangePasswordOnNextLogin = shouldChangePasswordOnNextLogin;
                      adminUser.IsActive = isActive;
  
                      CheckErrors(await _userManager.CreateAsync(adminUser));
                      await _unitOfWorkManager.Current.SaveChangesAsync(); //To get admin user's id
  
                      //Assign admin user to admin role!
                      CheckErrors(await _userManager.AddToRoleAsync(adminUser.Id, adminRole.Name));
  
                      //Notifications
                      await _appNotifier.WelcomeToTheApplicationAsync(adminUser);
  
                      //Send activation email
                      if (sendActivationEmail)
                      {
                          adminUser.SetNewEmailConfirmationCode();
                          await _userEmailer.SendEmailActivationLinkAsync(adminUser, adminPassword);
                      }
  
                      await _unitOfWorkManager.Current.SaveChangesAsync();
  
                      await _demoDataBuilder.BuildForAsync(tenant);
  
                      newTenantId = tenant.Id;
                      newAdminId = adminUser.Id;
  
                  }
                  if (sourcetenantId.HasValue)
                      await CloneTenantData(newTenantId, sourcetenantId, entityList);
                  await uow.CompleteAsync();
              }
  
              //Used a second UOW since UOW above sets some permissions and _notificationSubscriptionManager.SubscribeToAllAvailableNotificationsAsync needs these permissions to be saved.
              using (var uow = _unitOfWorkManager.Begin(TransactionScopeOption.RequiresNew))
              {
                  using (_unitOfWorkManager.Current.SetTenantId(newTenantId))
                  {
                      await _notificationSubscriptionManager.SubscribeToAllAvailableNotificationsAsync(new UserIdentifier(newTenantId, newAdminId));
                      await _unitOfWorkManager.Current.SaveChangesAsync();
                      await uow.CompleteAsync();
                  }
              }
  
              return newTenantId;
          }
  

  Do you find any issue with this code ?

  Save Cancel
• 

  0

  ismcagdas created 7 years ago

  Support Team

  Hi,

  Can you try to move added codes in a seperate unitOfWork ?

  Move these lines before first unitOfWork and put it inside another unit of work

  var connectionstringUnit = await (from org in _organizationRepository.GetAll()
                                join constr in _connectionStringRepository.GetAll() on org.ConnectionStringId equals
                                    constr.Id
                                where org.Id == organizationId
                                select constr).FirstOrDefaultAsync();
  

  and put CloneTenantData just before these lines and put it in a new unitOfWork

  //Used a second UOW since UOW above sets some permissions and _notificationSubscriptionManager.SubscribeToAllAvailableNotificationsAsync needs these permissions to be saved.
  using (var uow = _unitOfWorkManager.Begin(TransactionScopeOption.RequiresNew))
  

  Can you also share CloneTenantData code if this does not work for you ?

  Thanks.

  Save Cancel