1*b1cdbd2cSJim Jagielski /************************************************************** 2*b1cdbd2cSJim Jagielski * 3*b1cdbd2cSJim Jagielski * Licensed to the Apache Software Foundation (ASF) under one 4*b1cdbd2cSJim Jagielski * or more contributor license agreements. See the NOTICE file 5*b1cdbd2cSJim Jagielski * distributed with this work for additional information 6*b1cdbd2cSJim Jagielski * regarding copyright ownership. The ASF licenses this file 7*b1cdbd2cSJim Jagielski * to you under the Apache License, Version 2.0 (the 8*b1cdbd2cSJim Jagielski * "License"); you may not use this file except in compliance 9*b1cdbd2cSJim Jagielski * with the License. You may obtain a copy of the License at 10*b1cdbd2cSJim Jagielski * 11*b1cdbd2cSJim Jagielski * http://www.apache.org/licenses/LICENSE-2.0 12*b1cdbd2cSJim Jagielski * 13*b1cdbd2cSJim Jagielski * Unless required by applicable law or agreed to in writing, 14*b1cdbd2cSJim Jagielski * software distributed under the License is distributed on an 15*b1cdbd2cSJim Jagielski * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY 16*b1cdbd2cSJim Jagielski * KIND, either express or implied. See the License for the 17*b1cdbd2cSJim Jagielski * specific language governing permissions and limitations 18*b1cdbd2cSJim Jagielski * under the License. 19*b1cdbd2cSJim Jagielski * 20*b1cdbd2cSJim Jagielski *************************************************************/ 21*b1cdbd2cSJim Jagielski 22*b1cdbd2cSJim Jagielski 23*b1cdbd2cSJim Jagielski #ifndef CONNECTIVITY_POOLCOLLECTION_HXX 24*b1cdbd2cSJim Jagielski #define CONNECTIVITY_POOLCOLLECTION_HXX 25*b1cdbd2cSJim Jagielski 26*b1cdbd2cSJim Jagielski #include <cppuhelper/implbase5.hxx> 27*b1cdbd2cSJim Jagielski #include <com/sun/star/beans/XPropertyChangeListener.hpp> 28*b1cdbd2cSJim Jagielski #include <com/sun/star/sdbc/XDriverManager.hpp> 29*b1cdbd2cSJim Jagielski #include <com/sun/star/sdbc/XDriver.hpp> 30*b1cdbd2cSJim Jagielski #include <com/sun/star/sdbc/XDriverAccess.hpp> 31*b1cdbd2cSJim Jagielski #include <com/sun/star/sdbc/XPooledConnection.hpp> 32*b1cdbd2cSJim Jagielski #include <com/sun/star/sdbc/XConnection.hpp> 33*b1cdbd2cSJim Jagielski #include <com/sun/star/lang/XMultiServiceFactory.hpp> 34*b1cdbd2cSJim Jagielski #include <com/sun/star/lang/XServiceInfo.hpp> 35*b1cdbd2cSJim Jagielski #include <com/sun/star/lang/XEventListener.hpp> 36*b1cdbd2cSJim Jagielski #include <com/sun/star/frame/XDesktop.hpp> 37*b1cdbd2cSJim Jagielski #include <com/sun/star/frame/XTerminateListener.hpp> 38*b1cdbd2cSJim Jagielski #include <com/sun/star/reflection/XProxyFactory.hpp> 39*b1cdbd2cSJim Jagielski #include <comphelper/stl_types.hxx> 40*b1cdbd2cSJim Jagielski #include <osl/mutex.hxx> 41*b1cdbd2cSJim Jagielski 42*b1cdbd2cSJim Jagielski namespace connectivity 43*b1cdbd2cSJim Jagielski { 44*b1cdbd2cSJim Jagielski class OConnectionPool; 45*b1cdbd2cSJim Jagielski //========================================================================== 46*b1cdbd2cSJim Jagielski //= OPoolCollection - the one-instance service for PooledConnections 47*b1cdbd2cSJim Jagielski //= manages the active connections and the connections in the pool 48*b1cdbd2cSJim Jagielski //========================================================================== 49*b1cdbd2cSJim Jagielski typedef ::cppu::WeakImplHelper5< ::com::sun::star::sdbc::XDriverManager, 50*b1cdbd2cSJim Jagielski ::com::sun::star::sdbc::XDriverAccess, 51*b1cdbd2cSJim Jagielski ::com::sun::star::lang::XServiceInfo, 52*b1cdbd2cSJim Jagielski ::com::sun::star::frame::XTerminateListener, 53*b1cdbd2cSJim Jagielski ::com::sun::star::beans::XPropertyChangeListener 54*b1cdbd2cSJim Jagielski > OPoolCollection_Base; 55*b1cdbd2cSJim Jagielski 56*b1cdbd2cSJim Jagielski /// OPoolCollection: controll the whole connection pooling for oo 57*b1cdbd2cSJim Jagielski class OPoolCollection : public OPoolCollection_Base 58*b1cdbd2cSJim Jagielski { 59*b1cdbd2cSJim Jagielski 60*b1cdbd2cSJim Jagielski //========================================================================== 61*b1cdbd2cSJim Jagielski typedef ::comphelper::OInterfaceCompare< ::com::sun::star::sdbc::XDriver > ODriverCompare; 62*b1cdbd2cSJim Jagielski DECLARE_STL_USTRINGACCESS_MAP(OConnectionPool*, OConnectionPools); 63*b1cdbd2cSJim Jagielski 64*b1cdbd2cSJim Jagielski DECLARE_STL_MAP( 65*b1cdbd2cSJim Jagielski ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XDriver >, 66*b1cdbd2cSJim Jagielski ::com::sun::star::uno::WeakReference< ::com::sun::star::sdbc::XDriver >, 67*b1cdbd2cSJim Jagielski ODriverCompare, 68*b1cdbd2cSJim Jagielski MapDriver2DriverRef ); 69*b1cdbd2cSJim Jagielski 70*b1cdbd2cSJim Jagielski MapDriver2DriverRef m_aDriverProxies; 71*b1cdbd2cSJim Jagielski ::osl::Mutex m_aMutex; 72*b1cdbd2cSJim Jagielski OConnectionPools m_aPools; // the driver pools 73*b1cdbd2cSJim Jagielski ::com::sun::star::uno::Reference< ::com::sun::star::lang::XMultiServiceFactory > m_xServiceFactory; 74*b1cdbd2cSJim Jagielski ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XDriverManager > m_xManager; 75*b1cdbd2cSJim Jagielski ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XDriverAccess > m_xDriverAccess; 76*b1cdbd2cSJim Jagielski ::com::sun::star::uno::Reference< ::com::sun::star::reflection::XProxyFactory > m_xProxyFactory; 77*b1cdbd2cSJim Jagielski ::com::sun::star::uno::Reference< ::com::sun::star::uno::XInterface > m_xConfigNode; // config node for generel connection pooling 78*b1cdbd2cSJim Jagielski ::com::sun::star::uno::Reference< ::com::sun::star::frame::XDesktop> m_xDesktop; 79*b1cdbd2cSJim Jagielski 80*b1cdbd2cSJim Jagielski private: 81*b1cdbd2cSJim Jagielski OPoolCollection(); // never implemented 82*b1cdbd2cSJim Jagielski OPoolCollection(const OPoolCollection&); // never implemented 83*b1cdbd2cSJim Jagielski int operator= (const OPoolCollection&); // never implemented 84*b1cdbd2cSJim Jagielski 85*b1cdbd2cSJim Jagielski OPoolCollection( 86*b1cdbd2cSJim Jagielski const ::com::sun::star::uno::Reference< ::com::sun::star::lang::XMultiServiceFactory >& _rxFactory); 87*b1cdbd2cSJim Jagielski 88*b1cdbd2cSJim Jagielski // some configuration helper methods 89*b1cdbd2cSJim Jagielski ::com::sun::star::uno::Reference< ::com::sun::star::uno::XInterface > createWithServiceFactory(const ::rtl::OUString& _rPath) const; 90*b1cdbd2cSJim Jagielski ::com::sun::star::uno::Reference< ::com::sun::star::uno::XInterface > getConfigPoolRoot(); 91*b1cdbd2cSJim Jagielski ::com::sun::star::uno::Reference< ::com::sun::star::uno::XInterface > createWithProvider( const ::com::sun::star::uno::Reference< ::com::sun::star::lang::XMultiServiceFactory >& _rxConfProvider, 92*b1cdbd2cSJim Jagielski const ::rtl::OUString& _rPath) const; 93*b1cdbd2cSJim Jagielski ::com::sun::star::uno::Reference< ::com::sun::star::uno::XInterface > openNode( const ::rtl::OUString& _rPath, 94*b1cdbd2cSJim Jagielski const ::com::sun::star::uno::Reference< ::com::sun::star::uno::XInterface >& _xTreeNode) const throw(); 95*b1cdbd2cSJim Jagielski sal_Bool isPoolingEnabled(); 96*b1cdbd2cSJim Jagielski sal_Bool isDriverPoolingEnabled(const ::rtl::OUString& _sDriverImplName, 97*b1cdbd2cSJim Jagielski ::com::sun::star::uno::Reference< ::com::sun::star::uno::XInterface >& _rxDriverNode); 98*b1cdbd2cSJim Jagielski sal_Bool isPoolingEnabledByUrl( const ::rtl::OUString& _sUrl, 99*b1cdbd2cSJim Jagielski ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XDriver >& _rxDriver, 100*b1cdbd2cSJim Jagielski ::rtl::OUString& _rsImplName, 101*b1cdbd2cSJim Jagielski ::com::sun::star::uno::Reference< ::com::sun::star::uno::XInterface >& _rxDriverNode); 102*b1cdbd2cSJim Jagielski 103*b1cdbd2cSJim Jagielski OConnectionPool* getConnectionPool( const ::rtl::OUString& _sImplName, 104*b1cdbd2cSJim Jagielski const ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XDriver >& _xDriver, 105*b1cdbd2cSJim Jagielski const ::com::sun::star::uno::Reference< ::com::sun::star::uno::XInterface >& _rxDriverNode); 106*b1cdbd2cSJim Jagielski void clearConnectionPools(sal_Bool _bDispose); 107*b1cdbd2cSJim Jagielski void clearDesktop(); 108*b1cdbd2cSJim Jagielski protected: 109*b1cdbd2cSJim Jagielski virtual ~OPoolCollection(); 110*b1cdbd2cSJim Jagielski public: 111*b1cdbd2cSJim Jagielski 112*b1cdbd2cSJim Jagielski static ::com::sun::star::uno::Any getNodeValue( const ::rtl::OUString& _rPath, 113*b1cdbd2cSJim Jagielski const ::com::sun::star::uno::Reference< ::com::sun::star::uno::XInterface>& _xTreeNode)throw(); 114*b1cdbd2cSJim Jagielski 115*b1cdbd2cSJim Jagielski // XDriverManager 116*b1cdbd2cSJim Jagielski 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); 117*b1cdbd2cSJim Jagielski 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); 118*b1cdbd2cSJim Jagielski virtual void SAL_CALL setLoginTimeout( sal_Int32 seconds ) throw(::com::sun::star::uno::RuntimeException); 119*b1cdbd2cSJim Jagielski virtual sal_Int32 SAL_CALL getLoginTimeout( ) throw(::com::sun::star::uno::RuntimeException); 120*b1cdbd2cSJim Jagielski 121*b1cdbd2cSJim Jagielski //XDriverAccess 122*b1cdbd2cSJim Jagielski virtual ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XDriver > SAL_CALL getDriverByURL( const ::rtl::OUString& url ) throw (::com::sun::star::uno::RuntimeException); 123*b1cdbd2cSJim Jagielski // XServiceInfo 124*b1cdbd2cSJim Jagielski virtual ::rtl::OUString SAL_CALL getImplementationName( ) throw(::com::sun::star::uno::RuntimeException); 125*b1cdbd2cSJim Jagielski virtual sal_Bool SAL_CALL supportsService( const ::rtl::OUString& ServiceName ) throw(::com::sun::star::uno::RuntimeException); 126*b1cdbd2cSJim Jagielski virtual ::com::sun::star::uno::Sequence< ::rtl::OUString > SAL_CALL getSupportedServiceNames( ) throw(::com::sun::star::uno::RuntimeException); 127*b1cdbd2cSJim Jagielski 128*b1cdbd2cSJim Jagielski // XServiceInfo - static methods 129*b1cdbd2cSJim Jagielski 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 >&); 130*b1cdbd2cSJim Jagielski static ::rtl::OUString SAL_CALL getImplementationName_Static( ) throw(::com::sun::star::uno::RuntimeException); 131*b1cdbd2cSJim Jagielski static ::com::sun::star::uno::Sequence< ::rtl::OUString > SAL_CALL getSupportedServiceNames_Static( ) throw(::com::sun::star::uno::RuntimeException); 132*b1cdbd2cSJim Jagielski 133*b1cdbd2cSJim Jagielski // XEventListener 134*b1cdbd2cSJim Jagielski virtual void SAL_CALL disposing( const ::com::sun::star::lang::EventObject& Source ) throw (::com::sun::star::uno::RuntimeException); 135*b1cdbd2cSJim Jagielski // XPropertyChangeListener 136*b1cdbd2cSJim Jagielski virtual void SAL_CALL propertyChange( const ::com::sun::star::beans::PropertyChangeEvent& evt ) throw (::com::sun::star::uno::RuntimeException); 137*b1cdbd2cSJim Jagielski 138*b1cdbd2cSJim Jagielski // XTerminateListener 139*b1cdbd2cSJim Jagielski virtual void SAL_CALL queryTermination( const ::com::sun::star::lang::EventObject& Event ) throw (::com::sun::star::frame::TerminationVetoException, ::com::sun::star::uno::RuntimeException); 140*b1cdbd2cSJim Jagielski virtual void SAL_CALL notifyTermination( const ::com::sun::star::lang::EventObject& Event ) throw (::com::sun::star::uno::RuntimeException); 141*b1cdbd2cSJim Jagielski }; 142*b1cdbd2cSJim Jagielski } 143*b1cdbd2cSJim Jagielski #endif // CONNECTIVITY_POOLCOLLECTION_HXX 144*b1cdbd2cSJim Jagielski 145