PHP7 MongoDB 使用方法

努力前行 發表於 2019-7-4 19:37:00

原文链接: http://www.zhaokeli.com/article/8574.html
<div class="smcon">
<h1>MongoDb原生操作</h1>

<h2>Mongodb连接</h2>
PHP7 连接 MongoDB 语法如下：
复制代码
<pre class="php hljs inited">$manager = new MongoDB\Driver\Manager("mongodb://localhost:27017");</pre>

<h2>插入数据</h2>
将 name 为"自学教程" 的数据插入到 test 数据库的 runoob 集合中。
复制代码
<pre class="php hljs inited">$bulk = new MongoDB\Driver\BulkWrite;
$document = ['_id' => new MongoDB\BSON\ObjectID, 'name' => '菜鸟教程'];
 
$_id= $bulk->insert($document);
 
var_dump($_id);
 
$manager = new MongoDB\Driver\Manager("mongodb://localhost:27017");  
$writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);
$result = $manager->executeBulkWrite('test.runoob', $bulk, $writeConcern);</pre>

<h2>读取数据</h2>
复制代码
<pre class="php hljs inited">$manager = new MongoDB\Driver\Manager("mongodb://localhost:27017");  
 
// 插入数据
$bulk = new MongoDB\Driver\BulkWrite;
$bulk->insert(['x' => 1, 'name'=>'baidu', 'url' => 'http://www.baidu.com']);
$bulk->insert(['x' => 2, 'name'=>'Google', 'url' => 'http://www.google.com']);
$bulk->insert(['x' => 3, 'name'=>'taobao', 'url' => 'http://www.taobao.com']);
$manager->executeBulkWrite('test.sites', $bulk);
 
$filter = ['x' => ['$gt' => 1]];
$options = [
    'projection' => ['_id' => 0],
    'sort' => ['x' => -1],
];
 
// 查询数据
$query = new MongoDB\Driver\Query($filter, $options);
$cursor = $manager->executeQuery('test.sites', $query);
 
foreach ($cursor as $document) {
    print_r($document);
}</pre>

<h2>更新数据</h2>
复制代码
<pre class="php hljs inited">$bulk = new MongoDB\Driver\BulkWrite;
$bulk->update(
    ['x' => 2],
    ['$set' => ['name' => '菜鸟工具', 'url' => 'tool.runoob.com']],
    ['multi' => false, 'upsert' => false]
);
 
$manager = new MongoDB\Driver\Manager("mongodb://localhost:27017");  
$writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);
$result = $manager->executeBulkWrite('test.sites', $bulk, $writeConcern);</pre>

<h2>删除数据</h2>
复制代码
<pre class="php hljs inited">$bulk = new MongoDB\Driver\BulkWrite;
$bulk->delete(['x' => 1], ['limit' => 1]);   // limit 为 1 时，删除第一条匹配数据
$bulk->delete(['x' => 2], ['limit' => 0]);   // limit 为 0 时，删除所有匹配数据
 
$manager = new MongoDB\Driver\Manager("mongodb://localhost:27017");  
$writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);
$result = $manager->executeBulkWrite('test.sites', $bulk, $writeConcern);</pre>

<h1>MongoDB官方操作库</h1>
看完上面的CURD操作是不是感觉有点懵逼，操作方式跟想像中的完全不一样，<img src="http://img.baidu.com/hi/tsj/t_0038.gif">可能官方也想到啦这一块，于是又封装啦一个操作库让大家使用。文档地址如下
https://docs.mongodb.com/php-library/current/tutorial/crud/

<h2>安装</h2>
复制代码
<pre class="bash hljs inited">composer require mongodb/mongodb</pre>

<h2>添加数据</h2>

