def __init__(self) -> None:

self.db = psycopg2.connect(host=pcon['host'], dbname=pcon['db'],

user=pcon['user'], port=pcon['port'], password=pcon['password'])

self.cursor = self.db.cursor()

def __del__(self):

self.cursor.close()

self.db.close()

print('db 연결 종료')

def execute(self, query, args={}):

self.cursor.execute(query, args)

row = self.cursor.fetchall()

return row

def commit(self):

self.db.commit()

def insertDB(self, query):

try:

self.cursor.execute(query)

self.db.commit()

except Exception as e:

print(" insert DB err", e)

def readDB(self, query):

try:

self.cursor.execute(query)

result = self.cursor.fetchall()

except Exception as e:

result = (" read DB err", e)