OciField.cpp

Go to the documentation of this file.

#include <dcl/Config.h>
 
#include <oci.h>
 
#include <dcl/Object.h>
#if __DCL_HAVE_ALLOC_DEBUG
#undef __DCL_ALLOC_LEVEL
#define __DCL_ALLOC_LEVEL   __DCL_ALLOC_INTERNAL
#endif
 
#include <dcl/OutputStream.h>
#include <dcl/BytesOutputStream.h>
#include <dcl/Charset.h>
#include <dcl/SQLCore.h>
 
#include "OciConnection.h"
#include "OciQuery.h"
#include "OciField.h"
 
#define __TRACE_THIS    0
#if __TRACE_THIS
#define __DCL_TRACE0_N  __DCL_TRACE0
#define __DCL_TRACE1_N  __DCL_TRACE1
#define __DCL_TRACE2_N  __DCL_TRACE2
#define __DCL_TRACE3_N  __DCL_TRACE3
#define __DCL_TRACE4_N  __DCL_TRACE4
#define __DCL_TRACE5_N  __DCL_TRACE5
#else
#define __DCL_TRACE0_N(fmt)
#define __DCL_TRACE1_N(fmt, arg)
#define __DCL_TRACE2_N(fmt, arg1, arg2)
#define __DCL_TRACE3_N(fmt, arg1, arg2, arg3)
#define __DCL_TRACE4_N(fmt, arg1, arg2, arg3, arg4)
#define __DCL_TRACE5_N(fmt, arg1, arg2, arg3, arg4, arg5)
#endif
 
#undef __THIS_FILE__
static const char_t __THIS_FILE__[] = __T("dcl/sql/OciField.cpp");
 
__DCL_BEGIN_NAMESPACE
 
#define __SET_ERROR_HANDLE(_error, _status, _OCIError) \
    conn()->setErrorHandle(_error, _status, _OCIError, \
            true, __THIS_FILE__, __LINE__)
#define __SET_ERROR_MSG(_msg) \
    conn()->setErrorMessage(_msg, __THIS_FILE__, __LINE__)
 
IMPLEMENT_CLASSINFO(OciField, SQL::Field)
 
OciField::OciField()
    : Field(NULL)
{
    __sqlt = 0;
}
 
OciField::~OciField()
{
    if (OciData::__descType) {
        __DCL_VERIFY(
            conn()->DescriptorFree(
                *(void**)OciData::__valuePtr,
                OciData::__descType
            ) == OCI_SUCCESS
        );
    }
}
 
OciQuery* OciField::query() const
{
    return (OciQuery*)Field::__queryHandle;
}
 
