企业项目实战 .Net Core + Vue/Angular 分库分表日志系统五 | 完善业务自动建立数据库

时间 2020-09-23

标签企业项目实战 core vue angular 分库分表日志系统完善业务自动建立数据库栏目 AngularJS 繁體版

原文原文链接

教程

01 | 模块化方案一html

02 | 模块化方案二git

其余教程预览

分库分表项目实战教程

Git地址： https://github.com/MrChuJiu/EasyLogger

01 | 前言github

02 | 简单的分库分表设计sql

03 | 控制反转搭配简单业务数据库

04 | 强化设计方案api

05 | 完善业务自动建立数据库app

06 | 最终篇-经过AOP自动链接数据库-完成日志业务ide

说明

这节来把基础的业务部分完善一下。模块化

由于 IQueryable的问题咱们仍是先把 IDbRepository 换成 ISqlSugarRepository来使用
private readonly ISqlSugarRepository<EasyLoggerProject,int> _repository;ui

AutoMapper 和 Swagger 已经有很好的讲解文章，不作重复讲解。
安装基本使用的包
AutoMapper
AutoMapper.Extensions.Microsoft.DependencyInjection
基本介绍和使用方法参考：http://www.javashuo.com/article/p-rkhbpcbn-bn.html
Swashbuckle.AspNetCore
基本介绍和使用方法参考：http://www.javashuo.com/article/p-yiveyxrl-bw.html

业务代码部分没什么重点讲解的这里你们对着写一下就行

1.在项目目录下新建文件夹 Dtos 来存放咱们的Dto实体新建文件夹 EasyLoggerProjectDto 存放项目部分的Dto

public class PagedInput
    {
        public Int32 PageSize { get; set; }
        public Int32 PageIndex { get; set; }
    }

public class PagedResultDto<T>
    {
        public List<T> List { get; set; }
        public long Total { get; set; }
    }

public class EasyLoggerProjectListDto
    {
        /// <summary>
        /// 主键
        /// </summary>
        public int Id { get; set; }
        /// <summary>
        /// 名称
        /// </summary>
        public string Name { get; set; }
        /// <summary>
        /// 系统编码
        /// </summary>
        public string Code { get; set; }
    }

public class EasyLoggerProjectInput: PagedInput
    {
        /// <summary>
        /// 项目名称
        /// </summary>
        public string Name { get; set; }
        /// <summary>
        /// 系统编码
        /// </summary>
        public string Code { get; set; }

    }

public class EasyLoggerProjectEditDto
    {
        /// <summary>
        /// 主键
        /// </summary>
        public int? Id { get; set; }
        /// <summary>
        /// 名称
        /// </summary>
        public string Name { get; set; }
        /// <summary>
        /// 系统编码
        /// </summary>
        public string Code { get; set; }
    }

public class CreateOrUpdateEasyLoggerProjectInput
    {
        public EasyLoggerProjectEditDto EasyLoggerProject { get; set; }
    }

2.在项目目录下新建文件夹 AutoMapper 存放咱们的配置文件新建类 EntityToViewModelMappingProfile、ViewModelToEntityMappingProfile 统一继承 Profile 来作Dto的配置

public class EntityToViewModelMappingProfile : Profile
    {
        public EntityToViewModelMappingProfile()
        {
            CreateMap<EasyLoggerProject, EasyLoggerProjectListDto>();
            CreateMap<EasyLoggerProject, EasyLoggerProjectEditDto>();
        }
    }

public class ViewModelToEntityMappingProfile : Profile
    {
        public ViewModelToEntityMappingProfile()
        {
            CreateMap<EasyLoggerProjectListDto, EasyLoggerProject>();
            CreateMap<EasyLoggerProjectEditDto, EasyLoggerProject>();

        }
    }

3.Startup 中记得添加AutoMapper

#region AutoMapper
            services.AddAutoMapper(typeof(EntityToViewModelMappingProfile), typeof(ViewModelToEntityMappingProfile));
#endregion

4.为了方便调试把Swagger也加上去吧(记得操做完从新生成下项目)

5.调试试验一下

6.完工

到此整个教程中最枯燥的部分咱们终于把他完成了。

继续改造咱们的项目

不一样的ORM 都有本身的生成数据库和表的API 咱们把这一部分处理一下

1,将咱们的SqlSugar的依赖注入封装起来

在 EasyLogger.SqlSugarDbStorage 类库下新建SqlSugarDbStorageServiceCollectionExtensions 类

public static class SqlSugarDbStorageServiceCollectionExtensions
    {
        public static IServiceCollection AddSqlSugarDbStorage(this IServiceCollection services,
         ISqlSugarSetting defaultDbSetting)
        {
            if (defaultDbSetting == null)
            {
                throw new ArgumentNullException(nameof(defaultDbSetting));
            }

            services.AddSingleton<ISqlSugarProvider>(new SqlSugarProvider(defaultDbSetting));
            services.AddTransient(typeof(ISqlSugarRepository<,>), typeof(SqlSugarRepository<,>));
            services.AddTransient(typeof(IDbRepository<,>), typeof(SqlSugarRepository<,>));
            services.AddSingleton<ISqlSugarProviderStorage, DefaultSqlSugarProviderStorage>();


            return services;

        }
    }

