使用 Python (Pymongo) 进行 MongoDB CRUD 操作

PyMongo是一个 Python 发行版，包含用于使用 MongoDB 的工具，因此在这篇博文中，我们将了解一些对集合执行 CRUD 操作的基本方法。insert_one()、insert_many()、find_one()、find()、update()、delete()、...

一、连接并创建数据库

import pymongo

myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["mydatabase"]
mycol = mydb["mytable"]

二、创作、写作

1、插入()

可用于插入 1 条或多条记录。

myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["mydatabase"]
mycol = mydb["users"]

# insert single user
mycol.insert({ "username": "aaa", "pass": "123456" })

# insert many users
mycol.insert([{ "username": "bbb", "pass": "123456" }, { "username": "ccc", "pass": "123456" }])

insert() 方法返回

# insert single user
ObjectId('5fbe1c17242098c02a7f4ecb')

# insert many users
[ObjectId('5fbe1c17242098c02a7f4ecb'), ObjectId('5fbe1c63fa9741631f6a1f6c')]

2、insert_one()

将单个记录插入数据库

mycol.insert_one({ "username": "aaa", "pass": "123456" })

3、insert_many()

将多条记录插入集合中

mycol.insert_many([
    { "username": "aaa", "pass": "123456" },
    { "username": "bbb", "pass": "123456" },
    { "username": "ccc", "pass": "123456" }
])

三、更新

1、更新()

myquery = { "username": "aaa" }
newvalues = { "$set": { "username": "ddd" } }

mycol.update(myquery, newvalues)

2、update_one()

myquery = { "username": "aaa" }
newvalues = { "$set": { "username": "ddd" } }

mycol.update_one(myquery, newvalues)

3、update_many()

myquery = { "username": "aaa" }
newvalues = { "$set": { "username": "ddd" } }

mycol.update_many(myquery, newvalues)

4、replace_one()

myquery = { "username": "aaa" }
newvalues = { "username": "ddd" }

mycol.replace_one(myquery, newvalues)

四、选择数据、读取、查找、搜索、排序

1、查找()

返回所有记录

mycol.find()
# return
<pymongo.cursor.Cursor object at 0x7f8fc1878890>

2、find_one()

返回第一条记录

mycol.find_one()

# return 
{'id': ObjectId('5fbe1c17242098c02a7f4ecb'), 'username': 'aaa',  'pass': '123456'}

3、过滤器

myquery = { "username": "aaa" } 
mydoc = mycol.find(myquery)

for x in mydoc:
  print(x)

查找用户名以“a”开头的所有记录

myquery = { "username": { "$gt": "a" } }
mydoc = mycol.find(myquery)

for x in mydoc:
  print(x)

4、排序

ASC

mydoc = mycol.find().sort("username", 1)

DESC

mydoc = mycol.find().sort("username", -1)

5、限制

users = mycol.find().limit(5)

五、删除

1、delete_one()

mycol.delete_one({ "username": "aaa" })

2、delete_many()

mycol.delete_many({ "username": "aaa" })