/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ /************************************************************************* * * Effective License of whole file: * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Lesser General Public * License version 2.1, as published by the Free Software Foundation. * * This library is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * Lesser General Public License for more details. * * You should have received a copy of the GNU Lesser General Public * License along with this library; if not, write to the Free Software * Foundation, Inc., 59 Temple Place, Suite 330, Boston, * MA 02111-1307 USA * * Parts "Copyright by Sun Microsystems, Inc" prior to August 2011: * * The Contents of this file are made available subject to the terms of * the GNU Lesser General Public License Version 2.1 * * Copyright: 2000 by Sun Microsystems, Inc. * * Contributor(s): Joerg Budischewski * * All parts contributed on or after August 2011: * * Version: MPL 1.1 / GPLv3+ / LGPLv2.1+ * * The contents of this file are subject to the Mozilla Public License Version * 1.1 (the "License"); you may not use this file except in compliance with * the License or as specified alternatively below. You may obtain a copy of * the License at http://www.mozilla.org/MPL/ * * Software distributed under the License is distributed on an "AS IS" basis, * WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License * for the specific language governing rights and limitations under the * License. * * Major Contributor(s): * [ Copyright (C) 2011 Lionel Elie Mamane ] * * All Rights Reserved. * * For minor contributions see the git repository. * * Alternatively, the contents of this file may be used under the terms of * either the GNU General Public License Version 3 or later (the "GPLv3+"), or * the GNU Lesser General Public License Version 2.1 or later (the "LGPLv2.1+"), * in which case the provisions of the GPLv3+ or the LGPLv2.1+ are applicable * instead of those above. * ************************************************************************/ #include #include #include #include #include "pq_xviews.hxx" #include "pq_xview.hxx" #include "pq_xtables.hxx" #include "pq_statics.hxx" #include "pq_tools.hxx" using osl::MutexGuard; using rtl::OUString; using rtl::OUStringBuffer; using rtl::OUStringToOString; using com::sun::star::beans::XPropertySet; using com::sun::star::uno::Any; using com::sun::star::uno::makeAny; using com::sun::star::uno::UNO_QUERY; using com::sun::star::uno::Type; using com::sun::star::uno::XInterface; using com::sun::star::uno::Reference; using com::sun::star::uno::Sequence; using com::sun::star::uno::RuntimeException; using com::sun::star::container::NoSuchElementException; using com::sun::star::lang::WrappedTargetException; using com::sun::star::sdbc::XRow; using com::sun::star::sdbc::XCloseable; using com::sun::star::sdbc::XStatement; using com::sun::star::sdbc::XResultSet; using com::sun::star::sdbc::XParameters; using com::sun::star::sdbc::XPreparedStatement; using com::sun::star::sdbc::XDatabaseMetaData; // using com::sun::star::sdbcx::Privilege; namespace pq_sdbc_driver { #define ASCII_STR(x) OUString( RTL_CONSTASCII_USTRINGPARAM( x ) ) Views::Views( const ::rtl::Reference< RefCountedMutex > & refMutex, const ::com::sun::star::uno::Reference< com::sun::star::sdbc::XConnection > & origin, ConnectionSettings *pSettings ) : Container( refMutex, origin, pSettings, getStatics().VIEW ) {} Views::~Views() {} void Views::refresh() throw (::com::sun::star::uno::RuntimeException) { try { osl::MutexGuard guard( m_refMutex->mutex ); Statics & st = getStatics(); Reference< XStatement > stmt = m_origin->createStatement(); Reference< XResultSet > rs = stmt->executeQuery( ASCII_STR( "SELECT " "DISTINCT ON( pg_namespace.nspname, relname) " // needed because of duplicates "pg_namespace.nspname," // 1 "relname," // 2 "pg_get_viewdef(ev_class) " // 3 "FROM pg_namespace, pg_class, pg_rewrite " "WHERE pg_namespace.oid = relnamespace " "AND pg_class.oid = ev_class " "AND relkind='v'" ) ); Reference< XRow > xRow( rs , UNO_QUERY ); m_values = Sequence< com::sun::star::uno::Any > (); String2IntMap map; sal_Int32 viewIndex = 0; while( rs->next() ) { rtl::OUString table, schema, command; schema = xRow->getString( 1 ); table = xRow->getString( 2 ); command = xRow->getString( 3 ); View *pView = new View (m_refMutex, m_origin, m_pSettings ); Reference< com::sun::star::beans::XPropertySet > prop = pView; pView->setPropertyValue_NoBroadcast_public(st.NAME , makeAny(table) ); pView->setPropertyValue_NoBroadcast_public(st.SCHEMA_NAME, makeAny(schema) ); pView->setPropertyValue_NoBroadcast_public(st.COMMAND, makeAny(command) ); { const int currentViewIndex = viewIndex++; assert(currentViewIndex == m_values.getLength()); m_values.realloc( viewIndex ); m_values[currentViewIndex] = makeAny( prop ); OUStringBuffer buf( table.getLength() + schema.getLength() + 1); buf.append( schema ).appendAscii( "." ).append( table ); map[ buf.makeStringAndClear() ] = currentViewIndex; } } m_name2index.swap( map ); } catch ( com::sun::star::sdbc::SQLException & e ) { throw RuntimeException( e.Message , e.Context ); } fire( RefreshedBroadcaster( *this ) ); } void Views::appendByDescriptor( const ::com::sun::star::uno::Reference< ::com::sun::star::beans::XPropertySet >& descriptor ) throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::container::ElementExistException, ::com::sun::star::uno::RuntimeException) { osl::MutexGuard guard( m_refMutex->mutex ); Statics &st = getStatics(); OUString name,schema,command; descriptor->getPropertyValue( st.SCHEMA_NAME ) >>= schema; descriptor->getPropertyValue( st.NAME ) >>= name; descriptor->getPropertyValue( st.COMMAND ) >>= command; Reference< XStatement > stmt = m_origin->createStatement(); OUStringBuffer buf( 128 ); buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( "CREATE VIEW " ) ); bufferQuoteQualifiedIdentifier( buf, schema, name, m_pSettings ); buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( " AS " ) ); buf.append( command ); stmt->executeUpdate( buf.makeStringAndClear() ); disposeNoThrow( stmt ); refresh(); if( m_pSettings->tables.is() ) { m_pSettings->pTablesImpl->refresh(); } // increase the vector // sal_Int32 index = m_values.getLength(); // m_values.realloc( index + 1 ); // View * pView = // new View( m_refMutex, m_origin, m_pSettings, false /*modifiable*/ ); // Reference< com::sun::star::beans::XPropertySet > prop = pTable; // copyProperties( pTable, descriptor ); // m_values[index] = makeAny( prop ); // OUStringBuffer buf( name.getLength() + 1 + schema.getLength() ); // buf.append( schema ).appendAscii( "." ).append( name ); // m_name2index[ buf.makeStringAndClear() ] = index; } void Views::dropByName( const ::rtl::OUString& elementName ) throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::container::NoSuchElementException, ::com::sun::star::uno::RuntimeException) { String2IntMap::const_iterator ii = m_name2index.find( elementName ); if( ii == m_name2index.end() ) { OUStringBuffer buf( 128 ); buf.appendAscii( "View " ); buf.append( elementName ); buf.appendAscii( " is unknown, so it can't be dropped" ); throw com::sun::star::container::NoSuchElementException( buf.makeStringAndClear(), *this ); } dropByIndex( ii->second ); } void Views::dropByIndex( sal_Int32 index ) throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::lang::IndexOutOfBoundsException, ::com::sun::star::uno::RuntimeException) { // throw SQLException( // ASCII_STR( "view deletion not supported" ), *this, OUString(), 1, Any() ); osl::MutexGuard guard( m_refMutex->mutex ); if( index < 0 || index >= m_values.getLength() ) { OUStringBuffer buf( 128 ); buf.appendAscii( "VIEWS: Index out of range (allowed 0 to " ); buf.append( (sal_Int32) (m_values.getLength() -1) ); buf.appendAscii( ", got " ); buf.append( index ); buf.appendAscii( ")" ); throw com::sun::star::lang::IndexOutOfBoundsException( buf.makeStringAndClear(), *this ); } Reference< XPropertySet > set; m_values[index] >>= set; Statics &st = getStatics(); OUString name,schema; set->getPropertyValue( st.SCHEMA_NAME ) >>= schema; set->getPropertyValue( st.NAME ) >>= name; OUStringBuffer update( 128 ); update.appendAscii( "DROP VIEW \"" ).append( schema ).appendAscii( "\".\"" ); update.append( name ).appendAscii( "\"" ); Reference< XStatement > stmt = m_origin->createStatement( ); stmt->executeUpdate( update.makeStringAndClear() ); } ::com::sun::star::uno::Reference< ::com::sun::star::beans::XPropertySet > Views::createDataDescriptor() throw (::com::sun::star::uno::RuntimeException) { return new ViewDescriptor( m_refMutex, m_origin, m_pSettings ); } Reference< com::sun::star::container::XNameAccess > Views::create( const ::rtl::Reference< RefCountedMutex > & refMutex, const ::com::sun::star::uno::Reference< com::sun::star::sdbc::XConnection > & origin, ConnectionSettings *pSettings, Views **ppViews) { *ppViews = new Views( refMutex, origin, pSettings ); Reference< com::sun::star::container::XNameAccess > ret = *ppViews; (*ppViews)->refresh(); return ret; } void Views::disposing() { Container::disposing(); } };