dbase.h

/*
Copyright (C) 2006  Adam Charrett

This program is free software; you can redistribute it and/or
modify it under the terms of the GNU General Public License
as published by the Free Software Foundation; either version 2
of the License, or (at your option) any later version.

This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU General Public License for more details.

You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software
Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA

dbase.h

Opens/Closes and setups the sqlite database for use by the rest of the application.

*/

#ifndef _DBASE_H
#define _DBASE_H
#include <sqlite3.h>

#define SERVICES_TABLE          "Services"

#define SERVICE_MULTIPLEXUID    "mplexuid"

#define SERVICE_ID              "id"

#define SERVICE_SOURCE          "source"

#define SERVICE_CA              "ca"

#define SERVICE_NAME            "name"

#define SERVICE_TYPE            "type"

#define SERVICE_PMTPID          "pmtpid"

#define SERVICE_PMTVERSION      "pmtversion"

#define SERVICE_PCRPID          "pcrpid"

#define SERVICE_PROVIDER        "provider"

#define SERVICE_DEFAUTHORITY    "defauthority"

#define MULTIPLEXES_TABLE       "Multiplexes"

#define MULTIPLEX_UID           "uid"

#define MULTIPLEX_FREQ          "freq"

#define MULTIPLEX_TSID          "tsid"

#define MULTIPLEX_NETID         "netid"

#define MULTIPLEX_TYPE          "type"

#define MULTIPLEX_PATVERSION    "patversion"

#define OFDMPARAMS_TABLE        "OFDMParameters"

#define OFDMPARAM_MULTIPLEXUID  "mplexuid"

#define OFDMPARAM_FREQ          "freq"

#define OFDMPARAM_INVERSION     "inversion"

#define OFDMPARAM_BW            "bw"

#define OFDMPARAM_FEC_HP        "fec_hp"

#define OFDMPARAM_FEC_LP        "fec_lp"

#define OFDMPARAM_QAM           "qam"

#define OFDMPARAM_TRANSMISSIONM "transmissionm"

#define OFDMPARAM_GUARDLIST     "guardlist"

#define OFDMPARAM_HIERARCHINFO  "hierarchinfo"

#define QPSKPARAMS_TABLE  "QPSKParameters"

#define QPSKPARAM_MULTIPLEXUID  "mplexuid"

#define QPSKPARAM_FREQ          "freq"

#define QPSKPARAM_INVERSION     "inversion"

#define QPSKPARAM_SYMBOL_RATE    "symbol_rate"

#define QPSKPARAM_FEC_INNER      "fec_inner"

#define QPSKPARAM_POLARISATION   "polarisation"

#define QPSKPARAM_SATNUMBER      "satnumber"

#define QAMPARAMS_TABLE   "QAMParameters"

#define QAMPARAM_MULTIPLEXUID  "mplexuid"

#define QAMPARAM_FREQ           "freq"

#define QAMPARAM_INVERSION      "inversion"

#define QAMPARAM_SYMBOL_RATE    "symbol_rate"

#define QAMPARAM_FEC_INNER      "fec_inner"

#define QAMPARAM_MODULATION     "modulation"

#define VSBPARAMS_TABLE   "VSBParameters"

#define VSBPARAM_MULTIPLEXUID  "mplexuid"

#define VSBPARAM_FREQ           "freq"

#define VSBPARAM_MODULATION     "modulation"

#define PIDS_TABLE              "PIDs"

#define PID_MULTIPLEXUID        "mplexuid"

#define PID_SERVICEID           "serviceid"

#define PID_PID                 "pid"

#define PID_TYPE                "type"

#define PID_SUBTYPE             "subtype"

#define PID_PMTVERSION          "pmtversion"

#define PID_DESCRIPTORS         "descriptors"

#define METADATA_TABLE           "Metadata"

#define METADATA_NAME            "name"

#define METADATA_VALUE           "value"

#define EPGEVENTS_TABLE          "EPGEvents"

