.net core +codefirst(.net core 基础入门,适合这方面的小白阅读) 【我们一起写框架】领域驱动设计的CodeFirst框架(一)—序篇

时间:2021-09-17 13:36:51

.net core +codefirst(.net core 基础入门,适合这方面的小白阅读)

 

前言 

 .net core mvc和 .net mvc开发很相似,比如 视图-模型-控制器结构。所以.net mvc开发员很容易入手.net core mvc 。但是两个又有细微的区别,比如配置.net mvc中Web.config和Global.asax消失,而在.net core mvc中则是Startup.cs、Program.cs、appsettings.json等等。所以想要深入了解.net core就必须更加深入的学习。而刚刚开始的学习则是通过建立一个连接数据库的demo开始。由于配置文件的不同,导致很多新手在连接数据库,或者使用codeFisrt开发却不知道怎么配置。所以我在这里较为详细的写一个demo提供给需要此方面的博友。(如有不正确地方欢迎各位指正)

开发工具vs2017

数据库  mssql2014

.net core环境 .net core2.1

1】先建立model层

  1.1先建立一个空白方案

.net core +codefirst(.net core 基础入门,适合这方面的小白阅读)  【我们一起写框架】领域驱动设计的CodeFirst框架(一)—序篇

然后建立一个内库,用来存放model:注意选择内库(.net core)

.net core +codefirst(.net core 基础入门,适合这方面的小白阅读)  【我们一起写框架】领域驱动设计的CodeFirst框架(一)—序篇

  1.2在model层添加内容

现在nuget中分别引用:Microsoft.EntityFrameworkCore.SqlServer和Microsoft.EntityFrameworkCore.Tools,注意两者版本号最好相同,以免出错

.net core +codefirst(.net core 基础入门,适合这方面的小白阅读)  【我们一起写框架】领域驱动设计的CodeFirst框架(一)—序篇

  然后加入model和数据库的上下文类DataBase(这个名字自己随意取),我在这里先只建立一个user表(注意在DataBase中需要

using Microsoft.EntityFrameworkCore;)

.net core +codefirst(.net core 基础入门,适合这方面的小白阅读)  【我们一起写框架】领域驱动设计的CodeFirst框架(一)—序篇
public class DataBase : DbContext
    {
        //构造方法
        public DataBase(DbContextOptions<DataBase> options)
            : base(options)
        { }

        #region 数据区域
        public DbSet<User> User { get; set; }
        #endregion

    }
.net core +codefirst(.net core 基础入门,适合这方面的小白阅读)  【我们一起写框架】领域驱动设计的CodeFirst框架(一)—序篇

.net core +codefirst(.net core 基础入门,适合这方面的小白阅读)  【我们一起写框架】领域驱动设计的CodeFirst框架(一)—序篇

至此,model层配置完毕

2】开始建立.net core项目

先建立一个.net core项目

.net core +codefirst(.net core 基础入门,适合这方面的小白阅读)  【我们一起写框架】领域驱动设计的CodeFirst框架(一)—序篇.net core +codefirst(.net core 基础入门,适合这方面的小白阅读)  【我们一起写框架】领域驱动设计的CodeFirst框架(一)—序篇

项目建立完毕之后先引用model层

.net core +codefirst(.net core 基础入门,适合这方面的小白阅读)  【我们一起写框架】领域驱动设计的CodeFirst框架(一)—序篇

然后进入Startup.cs配置数据库连接,这里首先引用using Microsoft.EntityFrameworkCore;和model层 using Modelx;然后配置连接

.net core +codefirst(.net core 基础入门,适合这方面的小白阅读)  【我们一起写框架】领域驱动设计的CodeFirst框架(一)—序篇

注意services.AddDbContext<DataBase>中的DataBase是model层中的  数据库的上下文类,别弄错了

.net core +codefirst(.net core 基础入门,适合这方面的小白阅读)  【我们一起写框架】领域驱动设计的CodeFirst框架(一)—序篇

以上全部完成,然后添加一个例子看看效果,在任意一个控制器中写入以下代码然后运行(.net core 的一个好处就是内置依赖注入)

.net core +codefirst(.net core 基础入门,适合这方面的小白阅读)  【我们一起写框架】领域驱动设计的CodeFirst框架(一)—序篇

这时,会发现程序报错

.net core +codefirst(.net core 基础入门,适合这方面的小白阅读)  【我们一起写框架】领域驱动设计的CodeFirst框架(一)—序篇

原来,.net core 和.net mvc相比,在使用codefirst时候,除了配置文件之外,.net core 还需要在控制台中执行以下两行代码

 先输入:Add-Migration  MyFirstMigration(名字。这里随意取未MyFirstMigration)

 在输入:Update-Database  

