WaterServer/InsertHotPointData.py

import json
import pymysql
import codecs;
# 连接数据库
conn = pymysql.connect(host='localhost', user='root', password='HelloWorld123', db='water', charset='utf8mb4')
try:
    with conn.cursor() as cursor:
        content = ""
        with codecs.open("hotPoints.json",encoding="utf-8") as lud:
            content = lud.read()
        # 解析JSON数据
        data = json.loads(content)
        
        # 插入数据到数据库
        for item in data:
            cursor.execute("INSERT INTO WaterHotPoints (type, longitude, latitude, name, name_pri) VALUES (%s, %s, %s, %s, %s)",
                           (item['type'], item['longitude'], item['latitude'], item['name'], item['name_pri']))
        
        conn.commit()
finally:
    conn.close()