diff options
Diffstat (limited to 'ucb/source/sorter/sortresult.hxx')
| -rw-r--r-- | ucb/source/sorter/sortresult.hxx | 455 |
1 files changed, 455 insertions, 0 deletions
diff --git a/ucb/source/sorter/sortresult.hxx b/ucb/source/sorter/sortresult.hxx new file mode 100644 index 000000000000..3817152f3d6c --- /dev/null +++ b/ucb/source/sorter/sortresult.hxx @@ -0,0 +1,455 @@ +/************************************************************************* + * + * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. + * + * Copyright 2000, 2010 Oracle and/or its affiliates. + * + * OpenOffice.org - a multi-platform office productivity suite + * + * This file is part of OpenOffice.org. + * + * OpenOffice.org is free software: you can redistribute it and/or modify + * it under the terms of the GNU Lesser General Public License version 3 + * only, as published by the Free Software Foundation. + * + * OpenOffice.org is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU Lesser General Public License version 3 for more details + * (a copy is included in the LICENSE file that accompanied this code). + * + * You should have received a copy of the GNU Lesser General Public License + * version 3 along with OpenOffice.org. If not, see + * <http://www.openoffice.org/license.html> + * for a copy of the LGPLv3 License. + * + ************************************************************************/ + +#ifndef _SORTRESULT_HXX +#define _SORTRESULT_HXX + +#include <com/sun/star/beans/XPropertySet.hpp> +#include <com/sun/star/lang/XMultiServiceFactory.hpp> +#include <com/sun/star/lang/XTypeProvider.hpp> +#include <com/sun/star/lang/XServiceInfo.hpp> +#include <com/sun/star/lang/XComponent.hpp> +#include <com/sun/star/sdbc/XCloseable.hpp> +#include <com/sun/star/sdbc/XResultSet.hpp> +#include <com/sun/star/sdbc/XResultSetMetaData.hpp> +#include <com/sun/star/sdbc/XResultSetMetaDataSupplier.hpp> +#include <com/sun/star/sdbc/XRow.hpp> +#include <com/sun/star/ucb/XContentAccess.hpp> +#include <com/sun/star/ucb/NumberedSortingInfo.hpp> +#include <com/sun/star/ucb/XAnyCompareFactory.hpp> +#include <com/sun/star/ucb/ListAction.hpp> +#include <cppuhelper/weak.hxx> +#include <osl/mutex.hxx> + +#include <deque> +#include <ucbhelper/macros.hxx> + +namespace cppu { + class OInterfaceContainerHelper; +} + +//----------------------------------------------------------------------------- +struct SortInfo; +struct SortListData; +class SRSPropertySetInfo; +class PropertyChangeListeners_Impl; + +//----------------------------------------------------------------------------- +class SortedEntryList +{ + std::deque < SortListData* > maData; + +public: + SortedEntryList(){} + ~SortedEntryList(){ Clear(); } + + sal_uInt32 Count() const { return (sal_uInt32) maData.size(); } + + void Clear(); + void Insert( SortListData *pEntry, long nPos ); + SortListData* Remove( long nPos ); + SortListData* GetData( long nPos ); + + long operator [] ( long nPos ) const; +}; + +//----------------------------------------------------------------------------- +#define LISTACTION com::sun::star::ucb::ListAction + +class EventList +{ + std::deque < LISTACTION* > maData; + +public: + EventList(){} + ~EventList(){ Clear(); } + + sal_uInt32 Count() { return (sal_uInt32) maData.size(); } + + void AddEvent( long nType, long nPos, long nCount ); + void Insert( LISTACTION *pAction ) { maData.push_back( pAction ); } + void Clear(); + LISTACTION* GetAction( long nIndex ) { return maData[ nIndex ]; } +}; + +//----------------------------------------------------------------------------- + +class SimpleList +{ + std::deque < void* > maData; + +public: + SimpleList(){} + ~SimpleList(){ Clear(); } + + sal_uInt32 Count() { return (sal_uInt32) maData.size(); } + void Clear() { maData.clear(); } + + void Remove( sal_uInt32 nPos ); + void Remove( void* pData ); + + void Append( void* pData ) + { maData.push_back( pData ); } + void Insert( void* pData, sal_uInt32 nPos ); + void* GetObject( sal_uInt32 nPos ) const; + void Replace( void* pData, sal_uInt32 nPos ); +}; + +//----------------------------------------------------------------------------- + +#define PROPERTYCHANGEEVENT com::sun::star::beans::PropertyChangeEvent +#define RUNTIME_EXCEPTION com::sun::star::uno::RuntimeException +#define REFERENCE com::sun::star::uno::Reference +#define SEQUENCE com::sun::star::uno::Sequence +#define XEVENTLISTENER com::sun::star::lang::XEventListener +#define XRESULTSET com::sun::star::sdbc::XResultSet +#define SQLEXCEPTION com::sun::star::sdbc::SQLException +#define XRESULTSETMETADATA com::sun::star::sdbc::XResultSetMetaData +#define NUMBERED_SORTINGINFO com::sun::star::ucb::NumberedSortingInfo +#define XANYCOMPAREFACTORY com::sun::star::ucb::XAnyCompareFactory + +#define RESULTSET_SERVICE_NAME "com.sun.star.ucb.SortedResultSet" + +//----------------------------------------------------------------------------- + +class SortedResultSet: + public cppu::OWeakObject, + public com::sun::star::lang::XTypeProvider, + public com::sun::star::lang::XServiceInfo, + public com::sun::star::lang::XComponent, + public com::sun::star::ucb::XContentAccess, + public XRESULTSET, + public com::sun::star::sdbc::XRow, + public com::sun::star::sdbc::XCloseable, + public com::sun::star::sdbc::XResultSetMetaDataSupplier, + public com::sun::star::beans::XPropertySet +{ + cppu::OInterfaceContainerHelper *mpDisposeEventListeners; + PropertyChangeListeners_Impl *mpPropChangeListeners; + PropertyChangeListeners_Impl *mpVetoChangeListeners; + + REFERENCE < XRESULTSET > mxOriginal; + REFERENCE < XRESULTSET > mxOther; + + SRSPropertySetInfo* mpPropSetInfo; + SortInfo* mpSortInfo; + osl::Mutex maMutex; + SortedEntryList maS2O; // maps the sorted entries to the original ones + SimpleList maO2S; // maps the original Entries to the sorted ones + SimpleList maModList; // keeps track of modified entries + long mnLastSort; // index of the last sorted entry; + long mnCurEntry; // index of the current entry + long mnCount; // total count of the elements + sal_Bool mbIsCopy; + + +private: + + long FindPos( SortListData *pEntry, long nStart, long nEnd ) + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + long Compare( SortListData *pOne, + SortListData *pTwo ) + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + void BuildSortInfo( REFERENCE< XRESULTSET > aResult, + const SEQUENCE < NUMBERED_SORTINGINFO > &xSortInfo, + const REFERENCE< XANYCOMPAREFACTORY > &xCompFac ); + long CompareImpl( REFERENCE < XRESULTSET > xResultOne, + REFERENCE < XRESULTSET > xResultTwo, + long nIndexOne, long nIndexTwo, + SortInfo* pSortInfo ) + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + long CompareImpl( REFERENCE < XRESULTSET > xResultOne, + REFERENCE < XRESULTSET > xResultTwo, + long nIndexOne, long nIndexTwo ) + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + void PropertyChanged( const PROPERTYCHANGEEVENT& rEvt ); + +public: + SortedResultSet( REFERENCE< XRESULTSET > aResult ); + ~SortedResultSet(); + + const SortedEntryList* GetS2OList() const { return &maS2O; } + const SimpleList* GetO2SList() const { return &maO2S; } + REFERENCE < XRESULTSET > GetResultSet() const { return mxOriginal; } + SortInfo* GetSortInfo() const { return mpSortInfo; } + long GetCount() const { return mnCount; } + + void CopyData( SortedResultSet* pSource ); + void Initialize( const SEQUENCE < NUMBERED_SORTINGINFO > &xSortInfo, + const REFERENCE< XANYCOMPAREFACTORY > &xCompFac ); + void CheckProperties( long nOldCount, sal_Bool bWasFinal ); + + void InsertNew( long nPos, long nCount ); + void SetChanged( long nPos, long nCount ); + void Remove( long nPos, long nCount, EventList *pList ); + void Move( long nPos, long nCount, long nOffset ); + + void ResortModified( EventList* pList ); + void ResortNew( EventList* pList ); + + // XInterface + XINTERFACE_DECL() + + // XTypeProvider + XTYPEPROVIDER_DECL() + + // XServiceInfo + XSERVICEINFO_NOFACTORY_DECL() + + // XComponent + virtual void SAL_CALL + dispose() throw( RUNTIME_EXCEPTION ); + + virtual void SAL_CALL + addEventListener( const REFERENCE< XEVENTLISTENER >& Listener ) + throw( RUNTIME_EXCEPTION ); + + virtual void SAL_CALL + removeEventListener( const REFERENCE< XEVENTLISTENER >& Listener ) + throw( RUNTIME_EXCEPTION ); + + // XContentAccess + virtual rtl::OUString SAL_CALL + queryContentIdentifierString() + throw( RUNTIME_EXCEPTION ); + virtual REFERENCE< + com::sun::star::ucb::XContentIdentifier > SAL_CALL + queryContentIdentifier() + throw( RUNTIME_EXCEPTION ); + virtual REFERENCE< + com::sun::star::ucb::XContent > SAL_CALL + queryContent() + throw( RUNTIME_EXCEPTION ); + + // XResultSet + virtual sal_Bool SAL_CALL + next() + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + virtual sal_Bool SAL_CALL + isBeforeFirst() + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + virtual sal_Bool SAL_CALL + isAfterLast() + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + virtual sal_Bool SAL_CALL + isFirst() + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + virtual sal_Bool SAL_CALL + isLast() + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + virtual void SAL_CALL + beforeFirst() + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + virtual void SAL_CALL + afterLast() + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + virtual sal_Bool SAL_CALL + first() + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + virtual sal_Bool SAL_CALL + last() + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + virtual sal_Int32 SAL_CALL + getRow() + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + virtual sal_Bool SAL_CALL + absolute( sal_Int32 row ) + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + virtual sal_Bool SAL_CALL + relative( sal_Int32 rows ) + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + virtual sal_Bool SAL_CALL + previous() + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + virtual void SAL_CALL + refreshRow() + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + virtual sal_Bool SAL_CALL + rowUpdated() + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + virtual sal_Bool SAL_CALL + rowInserted() + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + virtual sal_Bool SAL_CALL + rowDeleted() + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + virtual REFERENCE< + com::sun::star::uno::XInterface > SAL_CALL + getStatement() + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + + // XRow + virtual sal_Bool SAL_CALL + wasNull() throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + + virtual rtl::OUString SAL_CALL + getString( sal_Int32 columnIndex ) + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + + virtual sal_Bool SAL_CALL + getBoolean( sal_Int32 columnIndex ) + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + + virtual sal_Int8 SAL_CALL + getByte( sal_Int32 columnIndex ) + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + + virtual sal_Int16 SAL_CALL + getShort( sal_Int32 columnIndex ) + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + + virtual sal_Int32 SAL_CALL + getInt( sal_Int32 columnIndex ) + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + + virtual sal_Int64 SAL_CALL + getLong( sal_Int32 columnIndex ) + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + + virtual float SAL_CALL + getFloat( sal_Int32 columnIndex ) + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + + virtual double SAL_CALL + getDouble( sal_Int32 columnIndex ) + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + + virtual com::sun::star::uno::Sequence< sal_Int8 > SAL_CALL + getBytes( sal_Int32 columnIndex ) + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + + virtual com::sun::star::util::Date SAL_CALL + getDate( sal_Int32 columnIndex ) + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + + virtual com::sun::star::util::Time SAL_CALL + getTime( sal_Int32 columnIndex ) + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + + virtual com::sun::star::util::DateTime SAL_CALL + getTimestamp( sal_Int32 columnIndex ) + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + + virtual REFERENCE< + com::sun::star::io::XInputStream > SAL_CALL + getBinaryStream( sal_Int32 columnIndex ) + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + + virtual REFERENCE< + com::sun::star::io::XInputStream > SAL_CALL + getCharacterStream( sal_Int32 columnIndex ) + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + + virtual com::sun::star::uno::Any SAL_CALL + getObject( sal_Int32 columnIndex, + const REFERENCE< + com::sun::star::container::XNameAccess >& typeMap ) + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + virtual REFERENCE< + com::sun::star::sdbc::XRef > SAL_CALL + getRef( sal_Int32 columnIndex ) + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + virtual REFERENCE< + com::sun::star::sdbc::XBlob > SAL_CALL + getBlob( sal_Int32 columnIndex ) + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + virtual REFERENCE< + com::sun::star::sdbc::XClob > SAL_CALL + getClob( sal_Int32 columnIndex ) + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + virtual REFERENCE< + com::sun::star::sdbc::XArray > SAL_CALL + getArray( sal_Int32 columnIndex ) + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + + // XCloseable + virtual void SAL_CALL + close() + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + + // XResultSetMetaDataSupplier + virtual REFERENCE< XRESULTSETMETADATA > SAL_CALL + getMetaData() + throw( SQLEXCEPTION, RUNTIME_EXCEPTION ); + + + // XPropertySet + virtual REFERENCE< + com::sun::star::beans::XPropertySetInfo > SAL_CALL + getPropertySetInfo() + throw( RUNTIME_EXCEPTION ); + + virtual void SAL_CALL + setPropertyValue( const rtl::OUString& PropertyName, + const com::sun::star::uno::Any& Value ) + throw( com::sun::star::beans::UnknownPropertyException, + com::sun::star::beans::PropertyVetoException, + com::sun::star::lang::IllegalArgumentException, + com::sun::star::lang::WrappedTargetException, + RUNTIME_EXCEPTION ); + + virtual com::sun::star::uno::Any SAL_CALL + getPropertyValue( const rtl::OUString& PropertyName ) + throw( com::sun::star::beans::UnknownPropertyException, + com::sun::star::lang::WrappedTargetException, + RUNTIME_EXCEPTION ); + + virtual void SAL_CALL + addPropertyChangeListener( const rtl::OUString& PropertyName, + const REFERENCE< + com::sun::star::beans::XPropertyChangeListener >& Listener ) + throw( com::sun::star::beans::UnknownPropertyException, + com::sun::star::lang::WrappedTargetException, + RUNTIME_EXCEPTION ); + + virtual void SAL_CALL + removePropertyChangeListener( const rtl::OUString& PropertyName, + const REFERENCE< + com::sun::star::beans::XPropertyChangeListener >& Listener ) + throw( com::sun::star::beans::UnknownPropertyException, + com::sun::star::lang::WrappedTargetException, + RUNTIME_EXCEPTION ); + + virtual void SAL_CALL + addVetoableChangeListener( const rtl::OUString& PropertyName, + const REFERENCE< + com::sun::star::beans::XVetoableChangeListener >& Listener ) + throw( com::sun::star::beans::UnknownPropertyException, + com::sun::star::lang::WrappedTargetException, + RUNTIME_EXCEPTION ); + + virtual void SAL_CALL + removeVetoableChangeListener( const rtl::OUString& PropertyName, + const REFERENCE< + com::sun::star::beans::XVetoableChangeListener >& aListener ) + throw( com::sun::star::beans::UnknownPropertyException, + com::sun::star::lang::WrappedTargetException, + RUNTIME_EXCEPTION ); +}; + +#endif + |