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:
上一篇:Windows 2008 R2企业版系统时常宕机问题


下一篇:Mysql 锁