当前位置 : 主页 > 网络编程 > ASP >

为ABP框架配置数据库

来源:互联网 收集:自由互联 发布时间:2023-01-17
目录 创建标准的 EFCore 数据库上下文 连接字符串 定义隔离的上下文 多数据库支持和配置 Freesql 配置服务 在 AbpBase.Database 中,通过 Nuget 添加以下几个库: 版本都是 1.9.0-preview0917,你可
目录
  • 创建标准的 EFCore 数据库上下文
    • 连接字符串
    • 定义隔离的上下文
    • 多数据库支持和配置
  • Freesql 配置服务

    在 AbpBase.Database 中,通过 Nuget 添加以下几个库:

    版本都是 1.9.0-preview0917,你可以使用最新版本的。

    Freesql									
    FreeSql.Provider.Sqlite
    FreeSql.Provider.SqlServer
    FreeSql.Provider.MySql

    创建标准的 EFCore 数据库上下文

    在 ABP 中,EFCore 上下文类需要继承 AbpDbContext<T>,整体编写方法跟继承 DbContext<T> 一致 ,接下来我们将一步步来讲解在 AbpBase 中如何添加 EFCore 功能。

    连接字符串

    ABP 中,可以在上下文类加上一个 ConnectionStringName 特性,然后在配置服务时,ABP 会自动为其配置连接字符串。

        [ConnectionStringName("Default")]
        public partial class DatabaseContext : AbpDbContext<DatabaseContext>

    Default 是一个标识,你也可以填写其他字符串标识。

    定义隔离的上下文

    首先,我们在 AbpBase.Database 模块中,创建两个文件夹:

    BaseData
    ExtensionData

    BaseData 目录用来存放基础表结构的上下文,ExtensionData 用来存放可能会拓展或者经常变动的表结构。

    在 BaseData 中创建一个 AbpBaseDataContext 类,其内容如下:

    using Microsoft.EntityFrameworkCore;
    using Volo.Abp.Data;
    using Volo.Abp.EntityFrameworkCore;
    
    namespace AbpBase.Database
    {
        /// <summary>
        /// 上下文
        /// <para>这部分用于定义和配置基础表的映射</para>
        /// </summary>
        [ConnectionStringName("Default")]
        public partial class AbpBaseDataContext : AbpDbContext<AbpBaseDataContext>
        {
    
            #region 定义 DbSet<T>
    
            #endregion
    
    
            public AbpBaseDataContext(DbContextOptions<AbpBaseDataContext> options)
        : base(options)
            {
            }
    
            /// <summary>
            /// 定义映射
            /// </summary>
            /// <param name="modelBuilder"></param>
            protected override void OnModelCreating(ModelBuilder modelBuilder)
            {
                #region 定义 映射
    
                #endregion
    
                OnModelCreatingPartial(modelBuilder);
            }
    
            partial void OnModelCreatingPartial(ModelBuilder modelBuilder);
        }
    }

    在 ExtensionData 中也创建一个相同的 AbpBaseDataContext 类,其内容如下:

    using Microsoft.EntityFrameworkCore;
    
    namespace AbpBase.Database
    {
    
        public partial class AbpBaseDataContext
        {
            #region 定义 DbSet<T>
    
            #endregion
    
            /// <summary>
            /// 定义映射
            /// </summary>
            /// <param name="modelBuilder"></param>
            partial void OnModelCreatingPartial(ModelBuilder modelBuilder)
            {
    
            }
        }
    }

    分部类,前者用于定义那些非常基础的,程序核心的实体(表)以及映射。而后者定义后续可能多次修改的,设计时感觉有设计余地的。

    多数据库支持和配置

    这里我们将对上下文进行配置和注入,使得程序能够支持多数据库。

    在 AbpBase.Domain.Shared 项目中,创建一个枚举,其内容如下:

    namespace AbpBase.Domain.Shared
    {
        public enum AbpBaseDataType
        {
            Sqlite = 0,
            Mysql = 1,
            Sqlserver = 2
    
            // 其他数据库
        }
    }

    再创建一个 WholeShared 类,其内容如下:

    namespace AbpBase.Domain.Shared
    {
        /// <summary>
        /// 全局共享内容
        /// </summary>
        public static class WholeShared
        {
            // 数据库连接属性可以自行在配置文件中定义,这里写固定的,只是为了演示
    
            /// <summary>
            /// 数据库连接字符串
            /// </summary>
            public static readonly string SqlConnectString = "";
    
            /// <summary>
            /// 要使用的数据库类型
            /// </summary>
            public static readonly AbpBaseDataType DataType = AbpBaseDataType.Sqlite;
        }
    }

    然后我们在 AbpBaseDatabaseModule 模块中的 ConfigureServices 函数里面添加依赖注入:

    context.Services.AddAbpDbContext<AbpBaseDataContext>();

    这里不需要配置数据库连接字符串,后面可以通过 ABP 的一些方法来配置。

    配置上下文连接字符串

                string connectString = default;
                Configure<AbpDbConnectionOptions>(options =>
                {
                    connectString = WholeShared.SqlConnectString;
                    options.ConnectionStrings.Default = connectString;
                });

    配置多数据库支持:

                FreeSql.DataType dataType = default;
    
                Configure<AbpDbContextOptions>(options =>
                {
                    switch (WholeShared.DataType)
                    {
                        case AbpBaseDataType.Sqlite:
                            options.UseSqlite<AbpBaseDataContext>(); dataType = FreeSql.DataType.Sqlite; break;
                        case AbpBaseDataType.Mysql:
                            options.UseMySQL<AbpBaseDataContext>(); dataType = FreeSql.DataType.MySql; break;
                        case AbpBaseDataType.Sqlserver:
                            options.UseSqlServer<AbpBaseDataContext>(); dataType = FreeSql.DataType.SqlServer; break;
                    }
                });

    这样就完成了对 EFCore 的多数据库配置了。

    下面我们来使用类似的方法配置 Freesql。

    Freesql 配置服务

    首先,Freesql 里面有多种配置方式,例如 DbContext,读者可以到 Wiki 去学习 Freesql

    https://github.com/dotnetcore/FreeSql/wiki/%E5%85%A5%E9%97%A8

    笔者这里使用的是 “非正规” 的设计方式,哈哈哈哈。

    在 BaseData 目录中,创建一个 FreesqlContext 类,其内容如下:

    using FreeSql.Internal;
    using System;
    using System.Collections.Generic;
    using System.Text;
    
    namespace AbpBase.Database
    {
        /// <summary>
        /// Freesql 上下文
        /// </summary>
        public partial class FreesqlContext
        {
            public static IFreeSql FreeselInstance => Freesql_Instance;
            private static IFreeSql Freesql_Instance;
    
            public static void Init(string connectStr, FreeSql.DataType dataType = FreeSql.DataType.Sqlite)
            {
                Freesql_Instance = new FreeSql.FreeSqlBuilder()
                    .UseNameConvert(NameConvertType.PascalCaseToUnderscore)
                    .UseConnectionString(dataType, connectStr)
    
                    //.UseAutoSyncStructure(true) // 自动同步实体结构到数据库,生产环境禁止使用!
    
                    .Build();
                OnModelCreating(Freesql_Instance);
            }
    
            private static void OnModelCreating(IFreeSql freeSql)
            {
    
    
                OnModelCreatingPartial(freeSql);
            }
        }
    }

    ExtensionData 目录中,创建 FreesqlContext 类 如下:

    using FreeSql;
    using System;
    using System.Collections.Generic;
    using System.Text;
    
    namespace AbpBase.Database
    {
        public partial class FreesqlContext
        {
            private static void OnModelCreatingPartial(IFreeSql freeSql)
            {
                var modelBuilder = freeSql.CodeFirst;
    
                SyncStruct(modelBuilder);
    
            }
    
            /// <summary>
            /// 同步结构到数据中
            /// </summary>
            /// <param name="codeFirst"></param>
            private static void SyncStruct(ICodeFirst codeFirst)
            {
                //  codeFirst.SyncStructure(typeof(user));
            }
        }
    }

    然后在 AbpBaseDatabaseModule 的 ConfigureServices 函数中添加注入服务:

                FreesqlContext.Init(connectString, dataType);
                context.Services.AddSingleton(typeof(IFreeSql), FreesqlContext.FreeselInstance);
                context.Services.AddTransient(typeof(FreesqlContext), typeof(FreesqlContext));

    通过以上步骤,我们的 ABP 就可以支持多数据库了,EFCore + Freesql,并且将将表分级隔离维护。

    到此这篇关于为ABP框架配置数据库的文章就介绍到这了。希望对大家的学习有所帮助,也希望大家多多支持自由互联。

    上一篇:Redis数据库基础与ASP.NET Core缓存实现
    下一篇:没有了
    网友评论