.net之生成數(shù)據(jù)庫(kù)全流程實(shí)現(xiàn)

開(kāi)篇語(yǔ)

本文主要是回顧下從項(xiàng)目創(chuàng)建到生成數(shù)據(jù)到數(shù)據(jù)庫(kù)(代碼優(yōu)先)的全部過(guò)程。采用efcore作為orm框架。

本次示例環(huán)境：vs2019、net5、mysql

創(chuàng)建項(xiàng)目

本次事例代碼是用過(guò)vs2019創(chuàng)建的asp.net core web api項(xiàng)目

可以通過(guò)可視化界面創(chuàng)建或者通過(guò)命令行創(chuàng)建

dotnet new webapi -o net5bydocker

創(chuàng)建實(shí)體類

安裝組件

  <packagereference include="pomelo.entityframeworkcore.mysql" version="5.0.0" />
  <packagereference include="pomelo.entityframeworkcore.mysql.json.newtonsoft" version="5.0.0" />

增加實(shí)體類

  [table("user")]
  public class user
  {
      public user()
      {
          id = guid.newguid().tostring();
      }

      public user(string account, string password, string creater) : this()
      {
          account = account;
          password = password;
          deleted = false;
          setcreater(creater);
      }

      [key]
      [comment("主鍵")]
      [stringlength(36)]
      [required]
      public string id { get; private set; }

      [comment("帳號(hào)")]
      [stringlength(36)]
      [required]
      public string account { get; private set; }

      [comment("密碼")]
      [stringlength(36)]
      [required]
      public string password { get; private set; }

      [comment("余額")]
      [column(typename = "decimal(18, 2)")]
      [required]
      public decimal money { get; set; }

      [comment("是否刪除")]
      [column(typename = "tinyint(1)")]
      [required]
      public bool deleted { get; private set; }

      [comment("創(chuàng)建人")]
      [stringlength(20)]
      [required]
      public string creater { get; private set; }

      [comment("創(chuàng)建時(shí)間")]
      [required]
      public datetime createtime { get; private set; }

      [comment("修改人")]
      [stringlength(20)]
      [required]
      public string modifyer { get; private set; }

      [comment("修改時(shí)間")]
      [required]
      public datetime modifytime { get; private set; }

      public void setcreater(string name)
      {
          creater = name;
          createtime = datetime.now;
          setmodifyer(name);
      }

      public void setmodifyer(string name)
      {
          modifyer = name;
          modifytime = datetime.now;
      }
  }

這種只是增加實(shí)體類類型的一種方式，可能這種看著比較亂，還可以通過(guò)onmodelcreating實(shí)現(xiàn)，詳情看參考文檔

增加數(shù)據(jù)庫(kù)上下文opendbcontext

  public class opendbcontext : dbcontext
  {
      public opendbcontext(dbcontextoptions<opendbcontext> options)
          : base(options)
      {
      }

      public dbset<user> users { get; set; }
  }

startup注入連接數(shù)據(jù)庫(kù)操作

          var connection = configuration["dbconfig:mysql:connectionstring"];
          var migrationsassembly = introspectionextensions.gettypeinfo(typeof(startup)).assembly.getname().name;
          services.adddbcontext<opendbcontext>(option => option.usemysql(connection, serverversion.autodetect(connection), x =>
          {
              x.usenewtonsoftjson();
              x.migrationsassembly(migrationsassembly);
          }));

生成遷移文件

引用組件

<packagereference include="microsoft.entityframeworkcore.design" version="5.0.5">
<packagereference include="microsoft.entityframeworkcore.tools" version="5.0.5">

遷移命令

add-migration init

結(jié)果

要看下生成的遷移文件是否是自己預(yù)期的那樣子，也可以在這一步就生成數(shù)據(jù)庫(kù)，命令：update-database

數(shù)據(jù)種子

