【捷哥浅谈PHP】第十四弹---NoSQL数据库之PHP连接MongoDB

爱死你了

大家好，我又来跟大家啰嗦了，今天外面的天气由于阴天好像不是很热，相比前几天的持续高温，今天已经凉爽了很多，不过出门要记得带伞哦！

好了，今天我们就来完成唐僧师徒的取经大业！

上一回我们讲了MongoDB的游标，索引和聚合，本回我们接着来搞定我们的PHP连接MongoDB数据库！

今天我们来搞定MongoDB的4个核心类：

1，针对mongoDB连接的操作：Mongo
2，针对mongoDB中数据库的操作：MongoDB
3，针对mongoDB中collection的操作：MongoCollection
4，针对查询结果集的操作：MongoCursor

大家还记得我们用PHP使用PDO，使用memcache，是不是都需要在环境下给php打模块，扩展包！

MongoDB同样需要PHP来打模块，编译扩展包：

好，我们来看下编译的步骤：

1）首先下载最新的php mongodb扩展源码，源码可以在http://pecl.php.net/package/mongo下载.
2）然后解压出来
tar zxvf mongo-1.2.6.tgz




3)进入文件夹后，首先运行phpize来准备编译扩展的环境
/usr/local/php/bin/phpize



4)运行后，我们运行./configure脚本来进行配置
./configure --with-php-config=/usr/local/php/bin/php-config




--with-php-config这个参数是告诉配置脚本php-config这个程序的路径

5)这时用make来编译扩展

make && make install
正确编译执行结果如下（下图是编译输出的最后几行）

6)完成后，请编辑你php.ini文件增加一行
extension=mongo.so
一般默认的编译php的ini文件/usr/local/php/etc/php.ini


重启Apache 打开phpinfo
看到mongo模块，证明MongoDB的php扩展安装成功

好，我们来看这四个核心类：
首先，来看第一个类：Mongo（连接）类
先看它的构造方法：

public Mongo::__construct([ string $server = "mongodb://localhost:27017" [, array $options = array("connect" => TRUE) ]] )

通过它的构造方法我们可以看出，实例化的时候可以填写用户名密码，还有主机地址，第二个参数为选项，可以指明主从复制等一些选项，这里不过多去讲了！

好，我们来看以下代码：

复制代码

• <?php
  
• //连接localhost:27017
  
• $conn = new Mongo();
  
• //连接远程主机默认端口
  
• $conn = new Mongo('test.com');
  
• //连接远程主机22011端口
  
• $conn = new Mongo('test.com:22011');
  
• //MongoDB有用户名密码
  
• $conn = new Mongo("mongodb://${username}:${password}@localhost");
  
• //MongoDB有用户名密码并指定数据库blog
  
• $conn = new Mongo("mongodb://${username}:${password}@localhost/blog");
  
• //多个服务器
  
• $conn = new Mongo("mongodb://localhost:27017,localhost:27018");
  
• ?>
  

通过以上事例，我们可以看到，在实例化Mongo类的时候，我们可以指定连接的用户名，密码，地址，端口，要选择的数据库；

还可以什么都不写，不写的情况下，默认进入的是test数据库，如果我们要选择其他数据库，我们这里可以使用以下方法进行选择：

public MongoDB Mongo::selectDB ( string $name )

也就是：

复制代码

• <?php
  
• //选择数据库
  
• $db = $conn->selectDB('dahuaxiyou');
  
• ?>
  

MongoDB选择数据库还有一种很简单的方法，那就是直接使用连接对象调用数据库名称即可：

复制代码

• <?php
  
• //通过数据库名称直接选择数据库
  
• $db = $conn->dahuaxiyou;
  
• ?>
  

我们还可以使用listDBs()方法查看数据库列表：

public array Mongo::listDBs ( void )

这里返回的是一个数组，返回所有数据库的名称等信息！

除此之外还可以使用dropDB方法来删除数据库：

public array Mongo::dropDB ( mixed $db )

最后，Mongo类还有一个很有用的方法，关闭数据库连接的方法：

public bool Mongo::close ( void )

好，我们再来看第二个类------MongoDB（数据库）类：

给数据库用户授权的方法：

public array authenticate ( string $username , string $password )

执行数据库命令的方法：

public array command ( array $command [, array $options = array() ] )

构造方法：

public__construct ( Mongo $conn , string $name )

创建集合的方法：

public MongoCollection createCollection ( string $name [, bool $capped = FALSE [, int $size = 0 [, int $max = 0 ]]] )

删除数据库的方法：

public array drop ( void )

删除集合的方法：

public array dropCollection ( mixed $coll )

