Compare commits

..

No commits in common. "ba60585550a8c09ff6deb7cbde8d59185e733e30" and "8b4ff41b96f13000e4f6d83f2e9ea8880d2fdbe0" have entirely different histories.

15 changed files with 56 additions and 140 deletions

View File

@ -64,7 +64,6 @@ class BoundaryConditionAdisTS(SQLSubModel):
execute(f""" execute(f"""
CREATE TABLE boundary_condition_adists{ext}( CREATE TABLE boundary_condition_adists{ext}(
{cls.create_db_add_pamhyr_id()}, {cls.create_db_add_pamhyr_id()},
deleted BOOLEAN NOT NULL DEFAULT FALSE,
pollutant INTEGER NOT NULL, pollutant INTEGER NOT NULL,
type TEXT NOT NULL, type TEXT NOT NULL,
node INTEGER, node INTEGER,
@ -206,7 +205,7 @@ class BoundaryConditionAdisTS(SQLSubModel):
return new return new
table = execute( table = execute(
"SELECT pamhyr_id, deleted, pollutant, type, node, scenario " + "SELECT pamhyr_id, pollutant, type, node, scenario " +
"FROM boundary_condition_adists " + "FROM boundary_condition_adists " +
f"WHERE scenario = {scenario.id} " + f"WHERE scenario = {scenario.id} " +
f"AND pamhyr_id NOT IN ({', '.join(map(str, loaded))}) " f"AND pamhyr_id NOT IN ({', '.join(map(str, loaded))}) "
@ -217,7 +216,6 @@ class BoundaryConditionAdisTS(SQLSubModel):
it = iter(row) it = iter(row)
pid = next(it) pid = next(it)
deleted = (next(it) == 1)
pollutant = next(it) pollutant = next(it)
bc_type = next(it) bc_type = next(it)
node = next(it) node = next(it)
@ -229,8 +227,6 @@ class BoundaryConditionAdisTS(SQLSubModel):
status=status, status=status,
owner_scenario=owner_scenario owner_scenario=owner_scenario
) )
if deleted:
bc.set_as_deleted()
bc.type = bc_type bc.type = bc_type
@ -291,12 +287,10 @@ class BoundaryConditionAdisTS(SQLSubModel):
execute( execute(
"INSERT INTO " + "INSERT INTO " +
"boundary_condition_adists(" + "boundary_condition_adists(id, pollutant, type, " +
"pamhyr_id, deleted, pollutant, type, " +
"node, scenario) " + "node, scenario) " +
"VALUES (" + "VALUES (" +
f"{self.id}, {self._db_format(self.is_deleted())}, " + f"{self.id}, {self._pollutant}, " +
f"{self._pollutant}, " +
f"'{self._db_format(self._type)}', {node}, " + f"'{self._db_format(self._type)}', {node}, " +
f"{self._status.scenario_id}" + f"{self._status.scenario_id}" +
")" ")"
@ -308,8 +302,7 @@ class BoundaryConditionAdisTS(SQLSubModel):
execute( execute(
"INSERT INTO " + "INSERT INTO " +
"boundary_condition_data_adists(" + "boundary_condition_data_adists(data0, data1, bc, scenario) " +
"data0, data1, bc, scenario) " +
f"VALUES ('{data0}', {data1}, {self.id}, " + f"VALUES ('{data0}', {data1}, {self.id}, " +
f"{self._status.scenario_id})" f"{self._status.scenario_id})"
) )

View File

@ -19,7 +19,7 @@
from copy import copy from copy import copy
from tools import trace, timer from tools import trace, timer
from Model.Tools.PamhyrListExt import PamhyrModelList from Model.Tools.PamhyrList import PamhyrModelList
from Model.Except import NotImplementedMethodeError from Model.Except import NotImplementedMethodeError
from Model.BoundaryConditionsAdisTS.BoundaryConditionAdisTS \ from Model.BoundaryConditionsAdisTS.BoundaryConditionAdisTS \

View File

@ -54,7 +54,6 @@ class D90AdisTS(SQLSubModel):
execute(f""" execute(f"""
CREATE TABLE d90_adists{ext}( CREATE TABLE d90_adists{ext}(
{cls.create_db_add_pamhyr_id()}, {cls.create_db_add_pamhyr_id()},
deleted BOOLEAN NOT NULL DEFAULT FALSE,
name TEXT NOT NULL, name TEXT NOT NULL,
d90 REAL NOT NULL, d90 REAL NOT NULL,
enabled BOOLEAN NOT NULL, enabled BOOLEAN NOT NULL,
@ -111,7 +110,7 @@ class D90AdisTS(SQLSubModel):
return new return new
table = execute( table = execute(
"SELECT pamhyr_id, deleted, name, d90, enabled, scenario " + "SELECT pamhyr_id, name, d90, enabled, scenario " +
"FROM d90_adists " + "FROM d90_adists " +
f"WHERE scenario = {scenario.id} " + f"WHERE scenario = {scenario.id} " +
f"AND pamhyr_id NOT IN ({', '.join(map(str, loaded))}) " f"AND pamhyr_id NOT IN ({', '.join(map(str, loaded))}) "
@ -122,7 +121,6 @@ class D90AdisTS(SQLSubModel):
it = iter(row) it = iter(row)
pid = next(it) pid = next(it)
deleted = (next(it) == 1)
name = next(it) name = next(it)
value_d90 = next(it) value_d90 = next(it)
enabled = (next(it) == 1) enabled = (next(it) == 1)
@ -134,8 +132,6 @@ class D90AdisTS(SQLSubModel):
status=status, status=status,
owner_scenario=owner_scenario owner_scenario=owner_scenario
) )
if deleted:
d90.set_as_deleted()
d90.d90 = value_d90 d90.d90 = value_d90
d90.enabled = enabled d90.enabled = enabled
@ -169,12 +165,10 @@ class D90AdisTS(SQLSubModel):
execute( execute(
"INSERT INTO " + "INSERT INTO " +
"d90_adists(" + "d90_adists(" +
"pamhyr_id, deleted, " + "pamhyr_id, name, d90, enabled, scenario" +
"name, d90, enabled, scenario" +
") " + ") " +
"VALUES (" + "VALUES (" +
f"{self.id}, {self._db_format(self.is_deleted())}, " + f"{self.id}, '{self._db_format(self._name)}', " +
f"'{self._db_format(self._name)}', " +
f"{d90}, {self._enabled}, {self._status.scenario_id}" + f"{d90}, {self._enabled}, {self._status.scenario_id}" +
")" ")"
) )
@ -228,36 +222,19 @@ class D90AdisTS(SQLSubModel):
return n return n
def delete(self, data): def delete(self, data):
list( self._data = list(
map( filter(
lambda x: x.set_as_deleted(), lambda x: x not in data,
data self._data
) )
) )
self.modified() self.modified()
def delete_i(self, indexes): def delete_i(self, indexes):
list( for ind in indexes:
map( del self._data[ind]
lambda e: e[1].set_as_deleted(),
filter(
lambda e: e[0] in indexes,
enumerate(self._data)
)
)
)
self.modified() self.modified()
def insert(self, index, data): def insert(self, index, data):
if data in self._data: self._data.insert(index, data)
self.undelete([data])
else:
self._data.insert(index, data)
self.modified()
def undelete(self, lst):
for x in lst:
x.set_as_not_deleted()
self.modified() self.modified()

View File

@ -19,7 +19,7 @@
from copy import copy from copy import copy
from tools import trace, timer from tools import trace, timer
from Model.Tools.PamhyrListExt import PamhyrModelList from Model.Tools.PamhyrList import PamhyrModelList
from Model.D90AdisTS.D90AdisTS import D90AdisTS from Model.D90AdisTS.D90AdisTS import D90AdisTS

View File

@ -51,7 +51,6 @@ class D90AdisTSSpec(SQLSubModel):
execute(f""" execute(f"""
CREATE TABLE d90_adists_spec{ext}( CREATE TABLE d90_adists_spec{ext}(
{cls.create_db_add_pamhyr_id()}, {cls.create_db_add_pamhyr_id()},
deleted BOOLEAN NOT NULL DEFAULT FALSE,
d90_default INTEGER NOT NULL, d90_default INTEGER NOT NULL,
name TEXT NOT NULL, name TEXT NOT NULL,
reach INTEGER NOT NULL, reach INTEGER NOT NULL,
@ -138,8 +137,7 @@ class D90AdisTSSpec(SQLSubModel):
return new return new
table = execute( table = execute(
"SELECT pamhyr_id, deleted, " + "SELECT pamhyr_id, name, reach, start_rk, end_rk, " +
f"name, reach, start_rk, end_rk, " +
"d90, enabled, scenario " + "d90, enabled, scenario " +
"FROM d90_adists_spec " + "FROM d90_adists_spec " +
f"WHERE d90_default = {data['d90_default_id']} " + f"WHERE d90_default = {data['d90_default_id']} " +
@ -152,7 +150,6 @@ class D90AdisTSSpec(SQLSubModel):
it = iter(row) it = iter(row)
pid = next(it) pid = next(it)
deleted = (next(it) == 1)
name = next(it) name = next(it)
reach = next(it) reach = next(it)
start_rk = next(it) start_rk = next(it)
@ -167,8 +164,6 @@ class D90AdisTSSpec(SQLSubModel):
status=status, status=status,
owner_scenario=owner_scenario owner_scenario=owner_scenario
) )
if deleted:
new_spec.is_deleted()
new_spec.reach = reach new_spec.reach = reach
new_spec.start_rk = start_rk new_spec.start_rk = start_rk
@ -193,12 +188,10 @@ class D90AdisTSSpec(SQLSubModel):
execute( execute(
"INSERT INTO " + "INSERT INTO " +
"d90_spec(pamhyr_id, deleted, " + "d90_spec(pamhyr_id, d90_default, name, reach, " +
"d90_default, name, reach, " +
"start_rk, end_rk, d90, enabled, scenario) " + "start_rk, end_rk, d90, enabled, scenario) " +
"VALUES (" + "VALUES (" +
f"{self.id}, {self._db_format(self.is_deleted())}" + f"{self.id}, {d90_default}, " +
f"{d90_default}, " +
f"'{self._db_format(self._name_section)}', " + f"'{self._db_format(self._name_section)}', " +
f"{self._reach}, " + f"{self._reach}, " +
f"{self._start_rk}, {self._end_rk}, " + f"{self._start_rk}, {self._end_rk}, " +

View File

@ -282,36 +282,19 @@ class DIFAdisTS(SQLSubModel):
return n return n
def delete(self, data): def delete(self, data):
list( self._data = list(
map( filter(
lambda x: x.set_as_deleted(), lambda x: x not in data,
data self._data
) )
) )
self.modified() self.modified()
def delete_i(self, indexes): def delete_i(self, indexes):
list( for ind in indexes:
map( del self._data[ind]
lambda e: e[1].set_as_deleted(),
filter(
lambda e: e[0] in indexes,
enumerate(self._data)
)
)
)
self.modified() self.modified()
def insert(self, index, data): def insert(self, index, data):
if data in self._data: self._data.insert(index, data)
self.undelete([data])
else:
self._data.insert(index, data)
self.modified()
def undelete(self, lst):
for x in lst:
x.set_as_not_deleted()
self.modified() self.modified()

View File

@ -19,7 +19,7 @@
from copy import copy from copy import copy
from tools import trace, timer from tools import trace, timer
from Model.Tools.PamhyrListExt import PamhyrModelList from Model.Tools.PamhyrList import PamhyrModelList
from Model.DIFAdisTS.DIFAdisTS import DIFAdisTS from Model.DIFAdisTS.DIFAdisTS import DIFAdisTS

View File

@ -59,7 +59,6 @@ class DIFAdisTSSpec(SQLSubModel):
execute(f""" execute(f"""
CREATE TABLE dif_adists_spec{ext}( CREATE TABLE dif_adists_spec{ext}(
{cls.create_db_add_pamhyr_id()}, {cls.create_db_add_pamhyr_id()},
deleted BOOLEAN NOT NULL DEFAULT FALSE,
dif_default INTEGER NOT NULL, dif_default INTEGER NOT NULL,
method TEXT NOT NULL, method TEXT NOT NULL,
reach INTEGER NOT NULL, reach INTEGER NOT NULL,
@ -150,7 +149,7 @@ class DIFAdisTSSpec(SQLSubModel):
return new return new
table = execute( table = execute(
"SELECT pamhyr_id, deleted, method, reach, start_rk, end_rk, " + "SELECT pamhyr_id, method, reach, start_rk, end_rk, " +
"dif, b, c, enabled, scenario " + "dif, b, c, enabled, scenario " +
"FROM dif_adists_spec " + "FROM dif_adists_spec " +
f"WHERE dif_default = {data['dif_default_id']} " + f"WHERE dif_default = {data['dif_default_id']} " +
@ -163,7 +162,6 @@ class DIFAdisTSSpec(SQLSubModel):
it = iter(row) it = iter(row)
id = next(it) id = next(it)
deleted = (next(it) == 1)
method = next(it) method = next(it)
reach = next(it) reach = next(it)
start_rk = next(it) start_rk = next(it)
@ -180,8 +178,6 @@ class DIFAdisTSSpec(SQLSubModel):
status=status, status=status,
owner_scenario=owner_scenario owner_scenario=owner_scenario
) )
if deleted:
new_spec.set_as_deleted()
new_spec.reach = reach new_spec.reach = reach
new_spec.start_rk = start_rk new_spec.start_rk = start_rk
@ -208,12 +204,10 @@ class DIFAdisTSSpec(SQLSubModel):
execute( execute(
"INSERT INTO " + "INSERT INTO " +
"dif_adists_spec(pamhyr_id, deleted, " + "dif_adists_spec(pamhyr_id, dif_default, method, reach, " +
"dif_default, method, reach, " +
"start_rk, end_rk, dif, b, c, enabled, scenario) " + "start_rk, end_rk, dif, b, c, enabled, scenario) " +
"VALUES (" + "VALUES (" +
f"{self.id}, {self._db_format(self.is_deleted())}" + f"{self.id}, {dif_default}, " +
f"{dif_default}, " +
f"'{self._db_format(self._method)}', " + f"'{self._db_format(self._method)}', " +
f"{self._reach}, " + f"{self._reach}, " +
f"{self._start_rk}, {self._end_rk}, " + f"{self._start_rk}, {self._end_rk}, " +

View File

@ -60,7 +60,6 @@ class InitialConditionsAdisTS(SQLSubModel):
execute(f""" execute(f"""
CREATE TABLE initial_conditions_adists{ext}( CREATE TABLE initial_conditions_adists{ext}(
{cls.create_db_add_pamhyr_id()}, {cls.create_db_add_pamhyr_id()},
deleted BOOLEAN NOT NULL DEFAULT FALSE,
pollutant INTEGER NOT NULL, pollutant INTEGER NOT NULL,
name TEXT NOT NULL, name TEXT NOT NULL,
concentration REAL NOT NULL, concentration REAL NOT NULL,
@ -148,8 +147,7 @@ class InitialConditionsAdisTS(SQLSubModel):
return new return new
table = execute( table = execute(
"SELECT pamhyr_id, deleted, " + "SELECT pamhyr_id, pollutant, name, concentration, eg, em, ed, " +
"pollutant, name, concentration, eg, em, ed, " +
"enabled, scenario " + "enabled, scenario " +
"FROM initial_conditions_adists " + "FROM initial_conditions_adists " +
f"WHERE scenario = {scenario.id} " + f"WHERE scenario = {scenario.id} " +
@ -161,7 +159,6 @@ class InitialConditionsAdisTS(SQLSubModel):
it = iter(row) it = iter(row)
pid = next(it) pid = next(it)
deleted = (next(it) == 1)
pollutant = next(it) pollutant = next(it)
name = next(it) name = next(it)
concentration = next(it) concentration = next(it)
@ -177,8 +174,6 @@ class InitialConditionsAdisTS(SQLSubModel):
status=status, status=status,
owner_scenario=owner_scenario owner_scenario=owner_scenario
) )
if deleted:
ic.set_as_deleted()
ic.pollutant = pollutant ic.pollutant = pollutant
ic.concentration = concentration ic.concentration = concentration
@ -232,12 +227,11 @@ class InitialConditionsAdisTS(SQLSubModel):
sql = ( sql = (
"INSERT INTO " + "INSERT INTO " +
"initial_conditions_adists(" + "initial_conditions_adists(" +
"pamhyr_id, deletec, pollutant, name, concentration, " + "pamhyr_id, pollutant, name, concentration, " +
"eg, em, ed, enabled, scenario" + "eg, em, ed, enabled, scenario" +
") " + ") " +
"VALUES (" + "VALUES (" +
f"{self.id}, {self.is_deleted()}, " + f"{self.id}, {pollutant}, '{self._db_format(self._name)}', " +
f"{pollutant}, '{self._db_format(self._name)}', " +
f"{concentration}, {eg}, {em}, {ed}, {self._enabled}, " + f"{concentration}, {eg}, {em}, {ed}, {self._enabled}, " +
f"{self._status.scenario_id}" + f"{self._status.scenario_id}" +
")" ")"

View File

@ -19,7 +19,7 @@
from copy import copy from copy import copy
from tools import trace, timer from tools import trace, timer
from Model.Tools.PamhyrListExt import PamhyrModelList from Model.Tools.PamhyrList import PamhyrModelList
from Model.InitialConditionsAdisTS.InitialConditionsAdisTS \ from Model.InitialConditionsAdisTS.InitialConditionsAdisTS \
import InitialConditionsAdisTS import InitialConditionsAdisTS

View File

@ -52,7 +52,6 @@ class ICAdisTSSpec(SQLSubModel):
execute(f""" execute(f"""
CREATE TABLE initial_conditions_adists_spec{ext}( CREATE TABLE initial_conditions_adists_spec{ext}(
{cls.create_db_add_pamhyr_id()}, {cls.create_db_add_pamhyr_id()},
deleted BOOLEAN NOT NULL DEFAULT FALSE,
ic_default INTEGER NOT NULL, ic_default INTEGER NOT NULL,
name TEXT NOT NULL, name TEXT NOT NULL,
reach INTEGER NOT NULL, reach INTEGER NOT NULL,
@ -150,7 +149,7 @@ class ICAdisTSSpec(SQLSubModel):
return new return new
table = execute( table = execute(
"SELECT pamhyr_id, deleted, name, reach, start_rk, end_rk, " + "SELECT pamhyr_id, name, reach, start_rk, end_rk, " +
"concentration, eg, em, ed, rate, enabled, scenario " + "concentration, eg, em, ed, rate, enabled, scenario " +
"FROM initial_conditions_adists_spec " + "FROM initial_conditions_adists_spec " +
f"WHERE ic_default = {data['ic_default_id']} " + f"WHERE ic_default = {data['ic_default_id']} " +
@ -163,7 +162,6 @@ class ICAdisTSSpec(SQLSubModel):
it = iter(row) it = iter(row)
id = next(it) id = next(it)
deleted = (next(it) == 1)
name = next(it) name = next(it)
reach = next(it) reach = next(it)
start_rk = next(it) start_rk = next(it)
@ -181,8 +179,6 @@ class ICAdisTSSpec(SQLSubModel):
status=status, status=status,
owner_scenario=owner_scenario owner_scenario=owner_scenario
) )
if deleted:
new_spec.set_as_deleted()
new_spec.reach = reach new_spec.reach = reach
new_spec.start_rk = start_rk new_spec.start_rk = start_rk
@ -211,13 +207,11 @@ class ICAdisTSSpec(SQLSubModel):
sql = ( sql = (
"INSERT INTO " + "INSERT INTO " +
"initial_conditions_adists_spec(id, deleted, " + "initial_conditions_adists_spec(id, ic_default, name, reach, " +
"ic_default, name, reach, " +
"start_rk, end_rk, concentration, eg, em, ed, rate, " + "start_rk, end_rk, concentration, eg, em, ed, rate, " +
"enabled, scenario) " + "enabled, scenario) " +
"VALUES (" + "VALUES (" +
f"{self.id}, {self._db_format(self.is_deleted())}, " + f"{self.id}, {ic_default}, " +
f"{ic_default}, " +
f"'{self._db_format(self._name_section)}', " + f"'{self._db_format(self._name_section)}', " +
f"{self._reach}, " + f"{self._reach}, " +
f"{self._start_rk}, {self._end_rk}, " + f"{self._start_rk}, {self._end_rk}, " +

View File

@ -65,7 +65,6 @@ class LateralContributionAdisTS(SQLSubModel):
execute(f""" execute(f"""
CREATE TABLE lateral_contribution_adists{ext}( CREATE TABLE lateral_contribution_adists{ext}(
{cls.create_db_add_pamhyr_id()}, {cls.create_db_add_pamhyr_id()},
deleted BOOLEAN NOT NULL DEFAULT FALSE,
pollutant INTEGER NOT NULL, pollutant INTEGER NOT NULL,
reach INTEGER NOT NULL, reach INTEGER NOT NULL,
begin_rk REAL NOT NULL, begin_rk REAL NOT NULL,
@ -82,7 +81,6 @@ class LateralContributionAdisTS(SQLSubModel):
execute(f""" execute(f"""
CREATE TABLE lateral_contribution_data_adists{ext}( CREATE TABLE lateral_contribution_data_adists{ext}(
{cls.create_db_add_pamhyr_id()}, {cls.create_db_add_pamhyr_id()},
deleted BOOLEAN NOT NULL DEFAULT FALSE,
data0 TEXT NOT NULL, data0 TEXT NOT NULL,
data1 TEXT NOT NULL, data1 TEXT NOT NULL,
lca INTEGER, lca INTEGER,
@ -206,7 +204,7 @@ class LateralContributionAdisTS(SQLSubModel):
return new return new
table = execute( table = execute(
"SELECT pamhyr_id, deleted, pollutant, reach, " + "SELECT pamhyr_id, pollutant, reach, " +
"begin_rk, end_rk, scenario " + "begin_rk, end_rk, scenario " +
"FROM lateral_contribution_adists " + "FROM lateral_contribution_adists " +
f"WHERE scenario = {scenario.id} " + f"WHERE scenario = {scenario.id} " +
@ -218,7 +216,6 @@ class LateralContributionAdisTS(SQLSubModel):
it = iter(row) it = iter(row)
pid = next(it) pid = next(it)
deleted = (next(it) == 1)
pollutant = next(it) pollutant = next(it)
reach = next(it) reach = next(it)
brk = next(it) brk = next(it)
@ -231,8 +228,6 @@ class LateralContributionAdisTS(SQLSubModel):
status=status, status=status,
owner_scenario=owner_scenario owner_scenario=owner_scenario
) )
if deleted:
lca.set_as_deleted()
lca.reach = reach lca.reach = reach
lca.begin_rk = brk lca.begin_rk = brk
@ -279,11 +274,10 @@ class LateralContributionAdisTS(SQLSubModel):
execute( execute(
"INSERT INTO " + "INSERT INTO " +
"lateral_contribution_adists(id, deleted," + "lateral_contribution_adists(id, " +
"pollutant, reach, begin_rk, end_rk, scenario) " + "pollutant, reach, begin_rk, end_rk, scenario) " +
"VALUES (" + "VALUES (" +
f"{self.id}, {self._db_format(self.is_deleted())}, " + f"{self.id}, {self._pollutant}, {self.reach}, " +
f"{self._pollutant}, {self.reach}, " +
f"{self._begin_rk}, {self._end_rk}" + f"{self._begin_rk}, {self._end_rk}" +
f"{self._status.scenario_id}" + f"{self._status.scenario_id}" +
")" ")"

View File

@ -19,7 +19,7 @@
from copy import copy from copy import copy
from tools import trace, timer from tools import trace, timer
from Model.Tools.PamhyrListExt import PamhyrModelList from Model.Tools.PamhyrList import PamhyrModelList
from Model.Except import NotImplementedMethodeError from Model.Except import NotImplementedMethodeError
from Model.LateralContributionsAdisTS.LateralContributionAdisTS \ from Model.LateralContributionsAdisTS.LateralContributionAdisTS \

View File

@ -77,18 +77,17 @@ class OutputRKAdists(SQLSubModel):
@classmethod @classmethod
def _db_create(cls, execute, ext=""): def _db_create(cls, execute, ext=""):
execute(f""" execute(
CREATE TABLE output_rk_adists{ext}( f"CREATE TABLE output_rk_adists{ext}(" +
{cls.create_db_add_pamhyr_id()}, f"{cls.create_db_add_pamhyr_id()},"
deleted BOOLEAN NOT NULL DEFAULT FALSE, "reach INTEGER NOT NULL, " +
reach INTEGER NOT NULL, "rk REAL NOT NULL, " +
rk REAL NOT NULL, "title TEXT NOT NULL, " +
title TEXT NOT NULL, f"{Scenario.create_db_add_scenario()},"
{Scenario.create_db_add_scenario()}, f"{Scenario.create_db_add_scenario_fk()},"
{Scenario.create_db_add_scenario_fk()}, "FOREIGN KEY(reach) REFERENCES river_reach(id)" +
FOREIGN KEY(reach) REFERENCES river_reach(id) ")"
) )
""")
return cls._create_submodel(execute) return cls._create_submodel(execute)
@ -145,7 +144,7 @@ class OutputRKAdists(SQLSubModel):
return new return new
table = execute( table = execute(
"SELECT pamhyr_id, deleted, reach, rk, title, scenario " + "SELECT pamhyr_id, reach, rk, title, scenario " +
f"FROM output_rk_adists" f"FROM output_rk_adists"
) )
@ -154,7 +153,6 @@ class OutputRKAdists(SQLSubModel):
it = iter(row) it = iter(row)
pid = next(it) pid = next(it)
deleted = (next(it) == 1)
id_reach = next(it) id_reach = next(it)
id_rk = next(it) id_rk = next(it)
title = next(it) title = next(it)
@ -166,8 +164,6 @@ class OutputRKAdists(SQLSubModel):
status=status, status=status,
owner_scenario=owner_scenario, owner_scenario=owner_scenario,
) )
if deleted:
new_output.set_as_deleted()
loaded.add(pid) loaded.add(pid)
new.append(new_output) new.append(new_output)
@ -190,11 +186,9 @@ class OutputRKAdists(SQLSubModel):
execute( execute(
"INSERT INTO " + "INSERT INTO " +
"output_rk_adists(pamhyr_id, deleted, " + "output_rk_adists(pamhyr_id, reach, rk, title, scenario) " +
"reach, rk, title, scenario) " +
"VALUES (" + "VALUES (" +
f"{self.id}, {self._db_format({self.is_deleted()})}" + f"{self.id}, {self._reach}, {self._rk}, " +
f"{self._reach}, {self._rk}, " +
f"'{self._db_format(self._title)}'" + f"'{self._db_format(self._title)}'" +
f"{self._status.scenario_id}" + f"{self._status.scenario_id}" +
")" ")"

View File

@ -19,7 +19,7 @@
from tools import trace, timer from tools import trace, timer
from Model.Except import NotImplementedMethodeError from Model.Except import NotImplementedMethodeError
from Model.Tools.PamhyrListExt import PamhyrModelList from Model.Tools.PamhyrList import PamhyrModelList
from Model.OutputRKAdists.OutputRKAdists import OutputRKAdists from Model.OutputRKAdists.OutputRKAdists import OutputRKAdists