import pandas as pd
import psycopg2 as psy


data = pd.read_csv(r'911.csv')
df = pd.DataFrame(data)
df2 = df.drop_duplicates()
co = None


try : 
    co = psy.connect(host='berlin',
        database = 'dbmalanone',
        user = 'malanone',
        password = 'azertyuiop')
    curs=co.cursor()

    curs.execute('''DROP TABLE IF EXISTS 911;''')

    curs.execute('''
        CREATE TABLE 911(
            latitude numeric NOT NULL,
            longitude numeric NOT NULL,
            description varchar(150) PRIMARY KEY,
            zipCode numeric NOT NULL,
            title varchar(50) NOT NULL,
            DateHeure timestamp NOT NULL CHECK DateHeure < CURRENT_TIMESTAMP,
            ville varchar(50) NOT NULL,
            adresse varchar(50) NOT NULL,
            indexColone char(1) DEFAULT = 1;
        );
    ''')

    for row in df2.intertuples():
        curs.execute(
        '''INSERT INTO 911 VALUES(%f%f%s%d%s%s%s%s%d)''',
        (row.Latitude, row.Longitude, row.Description, row.zipCode, row.Title, row.DateHeure, row.Ville, row.Adresse, row.indexColone)
        )


    curs.execute('''SELECT * FROM 911;''')

except(Exception, psy.DatabaseError) as error:
	print(error)
finally:
	if co is not None:
		co.close()