lariov::DBDataset Class Reference

#include "DBDataset.h"

Classes
class	DBRow

Public Types
typedef std::variant< long, double, std::unique_ptr< std::string > >	value_type

Public Member Functions
	DBDataset ()
	DBDataset (void *dataset, bool release=false)
	DBDataset (const IOVTimeStamp &begin_time, const IOVTimeStamp &end_time, std::vector< std::string > &&col_names, std::vector< std::string > &&col_types, std::vector< DBChannelID_t > &&channels, std::vector< value_type > &&data)
const IOVTimeStamp &	beginTime () const
const IOVTimeStamp &	endTime () const
size_t	nrows () const
size_t	ncols () const
const std::vector< std::string > &	colNames () const
const std::vector< std::string > &	colTypes () const
const std::vector< DBChannelID_t > &	channels () const
const std::vector< value_type > &	data () const
int	getRowNumber (DBChannelID_t ch) const
int	getColNumber (const std::string &name) const
DBRow	getRow (size_t row) const

Private Attributes
IOVTimeStamp	fBeginTime
IOVTimeStamp	fEndTime
std::vector< std::string >	fColNames
std::vector< std::string >	fColTypes
std::vector< DBChannelID_t >	fChannels
std::vector< value_type >	fData

Detailed Description

Definition at line 59 of file DBDataset.h.

Member Typedef Documentation

typedef std::variant<long, double, std::unique_ptr<std::string> > lariov::DBDataset::value_type

Definition at line 64 of file DBDataset.h.

Constructor & Destructor Documentation

lariov::DBDataset::DBDataset

(

)

Definition at line 20 of file DBDataset.cxx.

: fBeginTime(0, 0), fEndTime(0, 0) {}

lariov::DBDataset::DBDataset	(	void *	dataset,
		bool	release = false
	)

Definition at line 24 of file DBDataset.cxx.

