Execute a query on the server.
(
&mut self,
query: String,
transaction_id: Option<Bytes>,
)
| 144 | |
| 145 | /// Execute a query on the server. |
| 146 | pub async fn execute( |
| 147 | &mut self, |
| 148 | query: String, |
| 149 | transaction_id: Option<Bytes>, |
| 150 | ) -> Result<FlightInfo> { |
| 151 | let cmd = CommandStatementQuery { |
| 152 | query, |
| 153 | transaction_id, |
| 154 | }; |
| 155 | self.get_flight_info_for_command(cmd).await |
| 156 | } |
| 157 | |
| 158 | /// Perform a `handshake` with the server, passing credentials and establishing a session. |
| 159 | /// |