Bedarfsszenario: Der Chef bat mich, den Crawler zu verwenden, um die Daten in die MySQL-Datenbank zu schreiben oder zu aktualisieren. Baidu fand zwei Methoden 1 besteht darin, pymysql zu verwenden, um eine Verbindung zu mysql herzustellen und Daten durch Ausführen nativer SQL-Anweisungen hinzuzufügen, zu löschen, zu ändern und abzufragen. 2 besteht darin, SQLAlchemy zu verwenden, um eine Verbindung zu MySQL herzustellen, Tabellen zu erstellen und Datenbanken über ORM-Modelle zu betreiben, ohne native SQL-Anweisungen zu schreiben, was relativ einfach ist. Im Folgenden schildern wir meine Erfahrungen mit der Verwendung von sqlalchemy. Implementierungsprozess: Verbindung zur Datenbank herstellen > Tabelle über die Modellklasse erstellen > Sitzung einrichten > Anweisung zum Erstellen der Tabelle ausführen > Hinzufügen, Löschen, Ändern und Abfragen über die Sitzung 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 Das Obige ist der vollständige Inhalt dieses Artikels. Ich hoffe, er wird für jedermanns Studium hilfreich sein. Ich hoffe auch, dass jeder 123WORDPRESS.COM unterstützen wird. Das könnte Sie auch interessieren:
|
Apache SkyWalking Apache SkyWalking ist ein Tool ...
Inhaltsverzeichnis 1. Problembeschreibung 2. Prob...
In diesem Artikelbeispiel wird der spezifische Co...
Wenn Sie das Win10-System installiert haben und e...
Dieses Tag ist nicht Teil von HTML3.2 und unterstü...
Erweiterte MySQL-SQL-Anweisungen benutze kgc; Tab...
Da meine lokale MySQL-Version relativ niedrig ist...
In diesem Artikel wird der Beispielcode für den C...
Dieses Mal schauen wir uns ein Navigationsleisten...
Auf der Seite werden externe Dateien wie JS, CSS u...
Quelle: https://medium.com/better-programming, Au...
Privot ist die Zwischentabelle von Viele-zu-viele...
In diesem Artikel wird die Verwendung von „Explai...
Vorwort Wir alle wissen, dass unter Linux „alles ...
Ich habe vor Kurzem ein Testserver-Betriebssystem...