IBParam Class Reference

#include <IBParam.h>

Inheritance diagram for IBParam:

Public Member Functions
bool	init (SQL::Query *_query, XSQLVAR *_sqlvar)
void	onAfterExecute ()
	IBParam ()
virtual	~IBParam ()
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
IBQuery *	query () const
IBConnection *	conn () const
virtual const wchar_t *	serverDataTypeName () const
virtual void	setNull ()
virtual bool	__setData (_CONST void *_val, size_t _size, SQL::DataType _valType, SQL::DataType _sqlType)
bool	setInteger (const void *_val, size_t _size)
bool	setUInteger (const void *_val, size_t _size)
bool	setFloat (const void *_val, size_t _size)
bool	setDate (const SQL::Date *_val, size_t _size)
bool	setTime (const SQL::Time *_val, size_t _size)
bool	setTimeStamp (const SQL::TimeStamp *_val, size_t _size)
bool	setBytesToBlob (const byte_t *_val, size_t _size)
bool	setInputStreamToBlob (_CONST InputStream *_input, size_t _size)
bool	cancelBlob ()
Protected Member Functions inherited from SQL::Param
	Param (Query *_queryHandle)
virtual	~Param ()
virtual bool	__setOutputType (DataType _sqlType)
virtual bool	__getDataSize (size_t *_size, bool _maxsize)
virtual bool	__getData (void *_buf, size_t *_size, DataType _bufType)
Protected Member Functions inherited from SQL::Field
	Field (Query *_queryHandle)
virtual	~Field ()
Protected Member Functions inherited from Object
virtual	~Object ()
	Object ()

Additional Inherited Members
Protected Attributes inherited from SQL::Field
Query *	__queryHandle
String	__name
DataType	__dataType
short	__precision
short	__scale

Detailed Description

Definition at line 8 of file IBParam.h.

Constructor & Destructor Documentation

IBParam()

IBParam::IBParam

(

)

~IBParam()

IBParam::~IBParam ( )

virtual

Definition at line 43 of file IBParam.cpp.

{
    if (__indicator == 0 && __SQLTYPE_IS(SQL_BLOB)) {
        __DCL_VERIFY(cancelBlob());
    }
}

Member Function Documentation

__setData()

bool IBParam::__setData ( _CONST void * _val, size_t _size, SQL::DataType _valType, SQL::DataType _sqlType )

protectedvirtual

Implements SQL::Param.

Definition at line 93 of file IBParam.cpp.

{
    if (__indicator == 0 && __SQLTYPE_IS(SQL_BLOB)) {
        if (!cancelBlob())
            return false;
    }
 
    bool r = false;
    switch(_valType) {
        case SQL::typeInteger: {
            r = setInteger(_val, _size);
            break;
        }
        case SQL::typeUInteger: {
            r = setUInteger(_val, _size);
            break;
        }
        case SQL::typeFloat: {
            r = setFloat(_val, _size);
            break;
        }
        case SQL::typeDate: {
            r = setDate((const SQL::Date*)_val, _size);
            break;
        }
        case SQL::typeTime: {
            r = setTime((const SQL::Time*)_val, _size);
            break;
        }
        case SQL::typeTimeStamp: {
            r = setTimeStamp((const SQL::TimeStamp*)_val, _size);
            break;
        }
        case SQL::typeText:
        case SQL::typeBinary: {
            if (__SQLTYPE_IS(SQL_BLOB))
                r = setBytesToBlob((const byte_t*)_val, _size);
            else {
                __sqlvar->sqldata = (char*)_val;
                __sqlvar->sqllen = _size;
                __sqlvar->sqltype = SQL_TEXT + 1;
                r = true;
            }
            break;
        }
        case SQL::typeInputStream: {
            if (__SQLTYPE_IS(SQL_BLOB))
                r = setInputStreamToBlob((_CONST InputStream*)_val, _size);
            else {
                __SET_ERROR(SQL::eInvalidDataType);
                return false;
            }
            break;
        }
    //  case SQL::typeInterval:
        default: {
            __SET_ERROR(SQL::eNotSupportDataType);
            return false;
        }
    }
 
    if (r) {
        __indicator = 0;
        Param::__dataType = _sqlType;
    }
 
    return r;
}

cancelBlob()

bool IBParam::cancelBlob ( )

protected

Definition at line 456 of file IBParam.cpp.

