封装一个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的方法
WebSocket是一种在单个TCP连接上进行全双工通讯的协议。WebSocket允许服务端主动向客户端推送数据。这篇文章主要介绍了Django使用Channels实现WebSocket,需要的朋友可以参考下2019-07-07Centos下实现安装Python3.6和Python2共存
这篇文章主要介绍了Centos下实现安装Python3.6和Python2共存,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧2018-08-08python中分组函数groupby和分组运算函数agg的使用
本文主要介绍了python中分组函数groupby和分组运算函数agg的使用,文中通过示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下2021-10-10
最新评论