connectivity/source/drivers/ado/ACallableStatement.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: ACallableStatement.cxx,v $
  10  * $Revision: 1.10 $
  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_connectivity.hxx"
  33 #include "ado/ACallableStatement.hxx"
  34 #include <connectivity/dbexception.hxx>
  35
  36 using namespace connectivity::ado;
  37 using namespace com::sun::star::uno;
  38 using namespace com::sun::star::lang;
  39 using namespace com::sun::star::beans;
  40 using namespace com::sun::star::sdbc;
  41 using namespace com::sun::star::container;
  42 using namespace com::sun::star::lang;
  43
  44 IMPLEMENT_SERVICE_INFO(OCallableStatement,"com.sun.star.sdbcx.ACallableStatement","com.sun.star.sdbc.CallableStatement");
  45
  46 #define GET_PARAM()                                                                                                     \
  47     ADOParameter* pParam = NULL;                                                                        \
  48     m_pParameters->get_Item(OLEVariant(sal_Int32(columnIndex-1)),&pParam);              \
  49     if(pParam)                                                                                                          \
  50         pParam->get_Value(&m_aValue);
  51 //**************************************************************
  52 //************ Class: java.sql.CallableStatement
  53 //**************************************************************
  54 OCallableStatement::OCallableStatement( OConnection* _pConnection,const OTypeInfoMap& _TypeInfo,const ::rtl::OUString& sql )
  55                 : OPreparedStatement( _pConnection, _TypeInfo, sql )
  56 {
  57     m_Command.put_CommandType(adCmdStoredProc);
  58 }
  59 // -------------------------------------------------------------------------
  60
  61 Any SAL_CALL OCallableStatement::queryInterface( const Type & rType ) throw(RuntimeException)
  62 {
  63     Any aRet = OPreparedStatement::queryInterface(rType);
  64     return aRet.hasValue() ? aRet : ::cppu::queryInterface(rType,static_cast< XRow*>(this));
  65 }
  66 // -------------------------------------------------------------------------
  67
  68
  69 sal_Bool SAL_CALL OCallableStatement::wasNull(  ) throw(SQLException, RuntimeException)
  70 {
  71     return m_aValue.isNull();
  72 }
  73 // -------------------------------------------------------------------------
  74
  75 sal_Bool SAL_CALL OCallableStatement::getBoolean( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
  76 {
  77     GET_PARAM()
  78     return m_aValue;
  79 }
  80 // -------------------------------------------------------------------------
  81 sal_Int8 SAL_CALL OCallableStatement::getByte( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
  82 {
  83     GET_PARAM()
  84     return m_aValue;
  85 }
  86 // -------------------------------------------------------------------------
  87 Sequence< sal_Int8 > SAL_CALL OCallableStatement::getBytes( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
  88 {
  89     GET_PARAM()
  90     return m_aValue;
  91 }
  92 // -------------------------------------------------------------------------
  93 ::com::sun::star::util::Date SAL_CALL OCallableStatement::getDate( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
  94 {
  95     GET_PARAM()
  96     return m_aValue;
  97 }
  98 // -------------------------------------------------------------------------
  99 double SAL_CALL OCallableStatement::getDouble( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
 100 {
 101     GET_PARAM()
 102     return m_aValue;
 103 }
 104 // -------------------------------------------------------------------------
 105
 106 float SAL_CALL OCallableStatement::getFloat( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
 107 {
 108     GET_PARAM()
 109     return m_aValue;
 110 }
 111 // -------------------------------------------------------------------------
 112
 113 sal_Int32 SAL_CALL OCallableStatement::getInt( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
 114 {
 115     GET_PARAM()
 116     return m_aValue;
 117 }
 118 // -------------------------------------------------------------------------
 119
 120 sal_Int64 SAL_CALL OCallableStatement::getLong( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
 121 {
 122     GET_PARAM()
 123     return (sal_Int64)m_aValue.getCurrency().int64;
 124 }
 125 // -------------------------------------------------------------------------
 126
 127 Any SAL_CALL OCallableStatement::getObject( sal_Int32 /*columnIndex*/, const Reference< ::com::sun::star::container::XNameAccess >& /*typeMap*/ ) throw(SQLException, RuntimeException)
 128 {
 129     ::dbtools::throwFeatureNotImplementedException( "XRow::getObject", *this );
 130     return Any();
 131 }
 132 // -------------------------------------------------------------------------
 133
 134 sal_Int16 SAL_CALL OCallableStatement::getShort( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
 135 {
 136     GET_PARAM()
 137     return m_aValue;
 138 }
 139 // -------------------------------------------------------------------------
 140
 141 ::rtl::OUString SAL_CALL OCallableStatement::getString( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
 142 {
 143     GET_PARAM()
 144     return m_aValue;
 145 }
 146 // -------------------------------------------------------------------------
 147
 148  ::com::sun::star::util::Time SAL_CALL OCallableStatement::getTime( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
 149 {
 150     GET_PARAM()
 151     return m_aValue;
 152 }
 153 // -------------------------------------------------------------------------
 154
 155  ::com::sun::star::util::DateTime SAL_CALL OCallableStatement::getTimestamp( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
 156 {
 157     GET_PARAM()
 158     return m_aValue;
 159 }
 160 // -------------------------------------------------------------------------
 161
 162 void SAL_CALL OCallableStatement::registerOutParameter( sal_Int32 parameterIndex, sal_Int32 sqlType, const ::rtl::OUString& /*typeName*/ ) throw(SQLException, RuntimeException)
 163 {
 164     ADOParameter* pParam = NULL;
 165     m_pParameters->get_Item(OLEVariant(sal_Int32(parameterIndex-1)),&pParam);
 166     if(pParam)
 167     {
 168         pParam->put_Type(ADOS::MapJdbc2ADOType(sqlType,m_pConnection->getEngineType()));
 169         pParam->put_Direction(adParamOutput);
 170     }
 171 }
 172 // -------------------------------------------------------------------------
 173 void SAL_CALL OCallableStatement::registerNumericOutParameter( sal_Int32 parameterIndex, sal_Int32 sqlType, sal_Int32 scale ) throw(SQLException, RuntimeException)
 174 {
 175     ADOParameter* pParam = NULL;
 176     m_pParameters->get_Item(OLEVariant(sal_Int32(parameterIndex-1)),&pParam);
 177     if(pParam)
 178     {
 179         pParam->put_Type(ADOS::MapJdbc2ADOType(sqlType,m_pConnection->getEngineType()));
 180         pParam->put_Direction(adParamOutput);
 181         pParam->put_NumericScale((sal_Int8)scale);
 182     }
 183 }
 184 // -------------------------------------------------------------------------
 185
 186
 187 Reference< ::com::sun::star::io::XInputStream > SAL_CALL OCallableStatement::getBinaryStream( sal_Int32 /*columnIndex*/ ) throw(SQLException, RuntimeException)
 188 {
 189     ::dbtools::throwFeatureNotImplementedException( "XRow::getBinaryStream", *this );
 190     return NULL;
 191 }
 192 // -------------------------------------------------------------------------
 193 Reference< ::com::sun::star::io::XInputStream > SAL_CALL OCallableStatement::getCharacterStream( sal_Int32 /*columnIndex*/ ) throw(SQLException, RuntimeException)
 194 {
 195     ::dbtools::throwFeatureNotImplementedException( "XRow::getCharacterStream", *this );
 196     return NULL;
 197 }
 198 // -------------------------------------------------------------------------
 199
 200 Reference< XArray > SAL_CALL OCallableStatement::getArray( sal_Int32 /*columnIndex*/ ) throw(SQLException, RuntimeException)
 201 {
 202     ::dbtools::throwFeatureNotImplementedException( "XRow::getArray", *this );
 203     return NULL;
 204 }
 205 // -------------------------------------------------------------------------
 206
 207 Reference< XClob > SAL_CALL OCallableStatement::getClob( sal_Int32 /*columnIndex*/ ) throw(SQLException, RuntimeException)
 208 {
 209     ::dbtools::throwFeatureNotImplementedException( "XRow::getClob", *this );
 210     return NULL;
 211 }
 212 // -------------------------------------------------------------------------
 213 Reference< XBlob > SAL_CALL OCallableStatement::getBlob( sal_Int32 /*columnIndex*/ ) throw(SQLException, RuntimeException)
 214 {
 215     ::dbtools::throwFeatureNotImplementedException( "XRow::getBlob", *this );
 216     return NULL;
 217 }
 218 // -------------------------------------------------------------------------
 219
 220 Reference< XRef > SAL_CALL OCallableStatement::getRef( sal_Int32 /*columnIndex*/) throw(SQLException, RuntimeException)
 221 {
 222     ::dbtools::throwFeatureNotImplementedException( "XRow::getRef", *this );
 223     return NULL;
 224 }
 225 // -------------------------------------------------------------------------
 226 // -----------------------------------------------------------------------------
 227 void SAL_CALL OCallableStatement::acquire() throw()
 228 {
 229     OPreparedStatement::acquire();
 230 }
 231 // -----------------------------------------------------------------------------
 232 void SAL_CALL OCallableStatement::release() throw()
 233 {
 234     OPreparedStatement::release();
 235 }
 236 // -----------------------------------------------------------------------------
 237
 238