跨不同Azure数据库执行SQL MERGE操作的实现方案及.NET替代方案咨询

首先给你个最优解：因为你的源表和目标表在同一Azure SQL服务器的不同数据库里，完全可以直接用SQL MERGE语句搞定，根本不用绕到C#代码里处理——这也是性能最好的方式。

一、直接用SQL跨库MERGE（优先选择） #

同服务器下的不同Azure SQL数据库，支持用三部分对象命名格式（数据库名.架构名.表名）直接跨库引用表，所以标准的MERGE语句完全适用，正好满足你自定义匹配列、指定插入/更新列的需求。

给你举个对应你描述的int类型表的示例：
假设：

• 源数据库是SourceDB，源表dbo.SourceTable有列：ID, Value1, Value2
• 目标数据库是TargetDB，目标表dbo.TargetTable有列：ID, TargetValue, ExtraCol

MERGE语句可以这么写：

-- 可以先切换到目标数据库，或者直接用全限定名引用目标表
USE TargetDB;

MERGE INTO dbo.TargetTable AS Target
USING SourceDB.dbo.SourceTable AS Source
    ON Target.ID = Source.ID -- 指定匹配的主键/关联列
WHEN MATCHED THEN
    -- 匹配时更新指定列
    UPDATE SET 
        Target.TargetValue = Source.Value1,
        Target.ExtraCol = Source.Value2
WHEN NOT MATCHED BY TARGET THEN
    -- 目标表无匹配时插入指定列
    INSERT (ID, TargetValue, ExtraCol)
    VALUES (Source.ID, Source.Value1, Source.Value2);

注意点 #

• 确保执行这个语句的数据库账号，同时拥有源表的SELECT权限和目标表的INSERT/UPDATE权限
• Azure SQL同服务器跨库不需要额外配置链接服务器，直接用三部分名称就行，非常方便

二、ADO.NET中DataTable的手动合并方案（当SQL方案不可用时） #

如果因为某些特殊限制（比如权限不足、跨服务器等）没法用跨库MERGE，那可以在C#里加载两个DataTable，手动实现类似MERGE的逻辑。ADO.NET本身没有直接提供和SQL MERGE完全等价的API，但可以通过LINQ或者DataTable的自带方法来实现：

方案1：用LINQ关联处理（代码更简洁） #

适合数据量中等的场景，代码可读性高：

// 假设你已经通过SqlDataAdapter加载了源DataTable（sourceDt）和目标DataTable（targetDt）

// 第一步：处理匹配的行，更新目标表数据
var matchedPairs = from sourceRow in sourceDt.AsEnumerable()
                   join targetRow in targetDt.AsEnumerable()
                   on sourceRow.Field<int>("ID") equals targetRow.Field<int>("ID")
                   select new { Source = sourceRow, Target = targetRow };

foreach (var pair in matchedPairs)
{
    pair.Target["TargetValue"] = pair.Source["Value1"];
    pair.Target["ExtraCol"] = pair.Source["Value2"];
}

// 第二步：处理源表有、目标表没有的行，插入到目标表
var existingTargetIds = targetDt.AsEnumerable()
                                .Select(row => row.Field<int>("ID"))
                                .ToHashSet(); // 用HashSet提高查询效率

var newRowsToInsert = sourceDt.AsEnumerable()
                              .Where(row => !existingTargetIds.Contains(row.Field<int>("ID")));

foreach (var newRow in newRowsToInsert)
{
    DataRow insertRow = targetDt.NewRow();
    insertRow["ID"] = newRow["ID"];
    insertRow["TargetValue"] = newRow["Value1"];
    insertRow["ExtraCol"] = newRow["Value2"];
    targetDt.Rows.Add(insertRow);
}

// 最后用SqlDataAdapter把更新后的targetDt写回目标数据库
// adapter.Update(targetDt);

方案2：用DataTable.Find方法（适合目标表有主键的情况） #

如果你的目标DataTable已经设置了主键（比如把ID列设为主键），可以用Find方法快速定位匹配行，代码更直观：

// 先给目标表设置主键，方便快速查找
targetDt.PrimaryKey = new DataColumn[] { targetDt.Columns["ID"] };

foreach (DataRow sourceRow in sourceDt.Rows)
{
    int id = (int)sourceRow["ID"];
    DataRow targetRow = targetDt.Rows.Find(id);
    
    if (targetRow != null)
    {
        // 找到匹配行，更新数据
        targetRow["TargetValue"] = sourceRow["Value1"];
        targetRow["ExtraCol"] = sourceRow["Value2"];
    }
    else
    {
        // 无匹配行，插入新数据
        DataRow newRow = targetDt.NewRow();
        newRow["ID"] = id;
        newRow["TargetValue"] = sourceRow["Value1"];
        newRow["ExtraCol"] = sourceRow["Value2"];
        targetDt.Rows.Add(newRow);
    }
}

// 写回数据库
// adapter.Update(targetDt);

性能提醒 #

• 这种C#端处理的方式，性能肯定不如数据库端的MERGE高效——毕竟要把所有数据加载到内存，还要走网络传输。所以如果数据量较大（比如几万行以上），尽量想办法用SQL跨库方案。
• 如果必须用C#处理，可以考虑分批加载数据，减少内存占用。

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