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
24*b1cdbd2cSJim Jagielski // MARKER(update_precomp.py): autogen include statement, do not remove
25*b1cdbd2cSJim Jagielski #include "precompiled_connectivity.hxx"
26*b1cdbd2cSJim Jagielski #include "ZConnectionWrapper.hxx"
27*b1cdbd2cSJim Jagielski #include <com/sun/star/sdbc/ColumnValue.hpp>
28*b1cdbd2cSJim Jagielski #include <com/sun/star/sdbc/XRow.hpp>
29*b1cdbd2cSJim Jagielski #include <com/sun/star/lang/DisposedException.hpp>
30*b1cdbd2cSJim Jagielski #include <comphelper/extract.hxx>
31*b1cdbd2cSJim Jagielski #include <cppuhelper/typeprovider.hxx>
32*b1cdbd2cSJim Jagielski #include <comphelper/sequence.hxx>
33*b1cdbd2cSJim Jagielski
34*b1cdbd2cSJim Jagielski using namespace connectivity;
35*b1cdbd2cSJim Jagielski //------------------------------------------------------------------------------
36*b1cdbd2cSJim Jagielski using namespace com::sun::star::uno;
37*b1cdbd2cSJim Jagielski using namespace com::sun::star::lang;
38*b1cdbd2cSJim Jagielski using namespace com::sun::star::beans;
39*b1cdbd2cSJim Jagielski using namespace com::sun::star::sdbc;
40*b1cdbd2cSJim Jagielski // --------------------------------------------------------------------------------
OConnectionWeakWrapper(Reference<XAggregation> & _xConnection)41*b1cdbd2cSJim Jagielski OConnectionWeakWrapper::OConnectionWeakWrapper(Reference< XAggregation >& _xConnection)
42*b1cdbd2cSJim Jagielski : OConnectionWeakWrapper_BASE(m_aMutex)
43*b1cdbd2cSJim Jagielski {
44*b1cdbd2cSJim Jagielski setDelegation(_xConnection,m_refCount);
45*b1cdbd2cSJim Jagielski OSL_ENSURE(m_xConnection.is(),"OConnectionWeakWrapper: Connection must be valid!");
46*b1cdbd2cSJim Jagielski }
47*b1cdbd2cSJim Jagielski //-----------------------------------------------------------------------------
~OConnectionWeakWrapper()48*b1cdbd2cSJim Jagielski OConnectionWeakWrapper::~OConnectionWeakWrapper()
49*b1cdbd2cSJim Jagielski {
50*b1cdbd2cSJim Jagielski if ( !OConnectionWeakWrapper_BASE::rBHelper.bDisposed )
51*b1cdbd2cSJim Jagielski {
52*b1cdbd2cSJim Jagielski osl_incrementInterlockedCount( &m_refCount );
53*b1cdbd2cSJim Jagielski dispose();
54*b1cdbd2cSJim Jagielski }
55*b1cdbd2cSJim Jagielski }
56*b1cdbd2cSJim Jagielski // XServiceInfo
57*b1cdbd2cSJim Jagielski // --------------------------------------------------------------------------------
58*b1cdbd2cSJim Jagielski IMPLEMENT_SERVICE_INFO(OConnectionWeakWrapper, "com.sun.star.sdbc.drivers.OConnectionWeakWrapper", "com.sun.star.sdbc.Connection")
59*b1cdbd2cSJim Jagielski
60*b1cdbd2cSJim Jagielski // --------------------------------------------------------------------------------
createStatement()61*b1cdbd2cSJim Jagielski Reference< XStatement > SAL_CALL OConnectionWeakWrapper::createStatement( ) throw(SQLException, RuntimeException)
62*b1cdbd2cSJim Jagielski {
63*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aMutex );
64*b1cdbd2cSJim Jagielski checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
65*b1cdbd2cSJim Jagielski
66*b1cdbd2cSJim Jagielski
67*b1cdbd2cSJim Jagielski return m_xConnection->createStatement();
68*b1cdbd2cSJim Jagielski }
69*b1cdbd2cSJim Jagielski // --------------------------------------------------------------------------------
prepareStatement(const::rtl::OUString & sql)70*b1cdbd2cSJim Jagielski Reference< XPreparedStatement > SAL_CALL OConnectionWeakWrapper::prepareStatement( const ::rtl::OUString& sql ) throw(SQLException, RuntimeException)
71*b1cdbd2cSJim Jagielski {
72*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aMutex );
73*b1cdbd2cSJim Jagielski checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
74*b1cdbd2cSJim Jagielski
75*b1cdbd2cSJim Jagielski
76*b1cdbd2cSJim Jagielski return m_xConnection->prepareStatement(sql);
77*b1cdbd2cSJim Jagielski }
78*b1cdbd2cSJim Jagielski // --------------------------------------------------------------------------------
prepareCall(const::rtl::OUString & sql)79*b1cdbd2cSJim Jagielski Reference< XPreparedStatement > SAL_CALL OConnectionWeakWrapper::prepareCall( const ::rtl::OUString& sql ) throw(SQLException, RuntimeException)
80*b1cdbd2cSJim Jagielski {
81*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aMutex );
82*b1cdbd2cSJim Jagielski checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
83*b1cdbd2cSJim Jagielski
84*b1cdbd2cSJim Jagielski
85*b1cdbd2cSJim Jagielski return m_xConnection->prepareCall(sql);
86*b1cdbd2cSJim Jagielski }
87*b1cdbd2cSJim Jagielski // --------------------------------------------------------------------------------
nativeSQL(const::rtl::OUString & sql)88*b1cdbd2cSJim Jagielski ::rtl::OUString SAL_CALL OConnectionWeakWrapper::nativeSQL( const ::rtl::OUString& sql ) throw(SQLException, RuntimeException)
89*b1cdbd2cSJim Jagielski {
90*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aMutex );
91*b1cdbd2cSJim Jagielski checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
92*b1cdbd2cSJim Jagielski
93*b1cdbd2cSJim Jagielski
94*b1cdbd2cSJim Jagielski return m_xConnection->nativeSQL(sql);
95*b1cdbd2cSJim Jagielski }
96*b1cdbd2cSJim Jagielski // --------------------------------------------------------------------------------
setAutoCommit(sal_Bool autoCommit)97*b1cdbd2cSJim Jagielski void SAL_CALL OConnectionWeakWrapper::setAutoCommit( sal_Bool autoCommit ) throw(SQLException, RuntimeException)
98*b1cdbd2cSJim Jagielski {
99*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aMutex );
100*b1cdbd2cSJim Jagielski checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
101*b1cdbd2cSJim Jagielski
102*b1cdbd2cSJim Jagielski m_xConnection->setAutoCommit(autoCommit);
103*b1cdbd2cSJim Jagielski }
104*b1cdbd2cSJim Jagielski // --------------------------------------------------------------------------------
getAutoCommit()105*b1cdbd2cSJim Jagielski sal_Bool SAL_CALL OConnectionWeakWrapper::getAutoCommit( ) throw(SQLException, RuntimeException)
106*b1cdbd2cSJim Jagielski {
107*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aMutex );
108*b1cdbd2cSJim Jagielski checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
109*b1cdbd2cSJim Jagielski
110*b1cdbd2cSJim Jagielski
111*b1cdbd2cSJim Jagielski return m_xConnection->getAutoCommit();
112*b1cdbd2cSJim Jagielski }
113*b1cdbd2cSJim Jagielski // --------------------------------------------------------------------------------
commit()114*b1cdbd2cSJim Jagielski void SAL_CALL OConnectionWeakWrapper::commit( ) throw(SQLException, RuntimeException)
115*b1cdbd2cSJim Jagielski {
116*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aMutex );
117*b1cdbd2cSJim Jagielski checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
118*b1cdbd2cSJim Jagielski
119*b1cdbd2cSJim Jagielski
120*b1cdbd2cSJim Jagielski m_xConnection->commit();
121*b1cdbd2cSJim Jagielski }
122*b1cdbd2cSJim Jagielski // --------------------------------------------------------------------------------
rollback()123*b1cdbd2cSJim Jagielski void SAL_CALL OConnectionWeakWrapper::rollback( ) throw(SQLException, RuntimeException)
124*b1cdbd2cSJim Jagielski {
125*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aMutex );
126*b1cdbd2cSJim Jagielski checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
127*b1cdbd2cSJim Jagielski
128*b1cdbd2cSJim Jagielski
129*b1cdbd2cSJim Jagielski m_xConnection->rollback();
130*b1cdbd2cSJim Jagielski }
131*b1cdbd2cSJim Jagielski // --------------------------------------------------------------------------------
isClosed()132*b1cdbd2cSJim Jagielski sal_Bool SAL_CALL OConnectionWeakWrapper::isClosed( ) throw(SQLException, RuntimeException)
133*b1cdbd2cSJim Jagielski {
134*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aMutex );
135*b1cdbd2cSJim Jagielski
136*b1cdbd2cSJim Jagielski return m_xConnection->isClosed();
137*b1cdbd2cSJim Jagielski }
138*b1cdbd2cSJim Jagielski // --------------------------------------------------------------------------------
getMetaData()139*b1cdbd2cSJim Jagielski Reference< XDatabaseMetaData > SAL_CALL OConnectionWeakWrapper::getMetaData( ) throw(SQLException, RuntimeException)
140*b1cdbd2cSJim Jagielski {
141*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aMutex );
142*b1cdbd2cSJim Jagielski checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
143*b1cdbd2cSJim Jagielski
144*b1cdbd2cSJim Jagielski
145*b1cdbd2cSJim Jagielski return m_xConnection->getMetaData();
146*b1cdbd2cSJim Jagielski }
147*b1cdbd2cSJim Jagielski // --------------------------------------------------------------------------------
setReadOnly(sal_Bool readOnly)148*b1cdbd2cSJim Jagielski void SAL_CALL OConnectionWeakWrapper::setReadOnly( sal_Bool readOnly ) throw(SQLException, RuntimeException)
149*b1cdbd2cSJim Jagielski {
150*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aMutex );
151*b1cdbd2cSJim Jagielski checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
152*b1cdbd2cSJim Jagielski
153*b1cdbd2cSJim Jagielski
154*b1cdbd2cSJim Jagielski m_xConnection->setReadOnly(readOnly);
155*b1cdbd2cSJim Jagielski }
156*b1cdbd2cSJim Jagielski // --------------------------------------------------------------------------------
isReadOnly()157*b1cdbd2cSJim Jagielski sal_Bool SAL_CALL OConnectionWeakWrapper::isReadOnly( ) throw(SQLException, RuntimeException)
158*b1cdbd2cSJim Jagielski {
159*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aMutex );
160*b1cdbd2cSJim Jagielski checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
161*b1cdbd2cSJim Jagielski
162*b1cdbd2cSJim Jagielski
163*b1cdbd2cSJim Jagielski return m_xConnection->isReadOnly();
164*b1cdbd2cSJim Jagielski }
165*b1cdbd2cSJim Jagielski // --------------------------------------------------------------------------------
setCatalog(const::rtl::OUString & catalog)166*b1cdbd2cSJim Jagielski void SAL_CALL OConnectionWeakWrapper::setCatalog( const ::rtl::OUString& catalog ) throw(SQLException, RuntimeException)
167*b1cdbd2cSJim Jagielski {
168*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aMutex );
169*b1cdbd2cSJim Jagielski checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
170*b1cdbd2cSJim Jagielski
171*b1cdbd2cSJim Jagielski
172*b1cdbd2cSJim Jagielski m_xConnection->setCatalog(catalog);
173*b1cdbd2cSJim Jagielski }
174*b1cdbd2cSJim Jagielski // --------------------------------------------------------------------------------
getCatalog()175*b1cdbd2cSJim Jagielski ::rtl::OUString SAL_CALL OConnectionWeakWrapper::getCatalog( ) throw(SQLException, RuntimeException)
176*b1cdbd2cSJim Jagielski {
177*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aMutex );
178*b1cdbd2cSJim Jagielski checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
179*b1cdbd2cSJim Jagielski
180*b1cdbd2cSJim Jagielski
181*b1cdbd2cSJim Jagielski return m_xConnection->getCatalog();
182*b1cdbd2cSJim Jagielski }
183*b1cdbd2cSJim Jagielski // --------------------------------------------------------------------------------
setTransactionIsolation(sal_Int32 level)184*b1cdbd2cSJim Jagielski void SAL_CALL OConnectionWeakWrapper::setTransactionIsolation( sal_Int32 level ) throw(SQLException, RuntimeException)
185*b1cdbd2cSJim Jagielski {
186*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aMutex );
187*b1cdbd2cSJim Jagielski checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
188*b1cdbd2cSJim Jagielski
189*b1cdbd2cSJim Jagielski
190*b1cdbd2cSJim Jagielski m_xConnection->setTransactionIsolation(level);
191*b1cdbd2cSJim Jagielski }
192*b1cdbd2cSJim Jagielski // --------------------------------------------------------------------------------
getTransactionIsolation()193*b1cdbd2cSJim Jagielski sal_Int32 SAL_CALL OConnectionWeakWrapper::getTransactionIsolation( ) throw(SQLException, RuntimeException)
194*b1cdbd2cSJim Jagielski {
195*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aMutex );
196*b1cdbd2cSJim Jagielski checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
197*b1cdbd2cSJim Jagielski
198*b1cdbd2cSJim Jagielski
199*b1cdbd2cSJim Jagielski return m_xConnection->getTransactionIsolation();
200*b1cdbd2cSJim Jagielski }
201*b1cdbd2cSJim Jagielski // --------------------------------------------------------------------------------
getTypeMap()202*b1cdbd2cSJim Jagielski Reference< ::com::sun::star::container::XNameAccess > SAL_CALL OConnectionWeakWrapper::getTypeMap( ) throw(SQLException, RuntimeException)
203*b1cdbd2cSJim Jagielski {
204*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aMutex );
205*b1cdbd2cSJim Jagielski checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
206*b1cdbd2cSJim Jagielski
207*b1cdbd2cSJim Jagielski
208*b1cdbd2cSJim Jagielski return m_xConnection->getTypeMap();
209*b1cdbd2cSJim Jagielski }
210*b1cdbd2cSJim Jagielski // --------------------------------------------------------------------------------
setTypeMap(const Reference<::com::sun::star::container::XNameAccess> & typeMap)211*b1cdbd2cSJim Jagielski void SAL_CALL OConnectionWeakWrapper::setTypeMap( const Reference< ::com::sun::star::container::XNameAccess >& typeMap ) throw(SQLException, RuntimeException)
212*b1cdbd2cSJim Jagielski {
213*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aMutex );
214*b1cdbd2cSJim Jagielski checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
215*b1cdbd2cSJim Jagielski
216*b1cdbd2cSJim Jagielski
217*b1cdbd2cSJim Jagielski m_xConnection->setTypeMap(typeMap);
218*b1cdbd2cSJim Jagielski }
219*b1cdbd2cSJim Jagielski // --------------------------------------------------------------------------------
220*b1cdbd2cSJim Jagielski // XCloseable
close()221*b1cdbd2cSJim Jagielski void SAL_CALL OConnectionWeakWrapper::close( ) throw(SQLException, RuntimeException)
222*b1cdbd2cSJim Jagielski {
223*b1cdbd2cSJim Jagielski {
224*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aMutex );
225*b1cdbd2cSJim Jagielski checkDisposed(OConnectionWeakWrapper_BASE::rBHelper.bDisposed);
226*b1cdbd2cSJim Jagielski
227*b1cdbd2cSJim Jagielski }
228*b1cdbd2cSJim Jagielski dispose();
229*b1cdbd2cSJim Jagielski }
230*b1cdbd2cSJim Jagielski //------------------------------------------------------------------------------
disposing()231*b1cdbd2cSJim Jagielski void OConnectionWeakWrapper::disposing()
232*b1cdbd2cSJim Jagielski {
233*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard(m_aMutex);
234*b1cdbd2cSJim Jagielski
235*b1cdbd2cSJim Jagielski OConnectionWeakWrapper_BASE::disposing();
236*b1cdbd2cSJim Jagielski OConnectionWrapper::disposing();
237*b1cdbd2cSJim Jagielski }
238*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
239*b1cdbd2cSJim Jagielski // com::sun::star::lang::XUnoTunnel
240*b1cdbd2cSJim Jagielski #ifdef N_DEBUG
241*b1cdbd2cSJim Jagielski IMPLEMENT_FORWARD_XINTERFACE2(OConnectionWeakWrapper,OConnectionWeakWrapper_BASE,OConnectionWrapper)
242*b1cdbd2cSJim Jagielski #else
243*b1cdbd2cSJim Jagielski IMPLEMENT_FORWARD_REFCOUNT( OConnectionWeakWrapper, OConnectionWeakWrapper_BASE ) \
244*b1cdbd2cSJim Jagielski ::com::sun::star::uno::Any SAL_CALL OConnectionWeakWrapper::queryInterface( const ::com::sun::star::uno::Type& _rType ) throw (::com::sun::star::uno::RuntimeException) \
245*b1cdbd2cSJim Jagielski { \
246*b1cdbd2cSJim Jagielski ::com::sun::star::uno::Any aReturn = OConnectionWeakWrapper_BASE::queryInterface( _rType ); \
247*b1cdbd2cSJim Jagielski if ( !aReturn.hasValue() ) \
248*b1cdbd2cSJim Jagielski aReturn = OConnectionWrapper::queryInterface( _rType ); \
249*b1cdbd2cSJim Jagielski return aReturn; \
250*b1cdbd2cSJim Jagielski }
251*b1cdbd2cSJim Jagielski #endif
252*b1cdbd2cSJim Jagielski IMPLEMENT_FORWARD_XTYPEPROVIDER2(OConnectionWeakWrapper,OConnectionWeakWrapper_BASE,OConnectionWrapper)
253*b1cdbd2cSJim Jagielski
254*b1cdbd2cSJim Jagielski
255