mysql 导入shp数据

import ogr
import json

# 打开SHP文件
shp_file = ogr.Open('path_to_your_file.shp')
layer = shp_file.GetLayer()

# 创建GeoJSON文件
geojson = {
    "type": "FeatureCollection",
    "features": []
}

for feature in layer:
    geom = feature.GetGeometryRef()
    geom_json = json.loads(geom.ExportToJson())
    feature_json = {
        "type": "Feature",
        "geometry": geom_json,
        "properties": feature.items()
    }
    geojson["features"].append(feature_json)

with open('output.geojson', 'w') as f:
    json.dump(geojson, f)

# 导入到MySQL数据库（假设已创建表）
import mysql.connector

db = mysql.connector.connect(
    host="localhost",
    user="your_username",
    password="your_password",
    database="your_database"
)
cursor = db.cursor()

with open('output.geojson', 'r') as f:
    data = json.load(f)

for feature in data["features"]:
    sql = """
    INSERT INTO your_table (geom, name, type)
    VALUES (ST_GeomFromGeoJSON(%s), %s, %s)
    """
    cursor.execute(sql, (json.dumps(feature["geometry"]), feature["properties"]["name"], feature["properties"]["type"]))

db.commit()
cursor.close()
db.close()