Method GetData

cpp/src/arrow/flight/sql/odbc/odbc_impl/flight_sql_result_set.cc:217–245

}

SQLRETURN FlightSqlResultSet::GetData(int column_n, int16_t target_type, int precision,
                                      int scale, void* buffer, size_t buffer_length,
                                      ssize_t* str_len_buffer) {
  reset_get_data_ = true;
  // Check if the offset is already at the end.
  int64_t& value_offset = get_data_offsets_[column_n - 1];
  if (value_offset == -1) {
    return SQL_NO_DATA;
  }

  ColumnBinding binding(util::ConvertCDataTypeFromV2ToV3(target_type), precision, scale,
                        buffer, buffer_length, str_len_buffer);

  auto& column = columns_[column_n - 1];
  Accessor* accessor = column.GetAccessorForGetData(binding.target_type);

  // Note: current_row_ is always positioned at the index _after_ the one we are
  // on after calling Move(). So if we want to get data from the _last_ row
  // fetched, we need to subtract one from the current row.
  accessor->GetColumnarData(&binding, current_row_ - 1, 1, value_offset, true,
                            diagnostics_, nullptr);

  // If there was truncation, the converter would have reported it to the diagnostics.
  if (diagnostics_.HasWarning()) {
    return SQL_SUCCESS_WITH_INFO;
  } else {
    return SQL_SUCCESS;
  }
}

std::shared_ptr<ResultSetMetadata> FlightSqlResultSet::GetMetadata() { return metadata_; }