敢为公共库

敢为公共库数据库组件介绍

配置模型

模型必须通过IoTEntity特性标识

[IoTEntity]
public class Test
{
     [Key]
     public int Id { get; set; }
     public string UserId { get; set; }
     public string Name { get; set; }
}

EF Core提供注解和Fluent APi配置映射，比如上述用注解[Key]来标识主键，大部分情况下都可以使用注解来完成映射，但在有些情况下，EF Core不支持通过注解映射，比如联合主键，此时通过Fluent APi即实现IEntityTypeConfiguration（EF Core内置APi）接口来配置映射

比如，如下映射配置Id和UserId作为联合主键

public class TestEntityTypeConfiguration : IEntityTypeConfiguration<Test>
{
     public void Configure(EntityTypeBuilder<Test> builder)
     {
          builder.HasKey(k => new { k.Id, k.UserId });
     }
}

注：若同一列既通过注解也通过Fluent APi配置了映射，虽不会报错，但Fluent APi会覆盖注解映射配置

动态表映射配置

注：仅支持按天生成，例如：zzcurvedata20210315 {#注仅支持按天生成例如zzcurvedata20210315 .list-paragraph}

注：非动态表，禁止表名以动态表生成标识"IDENTITIES"命名

[IoTEntity]

public class CurveDataTableRow
{
     [Key]
     [Required]
     [Display(Name = "key")]
     public Int64 key { get; set; }
     [Display(Name = "历史数据")]
     public byte[] curvedata { get; set; }
     [Display(Name = "保留字段1")]
     public string Reserve1 { get; set; }
     [Display(Name = "保留字段2")]
     public string Reserve2 { get; set; }
     [Display(Name = "保留字段3")]
     public string Reserve3 { get; set; }
}
public class TestEntityTypeConfiguration : IEntityTypeConfiguration<Test>
{
     public void Configure(EntityTypeBuilder<Test> builder)
     {
          //注：CustomTable.Identifies作为动态表标识
          //注：zzcurvedata作为表前缀
          builder.ToTable($"{CustomTable.Identifies}zzcurvedata");
          builder.HasKey(k => new { k.Id, k.UserId });
     }
}

构建容器

var serviceProvider = IoTEfCore.Initial(Assembly assembly);

方法参数为模型所在程序集，将扫描该程序集所有IoTEntity特性标识并注册模型。第一次调用该方法后，会将程序集和方法返回的容器进行缓存，所以无需调用多次。注：从该方法参数可知，所有模型必须从属于同一程序集。一个程序集对应一个容器，所以将返回容器应定义为程序集内全局变量。

实例化上下文

从上述所构建的全局容器中创建作用域并初始化上下文。注：一定要加上using，保证出此作用域后，上下文能立马得到释放

using (var scope = serviceProvider.CreateScope())
{
     var context = scope.ServiceProvider.GetService<IoTDbContext>();
}

上下文操作

在上述作用域内，从容器中获取到的上下文，通过context.Set<T>()获取模型DbSet属性，T为用IoTEntity特性所标识的模型

SQL语句操作（上下文扩展方法中）

Execute/ExecuteAsync：增、删、修改

例如：context.Execute("insert into test(id) values(1)");

ExecuteScalar/ExecuteScalarAsync：查询单个值

例如：context.ExecuteScalar("select max(id) from test");

Query/QueryAsync：查询集合

例如：context.Query("select * from test");

QueryFirstOrDefault/QueryFirstOrDefaultAsync：查询单行记录

例如：context.QueryFirstOrDefault("select * from test where id = 1");