使用BulkMerge处理子实体时触发外键约束错误

问题核心原因 #

你遇到的外键冲突，本质是当用ColumnPrimaryKeyExpression指定Stock的业务主键（而非自增ID）执行BulkMerge时，EF Extensions无法自动将新插入Stock生成的自增ID关联到对应的StockPrice子实体上，导致StockPrice的StockId值无效（为空或未匹配到存在的Stock），触发FK_StockPrice_Stock_StockId约束。

分步解决方案 #

1. 批量处理Stock实体，获取业务主键与自增ID的映射 #

先单独对Stock执行BulkMerge，启用OutputIdentity来捕获数据库生成的Stock ID，同时用ColumnPrimaryKeyExpression指定你的业务主键（比如Stock的Code字段）。这样能拿到每个Stock业务主键对应的最新数据库ID。

// 假设你的Stock业务主键是Code字段
var stockBusinessKeys = stocks.Select(s => s.Code).ToList();

// 执行BulkMerge并输出自增ID
context.BulkMerge(stocks, options => {
    options.ColumnPrimaryKeyExpression = s => s.Code; // 指定业务主键
    options.OutputIdentity = true; // 启用输出自增ID
});

// 构建业务主键到自增ID的映射字典
var stockIdMap = stocks.ToDictionary(s => s.Code, s => s.Id);

2. 预处理StockPrice子实体 #

• 替换StockId：遍历所有StockPrice，用上面的映射字典把业务主键对应的StockId替换成数据库生成的有效ID。
• 去重处理：过滤掉与对应Stock最后一条价格重复的记录（可以先批量查询现有Stock的最新价格，再在内存中过滤）。

// 批量获取所有Stock的最新价格（减少数据库查询次数）
var latestStockPrices = context.StockPrices
    .GroupBy(sp => sp.StockId)
    .Select(g => new { StockId = g.Key, LastPrice = g.Max(sp => sp.Price) })
    .ToDictionary(x => x.StockId, x => x.LastPrice);

// 预处理StockPrice：替换StockId + 过滤重复价格
var validStockPrices = stockPrices.Where(sp => {
    // 从映射字典获取正确的StockId
    if (!stockIdMap.TryGetValue(sp.StockCode, out var stockId))
        return false; // 过滤无效的Stock记录
    sp.StockId = stockId;
    
    // 检查是否与最后一条价格重复
    return !latestStockPrices.TryGetValue(stockId, out var lastPrice) || sp.Price != lastPrice;
}).ToList();

3. 批量插入StockPrice #

对预处理后的有效StockPrice执行BulkInsert，避免外键冲突：

context.BulkInsert(validStockPrices);

针对百万级数据的效率优化 #

• 批量查询替代单条查询：不要逐个查询Stock，而是一次性传入所有业务主键，用Contains批量获取现有Stock的ID和最新价格，减少数据库往返次数。
• 内存预处理：价格去重和StockId替换都在内存中完成，避免多次数据库交互。
• 事务包裹：将整个BulkMerge和BulkInsert操作放在同一个事务中，保证数据一致性：

using var transaction = context.Database.BeginTransaction();
try {
    // 执行Stock BulkMerge
    // 预处理StockPrice
    // 执行StockPrice BulkInsert
    
    transaction.Commit();
} catch {
    transaction.Rollback();
    throw;
}

替代方案：使用BulkMerge的IncludeGraph配置（需注意版本支持） #

如果你的EF Extensions版本支持IncludeGraph，可以尝试配置主从实体的关联，但需要确保业务主键的映射正确：

context.BulkMerge(stocks, options => {
    options.ColumnPrimaryKeyExpression = s => s.Code;
    options.IncludeGraph = true;
    options.IncludeGraphOperationBuilder = op => {
        if (op is BulkOperation<StockPrice> priceOp) {
            // 配置StockPrice的关联字段
            priceOp.ColumnPrimaryKeyExpression = sp => new { sp.StockId, sp.Date }; // 假设StockPrice的主键是StockId+Date
        }
    };
});

注意：这种方式需要确保StockPrice的StockId在BulkMerge前能正确关联，否则仍会触发外键冲突，因此更推荐前面的分步处理方案。

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