使用PHP操作MongoDB

admin

链接数据库
使用下面的代码创建一个数据库链接
, W4 V& P- K5 G2 {# k) g9 Q  A

1. <?php
   - K, y/ Y4 A5 o7 y1 i$ \
2. $connection = new Mongo(mongodb://192.168.1.5:27017); //链接到 192.168.1.5:27017//27017端口是默认的。
   0 |: N. u5 I4 q# l7 x0 n
3. $connection = new Mongo( "example.com" ); //链接到远程主机(默认端口)
   
4. $connection = new Mongo( "example.com:65432" ); //链接到远程主机的自定义的端口
   ; }7 N7 t3 g/ v
5. print_r($connection->listDBs());//能打印出数据库数组，看看有几个数据库。

复制代码

( m; \& V1 I5 O7 B, l2 h上图说有一个数据库名字叫local,总大小1个字节，他是空的。看见ok表示运行成功。
$ N0 l7 S) A& @; `1 s, z
?>
# L& x7 T. G5 S& P6 o8 T
2 d: w, I% q% Q
! P- F7 d2 }+ _7 J5 w& i) g# u. n

现在你可以使用$connection链接来操作数据库了

选择数据库
7 [, ?9 d, _: ]" o, j9 Z- l使用下面的代码来选择一个数据库

1. <?php
   
2. $db = $connection->dbname;
   3 J% H" F! t9 ?
3. ?>

复制代码

这里的数据库并不一定是一个已经存在的数据库，如果所选择的数据库不存在，则会新建一个数据库，所以在选择数据库的时候，注意一定要填上正确的数据库名
如果拼写错误的话，很有可能会新建一个数据库

1. <?php
   " n0 [* c) V7 M
2. $db = $connection->mybiglongdbname;
   
3. //做一些事情
   # U1 B. \% K6 \2 i
4. $db = $connection->mybiglongdbnme;
   * T0 h  W* s- ?8 `* K  q8 w) J3 C7 ~
5. //现在会连上一个新的数据库
   ; v: N+ x8 d! j0 M" y
6. ?>

复制代码

获取一个集合
获取一个集合跟选择数据库拥有相同的语法格式
6 I6 {* A: E5 L- F( q0 X3 b/ h8 q

1. <?php
   
2. $db = $connection->baz;//选择数据库
   
3. $collection = $db->foobar;//选择foobar集合
   
4. //或者使用更简洁的方式
     f# m1 _1 d6 ?3 N; `  _
5. $collection = $connection->baz->foobar;
   6 ~5 ^. ]! T* `; Z$ a
6. ?>

复制代码

插入一个文档
. y2 S9 F2 ?, W% b, s多维数组是可以被储存到数据库中的基本单元
一个随机的文档可能是这样
; b8 n$ r4 \% `% Q! ]% J

1. <?php
   
2. $doc = array(
   $ M& `$ X9 {) m5 G6 y$ ^
3. ”name” => “MongoDB”,
   , V. s5 f$ R! M( y! p% x9 d6 \0 ?
4.     “type” => “database”,
   
5.     “count” => 1,
   6 w5 k6 N, ?) L; Y$ `
6.     “info” => (object)array( “x” => 203,
   6 N1 K) `4 m. C% R
7.     “y” => 102),
   4 o/ f4 w: a. k6 p
8.     “versions” => array(“0.9.7″, “0.9.8″, “0.9.9″)
   
9. );
   - d2 |( v( }; V" b' L. Y
10. ?>

复制代码

注意：你可以嵌套数组与对象，对象与文档在mongodb中几乎是一样的，你可以使用$doc调用一个文档或对象，但是info字段总是一个对象而不是一个文档，
本约束适用于所有文档

使用MongoCollection::insert()插入一个文档

6 g( m, I/ ]4 S3 J

1. <?php
   
2. $m = new Mongo();
   / J6 f% [6 C7 ~- r/ w: G
3. $collection = $m->foo->bar;
   6 b) I# w8 `2 y$ Z4 B; _
4. $collection->insert($doc);
   
5. ?>

复制代码

mongodb 的 insert()、save()  ，区别主要是：若存在主键，insert()  不做操作，而save() 则更改原来的内容为新内容。

存在数据：  { _id : 1, " name " : " n1 " }

insert({ _id : 1, " name " : " n2 " })    会提示错误

save({ _id : 1, " name " : " n2 " })     会把 n1 改为  n2  。

使用MongoCollection::findOne()查询文档
为了证明上面那段代码的数据已经插入到数据库里了，我们进行简单的 findOne()操作以得到集合中的第一个文档数据，这种方法只返回一个文档数据，
' M, M5 E! X6 @1 a# h5 M4 F* p' g这种方法适用于在你的查询语句的时候只匹配一个文档或者你只关心第一条数据

1. <?php
   
2. $obj = $collection->findOne();
   9 @+ u7 P% q) G: C* [+ f
3. var_dump( $obj );
   . |8 ?4 n# [( ^# ^+ v: j; Z& g1 c
4. ?>
   5 y# R7 h$ o7 G7 ^* I+ n3 @
5. 你会看到下列结果
   
6. array(5) {
   $ M8 B4 ?$ k) W% ?8 H
7.   ["_id"]=>
   % T' k/ @- p. i" y) \1 q
8.   object(MongoId)#6 (0) {
   
9.   }
   
