查询操作
+ P& E1 d( k) o0 V5 ]% h- $filter["season_id"] = 106;# `* a4 a5 p+ L0 |# {& @% t9 g: d
- //$filter["array.8"] = 'cml123';
/ R6 |9 T7 Q# x% G+ L3 C3 X. a - . X/ p% c4 O9 l' O
- $filter = ["matches.events_id"=>1];" [* t! L% N9 r
- 5 U0 Q$ A* T# k- v) `; l- H6 T* R
- $filter = ["matches.events_id"=>['$in'=>[2,3,4,5,7]]];
) v" Y7 {: k+ [4 M - $filter = ["matches.events_id"=>['$lt'=>'8'];
) Y9 }7 u% O6 U5 B* Y
; g; t- _8 b0 e- d- 7 k7 i$ J3 c& f6 [& v
- 以上条件说明 http://bbs.cncml.com/forum.php?m ... &extra=page%3D1
: ]9 c3 ?$ }8 b6 o( g) S {
# d. R9 [: w3 n* ^/ a# M0 p4 [" n- $options = [
& b1 Z8 p$ | H - 'projection' => ['_id' => 0,"s_lastid" => 1],! J- d# a0 J- I% R( W6 ^9 f1 J* P
- 'limit' => 1, //显示条数7 B+ ~9 u- K- U; s" H3 L
- 'skip' => 1 //跳过几条
0 d7 E' s' k! L0 n! ]7 s& t5 t - ];0 g3 X1 n% K8 g- e- H$ _& B+ ?
- 8 l* ^2 ^3 e/ |+ b( X6 w
- $querys = new MongoDB\Driver\Query($filter,$options);& m- A. y# J' S* M
- $cursors = $manager->executeQuery('football.football_Competition_season_matches', $querys);
0 G! W. h/ j7 @/ A9 B - $schedule= mg_querys($cursors);
& C# z0 r1 ^6 e# t1 Y( F4 c - print_r($schedule);
7 m6 {9 l( d, w. p! |
复制代码
/ l% W7 {: N% m) H 1 F6 i6 E+ }; d; K0 f2 L2 I, X
% B- }& k$ L& B, _) F" Z3 J+ A( V9 \ {1 |8 P9 m
------------------------------------------------------------------------------------- 一、更新前通过控制台查看数据,查看命令如下 db.sites.find().pretty() 二、通过php实现数据更新,代码如下 <?php // 1.创建数据库连接对象 $manager = new MongoDB\Driver\Manager("mongodb://localhost:27017");
" ?5 m9 ~# |; R0 g// 2.创建数据更新对象 $bulk = new MongoDB\Driver\BulkWrite; // 说明:更新index=2的数据,把原来的url更新为现在的内容,multi:只更新匹配到的第一条数据 $bulk->update( ['index' => 2], ['$set' => ['url' => 'https://www.java.com']], ['multi' => false, 'upsert' => false] ); 1 w6 R0 @# m. o* D3 S. a
// 3.创建更新操作级别对象 // 说明:MongoDB\Driver\WriteConcern::MAJORITY :抛出网络错误异常、服务器错误异常;并等待一个主服务器完成写操作 // 1000:等待超时时间 $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000); 9 p* N. F: G. U8 ]# k: M$ R- a* X+ j
// 4.执行写命令 // 说明:test.sites是test库下的sites集合 // $bulk:更新对象 // $writeConcern:写操作保证级别 $result = $manager->executeBulkWrite('test.sites', $bulk, $writeConcern); 4 M) u/ \8 S6 K7 _2 p/ v3 j1 L4 S
// 5.输出更新后的结果 var_dump($result); 代码截图如下: 运行结果截图如下: 三、通过控制台查看更新后的数据,查看命令如下 db.sites.find().pretty() " s. Q9 t3 Y4 f+ E" K z
# X0 A( d2 J1 q0 r+ w
|