IFXConnection Class Reference

#include <IFXConnection.h>

Inheritance diagram for IFXConnection:

Public Member Functions
void	setErrorHandle (SQL::Error _error, long _SQLCODE, const wchar_t *_filename, int _line)
void	setErrorMessage (const ByteString &_message, const wchar_t *_filename, int _line)
_CONST char *	connectionID () const
virtual void	destroy ()
	IFXConnection (const wchar_t *_serverTitle)
virtual	~IFXConnection ()
virtual bool	__open (const char *_conns, size_t _connlen)
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 6 of file IFXConnection.h.

Constructor & Destructor Documentation

IFXConnection()

IFXConnection::IFXConnection

(

const wchar_t *

_serverTitle

)

~IFXConnection()

IFXConnection::~IFXConnection ( )

virtual

Definition at line 60 of file IFXConnection.cpp.

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

Member Function Documentation

__close()

bool IFXConnection::__close ( )

virtual

Implements SQL::Connection.

Definition at line 197 of file IFXConnection.cpp.

{
    if (__connectionID.isEmpty()) {
        __SET_ERROR(SQL::eNotConnected);
        return false;
    }
 
/*
 *  EXEC SQL BEGIN DECLARE SECTION;
 */
#line 149 "ifxconnection.ec"
#line 150 "ifxconnection.ec"
  char *connID = (_CONST char*) __connectionID.data();
/*
 *  EXEC SQL END DECLARE SECTION;
 */
#line 151 "ifxconnection.ec"
 
 
/*
 *  EXEC SQL DISCONNECT :connID;
 */
#line 153 "ifxconnection.ec"
  {
#line 153 "ifxconnection.ec"
  sqli_connect_close(0, connID, 0, 0);
#line 153 "ifxconnection.ec"
  }
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        return false;
    }
 
    __connectionID.clear();
    return true;
}

__commitTrans()

bool IFXConnection::__commitTrans ( )

virtual

Implements SQL::Connection.

Definition at line 374 of file IFXConnection.cpp.

{
/*
 *  EXEC SQL BEGIN DECLARE SECTION;
 */
#line 257 "ifxconnection.ec"
#line 258 "ifxconnection.ec"
  char *connID = (_CONST char*) __connectionID.data();
/*
 *  EXEC SQL END DECLARE SECTION;
 */
#line 259 "ifxconnection.ec"
 
 
/*
 *  EXEC SQL SET CONNECTION :connID;
 */
#line 261 "ifxconnection.ec"
  {
#line 261 "ifxconnection.ec"
  sqli_connect_set(0, connID, 0);
#line 261 "ifxconnection.ec"
  }
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        return false;
    }
 
/*
 *  EXEC SQL COMMIT WORK;
 */
#line 267 "ifxconnection.ec"
  {
#line 267 "ifxconnection.ec"
  sqli_trans_commit();
#line 267 "ifxconnection.ec"
  }
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        return false;
    }
 
    __UNSET_STATE(stInTransaction);
    return true;
}

__createQueryInstance()

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

virtual

Implements SQL::Connection.

Definition at line 466 of file IFXConnection.cpp.

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

__execute()

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

virtual

Implements SQL::Connection.

Definition at line 267 of file IFXConnection.cpp.

{
/*
 *  EXEC SQL BEGIN DECLARE SECTION;
 */
#line 198 "ifxconnection.ec"
#line 199 "ifxconnection.ec"
  char *connID = (_CONST char*) __connectionID.data();
  char *pszSqlStatement = (_CONST char*) _sql;
/*
 *  EXEC SQL END DECLARE SECTION;
 */
#line 201 "ifxconnection.ec"
 
 
/*
 *  EXEC SQL SET CONNECTION :connID;
 */
#line 203 "ifxconnection.ec"
  {
#line 203 "ifxconnection.ec"
  sqli_connect_set(0, connID, 0);
#line 203 "ifxconnection.ec"
  }
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        return false;
    }
 
/*
 *  EXEC SQL EXECUTE IMMEDIATE :pszSqlStatement;
 */
#line 209 "ifxconnection.ec"
  {
#line 209 "ifxconnection.ec"
  sqli_exec_immed(pszSqlStatement);
#line 209 "ifxconnection.ec"
  }
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        return false;
    }
 
    switch(__GetStmtType(_sql)) {
        case StmtTransBegin :
            __SET_STATE(stInTransaction);
            break;
        case StmtTransEnd :
            __UNSET_STATE(stInTransaction);
            break;
        case StmtDatabase :
            reset();
            break;
        case StmtOther :
        default :
            ;
    }
 
    return true;
}

