因爲產品運營部須要採用第三方個推平臺,來推送消息。若是手動一個個鍵入字段和字段值,容易出錯,且很是繁瑣,須要將mysql的數據轉換爲json數據,直接複製便可。python
本文將涉及到如何使用Python訪問Mysql數據庫及讀取獲取數據(前提須要安裝MySQLdb第三方庫哦),以及如何將數據轉換爲json數據,最後保存成文件輸出。mysql
代碼以下:註釋比較詳細了。sql
# coding=utf-8 ''' Created on 2016-10-26 @author: Jennifer Project:讀取mysql數據庫的數據,轉爲json格式 ''' import json,MySQLdb def 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"}編程