#! /usr/bin/env python3.5

import csv # import standart library csv
import mysql.connector # import library mysql.connector
from mysql.connector import errorcode # import library errorcod from mysql.conn


# db configuration
DB_CONFIG = dict(
    user='root',
    password='t00r0DGn1',
    host='localhost',
    database='odgn'
)

SENSOR_IDS = range(23, 45)

try:
    cnx = mysql.connector.connect(**DB_CONFIG) # open connection to the MySQL server and store the conn object in the variable cnx

except mysql.connector.Error as err:
    if err.errno == errorcode.ER_ACCESS_DENIED_ERROR:
        raise Exception("Something is wrong with your user name or password")

    elif err.errno == errorcode.ER_BAD_DB_ERROR:
        raise Exception("Database does not exist")

    else:
        raise Exception(err)


cursor = cnx.cursor() # create a new cursor

for sensor_id in SENSOR_IDS:

    query = "SELECT date_format(date, ''"'%Y-%m-%d %H:%i:%S'"'') as date, sensor, id, h FROM data_hydrolevel WHERE sensor = '%s';"
    cursor.execute(query, (sensor_id,))

    with open('file_sensor_%s.dat' % sensor_id, 'a') as f:
        writer = csv.writer(f, delimiter=';')
        writer.writerows(cursor)

cursor.close()

cnx.close()