.netcore基于mysql的codefirst

此文仅是对于netcore基于mysql的简单的codefirst实现的简单记录。示例为客服系统消息模板的增删改查实现

第一步、创建实体项目，并在其中建立对应的实体类，以及数据库访问类

须引入Pomelo.EntityFrameworkCore.MySql和Microsoft.EntityFrameworkCore

///

///消息模板///

public classMessatgeTemplate

{///

///id///

[Key]public System.Guid Id { get; set; }///

///名称///

[MaxLength(250)]public string Name { get; set; }///

///关键字///

[MaxLength(500)]public string Keywords { get; set; }///

///内容///

public string Content { get; set; }///

///语言///

[MaxLength(80)]public string CultureCode { get; set; }///

///类别///

[MaxLength(250)]public string Category { get; set; }///

///备注信息///

public string Remark { get; set; }///

///是否启用///

public bool Enabled { get; set; }///

///创建时间///

public DateTime Created { get; set; }///

///最近修改时间///

public DateTime LastModified { get; set; }

}

///

///

///

public classCustomerServiceContext : DbContext

{public CustomerServiceContext(DbContextOptionsoptions)

:base(options)

{

}///

///配置///

///

protected override voidOnConfiguring(DbContextOptionsBuilder optionsBuilder)

{base.OnConfiguring(optionsBuilder);

}public virtual DbSet MessatgeTemplate { get; set; }

}

第二步、创建业务服务项目，添加对应的业务处理类

///

///客服业务统一接口///

public interfaceICustomerServicerSerice

{

}

///

///模板业务类///

public classMessageTemplateService : ICustomerServicerSerice

{privateCustomerServiceContext _CustomerServiceContext;publicMessageTemplateService(CustomerServiceContext customerServiceContext)

{this._CustomerServiceContext =customerServiceContext;

}///

///创建模板///

public voidCreateMessageTemplate()

{//todo create

}///

///修改模板///

public voidModifyMessageTemplate()

{//TODO modified

}///

///获取模板///

///

public ListGetMessageTemplate()

{//TODO根据传入参数查询模板

return null;

}///

///删除///

public voidDeleteMessageTemplate(Guid id)

{var template = _CustomerServiceContext.MessatgeTemplate.FirstOrDefault(p => p.Id ==id);if (template != null)

{

_CustomerServiceContext.MessatgeTemplate.Remove(template);

_CustomerServiceContext.SaveChanges();

}

}///

///批量设置是否可用///

///

///

public void BatchEnableTemplate(List ids, boolenabled)

{//TODO set enabled

}

}

第三步、创建webapi项目，并在其中建立对应的实体类，以及数据库访问类

须引入Microsoft.EntityFrameworkCore和Microsoft.EntityFrameworkCore.Design.

1、在appsettings.json中配置数据连接

"ConnectionStrings": {"CumstomerServiceConnection": "server=localhost;port=3306;database=CustomerServiceCenter;uid=root;pwd=root23456;CharSet=utf8"}

2、修改startup.cs类的ConfigureServices注入db访问类

services.AddDbContext(p => p.UseMySql(Configuration.GetConnectionString("CumstomerServiceConnection")));

3、设置该webapi项目为启动项目，在nuget程序包控制台选择第一步中创建的实体类项目依次运行如下脚本创建数据库

1)add-migration init

2) update-database

上面的两个命令中，add-migration表示添加数据迁移，其实就是将实体变更转换成sql(add-migraion后面的init只是个名称，可以自行定义)，update-database是将生成的数据迁移信息更新到数据库

另外一些可能用到的命令

remove-migration  ---将最近生成的迁移(没有更新到数据库的)移除掉

script-migration --生成数据库迁移相应的脚本

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

命令执行成功后，就可以在数据库中找到创建好的数据库和表了

script-datatable可以生成数据库脚本语句

好了，以上就完成了codefirst的简单操作了。不过跟着第二步的业务类其实没啥关系！！！如果只是进行数据迁移确实没有service层什么事，但是业务逻辑要走通，实现crud，业务层还是必须的。

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

以下就顺带写下controller中引入service，实现简单的删除业务逻辑(其它的业务逻辑---略)

在webapi创建MessageTemplateController

[Route("api/[controller]")]

[ApiController]public classMessageTemplateController : ControllerBase

{privateMessageTemplateService _MessageTemplateService;publicMessageTemplateController(MessageTemplateService messageTemplateService)

{this._MessageTemplateService =messageTemplateService;

}///

///删除///

///

[HttpPost("DeleteMessageTemplate")]public voidDeleteMessageTemplate(Guid id)

{

_MessageTemplateService.DeleteMessageTemplate(id);

}//TODO其他操作：查询，新增，修改等

}

修改Startup.cs类，注入服务

public voidConfigureServices(IServiceCollection services)

{

services.AddControllers();

services.AddDbContext(p => p.UseMySql(Configuration.GetConnectionString("CumstomerServiceConnection")));#region 注入业务服务Assembly assembly= Assembly.Load("Qingy.DotNetCoreStudy.CustomerServiceService");

List types = assembly.GetTypes().Where(u => u.IsClass && !u.IsAbstract && !u.IsGenericType&& u.GetInterfaces().Any(p => p == typeof(ICustomerServicerSerice))

).ToList();foreach (var item intypes)

{

services.AddTransient(item);

}#endregion}

综合以上，就可以将api到db的完整实现了。