[78]pymongo学习总结

1、简介

MongoDB是一种强大、灵活、追求性能、易扩展的数据存储方式。是面向文档的数据库&＃xff0c;不是关系型数据库&＃xff0c;是NoSQL(not only SQL)的一种。所谓的面向文档&＃xff0c;就是将原来关系型数据库中的“行”的概念换成了更加灵活的"文档"&＃xff0c;以文档为存储单位。文档的值可以是数组、文档等复杂的数据模型。并且文档的键不会事先定义也不会固定不变。mongoDB设计的主要思想之一就是&＃xff0c;将能交给客户端的操作都要从服务端转移到客户端。

文档

文档是MongoDB的核心、基本数据单元&＃xff0c;类似于JS中的JSON对象&＃xff0c;由多个key-value构成&＃xff0c;但是支持更多的数据类型。多个键以及相关的值有序的放置在一起便是文档。在大多数编程语言中都是使用多个key-value的形式&＃xff0c;Java中是map&＃xff0c;Python中是字典&＃xff0c;Javascript中是对象。

文档中的key/value是有序的&＃xff0c;没有相同的两个文档。
文档中的value的数据类型没有限制&＃xff0c;甚至可以是文档。
文档的key一般应该是字符串。
文档的key不能含有空字符串&＃xff0c;不能含有.和$以及_。
文档的key不能重复。
mangoDB中&＃xff0c;key和value都是区分数据类型和大小写的。

集合

集合就是一组文档&＃xff0c;如果说文档类似于关系数据库中的行&＃xff0c;那么集合就是表。集合是无模式的(模式的概念参见模式的意义)。一个集合中的文档可以是任意类型的&＃xff0c;也就是说文档是可以任意组合的。

和key一样不能有空字符串
不能以"system.“开头&＃xff0c;不能含有”$"
一个集合的完全限定名&＃xff1a;数据库名.集合(子集合)名称&＃xff0c;例如cms.blog.posts

数据库

MangoDB中最基本的存储单元是文档&＃xff0c;文档组成集合&＃xff0c;集合组成数据库。一个MangoDB实例可以承载多个数据库&＃xff0c;数据库之间完全独立。一般情况下&＃xff0c;一个应用对应一个数据库&＃xff0c;类似于关系数据库中的外模式。

不能是空字符串
不得含有空格、点、斜杠与反斜杠以及空字符串。
应该全部小写
最多64字节

查看mongodb版本信息 mongod -v

配置文件参数说明&＃xff1a;

mongodb的参数说明&＃xff1a;--dbpath 数据库路径(数据文件)--logpath 日志文件路径
--master 指定为主机器
--slave 指定为从机器
--source 指定主机器的IP地址
--pologSize 指定日志文件大小不超过64M.因为resync是非常操作量大且耗时&＃xff0c;最好通过设置一个足够大的oplogSize来避免resync(默认的 oplog大小是空闲磁盘大小的5%)。
--logappend 日志文件末尾添加
--port 启用端口号
--fork 在后台运行
--only 指定只复制哪一个数据库
--slavedelay 指从复制检测的时间间隔
--auth 是否需要验证权限登录(用户名和密码)注&＃xff1a;mongodb配置文件里面的参数很多&＃xff0c;定制特定的需求&＃xff0c;请参考官方文档


配置文件内容&＃xff1a;

dbpath&＃61;/data/mongodb
logpath&＃61;/data/mongodb/log/mongodb.log
logappend&＃61;true
port&＃61;27017
fork&＃61;true
##auth &＃61; true # 先关闭, 创建好用户在启动


2、安装与使用

1、安装

pip install pymongo


2、使用

2.1 连接

(1) 导入

from pymongo import MongoClient


(2) 连接mongodb

host &＃61; localhost
port &＃61; 27017client &＃61; MongoClient(host,port)


(3) 连接数据库

db &＃61; client.test_databaseor db &＃61; client[test_database]


注&＃xff1a;当连接的数据库设置了auth之后&＃xff0c;需要这样连接&＃xff0c;不同版本&＃xff0c;不同平台都不一样&＃xff0c;具体见官方文档

client[test_database].authenticate("user","passwd",mechanism&＃61;"SCRAM-SHA-1")


(4) 连接数据库中的某个集合

## 获取该数据库中的非系统集合
db.collection_names(include_system_collections&＃61;False)## 连接集合
collection &＃61; db[collection_name]
or
collection &＃61; db.collection_name


2.2 增删改查

很好的一点就是&＃xff0c;数据库不需要先建立&＃xff0c;在连接后&＃xff0c;如果进行插入数据操作&＃xff0c;系统可以自己创建&＃xff0c;上面提到过&＃xff0c;mongodb的数据&＃xff0c;使用的是类似json风格的文档&＃xff0c;在python中即为字典&＃xff0c;形如下例&＃xff1a;

insert_data &＃61; {"author": "Mike","text": "My first blog post!","tags": ["mongodb", "python", "pymongo"],"date": datetime.datetime.utcnow()}


collection &＃61; db[collection_name]

(1)增

在插入一个文档时&＃xff0c;MongoDB会自动给每个文档增加一个”_id”的键&＃xff0c;这个键是通过复杂计算出来的&＃xff0c;不会重复&＃xff0c;类似于下面这样的&＃xff1a;

ObjectId(&＃39;4ea02dfdd483050fe8000001&＃39;)


那么如何利用ObjectId查询&＃xff0c;这里有一个坑

>>> import pymongo
>>> import time
>>> db &＃61; pymongo.Connection("192.168.xx.xx",27017).linuxyan
>>> posts &＃61; db.posts
>>> post &＃61; {"id": "1",
... "author": "Mike",
... "text": "My first blog post!",
... "tags": ["mongodb", "python", "pymongo"],
... "date": time.strftime(&＃39;%Y-%m-%d %H:%M:%S&＃39;)}
>>> posts.insert(post)
ObjectId(&＃39;53bd5a5fe138235f74b67563&＃39;)#//插入数据成功
#//利用{&＃39;author&＃39;:&＃39;Mike&＃39;} 测试查询正常
>>> posts.find_one({&＃39;author&＃39;:&＃39;Mike&＃39;})
{u&＃39;_id&＃39;: ObjectId(&＃39;53bd5a5fe138235f74b67563&＃39;), u&＃39;author&＃39;: u&＃39;Mike&＃39;,....}#//利用{&＃39;_id&＃39;:"ObjectId(&＃39;53bd5a5fe138235f74b67563&＃39;)"}查询为空
>>>posts.find_one({&＃39;_id&＃39;:"ObjectId(&＃39;53bd5a5fe138235f74b67563&＃39;)"}) #//如何利用ObjectId来查询&＃xff1f;
>>> from bson import ObjectId
>>> posts.find_one({&＃39;_id&＃39;:ObjectId(&＃39;53bd5a5fe138235f74b67563&＃39;)})
{ u&＃39;_id&＃39;: ObjectId(&＃39;53bd5a5fe138235f74b67563&＃39;), u&＃39;author&＃39;: u&＃39;Mike&＃39;,....}
#//原来ObjectId是一个对象&＃xff0c;而不是一个字符串&＃xff0c;此时我只能"呵呵"&＃xff0c;折腾两个多小时。


增加数据不需要事先定义文档的机构&＃xff0c;每个文档的结构也可以不一样

单条插入

result &＃61; collection.insert_one(insert_data)


多条插入

result &＃61; collection.insert_many(insert_datas)


返回插入id

result.insert_id [单]
result.insert_ids [多]


(2)查

无条件查询

collection.find_one() [单]
collection.find() [多]


条件查询

collection.find({"author": "Mike"})
collection.find_one({"author": "Mike"})
cursor &＃61; collection.find({
"$or":[{"cuisine": "Italian", "address.zipcode": "10075"}]
}
)
[仅显示cuisine为Italian和address.zipcode为10075的数据。两个条件只要满足一个就可以]