{
//  __DCL_ASSERT(__indicator == 0 && __SQLTYPE_IS(SQL_BLOB));
    isc_blob_handle hBlob = NULL_HANDLE;
 
    if(isc_open_blob2(
        conn()->statusVector(),
        conn()->dbHandlePtr(),
        conn()->trHandlePtr(),
        &hBlob,
        &__data.blob_id,
        0,
        NULL
    )) {
        __SET_ERROR(SQL::eServerError);
        return false;
    }
 
    if (isc_cancel_blob(
        conn()->statusVector(),
        &hBlob
    )) {
        __SET_ERROR(SQL::eServerError);
        return false;
    }
 
    return true;
}

conn()

IBConnection * IBParam::conn ( ) const

inlineprotected

Definition at line 72 of file IBParam.h.

{
    return query()->conn();
}

init()

bool IBParam::init	(	SQL::Query *	_query,
		XSQLVAR *	_sqlvar )

Definition at line 50 of file IBParam.cpp.

{
    __DCL_ASSERT(__sqlvar == NULL);
 
    Param::__queryHandle = _queryHandle;
 
    __indicator = -1;
    __sqltype = _sqlvar->sqltype;
 
    __sqlvar = _sqlvar;
    __sqlvar->sqldata = NULL;
    __sqlvar->sqlind = &__indicator;
    __sqlvar->sqlscale = 0;
 
    return true;
}

onAfterExecute()

void IBParam::onAfterExecute

(

)

Definition at line 67 of file IBParam.cpp.

{
    Param::__dataType = SQL::typeUnknown;
    __indicator = -1;   // set null
    __sqlvar->sqldata = NULL;
}

query()

IBQuery * IBParam::query ( ) const

inlineprotected

Definition at line 67 of file IBParam.h.

{
    return (IBQuery*)Param::__queryHandle;
}

serverDataTypeName()

const wchar_t * IBParam::serverDataTypeName ( ) const

protectedvirtual

Implements SQL::Field.

Definition at line 77 of file IBParam.cpp.

{
    return __dataTypeName(__sqlvar);
}

setBytesToBlob()

bool IBParam::setBytesToBlob ( const byte_t * _val, size_t _size )

protected

Definition at line 337 of file IBParam.cpp.

{
    isc_blob_handle hBlob = NULL_HANDLE;
    if(isc_create_blob2(
        conn()->statusVector(),
        conn()->dbHandlePtr(),
        conn()->trHandlePtr(),
        &hBlob,
        &__data.blob_id,
        0,
        NULL
    )) {
        __SET_ERROR(SQL::eServerError);
        return false;
    }
 
    size_t nTotal = 0;
    size_t nBytes = 0;
    while(nTotal < _size) {
        nBytes = __MIN(_size - nTotal, USHRT_MAX);     
        if (isc_put_segment(
            conn()->statusVector(),
            &hBlob,
            nBytes,
            (char*)_val
        )) {
            __SET_ERROR(SQL::eServerError);
            ISC_STATUS status2[ISC_STATUS_VECTOR_LENGTH];
            isc_close_blob(status2, &hBlob);
            return false;
        }
 
        nTotal += nBytes;
        _val += nBytes;
    }
 
    if (isc_close_blob(conn()->statusVector(), &hBlob)) {
        __SET_ERROR(SQL::eServerError);
        return false;
    }
 
    __sqlvar->sqldata = (char*)&__data.blob_id;
    __sqlvar->sqllen = sizeof(ISC_QUAD);
    __sqlvar->sqltype = SQL_BLOB + 1;
    return true;
}

setDate()

bool IBParam::setDate ( const SQL::Date * _val, size_t _size )

protected

Definition at line 251 of file IBParam.cpp.

{
    if (_size != sizeof(SQL::Date)) {
        __SET_ERROR(SQL::eInvalidDataSize);
        return false;
    }
 
    struct tm tm;
    tm.tm_year = _val->year - 1900;
    tm.tm_mon = _val->month - 1;
    tm.tm_mday = _val->day;
 
    isc_encode_sql_date(&tm, &__data.date);
 
    __sqlvar->sqldata = (char*)&__data;
    __sqlvar->sqllen = sizeof(ISC_DATE);
    __sqlvar->sqltype = SQL_TYPE_DATE + 1;
    return true;
}

setFloat()

bool IBParam::setFloat ( const void * _val, size_t _size )

protected

Definition at line 227 of file IBParam.cpp.

{
    switch(_size) {
        case sizeof(float) : {
            __data.f32 = *(float*)_val;
            __sqlvar->sqllen = sizeof(float);
            __sqlvar->sqltype = SQL_FLOAT + 1;
            break;
        }
        case sizeof(double) : {
            __data.f64 = *(double*)_val;
            __sqlvar->sqllen = sizeof(double);
            __sqlvar->sqltype = SQL_DOUBLE + 1;
            break;
        }
        default: {
            __SET_ERROR(SQL::eInvalidDataSize);
            return false;
        }
    }
    __sqlvar->sqldata = (char*)&__data;
    return true;
}

setInputStreamToBlob()

bool IBParam::setInputStreamToBlob ( _CONST InputStream * _input, size_t _size )

protected

Definition at line 384 of file IBParam.cpp.

{
    isc_blob_handle hBlob = NULL_HANDLE;
    if(isc_create_blob2(
        conn()->statusVector(),
        conn()->dbHandlePtr(),
        conn()->trHandlePtr(),
        &hBlob,
        &__data.blob_id,
        0,
        NULL
    )) {
        __SET_ERROR(SQL::eServerError);
        return false;
    }
 
    char* _pbuf = (char*)malloc(USHRT_MAX);
    if (!_pbuf) {
        __SET_ERROR(SQL::eOutOfMemory);
        ISC_STATUS status2[ISC_STATUS_VECTOR_LENGTH];
        isc_close_blob(status2, &hBlob);
        return false;
    }
 
    try {
        size_t nTotal = 0;
        size_t nBytes = 0;
        for (; ; ) {
            nBytes = __MIN(_size - nTotal, USHRT_MAX);
            if (nBytes && (nBytes = _input->read(_pbuf, nBytes))) {
                if (isc_put_segment(
                    conn()->statusVector(),
                    &hBlob,
                    nBytes,
                    _pbuf
                )) {
                    __SET_ERROR(SQL::eServerError);
                    free(_pbuf);
                    ISC_STATUS status2[ISC_STATUS_VECTOR_LENGTH];
                    isc_close_blob(status2, &hBlob);
                    return false;
                }
                nTotal += nBytes;
            }
            else {
                // done
                break;
            }
        }
    }
    catch (IOException* e) {
        __SET_ERROR_MSG(UTF8Encoder::encode(e->toStringAll()));
        e->destroy();
        free(_pbuf);
        ISC_STATUS status2[ISC_STATUS_VECTOR_LENGTH];
        isc_close_blob(status2, &hBlob);
        return false;
    }
 
    free(_pbuf);
 
    if (isc_close_blob(conn()->statusVector(), &hBlob)) {
        __SET_ERROR(SQL::eServerError);
        return false;
    }
 
    __sqlvar->sqldata = (char*)&__data.blob_id;
    __sqlvar->sqllen = sizeof(ISC_QUAD);
    __sqlvar->sqltype = SQL_BLOB + 1;
    return true;
}

setInteger()

bool IBParam::setInteger ( const void * _val, size_t _size )

protected

Definition at line 167 of file IBParam.cpp.

{
    switch(_size) {
        case sizeof(int16_t): {
            __data.i16 = *(int16_t*)_val;
            __sqlvar->sqllen = sizeof(int16_t);
            __sqlvar->sqltype = SQL_SHORT + 1;
            break;
        }
        case sizeof(int32_t): {
            __data.i32 = *(int32_t*)_val;
            __sqlvar->sqllen = sizeof(int32_t);
            __sqlvar->sqltype = SQL_LONG + 1;
            break;
        }
        case sizeof(int64_t): {
            __data.i64 = *(int64_t*)_val;
            __sqlvar->sqllen = sizeof(int64_t);
            __sqlvar->sqltype = SQL_INT64 + 1;
            break;
        }
        default: {
            __SET_ERROR(SQL::eInvalidDataSize);
            return false;
        }
    }
    __sqlvar->sqldata = (char*)&__data;
    return true;
}

setNull()

void IBParam::setNull ( )

protectedvirtual

Implements SQL::Param.

Definition at line 82 of file IBParam.cpp.

{
    if (__indicator == 0 && __SQLTYPE_IS(SQL_BLOB)) {
        __DCL_VERIFY(cancelBlob());
    }
 
    Param::__dataType = SQL::typeUnknown;
    __indicator = -1;   // set null
    __sqlvar->sqldata = NULL;
}

setTime()

bool IBParam::setTime ( const SQL::Time * _val, size_t _size )

protected

Definition at line 271 of file IBParam.cpp.

