#include <RelAlgDagBuilder.h>

Inheritance diagram for RelModify:

Collaboration diagram for RelModify:

Public Types
enum	ModifyOperation { ModifyOperation::Insert, ModifyOperation::Delete, ModifyOperation::Update }

using	RelAlgNodeInputPtr = std::shared_ptr< const RelAlgNode >

using	TargetColumnList = std::vector< std::string >

Public Member Functions
	RelModify (Catalog_Namespace::Catalog const &cat, TableDescriptor const *const td, bool flattened, std::string const &op_string, TargetColumnList const &target_column_list, RelAlgNodeInputPtr input)

	RelModify (Catalog_Namespace::Catalog const &cat, TableDescriptor const *const td, bool flattened, ModifyOperation op, TargetColumnList const &target_column_list, RelAlgNodeInputPtr input)

TableDescriptor const *const	getTableDescriptor () const

bool const	isFlattened () const

ModifyOperation	getOperation () const

TargetColumnList const &	getUpdateColumnNames ()

int	getUpdateColumnCount () const

size_t	size () const override

std::shared_ptr< RelAlgNode >	deepCopy () const override

std::string	toString () const override

void	applyUpdateModificationsToInputNode ()

void	applyDeleteModificationsToInputNode ()

Public Member Functions inherited from RelAlgNode
	RelAlgNode (RelAlgInputs inputs={})

virtual	~RelAlgNode ()

void	resetQueryExecutionState ()

void	setContextData (const void *context_data) const

void	setOutputMetainfo (const std::vector< TargetMetaInfo > &targets_metainfo) const

const std::vector< TargetMetaInfo > &	getOutputMetainfo () const

unsigned	getId () const

bool	hasContextData () const

const void *	getContextData () const

const size_t	inputCount () const

const RelAlgNode *	getInput (const size_t idx) const

std::shared_ptr< const RelAlgNode >	getAndOwnInput (const size_t idx) const

void	addManagedInput (std::shared_ptr< const RelAlgNode > input)

bool	hasInput (const RelAlgNode *needle) const

virtual void	replaceInput (std::shared_ptr< const RelAlgNode > old_input, std::shared_ptr< const RelAlgNode > input)

bool	isNop () const

void	markAsNop ()

Static Public Member Functions
static std::string	yieldModifyOperationString (ModifyOperation const op)

static ModifyOperation	yieldModifyOperationEnum (std::string const &op_string)

Static Public Member Functions inherited from RelAlgNode
static void	resetRelAlgFirstId () noexcept

Private Attributes
Catalog_Namespace::Catalog const &	catalog_

const TableDescriptor *	table_descriptor_

bool	flattened_

ModifyOperation	operation_

TargetColumnList	target_column_list_

Additional Inherited Members
Protected Attributes inherited from RelAlgNode
RelAlgInputs	inputs_

const unsigned	id_

Detailed Description

Definition at line 1453 of file RelAlgDagBuilder.h.

Member Typedef Documentation

◆ RelAlgNodeInputPtr

using RelModify::RelAlgNodeInputPtr = std::shared_ptr<const RelAlgNode>

Definition at line 1456 of file RelAlgDagBuilder.h.

◆ TargetColumnList

using RelModify::TargetColumnList = std::vector<std::string>

Definition at line 1457 of file RelAlgDagBuilder.h.

Member Enumeration Documentation

◆ ModifyOperation

enum RelModify::ModifyOperation

strong

Enumerator
Insert
Delete
Update

Definition at line 1455 of file RelAlgDagBuilder.h.

1455 { Insert, Delete, Update };

Constructor & Destructor Documentation

◆ RelModify() [1/2]

RelModify::RelModify	(	Catalog_Namespace::Catalog const &	cat,
		TableDescriptor const *const	td,
		bool	flattened,
		std::string const &	op_string,
		TargetColumnList const &	target_column_list,
		RelAlgNodeInputPtr	input
	)

inline

Definition at line 1486 of file RelAlgDagBuilder.h.

References foreign_storage::validate_non_foreign_table_write().

       : catalog_(cat)
       , table_descriptor_(td)
       , flattened_(flattened)
       , operation_(yieldModifyOperationEnum(op_string))
       , target_column_list_(target_column_list) {
     foreign_storage::validate_non_foreign_table_write(table_descriptor_);
     inputs_.push_back(input);
   }

Here is the call graph for this function:

◆ RelModify() [2/2]

RelModify::RelModify	(	Catalog_Namespace::Catalog const &	cat,
		TableDescriptor const *const	td,
		bool	flattened,
		ModifyOperation	op,
		TargetColumnList const &	target_column_list,
		RelAlgNodeInputPtr	input
	)

