MyConnection.h

Go to the documentation of this file.

#ifndef __DCL_MYSQL_CONNECTION_H__
#define __DCL_MYSQL_CONNECTION_H__  20031025_20250414
 
#include <mysql/mysql.h>
#include <mysql/mysqld_error.h>
 
#if MYSQL_VERSION_ID < 32224
#error "invalid mysql version"
#endif
 
__DCL_BEGIN_NAMESPACE
 
// BLOB_MAXSIZE < 1G
// see void BytesToHexString in MyParam.cpp
#define BLOB_MAXSIZE    (100 * 1024 * 1024) // 100M
class MyQuery;
 
class MyConnection : public SQL::Connection
{
    DECLARE_CLASSINFO(MyConnection)
protected:
    MYSQL*      __mysql;
    bool        __storeResult;
    ByteString  __lastErrorMessage;
    
public:
    MYSQL* connHandle() const;
    bool storeResult() const;
 
    void setErrorStatus(SQL::Error _error,  const wchar_t* _filename, int _line);
    void setErrorStatus(const ByteString& _message, const wchar_t* _filename, int _line);
 
public:
    // interface implementation
    MyConnection(const wchar_t* _serverTitle);
 
    virtual void destroy();
    virtual ~MyConnection();
    virtual bool __open(const char* _pszConnString, size_t _n);
    virtual bool __close();
    virtual bool __execute(const char* pszSQL, size_t _n);
    virtual bool __startTrans();
    virtual bool __commitTrans();
    virtual bool __rollbackTrans();
    virtual bool __createQueryInstance(SQL::Query** _ppQuery);
    virtual bool __getErrorMessage(char* _buffer, size_t* _size);
    virtual bool __getServerInfo(char* _buffer, size_t* _size);
};
 
inline MYSQL* MyConnection::connHandle() const
{
    return __mysql;
}
 
inline bool MyConnection::storeResult() const
{
    return __storeResult;
}
 
inline void MyConnection::setErrorStatus(
                SQL::Error _error, 
                const wchar_t* _filename,
                int _line
                )
{
    Connection::setErrorStatus(_error, _filename, _line);
 
    if (_error == SQL::eServerError)
        __lastErrorMessage = mysql_error(connHandle());
    else
        __lastErrorMessage.clear();
}
 
inline void MyConnection::setErrorStatus(
                const ByteString& _message, 
                const wchar_t* _filename,
                int _line
                )
{
    Connection::setErrorStatus(SQL::eServerError, _filename, _line);
    __lastErrorMessage = _message;
}
 
#undef __SET_ERROR
#define __SET_ERROR(_error) \
    setErrorStatus(_error, __THIS_FILE__, __LINE__)
 
#define __SET_ERROR_MSG(_msg) \
    setErrorStatus(_msg, __THIS_FILE__, __LINE__)
 
__DCL_END_NAMESPACE
 
#endif  // __DCL_MYSQL_CONNECTION_H__