翼度科技»论坛 编程开发 .net 查看内容

【EF Core】自动生成的字段值

9

主题

9

帖子

27

积分

新手上路

Rank: 1

积分
27
自动生成字段值,咱们首先想到的是主键列(带 IDENTITY 的主键)。EF Core 默认的主键配置也是启用 Identity 自增长的,而且可以自动标识主键。前提是代表主键的实体属性名要符合以下规则:
1、名字叫 ID、id、或 Id,就是不分大小写;
2、名字由实体类名 + Id 构成。比如,Car 实体类,包含一个属性叫 CarID 或 CarId;
3、属性类型是整数类型(int、long、ushort 等,但不是 byte)或 GUID。
这些识别主键的规则是由一种叫“约定”(Convension)的东西实现的,具体来说,是一个叫 KeyDiscoveryConvention 的类。老周放一小段源代码给各位瞧瞧。
  1. public class KeyDiscoveryConvention :
  2.     IEntityTypeAddedConvention,
  3.     IPropertyAddedConvention,
  4.     IKeyRemovedConvention,
  5.     IEntityTypeBaseTypeChangedConvention,
  6.     IEntityTypeMemberIgnoredConvention,
  7.     IForeignKeyAddedConvention,
  8.     IForeignKeyRemovedConvention,
  9.     IForeignKeyPropertiesChangedConvention,
  10.     IForeignKeyUniquenessChangedConvention,
  11.     IForeignKeyOwnershipChangedConvention,
  12.     ISkipNavigationForeignKeyChangedConvention
  13. {
  14.     private const string KeySuffix = "Id";
  15.     ……
  16.     public static IEnumerable<IConventionProperty> DiscoverKeyProperties(
  17.         IConventionEntityType entityType,
  18.         IEnumerable<IConventionProperty> candidateProperties)
  19.     {
  20.         Check.NotNull(entityType, nameof(entityType));
  21.         // ReSharper disable PossibleMultipleEnumeration
  22.         var keyProperties = candidateProperties.Where(p => string.Equals(p.Name, KeySuffix, StringComparison.OrdinalIgnoreCase));
  23.         if (!keyProperties.Any())
  24.         {
  25.             var entityTypeName = entityType.ShortName();
  26.             keyProperties = candidateProperties.Where(
  27.                 p => p.Name.Length == entityTypeName.Length + KeySuffix.Length
  28.                     && p.Name.StartsWith(entityTypeName, StringComparison.OrdinalIgnoreCase)
  29.                     && p.Name.EndsWith(KeySuffix, StringComparison.OrdinalIgnoreCase));
  30.         }
  31.         return keyProperties;
  32.         // ReSharper restore PossibleMultipleEnumeration
  33.     }
  34.    ……
  35. }
复制代码
这几个逻辑 And 其实就是查找 Id 格式的属性名,如 StudentID、CarId、OrderID…… 外键的发现原理也跟主键一样。
用 Sqlite 数据举一个简单的例子。下面是实体类(假设它用来表示输入法信息):
  1. public class InputMethod
  2. {
  3.     public ushort RecoId { get; set; }
  4.     public string? MethodDisplay { get; set; }
  5.     public string? Description { get; set; }
  6.     public string? Culture { get; set; }
  7. }
复制代码
如你所见,这个类作为主键的属性是 RecoId,但是,它的命名是无法被自动识别的,咱们必须明确地告诉 EF,它是主键。方法有二:
1、批注法。直接在属性上应用相关的特性类。如
  1. public class InputMethod
  2. {
  3.     [Key]
  4.     public ushort RecoId { get; set; }
  5.     ……
  6. }
复制代码
2、重写 DbContext 类的 OnModelCreating 方法。如
  1. protected override void OnModelCreating(ModelBuilder modelBuilder)
  2. {
  3.     modelBuilder.Entity<InputMethod>().HasKey(e => e.RecoId);
  4. }
复制代码
如果使用了上面重写 OnModelCreating 方法,那么,你的 DbContext 派生类已经能识别 InputMethod 实体类了。但如果你用的是在属性上应用 [Key] 特性的方式,那么 DbContext 的派生类是识别不到实体类的,你需要将它的集合声明为 DbContext 的属性。
  1. internal class TestDBContext : DbContext
  2. {
  3.     // 构造函数
  4.     public TestDBContext(DbContextOptions<TestDBContext> opt)
  5.         : base(opt)
  6.     { }
  7.     // 将实体集合声明为属性
  8.     public DbSet<InputMethod> InputMethods { get; set; }
  9. }
复制代码
注意,数据记录的集合要用 DbSet,其他类型的集合是不行的哟。比如,你改成这样,就会报错。
  1. public List<InputMethod> InputMethods { get; set; }
