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 char(6) 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;
        );
    ''')