python 操作数据库,代码封装

Posted 呓语落花

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了python 操作数据库,代码封装相关的知识,希望对你有一定的参考价值。

python 操作数据库


import pymysql

# 第一步:连接到数据库
conn = pymysql.connect(host="120.78.128.25",
                       port=3306,
                       user="future",
                       password="123456",
                       charset="utf8",
                       cursorclass = pymysql.cursors.DictCursor
                       )

# 第二步:创建一个游标对象
cur = conn.cursor()

sql = "SELECT * FROM futureloan.member LIMIT 10"

# 第三步:执行sql语句
res = cur.execute(sql)
print(res)

# 第四步:获取查询到的结果
# fetchone:获取查询到的一条数据
data = cur.fetchone()
print(data)

# data1 = cur.fetchone()
# print(data1)

# 连接db进行增删查改
sql = "SELECT * FROM futureloan.member LIMIT 10"

# 第三步:执行sql
cur.execute(sql)

# 第四步:提交事务
conn.commit()


# fetchall:获取查询到的所有数据
# datas = cur.fetchall()
# print(datas)


操作DB代码封装

"""
封装的需求:
    1、查询数据的方法
    2、增删改的方法
    3、init方法:建立连接


"""
import pymysql


class HandleMysql:

    def __init__(self):
        """初始化方法中,连接到数据库"""
        # 建立连接
        self.con = pymysql.connect(host="120.78.128.25",
                                   port=3306,
                                   user="future",
                                   password="123456",
                                   charset="utf8",
                                   cursorclass=pymysql.cursors.DictCursor
                                   )
        # 创建一个游标对象
        self.cur = self.con.cursor()

    def find_all(self, sql):
        """
        查询sql语句返回的所有数据
        :param sql: 查询的sql
        :return: 查询到的所有数据
        """
        self.cur.execute(sql)
        return self.cur.fetchall()

    def find_one(self, sql):
        """
        查询sql语句返回的第一条数据
        :param sql: 查询的sql
        :type sql:str
        :return: sql语句查询到的第一条数据
        """
        self.cur.execute(sql)
        return self.cur.fetchone()

    def update(self, sql):
        """
        增删改操作的方法
        :param sql: 增删改的sql语句
        :return:
        """
        self.cur.execute(sql)
        self.con.commit()

if __name__ == ‘__main__‘:
    db = HandleMysql()

    sql = "SELECT * FROM futureloan.member LIMIT 10"

    res = db.find_one(sql)
    print(res)

以上是关于python 操作数据库,代码封装的主要内容,如果未能解决你的问题,请参考以下文章

VSCode自定义代码片段14——Vue的axios网络请求封装

VSCode自定义代码片段14——Vue的axios网络请求封装

VSCode自定义代码片段14——Vue的axios网络请求封装

回归 | js实用代码片段的封装与总结(持续更新中...)

学习笔记:python3,代码片段(2017)

测试新人如何使用Python代码封装自动化测试的用例