{
    if (_size != sizeof(SQL::Time)) {
        __SET_ERROR(SQL::eInvalidDataSize);
        return false;
    }
 
    struct tm tm;
    tm.tm_hour = _val->hour;
    tm.tm_min = _val->min;
    tm.tm_sec = _val->sec;
 
    isc_encode_sql_time(&tm, &__data.time);
    __data.time += _val->frac / 100000;
 
    __sqlvar->sqldata = (char*)&__data;
    __sqlvar->sqllen = sizeof(ISC_TIME);
    __sqlvar->sqltype = SQL_TYPE_TIME + 1;
#if defined(FIREBIRD_IBASE_H) && FB_API_VER >= 40
    if (_val->tzoff != INT16_MIN) {
        __data.time_tz.time_zone = 0;
        __data.time_tz.ext_offset = _val->tzoff;
        __sqlvar->sqllen = sizeof(ISC_TIME_TZ_EX);
        __sqlvar->sqltype = SQL_TIME_TZ_EX + 1;
    }
#endif
    return true;
}

setTimeStamp()

bool IBParam::setTimeStamp ( const SQL::TimeStamp * _val, size_t _size )

protected

Definition at line 300 of file IBParam.cpp.

{
    if (_size != sizeof(SQL::TimeStamp)) {
        __SET_ERROR(SQL::eInvalidDataSize);
        return false;
    }
 
    struct tm tm;
    tm.tm_year = _val->year - 1900;
    tm.tm_mon = _val->month - 1;
    tm.tm_mday = _val->day;
    tm.tm_hour = _val->hour;
    tm.tm_min = _val->min;
    tm.tm_sec = _val->sec;
 
    isc_encode_timestamp(&tm, &__data.ts);
    __data.ts.timestamp_time += _val->frac / 100000;
 
    __sqlvar->sqldata = (char*)&__data;
    __sqlvar->sqllen = sizeof(ISC_TIMESTAMP);
    __sqlvar->sqltype = SQL_TIMESTAMP + 1;
#if defined(FIREBIRD_IBASE_H) && FB_API_VER >= 40
    if (_val->tzoff != INT16_MIN) {
        __data.ts_tz.time_zone = 0;
        __data.ts_tz.ext_offset = _val->tzoff;
        __sqlvar->sqllen = sizeof(ISC_TIMESTAMP_TZ_EX);
        __sqlvar->sqltype = SQL_TIMESTAMP_TZ_EX + 1;
    }
#endif
    return true;
}

setUInteger()

bool IBParam::setUInteger ( const void * _val, size_t _size )

protected

Definition at line 197 of file IBParam.cpp.

{
    switch(_size) {
        case sizeof(uint16_t): {
            __data.i16 = (int16_t) * (uint16_t*)_val;
            __sqlvar->sqllen = sizeof(int16_t);
            __sqlvar->sqltype = SQL_SHORT + 1;
            break;
        }
        case sizeof(uint32_t): {
            __data.i32 = (int32_t) * (uint32_t*)_val;
            __sqlvar->sqllen = sizeof(int32_t);
            __sqlvar->sqltype = SQL_LONG + 1;
            break;
        }
        case sizeof(uint64_t) : {
            __data.i64 = (int64_t) * (uint64_t*)_val;
            __sqlvar->sqllen = sizeof(int64_t);
            __sqlvar->sqltype = SQL_INT64 + 1;
            break;
        }
        default: {
            __SET_ERROR(SQL::eInvalidDataSize);
            return false;
        }
    }
    __sqlvar->sqldata = (char*)&__data;
    return true;
}

Member Data Documentation

blob_id

ISC_QUAD IBParam::blob_id

Definition at line 28 of file IBParam.h.

date

ISC_DATE IBParam::date

Definition at line 21 of file IBParam.h.

f32

float IBParam::f32

Definition at line 19 of file IBParam.h.

f64

double IBParam::f64

Definition at line 20 of file IBParam.h.

i16

int16_t IBParam::i16

Definition at line 16 of file IBParam.h.

i32

int32_t IBParam::i32

Definition at line 17 of file IBParam.h.

i64

int64_t IBParam::i64

Definition at line 18 of file IBParam.h.

time

ISC_TIME IBParam::time

Definition at line 22 of file IBParam.h.

ts

ISC_TIMESTAMP IBParam::ts

Definition at line 23 of file IBParam.h.

---

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

• IBParam.h
• IBParam.cpp