References col, fBeginTime, fChannels, fColNames, fColTypes, fData, fEndTime, lariov::IOVTimeStamp::GetFromString(), lariov::kBUFFER_SIZE, lariov::kNUMBER_HEADER_ROWS, lariov::IOVTimeStamp::MaxTimeStamp(), ncols(), nrows(), and value.

                                                      : fBeginTime(0, 0), fEndTime(0, 0)
{
  // Parse dataset and get number of rows.

  size_t nrows = getNtuples(dataset) - kNUMBER_HEADER_ROWS;
  //mf::LogInfo("DBDataset") << "DBDataset: Number of rows = " << nrows << "\n";
  fChannels.reserve(nrows);

  // Process header rows.

  int err = 0;
  char buf[kBUFFER_SIZE];
  Tuple tup;

  // Extract IOV begin time.

  tup = getTuple(dataset, 0);
  getStringValue(tup, 0, buf, kBUFFER_SIZE, &err);
  fBeginTime = IOVTimeStamp::GetFromString(std::string(buf));
  //mf::LogInfo log("DBDataset");
  //log << "DBDataset: Begin time stamp input = " << buf << "\n";
  //log << "DBDataset: Begin time stamp = " << fBeginTime.DBStamp() << "\n";
  releaseTuple(tup);

  // Extract IOV end time.

  tup = getTuple(dataset, 1);
  getStringValue(tup, 0, buf, kBUFFER_SIZE, &err);
  if (0 == strcmp(buf, "-"))
    fEndTime = IOVTimeStamp::MaxTimeStamp();
  else
    fEndTime = IOVTimeStamp::GetFromString(std::string(buf));
  //mf::LogInfo log("DBDataset");
  //log << "DBDataset: End time stamp input = " << buf << "\n";
  //log << "DBDataset: End time stamp = " << fEndTime.DBStamp() << "\n";
  releaseTuple(tup);

  // Extract column names.

  tup = getTuple(dataset, 2);
  size_t ncols = getNfields(tup);
  //mf::LogInfo("DBDataset") << "DBDataset: Number of columns = " << ncols << "\n";
  fColNames.reserve(ncols);
  for (size_t col = 0; col < ncols; ++col) {
    getStringValue(tup, col, buf, kBUFFER_SIZE, &err);
    //mf::LogInfo("DBDataset") << "DBDataset: Column name = " << buf << "\n";
    fColNames.push_back(std::string(buf));
  }
  releaseTuple(tup);

  // Extract column types.

  tup = getTuple(dataset, 3);
  fColTypes.reserve(ncols);
  for (size_t col = 0; col < ncols; ++col) {
    getStringValue(tup, col, buf, kBUFFER_SIZE, &err);
    //mf::LogInfo("DBDataset") << "DBDataset: Column type = " << buf << "\n";
    fColTypes.push_back(std::string(buf));
  }
  releaseTuple(tup);

  // Extract data.  Loop over rows.

  fData.reserve(nrows * ncols);
  for (size_t row = 0; row < nrows; ++row) {
    //mf::LogInfo("DBDataset") << "\nRow " << row << "\n";
    tup = getTuple(dataset, row + kNUMBER_HEADER_ROWS);

    // Loop over columns.

    for (size_t col = 0; col < ncols; ++col) {
      getStringValue(tup, col, buf, kBUFFER_SIZE, &err);

      // Convert string value to DBDataset::value_type (std::variant).

      if (fColTypes[col] == "integer" || fColTypes[col] == "bigint") {
        long value = strtol(buf, 0, 10);
        fData.push_back(value_type(value));
        //mf::LogInfo("DBDataset") << "DBDataset: row=" << row << ", column=" << col << ", value=" << fData.back()
        //      << "\n";
        if (col == 0) {
          fChannels.push_back(value);
          //mf::LogInfo("DBDataset") << "DBDataset: channel=" << fChannels.back() << "\n";
        }
      }
      else if (fColTypes[col] == "real") {
        double value = strtod(buf, 0);
        fData.push_back(value_type(value));
        //mf::LogInfo("DBDataset") << "DBDataset: row=" << row << ", column=" << col << ", value=" << fData.back()
        //      << "\n";
        if (col == 0) {
          mf::LogError("DBDataset") << "First column has wrong type real."
                                    << "\n";
          throw cet::exception("DBDataset") << "First column has wrong type real.";
        }
      }
      else if (fColTypes[col] == "text") {
        fData.emplace_back(std::make_unique<std::string>(buf));
        //mf::LogInfo("DBDataset") << "DBDataset: row=" << row << ", column=" << col << ", value=" << fData.back()
        //      << "\n";
        if (col == 0) {
          mf::LogError("DBDataset") << "First column has wrong type text."
                                    << "\n";
          throw cet::exception("DBDataset") << "First column has wrong type text.";
        }
      }
      else if (fColTypes[col] == "boolean") {
        long value = 0;
        std::string s = std::string(buf);
        if (s == "true" || s == "True" || s == "TRUE" || s == "1")
          value = 1;
        else if (s == "false" || s == "False" || s == "FALSE" || s == "0")
          value = 0;
        else {
          mf::LogError("DBDataset") << "Unknown string representation of boolean " << s << "\n";
          throw cet::exception("DBDataset")
            << "Unknown string representation of boolean " << s << "\n";
        }
        fData.push_back(value_type(value));
        //mf::LogInfo("DBDataset") << "DBDataset: row=" << row << ", column=" << col << ", value=" << fData.back()
        //      << "\n";
        if (col == 0) {
          mf::LogError("DBDataset") << "First column has wrong type boolean."
                                    << "\n";
          throw cet::exception("DBDataset") << "First column has wrong type boolean.";
        }
      }
      else {
        mf::LogError("DBDataset") << "Unknown datatype = " << fColTypes[col] << "\n";
        throw cet::exception("DBDataset")
          << "Unknown datatype = " << fColTypes[col] << ": " << buf << "\n";
      }
    }
    releaseTuple(tup);
  }

  // Maybe release dataset memory.

  if (release) releaseDataset(dataset);
}

lariov::DBDataset::DBDataset	(	const IOVTimeStamp &	begin_time,
		const IOVTimeStamp &	end_time,
		std::vector< std::string > &&	col_names,
		std::vector< std::string > &&	col_types,
		std::vector< DBChannelID_t > &&	channels,
		std::vector< value_type > &&	data
	)

Definition at line 167 of file DBDataset.cxx.

  : // Calibration data.
  fBeginTime(begin_time)
  , fEndTime(end_time)
  , fColNames(std::move(col_names))
  , fColTypes(std::move(col_types))
  , fChannels(std::move(channels))
  , fData(std::move(data))
{}

Member Function Documentation

const IOVTimeStamp& lariov::DBDataset::beginTime ( ) const

inline

Definition at line 115 of file DBDataset.h.

References fBeginTime.

Referenced by lariov::DBFolder::CachedStart(), lariov::DBFolder::CompareDataset(), lariov::DBFolder::DumpDataset(), and lariov::DBFolder::IsValid().

{ return fBeginTime; }

const std::vector<DBChannelID_t>& lariov::DBDataset::channels ( ) const

inline

Definition at line 121 of file DBDataset.h.

References fChannels.

Referenced by lariov::DBFolder::CompareDataset(), and lariov::DBFolder::GetChannelList().

{ return fChannels; }

const std::vector<std::string>& lariov::DBDataset::colNames ( ) const

