(col_name: &str, json_text: &str)
| 152 | // ── Helpers ──────────────────────────────────────────────────────────── |
| 153 | |
| 154 | fn respond_json(col_name: &str, json_text: &str) -> PgWireResult<Vec<Response>> { |
| 155 | let schema = std::sync::Arc::new(vec![super::super::types::text_field(col_name)]); |
| 156 | let mut encoder = DataRowEncoder::new(schema.clone()); |
| 157 | let _ = encoder.encode_field(&json_text.to_string()); |
| 158 | let row = encoder.take_row(); |
| 159 | Ok(vec![Response::Query(QueryResponse::new( |
| 160 | schema, |
| 161 | stream::iter(vec![Ok(row)]), |
| 162 | ))]) |
| 163 | } |
| 164 | |
| 165 | fn unquote(s: &str) -> String { |
| 166 | let t = s.trim(); |
no test coverage detected