c-core/05_core/core05Example_main.c

/*
 * Raima Database Manager
 *
 * Copyright (c) 2019 Raima Inc.,  All rights reserved.
 *
 * Use of this software, whether in source code format, or in executable,
 * binary object code form, is governed by the Raima LICENSE which
 * is fully described in the LICENSE.TXT file, included within this
 * distribution of files.
 */

#include <stdio.h>
#include <stdlib.h>
#include <time.h>
#include "example_fcns.h"
#include "rdm.h"
#include "rdmstartupapi.h"

/* Generated \c struct and \c typedef definitions to be used with the RDM APIs
 */
#include "core05_structs.h"

/* Generated catalog definition to be used with the RDM rdm_dbSetCatalog() API
 */
#include "core05_cat.h"

RDM_CMDLINE cmd;
const char *const description = "Demonstrates using an index for ordering";
const RDM_CMDLINE_OPT opts[] = {{NULL, NULL, NULL, NULL}};

RDM_RETCODE insertFiveRows (
    RDM_DB hDB) 
{
    PERSON person_rec;
    RDM_RETCODE rc;

    rc = rdm_dbStartUpdate (hDB, RDM_LOCK_ALL, 0, NULL, 0, NULL);
    print_error (rc);
    if (rc == sOKAY)
    {
        int ii;

        printf ("Adding 5 new person records\n");
        for (ii = 0; ii < 5; ii++)
        {
            unsigned int value;

            value = (unsigned int) rand () % 10000;
            sprintf (person_rec.last_four_ssn, "%04u", value);
            rc = rdm_dbInsertRow (
                hDB, TABLE_PERSON, &person_rec, sizeof (person_rec), NULL);
            print_error (rc);
            printf ("\t%s\n", person_rec.last_four_ssn);
        }

        if (rc == sOKAY)
            rc = rdm_dbEnd (hDB);
        else
            rc = rdm_dbEndRollback (hDB);

        print_error (rc);
    }

    return rc;
}

RDM_RETCODE readAllRows (
    RDM_DB hDB) 
{
    PERSON person_rec;
    RDM_CURSOR cursor = NULL;
    RDM_RETCODE rc;

    rc = rdm_dbStartRead (hDB, RDM_LOCK_ALL, 0, NULL);
    print_error (rc);
    if (rc == sOKAY)
    {
        printf ("\nList all records in index order\n");
        rc = rdm_dbGetRowsByKey (hDB, KEY_PERSON_LAST_FOUR_SSN, &cursor);
        print_error (rc);

        if (rc == sOKAY)
        {
            for (rc = rdm_cursorMoveToFirst (cursor); rc == sOKAY;
                 rc = rdm_cursorMoveToNext (cursor))
            {
                rc = rdm_cursorReadRow (
                    cursor, &person_rec, sizeof (person_rec), NULL);
                print_error (rc);

                printf ("%s\n", person_rec.last_four_ssn);
            }
            rdm_cursorFree (cursor);
        }
        rdm_dbEnd (hDB);

        /* We expect rc to be sENDOFCURSOR when we break out of the loop */
        if (rc == sENDOFCURSOR)
        {
            rc = sOKAY; /* change status to sOKAY because sENDOFCURSOR was
                           expected. */
        }
        else
        {
            print_error (rc);
        }
    }
    return rc;
}

int main_core05 (int argc, const char *const *argv)
{
    RDM_TFS hTFS;
    RDM_DB hDB;
    RDM_RETCODE rc;

    /* Seed the random number generator */
    srand ((unsigned int) time (NULL));

    rc = rdm_cmdlineInit (&cmd, argc, argv, description, opts);
    if (rc != sCMD_USAGE)
        print_error (rc);

    if (rc == sOKAY)
    {
        rc = exampleOpenDatabase (&hTFS, &hDB, "core05", core05_cat);
        if (rc == sOKAY)
        {
            rc = insertFiveRows (hDB);
            if (rc == sOKAY)
            {
                rc = readAllRows (hDB);
            }
            exampleCleanup (hTFS, hDB);
        }
    }

    return (int) rc;
}

RDM_STARTUP_EXAMPLE (core05)