区间查询

d &＃61; datetime.datetime(2009, 11, 12, 12)
for post in collection.find({"date": {"$lt": d}}).sort("author"): print post$lt 小于


文档记录数

collection.count()


数据排序

调用 pymongo.ASCENDING()和pymongo.DESCENDING()来指定是按升降序进行排序

cursor &＃61; collection.find().sort([("borough", pymongo.ASCENDING),("address.zipcode", pymongo.ASCENDING)
])


从第几行开始读取(SLICE)&＃xff0c;读取多少行(LIMIT)

for u in collection.find().skip(2).limit(3): print u


IN

for u in db.users.find({"age":{"$in":(23, 26, 32)}}): print u
for u in db.users.find({"age":{"$nin":(23, 26, 32)}}): print u


是否存在

db.users.find({&＃39;sex&＃39;:{&＃39;$exists&＃39;:True}}) # select * from 集合名 where exists 键1
db.users.find({&＃39;sex&＃39;:{&＃39;$exists&＃39;:False}}) # select * from 集合名 where not exists 键1


正则表达式查询

for u in db.users.find({"name" : {"$regex" : r"(?i)user[135]"}}, ["name"]): print u # 查询出 name 为 user1, user3, user5 的


多级路径的元素值匹配

Document 采取 JSON-like 这种层级结构&＃xff0c;因此我们可以直接用嵌入(Embed)代替传统关系型数据库的关联引用(Reference)。MongoDB 支持以 "." 分割的 namespace 路径&＃xff0c;条件表达式中的多级路径须用引号# 条件表达式中的多级路径须用引号,以 "." 分割u &＃61; 集合名.find_one({"im.qq":12345678})# 查询结果如&＃xff1a;{"_id" : ObjectId("4c479885089df9b53474170a"), "name" : "user1", "im" : {"msn" : "user1&＃64;hotmail.com", "qq" : 12345678}}


(3)改

origin_data &＃61; {"title":"Python and MongoDB","slug":"python-mongodb","author":"SErHo","content":"Python and MongoDB....","tags":["Python","MongoDB"],"time":datetime.datetime.now()}


>>> post &＃61; posts.find_one({"slug":"python-mongodb"})
>>> post["author"]
u&＃39;SErHo&＃39;
>>> post["author"] &＃61; "HaHa Lu"
>>> post["title"] &＃61; "Test Update"
>>> post["title"] &＃61; "Test Update"
>>> post["_id"]
ObjectId(&＃39;4ea0207dd483050fe8000001&＃39;)
>>> posts.update({"_id":post["_id"]},post)
>>> post &＃61; posts.find_one({"_id":post["_id"]})
>>> print post
{u&＃39;author&＃39;: u&＃39;HaHa Lu&＃39;, u&＃39;title&＃39;: u&＃39;Test Update&＃39;,u&＃39;tags&＃39;: [u&＃39;Python&＃39;, u&＃39;MongoDB&＃39;],u&＃39;content&＃39;: u&＃39;Python and MongoDB....&＃39;,u&＃39;time&＃39;: datetime.datetime(2011, 10, 20, 21, 21, 52, 818000),u&＃39;_id&＃39;: ObjectId(&＃39;4ea0207dd483050fe8000001&＃39;),u&＃39;slug&＃39;: u&＃39;python-mongodb&＃39;}


首先我们根据slug来获得一篇文章&＃xff0c;然后可以通过Python字典访问方法得到键的值&＃xff0c;然后重新设置&＃xff0c;再对post集合进行更新&＃xff0c;在对整个集合进行更新时&＃xff0c;你得先匹配要更改的文档&＃xff0c;利用_id这个属性来更新是比较常用的方法&＃xff0c;因为你其他改了&＃xff0c;这个可改不了。在执行update中最常见的错误就是限制的条件找到了多个文档&＃xff0c;如果这样&＃xff0c;数据库就不会更新这个集合&＃xff0c;所有最好使用_id来匹配。

