diff options
Diffstat (limited to 'connectivity/source/cpool/ZPoolCollection.hxx')
| -rw-r--r-- | connectivity/source/cpool/ZPoolCollection.hxx | 148 |
1 files changed, 148 insertions, 0 deletions
diff --git a/connectivity/source/cpool/ZPoolCollection.hxx b/connectivity/source/cpool/ZPoolCollection.hxx new file mode 100644 index 000000000000..039f29efa241 --- /dev/null +++ b/connectivity/source/cpool/ZPoolCollection.hxx @@ -0,0 +1,148 @@ +/************************************************************************* + * + * 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. + * + ************************************************************************/ +#ifndef CONNECTIVITY_POOLCOLLECTION_HXX +#define CONNECTIVITY_POOLCOLLECTION_HXX + +#include <cppuhelper/implbase5.hxx> +#include <com/sun/star/beans/XPropertyChangeListener.hpp> +#include <com/sun/star/sdbc/XDriverManager.hpp> +#include <com/sun/star/sdbc/XDriver.hpp> +#include <com/sun/star/sdbc/XDriverAccess.hpp> +#include <com/sun/star/sdbc/XPooledConnection.hpp> +#include <com/sun/star/sdbc/XConnection.hpp> +#include <com/sun/star/lang/XMultiServiceFactory.hpp> +#include <com/sun/star/lang/XServiceInfo.hpp> +#include <com/sun/star/lang/XEventListener.hpp> +#include <com/sun/star/frame/XDesktop.hpp> +#include <com/sun/star/frame/XTerminateListener.hpp> +#include <com/sun/star/reflection/XProxyFactory.hpp> +#include <comphelper/stl_types.hxx> +#include <osl/mutex.hxx> + +namespace connectivity +{ + class OConnectionPool; + //========================================================================== + //= OPoolCollection - the one-instance service for PooledConnections + //= manages the active connections and the connections in the pool + //========================================================================== + typedef ::cppu::WeakImplHelper5< ::com::sun::star::sdbc::XDriverManager, + ::com::sun::star::sdbc::XDriverAccess, + ::com::sun::star::lang::XServiceInfo, + ::com::sun::star::frame::XTerminateListener, + ::com::sun::star::beans::XPropertyChangeListener + > OPoolCollection_Base; + + /// OPoolCollection: controll the whole connection pooling for oo + class OPoolCollection : public OPoolCollection_Base + { + + //========================================================================== + typedef ::comphelper::OInterfaceCompare< ::com::sun::star::sdbc::XDriver > ODriverCompare; + DECLARE_STL_USTRINGACCESS_MAP(OConnectionPool*, OConnectionPools); + + DECLARE_STL_MAP( + ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XDriver >, + ::com::sun::star::uno::WeakReference< ::com::sun::star::sdbc::XDriver >, + ODriverCompare, + MapDriver2DriverRef ); + + MapDriver2DriverRef m_aDriverProxies; + ::osl::Mutex m_aMutex; + OConnectionPools m_aPools; // the driver pools + ::com::sun::star::uno::Reference< ::com::sun::star::lang::XMultiServiceFactory > m_xServiceFactory; + ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XDriverManager > m_xManager; + ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XDriverAccess > m_xDriverAccess; + ::com::sun::star::uno::Reference< ::com::sun::star::reflection::XProxyFactory > m_xProxyFactory; + ::com::sun::star::uno::Reference< ::com::sun::star::uno::XInterface > m_xConfigNode; // config node for generel connection pooling + ::com::sun::star::uno::Reference< ::com::sun::star::frame::XDesktop> m_xDesktop; + + private: + OPoolCollection(); // never implemented + OPoolCollection(const OPoolCollection&); // never implemented + int operator= (const OPoolCollection&); // never implemented + + OPoolCollection( + const ::com::sun::star::uno::Reference< ::com::sun::star::lang::XMultiServiceFactory >& _rxFactory); + + // some configuration helper methods + ::com::sun::star::uno::Reference< ::com::sun::star::uno::XInterface > createWithServiceFactory(const ::rtl::OUString& _rPath) const; + ::com::sun::star::uno::Reference< ::com::sun::star::uno::XInterface > getConfigPoolRoot(); + ::com::sun::star::uno::Reference< ::com::sun::star::uno::XInterface > createWithProvider( const ::com::sun::star::uno::Reference< ::com::sun::star::lang::XMultiServiceFactory >& _rxConfProvider, + const ::rtl::OUString& _rPath) const; + ::com::sun::star::uno::Reference< ::com::sun::star::uno::XInterface > openNode( const ::rtl::OUString& _rPath, + const ::com::sun::star::uno::Reference< ::com::sun::star::uno::XInterface >& _xTreeNode) const throw(); + sal_Bool isPoolingEnabled(); + sal_Bool isDriverPoolingEnabled(const ::rtl::OUString& _sDriverImplName, + ::com::sun::star::uno::Reference< ::com::sun::star::uno::XInterface >& _rxDriverNode); + sal_Bool isPoolingEnabledByUrl( const ::rtl::OUString& _sUrl, + ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XDriver >& _rxDriver, + ::rtl::OUString& _rsImplName, + ::com::sun::star::uno::Reference< ::com::sun::star::uno::XInterface >& _rxDriverNode); + + OConnectionPool* getConnectionPool( const ::rtl::OUString& _sImplName, + const ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XDriver >& _xDriver, + const ::com::sun::star::uno::Reference< ::com::sun::star::uno::XInterface >& _rxDriverNode); + void clearConnectionPools(sal_Bool _bDispose); + void clearDesktop(); + protected: + virtual ~OPoolCollection(); + public: + + static ::com::sun::star::uno::Any getNodeValue( const ::rtl::OUString& _rPath, + const ::com::sun::star::uno::Reference< ::com::sun::star::uno::XInterface>& _xTreeNode)throw(); + + // XDriverManager + virtual ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XConnection > SAL_CALL getConnection( const ::rtl::OUString& url ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); + virtual ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XConnection > SAL_CALL getConnectionWithInfo( const ::rtl::OUString& url, const ::com::sun::star::uno::Sequence< ::com::sun::star::beans::PropertyValue >& info ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); + virtual void SAL_CALL setLoginTimeout( sal_Int32 seconds ) throw(::com::sun::star::uno::RuntimeException); + virtual sal_Int32 SAL_CALL getLoginTimeout( ) throw(::com::sun::star::uno::RuntimeException); + + //XDriverAccess + virtual ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XDriver > SAL_CALL getDriverByURL( const ::rtl::OUString& url ) throw (::com::sun::star::uno::RuntimeException); + // XServiceInfo + virtual ::rtl::OUString SAL_CALL getImplementationName( ) throw(::com::sun::star::uno::RuntimeException); + virtual sal_Bool SAL_CALL supportsService( const ::rtl::OUString& ServiceName ) throw(::com::sun::star::uno::RuntimeException); + virtual ::com::sun::star::uno::Sequence< ::rtl::OUString > SAL_CALL getSupportedServiceNames( ) throw(::com::sun::star::uno::RuntimeException); + + // XServiceInfo - static methods + static ::com::sun::star::uno::Reference< ::com::sun::star::uno::XInterface > SAL_CALL CreateInstance(const::com::sun::star::uno::Reference< ::com::sun::star::lang::XMultiServiceFactory >&); + static ::rtl::OUString SAL_CALL getImplementationName_Static( ) throw(::com::sun::star::uno::RuntimeException); + static ::com::sun::star::uno::Sequence< ::rtl::OUString > SAL_CALL getSupportedServiceNames_Static( ) throw(::com::sun::star::uno::RuntimeException); + + // XEventListener + virtual void SAL_CALL disposing( const ::com::sun::star::lang::EventObject& Source ) throw (::com::sun::star::uno::RuntimeException); + // XPropertyChangeListener + virtual void SAL_CALL propertyChange( const ::com::sun::star::beans::PropertyChangeEvent& evt ) throw (::com::sun::star::uno::RuntimeException); + + // XTerminateListener + virtual void SAL_CALL queryTermination( const ::com::sun::star::lang::EventObject& Event ) throw (::com::sun::star::frame::TerminationVetoException, ::com::sun::star::uno::RuntimeException); + virtual void SAL_CALL notifyTermination( const ::com::sun::star::lang::EventObject& Event ) throw (::com::sun::star::uno::RuntimeException); + }; +} +#endif // CONNECTIVITY_POOLCOLLECTION_HXX + |