bool OciField::init(SQL::Query* _queryHandle, ub4 _position,
    ub2 _sqlt, void* _buf, ub2 _buflen
)
{
    __DCL_ASSERT(_queryHandle != NULL);
    Field::__queryHandle = _queryHandle;
    OciData::__position = _position; // 1, 2, 3, ...
    __sqlt = _sqlt;
 
    OCIParam* param = NULL;
    sword status = OCIParamGet(
        query()->stmtHandle(),     // const void *hndlp
        OCI_HTYPE_STMT,             // ub4 htype
        conn()->errorHandle(),      // OCIError *errhp
        (dvoid**)&param,            // void **parmdpp
        _position                   // ub4 pos
    );
    if (status != OCI_SUCCESS) {
        __SET_ERROR_HANDLE(SQL::eServerError, status, conn()->errorHandle());
        return false;
    }
 
    text* name = NULL;
    ub4  size = 0;
    status = OCIAttrGet(
        param,                      // const void *trgthndlp
        OCI_DTYPE_PARAM,            // ub4 trghndltyp
        &name,                      // void *attributep
        &size,                      // ub4 *sizep
        OCI_ATTR_NAME,              // ub4 attrtype
        conn()->errorHandle()       // OCIError *errhp
    );
    if (status != OCI_SUCCESS) {
        __SET_ERROR_HANDLE(SQL::eServerError, status, conn()->errorHandle());
        return false;
    }
 
    try {
        Field::__name = UTF8Decoder::decode((const char*)name, size);
    }
    catch (CharsetConvertException* _e) {
        __SET_ERROR_MSG(UTF8Encoder::encode(_e->toStringAll()));
        _e->destroy();
        return false;
    }
 
    sb2 precision = 0;
    size = sizeof(precision);
    status = OCIAttrGet(
        param,                      // const void *trgthndlp
        OCI_DTYPE_PARAM,            // ub4 trghndltyp
        &precision,                 // void *attributep
        &size,                      // ub4 *sizep
        OCI_ATTR_PRECISION,         // ub4 attrtype
        conn()->errorHandle()       // OCIError *errhp
    );
    __DCL_ASSERT(size == sizeof(precision));
    if (status != OCI_SUCCESS) {
        __SET_ERROR_HANDLE(SQL::eServerError, status, conn()->errorHandle());
        return false;
    }
 
    sb1 scale = 0;
    size = sizeof(scale);
    status = OCIAttrGet(
        param,                      // const void *trgthndlp
        OCI_DTYPE_PARAM,            // ub4 trghndltyp
        &scale,                     // void *attributep
        &size,                      // ub4 *sizep
        OCI_ATTR_SCALE,             // ub4 attrtype
        conn()->errorHandle()       // OCIError *errhp
    );
    __DCL_ASSERT(size == sizeof(scale));
    if (status != OCI_SUCCESS) {
        __SET_ERROR_HANDLE(SQL::eServerError, status, conn()->errorHandle());
        return false;
    }
 
    Field::__precision = precision;
    Field::__scale = scale;
 
#ifdef __DCL_DEBUG
    // ub2 dataSize 이었었는데, Assert failed 되었다.
    // 반환값의 범위는 0 ~ 4000이다.
    ub4 dataSize = 0;
    size = sizeof(dataSize);
    status = OCIAttrGet(
        param,                      // const void *trgthndlp
        OCI_DTYPE_PARAM,            // ub4 trghndltyp
        &dataSize,                  // void *attributep
        &size,                      // ub4 *sizep
        OCI_ATTR_DATA_SIZE,         // ub4 attrtype
        conn()->errorHandle()       // OCIError *errhp
    );
    __DCL_ASSERT(size == sizeof(dataSize));
    if (status != OCI_SUCCESS) {
        __SET_ERROR_HANDLE(SQL::eServerError, status, conn()->errorHandle());
        return false;
    }
    __DCL_TRACE5_N(L"Field [%2d]   size [%6d %3d,%3d] [%ls]\n",
        __position, dataSize, precision, scale, __name.data());
#endif
 
    OciData::__dynamicMode = OCI_DEFAULT;
    OciData::__valueSize = _buflen;
    OciData::__valueType = _sqlt;
    switch(_sqlt) {
        case SQLT_NUM: {
            OciData::__valueType = SQLT_VNU;
            // between 1.0 x 10^-130 and 9.9...9 x 10^125
            // (38 nines followed by 88 zeroes)
            OciData::__maxDataSize = 133;
            Field::__dataType = SQL::typeNumeric;
            break;
        }
        case SQLT_IBFLOAT: {
            OciData::__valueType = SQLT_BFLOAT;
            OciData::__maxDataSize = sizeof(float);
            Field::__dataType = SQL::typeFloat;
            break;
        }
        case SQLT_IBDOUBLE: {
            OciData::__valueType = SQLT_BDOUBLE;
            OciData::__maxDataSize = sizeof(double);
            Field::__dataType = SQL::typeFloat;
            break;
        }
        case SQLT_DAT: {
            OciData::__valueType = SQLT_ODT;
            OciData::__maxDataSize = sizeof(SQL::TimeStamp);
            Field::__dataType = SQL::typeTimeStamp;
            break;
        }
        case SQLT_TIMESTAMP: {
            OciData::__descType = OCI_DTYPE_TIMESTAMP;
            OciData::__maxDataSize = sizeof(SQL::TimeStamp);
            Field::__dataType = SQL::typeTimeStamp;
            break;
        }
        case SQLT_TIMESTAMP_TZ: {
            OciData::__descType = OCI_DTYPE_TIMESTAMP_TZ;
            OciData::__maxDataSize = sizeof(SQL::TimeStamp);
            Field::__dataType = SQL::typeTimeStampTz;
            break;
        }
        case SQLT_TIMESTAMP_LTZ: {
            OciData::__descType = OCI_DTYPE_TIMESTAMP_LTZ;
            OciData::__maxDataSize = sizeof(SQL::TimeStamp);
            Field::__dataType = SQL::typeTimeStampTz;
            break;
        }
        case SQLT_INTERVAL_YM: {
            OciData::__descType = OCI_DTYPE_INTERVAL_YM;
            OciData::__maxDataSize = sizeof(SQL::Interval);
            Field::__dataType = SQL::typeIntervalYm;
            break;
        }
        case SQLT_INTERVAL_DS: {
            OciData::__descType = OCI_DTYPE_INTERVAL_DS;
            OciData::__maxDataSize = sizeof(SQL::Interval);
            Field::__dataType = SQL::typeIntervalDs;
            break;
        }
        case SQLT_RDD: {
            // oci.h
            // #define OCI_ROWID_LEN 23
            // ROWID를 CHR로 받으면 base64로 인코딩되어 리턴한다.
            // 초기 버퍼를 3의 배수로 정한다.
            OciData::__valueType = SQLT_CHR;
            OciData::__maxDataSize = _buflen;
            Field::__dataType = SQL::typeText;
            break;
        }
        case SQLT_CHR: {        // VARCHAR2, NVARCHAR2
            OciData::__maxDataSize = _buflen;     // 4000
            Field::__dataType = SQL::typeText;
            break;
        }
        case SQLT_AFC: {        // CHAR, NCHAR, ANSI Fixed Char
            OciData::__maxDataSize = _buflen;     // 2000
            Field::__dataType = SQL::typeText;
            break;
        }
        case SQLT_BIN: {
            OciData::__maxDataSize = _buflen;     // 2000
            Field::__dataType = SQL::typeBinary;
            break;
        }
        case SQLT_LNG: {
            OciData::__dynamicMode = OCI_DYNAMIC_FETCH;
            OciData::__valueSize = INT32_MAX;
            OciData::__maxDataSize = INT32_MAX;
            Field::__dataType = SQL::typeLongText;
            break;
        }
        case SQLT_LBI: {
            OciData::__dynamicMode = OCI_DYNAMIC_FETCH;
            OciData::__valueSize = INT32_MAX;
            OciData::__maxDataSize = INT32_MAX;
            Field::__dataType = SQL::typeLongBinary;
            break;
        }
        case SQLT_CLOB: {
            OciData::__descType = OCI_DTYPE_LOB;
            OciData::__maxDataSize = UINT32_MAX;
            Field::__dataType = SQL::typeClob;
            break;
        }
        case SQLT_BLOB: {
            OciData::__descType = OCI_DTYPE_LOB;
            OciData::__maxDataSize = UINT32_MAX;
            Field::__dataType = SQL::typeBlob;
            break;
        }
        case SQLT_CFILE: {
            OciData::__descType = OCI_DTYPE_FILE;
            OciData::__maxDataSize = UINT32_MAX;
            Field::__dataType = SQL::typeClob;
            break;
        }
        case SQLT_BFILE: {
            OciData::__descType = OCI_DTYPE_FILE;
            OciData::__maxDataSize = UINT32_MAX;
            Field::__dataType = SQL::typeBlob;
            break;
        }
        default: {
#ifdef __DCL_DEBUG
            __DCL_ASSERT(false);
#else
            __SET_ERROR_HANDLE(SQL::eNotSupportDataType, 0, NULL);
            return false;
#endif
        }
    }
 
#if 0
    // 이 지점에서 반환하면 Segmentation fault
    // 이유를 모르겠다!
    // 위 switch 시작에서 반환하면 문제가 없다.
    // OCIExecute에서 스택에 흔적을 남겼을까?
    // 2025-12-27
    if (_position > 2) {
        __SET_ERROR_HANDLE(SQL::eNotSupportDataType, 0, NULL);
        return false;
    }
#endif
 
    OciData::__valuePtr = _buf;
    OciData::__actualLength = _buflen;
 
    if (OciData::__descType) {
        status = conn()->DescriptorAlloc(
            (dvoid**)OciData::__valuePtr,
            OciData::__descType
        );
        if (status != OCI_SUCCESS) {
            __SET_ERROR_HANDLE(SQL::eServerError, status, NULL);
            return false;
        }
    }
 
    OCIDefine* defnp = NULL;
    if (OciData::__dynamicMode == OCI_DEFAULT) {
        status = OCIDefineByPos(
            query()->stmtHandle(),     // OCIStmt *stmtp,
            &defnp,                     // OCIDefine **defnpp,
            conn()->errorHandle(),      // OCIError *errhp,
            OciData::__position,     // ub4 position,
            OciData::__valuePtr,     // dvoid *valuep,
            OciData::__valueSize,       // sb4 value_sz,
            OciData::__valueType,       // ub2 dty,
            &(OciData::__indicator),    // dvoid *indp,
            &(OciData::__actualLength),  // ub2 *rlenp,
            &(OciData::__returnCode),  // ub2 *rcodep,
            OciData::__dynamicMode        // ub4 mode 
        );
    }
    else {
        // OCI_DYNAMIC_FETCH
        status = OCIDefineByPos(
            query()->stmtHandle(),     // OCIStmt *stmtp,
            &defnp,                     // OCIDefine **defnpp,
            conn()->errorHandle(),      // OCIError *errhp,
            OciData::__position,     // ub4 position,
            NULL,                       // dvoid *valuep,
            OciData::__valueSize,       // sb4 value_sz,
            OciData::__valueType,       // ub2 dty,
            NULL,                       // dvoid *indp,
            NULL,                       // ub2 *rlenp,
            NULL,                       // ub2 *rcodep,
            OciData::__dynamicMode        // ub4 mode 
        );
        if (status == OCI_SUCCESS) {
            status = OCIDefineDynamic(
                defnp,                  // OCIDefine *defnp,
                conn()->errorHandle(),  // OCIError *errhp,
                this,                   // dvoid *octxp,
                defineCallback            // OCICallbackDefine(ocbfp)
            );
        }
    }
    if (status != OCI_SUCCESS) {
        __SET_ERROR_HANDLE(SQL::eServerError, status, conn()->errorHandle());
        return false;
    }
 
    return true;
}
 
