IBConnection Class Reference

#include <IBConnection.h>

Inheritance diagram for IBConnection:

Public Member Functions
void	setErrorHandle (SQL::Error _error, const wchar_t *_filename, int _line)
void	setErrorMessage (const ByteString &_message, const wchar_t *_filename, int _line)
isc_db_handle *	dbHandlePtr ()
isc_tr_handle *	trHandlePtr ()
short	dialect () const
ISC_STATUS *	statusVector ()
	IBConnection (const wchar_t *_serverTitle)
virtual void	destroy ()
virtual	~IBConnection ()
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 16 of file IBConnection.h.

Constructor & Destructor Documentation

IBConnection()

IBConnection::IBConnection

(

const wchar_t *

_serverTitle

)

~IBConnection()

IBConnection::~IBConnection ( )

virtual

Definition at line 59 of file IBConnection.cpp.

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

Member Function Documentation

__close()

bool IBConnection::__close ( )

virtual

Implements SQL::Connection.

Definition at line 207 of file IBConnection.cpp.

{
    if (!__dbHandle) {
        __SET_ERROR(SQL::eNotConnected);
        return false;
    }
    __DCL_ASSERT(__trHandle == NULL_HANDLE);
 
    if (isc_detach_database(
        __status,
        &__dbHandle
    )) {
//      __DCL_ASSERT(STATUS_FAILED(__status));
        __SET_ERROR(SQL::eServerError);
        return false;
    }
    __dbHandle = NULL_HANDLE;
    return true;
}

__commitTrans()

bool IBConnection::__commitTrans ( )

virtual

Implements SQL::Connection.

Definition at line 308 of file IBConnection.cpp.

{
    __DCL_ASSERT(__trHandle != NULL_HANDLE);
    if(isc_commit_transaction(
        __status, 
        &__trHandle
    )) {
//      __DCL_ASSERT(STATUS_FAILED(__status));
        __SET_ERROR(SQL::eServerError);
        return false;
    }
    __trHandle = NULL_HANDLE;
 
    return true;
}

__createQueryInstance()

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

virtual

Implements SQL::Connection.

Definition at line 340 of file IBConnection.cpp.

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

__execute()

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

virtual

Implements SQL::Connection.

Definition at line 255 of file IBConnection.cpp.

{
    __DCL_ASSERT(n <= UINT16_MAX);
    __DCL_ASSERT(__dbHandle != NULL_HANDLE);
    if(isc_dsql_execute_immediate(
        __status,
        &__dbHandle,
        &__trHandle,
        (unsigned short int)n,
        (_CONST char*)_sql,
        __dialect,
        NULL
    )) {
//      __DCL_ASSERT(STATUS_FAILED(__status));
        __SET_ERROR(SQL::eServerError);
        return false;
    }
 
    switch (__GetStmtType(_sql)) {
        case StmtTransBegin :
            __SET_STATE(stInTransaction);
            __DCL_ASSERT(__trHandle != NULL_HANDLE);
            break;
        case StmtTransEnd :
            __UNSET_STATE(stInTransaction);
            __trHandle = NULL_HANDLE;
            break;
        default :
            ;
    }
 
    return true;
}

__getErrorMessage()

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

virtual

Implements SQL::Connection.

Definition at line 354 of file IBConnection.cpp.

{
    ByteStringBuilder sb;
    if (!__lastErrorMessage.isEmpty())
        sb = __lastErrorMessage;
    else {
        char buf[512];
        ISC_STATUS* status = __status;
        size_t len = 0;
#ifdef FIREBIRD_IBASE_H
#define isc_interprete(buf, pp) fb_interpret(buf, sizeof(buf), (const ISC_STATUS**) pp)
#endif
        for(size_t i = 0; (len = isc_interprete(buf, &status))
                && (i < ISC_STATUS_VECTOR_LENGTH); i++) {
            if (i > 0)
                sb += ", ";
            sb.append(buf, 0, len);
        }
    }
 
    if (sb.length() < *_buflen) {
        *_buflen = sb.length();
        *(_buf + *_buflen) = '\0';
    }
    strncpy(_buf, sb.data(), *_buflen);
    return true;
}

