dbaccess/source/core/api/datacolumn.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 #include "datacolumn.hxx"
  21 #include <com/sun/star/lang/DisposedException.hpp>
  22 #include <com/sun/star/sdbc/XResultSetMetaDataSupplier.hpp>
  23 #include <com/sun/star/sdbc/DataType.hpp>
  24 #include <com/sun/star/sdbc/ColumnValue.hpp>
  25 #include <cppuhelper/typeprovider.hxx>
  26 #include <tools/debug.hxx>
  27 #include "dbastrings.hrc"
  28 #include "apitools.hxx"
  29
  30 using namespace dbaccess;
  31 using namespace ::com::sun::star::sdbc;
  32 using namespace ::com::sun::star::sdb;
  33 using namespace ::com::sun::star::beans;
  34 using namespace ::com::sun::star::uno;
  35 using namespace ::com::sun::star::lang;
  36 using namespace ::com::sun::star::container;
  37 using namespace ::osl;
  38 using namespace ::comphelper;
  39 using namespace ::cppu;
  40
  41 DBG_NAME(ODataColumn)
  42
  43 ODataColumn::ODataColumn(
  44                          const Reference < XResultSetMetaData >& _xMetaData,
  45                          const Reference < XRow >& _xRow,
  46                          const Reference < XRowUpdate >& _xRowUpdate,
  47                          sal_Int32 _nPos,
  48                          const Reference< XDatabaseMetaData >& _rxDBMeta)
  49                      :OResultColumn(_xMetaData, _nPos, _rxDBMeta)
  50                      ,m_xRow(_xRow)
  51                      ,m_xRowUpdate(_xRowUpdate)
  52 {
  53     DBG_CTOR(ODataColumn,NULL);
  54 }
  55
  56 ODataColumn::~ODataColumn()
  57 {
  58     DBG_DTOR(ODataColumn,NULL);
  59 }
  60
  61 // com::sun::star::lang::XTypeProvider
  62 Sequence< Type > ODataColumn::getTypes() throw (RuntimeException)
  63 {
  64     OTypeCollection aTypes(::getCppuType( (const Reference< XColumn > *)0 ),
  65                            ::getCppuType( (const Reference< XColumnUpdate > *)0 ),
  66                            OColumn::getTypes());
  67     return aTypes.getTypes();
  68 }
  69
  70 Sequence< sal_Int8 > ODataColumn::getImplementationId() throw (RuntimeException)
  71 {
  72     static OImplementationId * pId = 0;
  73     if (! pId)
  74     {
  75         MutexGuard aGuard( Mutex::getGlobalMutex() );
  76         if (! pId)
  77         {
  78             static OImplementationId aId;
  79             pId = &aId;
  80         }
  81     }
  82     return pId->getImplementationId();
  83 }
  84
  85 Any SAL_CALL ODataColumn::queryInterface( const Type & _rType ) throw (RuntimeException)
  86 {
  87     Any aReturn = OResultColumn::queryInterface(_rType);
  88     if (!aReturn.hasValue())
  89         aReturn = ::cppu::queryInterface(_rType,
  90             static_cast< XColumn* >(this),
  91             static_cast< XColumnUpdate* >(this)
  92         );
  93     return aReturn;
  94 }
  95
  96 // XServiceInfo
  97 rtl::OUString ODataColumn::getImplementationName(  ) throw(RuntimeException)
  98 {
  99     return rtl::OUString("com.sun.star.sdb.ODataColumn");
 100 }
 101
 102 Sequence< ::rtl::OUString > ODataColumn::getSupportedServiceNames(  ) throw (RuntimeException)
 103 {
 104     Sequence< ::rtl::OUString > aSNS( 3 );
 105     aSNS[0] = SERVICE_SDBCX_COLUMN;
 106     aSNS[1] = SERVICE_SDB_RESULTCOLUMN;
 107     aSNS[2] = SERVICE_SDB_DATACOLUMN;
 108     return aSNS;
 109 }
 110
 111 // OComponentHelper
 112 void ODataColumn::disposing()
 113 {
 114     OResultColumn::disposing();
 115
 116     m_xRow = NULL;
 117     m_xRowUpdate = NULL;
 118 }
 119
 120 // ::com::sun::star::sdb::XColumn
 121 sal_Bool ODataColumn::wasNull(void) throw( SQLException, RuntimeException )
 122 {
 123     MutexGuard aGuard(m_aMutex);
 124     ::connectivity::checkDisposed(!m_xRow.is());
 125
 126     return m_xRow->wasNull();
 127 }
 128
 129 rtl::OUString ODataColumn::getString(void) throw( SQLException, RuntimeException )
 130 {
 131     MutexGuard aGuard(m_aMutex);
 132     ::connectivity::checkDisposed(!m_xRow.is());
 133
 134     return m_xRow->getString(m_nPos);
 135 }
 136
 137 sal_Bool ODataColumn::getBoolean(void) throw( SQLException, RuntimeException )
 138 {
 139     MutexGuard aGuard(m_aMutex);
 140     ::connectivity::checkDisposed(!m_xRow.is());
 141
 142     return m_xRow->getBoolean(m_nPos);
 143 }
 144
 145 sal_Int8 ODataColumn::getByte(void) throw( SQLException, RuntimeException )
 146 {
 147     MutexGuard aGuard(m_aMutex);
 148     ::connectivity::checkDisposed(!m_xRow.is());
 149
 150     return m_xRow->getByte(m_nPos);
 151 }
 152
 153 sal_Int16 ODataColumn::getShort(void) throw( SQLException, RuntimeException )
 154 {
 155     MutexGuard aGuard(m_aMutex);
 156     ::connectivity::checkDisposed(!m_xRow.is());
 157
 158     return m_xRow->getShort(m_nPos);
 159 }
 160
 161 sal_Int32 ODataColumn::getInt(void) throw( SQLException, RuntimeException )
 162 {
 163     MutexGuard aGuard(m_aMutex);
 164     ::connectivity::checkDisposed(!m_xRow.is());
 165
 166     return m_xRow->getInt(m_nPos);
 167 }
 168
 169 sal_Int64 ODataColumn::getLong(void) throw( SQLException, RuntimeException )
 170 {
 171     MutexGuard aGuard(m_aMutex);
 172     ::connectivity::checkDisposed(!m_xRow.is());
 173
 174     return m_xRow->getLong(m_nPos);
 175 }
 176
 177 float ODataColumn::getFloat(void) throw( SQLException, RuntimeException )
 178 {
 179     MutexGuard aGuard(m_aMutex);
 180     ::connectivity::checkDisposed(!m_xRow.is());
 181
 182     return m_xRow->getFloat(m_nPos);
 183 }
 184
 185 double ODataColumn::getDouble(void) throw( SQLException, RuntimeException )
 186 {
 187     MutexGuard aGuard(m_aMutex);
 188     ::connectivity::checkDisposed(!m_xRow.is());
 189
 190     return m_xRow->getDouble(m_nPos);
 191 }
 192
 193 Sequence< sal_Int8 > ODataColumn::getBytes(void) throw( SQLException, RuntimeException )
 194 {
 195     MutexGuard aGuard(m_aMutex);
 196     ::connectivity::checkDisposed(!m_xRow.is());
 197
 198     return m_xRow->getBytes(m_nPos);
 199 }
 200
 201 com::sun::star::util::Date ODataColumn::getDate(void) throw( SQLException, RuntimeException )
 202 {
 203     MutexGuard aGuard(m_aMutex);
 204     ::connectivity::checkDisposed(!m_xRow.is());
 205
 206     return m_xRow->getDate(m_nPos);
 207 }
 208
 209 com::sun::star::util::Time ODataColumn::getTime(void) throw( SQLException, RuntimeException )
 210 {
 211     MutexGuard aGuard(m_aMutex);
 212     ::connectivity::checkDisposed(!m_xRow.is());
 213
 214     return m_xRow->getTime(m_nPos);
 215 }
 216
 217 com::sun::star::util::DateTime ODataColumn::getTimestamp(void) throw( SQLException, RuntimeException )
 218 {
 219     MutexGuard aGuard(m_aMutex);
 220     ::connectivity::checkDisposed(!m_xRow.is());
 221
 222     return m_xRow->getTimestamp(m_nPos);
 223 }
 224
 225 Reference< ::com::sun::star::io::XInputStream >  ODataColumn::getBinaryStream(void) throw( SQLException, RuntimeException )
 226 {
 227     MutexGuard aGuard(m_aMutex);
 228     ::connectivity::checkDisposed(!m_xRow.is());
 229
 230     return m_xRow->getBinaryStream(m_nPos);
 231 }
 232
 233 Reference< ::com::sun::star::io::XInputStream >  ODataColumn::getCharacterStream(void) throw( SQLException, RuntimeException )
 234 {
 235     MutexGuard aGuard(m_aMutex);
 236     ::connectivity::checkDisposed(!m_xRow.is());
 237
 238     return m_xRow->getCharacterStream(m_nPos);
 239 }
 240
 241 Any ODataColumn::getObject(const Reference< ::com::sun::star::container::XNameAccess > & typeMap) throw( SQLException, RuntimeException )
 242 {
 243     MutexGuard aGuard(m_aMutex);
 244     ::connectivity::checkDisposed(!m_xRow.is());
 245
 246     return m_xRow->getObject(m_nPos, typeMap);
 247 }
 248
 249 Reference< XRef >  ODataColumn::getRef(void) throw( SQLException, RuntimeException )
 250 {
 251     MutexGuard aGuard(m_aMutex);
 252     ::connectivity::checkDisposed(!m_xRow.is());
 253
 254     return m_xRow->getRef(m_nPos);
 255 }
 256
 257 Reference< XBlob >  ODataColumn::getBlob(void) throw( SQLException, RuntimeException )
 258 {
 259     MutexGuard aGuard(m_aMutex);
 260     ::connectivity::checkDisposed(!m_xRow.is());
 261
 262     return m_xRow->getBlob(m_nPos);
 263 }
 264
 265 Reference< XClob >  ODataColumn::getClob(void) throw( SQLException, RuntimeException )
 266 {
 267     MutexGuard aGuard(m_aMutex);
 268     ::connectivity::checkDisposed(!m_xRow.is());
 269
 270     return m_xRow->getClob(m_nPos);
 271 }
 272
 273 Reference< XArray >  ODataColumn::getArray(void) throw( SQLException, RuntimeException )
 274 {
 275     MutexGuard aGuard(m_aMutex);
 276     ::connectivity::checkDisposed(!m_xRow.is());
 277
 278     return m_xRow->getArray(m_nPos);
 279 }
 280
 281 // ::com::sun::star::sdb::XColumnUpdate
 282 void ODataColumn::updateNull(void) throw( SQLException, RuntimeException )
 283 {
 284     MutexGuard aGuard( m_aMutex );
 285     ::connectivity::checkDisposed(!m_xRowUpdate.is());
 286
 287     m_xRowUpdate->updateNull(m_nPos);
 288 }
 289
 290 void ODataColumn::updateBoolean(sal_Bool x) throw( SQLException, RuntimeException )
 291 {
 292     MutexGuard aGuard( m_aMutex );
 293     ::connectivity::checkDisposed(!m_xRowUpdate.is());
 294
 295     m_xRowUpdate->updateBoolean(m_nPos, x);
 296 }
 297
 298 void ODataColumn::updateByte(sal_Int8 x) throw( SQLException, RuntimeException )
 299 {
 300     MutexGuard aGuard( m_aMutex );
 301     ::connectivity::checkDisposed(!m_xRowUpdate.is());
 302
 303     m_xRowUpdate->updateByte(m_nPos, x);
 304 }
 305
 306 void ODataColumn::updateShort(sal_Int16 x) throw( SQLException, RuntimeException )
 307 {
 308     MutexGuard aGuard( m_aMutex );
 309     ::connectivity::checkDisposed(!m_xRowUpdate.is());
 310
 311     m_xRowUpdate->updateShort(m_nPos, x);
 312 }
 313
 314 void ODataColumn::updateInt(sal_Int32 x) throw( SQLException, RuntimeException )
 315 {
 316     MutexGuard aGuard( m_aMutex );
 317     ::connectivity::checkDisposed(!m_xRowUpdate.is());
 318
 319     m_xRowUpdate->updateInt(m_nPos, x);
 320 }
 321
 322 void ODataColumn::updateLong(sal_Int64 x) throw( SQLException, RuntimeException )
 323 {
 324     MutexGuard aGuard( m_aMutex );
 325     ::connectivity::checkDisposed(!m_xRowUpdate.is());
 326
 327     m_xRowUpdate->updateLong(m_nPos, x);
 328 }
 329
 330 void ODataColumn::updateFloat(float x) throw( SQLException, RuntimeException )
 331 {
 332     MutexGuard aGuard( m_aMutex );
 333     ::connectivity::checkDisposed(!m_xRowUpdate.is());
 334
 335     m_xRowUpdate->updateFloat(m_nPos, x);
 336 }
 337
 338 void ODataColumn::updateDouble(double x) throw( SQLException, RuntimeException )
 339 {
 340     MutexGuard aGuard( m_aMutex );
 341     ::connectivity::checkDisposed(!m_xRowUpdate.is());
 342
 343     m_xRowUpdate->updateDouble(m_nPos, x);
 344 }
 345
 346 void ODataColumn::updateString(const rtl::OUString& x) throw( SQLException, RuntimeException )
 347 {
 348     MutexGuard aGuard( m_aMutex );
 349     ::connectivity::checkDisposed(!m_xRowUpdate.is());
 350
 351     m_xRowUpdate->updateString(m_nPos, x);
 352 }
 353
 354 void ODataColumn::updateBytes(const Sequence< sal_Int8 >& x) throw( SQLException, RuntimeException )
 355 {
 356     MutexGuard aGuard( m_aMutex );
 357     ::connectivity::checkDisposed(!m_xRowUpdate.is());
 358
 359     m_xRowUpdate->updateBytes(m_nPos, x);
 360 }
 361
 362 void ODataColumn::updateDate(const com::sun::star::util::Date& x) throw( SQLException, RuntimeException )
 363 {
 364     MutexGuard aGuard( m_aMutex );
 365     ::connectivity::checkDisposed(!m_xRowUpdate.is());
 366
 367     m_xRowUpdate->updateDate(m_nPos, x);
 368 }
 369
 370 void ODataColumn::updateTime(const ::com::sun::star::util::Time& x) throw( SQLException, RuntimeException )
 371 {
 372     MutexGuard aGuard( m_aMutex );
 373     ::connectivity::checkDisposed(!m_xRowUpdate.is());
 374
 375     m_xRowUpdate->updateTime(m_nPos, x);
 376 }
 377
 378 void ODataColumn::updateTimestamp(const ::com::sun::star::util::DateTime& x) throw( SQLException, RuntimeException )
 379 {
 380     MutexGuard aGuard( m_aMutex );
 381     ::connectivity::checkDisposed(!m_xRowUpdate.is());
 382
 383     m_xRowUpdate->updateTimestamp(m_nPos, x);
 384 }
 385
 386 void ODataColumn::updateCharacterStream(const Reference< ::com::sun::star::io::XInputStream > & x, sal_Int32 length) throw( SQLException, RuntimeException )
 387 {
 388     MutexGuard aGuard( m_aMutex );
 389     ::connectivity::checkDisposed(!m_xRowUpdate.is());
 390
 391     m_xRowUpdate->updateCharacterStream(m_nPos, x, length);
 392 }
 393
 394 void ODataColumn::updateBinaryStream(const Reference< ::com::sun::star::io::XInputStream > & x, sal_Int32 length) throw( SQLException, RuntimeException )
 395 {
 396     MutexGuard aGuard( m_aMutex );
 397     ::connectivity::checkDisposed(!m_xRowUpdate.is());
 398
 399     m_xRowUpdate->updateBinaryStream(m_nPos, x, length);
 400 }
 401
 402 void ODataColumn::updateNumericObject(const Any& x, sal_Int32 scale) throw( SQLException, RuntimeException )
 403 {
 404     MutexGuard aGuard( m_aMutex );
 405     ::connectivity::checkDisposed(!m_xRowUpdate.is());
 406
 407     m_xRowUpdate->updateNumericObject(m_nPos, x, scale);
 408 }
 409
 410 void ODataColumn::updateObject(const Any& x) throw( SQLException, RuntimeException )
 411 {
 412     MutexGuard aGuard( m_aMutex );
 413     ::connectivity::checkDisposed(!m_xRowUpdate.is());
 414
 415     m_xRowUpdate->updateObject(m_nPos, x);
 416 }
 417 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */