xref: /aoo41x/main/dbaccess/source/core/api/KeySet.cxx (revision c82f2877)
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 // MARKER(update_precomp.py): autogen include statement, do not remove
25 #include "precompiled_dbaccess.hxx"
26 
27 #ifndef DBACCESS_CORE_API_KEYSET_HXX
28 #include "KeySet.hxx"
29 #endif
30 #ifndef _DBA_CORE_RESOURCE_HXX_
31 #include "core_resource.hxx"
32 #endif
33 #ifndef _DBA_CORE_RESOURCE_HRC_
34 #include "core_resource.hrc"
35 #endif
36 #ifndef _COM_SUN_STAR_BEANS_XPROPERTYSET_HPP_
37 #include <com/sun/star/beans/XPropertySet.hpp>
38 #endif
39 #ifndef _COM_SUN_STAR_SDBC_XDATABASEMETADATA_HPP_
40 #include <com/sun/star/sdbc/XDatabaseMetaData.hpp>
41 #endif
42 #include <com/sun/star/sdbc/ColumnValue.hpp>
43 #ifndef _COM_SUN_STAR_SDBC_XPREPAREDSTATEMENT_HPP_
44 #include <com/sun/star/sdbc/XPreparedStatement.hpp>
45 #endif
46 #ifndef _COM_SUN_STAR_SDBCxParameterS_HPP_
47 #include <com/sun/star/sdbc/XParameters.hpp>
48 #endif
49 #ifndef _COM_SUN_STAR_SDBC_XGENERATEDRESULTSET_HPP_
50 #include <com/sun/star/sdbc/XGeneratedResultSet.hpp>
51 #endif
52 #ifndef _COM_SUN_STAR_SDBC_XCOLUMNLOCATE_HPP_
53 #include <com/sun/star/sdbc/XColumnLocate.hpp>
54 #endif
55 #ifndef _COM_SUN_STAR_CONTAINER_XINDEXACCESS_HPP_
56 #include <com/sun/star/container/XIndexAccess.hpp>
57 #endif
58 #ifndef DBACCESS_SHARED_DBASTRINGS_HRC
59 #include "dbastrings.hrc"
60 #endif
61 #ifndef _DBASHARED_APITOOLS_HXX_
62 #include "apitools.hxx"
63 #endif
64 #ifndef _COM_SUN_STAR_SDBCX_XKEYSSUPPLIER_HPP_
65 #include <com/sun/star/sdbcx/XKeysSupplier.hpp>
66 #endif
67 #ifndef _COM_SUN_STAR_SDB_XSINGLESELECTQUERYCOMPOSER_HPP_
68 #include <com/sun/star/sdb/XSingleSelectQueryComposer.hpp>
69 #endif
70 #ifndef _COM_SUN_STAR_SDBCX_XINDEXESSUPPLIER_HPP_
71 #include <com/sun/star/sdbcx/XIndexesSupplier.hpp>
72 #endif
73 #ifndef _CPPUHELPER_TYPEPROVIDER_HXX_
74 #include <cppuhelper/typeprovider.hxx>
75 #endif
76 #ifndef _COMPHELPER_TYPES_HXX_
77 #include <comphelper/types.hxx>
78 #endif
79 #ifndef _COM_SUN_STAR_SDBCX_KEYTYPE_HPP_
80 #include <com/sun/star/sdbcx/KeyType.hpp>
81 #endif
82 #ifndef _CONNECTIVITY_DBTOOLS_HXX_
83 #include <connectivity/dbtools.hxx>
84 #endif
85 #ifndef _DBHELPER_DBEXCEPTION_HXX_
86 #include <connectivity/dbexception.hxx>
87 #endif
88 #include <list>
89 #include <algorithm>
90 #include <string.h>
91 #ifndef _COM_SUN_STAR_IO_XINPUTSTREAM_HPP_
92 #include <com/sun/star/io/XInputStream.hpp>
93 #endif
94 #ifndef _COM_SUN_STAR_SDBCX_XTABLESSUPPLIER_HPP_
95 #include <com/sun/star/sdbcx/XTablesSupplier.hpp>
96 #endif
97 #ifndef DBACCESS_CORE_API_QUERYCOMPOSER_HXX
98 #include "querycomposer.hxx"
99 #endif
100 #ifndef DBACCESS_SOURCE_CORE_INC_COMPOSERTOOLS_HXX
101 #include "composertools.hxx"
102 #endif
103 #ifndef _TOOLS_DEBUG_HXX
104 #include <tools/debug.hxx>
105 #endif
106 #include <string.h>
107 #include <rtl/logfile.hxx>
108 #include "PrivateRow.hxx"
109 
110 using namespace dbaccess;
111 using namespace ::connectivity;
112 using namespace ::dbtools;
113 using namespace ::com::sun::star::uno;
114 using namespace ::com::sun::star::beans;
115 using namespace ::com::sun::star::sdbc;
116 using namespace ::com::sun::star::sdb;
117 using namespace ::com::sun::star::sdbcx;
118 using namespace ::com::sun::star::container;
119 using namespace ::com::sun::star::lang;
120 using namespace ::com::sun::star::util;
121 using namespace ::com::sun::star::io;
122 using namespace ::com::sun::star;
123 using namespace ::cppu;
124 using namespace ::osl;
125 
126 namespace
127 {
lcl_fillIndexColumns(const Reference<XIndexAccess> & _xIndexes,::std::vector<Reference<XNameAccess>> & _rAllIndexColumns)128 	void lcl_fillIndexColumns(const Reference<XIndexAccess>& _xIndexes, ::std::vector< Reference<XNameAccess> >& _rAllIndexColumns)
129 	{
130 		if ( _xIndexes.is() )
131 		{
132 			Reference<XPropertySet> xIndexColsSup;
133 			sal_Int32 nCount = _xIndexes->getCount();
134 			for(sal_Int32 j = 0 ; j < nCount ; ++j)
135 			{
136 				xIndexColsSup.set(_xIndexes->getByIndex(j),UNO_QUERY);
137 				if(	xIndexColsSup.is()
138 					&& comphelper::getBOOL(xIndexColsSup->getPropertyValue(PROPERTY_ISUNIQUE))
139 					&& !comphelper::getBOOL(xIndexColsSup->getPropertyValue(PROPERTY_ISPRIMARYKEYINDEX))
140 				)
141 					_rAllIndexColumns.push_back(Reference<XColumnsSupplier>(xIndexColsSup,UNO_QUERY)->getColumns());
142 			}
143 		}
144 	}
145 }
DBG_NAME(OKeySet)146 DBG_NAME(OKeySet)
147 // -------------------------------------------------------------------------
148 OKeySet::OKeySet(const connectivity::OSQLTable& _xTable,
149                  const Reference< XIndexAccess>& _xTableKeys,
150 				 const ::rtl::OUString& _rUpdateTableName,	  // this can be the alias or the full qualified name
151 				 const Reference< XSingleSelectQueryAnalyzer >& _xComposer,
152                  const ORowSetValueVector& _aParameterValueForCache,
153                  sal_Int32 i_nMaxRows,
154                  sal_Int32& o_nRowCount)
155             :OCacheSet(i_nMaxRows)
156             ,m_aParameterValueForCache(_aParameterValueForCache)
157             ,m_pKeyColumnNames(NULL)
158 			,m_pColumnNames(NULL)
159             ,m_pParameterNames(NULL)
160             ,m_pForeignColumnNames(NULL)
161 			,m_xTable(_xTable)
162             ,m_xTableKeys(_xTableKeys)
163 			,m_xComposer(_xComposer)
164 			,m_sUpdateTableName(_rUpdateTableName)
165             ,m_rRowCount(o_nRowCount)
166 			,m_bRowCountFinal(sal_False)
167 {
168     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::OKeySet" );
169     DBG_CTOR(OKeySet,NULL);
170 
171 }
172 // -----------------------------------------------------------------------------
~OKeySet()173 OKeySet::~OKeySet()
174 {
175 	try
176 	{
177 		::comphelper::disposeComponent(m_xStatement);
178 	}
179 	catch(Exception&)
180 	{
181 		m_xStatement = NULL;
182 	}
183 	catch(...)
184 	{
185 		OSL_ENSURE(0,"Unknown Exception occured");
186 	}
187 	m_xComposer = NULL;
188 
189     DBG_DTOR(OKeySet,NULL);
190 }
initColumns()191 void OKeySet::initColumns()
192 {
193     Reference<XDatabaseMetaData> xMeta = m_xConnection->getMetaData();
194     bool bCase = (xMeta.is() && xMeta->supportsMixedCaseQuotedIdentifiers()) ? true : false;
195     m_pKeyColumnNames.reset( new SelectColumnsMetaData(bCase) );
196     m_pColumnNames.reset( new SelectColumnsMetaData(bCase) );
197     m_pParameterNames.reset( new SelectColumnsMetaData(bCase) );
198     m_pForeignColumnNames.reset( new SelectColumnsMetaData(bCase) );
199 }
findTableColumnsMatching_throw(const Any & i_aTable,const::rtl::OUString & i_rUpdateTableName,const Reference<XDatabaseMetaData> & i_xMeta,const Reference<XNameAccess> & i_xQueryColumns,::std::auto_ptr<SelectColumnsMetaData> & o_pKeyColumnNames)200 void OKeySet::findTableColumnsMatching_throw(   const Any& i_aTable,
201                                                 const ::rtl::OUString& i_rUpdateTableName,
202                                                 const Reference<XDatabaseMetaData>& i_xMeta,
203                                                 const Reference<XNameAccess>& i_xQueryColumns,
204                                                 ::std::auto_ptr<SelectColumnsMetaData>& o_pKeyColumnNames)
205 {
206     // first ask the database itself for the best columns which can be used
207     Sequence< ::rtl::OUString> aBestColumnNames;
208     Reference<XNameAccess> xKeyColumns	= getPrimaryKeyColumns_throw(i_aTable);
209     if ( xKeyColumns.is() )
210         aBestColumnNames = xKeyColumns->getElementNames();
211 
212     const Reference<XColumnsSupplier> xTblColSup(i_aTable,UNO_QUERY_THROW);
213     const Reference<XNameAccess> xTblColumns = xTblColSup->getColumns();
214     // locate parameter in select columns
215     Reference<XParametersSupplier> xParaSup(m_xComposer,UNO_QUERY);
216     Reference<XIndexAccess> xQueryParameters = xParaSup->getParameters();
217     const sal_Int32 nParaCount = xQueryParameters->getCount();
218     Sequence< ::rtl::OUString> aParameterColumns(nParaCount);
219     for(sal_Int32 i = 0; i< nParaCount;++i)
220     {
221         Reference<XPropertySet> xPara(xQueryParameters->getByIndex(i),UNO_QUERY_THROW);
222         xPara->getPropertyValue(PROPERTY_REALNAME) >>= aParameterColumns[i];
223     }
224 
225     ::rtl::OUString sUpdateTableName( i_rUpdateTableName );
226     if ( sUpdateTableName.getLength() == 0 )
227     {
228         OSL_ENSURE( false, "OKeySet::findTableColumnsMatching_throw: This is a fallback only - it won't work when the table has an alias name." );
229         // If i_aTable originates from a query composer, and is a table which appears with an alias in the SELECT statement,
230         // then the below code will not produce correct results.
231         // For instance, imagine a "SELECT alias.col FROM table AS alias". Now i_aTable would be the table named
232         // "table", so our sUpdateTableName would be "table" as well - not the information about the "alias" is
233         // already lost here.
234         // now getColumnPositions would travers the columns, and check which of them belong to the table denoted
235         // by sUpdateTableName. Since the latter is "table", but the columns only know that they belong to a table
236         // named "alias", there will be no matching - so getColumnPositions wouldn't find anything.
237 
238         ::rtl::OUString sCatalog, sSchema, sTable;
239 	    Reference<XPropertySet> xTableProp( i_aTable, UNO_QUERY_THROW );
240         xTableProp->getPropertyValue( PROPERTY_CATALOGNAME )>>= sCatalog;
241 	    xTableProp->getPropertyValue( PROPERTY_SCHEMANAME ) >>= sSchema;
242 	    xTableProp->getPropertyValue( PROPERTY_NAME )       >>= sTable;
243         sUpdateTableName = dbtools::composeTableName( i_xMeta, sCatalog, sSchema, sTable, sal_False, ::dbtools::eInDataManipulation );
244     }
245 
246     ::dbaccess::getColumnPositions(i_xQueryColumns,aBestColumnNames,sUpdateTableName,(*o_pKeyColumnNames),true);
247     ::dbaccess::getColumnPositions(i_xQueryColumns,xTblColumns->getElementNames(),sUpdateTableName,(*m_pColumnNames),true);
248     ::dbaccess::getColumnPositions(i_xQueryColumns,aParameterColumns,sUpdateTableName,(*m_pParameterNames),true);
249 
250     if ( o_pKeyColumnNames->empty() )
251     {
252         ::dbtools::throwGenericSQLException( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( "Could not find any key column." ) ), *this );
253     }
254 
255 	for (   SelectColumnsMetaData::const_iterator keyColumn = o_pKeyColumnNames->begin();
256             keyColumn != o_pKeyColumnNames->end();
257             ++keyColumn
258         )
259 	{
260 		if ( !xTblColumns->hasByName( keyColumn->second.sRealName ) )
261             continue;
262 
263         Reference<XPropertySet> xProp( xTblColumns->getByName( keyColumn->second.sRealName ), UNO_QUERY );
264 		sal_Bool bAuto = sal_False;
265 		if ( ( xProp->getPropertyValue( PROPERTY_ISAUTOINCREMENT ) >>= bAuto ) && bAuto )
266 			m_aAutoColumns.push_back( keyColumn->first );
267 	}
268 }
createKeyFilter()269 ::rtl::OUStringBuffer OKeySet::createKeyFilter()
270 {
271     static ::rtl::OUString aAnd		= ::rtl::OUString::createFromAscii(" AND ");
272 	const ::rtl::OUString aQuote	= getIdentifierQuoteString();
273     ::rtl::OUStringBuffer aFilter;
274 	static ::rtl::OUString s_sDot(RTL_CONSTASCII_USTRINGPARAM("."));
275 	static ::rtl::OUString s_sParam(RTL_CONSTASCII_USTRINGPARAM(" = ?"));
276 	// create the where clause
277     Reference<XDatabaseMetaData> xMeta = m_xConnection->getMetaData();
278     SelectColumnsMetaData::iterator aPosEnd = m_pKeyColumnNames->end();
279 	for(SelectColumnsMetaData::iterator aPosIter = m_pKeyColumnNames->begin();aPosIter != aPosEnd;)
280 	{
281         aFilter.append(::dbtools::quoteTableName( xMeta,aPosIter->second.sTableName,::dbtools::eInDataManipulation));
282 		aFilter.append(s_sDot);
283 		aFilter.append(::dbtools::quoteName( aQuote,aPosIter->second.sRealName));
284 		aFilter.append(s_sParam);
285 		++aPosIter;
286 		if(aPosIter != aPosEnd)
287 			aFilter.append(aAnd);
288 	}
289     return aFilter;
290 }
291 // -----------------------------------------------------------------------------
construct(const Reference<XResultSet> & _xDriverSet,const::rtl::OUString & i_sRowSetFilter)292 void OKeySet::construct(const Reference< XResultSet>& _xDriverSet,const ::rtl::OUString& i_sRowSetFilter)
293 {
294     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::construct" );
295 	OCacheSet::construct(_xDriverSet,i_sRowSetFilter);
296     initColumns();
297 
298 	Reference<XNameAccess> xKeyColumns	= getKeyColumns();
299     Reference<XDatabaseMetaData> xMeta = m_xConnection->getMetaData();
300     Reference<XColumnsSupplier> xQueryColSup(m_xComposer,UNO_QUERY);
301     const Reference<XNameAccess> xQueryColumns = xQueryColSup->getColumns();
302     findTableColumnsMatching_throw(makeAny(m_xTable),m_sUpdateTableName,xMeta,xQueryColumns,m_pKeyColumnNames);
303 
304 	// the first row is empty because it's now easier for us to distinguish	when we are beforefirst or first
305 	// without extra varaible to be set
306     m_aKeyMap.insert(OKeySetMatrix::value_type(0,OKeySetValue(NULL,::std::pair<sal_Int32,Reference<XRow> >(0,NULL))));
307 	m_aKeyIter = m_aKeyMap.begin();
308 
309     ::rtl::OUStringBuffer aFilter = createKeyFilter();
310 
311     Reference< XSingleSelectQueryComposer> xSourceComposer(m_xComposer,UNO_QUERY);
312 	Reference< XMultiServiceFactory >  xFactory(m_xConnection, UNO_QUERY_THROW);
313 	Reference<XSingleSelectQueryComposer> xAnalyzer(xFactory->createInstance(SERVICE_NAME_SINGLESELECTQUERYCOMPOSER),UNO_QUERY);
314 	xAnalyzer->setElementaryQuery(xSourceComposer->getElementaryQuery());
315 	Reference<XTablesSupplier> xTabSup(xAnalyzer,uno::UNO_QUERY);
316 	Reference<XNameAccess> xSelectTables(xTabSup->getTables(),uno::UNO_QUERY);
317     const Sequence< ::rtl::OUString> aSeq = xSelectTables->getElementNames();
318 	if ( aSeq.getLength() > 1 ) // special handling for join
319 	{
320         static ::rtl::OUString aAnd		= ::rtl::OUString::createFromAscii(" AND ");
321 	    const ::rtl::OUString aQuote	= getIdentifierQuoteString();
322 	    static ::rtl::OUString s_sDot(RTL_CONSTASCII_USTRINGPARAM("."));
323 	    static ::rtl::OUString s_sParam(RTL_CONSTASCII_USTRINGPARAM(" = ?"));
324         const ::rtl::OUString* pIter = aSeq.getConstArray();
325         const ::rtl::OUString* pEnd	  = pIter + aSeq.getLength();
326         for(;pIter != pEnd;++pIter)
327 		{
328 			if ( *pIter != m_sUpdateTableName )
329 			{
330                 connectivity::OSQLTable xSelColSup(xSelectTables->getByName(*pIter),uno::UNO_QUERY);
331                 Reference<XPropertySet> xProp(xSelColSup,uno::UNO_QUERY);
332 			    ::rtl::OUString sSelectTableName = ::dbtools::composeTableName( xMeta, xProp, ::dbtools::eInDataManipulation, false, false, false );
333 
334 				::dbaccess::getColumnPositions(xQueryColumns,xSelColSup->getColumns()->getElementNames(),sSelectTableName,(*m_pForeignColumnNames));
335 
336 				SelectColumnsMetaData::iterator aPosEnd = (*m_pForeignColumnNames).end();
337 	            for(SelectColumnsMetaData::iterator aPosIter = (*m_pForeignColumnNames).begin();aPosIter != aPosEnd;++aPosIter)
338 				{
339 					// look for columns not in the source columns to use them as filter as well
340 					// if ( !xSourceColumns->hasByName(aPosIter->first) )
341 					{
342                         if ( aFilter.getLength() )
343                             aFilter.append(aAnd);
344                         aFilter.append(::dbtools::quoteName( aQuote,sSelectTableName));
345 						aFilter.append(s_sDot);
346                         aFilter.append(::dbtools::quoteName( aQuote,aPosIter->second.sRealName));
347 						aFilter.append(s_sParam);
348 					}
349 				}
350 				break;
351 			}
352 		}
353 	} // if ( aSeq.getLength() > 1 ) // special handling for join
354     executeStatement(aFilter,i_sRowSetFilter,xAnalyzer);
355 }
executeStatement(::rtl::OUStringBuffer & io_aFilter,const::rtl::OUString & i_sRowSetFilter,Reference<XSingleSelectQueryComposer> & io_xAnalyzer)356 void OKeySet::executeStatement(::rtl::OUStringBuffer& io_aFilter,const ::rtl::OUString& i_sRowSetFilter,Reference<XSingleSelectQueryComposer>& io_xAnalyzer)
357 {
358     bool bFilterSet = i_sRowSetFilter.getLength() != 0;
359     if ( bFilterSet )
360     {
361         FilterCreator aFilterCreator;
362         aFilterCreator.append( i_sRowSetFilter );
363         aFilterCreator.append( io_aFilter.makeStringAndClear() );
364         io_aFilter = aFilterCreator.getComposedAndClear();
365     }
366     io_xAnalyzer->setFilter(io_aFilter.makeStringAndClear());
367     if ( bFilterSet )
368     {
369         Sequence< Sequence< PropertyValue > > aFilter2 = io_xAnalyzer->getStructuredFilter();
370         const Sequence< PropertyValue >* pOr = aFilter2.getConstArray();
371         const Sequence< PropertyValue >* pOrEnd = pOr + aFilter2.getLength();
372         for(;pOr != pOrEnd;++pOr)
373         {
374             const PropertyValue* pAnd = pOr->getConstArray();
375             const PropertyValue* pAndEnd = pAnd + pOr->getLength();
376             for(;pAnd != pAndEnd;++pAnd)
377             {
378                 ::rtl::OUString sValue;
379                 if ( !(pAnd->Value >>= sValue) || !(sValue.equalsAscii("?") || sValue.matchAsciiL(":",1,0)) )
380                 { // we have a criteria which has to be taken into account for updates
381                     m_aFilterColumns.push_back(pAnd->Name);
382                 }
383             }
384         }
385     }
386 	m_xStatement = m_xConnection->prepareStatement(io_xAnalyzer->getQueryWithSubstitution());
387 	::comphelper::disposeComponent(io_xAnalyzer);
388 }
389 // -------------------------------------------------------------------------
getBookmark()390 Any SAL_CALL OKeySet::getBookmark() throw(SQLException, RuntimeException)
391 {
392     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::getBookmark" );
393 	OSL_ENSURE(m_aKeyIter != m_aKeyMap.end() && m_aKeyIter != m_aKeyMap.begin(),
394 		"getBookmark is only possible when we stand on a valid row!");
395 	return makeAny(m_aKeyIter->first);
396 }
397 
398 // -------------------------------------------------------------------------
moveToBookmark(const Any & bookmark)399 sal_Bool SAL_CALL OKeySet::moveToBookmark( const Any& bookmark ) throw(SQLException, RuntimeException)
400 {
401     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::moveToBookmark" );
402 	m_bInserted = m_bUpdated = m_bDeleted = sal_False;
403 	m_aKeyIter = m_aKeyMap.find(::comphelper::getINT32(bookmark));
404 	return m_aKeyIter != m_aKeyMap.end();
405 }
406 // -------------------------------------------------------------------------
moveRelativeToBookmark(const Any & bookmark,sal_Int32 rows)407 sal_Bool SAL_CALL OKeySet::moveRelativeToBookmark( const Any& bookmark, sal_Int32 rows ) throw(SQLException, RuntimeException)
408 {
409     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::moveRelativeToBookmark" );
410 	m_bInserted = m_bUpdated = m_bDeleted = sal_False;
411 	m_aKeyIter = m_aKeyMap.find(::comphelper::getINT32(bookmark));
412 	if(m_aKeyIter != m_aKeyMap.end())
413 	{
414 		relative(rows);
415 	}
416 
417 	return !isBeforeFirst() && !isAfterLast();
418 }
419 // -------------------------------------------------------------------------
compareBookmarks(const Any & _first,const Any & _second)420 sal_Int32 SAL_CALL OKeySet::compareBookmarks( const Any& _first, const Any& _second ) throw(SQLException, RuntimeException)
421 {
422     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::compareBookmarks" );
423 	sal_Int32 nFirst = 0, nSecond = 0;
424 	_first >>= nFirst;
425 	_second >>= nSecond;
426 
427 	return (nFirst != nSecond) ? CompareBookmark::NOT_EQUAL : CompareBookmark::EQUAL;
428 }
429 // -------------------------------------------------------------------------
hasOrderedBookmarks()430 sal_Bool SAL_CALL OKeySet::hasOrderedBookmarks(  ) throw(SQLException, RuntimeException)
431 {
432     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::hasOrderedBookmarks" );
433 	return sal_True;
434 }
435 // -------------------------------------------------------------------------
hashBookmark(const Any & bookmark)436 sal_Int32 SAL_CALL OKeySet::hashBookmark( const Any& bookmark ) throw(SQLException, RuntimeException)
437 {
438     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::hashBookmark" );
439 	return ::comphelper::getINT32(bookmark);
440 }
441 // -------------------------------------------------------------------------
442 // ::com::sun::star::sdbcx::XDeleteRows
deleteRows(const Sequence<Any> & rows,const connectivity::OSQLTable & _xTable)443 Sequence< sal_Int32 > SAL_CALL OKeySet::deleteRows( const Sequence< Any >& rows ,const connectivity::OSQLTable& _xTable) throw(SQLException, RuntimeException)
444 {
445     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::deleteRows" );
446 	Reference<XPropertySet> xSet(_xTable,UNO_QUERY);
447 	fillTableName(xSet);
448 
449 	::rtl::OUStringBuffer aSql = ::rtl::OUString::createFromAscii("DELETE FROM ");
450 	aSql.append(m_aComposedTableName);
451 	aSql.append(::rtl::OUString::createFromAscii(" WHERE "));
452 
453 	// list all cloumns that should be set
454 	const ::rtl::OUString aQuote	= getIdentifierQuoteString();
455 	static ::rtl::OUString aAnd		= ::rtl::OUString::createFromAscii(" AND ");
456 	static ::rtl::OUString aOr		= ::rtl::OUString::createFromAscii(" OR ");
457 	static ::rtl::OUString aEqual	= ::rtl::OUString::createFromAscii(" = ?");
458 
459 
460 	// use keys and indexes for excat postioning
461 	// first the keys
462 	Reference<XNameAccess> xKeyColumns = getKeyColumns();
463 
464 	::rtl::OUStringBuffer aCondition = ::rtl::OUString::createFromAscii("( ");
465 
466 	SelectColumnsMetaData::const_iterator aIter = (*m_pKeyColumnNames).begin();
467     SelectColumnsMetaData::const_iterator aPosEnd = (*m_pKeyColumnNames).end();
468 	for(;aIter != aPosEnd;++aIter)
469 	{
470 		aCondition.append(::dbtools::quoteName( aQuote,aIter->second.sRealName));
471 		aCondition.append(aEqual);
472 		aCondition.append(aAnd);
473 	}
474     aCondition.setLength(aCondition.getLength()-5);
475     const ::rtl::OUString sCon( aCondition.makeStringAndClear() );
476 
477 	const Any* pBegin	= rows.getConstArray();
478 	const Any* pEnd		= pBegin + rows.getLength();
479 
480 	Sequence< Any > aKeys;
481 	for(;pBegin != pEnd;++pBegin)
482 	{
483         aSql.append(sCon);
484 		aSql.append(aOr);
485 	}
486     aSql.setLength(aSql.getLength()-3);
487 
488 	// now create end execute the prepared statement
489 
490     Reference< XPreparedStatement > xPrep(m_xConnection->prepareStatement(aSql.makeStringAndClear()));
491 	Reference< XParameters > xParameter(xPrep,UNO_QUERY);
492 
493 	pBegin	= rows.getConstArray();
494 	sal_Int32 i=1;
495 	for(;pBegin != pEnd;++pBegin)
496 	{
497 		m_aKeyIter = m_aKeyMap.find(::comphelper::getINT32(*pBegin));
498 		if(m_aKeyIter != m_aKeyMap.end())
499 		{
500 			connectivity::ORowVector< ORowSetValue >::Vector::iterator aKeyIter = m_aKeyIter->second.first->get().begin();
501             connectivity::ORowVector< ORowSetValue >::Vector::iterator aKeyEnd = m_aKeyIter->second.first->get().end();
502             SelectColumnsMetaData::const_iterator aPosIter = (*m_pKeyColumnNames).begin();
503 			for(sal_uInt16 j = 0;aKeyIter != aKeyEnd;++aKeyIter,++j,++aPosIter)
504 			{
505 				setParameter(i++,xParameter,*aKeyIter,aPosIter->second.nType,aPosIter->second.nScale);
506 			}
507 		}
508 	}
509 
510 	sal_Bool bOk = xPrep->executeUpdate() > 0;
511 	Sequence< sal_Int32 > aRet(rows.getLength());
512 	memset(aRet.getArray(),bOk,sizeof(sal_Int32)*aRet.getLength());
513 	if(bOk)
514 	{
515 		pBegin  = rows.getConstArray();
516 		pEnd    = pBegin + rows.getLength();
517 
518 		for(;pBegin != pEnd;++pBegin)
519 		{
520 			sal_Int32 nPos = 0;
521 			*pBegin >>= nPos;
522 			if(m_aKeyIter == m_aKeyMap.find(nPos) && m_aKeyIter != m_aKeyMap.end())
523 				++m_aKeyIter;
524 			m_aKeyMap.erase(nPos);
525 			m_bDeleted = sal_True;
526 		}
527 	}
528 	return aRet;
529 }
530 // -------------------------------------------------------------------------
updateRow(const ORowSetRow & _rInsertRow,const ORowSetRow & _rOrginalRow,const connectivity::OSQLTable & _xTable)531 void SAL_CALL OKeySet::updateRow(const ORowSetRow& _rInsertRow ,const ORowSetRow& _rOrginalRow,const connectivity::OSQLTable& _xTable  ) throw(SQLException, RuntimeException)
532 {
533     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::updateRow" );
534 	Reference<XPropertySet> xSet(_xTable,UNO_QUERY);
535 	fillTableName(xSet);
536 
537 	::rtl::OUStringBuffer aSql = ::rtl::OUString::createFromAscii("UPDATE ");
538 	aSql.append(m_aComposedTableName);
539 	aSql.append(::rtl::OUString::createFromAscii(" SET "));
540 	// list all cloumns that should be set
541 	static ::rtl::OUString aPara	= ::rtl::OUString::createFromAscii(" = ?,");
542 	::rtl::OUString aQuote	= getIdentifierQuoteString();
543 	static ::rtl::OUString aAnd		= ::rtl::OUString::createFromAscii(" AND ");
544     ::rtl::OUString sIsNull(RTL_CONSTASCII_USTRINGPARAM(" IS NULL"));
545     ::rtl::OUString sParam(RTL_CONSTASCII_USTRINGPARAM(" = ?"));
546 
547 	// use keys and indexes for excat postioning
548 	// first the keys
549 	Reference<XNameAccess> xKeyColumns = getKeyColumns();
550 
551 	// second the indexes
552 	Reference<XIndexesSupplier> xIndexSup(_xTable,UNO_QUERY);
553 	Reference<XIndexAccess> xIndexes;
554 	if ( xIndexSup.is() )
555 		xIndexes.set(xIndexSup->getIndexes(),UNO_QUERY);
556 
557 
558 	::std::vector< Reference<XNameAccess> > aAllIndexColumns;
559 	lcl_fillIndexColumns(xIndexes,aAllIndexColumns);
560 
561 	::rtl::OUString aColumnName;
562     ::rtl::OUStringBuffer sKeyCondition,sIndexCondition;
563 	::std::vector<sal_Int32> aIndexColumnPositions;
564 
565     const sal_Int32 nOldLength = aSql.getLength();
566 	sal_Int32 i = 1;
567 	// here we build the condition part for the update statement
568 	SelectColumnsMetaData::const_iterator aIter = m_pColumnNames->begin();
569     SelectColumnsMetaData::const_iterator aEnd = m_pColumnNames->end();
570 	for(;aIter != aEnd;++aIter,++i)
571 	{
572 		//if(xKeyColumns.is() && xKeyColumns->hasByName(aIter->first))
573         if ( m_pKeyColumnNames->find(aIter->first) != m_pKeyColumnNames->end() )
574 		{
575 			sKeyCondition.append(::dbtools::quoteName( aQuote,aIter->second.sRealName));
576 			if((_rOrginalRow->get())[aIter->second.nPosition].isNull())
577 				sKeyCondition.append(sIsNull);
578 			else
579 				sKeyCondition.append(sParam);
580 			sKeyCondition.append(aAnd);
581 		}
582 		else
583 		{
584             ::std::vector< Reference<XNameAccess> >::const_iterator aIndexEnd = aAllIndexColumns.end();
585 		    for( ::std::vector< Reference<XNameAccess> >::const_iterator aIndexIter = aAllIndexColumns.begin();
586 				aIndexIter != aIndexEnd;++aIndexIter)
587 			{
588 				if((*aIndexIter)->hasByName(aIter->first))
589 				{
590 					sIndexCondition.append(::dbtools::quoteName( aQuote,aIter->second.sRealName));
591 					if((_rOrginalRow->get())[aIter->second.nPosition].isNull())
592 						sIndexCondition.append(sIsNull);
593 					else
594 					{
595 						sIndexCondition.append(sParam);
596 						aIndexColumnPositions.push_back(aIter->second.nPosition);
597 					}
598 					sIndexCondition.append(aAnd);
599 					break;
600 				}
601 			}
602 		}
603 		if((_rInsertRow->get())[aIter->second.nPosition].isModified())
604 		{
605 			aSql.append(::dbtools::quoteName( aQuote,aIter->second.sRealName));
606 			aSql.append(aPara);
607 		}
608 	}
609 
610 	if( aSql.getLength() != nOldLength )
611 	{
612         aSql.setLength(aSql.getLength()-1);
613 	}
614 	else
615         ::dbtools::throwSQLException( DBACORE_RESSTRING( RID_STR_NO_VALUE_CHANGED ), SQL_GENERAL_ERROR, m_xConnection );
616 
617 	if(sKeyCondition.getLength() || sIndexCondition.getLength())
618 	{
619         aSql.append(::rtl::OUString::createFromAscii(" WHERE "));
620 		if(sKeyCondition.getLength() && sIndexCondition.getLength())
621 		{
622 			aSql.append(sKeyCondition.makeStringAndClear());
623 			aSql.append(sIndexCondition.makeStringAndClear());
624 		}
625 		else if(sKeyCondition.getLength())
626 		{
627 			aSql.append(sKeyCondition.makeStringAndClear());
628 		}
629 		else if(sIndexCondition.getLength())
630 		{
631 			aSql.append(sIndexCondition.makeStringAndClear());
632 		}
633         aSql.setLength(aSql.getLength()-5); // remove the last AND
634 	}
635 	else
636         ::dbtools::throwSQLException( DBACORE_RESSTRING( RID_STR_NO_CONDITION_FOR_PK ), SQL_GENERAL_ERROR, m_xConnection );
637 
638 	// now create end execute the prepared statement
639 
640     ::rtl::OUString sEmpty;
641     executeUpdate(_rInsertRow ,_rOrginalRow,aSql.makeStringAndClear(),sEmpty,aIndexColumnPositions);
642 }
643 // -----------------------------------------------------------------------------
executeUpdate(const ORowSetRow & _rInsertRow,const ORowSetRow & _rOrginalRow,const::rtl::OUString & i_sSQL,const::rtl::OUString & i_sTableName,const::std::vector<sal_Int32> & _aIndexColumnPositions)644 void OKeySet::executeUpdate(const ORowSetRow& _rInsertRow ,const ORowSetRow& _rOrginalRow,const ::rtl::OUString& i_sSQL,const ::rtl::OUString& i_sTableName,const ::std::vector<sal_Int32>& _aIndexColumnPositions)
645 {
646     // now create end execute the prepared statement
647     Reference< XPreparedStatement > xPrep(m_xConnection->prepareStatement(i_sSQL));
648 	Reference< XParameters > xParameter(xPrep,UNO_QUERY);
649 
650     bool bRefetch = true;
651     Reference<XRow> xRow;
652 	sal_Int32 i = 1;
653 	// first the set values
654 	SelectColumnsMetaData::const_iterator aIter = m_pColumnNames->begin();
655     SelectColumnsMetaData::const_iterator aEnd = m_pColumnNames->end();
656 	sal_uInt16 j = 0;
657 	for(;aIter != aEnd;++aIter,++j)
658 	{
659         if ( !i_sTableName.getLength() || aIter->second.sTableName == i_sTableName )
660         {
661 		    sal_Int32 nPos = aIter->second.nPosition;
662 		    if((_rInsertRow->get())[nPos].isModified())
663 		    {
664                 if ( bRefetch )
665                 {
666                     bRefetch = ::std::find(m_aFilterColumns.begin(),m_aFilterColumns.end(),aIter->second.sRealName) == m_aFilterColumns.end();
667                 }
668                 impl_convertValue_throw(_rInsertRow,aIter->second);
669 			    (_rInsertRow->get())[nPos].setSigned((_rOrginalRow->get())[nPos].isSigned());
670 			    setParameter(i++,xParameter,(_rInsertRow->get())[nPos],aIter->second.nType,aIter->second.nScale);
671 		    }
672         }
673 	}
674 	// and then the values of the where condition
675 	aIter = m_pKeyColumnNames->begin();
676     aEnd = m_pKeyColumnNames->end();
677 	j = 0;
678 	for(;aIter != aEnd;++aIter,++j)
679 	{
680         if ( !i_sTableName.getLength() || aIter->second.sTableName == i_sTableName )
681         {
682 		    setParameter(i++,xParameter,(_rOrginalRow->get())[aIter->second.nPosition],aIter->second.nType,aIter->second.nScale);
683         }
684 	}
685     if ( !_aIndexColumnPositions.empty() )
686     {
687         // now we have to set the index values
688 	    ::std::vector<sal_Int32>::const_iterator aIdxColIter = _aIndexColumnPositions.begin();
689         ::std::vector<sal_Int32>::const_iterator aIdxColEnd = _aIndexColumnPositions.end();
690 	    j = 0;
691         aIter = m_pColumnNames->begin();
692 	    for(;aIdxColIter != aIdxColEnd;++aIdxColIter,++i,++j,++aIter)
693 	    {
694 		    setParameter(i,xParameter,(_rOrginalRow->get())[*aIdxColIter],(_rOrginalRow->get())[*aIdxColIter].getTypeKind(),aIter->second.nScale);
695 	    }
696     }
697     const sal_Int32 nRowsUpdated = xPrep->executeUpdate();
698  	m_bUpdated =  nRowsUpdated > 0;
699 	if(m_bUpdated)
700 	{
701         const sal_Int32 nBookmark = ::comphelper::getINT32((_rInsertRow->get())[0].getAny());
702 		m_aKeyIter = m_aKeyMap.find(nBookmark);
703 	    m_aKeyIter->second.second.first = 2;
704         m_aKeyIter->second.second.second = xRow;
705         copyRowValue(_rInsertRow,m_aKeyIter->second.first,nBookmark);
706         tryRefetch(_rInsertRow,bRefetch);
707 	}
708 }
709 // -------------------------------------------------------------------------
insertRow(const ORowSetRow & _rInsertRow,const connectivity::OSQLTable & _xTable)710 void SAL_CALL OKeySet::insertRow( const ORowSetRow& _rInsertRow,const connectivity::OSQLTable& _xTable ) throw(SQLException, RuntimeException)
711 {
712     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::insertRow" );
713 	::rtl::OUStringBuffer aSql(::rtl::OUString::createFromAscii("INSERT INTO "));
714 	Reference<XPropertySet> xSet(_xTable,UNO_QUERY);
715 	fillTableName(xSet);
716 
717 	aSql.append(m_aComposedTableName);
718 	aSql.append(::rtl::OUString::createFromAscii(" ( "));
719 	// set values and column names
720     ::rtl::OUStringBuffer aValues(::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM(" VALUES ( ")));
721     static ::rtl::OUString aPara(RTL_CONSTASCII_USTRINGPARAM("?,"));
722 	::rtl::OUString aQuote = getIdentifierQuoteString();
723     static ::rtl::OUString aComma(RTL_CONSTASCII_USTRINGPARAM(","));
724 
725 	SelectColumnsMetaData::const_iterator aIter = m_pColumnNames->begin();
726     SelectColumnsMetaData::const_iterator aEnd = m_pColumnNames->end();
727 	sal_Int32 j = 1;
728     bool bRefetch = true;
729     sal_Bool bModified = sal_False;
730 	for(;aIter != aEnd;++aIter,++j)
731 	{
732 		if((_rInsertRow->get())[aIter->second.nPosition].isModified())
733 		{
734             if ( bRefetch )
735             {
736                 bRefetch = ::std::find(m_aFilterColumns.begin(),m_aFilterColumns.end(),aIter->second.sRealName) == m_aFilterColumns.end();
737             }
738 			aSql.append(::dbtools::quoteName( aQuote,aIter->second.sRealName));
739 			aSql.append(aComma);
740 			aValues.append(aPara);
741             bModified = sal_True;
742 		}
743 	}
744     if ( !bModified )
745         ::dbtools::throwSQLException( DBACORE_RESSTRING( RID_STR_NO_VALUE_CHANGED ), SQL_GENERAL_ERROR, m_xConnection );
746 
747     aSql.setCharAt(aSql.getLength()-1,')');
748     aValues.setCharAt(aValues.getLength()-1,')');
749     aSql.append(aValues.makeStringAndClear());
750 	// now create,fill and execute the prepared statement
751     ::rtl::OUString sEmpty;
752     executeInsert(_rInsertRow,aSql.makeStringAndClear(),sEmpty,bRefetch);
753 }
754 // -------------------------------------------------------------------------
executeInsert(const ORowSetRow & _rInsertRow,const::rtl::OUString & i_sSQL,const::rtl::OUString & i_sTableName,bool bRefetch)755 void OKeySet::executeInsert( const ORowSetRow& _rInsertRow,const ::rtl::OUString& i_sSQL,const ::rtl::OUString& i_sTableName,bool bRefetch )
756 {
757 	// now create,fill and execute the prepared statement
758     Reference< XPreparedStatement > xPrep(m_xConnection->prepareStatement(i_sSQL));
759 	Reference< XParameters > xParameter(xPrep,UNO_QUERY);
760 
761 	SelectColumnsMetaData::const_iterator aIter = m_pColumnNames->begin();
762     SelectColumnsMetaData::const_iterator aEnd = m_pColumnNames->end();
763 	for(sal_Int32 i = 1;aIter != aEnd;++aIter)
764 	{
765         if ( !i_sTableName.getLength() || aIter->second.sTableName == i_sTableName )
766         {
767 		    const sal_Int32 nPos = aIter->second.nPosition;
768 		    if((_rInsertRow->get())[nPos].isModified())
769 		    {
770 			    if((_rInsertRow->get())[nPos].isNull())
771 				    xParameter->setNull(i++,(_rInsertRow->get())[nPos].getTypeKind());
772 			    else
773 			    {
774                     impl_convertValue_throw(_rInsertRow,aIter->second);
775 				    (_rInsertRow->get())[nPos].setSigned(m_aSignedFlags[nPos-1]);
776 				    setParameter(i++,xParameter,(_rInsertRow->get())[nPos],aIter->second.nType,aIter->second.nScale);
777 			    }
778 		    }
779         }
780 	}
781 
782 	m_bInserted = xPrep->executeUpdate() > 0;
783 	sal_Bool bAutoValuesFetched = sal_False;
784 	if ( m_bInserted )
785 	{
786         // first insert the default values into the insertrow
787         aIter = m_pColumnNames->begin();
788         for(;aIter != aEnd;++aIter)
789 	    {
790             if ( !(_rInsertRow->get())[aIter->second.nPosition].isModified() )
791                 (_rInsertRow->get())[aIter->second.nPosition] = aIter->second.sDefaultValue;
792         }
793 		try
794 		{
795 			Reference< XGeneratedResultSet > xGRes(xPrep, UNO_QUERY);
796 			if ( xGRes.is() )
797 			{
798 				Reference< XResultSet > xRes = xGRes->getGeneratedValues();
799 				Reference< XRow > xRow(xRes,UNO_QUERY);
800 				if ( xRow.is() && xRes->next() )
801 				{
802 					Reference< XResultSetMetaDataSupplier > xMdSup(xRes,UNO_QUERY);
803 					Reference< XResultSetMetaData > xMd = xMdSup->getMetaData();
804 					sal_Int32 nColumnCount = xMd->getColumnCount();
805 					::std::vector< ::rtl::OUString >::iterator aAutoIter = m_aAutoColumns.begin();
806 					::std::vector< ::rtl::OUString >::iterator aAutoEnd = m_aAutoColumns.end();
807 					for (sal_Int32 i = 1;aAutoIter !=  aAutoEnd && i <= nColumnCount; ++aAutoIter,++i)
808 					{
809 #if OSL_DEBUG_LEVEL > 1
810 						::rtl::OUString sColumnName( xMd->getColumnName(i) );
811 #endif
812 						SelectColumnsMetaData::iterator aFind = m_pKeyColumnNames->find(*aAutoIter);
813 						if ( aFind != m_pKeyColumnNames->end() )
814                             (_rInsertRow->get())[aFind->second.nPosition].fill(i,aFind->second.nType,aFind->second.bNullable,xRow);
815 					}
816 					bAutoValuesFetched = sal_True;
817 				}
818 			}
819 		}
820 		catch(Exception&)
821 		{
822 			OSL_ENSURE(0,"Could not execute GeneratedKeys() stmt");
823 		}
824 	}
825 
826 	::comphelper::disposeComponent(xPrep);
827 
828     if ( !i_sTableName.getLength() && !bAutoValuesFetched && m_bInserted )
829 	{
830 		// first check if all key column values were set
831         const ::rtl::OUString sMax(RTL_CONSTASCII_USTRINGPARAM(" MAX("));
832         const ::rtl::OUString sMaxEnd(RTL_CONSTASCII_USTRINGPARAM("),"));
833 		const ::rtl::OUString sQuote = getIdentifierQuoteString();
834 		::rtl::OUString sMaxStmt;
835         aEnd = m_pKeyColumnNames->end();
836 		::std::vector< ::rtl::OUString >::iterator aAutoIter = m_aAutoColumns.begin();
837         ::std::vector< ::rtl::OUString >::iterator aAutoEnd = m_aAutoColumns.end();
838 		for (;aAutoIter !=  aAutoEnd; ++aAutoIter)
839 		{
840 			// we will only fetch values which are keycolumns
841             SelectColumnsMetaData::iterator aFind = m_pKeyColumnNames->find(*aAutoIter);
842 			if ( aFind != aEnd )
843 			{
844 				sMaxStmt += sMax;
845                 sMaxStmt += ::dbtools::quoteName( sQuote,aFind->second.sRealName
846 );
847 				sMaxStmt += sMaxEnd;
848 			}
849 		}
850 
851 		if(sMaxStmt.getLength())
852 		{
853 			sMaxStmt = sMaxStmt.replaceAt(sMaxStmt.getLength()-1,1,::rtl::OUString::createFromAscii(" "));
854 			::rtl::OUString sStmt = ::rtl::OUString::createFromAscii("SELECT ");
855 			sStmt += sMaxStmt;
856 			sStmt += ::rtl::OUString::createFromAscii("FROM ");
857             ::rtl::OUString sCatalog,sSchema,sTable;
858 			::dbtools::qualifiedNameComponents(m_xConnection->getMetaData(),m_sUpdateTableName,sCatalog,sSchema,sTable,::dbtools::eInDataManipulation);
859 			sStmt += ::dbtools::composeTableNameForSelect( m_xConnection, sCatalog, sSchema, sTable );
860 			try
861 			{
862 				// now fetch the autoincrement values
863 				Reference<XStatement> xStatement = m_xConnection->createStatement();
864 				Reference<XResultSet> xRes = xStatement->executeQuery(sStmt);
865 				Reference<XRow> xRow(xRes,UNO_QUERY);
866 				if(xRow.is() && xRes->next())
867 				{
868 					aAutoIter = m_aAutoColumns.begin();
869 					for (sal_Int32 i=1;aAutoIter != aAutoEnd; ++aAutoIter,++i)
870 					{
871 						// we will only fetch values which are keycolumns
872 						SelectColumnsMetaData::iterator aFind = m_pKeyColumnNames->find(*aAutoIter);
873 						if ( aFind != aEnd )
874                             (_rInsertRow->get())[aFind->second.nPosition].fill(i,aFind->second.nType,aFind->second.bNullable,xRow);
875 					}
876 				}
877 				::comphelper::disposeComponent(xStatement);
878 			}
879 			catch(SQLException&)
880 			{
881 				OSL_ENSURE(0,"Could not fetch with MAX() ");
882 			}
883 		}
884 	}
885 	if ( m_bInserted )
886 	{
887         OKeySetMatrix::iterator aKeyIter = m_aKeyMap.end();
888 		--aKeyIter;
889 		ORowSetRow aKeyRow = new connectivity::ORowVector< ORowSetValue >(m_pKeyColumnNames->size());
890         copyRowValue(_rInsertRow,aKeyRow,aKeyIter->first + 1);
891 
892         m_aKeyIter = m_aKeyMap.insert(OKeySetMatrix::value_type(aKeyIter->first + 1,OKeySetValue(aKeyRow,::std::pair<sal_Int32,Reference<XRow> >(1,NULL)))).first;
893 		// now we set the bookmark for this row
894 		(_rInsertRow->get())[0] = makeAny((sal_Int32)m_aKeyIter->first);
895         tryRefetch(_rInsertRow,bRefetch);
896 	}
897 }
tryRefetch(const ORowSetRow & _rInsertRow,bool bRefetch)898 void OKeySet::tryRefetch(const ORowSetRow& _rInsertRow,bool bRefetch)
899 {
900     if ( bRefetch )
901 	{
902         // we just areassign the base members
903         try
904         {
905             Reference< XParameters > xParameter(m_xStatement,UNO_QUERY);
906             OSL_ENSURE(xParameter.is(),"No Parameter interface!");
907             xParameter->clearParameters();
908 
909             sal_Int32 nPos=1;
910             connectivity::ORowVector< ORowSetValue >::Vector::const_iterator aParaIter;
911             connectivity::ORowVector< ORowSetValue >::Vector::const_iterator aParaEnd;
912             OUpdatedParameter::iterator aUpdateFind = m_aUpdatedParameter.find(m_aKeyIter->first);
913             if ( aUpdateFind == m_aUpdatedParameter.end() )
914             {
915                 aParaIter = m_aParameterValueForCache.get().begin();
916                 aParaEnd = m_aParameterValueForCache.get().end();
917             }
918             else
919             {
920                 aParaIter = aUpdateFind->second.get().begin();
921                 aParaEnd = aUpdateFind->second.get().end();
922             }
923 
924             for(++aParaIter;aParaIter != aParaEnd;++aParaIter,++nPos)
925             {
926                 ::dbtools::setObjectWithInfo( xParameter, nPos, aParaIter->makeAny(), aParaIter->getTypeKind() );
927             }
928             connectivity::ORowVector< ORowSetValue >::Vector::const_iterator aIter2 = m_aKeyIter->second.first->get().begin();
929             SelectColumnsMetaData::const_iterator aPosIter = (*m_pKeyColumnNames).begin();
930             SelectColumnsMetaData::const_iterator aPosEnd = (*m_pKeyColumnNames).end();
931             for(;aPosIter != aPosEnd;++aPosIter,++aIter2,++nPos)
932 	            setParameter(nPos,xParameter,*aIter2,aPosIter->second.nType,aPosIter->second.nScale);
933             aPosIter = (*m_pForeignColumnNames).begin();
934             aPosEnd = (*m_pForeignColumnNames).end();
935             for(;aPosIter != aPosEnd;++aPosIter,++aIter2,++nPos)
936 	            setParameter(nPos,xParameter,*aIter2,aPosIter->second.nType,aPosIter->second.nScale);
937 
938             m_xSet = m_xStatement->executeQuery();
939             OSL_ENSURE(m_xSet.is(),"No resultset form statement!");
940             bRefetch = m_xSet->next();
941         }
942         catch(Exception)
943         {
944             bRefetch = false;
945         }
946 	}
947     if ( !bRefetch )
948     {
949         m_aKeyIter->second.second.second = new OPrivateRow(_rInsertRow->get());
950     }
951 }
952 // -----------------------------------------------------------------------------
copyRowValue(const ORowSetRow & _rInsertRow,ORowSetRow & _rKeyRow,sal_Int32 i_nBookmark)953 void OKeySet::copyRowValue(const ORowSetRow& _rInsertRow,ORowSetRow& _rKeyRow,sal_Int32 i_nBookmark)
954 {
955     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::copyRowValue" );
956     connectivity::ORowVector< ORowSetValue >::Vector::iterator aIter = _rKeyRow->get().begin();
957 
958     // check the if the parameter values have been changed
959     OSL_ENSURE((m_aParameterValueForCache.get().size()-1) == m_pParameterNames->size(),"OKeySet::copyRowValue: Parameter values and names differ!");
960     connectivity::ORowVector< ORowSetValue >::Vector::const_iterator aParaValuesIter = m_aParameterValueForCache.get().begin() +1;
961 
962     bool bChanged = false;
963     SelectColumnsMetaData::const_iterator aParaIter = (*m_pParameterNames).begin();
964     SelectColumnsMetaData::const_iterator aParaEnd = (*m_pParameterNames).end();
965     for(sal_Int32 i = 1;aParaIter != aParaEnd;++aParaIter,++aParaValuesIter,++i)
966     {
967         ORowSetValue aValue(*aParaValuesIter);
968         aValue.setSigned(m_aSignedFlags[aParaIter->second.nPosition]);
969         if ( (_rInsertRow->get())[aParaIter->second.nPosition] != aValue )
970         {
971             ORowSetValueVector aCopy(m_aParameterValueForCache);
972             (aCopy.get())[i] = (_rInsertRow->get())[aParaIter->second.nPosition];
973             m_aUpdatedParameter[i_nBookmark] = aCopy;
974             bChanged = true;
975         }
976     }
977     if ( !bChanged )
978     {
979         m_aUpdatedParameter.erase(i_nBookmark);
980     }
981 
982     // update the key values
983 	SelectColumnsMetaData::const_iterator aPosIter = (*m_pKeyColumnNames).begin();
984     SelectColumnsMetaData::const_iterator aPosEnd = (*m_pKeyColumnNames).end();
985 	for(;aPosIter != aPosEnd;++aPosIter,++aIter)
986     {
987         impl_convertValue_throw(_rInsertRow,aPosIter->second);
988         *aIter = (_rInsertRow->get())[aPosIter->second.nPosition];
989         aIter->setTypeKind(aPosIter->second.nType);
990     }
991 }
992 // -------------------------------------------------------------------------
deleteRow(const ORowSetRow & _rDeleteRow,const connectivity::OSQLTable & _xTable)993 void SAL_CALL OKeySet::deleteRow(const ORowSetRow& _rDeleteRow,const connectivity::OSQLTable& _xTable   ) throw(SQLException, RuntimeException)
994 {
995     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::deleteRow" );
996 	Reference<XPropertySet> xSet(_xTable,UNO_QUERY);
997 	fillTableName(xSet);
998 
999 	::rtl::OUStringBuffer aSql = ::rtl::OUString::createFromAscii("DELETE FROM ");
1000 	aSql.append(m_aComposedTableName);
1001 	aSql.append(::rtl::OUString::createFromAscii(" WHERE "));
1002 
1003 	// list all cloumns that should be set
1004 	::rtl::OUString aQuote	= getIdentifierQuoteString();
1005 	static ::rtl::OUString aAnd		= ::rtl::OUString::createFromAscii(" AND ");
1006 
1007 	// use keys and indexes for excat postioning
1008 	Reference<XNameAccess> xKeyColumns = getKeyColumns();
1009 	// second the indexes
1010 	Reference<XIndexesSupplier> xIndexSup(_xTable,UNO_QUERY);
1011 	Reference<XIndexAccess> xIndexes;
1012 	if ( xIndexSup.is() )
1013 		xIndexes.set(xIndexSup->getIndexes(),UNO_QUERY);
1014 
1015 	//	Reference<XColumnsSupplier>
1016 	::std::vector< Reference<XNameAccess> > aAllIndexColumns;
1017 	lcl_fillIndexColumns(xIndexes,aAllIndexColumns);
1018 
1019 	::rtl::OUString aColumnName;
1020     ::rtl::OUStringBuffer sIndexCondition;
1021 	::std::vector<sal_Int32> aIndexColumnPositions;
1022 	SelectColumnsMetaData::const_iterator aIter = m_pColumnNames->begin();
1023     SelectColumnsMetaData::const_iterator aEnd = m_pColumnNames->end();
1024 
1025 	sal_Int32 i = 1;
1026 	for(i = 1;aIter != aEnd;++aIter,++i)
1027 	{
1028 		if ( m_pKeyColumnNames->find(aIter->first) != m_pKeyColumnNames->end() )
1029 		{
1030 			aSql.append(::dbtools::quoteName( aQuote,aIter->second.sRealName));
1031 			if((_rDeleteRow->get())[aIter->second.nPosition].isNull())
1032 			{
1033 				OSL_ENSURE(0,"can a primary key be null");
1034 				aSql.append(::rtl::OUString::createFromAscii(" IS NULL"));
1035 			}
1036 			else
1037 				aSql.append(::rtl::OUString::createFromAscii(" = ?"));
1038 			aSql.append(aAnd);
1039 		}
1040 		else
1041 		{
1042             ::std::vector< Reference<XNameAccess> >::const_iterator aIndexEnd = aAllIndexColumns.end();
1043 			for( ::std::vector< Reference<XNameAccess> >::const_iterator aIndexIter = aAllIndexColumns.begin();
1044 					aIndexIter != aIndexEnd;++aIndexIter)
1045 			{
1046 				if((*aIndexIter)->hasByName(aIter->first))
1047 				{
1048 					sIndexCondition.append(::dbtools::quoteName( aQuote,aIter->second.sRealName));
1049 					if((_rDeleteRow->get())[aIter->second.nPosition].isNull())
1050 						sIndexCondition.append(::rtl::OUString::createFromAscii(" IS NULL"));
1051 					else
1052 					{
1053 						sIndexCondition.append(::rtl::OUString::createFromAscii(" = ?"));
1054 						aIndexColumnPositions.push_back(aIter->second.nPosition);
1055 					}
1056 					sIndexCondition.append(aAnd);
1057 
1058 					break;
1059 				}
1060 			}
1061 		}
1062 	}
1063     aSql.append(sIndexCondition.makeStringAndClear());
1064     aSql.setLength(aSql.getLength()-5);
1065 
1066 	// now create end execute the prepared statement
1067 	Reference< XPreparedStatement > xPrep(m_xConnection->prepareStatement(aSql.makeStringAndClear()));
1068 	Reference< XParameters > xParameter(xPrep,UNO_QUERY);
1069 
1070 	aIter = (*m_pKeyColumnNames).begin();
1071     aEnd = (*m_pKeyColumnNames).end();
1072 	i = 1;
1073 	for(;aIter != aEnd;++aIter,++i)
1074 	{
1075 		setParameter(i,xParameter,(_rDeleteRow->get())[aIter->second.nPosition],aIter->second.nType,aIter->second.nScale);
1076 	}
1077 
1078 	// now we have to set the index values
1079 	::std::vector<sal_Int32>::iterator aIdxColIter = aIndexColumnPositions.begin();
1080     ::std::vector<sal_Int32>::iterator aIdxColEnd = aIndexColumnPositions.end();
1081     aIter = m_pColumnNames->begin();
1082 	for(;aIdxColIter != aIdxColEnd;++aIdxColIter,++i,++aIter)
1083 	{
1084 		setParameter(i,xParameter,(_rDeleteRow->get())[*aIdxColIter],(_rDeleteRow->get())[*aIdxColIter].getTypeKind(),aIter->second.nScale);
1085 	}
1086 
1087 	m_bDeleted = xPrep->executeUpdate() > 0;
1088 
1089 	if(m_bDeleted)
1090 	{
1091 		sal_Int32 nBookmark = ::comphelper::getINT32((_rDeleteRow->get())[0].getAny());
1092 		if(m_aKeyIter == m_aKeyMap.find(nBookmark) && m_aKeyIter != m_aKeyMap.end())
1093 			++m_aKeyIter;
1094 		m_aKeyMap.erase(nBookmark);
1095 		m_bDeleted = sal_True;
1096 	}
1097 }
1098 // -------------------------------------------------------------------------
cancelRowUpdates()1099 void SAL_CALL OKeySet::cancelRowUpdates(  ) throw(SQLException, RuntimeException)
1100 {
1101     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::cancelRowUpdates" );
1102 	m_bInserted = m_bUpdated = m_bDeleted = sal_False;
1103 }
1104 // -------------------------------------------------------------------------
moveToInsertRow()1105 void SAL_CALL OKeySet::moveToInsertRow(  ) throw(SQLException, RuntimeException)
1106 {
1107     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::moveToInsertRow" );
1108 }
1109 // -------------------------------------------------------------------------
moveToCurrentRow()1110 void SAL_CALL OKeySet::moveToCurrentRow(  ) throw(SQLException, RuntimeException)
1111 {
1112     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::moveToCurrentRow" );
1113 }
1114 // -------------------------------------------------------------------------
getKeyColumns() const1115 Reference<XNameAccess> OKeySet::getKeyColumns() const
1116 {
1117     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::getKeyColumns" );
1118 	// use keys and indexes for excat postioning
1119 	// first the keys
1120 
1121 	Reference<XIndexAccess> xKeys = m_xTableKeys;
1122     if ( !xKeys.is() )
1123     {
1124         Reference<XPropertySet> xSet(m_xTable,UNO_QUERY);
1125         const Reference<XNameAccess> xPrimaryKeyColumns = getPrimaryKeyColumns_throw(xSet);
1126         return xPrimaryKeyColumns;
1127     }
1128 
1129 	Reference<XColumnsSupplier> xKeyColsSup;
1130 	Reference<XNameAccess> xKeyColumns;
1131 	if(xKeys.is())
1132 	{
1133 		Reference<XPropertySet> xProp;
1134 		sal_Int32 nCount = xKeys->getCount();
1135 		for(sal_Int32 i = 0;i< nCount;++i)
1136 		{
1137 			xProp.set(xKeys->getByIndex(i),UNO_QUERY);
1138 			if ( xProp.is() )
1139 			{
1140 				sal_Int32 nKeyType = 0;
1141 				xProp->getPropertyValue(PROPERTY_TYPE) >>= nKeyType;
1142 				if(KeyType::PRIMARY == nKeyType)
1143 				{
1144 					xKeyColsSup.set(xProp,UNO_QUERY);
1145 					OSL_ENSURE(xKeyColsSup.is(),"Columnsupplier is null!");
1146 					xKeyColumns = xKeyColsSup->getColumns();
1147 					break;
1148 				}
1149 			}
1150 		}
1151 	}
1152 
1153 	return xKeyColumns;
1154 }
1155 // -----------------------------------------------------------------------------
next()1156 sal_Bool SAL_CALL OKeySet::next(  ) throw(SQLException, RuntimeException)
1157 {
1158     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::next" );
1159 	m_bInserted = m_bUpdated = m_bDeleted = sal_False;
1160 
1161 	if(isAfterLast())
1162 		return sal_False;
1163 	if(!m_bRowCountFinal) // not yet all records fetched
1164 	{
1165 		++m_aKeyIter; // this is possible because we stand on begin() and this is the "beforefirst" row
1166 		if(m_aKeyIter == m_aKeyMap.end() && !fetchRow())
1167 			m_aKeyIter = m_aKeyMap.end();
1168         else
1169         {
1170             //m_aKeyIter->second.second.second = new OPrivateRow(_rInsertRow->get());
1171             m_xRow.set(m_xDriverRow,UNO_QUERY_THROW);
1172             return !isAfterLast();
1173         }
1174 	}
1175 	else if(!isAfterLast())
1176 		++m_aKeyIter;
1177 
1178 	refreshRow();
1179 	return !isAfterLast();
1180 }
1181 // -----------------------------------------------------------------------------
isBeforeFirst()1182 sal_Bool SAL_CALL OKeySet::isBeforeFirst(  ) throw(SQLException, RuntimeException)
1183 {
1184     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::isBeforeFirst" );
1185 	return m_aKeyIter == m_aKeyMap.begin();
1186 }
1187 // -----------------------------------------------------------------------------
isAfterLast()1188 sal_Bool SAL_CALL OKeySet::isAfterLast(  ) throw(SQLException, RuntimeException)
1189 {
1190     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::isAfterLast" );
1191 	return  m_bRowCountFinal && m_aKeyIter == m_aKeyMap.end();
1192 }
1193 // -----------------------------------------------------------------------------
isFirst()1194 sal_Bool SAL_CALL OKeySet::isFirst(  ) throw(SQLException, RuntimeException)
1195 {
1196     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::isFirst" );
1197 	OKeySetMatrix::iterator aTemp = m_aKeyMap.begin();
1198 	++aTemp;
1199 	return m_aKeyIter == aTemp && m_aKeyIter != m_aKeyMap.end();
1200 }
1201 // -----------------------------------------------------------------------------
isLast()1202 sal_Bool SAL_CALL OKeySet::isLast(  ) throw(SQLException, RuntimeException)
1203 {
1204     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::isLast" );
1205 	if(!m_bRowCountFinal)
1206 		return sal_False;
1207 
1208 	OKeySetMatrix::iterator aTemp = m_aKeyMap.end();
1209 	--aTemp;
1210 	return m_aKeyIter == aTemp;
1211 }
1212 // -----------------------------------------------------------------------------
beforeFirst()1213 void SAL_CALL OKeySet::beforeFirst(  ) throw(SQLException, RuntimeException)
1214 {
1215     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::beforeFirst" );
1216 	m_bInserted = m_bUpdated = m_bDeleted = sal_False;
1217 	m_aKeyIter = m_aKeyMap.begin();
1218 	m_xRow = NULL;
1219 	::comphelper::disposeComponent(m_xSet);
1220 }
1221 // -----------------------------------------------------------------------------
afterLast()1222 void SAL_CALL OKeySet::afterLast(  ) throw(SQLException, RuntimeException)
1223 {
1224     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::afterLast" );
1225 	m_bInserted = m_bUpdated = m_bDeleted = sal_False;
1226 	fillAllRows();
1227 	m_aKeyIter = m_aKeyMap.end();
1228 	m_xRow = NULL;
1229 	::comphelper::disposeComponent(m_xSet);
1230 }
1231 // -----------------------------------------------------------------------------
first()1232 sal_Bool SAL_CALL OKeySet::first(  ) throw(SQLException, RuntimeException)
1233 {
1234     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::first" );
1235 	m_bInserted = m_bUpdated = m_bDeleted = sal_False;
1236 	m_aKeyIter = m_aKeyMap.begin();
1237 	++m_aKeyIter;
1238 	if(m_aKeyIter == m_aKeyMap.end() && !fetchRow())
1239 		m_aKeyIter = m_aKeyMap.end();
1240     else
1241 	    refreshRow();
1242 	return m_aKeyIter != m_aKeyMap.end() && m_aKeyIter != m_aKeyMap.begin();
1243 }
1244 // -----------------------------------------------------------------------------
last()1245 sal_Bool SAL_CALL OKeySet::last(  ) throw(SQLException, RuntimeException)
1246 {
1247     return last_checked(sal_True);
1248 }
1249 
last_checked(sal_Bool i_bFetchRow)1250 sal_Bool OKeySet::last_checked( sal_Bool i_bFetchRow)
1251 {
1252     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::last_checked" );
1253 	m_bInserted = m_bUpdated = m_bDeleted = sal_False;
1254 	fillAllRows();
1255 
1256 	m_aKeyIter = m_aKeyMap.end();
1257 	--m_aKeyIter;
1258     if ( i_bFetchRow )
1259 	    refreshRow();
1260 	return m_aKeyIter != m_aKeyMap.end() && m_aKeyIter != m_aKeyMap.begin();
1261 }
1262 // -----------------------------------------------------------------------------
getRow()1263 sal_Int32 SAL_CALL OKeySet::getRow(  ) throw(SQLException, RuntimeException)
1264 {
1265     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::getRow" );
1266 	OSL_ENSURE(!isAfterLast(),"getRow is not allowed when afterlast record!");
1267 	OSL_ENSURE(!isBeforeFirst(),"getRow is not allowed when beforefirst record!");
1268 
1269 	return ::std::distance(m_aKeyMap.begin(),m_aKeyIter);
1270 }
1271 // -----------------------------------------------------------------------------
absolute(sal_Int32 row)1272 sal_Bool SAL_CALL OKeySet::absolute( sal_Int32 row ) throw(SQLException, RuntimeException)
1273 {
1274     return absolute_checked(row,sal_True);
1275 }
absolute_checked(sal_Int32 row,sal_Bool i_bFetchRow)1276 sal_Bool OKeySet::absolute_checked( sal_Int32 row,sal_Bool i_bFetchRow )
1277 {
1278     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::absolute" );
1279 	m_bInserted = m_bUpdated = m_bDeleted = sal_False;
1280 	OSL_ENSURE(row,"absolute(0) isn't allowed!");
1281 	if(row < 0)
1282 	{
1283 		if(!m_bRowCountFinal)
1284 			fillAllRows();
1285 
1286 		for(;row < 0 && m_aKeyIter != m_aKeyMap.begin();++row)
1287 			m_aKeyIter--;
1288 	}
1289 	else
1290 	{
1291 		if(row >= (sal_Int32)m_aKeyMap.size())
1292 		{
1293 			if(!m_bRowCountFinal)
1294 			{
1295 				sal_Bool bNext = sal_True;
1296 				for(sal_Int32 i=m_aKeyMap.size()-1;i < row && bNext;++i)
1297 					bNext = fetchRow();
1298                 if ( bNext )
1299                 {
1300                     m_xRow.set(m_xDriverRow,UNO_QUERY_THROW);
1301                     return m_aKeyIter != m_aKeyMap.end() && m_aKeyIter != m_aKeyMap.begin();
1302                 }
1303 			}
1304 			else
1305 				m_aKeyIter = m_aKeyMap.end();
1306 		}
1307 		else
1308 		{
1309 			m_aKeyIter = m_aKeyMap.begin();
1310 			for(;row > 0 && m_aKeyIter != m_aKeyMap.end();--row)
1311 				++m_aKeyIter;
1312 		}
1313 	}
1314     if ( i_bFetchRow )
1315 	    refreshRow();
1316 
1317 	return m_aKeyIter != m_aKeyMap.end() && m_aKeyIter != m_aKeyMap.begin();
1318 }
1319 // -----------------------------------------------------------------------------
relative(sal_Int32 rows)1320 sal_Bool SAL_CALL OKeySet::relative( sal_Int32 rows ) throw(SQLException, RuntimeException)
1321 {
1322     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::relative" );
1323 	if(!rows)
1324 	{
1325 		refreshRow();
1326 		return sal_True;
1327 	}
1328 	return absolute(getRow()+rows);
1329 }
1330 // -----------------------------------------------------------------------------
previous_checked(sal_Bool i_bFetchRow)1331 sal_Bool OKeySet::previous_checked( sal_Bool i_bFetchRow )
1332 {
1333     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::previous" );
1334 	m_bInserted = m_bUpdated = m_bDeleted = sal_False;
1335 	if(m_aKeyIter != m_aKeyMap.begin())
1336 	{
1337 		--m_aKeyIter;
1338         if ( i_bFetchRow )
1339 		    refreshRow();
1340 	}
1341 	return m_aKeyIter != m_aKeyMap.begin();
1342 }
1343 // -----------------------------------------------------------------------------
previous()1344 sal_Bool SAL_CALL OKeySet::previous(  ) throw(SQLException, RuntimeException)
1345 {
1346     return previous_checked(sal_True);
1347 }
1348 
1349 // -----------------------------------------------------------------------------
refreshRow()1350 void SAL_CALL OKeySet::refreshRow() throw(SQLException, RuntimeException)
1351 {
1352     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::refreshRow" );
1353 	if(isBeforeFirst() || isAfterLast() || !m_xStatement.is())
1354 		return;
1355 
1356     m_xRow = NULL;
1357 	::comphelper::disposeComponent(m_xSet);
1358 
1359     if ( m_aKeyIter->second.second.second.is() )
1360     {
1361         m_xRow = m_aKeyIter->second.second.second;
1362         return;
1363     }
1364 	// we just areassign the base members
1365 	Reference< XParameters > xParameter(m_xStatement,UNO_QUERY);
1366 	OSL_ENSURE(xParameter.is(),"No Parameter interface!");
1367 	xParameter->clearParameters();
1368 
1369     sal_Int32 nPos=1;
1370     connectivity::ORowVector< ORowSetValue >::Vector::const_iterator aParaIter;
1371     connectivity::ORowVector< ORowSetValue >::Vector::const_iterator aParaEnd;
1372     OUpdatedParameter::iterator aUpdateFind = m_aUpdatedParameter.find(m_aKeyIter->first);
1373     if ( aUpdateFind == m_aUpdatedParameter.end() )
1374     {
1375         aParaIter = m_aParameterValueForCache.get().begin();
1376         aParaEnd = m_aParameterValueForCache.get().end();
1377     }
1378     else
1379     {
1380         aParaIter = aUpdateFind->second.get().begin();
1381         aParaEnd = aUpdateFind->second.get().end();
1382     }
1383 
1384     for(++aParaIter;aParaIter != aParaEnd;++aParaIter,++nPos)
1385     {
1386         ::dbtools::setObjectWithInfo( xParameter, nPos, aParaIter->makeAny(), aParaIter->getTypeKind() );
1387     }
1388 
1389     // now set the primary key column values
1390 	connectivity::ORowVector< ORowSetValue >::Vector::const_iterator aIter = m_aKeyIter->second.first->get().begin();
1391 	SelectColumnsMetaData::const_iterator aPosIter = (*m_pKeyColumnNames).begin();
1392     SelectColumnsMetaData::const_iterator aPosEnd = (*m_pKeyColumnNames).end();
1393 	for(;aPosIter != aPosEnd;++aPosIter,++aIter,++nPos)
1394 		setParameter(nPos,xParameter,*aIter,aPosIter->second.nType,aPosIter->second.nScale);
1395 	aPosIter = (*m_pForeignColumnNames).begin();
1396     aPosEnd = (*m_pForeignColumnNames).end();
1397 	for(;aPosIter != aPosEnd;++aPosIter,++aIter,++nPos)
1398 		setParameter(nPos,xParameter,*aIter,aPosIter->second.nType,aPosIter->second.nScale);
1399 
1400 	m_xSet = m_xStatement->executeQuery();
1401 	OSL_ENSURE(m_xSet.is(),"No resultset form statement!");
1402 	sal_Bool bOK = m_xSet->next();
1403     if ( !bOK )
1404     {
1405         OKeySetMatrix::iterator aTemp = m_aKeyIter;
1406         ++m_aKeyIter;
1407         m_aKeyMap.erase(aTemp);
1408         --m_rRowCount;
1409         refreshRow();
1410     }
1411     else
1412     {
1413 	    m_xRow.set(m_xSet,UNO_QUERY);
1414 	    OSL_ENSURE(m_xRow.is(),"No row form statement!");
1415     }
1416 }
1417 // -----------------------------------------------------------------------------
fetchRow()1418 sal_Bool OKeySet::fetchRow()
1419 {
1420     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::fetchRow" );
1421 	// fetch the next row and append on the keyset
1422 	sal_Bool bRet = sal_False;
1423 	if ( !m_bRowCountFinal && (!m_nMaxRows || sal_Int32(m_aKeyMap.size()) < m_nMaxRows) )
1424         bRet = m_xDriverSet->next();
1425     if ( bRet )
1426 	{
1427 		ORowSetRow aKeyRow = new connectivity::ORowVector< ORowSetValue >((*m_pKeyColumnNames).size() + m_pForeignColumnNames->size());
1428 		connectivity::ORowVector< ORowSetValue >::Vector::iterator aIter = aKeyRow->get().begin();
1429 		// first fetch the values needed for the key column
1430 		SelectColumnsMetaData::const_iterator aPosIter = (*m_pKeyColumnNames).begin();
1431         SelectColumnsMetaData::const_iterator aPosEnd = (*m_pKeyColumnNames).end();
1432 		for(;aPosIter != aPosEnd;++aPosIter,++aIter)
1433 		{
1434 			const SelectColumnDescription& rColDesc = aPosIter->second;
1435             aIter->fill(rColDesc.nPosition,rColDesc.nType,rColDesc.bNullable,m_xDriverRow);
1436 		}
1437 		// now fetch the values from the missing columns from other tables
1438 		aPosIter = (*m_pForeignColumnNames).begin();
1439         aPosEnd  = (*m_pForeignColumnNames).end();
1440 		for(;aPosIter != aPosEnd;++aPosIter,++aIter)
1441 		{
1442             const SelectColumnDescription& rColDesc = aPosIter->second;
1443             aIter->fill(rColDesc.nPosition,rColDesc.nType,rColDesc.bNullable,m_xDriverRow);
1444 		}
1445 		m_aKeyIter = m_aKeyMap.insert(OKeySetMatrix::value_type(m_aKeyMap.rbegin()->first+1,OKeySetValue(aKeyRow,::std::pair<sal_Int32,Reference<XRow> >(0,NULL)))).first;
1446 	}
1447 	else
1448 		m_bRowCountFinal = sal_True;
1449 	return bRet;
1450 }
1451 // -------------------------------------------------------------------------
fillAllRows()1452 void OKeySet::fillAllRows()
1453 {
1454     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::fillAllRows" );
1455 	if(!m_bRowCountFinal)
1456 	{
1457 		while(fetchRow())
1458 			;
1459 	}
1460 }
1461 // XRow
wasNull()1462 sal_Bool SAL_CALL OKeySet::wasNull(  ) throw(SQLException, RuntimeException)
1463 {
1464     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::wasNull" );
1465 	return m_xRow->wasNull();
1466 }
1467 // -------------------------------------------------------------------------
getString(sal_Int32 columnIndex)1468 ::rtl::OUString SAL_CALL OKeySet::getString( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1469 {
1470     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::getString" );
1471 	OSL_ENSURE(m_xRow.is(),"m_xRow is null!");
1472 	return m_xRow->getString(columnIndex);
1473 }
1474 // -------------------------------------------------------------------------
getBoolean(sal_Int32 columnIndex)1475 sal_Bool SAL_CALL OKeySet::getBoolean( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1476 {
1477     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::getBoolean" );
1478 	OSL_ENSURE(m_xRow.is(),"m_xRow is null!");
1479 	return m_xRow->getBoolean(columnIndex);
1480 }
1481 // -------------------------------------------------------------------------
getByte(sal_Int32 columnIndex)1482 sal_Int8 SAL_CALL OKeySet::getByte( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1483 {
1484     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::getByte" );
1485 	OSL_ENSURE(m_xRow.is(),"m_xRow is null!");
1486 	return m_xRow->getByte(columnIndex);
1487 }
1488 // -------------------------------------------------------------------------
getShort(sal_Int32 columnIndex)1489 sal_Int16 SAL_CALL OKeySet::getShort( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1490 {
1491     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::getShort" );
1492 	OSL_ENSURE(m_xRow.is(),"m_xRow is null!");
1493 	return m_xRow->getShort(columnIndex);
1494 }
1495 // -------------------------------------------------------------------------
getInt(sal_Int32 columnIndex)1496 sal_Int32 SAL_CALL OKeySet::getInt( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1497 {
1498     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::getInt" );
1499 	OSL_ENSURE(m_xRow.is(),"m_xRow is null!");
1500 	return m_xRow->getInt(columnIndex);
1501 }
1502 // -------------------------------------------------------------------------
getLong(sal_Int32 columnIndex)1503 sal_Int64 SAL_CALL OKeySet::getLong( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1504 {
1505     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::getLong" );
1506 	OSL_ENSURE(m_xRow.is(),"m_xRow is null!");
1507 	return m_xRow->getLong(columnIndex);
1508 }
1509 // -------------------------------------------------------------------------
getFloat(sal_Int32 columnIndex)1510 float SAL_CALL OKeySet::getFloat( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1511 {
1512     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::getFloat" );
1513 	OSL_ENSURE(m_xRow.is(),"m_xRow is null!");
1514 	return m_xRow->getFloat(columnIndex);
1515 }
1516 // -------------------------------------------------------------------------
getDouble(sal_Int32 columnIndex)1517 double SAL_CALL OKeySet::getDouble( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1518 {
1519     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::getDouble" );
1520 	OSL_ENSURE(m_xRow.is(),"m_xRow is null!");
1521 	return m_xRow->getDouble(columnIndex);
1522 }
1523 // -------------------------------------------------------------------------
getBytes(sal_Int32 columnIndex)1524 Sequence< sal_Int8 > SAL_CALL OKeySet::getBytes( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1525 {
1526     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::getBytes" );
1527 	OSL_ENSURE(m_xRow.is(),"m_xRow is null!");
1528 	return m_xRow->getBytes(columnIndex);
1529 }
1530 // -------------------------------------------------------------------------
getDate(sal_Int32 columnIndex)1531 ::com::sun::star::util::Date SAL_CALL OKeySet::getDate( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1532 {
1533     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::getDate" );
1534 	OSL_ENSURE(m_xRow.is(),"m_xRow is null!");
1535 	return m_xRow->getDate(columnIndex);
1536 }
1537 // -------------------------------------------------------------------------
getTime(sal_Int32 columnIndex)1538 ::com::sun::star::util::Time SAL_CALL OKeySet::getTime( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1539 {
1540     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::getTime" );
1541 	OSL_ENSURE(m_xRow.is(),"m_xRow is null!");
1542 	return m_xRow->getTime(columnIndex);
1543 }
1544 // -------------------------------------------------------------------------
getTimestamp(sal_Int32 columnIndex)1545 ::com::sun::star::util::DateTime SAL_CALL OKeySet::getTimestamp( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1546 {
1547     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::getTimestamp" );
1548 	OSL_ENSURE(m_xRow.is(),"m_xRow is null!");
1549 	return m_xRow->getTimestamp(columnIndex);
1550 }
1551 // -------------------------------------------------------------------------
getBinaryStream(sal_Int32 columnIndex)1552 Reference< ::com::sun::star::io::XInputStream > SAL_CALL OKeySet::getBinaryStream( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1553 {
1554     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::getBinaryStream" );
1555 	OSL_ENSURE(m_xRow.is(),"m_xRow is null!");
1556 	return m_xRow->getBinaryStream(columnIndex);
1557 }
1558 // -------------------------------------------------------------------------
getCharacterStream(sal_Int32 columnIndex)1559 Reference< ::com::sun::star::io::XInputStream > SAL_CALL OKeySet::getCharacterStream( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1560 {
1561     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::getCharacterStream" );
1562 	OSL_ENSURE(m_xRow.is(),"m_xRow is null!");
1563 	return m_xRow->getCharacterStream(columnIndex);
1564 }
1565 // -------------------------------------------------------------------------
getObject(sal_Int32 columnIndex,const Reference<::com::sun::star::container::XNameAccess> & typeMap)1566 Any SAL_CALL OKeySet::getObject( sal_Int32 columnIndex, const Reference< ::com::sun::star::container::XNameAccess >& typeMap ) throw(SQLException, RuntimeException)
1567 {
1568     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::getObject" );
1569 	OSL_ENSURE(m_xRow.is(),"m_xRow is null!");
1570 	return m_xRow->getObject(columnIndex,typeMap);
1571 }
1572 // -------------------------------------------------------------------------
getRef(sal_Int32 columnIndex)1573 Reference< XRef > SAL_CALL OKeySet::getRef( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1574 {
1575     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::getRef" );
1576 	OSL_ENSURE(m_xRow.is(),"m_xRow is null!");
1577 	return m_xRow->getRef(columnIndex);
1578 }
1579 // -------------------------------------------------------------------------
getBlob(sal_Int32 columnIndex)1580 Reference< XBlob > SAL_CALL OKeySet::getBlob( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1581 {
1582     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::getBlob" );
1583 	OSL_ENSURE(m_xRow.is(),"m_xRow is null!");
1584 	return m_xRow->getBlob(columnIndex);
1585 }
1586 // -------------------------------------------------------------------------
getClob(sal_Int32 columnIndex)1587 Reference< XClob > SAL_CALL OKeySet::getClob( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1588 {
1589     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::getClob" );
1590 	OSL_ENSURE(m_xRow.is(),"m_xRow is null!");
1591 	return m_xRow->getClob(columnIndex);
1592 }
1593 // -------------------------------------------------------------------------
getArray(sal_Int32 columnIndex)1594 Reference< XArray > SAL_CALL OKeySet::getArray( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1595 {
1596     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::getArray" );
1597 	OSL_ENSURE(m_xRow.is(),"m_xRow is null!");
1598 	return m_xRow->getArray(columnIndex);
1599 }
1600 // -------------------------------------------------------------------------
rowUpdated()1601 sal_Bool SAL_CALL OKeySet::rowUpdated(  ) throw(SQLException, RuntimeException)
1602 {
1603     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::rowUpdated" );
1604 	return m_aKeyIter != m_aKeyMap.begin() && m_aKeyIter != m_aKeyMap.end() && m_aKeyIter->second.second.first == 2;
1605 }
1606 // -------------------------------------------------------------------------
rowInserted()1607 sal_Bool SAL_CALL OKeySet::rowInserted(  ) throw(SQLException, RuntimeException)
1608 {
1609     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::rowInserted" );
1610 	return m_aKeyIter != m_aKeyMap.begin() && m_aKeyIter != m_aKeyMap.end() && m_aKeyIter->second.second.first == 1;
1611 }
1612 // -------------------------------------------------------------------------
rowDeleted()1613 sal_Bool SAL_CALL OKeySet::rowDeleted(  ) throw(SQLException, RuntimeException)
1614 {
1615     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::rowDeleted" );
1616 	sal_Bool bDeleted = m_bDeleted;
1617 	m_bDeleted = sal_False;
1618 	return bDeleted;
1619 }
1620 // -----------------------------------------------------------------------------
getComposedTableName(const::rtl::OUString & _sCatalog,const::rtl::OUString & _sSchema,const::rtl::OUString & _sTable)1621 ::rtl::OUString OKeySet::getComposedTableName(const ::rtl::OUString& _sCatalog,
1622 											  const ::rtl::OUString& _sSchema,
1623 											  const ::rtl::OUString& _sTable)
1624 {
1625     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OKeySet::getComposedTableName" );
1626 	::rtl::OUString aComposedName;
1627 	Reference<XDatabaseMetaData> xMetaData = m_xConnection->getMetaData();
1628 
1629 	if( xMetaData.is() && xMetaData->supportsTableCorrelationNames() )
1630 	{
1631 		aComposedName = ::dbtools::composeTableName( xMetaData, _sCatalog, _sSchema, _sTable, sal_False, ::dbtools::eInDataManipulation );
1632 		// first we have to check if the composed tablename is in the select clause or if an alias is used
1633 		Reference<XTablesSupplier> xTabSup(m_xComposer,UNO_QUERY);
1634 		Reference<XNameAccess> xSelectTables = xTabSup->getTables();
1635 		OSL_ENSURE(xSelectTables.is(),"No Select tables!");
1636 		if(xSelectTables.is())
1637 		{
1638 			if(!xSelectTables->hasByName(aComposedName))
1639 			{ // the composed name isn't used in the select clause so we have to find out which name is used instead
1640 				::rtl::OUString sCatalog,sSchema,sTable;
1641 				::dbtools::qualifiedNameComponents(xMetaData,m_sUpdateTableName,sCatalog,sSchema,sTable,::dbtools::eInDataManipulation);
1642 				aComposedName = ::dbtools::composeTableNameForSelect( m_xConnection, sCatalog, sSchema, sTable );
1643 			}
1644 			else
1645 				aComposedName = ::dbtools::composeTableNameForSelect( m_xConnection, _sCatalog, _sSchema, _sTable );
1646 		}
1647 	}
1648 	else
1649 		aComposedName = ::dbtools::composeTableNameForSelect( m_xConnection, _sCatalog, _sSchema, _sTable );
1650 
1651 	return aComposedName;
1652 }
1653 // -----------------------------------------------------------------------------
1654 namespace dbaccess
1655 {
1656 
getColumnPositions(const Reference<XNameAccess> & _rxQueryColumns,const::com::sun::star::uno::Sequence<::rtl::OUString> & _aColumnNames,const::rtl::OUString & _rsUpdateTableName,SelectColumnsMetaData & o_rColumnNames,bool i_bAppendTableName)1657 void getColumnPositions(const Reference<XNameAccess>& _rxQueryColumns,
1658 							const ::com::sun::star::uno::Sequence< ::rtl::OUString >& _aColumnNames,
1659 							const ::rtl::OUString& _rsUpdateTableName,
1660 							SelectColumnsMetaData& o_rColumnNames,
1661                             bool i_bAppendTableName)
1662 	{
1663 		// get the real name of the columns
1664 		Sequence< ::rtl::OUString> aSelNames(_rxQueryColumns->getElementNames());
1665 		const ::rtl::OUString* pSelIter	    = aSelNames.getConstArray();
1666 		const ::rtl::OUString* pSelEnd		= pSelIter + aSelNames.getLength();
1667 
1668 		const ::rtl::OUString* pTblColumnIter	= _aColumnNames.getConstArray();
1669 		const ::rtl::OUString* pTblColumnEnd	= pTblColumnIter + _aColumnNames.getLength();
1670 
1671 
1672         ::comphelper::UStringMixLess aTmp(o_rColumnNames.key_comp());
1673         ::comphelper::UStringMixEqual bCase(static_cast< ::comphelper::UStringMixLess*>(&aTmp)->isCaseSensitive());
1674 
1675 		for(sal_Int32 nPos = 1;pSelIter != pSelEnd;++pSelIter,++nPos)
1676 		{
1677 			Reference<XPropertySet> xQueryColumnProp(_rxQueryColumns->getByName(*pSelIter),UNO_QUERY_THROW);
1678 			::rtl::OUString sRealName,sTableName;
1679 			OSL_ENSURE(xQueryColumnProp->getPropertySetInfo()->hasPropertyByName(PROPERTY_REALNAME),"Property REALNAME not available!");
1680 			OSL_ENSURE(xQueryColumnProp->getPropertySetInfo()->hasPropertyByName(PROPERTY_TABLENAME),"Property TABLENAME not available!");
1681 			xQueryColumnProp->getPropertyValue(PROPERTY_REALNAME)	>>= sRealName;
1682 			xQueryColumnProp->getPropertyValue(PROPERTY_TABLENAME)	>>= sTableName;
1683 
1684 			for(;pTblColumnIter != pTblColumnEnd;++pTblColumnIter)
1685 			{
1686 				if(bCase(sRealName,*pTblColumnIter) && bCase(_rsUpdateTableName,sTableName) && o_rColumnNames.find(*pTblColumnIter) == o_rColumnNames.end())
1687 				{
1688 					sal_Int32 nType = 0;
1689 					xQueryColumnProp->getPropertyValue(PROPERTY_TYPE)	>>= nType;
1690                     sal_Int32 nScale = 0;
1691                     xQueryColumnProp->getPropertyValue(PROPERTY_SCALE)	>>= nScale;
1692                     ::rtl::OUString sColumnDefault;
1693                     if ( xQueryColumnProp->getPropertySetInfo()->hasPropertyByName(PROPERTY_DEFAULTVALUE) )
1694                         xQueryColumnProp->getPropertyValue(PROPERTY_DEFAULTVALUE) >>= sColumnDefault;
1695 
1696                     sal_Int32 nNullable = ColumnValue::NULLABLE_UNKNOWN;
1697                     OSL_VERIFY( xQueryColumnProp->getPropertyValue( PROPERTY_ISNULLABLE ) >>= nNullable );
1698 
1699                     if ( i_bAppendTableName )
1700                     {
1701                         ::rtl::OUStringBuffer sName;
1702                         sName.append(sTableName);
1703                         sName.appendAscii(".");
1704                         sName.append(sRealName);
1705                         SelectColumnDescription aColDesc( nPos, nType,nScale,nNullable != sdbc::ColumnValue::NO_NULLS, sColumnDefault );
1706                         aColDesc.sRealName = sRealName;
1707                         aColDesc.sTableName = sTableName;
1708                         o_rColumnNames[sName.makeStringAndClear()] = aColDesc;
1709                     }
1710                     else
1711                         o_rColumnNames[sRealName] = SelectColumnDescription( nPos, nType,nScale,nNullable != sdbc::ColumnValue::NO_NULLS, sColumnDefault );
1712 
1713 					break;
1714 				}
1715 			}
1716 			pTblColumnIter = _aColumnNames.getConstArray();
1717 		}
1718 	}
1719 }
1720 // -----------------------------------------------------------------------------
impl_convertValue_throw(const ORowSetRow & _rInsertRow,const SelectColumnDescription & i_aMetaData)1721 void OKeySet::impl_convertValue_throw(const ORowSetRow& _rInsertRow,const SelectColumnDescription& i_aMetaData)
1722 {
1723     ORowSetValue& aValue((_rInsertRow->get())[i_aMetaData.nPosition]);
1724     switch(i_aMetaData.nType)
1725     {
1726         case DataType::DECIMAL:
1727         case DataType::NUMERIC:
1728             {
1729                 ::rtl::OUString sValue = aValue.getString();
1730                 sal_Int32 nIndex = sValue.indexOf('.');
1731                 if ( nIndex != -1 )
1732                 {
1733 					aValue = sValue.copy(0,::std::min(sValue.getLength(),nIndex + (i_aMetaData.nScale > 0 ? i_aMetaData.nScale + 1 : 0)));
1734                 }
1735             }
1736             break;
1737         default:
1738             break;
1739     }
1740 }
1741 // -----------------------------------------------------------------------------
1742 
1743