import psycopg2
import json
"""
Get credentials from Kubernetes. The credentials were set up as a dictionary. For example:
{
    "username": "USERNAME",
    "password": "PASSWORD"
}
"""
credentials = None
with open('/var/run/secrets/user_credentials/postgres_credentials') as f:
    credentials = json.load(f)
# Verify the credentials were pulled correctly
if credentials:
    # Connect to the database
    conn = None
    try:
        conn = psycopg2.connect(
            dbname=credentials.get('db_name'),
            host=credentials.get('host_name'),
            user=credentials.get('username'),
            password=credentials.get('password')
        )
    except:
        print("I am unable to connect to the database")
    # Get a cursor and execute select statement
    cur = conn.cursor()
    cur.execute("""SELECT * from playground""")
    rows = cur.fetchall()
    # Print out the results
    for row in rows:
        print(row)
    # Close the connection when finished
    conn.close()