复制代码

说明人家只认 DbSet 集合,其他集合无效。
这里老周选用服务容器来配置。
  1. static void Main(string[] args)
  2. {
  3.     IServiceCollection services = new ServiceCollection();
  4.     // 构建连接字符串
  5.     SqliteConnectionStringBuilder constrbd = new();
  6.     constrbd.DataSource = "abc.db";
  7.     // 添加 Sqlite 功能
  8.     services.AddSqlite<TestDBContext>(
  9.             connectionString:    constrbd.ToString(),
  10.             optionsAction:       dcopt =>
  11.             {
  12.                 dcopt.LogTo(msg => Console.WriteLine(msg), LogLevel.Information);
  13.             }
  14.         );
  15.     // 生成服务列表
  16.     var svcProd = services.BuildServiceProvider();
  17.     if(svcProd == null)
  18.     {
  19.         return;
  20.     }
  21.     // 访问数据上下文
  22.     using TestDBContext dbc = svcProd.GetRequiredService<TestDBContext>();
  23.     ……
  24. }
复制代码
连接字符串你可以直接用字符串写,不用 ConnectionStringBuilder。默认的 SQLite 库是不支持密码的,所以老周就不设置密码了。在调用 AddSqlite 方法时,有一个名为 optionsAction 的参数,咱们可以用它配置日志输出。LogTo 方法配置简单,只要提供一个委托,它绑定的方法只要有一个 string 类型的输入参数就行,这个字符串参数就是日志文本。
配置日志功能后,运行程序时,控制台能看到执行的 SQL 语句。
下面咱们来创建数据库,然后插入两条 InputMethod 记录。
  1. // 访问数据上下文
  2. using TestDBContext dbc = svcProd.GetRequiredService<TestDBContext>();
  3. // 删除数据库
  4. dbc.Database.EnsureDeleted();
  5. // 创建数据库
  6. dbc.Database.EnsureCreated();
  7. // 尝试插入两条记录
  8. InputMethod[] ents = [
  9.         new(){MethodDisplay = "双拼输入", Description="按两个键完成一个音节",Culture="zh-CN"},
  10.         new() {MethodDisplay = "六指输入", Description="专供六个指头的人使用",Culture="zh-CN"}
  11.     ];
  12. dbc.Set<InputMethod>().AddRange(ents);
  13. int result = dbc.SaveChanges();
  14. Console.WriteLine($"更新记录数:{result}");
  15. // 打印插入的记录
  16. foreach(InputMethod im in dbc.Set<InputMethod>())
  17. {
  18.     Console.WriteLine($"ID={im.RecoId}, Display={im.MethodDisplay}, Culture={im.Culture}");
  19. }
复制代码
这里是为了测试,调用了 EnsureDeleted 方法,实际应用时一般不要调用。因为这个方法的功能是把现存的数据库删除。如果调用了此方法,那应用程序每次启动都会删掉数据库,那用户肯定会投诉你的。EnsureCreated 方法可以使用,它的功能是如果数据库不存在,就创建新数据库;如果数据库存在,那啥也不做。所以,调用 EnsureCreated 方法不会造成数据丢失,放心用。
插入数据和调用 SaveChanges 方法保存到数据库的代码,相信大伙都很熟了,老周就不介绍了。
程序运行之后,将得到这样的日志:
  1. info: 2024/8/4 12:48:11.517 RelationalEventId.CommandExecuted[20101] (Microsoft.EntityFrameworkCore.Database.Command)
  2.       Executed DbCommand (10ms) [Parameters=[], CommandType='Text', CommandTimeout='30']
  3.       PRAGMA journal_mode = 'wal';
  4. info: 2024/8/4 12:48:11.582 RelationalEventId.CommandExecuted[20101] (Microsoft.EntityFrameworkCore.Database.Command)
  5.       Executed DbCommand (0ms) [Parameters=[], CommandType='Text', CommandTimeout='30']
  6.       CREATE TABLE "tb_ims" (
  7.           "RecoId" INTEGER NOT NULL CONSTRAINT "PK_tb_ims""MethodDisplay""Description""Culture" TEXT NULL
  8.       );
  9. info: 2024/8/4 12:48:11.700 RelationalEventId.CommandExecuted[20101] (Microsoft.EntityFrameworkCore.Database.Command)
  10.       Executed DbCommand (3ms) [Parameters=[@p0='?' (Size = 5), @p1='?' (Size = 10), @p2='?' (Size = 4)], CommandType='Text', CommandTimeout='30']
  11.       INSERT INTO "tb_ims" ("Culture", "Description", "MethodDisplay")
  12.       VALUES (@p0, @p1, @p2)
  13.       RETURNING "RecoId";
  14. info: 2024/8/4 12:48:11.712 RelationalEventId.CommandExecuted[20101] (Microsoft.EntityFrameworkCore.Database.Command)
  15.       Executed DbCommand (0ms) [Parameters=[@p0='?' (Size = 5), @p1='?' (Size = 10), @p2='?' (Size = 4)], CommandType='Text', CommandTimeout='30']
  16.       INSERT INTO "tb_ims" ("Culture", "Description", "MethodDisplay")
  17.       VALUES (@p0, @p1, @p2)
  18.       RETURNING "RecoId";
  19. 更新记录数:2
  20. info: 2024/8/4 12:48:11.849 RelationalEventId.CommandExecuted[20101] (Microsoft.EntityFrameworkCore.Database.Command)
  21.       Executed DbCommand (0ms) [Parameters=[], CommandType='Text', CommandTimeout='30']
  22.       SELECT "t"."RecoId", "t"."Culture", "t"."Description", "t"."MethodDisplay"
  23.       FROM "tb_ims" AS "t"
  24. ID=1, Display=双拼输入, Culture=zh-CN
  25. ID=2, Display=六指输入, Culture=zh-CN
