pymysql封装

这篇具有很好参考价值的文章主要介绍了pymysql封装。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

安装PyMySQL库

本机环境:

  • Python 3.7.0
  • MySQL 5.7

使用Python来操作MySQL,需要用到 PyMySQL库

# 安装PyMySQL库
pip install PyMySQL

我这里安装的版本是 0.9.3。
image.png


基本操作-增删改查

Python操作MySQL的步骤如下:

  • 建立数据库连接,创建数据库连接对象。
  • 通过 cursor() 创建游标对象(pymysql通过游标来执行sql和获取结果)
  • 使用 execute() 执行sql
  • 获取结果(查询)/提交事务(增删改)
  • 关闭游标
  • 关闭连接

**注意:**用Python进行增删改查操作之前,最好先检查下sql语句是否正确,确保没有错误之后,再放到Python代码中。


查询操作

import pymysql

# 查询操作
def select_db(select_sql):
    """查询"""

    # 建立数据库连接,db是数据库连接对象
    # root:数据库密码@1.2.3.4:3306/ebook_management_system?charset=utf8', pool_recycle=3600
    db = pymysql.connect(
        host="1.2.3.4",
        port=3306,
        user="root",
        passwd="数据库密码",
        db="ebook_management_system"
    )

    # 通过 cursor() 创建游标对象,并让查询结果以字典格式输出
    cur = db.cursor(cursor=pymysql.cursors.DictCursor)

    # 使用 execute() 执行sql
    cur.execute(select_sql)

    # 使用 fetchall() 获取所有查询结果
    data = cur.fetchall()

    # 关闭游标
    cur.close()

    # 关闭数据库连接
    db.close()
    # 返回查询数据
    return data


if __name__ == '__main__':
    select_sql = 'SELECT * FROM user WHERE username="张三"'
    print(select_db(select_sql))

在上面,创建游标时使用了 cursor=pymysql.cursors.DictCursor ,目的是为了让查询结果以 列表嵌套字典 的格式输出,以方便后续操作。如果不使用该参数,那么返回的查询结果将是 元组嵌套元组 的形式。


更新操作

import pymysql

def update_db(update_sql):
    """更新"""

    # 建立数据库连接
    db = pymysql.connect(
        host="1.2.3.4",
        port=3306,
        user="root",
        passwd="数据库密码",
        db="ebook_management_system"
    )

    # 通过 cursor() 创建游标对象
    cur = db.cursor()
    try:

        # 使用 execute() 执行sql
        cur.execute(update_sql)

        # 提交事务
        db.commit()
    # 如果执行出错,捕获异常
    except Exception as e:
        print("操作出现错误:{}".format(e))

        # 回滚所有更改
        db.rollback()
    # 无论是否成功提交事务,都关闭游标和数据库
    finally:
        # 关闭游标
        cur.close()
        # 关闭数据库连接
        db.close()

在执行更新操作sql时,需要使用事务处理,即使用创建的连接进行提交事务 db.commit() ,使当前更改生效。当执行sql语句出现错误时,还应该支持事务回滚操作 db.rollback()


插入数据操作

在执行新增操作sql时,需要更新操作 一样,使用事务来处理。

# 插入数据
def insert_db(insert_sql):
    """插入"""
    # 建立数据库连接
    db = pymysql.connect(
        host="1.2.3.4",
        port=3306,
        user="root",
        passwd="数据库密码",
        db="ebook_management_system"
    )

    # 通过 cursor() 创建游标对象
    cur = db.cursor()
    try:
        # 使用 execute() 执行sql
        cur.execute(insert_sql)

        # 提交事务
        db.commit()

    except Exception as e:
        print("操作出现错误:{}".format(e))
        # 回滚所有更改
        db.rollback()
    finally:
        # 关闭游标
        cur.close()
        # 关闭数据库连接
        db.close()

删除操作

在执行删除操作sql时,需要像 更新操作插入操作 一样,使用事务来处理。