inline

Definition at line 1501 of file RelAlgDagBuilder.h.

References foreign_storage::validate_non_foreign_table_write().

       : catalog_(cat)
       , table_descriptor_(td)
       , flattened_(flattened)
       , operation_(op)
       , target_column_list_(target_column_list) {
     foreign_storage::validate_non_foreign_table_write(table_descriptor_);
     inputs_.push_back(input);
   }

Here is the call graph for this function:

Member Function Documentation

◆ applyDeleteModificationsToInputNode()

void RelModify::applyDeleteModificationsToInputNode ( )

inline

Definition at line 1592 of file RelAlgDagBuilder.h.

References CHECK, ModifyManipulationTarget::setDeleteViaSelectFlag(), and ModifyManipulationTarget::setModifiedTableDescriptor().

                                              {
     RelProject const* previous_project_node =
         dynamic_cast<RelProject const*>(inputs_[0].get());
     CHECK(previous_project_node != nullptr);
     previous_project_node->setDeleteViaSelectFlag();
     previous_project_node->setModifiedTableDescriptor(table_descriptor_);
   }

Here is the call graph for this function:

◆ applyUpdateModificationsToInputNode()

void RelModify::applyUpdateModificationsToInputNode ( )

inline

Definition at line 1538 of file RelAlgDagBuilder.h.

References CHECK, ModifyManipulationTarget::setModifiedTableDescriptor(), ModifyManipulationTarget::setTargetColumns(), ModifyManipulationTarget::setUpdateViaSelectFlag(), ModifyManipulationTarget::setVarlenUpdateRequired(), and RelProject::visitScalarExprs().

                                              {
     RelProject const* previous_project_node =
         dynamic_cast<RelProject const*>(inputs_[0].get());
     CHECK(previous_project_node != nullptr);
 
     previous_project_node->setUpdateViaSelectFlag();
     // remove the offset column in the projection for update handling
     target_column_list_.pop_back();
 
     previous_project_node->setModifiedTableDescriptor(table_descriptor_);
     previous_project_node->setTargetColumns(target_column_list_);
 
     int target_update_column_expr_start = 0;
     int target_update_column_expr_end = (int)(target_column_list_.size() - 1);
     CHECK(target_update_column_expr_start >= 0);
     CHECK(target_update_column_expr_end >= 0);
 
     bool varlen_update_required = false;
 
     auto varlen_scan_visitor = [this,
                                 &varlen_update_required,
                                 target_update_column_expr_start,
                                 target_update_column_expr_end](int index) {
       if (index >= target_update_column_expr_start &&
           index <= target_update_column_expr_end) {
         auto target_index = index - target_update_column_expr_start;
 
         auto* column_desc = catalog_.getMetadataForColumn(
             table_descriptor_->tableId, target_column_list_[target_index]);
         CHECK(column_desc);
 
         if (table_descriptor_->nShards) {
           const auto shard_cd =
               catalog_.getShardColumnMetadataForTable(table_descriptor_);
           CHECK(shard_cd);
           if ((column_desc->columnName == shard_cd->columnName)) {
             throw std::runtime_error("UPDATE of a shard key is currently unsupported.");
           }
         }
 
         // Check for valid types
         if (column_desc->columnType.is_varlen()) {
           varlen_update_required = true;
         }
         if (column_desc->columnType.is_geometry()) {
           throw std::runtime_error("UPDATE of a geo column is unsupported.");
         }
       }
     };
 
     previous_project_node->visitScalarExprs(varlen_scan_visitor);
     previous_project_node->setVarlenUpdateRequired(varlen_update_required);
   }

Here is the call graph for this function:

◆ deepCopy()

std::shared_ptr<RelAlgNode> RelModify::deepCopy ( ) const

inlineoverridevirtual

Implements RelAlgNode.

Definition at line 1523 of file RelAlgDagBuilder.h.

                                                       {
     return std::make_shared<RelModify>(*this);
   }

◆ getOperation()

ModifyOperation RelModify::getOperation ( ) const

inline

Definition at line 1518 of file RelAlgDagBuilder.h.

1518 { return operation_; }

RelModify::operation_

ModifyOperation operation_

Definition: RelAlgDagBuilder.h:1604

◆ getTableDescriptor()

TableDescriptor const* const RelModify::getTableDescriptor ( ) const

inline

Definition at line 1516 of file RelAlgDagBuilder.h.

1516 { return table_descriptor_; }

RelModify::table_descriptor_

const TableDescriptor * table_descriptor_

Definition: RelAlgDagBuilder.h:1602

◆ getUpdateColumnCount()

int RelModify::getUpdateColumnCount ( ) const

inline

Definition at line 1520 of file RelAlgDagBuilder.h.

1520 { return target_column_list_.size(); }

RelModify::target_column_list_

TargetColumnList target_column_list_

Definition: RelAlgDagBuilder.h:1605

◆ getUpdateColumnNames()

TargetColumnList const& RelModify::getUpdateColumnNames ( )

inline

Definition at line 1519 of file RelAlgDagBuilder.h.

1519 { return target_column_list_; }

RelModify::target_column_list_

TargetColumnList target_column_list_

Definition: RelAlgDagBuilder.h:1605

◆ isFlattened()

bool const RelModify::isFlattened ( ) const

inline

Definition at line 1517 of file RelAlgDagBuilder.h.

1517 { return flattened_; }

RelModify::flattened_

bool flattened_

Definition: RelAlgDagBuilder.h:1603

◆ size()

size_t RelModify::size ( ) const

inlineoverridevirtual

Implements RelAlgNode.

Definition at line 1522 of file RelAlgDagBuilder.h.

1522 { return 0; }

◆ toString()

std::string RelModify::toString ( ) const

inlineoverridevirtual

Implements RelAlgNode.

Definition at line 1527 of file RelAlgDagBuilder.h.

References to_string().

                                       {
     std::ostringstream result_stream;
     result_stream << std::boolalpha
                   << "(RelModify<" + std::to_string(reinterpret_cast<uint64_t>(this)) +
                          "> "
                   << table_descriptor_->tableName << " flattened= " << flattened_
                   << " operation= " << yieldModifyOperationString(operation_) << ")";
 
     return result_stream.str();
   }

Here is the call graph for this function:

◆ yieldModifyOperationEnum()

static ModifyOperation RelModify::yieldModifyOperationEnum ( std::string const & op_string )

inlinestatic

Definition at line 1473 of file RelAlgDagBuilder.h.

                                                                               {
     if (op_string == "INSERT") {
       return ModifyOperation::Insert;
     } else if (op_string == "DELETE") {
       return ModifyOperation::Delete;
     } else if (op_string == "UPDATE") {
       return ModifyOperation::Update;
     }
 
     throw std::runtime_error(
         std::string("Unsupported logical modify operation encountered " + op_string));
   }

◆ yieldModifyOperationString()

static std::string RelModify::yieldModifyOperationString ( ModifyOperation const op )

inlinestatic

Definition at line 1459 of file RelAlgDagBuilder.h.

                                                                         {
     switch (op) {
       case ModifyOperation::Delete:
         return "DELETE";
       case ModifyOperation::Insert:
         return "INSERT";
       case ModifyOperation::Update:
         return "UPDATE";
       default:
         break;
     }
     throw std::runtime_error("Unexpected ModifyOperation enum encountered.");
   }

Member Data Documentation

◆ catalog_

Catalog_Namespace::Catalog const& RelModify::catalog_

private

Definition at line 1601 of file RelAlgDagBuilder.h.

◆ flattened_

bool RelModify::flattened_

private

Definition at line 1603 of file RelAlgDagBuilder.h.

◆ operation_

ModifyOperation RelModify::operation_

private

Definition at line 1604 of file RelAlgDagBuilder.h.

◆ table_descriptor_

const TableDescriptor* RelModify::table_descriptor_

private

Definition at line 1602 of file RelAlgDagBuilder.h.

◆ target_column_list_

TargetColumnList RelModify::target_column_list_

private

Definition at line 1605 of file RelAlgDagBuilder.h.

The documentation for this class was generated from the following file:

/home/jenkins-slave/workspace/core-os-doxygen/QueryEngine/RelAlgDagBuilder.h

Public Types

Public Member Functions

Static Public Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ RelAlgNodeInputPtr

◆ TargetColumnList

Member Enumeration Documentation

◆ ModifyOperation

Constructor & Destructor Documentation

◆ RelModify() [1/2]

◆ RelModify() [2/2]

Member Function Documentation

◆ applyDeleteModificationsToInputNode()

◆ applyUpdateModificationsToInputNode()

◆ deepCopy()

◆ getOperation()

◆ getTableDescriptor()

◆ getUpdateColumnCount()

◆ getUpdateColumnNames()

◆ isFlattened()

◆ size()

◆ toString()

◆ yieldModifyOperationEnum()

◆ yieldModifyOperationString()

Member Data Documentation

◆ catalog_

◆ flattened_

◆ operation_

◆ table_descriptor_

◆ target_column_list_