复制代码
这样你会发现,对于整数类型的主键,默认是自动生成递增ID的。注意,这个是由数据库生成的,而不是 EF Core 的生成器。不同数据库的 SQL 语句会有差异。
为了对比,咱们不防改为 SQL Server,看看输出的日志。
  1. // 构建连接字符串
  2. SqlConnectionStringBuilder constrbd = new();
  3. constrbd.DataSource = ".\\SQLTEST";
  4. constrbd.InitialCatalog = "CrazyDB";
  5. constrbd.IntegratedSecurity = true;
  6. // 不信任服务器证书有时候会连不上
  7. constrbd.TrustServerCertificate = true;
  8. // 可读可写
  9. constrbd.ApplicationIntent = ApplicationIntent.ReadWrite;
  10. // 添加 SQL Server 功能
  11. services.AddSqlServer<TestDBContext>(
  12.         connectionString: constrbd.ToString(),
  13.         optionsAction: opt =>
  14.         {
  15.             opt.LogTo(logmsg => Console.WriteLine(logmsg), LogLevel.Information);
  16.         });
复制代码
其他代码不变,再次运行。输出的日志如下:
  1. info: 2024/8/4 13:01:06.087 RelationalEventId.CommandExecuted[20101] (Microsoft.EntityFrameworkCore.Database.Command)
  2.       Executed DbCommand (115ms) [Parameters=[], CommandType='Text', CommandTimeout='60']
  3.       CREATE DATABASE [CrazyDB];
  4. info: 2024/8/4 13:01:06.122 RelationalEventId.CommandExecuted[20101] (Microsoft.EntityFrameworkCore.Database.Command)
  5.       Executed DbCommand (31ms) [Parameters=[], CommandType='Text', CommandTimeout='60']
  6.       IF SERVERPROPERTY('EngineEdition') <> 5
  7.       BEGIN
  8.           ALTER DATABASE [CrazyDB] SET READ_COMMITTED_SNAPSHOT ON;
  9.       END;
  10. info: 2024/8/4 13:01:06.137 RelationalEventId.CommandExecuted[20101] (Microsoft.EntityFrameworkCore.Database.Command)
  11.       Executed DbCommand (5ms) [Parameters=[], CommandType='Text', CommandTimeout='30']
  12.       SELECT 1
  13. info: 2024/8/4 13:01:06.181 RelationalEventId.CommandExecuted[20101] (Microsoft.EntityFrameworkCore.Database.Command)
  14.       Executed DbCommand (10ms) [Parameters=[], CommandType='Text', CommandTimeout='30']
  15.       CREATE TABLE [tb_ims] (
  16.           [RecoId] int NOT NULL IDENTITY,
  17.           [MethodDisplay] nvarchar(12) NOT NULL,
  18.           [Description] nvarchar(max) NULL,
  19.           [Culture] nvarchar(max) NULL,
  20.           CONSTRAINT [PK_tb_ims] PRIMARY KEY ([RecoId])
  21.       );
  22. info: 2024/8/4 13:01:06.317 RelationalEventId.CommandExecuted[20101] (Microsoft.EntityFrameworkCore.Database.Command)
  23.       Executed DbCommand (30ms) [Parameters=[@p0='?' (Size = 4000), @p1='?' (Size = 4000), @p2='?' (Size = 12), @p3='?' (Size = 4000), @p4='?' (Size = 4000), @p5='?' (Size = 12)], CommandType='Text', CommandTimeout='30']
  24.       SET IMPLICIT_TRANSACTIONS OFF;
  25.       SET NOCOUNT ON;
  26.       MERGE [tb_ims] USING (
  27.       VALUES (@p0, @p1, @p2, 0),
  28.       (@p3, @p4, @p5, 1)) AS i ([Culture], [Description], [MethodDisplay], _Position) ON 1=0
  29.       WHEN NOT MATCHED THEN
  30.       INSERT ([Culture], [Description], [MethodDisplay])
  31.       VALUES (i.[Culture], i.[Description], i.[MethodDisplay])
  32.       OUTPUT INSERTED.[RecoId], i._Position;
  33. 更新记录数:2
  34. info: 2024/8/4 13:01:06.438 RelationalEventId.CommandExecuted[20101] (Microsoft.EntityFrameworkCore.Database.Command)
  35.       Executed DbCommand (2ms) [Parameters=[], CommandType='Text', CommandTimeout='30']
  36.       SELECT [t].[RecoId], [t].[Culture], [t].[Description], [t].[MethodDisplay]
  37.       FROM [tb_ims] AS [t]
  38. ID=1, Display=双拼输入, Culture=zh-CN
  39. ID=2, Display=六指输入, Culture=zh-CN
