带有 mongodb 的流明：出现错误：在 null 上调用成员函数 prepare()

Question

我正在使用 lumen 和 mongodb

我想根据文件夹获取（未读总数）和消息总数

我的 mongodb 查询如下所示，

$totalEmails = DB::connection('mongodb')
        ->select("sum(if(is_read==0,1,0)) as unread", "count(message_id) as total", "folder_id")
        ->collection('email_message')
        ->where('email_account_id', (int)$request->email_account_id)
        ->where('status', "Active")
        ->groupBy("folder_id")
        ->get();

它给了我如下错误，

FatalErrorException in Connection.php line 333:
Call to a member function prepare() on null

请帮我解决这个问题。谢谢。

我已通过如下更改查询来解决该错误，

$totalEmails = DB::connection('mongodb')            
            ->collection('email_message')
            ->select("sum(if(is_read==0,1,0)) as unread", "count(message_id) as total", "folder_id")
            ->where('email_account_id', (int)$request->email_account_id)
            ->where('status', "Active")
            ->groupBy("folder_id")
            ->get();

但它没有给我预期的结果，

它给我的结果如下，

[_id] => Array
            (
                [folder_id] => 5bee461e19f043020c001844
            )

    [folder_id] => 5bee461e19f043020c001844
    [sum(if(is_read==0,1,0)) as unread] => 
    [count(message_id) as total] => 

但我的期望是

[_id] => Array
            (
                [folder_id] => 5bee461e19f043020c001844
            )

    [folder_id] => 5bee461e19f043020c001844
    [unread] => 2
    [total] => 10

你能告诉我查询哪里出错了吗？？？

如果我使用下面的查询

$totalEmails = DB::connection('mongodb')
    ->selectRaw("sum(if(is_read==0,1,0)) as unread", "count(message_id) as total", "folder_id")
    ->collection('email_message')
    ->where('email_account_id', (int)$request->email_account_id)
    ->where('status', "Active")
    ->groupBy("folder_id")
    ->get();

它给了我这样的错误，

ErrorException in Builder.php line 245:
Argument 2 passed to Illuminate\Database\Query\Builder::selectRaw() must be of the type array, string given,

如果我使用以下查询，

 $totalEmails = DB::connection('mongodb')        
        ->collection('email_message')
        ->selectRaw("sum(if(is_read==0,1,0)) as unread,count(message_id) as total,folder_id")
        ->where('email_account_id', (int)$request->email_account_id)
        ->where('status', "Active")
        ->groupBy("folder_id")
        ->get();

它给了我这样的结果，

[_id] => Array
                (
                    [folder_id] => 5bee461e19f043020c001844
                )

            [folder_id] => 5bee461e19f043020c001844
            [sum(if(is_read==0,1,0)) as unread,count(message_id) as total,folder_id] => 

请帮助我获得预期的结果

Answer 1

据我所知，这是一个执行起来相当复杂的查询，并且很难使用 laravel 方法生成，因此我建议使用 $aggregate 进行原始查询，如下例所示：

$totalEmails = DB::connection("mongodb")
    ->collection("email_message")
    ->raw(function ($collection) {
        return $collection->aggregate(
            [
                [
                    "\$match" => [
                        "email_account_id" => (int)$request->email_account_id,
                        "status" => "active"
                    ]
                ],
                [
                    "\$group" => [
                        "_id" => [
                            "folder_id" => "\$folder_id"
                        ],
                        "unread" => [
                            "\$sum" => [
                                "\$switch" => [
                                    "branches" => [
                                        ["case" => [
                                            "\$eq" => [
                                                "\$is_read", '0,1,0'
                                            ]
                                        ],
                                            "then" => 1
                                        ]
                                    ],
                                    "default" => 0
                                ]
                            ]
                        ],
                        "total" => [
                            "\$sum" => 1
                        ]
                    ]
                ]
            ]
        );
    });

$collectedResult = array();
foreach ($result as $k => $v) {
    $collectResult[] = $v->jsonSerialize();
}

return $collectedResult;

我已将其格式化为尽可能可读，我会尽量解释查询的每个部分，以便您知道它的作用。

通过使用raw 语句，我们可以使用模拟mongo $aggregate 的aggregate() 函数。

首先我们要过滤email_account_id，这是通过$match方法完成的，注意$被转义，否则php会将其解释为变量。

之后我们需要执行这个部分的分组：

"_id" => [
      "folder_id" => "\$folder_id"
]

这将创建 _id 列，其中包含一个带有键 folder_id 的数组，并将收集 DB 列 'folder_id' 的所有唯一值到值中。

因此，这部分将生成具有唯一文件夹 ID 的元素数组，然后必须计算这些文件夹的未读消息和总消息。

总计很简单，使用$sum 运算符完成。未读部分有点复杂，因为这需要在is_read 运算符上进行过滤。这是通过 switch 语句和默认值 0 完成的（当条件失败时不计入）。

原始查询将返回MongoCursor，因此最后一部分是收集这些结果

我希望这对您有所帮助，如果有任何不清楚的地方，请告诉我。

Answer 2

我不确定这是否是导致您的问题的原因，但您的代码中有错误

应该是：

$totalEmails = DB::connection('mongodb')
    ->selectRaw("sum(if(is_read==0,1,0)) as unread, count(message_id) as total, folder_id")
    ->collection('email_message')
    ->where('email_account_id', (int)$request->email_account_id)
    ->where('status', "Active")
    ->groupBy("folder_id")
    ->get();

selectRaw 需要在选择中包含原始代码。这是有关更多信息的文档

https://laravel.com/docs/5.5/queries#raw-expressions