connectivity/source/commontools/FDatabaseMetaDataResultSet.cxx

   1 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
   2 /*
   3  * This file is part of the LibreOffice project.
   4  *
   5  * This Source Code Form is subject to the terms of the Mozilla Public
   6  * License, v. 2.0. If a copy of the MPL was not distributed with this
   7  * file, You can obtain one at http://mozilla.org/MPL/2.0/.
   8  *
   9  * This file incorporates work covered by the following license notice:
  10  *
  11  *   Licensed to the Apache Software Foundation (ASF) under one or more
  12  *   contributor license agreements. See the NOTICE file distributed
  13  *   with this work for additional information regarding copyright
  14  *   ownership. The ASF licenses this file to you under the Apache
  15  *   License, Version 2.0 (the "License"); you may not use this file
  16  *   except in compliance with the License. You may obtain a copy of
  17  *   the License at http://www.apache.org/licenses/LICENSE-2.0 .
  18  */
  19
  20
  21 #include <ParameterSubstitution.hxx>
  22 #include <FDatabaseMetaDataResultSet.hxx>
  23 #include <FDatabaseMetaDataResultSetMetaData.hxx>
  24 #include <com/sun/star/sdbc/ColumnSearch.hpp>
  25 #include <com/sun/star/beans/PropertyAttribute.hpp>
  26 #include <cppuhelper/typeprovider.hxx>
  27 #include <comphelper/sequence.hxx>
  28 #include <cppuhelper/supportsservice.hxx>
  29 #include <connectivity/dbexception.hxx>
  30 #include <o3tl/unreachable.hxx>
  31 #include <TConnection.hxx>
  32
  33 using namespace connectivity;
  34 using namespace dbtools;
  35 using namespace cppu;
  36
  37 using namespace ::com::sun::star::beans;
  38 using namespace ::com::sun::star::uno;
  39 using namespace ::com::sun::star::sdbcx;
  40 using namespace ::com::sun::star::sdbc;
  41 using namespace ::com::sun::star::container;
  42 using namespace ::com::sun::star::lang;
  43
  44 ODatabaseMetaDataResultSet::ODatabaseMetaDataResultSet()
  45     :ODatabaseMetaDataResultSet_BASE(m_aMutex)
  46     ,::comphelper::OPropertyContainer(ODatabaseMetaDataResultSet_BASE::rBHelper)
  47     ,m_aStatement(nullptr)
  48     ,m_nColPos(0)
  49     ,m_bBOF(true)
  50     ,m_bEOF(true)
  51 {
  52     construct();
  53 }
  54
  55
  56 ODatabaseMetaDataResultSet::ODatabaseMetaDataResultSet( MetaDataResultSetType _eType )
  57     :ODatabaseMetaDataResultSet_BASE(m_aMutex)
  58     ,::comphelper::OPropertyContainer(ODatabaseMetaDataResultSet_BASE::rBHelper)
  59     ,m_aStatement(nullptr)
  60     ,m_nColPos(0)
  61     ,m_bBOF(true)
  62     ,m_bEOF(true)
  63 {
  64     construct();
  65
  66     setType(_eType);
  67 }
  68
  69
  70 ODatabaseMetaDataResultSet::~ODatabaseMetaDataResultSet()
  71 {
  72 }
  73
  74 void ODatabaseMetaDataResultSet::construct()
  75 {
  76     registerProperty(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_FETCHSIZE),           PROPERTY_ID_FETCHSIZE,          0,&m_nFetchSize,        ::cppu::UnoType<sal_Int32>::get());
  77     registerProperty(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_RESULTSETTYPE),        PROPERTY_ID_RESULTSETTYPE,          PropertyAttribute::READONLY,&m_nResultSetType,       ::cppu::UnoType<sal_Int32>::get());
  78     registerProperty(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_FETCHDIRECTION),      PROPERTY_ID_FETCHDIRECTION,     0,  &m_nFetchDirection, ::cppu::UnoType<sal_Int32>::get());
  79     registerProperty(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_RESULTSETCONCURRENCY), PROPERTY_ID_RESULTSETCONCURRENCY,   PropertyAttribute::READONLY,&m_nResultSetConcurrency,                ::cppu::UnoType<sal_Int32>::get());
  80 }
  81
  82 void ODatabaseMetaDataResultSet::setType(MetaDataResultSetType _eType)
  83 {
  84     switch( _eType )
  85     {
  86         case eCatalogs:             setCatalogsMap(); break;
  87         case eSchemas:              setSchemasMap(); break;
  88         case eColumnPrivileges:     setColumnPrivilegesMap(); break;
  89         case eColumns:              setColumnsMap(); break;
  90         case eTables:               setTablesMap(); break;
  91         case eTableTypes:           setTableTypes(); break;
  92         case eProcedureColumns:     setProcedureColumnsMap(); break;
  93         case eProcedures:           setProceduresMap(); break;
  94         case eExportedKeys:         setExportedKeysMap(); break;
  95         case eImportedKeys:         setImportedKeysMap(); break;
  96         case ePrimaryKeys:          setPrimaryKeysMap(); break;
  97         case eIndexInfo:            setIndexInfoMap(); break;
  98         case eTablePrivileges:      setTablePrivilegesMap(); break;
  99         case eCrossReference:       setCrossReferenceMap(); break;
 100         case eTypeInfo:             setTypeInfoMap(); break;
 101         case eBestRowIdentifier:    setBestRowIdentifierMap(); break;
 102         case eVersionColumns:       setVersionColumnsMap(); break;
 103         case eUDTs:                 setUDTsMap(); break;
 104         default:
 105             OSL_FAIL("Wrong type!");
 106     }
 107 }
 108
 109 void ODatabaseMetaDataResultSet::disposing()
 110 {
 111     OPropertySetHelper::disposing();
 112
 113     ::osl::MutexGuard aGuard(m_aMutex);
 114     m_aStatement    = nullptr;
 115     m_xMetaData.clear();
 116     m_aRowsIter = m_aRows.end();
 117     m_aRows.clear();
 118     m_aRowsIter = m_aRows.end();
 119 }
 120
 121 void SAL_CALL ODatabaseMetaDataResultSet::acquire() throw()
 122 {
 123     ODatabaseMetaDataResultSet_BASE::acquire();
 124 }
 125
 126 void SAL_CALL ODatabaseMetaDataResultSet::release() throw()
 127 {
 128     ODatabaseMetaDataResultSet_BASE::release();
 129 }
 130
 131 Any SAL_CALL ODatabaseMetaDataResultSet::queryInterface( const Type & rType )
 132 {
 133     Any aRet = OPropertySetHelper::queryInterface(rType);
 134     return aRet.hasValue() ? aRet : ODatabaseMetaDataResultSet_BASE::queryInterface(rType);
 135 }
 136
 137 Sequence< Type > SAL_CALL ODatabaseMetaDataResultSet::getTypes(  )
 138 {
 139     ::cppu::OTypeCollection aTypes( cppu::UnoType<css::beans::XMultiPropertySet>::get(),
 140                                     cppu::UnoType<css::beans::XFastPropertySet>::get(),
 141                                     cppu::UnoType<css::beans::XPropertySet>::get());
 142
 143     return ::comphelper::concatSequences(aTypes.getTypes(),ODatabaseMetaDataResultSet_BASE::getTypes());
 144 }
 145
 146 void ODatabaseMetaDataResultSet::setRows(const ORows& _rRows)
 147 {
 148     m_aRows = _rRows;
 149     m_bBOF = true;
 150     m_bEOF = m_aRows.empty();
 151 }
 152
 153 sal_Int32 SAL_CALL ODatabaseMetaDataResultSet::findColumn( const OUString& columnName )
 154 {
 155     ::osl::MutexGuard aGuard( m_aMutex );
 156     checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed );
 157
 158
 159     Reference< XResultSetMetaData > xMeta = getMetaData();
 160     sal_Int32 nLen = xMeta->getColumnCount();
 161     sal_Int32 i = 1;
 162     for(;i<=nLen;++i)
 163     {
 164         if(xMeta->isCaseSensitive(i) ? columnName == xMeta->getColumnName(i) :
 165             columnName.equalsIgnoreAsciiCase(xMeta->getColumnName(i))
 166             )
 167             return i;
 168     }
 169
 170     ::dbtools::throwInvalidColumnException( columnName, *this );
 171     O3TL_UNREACHABLE;
 172 }
 173
 174 void ODatabaseMetaDataResultSet::checkIndex(sal_Int32 columnIndex )
 175 {
 176     if(columnIndex >= static_cast<sal_Int32>((*m_aRowsIter).size()) || columnIndex < 1)
 177         ::dbtools::throwInvalidIndexException(*this);
 178 }
 179
 180 Reference< css::io::XInputStream > SAL_CALL ODatabaseMetaDataResultSet::getBinaryStream( sal_Int32 /*columnIndex*/ )
 181 {
 182     return nullptr;
 183 }
 184
 185 Reference< css::io::XInputStream > SAL_CALL ODatabaseMetaDataResultSet::getCharacterStream( sal_Int32 /*columnIndex*/ )
 186 {
 187     return nullptr;
 188 }
 189
 190
 191 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::getBoolean( sal_Int32 columnIndex )
 192 {
 193     return bool(getValue(columnIndex));
 194 }
 195
 196
 197 sal_Int8 SAL_CALL ODatabaseMetaDataResultSet::getByte( sal_Int32 columnIndex )
 198 {
 199     return getValue(columnIndex);
 200 }
 201
 202
 203 Sequence< sal_Int8 > SAL_CALL ODatabaseMetaDataResultSet::getBytes( sal_Int32 columnIndex )
 204 {
 205     return getValue(columnIndex);
 206 }
 207
 208
 209 css::util::Date SAL_CALL ODatabaseMetaDataResultSet::getDate( sal_Int32 columnIndex )
 210 {
 211     return getValue(columnIndex);
 212 }
 213
 214
 215 double SAL_CALL ODatabaseMetaDataResultSet::getDouble( sal_Int32 columnIndex )
 216 {
 217     return getValue(columnIndex);
 218 }
 219
 220
 221 float SAL_CALL ODatabaseMetaDataResultSet::getFloat( sal_Int32 columnIndex )
 222 {
 223     return getValue(columnIndex);
 224 }
 225
 226
 227 sal_Int32 SAL_CALL ODatabaseMetaDataResultSet::getInt( sal_Int32 columnIndex )
 228 {
 229     return getValue(columnIndex);
 230 }
 231
 232
 233 sal_Int32 SAL_CALL ODatabaseMetaDataResultSet::getRow(  )
 234 {
 235     return 0;
 236 }
 237
 238
 239 sal_Int64 SAL_CALL ODatabaseMetaDataResultSet::getLong( sal_Int32 columnIndex )
 240 {
 241     return getValue(columnIndex);
 242 }
 243
 244
 245 Reference< XResultSetMetaData > SAL_CALL ODatabaseMetaDataResultSet::getMetaData(  )
 246 {
 247     ::osl::MutexGuard aGuard( m_aMutex );
 248     checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed );
 249
 250
 251     if(!m_xMetaData.is())
 252         m_xMetaData = new ODatabaseMetaDataResultSetMetaData();
 253
 254     return m_xMetaData;
 255 }
 256
 257 Reference< XArray > SAL_CALL ODatabaseMetaDataResultSet::getArray( sal_Int32 /*columnIndex*/ )
 258 {
 259     return nullptr;
 260 }
 261
 262
 263 Reference< XClob > SAL_CALL ODatabaseMetaDataResultSet::getClob( sal_Int32 /*columnIndex*/ )
 264 {
 265     return nullptr;
 266 }
 267
 268 Reference< XBlob > SAL_CALL ODatabaseMetaDataResultSet::getBlob( sal_Int32 /*columnIndex*/ )
 269 {
 270     return nullptr;
 271 }
 272
 273
 274 Reference< XRef > SAL_CALL ODatabaseMetaDataResultSet::getRef( sal_Int32 /*columnIndex*/ )
 275 {
 276     return nullptr;
 277 }
 278
 279
 280 Any SAL_CALL ODatabaseMetaDataResultSet::getObject( sal_Int32 columnIndex, const Reference< css::container::XNameAccess >& /*typeMap*/ )
 281 {
 282     return getValue(columnIndex).makeAny();
 283 }
 284
 285
 286 sal_Int16 SAL_CALL ODatabaseMetaDataResultSet::getShort( sal_Int32 columnIndex )
 287 {
 288     return getValue(columnIndex);
 289 }
 290
 291
 292 OUString SAL_CALL ODatabaseMetaDataResultSet::getString( sal_Int32 columnIndex )
 293 {
 294     return getValue(columnIndex);
 295 }
 296
 297
 298 css::util::Time SAL_CALL ODatabaseMetaDataResultSet::getTime( sal_Int32 columnIndex )
 299 {
 300     return getValue(columnIndex);
 301 }
 302
 303
 304 css::util::DateTime SAL_CALL ODatabaseMetaDataResultSet::getTimestamp( sal_Int32 columnIndex )
 305 {
 306     return getValue(columnIndex);
 307 }
 308
 309
 310 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::isAfterLast(  )
 311 {
 312     return m_bEOF;
 313 }
 314
 315
 316 SAL_WNOUNREACHABLE_CODE_PUSH
 317
 318 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::isFirst(  )
 319 {
 320     ::dbtools::throwFunctionSequenceException(*this);
 321     return false;
 322 }
 323
 324 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::isLast(  )
 325 {
 326     ::dbtools::throwFunctionSequenceException(*this);
 327     return false;
 328 }
 329
 330 SAL_WNOUNREACHABLE_CODE_POP
 331
 332
 333 void SAL_CALL ODatabaseMetaDataResultSet::beforeFirst(  )
 334 {
 335     ::dbtools::throwFunctionSequenceException(*this);
 336 }
 337
 338 void SAL_CALL ODatabaseMetaDataResultSet::afterLast(  )
 339 {
 340     ::dbtools::throwFunctionSequenceException(*this);
 341 }
 342
 343
 344 void SAL_CALL ODatabaseMetaDataResultSet::close(  )
 345 {
 346     {
 347         ::osl::MutexGuard aGuard( m_aMutex );
 348         checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed );
 349
 350     }
 351     dispose();
 352 }
 353
 354
 355 SAL_WNOUNREACHABLE_CODE_PUSH
 356
 357 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::first(  )
 358 {
 359     ::dbtools::throwFunctionSequenceException(*this);
 360     return false;
 361 }
 362
 363
 364 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::last(  )
 365 {
 366     ::dbtools::throwFunctionSequenceException(*this);
 367     return false;
 368 }
 369
 370 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::absolute( sal_Int32 /*row*/ )
 371 {
 372     ::dbtools::throwFunctionSequenceException(*this);
 373     return false;
 374 }
 375
 376 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::relative( sal_Int32 /*row*/ )
 377 {
 378     ::dbtools::throwFunctionSequenceException(*this);
 379     return false;
 380 }
 381
 382 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::previous(  )
 383 {
 384     ::dbtools::throwFunctionSequenceException(*this);
 385     return false;
 386 }
 387
 388 SAL_WNOUNREACHABLE_CODE_POP
 389
 390
 391 Reference< XInterface > SAL_CALL ODatabaseMetaDataResultSet::getStatement(  )
 392 {
 393     return m_aStatement.get();
 394 }
 395
 396
 397 SAL_WNOUNREACHABLE_CODE_PUSH
 398
 399 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::rowDeleted(  )
 400 {
 401     ::dbtools::throwFunctionSequenceException(*this);
 402     return false;
 403 }
 404
 405 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::rowInserted(  )
 406 {
 407     ::dbtools::throwFunctionSequenceException(*this);
 408     return false;
 409 }
 410
 411 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::rowUpdated(  )
 412 {
 413     ::dbtools::throwFunctionSequenceException(*this);
 414     return false;
 415 }
 416
 417 SAL_WNOUNREACHABLE_CODE_POP
 418
 419
 420 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::isBeforeFirst(  )
 421 {
 422     return m_bBOF;
 423 }
 424
 425
 426 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::next(  )
 427 {
 428     ::osl::MutexGuard aGuard( m_aMutex );
 429     checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed );
 430
 431     if ( m_bBOF )
 432     {
 433        m_aRowsIter = m_aRows.begin();
 434        m_bBOF = false;
 435     }
 436     else
 437     {
 438         if ( m_bEOF )
 439             throwFunctionSequenceException( *this );
 440         else
 441             if ( m_aRowsIter != m_aRows.end() )
 442                 ++m_aRowsIter;
 443     }
 444
 445     bool bSuccess = m_aRowsIter != m_aRows.end();
 446     if ( !bSuccess )
 447     {
 448         m_bEOF = true;
 449         m_bBOF = m_aRows.empty();
 450     }
 451     return bSuccess;
 452 }
 453
 454
 455 sal_Bool SAL_CALL ODatabaseMetaDataResultSet::wasNull(  )
 456 {
 457     ::osl::MutexGuard aGuard( m_aMutex );
 458     checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed );
 459
 460
 461     if(m_aRowsIter == m_aRows.end() || !(*m_aRowsIter)[m_nColPos].is())
 462         return true;
 463
 464     return (*m_aRowsIter)[m_nColPos]->getValue().isNull();
 465 }
 466
 467 void SAL_CALL ODatabaseMetaDataResultSet::refreshRow(  )
 468 {
 469 }
 470
 471
 472 void SAL_CALL ODatabaseMetaDataResultSet::cancel(  )
 473 {
 474 }
 475
 476 void SAL_CALL ODatabaseMetaDataResultSet::clearWarnings(  )
 477 {
 478 }
 479
 480 Any SAL_CALL ODatabaseMetaDataResultSet::getWarnings(  )
 481 {
 482     return Any();
 483 }
 484
 485 ::cppu::IPropertyArrayHelper* ODatabaseMetaDataResultSet::createArrayHelper( ) const
 486 {
 487     Sequence< Property > aProps;
 488     describeProperties(aProps);
 489     return new ::cppu::OPropertyArrayHelper(aProps);
 490 }
 491
 492 ::cppu::IPropertyArrayHelper & ODatabaseMetaDataResultSet::getInfoHelper()
 493 {
 494     return *getArrayHelper();
 495 }
 496
 497 void ODatabaseMetaDataResultSet::setProceduresMap()
 498 {
 499     ODatabaseMetaDataResultSetMetaData* pMetaData = new ODatabaseMetaDataResultSetMetaData();
 500     pMetaData->setProceduresMap();
 501     m_xMetaData = pMetaData;
 502 }
 503
 504 void ODatabaseMetaDataResultSet::setCatalogsMap()
 505 {
 506     ODatabaseMetaDataResultSetMetaData* pMetaData = new ODatabaseMetaDataResultSetMetaData();
 507     pMetaData->setCatalogsMap();
 508     m_xMetaData = pMetaData;
 509 }
 510
 511 void ODatabaseMetaDataResultSet::setSchemasMap()
 512 {
 513     ODatabaseMetaDataResultSetMetaData* pMetaData = new ODatabaseMetaDataResultSetMetaData();
 514     pMetaData->setSchemasMap();
 515     m_xMetaData = pMetaData;
 516 }
 517
 518 void ODatabaseMetaDataResultSet::setColumnPrivilegesMap()
 519 {
 520     ODatabaseMetaDataResultSetMetaData* pMetaData = new ODatabaseMetaDataResultSetMetaData();
 521     pMetaData->setColumnPrivilegesMap();
 522     m_xMetaData = pMetaData;
 523 }
 524
 525 void ODatabaseMetaDataResultSet::setColumnsMap()
 526 {
 527
 528     ODatabaseMetaDataResultSetMetaData* pMetaData = new ODatabaseMetaDataResultSetMetaData();
 529     pMetaData->setColumnsMap();
 530     m_xMetaData = pMetaData;
 531 }
 532
 533 void ODatabaseMetaDataResultSet::setTablesMap()
 534 {
 535
 536     ODatabaseMetaDataResultSetMetaData* pMetaData = new ODatabaseMetaDataResultSetMetaData();
 537     pMetaData->setTablesMap();
 538     m_xMetaData = pMetaData;
 539 }
 540
 541 void ODatabaseMetaDataResultSet::setProcedureColumnsMap()
 542 {
 543     ODatabaseMetaDataResultSetMetaData* pMetaData = new ODatabaseMetaDataResultSetMetaData();
 544     pMetaData->setProcedureColumnsMap();
 545     m_xMetaData = pMetaData;
 546 }
 547
 548 void ODatabaseMetaDataResultSet::setPrimaryKeysMap()
 549 {
 550     ODatabaseMetaDataResultSetMetaData* pMetaData = new ODatabaseMetaDataResultSetMetaData();
 551     pMetaData->setPrimaryKeysMap();
 552     m_xMetaData = pMetaData;
 553 }
 554
 555 void ODatabaseMetaDataResultSet::setIndexInfoMap()
 556 {
 557     ODatabaseMetaDataResultSetMetaData* pMetaData = new ODatabaseMetaDataResultSetMetaData();
 558     pMetaData->setIndexInfoMap();
 559     m_xMetaData = pMetaData;
 560 }
 561
 562 void ODatabaseMetaDataResultSet::setTablePrivilegesMap()
 563 {
 564     ODatabaseMetaDataResultSetMetaData* pMetaData = new ODatabaseMetaDataResultSetMetaData();
 565     pMetaData->setTablePrivilegesMap();
 566     m_xMetaData = pMetaData;
 567 }
 568
 569 void ODatabaseMetaDataResultSet::setCrossReferenceMap()
 570 {
 571     ODatabaseMetaDataResultSetMetaData* pMetaData = new ODatabaseMetaDataResultSetMetaData();
 572     pMetaData->setCrossReferenceMap();
 573     m_xMetaData = pMetaData;
 574 }
 575
 576 void ODatabaseMetaDataResultSet::setVersionColumnsMap()
 577 {
 578     ODatabaseMetaDataResultSetMetaData* pMetaData = new ODatabaseMetaDataResultSetMetaData();
 579     pMetaData->setVersionColumnsMap();
 580     m_xMetaData = pMetaData;
 581 }
 582
 583 void ODatabaseMetaDataResultSet::setBestRowIdentifierMap()
 584 {
 585     ODatabaseMetaDataResultSetMetaData* pMetaData = new ODatabaseMetaDataResultSetMetaData();
 586     pMetaData->setBestRowIdentifierMap();
 587     m_xMetaData = pMetaData;
 588 }
 589
 590 void ODatabaseMetaDataResultSet::setTypeInfoMap()
 591 {
 592     ODatabaseMetaDataResultSetMetaData* pMetaData = new ODatabaseMetaDataResultSetMetaData();
 593     pMetaData->setTypeInfoMap();
 594     m_xMetaData = pMetaData;
 595 }
 596
 597 void ODatabaseMetaDataResultSet::setUDTsMap()
 598 {
 599     ODatabaseMetaDataResultSetMetaData* pMetaData = new ODatabaseMetaDataResultSetMetaData();
 600     pMetaData->setUDTsMap();
 601     m_xMetaData = pMetaData;
 602 }
 603
 604 void ODatabaseMetaDataResultSet::setTableTypes()
 605 {
 606     ODatabaseMetaDataResultSetMetaData* pMetaData = new ODatabaseMetaDataResultSetMetaData();
 607     pMetaData->setTableTypes();
 608     m_xMetaData = pMetaData;
 609 }
 610
 611 void ODatabaseMetaDataResultSet::setExportedKeysMap()
 612 {
 613     ODatabaseMetaDataResultSetMetaData* pMetaData = new ODatabaseMetaDataResultSetMetaData();
 614     pMetaData->setExportedKeysMap();
 615     m_xMetaData = pMetaData;
 616 }
 617
 618 void ODatabaseMetaDataResultSet::setImportedKeysMap()
 619 {
 620     ODatabaseMetaDataResultSetMetaData* pMetaData = new ODatabaseMetaDataResultSetMetaData();
 621     pMetaData->setImportedKeysMap();
 622     m_xMetaData = pMetaData;
 623 }
 624
 625 Reference< css::beans::XPropertySetInfo > SAL_CALL ODatabaseMetaDataResultSet::getPropertySetInfo(  )
 626 {
 627     return ::cppu::OPropertySetHelper::createPropertySetInfo(getInfoHelper());
 628 }
 629
 630 ORowSetValueDecorator& ORowSetValueDecorator::operator=(const ORowSetValue& _aValue)
 631 {
 632     m_aValue = _aValue;
 633     return *this;
 634 }
 635
 636 const ORowSetValue& ODatabaseMetaDataResultSet::getValue(sal_Int32 columnIndex)
 637 {
 638     ::osl::MutexGuard aGuard( m_aMutex );
 639     checkDisposed(ODatabaseMetaDataResultSet_BASE::rBHelper.bDisposed );
 640
 641     if ( isBeforeFirst() || isAfterLast() )
 642         ::dbtools::throwFunctionSequenceException( *this );
 643
 644     checkIndex(columnIndex );
 645     m_nColPos = columnIndex;
 646
 647     if(m_aRowsIter != m_aRows.end() && (*m_aRowsIter)[columnIndex].is())
 648         return *(*m_aRowsIter)[columnIndex];
 649     return m_aEmptyValue;
 650 }
 651
 652 /// return an empty ORowSetValueDecorator
 653 ORowSetValueDecoratorRef const & ODatabaseMetaDataResultSet::getEmptyValue()
 654 {
 655     static ORowSetValueDecoratorRef aEmptyValueRef = new ORowSetValueDecorator();
 656     return aEmptyValueRef;
 657 }
 658
 659 /// return an ORowSetValueDecorator with 0 as value
 660 ORowSetValueDecoratorRef const & ODatabaseMetaDataResultSet::get0Value()
 661 {
 662     static ORowSetValueDecoratorRef a0ValueRef = new ORowSetValueDecorator(sal_Int32(0));
 663     return a0ValueRef;
 664 }
 665
 666 /// return an ORowSetValueDecorator with 1 as value
 667 ORowSetValueDecoratorRef const & ODatabaseMetaDataResultSet::get1Value()
 668 {
 669     static ORowSetValueDecoratorRef a1ValueRef = new ORowSetValueDecorator(sal_Int32(1));
 670     return a1ValueRef;
 671 }
 672
 673 /// return an ORowSetValueDecorator with ColumnSearch::BASIC as value
 674 ORowSetValueDecoratorRef const & ODatabaseMetaDataResultSet::getBasicValue()
 675 {
 676     static ORowSetValueDecoratorRef aValueRef = new ORowSetValueDecorator(ColumnSearch::BASIC);
 677     return aValueRef;
 678 }
 679
 680 ORowSetValueDecoratorRef const & ODatabaseMetaDataResultSet::getSelectValue()
 681 {
 682     static ORowSetValueDecoratorRef aValueRef = new ORowSetValueDecorator(OUString("SELECT"));
 683     return aValueRef;
 684 }
 685
 686 ORowSetValueDecoratorRef const & ODatabaseMetaDataResultSet::getInsertValue()
 687 {
 688     static ORowSetValueDecoratorRef aValueRef = new ORowSetValueDecorator(OUString("INSERT"));
 689     return aValueRef;
 690 }
 691
 692 ORowSetValueDecoratorRef const & ODatabaseMetaDataResultSet::getDeleteValue()
 693 {
 694     static ORowSetValueDecoratorRef aValueRef = new ORowSetValueDecorator(OUString("DELETE"));
 695     return aValueRef;
 696 }
 697
 698 ORowSetValueDecoratorRef const & ODatabaseMetaDataResultSet::getUpdateValue()
 699 {
 700     static ORowSetValueDecoratorRef aValueRef = new ORowSetValueDecorator(OUString("UPDATE"));
 701     return aValueRef;
 702 }
 703
 704 ORowSetValueDecoratorRef const & ODatabaseMetaDataResultSet::getCreateValue()
 705 {
 706     static ORowSetValueDecoratorRef aValueRef = new ORowSetValueDecorator(OUString("CREATE"));
 707     return aValueRef;
 708 }
 709
 710 ORowSetValueDecoratorRef const & ODatabaseMetaDataResultSet::getReadValue()
 711 {
 712     static ORowSetValueDecoratorRef aValueRef = new ORowSetValueDecorator(OUString("READ"));
 713     return aValueRef;
 714 }
 715
 716 ORowSetValueDecoratorRef const & ODatabaseMetaDataResultSet::getAlterValue()
 717 {
 718     static ORowSetValueDecoratorRef aValueRef = new ORowSetValueDecorator(OUString("ALTER"));
 719     return aValueRef;
 720 }
 721
 722 ORowSetValueDecoratorRef const & ODatabaseMetaDataResultSet::getDropValue()
 723 {
 724     static ORowSetValueDecoratorRef aValueRef = new ORowSetValueDecorator(OUString("DROP"));
 725     return aValueRef;
 726 }
 727
 728 ORowSetValueDecoratorRef const & ODatabaseMetaDataResultSet::getQuoteValue()
 729 {
 730     static ORowSetValueDecoratorRef aValueRef = new ORowSetValueDecorator(OUString("'"));
 731     return aValueRef;
 732 }
 733
 734 void SAL_CALL ODatabaseMetaDataResultSet::initialize( const Sequence< Any >& _aArguments )
 735 {
 736     if ( _aArguments.getLength() != 2 )
 737         return;
 738
 739     sal_Int32 nResultSetType = 0;
 740     if ( !(_aArguments[0] >>= nResultSetType))
 741         return;
 742
 743     setType(static_cast<MetaDataResultSetType>(nResultSetType));
 744     Sequence< Sequence<Any> > aRows;
 745     if ( !(_aArguments[1] >>= aRows) )
 746         return;
 747
 748     ORows aRowsToSet;
 749     const Sequence<Any>* pRowsIter = aRows.getConstArray();
 750     const Sequence<Any>* pRowsEnd  = pRowsIter + aRows.getLength();
 751     for (; pRowsIter != pRowsEnd;++pRowsIter)
 752     {
 753         ORow aRowToSet;
 754         const Any* pRowIter = pRowsIter->getConstArray();
 755         const Any* pRowEnd = pRowIter + pRowsIter->getLength();
 756         for (; pRowIter != pRowEnd;++pRowIter)
 757         {
 758             ORowSetValueDecoratorRef aValue;
 759             switch( pRowIter->getValueTypeClass() )
 760             {
 761                 case TypeClass_BOOLEAN:
 762                     {
 763                         bool bValue = false;
 764                         *pRowIter >>= bValue;
 765                         aValue = new ORowSetValueDecorator(ORowSetValue(bValue));
 766                     }
 767                     break;
 768                 case TypeClass_BYTE:
 769                     {
 770                         sal_Int8 nValue(0);
 771                         *pRowIter >>= nValue;
 772                         aValue = new ORowSetValueDecorator(ORowSetValue(nValue));
 773                     }
 774                     break;
 775                 case TypeClass_SHORT:
 776                 case TypeClass_UNSIGNED_SHORT:
 777                     {
 778                         sal_Int16 nValue(0);
 779                         *pRowIter >>= nValue;
 780                         aValue = new ORowSetValueDecorator(ORowSetValue(nValue));
 781                     }
 782                     break;
 783                 case TypeClass_LONG:
 784                 case TypeClass_UNSIGNED_LONG:
 785                     {
 786                         sal_Int32 nValue(0);
 787                         *pRowIter >>= nValue;
 788                         aValue = new ORowSetValueDecorator(ORowSetValue(nValue));
 789                     }
 790                     break;
 791                 case TypeClass_HYPER:
 792                 case TypeClass_UNSIGNED_HYPER:
 793                     {
 794                         sal_Int64 nValue(0);
 795                         *pRowIter >>= nValue;
 796                         aValue = new ORowSetValueDecorator(ORowSetValue(nValue));
 797                     }
 798                     break;
 799                 case TypeClass_FLOAT:
 800                     {
 801                         float nValue(0.0);
 802                         *pRowIter >>= nValue;
 803                         aValue = new ORowSetValueDecorator(ORowSetValue(nValue));
 804                     }
 805                     break;
 806                 case TypeClass_DOUBLE:
 807                     {
 808                         double nValue(0.0);
 809                         *pRowIter >>= nValue;
 810                         aValue = new ORowSetValueDecorator(ORowSetValue(nValue));
 811                     }
 812                     break;
 813                 case TypeClass_STRING:
 814                     {
 815                         OUString sValue;
 816                         *pRowIter >>= sValue;
 817                         aValue = new ORowSetValueDecorator(ORowSetValue(sValue));
 818                     }
 819                     break;
 820                 default:
 821                     break;
 822             }
 823             aRowToSet.push_back(aValue);
 824         }
 825         aRowsToSet.push_back(aRowToSet);
 826     } // for (; pRowsIter != pRowsEnd;++pRowsIter
 827     setRows(aRowsToSet);
 828 }
 829 // XServiceInfo
 830
 831
 832     OUString SAL_CALL ODatabaseMetaDataResultSet::getImplementationName(  )
 833     {
 834         return "org.openoffice.comp.helper.DatabaseMetaDataResultSet";
 835     }
 836
 837     sal_Bool SAL_CALL ODatabaseMetaDataResultSet::supportsService( const OUString& _rServiceName )
 838     {
 839         return cppu::supportsService(this, _rServiceName);
 840     }
 841
 842     Sequence< OUString > SAL_CALL ODatabaseMetaDataResultSet::getSupportedServiceNames(  )
 843     {
 844         return Sequence<OUString>{ "com.sun.star.sdbc.ResultSet" };
 845     }
 846
 847 extern "C" SAL_DLLPUBLIC_EXPORT css::uno::XInterface*
 848 connectivity_dbtools_ODatabaseMetaDataResultSet_get_implementation(
 849     css::uno::XComponentContext* , css::uno::Sequence<css::uno::Any> const&)
 850 {
 851     return cppu::acquire(new ODatabaseMetaDataResultSet());
 852 }
 853
 854 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */