mongodb

web

pymongo

连接

>>> from pymongo import MongoClient
>>> client = MongoClient()
>>> client = MongoClient('localhost', 27017)
>>> client = MongoClient('mongodb://localhost:27017/')

获得实例

db = client.test_database
db = client['test-database']
collection = db.test_collection
collection = db['test-collection']

>>> import datetime
>>> post = {"author": "Mike",
...         "text": "My first blog post!",
...         "tags": ["mongodb", "python", "pymongo"],
...         "date": datetime.datetime.utcnow()}
>>> posts = db.posts
>>> post_id = posts.insert_one(post).inserted_id
>>> post_id
ObjectId('...')

参考

PyMongo 3.4.0 documentation

数据库层次

1. 文档，键值对的有序集
2. 集合，文档集
3. 数据库，由集合组成

全局

use DATABASE // 进入数据库无则创建
db.dropDatabase() // 删除当前数据库
db.col.drop() // 删除集合col
db // 显示当前的数据库
show dbs // 显示所有数据库
show collections 

查询

条件查询

db.col.find({key1:value1, key2:value2}) // and条件
db.col.find({$or: [{key1: value1}, {key2:value2}]}) // or条件
# 条件操作符
(>) 大于 - $gt
(<) 小于 - $lt
(>=) 大于等于 - $gte
(<= ) 小于等于 - $lte
# 例
db.person.find({"age" : {$gt : 20}}) // 找到年龄大于20岁的人
db.col.find({"title" : {$type : 2}}) // 指定类型

结果集修饰

db.col.find().pe
db.col.find().limit(NUMBER)
db.col.find().limit(NUMBER).skip(NUMBER)
db.col.find().sort({KEY:1}) // 1为升序，-1为降序

插入

db.col.insert()
db.col.batchInsert() // 批量插入

更新

db.col.update(
   <query>, // 查询条件
   <update>, // 更新
   {
     upsert: <boolean>, // 不存在时是否插入，默认为false
     multi: <boolean>, // 是否更新多条，默认为false
     writeConcern: <document> // 异常级别
   }
)

删除

db.col.drop() // 清空集合
db.col.remove() // 清空集合
db.col.remove(
   <query>,
   {
     justOne: <boolean>,
     writeConcern: <document>
   }
)

索引

db.col.ensureIndex({KEY:1}, {param: type}) // 创建索引, 可指定参数

聚合

db.COLLECTION_NAME.aggregate(AGGREGATE_OPERATION)

参数说明

数据类型

参考

菜鸟教程