|
查询操作 ; I( Q; R$ @: a/ }
- $filter["season_id"] = 106;+ R. H' ]+ q) Z
- //$filter["array.8"] = 'cml123';% g# l, |3 o) B
( Q: ?$ B2 u& Z) D7 Q9 _+ ~- $filter = ["matches.events_id"=>1];; v! u/ _5 m6 ? m8 }' V6 c9 G
3 E" |$ c& ]4 e4 O; Q( G: K- $filter = ["matches.events_id"=>['$in'=>[2,3,4,5,7]]];
- t* b: Y7 x# s( [) X - $filter = ["matches.events_id"=>['$lt'=>'8'];1 f9 \) ]. s2 V* P
0 t7 a) `: Y7 g- ( [6 p* z4 w' i5 P1 F9 L; l. {
- 以上条件说明 http://bbs.cncml.com/forum.php?m ... &extra=page%3D1
[/ j! j& H6 P+ z2 w3 s
3 @1 [% H0 F& a! u# f- \9 I' d- $options = [+ v8 r8 x/ ~7 m4 l! B0 t
- 'projection' => ['_id' => 0,"s_lastid" => 1],3 ?9 N& H W% m( p7 h% q: H( R
- 'limit' => 1, //显示条数$ T1 W- w( |3 J6 o9 ^- N x
- 'skip' => 1 //跳过几条
0 b: b" Z. f9 o4 } - ];8 y9 ]" G( F/ @8 Q
5 M& \. E3 s& { r9 h; u3 H- $querys = new MongoDB\Driver\Query($filter,$options);7 i" L' Y3 I. U w( F* w
- $cursors = $manager->executeQuery('football.football_Competition_season_matches', $querys);
2 d5 |: U; N2 ~0 S2 ^4 u0 R) K2 ~, j( S& q - $schedule= mg_querys($cursors);
! X! c* Y4 k. ]5 p1 p0 o% g% Q - print_r($schedule);
, U. S' n# m7 z% ~+ F% b0 J
复制代码 , M3 @5 K( b: p5 L/ T
5 v6 `" n9 u7 S2 Q0 h1 M. E1 a! T
8 }' V' i. ^4 O$ W& R4 m
------------------------------------------------------------------------------------- 一、更新前通过控制台查看数据,查看命令如下 db.sites.find().pretty() 二、通过php实现数据更新,代码如下 <?php // 1.创建数据库连接对象 $manager = new MongoDB\Driver\Manager("mongodb://localhost:27017"); + u) e1 e1 C" {0 m( z j$ E
// 2.创建数据更新对象 $bulk = new MongoDB\Driver\BulkWrite; // 说明:更新index=2的数据,把原来的url更新为现在的内容,multi:只更新匹配到的第一条数据 $bulk->update( ['index' => 2], ['$set' => ['url' => 'https://www.java.com']], ['multi' => false, 'upsert' => false] ); 0 X4 h* P, f& v4 _ P
// 3.创建更新操作级别对象 // 说明:MongoDB\Driver\WriteConcern::MAJORITY :抛出网络错误异常、服务器错误异常;并等待一个主服务器完成写操作 // 1000:等待超时时间 $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);
[, x6 n, B) K// 4.执行写命令 // 说明:test.sites是test库下的sites集合 // $bulk:更新对象 // $writeConcern:写操作保证级别 $result = $manager->executeBulkWrite('test.sites', $bulk, $writeConcern); ( t j) ]5 K g, J
// 5.输出更新后的结果 var_dump($result); 代码截图如下: 运行结果截图如下: 三、通过控制台查看更新后的数据,查看命令如下 db.sites.find().pretty() 5 h9 @0 i0 k E3 W$ C5 X/ e
5 ~& @! i% Q6 P1 X/ N: ^9 t
|