在运行时更改表名

Question

让我们假设我有一个名为的员工和相应的EF 6.0 db-first模型的db表。

获取表的所有行员工通过查询完成：context.Employees.ToList()

是否有可能在运行时和需求，而使用相同的对象名称和查询到数据库表名重定向到的Test1 ？

EF 6.0 Interceptor的使用情况可能是这样吗？

Answer 1

为什么不使用一些很好的老式多态？

partial class Employee : IEmployee { } 
partial class HistoricalEmployee : IEmployee { } 

interface IEmployee { 
    public string Name { get; set; } 
} 

void PrintEmployeeName(IEmployee employee) 
{ 
    Debug.WriteLine(employee.Name); 
} 

PrintEmployeeName(context.Employees.First()); 
PrintEmployeeName(context.HistoricalEmployees.First()); 

Answer 2

我不知道你是否应该做到这一点，但我认为你可以。您将不得不深入实体框架元数据结构，例如MetadataWorkspace，您可以从底层ObjectContext获取该结构。在这里看到一个例子：http://weblogs.asp.net/ricardoperes/entity-framework-metadata。

Answer 3

感谢您的答案。

我认为我的情况是一个真实世界的情景，在EF教程和示例的所有“入门”典型场景中通常都会被忽略。

基于我使用db-first方法并且应该在应用程序级别的事实，我认为我将创建一个Context实例，它基于不同的SSDL以及用户将使用的新表名要求

Answer 4

我会做这样的事情：

public partial class MyContext : DbContext 
{ 
    private readonly ITableNameProvider _tableNameProvider; 

    public MyContext(ITableNameProvider tableNameProvider) 
     : base("name=ConnectionStringName") 
    { 
     _tableNameProvider = tableNameProvider; 
    } 

    public virtual DbSet<MyGenericEntity> Templates { get; set; } 

    protected override void OnModelCreating(DbModelBuilder modelBuilder) 
    { 
     modelBuilder.Entity<MyGenericEntity>() 
      .ToTable(_tableNameProvider.GetTableName(), _tableNameProvider.GetSchemaName()); 
    } 

} 

，我认为它在您的方案。唯一的问题是OnModelCreating（）只运行一次。因此，如果您在同一个应用程序中使用它，它将缓存结果后将第一个表名称。

Answer 5

我知道这已经有一段时间以来，原来的帖子，但我会加我的答案来帮助别人。我有具有不同表名的通用SQL队列表。即这两个表的模式完全相同。我创建了一个框架，以便您可以通过提供名称动态轮询您选择的表，这就是为什么我需要在运行时更新表名。基本上，你可以创建一个拦截器来拦截来自实体框架的原始SQL查询并从那里更新表名。

public class MyInterceptor : IDbCommandInterceptor 
{ 
    private const string TableReplaceString = "[TheTableNameToReplace]"; 

    private void ReplaceTableName(DbCommand command, IEnumerable<DbContext> contexts) 
    { 
     var myContext = contexts?.FirstOrDefault(x => x is MyContext) as MyContext; 
     if (myContext != null && command != null && command.CommandText.Contains(TableReplaceString)) 
     { 
      command.CommandText = command.CommandText.Replace(TableReplaceString, $"[{myContext.NewTableName}]"); 
     } 
    } 

    public void NonQueryExecuting(DbCommand command, DbCommandInterceptionContext<int> interceptionContext) 
    { 
     ReplaceTableName(command, interceptionContext.DbContexts); 
    } 

    public void NonQueryExecuted(DbCommand command, DbCommandInterceptionContext<int> interceptionContext) 
    { 
     ReplaceTableName(command, interceptionContext.DbContexts); 
    } 

    public void ReaderExecuting(DbCommand command, DbCommandInterceptionContext<DbDataReader> interceptionContext) 
    { 
     ReplaceTableName(command, interceptionContext.DbContexts); 
    } 

    public void ReaderExecuted(DbCommand command, DbCommandInterceptionContext<DbDataReader> interceptionContext) 
    { 
     ReplaceTableName(command, interceptionContext.DbContexts); 
    } 

    public void ScalarExecuting(DbCommand command, DbCommandInterceptionContext<object> interceptionContext) 
    { 
     ReplaceTableName(command, interceptionContext.DbContexts); 
    } 

    public void ScalarExecuted(DbCommand command, DbCommandInterceptionContext<object> interceptionContext) 
    { 
     ReplaceTableName(command, interceptionContext.DbContexts); 
    } 
} 

当然，你必须从某个地方得到新的表名。无论是从构造函数还是从您可以从interceptionContext.DbContexts中获取的自定义DBContext中的存储字段。

然后你只需要为你的上下文注册拦截器。

public class MyContext : DBContext 
{ 
    public readonly string NewTableName; 

    public MyContext(string connectionString, string newTableName) 
     : base(connectionString) 
    { 
     NewTableName = newTableName; 
     // Set interceptor 
     DbInterception.Add(new QueueMessageInterceptor()); 
    } 
} 

更新： 我发现，如果你在构造函数中添加拦截器上面会导致内存泄漏。 DotMemory不会告诉你这个问题。确保在静态构造函数中添加拦截器。

public class MyContext : DBContext 
{ 
    public readonly string NewTableName; 

    static MyContext() 
    { 
     // Set interceptor only in static constructor 
     DbInterception.Add(new QueueMessageInterceptor()); 
    } 

    public MyContext(string connectionString, string newTableName) 
     : base(connectionString) 
    { 
     NewTableName = newTableName; 
    } 
} 

Answer 6

老问题，但基于这个问题我建议你看一下基于“当前”位或时间字段partioning你的表。分区基于列值&由大多数现代DBMS支持。它会避免ORM级别的问题。