MongoDB 是 Nosql 数据库的典型代表,python 可以很方便地链接操作。
pymongo
包pip install pymongo
from pymongo import MongoClient
#建立MongoDB数据库连接
conn = MongoClient('127.0.0.1',27017)
conn.list_database_names()
['admin', 'config', 'local', 'waline']
mydb = conn.admin
comment = mydb["Comment"]
注意: 在 MongoDB 中,集合只有在内容插入后才会创建! 就是说,创建集合(数据表)后要再插入一个文档(记录),集合才会真正创建。
mydb.list_collection_names()
['system.users', 'system.version', 'Users', 'Comment']
collenction = mydb['Comment']
mydict = { "name": "RUNOOB", "alexa": "10000", "url": "https://www.runoob.com" }
x = collection.insert_one(mydict)
mylist = [
{ "name": "Taobao", "alexa": "100", "url": "https://www.taobao.com" },
{ "name": "QQ", "alexa": "101", "url": "https://www.qq.com" },
{ "name": "Facebook", "alexa": "10", "url": "https://www.facebook.com" },
{ "name": "知乎", "alexa": "103", "url": "https://www.zhihu.com" },
{ "name": "Github", "alexa": "109", "url": "https://www.github.com" }
]
x = collection.insert_many(mylist)
无论使用何种方式插入数据时,如果没有
_id
字段系统会自动创建,也可以手动指定插入
find_one()
方法来查询集合中的一条数据。mycol = mydb["sites"]
x = mycol.find_one()
find()
方法可以查询集合中的所有数据,类似 SQL 中的 SELECT * 操作。mycol = mydb["sites"]
for x in mycol.find():
print(x)
find()
方法来查询指定字段的数据,将要返回的字段对应值设置为 1。mycol = mydb["sites"]
for x in mycol.find({},{ "_id": 0, "name": 1, "alexa": 1 }):
print(x)
name, alexa
字段{'name': 'RUNOOB', 'alexa': '10000'}
{'name': 'Google', 'alexa': '1'}
{'name': 'Taobao', 'alexa': '100'}
{'name': 'QQ', 'alexa': '101'}
find()
中设置参数来过滤数据。mycol = mydb["sites"]
myquery = { "name": "RUNOOB" }
mydoc = mycol.find(myquery)
for x in mydoc:
print(x)
{'_id': ObjectId('5b23696ac315325f269f28d1'), 'name': 'RUNOOB', 'alexa': '10000', 'url': 'https://www.runoob.com'}
计数 集合.count_documents(query) 可以统计集合中符合条件的查询数量
collection = mydb['Comment']
query = {'url': '/notes/hexo/theme/next/6-add-valine-comments/add-valine-comments/'}
res = collection.count_documents(query)
print(res)
mycol = mydb["sites"]
myquery = { "name": { "$gt": "H" }
mydoc = mycol.find(myquery)
mycol = mydb["sites"]
myquery = { "name": { "$regex": "^R" } }
mydoc = mycol.find(myquery)
limit()
方法,该方法只接受一个数字参数。mycol = mydb["sites"]
myresult = mycol.find().limit(3)
update_one()
方法修改文档中的记录。该方法第一个参数为查询的条件,第二个参数为要修改的字段。如果查找到的匹配数据多于一条,则只会修改第一条。mycol = mydb["sites"]
myquery = { "alexa": "10000" }
newvalues = { "$set": { "alexa": "12345" } }
mycol.update_one(myquery, newvalues)
update_one()
方法只能修匹配到的第一条记录,如果要修改所有匹配到的记录,可以使用 update_many()
。
mycol = mydb["sites"]
myquery = { "name": { "$regex": "^F" } }
newvalues = { "$set": { "alexa": "123" } }
x = mycol.update_many(myquery, newvalues)
delete_one()
方法来删除一个文档,该方法第一个参数为查询对象,指定要删除哪些数据。mycol = mydb["sites"]
myquery = { "name": "Taobao" }
mycol.delete_one(myquery)
delete_many()
方法来删除多个文档,该方法第一个参数为查询对象,指定要删除哪些数据。mycol = mydb["sites"]
myquery = { "name": {"$regex": "^F"} }
x = mycol.delete_many(myquery)
delete_many()
方法如果传入的是一个空的查询对象,则会删除集合中的所有文档:mycol = mydb["sites"]
x = mycol.delete_many({})
drop()
方法来删除一个集合。mycol = mydb["sites"]
x = mycol.delete_many({})
sort()
方法可以指定升序或降序排序。sort()
方法第一个参数为要排序的字段,第二个字段指定排序规则,1 为升序,-1 为降序,默认为升序。mycol = mydb["sites"]
mydoc = mycol.find().sort("alexa")
# mydoc = mycol.find().sort("alexa", -1) # 降序排序