connectivity/source/drivers/postgresql/pq_xcontainer.cxx

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