2022-05-29发表2023-05-26更新.NET / MASA Framework13 分钟读完 (大约1967个字)

5. 数据访问 - EntityFramework集成

前言

Masa提供了基于EntityFramework的数据集成，并提供了数据过滤与软删除的功能，下面我们将介绍如何使用它？

MasaDbContext入门

安装.Net 6.0

新建ASP.NET Core 空项目Assignment.MasaEntityFramework，并安装Masa.Contrib.Data.EntityFrameworkCore、Swashbuckle.AspNetCore、Microsoft.EntityFrameworkCore.InMemory、Microsoft.EntityFrameworkCore.Tools

dotnet add package Masa.Contrib.Data.EntityFrameworkCore --version 0.4.0-rc.4
dotnet add package Swashbuckle.AspNetCore --version 6.2.3
dotnet add package Microsoft.EntityFrameworkCore.InMemory --version 6.0.5
dotnet add package Microsoft.EntityFrameworkCore.Tools --version 6.0.5

安装Swashbuckle.AspNetCore是为了方便通过Swagger来操作服务
安装Microsoft.EntityFrameworkCore.InMemory是为了方便，因此使用内存数据库，如果需要使用其他数据库，请自行安装对应的包
安装Microsoft.EntityFrameworkCore.Tools是为了使用CodeFirst创建数据库

新建类User

public class User
{
    public int Id { get; set; }

    public string Name { get; set; }

    public uint Gender { get; set; }

    public DateTime BirthDay { get; set; }

    public DateTime CreationTime { get; set; }

    public User()
    {
        this.CreationTime = DateTime.Now;
    }
}

新建用户上下文UserDbContext.cs
1
2
3
4
5
6
7
8
public class UserDbContext : MasaDbContext
{
public DbSet<User> User { get; set; }

public UserDbContext(MasaDbContextOptions options) : base(options)
{
}
}
UserDbContext改为继承MasaDbContext, 并新增一个参数的构造函数，参数类型为MasaDbContextOptions
当项目中存在多个DbContext时，需要改为继承MasaDbContext<TDbContext>，构造函数参数类型改为MasaDbContext<TDbContext>

新建类AddUserRequest作为添加用户的参数

public class AddUserRequest
{
    public string Name { get; set; }

    public uint Gender { get; set; }

    public DateTime BirthDay { get; set; }
}

新建类HostExtensions用于迁移数据库（使用CodeFirst）

public static class HostExtensions
{
    public static void MigrateDbContext<TContext>(
        this IHost host, Action<TContext, IServiceProvider> seeder) where TContext : DbContext
    {
        using (var scope = host.Services.CreateScope())
        {
            var services = scope.ServiceProvider;
            var context = services.GetRequiredService<TContext>();
            context.Database.EnsureCreated();
            seeder(context, services);
        }
    }
}

修改Program.cs，新增Swagger支持

builder.Services.AddEndpointsApiExplorer();
builder.Services.AddSwaggerGen();

var app = builder.Build();

app.UseSwagger();
app.UseSwaggerUI();

不需要Swagger可不添加，使用Swagger仅仅是为了测试调用服务，使用Postman或其他的Http工具也可以

修改Program.cs，添加用户上下文（重点）

builder.Services.AddMasaDbContext<UserDbContext>(options => 
{
  options.Builder = (_, dbContextOptionsBuilder) => dbContextOptionsBuilder.UseInMemoryDatabase("test")
});

修改Program.cs，使项目支持CodeFirst
1
2
3
app.MigrateDbContext<UserDbContext>((context, services) =>
{
});
不需要CodeFirst，不支持代码生成数据库可不添加

测试MasaDbContext，修改Program.cs

app.MapPost("/add", (UserDbContext dbContext, [FromBody] AddUserRequest request) =>
{
    dbContext.Set<User>().Add(new User()
    {
        Name = request.Name,
        Gender = request.Gender,
        BirthDay = request.BirthDay
    });
    dbContext.SaveChanges();
});

app.MapGet("/list", (UserDbContext dbContext) =>
{
    return dbContext.Set<User>().ToList();
});

自行运行项目，执行add后创建一个新的用户，之后执行list得到一个以上的用户数据，则证明MasaDbContext使用无误

如何使用软删除

选中Assignment.MasaEntityFramework并安装Masa.Contrib.Data.Contracts.EF
1
dotnet add package Masa.Contrib.Data.Contracts.EF --version 0.4.0-rc.4

修改类User，并实现ISoftDelete，代码改为：

public class User : ISoftDelete//重点：改为实现ISoftDelete
{
    public int Id { get; set; }

    public string Name { get; set; }

    public uint Gender { get; set; }

    public DateTime BirthDay { get; set; }

    public DateTime CreationTime { get; set; }

    public bool IsDeleted { get; private set; }

    public User()
    {
        this.CreationTime = DateTime.Now;
    }
}

增加实现ISoftDelete，并为IsDeleted属性添加set支持（可以是private set;）

修改Program.cs，并启用数据过滤

builder.Services.AddMasaDbContext<UserDbContext>(options =>
{
    options.Builder = (_, dbContextOptionsBuilder) => dbContextOptionsBuilder.UseInMemoryDatabase("test");
    options.UseFilter();//启用数据过滤，完整写法：options.UseFilter(filterOptions => filterOptions.EnableSoftDelete = true);
});

测试软删除是否成功

修改Program.cs，新增删除方法

