การดำเนินการ MongoDB CRUD ด้วย Python (Pymongo)

PyMongoคือการแจกจ่าย Python ที่มีเครื่องมือสำหรับการทำงานกับ MongoDB ดังนั้นในบล็อกโพสต์นี้ เรามาดูวิธีการพื้นฐานบางอย่างที่ดำเนินการ CRUD กับคอลเล็กชัน insert_one (), insert_many (), find_one (), ค้นหา (), อัปเดต (), ลบ (), ...

ฉันเชื่อมต่อและสร้างฐานข้อมูล

import pymongo

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

II สร้าง เขียน

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

III อัปเดต

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, แทนที่_หนึ่ง()

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

mycol.replace_one(myquery, newvalues)

IV เลือกข้อมูล อ่าน ค้นหา ค้นหาจัดเรียง

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 เรียงลำดับ

อ.ส.ค

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