Branch data Line data Source code
1 : : /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
2 : : /*
3 : : * This file is part of the LibreOffice project.
4 : : *
5 : : * This Source Code Form is subject to the terms of the Mozilla Public
6 : : * License, v. 2.0. If a copy of the MPL was not distributed with this
7 : : * file, You can obtain one at http://mozilla.org/MPL/2.0/.
8 : : *
9 : : * This file incorporates work covered by the following license notice:
10 : : *
11 : : * Licensed to the Apache Software Foundation (ASF) under one or more
12 : : * contributor license agreements. See the NOTICE file distributed
13 : : * with this work for additional information regarding copyright
14 : : * ownership. The ASF licenses this file to you under the Apache
15 : : * License, Version 2.0 (the "License"); you may not use this file
16 : : * except in compliance with the License. You may obtain a copy of
17 : : * the License at http://www.apache.org/licenses/LICENSE-2.0 .
18 : : */
19 : :
20 : : #include <statement.hxx>
21 : : #include <resultset.hxx>
22 : : #include "dbastrings.hrc"
23 : : #include <com/sun/star/lang/DisposedException.hpp>
24 : : #include <com/sun/star/sdbc/XDatabaseMetaData.hpp>
25 : : #include <comphelper/sequence.hxx>
26 : : #include <cppuhelper/typeprovider.hxx>
27 : : #include <comphelper/property.hxx>
28 : : #include <comphelper/types.hxx>
29 : : #include <tools/debug.hxx>
30 : : #include <tools/diagnose_ex.h>
31 : : #include <connectivity/dbexception.hxx>
32 : : #include <rtl/logfile.hxx>
33 : :
34 : : using namespace ::com::sun::star::sdb;
35 : : using namespace ::com::sun::star::sdbc;
36 : : using namespace ::com::sun::star::beans;
37 : : using namespace ::com::sun::star::uno;
38 : : using namespace ::com::sun::star::lang;
39 : : using namespace ::cppu;
40 : : using namespace ::osl;
41 : : using namespace dbaccess;
42 : : using namespace dbtools;
43 : :
44 : : DBG_NAME(OStatementBase)
45 : :
46 : 110 : OStatementBase::OStatementBase(const Reference< XConnection > & _xConn,
47 : : const Reference< XInterface > & _xStatement)
48 : : :OSubComponent(m_aMutex, _xConn)
49 : : ,OPropertySetHelper(OComponentHelper::rBHelper)
50 : : ,m_bUseBookmarks( sal_False )
51 [ + - ][ + - ]: 110 : ,m_bEscapeProcessing( sal_True )
[ + - ][ + - ]
52 : :
53 : : {
54 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatementBase::OStatementBase" );
55 : : DBG_CTOR(OStatementBase, NULL);
56 : : OSL_ENSURE(_xStatement.is() ,"Statement is NULL!");
57 [ + - ]: 110 : m_xAggregateAsSet.set(_xStatement,UNO_QUERY);
58 [ + - ][ + - ]: 110 : m_xAggregateAsCancellable = Reference< ::com::sun::star::util::XCancellable > (m_xAggregateAsSet, UNO_QUERY);
59 : 110 : }
60 : :
61 [ + - ][ + - ]: 110 : OStatementBase::~OStatementBase()
[ + - ][ + - ]
[ + - ]
62 : : {
63 : : DBG_DTOR(OStatementBase, NULL);
64 [ - + ]: 110 : }
65 : :
66 : : // com::sun::star::lang::XTypeProvider
67 : 0 : Sequence< Type > OStatementBase::getTypes() throw (RuntimeException)
68 : : {
69 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatementBase::getTypes" );
70 [ # # ]: 0 : OTypeCollection aTypes(::getCppuType( (const Reference< XPropertySet > *)0 ),
71 [ # # ]: 0 : ::getCppuType( (const Reference< XWarningsSupplier > *)0 ),
72 [ # # ]: 0 : ::getCppuType( (const Reference< XCloseable > *)0 ),
73 [ # # ]: 0 : ::getCppuType( (const Reference< XMultipleResults > *)0 ),
74 [ # # ]: 0 : ::getCppuType( (const Reference< ::com::sun::star::util::XCancellable > *)0 ),
75 [ # # ][ # # ]: 0 : OSubComponent::getTypes() );
[ # # ]
76 [ # # ]: 0 : Reference< XGeneratedResultSet > xGRes(m_xAggregateAsSet, UNO_QUERY);
77 [ # # ]: 0 : if ( xGRes.is() )
78 [ # # ][ # # ]: 0 : aTypes = OTypeCollection(::getCppuType( (const Reference< XGeneratedResultSet > *)0 ),aTypes.getTypes());
[ # # ][ # # ]
[ # # ][ # # ]
79 [ # # ]: 0 : Reference< XPreparedBatchExecution > xPreparedBatchExecution(m_xAggregateAsSet, UNO_QUERY);
80 [ # # ]: 0 : if ( xPreparedBatchExecution.is() )
81 [ # # ][ # # ]: 0 : aTypes = OTypeCollection(::getCppuType( (const Reference< XPreparedBatchExecution > *)0 ),aTypes.getTypes());
[ # # ][ # # ]
[ # # ][ # # ]
82 : :
83 [ # # ][ # # ]: 0 : return aTypes.getTypes();
84 : : }
85 : :
86 : : // com::sun::star::uno::XInterface
87 : 954 : Any OStatementBase::queryInterface( const Type & rType ) throw (RuntimeException)
88 : : {
89 : : //RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatementBase::queryInterface" );
90 : 954 : Any aIface = OSubComponent::queryInterface( rType );
91 [ + + ]: 954 : if (!aIface.hasValue())
92 : : {
93 : : aIface = ::cppu::queryInterface(
94 : : rType,
95 : : static_cast< XPropertySet * >( this ),
96 : : static_cast< XWarningsSupplier * >( this ),
97 : : static_cast< XCloseable * >( this ),
98 : : static_cast< XMultipleResults * >( this ),
99 [ + - ]: 410 : static_cast< ::com::sun::star::util::XCancellable * >( this ));
100 [ + + ]: 410 : if ( !aIface.hasValue() )
101 : : {
102 [ + - ]: 238 : Reference< XGeneratedResultSet > xGRes(m_xAggregateAsSet, UNO_QUERY);
103 [ + - ][ - + ]: 238 : if ( ::getCppuType( (const Reference< XGeneratedResultSet > *)0 ) == rType && xGRes.is() )
[ # # ][ - + ]
104 [ # # ]: 238 : aIface = ::cppu::queryInterface(rType,static_cast< XGeneratedResultSet * >( this ));
105 : : }
106 [ + + ]: 410 : if ( !aIface.hasValue() )
107 : : {
108 [ + - ]: 238 : Reference< XPreparedBatchExecution > xGRes(m_xAggregateAsSet, UNO_QUERY);
109 [ + - ][ - + ]: 238 : if ( ::getCppuType( (const Reference< XPreparedBatchExecution > *)0 ) == rType && xGRes.is() )
[ # # ][ - + ]
110 [ # # ]: 238 : aIface = ::cppu::queryInterface(rType,static_cast< XPreparedBatchExecution * >( this ));
111 : : }
112 : : }
113 : 954 : return aIface;
114 : : }
115 : :
116 : 3714 : void OStatementBase::acquire() throw ()
117 : : {
118 : 3714 : OSubComponent::acquire();
119 : 3714 : }
120 : :
121 : 3626 : void OStatementBase::release() throw ()
122 : : {
123 : 3626 : OSubComponent::release();
124 : 3626 : }
125 : :
126 : 172 : void OStatementBase::disposeResultSet()
127 : : {
128 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatementBase::disposeResultSet" );
129 : : // free the cursor if alive
130 [ + - ][ + - ]: 172 : Reference< XComponent > xComp(m_aResultSet.get(), UNO_QUERY);
131 [ - + ]: 172 : if (xComp.is())
132 [ # # ][ # # ]: 0 : xComp->dispose();
133 [ + - ][ + - ]: 172 : m_aResultSet = NULL;
134 : 172 : }
135 : :
136 : : // OComponentHelper
137 : 110 : void OStatementBase::disposing()
138 : : {
139 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatementBase::disposing" );
140 [ + - ]: 110 : OPropertySetHelper::disposing();
141 : :
142 [ + - ]: 110 : MutexGuard aGuard(m_aMutex);
143 : :
144 : : // free pending results
145 [ + - ]: 110 : disposeResultSet();
146 : :
147 : : // free the original statement
148 : : {
149 [ + - ]: 110 : MutexGuard aCancelGuard(m_aCancelMutex);
150 [ + - ][ + - ]: 110 : m_xAggregateAsCancellable = NULL;
151 : : }
152 : :
153 [ + - ]: 110 : if ( m_xAggregateAsSet.is() )
154 : : {
155 : : try
156 : : {
157 [ + - ][ + - ]: 110 : Reference< XCloseable > (m_xAggregateAsSet, UNO_QUERY)->close();
[ + - ][ # # ]
158 : : }
159 [ # # ]: 0 : catch(RuntimeException& )
160 : : {// don't care for anymore
161 : : }
162 : : }
163 [ + - ]: 110 : m_xAggregateAsSet = NULL;
164 : :
165 : : // free the parent at last
166 [ + - ][ + - ]: 110 : OSubComponent::disposing();
167 : 110 : }
168 : :
169 : : // XCloseable
170 : 0 : void OStatementBase::close(void) throw( SQLException, RuntimeException )
171 : : {
172 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatementBase::close" );
173 : : {
174 [ # # ]: 0 : MutexGuard aGuard( m_aMutex );
175 [ # # ][ # # ]: 0 : ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
176 : : }
177 : 0 : dispose();
178 : 0 : }
179 : :
180 : : // OPropertySetHelper
181 : 0 : Reference< XPropertySetInfo > OStatementBase::getPropertySetInfo() throw (RuntimeException)
182 : : {
183 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatementBase::getPropertySetInfo" );
184 : 0 : return createPropertySetInfo( getInfoHelper() ) ;
185 : : }
186 : :
187 : : // comphelper::OPropertyArrayUsageHelper
188 : 62 : ::cppu::IPropertyArrayHelper* OStatementBase::createArrayHelper( ) const
189 : : {
190 : : //RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatementBase::createArrayHelper" );
191 [ + - ][ + - ]: 62 : BEGIN_PROPERTY_HELPER(10)
192 [ + - ][ + - ]: 62 : DECL_PROP0(CURSORNAME, ::rtl::OUString);
193 [ + - ][ + - ]: 62 : DECL_PROP0_BOOL(ESCAPE_PROCESSING);
194 [ + - ][ + - ]: 62 : DECL_PROP0(FETCHDIRECTION, sal_Int32);
195 [ + - ][ + - ]: 62 : DECL_PROP0(FETCHSIZE, sal_Int32);
196 [ + - ][ + - ]: 62 : DECL_PROP0(MAXFIELDSIZE, sal_Int32);
197 [ + - ][ + - ]: 62 : DECL_PROP0(MAXROWS, sal_Int32);
198 [ + - ][ + - ]: 62 : DECL_PROP0(QUERYTIMEOUT, sal_Int32);
199 [ + - ][ + - ]: 62 : DECL_PROP0(RESULTSETCONCURRENCY, sal_Int32);
200 [ + - ][ + - ]: 62 : DECL_PROP0(RESULTSETTYPE, sal_Int32);
201 [ + - ][ + - ]: 62 : DECL_PROP0_BOOL(USEBOOKMARKS);
202 [ + - ][ + - ]: 62 : END_PROPERTY_HELPER();
203 : : }
204 : :
205 : : // cppu::OPropertySetHelper
206 : 626 : ::cppu::IPropertyArrayHelper& OStatementBase::getInfoHelper()
207 : : {
208 : : //RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatementBase::getInfoHelper" );
209 : 626 : return *getArrayHelper();
210 : : }
211 : :
212 : 182 : sal_Bool OStatementBase::convertFastPropertyValue( Any & rConvertedValue, Any & rOldValue, sal_Int32 nHandle, const Any& rValue ) throw( IllegalArgumentException )
213 : : {
214 : : //RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatementBase::convertFastPropertyValue" );
215 : 182 : sal_Bool bModified(sal_False);
216 [ + + + ]: 182 : switch (nHandle)
217 : : {
218 : : case PROPERTY_ID_USEBOOKMARKS:
219 : 40 : bModified = ::comphelper::tryPropertyValue( rConvertedValue, rOldValue, rValue, m_bUseBookmarks );
220 : 40 : break;
221 : :
222 : : case PROPERTY_ID_ESCAPE_PROCESSING:
223 : 22 : bModified = ::comphelper::tryPropertyValue( rConvertedValue, rOldValue, rValue, m_bEscapeProcessing );
224 : 22 : break;
225 : :
226 : : default:
227 [ + - ]: 120 : if ( m_xAggregateAsSet.is() )
228 : : {
229 : : // get the property name
230 : 120 : ::rtl::OUString sPropName;
231 [ + - ][ + - ]: 120 : getInfoHelper().fillPropertyMembersByHandle( &sPropName, NULL, nHandle );
232 : :
233 : : // now set the value
234 [ + - ][ + - ]: 120 : Any aCurrentValue = m_xAggregateAsSet->getPropertyValue( sPropName );
235 [ + + ]: 120 : if ( aCurrentValue != rValue )
236 : : {
237 : 40 : rOldValue = aCurrentValue;
238 : 40 : rConvertedValue = rValue;
239 : 40 : bModified = sal_True;
240 : 120 : }
241 : : }
242 : 120 : break;
243 : : }
244 : 182 : return bModified;
245 : : }
246 : :
247 : 102 : void OStatementBase::setFastPropertyValue_NoBroadcast( sal_Int32 nHandle, const Any& rValue ) throw (Exception)
248 : : {
249 : : //RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatementBase::setFastPropertyValue_NoBroadcast" );
250 [ + + + ]: 102 : switch ( nHandle )
251 : : {
252 : : case PROPERTY_ID_USEBOOKMARKS:
253 : : {
254 : 40 : m_bUseBookmarks = ::comphelper::getBOOL( rValue );
255 [ + - ][ + - ]: 40 : if ( m_xAggregateAsSet.is() && m_xAggregateAsSet->getPropertySetInfo()->hasPropertyByName( PROPERTY_USEBOOKMARKS ) )
[ + - ][ + - ]
[ + - ][ - + ]
[ + - ][ + - ]
[ - + # #
# # ][ + - ]
256 [ # # ]: 0 : m_xAggregateAsSet->setPropertyValue( PROPERTY_USEBOOKMARKS, rValue );
257 : : }
258 : 40 : break;
259 : :
260 : : case PROPERTY_ID_ESCAPE_PROCESSING:
261 : 22 : m_bEscapeProcessing = ::comphelper::getBOOL( rValue );
262 [ + - ]: 22 : if ( m_xAggregateAsSet.is() )
263 [ + - ]: 22 : m_xAggregateAsSet->setPropertyValue( PROPERTY_ESCAPE_PROCESSING, rValue );
264 : 22 : break;
265 : :
266 : : default:
267 [ + - ]: 40 : if ( m_xAggregateAsSet.is() )
268 : : {
269 : 40 : ::rtl::OUString sPropName;
270 [ + - ][ + - ]: 40 : getInfoHelper().fillPropertyMembersByHandle( &sPropName, NULL, nHandle );
271 [ + - ][ + - ]: 40 : m_xAggregateAsSet->setPropertyValue( sPropName, rValue );
272 : : }
273 : 40 : break;
274 : : }
275 : 102 : }
276 : :
277 : 0 : void OStatementBase::getFastPropertyValue( Any& rValue, sal_Int32 nHandle ) const
278 : : {
279 : : //RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatementBase::getFastPropertyValue" );
280 [ # # # ]: 0 : switch (nHandle)
281 : : {
282 : : case PROPERTY_ID_USEBOOKMARKS:
283 : 0 : rValue <<= m_bUseBookmarks;
284 : 0 : break;
285 : :
286 : : case PROPERTY_ID_ESCAPE_PROCESSING:
287 : : // don't rely on our aggregate - if it implements this wrong, and always returns
288 : : // TRUE here, then we would loop in impl_doEscapeProcessing_nothrow
289 : 0 : rValue <<= m_bEscapeProcessing;
290 : 0 : break;
291 : :
292 : : default:
293 [ # # ]: 0 : if ( m_xAggregateAsSet.is() )
294 : : {
295 : 0 : ::rtl::OUString sPropName;
296 [ # # ][ # # ]: 0 : const_cast< OStatementBase* >( this )->getInfoHelper().fillPropertyMembersByHandle( &sPropName, NULL, nHandle );
297 [ # # ][ # # ]: 0 : rValue = m_xAggregateAsSet->getPropertyValue( sPropName );
298 : : }
299 : 0 : break;
300 : : }
301 : 0 : }
302 : :
303 : : // XWarningsSupplier
304 : 0 : Any OStatementBase::getWarnings(void) throw( SQLException, RuntimeException )
305 : : {
306 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatementBase::getWarnings" );
307 [ # # ]: 0 : MutexGuard aGuard(m_aMutex);
308 [ # # ]: 0 : ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
309 : :
310 [ # # ][ # # ]: 0 : return Reference< XWarningsSupplier >(m_xAggregateAsSet, UNO_QUERY)->getWarnings();
[ # # ][ # # ]
311 : : }
312 : :
313 : 0 : void OStatementBase::clearWarnings(void) throw( SQLException, RuntimeException )
314 : : {
315 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatementBase::clearWarnings" );
316 [ # # ]: 0 : MutexGuard aGuard(m_aMutex);
317 [ # # ]: 0 : ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
318 : :
319 [ # # ][ # # ]: 0 : Reference< XWarningsSupplier >(m_xAggregateAsSet, UNO_QUERY)->clearWarnings();
[ # # ][ # # ]
320 : 0 : }
321 : :
322 : : // ::com::sun::star::util::XCancellable
323 : 0 : void OStatementBase::cancel(void) throw( RuntimeException )
324 : : {
325 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatementBase::cancel" );
326 : : // no blocking as cancel is typically called from a different thread
327 [ # # ]: 0 : ClearableMutexGuard aCancelGuard(m_aCancelMutex);
328 [ # # ]: 0 : if (m_xAggregateAsCancellable.is())
329 [ # # ][ # # ]: 0 : m_xAggregateAsCancellable->cancel();
[ # # ]
330 : : // else do nothing
331 : 0 : }
332 : :
333 : : // XMultipleResults
334 : 0 : Reference< XResultSet > SAL_CALL OStatementBase::getResultSet( ) throw(SQLException, RuntimeException)
335 : : {
336 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatementBase::getResultSet" );
337 [ # # ]: 0 : MutexGuard aGuard(m_aMutex);
338 [ # # ]: 0 : ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
339 : :
340 : : // first check the meta data
341 [ # # ][ # # ]: 0 : Reference<XDatabaseMetaData> xMeta = Reference< XConnection > (m_xParent, UNO_QUERY)->getMetaData();
[ # # ]
342 [ # # ][ # # ]: 0 : if (!xMeta.is() && !xMeta->supportsMultipleResultSets())
[ # # ][ # # ]
[ # # ]
343 [ # # ][ # # ]: 0 : throwFunctionSequenceException(*this);
344 : :
345 [ # # ][ # # ]: 0 : return Reference< XMultipleResults >(m_xAggregateAsSet, UNO_QUERY)->getResultSet();
[ # # ][ # # ]
346 : : }
347 : :
348 : 0 : sal_Int32 SAL_CALL OStatementBase::getUpdateCount( ) throw(SQLException, RuntimeException)
349 : : {
350 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatementBase::getUpdateCount" );
351 [ # # ]: 0 : MutexGuard aGuard(m_aMutex);
352 [ # # ]: 0 : ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
353 : :
354 : : // first check the meta data
355 [ # # ][ # # ]: 0 : Reference<XDatabaseMetaData> xMeta = Reference< XConnection > (m_xParent, UNO_QUERY)->getMetaData();
[ # # ]
356 [ # # ][ # # ]: 0 : if (!xMeta.is() && !xMeta->supportsMultipleResultSets())
[ # # ][ # # ]
[ # # ]
357 [ # # ][ # # ]: 0 : throwFunctionSequenceException(*this);
358 : :
359 [ # # ][ # # ]: 0 : return Reference< XMultipleResults >(m_xAggregateAsSet, UNO_QUERY)->getUpdateCount();
[ # # ][ # # ]
360 : : }
361 : :
362 : 0 : sal_Bool SAL_CALL OStatementBase::getMoreResults( ) throw(SQLException, RuntimeException)
363 : : {
364 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatementBase::getMoreResults" );
365 [ # # ]: 0 : MutexGuard aGuard(m_aMutex);
366 [ # # ]: 0 : ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
367 : :
368 : : // first check the meta data
369 [ # # ][ # # ]: 0 : Reference<XDatabaseMetaData> xMeta = Reference< XConnection > (m_xParent, UNO_QUERY)->getMetaData();
[ # # ]
370 [ # # ][ # # ]: 0 : if (!xMeta.is() && !xMeta->supportsMultipleResultSets())
[ # # ][ # # ]
[ # # ]
371 [ # # ][ # # ]: 0 : throwFunctionSequenceException(*this);
372 [ # # ][ # # ]: 0 : throwFunctionSequenceException(*this);
373 : :
374 : : // free the previous results
375 [ # # ]: 0 : disposeResultSet();
376 : :
377 [ # # ][ # # ]: 0 : return Reference< XMultipleResults >(m_xAggregateAsSet, UNO_QUERY)->getMoreResults();
[ # # ][ # # ]
378 : : }
379 : :
380 : : // XPreparedBatchExecution
381 : 0 : void SAL_CALL OStatementBase::addBatch( ) throw(SQLException, RuntimeException)
382 : : {
383 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatementBase::addBatch" );
384 [ # # ]: 0 : MutexGuard aGuard(m_aMutex);
385 [ # # ]: 0 : ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
386 : :
387 : : // first check the meta data
388 [ # # ][ # # ]: 0 : Reference<XDatabaseMetaData> xMeta = Reference< XConnection > (m_xParent, UNO_QUERY)->getMetaData();
[ # # ]
389 [ # # ][ # # ]: 0 : if (!xMeta.is() && !xMeta->supportsBatchUpdates())
[ # # ][ # # ]
[ # # ]
390 [ # # ][ # # ]: 0 : throwFunctionSequenceException(*this);
391 : :
392 [ # # ][ # # ]: 0 : Reference< XPreparedBatchExecution >(m_xAggregateAsSet, UNO_QUERY)->addBatch();
[ # # ][ # # ]
393 : 0 : }
394 : :
395 : 0 : void SAL_CALL OStatementBase::clearBatch( ) throw(SQLException, RuntimeException)
396 : : {
397 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatementBase::clearBatch" );
398 [ # # ]: 0 : MutexGuard aGuard(m_aMutex);
399 [ # # ]: 0 : ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
400 : :
401 : : // first check the meta data
402 [ # # ][ # # ]: 0 : Reference<XDatabaseMetaData> xMeta = Reference< XConnection > (m_xParent, UNO_QUERY)->getMetaData();
[ # # ]
403 [ # # ][ # # ]: 0 : if (!xMeta.is() && !xMeta->supportsBatchUpdates())
[ # # ][ # # ]
[ # # ]
404 [ # # ][ # # ]: 0 : throwFunctionSequenceException(*this);
405 : :
406 [ # # ][ # # ]: 0 : Reference< XPreparedBatchExecution >(m_xAggregateAsSet, UNO_QUERY)->clearBatch();
[ # # ][ # # ]
407 : 0 : }
408 : :
409 : 0 : Sequence< sal_Int32 > SAL_CALL OStatementBase::executeBatch( ) throw(SQLException, RuntimeException)
410 : : {
411 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatementBase::executeBatch" );
412 [ # # ]: 0 : MutexGuard aGuard(m_aMutex);
413 [ # # ]: 0 : ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
414 : :
415 : : // first check the meta data
416 [ # # ][ # # ]: 0 : Reference<XDatabaseMetaData> xMeta = Reference< XConnection > (m_xParent, UNO_QUERY)->getMetaData();
[ # # ]
417 [ # # ][ # # ]: 0 : if (!xMeta.is() && !xMeta->supportsBatchUpdates())
[ # # ][ # # ]
[ # # ]
418 [ # # ][ # # ]: 0 : throwFunctionSequenceException(*this);
419 : :
420 : : // free the previous results
421 [ # # ]: 0 : disposeResultSet();
422 : :
423 [ # # ][ # # ]: 0 : return Reference< XPreparedBatchExecution >(m_xAggregateAsSet, UNO_QUERY)->executeBatch();
[ # # ][ # # ]
424 : : }
425 : :
426 : 0 : Reference< XResultSet > SAL_CALL OStatementBase::getGeneratedValues( ) throw (SQLException, RuntimeException)
427 : : {
428 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatementBase::getGeneratedValues" );
429 [ # # ]: 0 : MutexGuard aGuard(m_aMutex);
430 [ # # ]: 0 : ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
431 [ # # ]: 0 : Reference< XGeneratedResultSet > xGRes(m_xAggregateAsSet, UNO_QUERY);
432 : :
433 [ # # ]: 0 : if ( xGRes.is() )
434 [ # # ][ # # ]: 0 : return xGRes->getGeneratedValues( );
435 [ # # ]: 0 : return Reference< XResultSet >();
436 : : }
437 : :
438 : : //************************************************************
439 : : // OStatement
440 : : //************************************************************
441 : 22 : OStatement::OStatement( const Reference< XConnection >& _xConn, const Reference< XInterface > & _xStatement )
442 : : :OStatementBase( _xConn, _xStatement )
443 : 22 : ,m_bAttemptedComposerCreation( false )
444 : : {
445 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatement::OStatement" );
446 [ + - ]: 22 : m_xAggregateStatement.set( _xStatement, UNO_QUERY_THROW );
447 : 22 : }
448 : :
449 [ + + ][ + - ]: 1188 : IMPLEMENT_FORWARD_XINTERFACE2( OStatement, OStatementBase, OStatement_IFACE );
450 [ # # ][ # # ]: 0 : IMPLEMENT_FORWARD_XTYPEPROVIDER2( OStatement, OStatementBase, OStatement_IFACE );
[ # # ]
451 : :
452 : : // XServiceInfo
453 : 0 : rtl::OUString OStatement::getImplementationName( ) throw(RuntimeException)
454 : : {
455 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatement::getImplementationName" );
456 : 0 : return rtl::OUString("com.sun.star.sdb.OStatement");
457 : : }
458 : :
459 : 0 : sal_Bool OStatement::supportsService( const ::rtl::OUString& _rServiceName ) throw (RuntimeException)
460 : : {
461 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatement::supportsService" );
462 [ # # ][ # # ]: 0 : return ::comphelper::findValue(getSupportedServiceNames(), _rServiceName, sal_True).getLength() != 0;
463 : : }
464 : :
465 : 0 : Sequence< ::rtl::OUString > OStatement::getSupportedServiceNames( ) throw (RuntimeException)
466 : : {
467 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatement::getSupportedServiceNames" );
468 : 0 : Sequence< ::rtl::OUString > aSNS( 1 );
469 [ # # ][ # # ]: 0 : aSNS.getArray()[0] = SERVICE_SDBC_STATEMENT;
470 : 0 : return aSNS;
471 : : }
472 : :
473 : : // XStatement
474 : 22 : Reference< XResultSet > OStatement::executeQuery( const rtl::OUString& _rSQL ) throw( SQLException, RuntimeException )
475 : : {
476 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatement::executeQuery" );
477 [ + - ]: 22 : MutexGuard aGuard(m_aMutex);
478 [ + - ]: 22 : ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
479 : :
480 [ + - ]: 22 : disposeResultSet();
481 : 22 : Reference< XResultSet > xResultSet;
482 : :
483 [ + - ]: 22 : ::rtl::OUString sSQL( impl_doEscapeProcessing_nothrow( _rSQL ) );
484 : :
485 [ + - ][ - + ]: 22 : Reference< XResultSet > xInnerResultSet = m_xAggregateStatement->executeQuery( sSQL );
486 [ # # ]: 0 : Reference< XConnection > xConnection( m_xParent, UNO_QUERY_THROW );
487 : :
488 [ # # ]: 0 : if ( xInnerResultSet.is() )
489 : : {
490 [ # # ][ # # ]: 0 : Reference< XDatabaseMetaData > xMeta = xConnection->getMetaData();
491 [ # # ][ # # ]: 0 : sal_Bool bCaseSensitive = xMeta.is() && xMeta->supportsMixedCaseQuotedIdentifiers();
[ # # ][ # # ]
492 [ # # ][ # # ]: 0 : xResultSet = new OResultSet( xInnerResultSet, *this, bCaseSensitive );
[ # # ][ # # ]
493 : :
494 : : // keep the resultset weak
495 [ # # ]: 0 : m_aResultSet = xResultSet;
496 : : }
497 : :
498 [ # # ]: 22 : return xResultSet;
499 : : }
500 : :
501 : 0 : sal_Int32 OStatement::executeUpdate( const rtl::OUString& _rSQL ) throw( SQLException, RuntimeException )
502 : : {
503 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatement::executeUpdate" );
504 [ # # ]: 0 : MutexGuard aGuard(m_aMutex);
505 [ # # ]: 0 : ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
506 : :
507 [ # # ]: 0 : disposeResultSet();
508 : :
509 [ # # ]: 0 : ::rtl::OUString sSQL( impl_doEscapeProcessing_nothrow( _rSQL ) );
510 [ # # ][ # # ]: 0 : return m_xAggregateStatement->executeUpdate( sSQL );
[ # # ]
511 : : }
512 : :
513 : 0 : sal_Bool OStatement::execute( const rtl::OUString& _rSQL ) throw( SQLException, RuntimeException )
514 : : {
515 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatement::execute" );
516 [ # # ]: 0 : MutexGuard aGuard(m_aMutex);
517 [ # # ]: 0 : ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
518 : :
519 [ # # ]: 0 : disposeResultSet();
520 : :
521 [ # # ]: 0 : ::rtl::OUString sSQL( impl_doEscapeProcessing_nothrow( _rSQL ) );
522 [ # # ][ # # ]: 0 : return m_xAggregateStatement->execute( sSQL );
[ # # ]
523 : : }
524 : :
525 : 0 : void OStatement::addBatch( const rtl::OUString& _rSQL ) throw( SQLException, RuntimeException )
526 : : {
527 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatement::execute" );
528 [ # # ]: 0 : MutexGuard aGuard(m_aMutex);
529 [ # # ]: 0 : ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
530 : :
531 : : // first check the meta data
532 [ # # ][ # # ]: 0 : Reference<XDatabaseMetaData> xMeta = Reference< XConnection > (m_xParent, UNO_QUERY)->getMetaData();
[ # # ]
533 [ # # ][ # # ]: 0 : if (!xMeta.is() && !xMeta->supportsBatchUpdates())
[ # # ][ # # ]
[ # # ]
534 [ # # ][ # # ]: 0 : throwFunctionSequenceException(*this);
535 : :
536 [ # # ]: 0 : ::rtl::OUString sSQL( impl_doEscapeProcessing_nothrow( _rSQL ) );
537 [ # # ][ # # ]: 0 : Reference< XBatchExecution >(m_xAggregateAsSet, UNO_QUERY)->addBatch( sSQL );
[ # # ][ # # ]
538 : 0 : }
539 : :
540 : 0 : void OStatement::clearBatch( ) throw( SQLException, RuntimeException )
541 : : {
542 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatement::execute" );
543 [ # # ]: 0 : MutexGuard aGuard(m_aMutex);
544 [ # # ]: 0 : ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
545 : : // first check the meta data
546 [ # # ][ # # ]: 0 : Reference<XDatabaseMetaData> xMeta = Reference< XConnection > (m_xParent, UNO_QUERY)->getMetaData();
[ # # ]
547 [ # # ][ # # ]: 0 : if (!xMeta.is() && !xMeta->supportsBatchUpdates())
[ # # ][ # # ]
[ # # ]
548 [ # # ][ # # ]: 0 : throwFunctionSequenceException(*this);
549 : :
550 [ # # ][ # # ]: 0 : Reference< XBatchExecution >(m_xAggregateAsSet, UNO_QUERY)->clearBatch();
[ # # ][ # # ]
551 : 0 : }
552 : :
553 : 0 : Sequence< sal_Int32 > OStatement::executeBatch( ) throw( SQLException, RuntimeException )
554 : : {
555 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatement::execute" );
556 [ # # ]: 0 : MutexGuard aGuard(m_aMutex);
557 [ # # ]: 0 : ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
558 : : // first check the meta data
559 [ # # ][ # # ]: 0 : Reference<XDatabaseMetaData> xMeta = Reference< XConnection > (m_xParent, UNO_QUERY)->getMetaData();
[ # # ]
560 [ # # ][ # # ]: 0 : if (!xMeta.is() && !xMeta->supportsBatchUpdates())
[ # # ][ # # ]
[ # # ]
561 [ # # ][ # # ]: 0 : throwFunctionSequenceException(*this);
562 [ # # ][ # # ]: 0 : return Reference< XBatchExecution >(m_xAggregateAsSet, UNO_QUERY)->executeBatch( );
[ # # ][ # # ]
563 : : }
564 : :
565 : :
566 : 0 : Reference< XConnection > OStatement::getConnection(void) throw( SQLException, RuntimeException )
567 : : {
568 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatement::getConnection" );
569 : 0 : return Reference< XConnection >( m_xParent, UNO_QUERY );
570 : : }
571 : :
572 : 22 : void SAL_CALL OStatement::disposing()
573 : : {
574 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatement::disposing" );
575 : 22 : OStatementBase::disposing();
576 : 22 : m_xComposer.clear();
577 : 22 : m_xAggregateStatement.clear();
578 : 22 : }
579 : :
580 : 22 : ::rtl::OUString OStatement::impl_doEscapeProcessing_nothrow( const ::rtl::OUString& _rSQL ) const
581 : : {
582 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatement::impl_doEscapeProcessing_nothrow" );
583 [ + - ]: 22 : if ( !m_bEscapeProcessing )
584 : 22 : return _rSQL;
585 : : try
586 : : {
587 [ # # ][ # # ]: 0 : if ( !impl_ensureComposer_nothrow() )
588 : 0 : return _rSQL;
589 : :
590 : 0 : bool bParseable = false;
591 [ # # ][ # # ]: 0 : try { m_xComposer->setQuery( _rSQL ); bParseable = true; }
592 [ # # # # ]: 0 : catch( const SQLException& ) { }
593 : :
594 [ # # ]: 0 : if ( !bParseable )
595 : : // if we cannot parse it, silently accept this. The driver is probably able to cope with it then
596 : 0 : return _rSQL;
597 : :
598 [ # # ][ # # ]: 0 : ::rtl::OUString sLowLevelSQL = m_xComposer->getQueryWithSubstitution();
599 [ # # ]: 22 : return sLowLevelSQL;
600 : : }
601 : 0 : catch( const Exception& )
602 : : {
603 : : DBG_UNHANDLED_EXCEPTION();
604 : : }
605 : :
606 : 0 : return _rSQL;
607 : : }
608 : :
609 : 0 : bool OStatement::impl_ensureComposer_nothrow() const
610 : : {
611 : : RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OStatement::impl_ensureComposer_nothrow" );
612 [ # # ]: 0 : if ( m_bAttemptedComposerCreation )
613 : 0 : return m_xComposer.is();
614 : :
615 : 0 : const_cast< OStatement* >( this )->m_bAttemptedComposerCreation = true;
616 : : try
617 : : {
618 [ # # ]: 0 : Reference< XMultiServiceFactory > xFactory( m_xParent, UNO_QUERY_THROW );
619 [ # # ][ # # ]: 0 : const_cast< OStatement* >( this )->m_xComposer.set( xFactory->createInstance( SERVICE_NAME_SINGLESELECTQUERYCOMPOSER ), UNO_QUERY_THROW );
[ # # ][ # # ]
[ # # ]
620 : : }
621 : 0 : catch( const Exception& )
622 : : {
623 : : DBG_UNHANDLED_EXCEPTION();
624 : : }
625 : :
626 : 0 : return m_xComposer.is();
627 : : }
628 : :
629 : : /* vim:set shiftwidth=4 softtabstop=4 expandtab: */
|
