QOCIResultPrivate Struct Reference

Public Functions
int	bindValue (OCIStmt *sql, OCIBind **hbnd, OCIError *err, int pos, const QVariant &val, dvoid *indPtr, ub2 *tmpSize, QList< QByteArray > &tmpStorage)
int	bindValues (QVector< QVariant > &values, IndicatorArray &indicators, SizeArray &tmpSizes, QList< QByteArray > &tmpStorage)
bool	isBinaryValue (int i) const
bool	isOutValue (int i) const
void	outValues (QVector< QVariant > &values, IndicatorArray &indicators, QList< QByteArray > &tmpStorage)
	QOCIResultPrivate (QOCIResult *result, const QOCIDriverPrivate *driver)
void	setCharset (dvoid *handle, ub4 type) const
void	setStatementAttributes ()
	~QOCIResultPrivate ()

Public Variables
QOCICols *	cols
OCIEnv *	env
OCIError *	err
int	prefetchMem
int	prefetchRows
QOCIResult *	q
int	serverVersion
OCIStmt *	sql
OCISvcCtx *&	svc
bool	transaction

Detailed Description

Definition at line 164 of file qsql_oci.cpp.

Constructors and Destructors

QOCIResultPrivate()

QOCIResultPrivate::QOCIResultPrivate	(	QOCIResult *	result,
		const QOCIDriverPrivate *	driver
	)

Definition at line 1777 of file qsql_oci.cpp.

    : cols(0), q(result), env(driver->env), err(0), svc(const_cast<OCISvcCtx*&>(driver->svc)),
      sql(0), transaction(driver->transaction), serverVersion(driver->serverVersion),
      prefetchRows(driver->prefetchRows), prefetchMem(driver->prefetchMem)
{
    int r = OCIHandleAlloc(env,
                           reinterpret_cast<void **>(&err),
                           OCI_HTYPE_ERROR,
                           0,
                           0);
    if (r != 0)
        qWarning("QOCIResult: unable to alloc error handle");
}

~QOCIResultPrivate()

QOCIResultPrivate::~QOCIResultPrivate

(

)

Definition at line 1791 of file qsql_oci.cpp.

{
    delete cols;

    int r = OCIHandleFree(err, OCI_HTYPE_ERROR);
    if (r != 0)
        qWarning("~QOCIResult: unable to free statement handle");
}

Functions

bindValue()

int QOCIResultPrivate::bindValue	(	OCIStmt *	sql,
		OCIBind **	hbnd,
		OCIError *	err,
		int	pos,
		const QVariant &	val,
		dvoid *	indPtr,
		ub2 *	tmpSize,
		QList< QByteArray > &	tmpStorage
	)

Definition at line 257 of file qsql_oci.cpp.

Referenced by QOCICols::execBatch().

