Python Mongodb 修改文档

我们可以在 MongoDB 中使用 update_one() 方法修改文档中的记录。该方法第一个参数为查询的条件，第二个参数为要修改的字段。

如果查找到的匹配数据多于一条，则只会修改第一条。

本文使用的测试数据如下：

  1. {'_id': ObjectId('5b2369cac315325f3698a1cf'), 'name': 'Google', 'alexa': "111", 'url': 'https://www.google.com'}
  2. {'_id': ObjectId('5b236aa9c315325f5236bbb6'), 'name': 'Taobao', 'alexa': "222", 'url': 'https://www.taobao.com'}
  3. {'_id': ObjectId('5b236aa9c315325f5236bbb7'), 'name': 'QQ', 'alexa': "3333", 'url': 'https://www.qq.com'}
  4. {'_id': ObjectId('5b236aa9c315325f5236bbb8'), 'name': 'Facebook', 'alexa': "4444", 'url': 'https://www.facebook.com'}
  5. {'_id': ObjectId('5b236aa9c315325f5236bbb9'), 'name': '知乎', 'alexa': "5555", 'url': 'https://www.zhihu.com'}
  6. {'_id': ObjectId('5b236aa9c315325f5236bbba'), 'name': 'Github', 'alexa': "6666", 'url': 'https://www.github.com'}

以下实例将 alexa 字段的值 10000 改为 12345:

实例

  1. import pymongo
  3. myclient = pymongo.MongoClient("mongodb://localhost:27017/")
  4. mydb = myclient["mydb"]
  5. mycol = mydb["sites"]
  7. myquery = { "alexa": "111" }
  8. newvalues = { "$set": { "alexa": "1000" } }
  10. mycol.update_one(myquery, newvalues)
  12. # 输出修改后的  "sites"  集合
  13. for x in mycol.find():
  14.   print(x)

执行输出结果为：

  1. {'_id': ObjectId('5b2369cac315325f3698a1cf'), 'name': 'Google', 'alexa': "1000", 'url': 'https://www.google.com'}
  2. {'_id': ObjectId('5b236aa9c315325f5236bbb6'), 'name': 'Taobao', 'alexa': "222", 'url': 'https://www.taobao.com'}
  3. {'_id': ObjectId('5b236aa9c315325f5236bbb7'), 'name': 'QQ', 'alexa': "3333", 'url': 'https://www.qq.com'}
  4. {'_id': ObjectId('5b236aa9c315325f5236bbb8'), 'name': 'Facebook', 'alexa': "4444", 'url': 'https://www.facebook.com'}
  5. {'_id': ObjectId('5b236aa9c315325f5236bbb9'), 'name': '知乎', 'alexa': "5555", 'url': 'https://www.zhihu.com'}
  6. {'_id': ObjectId('5b236aa9c315325f5236bbba'), 'name': 'Github', 'alexa': "6666", 'url': 'https://www.github.com'}

update_one() 方法只能修匹配到的第一条记录，如果要修改所有匹配到的记录，可以使用 update_many()。

以下实例将查找所有以 F 开头的 name 字段，并将匹配到所有记录的 alexa 字段修改为 123：

实例

  1. import pymongo
  3. myclient = pymongo.MongoClient("mongodb://localhost:27017/")
  4. mydb = myclient["mydb"]
  5. mycol = mydb["sites"]
  7. myquery = { "name": { "$regex": "^F" } }
  8. newvalues = { "$set": { "alexa": "123" } }
  10. x = mycol.update_many(myquery, newvalues)
  12. print(x.modified_count, "文档已修改")

输出结果为：

  1. 1 文档已修改

查看数据是否已修改：

  1. {'_id': ObjectId('5b2369cac315325f3698a1cf'), 'name': 'Google', 'alexa': "1000", 'url': 'https://www.google.com'}
  2. {'_id': ObjectId('5b236aa9c315325f5236bbb6'), 'name': 'Taobao', 'alexa': "222", 'url': 'https://www.taobao.com'}
  3. {'_id': ObjectId('5b236aa9c315325f5236bbb7'), 'name': 'QQ', 'alexa': "3333", 'url': 'https://www.qq.com'}
  4. {'_id': ObjectId('5b236aa9c315325f5236bbb8'), 'name': 'Facebook', 'alexa': "123", 'url': 'https://www.facebook.com'}
  5. {'_id': ObjectId('5b236aa9c315325f5236bbb9'), 'name': '知乎', 'alexa': "5555", 'url': 'https://www.zhihu.com'}
  6. {'_id': ObjectId('5b236aa9c315325f5236bbba'), 'name': 'Github', 'alexa': "6666", 'url': 'https://www.github.com'}