<h3>插入单条数据</h3>
在数据库test中的users集合中插入数据，如果数据库或集合不存在则会自动创建
复制代码
<pre class="php hljs inited">$collection      = (new MongoDB\Client)->test->users;
$insertOneResult = $collection->insertOne([
    'username' => 'admin',
    'email'    => 'admin@example.com',
    'name'     => 'Admin User',
]);
printf("Inserted %d document(s)\n", $insertOneResult->getInsertedCount());
var_dump($insertOneResult->getInsertedId());</pre>
输出结果
<img title="image.png" alt="1905281559025619827923.png" data-src="https://res.zkeli.com/uploads/image/2019/05/1905281559025619827923.png">
数据库中数据
<img src="https://res.zkeli.com/uploads/image/2019/05/1905281559025567787873.png">
可以看出返回$oid为数据库自动分配的唯一标识，如果我们插入的时候传入id值的话，mongodb会判断这个id是否存在，如果存在就会报错，如果不存在则直接返回传入的id值
复制代码
<pre class="php hljs inited">$collection      = (new MongoDB\Client)->test->users;
$insertOneResult = $collection->insertOne(['_id' => 1, 'name' => 'Alice']);
printf("Inserted %d document(s)\n", $insertOneResult->getInsertedCount());
var_dump($insertOneResult->getInsertedId());</pre>
执行结果
<img src="https://res.zkeli.com/uploads/image/2019/05/1905281559025985889303.png">

<h3>插入多条数据</h3>
复制代码
<pre class="php hljs inited">$collection = (new MongoDB\Client)->test->users;
$insertManyResult = $collection->insertMany([
    [
        'username' => 'admin',
        'email' => 'admin@example.com',
        'name' => 'Admin User',
    ],
    [
        'username' => 'test',
        'email' => 'test@example.com',
        'name' => 'Test User',
    ],]);
printf("Inserted %d document(s)\n", $insertManyResult->getInsertedCount());
var_dump($insertManyResult->getInsertedIds());</pre>
<img src="https://res.zkeli.com/uploads/image/2019/05/1905281559026233129220.png">

<h2>查询数据</h2>
如果要使用id查询,则需要使用下面的ObjectId类来封装下传进去

<h3>使用自增id查询</h3>
复制代码
<pre class="php hljs inited">$collection = (new MongoDB\Client)->test->users;
$id         = new \MongoDB\BSON\ObjectId('5cecd708ab4e4536fc0076e2');
$document   = $collection->findOne(['_id' => $id]);
var_dump($document);</pre>

<h3>其它条件查询</h3>
使用其它条件数据则直接传进去就可以 
复制代码
<pre class="php hljs inited">$collection = (new MongoDB\Client)->test->users;
$document   = $collection->findOne(['username' => 'admin']);
var_dump($document);</pre>
<img src="https://res.zkeli.com/uploads/image/2019/05/1905281559027257136568.png">

<h3>使用limit,sort,skip查询</h3>
默认情况下是返回所有的字段数据，也可以指定字段返回，limit是返回的行数，sort是使用name字段-1为降序，1为升序，skip为跳过前多少条数据如下
复制代码
<pre class="php hljs inited">$collection = (new MongoDB\Client)->test->users;
$cursor     = $collection->find(
    [
        'username' => 'admin',
    ],
    [
        'projection' => [
            'email' => 1,
        ],
        'limit'      => 4,
        'sort'       => ['name' => -1],
        'skip'       =>1,
    ]);
foreach ($cursor as $restaurant) {
    var_dump($restaurant);
}</pre>
<h3>正则条件查询</h3>
复制代码
<pre class="php hljs inited">$collection = (new MongoDB\Client)->test->users;
$cursor     = $collection->find(
    [
        'username' => new MongoDB\BSON\Regex('^ad', 'i'),
    ],
    [
        'projection' => [
            'email' => 1,
        ],
        'limit'      => 1,
        'sort'       => ['pop' => -1],
    ]);
foreach ($cursor as $restaurant) {
    var_dump($restaurant);
}</pre>
另外一种正则式的写法
复制代码
<pre class="php hljs inited">$collection = (new MongoDB\Client)->test->users;
$cursor     = $collection->find(
    [
        'username' => ['$regex' => '^ad', '$options' => 'i'],
    ],
    [
        'projection' => [
            'email' => 1,
        ],
        'limit'      => 1,
        'sort'       => ['pop' => -1],
    ]);
