| /************************************************************** |
| * |
| * 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_ucbhelper.hxx" |
| |
| /************************************************************************** |
| TODO |
| ************************************************************************** |
| |
| *************************************************************************/ |
| #include <cppuhelper/interfacecontainer.hxx> |
| #include <com/sun/star/beans/PropertyAttribute.hpp> |
| #include <ucbhelper/resultset.hxx> |
| #include <ucbhelper/resultsetmetadata.hxx> |
| |
| using namespace com::sun::star; |
| |
| //========================================================================= |
| |
| namespace ucbhelper_impl |
| { |
| |
| struct PropertyInfo |
| { |
| const char* pName; |
| sal_Int32 nHandle; |
| sal_Int16 nAttributes; |
| const uno::Type& (*pGetCppuType)(); |
| }; |
| |
| static const uno::Type& sal_Int32_getCppuType() |
| { |
| return getCppuType( static_cast< const sal_Int32 * >( 0 ) ); |
| } |
| |
| static const uno::Type& sal_Bool_getCppuType() |
| { |
| return getCppuBooleanType(); |
| } |
| |
| static const PropertyInfo aPropertyTable[] = |
| { |
| { "IsRowCountFinal", |
| 1000, |
| beans::PropertyAttribute::BOUND | beans::PropertyAttribute::READONLY, |
| &sal_Bool_getCppuType |
| }, |
| { "RowCount", |
| 1001, |
| beans::PropertyAttribute::BOUND | beans::PropertyAttribute::READONLY, |
| &sal_Int32_getCppuType |
| }, |
| { 0, |
| 0, |
| 0, |
| 0 |
| } |
| }; |
| |
| #define RESULTSET_PROPERTY_COUNT 2 |
| |
| //========================================================================= |
| // |
| // class PropertySetInfo |
| // |
| //========================================================================= |
| |
| class PropertySetInfo : |
| public cppu::OWeakObject, |
| public lang::XTypeProvider, |
| public beans::XPropertySetInfo |
| { |
| uno::Reference< lang::XMultiServiceFactory > m_xSMgr; |
| uno::Sequence< beans::Property >* m_pProps; |
| |
| private: |
| sal_Bool queryProperty( |
| const rtl::OUString& aName, beans::Property& rProp ); |
| |
| public: |
| PropertySetInfo( |
| const uno::Reference< lang::XMultiServiceFactory >& rxSMgr, |
| const PropertyInfo* pProps, |
| sal_Int32 nProps ); |
| virtual ~PropertySetInfo(); |
| |
| // XInterface |
| XINTERFACE_DECL() |
| |
| // XTypeProvider |
| XTYPEPROVIDER_DECL() |
| |
| // XPropertySetInfo |
| virtual uno::Sequence< beans::Property > SAL_CALL getProperties() |
| throw( uno::RuntimeException ); |
| virtual beans::Property SAL_CALL getPropertyByName( |
| const rtl::OUString& aName ) |
| throw( beans::UnknownPropertyException, uno::RuntimeException ); |
| virtual sal_Bool SAL_CALL hasPropertyByName( const rtl::OUString& Name ) |
| throw( uno::RuntimeException ); |
| }; |
| |
| //========================================================================= |
| // |
| // PropertyChangeListenerContainer. |
| // |
| //========================================================================= |
| |
| struct equalStr_Impl |
| { |
| bool operator()( const rtl::OUString& s1, const rtl::OUString& s2 ) const |
| { |
| return !!( s1 == s2 ); |
| } |
| }; |
| |
| struct hashStr_Impl |
| { |
| size_t operator()( const rtl::OUString& rName ) const |
| { |
| return rName.hashCode(); |
| } |
| }; |
| |
| typedef cppu::OMultiTypeInterfaceContainerHelperVar |
| < |
| rtl::OUString, |
| hashStr_Impl, |
| equalStr_Impl |
| > PropertyChangeListenerContainer; |
| |
| //========================================================================= |
| // |
| // class PropertyChangeListeners. |
| // |
| //========================================================================= |
| |
| class PropertyChangeListeners : public PropertyChangeListenerContainer |
| { |
| public: |
| PropertyChangeListeners( osl::Mutex& rMtx ) |
| : PropertyChangeListenerContainer( rMtx ) {} |
| }; |
| |
| } // namespace ucbhelper_impl |
| |
| using namespace ucbhelper_impl; |
| |
| namespace ucbhelper |
| { |
| |
| //========================================================================= |
| // |
| // struct ResultSet_Impl. |
| // |
| //========================================================================= |
| |
| struct ResultSet_Impl |
| { |
| uno::Reference< lang::XMultiServiceFactory > m_xSMgr; |
| uno::Reference< com::sun::star::ucb::XCommandEnvironment > m_xEnv; |
| uno::Reference< beans::XPropertySetInfo > m_xPropSetInfo; |
| uno::Reference< sdbc::XResultSetMetaData > m_xMetaData; |
| uno::Sequence< beans::Property > m_aProperties; |
| rtl::Reference< ResultSetDataSupplier > m_xDataSupplier; |
| osl::Mutex m_aMutex; |
| cppu::OInterfaceContainerHelper* m_pDisposeEventListeners; |
| PropertyChangeListeners* m_pPropertyChangeListeners; |
| sal_Int32 m_nPos; |
| sal_Bool m_bWasNull; |
| sal_Bool m_bAfterLast; |
| |
| inline ResultSet_Impl( |
| const uno::Reference< lang::XMultiServiceFactory >& rxSMgr, |
| const uno::Sequence< beans::Property >& rProperties, |
| const rtl::Reference< ResultSetDataSupplier >& rDataSupplier, |
| const uno::Reference< com::sun::star::ucb::XCommandEnvironment >& |
| rxEnv ); |
| inline ~ResultSet_Impl(); |
| }; |
| |
| inline ResultSet_Impl::ResultSet_Impl( |
| const uno::Reference< lang::XMultiServiceFactory >& rxSMgr, |
| const uno::Sequence< beans::Property >& rProperties, |
| const rtl::Reference< ResultSetDataSupplier >& rDataSupplier, |
| const uno::Reference< com::sun::star::ucb::XCommandEnvironment >& rxEnv ) |
| : m_xSMgr( rxSMgr ), |
| m_xEnv( rxEnv ), |
| m_aProperties( rProperties ), |
| m_xDataSupplier( rDataSupplier ), |
| m_pDisposeEventListeners( 0 ), |
| m_pPropertyChangeListeners( 0 ), |
| m_nPos( 0 ), // Position is one-based. Zero means: before first element. |
| m_bWasNull( sal_False ), |
| m_bAfterLast( sal_False ) |
| { |
| } |
| |
| //========================================================================= |
| inline ResultSet_Impl::~ResultSet_Impl() |
| { |
| delete m_pDisposeEventListeners; |
| delete m_pPropertyChangeListeners; |
| } |
| |
| //========================================================================= |
| //========================================================================= |
| // |
| // ResultSet Implementation. |
| // |
| //========================================================================= |
| //========================================================================= |
| |
| ResultSet::ResultSet( |
| const uno::Reference< lang::XMultiServiceFactory >& rxSMgr, |
| const uno::Sequence< beans::Property >& rProperties, |
| const rtl::Reference< ResultSetDataSupplier >& rDataSupplier ) |
| : m_pImpl( new ResultSet_Impl( |
| rxSMgr, |
| rProperties, |
| rDataSupplier, |
| uno::Reference< com::sun::star::ucb::XCommandEnvironment >() ) ) |
| { |
| rDataSupplier->m_pResultSet = this; |
| } |
| |
| //========================================================================= |
| ResultSet::ResultSet( |
| const uno::Reference< lang::XMultiServiceFactory >& rxSMgr, |
| const uno::Sequence< beans::Property >& rProperties, |
| const rtl::Reference< ResultSetDataSupplier >& rDataSupplier, |
| const uno::Reference< com::sun::star::ucb::XCommandEnvironment >& rxEnv ) |
| : m_pImpl( new ResultSet_Impl( rxSMgr, rProperties, rDataSupplier, rxEnv ) ) |
| { |
| rDataSupplier->m_pResultSet = this; |
| } |
| |
| //========================================================================= |
| // virtual |
| ResultSet::~ResultSet() |
| { |
| delete m_pImpl; |
| } |
| |
| //========================================================================= |
| // |
| // XInterface methods. |
| // |
| //========================================================================= |
| |
| XINTERFACE_IMPL_9( ResultSet, |
| lang::XTypeProvider, |
| lang::XServiceInfo, |
| lang::XComponent, |
| com::sun::star::ucb::XContentAccess, |
| sdbc::XResultSet, |
| sdbc::XResultSetMetaDataSupplier, |
| sdbc::XRow, |
| sdbc::XCloseable, |
| beans::XPropertySet ); |
| |
| //========================================================================= |
| // |
| // XTypeProvider methods. |
| // |
| //========================================================================= |
| |
| XTYPEPROVIDER_IMPL_9( ResultSet, |
| lang::XTypeProvider, |
| lang::XServiceInfo, |
| lang::XComponent, |
| com::sun::star::ucb::XContentAccess, |
| sdbc::XResultSet, |
| sdbc::XResultSetMetaDataSupplier, |
| sdbc::XRow, |
| sdbc::XCloseable, |
| beans::XPropertySet ); |
| |
| //========================================================================= |
| // |
| // XServiceInfo methods. |
| // |
| //========================================================================= |
| |
| XSERVICEINFO_NOFACTORY_IMPL_1( ResultSet, |
| rtl::OUString::createFromAscii( "ResultSet" ), |
| rtl::OUString::createFromAscii( RESULTSET_SERVICE_NAME ) ); |
| |
| //========================================================================= |
| // |
| // XComponent methods. |
| // |
| //========================================================================= |
| |
| // virtual |
| void SAL_CALL ResultSet::dispose() |
| throw( uno::RuntimeException ) |
| { |
| osl::MutexGuard aGuard( m_pImpl->m_aMutex ); |
| |
| if ( m_pImpl->m_pDisposeEventListeners && |
| m_pImpl->m_pDisposeEventListeners->getLength() ) |
| { |
| lang::EventObject aEvt; |
| aEvt.Source = static_cast< lang::XComponent * >( this ); |
| m_pImpl->m_pDisposeEventListeners->disposeAndClear( aEvt ); |
| } |
| |
| if ( m_pImpl->m_pPropertyChangeListeners ) |
| { |
| lang::EventObject aEvt; |
| aEvt.Source = static_cast< beans::XPropertySet * >( this ); |
| m_pImpl->m_pPropertyChangeListeners->disposeAndClear( aEvt ); |
| } |
| |
| m_pImpl->m_xDataSupplier->close(); |
| } |
| |
| //========================================================================= |
| // virtual |
| void SAL_CALL ResultSet::addEventListener( |
| const uno::Reference< lang::XEventListener >& Listener ) |
| throw( uno::RuntimeException ) |
| { |
| osl::MutexGuard aGuard( m_pImpl->m_aMutex ); |
| |
| if ( !m_pImpl->m_pDisposeEventListeners ) |
| m_pImpl->m_pDisposeEventListeners = |
| new cppu::OInterfaceContainerHelper( m_pImpl->m_aMutex ); |
| |
| m_pImpl->m_pDisposeEventListeners->addInterface( Listener ); |
| } |
| |
| //========================================================================= |
| // virtual |
| void SAL_CALL ResultSet::removeEventListener( |
| const uno::Reference< lang::XEventListener >& Listener ) |
| throw( uno::RuntimeException ) |
| { |
| osl::MutexGuard aGuard( m_pImpl->m_aMutex ); |
| |
| if ( m_pImpl->m_pDisposeEventListeners ) |
| m_pImpl->m_pDisposeEventListeners->removeInterface( Listener ); |
| } |
| |
| //========================================================================= |
| // |
| // XResultSetMetaDataSupplier methods. |
| // |
| //========================================================================= |
| |
| // virtual |
| uno::Reference< sdbc::XResultSetMetaData > SAL_CALL ResultSet::getMetaData() |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| osl::MutexGuard aGuard( m_pImpl->m_aMutex ); |
| |
| if ( !m_pImpl->m_xMetaData.is() ) |
| m_pImpl->m_xMetaData = new ResultSetMetaData( m_pImpl->m_xSMgr, |
| m_pImpl->m_aProperties ); |
| |
| return m_pImpl->m_xMetaData; |
| } |
| |
| //========================================================================= |
| // |
| // XResultSet methods. |
| // |
| //========================================================================= |
| |
| // virtual |
| sal_Bool SAL_CALL ResultSet::next() |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| // Note: Cursor is initially positioned before the first row. |
| // First call to 'next()' moves it to first row. |
| |
| osl::MutexGuard aGuard( m_pImpl->m_aMutex ); |
| |
| if ( m_pImpl->m_bAfterLast ) |
| { |
| m_pImpl->m_xDataSupplier->validate(); |
| return sal_False; |
| } |
| |
| // getResult works zero-based! |
| if ( !m_pImpl->m_xDataSupplier->getResult( m_pImpl->m_nPos ) ) |
| { |
| m_pImpl->m_bAfterLast = sal_True; |
| m_pImpl->m_xDataSupplier->validate(); |
| return sal_False; |
| } |
| |
| m_pImpl->m_nPos++; |
| m_pImpl->m_xDataSupplier->validate(); |
| return sal_True; |
| } |
| |
| //========================================================================= |
| // virtual |
| sal_Bool SAL_CALL ResultSet::isBeforeFirst() |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| if ( m_pImpl->m_bAfterLast ) |
| { |
| m_pImpl->m_xDataSupplier->validate(); |
| return sal_False; |
| } |
| |
| // getResult works zero-based! |
| if ( !m_pImpl->m_xDataSupplier->getResult( 0 ) ) |
| { |
| m_pImpl->m_xDataSupplier->validate(); |
| return sal_False; |
| } |
| |
| m_pImpl->m_xDataSupplier->validate(); |
| return ( m_pImpl->m_nPos == 0 ); |
| } |
| |
| //========================================================================= |
| // virtual |
| sal_Bool SAL_CALL ResultSet::isAfterLast() |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| m_pImpl->m_xDataSupplier->validate(); |
| return m_pImpl->m_bAfterLast; |
| } |
| |
| //========================================================================= |
| // virtual |
| sal_Bool SAL_CALL ResultSet::isFirst() |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| if ( m_pImpl->m_bAfterLast ) |
| { |
| m_pImpl->m_xDataSupplier->validate(); |
| return sal_False; |
| } |
| |
| m_pImpl->m_xDataSupplier->validate(); |
| return ( m_pImpl->m_nPos == 1 ); |
| } |
| |
| //========================================================================= |
| // virtual |
| sal_Bool SAL_CALL ResultSet::isLast() |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| if ( m_pImpl->m_bAfterLast ) |
| { |
| m_pImpl->m_xDataSupplier->validate(); |
| return sal_False; |
| } |
| |
| sal_Int32 nCount = m_pImpl->m_xDataSupplier->totalCount(); |
| if ( !nCount ) |
| { |
| m_pImpl->m_xDataSupplier->validate(); |
| return sal_False; |
| } |
| |
| m_pImpl->m_xDataSupplier->validate(); |
| return ( m_pImpl->m_nPos == nCount ); |
| } |
| |
| //========================================================================= |
| // virtual |
| void SAL_CALL ResultSet::beforeFirst() |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| osl::MutexGuard aGuard( m_pImpl->m_aMutex ); |
| m_pImpl->m_bAfterLast = sal_False; |
| m_pImpl->m_nPos = 0; |
| m_pImpl->m_xDataSupplier->validate(); |
| } |
| |
| //========================================================================= |
| // virtual |
| void SAL_CALL ResultSet::afterLast() |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| osl::MutexGuard aGuard( m_pImpl->m_aMutex ); |
| m_pImpl->m_bAfterLast = sal_True; |
| m_pImpl->m_xDataSupplier->validate(); |
| } |
| |
| //========================================================================= |
| // virtual |
| sal_Bool SAL_CALL ResultSet::first() |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| // getResult works zero-based! |
| if ( m_pImpl->m_xDataSupplier->getResult( 0 ) ) |
| { |
| osl::MutexGuard aGuard( m_pImpl->m_aMutex ); |
| m_pImpl->m_bAfterLast = sal_False; |
| m_pImpl->m_nPos = 1; |
| m_pImpl->m_xDataSupplier->validate(); |
| return sal_True; |
| } |
| |
| m_pImpl->m_xDataSupplier->validate(); |
| return sal_False; |
| } |
| |
| //========================================================================= |
| // virtual |
| sal_Bool SAL_CALL ResultSet::last() |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| sal_Int32 nCount = m_pImpl->m_xDataSupplier->totalCount(); |
| if ( nCount ) |
| { |
| osl::MutexGuard aGuard( m_pImpl->m_aMutex ); |
| m_pImpl->m_bAfterLast = sal_False; |
| m_pImpl->m_nPos = nCount; |
| m_pImpl->m_xDataSupplier->validate(); |
| return sal_True; |
| } |
| |
| m_pImpl->m_xDataSupplier->validate(); |
| return sal_False; |
| } |
| |
| //========================================================================= |
| // virtual |
| sal_Int32 SAL_CALL ResultSet::getRow() |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| if ( m_pImpl->m_bAfterLast ) |
| { |
| m_pImpl->m_xDataSupplier->validate(); |
| return 0; |
| } |
| |
| m_pImpl->m_xDataSupplier->validate(); |
| return m_pImpl->m_nPos; |
| } |
| |
| //========================================================================= |
| // virtual |
| sal_Bool SAL_CALL ResultSet::absolute( sal_Int32 row ) |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| /* |
| If the row number is positive, the cursor moves to the given row number |
| with respect to the beginning of the result set. The first row is row 1, |
| the second is row 2, and so on. |
| |
| If the given row number is negative, the cursor moves to an absolute row |
| position with respect to the end of the result set. For example, calling |
| absolaute( -1 ) positions the cursor on the last row, absolaute( -2 ) |
| indicates the next-to-last row, and so on. |
| |
| An attempt to position the cursor beyond the first/last row in the result |
| set leaves the cursor before/after the first/last row, respectively. |
| |
| Calling absolute( 1 ) is the same as calling first(). |
| |
| Calling absolute( -1 ) is the same as calling last(). |
| */ |
| if ( row < 0 ) |
| { |
| sal_Int32 nCount = m_pImpl->m_xDataSupplier->totalCount(); |
| |
| if ( ( row * -1 ) > nCount ) |
| { |
| osl::MutexGuard aGuard( m_pImpl->m_aMutex ); |
| m_pImpl->m_bAfterLast = sal_False; |
| m_pImpl->m_nPos = 0; |
| m_pImpl->m_xDataSupplier->validate(); |
| return sal_False; |
| } |
| else // |row| <= nCount |
| { |
| osl::MutexGuard aGuard( m_pImpl->m_aMutex ); |
| m_pImpl->m_bAfterLast = sal_False; |
| m_pImpl->m_nPos = ( nCount + row + 1 ); |
| m_pImpl->m_xDataSupplier->validate(); |
| return sal_True; |
| } |
| } |
| else if ( row == 0 ) |
| { |
| // @throws SQLException |
| // ... if row is 0 ... |
| throw sdbc::SQLException(); |
| } |
| else // row > 0 |
| { |
| sal_Int32 nCount = m_pImpl->m_xDataSupplier->totalCount(); |
| |
| if ( row <= nCount ) |
| { |
| osl::MutexGuard aGuard( m_pImpl->m_aMutex ); |
| m_pImpl->m_bAfterLast = sal_False; |
| m_pImpl->m_nPos = row; |
| m_pImpl->m_xDataSupplier->validate(); |
| return sal_True; |
| } |
| else // row > nCount |
| { |
| osl::MutexGuard aGuard( m_pImpl->m_aMutex ); |
| m_pImpl->m_bAfterLast = sal_True; |
| m_pImpl->m_xDataSupplier->validate(); |
| return sal_False; |
| } |
| } |
| |
| // unreachable... |
| } |
| |
| //========================================================================= |
| // virtual |
| sal_Bool SAL_CALL ResultSet::relative( sal_Int32 rows ) |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| /* |
| Attempting to move beyond the first/last row in the result set |
| positions the cursor before/after the the first/last row. |
| |
| Calling relative( 0 ) is valid, but does not change the cursor position. |
| |
| Calling relative( 1 ) is different from calling next() because it makes |
| sense to call next() when there is no current row, for example, when |
| the cursor is positioned before the first row or after the last row of |
| the result set. |
| */ |
| if ( m_pImpl->m_bAfterLast || ( m_pImpl->m_nPos == 0 ) ) |
| { |
| // "No current row". |
| throw sdbc::SQLException(); |
| } |
| |
| if ( rows < 0 ) |
| { |
| if ( ( m_pImpl->m_nPos + rows ) > 0 ) |
| { |
| osl::MutexGuard aGuard( m_pImpl->m_aMutex ); |
| m_pImpl->m_bAfterLast = sal_False; |
| m_pImpl->m_nPos = ( m_pImpl->m_nPos + rows ); |
| m_pImpl->m_xDataSupplier->validate(); |
| return sal_True; |
| } |
| else |
| { |
| osl::MutexGuard aGuard( m_pImpl->m_aMutex ); |
| m_pImpl->m_bAfterLast = sal_False; |
| m_pImpl->m_nPos = 0; |
| m_pImpl->m_xDataSupplier->validate(); |
| return sal_False; |
| } |
| } |
| else if ( rows == 0 ) |
| { |
| // nop. |
| m_pImpl->m_xDataSupplier->validate(); |
| return sal_True; |
| } |
| else // rows > 0 |
| { |
| sal_Int32 nCount = m_pImpl->m_xDataSupplier->totalCount(); |
| if ( ( m_pImpl->m_nPos + rows ) <= nCount ) |
| { |
| osl::MutexGuard aGuard( m_pImpl->m_aMutex ); |
| m_pImpl->m_bAfterLast = sal_False; |
| m_pImpl->m_nPos = ( m_pImpl->m_nPos + rows ); |
| m_pImpl->m_xDataSupplier->validate(); |
| return sal_True; |
| } |
| else |
| { |
| osl::MutexGuard aGuard( m_pImpl->m_aMutex ); |
| m_pImpl->m_bAfterLast = sal_True; |
| m_pImpl->m_xDataSupplier->validate(); |
| return sal_False; |
| } |
| } |
| |
| // unreachable... |
| } |
| |
| //========================================================================= |
| // virtual |
| sal_Bool SAL_CALL ResultSet::previous() |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| /* |
| previous() is not the same as relative( -1 ) because it makes sense |
| to call previous() when there is no current row. |
| */ |
| osl::MutexGuard aGuard( m_pImpl->m_aMutex ); |
| |
| if ( m_pImpl->m_bAfterLast ) |
| { |
| m_pImpl->m_bAfterLast = sal_False; |
| sal_Int32 nCount = m_pImpl->m_xDataSupplier->totalCount(); |
| m_pImpl->m_nPos = nCount; |
| } |
| else if ( m_pImpl->m_nPos ) |
| m_pImpl->m_nPos--; |
| |
| if ( m_pImpl->m_nPos ) |
| { |
| m_pImpl->m_xDataSupplier->validate(); |
| return sal_True; |
| } |
| |
| m_pImpl->m_xDataSupplier->validate(); |
| return sal_False; |
| } |
| |
| //========================================================================= |
| // virtual |
| void SAL_CALL ResultSet::refreshRow() |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| osl::MutexGuard aGuard( m_pImpl->m_aMutex ); |
| if ( m_pImpl->m_bAfterLast || ( m_pImpl->m_nPos == 0 ) ) |
| return; |
| |
| m_pImpl->m_xDataSupplier->releasePropertyValues( m_pImpl->m_nPos ); |
| m_pImpl->m_xDataSupplier->validate(); |
| } |
| |
| //========================================================================= |
| // virtual |
| sal_Bool SAL_CALL ResultSet::rowUpdated() |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| m_pImpl->m_xDataSupplier->validate(); |
| return sal_False; |
| } |
| |
| //========================================================================= |
| // virtual |
| sal_Bool SAL_CALL ResultSet::rowInserted() |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| m_pImpl->m_xDataSupplier->validate(); |
| return sal_False; |
| } |
| |
| //========================================================================= |
| // virtual |
| sal_Bool SAL_CALL ResultSet::rowDeleted() |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| m_pImpl->m_xDataSupplier->validate(); |
| return sal_False; |
| } |
| |
| //========================================================================= |
| // virtual |
| uno::Reference< uno::XInterface > SAL_CALL ResultSet::getStatement() |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| /* |
| returns the Statement that produced this ResultSet object. If the |
| result set was generated some other way, ... this method returns null. |
| */ |
| m_pImpl->m_xDataSupplier->validate(); |
| return uno::Reference< uno::XInterface >(); |
| } |
| |
| //========================================================================= |
| // |
| // XRow methods. |
| // |
| //========================================================================= |
| |
| // virtual |
| sal_Bool SAL_CALL ResultSet::wasNull() |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| // This method can not be implemented correctly!!! Imagine different |
| // threads doing a getXYZ - wasNull calling sequence on the same |
| // implementation object... |
| |
| if ( m_pImpl->m_nPos && !m_pImpl->m_bAfterLast ) |
| { |
| uno::Reference< sdbc::XRow > xValues |
| = m_pImpl->m_xDataSupplier->queryPropertyValues( |
| m_pImpl->m_nPos - 1 ); |
| if ( xValues.is() ) |
| { |
| m_pImpl->m_xDataSupplier->validate(); |
| return xValues->wasNull(); |
| } |
| } |
| |
| m_pImpl->m_xDataSupplier->validate(); |
| return m_pImpl->m_bWasNull; |
| } |
| |
| //========================================================================= |
| // virtual |
| rtl::OUString SAL_CALL ResultSet::getString( sal_Int32 columnIndex ) |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| if ( m_pImpl->m_nPos && !m_pImpl->m_bAfterLast ) |
| { |
| uno::Reference< sdbc::XRow > xValues |
| = m_pImpl->m_xDataSupplier->queryPropertyValues( |
| m_pImpl->m_nPos - 1 ); |
| if ( xValues.is() ) |
| { |
| m_pImpl->m_bWasNull = sal_False; |
| m_pImpl->m_xDataSupplier->validate(); |
| return xValues->getString( columnIndex ); |
| } |
| } |
| |
| m_pImpl->m_bWasNull = sal_True; |
| m_pImpl->m_xDataSupplier->validate(); |
| return rtl::OUString(); |
| } |
| |
| //========================================================================= |
| // virtual |
| sal_Bool SAL_CALL ResultSet::getBoolean( sal_Int32 columnIndex ) |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| if ( m_pImpl->m_nPos && !m_pImpl->m_bAfterLast ) |
| { |
| uno::Reference< sdbc::XRow > xValues |
| = m_pImpl->m_xDataSupplier->queryPropertyValues( |
| m_pImpl->m_nPos - 1 ); |
| if ( xValues.is() ) |
| { |
| m_pImpl->m_bWasNull = sal_False; |
| m_pImpl->m_xDataSupplier->validate(); |
| return xValues->getBoolean( columnIndex ); |
| } |
| } |
| |
| m_pImpl->m_bWasNull = sal_True; |
| m_pImpl->m_xDataSupplier->validate(); |
| return sal_False; |
| } |
| |
| //========================================================================= |
| // virtual |
| sal_Int8 SAL_CALL ResultSet::getByte( sal_Int32 columnIndex ) |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| if ( m_pImpl->m_nPos && !m_pImpl->m_bAfterLast ) |
| { |
| uno::Reference< sdbc::XRow > xValues |
| = m_pImpl->m_xDataSupplier->queryPropertyValues( |
| m_pImpl->m_nPos - 1 ); |
| if ( xValues.is() ) |
| { |
| m_pImpl->m_bWasNull = sal_False; |
| m_pImpl->m_xDataSupplier->validate(); |
| return xValues->getByte( columnIndex ); |
| } |
| } |
| |
| m_pImpl->m_bWasNull = sal_True; |
| m_pImpl->m_xDataSupplier->validate(); |
| return 0; |
| } |
| |
| //========================================================================= |
| // virtual |
| sal_Int16 SAL_CALL ResultSet::getShort( sal_Int32 columnIndex ) |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| if ( m_pImpl->m_nPos && !m_pImpl->m_bAfterLast ) |
| { |
| uno::Reference< sdbc::XRow > xValues |
| = m_pImpl->m_xDataSupplier->queryPropertyValues( |
| m_pImpl->m_nPos - 1 ); |
| if ( xValues.is() ) |
| { |
| m_pImpl->m_bWasNull = sal_False; |
| m_pImpl->m_xDataSupplier->validate(); |
| return xValues->getShort( columnIndex ); |
| } |
| } |
| |
| m_pImpl->m_bWasNull = sal_True; |
| m_pImpl->m_xDataSupplier->validate(); |
| return 0; |
| } |
| |
| //========================================================================= |
| // virtual |
| sal_Int32 SAL_CALL ResultSet::getInt( sal_Int32 columnIndex ) |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| if ( m_pImpl->m_nPos && !m_pImpl->m_bAfterLast ) |
| { |
| uno::Reference< sdbc::XRow > xValues |
| = m_pImpl->m_xDataSupplier->queryPropertyValues( |
| m_pImpl->m_nPos - 1 ); |
| if ( xValues.is() ) |
| { |
| m_pImpl->m_bWasNull = sal_False; |
| m_pImpl->m_xDataSupplier->validate(); |
| return xValues->getInt( columnIndex ); |
| } |
| } |
| |
| m_pImpl->m_bWasNull = sal_True; |
| m_pImpl->m_xDataSupplier->validate(); |
| return 0; |
| } |
| |
| //========================================================================= |
| // virtual |
| sal_Int64 SAL_CALL ResultSet::getLong( sal_Int32 columnIndex ) |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| if ( m_pImpl->m_nPos && !m_pImpl->m_bAfterLast ) |
| { |
| uno::Reference< sdbc::XRow > xValues |
| = m_pImpl->m_xDataSupplier->queryPropertyValues( |
| m_pImpl->m_nPos - 1 ); |
| if ( xValues.is() ) |
| { |
| m_pImpl->m_bWasNull = sal_False; |
| m_pImpl->m_xDataSupplier->validate(); |
| return xValues->getLong( columnIndex ); |
| } |
| } |
| |
| m_pImpl->m_bWasNull = sal_True; |
| m_pImpl->m_xDataSupplier->validate(); |
| return 0; |
| } |
| |
| //========================================================================= |
| // virtual |
| float SAL_CALL ResultSet::getFloat( sal_Int32 columnIndex ) |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| if ( m_pImpl->m_nPos && !m_pImpl->m_bAfterLast ) |
| { |
| uno::Reference< sdbc::XRow > xValues |
| = m_pImpl->m_xDataSupplier->queryPropertyValues( |
| m_pImpl->m_nPos - 1 ); |
| if ( xValues.is() ) |
| { |
| m_pImpl->m_bWasNull = sal_False; |
| m_pImpl->m_xDataSupplier->validate(); |
| return xValues->getFloat( columnIndex ); |
| } |
| } |
| |
| m_pImpl->m_bWasNull = sal_True; |
| m_pImpl->m_xDataSupplier->validate(); |
| return 0; |
| } |
| |
| //========================================================================= |
| // virtual |
| double SAL_CALL ResultSet::getDouble( sal_Int32 columnIndex ) |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| if ( m_pImpl->m_nPos && !m_pImpl->m_bAfterLast ) |
| { |
| uno::Reference< sdbc::XRow > xValues |
| = m_pImpl->m_xDataSupplier->queryPropertyValues( |
| m_pImpl->m_nPos - 1 ); |
| if ( xValues.is() ) |
| { |
| m_pImpl->m_bWasNull = sal_False; |
| m_pImpl->m_xDataSupplier->validate(); |
| return xValues->getDouble( columnIndex ); |
| } |
| } |
| |
| m_pImpl->m_bWasNull = sal_True; |
| m_pImpl->m_xDataSupplier->validate(); |
| return 0; |
| } |
| |
| //========================================================================= |
| // virtual |
| uno::Sequence< sal_Int8 > SAL_CALL |
| ResultSet::getBytes( sal_Int32 columnIndex ) |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| if ( m_pImpl->m_nPos && !m_pImpl->m_bAfterLast ) |
| { |
| uno::Reference< sdbc::XRow > xValues |
| = m_pImpl->m_xDataSupplier->queryPropertyValues( |
| m_pImpl->m_nPos - 1 ); |
| if ( xValues.is() ) |
| { |
| m_pImpl->m_bWasNull = sal_False; |
| m_pImpl->m_xDataSupplier->validate(); |
| return xValues->getBytes( columnIndex ); |
| } |
| } |
| |
| m_pImpl->m_bWasNull = sal_True; |
| m_pImpl->m_xDataSupplier->validate(); |
| return uno::Sequence< sal_Int8 >(); |
| } |
| |
| //========================================================================= |
| // virtual |
| util::Date SAL_CALL ResultSet::getDate( sal_Int32 columnIndex ) |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| if ( m_pImpl->m_nPos && !m_pImpl->m_bAfterLast ) |
| { |
| uno::Reference< sdbc::XRow > xValues |
| = m_pImpl->m_xDataSupplier->queryPropertyValues( |
| m_pImpl->m_nPos - 1 ); |
| if ( xValues.is() ) |
| { |
| m_pImpl->m_bWasNull = sal_False; |
| m_pImpl->m_xDataSupplier->validate(); |
| return xValues->getDate( columnIndex ); |
| } |
| } |
| |
| m_pImpl->m_bWasNull = sal_True; |
| m_pImpl->m_xDataSupplier->validate(); |
| return util::Date(); |
| } |
| |
| //========================================================================= |
| // virtual |
| util::Time SAL_CALL ResultSet::getTime( sal_Int32 columnIndex ) |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| if ( m_pImpl->m_nPos && !m_pImpl->m_bAfterLast ) |
| { |
| uno::Reference< sdbc::XRow > xValues |
| = m_pImpl->m_xDataSupplier->queryPropertyValues( |
| m_pImpl->m_nPos - 1 ); |
| if ( xValues.is() ) |
| { |
| m_pImpl->m_bWasNull = sal_False; |
| m_pImpl->m_xDataSupplier->validate(); |
| return xValues->getTime( columnIndex ); |
| } |
| } |
| |
| m_pImpl->m_bWasNull = sal_True; |
| m_pImpl->m_xDataSupplier->validate(); |
| return util::Time(); |
| } |
| |
| //========================================================================= |
| // virtual |
| util::DateTime SAL_CALL |
| ResultSet::getTimestamp( sal_Int32 columnIndex ) |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| if ( m_pImpl->m_nPos && !m_pImpl->m_bAfterLast ) |
| { |
| uno::Reference< sdbc::XRow > xValues |
| = m_pImpl->m_xDataSupplier->queryPropertyValues( |
| m_pImpl->m_nPos - 1 ); |
| if ( xValues.is() ) |
| { |
| m_pImpl->m_bWasNull = sal_False; |
| m_pImpl->m_xDataSupplier->validate(); |
| return xValues->getTimestamp( columnIndex ); |
| } |
| } |
| |
| m_pImpl->m_bWasNull = sal_True; |
| m_pImpl->m_xDataSupplier->validate(); |
| return util::DateTime(); |
| } |
| |
| //========================================================================= |
| // virtual |
| uno::Reference< io::XInputStream > SAL_CALL |
| ResultSet::getBinaryStream( sal_Int32 columnIndex ) |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| if ( m_pImpl->m_nPos && !m_pImpl->m_bAfterLast ) |
| { |
| uno::Reference< sdbc::XRow > xValues |
| = m_pImpl->m_xDataSupplier->queryPropertyValues( |
| m_pImpl->m_nPos - 1 ); |
| if ( xValues.is() ) |
| { |
| m_pImpl->m_bWasNull = sal_False; |
| m_pImpl->m_xDataSupplier->validate(); |
| return xValues->getBinaryStream( columnIndex ); |
| } |
| } |
| |
| m_pImpl->m_bWasNull = sal_True; |
| m_pImpl->m_xDataSupplier->validate(); |
| return uno::Reference< io::XInputStream >(); |
| } |
| |
| //========================================================================= |
| // virtual |
| uno::Reference< io::XInputStream > SAL_CALL |
| ResultSet::getCharacterStream( sal_Int32 columnIndex ) |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| if ( m_pImpl->m_nPos && !m_pImpl->m_bAfterLast ) |
| { |
| uno::Reference< sdbc::XRow > xValues |
| = m_pImpl->m_xDataSupplier->queryPropertyValues( |
| m_pImpl->m_nPos - 1 ); |
| if ( xValues.is() ) |
| { |
| m_pImpl->m_bWasNull = sal_False; |
| m_pImpl->m_xDataSupplier->validate(); |
| return xValues->getCharacterStream( columnIndex ); |
| } |
| } |
| |
| m_pImpl->m_bWasNull = sal_True; |
| m_pImpl->m_xDataSupplier->validate(); |
| return uno::Reference< io::XInputStream >(); |
| } |
| |
| //========================================================================= |
| // virtual |
| uno::Any SAL_CALL ResultSet::getObject( |
| sal_Int32 columnIndex, |
| const uno::Reference< container::XNameAccess >& typeMap ) |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| if ( m_pImpl->m_nPos && !m_pImpl->m_bAfterLast ) |
| { |
| uno::Reference< sdbc::XRow > xValues |
| = m_pImpl->m_xDataSupplier->queryPropertyValues( |
| m_pImpl->m_nPos - 1 ); |
| if ( xValues.is() ) |
| { |
| m_pImpl->m_bWasNull = sal_False; |
| m_pImpl->m_xDataSupplier->validate(); |
| return xValues->getObject( columnIndex, typeMap ); |
| } |
| } |
| |
| m_pImpl->m_bWasNull = sal_True; |
| m_pImpl->m_xDataSupplier->validate(); |
| return uno::Any(); |
| } |
| |
| //========================================================================= |
| // virtual |
| uno::Reference< sdbc::XRef > SAL_CALL |
| ResultSet::getRef( sal_Int32 columnIndex ) |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| if ( m_pImpl->m_nPos && !m_pImpl->m_bAfterLast ) |
| { |
| uno::Reference< sdbc::XRow > xValues |
| = m_pImpl->m_xDataSupplier->queryPropertyValues( |
| m_pImpl->m_nPos - 1 ); |
| if ( xValues.is() ) |
| { |
| m_pImpl->m_bWasNull = sal_False; |
| m_pImpl->m_xDataSupplier->validate(); |
| return xValues->getRef( columnIndex ); |
| } |
| } |
| |
| m_pImpl->m_bWasNull = sal_True; |
| m_pImpl->m_xDataSupplier->validate(); |
| return uno::Reference< sdbc::XRef >(); |
| } |
| |
| //========================================================================= |
| // virtual |
| uno::Reference< sdbc::XBlob > SAL_CALL |
| ResultSet::getBlob( sal_Int32 columnIndex ) |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| if ( m_pImpl->m_nPos && !m_pImpl->m_bAfterLast ) |
| { |
| uno::Reference< sdbc::XRow > xValues |
| = m_pImpl->m_xDataSupplier->queryPropertyValues( |
| m_pImpl->m_nPos - 1 ); |
| if ( xValues.is() ) |
| { |
| m_pImpl->m_bWasNull = sal_False; |
| m_pImpl->m_xDataSupplier->validate(); |
| return xValues->getBlob( columnIndex ); |
| } |
| } |
| |
| m_pImpl->m_bWasNull = sal_True; |
| m_pImpl->m_xDataSupplier->validate(); |
| return uno::Reference< sdbc::XBlob >(); |
| } |
| |
| //========================================================================= |
| // virtual |
| uno::Reference< sdbc::XClob > SAL_CALL |
| ResultSet::getClob( sal_Int32 columnIndex ) |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| if ( m_pImpl->m_nPos && !m_pImpl->m_bAfterLast ) |
| { |
| uno::Reference< sdbc::XRow > xValues |
| = m_pImpl->m_xDataSupplier->queryPropertyValues( |
| m_pImpl->m_nPos - 1 ); |
| if ( xValues.is() ) |
| { |
| m_pImpl->m_bWasNull = sal_False; |
| m_pImpl->m_xDataSupplier->validate(); |
| return xValues->getClob( columnIndex ); |
| } |
| } |
| |
| m_pImpl->m_bWasNull = sal_True; |
| m_pImpl->m_xDataSupplier->validate(); |
| return uno::Reference< sdbc::XClob >(); |
| } |
| |
| //========================================================================= |
| // virtual |
| uno::Reference< sdbc::XArray > SAL_CALL |
| ResultSet::getArray( sal_Int32 columnIndex ) |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| if ( m_pImpl->m_nPos && !m_pImpl->m_bAfterLast ) |
| { |
| uno::Reference< sdbc::XRow > xValues |
| = m_pImpl->m_xDataSupplier->queryPropertyValues( |
| m_pImpl->m_nPos - 1 ); |
| if ( xValues.is() ) |
| { |
| m_pImpl->m_bWasNull = sal_False; |
| m_pImpl->m_xDataSupplier->validate(); |
| return xValues->getArray( columnIndex ); |
| } |
| } |
| |
| m_pImpl->m_bWasNull = sal_True; |
| m_pImpl->m_xDataSupplier->validate(); |
| return uno::Reference< sdbc::XArray >(); |
| } |
| |
| //========================================================================= |
| // |
| // XCloseable methods. |
| // |
| //========================================================================= |
| |
| // virtual |
| void SAL_CALL ResultSet::close() |
| throw( sdbc::SQLException, uno::RuntimeException ) |
| { |
| m_pImpl->m_xDataSupplier->close(); |
| m_pImpl->m_xDataSupplier->validate(); |
| } |
| |
| //========================================================================= |
| // |
| // XContentAccess methods. |
| // |
| //========================================================================= |
| |
| // virtual |
| rtl::OUString SAL_CALL ResultSet::queryContentIdentifierString() |
| throw( uno::RuntimeException ) |
| { |
| if ( m_pImpl->m_nPos && !m_pImpl->m_bAfterLast ) |
| return m_pImpl->m_xDataSupplier->queryContentIdentifierString( |
| m_pImpl->m_nPos - 1 ); |
| |
| return rtl::OUString(); |
| } |
| |
| //========================================================================= |
| // virtual |
| uno::Reference< com::sun::star::ucb::XContentIdentifier > SAL_CALL |
| ResultSet::queryContentIdentifier() |
| throw( uno::RuntimeException ) |
| { |
| if ( m_pImpl->m_nPos && !m_pImpl->m_bAfterLast ) |
| return m_pImpl->m_xDataSupplier->queryContentIdentifier( |
| m_pImpl->m_nPos - 1 ); |
| |
| return uno::Reference< com::sun::star::ucb::XContentIdentifier >(); |
| } |
| |
| //========================================================================= |
| // virtual |
| uno::Reference< com::sun::star::ucb::XContent > SAL_CALL |
| ResultSet::queryContent() |
| throw( uno::RuntimeException ) |
| { |
| if ( m_pImpl->m_nPos && !m_pImpl->m_bAfterLast ) |
| return m_pImpl->m_xDataSupplier->queryContent( m_pImpl->m_nPos - 1 ); |
| |
| return uno::Reference< com::sun::star::ucb::XContent >(); |
| } |
| |
| //========================================================================= |
| // |
| // XPropertySet methods. |
| // |
| //========================================================================= |
| |
| // virtual |
| uno::Reference< beans::XPropertySetInfo > SAL_CALL |
| ResultSet::getPropertySetInfo() |
| throw( uno::RuntimeException ) |
| { |
| osl::MutexGuard aGuard( m_pImpl->m_aMutex ); |
| |
| if ( !m_pImpl->m_xPropSetInfo.is() ) |
| m_pImpl->m_xPropSetInfo |
| = new PropertySetInfo( m_pImpl->m_xSMgr, |
| aPropertyTable, |
| RESULTSET_PROPERTY_COUNT ); |
| return m_pImpl->m_xPropSetInfo; |
| } |
| |
| //========================================================================= |
| // virtual |
| void SAL_CALL ResultSet::setPropertyValue( const rtl::OUString& aPropertyName, |
| const uno::Any& ) |
| throw( beans::UnknownPropertyException, |
| beans::PropertyVetoException, |
| lang::IllegalArgumentException, |
| lang::WrappedTargetException, |
| uno::RuntimeException ) |
| { |
| if ( !aPropertyName.getLength() ) |
| throw beans::UnknownPropertyException(); |
| |
| if ( aPropertyName.equals( |
| rtl::OUString::createFromAscii( "RowCount" ) ) ) |
| { |
| // property is read-only. |
| throw lang::IllegalArgumentException(); |
| } |
| else if ( aPropertyName.equals( |
| rtl::OUString::createFromAscii( "IsRowCountFinal" ) ) ) |
| { |
| // property is read-only. |
| throw lang::IllegalArgumentException(); |
| } |
| else |
| { |
| throw beans::UnknownPropertyException(); |
| } |
| } |
| |
| //========================================================================= |
| // virtual |
| uno::Any SAL_CALL ResultSet::getPropertyValue( |
| const rtl::OUString& PropertyName ) |
| throw( beans::UnknownPropertyException, |
| lang::WrappedTargetException, |
| uno::RuntimeException ) |
| { |
| if ( !PropertyName.getLength() ) |
| throw beans::UnknownPropertyException(); |
| |
| uno::Any aValue; |
| |
| if ( PropertyName.equals( |
| rtl::OUString::createFromAscii( "RowCount" ) ) ) |
| { |
| aValue <<= m_pImpl->m_xDataSupplier->currentCount(); |
| } |
| else if ( PropertyName.equals( |
| rtl::OUString::createFromAscii( "IsRowCountFinal" ) ) ) |
| { |
| aValue <<= m_pImpl->m_xDataSupplier->isCountFinal(); |
| } |
| else |
| { |
| throw beans::UnknownPropertyException(); |
| } |
| |
| return aValue; |
| } |
| |
| //========================================================================= |
| // virtual |
| void SAL_CALL ResultSet::addPropertyChangeListener( |
| const rtl::OUString& aPropertyName, |
| const uno::Reference< beans::XPropertyChangeListener >& xListener ) |
| throw( beans::UnknownPropertyException, |
| lang::WrappedTargetException, |
| uno::RuntimeException ) |
| { |
| // Note: An empty property name means a listener for "all" properties. |
| |
| osl::MutexGuard aGuard( m_pImpl->m_aMutex ); |
| |
| if ( aPropertyName.getLength() && |
| !aPropertyName.equals( |
| rtl::OUString::createFromAscii( "RowCount" ) ) && |
| !aPropertyName.equals( |
| rtl::OUString::createFromAscii( "IsRowCountFinal" ) ) ) |
| throw beans::UnknownPropertyException(); |
| |
| if ( !m_pImpl->m_pPropertyChangeListeners ) |
| m_pImpl->m_pPropertyChangeListeners |
| = new PropertyChangeListeners( m_pImpl->m_aMutex ); |
| |
| m_pImpl->m_pPropertyChangeListeners->addInterface( |
| aPropertyName, xListener ); |
| } |
| |
| //========================================================================= |
| // virtual |
| void SAL_CALL ResultSet::removePropertyChangeListener( |
| const rtl::OUString& aPropertyName, |
| const uno::Reference< beans::XPropertyChangeListener >& xListener ) |
| throw( beans::UnknownPropertyException, |
| lang::WrappedTargetException, |
| uno::RuntimeException ) |
| { |
| osl::MutexGuard aGuard( m_pImpl->m_aMutex ); |
| |
| if ( aPropertyName.getLength() && |
| !aPropertyName.equals( |
| rtl::OUString::createFromAscii( "RowCount" ) ) && |
| !aPropertyName.equals( |
| rtl::OUString::createFromAscii( "IsRowCountFinal" ) ) ) |
| throw beans::UnknownPropertyException(); |
| |
| if ( m_pImpl->m_pPropertyChangeListeners ) |
| m_pImpl->m_pPropertyChangeListeners->removeInterface( |
| aPropertyName, xListener ); |
| |
| } |
| |
| //========================================================================= |
| // virtual |
| void SAL_CALL ResultSet::addVetoableChangeListener( |
| const rtl::OUString&, |
| const uno::Reference< beans::XVetoableChangeListener >& ) |
| throw( beans::UnknownPropertyException, |
| lang::WrappedTargetException, |
| uno::RuntimeException ) |
| { |
| // No constrained props, at the moment. |
| } |
| |
| //========================================================================= |
| // virtual |
| void SAL_CALL ResultSet::removeVetoableChangeListener( |
| const rtl::OUString&, |
| const uno::Reference< beans::XVetoableChangeListener >& ) |
| throw( beans::UnknownPropertyException, |
| lang::WrappedTargetException, |
| uno::RuntimeException ) |
| { |
| // No constrained props, at the moment. |
| } |
| |
| //========================================================================= |
| // |
| // Non-interface methods. |
| // |
| //========================================================================= |
| |
| void ResultSet::propertyChanged( const beans::PropertyChangeEvent& rEvt ) |
| { |
| if ( !m_pImpl->m_pPropertyChangeListeners ) |
| return; |
| |
| // Notify listeners interested especially in the changed property. |
| cppu::OInterfaceContainerHelper* pPropsContainer |
| = m_pImpl->m_pPropertyChangeListeners->getContainer( |
| rEvt.PropertyName ); |
| if ( pPropsContainer ) |
| { |
| cppu::OInterfaceIteratorHelper aIter( *pPropsContainer ); |
| while ( aIter.hasMoreElements() ) |
| { |
| uno::Reference< beans::XPropertyChangeListener > xListener( |
| aIter.next(), uno::UNO_QUERY ); |
| if ( xListener.is() ) |
| xListener->propertyChange( rEvt ); |
| } |
| } |
| |
| // Notify listeners interested in all properties. |
| pPropsContainer |
| = m_pImpl->m_pPropertyChangeListeners->getContainer( rtl::OUString() ); |
| if ( pPropsContainer ) |
| { |
| cppu::OInterfaceIteratorHelper aIter( *pPropsContainer ); |
| while ( aIter.hasMoreElements() ) |
| { |
| uno::Reference< beans::XPropertyChangeListener > xListener( |
| aIter.next(), uno::UNO_QUERY ); |
| if ( xListener.is() ) |
| xListener->propertyChange( rEvt ); |
| } |
| } |
| } |
| |
| //========================================================================= |
| void ResultSet::rowCountChanged( sal_uInt32 nOld, sal_uInt32 nNew ) |
| { |
| OSL_ENSURE( nOld < nNew, "ResultSet::rowCountChanged - nOld >= nNew!" ); |
| |
| if ( !m_pImpl->m_pPropertyChangeListeners ) |
| return; |
| |
| propertyChanged( |
| beans::PropertyChangeEvent( |
| static_cast< cppu::OWeakObject * >( this ), |
| rtl::OUString::createFromAscii( "RowCount" ), |
| sal_False, |
| 1001, |
| uno::makeAny( nOld ), // old value |
| uno::makeAny( nNew ) ) ); // new value |
| } |
| |
| //========================================================================= |
| void ResultSet::rowCountFinal() |
| { |
| if ( !m_pImpl->m_pPropertyChangeListeners ) |
| return; |
| |
| propertyChanged( |
| beans::PropertyChangeEvent( |
| static_cast< cppu::OWeakObject * >( this ), |
| rtl::OUString::createFromAscii( "IsRowCountFinal" ), |
| sal_False, |
| 1000, |
| uno:: makeAny( sal_False ), // old value |
| uno::makeAny( sal_True ) ) ); // new value |
| } |
| |
| //========================================================================= |
| const uno::Sequence< beans::Property >& ResultSet::getProperties() |
| { |
| return m_pImpl->m_aProperties; |
| } |
| |
| //========================================================================= |
| const uno::Reference< com::sun::star::ucb::XCommandEnvironment >& |
| ResultSet::getEnvironment() |
| { |
| return m_pImpl->m_xEnv; |
| } |
| |
| } // namespace ucbhelper |
| |
| namespace ucbhelper_impl { |
| |
| //========================================================================= |
| //========================================================================= |
| // |
| // PropertySetInfo Implementation. |
| // |
| //========================================================================= |
| //========================================================================= |
| |
| PropertySetInfo::PropertySetInfo( |
| const uno::Reference< lang::XMultiServiceFactory >& rxSMgr, |
| const PropertyInfo* pProps, |
| sal_Int32 nProps ) |
| : m_xSMgr( rxSMgr ) |
| { |
| m_pProps = new uno::Sequence< beans::Property >( nProps ); |
| |
| if ( nProps ) |
| { |
| const PropertyInfo* pEntry = pProps; |
| beans::Property* pProperties = m_pProps->getArray(); |
| |
| for ( sal_Int32 n = 0; n < nProps; ++n ) |
| { |
| beans::Property& rProp = pProperties[ n ]; |
| |
| rProp.Name = rtl::OUString::createFromAscii( pEntry->pName ); |
| rProp.Handle = pEntry->nHandle; |
| rProp.Type = pEntry->pGetCppuType(); |
| rProp.Attributes = pEntry->nAttributes; |
| |
| pEntry++; |
| } |
| } |
| } |
| |
| //========================================================================= |
| // virtual |
| PropertySetInfo::~PropertySetInfo() |
| { |
| delete m_pProps; |
| } |
| |
| //========================================================================= |
| // |
| // XInterface methods. |
| // |
| //========================================================================= |
| |
| XINTERFACE_IMPL_2( PropertySetInfo, |
| lang::XTypeProvider, |
| beans::XPropertySetInfo ); |
| |
| //========================================================================= |
| // |
| // XTypeProvider methods. |
| // |
| //========================================================================= |
| |
| XTYPEPROVIDER_IMPL_2( PropertySetInfo, |
| lang::XTypeProvider, |
| beans::XPropertySetInfo ); |
| |
| //========================================================================= |
| // |
| // XPropertySetInfo methods. |
| // |
| //========================================================================= |
| |
| // virtual |
| uno::Sequence< beans::Property > SAL_CALL PropertySetInfo::getProperties() |
| throw( uno::RuntimeException ) |
| { |
| return uno::Sequence< beans::Property >( *m_pProps ); |
| } |
| |
| //========================================================================= |
| // virtual |
| beans::Property SAL_CALL PropertySetInfo::getPropertyByName( |
| const rtl::OUString& aName ) |
| throw( beans::UnknownPropertyException, uno::RuntimeException ) |
| { |
| beans::Property aProp; |
| if ( queryProperty( aName, aProp ) ) |
| return aProp; |
| |
| throw beans::UnknownPropertyException(); |
| } |
| |
| //========================================================================= |
| // virtual |
| sal_Bool SAL_CALL PropertySetInfo::hasPropertyByName( |
| const rtl::OUString& Name ) |
| throw( uno::RuntimeException ) |
| { |
| beans::Property aProp; |
| return queryProperty( Name, aProp ); |
| } |
| |
| //========================================================================= |
| sal_Bool PropertySetInfo::queryProperty( |
| const rtl::OUString& aName, beans::Property& rProp ) |
| { |
| sal_Int32 nCount = m_pProps->getLength(); |
| const beans::Property* pProps = m_pProps->getConstArray(); |
| for ( sal_Int32 n = 0; n < nCount; ++n ) |
| { |
| const beans::Property& rCurr = pProps[ n ]; |
| if ( rCurr.Name == aName ) |
| { |
| rProp = rCurr; |
| return sal_True; |
| } |
| } |
| |
| return sal_False; |
| } |
| |
| } // namespace ucbhelper_impl |