PostgreSQL
 sql >> Database >  >> RDS >> PostgreSQL

Come connettere (Py)Spark al database Postgres usando JDBC

I problemi con la risoluzione dei nomi sono indicati da org.postgresql.util.PSQLException e non si traducono in NPE. L'origine del problema è in realtà una stringa di connessione e in particolare il modo in cui fornisci le credenziali dell'utente. A prima vista sembra un bug, ma se stai cercando una soluzione rapida puoi utilizzare le proprietà dell'URL:

url = 'jdbc:postgresql://PG_SERVER_IP/db_name?user=PG_USER&password=PASSWORD'

o argomento proprietà:

properties = {
    "user": "PG_USER",
    "password": "PASSWORD",
    "driver": "org.postgresql.Driver"
}