利用EF6简单实现多租户的应用
更新时间：2019年09月10日 09:38:22 作者：阿新
这篇文章主要给大家介绍了关于如何利用EF6简单实现多租户应用的相关资料，文中通过示例代码介绍的非常详细，对大家学习或者使用EF6具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧
什么是多租户
网上有好多解释，有些上升到了架构设计，让你觉得似乎非常高深莫测，特别是目前流行的ABP架构中就有提到多租户（IMustHaveTenant），其实说的简单一点就是再每一张数据库的表中添加一个TenantId的字段，用于区分属于不同的租户（或是说不同的用户组）的数据。关键是现实的方式必须对开发人员来说是透明的，不需要关注这个字段的信息，由后台或是封装在基类中实现数据的筛选和更新。
基本原理
从新用户注册时就必须指定用户的TenantId,我的例子是用CompanyId,公司信息做为TenantId,哪些用户属于不同的公司，每个用户将来只能修改和查询属于本公司的数据。
接下来就是用户登录的时候获取用户信息的时候把TenantId保存起来，asp.net mvc（不是 core） 是通过 Identity 2.0实现的认证和授权，这里需要重写部分代码来实现。
最后用户对数据查询/修改/新增时把用户信息中TenantId，这里就需要设定一个Filter(过滤器)和每次SaveChange的插入TenantId
如何实现
第一步，扩展 Asp.net Identity user 属性，必须新增一个TenantId字段,根据Asp.net Mvc 自带的项目模板修改IdentityModels.cs 这个文件
// You can add profile data for the user by adding more properties to your ApplicationUser class, please visit go.microsoft.com/fwlink/?LinkID=317594 to learn more.
public class ApplicationUser : IdentityUser
{
public async Task<ClaimsIdentity> GenerateUserIdentityAsync(UserManager<ApplicationUser> manager, string authenticationType)
{
// Note the authenticationType must match the one defined in CookieAuthenticationOptions.AuthenticationType
var userIdentity = await manager.CreateIdentityAsync(this, authenticationType);
// Add custom user claims here
userIdentity.AddClaim(new Claim(“schemas.microsoft.com/identity/claims/tenantid”, this.TenantId.ToString()));
userIdentity.AddClaim(new Claim(“CompanyName”, this.CompanyName));
userIdentity.AddClaim(new Claim(“EnabledChat”, this.EnabledChat.ToString()));
userIdentity.AddClaim(new Claim(“FullName”, this.FullName));
userIdentity.AddClaim(new Claim(“AvatarsX50”, this.AvatarsX50));
userIdentity.AddClaim(new Claim(“AvatarsX120”, this.AvatarsX120));
return userIdentity;
}
public async Task<ClaimsIdentity> GenerateUserIdentityAsync(UserManager<ApplicationUser> manager)
{
// Note the authenticationType must match the one defined in CookieAuthenticationOptions.AuthenticationType
var userIdentity = await manager.CreateIdentityAsync(this, DefaultAuthenticationTypes.ApplicationCookie);
// Add custom user claims here
return userIdentity;
}
[Display(Name = “全名”)]
public string FullName { get; set; }
[Display(Name = “性别”)]
public int Gender { get; set; }
public int AccountType { get; set; }
[Display(Name = “所属公司”)]
public string CompanyCode { get; set; }
[Display(Name = “公司名称”)]
public string CompanyName { get; set; }
[Display(Name = “是否在线”)]
public bool IsOnline { get; set; }
[Display(Name = “是否开启聊天功能”)]
public bool EnabledChat { get; set; }
[Display(Name = “小头像”)]
public string AvatarsX50 { get; set; }
[Display(Name = “大头像”)]
public string AvatarsX120 { get; set; }
[Display(Name = “租户ID”)]
public int TenantId { get; set; }
}
public class ApplicationDbContext : IdentityDbContext<ApplicationUser>
{
public ApplicationDbContext()
: base(“DefaultConnection”, throwIfV1Schema: false) => Database.SetInitializer<ApplicationDbContext>(null);
public static ApplicationDbContext Create() => new ApplicationDbContext();
}
第二步 修改注册用户的代码，注册新用户的时候需要选择所属的公司信息
[HttpPost]
[AllowAnonymous]
[ValidateAntiForgeryToken]
public async Task<ActionResult> Register(AccountRegistrationModel viewModel)
{
var data = this._companyService.Queryable().Select(x => new ListItem() { Value = x.Id.ToString(), Text = x.Name });
this.ViewBag.companylist = data;
// Ensure we have a valid viewModel to work with
if (!this.ModelState.IsValid)
{
return this.View(viewModel);
}
// Try to create a user with the given identity
try
{
// Prepare the identity with the provided information
var user = new ApplicationUser
{
UserName = viewModel.Username,
FullName = viewModel.Lastname + “.” + viewModel.Firstname,
CompanyCode = viewModel.CompanyCode,
CompanyName = viewModel.CompanyName,
TenantId=viewModel.TenantId,
Email = viewModel.Email,
AccountType = 0
};
var result = await this.UserManager.CreateAsync(user, viewModel.Password);
// If the user could not be created
if (!result.Succeeded)
{
// Add all errors to the page so they can be used to display what went wrong
this.AddErrors(result);
return this.View(viewModel);
}
// If the user was able to be created we can sign it in immediately
// Note: Consider using the email verification proces
await this.SignInAsync(user, true);
return this.RedirectToLocal();
}
catch (DbEntityValidationException ex)
{
// Add all errors to the page so they can be used to display what went wrong
this.AddErrors(ex);
return this.View(viewModel);
}
}
AccountController.cs
第三步 读取登录用户的TenantId 在用户查询和新增修改时把TenantId插入到表中,这里需要引用
Z.EntityFramework.Plus，这个是免费开源的一个类库，功能强大
public StoreContext()
: base(“Name=DefaultConnection”) {
//获取登录用户信息,tenantid
var claimsidentity = (ClaimsIdentity)HttpContext.Current.User.Identity;
var tenantclaim = claimsidentity?.FindFirst(“schemas.microsoft.com/identity/claims/tenantid”);
var tenantid = Convert.ToInt32(tenantclaim?.Value);
//设置当对Work对象进行查询时默认添加过滤条件
QueryFilterManager.Filter<Work>(q => q.Where(x => x.TenantId == tenantid));
//设置当对Order对象进行查询时默认添加过滤条件
QueryFilterManager.Filter<Order>(q => q.Where(x => x.TenantId == tenantid));
}
public override Task<int> SaveChangesAsync(CancellationToken cancellationToken)
{
var currentDateTime = DateTime.Now;
var claimsidentity = (ClaimsIdentity)HttpContext.Current.User.Identity;
var tenantclaim = claimsidentity?.FindFirst(“schemas.microsoft.com/identity/claims/tenantid”);
var tenantid = Convert.ToInt32(tenantclaim?.Value);
foreach (var auditableEntity in this.ChangeTracker.Entries<Entity>())
{
if (auditableEntity.State == EntityState.Added || auditableEntity.State == EntityState.Modified)
{
//auditableEntity.Entity.LastModifiedDate = currentDateTime;
switch (auditableEntity.State)
{
case EntityState.Added:
auditableEntity.Property(“LastModifiedDate”).IsModified = false;
auditableEntity.Property(“LastModifiedBy”).IsModified = false;
auditableEntity.Entity.CreatedDate = currentDateTime;
auditableEntity.Entity.CreatedBy = claimsidentity.Name;
auditableEntity.Entity.TenantId = tenantid;
break;
case EntityState.Modified:
auditableEntity.Property(“CreatedDate”).IsModified = false;
auditableEntity.Property(“CreatedBy”).IsModified = false;
auditableEntity.Entity.LastModifiedDate = currentDateTime;
auditableEntity.Entity.LastModifiedBy = claimsidentity.Name;
auditableEntity.Entity.TenantId = tenantid;
//if (auditableEntity.Property(p => p.Created).IsModified || auditableEntity.Property(p => p.CreatedBy).IsModified)
//{
// throw new DbEntityValidationException(string.Format(“Attempt to change created audit trails on a modified {0}”, auditableEntity.Entity.GetType().FullName));
//}
break;
}
}
}
return base.SaveChangesAsync(cancellationToken);
}
public override int SaveChanges()
{
var currentDateTime = DateTime.Now;
var claimsidentity =(ClaimsIdentity)HttpContext.Current.User.Identity;
var tenantclaim = claimsidentity?.FindFirst(“schemas.microsoft.com/identity/claims/tenantid”);
var tenantid = Convert.ToInt32(tenantclaim?.Value);
foreach (var auditableEntity in this.ChangeTracker.Entries<Entity>())
{
if (auditableEntity.State == EntityState.Added || auditableEntity.State == EntityState.Modified)
{
auditableEntity.Entity.LastModifiedDate = currentDateTime;
switch (auditableEntity.State)
{
case EntityState.Added:
auditableEntity.Property(“LastModifiedDate”).IsModified = false;
auditableEntity.Property(“LastModifiedBy”).IsModified = false;
auditableEntity.Entity.CreatedDate = currentDateTime;
auditableEntity.Entity.CreatedBy = claimsidentity.Name;
auditableEntity.Entity.TenantId = tenantid;
break;
case EntityState.Modified:
auditableEntity.Property(“CreatedDate”).IsModified = false;
auditableEntity.Property(“CreatedBy”).IsModified = false;
auditableEntity.Entity.LastModifiedDate = currentDateTime;
auditableEntity.Entity.LastModifiedBy = claimsidentity.Name;
auditableEntity.Entity.TenantId = tenantid;
break;
}
}
}
return base.SaveChanges();
}
DbContext.cs
经过以上3步就实现一个简单的多租户查询数据的功能。
总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对华域联盟的支持。
您可能感兴趣的文章:一个简单MVC5 + EF6示例分享
ef6
多租户
应用
相关文章
ASP.NET与MySQL数据库简明图示入门教程ASP.NET与MySQL数据库简明图示入门教程… 2006-09-09
C#中的委托和事件学习(续)如果你看过了 C#中的委托和事件 一文，我想你对委托和事件已经有了一个基本的认识。但那些远不是委托和事件的全部内容，还有很多的地方没有涉及。 2008-09-09
asp.net实现根据城市获取天气预报的方法这篇文章主要介绍了asp.net实现根据城市获取天气预报的方法,涉及asp.net调用新浪接口获取天气预报信息的实现技巧,非常简单实用,需要的朋友可以参考下 2015-12-12
ASP.NET JSON字符串与实体类的互转换示例代码本篇文章主要是对ASP.NET JSON字符串与实体类的互转换的示例代码进行了介绍，需要的朋友可以过来参考下，希望对大家有所帮助 2014-01-01
ASP.NET Eval进行数据绑定的方法ASP.NET Eval在数据绑定方面的应用是众所周知的,不过技术在发展,当ASP.NET Eval 1.1变成ASP.NET Eval 2.0的时候,在操作的时候会有什么变化呢? 2013-04-04
ASP.NET MVC中使用JavaScriptResult的用法示例这篇文章主要介绍了ASP.NET MVC中使用JavaScriptResult的用法,结合实例形式分析了采用javascript动态设置标签样式以及使用MVC中的JavaScriptResult来实现同样效果的相关技巧,需要的朋友可以参考下 2016-08-08
asp.net(c#)文件下载实现代码本文通过一个实例向大家介绍用C#进行Internet通讯编程的一些基本知识。我们知道.Net类包含了请求/响应层、应用协议层、传输层等层次。 2009-11-11
webapi中如何使用依赖注入本篇将要和大家分享的是webapi中如何使用依赖注入，依赖注入这个东西在接口中常用，实际工作中也用的比较频繁，因此这里分享两种在api中依赖注入的方式Ninject和Unity。下面跟着小编一起来看下吧
2017-02-02
ASP.NET防范SQL注入式攻击的方法所谓SQL注入式攻击，就是攻击者把SQL命令插入到Web表单的输入域或页面请求的查询字符串，欺骗服务器执行恶意的SQL命令，那么在ASP.NET中如何防范SQL注入式攻击，下文为大家揭晓 2016-05-05
解决 The Controls collection cannot be modified because the 在.aspx或.ascx的如果包括%，并在.aspx, .ascs中使用了AjaxToolkit中的控件，那么很可能会引发这个问题，下面给出具体的解决方法。 2010-10-10
最新评论
评论(0)