postgresqlconn.py 文件源码

def __init__(self, dbname: str, isolation: str = "auto-commit"):
        # Establishes the connection with the backend databases.

        isolation_level = self.isolation_opts.get(isolation, psycopg2.extensions.ISOLATION_LEVEL_AUTOCOMMIT)
        try:
            if dbname == "YOUR_DATABASE_NAME":
                self.__conn = self.__pool.getconn()
                self.__conn.set_isolation_level(isolation_level)
            else:
                self.__pool = None
                self.__conn = None
        except psycopg2.pool.PoolError as e:
            self.__pool = None
            self.__conn = None
            raise(e)
        except Exception as e:
            tb.print_exc()
            raise(e)