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)