10.   ["name"]
    
11.   string(7) “MongoDB”
    6 j+ b/ U& I! W6 P; ~
12.   ["type"]=>
    9 `  e: S/ @, {; `, G" H5 C: K5 H
13.   string(8) “database”
    
14.   ["count"]=>
    4 G6 M6 Q( L$ b
15.   int(1)
    6 n, Y( W- {9 W2 t  h
16.   ["info"]=>
    2 ?, V) C2 e* }+ ?6 O4 j7 C& {
17.   array (2) {
    % y& I8 v; s" e# e1 o  P& R
18.     ["x"]=>
    
19.     int(203)
    & v$ \$ U( }7 m4 b3 o$ G
20.     ["y"]=>
    5 \+ }, V7 S: ^1 F' ^& `+ h# d
21.     int(102)
    . k" N" z/ R, m# |  r5 L3 g0 q" ^, H6 e
22.   }
    * I, {# l" V( Z  Y2 t9 A
23.   ["versions"]
    0 ~5 |& V/ n, r* ^! }' {3 \- X
24.   array(3) {
    
25.     [0]=>
    
26.     string(5) “0.9.7″
    
27.     [1]=>
    $ I: I9 u% i! V* V3 h% ^3 G& C1 y
28.     string(5) “0.9.8″
    ; h; P2 O$ `0 m  D8 F1 z
29.     [2]=>
    
30.     string(5) “0.9.9″
    + b0 b. x# P5 o4 c* p
31.   }
    
32. }

复制代码

注意_id字段自动加载了文档上，MongoDB储存元素中以_以及$开头的都是供内部使用的

添加更多文档
为了做一些更有趣的事情，我们添加更多简单的文档到集合中，这些文档如下

1. <?php
   
2. array( “i” => value );
   
3. ?>

复制代码

我们可以使用循环相当有效的插入数据

1. <?php
   
2. for($i=0; $i<100; $i++) {
   
3.     $collection->insert( array( “i” => $i ) );
     F9 T+ C) l6 _; k* T( ^7 z  `
4. }
   # Q: o% r: o0 g) @! `, |- M
5. ?>

复制代码

注意：我们可以插入不同的字段在同一字符集中，在这方面意味着MongoDB拥有非常自由的储存模式

在一个集合中计算文档的数量
现在我们插入了101个文档(我们用循环插入了100个，之前还插入了一个)，我们可以使用count()来看看我们的数据是不是都被插入进去了

1. <?php
   ( {' Q: I* ~7 N( R. K+ W
2. echo $collection->count();
   % Y. K9 M1 K8 X' w( {
3. ?>

复制代码

这段代码将打印出101
+ T% Z) x) X! ?9 k' z( G5 KMongoCollection::count() 也可以查询字段数据

使用游标得到集合中的所有文档
  N3 z" w& g6 `; Y/ a: I为了得到集合中的所有文档，我们可以使用 MongoCollection::find()方法，find()方法返回一个 MongoCursor对象，可以让我们重复得到查询
所匹配的的文档

1. <?php
   7 c) n$ f1 n" i2 X- D3 |5 Q0 I
2. $cursor = $collection->find();
   # q3 K/ R& l: v6 {& p. P
3. foreach ($cursor as $id => $value) {
   
4.     echo “$id: “;
   ! O  S3 Q5 `* T
5.     var_dump( $value );
   
6. }
   0 _5 w  o) Z5 h( ^/ v6 h% {
7. ?>

复制代码

这样我们会打印出集合中的这101个文档，$id就是文档中的_id字段，$value 就是文档本身

为查询规定一个标准
6 c* p7 D  D- E2 o0 B  L2 K, ~2 K) H/ a我们可以通过find()方法得到集合中的文档子集，例如，我们要查询出集合中i字段为71的文档，我们可以使用下列方法

1. <?php
   1 E' H  a1 W- d! Q9 T. x
2. $query = array( “i” => 71 );
   
3. $cursor = $collection->find( $query );
   " b9 t1 a7 k/ \7 z& B3 ]+ `
4. while( $cursor->hasNext() ) {
   . l! ~4 {" X+ ]. h; b
5.     var_dump( $cursor->getNext() );
   2 a% l# D, c, }% _3 ^' _5 y
6. }
   
7. ?>

复制代码

我们将打印如下数据
: [2 g5 Z* F( O5 M

1. array(2) {
   
2.   ["_id"]=>
   
3.   object(MongoId)#6 (0) {
   # c0 Y: s  R! ^- Z8 l2 Z( `
4.   }
   
5.   ["i"]=>
   
6.   int(71)
   
7.   ["_ns"]=>
   
8.   “testCollection”
   / E3 ~) a! v0 R/ n
9. }

复制代码

为查询设定一个范围
) b, @1 W6 H' _) E' V我们可以通过find()创建一个查询语句以得集合中的一个子集，例如如果我们得到所有”i”>50的文档，我们可以使用如下代码
7 U" }4 R4 f' N

1. <?php
   
2. $query = array( “i” => array(‘$gt’ =>50)); //注意’$gt’两边的单引号
   
3. $cursor = $coll->find( $query );
   % ~4 a& b" E! l1 O  o" `& f: v
4. while( $cursor->hasNext() ) {
   + I% N& k  E4 o2 {$ e! ?& f  Z
5.     var_dump( $cursor->getNext() );
   9 D# j$ m2 K; R% [# C
6. }
   ( H  W/ U8 X+ t) V4 G
7. ?>

复制代码

我们同样可以得到20 < i <= 30之间的数据
6 [6 M4 y# l5 ]

1. <?php
   : Q$ c3 f8 g8 l* h$ K1 u& w
2. $query = array( “i” => array( “\$gt” => 20, “\$lte” => 30 ) );
   2 S7 ]9 g1 s+ @) L, `5 x/ L
3. $cursor = $coll->find( $query );
   
4. while( $cursor->hasNext() ) {
   $ n0 r  X+ V) v+ C
5.     var_dump( $cursor->getNext() );
   ) ?: o. ^5 s$ {
6. }
   