返回上一条Mongo错误的方法：

public array lastError ( void )

选择集合的方法：

public MongoCollection selectCollection ( string $name )


第三个类------MongoCollection（集合）类：

构造方法：

public__construct ( MongoDB $db , string $name )

获取文档总数：

public int count ([ array $query = array() [, int $limit = 0 [, int $skip = 0 ]]] )

删除集合内的索引：

public array deleteIndex ( string|array $keys )

删除集合内的所有索引：

public array deleteIndexes ( void )

删除当前集合：

public array drop ( void )

创建索引：

public bool ensureIndex ( string|array $key|keys [, array $options = array() ] )

查询集合内的文档：

public MongoCursor find ([ array $query = array() [, array $fields = array() ]] )

查询集合内满足条件的一条文档：

public array findOne ([ array $query = array() [, array $fields = array() ]] )

新增一条文档：

public bool|array insert ( array $a [, array $options = array() ] )

移除文档：

public bool|array remove ([ array $criteria = array() [, array $options = array() ]] )

新增或更新文档：

public mixed save ( array $a [, array $options = array() ] )

更新文档：

public bool|array update ( array $criteria , array $new_object [, array $options = array() ] )


第四个类------MongoCursor（游标）类：

获取下一个游标：

public array getNext ( void )

判断是否有下一个游标：

public bool hasNext ( void )

显示几条文档：

public MongoCursor limit ( int $num )

将游标向后移一位：

public void next ( void )

将游标跳过N个文档：

public MongoCursor skip ( int $num )

将文档排序：

public MongoCursor sort ( array $fields )

好，通过这四个类，我们就可以写一个简单的新闻发布系统：

index.php 首页列表
复制代码

• <?php
  
• include 'header.php';
  
• if(!empty($_GET['info'])){
  
• echo "<script>alert('".$_GET['info']."')</script>";
  
• }
  
• //$result = $collection->find(array(),array("title"=>1,"ptime"=>1))->sort(array("ptime"=>-1));
  
• //var_dump($result);
  
• ?>
  
• 
  
• <div id='content'>
  
• <?php
  
• //定义页大小
  
• $page_size = 10;
  
• 
  
• //计算文档总数
  
• $count = $collection->count();
  
• 
  
• //当前页码
  
• $page_num = empty($_GET['page'])?'1':$_GET['page'];
  
• 
  
• //查询出当前页
  
• $doc = $collection->find(array(),array("title"=>1,"ptime"=>1))->limit($page_size)->skip(($page_num-1)*$page_size)->sort(array("ptime"=>-1));
  
• 
  
• 
  
• //总页数
  
• $page_count = ceil($count/$page_size);
  
• 
  
• //遍历游标，输出结果集
  
• while($doc->hasNext()){
  
• $res = $doc->getNext();
  
• //var_dump($res);
  
• echo '<div class="doc" >※';
  
• echo $res['title'];
  
• echo '<span>发表时间：'.date('Y-m-d H:i:s',$res['ptime']->sec).'</span></div>';
  
• }
  
• 
  
• ?>
  
• <script>
  
• function show(id){
  
• window.location.href='show.php?id='+id;
  
• }
  
• </script>
  
• <div class="page">
  
• 
  
• <!--分页的链接-->
  
• 
  
• <a href='index.php?page=1'>第一页</a>
  
• <a href='index.php?page=<?php echo (($page_num-1)<=1)?1:($page_num-1);?>'>上一页</a>
  
• <a href='index.php?page=<?php echo (($page_num+1)>=$page_count)?$page_count:($page_num+1);?>'>下一页& lt;/a>
  
• <a href='index.php?page=<?php echo $page_count;?>'>最后一页</a>
  
• 共<?php echo $page_count?>页
  
• 总计<?php echo $count?>条新闻
  
• 当前第<?php echo $page_num?>页
  
• 
  
• </div>
  
• </div>
  
• <?php include 'footer.php'; ?>
  

header.php 页头
复制代码

• <?php include 'Mongoconn.php';?>
  
• <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
  
• <html>
  
• <head>
  
• <title>MongoDB微型新闻发布系统</title>
  
• <link rel="stylesheet" type="text/css" href="ueditor/themes/default/ueditor.css"/>
  
• <meta http-equiv='Content-Type' content='text/html;charset=utf-8'>
  
• <style>
  
• body{
  
• font-family:微软雅黑;
  
• }
  
• #main{
  
• margin:0 auto;
  
• width:960px;
  
• }
  
• #header{
  
• height:100px;
  
• line-height:100px;
  
• border:1px solid #999;
  
• text-align:center;
  
• font-size:30px;
  
• }
  
• #content{
  
• margin-top:10px;
  
• border:1px solid #999;
  
• padding-top:20px;
  
• }
  
• #content .doc{
  
• height:45px;
  
• line-height:45px;
  
• border-bottom:1px dashed #999;
  
• width:90%;
  
• margin:0px auto;
  
• font-size:13px;
  
• padding:0 15px;
  
• cursor:pointer;
  
• }
  
• #content .page{
  
• margin:10px 0;
  
• text-align:center;
  
• height:50px;
  
• line-height:50px;
  
• }
  
• #footer{
  
• height:60px;
  
• line-height:60px;
  
• text-align:center;
  
• margin-top:10px;
  
• border:1px solid #999;
  
• }
  
• .doc span{
  
• float:right;
  
• }
  
• #menu{
  
• height:50px;
  
• border:1px solid #999;
  
• margin-top:10px;
  
• }
  
• #menu ul{
  
• float:right;
  
• }
  
• #menu li{
  
• float:left;
  
• list-style:none;
  
• margin-right:20px;
  
• }
  
• #post{
  
• height:500px;
  
• border:1px solid #999;
  
• margin:10px auto;
  
• padding:30px;
  
• }
  
• #title{
  
• margin-bottom:10px;
  
• }
  
• #sub{
  
• margin-top:10px;
  
• }
  
• #sub input{
  
• width:60px;
  
• height:25px;
  
• margin-right:10px;
  
• }
  
• #show{
  
• border:1px solid #999;
  
• padding:15px;
  
• margin-top:10px;
  
• }
  
• #show_title{
  
• margin:0 auto;
  
• text-align:center;
  
• font-weight:700;
  
• font-size:20px;
  
• color:green;
  
• }
  
• #show_content{
  
• padding: 5px 20px;
  
• font-size:14px;
  
• }
  
• 
  
• </style>
  
• <script src="jquery.js" type="text/javascript" charset="utf-8"></script>
  
• <script type="text/javascript" charset="utf-8" src="./ueditor/editor_config.js"></script>
  
• <script type="text/javascript" charset="utf-8" src="./ueditor/editor_all.js"></script>
  
• <script type="text/javascript">
  
• $(function(){
  
• $('.doc').hover(function(){
  
• $(this).css("background",'#ddd');
  
• },function(){
  
• $(this).css("background","white");
  
• });
  
• });
  
• </script>
  
• </head>
  
• <body>
  
• <div id='main'>
  
• <div id='header'>基于MongoDB的新闻发布系统</div>
  
• <div id='menu'>
  
• <ul>
  
• <li><a href='index.php'>查看新闻</a></li>
  
• <li><a href='add.php'>添加新闻</a></li>
  
• </ul>
  
• </div>
  

Mongoconn.php 连接MongoDB数据库文件
复制代码

• <?php
  
• header('Content-Type:text/html;charset=utf-8');
  
• try{
  
• $conn = new Mongo("mongodb://news:news27017@192.168.88.89/news");
  
• }catch(MongoException $e){
  
• exit("数据库连接错误！".$e->getMessage());
  
• }
  
• $db = $conn->news;
  
• $collection = $db->news;
  
• ?>
  

add.php 添加页面

复制代码

• <?php
  
• include 'header.php';
  
• $_POST['ptime']=new MongoDate();
  
• //var_dump($_POST);
  
• if(!empty($_POST['title'])){
  
• if($collection->insert($_POST)){
  
• header("location:index.php?id=".$_GET['id']."&info=发表成功！");
  
• }
  
• }
  
• ?>
  
• <div id='post'>
  
• <form action='' method='post'>
  
• <div id='title'>
  
• <label name='title'>标题：</lable><input type='text' name='title' style='width:700px' />
  
• </div>
  
• <div id='con'>
  
• <textarea name='content' id='news_content'></textarea>
  
• <script type="text/javascript">
  
• var editor_a = new baidu.editor.ui.Editor();
  
• 
  
• //渲染编辑器
  
• //function render(){
  
• editor_a.render('news_content');
  
• //}
  
• </script>
  
• </div>
  
• <div id='sub'>
  
• <input type='submit' value='提交' />
  
• <input type='reset' value='重填' />
  
• </div>
  
• </form>
  
• </div>
  
• <?php include 'footer.php';?>
  

del.php 删除页面

复制代码

• <?php
  
• include 'mongoconn.php';
  
• if($_GET['id']){
  
• if($collection->remove(array('_id'=>new MongoID($_GET['id'])))){
  
• header('location:index.php?info=删除成功！');
  
• }else{
  
• header('location:index.php?info=删除失败！');
  
• }
  
• }
  
• ?>
  

