怎么办?上万事OK网

问题:python将json文件导入mysql数据库

【答案】:# 准备json文件,里边内容为:{"name": "tom", "age": "28"}

import json
import pymysql

# 连接数据库
conn = pymysql.connect(
        host = '192.168.32.131',
    #端口号
        port = 3306,
    #用户名
        user = 'root',
    #密码
        passwd = '123456',
    #数据库名称
        db = 'test',
    #字符编码格式
        charset = 'utf8')

cur = conn.cursor()


# 建表语句,字段要与json中的key值对应
createTableSql = 'CREATE table IF NOT EXISTS test.jsontest(name varchar(20) default null,age varchar(20) default null) ENGINE=InnoDB DEFAULT CHARSET=utf8;'
#json在我本地的路径
jsonPath = 'C:/Users/Administrator/Desktop/myself/python/json.json'

# 打开json文件
with open(jsonPath,'r',encoding='utf_8_sig') as f:
    # 读取json文件
    for line in f.readlines():
        # 读取json文件格式为python的dict字典类型
        dic = json.loads(line)
        
        # 拼接key值为:name,age
        keys = ','.join(dic.keys())
        
        # 将value值存为列表类型:['tom', '28'] <class 'list'>
        valuesList = [dici for dici in dic.values()]
        
        # 将value值存为元组类型:('tom', '28')
        valuesTuple = tuple(valuesList)
        
        # 拼接values为:%s, %s
        values = ', '.join(['%s']*len(dic)) 
        
        # 插入的表名
        table = 'test.jsontest'
        
        # 插入sql语句
        insertSql = 'INSERT INTO {table}({keys}) VALUES ({values})'.format(table=table, keys=keys, values=values)
        
        #执行建表与插入sql
        cur.execute(createTableSql)
        cur.execute(insertSql,valuesTuple)
        
        # 提交commit
        conn.commit()
    
    # 关闭数据库连接
    conn.close()
        

        

 
【关键字】:

首页 > IT » python将json文件导入mysql数据库

相关推荐

首页 |  家庭 | 升学 | 小学 | 中考 | 高考 | 考研 | 养老 | 育儿 | 旅游 | 宠物 | 美丽 | 家居 | 兴趣 | 健康 | 美食 | 商业 | 交通 | 艺术 | IT | 教育 | 体育 | 
© 2020 怎么办?上万事OK网