MongoDB CRUD hoạt động với Python (Pymongo)

PyMongo là một bản phân phối Python chứa các công cụ để làm việc với MongoDB. Vì vậy, trong bài đăng trên blog này, chúng ta hãy xem một số phương thức cơ bản thực hiện các thao tác CRUD đối với một bộ sưu tập. insert_one(), insert_many(), find_one(), find(), update(), delete(), ...

I, Conconnection and making the database

import pymongo

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

II, Tạo, Viết

1, chèn()

can be used to insert 1 or many writing.

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" }])

input method() return

# insert single user
ObjectId('5fbe1c17242098c02a7f4ecb')

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

2, chèn_một()

chèn một bản ghi vào DB

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

3, chèn_many()

đưa nhiều bản ghi vào một bộ sưu tập

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

III, Cập nhật

1, update()

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, thay_one()

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

mycol.replace_one(myquery, newvalues)

IV, Chọn dữ liệu, Đọc, Tìm, Tìm kiếm, Sắp xếp

1, find()

trả lại tất cả các bản ghi

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

2, find_one()

return the first entry

mycol.find_one()

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

3, Bộ lọc

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

for x in mydoc:
  print(x)

tìm tất cả các bản ghi có tên người dùng bắt đầu bằng 'a'

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

for x in mydoc:
  print(x)

4, Sắp xếp

TĂNG DẦN

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

DESC

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

5, giới hạn

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

V, Xóa

1, xóa_một()

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

2, xóa_many()

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