def delete_db(delete_sql):
    """删除"""
    # 建立数据库连接
    db = pymysql.connect(
        host="1.2.3.4",
        port=3306,
        user="root",
        passwd="数据库密码",
        db="ebook_management_system"
    )

    # 通过 cursor() 创建游标对象
    cur = db.cursor()
    try:
        # 使用 execute() 执行sql
        cur.execute(delete_sql)
        # 提交事务
        db.commit()
    except Exception as e:
        print("操作出现错误:{}".format(e))
        # 回滚所有更改
        db.rollback()
    finally:
        # 关闭游标
        cur.close()
        # 关闭数据库连接
        db.close()

类封装–简单数据库操作

从上面的代码中,我们可以发现存在不少问题,比如增删改操作的代码除了执行的sql不同外,其他代码都是一样的;同时每个操作时都写了一次建立数据库连接的代码,也就是说每次操作都会建立和删除连接的操作。

针对上面的问题,我们完全可以对上面的增删改查操作进行简单的封装,把Python操作MySQL的代码封装到一个类中,只在创建对象实例的时候建立数据库连接,只在对象删除时关闭连接。


代码示例:

参考:https://www.cnblogs.com/wintest/p/12152687.html

只有两个方法:文章来源地址https://www.toymoban.com/news/detail-416008.html

  1. 查询数据方法
  2. 变更数据方法
    • 包含增删改.
import pymysql
from pymysql.cursors import DictCursor


class MysqlDb:
    def __init__(self, host: str, port: int, user: str, passwd: str, db: str):
        """
        建立数据库连接
        :param host: 传入数据库主机地址
        :param port: 传入数据库端口
        :param user: 传入数据库用户名
        :param passwd: 传入数据库登陆密码
        :param db: 传入数据库名称
        """

        # 建立数据库连接
        self.conn = pymysql.connect(
            host=host,
            port=port,
            user=user,
            passwd=passwd,
            db=db
        )
        # 以字典形式返回结果的游标
        self.cur = self.conn.cursor(cursor=pymysql.cursors.DictCursor)

    def __del__(self):  # 对象资源被释放时触发,在对象即将被删除时的最后操作
        # 关闭游标
        self.cur.close()
        # 关闭数据库连接
        self.conn.close()

    def select_db(self, sql: str):
        """
        查询操作
        :param sql: 传入查询sql语句
        :return: 返回查询结果
        """

        # 使用 execute() 执行sql
        self.cur.execute(sql)

        # 使用 fetchall() 获取查询结果
        data = self.cur.fetchall()
        # 返回查询数据
        return data

    def change_db(self, sql: str):
        """
        变更数据操作----更新/插入/删除
        :param sql: 传入数据库语句
        :return: 没有返回值
        """

        try:
            # 使用 execute() 执行sql
            self.cur.execute(sql)
            # 提交事务
            self.conn.commit()
        except Exception as e:
            print("操作出现错误:{}".format(e))
            # 回滚所有更改
            self.conn.rollback()


if __name__ == '__main__':
    sql_obj = MysqlDb('localhost', 3306, 'root', 'sql123456', 'new_db')
    # 定义查询sql语句
    select_sql = 'SELECT * FROM user WHERE username="张三2"'
    # 定义更新数据sql语句
    update_sql = 'UPDATE user SET username = "张三2" WHERE id = 1'
    # 定义插入数据sql语句
    insert_sql = 'INSERT INTO user(id, username, password) VALUES(11, "王五", "333333")'
    # 定义删除数据sql语句
    delete_sql = 'DELETE FROM user WHERE id = 11'
    # 接收查询结果
    query_result = sql_obj.select_db(select_sql)
    print(query_result)
    # 执行更新数据sql
    sql_obj.change_db(update_sql)
    # 执行插入数据sql
    sql_obj.change_db(insert_sql)
    # 执行删除数据sql
    sql_obj.change_db(delete_sql)

