使用python完成mongodb数据库的增删改查

比眉伴天荒 2022-12-29 02:24 142阅读 0赞

> 使用python远程操作mongodb数据库

![在这里插入图片描述][6d9d1fd1d82ea2fb13206dffebfab6bc.png_pic_center]

> 没有下载MongoDB朋友，可以看看[ubuntu下载mongoDB][ubuntu_mongoDB]

--------------------

### 1. mongdb和python交互的模块 ###

`pymongo` 提供了mongdb和python交互的所有方法  
安装方式: `pip install pymongo`

### 2. 使用pymongo ###

#### 2.1 导入pymongo并选择要操作的集合 ####

> 数据库和集合能够自动创建

##### 2.1.1 无需权限认证的方式创建连接对象以及集合操作对象 #####

from pymongo import MongoClient
    
    client = MongoClient(host,port) # 如果是本地连接host,port参数可以省略
    
    collection = client[db名][集合名]
    # collection = client.db名.集合名 # 与上边用法相同

##### 2.1.2 需要权限认证的方式创建连接对象以及集合操作对象 #####

from pymongo import MongoClient
    from urllib.parse import quote_plus
    
    user = 'python' # 账号
    password = 'python' # 密码
    host = '127.0.0.1' # host
    port = 27017 # port
    uri = "mongodb://%s:%s@%s" % (quote_plus(user),
                                  quote_plus(password),
                                  host)
    # quote_plus函数：对url进行编码
    # uri = mongodb://python:python@127.0.0.1
    client = MongoClient(uri, port=port)
    collection = client.db名.集合名

#### 2.2 insert()添加数据 ####

> insert可以批量的插入数据列表，也可以插入一条数据

collection.insert({
        一条数据})
    collection.insert([{
        数据一},{
        数据二}])

##### 2.2.1 添加一条数据 #####

> 返回插入数据的\_id

ret = collection.insert({
        "name":"test10010","age":33})
    print(ret)

##### 2.2.2 添加多条数据 #####

> 返回ObjectId对象构成的列表

item_list = [{
        "name":"test1000{}".format(i)} for i in range(10)]
    rets = collection.insert(item_list)
    print(rets)
    for ret in rets:
        print(ret)

#### 2.3 find\_one()查找一条数据 ####

> 接收一个字典形式的条件，返回字典形式的整条数据  
> 如果条件为空，则返回第一条

ret = client.test.test.find_one({
        'name': 'test10001'})
    print(ret) # 包含mongodb的ObjectId对象的字典
    _ = ret.pop('_id') # 清除mongodb的ObjectId对象的k,v
    print(ret)

#### 2.4 find()查找全部数据 ####

> 返回所有满足条件的结果，如果条件为空，则返回全部  
> 结果是一个Cursor游标对象，是一个可迭代对象，可以类似读文件的指针，但是只能够进行一次读取

rets = collection.find({
        "name":"test10005"})，
    for ret in rets:
        print(ret)
    for ret in rets: #此时rets中没有内容
        print(ret)

#### 2.5 update()更新数据(全文档覆盖或指定键值，更新一条或多条) ####

*  语法：collection.update(\{条件\}, \{’$set’:\{指定的kv或完整的一条数据\}\}, multi=False/True, upsert=False/True)
 *  multi参数：默认为False,表示更新一条; multi=True则更新多条; multi参数必须和$set一起使用
 *  upsert参数：默认为False; upsert=True则先查询是否存在,存在则更新;不存在就插入
 *  $set表示指定字段进行更新

##### 2.5.1 更新一条数据；全文档覆盖；存在就更新，不存在就插入 #####

data = {
        'msg':'这是一条完整的数据1','name':'哈哈'}
    client.test.test.update({
        'haha': 'heihei'}, {
        '$set':data}, upsert=True)

##### 2.5.2 更新多条数据；全文档覆盖；存在就更新，不存在就插入 #####

data = {
        'msg':'这是一条完整的数据2','name':'哈哈'} # 该完整数据是先查询后获取的
    client.test.test.update({
        }, {
        '$set':data}, multi=True, upsert=True)

##### 2.5.3 更新一条数据；指定键值；存在就更新，不存在就插入 #####

data = {
        'msg':'指定只更新msg___1'}
    client.test.test.update({
        }, {
        '$set':data}, upsert=True)

##### 2.5.4 更新多条数据；指定键值；存在就更新，不存在就插入 #####

data = {
        'msg':'指定只更新msg___2'}
    client.test.test.update({
        }, {
        '$set':data}, multi=True, upsert=True)

#### 2.6 delete\_one()删除一条数据 ####

collection.delete_one({
        "name":"test10010"})

#### 2.7 delete\_many()删除全部数据 ####

collection.delete_many({
        "name":"test10010"})

### 3. pymongo模块其他api ###

> 查看pymongo官方文档或源代码 http://api.mongodb.com/python/current/

## 小结 ##

1.  掌握pymongo的增删改查的使用
2.  掌握权限认证的方式使用pymongo模块

--------------------

[6d9d1fd1d82ea2fb13206dffebfab6bc.png_pic_center]: /images/20221120/f248e414f87c4411b57d1ea111c44abe.png
[ubuntu_mongoDB]: https://blog.csdn.net/qq_45176548/article/details/111407235