import pymysql
import json

# 🔧 DB-Verbindung
conn = pymysql.connect(
    host="localhost",
    user="wahl",
    password="Uy9n2FPQ7%pM^H3",
    database="wahl",
    charset="utf8mb4"
)
cursor = conn.cursor()

# 📥 JSON laden
with open("einwohner_alter.json", "r", encoding="utf-8") as f:
    data = json.load(f)

# 🧾 Nur RAUMID, die mit "12" beginnen (Reinickendorf)
for eintrag in data:
    raumid = eintrag.get("RAUMID")
    if not raumid or not str(raumid).startswith("12"):
        continue  # Überspringe alle anderen

    cursor.execute("""
        INSERT INTO demografie_lor_detail (
            raumid, jahr, geschlecht, altersklasse, anzahl
        ) VALUES (%s, %s, %s, %s, %s)
    """, (
        raumid,
        eintrag.get("Jahr"),
        eintrag.get("Geschlecht"),
        eintrag.get("Altersklasse"),
        eintrag.get("Anzahl")
    ))

conn.commit()
cursor.close()
conn.close()

print("✅ Nur Reinickendorf (RAUMID beginnt mit 12) importiert.")