PHP7连接MongoDB进行数据更新

admin

查询操作

7 s- \0 C! h$ U3 V" k9 x7 ~/ ?

1. $filter["season_id"] = 106;
   
2. //$filter["array.8"] = 'cml123';
   
3. 
   ! d7 k4 m3 j9 c" V
4. $filter = ["matches.events_id"=>1];
   
5. 
   0 A+ v# X" [# |9 g! g" c$ o
6. $filter = ["matches.events_id"=>['$in'=>[2,3,4,5,7]]];
   
7. $filter = ["matches.events_id"=>['$lt'=>'8'];
   
8. 
   
9. 
   
10. 以上条件说明 http://bbs.cncml.com/forum.php?m ... &extra=page%3D1
    % t% n2 ]7 k6 o) `4 D5 n  b: v
11. 
    , g# y# l5 }- S9 m, b2 r
12. $options = [
    5 N  v1 M3 l* ?1 w( j
13.     'projection' => ['_id' => 0,"s_lastid" => 1],
    ( c. b* `( C* W0 l) X* @
14.     'limit' => 1,       //显示条数
    
15.     'skip' => 1         //跳过几条
    
16. ];
    0 R5 r" I( Y" k* x6 Q
17. 
    
18. $querys = new MongoDB\Driver\Query($filter,$options);
    
19. $cursors = $manager->executeQuery('football.football_Competition_season_matches', $querys);
    8 N* `6 {: H2 m) E4 R$ d% w; r
20. $schedule= mg_querys($cursors);
    
21. print_r($schedule);
    

复制代码

/ ]& `. O6 T* }. d+ k

: W2 T, m' M  @( p& J

-------------------------------------------------------------------------------------

一、更新前通过控制台查看数据，查看命令如下

    db.sites.find().pretty()

二、通过php实现数据更新，代码如下

<?php

// 1.创建数据库连接对象

$manager = new MongoDB\Driver\Manager("mongodb://localhost:27017");

+ c! ~& e' [' I# t' P* z

// 2.创建数据更新对象

$bulk = new MongoDB\Driver\BulkWrite;

// 说明：更新index=2的数据，把原来的url更新为现在的内容，multi:只更新匹配到的第一条数据

$bulk->update(

    ['index' => 2],

    ['$set' => ['url' => 'https://www.java.com']],

    ['multi' => false, 'upsert' => false]

);

& w4 r+ ~" p4 o# \5 X0 c

// 3.创建更新操作级别对象

// 说明：MongoDB\Driver\WriteConcern::MAJORITY :抛出网络错误异常、服务器错误异常；并等待一个主服务器完成写操作

// 1000:等待超时时间

$writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);

* N& S+ y0 H* k' x9 I- r

// 4.执行写命令

// 说明：test.sites是test库下的sites集合

// $bulk:更新对象

// $writeConcern:写操作保证级别

$result = $manager->executeBulkWrite('test.sites', $bulk, $writeConcern);

- H0 P; L% e5 [

// 5.输出更新后的结果

var_dump($result);

代码截图如下：

运行结果截图如下：

三、通过控制台查看更新后的数据，查看命令如下

    db.sites.find().pretty()