RunInfoSchema.h

Go to the documentation of this file.

#ifndef CondCore_CondDB_RunInfoSchema_h
#define CondCore_CondDB_RunInfoSchema_h

#include "DbCore.h"
#include "IDbSchema.h"
//
#include <boost/date_time/posix_time/posix_time.hpp>

namespace cond {

  namespace persistency {

    conddb_table(RUN_INFO) {
      conddb_column(RUN_NUMBER, cond::Time_t);
      conddb_column(START_TIME, boost::posix_time::ptime);
      conddb_column(END_TIME, boost::posix_time::ptime);

      struct MAX_RUN_NUMBER {
        typedef cond::Time_t type;
        static constexpr size_t size = 0;
        static std::string tableName() { return RUN_NUMBER::tableName(); }
        static std::string fullyQualifiedName() { return "MAX(" + RUN_NUMBER::fullyQualifiedName() + ")"; }
      };

      struct MIN_RUN_NUMBER {
        typedef cond::Time_t type;
        static constexpr size_t size = 0;
        static std::string tableName() { return RUN_NUMBER::tableName(); }
        static std::string fullyQualifiedName() { return "MIN(" + RUN_NUMBER::fullyQualifiedName() + ")"; }
      };

      struct MIN_START_TIME {
        typedef boost::posix_time::ptime type;
        static constexpr size_t size = 0;
        static std::string tableName() { return START_TIME::tableName(); }
        static std::string fullyQualifiedName() { return "MIN(" + START_TIME::fullyQualifiedName() + ")"; }
      };

      class Table : public IRunInfoTable {
      public:
        explicit Table(coral::ISchema& schema);
        ~Table() override {}
        bool exists() override;
        void create() override;
        bool select(cond::Time_t runNumber, boost::posix_time::ptime& start, boost::posix_time::ptime& end) override;
        cond::Time_t getLastInserted(boost::posix_time::ptime& start, boost::posix_time::ptime& end) override;
        bool getInclusiveRunRange(
            cond::Time_t lower,
            cond::Time_t upper,
            std::vector<std::tuple<cond::Time_t, boost::posix_time::ptime, boost::posix_time::ptime> >& runData)
            override;
        bool getInclusiveTimeRange(
            const boost::posix_time::ptime& lower,
            const boost::posix_time::ptime& upper,
            std::vector<std::tuple<cond::Time_t, boost::posix_time::ptime, boost::posix_time::ptime> >& runData)
            override;
        void insertOne(cond::Time_t runNumber,
                       const boost::posix_time::ptime& start,
                       const boost::posix_time::ptime& end) override;
        void insert(const std::vector<std::tuple<cond::Time_t, boost::posix_time::ptime, boost::posix_time::ptime> >&
                        runs) override;
        void updateEnd(cond::Time_t runNumber, const boost::posix_time::ptime& end) override;

      private:
        coral::ISchema& m_schema;
      };
    }

    class RunInfoSchema : public IRunInfoSchema {
    public:
      explicit RunInfoSchema(coral::ISchema& schema);
      ~RunInfoSchema() override {}
      bool exists() override;
      bool create() override;
      IRunInfoTable& runInfoTable() override;

    private:
      RUN_INFO::Table m_runInfoTable;
    };

  }  // namespace persistency
}  // namespace cond
#endif