#include <SQLCore.h>

Inheritance diagram for SQL::Connection:

Public Types
enum	State { stClosed = 0x0001 , stOpenned = 0x0002 , stInTransaction = 0x0004 }

Public Member Functions
long	refCount () const
long	addRef ()
long	release ()
bool	open (const char *_connString, size_t _connlen)
bool	close ()
bool	execute (const char *_sql, size_t _sqllen)
bool	startTrans ()
bool	commitTrans ()
bool	rollbackTrans ()
bool	getErrorMessage (char _pbuf, size_t _pn)
bool	getServerInfo (char _pbuf, size_t _pn)
bool	createQueryInstance (Query **_queryHandleOut)
bool	destroyQueryInstance (Query *_queryHandle)
Error	errorCode () const
bool	canTransact () const
const wchar_t *	serverTitle () const
bool	inState (unsigned int uState) const
virtual void	destroy ()=0
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

Static Public Member Functions
static size_t	splitConnectionString (const char *_connString, size_t _strlen, ListedByteStringToByteStringMap &_map)

Public Attributes
__PROTECTED	: void setErrorStatus(Error _errorCode
__PROTECTED const wchar_t *	_filename
__PROTECTED const wchar_t int	_line

Protected Member Functions
	Connection (const wchar_t *_serverTitle)
virtual	~Connection ()
virtual bool	__open (const char *_connString, size_t _connlen)=0
virtual bool	__close ()=0
virtual bool	__execute (const char *_sql, size_t _sqllen)=0
virtual bool	__startTrans ()=0
virtual bool	__commitTrans ()=0
virtual bool	__rollbackTrans ()=0
virtual bool	__createQueryInstance (Query **_queryHandleOut)=0
virtual bool	__getErrorMessage (char _buf, size_t _buflen)=0
virtual bool	__getServerInfo (char _buf, size_t _buflen)=0
Protected Member Functions inherited from Object
virtual	~Object ()
	Object ()

Protected Attributes
bool	__canTransact
const wchar_t *	__serverTitle
Error	__errorCode
const wchar_t *	__errorFileName
int	__errorLine
unsigned int	__states

Detailed Description

Definition at line 309 of file SQLCore.h.

Member Enumeration Documentation

◆ State

enum SQL::Connection::State

Enumerator
stClosed
stOpenned
stInTransaction

Definition at line 381 of file SQLCore.h.

    {
        stClosed    = 0x0001,
        stOpenned  = 0x0002,
        stInTransaction = 0x0004
    };

Constructor & Destructor Documentation

◆ Connection()

SQL::Connection::Connection ( const wchar_t * _serverTitle )

protected

Definition at line 653 of file SQLCore.cpp.

{
    __refCount = 0;
 
    __canTransact = false;
    __serverTitle = _serverTitle;
 
    __errorCode = eNoError;
    __errorFileName = NULL;
    __errorLine = 0;
 
    __states = stClosed;
}

◆ ~Connection()

SQL::Connection::~Connection ( )

protectedvirtual

Definition at line 667 of file SQLCore.cpp.

{
    __DCL_ASSERT(refCount() == 0);
}

Member Function Documentation

◆ __close()

virtual bool SQL::Connection::__close ( )

protectedpure virtual

Implemented in IBConnection, IFXConnection, MyConnection, OciConnection, and PgConnection.

◆ __commitTrans()

virtual bool SQL::Connection::__commitTrans ( )

protectedpure virtual

Implemented in IBConnection, IFXConnection, MyConnection, OciConnection, and PgConnection.

◆ __createQueryInstance()

virtual bool SQL::Connection::__createQueryInstance ( Query ** _queryHandleOut )

protectedpure virtual

Implemented in IBConnection, IFXConnection, MyConnection, OciConnection, and PgConnection.

◆ __execute()

virtual bool SQL::Connection::__execute	(	const char *	_sql,
		size_t	_sqllen )

protectedpure virtual

Implemented in IBConnection, IFXConnection, MyConnection, OciConnection, and PgConnection.

◆ __getErrorMessage()

virtual bool SQL::Connection::__getErrorMessage	(	char *	_buf,
		size_t *	_buflen )

protectedpure virtual

Implemented in IBConnection, IFXConnection, MyConnection, OciConnection, and PgConnection.

◆ __getServerInfo()

virtual bool SQL::Connection::__getServerInfo	(	char *	_buf,
		size_t *	_buflen )

protectedpure virtual

Implemented in IBConnection, IFXConnection, MyConnection, OciConnection, and PgConnection.

◆ __open()

virtual bool SQL::Connection::__open	(	const char *	_connString,
		size_t	_connlen )

protectedpure virtual

Implemented in IBConnection, IFXConnection, MyConnection, OciConnection, and PgConnection.

◆ __rollbackTrans()

virtual bool SQL::Connection::__rollbackTrans ( )

protectedpure virtual

Implemented in IBConnection, IFXConnection, MyConnection, OciConnection, and PgConnection.

◆ __startTrans()

virtual bool SQL::Connection::__startTrans ( )

protectedpure virtual

Implemented in IBConnection, IFXConnection, MyConnection, OciConnection, and PgConnection.

◆ addRef()

long SQL::Connection::addRef ( )

◆ canTransact()

bool SQL::Connection::canTransact ( ) const

inline

Definition at line 89 of file SQLCore.inl.

{ 
    return __canTransact; 
}

◆ close()

bool SQL::Connection::close ( )

Definition at line 688 of file SQLCore.cpp.

{
    if (!inState(stOpenned)) {
        __SET_ERROR(eNotConnected);
        return false;
    }
 
    if (refCount()) {
        __SET_ERROR(eHaveChildQuery);
        return false;
    }
 
    if (__close()) {
        __SET_STATE(stClosed);
        return true;
    }
    return false;
}

◆ commitTrans()

bool SQL::Connection::commitTrans ( )

Definition at line 738 of file SQLCore.cpp.

{
    if (!inState(stOpenned)) {
        __SET_ERROR(eNotConnected);
        return false;
    }
 
    if (!inState(stInTransaction)) {
        __SET_ERROR(eNotInTransaction);
        return false;
    }
 
    if (__commitTrans()) {
        __UNSET_STATE(stInTransaction);
        return true;
    }
    return false;
}

◆ createQueryInstance()

bool SQL::Connection::createQueryInstance ( SQL::Query ** _queryHandleOut )

Definition at line 797 of file SQLCore.cpp.

{
    if (!inState(stOpenned)) {
        __SET_ERROR(eNotConnected);
        return false;
    }
 
    __CHECK_ADDRESS(_queryHandleOut);
 
    if (__createQueryInstance(_queryHandleOut)) {
        addRef();
        return true;
    }
    return false;
}

◆ destroy()

virtual void SQL::Connection::destroy ( )

pure virtual

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

Reimplemented from Object.

Implemented in IBConnection, IFXConnection, MyConnection, OciConnection, and PgConnection.

◆ destroyQueryInstance()

bool SQL::Connection::destroyQueryInstance ( SQL::Query * _queryHandle )

Definition at line 813 of file SQLCore.cpp.

{
    if (!inState(stOpenned)) {
        __SET_ERROR(eNotConnected);
        return false;
    }
 
    if (_queryHandle->__connHandle != this) {
        __SET_ERROR(eNoChildQuery);
        return false;
    }
 
    release();
    _queryHandle->__destroy();
    return true;
}

◆ errorCode()

SQL::Error SQL::Connection::errorCode ( ) const

inline

Definition at line 72 of file SQLCore.inl.

{ 
    return __errorCode; 
}

◆ execute()

bool SQL::Connection::execute	(	const char *	_sql,
		size_t	_sqllen )

Definition at line 707 of file SQLCore.cpp.

{
    if (!inState(stOpenned)) {
        __SET_ERROR(eNotConnected);
        return false;
    }
 
    __CHECK_ADDRESS(_sql)
 
    return __execute(_sql, _sqllen);
}

◆ getErrorMessage()

bool SQL::Connection::getErrorMessage	(	char *	_pbuf,
		size_t *	_pn )

Definition at line 776 of file SQLCore.cpp.

{
    if ((_buf == NULL) || (_buflen == NULL) || (*_buflen <= 0))
        return false;
 
    return __getErrorMessage(_buf, _buflen);
}

◆ getServerInfo()

bool SQL::Connection::getServerInfo	(	char *	_pbuf,
		size_t *	_pn )

Definition at line 784 of file SQLCore.cpp.

{
    if (!inState(stOpenned)) {
        __SET_ERROR(eNotConnected);
        return false;
    }
 
    __CHECK_ADDRESS(_buf)
    __CHECK_ADDRESS(_buflen)
 
    return __getServerInfo(_buf, _buflen);
}

◆ inState()

bool SQL::Connection::inState ( unsigned int uState ) const

inline

Definition at line 99 of file SQLCore.inl.

{
    return (__states & _state) == _state;
}

◆ open()

bool SQL::Connection::open	(	const char *	_connString,
		size_t	_connlen )

Definition at line 672 of file SQLCore.cpp.

{
    if (inState(stOpenned)) {
        __SET_ERROR(eConnected);
        return false;
    }
 
    __CHECK_ADDRESS(_connString)
 
    if (__open(_connString, _connlen)) {
        __SET_STATE(stOpenned);
        return true;
    }
    return false;
}

◆ refCount()

long SQL::Connection::refCount ( ) const

inline

Definition at line 316 of file SQLCore.h.

316{ return __refCount; }

◆ release()

long SQL::Connection::release ( )

Definition at line 646 of file SQLCore.cpp.

{
    long n = Thread::decrementAndGet(__refCount);
    __DCL_ASSERT(n >= 0);
    return n;
}

◆ rollbackTrans()

bool SQL::Connection::rollbackTrans ( )

Definition at line 757 of file SQLCore.cpp.

{
    if (!inState(stOpenned)) {
        __SET_ERROR(eNotConnected);
        return false;
    }
 
    if (!inState(stInTransaction)) {
        __SET_ERROR(eNotInTransaction);
        return false;
    }
 
    if (__rollbackTrans()) {
        __UNSET_STATE(stInTransaction);
        return true;
    }
    return false;
}

◆ serverTitle()

const wchar_t * SQL::Connection::serverTitle ( ) const

inline

Definition at line 94 of file SQLCore.inl.

{ 
    return __serverTitle; 
}

◆ splitConnectionString()

size_t SQL::Connection::splitConnectionString	(	const char *	_connString,
		size_t	_strlen,
		ListedByteStringToByteStringMap &	_map )

static

Definition at line 832 of file SQLCore.cpp.

{
    __DCL_ASSERT(_pszConnectionString != NULL);
    ByteStringArray elts;
    ByteString::split(
        _pszConnectionString, _pszConnectionString + _n,
        ';', elts
        );
 
    for(ByteStringArray::Iterator it = elts.begin(); it != elts.end(); it++) {
        ByteStringArray pair;
        (*it).split('=', pair);
        if (pair.size() > 0) {
            ByteStringArray::Iterator itPair = pair.begin();
            ByteString name = *itPair++;
            ByteString value;
            if (pair.size() > 1) {
                value = *itPair;
            }
            _map[name.trim().toUpperCase()] = value.trim();
        }
    }
    return _map.size();
}

◆ startTrans()

bool SQL::Connection::startTrans ( )

Definition at line 719 of file SQLCore.cpp.

{
    if (!inState(stOpenned)) {
        __SET_ERROR(eNotConnected);
        return false;
    }
 
    if (inState(stInTransaction)) {
        __SET_ERROR(eInTransaction);
        return false;
    }
 
    if (__startTrans()) {
        __SET_STATE(stInTransaction);
        return true;
    }
    return false;
}

Member Data Documentation

◆ __canTransact

bool SQL::Connection::__canTransact

protected

Definition at line 371 of file SQLCore.h.

◆ __errorCode

Error SQL::Connection::__errorCode

protected

Definition at line 374 of file SQLCore.h.

◆ __errorFileName

const wchar_t* SQL::Connection::__errorFileName

protected

Definition at line 375 of file SQLCore.h.

◆ __errorLine

int SQL::Connection::__errorLine

protected

Definition at line 376 of file SQLCore.h.

◆ pad0

__PROTECTED SQL::Connection::__pad0__

Definition at line 388 of file SQLCore.h.

◆ __serverTitle

const wchar_t* SQL::Connection::__serverTitle

protected

Definition at line 372 of file SQLCore.h.

◆ __states

unsigned int SQL::Connection::__states

protected

Definition at line 379 of file SQLCore.h.

◆ _filename

__PROTECTED const wchar_t* SQL::Connection::_filename

Definition at line 390 of file SQLCore.h.

◆ _line

__PROTECTED const wchar_t int SQL::Connection::_line

Definition at line 390 of file SQLCore.h.

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

Public Types

Public Member Functions

Static Public Member Functions

Public Attributes

Protected Member Functions

Protected Attributes

Detailed Description

Member Enumeration Documentation

◆ State

Constructor & Destructor Documentation

◆ Connection()

◆ ~Connection()

Member Function Documentation

◆ __close()

◆ __commitTrans()

◆ __createQueryInstance()

◆ __execute()

◆ __getErrorMessage()

◆ __getServerInfo()

◆ __open()

◆ __rollbackTrans()

◆ __startTrans()

◆ addRef()

◆ canTransact()

◆ close()

◆ commitTrans()

◆ createQueryInstance()

◆ destroy()

◆ destroyQueryInstance()

◆ errorCode()

◆ execute()

◆ getErrorMessage()

◆ getServerInfo()

◆ inState()

◆ open()

◆ refCount()

◆ release()

◆ rollbackTrans()

◆ serverTitle()

◆ splitConnectionString()

◆ startTrans()

Member Data Documentation

◆ __canTransact

◆ __errorCode

◆ __errorFileName

◆ __errorLine

◆ __pad0__

◆ __serverTitle

◆ __states

◆ _filename

◆ _line

◆ pad0