#! /usr/bin/env python3.5

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


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

SENSOR_IDS = range(23, 35)

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, '%d.%m.%Y %H:%i') as date, sensor, id, h FROM data_hydrolevel WHERE sensor = '%s';"
    cursor.execute(query, (sensor_id,))

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

    cursor.close()

cnx.close()