| /************************************************************** |
| * |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, |
| * software distributed under the License is distributed on an |
| * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| * KIND, either express or implied. See the License for the |
| * specific language governing permissions and limitations |
| * under the License. |
| * |
| *************************************************************/ |
| |
| |
| |
| // MARKER(update_precomp.py): autogen include statement, do not remove |
| #include "precompiled_connectivity.hxx" |
| |
| #include "MacabResultSet.hxx" |
| #include "MacabAddressBook.hxx" |
| #include "MacabRecords.hxx" |
| #include "macabutilities.hxx" |
| #include "MacabResultSetMetaData.hxx" |
| #include "MacabConnection.hxx" |
| #include "macabcondition.hxx" |
| #include "macaborder.hxx" |
| #include <com/sun/star/beans/PropertyAttribute.hpp> |
| #include <com/sun/star/sdbcx/CompareBookmark.hpp> |
| #include "TConnection.hxx" |
| #include <connectivity/dbexception.hxx> |
| #include "resource/sharedresources.hxx" |
| #include "resource/macab_res.hrc" |
| |
| using namespace connectivity::macab; |
| 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::io; |
| using namespace com::sun::star::util; |
| |
| IMPLEMENT_SERVICE_INFO(MacabResultSet, "com.sun.star.sdbc.drivers.MacabResultSet", "com.sun.star.sdbc.ResultSet"); |
| // ------------------------------------------------------------------------- |
| MacabResultSet::MacabResultSet(MacabCommonStatement* pStmt) |
| : MacabResultSet_BASE(m_aMutex), |
| OPropertySetHelper(MacabResultSet_BASE::rBHelper), |
| m_xStatement(pStmt), |
| m_xMetaData(NULL), |
| m_aMacabRecords(), |
| m_nRowPos(-1), |
| m_bWasNull(sal_True) |
| { |
| m_sTableName = MacabAddressBook::getDefaultTableName(); |
| } |
| // ------------------------------------------------------------------------- |
| MacabResultSet::~MacabResultSet() |
| { |
| } |
| // ------------------------------------------------------------------------- |
| void MacabResultSet::allMacabRecords() |
| { |
| MacabConnection* pConnection = static_cast< MacabConnection *>(m_xStatement->getConnection().get()); |
| |
| m_aMacabRecords = pConnection->getAddressBook()->getMacabRecords(m_sTableName); |
| } |
| // ------------------------------------------------------------------------- |
| void MacabResultSet::someMacabRecords(const MacabCondition *pCondition) |
| { |
| MacabConnection* pConnection = static_cast< MacabConnection *>(m_xStatement->getConnection().get()); |
| MacabRecords* allRecords; |
| |
| allRecords = pConnection->getAddressBook()->getMacabRecords(m_sTableName); |
| |
| // Bad table!! Throw exception? |
| if(allRecords == NULL) |
| return; |
| |
| if(m_aMacabRecords != NULL && m_aMacabRecords != allRecords) |
| delete m_aMacabRecords; |
| |
| // The copy constructor copies everything but records (including the |
| // maximum alloted size, which means that we'll never have to resize) |
| m_aMacabRecords = new MacabRecords(allRecords); |
| |
| MacabRecords::iterator iterator; |
| |
| for (iterator = allRecords->begin(); |
| iterator != allRecords->end(); |
| ++iterator) |
| { |
| if (pCondition->eval(*iterator)) |
| m_aMacabRecords->insertRecord(*iterator); |
| } |
| } |
| // ------------------------------------------------------------------------- |
| void MacabResultSet::sortMacabRecords(const MacabOrder *pOrder) |
| { |
| // I do this with ints rather than an iterator because the ids will |
| // be changing when we change the order and ints are easier to deal |
| // with (for me). |
| sal_Int32 i, j, size, smallest; |
| size = m_aMacabRecords->size(); |
| |
| for(i = 0; i < size; i++) |
| { |
| smallest = i; |
| for( j = i + 1; j < size; j++) |
| { |
| // if smallest > j |
| if(pOrder->compare(m_aMacabRecords->getRecord(smallest), |
| m_aMacabRecords->getRecord(j) ) > 0) |
| { |
| smallest = j; |
| } |
| |
| } |
| |
| if(smallest != i) |
| { |
| m_aMacabRecords->swap(i,smallest); |
| } |
| } |
| |
| } |
| // ------------------------------------------------------------------------- |
| void MacabResultSet::setTableName(::rtl::OUString _sTableName) |
| { |
| m_sTableName = _sTableName; |
| } |
| // ------------------------------------------------------------------------- |
| void MacabResultSet::disposing() |
| { |
| OPropertySetHelper::disposing(); |
| |
| ::osl::MutexGuard aGuard(m_aMutex); |
| |
| m_xStatement.clear(); |
| m_xMetaData.clear(); |
| } |
| // ------------------------------------------------------------------------- |
| Any SAL_CALL MacabResultSet::queryInterface(const Type & rType) throw(RuntimeException) |
| { |
| Any aRet = OPropertySetHelper::queryInterface(rType); |
| if (!aRet.hasValue()) |
| aRet = MacabResultSet_BASE::queryInterface(rType); |
| return aRet; |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::acquire() throw() |
| { |
| MacabResultSet_BASE::acquire(); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::release() throw() |
| { |
| MacabResultSet_BASE::release(); |
| } |
| // ------------------------------------------------------------------------- |
| Sequence< Type > SAL_CALL MacabResultSet::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(), MacabResultSet_BASE::getTypes()); |
| } |
| // ------------------------------------------------------------------------- |
| ::com::sun::star::uno::Reference< ::com::sun::star::beans::XPropertySetInfo > SAL_CALL MacabResultSet::getPropertySetInfo( ) throw(::com::sun::star::uno::RuntimeException) |
| { |
| return ::cppu::OPropertySetHelper::createPropertySetInfo(getInfoHelper()); |
| } |
| // ------------------------------------------------------------------------- |
| sal_Int32 SAL_CALL MacabResultSet::findColumn(const ::rtl::OUString& columnName) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| // find the first column with the name columnName |
| Reference< XResultSetMetaData > xMeta = getMetaData(); |
| sal_Int32 nLen = xMeta->getColumnCount(); |
| |
| for (sal_Int32 i = 1; i <= nLen; ++i) |
| if (xMeta->isCaseSensitive(i) ? |
| columnName == xMeta->getColumnName(i) : |
| columnName.equalsIgnoreAsciiCase(xMeta->getColumnName(i))) |
| return i; |
| |
| ::connectivity::SharedResources aResources; |
| const ::rtl::OUString sError( aResources.getResourceStringWithSubstitution( |
| STR_NO_ELEMENT_NAME, |
| "$name$", columnName |
| ) ); |
| ::dbtools::throwGenericSQLException(sError , *this); |
| // Unreachable: |
| OSL_ASSERT(false); |
| return 0; |
| } |
| // ------------------------------------------------------------------------- |
| ::rtl::OUString SAL_CALL MacabResultSet::getString(sal_Int32 columnIndex) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| ::rtl::OUString aRet; |
| sal_Int32 nRecords = m_aMacabRecords->size(); |
| m_bWasNull = true; |
| |
| if (m_nRowPos != -1 && m_nRowPos != nRecords && m_xMetaData.is()) |
| { |
| sal_Int32 nFieldNumber = m_xMetaData->fieldAtColumn(columnIndex); |
| macabfield *aField = m_aMacabRecords->getField(m_nRowPos,nFieldNumber); |
| if(aField != NULL) |
| { |
| if(aField->type == kABStringProperty) |
| { |
| aRet = CFStringToOUString( (CFStringRef) aField->value); |
| m_bWasNull = false; |
| } |
| } |
| } |
| |
| // Trigger an exception if m_bWasNull is true? |
| return aRet; |
| } |
| // ------------------------------------------------------------------------- |
| sal_Bool SAL_CALL MacabResultSet::getBoolean(sal_Int32) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| ::dbtools::throwFunctionNotSupportedException("getBoolean", NULL); |
| |
| return sal_False; |
| } |
| // ------------------------------------------------------------------------- |
| sal_Int8 SAL_CALL MacabResultSet::getByte(sal_Int32) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| ::dbtools::throwFunctionNotSupportedException("getByte", NULL); |
| |
| sal_Int8 nRet = 0; |
| return nRet; |
| } |
| // ------------------------------------------------------------------------- |
| sal_Int16 SAL_CALL MacabResultSet::getShort(sal_Int32) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| ::dbtools::throwFunctionNotSupportedException("getShort", NULL); |
| |
| sal_Int16 nRet = 0; |
| return nRet; |
| } |
| // ------------------------------------------------------------------------- |
| sal_Int32 SAL_CALL MacabResultSet::getInt(sal_Int32 columnIndex) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| sal_Int32 nRet = 0; |
| sal_Int32 nRecords = m_aMacabRecords->size(); |
| m_bWasNull = true; |
| |
| if (m_nRowPos != -1 && m_nRowPos != nRecords && m_xMetaData.is()) |
| { |
| sal_Int32 nFieldNumber = m_xMetaData->fieldAtColumn(columnIndex); |
| macabfield *aField = m_aMacabRecords->getField(m_nRowPos,nFieldNumber); |
| if(aField != NULL) |
| { |
| if(aField->type == kABIntegerProperty) |
| { |
| CFNumberType numberType = CFNumberGetType( (CFNumberRef) aField->value ); |
| // m_bWasNull now becomes whether getting the value was successful |
| // Should we check for the wrong type here, e.g., a float or a 64 bit int? |
| m_bWasNull = !CFNumberGetValue((CFNumberRef) aField->value, numberType, &nRet); |
| } |
| } |
| } |
| |
| // Trigger an exception if m_bWasNull is true? |
| return nRet; |
| } |
| // ------------------------------------------------------------------------- |
| sal_Int64 SAL_CALL MacabResultSet::getLong(sal_Int32 columnIndex) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| sal_Int64 nRet = 0; |
| sal_Int32 nRecords = m_aMacabRecords->size(); |
| m_bWasNull = true; |
| |
| if (m_nRowPos != -1 && m_nRowPos != nRecords && m_xMetaData.is()) |
| { |
| sal_Int32 nFieldNumber = m_xMetaData->fieldAtColumn(columnIndex); |
| macabfield *aField = m_aMacabRecords->getField(m_nRowPos,nFieldNumber); |
| if(aField != NULL) |
| { |
| if(aField->type == kABIntegerProperty) |
| { |
| CFNumberType numberType = CFNumberGetType( (CFNumberRef) aField->value ); |
| // m_bWasNull now becomes whether getting the value was successful |
| // Should we check for the wrong type here, e.g., a float or a 32 bit int? |
| m_bWasNull = !CFNumberGetValue((CFNumberRef) aField->value, numberType, &nRet); |
| } |
| } |
| } |
| |
| // Trigger an exception if m_bWasNull is true? |
| return nRet; |
| } |
| // ------------------------------------------------------------------------- |
| float SAL_CALL MacabResultSet::getFloat(sal_Int32 columnIndex) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| float nVal = 0; |
| sal_Int32 nRecords = m_aMacabRecords->size(); |
| m_bWasNull = true; |
| |
| if (m_nRowPos != -1 && m_nRowPos != nRecords && m_xMetaData.is()) |
| { |
| sal_Int32 nFieldNumber = m_xMetaData->fieldAtColumn(columnIndex); |
| macabfield *aField = m_aMacabRecords->getField(m_nRowPos,nFieldNumber); |
| if(aField != NULL) |
| { |
| if(aField->type == kABRealProperty) |
| { |
| CFNumberType numberType = CFNumberGetType( (CFNumberRef) aField->value ); |
| // m_bWasNull now becomes whether getting the value was successful |
| // Should we check for the wrong type here, e.g., an int or a double? |
| m_bWasNull = !CFNumberGetValue((CFNumberRef) aField->value, numberType, &nVal); |
| } |
| } |
| } |
| |
| // Trigger an exception if m_bWasNull is true? |
| return nVal; |
| } |
| // ------------------------------------------------------------------------- |
| double SAL_CALL MacabResultSet::getDouble(sal_Int32 columnIndex) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| double nVal = 0; |
| sal_Int32 nRecords = m_aMacabRecords->size(); |
| m_bWasNull = true; |
| |
| if (m_nRowPos != -1 && m_nRowPos != nRecords && m_xMetaData.is()) |
| { |
| sal_Int32 nFieldNumber = m_xMetaData->fieldAtColumn(columnIndex); |
| macabfield *aField = m_aMacabRecords->getField(m_nRowPos,nFieldNumber); |
| if(aField != NULL) |
| { |
| if(aField->type == kABRealProperty) |
| { |
| CFNumberType numberType = CFNumberGetType( (CFNumberRef) aField->value ); |
| // m_bWasNull now becomes whether getting the value was successful |
| // Should we check for the wrong type here, e.g., an int or a float? |
| m_bWasNull = !CFNumberGetValue((CFNumberRef) aField->value, numberType, &nVal); |
| } |
| } |
| } |
| |
| // Trigger an exception if m_bWasNull is true? |
| return nVal; |
| } |
| // ------------------------------------------------------------------------- |
| Sequence< sal_Int8 > SAL_CALL MacabResultSet::getBytes(sal_Int32) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| ::dbtools::throwFunctionNotSupportedException("getBytes", NULL); |
| |
| return Sequence< sal_Int8 >(); |
| } |
| // ------------------------------------------------------------------------- |
| Date SAL_CALL MacabResultSet::getDate(sal_Int32) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| ::dbtools::throwFunctionNotSupportedException("getDate", NULL); |
| |
| Date aRet; |
| return aRet; |
| } |
| // ------------------------------------------------------------------------- |
| Time SAL_CALL MacabResultSet::getTime(sal_Int32) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| ::dbtools::throwFunctionNotSupportedException("getTime", NULL); |
| |
| Time nRet; |
| return nRet; |
| } |
| // ------------------------------------------------------------------------- |
| DateTime SAL_CALL MacabResultSet::getTimestamp(sal_Int32 columnIndex) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| DateTime nRet; |
| sal_Int32 nRecords = m_aMacabRecords->size(); |
| m_bWasNull = true; |
| |
| if (m_nRowPos != -1 && m_nRowPos != nRecords && m_xMetaData.is()) |
| { |
| sal_Int32 nFieldNumber = m_xMetaData->fieldAtColumn(columnIndex); |
| macabfield *aField = m_aMacabRecords->getField(m_nRowPos,nFieldNumber); |
| if(aField != NULL) |
| { |
| if(aField->type == kABDateProperty) |
| { |
| nRet = CFDateToDateTime((CFDateRef) aField->value); |
| m_bWasNull = false; |
| } |
| } |
| } |
| |
| // Trigger an exception if m_bWasNull is true? |
| return nRet; |
| } |
| // ------------------------------------------------------------------------- |
| Reference< XInputStream > SAL_CALL MacabResultSet::getBinaryStream(sal_Int32) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| ::dbtools::throwFunctionNotSupportedException("getBinaryStream", NULL); |
| |
| return NULL; |
| } |
| // ------------------------------------------------------------------------- |
| Reference< XInputStream > SAL_CALL MacabResultSet::getCharacterStream(sal_Int32) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| ::dbtools::throwFunctionNotSupportedException("getCharacterStream", NULL); |
| |
| return NULL; |
| } |
| // ------------------------------------------------------------------------- |
| Any SAL_CALL MacabResultSet::getObject(sal_Int32, const Reference< ::com::sun::star::container::XNameAccess >&) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| ::dbtools::throwFunctionNotSupportedException("getObject", NULL); |
| |
| return Any(); |
| } |
| // ------------------------------------------------------------------------- |
| Reference< XRef > SAL_CALL MacabResultSet::getRef(sal_Int32) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| ::dbtools::throwFunctionNotSupportedException("getRef", NULL); |
| |
| return NULL; |
| } |
| // ------------------------------------------------------------------------- |
| Reference< XBlob > SAL_CALL MacabResultSet::getBlob(sal_Int32) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| ::dbtools::throwFunctionNotSupportedException("getBlob", NULL); |
| |
| return NULL; |
| } |
| // ------------------------------------------------------------------------- |
| Reference< XClob > SAL_CALL MacabResultSet::getClob(sal_Int32) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| ::dbtools::throwFunctionNotSupportedException("getClob", NULL); |
| |
| return NULL; |
| } |
| // ------------------------------------------------------------------------- |
| Reference< XArray > SAL_CALL MacabResultSet::getArray(sal_Int32) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| ::dbtools::throwFunctionNotSupportedException("getArray", NULL); |
| |
| return NULL; |
| } |
| // ------------------------------------------------------------------------- |
| Reference< XResultSetMetaData > SAL_CALL MacabResultSet::getMetaData() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| if (!m_xMetaData.is()) |
| m_xMetaData = new MacabResultSetMetaData(m_xStatement->getOwnConnection(), m_sTableName); |
| |
| Reference< XResultSetMetaData > xMetaData = m_xMetaData.get(); |
| return xMetaData; |
| } |
| // ------------------------------------------------------------------------- |
| sal_Bool SAL_CALL MacabResultSet::isBeforeFirst() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| if (m_nRowPos == -1) |
| return sal_True; |
| |
| return sal_False; |
| } |
| // ------------------------------------------------------------------------- |
| sal_Bool SAL_CALL MacabResultSet::isAfterLast() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| sal_Int32 nRecords = m_aMacabRecords->size(); |
| if (m_nRowPos == nRecords) |
| return sal_True; |
| |
| return sal_False; |
| } |
| // ------------------------------------------------------------------------- |
| sal_Bool SAL_CALL MacabResultSet::isFirst() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| if (m_nRowPos == 0) |
| return sal_True; |
| |
| return sal_False; |
| } |
| // ------------------------------------------------------------------------- |
| sal_Bool SAL_CALL MacabResultSet::isLast() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| sal_Int32 nRecords = m_aMacabRecords->size(); |
| if (m_nRowPos == nRecords - 1) |
| return sal_True; |
| |
| return sal_False; |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::beforeFirst() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| // move before the first row |
| m_nRowPos = -1; |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::afterLast() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| // move after the last row |
| sal_Int32 nRecords = m_aMacabRecords->size(); |
| m_nRowPos = nRecords; |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::close() throw(SQLException, RuntimeException) |
| { |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| } |
| dispose(); |
| } |
| // ------------------------------------------------------------------------- |
| sal_Bool SAL_CALL MacabResultSet::first() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| sal_Int32 nRecords = m_aMacabRecords->size(); |
| if (nRecords == 0) |
| return sal_False; |
| |
| m_nRowPos = 0; |
| return sal_True; |
| } |
| // ------------------------------------------------------------------------- |
| sal_Bool SAL_CALL MacabResultSet::last() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| sal_Int32 nRecords = m_aMacabRecords->size(); |
| if (nRecords == 0) |
| return sal_False; |
| |
| m_nRowPos = nRecords - 1; |
| return sal_True; |
| } |
| // ------------------------------------------------------------------------- |
| sal_Int32 SAL_CALL MacabResultSet::getRow() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| return m_nRowPos; |
| } |
| // ------------------------------------------------------------------------- |
| sal_Bool SAL_CALL MacabResultSet::absolute(sal_Int32 row) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| sal_Int32 nRecords = m_aMacabRecords->size(); |
| if (row <= -1 || |
| row >= nRecords) |
| return sal_False; |
| |
| m_nRowPos = row; |
| return sal_True; |
| } |
| // ------------------------------------------------------------------------- |
| sal_Bool SAL_CALL MacabResultSet::relative(sal_Int32 row) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| return absolute(m_nRowPos + row); |
| } |
| // ------------------------------------------------------------------------- |
| sal_Bool SAL_CALL MacabResultSet::next() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| return absolute(m_nRowPos + 1); |
| } |
| // ------------------------------------------------------------------------- |
| sal_Bool SAL_CALL MacabResultSet::previous() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| return absolute(m_nRowPos - 1); |
| } |
| // ------------------------------------------------------------------------- |
| Reference< XInterface > SAL_CALL MacabResultSet::getStatement() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| Reference< XStatement > xStatement = m_xStatement.get(); |
| return xStatement; |
| } |
| // ------------------------------------------------------------------------- |
| sal_Bool SAL_CALL MacabResultSet::rowDeleted() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| return sal_False; |
| } |
| // ------------------------------------------------------------------------- |
| sal_Bool SAL_CALL MacabResultSet::rowInserted() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| return sal_False; |
| } |
| // ------------------------------------------------------------------------- |
| sal_Bool SAL_CALL MacabResultSet::rowUpdated() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| return sal_False; |
| } |
| // ------------------------------------------------------------------------- |
| sal_Bool SAL_CALL MacabResultSet::wasNull() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| return m_bWasNull; |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::cancel() throw(RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::clearWarnings() throw(SQLException, RuntimeException) |
| { |
| } |
| // ------------------------------------------------------------------------- |
| Any SAL_CALL MacabResultSet::getWarnings() throw(SQLException, RuntimeException) |
| { |
| return Any(); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::insertRow() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| // you only have to implement this if you want to insert new rows |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::updateRow() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| // only when you allow updates |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::deleteRow() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::cancelRowUpdates() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::moveToInsertRow() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| // only when you allow inserts |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::moveToCurrentRow() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::updateNull(sal_Int32) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::updateBoolean(sal_Int32, sal_Bool) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::updateByte(sal_Int32, sal_Int8) throw(SQLException, RuntimeException) |
| { |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::updateShort(sal_Int32, sal_Int16) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::updateInt(sal_Int32, sal_Int32) throw(SQLException, RuntimeException) |
| { |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::updateLong(sal_Int32, sal_Int64) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| } |
| // ----------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::updateFloat(sal_Int32, float) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::updateDouble(sal_Int32, double) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::updateString(sal_Int32, const ::rtl::OUString&) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::updateBytes(sal_Int32, const Sequence< sal_Int8 >&) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::updateDate(sal_Int32, const Date&) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::updateTime(sal_Int32, const Time&) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::updateTimestamp(sal_Int32, const DateTime&) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::updateBinaryStream(sal_Int32, const Reference< XInputStream >&, sal_Int32) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::updateCharacterStream(sal_Int32, const Reference< XInputStream >&, sal_Int32) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::refreshRow() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::updateObject(sal_Int32, const Any&) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL MacabResultSet::updateNumericObject(sal_Int32, const Any&, sal_Int32) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| } |
| // ------------------------------------------------------------------------- |
| // XRowLocate |
| Any SAL_CALL MacabResultSet::getBookmark() throw( SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| sal_Int32 nRecords = m_aMacabRecords->size(); |
| |
| if (m_nRowPos != -1 && m_nRowPos != nRecords) |
| { |
| macabfield *uidField = m_aMacabRecords->getField(m_nRowPos,::rtl::OUString::createFromAscii("UID")); |
| if(uidField != NULL) |
| { |
| if(uidField->type == kABStringProperty) |
| { |
| return makeAny(CFStringToOUString( (CFStringRef) uidField->value )); |
| } |
| } |
| } |
| return Any(); |
| } |
| // ------------------------------------------------------------------------- |
| sal_Bool SAL_CALL MacabResultSet::moveToBookmark(const Any& bookmark) throw( SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| ::rtl::OUString sBookmark = comphelper::getString(bookmark); |
| sal_Int32 nRecords = m_aMacabRecords->size(); |
| |
| for (sal_Int32 nRow = 0; nRow < nRecords; nRow++) |
| { |
| macabfield *uidField = m_aMacabRecords->getField(m_nRowPos,::rtl::OUString::createFromAscii("UID")); |
| if(uidField != NULL) |
| { |
| if(uidField->type == kABStringProperty) |
| { |
| ::rtl::OUString sUniqueIdentifier = CFStringToOUString( (CFStringRef) uidField->value ); |
| if (sUniqueIdentifier == sBookmark) |
| { |
| m_nRowPos = nRow; |
| return sal_True; |
| } |
| } |
| } |
| } |
| return sal_False; |
| } |
| // ------------------------------------------------------------------------- |
| sal_Bool SAL_CALL MacabResultSet::moveRelativeToBookmark(const Any& bookmark, sal_Int32 rows) throw( SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| sal_Int32 nRowSave = m_nRowPos; |
| |
| if (moveToBookmark(bookmark)) |
| { |
| sal_Int32 nRecords = m_aMacabRecords->size(); |
| |
| m_nRowPos += rows; |
| |
| if (-1 < m_nRowPos && m_nRowPos < nRecords) |
| return sal_True; |
| } |
| |
| m_nRowPos = nRowSave; |
| return sal_False; |
| } |
| // ------------------------------------------------------------------------- |
| sal_Int32 SAL_CALL MacabResultSet::compareBookmarks(const Any& firstItem, const Any& secondItem) throw( SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| ::rtl::OUString sFirst = comphelper::getString(firstItem); |
| ::rtl::OUString sSecond = comphelper::getString(secondItem); |
| |
| if (sFirst < sSecond) |
| return CompareBookmark::LESS; |
| if (sFirst > sSecond) |
| return CompareBookmark::GREATER; |
| return CompareBookmark::EQUAL; |
| } |
| // ------------------------------------------------------------------------- |
| sal_Bool SAL_CALL MacabResultSet::hasOrderedBookmarks() throw( SQLException, RuntimeException) |
| { |
| return sal_False; |
| } |
| // ------------------------------------------------------------------------- |
| sal_Int32 SAL_CALL MacabResultSet::hashBookmark(const Any& bookmark) throw( SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| ::rtl::OUString sBookmark = comphelper::getString(bookmark); |
| |
| return sBookmark.hashCode(); |
| } |
| // ------------------------------------------------------------------------- |
| // XDeleteRows |
| Sequence< sal_Int32 > SAL_CALL MacabResultSet::deleteRows(const Sequence< Any >&) throw( SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(MacabResultSet_BASE::rBHelper.bDisposed); |
| |
| return Sequence< sal_Int32 >(); |
| } |
| // ------------------------------------------------------------------------- |
| IPropertyArrayHelper* MacabResultSet::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 & MacabResultSet::getInfoHelper() |
| { |
| return *static_cast<MacabResultSet*>(this)->getArrayHelper(); |
| } |
| // ------------------------------------------------------------------------- |
| sal_Bool MacabResultSet::convertFastPropertyValue( |
| Any &, |
| Any &, |
| sal_Int32 nHandle, |
| const Any& ) |
| 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(); |
| break; |
| case PROPERTY_ID_FETCHDIRECTION: |
| case PROPERTY_ID_FETCHSIZE: |
| default: |
| ; |
| } |
| return sal_False; |
| } |
| // ------------------------------------------------------------------------- |
| void MacabResultSet::setFastPropertyValue_NoBroadcast( |
| sal_Int32 nHandle, |
| const Any& ) |
| throw (Exception) |
| { |
| switch (nHandle) |
| { |
| case PROPERTY_ID_ISBOOKMARKABLE: |
| case PROPERTY_ID_CURSORNAME: |
| case PROPERTY_ID_RESULTSETCONCURRENCY: |
| case PROPERTY_ID_RESULTSETTYPE: |
| throw Exception(); |
| break; |
| case PROPERTY_ID_FETCHDIRECTION: |
| break; |
| case PROPERTY_ID_FETCHSIZE: |
| break; |
| default: |
| ; |
| } |
| } |
| // ------------------------------------------------------------------------- |
| void MacabResultSet::getFastPropertyValue( |
| Any& _rValue, |
| sal_Int32 nHandle) const |
| { |
| switch (nHandle) |
| { |
| case PROPERTY_ID_ISBOOKMARKABLE: |
| _rValue <<= (sal_Bool)sal_False; |
| break; |
| case PROPERTY_ID_CURSORNAME: |
| case PROPERTY_ID_RESULTSETCONCURRENCY: |
| case PROPERTY_ID_RESULTSETTYPE: |
| case PROPERTY_ID_FETCHDIRECTION: |
| case PROPERTY_ID_FETCHSIZE: |
| ; |
| } |
| } |
| // ----------------------------------------------------------------------------- |