SociSelect.h

// -*- mode: c++; mode: auto-fill; mode: flyspell-prog; -*-

#ifndef SociSelect_h
#define SociSelect_h 1

#include "soci.h"
#include "postgresql/soci-postgresql.h"

#include "luiza/DataSourceProcessor.h"


using namespace gloria;

namespace luiza {
  
  

   class SociSelect : public DataSourceProcessor {
    
  public:
    
    virtual SociSelect*  newProcessor();
    
    
    SociSelect() ;
    
    virtual void init() ;


    virtual void startAnalysis( GloriaDataContainer* data ) ;
    
    virtual void processData( GloriaDataContainer* data ) ;
    
    
    virtual void check( GloriaDataContainer* data ) ; 
    
    

    virtual void concludeAnalysis( GloriaDataContainer* data ) ;

    virtual void end() ;
    
    
  protected:

    std::vector< std::string > _connectString;

    std::string _connection;

    std::vector< std::string > _selectString ;

    std::string _select;

    int _rowsPerLoop ;


    std::string _indexCollection ;

    std::string _indexColumn ;

    int _indexesPerLoop ;


    std::string _tableCollectionName ;

    bool _permanentCollection;


    int _nLoops ;

    int _nTables ;

    int _nSQL ;


    void printEndMessage() const ;

     GloriaFitsTable* _outputTemplate; 

     std::vector<soci::data_type> _sqlTypes;

     std::vector<std::string> _sqlNames;

     soci::session *_sociSession;

     soci::statement *_sociStatement;

     soci::row *_sociRow;

     bool _useIndex;

     int _indexRow;

     int _sqlRow;
  } ;

 } // end namespace luiza
#endif