diff options
Diffstat (limited to 'connectivity/source/drivers/odbcbase/OResultSet.cxx')
| -rw-r--r-- | connectivity/source/drivers/odbcbase/OResultSet.cxx | 1768 |
1 files changed, 0 insertions, 1768 deletions
diff --git a/connectivity/source/drivers/odbcbase/OResultSet.cxx b/connectivity/source/drivers/odbcbase/OResultSet.cxx deleted file mode 100644 index 32917e67bb..0000000000 --- a/connectivity/source/drivers/odbcbase/OResultSet.cxx +++ /dev/null @@ -1,1768 +0,0 @@ -/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ -/************************************************************************* - * - * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. - * - * Copyright 2000, 2010 Oracle and/or its affiliates. - * - * OpenOffice.org - a multi-platform office productivity suite - * - * This file is part of OpenOffice.org. - * - * OpenOffice.org is free software: you can redistribute it and/or modify - * it under the terms of the GNU Lesser General Public License version 3 - * only, as published by the Free Software Foundation. - * - * OpenOffice.org is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU Lesser General Public License version 3 for more details - * (a copy is included in the LICENSE file that accompanied this code). - * - * You should have received a copy of the GNU Lesser General Public License - * version 3 along with OpenOffice.org. If not, see - * <http://www.openoffice.org/license.html> - * for a copy of the LGPLv3 License. - * - ************************************************************************/ - -// MARKER(update_precomp.py): autogen include statement, do not remove -#include "precompiled_connectivity.hxx" -#include "odbc/OResultSet.hxx" -#include "odbc/OTools.hxx" -#include "odbc/OResultSetMetaData.hxx" -#include <com/sun/star/sdbc/DataType.hpp> -#include <com/sun/star/beans/PropertyAttribute.hpp> -#include <com/sun/star/sdbcx/CompareBookmark.hpp> -#include <com/sun/star/sdbc/ResultSetConcurrency.hpp> -#include <com/sun/star/sdbc/FetchDirection.hpp> -#include <com/sun/star/sdbc/ResultSetType.hpp> -#include <comphelper/property.hxx> -#include <comphelper/sequence.hxx> -#include <cppuhelper/typeprovider.hxx> -#include <comphelper/extract.hxx> -#include <com/sun/star/lang/DisposedException.hpp> -#include <comphelper/types.hxx> -#include "connectivity/dbtools.hxx" -#include "connectivity/dbexception.hxx" -#include "diagnose_ex.h" -#include <rtl/logfile.hxx> - -#include <o3tl/compat_functional.hxx> - -using namespace ::comphelper; -using namespace connectivity; -using namespace connectivity::odbc; -using namespace cppu; -using namespace com::sun::star::uno; -using namespace com::sun::star::lang; -using namespace com::sun::star::beans; -using namespace com::sun::star::sdbc; -using namespace com::sun::star::sdbcx; -using namespace com::sun::star::container; -using namespace com::sun::star::io; -using namespace com::sun::star::util; - -#define ODBC_SQL_NOT_DEFINED 99UL - -//------------------------------------------------------------------------------ -// IMPLEMENT_SERVICE_INFO(OResultSet,"com.sun.star.sdbcx.OResultSet","com.sun.star.sdbc.ResultSet"); -::rtl::OUString SAL_CALL OResultSet::getImplementationName( ) throw ( RuntimeException) -{ - return ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("com.sun.star.sdbcx.odbc.ResultSet")); -} -// ------------------------------------------------------------------------- - Sequence< ::rtl::OUString > SAL_CALL OResultSet::getSupportedServiceNames( ) throw( RuntimeException) -{ - Sequence< ::rtl::OUString > aSupported(2); - aSupported[0] = ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("com.sun.star.sdbc.ResultSet")); - aSupported[1] = ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("com.sun.star.sdbcx.ResultSet")); - return aSupported; -} -// ------------------------------------------------------------------------- -sal_Bool SAL_CALL OResultSet::supportsService( const ::rtl::OUString& _rServiceName ) throw( RuntimeException) -{ - Sequence< ::rtl::OUString > aSupported(getSupportedServiceNames()); - const ::rtl::OUString* pSupported = aSupported.getConstArray(); - const ::rtl::OUString* pEnd = pSupported + aSupported.getLength(); - for (;pSupported != pEnd && !pSupported->equals(_rServiceName); ++pSupported) - ; - - return pSupported != pEnd; -} - -// ------------------------------------------------------------------------- -OResultSet::OResultSet(SQLHANDLE _pStatementHandle ,OStatement_Base* pStmt) : OResultSet_BASE(m_aMutex) - ,OPropertySetHelper(OResultSet_BASE::rBHelper) - ,m_aStatementHandle(_pStatementHandle) - ,m_aConnectionHandle(pStmt->getConnectionHandle()) - ,m_pStatement(pStmt) - ,m_pSkipDeletedSet(NULL) - ,m_xStatement(*pStmt) - ,m_xMetaData(NULL) - ,m_pRowStatusArray( NULL ) - ,m_nTextEncoding(pStmt->getOwnConnection()->getTextEncoding()) - ,m_nRowPos(0) - ,m_nLastColumnPos(0) - ,m_nUseBookmarks(ODBC_SQL_NOT_DEFINED) - ,m_nCurrentFetchState(0) - ,m_bWasNull(sal_True) - ,m_bEOF(sal_True) - ,m_bLastRecord(sal_False) - ,m_bFreeHandle(sal_False) - ,m_bInserting(sal_False) - ,m_bFetchData(sal_True) - ,m_bRowInserted(sal_False) - ,m_bRowDeleted(sal_False) - ,m_bUseFetchScroll(sal_False) -{ - osl_incrementInterlockedCount( &m_refCount ); - try - { - m_pRowStatusArray = new SQLUSMALLINT[1]; // the default value - N3SQLSetStmtAttr(m_aStatementHandle,SQL_ATTR_ROW_STATUS_PTR,m_pRowStatusArray,SQL_IS_POINTER); - } - catch(const Exception&) - { // we don't want our result destroy here - } - SQLINTEGER nCurType = 0; - try - { - N3SQLGetStmtAttr(m_aStatementHandle,SQL_ATTR_CURSOR_TYPE,&nCurType,SQL_IS_UINTEGER,0); - SQLUINTEGER nValueLen = m_pStatement->getCursorProperties(nCurType,sal_False); - if( (nValueLen & SQL_CA2_SENSITIVITY_DELETIONS) != SQL_CA2_SENSITIVITY_DELETIONS || - (nValueLen & SQL_CA2_CRC_EXACT) != SQL_CA2_CRC_EXACT) - m_pSkipDeletedSet = new OSkipDeletedSet(this); - } - catch(const Exception&) - { // we don't want our result destroy here - } - try - { - SQLUINTEGER nValueLen = 0; - OTools::GetInfo(m_pStatement->getOwnConnection(),m_aConnectionHandle,SQL_GETDATA_EXTENSIONS,nValueLen,NULL); - m_bFetchData = !((SQL_GD_ANY_ORDER & nValueLen) == SQL_GD_ANY_ORDER && nCurType != SQL_CURSOR_FORWARD_ONLY); - } - catch(const Exception&) - { // we don't want our result destroy here - m_bFetchData = sal_True; - } - try - { - if ( getOdbcFunction(ODBC3SQLGetFunctions) ) - { - SQLUSMALLINT nSupported = 0; - m_bUseFetchScroll = ( N3SQLGetFunctions(m_aConnectionHandle,SQL_API_SQLFETCHSCROLL,&nSupported) == SQL_SUCCESS && nSupported == 1 ); - } - } - catch(const Exception&) - { - m_bUseFetchScroll = sal_False; - } - - osl_decrementInterlockedCount( &m_refCount ); -} -// ------------------------------------------------------------------------- -OResultSet::~OResultSet() -{ - delete [] m_pRowStatusArray; - delete m_pSkipDeletedSet; -} -// ----------------------------------------------------------------------------- -void OResultSet::construct() -{ - osl_incrementInterlockedCount( &m_refCount ); - allocBuffer(); - osl_decrementInterlockedCount( &m_refCount ); -} -// ------------------------------------------------------------------------- -void OResultSet::disposing(void) -{ - SQLRETURN nRet = N3SQLCloseCursor(m_aStatementHandle); - OSL_UNUSED( nRet ); - OPropertySetHelper::disposing(); - - ::osl::MutexGuard aGuard(m_aMutex); - if(!m_aBindVector.empty()) - releaseBuffer(); - if(m_bFreeHandle) - m_pStatement->getOwnConnection()->freeStatementHandle(m_aStatementHandle); - -m_xStatement.clear(); -m_xMetaData.clear(); -} -// ------------------------------------------------------------------------- -SQLRETURN OResultSet::unbind(sal_Bool _bUnbindHandle) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::unbind" ); - SQLRETURN nRet = 0; - if ( _bUnbindHandle ) - nRet = N3SQLFreeStmt(m_aStatementHandle,SQL_UNBIND); - - if ( m_aBindVector.size() > 1 ) - { - TVoidVector::iterator pValue = m_aBindVector.begin() + 1; - TVoidVector::iterator pEnd = m_aBindVector.end(); - for(; pValue != pEnd; ++pValue) - { - switch (pValue->second) - { - case DataType::CHAR: - case DataType::VARCHAR: - delete static_cast< ::rtl::OString* >(reinterpret_cast< void * >(pValue->first)); - break; - case DataType::BIGINT: - delete static_cast< sal_Int64* >(reinterpret_cast< void * >(pValue->first)); - break; - case DataType::DECIMAL: - case DataType::NUMERIC: - delete static_cast< ::rtl::OString* >(reinterpret_cast< void * >(pValue->first)); - break; - case DataType::REAL: - case DataType::DOUBLE: - delete static_cast< double* >(reinterpret_cast< void * >(pValue->first)); - break; - case DataType::LONGVARCHAR: - case DataType::CLOB: - delete [] static_cast< char* >(reinterpret_cast< void * >(pValue->first)); - break; - case DataType::LONGVARBINARY: - case DataType::BLOB: - delete [] static_cast< char* >(reinterpret_cast< void * >(pValue->first)); - break; - case DataType::DATE: - delete static_cast< DATE_STRUCT* >(reinterpret_cast< void * >(pValue->first)); - break; - case DataType::TIME: - delete static_cast< TIME_STRUCT* >(reinterpret_cast< void * >(pValue->first)); - break; - case DataType::TIMESTAMP: - delete static_cast< TIMESTAMP_STRUCT* >(reinterpret_cast< void * >(pValue->first)); - break; - case DataType::BIT: - case DataType::TINYINT: - delete static_cast< sal_Int8* >(reinterpret_cast< void * >(pValue->first)); - break; - case DataType::SMALLINT: - delete static_cast< sal_Int16* >(reinterpret_cast< void * >(pValue->first)); - break; - case DataType::INTEGER: - delete static_cast< sal_Int32* >(reinterpret_cast< void * >(pValue->first)); - break; - case DataType::FLOAT: - delete static_cast< float* >(reinterpret_cast< void * >(pValue->first)); - break; - case DataType::BINARY: - case DataType::VARBINARY: - delete static_cast< sal_Int8* >(reinterpret_cast< void * >(pValue->first)); - break; - } - } - m_aBindVector.clear(); - m_aBindVector.push_back(TVoidPtr(0,0)); // the first is reserved for the bookmark - } - return nRet; -} -// ------------------------------------------------------------------------- -TVoidPtr OResultSet::allocBindColumn(sal_Int32 _nType,sal_Int32 _nColumnIndex) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::allocBindColumn" ); - TVoidPtr aPair; - switch (_nType) - { - case DataType::CHAR: - case DataType::VARCHAR: - aPair = TVoidPtr(reinterpret_cast< sal_Int64 >(new ::rtl::OString()),_nType); - break; - case DataType::BIGINT: - aPair = TVoidPtr(reinterpret_cast< sal_Int64 >(new sal_Int64(0)),_nType); - break; - case DataType::DECIMAL: - case DataType::NUMERIC: - aPair = TVoidPtr(reinterpret_cast< sal_Int64 >(new ::rtl::OString()),_nType); - break; - case DataType::REAL: - case DataType::DOUBLE: - aPair = TVoidPtr(reinterpret_cast< sal_Int64 >(new double(0.0)),_nType); - break; - case DataType::LONGVARCHAR: - case DataType::CLOB: - aPair = TVoidPtr(reinterpret_cast< sal_Int64 >(new char[2]),_nType); // dient nur zum auffinden - break; - case DataType::LONGVARBINARY: - case DataType::BLOB: - aPair = TVoidPtr(reinterpret_cast< sal_Int64 >(new char[2]),_nType); // dient nur zum auffinden - break; - case DataType::DATE: - aPair = TVoidPtr(reinterpret_cast< sal_Int64 >(new DATE_STRUCT),_nType); - break; - case DataType::TIME: - aPair = TVoidPtr(reinterpret_cast< sal_Int64 >(new TIME_STRUCT),_nType); - break; - case DataType::TIMESTAMP: - aPair = TVoidPtr(reinterpret_cast< sal_Int64 >(new TIMESTAMP_STRUCT),_nType); - break; - case DataType::BIT: - case DataType::TINYINT: - aPair = TVoidPtr(reinterpret_cast< sal_Int64 >(new sal_Int8(0)),_nType); - break; - case DataType::SMALLINT: - aPair = TVoidPtr(reinterpret_cast< sal_Int64 >(new sal_Int16(0)),_nType); - break; - case DataType::INTEGER: - aPair = TVoidPtr(reinterpret_cast< sal_Int64 >(new sal_Int32(0)),_nType); - break; - case DataType::FLOAT: - aPair = TVoidPtr(reinterpret_cast< sal_Int64 >(new float(0)),_nType); - break; - case DataType::BINARY: - case DataType::VARBINARY: - aPair = TVoidPtr(reinterpret_cast< sal_Int64 >(new sal_Int8[m_aRow[_nColumnIndex].getSequence().getLength()]),_nType); - break; - default: - OSL_FAIL("Unknown type"); - aPair = TVoidPtr(0,_nType); - } - return aPair; -} -// ------------------------------------------------------------------------- -void OResultSet::allocBuffer() -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::allocBuffer" ); - Reference< XResultSetMetaData > xMeta = getMetaData(); - sal_Int32 nLen = xMeta->getColumnCount(); - - m_aBindVector.reserve(nLen+1); - m_aBindVector.push_back(TVoidPtr(0,0)); // the first is reserved for the bookmark - m_aRow.resize(nLen+1); - - for(sal_Int32 i = 1;i<=nLen;++i) - { - sal_Int32 nType = xMeta->getColumnType(i); - m_aRow[i].setTypeKind( nType ); - } - m_aLengthVector.resize(nLen + 1); -} -// ------------------------------------------------------------------------- -void OResultSet::releaseBuffer() -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::releaseBuffer" ); - unbind(sal_False); - m_aLengthVector.clear(); -} -// ------------------------------------------------------------------------- -Any SAL_CALL OResultSet::queryInterface( const Type & rType ) throw(RuntimeException) -{ - Any aRet = OPropertySetHelper::queryInterface(rType); - return aRet.hasValue() ? aRet : OResultSet_BASE::queryInterface(rType); -} -// ------------------------------------------------------------------------- - Sequence< Type > SAL_CALL OResultSet::getTypes( ) throw( RuntimeException) -{ - OTypeCollection aTypes( ::getCppuType( (const Reference< ::com::sun::star::beans::XMultiPropertySet > *)0 ), - ::getCppuType( (const Reference< ::com::sun::star::beans::XFastPropertySet > *)0 ), - ::getCppuType( (const Reference< ::com::sun::star::beans::XPropertySet > *)0 )); - - return ::comphelper::concatSequences(aTypes.getTypes(),OResultSet_BASE::getTypes()); -} -// ------------------------------------------------------------------------- - -sal_Int32 SAL_CALL OResultSet::findColumn( const ::rtl::OUString& columnName ) throw(SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::findColumn" ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - - - ::osl::MutexGuard aGuard( m_aMutex ); - - Reference< XResultSetMetaData > xMeta = getMetaData(); - sal_Int32 nLen = xMeta->getColumnCount(); - sal_Int32 i = 1; - for(;i<=nLen;++i) - if(xMeta->isCaseSensitive(i) ? columnName == xMeta->getColumnName(i) : - columnName.equalsIgnoreAsciiCase(xMeta->getColumnName(i))) - break; - return i; -} -// ------------------------------------------------------------------------- -Reference< XInputStream > SAL_CALL OResultSet::getBinaryStream( sal_Int32 /*columnIndex*/ ) throw(SQLException, RuntimeException) -{ - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - - - // TODO use getBytes instead of - return NULL; -} -// ------------------------------------------------------------------------- -Reference< XInputStream > SAL_CALL OResultSet::getCharacterStream( sal_Int32 /*columnIndex*/ ) throw(SQLException, RuntimeException) -{ - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - - - // TODO use getBytes instead of - return NULL; -} -// ----------------------------------------------------------------------------- -const ORowSetValue& OResultSet::getValue(sal_Int32 _nColumnIndex,SQLSMALLINT _nType,void* _pValue,SQLINTEGER _rSize) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::getValue" ); - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - - if(m_bFetchData) - { - if(_nColumnIndex > m_nLastColumnPos) - fillRow(_nColumnIndex); - return m_aRow[_nColumnIndex]; - } - else - OTools::getValue(m_pStatement->getOwnConnection(),m_aStatementHandle,_nColumnIndex,_nType,m_bWasNull,**this,_pValue,_rSize); - - return m_aEmptyValue; -} -// ------------------------------------------------------------------------- -sal_Bool SAL_CALL OResultSet::getBoolean( sal_Int32 columnIndex ) throw(SQLException, RuntimeException) -{ - sal_Int8 nVal(0); - const ORowSetValue& aValue = getValue(columnIndex,SQL_C_BIT,&nVal,sizeof nVal); - return (&aValue == &m_aEmptyValue) ? (sal_Bool)nVal : (sal_Bool)aValue; -} -// ------------------------------------------------------------------------- - -sal_Int8 SAL_CALL OResultSet::getByte( sal_Int32 columnIndex ) throw(SQLException, RuntimeException) -{ - sal_Int8 nRet(0); - const ORowSetValue& aValue = getValue(columnIndex,SQL_C_TINYINT,&nRet,sizeof nRet); - return (&aValue == &m_aEmptyValue) ? nRet : (sal_Int8)aValue; -} -// ------------------------------------------------------------------------- - -Sequence< sal_Int8 > SAL_CALL OResultSet::getBytes( sal_Int32 columnIndex ) throw(SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::getBytes" ); - - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - ::osl::MutexGuard aGuard( m_aMutex ); - - - if(m_bFetchData) - { - if(columnIndex > m_nLastColumnPos) - fillRow(columnIndex); - Sequence< sal_Int8 > nRet; - switch(m_aRow[columnIndex].getTypeKind()) - { - case DataType::BINARY: - case DataType::VARBINARY: - case DataType::LONGVARBINARY: - nRet = m_aRow[columnIndex]; - break; - default: - { - ::rtl::OUString sRet; - sRet = m_aRow[columnIndex].getString(); - nRet = Sequence<sal_Int8>(reinterpret_cast<const sal_Int8*>(sRet.getStr()),sizeof(sal_Unicode)*sRet.getLength()); - } - } - return nRet; - } - - const SWORD nColumnType = impl_getColumnType_nothrow(columnIndex); - - switch(nColumnType) - { - case SQL_WVARCHAR: - case SQL_WCHAR: - case SQL_WLONGVARCHAR: - case SQL_VARCHAR: - case SQL_CHAR: - case SQL_LONGVARCHAR: - { - ::rtl::OUString aRet = OTools::getStringValue(m_pStatement->getOwnConnection(),m_aStatementHandle,columnIndex,nColumnType,m_bWasNull,**this,m_nTextEncoding); - return Sequence<sal_Int8>(reinterpret_cast<const sal_Int8*>(aRet.getStr()),sizeof(sal_Unicode)*aRet.getLength()); - } - default: - ; - } - return OTools::getBytesValue(m_pStatement->getOwnConnection(),m_aStatementHandle,columnIndex,SQL_C_BINARY,m_bWasNull,**this); -} -// ------------------------------------------------------------------------- - -Date SAL_CALL OResultSet::getDate( sal_Int32 columnIndex ) throw(SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::getDate" ); - DATE_STRUCT aDate; - aDate.day = 0; - aDate.month = 0; - aDate.year = 0; - - const ORowSetValue& aValue = getValue( columnIndex, - m_pStatement->getOwnConnection()->useOldDateFormat() ? SQL_C_DATE : SQL_C_TYPE_DATE, - &aDate,sizeof aDate); - return (&aValue == &m_aEmptyValue) ? Date(aDate.day,aDate.month,aDate.year) : (Date)aValue; -} -// ------------------------------------------------------------------------- - -double SAL_CALL OResultSet::getDouble( sal_Int32 columnIndex ) throw(SQLException, RuntimeException) -{ - double nRet(0); - const ORowSetValue& aValue = getValue(columnIndex,SQL_C_DOUBLE,&nRet,sizeof nRet); - return (&aValue == &m_aEmptyValue) ? nRet : (double)aValue; -} -// ------------------------------------------------------------------------- - -float SAL_CALL OResultSet::getFloat( sal_Int32 columnIndex ) throw(SQLException, RuntimeException) -{ - float nRet(0); - const ORowSetValue& aValue = getValue(columnIndex,SQL_C_FLOAT,&nRet,sizeof nRet); - return (&aValue == &m_aEmptyValue) ? nRet : (float)aValue; -} -// ------------------------------------------------------------------------- - -sal_Int32 SAL_CALL OResultSet::getInt( sal_Int32 columnIndex ) throw(SQLException, RuntimeException) -{ - sal_Int32 nRet(0); - const ORowSetValue& aValue = getValue(columnIndex,SQL_C_LONG,&nRet,sizeof nRet); - return (&aValue == &m_aEmptyValue) ? nRet : (sal_Int32)aValue; -} -// ------------------------------------------------------------------------- - -sal_Int32 SAL_CALL OResultSet::getRow( ) throw(SQLException, RuntimeException) -{ - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - - return m_pSkipDeletedSet ? m_pSkipDeletedSet->getMappedPosition(getDriverPos()) : getDriverPos(); -} -// ------------------------------------------------------------------------- - -sal_Int64 SAL_CALL OResultSet::getLong( sal_Int32 columnIndex ) throw(SQLException, RuntimeException) -{ - sal_Int64 nRet(0); - try - { - const ORowSetValue& aValue = getValue(columnIndex,SQL_C_SBIGINT,&nRet,sizeof nRet); - return (&aValue == &m_aEmptyValue) ? nRet : (sal_Int64)aValue; - } - catch(const SQLException&) - { - nRet = getString(columnIndex).toInt64(); - } - return nRet; -} -// ------------------------------------------------------------------------- - -Reference< XResultSetMetaData > SAL_CALL OResultSet::getMetaData( ) throw(SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::getMetaData" ); - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - - - if(!m_xMetaData.is()) - m_xMetaData = new OResultSetMetaData(m_pStatement->getOwnConnection(),m_aStatementHandle); - return m_xMetaData; -} -// ------------------------------------------------------------------------- -Reference< XArray > SAL_CALL OResultSet::getArray( sal_Int32 /*columnIndex*/ ) throw(SQLException, RuntimeException) -{ - ::dbtools::throwFunctionNotSupportedException( "XRow::getArray", *this ); - return NULL; -} - -// ------------------------------------------------------------------------- - -Reference< XClob > SAL_CALL OResultSet::getClob( sal_Int32 /*columnIndex*/ ) throw(SQLException, RuntimeException) -{ - ::dbtools::throwFunctionNotSupportedException( "XRow::getClob", *this ); - return NULL; -} -// ------------------------------------------------------------------------- -Reference< XBlob > SAL_CALL OResultSet::getBlob( sal_Int32 /*columnIndex*/ ) throw(SQLException, RuntimeException) -{ - ::dbtools::throwFunctionNotSupportedException( "XRow::getBlob", *this ); - return NULL; -} -// ------------------------------------------------------------------------- - -Reference< XRef > SAL_CALL OResultSet::getRef( sal_Int32 /*columnIndex*/ ) throw(SQLException, RuntimeException) -{ - ::dbtools::throwFunctionNotSupportedException( "XRow::getRef", *this ); - return NULL; -} -// ------------------------------------------------------------------------- - -Any SAL_CALL OResultSet::getObject( sal_Int32 columnIndex, const Reference< ::com::sun::star::container::XNameAccess >& /*typeMap*/ ) throw(SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::getObject" ); - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - - fillRow(columnIndex); - return m_aRow[columnIndex].makeAny(); -} -// ------------------------------------------------------------------------- - -sal_Int16 SAL_CALL OResultSet::getShort( sal_Int32 columnIndex ) throw(SQLException, RuntimeException) -{ - sal_Int16 nRet(0); - const ORowSetValue& aValue = getValue(columnIndex,SQL_C_SHORT,&nRet,sizeof nRet); - return (&aValue == &m_aEmptyValue) ? nRet : (sal_Int16)aValue; -} -// ------------------------------------------------------------------------- - - -::rtl::OUString SAL_CALL OResultSet::getString( sal_Int32 columnIndex ) throw(SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::getString" ); - ::osl::MutexGuard aGuard( m_aMutex ); - - ::rtl::OUString nRet; - if ( m_bFetchData ) - nRet = getValue(columnIndex,0,NULL,0); - else - { - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - const SWORD nColumnType = impl_getColumnType_nothrow(columnIndex); - nRet = OTools::getStringValue(m_pStatement->getOwnConnection(),m_aStatementHandle,columnIndex,nColumnType,m_bWasNull,**this,m_nTextEncoding); - } - return nRet; -} -// ------------------------------------------------------------------------- - -Time SAL_CALL OResultSet::getTime( sal_Int32 columnIndex ) throw(SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::getTime" ); - TIME_STRUCT aTime={0,0,0}; - const ORowSetValue& aValue = getValue(columnIndex, - m_pStatement->getOwnConnection()->useOldDateFormat() ? SQL_C_TIME : SQL_C_TYPE_TIME, - &aTime,sizeof aTime); - return (&aValue == &m_aEmptyValue) ? Time(0,aTime.second,aTime.minute,aTime.hour) : (Time)aValue; -} -// ------------------------------------------------------------------------- - - -DateTime SAL_CALL OResultSet::getTimestamp( sal_Int32 columnIndex ) throw(SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::getTimestamp" ); - TIMESTAMP_STRUCT aTime={0,0,0,0,0,0,0}; - const ORowSetValue& aValue = getValue(columnIndex, - m_pStatement->getOwnConnection()->useOldDateFormat() ? SQL_C_TIMESTAMP : SQL_C_TYPE_TIMESTAMP, - &aTime,sizeof aTime); - return (&aValue == &m_aEmptyValue) - ? - DateTime(static_cast<sal_uInt16>(aTime.fraction*1000),aTime.second,aTime.minute,aTime.hour,aTime.day,aTime.month,aTime.year) - : - (DateTime)aValue; -} -// ------------------------------------------------------------------------- - -sal_Bool SAL_CALL OResultSet::isBeforeFirst( ) throw(SQLException, RuntimeException) -{ - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - return m_nRowPos == 0; -} -// ------------------------------------------------------------------------- -sal_Bool SAL_CALL OResultSet::isAfterLast( ) throw(SQLException, RuntimeException) -{ - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - - return m_nRowPos != 0 && m_nCurrentFetchState == SQL_NO_DATA; -} -// ------------------------------------------------------------------------- -sal_Bool SAL_CALL OResultSet::isFirst( ) throw(SQLException, RuntimeException) -{ - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - - return m_nRowPos == 1; -} -// ------------------------------------------------------------------------- -sal_Bool SAL_CALL OResultSet::isLast( ) throw(SQLException, RuntimeException) -{ - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - - - return m_bEOF && m_nCurrentFetchState != SQL_NO_DATA; -} -// ------------------------------------------------------------------------- -void SAL_CALL OResultSet::beforeFirst( ) throw(SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::beforeFirst" ); - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - - - if(first()) - previous(); - m_nCurrentFetchState = SQL_SUCCESS; -} -// ------------------------------------------------------------------------- -void SAL_CALL OResultSet::afterLast( ) throw(SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::afterLast" ); - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - - if(last()) - next(); - m_bEOF = sal_True; -} -// ------------------------------------------------------------------------- - -void SAL_CALL OResultSet::close( ) throw(SQLException, RuntimeException) -{ - { - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - - } - dispose(); -} -// ------------------------------------------------------------------------- - -sal_Bool SAL_CALL OResultSet::first( ) throw(SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::first" ); - return moveImpl(IResultSetHelper::FIRST,0,sal_True); -} -// ------------------------------------------------------------------------- - -sal_Bool SAL_CALL OResultSet::last( ) throw(SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::last" ); - return moveImpl(IResultSetHelper::LAST,0,sal_True); -} -// ------------------------------------------------------------------------- -sal_Bool SAL_CALL OResultSet::absolute( sal_Int32 row ) throw(SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::absolute" ); - return moveImpl(IResultSetHelper::ABSOLUTE,row,sal_True); -} -// ------------------------------------------------------------------------- -sal_Bool SAL_CALL OResultSet::relative( sal_Int32 row ) throw(SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::relative" ); - return moveImpl(IResultSetHelper::RELATIVE,row,sal_True); -} -// ------------------------------------------------------------------------- -sal_Bool SAL_CALL OResultSet::previous( ) throw(SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::previous" ); - return moveImpl(IResultSetHelper::PRIOR,0,sal_True); -} -// ------------------------------------------------------------------------- -Reference< XInterface > SAL_CALL OResultSet::getStatement( ) throw(SQLException, RuntimeException) -{ - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - return m_xStatement; -} -// ------------------------------------------------------------------------- - -sal_Bool SAL_CALL OResultSet::rowDeleted() throw(SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::rowDeleted" ); - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - - sal_Bool bRet = m_bRowDeleted; - m_bRowDeleted = sal_False; - - return bRet; -} -// ------------------------------------------------------------------------- -sal_Bool SAL_CALL OResultSet::rowInserted( ) throw(SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::rowInserted" ); - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - - sal_Bool bInserted = m_bRowInserted; - m_bRowInserted = sal_False; - - return bInserted; -} -// ------------------------------------------------------------------------- -sal_Bool SAL_CALL OResultSet::rowUpdated( ) throw(SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::rowUpdated" ); - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - - - return m_pRowStatusArray[0] == SQL_ROW_UPDATED; -} -// ------------------------------------------------------------------------- - -sal_Bool SAL_CALL OResultSet::next( ) throw(SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::next" ); - return moveImpl(IResultSetHelper::NEXT,1,sal_True); -} -// ------------------------------------------------------------------------- - -sal_Bool SAL_CALL OResultSet::wasNull( ) throw(SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::wasNull" ); - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - - - return m_bFetchData ? m_aRow[m_nLastColumnPos].isNull() : m_bWasNull; -} -// ------------------------------------------------------------------------- - -void SAL_CALL OResultSet::cancel( ) throw(RuntimeException) -{ - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - - - OTools::ThrowException(m_pStatement->getOwnConnection(),N3SQLCancel(m_aStatementHandle),m_aStatementHandle,SQL_HANDLE_STMT,*this); -} -// ------------------------------------------------------------------------- -void SAL_CALL OResultSet::clearWarnings( ) throw(SQLException, RuntimeException) -{ -} -// ------------------------------------------------------------------------- -Any SAL_CALL OResultSet::getWarnings( ) throw(SQLException, RuntimeException) -{ - return Any(); -} -// ------------------------------------------------------------------------- -void SAL_CALL OResultSet::insertRow( ) throw(SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::insertRow" ); - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - - - SQLLEN nMaxLen = 20; - SQLLEN nRealLen = 0; - Sequence<sal_Int8> aBookmark(nMaxLen); - - SQLRETURN nRet = N3SQLBindCol(m_aStatementHandle, - 0, - SQL_C_VARBOOKMARK, - aBookmark.getArray(), - nMaxLen, - &nRealLen - ); - // Sequence<sal_Int8> aRealBookmark(nMaxLen); - - sal_Bool bPositionByBookmark = ( NULL != getOdbcFunction( ODBC3SQLBulkOperations ) ); - if ( bPositionByBookmark ) - { - nRet = N3SQLBulkOperations( m_aStatementHandle, SQL_ADD ); - fillNeededData( nRet ); - } - else - { - if(isBeforeFirst()) - next(); // must be done - nRet = N3SQLSetPos( m_aStatementHandle, 1, SQL_ADD, SQL_LOCK_NO_CHANGE ); - fillNeededData( nRet ); - } - try - { - OTools::ThrowException(m_pStatement->getOwnConnection(),nRet,m_aStatementHandle,SQL_HANDLE_STMT,*this); - } - catch(const SQLException&) - { - nRet = unbind(); - throw; - } - - - if ( bPositionByBookmark ) - { - nRet = N3SQLSetStmtAttr(m_aStatementHandle,SQL_ATTR_FETCH_BOOKMARK_PTR,aBookmark.getArray(),SQL_IS_POINTER); // SQL_LEN_BINARY_ATTR(aBookmark.getLength()) - - nRet = N3SQLFetchScroll(m_aStatementHandle,SQL_FETCH_BOOKMARK,0); - } - else - nRet = N3SQLFetchScroll(m_aStatementHandle,SQL_FETCH_RELATIVE,0); // OJ 06.03.2004 - // sometimes we got an error but we are not interested in anymore #106047# OJ - // OTools::ThrowException(m_pStatement->getOwnConnection(),nRet,m_aStatementHandle,SQL_HANDLE_STMT,*this); - nRet = unbind(); - OTools::ThrowException(m_pStatement->getOwnConnection(),nRet,m_aStatementHandle,SQL_HANDLE_STMT,*this); - - if(m_pSkipDeletedSet) - { - aBookmark.realloc(nRealLen); - if(moveToBookmark(makeAny(aBookmark))) - { - sal_Int32 nRowPos = getDriverPos(); - if ( -1 == m_nRowPos ) - { - nRowPos = m_aPosToBookmarks.size() + 1; - } - if ( nRowPos == m_nRowPos ) - ++nRowPos; - m_nRowPos = nRowPos; - m_pSkipDeletedSet->insertNewPosition(nRowPos); - m_aPosToBookmarks[aBookmark] = nRowPos; - } - } - m_bRowInserted = sal_True; - -} -// ------------------------------------------------------------------------- -void SAL_CALL OResultSet::updateRow( ) throw(SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::updateRow" ); - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - - SQLRETURN nRet; - - sal_Bool bPositionByBookmark = ( NULL != getOdbcFunction( ODBC3SQLBulkOperations ) ); - if ( bPositionByBookmark ) - { - SQLLEN nRealLen = 0; - nRet = N3SQLBindCol(m_aStatementHandle, - 0, - SQL_C_VARBOOKMARK, - m_aBookmark.getArray(), - m_aBookmark.getLength(), - &nRealLen - ); - fillNeededData(nRet = N3SQLBulkOperations(m_aStatementHandle, SQL_UPDATE_BY_BOOKMARK)); - } - else - fillNeededData(nRet = N3SQLSetPos(m_aStatementHandle,1,SQL_UPDATE,SQL_LOCK_NO_CHANGE)); - OTools::ThrowException(m_pStatement->getOwnConnection(),nRet,m_aStatementHandle,SQL_HANDLE_STMT,*this); - // now unbind all columns so we can fetch all columns again with SQLGetData - nRet = unbind(); - OSL_ENSURE(nRet == SQL_SUCCESS,"Could not unbind the columns!"); -} -// ------------------------------------------------------------------------- -void SAL_CALL OResultSet::deleteRow( ) throw(SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::deleteRow" ); - SQLRETURN nRet = SQL_SUCCESS; - sal_Int32 nPos = getDriverPos(); - nRet = N3SQLSetPos(m_aStatementHandle,1,SQL_DELETE,SQL_LOCK_NO_CHANGE); - OTools::ThrowException(m_pStatement->getOwnConnection(),nRet,m_aStatementHandle,SQL_HANDLE_STMT,*this); - - m_bRowDeleted = ( m_pRowStatusArray[0] == SQL_ROW_DELETED ); - if ( m_bRowDeleted ) - { - TBookmarkPosMap::iterator aIter = m_aPosToBookmarks.begin(); - TBookmarkPosMap::iterator aEnd = m_aPosToBookmarks.end(); - for (; aIter != aEnd; ++aIter) - { - if ( aIter->second == nPos ) - { - m_aPosToBookmarks.erase(aIter); - break; - } - } - } - if ( m_pSkipDeletedSet ) - m_pSkipDeletedSet->deletePosition(nPos); -} -// ------------------------------------------------------------------------- - -void SAL_CALL OResultSet::cancelRowUpdates( ) throw(SQLException, RuntimeException) -{ -} -// ------------------------------------------------------------------------- - -void SAL_CALL OResultSet::moveToInsertRow( ) throw(SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::moveToInsertRow" ); - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - - - m_nLastColumnPos = 0; - // first unbound all columns - OSL_VERIFY_EQUALS( unbind(), SQL_SUCCESS, "Could not unbind columns!" ); - // SQLRETURN nRet = N3SQLSetStmtAttr(m_aStatementHandle,SQL_ATTR_ROW_ARRAY_SIZE ,(SQLPOINTER)1,SQL_IS_INTEGER); - m_bInserting = sal_True; -} -// ------------------------------------------------------------------------- - -void SAL_CALL OResultSet::moveToCurrentRow( ) throw(SQLException, RuntimeException) -{ - m_nLastColumnPos = 0; -} -// ------------------------------------------------------------------------- -void OResultSet::updateValue(sal_Int32 columnIndex,SQLSMALLINT _nType,void* _pValue) throw(SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::updateValue" ); - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - - m_aBindVector.push_back(allocBindColumn(OTools::MapOdbcType2Jdbc(_nType),columnIndex)); - void* pData = reinterpret_cast<void*>(m_aBindVector.rbegin()->first); - OSL_ENSURE(pData != NULL,"Data for update is NULL!"); - OTools::bindValue( m_pStatement->getOwnConnection(), - m_aStatementHandle, - columnIndex, - _nType, - 0, - _pValue, - pData, - &m_aLengthVector[columnIndex], - **this, - m_nTextEncoding, - m_pStatement->getOwnConnection()->useOldDateFormat()); -} -// ----------------------------------------------------------------------------- -void SAL_CALL OResultSet::updateNull( sal_Int32 columnIndex ) throw(SQLException, RuntimeException) -{ - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - - m_aBindVector.push_back(allocBindColumn(DataType::CHAR,columnIndex)); - void* pData = reinterpret_cast<void*>(m_aBindVector.rbegin()->first); - OTools::bindValue(m_pStatement->getOwnConnection(),m_aStatementHandle,columnIndex,SQL_CHAR,0,(sal_Int8*)NULL,pData,&m_aLengthVector[columnIndex],**this,m_nTextEncoding,m_pStatement->getOwnConnection()->useOldDateFormat()); -} -// ------------------------------------------------------------------------- - -void SAL_CALL OResultSet::updateBoolean( sal_Int32 columnIndex, sal_Bool x ) throw(SQLException, RuntimeException) -{ - updateValue(columnIndex,SQL_BIT,&x); -} -// ------------------------------------------------------------------------- -void SAL_CALL OResultSet::updateByte( sal_Int32 columnIndex, sal_Int8 x ) throw(SQLException, RuntimeException) -{ - updateValue(columnIndex,SQL_CHAR,&x); -} -// ------------------------------------------------------------------------- - -void SAL_CALL OResultSet::updateShort( sal_Int32 columnIndex, sal_Int16 x ) throw(SQLException, RuntimeException) -{ - updateValue(columnIndex,SQL_TINYINT,&x); -} -// ------------------------------------------------------------------------- -void SAL_CALL OResultSet::updateInt( sal_Int32 columnIndex, sal_Int32 x ) throw(SQLException, RuntimeException) -{ - updateValue(columnIndex,SQL_INTEGER,&x); -} -// ------------------------------------------------------------------------- -void SAL_CALL OResultSet::updateLong( sal_Int32 /*columnIndex*/, sal_Int64 /*x*/ ) throw(SQLException, RuntimeException) -{ - ::dbtools::throwFunctionNotSupportedException( "XRowUpdate::updateLong", *this ); -} -// ----------------------------------------------------------------------- -void SAL_CALL OResultSet::updateFloat( sal_Int32 columnIndex, float x ) throw(SQLException, RuntimeException) -{ - updateValue(columnIndex,SQL_REAL,&x); -} -// ------------------------------------------------------------------------- - -void SAL_CALL OResultSet::updateDouble( sal_Int32 columnIndex, double x ) throw(SQLException, RuntimeException) -{ - updateValue(columnIndex,SQL_DOUBLE,&x); -} -// ------------------------------------------------------------------------- -void SAL_CALL OResultSet::updateString( sal_Int32 columnIndex, const ::rtl::OUString& x ) throw(SQLException, RuntimeException) -{ - sal_Int32 nType = m_aRow[columnIndex].getTypeKind(); - SQLSMALLINT nOdbcType = static_cast<SQLSMALLINT>(OTools::jdbcTypeToOdbc(nType)); - m_aRow[columnIndex] = x; - m_aRow[columnIndex].setTypeKind(nType); // OJ: otherwise longvarchar will be recognized by fillNeededData - updateValue(columnIndex,nOdbcType,(void*)&x); -} -// ------------------------------------------------------------------------- -void SAL_CALL OResultSet::updateBytes( sal_Int32 columnIndex, const Sequence< sal_Int8 >& x ) throw(SQLException, RuntimeException) -{ - sal_Int32 nType = m_aRow[columnIndex].getTypeKind(); - SQLSMALLINT nOdbcType = static_cast<SQLSMALLINT>(OTools::jdbcTypeToOdbc(nType)); - m_aRow[columnIndex] = x; - m_aRow[columnIndex].setTypeKind(nType); // OJ: otherwise longvarbinary will be recognized by fillNeededData - updateValue(columnIndex,nOdbcType,(void*)&x); -} -// ------------------------------------------------------------------------- -void SAL_CALL OResultSet::updateDate( sal_Int32 columnIndex, const Date& x ) throw(SQLException, RuntimeException) -{ - DATE_STRUCT aVal = OTools::DateToOdbcDate(x); - updateValue(columnIndex,SQL_DATE,&aVal); -} -// ------------------------------------------------------------------------- - -void SAL_CALL OResultSet::updateTime( sal_Int32 columnIndex, const Time& x ) throw(SQLException, RuntimeException) -{ - TIME_STRUCT aVal = OTools::TimeToOdbcTime(x); - updateValue(columnIndex,SQL_TIME,&aVal); -} -// ------------------------------------------------------------------------- - -void SAL_CALL OResultSet::updateTimestamp( sal_Int32 columnIndex, const DateTime& x ) throw(SQLException, RuntimeException) -{ - TIMESTAMP_STRUCT aVal = OTools::DateTimeToTimestamp(x); - updateValue(columnIndex,SQL_TIMESTAMP,&aVal); -} -// ------------------------------------------------------------------------- - -void SAL_CALL OResultSet::updateBinaryStream( sal_Int32 columnIndex, const Reference< XInputStream >& x, sal_Int32 length ) throw(SQLException, RuntimeException) -{ - if(!x.is()) - ::dbtools::throwFunctionSequenceException(*this); - - Sequence<sal_Int8> aSeq; - x->readBytes(aSeq,length); - updateBytes(columnIndex,aSeq); -} -// ------------------------------------------------------------------------- -void SAL_CALL OResultSet::updateCharacterStream( sal_Int32 columnIndex, const Reference< XInputStream >& x, sal_Int32 length ) throw(SQLException, RuntimeException) -{ - updateBinaryStream(columnIndex,x,length); -} -// ------------------------------------------------------------------------- -void SAL_CALL OResultSet::refreshRow( ) throw(SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::refreshRow" ); - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - - - // SQLRETURN nRet = N3SQLSetPos(m_aStatementHandle,1,SQL_REFRESH,SQL_LOCK_NO_CHANGE); - m_nCurrentFetchState = N3SQLFetchScroll(m_aStatementHandle,SQL_FETCH_RELATIVE,0); - OTools::ThrowException(m_pStatement->getOwnConnection(),m_nCurrentFetchState,m_aStatementHandle,SQL_HANDLE_STMT,*this); -} -// ------------------------------------------------------------------------- -void SAL_CALL OResultSet::updateObject( sal_Int32 columnIndex, const Any& x ) throw(SQLException, RuntimeException) -{ - if (!::dbtools::implUpdateObject(this, columnIndex, x)) - throw SQLException(); -} -// ------------------------------------------------------------------------- - -void SAL_CALL OResultSet::updateNumericObject( sal_Int32 columnIndex, const Any& x, sal_Int32 /*scale*/ ) throw(SQLException, RuntimeException) -{ - if (!::dbtools::implUpdateObject(this, columnIndex, x)) - throw SQLException(); -} -// ------------------------------------------------------------------------- -// XRowLocate -Any SAL_CALL OResultSet::getBookmark( ) throw( SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::getBookmark" ); - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - - TBookmarkPosMap::iterator aFind = ::std::find_if(m_aPosToBookmarks.begin(),m_aPosToBookmarks.end(), - ::o3tl::compose1(::std::bind2nd(::std::equal_to<sal_Int32>(),m_nRowPos),::o3tl::select2nd<TBookmarkPosMap::value_type>())); - - if ( aFind == m_aPosToBookmarks.end() ) - { - if ( m_nUseBookmarks == ODBC_SQL_NOT_DEFINED ) - { - RTL_LOGFILE_CONTEXT_TRACE( aLogger, "SQLGetStmtAttr" ); - m_nUseBookmarks = SQL_UB_OFF; - SQLRETURN nRet = N3SQLGetStmtAttr(m_aStatementHandle,SQL_ATTR_USE_BOOKMARKS,&m_nUseBookmarks,SQL_IS_UINTEGER,NULL); - OSL_UNUSED( nRet ); - } - if(m_nUseBookmarks == SQL_UB_OFF) - throw SQLException(); - - m_aBookmark = OTools::getBytesValue(m_pStatement->getOwnConnection(),m_aStatementHandle,0,SQL_C_VARBOOKMARK,m_bWasNull,**this); - m_aPosToBookmarks[m_aBookmark] = m_nRowPos; - OSL_ENSURE(m_aBookmark.getLength(),"Invalid bookmark from length 0!"); - } - else - m_aBookmark = aFind->first; - return makeAny(m_aBookmark); -} -// ------------------------------------------------------------------------- -sal_Bool SAL_CALL OResultSet::moveToBookmark( const Any& bookmark ) throw( SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::moveToBookmark" ); - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - - m_nLastColumnPos = 0; - bookmark >>= m_aBookmark; - OSL_ENSURE(m_aBookmark.getLength(),"Invalid bookmark from length 0!"); - if(m_aBookmark.getLength()) - { - SQLRETURN nReturn = N3SQLSetStmtAttr(m_aStatementHandle,SQL_ATTR_FETCH_BOOKMARK_PTR,m_aBookmark.getArray(),SQL_IS_POINTER); // SQL_LEN_BINARY_ATTR(aBookmark.getLength()) - OSL_UNUSED( nReturn ); - - if ( SQL_INVALID_HANDLE != nReturn && SQL_ERROR != nReturn ) - { - m_nCurrentFetchState = N3SQLFetchScroll(m_aStatementHandle,SQL_FETCH_BOOKMARK,0); - OTools::ThrowException(m_pStatement->getOwnConnection(),m_nCurrentFetchState,m_aStatementHandle,SQL_HANDLE_STMT,*this); - TBookmarkPosMap::iterator aFind = m_aPosToBookmarks.find(m_aBookmark); - if(aFind != m_aPosToBookmarks.end()) - m_nRowPos = aFind->second; - else - m_nRowPos = -1; - return m_nCurrentFetchState == SQL_SUCCESS || m_nCurrentFetchState == SQL_SUCCESS_WITH_INFO; - } - } - return sal_False; -} -// ------------------------------------------------------------------------- -sal_Bool SAL_CALL OResultSet::moveRelativeToBookmark( const Any& bookmark, sal_Int32 rows ) throw( SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::moveRelativeToBookmark" ); - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - - - m_nLastColumnPos = 0; - bookmark >>= m_aBookmark; - SQLRETURN nReturn = N3SQLSetStmtAttr(m_aStatementHandle,SQL_ATTR_FETCH_BOOKMARK_PTR,m_aBookmark.getArray(),SQL_IS_POINTER); - OSL_UNUSED( nReturn ); - - m_nCurrentFetchState = N3SQLFetchScroll(m_aStatementHandle,SQL_FETCH_BOOKMARK,rows); - OTools::ThrowException(m_pStatement->getOwnConnection(),m_nCurrentFetchState,m_aStatementHandle,SQL_HANDLE_STMT,*this); - return m_nCurrentFetchState == SQL_SUCCESS || m_nCurrentFetchState == SQL_SUCCESS_WITH_INFO; -} -// ------------------------------------------------------------------------- -sal_Int32 SAL_CALL OResultSet::compareBookmarks( const Any& lhs, const Any& rhs ) throw( SQLException, RuntimeException) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::compareBookmarks" ); - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - - return (lhs == rhs) ? CompareBookmark::EQUAL : CompareBookmark::NOT_EQUAL; -} -// ------------------------------------------------------------------------- -sal_Bool SAL_CALL OResultSet::hasOrderedBookmarks( ) throw( SQLException, RuntimeException) -{ - return sal_False; -} -// ------------------------------------------------------------------------- -sal_Int32 SAL_CALL OResultSet::hashBookmark( const Any& /*bookmark*/ ) throw( SQLException, RuntimeException) -{ - ::dbtools::throwFunctionNotSupportedException( "XRowLocate::hashBookmark", *this ); - return 0; -} -// ------------------------------------------------------------------------- -// XDeleteRows -Sequence< sal_Int32 > SAL_CALL OResultSet::deleteRows( const Sequence< Any >& rows ) throw( SQLException, RuntimeException) -{ - Sequence< sal_Int32 > aRet(rows.getLength()); - sal_Int32 *pRet = aRet.getArray(); - - const Any *pBegin = rows.getConstArray(); - const Any *pEnd = pBegin + rows.getLength(); - - for(;pBegin != pEnd;++pBegin,++pRet) - { - try - { - if(moveToBookmark(*pBegin)) - { - deleteRow(); - *pRet = 1; - } - } - catch(const SQLException&) - { - *pRet = 0; - } - } - return aRet; -} -//------------------------------------------------------------------------------ -sal_Int32 OResultSet::getResultSetConcurrency() const -{ - sal_uInt32 nValue = 0; - SQLRETURN nReturn = N3SQLGetStmtAttr(m_aStatementHandle,SQL_ATTR_CONCURRENCY,&nValue,SQL_IS_UINTEGER,0); - OSL_UNUSED( nReturn ); - if(SQL_CONCUR_READ_ONLY == nValue) - nValue = ResultSetConcurrency::READ_ONLY; - else - nValue = ResultSetConcurrency::UPDATABLE; - - return nValue; -} -//------------------------------------------------------------------------------ -sal_Int32 OResultSet::getResultSetType() const -{ - sal_uInt32 nValue = 0; - N3SQLGetStmtAttr(m_aStatementHandle,SQL_ATTR_CURSOR_SENSITIVITY,&nValue,SQL_IS_UINTEGER,0); - if(SQL_SENSITIVE == nValue) - nValue = ResultSetType::SCROLL_SENSITIVE; - else if(SQL_INSENSITIVE == nValue) - nValue = ResultSetType::SCROLL_INSENSITIVE; - else - { - SQLINTEGER nCurType = 0; - N3SQLGetStmtAttr(m_aStatementHandle,SQL_ATTR_CURSOR_TYPE,&nCurType,SQL_IS_UINTEGER,0); - if(SQL_CURSOR_KEYSET_DRIVEN == nCurType) - nValue = ResultSetType::SCROLL_SENSITIVE; - else if(SQL_CURSOR_STATIC == nCurType) - nValue = ResultSetType::SCROLL_INSENSITIVE; - else if(SQL_CURSOR_FORWARD_ONLY == nCurType) - nValue = ResultSetType::FORWARD_ONLY; - else if(SQL_CURSOR_DYNAMIC == nCurType) - nValue = ResultSetType::SCROLL_SENSITIVE; - } - return nValue; -} -//------------------------------------------------------------------------------ -sal_Int32 OResultSet::getFetchDirection() const -{ - return FetchDirection::FORWARD; -} -//------------------------------------------------------------------------------ -sal_Int32 OResultSet::getFetchSize() const -{ - sal_uInt32 nValue = 0; - N3SQLGetStmtAttr(m_aStatementHandle,SQL_ATTR_ROW_ARRAY_SIZE,&nValue,SQL_IS_UINTEGER,0); - return nValue; -} -//------------------------------------------------------------------------------ -::rtl::OUString OResultSet::getCursorName() const -{ - SQLCHAR pName[258]; - SQLSMALLINT nRealLen = 0; - N3SQLGetCursorName(m_aStatementHandle,(SQLCHAR*)pName,256,&nRealLen); - return ::rtl::OUString::createFromAscii((const char*)pName); -} -// ------------------------------------------------------------------------- -sal_Bool OResultSet::isBookmarkable() const -{ - if(!m_aConnectionHandle) - return sal_False; - - sal_uInt32 nValue = 0; - N3SQLGetStmtAttr(m_aStatementHandle,SQL_ATTR_CURSOR_TYPE,&nValue,SQL_IS_UINTEGER,0); - - sal_Int32 nAttr = 0; - try - { - switch(nValue) - { - case SQL_CURSOR_FORWARD_ONLY: - return sal_False; - case SQL_CURSOR_STATIC: - OTools::GetInfo(m_pStatement->getOwnConnection(),m_aConnectionHandle,SQL_STATIC_CURSOR_ATTRIBUTES1,nAttr,NULL); - break; - case SQL_CURSOR_KEYSET_DRIVEN: - OTools::GetInfo(m_pStatement->getOwnConnection(),m_aConnectionHandle,SQL_KEYSET_CURSOR_ATTRIBUTES1,nAttr,NULL); - break; - case SQL_CURSOR_DYNAMIC: - OTools::GetInfo(m_pStatement->getOwnConnection(),m_aConnectionHandle,SQL_DYNAMIC_CURSOR_ATTRIBUTES1,nAttr,NULL); - break; - } - } - catch(const Exception&) - { - return sal_False; - } - - if ( m_nUseBookmarks == ODBC_SQL_NOT_DEFINED ) - { - m_nUseBookmarks = SQL_UB_OFF; - SQLRETURN nRet = N3SQLGetStmtAttr(m_aStatementHandle,SQL_ATTR_USE_BOOKMARKS,&m_nUseBookmarks,SQL_IS_UINTEGER,NULL); - OSL_UNUSED( nRet ); - } - - return (m_nUseBookmarks != SQL_UB_OFF) && (nAttr & SQL_CA1_BOOKMARK) == SQL_CA1_BOOKMARK; -} -//------------------------------------------------------------------------------ -void OResultSet::setFetchDirection(sal_Int32 _par0) -{ - OSL_ENSURE(_par0>0,"Illegal fetch direction!"); - if ( _par0 > 0 ) - { - N3SQLSetStmtAttr(m_aStatementHandle,SQL_ATTR_CURSOR_TYPE,(SQLPOINTER)(sal_IntPtr)_par0,SQL_IS_UINTEGER); - } -} -//------------------------------------------------------------------------------ -void OResultSet::setFetchSize(sal_Int32 _par0) -{ - OSL_ENSURE(_par0>0,"Illegal fetch size!"); - if ( _par0 > 0 ) - { - N3SQLSetStmtAttr(m_aStatementHandle,SQL_ATTR_ROW_ARRAY_SIZE,(SQLPOINTER)(sal_IntPtr)_par0,SQL_IS_UINTEGER); - delete [] m_pRowStatusArray; - - m_pRowStatusArray = new SQLUSMALLINT[_par0]; - N3SQLSetStmtAttr(m_aStatementHandle,SQL_ATTR_ROW_STATUS_PTR,m_pRowStatusArray,SQL_IS_POINTER); - } -} -// ------------------------------------------------------------------------- -IPropertyArrayHelper* OResultSet::createArrayHelper( ) const -{ - Sequence< Property > aProps(6); - Property* pProperties = aProps.getArray(); - sal_Int32 nPos = 0; - DECL_PROP1IMPL(CURSORNAME, ::rtl::OUString) PropertyAttribute::READONLY); - DECL_PROP0(FETCHDIRECTION, sal_Int32); - DECL_PROP0(FETCHSIZE, sal_Int32); - DECL_BOOL_PROP1IMPL(ISBOOKMARKABLE) PropertyAttribute::READONLY); - DECL_PROP1IMPL(RESULTSETCONCURRENCY,sal_Int32) PropertyAttribute::READONLY); - DECL_PROP1IMPL(RESULTSETTYPE, sal_Int32) PropertyAttribute::READONLY); - - return new OPropertyArrayHelper(aProps); -} -// ------------------------------------------------------------------------- -IPropertyArrayHelper & OResultSet::getInfoHelper() -{ - return *const_cast<OResultSet*>(this)->getArrayHelper(); -} -// ------------------------------------------------------------------------- -sal_Bool OResultSet::convertFastPropertyValue( - Any & rConvertedValue, - Any & rOldValue, - sal_Int32 nHandle, - const Any& rValue ) - throw (::com::sun::star::lang::IllegalArgumentException) -{ - switch(nHandle) - { - case PROPERTY_ID_ISBOOKMARKABLE: - case PROPERTY_ID_CURSORNAME: - case PROPERTY_ID_RESULTSETCONCURRENCY: - case PROPERTY_ID_RESULTSETTYPE: - throw ::com::sun::star::lang::IllegalArgumentException(); - case PROPERTY_ID_FETCHDIRECTION: - return ::comphelper::tryPropertyValue(rConvertedValue, rOldValue, rValue, getFetchDirection()); - case PROPERTY_ID_FETCHSIZE: - return ::comphelper::tryPropertyValue(rConvertedValue, rOldValue, rValue, getFetchSize()); - default: - ; - } - return sal_False; -} -// ------------------------------------------------------------------------- -void OResultSet::setFastPropertyValue_NoBroadcast( - sal_Int32 nHandle, - const Any& rValue - ) - throw (Exception) -{ - switch(nHandle) - { - case PROPERTY_ID_ISBOOKMARKABLE: - case PROPERTY_ID_CURSORNAME: - case PROPERTY_ID_RESULTSETCONCURRENCY: - case PROPERTY_ID_RESULTSETTYPE: - throw Exception(); - case PROPERTY_ID_FETCHDIRECTION: - setFetchDirection(getINT32(rValue)); - break; - case PROPERTY_ID_FETCHSIZE: - setFetchSize(getINT32(rValue)); - break; - default: - ; - } -} -// ------------------------------------------------------------------------- -void OResultSet::getFastPropertyValue( - Any& rValue, - sal_Int32 nHandle - ) const -{ - switch(nHandle) - { - case PROPERTY_ID_ISBOOKMARKABLE: - rValue = bool2any(isBookmarkable()); - break; - case PROPERTY_ID_CURSORNAME: - rValue <<= getCursorName(); - break; - case PROPERTY_ID_RESULTSETCONCURRENCY: - rValue <<= getResultSetConcurrency(); - break; - case PROPERTY_ID_RESULTSETTYPE: - rValue <<= getResultSetType(); - break; - case PROPERTY_ID_FETCHDIRECTION: - rValue <<= getFetchDirection(); - break; - case PROPERTY_ID_FETCHSIZE: - rValue <<= getFetchSize(); - break; - } -} -// ------------------------------------------------------------------------- -void OResultSet::fillRow(sal_Int32 _nToColumn) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::fillRow" ); - if((sal_Int32)m_aRow.size() <= _nToColumn) - { - m_aRow.resize(_nToColumn+1); - m_aRow[_nToColumn].setBound(sal_True); - } - m_bFetchData = sal_False; - - sal_Int32 nColumn = m_nLastColumnPos + 1; - TDataRow::iterator pColumn = m_aRow.begin() + nColumn; - TDataRow::iterator pColumnEnd = m_aRow.begin() + _nToColumn + 1; - - for (; pColumn < pColumnEnd; ++nColumn, ++pColumn) - { - const sal_Int32 nType = pColumn->getTypeKind(); - switch (nType) - { - case DataType::CHAR: - case DataType::VARCHAR: - case DataType::DECIMAL: - case DataType::NUMERIC: - case DataType::LONGVARCHAR: - case DataType::CLOB: - { - const SWORD nColumnType = impl_getColumnType_nothrow(nColumn); - *pColumn = OTools::getStringValue(m_pStatement->getOwnConnection(),m_aStatementHandle,nColumn,nColumnType,m_bWasNull,**this,m_nTextEncoding); - } - break; - case DataType::BIGINT: - *pColumn = getLong(nColumn); - break; - case DataType::REAL: - case DataType::DOUBLE: - *pColumn = getDouble(nColumn); - break; - case DataType::LONGVARBINARY: - case DataType::BLOB: - *pColumn = getBytes(nColumn); - break; - case DataType::DATE: - *pColumn = getDate(nColumn); - break; - case DataType::TIME: - *pColumn = getTime(nColumn); - break; - case DataType::TIMESTAMP: - *pColumn = getTimestamp(nColumn); - break; - case DataType::BIT: - *pColumn = getBoolean(nColumn); - break; - case DataType::TINYINT: - *pColumn = getByte(nColumn); - break; - case DataType::SMALLINT: - *pColumn = getShort(nColumn); - break; - case DataType::INTEGER: - *pColumn = getInt(nColumn); - break; - case DataType::FLOAT: - *pColumn = getFloat(nColumn); - break; - case DataType::BINARY: - case DataType::VARBINARY: - *pColumn = getBytes(nColumn); - break; - } - - if ( m_bWasNull ) - pColumn->setNull(); - if(nType != pColumn->getTypeKind()) - { - pColumn->setTypeKind(nType); - } - } - m_nLastColumnPos = _nToColumn; - m_bFetchData = sal_True; -} -// ----------------------------------------------------------------------------- -void SAL_CALL OResultSet::acquire() throw() -{ - OResultSet_BASE::acquire(); -} -// ----------------------------------------------------------------------------- -void SAL_CALL OResultSet::release() throw() -{ - OResultSet_BASE::release(); -} -// ----------------------------------------------------------------------------- -::com::sun::star::uno::Reference< ::com::sun::star::beans::XPropertySetInfo > SAL_CALL OResultSet::getPropertySetInfo( ) throw(::com::sun::star::uno::RuntimeException) -{ - return ::cppu::OPropertySetHelper::createPropertySetInfo(getInfoHelper()); -} -// ----------------------------------------------------------------------------- -sal_Bool OResultSet::move(IResultSetHelper::Movement _eCursorPosition, sal_Int32 _nOffset, sal_Bool /*_bRetrieveData*/) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::move" ); - SQLSMALLINT nFetchOrientation = SQL_FETCH_NEXT; - switch(_eCursorPosition) - { - case IResultSetHelper::NEXT: - nFetchOrientation = SQL_FETCH_NEXT; - break; - case IResultSetHelper::PRIOR: - nFetchOrientation = SQL_FETCH_PRIOR; - break; - case IResultSetHelper::FIRST: - nFetchOrientation = SQL_FETCH_FIRST; - break; - case IResultSetHelper::LAST: - nFetchOrientation = SQL_FETCH_LAST; - break; - case IResultSetHelper::RELATIVE: - nFetchOrientation = SQL_FETCH_RELATIVE; - break; - case IResultSetHelper::ABSOLUTE: - nFetchOrientation = SQL_FETCH_ABSOLUTE; - break; - case IResultSetHelper::BOOKMARK: // special case here because we are only called with position numbers - { - TBookmarkPosMap::iterator aIter = m_aPosToBookmarks.begin(); - TBookmarkPosMap::iterator aEnd = m_aPosToBookmarks.end(); - for (; aIter != aEnd; ++aIter) - { - if ( aIter->second == _nOffset ) - return moveToBookmark(makeAny(aIter->first)); - } - OSL_FAIL("Bookmark not found!"); - } - return sal_False; - } - - m_bEOF = sal_False; - m_nLastColumnPos = 0; - - SQLRETURN nOldFetchStatus = m_nCurrentFetchState; - if ( !m_bUseFetchScroll && _eCursorPosition == IResultSetHelper::NEXT ) - m_nCurrentFetchState = N3SQLFetch(m_aStatementHandle); - else - m_nCurrentFetchState = N3SQLFetchScroll(m_aStatementHandle,nFetchOrientation,_nOffset); - - OSL_TRACE( __FILE__": OSkipDeletedSet::OResultSet::move(%d,%d), FetchState = %d",nFetchOrientation,_nOffset,m_nCurrentFetchState); - OTools::ThrowException(m_pStatement->getOwnConnection(),m_nCurrentFetchState,m_aStatementHandle,SQL_HANDLE_STMT,*this); - - const bool bSuccess = m_nCurrentFetchState == SQL_SUCCESS || m_nCurrentFetchState == SQL_SUCCESS_WITH_INFO; - if ( bSuccess ) - { - switch(_eCursorPosition) - { - case IResultSetHelper::NEXT: - ++m_nRowPos; - break; - case IResultSetHelper::PRIOR: - --m_nRowPos; - break; - case IResultSetHelper::FIRST: - m_nRowPos = 1; - break; - case IResultSetHelper::LAST: - m_bEOF = sal_True; - break; - case IResultSetHelper::RELATIVE: - m_nRowPos += _nOffset; - break; - case IResultSetHelper::ABSOLUTE: - case IResultSetHelper::BOOKMARK: // special case here because we are only called with position numbers - m_nRowPos = _nOffset; - break; - } // switch(_eCursorPosition) - if ( m_nUseBookmarks == ODBC_SQL_NOT_DEFINED ) - { - RTL_LOGFILE_CONTEXT_TRACE( aLogger, "SQLGetStmtAttr" ); - m_nUseBookmarks = SQL_UB_OFF; - SQLRETURN nRet = N3SQLGetStmtAttr(m_aStatementHandle,SQL_ATTR_USE_BOOKMARKS,&m_nUseBookmarks,SQL_IS_UINTEGER,NULL); - OSL_UNUSED( nRet ); - } - if ( m_nUseBookmarks != SQL_UB_OFF ) - { - RTL_LOGFILE_CONTEXT_TRACE( aLogger, "OTools::getBytesValue" ); - m_aBookmark = OTools::getBytesValue(m_pStatement->getOwnConnection(),m_aStatementHandle,0,SQL_C_VARBOOKMARK,m_bWasNull,**this); - m_aPosToBookmarks[m_aBookmark] = m_nRowPos; - OSL_ENSURE(m_aBookmark.getLength(),"Invalid bookmark from length 0!"); - } - } - else if ( IResultSetHelper::PRIOR == _eCursorPosition && m_nCurrentFetchState == SQL_NO_DATA ) - m_nRowPos = 0; - else if(IResultSetHelper::NEXT == _eCursorPosition && m_nCurrentFetchState == SQL_NO_DATA && nOldFetchStatus != SQL_NO_DATA) - ++m_nRowPos; - - return bSuccess; -} -// ----------------------------------------------------------------------------- -sal_Int32 OResultSet::getDriverPos() const -{ - sal_Int32 nValue = 0; - SQLRETURN nRet = N3SQLGetStmtAttr(m_aStatementHandle,SQL_ATTR_ROW_NUMBER,&nValue,SQL_IS_UINTEGER,0); - OSL_UNUSED( nRet ); - OSL_TRACE( __FILE__": OResultSet::getDriverPos() = Ret = %d, RowNum = %d, RowPos = %d",nRet,nValue , m_nRowPos); - return nValue ? nValue : m_nRowPos; -} -// ----------------------------------------------------------------------------- -sal_Bool OResultSet::deletedVisible() const -{ - return sal_False; -} -// ----------------------------------------------------------------------------- -sal_Bool OResultSet::isRowDeleted() const -{ - return m_pRowStatusArray[0] == SQL_ROW_DELETED; -} -// ----------------------------------------------------------------------------- -sal_Bool OResultSet::moveImpl(IResultSetHelper::Movement _eCursorPosition, sal_Int32 _nOffset, sal_Bool _bRetrieveData) -{ - ::osl::MutexGuard aGuard( m_aMutex ); - checkDisposed(OResultSet_BASE::rBHelper.bDisposed); - return (m_pSkipDeletedSet != NULL) - ? m_pSkipDeletedSet->skipDeleted(_eCursorPosition,_nOffset,_bRetrieveData) - : move(_eCursorPosition,_nOffset,_bRetrieveData); -} -// ----------------------------------------------------------------------------- -void OResultSet::fillNeededData(SQLRETURN _nRet) -{ - RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "odbc", "Ocke.Janssen@sun.com", "OResultSet::fillNeededData" ); - SQLRETURN nRet = _nRet; - if( nRet == SQL_NEED_DATA) - { - void* pColumnIndex = 0; - nRet = N3SQLParamData(m_aStatementHandle,&pColumnIndex); - - do - { - if (nRet != SQL_SUCCESS && nRet != SQL_SUCCESS_WITH_INFO && nRet != SQL_NEED_DATA) - break; - - sal_IntPtr nColumnIndex ( reinterpret_cast<sal_IntPtr>(pColumnIndex)); - Sequence< sal_Int8 > aSeq; - switch(m_aRow[nColumnIndex].getTypeKind()) - { - case DataType::BINARY: - case DataType::VARBINARY: - case DataType::LONGVARBINARY: - case DataType::BLOB: - aSeq = m_aRow[nColumnIndex]; - N3SQLPutData (m_aStatementHandle, aSeq.getArray(), aSeq.getLength()); - break; - case SQL_WLONGVARCHAR: - { - ::rtl::OUString sRet; - sRet = m_aRow[nColumnIndex].getString(); - nRet = N3SQLPutData (m_aStatementHandle, (SQLPOINTER)sRet.getStr(), sizeof(sal_Unicode)*sRet.getLength()); - break; - } - case DataType::LONGVARCHAR: - case DataType::CLOB: - { - ::rtl::OUString sRet; - sRet = m_aRow[nColumnIndex].getString(); - ::rtl::OString aString(::rtl::OUStringToOString(sRet,m_nTextEncoding)); - nRet = N3SQLPutData (m_aStatementHandle, (SQLPOINTER)aString.getStr(), aString.getLength()); - break; - } - default: - OSL_FAIL("Not supported at the moment!"); - } - nRet = N3SQLParamData(m_aStatementHandle,&pColumnIndex); - } - while (nRet == SQL_NEED_DATA); - } -} -// ----------------------------------------------------------------------------- -SWORD OResultSet::impl_getColumnType_nothrow(sal_Int32 columnIndex) -{ - ::std::map<sal_Int32,SWORD>::iterator aFind = m_aODBCColumnTypes.find(columnIndex); - if ( aFind == m_aODBCColumnTypes.end() ) - aFind = m_aODBCColumnTypes.insert(::std::map<sal_Int32,SWORD>::value_type(columnIndex,OResultSetMetaData::getColumnODBCType(m_pStatement->getOwnConnection(),m_aStatementHandle,*this,columnIndex))).first; - return aFind->second; -} - -/* vim:set shiftwidth=4 softtabstop=4 expandtab: */ |