MyConnection Class Reference

#include <MyConnection.h>

Inheritance diagram for MyConnection:

Public Member Functions
MYSQL *	connHandle () const
bool	storeResult () const
void	setErrorHandle (SQL::Error _error, const wchar_t *_filename, int _line)
void	setErrorMessage (const ByteString &_message, const wchar_t *_filename, int _line)
	MyConnection (const wchar_t *_serverTitle)
virtual void	destroy ()
virtual	~MyConnection ()
virtual bool	__open (const char *_conns, size_t _connslen)
virtual bool	__close ()
virtual bool	__execute (const char *_sql, size_t _sqllen)
virtual bool	__startTrans ()
virtual bool	__commitTrans ()
virtual bool	__rollbackTrans ()
virtual bool	__createQueryInstance (SQL::Query **_queryHandleOut)
virtual bool	__getErrorMessage (char *_buf, size_t *_buflen)
virtual bool	__getServerInfo (char *_buf, size_t *_buflen)
Public Member Functions inherited from SQL::Connection
long	refCount () const
long	addRef ()
long	release ()
bool	open (const char *_conn, size_t _connlen)
bool	close ()
bool	execute (const char *_sql, size_t _sqllen)
bool	startTrans ()
bool	commitTrans ()
bool	rollbackTrans ()
bool	getErrorMessage (char *_buf, size_t *_buflen)
bool	getServerInfo (char *_buf, size_t *_buflen)
bool	createQueryInstance (Query **_queryHandle)
bool	destroyQueryInstance (Query *_queryHandle)
Error	errorCode () const
bool	canTransact () const
const wchar_t *	serverTitle () const
bool	inState (unsigned int _state) const
Public Member Functions inherited from Object
virtual String	toString () const
String	className () const
bool	isInstanceOf (const std::type_info &typeinfo) const
virtual const std::type_info &	typeInfo () const

