diff --git a/qgepqwat2ili/__init__.py b/qgepqwat2ili/__init__.py index cf34ab35..4e533d76 100644 --- a/qgepqwat2ili/__init__.py +++ b/qgepqwat2ili/__init__.py @@ -3,15 +3,15 @@ from logging import INFO, FileHandler, Formatter from . import config, utils -from .qgep.export import qgep_export as qgep_export_kek -from .qgep.import_ import qgep_import as qgep_import_kek +from .qgep.export import qgep_export_kek +from .qgep.import_ import qgep_import_kek from .qgep.mapping import get_qgep_mapping from .qgep.model_abwasser import Base as BaseAbwasser from .qgep.model_qgep import Base as BaseQgep -from .qgepdss.export import qgep_export as qgep_export_dss -from .qgepdss.import_ import qgep_import as qgep_import_dss -from .qgepsia405.export import qgep_export as qgep_export_sia405 -from .qgepsia405.import_ import qgep_import as qgep_import_sia405 +from .qgepdss.export import qgep_export_dss +from .qgepdss.import_ import qgep_import_dss +from .qgepsia405.export import qgep_export_sia405 +from .qgepsia405.import_ import qgep_import_sia405 from .qwat.export import qwat_export from .qwat.import_ import qwat_import from .qwat.mapping import get_qwat_mapping diff --git a/qgepqwat2ili/gui/__init__.py b/qgepqwat2ili/gui/__init__.py index 0a68fe00..6cc9b206 100644 --- a/qgepqwat2ili/gui/__init__.py +++ b/qgepqwat2ili/gui/__init__.py @@ -15,16 +15,16 @@ from ....utils.qgeplayermanager import QgepLayerManager from .. import config -from ..qgep.export import qgep_export as qgep_export_kek -from ..qgep.import_ import qgep_import as qgep_import_kek +from ..qgep.export import qgep_export_kek +from ..qgep.import_ import qgep_import_kek # 12.7.2022 additional models -from ..qgepdss.export import qgep_export as qgep_export_dss -from ..qgepdss.import_ import qgep_import as qgep_import_dss +from ..qgepdss.export import qgep_export_dss +from ..qgepdss.import_ import qgep_import_dss # 28.3.2023 additional import for sia405, export to be discussed further -from ..qgepsia405.export import qgep_export as qgep_export_sia405 -from ..qgepsia405.import_ import qgep_import as qgep_import_sia405 +from ..qgepsia405.export import qgep_export_sia405 +from ..qgepsia405.import_ import qgep_import_sia405 from ..utils.ili2db import ( # neu 22.7.2022; get_xtf_model,; neu 31.3.2023; neu 12.4.2023 check_fk_dataowner_null, check_fk_operator_null, diff --git a/qgepqwat2ili/qgep/export.py b/qgepqwat2ili/qgep/export.py index 2b400a5c..07087053 100644 --- a/qgepqwat2ili/qgep/export.py +++ b/qgepqwat2ili/qgep/export.py @@ -14,7 +14,7 @@ from .model_qgep import get_qgep_model -def qgep_export(selection=None, labels_file=None, orientation=None, basket_enabled=False): +def qgep_export_kek(selection=None, labels_file=None, orientation=None, basket_enabled=False): """ Export data from the QGEP model into the ili2pg model. diff --git a/qgepqwat2ili/qgep/import_.py b/qgepqwat2ili/qgep/import_.py index e900dec0..6d8a36d0 100644 --- a/qgepqwat2ili/qgep/import_.py +++ b/qgepqwat2ili/qgep/import_.py @@ -11,7 +11,7 @@ from .model_qgep import get_qgep_model -def qgep_import(precommit_callback=None): +def qgep_import_kek(precommit_callback=None): """ Imports data from the ili2pg model into the QGEP model. diff --git a/qgepqwat2ili/qgep/import_.py.tpl b/qgepqwat2ili/qgep/import_.py.tpl deleted file mode 100644 index adddbe7b..00000000 --- a/qgepqwat2ili/qgep/import_.py.tpl +++ /dev/null @@ -1,875 +0,0 @@ -from sqlalchemy.orm import Session -from geoalchemy2.functions import ST_Transform, ST_Force2D - -from .. import utils - -from .model_qgep import get_qgep_model -from .model_abwasser import get_abwasser_model - - -def qgep_import(): - - QGEP = get_qgep_model() - ABWASSER = get_abwasser_model() - - abwasser_session = Session(utils.sqlalchemy.create_engine(), autocommit=False, autoflush=False) - qgep_session = Session(utils.sqlalchemy.create_engine(), autocommit=False, autoflush=False) - - print("Importing ABWASSER.organisation, ABWASSER.metaattribute -> QGEP.organisation") - for row, metaattribute in abwasser_session.query(ABWASSER.organisation, ABWASSER.metaattribute).join(ABWASSER.metaattribute): - - # baseclass --- organisation.t_ili_tid, organisation.t_type - # sia405_baseclass --- organisation.obj_id - # organisation --- organisation.auid, organisation.bemerkung, organisation.bezeichnung, organisation.t_id - - # metaattribute --- metaattribute.datenherr, metaattribute.datenlieferant, metaattribute.letzte_aenderung, metaattribute.sia405_baseclass_metaattribute, metaattribute.t_id, metaattribute.t_ili_tid, metaattribute.t_seq - # _rel_ --- metaattribute.sia405_baseclass_metaattribute__REL - - organisation = QGEP.organisation( - - # --- organisation --- - # fk_dataowner=row.REPLACE_ME, # VARCHAR(16) - # fk_provider=row.REPLACE_ME, # VARCHAR(16) - # identifier=row.REPLACE_ME, # VARCHAR(80) - # last_modification=row.REPLACE_ME, # TIMESTAMP WITHOUT TIME ZONE - # obj_id=row.REPLACE_ME, # VARCHAR(16) - # remark=row.REPLACE_ME, # VARCHAR(80) - # uid=row.REPLACE_ME, # VARCHAR(12) - ) - qgep_session.add(organisation) - print(".", end="") - print("done") - - print("Importing ABWASSER.kanal, ABWASSER.metaattribute -> QGEP.channel") - for row, metaattribute in abwasser_session.query(ABWASSER.kanal, ABWASSER.metaattribute).join(ABWASSER.metaattribute): - - # baseclass --- kanal.t_ili_tid, kanal.t_type - # sia405_baseclass --- kanal.obj_id - # abwasserbauwerk --- kanal.akten, kanal.astatus, kanal.baujahr, kanal.baulicherzustand, kanal.baulos, kanal.bemerkung, kanal.betreiberref, kanal.bezeichnung, kanal.bruttokosten, kanal.detailgeometrie, kanal.eigentuemerref, kanal.ersatzjahr, kanal.finanzierung, kanal.inspektionsintervall, kanal.sanierungsbedarf, kanal.standortname, kanal.subventionen, kanal.wbw_basisjahr, kanal.wbw_bauart, kanal.wiederbeschaffungswert, kanal.zugaenglichkeit - # kanal --- kanal.bettung_umhuellung, kanal.funktionhierarchisch, kanal.funktionhydraulisch, kanal.nutzungsart_geplant, kanal.nutzungsart_ist, kanal.rohrlaenge, kanal.spuelintervall, kanal.t_id, kanal.verbindungsart - # _bwrel_ --- kanal.abwassernetzelement__BWREL_abwasserbauwerkref, kanal.bauwerksteil__BWREL_abwasserbauwerkref, kanal.erhaltungsereignis__BWREL_abwasserbauwerkref, kanal.haltung_alternativverlauf__BWREL_t_id, kanal.metaattribute__BWREL_sia405_baseclass_metaattribute, kanal.sia405_symbolpos__BWREL_abwasserbauwerkref, kanal.sia405_textpos__BWREL_abwasserbauwerkref, kanal.symbolpos__BWREL_t_id, kanal.textpos__BWREL_t_id - # _rel_ --- kanal.betreiberref__REL, kanal.eigentuemerref__REL - - # metaattribute --- metaattribute.datenherr, metaattribute.datenlieferant, metaattribute.letzte_aenderung, metaattribute.sia405_baseclass_metaattribute, metaattribute.t_id, metaattribute.t_ili_tid, metaattribute.t_seq - # _rel_ --- metaattribute.sia405_baseclass_metaattribute__REL - - channel = QGEP.channel( - - # --- wastewater_structure --- - # _bottom_label=row.REPLACE_ME, # TEXT - # _cover_label=row.REPLACE_ME, # TEXT - # _depth=row.REPLACE_ME, # NUMERIC(6, 3) - # _function_hierarchic=row.REPLACE_ME, # INTEGER - # _input_label=row.REPLACE_ME, # TEXT - # _label=row.REPLACE_ME, # TEXT - # _output_label=row.REPLACE_ME, # TEXT - # _usage_current=row.REPLACE_ME, # INTEGER - # accessibility=row.REPLACE_ME, # INTEGER - # contract_section=row.REPLACE_ME, # VARCHAR(50) - # detail_geometry_geometry=row.REPLACE_ME, # geometry(CURVEPOLYGONZ,2056) - # financing=row.REPLACE_ME, # INTEGER - # fk_dataowner=row.REPLACE_ME, # VARCHAR(16) - # fk_main_cover=row.REPLACE_ME, # VARCHAR(16) - # fk_main_wastewater_node=row.REPLACE_ME, # VARCHAR(16) - # fk_operator=row.REPLACE_ME, # VARCHAR(16) - # fk_owner=row.REPLACE_ME, # VARCHAR(16) - # fk_provider=row.REPLACE_ME, # VARCHAR(16) - # gross_costs=row.REPLACE_ME, # NUMERIC(10, 2) - # identifier=row.REPLACE_ME, # VARCHAR(20) - # inspection_interval=row.REPLACE_ME, # NUMERIC(4, 2) - # last_modification=row.REPLACE_ME, # TIMESTAMP WITHOUT TIME ZONE - # location_name=row.REPLACE_ME, # VARCHAR(50) - # records=row.REPLACE_ME, # VARCHAR(255) - # remark=row.REPLACE_ME, # VARCHAR(80) - # renovation_necessity=row.REPLACE_ME, # INTEGER - # replacement_value=row.REPLACE_ME, # NUMERIC(10, 2) - # rv_base_year=row.REPLACE_ME, # SMALLINT - # rv_construction_type=row.REPLACE_ME, # INTEGER - # status=row.REPLACE_ME, # INTEGER - # structure_condition=row.REPLACE_ME, # INTEGER - # subsidies=row.REPLACE_ME, # NUMERIC(10, 2) - # year_of_construction=row.REPLACE_ME, # SMALLINT - # year_of_replacement=row.REPLACE_ME, # SMALLINT - - # --- channel --- - # bedding_encasement=row.REPLACE_ME, # INTEGER - # connection_type=row.REPLACE_ME, # INTEGER - # function_hierarchic=row.REPLACE_ME, # INTEGER - # function_hydraulic=row.REPLACE_ME, # INTEGER - # jetting_interval=row.REPLACE_ME, # NUMERIC(4, 2) - # obj_id=row.REPLACE_ME, # VARCHAR(16) - # pipe_length=row.REPLACE_ME, # NUMERIC(7, 2) - # usage_current=row.REPLACE_ME, # INTEGER - # usage_planned=row.REPLACE_ME, # INTEGER - ) - qgep_session.add(channel) - print(".", end="") - print("done") - - print("Importing ABWASSER.normschacht, ABWASSER.metaattribute -> QGEP.manhole") - for row, metaattribute in abwasser_session.query(ABWASSER.normschacht, ABWASSER.metaattribute).join(ABWASSER.metaattribute): - - # baseclass --- normschacht.t_ili_tid, normschacht.t_type - # sia405_baseclass --- normschacht.obj_id - # abwasserbauwerk --- normschacht.akten, normschacht.astatus, normschacht.baujahr, normschacht.baulicherzustand, normschacht.baulos, normschacht.bemerkung, normschacht.betreiberref, normschacht.bezeichnung, normschacht.bruttokosten, normschacht.detailgeometrie, normschacht.eigentuemerref, normschacht.ersatzjahr, normschacht.finanzierung, normschacht.inspektionsintervall, normschacht.sanierungsbedarf, normschacht.standortname, normschacht.subventionen, normschacht.wbw_basisjahr, normschacht.wbw_bauart, normschacht.wiederbeschaffungswert, normschacht.zugaenglichkeit - # normschacht --- normschacht.dimension1, normschacht.dimension2, normschacht.funktion, normschacht.material, normschacht.oberflaechenzulauf, normschacht.t_id - # _bwrel_ --- normschacht.abwassernetzelement__BWREL_abwasserbauwerkref, normschacht.bauwerksteil__BWREL_abwasserbauwerkref, normschacht.erhaltungsereignis__BWREL_abwasserbauwerkref, normschacht.haltung_alternativverlauf__BWREL_t_id, normschacht.metaattribute__BWREL_sia405_baseclass_metaattribute, normschacht.sia405_symbolpos__BWREL_abwasserbauwerkref, normschacht.sia405_textpos__BWREL_abwasserbauwerkref, normschacht.symbolpos__BWREL_t_id, normschacht.textpos__BWREL_t_id - # _rel_ --- normschacht.betreiberref__REL, normschacht.eigentuemerref__REL - - # metaattribute --- metaattribute.datenherr, metaattribute.datenlieferant, metaattribute.letzte_aenderung, metaattribute.sia405_baseclass_metaattribute, metaattribute.t_id, metaattribute.t_ili_tid, metaattribute.t_seq - # _rel_ --- metaattribute.sia405_baseclass_metaattribute__REL - - manhole = QGEP.manhole( - - # --- wastewater_structure --- - # _bottom_label=row.REPLACE_ME, # TEXT - # _cover_label=row.REPLACE_ME, # TEXT - # _depth=row.REPLACE_ME, # NUMERIC(6, 3) - # _function_hierarchic=row.REPLACE_ME, # INTEGER - # _input_label=row.REPLACE_ME, # TEXT - # _label=row.REPLACE_ME, # TEXT - # _output_label=row.REPLACE_ME, # TEXT - # _usage_current=row.REPLACE_ME, # INTEGER - # accessibility=row.REPLACE_ME, # INTEGER - # contract_section=row.REPLACE_ME, # VARCHAR(50) - # detail_geometry_geometry=row.REPLACE_ME, # geometry(CURVEPOLYGONZ,2056) - # financing=row.REPLACE_ME, # INTEGER - # fk_dataowner=row.REPLACE_ME, # VARCHAR(16) - # fk_main_cover=row.REPLACE_ME, # VARCHAR(16) - # fk_main_wastewater_node=row.REPLACE_ME, # VARCHAR(16) - # fk_operator=row.REPLACE_ME, # VARCHAR(16) - # fk_owner=row.REPLACE_ME, # VARCHAR(16) - # fk_provider=row.REPLACE_ME, # VARCHAR(16) - # gross_costs=row.REPLACE_ME, # NUMERIC(10, 2) - # identifier=row.REPLACE_ME, # VARCHAR(20) - # inspection_interval=row.REPLACE_ME, # NUMERIC(4, 2) - # last_modification=row.REPLACE_ME, # TIMESTAMP WITHOUT TIME ZONE - # location_name=row.REPLACE_ME, # VARCHAR(50) - # records=row.REPLACE_ME, # VARCHAR(255) - # remark=row.REPLACE_ME, # VARCHAR(80) - # renovation_necessity=row.REPLACE_ME, # INTEGER - # replacement_value=row.REPLACE_ME, # NUMERIC(10, 2) - # rv_base_year=row.REPLACE_ME, # SMALLINT - # rv_construction_type=row.REPLACE_ME, # INTEGER - # status=row.REPLACE_ME, # INTEGER - # structure_condition=row.REPLACE_ME, # INTEGER - # subsidies=row.REPLACE_ME, # NUMERIC(10, 2) - # year_of_construction=row.REPLACE_ME, # SMALLINT - # year_of_replacement=row.REPLACE_ME, # SMALLINT - - # --- manhole --- - # _orientation=row.REPLACE_ME, # NUMERIC - # dimension1=row.REPLACE_ME, # SMALLINT - # dimension2=row.REPLACE_ME, # SMALLINT - # function=row.REPLACE_ME, # INTEGER - # material=row.REPLACE_ME, # INTEGER - # obj_id=row.REPLACE_ME, # VARCHAR(16) - # surface_inflow=row.REPLACE_ME, # INTEGER - ) - qgep_session.add(manhole) - print(".", end="") - print("done") - - print("Importing ABWASSER.einleitstelle, ABWASSER.metaattribute -> QGEP.discharge_point") - for row, metaattribute in abwasser_session.query(ABWASSER.einleitstelle, ABWASSER.metaattribute).join(ABWASSER.metaattribute): - - # baseclass --- einleitstelle.t_ili_tid, einleitstelle.t_type - # sia405_baseclass --- einleitstelle.obj_id - # abwasserbauwerk --- einleitstelle.akten, einleitstelle.astatus, einleitstelle.baujahr, einleitstelle.baulicherzustand, einleitstelle.baulos, einleitstelle.bemerkung, einleitstelle.betreiberref, einleitstelle.bezeichnung, einleitstelle.bruttokosten, einleitstelle.detailgeometrie, einleitstelle.eigentuemerref, einleitstelle.ersatzjahr, einleitstelle.finanzierung, einleitstelle.inspektionsintervall, einleitstelle.sanierungsbedarf, einleitstelle.standortname, einleitstelle.subventionen, einleitstelle.wbw_basisjahr, einleitstelle.wbw_bauart, einleitstelle.wiederbeschaffungswert, einleitstelle.zugaenglichkeit - # einleitstelle --- einleitstelle.hochwasserkote, einleitstelle.relevanz, einleitstelle.t_id, einleitstelle.terrainkote, einleitstelle.wasserspiegel_hydraulik - # _bwrel_ --- einleitstelle.abwassernetzelement__BWREL_abwasserbauwerkref, einleitstelle.bauwerksteil__BWREL_abwasserbauwerkref, einleitstelle.erhaltungsereignis__BWREL_abwasserbauwerkref, einleitstelle.haltung_alternativverlauf__BWREL_t_id, einleitstelle.metaattribute__BWREL_sia405_baseclass_metaattribute, einleitstelle.sia405_symbolpos__BWREL_abwasserbauwerkref, einleitstelle.sia405_textpos__BWREL_abwasserbauwerkref, einleitstelle.symbolpos__BWREL_t_id, einleitstelle.textpos__BWREL_t_id - # _rel_ --- einleitstelle.betreiberref__REL, einleitstelle.eigentuemerref__REL - - # metaattribute --- metaattribute.datenherr, metaattribute.datenlieferant, metaattribute.letzte_aenderung, metaattribute.sia405_baseclass_metaattribute, metaattribute.t_id, metaattribute.t_ili_tid, metaattribute.t_seq - # _rel_ --- metaattribute.sia405_baseclass_metaattribute__REL - - discharge_point = QGEP.discharge_point( - - # --- wastewater_structure --- - # _bottom_label=row.REPLACE_ME, # TEXT - # _cover_label=row.REPLACE_ME, # TEXT - # _depth=row.REPLACE_ME, # NUMERIC(6, 3) - # _function_hierarchic=row.REPLACE_ME, # INTEGER - # _input_label=row.REPLACE_ME, # TEXT - # _label=row.REPLACE_ME, # TEXT - # _output_label=row.REPLACE_ME, # TEXT - # _usage_current=row.REPLACE_ME, # INTEGER - # accessibility=row.REPLACE_ME, # INTEGER - # contract_section=row.REPLACE_ME, # VARCHAR(50) - # detail_geometry_geometry=row.REPLACE_ME, # geometry(CURVEPOLYGONZ,2056) - # financing=row.REPLACE_ME, # INTEGER - # fk_dataowner=row.REPLACE_ME, # VARCHAR(16) - # fk_main_cover=row.REPLACE_ME, # VARCHAR(16) - # fk_main_wastewater_node=row.REPLACE_ME, # VARCHAR(16) - # fk_operator=row.REPLACE_ME, # VARCHAR(16) - # fk_owner=row.REPLACE_ME, # VARCHAR(16) - # fk_provider=row.REPLACE_ME, # VARCHAR(16) - # gross_costs=row.REPLACE_ME, # NUMERIC(10, 2) - # identifier=row.REPLACE_ME, # VARCHAR(20) - # inspection_interval=row.REPLACE_ME, # NUMERIC(4, 2) - # last_modification=row.REPLACE_ME, # TIMESTAMP WITHOUT TIME ZONE - # location_name=row.REPLACE_ME, # VARCHAR(50) - # records=row.REPLACE_ME, # VARCHAR(255) - # remark=row.REPLACE_ME, # VARCHAR(80) - # renovation_necessity=row.REPLACE_ME, # INTEGER - # replacement_value=row.REPLACE_ME, # NUMERIC(10, 2) - # rv_base_year=row.REPLACE_ME, # SMALLINT - # rv_construction_type=row.REPLACE_ME, # INTEGER - # status=row.REPLACE_ME, # INTEGER - # structure_condition=row.REPLACE_ME, # INTEGER - # subsidies=row.REPLACE_ME, # NUMERIC(10, 2) - # year_of_construction=row.REPLACE_ME, # SMALLINT - # year_of_replacement=row.REPLACE_ME, # SMALLINT - - # --- discharge_point --- - # fk_sector_water_body=row.REPLACE_ME, # VARCHAR(16) - # highwater_level=row.REPLACE_ME, # NUMERIC(7, 3) - # obj_id=row.REPLACE_ME, # VARCHAR(16) - # relevance=row.REPLACE_ME, # INTEGER - # terrain_level=row.REPLACE_ME, # NUMERIC(7, 3) - # upper_elevation=row.REPLACE_ME, # NUMERIC(7, 3) - # waterlevel_hydraulic=row.REPLACE_ME, # NUMERIC(7, 3) - ) - qgep_session.add(discharge_point) - print(".", end="") - print("done") - - print("Importing ABWASSER.spezialbauwerk, ABWASSER.metaattribute -> QGEP.special_structure") - for row, metaattribute in abwasser_session.query(ABWASSER.spezialbauwerk, ABWASSER.metaattribute).join(ABWASSER.metaattribute): - - # baseclass --- spezialbauwerk.t_ili_tid, spezialbauwerk.t_type - # sia405_baseclass --- spezialbauwerk.obj_id - # abwasserbauwerk --- spezialbauwerk.akten, spezialbauwerk.astatus, spezialbauwerk.baujahr, spezialbauwerk.baulicherzustand, spezialbauwerk.baulos, spezialbauwerk.bemerkung, spezialbauwerk.betreiberref, spezialbauwerk.bezeichnung, spezialbauwerk.bruttokosten, spezialbauwerk.detailgeometrie, spezialbauwerk.eigentuemerref, spezialbauwerk.ersatzjahr, spezialbauwerk.finanzierung, spezialbauwerk.inspektionsintervall, spezialbauwerk.sanierungsbedarf, spezialbauwerk.standortname, spezialbauwerk.subventionen, spezialbauwerk.wbw_basisjahr, spezialbauwerk.wbw_bauart, spezialbauwerk.wiederbeschaffungswert, spezialbauwerk.zugaenglichkeit - # spezialbauwerk --- spezialbauwerk.bypass, spezialbauwerk.funktion, spezialbauwerk.notueberlauf, spezialbauwerk.regenbecken_anordnung, spezialbauwerk.t_id - # _bwrel_ --- spezialbauwerk.abwassernetzelement__BWREL_abwasserbauwerkref, spezialbauwerk.bauwerksteil__BWREL_abwasserbauwerkref, spezialbauwerk.erhaltungsereignis__BWREL_abwasserbauwerkref, spezialbauwerk.haltung_alternativverlauf__BWREL_t_id, spezialbauwerk.metaattribute__BWREL_sia405_baseclass_metaattribute, spezialbauwerk.sia405_symbolpos__BWREL_abwasserbauwerkref, spezialbauwerk.sia405_textpos__BWREL_abwasserbauwerkref, spezialbauwerk.symbolpos__BWREL_t_id, spezialbauwerk.textpos__BWREL_t_id - # _rel_ --- spezialbauwerk.betreiberref__REL, spezialbauwerk.eigentuemerref__REL - - # metaattribute --- metaattribute.datenherr, metaattribute.datenlieferant, metaattribute.letzte_aenderung, metaattribute.sia405_baseclass_metaattribute, metaattribute.t_id, metaattribute.t_ili_tid, metaattribute.t_seq - # _rel_ --- metaattribute.sia405_baseclass_metaattribute__REL - - special_structure = QGEP.special_structure( - - # --- wastewater_structure --- - # _bottom_label=row.REPLACE_ME, # TEXT - # _cover_label=row.REPLACE_ME, # TEXT - # _depth=row.REPLACE_ME, # NUMERIC(6, 3) - # _function_hierarchic=row.REPLACE_ME, # INTEGER - # _input_label=row.REPLACE_ME, # TEXT - # _label=row.REPLACE_ME, # TEXT - # _output_label=row.REPLACE_ME, # TEXT - # _usage_current=row.REPLACE_ME, # INTEGER - # accessibility=row.REPLACE_ME, # INTEGER - # contract_section=row.REPLACE_ME, # VARCHAR(50) - # detail_geometry_geometry=row.REPLACE_ME, # geometry(CURVEPOLYGONZ,2056) - # financing=row.REPLACE_ME, # INTEGER - # fk_dataowner=row.REPLACE_ME, # VARCHAR(16) - # fk_main_cover=row.REPLACE_ME, # VARCHAR(16) - # fk_main_wastewater_node=row.REPLACE_ME, # VARCHAR(16) - # fk_operator=row.REPLACE_ME, # VARCHAR(16) - # fk_owner=row.REPLACE_ME, # VARCHAR(16) - # fk_provider=row.REPLACE_ME, # VARCHAR(16) - # gross_costs=row.REPLACE_ME, # NUMERIC(10, 2) - # identifier=row.REPLACE_ME, # VARCHAR(20) - # inspection_interval=row.REPLACE_ME, # NUMERIC(4, 2) - # last_modification=row.REPLACE_ME, # TIMESTAMP WITHOUT TIME ZONE - # location_name=row.REPLACE_ME, # VARCHAR(50) - # records=row.REPLACE_ME, # VARCHAR(255) - # remark=row.REPLACE_ME, # VARCHAR(80) - # renovation_necessity=row.REPLACE_ME, # INTEGER - # replacement_value=row.REPLACE_ME, # NUMERIC(10, 2) - # rv_base_year=row.REPLACE_ME, # SMALLINT - # rv_construction_type=row.REPLACE_ME, # INTEGER - # status=row.REPLACE_ME, # INTEGER - # structure_condition=row.REPLACE_ME, # INTEGER - # subsidies=row.REPLACE_ME, # NUMERIC(10, 2) - # year_of_construction=row.REPLACE_ME, # SMALLINT - # year_of_replacement=row.REPLACE_ME, # SMALLINT - - # --- special_structure --- - # bypass=row.REPLACE_ME, # INTEGER - # emergency_spillway=row.REPLACE_ME, # INTEGER - # function=row.REPLACE_ME, # INTEGER - # obj_id=row.REPLACE_ME, # VARCHAR(16) - # stormwater_tank_arrangement=row.REPLACE_ME, # INTEGER - # upper_elevation=row.REPLACE_ME, # NUMERIC(7, 3) - ) - qgep_session.add(special_structure) - print(".", end="") - print("done") - - print("Importing ABWASSER.versickerungsanlage, ABWASSER.metaattribute -> QGEP.infiltration_installation") - for row, metaattribute in abwasser_session.query(ABWASSER.versickerungsanlage, ABWASSER.metaattribute).join(ABWASSER.metaattribute): - - # baseclass --- versickerungsanlage.t_ili_tid, versickerungsanlage.t_type - # sia405_baseclass --- versickerungsanlage.obj_id - # abwasserbauwerk --- versickerungsanlage.akten, versickerungsanlage.astatus, versickerungsanlage.baujahr, versickerungsanlage.baulicherzustand, versickerungsanlage.baulos, versickerungsanlage.bemerkung, versickerungsanlage.betreiberref, versickerungsanlage.bezeichnung, versickerungsanlage.bruttokosten, versickerungsanlage.detailgeometrie, versickerungsanlage.eigentuemerref, versickerungsanlage.ersatzjahr, versickerungsanlage.finanzierung, versickerungsanlage.inspektionsintervall, versickerungsanlage.sanierungsbedarf, versickerungsanlage.standortname, versickerungsanlage.subventionen, versickerungsanlage.wbw_basisjahr, versickerungsanlage.wbw_bauart, versickerungsanlage.wiederbeschaffungswert, versickerungsanlage.zugaenglichkeit - # versickerungsanlage --- versickerungsanlage.art, versickerungsanlage.beschriftung, versickerungsanlage.dimension1, versickerungsanlage.dimension2, versickerungsanlage.gwdistanz, versickerungsanlage.maengel, versickerungsanlage.notueberlauf, versickerungsanlage.saugwagen, versickerungsanlage.schluckvermoegen, versickerungsanlage.t_id, versickerungsanlage.versickerungswasser, versickerungsanlage.wasserdichtheit, versickerungsanlage.wirksameflaeche - # _bwrel_ --- versickerungsanlage.abwassernetzelement__BWREL_abwasserbauwerkref, versickerungsanlage.bauwerksteil__BWREL_abwasserbauwerkref, versickerungsanlage.erhaltungsereignis__BWREL_abwasserbauwerkref, versickerungsanlage.haltung_alternativverlauf__BWREL_t_id, versickerungsanlage.metaattribute__BWREL_sia405_baseclass_metaattribute, versickerungsanlage.sia405_symbolpos__BWREL_abwasserbauwerkref, versickerungsanlage.sia405_textpos__BWREL_abwasserbauwerkref, versickerungsanlage.symbolpos__BWREL_t_id, versickerungsanlage.textpos__BWREL_t_id - # _rel_ --- versickerungsanlage.betreiberref__REL, versickerungsanlage.eigentuemerref__REL - - # metaattribute --- metaattribute.datenherr, metaattribute.datenlieferant, metaattribute.letzte_aenderung, metaattribute.sia405_baseclass_metaattribute, metaattribute.t_id, metaattribute.t_ili_tid, metaattribute.t_seq - # _rel_ --- metaattribute.sia405_baseclass_metaattribute__REL - - infiltration_installation = QGEP.infiltration_installation( - - # --- wastewater_structure --- - # _bottom_label=row.REPLACE_ME, # TEXT - # _cover_label=row.REPLACE_ME, # TEXT - # _depth=row.REPLACE_ME, # NUMERIC(6, 3) - # _function_hierarchic=row.REPLACE_ME, # INTEGER - # _input_label=row.REPLACE_ME, # TEXT - # _label=row.REPLACE_ME, # TEXT - # _output_label=row.REPLACE_ME, # TEXT - # _usage_current=row.REPLACE_ME, # INTEGER - # accessibility=row.REPLACE_ME, # INTEGER - # contract_section=row.REPLACE_ME, # VARCHAR(50) - # detail_geometry_geometry=row.REPLACE_ME, # geometry(CURVEPOLYGONZ,2056) - # financing=row.REPLACE_ME, # INTEGER - # fk_dataowner=row.REPLACE_ME, # VARCHAR(16) - # fk_main_cover=row.REPLACE_ME, # VARCHAR(16) - # fk_main_wastewater_node=row.REPLACE_ME, # VARCHAR(16) - # fk_operator=row.REPLACE_ME, # VARCHAR(16) - # fk_owner=row.REPLACE_ME, # VARCHAR(16) - # fk_provider=row.REPLACE_ME, # VARCHAR(16) - # gross_costs=row.REPLACE_ME, # NUMERIC(10, 2) - # identifier=row.REPLACE_ME, # VARCHAR(20) - # inspection_interval=row.REPLACE_ME, # NUMERIC(4, 2) - # last_modification=row.REPLACE_ME, # TIMESTAMP WITHOUT TIME ZONE - # location_name=row.REPLACE_ME, # VARCHAR(50) - # records=row.REPLACE_ME, # VARCHAR(255) - # remark=row.REPLACE_ME, # VARCHAR(80) - # renovation_necessity=row.REPLACE_ME, # INTEGER - # replacement_value=row.REPLACE_ME, # NUMERIC(10, 2) - # rv_base_year=row.REPLACE_ME, # SMALLINT - # rv_construction_type=row.REPLACE_ME, # INTEGER - # status=row.REPLACE_ME, # INTEGER - # structure_condition=row.REPLACE_ME, # INTEGER - # subsidies=row.REPLACE_ME, # NUMERIC(10, 2) - # year_of_construction=row.REPLACE_ME, # SMALLINT - # year_of_replacement=row.REPLACE_ME, # SMALLINT - - # --- infiltration_installation --- - # absorption_capacity=row.REPLACE_ME, # NUMERIC(9, 3) - # defects=row.REPLACE_ME, # INTEGER - # dimension1=row.REPLACE_ME, # SMALLINT - # dimension2=row.REPLACE_ME, # SMALLINT - # distance_to_aquifer=row.REPLACE_ME, # NUMERIC(7, 2) - # effective_area=row.REPLACE_ME, # NUMERIC(8, 2) - # emergency_spillway=row.REPLACE_ME, # INTEGER - # fk_aquifier=row.REPLACE_ME, # VARCHAR(16) - # kind=row.REPLACE_ME, # INTEGER - # labeling=row.REPLACE_ME, # INTEGER - # obj_id=row.REPLACE_ME, # VARCHAR(16) - # seepage_utilization=row.REPLACE_ME, # INTEGER - # upper_elevation=row.REPLACE_ME, # NUMERIC(7, 3) - # vehicle_access=row.REPLACE_ME, # INTEGER - # watertightness=row.REPLACE_ME, # INTEGER - ) - qgep_session.add(infiltration_installation) - print(".", end="") - print("done") - - print("Importing ABWASSER.rohrprofil, ABWASSER.metaattribute -> QGEP.pipe_profile") - for row, metaattribute in abwasser_session.query(ABWASSER.rohrprofil, ABWASSER.metaattribute).join(ABWASSER.metaattribute): - - # baseclass --- rohrprofil.t_ili_tid, rohrprofil.t_type - # sia405_baseclass --- rohrprofil.obj_id - # rohrprofil --- rohrprofil.bemerkung, rohrprofil.bezeichnung, rohrprofil.hoehenbreitenverhaeltnis, rohrprofil.profiltyp, rohrprofil.t_id - # _bwrel_ --- rohrprofil.haltung__BWREL_rohrprofilref, rohrprofil.haltung_alternativverlauf__BWREL_t_id, rohrprofil.metaattribute__BWREL_sia405_baseclass_metaattribute, rohrprofil.symbolpos__BWREL_t_id, rohrprofil.textpos__BWREL_t_id - - # metaattribute --- metaattribute.datenherr, metaattribute.datenlieferant, metaattribute.letzte_aenderung, metaattribute.sia405_baseclass_metaattribute, metaattribute.t_id, metaattribute.t_ili_tid, metaattribute.t_seq - # _rel_ --- metaattribute.sia405_baseclass_metaattribute__REL - - pipe_profile = QGEP.pipe_profile( - - # --- pipe_profile --- - # fk_dataowner=row.REPLACE_ME, # VARCHAR(16) - # fk_provider=row.REPLACE_ME, # VARCHAR(16) - # height_width_ratio=row.REPLACE_ME, # NUMERIC(5, 2) - # identifier=row.REPLACE_ME, # VARCHAR(20) - # last_modification=row.REPLACE_ME, # TIMESTAMP WITHOUT TIME ZONE - # obj_id=row.REPLACE_ME, # VARCHAR(16) - # profile_type=row.REPLACE_ME, # INTEGER - # remark=row.REPLACE_ME, # VARCHAR(80) - ) - qgep_session.add(pipe_profile) - print(".", end="") - print("done") - - print("Importing ABWASSER.haltungspunkt, ABWASSER.metaattribute -> QGEP.reach_point") - for row, metaattribute in abwasser_session.query(ABWASSER.haltungspunkt, ABWASSER.metaattribute).join(ABWASSER.metaattribute): - - # baseclass --- haltungspunkt.t_ili_tid, haltungspunkt.t_type - # sia405_baseclass --- haltungspunkt.obj_id - # haltungspunkt --- haltungspunkt.abwassernetzelementref, haltungspunkt.auslaufform, haltungspunkt.bemerkung, haltungspunkt.bezeichnung, haltungspunkt.hoehengenauigkeit, haltungspunkt.kote, haltungspunkt.lage, haltungspunkt.lage_anschluss, haltungspunkt.t_id - # _bwrel_ --- haltungspunkt.haltung__BWREL_nachhaltungspunktref, haltungspunkt.haltung__BWREL_vonhaltungspunktref, haltungspunkt.haltung_alternativverlauf__BWREL_t_id, haltungspunkt.metaattribute__BWREL_sia405_baseclass_metaattribute, haltungspunkt.symbolpos__BWREL_t_id, haltungspunkt.textpos__BWREL_t_id, haltungspunkt.untersuchung__BWREL_haltungspunktref - # _rel_ --- haltungspunkt.abwassernetzelementref__REL - - # metaattribute --- metaattribute.datenherr, metaattribute.datenlieferant, metaattribute.letzte_aenderung, metaattribute.sia405_baseclass_metaattribute, metaattribute.t_id, metaattribute.t_ili_tid, metaattribute.t_seq - # _rel_ --- metaattribute.sia405_baseclass_metaattribute__REL - - reach_point = QGEP.reach_point( - - # --- reach_point --- - # elevation_accuracy=row.REPLACE_ME, # INTEGER - # fk_dataowner=row.REPLACE_ME, # VARCHAR(16) - # fk_provider=row.REPLACE_ME, # VARCHAR(16) - # fk_wastewater_networkelement=row.REPLACE_ME, # VARCHAR(16) - # identifier=row.REPLACE_ME, # VARCHAR(20) - # last_modification=row.REPLACE_ME, # TIMESTAMP WITHOUT TIME ZONE - # level=row.REPLACE_ME, # NUMERIC(7, 3) - # obj_id=row.REPLACE_ME, # VARCHAR(16) - # outlet_shape=row.REPLACE_ME, # INTEGER - # position_of_connection=row.REPLACE_ME, # SMALLINT - # remark=row.REPLACE_ME, # VARCHAR(80) - # situation_geometry=row.REPLACE_ME, # geometry(POINTZ,2056) - ) - qgep_session.add(reach_point) - print(".", end="") - print("done") - - print("Importing ABWASSER.abwasserknoten, ABWASSER.metaattribute -> QGEP.wastewater_node") - for row, metaattribute in abwasser_session.query(ABWASSER.abwasserknoten, ABWASSER.metaattribute).join(ABWASSER.metaattribute): - - # baseclass --- abwasserknoten.t_ili_tid, abwasserknoten.t_type - # sia405_baseclass --- abwasserknoten.obj_id - # abwassernetzelement --- abwasserknoten.abwasserbauwerkref, abwasserknoten.bemerkung, abwasserknoten.bezeichnung - # abwasserknoten --- abwasserknoten.lage, abwasserknoten.rueckstaukote, abwasserknoten.sohlenkote, abwasserknoten.t_id - # _bwrel_ --- abwasserknoten.haltung_alternativverlauf__BWREL_t_id, abwasserknoten.haltungspunkt__BWREL_abwassernetzelementref, abwasserknoten.metaattribute__BWREL_sia405_baseclass_metaattribute, abwasserknoten.symbolpos__BWREL_t_id, abwasserknoten.textpos__BWREL_t_id - # _rel_ --- abwasserknoten.abwasserbauwerkref__REL - - # metaattribute --- metaattribute.datenherr, metaattribute.datenlieferant, metaattribute.letzte_aenderung, metaattribute.sia405_baseclass_metaattribute, metaattribute.t_id, metaattribute.t_ili_tid, metaattribute.t_seq - # _rel_ --- metaattribute.sia405_baseclass_metaattribute__REL - - wastewater_node = QGEP.wastewater_node( - - # --- wastewater_networkelement --- - # fk_dataowner=row.REPLACE_ME, # VARCHAR(16) - # fk_provider=row.REPLACE_ME, # VARCHAR(16) - # fk_wastewater_structure=row.REPLACE_ME, # VARCHAR(16) - # identifier=row.REPLACE_ME, # VARCHAR(20) - # last_modification=row.REPLACE_ME, # TIMESTAMP WITHOUT TIME ZONE - # remark=row.REPLACE_ME, # VARCHAR(80) - - # --- wastewater_node --- - # backflow_level=row.REPLACE_ME, # NUMERIC(7, 3) - # bottom_level=row.REPLACE_ME, # NUMERIC(7, 3) - # fk_hydr_geometry=row.REPLACE_ME, # VARCHAR(16) - # obj_id=row.REPLACE_ME, # VARCHAR(16) - # situation_geometry=row.REPLACE_ME, # geometry(POINTZ,2056) - ) - qgep_session.add(wastewater_node) - print(".", end="") - print("done") - - print("Importing ABWASSER.haltung, ABWASSER.metaattribute -> QGEP.reach") - for row, metaattribute in abwasser_session.query(ABWASSER.haltung, ABWASSER.metaattribute).join(ABWASSER.metaattribute): - - # baseclass --- haltung.t_ili_tid, haltung.t_type - # sia405_baseclass --- haltung.obj_id - # abwassernetzelement --- haltung.abwasserbauwerkref, haltung.bemerkung, haltung.bezeichnung - # haltung --- haltung.innenschutz, haltung.laengeeffektiv, haltung.lagebestimmung, haltung.lichte_hoehe, haltung.material, haltung.nachhaltungspunktref, haltung.plangefaelle, haltung.reibungsbeiwert, haltung.reliner_art, haltung.reliner_bautechnik, haltung.reliner_material, haltung.reliner_nennweite, haltung.ringsteifigkeit, haltung.rohrprofilref, haltung.t_id, haltung.verlauf, haltung.vonhaltungspunktref, haltung.wandrauhigkeit - # _bwrel_ --- haltung.haltung_alternativverlauf__BWREL_haltungref, haltung.haltung_alternativverlauf__BWREL_t_id, haltung.haltungspunkt__BWREL_abwassernetzelementref, haltung.metaattribute__BWREL_sia405_baseclass_metaattribute, haltung.sia405_textpos__BWREL_haltungref, haltung.symbolpos__BWREL_t_id, haltung.textpos__BWREL_t_id - # _rel_ --- haltung.abwasserbauwerkref__REL, haltung.nachhaltungspunktref__REL, haltung.rohrprofilref__REL, haltung.vonhaltungspunktref__REL - - # metaattribute --- metaattribute.datenherr, metaattribute.datenlieferant, metaattribute.letzte_aenderung, metaattribute.sia405_baseclass_metaattribute, metaattribute.t_id, metaattribute.t_ili_tid, metaattribute.t_seq - # _rel_ --- metaattribute.sia405_baseclass_metaattribute__REL - - reach = QGEP.reach( - - # --- wastewater_networkelement --- - # fk_dataowner=row.REPLACE_ME, # VARCHAR(16) - # fk_provider=row.REPLACE_ME, # VARCHAR(16) - # fk_wastewater_structure=row.REPLACE_ME, # VARCHAR(16) - # identifier=row.REPLACE_ME, # VARCHAR(20) - # last_modification=row.REPLACE_ME, # TIMESTAMP WITHOUT TIME ZONE - # remark=row.REPLACE_ME, # VARCHAR(80) - - # --- reach --- - # clear_height=row.REPLACE_ME, # INTEGER - # coefficient_of_friction=row.REPLACE_ME, # SMALLINT - # elevation_determination=row.REPLACE_ME, # INTEGER - # fk_pipe_profile=row.REPLACE_ME, # VARCHAR(16) - # fk_reach_point_from=row.REPLACE_ME, # VARCHAR(16) - # fk_reach_point_to=row.REPLACE_ME, # VARCHAR(16) - # horizontal_positioning=row.REPLACE_ME, # INTEGER - # inside_coating=row.REPLACE_ME, # INTEGER - # length_effective=row.REPLACE_ME, # NUMERIC(7, 2) - # material=row.REPLACE_ME, # INTEGER - # obj_id=row.REPLACE_ME, # VARCHAR(16) - # progression_geometry=row.REPLACE_ME, # geometry(COMPOUNDCURVEZ,2056) - # reliner_material=row.REPLACE_ME, # INTEGER - # reliner_nominal_size=row.REPLACE_ME, # INTEGER - # relining_construction=row.REPLACE_ME, # INTEGER - # relining_kind=row.REPLACE_ME, # INTEGER - # ring_stiffness=row.REPLACE_ME, # SMALLINT - # slope_building_plan=row.REPLACE_ME, # SMALLINT - # wall_roughness=row.REPLACE_ME, # NUMERIC(5, 2) - ) - qgep_session.add(reach) - print(".", end="") - print("done") - - print("Importing ABWASSER.trockenwetterfallrohr, ABWASSER.metaattribute -> QGEP.dryweather_downspout") - for row, metaattribute in abwasser_session.query(ABWASSER.trockenwetterfallrohr, ABWASSER.metaattribute).join(ABWASSER.metaattribute): - - # baseclass --- trockenwetterfallrohr.t_ili_tid, trockenwetterfallrohr.t_type - # sia405_baseclass --- trockenwetterfallrohr.obj_id - # bauwerksteil --- trockenwetterfallrohr.abwasserbauwerkref, trockenwetterfallrohr.bemerkung, trockenwetterfallrohr.bezeichnung, trockenwetterfallrohr.instandstellung - # trockenwetterfallrohr --- trockenwetterfallrohr.durchmesser, trockenwetterfallrohr.t_id - # _bwrel_ --- trockenwetterfallrohr.haltung_alternativverlauf__BWREL_t_id, trockenwetterfallrohr.metaattribute__BWREL_sia405_baseclass_metaattribute, trockenwetterfallrohr.symbolpos__BWREL_t_id, trockenwetterfallrohr.textpos__BWREL_t_id - # _rel_ --- trockenwetterfallrohr.abwasserbauwerkref__REL - - # metaattribute --- metaattribute.datenherr, metaattribute.datenlieferant, metaattribute.letzte_aenderung, metaattribute.sia405_baseclass_metaattribute, metaattribute.t_id, metaattribute.t_ili_tid, metaattribute.t_seq - # _rel_ --- metaattribute.sia405_baseclass_metaattribute__REL - - dryweather_downspout = QGEP.dryweather_downspout( - - # --- structure_part --- - # fk_dataowner=row.REPLACE_ME, # VARCHAR(16) - # fk_provider=row.REPLACE_ME, # VARCHAR(16) - # fk_wastewater_structure=row.REPLACE_ME, # VARCHAR(16) - # identifier=row.REPLACE_ME, # VARCHAR(20) - # last_modification=row.REPLACE_ME, # TIMESTAMP WITHOUT TIME ZONE - # remark=row.REPLACE_ME, # VARCHAR(80) - # renovation_demand=row.REPLACE_ME, # INTEGER - - # --- dryweather_downspout --- - # diameter=row.REPLACE_ME, # SMALLINT - # obj_id=row.REPLACE_ME, # VARCHAR(16) - ) - qgep_session.add(dryweather_downspout) - print(".", end="") - print("done") - - print("Importing ABWASSER.einstiegshilfe, ABWASSER.metaattribute -> QGEP.access_aid") - for row, metaattribute in abwasser_session.query(ABWASSER.einstiegshilfe, ABWASSER.metaattribute).join(ABWASSER.metaattribute): - - # baseclass --- einstiegshilfe.t_ili_tid, einstiegshilfe.t_type - # sia405_baseclass --- einstiegshilfe.obj_id - # bauwerksteil --- einstiegshilfe.abwasserbauwerkref, einstiegshilfe.bemerkung, einstiegshilfe.bezeichnung, einstiegshilfe.instandstellung - # einstiegshilfe --- einstiegshilfe.art, einstiegshilfe.t_id - # _bwrel_ --- einstiegshilfe.haltung_alternativverlauf__BWREL_t_id, einstiegshilfe.metaattribute__BWREL_sia405_baseclass_metaattribute, einstiegshilfe.symbolpos__BWREL_t_id, einstiegshilfe.textpos__BWREL_t_id - # _rel_ --- einstiegshilfe.abwasserbauwerkref__REL - - # metaattribute --- metaattribute.datenherr, metaattribute.datenlieferant, metaattribute.letzte_aenderung, metaattribute.sia405_baseclass_metaattribute, metaattribute.t_id, metaattribute.t_ili_tid, metaattribute.t_seq - # _rel_ --- metaattribute.sia405_baseclass_metaattribute__REL - - access_aid = QGEP.access_aid( - - # --- structure_part --- - # fk_dataowner=row.REPLACE_ME, # VARCHAR(16) - # fk_provider=row.REPLACE_ME, # VARCHAR(16) - # fk_wastewater_structure=row.REPLACE_ME, # VARCHAR(16) - # identifier=row.REPLACE_ME, # VARCHAR(20) - # last_modification=row.REPLACE_ME, # TIMESTAMP WITHOUT TIME ZONE - # remark=row.REPLACE_ME, # VARCHAR(80) - # renovation_demand=row.REPLACE_ME, # INTEGER - - # --- access_aid --- - # kind=row.REPLACE_ME, # INTEGER - # obj_id=row.REPLACE_ME, # VARCHAR(16) - ) - qgep_session.add(access_aid) - print(".", end="") - print("done") - - print("Importing ABWASSER.trockenwetterrinne, ABWASSER.metaattribute -> QGEP.dryweather_flume") - for row, metaattribute in abwasser_session.query(ABWASSER.trockenwetterrinne, ABWASSER.metaattribute).join(ABWASSER.metaattribute): - - # baseclass --- trockenwetterrinne.t_ili_tid, trockenwetterrinne.t_type - # sia405_baseclass --- trockenwetterrinne.obj_id - # bauwerksteil --- trockenwetterrinne.abwasserbauwerkref, trockenwetterrinne.bemerkung, trockenwetterrinne.bezeichnung, trockenwetterrinne.instandstellung - # trockenwetterrinne --- trockenwetterrinne.material, trockenwetterrinne.t_id - # _bwrel_ --- trockenwetterrinne.haltung_alternativverlauf__BWREL_t_id, trockenwetterrinne.metaattribute__BWREL_sia405_baseclass_metaattribute, trockenwetterrinne.symbolpos__BWREL_t_id, trockenwetterrinne.textpos__BWREL_t_id - # _rel_ --- trockenwetterrinne.abwasserbauwerkref__REL - - # metaattribute --- metaattribute.datenherr, metaattribute.datenlieferant, metaattribute.letzte_aenderung, metaattribute.sia405_baseclass_metaattribute, metaattribute.t_id, metaattribute.t_ili_tid, metaattribute.t_seq - # _rel_ --- metaattribute.sia405_baseclass_metaattribute__REL - - dryweather_flume = QGEP.dryweather_flume( - - # --- structure_part --- - # fk_dataowner=row.REPLACE_ME, # VARCHAR(16) - # fk_provider=row.REPLACE_ME, # VARCHAR(16) - # fk_wastewater_structure=row.REPLACE_ME, # VARCHAR(16) - # identifier=row.REPLACE_ME, # VARCHAR(20) - # last_modification=row.REPLACE_ME, # TIMESTAMP WITHOUT TIME ZONE - # remark=row.REPLACE_ME, # VARCHAR(80) - # renovation_demand=row.REPLACE_ME, # INTEGER - - # --- dryweather_flume --- - # material=row.REPLACE_ME, # INTEGER - # obj_id=row.REPLACE_ME, # VARCHAR(16) - ) - qgep_session.add(dryweather_flume) - print(".", end="") - print("done") - - print("Importing ABWASSER.deckel, ABWASSER.metaattribute -> QGEP.cover") - for row, metaattribute in abwasser_session.query(ABWASSER.deckel, ABWASSER.metaattribute).join(ABWASSER.metaattribute): - - # baseclass --- deckel.t_ili_tid, deckel.t_type - # sia405_baseclass --- deckel.obj_id - # bauwerksteil --- deckel.abwasserbauwerkref, deckel.bemerkung, deckel.bezeichnung, deckel.instandstellung - # deckel --- deckel.deckelform, deckel.durchmesser, deckel.entlueftung, deckel.fabrikat, deckel.kote, deckel.lage, deckel.lagegenauigkeit, deckel.material, deckel.schlammeimer, deckel.t_id, deckel.verschluss - # _bwrel_ --- deckel.haltung_alternativverlauf__BWREL_t_id, deckel.metaattribute__BWREL_sia405_baseclass_metaattribute, deckel.symbolpos__BWREL_t_id, deckel.textpos__BWREL_t_id - # _rel_ --- deckel.abwasserbauwerkref__REL - - # metaattribute --- metaattribute.datenherr, metaattribute.datenlieferant, metaattribute.letzte_aenderung, metaattribute.sia405_baseclass_metaattribute, metaattribute.t_id, metaattribute.t_ili_tid, metaattribute.t_seq - # _rel_ --- metaattribute.sia405_baseclass_metaattribute__REL - - cover = QGEP.cover( - - # --- structure_part --- - # fk_dataowner=row.REPLACE_ME, # VARCHAR(16) - # fk_provider=row.REPLACE_ME, # VARCHAR(16) - # fk_wastewater_structure=row.REPLACE_ME, # VARCHAR(16) - # identifier=row.REPLACE_ME, # VARCHAR(20) - # last_modification=row.REPLACE_ME, # TIMESTAMP WITHOUT TIME ZONE - # remark=row.REPLACE_ME, # VARCHAR(80) - # renovation_demand=row.REPLACE_ME, # INTEGER - - # --- cover --- - # brand=row.REPLACE_ME, # VARCHAR(50) - # cover_shape=row.REPLACE_ME, # INTEGER - # diameter=row.REPLACE_ME, # SMALLINT - # fastening=row.REPLACE_ME, # INTEGER - # level=row.REPLACE_ME, # NUMERIC(7, 3) - # material=row.REPLACE_ME, # INTEGER - # obj_id=row.REPLACE_ME, # VARCHAR(16) - # positional_accuracy=row.REPLACE_ME, # INTEGER - # situation_geometry=row.REPLACE_ME, # geometry(POINTZ,2056) - # sludge_bucket=row.REPLACE_ME, # INTEGER - # venting=row.REPLACE_ME, # INTEGER - ) - qgep_session.add(cover) - print(".", end="") - print("done") - - print("Importing ABWASSER.bankett, ABWASSER.metaattribute -> QGEP.benching") - for row, metaattribute in abwasser_session.query(ABWASSER.bankett, ABWASSER.metaattribute).join(ABWASSER.metaattribute): - - # baseclass --- bankett.t_ili_tid, bankett.t_type - # sia405_baseclass --- bankett.obj_id - # bauwerksteil --- bankett.abwasserbauwerkref, bankett.bemerkung, bankett.bezeichnung, bankett.instandstellung - # bankett --- bankett.art, bankett.t_id - # _bwrel_ --- bankett.haltung_alternativverlauf__BWREL_t_id, bankett.metaattribute__BWREL_sia405_baseclass_metaattribute, bankett.symbolpos__BWREL_t_id, bankett.textpos__BWREL_t_id - # _rel_ --- bankett.abwasserbauwerkref__REL - - # metaattribute --- metaattribute.datenherr, metaattribute.datenlieferant, metaattribute.letzte_aenderung, metaattribute.sia405_baseclass_metaattribute, metaattribute.t_id, metaattribute.t_ili_tid, metaattribute.t_seq - # _rel_ --- metaattribute.sia405_baseclass_metaattribute__REL - - benching = QGEP.benching( - - # --- structure_part --- - # fk_dataowner=row.REPLACE_ME, # VARCHAR(16) - # fk_provider=row.REPLACE_ME, # VARCHAR(16) - # fk_wastewater_structure=row.REPLACE_ME, # VARCHAR(16) - # identifier=row.REPLACE_ME, # VARCHAR(20) - # last_modification=row.REPLACE_ME, # TIMESTAMP WITHOUT TIME ZONE - # remark=row.REPLACE_ME, # VARCHAR(80) - # renovation_demand=row.REPLACE_ME, # INTEGER - - # --- benching --- - # kind=row.REPLACE_ME, # INTEGER - # obj_id=row.REPLACE_ME, # VARCHAR(16) - ) - qgep_session.add(benching) - print(".", end="") - print("done") - - print("Importing ABWASSER.untersuchung, ABWASSER.metaattribute -> QGEP.examination") - for row, metaattribute in abwasser_session.query(ABWASSER.untersuchung, ABWASSER.metaattribute).join(ABWASSER.metaattribute): - - # baseclass --- untersuchung.t_ili_tid, untersuchung.t_type - # sia405_baseclass --- untersuchung.obj_id - # erhaltungsereignis --- untersuchung.abwasserbauwerkref, untersuchung.art, untersuchung.astatus, untersuchung.ausfuehrende_firmaref, untersuchung.ausfuehrender, untersuchung.bemerkung, untersuchung.bezeichnung, untersuchung.datengrundlage, untersuchung.dauer, untersuchung.detaildaten, untersuchung.ergebnis, untersuchung.grund, untersuchung.kosten, untersuchung.zeitpunkt - # untersuchung --- untersuchung.bispunktbezeichnung, untersuchung.erfassungsart, untersuchung.fahrzeug, untersuchung.geraet, untersuchung.haltungspunktref, untersuchung.inspizierte_laenge, untersuchung.t_id, untersuchung.videonummer, untersuchung.vonpunktbezeichnung, untersuchung.witterung - # _bwrel_ --- untersuchung.haltung_alternativverlauf__BWREL_t_id, untersuchung.metaattribute__BWREL_sia405_baseclass_metaattribute, untersuchung.schaden__BWREL_untersuchungref, untersuchung.symbolpos__BWREL_t_id, untersuchung.textpos__BWREL_t_id - # _rel_ --- untersuchung.abwasserbauwerkref__REL, untersuchung.ausfuehrende_firmaref__REL, untersuchung.haltungspunktref__REL - - # metaattribute --- metaattribute.datenherr, metaattribute.datenlieferant, metaattribute.letzte_aenderung, metaattribute.sia405_baseclass_metaattribute, metaattribute.t_id, metaattribute.t_ili_tid, metaattribute.t_seq - # _rel_ --- metaattribute.sia405_baseclass_metaattribute__REL - - examination = QGEP.examination( - - # --- maintenance_event --- - # active_zone=row.REPLACE_ME, # VARCHAR(1) - # base_data=row.REPLACE_ME, # TEXT - # cost=row.REPLACE_ME, # NUMERIC(10, 2) - # data_details=row.REPLACE_ME, # VARCHAR(50) - # duration=row.REPLACE_ME, # SMALLINT - # fk_dataowner=row.REPLACE_ME, # VARCHAR(16) - # fk_operating_company=row.REPLACE_ME, # VARCHAR(16) - # fk_provider=row.REPLACE_ME, # VARCHAR(16) - # identifier=row.REPLACE_ME, # VARCHAR(20) - # kind=row.REPLACE_ME, # INTEGER - # last_modification=row.REPLACE_ME, # TIMESTAMP WITHOUT TIME ZONE - # operator=row.REPLACE_ME, # VARCHAR(50) - # reason=row.REPLACE_ME, # VARCHAR(50) - # remark=row.REPLACE_ME, # VARCHAR(80) - # result=row.REPLACE_ME, # VARCHAR(50) - # status=row.REPLACE_ME, # INTEGER - # time_point=row.REPLACE_ME, # TIMESTAMP WITHOUT TIME ZONE - - # --- examination --- - # equipment=row.REPLACE_ME, # VARCHAR(50) - # fk_reach_point=row.REPLACE_ME, # VARCHAR(16) - # from_point_identifier=row.REPLACE_ME, # VARCHAR(41) - # inspected_length=row.REPLACE_ME, # NUMERIC(7, 2) - # obj_id=row.REPLACE_ME, # VARCHAR(16) - # recording_type=row.REPLACE_ME, # INTEGER - # to_point_identifier=row.REPLACE_ME, # VARCHAR(41) - # vehicle=row.REPLACE_ME, # VARCHAR(50) - # videonumber=row.REPLACE_ME, # VARCHAR(41) - # weather=row.REPLACE_ME, # INTEGER - ) - qgep_session.add(examination) - print(".", end="") - print("done") - - print("Importing ABWASSER.normschachtschaden, ABWASSER.metaattribute -> QGEP.damage_manhole") - for row, metaattribute in abwasser_session.query(ABWASSER.normschachtschaden, ABWASSER.metaattribute).join(ABWASSER.metaattribute): - - # baseclass --- normschachtschaden.t_ili_tid, normschachtschaden.t_type - # sia405_baseclass --- normschachtschaden.obj_id - # schaden --- normschachtschaden.anmerkung, normschachtschaden.ansichtsparameter, normschachtschaden.einzelschadenklasse, normschachtschaden.streckenschaden, normschachtschaden.untersuchungref, normschachtschaden.verbindung, normschachtschaden.videozaehlerstand - # normschachtschaden --- normschachtschaden.distanz, normschachtschaden.quantifizierung1, normschachtschaden.quantifizierung2, normschachtschaden.schachtbereich, normschachtschaden.schachtschadencode, normschachtschaden.schadenlageanfang, normschachtschaden.schadenlageende, normschachtschaden.t_id - # _bwrel_ --- normschachtschaden.haltung_alternativverlauf__BWREL_t_id, normschachtschaden.metaattribute__BWREL_sia405_baseclass_metaattribute, normschachtschaden.symbolpos__BWREL_t_id, normschachtschaden.textpos__BWREL_t_id - # _rel_ --- normschachtschaden.untersuchungref__REL - - # metaattribute --- metaattribute.datenherr, metaattribute.datenlieferant, metaattribute.letzte_aenderung, metaattribute.sia405_baseclass_metaattribute, metaattribute.t_id, metaattribute.t_ili_tid, metaattribute.t_seq - # _rel_ --- metaattribute.sia405_baseclass_metaattribute__REL - - damage_manhole = QGEP.damage_manhole( - - # --- damage --- - # comments=row.REPLACE_ME, # VARCHAR(100) - # connection=row.REPLACE_ME, # INTEGER - # damage_begin=row.REPLACE_ME, # SMALLINT - # damage_end=row.REPLACE_ME, # SMALLINT - # damage_reach=row.REPLACE_ME, # VARCHAR(3) - # distance=row.REPLACE_ME, # NUMERIC(7, 2) - # fk_dataowner=row.REPLACE_ME, # VARCHAR(16) - # fk_examination=row.REPLACE_ME, # VARCHAR(16) - # fk_provider=row.REPLACE_ME, # VARCHAR(16) - # last_modification=row.REPLACE_ME, # TIMESTAMP WITHOUT TIME ZONE - # quantification1=row.REPLACE_ME, # INTEGER - # quantification2=row.REPLACE_ME, # INTEGER - # single_damage_class=row.REPLACE_ME, # INTEGER - # video_counter=row.REPLACE_ME, # VARCHAR(11) - # view_parameters=row.REPLACE_ME, # VARCHAR(200) - - # --- damage_manhole --- - # manhole_damage_code=row.REPLACE_ME, # INTEGER - # manhole_shaft_area=row.REPLACE_ME, # INTEGER - # obj_id=row.REPLACE_ME, # VARCHAR(16) - ) - qgep_session.add(damage_manhole) - print(".", end="") - print("done") - - print("Importing ABWASSER.kanalschaden, ABWASSER.metaattribute -> QGEP.damage_channel") - for row, metaattribute in abwasser_session.query(ABWASSER.kanalschaden, ABWASSER.metaattribute).join(ABWASSER.metaattribute): - - # baseclass --- kanalschaden.t_ili_tid, kanalschaden.t_type - # sia405_baseclass --- kanalschaden.obj_id - # schaden --- kanalschaden.anmerkung, kanalschaden.ansichtsparameter, kanalschaden.einzelschadenklasse, kanalschaden.streckenschaden, kanalschaden.untersuchungref, kanalschaden.verbindung, kanalschaden.videozaehlerstand - # kanalschaden --- kanalschaden.distanz, kanalschaden.kanalschadencode, kanalschaden.quantifizierung1, kanalschaden.quantifizierung2, kanalschaden.schadenlageanfang, kanalschaden.schadenlageende, kanalschaden.t_id - # _bwrel_ --- kanalschaden.haltung_alternativverlauf__BWREL_t_id, kanalschaden.metaattribute__BWREL_sia405_baseclass_metaattribute, kanalschaden.symbolpos__BWREL_t_id, kanalschaden.textpos__BWREL_t_id - # _rel_ --- kanalschaden.untersuchungref__REL - - # metaattribute --- metaattribute.datenherr, metaattribute.datenlieferant, metaattribute.letzte_aenderung, metaattribute.sia405_baseclass_metaattribute, metaattribute.t_id, metaattribute.t_ili_tid, metaattribute.t_seq - # _rel_ --- metaattribute.sia405_baseclass_metaattribute__REL - - damage_channel = QGEP.damage_channel( - - # --- damage --- - # comments=row.REPLACE_ME, # VARCHAR(100) - # connection=row.REPLACE_ME, # INTEGER - # damage_begin=row.REPLACE_ME, # SMALLINT - # damage_end=row.REPLACE_ME, # SMALLINT - # damage_reach=row.REPLACE_ME, # VARCHAR(3) - # distance=row.REPLACE_ME, # NUMERIC(7, 2) - # fk_dataowner=row.REPLACE_ME, # VARCHAR(16) - # fk_examination=row.REPLACE_ME, # VARCHAR(16) - # fk_provider=row.REPLACE_ME, # VARCHAR(16) - # last_modification=row.REPLACE_ME, # TIMESTAMP WITHOUT TIME ZONE - # quantification1=row.REPLACE_ME, # INTEGER - # quantification2=row.REPLACE_ME, # INTEGER - # single_damage_class=row.REPLACE_ME, # INTEGER - # video_counter=row.REPLACE_ME, # VARCHAR(11) - # view_parameters=row.REPLACE_ME, # VARCHAR(200) - - # --- damage_channel --- - # channel_damage_code=row.REPLACE_ME, # INTEGER - # obj_id=row.REPLACE_ME, # VARCHAR(16) - ) - qgep_session.add(damage_channel) - print(".", end="") - print("done") - - print("Importing ABWASSER.datentraeger, ABWASSER.metaattribute -> QGEP.data_media") - for row, metaattribute in abwasser_session.query(ABWASSER.datentraeger, ABWASSER.metaattribute).join(ABWASSER.metaattribute): - - # baseclass --- datentraeger.t_ili_tid, datentraeger.t_type - # sia405_baseclass --- datentraeger.obj_id - # datentraeger --- datentraeger.art, datentraeger.bemerkung, datentraeger.bezeichnung, datentraeger.pfad, datentraeger.standort, datentraeger.t_id - # _bwrel_ --- datentraeger.datei__BWREL_datentraegerref, datentraeger.haltung_alternativverlauf__BWREL_t_id, datentraeger.metaattribute__BWREL_sia405_baseclass_metaattribute, datentraeger.symbolpos__BWREL_t_id, datentraeger.textpos__BWREL_t_id - - # metaattribute --- metaattribute.datenherr, metaattribute.datenlieferant, metaattribute.letzte_aenderung, metaattribute.sia405_baseclass_metaattribute, metaattribute.t_id, metaattribute.t_ili_tid, metaattribute.t_seq - # _rel_ --- metaattribute.sia405_baseclass_metaattribute__REL - - data_media = QGEP.data_media( - - # --- data_media --- - # fk_dataowner=row.REPLACE_ME, # VARCHAR(16) - # fk_provider=row.REPLACE_ME, # VARCHAR(16) - # identifier=row.REPLACE_ME, # VARCHAR(40) - # kind=row.REPLACE_ME, # INTEGER - # last_modification=row.REPLACE_ME, # TIMESTAMP WITHOUT TIME ZONE - # location=row.REPLACE_ME, # VARCHAR(50) - # obj_id=row.REPLACE_ME, # VARCHAR(16) - # path=row.REPLACE_ME, # VARCHAR(100) - # remark=row.REPLACE_ME, # VARCHAR(80) - ) - qgep_session.add(data_media) - print(".", end="") - print("done") - - print("Importing ABWASSER.datei, ABWASSER.metaattribute -> QGEP.file") - for row, metaattribute in abwasser_session.query(ABWASSER.datei, ABWASSER.metaattribute).join(ABWASSER.metaattribute): - - # baseclass --- datei.t_ili_tid, datei.t_type - # sia405_baseclass --- datei.obj_id - # datei --- datei.art, datei.bemerkung, datei.bezeichnung, datei.datentraegerref, datei.klasse, datei.objekt, datei.relativpfad, datei.t_id - # _bwrel_ --- datei.haltung_alternativverlauf__BWREL_t_id, datei.metaattribute__BWREL_sia405_baseclass_metaattribute, datei.symbolpos__BWREL_t_id, datei.textpos__BWREL_t_id - # _rel_ --- datei.datentraegerref__REL - - # metaattribute --- metaattribute.datenherr, metaattribute.datenlieferant, metaattribute.letzte_aenderung, metaattribute.sia405_baseclass_metaattribute, metaattribute.t_id, metaattribute.t_ili_tid, metaattribute.t_seq - # _rel_ --- metaattribute.sia405_baseclass_metaattribute__REL - - file = QGEP.file( - - # --- file --- - # class=row.REPLACE_ME, # INTEGER - # fk_data_media=row.REPLACE_ME, # VARCHAR(16) - # fk_dataowner=row.REPLACE_ME, # VARCHAR(16) - # fk_provider=row.REPLACE_ME, # VARCHAR(16) - # identifier=row.REPLACE_ME, # VARCHAR(60) - # kind=row.REPLACE_ME, # INTEGER - # last_modification=row.REPLACE_ME, # TIMESTAMP WITHOUT TIME ZONE - # obj_id=row.REPLACE_ME, # VARCHAR(16) - # object=row.REPLACE_ME, # VARCHAR(41) - # path_relative=row.REPLACE_ME, # VARCHAR(200) - # remark=row.REPLACE_ME, # VARCHAR(80) - ) - qgep_session.add(file) - print(".", end="") - print("done") - - qgep_session.commit() - - qgep_session.close() - abwasser_session.close() diff --git a/qgepqwat2ili/qgepdss/export.py b/qgepqwat2ili/qgepdss/export.py index b97ac9e1..6bcfe72e 100644 --- a/qgepqwat2ili/qgepdss/export.py +++ b/qgepqwat2ili/qgepdss/export.py @@ -14,7 +14,7 @@ from .model_qgep import get_qgep_model -def qgep_export(selection=None, labels_file=None, orientation=None, basket_enabled=False): +def qgep_export_dss(selection=None, labels_file=None, orientation=None, basket_enabled=False): """ Export data from the QGEP model into the ili2pg model. diff --git a/qgepqwat2ili/qgepdss/import_.py b/qgepqwat2ili/qgepdss/import_.py index 537312a8..405d9c42 100644 --- a/qgepqwat2ili/qgepdss/import_.py +++ b/qgepqwat2ili/qgepdss/import_.py @@ -13,7 +13,7 @@ from .model_qgep import get_qgep_model -def qgep_import(precommit_callback=None): +def qgep_import_dss(precommit_callback=None): """ Imports data from the ili2pg model into the QGEP model. diff --git a/qgepqwat2ili/qgepsia405/export.py b/qgepqwat2ili/qgepsia405/export.py index 32365601..e1e93382 100644 --- a/qgepqwat2ili/qgepsia405/export.py +++ b/qgepqwat2ili/qgepsia405/export.py @@ -13,7 +13,7 @@ from .model_qgep import get_qgep_model -def qgep_export(selection=None, labels_file=None, orientation=None, basket_enabled=False): +def qgep_export_sia405(selection=None, labels_file=None, orientation=None, basket_enabled=False): """ Export data from the QGEP model into the ili2pg model. diff --git a/qgepqwat2ili/qgepsia405/import_.py b/qgepqwat2ili/qgepsia405/import_.py index 6df72e47..23cd812b 100644 --- a/qgepqwat2ili/qgepsia405/import_.py +++ b/qgepqwat2ili/qgepsia405/import_.py @@ -11,7 +11,7 @@ from .model_qgep import get_qgep_model -def qgep_import(precommit_callback=None): +def qgep_import_sia405(precommit_callback=None): """ Imports data from the ili2pg model into the QGEP model.