PgConnection Class Reference

#include <PgConnection.h>

Inheritance diagram for PgConnection:

Public Member Functions
void	setErrorStatus (SQL::Error _error, long _SQLCODE, const wchar_t *_filename, int _line)
void	setErrorStatus (const ByteString &_message, const wchar_t *_filename, int _line)
_CONST char *	connectionID () const
virtual void	destroy ()
	PgConnection (const wchar_t *_serverTitle)
virtual	~PgConnection ()
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 **_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 *_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
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	splitConnectionString (const char *_connString, size_t _strlen, ListedByteStringToByteStringMap &_map)
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 PgConnection.h.

Constructor & Destructor Documentation

PgConnection()

PgConnection::PgConnection

(

const wchar_t *

_serverTitle

)

Definition at line 49 of file PgConnection.cpp.

    : Connection(pszServerTitle)
{
    Connection::__canTransact = true;
    __connectionID = ByteString::format("con:%ld",
        Thread::incrementAndGet(__connectionID__));
}

~PgConnection()

PgConnection::~PgConnection ( )

virtual

Definition at line 57 of file PgConnection.cpp.

{
}

Member Function Documentation

__close()

bool PgConnection::__close ( )

virtual

Implements SQL::Connection.

Definition at line 130 of file PgConnection.cpp.

{
    /* exec sql begin declare section */
         
    
#line 111 "PgConnection.pgc"
 char * pszConnectionID = ( _CONST char * ) __connectionID . data () ;
/* exec sql end declare section */
#line 112 "PgConnection.pgc"
 
 
    { ECPGdisconnect(__LINE__, pszConnectionID);}
#line 114 "PgConnection.pgc"
 
    if (SQLCODE < 0)
    {
        __SET_ERROR_SQLCODE(SQLCODE);
        return false;
    }
    
    return true;
}

__commitTrans()

bool PgConnection::__commitTrans ( )

virtual

Implements SQL::Connection.

Definition at line 253 of file PgConnection.cpp.

{
    /* exec sql begin declare section */
         
    
#line 218 "PgConnection.pgc"
 char * pszConnectionID = ( _CONST char * ) __connectionID . data () ;
/* exec sql end declare section */
#line 219 "PgConnection.pgc"
 
 
    { ECPGsetconn(__LINE__, pszConnectionID);}
#line 221 "PgConnection.pgc"
 
    if (SQLCODE < 0)
    {
        __SET_ERROR_SQLCODE(SQLCODE);
        return false;
    }
 
    { ECPGtrans(__LINE__, NULL, "commit work");}
#line 228 "PgConnection.pgc"
 
    if (SQLCODE < 0)
    {
        __SET_ERROR_SQLCODE(SQLCODE);
        return false;
    }
 
    __UNSET_STATE(stInTransaction);
 
    return true;
}

__createQueryInstance()

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

virtual

Implements SQL::Connection.

Definition at line 321 of file PgConnection.cpp.

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

__execute()

bool PgConnection::__execute ( const char * pszSQL, size_t n )

virtual

Implements SQL::Connection.

Definition at line 187 of file PgConnection.cpp.

{
    // PostgreSQL에서 EXEC SQL EXECUTE IMMEDIATE는 DML만 사용할 수 있다!
    PGconn* conn = ECPGget_PGconn(__connectionID.data());
    PGresult* res = PQexec(conn, _sql);
    ExecStatusType status = PQresultStatus(res);
    if (status != PGRES_COMMAND_OK) {
        ByteStringBuilder sb;
        sb.format("ExecStatusType(%d)", status)
            .append(PQresultErrorMessage(res));
        __SET_ERROR_MSG(sb);
        PQclear(res);
        return false;
    }
    PQclear(res);
 
    switch(__GetStmtType(_sql))
    {
    case StmtTransBegin :
        __SET_STATE(stInTransaction);
        break;
    case StmtTransEnd :
        __UNSET_STATE(stInTransaction);
        break;
    case StmtOther :
    default :
        ;
    }
 
    return true;
}

__getErrorMessage()

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

virtual

Implements SQL::Connection.

Definition at line 351 of file PgConnection.cpp.

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

__getServerInfo()

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

virtual

Implements SQL::Connection.

Definition at line 360 of file PgConnection.cpp.

{
    PgQuery* pQuery = new PgQuery(this);
    if (pQuery == NULL) {
        __SET_ERROR(SQL::eOutOfMemory);
        return false;
    }
 
    bool localTrans = false;
    if (!inState(SQL::Connection::stInTransaction)) {
        __startTrans();
        localTrans = true;
    }
 
    const char* _sql = "select version()";
    for ( ; ; ) {
        if (!pQuery->prepare(_sql, ByteString::length(_sql), 0))
            break;
 
        if (!pQuery->execute())
            break;
 
        if (!pQuery->fetch())
            break;
 
        if (pQuery->eof()) {
            __SET_ERROR(SQL::eNotAvailable);
            break;
        }
 
        PgField* pField = NULL;
        if (!pQuery->__getField(0, (SQL::Field**)&pField))
            break;
 
        if (pField->isNull()) {
            __SET_ERROR(SQL::eNotAvailable);
            break;
        }
 
        if (!pField->__getData(_buf, _buflen, SQL::typeText))
            break;
 
        pQuery->__destroy();
        pQuery = NULL;
 
        if (localTrans) {
            __commitTrans();
        }
        return true;
    }
 
    if (pQuery) {
        pQuery->__destroy();
    }
 
    if (localTrans) {
        __rollbackTrans();
    }
    return false;
}       

