Python脚本之连接MySQL【四】

本文为博主原创,未经授权,严禁转载及使用。
本文链接:https://blog.csdn.net/zyooooxie/article/details/124640412

之前写了篇 Python脚本之连接MySQL【三】,日常使用过程中,代码实际有很多改动,特此更新;

【实际这篇博客推迟发布N个月】

个人博客:https://blog.csdn.net/zyooooxie

【以下所有内容仅为个人项目经历,如有不同,纯属正常】

Cursor类的nextset()、_nextset()

https://peps.python.org/pep-0249/#nextset

Cursor.nextset()This method will make the cursor skip to the next available set, discarding any remaining rows from the current set.If there are no more sets, the method returns None. Otherwise, it returns a true value and subsequent calls to the .fetch*() methods will return rows from the next result set.

在这里插入图片描述

方法优化【2】

【读取ini配置文件 + 建立、关闭数据库连接】

@filename: db.ini

[zyooooxie_db]
user = user_zy
host = host_zy
passwd = passwd_zy
database = database_zy
"""
@blog: https://blog.csdn.net/zyooooxie
@qq: 153132336
@email: zyooooxie@gmail.com
"""from pymysql.connections import Connection
from pymysql.cursors import Cursor
from pymysql.constants import CLIENTdef read_ini(ini_path: str = 'db.ini'):"""读取配置文件:param ini_path:默认是数据库的配置文件:return:"""if os.path.isfile(ini_path):config = ConfigParser()config.read(ini_path, encoding='UTF-8')return {cf: config.items(cf) for cf in config.sections()}def connect_db(db_name: str) -> (Connection, Cursor):"""建立链接,传参为 具体的db:param db_name::return:"""ini_dict = read_ini()if db_name in ini_dict:res_list = ini_dict.get(db_name)res_dict = dict(res_list)else:raise Exception('传参不合法')db = pymysql.connect(port=3306, charset='utf8', autocommit=True, client_flag=CLIENT.MULTI_STATEMENTS,use_unicode=True, **res_dict)  # client_flag传值:默认可以同时执行多条sql语句的cur = db.cursor()Log.debug('{} connect'.format(db_name))return db, curdef close_db(db: Connection, cur: Cursor):"""断开连接:param db::param cur::return:"""cur.close()db.close()Log.debug('connect close')

exe_sql()、fetch_sql()、fetch_sqls()

"""
@blog: https://blog.csdn.net/zyooooxie
@qq: 153132336
@email: zyooooxie@gmail.com
"""def exe_sqls(sql: str, db_name: str, db: Connection = None, cur: Cursor = None):"""多条sql语句-execute():param sql::param db_name::param db::param cur::return:"""exe_sql(sql=sql, db_name=db_name, db=db, cur=cur)def exe_sql(sql: str, db_name: str, exe_mode: str = None, data_list: list or tuple = None,db: Connection = None, cur: Cursor = None):"""1条sql语句-execute()、executemany():param sql::param db_name::param exe_mode::param data_list::param db::param cur::return:"""if not bool(cur):db_use, cur_use = connect_db(db_name=db_name)else:db_use, cur_use = db, curLog.info(sql)if data_list is None and exe_mode is None:try_str = """cur_use.execute(sql)"""elif exe_mode == 'execute' and data_list is not None:assert sql.find('(%s') != -1try_str = """cur_use.execute(sql, data_list)"""elif exe_mode == 'executemany' and data_list is not None:assert sql.find('(%s') != -1try_str = """cur_use.executemany(sql, data_list)"""else:Log.error('{}--{}'.format(exe_mode, data_list))raise Exception('Execute Error')try:result = eval(try_str, locals())except Exception as e:db_use.rollback()Log.error(e.args)Log.info(traceback.format_exc())result = FalseLog.error('sql执行有问题')else:execute_sql_result_check(result)finally:if not bool(cur):close_db(db=db_use, cur=cur_use)def execute_sql_result_check(result):"""SQL Execute结果检查:param result::return:"""if not result:Log.error('{}-Number of affected rows'.format(result))else:Log.debug('Execute Succeed:{}'.format(result))def fetch_sqls(sql: str, db_name: str, db: Connection = None, cur: Cursor = None) -> List[tuple]:"""多条sql语句-fetchall():param sql::param db_name::param db::param cur::return:"""if not bool(cur):db_use, cur_use = connect_db(db_name=db_name)else:db_use, cur_use = db, curLog.info(sql)try:data = list()cur_use.execute(sql)data.append(cur_use.fetchall())# while True:##     if cur_use.nextset():#         data.append(cur_use.fetchall())##     else:#         breakwhile cur_use.nextset():data.append(cur_use.fetchall())except Exception as e:db_use.rollback()Log.debug(e.args)Log.info(traceback.format_exc())data = FalseLog.error('sql执行有问题')else:for d in data:fetch_sql_result_check(d)finally:if not bool(cur):close_db(db=db_use, cur=cur_use)return datadef fetch_sql(sql: str, db_name: str, fetch_mode: str = 'fetchall', db: Connection = None, cur: Cursor = None):"""1条sql语句-fetchone()、fetchall():param sql::param db_name::param fetch_mode::param db::param cur::return:"""if not bool(cur):db_use, cur_use = connect_db(db_name=db_name)else:db_use, cur_use = db, curLog.info(sql)if fetch_mode == 'fetchall':try_str = """cur_use.fetchall()"""elif fetch_mode == 'fetchone':  # 很少用到try_str = """cur_use.fetchone()"""else:Log.error('fetch_mode: {}'.format(fetch_mode))raise Exception(fetch_mode)try:cur_use.execute(sql)data = eval(try_str, locals())except Exception as e:db_use.rollback()Log.debug(e.args)Log.info(traceback.format_exc())data = FalseLog.error('sql执行有问题')else:fetch_sql_result_check(data)finally:if not bool(cur):close_db(db=db_use, cur=cur_use)return datadef fetch_sql_result_check(result):"""SQL Fetch结果检查:param result::return:"""if not result:Log.error('{}-Fetch Nothing'.format(result))else:Log.debug('Fetch Succeed')

实际应用【2】

"""
@blog: https://blog.csdn.net/zyooooxie
@qq: 153132336
@email: zyooooxie@gmail.com
"""def test_0801():from XXX_use.common_mysql import fetch_sql, connect_db, close_db, fetch_sqls, exe_sql, exe_sqlsdb_, cur_ = connect_db(db_name='zy_db')sql = """SELECT  *  FROM `table_c_r`    ORDER BY `update_date` DESC ;"""data = fetch_sql(sql=sql, db_name='zy_db', fetch_mode='fetchall', db=db_, cur=cur_)Log.info(data)data = fetch_sql(sql=sql, db_name='zy_db', fetch_mode='fetchone', db=db_, cur=cur_)Log.info(data)data = fetch_sql(sql=sql, db_name='zy_db', db=db_, cur=cur_)Log.info(data)sql = """SELECT  *  FROM `table_c_r_g_m_s`    ORDER BY `update_date` DESC LIMIT 50 ;# 这条sql查不到数据SELECT  *  FROM `table_c_b_r_r`  WHERE   `delete_flag` = 1   ORDER BY `update_date` DESC  ; SELECT  *  FROM `table_c_r`    ORDER BY `update_date` DESC LIMIT 1;"""res = fetch_sqls(sql=sql, db_name='zy_db', db=db_, cur=cur_)Log.info(res)data_list = [('TEST0801' + 'ZYOOOOXIE_' + str(i), 'Name' + str(i), 'zyooooxie') for i inrandom.sample(range(500), 10)]Log.info(data_list)sql = """insert into `table_c_g_c`     (`c_i`, `name`, `owner`) VALUES   (%s, %s, %s);"""exe_sql(sql=sql, db_name='zy_db', exe_mode='executemany', data_list=data_list, db=db_, cur=cur_)exe_sql(sql=sql, db_name='zy_db', exe_mode='execute', data_list=data_list[-1], db=db_, cur=cur_)sql = """insert into `table_c_g_c`     (`c_i`, `name`, `owner`) VALUES     ('TEST0801ZYOOOOXIE_11','Name_11', 'zyooooxie') ; insert into table_c_y_a    (username, password)values    ('TEST0801_11', 'pwd_11');insert into `table_c_g_c`    (`c_i`, `name`, `owner`) VALUES     ('TEST0801ZYOOOOXIE_12','Name_12', 'zyooooxie') ;    """exe_sql(sql=sql, db_name='zy_db', db=db_, cur=cur_)exe_sqls(sql=sql, db_name='zy_db', db=db_, cur=cur_)sql_ = """DELETE FROM `table_c_g_c` WHERE c_i LIKE 'TEST0801%' ;DELETE FROM `table_c_y_a` WHERE username LIKE 'TEST0801%' ;DELETE FROM `table_c_y_a` WHERE username LIKE 'TEST080808%' ;"""exe_sql(sql=sql_, db_name='zy_db', db=db_, cur=cur_)exe_sqls(sql=sql_, db_name='zy_db', db=db_, cur=cur_)close_db(db_, cur_)

本文链接:https://blog.csdn.net/zyooooxie/article/details/124640412

个人博客 https://blog.csdn.net/zyooooxie

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/37298.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

【先进PID控制算法(ADRC,TD,ESO)加入永磁同步电机发电控制仿真模型研究(Matlab代码实现)

💥💥💞💞欢迎来到本博客❤️❤️💥💥 🏆博主优势:🌞🌞🌞博客内容尽量做到思维缜密,逻辑清晰,为了方便读者。 ⛳️座右铭&a…

定量分析计算51单片机复位电路工作原理 怎么计算单片机复位电容和电阻大小

下面画出等效电路图 可以知道单片机内必然有一个电阻RX,为了简化分析,我们假设他是线性电阻(不带电容,电感的支路) 还有一个基础知识: 电容器的充电放电曲线: 还需要知道电容电压的变化是连续…

微信小程序data-item设置获取不到数据的问题

微信小程序data-item设置获取不到数据的问题 简单说明: 在微信小程序中,通过列表渲染使用wx:for根据数组中的每一项重复渲染组件。同时使用bindtap给每一项绑定点击事件clickItem,再通过data-item绑定数据。 **问题:**通过data-i…

观察者模式实战

场景 假设创建订单后需要发短信、发邮件等其它的操作,放在业务逻辑会使代码非常臃肿,可以使用观察者模式优化代码 代码实现 自定义一个事件 发送邮件 发送短信 最后再创建订单的业务逻辑进行监听,创建订单 假设后面还需要做其它的…

取个对象值导致系统崩溃

取个对象值导致系统崩溃 前言 想必各位小伙经常在项目中遇到一些错误,取对象值的时候,经常报错,又或者某些项目突然就挂经常都是出现在一些对象取值上面,然后就被领导一顿训斥 报错分析 例如: 下面这个报错大家想必不会陌生&am…

最大交换(力扣)枚举 JAVA

给定一个非负整数,你至多可以交换一次数字中的任意两位。返回你能得到的最大值。 示例 1 : 输入: 2736 输出: 7236 解释: 交换数字2和数字7。 示例 2 : 输入: 9973 输出: 9973 解释: 不需要交换。 注意: 给定数字的范围是 [0, 10^8] 解题思路: 1、数最…

【量化课程】08_2.深度学习量化策略基础实战

文章目录 1. 深度学习简介2. 常用深度学习模型架构2.1 LSTM 介绍2.2 LSTM在股票预测中的应用 3. 模块分类3.1 卷积层3.2 池化层3.3 全连接层3.4 Dropout层 4. 深度学习模型构建5. 策略实现 1. 深度学习简介 深度学习是模拟人脑进行分析学习的神经网络。 2. 常用深度学习模型架…

山东布谷科技直播软件源码Nginx服务器横向扩展:搭建更稳定的平台服务

在直播软件源码平台中,服务器扮演着重要的角色,关系着视频传输、数据处理、用户管理等工作的顺利完成。随着互联网的迅猛发展,直播行业也随之崛起,全世界的人们都加入到了直播软件源码平台中,用户流量的增加让服务器的…

视频高效剪辑,轻松平均分割视频,生成高质量M3U8

您是否在处理视频剪辑时常常面临繁琐的切分工作?是否希望能够快速而精准地平均分割视频,并生成适用于在线播放的高质量m3u8文件?现在,我们的智能视频剪辑大师为您提供了一种简便而高效的解决方案!无需复杂操作&#xf…

Leaflet入门,Leaflet如何实现vue双向绑定数据添加到图片标记物到地图上,动态根据vue数据更新到地图上以及鼠标经过标记物显示提示框

前言 本章使用Leaflet的vue2-leaflet或者vue-leaflet插件方式实现vue数据绑定地图数据,实现地图标记物与vue数据的双向联动更新,以及鼠标经过标记物显示提示框功能。 实现效果演示 vue如何使用Leaflet vue2如何使用:《Leaflet入门,如何使用vue2-leaflet实现vue2双向绑定…

【量化课程】02_3.投资学基础概念

文章目录 1. 投资和投资学的关系1.1 什么是投资?1.2 什么是投资学? 2. 投资学的主要内容2.1 金融市场与投资环境2.1.1 金融资产2.1.2 债券市场的意义2.1.3 金融市场与经济2.1.4 投资过程2.1.5 竞争性的市场2.1.6 市场参与者2.1.7 主要的市场债券市场外汇…

Stable Diffusion 插件开发经验

Stable Diffusion近来大热,但是插件开发的资料少之又少。 这里提供一些插件开发的经验,可供参考。 1.替换启动页。 如果你想要在运行Stable Diffusion的基础上想要一些独有的操作,不想要进行裁剪,直接替换启动页面,那么就需要在webui中进行替换 这里modules.ui.create_ui…

基于ipad协议的gewe框架进行微信群组管理(二)

友情链接 geweapi.com 点击访问即可。 获取群组详情 小提示: 该接口可以一次查询20个群组查询出来的信息是不带公告的 请求URL: http://域名地址/api/group/detail 请求方式: POST 请求头: Content-Type:applica…

2009年下半年 软件设计师 上午试卷

博主介绍:✌全网粉丝3W,全栈开发工程师,从事多年软件开发,在大厂呆过。持有软件中级、六级等证书。可提供微服务项目搭建与毕业项目实战,博主也曾写过优秀论文,查重率极低,在这方面有丰富的经验…

【Microsoft 支持】【数据库-MySql】当您尝试从大于 5000 的 TCP 端口连接时收到错误 WSAENOBUFS (10055)

​ 一、转载原文 When you try to connect from TCP ports greater than 5000 you receive the error ‘WSAENOBUFS (10055)’ Symptoms If you try to set up TCP connections from ports that are greater than 5000, the local computer responds with the following WSAE…

如何使用Spark/Flink等分布式计算引擎做网络入侵检测

如何使用Spark/Flink等分布式计算引擎做网络入侵检测 引言16 Distributed Abnormal Behavior Detection Approach Based on Deep Belief Network and Ensemble SVM Using Spark17 Spark configurations to optimize decision tree classification on UNSW-NB1518 A dynamic spa…

SOLIDWORKS PDM—文件版本的管控

SOLIDWORKS产品数据管理 (PDM) 解决方案可帮助您控制设计数据,并且从本质上改进您的团队就产品开发进行管理和协作的方式。使用 SOLIDWORKS PDM Professional,您的团队能够:1. 安全地存储和索引设计数据以实现快速检索;2. 打消关于…

使用QT可视化设计对话框详细步骤与代码

一、创建对话框基本步骤 创建并初始化子窗口部件把子窗口部件放到布局中设置tab键顺序建立信号-槽之间的连接实现对话框中的自定义槽 首先前面三步在这里是通过ui文件里面直接进行的,剩下两步则是通过代码来实现 二、项目创建详细步骤 创建新项目 为项目命名 为…

VScode如何设置中文教程

前言:打开VSCode软件,可以看到刚刚安装的VSCode软件默认使用的是英文语言环境,但网上都是vscode中文界面教你怎么设置中文,可能不利于小白阅读,所以重装vscode,手摸手从英文变成中文。 设置为中文 打开VS…

android app控制ros机器人五(百度地图)

半吊子改安卓,新增了标签页,此标签页需要显示百度地图 按照官方教程注册信息,得到访问应用AK,步骤也可以参照下面csdn Android地图SDK | 百度地图API SDK 【Android】实现百度地图显示_宾有为的博客-CSDN博客 本人使用的是aar开…