复制代码
A、使用 Sqlite 数据库时,生成的 CREATE TABLE 语句,主键列是 PRIMARY KEY AUTOINCREMENT;
B、使用 SQL Server 时,主键列使用的是 IDENTITY,默认以 1 为种子,增量是 1。所以插入记录的键值是1和2。
 
有时候我们并不希望主键列自动生成值,同样有两种配置方法:
1、通过特性类来批注。如
  1. public class InputMethod
  2. {
  3.     [Key, DatabaseGenerated(DatabaseGeneratedOption.None)]
  4.     public ushort RecoId { get; set; }
  5.     public string? MethodDisplay { get; set; }
  6.     public string? Description { get; set; }
  7.     public string? Culture { get; set; }
  8. }
复制代码
将 DatabaseGeneratedOption 设置为 None,就取消列的自动生成了。
2、通过模型配置,即重写 OnModelCreating 方法实现。
  1. protected override void OnModelCreating(ModelBuilder modelBuilder)
  2. {
  3.     modelBuilder.Entity<InputMethod>().HasKey(e => e.RecoId);
  4.     modelBuilder.Entity<InputMethod>()
  5.         .Property(k => k.RecoId)
  6.         .ValueGeneratedNever();
  7. }
复制代码
这种情况下,插入数据时主键列就需要咱们手动赋值了。
======================================================================================
上面的是热身运动,是比较简单的应用方案。下面老周给大伙伴解决一个问题。老周看到在 GitHub 等平台上有人提问,但没有得到解决。如果你看到老周这篇水文并且你有此困惑,那你运气不错。好,F话不多说,咱们看问题。
需求:主键不变,但是我不想让它带有 IDENTITY,插入记录时用我自定义的方式生成主键的值。这个需要的本质就是:我不要数据库给我生成递增ID,我要在程序里生成。
前面老周提过,默认行为下主键列如果是整数类型或 GUID,就会产生自增长的列。所以,咱们有一个很关键的步骤——就是怎么禁止 EF 去产生 IDENTITY 列。如果你看到 EF Core SQL Server 的源代码,可能你会知道有个约定类叫 SqlServerValueGenerationStrategyConvention。这个约定类默认会设置主键列的自动生成策略为 IdentityColumn。
  1. public virtual void ProcessModelInitialized(
  2.      IConventionModelBuilder modelBuilder,
  3.      IConventionContext<IConventionModelBuilder> context)
  4.      => modelBuilder.HasValueGenerationStrategy(SqlServerValueGenerationStrategy.IdentityColumn);
复制代码
于是,有大伙伴可能会想到,那我从 SqlServerValueGenerationStrategyConvention 派生出一个类,重写 ProcessModelInitialized 方法,把自动生成策略改为 None,然后在约定集合中替换掉 SqlServerValueGenerationStrategyConvention。
这个思路不是不行,就是工作量大一些。你不仅要定义个新类,还要把它注册到服务容器中替换 SqlServerValueGenerationStrategyConvention 。毕竟 EF Core 框架内部也是使用了服务容器和依赖注入的方式来组织各种组件的。具体做法是在初始化 DbContext 类(包括你派生的类)时会传递一个 DbContextOptions 对象,它有一个 ReplaceService 方法,可以替换容器中的服务。在调用 AddSqlServer 方法时就可以配置。
  1. public static IServiceCollection AddSqlServer<TContext>(
  2.      this IServiceCollection serviceCollection,
  3.      string? connectionString,
  4.      Action<SqlServerDbContextOptionsBuilder>? sqlServerOptionsAction = null,
  5.      Action<DbContextOptionsBuilder>? optionsAction = null)
  6.      where TContext : DbContext
