(
&mut self,
messages: Vec<BackendMessage>,
options: Option<&QueryOptions>,
)
| 992 | } |
| 993 | |
| 994 | fn finish_query( |
| 995 | &mut self, |
| 996 | messages: Vec<BackendMessage>, |
| 997 | options: Option<&QueryOptions>, |
| 998 | ) -> Result<Results> { |
| 999 | let blob = { |
| 1000 | let _phase = timing::phase("client.finish.blob_read"); |
| 1001 | self.get_written_blob()? |
| 1002 | }; |
| 1003 | { |
| 1004 | let _phase = timing::phase("client.finish.blob_cleanup"); |
| 1005 | self.cleanup_blob()?; |
| 1006 | } |
| 1007 | if !self.in_transaction { |
| 1008 | let _phase = timing::phase("client.finish.sync_to_fs"); |
| 1009 | self.sync_to_fs()?; |
| 1010 | } |
| 1011 | { |
| 1012 | let _phase = timing::phase("client.finish.ensure_array_types"); |
| 1013 | self.ensure_array_types_for_result_messages(&messages, options)?; |
| 1014 | } |
| 1015 | let parsed = { |
| 1016 | let _phase = timing::phase("client.finish.parse_results"); |
| 1017 | parse_results(&messages, &self.parsers, options, blob) |
| 1018 | }; |
| 1019 | parsed |
| 1020 | .into_iter() |
| 1021 | .next() |
| 1022 | .ok_or_else(|| anyhow!("query returned no result sets")) |
| 1023 | } |
| 1024 | |
| 1025 | fn finish_exec( |
| 1026 | &mut self, |
no test coverage detected