如果只更新一个键呢&＃xff0c;那就不用这么大费周折了&＃xff0c;可以使用”$set”这个修改器&＃xff0c;指定一个键&＃xff0c;如果不存在&＃xff0c;就可以创建。比如我要继续更新上面那篇文章的content&＃xff0c;可以这样做&＃xff08;记住&＃xff0c;修改它&＃xff0c;必须先找到它&＃xff0c;这里我利用上面查询到的_id值来找&＃xff09;&＃xff1a;

>>> posts.update({"_id":post["_id"]},{"$set": {"content":"Test Update SET...."}})


MongoDB的修改是很强大的&＃xff0c;你可以把数据类型也给改了&＃xff0c;比如把tags的数组改成普通的字符串。”$set”过后又想删除这个键\&＃xff0c;可以使用”$unset”。如果我的这个post里面有一个键是views&＃xff0c;即文章访问的次数&＃xff0c;我想在每次访问这个文章后给它的值增加1&＃xff0c;这该怎么办&＃xff1f;于是”$inc”修改器出场了&＃xff0c;这个可以用来增加已有键的值&＃xff0c;如果没有&＃xff0c;则创建它&＃xff0c;类似的用法是&＃xff1a;

>>> posts.update({"_id":post["_id"]},{"$inc": {"views":1}})


如果想修改tags这个数组里面的内容怎么办&＃xff1f;有一个办法就是用$set整体修改&＃xff0c;但只是改里面的一些元素呢&＃xff0c;MongoDB准备好了用于数组的修改器。比如&＃xff0c;想要在tags里面加一个”Test”&＃xff0c;这需要使用”$push”&＃xff0c;它可以在数组末尾添加一个元素&＃xff1a;

>>> posts.update({"_id":post["_id"]},{"$push":{"tags":"Test"}})


为了避免加入了重复的&＃xff0c;可以将”$push”改为使用”$addToSet”&＃xff0c;如果需要添加多个值&＃xff0c;可以配合”$each”来使用&＃xff0c;这样就可以添加不重复的进去&＃xff0c;如下面&＃xff1a;

>>> posts.update({"_id":post["_id"]},{"$addToSet": {"tags":{"$each":["Python","Each"]}}})


(4) 删

可以把数组看成栈和队列&＃xff0c;使用”$pop”来操作&＃xff0c;比如上面的&＃xff1a;

>>> posts.update({"_id":post["_id"]},{"$pop":{"tags":1}})


这个会删除tags里面最后一个&＃xff0c;改成-1则删除第一个。可以使用$pull来删除数组中指定的值&＃xff0c;它会删除数组中所有匹配的值。如何修改其中的一个值呢&＃xff1f;可以先删除掉&＃xff0c;再增加一个进去&＃xff0c;还有就是直接定位修改。比如tags数组中&＃xff0c;”Python”是第一个&＃xff0c;想把它改成”python”&＃xff0c;可以通过下标直接选择,就是tags[0]&＃xff0c;然后使用上面的$set等修改器&＃xff0c;如果不确定可以使用$来定位&＃xff1a;

>>> posts.update({"tags":"MongoDB"},{"$set":{"tags.$":"Hello"}})


这个将先搜索tags中满足”MongoDB”的&＃xff0c;如果找到&＃xff0c;就把它修改为”Hello”。可以看到上面的update这个函数已经有两个参数了&＃xff0c;它还有第3个参数upsert&＃xff0c;如果设为”True”&＃xff0c;则如果没有找到匹配的文档&＃xff0c;就会在匹配的基础上新建一个文档

3、相关操作