foreach ($cursor as $restaurant) {
    var_dump($restaurant);
}</pre>
<h3>查询多个数据</h3>
复制代码
<pre class="php hljs inited">$collection = (new MongoDB\Client)->test->users;
$cursor     = $collection->find(['username' => 'admin']);
foreach ($cursor as $document) {
    echo $document['_id'], "\n";
}</pre>
<img src="https://res.zkeli.com/uploads/image/2019/05/1905281559027339129636.png">
<h2>更新数据</h2>
<h3>更新单条数据</h3>
复制代码
<pre class="php hljs inited">$collection   = (new MongoDB\Client)->test->users;
$updateResult = $collection->updateOne(
    ['username' => 'admin'],
    ['$set' => ['name' => 'new nickname']]
);
printf("Matched %d document(s)\n", $updateResult->getMatchedCount());
printf("Modified %d document(s)\n", $updateResult->getModifiedCount());</pre>
<img src="https://res.zkeli.com/uploads/image/2019/05/1905281559029206114764.png">
<h3>更新多条数据</h3>
复制代码
<pre class="php hljs inited">$collection   = (new MongoDB\Client)->test->users;
$updateResult = $collection->updateMany(
    ['username' => 'admin'],
    ['$set' => ['name' => 'new nickname']]
);
printf("Matched %d document(s)\n", $updateResult->getMatchedCount());
printf("Modified %d document(s)\n", $updateResult->getModifiedCount());</pre>
<img src="https://res.zkeli.com/uploads/image/2019/05/1905281559029272301679.png">
<h3>替换文档</h3>
替换文档其它跟更新数据类似，但是这个操作不会修改id,如下
复制代码
<pre class="php hljs inited">$collection   = (new MongoDB\Client)->test->users;
$updateResult = $collection->replaceOne(
    ['username' => 'admin'],
    ['username' => 'admin2', 'name' => 'new nickname']
);
printf("Matched %d document(s)\n", $updateResult->getMatchedCount());
printf("Modified %d document(s)\n", $updateResult->getModifiedCount());</pre>
<h3>Upsert操作</h3>
这个名字应该是个缩写，更新或替换操作时如果有匹配的数据则直接操作，如果没有匹配的数据则插入一条新数据，意思是如果更新或替换操作的第三个参数如果传 'upsert'=>True 的话就可以开启这个功能
复制代码
<pre class="php hljs inited">$collection   = (new MongoDB\Client)->test->users;
$updateResult = $collection->updateOne(
    ['username' => 'admin3'],
    ['$set' => ['username' => 'admin2', 'name' => 'new nickname']],
    ['upsert' => true]
);
printf("Matched %d document(s)\n", $updateResult->getMatchedCount());
printf("Modified %d document(s)\n", $updateResult->getModifiedCount());
printf("Upserted %d document(s)\n", $updateResult->getUpsertedCount());
$upsertedDocument = $collection->findOne([
    '_id' => $updateResult->getUpsertedId(),
]);
var_dump($upsertedDocument);</pre>
如果有匹配的情况下最后输出为NULl
<img src="https://res.zkeli.com/uploads/image/2019/05/1905281559030215132171.png">
没有匹配的情况下最后输出插入的数据
<img src="https://res.zkeli.com/uploads/image/2019/05/1905281559030085203984.png">
<h2>删除数据</h2>
复制代码
<pre class="php hljs inited">$collection   = (new MongoDB\Client)->test->users;
$deleteResult = $collection->deleteOne(['username' => 'admin3']);
printf("Deleted %d document(s)\n", $deleteResult->getDeletedCount());
$deleteResult = $collection->deleteMany(['username' => 'admin2']);
printf("Deleted %d document(s)\n", $deleteResult->getDeletedCount());</pre>
<img src="https://res.zkeli.com/uploads/image/2019/05/1905281559030350141184.png">
</div> 
来源：https://www.cnblogs.com/rxbook/p/11134502.html

頁: [1]

琼殿技术论坛's Archiver

PHP7 MongoDB 使用方法