首先我们打开控制台:

.net core +codefirst(.net core 基础入门,适合这方面的小白阅读)  【我们一起写框架】领域驱动设计的CodeFirst框架(一)—序篇

先输入:Add-Migration  MyFirstMigration然后回车等待运行完毕

.net core +codefirst(.net core 基础入门,适合这方面的小白阅读)  【我们一起写框架】领域驱动设计的CodeFirst框架(一)—序篇

然后输入:Update-Database  回车,等到全部运行完毕之后,再运行项目看看,就发现项目正常运行,以及数据库正常生成

.net core +codefirst(.net core 基础入门,适合这方面的小白阅读)  【我们一起写框架】领域驱动设计的CodeFirst框架(一)—序篇

3】ps:关于连接数据库的第二中方法。

关于上文连接数据库,或许有人会问:和自己连接的不太一样,.net core 连接字符串不是应该写在appsettings.json里面?下面,我就将连接数据库的第二种方法写在下面,毕竟多多益善

.net core +codefirst(.net core 基础入门,适合这方面的小白阅读)  【我们一起写框架】领域驱动设计的CodeFirst框架(一)—序篇

.net core +codefirst(.net core 基础入门,适合这方面的小白阅读)  【我们一起写框架】领域驱动设计的CodeFirst框架(一)—序篇

如果想尝试这种方法的话,别忘了在控制台输入

先输入:Add-Migration MyFirstMigrations(名字,为了和上面区分,这里加了s)

在输入:Update-Database

【我们一起写框架】领域驱动设计的CodeFirst框架(一)—序篇

 

前言

领域驱动设计,其实已经是一个很古老的概念了,但它的复杂度依旧让学习的人头疼不已。

互联网关于领域驱动的文章有很多,每一篇写的都很好,理解领域驱动设计的人都看的懂。

不过,这些文章对于那些初学者而言,还是如同天书一样。

买本驱动领域的书来看?别逗了,这可不是C#语法入门,哪里有书能写明白的。

想学会领域驱动设计,只有一途——实践,不断的实践。

领域驱动设计是什么?

领域驱动设计就是我们俗称的DDD,英文全拼是Domain-Driven Design。

我认为,理解领域驱动设计的第一步是,顾名思义;所以,让我们先直白的通过名字来解释看看。

领域驱动设计:用业务领域来做模块分割,以领域为核心思想设计框架,用设计好的领域来驱动系统实现。

如何?这样是不是就好理解了。

其实,领域驱动设计,和我们之前常用的模型驱动设计很相似。其核心区别,也就是一个聚合的概念。

虽然,现在看来,CodeFirst中的聚合太普遍了,但早在十几年前,聚合可是一个让我们头疼的难题,因为那个时代还没有CodeFirst这么便捷的框架。

什么?你不知道聚合是什么?

别担心,我们在后续实现框架的地方,结合代码把这些聚合啦,值对象啦,等等名词一一讲解。

其实,以现在的技术框架的成熟度,聚合这种东西,不理解也就不理解了,无所谓的。

领域驱动设计的意义

虽然,我不想把领域驱动设计搞的那么神秘,但,事实上,领域驱动设计确实挺难学的。

虽然,我们有了CodeFirst这样优秀的框架,但那只是针对使用者,而对设计者而言,CodeFirst并没有减少设计逻辑。所以,想学会领域驱动设计,还是要有一点耐心,并花一点时间,付诸于实践。

虽然,领域驱动设计很复杂,但,我认为它是值得我们付出时间和心血学习的。

因为,驱动领域设计是技术思维的一个分水岭,学会了这种技术思维后,会对框架设计的理解更上一个台阶。

那么,让我们一起做一个领域驱动的框架,在实践中领会这门技艺吧。

领域驱动设计的实现

我们即将编写的框架是基于Entity Framework的,所以越熟悉Entity Framework越好,如果你不熟悉EF,那也没关系,因为我们是从头一步一步编写的。

下面让我们一起编写框架吧。

首先,我们创建项目如下:

.net core +codefirst(.net core 基础入门,适合这方面的小白阅读)  【我们一起写框架】领域驱动设计的CodeFirst框架(一)—序篇

接下来我们把相关的DLL放到KibaDDD程序集下待用。

.net core +codefirst(.net core 基础入门,适合这方面的小白阅读)  【我们一起写框架】领域驱动设计的CodeFirst框架(一)—序篇

然后我们编写核心代码程序集Repository。

