connectivity/source/drivers/file/FPreparedStatement.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: FPreparedStatement.cxx,v $
  10  * $Revision: 1.42.56.1 $
  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 <stdio.h>
  35 #include "connectivity/sdbcx/VColumn.hxx"
  36 #include <osl/diagnose.h>
  37 #include "file/FPreparedStatement.hxx"
  38 #include <com/sun/star/sdbc/DataType.hpp>
  39 #include "file/FResultSetMetaData.hxx"
  40 #include <cppuhelper/typeprovider.hxx>
  41 #include <comphelper/sequence.hxx>
  42 #include <com/sun/star/lang/DisposedException.hpp>
  43 #include "connectivity/dbconversion.hxx"
  44 #include "connectivity/dbexception.hxx"
  45 #include "connectivity/dbtools.hxx"
  46 #include "connectivity/PColumn.hxx"
  47 #include "diagnose_ex.h"
  48 #include <comphelper/types.hxx>
  49 #include <com/sun/star/sdbc/ColumnValue.hpp>
  50 #include <tools/debug.hxx>
  51 #include "resource/file_res.hrc"
  52 #include <rtl/logfile.hxx>
  53
  54 using namespace connectivity;
  55 using namespace comphelper;
  56 using namespace ::dbtools;
  57 using namespace connectivity::file;
  58 using namespace com::sun::star::uno;
  59 using namespace com::sun::star::lang;
  60 using namespace com::sun::star::beans;
  61 using namespace com::sun::star::sdbc;
  62 using namespace com::sun::star::sdbcx;
  63 using namespace com::sun::star::container;
  64 using namespace com::sun::star::util;
  65
  66 IMPLEMENT_SERVICE_INFO(OPreparedStatement,"com.sun.star.sdbc.driver.file.PreparedStatement","com.sun.star.sdbc.PreparedStatement");
  67
  68 DBG_NAME( file_OPreparedStatement )
  69 // -------------------------------------------------------------------------
  70 OPreparedStatement::OPreparedStatement( OConnection* _pConnection)
  71     : OStatement_BASE2( _pConnection )
  72     ,m_pResultSet(NULL)
  73 {
  74     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::OPreparedStatement" );
  75     DBG_CTOR( file_OPreparedStatement, NULL );
  76 }
  77
  78 // -------------------------------------------------------------------------
  79 OPreparedStatement::~OPreparedStatement()
  80 {
  81     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::~OPreparedStatement" );
  82     DBG_DTOR( file_OPreparedStatement, NULL );
  83 }
  84
  85 // -------------------------------------------------------------------------
  86 void OPreparedStatement::disposing()
  87 {
  88     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::disposing" );
  89     ::osl::MutexGuard aGuard(m_aMutex);
  90
  91     clearMyResultSet();
  92     OStatement_BASE2::disposing();
  93
  94     if(m_pResultSet)
  95     {
  96         m_pResultSet->release();
  97         m_pResultSet = NULL;
  98     }
  99
 100     m_xParamColumns = NULL;
 101     m_xMetaData.clear();
 102     if(m_aParameterRow.isValid())
 103     {
 104         m_aParameterRow->get().clear();
 105         m_aParameterRow = NULL;
 106     }
 107
 108
 109 }
 110 // -------------------------------------------------------------------------
 111 void OPreparedStatement::construct(const ::rtl::OUString& sql)  throw(SQLException, RuntimeException)
 112 {
 113     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::construct" );
 114     OStatement_Base::construct(sql);
 115
 116     m_aParameterRow = new OValueRefVector();
 117     m_aParameterRow->get().push_back(new ORowSetValueDecorator(sal_Int32(0)) );
 118
 119     Reference<XIndexAccess> xNames(m_xColNames,UNO_QUERY);
 120
 121     if ( m_aSQLIterator.getStatementType() == SQL_STATEMENT_SELECT )
 122         m_xParamColumns = m_aSQLIterator.getParameters();
 123     else
 124     {
 125         m_xParamColumns = new OSQLColumns();
 126         // describe all parameters need for the resultset
 127         describeParameter();
 128     }
 129
 130     OValueRefRow aTemp;
 131     OResultSet::setBoundedColumns(m_aEvaluateRow,aTemp,m_xParamColumns,xNames,sal_False,m_xDBMetaData,m_aColMapping);
 132
 133     m_pResultSet = createResultSet();
 134     m_pResultSet->acquire();
 135     m_xResultSet = Reference<XResultSet>(m_pResultSet);
 136     initializeResultSet(m_pResultSet);
 137 }
 138 // -------------------------------------------------------------------------
 139
 140 Any SAL_CALL OPreparedStatement::queryInterface( const Type & rType ) throw(RuntimeException)
 141 {
 142     //RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::queryInterface" );
 143     Any aRet = OStatement_BASE2::queryInterface(rType);
 144     return aRet.hasValue() ? aRet : ::cppu::queryInterface(     rType,
 145                                         static_cast< XPreparedStatement*>(this),
 146                                         static_cast< XParameters*>(this),
 147                                         static_cast< XResultSetMetaDataSupplier*>(this));
 148 }
 149 // -------------------------------------------------------------------------
 150 ::com::sun::star::uno::Sequence< ::com::sun::star::uno::Type > SAL_CALL OPreparedStatement::getTypes(  ) throw(::com::sun::star::uno::RuntimeException)
 151 {
 152     //RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::getTypes" );
 153         ::cppu::OTypeCollection aTypes( ::getCppuType( (const ::com::sun::star::uno::Reference< XPreparedStatement > *)0 ),
 154                                         ::getCppuType( (const ::com::sun::star::uno::Reference< XParameters > *)0 ),
 155                                         ::getCppuType( (const ::com::sun::star::uno::Reference< XResultSetMetaDataSupplier > *)0 ));
 156
 157     return ::comphelper::concatSequences(aTypes.getTypes(),OStatement_BASE2::getTypes());
 158 }
 159 // -------------------------------------------------------------------------
 160
 161 Reference< XResultSetMetaData > SAL_CALL OPreparedStatement::getMetaData(  ) throw(SQLException, RuntimeException)
 162 {
 163     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::getMetaData" );
 164     ::osl::MutexGuard aGuard( m_aMutex );
 165     checkDisposed(OStatement_BASE::rBHelper.bDisposed);
 166
 167
 168     if(!m_xMetaData.is())
 169         m_xMetaData = new OResultSetMetaData(m_aSQLIterator.getSelectColumns(),m_aSQLIterator.getTables().begin()->first,m_pTable);
 170     return m_xMetaData;
 171 }
 172 // -------------------------------------------------------------------------
 173
 174 void SAL_CALL OPreparedStatement::close(  ) throw(SQLException, RuntimeException)
 175 {
 176     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::close" );
 177     ::osl::MutexGuard aGuard( m_aMutex );
 178     checkDisposed(OStatement_BASE::rBHelper.bDisposed);
 179
 180
 181     clearMyResultSet();
 182 }
 183 // -------------------------------------------------------------------------
 184
 185 sal_Bool SAL_CALL OPreparedStatement::execute(  ) throw(SQLException, RuntimeException)
 186 {
 187     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::execute" );
 188     ::osl::MutexGuard aGuard( m_aMutex );
 189     checkDisposed(OStatement_BASE::rBHelper.bDisposed);
 190
 191     initResultSet();
 192
 193     return m_aSQLIterator.getStatementType() == SQL_STATEMENT_SELECT;
 194 }
 195 // -------------------------------------------------------------------------
 196
 197 sal_Int32 SAL_CALL OPreparedStatement::executeUpdate(  ) throw(SQLException, RuntimeException)
 198 {
 199     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::executeUpdate" );
 200     ::osl::MutexGuard aGuard( m_aMutex );
 201     checkDisposed(OStatement_BASE::rBHelper.bDisposed);
 202
 203     initResultSet();
 204
 205     return m_pResultSet ? m_pResultSet->getRowCountResult() : sal_Int32(0);
 206 }
 207 // -------------------------------------------------------------------------
 208
 209 void SAL_CALL OPreparedStatement::setString( sal_Int32 parameterIndex, const ::rtl::OUString& x ) throw(SQLException, RuntimeException)
 210 {
 211     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::setString" );
 212     setParameter(parameterIndex,x);
 213 }
 214 // -------------------------------------------------------------------------
 215
 216 Reference< XConnection > SAL_CALL OPreparedStatement::getConnection(  ) throw(SQLException, RuntimeException)
 217 {
 218     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::getConnection" );
 219     ::osl::MutexGuard aGuard( m_aMutex );
 220     checkDisposed(OStatement_BASE::rBHelper.bDisposed);
 221
 222     return (Reference< XConnection >)m_pConnection;
 223 }
 224 // -------------------------------------------------------------------------
 225
 226 Reference< XResultSet > SAL_CALL OPreparedStatement::executeQuery(  ) throw(SQLException, RuntimeException)
 227 {
 228     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::executeQuery" );
 229     ::osl::MutexGuard aGuard( m_aMutex );
 230     checkDisposed(OStatement_BASE::rBHelper.bDisposed);
 231
 232     return initResultSet();
 233 }
 234 // -------------------------------------------------------------------------
 235
 236 void SAL_CALL OPreparedStatement::setBoolean( sal_Int32 parameterIndex, sal_Bool x ) throw(SQLException, RuntimeException)
 237 {
 238     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::setBoolean" );
 239     setParameter(parameterIndex,x);
 240 }
 241 // -------------------------------------------------------------------------
 242 void SAL_CALL OPreparedStatement::setByte( sal_Int32 parameterIndex, sal_Int8 x ) throw(SQLException, RuntimeException)
 243 {
 244     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::setByte" );
 245     setParameter(parameterIndex,x);
 246 }
 247 // -------------------------------------------------------------------------
 248
 249 void SAL_CALL OPreparedStatement::setDate( sal_Int32 parameterIndex, const Date& aData ) throw(SQLException, RuntimeException)
 250 {
 251     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::setDate" );
 252     setParameter(parameterIndex,DBTypeConversion::toDouble(aData));
 253 }
 254 // -------------------------------------------------------------------------
 255 void SAL_CALL OPreparedStatement::setTime( sal_Int32 parameterIndex, const Time& aVal ) throw(SQLException, RuntimeException)
 256 {
 257     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::setTime" );
 258     setParameter(parameterIndex,DBTypeConversion::toDouble(aVal));
 259 }
 260 // -------------------------------------------------------------------------
 261
 262 void SAL_CALL OPreparedStatement::setTimestamp( sal_Int32 parameterIndex, const DateTime& aVal ) throw(SQLException, RuntimeException)
 263 {
 264     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::setTimestamp" );
 265     setParameter(parameterIndex,DBTypeConversion::toDouble(aVal));
 266 }
 267 // -------------------------------------------------------------------------
 268
 269 void SAL_CALL OPreparedStatement::setDouble( sal_Int32 parameterIndex, double x ) throw(SQLException, RuntimeException)
 270 {
 271     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::setDouble" );
 272     setParameter(parameterIndex,x);
 273 }
 274
 275 // -------------------------------------------------------------------------
 276
 277 void SAL_CALL OPreparedStatement::setFloat( sal_Int32 parameterIndex, float x ) throw(SQLException, RuntimeException)
 278 {
 279     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::setFloat" );
 280     setParameter(parameterIndex,x);
 281 }
 282 // -------------------------------------------------------------------------
 283
 284 void SAL_CALL OPreparedStatement::setInt( sal_Int32 parameterIndex, sal_Int32 x ) throw(SQLException, RuntimeException)
 285 {
 286     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::setInt" );
 287     setParameter(parameterIndex,x);
 288 }
 289 // -------------------------------------------------------------------------
 290
 291 void SAL_CALL OPreparedStatement::setLong( sal_Int32 /*parameterIndex*/, sal_Int64 /*aVal*/ ) throw(SQLException, RuntimeException)
 292 {
 293     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::setLong" );
 294     throwFeatureNotImplementedException( "XParameters::setLong", *this );
 295 }
 296 // -------------------------------------------------------------------------
 297
 298 void SAL_CALL OPreparedStatement::setNull( sal_Int32 parameterIndex, sal_Int32 /*sqlType*/ ) throw(SQLException, RuntimeException)
 299 {
 300     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::setNull" );
 301     ::osl::MutexGuard aGuard( m_aMutex );
 302     checkAndResizeParameters(parameterIndex);
 303
 304     if ( m_aAssignValues.isValid() )
 305         (m_aAssignValues->get())[m_aParameterIndexes[parameterIndex]]->setNull();
 306     else
 307         (m_aParameterRow->get())[parameterIndex]->setNull();
 308 }
 309 // -------------------------------------------------------------------------
 310
 311 void SAL_CALL OPreparedStatement::setClob( sal_Int32 /*parameterIndex*/, const Reference< XClob >& /*x*/ ) throw(SQLException, RuntimeException)
 312 {
 313     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::setClob" );
 314     throwFeatureNotImplementedException( "XParameters::setClob", *this );
 315 }
 316 // -------------------------------------------------------------------------
 317
 318 void SAL_CALL OPreparedStatement::setBlob( sal_Int32 /*parameterIndex*/, const Reference< XBlob >& /*x*/ ) throw(SQLException, RuntimeException)
 319 {
 320     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::setBlob" );
 321     throwFeatureNotImplementedException( "XParameters::setBlob", *this );
 322 }
 323 // -------------------------------------------------------------------------
 324
 325 void SAL_CALL OPreparedStatement::setArray( sal_Int32 /*parameterIndex*/, const Reference< XArray >& /*x*/ ) throw(SQLException, RuntimeException)
 326 {
 327     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::setArray" );
 328     throwFeatureNotImplementedException( "XParameters::setArray", *this );
 329 }
 330 // -------------------------------------------------------------------------
 331
 332 void SAL_CALL OPreparedStatement::setRef( sal_Int32 /*parameterIndex*/, const Reference< XRef >& /*x*/ ) throw(SQLException, RuntimeException)
 333 {
 334     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::setRef" );
 335     throwFeatureNotImplementedException( "XParameters::setRef", *this );
 336 }
 337 // -------------------------------------------------------------------------
 338
 339 void SAL_CALL OPreparedStatement::setObjectWithInfo( sal_Int32 parameterIndex, const Any& x, sal_Int32 sqlType, sal_Int32 scale ) throw(SQLException, RuntimeException)
 340 {
 341     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::setObjectWithInfo" );
 342     switch(sqlType)
 343     {
 344         case DataType::DECIMAL:
 345         case DataType::NUMERIC:
 346             setString(parameterIndex,::comphelper::getString(x));
 347             break;
 348         default:
 349             ::dbtools::setObjectWithInfo(this,parameterIndex,x,sqlType,scale);
 350             break;
 351     }
 352 }
 353 // -------------------------------------------------------------------------
 354
 355 void SAL_CALL OPreparedStatement::setObjectNull( sal_Int32 parameterIndex, sal_Int32 sqlType, const ::rtl::OUString& /*typeName*/ ) throw(SQLException, RuntimeException)
 356 {
 357     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::setObjectNull" );
 358     setNull(parameterIndex,sqlType);
 359 }
 360 // -------------------------------------------------------------------------
 361
 362 void SAL_CALL OPreparedStatement::setObject( sal_Int32 parameterIndex, const Any& x ) throw(SQLException, RuntimeException)
 363 {
 364     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::setObject" );
 365     if(!::dbtools::implSetObject(this,parameterIndex,x))
 366     {
 367         const ::rtl::OUString sError( m_pConnection->getResources().getResourceStringWithSubstitution(
 368                 STR_UNKNOWN_PARA_TYPE,
 369                 "$position$", ::rtl::OUString::valueOf(parameterIndex)
 370              ) );
 371         ::dbtools::throwGenericSQLException(sError,*this);
 372     }
 373     //  setObject (parameterIndex, x, sqlType, 0);
 374 }
 375 // -------------------------------------------------------------------------
 376
 377 void SAL_CALL OPreparedStatement::setShort( sal_Int32 parameterIndex, sal_Int16 x ) throw(SQLException, RuntimeException)
 378 {
 379     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::setShort" );
 380     setParameter(parameterIndex,x);
 381 }
 382 // -------------------------------------------------------------------------
 383
 384 void SAL_CALL OPreparedStatement::setBytes( sal_Int32 parameterIndex, const Sequence< sal_Int8 >& x ) throw(SQLException, RuntimeException)
 385 {
 386     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::setBytes" );
 387     setParameter(parameterIndex,x);
 388 }
 389 // -------------------------------------------------------------------------
 390
 391
 392 void SAL_CALL OPreparedStatement::setCharacterStream( sal_Int32 parameterIndex, const Reference< ::com::sun::star::io::XInputStream >& x, sal_Int32 length ) throw(SQLException, RuntimeException)
 393 {
 394     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::setCharacterStream" );
 395     setBinaryStream(parameterIndex,x,length );
 396 }
 397 // -------------------------------------------------------------------------
 398
 399 void SAL_CALL OPreparedStatement::setBinaryStream( sal_Int32 parameterIndex, const Reference< ::com::sun::star::io::XInputStream >& x, sal_Int32 length ) throw(SQLException, RuntimeException)
 400 {
 401     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::setBinaryStream" );
 402     if(!x.is())
 403         ::dbtools::throwFunctionSequenceException(*this);
 404
 405     Sequence<sal_Int8> aSeq;
 406     x->readBytes(aSeq,length);
 407     setParameter(parameterIndex,aSeq);
 408 }
 409 // -------------------------------------------------------------------------
 410
 411 void SAL_CALL OPreparedStatement::clearParameters(  ) throw(SQLException, RuntimeException)
 412 {
 413     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::clearParameters" );
 414     ::osl::MutexGuard aGuard( m_aMutex );
 415     checkDisposed(OStatement_BASE::rBHelper.bDisposed);
 416
 417     m_aParameterRow->get().clear();
 418     m_aParameterRow->get().push_back(new ORowSetValueDecorator(sal_Int32(0)) );
 419 }
 420 // -------------------------------------------------------------------------
 421 OResultSet* OPreparedStatement::createResultSet()
 422 {
 423     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::createResultSet" );
 424     return new OResultSet(this,m_aSQLIterator);
 425 }
 426 // -----------------------------------------------------------------------------
 427 Reference<XResultSet> OPreparedStatement::initResultSet()
 428 {
 429     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::initResultSet" );
 430     m_pResultSet->clear();
 431     Reference<XResultSet> xRs(m_pResultSet);
 432
 433     // check if we got enough paramters
 434     if ( (m_aParameterRow.isValid() && ( m_aParameterRow->get().size() -1 ) < m_xParamColumns->get().size()) ||
 435          (m_xParamColumns.isValid() && !m_aParameterRow.isValid() && !m_aParameterRow->get().empty()) )
 436          m_pConnection->throwGenericSQLException(STR_INVALID_PARA_COUNT,*this);
 437
 438     m_pResultSet->OpenImpl();
 439     m_pResultSet->setMetaData(getMetaData());
 440
 441     return xRs;
 442 }
 443 // -----------------------------------------------------------------------------
 444 void SAL_CALL OPreparedStatement::acquire() throw()
 445 {
 446     OStatement_BASE2::acquire();
 447 }
 448 // -----------------------------------------------------------------------------
 449 void SAL_CALL OPreparedStatement::release() throw()
 450 {
 451     OStatement_BASE2::release();
 452 }
 453 // -----------------------------------------------------------------------------
 454 void OPreparedStatement::checkAndResizeParameters(sal_Int32 parameterIndex)
 455 {
 456     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::checkAndResizeParameters" );
 457     ::connectivity::checkDisposed(OStatement_BASE::rBHelper.bDisposed);
 458     if ( m_aAssignValues.isValid() && (parameterIndex < 1 || parameterIndex >= static_cast<sal_Int32>(m_aParameterIndexes.size())) )
 459         throwInvalidIndexException(*this);
 460     else if ( static_cast<sal_Int32>((m_aParameterRow->get()).size()) <= parameterIndex )
 461     {
 462         sal_Int32 i = m_aParameterRow->get().size();
 463         (m_aParameterRow->get()).resize(parameterIndex+1);
 464         for ( ;i <= parameterIndex+1; ++i )
 465         {
 466             if ( !(m_aParameterRow->get())[i].isValid() )
 467                 (m_aParameterRow->get())[i] = new ORowSetValueDecorator;
 468         }
 469     }
 470 }
 471 // -----------------------------------------------------------------------------
 472 void OPreparedStatement::setParameter(sal_Int32 parameterIndex, const ORowSetValue& x)
 473 {
 474     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::setParameter" );
 475     ::osl::MutexGuard aGuard( m_aMutex );
 476     checkAndResizeParameters(parameterIndex);
 477
 478     if(m_aAssignValues.isValid())
 479         *(m_aAssignValues->get())[m_aParameterIndexes[parameterIndex]] = x;
 480     else
 481         *((m_aParameterRow->get())[parameterIndex]) = x;
 482 }
 483 // -----------------------------------------------------------------------------
 484 UINT32 OPreparedStatement::AddParameter(OSQLParseNode * pParameter, const Reference<XPropertySet>& _xCol)
 485 {
 486     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::AddParameter" );
 487     OSL_UNUSED( pParameter );
 488     OSL_ENSURE(SQL_ISRULE(pParameter,parameter),"OResultSet::AddParameter: Argument ist kein Parameter");
 489     OSL_ENSURE(pParameter->count() > 0,"OResultSet: Fehler im Parse Tree");
 490 #if OSL_DEBUG_LEVEL > 0
 491     OSQLParseNode * pMark = pParameter->getChild(0);
 492     OSL_UNUSED( pMark );
 493 #endif
 494
 495     ::rtl::OUString sParameterName;
 496     // Parameter-Column aufsetzen:
 497     sal_Int32 eType = DataType::VARCHAR;
 498     UINT32 nPrecision = 255;
 499     sal_Int32 nScale = 0;
 500     sal_Int32 nNullable = ColumnValue::NULLABLE;
 501
 502     if (_xCol.is())
 503     {
 504         // Typ, Precision, Scale ... der angegebenen Column verwenden,
 505         // denn dieser Column wird der Wert zugewiesen bzw. mit dieser
 506         // Column wird der Wert verglichen.
 507         _xCol->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_TYPE))                 >>= eType;
 508         _xCol->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_PRECISION))    >>= nPrecision;
 509         _xCol->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_SCALE))                >>= nScale;
 510         _xCol->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_ISNULLABLE))   >>= nNullable;
 511         _xCol->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_NAME))                 >>= sParameterName;
 512     }
 513
 514     Reference<XPropertySet> xParaColumn = new connectivity::parse::OParseColumn(sParameterName
 515                                                     ,::rtl::OUString()
 516                                                     ,::rtl::OUString()
 517                                                     ,nNullable
 518                                                     ,nPrecision
 519                                                     ,nScale
 520                                                     ,eType
 521                                                     ,sal_False
 522                                                     ,sal_False
 523                                                     ,m_aSQLIterator.isCaseSensitive());
 524     m_xParamColumns->get().push_back(xParaColumn);
 525     return m_xParamColumns->get().size();
 526 }
 527 // -----------------------------------------------------------------------------
 528 void OPreparedStatement::describeColumn(OSQLParseNode* _pParameter,OSQLParseNode* _pNode,const OSQLTable& _xTable)
 529 {
 530     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::describeColumn" );
 531     Reference<XPropertySet> xProp;
 532     if(SQL_ISRULE(_pNode,column_ref))
 533     {
 534         ::rtl::OUString sColumnName,sTableRange;
 535         m_aSQLIterator.getColumnRange(_pNode,sColumnName,sTableRange);
 536         if ( sColumnName.getLength() )
 537         {
 538             Reference<XNameAccess> xNameAccess = _xTable->getColumns();
 539             if(xNameAccess->hasByName(sColumnName))
 540                 xNameAccess->getByName(sColumnName) >>= xProp;
 541             AddParameter(_pParameter,xProp);
 542         }
 543     }
 544     //  else
 545         //      AddParameter(_pParameter,xProp);
 546 }
 547 // -------------------------------------------------------------------------
 548 void OPreparedStatement::describeParameter()
 549 {
 550     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::describeParameter" );
 551     ::std::vector< OSQLParseNode*> aParseNodes;
 552     scanParameter(m_pParseTree,aParseNodes);
 553     if ( !aParseNodes.empty() )
 554     {
 555         //      m_xParamColumns = new OSQLColumns();
 556         const OSQLTables& xTabs = m_aSQLIterator.getTables();
 557         if( !xTabs.empty() )
 558         {
 559             OSQLTable xTable = xTabs.begin()->second;
 560             ::std::vector< OSQLParseNode*>::const_iterator aIter = aParseNodes.begin();
 561             for (;aIter != aParseNodes.end();++aIter )
 562             {
 563                 describeColumn(*aIter,(*aIter)->getParent()->getChild(0),xTable);
 564             }
 565         }
 566     }
 567 }
 568 // -----------------------------------------------------------------------------
 569 void OPreparedStatement::initializeResultSet(OResultSet* _pResult)
 570 {
 571     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::initializeResultSet" );
 572     OStatement_Base::initializeResultSet(_pResult);
 573
 574     m_pResultSet->setParameterColumns(m_xParamColumns);
 575     m_pResultSet->setParameterRow(m_aParameterRow);
 576
 577     // Parameter substituieren (AssignValues und Kriterien):
 578     if (!m_xParamColumns->get().empty())
 579     {
 580         // Zunaechst AssignValues
 581         USHORT nParaCount=0; // gibt die aktuelle Anzahl der bisher gesetzen Parameter an
 582
 583         // Nach zu substituierenden Parametern suchen:
 584         size_t nCount = m_aAssignValues.isValid() ? m_aAssignValues->get().size() : 1; // 1 ist wichtig fuer die Kriterien
 585         for (size_t j = 1; j < nCount; j++)
 586         {
 587             UINT32 nParameter = (*m_aAssignValues).getParameterIndex(j);
 588             if (nParameter == SQL_NO_PARAMETER)
 589                 continue;       // dieser AssignValue ist kein Parameter
 590
 591             ++nParaCount; // ab hier ist der Parameter gueltig
 592             // Parameter ersetzen. Wenn Parameter nicht verfuegbar,
 593             //  Value auf NULL setzen.
 594             //  (*m_aAssignValues)[j] = (*m_aParameterRow)[(UINT16)nParameter];
 595         }
 596
 597         if (m_aParameterRow.isValid() &&  (m_xParamColumns->get().size()+1) != m_aParameterRow->get().size() )
 598         {
 599             sal_Int32 i = m_aParameterRow->get().size();
 600             sal_Int32 nParamColumns = m_xParamColumns->get().size()+1;
 601             m_aParameterRow->get().resize(nParamColumns);
 602             for ( ;i < nParamColumns; ++i )
 603             {
 604                 if ( !(m_aParameterRow->get())[i].isValid() )
 605                     (m_aParameterRow->get())[i] = new ORowSetValueDecorator;
 606             }
 607             //m_aParameterRow->resize(m_xParamColumns->size()+1);
 608         }
 609         if (m_aParameterRow.isValid() && nParaCount < m_aParameterRow->get().size() )
 610         {
 611
 612             m_pSQLAnalyzer->bindParameterRow(m_aParameterRow);
 613         }
 614     }
 615 }
 616 // -----------------------------------------------------------------------------
 617 void OPreparedStatement::parseParamterElem(const String& _sColumnName,OSQLParseNode* pRow_Value_Constructor_Elem)
 618 {
 619     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "file", "Ocke.Janssen@sun.com", "OPreparedStatement::parseParamterElem" );
 620     Reference<XPropertySet> xCol;
 621     m_xColNames->getByName(_sColumnName) >>= xCol;
 622     sal_Int32 nParameter = -1;
 623     if(m_xParamColumns.isValid())
 624     {
 625         OSQLColumns::Vector::const_iterator aIter = find(m_xParamColumns->get().begin(),m_xParamColumns->get().end(),_sColumnName,::comphelper::UStringMixEqual(m_pTable->isCaseSensitive()));
 626         if(aIter != m_xParamColumns->get().end())
 627             nParameter = m_xParamColumns->get().size() - (m_xParamColumns->get().end() - aIter) + 1;// +1 because the rows start at 1
 628     }
 629     if(nParameter == -1)
 630         nParameter = AddParameter(pRow_Value_Constructor_Elem,xCol);
 631     // Nr. des Parameters in der Variablen merken:
 632     SetAssignValue(_sColumnName, String(), TRUE, nParameter);
 633 }
 634 // -----------------------------------------------------------------------------
 635
 636