00001 #include "DbiRawDataFileSvc/DaqRawDataFileInfo.h" 00002 #include "DatabaseInterface/DbiLog.h" 00003 #include "DatabaseInterface/DbiOutRowStream.h" 00004 #include "DatabaseInterface/DbiResultSet.h" 00005 #include "DatabaseInterface/DbiValidityRec.h" 00006 00007 #include "DatabaseInterface/DbiResultPtr.tpl" 00008 template class DbiResultPtr<DaqRawDataFileInfo>; 00009 00010 #include "DatabaseInterface/DbiWriter.tpl" 00011 template class DbiWriter<DaqRawDataFileInfo>; 00012 00013 void DaqRawDataFileInfo::Fill(DbiResultSet& rs, 00014 const DbiValidityRec* /* vrec */) { 00015 00016 Int_t numCol = rs.NumCols(); 00017 // The first column (SeqNo) has already been processed. 00018 for (Int_t curCol = 2; curCol <= numCol; ++curCol) { 00019 string colName = rs.CurColName(); 00020 if ( colName == "RUNNO" ) rs >> m_RunNo; 00021 else if ( colName == "FILENO" ) rs >> m_FileNo; 00022 else if ( colName == "FILENAME" ) rs >> m_FileName; 00023 else if ( colName == "STREAMTYPE" ) rs >> m_StreamType; 00024 else if ( colName == "STREAM" ) rs >> m_Stream; 00025 else if ( colName == "FILESTATE" ) rs >> m_FileState; 00026 else if ( colName == "FILESIZE" ) rs >> m_FileSize; 00027 else if ( colName == "CHECKSUM" ) rs >> m_CheckSum; 00028 else if ( colName == "TRANSFERSTATE" ) rs >> m_TransferState; 00029 else { 00030 LOG(dbi,Logging::kDebug1) << "Ignoring column " << curCol 00031 << "(" << colName << ")" 00032 << "; not part of DaqRawDataFileInfo" << std::endl; 00033 rs.IncrementCurCol(); 00034 } 00035 } 00036 00037 } 00038 00039 void DaqRawDataFileInfo::Store(DbiOutRowStream& ors, 00040 const DbiValidityRec* /* vrec */) const { 00041 ors << m_RunNo << m_FileNo << m_FileName << m_StreamType << m_Stream 00042 << m_FileState << m_FileSize << m_CheckSum << m_TransferState; 00043 00044 } 00045 00046