具有DbContext和TenantId的MultiTenancy – 拦截器，filter，EF代码优先

我的组织需要一个共享数据库，共享模式多租户数据库。 我们将根据TenantId进行查询。 我们将只有极少数租户（少于10个），并且所有租户都将共享相同的数据库架构，不支持特定于租户的更改或function。 租户元数据将存储在内存中，而不是存储在DB（静态成员）中。

这意味着所有实体现在都需要一个TenantId， DbContext需要知道默认情况下对此进行过滤。

TenantId可能会被标头值或原始域标识，除非有更明智的方法。

我已经看到各种样本利用拦截器，但没有看到TenantId实现的明确示例。

我们需要解决的问题：

1. 我们如何修改当前架构来支持这个（简单的我想，只需添加TenantId）
2. 我们如何检测租户（简单 – 基于原始请求的域或标头值 – 从BaseController拉出）
3. 我们如何将它传播到服务方法（有点棘手…我们使用DI通过构造函数进行水合…希望避免使用tenantId对所有方法签名进行tenantId ）
4. 一旦我们有了它，我们如何修改DbContext来过滤这个tenantId（不知道）
5. 我们如何优化性能。 我们需要什么索引，我们如何确保查询缓存没有做任何与tenantId隔离等相关的时髦（不知道）
6. 身份validation – 使用SimpleMembership，我们如何隔离User ，以某种方式将他们与租户联系起来。

我认为最大的问题是4 – 修改DbContext。

我喜欢本文如何利用RLS，但我不知道如何以代码优先，dbContext方式处理它：

https://azure.microsoft.com/en-us/documentation/articles/web-sites-dotnet-entity-framework-row-level-security/

我想说的是我想要的是一种方法 – 考虑到性能 – 使用DbContext有选择地查询tenantId隔离的资源，而不用我的调用"AND TenantId = 1"等。

更新 – 我找到了一些选项，但我不确定每个选项的优缺点是什么，或者是否有一些“更好”的方法。 我对选项的评估归结为：

方法A.

这似乎“昂贵”，因为每次我们新建dbContext时，我们都必须重新初始化filter：

Row level security in EntityFramework 6 (EF6)

首先，我设置了我的租户和界面：

 public static class Tenant { public static int TenantA { get { return 1; } } public static int TenantB { get { return 2; } } } public interface ITenantEntity { int TenantId { get; set; } } 

我在任何实体上实现该接口：

  public class Photo : ITenantEntity { public Photo() { DateProcessed = (DateTime) SqlDateTime.MinValue; } [Key] public int PhotoId { get; set; } [Required] public int TenantId { get; set; } } 

然后我更新我的DbContext实现：

  public AppContext(): base("name=ProductionConnection") { Init(); } protected internal virtual void Init() { this.InitializeDynamicFilters(); } int? _currentTenantId = null; public void SetTenantId(int? tenantId) { _currentTenantId = tenantId; this.SetFilterScopedParameterValue("TenantEntity", "tenantId", _currentTenantId); this.SetFilterGlobalParameterValue("TenantEntity", "tenantId", _currentTenantId); var test = this.GetFilterParameterValue("TenantEntity", "tenantId"); } public override int SaveChanges() { var createdEntries = GetCreatedEntries().ToList(); if (createdEntries.Any()) { foreach (var createdEntry in createdEntries) { var isTenantEntity = createdEntry.Entity as ITenantEntity; if (isTenantEntity != null && _currentTenantId != null) { isTenantEntity.TenantId = _currentTenantId.Value; } else { throw new InvalidOperationException("Tenant Id Not Specified"); } } } } private IEnumerable GetCreatedEntries() { var createdEntries = ChangeTracker.Entries().Where(V => EntityState.Added.HasFlag(V.State)); return createdEntries; } protected override void OnModelCreating(DbModelBuilder modelBuilder) { modelBuilder.Filter("TenantEntity", (ITenantEntity tenantEntity, int? tenantId) => tenantEntity.TenantId == tenantId.Value, () => null); base.OnModelCreating(modelBuilder); } 

最后，在我对DbContext的调用中，我使用了这个：

  using (var db = new AppContext()) { db.SetTenantId(someValueDeterminedElsewhere); } 

我有一个问题，因为我在大约一百万个地方新建了我的AppContext（一些服务方法需要它，有些不需要） – 所以这会使我的代码膨胀一点。 还有关于租户确定的问题 – 我是否传入HttpContext，是否强制我的控制器将TenantId传递给所有服务方法调用，如何处理我没有原始域（webjob调用等）的情况。

方法B.

在这里找到： http ： //howtoprogram.eu/question/na,28158

看似相似，但很简单：

  public interface IMultiTenantEntity { int TenantID { get; set; } } public partial class YourEntity : IMultiTenantEntity {} public partial class YourContext : DbContext { private int _tenantId; public override int SaveChanges() { var addedEntities = this.ChangeTracker.Entries().Where(c => c.State == EntityState.Added) .Select(c => c.Entity).OfType(); foreach (var entity in addedEntities) { entity.TenantID = _tenantId; } return base.SaveChanges(); } public IQueryable TenantCodes => this.Codes.Where(c => c.TenantID == _tenantId); } public IQueryable TenantYourEntities => this.YourEntities.Where(c => c.TenantID == _tenantId); 

 using System; using System.Data.Entity; using System.Linq; namespace SqlServerDatabaseBackup { public class Table { public int TenantId { get; set; } public int TableId { get; set; } } public interface ITentantIdProvider { int TenantId(); } public class TenantRepository : ITenantRepositoty { private int tenantId; private ITentantIdProvider _tentantIdProvider; private TenantContext context = new TenantContext(); //You can abstract this if you want private DbSet filteredTables; public IQueryable Tables { get { return filteredTables.Where(t => t.TenantId == tenantId); } } public TenantRepository(ITentantIdProvider tentantIdProvider) { _tentantIdProvider = tentantIdProvider; tenantId = _tentantIdProvider.TenantId(); filteredTables = context.Tables; } public Table Find(int id) { return filteredTables.Find(id); } } public interface ITenantRepositoty { IQueryable Tables { get; } Table Find(int id); } public class TenantContext : DbContext { public DbSet Tables { get; set; } } public interface IService { void DoWork(); } public class Service : IService { private ITenantRepositoty _tenantRepositoty; public Service(ITenantRepositoty tenantRepositoty) { _tenantRepositoty = tenantRepositoty; } public void DoWork() { _tenantRepositoty.Tables.ToList();//These are filtered records } } }