MongoDB数据库

pymongo安装

  1. pip install pymongo

连接数据库

  1. 方式一
  2. client = MongoClient()
  3. 方式二 指定端口和地址
  4. client = MongoClient('localhost',27017)

新增数据

  1. from pymongo import MongoClient
  2. from datetime import datetime
  4. class TestMongo(object):
  5.     def __init__(self):
  6.         self.client = MongoClient('mongodb://localhost:27017/')
  7.         # 也可以指定连接的集合client['admin']['students']
  8.         self.db = self.client['admin']
  9.         # print(self.client.database_names())
  11.     def add_one(self):
  12.         post = {'title':'标题','content':'内容','created_at':datetime.now()}
  13.         # db.students   students 是表明
  14.         res = self.db.students.insert_one(post)
  15.         return res
  17.     def add_more(self):
  18.         data_list = [{"name":"test{}".format(i)} for i in range(5)]
  19.         res = self.db.students.insert_many(data_list)
  20.         return res
  23. mongo = TestMongo()
  24. res = mongo.add_one()
  25. 插入的ID
  26. print(res.inserted_id)

查询数据

  1. from bson.objectid import ObjectId
  2. 查询一条数据
  3. def get_one(self):
  4.     return self.db.students.find_one()
  6. 查询多条数据
  7. def get_more(self):
  8.     return self.db.students.find()
  10. 根据记录的ID查询数据
  11. def get_from_id(self,id):
  12.     return self.db.students.find_one({'_id':ObjectId(id)})
  14. 查询一条数据 
  15. res = mongo.get_one()
  16. 查询多条数据
  17. res = mongo.get_more()
  18. for i in res:
  19.     print(i)
  20. 根据记录的ID查询数据
  21. res = mongo.get_from_id('5b83e8a1b594c32e8c70c1f7')
  22. print(res)

修改数据

  1. 修改单条数据
  2. def update(self):
  3.     res = self.db.students.update_one({'title':'标题'},{'$set':{'title':'title-2'}})
  4.     # 匹配的数据条数
  5.     print(res.matched_count)
  6.     # 影响的数据条数。
  7.     print(res.modified_count)
  9. 修改多条
  10. def update_more(self):
  11.     res = self.db.students.update_many({},{'$set':{'x':1}})
  12.     print(res.matched_count)
  13.     print(res.modified_count)
  14.     res = self.db.students.update({'x':2},{'$set':{'x':3}},True)
  16. res = mongo.update()
  17. res = mongo.update_more()

删除数据

  1. 删除一条
  2. def delete_one(self):
  3.     res = self.db.students.delete_one({'title':'title-2'})
  4.     print(res.deleted_count)
  6. 删除多条
  7. def delete_more(self):
  8.     res = self.db.students.delete_many({'x':2})
  9.     print(res.deleted_count)
  11. res = mongo.delete_one()
  12. res = mongo.delete_more()