dbaccess/source/core/misc/ContainerMediator.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 #include "ContainerMediator.hxx"
  21 #include "dbastrings.hrc"
  22 #include "PropertyForward.hxx"
  23
  24 #include <com/sun/star/beans/PropertyAttribute.hpp>
  25 #include <com/sun/star/sdbcx/XColumnsSupplier.hpp>
  26 #include <com/sun/star/sdbcx/XTablesSupplier.hpp>
  27 #include <com/sun/star/sdbcx/XRename.hpp>
  28 #include <connectivity/dbtools.hxx>
  29 #include <comphelper/property.hxx>
  30 #include <tools/debug.hxx>
  31 #include <tools/diagnose_ex.h>
  32
  33 namespace dbaccess
  34 {
  35     using namespace ::com::sun::star::uno;
  36     using namespace ::com::sun::star::lang;
  37     using namespace ::com::sun::star::sdbc;
  38     using namespace ::com::sun::star::sdbcx;
  39     using namespace ::com::sun::star::beans;
  40     using namespace ::com::sun::star::container;
  41
  42 OContainerMediator::OContainerMediator( const Reference< XContainer >& _xContainer, const Reference< XNameAccess >& _xSettings )
  43     : m_xSettings( _xSettings )
  44     , m_xContainer( _xContainer )
  45 {
  46
  47     if ( _xSettings.is() && _xContainer.is() )
  48     {
  49         osl_atomic_increment(&m_refCount);
  50         try
  51         {
  52             m_xContainer->addContainerListener(this);
  53             Reference< XContainer > xContainer(_xSettings, UNO_QUERY);
  54             if ( xContainer.is() )
  55                 xContainer->addContainerListener(this);
  56         }
  57         catch(Exception&)
  58         {
  59             OSL_FAIL("OContainerMediator::OContainerMediator: caught an exception!");
  60         }
  61         osl_atomic_decrement( &m_refCount );
  62     }
  63     else
  64     {
  65         m_xSettings.clear();
  66         m_xContainer.clear();
  67     }
  68 }
  69
  70 OContainerMediator::~OContainerMediator()
  71 {
  72     acquire();
  73     impl_cleanup_nothrow();
  74 }
  75
  76 void OContainerMediator::impl_cleanup_nothrow()
  77 {
  78     try
  79     {
  80         Reference< XContainer > xContainer( m_xSettings, UNO_QUERY );
  81         if ( xContainer.is() )
  82             xContainer->removeContainerListener( this );
  83         m_xSettings.clear();
  84
  85         xContainer = m_xContainer;
  86         if ( xContainer.is() )
  87             xContainer->removeContainerListener( this );
  88         m_xContainer.clear();
  89
  90         m_aForwardList.clear();
  91     }
  92     catch( const Exception& )
  93     {
  94         DBG_UNHANDLED_EXCEPTION();
  95     }
  96 }
  97
  98 void SAL_CALL OContainerMediator::elementInserted( const ContainerEvent& _rEvent ) throw(RuntimeException, std::exception)
  99 {
 100     ::osl::MutexGuard aGuard(m_aMutex);
 101     if ( _rEvent.Source == m_xSettings && m_xSettings.is() )
 102     {
 103         OUString sElementName;
 104         _rEvent.Accessor >>= sElementName;
 105         PropertyForwardList::const_iterator aFind = m_aForwardList.find(sElementName);
 106         if ( aFind != m_aForwardList.end() )
 107         {
 108             Reference< XPropertySet> xDest(_rEvent.Element,UNO_QUERY);
 109             aFind->second->setDefinition( xDest );
 110         }
 111     }
 112 }
 113
 114 void SAL_CALL OContainerMediator::elementRemoved( const ContainerEvent& _rEvent ) throw(RuntimeException, std::exception)
 115 {
 116     ::osl::MutexGuard aGuard(m_aMutex);
 117     Reference< XContainer > xContainer = m_xContainer;
 118     if ( _rEvent.Source == xContainer && xContainer.is() )
 119     {
 120         OUString sElementName;
 121         _rEvent.Accessor >>= sElementName;
 122         m_aForwardList.erase(sElementName);
 123         try
 124         {
 125             Reference<XNameContainer> xNameContainer( m_xSettings, UNO_QUERY );
 126             if ( xNameContainer.is() && m_xSettings->hasByName( sElementName ) )
 127                 xNameContainer->removeByName( sElementName );
 128         }
 129         catch( const Exception& )
 130         {
 131             DBG_UNHANDLED_EXCEPTION();
 132         }
 133     }
 134 }
 135
 136 void SAL_CALL OContainerMediator::elementReplaced( const ContainerEvent& _rEvent ) throw(RuntimeException, std::exception)
 137 {
 138     Reference< XContainer > xContainer = m_xContainer;
 139     if ( _rEvent.Source == xContainer && xContainer.is() )
 140     {
 141         OUString sElementName;
 142         _rEvent.ReplacedElement >>= sElementName;
 143
 144         PropertyForwardList::const_iterator aFind = m_aForwardList.find(sElementName);
 145         if ( aFind != m_aForwardList.end() )
 146         {
 147             OUString sNewName;
 148             _rEvent.Accessor >>= sNewName;
 149             try
 150             {
 151                 Reference<XNameContainer> xNameContainer( m_xSettings, UNO_QUERY_THROW );
 152                 if ( xNameContainer.is() && m_xSettings->hasByName( sElementName ) )
 153                 {
 154                     Reference<XRename> xSource(m_xSettings->getByName(sElementName),UNO_QUERY_THROW);
 155                     xSource->rename(sNewName);
 156                 }
 157             }
 158             catch( const Exception& )
 159             {
 160                 DBG_UNHANDLED_EXCEPTION();
 161             }
 162
 163             aFind->second->setName(sNewName);
 164         }
 165     }
 166 }
 167
 168 void SAL_CALL OContainerMediator::disposing( const EventObject& /*Source*/ ) throw(RuntimeException, std::exception)
 169 {
 170     ::osl::MutexGuard aGuard(m_aMutex);
 171
 172     impl_cleanup_nothrow();
 173 }
 174
 175 void OContainerMediator::impl_initSettings_nothrow( const OUString& _rName, const Reference< XPropertySet >& _rxDestination )
 176 {
 177     try
 178     {
 179         if ( m_xSettings.is() && m_xSettings->hasByName( _rName ) )
 180         {
 181             Reference< XPropertySet > xSettings( m_xSettings->getByName( _rName ), UNO_QUERY_THROW );
 182             ::comphelper::copyProperties( xSettings, _rxDestination );
 183         }
 184     }
 185     catch( const Exception& )
 186     {
 187         DBG_UNHANDLED_EXCEPTION();
 188     }
 189 }
 190
 191 void OContainerMediator::notifyElementCreated( const OUString& _sName, const Reference< XPropertySet >& _xDest )
 192 {
 193     if ( !m_xSettings.is() )
 194         return;
 195
 196     PropertyForwardList::const_iterator aFind = m_aForwardList.find( _sName );
 197     if  (   aFind != m_aForwardList.end()
 198         &&  aFind->second->getDefinition().is()
 199         )
 200     {
 201         OSL_FAIL( "OContainerMediator::notifyElementCreated: is this really a valid case?" );
 202         return;
 203     }
 204
 205     ::std::vector< OUString > aPropertyList;
 206     try
 207     {
 208         // initially copy from the settings object (if existent) to the newly created object
 209         impl_initSettings_nothrow( _sName, _xDest );
 210
 211         // collect the to-be-monitored properties
 212         Reference< XPropertySetInfo > xPSI( _xDest->getPropertySetInfo(), UNO_QUERY_THROW );
 213         Sequence< Property > aProperties( xPSI->getProperties() );
 214         const Property* property = aProperties.getConstArray();
 215         const Property* propertyEnd = aProperties.getConstArray() + aProperties.getLength();
 216         for ( ; property != propertyEnd; ++property )
 217         {
 218             if ( ( property->Attributes & PropertyAttribute::READONLY ) != 0 )
 219                 continue;
 220             if ( ( property->Attributes & PropertyAttribute::BOUND ) == 0 )
 221                 continue;
 222
 223             aPropertyList.push_back( property->Name );
 224         }
 225     }
 226     catch( const Exception& )
 227     {
 228         DBG_UNHANDLED_EXCEPTION();
 229     }
 230
 231     ::rtl::Reference< OPropertyForward > pForward( new OPropertyForward( _xDest, m_xSettings, _sName, aPropertyList ) );
 232     m_aForwardList[ _sName ] = pForward;
 233 }
 234
 235 }   // namespace dbaccess
 236
 237 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */