connectivity/source/drivers/postgresql/pq_xcontainer.cxx

   1 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
   2 /*************************************************************************
   3  *
   4  *  Effective License of whole file:
   5  *
   6  *    This library is free software; you can redistribute it and/or
   7  *    modify it under the terms of the GNU Lesser General Public
   8  *    License version 2.1, as published by the Free Software Foundation.
   9  *
  10  *    This library is distributed in the hope that it will be useful,
  11  *    but WITHOUT ANY WARRANTY; without even the implied warranty of
  12  *    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  13  *    Lesser General Public License for more details.
  14  *
  15  *    You should have received a copy of the GNU Lesser General Public
  16  *    License along with this library; if not, write to the Free Software
  17  *    Foundation, Inc., 59 Temple Place, Suite 330, Boston,
  18  *    MA  02111-1307  USA
  19  *
  20  *  Parts "Copyright by Sun Microsystems, Inc" prior to August 2011:
  21  *
  22  *    The Contents of this file are made available subject to the terms of
  23  *    the GNU Lesser General Public License Version 2.1
  24  *
  25  *    Copyright: 2000 by Sun Microsystems, Inc.
  26  *
  27  *    Contributor(s): Joerg Budischewski
  28  *
  29  *  All parts contributed on or after August 2011:
  30  *
  31  *    This Source Code Form is subject to the terms of the Mozilla Public
  32  *    License, v. 2.0. If a copy of the MPL was not distributed with this
  33  *    file, You can obtain one at http://mozilla.org/MPL/2.0/.
  34  *
  35  ************************************************************************/
  36
  37 #include <rtl/ustrbuf.hxx>
  38
  39 #include <com/sun/star/sdbc/XRow.hpp>
  40 #include <com/sun/star/sdbc/XParameters.hpp>
  41
  42
  43 #include <cppuhelper/implbase1.hxx>
  44
  45 #include "pq_xcontainer.hxx"
  46 #include "pq_statics.hxx"
  47 #include "pq_tools.hxx"
  48
  49 using osl::MutexGuard;
  50
  51
  52 using com::sun::star::beans::XPropertySet;
  53
  54 using com::sun::star::uno::Any;
  55 using com::sun::star::uno::makeAny;
  56 using com::sun::star::uno::UNO_QUERY;
  57 using com::sun::star::uno::Type;
  58 using com::sun::star::uno::XInterface;
  59 using com::sun::star::uno::Reference;
  60 using com::sun::star::uno::Sequence;
  61 using com::sun::star::uno::RuntimeException;
  62
  63 using com::sun::star::container::NoSuchElementException;
  64 using com::sun::star::container::XEnumeration;
  65 using com::sun::star::container::XContainerListener;
  66 using com::sun::star::container::ContainerEvent;
  67 using com::sun::star::lang::IndexOutOfBoundsException;
  68 using com::sun::star::lang::XEventListener;
  69
  70 using com::sun::star::lang::WrappedTargetException;
  71
  72 using com::sun::star::sdbc::XRow;
  73 using com::sun::star::sdbc::XCloseable;
  74 using com::sun::star::sdbc::XStatement;
  75 using com::sun::star::sdbc::XResultSet;
  76 using com::sun::star::sdbc::XParameters;
  77 using com::sun::star::sdbc::XPreparedStatement;
  78 using com::sun::star::sdbcx::XDataDescriptorFactory;
  79
  80 namespace pq_sdbc_driver
  81 {
  82
  83 class ReplacedBroadcaster : public EventBroadcastHelper
  84 {
  85     ContainerEvent m_event;
  86 public:
  87     ReplacedBroadcaster(
  88         const Reference< XInterface > & source,
  89         const OUString & name,
  90         const Any & newElement,
  91         const OUString & oldElement ) :
  92         m_event( source, makeAny( name ), newElement, makeAny(oldElement) )
  93     {}
  94
  95     virtual void fire( XEventListener * listener ) const SAL_OVERRIDE
  96     {
  97         ((XContainerListener*)listener)->elementReplaced( m_event );
  98     }
  99     virtual Type getType() const SAL_OVERRIDE
 100     {
 101         return getCppuType( (Reference< XContainerListener > *)0 );
 102     }
 103 };
 104
 105 class InsertedBroadcaster : public EventBroadcastHelper
 106 {
 107 public:
 108     ContainerEvent m_event;
 109     InsertedBroadcaster(
 110         const Reference< XInterface > & source,
 111         const OUString & name,
 112         const Any & newElement ) :
 113         m_event( source, makeAny( name ), newElement, Any() )
 114     {}
 115
 116     virtual void fire( XEventListener * listener ) const SAL_OVERRIDE
 117     {
 118         ((XContainerListener*)listener)->elementInserted( m_event );
 119     }
 120
 121     virtual Type getType() const SAL_OVERRIDE
 122     {
 123         return getCppuType( (Reference< XContainerListener > *)0 );
 124     }
 125 };
 126
 127 class RemovedBroadcaster : public EventBroadcastHelper
 128 {
 129 public:
 130     ContainerEvent m_event;
 131     RemovedBroadcaster(
 132         const Reference< XInterface > & source,
 133         const OUString & name) :
 134         m_event( source, makeAny( name ), Any(), Any() )
 135     {}
 136
 137     virtual void fire( XEventListener * listener ) const SAL_OVERRIDE
 138     {
 139         ((XContainerListener*)listener)->elementRemoved( m_event );
 140     }
 141
 142     virtual Type getType() const SAL_OVERRIDE
 143     {
 144         return getCppuType( (Reference< XContainerListener > *)0 );
 145     }
 146 };
 147
 148 Container::Container(
 149     const ::rtl::Reference< RefCountedMutex > & refMutex,
 150     const ::com::sun::star::uno::Reference< com::sun::star::sdbc::XConnection >  & origin,
 151     ConnectionSettings *pSettings,
 152     const OUString &type)
 153     : ContainerBase( refMutex->mutex ),
 154       m_refMutex( refMutex ),
 155       m_pSettings( pSettings ),
 156       m_origin( origin ),
 157       m_type( type )
 158 {
 159 }
 160
 161 Any Container::getByName( const OUString& aName )
 162     throw (NoSuchElementException,WrappedTargetException,RuntimeException, std::exception)
 163 {
 164     String2IntMap::const_iterator ii = m_name2index.find( aName );
 165     if( ii == m_name2index.end() )
 166     {
 167         OUStringBuffer buf(128);
 168         buf.appendAscii( "Element "  );
 169         buf.append( aName );
 170         buf.appendAscii( " unknown in " );
 171         buf.append( m_type );
 172         buf.appendAscii( "-Container" );
 173         throw NoSuchElementException( buf.makeStringAndClear() , *this );
 174     }
 175     OSL_ASSERT( ii->second >= 0 && ii->second < m_values.getLength() );
 176     return m_values[ ii->second ];
 177 }
 178
 179 Sequence< OUString > Container::getElementNames(  )
 180         throw (::com::sun::star::uno::RuntimeException, std::exception)
 181 {
 182     Sequence< OUString > ret( m_values.getLength() );
 183     for( String2IntMap::const_iterator ii = m_name2index.begin();
 184          ii != m_name2index.end() ;
 185          ++ ii )
 186     {
 187         // give element names in index order !
 188         ret[ii->second] = ii->first;
 189 //         ret[i] = ii->first;
 190     }
 191     return ret;
 192 }
 193
 194 sal_Bool Container::hasByName( const OUString& aName )
 195         throw (::com::sun::star::uno::RuntimeException, std::exception)
 196 {
 197     return m_name2index.find( aName ) != m_name2index.end();
 198 }
 199     // Methods
 200 Type Container::getElementType(  )
 201         throw (::com::sun::star::uno::RuntimeException, std::exception)
 202 {
 203     return Type();
 204 }
 205
 206 sal_Bool Container::hasElements(  )
 207         throw (::com::sun::star::uno::RuntimeException, std::exception)
 208 {
 209     return ! m_name2index.empty();
 210 }
 211
 212 Any Container::getByIndex( sal_Int32 Index )
 213     throw (::com::sun::star::lang::IndexOutOfBoundsException,
 214            ::com::sun::star::lang::WrappedTargetException,
 215            ::com::sun::star::uno::RuntimeException, std::exception)
 216 {
 217     if( Index < 0 || Index >= m_values.getLength() )
 218     {
 219         OUStringBuffer buf(128);
 220         buf.appendAscii( "Index " );
 221         buf.append( Index );
 222         buf.appendAscii(" out of range for " );
 223         buf.append( m_type );
 224         buf.appendAscii("-Container, expected 0 <= x <= " );
 225         buf.append( (sal_Int32 ) (m_values.getLength() -1));
 226         throw IndexOutOfBoundsException( buf.makeStringAndClear(), *this );
 227     }
 228     return m_values[Index];
 229 }
 230
 231 sal_Int32 Container::getCount()
 232         throw (::com::sun::star::uno::RuntimeException, std::exception)
 233 {
 234     return m_values.getLength();
 235 }
 236
 237
 238 class ContainerEnumeration : public ::cppu::WeakImplHelper1< XEnumeration >
 239 {
 240     com::sun::star::uno::Sequence< com::sun::star::uno::Any > m_vec;
 241     sal_Int32 m_index;
 242 public:
 243     ContainerEnumeration( const  com::sun::star::uno::Sequence< com::sun::star::uno::Any > &vec )
 244         : m_vec( vec ),
 245           m_index( -1 )
 246     {}
 247
 248 public:
 249     // XEnumeration
 250     virtual sal_Bool SAL_CALL hasMoreElements(  )
 251         throw (::com::sun::star::uno::RuntimeException, std::exception) SAL_OVERRIDE;
 252     virtual ::com::sun::star::uno::Any SAL_CALL nextElement(  )
 253         throw (::com::sun::star::container::NoSuchElementException,
 254                ::com::sun::star::lang::WrappedTargetException,
 255                ::com::sun::star::uno::RuntimeException, std::exception) SAL_OVERRIDE;
 256
 257 };
 258
 259 sal_Bool ContainerEnumeration::hasMoreElements()
 260         throw (::com::sun::star::uno::RuntimeException, std::exception)
 261 {
 262     return m_vec.getLength() > m_index +1;
 263 }
 264
 265 com::sun::star::uno::Any ContainerEnumeration::nextElement()
 266         throw (::com::sun::star::container::NoSuchElementException,
 267                ::com::sun::star::lang::WrappedTargetException,
 268                ::com::sun::star::uno::RuntimeException, std::exception)
 269 {
 270     if( ! hasMoreElements() )
 271     {
 272         throw NoSuchElementException(
 273             "NoSuchElementException during enumeration", *this );
 274     }
 275     m_index ++;
 276     return m_vec[m_index];
 277 }
 278
 279 Reference< XEnumeration > Container::createEnumeration(  )
 280     throw (::com::sun::star::uno::RuntimeException, std::exception)
 281 {
 282     return new ContainerEnumeration( m_values );
 283 }
 284
 285 void Container::addRefreshListener(
 286     const ::com::sun::star::uno::Reference< ::com::sun::star::util::XRefreshListener >& l )
 287     throw (::com::sun::star::uno::RuntimeException, std::exception)
 288 {
 289     rBHelper.addListener( getCppuType(&l) , l );
 290 }
 291
 292 void Container::removeRefreshListener(
 293     const ::com::sun::star::uno::Reference< ::com::sun::star::util::XRefreshListener >& l )
 294     throw (::com::sun::star::uno::RuntimeException, std::exception)
 295 {
 296     rBHelper.removeListener( getCppuType(&l) , l );
 297 }
 298
 299 void Container::disposing()
 300 {
 301     m_origin.clear();
 302 }
 303
 304 void Container::rename( const OUString &oldName, const OUString &newName )
 305 {
 306     Any newValue;
 307     {
 308         osl::MutexGuard guard ( m_refMutex->mutex );
 309         String2IntMap::iterator ii = m_name2index.find( oldName );
 310         if( ii != m_name2index.end() )
 311         {
 312             sal_Int32 nIndex = ii->second;
 313             newValue = m_values[nIndex];
 314             m_name2index.erase( ii );
 315             m_name2index[ newName ] = nIndex;
 316         }
 317     }
 318     fire( ReplacedBroadcaster( *this, newName, newValue, oldName ) );
 319     fire( RefreshedBroadcaster( *this ) );
 320 }
 321
 322 void Container::dropByName( const OUString& elementName )
 323     throw (::com::sun::star::sdbc::SQLException,
 324            ::com::sun::star::container::NoSuchElementException,
 325            ::com::sun::star::uno::RuntimeException, std::exception)
 326 {
 327     osl::MutexGuard guard( m_refMutex->mutex );
 328     String2IntMap::const_iterator ii = m_name2index.find( elementName );
 329     if( ii == m_name2index.end() )
 330     {
 331         OUStringBuffer buf( 128 );
 332         buf.appendAscii( "Column " );
 333         buf.append( elementName );
 334         buf.appendAscii( " is unknown in " );
 335         buf.append( m_type );
 336 //         buf.appendAscii( " " );
 337 //         buf.append( m_schemaName );
 338 //         buf.appendAscii( "." );
 339 //         buf.append( m_tableName );
 340         buf.appendAscii( " container, so it can't be dropped" );
 341         throw com::sun::star::container::NoSuchElementException(
 342             buf.makeStringAndClear(), *this );
 343     }
 344     dropByIndex( ii->second );
 345 }
 346
 347 void Container::dropByIndex( sal_Int32 index )
 348     throw (::com::sun::star::sdbc::SQLException,
 349            ::com::sun::star::lang::IndexOutOfBoundsException,
 350            ::com::sun::star::uno::RuntimeException, std::exception)
 351 {
 352     osl::MutexGuard guard( m_refMutex->mutex );
 353     if( index < 0 ||  index >= m_values.getLength() )
 354     {
 355         OUStringBuffer buf( 128 );
 356         buf.appendAscii( "Index out of range (allowed 0 to " );
 357         buf.append((sal_Int32)(m_values.getLength() -1) );
 358         buf.appendAscii( ", got " );
 359         buf.append( index );
 360         buf.appendAscii( ") in " );
 361         buf.append( m_type );
 362         throw com::sun::star::lang::IndexOutOfBoundsException(
 363             buf.makeStringAndClear(), *this );
 364     }
 365
 366     OUString name;
 367     for( String2IntMap::iterator ii = m_name2index.begin() ;
 368          ii != m_name2index.end() ;
 369          ++ ii )
 370     {
 371         if( ii->second == index )
 372         {
 373             name = ii->first;
 374             m_name2index.erase( ii );
 375             break;
 376         }
 377     }
 378
 379     for( int i = index +1 ; i < m_values.getLength() ; i ++ )
 380     {
 381         m_values[i-1] = m_values[i];
 382
 383         // I know, this is expensive, but don't want to maintain another map ...
 384         for( String2IntMap::iterator ii = m_name2index.begin() ;
 385              ii != m_name2index.end() ;
 386              ++ ii )
 387         {
 388             if( ii->second == i )
 389             {
 390                 ii->second = i-1;
 391                 break;
 392             }
 393         }
 394     }
 395     m_values.realloc( m_values.getLength() - 1 );
 396
 397     fire( RemovedBroadcaster( *this, name ) );
 398 }
 399
 400 void Container::append(
 401     const OUString & name,
 402     const ::com::sun::star::uno::Reference< ::com::sun::star::beans::XPropertySet >& descriptor )
 403     throw ( ::com::sun::star::container::ElementExistException )
 404
 405 {
 406     osl::MutexGuard guard( m_refMutex->mutex );
 407
 408     if( hasByName( name ) )
 409     {
 410         OUStringBuffer buf( 128 );
 411         buf.appendAscii( "a ");
 412         buf.append( m_type );
 413         buf.appendAscii( " with name " );
 414         buf.append( name );
 415         buf.appendAscii( " already exists in this container" );
 416         throw com::sun::star::container::ElementExistException(
 417             buf.makeStringAndClear() , *this );
 418     }
 419
 420     int index = m_values.getLength();
 421     m_values.realloc( m_values.getLength() + 1 );
 422     m_values[index] = makeAny( descriptor );
 423     m_name2index[name] = index;
 424
 425     fire( InsertedBroadcaster( *this, name, makeAny( descriptor ) ) );
 426 }
 427
 428 void Container::appendByDescriptor(
 429     const ::com::sun::star::uno::Reference< ::com::sun::star::beans::XPropertySet >& descriptor)
 430     throw (::com::sun::star::sdbc::SQLException,
 431            ::com::sun::star::container::ElementExistException,
 432            ::com::sun::star::uno::RuntimeException, std::exception)
 433 {
 434     append( extractStringProperty( descriptor, getStatics().NAME ), descriptor );
 435 }
 436
 437
 438 void Container::addContainerListener(
 439         const ::com::sun::star::uno::Reference< ::com::sun::star::container::XContainerListener >& l )
 440         throw (::com::sun::star::uno::RuntimeException, std::exception)
 441 {
 442     rBHelper.addListener( getCppuType(&l) , l );
 443 }
 444
 445 void Container::removeContainerListener(
 446         const ::com::sun::star::uno::Reference< ::com::sun::star::container::XContainerListener >& l )
 447         throw (::com::sun::star::uno::RuntimeException, std::exception)
 448 {
 449     rBHelper.removeListener( getCppuType(&l) , l );
 450 }
 451
 452
 453 void Container::fire( const EventBroadcastHelper &helper )
 454 {
 455     Reference< ::com::sun::star::util::XRefreshListener > l;
 456     cppu::OInterfaceContainerHelper *container = rBHelper.getContainer( helper.getType() );
 457     if( container )
 458     {
 459         cppu::OInterfaceIteratorHelper iterator( * container );
 460         while( iterator.hasMoreElements() )
 461         {
 462             try
 463             {
 464                 helper.fire( (XEventListener * ) iterator.next() );
 465             }
 466             catch ( com::sun::star::uno::RuntimeException & )
 467             {
 468                 OSL_ENSURE( false, "exception catched" );
 469                 // loose coupling, a runtime exception shall not break anything
 470                 // TODO: log away as warning !
 471             }
 472             catch( com::sun::star::uno::Exception & )
 473             {
 474                 OSL_ENSURE( false, "exception from listener flying through" );
 475                 throw;
 476             }
 477         }
 478     }
 479
 480 }
 481
 482 }
 483
 484 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */