1 首先需要创建python 与mongodb的连接
from pymongo import MongoClient
from bson.objectid import ObjectId
from datetime import datetime
client = MongoClient()
print(client.database_names())
如果输出有数据库的名字['admin', 'config', 'local', 'mydb', 'test'],则证明python与 mongodb连接成功
2:python创建数据库和删除数据库
from pymongo import MongoClient
from bson.objectid import ObjectId
from datetime import datetime
client = MongoClient()
print(client.database_names())
db = client['guet']#新建数据库guet
db.guet.insert({'name':'jisu'}) #inser 插入一个字典
print(client.database_names())
new_database = client.test#删除数据库test
client.drop_database(new_database)
print(client.database_names())
注意:新建数据库后,需要向数据库添加元素后,才能查询到该数据库
3: python 查询数据库
from pymongo import MongoClient
from bson.objectid import ObjectId
from datetime import datetime
client = MongoClient()
print(client.database_names())
db = client['guet']
#db.guet.insert({'name':'jisu'}) #inser 插入一个字典
print(client.database_names())
new_database = client.mydb
client.drop_database(new_database)
print(client.database_names())
db.guet.insert({'name':'gaohong'})
db.guet.insert({'name':'zengli'})
db.guet.insert({'name':'xilele'})
my_collection=db.guet
cursor=my_collection.find()
print(cursor.count()) # 获取文档个数
for item in cursor:
print(item)
运行结果如下所示:
4: python更新数据库
my_collection=db.guet
cursor=my_collection.find()
my_collection.update({'name':'xilele'},{'$set':{'hobbies':['向Alice学习读书','跟Alice一起跑步','向Alice学习弹吉他']}})
my_collection.update_one({'name':'zengli'},{'$inc':{'age':12}})
my_collection.update({'name':'gaohong'},{'name':'Tom'})
print(cursor.count()) # 获取文档个数
for item in cursor:
print(item)
程序中有三种更新的方法运行结果:
5 :python 删除mongodb的元素
result=my_collection.delete_one({'name':'Tom'})#删除一个元素
print(result.deleted_count)
cursor=my_collection.find()
print(cursor.count()) # 获取文档个数
for item in cursor:
print(item)
my_collection.remove()#移除该数据库所有的数据
print("****************")
for item in cursor:
print(item)
运行结果: