Function parse_pg_conn_string

misc/python/materialize/util.py:199–212

Not supported natively by pg8000, so we have to parse ourselves

(conn_string: str)

def parse_pg_conn_string(conn_string: str) -> PgConnInfo:
    """Not supported natively by pg8000, so we have to parse ourselves"""
    url = urlparse(conn_string)
    query_params = parse_qs(url.query)
    assert url.username
    assert url.hostname
    return PgConnInfo(
        user=unquote(url.username),
        password=unquote(url.password) if url.password else url.password,
        host=url.hostname,
        port=url.port or 5432,
        database=url.path.lstrip("/"),
        ssl=query_params.get("sslmode", ["disable"])[-1] != "disable",
    )


FILTERED_ARGS = [