#define EPGEVENT_NETID           "netid"

#define EPGEVENT_TSID            "tsid"

#define EPGEVENT_SERVICEID       "serviceid"

#define EPGEVENT_EVENTID         "eventid"

#define EPGEVENT_STARTTIME       "starttime"

#define EPGEVENT_ENDTIME         "endtime"

#define EPGEVENT_CA              "ca"

#define EPGRATINGS_TABLE         "EPGRatings"

#define EPGRATING_ID             "id"

#define EPGRATING_EVENTUID         "eventuid"

#define EPGRATING_STANDARD        "standard"

#define EPGRATING_RATING          "rating"

#define EPGDETAILS_TABLE         "EPGDetails"

#define EPGDETAIL_ID             "id"

#define EPGDETAIL_EVENTUID         "eventuid"

#define EPGDETAIL_LANGUAGE        "lang"

#define EPGDETAIL_NAME            "name"

#define EPGDETAIL_VALUE           "value"

#define METADATA_NAME_LNB_LOW_FREQ     "lnb.lowfreq"

#define METADATA_NAME_LNB_HIGH_FREQ    "lnb.highfreq"

#define METADATA_NAME_LNB_SWITCH_FREQ  "lnb.switchfreq"

#define METADATA_NAME_SCAN_ALL "scan.all"

#define STATEMENT_INIT int rc; sqlite3_stmt *stmt=NULL

#ifndef DBASE_CONNECTION_GET

#define DBASE_CONNECTION_GET DBaseConnectionGet
#endif

#define STATEMENT_PREPARE(_statement) rc = sqlite3_prepare( DBASE_CONNECTION_GET(),  _statement, -1, &stmt, NULL)

#define STATEMENT_PREPAREVA(_statement, _args...) \
    do{\
        char *sqlstring;\
        sqlstring = sqlite3_mprintf(_statement, _args);\
        if (sqlstring)\
        {\
            STATEMENT_PREPARE(sqlstring);\
            sqlite3_free(sqlstring);\
        }\
        else\
        {\
            rc = SQLITE_NOMEM;\
        }\
    }while(0)

#define STATEMENT_STEP()                rc = sqlite3_step(stmt)

#define STATEMENT_COLUMN_INT(_index)    sqlite3_column_int(stmt, _index)

#define STATEMENT_COLUMN_DOUBLE(_index) sqlite3_column_double(stmt, _index)

#define STATEMENT_COLUMN_TEXT(_index)   (char*)sqlite3_column_text( stmt, _index)

#define STATEMENT_FINALIZE()            rc = sqlite3_finalize(stmt)

#define PRINTLOG_SQLITE3ERROR() \
    do{\
        LogModule(LOG_DEBUG, "dbase", "%s(%d): Failed with error code 0x%x=%s\n",\
            __FUNCTION__,__LINE__, rc, sqlite3_errmsg(DBASE_CONNECTION_GET()));\
    }while(0)

#define RETURN_ON_ERROR(_result) \
    do{\
        if ((rc != SQLITE_OK) && (rc != SQLITE_ROW) && (rc != SQLITE_DONE))\
        {\
            PRINTLOG_SQLITE3ERROR();\
            if (stmt)\
            {\
                STATEMENT_FINALIZE();\
            }\
            return _result;\
        }\
    }while(0)

#define RETURN_RC_ON_ERROR RETURN_ON_ERROR(rc)

int DBaseInit(int adapter);

void DBaseDeInit();

sqlite3* DBaseConnectionGet(void);
    
int DBaseTransactionBegin(void);

int DBaseTransactionCommit(void);

int DBaseMetadataGet(char *name, char **value);

int DBaseMetadataSet(char *name, char *value);

int DBaseMetadataGetInt(char *name, int *value);
int DBaseMetadataSetInt(char *name, int value);

int DBaseMetadataGetDouble(char *name, double *value);

int DBaseMetadataSetDouble(char *name, double value);

int DBaseMetadataDelete(char *name);

#endif

---