由于产品运营部需要采用第三方个推平台，来推送消息。如果手动一个个键入字段和字段值，容易出错，且非常繁琐，需要将mysql的数据转换为json数据，直接复制即可。
本文将涉及到如何使用Python访问Mysql数据库及读取获取数据（前提需要安装MySQLdb第三方库哦），以及如何将数据转换为json数据，最后保存成文件输出。
代码如下：注释比较详细了。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
|
# coding=utf-8'''Created on 2016-10-26@author: JenniferProject:读取mysql数据库的数据，转为json格式'''import json,MySQLdbdef TableToJson(): try: #1-7：如何使用python DB API访问数据库流程的 #1.创建mysql数据库连接对象connection #connection对象支持的方法有cursor(),commit(),rollback(),close() conn = MySQLdb.Connect(host='mysql服务器地址',user='用户名',passwd='密码',db='数据库名称',port=3306,charset = 'utf8') #2.创建mysql数据库游标对象 cursor #cursor对象支持的方法有execute(sql语句),fetchone(),fetchmany(size),fetchall(),rowcount,close() cur = conn.cursor() #3.编写sql sql = "SELECT pm.name AS nm,pm.desc AS dc,pm.image_url AS iu,pm.image_type AS it, pm.on_going AS og, pm.type AS mt,pm.pkgName AS pn,pm.apk_url AS du,pm.apkMd5 AS am,pm.minversionCode AS mc,pm.versionCode AS vc,pm.versionName AS vn, pm.signatureMd5 AS sm,pm.source AS se,pm.action AS ao FROM message pm WHERE pm.id = '217'" #4.执行sql命令 #execute可执行数据库查询select和命令insert，delete，update三种命令(这三种命令需要commit()或rollback()) cur.execute(sql) #5.获取数据 #fetchall遍历execute执行的结果集。取execute执行后放在缓冲区的数据，遍历结果，返回数据。 #返回的数据类型是元组类型，每个条数据元素为元组类型:(('第一条数据的字段1的值','第一条数据的字段2的值',...,'第一条数据的字段N的值'),(第二条数据),...,(第N条数据)) data = cur.fetchall() print u'fetchall()返回的数据：',data #6.关闭cursor cur.close() #7.关闭connection conn.close() jsonData = [] #循环读取元组数据 #将元组数据转换为列表类型，每个条数据元素为字典类型:[{'字段1':'字段1的值','字段2':'字段2的值',...,'字段N:字段N的值'},{第二条数据},...,{第N条数据}] for row in data: result = {} result['nm'] = row[0] result['dc'] = row[1] result['iu'] = row[2] result['it'] = str(row[3]) result['og'] = str(row[4]) result['mt'] = str(row[5]) result['pn'] = row[6] result['du'] = row[7] result['am'] = row[8] result['mc'] = str(row[9]) result['vc'] = str(row[10]) result['vn'] = row[11] result['sm'] = row[12] result['se'] = str(row[13]) result['ao'] = str(row[14]) jsonData.append(result) print u'转换为列表字典的原始数据：',jsonData except: print 'MySQL connect fail...' else: #使用json.dumps将数据转换为json格式，json.dumps方法默认会输出成这种格式"\u5377\u76ae\u6298\u6263"，加ensure_ascii=False，则能够防止中文乱码。 #JSON采用完全独立于语言的文本格式，事实上大部分现代计算机语言都以某种形式支持它们。这使得一种数据格式在同样基于这些结构的编程语言之间交换成为可能。 #json.dumps()是将原始数据转为json（其中单引号会变为双引号），而json.loads()是将json转为原始数据。 jsondatar=json.dumps(jsonData,ensure_ascii=False) #去除首尾的中括号 return jsondatar[1:len(jsondatar)-1] if __name__ == '__main__': #调用函数 jsonData = TableToJson() print u'转换为json格式的数据：',jsonData #以读写方式w+打开文件，路径前加r，防止字符转义 f = open(r'D:\getui\getuidata.txt','w+') #写数据 f.write(jsonData) #关闭文件 f.close() |
执行结果：（注代码上方打印的数据为了方便查看数据，可屏蔽，最终json数据会保存在txt文件中）
fetchall()返回的数据： ((u'\u5377\u76ae\u6298\u6263', u'\u5377\u76ae\u6298\u6263', u'http://域名/push/push_d701df5f48c727df46c847fa912993cf.jpg', 3L, 0L, 1L, u'com.juanpi.ui', u'http://域名/apk_1476871813.apk', u'301e757dc6669ecc95ffaaae13bb096d', 14L, 64L, u'4.1.2', u'd1e536a6a60f414700cf3c86f28719c2', 3L, 2L),)
转换为列表字典的原始数据： [{'vc': '64', 'nm': u'\u5377\u76ae\u6298\u6263', 'mc': '14', 'og': '0', 'am': u'301e757dc6669ecc95ffaaae13bb096d', 'iu': u'http://域名/push/push_d701df5f48c727df46c847fa912993cf.jpg', 'it': '3', 'vn': u'4.1.2', 'dc': u'\u5377\u76ae\u6298\u6263', 'mt': '1', 'ao': '2', 'sm': u'd1e536a6a60f414700cf3c86f28719c2', 'du': u'http://域名/apk_1476871813.apk', 'pn': u'com.juanpi.ui', 'se': '3'}]
转换为json格式的数据： {"vc": "64", "nm": "卷皮折扣", "mc": "14", "og": "0", "am": "301e757dc6669ecc95ffaaae13bb096d", "iu": "http:/域名/push/push_d701df5f48c727df46c847fa912993cf.jpg", "it": "3", "vn": "4.1.2", "dc": "卷皮折扣", "mt": "1", "ao": "2", "sm": "d1e536a6a60f414700cf3c86f28719c2", "du": "http://域名/apk_1476871813.apk", "pn": "com.juanpi.ui", "se": "3"}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持服务器之家。
原文链接：https://www.cnblogs.com/yufeihlf/p/6004124.html