首先为Repository程序集引入外部DLL[EntityFramework,EntityFramework.Extended,EntityFramework.SqlServer,CodeFirstStoredProcs],同时,再为程序集引入Utility程序集。

然后我们开始设计Repository程序集的布局。

.net core +codefirst(.net core 基础入门,适合这方面的小白阅读)  【我们一起写框架】领域驱动设计的CodeFirst框架(一)—序篇

如上图所示,我们建立了Repository程序集的布局,布局中的文件夹及文件作用如下:

TableMapping文件夹:用于存储数据表的映射关系。

TableModel文件夹:用于存储数据表模型。

TableRepository文件夹:用于操作数据表。

DateBaseContext文件:管理数据库的核心文件。

RepositoryStatic文件:存储静态的DateBaseContext对象,供其他程序集调用,实现线程内,使用同一个DateBaseContext对象,减少内存开销。

Repository的实现

TableModel

TableModel中我们建立了一个表——Kiba_User,代码如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
public partial class Kiba_User
{
    [Key]
    public int UserId { getset; }
    [Required]
    [StringLength(50)]
    public string UserName { getset; }
    [StringLength(200)]
    public string UserNickName { getset;
    [StringLength(100)]
    public string Password { getset; }
    public int? Age { getset; }
    public int? Sex { getset; }
    [StringLength(500)]
    public string Remark { getset; } 
}

代码很简单,就是把数据表和其字段转换成了类和属性,我们可以把这个类暂时理解为表的数据模型。

TableMapping

TableMapping中我们建立Kiba_User的数据模型表与数据库表的映射关系,代码如下所示:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
public class Kiba_UserMap : EntityTypeConfiguration<Kiba_User>
{
    public Kiba_UserMap()
    {
        this.Property(e => e.UserName)
          .IsUnicode(false);
        this.Property(e => e.UserNickName)
            .IsUnicode(false);
        this.Property(e => e.Password)
            .IsUnicode(false);
        this.Property(e => e.Remark)
            .IsUnicode(false); 
    }
}

从代码中我们可以发现,映射只对部分字符串类型的属性进行了映射,而其他属性,并没有做映射处理。

原因是这样的,没有显示映射处理的属性,会默认映射到同名的数据表字段上;所以这里节省了一些代码量。

DateBaseContext文件

表的数据模型和映射我们已经编写完了,并且,我们还编写了仓储用来对表进行操作;但,这样还不能让数据库和代码模型关联到一起。

我们还需要编写DateBaseContext文件,通过DateBaseContext文件编写,我们就可以把表模型和表映射与数据库关联了。

DateBaseContext文件的代码如下所示:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
public partial class DateBaseContext : DbContext
{
    public DateBaseContext()
        base("name=DateBaseContext")
    {
        this.Configuration.ValidateOnSaveEnabled = true;//保存时验证
        this.Configuration.AutoDetectChangesEnabled = true;//跟踪变化
        this.Configuration.LazyLoadingEnabled = true;//懒惰加载
        this.Configuration.ProxyCreationEnabled = true;//代理创建数据库
    }
    #region Table List
    public virtual DbSet<Kiba_User> Kiba_User { getset; }
    #endregion
    protected override void OnModelCreating(DbModelBuilder modelBuilde
    {
        modelBuilder.Configurations.Add(new Kiba_UserMap());
    }
}

代码很简单,下面我们一起来解读下DateBaseContext文件里的代码。

首先是DateBaseContext继承了DbContext类;DbContext可以理解为微软提供的,专门来管理数据库和代码之间的关系的类。

然后再构造函数DateBaseContext()里,可以看到,我们在构造函数中做了几项基础配置,代码中已经做了相应的注释。

其中this.Configuration.ProxyCreationEnabled属性,我们重点讲一下。

当ProxyCreationEnabled属性设置为True时,我们一旦运行系统,系统会自动的,数据模型同步到数据库,并且会创建一个__MigrationHistory表,来记录同步的内容。

PS:【虽然,在领域驱动设计的理念中,是先有表的数据模型,然后在建立表结构。但,这只是理念,我们运用的时候,先建立表在建立数据模型也是可以的。我这里只是为了简单的实现,所以将ProxyCreationEnabled设置为了True】

接下来,我们定义了一个public virtual DbSet<Kiba_User> Kiba_User { get; set; }属性。

Kiba_User 这个属性,我们可以把他理解为,数据库表在代码世界的代理,如果我们想对数据库表内容进行查询和修改,只要对这个代理进行修改,就会自动同步到数据库了。

然后我们重写了OnModelCreating方法,在OnModelCreating里,把我们刚刚建立的映射关系添加了进去,这样数据库的表,就被我们立体的加载到了代码世界。

TableRepository

TableRepository中主要是应用DateBaseContext来对表进行增删改查的处理,理论上TableRepository是修改数据库的唯一入口;

我们首先,先看下BaseRepository类;代码如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
public class BaseRepository
{
    public DateBaseContext Database
    {
        get
        {
            var context = RepositoryStatic.DateBaseContext as DateBaseContext;
 
            if (context == null)
            {
                context = new DateBaseContext();
                RepositoryStatic.DateBaseContext = context;
            }
              
            return context;
        }
    }
    public int SaveChanges()
    {
        int i = 0;
        int saveCount = 0;
        bool saveFailed;
        do
        {
            saveFailed = false;
 
            try
            {
                saveCount++;
                i = Database.SaveChanges();
                Logger.Debug("SaveChanges Retrun:" + i);
 
            }
            catch (DbUpdateConcurrencyException ex)
            {
                if (saveCount > 3)
                {
                    throw new Exception("服务器繁忙,请稍后");
                }
                Logger.Error("DbUpdateConcurrencyException保存次数:" + saveCount, ex);
                saveFailed = true;
                try
                {
                    ex.Entries.Single().Reload();
                }
                catch (Exception exReload)
                {
                    Logger.Info("exReload保存失败");
                    throw exReload;
                }
            }
            catch (DbUpdateException ex)
            {
                if (ex.Message.Contains("与另一个进程被死锁在 锁 资源上,并且已被选作死锁牺牲品。请重新运行该事务。"))
                {
                    throw new Exception("服务器繁忙,请稍后");
                }
                else
                {
                    throw ex;
                }
            }
            catch (DbEntityValidationException dbEx)
            {
                Logger.Error(dbEx);
                throw dbEx;
            }
 
            catch (Exception ex)
            {
                Logger.Info("SaveChanges保存失败");
                throw ex;
            }
 
        while (saveFailed);
        return i;
    }
}

这里我们主要定义一个属性Database和一个方法SaveChanges。

Database就是DateBaseContext类的实例,相当于代码世界的数据库。

SaveChanges就是调用Database的SaveChanges方法来保存数据的修改,当然,我们对该方法进行了一些封装,让他更饱满一些。

然后我们在一起看下表的独立仓储Kiba_UserRepo,代码如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
public class Kiba_UserRepo : BaseRepository
{  
    public List<T> GetSelector<T>(Expression<Func<Kiba_User, T>> selector, Expression<Func<Kiba_User, bool>> where)
    {
        return Database.Kiba_User.Where(where).Select(selector).ToList();
    }
    public List<Kiba_User> GetWhere(Expression<Func<Kiba_User, bool>> whereint currentPage, int pageCount)
    {
        return Database.Kiba_User.Where(where).OrderByDescending(p => p.UserId).Skip((currentPage - 1) * pageCount).Take(pageCount).ToList();
    }
    public int GetWhereCount(Expression<Func<Kiba_User, bool>> where)
    {
        return Database.Kiba_User.Where(where).Count();
    }
    public Kiba_User Add(Kiba_User model)
    {
        var addModel = Database.Kiba_User.Add(model);
        return addModel;
    }
    public Kiba_User Delete(Kiba_User model)
    {
        var delModel = Database.Kiba_User.Remove(model);
        return delModel;
    }
}

表仓储里的代码很简单,就是普通的LINQ增删改查。

----------------------------------------------------------------------------------------------------

到此,框架的基本雏形就已经编写完成了,接下来我们做一下简单调用,测试一下。

在KibaDDD项目建立测试类——TestRun;代码如下:

1
2
3
4
5
6
7
8
9
public class TestRun
{
    public TestRun()
    {
        Kiba_UserRepo repo = new Kiba_UserRepo();
        repo.Add(new Kiba_User() { UserName = "kiba518" });
        repo.SaveChanges();
    }
}

运行结果:

.net core +codefirst(.net core 基础入门,适合这方面的小白阅读)  【我们一起写框架】领域驱动设计的CodeFirst框架(一)—序篇

.net core +codefirst(.net core 基础入门,适合这方面的小白阅读)  【我们一起写框架】领域驱动设计的CodeFirst框架(一)—序篇

数据库无中生有的,为我们创建了表Kiba_User,并且数据也顺利的插入进了数据库表。

这样,我们的领域驱动框架就已经完成了雏形搭建,下一篇文章将进一步搭建,实现领域驱动独有的聚合。

----------------------------------------------------------------------------------------------------

框架代码已经传到Github上了,欢迎大家下载。

Github地址:https://github.com/kiba518/KibaDDD