Python(Pymongo)을 사용한 MongoDB CRUD 작업

PyMongo 는 MongoDB 작업을 위한 도구가 포함된 Python 배포판이므로 이 블로그 게시물에서는 컬렉션에 대한 CRUD 작업을 수행하는 몇 가지 기본 메서드를 살펴보겠습니다. insert_one(), insert_many(), find_one(), find(), update(), delete(), ...

I, 데이터베이스 연결 및 생성

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() 메서드 반환

# 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, 업데이트_원()

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, 찾기()

모든 레코드 반환

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)

브이, 삭제

1, 삭제_원()

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

2, delete_many()

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