mod.php修改页面

• <?php
  
• include 'header.php';
  
• if(!empty($_POST['title'])){
  
• if(!empty($_GET['id'])){
  
• if($collection->update(array("_id"=>new MongoID($_GET['id'])),array('$set'=>$_POST))){
  
• header("location:show.php?id=".$_GET['id']."&info=修改成功！");
  
• }
  
• }
  
• }
  
• $result = $collection->findOne(array("_id"=>new MongoID($_GET['id'])),array("title"=>1,"content"=>1));
  
• ?>
  
• <div id='post'>
  
• <form action='' method='post'>
  
• <div id='title'>
  
• <label name='title'>标题：</lable><input type='text' name='title' style='width:92%;' value='<?php echo $result['title']?>' />
  
• </div>
  
• <div id='con'>
  
• <textarea name='content' id='news_content'><?php echo $result['content']?></textarea>
  
• <script type="text/javascript">
  
• var editor_a = new baidu.editor.ui.Editor();
  
• 
  
• //渲染编辑器
  
• //function render(){
  
• editor_a.render('news_content');
  
• //}
  
• </script>
  
• </div>
  
• <div id='sub'>
  
• <input type='submit' value='提交' />
  
• <input type='reset' value='重填' />
  
• </div>
  
• </form>
  
• </div>
  
• <?php include 'footer.php';?>
  

show.php新闻详情页

复制代码

• <?php
  
• include 'header.php';
  
• //var_dump($_GET);
  
• if(!empty($_GET['info'])){
  
• echo "<script>alert('".$_GET['info']."')</script>";
  
• }
  
• if($_GET['id']){
  
• //$collection->remove(array('_id'=>new MongoID($_GET['id'])));
  
• $result = $collection->findOne(array("_id"=>new MongoID($_GET['id'])));
  
• //var_dump($result);
  
• }
  
• ?>
  
• <div id='show'>
  
• <div id='show_title'>
  
• <?php echo $result['title']?>
  
• </div>
  
• <div style='height:10px;border-top:1px dashed #999;margin:15px 0;text-align:right;font-size:12px;line-height:30px'>
  
• 发表于：<?php echo date("Y-m-d H:i:s",$result['ptime']->sec) ?>
  
• </div>
  
• <div id='show_content'>
  
• <?php echo $result['content']?>
  
• <div style='font-size:13px;text-align:right'><span><a href='mod.php?id=<?php echo $result['_id']?>'>编辑</a> | </span><span><a href='del.php?id=<?php echo $result['_id']?>'>删除</a> </span></div>
  
• </div>
  
• </div>
  
• 
  
• <?php include 'footer.php'?>
  

footer.php 页脚

复制代码

• <div id='footer'>版权归LAMP兄弟连所有</div>
  
• </div>
  
• </body>
  
• </html>
  

注意：在MongoDB当中传递_id的时候，需要使用new MongoId($_GET['id'])，把_id转为Mongo对象的ID，才能找到数据库中的文档！
分页的原理如果还是不明白，可以查看【捷哥浅谈PHP】第五弹---分页之九阳神功
至此，我们的MongoDB就全部学完，如学习过程当中有什么不明白的，可以跟帖留言，或者跟我QQ交流：86267659，或者进我的微博：http://weibo.com/u/1372373023

MongoDB系列文章：
【捷哥浅谈PHP】第九弹---NoSQL数据库之MongoDB的介绍及安装
【捷哥浅谈PHP】第十弹---NoSQL数据库之MongoDB的CURD操作（一）
【捷哥浅谈PHP】第十一弹---NoSQL数据库之MongoDB的CURD操作（二）
【捷哥浅谈PHP】第十二弹---NoSQL数据库之MongoDB的CURD操作（三）
【捷哥浅谈PHP】第十三弹---NoSQL数据库之MongoDB的CURD操作（四）

更多精彩，请猛击：
【捷哥浅谈PHP】第一弹---php位运算符”|”和逻辑运算符”||”遇到的问题
【捷哥浅谈PHP】第二弹---经典算法的运用(冒泡排序和快速排序)
【捷哥浅谈PHP】第三弹---使用二分查找法查找数组中的元素位置
【捷哥浅谈PHP】第四弹---递归函数
【捷哥浅谈PHP】第五弹 --- 分页之九阳神功
【捷哥浅谈PHP】第六弹 ---- 使用for循环输出九九乘法表
【捷哥浅谈PHP】第七弹 ---- 基于角色的访问控制RBAC
【捷哥浅谈PHP】第八弹---使用PHP的date函数输出日历

原文地址：http://bbs.lampbrother.net/read-htm-tid-120215.html