connectivity/source/drivers/postgresql/pq_xtable.cxx

   1 /*************************************************************************
   2  *
   3  *  $RCSfile: pq_xtable.cxx,v $
   4  *
   5  *  $Revision: 1.1.2.6 $
   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 <cppuhelper/typeprovider.hxx>
  65 #include <cppuhelper/queryinterface.hxx>
  66
  67 #include <com/sun/star/beans/PropertyAttribute.hpp>
  68
  69 #include <com/sun/star/sdbc/XRow.hpp>
  70 #include <com/sun/star/sdbc/XParameters.hpp>
  71
  72 #include "pq_xtable.hxx"
  73 #include "pq_xtables.hxx"
  74 #include "pq_xviews.hxx"
  75 #include "pq_xindexes.hxx"
  76 #include "pq_xkeys.hxx"
  77 #include "pq_xcolumns.hxx"
  78 #include "pq_tools.hxx"
  79 #include "pq_statics.hxx"
  80
  81 using osl::MutexGuard;
  82 using osl::Mutex;
  83
  84 using rtl::OUString;
  85 using rtl::OUStringBuffer;
  86 using rtl::OUStringToOString;
  87
  88 using com::sun::star::container::XNameAccess;
  89 using com::sun::star::container::XIndexAccess;
  90 using com::sun::star::container::ElementExistException;
  91 using com::sun::star::container::NoSuchElementException;
  92
  93 using com::sun::star::uno::Reference;
  94 using com::sun::star::uno::Exception;
  95 using com::sun::star::uno::UNO_QUERY;
  96 using com::sun::star::uno::XInterface;
  97 using com::sun::star::uno::Sequence;
  98 using com::sun::star::uno::Any;
  99 using com::sun::star::uno::makeAny;
 100 using com::sun::star::uno::Type;
 101 using com::sun::star::uno::RuntimeException;
 102
 103 using com::sun::star::lang::IllegalArgumentException;
 104 using com::sun::star::lang::IndexOutOfBoundsException;
 105
 106 using com::sun::star::beans::XPropertySetInfo;
 107 using com::sun::star::beans::XFastPropertySet;
 108 using com::sun::star::beans::XMultiPropertySet;
 109 using com::sun::star::beans::XPropertySet;
 110 using com::sun::star::beans::Property;
 111
 112 using com::sun::star::sdbc::XResultSet;
 113 using com::sun::star::sdbc::XPreparedStatement;
 114 using com::sun::star::sdbc::XStatement;
 115 using com::sun::star::sdbc::XParameters;
 116 using com::sun::star::sdbc::XRow;
 117 using com::sun::star::sdbc::SQLException;
 118
 119 namespace pq_sdbc_driver
 120 {
 121 #define ASCII_STR(x) OUString( RTL_CONSTASCII_USTRINGPARAM( x ) )
 122
 123 Table::Table( const ::rtl::Reference< RefCountedMutex > & refMutex,
 124               const Reference< com::sun::star::sdbc::XConnection > & connection,
 125               ConnectionSettings *pSettings)
 126     : ReflectionBase(
 127         getStatics().refl.table.implName,
 128         getStatics().refl.table.serviceNames,
 129         refMutex,
 130         connection,
 131         pSettings,
 132         * getStatics().refl.table.pProps ),
 133       m_pColumns( 0 )
 134 {}
 135
 136 Reference< XPropertySet > Table::createDataDescriptor(  ) throw (RuntimeException)
 137 {
 138     TableDescriptor * pTable = new TableDescriptor(
 139         m_refMutex, m_conn, m_pSettings );
 140     pTable->copyValuesFrom( this );
 141
 142     return Reference< XPropertySet > ( pTable );
 143 }
 144
 145 Reference< XNameAccess > Table::getColumns(  ) throw (::com::sun::star::uno::RuntimeException)
 146 {
 147     if( ! m_columns.is() )
 148     {
 149         m_columns = Columns::create(
 150             m_refMutex,
 151             m_conn,
 152             m_pSettings,
 153             extractStringProperty( this, getStatics().SCHEMA_NAME ),
 154             extractStringProperty( this, getStatics().NAME ),
 155             &m_pColumns);
 156     }
 157     return m_columns;
 158 }
 159
 160 Reference< XNameAccess > Table::getIndexes() throw (::com::sun::star::uno::RuntimeException)
 161 {
 162     if( ! m_indexes.is() )
 163     {
 164         m_indexes = ::pq_sdbc_driver::Indexes::create(
 165             m_refMutex,
 166             m_conn,
 167             m_pSettings,
 168             extractStringProperty( this, getStatics().SCHEMA_NAME ),
 169             extractStringProperty( this, getStatics().NAME ) );
 170     }
 171     return m_indexes;
 172 }
 173
 174 Reference< XIndexAccess > Table::getKeys(  ) throw (::com::sun::star::uno::RuntimeException)
 175 {
 176     if( ! m_keys.is() )
 177     {
 178         m_keys = ::pq_sdbc_driver::Keys::create(
 179             m_refMutex,
 180             m_conn,
 181             m_pSettings,
 182             extractStringProperty( this, getStatics().SCHEMA_NAME ),
 183             extractStringProperty( this, getStatics().NAME ) );
 184     }
 185     return m_keys;
 186 }
 187
 188 void Table::rename( const ::rtl::OUString& newName )
 189         throw (::com::sun::star::sdbc::SQLException,
 190                ::com::sun::star::container::ElementExistException,
 191                ::com::sun::star::uno::RuntimeException)
 192 {
 193     MutexGuard guard( m_refMutex->mutex );
 194     Statics & st = getStatics();
 195
 196     ::rtl::OUString oldName = extractStringProperty(this,st.NAME );
 197     ::rtl::OUString schema = extractStringProperty(this,st.SCHEMA_NAME );
 198     ::rtl::OUString fullOldName = concatQualified( schema, oldName );
 199
 200     OUString newTableName;
 201     OUString newSchemaName;
 202     // OOo2.0 passes schema + dot + new-table-name while
 203     // OO1.1.x passes new Name without schema
 204     // in case name contains a dot, it is interpreted as schema.tablename
 205     if( newName.indexOf( '.' ) >= 0 )
 206     {
 207         splitConcatenatedIdentifier( newName, &newSchemaName, &newTableName );
 208     }
 209     else
 210     {
 211         newTableName = newName;
 212         newSchemaName = schema;
 213     }
 214     ::rtl::OUString fullNewName = concatQualified( newSchemaName, newTableName );
 215
 216     if( extractStringProperty( this, st.TYPE ).equals( st.VIEW ) && m_pSettings->views.is() )
 217     {
 218         // maintain view list (really strange API !)
 219         Any a = m_pSettings->pViewsImpl->getByName( fullOldName );
 220         Reference< com::sun::star::sdbcx::XRename > rename;
 221         a >>= rename;
 222         if( rename.is() )
 223         {
 224             rename->rename( newName );
 225             setPropertyValue_NoBroadcast_public( st.SCHEMA_NAME, makeAny(newSchemaName) );
 226         }
 227     }
 228     else
 229     {
 230         if( ! newSchemaName.equals(schema) )
 231         {
 232             // try new schema name first
 233             try
 234             {
 235                 OUStringBuffer buf(128);
 236                 buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( "ALTER TABLE" ) );
 237                 bufferQuoteQualifiedIdentifier(buf, schema, oldName );
 238                 buf.appendAscii( RTL_CONSTASCII_STRINGPARAM("SET SCHEMA" ) );
 239                 bufferQuoteIdentifier( buf, newSchemaName );
 240                 Reference< XStatement > statement = m_conn->createStatement();
 241                 statement->executeUpdate( buf.makeStringAndClear() );
 242                 setPropertyValue_NoBroadcast_public( st.SCHEMA_NAME, makeAny(newSchemaName) );
 243                 disposeNoThrow( statement );
 244                 schema = newSchemaName;
 245             }
 246             catch( com::sun::star::sdbc::SQLException &e )
 247             {
 248                 OUStringBuffer buf( e.Message );
 249                 buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( "(NOTE: Only postgresql server >= V8.1 support changing a table's schema)" ) );
 250                 e.Message = buf.makeStringAndClear();
 251                 throw e;
 252             }
 253
 254         }
 255         if( ! newTableName.equals( oldName ) ) // might also be just the change of a schema name
 256         {
 257             OUStringBuffer buf(128);
 258             buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( "ALTER TABLE" ) );
 259             bufferQuoteQualifiedIdentifier(buf, schema, oldName );
 260             buf.appendAscii( RTL_CONSTASCII_STRINGPARAM("RENAME TO" ) );
 261             bufferQuoteIdentifier( buf, newTableName );
 262             Reference< XStatement > statement = m_conn->createStatement();
 263             statement->executeUpdate( buf.makeStringAndClear() );
 264             disposeNoThrow( statement );
 265         }
 266     }
 267     setPropertyValue_NoBroadcast_public( st.NAME, makeAny(newTableName) );
 268     // inform the container of the name change !
 269     if( m_pSettings->tables.is() )
 270     {
 271         m_pSettings->pTablesImpl->rename( fullOldName, fullNewName );
 272     }
 273 }
 274
 275 void Table::alterColumnByName(
 276     const ::rtl::OUString& colName,
 277     const Reference< XPropertySet >& descriptor )
 278     throw (SQLException,NoSuchElementException,RuntimeException)
 279 {
 280     Reference< com::sun::star::container::XNameAccess > colums =
 281         Reference< com::sun::star::container::XNameAccess > ( getColumns(), UNO_QUERY );
 282
 283     OUString newName = extractStringProperty(descriptor, getStatics().NAME );
 284     ::pq_sdbc_driver::alterColumnByDescriptor(
 285         extractStringProperty( this, getStatics().SCHEMA_NAME ),
 286         extractStringProperty( this, getStatics().NAME ),
 287         m_pSettings->encoding,
 288         m_conn->createStatement(),
 289         Reference< com::sun::star::beans::XPropertySet>( colums->getByName( colName ), UNO_QUERY) ,
 290         descriptor );
 291
 292     if( colName !=  newName )
 293     {
 294 //         m_pColumns->rename( colName, newName );
 295         m_pColumns->refresh();
 296     }
 297 }
 298
 299 void Table::alterColumnByIndex(
 300     sal_Int32 index,
 301     const ::com::sun::star::uno::Reference< ::com::sun::star::beans::XPropertySet >& descriptor )
 302     throw (SQLException,IndexOutOfBoundsException,RuntimeException)
 303 {
 304     Reference< com::sun::star::container::XIndexAccess > colums =
 305         Reference< com::sun::star::container::XIndexAccess>( getColumns(), UNO_QUERY );
 306     Reference< com::sun::star::beans::XPropertySet> column(colums->getByIndex( index ), UNO_QUERY );
 307     OUString oldName = extractStringProperty( column, getStatics().NAME );
 308     OUString newName = extractStringProperty( descriptor, getStatics().NAME );
 309     ::pq_sdbc_driver::alterColumnByDescriptor(
 310         extractStringProperty( this, getStatics().SCHEMA_NAME ),
 311         extractStringProperty( this, getStatics().NAME ),
 312         m_pSettings->encoding,
 313         m_conn->createStatement(),
 314         column,
 315         descriptor );
 316 //     m_pColumns->rename( oldName, newName );
 317     m_pColumns->refresh();
 318 }
 319
 320 Sequence<Type > Table::getTypes() throw( RuntimeException )
 321 {
 322     static cppu::OTypeCollection *pCollection;
 323     if( ! pCollection )
 324     {
 325         MutexGuard guard( osl::Mutex::getGlobalMutex() );
 326         if( !pCollection )
 327         {
 328             static cppu::OTypeCollection collection(
 329                 getCppuType( (Reference< com::sun::star::sdbcx::XIndexesSupplier> *) 0 ),
 330                 getCppuType( (Reference< com::sun::star::sdbcx::XKeysSupplier> *) 0 ),
 331                 getCppuType( (Reference< com::sun::star::sdbcx::XColumnsSupplier> *) 0 ),
 332                 getCppuType( (Reference< com::sun::star::sdbcx::XRename> *) 0 ),
 333                 getCppuType( (Reference< com::sun::star::sdbcx::XAlterTable> *) 0 ),
 334                 ReflectionBase::getTypes());
 335             pCollection = &collection;
 336         }
 337     }
 338     return pCollection->getTypes();
 339 }
 340
 341 Sequence< sal_Int8> Table::getImplementationId() throw( RuntimeException )
 342 {
 343     return getStatics().refl.table.implementationId;
 344 }
 345
 346 Any Table::queryInterface( const Type & reqType ) throw (RuntimeException)
 347 {
 348     Any ret;
 349
 350     ret = ReflectionBase::queryInterface( reqType );
 351     if( ! ret.hasValue() )
 352         ret = ::cppu::queryInterface(
 353             reqType,
 354             static_cast< com::sun::star::sdbcx::XIndexesSupplier * > ( this ),
 355             static_cast< com::sun::star::sdbcx::XKeysSupplier * > ( this ),
 356             static_cast< com::sun::star::sdbcx::XColumnsSupplier * > ( this ),
 357             static_cast< com::sun::star::sdbcx::XRename * > ( this ),
 358             static_cast< com::sun::star::sdbcx::XAlterTable * > ( this )
 359             );
 360     return ret;
 361 }
 362
 363 ::com::sun::star::uno::Any Table::getPropertyValue(const ::rtl::OUString& aPropertyName)
 364                 throw(::com::sun::star::beans::UnknownPropertyException, ::com::sun::star::lang::WrappedTargetException, ::com::sun::star::uno::RuntimeException)
 365 {
 366     return ReflectionBase::getPropertyValue( aPropertyName );
 367 }
 368
 369
 370 ::rtl::OUString Table::getName(  ) throw (::com::sun::star::uno::RuntimeException)
 371 {
 372     Statics & st = getStatics();
 373     return concatQualified(
 374         extractStringProperty( this, st.SCHEMA_NAME ),
 375         extractStringProperty( this, st.NAME ) );
 376 }
 377
 378 void Table::setName( const ::rtl::OUString& aName ) throw (::com::sun::star::uno::RuntimeException)
 379 {
 380     rename( aName );
 381 }
 382
 383
 384
 385 //________________________________________________________________________
 386 TableDescriptor::TableDescriptor(
 387     const ::rtl::Reference< RefCountedMutex > & refMutex,
 388     const Reference< com::sun::star::sdbc::XConnection > & connection,
 389     ConnectionSettings *pSettings)
 390     : ReflectionBase(
 391         getStatics().refl.tableDescriptor.implName,
 392         getStatics().refl.tableDescriptor.serviceNames,
 393         refMutex,
 394         connection,
 395         pSettings,
 396         * getStatics().refl.tableDescriptor.pProps )
 397 {
 398 }
 399
 400 Reference< XNameAccess > TableDescriptor::getColumns(  ) throw (::com::sun::star::uno::RuntimeException)
 401 {
 402     if( ! m_columns.is() )
 403     {
 404         m_columns = new ColumnDescriptors(m_refMutex, m_conn, m_pSettings );
 405     }
 406     return m_columns;
 407 }
 408
 409 Reference< XNameAccess > TableDescriptor::getIndexes() throw (::com::sun::star::uno::RuntimeException)
 410 {
 411     if( ! m_indexes.is() )
 412     {
 413         m_indexes = ::pq_sdbc_driver::IndexDescriptors::create(
 414             m_refMutex,
 415             m_conn,
 416             m_pSettings);
 417     }
 418     return m_indexes;
 419 }
 420
 421 Reference< XIndexAccess > TableDescriptor::getKeys(  ) throw (::com::sun::star::uno::RuntimeException)
 422 {
 423     if( ! m_keys.is() )
 424     {
 425         m_keys = ::pq_sdbc_driver::KeyDescriptors::create(
 426             m_refMutex,
 427             m_conn,
 428             m_pSettings );
 429     }
 430     return m_keys;
 431 }
 432
 433
 434 Sequence<Type > TableDescriptor::getTypes() throw( RuntimeException )
 435 {
 436     static cppu::OTypeCollection *pCollection;
 437     if( ! pCollection )
 438     {
 439         MutexGuard guard( osl::Mutex::getGlobalMutex() );
 440         if( !pCollection )
 441         {
 442             static cppu::OTypeCollection collection(
 443                 getCppuType( (Reference< com::sun::star::sdbcx::XIndexesSupplier> *) 0 ),
 444                 getCppuType( (Reference< com::sun::star::sdbcx::XKeysSupplier> *) 0 ),
 445                 getCppuType( (Reference< com::sun::star::sdbcx::XColumnsSupplier> *) 0 ),
 446                 ReflectionBase::getTypes());
 447             pCollection = &collection;
 448         }
 449     }
 450     return pCollection->getTypes();
 451 }
 452
 453 Sequence< sal_Int8> TableDescriptor::getImplementationId() throw( RuntimeException )
 454 {
 455     return getStatics().refl.tableDescriptor.implementationId;
 456 }
 457
 458 Any TableDescriptor::queryInterface( const Type & reqType ) throw (RuntimeException)
 459 {
 460     Any ret;
 461
 462     ret = ReflectionBase::queryInterface( reqType );
 463     if( ! ret.hasValue() )
 464         ret = ::cppu::queryInterface(
 465             reqType,
 466             static_cast< com::sun::star::sdbcx::XIndexesSupplier * > ( this ),
 467             static_cast< com::sun::star::sdbcx::XKeysSupplier * > ( this ),
 468             static_cast< com::sun::star::sdbcx::XColumnsSupplier * > ( this ));
 469     return ret;
 470 }
 471
 472
 473 Reference< XPropertySet > TableDescriptor::createDataDescriptor(  ) throw (RuntimeException)
 474 {
 475     TableDescriptor * pTable = new TableDescriptor(
 476         m_refMutex, m_conn, m_pSettings );
 477
 478     // TODO: deep copies
 479     pTable->m_values = m_values;
 480
 481     return Reference< XPropertySet > ( pTable );
 482 }
 483
 484 }