const wchar_t* OciField::serverDataTypeName() const
{
    return OciData::__TYPE_NAME(__sqlt);
}
 
bool OciField::__getDataSize(size_t* _size, bool _maxsize)
{
    return OciData::getDataSize(_size, _maxsize);
}
 
bool OciField::__getData(
    void*           _buf,
    size_t*         _size,
    SQL::DataType  _bufType
)
{
#if __TRACE_THIS && 0
    __DCL_TRACE3_N(L"Field::__name[%ls] _bufType[%3d] _size[%zd]\n",
        Field::__name.data(), _bufType, *_size);
    bool r = OciData::getData(_buf, _size, _bufType);
    __DCL_TRACE3_N(L"Field::__name[%ls] _bufType[%3d] _size[%zd]\n",
        Field::__name.data(), _bufType, *_size);
    if (_bufType == SQL::typeText) {
        __DCL_TRACE1_N(L"_buf[%ls]\n",
            String::tryString((const char*) _buf, *_size).data());
    }
    return r;
#else
    return OciData::getData(_buf, _size, _bufType);
#endif
}
 
sb4 OciField::defineCallback(
    dvoid*      _octxp,
    OCIDefine*  _defnp,
    ub4         _iter,
    dvoid**     _bufpp,
    ub4**       _alenpp,
    ub1*        _piecep,
    dvoid**     _indpp,
    ub2**       _rcodepp
)
{
    return ((OciField*)_octxp)->defineCallback(
        _defnp,
        _iter,
        _bufpp,
        _alenpp,
        _piecep,
        _indpp,
        _rcodepp
    );
}
 