复制代码
上述方案太麻烦,故老周未采用。其实,就算服务初始化时设置了生成策略是 Identity,可我们可以在构建模型时修改它呀。做法就是重写 DbContext 类的 OnModelCreating 方法,然后通过 IConventionModelBuilder.HasValueGenerationStrategy 方法就能修改生成策略。当然,这里头是有点波折的,我们不能在 ModelBuilder 实例上调用,因为这货并不是直接实现 IConventionModelBuilder 接口的,它是这么搞的:
  1. public class ModelBuilder : IInfrastructure<IConventionModelBuilder>
复制代码
IInfrastructure 接口的作用是把 T 隐藏,不希望程序代码访问类型T。DbContext 类也实现这个接口,但它隐藏的是 IServiceProvider 对象,不想让咱们访问里面注册的服务。也就是说,IConventionModelBuilder 的实现者被隐藏了。不过,EF Core 并没有把事情做得太绝,好歹给了一个扩展方法 GetInfrastructure。用这个扩展方法我们能得到 IConventionModelBuilder 类型的引用。
弄清楚这个原理,代码就好写了。
  1. protected override void OnModelCreating(ModelBuilder modelBuilder)
  2. {
  3.     IConventionModelBuilder cvbd = modelBuilder.GetInfrastructure();
  4.     if (cvbd.CanSetValueGenerationStrategy(Microsoft.EntityFrameworkCore.Metadata.SqlServerValueGenerationStrategy.None))
  5.     {
  6.         cvbd.HasValueGenerationStrategy(Microsoft.EntityFrameworkCore.Metadata.SqlServerValueGenerationStrategy.None);
  7.     }
  8.     ……
  9. }
复制代码
把生成策略改为 None 后,生成主键列时就不会有 IDENTITY 了。
如果你乐意,可以在插入记录时手动给主键列赋值也行的。不过,为了能自动生成值,我们应该写一个自己的生成类。
  1. public class MyValueGenerator : ValueGenerator<int>
  2. {
  3.     // 返回false表示这个生成的值不是临时,它最终要存入数据库的
  4.     public override bool GeneratesTemporaryValues => false;
  5.     private static readonly Random rand = new((int)DateTime.Now.Ticks);
  6.     public override int Next(EntityEntry entry)
  7.     {
  8.         // 获取所有实体
  9.         DbSet<InputMethod> ents = entry.Context.Set<InputMethod>();
  10.         int newID = default;
  11.         do
  12.         {
  13.             // 生成随机ID
  14.             newID = rand.Next();
  15.         }
  16.         // 保证不重复
  17.         while (ents.Any(x => x.RecoId == newID));
  18.         // 返回新值
  19.         return newID;
  20.     }
  21. }
复制代码
我这里的逻辑是这样的,值是随机生成的,但要用一个循环去检查这个值是不是已存在数据库中,如果存在,继续生成,直到数值不重复。
实现自定义生成器,有两个抽象类可供选择:
1、如果你生成的值,类型不确定(可能是int,可能是 long,可能是……),那就实现 ValueGenerator 类;
2、如果要生成的值是明确类型的,比如这里是 int,那就实现带泛型参数的 ValueGenerator 类。
这两个类有继承关系,ValueGenerator 派生自 ValueGenerator 类。需要实现的抽象成员:
A、GeneratesTemporaryValues 属性:只读,返回 bool 值。如果你生成的值是临时的,返回 true,不是临时的,返回 false。啥意思呢。临时的值表示暂时赋值给属性/字段,但 INSERT、UPDATE 时,这个值不会存入数据库;如果不是临时的值,最终会存进数据库。上面例子中,老周让它返回 false,就说明生成的这个值,要写入数据库的。
B、如果继承 ValueGenerator 类,请实现 NextValue 抽象方法,返回类型是 object,就是生成的值;如果继承的是 ValueGenerator,请实现 Next 方法,此方法返回的类型由泛型参数决定。上面例子中是 int。
写好生成类后,要把它应用到实体模型中,同样是重写 DbContext 类的 OnModelCreating 方法。
  1. protected override void OnModelCreating(ModelBuilder modelBuilder)
  2. {
  3.     IConventionModelBuilder cvbd = modelBuilder.GetInfrastructure();
  4.     if (cvbd.CanSetValueGenerationStrategy(Microsoft.EntityFrameworkCore.Metadata.SqlServerValueGenerationStrategy.None))
  5.     {
  6.         cvbd.HasValueGenerationStrategy(Microsoft.EntityFrameworkCore.Metadata.SqlServerValueGenerationStrategy.None);
  7.     }
  8.     modelBuilder.Entity<InputMethod>().HasKey(e => e.RecoId);
  9.     modelBuilder.Entity<InputMethod>()
  10.         .Property(k => k.RecoId)
  11.         .HasValueGenerator<MyValueGenerator>()
  12.         .ValueGeneratedOnAdd();
  13.     modelBuilder.Entity<InputMethod>().ToTable("tb_ims")
  14.         .Property(x => x.MethodDisplay)
  15.         .IsRequired()
  16.         .HasMaxLength(12);
  17. }
