PHP操作MongoDB实例

从mysql中把数据导入到MongoDB中做测试.

//连接数据库
$link = mysql_connect("127.0.0.1","root","123456");
mysql_select_db("jiang", $link);
mysql_query("set names utf-8");
$sql = "select `id`,`name`,`address` from member";
$result = mysql_query($sql);
//实例化Mongo
$mongo = new Mongo();
//选择数据库
$db = $mongo->selectDB("post")->member;
//从数据库中取出数据存入mongodb
while($row = mysql_fetch_array($result,MYSQLI_ASSOC)){
$res = $db->insert(array("vid"=>(float)$row['id'],"name"=>$row['name'],"address"=>$row['address']));
}
//查询当前文档的数据总数
$tp = $db->find()->count();
$page = isset($_GET['page']) ? max(1,(int)$_GET['page']) : 1;
//每页显示的数量
$pagesize = 50;
//设置分页
$skip = ($page-1) * $pagesize;
//总页数
$totalPage = ceil($tp/$pagesize);
//获取数据
$data = $db->find()->fields(array("_id"=>0))->sort(array('_id'=>-1))->skip($skip)->limit($pagesize);
$list = array();
foreach ($data as $key => $val) {
$list[] = $val;
}