SQLite Export

gdm-flow export examples/models/p5r.json --db results.db

from gdm_flow import (
    optimize_ac_power_flow_from_components,
    solve_dc_opf_from_components,
    solve_lindistflow,
    export_all_results_to_sqlite,
)
from gdm.distribution import DistributionSystem

system = DistributionSystem.from_json("model.json")
ac = optimize_ac_power_flow_from_components(system)
dc = solve_dc_opf_from_components(system)
ldf = solve_lindistflow(system)

export_all_results_to_sqlite(
    db_path="results.db",
    ac_result=ac,
    dc_result=dc,
    lindistflow_result=ldf,
)

-- Compare source power across all runs
SELECT r.implementation, r.success,
       CASE r.implementation
           WHEN 'ac_opf' THEN (SELECT SUM(p_injection_w) FROM ac_opf_nodes n
                                WHERE n.run_id = r.run_id AND n.bus_name = 'source_bus')
           WHEN 'dc_opf' THEN (SELECT slack_injection_w FROM dc_opf_summary s
                                WHERE s.run_id = r.run_id)
       END AS source_p_w
FROM runs r;

-- Get all bus voltages from the latest AC run
SELECT bus_name, phase, voltage_mag_v
FROM ac_opf_nodes
WHERE run_id = (SELECT run_id FROM runs
                WHERE implementation = 'ac_opf'
                ORDER BY created_at_utc DESC LIMIT 1)
ORDER BY bus_name, phase;