#!/usr/bin/python

import psycopg2

def getconnection(dbname, user, password, host, port):
    try:
        conn = psycopg2.connect("dbname="+dbname+" user="+user+" password="+password+" host="+host+" port="+port)
        print('CONNECTION SUCCESSFUL')
        return conn
    except:
        print('CONNECTION FAILED')


def insert(conn, sql):
    cur = conn.cursor()
    try:
        cur.execute(sql)
        conn.commit()
        print('INSERT SUCCESSFUL')
    except:
        print('INSERT FAILED')


def delete(conn,sql):
    cur = conn.cursor()
    try:
        cur.execute(sql)
        conn.commit()
        print('DELETE SUCCESSFUL')
    except:
        print('DELETE FAILED')


def update(conn,sql):
    cur = conn.cursor()
    try:
        cur.execute(sql)
        conn.commit()
        print('UPDATE SUCCESSFUL')
    except:
        print('UPDATE FAILED')


def select(conn, sql, limit=):
    cur = conn.cursor()
    try:
        cur.execute(sql)
        print('SELECT SUCCESSFUL')
        rows = cur.fetchall()
        print('Rows: ')
        for row in rows:
            siz = len(row)
            for i in range(0,siz):
                print(row[i], end=' ')
            print('')
    except:
        print('SELECT FAILED')