如何在ASP.NET Core中配置双跨服务器数据库并实现数据插入迁移？

1. 添加第二个数据库连接配置 #

修改appsettings.json，在ConnectionStrings节点下新增Database2的连接信息：

{
  "ConnectionStrings": {
    "DefaultConnection": "Server=TestServer;TrustServerCertificate=True;Initial Catalog=Database1;uid=test;pwd=test",
    "SecondConnection": "Server=YourDatabase2Server;TrustServerCertificate=True;Initial Catalog=Database2;uid=db2user;pwd=db2pwd"
  }
}

2. 为Database2创建DbContext类 #

如果还没有对应Database2的DbContext，新建一个类来映射Database2的表结构：

using Microsoft.EntityFrameworkCore;

namespace YourProjectNamespace
{
    public class Database2Context : DbContext
    {
        public Database2Context(DbContextOptions<Database2Context> options) : base(options)
        {
        }

        // 映射Database2中的tableB
        public DbSet<TableB> TableB { get; set; }

        protected override void OnModelCreating(ModelBuilder modelBuilder)
        {
            // 根据实际表结构配置实体映射，比如指定表名、主键等
            modelBuilder.Entity<TableB>().ToTable("tableB");
        }
    }

    // 定义tableB对应的实体类，字段与数据库表保持一致
    public class TableB
    {
        public int Id { get; set; }
        public string DataField1 { get; set; }
        public string DataField2 { get; set; }
        // 其他字段...
    }
}

3. 在Startup.cs中注册第二个DbContext #

更新ConfigureServices方法，同时注册两个数据库的DbContext：

public void ConfigureServices(IServiceCollection services)
{
    // 注册Database1的DbContext
    services.AddDbContext<AckPackage.Data.AckContext>(options =>
        options.UseSqlServer(Configuration.GetConnectionString("DefaultConnection")));

    // 注册Database2的DbContext
    services.AddDbContext<Database2Context>(options =>
        options.UseSqlServer(Configuration.GetConnectionString("SecondConnection")));

    // 其他原有服务注册...
}

4. 在控制器中注入双DbContext并实现数据迁移 #

修改控制器构造函数，注入两个DbContext，然后编写数据迁移逻辑：

private readonly IEmployeeService _employeeService;
private readonly ILogger _logger;
private readonly IHttpContextAccessor _contextAccessor;
private readonly IWebHostEnvironment _environment;
private readonly AckPackage.Data.AckContext _db1Context;
private readonly Database2Context _db2Context;

public EmployeeController(IEmployeeService employeeService,
    ILogger<EmployeeController> logger,
    IHttpContextAccessor contextAccessor,
    IWebHostEnvironment environment,
    AckPackage.Data.AckContext db1Context,
    Database2Context db2Context)
{
    _employeeService = employeeService;
    _logger = logger;
    _contextAccessor = contextAccessor;
    _environment = environment;
    _db1Context = db1Context;
    _db2Context = db2Context;
}

// 示例接口：执行从tableA到tableB的数据迁移
[HttpPost("migrate-table-data")]
public async Task<IActionResult> MigrateTableData()
{
    try
    {
        // 从Database1的tableA读取数据（假设已存在TableA实体类）
        var tableARecords = await _db1Context.TableA.ToListAsync();

        // 转换为tableB的实体格式
        var tableBRecords = tableARecords.Select(record => new TableB
        {
            Id = record.Id,
            DataField1 = record.SourceField1,
            DataField2 = record.SourceField2
            // 按实际字段映射关系调整
        }).ToList();

        // 批量插入到Database2的tableB
        _db2Context.TableB.AddRange(tableBRecords);
        await _db2Context.SaveChangesAsync();

        return Ok($"完成数据迁移，共插入{tableBRecords.Count}条记录");
    }
    catch (Exception ex)
    {
        _logger.LogError(ex, "跨库数据迁移失败");
        return StatusCode(500, $"迁移出错：{ex.Message}");
    }
}

关键注意事项 #

• 确保TableA和TableB的实体类字段与数据库表结构完全匹配，避免映射错误
• 数据量大时建议分批处理，避免内存溢出
• 可添加事务控制，保证迁移操作的原子性：在迁移逻辑中使用using var transaction = await _db2Context.Database.BeginTransactionAsync();，操作完成后调用await transaction.CommitAsync();

内容的提问来源于stack exchange，提问作者rimi