随着越来越多的数据以非结构化或半结构化的方式来提供,需要通过NoSql数据库来管理它们。 Python也可以以与关系数据库交互的相似方式与NoSQL数据库进行交互。 在本章中,我们将使用python作为NoSQL数据库与MongoDB进行交互。 如果您是MongoDB的新手,可以通过MongoDB教程来学习。
要连接到MongoDB,python使用一个名为pymongo
的库。可以使用Anaconda环境中的以下命令将此库添加到您的python环境。
conda install pymongo
这个库允许python使用数据库客户端连接到MOngoDB。 一旦连接,我们选择要用于各种操作的数据库名称。
要将数据插入到MongoDB中,使用数据库环境中可用的insert()
方法。 首先使用下面显示的Python代码连接到数据库,然后以一系列键值对的形式提供文档详细信息。
# Import the python libraries from pymongo import MongoClient from pprint import pprint # Choose the appropriate client client = MongoClient() # Connect to the test db db=client.test # Use the employee collection employee = db.employee employee_details = { 'Name': 'Raj Kumar', 'Address': 'Sears Streer, NZ', 'Age': '42' } # Use the insert method result = employee.insert_one(employee_details) # Query for the inserted document. Queryresult = employee.find_one({'Age': '42'}) print(Queryresult)
执行上面示例代码,得到以下结果 -
{u'Address': u'Sears Streer, NZ', u'Age': u'42', u'Name': u'Raj Kumar', u'_id': ObjectId('5adc5a9f84e7cd3940399f93')}
更新现有的MongoDB数据与插入类似。 使用mongoDB原生的update()
方法。 在下面的代码中,使用新的键值对替换了现有的记录。 请注意:这里可通过使用条件标准来决定更新哪条记录。
# Import the python libraries from pymongo import MongoClient from pprint import pprint # Choose the appropriate client client = MongoClient() # Connect to db db=client.test employee = db.employee # Use the condition to choose the record # and use the update method db.employee.update_one( {"Age":'42'}, { "$set": { "Name":"Srinidhi", "Age":'35', "Address":"New Omsk, WC" } } ) Queryresult = employee.find_one({'Age':'35'}) print(Queryresult)
当执行上面的代码时,它会产生以下结果。
{u'Address': u'New Omsk, WC', u'Age': u'35', u'Name': u'Srinidhi', u'_id': ObjectId('5adc5a9f84e7cd3940399f93')}
使用delete
方法的地方删除记录也很简单。 这里还提到用于选择要删除的记录的条件。
# Import the python libraries from pymongo import MongoClient from pprint import pprint # Choose the appropriate client client = MongoClient() # Connect to db db=client.test employee = db.employee # Use the condition to choose the record # and use the delete method db.employee.delete_one({"Age":'35'}) Queryresult = employee.find_one({'Age':'35'}) print(Queryresult)
执行上面示例代码,得到以下结果 -
None
所以看到特定的记录不再存在于db
中。