diff --git a/src/flask_covid19/blueprints/data_rki/rki_model.py b/src/flask_covid19/blueprints/data_rki/rki_model.py index 1407161c5e4139219e6cb3a1b4702893deea9c85..8ca27396736f3aa4c79260a4c0349358fd5b536e 100644 --- a/src/flask_covid19/blueprints/data_rki/rki_model.py +++ b/src/flask_covid19/blueprints/data_rki/rki_model.py @@ -45,6 +45,13 @@ class RkiMeldedatum(BlueprintDateReported): db.session.rollback() return num_rows_deleted + @classmethod + def delete_all(cls): + for o in cls.find_all(): + db.session.remove(o) + db.session.commit() + return None + class RkiDatenstand(BlueprintDateReported): __tablename__ = 'rki_date_datenstand' diff --git a/src/flask_covid19/blueprints/data_rki/rki_service_update.py b/src/flask_covid19/blueprints/data_rki/rki_service_update.py index dd0af6d74a6cdef73ea11cc9fe70766278fe300b..9ce64c1ab2c08dc7709e6c23bf83ef06ecb000e9 100644 --- a/src/flask_covid19/blueprints/data_rki/rki_service_update.py +++ b/src/flask_covid19/blueprints/data_rki/rki_service_update.py @@ -62,7 +62,7 @@ class RkiServiceUpdateFull(RkiServiceUpdateBase): def __full_update_date_reported(self): app.logger.info(" RkiServiceUpdateFull.__full_update_date_reported [begin]") app.logger.info("------------------------------------------------------------") - RkiMeldedatum.remove_all() + RkiMeldedatum.delete_all() i = 0 output_lines = [] for datum_of_import in RkiImport.get_meldedatum_list(): @@ -71,7 +71,6 @@ class RkiServiceUpdateFull(RkiServiceUpdateBase): i += 1 o = BlueprintDateReportedFactory.create_new_object_for_rki(my_date_rep=datum_of_import[0]) db.session.add(o) - db.session.commit() output = " [ " + str(i) + " ] full update RKI meldedatum ... " + str(o) output_lines.append(output) app.logger.info(output)