复制代码
ValueGeneratedOnAdd 方法表示在记录插入数据库时自动生成值,HasValueGenerator 方法设置你自定义的生成器。
现在,有了自定义生成规则,在插入数据时,主键不能赋值。一旦赋值,生成器就无效了。
  1. // 尝试插入两条记录
  2. InputMethod[] ents = [
  3.         new(){ MethodDisplay = "双拼输入", Description="按两个键完成一个音节",Culture="zh-CN"},
  4.         new() { MethodDisplay = "六指输入", Description="专供六个指头的人使用",Culture="zh-CN"}
  5.     ];
  6. dbc.Set<InputMethod>().AddRange(ents);
  7. int result = dbc.SaveChanges();
复制代码
运行应用程序,你会发现,这次生成的 CREATE TABLE 语句中,RecoId 列已经没有 IDENTITY 关键字了。
  1. info: 2024/8/4 18:41:24.956 RelationalEventId.CommandExecuted[20101] (Microsoft.EntityFrameworkCore.Database.Command)
  2.       Executed DbCommand (12ms) [Parameters=[], CommandType='Text', CommandTimeout='30']
  3.       SELECT 1
  4. info: 2024/8/4 18:41:24.982 RelationalEventId.CommandExecuted[20101] (Microsoft.EntityFrameworkCore.Database.Command)
  5.       Executed DbCommand (4ms) [Parameters=[], CommandType='Text', CommandTimeout='60']
  6.       IF SERVERPROPERTY('EngineEdition') <> 5
  7.       BEGIN
  8.           ALTER DATABASE [CrazyDB] SET SINGLE_USER WITH ROLLBACK IMMEDIATE;
  9.       END;
  10. info: 2024/8/4 18:41:25.003 RelationalEventId.CommandExecuted[20101] (Microsoft.EntityFrameworkCore.Database.Command)
  11.       Executed DbCommand (21ms) [Parameters=[], CommandType='Text', CommandTimeout='60']
  12.       DROP DATABASE [CrazyDB];
  13. info: 2024/8/4 18:41:25.104 RelationalEventId.CommandExecuted[20101] (Microsoft.EntityFrameworkCore.Database.Command)
  14.       Executed DbCommand (82ms) [Parameters=[], CommandType='Text', CommandTimeout='60']
  15.       CREATE DATABASE [CrazyDB];
  16. info: 2024/8/4 18:41:25.137 RelationalEventId.CommandExecuted[20101] (Microsoft.EntityFrameworkCore.Database.Command)
  17.       Executed DbCommand (32ms) [Parameters=[], CommandType='Text', CommandTimeout='60']
  18.       IF SERVERPROPERTY('EngineEdition') <> 5
  19.       BEGIN
  20.           ALTER DATABASE [CrazyDB] SET READ_COMMITTED_SNAPSHOT ON;
  21.       END;
  22. info: 2024/8/4 18:41:25.142 RelationalEventId.CommandExecuted[20101] (Microsoft.EntityFrameworkCore.Database.Command)
  23.       Executed DbCommand (0ms) [Parameters=[], CommandType='Text', CommandTimeout='30']
  24.       SELECT 1
  25. info: 2024/8/4 18:41:25.194 RelationalEventId.CommandExecuted[20101] (Microsoft.EntityFrameworkCore.Database.Command)
  26.       Executed DbCommand (6ms) [Parameters=[], CommandType='Text', CommandTimeout='30']
  27.       <em><strong>CREATE TABLE [tb_ims] (
  28.           [RecoId] </strong></em><em><strong>int NOT NULL,
  29.           [MethodDisplay] nvarchar(12</strong></em><em><strong>) NOT NULL,
  30.           [Description] nvarchar(max) NULL,
  31.           [Culture] nvarchar(max) NULL,
  32.           CONSTRAINT [PK_tb_ims] PRIMARY KEY ([RecoId])
  33.       );</strong></em>
  34. info: 2024/8/4 18:41:25.408 RelationalEventId.CommandExecuted[20101] (Microsoft.EntityFrameworkCore.Database.Command)
  35.       Executed DbCommand (24ms) [Parameters=[@__newID_0='?' (DbType = Int32)], CommandType='Text', CommandTimeout='30']
  36.       SELECT CASE
  37.           WHEN EXISTS (
  38.               SELECT 1
  39.               FROM [tb_ims] AS [t]
  40.               WHERE [t].[RecoId] = @__newID_0) THEN CAST(1 AS bit)
  41.           ELSE CAST(0 AS bit)
  42.       END
  43. info: 2024/8/4 18:41:25.448 RelationalEventId.CommandExecuted[20101] (Microsoft.EntityFrameworkCore.Database.Command)
  44.       Executed DbCommand (1ms) [Parameters=[@__newID_0='?' (DbType = Int32)], CommandType='Text', CommandTimeout='30']
  45.       SELECT CASE
  46.           WHEN EXISTS (
  47.               SELECT 1
  48.               FROM [tb_ims] AS [t]
  49.               WHERE [t].[RecoId] = @__newID_0) THEN CAST(1 AS bit)
  50.           ELSE CAST(0 AS bit)
  51.       END
  52. info: 2024/8/4 18:41:25.488 RelationalEventId.CommandExecuted[20101] (Microsoft.EntityFrameworkCore.Database.Command)
  53.       Executed DbCommand (2ms) [Parameters=[@p0='?' (DbType = Int32), @p1='?' (Size = 4000), @p2='?' (Size = 4000), @p3='?' (Size = 12), @p4='?' (DbType = Int32), @p5='?' (Size = 4000), @p6='?' (Size = 4000), @p7='?' (Size = 12)], CommandType='Text', CommandTimeout='30']
  54.       SET IMPLICIT_TRANSACTIONS OFF;
  55.       SET NOCOUNT ON;
  56.       INSERT INTO [tb_ims] ([RecoId], [Culture], [Description], [MethodDisplay])
  57.       VALUES (@p0, @p1, @p2, @p3),
  58.       (@p4, @p5, @p6, @p7);
  59. 更新记录数:2
  60. info: 2024/8/4 18:41:25.524 RelationalEventId.CommandExecuted[20101] (Microsoft.EntityFrameworkCore.Database.Command)
  61.       Executed DbCommand (1ms) [Parameters=[], CommandType='Text', CommandTimeout='30']
  62.       SELECT [t].[RecoId], [t].[Culture], [t].[Description], [t].[MethodDisplay]
  63.       FROM [tb_ims] AS [t]
  64. ID=427211935, Display=六指输入, Culture=zh-CN
  65. ID=1993200136, Display=双拼输入, Culture=zh-CN
