RDBQuery.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2026 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef RDBACCESSSVC_RDBQUERY_H
#define RDBACCESSSVC_RDBQUERY_H
 
#include "RDBAccessSvc/IRDBQuery.h"
#include "DBLock/DBLock.h"
#include <memory>
#include <vector>
#include <string>
 
namespace coral
{
  class IQuery;
  class ICursor;
}

 
class RDBAccessSvc;
 
class RDBQuery final : public IRDBQuery
{
 public:
  RDBQuery(const Athena::DBLock& dblock
           , RDBAccessSvc* accessSvc
       , const std::string& nodeName
       , const std::string& tagId
       , const std::string& connName);
 
  virtual ~RDBQuery() override;
  
  virtual void execute() override;
  virtual long size() override;
  virtual void finalize() override;
  virtual void setOrder(const std::string&) override;
  virtual void addToOutput(const std::string&) override;
 
  virtual bool next() override;
 
 private:
  RDBQuery() = delete;
 
  Athena::DBLock           m_dblock;
  std::unique_ptr<coral::IQuery>  m_query;
  std::unique_ptr<coral::IQuery>  m_queryCount;
  RDBAccessSvc*            m_accessSvc;
  std::string              m_nodeName;
  std::string              m_tagId;
  std::string              m_connName;
  long                     m_size;
  std::vector<std::string> m_fields;
  coral::ICursor*          m_cursor;
  std::string              m_orderField;
  bool                     m_executed;
};
 
#endif