MongoDB是由c++语言编写的，是一个基于分布式文件存储的开源数据库系统，在高负载的情况下，添加更多的节点，可以保证服务器性能。MongoDB旨在为web应用提供扩展的高性能数据存储解决方案。MongoDB将数据存储为一个文档，数据结构由键值对（key=value）组成。MongoDB文档类似于json对象。字段值可以包含其他文档，数组及文档数组。在MongoDB数据库中，集合就相当于mysql中的表，文档将相当于mysql中记录。

　　3.1 配置存放数据的路径

　　首先需要我们在MongoDB文件夹下创建一个data文件夹，然后再在data文件夹下创建一个db的文件夹；其次打开cmd，进入D:\MongoDB\bin的目录下，输入指令：mongod.exe –dbpath=D:\MongoDB\data\db

　　3.2 配置日志路径

　　cmd在D:\MongoDB\bin的目录下，输入指令：mongod.exe –logpath=D:\MongoDB\data\log\mongodb.log 

　　我们在D:\MongoDb目录下，创建一个mongodb.config 配置文件，有两个属性logpath和dbpath，分别设定值，就是刚才我们配置的路径，在这文件里写入：

  1. dbpath=D:\MongoDB\data\db
  2. logpath=D:\MongoDB\data\log\mongodb.log

　　首先打开一个cmd，进入D:\MongoDB\bin的目录下输入：mongod.exe  –config d:\MongoDB\mongodb.config，这是启动MongoDB服务器，启动之后不要关闭cmd；其次是，再打开一个cmd，同样进入D:\MongoDB\bin的目录下，输入：mongo

　　这就说明配置完成，可以使用MongoDB了

　　以管理员身份进入cmd，然后进入到D:\MongoDB\bin的目录下，输入指令：mongod.exe–dbpath=d:\MongoDB\data\db –logpath=d:\MongoDB\data\log\log.txt  –install –serviceName “MongoDB”；

