data.datasets.gas_neighbours.gas_abroad.insert_gas_grid_capacities()

Complexity

Conditions

4

Size

Total Lines	107
Code Lines	26

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

"""Module containing functions to insert gas abroad

def insert_gas_grid_capacities(Neighbouring_pipe_capacities_list, scn_name):

    """Insert crossbordering gas pipelines in the database


    This function insert a list of crossbordering gas pipelines after

    cleaning the database.

    For eGon2035, all the CH4 crossbordering pipelines are inserted

    there (no H2 grid in this scenario).

    For eGon100RE, only the the crossbordering pipelines with Germany

    are inserted there (the other ones are inerted in PypsaEurSec),

    but in this scenario there are H2 and CH4 pipelines.


    Parameters

    ----------

    Neighbouring_pipe_capacities_list : pandas.DataFrame

        List of the crossbordering gas pipelines

    scn_name : str

        Name of the scenario


    Returns

    -------

    None


    """

    sources = config.datasets()["gas_neighbours"]["sources"]

    targets = config.datasets()["gas_neighbours"]["targets"]


    # Delete existing data

    if scn_name == "eGon2035":

        carrier_link = "CH4"

        carrier_bus = "CH4"


        db.execute_sql(

            f"""

            DELETE FROM 

            {sources['links']['schema']}.{sources['links']['table']}

            WHERE "bus0" IN (

                SELECT bus_id FROM 

                {sources['buses']['schema']}.{sources['buses']['table']}

                    WHERE country != 'DE'

                    AND carrier = '{carrier_bus}'

                    AND scn_name = '{scn_name}')

            OR "bus1" IN (

                SELECT bus_id FROM 

                {sources['buses']['schema']}.{sources['buses']['table']}

                    WHERE country != 'DE'

                    AND carrier = '{carrier_bus}' 

                    AND scn_name = '{scn_name}')

            AND scn_name = '{scn_name}'

            AND carrier = '{carrier_link}'            

            ;

            """

        )


    carriers = {

        "CH4": {"bus_inDE": "CH4", "bus_abroad": "CH4"},

        "H2_retrofit": {"bus_inDE": "H2_grid", "bus_abroad": "H2"},

    }


    if scn_name == "eGon100RE":

        for c in carriers:

            db.execute_sql(

                f"""

                DELETE FROM

                {sources['links']['schema']}.{sources['links']['table']}

                WHERE ("bus0" IN (

                        SELECT bus_id FROM 

                        {sources['buses']['schema']}.{sources['buses']['table']}

                        WHERE country != 'DE'

                        AND carrier = '{carriers[c]["bus_abroad"]}'

                        AND scn_name = '{scn_name}')

                    AND "bus1" IN (SELECT bus_id FROM 

                        {sources['buses']['schema']}.{sources['buses']['table']}

                        WHERE country = 'DE'

                        AND carrier = '{carriers[c]["bus_inDE"]}' 

                        AND scn_name = '{scn_name}'))

                OR ("bus0" IN (

                        SELECT bus_id FROM 

                        {sources['buses']['schema']}.{sources['buses']['table']}

                        WHERE country = 'DE'

                        AND carrier = '{carriers[c]["bus_inDE"]}'

                        AND scn_name = '{scn_name}')

                AND "bus1" IN (

                        SELECT bus_id FROM 

                        {sources['buses']['schema']}.{sources['buses']['table']}

                        WHERE country != 'DE'

                        AND carrier = '{carriers[c]["bus_abroad"]}' 

                        AND scn_name = '{scn_name}'))

                AND scn_name = '{scn_name}'

                AND carrier = '{c.index}'            

                ;

                """

            )


    # Insert data to db

    Neighbouring_pipe_capacities_list.set_geometry(

        "geom", crs=4326

    ).to_postgis(

        "egon_etrago_gas_link",

        db.engine(),

        schema="grid",

        index=False,

        if_exists="replace",

        dtype={"geom": Geometry(), "topo": Geometry()},

    )


    db.execute_sql(

        f"""

    select UpdateGeometrySRID('grid', 'egon_etrago_gas_link', 'topo', 4326) ;