{
    int r = OCI_SUCCESS;
    void *data = const_cast<void *>(val.constData());

    switch (val.type()) {
    case QVariant::ByteArray:
        r = OCIBindByPos(sql, hbnd, err,
                         pos + 1,
                         isOutValue(pos)
                            ?  const_cast<char *>(reinterpret_cast<QByteArray *>(data)->constData())
                            : reinterpret_cast<QByteArray *>(data)->data(),
                         reinterpret_cast<QByteArray *>(data)->size(),
                         SQLT_BIN, indPtr, 0, 0, 0, 0, OCI_DEFAULT);
        break;
    case QVariant::Time:
    case QVariant::Date:
    case QVariant::DateTime: {
        QByteArray ba = qMakeOraDate(val.toDateTime());
        r = OCIBindByPos(sql, hbnd, err,
                         pos + 1,
                         ba.data(),
                         ba.size(),
                         SQLT_DAT, indPtr, 0, 0, 0, 0, OCI_DEFAULT);
        tmpStorage.append(ba);
        break; }
    case QVariant::Int:
        r = OCIBindByPos(sql, hbnd, err,
                         pos + 1,
                         // if it's an out value, the data is already detached
                         // so the const cast is safe.
                         const_cast<void *>(data),
                         sizeof(int),
                         SQLT_INT, indPtr, 0, 0, 0, 0, OCI_DEFAULT);
        break;
    case QVariant::UInt:
        r = OCIBindByPos(sql, hbnd, err,
                         pos + 1,
                         // if it's an out value, the data is already detached
                         // so the const cast is safe.
                         const_cast<void *>(data),
                         sizeof(uint),
                         SQLT_UIN, indPtr, 0, 0, 0, 0, OCI_DEFAULT);
        break;
    case QVariant::LongLong:
    {
        QByteArray ba = qMakeOCINumber(val.toLongLong(), err);
        r = OCIBindByPos(sql, hbnd, err,
                           pos + 1,
                           ba.data(),
                           ba.size(),
                           SQLT_VNU, indPtr, 0, 0, 0, 0, OCI_DEFAULT);
        tmpStorage.append(ba);
        break;
    }
    case QVariant::ULongLong:
    {
        QByteArray ba = qMakeOCINumber(val.toULongLong(), err);
        r = OCIBindByPos(sql, hbnd, err,
                           pos + 1,
                           ba.data(),
                           ba.size(),
                           SQLT_VNU, indPtr, 0, 0, 0, 0, OCI_DEFAULT);
        tmpStorage.append(ba);
        break;
    }
    case QVariant::Double:
        r = OCIBindByPos(sql, hbnd, err,
                         pos + 1,
                         // if it's an out value, the data is already detached
                         // so the const cast is safe.
                         const_cast<void *>(data),
                         sizeof(double),
                         SQLT_FLT, indPtr, 0, 0, 0, 0, OCI_DEFAULT);
        break;
    case QVariant::UserType:
        if (val.canConvert<QOCIRowIdPointer>() && !isOutValue(pos)) {
            // use a const pointer to prevent a detach
            const QOCIRowIdPointer rptr = qvariant_cast<QOCIRowIdPointer>(val);
            r = OCIBindByPos(sql, hbnd, err,
                             pos + 1,
                             // it's an IN value, so const_cast is ok
                             const_cast<OCIRowid **>(&rptr->id),
                             -1,
                             SQLT_RDD, indPtr, 0, 0, 0, 0, OCI_DEFAULT);
        } else {
            qWarning("Unknown bind variable");
            r = OCI_ERROR;
        }
        break;
    case QVariant::String: {
        const QString s = val.toString();
        if (isBinaryValue(pos)) {
            r = OCIBindByPos(sql, hbnd, err,
                             pos + 1,
                             const_cast<ushort *>(s.utf16()),
                             s.length() * sizeof(QChar),
                             SQLT_LNG, indPtr, 0, 0, 0, 0, OCI_DEFAULT);
            break;
        } else if (!isOutValue(pos)) {
            // don't detach the string
            r = OCIBindByPos(sql, hbnd, err,
                             pos + 1,
                             // safe since oracle doesn't touch OUT values
                             const_cast<ushort *>(s.utf16()),
                             (s.length() + 1) * sizeof(QChar),
                             SQLT_STR, indPtr, 0, 0, 0, 0, OCI_DEFAULT);
            if (r == OCI_SUCCESS)
                setCharset(*hbnd, OCI_HTYPE_BIND);
            break;
        }
    } // fall through for OUT values
    default: {
        const QString s = val.toString();
        // create a deep-copy
        QByteArray ba(reinterpret_cast<const char *>(s.utf16()), (s.length() + 1) * sizeof(QChar));
        if (isOutValue(pos)) {
            ba.reserve((s.capacity() + 1) * sizeof(QChar));
            *tmpSize = ba.size();
            r = OCIBindByPos(sql, hbnd, err,
                             pos + 1,
                             ba.data(),
                             ba.capacity(),
                             SQLT_STR, indPtr, tmpSize, 0, 0, 0, OCI_DEFAULT);
        } else {
            r = OCIBindByPos(sql, hbnd, err,
                             pos + 1,
                             ba.data(),
                             ba.size(),
                             SQLT_STR, indPtr, 0, 0, 0, 0, OCI_DEFAULT);
        }
        if (r == OCI_SUCCESS)
            setCharset(*hbnd, OCI_HTYPE_BIND);
        tmpStorage.append(ba);
        break;
    } // default case
    } // switch
    if (r != OCI_SUCCESS)
        qOraWarning("QOCIResultPrivate::bindValue:", err);
    return r;
}

bindValues()

int QOCIResultPrivate::bindValues	(	QVector< QVariant > &	values,
		IndicatorArray &	indicators,
		SizeArray &	tmpSizes,
		QList< QByteArray > &	tmpStorage
	)

Definition at line 400 of file qsql_oci.cpp.

Referenced by QOCIResult::exec().

{
    int r = OCI_SUCCESS;
    for (int i = 0; i < values.count(); ++i) {
        if (isOutValue(i))
            values[i].detach();
        const QVariant &val = values.at(i);

        OCIBind * hbnd = 0; // Oracle handles these automatically
        sb2 *indPtr = &indicators[i];
        *indPtr = val.isNull() ? -1 : 0;

        bindValue(sql, &hbnd, err, i, val, indPtr, &tmpSizes[i], tmpStorage);
    }
    return r;
}

isBinaryValue()

bool QOCIResultPrivate::isBinaryValue ( int  i ) const

inline

Definition at line 188 of file qsql_oci.cpp.

    { return q->bindValueType(i) & QSql::Binary; }

isOutValue()

bool QOCIResultPrivate::isOutValue ( int  i ) const

inline

Definition at line 186 of file qsql_oci.cpp.

Referenced by QOCICols::execBatch().

    { return q->bindValueType(i) & QSql::Out; }

outValues()

void QOCIResultPrivate::outValues	(	QVector< QVariant > &	values,
		IndicatorArray &	indicators,
		QList< QByteArray > &	tmpStorage
	)

Definition at line 446 of file qsql_oci.cpp.

Referenced by QOCIResult::exec().

{
    for (int i = 0; i < values.count(); ++i) {

        if (!isOutValue(i))
            continue;

        qOraOutValue(values[i], tmpStorage, err);

        QVariant::Type typ = values.at(i).type();
        if (indicators[i] == -1) // NULL
            values[i] = QVariant(typ);
        else
            values[i] = QVariant(typ, values.at(i).constData());
    }
}

setCharset()

void QOCIResultPrivate::setCharset ( dvoid *  handle, ub4  type  ) const

inline

Definition at line 191 of file qsql_oci.cpp.

Referenced by QOCICols::QOCICols().

    {
        int r = 0;
        Q_ASSERT(handle);

#ifdef OCI_ATTR_CHARSET_FORM
        r = OCIAttrSet(handle,
                       type,
                       // this const cast is safe since OCI doesn't touch
                       // the charset.
                       const_cast<void *>(static_cast<const void *>(&qOraCharsetForm)),
                       0,
                       OCI_ATTR_CHARSET_FORM,
                       //Strange Oracle bug: some Oracle servers crash the server process with non-zero error handle (mostly for 10g).
                       //So ignore the error message here.
                       0);
        #ifdef QOCI_DEBUG
        if (r != 0)
            qWarning("QOCIResultPrivate::setCharset: Couldn't set OCI_ATTR_CHARSET_FORM.");
        #endif
#endif

        r = OCIAttrSet(handle,
                       type,
                       // this const cast is safe since OCI doesn't touch
                       // the charset.
                       const_cast<void *>(static_cast<const void *>(&qOraCharset)),
                       0,
                       OCI_ATTR_CHARSET_ID,
                       err);
        if (r != 0)
            qOraWarning("QOCIResultPrivate::setCharsetI Couldn't set OCI_ATTR_CHARSET_ID: ", err);

    }

