Tabellen Überwachen und CSV Datei erstellen

Moin Herr Stark,gibt es einen Heater, der bestimmte MySQL Tabellen überwacht und sobald ein neuer Eintrag passiert, eine CSV Datei erstellt werden kann?

Konkret:

Wir lesen in unser Datenbank Sendungsnummern zu Aufträgen ein. Jetzt sollte, sobald einen neue Sendungsnummer in die Datenbank geschrieben wird, eine csv von diesem Auftag mit Kundendaten, Sendungsnummer usw. aus weiteren, verschiedenen SQL Tabellen/Feldern erstellt werden.

Grüße,
Patrick Stelling

Hallo Herr Stelling,

leider können aus MySQL Datenbank Triggern heraus keine Dateien direkt erzeugt werden, so dass nur die Option bleibt die Tabelle alle X Sekunden/Minuten auf neue Datensätze abzufragen. Wie niedrig bzw. hoch das Abfrageintervall gesetzt wird, hängt von Ihren Anforderungen ab. Am einfachsten geht das Aufsetzen eines solchen Task über den FlowHeater Server, alternativ kann aber auch die Windows Aufgabenplanung dazu verwendet werden.

Die Definition, die Sie erstellen, braucht in der Datenbank ein eindeutiges aufsteigendes Feld. Das ist im Idealfall der Primary Key, worüber bei jedem Start nur neue Datensätze abgefragt werden können. In Ihrem Fall könnte das die Sendungsnummer sein? Wenn diese eindeutig und fortlaufend ist geht das folgendermaßen.

Zuerst benötigen Sie in der Definition einen FlowHeater Parameter z.B. $LAST$
Diesen legen Sie über "Menü->Bearbeiten->Parameter" an und aktivieren die Option speichern. Achtung: wenn das Datenbankfeld eine Zahl ist (Auto Increment) dann müssen Sie den Parameter ohne Tausendtrennzeichen formatiert speichern, siehe Screenshot.

So merkt sich der FlowHeater den zuletzt verarbeiteten Datensatz über die Sendungsnummer. Der FlowHeater legt dazu nach erfolgreicher Ausführung eine weitere Datei mit der Endung „.fhpara“ an und merkt sich in dieser Datei die letzten Werte. Der Dateiname ist gleich dem Namen der Definition. Beim nächsten Start liest der FlowHeater die Parameter aus dieser Datei ein und initialisiert diese mit diesen Werten. Hinweis: Es können beliebig viele Parameter hier gespeichert werden.

Auf der READ Seite im MySQL Adapter verwenden Sie nun diesen Parameter um alle Datensätze abzufragen die größer der letzten Abfrage waren.

    z.B. über „ select * from t_Sendungen where `Sendungsnummer` > $LAST$ order by Sendungsnummer”

Der Paramater muss während der Verarbeitung auf den jeweils aktuellen Wert gesetzt werden, um das Speichern kümmert sich der FlowHeater.

Dann brauchen Sie noch einen weiteren Parameter (nicht $LAST$) der die aktuelle Sendungsnummer beinhaltet. Wichtig: Mit Version 4.5.0 wurde eingebaut, dass wenn keine Daten verarbeitet werden, der TextFile Adapter die angegeben Datei löscht, falls nicht an eine vorhandene Datei angefügt werden soll. Wenn Sie nun $LAST$ nehmen, würde bei einer Ausführung, die keine Daten verarbeitet die letzte exportierte Datei gelöscht werden, falls diese noch im Ausgabeordner vorhanden ist!

Diesen zweiten Parameter verwenden Sie nun auf der WRITE Seite im Dateinamen vom TextFile Adapter

     z.B. Sendung_$SendNR$.txt

So erstellt der TextFile Adapter automatisch pro Sendungsnummer eine separate Datei, der Parameter wird automatisch mit der aktuellen Sendungsnummer ersetzt.

Im Anhang finden Sie ein kleines Beispiel dazu.