Google Git
Sign in
apache / openoffice / bab44dcac0296df22024f3f10e7997de78ed4094 / . / AOO410 / main / dbaccess / source / core / dataaccess / databasedocument.cxx
blob: 13a14df89910cad9f8f2bb39730fb6f83c44ed5e [file] [log] [blame]
/**************************************************************
*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*
*************************************************************/
// MARKER(update_precomp.py): autogen include statement, do not remove
#include "precompiled_dbaccess.hxx"
#include "core_resource.hxx"
#include "core_resource.hrc"
#include "datasource.hxx"
#include "databasedocument.hxx"
#include "dbastrings.hrc"
#include "module_dba.hxx"
#include "documenteventexecutor.hxx"
#include "databasecontext.hxx"
#include "documentcontainer.hxx"
#include "sdbcoretools.hxx"
#include "recovery/dbdocrecovery.hxx"
/** === begin UNO includes === **/
#include <com/sun/star/beans/Optional.hpp>
#include <com/sun/star/document/XExporter.hpp>
#include <com/sun/star/document/XFilter.hpp>
#include <com/sun/star/document/XImporter.hpp>
#include <com/sun/star/embed/EntryInitModes.hpp>
#include <com/sun/star/embed/XEmbedPersist.hpp>
#include <com/sun/star/embed/XTransactedObject.hpp>
#include <com/sun/star/embed/XTransactionBroadcaster.hpp>
#include <com/sun/star/io/XActiveDataSource.hpp>
#include <com/sun/star/io/XSeekable.hpp>
#include <com/sun/star/io/XOutputStream.hpp>
#include <com/sun/star/io/XTruncate.hpp>
#include <com/sun/star/script/provider/XScriptProviderFactory.hpp>
#include <com/sun/star/task/ErrorCodeIOException.hpp>
#include <com/sun/star/task/XStatusIndicator.hpp>
#include <com/sun/star/task/XStatusIndicatorFactory.hpp>
#include <com/sun/star/ucb/XSimpleFileAccess.hpp>
#include <com/sun/star/ui/XUIConfigurationStorage.hpp>
#include <com/sun/star/view/XSelectionSupplier.hpp>
#include <com/sun/star/xml/sax/XDocumentHandler.hpp>
#include <com/sun/star/ucb/XContent.hpp>
#include <com/sun/star/sdb/application/XDatabaseDocumentUI.hpp>
/** === end UNO includes === **/
#include <comphelper/documentconstants.hxx>
#include <comphelper/enumhelper.hxx>
#include <comphelper/genericpropertyset.hxx>
#include <comphelper/interaction.hxx>
#include <comphelper/mediadescriptor.hxx>
#include <comphelper/namedvaluecollection.hxx>
#include <comphelper/numberedcollection.hxx>
#include <comphelper/property.hxx>
#include <comphelper/storagehelper.hxx>
#include <comphelper/genericpropertyset.hxx>
#include <comphelper/property.hxx>
#include <connectivity/dbtools.hxx>
#include <cppuhelper/exc_hlp.hxx>
#include <framework/titlehelper.hxx>
#include <unotools/saveopt.hxx>
#include <tools/debug.hxx>
#include <tools/diagnose_ex.h>
#include <tools/errcode.hxx>
#include <tools/urlobj.hxx>
#include <boost/bind.hpp>
#include <algorithm>
#include <functional>
#include <list>
#define MAP_LEN(x) x, sizeof(x) - 1
#define MAP_LEN(x) x, sizeof(x) - 1
using namespace ::com::sun::star::uno;
using namespace ::com::sun::star::beans;
using namespace ::com::sun::star::frame;
using namespace ::com::sun::star::lang;
using namespace ::com::sun::star::container;
using namespace ::com::sun::star::document;
using namespace ::com::sun::star::io;
using namespace ::com::sun::star::util;
using namespace ::com::sun::star::embed;
using namespace ::com::sun::star::task;
using namespace ::com::sun::star::view;
using namespace ::com::sun::star::sdbc;
using namespace ::com::sun::star;
using namespace ::com::sun::star::xml::sax;
using namespace ::com::sun::star::script;
using namespace ::com::sun::star::script::provider;
using namespace ::com::sun::star::ui;
using namespace ::cppu;
using namespace ::osl;
using ::com::sun::star::awt::XWindow;
using ::com::sun::star::ucb::XContent;
using ::com::sun::star::sdb::application::XDatabaseDocumentUI;
//........................................................................
namespace dbaccess
{
//........................................................................
//============================================================
//= ViewMonitor
//============================================================
//--------------------------------------------------------------------------
bool ViewMonitor::onControllerConnected( const Reference< XController >& _rxController )
{
bool bFirstControllerEver = ( m_bEverHadController == false );
m_bEverHadController = true;
m_xLastConnectedController = _rxController;
m_bLastIsFirstEverController = bFirstControllerEver;
return bFirstControllerEver;
}
//--------------------------------------------------------------------------
bool ViewMonitor::onSetCurrentController( const Reference< XController >& _rxController )
{
// we interpret this as "loading the document (including UI) is finished",
// if and only if this is the controller which was last connected, and it was the
// first controller ever connected
bool bLoadFinished = ( _rxController == m_xLastConnectedController ) && m_bLastIsFirstEverController;
// notify the respective events
if ( bLoadFinished )
m_rEventNotifier.notifyDocumentEventAsync( m_bIsNewDocument ? "OnNew" : "OnLoad" );
return bLoadFinished;
}
//============================================================
//= ODatabaseDocument
//============================================================
DBG_NAME(ODatabaseDocument)
//--------------------------------------------------------------------------
extern "C" void SAL_CALL createRegistryInfo_ODatabaseDocument()
{
static ::dba::OAutoRegistration< ODatabaseDocument > aAutoRegistration;
}
//--------------------------------------------------------------------------
ODatabaseDocument::ODatabaseDocument(const ::rtl::Reference<ODatabaseModelImpl>& _pImpl )
:ModelDependentComponent( _pImpl )
,ODatabaseDocument_OfficeDocument( getMutex() )
,m_aModifyListeners( getMutex() )
,m_aCloseListener( getMutex() )
,m_aStorageListeners( getMutex() )
,m_pEventContainer( new DocumentEvents( *this, getMutex(), _pImpl->getDocumentEvents() ) )
,m_pEventExecutor( NULL ) // initialized below, ref-count-protected
,m_aEventNotifier( *this, getMutex() )
,m_aViewMonitor( m_aEventNotifier )
,m_eInitState( NotInitialized )
,m_bClosing( false )
,m_bAllowDocumentScripting( false )
,m_bHasBeenRecovered( false )
{
DBG_CTOR(ODatabaseDocument,NULL);
OSL_TRACE( "DD: ctor: %p: %p", this, m_pImpl.get() );
osl_incrementInterlockedCount( &m_refCount );
{
impl_reparent_nothrow( m_xForms );
impl_reparent_nothrow( m_xReports );
impl_reparent_nothrow( m_pImpl->m_xTableDefinitions );
impl_reparent_nothrow( m_pImpl->m_xCommandDefinitions );
m_pEventExecutor = new DocumentEventExecutor( m_pImpl->m_aContext, this );
}
osl_decrementInterlockedCount( &m_refCount );
// if there previously was a document instance for the same Impl which was already initialized,
// then consider ourself initialized, too.
// #i94840#
if ( m_pImpl->hadInitializedDocument() )
{
// Note we set our init-state to "Initializing", not "Initialized". We're created from inside the ModelImpl,
// which is expected to call attachResource in case there was a previous incarnation of the document,
// so we can properly finish our initialization then.
impl_setInitializing();
if ( m_pImpl->getURL().getLength() )
{
// if the previous incarnation of the DatabaseDocument already had an URL, then creating this incarnation
// here is effectively loading the document.
// #i105505# / 2009-10-01 / frank.schoenheit@sun.com
m_aViewMonitor.onLoadedDocument();
}
}
}
//--------------------------------------------------------------------------
ODatabaseDocument::~ODatabaseDocument()
{
OSL_TRACE( "DD: dtor: %p: %p", this, m_pImpl.get() );
DBG_DTOR(ODatabaseDocument,NULL);
if ( !ODatabaseDocument_OfficeDocument::rBHelper.bInDispose && !ODatabaseDocument_OfficeDocument::rBHelper.bDisposed )
{
acquire();
dispose();
}
delete m_pEventContainer, m_pEventContainer = NULL;
}
// -----------------------------------------------------------------------------
Any SAL_CALL ODatabaseDocument::queryInterface( const Type& _rType ) throw (RuntimeException)
{
// strip XEmbeddedScripts and XScriptInvocationContext if we have any form/report
// which already contains macros. In this case, the database document itself is not
// allowed to contain macros, too.
if ( !m_bAllowDocumentScripting
&& ( _rType.equals( XEmbeddedScripts::static_type() )
|| _rType.equals( XScriptInvocationContext::static_type() )
)
)
return Any();
Any aReturn = ODatabaseDocument_OfficeDocument::queryInterface(_rType);
if (!aReturn.hasValue())
aReturn = ODatabaseDocument_Title::queryInterface(_rType);
return aReturn;
}
//------------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::acquire( ) throw ()
{
ODatabaseDocument_OfficeDocument::acquire();
}
//------------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::release( ) throw ()
{
ODatabaseDocument_OfficeDocument::release();
}
//------------------------------------------------------------------------------
Sequence< Type > SAL_CALL ODatabaseDocument::getTypes( ) throw (RuntimeException)
{
Sequence< Type > aTypes = ::comphelper::concatSequences(
ODatabaseDocument_OfficeDocument::getTypes(),
ODatabaseDocument_Title::getTypes()
);
// strip XEmbeddedScripts and XScriptInvocationContext if we have any form/report
// which already contains macros. In this case, the database document itself is not
// allowed to contain macros, too.
if ( !m_bAllowDocumentScripting )
{
Sequence< Type > aStrippedTypes( aTypes.getLength() );
Type* pStripTo( aStrippedTypes.getArray() );
// strip XEmbeddedScripts, and immediately re-assign to aTypes
aTypes = Sequence< Type >(
pStripTo,
::std::remove_copy_if(
aTypes.getConstArray(),
aTypes.getConstArray() + aTypes.getLength(),
pStripTo,
::std::bind2nd( ::std::equal_to< Type >(), XEmbeddedScripts::static_type() )
) - pStripTo
);
// strip XScriptInvocationContext, and immediately re-assign to aTypes
aTypes = Sequence< Type >(
pStripTo,
::std::remove_copy_if(
aTypes.getConstArray(),
aTypes.getConstArray() + aTypes.getLength(),
pStripTo,
::std::bind2nd( ::std::equal_to< Type >(), XScriptInvocationContext::static_type() )
) - pStripTo
);
}
return aTypes;
}
//------------------------------------------------------------------------------
Sequence< sal_Int8 > SAL_CALL ODatabaseDocument::getImplementationId( ) throw (RuntimeException)
{
static ::cppu::OImplementationId * pId = 0;
if (! pId)
{
::osl::MutexGuard aGuard( ::osl::Mutex::getGlobalMutex() );
if (! pId)
{
static ::cppu::OImplementationId aId;
pId = &aId;
}
}
return pId->getImplementationId();
}
// -----------------------------------------------------------------------------
// local functions
// -----------------------------------------------------------------------------
namespace
{
// -----------------------------------------------------------------------------
Reference< XStatusIndicator > lcl_extractStatusIndicator( const ::comphelper::NamedValueCollection& _rArguments )
{
Reference< XStatusIndicator > xStatusIndicator;
return _rArguments.getOrDefault( "StatusIndicator", xStatusIndicator );
}
// -----------------------------------------------------------------------------
static void lcl_triggerStatusIndicator_throw( const ::comphelper::NamedValueCollection& _rArguments, DocumentGuard& _rGuard, const bool _bStart )
{
Reference< XStatusIndicator > xStatusIndicator( lcl_extractStatusIndicator( _rArguments ) );
if ( !xStatusIndicator.is() )
return;
_rGuard.clear();
try
{
if ( _bStart )
xStatusIndicator->start( ::rtl::OUString(), (sal_Int32)1000000 );
else
xStatusIndicator->end();
}
catch( const Exception& )
{
DBG_UNHANDLED_EXCEPTION();
}
_rGuard.reset();
// note that |reset| can throw a DisposedException
}
// -----------------------------------------------------------------------------
static void lcl_extractStatusIndicator( const ::comphelper::NamedValueCollection& _rArguments, Sequence< Any >& _rCallArgs )
{
Reference< XStatusIndicator > xStatusIndicator( lcl_extractStatusIndicator( _rArguments ) );
if ( !xStatusIndicator.is() )
return;
sal_Int32 nLength = _rCallArgs.getLength();
_rCallArgs.realloc( nLength + 1 );
_rCallArgs[ nLength ] <<= xStatusIndicator;
}
// -----------------------------------------------------------------------------
static void lcl_extractAndStartStatusIndicator( const ::comphelper::NamedValueCollection& _rArguments, Reference< XStatusIndicator >& _rxStatusIndicator,
Sequence< Any >& _rCallArgs )
{
_rxStatusIndicator = lcl_extractStatusIndicator( _rArguments );
if ( !_rxStatusIndicator.is() )
return;
try
{
_rxStatusIndicator->start( ::rtl::OUString(), (sal_Int32)1000000 );
sal_Int32 nLength = _rCallArgs.getLength();
_rCallArgs.realloc( nLength + 1 );
_rCallArgs[ nLength ] <<= _rxStatusIndicator;
}
catch( const Exception& )
{
DBG_UNHANDLED_EXCEPTION();
}
}
// -----------------------------------------------------------------------------
static Sequence< PropertyValue > lcl_appendFileNameToDescriptor( const ::comphelper::NamedValueCollection& _rDescriptor, const ::rtl::OUString _rURL )
{
::comphelper::NamedValueCollection aMutableDescriptor( _rDescriptor );
if ( _rURL.getLength() )
{
aMutableDescriptor.put( "FileName", _rURL );
aMutableDescriptor.put( "URL", _rURL );
}
return aMutableDescriptor.getPropertyValues();
}
}
// -----------------------------------------------------------------------------
void ODatabaseDocument::impl_setInitialized()
{
m_eInitState = Initialized;
// start event notifications
m_aEventNotifier.onDocumentInitialized();
}
// -----------------------------------------------------------------------------
void ODatabaseDocument::impl_reset_nothrow()
{
try
{
m_pImpl->clearConnections();
m_pImpl->disposeStorages();
m_pImpl->resetRootStroage();
clearObjectContainer( m_xForms );
clearObjectContainer( m_xReports );
clearObjectContainer( m_pImpl->m_xTableDefinitions );
clearObjectContainer( m_pImpl->m_xCommandDefinitions );
m_eInitState = NotInitialized;
m_pImpl->reset();
}
catch(const Exception&)
{
DBG_UNHANDLED_EXCEPTION();
}
m_pImpl->m_bDocumentReadOnly = sal_False;
}
// -----------------------------------------------------------------------------
void ODatabaseDocument::impl_import_nolck_throw( const ::comphelper::ComponentContext _rContext, const Reference< XInterface >& _rxTargetComponent,
const ::comphelper::NamedValueCollection& _rResource )
{
Sequence< Any > aFilterCreationArgs;
Reference< XStatusIndicator > xStatusIndicator;
lcl_extractAndStartStatusIndicator( _rResource, xStatusIndicator, aFilterCreationArgs );
/** property map for import info set */
comphelper::PropertyMapEntry aExportInfoMap[] =
{
{ MAP_LEN( "BaseURI"), 0,&::getCppuType( (::rtl::OUString *)0 ),beans::PropertyAttribute::MAYBEVOID, 0 },
{ MAP_LEN( "StreamName"), 0,&::getCppuType( (::rtl::OUString *)0 ),beans::PropertyAttribute::MAYBEVOID, 0 },
{ NULL, 0, 0, NULL, 0, 0 }
};
uno::Reference< beans::XPropertySet > xInfoSet( comphelper::GenericPropertySet_CreateInstance( new comphelper::PropertySetInfo( aExportInfoMap ) ) );
xInfoSet->setPropertyValue(rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("BaseURI")), uno::makeAny(_rResource.getOrDefault("URL",::rtl::OUString())));
xInfoSet->setPropertyValue(rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("StreamName")), uno::makeAny(::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("content.xml"))));
const sal_Int32 nCount = aFilterCreationArgs.getLength();
aFilterCreationArgs.realloc(nCount + 1);
aFilterCreationArgs[nCount] <<= xInfoSet;
Reference< XImporter > xImporter(
_rContext.createComponentWithArguments( "com.sun.star.comp.sdb.DBFilter", aFilterCreationArgs ),
UNO_QUERY_THROW );
Reference< XComponent > xComponent( _rxTargetComponent, UNO_QUERY_THROW );
xImporter->setTargetDocument( xComponent );
Reference< XFilter > xFilter( xImporter, UNO_QUERY_THROW );
Sequence< PropertyValue > aFilterArgs( ODatabaseModelImpl::stripLoadArguments( _rResource ).getPropertyValues() );
xFilter->filter( aFilterArgs );
if ( xStatusIndicator.is() )
xStatusIndicator->end();
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::initNew( ) throw (DoubleInitializationException, IOException, Exception, RuntimeException)
{
// SYNCHRONIZED ->
DocumentGuard aGuard( *this, DocumentGuard::InitMethod );
impl_reset_nothrow();
impl_setInitializing();
// create a temporary storage
Reference< XStorage > xTempStor( ::comphelper::OStorageHelper::GetTemporaryStorage(
m_pImpl->m_aContext.getLegacyServiceFactory() ) );
// store therein
impl_storeToStorage_throw( xTempStor, Sequence< PropertyValue >(), aGuard );
// let the impl know we're now based on this storage
m_pImpl->switchToStorage( xTempStor );
// for the newly created document, allow document-wide scripting
m_bAllowDocumentScripting = true;
impl_setInitialized();
m_aEventNotifier.notifyDocumentEventAsync( "OnTitleChanged" );
impl_setModified_nothrow( sal_False, aGuard );
// <- SYNCHRONIZED
m_aEventNotifier.notifyDocumentEvent( "OnCreate" );
impl_notifyStorageChange_nolck_nothrow( xTempStor );
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::load( const Sequence< PropertyValue >& _Arguments ) throw (DoubleInitializationException, IOException, Exception, RuntimeException)
{
// SYNCHRONIZED ->
DocumentGuard aGuard( *this, DocumentGuard::InitMethod );
impl_reset_nothrow();
::comphelper::NamedValueCollection aResource( _Arguments );
if ( aResource.has( "FileName" ) && !aResource.has( "URL" ) )
// FileName is the compatibility name for URL, so we might have clients passing
// a FileName only. However, some of our code works with the URL only, so ensure
// we have one.
aResource.put( "URL", aResource.get( "FileName" ) );
if ( aResource.has( "URL" ) && !aResource.has( "FileName" ) )
// similar ... just in case there is legacy code which expects a FileName only
aResource.put( "FileName", aResource.get( "URL" ) );
// now that somebody (perhaps) told us an macro execution mode, remember it as
// ImposedMacroExecMode
m_pImpl->setImposedMacroExecMode(
aResource.getOrDefault( "MacroExecutionMode", m_pImpl->getImposedMacroExecMode() ) );
impl_setInitializing();
try
{
aGuard.clear();
impl_import_nolck_throw( m_pImpl->m_aContext, *this, aResource );
aGuard.reset();
}
catch( const Exception& )
{
impl_reset_nothrow();
throw;
}
// tell our view monitor that the document has been loaded - this way it will fire the proper
// event (OnLoad instead of OnCreate) later on
m_aViewMonitor.onLoadedDocument();
// note that we do *not* call impl_setInitialized() here: The initialization is only complete
// when the XModel::attachResource has been called, not sooner.
impl_setModified_nothrow( sal_False, aGuard );
// <- SYNCHRONIZED
}
// -----------------------------------------------------------------------------
namespace
{
// .........................................................................
bool lcl_hasAnyModifiedSubComponent_throw( const Reference< XController >& i_rController )
{
Reference< XDatabaseDocumentUI > xDatabaseUI( i_rController, UNO_QUERY_THROW );
Sequence< Reference< XComponent > > aComponents( xDatabaseUI->getSubComponents() );
const Reference< XComponent >* component = aComponents.getConstArray();
const Reference< XComponent >* componentsEnd = aComponents.getConstArray() + aComponents.getLength();
bool isAnyModified = false;
for ( ; component != componentsEnd; ++component )
{
Reference< XModifiable > xModify( *component, UNO_QUERY );
if ( xModify.is() )
{
isAnyModified = xModify->isModified();
continue;
}
// TODO: clarify: anything else to care for? Both the sub componbents with and without model
// should support the XModifiable interface, so I think nothing more is needed here.
OSL_ENSURE( false, "lcl_hasAnyModifiedSubComponent_throw: anything left to do here?" );
}
return isAnyModified;
}
}
// -----------------------------------------------------------------------------
::sal_Bool SAL_CALL ODatabaseDocument::wasModifiedSinceLastSave() throw ( RuntimeException )
{
DocumentGuard aGuard( *this );
// The implementation here is somewhat sloppy, in that it returns whether *any* part of the whole
// database document, including opened sub components, is modified. This is more than what is requested:
// We need to return <TRUE/> if the doc itself, or any of the opened sub components, has been modified
// since the last call to any of the save* methods, or since the document has been loaded/created.
// However, the API definition explicitly allows to be that sloppy ...
if ( isModified() )
return sal_True;
// auto recovery is an "UI feature", it is to restore the UI the user knows. Thus,
// we ask our connected controllers, not simply our existing form/report definitions.
// (There is some information which even cannot be obtained without asking the controller.
// For instance, newly created, but not yet saved, forms/reports are acessible via the
// controller only, but not via the model.)
try
{
for ( Controllers::const_iterator ctrl = m_aControllers.begin();
ctrl != m_aControllers.end();
++ctrl
)
{
if ( lcl_hasAnyModifiedSubComponent_throw( *ctrl ) )
return sal_True;
}
}
catch( const Exception& )
{
DBG_UNHANDLED_EXCEPTION();
}
return sal_False;
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::storeToRecoveryFile( const ::rtl::OUString& i_TargetLocation, const Sequence< PropertyValue >& i_MediaDescriptor ) throw ( RuntimeException, IOException, WrappedTargetException )
{
DocumentGuard aGuard( *this );
ModifyLock aLock( *this );
try
{
// create a storage for the target location
Reference< XStorage > xTargetStorage( impl_createStorageFor_throw( i_TargetLocation ) );
// first store the document as a whole into this storage
impl_storeToStorage_throw( xTargetStorage, i_MediaDescriptor, aGuard );
// save the sub components which need saving
DatabaseDocumentRecovery aDocRecovery( m_pImpl->m_aContext);
aDocRecovery.saveModifiedSubComponents( xTargetStorage, m_aControllers );
// commit the root storage
tools::stor::commitStorageIfWriteable( xTargetStorage );
}
catch( const Exception& )
{
Any aError = ::cppu::getCaughtException();
if ( aError.isExtractableTo( ::cppu::UnoType< IOException >::get() )
|| aError.isExtractableTo( ::cppu::UnoType< RuntimeException >::get() )
|| aError.isExtractableTo( ::cppu::UnoType< WrappedTargetException >::get() )
)
{
// allowed to leave
throw;
}
throw WrappedTargetException( ::rtl::OUString(), *this, aError );
}
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::recoverFromFile( const ::rtl::OUString& i_SourceLocation, const ::rtl::OUString& i_SalvagedFile, const Sequence< PropertyValue >& i_MediaDescriptor ) throw ( RuntimeException, IOException, WrappedTargetException )
{
DocumentGuard aGuard( *this, DocumentGuard::InitMethod );
if ( i_SourceLocation.getLength() == 0 )
throw IllegalArgumentException( ::rtl::OUString(), *this, 1 );
try
{
// load the document itself, by simply delegating to our "load" method
// our load implementation expects the SalvagedFile and URL to be in the media descriptor
::comphelper::NamedValueCollection aMediaDescriptor( i_MediaDescriptor );
aMediaDescriptor.put( "SalvagedFile", i_SalvagedFile );
aMediaDescriptor.put( "URL", i_SourceLocation );
aGuard.clear(); // (load has an own guarding scheme)
load( aMediaDescriptor.getPropertyValues() );
// Without a controller, we are unable to recover the sub components, as they're always tied to a controller.
// So, everything else is done when the first controller is connected.
m_bHasBeenRecovered = true;
// tell the impl that we've been loaded from the given location
m_pImpl->setDocFileLocation( i_SourceLocation );
// by definition (of XDocumentRecovery), we're responsible for delivering a fully-initialized document,
// which includes an attachResource call.
const ::rtl::OUString sLogicalDocumentURL( i_SalvagedFile.getLength() ? i_SalvagedFile : i_SourceLocation );
impl_attachResource( sLogicalDocumentURL, aMediaDescriptor.getPropertyValues(), aGuard );
// <- SYNCHRONIZED
}
catch( const Exception& )
{
Any aError = ::cppu::getCaughtException();
if ( aError.isExtractableTo( ::cppu::UnoType< IOException >::get() )
|| aError.isExtractableTo( ::cppu::UnoType< RuntimeException >::get() )
|| aError.isExtractableTo( ::cppu::UnoType< WrappedTargetException >::get() )
)
{
// allowed to leave
throw;
}
throw WrappedTargetException( ::rtl::OUString(), *this, aError );
}
}
// -----------------------------------------------------------------------------
// XModel
sal_Bool SAL_CALL ODatabaseDocument::attachResource( const ::rtl::OUString& _rURL, const Sequence< PropertyValue >& _rArguments ) throw (RuntimeException)
{
DocumentGuard aGuard( *this, DocumentGuard::MethodUsedDuringInit );
return impl_attachResource( _rURL, _rArguments, aGuard );
}
// -----------------------------------------------------------------------------
sal_Bool ODatabaseDocument::impl_attachResource( const ::rtl::OUString& i_rLogicalDocumentURL,
const Sequence< PropertyValue >& i_rMediaDescriptor, DocumentGuard& _rDocGuard )
{
if ( ( i_rLogicalDocumentURL == getURL() )
&& ( i_rMediaDescriptor.getLength() == 1 )
&& ( i_rMediaDescriptor[0].Name.compareToAscii( "BreakMacroSignature" ) == 0 )
)
{
// this is a BAD hack of the Basic importer code ... there should be a dedicated API for this,
// not this bad mis-using of existing interfaces
return sal_False;
// (we do not support macro signatures, so we can ignore this call)
}
// if no URL has been provided, the caller was lazy enough to not call our getURL - which is not allowed anymore,
// now since getURL and getLocation both return the same, so calling one of those should be simple.
::rtl::OUString sDocumentURL( i_rLogicalDocumentURL );
OSL_ENSURE( sDocumentURL.getLength(), "ODatabaseDocument::impl_attachResource: invalid URL!" );
if ( !sDocumentURL.getLength() )
sDocumentURL = getURL();
m_pImpl->setResource( sDocumentURL, i_rMediaDescriptor );
if ( impl_isInitializing() )
{ // this means we've just been loaded, and this is the attachResource call which follows
// the load call.
impl_setInitialized();
// determine whether the document as a whole, or sub documents, have macros. Especially the latter
// controls the availability of our XEmbeddedScripts and XScriptInvocationContext interfaces, and we
// should know this before anybody actually uses the object.
m_bAllowDocumentScripting = ( m_pImpl->determineEmbeddedMacros() != ODatabaseModelImpl::eSubDocumentMacros );
_rDocGuard.clear();
// <- SYNCHRONIZED
m_aEventNotifier.notifyDocumentEvent( "OnLoadFinished" );
}
return sal_True;
}
// -----------------------------------------------------------------------------
::rtl::OUString SAL_CALL ODatabaseDocument::getURL( ) throw (RuntimeException)
{
DocumentGuard aGuard( *this, DocumentGuard::MethodWithoutInit );
return m_pImpl->getURL();
}
// -----------------------------------------------------------------------------
Sequence< PropertyValue > SAL_CALL ODatabaseDocument::getArgs( ) throw (RuntimeException)
{
DocumentGuard aGuard( *this, DocumentGuard::MethodWithoutInit );
return m_pImpl->getMediaDescriptor().getPropertyValues();
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::connectController( const Reference< XController >& _xController ) throw (RuntimeException)
{
DocumentGuard aGuard( *this );
#if OSL_DEBUG_LEVEL > 0
for ( Controllers::const_iterator controller = m_aControllers.begin();
controller != m_aControllers.end();
++controller
)
{
OSL_ENSURE( *controller != _xController, "ODatabaseDocument::connectController: this controller is already connected!" );
}
#endif
m_aControllers.push_back( _xController );
m_aEventNotifier.notifyDocumentEventAsync( "OnViewCreated", Reference< XController2 >( _xController, UNO_QUERY ) );
bool bFirstControllerEver = m_aViewMonitor.onControllerConnected( _xController );
if ( !bFirstControllerEver )
return;
// check/adjust our macro mode.
m_pImpl->checkMacrosOnLoading();
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::disconnectController( const Reference< XController >& _xController ) throw (RuntimeException)
{
bool bNotifyViewClosed = false;
bool bLastControllerGone = false;
bool bIsClosing = false;
// SYNCHRONIZED ->
{
DocumentGuard aGuard( *this );
Controllers::iterator pos = ::std::find( m_aControllers.begin(), m_aControllers.end(), _xController );
OSL_ENSURE( pos != m_aControllers.end(), "ODatabaseDocument::disconnectController: don't know this controller!" );
if ( pos != m_aControllers.end() )
{
m_aControllers.erase( pos );
bNotifyViewClosed = true;
}
if ( m_xCurrentController == _xController )
m_xCurrentController = NULL;
bLastControllerGone = m_aControllers.empty();
bIsClosing = m_bClosing;
}
// <- SYNCHRONIZED
if ( bNotifyViewClosed )
m_aEventNotifier.notifyDocumentEvent( "OnViewClosed", Reference< XController2 >( _xController, UNO_QUERY ) );
if ( bLastControllerGone && !bIsClosing )
{
// if this was the last view, close the document as a whole
// #i51157# / 2006-03-16 / frank.schoenheit@sun.com
try
{
close( sal_True );
}
catch( const CloseVetoException& )
{
// okay, somebody vetoed and took ownership
}
}
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::lockControllers( ) throw (RuntimeException)
{
DocumentGuard aGuard( *this );
++m_pImpl->m_nControllerLockCount;
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::unlockControllers( ) throw (RuntimeException)
{
DocumentGuard aGuard( *this );
--m_pImpl->m_nControllerLockCount;
}
// -----------------------------------------------------------------------------
sal_Bool SAL_CALL ODatabaseDocument::hasControllersLocked( ) throw (RuntimeException)
{
DocumentGuard aGuard( *this );
return m_pImpl->m_nControllerLockCount != 0;
}
// -----------------------------------------------------------------------------
Reference< XController > SAL_CALL ODatabaseDocument::getCurrentController() throw (RuntimeException)
{
DocumentGuard aGuard( *this );
return m_xCurrentController.is() ? m_xCurrentController : ( m_aControllers.empty() ? Reference< XController >() : *m_aControllers.begin() );
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::setCurrentController( const Reference< XController >& _xController ) throw (NoSuchElementException, RuntimeException)
{
DocumentGuard aGuard( *this );
m_xCurrentController = _xController;
if ( !m_aViewMonitor.onSetCurrentController( _xController ) )
return;
// check if there are sub components to recover from our document storage
bool bAttemptRecovery = m_bHasBeenRecovered;
if ( !bAttemptRecovery && m_pImpl->getMediaDescriptor().has( "ForceRecovery" ) )
// do not use getOrDefault, it will throw for invalid types, which is not desired here
m_pImpl->getMediaDescriptor().get( "ForceRecovery" ) >>= bAttemptRecovery;
if ( !bAttemptRecovery )
return;
try
{
DatabaseDocumentRecovery aDocRecovery( m_pImpl->m_aContext );
aDocRecovery.recoverSubDocuments( m_pImpl->getRootStorage(), _xController );
}
catch( const Exception& )
{
DBG_UNHANDLED_EXCEPTION();
}
}
// -----------------------------------------------------------------------------
Reference< XInterface > SAL_CALL ODatabaseDocument::getCurrentSelection( ) throw (RuntimeException)
{
DocumentGuard aGuard( *this );
Reference< XInterface > xRet;
Reference< XSelectionSupplier > xDocView( getCurrentController(), UNO_QUERY );
if ( xDocView.is() )
xRet.set(xDocView->getSelection(),UNO_QUERY);
return xRet;
}
// -----------------------------------------------------------------------------
// XStorable
sal_Bool SAL_CALL ODatabaseDocument::hasLocation( ) throw (RuntimeException)
{
return getLocation().getLength() > 0;
}
// -----------------------------------------------------------------------------
::rtl::OUString SAL_CALL ODatabaseDocument::getLocation( ) throw (RuntimeException)
{
DocumentGuard aGuard( *this, DocumentGuard::MethodWithoutInit );
return m_pImpl->getURL();
// both XStorable::getLocation and XModel::getURL have to return the URL of the document, *not*
// the location of the file which the docunment was possibly recovered from (which would be getDocFileLocation)
}
// -----------------------------------------------------------------------------
sal_Bool SAL_CALL ODatabaseDocument::isReadonly( ) throw (RuntimeException)
{
DocumentGuard aGuard( *this, DocumentGuard::MethodWithoutInit );
return m_pImpl->m_bDocumentReadOnly;
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::store( ) throw (IOException, RuntimeException)
{
DocumentGuard aGuard( *this );
::rtl::OUString sDocumentURL( m_pImpl->getURL() );
if ( sDocumentURL.getLength() )
{
if ( m_pImpl->getDocFileLocation() == m_pImpl->getURL() )
if ( m_pImpl->m_bDocumentReadOnly )
throw IOException();
impl_storeAs_throw( m_pImpl->getURL(), m_pImpl->getMediaDescriptor(), SAVE, aGuard );
return;
}
// if we have no URL, but did survive the DocumentGuard above, then we've been inited via XLoadable::initNew,
// i.e. we're based on a temporary storage
OSL_ENSURE( m_pImpl->getDocFileLocation().getLength() == 0, "ODatabaseDocument::store: unexpected URL inconsistency!" );
try
{
impl_storeToStorage_throw( m_pImpl->getRootStorage(), m_pImpl->getMediaDescriptor().getPropertyValues(), aGuard );
}
catch( const Exception& )
{
Any aError = ::cppu::getCaughtException();
if ( aError.isExtractableTo( ::cppu::UnoType< IOException >::get() )
|| aError.isExtractableTo( ::cppu::UnoType< RuntimeException >::get() )
)
{
// allowed to leave
throw;
}
impl_throwIOExceptionCausedBySave_throw( aError, ::rtl::OUString() );
}
}
// -----------------------------------------------------------------------------
void ODatabaseDocument::impl_throwIOExceptionCausedBySave_throw( const Any& i_rError, const ::rtl::OUString& i_rTargetURL ) const
{
::rtl::OUString sErrorMessage = extractExceptionMessage( m_pImpl->m_aContext, i_rError );
sErrorMessage = ResourceManager::loadString(
RID_STR_ERROR_WHILE_SAVING,
"$location$", i_rTargetURL,
"$message$", sErrorMessage
);
throw IOException( sErrorMessage, *const_cast< ODatabaseDocument* >( this ) );
}
// -----------------------------------------------------------------------------
void ODatabaseDocument::impl_storeAs_throw( const ::rtl::OUString& _rURL, const ::comphelper::NamedValueCollection& _rArguments,
const StoreType _eType, DocumentGuard& _rGuard ) throw ( IOException, RuntimeException )
{
OSL_PRECOND( ( _eType == SAVE ) || ( _eType == SAVE_AS ),
"ODatabaseDocument::impl_storeAs_throw: you introduced a new type which cannot be handled here!" );
// if we're in the process of initializing the document (which effectively means it is an implicit
// initialization triggered in storeAsURL), the we do not notify events, since to an observer, the SaveAs
// should not be noticable
bool bIsInitializationProcess = impl_isInitializing();
if ( !bIsInitializationProcess )
{
_rGuard.clear();
m_aEventNotifier.notifyDocumentEvent( _eType == SAVE ? "OnSave" : "OnSaveAs", NULL, makeAny( _rURL ) );
_rGuard.reset();
}
Reference< XStorage > xNewRootStorage;
// will be non-NULL if our storage changed
try
{
ModifyLock aLock( *this );
// ignore all changes of our "modified" state during storing
sal_Bool bLocationChanged = ( _rURL != m_pImpl->getDocFileLocation() );
if ( bLocationChanged )
{
// create storage for target URL
Reference< XStorage > xTargetStorage( impl_createStorageFor_throw( _rURL ) );
if ( m_pImpl->isEmbeddedDatabase() )
m_pImpl->clearConnections();
// commit everything
m_pImpl->commitEmbeddedStorage();
m_pImpl->commitStorages();
// copy own storage to target storage
Reference< XStorage > xCurrentStorage( m_pImpl->getRootStorage() );
if ( xCurrentStorage.is() )
xCurrentStorage->copyToStorage( xTargetStorage );
m_pImpl->disposeStorages();
// each and every document definition obtained via m_xForms and m_xReports depends
// on the sub storages which we just disposed. So, dispose the forms/reports collections, too.
// This ensures that they're re-created when needed.
clearObjectContainer( m_xForms );
clearObjectContainer( m_xReports );
xNewRootStorage = m_pImpl->switchToStorage( xTargetStorage );
m_pImpl->m_bDocumentReadOnly = sal_False;
}
// store to current storage
Reference< XStorage > xCurrentStorage( m_pImpl->getOrCreateRootStorage(), UNO_QUERY_THROW );
Sequence< PropertyValue > aMediaDescriptor( lcl_appendFileNameToDescriptor( _rArguments, _rURL ) );
impl_storeToStorage_throw( xCurrentStorage, aMediaDescriptor, _rGuard );
// success - tell our impl
m_pImpl->setDocFileLocation( _rURL );
m_pImpl->setResource( _rURL, aMediaDescriptor );
// if we are in an initialization process, then this is finished, now that we stored the document
if ( bIsInitializationProcess )
impl_setInitialized();
}
catch( const Exception& )
{
Any aError = ::cppu::getCaughtException();
// notify the failure
if ( !bIsInitializationProcess )
m_aEventNotifier.notifyDocumentEventAsync( _eType == SAVE ? "OnSaveFailed" : "OnSaveAsFailed", NULL, makeAny( _rURL ) );
if ( aError.isExtractableTo( ::cppu::UnoType< IOException >::get() )
|| aError.isExtractableTo( ::cppu::UnoType< RuntimeException >::get() )
)
{
// allowed to leave
throw;
}
impl_throwIOExceptionCausedBySave_throw( aError, _rURL );
}
// notify the document event
if ( !bIsInitializationProcess )
m_aEventNotifier.notifyDocumentEventAsync( _eType == SAVE ? "OnSaveDone" : "OnSaveAsDone", NULL, makeAny( _rURL ) );
// reset our "modified" flag, and clear the guard
impl_setModified_nothrow( sal_False, _rGuard );
// <- SYNCHRONIZED
// notify storage listeners
if ( xNewRootStorage.is() )
impl_notifyStorageChange_nolck_nothrow( xNewRootStorage );
}
// -----------------------------------------------------------------------------
Reference< XStorage > ODatabaseDocument::impl_createStorageFor_throw( const ::rtl::OUString& _rURL ) const
{
Reference < ::com::sun::star::ucb::XSimpleFileAccess > xTempAccess;
m_pImpl->m_aContext.createComponent( ::rtl::OUString::createFromAscii( "com.sun.star.ucb.SimpleFileAccess" ) ,xTempAccess);
Reference< io::XStream > xStream = xTempAccess->openFileReadWrite( _rURL );
Reference< io::XTruncate > xTruncate(xStream,UNO_QUERY);
if ( xTruncate.is() )
{
xTruncate->truncate();
}
Sequence<Any> aParam(2);
aParam[0] <<= xStream;
aParam[1] <<= ElementModes::READWRITE | ElementModes::TRUNCATE;
Reference< XSingleServiceFactory > xStorageFactory( m_pImpl->createStorageFactory(), UNO_SET_THROW );
return Reference< XStorage >( xStorageFactory->createInstanceWithArguments( aParam ), UNO_QUERY_THROW );
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::storeAsURL( const ::rtl::OUString& _rURL, const Sequence< PropertyValue >& _rArguments ) throw (IOException, RuntimeException)
{
// SYNCHRONIZED ->
DocumentGuard aGuard( *this, DocumentGuard::MethodWithoutInit );
// Normally, a document initialization is done via XLoadable::load or XLoadable::initNew. For convenience
// reasons, and to not break existing API clients, it's allowed to call storeAsURL without having initialized
// the document, in which case the initialization will be done implicitly.
bool bImplicitInitialization = !impl_isInitialized();
// implicit initialization while another initialization is just running is not possible
if ( bImplicitInitialization && impl_isInitializing() )
throw DoubleInitializationException();
if ( bImplicitInitialization )
impl_setInitializing();
try
{
impl_storeAs_throw( _rURL, _rArguments, SAVE_AS, aGuard );
// <- SYNCHRONIZED
// impl_storeAs_throw cleared the lock on our mutex, but the below lines need this lock
// SYNCHRONIZED ->
aGuard.reset();
// our title might have changed, potentially at least
// Sadly, we cannot check this: Calling getTitle here and now would not deliver
// an up-to-date result, as the call is delegated to our TitleHelper instance, which itself
// updates its title only if it gets the OnSaveAsDone event (which was sent asynchronously
// by impl_storeAs_throw). So, we simply notify always, and also asynchronously
m_aEventNotifier.notifyDocumentEventAsync( "OnTitleChanged" );
}
catch( const Exception& )
{
impl_reset_nothrow();
throw;
}
if ( bImplicitInitialization )
m_bAllowDocumentScripting = true;
aGuard.clear();
// <- SYNCHRONIZED
if ( bImplicitInitialization )
m_aEventNotifier.notifyDocumentEvent( "OnCreate" );
}
// -----------------------------------------------------------------------------
void ODatabaseDocument::impl_storeToStorage_throw( const Reference< XStorage >& _rxTargetStorage, const Sequence< PropertyValue >& _rMediaDescriptor,
DocumentGuard& _rDocGuard ) const
{
if ( !_rxTargetStorage.is() )
throw IllegalArgumentException( ::rtl::OUString(), *const_cast< ODatabaseDocument* >( this ), 1 );
if ( !m_pImpl.is() )
throw DisposedException( ::rtl::OUString(), *const_cast< ODatabaseDocument* >( this ) );
try
{
// commit everything
m_pImpl->commitEmbeddedStorage();
m_pImpl->commitStorages();
// copy own storage to target storage
if ( impl_isInitialized() )
{
Reference< XStorage > xCurrentStorage( m_pImpl->getOrCreateRootStorage(), UNO_QUERY_THROW );
if ( xCurrentStorage != _rxTargetStorage )
xCurrentStorage->copyToStorage( _rxTargetStorage );
}
// write into target storage
::comphelper::NamedValueCollection aWriteArgs( _rMediaDescriptor );
lcl_triggerStatusIndicator_throw( aWriteArgs, _rDocGuard, true );
impl_writeStorage_throw( _rxTargetStorage, aWriteArgs );
lcl_triggerStatusIndicator_throw( aWriteArgs, _rDocGuard, false );
// commit target storage
OSL_VERIFY( tools::stor::commitStorageIfWriteable( _rxTargetStorage ) );
}
catch( const IOException& ) { throw; }
catch( const RuntimeException& ) { throw; }
catch ( const Exception& e )
{
throw IOException( e.Message, *const_cast< ODatabaseDocument* >( this ) );
}
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::storeToURL( const ::rtl::OUString& _rURL, const Sequence< PropertyValue >& _rArguments ) throw (IOException, RuntimeException)
{
DocumentGuard aGuard( *this );
ModifyLock aLock( *this );
{
aGuard.clear();
m_aEventNotifier.notifyDocumentEvent( "OnSaveTo", NULL, makeAny( _rURL ) );
aGuard.reset();
}
try
{
// create storage for target URL
Reference< XStorage > xTargetStorage( impl_createStorageFor_throw( _rURL ) );
// extend media descriptor with URL
Sequence< PropertyValue > aMediaDescriptor( lcl_appendFileNameToDescriptor( _rArguments, _rURL ) );
// store to this storage
impl_storeToStorage_throw( xTargetStorage, aMediaDescriptor, aGuard );
}
catch( const Exception& )
{
Any aError = ::cppu::getCaughtException();
m_aEventNotifier.notifyDocumentEventAsync( "OnSaveToFailed", NULL, aError );
if ( aError.isExtractableTo( ::cppu::UnoType< IOException >::get() )
|| aError.isExtractableTo( ::cppu::UnoType< RuntimeException >::get() )
)
{
// allowed to leave
throw;
}
impl_throwIOExceptionCausedBySave_throw( aError, _rURL );
}
m_aEventNotifier.notifyDocumentEventAsync( "OnSaveToDone", NULL, makeAny( _rURL ) );
}
// -----------------------------------------------------------------------------
// XModifyBroadcaster
void SAL_CALL ODatabaseDocument::addModifyListener( const Reference< XModifyListener >& _xListener ) throw (RuntimeException)
{
DocumentGuard aGuard( *this );
m_aModifyListeners.addInterface(_xListener);
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::removeModifyListener( const Reference< XModifyListener >& _xListener ) throw (RuntimeException)
{
DocumentGuard aGuard( *this );
m_aModifyListeners.removeInterface(_xListener);
}
// -----------------------------------------------------------------------------
// XModifiable
sal_Bool SAL_CALL ODatabaseDocument::isModified( ) throw (RuntimeException)
{
DocumentGuard aGuard( *this );
return m_pImpl->m_bModified;
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::setModified( sal_Bool _bModified ) throw (PropertyVetoException, RuntimeException)
{
DocumentGuard aGuard( *this, DocumentGuard::MethodWithoutInit );
if ( impl_isInitialized() )
impl_setModified_nothrow( _bModified, aGuard );
// it's allowed to call setModified without the document being initialized already. In this case,
// we simply ignore the call - when the initialization is finished, the respective code will set
// a proper "modified" flag
}
// -----------------------------------------------------------------------------
void ODatabaseDocument::impl_setModified_nothrow( sal_Bool _bModified, DocumentGuard& _rGuard )
{
// SYNCHRONIZED ->
bool bModifiedChanged = ( m_pImpl->m_bModified != _bModified ) && ( !m_pImpl->isModifyLocked() );
if ( bModifiedChanged )
{
m_pImpl->m_bModified = _bModified;
m_aEventNotifier.notifyDocumentEventAsync( "OnModifyChanged" );
}
_rGuard.clear();
// <- SYNCHRONIZED
if ( bModifiedChanged )
{
lang::EventObject aEvent( *this );
m_aModifyListeners.notifyEach( &XModifyListener::modified, aEvent );
}
}
// -----------------------------------------------------------------------------
// ::com::sun::star::document::XEventBroadcaster
void SAL_CALL ODatabaseDocument::addEventListener(const uno::Reference< document::XEventListener >& _Listener ) throw (uno::RuntimeException)
{
m_aEventNotifier.addLegacyEventListener( _Listener );
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::removeEventListener( const uno::Reference< document::XEventListener >& _Listener ) throw (uno::RuntimeException)
{
m_aEventNotifier.removeLegacyEventListener( _Listener );
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::addDocumentEventListener( const Reference< XDocumentEventListener >& _Listener ) throw (RuntimeException)
{
m_aEventNotifier.addDocumentEventListener( _Listener );
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::removeDocumentEventListener( const Reference< XDocumentEventListener >& _Listener ) throw (RuntimeException)
{
m_aEventNotifier.removeDocumentEventListener( _Listener );
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::notifyDocumentEvent( const ::rtl::OUString& _EventName, const Reference< XController2 >& _ViewController, const Any& _Supplement ) throw (IllegalArgumentException, NoSupportException, RuntimeException)
{
if ( !_EventName.getLength() )
throw IllegalArgumentException( ::rtl::OUString(), *this, 1 );
// SYNCHRONIZED ->
DocumentGuard aGuard( *this );
if ( !DocumentEvents::needsSynchronousNotification( _EventName ) )
{
m_aEventNotifier.notifyDocumentEventAsync( _EventName, _ViewController, _Supplement );
return;
}
aGuard.clear();
// <- SYNCHRONIZED
m_aEventNotifier.notifyDocumentEvent( _EventName, _ViewController, _Supplement );
}
// -----------------------------------------------------------------------------
Sequence< PropertyValue > SAL_CALL ODatabaseDocument::getPrinter( ) throw (RuntimeException)
{
DBG_ERROR( "ODatabaseDocument::getPrinter: not supported!" );
return Sequence< PropertyValue >();
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::setPrinter( const Sequence< PropertyValue >& /*aPrinter*/ ) throw (IllegalArgumentException, RuntimeException)
{
DBG_ERROR( "ODatabaseDocument::setPrinter: not supported!" );
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::print( const Sequence< PropertyValue >& /*xOptions*/ ) throw (IllegalArgumentException, RuntimeException)
{
DBG_ERROR( "ODatabaseDocument::print: not supported!" );
}
// -----------------------------------------------------------------------------
void ODatabaseDocument::impl_reparent_nothrow( const WeakReference< XNameAccess >& _rxContainer )
{
Reference< XChild > xChild( _rxContainer.get(), UNO_QUERY );
if ( xChild.is() )
xChild->setParent( *this );
}
// -----------------------------------------------------------------------------
void ODatabaseDocument::clearObjectContainer( WeakReference< XNameAccess >& _rxContainer)
{
Reference< XNameAccess > xContainer = _rxContainer;
::comphelper::disposeComponent( xContainer );
Reference< XChild > xChild( _rxContainer.get(),UNO_QUERY );
if ( xChild.is() )
xChild->setParent( NULL );
_rxContainer = Reference< XNameAccess >();
}
// -----------------------------------------------------------------------------
Reference< XNameAccess > ODatabaseDocument::impl_getDocumentContainer_throw( ODatabaseModelImpl::ObjectType _eType )
{
if ( ( _eType != ODatabaseModelImpl::E_FORM ) && ( _eType != ODatabaseModelImpl::E_REPORT ) )
throw IllegalArgumentException();
bool bFormsContainer = _eType == ODatabaseModelImpl::E_FORM;
WeakReference< XNameAccess >& rContainerRef( bFormsContainer ? m_xForms : m_xReports );
Reference< XNameAccess > xContainer = rContainerRef;
if ( !xContainer.is() )
{
Any aValue;
::com::sun::star::uno::Reference< ::com::sun::star::uno::XInterface > xMy(*this);
if ( dbtools::getDataSourceSetting(xMy,bFormsContainer ? "Forms" : "Reports",aValue) )
{
::rtl::OUString sSupportService;
aValue >>= sSupportService;
if ( sSupportService.getLength() )
{
Sequence<Any> aArgs(1);
aArgs[0] <<= NamedValue(::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("DatabaseDocument")),makeAny(xMy));
xContainer.set(m_pImpl->m_aContext.createComponentWithArguments(sSupportService,aArgs),UNO_QUERY);
rContainerRef = xContainer;
}
}
if ( !xContainer.is() )
{
TContentPtr& rContainerData( m_pImpl->getObjectContainer( _eType ) );
rContainerRef = xContainer = new ODocumentContainer( m_pImpl->m_aContext.getLegacyServiceFactory(), *this, rContainerData, bFormsContainer );
}
impl_reparent_nothrow( xContainer );
}
return xContainer;
}
// -----------------------------------------------------------------------------
void ODatabaseDocument::impl_closeControllerFrames_nolck_throw( sal_Bool _bDeliverOwnership )
{
Controllers aCopy = m_aControllers;
Controllers::iterator aEnd = aCopy.end();
for ( Controllers::iterator aIter = aCopy.begin(); aIter != aEnd ; ++aIter )
{
if ( !aIter->is() )
continue;
try
{
Reference< XCloseable> xFrame( (*aIter)->getFrame(), UNO_QUERY );
if ( xFrame.is() )
xFrame->close( _bDeliverOwnership );
}
catch( const CloseVetoException& ) { throw; }
catch( const Exception& )
{
DBG_UNHANDLED_EXCEPTION();
}
}
}
// -----------------------------------------------------------------------------
struct DisposeControllerFrame : public ::std::unary_function< Reference< XController >, void >
{
void operator()( const Reference< XController >& _rxController ) const
{
try
{
if ( !_rxController.is() )
return;
Reference< XFrame > xFrame( _rxController->getFrame() );
::comphelper::disposeComponent( xFrame );
}
catch( const Exception& )
{
DBG_UNHANDLED_EXCEPTION();
}
};
};
// -----------------------------------------------------------------------------
void ODatabaseDocument::impl_disposeControllerFrames_nothrow()
{
Controllers aCopy;
aCopy.swap( m_aControllers ); // ensure m_aControllers is empty afterwards
::std::for_each( aCopy.begin(), aCopy.end(), DisposeControllerFrame() );
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::close( sal_Bool _bDeliverOwnership ) throw (CloseVetoException, RuntimeException)
{
// nearly everything below can/must be done without our mutex locked, the below is just for
// the checks for being disposed and the like
// SYNCHRONIZED ->
{
DocumentGuard aGuard( *this );
m_bClosing = true;
}
// <- SYNCHRONIZED
try
{
// allow listeners to veto
lang::EventObject aEvent( *this );
m_aCloseListener.forEach< XCloseListener >(
boost::bind( &XCloseListener::queryClosing, _1, boost::cref( aEvent ), boost::cref( _bDeliverOwnership ) ) );
// notify that we're going to unload
m_aEventNotifier.notifyDocumentEvent( "OnPrepareUnload" );
impl_closeControllerFrames_nolck_throw( _bDeliverOwnership );
m_aCloseListener.notifyEach( &XCloseListener::notifyClosing, (const lang::EventObject&)aEvent );
dispose();
}
catch ( const Exception& )
{
::osl::MutexGuard aGuard( m_aMutex );
m_bClosing = false;
throw;
}
// SYNCHRONIZED ->
::osl::MutexGuard aGuard( m_aMutex );
m_bClosing = false;
// <- SYNCHRONIZED
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::addCloseListener( const Reference< ::com::sun::star::util::XCloseListener >& Listener ) throw (RuntimeException)
{
DocumentGuard aGuard( *this );
m_aCloseListener.addInterface(Listener);
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::removeCloseListener( const Reference< ::com::sun::star::util::XCloseListener >& Listener ) throw (RuntimeException)
{
DocumentGuard aGuard( *this );
m_aCloseListener.removeInterface(Listener);
}
// -----------------------------------------------------------------------------
Reference< XNameAccess > SAL_CALL ODatabaseDocument::getFormDocuments( ) throw (RuntimeException)
{
DocumentGuard aGuard( *this, DocumentGuard::MethodUsedDuringInit );
return impl_getDocumentContainer_throw( ODatabaseModelImpl::E_FORM );
}
// -----------------------------------------------------------------------------
Reference< XNameAccess > SAL_CALL ODatabaseDocument::getReportDocuments( ) throw (RuntimeException)
{
DocumentGuard aGuard( *this, DocumentGuard::MethodUsedDuringInit );
return impl_getDocumentContainer_throw( ODatabaseModelImpl::E_REPORT );
}
// -----------------------------------------------------------------------------
void ODatabaseDocument::WriteThroughComponent( const Reference< XComponent >& xComponent, const sal_Char* pStreamName,
const sal_Char* pServiceName, const Sequence< Any >& _rArguments, const Sequence< PropertyValue >& rMediaDesc,
const Reference<XStorage>& _xStorageToSaveTo ) const
{
OSL_ENSURE( pStreamName, "Need stream name!" );
OSL_ENSURE( pServiceName, "Need service name!" );
// open stream
::rtl::OUString sStreamName = ::rtl::OUString::createFromAscii( pStreamName );
Reference< XStream > xStream = _xStorageToSaveTo->openStreamElement( sStreamName, ElementModes::READWRITE | ElementModes::TRUNCATE );
if ( !xStream.is() )
return;
Reference< XOutputStream > xOutputStream( xStream->getOutputStream() );
OSL_ENSURE( xOutputStream.is(), "Can't create output stream in package!" );
if ( !xOutputStream.is() )
return;
Reference< XSeekable > xSeek( xOutputStream, UNO_QUERY );
if ( xSeek.is() )
xSeek->seek(0);
Reference< XPropertySet > xStreamProp( xOutputStream, UNO_QUERY_THROW );
xStreamProp->setPropertyValue( INFO_MEDIATYPE, makeAny( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( "text/xml" ) ) ) );
xStreamProp->setPropertyValue( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( "Compressed" ) ), makeAny( (sal_Bool)sal_True ) );
// write the stuff
WriteThroughComponent( xOutputStream, xComponent, pServiceName, _rArguments, rMediaDesc );
}
void ODatabaseDocument::WriteThroughComponent( const Reference< XOutputStream >& xOutputStream,
const Reference< XComponent >& xComponent, const sal_Char* pServiceName, const Sequence< Any >& _rArguments,
const Sequence< PropertyValue >& rMediaDesc ) const
{
OSL_ENSURE( xOutputStream.is(), "I really need an output stream!" );
OSL_ENSURE( xComponent.is(), "Need component!" );
OSL_ENSURE( NULL != pServiceName, "Need component name!" );
// get component
Reference< XActiveDataSource > xSaxWriter;
OSL_VERIFY( m_pImpl->m_aContext.createComponent( "com.sun.star.xml.sax.Writer", xSaxWriter ) );
if ( !xSaxWriter.is() )
return;
// connect XML writer to output stream
xSaxWriter->setOutputStream( xOutputStream );
// prepare arguments (prepend doc handler to given arguments)
Reference< XDocumentHandler > xDocHandler( xSaxWriter,UNO_QUERY);
Sequence<Any> aArgs( 1 + _rArguments.getLength() );
aArgs[0] <<= xDocHandler;
for ( sal_Int32 i = 0; i < _rArguments.getLength(); ++i )
aArgs[ i+1 ] = _rArguments[i];
// get filter component
Reference< XExporter > xExporter;
OSL_VERIFY( m_pImpl->m_aContext.createComponentWithArguments( pServiceName, aArgs, xExporter ) );
if ( !xExporter.is() )
return;
// connect model and filter
xExporter->setSourceDocument( xComponent );
// filter
Reference< XFilter > xFilter( xExporter, UNO_QUERY_THROW );
xFilter->filter( rMediaDesc );
}
// -----------------------------------------------------------------------------
void ODatabaseDocument::impl_writeStorage_throw( const Reference< XStorage >& _rxTargetStorage, const ::comphelper::NamedValueCollection& _rMediaDescriptor ) const
{
// extract status indicator
Sequence< Any > aDelegatorArguments;
lcl_extractStatusIndicator( _rMediaDescriptor, aDelegatorArguments );
/** property map for export info set */
comphelper::PropertyMapEntry aExportInfoMap[] =
{
{ MAP_LEN( "BaseURI"), 0,&::getCppuType( (::rtl::OUString *)0 ),beans::PropertyAttribute::MAYBEVOID, 0 },
{ MAP_LEN( "StreamName"), 0,&::getCppuType( (::rtl::OUString *)0 ),beans::PropertyAttribute::MAYBEVOID, 0 },
{ MAP_LEN( "UsePrettyPrinting" ), 0, &::getCppuType((sal_Bool*)0), beans::PropertyAttribute::MAYBEVOID, 0},
{ NULL, 0, 0, NULL, 0, 0 }
};
uno::Reference< beans::XPropertySet > xInfoSet( comphelper::GenericPropertySet_CreateInstance( new comphelper::PropertySetInfo( aExportInfoMap ) ) );
SvtSaveOptions aSaveOpt;
xInfoSet->setPropertyValue(rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("UsePrettyPrinting")), uno::makeAny(aSaveOpt.IsPrettyPrinting()));
if ( aSaveOpt.IsSaveRelFSys() )
xInfoSet->setPropertyValue(rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("BaseURI")), uno::makeAny(_rMediaDescriptor.getOrDefault("URL",::rtl::OUString())));
::rtl::OUString aVersion;
SvtSaveOptions::ODFDefaultVersion nDefVersion = aSaveOpt.GetODFDefaultVersion();
// older versions can not have this property set, it exists only starting from ODF1.2
if ( nDefVersion >= SvtSaveOptions::ODFVER_012 )
aVersion = ODFVER_012_TEXT;
if ( aVersion.getLength() )
{
try
{
xInfoSet->setPropertyValue( rtl::OUString(RTL_CONSTASCII_USTRINGPARAM( "Version" )), uno::makeAny( aVersion ) );
}
catch( uno::Exception& )
{
}
}
sal_Int32 nArgsLen = aDelegatorArguments.getLength();
aDelegatorArguments.realloc(nArgsLen+1);
aDelegatorArguments[nArgsLen++] <<= xInfoSet;
Reference< XPropertySet > xProp( _rxTargetStorage, UNO_QUERY_THROW );
xProp->setPropertyValue( INFO_MEDIATYPE, makeAny( (rtl::OUString)MIMETYPE_OASIS_OPENDOCUMENT_DATABASE ) );
Reference< XComponent > xComponent( *const_cast< ODatabaseDocument* >( this ), UNO_QUERY_THROW );
Sequence< PropertyValue > aMediaDescriptor;
_rMediaDescriptor >>= aMediaDescriptor;
xInfoSet->setPropertyValue(rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("StreamName")), uno::makeAny(::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("settings.xml"))));
WriteThroughComponent( xComponent, "settings.xml", "com.sun.star.comp.sdb.XMLSettingsExporter",
aDelegatorArguments, aMediaDescriptor, _rxTargetStorage );
xInfoSet->setPropertyValue(rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("StreamName")), uno::makeAny(::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("content.xml"))));
WriteThroughComponent( xComponent, "content.xml", "com.sun.star.comp.sdb.DBExportFilter",
aDelegatorArguments, aMediaDescriptor, _rxTargetStorage );
m_pImpl->storeLibraryContainersTo( _rxTargetStorage );
}
// -----------------------------------------------------------------------------
Reference< XUIConfigurationManager > SAL_CALL ODatabaseDocument::getUIConfigurationManager( ) throw (RuntimeException)
{
DocumentGuard aGuard( *this );
if ( !m_xUIConfigurationManager.is() )
{
m_pImpl->m_aContext.createComponent( "com.sun.star.ui.UIConfigurationManager", m_xUIConfigurationManager );
Reference< XUIConfigurationStorage > xUIConfigStorage( m_xUIConfigurationManager, UNO_QUERY );
if ( xUIConfigStorage.is() )
{
rtl::OUString aUIConfigFolderName( RTL_CONSTASCII_USTRINGPARAM( "Configurations2" ));
Reference< XStorage > xConfigStorage;
// First try to open with READWRITE and then READ
xConfigStorage = getDocumentSubStorage( aUIConfigFolderName, ElementModes::READWRITE );
if ( xConfigStorage.is() )
{
rtl::OUString aUIConfigMediaType( RTL_CONSTASCII_USTRINGPARAM( "application/vnd.sun.xml.ui.configuration" ));
rtl::OUString aMediaType;
Reference< XPropertySet > xPropSet( xConfigStorage, UNO_QUERY );
Any a = xPropSet->getPropertyValue( INFO_MEDIATYPE );
if ( !( a >>= aMediaType ) || ( aMediaType.getLength() == 0 ))
{
a <<= aUIConfigMediaType;
xPropSet->setPropertyValue( INFO_MEDIATYPE, a );
}
}
else
xConfigStorage = getDocumentSubStorage( aUIConfigFolderName, ElementModes::READ );
// initialize ui configuration manager with document substorage
xUIConfigStorage->setStorage( xConfigStorage );
}
}
return m_xUIConfigurationManager;
}
// -----------------------------------------------------------------------------
Reference< XStorage > SAL_CALL ODatabaseDocument::getDocumentSubStorage( const ::rtl::OUString& aStorageName, sal_Int32 nMode ) throw (RuntimeException)
{
DocumentGuard aGuard( *this );
Reference< XDocumentSubStorageSupplier > xStorageAccess( m_pImpl->getDocumentSubStorageSupplier() );
return xStorageAccess->getDocumentSubStorage( aStorageName, nMode );
}
// -----------------------------------------------------------------------------
Sequence< ::rtl::OUString > SAL_CALL ODatabaseDocument::getDocumentSubStoragesNames( ) throw (::com::sun::star::io::IOException, RuntimeException)
{
Reference< XDocumentSubStorageSupplier > xStorageAccess( m_pImpl->getDocumentSubStorageSupplier() );
return xStorageAccess->getDocumentSubStoragesNames();
}
//------------------------------------------------------------------------------
void ODatabaseDocument::impl_notifyStorageChange_nolck_nothrow( const Reference< XStorage >& _rxNewRootStorage )
{
Reference< XInterface > xMe( *const_cast< ODatabaseDocument* >( this ) );
m_aStorageListeners.forEach< XStorageChangeListener >(
boost::bind( &XStorageChangeListener::notifyStorageChange, _1, boost::cref( xMe ), boost::cref( _rxNewRootStorage ) ) );
}
//------------------------------------------------------------------------------
void ODatabaseDocument::disposing()
{
OSL_TRACE( "DD: disp: %p: %p", this, m_pImpl.get() );
if ( !m_pImpl.is() )
{
// this means that we're already disposed
DBG_ASSERT( ODatabaseDocument_OfficeDocument::rBHelper.bDisposed, "ODatabaseDocument::disposing: no impl anymore, but not yet disposed!" );
return;
}
if ( impl_isInitialized() )
m_aEventNotifier.notifyDocumentEvent( "OnUnload" );
Reference< XModel > xHoldAlive( this );
m_aEventNotifier.disposing();
lang::EventObject aDisposeEvent(static_cast<XWeak*>(this));
m_aModifyListeners.disposeAndClear( aDisposeEvent );
m_aCloseListener.disposeAndClear( aDisposeEvent );
m_aStorageListeners.disposeAndClear( aDisposeEvent );
// this is the list of objects which we currently hold as member. Upon resetting
// those members, we can (potentially) release the last reference to them, in which
// case they will be deleted - if they're C++ implementations, that is :).
// Some of those implementations are offending enough to require the SolarMutex, which
// means we should not release the last reference while our own mutex is locked ...
::std::list< Reference< XInterface > > aKeepAlive;
// SYNCHRONIZED ->
::osl::ClearableMutexGuard aGuard( m_aMutex );
DBG_ASSERT( m_aControllers.empty(), "ODatabaseDocument::disposing: there still are controllers!" );
// normally, nobody should explicitly dispose, but only XCloseable::close the document. And upon
// closing, our controllers are closed, too
aKeepAlive.push_back( m_xUIConfigurationManager );
m_xUIConfigurationManager = NULL;
clearObjectContainer( m_xForms );
clearObjectContainer( m_xReports );
// reset the macro mode: in case the our impl struct stays alive (e.g. because our DataSource
// object still exists), and somebody subsequently re-opens the document, we want to have
// the security warning, again.
m_pImpl->resetMacroExecutionMode();
// similar argueing for our ViewMonitor
m_aViewMonitor.reset();
// tell our Impl to forget us
m_pImpl->modelIsDisposing( impl_isInitialized(), ODatabaseModelImpl::ResetModelAccess() );
// now, at the latest, the controller array should be empty. Controllers are
// expected to listen for our disposal, and disconnect then
DBG_ASSERT( m_aControllers.empty(), "ODatabaseDocument::disposing: there still are controllers!" );
impl_disposeControllerFrames_nothrow();
aKeepAlive.push_back( m_xModuleManager );
m_xModuleManager.clear();
aKeepAlive.push_back( m_xTitleHelper );
m_xTitleHelper.clear();
m_pImpl.clear();
aGuard.clear();
// <- SYNCHRONIZED
aKeepAlive.clear();
}
// -----------------------------------------------------------------------------
// XComponent
void SAL_CALL ODatabaseDocument::dispose( ) throw (RuntimeException)
{
::cppu::WeakComponentImplHelperBase::dispose();
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::addEventListener( const Reference< lang::XEventListener >& _xListener ) throw (RuntimeException)
{
::cppu::WeakComponentImplHelperBase::addEventListener( _xListener );
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::removeEventListener( const Reference< lang::XEventListener >& _xListener ) throw (RuntimeException)
{
::cppu::WeakComponentImplHelperBase::removeEventListener( _xListener );
}
// XServiceInfo
//------------------------------------------------------------------------------
rtl::OUString ODatabaseDocument::getImplementationName( ) throw(RuntimeException)
{
return getImplementationName_static();
}
//------------------------------------------------------------------------------
rtl::OUString ODatabaseDocument::getImplementationName_static( ) throw(RuntimeException)
{
return rtl::OUString::createFromAscii("com.sun.star.comp.dba.ODatabaseDocument");
}
//------------------------------------------------------------------------------
Sequence< ::rtl::OUString > ODatabaseDocument::getSupportedServiceNames( ) throw (RuntimeException)
{
return getSupportedServiceNames_static();
}
//------------------------------------------------------------------------------
Reference< XInterface > ODatabaseDocument::Create( const Reference< XComponentContext >& _rxContext )
{
::comphelper::ComponentContext aContext( _rxContext );
Reference< XUnoTunnel > xDBContextTunnel( aContext.createComponent( (::rtl::OUString)SERVICE_SDB_DATABASECONTEXT ), UNO_QUERY_THROW );
ODatabaseContext* pContext = reinterpret_cast< ODatabaseContext* >( xDBContextTunnel->getSomething( ODatabaseContext::getUnoTunnelImplementationId() ) );
::rtl::Reference<ODatabaseModelImpl> pImpl( new ODatabaseModelImpl( aContext.getLegacyServiceFactory(), *pContext ) );
Reference< XModel > xModel( pImpl->createNewModel_deliverOwnership( false ) );
return xModel.get();
}
//------------------------------------------------------------------------------
Sequence< ::rtl::OUString > ODatabaseDocument::getSupportedServiceNames_static( ) throw (RuntimeException)
{
Sequence< ::rtl::OUString > aSNS( 2 );
aSNS[0] = ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("com.sun.star.sdb.OfficeDatabaseDocument"));
aSNS[1] = ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("com.sun.star.document.OfficeDocument"));
return aSNS;
}
//------------------------------------------------------------------------------
sal_Bool ODatabaseDocument::supportsService( const ::rtl::OUString& _rServiceName ) throw (RuntimeException)
{
return ::comphelper::findValue(getSupportedServiceNames(), _rServiceName, sal_True).getLength() != 0;
}
// -----------------------------------------------------------------------------
Reference< XDataSource > SAL_CALL ODatabaseDocument::getDataSource() throw (RuntimeException)
{
DocumentGuard aGuard( *this, DocumentGuard::MethodWithoutInit );
return m_pImpl->getOrCreateDataSource();
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::loadFromStorage( const Reference< XStorage >& /*xStorage*/, const Sequence< PropertyValue >& /*aMediaDescriptor*/ ) throw (IllegalArgumentException, DoubleInitializationException, IOException, Exception, RuntimeException)
{
DocumentGuard aGuard( *this );
throw Exception(
DBACORE_RESSTRING( RID_STR_NO_EMBEDDING ),
*this
);
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::storeToStorage( const Reference< XStorage >& _rxStorage, const Sequence< PropertyValue >& _rMediaDescriptor ) throw (IllegalArgumentException, IOException, Exception, RuntimeException)
{
DocumentGuard aGuard( *this );
impl_storeToStorage_throw( _rxStorage, _rMediaDescriptor, aGuard );
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::switchToStorage( const Reference< XStorage >& _rxNewRootStorage ) throw (IllegalArgumentException, IOException, Exception, RuntimeException)
{
DocumentGuard aGuard( *this );
Reference< XStorage > xNewRootStorage( m_pImpl->switchToStorage( _rxNewRootStorage ) );
aGuard.clear();
impl_notifyStorageChange_nolck_nothrow( xNewRootStorage );
}
// -----------------------------------------------------------------------------
Reference< XStorage > SAL_CALL ODatabaseDocument::getDocumentStorage( ) throw (IOException, Exception, RuntimeException)
{
DocumentGuard aGuard( *this );
return m_pImpl->getOrCreateRootStorage();
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::addStorageChangeListener( const Reference< XStorageChangeListener >& _Listener ) throw (RuntimeException)
{
DocumentGuard aGuard( *this );
m_aStorageListeners.addInterface( _Listener );
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::removeStorageChangeListener( const Reference< XStorageChangeListener >& _Listener ) throw (RuntimeException)
{
DocumentGuard aGuard( *this );
m_aStorageListeners.addInterface( _Listener );
}
// -----------------------------------------------------------------------------
Reference< XStorageBasedLibraryContainer > SAL_CALL ODatabaseDocument::getBasicLibraries() throw (RuntimeException)
{
DocumentGuard aGuard( *this, DocumentGuard::MethodUsedDuringInit );
return m_pImpl->getLibraryContainer( true );
}
// -----------------------------------------------------------------------------
Reference< XStorageBasedLibraryContainer > SAL_CALL ODatabaseDocument::getDialogLibraries() throw (RuntimeException)
{
DocumentGuard aGuard( *this );
return m_pImpl->getLibraryContainer( false );
}
// -----------------------------------------------------------------------------
::sal_Bool SAL_CALL ODatabaseDocument::getAllowMacroExecution() throw (RuntimeException)
{
DocumentGuard aGuard( *this );
return m_pImpl->adjustMacroMode_AutoReject();
}
// -----------------------------------------------------------------------------
Reference< XEmbeddedScripts > SAL_CALL ODatabaseDocument::getScriptContainer() throw (RuntimeException)
{
DocumentGuard aGuard( *this );
return this;
}
// -----------------------------------------------------------------------------
Reference< provider::XScriptProvider > SAL_CALL ODatabaseDocument::getScriptProvider( ) throw (RuntimeException)
{
DocumentGuard aGuard( *this );
Reference< XScriptProvider > xScriptProvider( m_xScriptProvider );
if ( !xScriptProvider.is() )
{
Reference < XScriptProviderFactory > xFactory(
m_pImpl->m_aContext.getSingleton( "com.sun.star.script.provider.theMasterScriptProviderFactory" ), UNO_QUERY_THROW );
Any aScriptProviderContext;
if ( m_bAllowDocumentScripting )
aScriptProviderContext <<= Reference< XModel >( this );
xScriptProvider.set( xFactory->createScriptProvider( aScriptProviderContext ), UNO_SET_THROW );
m_xScriptProvider = xScriptProvider;
}
return xScriptProvider;
}
// -----------------------------------------------------------------------------
Reference< XNameReplace > SAL_CALL ODatabaseDocument::getEvents( ) throw (RuntimeException)
{
DocumentGuard aGuard( *this, DocumentGuard::MethodUsedDuringInit );
return m_pEventContainer;
}
// -----------------------------------------------------------------------------
void SAL_CALL ODatabaseDocument::disposing( const ::com::sun::star::lang::EventObject& Source ) throw(RuntimeException)
{
if ( m_pImpl.is() )
m_pImpl->disposing(Source);
}
//------------------------------------------------------------------
Reference< XInterface > ODatabaseDocument::getThis() const
{
return *const_cast< ODatabaseDocument* >( this );
}
// -----------------------------------------------------------------------------
struct CreateAny : public ::std::unary_function< Reference<XController>, Any>
{
Any operator() (const Reference<XController>& lhs) const
{
return makeAny(lhs);
}
};
// XModel2
Reference< XEnumeration > SAL_CALL ODatabaseDocument::getControllers( ) throw (RuntimeException)
{
DocumentGuard aGuard( *this );
uno::Sequence< Any> aController( m_aControllers.size() );
::std::transform( m_aControllers.begin(), m_aControllers.end(), aController.getArray(), CreateAny() );
return new ::comphelper::OAnyEnumeration(aController);
}
// -----------------------------------------------------------------------------
Sequence< ::rtl::OUString > SAL_CALL ODatabaseDocument::getAvailableViewControllerNames( ) throw (RuntimeException)
{
Sequence< ::rtl::OUString > aNames(1);
aNames[0] = SERVICE_SDB_APPLICATIONCONTROLLER;
return aNames;
}
// -----------------------------------------------------------------------------
Reference< XController2 > SAL_CALL ODatabaseDocument::createDefaultViewController( const Reference< XFrame >& _Frame ) throw (IllegalArgumentException, Exception, RuntimeException)
{
return createViewController(
::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( "Default" ) ),
Sequence< PropertyValue >(),
_Frame
);
}
// -----------------------------------------------------------------------------
Reference< XController2 > SAL_CALL ODatabaseDocument::createViewController( const ::rtl::OUString& _ViewName, const Sequence< PropertyValue >& _Arguments, const Reference< XFrame >& _Frame ) throw (IllegalArgumentException, Exception, RuntimeException)
{
if ( !_ViewName.equalsAscii( "Default" ) && !_ViewName.equalsAscii( "Preview" ) )
throw IllegalArgumentException( ::rtl::OUString(), *this, 1 );
if ( !_Frame.is() )
throw IllegalArgumentException( ::rtl::OUString(), *this, 3 );
DocumentGuard aGuard( *this );
::comphelper::ComponentContext aContext( m_pImpl->m_aContext );
aGuard.clear();
Reference< XController2 > xController;
aContext.createComponent( "org.openoffice.comp.dbu.OApplicationController", xController );
::comphelper::NamedValueCollection aInitArgs( _Arguments );
aInitArgs.put( "Frame", _Frame );
if ( _ViewName.equalsAscii( "Preview" ) )
aInitArgs.put( "Preview", sal_Bool( sal_True ) );
Reference< XInitialization > xInitController( xController, UNO_QUERY_THROW );
xInitController->initialize( aInitArgs.getWrappedPropertyValues() );
return xController;
}
// -----------------------------------------------------------------------------
//=============================================================================
Reference< XTitle > ODatabaseDocument::impl_getTitleHelper_throw()
{
if ( ! m_xTitleHelper.is ())
{
Reference< XUntitledNumbers > xDesktop(
m_pImpl->m_aContext.createComponent( "com.sun.star.frame.Desktop" ),
UNO_QUERY_THROW );
uno::Reference< frame::XModel > xThis (getThis(), uno::UNO_QUERY_THROW);
::framework::TitleHelper* pHelper = new ::framework::TitleHelper(m_pImpl->m_aContext.getLegacyServiceFactory());
m_xTitleHelper.set(static_cast< ::cppu::OWeakObject* >(pHelper), uno::UNO_QUERY_THROW);
pHelper->setOwner (xThis );
pHelper->connectWithUntitledNumbers (xDesktop);
}
return m_xTitleHelper;
}
//=============================================================================
uno::Reference< frame::XUntitledNumbers > ODatabaseDocument::impl_getUntitledHelper_throw(const uno::Reference< uno::XInterface >& _xComponent)
{
if ( !m_xModuleManager.is() )
m_xModuleManager.set( m_pImpl->m_aContext.createComponent( "com.sun.star.frame.ModuleManager" ), UNO_QUERY_THROW );
::rtl::OUString sModuleId;
try
{
sModuleId = m_xModuleManager->identify( _xComponent );
}
catch(uno::Exception)
{
// ni
}
uno::Reference< frame::XUntitledNumbers > xNumberedControllers;
TNumberedController::iterator aFind = m_aNumberedControllers.find(sModuleId);
if ( aFind == m_aNumberedControllers.end() )
{
uno::Reference< frame::XModel > xThis(static_cast< frame::XModel* >(this), uno::UNO_QUERY_THROW);
::comphelper::NumberedCollection* pHelper = new ::comphelper::NumberedCollection();
xNumberedControllers.set(static_cast< ::cppu::OWeakObject* >(pHelper), uno::UNO_QUERY_THROW);
pHelper->setOwner (xThis);
//pHelper->setUntitledPrefix (::rtl::OUString::createFromAscii(" : "));
m_aNumberedControllers.insert(TNumberedController::value_type(sModuleId,xNumberedControllers));
}
else
xNumberedControllers = aFind->second;
return xNumberedControllers;
}
//=============================================================================
// css.frame.XTitle
::rtl::OUString SAL_CALL ODatabaseDocument::getTitle()
throw (uno::RuntimeException)
{
// SYNCHRONIZED ->
DocumentGuard aGuard( *this, DocumentGuard::MethodUsedDuringInit );
return impl_getTitleHelper_throw()->getTitle();
}
//=============================================================================
// css.frame.XTitle
void SAL_CALL ODatabaseDocument::setTitle( const ::rtl::OUString& sTitle )
throw (uno::RuntimeException)
{
// SYNCHRONIZED ->
DocumentGuard aGuard( *this );
impl_getTitleHelper_throw()->setTitle( sTitle );
m_aEventNotifier.notifyDocumentEventAsync( "OnTitleChanged" );
// <- SYNCHRONIZED
}
//=============================================================================
// css.frame.XTitleChangeBroadcaster
void SAL_CALL ODatabaseDocument::addTitleChangeListener( const uno::Reference< frame::XTitleChangeListener >& xListener )
throw (uno::RuntimeException)
{
// SYNCHRONIZED ->
DocumentGuard aGuard( *this );
uno::Reference< frame::XTitleChangeBroadcaster > xBroadcaster( impl_getTitleHelper_throw(), uno::UNO_QUERY_THROW );
xBroadcaster->addTitleChangeListener( xListener );
}
//=============================================================================
// css.frame.XTitleChangeBroadcaster
void SAL_CALL ODatabaseDocument::removeTitleChangeListener( const uno::Reference< frame::XTitleChangeListener >& xListener )
throw (uno::RuntimeException)
{
// SYNCHRONIZED ->
DocumentGuard aGuard( *this );
uno::Reference< frame::XTitleChangeBroadcaster > xBroadcaster( impl_getTitleHelper_throw(), uno::UNO_QUERY_THROW );
xBroadcaster->removeTitleChangeListener( xListener );
}
//=============================================================================
// css.frame.XUntitledNumbers
::sal_Int32 SAL_CALL ODatabaseDocument::leaseNumber( const uno::Reference< uno::XInterface >& xComponent )
throw (lang::IllegalArgumentException,
uno::RuntimeException )
{
DocumentGuard aGuard( *this );
return impl_getUntitledHelper_throw(xComponent)->leaseNumber (xComponent);
}
//=============================================================================
// css.frame.XUntitledNumbers
void SAL_CALL ODatabaseDocument::releaseNumber( ::sal_Int32 nNumber )
throw (lang::IllegalArgumentException,
uno::RuntimeException )
{
DocumentGuard aGuard( *this );
impl_getUntitledHelper_throw()->releaseNumber (nNumber);
}
//=============================================================================
// css.frame.XUntitledNumbers
void SAL_CALL ODatabaseDocument::releaseNumberForComponent( const uno::Reference< uno::XInterface >& xComponent )
throw (lang::IllegalArgumentException,
uno::RuntimeException )
{
DocumentGuard aGuard( *this );
impl_getUntitledHelper_throw(xComponent)->releaseNumberForComponent (xComponent);
}
//=============================================================================
// css.frame.XUntitledNumbers
::rtl::OUString SAL_CALL ODatabaseDocument::getUntitledPrefix() throw (uno::RuntimeException)
{
return ::rtl::OUString();/*RTL_CONSTASCII_USTRINGPARAM(" : "));*/
}
//------------------------------------------------------------------
//........................................................................
} // namespace dbaccess
//........................................................................