#psycopg2 execute #sql from #python

psycopg2_execute_sql.py

import psycopg2
import logging

    
def execute_sql(sql, conn_str):
    
    conn =  psycopg2.connect(conn_str)
    cursor = conn.cursor()
    
    try:
        cursor.execute(sql)
        conn.commit()
        
    except Exception as e:
        print(sql, e)
        logging.info(e)
        conn.commit()

        
        

DB_DATABASE= ''
DB_HOST= ''
DB_PASSWORD= ''
DB_PORT= ""
DB_USERNAME= ''


conn_str = f"dbname='{DB_DATABASE}' user='{DB_USERNAME}' password='{DB_PASSWORD}' host='{DB_HOST}' port={DB_PORT}"


sql= '''

'''


execute_sql(sql, conn_str=conn_str)