commit 8a8fed9c7ddd78b1bc63718ca06b1410c68a307d Author: Jadowyne Ulve Date: Tue Sep 24 19:01:50 2024 -0500 first test diff --git a/__pycache__/config.cpython-312.pyc b/__pycache__/config.cpython-312.pyc new file mode 100644 index 0000000..cc28c84 Binary files /dev/null and b/__pycache__/config.cpython-312.pyc differ diff --git a/config.py b/config.py new file mode 100644 index 0000000..e131417 --- /dev/null +++ b/config.py @@ -0,0 +1,21 @@ +#!/usr/bin/python +from configparser import ConfigParser + + +def config(filename='database.ini', section='postgresql'): + # create a parser + parser = ConfigParser() + # read config file + parser.read(filename) + + # get section, default to postgresql + db = {} + if parser.has_section(section): + params = parser.items(section) + for param in params: + db[param[0]] = param[1] + else: + raise Exception('Section {0} not found in the {1} file'.format(section, filename)) + + return db + diff --git a/database.ini b/database.ini new file mode 100644 index 0000000..4b683f2 --- /dev/null +++ b/database.ini @@ -0,0 +1,6 @@ +[postgresql] +host=192.168.1.67 +database=test +user=test +password=test +port=5432 \ No newline at end of file diff --git a/main.py b/main.py new file mode 100644 index 0000000..abd19d2 --- /dev/null +++ b/main.py @@ -0,0 +1,38 @@ +#!/usr/bin/python +import psycopg2 +from config import config + +def connect(): + """ Connect to the PostgreSQL database server """ + conn = None + try: + # read connection parameters + params = config() + + # connect to the PostgreSQL server + print('Connecting to the PostgreSQL database...') + conn = psycopg2.connect(**params) + + # create a cursor + cur = conn.cursor() + + # execute a statement + print('PostgreSQL database version:') + cur.execute('SELECT version()') + + # display the PostgreSQL database server version + db_version = cur.fetchone() + print(db_version) + + # close the communication with the PostgreSQL + cur.close() + except (Exception, psycopg2.DatabaseError) as error: + print(error) + finally: + if conn is not None: + conn.close() + print('Database connection closed.') + + +if __name__ == '__main__': + connect()