PHP7 mongoDB扩展使用

栏目: PHP · 发布时间: 4年前

内容简介:最近在做的项目需要将PHP5.6升级到PHP7.0,使用过PHP-mongo扩展的同学应该知道,PHP7.0的mongodb扩展是完全不兼容PHP5.6的mongo扩展的,php-mongodb改如何使用呢。下面直接说明各种方法的使用:

最近在做的项目需要将 PHP 5.6升级到PHP7.0,使用过PHP-mongo扩展的同学应该知道,PHP7.0的 mongodb 扩展是完全不兼容PHP5.6的mongo扩展的,php-mongodb改如何使用呢。

下面直接说明各种方法的使用:

1.mongodb连接:

private function connect($confArr) {
    try{
        $connStr = "mongodb://" . $confArr['host'] . ":" . $confArr['port'] . "/" . $confArr['db_name'];
        $options = array(
            'username' => $confArr['username'],
            'password' => $confArr['password'],
            'readPreference' => $confArr['read_preference'],
            'connectTimeoutMS' => intval($confArr['connect_timeout_ms']),
            'socketTimeoutMS' => intval($confArr['socket_timeout_ms']),
        );
        $mc = new MongoDB\Driver\Manager($connStr, $options);
        return $mc;
    }
    catch(Exception $e){
        return false;
    }
}

2.查询find:

public function find($query = array(), $fields = array(), $collection, $sort = array(), $limit = 0, $skip = 0) {
    $conn = $this->connect();
    if (empty($conn)) {
        return false;
    }
    try {
        $data = array();
        $options = array();
        if (!empty($query)) {
            $options['projection'] = array_fill_keys($fields, 1);
        }
        if (!empty($sort)) {
            $options['sort'] = $sort;
        }
        if (!empty($limit)) {
            $options['skip'] = $skip;
            $options['limit'] = $limit;
        }
        $mongoQuery = new MongoDB\Driver\Query($query, $options);
        $readPreference = new MongoDB\Driver\ReadPreference(MongoDB\Driver\ReadPreference::RP_SECONDARY);
        $cursor = $conn->executeQuery($collection, $mongoQuery, $readPreference);
        foreach($cursor as $value) {
            $data[] = (array)$value;
        }
        return $data;
    } catch (Exception $e) {
        //记录错误日志
    }
    return false;
}

3.插入操作insert:

public function insert($addArr, $collection) {
    if (empty($addArr) || !is_array($addArr)) {
        return false;
    }
    $conn = $this->connect();
    if (empty($conn)) {
        return false;
    }
    try {
        $bulk = new MongoDB\Driver\BulkWrite();
        $bulk->insert($addArr);
        $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 6000);
        $result = $conn->executeBulkWrite($collection, $bulk, $writeConcern);
        if ($result->getInsertedCount()) {
            return true;
        }
    } catch (Exception $e) {
        //记录错误日志
    }
    return false;
}

4.删除delete:

public function delete($whereArr, $options = array(), $collection) {
    if (empty($whereArr)) {
        return false;
    }
    if (!isset($options['justOne'])) {
        $options = array(
            'justOne' => false,
        );
    }
    $conn = $this->connect();
    if (empty($conn)) {
        return false;
    }
    try {
        $bulk = new MongoDB\Driver\BulkWrite();
        $bulk->delete($whereArr, $options);
        $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 30000);
        $result = $conn->executeBulkWrite($collection, $bulk, $writeConcern);
        return true;
    } catch (Exception $e) {
        //记录错误日志
    }
    return false;
}

5.执行command操作:

private function command($params, $dbName) {
    $conn = $this->connect();
    if (empty($conn)) {
        return false;
    }
    try {
        $cmd = new MongoDB\Driver\Command($params);
        $result = $conn->executeCommand($dbName, $cmd);
        return $result;
    } catch (Exception $e) {
        //记录错误
    }
    return false;
}

6.统计count:

public function count($query, $collection) {
    try {
        $cmd = array(
            'count' => $collection,
            'query' => $query,
        );
        $res = $this->command($cmd);
        $result = $res->toArray();
        return $result[0]->n;
    } catch (Exception $e) {
        //记录错误
    }
    return false;
}

7.聚合distinct:

public function distinct($key, $where, $collection) {
    try {
        $cmd = array(
            'distinct' => $collection,
            'key' => $key,
            'query' => $where,
        );
        $res = $this->command($cmd);
        $result = $res->toArray();
        return $result[0]->values;
    } catch (Exception $e) {
        //记录错误
    }
    return false;
}

8.aggregate操作:

public function aggregate($where, $group, $collection) {
    try {
        $cmd = array(
            'aggregate' => $collection,
            'pipeline' => array(
                array(
                    '$match' => $where,
                ),
                array(
                    '$group' => $group,
                ),
            ),
            'explain' => false,
        );
        $res = $this->command($cmd);
        if (!$res) {
            return false;
        }
        $result = $res->toArray();
        return $result[0]->total;
    } catch (Exception $e) {
        //记录错误
    }
    return false;
}

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持 码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

網絡社會之崛起

網絡社會之崛起

曼威·柯司特 / 夏鑄九、王志弘 等 / 唐山 / 2000-11 / NT$550

本書解釋了今日重塑世界的兩股強大但相互衝突的潮流:全球化與認同。資訊科技的革命以及資本主義的再結構已經引動了網絡社會,並帶來了策略,除經濟行為的全球化、工作的彈性化與不穩定,以及真實的虛擬文化。但是,伴隨著資本主義的轉化與國家主義的消亡而來的,是集體認同的表達以火力十足的方式竄起。它們挑戰了全球化中的文化單一性以及對於生活、環境的控制。曼威.柯司特在本書中描繪了社會運動的根源、目標以及效果,包括了......一起来看看 《網絡社會之崛起》 这本书的介绍吧!

Base64 编码/解码
Base64 编码/解码

Base64 编码/解码

URL 编码/解码
URL 编码/解码

URL 编码/解码

SHA 加密
SHA 加密

SHA 加密工具