---

sqlstreamer.hpp

Go to the documentation of this file.

#if !defined(_SQLStreamer_HPP)
#define _SQLStreamer_HPP
//============================================================================= 
//
// XDFLengine library
//
//-----------------------------------------------------------------------------
//  SQLStreamer.HPP
//----------------------------------------------------------------------------- 
//_____________________________________________________________________________
//
//  Copyright (C) 2003 Guillaume Baurand. All Rights Reserved.
//
//  This file is part of the XDFLengine project.
//
//  The XDFLengine is free software; you can redistribute it and/or modify
//  it under the terms of the GNU General Public License as published by
//  the Free Software Foundation; either version 2 of the License, or
//  (at your option) any later version.
//
//  This program is distributed in the hope that it will be useful,
//  but WITHOUT ANY WARRANTY; without even the implied warranty of
//  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
//  GNU General Public License for more details.
//
//  You should have received a copy of the GNU General Public License
//  along with this program; if not, write to the Free Software
//  Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307,
//  USA.
//
//  For more information, 
//      contact  : guillaume@baurand.net 
//      or visit : http://xdflengine.sourceforge.net
//
//============================================================================= 

#   include "config/commonincs.hpp"
#   include "streamers/db/dbstreamerfactory.hpp"

BEGIN_XDFLENGINE_NS

class XMLProcessor;

//============================================================================= 
//  CLASS SQLStreamerFACTORY
//----------------------------------------------------------------------------- 
//~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
class XDFLENGINE_EXPORT SQLStreamerFactory:public DBStreamerFactory
{

    public: //~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

        //_____________________________________________________________________
        //  GETSTREAMER
        //---------------------------------------------------------------------
        XMLStreamer* getStreamer(StreamerParams* p_pParameters, XMLFlowContext* p_pStreamContext, XMLStreamConsumer* p_pStreamConsumer) const;
};

//~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
//=============================================================================



//============================================================================= 
//  CLASS SAXSQLHandler
//----------------------------------------------------------------------------- 
//~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
class XDFLENGINE_EXPORT SAXSQLHandler : public ContentHandler
{


    private: //~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        const           XMLStreamerFactory* m_pStreamerFactory;
        const           XMLFlowContext*     m_pContext;
        XMLStreamConsumer*  m_pOutput;      
        char*           m_pszConnection;
        otl_connect*    m_pCNN_connection ; 
        otl_stream*     m_rsData;           
        otl_var_desc*   m_varsDesc;         
        char*           m_pszEncloseRecord; 
        char*           m_pszSQLStmt;       
        char*           m_pszFilterData;    
        unsigned int    m_uiBufSize;        
        unsigned int    m_uiLevel;          
        int             m_iDescLen;         
        int             m_iDescrPos;        
        char*           m_pszCurVal;        
        int             m_iFilterMode;      
        unsigned int    m_uiStreamObjects;
        unsigned int    m_uiToStream;
        int             m_iCommitPack;      
        int             m_iCommit;
        unsigned int    m_uiFlushPack;      
        unsigned int    m_uiFlush;
        bool            m_fDBErrorFatal;
        bool            m_fCurRecordError;
        bool            m_fTransmitData;

    public: //~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

    // CONSTRUCTOR & DESTRUCTOR

        //_____________________________________________________________________
        //  SAXSQLHANDLER
        //---------------------------------------------------------------------
        SAXSQLHandler(  DBStreamerFactory*      p_pStreamerFactory,
                        StreamerParams*         p_pParameters, 
                        XMLFlowContext*         p_pStreamContext, 
                        XMLStreamConsumer*      p_pStreamConsumer); 

        //_____________________________________________________________________
        //  ~SAXSQLHANDLER
        //---------------------------------------------------------------------
        //_____________________________________________________________________
        ~SAXSQLHandler    ();



    // CONTENTHANDLER ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
    
        //____________________________________________________________________
        //  STARTDOCUMENT
        //--------------------------------------------------------------------
        //_____________________________________________________________________ 
        void startDocument();
        
        //____________________________________________________________________
        //  STARTELEMENT
        //--------------------------------------------------------------------
        //_____________________________________________________________________ 
        void startElement(  const XMLCh* const uri,  const XMLCh* const localname,   const XMLCh* const qname, const Attributes& attrs);

        //____________________________________________________________________
        //  CHARACTERS
        //--------------------------------------------------------------------
        //_____________________________________________________________________ 
        void characters(  const XMLCh* const chars,   const unsigned int length);

        //____________________________________________________________________
        //  ENDELEMENT
        //--------------------------------------------------------------------
        //_____________________________________________________________________ 
        void endElement (  const XMLCh* const uri,   const XMLCh* const localname,   const XMLCh* const qname);

        //____________________________________________________________________
        //  ENDDOCUMENT
        //--------------------------------------------------------------------
        //_____________________________________________________________________ 
        void endDocument();

        // not implemented :
        void ignorableWhitespace ( const XMLCh* const chars, const unsigned int length){};
        void processingInstruction ( const XMLCh* const target, const XMLCh* const data){};
        void setDocumentLocator ( const Locator* const locator) {};
        void startPrefixMapping ( const XMLCh* const prefix,const XMLCh* const uri){};      
        void endPrefixMapping ( const XMLCh* const prefix){};
        void skippedEntity ( const XMLCh* const name){};

    private: //~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

        //____________________________________________________________________
        //  OPENDATASTREAM
        //--------------------------------------------------------------------
        //_____________________________________________________________________
        void openDataStream();
        
        //____________________________________________________________________
        //  RELEASEDATASTREAM
        //--------------------------------------------------------------------
        //_____________________________________________________________________     
        void releaseDataStream ();


        //____________________________________________________________________
        //  FLUSHRECORDS
        //--------------------------------------------------------------------
        void flushRecords();

        //____________________________________________________________________
        //  COMMITRECORDS
        //--------------------------------------------------------------------
        void commitRecords();

        //____________________________________________________________________
        //  ROLLBACKRECORDS
        //--------------------------------------------------------------------
        void rollbackRecords();

        //____________________________________________________________________
        //  SETINVAR
        //--------------------------------------------------------------------
        //_____________________________________________________________________
        void setInVar ( const char* p_pszName, const char* p_pszVarValue);

        //____________________________________________________________________
        //  INSERTINVAR
        //--------------------------------------------------------------------
        //_____________________________________________________________________
        void insertInVar ( int p_intOTLType, const char* p_pszVarValue);

        //_____________________________________________________________________
        //  MAKEXML
        //---------------------------------------------------------------------
        //_____________________________________________________________________
        void makeXML ();
        
};
//~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
//=============================================================================

END_XDFLENGINE_NS

#endif

---