PyMongo అనేది MongoDBతో పని చేయడానికి సాధనాలను కలిగి ఉన్న పైథాన్ పంపిణీ, కాబట్టి ఈ బ్లాగ్ పోస్ట్లో సేకరణకు 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, చొప్పించు()
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()
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, రీప్లేస్_వన్()
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)
DESC
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" })