1.鏈接數(shù)據(jù)庫(kù)(database)和聚類(collection)
import pymongo
# 連接 MongoDB锥咸,默認(rèn)使用本地鏈接的 27017 端口
client = pymongo.MongoClient('localhost', 27017)
# 連接到具體某一個(gè)數(shù)據(jù)庫(kù)
test = client['test_db']
# 也可寫(xiě)成這種形式
test = client.test_db
# 鏈接到 student_info 這個(gè)聚類
student_info = test['student_info']
Mongodb 中的 數(shù)據(jù)庫(kù)(database)等同于 SQL 中的 database掰烟,可以理解為一個(gè) Excel 文件刃永。
Mongodb 中的 聚類(collection)连锯,相當(dāng)于 SQL 中的 表(table),可以理解為 一個(gè) Excel 文件里面的 sheet贾铝。
2.插入數(shù)據(jù)
使用 insert_one()
語(yǔ)句插入一條數(shù)據(jù)汇恤,數(shù)據(jù)包裝成字典的形式。
test.student_info.insert_one({'name':'小白'})
用迭代插入多條數(shù)據(jù):
student_infos = [
{'name':'小明','age':12,'city':'廣州','hobby':['足球','游戲']},
{'name':'小李','age':11,'city':'北京','hobby':['籃球']},
{'name':'小張','age':9,'city':'上海','hobby':['吃飯','睡覺(jué)','發(fā)呆']},
{'name':'小麗','age':12,'city':'蘇州','hobby':['音樂(lè)']},
{'name':'小紅','age':8,'city':'南京','hobby':['讀書(shū)']}
]
for student in student_infos:
student_info.insert_one(
{
'name':student['name'],
'city':student['city'],
'age':student['age'],
'hobby':student['hobby']
}
)
用 insert_many()
語(yǔ)句插入多條記錄:
test.student_info.\
insert_many(
[
{'name':'小x', 'age': 10},
{'name':'小y', 'age': 11},
{'name':'小z', 'age': 12}
]
)
3.查詢操作
3.1 查看全部聚集名稱
>>> test.collection_names()
['student_info']
3.2 查看聚集的第一條記錄
>>> test.student_info.find_one()
{
'_id': ObjectId('5a1cd216f1a19d178cc7f6c8'),
'city': '廣州',
'name': '小明',
'age': 12,
'hobby': ['足球', '游戲']
}
3.3 條件查詢
# 查找 age 為 12 的記錄
r = test.student_info.\
find_one(
{'age':12}
)
print(r)
# 結(jié)果
{
'age': 12,
'hobby': ['足球', '游戲'],
'city': '廣州',
'_id': ObjectId('5a1cd216f1a19d178cc7f6c8'),
'name': '小明'
}
注意:符合搜索條件的記錄是有多條的访锻,find_one()
語(yǔ)句只會(huì)顯示其中一條褪尝。查詢?nèi)亢戏麠l件的記錄,使用 find()
語(yǔ)句期犬。
r = test.student_info.\
find(
{'age':12}
)
3.4 查看聚集的記錄統(tǒng)計(jì)
# 查看聚集的總數(shù)
>>> test.student_info.find().count()
5
# 查看聚類中某個(gè)鍵的所有值
>>> test.student_info.distinct('city')
['廣州', '北京', '上海', '蘇州', '南京']
3.5 聚集查詢結(jié)果排序
# 默認(rèn)為升序
r = test.student_info.\
find().\
sort("age")
# 升序
r = test.student_info.\
find().\
sort("age", pymongo.ASCENDING)
# 降序
r = test.student_info.\
find().\
sort("age", pymongo.DESCENDING)
# 多重排序
# 先根據(jù) age 排序河哑,age 相等時(shí)再按 name 排序
r = test.student_info.\
find().\
sort(
[
("age",pymongo.ASCENDING),
("name",pymongo.DESCENDING)
]
)
4.修改操作
4.1 修改一條記錄
# 找到 age = 12 的記錄
# 然后修改其中一條的 age 為 100
test.student_info.\
update_one(
{'age': 12},
{
'$set':{'age': 100}
}
)
4.2 修改多條記錄
test.student_info.\
update_many(
{'age': 100},
{
'$set':{'age': 1}
}
)
4.3 修改全部記錄
# 以_id為索引,遍歷全部記錄龟虎,并把每一條的'age'值修改為:100
for i in test.student_info.find():
test.student_info.\
update_one(
{'_id':i['_id']},
{'$set':
{'age': 100}
}
)
5.替換操作
替換一條記錄:
# 找出 city 值為 '北京 '的記錄璃谨,替換為 'hometown':'廊坊'
# 注意:是替換記錄內(nèi)的全部?jī)?nèi)容,并非只是替換 'city' 字段
test.student_info.replace_one(
{'city':'北京'},
{'hometown':'廊坊'}
)
r = test.student_info.find({'hometown':'廊坊'})
for i in r:
print(i)
# 結(jié)果
{
'_id': ObjectId('571c901b13d5942564a5a23e'),
'hometown': '廊坊'
}
6.刪除操作
6.1刪除一條記錄
# 刪除第一條 name 為 '小明' 的記錄
test.student_info.delete_one({'name':'小明'})
6.2 刪除多條記錄
# 刪除全部 age 為 12 的記錄
test.student_info.delete_many({'age':12})