封装一个python的pymysql操作类

 更新时间:2022年12月25日 09:13:36   作者:野生大虾  
这篇文章主要介绍了封装一个python的pymysql操作类的相关资料,需要的朋友可以参考下

最近使用pymysql写脚本的情况越来越多了,刚好整理,简单封装一个pymysql的操作类

import pymysql


class MysqlDB:

    def __init__(
        self, 
        host=None, 
        port=None, 
        db=None, 
        account=None,
        password=None, 
        connect_timeout=20,
        read_timeout=20,
        write_timeout=20
        ):
        self.conn = pymysql.connect(
            host=self.host,
            port=self.port,
            db=self.db,
            user=self.account,
            passwd=self.password,
            connect_timeout=self.connect_timeout,
            read_timeout=self.read_timeout,
            write_timeout=self.write_timeout
        )
    
    def fetch(self, table_name=None, fields=(), where=None, many=False):
        cur = self.conn.cursor()

        if where:
            sql = f'select {",".join(fields)} from {table_name} where {where}'
        else:
            sql = f'select {",".join(fields)} from {table_name}'
        cur.execute(sql)
        if many:
            data = cur.fetchmany()
        else:
            data = cur.fetchone()
        cur.close()
        return data


    def update(self, table_name=None, field=None, value=None, where=None):
        cur = self.conn.cursor()
        sql = f'update {table_name} set {field} = {value}'
        if where:
            sql += f'where {where}'
        cur.execute(sql)
        self.conn.commit()
        cur.close()
    
    def insert(self, table_name=None, single=True, data_list: list = []):
        cur = self.conn.cursor()
        for data in data_list:
            sql = f'insert into {table_name}({",".join([key for key in data.keys()])}) values({",".join(["%s" for _ in range(len(data.keys()))])})'
            cur.execute(sql, data)
        self.conn.commit()
        cur.close()

    def quit(self):
        self.conn.close()

到此这篇关于封装一个python的pymysql操作类的文章就介绍到这了,更多相关封装pymysql操作类内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • Django使用Channels实现WebSocket的方法

    Django使用Channels实现WebSocket的方法

    WebSocket是一种在单个TCP连接上进行全双工通讯的协议。WebSocket允许服务端主动向客户端推送数据。这篇文章主要介绍了Django使用Channels实现WebSocket,需要的朋友可以参考下
    2019-07-07
  • Centos下实现安装Python3.6和Python2共存

    Centos下实现安装Python3.6和Python2共存

    这篇文章主要介绍了Centos下实现安装Python3.6和Python2共存,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2018-08-08
  • Python中获取文件大小的四种办法

    Python中获取文件大小的四种办法

    这篇文章主要给大家介绍了关于Python中获取文件大小的四种办法,我们可以使用Python中的os模块来获取视频文件大小,文中通过代码示例介绍的非常详细,需要的朋友可以参考下
    2023-08-08
  • python中分组函数groupby和分组运算函数agg的使用

    python中分组函数groupby和分组运算函数agg的使用

    本文主要介绍了python中分组函数groupby和分组运算函数agg的使用,文中通过示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2021-10-10
  • python如何将一个四位数反向输出

    python如何将一个四位数反向输出

    这篇文章主要介绍了python如何将一个四位数反向输出,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-05-05
  • 在pytorch中查看可训练参数的例子

    在pytorch中查看可训练参数的例子

    今天小编就为大家分享一篇在pytorch中查看可训练参数的例子,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2019-08-08
  • django 捕获异常和日志系统过程详解

    django 捕获异常和日志系统过程详解

    这篇文章主要介绍了django-捕获异常和日志系统过程详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-07-07
  • Python实现购物系统(示例讲解)

    Python实现购物系统(示例讲解)

    下面小编就为大家带来一篇Python实现购物系统(示例讲解)。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-09-09
  • opencv 实现特定颜色线条提取与定位操作

    opencv 实现特定颜色线条提取与定位操作

    这篇文章主要介绍了opencv 实现特定颜色线条提取与定位操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2020-06-06
  • python编程项目中线上问题排查与解决

    python编程项目中线上问题排查与解决

    因为业务上的设计存在问题,导致数据库表总是被锁,而且是不定期的锁定,导致服务器运行异常,今天就来跟大家说说该如何避免这种问题
    2021-11-11

最新评论