ddl_utils::alter_column_utils Namespace Reference

Classes
struct	CompareResult

Functions
bool	compare_sql_type_infos (const SQLTypeInfo &lhs, const SQLTypeInfo &rhs)
CompareResult	compare_column_descriptors (const ColumnDescriptor *lhs, const ColumnDescriptor *rhs)

Function Documentation

CompareResult ddl_utils::alter_column_utils::compare_column_descriptors	(	const ColumnDescriptor *	lhs,
		const ColumnDescriptor *	rhs
	)

Definition at line 52 of file DdlUtils.cpp.

References ColumnDescriptor::chunks, ColumnDescriptor::columnId, ColumnDescriptor::columnName, ColumnDescriptor::columnType, compare_sql_type_infos(), ColumnDescriptor::default_value, ddl_utils::alter_column_utils::CompareResult::defaults_match, ddl_utils::alter_column_utils::CompareResult::exact_match, ColumnDescriptor::isDeletedCol, ColumnDescriptor::isGeoPhyCol, ColumnDescriptor::isSystemCol, ColumnDescriptor::isVirtualCol, ddl_utils::alter_column_utils::CompareResult::remainder_match, run_benchmark_import::result, ColumnDescriptor::sourceName, ddl_utils::alter_column_utils::CompareResult::sql_types_match, ColumnDescriptor::tableId, and ColumnDescriptor::virtualExpr.

Referenced by AlterTableAlterColumnCommand::alterColumns(), Fragmenter_Namespace::InsertOrderFragmenter::alterNonGeoColumnType(), AlterTableAlterColumnCommandRecoveryMgr::checkpoint(), AlterTableAlterColumnCommandRecoveryMgr::cleanupDeleteDictionaries(), AlterTableAlterColumnCommand::collectExpectedCatalogChanges(), anonymous_namespace{DdlCommandExecutor.cpp}::get_alter_column_src_dst_cds(), and AlterTableAlterColumnCommand::prepareColumns().

                                                                      {
  CompareResult result;
  result.defaults_match =
      (!lhs->default_value.has_value() && !rhs->default_value.has_value()) ||
      (lhs->default_value.has_value() && rhs->default_value.has_value() &&
       lhs->default_value.value() == rhs->default_value.value());
  result.sql_types_match = compare_sql_type_infos(lhs->columnType, rhs->columnType);
  result.remainder_match =
      lhs->tableId == rhs->tableId && lhs->columnId == rhs->columnId &&
      lhs->columnName == rhs->columnName && lhs->sourceName == rhs->sourceName &&
      lhs->chunks == rhs->chunks && lhs->isSystemCol == rhs->isSystemCol &&
      lhs->isVirtualCol == rhs->isVirtualCol && lhs->virtualExpr == rhs->virtualExpr &&
      lhs->isDeletedCol == rhs->isDeletedCol && lhs->isGeoPhyCol == rhs->isGeoPhyCol;
  result.exact_match =
      result.defaults_match && result.sql_types_match && result.remainder_match;
  return result;
}

Here is the call graph for this function:

Here is the caller graph for this function:

bool ddl_utils::alter_column_utils::compare_sql_type_infos	(	const SQLTypeInfo &	lhs,
		const SQLTypeInfo &	rhs
	)

Definition at line 40 of file DdlUtils.cpp.

References SQLTypeInfo::get_comp_param(), SQLTypeInfo::get_compression(), SQLTypeInfo::get_dimension(), SQLTypeInfo::get_notnull(), SQLTypeInfo::get_scale(), SQLTypeInfo::get_size(), SQLTypeInfo::get_subtype(), SQLTypeInfo::get_type(), kENCODING_DICT, and kENCODING_NONE.

Referenced by compare_column_descriptors().

                                                                            {
  return lhs.get_type() == rhs.get_type() && lhs.get_subtype() == rhs.get_subtype() &&
         lhs.get_dimension() == rhs.get_dimension() &&
         lhs.get_scale() == rhs.get_scale() &&
         lhs.get_compression() == rhs.get_compression() &&
         (lhs.get_compression() == kENCODING_NONE ||
          lhs.get_comp_param() == rhs.get_comp_param() ||
          (lhs.get_compression() == kENCODING_DICT &&
           lhs.get_size() == rhs.get_size())) &&
         lhs.get_notnull() == rhs.get_notnull();
}

Here is the call graph for this function:

Here is the caller graph for this function: