Function TestBindColumn

cpp/src/arrow/flight/sql/odbc/odbc_impl/main.cc:44–79

using arrow::flight::sql::odbc::Statement;

void TestBindColumn(const std::shared_ptr<Connection>& connection) {
  const std::shared_ptr<Statement>& statement = connection->CreateStatement();
  statement->Execute("SELECT IncidntNum, Category FROM \"@apache\".Test LIMIT 10");

  const std::shared_ptr<ResultSet>& result_set = statement->GetResultSet();

  const int batch_size = 100;
  const int max_str_len = 1000;

  char incidnt_num[batch_size][max_str_len];
  ssize_t incidnt_num_length[batch_size];

  char category[batch_size][max_str_len];
  ssize_t category_length[batch_size];

  result_set->BindColumn(1, arrow::flight::sql::odbc::CDataType_CHAR, 0, 0, incidnt_num,
                         max_str_len, incidnt_num_length);
  result_set->BindColumn(2, arrow::flight::sql::odbc::CDataType_CHAR, 0, 0, category,
                         max_str_len, category_length);

  size_t total = 0;
  while (true) {
    size_t fetched_rows = result_set->Move(batch_size, 0, 0, nullptr);
    std::cout << "Fetched " << fetched_rows << " rows." << std::endl;

    total += fetched_rows;
    std::cout << "Total:" << total << std::endl;

    for (size_t i = 0; i < fetched_rows; ++i) {
      ARROW_LOG(DEBUG) << "Row[" << i << "] incidnt_num: '" << incidnt_num[i]
                       << "', Category: '" << category[i] << "'";
    }

    if (fetched_rows < batch_size) break;
  }
}

void TestGetData(const std::shared_ptr<Connection>& connection) {
  const std::shared_ptr<Statement>& statement = connection->CreateStatement();