import os
import re
import time
import pymssql
import xlsxwriter
import argparse
def get_data_from_db(host='127.0.0.1',server='mssql',port=1433,database='master',sql_stament=''):
conn = pymssql.connect(host=host, server=server,port=port, database=database,as_dict=True, autocommit=True)
cursor = conn.cursor()
# 简单的判断,别尼玛执行了truncate啥的
if len(sql_statment)<6 or not (re.match(r'^select',sql_statment.lstrip())):
print('sql statment is error,exit……')
exit(1)
try:
cursor.execute(sql_stament)
result = cursor.fetchall()
except:
raise
finally:
cursor.close()
conn.close()
return result
def export_to_excel(result):
current_time = time.strftime("%Y%m%d%H%M%S", time.localtime())
workbook = xlsxwriter.Workbook('C:\\Windows\\Temp\\'+current_time+'_temp.xlsx')
worksheet = workbook.add_worksheet("sheet1")
# head row
col = 0
for key in result[0].keys():
worksheet.write(0, col, key)
col = col+1
# data row
row = 1
col = 0
for dict in result:
for key in dict:
worksheet.write(row, col, str(dict[key]))
col = col + 1
col = 0
row += 1
workbook.close()
os.startfile('C:\\Windows\\Temp\\'+current_time+'_temp.xlsx')
if __name__ == "__main__":
parser = argparse.ArgumentParser()
parser.add_argument("--host",required=True, type=str,help="host name or ip")
parser.add_argument("--db",required=False, type=str,help="database name")
parser.add_argument("--sql", required=True, type=str, help="sql statment")
args = parser.parse_args()
host = args.host
database = args.db
if not database:
database='master'
sql_statment = args.sql
print('executing sql……')
result = get_data_from_db(host = host,database = database,sql_stament =sql_statment)
print('exporting data……')
export_to_excel(result)
# example
# python export_data_to_excel.py --host "127.0.0.1" --sql "select * from tempdb.dbo.Test"