__getErrorMessage()

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

virtual

Implements SQL::Connection.

Definition at line 530 of file IFXConnection.cpp.

{
    __DCL_ASSERT(Connection::__errorCode == SQL::eServerError);
    if (__lastErrorMessage.length() < *_buflen) {
        *_buflen = __lastErrorMessage.length();
        *(_buf + *_buflen) = '\0';
    }
    strncpy(_buf, __lastErrorMessage.data(), *_buflen);
    return true;
}

__getServerInfo()

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

virtual

Implements SQL::Connection.

Definition at line 541 of file IFXConnection.cpp.

{
    IFXQuery* query = new IFXQuery(this);
    if (query == NULL) {
        __SET_ERROR(SQL::eOutOfMemory);
        return false;
    }
 
    bool localTrans = false;
    if (!inState(SQL::Connection::stInTransaction)) {
        __startTrans();
        localTrans = true;
    }
 
    const char* _sql =
        "SELECT DBINFO('version', 'full')"
        "\n FROM systables WHERE tabid = 1";
    for ( ; ; ) {
        if (!query->prepare(_sql, ByteString::length(_sql), 0))
            break;
 
        if (!query->execute())
            break;
 
        if (!query->fetch())
            break;
 
        if (query->eof()) {
            __SET_ERROR(SQL::eNotAvailable);
            break;
        }
 
        IFXField* field = NULL;
        if (!query->__getField(0, (SQL::Field**)&field))
            break;
 
        size_t size = (size_t)-1;
        if (!field->__getDataSize(&size, false) || size == (size_t)-1) {
            __SET_ERROR(SQL::eNotAvailable);
            break;
        }
 
        if (!field->__getData(_buf, _buflen, SQL::typeText))
            break;
 
        // *_buflen에 '\0'이 포함되어 있다.
        *_buflen = ByteString::length(_buf, *_buflen);
 
        query->__destroy();
        query = NULL;
 
        if (localTrans) {
            __commitTrans();
        }
        return true;
    }
 
    if (query) {
        query->__destroy();
    }
 
    if (localTrans) {
        __rollbackTrans();
    }
    return false;
}       

__open()

bool IFXConnection::__open ( const char * _conns, size_t _connlen )

virtual

Implements SQL::Connection.

Definition at line 133 of file IFXConnection.cpp.

{
    ListedByteStringToByteStringMap map;
    Connection::splitConnStr(_conns, _connlen, map);
 
    ByteString _SERVER = map["SERVER"];
    ByteString _USER = map["USER"];
    ByteString _PASSWORD = map["PASSWORD"];
    ByteString _DATABASE = map["DATABASE"];
    ByteString _TARGET;
 
    {
        ByteStringBuilder sb = _DATABASE;
        if (!_SERVER.isEmpty()) {
            sb.append("@").append(_SERVER);
        }
        _TARGET = sb.toByteString();
        __DCL_TRACE1_N(L"TARGET [%hs]\n", _TARGET.data());
    }
 
    ByteString connectionID = ByteString::format("conn_%zx", (size_t)this);
 
/*
 *  EXEC SQL BEGIN DECLARE SECTION;
 */
#line 119 "ifxconnection.ec"
#line 120 "ifxconnection.ec"
  char *user = (_CONST char*) _USER.data();
  char *pass = (_CONST char*) _PASSWORD.data();
  char *target = (_CONST char*) _TARGET.data();
  char *connID = (_CONST char*) connectionID.data();
/*
 *  EXEC SQL END DECLARE SECTION;
 */
#line 124 "ifxconnection.ec"
 
 
/*
 *  EXEC SQL CONNECT TO :target AS :connID
 *      USER :user USING :pass
 *      WITH CONCURRENT TRANSACTION;
 */
#line 126 "ifxconnection.ec"
  {
#line 128 "ifxconnection.ec"
  ifx_conn_t      *_sqiconn;
  _sqiconn = (ifx_conn_t *)ifx_alloc_conn_user(user, pass);
  sqli_connect_open(ESQLINTVERSION, 0, target, connID, _sqiconn, 1);
  ifx_free_conn_user(&_sqiconn);
#line 128 "ifxconnection.ec"
  }
 
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        return false;
    }
    __connectionID = connectionID;
 
    if (!_DATABASE.isEmpty()) {
        reset();
    }
    return true;
}

__rollbackTrans()

bool IFXConnection::__rollbackTrans ( )

virtual

Implements SQL::Connection.

Definition at line 420 of file IFXConnection.cpp.

{   
/*
 *  EXEC SQL BEGIN DECLARE SECTION;
 */
#line 279 "ifxconnection.ec"
#line 280 "ifxconnection.ec"
  char *connID = (_CONST char*) __connectionID.data();
/*
 *  EXEC SQL END DECLARE SECTION;
 */
#line 281 "ifxconnection.ec"
 
 
/*
 *  EXEC SQL SET CONNECTION :connID;
 */
#line 283 "ifxconnection.ec"
  {
#line 283 "ifxconnection.ec"
  sqli_connect_set(0, connID, 0);
#line 283 "ifxconnection.ec"
  }
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        return false;
    }
 
/*
 *  EXEC SQL ROLLBACK WORK;
 */
#line 289 "ifxconnection.ec"
  {
#line 289 "ifxconnection.ec"
  sqli_trans_rollback();
#line 289 "ifxconnection.ec"
  }
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        return false;
    }
 
    __UNSET_STATE(stInTransaction);
    return true;
}

__startTrans()

bool IFXConnection::__startTrans ( )

virtual

Implements SQL::Connection.

Definition at line 328 of file IFXConnection.cpp.

{
/*
 *  EXEC SQL BEGIN DECLARE SECTION;
 */
#line 235 "ifxconnection.ec"
#line 236 "ifxconnection.ec"
  char *connID = (_CONST char*) __connectionID.data();
/*
 *  EXEC SQL END DECLARE SECTION;
 */
#line 237 "ifxconnection.ec"
 
 
/*
 *  EXEC SQL SET CONNECTION :connID;
 */
#line 239 "ifxconnection.ec"
  {
#line 239 "ifxconnection.ec"
  sqli_connect_set(0, connID, 0);
#line 239 "ifxconnection.ec"
  }
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        return false;
    }
 
/*
 *  EXEC SQL BEGIN WORK;
 */
#line 245 "ifxconnection.ec"
  {
#line 245 "ifxconnection.ec"
  sqli_trans_begin2((mint)1);
#line 245 "ifxconnection.ec"
  }
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        return false;
    }
 
    __SET_STATE(stInTransaction);
    return true;
}

connectionID()

_CONST char * IFXConnection::connectionID ( ) const

inline

Definition at line 52 of file IFXConnection.h.

{
    return (_CONST char*)__connectionID.data();
}

destroy()

void IFXConnection::destroy ( )

virtual

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

Implements SQL::Connection.

Definition at line 68 of file IFXConnection.cpp.

{
    delete this;
}

setErrorHandle()

void IFXConnection::setErrorHandle	(	SQL::Error	_error,
		long	_SQLCODE,
		const wchar_t *	_filename,
		int	_line )

Definition at line 480 of file IFXConnection.cpp.

{
    Connection::setErrorStatus(_error, _filename, _line);
    if (_SQLCODE == 0) {
        __lastErrorMessage.clear();
        return;
    }
 
    __DCL_ASSERT(_SQLCODE == sqlca.sqlcode);
 
    ByteStringBuilder sb;
    sb.format("SQLCODE(%d) ", _SQLCODE);
 
    char buf[1024];
    mint actual = 0;
    mint r = rgetlmsg(_SQLCODE, buf, sizeof(buf), &actual);
    if (!r) {
        while (actual > 0) {
            if (!isspace(buf[actual - 1]))
                break;
            actual--;
        }
        buf[actual] = '\0';
        sb.format(buf, sqlca.sqlerrm);
    }
    else {
        sb.format("(%d)", r);
        switch (r) {
        case -1227:
            sb.append("Message file not found");
            break;
        case -1228:
            sb.append("Message number not found in message file");
            break;
        case -1231:
            sb.append("Cannot seek within messge file");
            break;
        case -1232:
            sb.append("Message buffer too small");
            break;
        default:
            sb.append("Unkndown");
        }
    }
    __lastErrorMessage = sb.toByteString();
}

setErrorMessage()

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

inline

Definition at line 43 of file IFXConnection.h.

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

---

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

• IFXConnection.h
• IFXConnection.cpp