Dapper MultiQuery仅返回首个匹配项问题排查求助

问题描述 #

你编写SQL查询获取单个文档及其关联的标签和协作者，使用Dapper映射时，返回的DocumentDto仅包含第一个匹配的标签或协作者。调试发现每行数据都会触发map函数，但每次的doc对象都是全新的，之前添加的标签/协作者未被保留。

根本原因 #

你的SQL查询通过LEFT JOIN同时关联标签和协作者表，返回的是笛卡尔积结果（每个标签与每个协作者组合成一行）。Dapper的多映射默认不会自动合并相同的父实体（DocumentDto），而是为每一行创建新的父实体实例，因此每次map函数拿到的都是全新的DocumentDto，无法累积标签和协作者。此外，当前的splitOn参数仅指定了实体分割点，没有提供复用父实体的机制。

解决方案 #

方案一：用字典跟踪复用DocumentDto实例 #

在map函数外部维护字典，通过文档ID记录已创建的DocumentDto实例，确保同一文档的所有行复用同一个实例来添加标签和协作者：

var docDict = new Dictionary<Guid, DocumentDto>();

var documents = await connection.QueryAsync<DocumentDto, LabelDto, CollaboratorDto, DocumentDto>(
    GetDocumentSql,
    (doc, label, collaborator) => {
        // 尝试获取已存在的文档实例
        if (!docDict.TryGetValue(doc.Id, out var existingDoc))
        {
            existingDoc = doc;
            docDict[doc.Id] = existingDoc;
        }

        // 添加标签（避免重复）
        if (label.LabelId != Guid.Empty && !existingDoc.Labels.Any(l => l.LabelId == label.LabelId))
        {
            existingDoc.Labels.Add(label);
        }

        // 添加协作者（避免重复）
        if (collaborator.ProfileId != Guid.Empty && !existingDoc.Collaborators.Any(c => c.ProfileId == collaborator.ProfileId))
        {
            existingDoc.Collaborators.Add(collaborator);
        }

        return existingDoc;
    },
    new { Id = documentId.ToString() },
    splitOn: "LabelId,DocumentId");

// 取字典中的唯一文档实例
var result = docDict.Values.FirstOrDefault();

方案二：拆分查询避免笛卡尔积 #

将查询拆分为三个独立SQL，分别获取文档基础信息、关联标签、关联协作者，再手动组合数据。这种方式更高效，避免不必要的重复数据传输：

1. 拆分后的SQL语句

-- 获取文档基本信息
SELECT doc.Id, doc.Type, doc.Name, doc.Description, doc.File, doc.CreatedAt, doc.UpdatedAt
FROM Documents as doc
WHERE doc.Id = @Id

-- 获取关联标签
SELECT dl.LabelId, l.Name, l.Description, l.CreatedAt, l.UpdatedAt
FROM DocumentLabels as dl
JOIN Labels as l ON dl.LabelId = l.Id
WHERE dl.DocumentId = @Id

-- 获取关联协作者
SELECT dc.ProfileId, dc.Role
FROM DocumentCollaborators as dc
WHERE dc.DocumentId = @Id

2. 使用Dapper的QueryMultiple执行

using var multi = await connection.QueryMultipleAsync(@"
    SELECT doc.Id, doc.Type, doc.Name, doc.Description, doc.File, doc.CreatedAt, doc.UpdatedAt
    FROM Documents as doc
    WHERE doc.Id = @Id;

    SELECT dl.LabelId, l.Name, l.Description, l.CreatedAt, l.UpdatedAt
    FROM DocumentLabels as dl
    JOIN Labels as l ON dl.LabelId = l.Id
    WHERE dl.DocumentId = @Id;

    SELECT dc.ProfileId, dc.Role
    FROM DocumentCollaborators as dc
    WHERE dc.DocumentId = @Id;",
    new { Id = documentId.ToString() });

var doc = await multi.ReadSingleOrDefaultAsync<DocumentDto>();
if (doc != null)
{
    doc.Labels = (await multi.ReadAsync<LabelDto>()).ToList();
    doc.Collaborators = (await multi.ReadAsync<CollaboratorDto>()).ToList();
}

关键注意事项 #

• 方案一基于现有查询修复，但笛卡尔积会返回大量重复数据，性能不如方案二。
• 方案二更符合数据库查询最佳实践，减少数据传输量，逻辑更清晰。
• 无论哪种方案，都要避免重复添加标签/协作者（如方案一中的Any判断），因为笛卡尔积会导致同一标签/协作者多次出现在不同行中。

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