BaseSqlInterface.h

// (c) Copyright 2022 CERN for the benefit of the LHCb Collaboration.
//
// This software is distributed under the terms of the GNU General Public
// Licence version 3 (GPL Version 3), copied verbatim in the file "LICENCE".
//
// In applying this licence, CERN does not waive the privileges and immunities
// granted to it by virtue of its status as an Intergovernmental Organization
// or submit itself to any jurisdiction.
 
 
#pragma once
#include <iostream>
#include <string>
#include <unordered_map>
 
#include "SQLamarr/db_functions.h"
 
namespace SQLamarr
{
  class BaseSqlInterface
  {
    public: 
      BaseSqlInterface(SQLite3DB& db);
      virtual ~BaseSqlInterface();
 
      void sync_database(const std::string& db_uri)
      {update_db_connection(m_database, db_uri);}
 
      void invalidate_cache(void);
 
    protected: // members
      SQLite3DB& m_database; 
 
 
    private: //members
      std::unordered_map<std::string, sqlite3_stmt*> m_queries;
      sqlite3* m_cached_raw_ptr;
 
    protected: // methods
      sqlite3_stmt* get_statement (
          const std::string& name,      
          const std::string& query      
          );
 
      void begin_transaction () { sqlite3_exec(m_database.get(), "BEGIN", 0, 0, 0); }
 
      void end_transaction () { sqlite3_exec(m_database.get(), "COMMIT", 0, 0, 0); }
 
      int last_insert_row () { return sqlite3_last_insert_rowid(m_database.get()); }
 
      void using_sql_function (
          const std::string& name,  
          int argc,                 
          void (*xFunc)(sqlite3_context*, int, sqlite3_value**) 
          );
 
      bool exec_stmt (sqlite3_stmt*);
  };
}