Docs 菜单

Docs 主页开发应用程序Python 驱动程序pymongo

将数据写入 MongoDB

在此页面上

  • Overview
  • 示例应用程序
  • insertOne
  • 插入多个
  • updateOne
  • 更新多个
  • replaceOne
  • deleteOne
  • 删除多个
  • 批量写入

在此页面上,您可以查看可复制的代码示例,这些示例展示了通过 PyMongo 将数据写入 MongoDB 的常用方法。

提示

要了解有关此页面上显示的任何方法的更多信息,请参阅每个部分中提供的链接。

要使用本页中的示例,请将代码示例复制到示例应用程序或您自己的应用程序中。 请务必将代码示例中的所有占位符(例如 <connection string URI> )替换为 MongoDB 部署的相关值。

您可以使用以下示例应用程序来测试本页上的代码示例。 要使用示例应用程序,请执行以下步骤:

  1. 确保已安装 PyMongo。

  2. 复制以下代码并将其粘贴到新的.py文件中。

  3. 从此页面复制代码示例,并将其粘贴到文件中的指定行。

1import pymongo
2from pymongo import MongoClient
3
4try:
5 uri = "<connection string URI>"
6 client = MongoClient(uri)
7
8 database = client["<database name>"]
9 collection = database["<collection name>"]
10
11 # start example code here
12
13 # end example code here
14
15 client.close()
16
17except Exception as e:
18 raise Exception(
19 "The following error occurred: ", e)
result = collection.insert_one({ "<field name>" : "<value>" })
print(result.acknowledged)

要了解有关insert_one()方法的更多信息,请参阅“插入文档”指南。

document_list = [
{ "<field name>" : "<value>" },
{ "<field name>" : "<value>" }
]
result = collection.insert_many(document_list)
print(result.acknowledged)

要了解有关insert_many()方法的更多信息,请参阅“插入文档”指南。

query_filter = { "<field to match>" : "<value to match>" }
update_operation = { "$set" :
{ "<field name>" : "<value>" }
}
result = collection.update_one(query_filter, update_operation)
print(result.modified_count)

要了解有关update_one()方法的更多信息,请参阅更新文档指南。

query_filter = { "<field to match>" : "<value to match>" }
update_operation = { "$set" :
{ "<field name>" : "<value>" }
}
result = collection.update_many(query_filter, update_operation)
print(result.modified_count)

要了解有关update_many()方法的更多信息,请参阅更新文档指南。

query_filter = { "<field to match>" : "<value to match>" }
replace_document = { "<new document field name>" : "<new document value>" }
result = collection.replace_one(query_filter, replace_document)
print(result.modified_count)

要了解有关replace_one()方法的更多信息,请参阅替换文档指南。

query_filter = { "<field to match>" : "<value to match>" }
result = collection.delete_one(query_filter)
print(result.deleted_count)

要了解有关delete_one()方法的更多信息,请参阅“删除文档”指南。

query_filter = { "<field to match>" : "<value to match>" }
result = collection.delete_many(query_filter)
print(result.deleted_count)

要了解有关delete_many()方法的更多信息,请参阅“删除文档”指南。

operations = [
pymongo.InsertOne(
{
"<field name>" : "<value>"
}
),
pymongo.UpdateMany(
{ "<field to match>" : "<value to match>" },
{ "$set" : { "<field name>" : "<value>" }},
),
pymongo.DeleteOne(
{ "<field to match>" : "<value to match>" }
),
]
result = collection.bulk_write(operations)
print(result)

要了解有关bulk_write()方法的更多信息,请参阅批量写入指南。

← 数据库和集合