复制代码
怎么样,这玩法是不是很高端?当然,如果主键是字符串类型,你也可以生成字符串的值,一切看你需求,反正原理是相同的。
最后,咱们顺便聊聊如何自动更改日期时间的问题。这个在实际开发中也很常用,比如一个计划表,其实体如下:
  1. public class Plan
  2. {
  3.     /// <summary>
  4.     /// 计划ID
  5.     /// </summary>
  6.     public int ID { get; set; }
  7.     /// <summary>
  8.     /// 计划简述
  9.     /// </summary>
  10.     public string? PlanDesc { get; set; }
  11.     /// <summary>
  12.     /// 计划级别
  13.     /// </summary>
  14.     public int Level { get; set; }
  15.     /// <summary>
  16.     /// 计划创建时间
  17.     /// </summary>
  18.     public DateTime? CreateTime { get; set; }
  19.     /// <summary>
  20.     /// 总计划量
  21.     /// </summary>
  22.     public float TotalTask { get; set; }
  23.     /// <summary>
  24.     /// 完成量
  25.     /// </summary>
  26.     public float Completed { get; set; }
  27.     /// <summary>
  28.     /// 更新时间
  29.     /// </summary>
  30.     public DateTime? UpdateTime { get; set; }
  31. }
复制代码
最后一个字段 UpdateTime 表示在插入后更新的时间,所以在插入时这个字段可以留 NULL。比如我修改计划完成数 Completed,在写入数据库时自动给 UpdateTime 字段赋当前时间。这个不能用值生成器来做,因为生成器只能在数据插入前或插入后产生一次值,后面更新数据时不会再生成新值,就做不到自动设置更新时间了。所以,这里咱们可以换个思路:重写 DbContext 类的 SaveChanges 方法,在命令发送到数据库之前找出哪些记录被修改过,然后设置 UpdateTime 属性,最后才发送 SQL 语句。这样也能达到自动记录更新时间的功能。
  1. public class MyDBContext : DbContext
  2. {
  3.     ……
  4.     public override int SaveChanges(bool acceptAllChangesOnSuccess)
  5.     {
  6.         var modifieds = from c in ChangeTracker.Entries()
  7.                         where c.State == EntityState.Modified
  8.                               && c.Entity is Plan
  9.                         select c;
  10.         foreach(var obj in modifieds)
  11.         {
  12.             obj.Property(nameof(Plan.UpdateTime)).CurrentValue = DateTime.Now;
  13.         }
  14.         return base.SaveChanges(acceptAllChangesOnSuccess);
  15.     }
  16. }
