ISISDB.h

Go to the documentation of this file.

#ifndef ISISDB_H
#define ISISDB_H

#include "sqlite3.h"

static const char* isisdb_per_session_sql = "";

//                      "DROP TABLE IF EXISTS t1; " 
//                      "CREATE TEMPORARY TABLE t1 ( run_number INTEGER, source TEXT, period INTEGER, iso_time STRING, unix_time INTEGER, is_start INTEGER ); "
//                      "DROP TRIGGER IF EXISTS on_run_state; "
//                      "CREATE TEMPORARY TRIGGER on_run_state AFTER INSERT ON run_state FOR EACH ROW BEGIN "
//                      "DELETE FROM t1; "
//                      "INSERT INTO t1 VALUES ( -1, 'TRIGGER', -1, new.iso_time, new.unix_time, new.is_start ); "  /* 'TRIGGER' or seblocks.source ? */
//                      "UPDATE t1 SET period=(SELECT value FROM config WHERE name='period'); "
//                      "UPDATE t1 SET run_number=(SELECT value FROM config WHERE name='run_number'); "
//                      "INSERT INTO seperiods SELECT t1.run_number,t1.period,t1.iso_time,t1.unix_time,t1.is_start,seblocks.block_name,seblocks.setpoint_value,seblocks.block_value FROM t1,seblocks WHERE seblocks.run_number=t1.run_number; "
//                      "INSERT INTO selog SELECT t1.run_number,t1.source,t1.iso_time,t1.unix_time,seblocks.block_name,seblocks.block_value,seblocks.is_real FROM t1,seblocks WHERE seblocks.run_number=t1.run_number; "
//                      "END; ";

class ISISDB
{
  private:
        sqlite3* m_db;
        static std::list<sqlite3*> db_list;
        static const char* db_file;

  public:
        ISISDB(bool integrity_check);

        ~ISISDB();

        operator sqlite3*()
        {
                return m_db;
        }

        int closeDatabase();

        int exec(const char* sql, int (*callback)(void*,int,char**,char**),  void* arg)
        {
                char last_error[256];
                char *errmsg = NULL;
                int ret = sqlite3_exec(m_db, sql, callback, arg, &errmsg);
                if (ret != SQLITE_OK)
                {
                        _snprintf_s(last_error, sizeof(last_error), _TRUNCATE, "SELOGGER: SQLITE error %s", errmsg);
                        sqlite3_free(errmsg);
                        throw(std::exception(last_error));
                }
                return ret;
        }

        const char* version();
};

#include "Poco/SingletonHolder.h"
#include "Poco/Data/Common.h"
#include "Poco/Data/SessionPool.h"
#include "Poco/Data/SQLite/Connector.h"
#include "Poco/Data/MySQl/Connector.h"
#include "Poco/Data/RecordSet.h"

class SQLITESessionPool : public Poco::Data::SessionPool
{
public:
        SQLITESessionPool() : Poco::Data::SessionPool("SQLite", "c:\\data\\selog.sq3", 3, 32, 0)
        {
                Poco::Data::SQLite::Connector::registerConnector();
        }

        void customizeSession(Poco::Data::Session& session)
        {
                session.setProperty("maxRetryAttempts", 1000000);
                if (strlen(isisdb_per_session_sql) > 0)
                {
                        Poco::Data::Statement stmt(session);
                        stmt << isisdb_per_session_sql;
                        stmt.execute();
                        poco_assert(stmt.done());
                }
        }
};

extern Poco::SingletonHolder<SQLITESessionPool> sqlite_session_pool;


#endif /* ISISDB_H */