SqQuery Class Reference

#include <SqQuery.h>

Inheritance diagram for SqQuery:

Public Member Functions
	SqQuery (SqConnection *pConnection)
virtual	~SqQuery ()
virtual void	__destroy ()
virtual bool	__prepare (const char *_sql, size_t _sqllen, size_t _paramCount)
virtual bool	__execute ()
virtual bool	__fetch ()
virtual bool	__getField (size_t _index, SQL::Field **_fieldHandleOut)
virtual bool	__getParam (size_t _index, SQL::Param **_paramHandleOut)
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 Member Functions
bool	reset ()
Protected Member Functions inherited from SQL::Query
	Query (Connection *_connHandle)
virtual	~Query ()
virtual bool	__moreResults (bool *_moreResults)
Protected Member Functions inherited from Object
virtual	~Object ()
	Object ()

Protected Attributes
sqlite3_stmt *	__stmt
bool	__first
SqField *	__fields
SqParam *	__params
Protected Attributes inherited from SQL::Query
Connection *	__connHandle
bool	__eof
int64_t	__affectedRows
size_t	__fieldCount
size_t	__paramCount
wchar_t	__placeholder
unsigned int	__states

Additional Inherited Members
Public Types inherited from SQL::Query
enum	State { stStandBy = (unsigned int) 0x0001 , stPrepared = 0x0002 , stExecuted = 0x0004 , stFetched = 0x0008 }

Detailed Description

Definition at line 9 of file SqQuery.h.

Constructor & Destructor Documentation

SqQuery()

SqQuery::SqQuery

(

SqConnection *

pConnection

)

~SqQuery()

SqQuery::~SqQuery ( )

virtual

Definition at line 64 of file SqQuery.cpp.

{
#ifdef __DCL_DEBUG
    if (!reset()) {
        char buf[256];
        size_t buflen = sizeof(buf) - 1;
        bool b = conn()->__getErrorMessage(buf, &buflen);
        buf[b ? buflen : 0] = '\0';
        __DCL_TRACE1(L"Warning! Query reset error! %hs\n", buf);
    }
#else
    (void)reset();
#endif
}

Member Function Documentation

__destroy()

void SqQuery::__destroy ( )

virtual

Implements SQL::Query.

Definition at line 79 of file SqQuery.cpp.

{
    delete this;
}

__execute()

bool SqQuery::__execute ( )

virtual

Implements SQL::Query.

Definition at line 167 of file SqQuery.cpp.

{
    __DCL_ASSERT(__stmt != NULL);
 
    for (size_t i = 0; i < Query::__paramCount; i++) {
        if (!(__params[i].onBeforeExecute()))
            return false;
    }
 
    int rc = sqlite3_step(__stmt);
    switch (rc) {
        case SQLITE_ROW: {
            __DCL_ASSERT(
                (__fields == NULL)
                && (Query::__fieldCount == 0)
            );
            Query::__fieldCount = sqlite3_column_count(__stmt);
            __fields = new SqField[Query::__fieldCount];
            if (__fields == NULL) {
                __SET_ERROR(SQL::eOutOfMemory);
                return false;
            }
 
            for (size_t i = 0; i < Query::__fieldCount; i++) {
                if (!__fields[i].init(this, (int) i))
                    return false;
            }
            Query::__eof = false;
            __first = true;
            break;
        }
        case SQLITE_OK:
        case SQLITE_DONE: {
#if SQLITE_VERSION_NUMBER >= 3037000
            Query::__affectedRows = sqlite3_changes64(conn()->connHandle());
#else
            Query::__affectedRows = sqlite3_changes(conn()->connHandle());
#endif
            __DCL_TRACE2_N(L"__execute sqlite3_step[%d][%lld]\n",
                rc, Query::__affectedRows
            );
            break;
        }
        default: {
            __SET_ERROR_MSG(sqlite3_errmsg(conn()->connHandle()));
            return false;
        }
    }
 
    if (Query::__paramCount) {
        for (size_t i = 0; i < Query::__paramCount; i++) {
            if (!(__params[i].onAfterExecute()))
                return false;
        }
        rc = sqlite3_reset(__stmt);
        if (rc != SQLITE_OK) {
            __SET_ERROR_MSG(sqlite3_errmsg(conn()->connHandle()));
            return false;
        }
    }
 
    return true;
}

__fetch()

bool SqQuery::__fetch ( )

virtual

Implements SQL::Query.

