| 145 | } |
| 146 | |
| 147 | arrow::Result<std::unique_ptr<FlightInfo>> FlightSqlClient::Execute( |
| 148 | const FlightCallOptions& options, const std::string& query, |
| 149 | const Transaction& transaction) { |
| 150 | flight_sql_pb::CommandStatementQuery command; |
| 151 | command.set_query(query); |
| 152 | if (transaction.is_valid()) { |
| 153 | command.set_transaction_id(transaction.transaction_id()); |
| 154 | } |
| 155 | |
| 156 | return GetFlightInfoForCommand(this, options, command); |
| 157 | } |
| 158 | |
| 159 | arrow::Result<std::unique_ptr<SchemaResult>> FlightSqlClient::GetExecuteSchema( |
| 160 | const FlightCallOptions& options, const std::string& query, |