python连接mongodb

python连接mongodb
 
第一步，导包
 
第二步，连接mongodb数据库。需要实例化一个MongoClient对象。
创建这个对象，有以下三种写法，方式一为默认方式，连接本地mongodb数据库。后边的两种手动传入地址。
其中mongodb的端口号为27017。
①pymongo.MongoClient()
②pymongo.MongoClient(‘127.0.0.1’， 27017)
③pymongo.MongoClient(‘mongodb://127.0.0.1:27017’)

第三步，连接好后，接着需要切换到需要使用的数据库，这里的代码有以下三种写法：
self.db = self.client[‘db_name’]
self.db = self.client.get_database(‘db_name’)
self.db = self.client.db_name

第四步，写入数据
除了代码中的写法，还可以先切换到集合test，再写入：
col = self.db.get_collection(‘test’)
result = col.insert_one(data)

import pymongo


class MongoDBLink(object):
    def __init__(self, host='127.0.0.1', port=27017):
        # 连接mongodb

        self.host = host
        self.port = port
        self.client = pymongo.MongoClient(host=self.host, port=self.port)
        # 切换数据库
        self.db = self.client['db_name']
        # self.db = self.client.get_database('db_name')
        # self.db = self.client.db_name

    # 往数据库中添加一条内容
    def add_one(self, data):
        result = self.db.test.insert_one(data)
        # inserted_id返回插入记录的id
        print(result.inserted_id)


if __name__ == '__main__':
    mongo_py = MongoDBLink()
    mongo_py.add_one({'name': 'abc', 'x_value': 88})