__getServerInfo()

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

virtual

Implements SQL::Connection.

Definition at line 388 of file IBConnection.cpp.

{
    char buffer[512];
    if (isc_database_info (
        __status,
        &__dbHandle,
        sizeof(database_info_items),
        database_info_items,
        sizeof(buffer),
        buffer
    )) {
        __SET_ERROR(SQL::eServerError);
        return false;
    }
 
    ByteString version;
    ByteString dbId;
    ByteString site;
 
    char* p = buffer;
    char item;
    unsigned short length;
    __DCL_ASSERT(sizeof(unsigned short) == 2);
    while(*p != isc_info_end) {
        item = *p++;
        length = (unsigned short)isc_vax_integer(p, 2);
        p += 2;
        if (item == isc_info_version) {
        //  __DCL_ASSERT(p[0] == 1);
            //__DCL_TRACE1(L"[%d]\n", p[0]);
            version.assign(p, 2, p[1]);
        }
        else if (item == isc_info_db_id) {
            char* t = p;
            //__DCL_TRACE1(L"[%d]\n", *t);
            //__DCL_ASSERT(*t == 2);
            t++;
            unsigned short strlen = *t++;
            dbId.assign(t, strlen);
            t += strlen;
            strlen = *t++;
            site.assign(t, strlen);
        }
        else {
            __SET_ERROR(SQL::eNotAvailable);
            return false;
        }
        p += length;
    }
 
    ByteString info =
#ifndef FIREBIRD_IBASE_H
        "InterBase " + version
#else
        version
#endif
    // +" \"" + site + ':' + dbId + "\""
    ;
 
    if (info.length() < *_buflen)
        *_buflen = info.length();
 
    strncpy(_buf, info.data(), *_buflen);
    return true;
}

__open()

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

virtual

Implements SQL::Connection.

Definition at line 85 of file IBConnection.cpp.

{
    try  {
        if (Regex::test(__createDatabasePattern__, _conns, true)) {
            // CREATE DATABASE
            if(isc_dsql_execute_immediate(
                __status,
                &__dbHandle,
                &__trHandle,
                0,
                (_CONST char*)_conns,
                __dialect,
                NULL
            )) {
                __SET_ERROR(SQL::eServerError);
                return false;
            }
            return true;
        }
    }
    catch(RegexException* e) {
        e->destroy();
    }
 
    ListedByteStringToByteStringMap map;
    Connection::splitConnStr(_conns, _connlen, map);
 
    ByteString _SERVER = map["SERVER"];
    ByteString _DATABASE = map["DATABASE"];
    ByteString _USER = map["USER"];
    ByteString _PASSWORD = map["PASSWORD"];
    ByteString _SQL_DIALECT = map["SQL_DIALECT"];
 
    if (!_SQL_DIALECT.isEmpty()) {
        int nDialect = SQL_DIALECT_CURRENT;
        char* endptr;
        long n = strtol(_SQL_DIALECT, &endptr, 10);
        if (n == LONG_MAX || n == LONG_MIN
            || n < INT_MIN || INT_MAX < n
        ) {
            __SET_ERROR_MSG("연결 문자열이 잘못되었습니다. SQL_DIALECT="
                + _SQL_DIALECT);
            return false;
        }
 
        nDialect = (int)n;
 
        if (!(nDialect == SQL_DIALECT_V5
            || nDialect == SQL_DIALECT_V6_TRANSITION
            || nDialect == SQL_DIALECT_V6)
        ) {
            __SET_ERROR_MSG("\"SQL_DIALECT\"- invalid value");
            return false;
        }
 
        __dialect = nDialect;
    }
 
    if ((_USER.length() > 127) || (_PASSWORD.length() > 127)) {
        // USER NAME 과 PASSWORD 의 길이는 127을 넘을 수 없다.
        __SET_ERROR(SQL::eInvalidConnectionString);
        return false;
    }
 
    ByteString dbEnv;
    if (!_SERVER.isEmpty())
        dbEnv = _SERVER + ":";
 
    if (!_DATABASE.isEmpty())
        dbEnv = dbEnv + _DATABASE;
 
    if (dbEnv.isEmpty()) {
        __SET_ERROR(SQL::eInvalidConnectionString);
        return false;
    }
 
    // database parameter block
    ByteStringBuilder dpb;
    dpb = (char)isc_dpb_version1;
    dpb += (char)isc_dpb_user_name;
    dpb += (char)_USER.length();
    dpb += _USER;
    dpb += (char)isc_dpb_password;
    dpb += (char)_PASSWORD.length();
    dpb += _PASSWORD;
 
    static const char __UTF8__[] = "UTF8";
    dpb += (char)isc_dpb_lc_ctype;
    dpb += (char)(sizeof(__UTF8__) - 1);
    dpb += __UTF8__;
 
#if defined(FIREBIRD_IBASE_H) && FB_API_VER >= 40
    static const char __SET_BIND__[] =
        "DECFLOAT TO VARCHAR;"      // 20
        "INT128 TO VARCHAR;"        // 18
        "TIME ZONE TO EXTENDED";    // 21
    dpb += (char)isc_dpb_set_bind;
    dpb += (char)(sizeof(__SET_BIND__) - 1);
    dpb += __SET_BIND__;
#endif
 
#ifdef FIREBIRD_IBASE_H
    #undef _CONST
    #define _CONST const
#endif
 
    if (isc_attach_database(
        __status,
        (short) dbEnv.length(),
        (_CONST char*) dbEnv.data(),
        &__dbHandle,
        (short) dpb.length(),
        (_CONST char*) dpb.data())
    ) {
//      __DCL_ASSERT(STATUS_FAILED(__status));
        __SET_ERROR(SQL::eServerError);
        __dbHandle = NULL_HANDLE;
        return false;
    }
    return true;
}

