Python从数据库读取数据写入json格式文件

#!/usr/bin/python# -*- coding: UTF-8 -*-########################################################################## File Name: addreplace.py# Author: yuhaitao# mail: [email protected]# Created Time: Fri 31 Mar 2017 07:05:13 PM PDT#########################################################################import osimport sysimport reimport cgi,cgitbimport codecsimport timeimport pymysqlimport MySQLdbimport jsonimport codecs

#接收数据#def RecvFromForm():form = cgi.FieldStorage()#getURL = form.getvalue(‘netURL‘)#接受xmlhttp.open("GET","/cgi-bin/SqltoHtml.py?q="+str,true)传递的参数getNum = form.getvalue(‘q‘)

def convert_to_json_string2(contxt,str_ft):    ret = []  # 需要序列化的列表    tmp = {‘contxt‘:contxt , ‘footer‘:str_ft}  # 通过data的每一个元素构造一个字典    ret.append(tmp)    ret = json.dumps(ret, indent=4)    return ret

def DbSongName(song_id,cursor):    sql_song_name = """SELECT * FROM  music163 WHERE song_id = %s """ %(song_id)    #sql_song_name = """SELECT * FROM  music163 WHERE song_id=186016;"""    #print sql_song_name    try:        cursor.execute(sql_song_name)        results = cursor.fetchall()        for row in results:            name = row[2]    except Exception , e:        print "DbSong"+str(e)        db.rollback()        db.close()    return namedef convert_to_json_string1(data):    return json.dumps(data,indent=4,encoding=‘utf-8‘,ensure_ascii=False)

def Dbinsert():    db = MySQLdb.connect("bdm273925510.my3w.com","bdm273925510","hfdsggsgfs","bdm273925510_db",charset=‘utf8‘ )    cursor = db.cursor()    sql ="""SELECT * FROM  comment163 WHERE liked  > 50000 order by liked DESC """    try:        cursor.execute(sql)        results = cursor.fetchall()        for i, row in enumerate(results):            id = row[0]            song_id = row[1]            song_name = DbSongName(song_id,cursor)            txt = row[2]            author = row[3]            liked = row[4]            data = {‘contxt‘:txt,‘footer‘:u‘序列号:‘+str(i)+u‘--歌曲:‘+song_name+u‘--评论:‘+str(liked)+u‘--作者:‘+author}            #convert_to_json_string2(txt,str(i)+song_name+str(liked)+author)            print convert_to_json_string1(data)            with codecs.open("J:\\Users\\Acer_haitao\\Desktop\\net.json","a+",encoding=‘utf-8‘) as f:                json.dump(data,f,indent=4,encoding=‘utf-8‘,ensure_ascii=False)    except Exception , e:        print "Dbinsert "+str(e)        db.rollback()        db.close()Dbinsert()

原文地址：https://www.cnblogs.com/acer-haitao/p/8366048.html