|
查询操作 , H% D9 m8 c. m; |* m+ L6 x
- $filter["season_id"] = 106;; Z/ }+ `4 I6 A- p$ o8 f" n! v
- //$filter["array.8"] = 'cml123';( q& {) y& V A" J8 d
# ^. X, f! Z% O4 r5 g* ~- $filter = ["matches.events_id"=>1];7 t, I& r0 _0 j0 H) _4 b
6 F' g t1 L' p+ [! U- $filter = ["matches.events_id"=>['$in'=>[2,3,4,5,7]]];
" s" |) Q, B6 p) V! ~; }! f0 } - $filter = ["matches.events_id"=>['$lt'=>'8'];
( x8 _* Z! S- n: m0 F - ; ?' M, h% q0 ?% R) g& n& r( H
! h: O7 u( r3 n6 L; i; c+ \! M- 以上条件说明 http://bbs.cncml.com/forum.php?m ... &extra=page%3D1
; Q4 V9 b0 b: l4 U - 6 b* F$ X2 A. M0 ]" C/ D
- $options = [( L3 N' [7 R# V7 E) e+ B
- 'projection' => ['_id' => 0,"s_lastid" => 1],
\. y! i/ z9 R - 'limit' => 1, //显示条数- G1 j$ Y" H7 w: }! P8 P2 }4 D
- 'skip' => 1 //跳过几条
|/ e' b& U% C* \ - ];5 F, M# w, m- z. s, c% ~
6 o. [: S8 s; S0 H- $querys = new MongoDB\Driver\Query($filter,$options);- G/ d2 n1 J9 S3 C
- $cursors = $manager->executeQuery('football.football_Competition_season_matches', $querys);
. K5 W8 H$ I4 T7 F# q - $schedule= mg_querys($cursors);$ ^, ^. P, I8 X
- print_r($schedule);, j" r5 @# a' ?
复制代码
8 t$ C7 ^. ]8 B. u6 L7 p : K: Y5 r4 N3 g5 @/ x
) g* p9 r" S8 C. O4 \2 j: H
+ F8 E: R( _, z! T }9 K* N
------------------------------------------------------------------------------------- 一、更新前通过控制台查看数据,查看命令如下 db.sites.find().pretty() 二、通过php实现数据更新,代码如下 <?php // 1.创建数据库连接对象 $manager = new MongoDB\Driver\Manager("mongodb://localhost:27017"); ) q1 {$ `3 P* ?' t# b
// 2.创建数据更新对象 $bulk = new MongoDB\Driver\BulkWrite; // 说明:更新index=2的数据,把原来的url更新为现在的内容,multi:只更新匹配到的第一条数据 $bulk->update( ['index' => 2], ['$set' => ['url' => 'https://www.java.com']], ['multi' => false, 'upsert' => false] );
' L, s, y H. y. F6 E7 N// 3.创建更新操作级别对象 // 说明:MongoDB\Driver\WriteConcern::MAJORITY :抛出网络错误异常、服务器错误异常;并等待一个主服务器完成写操作 // 1000:等待超时时间 $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);
3 v5 n6 B- I2 \$ b/ `// 4.执行写命令 // 说明:test.sites是test库下的sites集合 // $bulk:更新对象 // $writeConcern:写操作保证级别 $result = $manager->executeBulkWrite('test.sites', $bulk, $writeConcern);
. p; ^" T/ E6 v5 O* B// 5.输出更新后的结果 var_dump($result); 代码截图如下: 运行结果截图如下: 三、通过控制台查看更新后的数据,查看命令如下 db.sites.find().pretty()
9 C: P t+ ` r! h; ?8 g* `
5 N# N0 ]- ? |; d; d* A |