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_dbaccess.hxx"
26*b1cdbd2cSJim Jagielski
27*b1cdbd2cSJim Jagielski /**************************************************************************
28*b1cdbd2cSJim Jagielski TODO
29*b1cdbd2cSJim Jagielski **************************************************************************
30*b1cdbd2cSJim Jagielski
31*b1cdbd2cSJim Jagielski *************************************************************************/
32*b1cdbd2cSJim Jagielski
33*b1cdbd2cSJim Jagielski #include <vector>
34*b1cdbd2cSJim Jagielski
35*b1cdbd2cSJim Jagielski #ifndef _UCBHELPER_CONTENTIDENTIFIER_HXX
36*b1cdbd2cSJim Jagielski #include <ucbhelper/contentidentifier.hxx>
37*b1cdbd2cSJim Jagielski #endif
38*b1cdbd2cSJim Jagielski #ifndef _UCBHELPER_PROVIDERHELPER_HXX
39*b1cdbd2cSJim Jagielski #include <ucbhelper/providerhelper.hxx>
40*b1cdbd2cSJim Jagielski #endif
41*b1cdbd2cSJim Jagielski
42*b1cdbd2cSJim Jagielski #ifndef DBA_DATASUPPLIER_HXX
43*b1cdbd2cSJim Jagielski #include "myucp_datasupplier.hxx"
44*b1cdbd2cSJim Jagielski #endif
45*b1cdbd2cSJim Jagielski #ifndef DBA_CONTENTHELPER_HXX
46*b1cdbd2cSJim Jagielski #include "ContentHelper.hxx"
47*b1cdbd2cSJim Jagielski #endif
48*b1cdbd2cSJim Jagielski #ifndef _COM_SUN_STAR_CONTAINER_XHIERARCHICALNAMEACCESS_HPP_
49*b1cdbd2cSJim Jagielski #include <com/sun/star/container/XHierarchicalNameAccess.hpp>
50*b1cdbd2cSJim Jagielski #endif
51*b1cdbd2cSJim Jagielski #ifndef _TOOLS_DEBUG_HXX
52*b1cdbd2cSJim Jagielski #include <tools/debug.hxx>
53*b1cdbd2cSJim Jagielski #endif
54*b1cdbd2cSJim Jagielski
55*b1cdbd2cSJim Jagielski using namespace ::com::sun::star::uno;
56*b1cdbd2cSJim Jagielski using namespace ::com::sun::star::ucb;
57*b1cdbd2cSJim Jagielski using namespace ::com::sun::star::beans;
58*b1cdbd2cSJim Jagielski using namespace ::com::sun::star::lang;
59*b1cdbd2cSJim Jagielski using namespace ::com::sun::star::sdbc;
60*b1cdbd2cSJim Jagielski using namespace ::com::sun::star::io;
61*b1cdbd2cSJim Jagielski using namespace ::com::sun::star::container;
62*b1cdbd2cSJim Jagielski
63*b1cdbd2cSJim Jagielski // @@@ Adjust namespace name.
64*b1cdbd2cSJim Jagielski using namespace dbaccess;
65*b1cdbd2cSJim Jagielski
66*b1cdbd2cSJim Jagielski // @@@ Adjust namespace name.
67*b1cdbd2cSJim Jagielski namespace dbaccess
68*b1cdbd2cSJim Jagielski {
69*b1cdbd2cSJim Jagielski
70*b1cdbd2cSJim Jagielski //=========================================================================
71*b1cdbd2cSJim Jagielski //
72*b1cdbd2cSJim Jagielski // struct ResultListEntry.
73*b1cdbd2cSJim Jagielski //
74*b1cdbd2cSJim Jagielski //=========================================================================
75*b1cdbd2cSJim Jagielski
76*b1cdbd2cSJim Jagielski struct ResultListEntry
77*b1cdbd2cSJim Jagielski {
78*b1cdbd2cSJim Jagielski rtl::OUString aId;
79*b1cdbd2cSJim Jagielski Reference< XContentIdentifier > xId;
80*b1cdbd2cSJim Jagielski ::rtl::Reference< OContentHelper > xContent;
81*b1cdbd2cSJim Jagielski Reference< XRow > xRow;
82*b1cdbd2cSJim Jagielski const ContentProperties& rData;
83*b1cdbd2cSJim Jagielski
ResultListEntrydbaccess::ResultListEntry84*b1cdbd2cSJim Jagielski ResultListEntry( const ContentProperties& rEntry ) : rData( rEntry ) {}
85*b1cdbd2cSJim Jagielski };
86*b1cdbd2cSJim Jagielski
87*b1cdbd2cSJim Jagielski //=========================================================================
88*b1cdbd2cSJim Jagielski //
89*b1cdbd2cSJim Jagielski // ResultList.
90*b1cdbd2cSJim Jagielski //
91*b1cdbd2cSJim Jagielski //=========================================================================
92*b1cdbd2cSJim Jagielski
93*b1cdbd2cSJim Jagielski typedef std::vector< ResultListEntry* > ResultList;
94*b1cdbd2cSJim Jagielski
95*b1cdbd2cSJim Jagielski //=========================================================================
96*b1cdbd2cSJim Jagielski //
97*b1cdbd2cSJim Jagielski // struct DataSupplier_Impl.
98*b1cdbd2cSJim Jagielski //
99*b1cdbd2cSJim Jagielski //=========================================================================
100*b1cdbd2cSJim Jagielski
101*b1cdbd2cSJim Jagielski struct DataSupplier_Impl
102*b1cdbd2cSJim Jagielski {
103*b1cdbd2cSJim Jagielski osl::Mutex m_aMutex;
104*b1cdbd2cSJim Jagielski ResultList m_aResults;
105*b1cdbd2cSJim Jagielski rtl::Reference< ODocumentContainer > m_xContent;
106*b1cdbd2cSJim Jagielski Reference< XMultiServiceFactory > m_xSMgr;
107*b1cdbd2cSJim Jagielski sal_Int32 m_nOpenMode;
108*b1cdbd2cSJim Jagielski sal_Bool m_bCountFinal;
109*b1cdbd2cSJim Jagielski
DataSupplier_Impldbaccess::DataSupplier_Impl110*b1cdbd2cSJim Jagielski DataSupplier_Impl( const Reference< XMultiServiceFactory >& rxSMgr,
111*b1cdbd2cSJim Jagielski const rtl::Reference< ODocumentContainer >& rContent,
112*b1cdbd2cSJim Jagielski sal_Int32 nOpenMode )
113*b1cdbd2cSJim Jagielski : m_xContent(rContent)
114*b1cdbd2cSJim Jagielski , m_xSMgr( rxSMgr )
115*b1cdbd2cSJim Jagielski , m_nOpenMode( nOpenMode )
116*b1cdbd2cSJim Jagielski , m_bCountFinal( sal_False ) {}
117*b1cdbd2cSJim Jagielski ~DataSupplier_Impl();
118*b1cdbd2cSJim Jagielski };
119*b1cdbd2cSJim Jagielski
120*b1cdbd2cSJim Jagielski //=========================================================================
~DataSupplier_Impl()121*b1cdbd2cSJim Jagielski DataSupplier_Impl::~DataSupplier_Impl()
122*b1cdbd2cSJim Jagielski {
123*b1cdbd2cSJim Jagielski ResultList::const_iterator it = m_aResults.begin();
124*b1cdbd2cSJim Jagielski ResultList::const_iterator end = m_aResults.end();
125*b1cdbd2cSJim Jagielski
126*b1cdbd2cSJim Jagielski while ( it != end )
127*b1cdbd2cSJim Jagielski {
128*b1cdbd2cSJim Jagielski delete (*it);
129*b1cdbd2cSJim Jagielski it++;
130*b1cdbd2cSJim Jagielski }
131*b1cdbd2cSJim Jagielski }
132*b1cdbd2cSJim Jagielski
133*b1cdbd2cSJim Jagielski }
134*b1cdbd2cSJim Jagielski
135*b1cdbd2cSJim Jagielski //=========================================================================
136*b1cdbd2cSJim Jagielski //=========================================================================
137*b1cdbd2cSJim Jagielski //
138*b1cdbd2cSJim Jagielski // DataSupplier Implementation.
139*b1cdbd2cSJim Jagielski //
140*b1cdbd2cSJim Jagielski //=========================================================================
141*b1cdbd2cSJim Jagielski //=========================================================================
DBG_NAME(DataSupplier)142*b1cdbd2cSJim Jagielski DBG_NAME(DataSupplier)
143*b1cdbd2cSJim Jagielski
144*b1cdbd2cSJim Jagielski DataSupplier::DataSupplier( const Reference< XMultiServiceFactory >& rxSMgr,
145*b1cdbd2cSJim Jagielski const rtl::Reference< ODocumentContainer >& rContent,
146*b1cdbd2cSJim Jagielski sal_Int32 nOpenMode )
147*b1cdbd2cSJim Jagielski : m_pImpl( new DataSupplier_Impl( rxSMgr, rContent,nOpenMode ) )
148*b1cdbd2cSJim Jagielski {
149*b1cdbd2cSJim Jagielski DBG_CTOR(DataSupplier,NULL);
150*b1cdbd2cSJim Jagielski
151*b1cdbd2cSJim Jagielski }
152*b1cdbd2cSJim Jagielski
153*b1cdbd2cSJim Jagielski //=========================================================================
154*b1cdbd2cSJim Jagielski // virtual
~DataSupplier()155*b1cdbd2cSJim Jagielski DataSupplier::~DataSupplier()
156*b1cdbd2cSJim Jagielski {
157*b1cdbd2cSJim Jagielski
158*b1cdbd2cSJim Jagielski DBG_DTOR(DataSupplier,NULL);
159*b1cdbd2cSJim Jagielski }
160*b1cdbd2cSJim Jagielski
161*b1cdbd2cSJim Jagielski //=========================================================================
162*b1cdbd2cSJim Jagielski // virtual
queryContentIdentifierString(sal_uInt32 nIndex)163*b1cdbd2cSJim Jagielski rtl::OUString DataSupplier::queryContentIdentifierString( sal_uInt32 nIndex )
164*b1cdbd2cSJim Jagielski {
165*b1cdbd2cSJim Jagielski osl::Guard< osl::Mutex > aGuard( m_pImpl->m_aMutex );
166*b1cdbd2cSJim Jagielski
167*b1cdbd2cSJim Jagielski if ( (size_t)nIndex < m_pImpl->m_aResults.size() )
168*b1cdbd2cSJim Jagielski {
169*b1cdbd2cSJim Jagielski rtl::OUString aId = m_pImpl->m_aResults[ nIndex ]->aId;
170*b1cdbd2cSJim Jagielski if ( aId.getLength() )
171*b1cdbd2cSJim Jagielski {
172*b1cdbd2cSJim Jagielski // Already cached.
173*b1cdbd2cSJim Jagielski return aId;
174*b1cdbd2cSJim Jagielski }
175*b1cdbd2cSJim Jagielski }
176*b1cdbd2cSJim Jagielski
177*b1cdbd2cSJim Jagielski if ( getResult( nIndex ) )
178*b1cdbd2cSJim Jagielski {
179*b1cdbd2cSJim Jagielski rtl::OUString aId
180*b1cdbd2cSJim Jagielski = m_pImpl->m_xContent->getIdentifier()->getContentIdentifier();
181*b1cdbd2cSJim Jagielski
182*b1cdbd2cSJim Jagielski if ( aId.getLength() )
183*b1cdbd2cSJim Jagielski aId += ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("/"));
184*b1cdbd2cSJim Jagielski
185*b1cdbd2cSJim Jagielski aId += m_pImpl->m_aResults[ nIndex ]->rData.aTitle;
186*b1cdbd2cSJim Jagielski
187*b1cdbd2cSJim Jagielski m_pImpl->m_aResults[ nIndex ]->aId = aId;
188*b1cdbd2cSJim Jagielski return aId;
189*b1cdbd2cSJim Jagielski }
190*b1cdbd2cSJim Jagielski return rtl::OUString();
191*b1cdbd2cSJim Jagielski }
192*b1cdbd2cSJim Jagielski
193*b1cdbd2cSJim Jagielski //=========================================================================
194*b1cdbd2cSJim Jagielski // virtual
195*b1cdbd2cSJim Jagielski Reference< XContentIdentifier >
queryContentIdentifier(sal_uInt32 nIndex)196*b1cdbd2cSJim Jagielski DataSupplier::queryContentIdentifier( sal_uInt32 nIndex )
197*b1cdbd2cSJim Jagielski {
198*b1cdbd2cSJim Jagielski osl::Guard< osl::Mutex > aGuard( m_pImpl->m_aMutex );
199*b1cdbd2cSJim Jagielski
200*b1cdbd2cSJim Jagielski if ( (size_t)nIndex < m_pImpl->m_aResults.size() )
201*b1cdbd2cSJim Jagielski {
202*b1cdbd2cSJim Jagielski Reference< XContentIdentifier > xId = m_pImpl->m_aResults[ nIndex ]->xId;
203*b1cdbd2cSJim Jagielski if ( xId.is() )
204*b1cdbd2cSJim Jagielski {
205*b1cdbd2cSJim Jagielski // Already cached.
206*b1cdbd2cSJim Jagielski return xId;
207*b1cdbd2cSJim Jagielski }
208*b1cdbd2cSJim Jagielski }
209*b1cdbd2cSJim Jagielski
210*b1cdbd2cSJim Jagielski rtl::OUString aId = queryContentIdentifierString( nIndex );
211*b1cdbd2cSJim Jagielski if ( aId.getLength() )
212*b1cdbd2cSJim Jagielski {
213*b1cdbd2cSJim Jagielski Reference< XContentIdentifier > xId = new ::ucbhelper::ContentIdentifier( aId );
214*b1cdbd2cSJim Jagielski m_pImpl->m_aResults[ nIndex ]->xId = xId;
215*b1cdbd2cSJim Jagielski return xId;
216*b1cdbd2cSJim Jagielski }
217*b1cdbd2cSJim Jagielski return Reference< XContentIdentifier >();
218*b1cdbd2cSJim Jagielski }
219*b1cdbd2cSJim Jagielski
220*b1cdbd2cSJim Jagielski //=========================================================================
221*b1cdbd2cSJim Jagielski // virtual
222*b1cdbd2cSJim Jagielski Reference< XContent >
queryContent(sal_uInt32 _nIndex)223*b1cdbd2cSJim Jagielski DataSupplier::queryContent( sal_uInt32 _nIndex )
224*b1cdbd2cSJim Jagielski {
225*b1cdbd2cSJim Jagielski osl::Guard< osl::Mutex > aGuard( m_pImpl->m_aMutex );
226*b1cdbd2cSJim Jagielski
227*b1cdbd2cSJim Jagielski if ( (size_t)_nIndex < m_pImpl->m_aResults.size() )
228*b1cdbd2cSJim Jagielski {
229*b1cdbd2cSJim Jagielski Reference< XContent > xContent = m_pImpl->m_aResults[ _nIndex ]->xContent.get();
230*b1cdbd2cSJim Jagielski if ( xContent.is() )
231*b1cdbd2cSJim Jagielski {
232*b1cdbd2cSJim Jagielski // Already cached.
233*b1cdbd2cSJim Jagielski return xContent;
234*b1cdbd2cSJim Jagielski }
235*b1cdbd2cSJim Jagielski }
236*b1cdbd2cSJim Jagielski
237*b1cdbd2cSJim Jagielski Reference< XContentIdentifier > xId = queryContentIdentifier( _nIndex );
238*b1cdbd2cSJim Jagielski if ( xId.is() )
239*b1cdbd2cSJim Jagielski {
240*b1cdbd2cSJim Jagielski try
241*b1cdbd2cSJim Jagielski {
242*b1cdbd2cSJim Jagielski Reference< XContent > xContent;
243*b1cdbd2cSJim Jagielski ::rtl::OUString sName = xId->getContentIdentifier();
244*b1cdbd2cSJim Jagielski sal_Int32 nIndex = sName.lastIndexOf('/') + 1;
245*b1cdbd2cSJim Jagielski sName = sName.getToken(0,'/',nIndex);
246*b1cdbd2cSJim Jagielski
247*b1cdbd2cSJim Jagielski m_pImpl->m_aResults[ _nIndex ]->xContent = m_pImpl->m_xContent->getContent(sName);
248*b1cdbd2cSJim Jagielski
249*b1cdbd2cSJim Jagielski xContent = m_pImpl->m_aResults[ _nIndex ]->xContent.get();
250*b1cdbd2cSJim Jagielski return xContent;
251*b1cdbd2cSJim Jagielski
252*b1cdbd2cSJim Jagielski }
253*b1cdbd2cSJim Jagielski catch ( IllegalIdentifierException& )
254*b1cdbd2cSJim Jagielski {
255*b1cdbd2cSJim Jagielski }
256*b1cdbd2cSJim Jagielski }
257*b1cdbd2cSJim Jagielski return Reference< XContent >();
258*b1cdbd2cSJim Jagielski }
259*b1cdbd2cSJim Jagielski
260*b1cdbd2cSJim Jagielski //=========================================================================
261*b1cdbd2cSJim Jagielski // virtual
getResult(sal_uInt32 nIndex)262*b1cdbd2cSJim Jagielski sal_Bool DataSupplier::getResult( sal_uInt32 nIndex )
263*b1cdbd2cSJim Jagielski {
264*b1cdbd2cSJim Jagielski osl::ClearableGuard< osl::Mutex > aGuard( m_pImpl->m_aMutex );
265*b1cdbd2cSJim Jagielski
266*b1cdbd2cSJim Jagielski if ( (size_t)nIndex < m_pImpl->m_aResults.size() )
267*b1cdbd2cSJim Jagielski {
268*b1cdbd2cSJim Jagielski // Result already present.
269*b1cdbd2cSJim Jagielski return sal_True;
270*b1cdbd2cSJim Jagielski }
271*b1cdbd2cSJim Jagielski
272*b1cdbd2cSJim Jagielski // Result not (yet) present.
273*b1cdbd2cSJim Jagielski
274*b1cdbd2cSJim Jagielski if ( m_pImpl->m_bCountFinal )
275*b1cdbd2cSJim Jagielski return sal_False;
276*b1cdbd2cSJim Jagielski
277*b1cdbd2cSJim Jagielski // Try to obtain result...
278*b1cdbd2cSJim Jagielski
279*b1cdbd2cSJim Jagielski sal_uInt32 nOldCount = m_pImpl->m_aResults.size();
280*b1cdbd2cSJim Jagielski sal_Bool bFound = sal_False;
281*b1cdbd2cSJim Jagielski sal_uInt32 nPos = nOldCount;
282*b1cdbd2cSJim Jagielski
283*b1cdbd2cSJim Jagielski // @@@ Obtain data and put it into result list...
284*b1cdbd2cSJim Jagielski Sequence< ::rtl::OUString> aSeq = m_pImpl->m_xContent->getElementNames();
285*b1cdbd2cSJim Jagielski if ( nIndex < sal::static_int_cast< sal_uInt32 >( aSeq.getLength() ) )
286*b1cdbd2cSJim Jagielski {
287*b1cdbd2cSJim Jagielski const ::rtl::OUString* pIter = aSeq.getConstArray();
288*b1cdbd2cSJim Jagielski const ::rtl::OUString* pEnd = pIter + aSeq.getLength();
289*b1cdbd2cSJim Jagielski for(pIter = pIter + nPos;pIter != pEnd;++pIter,++nPos)
290*b1cdbd2cSJim Jagielski {
291*b1cdbd2cSJim Jagielski m_pImpl->m_aResults.push_back(
292*b1cdbd2cSJim Jagielski new ResultListEntry( m_pImpl->m_xContent->getContent(*pIter)->getContentProperties() ) );
293*b1cdbd2cSJim Jagielski
294*b1cdbd2cSJim Jagielski if ( nPos == nIndex )
295*b1cdbd2cSJim Jagielski {
296*b1cdbd2cSJim Jagielski // Result obtained.
297*b1cdbd2cSJim Jagielski bFound = sal_True;
298*b1cdbd2cSJim Jagielski break;
299*b1cdbd2cSJim Jagielski }
300*b1cdbd2cSJim Jagielski }
301*b1cdbd2cSJim Jagielski }
302*b1cdbd2cSJim Jagielski
303*b1cdbd2cSJim Jagielski if ( !bFound )
304*b1cdbd2cSJim Jagielski m_pImpl->m_bCountFinal = sal_True;
305*b1cdbd2cSJim Jagielski
306*b1cdbd2cSJim Jagielski rtl::Reference< ::ucbhelper::ResultSet > xResultSet = getResultSet().get();
307*b1cdbd2cSJim Jagielski if ( xResultSet.is() )
308*b1cdbd2cSJim Jagielski {
309*b1cdbd2cSJim Jagielski // Callbacks follow!
310*b1cdbd2cSJim Jagielski aGuard.clear();
311*b1cdbd2cSJim Jagielski
312*b1cdbd2cSJim Jagielski if ( (size_t)nOldCount < m_pImpl->m_aResults.size() )
313*b1cdbd2cSJim Jagielski xResultSet->rowCountChanged(
314*b1cdbd2cSJim Jagielski nOldCount, m_pImpl->m_aResults.size() );
315*b1cdbd2cSJim Jagielski
316*b1cdbd2cSJim Jagielski if ( m_pImpl->m_bCountFinal )
317*b1cdbd2cSJim Jagielski xResultSet->rowCountFinal();
318*b1cdbd2cSJim Jagielski }
319*b1cdbd2cSJim Jagielski
320*b1cdbd2cSJim Jagielski return bFound;
321*b1cdbd2cSJim Jagielski }
322*b1cdbd2cSJim Jagielski
323*b1cdbd2cSJim Jagielski //=========================================================================
324*b1cdbd2cSJim Jagielski // virtual
totalCount()325*b1cdbd2cSJim Jagielski sal_uInt32 DataSupplier::totalCount()
326*b1cdbd2cSJim Jagielski {
327*b1cdbd2cSJim Jagielski osl::ClearableGuard< osl::Mutex > aGuard( m_pImpl->m_aMutex );
328*b1cdbd2cSJim Jagielski
329*b1cdbd2cSJim Jagielski if ( m_pImpl->m_bCountFinal )
330*b1cdbd2cSJim Jagielski return m_pImpl->m_aResults.size();
331*b1cdbd2cSJim Jagielski
332*b1cdbd2cSJim Jagielski sal_uInt32 nOldCount = m_pImpl->m_aResults.size();
333*b1cdbd2cSJim Jagielski
334*b1cdbd2cSJim Jagielski // @@@ Obtain data and put it into result list...
335*b1cdbd2cSJim Jagielski Sequence< ::rtl::OUString> aSeq = m_pImpl->m_xContent->getElementNames();
336*b1cdbd2cSJim Jagielski const ::rtl::OUString* pIter = aSeq.getConstArray();
337*b1cdbd2cSJim Jagielski const ::rtl::OUString* pEnd = pIter + aSeq.getLength();
338*b1cdbd2cSJim Jagielski for(;pIter != pEnd;++pIter)
339*b1cdbd2cSJim Jagielski m_pImpl->m_aResults.push_back(
340*b1cdbd2cSJim Jagielski new ResultListEntry( m_pImpl->m_xContent->getContent(*pIter)->getContentProperties() ) );
341*b1cdbd2cSJim Jagielski
342*b1cdbd2cSJim Jagielski m_pImpl->m_bCountFinal = sal_True;
343*b1cdbd2cSJim Jagielski
344*b1cdbd2cSJim Jagielski rtl::Reference< ::ucbhelper::ResultSet > xResultSet = getResultSet().get();
345*b1cdbd2cSJim Jagielski if ( xResultSet.is() )
346*b1cdbd2cSJim Jagielski {
347*b1cdbd2cSJim Jagielski // Callbacks follow!
348*b1cdbd2cSJim Jagielski aGuard.clear();
349*b1cdbd2cSJim Jagielski
350*b1cdbd2cSJim Jagielski if ( (size_t)nOldCount < m_pImpl->m_aResults.size() )
351*b1cdbd2cSJim Jagielski xResultSet->rowCountChanged(
352*b1cdbd2cSJim Jagielski nOldCount, m_pImpl->m_aResults.size() );
353*b1cdbd2cSJim Jagielski
354*b1cdbd2cSJim Jagielski xResultSet->rowCountFinal();
355*b1cdbd2cSJim Jagielski }
356*b1cdbd2cSJim Jagielski
357*b1cdbd2cSJim Jagielski return m_pImpl->m_aResults.size();
358*b1cdbd2cSJim Jagielski }
359*b1cdbd2cSJim Jagielski
360*b1cdbd2cSJim Jagielski //=========================================================================
361*b1cdbd2cSJim Jagielski // virtual
currentCount()362*b1cdbd2cSJim Jagielski sal_uInt32 DataSupplier::currentCount()
363*b1cdbd2cSJim Jagielski {
364*b1cdbd2cSJim Jagielski return m_pImpl->m_aResults.size();
365*b1cdbd2cSJim Jagielski }
366*b1cdbd2cSJim Jagielski
367*b1cdbd2cSJim Jagielski //=========================================================================
368*b1cdbd2cSJim Jagielski // virtual
isCountFinal()369*b1cdbd2cSJim Jagielski sal_Bool DataSupplier::isCountFinal()
370*b1cdbd2cSJim Jagielski {
371*b1cdbd2cSJim Jagielski return m_pImpl->m_bCountFinal;
372*b1cdbd2cSJim Jagielski }
373*b1cdbd2cSJim Jagielski
374*b1cdbd2cSJim Jagielski //=========================================================================
375*b1cdbd2cSJim Jagielski // virtual
376*b1cdbd2cSJim Jagielski Reference< XRow >
queryPropertyValues(sal_uInt32 nIndex)377*b1cdbd2cSJim Jagielski DataSupplier::queryPropertyValues( sal_uInt32 nIndex )
378*b1cdbd2cSJim Jagielski {
379*b1cdbd2cSJim Jagielski osl::Guard< osl::Mutex > aGuard( m_pImpl->m_aMutex );
380*b1cdbd2cSJim Jagielski
381*b1cdbd2cSJim Jagielski if ( (size_t)nIndex < m_pImpl->m_aResults.size() )
382*b1cdbd2cSJim Jagielski {
383*b1cdbd2cSJim Jagielski Reference< XRow > xRow = m_pImpl->m_aResults[ nIndex ]->xRow;
384*b1cdbd2cSJim Jagielski if ( xRow.is() )
385*b1cdbd2cSJim Jagielski {
386*b1cdbd2cSJim Jagielski // Already cached.
387*b1cdbd2cSJim Jagielski return xRow;
388*b1cdbd2cSJim Jagielski }
389*b1cdbd2cSJim Jagielski }
390*b1cdbd2cSJim Jagielski
391*b1cdbd2cSJim Jagielski if ( getResult( nIndex ) )
392*b1cdbd2cSJim Jagielski {
393*b1cdbd2cSJim Jagielski if ( !m_pImpl->m_aResults[ nIndex ]->xContent.is() )
394*b1cdbd2cSJim Jagielski queryContent(nIndex);
395*b1cdbd2cSJim Jagielski
396*b1cdbd2cSJim Jagielski Reference< XRow > xRow = m_pImpl->m_aResults[ nIndex ]->xContent->getPropertyValues(getResultSet()->getProperties());
397*b1cdbd2cSJim Jagielski m_pImpl->m_aResults[ nIndex ]->xRow = xRow;
398*b1cdbd2cSJim Jagielski return xRow;
399*b1cdbd2cSJim Jagielski }
400*b1cdbd2cSJim Jagielski
401*b1cdbd2cSJim Jagielski return Reference< XRow >();
402*b1cdbd2cSJim Jagielski }
403*b1cdbd2cSJim Jagielski
404*b1cdbd2cSJim Jagielski //=========================================================================
405*b1cdbd2cSJim Jagielski // virtual
releasePropertyValues(sal_uInt32 nIndex)406*b1cdbd2cSJim Jagielski void DataSupplier::releasePropertyValues( sal_uInt32 nIndex )
407*b1cdbd2cSJim Jagielski {
408*b1cdbd2cSJim Jagielski osl::Guard< osl::Mutex > aGuard( m_pImpl->m_aMutex );
409*b1cdbd2cSJim Jagielski
410*b1cdbd2cSJim Jagielski if ( (size_t)nIndex < m_pImpl->m_aResults.size() )
411*b1cdbd2cSJim Jagielski m_pImpl->m_aResults[ nIndex ]->xRow = Reference< XRow >();
412*b1cdbd2cSJim Jagielski }
413*b1cdbd2cSJim Jagielski
414*b1cdbd2cSJim Jagielski //=========================================================================
415*b1cdbd2cSJim Jagielski // virtual
close()416*b1cdbd2cSJim Jagielski void DataSupplier::close()
417*b1cdbd2cSJim Jagielski {
418*b1cdbd2cSJim Jagielski }
419*b1cdbd2cSJim Jagielski
420*b1cdbd2cSJim Jagielski //=========================================================================
421*b1cdbd2cSJim Jagielski // virtual
validate()422*b1cdbd2cSJim Jagielski void DataSupplier::validate()
423*b1cdbd2cSJim Jagielski throw( ResultSetException )
424*b1cdbd2cSJim Jagielski {
425*b1cdbd2cSJim Jagielski }
426*b1cdbd2cSJim Jagielski
427