core14Example_main.c

Simple example on how to insert a large amount of data at once using RDM's simple API. This example needs a compiled schema, core14Example.sdl.

#include "rdm.h"

#include "rdmapi.h"

#include "rdmtfsapi.h"

#include "core14Example_structs.h"

#include "core14Example_cat.h"

#include "rdmdatetimeapi.h"

#include "rdmstartupapi.h"



#include <stdio.h>

#include <stdlib.h>



int32_t main_bulkInsertTutorial (int32_t argc, const char *const *argv)
{
RDM_RETCODE rc;
RDM_TFS tfs;


RDM_UNREF (argc);
RDM_UNREF (argv);


/* Allocate a TFS Handle */

rc = rdm_rdmAllocTFS (&tfs);
if (rc == sOKAY)
{
rc = rdm_tfsInitialize (tfs);


/* Allocate a database hande */

if (rc == sOKAY)
{
RDM_DB db;
rc = rdm_tfsAllocDatabase (tfs, &db);
if (rc == sOKAY)
{
/* Override default DURABLE setting to CONSISTENT */

rc = rdm_dbSetOptions (db, "durability=consistent");
}
if (rc == sOKAY)
{
RDM_TABLE_ID tables[] = {TABLE_BULKINSERT};


rc = rdm_dbSetCatalog (db, core14Example_cat);


if (rc == sOKAY)
{
/* Open the database. */

rc =
rdm_dbOpen (db, "core14Example", RDM_OPEN_SHARED);
}
if (rc == sOKAY)
{
/* Start an update transaction and lock the table */

rc = rdm_dbStartUpdate (
db, tables, RDM_LEN (tables), NULL, 0, NULL);
}
if (rc == sOKAY)
{
/* Remove all of the rows from the database */

rc = rdm_dbDeleteAllRowsFromDatabase (db);


if (rc == sOKAY)
{
/* Commit a transaction */

rc = rdm_dbEnd (db);
}
else

{
/* Abort the transaction */

rdm_dbEndRollback (db);
}
}


if (rc == sOKAY)
{
/* Start an update transaction and lock the table */

rc = rdm_dbStartUpdate (
db, tables, RDM_LEN (tables), NULL, 0, NULL);
}
if (rc == sOKAY)
{
BULKINSERT insertions[3];
RDM_PACKED_DATE_T rdmDate;
int16_t tzPST = -420;
uint32_t counter;


(void) rdm_dateFromString (
"11-11-2011", RDM_MMDDYYYY, &rdmDate);
insertions[0].id = rdmDate;
insertions[0]._id_has_value = RDM_COL_HAS_VALUE;
(void) rdm_dateToday (tzPST, &rdmDate);
insertions[1].id = rdmDate;
insertions[1]._id_has_value = RDM_COL_HAS_VALUE;
(void) rdm_dateFromString (
"09-17-2013", RDM_MMDDYYYY, &rdmDate);
insertions[2].id = rdmDate;
insertions[2]._id_has_value = RDM_COL_HAS_VALUE;


/* Insert multiple rows into the table */

rc = rdm_dbInsertRows (
db, TABLE_BULKINSERT, insertions, sizeof (insertions),
RDM_LEN (insertions), NULL, NULL);


for (counter = 0;
rc == sOKAY && counter < RDM_LEN (insertions);
counter++)
{
char outBuffer[100];
rdm_dateToString (
insertions[counter].id, RDM_MMDDYYYY,
RDM_DEF_DATE_SEP, outBuffer, sizeof (outBuffer),
NULL);
printf ("Date Inserted: %s\n", outBuffer);
}


if (rc == sOKAY)
{
/* Commit a transaction */

rc = rdm_dbEnd (db);
}
else

{
/* Abort the transaction */

rdm_dbEndRollback (db);
}
}


if (rc == sOKAY)
{
/* Start a read transaction and lock the table */

rc = rdm_dbStartRead (db, tables, RDM_LEN (tables), NULL);
}
if (rc == sOKAY)
{
RDM_CURSOR cursor = NULL;
rc = rdm_dbGetRows (db, TABLE_BULKINSERT, &cursor);
if (rc == sOKAY)
{
rc = rdm_cursorMoveToFirst (cursor);


while (rc == sOKAY)
{
BULKINSERT recS;


rc = rdm_cursorReadRow (
cursor, &recS, sizeof (recS), NULL);
if (rc == sOKAY)
{
char outBuffer[100];
rdm_dateToString (
recS.id, RDM_DEF_DATE_FORMAT,
RDM_DEF_DATE_SEP, outBuffer,
sizeof (outBuffer), NULL);
printf ("Date Retrieved: %s\n", outBuffer);
rc = rdm_cursorMoveToNext (cursor);
}
}
/* We will break out of the loop with a sENDOFCURSOR

* return code */

if (rc == sENDOFCURSOR)
{
rc = sOKAY;
}


/* Free the cursor allocated in the rdm_dbGetRows call

*/

rdm_cursorFree (cursor);
}


/* Free the read locks */

rdm_dbEnd (db);
}
/* Free the databse handle */

rdm_dbFree (db);
}
}
/* Free the TFS handle */

rdm_tfsFree (tfs);
}


if (rc != sOKAY)
{
printf (
"There was an error in this Tutorial (%s - %s)\n",
rdm_retcodeGetName (rc), rdm_retcodeGetDescription (rc));
return EXIT_FAILURE;
}


return EXIT_SUCCESS;
}


RDM_STARTUP_EXAMPLE (bulkInsertTutorial)