foreign_storage::anonymous_namespace{CsvFileBufferParser.cpp} Namespace Reference

Functions
bool	skip_column_import (ParseBufferRequest &request, int column_idx)
void	set_array_flags_and_geo_columns_count (std::unique_ptr< bool[]> &array_flags, int &phys_cols, int &point_cols, const std::list< const ColumnDescriptor * > &columns)
void	validate_expected_column_count (std::vector< std::string_view > &row, size_t num_cols, int point_cols, const std::string &file_name)
std::string	validate_and_get_delimiter (const ForeignTable *foreign_table, const std::string &option_name)
std::string	validate_and_get_string_with_length (const ForeignTable *foreign_table, const std::string &option_name, const size_t expected_num_chars)
std::optional< bool >	validate_and_get_bool_value (const ForeignTable *foreign_table, const std::string &option_name)

Function Documentation

void foreign_storage::anonymous_namespace{CsvFileBufferParser.cpp}::set_array_flags_and_geo_columns_count	(	std::unique_ptr< bool[]> &	array_flags,
		int &	phys_cols,
		int &	point_cols,
		const std::list< const ColumnDescriptor * > &	columns
	)

Definition at line 31 of file CsvFileBufferParser.cpp.

References kARRAY, and kPOINT.

Referenced by foreign_storage::CsvFileBufferParser::parseBuffer().

                                                     {
  array_flags = std::unique_ptr<bool[]>(new bool[columns.size()]);
  size_t i = 0;
  for (const auto cd : columns) {
    const auto& col_ti = cd->columnType;
    phys_cols += col_ti.get_physical_cols();
    if (cd->columnType.get_type() == kPOINT) {
      point_cols++;
    }

    if (cd->columnType.get_type() == kARRAY) {
      array_flags.get()[i] = true;
    } else {
      array_flags.get()[i] = false;
    }
    i++;
  }
}

Here is the caller graph for this function:

bool foreign_storage::anonymous_namespace{CsvFileBufferParser.cpp}::skip_column_import ( ParseBufferRequest &  request, int  column_idx  )

inline

Definition at line 27 of file CsvFileBufferParser.cpp.

References foreign_storage::ParseBufferRequest::import_buffers.

Referenced by foreign_storage::CsvFileBufferParser::parseBuffer().

                                                                            {
  return request.import_buffers[column_idx] == nullptr;
}

Here is the caller graph for this function:

std::optional<bool> foreign_storage::anonymous_namespace{CsvFileBufferParser.cpp}::validate_and_get_bool_value	(	const ForeignTable *	foreign_table,
		const std::string &	option_name
	)

Definition at line 100 of file CsvFileBufferParser.cpp.

References foreign_storage::OptionsContainer::options.

Referenced by foreign_storage::Csv::validate_and_get_copy_params(), foreign_storage::CsvFileBufferParser::validateAndGetCopyParams(), and foreign_storage::RegexFileBufferParser::validateAndGetCopyParams().

                                                                              {
  if (auto it = foreign_table->options.find(option_name);
      it != foreign_table->options.end()) {
    if (boost::iequals(it->second, "TRUE")) {
      return true;
    } else if (boost::iequals(it->second, "FALSE")) {
      return false;
    } else {
      throw std::runtime_error{"Invalid boolean value specified for \"" + option_name +
                               "\" foreign table option. "
                               "Value must be either 'true' or 'false'."};
    }
  }
  return std::nullopt;
}

Here is the caller graph for this function:

std::string foreign_storage::anonymous_namespace{CsvFileBufferParser.cpp}::validate_and_get_delimiter	(	const ForeignTable *	foreign_table,
		const std::string &	option_name
	)

Definition at line 64 of file CsvFileBufferParser.cpp.

References foreign_storage::OptionsContainer::options.

Referenced by foreign_storage::Csv::validate_and_get_copy_params(), and foreign_storage::CsvFileBufferParser::validateAndGetCopyParams().

                                                                     {
  if (auto it = foreign_table->options.find(option_name);
      it != foreign_table->options.end()) {
    if (it->second.length() == 1) {
      return it->second;
    } else {
      if (it->second == std::string("\\n")) {
        return "\n";
      } else if (it->second == std::string("\\t")) {
        return "\t";
      } else {
        throw std::runtime_error{"Invalid value specified for option \"" + option_name +
                                 "\". Expected a single character, \"\\n\" or  \"\\t\"."};
      }
    }
  }
  return "";
}

Here is the caller graph for this function:

std::string foreign_storage::anonymous_namespace{CsvFileBufferParser.cpp}::validate_and_get_string_with_length	(	const ForeignTable *	foreign_table,
		const std::string &	option_name,
		const size_t	expected_num_chars
	)

Definition at line 84 of file CsvFileBufferParser.cpp.

References foreign_storage::OptionsContainer::options, and to_string().

Referenced by foreign_storage::Csv::validate_and_get_copy_params(), and foreign_storage::CsvFileBufferParser::validateAndGetCopyParams().

                                                                                 {
  if (auto it = foreign_table->options.find(option_name);
      it != foreign_table->options.end()) {
    if (it->second.length() != expected_num_chars) {
      throw std::runtime_error{"Value of \"" + option_name +
                               "\" foreign table option has the wrong number of "
                               "characters. Expected " +
                               std::to_string(expected_num_chars) + " character(s)."};
    }
    return it->second;
  }
  return "";
}

Here is the call graph for this function:

Here is the caller graph for this function:

void foreign_storage::anonymous_namespace{CsvFileBufferParser.cpp}::validate_expected_column_count	(	std::vector< std::string_view > &	row,
		size_t	num_cols,
		int	point_cols,
		const std::string &	file_name
	)

Definition at line 54 of file CsvFileBufferParser.cpp.

References foreign_storage::throw_number_of_columns_mismatch_error().

Referenced by foreign_storage::CsvFileBufferParser::parseBuffer(), and foreign_storage::CsvFileBufferParser::validateExpectedColumnCount().

                                                                {
  // Each POINT could consume two separate coords instead of a single WKT
  if (row.size() < num_cols || (num_cols + point_cols) < row.size()) {
    throw_number_of_columns_mismatch_error(num_cols, row.size(), file_name);
  }
}

Here is the call graph for this function:

Here is the caller graph for this function: