title: 数据库 EF Core 连接层
abbrlink: b8fc92bb
date: 2022-09-09 18:57:54

示例

oracle

Factory

工厂和连接池可以减少访问；

对业务访问量小的就不用考虑了；

如果你业务有不同数据库的考虑就使用工厂模式读取配置这个方式；

// C#

using System;
using System.Data;
using System.Data.Common;
using Oracle.DataAccess.Client;

class FactorySample
{
  static void Main()
  {
    string constr = "user id=scott;password=tiger;data source=oracle";

    DbProviderFactory factory =
            DbProviderFactories.GetFactory("Oracle.DataAccess.Client");

    DbConnection conn = factory.CreateConnection();

    try
    {
      conn.ConnectionString = constr;
      conn.Open();

      DbCommand cmd = factory.CreateCommand();
      cmd.Connection = conn;
      cmd.CommandText = "select * from emp";

      DbDataReader reader = cmd.ExecuteReader();
      while (reader.Read())
        Console.WriteLine(reader["EMPNO"] + " : " + reader["ENAME"]);
    }
    catch (Exception ex)
    {
      Console.WriteLine(ex.Message);
      Console.WriteLine(ex.StackTrace);
    }
  }
}

使用

见官网教程；

配置这块：使用appsettings.json; 这个文件要设置成在build 会copy to output dir; 不然build后没有这个文件；

{
  "BlogCateLog": "H:\ \\YuriBlog",
  "editor": "C:\\Program Files\\MarkText\\MarkText.exe",
  "Connstr": "Data Source =",
  //"NpgsqlConnstr": "Data Source = postgres://postgres:postgrespw@localhost:55000"
  "NpgsqlConnstr": "Server=127.0.0.1;Port=55000;Database=postgres;User Id=postgres;Password=postgrespw;"
}

Model类这块：

我设计了从配置文件里读入连接字符串；建议使用依赖注入模式；

 public BloggingContext()
       {
           var folder = Environment.SpecialFolder.LocalApplicationData;
           var path = Environment.GetFolderPath(folder);
           DbPath = System.IO.Path.Join(path, "blogging.db");
           MyService myService = ServiceProviderFactory.ServiceProvider.GetRequiredService<MyService>();
           Connstr = myService.getConnstr("NpgsqlConnstr");
           //Connstr = myService.getConnstr("Connstr");
       }

       // The following configures EF to create a Sqlite database file in the
       // special "local" folder for your platform.
       protected override void OnConfiguring(DbContextOptionsBuilder options)
           => options.UseNpgsql(Connstr);
       //=> options.UseOracle(Connstr);
       //=> options.UseOracle($"Data Source={DbPath}");

       //https://docs.microsoft.com/zh-cn/ef/core/cli/powershell
   }

访问操作：
业务架构简单的，需求，稳定性的；使用实体型；

即使用 orm操作对象；orm已经在安全性方面有了准备（sql注入）；

DbContext Lifetime, Configuration, and Initialization - EF Core | Microsoft Docs了解；如果与外界隔离无视安全的；可以自实现；写原生sql的好处；业务及性能及维运都有好处，程式也会简洁；

其实只有最适合的；只不是把工作转嫁到了另一方面；

raw sql 写原生sql；如果两种方式都想实现的话；使用Executing Raw SQL Queries using Entity Framework Core | Learn Entity Framework Core

      //主要是从database拿到连接执行sql
      #region rawsql
              //db.Database.ExecuteSqlRaw("sql"  );
              //db.Blogs.FromSqlRaw();//https://www.learnentityframeworkcore.com/raw-sql
              //db.Database.GetDbConnection().CreateCommand();
              #endregion

不建议同一业务内两种模式；因为同一业务可能是逻辑差不多的，两个就得两种维护；

更换数据库

先add migration 或者删除旧的remove migration 等；不然不同的数据库生成的sql无法执行的问题；

如pg 到oracle ：删除旧的migratin文件；

了解底层转换原理

由于数据库与语言有差异；在转换的时候可能并不是你要的结果；

如在Linq时：null 如何判定？where等值对null的处理;？

以及一些数据库有特别的类型；

操作

Entity Framework 多種刪除 | 我，傑夫。開發人 (wordpress.com)

第一個是常見的寫法：

Remove()

| 1

2

3 | TestModel object = context.TestModel.Single(x => x.Name == "John"`); context.TestModel.Remove(object); context.SaveChanges();` |
| ——————- | ———————————————————————————————————————————————————— |

.
第二個方式是改變 EntityState 狀態：

EntityState.Deleted

| 1

2

3 | TestModel object = context.TestModel.Single(x => x.Name == "John"`); context.Entry(object).State = EntityState.Deleted; context.SaveChanges();` |
| ——————- | —————————————————————————————————————————————————————————– |

.
或者使用套件 Entity Framework Extended Library。就可以使用以下的寫法來刪除資料。要安装库啊

Delete()

| 1 | context.TestModel.Delete(x => x.Id == ID); |
| — | ——————————————– |

或是

| 1 | context.TestModel.Where(x => x.Id == ID).Delete(); |
| — | —————————————————- |

c# - Delete a single record from Entity Framework? - Stack Overflow

RemoveRange 移除多个1- For multiple records

```javascript
db.People.RemoveRange(db.People.Where(x => x.State == "CA"));
db.SaveChanges();

```csharp
context.ExecuteStoreCommand("DELETE FROM YOURTABLE WHERE CustomerID = {0}", customerId);

数据库-EF-Core-连接层

tags:

示例