使用SqlKata执行多个查询

Question

是否可以同时使用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);

谢谢。

Answer 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的注释中提到的那样向数据库发送一个查询。如果性能确实是您所追求的，那么您可以考虑使用Dapper扩展方法QueryMultiple而不是Query ( SqlKata正在对Get()方法进行调用)。我对Dapper所做的潜在魔法还不太熟悉，无法自信地给你指路。另一种可能是为GetAsync添加扩展，而不是Get。这可能更适合你的需要。

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