connectivity/source/drivers/kab/KPreparedStatement.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: KPreparedStatement.cxx,v $
  10  * $Revision: 1.6.56.2 $
  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
  34 #include "KPreparedStatement.hxx"
  35 #include "propertyids.hxx"
  36 #include <connectivity/dbexception.hxx>
  37 #include <connectivity/dbtools.hxx>
  38 #include "resource/kab_res.hrc"
  39 #include "resource/sharedresources.hxx"
  40
  41 using namespace connectivity::kab;
  42 using namespace com::sun::star::uno;
  43 using namespace com::sun::star::lang;
  44 using namespace com::sun::star::sdbc;
  45 using namespace com::sun::star::util;
  46
  47 IMPLEMENT_SERVICE_INFO(KabPreparedStatement, "com.sun.star.sdbc.drivers.KabPreparedStatement", "com.sun.star.sdbc.PreparedStatement");
  48 // -------------------------------------------------------------------------
  49 void KabPreparedStatement::checkAndResizeParameters(sal_Int32 nParams) throw(SQLException)
  50 {
  51     if ( !m_aParameterRow.isValid() )
  52         m_aParameterRow = new OValueVector();
  53
  54     if (nParams < 1)
  55         ::dbtools::throwInvalidIndexException(*(KabPreparedStatement *) this,Any());
  56
  57     if (nParams >= (sal_Int32) (m_aParameterRow->get()).size())
  58         (m_aParameterRow->get()).resize(nParams);
  59 }
  60 // -------------------------------------------------------------------------
  61 void KabPreparedStatement::setKabFields() const throw(SQLException)
  62 {
  63     ::vos::ORef<connectivity::OSQLColumns> xColumns;    // selected columns
  64
  65     xColumns = m_aSQLIterator.getSelectColumns();
  66     if (!xColumns.isValid())
  67     {
  68         ::connectivity::SharedResources aResources;
  69         const ::rtl::OUString sError( aResources.getResourceString(
  70                 STR_INVALID_COLUMN_SELECTION
  71              ) );
  72         ::dbtools::throwGenericSQLException(sError,NULL);
  73     }
  74     m_xMetaData->setKabFields(xColumns);
  75 }
  76 // -------------------------------------------------------------------------
  77 void KabPreparedStatement::resetParameters() const throw(SQLException)
  78 {
  79     m_nParameterIndex = 0;
  80 }
  81 // -------------------------------------------------------------------------
  82 void KabPreparedStatement::getNextParameter(::rtl::OUString &rParameter) const throw(SQLException)
  83 {
  84     if (m_nParameterIndex >= (sal_Int32) (m_aParameterRow->get()).size())
  85     {
  86         ::connectivity::SharedResources aResources;
  87         const ::rtl::OUString sError( aResources.getResourceString(
  88                 STR_INVALID_PARA_COUNT
  89              ) );
  90         ::dbtools::throwGenericSQLException(sError,*(KabPreparedStatement *) this);
  91     } // if (m_nParameterIndex >= (sal_Int32) (*m_aParameterRow).size())
  92
  93     rParameter = (m_aParameterRow->get())[m_nParameterIndex];
  94
  95     m_nParameterIndex++;
  96 }
  97 // -------------------------------------------------------------------------
  98 KabPreparedStatement::KabPreparedStatement(
  99     KabConnection* _pConnection,
 100     const ::rtl::OUString& sql)
 101     : KabPreparedStatement_BASE(_pConnection),
 102       m_sSqlStatement(sql),
 103       m_bPrepared(sal_False),
 104       m_nParameterIndex(0),
 105       m_aParameterRow()
 106 {
 107 }
 108 // -------------------------------------------------------------------------
 109 KabPreparedStatement::~KabPreparedStatement()
 110 {
 111 }
 112 // -------------------------------------------------------------------------
 113 void KabPreparedStatement::disposing()
 114 {
 115     KabPreparedStatement_BASE::disposing();
 116
 117     if (m_aParameterRow.isValid())
 118     {
 119         m_aParameterRow->get().clear();
 120         m_aParameterRow = NULL;
 121     }
 122 }
 123 // -------------------------------------------------------------------------
 124 Reference< XResultSetMetaData > SAL_CALL KabPreparedStatement::getMetaData() throw(SQLException, RuntimeException)
 125 {
 126     ::osl::MutexGuard aGuard( m_aMutex );
 127     checkDisposed(KabCommonStatement_BASE::rBHelper.bDisposed);
 128
 129     if (!m_xMetaData.is())
 130     {
 131         m_xMetaData = new KabResultSetMetaData(getOwnConnection());
 132         setKabFields();
 133     }
 134     Reference< XResultSetMetaData > xMetaData = m_xMetaData.get();
 135     return xMetaData;
 136 }
 137 // -------------------------------------------------------------------------
 138 void SAL_CALL KabPreparedStatement::close() throw(SQLException, RuntimeException)
 139 {
 140     ::osl::MutexGuard aGuard( m_aMutex );
 141     checkDisposed(KabCommonStatement_BASE::rBHelper.bDisposed);
 142
 143     // Reset last warning message
 144     try {
 145         clearWarnings ();
 146         KabCommonStatement::close();
 147     }
 148     catch (SQLException &) {
 149         // If we get an error, ignore
 150     }
 151
 152     // Remove this Statement object from the Connection object's
 153     // list
 154 }
 155 // -------------------------------------------------------------------------
 156 sal_Bool SAL_CALL KabPreparedStatement::execute() throw(SQLException, RuntimeException)
 157 {
 158     ::osl::MutexGuard aGuard( m_aMutex );
 159     checkDisposed(KabCommonStatement_BASE::rBHelper.bDisposed);
 160
 161     Reference< XResultSet> xRS = KabCommonStatement::executeQuery(m_sSqlStatement);
 162
 163     return xRS.is();
 164 }
 165 // -------------------------------------------------------------------------
 166 sal_Int32 SAL_CALL KabPreparedStatement::executeUpdate() throw(SQLException, RuntimeException)
 167 {
 168     ::osl::MutexGuard aGuard( m_aMutex );
 169     checkDisposed(KabCommonStatement_BASE::rBHelper.bDisposed);
 170
 171     // same as in statement with the difference that this statement also can contain parameter
 172     return 0;
 173 }
 174 // -------------------------------------------------------------------------
 175 Reference< XConnection > SAL_CALL KabPreparedStatement::getConnection() throw(SQLException, RuntimeException)
 176 {
 177     ::osl::MutexGuard aGuard( m_aMutex );
 178     checkDisposed(KabCommonStatement_BASE::rBHelper.bDisposed);
 179
 180     return (Reference< XConnection >) m_pConnection;
 181 }
 182 // -------------------------------------------------------------------------
 183 Reference< XResultSet > SAL_CALL KabPreparedStatement::executeQuery() throw(SQLException, RuntimeException)
 184 {
 185     ::osl::MutexGuard aGuard( m_aMutex );
 186     checkDisposed(KabCommonStatement_BASE::rBHelper.bDisposed);
 187
 188     Reference< XResultSet > rs = KabCommonStatement::executeQuery(m_sSqlStatement);
 189
 190     return rs;
 191 }
 192 // -------------------------------------------------------------------------
 193 void SAL_CALL KabPreparedStatement::setNull(sal_Int32 parameterIndex, sal_Int32) throw(SQLException, RuntimeException)
 194 {
 195     ::osl::MutexGuard aGuard( m_aMutex );
 196     checkDisposed(KabCommonStatement_BASE::rBHelper.bDisposed);
 197
 198     checkAndResizeParameters(parameterIndex);
 199
 200     (m_aParameterRow->get())[parameterIndex - 1].setNull();
 201 }
 202 // -------------------------------------------------------------------------
 203 void SAL_CALL KabPreparedStatement::setObjectNull(sal_Int32, sal_Int32, const ::rtl::OUString&) throw(SQLException, RuntimeException)
 204 {
 205
 206
 207
 208 ::dbtools::throwFunctionNotSupportedException("setObjectNull", NULL);
 209 }
 210 // -------------------------------------------------------------------------
 211 void SAL_CALL KabPreparedStatement::setBoolean(sal_Int32, sal_Bool) throw(SQLException, RuntimeException)
 212 {
 213
 214
 215
 216 ::dbtools::throwFunctionNotSupportedException("setBoolean", NULL);
 217 }
 218 // -------------------------------------------------------------------------
 219 void SAL_CALL KabPreparedStatement::setByte(sal_Int32, sal_Int8) throw(SQLException, RuntimeException)
 220 {
 221
 222
 223
 224 ::dbtools::throwFunctionNotSupportedException("setByte", NULL);
 225 }
 226 // -------------------------------------------------------------------------
 227 void SAL_CALL KabPreparedStatement::setShort(sal_Int32, sal_Int16) throw(SQLException, RuntimeException)
 228 {
 229
 230
 231
 232 ::dbtools::throwFunctionNotSupportedException("setShort", NULL);
 233 }
 234 // -------------------------------------------------------------------------
 235 void SAL_CALL KabPreparedStatement::setInt(sal_Int32, sal_Int32) throw(SQLException, RuntimeException)
 236 {
 237
 238
 239
 240 ::dbtools::throwFunctionNotSupportedException("setInt", NULL);
 241 }
 242 // -------------------------------------------------------------------------
 243 void SAL_CALL KabPreparedStatement::setLong(sal_Int32, sal_Int64) throw(SQLException, RuntimeException)
 244 {
 245
 246
 247
 248 ::dbtools::throwFunctionNotSupportedException("", NULL);
 249 }
 250 // -------------------------------------------------------------------------
 251 void SAL_CALL KabPreparedStatement::setFloat(sal_Int32, float) throw(SQLException, RuntimeException)
 252 {
 253
 254
 255
 256 ::dbtools::throwFunctionNotSupportedException("setFloat", NULL);
 257 }
 258 // -------------------------------------------------------------------------
 259 void SAL_CALL KabPreparedStatement::setDouble(sal_Int32, double) throw(SQLException, RuntimeException)
 260 {
 261
 262
 263
 264 ::dbtools::throwFunctionNotSupportedException("setDouble", NULL);
 265 }
 266 // -------------------------------------------------------------------------
 267 void SAL_CALL KabPreparedStatement::setString(sal_Int32 parameterIndex, const ::rtl::OUString &x) throw(SQLException, RuntimeException)
 268 {
 269     ::osl::MutexGuard aGuard( m_aMutex );
 270     checkDisposed(KabCommonStatement_BASE::rBHelper.bDisposed);
 271
 272     checkAndResizeParameters(parameterIndex);
 273
 274     (m_aParameterRow->get())[parameterIndex - 1] = x;
 275 }
 276 // -------------------------------------------------------------------------
 277 void SAL_CALL KabPreparedStatement::setBytes(sal_Int32, const Sequence< sal_Int8 >&) throw(SQLException, RuntimeException)
 278 {
 279
 280
 281
 282 ::dbtools::throwFunctionNotSupportedException("setBytes", NULL);
 283 }
 284 // -------------------------------------------------------------------------
 285 void SAL_CALL KabPreparedStatement::setDate(sal_Int32, const Date&) throw(SQLException, RuntimeException)
 286 {
 287
 288
 289
 290 ::dbtools::throwFunctionNotSupportedException("setDate", NULL);
 291 }
 292 // -------------------------------------------------------------------------
 293 void SAL_CALL KabPreparedStatement::setTime(sal_Int32, const Time&) throw(SQLException, RuntimeException)
 294 {
 295
 296
 297
 298 ::dbtools::throwFunctionNotSupportedException("setTime", NULL);
 299 }
 300 // -------------------------------------------------------------------------
 301 void SAL_CALL KabPreparedStatement::setTimestamp(sal_Int32, const DateTime&) throw(SQLException, RuntimeException)
 302 {
 303
 304
 305
 306 ::dbtools::throwFunctionNotSupportedException("setTimestamp", NULL);
 307 }
 308 // -------------------------------------------------------------------------
 309 void SAL_CALL KabPreparedStatement::setBinaryStream(sal_Int32, const Reference< ::com::sun::star::io::XInputStream >&, sal_Int32) throw(SQLException, RuntimeException)
 310 {
 311
 312
 313
 314 ::dbtools::throwFunctionNotSupportedException("setBinaryStream", NULL);
 315 }
 316 // -------------------------------------------------------------------------
 317 void SAL_CALL KabPreparedStatement::setCharacterStream(sal_Int32, const Reference< ::com::sun::star::io::XInputStream >&, sal_Int32) throw(SQLException, RuntimeException)
 318 {
 319
 320
 321
 322 ::dbtools::throwFunctionNotSupportedException("setCharacterStream", NULL);
 323 }
 324 // -------------------------------------------------------------------------
 325 void SAL_CALL KabPreparedStatement::setObject(sal_Int32 parameterIndex, const Any& x) throw(SQLException, RuntimeException)
 326 {
 327     if(!::dbtools::implSetObject(this,parameterIndex,x))
 328     {
 329         throw SQLException();
 330     }
 331 }
 332 // -------------------------------------------------------------------------
 333 void SAL_CALL KabPreparedStatement::setObjectWithInfo(sal_Int32, const Any&, sal_Int32, sal_Int32) throw(SQLException, RuntimeException)
 334 {
 335
 336
 337
 338 ::dbtools::throwFunctionNotSupportedException("setObjectWithInfo", NULL);
 339 }
 340 // -------------------------------------------------------------------------
 341 void SAL_CALL KabPreparedStatement::setRef(sal_Int32, const Reference< XRef >&) throw(SQLException, RuntimeException)
 342 {
 343
 344
 345
 346 ::dbtools::throwFunctionNotSupportedException("setRef", NULL);
 347 }
 348 // -------------------------------------------------------------------------
 349 void SAL_CALL KabPreparedStatement::setBlob(sal_Int32, const Reference< XBlob >&) throw(SQLException, RuntimeException)
 350 {
 351
 352
 353
 354 ::dbtools::throwFunctionNotSupportedException("setBlob", NULL);
 355 }
 356 // -------------------------------------------------------------------------
 357 void SAL_CALL KabPreparedStatement::setClob(sal_Int32, const Reference< XClob >&) throw(SQLException, RuntimeException)
 358 {
 359
 360
 361
 362 ::dbtools::throwFunctionNotSupportedException("setClob", NULL);
 363 }
 364 // -------------------------------------------------------------------------
 365 void SAL_CALL KabPreparedStatement::setArray(sal_Int32, const Reference< XArray >&) throw(SQLException, RuntimeException)
 366 {
 367
 368
 369
 370 ::dbtools::throwFunctionNotSupportedException("setArray", NULL);
 371 }
 372 // -------------------------------------------------------------------------
 373 void SAL_CALL KabPreparedStatement::clearParameters() throw(SQLException, RuntimeException)
 374 {
 375 ::dbtools::throwFunctionNotSupportedException("clearParameters", NULL);
 376 }
 377 // -------------------------------------------------------------------------
 378 void KabPreparedStatement::setFastPropertyValue_NoBroadcast(sal_Int32 nHandle,const Any& rValue) throw (Exception)
 379 {
 380     switch (nHandle)
 381     {
 382         case PROPERTY_ID_RESULTSETCONCURRENCY:
 383             break;
 384         case PROPERTY_ID_RESULTSETTYPE:
 385             break;
 386         case PROPERTY_ID_FETCHDIRECTION:
 387             break;
 388         case PROPERTY_ID_USEBOOKMARKS:
 389             break;
 390         default:
 391             KabCommonStatement::setFastPropertyValue_NoBroadcast(nHandle,rValue);
 392     }
 393 }