带有 mongodb 的流明:出现错误:在 null 上调用成员函数 prepare()
Posted
技术标签:
【中文标题】带有 mongodb 的流明:出现错误:在 null 上调用成员函数 prepare()【英文标题】:lumen with mongodb :getting error : Call to a member function prepare() on null 【发布时间】:2019-04-19 06:50:49 【问题描述】:我正在使用 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] =>
请帮助我获得预期的结果
【问题讨论】:
【参考方案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
,因此最后一部分是收集这些结果
我希望这对您有所帮助,如果有任何不清楚的地方,请告诉我。
【讨论】:
【参考方案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
【讨论】:
我也试过这个,但它给我的结果是,[_id] => Array ([folder_id] => 5bee461e19f043020c001844) [folder_id] => 5bee461e19f043020c001844 [sum(if(is_read==0 ,1,0)) 作为未读,count(message_id) 作为总数,folder_id] => 将选择更改为 selectRaw 并使其成为单个字符串 谢谢,我已经更新了我的问题,这是怎么回事,请查看 嗨 Hetel 我建议您的问题现在与原始代码有关,因为它看起来不像使用 mongoDB 语言,但我不熟悉它。以上是关于带有 mongodb 的流明:出现错误:在 null 上调用成员函数 prepare()的主要内容,如果未能解决你的问题,请参考以下文章
如何在某些元素中处理带有 nul char 的 CSV 行?