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