MongoDb随笔，PyMongo简单使用

安装MongoDb

【更新2021-07-06】

https://www.mongodb.com/try/download/community 下载对应系统的软件版本（CentOS7.9 mongod 4.4.6）
rpm -ivh mongodb-org-server-4.4.6-1.el7.x86_64.rpm安装服务
systemctl start mongod启动服务
rpm -ivh mongodb-org-shell-4.4.6-1.el7.x86_64.rpm安装客户端程序mongo

【很久很久以前】
MongoDb下载对应的系统版本的可执行文件
本人系统环境:rhel-server-6.2-x86_64
解压缩包tar zxvf mongodb-linux-x86_64-rhel62-3.0.2.tgz

可以查看目录下的README，了解各个可执行文件的作用。
简单启动命令 mkdir db; mongo --dbpath=./db
mongo --help 可以获取更多帮助。
也可以指定配置文件来更改启动参数参考https://docs.mongodb.com/manual/reference/configuration-options/#configuration-file

安装PyMongo

安装命令：pip install pymongo
更多关于pip的应用可参考Python下pip pydoc 2to3等工具

PyMongo简单使用

#!/usr/bin/env python
# -*- coding: utf-8 -*-import pymongo
import datetimedef get_db():# 建立连接client = pymongo.MongoClient(host="127.0.0.1", port=27017)db = client['example']#或者 db = client.examplereturn dbdef get_collection(db):# 选择集合（mongo中collection和database都是延时创建的）coll = db['informations']print(db.collection_names())return colldef insert_one_doc(db):# 插入一个documentcoll = db['informations']information = {"name": "quyang", "age": "25"}information_id = coll.insert(information)print(information_id)def insert_multi_docs(db):# 批量插入documents,插入一个数组coll = db['informations']information = [{"name": "xiaoming", "age": "25"}, {"name": "xiaoqiang", "age": "24"}]information_id = coll.insert(information)print(information_id)def get_one_doc(db):# 有就返回一个，没有就返回Nonecoll = db['informations']print(coll.find_one())  # 返回第一条记录print(coll.find_one({"name": "quyang"}))print(coll.find_one({"name": "none"}))def get_one_by_id(db):# 通过objectid来查找一个doccoll = db['informations']obj = coll.find_one()obj_id = obj["_id"]print("_id 为ObjectId类型，obj_id:" + str(obj_id))print(coll.find_one({"_id": obj_id}))# 需要注意这里的obj_id是一个对象，不是一个str，使用str类型作为_id的值无法找到记录print("_id 为str类型 ")print(coll.find_one({"_id": str(obj_id)}))# 可以通过ObjectId方法把str转成ObjectId类型from bson.objectid import ObjectIdprint("_id 转换成ObjectId类型")print(coll.find_one({"_id": ObjectId(str(obj_id))}))def get_many_docs(db):# mongo中提供了过滤查找的方法，可以通过各种条件筛选来获取数据集，还可以对数据进行计数，排序等处理coll = db['informations']#ASCENDING = 1 升序;DESCENDING = -1降序;default is ASCENDINGfor item in coll.find().sort("age", pymongo.DESCENDING):print(item)count = coll.count()print("集合中所有数据 %s个" % int(count))#条件查询count = coll.find({"name":"quyang"}).count()print("quyang: %s"%count)def clear_all_datas(db):#清空一个集合中的所有数据db["informations"].remove()if __name__ == '__main__':db = get_db()my_collection = get_collection(db)post = {"author": "Mike", "text": "My first blog post!", "tags": ["mongodb", "python", "pymongo"],"date": datetime.datetime.utcnow()}# 插入记录my_collection.insert(post)insert_one_doc(db)# 条件查询print(my_collection.find_one({"x": "10"}))# 查询表中所有的数据for iii in my_collection.find():print(iii)print(my_collection.count())my_collection.update({"author": "Mike"},{"author": "quyang", "text": "My first blog post!", "tags": ["mongodb", "python", "pymongo"],"date": datetime.datetime.utcnow()})for jjj in my_collection.find():print(jjj)get_one_doc(db)get_one_by_id(db)get_many_docs(db)# clear_all_datas(db)