connectivity/source/drivers/firebird/Statement.cxx

   1 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4; fill-column: 100 -*- */
   2 /*
   3  * This file is part of the LibreOffice project.
   4  *
   5  * This Source Code Form is subject to the terms of the Mozilla Public
   6  * License, v. 2.0. If a copy of the MPL was not distributed with this
   7  * file, You can obtain one at http://mozilla.org/MPL/2.0/.
   8  *
   9  * This file incorporates work covered by the following license notice:
  10  *
  11  *   Licensed to the Apache Software Foundation (ASF) under one or more
  12  *   contributor license agreements. See the NOTICE file distributed
  13  *   with this work for additional information regarding copyright
  14  *   ownership. The ASF licenses this file to you under the Apache
  15  *   License, Version 2.0 (the "License"); you may not use this file
  16  *   except in compliance with the License. You may obtain a copy of
  17  *   the License at http://www.apache.org/licenses/LICENSE-2.0 .
  18  */
  19
  20 #include "Connection.hxx"
  21 #include "ResultSet.hxx"
  22 #include "Statement.hxx"
  23 #include "Util.hxx"
  24
  25 #include <comphelper/sequence.hxx>
  26 #include <cppuhelper/queryinterface.hxx>
  27 #include <sal/log.hxx>
  28
  29 using namespace connectivity::firebird;
  30
  31 using namespace com::sun::star;
  32 using namespace com::sun::star::uno;
  33 using namespace com::sun::star::lang;
  34 using namespace com::sun::star::beans;
  35 using namespace com::sun::star::sdbc;
  36 using namespace com::sun::star::sdbcx;
  37 using namespace com::sun::star::container;
  38 using namespace com::sun::star::io;
  39 using namespace com::sun::star::util;
  40
  41 using namespace ::comphelper;
  42 using namespace ::osl;
  43 using namespace ::std;
  44
  45 // ---- XBatchExecution - UNSUPPORTED ----------------------------------------
  46 void SAL_CALL OStatement::addBatch(const OUString&)
  47 {
  48 }
  49
  50 void SAL_CALL OStatement::clearBatch()
  51 {
  52 }
  53
  54 Sequence< sal_Int32 > SAL_CALL OStatement::executeBatch()
  55 {
  56     return Sequence< sal_Int32 >();
  57 }
  58
  59 IMPLEMENT_SERVICE_INFO(OStatement,"com.sun.star.sdbcx.OStatement","com.sun.star.sdbc.Statement");
  60
  61 void SAL_CALL OStatement::acquire() noexcept
  62 {
  63     OStatementCommonBase::acquire();
  64 }
  65
  66 void SAL_CALL OStatement::release() noexcept
  67 {
  68     OStatementCommonBase::release();
  69 }
  70
  71 void OStatement::disposeResultSet()
  72 {
  73     MutexGuard aGuard(m_aMutex);
  74     checkDisposed(OStatementCommonBase_Base::rBHelper.bDisposed);
  75
  76     OStatementCommonBase::disposeResultSet();
  77
  78     if (m_pSqlda)
  79     {
  80         freeSQLVAR(m_pSqlda);
  81         free(m_pSqlda);
  82         m_pSqlda = nullptr;
  83     }
  84 }
  85
  86 // ---- XStatement -----------------------------------------------------------
  87 sal_Int32 SAL_CALL OStatement::executeUpdate(const OUString& sql)
  88 {
  89     execute(sql);
  90     return getStatementChangeCount();
  91 }
  92
  93
  94 uno::Reference< XResultSet > SAL_CALL OStatement::executeQuery(const OUString& sql)
  95 {
  96     MutexGuard aGuard(m_aMutex);
  97     checkDisposed(OStatementCommonBase_Base::rBHelper.bDisposed);
  98
  99     SAL_INFO("connectivity.firebird", "executeQuery(" << sql << ")");
 100
 101     ISC_STATUS aErr = 0;
 102
 103     disposeResultSet();
 104
 105     prepareAndDescribeStatement(sql,
 106                                 m_pSqlda);
 107
 108     aErr = isc_dsql_execute(m_statusVector,
 109                             &m_pConnection->getTransaction(),
 110                             &m_aStatementHandle,
 111                             1,
 112                             nullptr);
 113     if (aErr)
 114         SAL_WARN("connectivity.firebird", "isc_dsql_execute failed");
 115
 116     m_xResultSet = new OResultSet(m_pConnection.get(),
 117                                   m_aMutex,
 118                                   uno::Reference< XInterface >(*this),
 119                                   m_aStatementHandle,
 120                                   m_pSqlda );
 121
 122     // TODO: deal with cleanup
 123
 124     evaluateStatusVector(m_statusVector, sql, *this);
 125
 126     if (isDDLStatement())
 127     {
 128         m_pConnection->commit();
 129         m_pConnection->notifyDatabaseModified();
 130     }
 131     else if (getStatementChangeCount() > 0)
 132     {
 133         m_pConnection->notifyDatabaseModified();
 134     }
 135
 136     return m_xResultSet;
 137 }
 138
 139 sal_Bool SAL_CALL OStatement::execute(const OUString& sql)
 140 {
 141     uno::Reference< XResultSet > xResults = executeQuery(sql);
 142     return xResults.is();
 143     // TODO: what if we have multiple results?
 144 }
 145
 146 uno::Reference< XConnection > SAL_CALL OStatement::getConnection()
 147 {
 148     MutexGuard aGuard(m_aMutex);
 149     checkDisposed(OStatementCommonBase_Base::rBHelper.bDisposed);
 150
 151     return m_pConnection;
 152 }
 153
 154 Any SAL_CALL OStatement::queryInterface( const Type & rType )
 155 {
 156     Any aRet = OStatement_Base::queryInterface(rType);
 157     if(!aRet.hasValue())
 158         aRet = ::cppu::queryInterface(rType,static_cast< XBatchExecution*> (this));
 159     if(!aRet.hasValue())
 160         aRet = OStatementCommonBase::queryInterface(rType);
 161     return aRet;
 162 }
 163
 164 uno::Sequence< Type > SAL_CALL OStatement::getTypes()
 165 {
 166     return concatSequences(OStatement_Base::getTypes(),
 167                            OStatementCommonBase::getTypes());
 168 }
 169
 170 void SAL_CALL OStatement::disposing()
 171 {
 172     disposeResultSet();
 173     close();
 174 }
 175
 176 /* vim:set shiftwidth=4 softtabstop=4 expandtab cinoptions=b1,g0,N-s cinkeys+=0=break: */