1. 基础概念
-
MongoDB简介:
- MongoDB是一个基于文档的NoSQL数据库,具有高性能、高可用性和易扩展性。
- 数据存储在类似JSON的BSON格式中。
-
基本术语:
- Database(数据库): 集合的容器。
- Collection(集合): 文档的容器,类似于关系型数据库中的表。
- Document(文档): 数据的基本单元,类似于关系型数据库中的行。
2. 安装与设置
-
安装MongoDB:
- 官方安装指南
-
启动MongoDB服务:
- Windows:
mongod
- Mac/Linux:
sudo service mongod start
- Windows:
-
MongoDB Shell:
- 连接MongoDB实例:
mongo
- 连接MongoDB实例:
3. 基本操作
选择数据库:use share 选中share的数据库
创建集合
db.createCollection("news") 创建一个名字为news的集合
插入数据(文档) db.news.insertOne({ name: "Alice", age: 25, city: "New York" }) 像news这个集合中插入一条数据
查询文档:
查所有
db.news.find() 查找所有的文档
带条件
db.news.find({ age: 25 }) 带条件查找 查询年龄为25的这一条数据
db.news.find({ age: { $gt: 20 }) 查询年龄大于20岁的
db.news.find({age:{$gt:20}},{name:1,age:1,_id:0}) 查询年龄>20,且返回name,age字段,不返回_id字段
排序
db.news.find().sort({age:-1}) 按照年龄降序排序
db.news.find().sort({age:1}) 按照年龄升序
分页
跳过指定数量的文档
db.news.find().skip(10)
限制返回的文档数量
db.news.find().limit(5)
分页查询
db.news.find().skip(10).limit(5)
逻辑操作符
$and
:与
db.news.find({ $and: [ { age: { $gt: 20 } }, { age: { $lt: 30 } } ] }) 查询大于二十小于三十
$or
:或
db.news.find({ $or: [ { age: 25 }, { age: 30 } ] })
查询年龄是25跟30的那两条
$not
:非
db.myCollection.find({ age: { $not: { $gt: 20 } } })
数组操作符
$in
:在指定数组中
db.news.find({ age: { $in: [25, 30, 35] } })
$nin
:不在指定数组中
db.news.find({ age: { $nin: [20, 25, 30] } })
$all
:包含数组中的所有元素
db.news.find({ tags: { $all: ["red", "blue"] } })
更新文档
db.news.updateOne({ name: "Alice" }, { $set: { age: 26 } }) 更新语句用于在 news集合中查找
name
字段值为"Alice"
的文档,并将其age
字段更新为26
。如果文档中没有age
字段,则会添加这个字段。删除文档
db.news.deleteOne({ name: "Alice" }) 删除所有 name 字段为Alice的文档
4.Python整合mongdb
1.安装pymongdb
pip install pymongdb
2.连接
from mongdb import MongClient
client =MongClient("localhost", 27017)
db = client['mydatabase'] 选择名为mydatabase的数据库,没有则自动创建
# 选择集合(如果集合不存在,MongoDB会自动创建)
collection = db['mycollection']
3.就是做一些业务操作了,增删改,这举出一个分页查询的代码
@bp.route('/list', methods=['GET'])
def list_documents():try:# 获取分页参数page = int(request.args.get('page', 1))per_page = int(request.args.get('per_page', 40))# 计算跳过的记录数量skip = (page - 1) * per_page# 获取集合with get_mongo_db() as m_db:collection = m_db.information# 查询文档并排序pipeline = [{"$sort": {"publish_date": -1}},{"$skip": skip},{"$limit": per_page},{"$project": {"full_title": 1,"report_type": 1,"publish_date": 1,"researcher": 1,"detail_link": 1,"_id": {"$toString": "$_id"}}}]documents = collection.aggregate(pipeline)# 将查询结果转换为列表documents_list = list(documents)# 获取总记录数total_documents = collection.count_documents({})# 计算总页数total_pages = (total_documents + per_page - 1) // per_pageresult = {"documents": documents_list,"page": page,"per_page": per_page,"total_pages": total_pages,"total_documents": total_documents}return Success(message="查询列表成功", result=result)except Exception as e:logger.error(e)return Fail('查询失败')
然后这里普及一下我踩的坑吧,
1.在插入数据的时候,会自动生成一个_id的对象,这是mongdb自动生成,且是唯一的,如果你
from bson improt Objectid
Objectid(id)
利用这个把前端传的字符串id对象转为Objectid,这样才好去查询
如果是返回的话,直接下面这样操作
document['_id'] = str(document['_id'])