#include <CDBPublisher.h>

Inheritance diagram for CDBPublisher:

Public Member Functions
	CDBPublisher ()
virtual	~CDBPublisher ()
void	StartPublishing (const char pDatabase, const char pCollection, VEC_DB_KEYS &vKeys, const char pHost, const char pUser, const char *pPassword)
	to ensure that the indices exist in the collection. Starts publishing thread.
void	StopPublishing ()
	Stop publishing. Stops the publishing thread.
bool	Publish (CDBRecordsArray &cRecords)
DBStats &	GetDBStats ()
void	SetUpsert (bool bOnOff)
bool	GetUpsert ()
	See if the upsert flag is set.
Public Attributes
time_t	tLastPublished
	Our last published timestamp.
Protected Member Functions
virtual unsigned	WorkerFunction (void *pParam)
	Called by CXPlatThread to start work in object context.
Protected Attributes
DBStats	cDBStats
CXPlatCriticalSection	cPublishMutex
CXPlatEvent	cStartEvent
string	sHost
string	sUser
string	sPassword
bool	bTerminate
string	sDatabase
VEC_DB_RECORDS	vDBRecords
VEC_DB_KEYS	vKeys
string	sCollection
string	sDB_Collection
Static Protected Attributes
static DBStats	cDBCopy

Detailed Description

CDBPublisher - publisher thread This class takes a set of records to be published to the MongoDB and writes them in bulk on a schedule

Definition at line 63 of file CDBPublisher.h.

Constructor & Destructor Documentation

CDBPublisher::CDBPublisher ( )

Definition at line 26 of file CDBPublisher.cpp.

CDBPublisher::~CDBPublisher ( ) [virtual]

Definition at line 34 of file CDBPublisher.cpp.

Member Function Documentation

DBStats & CDBPublisher::GetDBStats ( )

Get and clear statistics. This returns a call to a static variable, which means the next call changes it.

Definition at line 215 of file CDBPublisher.cpp.

bool CDBPublisher::GetUpsert ( )

See if the upsert flag is set.

Definition at line 76 of file CDBPublisher.cpp.

bool CDBPublisher::Publish ( CDBRecordsArray & cRecords )

Publish records. This will copy the data from the passed in array, clear the array, and return immediately while connecting and writing in the background.

Definition at line 83 of file CDBPublisher.cpp.

void CDBPublisher::SetUpsert ( bool bOnOff )

Set upsert. Since Mongo doesn't have an "upsert" per se, this is a very expensive setting, performance wise. It will bulk delete all records before an insert is done.

Definition at line 70 of file CDBPublisher.cpp.

void CDBPublisher::StartPublishing	(	const char *	pDatabase,
		const char *	pCollection,
		VEC_DB_KEYS &	vKeys,
		const char *	pHost,
		const char *	pUser,
		const char *	pPassword
	)