7. ?>

复制代码

+ ~. }2 m6 n& ^0 v

我们非常容易漏掉$美元符号，你也可以选择你自定义的符号来代替美元符号，选择一个不会在你的建里面出现的符号例如”:”,在php.ini中加上这么一句话
mongo.cmd = “:”
那么上面的代码就可以替换成

1. <?php
   # S. B- h% d" F# Y) E; b: j
2. $query = array( “i” => array( “:gt” => 20, “:lte” => 30 ) );
   & u* p, b4 w) Y' m" p3 }9 T6 d0 q
3. ?>

复制代码

# q4 F, M* D4 C" a4 G! M0 F3 G当然你也可以使用ini_set(“mongo.cmd”, “:”)的方法来改变

创建一个索引
* O0 C# v; A9 g/ w+ o  s2 q8 j2 `MongoDB支持索引，并且可以很容易的加到一个集合中，你只要指定某个字段为索引就行了，并且还可以指定 正序索引(1)与 倒序索引(-1)
+ ?* j+ }' n; r  h5 J' T7 l下面的代码为I创建了索引
3 S+ x9 I: ^$ A( K& A" }) A, V0 n

1. <?php
   
2. $coll->ensureIndex( array( “i” => 1 ) );  //在”i”上创建了一个索引
   * f# J- _9 d6 l& a( M
3. $coll->ensureIndex( array( “i” => -1, “j” => 1 ) );//在”i”上创建了倒序索引 在”j”上创建了正序索引
   6 b: C: n- v0 g% o9 M
4. ?>

复制代码

一个简单的列子
这个例子展示了如何链接mongodb数据库，如何选择数据库，如何插入数据，如何查询数据，以及关闭数据库链接

1. <?php
   
2. //链接
   + u% N6 W8 p0 U" A- E9 T
3. $m = new Mongo();
   5 c0 _5 c6 i3 t! v- Y6 ]
4. 
   
5. // 选择一个数据库
     H1 P- d! ]& |0 `# H7 |
6. $db = $m->comedy;
   
7. $collection = $db->cartoons;
   
8. 
   ; w  ?; [0 ~- z% V0 ?6 {
9. //添加一个元素
   0 i% o3 e+ u( O) _) D
10. $obj = array( "title" => "Calvin and Hobbes", "author" => "Bill Watterson" );
    
11. $collection->insert($obj);
    + _1 {4 T) M6 O
12. 
    
13. //添加另一个元素，使用不同的格式
    
14. $obj = array( "title" => "XKCD", "online" => true );
    $ U" u; N$ K/ t+ i) [
15. $collection->insert($obj);
    $ B0 o9 m+ D; e' P" d3 G
16. 
    
17. //查询所有的集合
      w& l0 f6 _  u4 E- W* A6 e
18. $cursor = $collection->find();
    ! e: g$ p& b1 V8 B9 v& U2 S
19. 
    & i% O) `' h" e+ j" G% \) v. J
20. //重复显示结果
    & j" W) L5 m) \4 q( T6 z$ v
21. foreach ($cursor as $obj) {
    % n! c5 K% p& B! ]3 D" l
22.     echo $obj["title"] . "\n";
    + T' t9 f# b, |  t4 Y, Q
23. }
    
24. 
    
25. // 关闭链接
    6 X5 l7 l6 ^6 u7 b
26. $m->close();
    % M  ^' o9 F* k4 S0 H2 h2 I
27. ?>

复制代码

输出结果为
7 w  n! q. w' x% b( A

1. Calvin and Hobbes
   
2. XKCD

复制代码

6 D2 B8 S1 }. @

, O8 y+ [( ~- ?3 k4 r9 s$ t# B) G
6 [' j4 d8 z; P, D! y, N2 m* W7 Q