PeConnection Class Reference

#include <PeConnection.h>

Inheritance diagram for PeConnection:

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 ()
	PeConnection (const wchar_t *_serverTitle)
virtual	~PeConnection ()
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 6 of file PeConnection.h.

Constructor & Destructor Documentation

PeConnection()

PeConnection::PeConnection

(

const wchar_t *

_serverTitle

)

~PeConnection()

PeConnection::~PeConnection ( )

virtual

Definition at line 64 of file PeConnection.cpp.

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

Member Function Documentation

__close()

bool PeConnection::__close ( )

virtual

Implements SQL::Connection.

Definition at line 151 of file PeConnection.cpp.

{
    if (__connectionID.isEmpty()) {
        __SET_ERROR(SQL::eNotConnected);
        return false;
    }
 
    /* exec sql begin declare section */
         
    
#line 136 "PeConnection.pgc"
 char * connID = ( _CONST char * ) __connectionID . data () ;
/* exec sql end declare section */
#line 137 "PeConnection.pgc"
 
 
    { ECPGdisconnect(__LINE__, connID);}
#line 139 "PeConnection.pgc"
 
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        return false;
    }
 
    __connectionID.clear();
    return true;
}

__commitTrans()

bool PeConnection::__commitTrans ( )

virtual

Implements SQL::Connection.

Definition at line 272 of file PeConnection.cpp.

{
    /* exec sql begin declare section */
         
    
#line 236 "PeConnection.pgc"
 char * connID = ( _CONST char * ) __connectionID . data () ;
/* exec sql end declare section */
#line 237 "PeConnection.pgc"
 
 
    { ECPGsetconn(__LINE__, connID);}
#line 239 "PeConnection.pgc"
 
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        return false;
    }
 
    { ECPGtrans(__LINE__, NULL, "commit work");}
#line 245 "PeConnection.pgc"
 
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        return false;
    }
 
    __UNSET_STATE(stInTransaction);
    return true;
}

__createQueryInstance()

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

virtual

Implements SQL::Connection.

Definition at line 334 of file PeConnection.cpp.

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

__execute()

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

virtual

Implements SQL::Connection.

Definition at line 210 of file PeConnection.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 PeConnection::__getErrorMessage ( char * _buf, size_t * _buflen )

virtual

Implements SQL::Connection.

Definition at line 365 of file PeConnection.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 PeConnection::__getServerInfo ( char * _buf, size_t * _buflen )

virtual

Implements SQL::Connection.

Definition at line 376 of file PeConnection.cpp.

{
    PGconn* conn = ECPGget_PGconn(__connectionID.data());
    int serverVersion = PQserverVersion(conn);
    int protocolVersion =
#ifdef LIBPQ_HAS_FULL_PROTOCOL_VERSION
        PQfullProtocolVersion(conn)
#else
        PQprotocolVersion(conn) * 10000
#endif
        ;
    int libVersion = PQlibVersion();
 
    ByteString s = ByteString::format("PostgreSQL %d.%d/%d.%d/%d.%d/ecpg",
        serverVersion / 10000, serverVersion % 10000,
        protocolVersion / 10000, protocolVersion % 10000,
        libVersion / 10000, libVersion % 10000
    );
    if (s.length() < *_buflen) {
        *_buflen = s.length();
        *(_buf + *_buflen) = '\0';
    }
    strncpy(_buf, s.data(), *_buflen);
    return true;
}       

__open()

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

virtual

Implements SQL::Connection.

Definition at line 85 of file PeConnection.cpp.

{
    ListedByteStringToByteStringMap map;
    Connection::splitConnStr(_conns, _connslen, map);
 
    ByteString _USER = map["USER"];
    ByteString _PASSWORD = map["PASSWORD"];
    ByteString _SERVER = map["SERVER"];
    ByteString _PORT = map["PORT"];
    ByteString _DATABASE = map["DATABASE"];
    ByteString _TARGET;
 
    {
        ByteStringBuilder sb;
        if (!_SERVER.isEmpty()) {
            sb.append("tcp:postgresql://").append(_SERVER);
            if (!_PORT.isEmpty()) {
                sb.append(":").append(_PORT);
            }
        }
        if (!_DATABASE.isEmpty()) {
            if (!sb.isEmpty()) {
                sb += "/";
            }
            sb += _DATABASE;
        }
        _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 110 "PeConnection.pgc"
 char * user = ( _CONST char * ) _USER . data () ;
 
#line 111 "PeConnection.pgc"
 char * pass = ( _CONST char * ) _PASSWORD . data () ;
 
#line 112 "PeConnection.pgc"
 char * target = ( _CONST char * ) _TARGET . data () ;
 
#line 113 "PeConnection.pgc"
 char * connID = ( _CONST char * ) connectionID . data () ;
/* exec sql end declare section */
#line 114 "PeConnection.pgc"
 
 
    { ECPGconnect(__LINE__, 0, target , user , pass , connID, 0); }
#line 117 "PeConnection.pgc"
  
 
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        return false;
    }
    __connectionID = connectionID;
 
    return true;
}

__rollbackTrans()

bool PeConnection::__rollbackTrans ( )

virtual

Implements SQL::Connection.

Definition at line 303 of file PeConnection.cpp.

{   
    /* exec sql begin declare section */
         
    
#line 258 "PeConnection.pgc"
 char * connID = ( _CONST char * ) __connectionID . data () ;
/* exec sql end declare section */
#line 259 "PeConnection.pgc"
 
 
    { ECPGsetconn(__LINE__, connID);}
#line 261 "PeConnection.pgc"
 
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        return false;
    }
 
    { ECPGtrans(__LINE__, NULL, "rollback work");}
#line 267 "PeConnection.pgc"
 
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        return false;
    }
 
    __UNSET_STATE(stInTransaction);
    return true;
}

__startTrans()

bool PeConnection::__startTrans ( )

virtual

Implements SQL::Connection.

Definition at line 241 of file PeConnection.cpp.

{
    /* exec sql begin declare section */
         
    
#line 214 "PeConnection.pgc"
 char * connID = ( _CONST char * ) __connectionID . data () ;
/* exec sql end declare section */
#line 215 "PeConnection.pgc"
 
 
    { ECPGsetconn(__LINE__, connID);}
#line 217 "PeConnection.pgc"
 
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        return false;
    }
 
    { ECPGtrans(__LINE__, NULL, "begin work");}
#line 223 "PeConnection.pgc"
 
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        return false;
    }
 
    __SET_STATE(stInTransaction);
    return true;
}

connectionID()

_CONST char * PeConnection::connectionID ( ) const

inline

Definition at line 51 of file PeConnection.h.

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

destroy()

void PeConnection::destroy ( )

virtual

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

Implements SQL::Connection.

Definition at line 72 of file PeConnection.cpp.

{
    delete this;
}

setErrorHandle()

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

Definition at line 348 of file PeConnection.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();
    }
}

setErrorMessage()

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

inline

Definition at line 42 of file PeConnection.h.

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

---

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

• PeConnection.h
• PeConnection.cpp