| /************************************************************** |
| * |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, |
| * software distributed under the License is distributed on an |
| * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| * KIND, either express or implied. See the License for the |
| * specific language governing permissions and limitations |
| * under the License. |
| * |
| *************************************************************/ |
| |
| |
| |
| // MARKER(update_precomp.py): autogen include statement, do not remove |
| #include "precompiled_connectivity.hxx" |
| |
| #include "KPreparedStatement.hxx" |
| #include "propertyids.hxx" |
| #include <connectivity/dbexception.hxx> |
| #include <connectivity/dbtools.hxx> |
| #include "resource/kab_res.hrc" |
| #include "resource/sharedresources.hxx" |
| |
| using namespace connectivity::kab; |
| using namespace com::sun::star::uno; |
| using namespace com::sun::star::lang; |
| using namespace com::sun::star::sdbc; |
| using namespace com::sun::star::util; |
| |
| IMPLEMENT_SERVICE_INFO(KabPreparedStatement, "com.sun.star.sdbc.drivers.KabPreparedStatement", "com.sun.star.sdbc.PreparedStatement"); |
| // ------------------------------------------------------------------------- |
| void KabPreparedStatement::checkAndResizeParameters(sal_Int32 nParams) throw(SQLException) |
| { |
| if ( !m_aParameterRow.isValid() ) |
| m_aParameterRow = new OValueVector(); |
| |
| if (nParams < 1) |
| ::dbtools::throwInvalidIndexException(*(KabPreparedStatement *) this,Any()); |
| |
| if (nParams >= (sal_Int32) (m_aParameterRow->get()).size()) |
| (m_aParameterRow->get()).resize(nParams); |
| } |
| // ------------------------------------------------------------------------- |
| void KabPreparedStatement::setKabFields() const throw(SQLException) |
| { |
| ::vos::ORef<connectivity::OSQLColumns> xColumns; // selected columns |
| |
| xColumns = m_aSQLIterator.getSelectColumns(); |
| if (!xColumns.isValid()) |
| { |
| ::connectivity::SharedResources aResources; |
| const ::rtl::OUString sError( aResources.getResourceString( |
| STR_INVALID_COLUMN_SELECTION |
| ) ); |
| ::dbtools::throwGenericSQLException(sError,NULL); |
| } |
| m_xMetaData->setKabFields(xColumns); |
| } |
| // ------------------------------------------------------------------------- |
| void KabPreparedStatement::resetParameters() const throw(SQLException) |
| { |
| m_nParameterIndex = 0; |
| } |
| // ------------------------------------------------------------------------- |
| void KabPreparedStatement::getNextParameter(::rtl::OUString &rParameter) const throw(SQLException) |
| { |
| if (m_nParameterIndex >= (sal_Int32) (m_aParameterRow->get()).size()) |
| { |
| ::connectivity::SharedResources aResources; |
| const ::rtl::OUString sError( aResources.getResourceString( |
| STR_INVALID_PARA_COUNT |
| ) ); |
| ::dbtools::throwGenericSQLException(sError,*(KabPreparedStatement *) this); |
| } // if (m_nParameterIndex >= (sal_Int32) (*m_aParameterRow).size()) |
| |
| rParameter = (m_aParameterRow->get())[m_nParameterIndex]; |
| |
| m_nParameterIndex++; |
| } |
| // ------------------------------------------------------------------------- |
| KabPreparedStatement::KabPreparedStatement( |
| KabConnection* _pConnection, |
| const ::rtl::OUString& sql) |
| : KabPreparedStatement_BASE(_pConnection), |
| m_sSqlStatement(sql), |
| m_bPrepared(sal_False), |
| m_nParameterIndex(0), |
| m_aParameterRow() |
| { |
| } |
| // ------------------------------------------------------------------------- |
| KabPreparedStatement::~KabPreparedStatement() |
| { |
| } |
| // ------------------------------------------------------------------------- |
| void KabPreparedStatement::disposing() |
| { |
| KabPreparedStatement_BASE::disposing(); |
| |
| if (m_aParameterRow.isValid()) |
| { |
| m_aParameterRow->get().clear(); |
| m_aParameterRow = NULL; |
| } |
| } |
| // ------------------------------------------------------------------------- |
| Reference< XResultSetMetaData > SAL_CALL KabPreparedStatement::getMetaData() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(KabCommonStatement_BASE::rBHelper.bDisposed); |
| |
| if (!m_xMetaData.is()) |
| { |
| m_xMetaData = new KabResultSetMetaData(getOwnConnection()); |
| setKabFields(); |
| } |
| Reference< XResultSetMetaData > xMetaData = m_xMetaData.get(); |
| return xMetaData; |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL KabPreparedStatement::close() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(KabCommonStatement_BASE::rBHelper.bDisposed); |
| |
| // Reset last warning message |
| try { |
| clearWarnings (); |
| KabCommonStatement::close(); |
| } |
| catch (SQLException &) { |
| // If we get an error, ignore |
| } |
| |
| // Remove this Statement object from the Connection object's |
| // list |
| } |
| // ------------------------------------------------------------------------- |
| sal_Bool SAL_CALL KabPreparedStatement::execute() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(KabCommonStatement_BASE::rBHelper.bDisposed); |
| |
| Reference< XResultSet> xRS = KabCommonStatement::executeQuery(m_sSqlStatement); |
| |
| return xRS.is(); |
| } |
| // ------------------------------------------------------------------------- |
| sal_Int32 SAL_CALL KabPreparedStatement::executeUpdate() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(KabCommonStatement_BASE::rBHelper.bDisposed); |
| |
| // same as in statement with the difference that this statement also can contain parameter |
| return 0; |
| } |
| // ------------------------------------------------------------------------- |
| Reference< XConnection > SAL_CALL KabPreparedStatement::getConnection() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(KabCommonStatement_BASE::rBHelper.bDisposed); |
| |
| return (Reference< XConnection >) m_pConnection; |
| } |
| // ------------------------------------------------------------------------- |
| Reference< XResultSet > SAL_CALL KabPreparedStatement::executeQuery() throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(KabCommonStatement_BASE::rBHelper.bDisposed); |
| |
| Reference< XResultSet > rs = KabCommonStatement::executeQuery(m_sSqlStatement); |
| |
| return rs; |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL KabPreparedStatement::setNull(sal_Int32 parameterIndex, sal_Int32) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(KabCommonStatement_BASE::rBHelper.bDisposed); |
| |
| checkAndResizeParameters(parameterIndex); |
| |
| (m_aParameterRow->get())[parameterIndex - 1].setNull(); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL KabPreparedStatement::setObjectNull(sal_Int32, sal_Int32, const ::rtl::OUString&) throw(SQLException, RuntimeException) |
| { |
| |
| |
| |
| ::dbtools::throwFunctionNotSupportedException("setObjectNull", NULL); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL KabPreparedStatement::setBoolean(sal_Int32, sal_Bool) throw(SQLException, RuntimeException) |
| { |
| |
| |
| |
| ::dbtools::throwFunctionNotSupportedException("setBoolean", NULL); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL KabPreparedStatement::setByte(sal_Int32, sal_Int8) throw(SQLException, RuntimeException) |
| { |
| |
| |
| |
| ::dbtools::throwFunctionNotSupportedException("setByte", NULL); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL KabPreparedStatement::setShort(sal_Int32, sal_Int16) throw(SQLException, RuntimeException) |
| { |
| |
| |
| |
| ::dbtools::throwFunctionNotSupportedException("setShort", NULL); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL KabPreparedStatement::setInt(sal_Int32, sal_Int32) throw(SQLException, RuntimeException) |
| { |
| |
| |
| |
| ::dbtools::throwFunctionNotSupportedException("setInt", NULL); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL KabPreparedStatement::setLong(sal_Int32, sal_Int64) throw(SQLException, RuntimeException) |
| { |
| |
| |
| |
| ::dbtools::throwFunctionNotSupportedException("", NULL); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL KabPreparedStatement::setFloat(sal_Int32, float) throw(SQLException, RuntimeException) |
| { |
| |
| |
| |
| ::dbtools::throwFunctionNotSupportedException("setFloat", NULL); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL KabPreparedStatement::setDouble(sal_Int32, double) throw(SQLException, RuntimeException) |
| { |
| |
| |
| |
| ::dbtools::throwFunctionNotSupportedException("setDouble", NULL); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL KabPreparedStatement::setString(sal_Int32 parameterIndex, const ::rtl::OUString &x) throw(SQLException, RuntimeException) |
| { |
| ::osl::MutexGuard aGuard( m_aMutex ); |
| checkDisposed(KabCommonStatement_BASE::rBHelper.bDisposed); |
| |
| checkAndResizeParameters(parameterIndex); |
| |
| (m_aParameterRow->get())[parameterIndex - 1] = x; |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL KabPreparedStatement::setBytes(sal_Int32, const Sequence< sal_Int8 >&) throw(SQLException, RuntimeException) |
| { |
| |
| |
| |
| ::dbtools::throwFunctionNotSupportedException("setBytes", NULL); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL KabPreparedStatement::setDate(sal_Int32, const Date&) throw(SQLException, RuntimeException) |
| { |
| |
| |
| |
| ::dbtools::throwFunctionNotSupportedException("setDate", NULL); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL KabPreparedStatement::setTime(sal_Int32, const Time&) throw(SQLException, RuntimeException) |
| { |
| |
| |
| |
| ::dbtools::throwFunctionNotSupportedException("setTime", NULL); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL KabPreparedStatement::setTimestamp(sal_Int32, const DateTime&) throw(SQLException, RuntimeException) |
| { |
| |
| |
| |
| ::dbtools::throwFunctionNotSupportedException("setTimestamp", NULL); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL KabPreparedStatement::setBinaryStream(sal_Int32, const Reference< ::com::sun::star::io::XInputStream >&, sal_Int32) throw(SQLException, RuntimeException) |
| { |
| |
| |
| |
| ::dbtools::throwFunctionNotSupportedException("setBinaryStream", NULL); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL KabPreparedStatement::setCharacterStream(sal_Int32, const Reference< ::com::sun::star::io::XInputStream >&, sal_Int32) throw(SQLException, RuntimeException) |
| { |
| |
| |
| |
| ::dbtools::throwFunctionNotSupportedException("setCharacterStream", NULL); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL KabPreparedStatement::setObject(sal_Int32 parameterIndex, const Any& x) throw(SQLException, RuntimeException) |
| { |
| if(!::dbtools::implSetObject(this,parameterIndex,x)) |
| { |
| throw SQLException(); |
| } |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL KabPreparedStatement::setObjectWithInfo(sal_Int32, const Any&, sal_Int32, sal_Int32) throw(SQLException, RuntimeException) |
| { |
| |
| |
| |
| ::dbtools::throwFunctionNotSupportedException("setObjectWithInfo", NULL); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL KabPreparedStatement::setRef(sal_Int32, const Reference< XRef >&) throw(SQLException, RuntimeException) |
| { |
| |
| |
| |
| ::dbtools::throwFunctionNotSupportedException("setRef", NULL); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL KabPreparedStatement::setBlob(sal_Int32, const Reference< XBlob >&) throw(SQLException, RuntimeException) |
| { |
| |
| |
| |
| ::dbtools::throwFunctionNotSupportedException("setBlob", NULL); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL KabPreparedStatement::setClob(sal_Int32, const Reference< XClob >&) throw(SQLException, RuntimeException) |
| { |
| |
| |
| |
| ::dbtools::throwFunctionNotSupportedException("setClob", NULL); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL KabPreparedStatement::setArray(sal_Int32, const Reference< XArray >&) throw(SQLException, RuntimeException) |
| { |
| |
| |
| |
| ::dbtools::throwFunctionNotSupportedException("setArray", NULL); |
| } |
| // ------------------------------------------------------------------------- |
| void SAL_CALL KabPreparedStatement::clearParameters() throw(SQLException, RuntimeException) |
| { |
| ::dbtools::throwFunctionNotSupportedException("clearParameters", NULL); |
| } |
| // ------------------------------------------------------------------------- |
| void KabPreparedStatement::setFastPropertyValue_NoBroadcast(sal_Int32 nHandle,const Any& rValue) throw (Exception) |
| { |
| switch (nHandle) |
| { |
| case PROPERTY_ID_RESULTSETCONCURRENCY: |
| break; |
| case PROPERTY_ID_RESULTSETTYPE: |
| break; |
| case PROPERTY_ID_FETCHDIRECTION: |
| break; |
| case PROPERTY_ID_USEBOOKMARKS: |
| break; |
| default: |
| KabCommonStatement::setFastPropertyValue_NoBroadcast(nHandle,rValue); |
| } |
| } |
