Function TestBindColumnBigInt

cpp/src/arrow/flight/sql/odbc/odbc_impl/main.cc:99–149

}

void TestBindColumnBigInt(const std::shared_ptr<Connection>& connection) {
  const std::shared_ptr<Statement>& statement = connection->CreateStatement();
  statement->Execute(
      "SELECT IncidntNum, CAST(\"IncidntNum\" AS DOUBLE) / 100 AS "
      "double_field, Category\n"
      "FROM (\n"
      "  SELECT CONVERT_TO_INTEGER(IncidntNum, 1, 1, 0) AS IncidntNum, "
      "Category\n"
      "  FROM (\n"
      "    SELECT IncidntNum, Category FROM \"@apache\".Test LIMIT 10\n"
      "  ) nested_0\n"
      ") nested_0");

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

  const int batch_size = 100;
  const int max_strlen = 1000;

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

  double double_field[batch_size];
  ssize_t double_field_length[batch_size];

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

  result_set->BindColumn(1, arrow::flight::sql::odbc::CDataType_CHAR, 0, 0, incidnt_num,
                         max_strlen, incidnt_num_length);
  result_set->BindColumn(2, arrow::flight::sql::odbc::CDataType_DOUBLE, 0, 0,
                         double_field, max_strlen, double_field_length);
  result_set->BindColumn(3, arrow::flight::sql::odbc::CDataType_CHAR, 0, 0, category,
                         max_strlen, category_length);

  size_t total = 0;
  while (true) {
    size_t fetched_rows = result_set->Move(batch_size, 0, 0, nullptr);
    ARROW_LOG(DEBUG) << "Fetched " << fetched_rows << " rows.";

    total += fetched_rows;
    ARROW_LOG(DEBUG) << "Total:" << total;

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

    if (fetched_rows < batch_size) break;
  }
}

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