我重写DbContext.SaveChanges()以便在我的应用程序中实现数据库审核。
我的DbContext类如下所示:
public override int SaveChanges()
{
throw new InvalidOperationException("User Id must be provided for auditing purposes.");
}
public int SaveChanges(bool suppressAudit)
{
if (suppressAudit)
return base.SaveChanges();
else
throw new InvalidOperationException("User Id must be provided for auditing purposes.");
}
public int SaveChanges(int userId)
{
foreach(var entity in ChangeTracker.Entries().Where(p=>p.State == EntityState.Added || p.State == EntityState.Deleted || p.State == EntityState.Modified))
{
foreach(var auditEntry in GetAuditRecordsForChange(entity,userId))
{
Audit.Add(auditEntry);
}
}
return base.SaveChanges();
}
在我的应用程序的“正常”运行期间,它似乎运行得很好(至少到目前为止)。
但是,当我想使用初始化程序来重新创建数据库时,就会出现问题:
public class ABS4Initializer : DropCreateDatabaseAlways<MyContext>
{
protected override void Seed(MyContext context)
{
var users = BuildUserData();
users.ForEach(u => context.Users.AddOrUpdate(u));
context.SaveChanges(true);
}
}
尽管我在种子中使用了
context.SaveChanges(true)
调用,但是某处某处正在调用context.SaveChanges()
(因此,引发了预期的异常)我怀疑它围绕数据库/表的创建,但是我找不到位置。
在
SaveChanges
上插入断点仅表明“外部代码”正在发出呼叫:我假设我错过了某些地方的替代,甚至更简单/更愚蠢的东西。
有什么线索吗?
(作为参考,我正在尝试实现与该问题最受好评的答案所示的类似的东西:how to create an audit trail with Entity framework 5 and MVC 4)
编辑
根据注释中的要求,这是一个产生相同结果的FULL dbContext类:
public class DemoContext : DbContext
{
public DemoContext() : base("DemoContext")
{
}
public DbSet<User> Users { get; set; }
public DbSet<AuditLog> Audit { get; set; }
public override int SaveChanges()
{
throw new InvalidOperationException("User Id must be provided for auditing purposes.");
}
public int SaveChanges(bool suppressAudit)
{
if (suppressAudit)
return base.SaveChanges();
else
throw new InvalidOperationException("User Id must be provided for auditing purposes.");
}
public int SaveChanges(int userId)
{
foreach (var entity in ChangeTracker.Entries().Where(p => p.State == EntityState.Added || p.State == EntityState.Deleted || p.State == EntityState.Modified))
{
foreach (var auditEntry in GetAuditRecordsForChange(entity, userId))
{
Audit.Add(auditEntry);
}
}
return base.SaveChanges();
}
private List<AuditLog> GetAuditRecordsForChange(DbEntityEntry dbEntity, int userId)
{
return new List<AuditLog>();
}
}
App.config
<entityFramework>
<contexts>
<context type="DAL.DAL.DemoContext, DAL">
<databaseInitializer type="DAL.DAL.ABS4Initializer, DAL"/>
</context>
</contexts>
<defaultConnectionFactory type="System.Data.Entity.Infrastructure.LocalDbConnectionFactory, EntityFramework">
<parameters>
<parameter value="mssqllocaldb" />
</parameters>
</defaultConnectionFactory>
<providers>
<provider invariantName="System.Data.SqlClient" type="System.Data.Entity.SqlServer.SqlProviderServices, EntityFramework.SqlServer" />
</providers>
</entityFramework>
最佳答案
Entity Framework中的DropCreateDatabaseAlways()类具有以下虚拟方法InitializeDatabase,如果下载EF源代码,则会发现实现类似于以下内容:
public virtual void InitializeDatabase(TContext context)
{
Check.NotNull(context, "context");
context.Database.Delete();
context.Database.Create(DatabaseExistenceState.DoesNotExist);
Seed(context);
context.SaveChanges();
}
您需要使用以下内容覆盖:
public override void InitializeDatabase(ABSContext context)
{
if (context != null)
{
if (context.Database.Exists())
{
context.Database.Delete();
}
context.Database.Create();
Seed(context);
context.SaveChanges(true);
}
else
throw new ArgumentNullException();
}
关于c# - DropCreateDatabaseAlways始终具有覆盖的context.SaveChanges(),我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/30728775/