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 : : #include <connectivity/paramwrapper.hxx>
20 : :
21 : : #include <com/sun/star/beans/PropertyAttribute.hpp>
22 : : #include <com/sun/star/sdbc/DataType.hpp>
23 : : #include <com/sun/star/lang/WrappedTargetException.hpp>
24 : : #include <com/sun/star/sdb/XParametersSupplier.hpp>
25 : : #include <com/sun/star/lang/DisposedException.hpp>
26 : :
27 : : #include <tools/diagnose_ex.h>
28 : : #include <comphelper/enumhelper.hxx>
29 : :
30 : : #define PROPERTY_ID_VALUE 1000
31 : :
32 : : //........................................................................
33 : : namespace dbtools
34 : : {
35 : : namespace param
36 : : {
37 : : //........................................................................
38 : :
39 : : /** === begin UNO using === **/
40 : : using ::com::sun::star::uno::Reference;
41 : : using ::com::sun::star::beans::XPropertySet;
42 : : using ::com::sun::star::sdbc::XParameters;
43 : : using ::com::sun::star::uno::Sequence;
44 : : using ::com::sun::star::uno::Type;
45 : : using ::com::sun::star::uno::RuntimeException;
46 : : using ::com::sun::star::uno::XWeak;
47 : : using ::com::sun::star::beans::XPropertySet;
48 : : using ::com::sun::star::beans::XFastPropertySet;
49 : : using ::com::sun::star::beans::XMultiPropertySet;
50 : : using ::com::sun::star::beans::XPropertySetInfo;
51 : : using ::com::sun::star::beans::Property;
52 : : using ::com::sun::star::uno::Exception;
53 : : using ::com::sun::star::uno::UNO_QUERY_THROW;
54 : : using ::com::sun::star::uno::Any;
55 : : using ::com::sun::star::lang::IllegalArgumentException;
56 : : using ::com::sun::star::sdbc::SQLException;
57 : : using ::com::sun::star::lang::WrappedTargetException;
58 : : using ::com::sun::star::lang::IndexOutOfBoundsException;
59 : : using ::com::sun::star::container::XEnumeration;
60 : : using ::com::sun::star::sdb::XSingleSelectQueryAnalyzer;
61 : : using ::com::sun::star::sdb::XParametersSupplier;
62 : : using ::com::sun::star::lang::DisposedException;
63 : : /** === end UNO using === **/
64 : : namespace PropertyAttribute = ::com::sun::star::beans::PropertyAttribute;
65 : : namespace DataType = ::com::sun::star::sdbc::DataType;
66 : :
67 : : //====================================================================
68 : : //= ParameterWrapper
69 : : //====================================================================
70 : : //--------------------------------------------------------------------
71 : 12 : ParameterWrapper::ParameterWrapper( const Reference< XPropertySet >& _rxColumn )
72 : : :PropertyBase( m_aBHelper )
73 [ + - ][ + - ]: 12 : ,m_xDelegator( _rxColumn )
[ + - ]
74 : : {
75 [ + - ]: 12 : if ( m_xDelegator.is() )
76 [ + - ][ + - ]: 12 : m_xDelegatorPSI = m_xDelegator->getPropertySetInfo();
[ + - ]
77 [ - + ]: 12 : if ( !m_xDelegatorPSI.is() )
78 [ # # ]: 0 : throw RuntimeException();
79 : 12 : }
80 : :
81 : : //--------------------------------------------------------------------
82 : 0 : ParameterWrapper::ParameterWrapper( const Reference< XPropertySet >& _rxColumn,
83 : : const Reference< XParameters >& _rxAllParameters, const ::std::vector< sal_Int32 >& _rIndexes )
84 : : :PropertyBase( m_aBHelper )
85 : : ,m_aIndexes( _rIndexes )
86 : : ,m_xDelegator( _rxColumn )
87 [ # # ][ # # ]: 0 : ,m_xValueDestination( _rxAllParameters )
[ # # ]
88 : : {
89 [ # # ]: 0 : if ( m_xDelegator.is() )
90 [ # # ][ # # ]: 0 : m_xDelegatorPSI = m_xDelegator->getPropertySetInfo();
[ # # ]
91 [ # # ]: 0 : if ( !m_xDelegatorPSI.is() )
92 [ # # ]: 0 : throw RuntimeException();
93 : :
94 : : OSL_ENSURE( !m_aIndexes.empty(), "ParameterWrapper::ParameterWrapper: sure about the indexes?" );
95 : 0 : }
96 : :
97 : : //--------------------------------------------------------------------
98 [ + - ][ + - ]: 12 : ParameterWrapper::~ParameterWrapper()
[ + - ][ + - ]
99 : : {
100 [ - + ]: 24 : }
101 : :
102 : : //--------------------------------------------------------------------
103 [ # # ][ # # ]: 48 : IMPLEMENT_FORWARD_XINTERFACE2( ParameterWrapper, UnoBase, PropertyBase )
104 : :
105 : : //--------------------------------------------------------------------
106 : 0 : Sequence< Type > SAL_CALL ParameterWrapper::getTypes( ) throw(RuntimeException)
107 : : {
108 : 0 : Sequence< Type > aTypes( 4 );
109 [ # # ][ # # ]: 0 : aTypes[ 1 ] = ::getCppuType( static_cast< Reference< XWeak >* >( NULL ) );
110 [ # # ][ # # ]: 0 : aTypes[ 1 ] = ::getCppuType( static_cast< Reference< XPropertySet >* >( NULL ) );
111 [ # # ][ # # ]: 0 : aTypes[ 2 ] = ::getCppuType( static_cast< Reference< XFastPropertySet >* >( NULL ) );
112 [ # # ][ # # ]: 0 : aTypes[ 3 ] = ::getCppuType( static_cast< Reference< XMultiPropertySet >* >( NULL ) );
113 : 0 : return aTypes;
114 : : }
115 : :
116 : : //--------------------------------------------------------------------
117 : 0 : IMPLEMENT_GET_IMPLEMENTATION_ID( ParameterWrapper )
118 : :
119 : : //--------------------------------------------------------------------
120 : 0 : ::rtl::OUString ParameterWrapper::impl_getPseudoAggregatePropertyName( sal_Int32 _nHandle ) const
121 : : {
122 [ # # ]: 0 : Reference< XPropertySetInfo > xInfo = const_cast<ParameterWrapper*>( this )->getPropertySetInfo();
123 [ # # ][ # # ]: 0 : Sequence< Property > aProperties = xInfo->getProperties();
124 : 0 : const Property* pProperties = aProperties.getConstArray();
125 [ # # ]: 0 : for ( sal_Int32 i = 0; i < aProperties.getLength(); ++i, ++pProperties )
126 : : {
127 [ # # ]: 0 : if ( pProperties->Handle == _nHandle )
128 : 0 : return pProperties->Name;
129 : : }
130 : :
131 : : OSL_FAIL( "ParameterWrapper::impl_getPseudoAggregatePropertyName: invalid argument!" );
132 [ # # ]: 0 : return ::rtl::OUString();
133 : : }
134 : :
135 : : //--------------------------------------------------------------------
136 : 0 : Reference< XPropertySetInfo > ParameterWrapper::getPropertySetInfo() throw( RuntimeException )
137 : : {
138 : 0 : return createPropertySetInfo( getInfoHelper() );
139 : : }
140 : :
141 : : //--------------------------------------------------------------------
142 : 0 : ::cppu::IPropertyArrayHelper& ParameterWrapper::getInfoHelper()
143 : : {
144 [ # # ]: 0 : if ( !m_pInfoHelper.get() )
145 : : {
146 [ # # ]: 0 : Sequence< Property > aProperties;
147 : : try
148 : : {
149 [ # # ][ # # ]: 0 : aProperties = m_xDelegatorPSI->getProperties();
[ # # ][ # # ]
150 : 0 : sal_Int32 nProperties( aProperties.getLength() );
151 [ # # ]: 0 : aProperties.realloc( nProperties + 1 );
152 [ # # ]: 0 : aProperties[ nProperties ] = Property(
153 : : ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( "Value" ) ),
154 : : PROPERTY_ID_VALUE,
155 : 0 : ::cppu::UnoType< Any >::get(),
156 : : PropertyAttribute::TRANSIENT | PropertyAttribute::MAYBEVOID
157 [ # # ][ # # ]: 0 : );
158 : : }
159 [ # # ]: 0 : catch( const Exception& )
160 : : {
161 : : DBG_UNHANDLED_EXCEPTION();
162 : : }
163 : :
164 [ # # ][ # # ]: 0 : m_pInfoHelper.reset( new ::cppu::OPropertyArrayHelper( aProperties, false ) );
165 : : }
166 : 0 : return *m_pInfoHelper;
167 : : }
168 : :
169 : : //--------------------------------------------------------------------
170 : 0 : sal_Bool ParameterWrapper::convertFastPropertyValue(Any& rConvertedValue, Any& rOldValue, sal_Int32 nHandle, const Any& rValue) throw( IllegalArgumentException )
171 : : {
172 : : OSL_ENSURE( PROPERTY_ID_VALUE == nHandle, "ParameterWrapper::convertFastPropertyValue: the only non-readonly prop should be our PROPERTY_VALUE!" );
173 : : (void)nHandle;
174 : :
175 : : // we're lazy here ...
176 : 0 : rOldValue = m_aValue.makeAny();
177 : 0 : rConvertedValue = rValue;
178 : 0 : return sal_True; // assume "modified" ...
179 : : }
180 : :
181 : : //--------------------------------------------------------------------
182 : 0 : void ParameterWrapper::setFastPropertyValue_NoBroadcast( sal_Int32 nHandle, const Any& rValue ) throw( Exception )
183 : : {
184 [ # # ]: 0 : if ( nHandle == PROPERTY_ID_VALUE )
185 : : {
186 : : try
187 : : {
188 : : // TODO : aParamType & nScale can be obtained within the constructor ....
189 : 0 : sal_Int32 nParamType = DataType::VARCHAR;
190 [ # # ][ # # ]: 0 : OSL_VERIFY( m_xDelegator->getPropertyValue( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( "Type" ) ) ) >>= nParamType );
[ # # ]
191 : :
192 : 0 : sal_Int32 nScale = 0;
193 [ # # ][ # # ]: 0 : if ( m_xDelegatorPSI->hasPropertyByName( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( "Scale" ) ) ) )
[ # # ][ # # ]
194 [ # # ][ # # ]: 0 : OSL_VERIFY( m_xDelegator->getPropertyValue( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( "Scale" ) ) ) >>= nScale );
[ # # ]
195 : :
196 [ # # ]: 0 : if ( m_xValueDestination.is() )
197 : : {
198 [ # # ][ # # ]: 0 : for ( ::std::vector< sal_Int32 >::iterator aIter = m_aIndexes.begin(); aIter != m_aIndexes.end(); ++aIter )
[ # # ]
199 : : {
200 [ # # ][ # # ]: 0 : m_xValueDestination->setObjectWithInfo( *aIter + 1, rValue, nParamType, nScale );
[ # # ]
201 : : // (the index of the parameters is one-based)
202 : : }
203 : : }
204 : :
205 [ # # ]: 0 : m_aValue = rValue;
206 : : }
207 [ # # ]: 0 : catch( SQLException& e )
208 : : {
209 [ # # ]: 0 : WrappedTargetException aExceptionWrapper;
210 [ # # ]: 0 : aExceptionWrapper.Context = e.Context;
211 : 0 : aExceptionWrapper.Message = e.Message;
212 [ # # ]: 0 : aExceptionWrapper.TargetException <<= e;
213 [ # # ]: 0 : throw WrappedTargetException( aExceptionWrapper );
214 : : }
215 : : }
216 : : else
217 : : {
218 [ # # ]: 0 : ::rtl::OUString aName = impl_getPseudoAggregatePropertyName( nHandle );
219 [ # # ][ # # ]: 0 : m_xDelegator->setPropertyValue( aName, rValue );
220 : : }
221 : 0 : }
222 : :
223 : : //--------------------------------------------------------------------
224 : 0 : void ParameterWrapper::getFastPropertyValue( Any& rValue, sal_Int32 nHandle ) const
225 : : {
226 [ # # ]: 0 : if ( nHandle == PROPERTY_ID_VALUE )
227 : : {
228 : 0 : rValue = m_aValue.makeAny();
229 : : }
230 : : else
231 : : {
232 [ # # ]: 0 : ::rtl::OUString aName = impl_getPseudoAggregatePropertyName( nHandle );
233 [ # # ][ # # ]: 0 : rValue = m_xDelegator->getPropertyValue( aName );
234 : : }
235 : 0 : }
236 : :
237 : : //--------------------------------------------------------------------
238 : 12 : void SAL_CALL ParameterWrapper::dispose()
239 : : {
240 [ + - ]: 12 : ::osl::MutexGuard aGuard( m_aMutex );
241 : :
242 [ + - ]: 12 : m_aValue.setNull();
243 [ + - ]: 12 : m_aIndexes.resize(0);
244 : 12 : m_xDelegator.clear();
245 : 12 : m_xDelegatorPSI.clear();
246 : 12 : m_xValueDestination.clear();
247 : :
248 [ + - ]: 12 : m_aBHelper.bDisposed = sal_True;
249 : 12 : }
250 : :
251 : : //====================================================================
252 : : //= ParameterWrapperContainer
253 : : //====================================================================
254 : : //--------------------------------------------------------------------
255 : 0 : ParameterWrapperContainer::ParameterWrapperContainer()
256 [ # # ][ # # ]: 0 : :ParameterWrapperContainer_Base( m_aMutex )
257 : : {
258 : 0 : }
259 : :
260 : : //--------------------------------------------------------------------
261 : 40 : ParameterWrapperContainer::ParameterWrapperContainer( const Reference< XSingleSelectQueryAnalyzer >& _rxComposer )
262 [ + - ][ + - ]: 40 : :ParameterWrapperContainer_Base( m_aMutex )
263 : : {
264 [ + - ]: 40 : Reference< XParametersSupplier > xSuppParams( _rxComposer, UNO_QUERY_THROW );
265 [ + - ][ + - ]: 40 : Reference< XIndexAccess > xParameters( xSuppParams->getParameters(), UNO_QUERY_THROW );
[ + - ]
266 [ + - ][ + - ]: 40 : sal_Int32 nParamCount( xParameters->getCount() );
267 [ + - ]: 40 : m_aParameters.reserve( nParamCount );
268 [ + + ]: 52 : for ( sal_Int32 i=0; i<nParamCount; ++i )
269 : : {
270 [ + - ][ + - ]: 12 : m_aParameters.push_back( new ParameterWrapper( Reference< XPropertySet >( xParameters->getByIndex( i ), UNO_QUERY_THROW ) ) );
[ + - ][ + - ]
[ + - ]
271 : 40 : }
272 : 40 : }
273 : :
274 : : //--------------------------------------------------------------------
275 [ + - ]: 40 : ParameterWrapperContainer::~ParameterWrapperContainer()
276 : : {
277 [ - + ]: 80 : }
278 : :
279 : : //--------------------------------------------------------------------
280 : 0 : Type SAL_CALL ParameterWrapperContainer::getElementType() throw( RuntimeException )
281 : : {
282 [ # # ]: 0 : ::osl::MutexGuard aGuard( m_aMutex );
283 [ # # ]: 0 : impl_checkDisposed_throw();
284 [ # # ][ # # ]: 0 : return ::getCppuType( static_cast< Reference< XPropertySet >* >( NULL ) );
285 : : }
286 : :
287 : : //--------------------------------------------------------------------
288 : 0 : sal_Bool SAL_CALL ParameterWrapperContainer::hasElements() throw( RuntimeException )
289 : : {
290 [ # # ]: 0 : ::osl::MutexGuard aGuard( m_aMutex );
291 [ # # ]: 0 : impl_checkDisposed_throw();
292 [ # # ]: 0 : return !m_aParameters.empty();
293 : : }
294 : :
295 : : //--------------------------------------------------------------------
296 : 0 : sal_Int32 SAL_CALL ParameterWrapperContainer::getCount() throw( RuntimeException )
297 : : {
298 [ # # ]: 0 : ::osl::MutexGuard aGuard( m_aMutex );
299 [ # # ]: 0 : impl_checkDisposed_throw();
300 [ # # ]: 0 : return m_aParameters.size();
301 : : }
302 : :
303 : : //--------------------------------------------------------------------
304 : 0 : Any SAL_CALL ParameterWrapperContainer::getByIndex( sal_Int32 _nIndex ) throw( IndexOutOfBoundsException, WrappedTargetException, RuntimeException )
305 : : {
306 [ # # ]: 0 : ::osl::MutexGuard aGuard( m_aMutex );
307 [ # # ]: 0 : impl_checkDisposed_throw();
308 : :
309 [ # # ][ # # ]: 0 : if ( ( _nIndex < 0 ) || ( _nIndex >= (sal_Int32)m_aParameters.size() ) )
[ # # ]
310 [ # # ]: 0 : throw IndexOutOfBoundsException();
311 : :
312 [ # # ][ # # ]: 0 : return makeAny( Reference< XPropertySet >( m_aParameters[ _nIndex ].get() ) );
[ # # ][ # # ]
313 : : }
314 : :
315 : : //--------------------------------------------------------------------
316 : 0 : Reference< XEnumeration > ParameterWrapperContainer::createEnumeration() throw( RuntimeException )
317 : : {
318 [ # # ]: 0 : ::osl::MutexGuard aGuard( m_aMutex );
319 [ # # ]: 0 : impl_checkDisposed_throw();
320 : :
321 [ # # ][ # # ]: 0 : return new ::comphelper::OEnumerationByIndex( static_cast< XIndexAccess* >( this ) );
[ # # ][ # # ]
[ # # ]
322 : : }
323 : :
324 : : //--------------------------------------------------------------------
325 : 40 : void ParameterWrapperContainer::impl_checkDisposed_throw()
326 : : {
327 [ - + ]: 40 : if ( rBHelper.bDisposed )
328 [ # # ][ # # ]: 0 : throw DisposedException( ::rtl::OUString(), *this );
329 : 40 : }
330 : :
331 : : //--------------------------------------------------------------------
332 : 40 : void SAL_CALL ParameterWrapperContainer::disposing()
333 : : {
334 [ + - ]: 40 : ::osl::MutexGuard aGuard( m_aMutex );
335 [ + - ]: 40 : impl_checkDisposed_throw();
336 : :
337 [ + - ][ + - ]: 104 : for ( Parameters::const_iterator param = m_aParameters.begin();
[ + + ]
338 : 52 : param != m_aParameters.end();
339 : : ++param
340 : : )
341 : : {
342 [ + - ]: 12 : (*param)->dispose();
343 : : }
344 : :
345 [ + - ]: 40 : Parameters aEmpty;
346 [ + - ]: 40 : m_aParameters.swap( aEmpty );
347 : 40 : }
348 : :
349 : : //........................................................................
350 : : } } // namespace dbtools::param
351 : : //........................................................................
352 : :
353 : : /* vim:set shiftwidth=4 softtabstop=4 expandtab: */
|
