1 /************************************************************** 2 * 3 * Licensed to the Apache Software Foundation (ASF) under one 4 * or more contributor license agreements. See the NOTICE file 5 * distributed with this work for additional information 6 * regarding copyright ownership. The ASF licenses this file 7 * to you under the Apache License, Version 2.0 (the 8 * "License"); you may not use this file except in compliance 9 * with the License. You may obtain a copy of the License at 10 * 11 * http://www.apache.org/licenses/LICENSE-2.0 12 * 13 * Unless required by applicable law or agreed to in writing, 14 * software distributed under the License is distributed on an 15 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY 16 * KIND, either express or implied. See the License for the 17 * specific language governing permissions and limitations 18 * under the License. 19 * 20 *************************************************************/ 21 22 23 24 #ifndef _CONNECTIVITY_ODBC_OPREPAREDSTATEMENT_HXX_ 25 #define _CONNECTIVITY_ODBC_OPREPAREDSTATEMENT_HXX_ 26 27 #include "odbc/odbcbasedllapi.hxx" 28 #include "odbc/OStatement.hxx" 29 #include <com/sun/star/sdbc/XPreparedStatement.hpp> 30 #include <com/sun/star/sdbc/XParameters.hpp> 31 #include <com/sun/star/sdbc/XResultSetMetaDataSupplier.hpp> 32 #include <com/sun/star/sdbc/XPreparedBatchExecution.hpp> 33 #include <com/sun/star/io/XInputStream.hpp> 34 #include <cppuhelper/implbase5.hxx> 35 36 namespace connectivity 37 { 38 namespace odbc 39 { 40 41 class OBoundParam; 42 typedef ::cppu::ImplHelper5< ::com::sun::star::sdbc::XPreparedStatement, 43 ::com::sun::star::sdbc::XParameters, 44 ::com::sun::star::sdbc::XPreparedBatchExecution, 45 ::com::sun::star::sdbc::XResultSetMetaDataSupplier, 46 ::com::sun::star::lang::XServiceInfo> OPreparedStatement_BASE; 47 48 class OOO_DLLPUBLIC_ODBCBASE OPreparedStatement : 49 public OStatement_BASE2, 50 public OPreparedStatement_BASE 51 { 52 protected: 53 struct Parameter 54 { 55 ::com::sun::star::uno::Any aValue; 56 sal_Int32 nDataType; 57 Parameterconnectivity::odbc::OPreparedStatement::Parameter58 Parameter(const ::com::sun::star::uno::Any& rValue, 59 sal_Int32 rDataType) : aValue(rValue),nDataType(rDataType) 60 { 61 } 62 63 }; 64 65 ::std::vector< Parameter> m_aParameters; 66 //==================================================================== 67 // Data attributes 68 //==================================================================== 69 SQLSMALLINT numParams; // Number of parameter markers 70 // for the prepared statement 71 72 OBoundParam* boundParams; 73 // Array of bound parameter 74 // objects. Each parameter 75 // marker will have a 76 // corresponding object to 77 // hold bind information, and 78 // resulting data. 79 ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XResultSetMetaData > m_xMetaData; 80 sal_Bool m_bPrepared; 81 82 void FreeParams(); 83 void putParamData (sal_Int32 index) throw(::com::sun::star::sdbc::SQLException); 84 void setStream (sal_Int32 ParameterIndex,const ::com::sun::star::uno::Reference< ::com::sun::star::io::XInputStream>& x, 85 SQLLEN length,sal_Int32 SQLtype) throw(::com::sun::star::sdbc::SQLException); 86 sal_Int32 getParamLength ( sal_Int32 index); 87 sal_Int8* getLengthBuf (sal_Int32 index); 88 sal_Int8* getDataBuf (sal_Int32 index); 89 sal_Int8* allocBindBuf ( sal_Int32 index, sal_Int32 bufLen); 90 void initBoundParam () throw(::com::sun::star::sdbc::SQLException); 91 void setParameter(sal_Int32 parameterIndex,sal_Int32 _nType,sal_Int32 _nSize,void* _pData); 92 93 sal_Int32 getPrecision ( sal_Int32 sqlType); 94 isPrepared() const95 sal_Bool isPrepared() const { return m_bPrepared;} 96 void prepareStatement(); 97 void checkParameterIndex(sal_Int32 _parameterIndex); 98 void setDecimal( sal_Int32 parameterIndex, const ::rtl::OUString& x ); 99 100 /** 101 creates the driver specific resultset (factory) 102 */ 103 virtual OResultSet* createResulSet(); 104 105 protected: 106 virtual void SAL_CALL setFastPropertyValue_NoBroadcast(sal_Int32 nHandle, 107 const ::com::sun::star::uno::Any& rValue) 108 throw (::com::sun::star::uno::Exception); 109 public: 110 DECLARE_SERVICE_INFO(); 111 // ein Konstruktor, der fuer das Returnen des Objektes benoetigt wird: 112 OPreparedStatement( OConnection* _pConnection,const ::rtl::OUString& sql); 113 114 //XInterface 115 virtual ::com::sun::star::uno::Any SAL_CALL queryInterface( const ::com::sun::star::uno::Type & rType ) throw(::com::sun::star::uno::RuntimeException); 116 virtual void SAL_CALL acquire() throw(); 117 virtual void SAL_CALL release() throw(); 118 //XTypeProvider 119 virtual ::com::sun::star::uno::Sequence< ::com::sun::star::uno::Type > SAL_CALL getTypes( ) throw(::com::sun::star::uno::RuntimeException); 120 121 // XPreparedStatement 122 virtual ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XResultSet > SAL_CALL executeQuery( ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 123 virtual sal_Int32 SAL_CALL executeUpdate( ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 124 virtual sal_Bool SAL_CALL execute( ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 125 virtual ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XConnection > SAL_CALL getConnection( ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 126 // XParameters 127 virtual void SAL_CALL setNull( sal_Int32 parameterIndex, sal_Int32 sqlType ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 128 virtual void SAL_CALL setObjectNull( sal_Int32 parameterIndex, sal_Int32 sqlType, const ::rtl::OUString& typeName ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 129 virtual void SAL_CALL setBoolean( sal_Int32 parameterIndex, sal_Bool x ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 130 virtual void SAL_CALL setByte( sal_Int32 parameterIndex, sal_Int8 x ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 131 virtual void SAL_CALL setShort( sal_Int32 parameterIndex, sal_Int16 x ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 132 virtual void SAL_CALL setInt( sal_Int32 parameterIndex, sal_Int32 x ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 133 virtual void SAL_CALL setLong( sal_Int32 parameterIndex, sal_Int64 x ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 134 virtual void SAL_CALL setFloat( sal_Int32 parameterIndex, float x ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 135 virtual void SAL_CALL setDouble( sal_Int32 parameterIndex, double x ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 136 virtual void SAL_CALL setString( sal_Int32 parameterIndex, const ::rtl::OUString& x ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 137 virtual void SAL_CALL setBytes( sal_Int32 parameterIndex, const ::com::sun::star::uno::Sequence< sal_Int8 >& x ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 138 virtual void SAL_CALL setDate( sal_Int32 parameterIndex, const ::com::sun::star::util::Date& x ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 139 virtual void SAL_CALL setTime( sal_Int32 parameterIndex, const ::com::sun::star::util::Time& x ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 140 virtual void SAL_CALL setTimestamp( sal_Int32 parameterIndex, const ::com::sun::star::util::DateTime& x ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 141 virtual void SAL_CALL setBinaryStream( sal_Int32 parameterIndex, const ::com::sun::star::uno::Reference< ::com::sun::star::io::XInputStream >& x, sal_Int32 length ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 142 virtual void SAL_CALL setCharacterStream( sal_Int32 parameterIndex, const ::com::sun::star::uno::Reference< ::com::sun::star::io::XInputStream >& x, sal_Int32 length ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 143 virtual void SAL_CALL setObject( sal_Int32 parameterIndex, const ::com::sun::star::uno::Any& x ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 144 virtual void SAL_CALL setObjectWithInfo( sal_Int32 parameterIndex, const ::com::sun::star::uno::Any& x, sal_Int32 targetSqlType, sal_Int32 scale ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 145 virtual void SAL_CALL setRef( sal_Int32 parameterIndex, const ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XRef >& x ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 146 virtual void SAL_CALL setBlob( sal_Int32 parameterIndex, const ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XBlob >& x ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 147 virtual void SAL_CALL setClob( sal_Int32 parameterIndex, const ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XClob >& x ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 148 virtual void SAL_CALL setArray( sal_Int32 parameterIndex, const ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XArray >& x ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 149 virtual void SAL_CALL clearParameters( ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 150 // XPreparedBatchExecution 151 virtual void SAL_CALL addBatch( ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 152 virtual void SAL_CALL clearBatch( ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 153 virtual ::com::sun::star::uno::Sequence< sal_Int32 > SAL_CALL executeBatch( ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 154 // XCloseable 155 virtual void SAL_CALL close( ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 156 // XResultSetMetaDataSupplier 157 virtual ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XResultSetMetaData > SAL_CALL getMetaData( ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException); 158 159 public: 160 using OStatement_Base::executeQuery; 161 using OStatement_Base::executeUpdate; 162 using OStatement_Base::execute; 163 }; 164 } 165 } 166 #endif // _CONNECTIVITY_ODBC_OPREPAREDSTATEMENT_HXX_ 167 168