feat:开发

sunpengfei

2025-09-02 44c6adb7620d3e7ddec49a59035f094499113a6a

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
using FlexJobApi.Core;
using Furion;
using Furion.DatabaseAccessor;
using Microsoft.EntityFrameworkCore;
using Microsoft.EntityFrameworkCore.Diagnostics;
using Microsoft.EntityFrameworkCore.Metadata.Builders;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Options;
using System;
 
namespace FlexJobApi.EntityFramework.Core;
 
[AppDbContext("FlexJobApi", DbProvider.SqlServer)]
public class DefaultDbContext : AppDbContext<DefaultDbContext>
{
    public DefaultDbContext(DbContextOptions<DefaultDbContext> options) : base(options)
    {
    }
 
    protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
    {
        base.OnConfiguring(optionsBuilder);
        optionsBuilder
            .UseSqlServer(App.Configuration.GetConnectionString("FlexJobApi"), options =>
            {
                // 指定目标数据库版本为SQL Server 2014
                options.UseCompatibilityLevel(120); // 120对应SQL Server 2014
                // 可选：设置批量操作大小（按需调整）
                options.MaxBatchSize(1000);
            });
    }
 
    protected override void OnModelCreating(ModelBuilder modelBuilder)
    {
        base.OnModelCreating(modelBuilder);
        DbUtils.BuildEntity(modelBuilder).Wait();
    }
 
    protected override void SavingChangesEvent(DbContextEventData eventData, InterceptionResult<int> result)
    {
        DbUtils.SavingChangesEvent(eventData, result);
    }
}