def save(self, db_conn: DatabaseConnection) -> None:
"""Add (or re-write) self and connected items to DB."""
self.save_core(db_conn)
+ assert isinstance(self.id_, int)
self.title.save(db_conn)
self.description.save(db_conn)
self.effort.save(db_conn)
- db_conn.exec('DELETE FROM process_conditions WHERE process = ?',
- (self.id_,))
- for condition in self.conditions:
- db_conn.exec('INSERT INTO process_conditions VALUES (?,?)',
- (self.id_, condition.id_))
- db_conn.exec('DELETE FROM process_fulfills WHERE process = ?',
- (self.id_,))
- for condition in self.fulfills:
- db_conn.exec('INSERT INTO process_fulfills VALUES (?,?)',
- (self.id_, condition.id_))
- db_conn.exec('DELETE FROM process_undoes WHERE process = ?',
- (self.id_,))
- for condition in self.undoes:
- db_conn.exec('INSERT INTO process_undoes VALUES (?,?)',
- (self.id_, condition.id_))
- assert isinstance(self.id_, int)
+ db_conn.rewrite_relations('process_conditions', 'process', self.id_,
+ [[c.id_] for c in self.conditions])
+ db_conn.rewrite_relations('process_fulfills', 'process', self.id_,
+ [[c.id_] for c in self.fulfills])
+ db_conn.rewrite_relations('process_undoes', 'process', self.id_,
+ [[c.id_] for c in self.undoes])
db_conn.exec('DELETE FROM process_steps WHERE owner = ?',
(self.id_,))
for step in self.explicit_steps: