#include <message_collection_helper.h>

Inheritance diagram for warehouse_ros_sqlite::MessageCollectionHelper:

Public Member Functions
std::string	collectionName () const override

unsigned	count () override

warehouse_ros::Metadata::Ptr	createMetadata () const override

warehouse_ros::Query::Ptr	createQuery () const override

bool	initialize (const std::string &datatype, const std::string &md5) override

void	insert (char *msg, size_t msg_size, warehouse_ros::Metadata::ConstPtr metadata) override

	MessageCollectionHelper ()=default

	MessageCollectionHelper (sqlite3_ptr db, const std::string &db_name, const std::string &name)

void	modifyMetadata (warehouse_ros::Query::ConstPtr q, warehouse_ros::Metadata::ConstPtr m) override

warehouse_ros::ResultIteratorHelper::Ptr	query (warehouse_ros::Query::ConstPtr query, const std::string &sort_by="", bool ascending=true) const override

unsigned	removeMessages (warehouse_ros::Query::ConstPtr query) override

Public Member Functions inherited from warehouse_ros::MessageCollectionHelper
virtual	~MessageCollectionHelper ()=default

Private Types
enum	Md5CompareResult { Md5CompareResult::EMPTY, Md5CompareResult::MATCH, Md5CompareResult::MISMATCH }

Private Member Functions
Md5CompareResult	findAndMatchMd5Sum (const std::array< unsigned char, 16 > &md5_bytes)

Private Attributes
std::string	collection_name_

sqlite3_ptr	db_

std::string	db_name_

schema::escaped_tablename	escaped_mangled_name_

std::string	mangled_tablename_

Additional Inherited Members
Public Types inherited from warehouse_ros::MessageCollectionHelper
typedef boost::shared_ptr< MessageCollectionHelper >	Ptr

Detailed Description

Definition at line 37 of file message_collection_helper.h.

Member Enumeration Documentation

◆ Md5CompareResult

enum warehouse_ros_sqlite::MessageCollectionHelper::Md5CompareResult

strongprivate

Enumerator
EMPTY
MATCH
MISMATCH

Definition at line 70 of file message_collection_helper.h.

Constructor & Destructor Documentation

◆ MessageCollectionHelper() [1/2]

warehouse_ros_sqlite::MessageCollectionHelper::MessageCollectionHelper ( )

default

◆ MessageCollectionHelper() [2/2]

warehouse_ros_sqlite::MessageCollectionHelper::MessageCollectionHelper	(	sqlite3_ptr	db,
		const std::string &	db_name,
		const std::string &	name
	)

inline

Definition at line 47 of file message_collection_helper.h.

Member Function Documentation

◆ collectionName()

std::string warehouse_ros_sqlite::MessageCollectionHelper::collectionName ( ) const

inlineoverridevirtual

Implements warehouse_ros::MessageCollectionHelper.

Definition at line 64 of file message_collection_helper.h.

◆ count()

unsigned warehouse_ros_sqlite::MessageCollectionHelper::count ( )

overridevirtual

Implements warehouse_ros::MessageCollectionHelper.

Definition at line 247 of file message_collection_helper.cpp.

◆ createMetadata()

warehouse_ros::Metadata::Ptr warehouse_ros_sqlite::MessageCollectionHelper::createMetadata ( ) const

overridevirtual

Implements warehouse_ros::MessageCollectionHelper.

Definition at line 266 of file message_collection_helper.cpp.

◆ createQuery()

warehouse_ros::Query::Ptr warehouse_ros_sqlite::MessageCollectionHelper::createQuery ( ) const

overridevirtual

Implements warehouse_ros::MessageCollectionHelper.

Definition at line 262 of file message_collection_helper.cpp.

◆ findAndMatchMd5Sum()

warehouse_ros_sqlite::MessageCollectionHelper::Md5CompareResult warehouse_ros_sqlite::MessageCollectionHelper::findAndMatchMd5Sum ( const std::array< unsigned char, 16 > & md5_bytes )

private

Definition at line 44 of file message_collection_helper.cpp.

◆ initialize()

bool warehouse_ros_sqlite::MessageCollectionHelper::initialize	(	const std::string &	datatype,
		const std::string &	md5
	)

overridevirtual

Implements warehouse_ros::MessageCollectionHelper.

Definition at line 80 of file message_collection_helper.cpp.

◆ insert()

void warehouse_ros_sqlite::MessageCollectionHelper::insert	(	char *	msg,
		size_t	msg_size,
		warehouse_ros::Metadata::ConstPtr	metadata
	)

overridevirtual

Implements warehouse_ros::MessageCollectionHelper.

Definition at line 111 of file message_collection_helper.cpp.

◆ modifyMetadata()

void warehouse_ros_sqlite::MessageCollectionHelper::modifyMetadata	(	warehouse_ros::Query::ConstPtr	q,
		warehouse_ros::Metadata::ConstPtr	m
	)

overridevirtual

Implements warehouse_ros::MessageCollectionHelper.

Definition at line 216 of file message_collection_helper.cpp.

◆ query()

warehouse_ros::ResultIteratorHelper::Ptr warehouse_ros_sqlite::MessageCollectionHelper::query	(	warehouse_ros::Query::ConstPtr	query,
		const std::string &	sort_by = `""`,
		bool	ascending = `true`
	)		const