(msg: &tokio_postgres::SimpleQueryMessage)
| 19 | use common::pgwire_harness::TestServer; |
| 20 | |
| 21 | fn row_columns(msg: &tokio_postgres::SimpleQueryMessage) -> Option<Vec<String>> { |
| 22 | if let tokio_postgres::SimpleQueryMessage::Row(row) = msg { |
| 23 | let cols: Vec<String> = (0..row.columns().len()) |
| 24 | .map(|i| row.get(i).unwrap_or("").to_string()) |
| 25 | .collect(); |
| 26 | Some(cols) |
| 27 | } else { |
| 28 | None |
| 29 | } |
| 30 | } |
| 31 | |
| 32 | #[tokio::test(flavor = "multi_thread", worker_threads = 4)] |
| 33 | async fn pure_vector_projection_skips_payload_fetch() { |