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("layerUnitDatas.json",encoding="utf-8") as lud:
            content = lud.read()
        # 解析JSON数据
        data = json.loads(content)
        
        # 插入数据到数据库
        for item in data:
            cursor.execute("INSERT INTO WaterManagementProjects (special, type, longitude, latitude, name, name_pri, text1, text2) VALUES (%s, %s, %s, %s, %s, %s, %s, %s)",
                           (item['special'], item['type'], item['longitude'], item['latitude'], item['name'], item['name_pri'], item['text1'], item['text2']))
        
        conn.commit()
finally:
    conn.close()