Yuebon.Core/SeedInitData/DBSeedService.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using Quartz.Impl.AdoJobStore.Common;
using SqlSugar;
using System.Collections;
using System.ComponentModel.DataAnnotations;
using System.Reflection;
using Yuebon.Commons;
using Yuebon.Commons.Attributes;
using Yuebon.Commons.Core.App;
using Yuebon.Commons.Extensions;
using Yuebon.Commons.Helpers;
using Yuebon.Commons.Json;
using Yuebon.Commons.Log;
using Yuebon.Core.DataManager;

namespace Yuebon.Core.SeedInitData
{
    /// <summary>
    /// 种子数据生成业务服务类
    /// </summary>
    public class DBSeedService
    {
        /// <summary>
        /// 异步添加种子数据
        /// </summary>
        /// <param name="assembliesDlls">DLL文件名称</param>
        /// <param name="config"></param>
        /// <returns></returns>
        public static async Task SeedAsync(List<string> assembliesDlls,ConnectionConfig config=null)
        {
            string nowAssembliesDll=string.Empty;
            try
            {
                SqlSugarClient Db = GetCustomDB(config);
                //bool isDBReadWriteSeparate = Configs.GetConfigurationValue("AppSetting", "IsDBReadWriteSeparate").ToBool();
                Console.WriteLine("************ YuebonCore DataBase Set *****************");
                Console.WriteLine($"Is multi-DataBase: {Configs.GetConfigurationValue("AppSetting", "MutiDBEnabled")}");
                Console.WriteLine($"Is CQRS: {Configs.GetConfigurationValue("AppSetting", "IsDBReadWriteSeparate")}");
                Console.WriteLine();
                Console.WriteLine($"Master DB ConId: {Db.CurrentConnectionConfig.ConfigId}");
                Console.WriteLine($"Master DB Type: {Db.CurrentConnectionConfig.DbType}");
                Console.WriteLine($"Master DB ConnectString: {Db.CurrentConnectionConfig.ConnectionString}");
                Console.WriteLine();

                // 创建数据库
                Console.WriteLine($"Create Database(The Db Id:{Db.CurrentConnectionConfig.ConfigId})...");
                if (Db.CurrentConnectionConfig.DbType != SqlSugar.DbType.Oracle)
                {
                    Db.DbMaintenance.CreateDatabase();
                    ConsoleHelper.WriteSuccessLine($"Database created successfully!");
                }
                else
                {
                    //Oracle 数据库不支持该操作
                    ConsoleHelper.WriteSuccessLine($"Oracle 数据库不支持该操作，可手动创建Oracle数据库!");
                }
                foreach (string itemDll in assembliesDlls)
                {
                    nowAssembliesDll = itemDll;
                    Console.WriteLine($"assemblies:{itemDll} start...");
                    var path = AppDomain.CurrentDomain.RelativeSearchPath ?? AppDomain.CurrentDomain.BaseDirectory;