注&＃xff1a;collection:user
(1) $all: 判断数组属性是否包含全部条件。db.users.insert({&＃39;name&＃39;:"user3", &＃39;data&＃39;:[1,2,3,4,5,6,7]})db.users.insert({&＃39;name&＃39;:"user4", &＃39;data&＃39;:[1,2,3]})for u in db.users.find({&＃39;data&＃39;:{&＃39;$all&＃39;:[2,3,4]}}): print u# 显示&＃xff1a; { "_id" : ObjectId("4c47a133b48cde79c6780df0"), "name" : "user3", "data" : [ 1, 2, 3, 4, 5, 6, 7 ] }注意和 $in 的区别。$in 是检查目标属性值是条件表达式中的一员&＃xff0c;而 $all 则要求属性值包含全部条件元素。(2) $size: 匹配数组属性元素数量。for u in db.users.find({&＃39;data&＃39;:{&＃39;$size&＃39;:3}}): print u# 只显示匹配此数组数量的&＃xff1a; { "_id" : ObjectId("4c47a13bb48cde79c6780df1"), "name" : "user4", "data" : [ 1, 2, 3 ] }(3) $type: 判断属性类型。for u in db.users.find({&＃39;t&＃39;:{&＃39;$type&＃39;:1}}): print u # 查询数字类型的for u in db.users.find({&＃39;t&＃39;:{&＃39;$type&＃39;:2}}): print u # 查询字符串类型的类型值:double:1string: 2object: 3array: 4binary data: 5object id: 7boolean: 8date: 9null: 10regular expression: 11Javascript code: 13symbol: 14Javascript code with scope: 1532-bit integer: 16timestamp: 1764-bit integer: 18min key: 255max key: 127(4) $not: 取反&＃xff0c;表示返回条件不成立的文档。似乎只能跟正则和 $mod 一起使用&＃xff1f;&＃xff1f;&＃xff1f;&＃xff1f;# 还不知如何使用(5) $unset: 和 $set 相反&＃xff0c;表示移除文档属性。for u in db.users.find({&＃39;name&＃39;:"user1"}): print u# 显示如&＃xff1a; { "_id" : ObjectId("4c479885089df9b53474170a"), "name" : "user1", "age" : 15, "address" : [ "address1", "address2" ] }db.users.update({&＃39;name&＃39;:"user1"}, {&＃39;$unset&＃39;:{&＃39;address&＃39;:1, &＃39;age&＃39;:1}})for u in db.users.find({&＃39;name&＃39;:"user1"}): print u# 显示如&＃xff1a; { "_id" : ObjectId("4c479885089df9b53474170a"), "name" : "user1" }(6) $push: 和 $ pushAll 都是向数组属性添加元素。# 好像两者没啥区别for u in db.users.find({&＃39;name&＃39;:"user1"}): print u# 显示如&＃xff1a; { "_id" : ObjectId("4c479885089df9b53474170a"), "age" : 15, "name" : "user1" }db.users.update({&＃39;name&＃39;:"user1"}, {&＃39;$push&＃39;:{&＃39;data&＃39;:1}})for u in db.users.find({&＃39;name&＃39;:"user1"}): print u# 显示如&＃xff1a; { "_id" : ObjectId("4c479885089df9b53474170a"), "age" : 15, "data" : [ 1 ], "name" : "user1" }db.users.update({&＃39;name&＃39;:"user1"}, {&＃39;$pushAll&＃39;:{&＃39;data&＃39;:[2,3,4,5]}})for u in db.users.find({&＃39;name&＃39;:"user1"}): print u# 显示如&＃xff1a; { "_id" : ObjectId("4c479885089df9b53474170a"), "age" : 15, "data" : [ 1, 2, 3, 4, 5 ], "name" : "user1" }(7) $addToSet: 和 $push 类似&＃xff0c;不过仅在该元素不存在时才添加 (Set 表示不重复元素集合)。db.users.update({&＃39;name&＃39;:"user2"}, {&＃39;$unset&＃39;:{&＃39;data&＃39;:1}})db.users.update({&＃39;name&＃39;:"user2"}, {&＃39;$addToSet&＃39;:{&＃39;data&＃39;:1}})db.users.update({&＃39;name&＃39;:"user2"}, {&＃39;$addToSet&＃39;:{&＃39;data&＃39;:1}})for u in db.users.find({&＃39;name&＃39;:"user2"}): print u# 显示&＃xff1a; { "_id" : ObjectId("4c479896089df9b53474170b"), "data" : [ 1 ], "name" : "user2" }db.users.update({&＃39;name&＃39;:"user2"}, {&＃39;$push&＃39;:{&＃39;data&＃39;:1}})for u in db.users.find({&＃39;name&＃39;:"user2"}): print u# 显示&＃xff1a; { "_id" : ObjectId("4c479896089df9b53474170b"), "data" : [ 1, 1 ], "name" : "user2" }要添加多个元素&＃xff0c;使用 $each。db.users.update({&＃39;name&＃39;:"user2"}, {&＃39;$addToSet&＃39;:{&＃39;data&＃39;:{&＃39;$each&＃39;:[1,2,3,4]}}})for u in db.users.find({&＃39;name&＃39;:"user2"}): print u# 显示&＃xff1a; {u&＃39;age&＃39;: 12, u&＃39;_id&＃39;: ObjectId(&＃39;4c479896089df9b53474170b&＃39;), u&＃39;data&＃39;: [1, 1, 2, 3, 4], u&＃39;name&＃39;: u&＃39;user2&＃39;}# 貌似不会自动删除重复(8) $each 添加多个元素用。db.users.update({&＃39;name&＃39;:"user2"}, {&＃39;$unset&＃39;:{&＃39;data&＃39;:1}})db.users.update({&＃39;name&＃39;:"user2"}, {&＃39;$addToSet&＃39;:{&＃39;data&＃39;:1}})for u in db.users.find({&＃39;name&＃39;:"user2"}): print u# 显示&＃xff1a; { "_id" : ObjectId("4c479896089df9b53474170b"), "data" : [ 1 ], "name" : "user2" }db.users.update({&＃39;name&＃39;:"user2"}, {&＃39;$addToSet&＃39;:{&＃39;data&＃39;:{&＃39;$each&＃39;:[1,2,3,4]}}})for u in db.users.find({&＃39;name&＃39;:"user2"}): print u# 显示&＃xff1a; {u&＃39;age&＃39;: 12, u&＃39;_id&＃39;: ObjectId(&＃39;4c479896089df9b53474170b&＃39;), u&＃39;data&＃39;: [1, 2, 3, 4], u&＃39;name&＃39;: u&＃39;user2&＃39;}db.users.update({&＃39;name&＃39;:"user2"}, {&＃39;$addToSet&＃39;:{&＃39;data&＃39;:[1,2,3,4]}})for u in db.users.find({&＃39;name&＃39;:"user2"}): print u# 显示&＃xff1a; { "_id" : ObjectId("4c479896089df9b53474170b"), "data" : [ 1, 2, 3, 4, [ 1, 2, 3, 4 ] ], "name" : "user2" }db.users.update({&＃39;name&＃39;:"user2"}, {&＃39;$unset&＃39;:{&＃39;data&＃39;:1}})db.users.update({&＃39;name&＃39;:"user2"}, {&＃39;$addToSet&＃39;:{&＃39;data&＃39;:[1,2,3,4]}})for u in db.users.find({&＃39;name&＃39;:"user2"}): print u# 显示&＃xff1a; { "_id" : ObjectId("4c47a133b48cde79c6780df0"), "data" : [ [1, 2, 3, 4] ], "name" : "user2" }(9) $pop: 移除数组属性的元素(按数组下标移除)&＃xff0c;$pull 按值移除&＃xff0c;$pullAll 移除所有符合提交的元素。db.users.update({&＃39;name&＃39;:"user2"}, {&＃39;$unset&＃39;:{&＃39;data&＃39;:1}})db.users.update({&＃39;name&＃39;:"user2"}, {&＃39;$addToSet&＃39;:{&＃39;data&＃39;:{&＃39;$each&＃39;:[1, 2, 3, 4, 5, 6, 7, 2, 3 ]}}})for u in db.users.find({&＃39;name&＃39;:"user2"}): print u# 显示&＃xff1a; { "_id" : ObjectId("4c47a133b48cde79c6780df0"), "data" : [ 1, 2, 3, 4, 5, 6, 7, 2, 3 ], "name" : "user2" }db.users.update({&＃39;name&＃39;:"user2"}, {&＃39;$pop&＃39;:{&＃39;data&＃39;:1}}) # 移除最后一个元素for u in db.users.find({&＃39;name&＃39;:"user2"}): print u# 显示&＃xff1a; { "_id" : ObjectId("4c47a133b48cde79c6780df0"), "data" : [ 1, 2, 3, 4, 5, 6, 7, 2 ], "name" : "user2" }db.users.update({&＃39;name&＃39;:"user2"}, {&＃39;$pop&＃39;:{&＃39;data&＃39;:-1}}) # 移除第一个元素for u in db.users.find({&＃39;name&＃39;:"user2"}): print u# 显示&＃xff1a; { "_id" : ObjectId("4c47a133b48cde79c6780df0"), "data" : [ 2, 3, 4, 5, 6, 7, 2 ], "name" : "user2" }db.users.update({&＃39;name&＃39;:"user2"}, {&＃39;$pull&＃39;:{&＃39;data&＃39;:2}}) # 移除全部 2for u in db.users.find({&＃39;name&＃39;:"user2"}): print u# 显示&＃xff1a; { "_id" : ObjectId("4c47a133b48cde79c6780df0"), "data" : [ 3, 4, 5, 6, 7 ], "name" : "user2" }db.users.update({&＃39;name&＃39;:"user2"}, {&＃39;$pullAll&＃39;:{&＃39;data&＃39;:[3,5,6]}}) # 移除 3,5,6for u in db.users.find({&＃39;name&＃39;:"user2"}): print u# 显示&＃xff1a; { "_id" : ObjectId("4c47a133b48cde79c6780df0"), "data" : [ 4, 7 ], "name" : "user2" }(10) $where: 用 JS 代码来代替有些丑陋的 $lt、$gt。MongoDB 内置了 Javascript Engine (SpiderMonkey)。可直接使用 JS Expression&＃xff0c;甚至使用 JS Function 写更复杂的 Code Block。db.users.remove() # 删除集合里的所有记录for i in range(10):db.users.insert({&＃39;name&＃39;:"user" &＃43; str(i), &＃39;age&＃39;:i})for u in db.users.find(): print u# 显示如下&＃xff1a;{ "_id" : ObjectId("4c47b3372a9b2be866da226e"), "name" : "user0", "age" : 0 }{ "_id" : ObjectId("4c47b3372a9b2be866da226f"), "name" : "user1", "age" : 1 }{ "_id" : ObjectId("4c47b3372a9b2be866da2270"), "name" : "user2", "age" : 2 }{ "_id" : ObjectId("4c47b3372a9b2be866da2271"), "name" : "user3", "age" : 3 }{ "_id" : ObjectId("4c47b3372a9b2be866da2272"), "name" : "user4", "age" : 4 }{ "_id" : ObjectId("4c47b3372a9b2be866da2273"), "name" : "user5", "age" : 5 }{ "_id" : ObjectId("4c47b3372a9b2be866da2274"), "name" : "user6", "age" : 6 }{ "_id" : ObjectId("4c47b3372a9b2be866da2275"), "name" : "user7", "age" : 7 }{ "_id" : ObjectId("4c47b3372a9b2be866da2276"), "name" : "user8", "age" : 8 }{ "_id" : ObjectId("4c47b3372a9b2be866da2277"), "name" : "user9", "age" : 9 }for u in db.users.find({"$where":"this.age > 7 || this.age <3"}): print u# 显示如下&＃xff1a;{u&＃39;age&＃39;: 0.0, u&＃39;_id&＃39;: ObjectId(&＃39;4c47b3372a9b2be866da226e&＃39;), u&＃39;name&＃39;: u&＃39;user0&＃39;}{u&＃39;age&＃39;: 1.0, u&＃39;_id&＃39;: ObjectId(&＃39;4c47b3372a9b2be866da226f&＃39;), u&＃39;name&＃39;: u&＃39;user1&＃39;}{u&＃39;age&＃39;: 2.0, u&＃39;_id&＃39;: ObjectId(&＃39;4c47b3372a9b2be866da2270&＃39;), u&＃39;name&＃39;: u&＃39;user2&＃39;}{u&＃39;age&＃39;: 8.0, u&＃39;_id&＃39;: ObjectId(&＃39;4c47b3372a9b2be866da2276&＃39;), u&＃39;name&＃39;: u&＃39;user8&＃39;}{u&＃39;age&＃39;: 9.0, u&＃39;_id&＃39;: ObjectId(&＃39;4c47b3372a9b2be866da2277&＃39;), u&＃39;name&＃39;: u&＃39;user9&＃39;}for u in db.users.find().where("this.age > 7 || this.age <3"): print u# 显示如下&＃xff1a;{u&＃39;age&＃39;: 0.0, u&＃39;_id&＃39;: ObjectId(&＃39;4c47b3372a9b2be866da226e&＃39;), u&＃39;name&＃39;: u&＃39;user0&＃39;}{u&＃39;age&＃39;: 1.0, u&＃39;_id&＃39;: ObjectId(&＃39;4c47b3372a9b2be866da226f&＃39;), u&＃39;name&＃39;: u&＃39;user1&＃39;}{u&＃39;age&＃39;: 2.0, u&＃39;_id&＃39;: ObjectId(&＃39;4c47b3372a9b2be866da2270&＃39;), u&＃39;name&＃39;: u&＃39;user2&＃39;}{u&＃39;age&＃39;: 8.0, u&＃39;_id&＃39;: ObjectId(&＃39;4c47b3372a9b2be866da2276&＃39;), u&＃39;name&＃39;: u&＃39;user8&＃39;}{u&＃39;age&＃39;: 9.0, u&＃39;_id&＃39;: ObjectId(&＃39;4c47b3372a9b2be866da2277&＃39;), u&＃39;name&＃39;: u&＃39;user9&＃39;}# 使用自定义的 function, Javascript语法的for u in db.users.find().where("function() { return this.age > 7 || this.age <3;}"): print u# 显示如下&＃xff1a;{u&＃39;age&＃39;: 0.0, u&＃39;_id&＃39;: ObjectId(&＃39;4c47b3372a9b2be866da226e&＃39;), u&＃39;name&＃39;: u&＃39;user0&＃39;}{u&＃39;age&＃39;: 1.0, u&＃39;_id&＃39;: ObjectId(&＃39;4c47b3372a9b2be866da226f&＃39;), u&＃39;name&＃39;: u&＃39;user1&＃39;}{u&＃39;age&＃39;: 2.0, u&＃39;_id&＃39;: ObjectId(&＃39;4c47b3372a9b2be866da2270&＃39;), u&＃39;name&＃39;: u&＃39;user2&＃39;}{u&＃39;age&＃39;: 8.0, u&＃39;_id&＃39;: ObjectId(&＃39;4c47b3372a9b2be866da2276&＃39;), u&＃39;name&＃39;: u&＃39;user8&＃39;}{u&＃39;age&＃39;: 9.0, u&＃39;_id&＃39;: ObjectId(&＃39;4c47b3372a9b2be866da2277&＃39;), u&＃39;name&＃39;: u&＃39;user9&＃39;}


来源&＃xff1a;http://www.cnblogs.com/playcodes/p/6292344.html