专栏名称: Python学习交流

每天更新，更新python相关的知识。希望诸君有所收获！

pymongo看了就会啦

Python学习交流 · 公众号 · Python · 2017-10-08 14:41

正文

准备

我的本机环境是：

Python3.6
mongodb3.4.3
IDE: PyCharm Professional

因为要使用Python来操作数据库，所以还需要安装一个pymongo的包。需要注意的是直接用 pip安装 是没办法使用的，可能是版本的问题，也可能是兼容性的问题。所以到 http://www.lfd.uci.edu/~gohlke/pythonlibs/#pymongo 下找到合适自己Python版本的whl文件，然后再使用pip安装这个whl文件即可。

简单操作

简单操作嘛，无非增删改查。接下来就逐个尝试尝试吧。在此之前先来看看如何连接本地的mongodb数据库。

数据库连接

连接数据库有下面两种方式。官方建议使用MongoClient的形式，而Connection则最好不要使用，我这里就干脆按照官方来吧。

# coding: utf8

# @Author: 郭璞

# @File: mongo-connect.py

# @Time: 2017/4/22

# @Contact: [email protected]

# @blog: http://blog.csdn.net/marksinoberg

# @Description: 链接Mongodb的测试程序

import pymongo

# 默认没有密码，所以可以这么写。如果设置了密码需要使用授权方法db.auth("用户名","密码")

conn = pymongo.MongoClient()

# 选择一个数据库

db = conn.test

# 选择一个collection

collection = db.user

print(collection)

如果您的控制台也输出了如下类似的信息，那说明您已经连接成功了。

Collection(Database(MongoClient(host=['localhost:27017'], document_class=dict, tz_aware=False, connect=True), 'test'), 'user')

增：insert

mongodb的插入操作也是很方便的。我这里事先在MongoVUE中添加了几条数据。

下面咱们通过代码来插入数据。

插入单条记录

import pymongo

conn = pymongo.MongoClient()

# 选择一个数据库

db = conn.test

# 选择一个collection

collection = db.user

def show(collection):

# 查找

for item in collection.find():

print(item)

# 插入

dic = {

'name': '刀塔传奇',

'age': 23,

'address': '北京朝阳',

'blog': '没有博客'

}

collection.insert(dic)

show(collection)

代码运行的结果如下：

D:\Software\Python3\python.exe E:/Code/Python/Python3/MyWork/mongo/mongo-connect.py

