---

dbstreamerfactory.hpp

Go to the documentation of this file.

#if !defined(_DBStreamerFactory_HPP)
#define _DBStreamerFactory_HPP
//============================================================================= 
//
// XDFLengine library
//
//-----------------------------------------------------------------------------
//  DBGETHANDLER.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 "processor/xmlstreamerfactory.hpp"
#   include "utils/otl_utils.hpp" // OTL4

BEGIN_XDFLENGINE_NS

class DBConnectionPool;
class XMLProcessor;


//=============================================================================
// GLOBALS
//-----------------------------------------------------------------------------
static unsigned long                g_ulPooledConnectionLifeTime;
static bool                         g_boolConnectionPoolsReady=false; 
static DBConnectionPool**           g_ppConnectionPools ;            

#if defined(OTL_ODBC) 
    static unsigned int                 g_uiSQLSyntax = SQL_SYNTAX_MSSQL;
#elif defined(OTL_ORA7) || defined(OTL_ORA8) || defined(OTL_ORA8I) || defined(OTL_ORA9I)
    static unsigned int                 g_uiSQLSyntax = SQL_SYNTAX_ORA;
#elif defined(OTL_DB2_CLI)
    static unsigned int                 g_uiSQLSyntax = SQL_SYNTAX_DB2;
#else
    static unsigned int                 g_uiSQLSyntax = SQL_SYNTAX_ORA;
#endif

//============================================================================= 
//  CLASS DBStreamerFactory
//----------------------------------------------------------------------------- 
//~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
class XDFLENGINE_EXPORT DBStreamerFactory: public XMLStreamerFactory
{

    protected: //~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~


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

    // CONTRUCTOR & DESTRUCTOR

        //_____________________________________________________________________
        //  setSQLSyntax
        //---------------------------------------------------------------------
        static void setSQLSyntax(const char* p_pszSQLSyntax=0);

        //_________________________________________________________________________
        //  GETCONNECTIONLIFETIME
        //-------------------------------------------------------------------------
        static unsigned int getSQLSyntax();

        //_____________________________________________________________________
        //  DBStreamerFactory
        //---------------------------------------------------------------------
        //_____________________________________________________________________
        DBStreamerFactory();

        //_____________________________________________________________________
        //  DBStreamerFactory
        //---------------------------------------------------------------------
        //_____________________________________________________________________
        virtual ~DBStreamerFactory();

    // CONNECTIONS      

        //_____________________________________________________________________
        // GETCONNECTION
        //---------------------------------------------------------------------
        otl_connect* getConnection(const char* p_pszConnectionString,unsigned int p_uiThreadId  );


        //_____________________________________________________________________
        // RELEASECONNECTION
        //---------------------------------------------------------------------
        void releaseConnection(const char* p_pszConnectionString,unsigned int p_uiThreadId  );


        //_____________________________________________________________________
        //  TICK
        //---------------------------------------------------------------------
        //_____________________________________________________________________
        void tick(unsigned long  p_ulClock);

};
//=============================================================================





//============================================================================= 
//  STRUCT DBPOOLEDCONNECTION
//----------------------------------------------------------------------------- 
//~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
typedef struct _DBPooledConnection
{
        otl_connect*    m_pOTLConnection;   
        unsigned long   m_ulTimeCreated;
        unsigned int    m_uiUsage;
        char*           m_pszConnectionString;
} DBPooledConnection;
//=============================================================================






//============================================================================= 
//  CLASS DBCONNECTIONPOOL
//----------------------------------------------------------------------------- 
//~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
class XDFLENGINE_EXPORT DBConnectionPool
{

    private: //~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        VAarray<DBPooledConnection* >   m_vaActiveConnections;
        unsigned long                       m_ulLastTick;



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

    // STATICS
        //_____________________________________________________________________
        //  SETCONNECTIONLIFETIME
        //--------------------------------------------------------------------- 
        static void setConnectionLifeTime(unsigned long  p_lngConnectionLifeTime);

    // CONTRUCTOR & DESTRUCTOR

        //_____________________________________________________________________
        //  DBStreamerFactory
        //---------------------------------------------------------------------
        //_____________________________________________________________________
        DBConnectionPool();

        //_____________________________________________________________________
        //  DBStreamerFactory
        //---------------------------------------------------------------------
        //_____________________________________________________________________
        ~DBConnectionPool();


    // CONNECTIONS      

        //_____________________________________________________________________
        // GETCONNECTION
        //---------------------------------------------------------------------
        otl_connect* getConnection(const char* p_pszConnectionString);


        //_____________________________________________________________________
        // RELEASECONNECTION
        //---------------------------------------------------------------------
        void releaseConnection(const char* p_pszConnectionString);


    // TICKER

        //_____________________________________________________________________
        //  TICK
        //---------------------------------------------------------------------
        void tick(unsigned long  p_ulClock);


    private:
        DBPooledConnection* poolConnection(const char* p_pszConnectionString);
        void unPoolConnection(DBPooledConnection*   p_pDBPooledConnection);
        void deletePooledConnection(DBPooledConnection* p_pDBPooledConnection);

};
//=============================================================================

END_XDFLENGINE_NS

#endif
  

---