MonitorDB Class Reference

Static Public Member Functions
static void	add (DBInterface &db, const std::string &tablename, const std::string &vname, int val)
static void	add (DBInterface &db, const std::string &tablename, const std::string &vname, float val)
static void	add (DBInterface &db, const std::string &tablename, const std::string &vname, const std::string &val)
static NSMVarList	get (DBInterface &db, const std::string &tablename, const std::string &vname)
static NSMVarList	get (DBInterface &db, const std::string &tablename, const std::string &vname, int max)
static NSMVarList	get (DBInterface &db, const std::string &tablename, const std::string &vname, const Date &start, const Date &end)
static NSMVarList	get (DBInterface &db, const std::string &tablename, const std::string &vname, int max, const Date &start, const Date &end)

Static Private Member Functions
static NSMVarList	readTable (DBInterface &db, const std::string &vname)
static void	createTable (DBInterface &db, const std::string &tablename)

Detailed Description

Definition at line 23 of file MonitorDB.h.

Member Function Documentation

add() [1/3]

void add ( DBInterface &  db, const std::string &  tablename, const std::string &  vname, const std::string &  val  )

static

Definition at line 41 of file MonitorDB.cc.

{
  try {
    createTable(db, table);
    db.execute("insert into %s (name, value_t) values ('%s', '%s');",
               table.c_str(), vname.c_str(), val.c_str());
  } catch (const DBHandlerException& e) {
    LogFile::error(e.what());
    throw (e);
  }
 
}

add() [2/3]

void add ( DBInterface &  db, const std::string &  tablename, const std::string &  vname, float  val  )

static

Definition at line 28 of file MonitorDB.cc.

{
  try {
    createTable(db, table);
    db.execute("insert into %s (name, value_f) values ('%s', %f);",
               table.c_str(), vname.c_str(), val);
  } catch (const DBHandlerException& e) {
    LogFile::error(e.what());
    throw (e);
  }
}

add() [3/3]

void add ( DBInterface &  db, const std::string &  tablename, const std::string &  vname, int  val  )

static

Definition at line 15 of file MonitorDB.cc.

{
  try {
    createTable(db, table);
    db.execute("insert into %s (name, value_i) values ('%s', %d);",
               table.c_str(), vname.c_str(), val);
  } catch (const DBHandlerException& e) {
    LogFile::error(e.what());
    throw (e);
  }
}

createTable()

void createTable ( DBInterface &  db, const std::string &  tablename  )

staticprivate

Definition at line 130 of file MonitorDB.cc.

{
  if (!db.isConnected()) db.connect();
  if (!db.checkTable(tablename)) {
    db.execute("create table %s \n"
               "(name  varchar(64), \n"
               "id bigserial, \n"
               "record_time timestamp with time zone default current_timestamp, \n"
               "value_b boolean default NULL, \n"
               "value_c char default NULL, \n"
               "value_s smallint default NULL, \n"
               "value_i int default NULL, \n"
               "value_l bigint default NULL, \n"
               "value_f float default NULL, \n"
               "value_d double precision default NULL, \n"
               "value_t text default NULL \n"
               "); ", tablename.c_str());
    db.execute("create index %s_id_index on %s(id);",
               tablename.c_str(), tablename.c_str());
  }
}

get() [1/4]

NSMVarList get ( DBInterface &  db, const std::string &  tablename, const std::string &  vname  )

static

Definition at line 55 of file MonitorDB.cc.

{
  if (!db.isConnected()) db.connect();
  db.execute("select *, extract(epoch from record_time) rtime "
             "from %s p where p.name = '%s' order by id;",
             tablename.c_str(), vname.c_str());
  return readTable(db, vname);
}

get() [2/4]

NSMVarList get ( DBInterface &  db, const std::string &  tablename, const std::string &  vname, const Date &  start, const Date &  end  )

static

Definition at line 75 of file MonitorDB.cc.

{
  if (!db.isConnected()) db.connect();
  db.execute("select *, extract(epoch from record_time) rtime "
             "from %s p where p.name = '%s' and record_time > '%s' and "
             "record_time < '%s'order by id;", tablename.c_str(),
             vname.c_str(), start.toString(), end.toString());
  return readTable(db, vname);
}

get() [3/4]

NSMVarList get ( DBInterface &  db, const std::string &  tablename, const std::string &  vname, int  max  )

static

Definition at line 65 of file MonitorDB.cc.

{
  if (!db.isConnected()) db.connect();
  db.execute("select *, extract(epoch from record_time) rtime "
             "from %s p where p.name = '%s' limit %d order by id;",
             tablename.c_str(), vname.c_str(), max);
  return readTable(db, vname);
}

get() [4/4]

NSMVarList get ( DBInterface &  db, const std::string &  tablename, const std::string &  vname, int  max, const Date &  start, const Date &  end  )

static

Definition at line 87 of file MonitorDB.cc.

{
  if (!db.isConnected()) db.connect();
  db.execute("select *, extract(epoch from record_time) rtime "
             "from %s p where p.name = '%s' and record_time > '%s' and "
             "record_time < '%s' limit %d order by id;",
             tablename.c_str(), vname.c_str(),
             start.toString(), end.toString(), max);
  return readTable(db, vname);
}

readTable()

NSMVarList readTable ( DBInterface &  db, const std::string &  vname  )

staticprivate

Definition at line 100 of file MonitorDB.cc.

{
  DBRecordList record_v(db.loadRecords());
  NSMVarList vars;
  for (size_t i = 0; i < record_v.size(); i++) {
    DBRecord& record(record_v[i]);
    NSMVar var(vname);
    if (record.hasField("value_b")) {
      var = (int)record.getBool("value_b");
    } else if (record.hasField("value_c")) {
      var = (int)record.getInt("value_c");
    } else if (record.hasField("value_s")) {
      var = (int)record.getInt("value_s");
    } else if (record.hasField("value_i")) {
      var = record.getInt("value_i");
    } else if (record.hasField("value_f")) {
      var = record.getFloat("value_f");
    } else if (record.hasField("value_d")) {
      var = record.getFloat("value_d");
    } else if (record.hasField("value_t")) {
      var = record.get("value_t");
    }
    var.setId(record.getInt("id"));
    var.setDate(record.getInt("rtime"));
    LogFile::debug("%d=%s", record.getInt("rtime"), Date(var.getDate()).toString());
    vars.push_back(var);
  }
  return vars;
}

---

The documentation for this class was generated from the following files:

• daq/slc/database/include/MonitorDB.h
• daq/slc/database/src/MonitorDB.cc