#!/usr/bin/env python3
# -*- coding: utf-8 -*-

#benötigte Bibliotheken
import mariadb
import time

db_user = "wettergott"
db_password ="Chilli07"
db_host="localhost"
db_port = 3306
db_name="wetter"

# Funktion zum Schreiben von Werten in die Datenbank
def write_to_database(temperatur, fan_speed):
    try:
        # Verbindung zur Datenbank herstellen
        db = mariadb.connect(
            user=db_user,
            password=db_password,
            host=db_host,
            port=db_port,
            database=db_name
            )
        #print("Verbunden")
        # Cursor erstellen
        cursor = db.cursor(prepared=True)

        # SQL-Befehl zum Einfügen von Daten
        sql_command = """
            INSERT INTO hermes4_serverbox (temp,fan_speed) 
            VALUES(%s,%s);"""
        
        # Daten für den Eintrag
        eintrag = (temperatur,fan_speed)

         # Befehl ausführen und Änderungen speichern
        cursor.execute(sql_command, eintrag)
        db.commit()

        # Cursor und Datenbankverbindung schließen
        cursor.close()
        db.close()

    except mariadb.Error as e:
        print(f"Error connecting to MariaDB Platform: {e}")

# Hauptfunktion
def main():
    # Dummy-Werte für Temperatur und Lüftergeschwindigkeit
    temperature = 34
    fan_speed = 55
    
    # Endlosschleife zum Schreiben von Daten in die Datenbank
    while True:
        # Daten in die Datenbank schreiben
        write_to_database(temperature, fan_speed)
        
        # 5 Sekunden warten, bevor der nächste Eintrag erfolgt
        time.sleep(5)

if __name__ == "__main__":
    main()