connectivity/source/inc/ado/ADatabaseMetaDataResultSet.hxx

   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: ADatabaseMetaDataResultSet.hxx,v $
  10  * $Revision: 1.13 $
  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 #ifndef _CONNECTIVITY_ADO_ADATABASEMETADATARESULTSET_HXX_
  32 #define _CONNECTIVITY_ADO_ADATABASEMETADATARESULTSET_HXX_
  33
  34 #include <com/sun/star/sdbc/XResultSet.hpp>
  35 #include <com/sun/star/sdbc/XRow.hpp>
  36 #include <com/sun/star/sdbc/XResultSetMetaDataSupplier.hpp>
  37 #include <com/sun/star/sdbc/XCloseable.hpp>
  38 #include <com/sun/star/sdbc/XColumnLocate.hpp>
  39 #include <com/sun/star/util/XCancellable.hpp>
  40 #include <com/sun/star/sdbc/XWarningsSupplier.hpp>
  41 #include <com/sun/star/sdbc/XResultSetUpdate.hpp>
  42 #include <com/sun/star/sdbc/XRowUpdate.hpp>
  43 #include <cppuhelper/compbase7.hxx>
  44 #include <comphelper/proparrhlp.hxx>
  45 #include "ado/AStatement.hxx"
  46 //#ifndef _CONNECTIVITY_COMMONTOOLS_HXX_
  47 //#include "connectivity/CommonTools.hxx"
  48 //#endif
  49 #include <comphelper/broadcasthelper.hxx>
  50 #include "connectivity/StdTypeDefs.hxx"
  51
  52 namespace connectivity
  53 {
  54     namespace ado
  55     {
  56         class ODatabaseMetaDataResultSetMetaData;
  57         /*
  58         **      java_sql_ResultSet
  59         */
  60         typedef ::cppu::WeakComponentImplHelper7<       ::com::sun::star::sdbc::XResultSet,
  61                                                     ::com::sun::star::sdbc::XRow,
  62                                                     ::com::sun::star::sdbc::XResultSetMetaDataSupplier,
  63                                                     ::com::sun::star::util::XCancellable,
  64                                                     ::com::sun::star::sdbc::XWarningsSupplier,
  65                                                     ::com::sun::star::sdbc::XCloseable,
  66                                                     ::com::sun::star::sdbc::XColumnLocate> ODatabaseMetaDataResultSet_BASE;
  67
  68         class ODatabaseMetaDataResultSet :      public comphelper::OBaseMutex,
  69                                     public      ODatabaseMetaDataResultSet_BASE,
  70                                     public      ::cppu::OPropertySetHelper,
  71                                     public      ::comphelper::OPropertyArrayUsageHelper<ODatabaseMetaDataResultSet>
  72         {
  73             ::std::vector<sal_Int32>            m_aColMapping; // pos 0 is unused so we don't have to decrement 1 everytime
  74
  75             ::std::map<sal_Int32, TInt2IntMap > m_aValueRange;
  76             ::std::map<sal_Int32, TInt2IntMap >::iterator       m_aValueRangeIter;
  77
  78             ::std::map<sal_Int32, ::std::map< ::rtl::OUString,sal_Int32> >                              m_aStrValueRange;
  79             ::std::map<sal_Int32, ::std::map< ::rtl::OUString,sal_Int32> >::iterator    m_aStrValueRangeIter;
  80
  81             ::std::map<sal_Int32, ::std::map< sal_Int32,::rtl::OUString> >                              m_aIntValueRange;
  82             ::std::map<sal_Int32, ::std::map< sal_Int32,::rtl::OUString> >::iterator    m_aIntValueRangeIter;
  83
  84             ADORecordset*                                       m_pRecordSet;
  85                         ::com::sun::star::uno::WeakReferenceHelper    m_aStatement;
  86                         ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XResultSetMetaData>        m_xMetaData;
  87             OLEVariant                                          m_aValue;
  88             sal_Int32                                           m_nRowPos;
  89             sal_Bool                                            m_bWasNull;
  90             sal_Bool                                            m_bEOF;
  91             sal_Bool                                            m_bOnFirstAfterOpen;
  92
  93             sal_Int32 getResultSetConcurrency() const throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
  94             sal_Int32 getResultSetType()                const throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
  95             sal_Int32 getFetchDirection()               const throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
  96             sal_Int32 getFetchSize()                    const throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
  97             ::rtl::OUString getCursorName()             const throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
  98
  99             void setFetchDirection(sal_Int32 _par0) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 100             void setFetchSize(sal_Int32 _par0) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 101
 102
 103             inline sal_Int32 mapColumn (sal_Int32       column);
 104             void checkRecordSet() throw(::com::sun::star::sdbc::SQLException);
 105             OLEVariant getValue(sal_Int32 columnIndex ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 106
 107         protected:
 108
 109             // OPropertyArrayUsageHelper
 110             virtual ::cppu::IPropertyArrayHelper* createArrayHelper( ) const;
 111             // OPropertySetHelper
 112             virtual ::cppu::IPropertyArrayHelper & SAL_CALL getInfoHelper();
 113
 114             virtual sal_Bool SAL_CALL convertFastPropertyValue(
 115                                                                 ::com::sun::star::uno::Any & rConvertedValue,
 116                                                                 ::com::sun::star::uno::Any & rOldValue,
 117                                 sal_Int32 nHandle,
 118                                                                 const ::com::sun::star::uno::Any& rValue )
 119                                     throw (::com::sun::star::lang::IllegalArgumentException);
 120             virtual void SAL_CALL setFastPropertyValue_NoBroadcast(
 121                                     sal_Int32 nHandle,
 122                                                                         const ::com::sun::star::uno::Any& rValue
 123                                                      )
 124                                                                                                          throw (::com::sun::star::uno::Exception);
 125             virtual void SAL_CALL getFastPropertyValue(
 126                                                                         ::com::sun::star::uno::Any& rValue,
 127                                     sal_Int32 nHandle
 128                                          ) const;
 129         public:
 130             // ein Konstruktor, der fuer das Returnen des Objektes benoetigt wird:
 131             ODatabaseMetaDataResultSet( ADORecordset* _pRecordSet);
 132             ~ODatabaseMetaDataResultSet();
 133
 134             // ::cppu::OComponentHelper
 135             virtual void SAL_CALL disposing(void);
 136             // XInterface
 137             virtual ::com::sun::star::uno::Any SAL_CALL queryInterface( const ::com::sun::star::uno::Type & rType ) throw(::com::sun::star::uno::RuntimeException);
 138             virtual void SAL_CALL acquire() throw();
 139             virtual void SAL_CALL release() throw();
 140             //XTypeProvider
 141             virtual ::com::sun::star::uno::Sequence< ::com::sun::star::uno::Type > SAL_CALL getTypes(  ) throw(::com::sun::star::uno::RuntimeException);
 142             // XPropertySet
 143             virtual ::com::sun::star::uno::Reference< ::com::sun::star::beans::XPropertySetInfo > SAL_CALL getPropertySetInfo(  ) throw(::com::sun::star::uno::RuntimeException);
 144             // XResultSet
 145             virtual sal_Bool SAL_CALL next(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 146             virtual sal_Bool SAL_CALL isBeforeFirst(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 147             virtual sal_Bool SAL_CALL isAfterLast(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 148             virtual sal_Bool SAL_CALL isFirst(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 149             virtual sal_Bool SAL_CALL isLast(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 150             virtual void SAL_CALL beforeFirst(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 151             virtual void SAL_CALL afterLast(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 152             virtual sal_Bool SAL_CALL first(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 153             virtual sal_Bool SAL_CALL last(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 154             virtual sal_Int32 SAL_CALL getRow(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 155             virtual sal_Bool SAL_CALL absolute( sal_Int32 row ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 156             virtual sal_Bool SAL_CALL relative( sal_Int32 rows ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 157             virtual sal_Bool SAL_CALL previous(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 158             virtual void SAL_CALL refreshRow(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 159             virtual sal_Bool SAL_CALL rowUpdated(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 160             virtual sal_Bool SAL_CALL rowInserted(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 161             virtual sal_Bool SAL_CALL rowDeleted(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 162             virtual ::com::sun::star::uno::Reference< ::com::sun::star::uno::XInterface > SAL_CALL getStatement(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 163             // XRow
 164             virtual sal_Bool SAL_CALL wasNull(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 165             virtual ::rtl::OUString SAL_CALL getString( sal_Int32 columnIndex ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 166             virtual sal_Bool SAL_CALL getBoolean( sal_Int32 columnIndex ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 167             virtual sal_Int8 SAL_CALL getByte( sal_Int32 columnIndex ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 168             virtual sal_Int16 SAL_CALL getShort( sal_Int32 columnIndex ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 169             virtual sal_Int32 SAL_CALL getInt( sal_Int32 columnIndex ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 170             virtual sal_Int64 SAL_CALL getLong( sal_Int32 columnIndex ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 171             virtual float SAL_CALL getFloat( sal_Int32 columnIndex ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 172             virtual double SAL_CALL getDouble( sal_Int32 columnIndex ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 173             virtual ::com::sun::star::uno::Sequence< sal_Int8 > SAL_CALL getBytes( sal_Int32 columnIndex ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 174             virtual ::com::sun::star::util::Date SAL_CALL getDate( sal_Int32 columnIndex ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 175             virtual ::com::sun::star::util::Time SAL_CALL getTime( sal_Int32 columnIndex ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 176             virtual ::com::sun::star::util::DateTime SAL_CALL getTimestamp( sal_Int32 columnIndex ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 177             virtual ::com::sun::star::uno::Reference< ::com::sun::star::io::XInputStream > SAL_CALL getBinaryStream( sal_Int32 columnIndex ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 178             virtual ::com::sun::star::uno::Reference< ::com::sun::star::io::XInputStream > SAL_CALL getCharacterStream( sal_Int32 columnIndex ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 179             virtual ::com::sun::star::uno::Any SAL_CALL getObject( sal_Int32 columnIndex, const ::com::sun::star::uno::Reference< ::com::sun::star::container::XNameAccess >& typeMap ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 180             virtual ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XRef > SAL_CALL getRef( sal_Int32 columnIndex ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 181             virtual ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XBlob > SAL_CALL getBlob( sal_Int32 columnIndex ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 182             virtual ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XClob > SAL_CALL getClob( sal_Int32 columnIndex ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 183             virtual ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XArray > SAL_CALL getArray( sal_Int32 columnIndex ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 184             // XResultSetMetaDataSupplier
 185             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);
 186             // XCancellable
 187             virtual void SAL_CALL cancel(  ) throw(::com::sun::star::uno::RuntimeException);
 188             // XCloseable
 189             virtual void SAL_CALL close(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 190             // XWarningsSupplier
 191             virtual ::com::sun::star::uno::Any SAL_CALL getWarnings(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 192             virtual void SAL_CALL clearWarnings(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 193             // XColumnLocate
 194             virtual sal_Int32 SAL_CALL findColumn( const ::rtl::OUString& columnName ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 195
 196             const ::std::vector<sal_Int32>& getColumnMapping() { return m_aColMapping; }
 197
 198             void setCatalogsMap();
 199             void setSchemasMap();
 200             void setColumnPrivilegesMap();
 201             void setColumnsMap();
 202             void setTablesMap();
 203             void setProcedureColumnsMap();
 204             void setProceduresMap();
 205             void setExportedKeysMap();
 206             void setImportedKeysMap();
 207             void setPrimaryKeysMap();
 208             void setIndexInfoMap();
 209             void setTablePrivilegesMap();
 210             void setCrossReferenceMap();
 211             void setTypeInfoMap(sal_Bool _bJetEngine);
 212         };
 213         // -------------------------------------------------------------------------
 214         inline sal_Int32 ODatabaseMetaDataResultSet::mapColumn (sal_Int32       column)
 215         {
 216             sal_Int32   map = column;
 217
 218             if (!m_aColMapping.empty())
 219             {
 220                 // Validate column number
 221                 map = m_aColMapping[column];
 222             }
 223
 224             return map;
 225         }
 226     }
 227
 228 }
 229 #endif // _CONNECTIVITY_ADO_ADATABASEMETADATARESULTSET_HXX_
 230