The naming really matters

pull/224/head
Kris Wehner 2017-01-05 12:50:42 -08:00
parent 24f06aed9a
commit d9a80caaad
3 changed files with 5 additions and 9 deletions

View File

@ -14,7 +14,7 @@ var plainPasswordConnConfig *pgx.ConnConfig = nil
var invalidUserConnConfig *pgx.ConnConfig = nil
var tlsConnConfig *pgx.ConnConfig = nil
var customDialerConnConfig *pgx.ConnConfig = nil
var replicationConfig *pgx.ConnConfig = nil
var replicationConnConfig *pgx.ConnConfig = nil
// var tcpConnConfig *pgx.ConnConfig = &pgx.ConnConfig{Host: "127.0.0.1", User: "pgx_md5", Password: "secret", Database: "pgx_test"}
// var unixSocketConnConfig *pgx.ConnConfig = &pgx.ConnConfig{Host: "/private/tmp", User: "pgx_none", Database: "pgx_test"}

View File

@ -15,13 +15,12 @@ var plainPasswordConnConfig = &pgx.ConnConfig{Host: "127.0.0.1", User: "pgx_pw",
var invalidUserConnConfig = &pgx.ConnConfig{Host: "127.0.0.1", User: "invalid", Database: "pgx_test"}
var tlsConnConfig = &pgx.ConnConfig{Host: "127.0.0.1", User: "pgx_ssl", Password: "secret", Database: "pgx_test", TLSConfig: &tls.Config{InsecureSkipVerify: true}}
var customDialerConnConfig = &pgx.ConnConfig{Host: "127.0.0.1", User: "pgx_md5", Password: "secret", Database: "pgx_test"}
var pgVersion string
var replicationConfig *pgx.ConnConfig = nil
var replicationConnConfig *pgx.ConnConfig = nil
pgVersion = os.getenv("PGVERSION")
pgVersion := os.getenv("PGVERSION")
if len(pgVersion) > 0 {
version, err := strconv.ParseFloat(pgVersion)
if err == nil && version >= 9.6 {
replicationConfig = &pgx.ConnConfig{Host: "127.0.0.1", User: "pgx_replication", Password: "secret", Database: "pgx_test"}
replicationConnConfig = &pgx.ConnConfig{Host: "127.0.0.1", User: "pgx_replication", Password: "secret", Database: "pgx_test"}
}
}

View File

@ -40,15 +40,12 @@ func TestSimpleReplicationConnection(t *testing.T) {
t.Parallel()
var err error
var replicationUserConfig pgx.ConnConfig
// /.s.PGSQL.5432
if replicationConnConfig == nil {
t.Skip("Skipping due to undefined replicationConnConfig")
}
replicationUserConfig = *replicationConnConfig
conn := mustConnect(t, replicationUserConfig)
conn := mustConnect(t, *replicationConnConfig)
defer closeConn(t, conn)
replicationConnConfig.RuntimeParams = make(map[string]string)