Inheritance diagram for EmbeddedDatabase::CursorImpl:

Collaboration diagram for EmbeddedDatabase::CursorImpl:

Public Member Functions
	CursorImpl (std::shared_ptr< ResultSet > result_set, std::vector< std::string > col_names)

	~CursorImpl ()

size_t	getColCount ()

size_t	getRowCount ()

Row	getNextRow ()

ColumnType	getColType (uint32_t col_num)

std::shared_ptr < arrow::RecordBatch >	getArrowRecordBatch ()

Public Member Functions inherited from EmbeddedDatabase::Cursor
virtual	~Cursor ()

size_t	getColCount ()

size_t	getRowCount ()

Row	getNextRow ()

ColumnType	getColType (uint32_t col_num)

std::shared_ptr < arrow::RecordBatch >	getArrowRecordBatch ()

Private Attributes
std::shared_ptr< ResultSet >	result_set_

std::vector< std::string >	col_names_

std::shared_ptr < arrow::RecordBatch >	record_batch_

Additional Inherited Members
Protected Member Functions inherited from EmbeddedDatabase::Cursor
	Cursor ()

	Cursor (const Cursor &)=delete

Cursor &	operator= (const Cursor &)=delete

Detailed Description

Cursor internal implementation

Definition at line 43 of file DBEngine.cpp.

Constructor & Destructor Documentation

EmbeddedDatabase::CursorImpl::CursorImpl	(	std::shared_ptr< ResultSet >	result_set,
		std::vector< std::string >	col_names
	)

inline

Definition at line 45 of file DBEngine.cpp.

46 : result_set_(result_set), col_names_(col_names) {}

EmbeddedDatabase::CursorImpl::result_set_

std::shared_ptr< ResultSet > result_set_

Definition: DBEngine.cpp:92

EmbeddedDatabase::CursorImpl::col_names_

std::vector< std::string > col_names_

Definition: DBEngine.cpp:93

EmbeddedDatabase::CursorImpl::~CursorImpl ( )

inline

Definition at line 48 of file DBEngine.cpp.

References col_names_, record_batch_, and result_set_.

                 {
     col_names_.clear();
     record_batch_.reset();
     result_set_.reset();
   }

Member Function Documentation

std::shared_ptr<arrow::RecordBatch> EmbeddedDatabase::CursorImpl::getArrowRecordBatch ( )

inline

Definition at line 74 of file DBEngine.cpp.

References col_names_, getColCount(), getRowCount(), record_batch_, and result_set_.

Referenced by EmbeddedDatabase::Cursor::getArrowRecordBatch().

                                                         {
     if (record_batch_) {
       return record_batch_;
     }
     auto col_count = getColCount();
     if (col_count > 0) {
       auto row_count = getRowCount();
       if (row_count > 0) {
         auto converter =
             std::make_unique<ArrowResultSetConverter>(result_set_, col_names_, -1);
         record_batch_ = converter->convertToArrow();
         return record_batch_;
       }
     }
     return nullptr;
   }

Here is the call graph for this function:

Here is the caller graph for this function:

size_t EmbeddedDatabase::CursorImpl::getColCount ( )

inline

Definition at line 54 of file DBEngine.cpp.

References result_set_.

Referenced by getArrowRecordBatch(), EmbeddedDatabase::Cursor::getColCount(), and getColType().

54 { return result_set_ ? result_set_->colCount() : 0; }

EmbeddedDatabase::CursorImpl::result_set_

std::shared_ptr< ResultSet > result_set_

Definition: DBEngine.cpp:92

Here is the caller graph for this function:

ColumnType EmbeddedDatabase::CursorImpl::getColType ( uint32_t col_num )

inline

Definition at line 66 of file DBEngine.cpp.

References SQLTypeInfo::get_type(), getColCount(), result_set_, EmbeddedDatabase::sqlToColumnType(), and EmbeddedDatabase::UNKNOWN.

Referenced by EmbeddedDatabase::Cursor::getColType().

                                           {
     if (col_num < getColCount()) {
       SQLTypeInfo type_info = result_set_->getColType(col_num);
       return sqlToColumnType(type_info.get_type());
     }
     return ColumnType::UNKNOWN;
   }

Here is the call graph for this function:

Here is the caller graph for this function:

Row EmbeddedDatabase::CursorImpl::getNextRow ( )

inline

Definition at line 58 of file DBEngine.cpp.

References result_set_.

Referenced by EmbeddedDatabase::Cursor::getNextRow().

                    {
     if (result_set_) {
       auto row = result_set_->getNextRow(true, false);
       return row.empty() ? Row() : Row(row);
     }
     return Row();
   }