__rollbackTrans()

bool IBConnection::__rollbackTrans ( )

virtual

Implements SQL::Connection.

Definition at line 324 of file IBConnection.cpp.

{
    __DCL_ASSERT(__trHandle != NULL_HANDLE);
    if(isc_rollback_transaction(
        __status, 
        &__trHandle
    )) {
//      __DCL_ASSERT(STATUS_FAILED(__status));
        __SET_ERROR(SQL::eServerError);
        return false;
    }
    __trHandle = NULL_HANDLE;
 
    return true;
}

__startTrans()

bool IBConnection::__startTrans ( )

virtual

Implements SQL::Connection.

Definition at line 289 of file IBConnection.cpp.

{
    __DCL_ASSERT(__trHandle == NULL_HANDLE);
    if (isc_start_transaction(
        __status, 
        &__trHandle, 
        1, 
        &__dbHandle, 
        0, 
        NULL
    )) {
//      __DCL_ASSERT(STATUS_FAILED(__status));
        __SET_ERROR(SQL::eServerError);
        return false;
    }
 
    return true;
}

dbHandlePtr()

isc_db_handle * IBConnection::dbHandlePtr ( )

inline

Definition at line 37 of file IBConnection.h.

{ return &__dbHandle; }

destroy()

void IBConnection::destroy ( )

virtual

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

Implements SQL::Connection.

Definition at line 67 of file IBConnection.cpp.

{
    delete this;
}

dialect()

short IBConnection::dialect ( ) const

inline

Definition at line 39 of file IBConnection.h.

{ return __dialect; }

setErrorHandle()

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

inline

Definition at line 59 of file IBConnection.h.

{
    Connection::setErrorStatus(_error, _filename, _line);
    __lastErrorMessage.clear();
}

setErrorMessage()

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

inline

Definition at line 68 of file IBConnection.h.

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

statusVector()

ISC_STATUS * IBConnection::statusVector ( )

inline

Definition at line 40 of file IBConnection.h.

{ return __status; }

trHandlePtr()

isc_tr_handle * IBConnection::trHandlePtr ( )

inline

Definition at line 38 of file IBConnection.h.

{ return &__trHandle; }

---

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

• IBConnection.h
• IBConnection.cpp