SQLConnection Class Reference

#include <SQL.h>

Inheritance diagram for SQLConnection:

Public Member Functions
	SQLConnection (SQLDriver *_driver)
	SQLConnection (const String &_driverName) __DCL_THROWS1(SQLDriverException *)
virtual	~SQLConnection ()
void	open (const String &_connstr) __DCL_THROWS1(SQLException *)
void	close () __DCL_THROWS1(SQLException *)
void	execute (const String &_sql) __DCL_THROWS1(SQLException *)
void	startTrans () __DCL_THROWS1(SQLException *)
void	commitTrans () __DCL_THROWS1(SQLException *)
void	rollbackTrans () __DCL_THROWS1(SQLException *)
String	getServerInfo () __DCL_THROWS1(SQLException *)
bool	canTransact () const
SQL::Connection *	handle () const
SQLDriver *	driver () const
bool	connected () const
bool	inTransaction () const
Public Member Functions inherited from Object
virtual String	toString () const
virtual void	destroy ()
String	className () const
bool	isInstanceOf (const std::type_info &typeinfo) const
virtual const std::type_info &	typeInfo () const

Protected Attributes
SQL::Connection *	__handle
SQLDriver *	__driver
bool	__connected

Additional Inherited Members
Protected Member Functions inherited from Object
virtual	~Object ()
	Object ()

Detailed Description

Definition at line 311 of file SQL.h.

Constructor & Destructor Documentation

SQLConnection() [1/2]

SQLConnection::SQLConnection

(

SQLDriver *

_driver

)

Definition at line 44 of file SQLConnection.cpp.

{
    __DCL_ASSERT_PARAM(_driver != NULL);
    initialize(_driver);
}

SQLConnection() [2/2]

SQLConnection::SQLConnection

(

const String &

_driverName

)

Definition at line 50 of file SQLConnection.cpp.

{
    __DCL_ASSERT_PARAM(!_driverName.isEmpty());
 
    SQLDriver* _driver = SQLDriver::getDriver(_driverName);
    initialize(_driver);
}

~SQLConnection()

SQLConnection::~SQLConnection ( )

virtual

Definition at line 59 of file SQLConnection.cpp.

{
    __DCL_ASSERT(__handle->refCount() == 0);
    if (__connected) {
        try {
            //__DCL_TRACE0(__T("close()\n"));
            close();
        }
        catch (SQLException* e) {
            __DCL_TRACE1(__T("Warning! %ls\n"), e->toString().data());
            e->destroy();
        }
    }
 
    __driver->destroyConnection(__handle);
    //__handle = NULL;
    //__driver = NULL;
}

Member Function Documentation

canTransact()

bool SQLConnection::canTransact

(

)

const

Definition at line 207 of file SQLConnection.cpp.

{
    __DCL_ASSERT(__handle != NULL);
    __DCL_ASSERT(__connected);
    return __handle->canTransact();
}

close()

void SQLConnection::close

(

)

Definition at line 103 of file SQLConnection.cpp.

{
    __DCL_ASSERT(__handle != NULL);
 
    if (__connected) {
        if (inTransaction())
            rollbackTrans();
 
        if (!__handle->close()) {
            throw new SQLException(this, NULL);
        }
 
        __connected = false;
    }
}

commitTrans()

void SQLConnection::commitTrans

(

)

Definition at line 152 of file SQLConnection.cpp.

{
    __DCL_ASSERT(__handle != NULL);
    __DCL_ASSERT(__connected);
//  __DCL_ASSERT(inTransaction());
 
    if (!__handle->commitTrans()) {
        throw new SQLException(this, NULL);
    }
}

connected()

bool SQLConnection::connected ( ) const

inline

Definition at line 132 of file SQL.inl.

{
    return __connected;
}

driver()

SQLDriver * SQLConnection::driver ( ) const

inline

Definition at line 127 of file SQL.inl.

{
    return __driver;
}

execute()

void SQLConnection::execute

(

const String &

_sql

)

Definition at line 119 of file SQLConnection.cpp.

{
    __DCL_ASSERT(__handle != NULL);
    __DCL_ASSERT(__connected);
 
    ByteString mbs;
    try {
        mbs = UTF8Encoder::encode(_sql);
    }
    catch (CharsetConvertException* _cause) {
        throw new SQLException(this, _cause);
    }
 
    if (!__handle->execute(mbs, mbs.length())) {
#ifdef __DCL_DEBUG
        throw new SQLException(this, _sql);
#else
        throw new SQLException(this, NULL);
#endif
    }
}

getServerInfo()

String SQLConnection::getServerInfo

(

)

Definition at line 184 of file SQLConnection.cpp.

{
    __DCL_ASSERT(__handle != NULL);
    __DCL_ASSERT(__connected);
 
    size_t len = 1024;
    ByteBuffer* buf = ByteBuffer::create(len);
    if (!__handle->getServerInfo(buf->data(), &len)) {
        buf->release();
        throw new SQLException(this, NULL);
    }
    buf->__dataLength = len;
    ByteString r = buf;
    buf->release();
 
    try {
        return UTF8Decoder::decode(r);
    }
    catch (CharsetConvertException* _cause) {
        throw new SQLException(this, _cause);
    }
}

handle()

SQL::Connection * SQLConnection::handle ( ) const

inline

Definition at line 122 of file SQL.inl.

{
    return __handle;
}

inTransaction()

bool SQLConnection::inTransaction

(

)

const

Definition at line 174 of file SQLConnection.cpp.

{
    __DCL_ASSERT(__handle != NULL);
 
    if (__connected) {
        return __handle->inState(SQL::Connection::stInTransaction);
    }
    return false;
}

open()

void SQLConnection::open

(

const String &

_connstr

)

Definition at line 79 of file SQLConnection.cpp.

{
    __DCL_ASSERT(__handle != NULL);
    __DCL_ASSERT(__connected == false);
 
    ByteString mbs;
    try {
        mbs = UTF8Encoder::encode(_connstr);
    }
    catch (CharsetConvertException* _cause) {
        throw new SQLException(this, _cause);
    }
 
    if (!__handle->open(mbs, mbs.length())) {
#ifdef __DCL_DEBUG
        throw new SQLException(this, _connstr);
#else
        throw new SQLException(this, NULL);
#endif
    }
 
    __connected = true;
}

rollbackTrans()

void SQLConnection::rollbackTrans

(

)

Definition at line 163 of file SQLConnection.cpp.

{
    __DCL_ASSERT(__handle != NULL);
    __DCL_ASSERT(__connected);
//  __DCL_ASSERT(inTransaction());
 
    if (!__handle->rollbackTrans()) {
        throw new SQLException(this, NULL);
    }
}

startTrans()

void SQLConnection::startTrans

(

)

Definition at line 141 of file SQLConnection.cpp.

{
    __DCL_ASSERT(__handle != NULL);
    __DCL_ASSERT(__connected);
//  __DCL_ASSERT(!inTransaction());
 
    if (!__handle->startTrans()) {
        throw new SQLException(this, NULL);
    }
}

Member Data Documentation

__connected

bool SQLConnection::__connected

protected

Definition at line 345 of file SQL.h.

__driver

SQLDriver* SQLConnection::__driver

protected

Definition at line 344 of file SQL.h.

__handle

SQL::Connection* SQLConnection::__handle

protected

Definition at line 343 of file SQL.h.

---

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

• SQL.h
• SQL.inl
• SQLConnection.cpp