小编给大家分享一下利用Python怎么批量修改数据库执行Sql文件,希望大家阅读完这篇文章之后都有所收获,下面让我们一起去探讨吧!
创新互联-专业网站定制、快速模板网站建设、高性价比相山网站开发、企业建站全套包干低至880元,成熟完善的模板库,直接使用。一站式相山网站制作公司更省心,省钱,快速模板网站建设找我们,业务覆盖相山地区。费用合理售后完善,十载实体公司更值得信赖。环境
版本:Python3.6
系统:MacOS
IDE:PyCharm
第三方库:pymysql
Show Code
import pymysql host = 'xxx.65.9.191' username = 'root' password = 'root' def connectMySQL(): print('开始连接数据库') # 打开数据库连接 db = pymysql.connect(host,username,password,charset='utf8') # 使用 cursor() 方法创建一个游标对象 cursor cursor = 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: continue for 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() 方法创建一个游标对象 cursor cursor = 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: continue for tb in table: tbname = tb[0] print('开始删除'+tbname+'表') # 删除所有的表 cursor.execute("DROP TABLE " + tbname) executeScriptsFromFile('1.sql', cursor) db.close()
这2篇文章的代码从思路、编写、到测试,用了一下午吧!我对Python也不是很熟悉,所以中间也踩了些坑,但确实能看出来,Python作为胶水语言拿来做这些小工具真的舒服!
看完了这篇文章,相信你对“利用Python怎么批量修改数据库执行Sql文件”有了一定的了解,如果想了解更多相关知识,欢迎关注创新互联成都网站设计公司行业资讯频道,感谢各位的阅读!
另外有需要云服务器可以了解下创新互联scvps.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。