Python編程：mongodb的基本增刪改查操作
文檔：http://api.mongodb.com/python/current/api/index.html
第一步當(dāng)然是配置環(huán)境，啟動(dòng)數(shù)據(jù)庫(kù)服務(wù)
mongodb的安裝及簡(jiǎn)單使用-mac環(huán)境
引入模塊
# -*- coding: utf-8 -*- # @File : pymongo_demo.py # @Date : 2018-06-02 # @Author : Peng Shiyu import pymongo
1、創(chuàng)建MongoDB的連接對(duì)象
# client = pymongo.MongoClient(host="localhost", port=27017) client = pymongo.MongoClient('mongodb://localhost:27017/')
2、指定數(shù)據(jù)庫(kù)
# db = client["mydemo"] db = client.mydemo
3、指定集合Collection對(duì)象
# collection = db["students"] collection = db.students
4、插入數(shù)據(jù)
# 一條數(shù)據(jù) student = { 'id': '20170101', 'name': '小明', 'age': 22, 'gender': '男性' } # result = collection.insert(student) result = collection.insert_one(student) print(result) # <pymongo.results.InsertOneResult object at 0x1034e08c8> print(result.inserted_id) # 5b1205b2d7696c4230dd9456 # 多條數(shù)據(jù) student1 = { 'id': '20170101', 'name': 'Jordan', 'age': 20, 'gender': 'male' } student2 = { 'id': '20170202', 'name': 'Mike', 'age': 21, 'gender': 'male' } # # # result = collection.insert([student1, student2]) result = collection.insert_many([student1, student2]) print(result) # <pymongo.results.InsertManyResult object at 0x1034e0748> print(result.inserted_ids) # # [ObjectId('5b1205b2d7696c4230dd9457'), ObjectId('5b1205b2d7696c4230dd9458')]
5、查詢數(shù)據(jù)庫(kù)
# 查詢一條數(shù)據(jù) result = collection.find_one({"name": "Mike"}) print(type(result)) # <class 'dict'> print(result) # {'_id': ObjectId('5b1204a3d7696c41c083d21e'), # 'id': '20170202', 'name': 'Mike', 'age': 21, 'gender': 'male'} # 通過(guò)_id屬性來(lái)查詢， 不存在則返回None from bson.objectid import ObjectId result = collection.find_one({'_id': ObjectId('5b1204a3d7696c41c083d21e')}) print(result) # {'_id': ObjectId('5b1204a3d7696c41c083d21e'), # 'id': '20170202', 'name': 'Mike', 'age': 21, 'gender': 'male'} # 查詢多條數(shù)據(jù), 返回一個(gè)生成器 results = collection.find({"age": 21}) print(results) # <pymongo.cursor.Cursor object at 0x10133f160> for result in results: print(result) # {'_id': ObjectId('5b12055fd7696c4208deb74a'), # 'id': '20170202', 'name': 'Mike', 'age': 21, 'gender': 'male'} # 條件查詢 results = collection.find({"age": {"$gt": 20}}) for result in results: print(result) # {'_id': ObjectId('5b1209ccd7696c437c51d5bb'), # 'id': '20170101', 'name': '小明', 'age': 22, 'gender': '男性'} # {'_id': ObjectId('5b1209ccd7696c437c51d5bd'), # 'id': '20170202', 'name': 'Mike', 'age': 21, 'gender': 'male'} # 正則匹配查詢 results = collection.find({"name": {"$regex": "^M.*"}}) for result in results: print(result) # {'_id': ObjectId('5b1209ccd7696c437c51d5bd'), # 'id': '20170202', 'name': 'Mike', 'age': 21, 'gender': 'male'} ## 轉(zhuǎn)為list >>> db.collection.find() <pymongo.cursor.Cursor object at 0x108dabf50> >>> list(db.collection.find()) [ {'_id': ObjectId('5839b12eee86fb71849a0905'), 'name': 'Tom'} ]
比較符號(hào)
|
符號(hào) |
表示 |
含義 |
示例 |
|
: |
= |
等于 |
{“age”: 20} |
|
$lt |
< |
小于 |
{“age”: {"$lt": 20}} |
|
$gt |
> |
大于 |
{“age”: {"$gt": 20}} |
|
$lte |
<= |
小于等于 |
{“age”: {"$lte": 20}} |
|
$gte |
>= |
大于等于 |
{“age”: {"$gte": 20}} |
|
$ne |
!= |
不等于 |
{“age”: {"$ne": 20}} |
|
$in |
in |
范圍內(nèi) |
{“age”: {"$in": [20, 30]}} |
|
$nin |
not in |
不在范圍內(nèi) |
{“age”: {"$nin": [20, 30]}} |
|
|
|
|
|
說(shuō)明：
lt: less than
gt: great than
e: equal
功能符號(hào)
|
符號(hào) |
含義 |
示例 |
示例說(shuō)明 |
|
$regex |
匹配正則表達(dá)式 |
{“name”: {"$regex": “^M.*”}} |
name以M開(kāi)頭 |
|
$exists |
屬性是否存在 |
{“name”: {"$exists": True}} |
name屬性存在 |
|
$type |
類(lèi)型判斷 |
{“age”: {"$type": “int”}} |
age的類(lèi)型為int |
|
$mod |
數(shù)字模操作 |
{“age”: {"$mod": [5, 0]}} |
年齡模5余0 |
|
$text |
文本查詢 |
{“text”: {"$search": “Mike”}} |
text類(lèi)型的屬性中包含字符串Mike |
|
$where |
高級(jí)條件查詢 |
{“name”: {"$where": “obj.age==obj.count”}} |
自身年齡等于自身數(shù)量 |
6、查詢計(jì)數(shù)
count = collection.find().count() print(count) # 3
7、數(shù)據(jù)排序
# 升序pymongo.ASCENDING 降序pymongo.DESCENDING results = collection.find().sort("name", pymongo.ASCENDING) print([result["name"] for result in results]) # ['Jordan', 'Mike', '小明']
8、數(shù)據(jù)的偏移
results = collection.find().sort('name', pymongo.ASCENDING).skip(2) print([result['name'] for result in results]) # ['小明'] results = collection.find().sort('name', pymongo.ASCENDING).skip(1).limit(1) print([result['name'] for result in results]) # ['Mike'] # 數(shù)據(jù)庫(kù)數(shù)量非常龐大的時(shí)候，不要使用大的偏移量 from bson.objectid import ObjectId results = collection.find({'_id': {'$gt': ObjectId('5b1209ccd7696c437c51d5bb')}}) print([result['name'] for result in results])
9、更新數(shù)據(jù)庫(kù)
更新函數(shù)
update_one(filter, update, upsert=False, bypass_document_validation=False, collation=None, array_filters=None, session=None) update_many(filter, update, upsert=False, array_filters=None, bypass_document_validation=False, collation=None, session=None) # 過(guò)時(shí)了 update(spec, document, upsert=False, manipulate=False, multi=False, check_keys=True, **kwargs)
condition = {'name': 'Mike'} student = collection.find_one(condition) student['age'] = 25 # 全部用student字典替換 # result = collection.update(condition, student) # 只更新student字典內(nèi)存在的字段 result = collection.update(condition, {'$set': student}) print(result) # {'n': 1, 'nModified': 1, 'ok': 1.0, 'updatedExisting': True} condition = {'name': 'Mike'} student = collection.find_one(condition) student['age'] = 26 result = collection.update_one(condition, {'$set': student}) print(result) # <pymongo.results.UpdateResult object at 0x1034de708> print(result.matched_count, result.modified_count) # 1 1 condition = {'age': {'$gt': 20}} result = collection.update_one(condition, {'$inc': {'age': 1}}) print(result) # <pymongo.results.UpdateResult object at 0x1034e8588> print(result.matched_count, result.modified_count) # 1 1
10、數(shù)據(jù)刪除
result = collection.remove({'name': 'Jordan'}) print(result) # 刪除一條 result = collection.delete_one({'name': 'Kevin'}) print(result) print(result.deleted_count) result = collection.delete_many({'age': {'$lt': 25}}) print(result.deleted_count) # 刪除多條 result = collection.delete_many({'name': 'Kevin'})
官方文檔：
http://api.mongodb.com/python/current/api/pymongo/collection.html
多條件查詢
db.getCollection('table').find({"$and": [{"detail": {"$ne": null}}, {"detail": {"$ne": true}}]})