Insert "ignore" to SQL statement.

diff --git a/seewasser.py b/seewasser.py
index ecd67d6ad8d514f1e4428e0bdc6d03cefe54c90d..be5f149ea49e8afd6660e5113756ca1c91b4b616 100755 (executable)
--- a/seewasser.py
+++ b/seewasser.py
@@ -8,7 +8,7 @@ import sys
 import csv
 import os
 import configparser
 import csv
 import os
 import configparser

-from sqlalchemy import create_engine, exc
+from sqlalchemy import create_engine

 import warnings
 import MySQLdb.cursors
 
 import warnings
 import MySQLdb.cursors
 


@@ -77,17 +77,9 @@ def writesensordatadb(config, sensor_id, sensor_name, timestamp, value_type, val
     engine = create_engine('mysql+mysqldb://{}:{}@{}/{}'.format(user, pwd, host, db), echo=False)
     conn = engine.connect()
     with warnings.catch_warnings():
     engine = create_engine('mysql+mysqldb://{}:{}@{}/{}'.format(user, pwd, host, db), echo=False)
     conn = engine.connect()
     with warnings.catch_warnings():

-        # ignore _mysql_exceptions.IntegrityError: (1062, "Duplicate entry '0316a2193bff-2018-08-29 14:30:00' for key 'sensorid_timestamp'")
-        # TODO: the following doesn't work
+        # ignore _mysql_exceptions.Warning: Duplicate entry '0316a2193bff-2018-08-29 14:30:00' for key 'sensorid_timestamp'

         warnings.simplefilter("ignore", category=MySQLdb.cursors.Warning)
         warnings.simplefilter("ignore", category=MySQLdb.cursors.Warning)

-        # TODO: this does but …?!
-        try:
-            conn.execute("insert into sensors (sensor_id, sensor_name, value_type, value_raw, value, timestamp) values (%s,%s,%s,%s,%s,%s)", sensor_id, sensor_name, value_type, value_raw, value, timestamp)
-        except exc.IntegrityError as e:
-            if "1062" in str(e):
-                pass
-            else:
-                raise
+        conn.execute("insert ignore into sensors (sensor_id, sensor_name, value_type, value_raw, value, timestamp) values (%s,%s,%s,%s,%s,%s)", sensor_id, sensor_name, value_type, value_raw, value, timestamp)

     conn.close()
 
 
     conn.close()