1*b1cdbd2cSJim Jagielski /**************************************************************
2*b1cdbd2cSJim Jagielski *
3*b1cdbd2cSJim Jagielski * Licensed to the Apache Software Foundation (ASF) under one
4*b1cdbd2cSJim Jagielski * or more contributor license agreements. See the NOTICE file
5*b1cdbd2cSJim Jagielski * distributed with this work for additional information
6*b1cdbd2cSJim Jagielski * regarding copyright ownership. The ASF licenses this file
7*b1cdbd2cSJim Jagielski * to you under the Apache License, Version 2.0 (the
8*b1cdbd2cSJim Jagielski * "License"); you may not use this file except in compliance
9*b1cdbd2cSJim Jagielski * with the License. You may obtain a copy of the License at
10*b1cdbd2cSJim Jagielski *
11*b1cdbd2cSJim Jagielski * http://www.apache.org/licenses/LICENSE-2.0
12*b1cdbd2cSJim Jagielski *
13*b1cdbd2cSJim Jagielski * Unless required by applicable law or agreed to in writing,
14*b1cdbd2cSJim Jagielski * software distributed under the License is distributed on an
15*b1cdbd2cSJim Jagielski * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16*b1cdbd2cSJim Jagielski * KIND, either express or implied. See the License for the
17*b1cdbd2cSJim Jagielski * specific language governing permissions and limitations
18*b1cdbd2cSJim Jagielski * under the License.
19*b1cdbd2cSJim Jagielski *
20*b1cdbd2cSJim Jagielski *************************************************************/
21*b1cdbd2cSJim Jagielski
22*b1cdbd2cSJim Jagielski
23*b1cdbd2cSJim Jagielski
24*b1cdbd2cSJim Jagielski // MARKER(update_precomp.py): autogen include statement, do not remove
25*b1cdbd2cSJim Jagielski #include "precompiled_ucb.hxx"
26*b1cdbd2cSJim Jagielski
27*b1cdbd2cSJim Jagielski #include <cachedcontentresultsetstub.hxx>
28*b1cdbd2cSJim Jagielski #include <com/sun/star/sdbc/FetchDirection.hpp>
29*b1cdbd2cSJim Jagielski #include <com/sun/star/ucb/FetchError.hpp>
30*b1cdbd2cSJim Jagielski #include <osl/diagnose.h>
31*b1cdbd2cSJim Jagielski
32*b1cdbd2cSJim Jagielski using namespace com::sun::star::beans;
33*b1cdbd2cSJim Jagielski using namespace com::sun::star::lang;
34*b1cdbd2cSJim Jagielski using namespace com::sun::star::sdbc;
35*b1cdbd2cSJim Jagielski using namespace com::sun::star::ucb;
36*b1cdbd2cSJim Jagielski using namespace com::sun::star::uno;
37*b1cdbd2cSJim Jagielski using namespace com::sun::star::util;
38*b1cdbd2cSJim Jagielski using namespace cppu;
39*b1cdbd2cSJim Jagielski using namespace rtl;
40*b1cdbd2cSJim Jagielski
CachedContentResultSetStub(Reference<XResultSet> xOrigin)41*b1cdbd2cSJim Jagielski CachedContentResultSetStub::CachedContentResultSetStub( Reference< XResultSet > xOrigin )
42*b1cdbd2cSJim Jagielski : ContentResultSetWrapper( xOrigin )
43*b1cdbd2cSJim Jagielski , m_nColumnCount( 0 )
44*b1cdbd2cSJim Jagielski , m_bColumnCountCached( sal_False )
45*b1cdbd2cSJim Jagielski , m_bNeedToPropagateFetchSize( sal_True )
46*b1cdbd2cSJim Jagielski , m_bFirstFetchSizePropagationDone( sal_False )
47*b1cdbd2cSJim Jagielski , m_nLastFetchSize( 1 )//this value is not important at all
48*b1cdbd2cSJim Jagielski , m_bLastFetchDirection( sal_True )//this value is not important at all
49*b1cdbd2cSJim Jagielski , m_aPropertyNameForFetchSize( OUString::createFromAscii( "FetchSize" ) )
50*b1cdbd2cSJim Jagielski , m_aPropertyNameForFetchDirection( OUString::createFromAscii( "FetchDirection" ) )
51*b1cdbd2cSJim Jagielski {
52*b1cdbd2cSJim Jagielski impl_init();
53*b1cdbd2cSJim Jagielski }
54*b1cdbd2cSJim Jagielski
~CachedContentResultSetStub()55*b1cdbd2cSJim Jagielski CachedContentResultSetStub::~CachedContentResultSetStub()
56*b1cdbd2cSJim Jagielski {
57*b1cdbd2cSJim Jagielski impl_deinit();
58*b1cdbd2cSJim Jagielski }
59*b1cdbd2cSJim Jagielski
60*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
61*b1cdbd2cSJim Jagielski // XInterface methods.
62*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
XINTERFACE_COMMON_IMPL(CachedContentResultSetStub)63*b1cdbd2cSJim Jagielski XINTERFACE_COMMON_IMPL( CachedContentResultSetStub )
64*b1cdbd2cSJim Jagielski
65*b1cdbd2cSJim Jagielski Any SAL_CALL CachedContentResultSetStub
66*b1cdbd2cSJim Jagielski ::queryInterface( const Type& rType )
67*b1cdbd2cSJim Jagielski throw ( RuntimeException )
68*b1cdbd2cSJim Jagielski {
69*b1cdbd2cSJim Jagielski //list all interfaces inclusive baseclasses of interfaces
70*b1cdbd2cSJim Jagielski
71*b1cdbd2cSJim Jagielski Any aRet = ContentResultSetWrapper::queryInterface( rType );
72*b1cdbd2cSJim Jagielski if( aRet.hasValue() )
73*b1cdbd2cSJim Jagielski return aRet;
74*b1cdbd2cSJim Jagielski
75*b1cdbd2cSJim Jagielski aRet = cppu::queryInterface( rType
76*b1cdbd2cSJim Jagielski , static_cast< XTypeProvider* >( this )
77*b1cdbd2cSJim Jagielski , static_cast< XServiceInfo* >( this )
78*b1cdbd2cSJim Jagielski , static_cast< XFetchProvider* >( this )
79*b1cdbd2cSJim Jagielski , static_cast< XFetchProviderForContentAccess* >( this )
80*b1cdbd2cSJim Jagielski );
81*b1cdbd2cSJim Jagielski
82*b1cdbd2cSJim Jagielski return aRet.hasValue() ? aRet : OWeakObject::queryInterface( rType );
83*b1cdbd2cSJim Jagielski }
84*b1cdbd2cSJim Jagielski
85*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
86*b1cdbd2cSJim Jagielski // own methods. ( inherited )
87*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
88*b1cdbd2cSJim Jagielski
89*b1cdbd2cSJim Jagielski //virtual
90*b1cdbd2cSJim Jagielski void SAL_CALL CachedContentResultSetStub
impl_propertyChange(const PropertyChangeEvent & rEvt)91*b1cdbd2cSJim Jagielski ::impl_propertyChange( const PropertyChangeEvent& rEvt )
92*b1cdbd2cSJim Jagielski throw( RuntimeException )
93*b1cdbd2cSJim Jagielski {
94*b1cdbd2cSJim Jagielski impl_EnsureNotDisposed();
95*b1cdbd2cSJim Jagielski
96*b1cdbd2cSJim Jagielski //don't notify events on fetchsize and fetchdirection to the above CachedContentResultSet
97*b1cdbd2cSJim Jagielski //because it will ignore them anyway and we can save this remote calls
98*b1cdbd2cSJim Jagielski if( rEvt.PropertyName == m_aPropertyNameForFetchSize
99*b1cdbd2cSJim Jagielski || rEvt.PropertyName == m_aPropertyNameForFetchDirection )
100*b1cdbd2cSJim Jagielski return;
101*b1cdbd2cSJim Jagielski
102*b1cdbd2cSJim Jagielski PropertyChangeEvent aEvt( rEvt );
103*b1cdbd2cSJim Jagielski aEvt.Source = static_cast< XPropertySet * >( this );
104*b1cdbd2cSJim Jagielski aEvt.Further = sal_False;
105*b1cdbd2cSJim Jagielski
106*b1cdbd2cSJim Jagielski impl_notifyPropertyChangeListeners( aEvt );
107*b1cdbd2cSJim Jagielski }
108*b1cdbd2cSJim Jagielski
109*b1cdbd2cSJim Jagielski
110*b1cdbd2cSJim Jagielski //virtual
111*b1cdbd2cSJim Jagielski void SAL_CALL CachedContentResultSetStub
impl_vetoableChange(const PropertyChangeEvent & rEvt)112*b1cdbd2cSJim Jagielski ::impl_vetoableChange( const PropertyChangeEvent& rEvt )
113*b1cdbd2cSJim Jagielski throw( PropertyVetoException,
114*b1cdbd2cSJim Jagielski RuntimeException )
115*b1cdbd2cSJim Jagielski {
116*b1cdbd2cSJim Jagielski impl_EnsureNotDisposed();
117*b1cdbd2cSJim Jagielski
118*b1cdbd2cSJim Jagielski //don't notify events on fetchsize and fetchdirection to the above CachedContentResultSet
119*b1cdbd2cSJim Jagielski //because it will ignore them anyway and we can save this remote calls
120*b1cdbd2cSJim Jagielski if( rEvt.PropertyName == m_aPropertyNameForFetchSize
121*b1cdbd2cSJim Jagielski || rEvt.PropertyName == m_aPropertyNameForFetchDirection )
122*b1cdbd2cSJim Jagielski return;
123*b1cdbd2cSJim Jagielski
124*b1cdbd2cSJim Jagielski PropertyChangeEvent aEvt( rEvt );
125*b1cdbd2cSJim Jagielski aEvt.Source = static_cast< XPropertySet * >( this );
126*b1cdbd2cSJim Jagielski aEvt.Further = sal_False;
127*b1cdbd2cSJim Jagielski
128*b1cdbd2cSJim Jagielski impl_notifyVetoableChangeListeners( aEvt );
129*b1cdbd2cSJim Jagielski }
130*b1cdbd2cSJim Jagielski
131*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
132*b1cdbd2cSJim Jagielski // XTypeProvider methods.
133*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
134*b1cdbd2cSJim Jagielski
XTYPEPROVIDER_COMMON_IMPL(CachedContentResultSetStub)135*b1cdbd2cSJim Jagielski XTYPEPROVIDER_COMMON_IMPL( CachedContentResultSetStub )
136*b1cdbd2cSJim Jagielski //list all interfaces exclusive baseclasses
137*b1cdbd2cSJim Jagielski Sequence< Type > SAL_CALL CachedContentResultSetStub
138*b1cdbd2cSJim Jagielski ::getTypes()
139*b1cdbd2cSJim Jagielski throw( RuntimeException )
140*b1cdbd2cSJim Jagielski {
141*b1cdbd2cSJim Jagielski static Sequence< Type >* pTypes = NULL;
142*b1cdbd2cSJim Jagielski if( !pTypes )
143*b1cdbd2cSJim Jagielski {
144*b1cdbd2cSJim Jagielski osl::Guard< osl::Mutex > aGuard( osl::Mutex::getGlobalMutex() );
145*b1cdbd2cSJim Jagielski if( !pTypes )
146*b1cdbd2cSJim Jagielski {
147*b1cdbd2cSJim Jagielski pTypes = new Sequence< Type >(13);
148*b1cdbd2cSJim Jagielski (*pTypes)[0] = CPPU_TYPE_REF( XTypeProvider );
149*b1cdbd2cSJim Jagielski (*pTypes)[1] = CPPU_TYPE_REF( XServiceInfo );
150*b1cdbd2cSJim Jagielski (*pTypes)[2] = CPPU_TYPE_REF( XComponent );
151*b1cdbd2cSJim Jagielski (*pTypes)[3] = CPPU_TYPE_REF( XCloseable );
152*b1cdbd2cSJim Jagielski (*pTypes)[4] = CPPU_TYPE_REF( XResultSetMetaDataSupplier );
153*b1cdbd2cSJim Jagielski (*pTypes)[5] = CPPU_TYPE_REF( XPropertySet );
154*b1cdbd2cSJim Jagielski (*pTypes)[6] = CPPU_TYPE_REF( XPropertyChangeListener );
155*b1cdbd2cSJim Jagielski (*pTypes)[7] = CPPU_TYPE_REF( XVetoableChangeListener );
156*b1cdbd2cSJim Jagielski (*pTypes)[8] = CPPU_TYPE_REF( XResultSet );
157*b1cdbd2cSJim Jagielski (*pTypes)[9] = CPPU_TYPE_REF( XContentAccess );
158*b1cdbd2cSJim Jagielski (*pTypes)[10] = CPPU_TYPE_REF( XRow );
159*b1cdbd2cSJim Jagielski (*pTypes)[11] = CPPU_TYPE_REF( XFetchProvider );
160*b1cdbd2cSJim Jagielski (*pTypes)[12] = CPPU_TYPE_REF( XFetchProviderForContentAccess );
161*b1cdbd2cSJim Jagielski }
162*b1cdbd2cSJim Jagielski }
163*b1cdbd2cSJim Jagielski return *pTypes;
164*b1cdbd2cSJim Jagielski /*
165*b1cdbd2cSJim Jagielski static cppu::OTypeCollection * pCollection = 0;
166*b1cdbd2cSJim Jagielski if (!pCollection)
167*b1cdbd2cSJim Jagielski {
168*b1cdbd2cSJim Jagielski osl::MutexGuard aGuard(osl::Mutex::getGlobalMutex());
169*b1cdbd2cSJim Jagielski if (!pCollection)
170*b1cdbd2cSJim Jagielski {
171*b1cdbd2cSJim Jagielski static cppu::OTypeCollection
172*b1cdbd2cSJim Jagielski aTheCollection(
173*b1cdbd2cSJim Jagielski getCppuType(
174*b1cdbd2cSJim Jagielski static_cast< Reference< XTypeProvider >
175*b1cdbd2cSJim Jagielski const * >(
176*b1cdbd2cSJim Jagielski 0)),
177*b1cdbd2cSJim Jagielski getCppuType(
178*b1cdbd2cSJim Jagielski static_cast< Reference< XServiceInfo >
179*b1cdbd2cSJim Jagielski const * >(
180*b1cdbd2cSJim Jagielski 0)),
181*b1cdbd2cSJim Jagielski getCppuType(
182*b1cdbd2cSJim Jagielski static_cast< Reference< XComponent >
183*b1cdbd2cSJim Jagielski const * >(
184*b1cdbd2cSJim Jagielski 0)),
185*b1cdbd2cSJim Jagielski getCppuType(
186*b1cdbd2cSJim Jagielski static_cast< Reference< XCloseable >
187*b1cdbd2cSJim Jagielski const * >(
188*b1cdbd2cSJim Jagielski 0)),
189*b1cdbd2cSJim Jagielski getCppuType(
190*b1cdbd2cSJim Jagielski static_cast< Reference< XResultSetMetaDataSupplier >
191*b1cdbd2cSJim Jagielski const * >(
192*b1cdbd2cSJim Jagielski 0)),
193*b1cdbd2cSJim Jagielski getCppuType(
194*b1cdbd2cSJim Jagielski static_cast< Reference< XPropertySet >
195*b1cdbd2cSJim Jagielski const * >(
196*b1cdbd2cSJim Jagielski 0)),
197*b1cdbd2cSJim Jagielski getCppuType(
198*b1cdbd2cSJim Jagielski static_cast< Reference< XPropertyChangeListener >
199*b1cdbd2cSJim Jagielski const * >(
200*b1cdbd2cSJim Jagielski 0)),
201*b1cdbd2cSJim Jagielski getCppuType(
202*b1cdbd2cSJim Jagielski static_cast< Reference< XVetoableChangeListener >
203*b1cdbd2cSJim Jagielski const * >(
204*b1cdbd2cSJim Jagielski 0)),
205*b1cdbd2cSJim Jagielski getCppuType(
206*b1cdbd2cSJim Jagielski static_cast< Reference< XResultSet >
207*b1cdbd2cSJim Jagielski const * >(
208*b1cdbd2cSJim Jagielski 0)),
209*b1cdbd2cSJim Jagielski getCppuType(
210*b1cdbd2cSJim Jagielski static_cast< Reference< XContentAccess >
211*b1cdbd2cSJim Jagielski const * >(
212*b1cdbd2cSJim Jagielski 0)),
213*b1cdbd2cSJim Jagielski getCppuType(
214*b1cdbd2cSJim Jagielski static_cast< Reference< XRow >
215*b1cdbd2cSJim Jagielski const * >(
216*b1cdbd2cSJim Jagielski 0)),
217*b1cdbd2cSJim Jagielski getCppuType(
218*b1cdbd2cSJim Jagielski static_cast< Reference< XFetchProvider >
219*b1cdbd2cSJim Jagielski const * >(
220*b1cdbd2cSJim Jagielski 0)),
221*b1cdbd2cSJim Jagielski getCppuType(
222*b1cdbd2cSJim Jagielski static_cast< Reference< XFetchProviderForContentAccess >
223*b1cdbd2cSJim Jagielski const * >(
224*b1cdbd2cSJim Jagielski 0))
225*b1cdbd2cSJim Jagielski );
226*b1cdbd2cSJim Jagielski pCollection = &aTheCollection;
227*b1cdbd2cSJim Jagielski }
228*b1cdbd2cSJim Jagielski }
229*b1cdbd2cSJim Jagielski return pCollection->getTypes();
230*b1cdbd2cSJim Jagielski */
231*b1cdbd2cSJim Jagielski }
232*b1cdbd2cSJim Jagielski
233*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
234*b1cdbd2cSJim Jagielski // XServiceInfo methods.
235*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
236*b1cdbd2cSJim Jagielski
237*b1cdbd2cSJim Jagielski XSERVICEINFO_NOFACTORY_IMPL_1( CachedContentResultSetStub,
238*b1cdbd2cSJim Jagielski OUString::createFromAscii(
239*b1cdbd2cSJim Jagielski "com.sun.star.comp.ucb.CachedContentResultSetStub" ),
240*b1cdbd2cSJim Jagielski OUString::createFromAscii(
241*b1cdbd2cSJim Jagielski CACHED_CRS_STUB_SERVICE_NAME ) );
242*b1cdbd2cSJim Jagielski
243*b1cdbd2cSJim Jagielski //-----------------------------------------------------------------
244*b1cdbd2cSJim Jagielski // XFetchProvider methods.
245*b1cdbd2cSJim Jagielski //-----------------------------------------------------------------
246*b1cdbd2cSJim Jagielski
247*b1cdbd2cSJim Jagielski #define FETCH_XXX( impl_loadRow, loadInterface ) \
248*b1cdbd2cSJim Jagielski impl_EnsureNotDisposed(); \
249*b1cdbd2cSJim Jagielski if( !m_xResultSetOrigin.is() ) \
250*b1cdbd2cSJim Jagielski { \
251*b1cdbd2cSJim Jagielski OSL_ENSURE( sal_False, "broadcaster was disposed already" ); \
252*b1cdbd2cSJim Jagielski throw RuntimeException(); \
253*b1cdbd2cSJim Jagielski } \
254*b1cdbd2cSJim Jagielski impl_propagateFetchSizeAndDirection( nRowCount, bDirection ); \
255*b1cdbd2cSJim Jagielski FetchResult aRet; \
256*b1cdbd2cSJim Jagielski aRet.StartIndex = nRowStartPosition; \
257*b1cdbd2cSJim Jagielski aRet.Orientation = bDirection; \
258*b1cdbd2cSJim Jagielski aRet.FetchError = FetchError::SUCCESS; /*ENDOFDATA, EXCEPTION*/ \
259*b1cdbd2cSJim Jagielski sal_Int32 nOldOriginal_Pos = m_xResultSetOrigin->getRow(); \
260*b1cdbd2cSJim Jagielski if( impl_isForwardOnly() ) \
261*b1cdbd2cSJim Jagielski { \
262*b1cdbd2cSJim Jagielski if( nOldOriginal_Pos != nRowStartPosition ) \
263*b1cdbd2cSJim Jagielski { \
264*b1cdbd2cSJim Jagielski /*@todo*/ \
265*b1cdbd2cSJim Jagielski aRet.FetchError = FetchError::EXCEPTION; \
266*b1cdbd2cSJim Jagielski return aRet; \
267*b1cdbd2cSJim Jagielski } \
268*b1cdbd2cSJim Jagielski if( nRowCount != 1 ) \
269*b1cdbd2cSJim Jagielski aRet.FetchError = FetchError::EXCEPTION; \
270*b1cdbd2cSJim Jagielski \
271*b1cdbd2cSJim Jagielski aRet.Rows.realloc( 1 ); \
272*b1cdbd2cSJim Jagielski \
273*b1cdbd2cSJim Jagielski try \
274*b1cdbd2cSJim Jagielski { \
275*b1cdbd2cSJim Jagielski impl_loadRow( aRet.Rows[0], loadInterface ); \
276*b1cdbd2cSJim Jagielski } \
277*b1cdbd2cSJim Jagielski catch( SQLException& ) \
278*b1cdbd2cSJim Jagielski { \
279*b1cdbd2cSJim Jagielski aRet.Rows.realloc( 0 ); \
280*b1cdbd2cSJim Jagielski aRet.FetchError = FetchError::EXCEPTION; \
281*b1cdbd2cSJim Jagielski return aRet; \
282*b1cdbd2cSJim Jagielski } \
283*b1cdbd2cSJim Jagielski return aRet; \
284*b1cdbd2cSJim Jagielski } \
285*b1cdbd2cSJim Jagielski aRet.Rows.realloc( nRowCount ); \
286*b1cdbd2cSJim Jagielski sal_Bool bOldOriginal_AfterLast = sal_False; \
287*b1cdbd2cSJim Jagielski if( !nOldOriginal_Pos ) \
288*b1cdbd2cSJim Jagielski bOldOriginal_AfterLast = m_xResultSetOrigin->isAfterLast(); \
289*b1cdbd2cSJim Jagielski sal_Int32 nN = 1; \
290*b1cdbd2cSJim Jagielski sal_Bool bValidNewPos = sal_False; \
291*b1cdbd2cSJim Jagielski try \
292*b1cdbd2cSJim Jagielski { \
293*b1cdbd2cSJim Jagielski try \
294*b1cdbd2cSJim Jagielski { \
295*b1cdbd2cSJim Jagielski /*if( nOldOriginal_Pos != nRowStartPosition )*/ \
296*b1cdbd2cSJim Jagielski bValidNewPos = m_xResultSetOrigin->absolute( nRowStartPosition ); \
297*b1cdbd2cSJim Jagielski } \
298*b1cdbd2cSJim Jagielski catch( SQLException& ) \
299*b1cdbd2cSJim Jagielski { \
300*b1cdbd2cSJim Jagielski aRet.Rows.realloc( 0 ); \
301*b1cdbd2cSJim Jagielski aRet.FetchError = FetchError::EXCEPTION; \
302*b1cdbd2cSJim Jagielski return aRet; \
303*b1cdbd2cSJim Jagielski } \
304*b1cdbd2cSJim Jagielski if( !bValidNewPos ) \
305*b1cdbd2cSJim Jagielski { \
306*b1cdbd2cSJim Jagielski aRet.Rows.realloc( 0 ); \
307*b1cdbd2cSJim Jagielski aRet.FetchError = FetchError::EXCEPTION; \
308*b1cdbd2cSJim Jagielski \
309*b1cdbd2cSJim Jagielski /*restore old position*/ \
310*b1cdbd2cSJim Jagielski if( nOldOriginal_Pos ) \
311*b1cdbd2cSJim Jagielski m_xResultSetOrigin->absolute( nOldOriginal_Pos ); \
312*b1cdbd2cSJim Jagielski else if( bOldOriginal_AfterLast ) \
313*b1cdbd2cSJim Jagielski m_xResultSetOrigin->afterLast(); \
314*b1cdbd2cSJim Jagielski else \
315*b1cdbd2cSJim Jagielski m_xResultSetOrigin->beforeFirst(); \
316*b1cdbd2cSJim Jagielski \
317*b1cdbd2cSJim Jagielski return aRet; \
318*b1cdbd2cSJim Jagielski } \
319*b1cdbd2cSJim Jagielski for( ; nN <= nRowCount; ) \
320*b1cdbd2cSJim Jagielski { \
321*b1cdbd2cSJim Jagielski impl_loadRow( aRet.Rows[nN-1], loadInterface ); \
322*b1cdbd2cSJim Jagielski nN++; \
323*b1cdbd2cSJim Jagielski if( nN <= nRowCount ) \
324*b1cdbd2cSJim Jagielski { \
325*b1cdbd2cSJim Jagielski if( bDirection ) \
326*b1cdbd2cSJim Jagielski { \
327*b1cdbd2cSJim Jagielski if( !m_xResultSetOrigin->next() ) \
328*b1cdbd2cSJim Jagielski { \
329*b1cdbd2cSJim Jagielski aRet.Rows.realloc( nN-1 ); \
330*b1cdbd2cSJim Jagielski aRet.FetchError = FetchError::ENDOFDATA; \
331*b1cdbd2cSJim Jagielski break; \
332*b1cdbd2cSJim Jagielski } \
333*b1cdbd2cSJim Jagielski } \
334*b1cdbd2cSJim Jagielski else \
335*b1cdbd2cSJim Jagielski { \
336*b1cdbd2cSJim Jagielski if( !m_xResultSetOrigin->previous() ) \
337*b1cdbd2cSJim Jagielski { \
338*b1cdbd2cSJim Jagielski aRet.Rows.realloc( nN-1 ); \
339*b1cdbd2cSJim Jagielski aRet.FetchError = FetchError::ENDOFDATA; \
340*b1cdbd2cSJim Jagielski break; \
341*b1cdbd2cSJim Jagielski } \
342*b1cdbd2cSJim Jagielski } \
343*b1cdbd2cSJim Jagielski } \
344*b1cdbd2cSJim Jagielski } \
345*b1cdbd2cSJim Jagielski } \
346*b1cdbd2cSJim Jagielski catch( SQLException& ) \
347*b1cdbd2cSJim Jagielski { \
348*b1cdbd2cSJim Jagielski aRet.Rows.realloc( nN-1 ); \
349*b1cdbd2cSJim Jagielski aRet.FetchError = FetchError::EXCEPTION; \
350*b1cdbd2cSJim Jagielski } \
351*b1cdbd2cSJim Jagielski /*restore old position*/ \
352*b1cdbd2cSJim Jagielski if( nOldOriginal_Pos ) \
353*b1cdbd2cSJim Jagielski m_xResultSetOrigin->absolute( nOldOriginal_Pos ); \
354*b1cdbd2cSJim Jagielski else if( bOldOriginal_AfterLast ) \
355*b1cdbd2cSJim Jagielski m_xResultSetOrigin->afterLast(); \
356*b1cdbd2cSJim Jagielski else \
357*b1cdbd2cSJim Jagielski m_xResultSetOrigin->beforeFirst(); \
358*b1cdbd2cSJim Jagielski return aRet;
359*b1cdbd2cSJim Jagielski
360*b1cdbd2cSJim Jagielski FetchResult SAL_CALL CachedContentResultSetStub
fetch(sal_Int32 nRowStartPosition,sal_Int32 nRowCount,sal_Bool bDirection)361*b1cdbd2cSJim Jagielski ::fetch( sal_Int32 nRowStartPosition
362*b1cdbd2cSJim Jagielski , sal_Int32 nRowCount, sal_Bool bDirection )
363*b1cdbd2cSJim Jagielski throw( RuntimeException )
364*b1cdbd2cSJim Jagielski {
365*b1cdbd2cSJim Jagielski impl_init_xRowOrigin();
366*b1cdbd2cSJim Jagielski FETCH_XXX( impl_getCurrentRowContent, m_xRowOrigin );
367*b1cdbd2cSJim Jagielski }
368*b1cdbd2cSJim Jagielski
369*b1cdbd2cSJim Jagielski sal_Int32 SAL_CALL CachedContentResultSetStub
impl_getColumnCount()370*b1cdbd2cSJim Jagielski ::impl_getColumnCount()
371*b1cdbd2cSJim Jagielski {
372*b1cdbd2cSJim Jagielski sal_Int32 nCount;
373*b1cdbd2cSJim Jagielski sal_Bool bCached;
374*b1cdbd2cSJim Jagielski {
375*b1cdbd2cSJim Jagielski osl::Guard< osl::Mutex > aGuard( m_aMutex );
376*b1cdbd2cSJim Jagielski nCount = m_nColumnCount;
377*b1cdbd2cSJim Jagielski bCached = m_bColumnCountCached;
378*b1cdbd2cSJim Jagielski }
379*b1cdbd2cSJim Jagielski if( !bCached )
380*b1cdbd2cSJim Jagielski {
381*b1cdbd2cSJim Jagielski try
382*b1cdbd2cSJim Jagielski {
383*b1cdbd2cSJim Jagielski Reference< XResultSetMetaData > xMetaData = getMetaData();
384*b1cdbd2cSJim Jagielski if( xMetaData.is() )
385*b1cdbd2cSJim Jagielski nCount = xMetaData->getColumnCount();
386*b1cdbd2cSJim Jagielski }
387*b1cdbd2cSJim Jagielski catch( SQLException& )
388*b1cdbd2cSJim Jagielski {
389*b1cdbd2cSJim Jagielski OSL_ENSURE( sal_False, "couldn't determine the column count" );
390*b1cdbd2cSJim Jagielski nCount = 0;
391*b1cdbd2cSJim Jagielski }
392*b1cdbd2cSJim Jagielski }
393*b1cdbd2cSJim Jagielski osl::Guard< osl::Mutex > aGuard( m_aMutex );
394*b1cdbd2cSJim Jagielski m_nColumnCount = nCount;
395*b1cdbd2cSJim Jagielski m_bColumnCountCached = sal_True;
396*b1cdbd2cSJim Jagielski return m_nColumnCount;
397*b1cdbd2cSJim Jagielski }
398*b1cdbd2cSJim Jagielski
399*b1cdbd2cSJim Jagielski void SAL_CALL CachedContentResultSetStub
impl_getCurrentRowContent(Any & rRowContent,Reference<XRow> xRow)400*b1cdbd2cSJim Jagielski ::impl_getCurrentRowContent( Any& rRowContent
401*b1cdbd2cSJim Jagielski , Reference< XRow > xRow )
402*b1cdbd2cSJim Jagielski throw ( SQLException, RuntimeException )
403*b1cdbd2cSJim Jagielski {
404*b1cdbd2cSJim Jagielski sal_Int32 nCount = impl_getColumnCount();
405*b1cdbd2cSJim Jagielski
406*b1cdbd2cSJim Jagielski Sequence< Any > aContent( nCount );
407*b1cdbd2cSJim Jagielski for( sal_Int32 nN = 1; nN <= nCount; nN++ )
408*b1cdbd2cSJim Jagielski {
409*b1cdbd2cSJim Jagielski aContent[nN-1] = xRow->getObject( nN, NULL );
410*b1cdbd2cSJim Jagielski }
411*b1cdbd2cSJim Jagielski
412*b1cdbd2cSJim Jagielski rRowContent <<= aContent;
413*b1cdbd2cSJim Jagielski }
414*b1cdbd2cSJim Jagielski
415*b1cdbd2cSJim Jagielski void SAL_CALL CachedContentResultSetStub
impl_propagateFetchSizeAndDirection(sal_Int32 nFetchSize,sal_Bool bFetchDirection)416*b1cdbd2cSJim Jagielski ::impl_propagateFetchSizeAndDirection( sal_Int32 nFetchSize, sal_Bool bFetchDirection )
417*b1cdbd2cSJim Jagielski throw ( RuntimeException )
418*b1cdbd2cSJim Jagielski {
419*b1cdbd2cSJim Jagielski //this is done only for the case, that there is another CachedContentResultSet in the chain of underlying ResulSets
420*b1cdbd2cSJim Jagielski
421*b1cdbd2cSJim Jagielski //we do not propagate the property 'FetchSize' or 'FetchDirection' via 'setPropertyValue' from the above CachedContentResultSet to save remote calls
422*b1cdbd2cSJim Jagielski
423*b1cdbd2cSJim Jagielski //if the underlying ResultSet has a property FetchSize and FetchDirection,
424*b1cdbd2cSJim Jagielski //we will set these properties, if the new given parameters are different from the last ones
425*b1cdbd2cSJim Jagielski
426*b1cdbd2cSJim Jagielski if( !m_bNeedToPropagateFetchSize )
427*b1cdbd2cSJim Jagielski return;
428*b1cdbd2cSJim Jagielski
429*b1cdbd2cSJim Jagielski sal_Bool bNeedAction;
430*b1cdbd2cSJim Jagielski sal_Int32 nLastSize;
431*b1cdbd2cSJim Jagielski sal_Bool bLastDirection;
432*b1cdbd2cSJim Jagielski sal_Bool bFirstPropagationDone;
433*b1cdbd2cSJim Jagielski {
434*b1cdbd2cSJim Jagielski osl::Guard< osl::Mutex > aGuard( m_aMutex );
435*b1cdbd2cSJim Jagielski bNeedAction = m_bNeedToPropagateFetchSize;
436*b1cdbd2cSJim Jagielski nLastSize = m_nLastFetchSize;
437*b1cdbd2cSJim Jagielski bLastDirection = m_bLastFetchDirection;
438*b1cdbd2cSJim Jagielski bFirstPropagationDone = m_bFirstFetchSizePropagationDone;
439*b1cdbd2cSJim Jagielski }
440*b1cdbd2cSJim Jagielski if( bNeedAction )
441*b1cdbd2cSJim Jagielski {
442*b1cdbd2cSJim Jagielski if( nLastSize == nFetchSize
443*b1cdbd2cSJim Jagielski && bLastDirection == bFetchDirection
444*b1cdbd2cSJim Jagielski && bFirstPropagationDone == sal_True )
445*b1cdbd2cSJim Jagielski return;
446*b1cdbd2cSJim Jagielski
447*b1cdbd2cSJim Jagielski if(!bFirstPropagationDone)
448*b1cdbd2cSJim Jagielski {
449*b1cdbd2cSJim Jagielski //check wether the properties 'FetchSize' and 'FetchDirection' do exist
450*b1cdbd2cSJim Jagielski
451*b1cdbd2cSJim Jagielski Reference< XPropertySetInfo > xPropertySetInfo = getPropertySetInfo();
452*b1cdbd2cSJim Jagielski sal_Bool bHasSize = xPropertySetInfo->hasPropertyByName( m_aPropertyNameForFetchSize );
453*b1cdbd2cSJim Jagielski sal_Bool bHasDirection = xPropertySetInfo->hasPropertyByName( m_aPropertyNameForFetchDirection );
454*b1cdbd2cSJim Jagielski
455*b1cdbd2cSJim Jagielski if(!bHasSize || !bHasDirection)
456*b1cdbd2cSJim Jagielski {
457*b1cdbd2cSJim Jagielski osl::Guard< osl::Mutex > aGuard( m_aMutex );
458*b1cdbd2cSJim Jagielski m_bNeedToPropagateFetchSize = sal_False;
459*b1cdbd2cSJim Jagielski return;
460*b1cdbd2cSJim Jagielski }
461*b1cdbd2cSJim Jagielski }
462*b1cdbd2cSJim Jagielski
463*b1cdbd2cSJim Jagielski sal_Bool bSetSize = ( nLastSize !=nFetchSize ) || !bFirstPropagationDone;
464*b1cdbd2cSJim Jagielski sal_Bool bSetDirection = ( bLastDirection !=bFetchDirection ) || !bFirstPropagationDone;
465*b1cdbd2cSJim Jagielski
466*b1cdbd2cSJim Jagielski {
467*b1cdbd2cSJim Jagielski osl::Guard< osl::Mutex > aGuard( m_aMutex );
468*b1cdbd2cSJim Jagielski m_bFirstFetchSizePropagationDone = sal_True;
469*b1cdbd2cSJim Jagielski m_nLastFetchSize = nFetchSize;
470*b1cdbd2cSJim Jagielski m_bLastFetchDirection = bFetchDirection;
471*b1cdbd2cSJim Jagielski }
472*b1cdbd2cSJim Jagielski
473*b1cdbd2cSJim Jagielski if( bSetSize )
474*b1cdbd2cSJim Jagielski {
475*b1cdbd2cSJim Jagielski Any aValue;
476*b1cdbd2cSJim Jagielski aValue <<= nFetchSize;
477*b1cdbd2cSJim Jagielski try
478*b1cdbd2cSJim Jagielski {
479*b1cdbd2cSJim Jagielski setPropertyValue( m_aPropertyNameForFetchSize, aValue );
480*b1cdbd2cSJim Jagielski }
481*b1cdbd2cSJim Jagielski catch( com::sun::star::uno::Exception& ) {}
482*b1cdbd2cSJim Jagielski }
483*b1cdbd2cSJim Jagielski if( bSetDirection )
484*b1cdbd2cSJim Jagielski {
485*b1cdbd2cSJim Jagielski sal_Int32 nFetchDirection = FetchDirection::FORWARD;
486*b1cdbd2cSJim Jagielski if( !bFetchDirection )
487*b1cdbd2cSJim Jagielski nFetchDirection = FetchDirection::REVERSE;
488*b1cdbd2cSJim Jagielski Any aValue;
489*b1cdbd2cSJim Jagielski aValue <<= nFetchDirection;
490*b1cdbd2cSJim Jagielski try
491*b1cdbd2cSJim Jagielski {
492*b1cdbd2cSJim Jagielski setPropertyValue( m_aPropertyNameForFetchDirection, aValue );
493*b1cdbd2cSJim Jagielski }
494*b1cdbd2cSJim Jagielski catch( com::sun::star::uno::Exception& ) {}
495*b1cdbd2cSJim Jagielski }
496*b1cdbd2cSJim Jagielski
497*b1cdbd2cSJim Jagielski }
498*b1cdbd2cSJim Jagielski }
499*b1cdbd2cSJim Jagielski
500*b1cdbd2cSJim Jagielski //-----------------------------------------------------------------
501*b1cdbd2cSJim Jagielski // XFetchProviderForContentAccess methods.
502*b1cdbd2cSJim Jagielski //-----------------------------------------------------------------
503*b1cdbd2cSJim Jagielski
504*b1cdbd2cSJim Jagielski void SAL_CALL CachedContentResultSetStub
impl_getCurrentContentIdentifierString(Any & rAny,Reference<XContentAccess> xContentAccess)505*b1cdbd2cSJim Jagielski ::impl_getCurrentContentIdentifierString( Any& rAny
506*b1cdbd2cSJim Jagielski , Reference< XContentAccess > xContentAccess )
507*b1cdbd2cSJim Jagielski throw ( RuntimeException )
508*b1cdbd2cSJim Jagielski {
509*b1cdbd2cSJim Jagielski rAny <<= xContentAccess->queryContentIdentifierString();
510*b1cdbd2cSJim Jagielski }
511*b1cdbd2cSJim Jagielski
512*b1cdbd2cSJim Jagielski void SAL_CALL CachedContentResultSetStub
impl_getCurrentContentIdentifier(Any & rAny,Reference<XContentAccess> xContentAccess)513*b1cdbd2cSJim Jagielski ::impl_getCurrentContentIdentifier( Any& rAny
514*b1cdbd2cSJim Jagielski , Reference< XContentAccess > xContentAccess )
515*b1cdbd2cSJim Jagielski throw ( RuntimeException )
516*b1cdbd2cSJim Jagielski {
517*b1cdbd2cSJim Jagielski rAny <<= xContentAccess->queryContentIdentifier();
518*b1cdbd2cSJim Jagielski }
519*b1cdbd2cSJim Jagielski
520*b1cdbd2cSJim Jagielski void SAL_CALL CachedContentResultSetStub
impl_getCurrentContent(Any & rAny,Reference<XContentAccess> xContentAccess)521*b1cdbd2cSJim Jagielski ::impl_getCurrentContent( Any& rAny
522*b1cdbd2cSJim Jagielski , Reference< XContentAccess > xContentAccess )
523*b1cdbd2cSJim Jagielski throw ( RuntimeException )
524*b1cdbd2cSJim Jagielski {
525*b1cdbd2cSJim Jagielski rAny <<= xContentAccess->queryContent();
526*b1cdbd2cSJim Jagielski }
527*b1cdbd2cSJim Jagielski
528*b1cdbd2cSJim Jagielski //virtual
529*b1cdbd2cSJim Jagielski FetchResult SAL_CALL CachedContentResultSetStub
fetchContentIdentifierStrings(sal_Int32 nRowStartPosition,sal_Int32 nRowCount,sal_Bool bDirection)530*b1cdbd2cSJim Jagielski ::fetchContentIdentifierStrings( sal_Int32 nRowStartPosition
531*b1cdbd2cSJim Jagielski , sal_Int32 nRowCount, sal_Bool bDirection )
532*b1cdbd2cSJim Jagielski throw( com::sun::star::uno::RuntimeException )
533*b1cdbd2cSJim Jagielski {
534*b1cdbd2cSJim Jagielski impl_init_xContentAccessOrigin();
535*b1cdbd2cSJim Jagielski FETCH_XXX( impl_getCurrentContentIdentifierString, m_xContentAccessOrigin );
536*b1cdbd2cSJim Jagielski }
537*b1cdbd2cSJim Jagielski
538*b1cdbd2cSJim Jagielski //virtual
539*b1cdbd2cSJim Jagielski FetchResult SAL_CALL CachedContentResultSetStub
fetchContentIdentifiers(sal_Int32 nRowStartPosition,sal_Int32 nRowCount,sal_Bool bDirection)540*b1cdbd2cSJim Jagielski ::fetchContentIdentifiers( sal_Int32 nRowStartPosition
541*b1cdbd2cSJim Jagielski , sal_Int32 nRowCount, sal_Bool bDirection )
542*b1cdbd2cSJim Jagielski throw( com::sun::star::uno::RuntimeException )
543*b1cdbd2cSJim Jagielski {
544*b1cdbd2cSJim Jagielski impl_init_xContentAccessOrigin();
545*b1cdbd2cSJim Jagielski FETCH_XXX( impl_getCurrentContentIdentifier, m_xContentAccessOrigin );
546*b1cdbd2cSJim Jagielski }
547*b1cdbd2cSJim Jagielski
548*b1cdbd2cSJim Jagielski //virtual
549*b1cdbd2cSJim Jagielski FetchResult SAL_CALL CachedContentResultSetStub
fetchContents(sal_Int32 nRowStartPosition,sal_Int32 nRowCount,sal_Bool bDirection)550*b1cdbd2cSJim Jagielski ::fetchContents( sal_Int32 nRowStartPosition
551*b1cdbd2cSJim Jagielski , sal_Int32 nRowCount, sal_Bool bDirection )
552*b1cdbd2cSJim Jagielski throw( com::sun::star::uno::RuntimeException )
553*b1cdbd2cSJim Jagielski {
554*b1cdbd2cSJim Jagielski impl_init_xContentAccessOrigin();
555*b1cdbd2cSJim Jagielski FETCH_XXX( impl_getCurrentContent, m_xContentAccessOrigin );
556*b1cdbd2cSJim Jagielski }
557*b1cdbd2cSJim Jagielski
558*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
559*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
560*b1cdbd2cSJim Jagielski // class CachedContentResultSetStubFactory
561*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
562*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
563*b1cdbd2cSJim Jagielski
CachedContentResultSetStubFactory(const Reference<XMultiServiceFactory> & rSMgr)564*b1cdbd2cSJim Jagielski CachedContentResultSetStubFactory::CachedContentResultSetStubFactory(
565*b1cdbd2cSJim Jagielski const Reference< XMultiServiceFactory > & rSMgr )
566*b1cdbd2cSJim Jagielski {
567*b1cdbd2cSJim Jagielski m_xSMgr = rSMgr;
568*b1cdbd2cSJim Jagielski }
569*b1cdbd2cSJim Jagielski
~CachedContentResultSetStubFactory()570*b1cdbd2cSJim Jagielski CachedContentResultSetStubFactory::~CachedContentResultSetStubFactory()
571*b1cdbd2cSJim Jagielski {
572*b1cdbd2cSJim Jagielski }
573*b1cdbd2cSJim Jagielski
574*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
575*b1cdbd2cSJim Jagielski // CachedContentResultSetStubFactory XInterface methods.
576*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
577*b1cdbd2cSJim Jagielski
578*b1cdbd2cSJim Jagielski XINTERFACE_IMPL_3( CachedContentResultSetStubFactory,
579*b1cdbd2cSJim Jagielski XTypeProvider,
580*b1cdbd2cSJim Jagielski XServiceInfo,
581*b1cdbd2cSJim Jagielski XCachedContentResultSetStubFactory );
582*b1cdbd2cSJim Jagielski
583*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
584*b1cdbd2cSJim Jagielski // CachedContentResultSetStubFactory XTypeProvider methods.
585*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
586*b1cdbd2cSJim Jagielski
587*b1cdbd2cSJim Jagielski XTYPEPROVIDER_IMPL_3( CachedContentResultSetStubFactory,
588*b1cdbd2cSJim Jagielski XTypeProvider,
589*b1cdbd2cSJim Jagielski XServiceInfo,
590*b1cdbd2cSJim Jagielski XCachedContentResultSetStubFactory );
591*b1cdbd2cSJim Jagielski
592*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
593*b1cdbd2cSJim Jagielski // CachedContentResultSetStubFactory XServiceInfo methods.
594*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
595*b1cdbd2cSJim Jagielski
596*b1cdbd2cSJim Jagielski XSERVICEINFO_IMPL_1( CachedContentResultSetStubFactory,
597*b1cdbd2cSJim Jagielski OUString::createFromAscii(
598*b1cdbd2cSJim Jagielski "com.sun.star.comp.ucb.CachedContentResultSetStubFactory" ),
599*b1cdbd2cSJim Jagielski OUString::createFromAscii(
600*b1cdbd2cSJim Jagielski CACHED_CRS_STUB_FACTORY_NAME ) );
601*b1cdbd2cSJim Jagielski
602*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
603*b1cdbd2cSJim Jagielski // Service factory implementation.
604*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
605*b1cdbd2cSJim Jagielski
606*b1cdbd2cSJim Jagielski ONE_INSTANCE_SERVICE_FACTORY_IMPL( CachedContentResultSetStubFactory );
607*b1cdbd2cSJim Jagielski
608*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
609*b1cdbd2cSJim Jagielski // CachedContentResultSetStubFactory XCachedContentResultSetStubFactory methods.
610*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
611*b1cdbd2cSJim Jagielski
612*b1cdbd2cSJim Jagielski //virtual
613*b1cdbd2cSJim Jagielski Reference< XResultSet > SAL_CALL CachedContentResultSetStubFactory
createCachedContentResultSetStub(const Reference<XResultSet> & xSource)614*b1cdbd2cSJim Jagielski ::createCachedContentResultSetStub(
615*b1cdbd2cSJim Jagielski const Reference< XResultSet > & xSource )
616*b1cdbd2cSJim Jagielski throw( RuntimeException )
617*b1cdbd2cSJim Jagielski {
618*b1cdbd2cSJim Jagielski if( xSource.is() )
619*b1cdbd2cSJim Jagielski {
620*b1cdbd2cSJim Jagielski Reference< XResultSet > xRet;
621*b1cdbd2cSJim Jagielski xRet = new CachedContentResultSetStub( xSource );
622*b1cdbd2cSJim Jagielski return xRet;
623*b1cdbd2cSJim Jagielski }
624*b1cdbd2cSJim Jagielski return NULL;
625*b1cdbd2cSJim Jagielski }
626*b1cdbd2cSJim Jagielski
627*b1cdbd2cSJim Jagielski
628