Additional Inherited Members
Public Types inherited from SQL::Connection
enum	State { stClosed = 0x0001 , stOpenned = 0x0002 , stInTransaction = 0x0004 }
Static Public Member Functions inherited from SQL::Connection
static size_t	splitConnStr (const char *_connstr, size_t _strlen, ListedByteStringToByteStringMap &_results)
Public Attributes inherited from SQL::Connection
_PROTECTED	: void setErrorStatus( Error _errorCode
_PROTECTED const wchar_t *	_filename
_PROTECTED const wchar_t int	_line
Protected Member Functions inherited from SQL::Connection
	Connection (const wchar_t *_serverTitle)
virtual	~Connection ()
Protected Member Functions inherited from Object
virtual	~Object ()
	Object ()
Protected Attributes inherited from SQL::Connection
bool	__canTransact
const wchar_t *	__serverTitle
Error	__errorCode
const wchar_t *	__errorFileName
int	__errorLine
unsigned int	__states

Detailed Description

Definition at line 8 of file MyConnection.h.

Constructor & Destructor Documentation

MyConnection()

MyConnection::MyConnection

(

const wchar_t *

_serverTitle

)

~MyConnection()

MyConnection::~MyConnection ( )

virtual

Definition at line 56 of file MyConnection.cpp.

{
    if (__mysql) {
        __DCL_TRACE0_N(L"Warning!! The connection was not closed\n");
        close();
    }
}

Member Function Documentation

__close()

bool MyConnection::__close ( )

virtual

Implements SQL::Connection.

Definition at line 154 of file MyConnection.cpp.

{
    if (!__mysql) {
        __SET_ERROR_HANDLE(SQL::eNotConnected);
        return false;
    }
 
    mysql_close(__mysql);
    __mysql = NULL;
 
    return true;
}

__commitTrans()

bool MyConnection::__commitTrans ( )

virtual

Implements SQL::Connection.

Definition at line 227 of file MyConnection.cpp.

{
    if (mysql_commit(connHandle())) {
        __SET_ERROR_MSG(ByteString::format("(%u) %hs",
            mysql_errno(connHandle()),
            mysql_error(connHandle()))
        );
    }
 
    return true;
}

__createQueryInstance()

bool MyConnection::__createQueryInstance ( SQL::Query ** _queryHandleOut )

virtual

Implements SQL::Connection.

Definition at line 251 of file MyConnection.cpp.

{
    __DCL_ASSERT(_queryHandleOut != NULL);
 
    MyQuery* pNewQuery = new MyQuery(this);
    if (!pNewQuery) {
        __SET_ERROR_HANDLE(SQL::eOutOfMemory);
        return false;
    }
 
    *_queryHandleOut = pNewQuery;
    return true;
}

__execute()

bool MyConnection::__execute ( const char * _sql, size_t _sqllen )

virtual

Implements SQL::Connection.

Definition at line 198 of file MyConnection.cpp.

{
    if (mysql_real_query(connHandle(), _sql, (unsigned long) _sqllen)) {
        __SET_ERROR_MSG(ByteString::format("(%u) %hs",
            mysql_errno(connHandle()),
            mysql_error(connHandle()))
        );
    }
 
    switch (__GetStmtType(_sql)) {
    case StmtTransBegin:
        __SET_STATE(stInTransaction);
        break;
    case StmtTransEnd:
        __UNSET_STATE(stInTransaction);
        break;
    case StmtOther:
    default:
        ;
    }
 
    return true;
}

__getErrorMessage()

bool MyConnection::__getErrorMessage ( char * _buf, size_t * _buflen )

virtual

Implements SQL::Connection.

Definition at line 265 of file MyConnection.cpp.

{
    if (__lastErrorMessage.length() < *_buflen) {
        *_buflen = __lastErrorMessage.length();
        *(_buf + *_buflen) = '\0';
    }
    strncpy(_buf, __lastErrorMessage.data(), *_buflen);
    return true;
}

__getServerInfo()

bool MyConnection::__getServerInfo ( char * _buf, size_t * _buflen )

virtual

Implements SQL::Connection.

Definition at line 275 of file MyConnection.cpp.

{
    const char* psz = mysql_get_server_info(connHandle());
    if (!psz) {
        return false;
    }
 
    size_t length = strlen(psz);
    if (length < *_buflen) {
        *_buflen = length;
        *(_buf + *_buflen) = '\0';
    }
    strncpy(_buf, psz, *_buflen);
    return true;
}       

__open()

bool MyConnection::__open ( const char * _conns, size_t _connslen )

virtual

Implements SQL::Connection.

Definition at line 87 of file MyConnection.cpp.

{
    if (__mysql == NULL && (__mysql = mysql_init(NULL)) == NULL) {
        __SET_ERROR_HANDLE(SQL::eOutOfMemory);
        return false;
    }
 
    ListedByteStringToByteStringMap map;
    Connection::splitConnStr(_conns, _connslen, map);
 
    ByteString _APPLICATION = map["APPLICATION"];
    if (!_APPLICATION.isEmpty()) {
        mysql_options(connHandle(), MYSQL_READ_DEFAULT_GROUP, _APPLICATION.data());
    }
 
    ByteString _USER = map["USER"];
    ByteString _PASSWORD = map["PASSWORD"];
    ByteString _SERVER = map["SERVER"];
    ByteString _DATABASE = map["DATABASE"];
    ByteString _PORT = map["PORT"];
    ByteString _UNIX_SOCKET = map["UNIX_SOCKET"];
    __storeResult = map.find("STORE_RESULT") != map.end();
 
    unsigned int port = 0;
    if (!_PORT.isEmpty()) {
        char* endptr;
        unsigned long n = strtoul(_PORT.data(), &endptr, 10);
        if (n == ULONG_MAX) {
            __SET_ERROR_MSG("연결 문자열이 잘못되었습니다. PORT=" + _PORT);
            return false;
        }
        port = (unsigned int) n;
    }
 
    if (mysql_real_connect(
        connHandle(),
        _SERVER.isEmpty()? NULL : _SERVER.data(),
        _USER.isEmpty()? NULL : _USER.data(),
        _PASSWORD.isEmpty()? NULL : _PASSWORD.data(),
        _DATABASE.isEmpty() ? NULL : _DATABASE.data(),
        port,
        _UNIX_SOCKET.isEmpty() ? NULL : _UNIX_SOCKET.data(),
        0
    ) == NULL) {
        __SET_ERROR_HANDLE(SQL::eServerError);
        return false;
    }
 
    if (mysql_set_character_set(connHandle(), "utf8")) {
        __SET_ERROR_MSG(ByteString::format("(%u) %hs",
            mysql_errno(connHandle()),
            mysql_error(connHandle()))
        );
        return false;
    }
 
    if (mysql_autocommit(connHandle(), 0)) {
        __SET_ERROR_MSG(ByteString::format("(%u) %hs",
            mysql_errno(connHandle()),
            mysql_error(connHandle()))
        );
        return false;
    }
 
    return true;
}

__rollbackTrans()

bool MyConnection::__rollbackTrans ( )

virtual

Implements SQL::Connection.

Definition at line 239 of file MyConnection.cpp.

{   
    if (mysql_rollback(connHandle())) {
        __SET_ERROR_MSG(ByteString::format("(%u) %hs",
            mysql_errno(connHandle()),
            mysql_error(connHandle()))
        );
    }
 
    return true;
}

__startTrans()

bool MyConnection::__startTrans ( )

virtual

Implements SQL::Connection.

Definition at line 222 of file MyConnection.cpp.

{
    return __execute("START TRANSACTION", 17);
}

connHandle()

MYSQL * MyConnection::connHandle ( ) const

inline

Definition at line 47 of file MyConnection.h.

{
    return __mysql;
}

destroy()

void MyConnection::destroy ( )

virtual

파생클래스에서 new 연산자를 override했거나, 추가적인 행위가 필요하다면 이것도 override하라

Implements SQL::Connection.

Definition at line 64 of file MyConnection.cpp.

{
    delete this;
}

setErrorHandle()

void MyConnection::setErrorHandle ( SQL::Error _error, const wchar_t * _filename, int _line )

inline

Definition at line 57 of file MyConnection.h.

{
    Connection::setErrorStatus(_error, _filename, _line);
 
    if (_error == SQL::eServerError)
        __lastErrorMessage = mysql_error(connHandle());
    else
        __lastErrorMessage.clear();
}

setErrorMessage()

void MyConnection::setErrorMessage ( const ByteString & _message, const wchar_t * _filename, int _line )

inline

Definition at line 71 of file MyConnection.h.

{
    Connection::setErrorStatus(SQL::eServerError, _filename, _line);
 
    __lastErrorMessage = _message;
}

storeResult()

bool MyConnection::storeResult ( ) const

inline

Definition at line 52 of file MyConnection.h.

{
    return __storeResult;
}

---

The documentation for this class was generated from the following files:

• MyConnection.h
• MyConnection.cpp