SqliteReadSvc.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2024 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef RDBACCESSSVC_SQLITEREADSVC_H
#define RDBACCESSSVC_SQLITEREADSVC_H
 
#include "RDBAccessSvc/IRDBAccessSvc.h"
#include "SqliteRecordset.h"
 
#include "AthenaBaseComps/AthService.h"
 
#include <sqlite3.h>
#include <string>
#include <map>
#include <mutex>
 
class ISvcLocator;
 
template <class TYPE> class SvcFactory;
 
// Map of recordset pointers by table name
typedef std::map<std::string, IRDBRecordset_ptr> RecordsetPtrMap;
 
class SqliteReadSvc final : public AthService, virtual public IRDBAccessSvc 
{
 public:
  SqliteReadSvc(const std::string& name, ISvcLocator* svc);
 
  StatusCode finalize() override;
  StatusCode queryInterface( const InterfaceID& riid, void** ppvInterface ) override;
 
  friend class SvcFactory<SqliteReadSvc>;
 
  static const InterfaceID& interfaceID() { return IID_IRDBAccessSvc; }
 
  bool connect(const std::string& connName) override;
 
  bool disconnect(const std::string&) override;
 
  bool shutdown(const std::string&) override;
 
  IRDBRecordset_ptr getRecordsetPtr(const std::string& node
                    , const std::string& 
                    , const std::string& 
                    , const std::string&) override;
 
  std::string getChildTag(const std::string& childNode
              , const std::string& 
              , const std::string& 
              , const std::string& ) override;
 
  std::unique_ptr<IRDBQuery> getQuery(const std::string& node
                      , const std::string& 
                      , const std::string& 
                      , const std::string& ) override;
 
  void getTagDetails(RDBTagDetails& tagDetails
             , const std::string& tag
             , const std::string& ) override;
 
private:
  RecordsetPtrMap m_recordsets;
  sqlite3*        m_db{nullptr};
  std::mutex      m_recordsetMutex;
  std::mutex      m_sessionMutex;
};
 
#endif