EPANET-RTX
1.1
real-time extension for the EPANET toolkit
|
A persistence layer for databases. More...
#include <DbPointRecord.h>
Classes | |
class | request_t |
class | RtxDbConnectException |
class | RtxDbRetrievalException |
Public Types | |
typedef boost::shared_ptr < DbPointRecord > | sharedPointer |
Public Types inherited from RTX::BufferPointRecord | |
typedef boost::circular_buffer < Point > | PointBuffer_t |
typedef std::pair < PointBuffer_t, boost::shared_ptr < boost::signals2::mutex > > | BufferMutexPair_t |
typedef std::map< std::string, BufferMutexPair_t > | KeyedBufferMutexMap_t |
typedef boost::shared_ptr < BufferPointRecord > | sharedPointer |
Public Types inherited from RTX::PointRecord | |
typedef boost::shared_ptr < PointRecord > | sharedPointer |
typedef std::pair< time_t, time_t > | time_pair_t |
Public Member Functions | |
Point | point (const string &id, time_t time) |
Get a Point with a specific name at a specific time. More... | |
Point | pointBefore (const string &id, time_t time) |
Point | pointAfter (const string &id, time_t time) |
std::vector< Point > | pointsInRange (const string &id, time_t startTime, time_t endTime) |
Get a vector of Points with a specific name within a specific time range. More... | |
void | addPoint (const string &id, Point point) |
void | addPoints (const string &id, std::vector< Point > points) |
void | reset () |
void | reset (const string &id) |
virtual void | invalidate (const string &identifier) |
virtual void | truncate ()=0 |
virtual std::vector< std::pair < std::string, Units > > | availableData () |
virtual void | dbConnect () throw (RtxException) |
virtual bool | isConnected () |
virtual bool | supportsBoundedQueries () |
void | setSearchDistance (time_t time) |
time_t | searchDistance () |
Public Member Functions inherited from RTX::BufferPointRecord | |
BufferPointRecord (int defaultCapacity=100) | |
virtual std::string | registerAndGetIdentifier (std::string recordName, Units dataUnits) |
virtual std::vector< std::string > | identifiers () |
virtual Point | firstPoint (const string &id) |
virtual Point | lastPoint (const string &id) |
virtual time_pair_t | range (const string &id) |
virtual std::ostream & | toStream (std::ostream &stream) |
Public Member Functions inherited from RTX::PointRecord | |
std::string | name () |
void | setName (std::string name) |
Public Attributes | |
std::string | errorMessage |
Protected Member Functions | |
virtual std::vector< Point > | selectRange (const std::string &id, time_t startTime, time_t endTime)=0 |
virtual Point | selectNext (const std::string &id, time_t time)=0 |
virtual Point | selectPrevious (const std::string &id, time_t time)=0 |
virtual void | insertSingle (const std::string &id, Point point)=0 |
virtual void | insertRange (const std::string &id, std::vector< Point > points)=0 |
virtual void | removeRecord (const std::string &id)=0 |
Protected Attributes | |
request_t | request |
Protected Attributes inherited from RTX::PointRecord | |
std::string | _cachedPointId |
Point | _cachedPoint |
std::map< std::string, Point > | _pointCache |
A persistence layer for databases.
Base class for database-connected PointRecord classes.
|
virtual |
Get a Point with a specific name at a specific time.
name | The name of the data source (tag name). |
time | The requested time. |
Reimplemented from RTX::BufferPointRecord.
|
virtual |
Get a vector of Points with a specific name within a specific time range.
name | The name of the data source (tag name). |
startTime | The beginning of the requested time range. |
endTime | The end of the requested time range. |
Reimplemented from RTX::BufferPointRecord.