php - MySQL 到 Mongodb 查询问题

Question

我要感谢过去帮助过我的每个人，以及您花时间阅读这篇文章。

我在将 sql 查询转换为 mongodb 查询时遇到问题。

SQL 查询:

SELECT m_time,m_latency FROM pkt_tbl WHERE (m_time-m_latency+" . LATENCY_DELTA . ")>=" . $rangeXFrom . " AND (m_time-m_latency+" . LATENCY_DELTA . ")<=" . $rangeXTo . " ORDER BY (m_time-m_latency+" . LATENCY_DELTA . ")"

Mongodb 查询(我的尝试)

$latency_delta_split = array('m_time-m_latency'=>LATENCY_DELTA);
$find_query = array($latency_delta_split=>array('$gte'=>$rangeXFrom),$latency_delta_split=>array('$lte'=>$rangeXTo));
$find_projectins = array('m_time'=>1, 'm_latency'=>1);    $find_query = array(('m_time-m_latency'=>LATENCY_DELTA)=>array('$gte'=>$rangeXFrom),('m_time-m_latency'=>LATENCY_DELTA)=>array('$lte'=>$rangeXTo));

我仍然遇到错误，无法真正找到解决方案。

我做了什么:

1] Read Mongodb Docs.
2] Searched on StackOverflow for similar problems. (None addressed mine)
3] Refered to PHP.NET official docs.

但是，我想不通，不胜感激。

Answer 1

在您的 SQL 中，您有:m_time-m_latency，我认为这意味着从另一列中减去一列。

简短的回答:

这不是您可以用 MongoDB 查询表示的东西，因为您只能比较具有静态值的字段。

长答案:

如果您想查找 m_time - m_latency + LATENCY_DELTA 在特定范围内的文档，那么您必须将该值存储在 pre-calculated 的另一个字段中文档。如果你这样做，那么你可以简单地运行查询:

db.collection.find( { 'm_calculated_latency' : { '$gte' : FROM_RANGE, '$lte' : TO_RANGE } } );

或者在 PHP 中:

$collection->find( array(
    'm_calculated_latency' => array(
        '$gte' => $from_range,
        '$lte' => $to_range,
    )
)

解决方法:

使用 MongoDB 的聚合框架，您可能可以随心所欲地进行查询，但它目前还不是最快或最优雅的解决方案，而且它也不使用索引。因此，请重新设计您的架构并添加该预先计算的字段。

去掉警告，下面是:

FROM=3
TO=5
DELTA=1
db.so.aggregate( [ 
    { $project: { 
        'time': { $add: [
            { $subtract: [ '$m_time', '$m_latency' ] },
            DELTA
        ] },
        'm_time' : 1,
        'm_latency' : 1
    } }, 
    { $match: { 'time' : { $gte: FROM, $lte: TO } } },
    { $sort: { 'time' : 1 } }
] );

在 $project 步骤中，我们将字段时间计算为 m_time - m_latency + DELTA。我们还输出了原始的 m_time 和 m_latency 字段。然后在 $match 步骤中，我们将计算出的 time 与 FROM 或 TO 进行比较。最后我们按计算出的 time 排序。 (由于您原来的 SQL 排序也没有意义，我假设您打算按时差排序)。

使用我的输入数据:

> db.so.insert( { m_time: 5, m_latency: 3 } );
> db.so.insert( { m_time: 5, m_latency: 1 } );
> db.so.insert( { m_time: 8, m_latency: 1 } );
> db.so.insert( { m_time: 8, m_latency: 3 } );
> db.so.insert( { m_time: 7, m_latency: 2 } );
> db.so.insert( { m_time: 7, m_latency: 4 } );
> db.so.insert( { m_time: 7, m_latency: 6 } );
> FROM=3
> TO=5
> DELTA=1

这会产生:

{
    "result" : [
        {
            "_id" : ObjectId("51e7988af4f32a33dac184e8"),
            "m_time" : 5,
            "m_latency" : 3,
            "time" : 3
        },
        {
            "_id" : ObjectId("51e7989af4f32a33dac184ed"),
            "m_time" : 7,
            "m_latency" : 4,
            "time" : 4
        },
        {
            "_id" : ObjectId("51e7988cf4f32a33dac184e9"),
            "m_time" : 5,
            "m_latency" : 1,
            "time" : 5
        }
    ],
    "ok" : 1
}

现在最后一个技巧是用 PHP 语法编写上面的聚合查询，如您所见，这非常简单:

<?php
$m = new MongoClient;
$db = $m->test;

$r = $db->so->aggregate( [ 
    [ '$project' =>  [
        'time' => [ '$add' => [
            [ '$subtract' => [ '$m_time', '$m_latency' ] ],
            $DELTA
        ] ],
        'm_time' => 1,
        'm_latency' => 1
    ] ], 
    [ '$match' => [ 'time' => [ '$gte' => $FROM, '$lte' => $TO ] ] ],
    [ '$sort' => [ 'time' => 1 ] ]
] );
var_dump( $r );
?>