python导入数据库的脚本-创新互联

该脚本针对批量导入数据sql文件，data目录存放所要导入的sql文件，list.txt存放要导入的列表信息。

创新互联公司主营桃源网站建设的网络公司,主营网站建设方案,重庆APP开发,桃源h5重庆小程序开发公司搭建,桃源网站营销推广欢迎桃源等地区企业咨询

脚本内容如下：

#!/usr/bin/env python # -*- coding:utf-8 -*- import os, sys, logging, datetime # 日志文件配置 if not os.path.isdir('logs'):     os.mkdir('logs') logging.basicConfig(level=logging.INFO,                     format='%(asctime)s %(name)-12s %(levelname)-8s %(message)s',                     datefmt='%Y-%m-%d %H:%M',                     filename='logs/importable.log',                     filemode='a') console = logging.StreamHandler() console.setLevel(logging.INFO) formatter = logging.Formatter('%(message)s') console.setFormatter(formatter) logging.getLogger('').addHandler(console) logger = logging.getLogger(__name__) # 从本地配置文件中读取主机列表信息 def readinfo(confile):     info_list = []     if os.path.isfile(confile):         with open(confile, 'r+') as f:             for line in f.readlines():                 if not line.startswith("#"):                     dict = {}                     dict['id'] = line.split()[0]                     dict['host'] = line.split()[1]                     dict['name'] = line.split()[2]                     info_list.append(dict)             return info_list     else:         logger.error(u"本地配置文件%s不存在！" % confile)         sys.exit(1) def readsqlfile(data):     sql_list = []     # 判断本地的sql文件是否存在目录是否存在。     if os.path.isdir(data):         for sql_file in os.listdir(data):             if sql_file:                 sql_list.append(os.path.join(data,sql_file))             else:                 logger.error(u"本地%s目录中没有要导入的sql文件！"%data)     else:         logger.error(u"%s 不是一个目录。"%data)     return sql_list # 循环info_list和sql_list将sql导入每一个服务器 def importhost(info_list, sql_list):     succ_list = []     fail_list = []     for ser in info_list:         for sql_file in sql_list:             cmd = "%s/mysql -u%s -p%s -h'%s' %s < %s" % (mysql_path, mysql_user, mysql_passwd, ser['host'], ser['name'] ,sql_file)             status = os.system(cmd)             if status == 0:                 msg = "%s -- %s -- %s 导入sql：%s 完毕！"%(ser['id'],ser['host'],ser['name'],sql_file)                 succ_list.append(msg)                 logger.info(msg)             else:                 msg = "%s -- %s -- %s 导入sql：%s 失败！" % (ser['id'], ser['host'], ser['name'], sql_file)                 fail_list.append(msg)                 logger.error(msg)                 sys.exit(1)     return succ_list,fail_list def yesorno(confile,data):     print "数据库列表如下:"     info_list = readinfo(confile)     for ser in info_list:         print "%s --- %s ---- %s"%(ser['id'],ser['host'],ser['name'])     iput = raw_input("你是否要导入sql文件 %s，请输入yes or no:" % (os.listdir(data)))     while True:         if iput.lower() in ['y','yes']:             print "你选择了继续执行程序动作！"             break         elif iput.lower() in ['n','no']:             print "你选择了退出程序动作!"             sys.exit(1)         else:             print "你输入了非法的字符,脚本并未执行导入sql文件的任何动作，程序即将退出。"             sys.exit(1) if __name__ == '__main__':     # 基本信息配置变量     data = r'data' # 存放本地sql文件的目录     confile = 'list.txt' # 存放服务器列表信息,格式如： id  host dbname ： 1 192.168.2.20 game_name_cn1     # MySQL变量     mysql_path = '/usr/local/mysql/bin'     mysql_user = 'root'     mysql_passwd = 'xirexrt,mf'     yesorno(confile,data)     startime = datetime.datetime.now()     sql_list = readsqlfile(data)     info_list = readinfo(confile)     succ,fail= importhost(info_list,sql_list)     logger.info(u'总共执行成功%s条. \r\n 总共执行失败%s条.'%(len(succ), len(fail)))     endtime = datetime.datetime.now()     logger.info(u"\r\nTotal time: %s ms" % ((endtime - startime).microseconds / 1000))

另外有需要云服务器可以了解下创新互联cdcxhl.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。

网站标题：python导入数据库的脚本-创新互联
文章URL：http://cqcxhl.com/article/phgcs.html