MySQLAppender.h

/***************************************************************************
                          MySQLAppender.h  -  class MySQLAppender
                             -------------------
    begin                : jeu mai 8 2003
    copyright            : (C) 2003 by Michael CATANZARITI
    email                : mcatan@free.fr
 ***************************************************************************/

/***************************************************************************
 * 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_DB_MYSQL_APPENDER_H
#define _LOG4CXX_DB_MYSQL_APPENDER_H

#include "StLoggerConfig.h"
#if 1
// def HAVE_MYSQL
 
#include <log4cxx/helpers/exception.h>
#include <log4cxx/appenderskeleton.h>
#include <log4cxx/spi/loggingevent.h>
#include <list>
#ifdef HAVE_MS_MYSQL
#include <windows.h>
#endif

#include "mysql.h"
namespace log4cxx
{
        namespace db
        {
#if  0
                class LOG4CXX_EXPORT SQLException : public helpers::Exception
                {
                public:
                        SQLException(int code) : code(code) {}
                        virtual String getMessage() { return String(); }

                        int code;
                };
#endif
                class MySQLAppender;
                typedef helpers::ObjectPtrT<MySQLAppender> MySQLAppenderPtr;

#ifndef SQLHDBC
#define SQLHDBC MYSQL*
#endif
                class LOG4CXX_EXPORT MySQLAppender : public AppenderSkeleton
                {
                protected:
                        String databaseURL;
                        
                        String databaseUser;
                        
                        String databasePassword;
                        
                        MYSQL *connection;
                        
                        String sqlStatement;
                        
                        size_t bufferSize;
                        
                        std::list<spi::LoggingEventPtr> buffer;
         unsigned long fLastId;
         bool fIsConnectionOpen;
                        
                public:                         
                        DECLARE_LOG4CXX_OBJECT(MySQLAppender)
                        BEGIN_LOG4CXX_CAST_MAP()
                                LOG4CXX_CAST_ENTRY(MySQLAppender)
                                LOG4CXX_CAST_ENTRY_CHAIN(AppenderSkeleton)
                        END_LOG4CXX_CAST_MAP()

                        MySQLAppender();
                        virtual ~MySQLAppender();
                        
                        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;
#if (STAR_LOG4CXX_VERSION == 10) 
      protected:
         virtual void append(const spi::LoggingEventPtr& event, log4cxx::helpers::Pool& p);
#endif

                        unsigned int execute(const String& sql) /*throw(SQLException)*/;
                        
                        virtual void closeConnection();
                        
                        virtual MYSQL *getConnection() /*throw(SQLException)*/;
                        
                public:
                        virtual void close();
                        
                        void flushBuffer();
                        
//                      virtual bool requiresLayout()
                        virtual bool requiresLayout() const
                                { return true; }
                        
                        void setSql(const String& s);

                        inline const String& getSql() const
                                { return sqlStatement; }
                        
                        
                        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 MySQLAppender
    } // namespace db
}; // namespace log4cxx

#endif // HAVE_MYSQL
#endif // _LOG4CXX_DB_MYSQL_APPENDER_H