Python を使用した MongoDB CRUD 操作(Pymongo)

PyMongo は、MongoDB を操作するためのツールを含む Python ディストリビューションです。そのため、このブログ投稿では、コレクションに対して CRUD 操作を実行するいくつかの基本的なメソッドを見てみましょう。 insert_one()、insert_many()、find_one()、find()、update()、delete() など

私はデータベースを接続して作成します

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() メソッドの戻り値

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

2、insert_one()

単一のレコードを DB に挿入します

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、replace_one()

myquery = { "username": "aaa" }  
newvalues = { "username": "ddd" }  
  
mycol.replace_one(myquery, newvalues)

IV、データの選択、読み取り、検索、検索、並べ替え

1、find()

すべてのレコードを返します

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