1 /**************************************************************
2  *
3  * Licensed to the Apache Software Foundation (ASF) under one
4  * or more contributor license agreements.  See the NOTICE file
5  * distributed with this work for additional information
6  * regarding copyright ownership.  The ASF licenses this file
7  * to you under the Apache License, Version 2.0 (the
8  * "License"); you may not use this file except in compliance
9  * with the License.  You may obtain a copy of the License at
10  *
11  *   http://www.apache.org/licenses/LICENSE-2.0
12  *
13  * Unless required by applicable law or agreed to in writing,
14  * software distributed under the License is distributed on an
15  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16  * KIND, either express or implied.  See the License for the
17  * specific language governing permissions and limitations
18  * under the License.
19  *
20  *************************************************************/
21 
22 
23 
24 #include <stdio.h>
25 #include <osl/diagnose.h>
26 #include "SStatement.hxx"
27 #include "SConnection.hxx"
28 #include "SResultSet.hxx"
29 #include <osl/thread.h>
30 #include <com/sun/star/sdbc/ResultSetConcurrency.hpp>
31 #include <com/sun/star/sdbc/ResultSetType.hpp>
32 #include <com/sun/star/sdbc/FetchDirection.hpp>
33 #include <com/sun/star/lang/DisposedException.hpp>
34 #include <cppuhelper/typeprovider.hxx>
35 #include "propertyids.hxx"
36 
37 using namespace connectivity::skeleton;
38 //------------------------------------------------------------------------------
39 using namespace com::sun::star::uno;
40 using namespace com::sun::star::lang;
41 using namespace com::sun::star::beans;
42 using namespace com::sun::star::sdbc;
43 using namespace com::sun::star::sdbcx;
44 using namespace com::sun::star::container;
45 using namespace com::sun::star::io;
46 using namespace com::sun::star::util;
47 //------------------------------------------------------------------------------
OStatement_Base(OConnection * _pConnection)48 OStatement_Base::OStatement_Base(OConnection* _pConnection )
49 	: OStatement_BASE(m_aMutex),
50 	OPropertySetHelper(OStatement_BASE::rBHelper),
51 	rBHelper(OStatement_BASE::rBHelper),
52 	m_pConnection(_pConnection)
53 {
54 	m_pConnection->acquire();
55 }
56 // -----------------------------------------------------------------------------
~OStatement_Base()57 OStatement_Base::~OStatement_Base()
58 {
59 }
60 //------------------------------------------------------------------------------
disposeResultSet()61 void OStatement_Base::disposeResultSet()
62 {
63 	// free the cursor if alive
64 	Reference< XComponent > xComp(m_xResultSet.get(), UNO_QUERY);
65 	if (xComp.is())
66 		xComp->dispose();
67 	m_xResultSet = Reference< XResultSet>();
68 }
69 //------------------------------------------------------------------------------
disposing()70 void OStatement_BASE2::disposing()
71 {
72 	::osl::MutexGuard aGuard(m_aMutex);
73 
74 	disposeResultSet();
75 
76 	if (m_pConnection)
77 		m_pConnection->release();
78 	m_pConnection = NULL;
79 
80 	dispose_ChildImpl();
81 	OStatement_Base::disposing();
82 }
83 //-----------------------------------------------------------------------------
release()84 void SAL_CALL OStatement_BASE2::release() throw()
85 {
86 	relase_ChildImpl();
87 }
88 //-----------------------------------------------------------------------------
queryInterface(const Type & rType)89 Any SAL_CALL OStatement_Base::queryInterface( const Type & rType ) throw(RuntimeException)
90 {
91 	Any aRet = OStatement_BASE::queryInterface(rType);
92 	if(!aRet.hasValue())
93 		aRet = OPropertySetHelper::queryInterface(rType);
94 	return aRet;
95 }
96 // -------------------------------------------------------------------------
getTypes()97 Sequence< Type > SAL_CALL OStatement_Base::getTypes(  ) throw(RuntimeException)
98 {
99 	::cppu::OTypeCollection aTypes(
100         ::cppu::UnoType< Reference< XMultiPropertySet > >::get(),
101         ::cppu::UnoType< Reference< XFastPropertySet > >::get(),
102         ::cppu::UnoType< Reference< XPropertySet > >::get());
103 
104 	return concatSequences(aTypes.getTypes(),OStatement_BASE::getTypes());
105 }
106 // -------------------------------------------------------------------------
107 
cancel()108 void SAL_CALL OStatement_Base::cancel(  ) throw(RuntimeException)
109 {
110 	::osl::MutexGuard aGuard( m_aMutex );
111 	checkDisposed(OStatement_BASE::rBHelper.bDisposed);
112 	// cancel the current sql statement
113 }
114 // -------------------------------------------------------------------------
115 
close()116 void SAL_CALL OStatement_Base::close(  ) throw(SQLException, RuntimeException)
117 {
118 	{
119 		::osl::MutexGuard aGuard( m_aMutex );
120 		checkDisposed(OStatement_BASE::rBHelper.bDisposed);
121 
122 	}
123 	dispose();
124 }
125 // -------------------------------------------------------------------------
126 
clearBatch()127 void SAL_CALL OStatement::clearBatch(  ) throw(SQLException, RuntimeException)
128 {
129 	// if you support batches clear it here
130 }
131 // -------------------------------------------------------------------------
execute(const::rtl::OUString & sql)132 sal_Bool SAL_CALL OStatement_Base::execute( const ::rtl::OUString& sql ) throw(SQLException, RuntimeException)
133 {
134 	::osl::MutexGuard aGuard( m_aMutex );
135 	checkDisposed(OStatement_BASE::rBHelper.bDisposed);
136 
137 	// returns true when a resultset is available
138 	return sal_False;
139 }
140 // -------------------------------------------------------------------------
141 
executeQuery(const::rtl::OUString & sql)142 Reference< XResultSet > SAL_CALL OStatement_Base::executeQuery( const ::rtl::OUString& sql ) throw(SQLException, RuntimeException)
143 {
144 	::osl::MutexGuard aGuard( m_aMutex );
145 	checkDisposed(OStatement_BASE::rBHelper.bDisposed);
146 
147 
148 	Reference< XResultSet > xRS = NULL;
149 	// create a resultset as result of executing the sql statement
150 	// you have to here something :-)
151 	m_xResultSet = xRS; // we nedd a reference to it for later use
152 	return xRS;
153 }
154 // -------------------------------------------------------------------------
155 
getConnection()156 Reference< XConnection > SAL_CALL OStatement_Base::getConnection(  ) throw(SQLException, RuntimeException)
157 {
158 	::osl::MutexGuard aGuard( m_aMutex );
159 	checkDisposed(OStatement_BASE::rBHelper.bDisposed);
160 
161 	// just return our connection here
162 	return (Reference< XConnection >)m_pConnection;
163 }
164 // -----------------------------------------------------------------------------
getUpdateCount()165 sal_Int32 SAL_CALL OStatement_Base::getUpdateCount(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException)
166 {
167 	return 0;
168 }
169 // -------------------------------------------------------------------------
170 
queryInterface(const Type & rType)171 Any SAL_CALL OStatement::queryInterface( const Type & rType ) throw(RuntimeException)
172 {
173 	Any aRet = ::cppu::queryInterface(rType,static_cast< XBatchExecution*> (this));
174 	if(!aRet.hasValue())
175 		aRet = OStatement_Base::queryInterface(rType);
176 	return aRet;
177 }
178 // -------------------------------------------------------------------------
179 
addBatch(const::rtl::OUString & sql)180 void SAL_CALL OStatement::addBatch( const ::rtl::OUString& sql ) throw(SQLException, RuntimeException)
181 {
182 	::osl::MutexGuard aGuard( m_aMutex );
183 	checkDisposed(OStatement_BASE::rBHelper.bDisposed);
184 
185 
186 	m_aBatchList.push_back(sql);
187 }
188 // -------------------------------------------------------------------------
executeBatch()189 Sequence< sal_Int32 > SAL_CALL OStatement::executeBatch(  ) throw(SQLException, RuntimeException)
190 {
191 	::osl::MutexGuard aGuard( m_aMutex );
192 	checkDisposed(OStatement_BASE::rBHelper.bDisposed);
193 
194 	return Sequence< sal_Int32 >();
195 }
196 // -------------------------------------------------------------------------
197 
198 
executeUpdate(const::rtl::OUString & sql)199 sal_Int32 SAL_CALL OStatement_Base::executeUpdate( const ::rtl::OUString& sql ) throw(SQLException, RuntimeException)
200 {
201 	::osl::MutexGuard aGuard( m_aMutex );
202 	checkDisposed(OStatement_BASE::rBHelper.bDisposed);
203 
204 	// the return values gives information about how many rows are affected by executing the sql statement
205 	return 0;
206 
207 }
208 // -------------------------------------------------------------------------
209 
getResultSet()210 Reference< XResultSet > SAL_CALL OStatement_Base::getResultSet(  ) throw(SQLException, RuntimeException)
211 {
212 	::osl::MutexGuard aGuard( m_aMutex );
213 	checkDisposed(OStatement_BASE::rBHelper.bDisposed);
214 
215 //	return our save resultset here
216 	return m_xResultSet;
217 }
218 // -------------------------------------------------------------------------
219 
getMoreResults()220 sal_Bool SAL_CALL OStatement_Base::getMoreResults(  ) throw(SQLException, RuntimeException)
221 {
222 	::osl::MutexGuard aGuard( m_aMutex );
223 	checkDisposed(OStatement_BASE::rBHelper.bDisposed);
224 
225 	// if your driver supports more than only one resultset
226 	// and has one more at this moment return true
227 	return sal_False;
228 }
229 // -------------------------------------------------------------------------
230 
231 // -------------------------------------------------------------------------
getWarnings()232 Any SAL_CALL OStatement_Base::getWarnings(  ) throw(SQLException, RuntimeException)
233 {
234 	::osl::MutexGuard aGuard( m_aMutex );
235 	checkDisposed(OStatement_BASE::rBHelper.bDisposed);
236 
237 
238 	return makeAny(m_aLastWarning);
239 }
240 // -------------------------------------------------------------------------
241 
242 // -------------------------------------------------------------------------
clearWarnings()243 void SAL_CALL OStatement_Base::clearWarnings(  ) throw(SQLException, RuntimeException)
244 {
245 	::osl::MutexGuard aGuard( m_aMutex );
246 	checkDisposed(OStatement_BASE::rBHelper.bDisposed);
247 
248 
249 	m_aLastWarning = SQLWarning();
250 }
251 // -------------------------------------------------------------------------
createArrayHelper() const252 ::cppu::IPropertyArrayHelper* OStatement_Base::createArrayHelper( ) const
253 {
254 	// this properties are define by the service statement
255 	// they must in alphabetic order
256 	Sequence< Property > aProps(10);
257 	Property* pProperties = aProps.getArray();
258 	sal_Int32 nPos = 0;
259 	DECL_PROP0(CURSORNAME,	::rtl::OUString);
260 	DECL_BOOL_PROP0(ESCAPEPROCESSING);
261 	DECL_PROP0(FETCHDIRECTION,sal_Int32);
262 	DECL_PROP0(FETCHSIZE,	sal_Int32);
263 	DECL_PROP0(MAXFIELDSIZE,sal_Int32);
264 	DECL_PROP0(MAXROWS,		sal_Int32);
265 	DECL_PROP0(QUERYTIMEOUT,sal_Int32);
266 	DECL_PROP0(RESULTSETCONCURRENCY,sal_Int32);
267 	DECL_PROP0(RESULTSETTYPE,sal_Int32);
268 	DECL_BOOL_PROP0(USEBOOKMARKS);
269 
270 	return new ::cppu::OPropertyArrayHelper(aProps);
271 }
272 
273 // -------------------------------------------------------------------------
getInfoHelper()274 ::cppu::IPropertyArrayHelper & OStatement_Base::getInfoHelper()
275 {
276 	return *const_cast<OStatement_Base*>(this)->getArrayHelper();
277 }
278 // -------------------------------------------------------------------------
convertFastPropertyValue(Any & rConvertedValue,Any & rOldValue,sal_Int32 nHandle,const Any & rValue)279 sal_Bool OStatement_Base::convertFastPropertyValue(
280 							Any & rConvertedValue,
281 							Any & rOldValue,
282 							sal_Int32 nHandle,
283 							const Any& rValue )
284 								throw (::com::sun::star::lang::IllegalArgumentException)
285 {
286 	sal_Bool bConverted = sal_False;
287 	// here we have to try to convert
288 	return bConverted;
289 }
290 // -------------------------------------------------------------------------
setFastPropertyValue_NoBroadcast(sal_Int32 nHandle,const Any & rValue)291 void OStatement_Base::setFastPropertyValue_NoBroadcast(sal_Int32 nHandle,const Any& rValue) throw (Exception)
292 {
293 	// set the value to what ever is necessary
294 	switch(nHandle)
295 	{
296 		case PROPERTY_ID_QUERYTIMEOUT:
297 		case PROPERTY_ID_MAXFIELDSIZE:
298 		case PROPERTY_ID_MAXROWS:
299 		case PROPERTY_ID_CURSORNAME:
300 		case PROPERTY_ID_RESULTSETCONCURRENCY:
301 		case PROPERTY_ID_RESULTSETTYPE:
302 		case PROPERTY_ID_FETCHDIRECTION:
303 		case PROPERTY_ID_FETCHSIZE:
304 		case PROPERTY_ID_ESCAPEPROCESSING:
305 		case PROPERTY_ID_USEBOOKMARKS:
306 		default:
307 			;
308 	}
309 }
310 // -------------------------------------------------------------------------
getFastPropertyValue(Any & rValue,sal_Int32 nHandle) const311 void OStatement_Base::getFastPropertyValue(Any& rValue,sal_Int32 nHandle) const
312 {
313 	switch(nHandle)
314 	{
315 		case PROPERTY_ID_QUERYTIMEOUT:
316 		case PROPERTY_ID_MAXFIELDSIZE:
317 		case PROPERTY_ID_MAXROWS:
318 		case PROPERTY_ID_CURSORNAME:
319 		case PROPERTY_ID_RESULTSETCONCURRENCY:
320 		case PROPERTY_ID_RESULTSETTYPE:
321 		case PROPERTY_ID_FETCHDIRECTION:
322 		case PROPERTY_ID_FETCHSIZE:
323 		case PROPERTY_ID_ESCAPEPROCESSING:
324 		case PROPERTY_ID_USEBOOKMARKS:
325 		default:
326 			;
327 	}
328 }
329 // -------------------------------------------------------------------------
330 IMPLEMENT_SERVICE_INFO(OStatement,"com.sun.star.sdbcx.OStatement","com.sun.star.sdbc.Statement");
331 // -----------------------------------------------------------------------------
acquire()332 void SAL_CALL OStatement_Base::acquire() throw()
333 {
334 	OStatement_BASE::acquire();
335 }
336 // -----------------------------------------------------------------------------
release()337 void SAL_CALL OStatement_Base::release() throw()
338 {
339 	OStatement_BASE::release();
340 }
341 // -----------------------------------------------------------------------------
acquire()342 void SAL_CALL OStatement::acquire() throw()
343 {
344 	OStatement_BASE2::acquire();
345 }
346 // -----------------------------------------------------------------------------
release()347 void SAL_CALL OStatement::release() throw()
348 {
349 	OStatement_BASE2::release();
350 }
351 // -----------------------------------------------------------------------------
getPropertySetInfo()352 Reference< ::com::sun::star::beans::XPropertySetInfo > SAL_CALL OStatement_Base::getPropertySetInfo(  ) throw(RuntimeException)
353 {
354 	return ::cppu::OPropertySetHelper::createPropertySetInfo(getInfoHelper());
355 }
356 // -----------------------------------------------------------------------------
357 
358