cpp70Example_main.cpp

TBD: Update GenDefines.txt with a $DESCRIPTION for this example. This example needs a compiled schema, cpp70.sdl.

#include <cstdio>

#include <iostream>

#include <math.h>

 
#include "rdmtfsapi.h"

#include "rdmdbapi.h"

#include "rdmcursorapi.h"

#include "rdmstartupapi.h"

#include "rdm_db_transaction.h"

#include "rdm_db_insert_row.h"

#include "rdm_time_series_split.h"

#include "rdm_time_series_stats.h"

 
/* Generated \c struct and \c typedef definitions to be used with the RDM APIs

 */

#include "cpp70_structs.h"

 
/* Generated catalog definition to be used with the RDM rdm_dbSetCatalog() API

 */

#include "cpp70_cat.h"

 
using namespace RDM_CPP::CPP70;
 
#define print_error(rc) print_errorEx (rc, __FILE__, __LINE__)

 
void print_errorEx (
RDM_RETCODE rc, 
const char *file, 
int line) 
{
if (rc != sOKAY)
 {
 fprintf (
 stderr, "%s:%d:0: error: %d (%s): %s\n", file, line, rc,
rdm_retcodeGetName (rc), rdm_retcodeGetDescription (rc));
 }
}
 
RDM_RETCODE insertTimeSeriesData (
RDM_DB db 
 )
{
using namespace RDM::TIME_SERIES;
using namespace RDM::DB;
 
transaction <split <insert_row <TABLE_MEASUREMENT_SECONDS>,
stats <60, STATS_MINUTES,
split <insert_row <TABLE_STATS_MINUTES>,
stats <60, STATS_HOURS,
split <insert_row <TABLE_STATS_HOURS>,
stats <24, STATS_DAYS,
insert_row <TABLE_STATS_DAYS>>>>>>>> ts;
 
RDM_RETCODE rc = ts.init (db);
 
for (int hour = 0; hour < 72 && rc == sOKAY; hour++)
 {
 rc = ts.begin ();
print_error (rc);
 
if (rc == sOKAY)
 {
 
for (uint64_t time_stamp = hour * 60 * 60; rc == sOKAY && time_stamp < (hour + 1) * 60 * 60; time_stamp++)
 {
const double tau = 6.283185307179586;
const double signal = sin (tau * time_stamp / 23.45);
 MEASUREMENT_SECONDS measurement = {time_stamp, signal};
 
 rc = ts.put_value (&measurement);
print_error (rc);
 }
 }
 
if (rc == sOKAY)
 {
 rc = ts.end ();
print_error (rc);
 }
else

 {
 ts.rollback ();
 }
 }
 
 rc = sOKAY;


return rc;
}
 
RDM_RETCODE readTimeSeriesData (
RDM_DB db 
)
{
RDM_CURSOR cursor = NULL;
RDM_TABLE_ID readTable[] = {TABLE_STATS_DAYS};
RDM_RETCODE rc = rdm_dbGetRows (db, TABLE_STATS_DAYS, &cursor);
print_error (rc);
 
if (rc == sOKAY)
 {
RDM_TRANS trans;
 rc = rdm_dbStartRead (db, readTable, RDM_LEN (readTable), &trans);
print_error (rc);
 
if (rc == sOKAY)
 {
 rc = rdm_cursorMoveToFirst (cursor);
 
while (rc == sOKAY)
 {
 STATS_DAYS stats;
 rc = rdm_cursorReadRow (cursor, &stats, sizeof (stats), NULL);
print_error (rc);
 
 std::cout << "(" << stats.time_stamp_first << ":" << stats.time_stamp_last << "):" << "N: " << stats.n <<
", average: " << stats.value_sum / stats.n << ", standard deviation: " <<
 sqrt ((stats.value_sum2 - stats.value_sum * stats.value_sum / stats.n) / (stats.n - 1)) << std::endl;
 
if (rc == sOKAY)
 {
 rc = rdm_cursorMoveToNext (cursor);
 }
 }
if (rc == sENDOFCURSOR)
 {
 rc = sOKAY;
 }
print_error (rc);
 
rdm_transEnd (trans);
 }
rdm_cursorFree (cursor); 
 }
 
return rc;
}
 
RDM_RETCODE openAndDeleteRows (
RDM_DB db 
)
{
RDM_RETCODE rc = rdm_dbSetCatalog (db, cpp70_cat);
print_error (rc);
 
if (rc == sOKAY)
 {
 rc = rdm_dbOpen (db, "cpp70", RDM_OPEN_EXCLUSIVE);
print_error (rc);
 }
 
RDM_TRANS trans;
if (rc == sOKAY)
 {
rdm_dbStartUpdate(db, RDM_LOCK_ALL, 0, NULL, 0, &trans);
print_error (rc);
 }
 
if (rc == sOKAY)
 {
 rc = rdm_dbDeleteAllRowsFromDatabase (db);
print_error (rc);
 
if (rc == sOKAY)
 {
 rc = rdm_transEnd (trans);
print_error (rc);
 }
else

 {
rdm_transEndRollback (trans);
 }
 }


return rc;
}
 
RDM_RETCODE doDBOperations (
RDM_TFS tfs 
 )
{
RDM_DB db;
RDM_RETCODE rc = rdm_tfsAllocDatabase (tfs, &db);
print_error (rc);
 
if (rc == sOKAY)
 {
 rc = openAndDeleteRows (db);
 
if (rc == sOKAY)
 {
 rc = insertTimeSeriesData (db);
 }
 
if (rc == sOKAY)
 {
 rc = readTimeSeriesData (db);
 }
 
if (rc == sOKAY)
 {
 rc = rdm_dbFree (db);
print_error (rc);
 }
else

 {
rdm_dbFree (db);
 }
 }
 
return rc;
}
 
RDM_RETCODE setupTFSAndDoDBOperations (void)
{
RDM_TFS tfs;
RDM_RETCODE rc = rdm_rdmAllocTFS (&tfs);
print_error (rc);
 
if (rc == sOKAY)
 {
 
 rc = rdm_tfsInitialize (tfs);
print_error (rc);
 
if (rc == sOKAY)
 {
 rc = doDBOperations (tfs);
 }
 
rdm_tfsFree (tfs);
 }
 
return rc;
}
 
int main_cpp70 (int argc, const char *const *argv)
{
 
RDM_CMDLINE cmd;
const RDM_CMDLINE_OPT opts[] = {{NULL, NULL, NULL, NULL}};
RDM_RETCODE rc = rdm_cmdlineInit (&cmd, argc, argv, "An example that demonstrates some time series functionality.", opts);
print_error (rc);
 
 rc = setupTFSAndDoDBOperations ();
 
return rc == sOKAY ? 0 : 1;
}
 
RDM_STARTUP_EXAMPLE (cpp70)