dbaccess/source/core/api/callablestatement.cxx

   1 /*************************************************************************
   2  *
   3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   4  *
   5  * Copyright 2008 by Sun Microsystems, Inc.
   6  *
   7  * OpenOffice.org - a multi-platform office productivity suite
   8  *
   9  * $RCSfile: callablestatement.cxx,v $
  10  * $Revision: 1.8 $
  11  *
  12  * This file is part of OpenOffice.org.
  13  *
  14  * OpenOffice.org is free software: you can redistribute it and/or modify
  15  * it under the terms of the GNU Lesser General Public License version 3
  16  * only, as published by the Free Software Foundation.
  17  *
  18  * OpenOffice.org is distributed in the hope that it will be useful,
  19  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  20  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  21  * GNU Lesser General Public License version 3 for more details
  22  * (a copy is included in the LICENSE file that accompanied this code).
  23  *
  24  * You should have received a copy of the GNU Lesser General Public License
  25  * version 3 along with OpenOffice.org.  If not, see
  26  * <http://www.openoffice.org/license.html>
  27  * for a copy of the LGPLv3 License.
  28  *
  29  ************************************************************************/
  30
  31 // MARKER(update_precomp.py): autogen include statement, do not remove
  32 #include "precompiled_dbaccess.hxx"
  33 #ifndef _DBA_COREAPI_CALLABLESTATEMENT_HXX_
  34 #include <callablestatement.hxx>
  35 #endif
  36 #ifndef _COM_SUN_STAR_LANG_DISPOSEDEXCEPTION_HPP_
  37 #include <com/sun/star/lang/DisposedException.hpp>
  38 #endif
  39 #ifndef _CPPUHELPER_TYPEPROVIDER_HXX_
  40 #include <cppuhelper/typeprovider.hxx>
  41 #endif
  42 #ifndef _COMPHELPER_PROPERTY_HXX_
  43 #include <comphelper/property.hxx>
  44 #endif
  45 #ifndef _TOOLS_DEBUG_HXX //autogen
  46 #include <tools/debug.hxx>
  47 #endif
  48 #ifndef DBACCESS_SHARED_DBASTRINGS_HRC
  49 #include "dbastrings.hrc"
  50 #endif
  51 #include <rtl/logfile.hxx>
  52
  53 using namespace dbaccess;
  54 using namespace ::com::sun::star::sdbc;
  55 using namespace ::com::sun::star::sdbcx;
  56 using namespace ::com::sun::star::beans;
  57 using namespace ::com::sun::star::uno;
  58 using namespace ::com::sun::star::lang;
  59 using namespace ::cppu;
  60 using namespace ::osl;
  61
  62 // com::sun::star::lang::XTypeProvider
  63 //--------------------------------------------------------------------------
  64 Sequence< Type > OCallableStatement::getTypes() throw (RuntimeException)
  65 {
  66     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OCallableStatement::getTypes" );
  67     OTypeCollection aTypes(::getCppuType( (const Reference< XRow > *)0 ),
  68                            ::getCppuType( (const Reference< XOutParameters > *)0 ),
  69                             OPreparedStatement::getTypes() );
  70
  71     return aTypes.getTypes();
  72 }
  73
  74 //--------------------------------------------------------------------------
  75 Sequence< sal_Int8 > OCallableStatement::getImplementationId() throw (RuntimeException)
  76 {
  77     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OCallableStatement::getImplementationId" );
  78     static OImplementationId * pId = 0;
  79     if (! pId)
  80     {
  81         MutexGuard aGuard( Mutex::getGlobalMutex() );
  82         if (! pId)
  83         {
  84             static OImplementationId aId;
  85             pId = &aId;
  86         }
  87     }
  88     return pId->getImplementationId();
  89 }
  90
  91 // com::sun::star::uno::XInterface
  92 //--------------------------------------------------------------------------
  93 Any OCallableStatement::queryInterface( const Type & rType ) throw (RuntimeException)
  94 {
  95     //RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OCallableStatement::queryInterface" );
  96     Any aIface = OPreparedStatement::queryInterface( rType );
  97     if (!aIface.hasValue())
  98         aIface = ::cppu::queryInterface(
  99                     rType,
 100                     static_cast< XRow * >( this ),
 101                     static_cast< XOutParameters * >( this ));
 102     return aIface;
 103 }
 104
 105 //--------------------------------------------------------------------------
 106 void OCallableStatement::acquire() throw ()
 107 {
 108     OPreparedStatement::acquire();
 109 }
 110
 111 //--------------------------------------------------------------------------
 112 void OCallableStatement::release() throw ()
 113 {
 114     OPreparedStatement::release();
 115 }
 116
 117 // XServiceInfo
 118 //------------------------------------------------------------------------------
 119 rtl::OUString OCallableStatement::getImplementationName(  ) throw(RuntimeException)
 120 {
 121     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OCallableStatement::getImplementationName" );
 122     return rtl::OUString::createFromAscii("com.sun.star.sdb.OCallableStatement");
 123 }
 124
 125 //------------------------------------------------------------------------------
 126 Sequence< ::rtl::OUString > OCallableStatement::getSupportedServiceNames(  ) throw (RuntimeException)
 127 {
 128     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OCallableStatement::getSupportedServiceNames" );
 129     Sequence< ::rtl::OUString > aSNS( 2 );
 130     aSNS.getArray()[0] = SERVICE_SDBC_CALLABLESTATEMENT;
 131     aSNS.getArray()[1] = SERVICE_SDB_CALLABLESTATEMENT;
 132     return aSNS;
 133 }
 134
 135 // XOutParameters
 136 //------------------------------------------------------------------------------
 137 void SAL_CALL OCallableStatement::registerOutParameter( sal_Int32 parameterIndex, sal_Int32 sqlType, const ::rtl::OUString& typeName ) throw(SQLException, RuntimeException)
 138 {
 139     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OCallableStatement::registerOutParameter" );
 140     MutexGuard aGuard(m_aMutex);
 141
 142     ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
 143
 144
 145     Reference< XOutParameters >(m_xAggregateAsSet, UNO_QUERY)->registerOutParameter( parameterIndex, sqlType, typeName );
 146 }
 147
 148 //------------------------------------------------------------------------------
 149 void SAL_CALL OCallableStatement::registerNumericOutParameter( sal_Int32 parameterIndex, sal_Int32 sqlType, sal_Int32 scale ) throw(SQLException, RuntimeException)
 150 {
 151     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OCallableStatement::registerNumericOutParameter" );
 152     MutexGuard aGuard(m_aMutex);
 153     ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
 154
 155     Reference< XOutParameters >(m_xAggregateAsSet, UNO_QUERY)->registerNumericOutParameter( parameterIndex, sqlType, scale );
 156 }
 157
 158 // XRow
 159 //------------------------------------------------------------------------------
 160 sal_Bool SAL_CALL OCallableStatement::wasNull(  ) throw(SQLException, RuntimeException)
 161 {
 162     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OCallableStatement::wasNull" );
 163     MutexGuard aGuard(m_aMutex);
 164     ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
 165
 166     return Reference< XRow >(m_xAggregateAsSet, UNO_QUERY)->wasNull();
 167 }
 168
 169 //------------------------------------------------------------------------------
 170 ::rtl::OUString SAL_CALL OCallableStatement::getString( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
 171 {
 172     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OCallableStatement::getString" );
 173     MutexGuard aGuard(m_aMutex);
 174     ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
 175
 176     return Reference< XRow >(m_xAggregateAsSet, UNO_QUERY)->getString( columnIndex );
 177 }
 178
 179 //------------------------------------------------------------------------------
 180 sal_Bool SAL_CALL OCallableStatement::getBoolean( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
 181 {
 182     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OCallableStatement::getBoolean" );
 183     MutexGuard aGuard(m_aMutex);
 184     ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
 185
 186     return Reference< XRow >(m_xAggregateAsSet, UNO_QUERY)->getBoolean( columnIndex );
 187 }
 188
 189 //------------------------------------------------------------------------------
 190 sal_Int8 SAL_CALL OCallableStatement::getByte( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
 191 {
 192     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OCallableStatement::getByte" );
 193     MutexGuard aGuard(m_aMutex);
 194     ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
 195
 196     return Reference< XRow >(m_xAggregateAsSet, UNO_QUERY)->getByte( columnIndex );
 197 }
 198
 199 //------------------------------------------------------------------------------
 200 sal_Int16 SAL_CALL OCallableStatement::getShort( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
 201 {
 202     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OCallableStatement::getShort" );
 203     MutexGuard aGuard(m_aMutex);
 204     ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
 205     return Reference< XRow >(m_xAggregateAsSet, UNO_QUERY)->getShort( columnIndex );
 206 }
 207
 208 //------------------------------------------------------------------------------
 209 sal_Int32 SAL_CALL OCallableStatement::getInt( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
 210 {
 211     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OCallableStatement::getInt" );
 212     MutexGuard aGuard(m_aMutex);
 213     ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
 214     return Reference< XRow >(m_xAggregateAsSet, UNO_QUERY)->getInt( columnIndex );
 215 }
 216
 217 //------------------------------------------------------------------------------
 218 sal_Int64 SAL_CALL OCallableStatement::getLong( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
 219 {
 220     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OCallableStatement::getLong" );
 221     MutexGuard aGuard(m_aMutex);
 222     ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
 223     return Reference< XRow >(m_xAggregateAsSet, UNO_QUERY)->getLong( columnIndex );
 224 }
 225
 226 //------------------------------------------------------------------------------
 227 float SAL_CALL OCallableStatement::getFloat( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
 228 {
 229     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OCallableStatement::getFloat" );
 230     MutexGuard aGuard(m_aMutex);
 231     ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
 232     return Reference< XRow >(m_xAggregateAsSet, UNO_QUERY)->getFloat( columnIndex );
 233 }
 234
 235 //------------------------------------------------------------------------------
 236 double SAL_CALL OCallableStatement::getDouble( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
 237 {
 238     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OCallableStatement::getDouble" );
 239     MutexGuard aGuard(m_aMutex);
 240     ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
 241     return Reference< XRow >(m_xAggregateAsSet, UNO_QUERY)->getDouble( columnIndex );
 242 }
 243
 244 //------------------------------------------------------------------------------
 245 Sequence< sal_Int8 > SAL_CALL OCallableStatement::getBytes( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
 246 {
 247     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OCallableStatement::getBytes" );
 248     MutexGuard aGuard(m_aMutex);
 249     ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
 250     return Reference< XRow >(m_xAggregateAsSet, UNO_QUERY)->getBytes( columnIndex );
 251 }
 252
 253 //------------------------------------------------------------------------------
 254 ::com::sun::star::util::Date SAL_CALL OCallableStatement::getDate( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
 255 {
 256     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OCallableStatement::getDate" );
 257     MutexGuard aGuard(m_aMutex);
 258     ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
 259     return Reference< XRow >(m_xAggregateAsSet, UNO_QUERY)->getDate( columnIndex );
 260 }
 261
 262 //------------------------------------------------------------------------------
 263 ::com::sun::star::util::Time SAL_CALL OCallableStatement::getTime( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
 264 {
 265     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OCallableStatement::getTime" );
 266     MutexGuard aGuard(m_aMutex);
 267     ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
 268     return Reference< XRow >(m_xAggregateAsSet, UNO_QUERY)->getTime( columnIndex );
 269 }
 270
 271 //------------------------------------------------------------------------------
 272 ::com::sun::star::util::DateTime SAL_CALL OCallableStatement::getTimestamp( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
 273 {
 274     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OCallableStatement::getTimestamp" );
 275     MutexGuard aGuard(m_aMutex);
 276     ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
 277
 278     return Reference< XRow >(m_xAggregateAsSet, UNO_QUERY)->getTimestamp( columnIndex );
 279 }
 280
 281 //------------------------------------------------------------------------------
 282 Reference< ::com::sun::star::io::XInputStream > SAL_CALL OCallableStatement::getBinaryStream( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
 283 {
 284     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OCallableStatement::getBinaryStream" );
 285     MutexGuard aGuard(m_aMutex);
 286     ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
 287
 288     return Reference< XRow >(m_xAggregateAsSet, UNO_QUERY)->getBinaryStream( columnIndex );
 289 }
 290
 291 //------------------------------------------------------------------------------
 292 Reference< ::com::sun::star::io::XInputStream > SAL_CALL OCallableStatement::getCharacterStream( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
 293 {
 294     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OCallableStatement::getCharacterStream" );
 295     MutexGuard aGuard(m_aMutex);
 296     ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
 297
 298     return Reference< XRow >(m_xAggregateAsSet, UNO_QUERY)->getCharacterStream( columnIndex );
 299 }
 300
 301 //------------------------------------------------------------------------------
 302 Any SAL_CALL OCallableStatement::getObject( sal_Int32 columnIndex, const Reference< ::com::sun::star::container::XNameAccess >& typeMap ) throw(SQLException, RuntimeException)
 303 {
 304     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OCallableStatement::getObject" );
 305     MutexGuard aGuard(m_aMutex);
 306     ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
 307
 308     return Reference< XRow >(m_xAggregateAsSet, UNO_QUERY)->getObject( columnIndex, typeMap );
 309 }
 310
 311 //------------------------------------------------------------------------------
 312 Reference< XRef > SAL_CALL OCallableStatement::getRef( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
 313 {
 314     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OCallableStatement::getRef" );
 315     MutexGuard aGuard(m_aMutex);
 316     ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
 317     return Reference< XRow >(m_xAggregateAsSet, UNO_QUERY)->getRef( columnIndex );
 318 }
 319
 320 //------------------------------------------------------------------------------
 321 Reference< XBlob > SAL_CALL OCallableStatement::getBlob( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
 322 {
 323     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OCallableStatement::getBlob" );
 324     MutexGuard aGuard(m_aMutex);
 325     ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
 326     return Reference< XRow >(m_xAggregateAsSet, UNO_QUERY)->getBlob( columnIndex );
 327 }
 328
 329 //------------------------------------------------------------------------------
 330 Reference< XClob > SAL_CALL OCallableStatement::getClob( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
 331 {
 332     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OCallableStatement::getClob" );
 333     MutexGuard aGuard(m_aMutex);
 334     ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
 335     return Reference< XRow >(m_xAggregateAsSet, UNO_QUERY)->getClob( columnIndex );
 336 }
 337
 338 //------------------------------------------------------------------------------
 339 Reference< XArray > SAL_CALL OCallableStatement::getArray( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
 340 {
 341     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OCallableStatement::getArray" );
 342     MutexGuard aGuard(m_aMutex);
 343     ::connectivity::checkDisposed(OComponentHelper::rBHelper.bDisposed);
 344     return Reference< XRow >(m_xAggregateAsSet, UNO_QUERY)->getArray( columnIndex );
 345 }
 346
 347