/* -*- 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: * * This Source Code Form is subject to the terms of the Mozilla Public * License, v. 2.0. If a copy of the MPL was not distributed with this * file, You can obtain one at http://mozilla.org/MPL/2.0/. * ************************************************************************/ #include #include #include #include #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 com::sun::star::beans::XPropertySet; using com::sun::star::uno::Any; using com::sun::star::uno::UNO_QUERY; using com::sun::star::uno::Reference; using com::sun::star::container::NoSuchElementException; using com::sun::star::sdbc::XRow; using com::sun::star::sdbc::XStatement; using com::sun::star::sdbc::XResultSet; namespace pq_sdbc_driver { Views::Views( const ::rtl::Reference< comphelper::RefCountedMutex > & refMutex, const css::uno::Reference< css::sdbc::XConnection > & origin, ConnectionSettings *pSettings ) : Container( refMutex, origin, pSettings, getStatics().VIEW ) {} Views::~Views() {} void Views::refresh() { try { osl::MutexGuard guard( m_xMutex->GetMutex() ); Statics & st = getStatics(); Reference< XStatement > stmt = m_origin->createStatement(); Reference< XResultSet > rs = stmt->executeQuery("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.clear(); String2IntMap map; sal_Int32 viewIndex = 0; while( rs->next() ) { OUString table, schema, command; schema = xRow->getString( 1 ); table = xRow->getString( 2 ); command = xRow->getString( 3 ); rtl::Reference pView = new View (m_xMutex, m_origin, m_pSettings ); Reference< css::beans::XPropertySet > prop = pView; pView->setPropertyValue_NoBroadcast_public(st.NAME , Any(table) ); pView->setPropertyValue_NoBroadcast_public(st.SCHEMA_NAME, Any(schema) ); pView->setPropertyValue_NoBroadcast_public(st.COMMAND, Any(command) ); { m_values.push_back( Any( prop ) ); map[ schema + "." + table ] = viewIndex; ++viewIndex; } } m_name2index.swap( map ); } catch ( css::sdbc::SQLException & e ) { css::uno::Any anyEx = cppu::getCaughtException(); throw css::lang::WrappedTargetRuntimeException( e.Message, e.Context, anyEx ); } fire( RefreshedBroadcaster( *this ) ); } void Views::appendByDescriptor( const css::uno::Reference< css::beans::XPropertySet >& descriptor ) { osl::MutexGuard guard( m_xMutex->GetMutex() ); 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.append( "CREATE VIEW "); bufferQuoteQualifiedIdentifier( buf, schema, name, m_pSettings ); buf.append(" AS " + command ); stmt->executeUpdate( buf.makeStringAndClear() ); disposeNoThrow( stmt ); refresh(); if( m_pSettings->tables.is() ) { m_pSettings->pTablesImpl->refresh(); } } void Views::dropByName( const OUString& elementName ) { String2IntMap::const_iterator ii = m_name2index.find( elementName ); if( ii == m_name2index.end() ) { throw css::container::NoSuchElementException( "View " + elementName + " is unknown, so it can't be dropped", *this ); } dropByIndex( ii->second ); } void Views::dropByIndex( sal_Int32 index ) { osl::MutexGuard guard( m_xMutex->GetMutex() ); if( index < 0 || o3tl::make_unsigned(index) >= m_values.size() ) { throw css::lang::IndexOutOfBoundsException( "VIEWS: Index out of range (allowed 0 to " + OUString::number(m_values.size() -1) + ", got " + OUString::number( index ) + ")", *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; Reference< XStatement > stmt = m_origin->createStatement( ); stmt->executeUpdate( "DROP VIEW \"" + schema + "\".\"" + name + "\"" ); } css::uno::Reference< css::beans::XPropertySet > Views::createDataDescriptor() { return new ViewDescriptor( m_xMutex, m_origin, m_pSettings ); } Reference< css::container::XNameAccess > Views::create( const ::rtl::Reference< comphelper::RefCountedMutex > & refMutex, const css::uno::Reference< css::sdbc::XConnection > & origin, ConnectionSettings *pSettings, rtl::Reference *ppViews) { *ppViews = new Views( refMutex, origin, pSettings ); (*ppViews)->refresh(); return *ppViews; } }; /* vim:set shiftwidth=4 softtabstop=4 expandtab: */