Line data Source code
1 : /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
2 : /*
3 : * This file is part of the LibreOffice project.
4 : *
5 : * This Source Code Form is subject to the terms of the Mozilla Public
6 : * License, v. 2.0. If a copy of the MPL was not distributed with this
7 : * file, You can obtain one at http://mozilla.org/MPL/2.0/.
8 : *
9 : * This file incorporates work covered by the following license notice:
10 : *
11 : * Licensed to the Apache Software Foundation (ASF) under one or more
12 : * contributor license agreements. See the NOTICE file distributed
13 : * with this work for additional information regarding copyright
14 : * ownership. The ASF licenses this file to you under the Apache
15 : * License, Version 2.0 (the "License"); you may not use this file
16 : * except in compliance with the License. You may obtain a copy of
17 : * the License at http://www.apache.org/licenses/LICENSE-2.0 .
18 : */
19 :
20 : #ifndef _SORTRESULT_HXX
21 : #define _SORTRESULT_HXX
22 :
23 : #include <com/sun/star/beans/XPropertySet.hpp>
24 : #include <com/sun/star/lang/XMultiServiceFactory.hpp>
25 : #include <com/sun/star/lang/XTypeProvider.hpp>
26 : #include <com/sun/star/lang/XServiceInfo.hpp>
27 : #include <com/sun/star/lang/XComponent.hpp>
28 : #include <com/sun/star/sdbc/XCloseable.hpp>
29 : #include <com/sun/star/sdbc/XResultSet.hpp>
30 : #include <com/sun/star/sdbc/XResultSetMetaData.hpp>
31 : #include <com/sun/star/sdbc/XResultSetMetaDataSupplier.hpp>
32 : #include <com/sun/star/sdbc/XRow.hpp>
33 : #include <com/sun/star/ucb/XContentAccess.hpp>
34 : #include <com/sun/star/ucb/NumberedSortingInfo.hpp>
35 : #include <com/sun/star/ucb/XAnyCompareFactory.hpp>
36 : #include <com/sun/star/ucb/ListAction.hpp>
37 : #include <cppuhelper/weak.hxx>
38 : #include <osl/mutex.hxx>
39 :
40 : #include <deque>
41 : #include <ucbhelper/macros.hxx>
42 :
43 : namespace cppu {
44 : class OInterfaceContainerHelper;
45 : }
46 :
47 : //-----------------------------------------------------------------------------
48 : struct SortInfo;
49 : struct SortListData;
50 : class SRSPropertySetInfo;
51 : class PropertyChangeListeners_Impl;
52 :
53 : //-----------------------------------------------------------------------------
54 : class SortedEntryList
55 : {
56 : std::deque < SortListData* > maData;
57 :
58 : public:
59 0 : SortedEntryList(){}
60 0 : ~SortedEntryList(){ Clear(); }
61 :
62 0 : sal_uInt32 Count() const { return (sal_uInt32) maData.size(); }
63 :
64 : void Clear();
65 : void Insert( SortListData *pEntry, long nPos );
66 : SortListData* Remove( long nPos );
67 : SortListData* GetData( long nPos );
68 :
69 : long operator [] ( long nPos ) const;
70 : };
71 :
72 : //-----------------------------------------------------------------------------
73 : #define LISTACTION com::sun::star::ucb::ListAction
74 :
75 : class EventList
76 : {
77 : std::deque < LISTACTION* > maData;
78 :
79 : public:
80 0 : EventList(){}
81 0 : ~EventList(){ Clear(); }
82 :
83 0 : sal_uInt32 Count() { return (sal_uInt32) maData.size(); }
84 :
85 : void AddEvent( long nType, long nPos, long nCount );
86 0 : void Insert( LISTACTION *pAction ) { maData.push_back( pAction ); }
87 : void Clear();
88 0 : LISTACTION* GetAction( long nIndex ) { return maData[ nIndex ]; }
89 : };
90 :
91 : //-----------------------------------------------------------------------------
92 :
93 : class SimpleList
94 : {
95 : std::deque < void* > maData;
96 :
97 : public:
98 0 : SimpleList(){}
99 0 : ~SimpleList(){ Clear(); }
100 :
101 0 : sal_uInt32 Count() { return (sal_uInt32) maData.size(); }
102 0 : void Clear() { maData.clear(); }
103 :
104 : void Remove( sal_uInt32 nPos );
105 : void Remove( void* pData );
106 :
107 0 : void Append( void* pData )
108 0 : { maData.push_back( pData ); }
109 : void Insert( void* pData, sal_uInt32 nPos );
110 : void* GetObject( sal_uInt32 nPos ) const;
111 : void Replace( void* pData, sal_uInt32 nPos );
112 : };
113 :
114 : //-----------------------------------------------------------------------------
115 :
116 : #define PROPERTYCHANGEEVENT com::sun::star::beans::PropertyChangeEvent
117 : #define RUNTIME_EXCEPTION com::sun::star::uno::RuntimeException
118 : #define REFERENCE com::sun::star::uno::Reference
119 : #define SEQUENCE com::sun::star::uno::Sequence
120 : #define XEVENTLISTENER com::sun::star::lang::XEventListener
121 : #define XRESULTSET com::sun::star::sdbc::XResultSet
122 : #define SQLEXCEPTION com::sun::star::sdbc::SQLException
123 : #define XRESULTSETMETADATA com::sun::star::sdbc::XResultSetMetaData
124 : #define NUMBERED_SORTINGINFO com::sun::star::ucb::NumberedSortingInfo
125 : #define XANYCOMPAREFACTORY com::sun::star::ucb::XAnyCompareFactory
126 :
127 : #define RESULTSET_SERVICE_NAME "com.sun.star.ucb.SortedResultSet"
128 :
129 : //-----------------------------------------------------------------------------
130 :
131 : class SortedResultSet:
132 : public cppu::OWeakObject,
133 : public com::sun::star::lang::XTypeProvider,
134 : public com::sun::star::lang::XServiceInfo,
135 : public com::sun::star::lang::XComponent,
136 : public com::sun::star::ucb::XContentAccess,
137 : public XRESULTSET,
138 : public com::sun::star::sdbc::XRow,
139 : public com::sun::star::sdbc::XCloseable,
140 : public com::sun::star::sdbc::XResultSetMetaDataSupplier,
141 : public com::sun::star::beans::XPropertySet
142 : {
143 : cppu::OInterfaceContainerHelper *mpDisposeEventListeners;
144 : PropertyChangeListeners_Impl *mpPropChangeListeners;
145 : PropertyChangeListeners_Impl *mpVetoChangeListeners;
146 :
147 : REFERENCE < XRESULTSET > mxOriginal;
148 : REFERENCE < XRESULTSET > mxOther;
149 :
150 : SRSPropertySetInfo* mpPropSetInfo;
151 : SortInfo* mpSortInfo;
152 : osl::Mutex maMutex;
153 : SortedEntryList maS2O; // maps the sorted entries to the original ones
154 : SimpleList maO2S; // maps the original Entries to the sorted ones
155 : SimpleList maModList; // keeps track of modified entries
156 : long mnLastSort; // index of the last sorted entry;
157 : long mnCurEntry; // index of the current entry
158 : long mnCount; // total count of the elements
159 : sal_Bool mbIsCopy;
160 :
161 :
162 : private:
163 :
164 : long FindPos( SortListData *pEntry, long nStart, long nEnd )
165 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
166 : long Compare( SortListData *pOne,
167 : SortListData *pTwo )
168 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
169 : void BuildSortInfo( REFERENCE< XRESULTSET > aResult,
170 : const SEQUENCE < NUMBERED_SORTINGINFO > &xSortInfo,
171 : const REFERENCE< XANYCOMPAREFACTORY > &xCompFac );
172 : long CompareImpl( REFERENCE < XRESULTSET > xResultOne,
173 : REFERENCE < XRESULTSET > xResultTwo,
174 : long nIndexOne, long nIndexTwo,
175 : SortInfo* pSortInfo )
176 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
177 : long CompareImpl( REFERENCE < XRESULTSET > xResultOne,
178 : REFERENCE < XRESULTSET > xResultTwo,
179 : long nIndexOne, long nIndexTwo )
180 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
181 : void PropertyChanged( const PROPERTYCHANGEEVENT& rEvt );
182 :
183 : public:
184 : SortedResultSet( REFERENCE< XRESULTSET > aResult );
185 : ~SortedResultSet();
186 :
187 0 : const SortedEntryList* GetS2OList() const { return &maS2O; }
188 0 : const SimpleList* GetO2SList() const { return &maO2S; }
189 0 : REFERENCE < XRESULTSET > GetResultSet() const { return mxOriginal; }
190 0 : SortInfo* GetSortInfo() const { return mpSortInfo; }
191 0 : long GetCount() const { return mnCount; }
192 :
193 : void CopyData( SortedResultSet* pSource );
194 : void Initialize( const SEQUENCE < NUMBERED_SORTINGINFO > &xSortInfo,
195 : const REFERENCE< XANYCOMPAREFACTORY > &xCompFac );
196 : void CheckProperties( long nOldCount, sal_Bool bWasFinal );
197 :
198 : void InsertNew( long nPos, long nCount );
199 : void SetChanged( long nPos, long nCount );
200 : void Remove( long nPos, long nCount, EventList *pList );
201 : void Move( long nPos, long nCount, long nOffset );
202 :
203 : void ResortModified( EventList* pList );
204 : void ResortNew( EventList* pList );
205 :
206 : // XInterface
207 : XINTERFACE_DECL()
208 :
209 : // XTypeProvider
210 : XTYPEPROVIDER_DECL()
211 :
212 : // XServiceInfo
213 : XSERVICEINFO_NOFACTORY_DECL()
214 :
215 : // XComponent
216 : virtual void SAL_CALL
217 : dispose() throw( RUNTIME_EXCEPTION );
218 :
219 : virtual void SAL_CALL
220 : addEventListener( const REFERENCE< XEVENTLISTENER >& Listener )
221 : throw( RUNTIME_EXCEPTION );
222 :
223 : virtual void SAL_CALL
224 : removeEventListener( const REFERENCE< XEVENTLISTENER >& Listener )
225 : throw( RUNTIME_EXCEPTION );
226 :
227 : // XContentAccess
228 : virtual rtl::OUString SAL_CALL
229 : queryContentIdentifierString()
230 : throw( RUNTIME_EXCEPTION );
231 : virtual REFERENCE<
232 : com::sun::star::ucb::XContentIdentifier > SAL_CALL
233 : queryContentIdentifier()
234 : throw( RUNTIME_EXCEPTION );
235 : virtual REFERENCE<
236 : com::sun::star::ucb::XContent > SAL_CALL
237 : queryContent()
238 : throw( RUNTIME_EXCEPTION );
239 :
240 : // XResultSet
241 : virtual sal_Bool SAL_CALL
242 : next()
243 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
244 : virtual sal_Bool SAL_CALL
245 : isBeforeFirst()
246 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
247 : virtual sal_Bool SAL_CALL
248 : isAfterLast()
249 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
250 : virtual sal_Bool SAL_CALL
251 : isFirst()
252 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
253 : virtual sal_Bool SAL_CALL
254 : isLast()
255 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
256 : virtual void SAL_CALL
257 : beforeFirst()
258 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
259 : virtual void SAL_CALL
260 : afterLast()
261 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
262 : virtual sal_Bool SAL_CALL
263 : first()
264 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
265 : virtual sal_Bool SAL_CALL
266 : last()
267 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
268 : virtual sal_Int32 SAL_CALL
269 : getRow()
270 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
271 : virtual sal_Bool SAL_CALL
272 : absolute( sal_Int32 row )
273 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
274 : virtual sal_Bool SAL_CALL
275 : relative( sal_Int32 rows )
276 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
277 : virtual sal_Bool SAL_CALL
278 : previous()
279 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
280 : virtual void SAL_CALL
281 : refreshRow()
282 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
283 : virtual sal_Bool SAL_CALL
284 : rowUpdated()
285 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
286 : virtual sal_Bool SAL_CALL
287 : rowInserted()
288 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
289 : virtual sal_Bool SAL_CALL
290 : rowDeleted()
291 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
292 : virtual REFERENCE<
293 : com::sun::star::uno::XInterface > SAL_CALL
294 : getStatement()
295 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
296 :
297 : // XRow
298 : virtual sal_Bool SAL_CALL
299 : wasNull() throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
300 :
301 : virtual rtl::OUString SAL_CALL
302 : getString( sal_Int32 columnIndex )
303 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
304 :
305 : virtual sal_Bool SAL_CALL
306 : getBoolean( sal_Int32 columnIndex )
307 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
308 :
309 : virtual sal_Int8 SAL_CALL
310 : getByte( sal_Int32 columnIndex )
311 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
312 :
313 : virtual sal_Int16 SAL_CALL
314 : getShort( sal_Int32 columnIndex )
315 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
316 :
317 : virtual sal_Int32 SAL_CALL
318 : getInt( sal_Int32 columnIndex )
319 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
320 :
321 : virtual sal_Int64 SAL_CALL
322 : getLong( sal_Int32 columnIndex )
323 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
324 :
325 : virtual float SAL_CALL
326 : getFloat( sal_Int32 columnIndex )
327 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
328 :
329 : virtual double SAL_CALL
330 : getDouble( sal_Int32 columnIndex )
331 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
332 :
333 : virtual com::sun::star::uno::Sequence< sal_Int8 > SAL_CALL
334 : getBytes( sal_Int32 columnIndex )
335 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
336 :
337 : virtual com::sun::star::util::Date SAL_CALL
338 : getDate( sal_Int32 columnIndex )
339 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
340 :
341 : virtual com::sun::star::util::Time SAL_CALL
342 : getTime( sal_Int32 columnIndex )
343 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
344 :
345 : virtual com::sun::star::util::DateTime SAL_CALL
346 : getTimestamp( sal_Int32 columnIndex )
347 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
348 :
349 : virtual REFERENCE<
350 : com::sun::star::io::XInputStream > SAL_CALL
351 : getBinaryStream( sal_Int32 columnIndex )
352 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
353 :
354 : virtual REFERENCE<
355 : com::sun::star::io::XInputStream > SAL_CALL
356 : getCharacterStream( sal_Int32 columnIndex )
357 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
358 :
359 : virtual com::sun::star::uno::Any SAL_CALL
360 : getObject( sal_Int32 columnIndex,
361 : const REFERENCE<
362 : com::sun::star::container::XNameAccess >& typeMap )
363 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
364 : virtual REFERENCE<
365 : com::sun::star::sdbc::XRef > SAL_CALL
366 : getRef( sal_Int32 columnIndex )
367 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
368 : virtual REFERENCE<
369 : com::sun::star::sdbc::XBlob > SAL_CALL
370 : getBlob( sal_Int32 columnIndex )
371 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
372 : virtual REFERENCE<
373 : com::sun::star::sdbc::XClob > SAL_CALL
374 : getClob( sal_Int32 columnIndex )
375 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
376 : virtual REFERENCE<
377 : com::sun::star::sdbc::XArray > SAL_CALL
378 : getArray( sal_Int32 columnIndex )
379 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
380 :
381 : // XCloseable
382 : virtual void SAL_CALL
383 : close()
384 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
385 :
386 : // XResultSetMetaDataSupplier
387 : virtual REFERENCE< XRESULTSETMETADATA > SAL_CALL
388 : getMetaData()
389 : throw( SQLEXCEPTION, RUNTIME_EXCEPTION );
390 :
391 :
392 : // XPropertySet
393 : virtual REFERENCE<
394 : com::sun::star::beans::XPropertySetInfo > SAL_CALL
395 : getPropertySetInfo()
396 : throw( RUNTIME_EXCEPTION );
397 :
398 : virtual void SAL_CALL
399 : setPropertyValue( const rtl::OUString& PropertyName,
400 : const com::sun::star::uno::Any& Value )
401 : throw( com::sun::star::beans::UnknownPropertyException,
402 : com::sun::star::beans::PropertyVetoException,
403 : com::sun::star::lang::IllegalArgumentException,
404 : com::sun::star::lang::WrappedTargetException,
405 : RUNTIME_EXCEPTION );
406 :
407 : virtual com::sun::star::uno::Any SAL_CALL
408 : getPropertyValue( const rtl::OUString& PropertyName )
409 : throw( com::sun::star::beans::UnknownPropertyException,
410 : com::sun::star::lang::WrappedTargetException,
411 : RUNTIME_EXCEPTION );
412 :
413 : virtual void SAL_CALL
414 : addPropertyChangeListener( const rtl::OUString& PropertyName,
415 : const REFERENCE<
416 : com::sun::star::beans::XPropertyChangeListener >& Listener )
417 : throw( com::sun::star::beans::UnknownPropertyException,
418 : com::sun::star::lang::WrappedTargetException,
419 : RUNTIME_EXCEPTION );
420 :
421 : virtual void SAL_CALL
422 : removePropertyChangeListener( const rtl::OUString& PropertyName,
423 : const REFERENCE<
424 : com::sun::star::beans::XPropertyChangeListener >& Listener )
425 : throw( com::sun::star::beans::UnknownPropertyException,
426 : com::sun::star::lang::WrappedTargetException,
427 : RUNTIME_EXCEPTION );
428 :
429 : virtual void SAL_CALL
430 : addVetoableChangeListener( const rtl::OUString& PropertyName,
431 : const REFERENCE<
432 : com::sun::star::beans::XVetoableChangeListener >& Listener )
433 : throw( com::sun::star::beans::UnknownPropertyException,
434 : com::sun::star::lang::WrappedTargetException,
435 : RUNTIME_EXCEPTION );
436 :
437 : virtual void SAL_CALL
438 : removeVetoableChangeListener( const rtl::OUString& PropertyName,
439 : const REFERENCE<
440 : com::sun::star::beans::XVetoableChangeListener >& aListener )
441 : throw( com::sun::star::beans::UnknownPropertyException,
442 : com::sun::star::lang::WrappedTargetException,
443 : RUNTIME_EXCEPTION );
444 : };
445 :
446 : #endif
447 :
448 : /* vim:set shiftwidth=4 softtabstop=4 expandtab: */
|
