phalapi / mongo
PhalApi 2.x 扩展类库 - 使用 MongoDB 的扩展
dev-master
2020-06-14 08:48 UTC
Requires
- php: >=7.1
- ext-json: *
- ext-mongodb: *
- mongodb/mongodb: *
This package is auto-updated.
Last update: 2024-10-14 18:40:09 UTC
README
前言
使用 MongoDB 存储数据时,用到此扩展。
注意:
由于MongoDB在 PHP5.6之前的驱动与 PHP7.0 以后的驱动完全不一致,所以此项目建议使用 PHP7.1以上,建议使用当前较新的 PHP7.2或7.3版本。 php的windows驱动下载地址:https://windows.php.net/downloads/pecl/releases/mongodb/,下载到 ext 目录,并加到php.ini文件中。 其他系统的可以使用 yum/apt等工具下载安装
安装及配置方法:
-
在 config 目录下,新建一个文件:config/mongo.php,内容如下
<?php return array( 'mongo' => array( 'host' => 'localhost', // 连接主机 'port' => '27017', // 端口 'db_name' => 'wxwork', // 连接MongoDB的库 'username' => 'wxwork', //登录用户名 'password' => 'wxwork', // 密码 'connect_timeout_ms' => '', // tcp连接超时时间 'socket_timeout_ms' => '', // socket超时时间 'persist' => 'x', // 连接保持(MongoDB3.*新增) ), 'wkuser' => 'wkuser', // MongoDB 的库中的集合 collection,类似于数据库的一张表 );
-
在 config/di.php 靠后的位置加入一行:
$di->mongo = new PhalApi\Mongo\Lite($di->config->get('mongo.mongo'));
-
在 composer.json 中的 require 中加入一行: (说明:暂时未支持,后续争取支持使用 phalapi/mongo)
"phalapi/mongo": "dev-master"
-
执行命令:
php composer.phar update --no-interaction --ansi
-
可以开始测试了。
-
问题:在使用较低版本的 mongodb 驱动连接较低MongoDB服务器时,会提示:Authentication failed。这时使用较新的驱动即可解决。
使用方法:
各种使用方法示例,请参考 demo_app 目录下的 Site.php 。
其他无示例的操作,可以调用 command 函数进行封装。
如果您有其他命令要封装,请发issue ,我会尽力增加到项目中。
- 插入示例:
$mong = DI()->mongo; // $arr_user = $this->object2array($user); // 把接收到的 json 值转为数组 $user = array ( 'userid' => 'bob', 'name' => 'Bob', 'english_name' => '', 'mobile' => '', 'department' => array ( 0 => 15, ), 'order' => array ( 0 => 0, ), 'position' => '', 'gender' => '0', 'email' => '', 'telephone' => '', 'isleader' => 0, 'avatar_mediaid' => NULL, 'enable' => 1, 'extattr' => array ( 'attrs' => NULL, ), 'status' => 4, ); $es = ""; try{ $ns = DI()->config->get('mongo.namespace'); $msg = $mong->insert($arr_user, $ns.".wkuser") != true; if ( $msg ){ $es = $msg; } else { // 其他提示 } } catch (Exception $e){ DI()->logger->error("插入或更新用户失败:", json_encode($arr_user) . $e->getMessage() ); $es = $e->getMessage(); }
- 读取: (其他操作,请参考demo)