mysql_db.h

Go to the documentation of this file.

/*                                                              
 * A database abstraction layer for C++ and ACE framework
 * 
 * (C) 2006-2007 Thralling Penguin LLC. All rights reserved.
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 *
 * This library 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
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA                                                                
 */
#include <fstream>
#include <iomanip>
#include "ace/os_include/os_stddef.h"
#include "ace/OS_Memory.h"
#include "db.h"
#include "mysql/mysql.h"

namespace DB
{
    class MySQL_Connection;

    class MySQL_ResultSet : public ResultSet
    {
        friend class MySQL_Connection;
    protected:
        MySQL_ResultSet(MYSQL_RES *res) : res_(res) {};
        ~MySQL_ResultSet();
    private:
        MySQL_ResultSet() {};
        MySQL_ResultSet(const MySQL_ResultSet &old);
        const MySQL_ResultSet &operator=(const MySQL_ResultSet &old);

    public:
        bool close(void);
        bool next(void);

        unsigned long recordCount(void) const;
        unsigned int findColumn(const char *field) const;

        const char *getString(const int idx) const;
        const int getInteger(const int idx) const;
        const bool getBool(const int idx) const;
        const time_t getUnixTime(const int idx) const;
        const double getDouble(const int idx) const;
        const float getFloat(const int idx) const;
        const long getLong(const int idx) const;
        const short getShort(const int idx) const;

        // Overload the new/delete opertors so the object will be
        // created/deleted using the memory allocator associated with the
        // DLL/SO.
        void *operator new (size_t bytes);
        #if defined (ACE_HAS_NEW_NOTHROW)
        // Overloaded new operator, nothrow_t variant.
        void *operator new (size_t bytes, const ACE_nothrow_t&);
        #if !defined (ACE_LACKS_PLACEMENT_OPERATOR_DELETE)
        void operator delete (void *p, const ACE_nothrow_t&) throw ();
        #endif /* ACE_LACKS_PLACEMENT_OPERATOR_DELETE */
        #endif
        void operator delete (void *ptr);

    private:
        MYSQL_RES *res_;
        MYSQL_ROW row_;
    };

    class MySQL_Connection : public Connection
    {
    private:
        MySQL_Connection(const MySQL_Connection &old);
        const MySQL_Connection &operator=(const MySQL_Connection &old);

    public:
        MySQL_Connection() : mysql_(NULL) {};
        ~MySQL_Connection() { close(); }

        bool open(const char *database, const char *host, const int port, const char *user, const char *pass);
        bool close(void);
        bool isConnected(void);
        bool execute(const char *sql);
        ResultSet *executeQuery(const char *sql);
        char *escape(const char *);
        const char *unixtimeToSql(const time_t);
        const unsigned long insertId(void);

        bool beginTrans(void);
        bool commitTrans(void);
        bool rollbackTrans(void);
        bool setTransactionMode(const enum TRANS_MODE mode);

        unsigned int errorno(void) const;
        const char *errormsg(void) const;

        const char *version(void) const;

        // Overload the new/delete opertors so the object will be
        // created/deleted using the memory allocator associated with the
        // DLL/SO.
        void *operator new (size_t bytes);
        #if defined (ACE_HAS_NEW_NOTHROW)
        // Overloaded new operator, nothrow_t variant.
        void *operator new (size_t bytes, const ACE_nothrow_t&);
        #if !defined (ACE_LACKS_PLACEMENT_OPERATOR_DELETE)
        void operator delete (void *p, const ACE_nothrow_t&) throw ();
        #endif /* ACE_LACKS_PLACEMENT_OPERATOR_DELETE */
        #endif
        void operator delete (void *ptr);

    private:
        MYSQL *mysql_;
    };
}

---