SimpleTransactionReader.hpp

Go to the documentation of this file.

#ifndef SimpleTransactionReader_HPP
#define SimpleTransactionReader_HPP


#include "io/StreamRepr.hpp"  
#include "io/input/transaction_reader/TransactionReader.hpp"  

class SimpleTransactionReader : public TransactionReader<StreamRepr>
{
   public:

      SimpleTransactionReader( const params_t* par ) :
         TransactionReader<StreamRepr>(par){}

      template <class BIS> counter_t nextTransactionBIS( BIS& transaction );

      template <class UAC> counter_t nextTransactionUAC( UAC& transaction );

   private:
      bool getNextItem(int& item, char& c);
};

template <class BIS> inline counter_t SimpleTransactionReader::
nextTransactionBIS( BIS& transaction )
{
   transaction.clear();
   if( input_stream.eof() ) return 0;
   char          c;
   int           item;
      
   do
   {
      if( getNextItem(item, c) )
         transaction.push_back( (item_t) item );
   }
   while( !input_stream.eof() && c != '\n' );
//   copy(transaction.begin(),transaction.end(),ostream_iterator<item_t>(cout," "));
//   cout<<"\n";
   return 1;
}

template <class UAC> inline counter_t SimpleTransactionReader::
nextTransactionUAC( UAC& transaction )
{
   transaction.clear();
   if( input_stream.eof() ) return 0;
   int item;
   char c;
   do
   {
      if( getNextItem(item, c) ) 
         transaction.insert( (item_t) item );
   }
   while( !input_stream.eof() && c != '\n' );
   return 1;
}

inline bool SimpleTransactionReader::getNextItem(int& item, char& c)
{
   item = 0;
   bool has_next_int;
   has_next_int = false;
   input_stream.get(c);
   while(input_stream.good() && (c >= '0') && (c <= '9'))
   {
      has_next_int = true;
      item = 10 * item + int(c) - int('0');
      input_stream.get(c);
   }
   return has_next_int;
}

#endif

---