带有 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 $aggregateaggregate() 函数。

首先我们要过滤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()的主要内容,如果未能解决你的问题,请参考以下文章

在 docker 中构建流明

如何在某些元素中处理带有 nul char 的 CSV 行?

LUMEN:如何修复 SQLSTATE [42000]:语法错误或访问冲突:laravel 流明上的 1071

markdown 带有CORS和OPTIONS请求的流明

带有标题集的流明/laravel中的CORS问题

软删除是不是适用于流明框架?流明的限制?