EF Core 基础知识

数据库链接字符串

在 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的日志提供程序一块儿工做,只须要使用AddDbContextAddDbContextPool添加服务便可。多线程

除此以外,还能够手工添加日志记录。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配置项

DbContext必须有DbContextOptions实例能,Options的做用以下:

  • 配置数据库提供程序
  • 链接字符串
  • 数据库提供程序级别的可选项
  • EF Core级别的可选项

能够经过构造函数添加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 使用文档,详情:

相关文章
相关标签/搜索