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