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})

Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