复制代码
Modified 表示实体被更改过的状态。修改属性值时,应赋值给 CurrentValue,它代表的是实体当前的值,不要改 OriginalValue 的值,它指的是从数据库中读到的值,多数情况下不用去改,除非你要把当前 DbContext 实例的数据复制到另一个 DbContext 实例。
这样当 Plan 对象被修改后,在提交前会自动设置更新时间。下面是测试代码:
  1. // 创建上下文
  2. using var ctx  = new MyDBContext();
  3. // 测试用,确定删除数据库
  4. ctx.Database.EnsureDeleted();
  5. // 确定创建数据库
  6. ctx.Database.EnsureCreated();
  7. // 创建三条记录
  8. Plan p01 = new()
  9. {
  10.      PlanDesc = "装配电池",
  11.      CreateTime = DateTime.Now,
  12.      TotalTask = 100f,
  13.      Completed = 0f,
  14. };
  15. Plan p02 = new Plan()
  16. {
  17.      PlanDesc = "更换底板",
  18.      CreateTime = DateTime.Now,
  19.      Level = 4,
  20.      TotalTask = 12.0f,
  21.      Completed = 0f
  22. };
  23. Plan p03 = new()
  24. {
  25.      PlanDesc = "清洗盖板",
  26.      TotalTask = 20.5f,
  27.      Completed = 0f,
  28.      CreateTime = DateTime.Now
  29. };
  30. ctx.Plans.Add(p01);
  31. ctx.Plans.Add(p02);
  32. ctx.Plans.Add(p03);
  33. // 更新到数据库
  34. int n = ctx.SaveChanges();
  35. Console.WriteLine($"已插入{n}条记录");
  36. // 打印数据
  37. Print(ctx.Plans);
  38. MODIFY:     // 这是个标签
  39. Console.Write("请输入要更新的记录ID:");
  40. string? line = Console.ReadLine();
  41. if(line == null)
  42. {
  43.      Console.WriteLine("你输入了吗?");
  44.      goto MODIFY;    // 回到标签处
  45. }
  46. if(!int.TryParse(line, out int id))
  47. {
  48.      Console.WriteLine("你丫的输入的是整数吗?");
  49.      goto MODIFY;    // 回到标签处
  50. }
  51. UPDATE:     // 标签
  52. Console.Write("请输入计划完成数:");
  53. line = Console.ReadLine();
  54. if (line == null)
  55. {
  56.      Console.WriteLine("你确定你没敲错键盘?");
  57.      goto UPDATE;
  58. }
  59. if(!float.TryParse(line, out float comp))
  60. {
  61.      Console.WriteLine("浮点数,浮点数,浮点数");
  62.      goto UPDATE;
  63. }
  64. // 查找
  65. Plan? curPlan = ctx.Plans.FirstOrDefault(x => x.ID == id);
  66. if (curPlan == null)
  67. {
  68.      Console.WriteLine("找不到记录");
  69.      goto MODIFY;
  70. }
  71. if(comp > curPlan.TotalTask)
  72. {
  73.      Console.WriteLine("你是在异空间工作吗?");
  74.      goto UPDATE;
  75. }
  76. // 更新
  77. curPlan.Completed = comp;
  78. ctx.SaveChanges();
  79. // 再次打印
  80. Print(ctx.Plans);
复制代码
先插入三条数据,然后输入记录ID来修改 Completed 的值。更改后会看到更新时间。

 好了,今天咱们就水到这里了。
 

来源:https://www.cnblogs.com/tcjiaan/p/18340772
免责声明:由于采集信息均来自互联网,如果侵犯了您的权益,请联系我们【E-Mail:cb@itdo.tech】 我们会及时删除侵权内容,谢谢合作!

本帖子中包含更多资源

您需要 登录 才可以下载或查看,没有账号?立即注册

x

举报 回复 使用道具