diff options
Diffstat (limited to 'dbaccess/source/core/dataaccess/databasecontext.cxx')
| -rw-r--r-- | dbaccess/source/core/dataaccess/databasecontext.cxx | 765 |
1 files changed, 0 insertions, 765 deletions
diff --git a/dbaccess/source/core/dataaccess/databasecontext.cxx b/dbaccess/source/core/dataaccess/databasecontext.cxx deleted file mode 100644 index f0ba9e6c6..000000000 --- a/dbaccess/source/core/dataaccess/databasecontext.cxx +++ /dev/null @@ -1,765 +0,0 @@ -/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ -/************************************************************************* - * - * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. - * - * Copyright 2000, 2010 Oracle and/or its affiliates. - * - * OpenOffice.org - a multi-platform office productivity suite - * - * This file is part of OpenOffice.org. - * - * OpenOffice.org is free software: you can redistribute it and/or modify - * it under the terms of the GNU Lesser General Public License version 3 - * only, as published by the Free Software Foundation. - * - * OpenOffice.org 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 version 3 for more details - * (a copy is included in the LICENSE file that accompanied this code). - * - * You should have received a copy of the GNU Lesser General Public License - * version 3 along with OpenOffice.org. If not, see - * <http://www.openoffice.org/license.html> - * for a copy of the LGPLv3 License. - * - ************************************************************************/ - -// MARKER(update_precomp.py): autogen include statement, do not remove -#include "precompiled_dbaccess.hxx" - -#include "apitools.hxx" -#include "core_resource.hrc" -#include "core_resource.hxx" -#include "databasecontext.hxx" -#include "databasedocument.hxx" -#include "databaseregistrations.hxx" -#include "datasource.hxx" -#include "dbastrings.hrc" -#include "module_dba.hxx" - -/** === being UNO includes === **/ -#include <com/sun/star/beans/NamedValue.hpp> -#include <com/sun/star/beans/PropertyAttribute.hpp> -#include <com/sun/star/beans/XPropertySet.hpp> -#include <com/sun/star/document/MacroExecMode.hpp> -#include <com/sun/star/document/XFilter.hpp> -#include <com/sun/star/document/XImporter.hpp> -#include <com/sun/star/frame/XDesktop.hpp> -#include <com/sun/star/frame/XModel.hpp> -#include <com/sun/star/frame/XModel2.hpp> -#include <com/sun/star/frame/XTerminateListener.hpp> -#include <com/sun/star/lang/DisposedException.hpp> -#include <com/sun/star/registry/InvalidRegistryException.hpp> -#include <com/sun/star/sdbc/XDataSource.hpp> -#include <com/sun/star/task/InteractionClassification.hpp> -#include <com/sun/star/ucb/InteractiveIOException.hpp> -#include <com/sun/star/ucb/IOErrorCode.hpp> -#include <com/sun/star/util/XCloseable.hpp> -/** === end UNO includes === **/ - -#include <basic/basmgr.hxx> -#include <comphelper/enumhelper.hxx> -#include <comphelper/evtlistenerhlp.hxx> -#include <comphelper/namedvaluecollection.hxx> -#include <comphelper/processfactory.hxx> -#include <comphelper/sequence.hxx> -#include <cppuhelper/implbase1.hxx> -#include <cppuhelper/typeprovider.hxx> -#include <cppuhelper/exc_hlp.hxx> -#include <svl/filenotation.hxx> -#include <tools/debug.hxx> -#include <tools/diagnose_ex.h> -#include <tools/fsys.hxx> -#include <tools/urlobj.hxx> -#include <ucbhelper/content.hxx> -#include <unotools/confignode.hxx> -#include <unotools/pathoptions.hxx> -#include <unotools/sharedunocomponent.hxx> -#include <list> -#include <boost/bind.hpp> - -using namespace ::com::sun::star::sdbc; -using namespace ::com::sun::star::sdb; -using namespace ::com::sun::star::beans; -using namespace ::com::sun::star::uno; -using namespace ::com::sun::star::document; -using namespace ::com::sun::star::frame; -using namespace ::com::sun::star::lang; -using namespace ::com::sun::star::container; -using namespace ::com::sun::star::util; -using namespace ::com::sun::star::registry; -using namespace ::com::sun::star; -using namespace ::cppu; -using namespace ::osl; -using namespace ::utl; - -using ::com::sun::star::task::InteractionClassification_ERROR; -using ::com::sun::star::ucb::IOErrorCode_NO_FILE; -using ::com::sun::star::ucb::InteractiveIOException; -using ::com::sun::star::ucb::IOErrorCode_NOT_EXISTING; -using ::com::sun::star::ucb::IOErrorCode_NOT_EXISTING_PATH; - - -namespace dbaccess -{ - - typedef ::cppu::WeakImplHelper1 < XTerminateListener - > DatabaseDocumentLoader_Base; - class DatabaseDocumentLoader : public DatabaseDocumentLoader_Base - { - private: - Reference< XDesktop > m_xDesktop; - ::std::list< const ODatabaseModelImpl* > m_aDatabaseDocuments; - - public: - DatabaseDocumentLoader( const comphelper::ComponentContext& _aContext); - - inline void append(const ODatabaseModelImpl& _rModelImpl ) - { - m_aDatabaseDocuments.push_back(&_rModelImpl); - } - inline void remove(const ODatabaseModelImpl& _rModelImpl) { m_aDatabaseDocuments.remove(&_rModelImpl); } - - private: - // XTerminateListener - virtual void SAL_CALL queryTermination( const lang::EventObject& Event ) throw (TerminationVetoException, RuntimeException); - virtual void SAL_CALL notifyTermination( const lang::EventObject& Event ) throw (RuntimeException); - // XEventListener - virtual void SAL_CALL disposing( const ::com::sun::star::lang::EventObject& Source ) throw (::com::sun::star::uno::RuntimeException); - }; - - DatabaseDocumentLoader::DatabaseDocumentLoader( const comphelper::ComponentContext& _aContext ) - { - acquire(); - try - { - m_xDesktop.set( _aContext.createComponent( (rtl::OUString)SERVICE_FRAME_DESKTOP ), UNO_QUERY_THROW ); - m_xDesktop->addTerminateListener( this ); - } - catch( const Exception& ) - { - DBG_UNHANDLED_EXCEPTION(); - } - } - - struct TerminateFunctor : ::std::unary_function<ODatabaseModelImpl* , void> - { - void operator()( const ODatabaseModelImpl* _pModelImpl ) const - { - try - { - const Reference< XModel2> xModel( _pModelImpl ->getModel_noCreate(),UNO_QUERY_THROW ); - if ( !xModel->getControllers()->hasMoreElements() ) - { - Reference<util::XCloseable> xCloseable(xModel,UNO_QUERY_THROW); - xCloseable->close(sal_False); - } - } - catch(const CloseVetoException&) - { - throw TerminationVetoException(); - } - } - }; - - void SAL_CALL DatabaseDocumentLoader::queryTermination( const lang::EventObject& /*Event*/ ) throw (TerminationVetoException, RuntimeException) - { - ::std::list< const ODatabaseModelImpl* > aCopy(m_aDatabaseDocuments); - ::std::for_each(aCopy.begin(),aCopy.end(),TerminateFunctor()); - } - - void SAL_CALL DatabaseDocumentLoader::notifyTermination( const lang::EventObject& /*Event*/ ) throw (RuntimeException) - { - } - - void SAL_CALL DatabaseDocumentLoader::disposing( const lang::EventObject& /*Source*/ ) throw (RuntimeException) - { - } - -//= ODatabaseContext -//========================================================================== - -ODatabaseContext::ODatabaseContext( const Reference< XComponentContext >& _rxContext ) - :DatabaseAccessContext_Base(m_aMutex) - ,m_aContext( _rxContext ) - ,m_aContainerListeners(m_aMutex) -{ - m_pDatabaseDocumentLoader = new DatabaseDocumentLoader( m_aContext ); - ::basic::BasicManagerRepository::registerCreationListener( *this ); - - osl_incrementInterlockedCount( &m_refCount ); - { - m_xDBRegistrationAggregate.set( createDataSourceRegistrations( m_aContext ), UNO_SET_THROW ); - m_xDatabaseRegistrations.set( m_xDBRegistrationAggregate, UNO_QUERY_THROW ); - - m_xDBRegistrationAggregate->setDelegator( *this ); - } - osl_decrementInterlockedCount( &m_refCount ); -} - -ODatabaseContext::~ODatabaseContext() -{ - ::basic::BasicManagerRepository::revokeCreationListener( *this ); - if ( m_pDatabaseDocumentLoader ) - m_pDatabaseDocumentLoader->release(); - - m_xDBRegistrationAggregate->setDelegator( NULL ); - m_xDBRegistrationAggregate.clear(); - m_xDatabaseRegistrations.clear(); -} - -// Helper -rtl::OUString ODatabaseContext::getImplementationName_static() throw( RuntimeException ) - -{ - return ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("com.sun.star.comp.dba.ODatabaseContext")); -} - -Reference< XInterface > ODatabaseContext::Create(const Reference< XComponentContext >& _rxContext) -{ - return *( new ODatabaseContext( _rxContext ) ); -} - -Sequence< rtl::OUString > ODatabaseContext::getSupportedServiceNames_static(void) throw( RuntimeException ) -{ - Sequence< ::rtl::OUString > aSNS( 1 ); - aSNS[0] = SERVICE_SDB_DATABASECONTEXT; - return aSNS; -} - -// XServiceInfo -rtl::OUString ODatabaseContext::getImplementationName( ) throw(RuntimeException) -{ - return getImplementationName_static(); -} - -sal_Bool ODatabaseContext::supportsService( const ::rtl::OUString& _rServiceName ) throw (RuntimeException) -{ - return ::comphelper::findValue(getSupportedServiceNames(), _rServiceName, sal_True).getLength() != 0; -} - -Sequence< ::rtl::OUString > ODatabaseContext::getSupportedServiceNames( ) throw (RuntimeException) -{ - return getSupportedServiceNames_static(); -} - -Reference< XInterface > ODatabaseContext::impl_createNewDataSource() -{ - ::rtl::Reference<ODatabaseModelImpl> pImpl( new ODatabaseModelImpl( m_aContext.getLegacyServiceFactory(), *this ) ); - Reference< XDataSource > xDataSource( pImpl->getOrCreateDataSource() ); - - return xDataSource.get(); -} - -Reference< XInterface > SAL_CALL ODatabaseContext::createInstance( ) throw (Exception, RuntimeException) -{ - // for convenience of the API user, we ensure the document is fully initialized (effectively: XLoadable::initNew - // has been called at the DatabaseDocument). - return impl_createNewDataSource(); -} - -Reference< XInterface > SAL_CALL ODatabaseContext::createInstanceWithArguments( const Sequence< Any >& _rArguments ) throw (Exception, RuntimeException) -{ - ::comphelper::NamedValueCollection aArgs( _rArguments ); - ::rtl::OUString sURL = aArgs.getOrDefault( (::rtl::OUString)INFO_POOLURL, ::rtl::OUString() ); - - Reference< XInterface > xDataSource; - if ( sURL.getLength() ) - xDataSource = getObject( sURL ); - - if ( !xDataSource.is() ) - xDataSource = impl_createNewDataSource(); - - return xDataSource; -} - -// DatabaseAccessContext_Base -void ODatabaseContext::disposing() -{ - // notify our listener - com::sun::star::lang::EventObject aDisposeEvent(static_cast< XContainer* >(this)); - m_aContainerListeners.disposeAndClear(aDisposeEvent); - - // dispose the data sources - ObjectCache::iterator aEnd = m_aDatabaseObjects.end(); - for ( ObjectCache::iterator aIter = m_aDatabaseObjects.begin(); - aIter != aEnd; - ++aIter - ) - { - aIter->second->dispose(); - } - m_aDatabaseObjects.clear(); -} - -// XNamingService -Reference< XInterface > ODatabaseContext::getRegisteredObject(const rtl::OUString& _rName) throw( Exception, RuntimeException ) -{ - MutexGuard aGuard(m_aMutex); - ::connectivity::checkDisposed(DatabaseAccessContext_Base::rBHelper.bDisposed); - - ::rtl::OUString sURL( getDatabaseLocation( _rName ) ); - - if ( !sURL.getLength() ) - // there is a registration for this name, but no URL - throw IllegalArgumentException(); - - // check if URL is already loaded - Reference< XInterface > xExistent = getObject( sURL ); - if ( xExistent.is() ) - return xExistent; - - return loadObjectFromURL( _rName, sURL ); -} - -Reference< XInterface > ODatabaseContext::loadObjectFromURL(const ::rtl::OUString& _rName,const ::rtl::OUString& _sURL) -{ - INetURLObject aURL( _sURL ); - if ( aURL.GetProtocol() == INET_PROT_NOT_VALID ) - throw NoSuchElementException( _rName, *this ); - - try - { - ::ucbhelper::Content aContent( _sURL, NULL ); - if ( !aContent.isDocument() ) - throw InteractiveIOException( - _sURL, *this, InteractionClassification_ERROR, IOErrorCode_NO_FILE - ); - } - catch ( const InteractiveIOException& e ) - { - if ( ( e.Code == IOErrorCode_NO_FILE ) - || ( e.Code == IOErrorCode_NOT_EXISTING ) - || ( e.Code == IOErrorCode_NOT_EXISTING_PATH ) - ) - { - // #i40463# #i39187# - String sErrorMessage( DBACORE_RESSTRING( RID_STR_FILE_DOES_NOT_EXIST ) ); - ::svt::OFileNotation aTransformer( _sURL ); - sErrorMessage.SearchAndReplaceAscii( "$file$", aTransformer.get( ::svt::OFileNotation::N_SYSTEM ) ); - - SQLException aError; - aError.Message = sErrorMessage; - - throw WrappedTargetException( _sURL, *this, makeAny( aError ) ); - } - throw WrappedTargetException( _sURL, *this, ::cppu::getCaughtException() ); - } - catch( const Exception& ) - { - throw WrappedTargetException( _sURL, *this, ::cppu::getCaughtException() ); - } - - OSL_ENSURE( m_aDatabaseObjects.find( _sURL ) == m_aDatabaseObjects.end(), - "ODatabaseContext::loadObjectFromURL: not intended for already-cached objects!" ); - - ::rtl::Reference< ODatabaseModelImpl > pModelImpl; - { - pModelImpl.set( new ODatabaseModelImpl( _rName, m_aContext.getLegacyServiceFactory(), *this ) ); - - Reference< XModel > xModel( pModelImpl->createNewModel_deliverOwnership( false ), UNO_SET_THROW ); - Reference< XLoadable > xLoad( xModel, UNO_QUERY_THROW ); - - ::comphelper::NamedValueCollection aArgs; - aArgs.put( "URL", _sURL ); - aArgs.put( "MacroExecutionMode", MacroExecMode::USE_CONFIG ); - aArgs.put( "InteractionHandler", m_aContext.createComponent( "com.sun.star.task.InteractionHandler" ) ); - - Sequence< PropertyValue > aResource( aArgs.getPropertyValues() ); - xLoad->load( aResource ); - xModel->attachResource( _sURL, aResource ); - - ::utl::CloseableComponent aEnsureClose( xModel ); - } - - setTransientProperties( _sURL, *pModelImpl ); - - return pModelImpl->getOrCreateDataSource().get(); -} - -void ODatabaseContext::appendAtTerminateListener(const ODatabaseModelImpl& _rDataSourceModel) -{ - m_pDatabaseDocumentLoader->append(_rDataSourceModel); -} - -void ODatabaseContext::removeFromTerminateListener(const ODatabaseModelImpl& _rDataSourceModel) -{ - m_pDatabaseDocumentLoader->remove(_rDataSourceModel); -} - -void ODatabaseContext::setTransientProperties(const ::rtl::OUString& _sURL, ODatabaseModelImpl& _rDataSourceModel ) -{ - if ( m_aDatasourceProperties.end() == m_aDatasourceProperties.find(_sURL) ) - return; - try - { - ::rtl::OUString sAuthFailedPassword; - Reference< XPropertySet > xDSProps( _rDataSourceModel.getOrCreateDataSource(), UNO_QUERY_THROW ); - const Sequence< PropertyValue >& rSessionPersistentProps = m_aDatasourceProperties[_sURL]; - const PropertyValue* pProp = rSessionPersistentProps.getConstArray(); - const PropertyValue* pPropsEnd = rSessionPersistentProps.getConstArray() + rSessionPersistentProps.getLength(); - for ( ; pProp != pPropsEnd; ++pProp ) - { - if ( pProp->Name.equalsAsciiL( RTL_CONSTASCII_STRINGPARAM( "AuthFailedPassword" ) ) ) - { - OSL_VERIFY( pProp->Value >>= sAuthFailedPassword ); - } - else - { - xDSProps->setPropertyValue( pProp->Name, pProp->Value ); - } - } - - _rDataSourceModel.m_sFailedPassword = sAuthFailedPassword; - } - catch( const Exception& ) - { - DBG_UNHANDLED_EXCEPTION(); - } -} - -void ODatabaseContext::registerObject(const rtl::OUString& _rName, const Reference< XInterface > & _rxObject) throw( Exception, RuntimeException ) -{ - MutexGuard aGuard(m_aMutex); - ::connectivity::checkDisposed(DatabaseAccessContext_Base::rBHelper.bDisposed); - - if ( !_rName.getLength() ) - throw IllegalArgumentException( ::rtl::OUString(), *this, 1 ); - - Reference< XDocumentDataSource > xDocDataSource( _rxObject, UNO_QUERY ); - Reference< XModel > xModel( xDocDataSource.is() ? xDocDataSource->getDatabaseDocument() : Reference< XOfficeDatabaseDocument >(), UNO_QUERY ); - if ( !xModel.is() ) - throw IllegalArgumentException( ::rtl::OUString(), *this, 2 ); - - ::rtl::OUString sURL = xModel->getURL(); - if ( !sURL.getLength() ) - throw IllegalArgumentException( DBACORE_RESSTRING( RID_STR_DATASOURCE_NOT_STORED ), *this, 2 ); - - registerDatabaseLocation( _rName, sURL ); - - ODatabaseSource::setName( xDocDataSource, _rName, ODatabaseSource::DBContextAccess() ); - - // notify our container listeners - ContainerEvent aEvent(static_cast<XContainer*>(this), makeAny(_rName), makeAny(_rxObject), Any()); - m_aContainerListeners.notifyEach( &XContainerListener::elementInserted, aEvent ); -} - -void ODatabaseContext::storeTransientProperties( ODatabaseModelImpl& _rModelImpl) -{ - Reference< XPropertySet > xSource( _rModelImpl.getOrCreateDataSource(), UNO_QUERY ); - ::comphelper::NamedValueCollection aRememberProps; - - try - { - // get the info about the properties, check which ones are transient and not readonly - Reference< XPropertySetInfo > xSetInfo; - if (xSource.is()) - xSetInfo = xSource->getPropertySetInfo(); - Sequence< Property > aProperties; - if (xSetInfo.is()) - aProperties = xSetInfo->getProperties(); - - if (aProperties.getLength()) - { - const Property* pProperties = aProperties.getConstArray(); - for ( sal_Int32 i=0; i<aProperties.getLength(); ++i, ++pProperties ) - { - if ( ( ( pProperties->Attributes & PropertyAttribute::TRANSIENT) != 0 ) - && ( ( pProperties->Attributes & PropertyAttribute::READONLY) == 0 ) - ) - { - // found such a property - aRememberProps.put( pProperties->Name, xSource->getPropertyValue( pProperties->Name ) ); - } - } - } - } - catch ( const Exception& ) - { - DBG_UNHANDLED_EXCEPTION(); - } - - // additionally, remember the "failed password", which is not available as property - // #i86178# - aRememberProps.put( "AuthFailedPassword", _rModelImpl.m_sFailedPassword ); - - ::rtl::OUString sDocumentURL( _rModelImpl.getURL() ); - if ( m_aDatabaseObjects.find( sDocumentURL ) != m_aDatabaseObjects.end() ) - { - m_aDatasourceProperties[ sDocumentURL ] = aRememberProps.getPropertyValues(); - } - else if ( m_aDatabaseObjects.find( _rModelImpl.m_sName ) != m_aDatabaseObjects.end() ) - { - OSL_FAIL( "ODatabaseContext::storeTransientProperties: a database document register by name? This shouldn't happen anymore!" ); - // all the code should have been changed so that registration is by URL only - m_aDatasourceProperties[ _rModelImpl.m_sName ] = aRememberProps.getPropertyValues(); - } - else - { - OSL_ENSURE( ( sDocumentURL.getLength() == 0 ) && ( _rModelImpl.m_sName.getLength() == 0 ), - "ODatabaseContext::storeTransientProperties: a non-empty data source which I do not know?!" ); - } -} - -void SAL_CALL ODatabaseContext::addContainerListener( const Reference< XContainerListener >& _rxListener ) throw(RuntimeException) -{ - m_aContainerListeners.addInterface(_rxListener); -} - -void SAL_CALL ODatabaseContext::removeContainerListener( const Reference< XContainerListener >& _rxListener ) throw(RuntimeException) -{ - m_aContainerListeners.removeInterface(_rxListener); -} - -void ODatabaseContext::revokeObject(const rtl::OUString& _rName) throw( Exception, RuntimeException ) -{ - ClearableMutexGuard aGuard(m_aMutex); - ::connectivity::checkDisposed(DatabaseAccessContext_Base::rBHelper.bDisposed); - - ::rtl::OUString sURL = getDatabaseLocation( _rName ); - - revokeDatabaseLocation( _rName ); - // will throw if something goes wrong - - if ( m_aDatabaseObjects.find( _rName ) != m_aDatabaseObjects.end() ) - { - m_aDatasourceProperties[ sURL ] = m_aDatasourceProperties[ _rName ]; - } - - // check if URL is already loaded - ObjectCacheIterator aExistent = m_aDatabaseObjects.find( sURL ); - if ( aExistent != m_aDatabaseObjects.end() ) - m_aDatabaseObjects.erase( aExistent ); - - // notify our container listeners - ContainerEvent aEvent( *this, makeAny( _rName ), Any(), Any() ); - aGuard.clear(); - m_aContainerListeners.notifyEach( &XContainerListener::elementRemoved, aEvent ); -} - -::sal_Bool SAL_CALL ODatabaseContext::hasRegisteredDatabase( const ::rtl::OUString& _Name ) throw (IllegalArgumentException, RuntimeException) -{ - return m_xDatabaseRegistrations->hasRegisteredDatabase( _Name ); -} - -Sequence< ::rtl::OUString > SAL_CALL ODatabaseContext::getRegistrationNames() throw (RuntimeException) -{ - return m_xDatabaseRegistrations->getRegistrationNames(); -} - -::rtl::OUString SAL_CALL ODatabaseContext::getDatabaseLocation( const ::rtl::OUString& _Name ) throw (IllegalArgumentException, NoSuchElementException, RuntimeException) -{ - return m_xDatabaseRegistrations->getDatabaseLocation( _Name ); -} - -void SAL_CALL ODatabaseContext::registerDatabaseLocation( const ::rtl::OUString& _Name, const ::rtl::OUString& _Location ) throw (IllegalArgumentException, ElementExistException, RuntimeException) -{ - m_xDatabaseRegistrations->registerDatabaseLocation( _Name, _Location ); -} - -void SAL_CALL ODatabaseContext::revokeDatabaseLocation( const ::rtl::OUString& _Name ) throw (IllegalArgumentException, NoSuchElementException, IllegalAccessException, RuntimeException) -{ - m_xDatabaseRegistrations->revokeDatabaseLocation( _Name ); -} - -void SAL_CALL ODatabaseContext::changeDatabaseLocation( const ::rtl::OUString& _Name, const ::rtl::OUString& _NewLocation ) throw (IllegalArgumentException, NoSuchElementException, IllegalAccessException, RuntimeException) -{ - m_xDatabaseRegistrations->changeDatabaseLocation( _Name, _NewLocation ); -} - -::sal_Bool SAL_CALL ODatabaseContext::isDatabaseRegistrationReadOnly( const ::rtl::OUString& _Name ) throw (IllegalArgumentException, NoSuchElementException, RuntimeException) -{ - return m_xDatabaseRegistrations->isDatabaseRegistrationReadOnly( _Name ); -} - -void SAL_CALL ODatabaseContext::addDatabaseRegistrationsListener( const Reference< XDatabaseRegistrationsListener >& _Listener ) throw (RuntimeException) -{ - m_xDatabaseRegistrations->addDatabaseRegistrationsListener( _Listener ); -} - -void SAL_CALL ODatabaseContext::removeDatabaseRegistrationsListener( const Reference< XDatabaseRegistrationsListener >& _Listener ) throw (RuntimeException) -{ - m_xDatabaseRegistrations->removeDatabaseRegistrationsListener( _Listener ); -} - -// ::com::sun::star::container::XElementAccess -Type ODatabaseContext::getElementType( ) throw(RuntimeException) -{ - return::getCppuType(static_cast<Reference<XDataSource>*>(NULL)); -} - -sal_Bool ODatabaseContext::hasElements(void) throw( RuntimeException ) -{ - MutexGuard aGuard(m_aMutex); - ::connectivity::checkDisposed(DatabaseAccessContext_Base::rBHelper.bDisposed); - - return 0 != getElementNames().getLength(); -} - -// ::com::sun::star::container::XEnumerationAccess -Reference< ::com::sun::star::container::XEnumeration > ODatabaseContext::createEnumeration(void) throw( RuntimeException ) -{ - MutexGuard aGuard(m_aMutex); - return new ::comphelper::OEnumerationByName(static_cast<XNameAccess*>(this)); -} - -// ::com::sun::star::container::XNameAccess -Any ODatabaseContext::getByName(const rtl::OUString& _rName) throw( NoSuchElementException, - WrappedTargetException, RuntimeException ) -{ - MutexGuard aGuard(m_aMutex); - ::connectivity::checkDisposed(DatabaseAccessContext_Base::rBHelper.bDisposed); - if ( !_rName.getLength() ) - throw NoSuchElementException(_rName, *this); - - try - { - Reference< XInterface > xExistent = getObject( _rName ); - if ( xExistent.is() ) - return makeAny( xExistent ); - - // see whether this is an registered name - ::rtl::OUString sURL; - if ( hasRegisteredDatabase( _rName ) ) - { - sURL = getDatabaseLocation( _rName ); - // is the object cached under its URL? - xExistent = getObject( sURL ); - } - else - // interpret the name as URL - sURL = _rName; - - if ( !xExistent.is() ) - // try to load this as URL - xExistent = loadObjectFromURL( _rName, sURL ); - return makeAny( xExistent ); - } - catch (const NoSuchElementException&) - { // let these exceptions through - throw; - } - catch (const WrappedTargetException&) - { // let these exceptions through - throw; - } - catch (const RuntimeException&) - { // let these exceptions through - throw; - } - catch (const Exception&) - { // exceptions other than the speciafied ones -> wrap - Any aError = ::cppu::getCaughtException(); - throw WrappedTargetException(_rName, *this, aError ); - } -} - -Sequence< rtl::OUString > ODatabaseContext::getElementNames(void) throw( RuntimeException ) -{ - MutexGuard aGuard(m_aMutex); - ::connectivity::checkDisposed(DatabaseAccessContext_Base::rBHelper.bDisposed); - - return getRegistrationNames(); -} - -sal_Bool ODatabaseContext::hasByName(const rtl::OUString& _rName) throw( RuntimeException ) -{ - MutexGuard aGuard(m_aMutex); - ::connectivity::checkDisposed(DatabaseAccessContext_Base::rBHelper.bDisposed); - - return hasRegisteredDatabase( _rName ); -} - -Reference< XInterface > ODatabaseContext::getObject( const ::rtl::OUString& _rURL ) -{ - ObjectCacheIterator aFind = m_aDatabaseObjects.find( _rURL ); - Reference< XInterface > xExistent; - if ( aFind != m_aDatabaseObjects.end() ) - xExistent = aFind->second->getOrCreateDataSource(); - return xExistent; -} - -void ODatabaseContext::registerDatabaseDocument( ODatabaseModelImpl& _rModelImpl ) -{ - ::rtl::OUString sURL( _rModelImpl.getURL() ); -#if OSL_DEBUG_LEVEL > 1 - OSL_TRACE( "DatabaseContext: registering %s", ::rtl::OUStringToOString( sURL, RTL_TEXTENCODING_UTF8 ).getStr() ); -#endif - if ( m_aDatabaseObjects.find( sURL ) == m_aDatabaseObjects.end() ) - { - m_aDatabaseObjects[ sURL ] = &_rModelImpl; - setTransientProperties( sURL, _rModelImpl ); - } - else - OSL_FAIL( "ODatabaseContext::registerDatabaseDocument: already have an object registered for this URL!" ); -} - -void ODatabaseContext::revokeDatabaseDocument( const ODatabaseModelImpl& _rModelImpl ) -{ - ::rtl::OUString sURL( _rModelImpl.getURL() ); -#if OSL_DEBUG_LEVEL > 1 - OSL_TRACE( "DatabaseContext: deregistering %s", ::rtl::OUStringToOString( sURL, RTL_TEXTENCODING_UTF8 ).getStr() ); -#endif - m_aDatabaseObjects.erase( sURL ); -} - -void ODatabaseContext::databaseDocumentURLChange( const ::rtl::OUString& _rOldURL, const ::rtl::OUString& _rNewURL ) -{ -#if OSL_DEBUG_LEVEL > 1 - OSL_TRACE( "DatabaseContext: changing registration from %s to %s", - ::rtl::OUStringToOString( _rOldURL, RTL_TEXTENCODING_UTF8 ).getStr(), - ::rtl::OUStringToOString( _rNewURL, RTL_TEXTENCODING_UTF8 ).getStr() ); -#endif - ObjectCache::iterator oldPos = m_aDatabaseObjects.find( _rOldURL ); - ENSURE_OR_THROW( oldPos != m_aDatabaseObjects.end(), "illegal old database document URL" ); - ObjectCache::iterator newPos = m_aDatabaseObjects.find( _rNewURL ); - ENSURE_OR_THROW( newPos == m_aDatabaseObjects.end(), "illegal new database document URL" ); - - m_aDatabaseObjects[ _rNewURL ] = oldPos->second; - m_aDatabaseObjects.erase( oldPos ); -} - -sal_Int64 SAL_CALL ODatabaseContext::getSomething( const Sequence< sal_Int8 >& rId ) throw(RuntimeException) -{ - if (rId.getLength() == 16 && 0 == rtl_compareMemory(getUnoTunnelImplementationId().getConstArray(), rId.getConstArray(), 16 ) ) - return reinterpret_cast<sal_Int64>(this); - - return 0; -} - -Sequence< sal_Int8 > ODatabaseContext::getUnoTunnelImplementationId() -{ - static ::cppu::OImplementationId * pId = 0; - if (! pId) - { - ::osl::MutexGuard aGuard( ::osl::Mutex::getGlobalMutex() ); - if (! pId) - { - static ::cppu::OImplementationId aId; - pId = &aId; - } - } - return pId->getImplementationId(); -} - -void ODatabaseContext::onBasicManagerCreated( const Reference< XModel >& _rxForDocument, BasicManager& _rBasicManager ) -{ - // if it's a database document ... - Reference< XOfficeDatabaseDocument > xDatabaseDocument( _rxForDocument, UNO_QUERY ); - // ... or a sub document of a database document ... - if ( !xDatabaseDocument.is() ) - { - Reference< XChild > xDocAsChild( _rxForDocument, UNO_QUERY ); - if ( xDocAsChild.is() ) - xDatabaseDocument.set( xDocAsChild->getParent(), UNO_QUERY ); - } - - // ... whose BasicManager has just been created, then add the global DatabaseDocument variable to its scope. - if ( xDatabaseDocument.is() ) - _rBasicManager.SetGlobalUNOConstant( "ThisDatabaseDocument", makeAny( xDatabaseDocument ) ); -} - -} // namespace dbaccess -/* vim:set shiftwidth=4 softtabstop=4 expandtab: */ |