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