【无标题】mysql python 连接
coding:utf8
import os
import pymysql
import yaml
from common.log import logger
class Mysql:
# 处理.sql备份文件为SQL语句
def __read_sql_file(self,file_path):
# 打开SQL文件到f
sql_list = []
with open(file_path, ‘r’, encoding=‘utf8’) as f:
# 逐行读取和处理SQL文件
for line in f.readlines():
# 如果是配置数据库的SQL语句，就去掉末尾的换行
if line.startswith(‘SET’):
sql_list.append(line.replace(‘\n’, ‘’))
# 如果是删除表的语句，则改成删除表中的数据
elif line.startswith(‘DROP’):
sql_list.append(line.replace(‘DROP’, ‘TRUNCATE’).replace(’ IF EXISTS’, ‘’).replace(‘\n’, ‘’))
# 如果是插入语句，也删除末尾的换行
elif line.startswith(‘INSERT’):
sql_list.append(line.replace(‘\n’, ‘’))
elif li