SqConnection Class Reference

#include <SqConnection.h>

Inheritance diagram for SqConnection:

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

Constructor & Destructor Documentation

SqConnection()

SqConnection::SqConnection

(

const wchar_t *

_serverTitle

)

~SqConnection()

SqConnection::~SqConnection ( )

virtual

Definition at line 60 of file SqConnection.cpp.

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

Member Function Documentation

__close()

bool SqConnection::__close ( )

virtual

Implements SQL::Connection.

Definition at line 165 of file SqConnection.cpp.

{
    if (!__conn) {
        __SET_ERROR(SQL::eNotConnected);
        return false;
    }
 
    int rc = sqlite3_close_v2(__conn);
    __conn = NULL;
    if (rc != SQLITE_OK) {
        __SET_ERROR_MSG(sqlite3_errstr(rc));
        return false;
    }
    return true;
}

__commitTrans()

bool SqConnection::__commitTrans ( )

virtual

Implements SQL::Connection.

Definition at line 241 of file SqConnection.cpp.

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

__createQueryInstance()

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

virtual

Implements SQL::Connection.

Definition at line 251 of file SqConnection.cpp.

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

__execute()

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

virtual

Implements SQL::Connection.

Definition at line 212 of file SqConnection.cpp.

{
    char* errmsg = NULL;
    int rc = sqlite3_exec(__conn, _sql, NULL, NULL, &errmsg);
    if (rc != SQLITE_OK) {
        __SET_ERROR_MSG(errmsg);
        return false;
    }
 
    switch(__GetStmtType(_sql)) {
        case StmtTransBegin :
            __SET_STATE(stInTransaction);
            break;
        case StmtTransEnd :
            __UNSET_STATE(stInTransaction);
            break;
        case StmtOther :
        default :
            ;
    }
 
    return true;
}

__getErrorMessage()

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

virtual

Implements SQL::Connection.

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

virtual

Implements SQL::Connection.

Definition at line 276 of file SqConnection.cpp.

{
    ByteStringBuilder sb = "SQLite ";
    sb += sqlite3_libversion();
#ifdef SQLITE_HAS_CODEC
    sb += "/SQLCipher";
#endif
 
    if (sb.length() < *_buflen) {
        *_buflen = sb.length();
        *(_buf + *_buflen) = '\0';
    }
    strncpy(_buf, sb.data(), *_buflen);
    return true;
}       

__open()

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

virtual

Implements SQL::Connection.

Definition at line 73 of file SqConnection.cpp.

{
    ByteString conns(_conns, _connslen);
    ListedByteStringToByteStringMap map;
    Connection::splitConnStr(_conns, _connslen, map);
 
    ByteString _DATABASE = map["DATABASE"];
    ByteString _URI = map["URI"];
#ifdef SQLITE_HAS_CODEC
    ByteString _KEY = map["KEY"];
    ByteString _REKEY = map["REKEY"];
 
    const char* pKey = NULL;
    int nKey = 0;
    if (_KEY.length() > 0) {
        pKey = _KEY.data();
        nKey = _KEY.length();
    }
 
    bool hasReKey = conns.searches("REKEY", true);
    const char* pReKey = NULL;
    int nReKey = 0;
    if (_REKEY.length() > 0) {
        pReKey = _REKEY.data();
        nReKey = _REKEY.length();
    }
#endif
 
    int flags = SQLITE_OPEN_MEMORY;
    const char* zVfs = NULL;
    if (!(_DATABASE.isEmpty())) {
        _URI = _DATABASE;
        flags = SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE;
    }
    else if (!(_URI.isEmpty())) {
        flags = SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE;
    }
    else if (!conns.isEmpty()) {
        _URI = conns;
        if (!_URI.isEmpty()) {
            flags = SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE;
        }
    }
    else {
        flags = SQLITE_OPEN_MEMORY;
        _URI.assign(":memory:");
    }
 
    if (_URI.toLowerCase().startsWith("file:")) {
        flags |= SQLITE_OPEN_URI;
    }
 
#ifdef __WINNT__
    zVfs = "win32-none";
#else
    zVfs = "unix-none";
#endif
 
    sqlite3* conn = NULL;
    int rc = sqlite3_open_v2(_URI, &conn, flags, zVfs);
    if (rc != SQLITE_OK) {
        __SET_ERROR_MSG(sqlite3_errstr(rc));
        return false;
    }
 
    for ( ; ; ) {
#ifdef SQLITE_HAS_CODEC
        rc = sqlite3_key(conn, pKey, nKey);
        if (rc != SQLITE_OK) {
            __SET_ERROR_MSG(sqlite3_errmsg(conn));
            break;
        }
        __DCL_TRACE2_N(L"sqlite3_key [%hs][%d]\n",
            (pKey ? pKey : "(nil)"), nKey);
        if (hasReKey) {
            rc = sqlite3_rekey(conn, pReKey, nReKey);
            if (rc != SQLITE_OK) {
                __SET_ERROR_MSG(sqlite3_errmsg(conn));
                break;
            }
        }
#endif
        __conn = conn;
        return true;
    }
 
    if (conn) {
        sqlite3_close_v2(conn);
    }
    return false;
}

__rollbackTrans()

bool SqConnection::__rollbackTrans ( )

virtual

Implements SQL::Connection.

Definition at line 246 of file SqConnection.cpp.

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

__startTrans()

bool SqConnection::__startTrans ( )

virtual

Implements SQL::Connection.

Definition at line 236 of file SqConnection.cpp.

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

connHandle()

sqlite3 * SqConnection::connHandle ( ) const

inline

Definition at line 39 of file SqConnection.h.

{
    return __conn;
}

cursor()

int SqConnection::cursor

(

)

const

destroy()

void SqConnection::destroy ( )

virtual

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

Implements SQL::Connection.

Definition at line 68 of file SqConnection.cpp.

{
    delete this;
}

setErrorMessage()

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

inline

Definition at line 44 of file SqConnection.h.

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

stmtNo()

int SqConnection::stmtNo

(

)

---

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

• SqConnection.h
• SqConnection.cpp