PHP MongoDB入門
用php實現mongoDB的基本操作
php的官方手冊,網址在:http://us.php.net/manual/en/book.mongo.php
與mongoDB建立連接:
直接實例化mongo類+創建連接:
$mo = new Mongo();//得到一個Mongo連接對象
實例化了一個Mongo類,并且與默認的localhost:27017端口的mongoDB建立連接。
如果想連接到其他的主機,可以這樣寫:$mongo =
另外一種方式,實例化mongo類,再手動建立連接:
$mongo =
$mongo->connect();//創建連接
Mongo類中有用的一些方法:
Mongo::listDBs()
http://us.php.net/manual/en/mongo.listdbs.php
返回一個包含當前mongo服務上的庫(DB)信息的數組。
$mo = new Mongo();
$dbs = $mo->listDBs();//獲得一個包含db信息的數組
Mongo::selectCollection($db,$coll)
http://us.php.net/manual/en/mongo.selectcollection.php
返回一個當前連接下的某db中的collection對象。
$mo = new Mongo();
$coll = $mo->selectCollection(’db’,'mycoll’);//得到一個collection對象
選擇想要的數據庫(Mongo類):
一種方式:
http://us.php.net/manual/en/mongo.get.php
$mongo = new Mongo();
$db = $mongo->foo;//得到一個MongoDB對象
另一種方式:
http://us.php.net/manual/en/mongo.selectdb.php
$mongo = new Mongo();
$db = $mongo->selectDB(’foo’);//得到一個MongoDB對象
MongoDB中有用的函數:
創建一個MongoDB對象
http://us.php.net/manual/en/mongodb.construct.php
$mo = new Mongo();
$db = new MongoDB($mo,’dbname’);//通過創建方式獲得一個MongoDB對象
刪除當前DB
http://us.php.net/manual/en/mongodb.drop.php
$db = $mo->dbname;
$db->drop();
獲得當前數據庫名
http://us.php.net/manual/en/mongodb.–tostring.php
$db = $mo->dbname;
$db->_tostring();
選擇想要的collection:
A:
$mo = new Mongo();
$coll = $mo->dbname->collname;//獲得一個collection對象
B:
$db = $mo->selectDB(’dbname’);
$coll = $db->collname;
C:
$db = $mo->dbname;
$coll = $db->selectCollectoin(’collname’);//獲得一個collection對象
插入數據(MongoCollection對象):
http://us.php.net/manual/en/mongocollection.insert.php
MongoCollection::insert(array $a,array $options)
array $a 要插入的數組
array $options 選項
safe 是否返回操作結果信息
fsync 是否直接插入到物理硬盤
例程:
$coll = $mo->db->foo;
$a = array(’a'=>’b');
$options = array(’safe’=>true);
$rs
$rs為一個array型的數組,包含操作信息
刪除數據庫中的記錄(MongoCollection對象):
http://us.php.net/manual/en/mongocollection.remove.php
MongoCollection::remove(array $criteria,array $options)
array $criteria
array $options 選項
safe 是否返回操作結果
fsync 是否是直接影響到物理硬盤
justOne 是否只影響一條記錄
例程:
$coll = $mo->db->coll;
$c = array(’a'=>1,’s’=>array(’$lt’=>100));
$options = array(’safe’=>true);
$rs = $coll->remove($c,$options);
$rs為一個array型的數組,包含操作信息
更新數據庫中的記錄(MongoCollection對象):
http://us.php.net/manual/en/mongocollection.update.php
MongoCollection::update(array $criceria,array $newobj,array $options)
array $criteria
array $newobj 要更新的內容
array $options 選項
safe 是否返回操作結果
fsync 是否是直接影響到物理硬盤
upsert 是否沒有匹配數據就添加一條新的
multiple 是否影響所有符合條件的記錄,默認只影響一條
例程:
$coll = $mo->db->coll;
$c = array(’a'=>1,’s’=>array(’$lt’=>100));
$newobj = array(’e'=>’f',’x'=>’y');
$options = array(’safe’=>true,’multiple’=>true);
$rs = $coll->remove($c,$newobj,$options);
$rs為一個array型的數組,包含操作信息
查詢collection獲得單條記錄(MongoCollection類):
http://us.php.net/manual/en/mongocollection.findone.php
arrayMongoCollection::findOne(array $query,array $fields)
array $query 條件
array $fields 要獲得的字段
例程:
$coll = $mo->db->coll;
$query = array(’s’=>array(’$lt’=>100));
$fields = array(’a'=>true,’b'=>true);
$rs = $coll->findOne($query,$fields);
如果有結果就返回一個array,如果沒有結果就返回NULL
查詢collection獲得多條記錄(MongoCollection類):
http://us.php.net/manual/en/mongocollection.find.php
MongoCursorMongoCollection::find(array $query,array $fields)
array $query 條件
array $fields 要獲得的字段
例程:
$coll = $mo->db->coll;
$query = array(’s’=>array(’$lt’=>100));
$fields = array(’a'=>true,’b'=>true);
$cursor = $coll->find($query,$fields);
返回一個游標記錄對象MongoCursor。
針對游標對象MongoCursor的操作(MongoCursor類):
http://us.php.net/manual/en/class.mongocursor.php
循環或的結果記錄:
$cursor = $coll->find($query,$fields);
while($cursor->hasNext()){
$r = $cursor->getNext();
var_dump($r);
}
或者
$cursor = $coll->find($query,$fields);
foreache($cursor as $k=>$v){
var_dump($v);
}
或者
$cursor = $coll->find($query,$fields);
$array= iterator_to_array($cursor);
更多的大小比對為:$gt為大于、$gte為大于等于、$lt為小于、$lte為小于等于、$ne為不等于
補充:
http://us.php.net/manual/en/mongocursor.snapshot.php
在我們做了find()操作,獲得$cursor游標之后,這個游標還是動態的,也就是在我獲得游標到我循環操作完成對應記錄的過程中,默認情況下,這對符合條件的記錄如果增加,結果集也會自動增加。換句話說,在我find()之后,到我的游標循環完成這段時間,如果再有符合條件的記錄被插入到collection,那么這些記錄也會被$cursor獲得。
如果你想在獲得$cursor之后的結果集不變化,需要這樣做:
$cursor = $coll->find($query,$fields);
$cursor->snapshot();
foreache($cursor as $k=>$v){
var_dump($v);
}
</div> 原文地址:http://blog.sina.com.cn/s/blog_664badeb0100zn4z.html