mysqlc/source/mysqlc_statement.hxx

   1 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
   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 #ifndef INCLUDED_MYSQLC_SOURCE_MYSQLC_STATEMENT_HXX
  21 #define INCLUDED_MYSQLC_SOURCE_MYSQLC_STATEMENT_HXX
  22
  23 #include "mysqlc_connection.hxx"
  24 #include "mysqlc_subcomponent.hxx"
  25
  26 #include <com/sun/star/lang/XServiceInfo.hpp>
  27 #include <com/sun/star/sdbc/SQLWarning.hpp>
  28 #include <com/sun/star/sdbc/XBatchExecution.hpp>
  29 #include <com/sun/star/sdbc/XCloseable.hpp>
  30 #include <com/sun/star/sdbc/XMultipleResults.hpp>
  31 #include <com/sun/star/sdbc/XStatement.hpp>
  32 #include <com/sun/star/sdbc/XWarningsSupplier.hpp>
  33 #include <com/sun/star/util/XCancellable.hpp>
  34
  35 #include <cppconn/statement.h>
  36 #include <cppuhelper/compbase5.hxx>
  37 #include <list>
  38
  39 namespace connectivity
  40 {
  41     namespace mysqlc
  42     {
  43         using ::com::sun::star::sdbc::SQLWarning;
  44         using ::com::sun::star::sdbc::SQLException;
  45         using ::com::sun::star::uno::Any;
  46         using ::com::sun::star::uno::RuntimeException;
  47
  48         typedef ::cppu::WeakComponentImplHelper5<   ::com::sun::star::sdbc::XStatement,
  49                                                     ::com::sun::star::sdbc::XWarningsSupplier,
  50                                                     ::com::sun::star::util::XCancellable,
  51                                                     ::com::sun::star::sdbc::XCloseable,
  52                                                     ::com::sun::star::sdbc::XMultipleResults> OCommonStatement_IBase;
  53
  54         class OCommonStatement;
  55         typedef OSubComponent< OCommonStatement, OCommonStatement_IBase >   OStatement_CBase;
  56
  57
  58         //************ Class: OCommonStatement
  59         // is a base class for the normal statement and for the prepared statement
  60
  61         class OCommonStatement  :public OBase_Mutex
  62                                 ,public OCommonStatement_IBase
  63                                 ,public ::cppu::OPropertySetHelper
  64                                 ,public OPropertyArrayUsageHelper<OCommonStatement>
  65                                 ,public OStatement_CBase
  66
  67         {
  68             friend class OSubComponent< OCommonStatement, OCommonStatement_IBase >;
  69
  70         private:
  71             SQLWarning m_aLastWarning;
  72
  73         protected:
  74             ::std::list< rtl::OUString>  m_aBatchList;
  75
  76             OConnection*            m_pConnection;  // The owning Connection object
  77
  78             sql::Statement          *cppStatement;
  79
  80         protected:
  81             void disposeResultSet();
  82
  83             // OPropertyArrayUsageHelper
  84             ::cppu::IPropertyArrayHelper* createArrayHelper( ) const SAL_OVERRIDE;
  85
  86             // OPropertySetHelper
  87             ::cppu::IPropertyArrayHelper & SAL_CALL getInfoHelper() SAL_OVERRIDE;
  88             sal_Bool SAL_CALL convertFastPropertyValue(Any & rConvertedValue, Any & rOldValue,
  89                                                                sal_Int32 nHandle, const Any& rValue)
  90                                                 throw (::com::sun::star::lang::IllegalArgumentException) SAL_OVERRIDE;
  91
  92             void SAL_CALL setFastPropertyValue_NoBroadcast(sal_Int32 nHandle, const Any& rValue)
  93                                                 throw(::com::sun::star::uno::Exception, std::exception) SAL_OVERRIDE;
  94
  95             void SAL_CALL getFastPropertyValue(Any& rValue, sal_Int32 nHandle) const SAL_OVERRIDE;
  96             virtual ~OCommonStatement();
  97
  98         protected:
  99             OCommonStatement(OConnection* _pConnection, sql::Statement *_cppStatement);
 100
 101         public:
 102             ::cppu::OBroadcastHelper& rBHelper;
 103             using OCommonStatement_IBase::operator ::com::sun::star::uno::Reference< ::com::sun::star::uno::XInterface >;
 104
 105             // OComponentHelper
 106             void SAL_CALL disposing() SAL_OVERRIDE;
 107
 108             // XInterface
 109             void SAL_CALL release()             throw() SAL_OVERRIDE;
 110
 111             void SAL_CALL acquire()             throw() SAL_OVERRIDE;
 112
 113             // XInterface
 114             Any SAL_CALL queryInterface(const ::com::sun::star::uno::Type & rType)
 115                                                 throw(RuntimeException, std::exception) SAL_OVERRIDE;
 116
 117             //XTypeProvider
 118             ::com::sun::star::uno::Sequence< ::com::sun::star::uno::Type > SAL_CALL getTypes()
 119                                                 throw(RuntimeException, std::exception) SAL_OVERRIDE;
 120
 121             // XPropertySet
 122             ::com::sun::star::uno::Reference< ::com::sun::star::beans::XPropertySetInfo > SAL_CALL getPropertySetInfo()
 123                                                 throw(RuntimeException, std::exception) SAL_OVERRIDE;
 124
 125             // XStatement
 126             ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XResultSet > SAL_CALL executeQuery(const rtl::OUString& sql)
 127                                                 throw(SQLException, RuntimeException, std::exception) SAL_OVERRIDE;
 128
 129             sal_Int32 SAL_CALL executeUpdate(const rtl::OUString& sql)
 130                                                 throw(SQLException, RuntimeException, std::exception) SAL_OVERRIDE;
 131
 132             sal_Bool SAL_CALL execute( const rtl::OUString& sql )
 133                                                 throw(SQLException, RuntimeException, std::exception) SAL_OVERRIDE;
 134
 135             ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XConnection > SAL_CALL getConnection()
 136                                                 throw(SQLException, RuntimeException, std::exception) SAL_OVERRIDE;
 137
 138             // XWarningsSupplier
 139             Any SAL_CALL getWarnings()      throw(SQLException, RuntimeException, std::exception) SAL_OVERRIDE;
 140
 141             void SAL_CALL clearWarnings()       throw(SQLException, RuntimeException, std::exception) SAL_OVERRIDE;
 142
 143             // XCancellable
 144             void SAL_CALL cancel()              throw(RuntimeException, std::exception) SAL_OVERRIDE;
 145
 146             // XCloseable
 147             void SAL_CALL close()               throw(SQLException, RuntimeException, std::exception) SAL_OVERRIDE;
 148
 149             // XMultipleResults
 150             ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XResultSet > SAL_CALL getResultSet()
 151                                                 throw(SQLException, RuntimeException, std::exception) SAL_OVERRIDE;
 152
 153             sal_Int32 SAL_CALL getUpdateCount() throw(SQLException, RuntimeException, std::exception) SAL_OVERRIDE;
 154
 155             sal_Bool SAL_CALL getMoreResults()  throw(SQLException, RuntimeException, std::exception) SAL_OVERRIDE;
 156
 157             // other methods
 158             OConnection* getOwnConnection() const { return m_pConnection;}
 159
 160         private:
 161             using ::cppu::OPropertySetHelper::getFastPropertyValue;
 162         };
 163
 164
 165         class OStatement :  public OCommonStatement,
 166                             public ::com::sun::star::sdbc::XBatchExecution,
 167                             public ::com::sun::star::lang::XServiceInfo
 168
 169         {
 170         protected:
 171             virtual ~OStatement(){}
 172
 173         public:
 174             // A constructor which is required for the return of the objects
 175             OStatement(OConnection* _pConnection, sql::Statement *_cppStatement) :
 176                 OCommonStatement(_pConnection, _cppStatement) {}
 177
 178             virtual rtl::OUString SAL_CALL getImplementationName()
 179                 throw (css::uno::RuntimeException, std::exception) SAL_OVERRIDE;
 180
 181             virtual sal_Bool SAL_CALL supportsService(
 182                 rtl::OUString const & ServiceName) throw (css::uno::RuntimeException, std::exception)
 183                 SAL_OVERRIDE;
 184
 185             virtual css::uno::Sequence<rtl::OUString> SAL_CALL
 186             getSupportedServiceNames() throw (css::uno::RuntimeException, std::exception)
 187                 SAL_OVERRIDE;
 188
 189             Any SAL_CALL queryInterface( const ::com::sun::star::uno::Type & rType )
 190                                                 throw(RuntimeException, std::exception) SAL_OVERRIDE;
 191
 192             void SAL_CALL acquire()             throw() SAL_OVERRIDE;
 193             void SAL_CALL release()             throw() SAL_OVERRIDE;
 194
 195             // XBatchExecution
 196             void SAL_CALL addBatch(const rtl::OUString& sql)
 197                                                 throw(SQLException, RuntimeException, std::exception) SAL_OVERRIDE;
 198
 199             void SAL_CALL clearBatch()          throw(SQLException, RuntimeException, std::exception) SAL_OVERRIDE;
 200
 201             ::com::sun::star::uno::Sequence< sal_Int32 > SAL_CALL executeBatch()
 202                                                 throw(SQLException, RuntimeException, std::exception) SAL_OVERRIDE;
 203
 204         };
 205     }
 206 }
 207 #endif // INCLUDED_MYSQLC_SOURCE_MYSQLC_STATEMENT_HXX
 208
 209 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */