使用Python批量修改数据库执行Sql文件
由于上篇文章中批量修改了文件,有的时候数据库也需要批量修改一下,之前的做法是使用宝塔的phpMyAdmin
导出一个已经修改好了的sql
文件,然后依次去其他数据库里导入,效率不说极低,也算低了,且都是些重复性的劳动,所以打算用Python来批量执行sql
环境
版本:Python3.6
系统:MacOS
IDE:PyCharm
第三方库:pymysql
厦门哪里有卖厦工叉车的
Show Code
import pymysqlhost = 'xxx.65.9.191'username = 'root'password = 'root'def connectMySQL():print('开始连接数据库') # 打开数据库连接db = pymysql.connect(host,username,password,charset='utf8') # 使用 cursor() 方法创建一个游标对象 cursorcursor = db.cursor() # 使用 execute() 显示所有数据库cursor.execute("SHOW DATABASES")print('开始查询所有数据库') # 获取所有数据库名称data = cursor.fetchall() # 开始操作for dbb in data:dbname = dbb[0]print('选中' + dbname + '数据库') # 选择数据库cursor.execute("use " + dbname) # 查看有哪些表cursor.execute("show tables")table = cursor.fetchall() # 如果不是3个表的就不管if len(table) != 3: continuefor tb in table:tbname = tb[0]print('开始删除'+tbname+'表') # 删除所有的表cursor.execute("DROP TABLE " + tbname)executeScriptsFromFile('1.sql', cursor)db.close()def executeScriptsFromFile(filename,cursor):fd = open(filename, 'r',encoding='utf-8')sqlFile = fd.read()fd.close()sqlCommands = sqlFile.split(';') for command in sqlCommands: try:cursor.execute(command) except Exception as msg:print(msg)print('sql执行完成')if __name__ == "__main__":connectMySQL()
解释代码
这是用于执行sql
文件,这里第一句就有个坑,最好设置encoding='utf-8'
否则可能会报错UnicodeEncodeError: 'latin-1' codec can't encode characters in position 41-44: ordinal not in range(256)
,当读取了sql
文件后用;
分割语句然后用for循环依次执行sql
语句
def executeScriptsFromFile(filename,cursor):fd = open(filename, 'r',encoding='utf-8')sqlFile = fd.read()fd.close()sqlCommands = sqlFile.split(';') for command in sqlCommands: try:cursor.execute(command) except Exception as msg:print(msg)print('sql执行完成')
这一段比较容易理解了,首先是连接数据库,注意还是最好设置一下charset='utf8'
,因为我要操作多个数据库执行sql
文件,所以先把数据库名称全部获取出来,这里获取出来的结果是元组类型,即使for循环后出来的也是一个元组,所以用[0]取出元组中的值,然后选中数据库执行删表操作(当然不是每个人都要按我这些操作哈,需要执行啥操作就自己改SQL语句),表删完了,然后开始执行1.sql
文件,执行完成后关闭数据库
def connectMySQL():print('开始连接数据库') # 打开数据库连接db = pymysql.connect(host,username,password,charset='utf8') # 使用 cursor() 方法创建一个游标对象 cursorcursor = db.cursor() # 使用 execute() 显示所有数据库cursor.execute("SHOW DATABASES")print('开始查询所有数据库') # 获取所有数据库名称data = cursor.fetchall() # 开始操作for dbb in data:dbname = dbb[0]print('选中' + dbname + '数据库') # 选择数据库cursor.execute("use " + dbname) # 查看有哪些表cursor.execute("show tables")table = cursor.fetchall() # 如果不是3个表的就不管if len(table) != 3: continuefor tb in table:tbname = tb[0]print('开始删除'+tbname+'表') # 删除所有的表cursor.execute("DROP TABLE " + tbname)executeScriptsFromFile('1.sql', cursor)db.close()
这2篇文章的代码从思路、编写、到测试,用了一下午吧!我对Python也不是很熟悉,所以中间也踩了些坑,但确实能看出来,Python作为胶水语言拿来做这些小工具真的舒服!
转载于:https://www.cnblogs.com/xyou/p/9466251.html
使用Python批量修改数据库执行Sql文件相关推荐
- python数据库操作批量sql执行_使用Python批量修改数据库执行Sql文件
由于上篇文章中批量修改了文件,有的时候数据库也需要批量修改一下,之前的做法是使用宝塔的phpMyAdmin导出一个已经修改好了的sql文件,然后依次去其他数据库里导入,效率不说极低,也算低了,且都是些 ...
- python数据库操作批量sql执行_利用Python如何批量修改数据库执行Sql文件
利用Python如何批量修改数据库执行Sql文件 来源:中文源码网 浏览: 次 日期:2018年9月2日 [下载文档: 利用Python如何批量修改数据库执行Sql文件.txt ] (友 ...
- python数据库操作批量sql执行_Python批量修改数据库执行Sql文件
{"moduleinfo":{"card_count":[{"count_phone":1,"count":1}],&q ...
- python 选择不同数据库环境执行SQL文件
在有很多SQL文件,或者很多SQL语句的时候,如果手动每个文件执行会很麻烦:另外有的时候SQL语句的执行会影响用户的使用效果,需要在晚上没有用户使用网站的情况下执行SQL语句,也就是晚上定时执行SQL ...
- Python连接MySQL数据库执行sql语句时的参数问题
由于工作需要,今天写了一个Python小脚本,其中需要连接MySQL数据库,在执行sql命令时需要传递参数,结果出问题了.在网上查了一下,发现有以下几种方式传递参数: 一.直接把sql查询语句完整写入 ...
- mysql和oracle 命令行执行sql文件 数据库执行sql文件 执行sql语句
windows和linux操作相同 借鉴:http://www.361way.com/mysql-exec-sql-file/2646.html 方法一:mysql 调用法 操作方式如下: mysql ...
- pg数据库执行sql文件_在linux中Postgresql数据库如何执行脚本文件
在linux中Postgresql数据库如何恢复数据库?执行sql脚本文件呢?具体步骤如下: 一.恢复数据库备份文件 1.将数据库备份文件xxx.backup用连接工具拷贝到/opt下,这个不固定,位 ...
- 8万行的insert数据,Ctrl+c、Ctrl+v后心态崩了(如何在Linux下对MySQL数据库执行sql文件)...
从最下面可以看到,差不多有86389行,Ctrl+c.Ctrl+v后 PHPstorm一直没有反应.... 肿么办??复制粘贴不行的话,可以用什么方法把数据插入到数据库中,数据库用的是MySQL. 皇 ...
- 如何修改数据库名字.sql文件
首先,找到数据库.sql源文件,以记事本或者写字板打开 编辑->替换 将文本中的源数据库名字(如我的为kaoqin),全部替换为目标的名字,如我这里演示的为改为testdb1.sql 点击全部替 ...
最新文章
- 用户操作拦截并作日志记录--自定义注解+AOP拦截
- 随笔汇总_索取资料请进入
- 限界分支法优先级队列方式出口和追踪解的两种方法总结
- EGLSurfaces 和 OpenGL ES
- [Java基础]自定义注解 格式本质
- 搭建云计算机win10,win10电脑做云服务器
- Atitit.设计模式-----触发器模式 trigger 详解
- iOS自动化测试元素定位
- 单片机中存储器扩展位地址线怎么算_单片机程序存储器的扩展
- pdf线条粗细设置_pdf线条很模糊怎么办 如何调整pdf线条粗细
- ES 根据查询条件求和sum
- java集成微信支付
- Redis源码阅读笔记(二)list双向链表结构
- ng-template、ng-content、ng-container
- 几款免费wordpress主题推荐
- 基于JAVA师大家教中心管理系统计算机毕业设计源码+系统+mysql数据库+lw文档+部署
- 如何更改计算机开机壁纸,如何修改电脑开机的背景图片
- Bootstrap-CL:标签
- python3 mysql5.7_/如何连接python3.4 和MySQL5.7,请大牛们指教这个python入门新手
- 使用python+selenium爬取同城旅游网机票信息