bh3a-Icetruck-Challenge-1-3/Pi-py-Code/protocoll.py

import mysql.connector
from mysql.connector import errorcode
from tmp_0x09 import get_temp


# MySQL database connection setup
config_local = {
    'user': 'root',       # dein MySQL-Benutzername
    'password': '',       # dein MySQL-Passwort (standardmäßig leer bei XAMPP)
    'host': '127.0.0.1',
    'database': 'arduino',
    'raise_on_warnings': True
}

config_cloud = {
    'user': 'moritz',       # dein MySQL-Benutzername
    'password': 'T3st1234',       # dein MySQL-Passwort (standardmäßig leer bei XAMPP)
    'host': 'icetruck.mysql.database.azure.com',
    'database': 'arduino',
    'raise_on_warnings': True
}

def insert_data(temp, sensor_id, config):
    try:
        cnx = mysql.connector.connect(**config)
        cursor = cnx.cursor()
        add_data = ("INSERT INTO sensordaten "
                    "(temperatur, sensor_id) "
                    "VALUES (%s, %s)")
        data = (temp, sensor_id)
        cursor.execute(add_data, data)
        cnx.commit()
        cursor.close()
        cnx.close()
        print(f'Daten erfolgreich eingefügt in: {config["host"]}')
    except mysql.connector.Error as err:
        if err.errno == errorcode.ER_ACCESS_DENIED_ERROR:
            print("Etwas ist mit deinem Benutzernamen oder Passwort falsch.")
            print(f'Datenbank: {config["host"]}')
        elif err.errno == errorcode.ER_BAD_DB_ERROR:
            print("Die Datenbank existiert nicht.")
            print(f'Datenbank: {config["host"]}')
        else:
            print(err)
            print(f'Datenbank: {config["host"]}')

if __name__ == '__main__':
    while True: 
        insert_data(get_temp(0x09), 1, config_cloud)
        insert_data(get_temp(0x0a), 2, config_cloud)
        insert_data(get_temp(0x0b), 3, config_cloud)
        insert_data(get_temp(0x09), 1, config_local)
        insert_data(get_temp(0x0a), 2, config_local)
        insert_data(get_temp(0x0b), 3, config_local)