使用 SqlKata 执行多个查询答案

【问题标题】：Execute multiple queries using SqlKata使用 SqlKata 执行多个查询
【发布时间】：2018-10-11 15:28:46
【问题描述】：

是否可以同时使用 SqlKata 执行多个查询。

目前我有以下代码：

var latestUsersQuery = db.Query("tbl_users").Where("created_at", ">", from);
var activitiesQuery = db.Query("tbl_activities").WhereIn("user_id", latestUsersQuery.Clone());

我正在单独查询每一个。

var latestUsers = latestUsersQuery.Get();
var activities = activitiesQuery().Get();

我想知道是否有办法同时执行两个查询。

// for example something like this
var results = db.GetAll(latestUsersQuery, activitiesQuery);

谢谢。

【问题讨论】：

您的目标是只向数据库发送一个查询（以提高性能）吗？
是的，使用相同的连接

标签： c# sqlkata

【解决方案1】：

这方面的游戏晚了，但您可以扩展 SqlKata 的 QueryFactory 类，类似于他们编写其他方法的方式；使用扩展方法。

using SqlKata;
using SqlKata.Execution;
using System.Collections.Generic;
using System.Linq;
// ...

public static class QueryFactoryExtensions
{
    public static IEnumerable<IEnumerable<T>> GetAll<T>(this QueryFactory db, params Query[] queries)
    {
        return queries.Select(q =>
        {
            return SqlKata.Execution.QueryFactoryExtensions.Get<T>(db, q);
        });
    }
    public static IEnumerable<IEnumerable<dynamic>> GetAll(this QueryFactory db, params Query[] queries)
    {
        return GetAll<dynamic>(db, queries);
    }
}

用法如下：

var query1 = new Query();
var query2 = new Query();

var results = db.GetAll(query1, query2)

从那里你可以：枚举它，强制转换为数组并按索引访问，等等。

请记住，这并不是像 OP 的 cmets 中提到的那样向数据库发送一个查询。如果 performance 确实是您所追求的，那么您可能会考虑使用 Dapper 扩展方法 QueryMultiple 而不是查询（这是 SqlKata 在 Get() 方法上调用的内容）。我对 Dapper 正在做的能够自信地给你指导的潜在魔力不够熟悉。您还可以为 GetAsync 添加扩展而不是 Get。这可能更适合您的需求。

综上所述，至少我希望这可以为您提供一些方向来做出决定或潜在的基准性能。

【讨论】：