@@ -112,6 +112,18 @@ func NetworkAddress(host string, port uint16) (network, address string) {
|
|||||||
return network, address
|
return network, address
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// NewConfig returns an *Config without parsing a connection string or reading the standard PG* environment variables.
|
||||||
|
// Host, Port, Database, User, and Password must be set before the config can be used to establish a connection.
|
||||||
|
func NewConfig() *Config {
|
||||||
|
return &Config{
|
||||||
|
DialFunc: makeDefaultDialer().DialContext,
|
||||||
|
LookupFunc: makeDefaultResolver().LookupHost,
|
||||||
|
BuildFrontend: makeDefaultBuildFrontendFunc(8192),
|
||||||
|
RuntimeParams: map[string]string{},
|
||||||
|
createdByParseConfig: true,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
// ParseConfig builds a *Config with similar behavior to the PostgreSQL standard C library libpq. It uses the same
|
// ParseConfig builds a *Config with similar behavior to the PostgreSQL standard C library libpq. It uses the same
|
||||||
// defaults as libpq (e.g. port=5432) and understands most PG* environment variables. connString may be a URL or a DSN.
|
// defaults as libpq (e.g. port=5432) and understands most PG* environment variables. connString may be a URL or a DSN.
|
||||||
// It also may be empty to only read from the environment. If a password is not supplied it will attempt to read the
|
// It also may be empty to only read from the environment. If a password is not supplied it will attempt to read the
|
||||||
@@ -154,7 +166,7 @@ func NetworkAddress(host string, port uint16) (network, address string) {
|
|||||||
// See https://www.postgresql.org/docs/11/libpq-connect.html#LIBPQ-PARAMKEYWORDS for parameter key word names. They are
|
// See https://www.postgresql.org/docs/11/libpq-connect.html#LIBPQ-PARAMKEYWORDS for parameter key word names. They are
|
||||||
// usually but not always the environment variable name downcased and without the "PG" prefix.
|
// usually but not always the environment variable name downcased and without the "PG" prefix.
|
||||||
//
|
//
|
||||||
// Important TLS Security Notes:
|
// Important Security Notes:
|
||||||
//
|
//
|
||||||
// ParseConfig tries to match libpq behavior with regard to PGSSLMODE. This includes defaulting to "prefer" behavior if
|
// ParseConfig tries to match libpq behavior with regard to PGSSLMODE. This includes defaulting to "prefer" behavior if
|
||||||
// not set.
|
// not set.
|
||||||
@@ -162,6 +174,13 @@ func NetworkAddress(host string, port uint16) (network, address string) {
|
|||||||
// See http://www.postgresql.org/docs/11/static/libpq-ssl.html#LIBPQ-SSL-PROTECTION for details on what level of
|
// See http://www.postgresql.org/docs/11/static/libpq-ssl.html#LIBPQ-SSL-PROTECTION for details on what level of
|
||||||
// security each sslmode provides.
|
// security each sslmode provides.
|
||||||
//
|
//
|
||||||
|
// The sslmode "prefer" (the default), sslmode "allow", and multiple hosts are implemented via the Fallbacks field of
|
||||||
|
// the Config struct. If the main TLS config is manually changed it will not affect the fallbacks. For example, in the
|
||||||
|
// case of sslmode "prefer" this means it will first try the main Config settings which use TLS, then it will try
|
||||||
|
// the fallback which does not use TLS. This can lead to an unexpected unencrypted connection if the main TLS config
|
||||||
|
// is manually changed later but the unencrypted fallback is present. Remove or update all fallbacks or use NewConfig
|
||||||
|
// to build the config manually.
|
||||||
|
//
|
||||||
// Other known differences with libpq:
|
// Other known differences with libpq:
|
||||||
//
|
//
|
||||||
// If a host name resolves into multiple addresses, libpq will try all addresses. pgconn will only try the first.
|
// If a host name resolves into multiple addresses, libpq will try all addresses. pgconn will only try the first.
|
||||||
|
|||||||
@@ -198,6 +198,24 @@ func TestConnectWithConnectionRefused(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestConnectConfigFromNewConfig(t *testing.T) {
|
||||||
|
t.Parallel()
|
||||||
|
|
||||||
|
baseConfig, err := pgconn.ParseConfig(os.Getenv("PGX_TEST_CONN_STRING"))
|
||||||
|
require.NoError(t, err)
|
||||||
|
|
||||||
|
config := pgconn.NewConfig()
|
||||||
|
config.Host = baseConfig.Host
|
||||||
|
config.Port = baseConfig.Port
|
||||||
|
config.Database = baseConfig.Database
|
||||||
|
config.User = baseConfig.User
|
||||||
|
config.Password = baseConfig.Password
|
||||||
|
|
||||||
|
conn, err := pgconn.ConnectConfig(context.Background(), config)
|
||||||
|
require.NoError(t, err)
|
||||||
|
closeConn(t, conn)
|
||||||
|
}
|
||||||
|
|
||||||
func TestConnectCustomDialer(t *testing.T) {
|
func TestConnectCustomDialer(t *testing.T) {
|
||||||
t.Parallel()
|
t.Parallel()
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user