{'_id': ObjectId('58f9e91295ee7820082b562b'), 'name': '郭璞', 'age': 20}
{'_id': ObjectId('58f9e96f95ee7820082b562c'), 'name': '张三', 'age': 28, 'Address': '北京海淀', 'blog': 'http://blog.csdn.net/zhangsan

'}
{'_id': ObjectId('58f9e98f95ee7820082b562d'), 'name': '李四', 'age': 19, 'Address': '上海滩', 'blog': 'http://blog.csdn.net/lisi

'}
{'_id': ObjectId('58f9e9a895ee7820082b562e'), 'name': '王五', 'age': 23, 'Address': '江苏杭州', 'blog': 'http://blog.csdn.net/wangwu

'}
{'_id': ObjectId('58f9e9c595ee7820082b562f'), 'name': '赵六', 'age': 32, 'Address': '江苏南京', 'blog': 'http://blog.csdn.net/zhaoliu

'}
{'_id': ObjectId('58fac6c495ee78170c9075c7'), 'name': '可爱的哒哒', 'age': 19, 'address': '北京朝阳', 'blog': '哒哒的博客一般人是不会知道的'}
{'_id': ObjectId('58fae2dd95ee7810044c07cf'), 'name': '刀塔传奇', 'age': 23, 'address': '北京朝阳', 'blog': '没有博客'}

对比初始状态，不难发现多了一条新插入的记录。

插入多条记录

也许你会有这样的需求，要一次插入多条记录。这在命令行中很方便，我们写个循环就可以了。不过pymongo也给我们提供了这样的一个接口。

import pymongo

conn = pymongo.MongoClient()

# 选择一个数据库

db = conn.test

# 选择一个collection

collection = db.user

def show(collection):

# 查找

for item in collection.find():

print(item)

# 插入

dic = {

'name': '刀塔传奇',

'age': 23,

'address': '北京朝阳',

'blog': '没有博客'

}

# collection.insert(dic)

many = []

import copy

for index in range(1, 8):

tempdic = copy.deepcopy(dic)

tempdic['age'] = index**2

many.append(tempdic)

collection.insert_many(many)

show(collection)

运行的结果如下：

D:\Software\Python3\python.exe E:/Code/Python/Python3/MyWork/mongo/mongo-connect.py

{'_id': ObjectId('58f9e91295ee7820082b562b'), 'name': '郭璞', 'age': 20}

{'_id': ObjectId('58f9e96f95ee7820082b562c'), 'name': '张三', 'age': 28, 'Address': '北京海淀', 'blog': 'http://blog.csdn.net/zhangsan'}

{'_id': ObjectId('58f9e98f95ee7820082b562d'), 'name': '李四', 'age': 19, 'Address': '上海滩', 'blog': 'http://blog.csdn.net/lisi'}

{'_id': ObjectId('58f9e9a895ee7820082b562e'), 'name': '王五', 'age': 23, 'Address': '江苏杭州', 'blog': 'http://blog.csdn.net/wangwu'}

{'_id': ObjectId('58f9e9c595ee7820082b562f'), 'name': '赵六', 'age': 32, 'Address': '江苏南京', 'blog': 'http://blog.csdn.net/zhaoliu'}

{'_id': ObjectId('58fac6c495ee78170c9075c7'), 'name': '可爱的哒哒', 'age': 19, 'address': '北京朝阳', 'blog': '哒哒的博客一般人是不会知道的'}

{'_id': ObjectId('58fae2dd95ee7810044c07cf'), 'name': '刀塔传奇', 'age': 23, 'address': '北京朝阳', 'blog': '没有博客'}

{'_id': ObjectId('58fae37b95ee78202cc2cc07'), 'name': '刀塔传奇', 'age': 1, 'address': '北京朝阳', 'blog': '没有博客'}

{'_id': ObjectId('58fae37b95ee78202cc2cc08'), 'name': '刀塔传奇', 'age': 4, 'address': '北京朝阳', 'blog': '没有博客'}

{'_id': ObjectId('58fae37b95ee78202cc2cc09'), 'name': '刀塔传奇', 'age': 9, 'address': '北京朝阳', 'blog': '没有博客'}

{'_id': ObjectId('58fae37b95ee78202cc2cc0a'), 'name': '刀塔传奇', 'age': 16, 'address': '北京朝阳', 'blog': '没有博客'}

{'_id': ObjectId('58fae37b95ee78202cc2cc0b'), 'name': '刀塔传奇', 'age': 25, 'address': '北京朝阳', 'blog': '没有博客'}

{'_id': ObjectId('58fae37b95ee78202cc2cc0c'), 'name': '刀塔传奇', 'age': 36, 'address': '北京朝阳', 'blog': '没有博客'}

{'_id': ObjectId('58fae37b95ee78202cc2cc0d'), 'name': '刀塔传奇', 'age': 49, 'address': '北京朝阳', 'blog': '没有博客'}

怎么样，还是很方便的吧。

改： update

修改数据的话，需要了解的是update方法的参数的含义。

第一个参数是数据库中某一条记录的一个字段的值。它就是一个“代号”，保证我们在数据库中能找到它。
第二个参数是更新后的数据。

而修改的话，也可以有两种方式。

方式一

这种方式其实是需要整条记录参与的。

collection.update({'name': "傻瓜哒哒"}, dic)

show(collection)

程序运行的结果如下：