到了这里,关于pymysql封装的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • Python 操作Mysql(PyMysql)

    Python 操作 Mysql 常用方式: PyMysql:纯 Python 语言编写的 Mysql 操作客户端,安装方便,支持 Python3。 SQLAlchemy:是一个非常强大的 ORM 框架,不提供底层的数据库操作,主要是通过定义模型对应数据表结构,在 Python Web 编程领域应用广泛。 在实际项目中,如果仅仅是简单的爬虫

    2024年02月04日
    浏览(15)
  • [Python]pymysql对应PyInstaller解析

    报错信息: 本地使用pymysql的场景:使用了tkinter进行GUI开发功能,又采用了pyinstaller进行了打包成exe的操作。 了解tkinter常用组件:https://blog.csdn.net/yingshukun/article/details/78705337 组件使用情况,其他是python自带的 原本是在python365的环境上进行的操作,历史中都没有出现打包及链

    2024年01月20日
    浏览(10)
  • 【Python】Python操作MySQL详解——PyMySQL

    Python标准数据库规范为 DB-API, DB-API定义了一系列必须的对象和数据库操作方式,以便为各种数据库系统和数据库访问程序提供一致的访问接口。 开发人员将接口封装成不同的数据库操作模块,不同的数据库需要不同数据库操作模块,例如,MySQL数据库,它对应以下操作模块

    2024年02月02日
    浏览(19)
  • Python + pymysql 之 MySQL 查询操作

    在MySQL中构建一个测试表,如下:  打印输出结果: 从中可以看出,默认情况下,查询结果返回的是元组tuple形式 返回元组会有一个问题,当你只查询一个属性字段时,返回的结果会是有逗号的元组 例如:sql改变一下 此时,打印输出结果: 此时,建议return前,简单处理一下

    2024年02月13日
    浏览(38)
  • Python数据库操作 ---- pymysql教学

    安装mysql 在使用pymysql的前提就是又一个mysql数据库,这个数据库可以是本地数据库也可以是远程的数据库, mysql的安装这里就不再赘述了,大家可以参考其他的模块进行安装 安装pymysql 解释: 在连接数据的时候需要指定相应的参数 host 数据库ip地址,如果是本地可以用localhos

    2024年02月03日
    浏览(16)
  • python——数据库操作PyMysql使用详解

    劝君惜取少年时 在编写小脚本时,PyMysql是快速连接并操作数据库的一个不错选择。 连接数据库 使用connect函数创建连接对象,此连接对象提供关闭数据库、事务回滚等操作 一般传参为:host, user, password, port(默认为3306), database(想要连接的数据库名) 连接对象的常见方法 :

    2024年02月02日
    浏览(25)
  • Python使用pymysql和sqlalchemy访问MySQL的区别

    pymysql和sqlalchemy是两个Python中经常用于与MySQL数据库交互的库。都可以连接MySQL数据库,但它们有明显的区别。 (1)特点 pymysql是一个Python模块,它可以用作一个独立的Python文件或作为Python程序中的一个模块。安装pymysql之后,需要导入它并连接到一个MySQL数据库,以开始与之交

    2024年02月12日
    浏览(18)
  • PyMySQL库版本引起的python执行sql编码错误

    长话短说,之前在A主机(centos7.9)上运行的py脚本拿到B主机上(centos7.9)运行报错: 两个主机系统、python版本、pip版本都是相同的。但是在B主机执行py脚本时,报错指向的代码就是 sql 语句,sql语句也就是一串字符串啊; py脚本是定时任务,使用pymysql库连接环境内的mysql执行

    2024年02月14日
    浏览(10)
  • 使用Python pymysql连接Mysql数据库-菜鸟教程

    1、安装pymysql模块 pip install pymysql 2、启动Mysql数据库服务 net start mysql80  3、连接数据库 运行结果如下  4、创建数据库表 执行成功后,在本地登录mysql数据库进行查看验证   5、数据库插入操作  执行程序后在本地查看验证  6、数据库查询操作 Python查询Mysql使用 fetchone() 方法

    2024年02月04日
    浏览(19)
  • python新手案例——商品进销存管理系统(pymysql+xlwt)(一)

    1.pymsq          此模块的作用是让python语言能够对数据库的表进行操作,在此,我们需要简单地了解以下pymysql最基础的操作。 Python3 MySQL 数据库连接 – PyMySQL 驱动 | 菜鸟教程 (runoob.com) 2.xlwt         此模块是excel写入模块,在该系统中,我们需要导出数据,最好的方式就

    2024年02月02日
    浏览(15)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包