Developers Manual Project homepage

O3DBIStatement.cpp

Go to the documentation of this file.

#include "O3DBIStatement.h"
#include "O3DBIError.h"
#include "O3DBIException.h"

// ----------------------------------------------------------------------------
// O3DBIStatement construction/destruction

O3DBIStatement::O3DBIStatement() :
    _pchStmnt(NULL),
    _hStmnt(NULL)
{
    AllocateStmntHandle();
}

O3DBIStatement::O3DBIStatement(PC_TCHAR pchStmnt) :
    _pchStmnt(NULL),
    _hStmnt(NULL)
{
    AllocateStmntHandle();
    if (! AllocateAndSetStmnt(pchStmnt))
        throw new O3DBIException(O3DBI_INVALID_STATEMENT,
            O3DBIErrorTxt::pchInvalidStatement,
            _T("O3DBIStatement::O3DBIStatement"), this);
}

O3DBIStatement::O3DBIStatement(const O3DBIStatement& other) :
    _pchStmnt(NULL),
    _hStmnt(NULL)
{
    AllocateStmntHandle();
    (*this) = other;
}

O3DBIStatement::~O3DBIStatement()
{
    // Free statement string
    if (_pchStmnt != NULL)
    {
        ::free(reinterpret_cast<void*>(_pchStmnt));
        _pchStmnt = NULL;
    }

    // Free statement handle
    if (_hStmnt != NULL)
        OCIHandleFree(reinterpret_cast<TOCIDvoidPtr*>(&_hStmnt),
        OCI_HTYPE_STMT);
}

// ----------------------------------------------------------------------------
// O3DBIStatement operations

O3DBIStatement& O3DBIStatement::operator=(const O3DBIStatement& other)
{
    if (! AllocateAndSetStmnt(other._pchStmnt))
        throw new O3DBIException(O3DBI_INVALID_STATEMENT,
            O3DBIErrorTxt::pchInvalidStatement,
            _T("O3DBIStatement::operator="), this);
    return (*this);
}

O3DBIStatement& O3DBIStatement::operator=(PC_TCHAR pchStmnt)
{
    if (! AllocateAndSetStmnt(pchStmnt))
        throw new O3DBIException(O3DBI_INVALID_STATEMENT,
            O3DBIErrorTxt::pchInvalidStatement,
            _T("O3DBIStatement::operator="), this);
    return (*this);
}

bool O3DBIStatement::operator==(const O3DBIStatement& other) const
{
    return (::_tcscmp(_pchStmnt, other._pchStmnt) == 0);
}

void O3DBIStatement::SetStatement(PC_TCHAR pchStmnt)
{
    if (! AllocateAndSetStmnt(pchStmnt))
        throw new O3DBIException(O3DBI_INVALID_STATEMENT,
            O3DBIErrorTxt::pchInvalidStatement,
            _T("O3DBIStatement::SetStatement"), this);
}

PC_TCHAR O3DBIStatement::GetStatement() const
{
    return _pchStmnt;
}

void O3DBIStatement::SetBindVariable(PC_TCHAR pchPlaceholderName, int iValue)
{
    PreBindCheck(pchPlaceholderName);

}

TO3DBIResult O3DBIStatement::Execute(O3DBIDatabase& db,
                                     O3DBIRecordSet& recordset)
{
    PrepareStatement();
//  BindInputParams();
//  DefineOutputParams();
    return OSUCCESS;
}

TO3DBIResult O3DBIStatement::ExecuteAsync(O3DBIDatabase& db,
                                          O3DBIRecordSet& recordset)
{
    PrepareStatement();
//  BindInputParams();
//  DefineOutputParams();
    return OSUCCESS;
}

bool O3DBIStatement::IsStillExecuting()
{
    return true;
}

bool O3DBIStatement::Terminate()
{
    return true;
}

TO3DBIString O3DBIStatement::ToString() const
{
    _TCHAR buffer[512];
    int p;

    p = _stprintf(buffer, _T("O3DBIStatement at: 0x%x\n"), this);
    p += _stprintf(buffer + p, _T("\tStatement handle: %x\n"), _hStmnt);
    _stprintf(buffer + p, _T("\tStatement: %s\n"), GetStatement());
    return TO3DBIString(buffer);
}

// ----------------------------------------------------------------------------
// O3DBIStatement internal implementation

bool O3DBIStatement::AllocateAndSetStmnt(PC_TCHAR pchStmnt)
{
    if (pchStmnt == NULL)
        return false;   // NULL pointers not allowed!
    unsigned int nLength = ::_tcslen(pchStmnt);
    if (nLength == 0)
        return false;   // Zero-length strings are not allowed!
    if (_pchStmnt != NULL)
    {
        // Free previous allocated memory first
        ::free(reinterpret_cast<void*>(_pchStmnt));
    }
    _pchStmnt =
        reinterpret_cast<P_TCHAR>(::calloc(nLength + sizeof(_TCHAR),
        sizeof(_TCHAR)));
    if (_pchStmnt == NULL)
        return false;
    // Copy string
    ::_tcsncpy(_pchStmnt, pchStmnt, nLength);
    return true;
}

void O3DBIStatement::AllocateStmntHandle()
{
    // Allocate server handle
    TOCIResult result = OCIHandleAlloc(_hEnv,
        reinterpret_cast<TOCIDvoidPtr*>(&_hStmnt), OCI_HTYPE_STMT,
        (size_t)0, (TOCIDvoidPtr*)NULL);

    if (result == OCI_INVALID_HANDLE)
    {
        throw new O3DBIException(-1, _T("Could not allocate statement handle: ")
            _T("OCIHandleAlloc returned OCI_INVALID_HANDLE!"),
            _T("O3DBIStatement::O3DBIStatement"), this);
    }
}

void O3DBIStatement::PrepareStatement()
{
    // Prepare the statement for execution
    ub4 nLength = static_cast<ub4>(::_tcslen(_pchStmnt));
    TOCIResult result = OCIStmtPrepare(_hStmnt, _hError,
        reinterpret_cast<TOCITextPtr>(_pchStmnt), nLength,
        static_cast<ub4>(OCI_NTV_SYNTAX), static_cast<ub4>(OCI_DEFAULT));
    if (result != OCI_SUCCESS)
    {
        TO3DBIString errortext;
        TOCIErrorcode errorcode = GetLastError(result, errortext);
        throw new O3DBIException(errorcode, errortext.c_str(),
            _T("O3DBIStatement::PrepareStatement"), this);
    }
}

void O3DBIStatement::BindInputParams()
{

}

void O3DBIStatement::DefineOutputParams()
{

}

void O3DBIStatement::PreBindCheck(PC_TCHAR pchPlaceholderName) const
{
    // Called by SetBindVariable() with placeholder name.
    if (_hStmnt == NULL)
        throw new O3DBIException(O3DBI_INVALID_STATEMENTHANDLE,
        O3DBIErrorTxt::pchInvalidStatementhandle,
        _T("O3DBIStatement::SetBindVariable"), this);
    if (pchPlaceholderName == NULL || ::_tcslen(pchPlaceholderName) == 0)
        throw new O3DBIException(O3DBI_INVALID_PLACEHOLDER,
        O3DBIErrorTxt::pchInvalidPlaceholder,
        _T("O3DBIStatement::SetBindVariable"), this);
}

---

Generated on Sun Jan 23 11:36:35 2005 for Oracle Object Oriented Database Interface (O3DBI) by  1.3.9.1