　　以管理员身份进入cmd，输入：net start mongodb ,这样服务就启动了；输入：net stop mongodb,服务就关闭了

  1. > use blog      #这是进入blog库，如果blog库不存在，它会创建
  2. switched to db blog
  3. > show dbs     #这是展示所有的库，此时是看不到刚创建的blog库
  4. admin   0.000GB
  5. config  0.000GB
  6. local   0.000GB
  7. test    0.000GB
  8. > db.article.insert({"title":"西游记"})   #这是在blog库下创建一个集合article，并往集合里插入一条文档
  9. WriteResult({ "nInserted" : 1 })
  10. > db.userinfo.insert({"name":"alex"})     #这是在blog库下创建一个集合userinfo，并往集合里面插入一条文档
  11. WriteResult({ "nInserted" : 1 })
  12. > show tables;         #这是展示当前blog库下的所有集合
  13. article
  14. userinfo
  15. > show dbs           #这时，再去查看所有的库，就可以看到blog库
  16. admin 0.000GB
  17. blog 0.000GB
  18. config 0.000GB
  19. local 0.000GB
  20. test 0.000GB
  1. db.article.drop()     #这是删除blog库下的article集合
  1. > db.dropDatabase() #这是删除当前的blog库 { "dropped" : "blog", "ok" : 1 }　　
  1. 1、没有指定_id则默认ObjectId,_id不能重复，且在插入后不可变
  2. #2、插入单条
  3. user0={
  4.     "name":"egon",
  5.     "age":10,
  6.     'hobbies':['music','read','dancing'],
  7.     'addr':{'country':'China','city':'BJ'}}
  8. db.test.insert(user0)    #插入单条文档
  9. db.test.find()          #查询出所有文档
  10. #3、插入多条
  11. user1={
  12.     "_id":1,
  13.     "name":"alex",
  14.     "age":10,
  15.     'hobbies':['music','read','dancing'],
  16.     'addr':{'country':'China','city':'weifang'}}
  17. user2={
  18.     "_id":2,
  19.     "name":"wupeiqi",
  20.     "age":20,
  21.     'hobbies':['music','read','run'],
  22.     'addr':{'country':'China','city':'hebei'}}
  23. user3={
  24.     "_id":3,
  25.     "name":"yuanhao",
  26.     "age":30,
  27.     'hobbies':['music','drink'],
  28.     'addr':{'country':'China','city':'heibei'}}
  29. db.user.insertMany([user1,user2,user3,user4,user5])　#插入多条文档
  30. db.user.find()
  1. ###################### (1) 比较运算  ###################################
  2.  
  3. # SQL：=,!=,>,<,>=,<=
  4. # MongoDB：{key:value}代表什么等于什么,"$ne","$gt","$lt","gte","lte",其中"$ne"能用于所有数据类型
  5.  
  6. #1、select * from db1.user where name = "alex";
  7. db.user.find({'name':'alex'})
  8.  
  9. #2、select * from db1.user where name != "alex";
  10. db.user.find({'name':{"$ne":'alex'}})
  11.  
  12. #3、select * from db1.user where id > 2;
  13. db.user.find({'_id':{'$gt':2}})
  14.  
  15. #4、select * from db1.user where id < 3;
  16. db.user.find({'_id':{'$lt':3}})
  17.  
  18. #5、select * from db1.user where id >= 2;
  19. db.user.find({"_id":{"$gte":2,}})
  20.  
  21. #6、select * from db1.user where id <= 2;
  22. db.user.find({"_id":{"$lte":2}})
  24. ###################### (2) 逻辑运算  ###################################
  25.  
  26. # SQL：and，or，not
  27. # MongoDB：字典中逗号分隔的多个条件是and关系，"$or"的条件放到[]内,"$not"
  28.  
  29. #1、select * from db1.user where id >= 2 and id < 4;
  30. db.user.find({'_id':{"$gte":2,"$lt":4}})
  31.  
  32. #2、select * from db1.user where id >= 2 and age < 40;
  33. db.user.find({"_id":{"$gte":2},"age":{"$lt":40}})
  34.  
  35. #3、select * from db1.user where id >= 5 or name = "alex";
  36. db.user.find({
  37.     "$or":[
  38.         {'_id':{"$gte":5}},
  39.         {"name":"alex"}
  40.         ]
  41. })
  42. #4、select * from db1.user where id % 2=1;
  43. db.user.find({'_id':{"$mod":[2,1]}})
  44.  
  45. #5、上题，取反
  46. db.user.find({'_id':{"$not":{"$mod":[2,1]}}})
  47. ###################### (3) 成员运算  ###################################
  48.  
  49. # SQL：in，not in
  50. # MongoDB："$in","$nin"
  51.  
  52. #1、select * from db1.user where age in (20,30,31);
  53. db.user.find({"age":{"$in":[20,30,31]}})
  54.  
  55. #2、select * from db1.user where name not in ('alex','yuanhao');
  56. db.user.find({"name":{"$nin":['alex','yuanhao']}})
  58. ###################### (4) 正则匹配  ###################################
  59.  
  60. # SQL: regexp 正则
  61. # MongoDB: /正则表达/i
  62.  
  63. #1、select * from db1.user where name regexp '^j.*?(g|n)$';
  64. db.user.find({'name':/^j.*?(g|n)$/i})
  67. ###################### (5) 取指定字段  ###################################
  68.  
  69. #1、select name,age from db1.user where id=3;
  70. db.user.find({'_id':3},{''name':1,'age':1})
  71. #2 db.user.find({'_id':3},{"addr":0})
  72. { "_id" : 3, "name" : "yuanhao", "age" : 30, "hobbies" : [ "music", "drink" ] }
  74. ###################### (6) 查询数组  ###################################
  75.  
  76. #1、查看有dancing爱好的人
  77. db.user.find({'hobbies':'dancing'})
  78.  
  79. #2、查看既有dancing爱好又有tea爱好的人
  80. db.user.find({
  81.     'hobbies':{
  82.         "$all":['dancing','tea']
  83.         }
  84. })
  85.  
  86. #3、查看第4个爱好为tea的人
  87. db.user.find({"hobbies.3":'tea'})
  88.  
  89. #4、查看所有人最后两个爱好
  90. db.user.find({},{'hobbies':{"$slice":-2},"age":0,"_id":0,"name":0,"addr":0})
  91.  
  92. #5、查看所有人的第2个到第3个爱好
  93. db.user.find({},{'hobbies':{"$slice":[1,2]},"age":0,"_id":0,"name":0,"addr":0})
  94.  
  96. ###################### (7) 排序  ###################################
  97.  
  98. # 排序:--1代表升序，-1代表降序
  99. db.user.find().sort({"name":1,})
  100. db.user.find().sort({"age":-1,'_id':1})
  102. ###################### (8) 分页  ###################################
  103.  
  104. # 分页:--limit代表取多少个document，skip代表跳过前多少个document。
  105. db.user.find().sort({'age':1}).limit(1).skip(2)
  106.  
  107. ###################### (9) 查询数量  ###################################
  108. # 获取数量
  109. db.user.count({'age':{"$gt":30}})
  110.  
  111. --或者
  112. db.user.find({'age':{"$gt":30}}).count()
  114. ###################### (10) 其它  ###################################
  115.  
  116. #1、{'key':null} 匹配key的值为null或者没有这个key
  117. db.t2.insert({'a':10,'b':111})
  118. db.t2.insert({'a':20})
  119. db.t2.insert({'b':null})
  120.  
  121. > db.t2.find({"b":null})
  122. { "_id" : ObjectId("5a5cc2a7c1b4645aad959e5a"), "a" : 20 }
  123. { "_id" : ObjectId("5a5cc2a8c1b4645aad959e5b"), "b" : null }
  124.  
  125. #2、查找所有
  126. db.user.find() #等同于db.user.find({})
  127. db.user.find().pretty()
  128.  
  129. #3、查找一个，与find用法一致，只是只取匹配成功的第一个
  130. db.user.findOne({"_id":{"$gt":3}})　
  1. ############################## 1 update的语法  ##############################
  2.  
  3. update() 方法用于更新已存在的文档。语法格式如下：
  4. db.collection.update(
  5.    <query>,
  6.    <update>,
  7.    {
  8.      upsert: <boolean>,
  9.      multi: <boolean>,
  10.      writeConcern: <document>
  11.    }
  12. )
  13. 参数说明：对比update db1.t1 set name='EGON',sex='Male' where name='egon' and age=18;
  14.  
  15. query : 相当于where条件。
  16. update : update的对象和一些更新的操作符（如$,$inc...等，相当于set后面的
  17. upsert : 可选，默认为false，代表如果不存在update的记录不更新也不插入，设置为true代表插入。
  18. multi : 可选，默认为false，代表只更新找到的第一条记录，设为true,代表更新找到的全部记录。
  19. writeConcern :可选，抛出异常的级别。
  20.  
  21. 更新操作是不可分割的：若两个更新同时发送，先到达服务器的先执行，然后执行另外一个，不会破坏文档。
  22.  
  23. ############################## 2 覆盖更新  ##############################
  24.  
  25. #注意：除非是删除，否则_id是始终不会变的
  26. #1 :
  27. db.user.update({'age':20},{"name":"Wxx","hobbies_count":3})
  28. 是用{"_id":2,"name":"Wxx","hobbies_count":3}覆盖原来的记录
  29.  
  30. #2、一种最简单的更新就是用一个新的文档完全替换匹配的文档。这适用于大规模式迁移的情况。例如
  31. var obj=db.user.findOne({"_id":2})
  32.  
  33. obj.username=obj.name+'SB'
  34. obj.hobbies_count++
  35. delete obj.age
  36.  
  37. db.user.update({"_id":2},obj)
  38.  
  39. ############################## 3 局部更新  ##############################
  40.  
  41. #设置：$set
  42.  
  43. 通常文档只会有一部分需要更新。可以使用原子性的更新修改器，指定对文档中的某些字段进行更新。
  44. 更新修改器是种特殊的键，用来指定复杂的更新操作，比如修改、增加后者删除
  45.  
  46. #1、update db1.user set  name="WXX" where id = 2
  47. db.user.update({'_id':2},{"$set":{"name":"WXX",}})
  48.  
  49. #2、没有匹配成功则新增一条{"upsert":true}
  50. db.user.update({'_id':6},{"$set":{"name":"egon","age":18}},{"upsert":true})
  51.  
  52. #3、默认只改匹配成功的第一条,{"multi":改多条}
  53. db.user.update({'_id':{"$gt":4}},{"$set":{"age":28}})
  54. db.user.update({'_id':{"$gt":4}},{"$set":{"age":38}},{"multi":true})
  55.  
  56. #4、修改内嵌文档，把名字为alex的人所在的地址国家改成Japan
  57. db.user.update({'name':"alex"},{"$set":{"addr.country":"Japan"}})
  58.  
  59. #5、把名字为alex的人的地2个爱好改成piao
  60. db.user.update({'name':"alex"},{"$set":{"hobbies.1":"piao"}})
  61.  
  62. #6、删除alex的爱好,$unset
  63. db.user.update({'name':"alex"},{"$unset":{"hobbies":""}})
  64.  
  65. ############################## 4 自增或自减  ##############################
  66.  
  67. #增加和减少：$inc
  68.  
  69. #1、所有人年龄增加一岁
  70. db.user.update({},
  71.     {
  72.         "$inc":{"age":1}
  73.     },
  74.     {
  75.         "multi":true
  76.     }
  77.     )
  78. #2、所有人年龄减少5岁
  79. db.user.update({},
  80.     {
  81.         "$inc":{"age":-5}
  82.     },
  83.     {
  84.         "multi":true
  85.     }
  86.     )
  87.  
  88.  
  89. ############################## 5 添加删除数组内元素 ##############################
  90.  
  91. #添加删除数组内元素：$push,$pop,$pull
  92.      
  93. 往数组内添加元素:$push
  94. #1、为名字为yuanhao的人添加一个爱好read
  95. db.user.update({"name":"yuanhao"},{"$push":{"hobbies":"read"}})
  96.  
  97. #2、为名字为yuanhao的人一次添加多个爱好tea，dancing
  98. db.user.update({"name":"yuanhao"},{"$push":{
  99.     "hobbies":{"$each":["tea","dancing"]}
  100. }})
  101.  
  102. 按照位置且只能从开头或结尾删除元素：$pop
  103. #3、{"$pop":{"key":1}} 从数组末尾删除一个元素
  104.  
  105. db.user.update({"name":"yuanhao"},{"$pop":{
  106.     "hobbies":1}
  107. })
  108.  
  109. #4、{"$pop":{"key":-1}} 从头部删除
  110. db.user.update({"name":"yuanhao"},{"$pop":{
  111.     "hobbies":-1}
  112. })
  113.  
  114. #5、按照条件删除元素,："$pull" 把符合条件的统统删掉，而$pop只能从两端删
  115. db.user.update({'addr.country':"China"},{"$pull":{
  116.     "hobbies":"read"}
  117. },
  118. {
  119.     "multi":true
  120. }
  121. )
  122.  
  123.  
  124. ############################## 6 避免重复添加 ##############################
  125.  
  126. #避免添加重复："$addToSet"
  127.  
  128. db.urls.insert({"_id":1,"urls":[]})
  129.  
  130. db.urls.update({"_id":1},{"$addToSet":{"urls":'http://www.baidu.com'}})
  131. db.urls.update({"_id":1},{"$addToSet":{"urls":'http://www.baidu.com'}})
  132. db.urls.update({"_id":1},{"$addToSet":{"urls":'http://www.baidu.com'}})
  133.  
  134. db.urls.update({"_id":1},{
  135.     "$addToSet":{
  136.         "urls":{
  137.         "$each":[
  138.             'http://www.baidu.com',
  139.             'http://www.baidu.com',
  140.             'http://www.xxxx.com'
  141.             ]
  142.             }
  143.         }
  144.     }
  145. )
  146.  
  147. ############################## 7 其它 ##############################
  148.  
  149. #1、了解：限制大小"$slice"，只留最后n个
  150.  
  151. db.user.update({"_id":5},{
  152.     "$push":{"hobbies":{
  153.         "$each":["read",'music','dancing'],
  154.         "$slice":-2
  155.     }
  156.     }
  157. })
  158.  
  159. #2、了解：排序The $sort element value must be either 1 or -1"
  160. db.user.update({"_id":5},{
  161.     "$push":{"hobbies":{
  162.         "$each":["read",'music','dancing'],
  163.         "$slice":-1,
  164.         "$sort":-1
  165.     }
  166.     }
  167. })
  168.  
  169. #注意：不能只将"$slice"或者"$sort"与"$push"配合使用，且必须使用"$eah"　　
  1. #1、删除多个中的第一个
  2. db.user.deleteOne({ 'age': 8 })
  3.  
  4. #2、删除国家为China的全部
  5. db.user.deleteMany( {'addr.country': 'China'} )
  6.  
  7. #3、删除全部
  8. db.user.deleteMany({}) 
  1. """  
  2. 连接MongoDB
  3.     连接MongoDB我们需要使用PyMongo库里面的MongoClient，一般来说传入MongoDB的IP及端口即可，第一个参数为地址host，
  4.     第二个参数为端口port，端口如果不传默认是27017。
  5. """<br>
  6. import pymongo
  7. client = pymongo.MongoClient(host='localhost', port=27017)<br>
  8. """
  9. 这样我们就可以创建一个MongoDB的连接对象了。另外MongoClient的第一个参数host还可以直接传MongoDB的连接字符串，以mongodb开头，
  10. 例如：client = MongoClient('mongodb://localhost:27017/')可以达到同样的连接效果。<br>
  11. """
  12. # 指定数据库
  13. # MongoDB中还分为一个个数据库，我们接下来的一步就是指定要操作哪个数据库，在这里我以test数据库为例进行说明，所以下一步我们
  14. # 需要在程序中指定要使用的数据库。
  15.   
  16. db = client.test
  17. # 调用client的test属性即可返回test数据库，当然也可以这样来指定：
  18. # db = client['test']
  19. #　两种方式是等价的。
  20.   
  21. # 指定集合
  22. # MongoDB的每个数据库又包含了许多集合Collection，也就类似与关系型数据库中的表，下一步我们需要指定要操作的集合，
  23. # 在这里我们指定一个集合名称为students，学生集合。还是和指定数据库类似，指定集合也有两种方式。
  24.   
  25. collection = db.students
  26. # collection = db['students']
  27. # 插入数据,接下来我们便可以进行数据插入了，对于students这个Collection，我们新建一条学生数据，以字典的形式表示：
  28.   
  29. student = {
  30.     'id': '20170101',
  31.     'name': 'Jordan',
  32.     'age': 20,
  33.     'gender': 'male'
  34. }
  35. # 在这里我们指定了学生的学号、姓名、年龄和性别，然后接下来直接调用collection的insert()方法即可插入数据。
  36.   
  37. result = collection.insert(student)
  38. print(result)
  39. # 在MongoDB中，每条数据其实都有一个_id属性来唯一标识，如果没有显式指明_id，MongoDB会自动产生一个ObjectId类型的_id属性。
  40. # insert()方法会在执行后返回的_id值。
  41.   
  42. # 运行结果：
  43. # 5932a68615c2606814c91f3d
  44. # 当然我们也可以同时插入多条数据，只需要以列表形式传递即可，示例如下：
  45.   
  46. student1 = {
  47.     'id': '20170101',
  48.     'name': 'Jordan',
  49.     'age': 20,
  50.     'gender': 'male'
  51. }
  52.   
  53. student2 = {
  54.     'id': '20170202',
  55.     'name': 'Mike',
  56.     'age': 21,
  57.     'gender': 'male'
  58. }
  59.   
  60. result = collection.insert([student1, student2])
  61. print(result)
  62. # 返回的结果是对应的_id的集合，运行结果：
  63. # [ObjectId('5932a80115c2606a59e8a048'), ObjectId('5932a80115c2606a59e8a049')]
  64. # 实际上在PyMongo 3.X版本中，insert()方法官方已经不推荐使用了，当然继续使用也没有什么问题，
  65. # 官方推荐使用insert_one()和insert_many()方法将插入单条和多条记录分开。
  66.   
  67. student = {
  68.     'id': '20170101',
  69.     'name': 'Jordan',
  70.     'age': 20,
  71.     'gender': 'male'
  72. }
  73.   
  74. result = collection.insert_one(student)
  75. print(result)
  76. print(result.inserted_id)
  77. # 运行结果：
  78. # <pymongo.results.InsertOneResult object at 0x10d68b558>
  79. # 5932ab0f15c2606f0c1cf6c5
  80. # 返回结果和insert()方法不同，这次返回的是InsertOneResult对象，我们可以调用其inserted_id属性获取_id。
  81.   
  82. # 对于insert_many()方法，我们可以将数据以列表形式传递即可，示例如下：
  83.   
  84. student1 = {
  85.     'id': '20170101',
  86.     'name': 'Jordan',
  87.     'age': 20,
  88.     'gender': 'male'
  89. }
  90.   
  91. student2 = {
  92.     'id': '20170202',
  93.     'name': 'Mike',
  94.     'age': 21,
  95.     'gender': 'male'
  96. }
  97.   
  98. result = collection.insert_many([student1, student2])
  99. print(result)
  100. print(result.inserted_ids)
  101. # insert_many()方法返回的类型是InsertManyResult，调用inserted_ids属性可以获取插入数据的_id列表，运行结果：
  102.   
  103. # <pymongo.results.InsertManyResult object at 0x101dea558>
  104. # [ObjectId('5932abf415c2607083d3b2ac'), ObjectId('5932abf415c2607083d3b2ad')]
  105. # 查询，插入数据后我们可以利用find_one()或find()方法进行查询，find_one()查询得到是单个结果，find()则返回多个结果。
  106.   
  107. result = collection.find_one({'name': 'Mike'})
  108. print(type(result))
  109. print(result)
  110. # 在这里我们查询name为Mike的数据，它的返回结果是字典类型，运行结果：
  111. # <class'dict'>
  112. # {'_id': ObjectId('5932a80115c2606a59e8a049'), 'id': '20170202', 'name': 'Mike', 'age': 21, 'gender': 'male'}
  113. # 可以发现它多了一个_id属性，这就是MongoDB在插入的过程中自动添加的。
  114.   
  115. # 我们也可以直接根据ObjectId来查询，这里需要使用bson库里面的ObjectId。
  116.   
  117. from bson.objectid import ObjectId
  118.   
  119. result = collection.find_one({'_id': ObjectId('593278c115c2602667ec6bae')})
  120. print(result)
  121. # 其查询结果依然是字典类型，运行结果：
  122.   
  123. # {' ObjectId('593278c115c2602667ec6bae'), 'id': '20170101', 'name': 'Jordan', 'age': 20, 'gender': 'male'}
  124. # 当然如果查询_id':结果不存在则会返回None。
  125.   
  126. # 对于多条数据的查询，我们可以使用find()方法，例如在这里查找年龄为20的数据，示例如下：
  127.   
  128. results = collection.find({'age': 20})
  129. print(results)
  130. for result in results:
  131.     print(result)
  132. # 运行结果：
  133.   
  134. # <pymongo.cursor.Cursor object at 0x1032d5128>
  135. # {'_id': ObjectId('593278c115c2602667ec6bae'), 'id': '20170101', 'name': 'Jordan', 'age': 20, 'gender': 'male'}
  136. # {'_id': ObjectId('593278c815c2602678bb2b8d'), 'id': '20170102', 'name': 'Kevin', 'age': 20, 'gender': 'male'}
  137. # {'_id': ObjectId('593278d815c260269d7645a8'), 'id': '20170103', 'name': 'Harden', 'age': 20, 'gender': 'male'}
  138. # 返回结果是Cursor类型，相当于一个生成器，我们需要遍历取到所有的结果，每一个结果都是字典类型。
  139.   
  140. # 如果要查询年龄大于20的数据，则写法如下：
  141.   
  142. results = collection.find({'age': {'$gt': 20}})
  143. # 在这里查询的条件键值已经不是单纯的数字了，而是一个字典，其键名为比较符号$gt，意思是大于，键值为20，这样便可以查询出所有
  144. # 年龄大于20的数据。
  145.   
  146. # 在这里将比较符号归纳如下表：
  147. """
  148. 符号含义示例
  149. $lt小于{'age': {'$lt': 20}}
  150. $gt大于{'age': {'$gt': 20}}
  151. $lte小于等于{'age': {'$lte': 20}}
  152. $gte大于等于{'age': {'$gte': 20}}
  153. $ne不等于{'age': {'$ne': 20}}
  154. $in在范围内{'age': {'$in': [20, 23]}}
  155. $nin不在范围内{'age': {'$nin': [20, 23]}}
  156. """
  157. # 另外还可以进行正则匹配查询，例如查询名字以M开头的学生数据，示例如下：
  158.   
  159. results = collection.find({'name': {'$regex': '^M.*'}})
  160. # 在这里使用了$regex来指定正则匹配，^M.*代表以M开头的正则表达式，这样就可以查询所有符合该正则的结果。
  161.   
  162. # 在这里将一些功能符号再归类如下：
  163. """
  164. 符号含义示例示例含义
  165. $regex匹配正则{'name': {'$regex': '^M.*'}}name以M开头
  166. $exists属性是否存在{'name': {'$exists': True}}name属性存在
  167. $type类型判断{'age': {'$type': 'int'}}age的类型为int
  168. $mod数字模操作{'age': {'$mod': [5, 0]}}年龄模5余0
  169. $text文本查询{'$text': {'$search': 'Mike'}}text类型的属性中包含Mike字符串
  170. $where高级条件查询{'$where': 'obj.fans_count == obj.follows_count'}自身粉丝数等于关注数
  171. """
  172. # 这些操作的更详细用法在可以在MongoDB官方文档找到：
  173. # https://docs.mongodb.com/manual/reference/operator/query/
  174.   
  175. # 计数
  176. # 要统计查询结果有多少条数据，可以调用count()方法，如统计所有数据条数：
  177.   
  178. count = collection.find().count()
  179. print(count)
  180. # 或者统计符合某个条件的数据：
  181.   
  182. count = collection.find({'age': 20}).count()
  183. print(count)
  184. # 排序
  185. # 可以调用sort方法，传入排序的字段及升降序标志即可，示例如下：
  186.   
  187. results = collection.find().sort('name', pymongo.ASCENDING)
  188. print([result['name'] for result in results])
  189. # 运行结果：
  190.   
  191. # ['Harden', 'Jordan', 'Kevin', 'Mark', 'Mike']
  192. # 偏移,可能想只取某几个元素，在这里可以利用skip()方法偏移几个位置，比如偏移2，就忽略前2个元素，得到第三个及以后的元素。
  193.   
  194. results = collection.find().sort('name', pymongo.ASCENDING).skip(2)
  195. print([result['name'] for result in results])
  196. # 运行结果：
  197. # ['Kevin', 'Mark', 'Mike']
  198. # 另外还可以用limit()方法指定要取的结果个数，示例如下：
  199.   
  200. results = collection.find().sort('name', pymongo.ASCENDING).skip(2).limit(2)
  201. print([result['name'] for result in results])
  202. # 运行结果：
  203. # ['Kevin', 'Mark']
  204. # 如果不加limit()原本会返回三个结果，加了限制之后，会截取2个结果返回。
  205.   
  206. # 值得注意的是，在数据库数量非常庞大的时候，如千万、亿级别，最好不要使用大的偏移量来查询数据，很可能会导致内存溢出，
  207. # 可以使用类似find({'_id': {'$gt': ObjectId('593278c815c2602678bb2b8d')}}) 这样的方法来查询，记录好上次查询的_id。
  208.   
  209. # 更新
  210. # 对于数据更新可以使用update()方法，指定更新的条件和更新后的数据即可，例如：
  211.   
  212. condition = {'name': 'Kevin'}
  213. student = collection.find_one(condition)
  214. student['age'] = 25
  215. result = collection.update(condition, student)
  216. print(result)
  217. # 在这里我们将name为Kevin的数据的年龄进行更新，首先指定查询条件，然后将数据查询出来，修改年龄，
  218. # 之后调用update方法将原条件和修改后的数据传入，即可完成数据的更新。
  219.   
  220. # 运行结果：
  221.   
  222. # {'ok': 1, 'nModified': 1, 'n': 1, 'updatedExisting': True}
  223. # 返回结果是字典形式，ok即代表执行成功，nModified代表影响的数据条数。
  224.   
  225. # 另外update()方法其实也是官方不推荐使用的方法，在这里也分了update_one()方法和update_many()方法，用法更加严格，
  226. # 第二个参数需要使用$类型操作符作为字典的键名，我们用示例感受一下。
  227.   
  228. condition = {'name': 'Kevin'}
  229. student = collection.find_one(condition)
  230. student['age'] = 26
  231. result = collection.update_one(condition, {'$set': student})
  232. print(result)
  233. print(result.matched_count, result.modified_count)
  234. # 在这里调用了update_one方法，第二个参数不能再直接传入修改后的字典，而是需要使用{'$set': student}这样的形式，
  235. # 其返回结果是UpdateResult类型，然后调用matched_count和modified_count属性分别可以获得匹配的数据条数和影响的数据条数。
  236.   
  237. # 运行结果：
  238. #
  239. # <pymongo.results.UpdateResult object at 0x10d17b678>
  240. # 1 0
  241. # 我们再看一个例子：
  242.   
  243. condition = {'age': {'$gt': 20}}
  244. result = collection.update_one(condition, {'$inc': {'age': 1}})
  245. print(result)
  246. print(result.matched_count, result.modified_count)
  247. # 在这里我们指定查询条件为年龄大于20，然后更新条件为{'$inc': {'age': 1}}，执行之后会讲第一条符合条件的数据年龄加1。
  248.   
  249. # 运行结果：
  250. #
  251. # <pymongo.results.UpdateResult object at 0x10b8874c8>
  252. # 1 1
  253. # 可以看到匹配条数为1条，影响条数也为1条。
  254.   
  255. # 如果调用update_many()方法，则会将所有符合条件的数据都更新，示例如下：
  256.   
  257. condition = {'age': {'$gt': 20}}
  258. result = collection.update_many(condition, {'$inc': {'age': 1}})
  259. print(result)
  260. print(result.matched_count, result.modified_count)
  261. # 这时候匹配条数就不再为1条了，运行结果如下：
  262. #
  263. # <pymongo.results.UpdateResult object at 0x10c6384c8>
  264. # 3 3
  265. # 可以看到这时所有匹配到的数据都会被更新。
  266.   
  267. # 删除
  268. # 删除操作比较简单，直接调用remove()方法指定删除的条件即可，符合条件的所有数据均会被删除，示例如下：
  269.   
  270. result = collection.remove({'name': 'Kevin'})
  271. print(result)
  272. # 运行结果：
  273. #
  274. # {'ok': 1, 'n': 1}
  275. # 另外依然存在两个新的推荐方法，delete_one()和delete_many()方法，示例如下：
  276.   
  277. result = collection.delete_one({'name': 'Kevin'})
  278. print(result)
  279. print(result.deleted_count)
  280. result = collection.delete_many({'age': {'$lt': 25}})
  281. print(result.deleted_count)
  282. # 运行结果：
  283.   
  284. # <pymongo.results.DeleteResult object at 0x10e6ba4c8>
  285. # 1
  286. # 4
  287. # delete_one()即删除第一条符合条件的数据，delete_many()即删除所有符合条件的数据，返回结果是DeleteResult类型，
  288. # 可以调用deleted_count属性获取删除的数据条数。
  289.   
  290. # 更多
  291. # 另外PyMongo还提供了一些组合方法，如find_one_and_delete()、find_one_and_replace()、find_one_and_update()，
  292. # 就是查找后删除、替换、更新操作，用法与上述方法基本一致。
  293.   
  294. # 另外还可以对索引进行操作，如create_index()、create_indexes()、drop_index()等。
  295.   
  296. # 详细用法可以参见官方文档：http://api.mongodb.com/python/current/api/pymongo/collection.html
  297.   
  298. # 另外还有对数据库、集合本身以及其他的一些操作，在这不再一一讲解，可以参见
  299. # 官方文档：http://api.mongodb.com/python/current/api/pymongo/

本篇博客大多是摘抄于大佬，亮出大佬博客：https://www.cnblogs.com/pyedu/p/10311866.html

版权声明：本文为12345huangchun原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://www.cnblogs.com/12345huangchun/p/10481393.html