用Python操作MongoDB

水深无声 2021-09-29 03:32 395阅读 0赞

**MongoDB简介**（摘自：[http://www.runoob.com/mongodb/mongodb-intro.html][http_www.runoob.com_mongodb_mongodb-intro.html]）

MongoDB 由C++语言编写，是一个基于分布式文件存储的开源数据库系统。

MongoDB 将数据存储为一个文档，数据结构由键值对(key=>value)组成，类似于 JSON 对象。

MongoDB 属于NoSQL，NoSQL即Not Only SQL，意思是"不仅仅是SQL"，泛指非关系型数据库。

（关系数据库管理系统（RDBMS）与非关系型数据库（NoSQL）之间的区别请见：[https://www.cnblogs.com/HuZihu/p/10233242.html][https_www.cnblogs.com_HuZihu_p_10233242.html]）

**MongoDB的一些基本术语**

<table> 
 <tbody> 
 <tr> 
 <th>SQL术语/概念</th> 
 <th>MongoDB术语/概念</th> 
 <th>解释/说明</th> 
 </tr> 
 <tr> 
 <td>database</td> 
 <td>database</td> 
 <td>数据库</td> 
 </tr> 
 <tr> 
 <td>table</td> 
 <td>collection</td> 
 <td>数据库表/集合</td> 
 </tr> 
 <tr> 
 <td>row</td> 
 <td>document</td> 
 <td>数据记录行/文档</td> 
 </tr> 
 <tr> 
 <td>column</td> 
 <td>field</td> 
 <td>数据字段/域</td> 
 </tr> 
 <tr> 
 <td>index</td> 
 <td>index</td> 
 <td>索引</td> 
 </tr> 
 <tr> 
 <td>table joins</td> 
 <td>&nbsp;</td> 
 <td>表连接,MongoDB不支持</td> 
 </tr> 
 <tr> 
 <td>primary key</td> 
 <td>primary key</td> 
 <td>主键,MongoDB自动将_id字段设置为主键</td> 
 </tr> 
 </tbody> 
</table>

**使用Python操作MongoDB**

接下来我们用python来操作MongDB，首先需要安装**PyMongo库**（pip install pymongo）。

**连接MongoDB**：

import pymongo
    client=pymongo.MongoClient(host='localhost',port=27017)

注：

host为指定的连接服务器的地址，设置为'localhost'代表连接到本地的MongoDB服务上

port为指定的端口，如果不填，默认为27017

**查看MongoDB中的所有数据库**：

dblist=client.list_database_names()

结果显示现有3个数据库：

['admin', 'config', 'local']

**创建或指定数据库**：

db=client['HuziHu']

（注：在MongoDB中，数据库只有在内容插入后才会创建）

**创建或指定集合：**（集合类似于关系型数据库中的表格）

collection=db['Xiaoyugan']

（注：在MongoDB中，集合只有在内容插入后才会创建）

**查看指定数据库中的所有集合**：

collist=db.list_collection_names()

**插入数据**：（我们可以自行指定每条数据的id--**"\_id"**；如果我们在插入数据时没有指定 **\_id**，那么MongoDB 会为每条数据添加一个唯一的id。）

**插入单条数据：insert\_one()**

yugan={
        "Name":"Xiaoyugan", "Type":"001", "Flavor":"Spicy","Num":4,"Comment":"Don\'t like it.Too hot!"}
    collection.insert_one(yugan)

注：insert\_one()方法返回**InsertOneResult**对象，该对象包含 **inserted\_id** 属性，它是插入数据的id值。

**插入多条数据：insert\_many()**

yugan=[{
        "Name":"Xiaoyugan", "Type":"001", "Flavor":"Spicy","Num":4,"Comment":"Don\'t like it.Too hot!"},
           {
         "Name":"Xiaoyugan", "Type":"002", "Flavor":"Sweet","Num":2,"Comment":"Don\'t like it.Too sweet!"},
           {
         "Name":"Xiaoyugan", "Type":"004", "Flavor":"Fish","Num":16,"Comment":"liked it."}]
    collection.insert_many(yugan)

注：insert\_many()方法返回**InsertManyResult**对象，该对象包含 **inserted\_ids** 属性，该属性保存着所有插入数据的id值。

**查看数据的id值：xx.inserted\_id（对于单条数据）**

**                            xx.inserted\_ids（对于多条数据）**

**查看指定集合中的所有数据：**

for i in collection.find():
        print(i)

**查询数据：**

**查询单条数据：find\_one(...)   **\---返回符合查询条件的第一条结果，如果没有符合查询条件的结果，那么返回None

query={
        "Type":"004"}
    
    print(collection.find_one(query))

结果：

{
        '_id': ObjectId('5c330ea47eb8d621f8d0a351'), 'Name': 'Xiaoyugan', 'Type': '004', 'Flavor': 'Fish', 'Num': 16, 'Comment': 'liked it.'}

**查询所有数据：find(...)   **\---返回符合查询条件的所有结果，如果没有符合查询条件的结果，那么返回None

query={
        "Type":"004"}
    
    for i in collection.find(query):
        print(i)

结果：

{
        '_id': ObjectId('5c330ea47eb8d621f8d0a351'), 'Name': 'Xiaoyugan', 'Type': '004', 'Flavor': 'Fish', 'Num': 16, 'Comment': 'liked it.'}
    {
         '_id': ObjectId('5c330f6e7eb8d621f8d0a355'), 'Name': 'Xiaoyugan', 'Type': '004', 'Flavor': 'Fish', 'Num': 16, 'Comment': 'liked it.'}
    {
         '_id': ObjectId('5c330f857eb8d621f8d0a359'), 'Name': 'Xiaoyugan', 'Type': '004', 'Flavor': 'Fish', 'Num': 16, 'Comment': 'liked it.'}

**查询条件可以使用修饰符：**

<table> 
 <tbody> 
 <tr> 
 <td> 符号 </td> 
 <td> 含义 </td> 
 <td> 语法 </td> 
 </tr> 
 <tr> 
 <td> $lt </td> 
 <td> 小于 </td> 
 <td> {field: {'$lt': value} } </td> 
 </tr> 
 <tr> 
 <td> $gt </td> 
 <td> 大于 </td> 
 <td> {field: {'$gt': value} } </td> 
 </tr> 
 <tr> 
 <td> $lte </td> 
 <td> 小于等于 </td> 
 <td> {field: {'$lte': value} } </td> 
 </tr> 
 <tr> 
 <td> $gte </td> 
 <td> 大于等于 </td> 
 <td> {field: {'$gte': value} } </td> 
 </tr> 
 <tr> 
 <td> $ne </td> 
 <td> 不等于 </td> 
 <td> {field: {'$ne': value} } </td> 
 </tr> 
 <tr> 
 <td> $in </td> 
 <td> 在范围内 </td> 
 <td> {field: {'$in': [ &lt;value1&gt;, &lt;value2&gt; ... &lt;valueN&gt; ]} } </td> 
 </tr> 
 <tr> 
 <td> $nin </td> 
 <td> 不在范围内 </td> 
 <td> { field: { '$nin': [ &lt;value1&gt;, &lt;value2&gt; ... &lt;valueN&gt; ]} } </td> 
 </tr> 
 <tr> 
 <td> $and </td> 
 <td> 和 </td> 
 <td> &nbsp;{ '$and': [ { &lt;expression1&gt; }, { &lt;expression2&gt; } , ... , { &lt;expressionN&gt; } ] } </td> 
 </tr> 
 <tr> 
 <td> $or </td> 
 <td> &nbsp;或 </td> 
 <td> &nbsp;{ '$or': [ { &lt;expression1&gt; }, { &lt;expression2&gt; }, ... , { &lt;expressionN&gt; } ] } </td> 
 </tr> 
 <tr> 
 <td> $not </td> 
 <td> &nbsp;不是 </td> 
 <td>&nbsp;{ field: { '$not': { &lt;operator-expression&gt; } } }</td> 
 </tr> 
 </tbody> 
</table>

## ##

**此外，查询还可以使用一些功能符号：**

<table style="width:669px;"> 
 <tbody> 
 <tr> 
 <td> 符号 </td> 
 <td> 含义 </td> 
 <td> 示例 </td> 
 <td> 示例含义 </td> 
 </tr> 
 <tr> 
 <td> $regex </td> 
 <td> 匹配正则表达式 </td> 
 <td> {'name': {'$regex': '^M.*'}} </td> 
 <td> name以M开头 </td> 
 </tr> 
 <tr> 
 <td> $exists </td> 
 <td> 属性是否存在 </td> 
 <td> {'name': {'$exists': True}} </td> 
 <td> name属性存在 </td> 
 </tr> 
 <tr> 
 <td> $type </td> 
 <td> 类型判断 </td> 
 <td> {'age': {'$type': 'int'}} </td> 
 <td> age的类型为int </td> 
 </tr> 
 <tr> 
 <td> $mod </td> 
 <td> 数字模操作 </td> 
 <td> {'age': {'$mod': [5, 0]}} </td> 
 <td> 年龄模5余0 </td> 
 </tr> 
 <tr> 
 <td> $text </td> 
 <td> 文本查询 </td> 
 <td> {'$text': {'$search': 'Mike'}} </td> 
 <td> text类型的属性中包含Mike字符串 </td> 
 </tr> 
 <tr> 
 <td> $expr </td> 
 <td> 使用聚合表达式 </td> 
 <td> { '$expr': {'$gt':['$fans_count', '$follows_count']} } </td> 
 <td>粉丝数大于关注数</td> 
 </tr> 
 </tbody> 
</table>

对查询条件更多的说明请见官方文档：[https://docs.mongodb.com/manual/reference/operator/query/][https_docs.mongodb.com_manual_reference_operator_query]。

**限制返回查询结果的条数：limit(...)**

query={
        "Comment":{
        "$regex":"^Don"}}
    
    for i in collection.find(query).limit(2):
        print(i)

结果：

{
        '_id': ObjectId('5c330d667eb8d621f8d0a34d'), 'Name': 'Xiaoyugan', 'Type': '001', 'Flavor': 'Spicy', 'Num': 4, 'Comment': "Don't like it.Too hot!"}
    {
         '_id': ObjectId('5c330ea47eb8d621f8d0a34f'), 'Name': 'Xiaoyugan', 'Type': '001', 'Flavor': 'Spicy', 'Num': 4, 'Comment': "Don't like it.Too hot!"}

**统计查询结果的条数：count\_documents(...)**

query={
        "Type":"004"}
    
    print(collection.count_documents(query))

**对查询结果进行排序：sort(...)**

for i in collection.find().sort('Num', pymongo.ASCENDING):
        print(i)

注：pymongo.ASCENDING为升序，pymongo.DESCENDING为降序。

**更新数据：**

**更新单条数据： update\_one(..., ...)**   --- 修改符合查询条件的第一条数据

query={
        'Flavor': 'Spicy'}
    newvalue={
        "Flavor":"Hot"}
    
    collection.update_one(query,{
         '$set':newvalue})

**更新多条数据： update\_many(..., ...)**   --- 修改符合查询条件的所有数据

query={}
    newvalue={
        'Num':1}
    
    collection.update_many(query,{
         '$inc': newvalue})

注：返回结果是UpdateResult类型，分别调用**matched\_count**和**modified\_count**属性，可以获得匹配的数据条数和影响的数据条数。

** **

**一些常用的更新操作符：**

<table style="width:669px;"> 
 <tbody> 
 <tr> 
 <td> 符号 </td> 
 <td> 含义 </td> 
 </tr> 
 <tr> 
 <td> $rename </td> 
 <td> 重新命名字典的键 </td> 
 </tr> 
 <tr> 
 <td> $set </td> 
 <td> 设置字典的值 </td> 
 </tr> 
 <tr> 
 <td> $unset </td> 
 <td> 去除字典的键 </td> 
 </tr> 
 <tr> 
 <td> $inc </td> 
 <td> 增加字典的值 </td> 
 </tr> 
 <tr> 
 <td> $setOnInsert </td> 
 <td> 对已有的数据不更新，只插入原本不存在的数据 </td> 
 </tr> 
 </tbody> 
</table>

**删除数据：**

**删除单条数据： delete\_one(...)**   --- 删除符合查询条件的第一条数据

**删除多条数据： delete\_many(...)**   --- 删除符合查询条件的所有数据

from bson.objectid import ObjectId
    
    collection.delete_many({
         '_id':{
        '$gt':ObjectId('5c330f857eb8d621f8d0a359')}})

删除\_id大于ObjectId('5c330f857eb8d621f8d0a359')的数据。

注：

删除数据返回的结果都是DeleteResult类型，可以调用**deleted\_count**属性获取删除数据的条数。

delete\_many() 方法如果传入的是一个空的查询对象，则会删除集合中所有的文档。

**对集合重新命名： rename()**

collection.rename('Yu')

**删除集合：**

collection.drop()

**删除数据库：**

client.drop_database('HuziHu')

对集合的更多操作可参见官方文档：[http://api.mongodb.com/python/current/api/pymongo/collection.html][http_api.mongodb.com_python_current_api_pymongo_collection.html]。

转载于:https://www.cnblogs.com/HuZihu/p/10229073.html

[http_www.runoob.com_mongodb_mongodb-intro.html]: http://www.runoob.com/mongodb/mongodb-intro.html
[https_www.cnblogs.com_HuZihu_p_10233242.html]: https://www.cnblogs.com/HuZihu/p/10233242.html
[https_docs.mongodb.com_manual_reference_operator_query]: https://docs.mongodb.com/manual/reference/operator/query/
[http_api.mongodb.com_python_current_api_pymongo_collection.html]: http://api.mongodb.com/python/current/api/pymongo/collection.html