(t *testing.T)
| 301 | } |
| 302 | |
| 303 | func TestConnectTLSPasswordProtectedClientCertWithSSLPassword(t *testing.T) { |
| 304 | t.Parallel() |
| 305 | |
| 306 | ctx, cancel := context.WithTimeout(context.Background(), 120*time.Second) |
| 307 | defer cancel() |
| 308 | |
| 309 | connString := os.Getenv("PGX_TEST_TLS_CLIENT_CONN_STRING") |
| 310 | if connString == "" { |
| 311 | t.Skipf("Skipping due to missing environment variable %v", "PGX_TEST_TLS_CLIENT_CONN_STRING") |
| 312 | } |
| 313 | if os.Getenv("PGX_SSL_PASSWORD") == "" { |
| 314 | t.Skipf("Skipping due to missing environment variable %v", "PGX_SSL_PASSWORD") |
| 315 | } |
| 316 | |
| 317 | connString += " sslpassword=" + os.Getenv("PGX_SSL_PASSWORD") |
| 318 | |
| 319 | conn, err := pgconn.Connect(ctx, connString) |
| 320 | require.NoError(t, err) |
| 321 | |
| 322 | result := conn.ExecParams(ctx, `select ssl from pg_stat_ssl where pg_backend_pid() = pid;`, nil, nil, nil, nil).Read() |
| 323 | require.NoError(t, result.Err) |
| 324 | require.Len(t, result.Rows, 1) |
| 325 | require.Len(t, result.Rows[0], 1) |
| 326 | require.Equalf(t, "t", string(result.Rows[0][0]), "not a TLS connection") |
| 327 | |
| 328 | closeConn(t, conn) |
| 329 | } |
| 330 | |
| 331 | func TestConnectTLSPasswordProtectedClientCertWithGetSSLPasswordConfigOption(t *testing.T) { |
| 332 | t.Parallel() |
nothing calls this directly
no test coverage detected