Method Execute

cpp/src/arrow/flight/sql/odbc/odbc_impl/flight_sql_statement.cc:139–150

}

bool FlightSqlStatement::Execute(const std::string& query) {
  ClosePreparedStatementIfAny(prepared_statement_, call_options_);

  Result<std::shared_ptr<FlightInfo>> result = sql_client_.Execute(call_options_, query);
  ThrowIfNotOK(result.status());

  current_result_set_ = std::make_shared<FlightSqlResultSet>(
      sql_client_, client_options_, call_options_, result.ValueOrDie(), nullptr,
      diagnostics_, metadata_settings_);

  return true;
}

std::shared_ptr<ResultSet> FlightSqlStatement::GetResultSet() {
  return current_result_set_;