connectivity/source/drivers/postgresql/pq_xviews.cxx

   1 /*************************************************************************
   2  *
   3  *  $RCSfile: pq_xviews.cxx,v $
   4  *
   5  *  $Revision: 1.1.2.4 $
   6  *
   7  *  last change: $Author: jbu $ $Date: 2006/05/01 19:19:09 $
   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 <vector>
  63
  64 #include <rtl/ustrbuf.hxx>
  65
  66 #include <com/sun/star/sdbc/XRow.hpp>
  67 #include <com/sun/star/sdbc/XParameters.hpp>
  68 #include <com/sun/star/sdbcx/Privilege.hpp>
  69
  70 #include "pq_xviews.hxx"
  71 #include "pq_xview.hxx"
  72 #include "pq_xtables.hxx"
  73 #include "pq_statics.hxx"
  74 #include "pq_tools.hxx"
  75
  76 using osl::MutexGuard;
  77
  78 using rtl::OUString;
  79 using rtl::OUStringBuffer;
  80 using rtl::OUStringToOString;
  81
  82 using com::sun::star::beans::XPropertySet;
  83
  84 using com::sun::star::uno::Any;
  85 using com::sun::star::uno::makeAny;
  86 using com::sun::star::uno::UNO_QUERY;
  87 using com::sun::star::uno::Type;
  88 using com::sun::star::uno::XInterface;
  89 using com::sun::star::uno::Reference;
  90 using com::sun::star::uno::Sequence;
  91 using com::sun::star::uno::RuntimeException;
  92
  93 using com::sun::star::container::NoSuchElementException;
  94 using com::sun::star::lang::WrappedTargetException;
  95
  96 using com::sun::star::sdbc::XRow;
  97 using com::sun::star::sdbc::XCloseable;
  98 using com::sun::star::sdbc::XStatement;
  99 using com::sun::star::sdbc::XResultSet;
 100 using com::sun::star::sdbc::XParameters;
 101 using com::sun::star::sdbc::XPreparedStatement;
 102 using com::sun::star::sdbc::XDatabaseMetaData;
 103
 104 //  using com::sun::star::sdbcx::Privilege;
 105
 106 namespace pq_sdbc_driver
 107 {
 108 #define ASCII_STR(x) OUString( RTL_CONSTASCII_USTRINGPARAM( x ) )
 109 Views::Views(
 110         const ::rtl::Reference< RefCountedMutex > & refMutex,
 111         const ::com::sun::star::uno::Reference< com::sun::star::sdbc::XConnection >  & origin,
 112         ConnectionSettings *pSettings )
 113     : Container( refMutex, origin, pSettings,  getStatics().VIEW )
 114 {}
 115
 116 Views::~Views()
 117 {}
 118
 119 void Views::refresh()
 120     throw (::com::sun::star::uno::RuntimeException)
 121 {
 122     try
 123     {
 124         osl::MutexGuard guard( m_refMutex->mutex );
 125         Statics & st = getStatics();
 126
 127         Reference< XStatement > stmt = m_origin->createStatement();
 128
 129         Reference< XResultSet > rs = stmt->executeQuery(
 130             ASCII_STR( "SELECT "
 131                               "DISTINCT ON( pg_namespace.nspname, relname) " // needed because of duplicates
 132                               "pg_namespace.nspname,"     // 1
 133                               "relname,"                  // 2
 134                               "pg_get_viewdef(ev_class) " // 3
 135                        "FROM pg_namespace, pg_class, pg_rewrite "
 136                        "WHERE pg_namespace.oid = relnamespace "
 137                              "AND pg_class.oid = ev_class "
 138                        "AND relkind='v'" ) );
 139
 140         Reference< XRow > xRow( rs , UNO_QUERY );
 141
 142         std::vector< Any, Allocator< Any> > vec;
 143         String2IntMap map;
 144         sal_Int32 viewIndex = 0;
 145
 146         while( rs->next() )
 147         {
 148             rtl::OUString table, schema, command;
 149             schema = xRow->getString( 1 );
 150             table = xRow->getString( 2 );
 151             command = xRow->getString( 3 );
 152
 153             View *pView = new View (m_refMutex, m_origin, m_pSettings );
 154             Reference< com::sun::star::beans::XPropertySet > prop = pView;
 155
 156             pView->setPropertyValue_NoBroadcast_public(st.NAME , makeAny(table) );
 157             pView->setPropertyValue_NoBroadcast_public(st.SCHEMA_NAME, makeAny(schema) );
 158             pView->setPropertyValue_NoBroadcast_public(st.COMMAND, makeAny(command) );
 159             vec.push_back( makeAny( prop ) );
 160
 161             OUStringBuffer buf( table.getLength() + schema.getLength() + 1);
 162             buf.append( schema ).appendAscii( "." ).append( table );
 163             map[ buf.makeStringAndClear() ] = viewIndex;
 164             viewIndex ++;
 165
 166         }
 167         m_values = Sequence< com::sun::star::uno::Any > ( &vec[0], vec.size() );
 168         m_name2index.swap( map );
 169     }
 170     catch ( com::sun::star::sdbc::SQLException & e )
 171     {
 172         throw RuntimeException( e.Message , e.Context );
 173     }
 174     fire( RefreshedBroadcaster( *this ) );
 175 }
 176
 177
 178 void Views::appendByDescriptor(
 179     const ::com::sun::star::uno::Reference< ::com::sun::star::beans::XPropertySet >& descriptor )
 180     throw (::com::sun::star::sdbc::SQLException,
 181            ::com::sun::star::container::ElementExistException,
 182            ::com::sun::star::uno::RuntimeException)
 183 {
 184     osl::MutexGuard guard( m_refMutex->mutex );
 185
 186     Statics &st = getStatics();
 187     OUString name,schema,command;
 188     descriptor->getPropertyValue( st.SCHEMA_NAME ) >>= schema;
 189     descriptor->getPropertyValue( st.NAME ) >>= name;
 190     descriptor->getPropertyValue( st.COMMAND ) >>= command;
 191
 192     Reference< XStatement > stmt = m_origin->createStatement();
 193
 194     OUStringBuffer buf( 128 );
 195
 196     buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( "CREATE VIEW " ) );
 197     bufferQuoteQualifiedIdentifier( buf, schema, name );
 198     buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( " AS " ) );
 199     buf.append( command );
 200
 201     stmt->executeUpdate( buf.makeStringAndClear() );
 202
 203     disposeNoThrow( stmt );
 204     refresh();
 205     if( m_pSettings->tables.is() )
 206     {
 207         m_pSettings->pTablesImpl->refresh();
 208     }
 209     // increase the vector
 210 //     sal_Int32 index = m_values.getLength();
 211 //     m_values.realloc( index + 1 );
 212
 213 //     View * pView =
 214 //         new View( m_refMutex, m_origin, m_pSettings, false /*modifiable*/ );
 215 //     Reference< com::sun::star::beans::XPropertySet > prop = pTable;
 216 //     copyProperties( pTable, descriptor );
 217 //     m_values[index] = makeAny( prop );
 218 //     OUStringBuffer buf( name.getLength() + 1 + schema.getLength() );
 219 //     buf.append( schema ).appendAscii( "." ).append( name );
 220 //     m_name2index[ buf.makeStringAndClear() ] = index;
 221 }
 222
 223 void Views::dropByName( const ::rtl::OUString& elementName )
 224     throw (::com::sun::star::sdbc::SQLException,
 225            ::com::sun::star::container::NoSuchElementException,
 226            ::com::sun::star::uno::RuntimeException)
 227 {
 228     String2IntMap::const_iterator ii = m_name2index.find( elementName );
 229     if( ii == m_name2index.end() )
 230     {
 231         OUStringBuffer buf( 128 );
 232         buf.appendAscii( "View " );
 233         buf.append( elementName );
 234         buf.appendAscii( " is unknown, so it can't be dropped" );
 235         throw com::sun::star::container::NoSuchElementException(
 236             buf.makeStringAndClear(), *this );
 237     }
 238     dropByIndex( ii->second );
 239 }
 240
 241 void Views::dropByIndex( sal_Int32 index )
 242     throw (::com::sun::star::sdbc::SQLException,
 243            ::com::sun::star::lang::IndexOutOfBoundsException,
 244            ::com::sun::star::uno::RuntimeException)
 245 {
 246 //     throw SQLException(
 247 //         ASCII_STR( "view deletion not supported" ), *this, OUString(), 1, Any() );
 248     osl::MutexGuard guard( m_refMutex->mutex );
 249     if( index < 0 ||  index >= m_values.getLength() )
 250     {
 251         OUStringBuffer buf( 128 );
 252         buf.appendAscii( "VIEWS: Index out of range (allowed 0 to " );
 253         buf.append( (sal_Int32) (m_values.getLength() -1) );
 254         buf.appendAscii( ", got " );
 255         buf.append( index );
 256         buf.appendAscii( ")" );
 257         throw com::sun::star::lang::IndexOutOfBoundsException(
 258             buf.makeStringAndClear(), *this );
 259     }
 260
 261     Reference< XPropertySet > set;
 262     m_values[index] >>= set;
 263     Statics &st = getStatics();
 264     OUString name,schema;
 265     set->getPropertyValue( st.SCHEMA_NAME ) >>= schema;
 266     set->getPropertyValue( st.NAME ) >>= name;
 267
 268     OUStringBuffer update( 128 );
 269     update.appendAscii( "DROP VIEW \"" ).append( schema ).appendAscii( "\".\"" );
 270     update.append( name ).appendAscii( "\"" );
 271
 272     Reference< XStatement > stmt = m_origin->createStatement( );
 273
 274     stmt->executeUpdate( update.makeStringAndClear() );
 275 }
 276
 277
 278 ::com::sun::star::uno::Reference< ::com::sun::star::beans::XPropertySet > Views::createDataDescriptor()
 279         throw (::com::sun::star::uno::RuntimeException)
 280 {
 281     return new ViewDescriptor( m_refMutex, m_origin, m_pSettings );
 282 }
 283
 284 Reference< com::sun::star::container::XNameAccess > Views::create(
 285     const ::rtl::Reference< RefCountedMutex > & refMutex,
 286     const ::com::sun::star::uno::Reference< com::sun::star::sdbc::XConnection >  & origin,
 287     ConnectionSettings *pSettings,
 288     Views **ppViews)
 289 {
 290     *ppViews = new Views( refMutex, origin, pSettings );
 291     Reference< com::sun::star::container::XNameAccess > ret = *ppViews;
 292     (*ppViews)->refresh();
 293
 294     return ret;
 295 }
 296
 297 void Views::disposing()
 298 {
 299     Container::disposing();
 300 }
 301
 302
 303
 304 };