Implementierung von Add-, Delete-, Modification- und Query-Operationen in MySQL basierend auf sqlalchemy

from sqlalchemy import exists, Spalte, Ganzzahl, Zeichenfolge, Fremdschlüssel, existiert
von sqlalchemy.ext.declarative importiere declarative_base
von sqlalchemy importiere create_engine
aus sqlalchemy.orm importiere Sessionmaker

# Datenbank-Engine erstellt engine = create_engine("mysql+pymysql://user:pwd@ip/database name?charset=utf8")

#Sitzungstyp erstellen DBSession = sessionmaker(bind=engine)

# Instanziieren Sie das offizielle Modell – Base ist das ORM-Modell Base = declarative_base()


# Erstellen Sie eine Serviceauftragstabelle der Klasse ServiceOrder(Base):
  __tablename__ = "Dienstbestelltabelle"
  id = Spalte(Integer, Primärschlüssel=True, Autoincrement=True)
  serviceOrderId = Spalte (String(32), nullwertfähig=Falsch, Index=Wahr, Kommentar='Service-Bestell-ID')
  serviceDesc = Spalte(String(268), Kommentar='Dienstbeschreibung')
  oneLevelName = Spalte(String(32), Kommentar='C Kategorie')
  twoLevelName = Spalte(String(32), Kommentar='T-Unterklasse')
  threeLevelName = Spalte(String(32), Kommentar='Ich projiziere')
  fourLevelName = Spalte(String(32), Kommentar='S-Unterelement')
  transferTimes = Column(String(32), Kommentar='Anzahl der Transfers')
  overDueStatus = Column(String(32), Kommentar='Abgelaufener Status')
  serviceTimeLimit = Spalte(String(32), Kommentar='Servicezeitlimit')
  serTimeLimitTypeName = Column(String(16), Kommentar='Zeitlimittyp')  
  # Eins-zu-viele:
  # serviceWorkOrder = Beziehung("ServiceWorkOrder", backref="serviceorder")


# Viele-zu-eins: Mehrere Serviceaufträge können zur Serviceauftragsklasse ServiceWorkOrder(Base) gehören:
  __tablename__ = "serviceWorkOrderTable"
  id = Spalte(Integer, Primärschlüssel=True, Autoincrement=True)
  serviceWorkOrderId = Spalte (String(32), nullable=False, index=True, comment='Service-Arbeitsauftrags-ID')
  workOrderName = Spalte(String(268), Kommentar='Arbeitsauftragsname')
  fromId = Spalte(String(32), Kommentar='Service-Auftrags-ID')
  createUserSectionName = Column(String(32), Kommentar='Benutzerabschnitt erstellen')
  createUserName = Spalte(String(32), Kommentar='Ersteller')
  handlerName = Spalte(String(32), Kommentar='Handler')
  statusName = Spalte(String(32), Kommentar='Arbeitsauftragsstatus')
  createTime = Column(String(32), Kommentar='Erstellungszeitpunkt') 
  # Die Buchtabelle auf der "vielen" Seite ist über einen Fremdschlüssel mit der Benutzertabelle verknüpft:
  # serviceOrder_id = Spalte (Ganzzahl, Fremdschlüssel ('serviceOrderTable.id'))

# Erstellen Sie eine Datenbank. Wenn die Datenbank bereits existiert, wird sie nicht erstellt. Es wird eine direkte Verbindung zur vorhandenen Bibliothek gemäß dem Bibliotheksnamen hergestellt. def init_db():
  Base.metadata.create_all(Engine)

def drop_db():
  Base.metadata.drop_all(Engine)

def insert_update():
  # all_needed_data_lists ist das Datenformat, das in die Datenbank eingefügt werden muss [{key: value, ... }, { }, { }...]
  für Element in all_needed_data_lists:
    ServiceOrderRow = ServiceOrder(serviceOrderId=item['serviceOrderId'],
                    serviceDesc=Element['serviceDesc'],
                    oneLevelName=item['oneLevelName'],
                    twoLevelName=Element['twoLevelName'],
                    threeLevelName=item['threeLevelName'],
                    fourLevelName=item['fourLevelName'],
                    transferTimes=item['transferTimes'],
                    overDueStatus=Element['overDueStatus'],
                    serviceTimeLimit=Element['serviceTimeLimit'],
                    serTimeLimitTypeName=Element['serTimeLimitTypeName'],
                    )
    versuchen:
      # Verwenden Sie exists, um zu bestimmen, ob das Zielobjekt existiert, und geben Sie True oder Faults zurück.
      it_exists = Sitzung.Abfrage(
          existiert().wo(ServiceOrder.serviceOrderId == item['serviceOrderId'] )
        ).scalar()
    außer Ausnahme als e:
      selbst.log.error(e)
      brechen
    versuchen:
      # Wenn es nicht existiert, fügen Sie es hinzu; wenn es existiert, aktualisieren Sie die vorhandenen Daten, andernfalls existiert es:
        Sitzung.Hinzufügen(ServiceOrderRow)
      anders:
        Sitzung.Abfrage(ServiceOrder).Filter(ServiceOrder.serviceOrderId == Artikel['serviceOrderId'])\
          .update(Artikel)
    außer Ausnahme als e:
      selbst.log.error(e)
      brechen
  versuchen:
    Sitzung.commit()
    self.log.info('Daten erfolgreich aktualisiert!')
  außer:
    Sitzung.rollback()
    self.log.info('Datenaktualisierung fehlgeschlagen!')

wenn __name__ == "__main__":
  # Erstellen Sie eine Datenbank. Wenn die Datenbank bereits existiert, wird sie nicht erstellt. Sie stellt entsprechend dem Bibliotheksnamen eine direkte Verbindung zur vorhandenen Bibliothek her. init_db()
  # Erstellen Sie ein Sitzungsobjekt zum Hinzufügen, Löschen, Ändern und Abfragen:
  Sitzung = DBSession()
  # Verwenden Sie die Sitzung, um Daten hinzuzufügen oder zu ändern. Denken Sie daran, insert_update() zu übermitteln