[Gelöst] Python3 Werte mit Variable in mariadb schreiben

fred0815 · Feb 8th 2023

Ich habe eine mariadb mit der Datenbank lokalerbme280 aufgesetzt und dort eine Tabelle daten.

Dort möchte ich vier Werte vom Sensor BME280 speichern: temperatur, luftdruck, luftfeuchtigkeit und datumzeit.

Dazu habe ich dieses Script:

Python

#!/usr/bin/env python3
import time
import datetime
import mysql.connector
from mysql.connector import errorcode
import bme280
import smbus2

port = 1
address = 0x76
bus = smbus2.SMBus(port)
calibration_params = bme280.load_calibration_params(bus, address)
data = bme280.sample(bus, address, calibration_params)
print(data.id)
print(data.timestamp)
print(data.temperature)
print(data.pressure)
print(data.humidity)

datumzeit=(datetime.datetime.now().strftime('%y-%m-%d %H:%M:%S'))
temperatur=float('%.2f' % data.temperature)
print(temperatur)
luftdruck=float('%.2f' % data.pressure)
print(luftdruck)
luftfeuchtigkeit=float('%.2f' % data.humidity)
print(luftfeuchtigkeit)
print(datumzeit)

db = mysql.connector.connect(user='lokalerbme280', password='geheim', host='127.0.0.1', database='lokalerbme280')
cursor = db.cursor()
cursor.execute('INSERT INTO daten (temperatur, luftdruck, luftfeuchtigkeit, datumzeit) VALUES (temperatur, luftdruck, luftfeuchtigkeit, datumzeit)'
db.commit()
cursor.close()
db.close()

Display More

Dabei bekomme ich die Fehlermeldung:

Code

    db.commit()
    ^
SyntaxError: invalid syntax

Vermutlich liegt der Fehler in der Zeile darüber, aber egal, was ich probiere, es mag nicht funktionieren.

Da ich mit meinem Latein am Ende bin, frage ich mal in die Runde.

Wo liegt mein Fehler ?

Bot · Vor 5 Minuten

Schau mal ob du hier fündig wirst!

KKoPi · Feb 8th 2023

Quote from fred0815

cursor.execute('INSERT INTO daten (temperatur, luftdruck, luftfeuchtigkeit, datumzeit) VALUES (temperatur, luftdruck, luftfeuchtigkeit, datumzeit)'

Du willst doch die Variablenwerte einfügen, so ist es Syntax-Error ...

Und zeig mal das CREATE TABLE

DeaD_EyE · Feb 8th 2023

Code

cursor.execute('INSERT INTO daten (temperatur, luftdruck, luftfeuchtigkeit, datumzeit) VALUES (temperatur, luftdruck, luftfeuchtigkeit, datumzeit)'

Eine Zeile davor fehlt die runde Klammer am Ende.

Code

cursor.execute('INSERT INTO daten (temperatur, luftdruck, luftfeuchtigkeit, datumzeit) VALUES (temperatur, luftdruck, luftfeuchtigkeit, datumzeit)')

Wo sind denn die Werte?!

Bei sqlite3 kann man Platzhalter für Werte setzen. Das verhindert unter anderem eine mögliche SQL-injection (;DROP TABLE daten;).

Code

cursor.execute(
    'INSERT INTO daten (temperatur, luftdruck, luftfeuchtigkeit, datumzeit) VALUES (?, ?, ?, ?)',
    (20.0, 1.0, 0.48, "2022-08-02T12:23:00"),
)

Das zweite Argument ist eine Tupel mit den Werten, die eingefügt werden sollen.

Die Werte werden der DB nicht einfach blind übergeben, sondern Steuerzeichen innerhalb der Werte werden sozusagen auskommentiert, damit SQL-Statements in Werten nicht als Code ausgeführt werden.

Bot · Vor einem Moment

Schau mal ob du hier fündig wirst:

__blackjack__ · Feb 8th 2023

Was sind denn ``float('%.2f' % data.temperature)`` für Aktionen? Theoretisch könnte man die Werte ja runden bevor man sie speichert, aber wenn dann nicht *so*, aber eigentlich stellt sich auch die Frage warum überhaupt? Einfach in die Datenbank schreiben und gut ist. Man könnte *dort* die Anzahl der Nachkommastellen bei der Spaltendefinition angeben wenn man mag, oder bei der Abfrage runden, oder bei der Darstellung nach der Abfrage.

Die Spalte `datumzeit` sollte in der Datenbank einen passenden Typ haben und nicht als Zeichenkette gespeichert werden. Also beispielsweise den SQL-Typ TIMESTAMP. Und dann speichert man ein `datetime`-Objekt in der Datenbank und keine Zeichenkette. Dann bekommt man auch keine Probleme mit irgendwelchen Locale-Einstellungen in welchem Format ein Zeitstempel als Zeichenkette von der Datenbank erwartet/geliefert wird.

`time` und `errorcode` aus `mysql.connector` werden importiert, aber nirgends verwendet.

Das schliessen von Datenbankverbindung und Cursor sichert man am besten mit ``with`` und `contextlib.closing()` ab.

Zwischenstand (ungetestet):

Python

#!/usr/bin/env python3
import datetime
from contextlib import closing

import bme280
import mysql.connector
import smbus2


def main():
    port = 1
    address = 0x76
    bus = smbus2.SMBus(port)
    calibration_params = bme280.load_calibration_params(bus, address)
    data = bme280.sample(bus, address, calibration_params)
    print(data.id)
    print(data.timestamp)
    print(data.temperature)
    print(data.pressure)
    print(data.humidity)

    datumzeit = datetime.datetime.now()
    print(datumzeit)
    
    with closing(
        mysql.connector.connect(
            user="lokalerbme280",
            password="geheim",
            host="127.0.0.1",
            database="lokalerbme280",
        )
    ) as db:
        with closing(db.cursor()) as cursor:
            cursor.execute(
                (
                    "INSERT INTO daten (temperatur, luftdruck,"
                    "                   luftfeuchtigkeit, datumzeit)"
                    " VALUES (?, ?, ?, ?)"
                ),
                [data.temperature, data.pressure, data.humidity, datumzeit],
            )
            db.commit()


if __name__ == "__main__":
    main()

Display More

Warum wird eigentlich `datumzeit` definiert wenn es doch ein `data.timestamp` gibt?

Man muss sich bei lokalen Zeitstempeln auch immer klar machen, dass es so Sachen wie Sommer/Winterzeit-Umstellung gibt die man bei der Auswertung dann berücksichtigen muss, oder zweimal im Jahr ”komische” Zeit-/Werteverläufe hat.

fred0815 · Feb 13th 2023

Gelöst, da hat ein prepared=True bei cursor = db.cursor() gefehlt:

Python

#!/usr/bin/env python3
import time
import datetime
import mysql.connector
from mysql.connector import errorcode
import bme280
import smbus2

port = 1
address = 0x76
bus = smbus2.SMBus(port)
calibration_params = bme280.load_calibration_params(bus, address)
data = bme280.sample(bus, address, calibration_params)
print(data.id)
print(data.timestamp)
print(data.temperature)
print(data.pressure)
print(data.humidity)

datumzeit=(datetime.datetime.now().strftime('%y-%m-%d %H:%M:%S'))

temperatur=round(data.temperature, 2)
print(temperatur)

luftdruck=round( data.pressure, 2)
print(luftdruck)

luftfeuchtigkeit=round(data.humidity, 2)
print(luftfeuchtigkeit)

db = mysql.connector.connect(user='lokalerbme280', password='geheim', host='localhost', database='lokalerbme280')
cursor = db.cursor(prepared=True)
sql = "INSERT INTO Daten (temperatur, luftdruck, luftfeuchtigkeit, datumzeit) VALUES (%s, %s, %s, %s)"
val = (temperatur, luftdruck, luftfeuchtigkeit, datumzeit)
cursor.execute(sql,val)
db.commit()
print(cursor.rowcount, "Daten geschrieben")
cursor.close()
db.close()

Display More

DeaD_EyE · Feb 13th 2023

Datenbanken mögen es nicht, wenn Felder mit den falschen Datentypen befüllt werden sollen. Die einzige völlig schmerzfreie relationale Datenbank, die ich kenne, ist sqlite3.

Du musst float übergeben, wenn die Felder float sind. Du übergibst str, was der falsche Datentyp ist. Manche Konnektoren machen eine automatische Konvertierung, aber darauf sollte man sich nicht verlassen.

Man kann auch nicht alle Beispiele von sqlite3 auf MySQL übertragen.

Ich denke mal, dass MySQL (mariadb) auch ein paar mehr Datentypen kennt, als sqlite3.

Die Werte überträgst du übrigens immer noch im Query, das sich zum Hacken wunderbar ausnutzen lässt, wenn die Daten z.B. von einem Benutzer eingegeben werden und ungeprüft in den Query übernommen werden. Deswegen hat man die Möglichkeit, Query und Daten getrennt der execute-Methode zu übergeben.

Gültiger SQL-Syntax in Daten wird unwirksam gemacht.

Bot · Vor einem Moment

Schau mal ob du hier fündig wirst:

fred0815 · Feb 14th 2023

Quote from DeaD_EyE

Du musst float übergeben, wenn die Felder float sind. Du übergibst str, was der falsche Datentyp ist. Manche Konnektoren machen eine automatische Konvertierung, aber darauf sollte man sich nicht verlassen.

In der Datenbank sind die Spalten bis auf datumzeit auf float gestellt, damit sollte es doch auch als float in der db sein, oder ?

Wenn ich im Script versuche, die Werte als float zu übergebgen, bekomme ich ja den Syntaxfehler.

Quote from DeaD_EyE

Die Werte überträgst du übrigens immer noch im Query, das sich zum Hacken wunderbar ausnutzen lässt, wenn die Daten z.B. von einem Benutzer eingegeben werden und ungeprüft in den Query übernommen werden. Deswegen hat man die Möglichkeit, Query und Daten getrennt der execute-Methode zu übergeben.

Ich wüsste auch nicht wie es anders geht, mein Kontakt mit mysql beschränkt sich auf meine Schulzeit von anno dazumals.

Aber der Benutzer lokalerbme280 hat ja seine eigene, gleichnamige Datenbank und darf dort nur INSERT durchführen, die Datenbank akzeptiert auch nur localhost. Könnte das trotzdem ein Problem sein ?

[Gelöst] Python3 Werte mit Variable in mariadb schreiben

Similar Threads

Schreibzyklus SD Karte mit Datenbank und Sensor

PYthon Script beendet sich von alleine