parouby
/
Pamhyr2
mirror of https://gitlab.com/pamhyr/pamhyr2
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Adists: LC: Fix update for scenario.

scenarios
Pierre-Antoine 2025-08-15 14:31:28 +02:00
parent 0379a8ee02
commit 93340a48b1
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/Model/LateralContributionsAdisTS/LateralContributionAdisTS.py
View File

@ -93,11 +93,15 @@ class LateralContributionAdisTS(SQLSubModel):
@classmethod @classmethod
def _db_update(cls, execute, version, data=None): def _db_update(cls, execute, version, data=None):
major, minor, release = version.strip().split(".") major, minor, release = version.strip().split(".")
created = False
if major == "0" and int(minor) <= 1: if major == "0" and int(minor) <= 1:
if int(release) < 7: if int(release) < 7:
cls._db_create(execute) cls._db_create(execute)
created = True
elif major == "0" and int(minor) < 2: if major == "0" and int(minor) < 2:
if not created:
cls._db_update_to_0_2_0(execute, data) cls._db_update_to_0_2_0(execute, data)
return True return True
@ -127,7 +131,6 @@ class LateralContributionAdisTS(SQLSubModel):
@classmethod @classmethod
def _db_update_to_0_2_0_data(cls, execute, data): def _db_update_to_0_2_0_data(cls, execute, data):
table = "lateral_contribution_data_adists" table = "lateral_contribution_data_adists"
reachs = data['id2pid']['river_reach']
cls.update_db_add_pamhyr_id(execute, table, data) cls.update_db_add_pamhyr_id(execute, table, data)
Scenario.update_db_add_scenario(execute, table) Scenario.update_db_add_scenario(execute, table)
@ -137,15 +140,13 @@ class LateralContributionAdisTS(SQLSubModel):
execute( execute(
f"INSERT INTO {table}_tmp " + f"INSERT INTO {table}_tmp " +
"(pamhyr_id, data0, data1, lca, scenario) " + "(pamhyr_id, data0, data1, lca, scenario) " +
"SELECT pamhyr_id, data0, data1, lc, scenario) " + "SELECT pamhyr_id, data0, data1, lc, scenario " +
f"FROM {table}" f"FROM {table}"
) )
execute(f"DROP TABLE {table}") execute(f"DROP TABLE {table}")
execute(f"ALTER TABLE {table}_tmp RENAME TO {table}") execute(f"ALTER TABLE {table}_tmp RENAME TO {table}")
cls._db_update_to_0_2_0_set_reach_pid(execute, table, reachs)
@classmethod @classmethod
def _db_load(cls, execute, data=None): def _db_load(cls, execute, data=None):
new = [] new = []