dapper 中的多对多多重映射

Question

这是我的数据库

Product
+----+----------+
| Id |   Name   |
+----+----------+
|  1 | Product1 |
|  2 | Product2 |
|  3 | Product3 |
+----+----------+

Category
+----+-----------+
| Id |   Name    |
+----+-----------+
|  1 | Category1 |
|  2 | Category2 |
|  3 | Category3 |
+----+-----------+

ProductCategory
+----+------------+------------+
| Id | ProductId  | CategoryId |
+----+------------+------------+
|  1 |          1 |          1 |
|  2 |          1 |          1 |
|  3 |          2 |          2 |
+----+------------+------------+

现在，我想获取所有产品及其类别。在我的存储库中，我添加了以下代码：

public async Task<IEnumerable<Product>> GetAllProducts()
{
    var products = await _dbConnection.QueryAsync<Product, Category, Product>(
        @"
            SELECT p.Id, p.Name, c.Id, c.Name
            FROM Product p
            LEFT JOIN ProductCategory pc on pc.ProductId = p.Id
            LEFT JOIN Category c on c.Id = pc.CategoryId
        ",
        (product, category) =>
        {
            product.Categories.Add(category);
            return product;
        }, splitOn: "Id",
        transaction: _dbTransaction
    );

    return products.GroupBy(p => p.Id).Select(g =>
    {
        var product = g.First();
        product.Categories = g.Select(p => p.Categories.Single()).ToList();
        return product;
    });
}

在结果中，我得到了 3 个项目的列表：

• Product1 有 2 个类别（Category1、Category2）
• Product2 有 1 个类别（Category2）
• Product3 有 1 个类别（null）

问题是我不想要Product3 使用 null 值填充类别列表。我想要的是在这种情况下有空的类别列表。我应该做什么才能实现这一目标？

Answer 1

为什么不直接将映射函数更改为？：

(product, category) =>
{
    if (category!=null)
    {
        product.Categories.Add(category);
    }
    return product;
}

对于 GroupBy 中的 .Single() 来说，这当然会失败，但是无论如何，您将如何按缺失的类别进行分组呢？

Answer 2

首先从查询中返回原始数据，然后进行一些处理会更容易。然后你就可以将所有逻辑集中在一处。例如：

var products = await _dbConnection
    .QueryAsync<Product, Category, (Product Product, Category Category)>(
    @"
        SELECT p.Id, p.Name, c.Id, c.Name
        FROM Product p
        LEFT JOIN ProductCategory pc on pc.ProductId = p.Id
        LEFT JOIN Category c on c.Id = pc.CategoryId
    "
    ,(product, category) => (product, category)
    , splitOn: "Id"
    ,transaction: _dbTransaction
);

return products.GroupBy(pc => pc.Product.Id)
    .Select(g =>
    {
        var product = g.First().Product;
        product.Categories = g.Select(pc => pc.Category)
            .Where(c => c != null).ToList();
        return product;
    });

null 检查会跳过由于外连接而不可避免地出现在 SQL 结果集中的 null 类别。