Definition at line 231 of file SqQuery.cpp.

{
    if (__first) {
        __first = false;
    }
    else {
        int rc = sqlite3_step(__stmt);
        __DCL_TRACE1_N(L"sqlite3_step [%d]\n", rc);
        switch (rc) {
            case SQLITE_ROW:
                break;
            case SQLITE_DONE:
                Query::__eof = true;
                break;
            default: {
                __SET_ERROR_MSG(sqlite3_errmsg(conn()->connHandle()));
                return false;
            }
        }
    }
    return true;
}

__getField()

bool SqQuery::__getField ( size_t _index, SQL::Field ** _fieldHandleOut )

virtual

Implements SQL::Query.

Definition at line 254 of file SqQuery.cpp.

{
    __DCL_ASSERT(Query::__fieldCount > 0);
    __DCL_ASSERT((0 <= _index) && (_index < Query::__fieldCount));
    *_fieldHandleOut = &__fields[_index];
    return true;
}

__getParam()

bool SqQuery::__getParam ( size_t _index, SQL::Param ** _paramHandleOut )

virtual

Implements SQL::Query.

Definition at line 262 of file SqQuery.cpp.

{
    __DCL_ASSERT(Query::__paramCount > 0);
    __DCL_ASSERT((0 <= _index) && (_index < Query::__paramCount));
    *_paramHandleOut = &__params[_index];
    return true;
}

__prepare()

bool SqQuery::__prepare ( const char * _sql, size_t _sqllen, size_t _paramCount )

virtual

Implements SQL::Query.

Definition at line 117 of file SqQuery.cpp.

{
    if(!reset())
        return false;
 
    sqlite3_stmt* stmt = NULL;
    const char* pzTail = NULL;
    int rc = sqlite3_prepare_v2(conn()->connHandle(),
        _sql, (int)_sqllen, &stmt, &pzTail);
    if (rc != SQLITE_OK) {
        __SET_ERROR_MSG(sqlite3_errmsg(conn()->connHandle()));
        return false;
    }
 
#if defined(__DCL_DEBUG) && __TRACE_THIS
    __DCL_TRACE1_N(L"bind_parameter_count [%d]\n",
        sqlite3_bind_parameter_count(stmt)
    );
    __DCL_TRACE1_N(L"column_count [%d]\n",
        sqlite3_column_count(stmt)
    );
#endif
 
    __DCL_ASSERT((__params == NULL)
        && (Query::__paramCount == 0)
    );
 
    Query::__paramCount = sqlite3_bind_parameter_count(stmt);
    if (Query::__paramCount) {
        __params = new SqParam[Query::__paramCount];
        if (__params == NULL) {
            __SET_ERROR(SQL::eOutOfMemory);
            return false;
        }
 
        for (size_t i = 0; i < Query::__paramCount; i++) {
            int number = (int) i + 1;
            const char* name = sqlite3_bind_parameter_name(stmt, number);
            if (!__params[i].init(this, number, name)) {
                return false;
            }
        }
    }
 
    __stmt = stmt;
    return true;
}

reset()

bool SqQuery::reset ( )

protected

Definition at line 84 of file SqQuery.cpp.

{
    Query::__eof = true;
    Query::__affectedRows = -1;
 
    // clear fields
    if (__fields) {
        __DCL_ASSERT(Query::__fieldCount > 0);
        delete[] __fields;
        __fields = NULL;
        Query::__fieldCount = 0;
    }
 
    // clear binds
    if (__params) {
        __DCL_ASSERT(Query::__paramCount > 0);
        delete[] __params;
        __params = NULL;
        Query::__paramCount = 0;
    }
 
    bool r = true;
    if (__stmt) {
        int rc = sqlite3_finalize(__stmt);
        if (rc != SQLITE_OK) {
            __SET_ERROR_MSG(sqlite3_errmsg(conn()->connHandle()));
            r = false;
        }
    }
 
    return r;
}

Member Data Documentation

__fields

SqField* SqQuery::__fields

protected

Definition at line 20 of file SqQuery.h.

__first

bool SqQuery::__first

protected

Definition at line 18 of file SqQuery.h.

__params

SqParam* SqQuery::__params

protected

Definition at line 21 of file SqQuery.h.

__stmt

sqlite3_stmt* SqQuery::__stmt

protected

Definition at line 17 of file SqQuery.h.

---

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

• SqQuery.h
• SqQuery.cpp