import psycopg2
import pybreaker
import time
from datetime import datetime

db_breaker = pybreaker.CircuitBreaker(fail_max=2, reset_timeout=60)

insert_sql = """INSERT INTO account(username, password, email, created_on, last_login) VALUES(%s, %s, %s, %s, %s)"""

username = 'username'
password = 'password'
email = 'email@email.com'

@db_breaker
def insert_row():
    print('LOGGER | Current PyBreaker STATE: ' + db_breaker.current_state)

    db_connection = None
    db_cursor = None

    try:
        db_connection = psycopg2.connect(db_url)
        db_cursor = db_connection.cursor()
    except:
        raise Exception('EXCEPTION: Error connecting to database!')

    print('LOGGER | Successfully connected to database!')

    created_on = datetime.now()
    last_login = datetime.now()

    print('LOGGER | Current PyBreaker STATE: ' + db_breaker.current_state)

    try:
        db_cursor.execute(insert_sql, (username, password, email, created_on, last_login))
        db_connection.commit()
        print('LOGGER | Successfully inserted row to database!')
    except:
        raise Exception("EXCEPTION: Error inserting to database!")


    db_cursor.close()
    db_connection.close()
    print('LOGGER | Successfully closed connection to database!')


while True:
    try:
        insert_row()
    except Exception as e:
        print('LOGGER | Error occured in insert_row function!')
        print(e)
    print('LOGGER | Current PyBreaker STATE: ' + db_breaker.current_state)
    print('LOGGER | INITIATED 10 seconds WAIT...')
    time.sleep(10)