StUCMAppender.h

/***************************************************************************
                          StUCMAppender.h  -  class StUCMAppender
                             -------------------
     begin                : Julu 2008
    copyright            : (C) 2008 by Valeri Fine
    email                : bnl.gov
 ***************************************************************************/

/***************************************************************************
 * Copyright (C) The Apache Software Foundation. All rights reserved.      *
 *                                                                         *
 * This software is published under the terms of the Apache Software       *
 * License version 1.1, a copy of which has been included with this        *
 * distribution in the LICENSE.txt file.                                   *
 ***************************************************************************/

#ifndef _LOG4CXX_UCM_APPENDER_H
#define _LOG4CXX_UCM_APPENDER_H
#ifdef   _UCMLOGGER_
#include "StLoggerConfig.h"

#include <log4cxx/helpers/exception.h>
#include <log4cxx/appenderskeleton.h>
#include <log4cxx/spi/loggingevent.h>
#include <list>

namespace TxLogging {
  class TxEventLog;
}

namespace log4cxx
{
        namespace db
        {
#if REDUNDANT_EXCEPTION
                class LOG4CXX_EXPORT UCMException : public helpers::Exception
                {
                public:
                        UCMException(int code) : code(code) {}
                        virtual String getMessage() { return String(); }
         ~UCMException() {}
                        int code;
                };
#endif

                class StUCMAppender;
#if (STAR_LOG4CXX_VERSION != 10) 
      typedef helpers::ObjectPtrT<StUCMAppender> StUCMAppenderPtr;
#endif

                class LOG4CXX_EXPORT StUCMAppender : public AppenderSkeleton
                {
                protected:
                        String databaseURL;
                        
                        String databaseUser;
                        
                        String databasePassword;
                        
                        TxLogging::TxEventLog *connection;

         String technology;
         
                        size_t bufferSize;
                        
                        std::list<spi::LoggingEventPtr> buffer;
         unsigned long fLastId;
         bool fIsConnectionOpen;
#if (STAR_LOG4CXX_VERSION == 10) 
      protected:
         virtual void append(const spi::LoggingEventPtr& event, log4cxx::helpers::Pool& p);
#endif
                        
                public:                         
         DECLARE_LOG4CXX_OBJECT(StUCMAppender)
                        BEGIN_LOG4CXX_CAST_MAP()
                                LOG4CXX_CAST_ENTRY(StUCMAppender)
                                LOG4CXX_CAST_ENTRY_CHAIN(AppenderSkeleton)
                        END_LOG4CXX_CAST_MAP()

                        StUCMAppender(const char *mode="F");
                        virtual ~StUCMAppender();
                        
                        virtual void setOption(const String& option, const String& value);

                        void append(const spi::LoggingEventPtr& event);
                        
                protected:
                        String getLogStatement(const spi::LoggingEventPtr& event);
//                      String getLogStatement(const spi::LoggingEventPtr& event) const;

                        virtual void closeConnection();
                        
                        virtual TxLogging::TxEventLog *getConnection() /*throw(SQLException)*/;
                        
                public:
                        virtual void close();

                        /* loops through the buffer of LoggingEvents, gets a
                        * sql string from getLogStatement() and sends it to execute().
                        * Errors are sent to the errorHandler.
                        *
                        * If a statement fails the LoggingEvent stays in the buffer!
                        */
                        void flushBuffer();
                                
//                      virtual bool requiresLayout()
                        virtual bool requiresLayout() const
                                { return true; }
                        
                        inline void setUser(const String& user)
                                { databaseUser = user; }
                        
                        
                        inline void setURL(const String& url)
                                { databaseURL = url; }
                        
                        
                        inline void setPassword(const String& password)
                                { databasePassword = password; }
                        
                        
                        inline void setBufferSize(size_t newBufferSize)
                                { bufferSize = newBufferSize; }
                        
                        inline const String& getUser() const
                                { return databaseUser; }
                        
                        
                        inline const String& getURL() const
                                { return databaseURL; }
                        
                        
                        inline const String& getPassword() const
                                { return databasePassword; }
                        
                        inline size_t getBufferSize() const
                                { return bufferSize; }
                }; // class StUCMAppender
#if (STAR_LOG4CXX_VERSION == 10) 
      LOG4CXX_PTR_DEF(StUCMAppender);
#endif
    } // namespace db
}; // namespace log4cxx
#endif
#endif // _LOG4CXX_UCM_APPENDER_H