sb4 OciField::defineCallback(
    OCIDefine*  _defnp,
    ub4         _iter,
    dvoid**     _bufpp,
    ub4**       _alenpp,
    ub1*        _piecep,
    dvoid**     _indpp,
    ub2**       _rcodepp
)
{
    __DCL_ASSERT(OciData::__dynamicMode == OCI_DYNAMIC_FETCH);
 
#if defined(__DCL_DEBUG) && 0
    switch(*_piecep) {
        case OCI_ONE_PIECE:
            __DCL_TRACE1_N(L"OCI_ONE_PIECE [%d]\n", __position);
            break;
        case OCI_FIRST_PIECE:
            __DCL_TRACE1_N(L"OCI_FIRST_PIECE [%d]\n", __position);
            break;
        case OCI_NEXT_PIECE:
            __DCL_TRACE1_N(L"OCI_NEXT_PIECE [%d]\n", __position);
            break;
        case OCI_LAST_PIECE:
            __DCL_TRACE1_N(L"OCI_LAST_PIECE [%d]\n", __position);
    }
#endif
 
    if (*_piecep == OCI_ONE_PIECE)
        *_piecep = OCI_FIRST_PIECE;
 
    if (*_piecep == OCI_FIRST_PIECE) {
        if (OciData::__bytesOutput)
            OciData::__bytesOutput->reset();
    }
    else {
        if (!OciData::__bytesOutput) {
            OciData::__bytesOutput = new BytesOutputStream();
            if (!OciData::__bytesOutput) {
                __SET_ERROR_HANDLE(SQL::eOutOfMemory, 0, NULL);
                return OCI_ERROR;
            }
 
        }       
        __DCL_ASSERT(OciData::__bytesOutput != NULL);
        try {
            // 이전 PIECE 데이터를 보관한다.
            OciData::__bytesOutput->write(OciData::__valuePtr, OciData::__callbackActualLength);
        }
        catch(IOException* _cause) {
            __SET_ERROR_MSG(UTF8Encoder::encode(_cause->toStringAll()));
            _cause->destroy();
            return OCI_ERROR;
        }
    }
 
    // OCI_DYNAMIC_FETCH에서 버퍼의 크기는 __actualLength에 보관되어있다.
    __DCL_ASSERT(OciData::__actualLength == __DYNAMIC_BUFFER_SIZE);
    OciData::__callbackActualLength = OciData::__actualLength;
    *_bufpp = OciData::__valuePtr;
    *_alenpp = &(OciData::__callbackActualLength);
    *_indpp = &(OciData::__indicator);
    *_rcodepp = &(OciData::__returnCode);
 
    return OCI_CONTINUE;
}
 
__DCL_END_NAMESPACE