2.而后改一下 Startup

#region SqlSugar
            // 改造一下把 本身的注入部分封装起来
            var defaultDbPath = Path.Combine(PathExtenstions.GetApplicationCurrentPath(), $"{Configuration["EasyLogger:DbName"]}.db");
            services.AddSqlSugarDbStorage(new SqlSugarSetting()
            {
                Name = SqlSugarDbStorageConsts.DefaultProviderName,
                ConnectionString = @$"Data Source={defaultDbPath}",
                DatabaseType = DbType.Sqlite,
                LogExecuting = (sql, pars) =>
                {
                    Console.WriteLine($"sql:{sql}");
                }
            });
#endregion

3.新建 EasyLogger.Model 类库记得引用 EasyLogger.DbStorage 把咱们的数据库实体迁移进去顺便把咱们的日志实体创建一下

public class EasyLoggerRecord : IDbEntity<int>
    {
        public int Id { get; set; }
        /// <summary>
        /// 项目Id
        /// </summary>
        public int ProjectId { get; set; }
        /// <summary>
        /// 类型.自定义标签
        /// </summary>
        public string LogType { get; set; }
        /// <summary>
        /// 状态-成功、失败、警告等
        /// </summary>
        public string LogState { get; set; }
        /// <summary>
        /// 标题
        /// </summary>
        public string LogTitle { get; set; }
        /// <summary>
        /// 内容描述
        /// </summary>
        public string LogContent { get; set; }
        /// <summary>
        /// 在系统中产生的时间
        /// </summary>
        public DateTime LogTime { get; set; }
        /// <summary>
        /// 建立时间
        /// </summary>
        public DateTime CreateTime { get; set; }
    }

补：注意调整一下引用

4.在 EasyLogger.DbStorage 类库新建 IPartitionDbTableFactory 接口来约束ORM生成数据库

public interface IPartitionDbTableFactory
    {
        void DbTableCreate(string path, bool isBaseDb);
    }

5.老规矩在 EasyLogger.SqlSugarDbStorage 建立类 SqlSugarPartitionDbTableFactory 实现接口

这部分代码的工做：经过外部传递进来数据库的链接，传递建立基础数据库仍是日志数据库，若是是日志数据库，就在生成数据库的同时，根据当月天数，建立对应的表结构。

public class SqlSugarPartitionDbTableFactory : IPartitionDbTableFactory
    {
       
        public void DbTableCreate(string path, bool isBaseDb)
        {
          
            var db = new SqlSugarClient(new ConnectionConfig()
            {
                ConnectionString = $@"Data Source={path}",
                DbType = DbType.Sqlite,
                IsAutoCloseConnection = true, // 自动释放数据务，若是存在事务，在事务结束后释放
                InitKeyType = InitKeyType.Attribute// 从实体特性中读取主键自增列信息
            });

            // 生成数据库
            // db.Ado.ExecuteCommand($"create dataabse {dbName}");

            if (isBaseDb)
            {
                db.CodeFirst.BackupTable().InitTables<EasyLoggerProject>();
            }
            else
            {

                CreateLoggerTable(db);
            }

            db.Dispose();
        }
        private static void CreateLoggerTable(SqlSugarClient db)
        {

            int days = DateTime.DaysInMonth(DateTime.Now.Year, DateTime.Now.Month);
            for (int i = 1; i <= days; i++)
            {
                // 自定义生成表的别名
                db.MappingTables.Add(nameof(EasyLoggerRecord), $"{nameof(EasyLoggerRecord)}_{i}");
                db.CodeFirst.InitTables(typeof(EasyLoggerRecord));
            }

        }
}

6.将咱们 Startup 中 ConfigureServices 建立数据库部分改形成下面这样。

#region 默认建立基础数据库 和  时间数据库

            if (!File.Exists(defaultDbPath))
            {
                var partition = services.BuildServiceProvider().GetService<IPartitionDbTableFactory>();
                partition.DbTableCreate(defaultDbPath, true);
            }

            var startUpDbPath = Path.Combine(PathExtenstions.GetApplicationCurrentPath(), $"{Configuration["EasyLogger:DbName"]}-{DateTime.Now.ToString("yyyy-MM")}.db");
            if (!File.Exists(startUpDbPath))
            {
                var partition = services.BuildServiceProvider().GetService<IPartitionDbTableFactory>();
                partition.DbTableCreate(startUpDbPath, false);
            }

    #endregion

7.最后记得不要忘了在咱们封装的SqlSugar的注入类中添加咱们的注入

8.效果

结尾回顾

这节文章前半部分很是的枯燥很是单纯的业务部分。

重点主要在后半部分

1.咱们首先创建将ORM本身的注入部分封装起来。

2.更改实体存放位置,让其公共出来，目的是能够被其余类库访问

3.咱们建立生成数据库的接口。

4.SqlSugar 使用本身的建立数据库和生成表的方式实现该接口。

思考

如今来看咱们的代码是否是很灵活，新的ORM进来只须要根据咱们的约束实现本身的部分咱们切换ORM只要将 Startup 中 SqlSugar 这行代码换掉就切换完成了。下一节咱们来作动态建立数据库链接，切换数据库查询数据，以及跨表查询数据。