PqConnection Class Reference

#include <PqConnection.h>

Inheritance diagram for PqConnection:

Public Member Functions
PGconn *	connHandle () const
int	cursor () const
int	stmtNo ()
void	setErrorMessage (const ByteString &_message, const wchar_t *_filename, int _line)
virtual void	destroy ()
	PqConnection (const wchar_t *_serverTitle)
virtual	~PqConnection ()
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 PqConnection.h.

Constructor & Destructor Documentation

PqConnection()

PqConnection::PqConnection

(

const wchar_t *

_serverTitle

)

~PqConnection()

PqConnection::~PqConnection ( )

virtual

Definition at line 58 of file PqConnection.cpp.

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

Member Function Documentation

__close()

bool PqConnection::__close ( )

virtual

Implements SQL::Connection.

Definition at line 170 of file PqConnection.cpp.

{
    if (!__conn) {
        __SET_ERROR(SQL::eNotConnected);
        return false;
    }
 
    PQfinish(__conn);
    __conn = NULL;
 
    return true;
}

__commitTrans()

bool PqConnection::__commitTrans ( )

virtual

Implements SQL::Connection.

Definition at line 244 of file PqConnection.cpp.

{
    return __execute("COMMIT", (size_t)-1);
}

__createQueryInstance()

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

virtual

Implements SQL::Connection.

Definition at line 254 of file PqConnection.cpp.

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

__execute()

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

virtual

Implements SQL::Connection.

Definition at line 214 of file PqConnection.cpp.

{
    PGresult* res = PQexec(__conn, _sql);
    if (PQresultStatus(res) != PGRES_COMMAND_OK) {
        __SET_ERROR_MSG(PQerrorMessage(connHandle()));
        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 PqConnection::__getErrorMessage ( char * _buf, size_t * _buflen )

virtual

Implements SQL::Connection.

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

virtual

Implements SQL::Connection.

Definition at line 280 of file PqConnection.cpp.

{
    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",
        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 PqConnection::__open ( const char * _conns, size_t _connslen )

virtual

Implements SQL::Connection.

Definition at line 79 of file PqConnection.cpp.

{
    ByteString conns(_conns, _connslen);
    const char* regex = "CURSOR *= *[^&;]*[&;]*";
    if (conns.searches(regex, true)) {
        ByteString cursor = conns.substring(regex, true);
        cursor = cursor.substring(cursor.indexOf('=') + 1).trim();
        char* endptr;
        __cursor = strtol(cursor, &endptr, 10);
 
        conns = conns.replace_r(regex, "", true);
    }
 
    ListedByteStringToByteStringMap map;
    Connection::splitConnStr(conns, conns.length(), map);
 
    ByteString _USER = map["USER"];
    ByteString _PASSWORD = map["PASSWORD"];
    ByteString _SERVER = map["SERVER"];
    ByteString _PORT = map["PORT"];
    ByteString _DATABASE = map["DATABASE"];
    ByteString _CONNECT_TIMEOUT = map["CONNECT_TIMEOUT"];
    ByteString _APPLICATION = map["APPLICATION"];
 
    ByteString uri;
    if (!(_USER.isEmpty() || _SERVER.isEmpty() || _DATABASE.isEmpty())) {
        // URI를 만든다.
        ByteStringBuilder sb("postgresql://");
        sb.append(_USER);
        if (!_PASSWORD.isEmpty()) {
            sb.append(":").append(_PASSWORD);
        }
        sb.append("@").append(_SERVER);
        if (!_PORT.isEmpty()) {
            sb.append(":").append(_PORT);
        }
        sb.append("/").append(_DATABASE)
            .append("?connect_timeout=")
            .append(_CONNECT_TIMEOUT.isEmpty() ? "10" : _CONNECT_TIMEOUT)
            .append("&application_name=")
            .append(_APPLICATION.isEmpty() ? "DCL" : _APPLICATION)
            ;
        uri = sb.toByteString();
    }
    else {
        // _conns가 URI이다.
        uri = conns.replace_r("client_encoding=[^&]*&*", "", true);
        if (uri.indexOf('?') == (size_t)-1) {
            uri = uri + '?';
        }
        regex = "connect_timeout=[^&]*&*";
        if (!uri.searches(regex, true)) {
            uri = uri + "&connect_timeout=10";
        }
        regex = "application_name=[^&]*&*";
        if (!uri.searches(regex, true)) {
            uri = uri + "&application_name=DCL";
        }
 
        uri = uri.replace_r("&{2,}", "&", true)
            .replace_r("\\?&", "?", true)
            .trimRight("&")
            ;
    }
    uri = uri + "&client_encoding=UTF8";
    __DCL_TRACE2_N(L"connection URI [%hs] cursor[%ls]\n",
        uri.data(), String::valueOf(__cursor).data()
    );
 
    PGconn* conn = PQconnectdb(uri.data());
    if (PQstatus(conn) != CONNECTION_OK) {
        __SET_ERROR_MSG(PQerrorMessage(conn));
        return false;
    }
 
    __conn = conn;
 
    if (!__execute("SET DateStyle TO 'ISO'; SET IntervalStyle TO 'iso_8601'", (size_t)-1))
        return false;
 
    __DCL_TRACE1_N(L"client_encoding [%hs]\n", PQparameterStatus(conn, "client_encoding"));
    __DCL_TRACE1_N(L"DateStyle [%hs]\n", PQparameterStatus(conn, "DateStyle"));
    __DCL_TRACE1_N(L"integer_datetimes [%hs]\n", PQparameterStatus(conn, "integer_datetimes"));
    __DCL_TRACE1_N(L"IntervalStyle [%hs]\n", PQparameterStatus(conn, "IntervalStyle"));;
    __DCL_TRACE1_N(L"server_encoding [%hs]\n", PQparameterStatus(conn, "server_encoding"));
    __DCL_TRACE1_N(L"server_version [%hs]\n", PQparameterStatus(conn, "server_version"));
    __DCL_TRACE1_N(L"TimeZone [%hs]\n", PQparameterStatus(conn, "TimeZone"));
 
    return true;
}

__rollbackTrans()

bool PqConnection::__rollbackTrans ( )

virtual

Implements SQL::Connection.

Definition at line 249 of file PqConnection.cpp.

{   
    return __execute("ROLLBACK", (size_t)-1);
}

__startTrans()

bool PqConnection::__startTrans ( )

virtual

Implements SQL::Connection.

Definition at line 239 of file PqConnection.cpp.

{
    return __execute("BEGIN", (size_t)-1);
}

connHandle()

PGconn * PqConnection::connHandle ( ) const

inline

Definition at line 41 of file PqConnection.h.

{
    return __conn;
}

cursor()

int PqConnection::cursor ( ) const

inline

Definition at line 46 of file PqConnection.h.

{
    return __cursor;
}

destroy()

void PqConnection::destroy ( )

virtual

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

Implements SQL::Connection.

Definition at line 66 of file PqConnection.cpp.

{
    delete this;
}

setErrorMessage()

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

inline

Definition at line 56 of file PqConnection.h.

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

stmtNo()

int PqConnection::stmtNo ( )

inline

Definition at line 51 of file PqConnection.h.

{
    return ++__stmtNo;
}

---

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

• PqConnection.h
• PqConnection.cpp