setStatementAttributes()

void QOCIResultPrivate::setStatementAttributes

(

)

Definition at line 227 of file qsql_oci.cpp.

Referenced by QOCIResult::prepare().

{
    Q_ASSERT(sql);

    int r = 0;

    if (prefetchRows >= 0) {
        r = OCIAttrSet(sql,
                       OCI_HTYPE_STMT,
                       &prefetchRows,
                       0,
                       OCI_ATTR_PREFETCH_ROWS,
                       err);
        if (r != 0)
            qOraWarning("QOCIResultPrivate::setStatementAttributes:"
                        " Couldn't set OCI_ATTR_PREFETCH_ROWS: ", err);
    }
    if (prefetchMem >= 0) {
        r = OCIAttrSet(sql,
                       OCI_HTYPE_STMT,
                       &prefetchMem,
                       0,
                       OCI_ATTR_PREFETCH_MEMORY,
                       err);
        if (r != 0)
            qOraWarning("QOCIResultPrivate::setStatementAttributes:"
                        " Couldn't set OCI_ATTR_PREFETCH_MEMORY: ", err);
    }
}

Properties

cols

QOCICols* QOCIResultPrivate::cols

Definition at line 169 of file qsql_oci.cpp.

Referenced by QOCIResult::exec(), QOCIResult::gotoNext(), QOCIResult::prepare(), QOCIResult::record(), and ~QOCIResultPrivate().

env

OCIEnv* QOCIResultPrivate::env

Definition at line 171 of file qsql_oci.cpp.

Referenced by QOCIResult::lastInsertId(), QOCIResult::prepare(), QOCICols::QOCICols(), QOCIResultPrivate(), and qReadLob().

err

OCIError* QOCIResultPrivate::err

Definition at line 172 of file qsql_oci.cpp.

Referenced by QOCIResult::exec(), QOCICols::execBatch(), QOCICols::getValues(), QOCIResult::gotoNext(), QOCIResult::lastInsertId(), QOCIResult::numRowsAffected(), QOCIResult::prepare(), QOCICols::qMakeOraField(), QOCICols::QOCICols(), QOCIResultPrivate(), qReadLob(), QOCICols::readPiecewise(), and ~QOCIResultPrivate().

prefetchMem

int QOCIResultPrivate::prefetchMem

Definition at line 177 of file qsql_oci.cpp.

prefetchRows

int QOCIResultPrivate::prefetchRows

Definition at line 177 of file qsql_oci.cpp.

q

QOCIResult* QOCIResultPrivate::q

Definition at line 170 of file qsql_oci.cpp.

Referenced by QOCICols::execBatch(), QOCICols::getValues(), and QOCICols::qMakeOraField().

serverVersion

int QOCIResultPrivate::serverVersion

Definition at line 176 of file qsql_oci.cpp.

sql

OCIStmt* QOCIResultPrivate::sql

Definition at line 174 of file qsql_oci.cpp.

Referenced by QOCIResult::exec(), QOCICols::execBatch(), QOCIResult::gotoNext(), QOCIResult::handle(), QOCIResult::lastInsertId(), QOCIResult::numRowsAffected(), QOCIResult::prepare(), QOCICols::QOCICols(), QOCICols::readPiecewise(), and QOCIResult::~QOCIResult().

svc

OCISvcCtx*& QOCIResultPrivate::svc

Definition at line 173 of file qsql_oci.cpp.

Referenced by QOCIResult::exec(), QOCICols::execBatch(), and qReadLob().

transaction

bool QOCIResultPrivate::transaction

Definition at line 175 of file qsql_oci.cpp.

Referenced by QOCIResult::exec(), and QOCICols::execBatch().

---

The documentation for this struct was generated from the following file:

• /src/sql/drivers/oci/qsql_oci.cpp