SqlHelper 使用EF-Core框架 连接池处理并发
定义数据库
数据库名称：T_dicomPatientMsg
注意5大约束条件：
1.主键约束：primary key IDKEY设置为主键，主键设置自增长
2.唯一性约束：unique
3.默认约束：default 所有值都要设置默认值，除了主键
4.检查约束：check
5.外键约束：foreign key
定义实体
public class DicomPatientMsg{[Key]public int IDKEY { get; set; } //设为主键，注意实体名称需要与数据库实体名称一致public string PatientID { get; set; }public string PatientName { get; set; }public DateTime PatientBirthDate { get; set; }public DateTime CheckDate { get; set; }public string PicturePath { get; set; }public string DicomFilePath { get; set; }public string SOPInstanceUID { get; set; }public string StudyID { get; set; }public string StudyInstanceUID { get; set; }public string SeriesInstanceUID { get; set; }public string InstanceNum { get; set; }public bool IsDelete { get; set; } }SQL帮助类
连接池实现并发连接
public class SqlHelper
{private readonly AppDbContext _context;//构造函数注入DB_contextpublic SqlHelper(AppDbContext context){_context = context;}// 增加实体public async Task AddAsync<T>(T entity) where T : class{await _context.Set<T>().AddAsync(entity);await _context.SaveChangesAsync();}// 获取所有实体public async Task<List<T>> GetAllAsync<T>() where T : class{return await _context.Set<T>().ToListAsync();}// 根据ID获取实体public async Task<T> GetByIdAsync<T>(int id) where T : class{return await _context.Set<T>().FindAsync(id);}// 更新实体public async Task UpdateAsync<T>(T entity) where T : class{_context.Set<T>().Update(entity);await _context.SaveChangesAsync();}// 删除实体public async Task DeleteAsync<T>(T entity, bool isDelete = false) where T : class{if (isDelete){_context.Set<T>().Remove(entity);}else{var property = entity.GetType().GetProperty("IsDeleted");if (property != null && property.PropertyType == typeof(bool)){property.SetValue(entity, true);_context.Set<T>().Update(entity);}else{throw new InvalidOperationException("Error");}}await _context.SaveChangesAsync();}
} public async Task AddAsync<T>(T entity) where T : class{await _context.Set<T>().AddAsync(entity);await _context.SaveChangesAsync();}//增加实体
public 表面方法是公开的，所有其他类都可以调用
async 表方法内可能包含异步操作，允许方法在内部使用"await"
await 在异步操作中使用，会暂停当前方法的执行（阻塞当前线程），直到方法执行完成后，才会继续执行下面的代码，暂停期间，控制权会返回给调用方（如UI线程）
Task 当一个 方法的返回类型是Task时，表面这个方法是异步的，但它不返回任何值（即它是'void'的异步版本，同理int的异步版本为Task<int>）。通过Task，调用者可以选择是否等待这个方法完成
AddAsync<T>(T entity) T是泛型类型的参数，它使得这个方法可以处理任意类型的实体对象。T由调用者传入的entity类型所决定。如果不使用泛型，只处理某一实体类型如User，也可以写成AddUserAsync(User entity)
where T : class 约束条件，限制了T必须是一个类
private readonly AppDbContext _context;//构造函数注入DB_contextpublic SqlHelper(AppDbContext context){_context = context;}这里为什么要用构造函数去注入DbContext
DbContext通常代表数据库的会话（增删改查等），每个DbContext实例都代表与数据库的一次交互。
配置AppDbContext
public class AppDbContext : DbContext
{public AppDbContext(DbContextOptions<AppDbContext> options) : base(options){}// 定义数据库表public DbSet<DicomPatientMsg> T_dicomPatientMsg { get;set;}protected override void OnModelCreating(ModelBuilder modelBuilder){modelBuilder.Entity<DicomPatientMsg>().HasQueryFilter(e => !e.IsDelete); //过滤已软删除的记录}}在appsettings.json配置数据库连接字符串
{"Logging": {"LogLevel": {"Default": "Information","Microsoft.AspNetCore": "Warning","Microsoft.Hosting.Lifetime": "Information"}},"ConnectionStrings": {"DefaultConnection": "Server=.\\SQLEXPRESS;Database=Colposcope;User Id=sa;Password=123;TrustServerCertificate=True;"},"AllowedHosts": "*"
}//TrustServerCertificate=true 禁用SSL验证
注册DbContext 服务
// 从配置文件读取字符串
var connectionString = builder.Configuration.GetConnectionString("DefaultConnection");// 添加DbContext服务
builder.Services.AddDbContext<AppDbContext>((options) => options.UseSqlServer(connectionString));//添加SqlHelper，DicomFunc 和控制器类到 DI 容器
builder.Services.AddScoped<SqlHelper>();
builder.Services.AddScoped<DicomFunc>();使用数据库
private readonly static SqlHelper sqlHelper = SqlHelper.Instance;DicomPatientMsg msg = new DicomPatientMsg()
{DicomFilePath = patientMsg.DicomFilePath,PatientID = patientMsg.PatientID,PatientName = patientMsg.PatientName,CheckDate = checkDate,PicturePath = patientMsg.PicturePath,SOPInstanceUID = dataset.GetString(DicomTag.SOPInstanceUID),StudyID = dataset.GetString(DicomTag.StudyID),StudyInstanceUID = dataset.GetString(DicomTag.StudyInstanceUID),SeriesInstanceUID = dataset.GetString(DicomTag.SeriesInstanceUID),InstanceNum = dataset.GetString(DicomTag.InstanceNumber),
};//存储到sql
await sqlHelper.AddAsync(msg);下面理清一下这个数据库的使用流程：
1. 依赖链
DicomController 依赖 DicomFunc，而 DicomFunc 依赖 SqlHelper，SqlHelper 又依赖 AppDbContext。
DicomController依赖DicomFuncDicomFunc依赖SqlHelperSqlHelper依赖AppDbContext
2. 服务注册
AppDbContext的注册：使用AddDbContext<AppDbContext>将数据库上下文注册到 DI 容器中。这允许SqlHelper构造函数接收AppDbContext实例。SqlHelper的注册：我们使用AddScoped<SqlHelper>()注册SqlHelper，让DicomFunc可以注入它。DicomFunc的注册：我们注册DicomFunc，确保DicomController能够接收它。
3. 依赖注入的执行
当一个请求到达DicomController时，ASP.NET Core的依赖注入容器会
-
实例化
控制器依赖于DicomController：DicomFunc，容器会尝试实例化DicomFunc。 -
实例化
DicomFunc：DicomFunc的构造函数依赖于SqlHelper，容器会进一步尝试实例化SqlHelper。 -
实例化
SqlHelper：SqlHelper的构造函数依赖于AppDbContext。AppDbContext是通过AddDbContext方法注册到容器中的，它会被自动提供给SqlHelper。 -
实例化
容器会从依赖注入容器中提取并实例化AppDbContext：AppDbContext，这可能涉及数据库连接的初始化等操作。 -
完成实例化：
- 最终，
AppDbContext实例被注入到SqlHelper中。 SqlHelper实例被注入到DicomFunc中。DicomFunc实例被注入到DicomController中。
- 最终，