inline

Definition at line 119 of file DBDataset.h.

References fColNames.

Referenced by lariov::DBFolder::CompareDataset(), and lariov::DBFolder::DumpDataset().

{ return fColNames; }

const std::vector<std::string>& lariov::DBDataset::colTypes ( ) const

inline

Definition at line 120 of file DBDataset.h.

References fColTypes.

Referenced by lariov::DBFolder::CompareDataset(), and lariov::DBFolder::DumpDataset().

{ return fColTypes; }

const std::vector<value_type>& lariov::DBDataset::data ( ) const

inline

Definition at line 122 of file DBDataset.h.

References lariov::DBDataset::DBRow::fData, getColNumber(), and getRowNumber().

Referenced by lariov::DBFolder::CompareDataset().

{ return fData; }

const IOVTimeStamp& lariov::DBDataset::endTime ( ) const

inline

Definition at line 116 of file DBDataset.h.

References fEndTime.

Referenced by lariov::DBFolder::CachedEnd(), lariov::DBFolder::DumpDataset(), and lariov::DBFolder::IsValid().

{ return fEndTime; }

int lariov::DBDataset::getColNumber

(

const std::string &

name

)

const

Definition at line 225 of file DBDataset.cxx.

References fColNames.

Referenced by data(), and lariov::DBFolder::GetColumn().

{
  int result = -1;

  // Scan column names.

  for (size_t i = 0; i < fColNames.size(); ++i) {
    if (fColNames[i] == name) {
      result = i;
      break;
    }
  }

  return result;
}

DBRow lariov::DBDataset::getRow ( size_t  row ) const

inline

Definition at line 131 of file DBDataset.h.

References lariov::DBDataset::DBRow::DBRow(), lariov::DBDataset::DBRow::fData, and ncols().

Referenced by lariov::DBFolder::CompareDataset(), lariov::DBFolder::DumpDataset(), and lariov::DBFolder::GetRow().

{ return DBRow(&fData[ncols() * row]); }

int lariov::DBDataset::getRowNumber

(

DBChannelID_t

ch

)

const

Definition at line 185 of file DBDataset.cxx.

References fChannels.

Referenced by data(), and lariov::DBFolder::GetRow().

{
  int result = -1;

  // Do a binary search on channel numbers.

  int low = 0;
  int high = fChannels.size() - 1;
  while (high - low > 1) {
    int mid = (low + high) / 2;
    if (fChannels[mid] < ch)
      low = mid;
    else if (fChannels[mid] > ch)
      high = mid;
    else {

      // Found an exact match.  Break out of loop.

      result = mid;
      break;
    }
  }

  // If we fell out of loop without finding a match...

  if (result < 0) {
    if (fChannels[low] == ch)
      result = low;
    else if (fChannels[high] == ch)
      result = high;
  }

  // Done.

  return result;
}

size_t lariov::DBDataset::ncols ( ) const

inline

Definition at line 118 of file DBDataset.h.

References fColNames.

Referenced by lariov::DBFolder::CompareDataset(), DBDataset(), lariov::DBFolder::DumpDataset(), and getRow().

{ return fColNames.size(); }

size_t lariov::DBDataset::nrows ( ) const

inline

Definition at line 117 of file DBDataset.h.

References fChannels.

Referenced by lariov::DBFolder::CompareDataset(), DBDataset(), and lariov::DBFolder::DumpDataset().

{ return fChannels.size(); }

Member Data Documentation

IOVTimeStamp lariov::DBDataset::fBeginTime

private

Definition at line 136 of file DBDataset.h.

Referenced by beginTime(), and DBDataset().

std::vector<DBChannelID_t> lariov::DBDataset::fChannels

private

Definition at line 140 of file DBDataset.h.

Referenced by channels(), DBDataset(), getRowNumber(), and nrows().

std::vector<std::string> lariov::DBDataset::fColNames

private

Definition at line 138 of file DBDataset.h.

Referenced by colNames(), DBDataset(), getColNumber(), and ncols().

std::vector<std::string> lariov::DBDataset::fColTypes

private

Definition at line 139 of file DBDataset.h.

Referenced by colTypes(), and DBDataset().

std::vector<value_type> lariov::DBDataset::fData

private

Definition at line 141 of file DBDataset.h.

Referenced by DBDataset().

IOVTimeStamp lariov::DBDataset::fEndTime

private

Definition at line 137 of file DBDataset.h.

Referenced by DBDataset(), and endTime().

---

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

• larevt/v09_10_03/source/larevt/CalibrationDBI/Providers/DBDataset.h
• larevt/v09_10_03/source/larevt/CalibrationDBI/Providers/DBDataset.cxx