在 ASP.NET Core 添加配置片断:sql
{ "ConnectionStrings": { "BloggingDatabase": "Server=(localdb)\\mssqllocaldb;Database=EFGetStarted.ConsoleApp.NewDb;Trusted_Connection=True;" } }
而后,配置对应的DbContext:数据库
public void ConfigureServices(IServiceCollection services) { services.AddDbContext<BloggingContext>(options => options.UseSqlServer(Configuration.GetConnectionString("BloggingDatabase"))); }
EF Core 默认会与 ASP.NET Core的日志提供程序一块儿工做,只须要使用AddDbContext
或AddDbContextPool
添加服务便可。多线程
除此以外,还能够手工添加日志记录。async
首先,建立LoggerFactory的单例:ide
public static readonly LoggerFactory MyLoggerFactory = new LoggerFactory(new[] {new ConsoleLoggerProvider((_, __) => true, true)});
而后,经过DbContextOptionsBuilder
注册此单例:函数
protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder) => optionsBuilder .UseLoggerFactory(MyLoggerFactory) // Warning: Do not create a new ILoggerFactory instance each time .UseSqlServer( @"Server=(localdb)\mssqllocaldb;Database=EFLogging;Trusted_Connection=True;ConnectRetryCount=0");
若是你只想记录想要的日志,例如数据操做语句,能够在ILoggerProvider中进行配置:ui
public static readonly LoggerFactory MyLoggerFactory = new LoggerFactory(new[] { new ConsoleLoggerProvider((category, level) => category == DbLoggerCategory.Database.Command.Name && level == LogLevel.Information, true) });
EF Core 能够根据不一样的数据库失败,制定不一样的执行策略,例如故障自动重试等。线程
针对SQL Server,它知道能够重试的异常类型,而且具备合理的默认值的最大重试,重试次数等之间的延迟。日志
配置以下:code
protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder) { optionsBuilder .UseSqlServer( @"Server=(localdb)\mssqllocaldb;Database=EFMiscellanous.ConnectionResiliency;Trusted_Connection=True;ConnectRetryCount=0", options => options.EnableRetryOnFailure()); }
也可在Startup中配置:
public void ConfigureServices(IServiceCollection services) { services.AddDbContext<PicnicContext>( options => options.UseSqlServer( "<connection string>", providerOptions => providerOptions.EnableRetryOnFailure())); }
你也能够自定义执行策略:
protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder) { optionsBuilder .UseMyProvider( "<connection string>", options => options.ExecutionStrategy(...)); }
对于执行自动重试策略来讲,每一次调用context.SaveChanges()
方法将会当作一个重试单元。若是你的事物中有多个SaveChanges操做,配置的自动重试策略将会抛出异常,解决方法是使用委托来手动调用执行策略。代码以下:
using (var db = new BloggingContext()) { var strategy = db.Database.CreateExecutionStrategy(); strategy.Execute(() => { using (var context = new BloggingContext()) { using (var transaction = context.Database.BeginTransaction()) { context.Blogs.Add(new Blog {Url = "http://blogs.msdn.com/dotnet"}); context.SaveChanges(); context.Blogs.Add(new Blog {Url = "http://blogs.msdn.com/visualstudio"}); context.SaveChanges(); transaction.Commit(); } } }); }
此方法一样适用于环境事物:
using (var context1 = new BloggingContext()) { context1.Blogs.Add(new Blog { Url = "http://blogs.msdn.com/visualstudio" }); var strategy = context1.Database.CreateExecutionStrategy(); strategy.Execute(() => { using (var context2 = new BloggingContext()) { using (var transaction = new TransactionScope()) { context2.Blogs.Add(new Blog { Url = "http://blogs.msdn.com/dotnet" }); context2.SaveChanges(); context1.SaveChanges(); transaction.Complete(); } } }); }
自动重试策略须要考虑幂等性问题,防止数据添加剧复等误操做。EF Core 引入了一种状态检查机制,能够帮助咱们实现是否执行成功的检测:
using (var db = new BloggingContext()) { var strategy = db.Database.CreateExecutionStrategy(); var blogToAdd = new Blog {Url = "http://blogs.msdn.com/dotnet"}; db.Blogs.Add(blogToAdd); strategy.ExecuteInTransaction(db, operation: context => { context.SaveChanges(acceptAllChangesOnSuccess: false); }, verifySucceeded: context => context.Blogs.AsNoTracking().Any(b => b.BlogId == blogToAdd.BlogId)); db.ChangeTracker.AcceptAllChanges(); }
DbContext必须有DbContextOptions实例能,Options的做用以下:
能够经过构造函数添加Options:
public class BloggingContext : DbContext { public BloggingContext(DbContextOptions<BloggingContext> options) : base(options) { } public DbSet<Blog> Blogs { get; set; } }
也能够经过OnConfiguring方法进行配置:
public class BloggingContext : DbContext { public DbSet<Blog> Blogs { get; set; } protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder) { optionsBuilder.UseSqlite("Data Source=blog.db"); } }
使用依赖注入DbContext时,须要构造函数的方式进行配置,并在Startup中配置DbContext:
public void ConfigureServices(IServiceCollection services) { services.AddDbContext<BloggingContext>(options => options.UseSqlite("Data Source=blog.db")); }
EF Core 提供了async/await操做,可是这是一个语法糖,它并不支持并行操做,这是因为数据库链接的特性限制的,所以咱们应避免针对同一个Context执行任何并行操做。
参考微软 EF Core 使用文档,详情: