Python读取MySQL导出文件并处理结果详解

Chloe

发布时间：2026-10-13| 5人浏览过

原创

本文介绍如何在运维场景中利用Python读取MySQL命令行导出的文本结果文件，并通过正则表达式进行字段拆分与处理。文章包含生成导出文件的MySQL命令示例，以及完整的Python脚本实现，涵盖文件读取、数据清洗、字段提取及后续业务逻辑调用的流程，适用于需要批量处理数据库导出结果的自动化任务。

Python处理MySQL结果输出概述

在系统运维工作中，经常需要获取MySQL数据库的查询结果并执行后续处理。本节将介绍如何使用Python读取MySQL导出的结果文件，并对数据进行相应的整理与分析。

生成MySQL结果导出文件

首先，执行MySQL命令以生成结果输出文件：

mysql -h10.20.10.207 -uroot -ppasswd test -e "select sendorderid, (price*100),mob from interfacelog where merid='****' >/home/anan/interfacelog.txt ##这里写你需要执行的sql语句将结果打印成一个文件

/home/anan/interfacelog.txt文件的内容如下所示。出于保密考虑，此处仅展示一条数据记录。

Python读取与处理逻辑实现

程序功能说明：readInterfacelog

该模块旨在读取MySQL导出的结果文件，并执行指定的处理逻辑。此处以重新输出处理后的结果作为演示案例。

具体代码实现如下：


#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Date  : 2018-07-19 11:39:00
# @Author : Zhou Jiaan
# @Version : V1.0
import os
import sys
import time
import re

def readInterfacelog(merid):
  with open('/home/anan/interfacelog.txt', 'r') as f: #读取mysql输出文件
    lines = f.readlines()
  for line in lines[2::1]: #因为第一第二行并不是我们需要处理的数据而是无效数据故我们忽略前两行直接读取后续我们需要的内容
    interfacelog = re.split(r'[\t|\s]\s*', line) #对文件进行切分，
    sendorderid = interfacelog[0]
    price100 = interfacelog[1]
    mob = interfacelog[2]
    print(sendorderid, price100, mob) 
    ###这里进行你需要对输出进行的操作。
    # os.system('/usr/local/bin/MsgSrvClient -h *.*.*.* -p 6004 -w0 -e "IFTran SlowInt 1 %s %s %s NA 1 5000 120 NA 22 NA NA %s NA NA NA";'%(sendorderid,price100,merid,mob)) ##这是我的需求
    time.sleep(0.1)

def main():
  # merid=sys.argv[1]
  try:
    merid_num = sys.argv[1]
  except Exception as e:
    merid_num = input("请输入merid:")
  else:
    print("输出merid_num:{}".format(merid_num))
  finally:
    merid = merid_num
    print(merid)
    readInterfacelog(merid)

if __name__ == '__main__':
  main()

补充：Python获取MySQL版本信息

补充知识：Python打印MySQL版本信息的方法

#注意：首行若写成#!/usr/local/python可能无法正常运行，具体原因待查


#!/usr/bin/env python

import MySQLdb
db = MySQLdb.connect("192.168.74.130","root","l","")
cursor=db.cursor()
cursor.execute("select version()")
data=cursor.fetchone()
print "Database version : %s " % data
db.close()

以上关于Python处理MySQL结果输出的方法即为全部内容，希望能对读者有所帮助。欢迎大家参考并支持本站。