mysql远程快速导出csv格式数据工具
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了mysql远程快速导出csv格式数据工具，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含3941字，纯文字阅读大概需要6分钟。
内容图文
-*- coding:UTF-8 -*-
#@author Jane.Hoo
#@date 2016/11/29
from __future__ import division
import os
import MySQLdb
import time
import commands
import logging
import re
import math
print ‘*******************************‘
timestamp=time.strftime("%Y%m%d%H%M%S", time.localtime())
logfile=‘/tmp/myloaddataout.log%s‘%timestamp
logging.basicConfig(level=logging.DEBUG,
format=‘%(asctime)s %(filename)s[line:%(lineno)d] %(levelname)s %(message)s‘,
datefmt=‘%a, %d %b %Y %H:%M:%S‘,
filename=‘%s‘%logfile,
filemode=‘w‘)
print ‘导出日志记录在：%s‘%logfile
#################################################################################################
#定义一个StreamHandler，将INFO级别或更高的日志信息打印到标准错误，并将其添加到当前的日志处理对象#
console = logging.StreamHandler()
console.setLevel(logging.INFO)
formatter = logging.Formatter(‘%(name)-12s: %(levelname)-8s %(message)s‘)
console.setFormatter(formatter)
logging.getLogger(‘‘).addHandler(console)
#################################################################################################
#python /cygdrive/c/Users/Jane.Hoo/PycharmProjects/loaddata/MySQLloaddataout.py
db_host=‘127.0.0.1‘
db_user=‘test‘
db_pwd=‘test‘
db=‘test‘
db_port=int(‘3306‘)
class Toolloadout:
def __init__(self,pathfile=0):
self.pathfile=pathfile
#得到数据库连接
def getdbconn(self,DB_HOST=db_host,DB_USER=‘routeload‘,DB_PWD=‘routeload‘,DB=‘test01‘,DB_PORT=‘3306‘):
logging.debug(‘%s:%s:%s:%s:%s‘%(DB_HOST,DB_USER,DB_PWD,DB,DB_PORT))
conn=‘unlink‘
try:
conn=MySQLdb.connect(host=DB_HOST,user=DB_USER,passwd=DB_PWD,port=int(DB_PORT),db=DB)
logging.info(‘数据库连接成功‘)
except MySQLdb.OperationalError,e:
logging.warning(‘数据库连接失败！%s‘%e)
return conn
#关闭数据库连接
def closedbconn(self,conn=0):
logging.debug(‘闭数据库连接‘)
conn.close()
#检查导出文件
def chekpathfile(self):
pathfile=self.pathfile
check_flag=0
iffile_exists=os.path.exists(pathfile)
if iffile_exists==1:
check_flag=1
logging.info(‘导出文件已存在！‘)
else:
path=os.path.split(pathfile)[0]
ifpath_exists=os.path.isdir(path)
if ifpath_exists==1:
logging.info(‘%s是有效的路径‘%path)
else:
check_flag=1
logging.info(‘%s是无效的路径‘%path)
return check_flag
if __name__==‘__main__‘:
print ‘准备导出...‘
pathfile=raw_input("请输入导出文件路径:").strip()
cmd_sql=raw_input(‘请输入要查询的语句:‘).strip()
c=Toolloadout(pathfile)
pf_check=c.chekpathfile()
if pf_check==0:
logging.info(‘文件路径校验通过‘)
ifinputdbmsg=raw_input(‘是否需要自定义数据库连接信息(Y|N)？‘).strip()
if ifinputdbmsg==‘Y‘:
db_host=raw_input(‘请输入数据地址：‘).strip()
db_user=raw_input(‘请输入用户名：‘).strip()
db_pwd=raw_input(‘请输入密码：‘).strip()
db=raw_input(‘请输入数据库名：‘).strip()
db_port=raw_input(‘请输入数据库端口：‘).strip()
if db_host==‘‘ or db_user==‘‘ or db_pwd==‘‘ or db==‘‘:
logging.info(‘自定义数据库输入信息有为空.‘)
check_flag=1
if_port=re.match(r"[0-9]", db_port)
if if_port:
db_port=int(db_port)
else:
db_port=int(‘3306‘)
logging.info(‘端口格式输入有误，将使用默认端口%s‘%db_port)
conn=c.getdbconn(db_host,db_user,db_pwd,db,db_port)
if str(conn)!=‘unlink‘:
selectsql="mysql -A %s -h %s -u%s -p%s -P%s -ss -e ‘%s;‘ | sed ‘s/\\t/,/g;s/^//;s/$//;s/\\n//g‘ >%s"%(db,db_host,db_user,db_pwd,db_port,cmd_sql,pathfile)
print ‘querysql:‘,selectsql
try:
os.system(‘%s‘%selectsql)
except BaseException,e:
logging.info(‘导出数据过程中报错!%s‘%e)
c.closedbconn(conn)
else:
logging.info(‘失败‘)
else:
logging.info(‘文件路径校验不通过，导出结束‘)
作者：jane.hoo 出处：jane.hoo的博客 http://www.cnblogs.com/janehoo/ [人生不设限,生命不息，折腾不止] 您的支持是对博主最大的鼓励，感谢您的认真阅读。本文版权归作者所有，欢迎转载，但请保留该声明。
mysql远程快速导出csv格式数据工具
标签：localtime get 密码 使用 脚本语言 import time 标准 use
本文系统来源：http://www.cnblogs.com/janehoo/p/6114104.html
内容总结
以上是互联网集市为您收集整理的mysql远程快速导出csv格式数据工具全部内容，希望文章能够帮你解决mysql远程快速导出csv格式数据工具所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。
来源：【匿名】