ucb/source/cacher/cacheddynamicresultsetstub.cxx

   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
  21 #include "cacheddynamicresultsetstub.hxx"
  22 #include <com/sun/star/sdbc/XResultSet.hpp>
  23 #include "cachedcontentresultsetstub.hxx"
  24 #include <com/sun/star/ucb/ContentResultSetCapability.hpp>
  25 #include <com/sun/star/ucb/SortedDynamicResultSetFactory.hpp>
  26 #include <osl/diagnose.h>
  27 #include <comphelper/processfactory.hxx>
  28 #include <ucbhelper/getcomponentcontext.hxx>
  29 #include <cppuhelper/queryinterface.hxx>
  30
  31 using namespace com::sun::star::lang;
  32 using namespace com::sun::star::sdbc;
  33 using namespace com::sun::star::ucb;
  34 using namespace com::sun::star::uno;
  35
  36
  37 CachedDynamicResultSetStub::CachedDynamicResultSetStub(
  38         Reference< XDynamicResultSet > const & xOrigin
  39         , const Reference< XComponentContext > & rxContext )
  40         : DynamicResultSetWrapper( xOrigin, rxContext )
  41 {
  42     OSL_ENSURE( m_xContext.is(), "need Multiservicefactory to create stub" );
  43     impl_init();
  44 }
  45
  46 CachedDynamicResultSetStub::~CachedDynamicResultSetStub()
  47 {
  48     impl_deinit();
  49 }
  50
  51 //virtual
  52 void CachedDynamicResultSetStub
  53     ::impl_InitResultSetOne( const Reference< XResultSet >& xResultSet )
  54 {
  55     DynamicResultSetWrapper::impl_InitResultSetOne( xResultSet );
  56     OSL_ENSURE( m_xSourceResultOne.is(), "need source resultset" );
  57
  58     Reference< XResultSet > xStub(
  59         new CachedContentResultSetStub( m_xSourceResultOne ) );
  60
  61     osl::Guard< osl::Mutex > aGuard( m_aMutex );
  62     m_xMyResultOne = xStub;
  63 }
  64
  65 //virtual
  66 void CachedDynamicResultSetStub
  67     ::impl_InitResultSetTwo( const Reference< XResultSet >& xResultSet )
  68 {
  69     DynamicResultSetWrapper::impl_InitResultSetTwo( xResultSet );
  70     OSL_ENSURE( m_xSourceResultTwo.is(), "need source resultset" );
  71
  72     Reference< XResultSet > xStub(
  73         new CachedContentResultSetStub( m_xSourceResultTwo ) );
  74
  75     osl::Guard< osl::Mutex > aGuard( m_aMutex );
  76     m_xMyResultTwo = xStub;
  77 }
  78
  79
  80 // XInterface methods.
  81 void SAL_CALL CachedDynamicResultSetStub::acquire()
  82     throw()
  83 {
  84     OWeakObject::acquire();
  85 }
  86
  87 void SAL_CALL CachedDynamicResultSetStub::release()
  88     throw()
  89 {
  90     OWeakObject::release();
  91 }
  92
  93 Any SAL_CALL CachedDynamicResultSetStub
  94     ::queryInterface( const Type&  rType )
  95 {
  96     //list all interfaces inclusive baseclasses of interfaces
  97
  98     Any aRet = DynamicResultSetWrapper::queryInterface( rType );
  99     if( aRet.hasValue() )
 100         return aRet;
 101
 102     aRet = cppu::queryInterface( rType,
 103                 static_cast< XTypeProvider* >( this )
 104                 , static_cast< XServiceInfo* >( this )
 105                 );
 106     return aRet.hasValue() ? aRet : OWeakObject::queryInterface( rType );
 107 }
 108
 109
 110 // XTypeProvider methods.
 111
 112 //list all interfaces exclusive baseclasses
 113 XTYPEPROVIDER_IMPL_5( CachedDynamicResultSetStub
 114                     , XTypeProvider
 115                     , XServiceInfo
 116                     , XDynamicResultSet
 117                     , XDynamicResultSetListener
 118                     , XSourceInitialization
 119                     );
 120
 121
 122 // XServiceInfo methods.
 123
 124 OUString SAL_CALL CachedDynamicResultSetStub::getImplementationName()
 125 {
 126     return OUString( "com.sun.star.comp.ucb.CachedDynamicResultSetStub" );
 127 }
 128
 129 sal_Bool SAL_CALL CachedDynamicResultSetStub::supportsService( const OUString& ServiceName )
 130 {
 131     return cppu::supportsService( this, ServiceName );
 132 }
 133
 134 css::uno::Sequence< OUString > SAL_CALL CachedDynamicResultSetStub::getSupportedServiceNames()
 135 {
 136     return { CACHED_DRS_STUB_SERVICE_NAME };
 137 }
 138
 139
 140
 141 // class CachedDynamicResultSetStubFactory
 142
 143
 144 CachedDynamicResultSetStubFactory::CachedDynamicResultSetStubFactory(
 145         const Reference< XComponentContext > & rxContext )
 146 {
 147     m_xContext = rxContext;
 148 }
 149
 150 CachedDynamicResultSetStubFactory::~CachedDynamicResultSetStubFactory()
 151 {
 152 }
 153
 154
 155 // CachedDynamicResultSetStubFactory XInterface methods.
 156 void SAL_CALL CachedDynamicResultSetStubFactory::acquire()
 157     throw()
 158 {
 159     OWeakObject::acquire();
 160 }
 161
 162 void SAL_CALL CachedDynamicResultSetStubFactory::release()
 163     throw()
 164 {
 165     OWeakObject::release();
 166 }
 167
 168 css::uno::Any SAL_CALL CachedDynamicResultSetStubFactory::queryInterface( const css::uno::Type & rType )
 169 {
 170     css::uno::Any aRet = cppu::queryInterface( rType,
 171                                                static_cast< XTypeProvider* >(this),
 172                                                static_cast< XServiceInfo* >(this),
 173                                                static_cast< XCachedDynamicResultSetStubFactory* >(this)
 174                                                );
 175     return aRet.hasValue() ? aRet : OWeakObject::queryInterface( rType );
 176 }
 177
 178 // CachedDynamicResultSetStubFactory XTypeProvider methods.
 179
 180
 181 XTYPEPROVIDER_IMPL_3( CachedDynamicResultSetStubFactory,
 182                       XTypeProvider,
 183                          XServiceInfo,
 184                       XCachedDynamicResultSetStubFactory );
 185
 186
 187 // CachedDynamicResultSetStubFactory XServiceInfo methods.
 188
 189 XSERVICEINFO_COMMOM_IMPL( CachedDynamicResultSetStubFactory,
 190                           OUString( "com.sun.star.comp.ucb.CachedDynamicResultSetStubFactory" ) )
 191 /// @throws css::uno::Exception
 192 static css::uno::Reference< css::uno::XInterface >
 193 CachedDynamicResultSetStubFactory_CreateInstance( const css::uno::Reference< css::lang::XMultiServiceFactory> & rSMgr )
 194 {
 195     css::lang::XServiceInfo* pX =
 196         static_cast<css::lang::XServiceInfo*>(new CachedDynamicResultSetStubFactory( ucbhelper::getComponentContext(rSMgr) ));
 197     return css::uno::Reference< css::uno::XInterface >::query( pX );
 198 }
 199
 200 css::uno::Sequence< OUString >
 201 CachedDynamicResultSetStubFactory::getSupportedServiceNames_Static()
 202 {
 203     css::uno::Sequence< OUString > aSNS { CACHED_DRS_STUB_FACTORY_NAME };
 204     return aSNS;
 205 }
 206
 207 // Service factory implementation.
 208
 209
 210 ONE_INSTANCE_SERVICE_FACTORY_IMPL( CachedDynamicResultSetStubFactory );
 211
 212
 213 // CachedDynamicResultSetStubFactory XCachedDynamicResultSetStubFactory methods.
 214
 215
 216 //virtual
 217 Reference< XDynamicResultSet > SAL_CALL CachedDynamicResultSetStubFactory
 218     ::createCachedDynamicResultSetStub(
 219             const Reference< XDynamicResultSet > & Source )
 220 {
 221     Reference< XDynamicResultSet > xRet;
 222     xRet = new CachedDynamicResultSetStub( Source, m_xContext );
 223     return xRet;
 224 }
 225
 226 //virtual
 227 void SAL_CALL CachedDynamicResultSetStubFactory
 228     ::connectToCache(
 229               const Reference< XDynamicResultSet > & Source
 230             , const Reference< XDynamicResultSet > & TargetCache
 231             , const Sequence< NumberedSortingInfo > & SortingInfo
 232             , const Reference< XAnyCompareFactory > & CompareFactory
 233             )
 234 {
 235     OSL_ENSURE( Source.is(), "a Source is needed" );
 236     OSL_ENSURE( TargetCache.is(), "a TargetCache is needed" );
 237
 238     Reference< XDynamicResultSet > xSource( Source );
 239     if( SortingInfo.getLength() &&
 240         !( xSource->getCapabilities() & ContentResultSetCapability::SORTED )
 241         )
 242     {
 243         Reference< XSortedDynamicResultSetFactory > xSortFactory;
 244         try
 245         {
 246             xSortFactory = SortedDynamicResultSetFactory::create( m_xContext );
 247         }
 248         catch ( Exception const & )
 249         {
 250         }
 251
 252         if( xSortFactory.is() )
 253         {
 254             Reference< XDynamicResultSet > xSorted(
 255                 xSortFactory->createSortedDynamicResultSet(
 256                     Source, SortingInfo, CompareFactory ) );
 257             if( xSorted.is() )
 258                 xSource = xSorted;
 259         }
 260     }
 261
 262     Reference< XDynamicResultSet > xStub(
 263         new CachedDynamicResultSetStub( xSource, m_xContext ) );
 264
 265     Reference< XSourceInitialization > xTarget( TargetCache, UNO_QUERY );
 266     OSL_ENSURE( xTarget.is(), "Target must have interface XSourceInitialization" );
 267
 268     xTarget->setSource( xStub );
 269 }
 270
 271 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */