PgPostBankBackupManager.h

Go to the documentation of this file. Or view the newest version in sPHENIX GitHub for file PgPostBankBackupManager.h

// Tell emacs that this is a C++ source
//  -*- C++ -*-.
// $Id: PgPostBankBackupManager.hh,v 1.8 2014/05/19 17:06:23 jinhuang Exp $

#ifndef PDBCALPG_PGPOSTBANKBACKUPMANAGER_H
#define PDBCALPG_PGPOSTBANKBACKUPMANAGER_H

#include <phool/PHTimeStamp.h>

#include <iostream>
#include <string>
#include <vector>

class PdbCalChan;
class PgPostBankBackupStorage;
class TSQLStatement;
class TSQLPreparedStatement;
class TSQLResultSet;

class PgPostBankBackupManager
{
 public:
  PgPostBankBackupManager(const std::string &Tag = "");
  virtual ~PgPostBankBackupManager();

  typedef std::vector<int> rid_list_t;

 public:
  bool
  isRIdExist(const std::string &bankName, int rid);

  int getTotalRowCount(const std::string &bankName);

  rid_list_t
  getListOfRId(const std::string &bankName,
               const std::string &condition = "");

  PgPostBankBackupStorage *
  fetchBank(const std::string &bankName, int rid);

  bool
  commit(PgPostBankBackupStorage *bs);

  int commitAllBankfromTFile(const std::string &in_file);

  int fetchBank2TFile(const std::string &bankName, const rid_list_t &rid_list,
                      const std::string &out_file);

  int fetchAllBank2TFile(const std::string &bankName,
                         const std::string &record_selection, const std::string &out_file_base,
                         int splitting_limit = 100000);

  void
  dumpTable(const std::string &bankName, std::ostream &out);

  int CleanTable(const std::string &bankName,
                 const PHTimeStamp &min_preserve_time = PHTimeStamp::PHFarFuture,
                 const bool do_delete = false, const std::string &log_file_name = "");

  virtual void
  Verbosity(const int ival)
  {
    verbosity = ival;
  }

  virtual int
  Verbosity() const
  {
    return verbosity;
  }

  static std::string
  getBankBaseName(const std::string &bank_classname);

  static void
  deleteSQLStatement(TSQLStatement *stmt);

  static void
  deleteODBCPreparedStatement(TSQLPreparedStatement *stmt);

  static ULong_t
  HashPdbCalChan(const PdbCalChan &c);

 protected:
  PgPostBankBackupStorage *
  SQLResultSet2BackupStorage(TSQLResultSet *rs, const std::string &table_name);

  int verbosity;

  std::string tag;
};

#endif /* PDBCAL_PG_PGPOSTBANKBACKUPMANAGER_H */