work

src/covid19/blueprints/rki/rki_model_import.py

 from database import db, ITEMS_PER_PAGE
 
+# OBJECTID_1,LAN_ew_AGS,LAN_ew_GEN,LAN_ew_BEZ,LAN_ew_EWZ,OBJECTID,Fallzahl,Aktualisierung,AGS_TXT,GlobalID,faelle_100000_EW,Death,cases7_bl_per_100k,cases7_bl,death7_bl,cases7_bl_per_100k_txt,AdmUnitId,SHAPE_Length,SHAPE_Area
 
-class RkiGermanyDataImportTable(db.Model):
-    __tablename__ = 'rki_global_data_import'
+class RkiBundeslaenderImport(db.Model):
+    __tablename__ = 'rki_bundeslsaender_import'
+
+    id = db.Column(db.Integer, primary_key=True)
+
+    OBJECTID_1 = db.Column(db.String(255), nullable=False)
+    LAN_ew_AGS = db.Column(db.String(255), nullable=False)
+    LAN_ew_GEN = db.Column(db.String(255), nullable=False)
+    LAN_ew_BEZ = db.Column(db.String(255), nullable=False)
+    LAN_ew_EWZ = db.Column(db.String(255), nullable=False)
+    OBJECTID = db.Column(db.String(255), nullable=False)
+    Fallzahl = db.Column(db.String(255), nullable=False)
+    Aktualisierung = db.Column(db.String(255), nullable=False)
+    AGS_TXT = db.Column(db.String(255), nullable=False)
+    GlobalID = db.Column(db.String(255), nullable=False)
+    faelle_100000_EW = db.Column(db.String(255), nullable=False)
+    Death = db.Column(db.String(255), nullable=False)
+    cases7_bl_per_100k = db.Column(db.String(255), nullable=False)
+    cases7_bl = db.Column(db.String(255), nullable=False)
+    death7_bl = db.Column(db.String(255), nullable=False)
+    cases7_bl_per_100k_txt = db.Column(db.String(255), nullable=False)
+    AdmUnitId = db.Column(db.String(255), nullable=False)
+    SHAPE_Length = db.Column(db.String(255), nullable=False)
+    SHAPE_Area = db.Column(db.String(255), nullable=False)
+
+    @classmethod
+    def remove_all(cls):
+        for one in cls.get_all():
+            db.session.delete(one)
+        db.session.commit()
+        return None
+
+    @classmethod
+    def get_all_as_page(cls, page):
+        return db.session.query(cls).paginate(page, per_page=ITEMS_PER_PAGE)
+
+    @classmethod
+    def get_all(cls):
+        return db.session.query(cls).all()
+
+    @classmethod
+    def get_by_id(cls, other_id):
+        return db.session.query(cls).filter(cls.id == other_id).one()
+
+
+class RkiLandkreiseImport(db.Model):
+    __tablename__ = 'rki_landkreise_import'
 
     id = db.Column(db.Integer, primary_key=True)
     date_reported = db.Column(db.String(255), nullable=False)