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 // MARKER(update_precomp.py): autogen include statement, do not remove
25 #include "precompiled_connectivity.hxx"
26 #include <comphelper/sequence.hxx>
27 #include "ado/ADatabaseMetaDataResultSet.hxx"
28 #include "ado/ADatabaseMetaDataResultSetMetaData.hxx"
29 #include <com/sun/star/sdbc/DataType.hpp>
30 #include <com/sun/star/sdbc/ColumnValue.hpp>
31 #include <com/sun/star/sdbc/KeyRule.hpp>
32 #include <com/sun/star/sdbc/ProcedureResult.hpp>
33 #include <com/sun/star/sdbc/IndexType.hpp>
34 #include <comphelper/property.hxx>
35 #include <com/sun/star/lang/DisposedException.hpp>
36 #include <com/sun/star/sdbc/ResultSetConcurrency.hpp>
37 #include <com/sun/star/sdbc/ResultSetType.hpp>
38 #include <com/sun/star/sdbc/FetchDirection.hpp>
39 #include <cppuhelper/typeprovider.hxx>
40 #include <comphelper/seqstream.hxx>
41 #include "connectivity/dbexception.hxx"
42
43
44 #include <oledb.h>
45
46 using namespace dbtools;
47 using namespace connectivity::ado;
48 using namespace cppu;
49 using namespace ::comphelper;
50 //------------------------------------------------------------------------------
51 using namespace ::com::sun::star::lang;
52 using namespace com::sun::star::uno;
53 using namespace com::sun::star::lang;
54 using namespace com::sun::star::beans;
55 using namespace com::sun::star::sdbc;
56
57 // -------------------------------------------------------------------------
ODatabaseMetaDataResultSet(ADORecordset * _pRecordSet)58 ODatabaseMetaDataResultSet::ODatabaseMetaDataResultSet(ADORecordset* _pRecordSet)
59 :ODatabaseMetaDataResultSet_BASE(m_aMutex)
60 ,OPropertySetHelper(ODatabaseMetaDataResultSet_BASE::rBHelper)
61 ,m_aStatement(NULL)
62 ,m_xMetaData(NULL)
63 ,m_pRecordSet(_pRecordSet)
64 ,m_bEOF(sal_False)
65 {
66 osl_incrementInterlockedCount( &m_refCount );
67 m_aColMapping.push_back(-1);
68 if(_pRecordSet)
69 {
70 m_pRecordSet->AddRef();
71 VARIANT_BOOL bIsAtBOF;
72 m_pRecordSet->get_BOF(&bIsAtBOF);
73 m_bOnFirstAfterOpen = bIsAtBOF != VARIANT_TRUE;
74 }
75 else
76 m_bOnFirstAfterOpen = sal_False;
77 osl_decrementInterlockedCount( &m_refCount );
78 // allocBuffer();
79 }
80
81 // -------------------------------------------------------------------------
~ODatabaseMetaDataResultSet()82 ODatabaseMetaDataResultSet::~ODatabaseMetaDataResultSet()
83 {
84 if(m_pRecordSet)
85 m_pRecordSet->Release();
86 }
87 // -------------------------------------------------------------------------
disposing(void)88 void ODatabaseMetaDataResultSet::disposing(void)
89 {
90 OPropertySetHelper::disposing();
91
92 ::osl::MutexGuard aGuard(m_aMutex);
93 if(m_pRecordSet)
94 m_pRecordSet->Close();
95 m_aStatement = NULL;
96 m_xMetaData.clear();
97 }
98 // -------------------------------------------------------------------------
queryInterface(const Type & rType)99 Any SAL_CALL ODatabaseMetaDataResultSet::queryInterface( const Type & rType ) throw(RuntimeException)
100 {
101 Any aRet = OPropertySetHelper::queryInterface(rType);
102 return aRet.hasValue() ? aRet : ODatabaseMetaDataResultSet_BASE::queryInterface(rType);
103 }
104 // -------------------------------------------------------------------------
getTypes()105 ::com::sun::star::uno::Sequence< ::com::sun::star::uno::Type > SAL_CALL ODatabaseMetaDataResultSet::getTypes( ) throw(::com::sun::star::uno::RuntimeException)
106 {
107 ::cppu::OTypeCollection aTypes( ::getCppuType( (const ::com::sun::star::uno::Reference< ::com::sun::star::beans::XMultiPropertySet > *)0 ),
108 ::getCppuType( (const ::com::sun::star::uno::Reference< ::com::sun::star::beans::XFastPropertySet > *)0 ),
109 ::getCppuType( (const ::com::sun::star::uno::Reference< ::com::sun::star::beans::XPropertySet > *)0 ));
110
111 return ::comphelper::concatSequences(aTypes.getTypes(),ODatabaseMetaDataResultSet_BASE::getTypes());
112 }
113 // -----------------------------------------------------------------------------
checkRecordSet()114 void ODatabaseMetaDataResultSet::checkRecordSet() throw(SQLException)
115 {
116 if(!m_pRecordSet)
117 throwFunctionSequenceException(*this);
118 }
119 // -------------------------------------------------------------------------
120
findColumn(const::rtl::OUString & columnName)121 sal_Int32 SAL_CALL ODatabaseMetaDataResultSet::findColumn( const ::rtl::OUString& columnName ) throw(SQLException, RuntimeException)
122 {
123 ::osl::MutexGuard aGuard( m_aMutex );
124 checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed );
125
126
127 Reference< XResultSetMetaData > xMeta = getMetaData();
128 sal_Int32 nLen = xMeta->getColumnCount();
129 sal_Int32 i = 1;
130 for(;i<=nLen;++i)
131 if(xMeta->isCaseSensitive(i) ? columnName == xMeta->getColumnName(i) :
132 columnName.equalsIgnoreAsciiCase(xMeta->getColumnName(i)))
133 break;
134 return i;
135 }
136 #define BLOCK_SIZE 256
137 // -------------------------------------------------------------------------
getBinaryStream(sal_Int32 columnIndex)138 Reference< ::com::sun::star::io::XInputStream > SAL_CALL ODatabaseMetaDataResultSet::getBinaryStream( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
139 {
140 ::osl::MutexGuard aGuard( m_aMutex );
141 checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed);
142
143 checkRecordSet();
144
145
146 columnIndex = mapColumn(columnIndex);
147 WpADOField aField = ADOS::getField(m_pRecordSet,columnIndex);
148 if((aField.GetAttributes() & adFldLong) == adFldLong)
149 {
150 //Copy the data only upto the Actual Size of Field.
151 sal_Int32 nSize = aField.GetActualSize();
152 Sequence<sal_Int8> aData(nSize);
153 long index = 0;
154 while(index < nSize)
155 {
156 m_aValue = aField.GetChunk(BLOCK_SIZE);
157 if(m_aValue.isNull())
158 break;
159 UCHAR chData;
160 for(long index2 = 0;index2 < BLOCK_SIZE;++index2)
161 {
162 HRESULT hr = ::SafeArrayGetElement(m_aValue.parray,&index2,&chData);
163 if(SUCCEEDED(hr))
164 {
165 //Take BYTE by BYTE and advance Memory Location
166 aData.getArray()[index++] = chData;
167 }
168 else
169 break;
170 }
171 }
172 return index ? Reference< ::com::sun::star::io::XInputStream >(new SequenceInputStream(aData)) : Reference< ::com::sun::star::io::XInputStream >();
173 }
174 // else we ask for a bytesequence
175 aField.get_Value(m_aValue);
176 if(m_aValue.isNull())
177 return NULL;
178 return new SequenceInputStream(m_aValue);
179 }
180 // -------------------------------------------------------------------------
getCharacterStream(sal_Int32)181 Reference< ::com::sun::star::io::XInputStream > SAL_CALL ODatabaseMetaDataResultSet::getCharacterStream( sal_Int32 /*columnIndex*/ ) throw(SQLException, RuntimeException)
182 {
183 ::dbtools::throwFeatureNotImplementedException( "XRow::getCharacterStream", *this );
184 return NULL;
185 }
186
187 // -------------------------------------------------------------------------
getBoolean(sal_Int32 columnIndex)188 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::getBoolean( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
189 {
190 ::osl::MutexGuard aGuard( m_aMutex );
191
192 if ( !m_aValueRange.empty() && columnIndex == 11 && (m_aValueRangeIter = m_aValueRange.find(columnIndex)) != m_aValueRange.end() )
193 {
194 getValue(2);
195 if ( static_cast<sal_Int16>(m_aValue) != adCurrency )
196 return sal_False;
197 }
198 return getValue(columnIndex);
199 }
200 // -------------------------------------------------------------------------
201
getByte(sal_Int32 columnIndex)202 sal_Int8 SAL_CALL ODatabaseMetaDataResultSet::getByte( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
203 {
204 ::osl::MutexGuard aGuard( m_aMutex );
205
206 getValue(columnIndex);
207
208 columnIndex = mapColumn(columnIndex);
209
210 if(m_aValue.isNull())
211 return 0;
212 if ( !m_aValueRange.empty() && (m_aValueRangeIter = m_aValueRange.find(columnIndex)) != m_aValueRange.end())
213 return (sal_Int8)(*m_aValueRangeIter).second[(sal_Int32)m_aValue];
214 else if(m_aStrValueRange.size() && (m_aStrValueRangeIter = m_aStrValueRange.find(columnIndex)) != m_aStrValueRange.end())
215 return (sal_Int8)(*m_aStrValueRangeIter).second[m_aValue];
216
217 return m_aValue;
218 }
219 // -------------------------------------------------------------------------
220
getBytes(sal_Int32 columnIndex)221 Sequence< sal_Int8 > SAL_CALL ODatabaseMetaDataResultSet::getBytes( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
222 {
223 return getValue(columnIndex);
224 }
225 // -------------------------------------------------------------------------
226
getDate(sal_Int32 columnIndex)227 ::com::sun::star::util::Date SAL_CALL ODatabaseMetaDataResultSet::getDate( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
228 {
229 return getValue(columnIndex);
230 }
231 // -------------------------------------------------------------------------
232
getDouble(sal_Int32 columnIndex)233 double SAL_CALL ODatabaseMetaDataResultSet::getDouble( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
234 {
235 return getValue(columnIndex);
236 }
237 // -------------------------------------------------------------------------
238
getFloat(sal_Int32 columnIndex)239 float SAL_CALL ODatabaseMetaDataResultSet::getFloat( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
240 {
241 return getValue(columnIndex);
242 }
243 // -------------------------------------------------------------------------
244
getInt(sal_Int32 columnIndex)245 sal_Int32 SAL_CALL ODatabaseMetaDataResultSet::getInt( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
246 {
247 ::osl::MutexGuard aGuard( m_aMutex );
248
249
250 getValue(columnIndex);
251
252 columnIndex = mapColumn(columnIndex);
253 if(m_aValue.isNull())
254 return 0;
255
256 if(m_aValueRange.size() && (m_aValueRangeIter = m_aValueRange.find(columnIndex)) != m_aValueRange.end())
257 return (*m_aValueRangeIter).second[(sal_Int32)m_aValue];
258 else if(m_aStrValueRange.size() && (m_aStrValueRangeIter = m_aStrValueRange.find(columnIndex)) != m_aStrValueRange.end())
259 return (*m_aStrValueRangeIter).second[m_aValue];
260
261 return m_aValue;
262 }
263 // -------------------------------------------------------------------------
264
getRow()265 sal_Int32 SAL_CALL ODatabaseMetaDataResultSet::getRow( ) throw(SQLException, RuntimeException)
266 {
267 ::dbtools::throwFeatureNotImplementedException( "XResultSet::getRow", *this );
268 return 0;
269 }
270 // -------------------------------------------------------------------------
271
getLong(sal_Int32)272 sal_Int64 SAL_CALL ODatabaseMetaDataResultSet::getLong( sal_Int32 /*columnIndex*/ ) throw(SQLException, RuntimeException)
273 {
274 ::dbtools::throwFeatureNotImplementedException( "XRow::getLong", *this );
275 return sal_Int64(0);
276 }
277 // -------------------------------------------------------------------------
278
getMetaData()279 Reference< XResultSetMetaData > SAL_CALL ODatabaseMetaDataResultSet::getMetaData( ) throw(SQLException, RuntimeException)
280 {
281 ::osl::MutexGuard aGuard( m_aMutex );
282 checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed);
283
284 checkRecordSet();
285
286
287 if(!m_xMetaData.is())
288 m_xMetaData = new ODatabaseMetaDataResultSetMetaData(m_pRecordSet,this);
289
290 return m_xMetaData;
291 }
292 // -------------------------------------------------------------------------
getArray(sal_Int32)293 Reference< XArray > SAL_CALL ODatabaseMetaDataResultSet::getArray( sal_Int32 /*columnIndex*/ ) throw(SQLException, RuntimeException)
294 {
295 ::dbtools::throwFeatureNotImplementedException( "XRow::getRow", *this );
296 return NULL;
297 }
298
299 // -------------------------------------------------------------------------
300
getClob(sal_Int32)301 Reference< XClob > SAL_CALL ODatabaseMetaDataResultSet::getClob( sal_Int32 /*columnIndex*/ ) throw(SQLException, RuntimeException)
302 {
303 ::dbtools::throwFeatureNotImplementedException( "XRow::getRow", *this );
304 return NULL;
305 }
306 // -------------------------------------------------------------------------
getBlob(sal_Int32)307 Reference< XBlob > SAL_CALL ODatabaseMetaDataResultSet::getBlob( sal_Int32 /*columnIndex*/ ) throw(SQLException, RuntimeException)
308 {
309 ::dbtools::throwFeatureNotImplementedException( "XRow::getRow", *this );
310 return NULL;
311 }
312 // -------------------------------------------------------------------------
313
getRef(sal_Int32)314 Reference< XRef > SAL_CALL ODatabaseMetaDataResultSet::getRef( sal_Int32 /*columnIndex*/ ) throw(SQLException, RuntimeException)
315 {
316 ::dbtools::throwFeatureNotImplementedException( "XRow::getRow", *this );
317 return NULL;
318 }
319 // -------------------------------------------------------------------------
320
getObject(sal_Int32 columnIndex,const Reference<::com::sun::star::container::XNameAccess> &)321 Any SAL_CALL ODatabaseMetaDataResultSet::getObject( sal_Int32 columnIndex, const Reference< ::com::sun::star::container::XNameAccess >& /*typeMap*/ ) throw(SQLException, RuntimeException)
322 {
323 ::osl::MutexGuard aGuard( m_aMutex );
324 checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed);
325
326 checkRecordSet();
327
328
329 columnIndex = mapColumn(columnIndex);
330 return Any();
331 }
332 // -------------------------------------------------------------------------
333
getShort(sal_Int32 columnIndex)334 sal_Int16 SAL_CALL ODatabaseMetaDataResultSet::getShort( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
335 {
336 ::osl::MutexGuard aGuard( m_aMutex );
337
338 getValue(columnIndex);
339
340 columnIndex = mapColumn(columnIndex);
341 if(m_aValue.isNull())
342 return 0;
343
344 if(m_aValueRange.size() && (m_aValueRangeIter = m_aValueRange.find(columnIndex)) != m_aValueRange.end())
345 return (sal_Int16)(*m_aValueRangeIter).second[(sal_Int32)m_aValue];
346 else if(m_aStrValueRange.size() && (m_aStrValueRangeIter = m_aStrValueRange.find(columnIndex)) != m_aStrValueRange.end())
347 return (sal_Int16)(*m_aStrValueRangeIter).second[m_aValue];
348
349 return m_aValue;
350 }
351 // -------------------------------------------------------------------------
352
getString(sal_Int32 columnIndex)353 ::rtl::OUString SAL_CALL ODatabaseMetaDataResultSet::getString( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
354 {
355 ::osl::MutexGuard aGuard( m_aMutex );
356
357 getValue(columnIndex);
358
359
360 columnIndex = mapColumn(columnIndex);
361 if(m_aValue.isNull())
362 return ::rtl::OUString();
363 if(m_aIntValueRange.size() && (m_aIntValueRangeIter = m_aIntValueRange.find(columnIndex)) != m_aIntValueRange.end())
364 return (*m_aIntValueRangeIter).second[m_aValue];
365
366 return m_aValue;
367 }
368
369 // -------------------------------------------------------------------------
370
371
getTime(sal_Int32 columnIndex)372 ::com::sun::star::util::Time SAL_CALL ODatabaseMetaDataResultSet::getTime( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
373 {
374 return getValue(columnIndex);
375 }
376 // -------------------------------------------------------------------------
377
378
getTimestamp(sal_Int32 columnIndex)379 ::com::sun::star::util::DateTime SAL_CALL ODatabaseMetaDataResultSet::getTimestamp( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
380 {
381 return getValue(columnIndex);
382 }
383 // -------------------------------------------------------------------------
384
isAfterLast()385 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::isAfterLast( ) throw(SQLException, RuntimeException)
386 {
387 ::osl::MutexGuard aGuard( m_aMutex );
388 checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed);
389
390 checkRecordSet();
391
392
393 VARIANT_BOOL bIsAtEOF;
394 m_pRecordSet->get_EOF(&bIsAtEOF);
395 return bIsAtEOF == VARIANT_TRUE;
396 }
397 // -------------------------------------------------------------------------
isFirst()398 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::isFirst( ) throw(SQLException, RuntimeException)
399 {
400 ::osl::MutexGuard aGuard( m_aMutex );
401 checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed);
402
403 checkRecordSet();
404
405
406 return m_nRowPos == 1;
407 }
408 // -------------------------------------------------------------------------
isLast()409 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::isLast( ) throw(SQLException, RuntimeException)
410 {
411 ::osl::MutexGuard aGuard( m_aMutex );
412 checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed);
413
414 checkRecordSet();
415
416
417 return sal_True;
418 }
419 // -------------------------------------------------------------------------
beforeFirst()420 void SAL_CALL ODatabaseMetaDataResultSet::beforeFirst( ) throw(SQLException, RuntimeException)
421 {
422 ::osl::MutexGuard aGuard( m_aMutex );
423 checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed);
424
425 checkRecordSet();
426
427
428 if(first())
429 previous();
430 }
431 // -------------------------------------------------------------------------
afterLast()432 void SAL_CALL ODatabaseMetaDataResultSet::afterLast( ) throw(SQLException, RuntimeException)
433 {
434 ::osl::MutexGuard aGuard( m_aMutex );
435 checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed);
436
437 checkRecordSet();
438
439
440 if(last())
441 next();
442 m_bEOF = sal_True;
443 }
444 // -------------------------------------------------------------------------
445
close()446 void SAL_CALL ODatabaseMetaDataResultSet::close( ) throw(SQLException, RuntimeException)
447 {
448 {
449 ::osl::MutexGuard aGuard( m_aMutex );
450 checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed);
451
452 }
453 dispose();
454 }
455 // -------------------------------------------------------------------------
456
first()457 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::first( ) throw(SQLException, RuntimeException)
458 {
459 ::osl::MutexGuard aGuard( m_aMutex );
460 checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed);
461
462
463 if(!m_pRecordSet)
464 return sal_False;
465
466 sal_Bool bRet = SUCCEEDED(m_pRecordSet->MoveFirst());
467 if ( bRet )
468 m_nRowPos = 1;
469 return bRet;
470 }
471 // -------------------------------------------------------------------------
472
last()473 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::last( ) throw(SQLException, RuntimeException)
474 {
475 ::osl::MutexGuard aGuard( m_aMutex );
476 checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed );
477
478
479 return m_pRecordSet && SUCCEEDED(m_pRecordSet->MoveLast()) ? sal_True : sal_False;
480 }
481 // -------------------------------------------------------------------------
absolute(sal_Int32 row)482 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::absolute( sal_Int32 row ) throw(SQLException, RuntimeException)
483 {
484 ::osl::MutexGuard aGuard( m_aMutex );
485 checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed);
486
487
488 if(first())
489 {
490 OLEVariant aEmpty;
491 aEmpty.setNoArg();
492 sal_Bool bRet = SUCCEEDED(m_pRecordSet->Move(row,aEmpty));
493 if(bRet)
494 m_nRowPos = row;
495 return bRet;
496 }
497 return sal_False;
498 }
499 // -------------------------------------------------------------------------
relative(sal_Int32 row)500 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::relative( sal_Int32 row ) throw(SQLException, RuntimeException)
501 {
502 ::osl::MutexGuard aGuard( m_aMutex );
503 checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed);
504
505
506 if(!m_pRecordSet)
507 return sal_False;
508
509 OLEVariant aEmpty;
510 aEmpty.setNoArg();
511 sal_Bool bRet = SUCCEEDED(m_pRecordSet->Move(row,aEmpty));
512 if(bRet)
513 m_nRowPos += row;
514 return bRet;
515 }
516 // -------------------------------------------------------------------------
previous()517 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::previous( ) throw(SQLException, RuntimeException)
518 {
519 ::osl::MutexGuard aGuard( m_aMutex );
520 checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed);
521
522
523 if(!m_pRecordSet)
524 return sal_False;
525
526 sal_Bool bRet = SUCCEEDED(m_pRecordSet->MovePrevious());
527 if(bRet)
528 --m_nRowPos;
529 return bRet;
530 }
531 // -------------------------------------------------------------------------
getStatement()532 Reference< XInterface > SAL_CALL ODatabaseMetaDataResultSet::getStatement( ) throw(SQLException, RuntimeException)
533 {
534 return m_aStatement.get();
535 }
536 // -------------------------------------------------------------------------
537
rowDeleted()538 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::rowDeleted( ) throw(SQLException, RuntimeException)
539 {
540 ::osl::MutexGuard aGuard( m_aMutex );
541 checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed);
542
543 checkRecordSet();
544
545
546 RecordStatusEnum eRec;
547 m_pRecordSet->get_Status((sal_Int32*)&eRec);
548 return (eRec & adRecDeleted) == adRecDeleted;
549 }
550 // -------------------------------------------------------------------------
rowInserted()551 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::rowInserted( ) throw(SQLException, RuntimeException)
552 { ::osl::MutexGuard aGuard( m_aMutex );
553 checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed);
554
555 checkRecordSet();
556
557
558 RecordStatusEnum eRec;
559 m_pRecordSet->get_Status((sal_Int32*)&eRec);
560 return (eRec & adRecNew) == adRecNew;
561 }
562 // -------------------------------------------------------------------------
rowUpdated()563 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::rowUpdated( ) throw(SQLException, RuntimeException)
564 {
565 ::osl::MutexGuard aGuard( m_aMutex );
566 checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed);
567
568 checkRecordSet();
569
570
571 RecordStatusEnum eRec;
572 m_pRecordSet->get_Status((sal_Int32*)&eRec);
573 return (eRec & adRecModified) == adRecModified;
574 }
575 // -------------------------------------------------------------------------
576
isBeforeFirst()577 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::isBeforeFirst( ) throw(SQLException, RuntimeException)
578 {
579 ::osl::MutexGuard aGuard( m_aMutex );
580 checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed);
581
582
583 if(!m_pRecordSet)
584 return sal_True;
585
586 VARIANT_BOOL bIsAtBOF;
587 m_pRecordSet->get_BOF(&bIsAtBOF);
588 return bIsAtBOF == VARIANT_TRUE;
589 }
590 // -------------------------------------------------------------------------
591
next()592 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::next( ) throw(SQLException, RuntimeException)
593 {
594 ::osl::MutexGuard aGuard( m_aMutex );
595 checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed);
596
597
598 if(!m_pRecordSet)
599 return sal_False;
600
601 if(m_bOnFirstAfterOpen)
602 {
603 m_bOnFirstAfterOpen = sal_False;
604 return sal_True;
605 }
606 else
607 return SUCCEEDED(m_pRecordSet->MoveNext());
608 }
609 // -------------------------------------------------------------------------
610
wasNull()611 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::wasNull( ) throw(SQLException, RuntimeException)
612 {
613 ::osl::MutexGuard aGuard( m_aMutex );
614 checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed);
615
616 checkRecordSet();
617
618
619 return m_aValue.isNull();
620 }
621 // -------------------------------------------------------------------------
refreshRow()622 void SAL_CALL ODatabaseMetaDataResultSet::refreshRow( ) throw(SQLException, RuntimeException)
623 {
624 ::osl::MutexGuard aGuard( m_aMutex );
625 checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed);
626
627 checkRecordSet();
628
629
630 m_pRecordSet->Resync(adAffectCurrent,adResyncAllValues);
631 }
632 // -------------------------------------------------------------------------
633
cancel()634 void SAL_CALL ODatabaseMetaDataResultSet::cancel( ) throw(RuntimeException)
635 {
636 ::osl::MutexGuard aGuard( m_aMutex );
637 checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed);
638
639 checkRecordSet();
640
641
642 m_pRecordSet->Cancel();
643 }
644 // -------------------------------------------------------------------------
clearWarnings()645 void SAL_CALL ODatabaseMetaDataResultSet::clearWarnings( ) throw(SQLException, RuntimeException)
646 {
647 }
648 // -------------------------------------------------------------------------
getWarnings()649 Any SAL_CALL ODatabaseMetaDataResultSet::getWarnings( ) throw(SQLException, RuntimeException)
650 {
651 return Any();
652 }
653 //------------------------------------------------------------------------------
getResultSetConcurrency() const654 sal_Int32 ODatabaseMetaDataResultSet::getResultSetConcurrency() const
655 throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException)
656 {
657 return ResultSetConcurrency::READ_ONLY;
658 }
659 //------------------------------------------------------------------------------
getResultSetType() const660 sal_Int32 ODatabaseMetaDataResultSet::getResultSetType() const
661 throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException)
662 {
663 return ResultSetType::FORWARD_ONLY;
664 }
665 //------------------------------------------------------------------------------
getFetchDirection() const666 sal_Int32 ODatabaseMetaDataResultSet::getFetchDirection() const
667 throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException)
668 {
669 return FetchDirection::FORWARD;
670 }
671 //------------------------------------------------------------------------------
getFetchSize() const672 sal_Int32 ODatabaseMetaDataResultSet::getFetchSize() const
673 throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException)
674 {
675 sal_Int32 nValue=-1;
676 if(m_pRecordSet)
677 m_pRecordSet->get_CacheSize(&nValue);
678 return nValue;
679 }
680 //------------------------------------------------------------------------------
getCursorName() const681 ::rtl::OUString ODatabaseMetaDataResultSet::getCursorName() const
682 throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException)
683 {
684 return ::rtl::OUString();
685 }
686
687 //------------------------------------------------------------------------------
setFetchDirection(sal_Int32)688 void ODatabaseMetaDataResultSet::setFetchDirection(sal_Int32 /*_par0*/)
689 throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException)
690 {
691 ::dbtools::throwFeatureNotImplementedException( "ResultSet::FetchDirection", *this );
692 }
693 //------------------------------------------------------------------------------
setFetchSize(sal_Int32 _par0)694 void ODatabaseMetaDataResultSet::setFetchSize(sal_Int32 _par0)
695 throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException)
696 {
697 if(m_pRecordSet)
698 m_pRecordSet->put_CacheSize(_par0);
699 }
700 // -------------------------------------------------------------------------
createArrayHelper() const701 ::cppu::IPropertyArrayHelper* ODatabaseMetaDataResultSet::createArrayHelper( ) const
702 {
703
704 Sequence< com::sun::star::beans::Property > aProps(5);
705 com::sun::star::beans::Property* pProperties = aProps.getArray();
706 sal_Int32 nPos = 0;
707 DECL_PROP0(CURSORNAME, ::rtl::OUString);
708 DECL_PROP0(FETCHDIRECTION, sal_Int32);
709 DECL_PROP0(FETCHSIZE, sal_Int32);
710 DECL_PROP0(RESULTSETCONCURRENCY,sal_Int32);
711 DECL_PROP0(RESULTSETTYPE, sal_Int32);
712
713 return new ::cppu::OPropertyArrayHelper(aProps);
714 }
715 // -------------------------------------------------------------------------
getInfoHelper()716 ::cppu::IPropertyArrayHelper & ODatabaseMetaDataResultSet::getInfoHelper()
717 {
718 return *const_cast<ODatabaseMetaDataResultSet*>(this)->getArrayHelper();
719 }
720 // -------------------------------------------------------------------------
convertFastPropertyValue(Any & rConvertedValue,Any & rOldValue,sal_Int32 nHandle,const Any & rValue)721 sal_Bool ODatabaseMetaDataResultSet::convertFastPropertyValue(
722 Any & rConvertedValue,
723 Any & rOldValue,
724 sal_Int32 nHandle,
725 const Any& rValue )
726 throw (::com::sun::star::lang::IllegalArgumentException)
727 {
728 switch(nHandle)
729 {
730 case PROPERTY_ID_CURSORNAME:
731 case PROPERTY_ID_RESULTSETCONCURRENCY:
732 case PROPERTY_ID_RESULTSETTYPE:
733 throw ::com::sun::star::lang::IllegalArgumentException();
734 break;
735 case PROPERTY_ID_FETCHDIRECTION:
736 return ::comphelper::tryPropertyValue(rConvertedValue, rOldValue, rValue, getFetchDirection());
737 case PROPERTY_ID_FETCHSIZE:
738 return ::comphelper::tryPropertyValue(rConvertedValue, rOldValue, rValue, getFetchSize());
739 default:
740 ;
741 }
742 return sal_False;
743 }
744 // -------------------------------------------------------------------------
setFastPropertyValue_NoBroadcast(sal_Int32 nHandle,const Any &)745 void ODatabaseMetaDataResultSet::setFastPropertyValue_NoBroadcast(
746 sal_Int32 nHandle,
747 const Any& /*rValue*/
748 )
749 throw (Exception)
750 {
751 switch(nHandle)
752 {
753 case PROPERTY_ID_CURSORNAME:
754 case PROPERTY_ID_RESULTSETCONCURRENCY:
755 case PROPERTY_ID_RESULTSETTYPE:
756 case PROPERTY_ID_FETCHDIRECTION:
757 case PROPERTY_ID_FETCHSIZE:
758 throw Exception();
759 break;
760 default:
761 OSL_ENSURE(0,"setFastPropertyValue_NoBroadcast: Illegal handle value!");
762 }
763 }
764 // -------------------------------------------------------------------------
getFastPropertyValue(Any & rValue,sal_Int32 nHandle) const765 void ODatabaseMetaDataResultSet::getFastPropertyValue(
766 Any& rValue,
767 sal_Int32 nHandle
768 ) const
769 {
770 switch(nHandle)
771 {
772 case PROPERTY_ID_CURSORNAME:
773 rValue <<= getCursorName();
774 break;
775 case PROPERTY_ID_RESULTSETCONCURRENCY:
776 rValue <<= getResultSetConcurrency();
777 break;
778 case PROPERTY_ID_RESULTSETTYPE:
779 rValue <<= getResultSetType();
780 break;
781 case PROPERTY_ID_FETCHDIRECTION:
782 rValue <<= getFetchDirection();
783 break;
784 case PROPERTY_ID_FETCHSIZE:
785 rValue <<= getFetchSize();
786 break;
787 }
788 }
789 // -------------------------------------------------------------------------
setProceduresMap()790 void ODatabaseMetaDataResultSet::setProceduresMap()
791 {
792
793 for(sal_Int32 i=1;i<4;i++)
794 m_aColMapping.push_back(i);
795 m_aColMapping.push_back(5);
796 m_aColMapping.push_back(7);
797 m_aColMapping.push_back(8);
798 m_aColMapping.push_back(6);
799 m_aColMapping.push_back(4);
800
801 TInt2IntMap aMap;
802 aMap[DB_PT_UNKNOWN] = ProcedureResult::UNKNOWN;
803 aMap[DB_PT_PROCEDURE] = ProcedureResult::NONE;
804 aMap[DB_PT_FUNCTION] = ProcedureResult::RETURN;
805 m_aValueRange[4] = aMap;
806
807 ODatabaseMetaDataResultSetMetaData* pMetaData = new ODatabaseMetaDataResultSetMetaData(m_pRecordSet,this);
808 pMetaData->setProceduresMap();
809 m_xMetaData = pMetaData;
810 }
811 // -------------------------------------------------------------------------
setCatalogsMap()812 void ODatabaseMetaDataResultSet::setCatalogsMap()
813 {
814 m_aColMapping.push_back(1);
815
816 m_xMetaData = new ODatabaseMetaDataResultSetMetaData(m_pRecordSet,this);
817 }
818 // -------------------------------------------------------------------------
setSchemasMap()819 void ODatabaseMetaDataResultSet::setSchemasMap()
820 {
821 m_aColMapping.push_back(2);
822
823 m_xMetaData = new ODatabaseMetaDataResultSetMetaData(m_pRecordSet,this);
824 }
825 // -------------------------------------------------------------------------
setColumnPrivilegesMap()826 void ODatabaseMetaDataResultSet::setColumnPrivilegesMap()
827 {
828
829 m_aColMapping.push_back(3);
830 m_aColMapping.push_back(4);
831 m_aColMapping.push_back(5);
832 m_aColMapping.push_back(6);
833 m_aColMapping.push_back(2);
834 m_aColMapping.push_back(9);
835 m_aColMapping.push_back(10);
836
837 ODatabaseMetaDataResultSetMetaData* pMetaData = new ODatabaseMetaDataResultSetMetaData(m_pRecordSet,this);
838 pMetaData->setColumnPrivilegesMap();
839 m_xMetaData = pMetaData;
840 }
841 // -------------------------------------------------------------------------
setColumnsMap()842 void ODatabaseMetaDataResultSet::setColumnsMap()
843 {
844
845 for(sal_Int32 i=1;i<5;++i)
846 m_aColMapping.push_back(i);
847
848 m_aColMapping.push_back(12);
849 m_aColMapping.push_back(12); // is used as TYPE_NAME
850
851 m_aColMapping.push_back(14);
852 m_aColMapping.push_back(6);
853 m_aColMapping.push_back(17);
854 m_aColMapping.push_back(18);
855
856 m_aColMapping.push_back(11);
857 m_aColMapping.push_back(29);
858 m_aColMapping.push_back(9);
859 m_aColMapping.push_back(18);
860 m_aColMapping.push_back(18);
861
862 m_aColMapping.push_back(15);
863 m_aColMapping.push_back(7);
864 m_aColMapping.push_back(11);
865
866 TInt2IntMap aMap;
867 aMap[adEmpty] = ADOS::MapADOType2Jdbc(adEmpty);
868 aMap[adTinyInt] = ADOS::MapADOType2Jdbc(adTinyInt);
869 aMap[adSmallInt] = ADOS::MapADOType2Jdbc(adSmallInt);
870 aMap[adInteger] = ADOS::MapADOType2Jdbc(adInteger);
871 aMap[adBigInt] = ADOS::MapADOType2Jdbc(adBigInt);
872 aMap[adUnsignedTinyInt] = ADOS::MapADOType2Jdbc(adUnsignedTinyInt);
873 aMap[adUnsignedSmallInt]= ADOS::MapADOType2Jdbc(adUnsignedSmallInt);
874 aMap[adUnsignedInt] = ADOS::MapADOType2Jdbc(adUnsignedInt);
875 aMap[adUnsignedBigInt] = ADOS::MapADOType2Jdbc(adUnsignedBigInt);
876 aMap[adSingle] = ADOS::MapADOType2Jdbc(adSingle);
877 aMap[adDouble] = ADOS::MapADOType2Jdbc(adDouble);
878 aMap[adCurrency] = ADOS::MapADOType2Jdbc(adCurrency);
879 aMap[adDecimal] = ADOS::MapADOType2Jdbc(adDecimal);
880 aMap[adNumeric] = ADOS::MapADOType2Jdbc(adNumeric);
881 aMap[adBoolean] = ADOS::MapADOType2Jdbc(adBoolean);
882 aMap[adError] = ADOS::MapADOType2Jdbc(adError);
883 aMap[adUserDefined] = ADOS::MapADOType2Jdbc(adUserDefined);
884 aMap[adVariant] = ADOS::MapADOType2Jdbc(adVariant);
885 aMap[adIDispatch] = ADOS::MapADOType2Jdbc(adIDispatch);
886 aMap[adIUnknown] = ADOS::MapADOType2Jdbc(adIUnknown);
887 aMap[adGUID] = ADOS::MapADOType2Jdbc(adGUID);
888 aMap[adDate] = ADOS::MapADOType2Jdbc(adDate);
889 aMap[adDBDate] = ADOS::MapADOType2Jdbc(adDBDate);
890 aMap[adDBTime] = ADOS::MapADOType2Jdbc(adDBTime);
891 aMap[adDBTimeStamp] = ADOS::MapADOType2Jdbc(adDBTimeStamp);
892 aMap[adBSTR] = ADOS::MapADOType2Jdbc(adBSTR);
893 aMap[adChar] = ADOS::MapADOType2Jdbc(adChar);
894 aMap[adVarChar] = ADOS::MapADOType2Jdbc(adVarChar);
895 aMap[adLongVarChar] = ADOS::MapADOType2Jdbc(adLongVarChar);
896 aMap[adWChar] = ADOS::MapADOType2Jdbc(adWChar);
897 aMap[adVarWChar] = ADOS::MapADOType2Jdbc(adVarWChar);
898 aMap[adLongVarWChar] = ADOS::MapADOType2Jdbc(adLongVarWChar);
899 aMap[adBinary] = ADOS::MapADOType2Jdbc(adBinary);
900 aMap[adVarBinary] = ADOS::MapADOType2Jdbc(adVarBinary);
901 aMap[adLongVarBinary] = ADOS::MapADOType2Jdbc(adLongVarBinary);
902 aMap[adChapter] = ADOS::MapADOType2Jdbc(adChapter);
903 aMap[adFileTime] = ADOS::MapADOType2Jdbc(adFileTime);
904 aMap[adPropVariant] = ADOS::MapADOType2Jdbc(adPropVariant);
905 aMap[adVarNumeric] = ADOS::MapADOType2Jdbc(adVarNumeric);
906 // aMap[adArray] = ADOS::MapADOType2Jdbc(adArray);
907
908 m_aValueRange[12] = aMap;
909
910 ::std::map< sal_Int32,::rtl::OUString> aMap2;
911 aMap2[0] = ::rtl::OUString::createFromAscii("YES");
912 aMap2[1] = ::rtl::OUString::createFromAscii("NO");
913 m_aIntValueRange[18] = aMap2;
914
915 ODatabaseMetaDataResultSetMetaData* pMetaData = new ODatabaseMetaDataResultSetMetaData(m_pRecordSet,this);
916 pMetaData->setColumnsMap();
917 m_xMetaData = pMetaData;
918 }
919 // -------------------------------------------------------------------------
setTablesMap()920 void ODatabaseMetaDataResultSet::setTablesMap()
921 {
922
923 for(sal_Int32 i=1;i<5;i++)
924 m_aColMapping.push_back(i);
925 m_aColMapping.push_back(6);
926
927 ODatabaseMetaDataResultSetMetaData* pMetaData = new ODatabaseMetaDataResultSetMetaData(m_pRecordSet,this);
928 pMetaData->setTablesMap();
929 m_xMetaData = pMetaData;
930 }
931 // -------------------------------------------------------------------------
setProcedureColumnsMap()932 void ODatabaseMetaDataResultSet::setProcedureColumnsMap()
933 {
934
935 for(sal_Int32 i=1;i<5;i++)
936 m_aColMapping.push_back(i);
937 m_aColMapping.push_back(6);
938 m_aColMapping.push_back(10);
939 m_aColMapping.push_back(16);
940 m_aColMapping.push_back(13);
941 m_aColMapping.push_back(11);
942 m_aColMapping.push_back(12);
943
944 m_aColMapping.push_back(9);
945 m_aColMapping.push_back(14);
946
947 TInt2IntMap aMap;
948 aMap[DBTYPE_EMPTY] = DataType::SQLNULL;
949 aMap[DBTYPE_NULL] = DataType::SQLNULL;
950 aMap[DBTYPE_I2] = DataType::SMALLINT;
951 aMap[DBTYPE_I4] = DataType::INTEGER;
952 aMap[DBTYPE_R4] = DataType::FLOAT;
953 aMap[DBTYPE_R8] = DataType::DOUBLE;
954 aMap[DBTYPE_CY] = DataType::BIGINT;
955 aMap[DBTYPE_DATE] = DataType::DATE;
956 aMap[DBTYPE_BSTR] = DataType::VARCHAR;
957 aMap[DBTYPE_IDISPATCH] = DataType::OBJECT;
958 aMap[DBTYPE_ERROR] = DataType::OTHER;
959 aMap[DBTYPE_BOOL] = DataType::BIT;
960 aMap[DBTYPE_VARIANT] = DataType::STRUCT;
961 aMap[DBTYPE_IUNKNOWN] = DataType::OTHER;
962 aMap[DBTYPE_DECIMAL] = DataType::DECIMAL;
963 aMap[DBTYPE_UI1] = DataType::TINYINT;
964 aMap[DBTYPE_ARRAY] = DataType::ARRAY;
965 aMap[DBTYPE_BYREF] = DataType::REF;
966 aMap[DBTYPE_I1] = DataType::CHAR;
967 aMap[DBTYPE_UI2] = DataType::SMALLINT;
968 aMap[DBTYPE_UI4] = DataType::INTEGER;
969
970 // aMap[The] = ;
971 // aMap[in] = ;
972 aMap[DBTYPE_I8] = DataType::BIGINT;
973 aMap[DBTYPE_UI8] = DataType::BIGINT;
974 aMap[DBTYPE_GUID] = DataType::OTHER;
975 aMap[DBTYPE_VECTOR] = DataType::OTHER;
976 aMap[DBTYPE_FILETIME] = DataType::OTHER;
977 aMap[DBTYPE_RESERVED] = DataType::OTHER;
978
979 // aMap[The] = ;
980 aMap[DBTYPE_BYTES] = DataType::VARBINARY;
981 aMap[DBTYPE_STR] = DataType::LONGVARCHAR;
982 aMap[DBTYPE_WSTR] = DataType::LONGVARCHAR;
983 aMap[DBTYPE_NUMERIC] = DataType::NUMERIC;
984 aMap[DBTYPE_UDT] = DataType::OTHER;
985 aMap[DBTYPE_DBDATE] = DataType::DATE;
986 aMap[DBTYPE_DBTIME] = DataType::TIME;
987 aMap[DBTYPE_DBTIMESTAMP] = DataType::TIMESTAMP;
988 aMap[DBTYPE_HCHAPTER] = DataType::OTHER;
989 aMap[DBTYPE_PROPVARIANT] = DataType::OTHER;
990 aMap[DBTYPE_VARNUMERIC] = DataType::NUMERIC;
991
992 m_aValueRange[10] = aMap;
993
994 ODatabaseMetaDataResultSetMetaData* pMetaData = new ODatabaseMetaDataResultSetMetaData(m_pRecordSet,this);
995 pMetaData->setProcedureColumnsMap();
996 m_xMetaData = pMetaData;
997 }
998 // -------------------------------------------------------------------------
setPrimaryKeysMap()999 void ODatabaseMetaDataResultSet::setPrimaryKeysMap()
1000 {
1001
1002 sal_Int32 i=1;
1003 for(;i<5;i++)
1004 m_aColMapping.push_back(i);
1005 m_aColMapping.push_back(7);
1006 m_aColMapping.push_back(8);
1007
1008 ODatabaseMetaDataResultSetMetaData* pMetaData = new ODatabaseMetaDataResultSetMetaData(m_pRecordSet,this);
1009 pMetaData->setProcedureColumnsMap();
1010 m_xMetaData = pMetaData;
1011 }
1012 // -------------------------------------------------------------------------
setIndexInfoMap()1013 void ODatabaseMetaDataResultSet::setIndexInfoMap()
1014 {
1015
1016 sal_Int32 i=1;
1017 for(;i<4;i++)
1018 m_aColMapping.push_back(i);
1019 m_aColMapping.push_back(8);
1020 m_aColMapping.push_back(4);
1021 m_aColMapping.push_back(6);
1022 m_aColMapping.push_back(10);
1023 m_aColMapping.push_back(17);
1024 m_aColMapping.push_back(18);
1025 m_aColMapping.push_back(21);
1026 m_aColMapping.push_back(22);
1027 m_aColMapping.push_back(23);
1028 m_aColMapping.push_back(24);
1029
1030 TInt2IntMap aMap;
1031 aMap[DBPROPVAL_IT_HASH] = IndexType::HASHED;
1032 aMap[DBPROPVAL_IT_CONTENT] = IndexType::OTHER;
1033 aMap[DBPROPVAL_IT_OTHER] = IndexType::OTHER;
1034 aMap[DBPROPVAL_IT_BTREE] = IndexType::OTHER;
1035
1036 m_aValueRange[10] = aMap;
1037
1038 TInt2IntMap aMap2;
1039 aMap[0] = 1;
1040 aMap[1] = 0;
1041 m_aValueRange[8] = aMap2;
1042
1043 ::std::map< sal_Int32,::rtl::OUString> aMap3;
1044 aMap3[0] = ::rtl::OUString();
1045 aMap3[DB_COLLATION_ASC] = ::rtl::OUString::createFromAscii("A");
1046 aMap3[DB_COLLATION_DESC] = ::rtl::OUString::createFromAscii("D");
1047
1048 m_aIntValueRange[21] = aMap3;
1049
1050 ODatabaseMetaDataResultSetMetaData* pMetaData = new ODatabaseMetaDataResultSetMetaData(m_pRecordSet,this);
1051 pMetaData->setIndexInfoMap();
1052 m_xMetaData = pMetaData;
1053 }
1054 // -------------------------------------------------------------------------
setTablePrivilegesMap()1055 void ODatabaseMetaDataResultSet::setTablePrivilegesMap()
1056 {
1057
1058 sal_Int32 i=3;
1059 for(;i<6;i++)
1060 m_aColMapping.push_back(i);
1061 m_aColMapping.push_back(1);
1062 m_aColMapping.push_back(2);
1063 m_aColMapping.push_back(6);
1064 m_aColMapping.push_back(7);
1065
1066 ::std::map< sal_Int32,::rtl::OUString> aMap;
1067 aMap[0] = ::rtl::OUString::createFromAscii("YES");
1068 aMap[1] = ::rtl::OUString::createFromAscii("NO");
1069 m_aIntValueRange[7] = aMap;
1070
1071
1072 ODatabaseMetaDataResultSetMetaData* pMetaData = new ODatabaseMetaDataResultSetMetaData(m_pRecordSet,this);
1073 pMetaData->setTablePrivilegesMap();
1074 m_xMetaData = pMetaData;
1075 }
1076 // -------------------------------------------------------------------------
setCrossReferenceMap()1077 void ODatabaseMetaDataResultSet::setCrossReferenceMap()
1078 {
1079
1080 sal_Int32 i=1;
1081 for(;i<5;i++)
1082 m_aColMapping.push_back(i);
1083 for(i=7;i<11;i++)
1084 m_aColMapping.push_back(i);
1085
1086 m_aColMapping.push_back(13);
1087 m_aColMapping.push_back(14);
1088 m_aColMapping.push_back(15);
1089 m_aColMapping.push_back(17);
1090 m_aColMapping.push_back(16);
1091 m_aColMapping.push_back(18);
1092
1093 ::std::map< ::rtl::OUString,sal_Int32> aMap;
1094 aMap[ ::rtl::OUString::createFromAscii("CASCADE")] = KeyRule::CASCADE;
1095 aMap[ ::rtl::OUString::createFromAscii("RESTRICT")] = KeyRule::RESTRICT;
1096 aMap[ ::rtl::OUString::createFromAscii("SET NULL")] = KeyRule::SET_NULL;
1097 aMap[ ::rtl::OUString::createFromAscii("SET DEFAULT")] = KeyRule::SET_DEFAULT;
1098 aMap[ ::rtl::OUString::createFromAscii("NO ACTION")] = KeyRule::NO_ACTION;
1099
1100 m_aStrValueRange[14] = aMap;
1101 m_aStrValueRange[15] = aMap;
1102
1103 ODatabaseMetaDataResultSetMetaData* pMetaData = new ODatabaseMetaDataResultSetMetaData(m_pRecordSet,this);
1104 pMetaData->setCrossReferenceMap();
1105 m_xMetaData = pMetaData;
1106 }
1107 // -------------------------------------------------------------------------
setTypeInfoMap(sal_Bool _bJetEngine)1108 void ODatabaseMetaDataResultSet::setTypeInfoMap(sal_Bool _bJetEngine)
1109 {
1110 sal_Int32 i=1;
1111 for(;i<19;i++)
1112 m_aColMapping.push_back(i);
1113
1114 ::std::map< ::rtl::OUString,sal_Int32> aMap1;
1115 aMap1[ ::rtl::OUString()] = 10;
1116
1117 m_aStrValueRange[18] = aMap1;
1118
1119 TInt2IntMap aMap;
1120 aMap[adEmpty] = ADOS::MapADOType2Jdbc(adEmpty);
1121 aMap[adTinyInt] = ADOS::MapADOType2Jdbc(adTinyInt);
1122 aMap[adSmallInt] = ADOS::MapADOType2Jdbc(adSmallInt);
1123 aMap[adInteger] = ADOS::MapADOType2Jdbc(adInteger);
1124 aMap[adBigInt] = ADOS::MapADOType2Jdbc(adBigInt);
1125 aMap[adUnsignedTinyInt] = ADOS::MapADOType2Jdbc(adUnsignedTinyInt);
1126 aMap[adUnsignedSmallInt]= ADOS::MapADOType2Jdbc(adUnsignedSmallInt);
1127 aMap[adUnsignedInt] = ADOS::MapADOType2Jdbc(adUnsignedInt);
1128 aMap[adUnsignedBigInt] = ADOS::MapADOType2Jdbc(adUnsignedBigInt);
1129 aMap[adSingle] = ADOS::MapADOType2Jdbc(adSingle);
1130 aMap[adDouble] = ADOS::MapADOType2Jdbc(adDouble);
1131 aMap[adCurrency] = ADOS::MapADOType2Jdbc(adCurrency);
1132 aMap[adDecimal] = ADOS::MapADOType2Jdbc(adDecimal);
1133 aMap[adNumeric] = ADOS::MapADOType2Jdbc(adNumeric);
1134 aMap[adBoolean] = ADOS::MapADOType2Jdbc(adBoolean);
1135 aMap[adError] = ADOS::MapADOType2Jdbc(adError);
1136 aMap[adUserDefined] = ADOS::MapADOType2Jdbc(adUserDefined);
1137 aMap[adVariant] = ADOS::MapADOType2Jdbc(adVariant);
1138 aMap[adIDispatch] = ADOS::MapADOType2Jdbc(adIDispatch);
1139 aMap[adIUnknown] = ADOS::MapADOType2Jdbc(adIUnknown);
1140 aMap[adGUID] = ADOS::MapADOType2Jdbc(adGUID);
1141 aMap[adDate] = _bJetEngine ? ADOS::MapADOType2Jdbc(adDBTimeStamp) : ADOS::MapADOType2Jdbc(adDate);
1142 aMap[adDBDate] = ADOS::MapADOType2Jdbc(adDBDate);
1143 aMap[adDBTime] = ADOS::MapADOType2Jdbc(adDBTime);
1144 aMap[adDBTimeStamp] = ADOS::MapADOType2Jdbc(adDBTimeStamp);
1145 aMap[adBSTR] = ADOS::MapADOType2Jdbc(adBSTR);
1146 aMap[adChar] = ADOS::MapADOType2Jdbc(adChar);
1147 aMap[adVarChar] = ADOS::MapADOType2Jdbc(adVarChar);
1148 aMap[adLongVarChar] = ADOS::MapADOType2Jdbc(adLongVarChar);
1149 aMap[adWChar] = ADOS::MapADOType2Jdbc(adWChar);
1150 aMap[adVarWChar] = ADOS::MapADOType2Jdbc(adVarWChar);
1151 aMap[adLongVarWChar] = ADOS::MapADOType2Jdbc(adLongVarWChar);
1152 aMap[adBinary] = ADOS::MapADOType2Jdbc(adBinary);
1153 aMap[adVarBinary] = ADOS::MapADOType2Jdbc(adVarBinary);
1154 aMap[adLongVarBinary] = ADOS::MapADOType2Jdbc(adLongVarBinary);
1155 aMap[adChapter] = ADOS::MapADOType2Jdbc(adChapter);
1156 aMap[adFileTime] = ADOS::MapADOType2Jdbc(adFileTime);
1157 aMap[adPropVariant] = ADOS::MapADOType2Jdbc(adPropVariant);
1158 aMap[adVarNumeric] = ADOS::MapADOType2Jdbc(adVarNumeric);
1159 // aMap[adArray] = ADOS::MapADOType2Jdbc(adArray);
1160
1161 m_aValueRange[2] = aMap;
1162
1163 TInt2IntMap aColumnValueMapping;
1164 aColumnValueMapping[VARIANT_FALSE] = ColumnValue::NO_NULLS;
1165 aColumnValueMapping[VARIANT_TRUE] = ColumnValue::NULLABLE;
1166 m_aValueRange[7] = aColumnValueMapping;
1167
1168 // now adjust the column mapping
1169 // OJ 24.01.2002 96860
1170 TInt2IntMap aSerachMapping;
1171 aSerachMapping[DB_UNSEARCHABLE] = ColumnSearch::NONE;
1172 aSerachMapping[DB_LIKE_ONLY] = ColumnSearch::CHAR;
1173 aSerachMapping[DB_ALL_EXCEPT_LIKE] = ColumnSearch::BASIC;
1174 aSerachMapping[DB_SEARCHABLE] = ColumnSearch::FULL;
1175
1176 m_aValueRange[9] = aSerachMapping;
1177
1178 TInt2IntMap aCurrencyMapping;
1179 m_aValueRange[11] = aCurrencyMapping;
1180
1181 ODatabaseMetaDataResultSetMetaData* pMetaData = new ODatabaseMetaDataResultSetMetaData(m_pRecordSet,this);
1182 pMetaData->setTypeInfoMap();
1183 m_xMetaData = pMetaData;
1184 }
1185 // -----------------------------------------------------------------------------
acquire()1186 void SAL_CALL ODatabaseMetaDataResultSet::acquire() throw()
1187 {
1188 ODatabaseMetaDataResultSet_BASE::acquire();
1189 }
1190 // -----------------------------------------------------------------------------
release()1191 void SAL_CALL ODatabaseMetaDataResultSet::release() throw()
1192 {
1193 ODatabaseMetaDataResultSet_BASE::release();
1194 }
1195 // -----------------------------------------------------------------------------
getPropertySetInfo()1196 ::com::sun::star::uno::Reference< ::com::sun::star::beans::XPropertySetInfo > SAL_CALL ODatabaseMetaDataResultSet::getPropertySetInfo( ) throw(::com::sun::star::uno::RuntimeException)
1197 {
1198 return ::cppu::OPropertySetHelper::createPropertySetInfo(getInfoHelper());
1199 }
1200 // -----------------------------------------------------------------------------
getValue(sal_Int32 columnIndex)1201 OLEVariant ODatabaseMetaDataResultSet::getValue(sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1202 {
1203 ::osl::MutexGuard aGuard( m_aMutex );
1204 checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed);
1205
1206 checkRecordSet();
1207
1208 WpADOField aField = ADOS::getField(m_pRecordSet,columnIndex);
1209 aField.get_Value(m_aValue);
1210 return m_aValue;
1211 }
1212 // -----------------------------------------------------------------------------
1213
1214
1215