AspNetCore Identity FreeSql的实现

IGeekFan.AspNetCore.Identity.FreeSql

是asp.net core 6 的identity的freesql存储的实现

• 支持.NET 6.0
• 安装包

dotnet add package IGeekFan.AspNetCore.Identity.FreeSql

• 新增 FreeSql的Provider 相关包

dotnet add package FreeSql.Provider.MySqlConnector

扩展用户、角色

public class AppUser : IdentityUser<Guid>
{
    public string FirstName { get; set; }
    public string LastName { get; set; }
}
public class AppRole : IdentityRole<Guid>
{

}
public class AppIdentityDbContext : IdentityDbContext<AppUser, AppRole, Guid>
{
    public AppIdentityDbContext(IOptions<IdentityOptions> identityOptions, IFreeSql fsql, DbContextOptions options)
    : base(identityOptions.Value, fsql, options)
    {
    }

    protected override void OnConfiguring(DbContextOptionsBuilder builder)
    {
        //这里直接指定一个静态的 IFreeSql 对象即可，切勿重新 Build()
    }

    protected override void OnModelCreating(ICodeFirst codefirst)
    {
        base.OnModelCreating(codefirst);
        //批量
        //codefirst.ApplyConfigurationsFromAssembly(typeof(AppUserConfiguration).Assembly);
        codefirst.ApplyConfiguration(new AppUserConfiguration());
        codefirst.ApplyConfiguration(new AppRoleConfiguration());
    }
}

配置用户、角色的FulentAPI

public class AppUserConfiguration : IEntityTypeConfiguration<AppUser>
{
    public void Configure(EfCoreTableFluent<AppUser> builder)
    {
        builder.Property(x => x.FirstName).HasMaxLength(50);
        builder.Property(x => x.LastName).HasMaxLength(50);
    }
}
public class AppRoleConfiguration : IEntityTypeConfiguration<AppRole>
{
    public void Configure(EfCoreTableFluent<AppRole> builder)
    {
    }
}

• appsettings.json 该配置通过方法UseConnectionString读取如下配置

"ConnectionStrings": {
    "MySql": "Data Source=localhost;Port=3306;User ID=root;Password=root;Initial Catalog=aspnetcoreidentity;Charset=utf8mb4;SslMode=none;Max pool size=1;Connection LifeTime=20"
}

配置 Identity+FreeSql

• 新增一个扩展方法，引用 aspnetcore identity 相关服务

public static IServiceCollection AddFreeSqlIdentity(this IServiceCollection services, IConfiguration configuration)
{
    Func<IServiceProvider, IFreeSql> fsql = r =>
    {
        IFreeSql fsql = new FreeSqlBuilder()
                .UseConnectionString(DataType.MySql, configuration["ConnectionStrings:MySql"])
               //.UseNameConvert(NameConvertType.PascalCaseToUnderscoreWithLower)
                .UseAutoSyncStructure(true) //自动同步实体结构到数据库，FreeSql不会扫描程序集，只有CRUD时才会生成表。
                .UseMappingPriority(MappingPriorityType.FluentApi, MappingPriorityType.Attribute, MappingPriorityType.Aop)
                .UseMonitorCommand(cmd =>
                {
                    Trace.WriteLine(cmd.CommandText + ";");
                })
                .Build();
        //软删除
        fsql.GlobalFilter.Apply<ISoftDelete>("IsDeleted", a => a.IsDeleted == false);      
        return fsql;
    };

    services.AddSingleton<IFreeSql>(fsql);
    services.AddFreeRepository();
    services.AddScoped<UnitOfWorkManager>();

    using (var scope = services.BuildServiceProvider().CreateScope())
    {
        var orm = scope.ServiceProvider.GetRequiredService<IFreeSql>();

        //只有实例化了AppIdentityDbContext，才能正常调用OnModelCreating，不然直接使用仓储，无法调用DbContext中的OnModelCreating方法，配置的TodoConfiguration 就会没有生效
        services.AddFreeDbContext<AppIdentityDbContext>(options => options
                    .UseFreeSql(orm)
                    .UseOptions(new DbContextOptions()
                    {
                        EnableCascadeSave = true
                    }));
    }

    services.AddIdentityCore<AppUser>(o =>
            {
                o.SignIn.RequireConfirmedEmail = false;
                o.Stores.MaxLengthForKeys = 128;
            })
            .AddRoles<AppRole>()
            .AddSignInManager()
            .AddFreeSqlStores<AppIdentityDbContext>()
            .AddDefaultTokenProviders();;

    // 如果是MVC 另外安装包 <PackageReference Include="Microsoft.AspNetCore.Identity.UI" Version="6.0.7" /> 使用AddDefaultIdentity方法
    // services.AddDefaultIdentity<AppUser>(options => options.SignIn.RequireConfirmedAccount = true).AddRoles<AppRole>()
    //        .AddFreeSqlStores<AppIdentityDbContext>().AddDefaultTokenProviders();

    return services;
}

软删除

public interface ISoftDelete
{
    bool IsDeleted { get; set; }
}

因为FreeSql只有运行时才会生成表,我们增加定义一个扩展方法

/// <summary>
/// 自定义Scope 的Serivce 执行 DbContext中的OnModelCreating
/// </summary>
/// <param name="serviceProvider"></param>
/// <returns></returns>

public static IServiceProvider RunScopeService(this IServiceProvider serviceProvider)
{
    //在项目启动时，从容器中获取IFreeSql实例，并执行一些操作：同步表，种子数据,FluentAPI等
    using (IServiceScope serviceScope = serviceProvider.CreateScope())
    {
        var freeSql = serviceScope.ServiceProvider.GetRequiredService<IFreeSql>();
        using var dbContext = serviceScope.ServiceProvider.GetRequiredService<AppIdentityDbContext>();

        freeSql.CodeFirst.SyncStructure(
            typeof(AppUser),
            typeof(AppRole),
            typeof(IdentityUserLogin<Guid>),
            typeof(IdentityUserRole<Guid>),
            typeof(IdentityUserClaim<Guid>),
            typeof(IdentityRoleClaim<Guid>),
            typeof(IdentityUserToken<Guid>)
            );
    }
    return serviceProvider;
}

在Program中Build后，我们执行此方法，以保证DbContext中的OnModelCreating生效

WebApplicationBuilder builder = WebApplication.CreateBuilder(args);
builder.Services.AddFreeSqlIdentity(builder.Configuration);

WebApplication app = builder.Build();
//自定义Scope 的Serivce 执行 DbContext中的OnModelCreating
app.Services.RunScopeService();