app.MapDelete("/delete", (UserDbContext dbContext, int id) =>
{
    var user = dbContext.Set<User>().First(u => u.Id == id);
    dbContext.Set<User>().Remove(user);
    dbContext.SaveChanges();
});

最后，先调用add方法创建用户后，之后再调用list方法获取所有的用户列表，并取出任意一条id信息，然后再调用delete方法删除用户，最后再调用list方法，查看取出的id是否存在，以此来验证软删除是否有效。

如何临时禁用软删除过滤

默认查询中会将标记已经被删除的数据过滤不再进行查询，但也有一些场景需要查询所有的数据，此时就需要用到数据过滤IDataFilter

新增All方法用于查询所有的数据（包含标记已经删除的数据）

app.MapGet("/all", (UserDbContext dbContext, [FromServices] IDataFilter dataFilter) =>
{
    //通过DI获取到IDataFilter，并调用其Disable方法可临时禁用ISoftDelete条件过滤
    using (dataFilter.Disable<ISoftDelete>())
    {
        return dbContext.Set<User>().ToList();
    }
});

重新运行项目，重复执行验证软删除步骤，确保通过list方法访问不到数据

重复运行验证软删除步骤的原因在于本示例使用的是内存数据库，项目停止后，所有数据都会被清空，重新执行是为了确保数据存在，仅被标记为删除
执行all方法，获取所有的数据，查看id所对应的用户数据是否存在

从配置文件中获取数据库连接字符串

选中项目Assignment.MasaEntityFramework，并安装Masa.Contrib.Data.EntityFrameworkCore.InMemory
1
dotnet add package Masa.Contrib.Data.EntityFrameworkCore.InMemory --version 0.4.0-rc.4
根据需要安装对应数据库包即可，如：Masa.Contrib.Data.EntityFrameworkCore.SqlServer (SqlServer)、Masa.Contrib.Data.EntityFrameworkCore.Pomelo.MySql (Pomelo提供的MySql)、Masa.Contrib.Data.EntityFrameworkCore.Oracle (Oracle)等

修改Program.cs，调整添加用户上下文配置为:

1	builder.Services.AddMasaDbContext<UserDbContext>(options => options.UseInMemoryDatabase().UseFilter());

修改appsettings.json，增加用户数据库连接字符串:

{
  "ConnectionStrings": {
    "DefaultConnection": "test"//更换为指定的数据库连接字符串
  }
}

修改Program.cs，新增database方法，验证当前数据库是test

app.MapGet("/database", (UserDbContext dbContext) =>
{
    var field = typeof(MasaDbContext).GetField("Options", BindingFlags.Public | BindingFlags.Instance | BindingFlags.NonPublic)!;
    var masaDbContextOptions = field.GetValue(dbContext) as MasaDbContextOptions;
    foreach (var dbContextOptionsExtension in masaDbContextOptions!.Extensions)
    {
        if (dbContextOptionsExtension is InMemoryOptionsExtension memoryOptionsExtension)
        {
            return memoryOptionsExtension.StoreName;
        }
    }

    return "";
});

最后访问http://localhost:5002/database，验证当前的数据库名称与修改后的数据库名称是否一致
验证数据库为test

常见问题

如何更改默认读取的配置节点?

修改用户上下文UserDbContext并增加ConnectionStringName特性:

[ConnectionStringName("User")]//自定义节点名
public class UserDbContext : MasaDbContext
{
    public DbSet<User> User { get; set; }

    public UserDbContext(MasaDbContextOptions options) : base(options)
    {
    }
}

修改配置appsettings.json

{
  "ConnectionStrings": {
    "User": "test"//改为从User节点读取数据库连接字符串
  }
}

除了从配置文件中获取，还支持从其他地方获取数据库连接字符串吗？

目前有两种办法可以更改数据库连接字符串。

方法1: 修改Program.cs，并删除appsettings.json数据库连接字符串的配置

修改Program.cs

builder.Services.Configure<MasaDbConnectionOptions>(option =>
{
    option.ConnectionStrings = new ConnectionStrings(new List<KeyValuePair<string, string>>()
    {
        new("User", "test2")//其中键为节点名，与ConnectionStringName特性的Name值保持一致即可，如果未指定ConnectionStringName，则应该为DefaultConnection，值为数据库连接字符串
    });
});

修改appsettings.json配置

1
2
3

//  "ConnectionStrings": {
//    "User": "test"
//  },

调用database方法，验证当前数据库是否为test2

验证数据库为test2

方法2: 重写IConnectionStringProvider和IDbConnectionStringProvider的实现并添加到DI中

新建类CustomizeConnectionStringProvider

public class CustomizeConnectionStringProvider : IConnectionStringProvider
{
    public Task<string> GetConnectionStringAsync(string name = "DefaultConnection") => Task.FromResult    (GetConnectionString(name));

    public string GetConnectionString(string name = "DefaultConnection") => "test3";
}

新建类CustomizeDbConnectionStringProvider

public class CustomizeDbConnectionStringProvider : IDbConnectionStringProvider
{
    public List<MasaDbContextConfigurationOptions> DbContextOptionsList { get; } = new()
    {
        new MasaDbContextConfigurationOptions("test3")
    };
}

修改Program.cs

1 2	builder.Services.AddSingleton<IConnectionStringProvider,CustomizeConnectionStringProvider>(); builder.Services.AddSingleton<IDbConnectionStringProvider,CustomizeDbConnectionStringProvider>();