增加opendbsend類，添加數(shù)據(jù)種子

  public class opendbsend
  {
      /// <summary>
      /// 生成數(shù)據(jù)庫(kù)以及數(shù)據(jù)種子
      /// </summary>
      /// <param name="dbcontext">數(shù)據(jù)庫(kù)上下文</param>
      /// <param name="loggerfactory">日志</param>
      /// <param name="retry">重試次數(shù)</param>
      /// <returns></returns>
      public static async task seedasync(opendbcontext dbcontext,
          iloggerfactory loggerfactory,
          int? retry = 0)
      {
          int retryforavailability = retry.value;
          try
          {
              dbcontext.database.migrate();//如果當(dāng)前數(shù)據(jù)庫(kù)不存在按照當(dāng)前 model 創(chuàng)建，如果存在則將數(shù)據(jù)庫(kù)調(diào)整到和當(dāng)前 model 匹配
              await initializeasync(dbcontext).configureawait(false);

              //if (dbcontext.database.ensurecreated())//如果當(dāng)前數(shù)據(jù)庫(kù)不存在按照當(dāng)前 model創(chuàng)建，如果存在則不管了。
              //  await initializeasync(dbcontext).configureawait(false);
          }
          catch (exception ex)
          {
              if (retryforavailability < 3)
              {
                  retryforavailability++;
                  var log = loggerfactory.createlogger<opendbsend>();
                  log.logerror(ex.message);
                  await seedasync(dbcontext, loggerfactory, retryforavailability).configureawait(false);
              }
          }
      }

      /// <summary>
      /// 初始化數(shù)據(jù)
      /// </summary>
      /// <param name="context"></param>
      /// <returns></returns>
      public static async task initializeasync(opendbcontext context)
      {
          if (!context.set<user>().any())
          {
              await context.set<user>().addasync(new user("azrng", "123456", "azrng")).configureawait(false);
              await context.set<user>().addasync(new user("張三", "123456", "azrng")).configureawait(false);
          }
          await context.savechangesasync().configureawait(false);
      }
  }

設(shè)置項(xiàng)目啟動(dòng)時(shí)候調(diào)用

      public static async task main(string[] args)
      {
          var host = createhostbuilder(args).build();
          using (var scope = host.services.createscope())
          {
              var services = scope.serviceprovider;
              var loggerfactory = services.getrequiredservice<iloggerfactory>();
              var _logger = loggerfactory.createlogger<program>();
              try
              {
                  var opencontext = services.getrequiredservice<opendbcontext>();
                  await opendbsend.seedasync(opencontext, loggerfactory).configureawait(false);
              }
              catch (exception ex)
              {
                  _logger.logerror(ex, $"項(xiàng)目啟動(dòng)出錯(cuò)  {ex.message}");
              }
          }

          await host.runasync().configureawait(false);
      }

生成數(shù)據(jù)庫(kù)

啟動(dòng)項(xiàng)目，自動(dòng)生成數(shù)據(jù)庫(kù)

表結(jié)構(gòu)如下

如果后期數(shù)據(jù)庫(kù)字段或者結(jié)構(gòu)有變動(dòng)，可以再次生成遷移文件然后生成數(shù)據(jù)庫(kù)

查詢數(shù)據(jù)

  /// <summary>
  /// 用戶接口
  /// </summary>
  public interface iuserservice
  {
      string getname();

      /// <summary>
      /// 查詢用戶信息
      /// </summary>
      /// <param name="account"></param>
      /// <returns></returns>
      task<user> getdetailsasync(string account);
  }

  /// <summary>
  /// 用戶實(shí)現(xiàn)
  /// </summary>
  public class userservice : iuserservice
  {
      private readonly opendbcontext _dbcontext;

      public userservice(opendbcontext dbcontext)
      {
          _dbcontext = dbcontext;
      }

      public string getname()
      {
          return "azrng";
      }

      ///<inheritdoc cref="iuserservice.getdetailsasync(string)"/>
      public async task<user> getdetailsasync(string account)
      {
          return await _dbcontext.set<user>().firstordefaultasync(t => t.account == account).configureawait(false);
      }
  }

一般更推薦建立指定的返回model類，然后只查詢需要的內(nèi)容，不直接返回實(shí)體類

控制器方法

      /// <summary>
      /// 查詢用戶詳情
      /// </summary>
      /// <param name="account"></param>
      /// <returns></returns>
      [httpget]
      public async task<actionresult<user>> getdetailsasync(string account)
      {
          return await _userservice.getdetailsasync(account).configureawait(false);
      }

查詢結(jié)果

{
"id": "e8976d0a-6ee9-4e2e-b8d8-1fe6e85b727b",
"account": "azrng",
"password": "123456",
"money": 0,
"deleted": false,
"creater": "azrng",
"createtime": "2021-05-09t15:48:45.730302",
"modifyer": "azrng",
"modifytime": "2021-05-09t15:48:45.730425"
}

參考文檔

實(shí)體類型：https://docs.microsoft.com/zh-cn/ef/core/modeling/entity-types?tabs=data-annotations

實(shí)體屬性：https://docs.microsoft.com/zh-cn/ef/core/modeling/entity-properties?tabs=data-annotations%2cwithout-nrt

關(guān)于.net之生成數(shù)據(jù)庫(kù)全流程實(shí)現(xiàn)的文章就介紹至此，更多相關(guān).net 生成數(shù)據(jù)庫(kù)內(nèi)容請(qǐng)搜索碩編程以前的文章，希望大家多多支持碩編程！