عمليات 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 ، إدراج ()

يمكن استخدامها لإدراج سجل واحد أو أكثر.

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

الثالث ، التحديث

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)

تنازلي

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

5 ، الحد

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

V ، حذف

1 ، delete_one ()

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

2 ، delete_many ()

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