Line data Source code
1 : /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
2 : /*************************************************************************
3 : *
4 : * Effective License of whole file:
5 : *
6 : * This library is free software; you can redistribute it and/or
7 : * modify it under the terms of the GNU Lesser General Public
8 : * License version 2.1, as published by the Free Software Foundation.
9 : *
10 : * This library is distributed in the hope that it will be useful,
11 : * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 : * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 : * Lesser General Public License for more details.
14 : *
15 : * You should have received a copy of the GNU Lesser General Public
16 : * License along with this library; if not, write to the Free Software
17 : * Foundation, Inc., 59 Temple Place, Suite 330, Boston,
18 : * MA 02111-1307 USA
19 : *
20 : * Parts "Copyright by Sun Microsystems, Inc" prior to August 2011:
21 : *
22 : * The Contents of this file are made available subject to the terms of
23 : * the GNU Lesser General Public License Version 2.1
24 : *
25 : * Copyright: 2000 by Sun Microsystems, Inc.
26 : *
27 : * Contributor(s): Joerg Budischewski
28 : *
29 : * All parts contributed on or after August 2011:
30 : *
31 : * Version: MPL 1.1 / GPLv3+ / LGPLv2.1+
32 : *
33 : * The contents of this file are subject to the Mozilla Public License Version
34 : * 1.1 (the "License"); you may not use this file except in compliance with
35 : * the License or as specified alternatively below. You may obtain a copy of
36 : * the License at http://www.mozilla.org/MPL/
37 : *
38 : * Software distributed under the License is distributed on an "AS IS" basis,
39 : * WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
40 : * for the specific language governing rights and limitations under the
41 : * License.
42 : *
43 : * Major Contributor(s):
44 : * [ Copyright (C) 2011 Lionel Elie Mamane <lionel@mamane.lu> ]
45 : *
46 : * All Rights Reserved.
47 : *
48 : * For minor contributions see the git repository.
49 : *
50 : * Alternatively, the contents of this file may be used under the terms of
51 : * either the GNU General Public License Version 3 or later (the "GPLv3+"), or
52 : * the GNU Lesser General Public License Version 2.1 or later (the "LGPLv2.1+"),
53 : * in which case the provisions of the GPLv3+ or the LGPLv2.1+ are applicable
54 : * instead of those above.
55 : *
56 : ************************************************************************/
57 :
58 : #include <osl/thread.h>
59 :
60 : #include <rtl/ustrbuf.hxx>
61 :
62 : #include <cppuhelper/typeprovider.hxx>
63 : #include <cppuhelper/queryinterface.hxx>
64 :
65 : #include "pq_tools.hxx"
66 : #include "pq_array.hxx"
67 : #include "pq_statement.hxx"
68 : #include "pq_baseresultset.hxx"
69 : #include "pq_resultsetmetadata.hxx"
70 :
71 : #include <com/sun/star/lang/DisposedException.hpp>
72 :
73 : using osl::Mutex;
74 : using osl::MutexGuard;
75 :
76 : using rtl::OUString;
77 : using rtl::OUStringToOString;
78 : using rtl::OUStringBuffer;
79 : using rtl::OString;
80 :
81 : using com::sun::star::beans::XPropertySetInfo;
82 : using com::sun::star::beans::XPropertySet;
83 : using com::sun::star::beans::XMultiPropertySet;
84 : using com::sun::star::beans::XFastPropertySet;
85 :
86 : using com::sun::star::uno::Any;
87 : using com::sun::star::uno::makeAny;
88 : using com::sun::star::uno::Type;
89 : using com::sun::star::uno::RuntimeException;
90 : using com::sun::star::uno::Exception;
91 : using com::sun::star::uno::Sequence;
92 : using com::sun::star::uno::Reference;
93 : using com::sun::star::uno::XInterface;
94 :
95 : using com::sun::star::lang::IllegalArgumentException;
96 :
97 : using com::sun::star::sdbc::XWarningsSupplier;
98 : using com::sun::star::sdbc::XCloseable;
99 : using com::sun::star::sdbc::XStatement;
100 : using com::sun::star::sdbc::XResultSet;
101 : using com::sun::star::sdbc::XConnection;
102 : using com::sun::star::sdbc::SQLException;
103 : using com::sun::star::sdbc::XRow;
104 : using com::sun::star::sdbc::XColumnLocate;
105 : using com::sun::star::sdbc::XResultSetMetaData;
106 : using com::sun::star::sdbc::XResultSetMetaDataSupplier;
107 :
108 :
109 : using com::sun::star::beans::Property;
110 :
111 : namespace pq_sdbc_driver
112 : {
113 0 : static ::cppu::IPropertyArrayHelper & getResultSetPropertyArrayHelper()
114 : {
115 : static ::cppu::IPropertyArrayHelper *pArrayHelper;
116 0 : if( ! pArrayHelper )
117 : {
118 0 : MutexGuard guard( Mutex::getGlobalMutex() );
119 0 : if( ! pArrayHelper )
120 : {
121 : static Property aTable[] =
122 : {
123 : // LEM TODO: this needs to be kept in sync with other, e.g. pq_statics.css:508
124 : // Should really share!
125 : // At least use for the handles the #define'd values in .hxx file...
126 : Property(
127 : OUString( RTL_CONSTASCII_USTRINGPARAM("CursorName") ), 0,
128 0 : ::getCppuType( (OUString *)0) , 0 ),
129 : Property(
130 : OUString( RTL_CONSTASCII_USTRINGPARAM("EscapeProcessing") ), 1,
131 0 : ::getBooleanCppuType() , 0 ),
132 : Property(
133 : OUString( RTL_CONSTASCII_USTRINGPARAM("FetchDirection") ), 2,
134 0 : ::getCppuType( (sal_Int32 *)0) , 0 ),
135 : Property(
136 : OUString( RTL_CONSTASCII_USTRINGPARAM("FetchSize") ), 3,
137 0 : ::getCppuType( (sal_Int32 *)0) , 0 ),
138 : Property(
139 : OUString( RTL_CONSTASCII_USTRINGPARAM("IsBookmarkable") ), 4,
140 0 : ::getBooleanCppuType() , 0 ),
141 : Property(
142 : OUString( RTL_CONSTASCII_USTRINGPARAM("ResultSetConcurrency") ), 5,
143 0 : ::getCppuType( (sal_Int32 *)0) , 0 ),
144 : Property(
145 : OUString( RTL_CONSTASCII_USTRINGPARAM("ResultSetType") ), 6,
146 0 : ::getCppuType( (sal_Int32 *)0) , 0 )
147 0 : };
148 : OSL_ASSERT( sizeof(aTable) / sizeof(Property) == BASERESULTSET_SIZE );
149 0 : static ::cppu::OPropertyArrayHelper arrayHelper( aTable, BASERESULTSET_SIZE, sal_True );
150 0 : pArrayHelper = &arrayHelper;
151 0 : }
152 : }
153 0 : return *pArrayHelper;
154 : }
155 :
156 0 : BaseResultSet::BaseResultSet(
157 : const ::rtl::Reference< RefCountedMutex > & refMutex,
158 : const Reference< XInterface > & owner,
159 : sal_Int32 rowCount,
160 : sal_Int32 colCount,
161 : const Reference< com::sun::star::script::XTypeConverter > & tc )
162 0 : : OComponentHelper( refMutex->mutex ),
163 : OPropertySetHelper( OComponentHelper::rBHelper ),
164 : m_owner( owner ),
165 : m_tc( tc ),
166 : m_refMutex( refMutex ),
167 : m_row( -1 ),
168 : m_rowCount( rowCount ),
169 0 : m_fieldCount( colCount )
170 : {
171 : POSTGRE_TRACE( "ctor BaseResultSet" );
172 0 : }
173 :
174 : // LEM TODO: refMutex->mutex should live longer than OComponentHelper,
175 : // but calling OComponentHelper::dispose explicitly here calls
176 : // BaseResultSet::~BaseResultSet in an infinite loop :(
177 0 : BaseResultSet::~BaseResultSet()
178 : {
179 : POSTGRE_TRACE( "dtor BaseResultSet" );
180 0 : }
181 :
182 0 : Any BaseResultSet::queryInterface( const Type & reqType ) throw (RuntimeException)
183 : {
184 0 : Any ret;
185 :
186 0 : ret = OComponentHelper::queryInterface( reqType );
187 0 : if( ! ret.hasValue() )
188 : ret = ::cppu::queryInterface( reqType,
189 : static_cast< XResultSet * > ( this ),
190 : static_cast< XResultSetMetaDataSupplier * > ( this ),
191 : static_cast< XRow * > ( this ),
192 : static_cast< XColumnLocate * > ( this ),
193 : static_cast< XCloseable * > ( this ),
194 : static_cast< XPropertySet * > ( this ),
195 : static_cast< XMultiPropertySet * > ( this ),
196 0 : static_cast< XFastPropertySet * > ( this ) );
197 0 : return ret;
198 : }
199 :
200 : // void BaseResultSet::close( ) throw (SQLException, RuntimeException)
201 : // {
202 : // Reference< XInterface > owner;
203 : // {
204 : // ResultSetGuard guard(*this);
205 : // if( m_result )
206 : // {
207 : // PQclear(m_result );
208 : // m_result = 0;
209 : // m_row = -1;
210 : // }
211 : // owner = m_owner;
212 : // m_owner.clear();
213 : // }
214 : // }
215 :
216 0 : Sequence<Type > BaseResultSet::getTypes() throw( RuntimeException )
217 : {
218 : static cppu::OTypeCollection *pCollection;
219 0 : if( ! pCollection )
220 : {
221 0 : MutexGuard guard( osl::Mutex::getGlobalMutex() );
222 0 : if( !pCollection )
223 : {
224 : static cppu::OTypeCollection collection(
225 0 : getCppuType( (Reference< XResultSet> *) 0 ),
226 0 : getCppuType( (Reference< XResultSetMetaDataSupplier> *) 0 ),
227 0 : getCppuType( (Reference< XRow> *) 0 ),
228 0 : getCppuType( (Reference< XColumnLocate> *) 0 ),
229 0 : getCppuType( (Reference< XCloseable> *) 0 ),
230 0 : getCppuType( (Reference< XPropertySet >*) 0 ),
231 0 : getCppuType( (Reference< XFastPropertySet > *) 0 ),
232 0 : getCppuType( (Reference< XMultiPropertySet > *) 0 ),
233 0 : OComponentHelper::getTypes());
234 0 : pCollection = &collection;
235 0 : }
236 : }
237 0 : return pCollection->getTypes();
238 : }
239 :
240 0 : Sequence< sal_Int8> BaseResultSet::getImplementationId() throw( RuntimeException )
241 : {
242 : static cppu::OImplementationId *pId;
243 0 : if( ! pId )
244 : {
245 0 : MutexGuard guard( osl::Mutex::getGlobalMutex() );
246 0 : if( ! pId )
247 : {
248 0 : static cppu::OImplementationId id(sal_False);
249 0 : pId = &id;
250 0 : }
251 : }
252 0 : return pId->getImplementationId();
253 : }
254 :
255 : // Reference< XResultSetMetaData > BaseResultSet::getMetaData( ) throw (SQLException, RuntimeException)
256 : // {
257 : // ResultSetGuard guard(*this);
258 : // checkClosed();
259 : // return new ResultSetMetaData( m_refMutex, this, &m_result );
260 : // }
261 :
262 0 : sal_Bool BaseResultSet::next( ) throw (SQLException, RuntimeException)
263 : {
264 0 : MutexGuard guard( m_refMutex->mutex );
265 0 : checkClosed();
266 0 : m_row ++;
267 0 : return m_row < m_rowCount;
268 : }
269 :
270 0 : sal_Bool BaseResultSet::isBeforeFirst( ) throw (SQLException, RuntimeException)
271 : {
272 0 : MutexGuard guard( m_refMutex->mutex );
273 0 : checkClosed();
274 0 : return m_row == -1;
275 : }
276 :
277 0 : sal_Bool BaseResultSet::isAfterLast( ) throw (SQLException, RuntimeException)
278 : {
279 0 : MutexGuard guard( m_refMutex->mutex );
280 0 : checkClosed();
281 0 : return m_row >= m_rowCount;
282 : }
283 :
284 0 : sal_Bool BaseResultSet::isFirst( ) throw (SQLException, RuntimeException)
285 : {
286 0 : MutexGuard guard( m_refMutex->mutex );
287 0 : checkClosed();
288 0 : return m_row == 0 && m_rowCount;
289 : }
290 :
291 0 : sal_Bool BaseResultSet::isLast( ) throw (SQLException, RuntimeException)
292 : {
293 0 : MutexGuard guard( m_refMutex->mutex );
294 0 : checkClosed();
295 0 : return m_row >= 0 && m_row + 1 == m_rowCount;
296 : }
297 :
298 0 : void BaseResultSet::beforeFirst( ) throw (SQLException, RuntimeException)
299 : {
300 0 : MutexGuard guard( m_refMutex->mutex );
301 0 : checkClosed();
302 0 : m_row = -1;
303 0 : }
304 :
305 0 : void BaseResultSet::afterLast( ) throw (SQLException, RuntimeException)
306 : {
307 0 : MutexGuard guard( m_refMutex->mutex );
308 0 : checkClosed();
309 0 : m_row = m_rowCount;
310 0 : }
311 :
312 0 : sal_Bool BaseResultSet::first( ) throw (SQLException, RuntimeException)
313 : {
314 0 : MutexGuard guard( m_refMutex->mutex );
315 0 : checkClosed();
316 0 : sal_Bool bRet = ( m_rowCount > 0 );
317 0 : if( bRet )
318 0 : m_row = 0;
319 0 : return bRet;
320 : }
321 :
322 0 : sal_Bool BaseResultSet::last( ) throw (SQLException, RuntimeException)
323 : {
324 0 : MutexGuard guard( m_refMutex->mutex );
325 0 : checkClosed();
326 0 : sal_Bool bRet = ( m_rowCount > 0 );
327 0 : if( bRet )
328 0 : m_row = m_rowCount -1;
329 0 : return bRet;
330 : }
331 :
332 0 : sal_Int32 BaseResultSet::getRow( ) throw (SQLException, RuntimeException)
333 : {
334 0 : MutexGuard guard( m_refMutex->mutex );
335 0 : checkClosed();
336 0 : return m_row +1;
337 : }
338 :
339 0 : sal_Bool BaseResultSet::absolute( sal_Int32 row ) throw (SQLException, RuntimeException)
340 : {
341 0 : MutexGuard guard( m_refMutex->mutex );
342 0 : checkClosed();
343 0 : if( row > 0 )
344 : {
345 0 : m_row = row -1;
346 0 : if( m_row > m_rowCount )
347 0 : m_row = m_rowCount;
348 : }
349 : else
350 : {
351 0 : m_row = m_rowCount + row;
352 0 : if( m_row < -1 )
353 0 : m_row = -1;
354 : }
355 0 : return sal_True;
356 : }
357 :
358 0 : sal_Bool BaseResultSet::relative( sal_Int32 rows ) throw (SQLException, RuntimeException)
359 : {
360 0 : MutexGuard guard( m_refMutex->mutex );
361 0 : checkClosed();
362 0 : m_row += rows;
363 :
364 0 : if( m_row > m_rowCount )
365 0 : m_row = m_rowCount;
366 0 : else if ( m_row < -1 )
367 0 : m_row = -1;
368 0 : return sal_True;
369 : }
370 :
371 0 : sal_Bool BaseResultSet::previous( ) throw (SQLException, RuntimeException)
372 : {
373 0 : MutexGuard guard( m_refMutex->mutex );
374 0 : checkClosed();
375 0 : sal_Bool bRet = ( m_row != -1 );
376 0 : if( bRet )
377 0 : m_row --;
378 0 : return bRet;
379 : }
380 :
381 0 : void BaseResultSet::refreshRow( ) throw (SQLException, RuntimeException)
382 : {
383 : // TODO: not supported for now
384 0 : }
385 :
386 0 : sal_Bool BaseResultSet::rowUpdated( ) throw (SQLException, RuntimeException)
387 : {
388 0 : return sal_False;
389 : }
390 :
391 0 : sal_Bool BaseResultSet::rowInserted( ) throw (SQLException, RuntimeException)
392 : {
393 0 : return sal_False;
394 : }
395 :
396 0 : sal_Bool BaseResultSet::rowDeleted( ) throw (SQLException, RuntimeException)
397 : {
398 0 : return sal_False;
399 : }
400 :
401 0 : Reference< XInterface > BaseResultSet::getStatement() throw (SQLException, RuntimeException)
402 : {
403 0 : MutexGuard guard( m_refMutex->mutex );
404 0 : checkClosed();
405 0 : return m_owner;
406 : }
407 :
408 :
409 : //----------------- XRow interface ----------------------------------------------------
410 :
411 0 : sal_Bool BaseResultSet::wasNull( ) throw (SQLException, RuntimeException)
412 : {
413 0 : return m_wasNull;
414 : }
415 :
416 0 : Any BaseResultSet::convertTo( const Any & val , const Type & type )
417 : {
418 0 : Any aRet;
419 : try
420 : {
421 0 : aRet = m_tc->convertTo( val , type );
422 : }
423 0 : catch( com::sun::star::lang::IllegalArgumentException & )
424 : {}
425 0 : catch( com::sun::star::script::CannotConvertException & )
426 : {}
427 0 : return aRet;
428 : }
429 :
430 0 : sal_Bool BaseResultSet::getBoolean( sal_Int32 columnIndex ) throw (SQLException, RuntimeException)
431 : {
432 0 : MutexGuard guard( m_refMutex->mutex );
433 0 : checkClosed();
434 0 : checkColumnIndex( columnIndex );
435 0 : checkRowIndex( sal_True /* must be on row */ );
436 :
437 0 : OUString str = getString( columnIndex );
438 :
439 0 : if( str.getLength() > 0 )
440 : {
441 0 : switch(str[0])
442 : {
443 : case '1':
444 : case 't':
445 : case 'T':
446 : case 'y':
447 : case 'Y':
448 :
449 0 : return sal_True;
450 : }
451 : }
452 0 : return sal_False;
453 : }
454 :
455 0 : sal_Int8 BaseResultSet::getByte( sal_Int32 columnIndex )
456 : throw (SQLException, RuntimeException)
457 : {
458 0 : MutexGuard guard( m_refMutex->mutex );
459 0 : checkClosed();
460 0 : checkColumnIndex( columnIndex );
461 0 : checkRowIndex( sal_True /* must be on row */ );
462 0 : sal_Int8 b = 0;
463 0 : convertTo( getValue( columnIndex ), getCppuType( &b )) >>= b;
464 0 : return b;
465 : }
466 :
467 0 : sal_Int16 BaseResultSet::getShort( sal_Int32 columnIndex )
468 : throw (SQLException, RuntimeException)
469 : {
470 0 : MutexGuard guard( m_refMutex->mutex );
471 0 : checkClosed();
472 0 : checkColumnIndex( columnIndex );
473 0 : checkRowIndex( sal_True /* must be on row */ );
474 0 : sal_Int16 i = 0;
475 0 : convertTo( getValue( columnIndex ), getCppuType( &i )) >>= i;
476 0 : return i;
477 : }
478 :
479 0 : OUString BaseResultSet::getString( sal_Int32 columnIndex ) throw (SQLException, RuntimeException)
480 : {
481 0 : MutexGuard guard(m_refMutex->mutex);
482 0 : checkClosed();
483 0 : checkColumnIndex( columnIndex );
484 0 : checkRowIndex( sal_True /* must be on row */ );
485 0 : OUString ret;
486 0 : convertTo( getValue( columnIndex ), getCppuType( &ret ) ) >>= ret;
487 : // printf( "BaseResultSet::getString() %s\n" , OUStringToOString( ret, RTL_TEXTENCODING_ASCII_US ).getStr() );
488 0 : return ret;
489 : }
490 :
491 0 : sal_Int32 BaseResultSet::getInt( sal_Int32 columnIndex )
492 : throw (SQLException, RuntimeException)
493 : {
494 0 : MutexGuard guard( m_refMutex->mutex );
495 0 : checkClosed();
496 0 : checkColumnIndex( columnIndex );
497 0 : checkRowIndex( sal_True /* must be on row */ );
498 0 : sal_Int32 i = 0;
499 0 : convertTo( getValue( columnIndex ), getCppuType( &i )) >>= i;
500 0 : return i;
501 : }
502 :
503 0 : sal_Int64 BaseResultSet::getLong( sal_Int32 columnIndex )
504 : throw (SQLException, RuntimeException)
505 : {
506 0 : MutexGuard guard( m_refMutex->mutex );
507 0 : checkClosed();
508 0 : checkColumnIndex( columnIndex );
509 0 : checkRowIndex( sal_True /* must be on row */ );
510 0 : sal_Int64 i = 0;
511 0 : convertTo( getValue( columnIndex ), getCppuType( &i )) >>= i;
512 0 : return i;
513 : }
514 :
515 0 : float BaseResultSet::getFloat( sal_Int32 columnIndex )
516 : throw (SQLException, RuntimeException)
517 : {
518 0 : MutexGuard guard( m_refMutex->mutex );
519 0 : checkClosed();
520 0 : checkColumnIndex( columnIndex );
521 0 : checkRowIndex( sal_True /* must be on row */ );
522 0 : float f = 0.;
523 0 : convertTo( getValue( columnIndex ), getCppuType( &f )) >>= f;
524 0 : return f;
525 : }
526 :
527 0 : double BaseResultSet::getDouble( sal_Int32 columnIndex )
528 : throw (SQLException, RuntimeException)
529 : {
530 0 : MutexGuard guard( m_refMutex->mutex );
531 0 : checkClosed();
532 0 : checkColumnIndex( columnIndex );
533 0 : double d = 0.;
534 0 : convertTo( getValue( columnIndex ), getCppuType( &d )) >>= d;
535 0 : return d;
536 : }
537 :
538 0 : Sequence< sal_Int8 > BaseResultSet::getBytes( sal_Int32 columnIndex )
539 : throw (SQLException, RuntimeException)
540 : {
541 0 : MutexGuard guard( m_refMutex->mutex );
542 0 : checkClosed();
543 0 : checkColumnIndex( columnIndex );
544 0 : checkRowIndex( sal_True /* must be on row */ );
545 :
546 0 : Sequence< sal_Int8 > ret;
547 0 : OUString ustr;
548 0 : if( ! (getValue( columnIndex ) >>= ustr) )
549 0 : m_wasNull = true;
550 : else
551 : {
552 : // if this is a binary, it must contain escaped data !
553 0 : OString val = rtl::OUStringToOString( ustr, RTL_TEXTENCODING_ASCII_US );
554 :
555 : size_t length;
556 0 : char * res = (char*) PQunescapeBytea( (unsigned char *)val.getStr() , &length);
557 0 : ret = Sequence< sal_Int8 > ( (sal_Int8*)res, length );
558 0 : if( res )
559 0 : free( res );
560 : }
561 0 : return ret;
562 : }
563 :
564 :
565 0 : ::com::sun::star::util::Date BaseResultSet::getDate( sal_Int32 columnIndex )
566 : throw (SQLException, RuntimeException)
567 : {
568 0 : return string2Date( getString( columnIndex ) );
569 : }
570 :
571 0 : ::com::sun::star::util::Time BaseResultSet::getTime( sal_Int32 columnIndex )
572 : throw (SQLException, RuntimeException)
573 : {
574 0 : return string2Time( getString( columnIndex ) );
575 : }
576 :
577 0 : ::com::sun::star::util::DateTime BaseResultSet::getTimestamp( sal_Int32 columnIndex )
578 : throw (SQLException, RuntimeException)
579 : {
580 0 : return string2DateTime( getString( columnIndex ) );
581 : }
582 :
583 : // LEM TODO: these look like they are missing an actual implementation
584 0 : Reference< ::com::sun::star::io::XInputStream > BaseResultSet::getBinaryStream( sal_Int32 /* columnIndex */ )
585 : throw (SQLException, RuntimeException)
586 : {
587 0 : return 0;
588 : }
589 :
590 0 : Reference< ::com::sun::star::io::XInputStream > BaseResultSet::getCharacterStream( sal_Int32 /* columnIndex */ )
591 : throw (SQLException, RuntimeException)
592 : {
593 0 : return 0;
594 : }
595 :
596 0 : Any BaseResultSet::getObject(
597 : sal_Int32 /* columnIndex */,
598 : const Reference< ::com::sun::star::container::XNameAccess >& /* typeMap */ )
599 : throw (SQLException, RuntimeException)
600 : {
601 0 : return Any();
602 : }
603 :
604 0 : Reference< ::com::sun::star::sdbc::XRef > BaseResultSet::getRef( sal_Int32 /* columnIndex */ )
605 : throw (SQLException, RuntimeException)
606 : {
607 0 : return Reference< com::sun::star::sdbc::XRef > ();
608 : }
609 :
610 0 : Reference< ::com::sun::star::sdbc::XBlob > BaseResultSet::getBlob( sal_Int32 /* columnIndex */ )
611 : throw (SQLException, RuntimeException)
612 : {
613 0 : return Reference< com::sun::star::sdbc::XBlob > ();
614 : }
615 :
616 0 : Reference< ::com::sun::star::sdbc::XClob > BaseResultSet::getClob( sal_Int32 /* columnIndex */ )
617 : throw (SQLException, RuntimeException)
618 : {
619 0 : return Reference< com::sun::star::sdbc::XClob > ();
620 : }
621 :
622 0 : Reference< ::com::sun::star::sdbc::XArray > BaseResultSet::getArray( sal_Int32 columnIndex )
623 : throw (SQLException, RuntimeException)
624 : {
625 0 : return new Array( m_refMutex, parseArray( getString( columnIndex ) ), *this, m_tc );
626 : }
627 :
628 0 : ::cppu::IPropertyArrayHelper & BaseResultSet::getInfoHelper()
629 : {
630 0 : return getResultSetPropertyArrayHelper();
631 : }
632 :
633 0 : sal_Bool BaseResultSet::convertFastPropertyValue(
634 : Any & /* rConvertedValue */, Any & /* rOldValue */, sal_Int32 nHandle, const Any& rValue )
635 : throw (IllegalArgumentException)
636 : {
637 : sal_Bool bRet;
638 0 : switch( nHandle )
639 : {
640 : case BASERESULTSET_CURSOR_NAME:
641 : {
642 0 : OUString val;
643 0 : bRet = ( rValue >>= val );
644 0 : m_props[nHandle] = makeAny( val );
645 0 : break;
646 : }
647 : case BASERESULTSET_ESCAPE_PROCESSING:
648 : case BASERESULTSET_IS_BOOKMARKABLE:
649 : {
650 : sal_Bool val;
651 0 : bRet = ( rValue >>= val );
652 0 : m_props[nHandle] = makeAny( val );
653 : break;
654 : }
655 : case BASERESULTSET_FETCH_DIRECTION:
656 : case BASERESULTSET_FETCH_SIZE:
657 : case BASERESULTSET_RESULT_SET_CONCURRENCY:
658 : case BASERESULTSET_RESULT_SET_TYPE:
659 : {
660 : sal_Int32 val;
661 0 : bRet = ( rValue >>= val );
662 0 : m_props[nHandle] = makeAny( val );
663 : break;
664 : }
665 : default:
666 : {
667 0 : OUStringBuffer buf(128);
668 0 : buf.appendAscii( "pq_resultset: Invalid property handle (" );
669 0 : buf.append( nHandle );
670 0 : buf.appendAscii( ")" );
671 0 : throw IllegalArgumentException( buf.makeStringAndClear(), *this, 2 );
672 : }
673 : }
674 0 : return bRet;
675 : }
676 :
677 :
678 0 : void BaseResultSet::setFastPropertyValue_NoBroadcast(
679 : sal_Int32 nHandle,const Any& rValue ) throw (Exception)
680 : {
681 0 : m_props[nHandle] = rValue;
682 0 : }
683 :
684 0 : void BaseResultSet::getFastPropertyValue( Any& rValue, sal_Int32 nHandle ) const
685 : {
686 0 : rValue = m_props[nHandle];
687 0 : }
688 :
689 0 : Reference < XPropertySetInfo > BaseResultSet::getPropertySetInfo()
690 : throw(RuntimeException)
691 : {
692 0 : return OPropertySetHelper::createPropertySetInfo( getResultSetPropertyArrayHelper() );
693 : }
694 :
695 0 : void BaseResultSet::disposing()
696 : {
697 0 : close();
698 0 : }
699 :
700 0 : void BaseResultSet::checkColumnIndex(sal_Int32 index ) throw ( SQLException, RuntimeException )
701 : {
702 0 : if( index < 1 || index > m_fieldCount )
703 : {
704 0 : OUStringBuffer buf(128);
705 0 : buf.appendAscii( "pq_resultset: index out of range (" );
706 0 : buf.append( index );
707 0 : buf.appendAscii( ", allowed range is 1 to " );
708 0 : buf.append( m_fieldCount );
709 0 : buf.appendAscii( ")" );
710 0 : throw SQLException( buf.makeStringAndClear(), *this, OUString(), 1, Any() );
711 : }
712 :
713 0 : }
714 :
715 0 : void BaseResultSet::checkRowIndex( sal_Bool mustBeOnValidRow )
716 : {
717 0 : OUStringBuffer buf( 128 );
718 0 : buf.appendAscii( "pq_baseresultset: row index out of range, allowed is " );
719 0 : if( mustBeOnValidRow )
720 : {
721 0 : if( m_row < 0 || m_row >= m_rowCount )
722 : {
723 0 : buf.appendAscii( "0 to " );
724 0 : buf.append( ((sal_Int32)(m_rowCount -1)) );
725 0 : buf.appendAscii( ", got " );
726 0 : buf.append( m_row );
727 0 : throw SQLException( buf.makeStringAndClear(), *this, OUString(),1, Any() );
728 : }
729 : }
730 : else
731 : {
732 0 : if( m_row < -1 || m_row > m_rowCount )
733 : {
734 0 : buf.appendAscii( "-1 to " );
735 0 : buf.append( m_rowCount );
736 0 : buf.appendAscii( ", got " );
737 0 : buf.append( m_row );
738 0 : throw SQLException( buf.makeStringAndClear(), *this, OUString(),1, Any() );
739 : }
740 0 : }
741 0 : }
742 :
743 : }
|
