1*2f86921cSAndrew Rist /**************************************************************
2cdf0e10cSrcweir *
3*2f86921cSAndrew Rist * Licensed to the Apache Software Foundation (ASF) under one
4*2f86921cSAndrew Rist * or more contributor license agreements. See the NOTICE file
5*2f86921cSAndrew Rist * distributed with this work for additional information
6*2f86921cSAndrew Rist * regarding copyright ownership. The ASF licenses this file
7*2f86921cSAndrew Rist * to you under the Apache License, Version 2.0 (the
8*2f86921cSAndrew Rist * "License"); you may not use this file except in compliance
9*2f86921cSAndrew Rist * with the License. You may obtain a copy of the License at
10*2f86921cSAndrew Rist *
11*2f86921cSAndrew Rist * http://www.apache.org/licenses/LICENSE-2.0
12*2f86921cSAndrew Rist *
13*2f86921cSAndrew Rist * Unless required by applicable law or agreed to in writing,
14*2f86921cSAndrew Rist * software distributed under the License is distributed on an
15*2f86921cSAndrew Rist * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16*2f86921cSAndrew Rist * KIND, either express or implied. See the License for the
17*2f86921cSAndrew Rist * specific language governing permissions and limitations
18*2f86921cSAndrew Rist * under the License.
19*2f86921cSAndrew Rist *
20*2f86921cSAndrew Rist *************************************************************/
21*2f86921cSAndrew Rist
22*2f86921cSAndrew Rist
23cdf0e10cSrcweir
24cdf0e10cSrcweir // MARKER(update_precomp.py): autogen include statement, do not remove
25cdf0e10cSrcweir #include "precompiled_ucb.hxx"
26cdf0e10cSrcweir
27cdf0e10cSrcweir /**************************************************************************
28cdf0e10cSrcweir TODO
29cdf0e10cSrcweir **************************************************************************
30cdf0e10cSrcweir
31cdf0e10cSrcweir *************************************************************************/
32cdf0e10cSrcweir
33cdf0e10cSrcweir #include <vector>
34cdf0e10cSrcweir #include <osl/diagnose.h>
35cdf0e10cSrcweir #include <com/sun/star/container/XEnumeration.hpp>
36cdf0e10cSrcweir #include <com/sun/star/container/XNamed.hpp>
37cdf0e10cSrcweir #include <ucbhelper/contentidentifier.hxx>
38cdf0e10cSrcweir #include <ucbhelper/providerhelper.hxx>
39cdf0e10cSrcweir #include "pkgdatasupplier.hxx"
40cdf0e10cSrcweir #include "pkgcontent.hxx"
41cdf0e10cSrcweir #include "pkgprovider.hxx"
42cdf0e10cSrcweir
43cdf0e10cSrcweir #include "../inc/urihelper.hxx"
44cdf0e10cSrcweir
45cdf0e10cSrcweir using namespace com::sun::star;
46cdf0e10cSrcweir using namespace package_ucp;
47cdf0e10cSrcweir
48cdf0e10cSrcweir namespace package_ucp
49cdf0e10cSrcweir {
50cdf0e10cSrcweir
51cdf0e10cSrcweir //=========================================================================
52cdf0e10cSrcweir //
53cdf0e10cSrcweir // struct ResultListEntry.
54cdf0e10cSrcweir //
55cdf0e10cSrcweir //=========================================================================
56cdf0e10cSrcweir
57cdf0e10cSrcweir struct ResultListEntry
58cdf0e10cSrcweir {
59cdf0e10cSrcweir rtl::OUString aURL;
60cdf0e10cSrcweir uno::Reference< ucb::XContentIdentifier > xId;
61cdf0e10cSrcweir uno::Reference< ucb::XContent > xContent;
62cdf0e10cSrcweir uno::Reference< sdbc::XRow > xRow;
63cdf0e10cSrcweir
ResultListEntrypackage_ucp::ResultListEntry64cdf0e10cSrcweir ResultListEntry( const rtl::OUString& rURL ) : aURL( rURL ) {}
65cdf0e10cSrcweir };
66cdf0e10cSrcweir
67cdf0e10cSrcweir //=========================================================================
68cdf0e10cSrcweir //
69cdf0e10cSrcweir // ResultList.
70cdf0e10cSrcweir //
71cdf0e10cSrcweir //=========================================================================
72cdf0e10cSrcweir
73cdf0e10cSrcweir typedef std::vector< ResultListEntry* > ResultList;
74cdf0e10cSrcweir
75cdf0e10cSrcweir //=========================================================================
76cdf0e10cSrcweir //
77cdf0e10cSrcweir // struct DataSupplier_Impl.
78cdf0e10cSrcweir //
79cdf0e10cSrcweir //=========================================================================
80cdf0e10cSrcweir
81cdf0e10cSrcweir struct DataSupplier_Impl
82cdf0e10cSrcweir {
83cdf0e10cSrcweir osl::Mutex m_aMutex;
84cdf0e10cSrcweir ResultList m_aResults;
85cdf0e10cSrcweir rtl::Reference< Content > m_xContent;
86cdf0e10cSrcweir uno::Reference< lang::XMultiServiceFactory > m_xSMgr;
87cdf0e10cSrcweir uno::Reference< container::XEnumeration > m_xFolderEnum;
88cdf0e10cSrcweir sal_Int32 m_nOpenMode;
89cdf0e10cSrcweir sal_Bool m_bCountFinal;
90cdf0e10cSrcweir sal_Bool m_bThrowException;
91cdf0e10cSrcweir
DataSupplier_Implpackage_ucp::DataSupplier_Impl92cdf0e10cSrcweir DataSupplier_Impl(
93cdf0e10cSrcweir const uno::Reference< lang::XMultiServiceFactory >& rxSMgr,
94cdf0e10cSrcweir const rtl::Reference< Content >& rContent,
95cdf0e10cSrcweir sal_Int32 nOpenMode )
96cdf0e10cSrcweir : m_xContent( rContent ), m_xSMgr( rxSMgr ),
97cdf0e10cSrcweir m_xFolderEnum( rContent->getIterator() ), m_nOpenMode( nOpenMode ),
98cdf0e10cSrcweir m_bCountFinal( !m_xFolderEnum.is() ), m_bThrowException( m_bCountFinal )
99cdf0e10cSrcweir {}
100cdf0e10cSrcweir ~DataSupplier_Impl();
101cdf0e10cSrcweir };
102cdf0e10cSrcweir
103cdf0e10cSrcweir //=========================================================================
~DataSupplier_Impl()104cdf0e10cSrcweir DataSupplier_Impl::~DataSupplier_Impl()
105cdf0e10cSrcweir {
106cdf0e10cSrcweir ResultList::const_iterator it = m_aResults.begin();
107cdf0e10cSrcweir ResultList::const_iterator end = m_aResults.end();
108cdf0e10cSrcweir
109cdf0e10cSrcweir while ( it != end )
110cdf0e10cSrcweir {
111cdf0e10cSrcweir delete (*it);
112cdf0e10cSrcweir it++;
113cdf0e10cSrcweir }
114cdf0e10cSrcweir }
115cdf0e10cSrcweir
116cdf0e10cSrcweir }
117cdf0e10cSrcweir
118cdf0e10cSrcweir //=========================================================================
119cdf0e10cSrcweir //=========================================================================
120cdf0e10cSrcweir //
121cdf0e10cSrcweir // DataSupplier Implementation.
122cdf0e10cSrcweir //
123cdf0e10cSrcweir //=========================================================================
124cdf0e10cSrcweir //=========================================================================
125cdf0e10cSrcweir
DataSupplier(const uno::Reference<lang::XMultiServiceFactory> & rxSMgr,const rtl::Reference<Content> & rContent,sal_Int32 nOpenMode)126cdf0e10cSrcweir DataSupplier::DataSupplier(
127cdf0e10cSrcweir const uno::Reference< lang::XMultiServiceFactory >& rxSMgr,
128cdf0e10cSrcweir const rtl::Reference< Content >& rContent,
129cdf0e10cSrcweir sal_Int32 nOpenMode )
130cdf0e10cSrcweir : m_pImpl( new DataSupplier_Impl( rxSMgr, rContent, nOpenMode ) )
131cdf0e10cSrcweir {
132cdf0e10cSrcweir }
133cdf0e10cSrcweir
134cdf0e10cSrcweir //=========================================================================
135cdf0e10cSrcweir // virtual
~DataSupplier()136cdf0e10cSrcweir DataSupplier::~DataSupplier()
137cdf0e10cSrcweir {
138cdf0e10cSrcweir delete m_pImpl;
139cdf0e10cSrcweir }
140cdf0e10cSrcweir
141cdf0e10cSrcweir //=========================================================================
142cdf0e10cSrcweir // virtual
queryContentIdentifierString(sal_uInt32 nIndex)143cdf0e10cSrcweir rtl::OUString DataSupplier::queryContentIdentifierString( sal_uInt32 nIndex )
144cdf0e10cSrcweir {
145cdf0e10cSrcweir osl::Guard< osl::Mutex > aGuard( m_pImpl->m_aMutex );
146cdf0e10cSrcweir
147cdf0e10cSrcweir if ( nIndex < m_pImpl->m_aResults.size() )
148cdf0e10cSrcweir {
149cdf0e10cSrcweir rtl::OUString aId = m_pImpl->m_aResults[ nIndex ]->aURL;
150cdf0e10cSrcweir if ( aId.getLength() )
151cdf0e10cSrcweir {
152cdf0e10cSrcweir // Already cached.
153cdf0e10cSrcweir return aId;
154cdf0e10cSrcweir }
155cdf0e10cSrcweir }
156cdf0e10cSrcweir
157cdf0e10cSrcweir if ( getResult( nIndex ) )
158cdf0e10cSrcweir {
159cdf0e10cSrcweir // Note: getResult fills m_pImpl->m_aResults[ nIndex ]->aURL.
160cdf0e10cSrcweir return m_pImpl->m_aResults[ nIndex ]->aURL;
161cdf0e10cSrcweir }
162cdf0e10cSrcweir return rtl::OUString();
163cdf0e10cSrcweir }
164cdf0e10cSrcweir
165cdf0e10cSrcweir //=========================================================================
166cdf0e10cSrcweir // virtual
167cdf0e10cSrcweir uno::Reference< ucb::XContentIdentifier >
queryContentIdentifier(sal_uInt32 nIndex)168cdf0e10cSrcweir DataSupplier::queryContentIdentifier( sal_uInt32 nIndex )
169cdf0e10cSrcweir {
170cdf0e10cSrcweir osl::Guard< osl::Mutex > aGuard( m_pImpl->m_aMutex );
171cdf0e10cSrcweir
172cdf0e10cSrcweir if ( nIndex < m_pImpl->m_aResults.size() )
173cdf0e10cSrcweir {
174cdf0e10cSrcweir uno::Reference< ucb::XContentIdentifier > xId
175cdf0e10cSrcweir = m_pImpl->m_aResults[ nIndex ]->xId;
176cdf0e10cSrcweir if ( xId.is() )
177cdf0e10cSrcweir {
178cdf0e10cSrcweir // Already cached.
179cdf0e10cSrcweir return xId;
180cdf0e10cSrcweir }
181cdf0e10cSrcweir }
182cdf0e10cSrcweir
183cdf0e10cSrcweir rtl::OUString aId = queryContentIdentifierString( nIndex );
184cdf0e10cSrcweir if ( aId.getLength() )
185cdf0e10cSrcweir {
186cdf0e10cSrcweir uno::Reference< ucb::XContentIdentifier > xId
187cdf0e10cSrcweir = new ::ucbhelper::ContentIdentifier( aId );
188cdf0e10cSrcweir m_pImpl->m_aResults[ nIndex ]->xId = xId;
189cdf0e10cSrcweir return xId;
190cdf0e10cSrcweir }
191cdf0e10cSrcweir return uno::Reference< ucb::XContentIdentifier >();
192cdf0e10cSrcweir }
193cdf0e10cSrcweir
194cdf0e10cSrcweir //=========================================================================
195cdf0e10cSrcweir // virtual
queryContent(sal_uInt32 nIndex)196cdf0e10cSrcweir uno::Reference< ucb::XContent > DataSupplier::queryContent(
197cdf0e10cSrcweir sal_uInt32 nIndex )
198cdf0e10cSrcweir {
199cdf0e10cSrcweir osl::Guard< osl::Mutex > aGuard( m_pImpl->m_aMutex );
200cdf0e10cSrcweir
201cdf0e10cSrcweir if ( nIndex < m_pImpl->m_aResults.size() )
202cdf0e10cSrcweir {
203cdf0e10cSrcweir uno::Reference< ucb::XContent > xContent
204cdf0e10cSrcweir = m_pImpl->m_aResults[ nIndex ]->xContent;
205cdf0e10cSrcweir if ( xContent.is() )
206cdf0e10cSrcweir {
207cdf0e10cSrcweir // Already cached.
208cdf0e10cSrcweir return xContent;
209cdf0e10cSrcweir }
210cdf0e10cSrcweir }
211cdf0e10cSrcweir
212cdf0e10cSrcweir uno::Reference< ucb::XContentIdentifier > xId
213cdf0e10cSrcweir = queryContentIdentifier( nIndex );
214cdf0e10cSrcweir if ( xId.is() )
215cdf0e10cSrcweir {
216cdf0e10cSrcweir try
217cdf0e10cSrcweir {
218cdf0e10cSrcweir uno::Reference< ucb::XContent > xContent
219cdf0e10cSrcweir = m_pImpl->m_xContent->getProvider()->queryContent( xId );
220cdf0e10cSrcweir m_pImpl->m_aResults[ nIndex ]->xContent = xContent;
221cdf0e10cSrcweir return xContent;
222cdf0e10cSrcweir
223cdf0e10cSrcweir }
224cdf0e10cSrcweir catch ( ucb::IllegalIdentifierException const & )
225cdf0e10cSrcweir {
226cdf0e10cSrcweir }
227cdf0e10cSrcweir }
228cdf0e10cSrcweir return uno::Reference< ucb::XContent >();
229cdf0e10cSrcweir }
230cdf0e10cSrcweir
231cdf0e10cSrcweir //=========================================================================
232cdf0e10cSrcweir // virtual
getResult(sal_uInt32 nIndex)233cdf0e10cSrcweir sal_Bool DataSupplier::getResult( sal_uInt32 nIndex )
234cdf0e10cSrcweir {
235cdf0e10cSrcweir osl::ClearableGuard< osl::Mutex > aGuard( m_pImpl->m_aMutex );
236cdf0e10cSrcweir
237cdf0e10cSrcweir if ( m_pImpl->m_aResults.size() > nIndex )
238cdf0e10cSrcweir {
239cdf0e10cSrcweir // Result already present.
240cdf0e10cSrcweir return sal_True;
241cdf0e10cSrcweir }
242cdf0e10cSrcweir
243cdf0e10cSrcweir // Result not (yet) present.
244cdf0e10cSrcweir
245cdf0e10cSrcweir if ( m_pImpl->m_bCountFinal )
246cdf0e10cSrcweir return sal_False;
247cdf0e10cSrcweir
248cdf0e10cSrcweir // Try to obtain result...
249cdf0e10cSrcweir
250cdf0e10cSrcweir sal_uInt32 nOldCount = m_pImpl->m_aResults.size();
251cdf0e10cSrcweir sal_Bool bFound = sal_False;
252cdf0e10cSrcweir sal_uInt32 nPos = nOldCount;
253cdf0e10cSrcweir
254cdf0e10cSrcweir while ( m_pImpl->m_xFolderEnum->hasMoreElements() )
255cdf0e10cSrcweir {
256cdf0e10cSrcweir try
257cdf0e10cSrcweir {
258cdf0e10cSrcweir uno::Reference< container::XNamed > xNamed;
259cdf0e10cSrcweir m_pImpl->m_xFolderEnum->nextElement() >>= xNamed;
260cdf0e10cSrcweir
261cdf0e10cSrcweir if ( !xNamed.is() )
262cdf0e10cSrcweir {
263cdf0e10cSrcweir OSL_ENSURE( sal_False,
264cdf0e10cSrcweir "DataSupplier::getResult - Got no XNamed!" );
265cdf0e10cSrcweir break;
266cdf0e10cSrcweir }
267cdf0e10cSrcweir
268cdf0e10cSrcweir rtl::OUString aName = xNamed->getName();
269cdf0e10cSrcweir
270cdf0e10cSrcweir if ( !aName.getLength() )
271cdf0e10cSrcweir {
272cdf0e10cSrcweir OSL_ENSURE( sal_False,
273cdf0e10cSrcweir "DataSupplier::getResult - Empty name!" );
274cdf0e10cSrcweir break;
275cdf0e10cSrcweir }
276cdf0e10cSrcweir
277cdf0e10cSrcweir // Assemble URL for child.
278cdf0e10cSrcweir rtl::OUString aURL = assembleChildURL( aName );
279cdf0e10cSrcweir
280cdf0e10cSrcweir m_pImpl->m_aResults.push_back( new ResultListEntry( aURL ) );
281cdf0e10cSrcweir
282cdf0e10cSrcweir if ( nPos == nIndex )
283cdf0e10cSrcweir {
284cdf0e10cSrcweir // Result obtained.
285cdf0e10cSrcweir bFound = sal_True;
286cdf0e10cSrcweir break;
287cdf0e10cSrcweir }
288cdf0e10cSrcweir
289cdf0e10cSrcweir nPos++;
290cdf0e10cSrcweir }
291cdf0e10cSrcweir catch ( container::NoSuchElementException const & )
292cdf0e10cSrcweir {
293cdf0e10cSrcweir m_pImpl->m_bThrowException = sal_True;
294cdf0e10cSrcweir break;
295cdf0e10cSrcweir }
296cdf0e10cSrcweir catch ( lang::WrappedTargetException const & )
297cdf0e10cSrcweir {
298cdf0e10cSrcweir m_pImpl->m_bThrowException = sal_True;
299cdf0e10cSrcweir break;
300cdf0e10cSrcweir }
301cdf0e10cSrcweir }
302cdf0e10cSrcweir
303cdf0e10cSrcweir if ( !bFound )
304cdf0e10cSrcweir m_pImpl->m_bCountFinal = sal_True;
305cdf0e10cSrcweir
306cdf0e10cSrcweir rtl::Reference< ::ucbhelper::ResultSet > xResultSet = getResultSet().get();
307cdf0e10cSrcweir if ( xResultSet.is() )
308cdf0e10cSrcweir {
309cdf0e10cSrcweir // Callbacks follow!
310cdf0e10cSrcweir aGuard.clear();
311cdf0e10cSrcweir
312cdf0e10cSrcweir if ( nOldCount < m_pImpl->m_aResults.size() )
313cdf0e10cSrcweir xResultSet->rowCountChanged(
314cdf0e10cSrcweir nOldCount, m_pImpl->m_aResults.size() );
315cdf0e10cSrcweir
316cdf0e10cSrcweir if ( m_pImpl->m_bCountFinal )
317cdf0e10cSrcweir xResultSet->rowCountFinal();
318cdf0e10cSrcweir }
319cdf0e10cSrcweir
320cdf0e10cSrcweir return bFound;
321cdf0e10cSrcweir }
322cdf0e10cSrcweir
323cdf0e10cSrcweir //=========================================================================
324cdf0e10cSrcweir // virtual
totalCount()325cdf0e10cSrcweir sal_uInt32 DataSupplier::totalCount()
326cdf0e10cSrcweir {
327cdf0e10cSrcweir osl::ClearableGuard< osl::Mutex > aGuard( m_pImpl->m_aMutex );
328cdf0e10cSrcweir
329cdf0e10cSrcweir if ( m_pImpl->m_bCountFinal )
330cdf0e10cSrcweir return m_pImpl->m_aResults.size();
331cdf0e10cSrcweir
332cdf0e10cSrcweir sal_uInt32 nOldCount = m_pImpl->m_aResults.size();
333cdf0e10cSrcweir
334cdf0e10cSrcweir while ( m_pImpl->m_xFolderEnum->hasMoreElements() )
335cdf0e10cSrcweir {
336cdf0e10cSrcweir try
337cdf0e10cSrcweir {
338cdf0e10cSrcweir uno::Reference< container::XNamed > xNamed;
339cdf0e10cSrcweir m_pImpl->m_xFolderEnum->nextElement() >>= xNamed;
340cdf0e10cSrcweir
341cdf0e10cSrcweir if ( !xNamed.is() )
342cdf0e10cSrcweir {
343cdf0e10cSrcweir OSL_ENSURE( sal_False,
344cdf0e10cSrcweir "DataSupplier::getResult - Got no XNamed!" );
345cdf0e10cSrcweir break;
346cdf0e10cSrcweir }
347cdf0e10cSrcweir
348cdf0e10cSrcweir rtl::OUString aName = xNamed->getName();
349cdf0e10cSrcweir
350cdf0e10cSrcweir if ( !aName.getLength() )
351cdf0e10cSrcweir {
352cdf0e10cSrcweir OSL_ENSURE( sal_False,
353cdf0e10cSrcweir "DataSupplier::getResult - Empty name!" );
354cdf0e10cSrcweir break;
355cdf0e10cSrcweir }
356cdf0e10cSrcweir
357cdf0e10cSrcweir // Assemble URL for child.
358cdf0e10cSrcweir rtl::OUString aURL = assembleChildURL( aName );
359cdf0e10cSrcweir
360cdf0e10cSrcweir m_pImpl->m_aResults.push_back( new ResultListEntry( aURL ) );
361cdf0e10cSrcweir }
362cdf0e10cSrcweir catch ( container::NoSuchElementException const & )
363cdf0e10cSrcweir {
364cdf0e10cSrcweir m_pImpl->m_bThrowException = sal_True;
365cdf0e10cSrcweir break;
366cdf0e10cSrcweir }
367cdf0e10cSrcweir catch ( lang::WrappedTargetException const & )
368cdf0e10cSrcweir {
369cdf0e10cSrcweir m_pImpl->m_bThrowException = sal_True;
370cdf0e10cSrcweir break;
371cdf0e10cSrcweir }
372cdf0e10cSrcweir }
373cdf0e10cSrcweir
374cdf0e10cSrcweir m_pImpl->m_bCountFinal = sal_True;
375cdf0e10cSrcweir
376cdf0e10cSrcweir rtl::Reference< ::ucbhelper::ResultSet > xResultSet = getResultSet().get();
377cdf0e10cSrcweir if ( xResultSet.is() )
378cdf0e10cSrcweir {
379cdf0e10cSrcweir // Callbacks follow!
380cdf0e10cSrcweir aGuard.clear();
381cdf0e10cSrcweir
382cdf0e10cSrcweir if ( nOldCount < m_pImpl->m_aResults.size() )
383cdf0e10cSrcweir xResultSet->rowCountChanged(
384cdf0e10cSrcweir nOldCount, m_pImpl->m_aResults.size() );
385cdf0e10cSrcweir
386cdf0e10cSrcweir xResultSet->rowCountFinal();
387cdf0e10cSrcweir }
388cdf0e10cSrcweir
389cdf0e10cSrcweir return m_pImpl->m_aResults.size();
390cdf0e10cSrcweir }
391cdf0e10cSrcweir
392cdf0e10cSrcweir //=========================================================================
393cdf0e10cSrcweir // virtual
currentCount()394cdf0e10cSrcweir sal_uInt32 DataSupplier::currentCount()
395cdf0e10cSrcweir {
396cdf0e10cSrcweir return m_pImpl->m_aResults.size();
397cdf0e10cSrcweir }
398cdf0e10cSrcweir
399cdf0e10cSrcweir //=========================================================================
400cdf0e10cSrcweir // virtual
isCountFinal()401cdf0e10cSrcweir sal_Bool DataSupplier::isCountFinal()
402cdf0e10cSrcweir {
403cdf0e10cSrcweir return m_pImpl->m_bCountFinal;
404cdf0e10cSrcweir }
405cdf0e10cSrcweir
406cdf0e10cSrcweir //=========================================================================
407cdf0e10cSrcweir // virtual
queryPropertyValues(sal_uInt32 nIndex)408cdf0e10cSrcweir uno::Reference< sdbc::XRow > DataSupplier::queryPropertyValues(
409cdf0e10cSrcweir sal_uInt32 nIndex )
410cdf0e10cSrcweir {
411cdf0e10cSrcweir osl::Guard< osl::Mutex > aGuard( m_pImpl->m_aMutex );
412cdf0e10cSrcweir
413cdf0e10cSrcweir if ( nIndex < m_pImpl->m_aResults.size() )
414cdf0e10cSrcweir {
415cdf0e10cSrcweir uno::Reference< sdbc::XRow > xRow = m_pImpl->m_aResults[ nIndex ]->xRow;
416cdf0e10cSrcweir if ( xRow.is() )
417cdf0e10cSrcweir {
418cdf0e10cSrcweir // Already cached.
419cdf0e10cSrcweir return xRow;
420cdf0e10cSrcweir }
421cdf0e10cSrcweir }
422cdf0e10cSrcweir
423cdf0e10cSrcweir if ( getResult( nIndex ) )
424cdf0e10cSrcweir {
425cdf0e10cSrcweir uno::Reference< sdbc::XRow > xRow = Content::getPropertyValues(
426cdf0e10cSrcweir m_pImpl->m_xSMgr,
427cdf0e10cSrcweir getResultSet()->getProperties(),
428cdf0e10cSrcweir static_cast< ContentProvider * >(
429cdf0e10cSrcweir m_pImpl->m_xContent->getProvider().get() ),
430cdf0e10cSrcweir queryContentIdentifierString( nIndex ) );
431cdf0e10cSrcweir m_pImpl->m_aResults[ nIndex ]->xRow = xRow;
432cdf0e10cSrcweir return xRow;
433cdf0e10cSrcweir }
434cdf0e10cSrcweir
435cdf0e10cSrcweir return uno::Reference< sdbc::XRow >();
436cdf0e10cSrcweir }
437cdf0e10cSrcweir
438cdf0e10cSrcweir //=========================================================================
439cdf0e10cSrcweir // virtual
releasePropertyValues(sal_uInt32 nIndex)440cdf0e10cSrcweir void DataSupplier::releasePropertyValues( sal_uInt32 nIndex )
441cdf0e10cSrcweir {
442cdf0e10cSrcweir osl::Guard< osl::Mutex > aGuard( m_pImpl->m_aMutex );
443cdf0e10cSrcweir
444cdf0e10cSrcweir if ( nIndex < m_pImpl->m_aResults.size() )
445cdf0e10cSrcweir m_pImpl->m_aResults[ nIndex ]->xRow = uno::Reference< sdbc::XRow >();
446cdf0e10cSrcweir }
447cdf0e10cSrcweir
448cdf0e10cSrcweir //=========================================================================
449cdf0e10cSrcweir // virtual
close()450cdf0e10cSrcweir void DataSupplier::close()
451cdf0e10cSrcweir {
452cdf0e10cSrcweir }
453cdf0e10cSrcweir
454cdf0e10cSrcweir //=========================================================================
455cdf0e10cSrcweir // virtual
validate()456cdf0e10cSrcweir void DataSupplier::validate()
457cdf0e10cSrcweir throw( ucb::ResultSetException )
458cdf0e10cSrcweir {
459cdf0e10cSrcweir if ( m_pImpl->m_bThrowException )
460cdf0e10cSrcweir throw ucb::ResultSetException();
461cdf0e10cSrcweir }
462cdf0e10cSrcweir
463cdf0e10cSrcweir //=========================================================================
assembleChildURL(const::rtl::OUString & aName)464cdf0e10cSrcweir ::rtl::OUString DataSupplier::assembleChildURL( const ::rtl::OUString& aName )
465cdf0e10cSrcweir {
466cdf0e10cSrcweir rtl::OUString aURL;
467cdf0e10cSrcweir rtl::OUString aContURL
468cdf0e10cSrcweir = m_pImpl->m_xContent->getIdentifier()->getContentIdentifier();
469cdf0e10cSrcweir sal_Int32 nParam = aContURL.indexOf( '?' );
470cdf0e10cSrcweir if ( nParam >= 0 )
471cdf0e10cSrcweir {
472cdf0e10cSrcweir aURL = aContURL.copy( 0, nParam );
473cdf0e10cSrcweir
474cdf0e10cSrcweir sal_Int32 nPackageUrlEnd = aURL.lastIndexOf( '/' );
475cdf0e10cSrcweir if ( nPackageUrlEnd != aURL.getLength() - 1 )
476cdf0e10cSrcweir aURL += rtl::OUString::createFromAscii( "/" );
477cdf0e10cSrcweir
478cdf0e10cSrcweir aURL += ::ucb_impl::urihelper::encodeSegment( aName );
479cdf0e10cSrcweir aURL += aContURL.copy( nParam );
480cdf0e10cSrcweir }
481cdf0e10cSrcweir else
482cdf0e10cSrcweir {
483cdf0e10cSrcweir aURL = aContURL;
484cdf0e10cSrcweir
485cdf0e10cSrcweir sal_Int32 nPackageUrlEnd = aURL.lastIndexOf( '/' );
486cdf0e10cSrcweir if ( nPackageUrlEnd != aURL.getLength() - 1 )
487cdf0e10cSrcweir aURL += rtl::OUString::createFromAscii( "/" );
488cdf0e10cSrcweir
489cdf0e10cSrcweir aURL += ::ucb_impl::urihelper::encodeSegment( aName );
490cdf0e10cSrcweir }
491cdf0e10cSrcweir return aURL;
492cdf0e10cSrcweir }
493cdf0e10cSrcweir
494cdf0e10cSrcweir
495