__open()

bool PgConnection::__open ( const char * _pszConnString, size_t _n )

virtual

Implements SQL::Connection.

Definition at line 74 of file PgConnection.cpp.

{
    ListedByteStringToByteStringMap map;
    Connection::splitConnectionString(_pszConnString, _n, map);
 
    ByteString strServer = map["SERVER"];
    ByteString strUser = map["USER"];
    ByteString strPassword = map["PASSWORD"];
    ByteString strDatabase = map["DATABASE"];
 
    ByteStringBuilder sbTarget;
    if (!strServer.isEmpty()) {
        sbTarget = strServer;
    }
    if (!strDatabase.isEmpty()) {
        if (!sbTarget.isEmpty()) {
            sbTarget += "/";
        }
        sbTarget += strDatabase;
    }
 
    /* exec sql begin declare section */
         
         
         
       
    
#line 88 "PgConnection.pgc"
 char * pszUserName = ( _CONST char * ) strUser . data () ;
 
#line 89 "PgConnection.pgc"
 char * pszPassword = ( _CONST char * ) strPassword . data () ;
 
#line 90 "PgConnection.pgc"
 char * pszTarget = ( _CONST char * ) sbTarget . data () ;
 
#line 91 "PgConnection.pgc"
 char * pszConnectionID = NULL ;
/* exec sql end declare section */
#line 92 "PgConnection.pgc"
 
 
    pszConnectionID = (_CONST char*) __connectionID.data();
 
    { ECPGconnect(__LINE__, 0, pszTarget , pszUserName , pszPassword , pszConnectionID, 0); }
#line 97 "PgConnection.pgc"
  
 
    if (SQLCODE < 0) {
        __SET_ERROR_SQLCODE(SQLCODE);
        return false;
    }
 
    return true;
}

__rollbackTrans()

bool PgConnection::__rollbackTrans ( )

virtual

Implements SQL::Connection.

Definition at line 287 of file PgConnection.cpp.

{   
    /* exec sql begin declare section */
         
    
#line 243 "PgConnection.pgc"
 char * pszConnectionID = ( _CONST char * ) __connectionID . data () ;
/* exec sql end declare section */
#line 244 "PgConnection.pgc"
 
 
    { ECPGsetconn(__LINE__, pszConnectionID);}
#line 246 "PgConnection.pgc"
 
    if (SQLCODE < 0)
    {
        __SET_ERROR_SQLCODE(SQLCODE);
        return false;
    }
 
    { ECPGtrans(__LINE__, NULL, "rollback work");}
#line 253 "PgConnection.pgc"
 
    if (SQLCODE < 0)
    {
        __SET_ERROR_SQLCODE(SQLCODE);
        return false;
    }
 
    __UNSET_STATE(stInTransaction);
    
    return true;
}

__startTrans()

bool PgConnection::__startTrans ( )

virtual

Implements SQL::Connection.

Definition at line 219 of file PgConnection.cpp.

{
    /* exec sql begin declare section */
         
    
#line 193 "PgConnection.pgc"
 char * pszConnectionID = ( _CONST char * ) __connectionID . data () ;
/* exec sql end declare section */
#line 194 "PgConnection.pgc"
 
 
    { ECPGsetconn(__LINE__, pszConnectionID);}
#line 196 "PgConnection.pgc"
 
    if (SQLCODE < 0)
    {
        __SET_ERROR_SQLCODE(SQLCODE);
        return false;
    }
 
    { ECPGtrans(__LINE__, NULL, "begin work");}
#line 203 "PgConnection.pgc"
 
    if (SQLCODE < 0)
    {
        __SET_ERROR_SQLCODE(SQLCODE);
        return false;
    }
 
    __SET_STATE(stInTransaction);
 
    return true;
}

connectionID()

_CONST char * PgConnection::connectionID ( ) const

inline

Definition at line 44 of file PgConnection.h.

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

destroy()

void PgConnection::destroy ( )

virtual

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

Implements SQL::Connection.

Definition at line 61 of file PgConnection.cpp.

{
    delete this;
}

setErrorStatus() [1/2]

void PgConnection::setErrorStatus ( const ByteString & _message, const wchar_t * _filename, int _line )

inline

Definition at line 37 of file PgConnection.h.

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

setErrorStatus() [2/2]

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

Definition at line 336 of file PgConnection.cpp.

{
    Connection::setErrorStatus(_error, _filename, _line);
    if (_SQLCODE == 0 /* ECPG_NO_ERROR */) {
        __lastErrorMessage.clear();
    }
    else {
        ByteStringBuilder sb;
        sb.format("SQLCODE(%d) ", _SQLCODE);
        sb.append(sqlca.sqlerrm.sqlerrmc, sqlca.sqlerrm.sqlerrml);
        __lastErrorMessage = sb.toByteString();
    }
}

---

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

• PgConnection.h
• PgConnection.cpp