python json2sql@2023-07-05

#!/usr/bin/python
# -*- encoding:UTF-8 -*-
#   author:pangPython
import json

#将sql语句写入文件
def main():
    movie_json_file = open("movies.json","r",encoding='utf-8')
    sql_file = open("movies.sql","a",encoding='utf-8')
    for line in movie_json_file:
        json2sql(sql_file,line)

#解析聚合数据返回的json影讯api查询串为sql语句
def json2sql(sql_file,json_str):
    jstr = json.loads(json_str)
    if jstr['resultcode'] == "200":
        result_jstr = jstr['result']
        sql = 'insert into movies(';
        key_jstr = ''
        value_jstr = '"'
        for j in result_jstr.keys():
            key_jstr = key_jstr+j+','
        for i in result_jstr.values():
            value_jstr = value_jstr+str(i)+'","'
        #print(sql+key_jstr[:-1]+') values('+value_jstr[:-2]+');')
        sql_file.write(sql+key_jstr[:-1]+') values('+value_jstr[:-2]+');\n')

if __name__ == '__main__':
    main()

pyHive 连接 hive数据库