import pymongo

創(chuàng)建數(shù)據(jù)庫(kù)連接
"""
host=None :ip 127.0.0.1
port=None 端口 27017
"""
mongo_client = pymongo.MongoClient(
host='127.0.0.1',
port=27017
)
mongo_client = pymongo.MongoClient(
'mongodb://127.0.0.1:217017/'
)

需要賬號(hào)密碼登錄

mongo_client = pymongo.MongoClient(
'mongodb://username:password@ip:port'
)

選擇數(shù)據(jù)庫(kù)

db = mongo_client['mongotest']
db = mongo_client.mongotest

選擇數(shù)據(jù)庫(kù)下的集合

col_name = db['test']

插入數(shù)據(jù)

def insert_data():
document1 = {
'title':'斯巴達(dá)克斯3',
'actor':'未知',
'type':'動(dòng)作',
'info':'古羅馬傳記',
}
document2 = {
'title': '斯巴達(dá)克斯4',
'actor': '未知',
'type': '動(dòng)作',
'info': '古羅馬傳記',
}
result = col_name.insert([document1,document2])
result = col_name.insert_many([document1,document2])
print(result)

def delete_data():

# multi = False:刪除一條，multi = True:刪除多條

 result = col_name.remove({'title':'斯巴達(dá)克斯'},multi=False)
 print(result)

 result = col_name.delete_one({'title':'斯巴達(dá)克斯'})
 print(result.deleted_count)

result = col_name.delete_many({'title': '斯巴達(dá)克斯2'})
print(result.deleted_count)
from bson import ObjectId
def update_data():
"""

:return:
"""#upsert=False：表示如果要更新的文檔不在集合下，則什么都不做，
upsert = ture：
result = col_name.update(
    {'title':'斯巴達(dá)克斯1'},
    {'$set':{'info':'1712b'}},
)
 print(result)
 col_name.update(
     {'title':'斯巴達(dá)克斯3'},
   {'name':'小米','gender':'女','age':18}
)
 col_name.update(
     {'name': '小米'},
     {'$set':{'age':20,'class':'1712b'}}
 )

save方法可以保存也可以更新數(shù)據(jù),如果ID不存在，則插入一條新數(shù)據(jù)。

result = col_name.save(
    {
        '_id':   ObjectId("5c26011b0a7f0a2b00f9041a"),
        'title':' this is a girl',
        'info':'1712b',
        'age':30,
        'name':'麗麗'
     }
)
print(result )

def find_data():
"""
查找
:return:
"""
result = col_name.find({})
print(result)
print([i for i in result ])
#根據(jù)條件查找所有
result = col_name.find({'name':'麗麗'})
print([i for i in result])
result = col_name.find_one({'name':'麗麗'})
print(result)
result = col_name.find({}).skip(2).limit(3).sort('age',1)
for i in result:
print(i)

result = col_name.find({}).skip(2).limit(3).sort('age',1)
for i in result:
    print(i)
#limit:限制
#skip:跳過
#sort:排序

if name == 'main':
insert_data()
delete_data()
update_data()
find_data()