# -*- coding:utf-8 -*- #!/bin/env python ''' #Auth:karl #Function: released version #Date:2017/6/27 #Version:V1.0 ''' import  sys,re,time,datetime import  paramiko import logging import ConfigParser import traceback import MySQLdb import platform import xlrd reload(sys) sys.setdefaultencoding('utf-8') if "Linux" == platform.system():     Excelpath="/home/appdeploy/version/Version" else:     Excelpath = "D:\\auto\\release\Version" class Mysql_connect(object):     def __init__(self,*agre):         self.port=agre[0]         self.passwd=agre[1]         self.username=agre[2]         self.host=agre[3]         self.version=agre[4]     def File_get(self): Excelfilepath="{path}_{version}/Filelist.xlsx".format(path=Excelpath,version=self.version)         workbook=xlrd.open_workbook(Excelfilepath)         booksheet = workbook.sheet_by_name('Sheet1')         self.p=list()         for row in range(booksheet.nrows):             row_data = []             for col in range(booksheet.ncols):                 cel = booksheet.cell(row, col)                 val = cel.value                 try:                     val = cel.value                     val = re.sub(r'\s+', '', val)                 except:                     pass                 if type(val) == float:                     val = int(val)                 else:                     val = str(val)                 row_data.append(val)             self.p.append(row_data)         self.__Mysql_deal()     def __Mysql_deal(self):         try:             con = MySQLdb.connect(user=self.username,passwd=self.passwd,db="version_release",port=int(self.port),charset="utf8")             dt = datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")             cursor=con.cursor()             cursor.execute("CREATE TABLE IF NOT EXISTS version(Id INT PRIMARY  KEY  AUTO_INCREMENT,\                             File VARCHAR (30) DEFAULT  null,Release_date TIMESTAMP,Instruction text)")             sql="""INSERT INTO version (File,Release_date,Instruction) VALUES (%s, %s, %s) """             for value in self.p:                 valuse=(value[0],dt,value[1])                 result=cursor.execute(sql,valuse)             cursor.close()             con.commit()             con.close()         except MySQLdb.Error, e:             print "Error %d: %s" % (e.args[0], e.args[1])             sys.exit(1)     def File_deal(self):         try:             ssh = paramiko.SSHClient()             ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())             ssh.connect(self.host,22, "root","****", timeout=5)             for name in self.p:                 route_0=name[0]                 route=name[1]                 cmd="\cp -vr {path}_{version}/{filename}.xls  {dir_new}".format(path=Excelpath,version=self.version,filename=route_0,dir_new=route)                 stdin, stdout, stderr = ssh.exec_command(cmd)                 for out_msg in stdout.readlines():                     print out_msg         except Exception, e:             print '%s\tError\n' % (self.host) ,e         ssh.close() def main():     agre = ["3306", "*****", "root","xx.xx.xx.xx","3.0"]     stg = Mysql_connect(*agre)     stg.File_get()     stg.File_deal() if __name__ == '__main__':     try:       main()     except Exception as e:         print traceback.format_exc()

创新互联成立与2013年，先为筠连等服务建站，筠连等地企业，进行企业商务咨询服务。为筠连企业网站制作PC+手机+微官网三网同步一站式服务解决您的所有建站问题。

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

文章标题：python数据库处理-创新互联
本文网址：http://chengdu.cdxwcx.cn/article/hiide.html