connectivity/source/drivers/postgresql/pq_baseresultset.cxx

   1 /*************************************************************************
   2  *
   3  *  $RCSfile: pq_baseresultset.cxx,v $
   4  *
   5  *  $Revision: 1.1.2.4 $
   6  *
   7  *  last change: $Author: jbu $ $Date: 2004/08/29 08:33:28 $
   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 <osl/thread.h>
  63
  64 #include <rtl/ustrbuf.hxx>
  65
  66 #include <cppuhelper/typeprovider.hxx>
  67 #include <cppuhelper/queryinterface.hxx>
  68
  69 #include "pq_tools.hxx"
  70 #include "pq_array.hxx"
  71 #include "pq_statement.hxx"
  72 #include "pq_baseresultset.hxx"
  73 #include "pq_resultsetmetadata.hxx"
  74
  75 #include <com/sun/star/lang/DisposedException.hpp>
  76
  77 using osl::Mutex;
  78 using osl::MutexGuard;
  79
  80 using rtl::OUString;
  81 using rtl::OUStringToOString;
  82 using rtl::OUStringBuffer;
  83 using rtl::OString;
  84
  85 using com::sun::star::beans::XPropertySetInfo;
  86 using com::sun::star::beans::XPropertySet;
  87 using com::sun::star::beans::XMultiPropertySet;
  88 using com::sun::star::beans::XFastPropertySet;
  89
  90 using com::sun::star::uno::Any;
  91 using com::sun::star::uno::makeAny;
  92 using com::sun::star::uno::Type;
  93 using com::sun::star::uno::RuntimeException;
  94 using com::sun::star::uno::Exception;
  95 using com::sun::star::uno::Sequence;
  96 using com::sun::star::uno::Reference;
  97 using com::sun::star::uno::XInterface;
  98
  99 using com::sun::star::lang::IllegalArgumentException;
 100
 101 using com::sun::star::sdbc::XWarningsSupplier;
 102 using com::sun::star::sdbc::XCloseable;
 103 using com::sun::star::sdbc::XStatement;
 104 using com::sun::star::sdbc::XResultSet;
 105 using com::sun::star::sdbc::XConnection;
 106 using com::sun::star::sdbc::SQLException;
 107 using com::sun::star::sdbc::XRow;
 108 using com::sun::star::sdbc::XColumnLocate;
 109 using com::sun::star::sdbc::XResultSetMetaData;
 110 using com::sun::star::sdbc::XResultSetMetaDataSupplier;
 111
 112
 113 using com::sun::star::beans::Property;
 114
 115 namespace pq_sdbc_driver
 116 {
 117 #define ASCII_STR(x) OUString( RTL_CONSTASCII_USTRINGPARAM( x ) )
 118
 119 static ::cppu::IPropertyArrayHelper & getResultSetPropertyArrayHelper()
 120 {
 121     static ::cppu::IPropertyArrayHelper *pArrayHelper;
 122         if( ! pArrayHelper )
 123     {
 124                 MutexGuard guard( Mutex::getGlobalMutex() );
 125                 if( ! pArrayHelper )
 126         {
 127             static Property aTable[] =
 128                 {
 129                     Property(
 130                         OUString( RTL_CONSTASCII_USTRINGPARAM("CursorName") ), 0,
 131                         ::getCppuType( (OUString *)0) , 0 ),
 132                     Property(
 133                         OUString( RTL_CONSTASCII_USTRINGPARAM("EscapeProcessing") ), 0,
 134                         ::getBooleanCppuType() , 0 ),
 135                     Property(
 136                         OUString( RTL_CONSTASCII_USTRINGPARAM("FetchDirection") ), 0,
 137                         ::getCppuType( (sal_Int32 *)0) , 0 ),
 138                     Property(
 139                         OUString( RTL_CONSTASCII_USTRINGPARAM("FetchSize") ), 0,
 140                         ::getCppuType( (sal_Int32 *)0) , 0 ),
 141                     Property(
 142                         OUString( RTL_CONSTASCII_USTRINGPARAM("ResultSetConcurrency") ), 0,
 143                         ::getCppuType( (sal_Int32 *)0) , 0 ),
 144                     Property(
 145                         OUString( RTL_CONSTASCII_USTRINGPARAM("ResultSetType") ), 0,
 146                         ::getCppuType( (sal_Int32 *)0) , 0 )
 147                 };
 148             OSL_ASSERT( sizeof(aTable) / sizeof(Property) == BASERESULTSET_SIZE );
 149                         static ::cppu::OPropertyArrayHelper arrayHelper( aTable, BASERESULTSET_SIZE, sal_True );
 150             pArrayHelper = &arrayHelper;
 151         }
 152     }
 153     return *pArrayHelper;
 154 }
 155
 156 BaseResultSet::BaseResultSet(
 157     const ::rtl::Reference< RefCountedMutex > & refMutex,
 158     const Reference< XInterface > & owner,
 159     sal_Int32 rowCount,
 160     sal_Int32 colCount,
 161     const Reference< com::sun::star::script::XTypeConverter > & tc )
 162     : OComponentHelper( refMutex->mutex ),
 163       OPropertySetHelper( OComponentHelper::rBHelper ),
 164       m_refMutex( refMutex ),
 165       m_owner( owner ),
 166       m_row( -1 ),
 167       m_rowCount( rowCount ),
 168       m_fieldCount( colCount ),
 169       m_tc( tc )
 170 {
 171     POSTGRE_TRACE( "ctor BaseResultSet" );
 172 }
 173
 174 BaseResultSet::~BaseResultSet()
 175 {
 176     POSTGRE_TRACE( "dtor BaseResultSet" );
 177 }
 178
 179 Any BaseResultSet::queryInterface( const Type & reqType ) throw (RuntimeException)
 180 {
 181     Any ret;
 182
 183     ret = OComponentHelper::queryInterface( reqType );
 184     if( ! ret.hasValue() )
 185         ret = ::cppu::queryInterface( reqType,
 186                                     static_cast< XResultSet * > ( this  ),
 187                                     static_cast< XResultSetMetaDataSupplier * > ( this ),
 188                                     static_cast< XRow * > ( this ),
 189                                     static_cast< XColumnLocate * > ( this ),
 190                                     static_cast< XCloseable * > ( this ),
 191                                     static_cast< XPropertySet * > ( this ),
 192                                     static_cast< XMultiPropertySet * > ( this ),
 193                                     static_cast< XFastPropertySet * > ( this ) );
 194     return ret;
 195 }
 196
 197 // void BaseResultSet::close(  ) throw (SQLException, RuntimeException)
 198 // {
 199 //     Reference< XInterface > owner;
 200 //     {
 201 //         ResultSetGuard guard(*this);
 202 //         if( m_result )
 203 //         {
 204 //             PQclear(m_result );
 205 //             m_result = 0;
 206 //             m_row = -1;
 207 //         }
 208 //         owner = m_owner;
 209 //         m_owner.clear();
 210 //     }
 211 // }
 212
 213 Sequence<Type > BaseResultSet::getTypes() throw( RuntimeException )
 214 {
 215     static cppu::OTypeCollection *pCollection;
 216     if( ! pCollection )
 217     {
 218         MutexGuard guard( osl::Mutex::getGlobalMutex() );
 219         if( !pCollection )
 220         {
 221             static cppu::OTypeCollection collection(
 222                 getCppuType( (Reference< XResultSet> *) 0 ),
 223                 getCppuType( (Reference< XResultSetMetaDataSupplier> *) 0 ),
 224                 getCppuType( (Reference< XRow> *) 0 ),
 225                 getCppuType( (Reference< XColumnLocate> *) 0 ),
 226                 getCppuType( (Reference< XCloseable> *) 0 ),
 227                 getCppuType( (Reference< XPropertySet >*) 0 ),
 228                 getCppuType( (Reference< XFastPropertySet > *) 0 ),
 229                 getCppuType( (Reference< XMultiPropertySet > *) 0 ),
 230                 OComponentHelper::getTypes());
 231             pCollection = &collection;
 232         }
 233     }
 234     return pCollection->getTypes();
 235 }
 236
 237 Sequence< sal_Int8> BaseResultSet::getImplementationId() throw( RuntimeException )
 238 {
 239     static cppu::OImplementationId *pId;
 240     if( ! pId )
 241     {
 242         MutexGuard guard( osl::Mutex::getGlobalMutex() );
 243         if( ! pId )
 244         {
 245             static cppu::OImplementationId id(sal_False);
 246             pId = &id;
 247         }
 248     }
 249     return pId->getImplementationId();
 250 }
 251
 252 // Reference< XResultSetMetaData > BaseResultSet::getMetaData(  ) throw (SQLException, RuntimeException)
 253 // {
 254 //     ResultSetGuard guard(*this);
 255 //     checkClosed();
 256 //     return new ResultSetMetaData( m_refMutex, this, &m_result );
 257 // }
 258
 259 sal_Bool BaseResultSet::next(  ) throw (SQLException, RuntimeException)
 260 {
 261     MutexGuard guard( m_refMutex->mutex );
 262     checkClosed();
 263     m_row ++;
 264     return m_row < m_rowCount;
 265 }
 266
 267 sal_Bool BaseResultSet::isBeforeFirst(  ) throw (SQLException, RuntimeException)
 268 {
 269     MutexGuard guard( m_refMutex->mutex );
 270     checkClosed();
 271     return m_row == -1;
 272 }
 273
 274 sal_Bool BaseResultSet::isAfterLast(  ) throw (SQLException, RuntimeException)
 275 {
 276     MutexGuard guard( m_refMutex->mutex );
 277     checkClosed();
 278     return m_row >= m_rowCount;
 279 }
 280
 281 sal_Bool BaseResultSet::isFirst(  ) throw (SQLException, RuntimeException)
 282 {
 283     MutexGuard guard( m_refMutex->mutex );
 284     checkClosed();
 285     return m_row == 0 && m_rowCount;
 286 }
 287
 288 sal_Bool BaseResultSet::isLast(  ) throw (SQLException, RuntimeException)
 289 {
 290     MutexGuard guard( m_refMutex->mutex );
 291     checkClosed();
 292     return m_row >= 0 && m_row + 1 == m_rowCount;
 293 }
 294
 295 void BaseResultSet::beforeFirst(  ) throw (SQLException, RuntimeException)
 296 {
 297     MutexGuard guard( m_refMutex->mutex );
 298     checkClosed();
 299     m_row = -1;
 300 }
 301
 302 void BaseResultSet::afterLast(  ) throw (SQLException, RuntimeException)
 303 {
 304     MutexGuard guard( m_refMutex->mutex );
 305     checkClosed();
 306     m_row = m_rowCount;
 307 }
 308
 309 sal_Bool BaseResultSet::first(  ) throw (SQLException, RuntimeException)
 310 {
 311     MutexGuard guard( m_refMutex->mutex );
 312     checkClosed();
 313     sal_Bool bRet = ( m_rowCount > 0 );
 314     if( bRet )
 315         m_row = 0;
 316     return bRet;
 317 }
 318
 319 sal_Bool BaseResultSet::last(  ) throw (SQLException, RuntimeException)
 320 {
 321     MutexGuard guard( m_refMutex->mutex );
 322     checkClosed();
 323     sal_Bool bRet = ( m_rowCount > 0 );
 324     if( bRet )
 325         m_row = m_rowCount -1;
 326     return bRet;
 327 }
 328
 329 sal_Int32 BaseResultSet::getRow(  ) throw (SQLException, RuntimeException)
 330 {
 331     MutexGuard guard( m_refMutex->mutex );
 332     checkClosed();
 333     return m_row +1;
 334 }
 335
 336 sal_Bool BaseResultSet::absolute( sal_Int32 row ) throw (SQLException, RuntimeException)
 337 {
 338     MutexGuard guard( m_refMutex->mutex );
 339     checkClosed();
 340     if( row > 0 )
 341     {
 342         m_row = row -1;
 343         if( m_row > m_rowCount )
 344             m_row = m_rowCount;
 345     }
 346     else
 347     {
 348         m_row = m_rowCount + row;
 349         if( m_row < -1 )
 350             m_row = -1;
 351     }
 352     return sal_True;
 353 }
 354
 355 sal_Bool BaseResultSet::relative( sal_Int32 rows ) throw (SQLException, RuntimeException)
 356 {
 357     MutexGuard guard( m_refMutex->mutex );
 358     checkClosed();
 359     m_row += rows;
 360
 361     if( m_row > m_rowCount )
 362         m_row = m_rowCount;
 363     else if ( m_row < -1 )
 364         m_row = -1;
 365     return sal_True;
 366 }
 367
 368 sal_Bool BaseResultSet::previous(  ) throw (SQLException, RuntimeException)
 369 {
 370     MutexGuard guard( m_refMutex->mutex );
 371     checkClosed();
 372     sal_Bool bRet = ( m_row != -1 );
 373     if( bRet )
 374         m_row --;
 375     return bRet;
 376 }
 377
 378 void BaseResultSet::refreshRow(  ) throw (SQLException, RuntimeException)
 379 {
 380     // TODO: not supported for now
 381 }
 382
 383 sal_Bool BaseResultSet::rowUpdated(  ) throw (SQLException, RuntimeException)
 384 {
 385     return sal_False;
 386 }
 387
 388 sal_Bool BaseResultSet::rowInserted(  ) throw (SQLException, RuntimeException)
 389 {
 390     return sal_False;
 391 }
 392
 393 sal_Bool BaseResultSet::rowDeleted(  ) throw (SQLException, RuntimeException)
 394 {
 395     return sal_False;
 396 }
 397
 398 Reference< XInterface > BaseResultSet::getStatement() throw (SQLException, RuntimeException)
 399 {
 400     MutexGuard guard( m_refMutex->mutex );
 401     checkClosed();
 402     return m_owner;
 403 }
 404
 405
 406 //----------------- XRow interface ----------------------------------------------------
 407
 408 sal_Bool BaseResultSet::wasNull(  ) throw (SQLException, RuntimeException)
 409 {
 410     return m_wasNull;
 411 }
 412
 413 Any BaseResultSet::convertTo( const Any & val , const Type & type )
 414 {
 415     Any aRet;
 416     try
 417     {
 418         aRet = m_tc->convertTo( val , type );
 419     }
 420     catch( com::sun::star::lang::IllegalArgumentException & e )
 421     {}
 422     catch( com::sun::star::script::CannotConvertException & e )
 423     {}
 424     return aRet;
 425 }
 426
 427 sal_Bool BaseResultSet::getBoolean( sal_Int32 columnIndex ) throw (SQLException, RuntimeException)
 428 {
 429     MutexGuard guard( m_refMutex->mutex );
 430     checkClosed();
 431     checkColumnIndex( columnIndex );
 432     checkRowIndex( sal_True /* must be on row */ );
 433
 434     sal_Bool b = sal_False;
 435
 436     OUString str = getString( columnIndex );
 437
 438     if( str.getLength() > 0 )
 439     {
 440         switch(str[0])
 441         {
 442         case '1':
 443         case 't':
 444         case 'T':
 445         case 'y':
 446         case 'Y':
 447
 448             return sal_True;
 449         }
 450     }
 451     return sal_False;
 452 }
 453
 454 sal_Int8 BaseResultSet::getByte( sal_Int32 columnIndex )
 455         throw (SQLException, RuntimeException)
 456 {
 457     MutexGuard guard( m_refMutex->mutex );
 458     checkClosed();
 459     checkColumnIndex( columnIndex );
 460     checkRowIndex( sal_True /* must be on row */ );
 461     sal_Int8 b = 0;
 462     convertTo( getValue( columnIndex ), getCppuType( &b )) >>= b;
 463     return b;
 464 }
 465
 466 sal_Int16 BaseResultSet::getShort( sal_Int32 columnIndex )
 467         throw (SQLException, RuntimeException)
 468 {
 469     MutexGuard guard( m_refMutex->mutex );
 470     checkClosed();
 471     checkColumnIndex( columnIndex );
 472     checkRowIndex( sal_True /* must be on row */ );
 473     sal_Int16 i = 0;
 474     convertTo( getValue( columnIndex ), getCppuType( &i )) >>= i;
 475     return i;
 476 }
 477
 478 OUString BaseResultSet::getString( sal_Int32 columnIndex ) throw (SQLException, RuntimeException)
 479 {
 480     MutexGuard guard(m_refMutex->mutex);
 481     checkClosed();
 482     checkColumnIndex( columnIndex );
 483     checkRowIndex( sal_True /* must be on row */ );
 484     OUString ret;
 485     convertTo( getValue(  columnIndex ), getCppuType( &ret ) ) >>= ret;
 486 //     printf( "BaseResultSet::getString() %s\n" , OUStringToOString( ret, RTL_TEXTENCODING_ASCII_US ).getStr() );
 487     return ret;
 488 }
 489
 490 sal_Int32 BaseResultSet::getInt( sal_Int32 columnIndex )
 491         throw (SQLException, RuntimeException)
 492 {
 493     MutexGuard guard( m_refMutex->mutex );
 494     checkClosed();
 495     checkColumnIndex( columnIndex );
 496     checkRowIndex( sal_True /* must be on row */ );
 497     sal_Int32 i = 0;
 498     convertTo( getValue( columnIndex ), getCppuType( &i )) >>= i;
 499     return i;
 500 }
 501
 502 sal_Int64 BaseResultSet::getLong( sal_Int32 columnIndex )
 503         throw (SQLException, RuntimeException)
 504 {
 505     MutexGuard guard( m_refMutex->mutex );
 506     checkClosed();
 507     checkColumnIndex( columnIndex );
 508     checkRowIndex( sal_True /* must be on row */ );
 509     sal_Int64 i = 0;
 510     convertTo( getValue( columnIndex ), getCppuType( &i )) >>= i;
 511     return i;
 512 }
 513
 514 float BaseResultSet::getFloat( sal_Int32 columnIndex )
 515         throw (SQLException, RuntimeException)
 516 {
 517     MutexGuard guard( m_refMutex->mutex );
 518     checkClosed();
 519     checkColumnIndex( columnIndex );
 520     checkRowIndex( sal_True /* must be on row */ );
 521     float f = 0.;
 522     convertTo( getValue( columnIndex ), getCppuType( &f )) >>= f;
 523     return f;
 524 }
 525
 526 double BaseResultSet::getDouble( sal_Int32 columnIndex )
 527         throw (SQLException, RuntimeException)
 528 {
 529     MutexGuard guard( m_refMutex->mutex );
 530     checkClosed();
 531     checkColumnIndex( columnIndex );
 532     double d = 0.;
 533     convertTo( getValue( columnIndex ), getCppuType( &d )) >>= d;
 534     return d;
 535 }
 536
 537 Sequence< sal_Int8 > BaseResultSet::getBytes( sal_Int32 columnIndex )
 538         throw (SQLException, RuntimeException)
 539 {
 540     MutexGuard guard( m_refMutex->mutex );
 541     checkClosed();
 542     checkColumnIndex( columnIndex );
 543     checkRowIndex( sal_True /* must be on row */ );
 544
 545     Sequence< sal_Int8 > ret;
 546     OUString ustr;
 547     if( ! (getValue( columnIndex ) >>= ustr) )
 548         m_wasNull = true;
 549     else
 550     {
 551         // if this is a binary, it must contain escaped data !
 552         OString val = rtl::OUStringToOString( ustr, RTL_TEXTENCODING_ASCII_US );
 553
 554         size_t length;
 555         char * res = (char*) PQunescapeBytea( (unsigned char *)val.getStr() , &length);
 556         ret = Sequence< sal_Int8 > ( (sal_Int8*)res, length );
 557         if( res )
 558             free( res );
 559     }
 560     return ret;
 561 }
 562
 563
 564 ::com::sun::star::util::Date BaseResultSet::getDate( sal_Int32 columnIndex )
 565         throw (SQLException, RuntimeException)
 566 {
 567     return string2Date( getString( columnIndex ) );
 568 }
 569
 570 ::com::sun::star::util::Time BaseResultSet::getTime( sal_Int32 columnIndex )
 571         throw (SQLException, RuntimeException)
 572 {
 573     return string2Time( getString( columnIndex ) );
 574 }
 575
 576 ::com::sun::star::util::DateTime BaseResultSet::getTimestamp( sal_Int32 columnIndex )
 577         throw (SQLException, RuntimeException)
 578 {
 579     return string2DateTime( getString( columnIndex ) );
 580 }
 581
 582 Reference< ::com::sun::star::io::XInputStream > BaseResultSet::getBinaryStream( sal_Int32 columnIndex )
 583         throw (SQLException, RuntimeException)
 584 {
 585     return 0;
 586 }
 587
 588 Reference< ::com::sun::star::io::XInputStream > BaseResultSet::getCharacterStream( sal_Int32 columnIndex )
 589         throw (SQLException, RuntimeException)
 590 {
 591     return 0;
 592 }
 593
 594 Any BaseResultSet::getObject(
 595         sal_Int32 columnIndex,
 596         const Reference< ::com::sun::star::container::XNameAccess >& typeMap )
 597         throw (SQLException, RuntimeException)
 598 {
 599     return Any();
 600 }
 601
 602 Reference< ::com::sun::star::sdbc::XRef > BaseResultSet::getRef( sal_Int32 columnIndex )
 603         throw (SQLException, RuntimeException)
 604 {
 605     return Reference< com::sun::star::sdbc::XRef > ();
 606 }
 607
 608 Reference< ::com::sun::star::sdbc::XBlob > BaseResultSet::getBlob( sal_Int32 columnIndex )
 609         throw (SQLException, RuntimeException)
 610 {
 611     return Reference< com::sun::star::sdbc::XBlob > ();
 612 }
 613
 614 Reference< ::com::sun::star::sdbc::XClob > BaseResultSet::getClob( sal_Int32 columnIndex )
 615         throw (SQLException, RuntimeException)
 616 {
 617     return Reference< com::sun::star::sdbc::XClob > ();
 618 }
 619
 620 Reference< ::com::sun::star::sdbc::XArray > BaseResultSet::getArray( sal_Int32 columnIndex )
 621         throw (SQLException, RuntimeException)
 622 {
 623     return new Array( m_refMutex, parseArray( getString( columnIndex ) ), *this, m_tc );
 624 }
 625
 626
 627 ::cppu::IPropertyArrayHelper & BaseResultSet::getInfoHelper()
 628 {
 629     return getResultSetPropertyArrayHelper();
 630 }
 631
 632
 633 sal_Bool BaseResultSet::convertFastPropertyValue(
 634                 Any & rConvertedValue, Any & rOldValue, sal_Int32 nHandle, const Any& rValue )
 635                 throw (IllegalArgumentException)
 636 {
 637     sal_Bool bRet;
 638     switch( nHandle )
 639     {
 640     case BASERESULTSET_CURSOR_NAME:
 641     {
 642         OUString val;
 643         bRet = ( rValue >>= val );
 644         m_props[nHandle] = makeAny( val );
 645         break;
 646     }
 647     case BASERESULTSET_ESCAPE_PROCESSING:
 648     {
 649         sal_Bool val;
 650         bRet = ( rValue >>= val );
 651         m_props[nHandle] = makeAny( val );
 652         break;
 653     }
 654     case BASERESULTSET_FETCH_DIRECTION:
 655     case BASERESULTSET_FETCH_SIZE:
 656     case BASERESULTSET_RESULT_SET_CONCURRENCY:
 657     case BASERESULTSET_RESULT_SET_TYPE:
 658     {
 659         sal_Int32 val;
 660         bRet = ( rValue >>= val );
 661         m_props[nHandle] = makeAny( val );
 662         break;
 663     }
 664     default:
 665     {
 666         OUStringBuffer buf(128);
 667         buf.appendAscii( "pq_resultset: Invalid property handle (" );
 668         buf.append( nHandle );
 669         buf.appendAscii( ")" );
 670         throw IllegalArgumentException( buf.makeStringAndClear(), *this, 2 );
 671     }
 672     }
 673     return bRet;
 674 }
 675
 676
 677 void BaseResultSet::setFastPropertyValue_NoBroadcast(
 678     sal_Int32 nHandle,const Any& rValue ) throw (Exception)
 679 {
 680     m_props[nHandle] = rValue;
 681 }
 682
 683 void BaseResultSet::getFastPropertyValue( Any& rValue, sal_Int32 nHandle ) const
 684 {
 685     rValue = m_props[nHandle];
 686 }
 687
 688 Reference < XPropertySetInfo >  BaseResultSet::getPropertySetInfo()
 689         throw(RuntimeException)
 690 {
 691     return OPropertySetHelper::createPropertySetInfo( getResultSetPropertyArrayHelper() );
 692 }
 693
 694 void BaseResultSet::disposing()
 695 {
 696     close();
 697 }
 698
 699 void BaseResultSet::checkColumnIndex(sal_Int32 index ) throw ( SQLException, RuntimeException )
 700 {
 701     if( index < 1 || index > m_fieldCount )
 702     {
 703         OUStringBuffer buf(128);
 704         buf.appendAscii( "pq_resultset: index out of range (" );
 705         buf.append( index );
 706         buf.appendAscii( ", allowed range is 1 to " );
 707         buf.append( m_fieldCount );
 708         buf.appendAscii( ")" );
 709         throw SQLException( buf.makeStringAndClear(), *this, OUString(), 1, Any() );
 710     }
 711
 712 }
 713
 714 void BaseResultSet::checkRowIndex( sal_Bool mustBeOnValidRow )
 715 {
 716     OUStringBuffer buf( 128 );
 717     buf.appendAscii( "pq_baseresultset: row index out of range, allowed is " );
 718     if( mustBeOnValidRow )
 719     {
 720         if( m_row < 0 || m_row >= m_rowCount )
 721         {
 722             buf.appendAscii( "0 to " );
 723             buf.append( ((sal_Int32)(m_rowCount -1)) );
 724             buf.appendAscii( ", got " );
 725             buf.append( m_row );
 726             throw SQLException( buf.makeStringAndClear(), *this, OUString(),1, Any() );
 727         }
 728     }
 729     else
 730     {
 731         if( m_row < -1 || m_row > m_rowCount )
 732         {
 733             buf.appendAscii( "-1 to " );
 734             buf.append( m_rowCount );
 735             buf.appendAscii( ", got " );
 736             buf.append( m_row );
 737             throw SQLException( buf.makeStringAndClear(), *this, OUString(),1, Any() );
 738         }
 739     }
 740 }
 741
 742 }