為ABP框架配置數據庫

在 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框架配置數據庫的文章就介紹到這瞭。希望對大傢的學習有所幫助,也希望大傢多多支持WalkonNet。

推薦閱讀: