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)