博客

如何使用Python连接和操作MongoDB数据库？

  • Post category:Python

在Python中，可以使用pymongo模块连接和操作MongoDB数据库。以下是Python使用pymongo模块连接和操作MongoDB数据库的完整攻略，包括连接MongoDB数据库、插入数据、查询数据、更新数据和删除数据等操作。

连接MongoDB数据库

在Python中，可以使用pymongo模块连接MongoDB数据库。以下是连接MongoDB数据库的基本语法：

import pymongo

myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["mydatabase"]

在上面的语法中，pymongo.MongoClient()方法用于连接MongoDB数据库，localhost是MongoDB服务器的主机名，27017是MongoDB服务器的端口号，mydatabase是要连接的数据库名称。

插入数据

在MongoDB中，可以使用insert_one()方法或insert_many()方法插入数据。以下是插入数据的基本语法：

import pymongo

myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["mydatabase"]
mycol = mydb["customers"]

# 插入一条数据
mydict = { "name": "John", "address": "Highway 37" }
x = mycol.insert_one(mydict)

# 插入多条数据
mylist [
  { "name": "Amy", "address": "Apple st 652" },
  { "name": "Hannah", "address": "Mountain 21" },
  { "name": "Michael", "address": "Valley 345" },
  { "name": "Sandy", "address": "Ocean blvd 2" },
  { "name": "Betty", "address": "Green Grass 1" },
  { "name": "Richard", "address": "Sky st 331" },
  { "name": "Susan", "address": "One way 98" },
  { "name": "Vicky", "address": "Yellow Garden 2" },
  { "name": "Ben", "address "Park Lane 38" },
  { "name": "William", "address": "Central st 954" },
  { "name": "Chuck", "address": "Main Road 989" },
  { "name": "Viola", "address": "Sideway 1633" }
]
x = mycol.insert(mylist)

在上面的语法中，mycol.insert_one()方法用于插入一条数据，mycol.insert_many()方法用于插入多条数据。

查询数据

在MongoDB中，可以使用find()方法查询数据。以下是查询数据的基本语法：

import pymongo

myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["mydatabase"]
mycol = mydb["customers"]

# 查询所有数据
for x in mycol.find():
  print(x)

# 查询指定条件的数据
myquery = { "address": "Park Lane 38" }
mydoc = mycol.find(myquery)
for x in mydoc:
  print(x)

在上面的语法中，mycol.find()方法用于查询所有数据，mycol.find(myquery)方法用于查询指定条件的数据。

更新数据

在MongoDB中，可以使用update_one()方法或update_many()方法更新数据。以下是更新数据的基本语法：

import pymongo

myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["mydatabase"]
mycol = mydb["customers"]

# 更新一条数据
myquery = { "address": "Valley345" }
newvalues = { "$set": { "address": "Canyon 123" } }
mycol.update_one(myquery, newvalues)

# 更新多条数据
myquery = { "address": { "$regex": "^S" } }
newvalues = { "$set": { "name": "Minnie" } }
x = mycol.update_many(myquery, newvalues)
print(x.modified_count, "文档已修改")

在上面的语法中，mycol.update_one()方法用于更新一条数据，mycol.update_many()方法用于更新多条数据。

删除数据

在MongoDB中，可以使用delete_one()方法或delete_many()方法删除数据。以下是删除数据的基本语法：

import pymongo

myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["mydatabase"]
mycol = mydb["customers"]

# 删除一条数据
myquery = { "address": "Mountain 21" }
mycol.delete_one(myquery)

# 删除多条数据
myquery = { "address": {"$regex": "^S"} }
x = mycol.delete_many(myquery)
print(x.deleted_count, "文档已删除")

在上面的语法中，mycol.delete_one()方法用于删除一条数据，mycol.delete_many()方法用于删除多条数据。

示例1

在这个示例中，我们将使用Python连接到MongoDB数据库，并插入一些数据，然后查询所有数据并打印结果。

以下是Python代码：

import pymongo

myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["mydatabase"]
mycol = mydb["customers"]

# 插入数据
mydict = { "name": "John", "address": "Highway 37" }
x = mycol.insert_one(mydict)

# 查询所有数据
for x in mycol.find():
  print(x)

在上面的代码中，我们使用pymongo模块连接到MongoDB数据库。然后，我们使用mycol.insert_one()方法插入一条数据。最后，我们使用for循环遍历每一行，并使用print()函数打印每一行。

示例2

在这个示例中，我们将使用Python连接到MongoDB数据库，并更新一些数据，然后查询指定条件的数据并打印结果。

以下是Python代码：

import pymongo

myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["mydatabase"]
mycol = mydb["customers"]

# 更新数据
myquery = { "address": "Valley345" }
newvalues = { "$set": { "address": "Canyon 123" } }
mycol.update_one(myquery, newvalues)

# 查询指定条件的数据
myquery = { "address": "Canyon 123" }
mydoc = mycol.find(myquery)
for x in mydoc:
  print(x)

在上面的代码中，我们使用pymongo模块连接到MongoDB数据库。然后，我们使用mycol.update_one()方法更新一条数据。最后，我们使用mycol.find()方法查询指定条件的数据，并使用for循环遍历每一行，并使用print()函数打印每一行。

以上是使用Python连接和操作MongoDB数据库的完整攻略，包括连接MongoDB数据库、插入数据、查询数据、更新数据和删除数据等操作。

Tags: ,