(server: &PgliteServer)
| 342 | } |
| 343 | |
| 344 | fn pg_connect_options(server: &PgliteServer) -> Result<PgConnectOptions> { |
| 345 | let options = PgConnectOptions::new() |
| 346 | .username("postgres") |
| 347 | .database("template1") |
| 348 | .ssl_mode(PgSslMode::Disable); |
| 349 | |
| 350 | #[cfg(unix)] |
| 351 | if let Some(path) = server.socket_path() { |
| 352 | let dir = path |
| 353 | .parent() |
| 354 | .ok_or_else(|| anyhow!("Unix socket {} has no parent", path.display()))?; |
| 355 | return Ok(options.host("localhost").socket(dir).port(5432)); |
| 356 | } |
| 357 | |
| 358 | let addr = server |
| 359 | .tcp_addr() |
| 360 | .ok_or_else(|| anyhow!("PGlite server did not expose a TCP address"))?; |
| 361 | Ok(options.host(&addr.ip().to_string()).port(addr.port())) |
| 362 | } |
| 363 | |
| 364 | fn normalize_row_count(row_count: u32) -> u32 { |
| 365 | if row_count == 0 { |
no test coverage detected