1*9b5730f6SAndrew Rist /**************************************************************
2cdf0e10cSrcweir  *
3*9b5730f6SAndrew Rist  * Licensed to the Apache Software Foundation (ASF) under one
4*9b5730f6SAndrew Rist  * or more contributor license agreements.  See the NOTICE file
5*9b5730f6SAndrew Rist  * distributed with this work for additional information
6*9b5730f6SAndrew Rist  * regarding copyright ownership.  The ASF licenses this file
7*9b5730f6SAndrew Rist  * to you under the Apache License, Version 2.0 (the
8*9b5730f6SAndrew Rist  * "License"); you may not use this file except in compliance
9*9b5730f6SAndrew Rist  * with the License.  You may obtain a copy of the License at
10*9b5730f6SAndrew Rist  *
11*9b5730f6SAndrew Rist  *   http://www.apache.org/licenses/LICENSE-2.0
12*9b5730f6SAndrew Rist  *
13*9b5730f6SAndrew Rist  * Unless required by applicable law or agreed to in writing,
14*9b5730f6SAndrew Rist  * software distributed under the License is distributed on an
15*9b5730f6SAndrew Rist  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16*9b5730f6SAndrew Rist  * KIND, either express or implied.  See the License for the
17*9b5730f6SAndrew Rist  * specific language governing permissions and limitations
18*9b5730f6SAndrew Rist  * under the License.
19*9b5730f6SAndrew Rist  *
20*9b5730f6SAndrew Rist  *************************************************************/
21*9b5730f6SAndrew Rist 
22*9b5730f6SAndrew Rist 
23cdf0e10cSrcweir 
24cdf0e10cSrcweir // MARKER(update_precomp.py): autogen include statement, do not remove
25cdf0e10cSrcweir #include "precompiled_connectivity.hxx"
26cdf0e10cSrcweir #include "ZDriverWrapper.hxx"
27cdf0e10cSrcweir #include "ZConnectionPool.hxx"
28cdf0e10cSrcweir #include <osl/diagnose.h>
29cdf0e10cSrcweir 
30cdf0e10cSrcweir //........................................................................
31cdf0e10cSrcweir namespace connectivity
32cdf0e10cSrcweir {
33cdf0e10cSrcweir //........................................................................
34cdf0e10cSrcweir 
35cdf0e10cSrcweir 	using namespace ::com::sun::star::uno;
36cdf0e10cSrcweir 	using namespace ::com::sun::star::sdbc;
37cdf0e10cSrcweir 	using namespace ::com::sun::star::beans;
38cdf0e10cSrcweir 
39cdf0e10cSrcweir 	//====================================================================
40cdf0e10cSrcweir 	//= ODriverWrapper
41cdf0e10cSrcweir 	//====================================================================
42cdf0e10cSrcweir 	//--------------------------------------------------------------------
ODriverWrapper(Reference<XAggregation> & _rxAggregateDriver,OConnectionPool * _pPool)43cdf0e10cSrcweir 	ODriverWrapper::ODriverWrapper( Reference< XAggregation >& _rxAggregateDriver, OConnectionPool* _pPool )
44cdf0e10cSrcweir 		:m_pConnectionPool(_pPool)
45cdf0e10cSrcweir 	{
46cdf0e10cSrcweir 		OSL_ENSURE(_rxAggregateDriver.is(), "ODriverWrapper::ODriverWrapper: invalid aggregate!");
47cdf0e10cSrcweir 		OSL_ENSURE(m_pConnectionPool, "ODriverWrapper::ODriverWrapper: invalid connection pool!");
48cdf0e10cSrcweir 
49cdf0e10cSrcweir 		if (m_pConnectionPool)
50cdf0e10cSrcweir 			m_pConnectionPool->acquire();
51cdf0e10cSrcweir 
52cdf0e10cSrcweir 		osl_incrementInterlockedCount( &m_refCount );
53cdf0e10cSrcweir 		if (_rxAggregateDriver.is())
54cdf0e10cSrcweir 		{
55cdf0e10cSrcweir 			// transfer the (one and only) real ref to the aggregate to our member
56cdf0e10cSrcweir 			m_xDriverAggregate = _rxAggregateDriver;
57cdf0e10cSrcweir 			_rxAggregateDriver = NULL;
58cdf0e10cSrcweir 
59cdf0e10cSrcweir 			// a second "real" reference
60cdf0e10cSrcweir 			m_xDriver = Reference< XDriver >(m_xDriverAggregate, UNO_QUERY);
61cdf0e10cSrcweir 			OSL_ENSURE(m_xDriver.is(), "ODriverWrapper::ODriverWrapper: invalid aggregate (no XDriver)!");
62cdf0e10cSrcweir 
63cdf0e10cSrcweir 			// set ourself as delegator
64cdf0e10cSrcweir 			m_xDriverAggregate->setDelegator( static_cast< XWeak* >( this ) );
65cdf0e10cSrcweir 		}
66cdf0e10cSrcweir 		osl_decrementInterlockedCount( &m_refCount );
67cdf0e10cSrcweir 	}
68cdf0e10cSrcweir 
69cdf0e10cSrcweir 	//--------------------------------------------------------------------
~ODriverWrapper()70cdf0e10cSrcweir 	ODriverWrapper::~ODriverWrapper()
71cdf0e10cSrcweir 	{
72cdf0e10cSrcweir 		if (m_xDriverAggregate.is())
73cdf0e10cSrcweir 			m_xDriverAggregate->setDelegator(NULL);
74cdf0e10cSrcweir 
75cdf0e10cSrcweir 		if (m_pConnectionPool)
76cdf0e10cSrcweir 			m_pConnectionPool->release();
77cdf0e10cSrcweir 		m_pConnectionPool = NULL;
78cdf0e10cSrcweir 	}
79cdf0e10cSrcweir 
80cdf0e10cSrcweir 	//--------------------------------------------------------------------
queryInterface(const Type & _rType)81cdf0e10cSrcweir 	Any SAL_CALL ODriverWrapper::queryInterface( const Type& _rType ) throw (RuntimeException)
82cdf0e10cSrcweir 	{
83cdf0e10cSrcweir 		Any aReturn = ODriverWrapper_BASE::queryInterface(_rType);
84cdf0e10cSrcweir 		return aReturn.hasValue() ? aReturn : (m_xDriverAggregate.is() ? m_xDriverAggregate->queryAggregation(_rType) : aReturn);
85cdf0e10cSrcweir 	}
86cdf0e10cSrcweir 
87cdf0e10cSrcweir 	//--------------------------------------------------------------------
connect(const::rtl::OUString & url,const Sequence<PropertyValue> & info)88cdf0e10cSrcweir 	Reference< XConnection > SAL_CALL ODriverWrapper::connect( const ::rtl::OUString& url, const Sequence< PropertyValue >& info ) throw (SQLException, RuntimeException)
89cdf0e10cSrcweir 	{
90cdf0e10cSrcweir 		Reference< XConnection > xConnection;
91cdf0e10cSrcweir 		if (m_pConnectionPool)
92cdf0e10cSrcweir 			// route this through the pool
93cdf0e10cSrcweir 			xConnection = m_pConnectionPool->getConnectionWithInfo( url, info );
94cdf0e10cSrcweir 		else if (m_xDriver.is())
95cdf0e10cSrcweir 			xConnection = m_xDriver->connect( url, info );
96cdf0e10cSrcweir 
97cdf0e10cSrcweir 		return xConnection;
98cdf0e10cSrcweir 	}
99cdf0e10cSrcweir 
100cdf0e10cSrcweir 	//--------------------------------------------------------------------
acceptsURL(const::rtl::OUString & url)101cdf0e10cSrcweir 	sal_Bool SAL_CALL ODriverWrapper::acceptsURL( const ::rtl::OUString& url ) throw (SQLException, RuntimeException)
102cdf0e10cSrcweir 	{
103cdf0e10cSrcweir 		return m_xDriver.is() && m_xDriver->acceptsURL(url);
104cdf0e10cSrcweir 	}
105cdf0e10cSrcweir 
106cdf0e10cSrcweir 	//--------------------------------------------------------------------
getPropertyInfo(const::rtl::OUString & url,const Sequence<PropertyValue> & info)107cdf0e10cSrcweir 	Sequence< DriverPropertyInfo > SAL_CALL ODriverWrapper::getPropertyInfo( const ::rtl::OUString& url, const Sequence< PropertyValue >& info ) throw (SQLException, RuntimeException)
108cdf0e10cSrcweir 	{
109cdf0e10cSrcweir 		Sequence< DriverPropertyInfo > aInfo;
110cdf0e10cSrcweir 		if (m_xDriver.is())
111cdf0e10cSrcweir 			aInfo = m_xDriver->getPropertyInfo(url, info);
112cdf0e10cSrcweir 		return aInfo;
113cdf0e10cSrcweir 	}
114cdf0e10cSrcweir 
115cdf0e10cSrcweir 	//--------------------------------------------------------------------
getMajorVersion()116cdf0e10cSrcweir 	sal_Int32 SAL_CALL ODriverWrapper::getMajorVersion(  ) throw (RuntimeException)
117cdf0e10cSrcweir 	{
118cdf0e10cSrcweir 		return m_xDriver.is() ? m_xDriver->getMajorVersion() : 0;
119cdf0e10cSrcweir 	}
120cdf0e10cSrcweir 
121cdf0e10cSrcweir 	//--------------------------------------------------------------------
getMinorVersion()122cdf0e10cSrcweir 	sal_Int32 SAL_CALL ODriverWrapper::getMinorVersion(  ) throw (RuntimeException)
123cdf0e10cSrcweir 	{
124cdf0e10cSrcweir 		return m_xDriver.is() ? m_xDriver->getMinorVersion() : 0;
125cdf0e10cSrcweir 	}
126cdf0e10cSrcweir 
127cdf0e10cSrcweir //........................................................................
128cdf0e10cSrcweir }	// namespace connectivity
129cdf0e10cSrcweir //........................................................................
130cdf0e10cSrcweir 
131cdf0e10cSrcweir 
132