1*b1cdbd2cSJim Jagielski /**************************************************************
2*b1cdbd2cSJim Jagielski *
3*b1cdbd2cSJim Jagielski * Licensed to the Apache Software Foundation (ASF) under one
4*b1cdbd2cSJim Jagielski * or more contributor license agreements. See the NOTICE file
5*b1cdbd2cSJim Jagielski * distributed with this work for additional information
6*b1cdbd2cSJim Jagielski * regarding copyright ownership. The ASF licenses this file
7*b1cdbd2cSJim Jagielski * to you under the Apache License, Version 2.0 (the
8*b1cdbd2cSJim Jagielski * "License"); you may not use this file except in compliance
9*b1cdbd2cSJim Jagielski * with the License. You may obtain a copy of the License at
10*b1cdbd2cSJim Jagielski *
11*b1cdbd2cSJim Jagielski * http://www.apache.org/licenses/LICENSE-2.0
12*b1cdbd2cSJim Jagielski *
13*b1cdbd2cSJim Jagielski * Unless required by applicable law or agreed to in writing,
14*b1cdbd2cSJim Jagielski * software distributed under the License is distributed on an
15*b1cdbd2cSJim Jagielski * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16*b1cdbd2cSJim Jagielski * KIND, either express or implied. See the License for the
17*b1cdbd2cSJim Jagielski * specific language governing permissions and limitations
18*b1cdbd2cSJim Jagielski * under the License.
19*b1cdbd2cSJim Jagielski *
20*b1cdbd2cSJim Jagielski *************************************************************/
21*b1cdbd2cSJim Jagielski
22*b1cdbd2cSJim Jagielski
23*b1cdbd2cSJim Jagielski
24*b1cdbd2cSJim Jagielski // MARKER(update_precomp.py): autogen include statement, do not remove
25*b1cdbd2cSJim Jagielski #include "precompiled_dbaccess.hxx"
26*b1cdbd2cSJim Jagielski
27*b1cdbd2cSJim Jagielski #include "RowSet.hxx"
28*b1cdbd2cSJim Jagielski #include "dbastrings.hrc"
29*b1cdbd2cSJim Jagielski #include "sdbcoretools.hxx"
30*b1cdbd2cSJim Jagielski #include "SingleSelectQueryComposer.hxx"
31*b1cdbd2cSJim Jagielski #include "module_dba.hxx"
32*b1cdbd2cSJim Jagielski #include "sdbcoretools.hxx"
33*b1cdbd2cSJim Jagielski #include "CRowSetColumn.hxx"
34*b1cdbd2cSJim Jagielski #include "CRowSetDataColumn.hxx"
35*b1cdbd2cSJim Jagielski #include "RowSetCache.hxx"
36*b1cdbd2cSJim Jagielski #include "core_resource.hrc"
37*b1cdbd2cSJim Jagielski #include "core_resource.hxx"
38*b1cdbd2cSJim Jagielski #include "tablecontainer.hxx"
39*b1cdbd2cSJim Jagielski
40*b1cdbd2cSJim Jagielski /** === begin UNO includes === **/
41*b1cdbd2cSJim Jagielski #include <com/sun/star/beans/PropertyAttribute.hpp>
42*b1cdbd2cSJim Jagielski #include <com/sun/star/container/XChild.hpp>
43*b1cdbd2cSJim Jagielski #include <com/sun/star/lang/DisposedException.hpp>
44*b1cdbd2cSJim Jagielski #include <com/sun/star/sdb/CommandType.hpp>
45*b1cdbd2cSJim Jagielski #include <com/sun/star/sdb/ErrorCondition.hpp>
46*b1cdbd2cSJim Jagielski #include <com/sun/star/sdb/RowChangeAction.hpp>
47*b1cdbd2cSJim Jagielski #include <com/sun/star/sdb/RowSetVetoException.hpp>
48*b1cdbd2cSJim Jagielski #include <com/sun/star/sdb/XCompletedConnection.hpp>
49*b1cdbd2cSJim Jagielski #include <com/sun/star/sdb/XParametersSupplier.hpp>
50*b1cdbd2cSJim Jagielski #include <com/sun/star/sdb/XQueriesSupplier.hpp>
51*b1cdbd2cSJim Jagielski #include <com/sun/star/sdbc/FetchDirection.hpp>
52*b1cdbd2cSJim Jagielski #include <com/sun/star/sdbc/ResultSetConcurrency.hpp>
53*b1cdbd2cSJim Jagielski #include <com/sun/star/sdbc/XDataSource.hpp>
54*b1cdbd2cSJim Jagielski #include <com/sun/star/sdbc/XDriverAccess.hpp>
55*b1cdbd2cSJim Jagielski #include <com/sun/star/sdbcx/CompareBookmark.hpp>
56*b1cdbd2cSJim Jagielski #include <com/sun/star/sdbcx/Privilege.hpp>
57*b1cdbd2cSJim Jagielski #include <com/sun/star/sdbcx/XDataDefinitionSupplier.hpp>
58*b1cdbd2cSJim Jagielski #include <com/sun/star/uno/XNamingService.hpp>
59*b1cdbd2cSJim Jagielski #include <com/sun/star/util/XNumberFormatsSupplier.hpp>
60*b1cdbd2cSJim Jagielski /** === end UNO includes === **/
61*b1cdbd2cSJim Jagielski
62*b1cdbd2cSJim Jagielski #include <comphelper/componentcontext.hxx>
63*b1cdbd2cSJim Jagielski #include <comphelper/extract.hxx>
64*b1cdbd2cSJim Jagielski #include <comphelper/interaction.hxx>
65*b1cdbd2cSJim Jagielski #include <comphelper/property.hxx>
66*b1cdbd2cSJim Jagielski #include <comphelper/seqstream.hxx>
67*b1cdbd2cSJim Jagielski #include <comphelper/sequence.hxx>
68*b1cdbd2cSJim Jagielski #include <comphelper/types.hxx>
69*b1cdbd2cSJim Jagielski #include <comphelper/uno3.hxx>
70*b1cdbd2cSJim Jagielski #include <connectivity/BlobHelper.hxx>
71*b1cdbd2cSJim Jagielski #include <connectivity/dbconversion.hxx>
72*b1cdbd2cSJim Jagielski #include <connectivity/dbexception.hxx>
73*b1cdbd2cSJim Jagielski #include <connectivity/dbtools.hxx>
74*b1cdbd2cSJim Jagielski #include <cppuhelper/exc_hlp.hxx>
75*b1cdbd2cSJim Jagielski #include <cppuhelper/interfacecontainer.h>
76*b1cdbd2cSJim Jagielski #include <cppuhelper/typeprovider.hxx>
77*b1cdbd2cSJim Jagielski #include <rtl/logfile.hxx>
78*b1cdbd2cSJim Jagielski #include <unotools/syslocale.hxx>
79*b1cdbd2cSJim Jagielski #include <tools/debug.hxx>
80*b1cdbd2cSJim Jagielski #include <tools/diagnose_ex.h>
81*b1cdbd2cSJim Jagielski #include <unotools/configmgr.hxx>
82*b1cdbd2cSJim Jagielski
83*b1cdbd2cSJim Jagielski using namespace utl;
84*b1cdbd2cSJim Jagielski using namespace dbaccess;
85*b1cdbd2cSJim Jagielski using namespace connectivity;
86*b1cdbd2cSJim Jagielski using namespace comphelper;
87*b1cdbd2cSJim Jagielski using namespace dbtools;
88*b1cdbd2cSJim Jagielski using namespace ::com::sun::star;
89*b1cdbd2cSJim Jagielski using namespace ::com::sun::star::uno;
90*b1cdbd2cSJim Jagielski using namespace ::com::sun::star::beans;
91*b1cdbd2cSJim Jagielski using namespace ::com::sun::star::sdbc;
92*b1cdbd2cSJim Jagielski using namespace ::com::sun::star::sdb;
93*b1cdbd2cSJim Jagielski using namespace ::com::sun::star::sdbcx;
94*b1cdbd2cSJim Jagielski using namespace ::com::sun::star::container;
95*b1cdbd2cSJim Jagielski using namespace ::com::sun::star::lang;
96*b1cdbd2cSJim Jagielski using namespace ::com::sun::star::task;
97*b1cdbd2cSJim Jagielski using namespace ::com::sun::star::util;
98*b1cdbd2cSJim Jagielski using namespace ::cppu;
99*b1cdbd2cSJim Jagielski using namespace ::osl;
100*b1cdbd2cSJim Jagielski
101*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
createRegistryInfo_ORowSet()102*b1cdbd2cSJim Jagielski extern "C" void SAL_CALL createRegistryInfo_ORowSet()
103*b1cdbd2cSJim Jagielski {
104*b1cdbd2cSJim Jagielski static ::dba::OAutoRegistration< ORowSet > aAutoRegistration;
105*b1cdbd2cSJim Jagielski }
106*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
107*b1cdbd2cSJim Jagielski
108*b1cdbd2cSJim Jagielski #define NOTIFY_LISTERNERS_CHECK(_rListeners,T,method) \
109*b1cdbd2cSJim Jagielski Sequence< Reference< XInterface > > aListenerSeq = _rListeners.getElements(); \
110*b1cdbd2cSJim Jagielski \
111*b1cdbd2cSJim Jagielski const Reference< XInterface >* pxIntBegin = aListenerSeq.getConstArray(); \
112*b1cdbd2cSJim Jagielski const Reference< XInterface >* pxInt = pxIntBegin + aListenerSeq.getLength(); \
113*b1cdbd2cSJim Jagielski \
114*b1cdbd2cSJim Jagielski _rGuard.clear(); \
115*b1cdbd2cSJim Jagielski sal_Bool bCheck = sal_True; \
116*b1cdbd2cSJim Jagielski while( pxInt > pxIntBegin && bCheck ) \
117*b1cdbd2cSJim Jagielski { \
118*b1cdbd2cSJim Jagielski try \
119*b1cdbd2cSJim Jagielski { \
120*b1cdbd2cSJim Jagielski while( pxInt > pxIntBegin && bCheck ) \
121*b1cdbd2cSJim Jagielski { \
122*b1cdbd2cSJim Jagielski --pxInt; \
123*b1cdbd2cSJim Jagielski bCheck = static_cast< T* >( pxInt->get() )->method(aEvt); \
124*b1cdbd2cSJim Jagielski } \
125*b1cdbd2cSJim Jagielski } \
126*b1cdbd2cSJim Jagielski catch( RuntimeException& ) \
127*b1cdbd2cSJim Jagielski { \
128*b1cdbd2cSJim Jagielski } \
129*b1cdbd2cSJim Jagielski } \
130*b1cdbd2cSJim Jagielski _rGuard.reset();
131*b1cdbd2cSJim Jagielski
132*b1cdbd2cSJim Jagielski
133*b1cdbd2cSJim Jagielski //..................................................................
134*b1cdbd2cSJim Jagielski namespace dbaccess
135*b1cdbd2cSJim Jagielski {
136*b1cdbd2cSJim Jagielski //..................................................................
137*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
ORowSet_CreateInstance(const Reference<XMultiServiceFactory> & _rxFactory)138*b1cdbd2cSJim Jagielski Reference< XInterface > ORowSet_CreateInstance(const Reference< XMultiServiceFactory >& _rxFactory)
139*b1cdbd2cSJim Jagielski {
140*b1cdbd2cSJim Jagielski return *(new ORowSet(_rxFactory));
141*b1cdbd2cSJim Jagielski }
142*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
ORowSet(const Reference<::com::sun::star::lang::XMultiServiceFactory> & _rxORB)143*b1cdbd2cSJim Jagielski ORowSet::ORowSet( const Reference< ::com::sun::star::lang::XMultiServiceFactory >& _rxORB )
144*b1cdbd2cSJim Jagielski :ORowSet_BASE1(m_aMutex)
145*b1cdbd2cSJim Jagielski ,ORowSetBase( _rxORB, ORowSet_BASE1::rBHelper, &m_aMutex )
146*b1cdbd2cSJim Jagielski ,m_pParameters( NULL )
147*b1cdbd2cSJim Jagielski ,m_aRowsetListeners(*m_pMutex)
148*b1cdbd2cSJim Jagielski ,m_aApproveListeners(*m_pMutex)
149*b1cdbd2cSJim Jagielski ,m_aRowsChangeListener(*m_pMutex)
150*b1cdbd2cSJim Jagielski ,m_pTables(NULL)
151*b1cdbd2cSJim Jagielski ,m_nFetchDirection(FetchDirection::FORWARD)
152*b1cdbd2cSJim Jagielski ,m_nFetchSize(50)
153*b1cdbd2cSJim Jagielski ,m_nMaxFieldSize(0)
154*b1cdbd2cSJim Jagielski ,m_nMaxRows(0)
155*b1cdbd2cSJim Jagielski ,m_nQueryTimeOut(0)
156*b1cdbd2cSJim Jagielski ,m_nCommandType(CommandType::COMMAND)
157*b1cdbd2cSJim Jagielski ,m_nTransactionIsolation(0)
158*b1cdbd2cSJim Jagielski ,m_nPrivileges(0)
159*b1cdbd2cSJim Jagielski ,m_nInAppend(0)
160*b1cdbd2cSJim Jagielski ,m_bUseEscapeProcessing(sal_True)
161*b1cdbd2cSJim Jagielski ,m_bApplyFilter(sal_False)
162*b1cdbd2cSJim Jagielski ,m_bCommandFacetsDirty( sal_True )
163*b1cdbd2cSJim Jagielski ,m_bModified(sal_False)
164*b1cdbd2cSJim Jagielski ,m_bRebuildConnOnExecute(sal_False)
165*b1cdbd2cSJim Jagielski ,m_bIsBookmarable(sal_True)
166*b1cdbd2cSJim Jagielski ,m_bNew(sal_False)
167*b1cdbd2cSJim Jagielski ,m_bCanUpdateInsertedRows(sal_True)
168*b1cdbd2cSJim Jagielski ,m_bOwnConnection(sal_False)
169*b1cdbd2cSJim Jagielski {
170*b1cdbd2cSJim Jagielski m_nResultSetType = ResultSetType::SCROLL_SENSITIVE;
171*b1cdbd2cSJim Jagielski m_nResultSetConcurrency = ResultSetConcurrency::UPDATABLE;
172*b1cdbd2cSJim Jagielski m_pMySelf = this;
173*b1cdbd2cSJim Jagielski m_aActiveConnection <<= m_xActiveConnection;
174*b1cdbd2cSJim Jagielski
175*b1cdbd2cSJim Jagielski sal_Int32 nRBT = PropertyAttribute::READONLY | PropertyAttribute::BOUND | PropertyAttribute::TRANSIENT;
176*b1cdbd2cSJim Jagielski sal_Int32 nRT = PropertyAttribute::READONLY | PropertyAttribute::TRANSIENT;
177*b1cdbd2cSJim Jagielski sal_Int32 nBT = PropertyAttribute::BOUND | PropertyAttribute::TRANSIENT;
178*b1cdbd2cSJim Jagielski
179*b1cdbd2cSJim Jagielski m_aPrematureParamValues.get().resize( 0 );
180*b1cdbd2cSJim Jagielski
181*b1cdbd2cSJim Jagielski // sdb.RowSet Properties
182*b1cdbd2cSJim Jagielski registerMayBeVoidProperty(PROPERTY_ACTIVE_CONNECTION,PROPERTY_ID_ACTIVE_CONNECTION, PropertyAttribute::MAYBEVOID|PropertyAttribute::TRANSIENT|PropertyAttribute::BOUND, &m_aActiveConnection, ::getCppuType(reinterpret_cast< Reference< XConnection >* >(NULL)));
183*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_DATASOURCENAME, PROPERTY_ID_DATASOURCENAME, PropertyAttribute::BOUND, &m_aDataSourceName, ::getCppuType(reinterpret_cast< ::rtl::OUString*>(NULL)));
184*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_COMMAND, PROPERTY_ID_COMMAND, PropertyAttribute::BOUND, &m_aCommand, ::getCppuType(reinterpret_cast< ::rtl::OUString*>(NULL)));
185*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_COMMAND_TYPE, PROPERTY_ID_COMMAND_TYPE, PropertyAttribute::BOUND, &m_nCommandType, ::getCppuType(reinterpret_cast< sal_Int32*>(NULL)));
186*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_ACTIVECOMMAND, PROPERTY_ID_ACTIVECOMMAND, nRBT, &m_aActiveCommand, ::getCppuType(reinterpret_cast< ::rtl::OUString*>(NULL)));
187*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_IGNORERESULT, PROPERTY_ID_IGNORERESULT, PropertyAttribute::BOUND, &m_bIgnoreResult, ::getBooleanCppuType());
188*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_FILTER, PROPERTY_ID_FILTER, PropertyAttribute::BOUND, &m_aFilter, ::getCppuType(reinterpret_cast< ::rtl::OUString*>(NULL)));
189*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_HAVING_CLAUSE, PROPERTY_ID_HAVING_CLAUSE, PropertyAttribute::BOUND, &m_aHavingClause, ::getCppuType(reinterpret_cast< ::rtl::OUString*>(NULL)));
190*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_GROUP_BY, PROPERTY_ID_GROUP_BY, PropertyAttribute::BOUND, &m_aGroupBy, ::getCppuType(reinterpret_cast< ::rtl::OUString*>(NULL)));
191*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_APPLYFILTER, PROPERTY_ID_APPLYFILTER, PropertyAttribute::BOUND, &m_bApplyFilter, ::getBooleanCppuType());
192*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_ORDER, PROPERTY_ID_ORDER, PropertyAttribute::BOUND, &m_aOrder, ::getCppuType(reinterpret_cast< ::rtl::OUString*>(NULL)));
193*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_PRIVILEGES, PROPERTY_ID_PRIVILEGES, nRT, &m_nPrivileges, ::getCppuType(reinterpret_cast< sal_Int32*>(NULL)));
194*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_ISMODIFIED, PROPERTY_ID_ISMODIFIED, nBT, &m_bModified, ::getBooleanCppuType());
195*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_ISNEW, PROPERTY_ID_ISNEW, nRBT, &m_bNew, ::getBooleanCppuType());
196*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_SINGLESELECTQUERYCOMPOSER,PROPERTY_ID_SINGLESELECTQUERYCOMPOSER, nRT, &m_xComposer, ::getCppuType(reinterpret_cast< Reference< XSingleSelectQueryComposer >* >(NULL)));
197*b1cdbd2cSJim Jagielski
198*b1cdbd2cSJim Jagielski // sdbcx.ResultSet Properties
199*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_ISBOOKMARKABLE, PROPERTY_ID_ISBOOKMARKABLE, nRT, &m_bIsBookmarable, ::getBooleanCppuType());
200*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_CANUPDATEINSERTEDROWS,PROPERTY_ID_CANUPDATEINSERTEDROWS, nRT, &m_bCanUpdateInsertedRows, ::getBooleanCppuType());
201*b1cdbd2cSJim Jagielski // sdbc.ResultSet Properties
202*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_RESULTSETCONCURRENCY, PROPERTY_ID_RESULTSETCONCURRENCY, PropertyAttribute::TRANSIENT, &m_nResultSetConcurrency,::getCppuType(reinterpret_cast< sal_Int32*>(NULL)));
203*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_RESULTSETTYPE, PROPERTY_ID_RESULTSETTYPE, PropertyAttribute::TRANSIENT, &m_nResultSetType, ::getCppuType(reinterpret_cast< sal_Int32*>(NULL)));
204*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_FETCHDIRECTION, PROPERTY_ID_FETCHDIRECTION, PropertyAttribute::TRANSIENT, &m_nFetchDirection, ::getCppuType(reinterpret_cast< sal_Int32*>(NULL)));
205*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_FETCHSIZE, PROPERTY_ID_FETCHSIZE, PropertyAttribute::TRANSIENT, &m_nFetchSize, ::getCppuType(reinterpret_cast< sal_Int32*>(NULL)));
206*b1cdbd2cSJim Jagielski
207*b1cdbd2cSJim Jagielski // sdbc.RowSet Properties
208*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_URL, PROPERTY_ID_URL, 0, &m_aURL, ::getCppuType(reinterpret_cast< ::rtl::OUString*>(NULL)));
209*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_TRANSACTIONISOLATION, PROPERTY_ID_TRANSACTIONISOLATION, PropertyAttribute::TRANSIENT, &m_nTransactionIsolation,::getCppuType(reinterpret_cast< sal_Int32*>(NULL)));
210*b1cdbd2cSJim Jagielski registerMayBeVoidProperty(PROPERTY_TYPEMAP, PROPERTY_ID_TYPEMAP, PropertyAttribute::MAYBEVOID|PropertyAttribute::TRANSIENT, &m_aTypeMap, ::getCppuType(reinterpret_cast< Reference< XNameAccess >* >(NULL)));
211*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_ESCAPE_PROCESSING,PROPERTY_ID_ESCAPE_PROCESSING, PropertyAttribute::BOUND, &m_bUseEscapeProcessing,::getBooleanCppuType() );
212*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_QUERYTIMEOUT, PROPERTY_ID_QUERYTIMEOUT, PropertyAttribute::TRANSIENT, &m_nQueryTimeOut, ::getCppuType(reinterpret_cast< sal_Int32*>(NULL)));
213*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_MAXFIELDSIZE, PROPERTY_ID_MAXFIELDSIZE, PropertyAttribute::TRANSIENT, &m_nMaxFieldSize, ::getCppuType(reinterpret_cast< sal_Int32*>(NULL)));
214*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_MAXROWS, PROPERTY_ID_MAXROWS, 0, &m_nMaxRows, ::getCppuType(reinterpret_cast< sal_Int32*>(NULL)) );
215*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_USER, PROPERTY_ID_USER, PropertyAttribute::TRANSIENT, &m_aUser, ::getCppuType(reinterpret_cast< ::rtl::OUString*>(NULL)));
216*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_PASSWORD, PROPERTY_ID_PASSWORD, PropertyAttribute::TRANSIENT, &m_aPassword, ::getCppuType(reinterpret_cast< ::rtl::OUString*>(NULL)));
217*b1cdbd2cSJim Jagielski
218*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_UPDATE_CATALOGNAME, PROPERTY_ID_UPDATE_CATALOGNAME, PropertyAttribute::BOUND, &m_aUpdateCatalogName, ::getCppuType(reinterpret_cast< ::rtl::OUString*>(NULL)));
219*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_UPDATE_SCHEMANAME, PROPERTY_ID_UPDATE_SCHEMANAME, PropertyAttribute::BOUND, &m_aUpdateSchemaName, ::getCppuType(reinterpret_cast< ::rtl::OUString*>(NULL)));
220*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_UPDATE_TABLENAME, PROPERTY_ID_UPDATE_TABLENAME, PropertyAttribute::BOUND, &m_aUpdateTableName, ::getCppuType(reinterpret_cast< ::rtl::OUString*>(NULL)));
221*b1cdbd2cSJim Jagielski }
222*b1cdbd2cSJim Jagielski
~ORowSet()223*b1cdbd2cSJim Jagielski ORowSet::~ORowSet()
224*b1cdbd2cSJim Jagielski {
225*b1cdbd2cSJim Jagielski if ( !m_rBHelper.bDisposed && !m_rBHelper.bInDispose )
226*b1cdbd2cSJim Jagielski {
227*b1cdbd2cSJim Jagielski OSL_ENSURE(0, "Please check who doesn't dispose this component!");
228*b1cdbd2cSJim Jagielski osl_incrementInterlockedCount( &m_refCount );
229*b1cdbd2cSJim Jagielski dispose();
230*b1cdbd2cSJim Jagielski }
231*b1cdbd2cSJim Jagielski }
232*b1cdbd2cSJim Jagielski
233*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
getPropertyDefaultByHandle(sal_Int32 _nHandle,Any & _rDefault) const234*b1cdbd2cSJim Jagielski void ORowSet::getPropertyDefaultByHandle( sal_Int32 _nHandle, Any& _rDefault ) const
235*b1cdbd2cSJim Jagielski {
236*b1cdbd2cSJim Jagielski switch( _nHandle )
237*b1cdbd2cSJim Jagielski {
238*b1cdbd2cSJim Jagielski case PROPERTY_ID_COMMAND_TYPE:
239*b1cdbd2cSJim Jagielski _rDefault <<= static_cast<sal_Int32>(CommandType::COMMAND);
240*b1cdbd2cSJim Jagielski break;
241*b1cdbd2cSJim Jagielski case PROPERTY_ID_IGNORERESULT:
242*b1cdbd2cSJim Jagielski _rDefault <<= sal_False;
243*b1cdbd2cSJim Jagielski break;
244*b1cdbd2cSJim Jagielski case PROPERTY_ID_APPLYFILTER:
245*b1cdbd2cSJim Jagielski _rDefault <<= sal_False;
246*b1cdbd2cSJim Jagielski break;
247*b1cdbd2cSJim Jagielski case PROPERTY_ID_ISMODIFIED:
248*b1cdbd2cSJim Jagielski _rDefault <<= sal_False;
249*b1cdbd2cSJim Jagielski break;
250*b1cdbd2cSJim Jagielski case PROPERTY_ID_ISBOOKMARKABLE:
251*b1cdbd2cSJim Jagielski _rDefault <<= sal_True;
252*b1cdbd2cSJim Jagielski break;
253*b1cdbd2cSJim Jagielski case PROPERTY_ID_CANUPDATEINSERTEDROWS:
254*b1cdbd2cSJim Jagielski _rDefault <<= sal_True;
255*b1cdbd2cSJim Jagielski break;
256*b1cdbd2cSJim Jagielski case PROPERTY_ID_RESULTSETTYPE:
257*b1cdbd2cSJim Jagielski _rDefault <<= ResultSetType::SCROLL_INSENSITIVE;
258*b1cdbd2cSJim Jagielski break;
259*b1cdbd2cSJim Jagielski case PROPERTY_ID_RESULTSETCONCURRENCY:
260*b1cdbd2cSJim Jagielski _rDefault <<= ResultSetConcurrency::UPDATABLE;
261*b1cdbd2cSJim Jagielski break;
262*b1cdbd2cSJim Jagielski case PROPERTY_ID_FETCHDIRECTION:
263*b1cdbd2cSJim Jagielski _rDefault <<= FetchDirection::FORWARD;
264*b1cdbd2cSJim Jagielski break;
265*b1cdbd2cSJim Jagielski case PROPERTY_ID_FETCHSIZE:
266*b1cdbd2cSJim Jagielski _rDefault <<= static_cast<sal_Int32>(1);
267*b1cdbd2cSJim Jagielski break;
268*b1cdbd2cSJim Jagielski case PROPERTY_ID_ESCAPE_PROCESSING:
269*b1cdbd2cSJim Jagielski _rDefault <<= sal_True;
270*b1cdbd2cSJim Jagielski break;
271*b1cdbd2cSJim Jagielski case PROPERTY_ID_MAXROWS:
272*b1cdbd2cSJim Jagielski _rDefault <<= sal_Int32( 0 );
273*b1cdbd2cSJim Jagielski break;
274*b1cdbd2cSJim Jagielski case PROPERTY_ID_FILTER:
275*b1cdbd2cSJim Jagielski case PROPERTY_ID_HAVING_CLAUSE:
276*b1cdbd2cSJim Jagielski case PROPERTY_ID_GROUP_BY:
277*b1cdbd2cSJim Jagielski case PROPERTY_ID_ORDER:
278*b1cdbd2cSJim Jagielski case PROPERTY_ID_UPDATE_CATALOGNAME:
279*b1cdbd2cSJim Jagielski case PROPERTY_ID_UPDATE_SCHEMANAME:
280*b1cdbd2cSJim Jagielski case PROPERTY_ID_UPDATE_TABLENAME:
281*b1cdbd2cSJim Jagielski _rDefault <<= ::rtl::OUString();
282*b1cdbd2cSJim Jagielski break;
283*b1cdbd2cSJim Jagielski }
284*b1cdbd2cSJim Jagielski }
285*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
286*b1cdbd2cSJim Jagielski // typedef ::comphelper::OPropertyArrayUsageHelper<ORowSet> ORowSet_Prop;
287*b1cdbd2cSJim Jagielski
setFastPropertyValue_NoBroadcast(sal_Int32 nHandle,const Any & rValue)288*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::setFastPropertyValue_NoBroadcast(sal_Int32 nHandle,const Any& rValue) throw (Exception)
289*b1cdbd2cSJim Jagielski {
290*b1cdbd2cSJim Jagielski switch(nHandle)
291*b1cdbd2cSJim Jagielski {
292*b1cdbd2cSJim Jagielski case PROPERTY_ID_ISMODIFIED:
293*b1cdbd2cSJim Jagielski m_bModified = cppu::any2bool(rValue);
294*b1cdbd2cSJim Jagielski break;
295*b1cdbd2cSJim Jagielski case PROPERTY_ID_FETCHDIRECTION:
296*b1cdbd2cSJim Jagielski if( m_nResultSetType == ResultSetType::FORWARD_ONLY)
297*b1cdbd2cSJim Jagielski throw Exception(); // else run through
298*b1cdbd2cSJim Jagielski default:
299*b1cdbd2cSJim Jagielski OPropertyStateContainer::setFastPropertyValue_NoBroadcast(nHandle,rValue);
300*b1cdbd2cSJim Jagielski }
301*b1cdbd2cSJim Jagielski
302*b1cdbd2cSJim Jagielski if ( ( nHandle == PROPERTY_ID_ACTIVE_CONNECTION )
303*b1cdbd2cSJim Jagielski || ( nHandle == PROPERTY_ID_DATASOURCENAME )
304*b1cdbd2cSJim Jagielski || ( nHandle == PROPERTY_ID_COMMAND )
305*b1cdbd2cSJim Jagielski || ( nHandle == PROPERTY_ID_COMMAND_TYPE )
306*b1cdbd2cSJim Jagielski || ( nHandle == PROPERTY_ID_IGNORERESULT )
307*b1cdbd2cSJim Jagielski || ( nHandle == PROPERTY_ID_FILTER )
308*b1cdbd2cSJim Jagielski || ( nHandle == PROPERTY_ID_HAVING_CLAUSE )
309*b1cdbd2cSJim Jagielski || ( nHandle == PROPERTY_ID_GROUP_BY )
310*b1cdbd2cSJim Jagielski || ( nHandle == PROPERTY_ID_APPLYFILTER )
311*b1cdbd2cSJim Jagielski || ( nHandle == PROPERTY_ID_ORDER )
312*b1cdbd2cSJim Jagielski || ( nHandle == PROPERTY_ID_URL )
313*b1cdbd2cSJim Jagielski || ( nHandle == PROPERTY_ID_USER )
314*b1cdbd2cSJim Jagielski )
315*b1cdbd2cSJim Jagielski {
316*b1cdbd2cSJim Jagielski m_bCommandFacetsDirty = sal_True;
317*b1cdbd2cSJim Jagielski }
318*b1cdbd2cSJim Jagielski
319*b1cdbd2cSJim Jagielski
320*b1cdbd2cSJim Jagielski switch(nHandle)
321*b1cdbd2cSJim Jagielski {
322*b1cdbd2cSJim Jagielski case PROPERTY_ID_ACTIVE_CONNECTION:
323*b1cdbd2cSJim Jagielski // the new connection
324*b1cdbd2cSJim Jagielski {
325*b1cdbd2cSJim Jagielski Reference< XConnection > xNewConnection(m_aActiveConnection,UNO_QUERY);
326*b1cdbd2cSJim Jagielski setActiveConnection(xNewConnection, sal_False);
327*b1cdbd2cSJim Jagielski }
328*b1cdbd2cSJim Jagielski
329*b1cdbd2cSJim Jagielski m_bOwnConnection = sal_False;
330*b1cdbd2cSJim Jagielski m_bRebuildConnOnExecute = sal_False;
331*b1cdbd2cSJim Jagielski break;
332*b1cdbd2cSJim Jagielski
333*b1cdbd2cSJim Jagielski case PROPERTY_ID_DATASOURCENAME:
334*b1cdbd2cSJim Jagielski if(!m_xStatement.is())
335*b1cdbd2cSJim Jagielski {
336*b1cdbd2cSJim Jagielski Reference< XConnection > xNewConn;
337*b1cdbd2cSJim Jagielski Any aNewConn;
338*b1cdbd2cSJim Jagielski aNewConn <<= xNewConn;
339*b1cdbd2cSJim Jagielski setFastPropertyValue(PROPERTY_ID_ACTIVE_CONNECTION, aNewConn);
340*b1cdbd2cSJim Jagielski }
341*b1cdbd2cSJim Jagielski else
342*b1cdbd2cSJim Jagielski m_bRebuildConnOnExecute = sal_True;
343*b1cdbd2cSJim Jagielski break;
344*b1cdbd2cSJim Jagielski case PROPERTY_ID_FETCHSIZE:
345*b1cdbd2cSJim Jagielski if(m_pCache)
346*b1cdbd2cSJim Jagielski {
347*b1cdbd2cSJim Jagielski m_pCache->setFetchSize(m_nFetchSize);
348*b1cdbd2cSJim Jagielski fireRowcount();
349*b1cdbd2cSJim Jagielski }
350*b1cdbd2cSJim Jagielski break;
351*b1cdbd2cSJim Jagielski case PROPERTY_ID_URL:
352*b1cdbd2cSJim Jagielski // is the connection-to-be-built determined by the url (which is the case if m_aDataSourceName is empty) ?
353*b1cdbd2cSJim Jagielski if (!m_aDataSourceName.getLength())
354*b1cdbd2cSJim Jagielski {
355*b1cdbd2cSJim Jagielski // are we active at the moment ?
356*b1cdbd2cSJim Jagielski if (m_xStatement.is())
357*b1cdbd2cSJim Jagielski // yes -> the next execute needs to rebuild our connection because of this new property
358*b1cdbd2cSJim Jagielski m_bRebuildConnOnExecute = sal_True;
359*b1cdbd2cSJim Jagielski else
360*b1cdbd2cSJim Jagielski { // no -> drop our active connection (if we have one) as it doesn't correspond to this new property value anymore
361*b1cdbd2cSJim Jagielski Reference< XConnection > xNewConn;
362*b1cdbd2cSJim Jagielski Any aNewConn;
363*b1cdbd2cSJim Jagielski aNewConn <<= xNewConn;
364*b1cdbd2cSJim Jagielski setFastPropertyValue(PROPERTY_ID_ACTIVE_CONNECTION, aNewConn);
365*b1cdbd2cSJim Jagielski }
366*b1cdbd2cSJim Jagielski }
367*b1cdbd2cSJim Jagielski m_bOwnConnection = sal_True;
368*b1cdbd2cSJim Jagielski break;
369*b1cdbd2cSJim Jagielski case PROPERTY_ID_TYPEMAP:
370*b1cdbd2cSJim Jagielski ::cppu::extractInterface(m_xTypeMap,m_aTypeMap);
371*b1cdbd2cSJim Jagielski break;
372*b1cdbd2cSJim Jagielski default:
373*b1cdbd2cSJim Jagielski break;
374*b1cdbd2cSJim Jagielski };
375*b1cdbd2cSJim Jagielski }
376*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
getFastPropertyValue(Any & rValue,sal_Int32 nHandle) const377*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::getFastPropertyValue(Any& rValue,sal_Int32 nHandle) const
378*b1cdbd2cSJim Jagielski {
379*b1cdbd2cSJim Jagielski if(m_pCache)
380*b1cdbd2cSJim Jagielski {
381*b1cdbd2cSJim Jagielski switch(nHandle)
382*b1cdbd2cSJim Jagielski {
383*b1cdbd2cSJim Jagielski case PROPERTY_ID_ISMODIFIED:
384*b1cdbd2cSJim Jagielski rValue.setValue(&m_bModified,::getCppuBooleanType());
385*b1cdbd2cSJim Jagielski break;
386*b1cdbd2cSJim Jagielski case PROPERTY_ID_ISNEW:
387*b1cdbd2cSJim Jagielski rValue.setValue(&m_bNew,::getCppuBooleanType());
388*b1cdbd2cSJim Jagielski break;
389*b1cdbd2cSJim Jagielski case PROPERTY_ID_PRIVILEGES:
390*b1cdbd2cSJim Jagielski rValue <<= m_pCache->m_nPrivileges;
391*b1cdbd2cSJim Jagielski break;
392*b1cdbd2cSJim Jagielski case PROPERTY_ID_ACTIVE_CONNECTION:
393*b1cdbd2cSJim Jagielski rValue <<= m_xActiveConnection;
394*b1cdbd2cSJim Jagielski break;
395*b1cdbd2cSJim Jagielski case PROPERTY_ID_TYPEMAP:
396*b1cdbd2cSJim Jagielski rValue <<= m_xTypeMap;
397*b1cdbd2cSJim Jagielski break;
398*b1cdbd2cSJim Jagielski default:
399*b1cdbd2cSJim Jagielski ORowSetBase::getFastPropertyValue(rValue,nHandle);
400*b1cdbd2cSJim Jagielski };
401*b1cdbd2cSJim Jagielski }
402*b1cdbd2cSJim Jagielski else
403*b1cdbd2cSJim Jagielski {
404*b1cdbd2cSJim Jagielski switch(nHandle)
405*b1cdbd2cSJim Jagielski {
406*b1cdbd2cSJim Jagielski case PROPERTY_ID_ACTIVE_CONNECTION:
407*b1cdbd2cSJim Jagielski rValue <<= m_xActiveConnection;
408*b1cdbd2cSJim Jagielski break;
409*b1cdbd2cSJim Jagielski case PROPERTY_ID_TYPEMAP:
410*b1cdbd2cSJim Jagielski rValue <<= m_xTypeMap;
411*b1cdbd2cSJim Jagielski break;
412*b1cdbd2cSJim Jagielski default:
413*b1cdbd2cSJim Jagielski ORowSetBase::getFastPropertyValue(rValue,nHandle);
414*b1cdbd2cSJim Jagielski }
415*b1cdbd2cSJim Jagielski }
416*b1cdbd2cSJim Jagielski }
417*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
418*b1cdbd2cSJim Jagielski // com::sun::star::XTypeProvider
getTypes()419*b1cdbd2cSJim Jagielski Sequence< Type > SAL_CALL ORowSet::getTypes() throw (RuntimeException)
420*b1cdbd2cSJim Jagielski {
421*b1cdbd2cSJim Jagielski OTypeCollection aTypes(::getCppuType( (const Reference< XPropertySet > *)0 ),
422*b1cdbd2cSJim Jagielski ::getCppuType( (const Reference< XFastPropertySet > *)0 ),
423*b1cdbd2cSJim Jagielski ::getCppuType( (const Reference< XMultiPropertySet > *)0 ),
424*b1cdbd2cSJim Jagielski ::comphelper::concatSequences(ORowSet_BASE1::getTypes(),ORowSetBase::getTypes()));
425*b1cdbd2cSJim Jagielski return aTypes.getTypes();
426*b1cdbd2cSJim Jagielski }
427*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
getImplementationId()428*b1cdbd2cSJim Jagielski Sequence< sal_Int8 > SAL_CALL ORowSet::getImplementationId() throw (RuntimeException)
429*b1cdbd2cSJim Jagielski {
430*b1cdbd2cSJim Jagielski static OImplementationId * pId = 0;
431*b1cdbd2cSJim Jagielski if (! pId)
432*b1cdbd2cSJim Jagielski {
433*b1cdbd2cSJim Jagielski MutexGuard aGuard( Mutex::getGlobalMutex() );
434*b1cdbd2cSJim Jagielski if (! pId)
435*b1cdbd2cSJim Jagielski {
436*b1cdbd2cSJim Jagielski static OImplementationId aId;
437*b1cdbd2cSJim Jagielski pId = &aId;
438*b1cdbd2cSJim Jagielski }
439*b1cdbd2cSJim Jagielski }
440*b1cdbd2cSJim Jagielski return pId->getImplementationId();
441*b1cdbd2cSJim Jagielski }
442*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
443*b1cdbd2cSJim Jagielski
444*b1cdbd2cSJim Jagielski // com::sun::star::XInterface
queryInterface(const Type & rType)445*b1cdbd2cSJim Jagielski Any SAL_CALL ORowSet::queryInterface( const Type & rType ) throw (RuntimeException)
446*b1cdbd2cSJim Jagielski {
447*b1cdbd2cSJim Jagielski return ORowSet_BASE1::queryInterface( rType);
448*b1cdbd2cSJim Jagielski }
449*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
acquire()450*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::acquire() throw()
451*b1cdbd2cSJim Jagielski {
452*b1cdbd2cSJim Jagielski ORowSet_BASE1::acquire();
453*b1cdbd2cSJim Jagielski }
454*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
release()455*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::release() throw()
456*b1cdbd2cSJim Jagielski {
457*b1cdbd2cSJim Jagielski ORowSet_BASE1::release();
458*b1cdbd2cSJim Jagielski }
459*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
460*b1cdbd2cSJim Jagielski
461*b1cdbd2cSJim Jagielski // com::sun::star::XUnoTunnel
getSomething(const Sequence<sal_Int8> & rId)462*b1cdbd2cSJim Jagielski sal_Int64 SAL_CALL ORowSet::getSomething( const Sequence< sal_Int8 >& rId ) throw(RuntimeException)
463*b1cdbd2cSJim Jagielski {
464*b1cdbd2cSJim Jagielski if (rId.getLength() == 16 && 0 == rtl_compareMemory(getImplementationId().getConstArray(), rId.getConstArray(), 16 ) )
465*b1cdbd2cSJim Jagielski return reinterpret_cast<sal_Int64>(this);
466*b1cdbd2cSJim Jagielski
467*b1cdbd2cSJim Jagielski return 0;
468*b1cdbd2cSJim Jagielski }
469*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
470*b1cdbd2cSJim Jagielski // com::sun::star::XAggregation
queryAggregation(const Type & rType)471*b1cdbd2cSJim Jagielski Any SAL_CALL ORowSet::queryAggregation( const Type& rType ) throw(RuntimeException)
472*b1cdbd2cSJim Jagielski {
473*b1cdbd2cSJim Jagielski Any aRet(ORowSetBase::queryInterface(rType));
474*b1cdbd2cSJim Jagielski if (!aRet.hasValue())
475*b1cdbd2cSJim Jagielski aRet = ORowSet_BASE1::queryAggregation(rType);
476*b1cdbd2cSJim Jagielski return aRet;
477*b1cdbd2cSJim Jagielski }
478*b1cdbd2cSJim Jagielski //------------------------------------------------------------------------------
getImplementationName_static()479*b1cdbd2cSJim Jagielski rtl::OUString ORowSet::getImplementationName_static( ) throw(RuntimeException)
480*b1cdbd2cSJim Jagielski {
481*b1cdbd2cSJim Jagielski return rtl::OUString::createFromAscii("com.sun.star.comp.dba.ORowSet");
482*b1cdbd2cSJim Jagielski }
483*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
484*b1cdbd2cSJim Jagielski // ::com::sun::star::XServiceInfo
getImplementationName()485*b1cdbd2cSJim Jagielski ::rtl::OUString SAL_CALL ORowSet::getImplementationName( ) throw(RuntimeException)
486*b1cdbd2cSJim Jagielski {
487*b1cdbd2cSJim Jagielski return getImplementationName_static();
488*b1cdbd2cSJim Jagielski }
489*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
supportsService(const::rtl::OUString & _rServiceName)490*b1cdbd2cSJim Jagielski sal_Bool SAL_CALL ORowSet::supportsService( const ::rtl::OUString& _rServiceName ) throw(RuntimeException)
491*b1cdbd2cSJim Jagielski {
492*b1cdbd2cSJim Jagielski return ::comphelper::findValue(getSupportedServiceNames(), _rServiceName, sal_True).getLength() != 0;
493*b1cdbd2cSJim Jagielski }
494*b1cdbd2cSJim Jagielski //------------------------------------------------------------------------------
getSupportedServiceNames_static()495*b1cdbd2cSJim Jagielski Sequence< ::rtl::OUString > ORowSet::getSupportedServiceNames_static( ) throw (RuntimeException)
496*b1cdbd2cSJim Jagielski {
497*b1cdbd2cSJim Jagielski Sequence< rtl::OUString > aSNS( 5 );
498*b1cdbd2cSJim Jagielski aSNS[0] = SERVICE_SDBC_RESULTSET;
499*b1cdbd2cSJim Jagielski aSNS[1] = SERVICE_SDBC_ROWSET;
500*b1cdbd2cSJim Jagielski aSNS[2] = SERVICE_SDBCX_RESULTSET;
501*b1cdbd2cSJim Jagielski aSNS[3] = SERVICE_SDB_RESULTSET;
502*b1cdbd2cSJim Jagielski aSNS[4] = SERVICE_SDB_ROWSET;
503*b1cdbd2cSJim Jagielski return aSNS;
504*b1cdbd2cSJim Jagielski }
505*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
getSupportedServiceNames()506*b1cdbd2cSJim Jagielski Sequence< ::rtl::OUString > SAL_CALL ORowSet::getSupportedServiceNames( ) throw(RuntimeException)
507*b1cdbd2cSJim Jagielski {
508*b1cdbd2cSJim Jagielski return getSupportedServiceNames_static();
509*b1cdbd2cSJim Jagielski }
510*b1cdbd2cSJim Jagielski //------------------------------------------------------------------------------
Create(const Reference<XComponentContext> & _rxContext)511*b1cdbd2cSJim Jagielski Reference< XInterface > ORowSet::Create(const Reference< XComponentContext >& _rxContext)
512*b1cdbd2cSJim Jagielski {
513*b1cdbd2cSJim Jagielski ::comphelper::ComponentContext aContext( _rxContext );
514*b1cdbd2cSJim Jagielski return ORowSet_CreateInstance( aContext.getLegacyServiceFactory() );
515*b1cdbd2cSJim Jagielski }
516*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
517*b1cdbd2cSJim Jagielski // OComponentHelper
disposing()518*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::disposing()
519*b1cdbd2cSJim Jagielski {
520*b1cdbd2cSJim Jagielski OPropertyStateContainer::disposing();
521*b1cdbd2cSJim Jagielski
522*b1cdbd2cSJim Jagielski MutexGuard aGuard(m_aMutex);
523*b1cdbd2cSJim Jagielski EventObject aDisposeEvent;
524*b1cdbd2cSJim Jagielski aDisposeEvent.Source = static_cast< XComponent* >(this);
525*b1cdbd2cSJim Jagielski m_aRowsetListeners.disposeAndClear( aDisposeEvent );
526*b1cdbd2cSJim Jagielski m_aApproveListeners.disposeAndClear( aDisposeEvent );
527*b1cdbd2cSJim Jagielski m_aRowsChangeListener.disposeAndClear( aDisposeEvent );
528*b1cdbd2cSJim Jagielski
529*b1cdbd2cSJim Jagielski freeResources( true );
530*b1cdbd2cSJim Jagielski
531*b1cdbd2cSJim Jagielski // remove myself as dispose listener
532*b1cdbd2cSJim Jagielski Reference< XComponent > xComponent(m_xActiveConnection, UNO_QUERY);
533*b1cdbd2cSJim Jagielski if (xComponent.is())
534*b1cdbd2cSJim Jagielski {
535*b1cdbd2cSJim Jagielski Reference<XEventListener> xEvt;
536*b1cdbd2cSJim Jagielski query_aggregation(this,xEvt);
537*b1cdbd2cSJim Jagielski xComponent->removeEventListener(xEvt);
538*b1cdbd2cSJim Jagielski }
539*b1cdbd2cSJim Jagielski
540*b1cdbd2cSJim Jagielski m_aActiveConnection = Any(); // the any conatains a reference too
541*b1cdbd2cSJim Jagielski if(m_bOwnConnection)
542*b1cdbd2cSJim Jagielski ::comphelper::disposeComponent(m_xActiveConnection);
543*b1cdbd2cSJim Jagielski m_xActiveConnection = NULL;
544*b1cdbd2cSJim Jagielski
545*b1cdbd2cSJim Jagielski
546*b1cdbd2cSJim Jagielski ORowSetBase::disposing();
547*b1cdbd2cSJim Jagielski }
548*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
freeResources(bool _bComplete)549*b1cdbd2cSJim Jagielski void ORowSet::freeResources( bool _bComplete )
550*b1cdbd2cSJim Jagielski {
551*b1cdbd2cSJim Jagielski MutexGuard aGuard(m_aMutex);
552*b1cdbd2cSJim Jagielski
553*b1cdbd2cSJim Jagielski // free all clones
554*b1cdbd2cSJim Jagielski connectivity::OWeakRefArray::iterator aEnd = m_aClones.end();
555*b1cdbd2cSJim Jagielski for (connectivity::OWeakRefArray::iterator i = m_aClones.begin(); aEnd != i; i++)
556*b1cdbd2cSJim Jagielski {
557*b1cdbd2cSJim Jagielski Reference< XComponent > xComp(i->get(), UNO_QUERY);
558*b1cdbd2cSJim Jagielski if (xComp.is())
559*b1cdbd2cSJim Jagielski xComp->dispose();
560*b1cdbd2cSJim Jagielski }
561*b1cdbd2cSJim Jagielski m_aClones.clear();
562*b1cdbd2cSJim Jagielski
563*b1cdbd2cSJim Jagielski if ( _bComplete )
564*b1cdbd2cSJim Jagielski {
565*b1cdbd2cSJim Jagielski // the columns must be disposed before the querycomposer is disposed because
566*b1cdbd2cSJim Jagielski // their owner can be the composer
567*b1cdbd2cSJim Jagielski TDataColumns().swap(m_aDataColumns);// clear and resize capacity
568*b1cdbd2cSJim Jagielski m_aReadOnlyDataColumns.clear();
569*b1cdbd2cSJim Jagielski m_xColumns = NULL;
570*b1cdbd2cSJim Jagielski if ( m_pColumns )
571*b1cdbd2cSJim Jagielski m_pColumns->disposing();
572*b1cdbd2cSJim Jagielski // dispose the composer to avoid that everbody knows that the querycomposer is eol
573*b1cdbd2cSJim Jagielski try { ::comphelper::disposeComponent( m_xComposer ); }
574*b1cdbd2cSJim Jagielski catch(Exception&)
575*b1cdbd2cSJim Jagielski {
576*b1cdbd2cSJim Jagielski DBG_UNHANDLED_EXCEPTION();
577*b1cdbd2cSJim Jagielski m_xComposer = NULL;
578*b1cdbd2cSJim Jagielski }
579*b1cdbd2cSJim Jagielski
580*b1cdbd2cSJim Jagielski // let our warnings container forget the reference to the (possibly disposed) old result set
581*b1cdbd2cSJim Jagielski m_aWarnings.setExternalWarnings( NULL );
582*b1cdbd2cSJim Jagielski
583*b1cdbd2cSJim Jagielski DELETEZ(m_pCache);
584*b1cdbd2cSJim Jagielski
585*b1cdbd2cSJim Jagielski impl_resetTables_nothrow();
586*b1cdbd2cSJim Jagielski
587*b1cdbd2cSJim Jagielski m_xStatement = NULL;
588*b1cdbd2cSJim Jagielski m_xTypeMap = NULL;
589*b1cdbd2cSJim Jagielski
590*b1cdbd2cSJim Jagielski m_aBookmark = Any();
591*b1cdbd2cSJim Jagielski m_bBeforeFirst = sal_True;
592*b1cdbd2cSJim Jagielski m_bAfterLast = sal_False;
593*b1cdbd2cSJim Jagielski m_bNew = sal_False;
594*b1cdbd2cSJim Jagielski m_bModified = sal_False;
595*b1cdbd2cSJim Jagielski m_bIsInsertRow = sal_False;
596*b1cdbd2cSJim Jagielski m_bLastKnownRowCountFinal = sal_False;
597*b1cdbd2cSJim Jagielski m_nLastKnownRowCount = 0;
598*b1cdbd2cSJim Jagielski if ( m_aOldRow.isValid() )
599*b1cdbd2cSJim Jagielski m_aOldRow->clearRow();
600*b1cdbd2cSJim Jagielski
601*b1cdbd2cSJim Jagielski impl_disposeParametersContainer_nothrow();
602*b1cdbd2cSJim Jagielski
603*b1cdbd2cSJim Jagielski m_bCommandFacetsDirty = sal_True;
604*b1cdbd2cSJim Jagielski }
605*b1cdbd2cSJim Jagielski }
606*b1cdbd2cSJim Jagielski
607*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
setActiveConnection(Reference<XConnection> & _rxNewConn,sal_Bool _bFireEvent)608*b1cdbd2cSJim Jagielski void ORowSet::setActiveConnection( Reference< XConnection >& _rxNewConn, sal_Bool _bFireEvent )
609*b1cdbd2cSJim Jagielski {
610*b1cdbd2cSJim Jagielski if (_rxNewConn.get() == m_xActiveConnection.get())
611*b1cdbd2cSJim Jagielski // nothing to do
612*b1cdbd2cSJim Jagielski return;
613*b1cdbd2cSJim Jagielski
614*b1cdbd2cSJim Jagielski // remove the event listener for the old connection
615*b1cdbd2cSJim Jagielski Reference< XComponent > xComponent(m_xActiveConnection, UNO_QUERY);
616*b1cdbd2cSJim Jagielski if (xComponent.is())
617*b1cdbd2cSJim Jagielski {
618*b1cdbd2cSJim Jagielski Reference<XEventListener> xListener;
619*b1cdbd2cSJim Jagielski query_aggregation(this, xListener);
620*b1cdbd2cSJim Jagielski xComponent->removeEventListener(xListener);
621*b1cdbd2cSJim Jagielski }
622*b1cdbd2cSJim Jagielski
623*b1cdbd2cSJim Jagielski // if we owned the connection, remember it for later disposing
624*b1cdbd2cSJim Jagielski if(m_bOwnConnection)
625*b1cdbd2cSJim Jagielski m_xOldConnection = m_xActiveConnection;
626*b1cdbd2cSJim Jagielski
627*b1cdbd2cSJim Jagielski // for firing the PropertyChangeEvent
628*b1cdbd2cSJim Jagielski sal_Int32 nHandle = PROPERTY_ID_ACTIVE_CONNECTION;
629*b1cdbd2cSJim Jagielski Any aOldConnection; aOldConnection <<= m_xActiveConnection;
630*b1cdbd2cSJim Jagielski Any aNewConnection; aNewConnection <<= _rxNewConn;
631*b1cdbd2cSJim Jagielski
632*b1cdbd2cSJim Jagielski // set the new connection
633*b1cdbd2cSJim Jagielski m_xActiveConnection = _rxNewConn;
634*b1cdbd2cSJim Jagielski if (m_xActiveConnection.is())
635*b1cdbd2cSJim Jagielski m_aActiveConnection <<= m_xActiveConnection;
636*b1cdbd2cSJim Jagielski else
637*b1cdbd2cSJim Jagielski m_aActiveConnection.clear();
638*b1cdbd2cSJim Jagielski
639*b1cdbd2cSJim Jagielski // fire the event
640*b1cdbd2cSJim Jagielski if (_bFireEvent)
641*b1cdbd2cSJim Jagielski fire(&nHandle, &aNewConnection, &aOldConnection, 1, sal_False);
642*b1cdbd2cSJim Jagielski
643*b1cdbd2cSJim Jagielski // register as event listener for the new connection
644*b1cdbd2cSJim Jagielski xComponent.set(m_xActiveConnection,UNO_QUERY);
645*b1cdbd2cSJim Jagielski if (xComponent.is())
646*b1cdbd2cSJim Jagielski {
647*b1cdbd2cSJim Jagielski Reference<XEventListener> xListener;
648*b1cdbd2cSJim Jagielski query_aggregation(this, xListener);
649*b1cdbd2cSJim Jagielski xComponent->addEventListener(xListener);
650*b1cdbd2cSJim Jagielski }
651*b1cdbd2cSJim Jagielski }
652*b1cdbd2cSJim Jagielski
653*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
654*b1cdbd2cSJim Jagielski // ::com::sun::star::XEventListener
disposing(const::com::sun::star::lang::EventObject & Source)655*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::disposing( const ::com::sun::star::lang::EventObject& Source ) throw(RuntimeException)
656*b1cdbd2cSJim Jagielski {
657*b1cdbd2cSJim Jagielski // close rowset because the connection is going to be deleted (someone told me :-)
658*b1cdbd2cSJim Jagielski Reference<XConnection> xCon(Source.Source,UNO_QUERY);
659*b1cdbd2cSJim Jagielski if(m_xActiveConnection == xCon)
660*b1cdbd2cSJim Jagielski {
661*b1cdbd2cSJim Jagielski close();
662*b1cdbd2cSJim Jagielski {
663*b1cdbd2cSJim Jagielski MutexGuard aGuard( m_aMutex );
664*b1cdbd2cSJim Jagielski Reference< XConnection > xXConnection;
665*b1cdbd2cSJim Jagielski setActiveConnection( xXConnection );
666*b1cdbd2cSJim Jagielski }
667*b1cdbd2cSJim Jagielski }
668*b1cdbd2cSJim Jagielski }
669*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
670*b1cdbd2cSJim Jagielski
671*b1cdbd2cSJim Jagielski // XCloseable
close()672*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::close( ) throw(SQLException, RuntimeException)
673*b1cdbd2cSJim Jagielski {
674*b1cdbd2cSJim Jagielski {
675*b1cdbd2cSJim Jagielski MutexGuard aGuard( m_aMutex );
676*b1cdbd2cSJim Jagielski ::connectivity::checkDisposed(ORowSet_BASE1::rBHelper.bDisposed);
677*b1cdbd2cSJim Jagielski }
678*b1cdbd2cSJim Jagielski // additionals things to set
679*b1cdbd2cSJim Jagielski freeResources( true );
680*b1cdbd2cSJim Jagielski }
681*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
682*b1cdbd2cSJim Jagielski // comphelper::OPropertyArrayUsageHelper
createArrayHelper() const683*b1cdbd2cSJim Jagielski ::cppu::IPropertyArrayHelper* ORowSet::createArrayHelper( ) const
684*b1cdbd2cSJim Jagielski {
685*b1cdbd2cSJim Jagielski Sequence< Property > aProps;
686*b1cdbd2cSJim Jagielski describeProperties(aProps);
687*b1cdbd2cSJim Jagielski return new ::cppu::OPropertyArrayHelper(aProps);
688*b1cdbd2cSJim Jagielski }
689*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
690*b1cdbd2cSJim Jagielski // cppu::OPropertySetHelper
getInfoHelper()691*b1cdbd2cSJim Jagielski ::cppu::IPropertyArrayHelper& SAL_CALL ORowSet::getInfoHelper()
692*b1cdbd2cSJim Jagielski {
693*b1cdbd2cSJim Jagielski typedef ::comphelper::OPropertyArrayUsageHelper<ORowSet> ORowSet_PROP;
694*b1cdbd2cSJim Jagielski return *ORowSet_PROP::getArrayHelper();
695*b1cdbd2cSJim Jagielski }
696*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
updateValue(sal_Int32 columnIndex,const ORowSetValue & x)697*b1cdbd2cSJim Jagielski void ORowSet::updateValue(sal_Int32 columnIndex,const ORowSetValue& x)
698*b1cdbd2cSJim Jagielski {
699*b1cdbd2cSJim Jagielski ::connectivity::checkDisposed(ORowSet_BASE1::rBHelper.bDisposed);
700*b1cdbd2cSJim Jagielski
701*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( *m_pMutex );
702*b1cdbd2cSJim Jagielski checkUpdateConditions(columnIndex);
703*b1cdbd2cSJim Jagielski checkUpdateIterator();
704*b1cdbd2cSJim Jagielski
705*b1cdbd2cSJim Jagielski ORowSetValueVector::Vector& rRow = ((*m_aCurrentRow)->get());
706*b1cdbd2cSJim Jagielski ORowSetNotifier aNotify(this,rRow);
707*b1cdbd2cSJim Jagielski m_pCache->updateValue(columnIndex,x,rRow,aNotify.getChangedColumns());
708*b1cdbd2cSJim Jagielski m_bModified = m_bModified || !aNotify.getChangedColumns().empty();
709*b1cdbd2cSJim Jagielski aNotify.firePropertyChange();
710*b1cdbd2cSJim Jagielski }
711*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
712*b1cdbd2cSJim Jagielski // XRowUpdate
updateNull(sal_Int32 columnIndex)713*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::updateNull( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
714*b1cdbd2cSJim Jagielski {
715*b1cdbd2cSJim Jagielski ::connectivity::checkDisposed(ORowSet_BASE1::rBHelper.bDisposed);
716*b1cdbd2cSJim Jagielski
717*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( *m_pMutex );
718*b1cdbd2cSJim Jagielski checkUpdateConditions(columnIndex);
719*b1cdbd2cSJim Jagielski checkUpdateIterator();
720*b1cdbd2cSJim Jagielski
721*b1cdbd2cSJim Jagielski ORowSetValueVector::Vector& rRow = ((*m_aCurrentRow)->get());
722*b1cdbd2cSJim Jagielski ORowSetNotifier aNotify(this,rRow);
723*b1cdbd2cSJim Jagielski m_pCache->updateNull(columnIndex,rRow,aNotify.getChangedColumns());
724*b1cdbd2cSJim Jagielski m_bModified = m_bModified || !aNotify.getChangedColumns().empty();
725*b1cdbd2cSJim Jagielski aNotify.firePropertyChange();
726*b1cdbd2cSJim Jagielski }
727*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
updateBoolean(sal_Int32 columnIndex,sal_Bool x)728*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::updateBoolean( sal_Int32 columnIndex, sal_Bool x ) throw(SQLException, RuntimeException)
729*b1cdbd2cSJim Jagielski {
730*b1cdbd2cSJim Jagielski updateValue(columnIndex,x);
731*b1cdbd2cSJim Jagielski }
732*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
updateByte(sal_Int32 columnIndex,sal_Int8 x)733*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::updateByte( sal_Int32 columnIndex, sal_Int8 x ) throw(SQLException, RuntimeException)
734*b1cdbd2cSJim Jagielski {
735*b1cdbd2cSJim Jagielski updateValue(columnIndex,x);
736*b1cdbd2cSJim Jagielski }
737*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
updateShort(sal_Int32 columnIndex,sal_Int16 x)738*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::updateShort( sal_Int32 columnIndex, sal_Int16 x ) throw(SQLException, RuntimeException)
739*b1cdbd2cSJim Jagielski {
740*b1cdbd2cSJim Jagielski updateValue(columnIndex,x);
741*b1cdbd2cSJim Jagielski }
742*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
updateInt(sal_Int32 columnIndex,sal_Int32 x)743*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::updateInt( sal_Int32 columnIndex, sal_Int32 x ) throw(SQLException, RuntimeException)
744*b1cdbd2cSJim Jagielski {
745*b1cdbd2cSJim Jagielski updateValue(columnIndex,x);
746*b1cdbd2cSJim Jagielski }
747*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
updateLong(sal_Int32 columnIndex,sal_Int64 x)748*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::updateLong( sal_Int32 columnIndex, sal_Int64 x ) throw(SQLException, RuntimeException)
749*b1cdbd2cSJim Jagielski {
750*b1cdbd2cSJim Jagielski updateValue(columnIndex,x);
751*b1cdbd2cSJim Jagielski }
752*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
updateFloat(sal_Int32 columnIndex,float x)753*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::updateFloat( sal_Int32 columnIndex, float x ) throw(SQLException, RuntimeException)
754*b1cdbd2cSJim Jagielski {
755*b1cdbd2cSJim Jagielski updateValue(columnIndex,x);
756*b1cdbd2cSJim Jagielski }
757*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
updateDouble(sal_Int32 columnIndex,double x)758*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::updateDouble( sal_Int32 columnIndex, double x ) throw(SQLException, RuntimeException)
759*b1cdbd2cSJim Jagielski {
760*b1cdbd2cSJim Jagielski updateValue(columnIndex,x);
761*b1cdbd2cSJim Jagielski }
762*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
updateString(sal_Int32 columnIndex,const::rtl::OUString & x)763*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::updateString( sal_Int32 columnIndex, const ::rtl::OUString& x ) throw(SQLException, RuntimeException)
764*b1cdbd2cSJim Jagielski {
765*b1cdbd2cSJim Jagielski updateValue(columnIndex,x);
766*b1cdbd2cSJim Jagielski }
767*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
updateBytes(sal_Int32 columnIndex,const Sequence<sal_Int8> & x)768*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::updateBytes( sal_Int32 columnIndex, const Sequence< sal_Int8 >& x ) throw(SQLException, RuntimeException)
769*b1cdbd2cSJim Jagielski {
770*b1cdbd2cSJim Jagielski updateValue(columnIndex,x);
771*b1cdbd2cSJim Jagielski }
772*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
updateDate(sal_Int32 columnIndex,const::com::sun::star::util::Date & x)773*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::updateDate( sal_Int32 columnIndex, const ::com::sun::star::util::Date& x ) throw(SQLException, RuntimeException)
774*b1cdbd2cSJim Jagielski {
775*b1cdbd2cSJim Jagielski updateValue(columnIndex,x);
776*b1cdbd2cSJim Jagielski }
777*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
updateTime(sal_Int32 columnIndex,const::com::sun::star::util::Time & x)778*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::updateTime( sal_Int32 columnIndex, const ::com::sun::star::util::Time& x ) throw(SQLException, RuntimeException)
779*b1cdbd2cSJim Jagielski {
780*b1cdbd2cSJim Jagielski updateValue(columnIndex,x);
781*b1cdbd2cSJim Jagielski }
782*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
updateTimestamp(sal_Int32 columnIndex,const::com::sun::star::util::DateTime & x)783*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::updateTimestamp( sal_Int32 columnIndex, const ::com::sun::star::util::DateTime& x ) throw(SQLException, RuntimeException)
784*b1cdbd2cSJim Jagielski {
785*b1cdbd2cSJim Jagielski updateValue(columnIndex,x);
786*b1cdbd2cSJim Jagielski }
787*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
updateBinaryStream(sal_Int32 columnIndex,const Reference<::com::sun::star::io::XInputStream> & x,sal_Int32 length)788*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::updateBinaryStream( sal_Int32 columnIndex, const Reference< ::com::sun::star::io::XInputStream >& x, sal_Int32 length ) throw(SQLException, RuntimeException)
789*b1cdbd2cSJim Jagielski {
790*b1cdbd2cSJim Jagielski ::connectivity::checkDisposed(ORowSet_BASE1::rBHelper.bDisposed);
791*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( *m_pMutex );
792*b1cdbd2cSJim Jagielski checkUpdateConditions(columnIndex);
793*b1cdbd2cSJim Jagielski checkUpdateIterator();
794*b1cdbd2cSJim Jagielski
795*b1cdbd2cSJim Jagielski //if(((*m_aCurrentRow)->get())[columnIndex].getTypeKind() == DataType::BLOB)
796*b1cdbd2cSJim Jagielski //{
797*b1cdbd2cSJim Jagielski // ::connectivity::ORowSetValue aOldValue = ((*m_aCurrentRow)->get())[columnIndex];
798*b1cdbd2cSJim Jagielski // m_pCache->updateBinaryStream(columnIndex,x,length);
799*b1cdbd2cSJim Jagielski // ((*m_aCurrentRow)->get())[columnIndex] = makeAny(x);
800*b1cdbd2cSJim Jagielski // ((*m_aCurrentRow)->get())[columnIndex].setTypeKind(DataType::BLOB);
801*b1cdbd2cSJim Jagielski // firePropertyChange(columnIndex-1 ,aOldValue);
802*b1cdbd2cSJim Jagielski // fireProperty(PROPERTY_ID_ISMODIFIED,sal_True,sal_False);
803*b1cdbd2cSJim Jagielski //}
804*b1cdbd2cSJim Jagielski //else
805*b1cdbd2cSJim Jagielski {
806*b1cdbd2cSJim Jagielski Sequence<sal_Int8> aSeq;
807*b1cdbd2cSJim Jagielski if(x.is())
808*b1cdbd2cSJim Jagielski x->readBytes(aSeq,length);
809*b1cdbd2cSJim Jagielski updateValue(columnIndex,aSeq);
810*b1cdbd2cSJim Jagielski }
811*b1cdbd2cSJim Jagielski }
812*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
updateCharacterStream(sal_Int32 columnIndex,const Reference<::com::sun::star::io::XInputStream> & x,sal_Int32 length)813*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::updateCharacterStream( sal_Int32 columnIndex, const Reference< ::com::sun::star::io::XInputStream >& x, sal_Int32 length ) throw(SQLException, RuntimeException)
814*b1cdbd2cSJim Jagielski {
815*b1cdbd2cSJim Jagielski ::connectivity::checkDisposed(ORowSet_BASE1::rBHelper.bDisposed);
816*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( *m_pMutex );
817*b1cdbd2cSJim Jagielski checkUpdateConditions(columnIndex);
818*b1cdbd2cSJim Jagielski checkUpdateIterator();
819*b1cdbd2cSJim Jagielski ORowSetValueVector::Vector& rRow = ((*m_aCurrentRow)->get());
820*b1cdbd2cSJim Jagielski ORowSetNotifier aNotify(this,rRow);
821*b1cdbd2cSJim Jagielski m_pCache->updateCharacterStream(columnIndex,x,length,rRow,aNotify.getChangedColumns());
822*b1cdbd2cSJim Jagielski m_bModified = m_bModified || !aNotify.getChangedColumns().empty();
823*b1cdbd2cSJim Jagielski aNotify.firePropertyChange();
824*b1cdbd2cSJim Jagielski }
825*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
updateObject(sal_Int32 columnIndex,const Any & x)826*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::updateObject( sal_Int32 columnIndex, const Any& x ) throw(SQLException, RuntimeException)
827*b1cdbd2cSJim Jagielski {
828*b1cdbd2cSJim Jagielski ::connectivity::checkDisposed(ORowSet_BASE1::rBHelper.bDisposed);
829*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( *m_pMutex );
830*b1cdbd2cSJim Jagielski checkUpdateConditions(columnIndex);
831*b1cdbd2cSJim Jagielski checkUpdateIterator();
832*b1cdbd2cSJim Jagielski
833*b1cdbd2cSJim Jagielski Any aNewValue = x;
834*b1cdbd2cSJim Jagielski
835*b1cdbd2cSJim Jagielski if ( m_pColumns )
836*b1cdbd2cSJim Jagielski {
837*b1cdbd2cSJim Jagielski Reference<XPropertySet> xColumn(m_pColumns->getByIndex(columnIndex-1),UNO_QUERY);
838*b1cdbd2cSJim Jagielski sal_Int32 nColType = 0;
839*b1cdbd2cSJim Jagielski xColumn->getPropertyValue(PROPERTY_TYPE) >>= nColType;
840*b1cdbd2cSJim Jagielski switch( nColType )
841*b1cdbd2cSJim Jagielski {
842*b1cdbd2cSJim Jagielski case DataType::DATE:
843*b1cdbd2cSJim Jagielski case DataType::TIME:
844*b1cdbd2cSJim Jagielski case DataType::TIMESTAMP:
845*b1cdbd2cSJim Jagielski {
846*b1cdbd2cSJim Jagielski double nValue = 0;
847*b1cdbd2cSJim Jagielski if ( x >>= nValue )
848*b1cdbd2cSJim Jagielski {
849*b1cdbd2cSJim Jagielski if ( DataType::TIMESTAMP == nColType )
850*b1cdbd2cSJim Jagielski aNewValue <<= dbtools::DBTypeConversion::toDateTime( nValue );
851*b1cdbd2cSJim Jagielski else if ( DataType::DATE == nColType )
852*b1cdbd2cSJim Jagielski aNewValue <<= dbtools::DBTypeConversion::toDate( nValue );
853*b1cdbd2cSJim Jagielski else
854*b1cdbd2cSJim Jagielski aNewValue <<= dbtools::DBTypeConversion::toTime( nValue );
855*b1cdbd2cSJim Jagielski }
856*b1cdbd2cSJim Jagielski break;
857*b1cdbd2cSJim Jagielski }
858*b1cdbd2cSJim Jagielski }
859*b1cdbd2cSJim Jagielski }
860*b1cdbd2cSJim Jagielski
861*b1cdbd2cSJim Jagielski if (!::dbtools::implUpdateObject(this, columnIndex, aNewValue))
862*b1cdbd2cSJim Jagielski { // there is no other updateXXX call which can handle the value in x
863*b1cdbd2cSJim Jagielski ORowSetValueVector::Vector& rRow = ((*m_aCurrentRow)->get());
864*b1cdbd2cSJim Jagielski ORowSetNotifier aNotify(this,rRow);
865*b1cdbd2cSJim Jagielski m_pCache->updateObject(columnIndex,aNewValue,rRow,aNotify.getChangedColumns());
866*b1cdbd2cSJim Jagielski m_bModified = m_bModified || !aNotify.getChangedColumns().empty();
867*b1cdbd2cSJim Jagielski aNotify.firePropertyChange();
868*b1cdbd2cSJim Jagielski }
869*b1cdbd2cSJim Jagielski }
870*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
updateNumericObject(sal_Int32 columnIndex,const Any & x,sal_Int32 scale)871*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::updateNumericObject( sal_Int32 columnIndex, const Any& x, sal_Int32 scale ) throw(SQLException, RuntimeException)
872*b1cdbd2cSJim Jagielski {
873*b1cdbd2cSJim Jagielski ::connectivity::checkDisposed(ORowSet_BASE1::rBHelper.bDisposed);
874*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( *m_pMutex );
875*b1cdbd2cSJim Jagielski checkUpdateConditions(columnIndex);
876*b1cdbd2cSJim Jagielski checkUpdateIterator();
877*b1cdbd2cSJim Jagielski ORowSetValueVector::Vector& rRow = ((*m_aCurrentRow)->get());
878*b1cdbd2cSJim Jagielski ORowSetNotifier aNotify(this,rRow);
879*b1cdbd2cSJim Jagielski m_pCache->updateNumericObject(columnIndex,x,scale,rRow,aNotify.getChangedColumns());
880*b1cdbd2cSJim Jagielski m_bModified = m_bModified || !aNotify.getChangedColumns().empty();
881*b1cdbd2cSJim Jagielski aNotify.firePropertyChange();
882*b1cdbd2cSJim Jagielski }
883*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
884*b1cdbd2cSJim Jagielski
885*b1cdbd2cSJim Jagielski // XResultSetUpdate
insertRow()886*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::insertRow( ) throw(SQLException, RuntimeException)
887*b1cdbd2cSJim Jagielski {
888*b1cdbd2cSJim Jagielski ::connectivity::checkDisposed(ORowSet_BASE1::rBHelper.bDisposed);
889*b1cdbd2cSJim Jagielski // insertRow is not allowd when
890*b1cdbd2cSJim Jagielski // standing not on the insert row nor
891*b1cdbd2cSJim Jagielski // when the row isn't modified
892*b1cdbd2cSJim Jagielski // or the concurency is read only
893*b1cdbd2cSJim Jagielski ::osl::ResettableMutexGuard aGuard( *m_pMutex );
894*b1cdbd2cSJim Jagielski
895*b1cdbd2cSJim Jagielski if(!m_pCache || !m_bNew || !m_bModified || m_nResultSetConcurrency == ResultSetConcurrency::READ_ONLY)
896*b1cdbd2cSJim Jagielski throwFunctionSequenceException(*this);
897*b1cdbd2cSJim Jagielski
898*b1cdbd2cSJim Jagielski // remember old value for fire
899*b1cdbd2cSJim Jagielski sal_Bool bOld = m_bNew;
900*b1cdbd2cSJim Jagielski
901*b1cdbd2cSJim Jagielski ORowSetRow aOldValues;
902*b1cdbd2cSJim Jagielski if ( !m_aCurrentRow.isNull() )
903*b1cdbd2cSJim Jagielski aOldValues = new ORowSetValueVector( m_aCurrentRow->getBody() );
904*b1cdbd2cSJim Jagielski Sequence<Any> aChangedBookmarks;
905*b1cdbd2cSJim Jagielski RowsChangeEvent aEvt(*this,RowChangeAction::INSERT,1,aChangedBookmarks);
906*b1cdbd2cSJim Jagielski notifyAllListenersRowBeforeChange(aGuard,aEvt);
907*b1cdbd2cSJim Jagielski
908*b1cdbd2cSJim Jagielski ::std::vector< Any > aBookmarks;
909*b1cdbd2cSJim Jagielski sal_Bool bInserted = m_pCache->insertRow(aBookmarks);
910*b1cdbd2cSJim Jagielski
911*b1cdbd2cSJim Jagielski // make sure that our row is set to the new inserted row before clearing the insert flags in the cache
912*b1cdbd2cSJim Jagielski m_pCache->resetInsertRow(bInserted);
913*b1cdbd2cSJim Jagielski
914*b1cdbd2cSJim Jagielski // notification order
915*b1cdbd2cSJim Jagielski // - column values
916*b1cdbd2cSJim Jagielski setCurrentRow( sal_False, sal_True, aOldValues, aGuard ); // we don't move here
917*b1cdbd2cSJim Jagielski
918*b1cdbd2cSJim Jagielski // read-only flag restored
919*b1cdbd2cSJim Jagielski impl_restoreDataColumnsWriteable_throw();
920*b1cdbd2cSJim Jagielski
921*b1cdbd2cSJim Jagielski // - rowChanged
922*b1cdbd2cSJim Jagielski notifyAllListenersRowChanged(aGuard,aEvt);
923*b1cdbd2cSJim Jagielski
924*b1cdbd2cSJim Jagielski if ( !aBookmarks.empty() )
925*b1cdbd2cSJim Jagielski {
926*b1cdbd2cSJim Jagielski RowsChangeEvent aUpEvt(*this,RowChangeAction::UPDATE,aBookmarks.size(),Sequence<Any>(&(*aBookmarks.begin()),aBookmarks.size()));
927*b1cdbd2cSJim Jagielski notifyAllListenersRowChanged(aGuard,aUpEvt);
928*b1cdbd2cSJim Jagielski }
929*b1cdbd2cSJim Jagielski
930*b1cdbd2cSJim Jagielski // - IsModified
931*b1cdbd2cSJim Jagielski if(!m_bModified)
932*b1cdbd2cSJim Jagielski fireProperty(PROPERTY_ID_ISMODIFIED,sal_False,sal_True);
933*b1cdbd2cSJim Jagielski OSL_ENSURE( !m_bModified, "ORowSet::insertRow: just updated, but _still_ modified?" );
934*b1cdbd2cSJim Jagielski
935*b1cdbd2cSJim Jagielski // - IsNew
936*b1cdbd2cSJim Jagielski if(m_bNew != bOld)
937*b1cdbd2cSJim Jagielski fireProperty(PROPERTY_ID_ISNEW,m_bNew,bOld);
938*b1cdbd2cSJim Jagielski
939*b1cdbd2cSJim Jagielski // - RowCount/IsRowCountFinal
940*b1cdbd2cSJim Jagielski fireRowcount();
941*b1cdbd2cSJim Jagielski }
942*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
getRow()943*b1cdbd2cSJim Jagielski sal_Int32 SAL_CALL ORowSet::getRow( ) throw(SQLException, RuntimeException)
944*b1cdbd2cSJim Jagielski {
945*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( *m_pMutex );
946*b1cdbd2cSJim Jagielski checkCache();
947*b1cdbd2cSJim Jagielski
948*b1cdbd2cSJim Jagielski // check if we are inserting a row
949*b1cdbd2cSJim Jagielski return (m_pCache && isInsertRow()) ? 0 : ORowSetBase::getRow();
950*b1cdbd2cSJim Jagielski }
951*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
updateRow()952*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::updateRow( ) throw(SQLException, RuntimeException)
953*b1cdbd2cSJim Jagielski {
954*b1cdbd2cSJim Jagielski ::connectivity::checkDisposed(ORowSet_BASE1::rBHelper.bDisposed);
955*b1cdbd2cSJim Jagielski // not allowed when standing on insert row
956*b1cdbd2cSJim Jagielski ::osl::ResettableMutexGuard aGuard( *m_pMutex );
957*b1cdbd2cSJim Jagielski if ( !m_pCache || m_nResultSetConcurrency == ResultSetConcurrency::READ_ONLY || m_bNew || ((m_pCache->m_nPrivileges & Privilege::UPDATE ) != Privilege::UPDATE) )
958*b1cdbd2cSJim Jagielski throwFunctionSequenceException(*this);
959*b1cdbd2cSJim Jagielski
960*b1cdbd2cSJim Jagielski
961*b1cdbd2cSJim Jagielski if(m_bModified)
962*b1cdbd2cSJim Jagielski {
963*b1cdbd2cSJim Jagielski ORowSetRow aOldValues;
964*b1cdbd2cSJim Jagielski if ( !m_aCurrentRow.isNull() )
965*b1cdbd2cSJim Jagielski aOldValues = new ORowSetValueVector( m_aCurrentRow->getBody() );
966*b1cdbd2cSJim Jagielski
967*b1cdbd2cSJim Jagielski Sequence<Any> aChangedBookmarks;
968*b1cdbd2cSJim Jagielski RowsChangeEvent aEvt(*this,RowChangeAction::UPDATE,1,aChangedBookmarks);
969*b1cdbd2cSJim Jagielski notifyAllListenersRowBeforeChange(aGuard,aEvt);
970*b1cdbd2cSJim Jagielski
971*b1cdbd2cSJim Jagielski ::std::vector< Any > aBookmarks;
972*b1cdbd2cSJim Jagielski m_pCache->updateRow(m_aCurrentRow.operator ->(),aBookmarks);
973*b1cdbd2cSJim Jagielski if ( !aBookmarks.empty() )
974*b1cdbd2cSJim Jagielski aEvt.Bookmarks = Sequence<Any>(&(*aBookmarks.begin()),aBookmarks.size());
975*b1cdbd2cSJim Jagielski aEvt.Rows += aBookmarks.size();
976*b1cdbd2cSJim Jagielski m_aBookmark = m_pCache->getBookmark();
977*b1cdbd2cSJim Jagielski m_aCurrentRow = m_pCache->m_aMatrixIter;
978*b1cdbd2cSJim Jagielski m_bIsInsertRow = sal_False;
979*b1cdbd2cSJim Jagielski if ( m_pCache->m_aMatrixIter != m_pCache->getEnd() && (*m_pCache->m_aMatrixIter).isValid() )
980*b1cdbd2cSJim Jagielski {
981*b1cdbd2cSJim Jagielski if ( m_pCache->isResultSetChanged() )
982*b1cdbd2cSJim Jagielski {
983*b1cdbd2cSJim Jagielski impl_rebuild_throw(aGuard);
984*b1cdbd2cSJim Jagielski }
985*b1cdbd2cSJim Jagielski else
986*b1cdbd2cSJim Jagielski {
987*b1cdbd2cSJim Jagielski m_aOldRow->setRow(new ORowSetValueVector(m_aCurrentRow->getBody()));
988*b1cdbd2cSJim Jagielski
989*b1cdbd2cSJim Jagielski // notification order
990*b1cdbd2cSJim Jagielski // - column values
991*b1cdbd2cSJim Jagielski ORowSetBase::firePropertyChange(aOldValues);
992*b1cdbd2cSJim Jagielski }
993*b1cdbd2cSJim Jagielski // - rowChanged
994*b1cdbd2cSJim Jagielski notifyAllListenersRowChanged(aGuard,aEvt);
995*b1cdbd2cSJim Jagielski
996*b1cdbd2cSJim Jagielski // - IsModified
997*b1cdbd2cSJim Jagielski if(!m_bModified)
998*b1cdbd2cSJim Jagielski fireProperty(PROPERTY_ID_ISMODIFIED,sal_False,sal_True);
999*b1cdbd2cSJim Jagielski OSL_ENSURE( !m_bModified, "ORowSet::updateRow: just updated, but _still_ modified?" );
1000*b1cdbd2cSJim Jagielski
1001*b1cdbd2cSJim Jagielski // - RowCount/IsRowCountFinal
1002*b1cdbd2cSJim Jagielski fireRowcount();
1003*b1cdbd2cSJim Jagielski }
1004*b1cdbd2cSJim Jagielski else if ( !m_bAfterLast ) // the update went rong
1005*b1cdbd2cSJim Jagielski {
1006*b1cdbd2cSJim Jagielski ::dbtools::throwSQLException( DBACORE_RESSTRING( RID_STR_UPDATE_FAILED ), SQL_INVALID_CURSOR_POSITION, *this );
1007*b1cdbd2cSJim Jagielski }
1008*b1cdbd2cSJim Jagielski }
1009*b1cdbd2cSJim Jagielski }
1010*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
deleteRow()1011*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::deleteRow( ) throw(SQLException, RuntimeException)
1012*b1cdbd2cSJim Jagielski {
1013*b1cdbd2cSJim Jagielski ::connectivity::checkDisposed(ORowSet_BASE1::rBHelper.bDisposed);
1014*b1cdbd2cSJim Jagielski
1015*b1cdbd2cSJim Jagielski ::osl::ResettableMutexGuard aGuard( *m_pMutex );
1016*b1cdbd2cSJim Jagielski checkCache();
1017*b1cdbd2cSJim Jagielski
1018*b1cdbd2cSJim Jagielski if ( m_bBeforeFirst || m_bAfterLast )
1019*b1cdbd2cSJim Jagielski ::dbtools::throwSQLException( DBACORE_RESSTRING( RID_STR_NO_DELETE_BEFORE_AFTER ), SQL_INVALID_CURSOR_POSITION, *this );
1020*b1cdbd2cSJim Jagielski if ( m_bNew )
1021*b1cdbd2cSJim Jagielski ::dbtools::throwSQLException( DBACORE_RESSTRING( RID_STR_NO_DELETE_INSERT_ROW ), SQL_INVALID_CURSOR_POSITION, *this );
1022*b1cdbd2cSJim Jagielski if ( m_nResultSetConcurrency == ResultSetConcurrency::READ_ONLY )
1023*b1cdbd2cSJim Jagielski ::dbtools::throwSQLException( DBACORE_RESSTRING( RID_STR_RESULT_IS_READONLY ), SQL_FUNCTION_SEQUENCE_ERROR, *this );
1024*b1cdbd2cSJim Jagielski if ( ( m_pCache->m_nPrivileges & Privilege::DELETE ) != Privilege::DELETE )
1025*b1cdbd2cSJim Jagielski ::dbtools::throwSQLException( DBACORE_RESSTRING( RID_STR_NO_DELETE_PRIVILEGE ), SQL_FUNCTION_SEQUENCE_ERROR, *this );
1026*b1cdbd2cSJim Jagielski if ( rowDeleted() )
1027*b1cdbd2cSJim Jagielski ::dbtools::throwSQLException( DBACORE_RESSTRING( RID_STR_ROW_ALREADY_DELETED ), SQL_FUNCTION_SEQUENCE_ERROR, *this );
1028*b1cdbd2cSJim Jagielski
1029*b1cdbd2cSJim Jagielski // this call position the cache indirect
1030*b1cdbd2cSJim Jagielski Any aBookmarkToDelete( m_aBookmark );
1031*b1cdbd2cSJim Jagielski positionCache( MOVE_NONE_REFRESH_ONLY );
1032*b1cdbd2cSJim Jagielski sal_Int32 nDeletePosition = m_pCache->getRow();
1033*b1cdbd2cSJim Jagielski
1034*b1cdbd2cSJim Jagielski notifyRowSetAndClonesRowDelete( aBookmarkToDelete );
1035*b1cdbd2cSJim Jagielski
1036*b1cdbd2cSJim Jagielski ORowSetRow aOldValues;
1037*b1cdbd2cSJim Jagielski if ( m_pCache->m_aMatrixIter != m_pCache->getEnd() && m_pCache->m_aMatrixIter->isValid() )
1038*b1cdbd2cSJim Jagielski aOldValues = new ORowSetValueVector( m_pCache->m_aMatrixIter->getBody() );
1039*b1cdbd2cSJim Jagielski
1040*b1cdbd2cSJim Jagielski Sequence<Any> aChangedBookmarks;
1041*b1cdbd2cSJim Jagielski RowsChangeEvent aEvt(*this,RowChangeAction::DELETE,1,aChangedBookmarks);
1042*b1cdbd2cSJim Jagielski notifyAllListenersRowBeforeChange(aGuard,aEvt);
1043*b1cdbd2cSJim Jagielski
1044*b1cdbd2cSJim Jagielski m_pCache->deleteRow();
1045*b1cdbd2cSJim Jagielski notifyRowSetAndClonesRowDeleted( aBookmarkToDelete, nDeletePosition );
1046*b1cdbd2cSJim Jagielski
1047*b1cdbd2cSJim Jagielski ORowSetNotifier aNotifier( this );
1048*b1cdbd2cSJim Jagielski // this will call cancelRowModification on the cache if necessary
1049*b1cdbd2cSJim Jagielski
1050*b1cdbd2cSJim Jagielski // notification order
1051*b1cdbd2cSJim Jagielski // - rowChanged
1052*b1cdbd2cSJim Jagielski notifyAllListenersRowChanged(aGuard,aEvt);
1053*b1cdbd2cSJim Jagielski
1054*b1cdbd2cSJim Jagielski // - IsModified
1055*b1cdbd2cSJim Jagielski // - IsNew
1056*b1cdbd2cSJim Jagielski aNotifier.fire( );
1057*b1cdbd2cSJim Jagielski
1058*b1cdbd2cSJim Jagielski // - RowCount/IsRowCountFinal
1059*b1cdbd2cSJim Jagielski fireRowcount();
1060*b1cdbd2cSJim Jagielski }
1061*b1cdbd2cSJim Jagielski
1062*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
implCancelRowUpdates(sal_Bool _bNotifyModified)1063*b1cdbd2cSJim Jagielski void ORowSet::implCancelRowUpdates( sal_Bool _bNotifyModified ) SAL_THROW( ( SQLException, RuntimeException ) )
1064*b1cdbd2cSJim Jagielski {
1065*b1cdbd2cSJim Jagielski ::connectivity::checkDisposed(ORowSet_BASE1::rBHelper.bDisposed);
1066*b1cdbd2cSJim Jagielski
1067*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( *m_pMutex );
1068*b1cdbd2cSJim Jagielski if ( m_bBeforeFirst || m_bAfterLast || rowDeleted() )
1069*b1cdbd2cSJim Jagielski return; // nothing to do so return
1070*b1cdbd2cSJim Jagielski
1071*b1cdbd2cSJim Jagielski checkCache();
1072*b1cdbd2cSJim Jagielski // cancelRowUpdates is not allowed when:
1073*b1cdbd2cSJim Jagielski // - standing on the insert row
1074*b1cdbd2cSJim Jagielski // - the concurrency is read only
1075*b1cdbd2cSJim Jagielski // - the current row is deleted
1076*b1cdbd2cSJim Jagielski if ( m_bNew || m_nResultSetConcurrency == ResultSetConcurrency::READ_ONLY )
1077*b1cdbd2cSJim Jagielski throwFunctionSequenceException(*this);
1078*b1cdbd2cSJim Jagielski
1079*b1cdbd2cSJim Jagielski positionCache( MOVE_NONE_REFRESH_ONLY );
1080*b1cdbd2cSJim Jagielski
1081*b1cdbd2cSJim Jagielski ORowSetRow aOldValues;
1082*b1cdbd2cSJim Jagielski if ( !m_bModified && _bNotifyModified && !m_aCurrentRow.isNull() )
1083*b1cdbd2cSJim Jagielski aOldValues = new ORowSetValueVector( m_aCurrentRow->getBody() );
1084*b1cdbd2cSJim Jagielski
1085*b1cdbd2cSJim Jagielski m_pCache->cancelRowUpdates();
1086*b1cdbd2cSJim Jagielski
1087*b1cdbd2cSJim Jagielski m_aBookmark = m_pCache->getBookmark();
1088*b1cdbd2cSJim Jagielski m_aCurrentRow = m_pCache->m_aMatrixIter;
1089*b1cdbd2cSJim Jagielski m_bIsInsertRow = sal_False;
1090*b1cdbd2cSJim Jagielski m_aCurrentRow.setBookmark(m_aBookmark);
1091*b1cdbd2cSJim Jagielski
1092*b1cdbd2cSJim Jagielski // notification order
1093*b1cdbd2cSJim Jagielski // IsModified
1094*b1cdbd2cSJim Jagielski if( !m_bModified && _bNotifyModified )
1095*b1cdbd2cSJim Jagielski {
1096*b1cdbd2cSJim Jagielski // - column values
1097*b1cdbd2cSJim Jagielski ORowSetBase::firePropertyChange(aOldValues);
1098*b1cdbd2cSJim Jagielski fireProperty(PROPERTY_ID_ISMODIFIED,sal_False,sal_True);
1099*b1cdbd2cSJim Jagielski }
1100*b1cdbd2cSJim Jagielski }
1101*b1cdbd2cSJim Jagielski
1102*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
cancelRowUpdates()1103*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::cancelRowUpdates( ) throw(SQLException, RuntimeException)
1104*b1cdbd2cSJim Jagielski {
1105*b1cdbd2cSJim Jagielski implCancelRowUpdates( sal_True );
1106*b1cdbd2cSJim Jagielski }
1107*b1cdbd2cSJim Jagielski
1108*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
addRowSetListener(const Reference<XRowSetListener> & listener)1109*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::addRowSetListener( const Reference< XRowSetListener >& listener ) throw(RuntimeException)
1110*b1cdbd2cSJim Jagielski {
1111*b1cdbd2cSJim Jagielski ::connectivity::checkDisposed(ORowSet_BASE1::rBHelper.bDisposed);
1112*b1cdbd2cSJim Jagielski
1113*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aColumnsMutex );
1114*b1cdbd2cSJim Jagielski if(listener.is())
1115*b1cdbd2cSJim Jagielski m_aRowsetListeners.addInterface(listener);
1116*b1cdbd2cSJim Jagielski }
1117*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
removeRowSetListener(const Reference<XRowSetListener> & listener)1118*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::removeRowSetListener( const Reference< XRowSetListener >& listener ) throw(RuntimeException)
1119*b1cdbd2cSJim Jagielski {
1120*b1cdbd2cSJim Jagielski ::connectivity::checkDisposed(ORowSet_BASE1::rBHelper.bDisposed);
1121*b1cdbd2cSJim Jagielski
1122*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aColumnsMutex );
1123*b1cdbd2cSJim Jagielski if(listener.is())
1124*b1cdbd2cSJim Jagielski m_aRowsetListeners.removeInterface(listener);
1125*b1cdbd2cSJim Jagielski }
1126*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
notifyAllListeners(::osl::ResettableMutexGuard & _rGuard)1127*b1cdbd2cSJim Jagielski void ORowSet::notifyAllListeners(::osl::ResettableMutexGuard& _rGuard)
1128*b1cdbd2cSJim Jagielski {
1129*b1cdbd2cSJim Jagielski EventObject aEvt(*m_pMySelf);
1130*b1cdbd2cSJim Jagielski _rGuard.clear();
1131*b1cdbd2cSJim Jagielski m_aRowsetListeners.notifyEach( &XRowSetListener::rowSetChanged, aEvt );
1132*b1cdbd2cSJim Jagielski _rGuard.reset();
1133*b1cdbd2cSJim Jagielski }
1134*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
notifyAllListenersCursorMoved(::osl::ResettableMutexGuard & _rGuard)1135*b1cdbd2cSJim Jagielski void ORowSet::notifyAllListenersCursorMoved(::osl::ResettableMutexGuard& _rGuard)
1136*b1cdbd2cSJim Jagielski {
1137*b1cdbd2cSJim Jagielski EventObject aEvt(*m_pMySelf);
1138*b1cdbd2cSJim Jagielski _rGuard.clear();
1139*b1cdbd2cSJim Jagielski m_aRowsetListeners.notifyEach( &XRowSetListener::cursorMoved, aEvt );
1140*b1cdbd2cSJim Jagielski _rGuard.reset();
1141*b1cdbd2cSJim Jagielski }
1142*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
notifyAllListenersRowChanged(::osl::ResettableMutexGuard & _rGuard,const RowsChangeEvent & aEvt)1143*b1cdbd2cSJim Jagielski void ORowSet::notifyAllListenersRowChanged(::osl::ResettableMutexGuard& _rGuard, const RowsChangeEvent& aEvt)
1144*b1cdbd2cSJim Jagielski {
1145*b1cdbd2cSJim Jagielski _rGuard.clear();
1146*b1cdbd2cSJim Jagielski m_aRowsetListeners.notifyEach( &XRowSetListener::rowChanged, (EventObject)aEvt );
1147*b1cdbd2cSJim Jagielski m_aRowsChangeListener.notifyEach( &XRowsChangeListener::rowsChanged, aEvt );
1148*b1cdbd2cSJim Jagielski _rGuard.reset();
1149*b1cdbd2cSJim Jagielski }
1150*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
notifyAllListenersCursorBeforeMove(::osl::ResettableMutexGuard & _rGuard)1151*b1cdbd2cSJim Jagielski sal_Bool ORowSet::notifyAllListenersCursorBeforeMove(::osl::ResettableMutexGuard& _rGuard)
1152*b1cdbd2cSJim Jagielski {
1153*b1cdbd2cSJim Jagielski EventObject aEvt(*m_pMySelf);
1154*b1cdbd2cSJim Jagielski NOTIFY_LISTERNERS_CHECK(m_aApproveListeners,XRowSetApproveListener,approveCursorMove);
1155*b1cdbd2cSJim Jagielski return bCheck;
1156*b1cdbd2cSJim Jagielski }
1157*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
notifyAllListenersRowBeforeChange(::osl::ResettableMutexGuard & _rGuard,const RowChangeEvent & aEvt)1158*b1cdbd2cSJim Jagielski void ORowSet::notifyAllListenersRowBeforeChange(::osl::ResettableMutexGuard& _rGuard,const RowChangeEvent &aEvt)
1159*b1cdbd2cSJim Jagielski {
1160*b1cdbd2cSJim Jagielski NOTIFY_LISTERNERS_CHECK(m_aApproveListeners,XRowSetApproveListener,approveRowChange);
1161*b1cdbd2cSJim Jagielski if ( !bCheck )
1162*b1cdbd2cSJim Jagielski m_aErrors.raiseTypedException( sdb::ErrorCondition::ROW_SET_OPERATION_VETOED, *this, ::cppu::UnoType< RowSetVetoException >::get() );
1163*b1cdbd2cSJim Jagielski }
1164*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
fireRowcount()1165*b1cdbd2cSJim Jagielski void ORowSet::fireRowcount()
1166*b1cdbd2cSJim Jagielski {
1167*b1cdbd2cSJim Jagielski sal_Int32 nCurrentRowCount( impl_getRowCount() );
1168*b1cdbd2cSJim Jagielski sal_Bool bCurrentRowCountFinal( m_pCache->m_bRowCountFinal );
1169*b1cdbd2cSJim Jagielski
1170*b1cdbd2cSJim Jagielski if ( m_nLastKnownRowCount != nCurrentRowCount )
1171*b1cdbd2cSJim Jagielski {
1172*b1cdbd2cSJim Jagielski sal_Int32 nHandle = PROPERTY_ID_ROWCOUNT;
1173*b1cdbd2cSJim Jagielski Any aNew,aOld;
1174*b1cdbd2cSJim Jagielski aNew <<= nCurrentRowCount; aOld <<= m_nLastKnownRowCount;
1175*b1cdbd2cSJim Jagielski fire(&nHandle,&aNew,&aOld,1,sal_False);
1176*b1cdbd2cSJim Jagielski m_nLastKnownRowCount = nCurrentRowCount;
1177*b1cdbd2cSJim Jagielski }
1178*b1cdbd2cSJim Jagielski if ( !m_bLastKnownRowCountFinal && ( m_bLastKnownRowCountFinal != bCurrentRowCountFinal ) )
1179*b1cdbd2cSJim Jagielski {
1180*b1cdbd2cSJim Jagielski sal_Int32 nHandle = PROPERTY_ID_ISROWCOUNTFINAL;
1181*b1cdbd2cSJim Jagielski Any aNew,aOld;
1182*b1cdbd2cSJim Jagielski aNew <<= bCurrentRowCountFinal;
1183*b1cdbd2cSJim Jagielski aOld <<= m_bLastKnownRowCountFinal;
1184*b1cdbd2cSJim Jagielski fire(&nHandle,&aNew,&aOld,1,sal_False);
1185*b1cdbd2cSJim Jagielski m_bLastKnownRowCountFinal = bCurrentRowCountFinal;
1186*b1cdbd2cSJim Jagielski }
1187*b1cdbd2cSJim Jagielski }
1188*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
moveToInsertRow()1189*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::moveToInsertRow( ) throw(SQLException, RuntimeException)
1190*b1cdbd2cSJim Jagielski {
1191*b1cdbd2cSJim Jagielski ::connectivity::checkDisposed(ORowSet_BASE1::rBHelper.bDisposed);
1192*b1cdbd2cSJim Jagielski
1193*b1cdbd2cSJim Jagielski ::osl::ResettableMutexGuard aGuard( *m_pMutex );
1194*b1cdbd2cSJim Jagielski checkPositioningAllowed();
1195*b1cdbd2cSJim Jagielski if ( ( m_pCache->m_nPrivileges & Privilege::INSERT ) != Privilege::INSERT )
1196*b1cdbd2cSJim Jagielski ::dbtools::throwSQLException( DBACORE_RESSTRING( RID_STR_NO_INSERT_PRIVILEGE ), SQL_GENERAL_ERROR, *this );
1197*b1cdbd2cSJim Jagielski
1198*b1cdbd2cSJim Jagielski if ( notifyAllListenersCursorBeforeMove( aGuard ) )
1199*b1cdbd2cSJim Jagielski {
1200*b1cdbd2cSJim Jagielski // remember old value for fire
1201*b1cdbd2cSJim Jagielski ORowSetRow aOldValues;
1202*b1cdbd2cSJim Jagielski if ( rowDeleted() )
1203*b1cdbd2cSJim Jagielski {
1204*b1cdbd2cSJim Jagielski positionCache( MOVE_FORWARD );
1205*b1cdbd2cSJim Jagielski m_pCache->next();
1206*b1cdbd2cSJim Jagielski setCurrentRow( sal_True, sal_False, aOldValues, aGuard);
1207*b1cdbd2cSJim Jagielski }
1208*b1cdbd2cSJim Jagielski else
1209*b1cdbd2cSJim Jagielski positionCache( MOVE_NONE_REFRESH_ONLY );
1210*b1cdbd2cSJim Jagielski
1211*b1cdbd2cSJim Jagielski // check before because the resultset could be empty
1212*b1cdbd2cSJim Jagielski if ( !m_bBeforeFirst
1213*b1cdbd2cSJim Jagielski && !m_bAfterLast
1214*b1cdbd2cSJim Jagielski && m_pCache->m_aMatrixIter != m_pCache->getEnd()
1215*b1cdbd2cSJim Jagielski && m_pCache->m_aMatrixIter->isValid()
1216*b1cdbd2cSJim Jagielski )
1217*b1cdbd2cSJim Jagielski aOldValues = new ORowSetValueVector( m_pCache->m_aMatrixIter->getBody() );
1218*b1cdbd2cSJim Jagielski
1219*b1cdbd2cSJim Jagielski const sal_Bool bNewState = m_bNew;
1220*b1cdbd2cSJim Jagielski const sal_Bool bModState = m_bModified;
1221*b1cdbd2cSJim Jagielski
1222*b1cdbd2cSJim Jagielski m_pCache->moveToInsertRow();
1223*b1cdbd2cSJim Jagielski m_aCurrentRow = m_pCache->m_aInsertRow;
1224*b1cdbd2cSJim Jagielski m_bIsInsertRow = sal_True;
1225*b1cdbd2cSJim Jagielski
1226*b1cdbd2cSJim Jagielski // set read-only flag to false
1227*b1cdbd2cSJim Jagielski impl_setDataColumnsWriteable_throw();
1228*b1cdbd2cSJim Jagielski
1229*b1cdbd2cSJim Jagielski // notification order
1230*b1cdbd2cSJim Jagielski // - column values
1231*b1cdbd2cSJim Jagielski ORowSetBase::firePropertyChange(aOldValues);
1232*b1cdbd2cSJim Jagielski
1233*b1cdbd2cSJim Jagielski // - cursorMoved
1234*b1cdbd2cSJim Jagielski notifyAllListenersCursorMoved(aGuard);
1235*b1cdbd2cSJim Jagielski
1236*b1cdbd2cSJim Jagielski // - IsModified
1237*b1cdbd2cSJim Jagielski if ( bModState != m_bModified )
1238*b1cdbd2cSJim Jagielski fireProperty( PROPERTY_ID_ISMODIFIED, m_bModified, bModState );
1239*b1cdbd2cSJim Jagielski
1240*b1cdbd2cSJim Jagielski // - IsNew
1241*b1cdbd2cSJim Jagielski if ( bNewState != m_bNew )
1242*b1cdbd2cSJim Jagielski fireProperty( PROPERTY_ID_ISNEW, m_bNew, bNewState );
1243*b1cdbd2cSJim Jagielski
1244*b1cdbd2cSJim Jagielski // - RowCount/IsRowCountFinal
1245*b1cdbd2cSJim Jagielski fireRowcount();
1246*b1cdbd2cSJim Jagielski }
1247*b1cdbd2cSJim Jagielski }
1248*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
impl_setDataColumnsWriteable_throw()1249*b1cdbd2cSJim Jagielski void ORowSet::impl_setDataColumnsWriteable_throw()
1250*b1cdbd2cSJim Jagielski {
1251*b1cdbd2cSJim Jagielski impl_restoreDataColumnsWriteable_throw();
1252*b1cdbd2cSJim Jagielski TDataColumns::iterator aIter = m_aDataColumns.begin();
1253*b1cdbd2cSJim Jagielski m_aReadOnlyDataColumns.resize(m_aDataColumns.size(),false);
1254*b1cdbd2cSJim Jagielski ::std::bit_vector::iterator aReadIter = m_aReadOnlyDataColumns.begin();
1255*b1cdbd2cSJim Jagielski for(;aIter != m_aDataColumns.end();++aIter,++aReadIter)
1256*b1cdbd2cSJim Jagielski {
1257*b1cdbd2cSJim Jagielski sal_Bool bReadOnly = sal_False;
1258*b1cdbd2cSJim Jagielski (*aIter)->getPropertyValue(PROPERTY_ISREADONLY) >>= bReadOnly;
1259*b1cdbd2cSJim Jagielski *aReadIter = bReadOnly;
1260*b1cdbd2cSJim Jagielski
1261*b1cdbd2cSJim Jagielski (*aIter)->setPropertyValue(PROPERTY_ISREADONLY,makeAny(sal_False));
1262*b1cdbd2cSJim Jagielski }
1263*b1cdbd2cSJim Jagielski }
1264*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
impl_restoreDataColumnsWriteable_throw()1265*b1cdbd2cSJim Jagielski void ORowSet::impl_restoreDataColumnsWriteable_throw()
1266*b1cdbd2cSJim Jagielski {
1267*b1cdbd2cSJim Jagielski TDataColumns::iterator aIter = m_aDataColumns.begin();
1268*b1cdbd2cSJim Jagielski ::std::bit_vector::iterator aReadIter = m_aReadOnlyDataColumns.begin();
1269*b1cdbd2cSJim Jagielski for(;aReadIter != m_aReadOnlyDataColumns.end();++aIter,++aReadIter)
1270*b1cdbd2cSJim Jagielski {
1271*b1cdbd2cSJim Jagielski (*aIter)->setPropertyValue(PROPERTY_ISREADONLY,makeAny((sal_Bool)*aReadIter ));
1272*b1cdbd2cSJim Jagielski }
1273*b1cdbd2cSJim Jagielski m_aReadOnlyDataColumns.clear();
1274*b1cdbd2cSJim Jagielski }
1275*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
moveToCurrentRow()1276*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::moveToCurrentRow( ) throw(SQLException, RuntimeException)
1277*b1cdbd2cSJim Jagielski {
1278*b1cdbd2cSJim Jagielski ::connectivity::checkDisposed(ORowSet_BASE1::rBHelper.bDisposed);
1279*b1cdbd2cSJim Jagielski
1280*b1cdbd2cSJim Jagielski ::osl::ResettableMutexGuard aGuard( *m_pMutex );
1281*b1cdbd2cSJim Jagielski checkPositioningAllowed();
1282*b1cdbd2cSJim Jagielski
1283*b1cdbd2cSJim Jagielski if ( !m_pCache->m_bNew && !m_bModified )
1284*b1cdbd2cSJim Jagielski // nothing to do if we're not on the insertion row, and not modified otherwise
1285*b1cdbd2cSJim Jagielski return;
1286*b1cdbd2cSJim Jagielski
1287*b1cdbd2cSJim Jagielski if ( rowDeleted() )
1288*b1cdbd2cSJim Jagielski // this would perhaps even justify a RuntimeException ....
1289*b1cdbd2cSJim Jagielski // if the current row is deleted, then no write access to this row should be possible. So,
1290*b1cdbd2cSJim Jagielski // m_bModified should be true. Also, as soon as somebody calls moveToInsertRow,
1291*b1cdbd2cSJim Jagielski // our current row should not be deleted anymore. So, we should not have survived the above
1292*b1cdbd2cSJim Jagielski // check "if ( !m_pCache->m_bNew && !m_bModified )"
1293*b1cdbd2cSJim Jagielski ::dbtools::throwSQLException( DBACORE_RESSTRING( RID_STR_ROW_ALREADY_DELETED ), SQL_FUNCTION_SEQUENCE_ERROR, *this );
1294*b1cdbd2cSJim Jagielski
1295*b1cdbd2cSJim Jagielski if ( notifyAllListenersCursorBeforeMove( aGuard ) )
1296*b1cdbd2cSJim Jagielski {
1297*b1cdbd2cSJim Jagielski positionCache( MOVE_NONE_REFRESH_ONLY );
1298*b1cdbd2cSJim Jagielski
1299*b1cdbd2cSJim Jagielski ORowSetNotifier aNotifier( this );
1300*b1cdbd2cSJim Jagielski
1301*b1cdbd2cSJim Jagielski // notification order
1302*b1cdbd2cSJim Jagielski // - cursorMoved
1303*b1cdbd2cSJim Jagielski notifyAllListenersCursorMoved(aGuard);
1304*b1cdbd2cSJim Jagielski
1305*b1cdbd2cSJim Jagielski // - IsModified
1306*b1cdbd2cSJim Jagielski // - IsNew
1307*b1cdbd2cSJim Jagielski aNotifier.fire();
1308*b1cdbd2cSJim Jagielski }
1309*b1cdbd2cSJim Jagielski }
1310*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
1311*b1cdbd2cSJim Jagielski // XRow
wasNull()1312*b1cdbd2cSJim Jagielski sal_Bool SAL_CALL ORowSet::wasNull( ) throw(SQLException, RuntimeException)
1313*b1cdbd2cSJim Jagielski {
1314*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( *m_pMutex );
1315*b1cdbd2cSJim Jagielski checkCache();
1316*b1cdbd2cSJim Jagielski
1317*b1cdbd2cSJim Jagielski return ( m_pCache && isInsertRow() ) ? ((*m_pCache->m_aInsertRow)->get())[m_nLastColumnIndex].isNull() : ORowSetBase::wasNull();
1318*b1cdbd2cSJim Jagielski }
1319*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
getInsertValue(sal_Int32 columnIndex)1320*b1cdbd2cSJim Jagielski const ORowSetValue& ORowSet::getInsertValue(sal_Int32 columnIndex)
1321*b1cdbd2cSJim Jagielski {
1322*b1cdbd2cSJim Jagielski checkCache();
1323*b1cdbd2cSJim Jagielski
1324*b1cdbd2cSJim Jagielski if ( m_pCache && isInsertRow() )
1325*b1cdbd2cSJim Jagielski return ((*m_pCache->m_aInsertRow)->get())[m_nLastColumnIndex = columnIndex];
1326*b1cdbd2cSJim Jagielski
1327*b1cdbd2cSJim Jagielski return getValue(columnIndex);
1328*b1cdbd2cSJim Jagielski }
1329*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
getString(sal_Int32 columnIndex)1330*b1cdbd2cSJim Jagielski ::rtl::OUString SAL_CALL ORowSet::getString( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1331*b1cdbd2cSJim Jagielski {
1332*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( *m_pMutex );
1333*b1cdbd2cSJim Jagielski return getInsertValue(columnIndex);
1334*b1cdbd2cSJim Jagielski }
1335*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
getBoolean(sal_Int32 columnIndex)1336*b1cdbd2cSJim Jagielski sal_Bool SAL_CALL ORowSet::getBoolean( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1337*b1cdbd2cSJim Jagielski {
1338*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( *m_pMutex );
1339*b1cdbd2cSJim Jagielski return getInsertValue(columnIndex);
1340*b1cdbd2cSJim Jagielski }
1341*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
getByte(sal_Int32 columnIndex)1342*b1cdbd2cSJim Jagielski sal_Int8 SAL_CALL ORowSet::getByte( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1343*b1cdbd2cSJim Jagielski {
1344*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( *m_pMutex );
1345*b1cdbd2cSJim Jagielski return getInsertValue(columnIndex);
1346*b1cdbd2cSJim Jagielski }
1347*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
getShort(sal_Int32 columnIndex)1348*b1cdbd2cSJim Jagielski sal_Int16 SAL_CALL ORowSet::getShort( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1349*b1cdbd2cSJim Jagielski {
1350*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( *m_pMutex );
1351*b1cdbd2cSJim Jagielski return getInsertValue(columnIndex);
1352*b1cdbd2cSJim Jagielski }
1353*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
getInt(sal_Int32 columnIndex)1354*b1cdbd2cSJim Jagielski sal_Int32 SAL_CALL ORowSet::getInt( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1355*b1cdbd2cSJim Jagielski {
1356*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( *m_pMutex );
1357*b1cdbd2cSJim Jagielski return getInsertValue(columnIndex);
1358*b1cdbd2cSJim Jagielski }
1359*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
getLong(sal_Int32 columnIndex)1360*b1cdbd2cSJim Jagielski sal_Int64 SAL_CALL ORowSet::getLong( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1361*b1cdbd2cSJim Jagielski {
1362*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( *m_pMutex );
1363*b1cdbd2cSJim Jagielski return getInsertValue(columnIndex);
1364*b1cdbd2cSJim Jagielski }
1365*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
getFloat(sal_Int32 columnIndex)1366*b1cdbd2cSJim Jagielski float SAL_CALL ORowSet::getFloat( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1367*b1cdbd2cSJim Jagielski {
1368*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( *m_pMutex );
1369*b1cdbd2cSJim Jagielski return getInsertValue(columnIndex);
1370*b1cdbd2cSJim Jagielski }
1371*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
getDouble(sal_Int32 columnIndex)1372*b1cdbd2cSJim Jagielski double SAL_CALL ORowSet::getDouble( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1373*b1cdbd2cSJim Jagielski {
1374*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( *m_pMutex );
1375*b1cdbd2cSJim Jagielski return getInsertValue(columnIndex);
1376*b1cdbd2cSJim Jagielski }
1377*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
getBytes(sal_Int32 columnIndex)1378*b1cdbd2cSJim Jagielski Sequence< sal_Int8 > SAL_CALL ORowSet::getBytes( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1379*b1cdbd2cSJim Jagielski {
1380*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( *m_pMutex );
1381*b1cdbd2cSJim Jagielski return getInsertValue(columnIndex);
1382*b1cdbd2cSJim Jagielski }
1383*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
getDate(sal_Int32 columnIndex)1384*b1cdbd2cSJim Jagielski ::com::sun::star::util::Date SAL_CALL ORowSet::getDate( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1385*b1cdbd2cSJim Jagielski {
1386*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( *m_pMutex );
1387*b1cdbd2cSJim Jagielski return getInsertValue(columnIndex);
1388*b1cdbd2cSJim Jagielski }
1389*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
getTime(sal_Int32 columnIndex)1390*b1cdbd2cSJim Jagielski ::com::sun::star::util::Time SAL_CALL ORowSet::getTime( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1391*b1cdbd2cSJim Jagielski {
1392*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( *m_pMutex );
1393*b1cdbd2cSJim Jagielski return getInsertValue(columnIndex);
1394*b1cdbd2cSJim Jagielski }
1395*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
getTimestamp(sal_Int32 columnIndex)1396*b1cdbd2cSJim Jagielski ::com::sun::star::util::DateTime SAL_CALL ORowSet::getTimestamp( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1397*b1cdbd2cSJim Jagielski {
1398*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( *m_pMutex );
1399*b1cdbd2cSJim Jagielski return getInsertValue(columnIndex);
1400*b1cdbd2cSJim Jagielski }
1401*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
getBinaryStream(sal_Int32 columnIndex)1402*b1cdbd2cSJim Jagielski Reference< ::com::sun::star::io::XInputStream > SAL_CALL ORowSet::getBinaryStream( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1403*b1cdbd2cSJim Jagielski {
1404*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( *m_pMutex );
1405*b1cdbd2cSJim Jagielski if ( m_pCache && isInsertRow() )
1406*b1cdbd2cSJim Jagielski {
1407*b1cdbd2cSJim Jagielski checkCache();
1408*b1cdbd2cSJim Jagielski return new ::comphelper::SequenceInputStream(((*m_pCache->m_aInsertRow)->get())[m_nLastColumnIndex = columnIndex].getSequence());
1409*b1cdbd2cSJim Jagielski }
1410*b1cdbd2cSJim Jagielski
1411*b1cdbd2cSJim Jagielski return ORowSetBase::getBinaryStream(columnIndex);
1412*b1cdbd2cSJim Jagielski }
1413*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
getCharacterStream(sal_Int32 columnIndex)1414*b1cdbd2cSJim Jagielski Reference< ::com::sun::star::io::XInputStream > SAL_CALL ORowSet::getCharacterStream( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1415*b1cdbd2cSJim Jagielski {
1416*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( *m_pMutex );
1417*b1cdbd2cSJim Jagielski if(m_pCache && isInsertRow() )
1418*b1cdbd2cSJim Jagielski {
1419*b1cdbd2cSJim Jagielski checkCache();
1420*b1cdbd2cSJim Jagielski return new ::comphelper::SequenceInputStream(((*m_pCache->m_aInsertRow)->get())[m_nLastColumnIndex = columnIndex].getSequence());
1421*b1cdbd2cSJim Jagielski }
1422*b1cdbd2cSJim Jagielski
1423*b1cdbd2cSJim Jagielski return ORowSetBase::getCharacterStream(columnIndex);
1424*b1cdbd2cSJim Jagielski }
1425*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
getObject(sal_Int32 columnIndex,const Reference<XNameAccess> &)1426*b1cdbd2cSJim Jagielski Any SAL_CALL ORowSet::getObject( sal_Int32 columnIndex, const Reference< XNameAccess >& /*typeMap*/ ) throw(SQLException, RuntimeException)
1427*b1cdbd2cSJim Jagielski {
1428*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( *m_pMutex );
1429*b1cdbd2cSJim Jagielski return getInsertValue(columnIndex).makeAny();
1430*b1cdbd2cSJim Jagielski }
1431*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
getRef(sal_Int32)1432*b1cdbd2cSJim Jagielski Reference< XRef > SAL_CALL ORowSet::getRef( sal_Int32 /*columnIndex*/ ) throw(SQLException, RuntimeException)
1433*b1cdbd2cSJim Jagielski {
1434*b1cdbd2cSJim Jagielski return Reference< XRef >();
1435*b1cdbd2cSJim Jagielski }
1436*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
getBlob(sal_Int32 columnIndex)1437*b1cdbd2cSJim Jagielski Reference< XBlob > SAL_CALL ORowSet::getBlob( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1438*b1cdbd2cSJim Jagielski {
1439*b1cdbd2cSJim Jagielski if ( m_pCache && isInsertRow() )
1440*b1cdbd2cSJim Jagielski {
1441*b1cdbd2cSJim Jagielski checkCache();
1442*b1cdbd2cSJim Jagielski return new ::connectivity::BlobHelper(((*m_pCache->m_aInsertRow)->get())[m_nLastColumnIndex = columnIndex].getSequence());
1443*b1cdbd2cSJim Jagielski }
1444*b1cdbd2cSJim Jagielski return ORowSetBase::getBlob(columnIndex);
1445*b1cdbd2cSJim Jagielski }
1446*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
getClob(sal_Int32 columnIndex)1447*b1cdbd2cSJim Jagielski Reference< XClob > SAL_CALL ORowSet::getClob( sal_Int32 columnIndex ) throw(SQLException, RuntimeException)
1448*b1cdbd2cSJim Jagielski {
1449*b1cdbd2cSJim Jagielski return Reference< XClob >(getInsertValue(columnIndex).makeAny(),UNO_QUERY);
1450*b1cdbd2cSJim Jagielski }
1451*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
getArray(sal_Int32)1452*b1cdbd2cSJim Jagielski Reference< XArray > SAL_CALL ORowSet::getArray( sal_Int32 /*columnIndex*/ ) throw(SQLException, RuntimeException)
1453*b1cdbd2cSJim Jagielski {
1454*b1cdbd2cSJim Jagielski return Reference< XArray >();
1455*b1cdbd2cSJim Jagielski }
1456*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
executeWithCompletion(const Reference<XInteractionHandler> & _rxHandler)1457*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::executeWithCompletion( const Reference< XInteractionHandler >& _rxHandler ) throw(SQLException, RuntimeException)
1458*b1cdbd2cSJim Jagielski {
1459*b1cdbd2cSJim Jagielski if (!_rxHandler.is())
1460*b1cdbd2cSJim Jagielski execute();
1461*b1cdbd2cSJim Jagielski
1462*b1cdbd2cSJim Jagielski ::connectivity::checkDisposed(ORowSet_BASE1::rBHelper.bDisposed);
1463*b1cdbd2cSJim Jagielski
1464*b1cdbd2cSJim Jagielski // tell everybody that we will change the result set
1465*b1cdbd2cSJim Jagielski approveExecution();
1466*b1cdbd2cSJim Jagielski
1467*b1cdbd2cSJim Jagielski ResettableMutexGuard aGuard( m_aMutex );
1468*b1cdbd2cSJim Jagielski
1469*b1cdbd2cSJim Jagielski try
1470*b1cdbd2cSJim Jagielski {
1471*b1cdbd2cSJim Jagielski freeResources( m_bCommandFacetsDirty );
1472*b1cdbd2cSJim Jagielski
1473*b1cdbd2cSJim Jagielski // calc the connection to be used
1474*b1cdbd2cSJim Jagielski if (m_xActiveConnection.is() && m_bRebuildConnOnExecute)
1475*b1cdbd2cSJim Jagielski {
1476*b1cdbd2cSJim Jagielski // there was a setProperty(ActiveConnection), but a setProperty(DataSource) _after_ that, too
1477*b1cdbd2cSJim Jagielski Reference< XConnection > xXConnection;
1478*b1cdbd2cSJim Jagielski setActiveConnection( xXConnection );
1479*b1cdbd2cSJim Jagielski }
1480*b1cdbd2cSJim Jagielski calcConnection( _rxHandler );
1481*b1cdbd2cSJim Jagielski m_bRebuildConnOnExecute = sal_False;
1482*b1cdbd2cSJim Jagielski
1483*b1cdbd2cSJim Jagielski Reference< XSingleSelectQueryComposer > xComposer = getCurrentSettingsComposer( this, m_aContext.getLegacyServiceFactory() );
1484*b1cdbd2cSJim Jagielski Reference<XParametersSupplier> xParameters(xComposer, UNO_QUERY);
1485*b1cdbd2cSJim Jagielski
1486*b1cdbd2cSJim Jagielski Reference<XIndexAccess> xParamsAsIndicies = xParameters.is() ? xParameters->getParameters() : Reference<XIndexAccess>();
1487*b1cdbd2cSJim Jagielski const sal_Int32 nParamCount = xParamsAsIndicies.is() ? xParamsAsIndicies->getCount() : 0;
1488*b1cdbd2cSJim Jagielski if ( m_aParametersSet.size() < (size_t)nParamCount )
1489*b1cdbd2cSJim Jagielski m_aParametersSet.resize( nParamCount ,false);
1490*b1cdbd2cSJim Jagielski
1491*b1cdbd2cSJim Jagielski ::dbtools::askForParameters( xComposer, this, m_xActiveConnection, _rxHandler,m_aParametersSet );
1492*b1cdbd2cSJim Jagielski }
1493*b1cdbd2cSJim Jagielski // ensure that only the allowed exceptions leave this block
1494*b1cdbd2cSJim Jagielski catch(SQLException&)
1495*b1cdbd2cSJim Jagielski {
1496*b1cdbd2cSJim Jagielski throw;
1497*b1cdbd2cSJim Jagielski }
1498*b1cdbd2cSJim Jagielski catch(RuntimeException&)
1499*b1cdbd2cSJim Jagielski {
1500*b1cdbd2cSJim Jagielski throw;
1501*b1cdbd2cSJim Jagielski }
1502*b1cdbd2cSJim Jagielski catch(Exception&)
1503*b1cdbd2cSJim Jagielski {
1504*b1cdbd2cSJim Jagielski DBG_ERROR("ORowSet::executeWithCompletion: caught an unexpected exception type while filling in the parameters!");
1505*b1cdbd2cSJim Jagielski }
1506*b1cdbd2cSJim Jagielski
1507*b1cdbd2cSJim Jagielski // we're done with the parameters, now for the real execution
1508*b1cdbd2cSJim Jagielski
1509*b1cdbd2cSJim Jagielski // do the real execute
1510*b1cdbd2cSJim Jagielski execute_NoApprove_NoNewConn(aGuard);
1511*b1cdbd2cSJim Jagielski }
1512*b1cdbd2cSJim Jagielski
1513*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
getParameters()1514*b1cdbd2cSJim Jagielski Reference< XIndexAccess > SAL_CALL ORowSet::getParameters( ) throw (RuntimeException)
1515*b1cdbd2cSJim Jagielski {
1516*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( *m_pMutex );
1517*b1cdbd2cSJim Jagielski ::connectivity::checkDisposed(ORowSet_BASE1::rBHelper.bDisposed);
1518*b1cdbd2cSJim Jagielski
1519*b1cdbd2cSJim Jagielski if ( m_bCommandFacetsDirty )
1520*b1cdbd2cSJim Jagielski // need to rebuild the parameters, since some property which contributes to the
1521*b1cdbd2cSJim Jagielski // complete command, and thus the parameters, changed
1522*b1cdbd2cSJim Jagielski impl_disposeParametersContainer_nothrow();
1523*b1cdbd2cSJim Jagielski
1524*b1cdbd2cSJim Jagielski if ( !m_pParameters.get() && m_aCommand.getLength() )
1525*b1cdbd2cSJim Jagielski {
1526*b1cdbd2cSJim Jagielski try
1527*b1cdbd2cSJim Jagielski {
1528*b1cdbd2cSJim Jagielski ::rtl::OUString sNotInterestedIn;
1529*b1cdbd2cSJim Jagielski impl_initComposer_throw( sNotInterestedIn );
1530*b1cdbd2cSJim Jagielski }
1531*b1cdbd2cSJim Jagielski catch( const Exception& )
1532*b1cdbd2cSJim Jagielski {
1533*b1cdbd2cSJim Jagielski // silence it
1534*b1cdbd2cSJim Jagielski }
1535*b1cdbd2cSJim Jagielski }
1536*b1cdbd2cSJim Jagielski
1537*b1cdbd2cSJim Jagielski return m_pParameters.get();
1538*b1cdbd2cSJim Jagielski }
1539*b1cdbd2cSJim Jagielski
1540*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
approveExecution()1541*b1cdbd2cSJim Jagielski void ORowSet::approveExecution() throw (RowSetVetoException, RuntimeException)
1542*b1cdbd2cSJim Jagielski {
1543*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aColumnsMutex );
1544*b1cdbd2cSJim Jagielski EventObject aEvt(*this);
1545*b1cdbd2cSJim Jagielski
1546*b1cdbd2cSJim Jagielski OInterfaceIteratorHelper aApproveIter( m_aApproveListeners );
1547*b1cdbd2cSJim Jagielski while ( aApproveIter.hasMoreElements() )
1548*b1cdbd2cSJim Jagielski {
1549*b1cdbd2cSJim Jagielski Reference< XRowSetApproveListener > xListener( static_cast< XRowSetApproveListener* >( aApproveIter.next() ) );
1550*b1cdbd2cSJim Jagielski try
1551*b1cdbd2cSJim Jagielski {
1552*b1cdbd2cSJim Jagielski if ( xListener.is() && !xListener->approveRowSetChange( aEvt ) )
1553*b1cdbd2cSJim Jagielski throw RowSetVetoException();
1554*b1cdbd2cSJim Jagielski }
1555*b1cdbd2cSJim Jagielski catch ( const DisposedException& e )
1556*b1cdbd2cSJim Jagielski {
1557*b1cdbd2cSJim Jagielski if ( e.Context == xListener )
1558*b1cdbd2cSJim Jagielski aApproveIter.remove();
1559*b1cdbd2cSJim Jagielski }
1560*b1cdbd2cSJim Jagielski catch ( const RuntimeException& ) { throw; }
1561*b1cdbd2cSJim Jagielski catch ( const RowSetVetoException& ) { throw; }
1562*b1cdbd2cSJim Jagielski catch ( const Exception& )
1563*b1cdbd2cSJim Jagielski {
1564*b1cdbd2cSJim Jagielski DBG_UNHANDLED_EXCEPTION();
1565*b1cdbd2cSJim Jagielski }
1566*b1cdbd2cSJim Jagielski }
1567*b1cdbd2cSJim Jagielski }
1568*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
1569*b1cdbd2cSJim Jagielski // XRowSet
1570*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
execute()1571*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::execute( ) throw(SQLException, RuntimeException)
1572*b1cdbd2cSJim Jagielski {
1573*b1cdbd2cSJim Jagielski ::connectivity::checkDisposed(ORowSet_BASE1::rBHelper.bDisposed);
1574*b1cdbd2cSJim Jagielski
1575*b1cdbd2cSJim Jagielski // tell everybody that we will change the result set
1576*b1cdbd2cSJim Jagielski approveExecution();
1577*b1cdbd2cSJim Jagielski
1578*b1cdbd2cSJim Jagielski ResettableMutexGuard aGuard( m_aMutex );
1579*b1cdbd2cSJim Jagielski freeResources( m_bCommandFacetsDirty );
1580*b1cdbd2cSJim Jagielski
1581*b1cdbd2cSJim Jagielski // calc the connection to be used
1582*b1cdbd2cSJim Jagielski if (m_xActiveConnection.is() && m_bRebuildConnOnExecute) {
1583*b1cdbd2cSJim Jagielski // there was a setProperty(ActiveConnection), but a setProperty(DataSource) _after_ that, too
1584*b1cdbd2cSJim Jagielski Reference< XConnection> xXConnection;
1585*b1cdbd2cSJim Jagielski setActiveConnection( xXConnection );
1586*b1cdbd2cSJim Jagielski }
1587*b1cdbd2cSJim Jagielski
1588*b1cdbd2cSJim Jagielski calcConnection(NULL);
1589*b1cdbd2cSJim Jagielski m_bRebuildConnOnExecute = sal_False;
1590*b1cdbd2cSJim Jagielski
1591*b1cdbd2cSJim Jagielski // do the real execute
1592*b1cdbd2cSJim Jagielski execute_NoApprove_NoNewConn(aGuard);
1593*b1cdbd2cSJim Jagielski }
1594*b1cdbd2cSJim Jagielski
1595*b1cdbd2cSJim Jagielski //------------------------------------------------------------------------------
setStatementResultSetType(const Reference<XPropertySet> & _rxStatement,sal_Int32 _nDesiredResultSetType,sal_Int32 _nDesiredResultSetConcurrency)1596*b1cdbd2cSJim Jagielski void ORowSet::setStatementResultSetType( const Reference< XPropertySet >& _rxStatement, sal_Int32 _nDesiredResultSetType, sal_Int32 _nDesiredResultSetConcurrency )
1597*b1cdbd2cSJim Jagielski {
1598*b1cdbd2cSJim Jagielski OSL_ENSURE( _rxStatement.is(), "ORowSet::setStatementResultSetType: invalid statement - this will crash!" );
1599*b1cdbd2cSJim Jagielski
1600*b1cdbd2cSJim Jagielski sal_Int32 nResultSetType( _nDesiredResultSetType );
1601*b1cdbd2cSJim Jagielski sal_Int32 nResultSetConcurrency( _nDesiredResultSetConcurrency );
1602*b1cdbd2cSJim Jagielski
1603*b1cdbd2cSJim Jagielski // there *might* be a data source setting which tells use to be more defensive with those settings
1604*b1cdbd2cSJim Jagielski // #i15113# / 2005-02-10 / frank.schoenheit@sun.com
1605*b1cdbd2cSJim Jagielski sal_Bool bRespectDriverRST = sal_False;
1606*b1cdbd2cSJim Jagielski Any aSetting;
1607*b1cdbd2cSJim Jagielski if ( getDataSourceSetting( ::dbaccess::getDataSource( m_xActiveConnection ), "RespectDriverResultSetType", aSetting ) )
1608*b1cdbd2cSJim Jagielski {
1609*b1cdbd2cSJim Jagielski OSL_VERIFY( aSetting >>= bRespectDriverRST );
1610*b1cdbd2cSJim Jagielski }
1611*b1cdbd2cSJim Jagielski
1612*b1cdbd2cSJim Jagielski if ( bRespectDriverRST )
1613*b1cdbd2cSJim Jagielski {
1614*b1cdbd2cSJim Jagielski // try type/concurrency settings with decreasing usefullness, and rely on what the connection claims
1615*b1cdbd2cSJim Jagielski // to support
1616*b1cdbd2cSJim Jagielski Reference< XDatabaseMetaData > xMeta( m_xActiveConnection->getMetaData() );
1617*b1cdbd2cSJim Jagielski
1618*b1cdbd2cSJim Jagielski sal_Int32 nCharacteristics[5][2] =
1619*b1cdbd2cSJim Jagielski { { ResultSetType::SCROLL_SENSITIVE, ResultSetConcurrency::UPDATABLE },
1620*b1cdbd2cSJim Jagielski { ResultSetType::SCROLL_INSENSITIVE, ResultSetConcurrency::UPDATABLE },
1621*b1cdbd2cSJim Jagielski { ResultSetType::SCROLL_SENSITIVE, ResultSetConcurrency::READ_ONLY },
1622*b1cdbd2cSJim Jagielski { ResultSetType::SCROLL_INSENSITIVE, ResultSetConcurrency::READ_ONLY },
1623*b1cdbd2cSJim Jagielski { ResultSetType::FORWARD_ONLY, ResultSetConcurrency::READ_ONLY }
1624*b1cdbd2cSJim Jagielski };
1625*b1cdbd2cSJim Jagielski sal_Int32 i=0;
1626*b1cdbd2cSJim Jagielski if ( m_xActiveConnection->getMetaData()->isReadOnly() )
1627*b1cdbd2cSJim Jagielski i = 2; // if the database is read-only we only should use read-only concurrency
1628*b1cdbd2cSJim Jagielski
1629*b1cdbd2cSJim Jagielski for ( ; i<5; ++i )
1630*b1cdbd2cSJim Jagielski {
1631*b1cdbd2cSJim Jagielski nResultSetType = nCharacteristics[i][0];
1632*b1cdbd2cSJim Jagielski nResultSetConcurrency = nCharacteristics[i][1];
1633*b1cdbd2cSJim Jagielski
1634*b1cdbd2cSJim Jagielski // don't try type/concurrency pairs which are more featured than what our caller requested
1635*b1cdbd2cSJim Jagielski if ( nResultSetType > _nDesiredResultSetType )
1636*b1cdbd2cSJim Jagielski continue;
1637*b1cdbd2cSJim Jagielski if ( nResultSetConcurrency > _nDesiredResultSetConcurrency )
1638*b1cdbd2cSJim Jagielski continue;
1639*b1cdbd2cSJim Jagielski
1640*b1cdbd2cSJim Jagielski if ( xMeta.is() && xMeta->supportsResultSetConcurrency( nResultSetType, nResultSetConcurrency ) )
1641*b1cdbd2cSJim Jagielski break;
1642*b1cdbd2cSJim Jagielski }
1643*b1cdbd2cSJim Jagielski }
1644*b1cdbd2cSJim Jagielski
1645*b1cdbd2cSJim Jagielski _rxStatement->setPropertyValue( PROPERTY_RESULTSETTYPE, makeAny( nResultSetType ) );
1646*b1cdbd2cSJim Jagielski _rxStatement->setPropertyValue( PROPERTY_RESULTSETCONCURRENCY, makeAny( nResultSetConcurrency ) );
1647*b1cdbd2cSJim Jagielski }
1648*b1cdbd2cSJim Jagielski
1649*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
impl_prepareAndExecute_throw()1650*b1cdbd2cSJim Jagielski Reference< XResultSet > ORowSet::impl_prepareAndExecute_throw()
1651*b1cdbd2cSJim Jagielski {
1652*b1cdbd2cSJim Jagielski ::rtl::OUString sCommandToExecute;
1653*b1cdbd2cSJim Jagielski sal_Bool bUseEscapeProcessing = impl_initComposer_throw( sCommandToExecute );
1654*b1cdbd2cSJim Jagielski
1655*b1cdbd2cSJim Jagielski Reference< XResultSet> xResultSet;
1656*b1cdbd2cSJim Jagielski try
1657*b1cdbd2cSJim Jagielski {
1658*b1cdbd2cSJim Jagielski m_xStatement = m_xActiveConnection->prepareStatement( sCommandToExecute );
1659*b1cdbd2cSJim Jagielski if ( !m_xStatement.is() )
1660*b1cdbd2cSJim Jagielski {
1661*b1cdbd2cSJim Jagielski ::dbtools::throwSQLException( DBACORE_RESSTRING( RID_STR_INTERNAL_ERROR ), SQL_GENERAL_ERROR, *this );
1662*b1cdbd2cSJim Jagielski }
1663*b1cdbd2cSJim Jagielski
1664*b1cdbd2cSJim Jagielski Reference< XPropertySet > xStatementProps( m_xStatement, UNO_QUERY_THROW );
1665*b1cdbd2cSJim Jagielski // set the result set type and concurrency
1666*b1cdbd2cSJim Jagielski try
1667*b1cdbd2cSJim Jagielski {
1668*b1cdbd2cSJim Jagielski xStatementProps->setPropertyValue( PROPERTY_USEBOOKMARKS, makeAny( sal_True ) );
1669*b1cdbd2cSJim Jagielski xStatementProps->setPropertyValue( PROPERTY_MAXROWS, makeAny( m_nMaxRows ) );
1670*b1cdbd2cSJim Jagielski
1671*b1cdbd2cSJim Jagielski setStatementResultSetType( xStatementProps, m_nResultSetType, m_nResultSetConcurrency );
1672*b1cdbd2cSJim Jagielski }
1673*b1cdbd2cSJim Jagielski catch ( const Exception& )
1674*b1cdbd2cSJim Jagielski {
1675*b1cdbd2cSJim Jagielski // this exception doesn't matter here because when we catch an exception
1676*b1cdbd2cSJim Jagielski // then the driver doesn't support this feature
1677*b1cdbd2cSJim Jagielski }
1678*b1cdbd2cSJim Jagielski m_aParameterValueForCache.get().resize(1);
1679*b1cdbd2cSJim Jagielski Reference< XParameters > xParam( m_xStatement, UNO_QUERY_THROW );
1680*b1cdbd2cSJim Jagielski size_t nParamCount( m_pParameters.is() ? m_pParameters->size() : m_aPrematureParamValues.get().size() );
1681*b1cdbd2cSJim Jagielski for ( size_t i=1; i<=nParamCount; ++i )
1682*b1cdbd2cSJim Jagielski {
1683*b1cdbd2cSJim Jagielski ORowSetValue& rParamValue( getParameterStorage( (sal_Int32)i ) );
1684*b1cdbd2cSJim Jagielski ::dbtools::setObjectWithInfo( xParam, i, rParamValue.makeAny(), rParamValue.getTypeKind() );
1685*b1cdbd2cSJim Jagielski m_aParameterValueForCache.get().push_back(rParamValue);
1686*b1cdbd2cSJim Jagielski }
1687*b1cdbd2cSJim Jagielski
1688*b1cdbd2cSJim Jagielski xResultSet = m_xStatement->executeQuery();
1689*b1cdbd2cSJim Jagielski }
1690*b1cdbd2cSJim Jagielski catch( const SQLException& )
1691*b1cdbd2cSJim Jagielski {
1692*b1cdbd2cSJim Jagielski SQLExceptionInfo aError( ::cppu::getCaughtException() );
1693*b1cdbd2cSJim Jagielski OSL_ENSURE( aError.isValid(), "ORowSet::impl_prepareAndExecute_throw: caught an SQLException which we cannot analyze!" );
1694*b1cdbd2cSJim Jagielski
1695*b1cdbd2cSJim Jagielski // append information about what we were actually going to execute
1696*b1cdbd2cSJim Jagielski try
1697*b1cdbd2cSJim Jagielski {
1698*b1cdbd2cSJim Jagielski String sQuery = bUseEscapeProcessing && m_xComposer.is() ? m_xComposer->getQuery() : m_aActiveCommand;
1699*b1cdbd2cSJim Jagielski String sInfo( DBA_RES_PARAM( RID_STR_COMMAND_LEADING_TO_ERROR, "$command$", sQuery ) );
1700*b1cdbd2cSJim Jagielski aError.append( SQLExceptionInfo::SQL_CONTEXT, sInfo );
1701*b1cdbd2cSJim Jagielski }
1702*b1cdbd2cSJim Jagielski catch( const Exception& ) { DBG_UNHANDLED_EXCEPTION(); }
1703*b1cdbd2cSJim Jagielski
1704*b1cdbd2cSJim Jagielski // propagate
1705*b1cdbd2cSJim Jagielski aError.doThrow();
1706*b1cdbd2cSJim Jagielski }
1707*b1cdbd2cSJim Jagielski
1708*b1cdbd2cSJim Jagielski return xResultSet;
1709*b1cdbd2cSJim Jagielski }
1710*b1cdbd2cSJim Jagielski
1711*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
impl_initializeColumnSettings_nothrow(const Reference<XPropertySet> & _rxTemplateColumn,const Reference<XPropertySet> & _rxRowSetColumn)1712*b1cdbd2cSJim Jagielski void ORowSet::impl_initializeColumnSettings_nothrow( const Reference< XPropertySet >& _rxTemplateColumn, const Reference< XPropertySet >& _rxRowSetColumn )
1713*b1cdbd2cSJim Jagielski {
1714*b1cdbd2cSJim Jagielski OSL_ENSURE( _rxTemplateColumn.is() && _rxRowSetColumn.is(),
1715*b1cdbd2cSJim Jagielski "ORowSet::impl_initializeColumnSettings_nothrow: this will crash!" );
1716*b1cdbd2cSJim Jagielski
1717*b1cdbd2cSJim Jagielski bool bHaveAnyColumnSetting = false;
1718*b1cdbd2cSJim Jagielski try
1719*b1cdbd2cSJim Jagielski {
1720*b1cdbd2cSJim Jagielski Reference< XPropertySetInfo > xInfo( _rxTemplateColumn->getPropertySetInfo(), UNO_QUERY_THROW );
1721*b1cdbd2cSJim Jagielski
1722*b1cdbd2cSJim Jagielski // a number of properties is plain copied
1723*b1cdbd2cSJim Jagielski const ::rtl::OUString aPropertyNames[] = {
1724*b1cdbd2cSJim Jagielski PROPERTY_ALIGN, PROPERTY_RELATIVEPOSITION, PROPERTY_WIDTH, PROPERTY_HIDDEN, PROPERTY_CONTROLMODEL,
1725*b1cdbd2cSJim Jagielski PROPERTY_HELPTEXT, PROPERTY_CONTROLDEFAULT
1726*b1cdbd2cSJim Jagielski };
1727*b1cdbd2cSJim Jagielski for ( size_t i=0; i<sizeof( aPropertyNames ) / sizeof( aPropertyNames[0] ); ++i )
1728*b1cdbd2cSJim Jagielski {
1729*b1cdbd2cSJim Jagielski if ( xInfo->hasPropertyByName( aPropertyNames[i] ) )
1730*b1cdbd2cSJim Jagielski {
1731*b1cdbd2cSJim Jagielski _rxRowSetColumn->setPropertyValue( aPropertyNames[i], _rxTemplateColumn->getPropertyValue( aPropertyNames[i] ) );
1732*b1cdbd2cSJim Jagielski bHaveAnyColumnSetting = true;
1733*b1cdbd2cSJim Jagielski }
1734*b1cdbd2cSJim Jagielski }
1735*b1cdbd2cSJim Jagielski
1736*b1cdbd2cSJim Jagielski // the format key is slightly more complex
1737*b1cdbd2cSJim Jagielski sal_Int32 nFormatKey = 0;
1738*b1cdbd2cSJim Jagielski if( xInfo->hasPropertyByName( PROPERTY_NUMBERFORMAT ) )
1739*b1cdbd2cSJim Jagielski {
1740*b1cdbd2cSJim Jagielski _rxTemplateColumn->getPropertyValue( PROPERTY_NUMBERFORMAT ) >>= nFormatKey;
1741*b1cdbd2cSJim Jagielski bHaveAnyColumnSetting = true;
1742*b1cdbd2cSJim Jagielski }
1743*b1cdbd2cSJim Jagielski if ( !nFormatKey && m_xNumberFormatTypes.is() )
1744*b1cdbd2cSJim Jagielski nFormatKey = ::dbtools::getDefaultNumberFormat( _rxTemplateColumn, m_xNumberFormatTypes, SvtSysLocale().GetLocaleData().getLocale() );
1745*b1cdbd2cSJim Jagielski _rxRowSetColumn->setPropertyValue( PROPERTY_NUMBERFORMAT, makeAny( nFormatKey ) );
1746*b1cdbd2cSJim Jagielski }
1747*b1cdbd2cSJim Jagielski catch(Exception&)
1748*b1cdbd2cSJim Jagielski {
1749*b1cdbd2cSJim Jagielski DBG_UNHANDLED_EXCEPTION();
1750*b1cdbd2cSJim Jagielski return;
1751*b1cdbd2cSJim Jagielski }
1752*b1cdbd2cSJim Jagielski
1753*b1cdbd2cSJim Jagielski if ( bHaveAnyColumnSetting )
1754*b1cdbd2cSJim Jagielski return;
1755*b1cdbd2cSJim Jagielski
1756*b1cdbd2cSJim Jagielski // the template column could not provide *any* setting. Okay, probably it's a parser column, which
1757*b1cdbd2cSJim Jagielski // does not offer those. However, perhaps the template column referes to a table column, which we
1758*b1cdbd2cSJim Jagielski // can use as new template column
1759*b1cdbd2cSJim Jagielski try
1760*b1cdbd2cSJim Jagielski {
1761*b1cdbd2cSJim Jagielski Reference< XPropertySetInfo > xInfo( _rxTemplateColumn->getPropertySetInfo(), UNO_QUERY_THROW );
1762*b1cdbd2cSJim Jagielski if ( !xInfo->hasPropertyByName( PROPERTY_TABLENAME ) )
1763*b1cdbd2cSJim Jagielski // no chance
1764*b1cdbd2cSJim Jagielski return;
1765*b1cdbd2cSJim Jagielski
1766*b1cdbd2cSJim Jagielski ::rtl::OUString sTableName;
1767*b1cdbd2cSJim Jagielski OSL_VERIFY( _rxTemplateColumn->getPropertyValue( PROPERTY_TABLENAME ) >>= sTableName );
1768*b1cdbd2cSJim Jagielski
1769*b1cdbd2cSJim Jagielski Reference< XNameAccess > xTables( impl_getTables_throw(), UNO_QUERY_THROW );
1770*b1cdbd2cSJim Jagielski if ( !xTables->hasByName( sTableName ) )
1771*b1cdbd2cSJim Jagielski // no chance
1772*b1cdbd2cSJim Jagielski return;
1773*b1cdbd2cSJim Jagielski
1774*b1cdbd2cSJim Jagielski Reference< XColumnsSupplier > xTableColSup( xTables->getByName( sTableName ), UNO_QUERY_THROW );
1775*b1cdbd2cSJim Jagielski Reference< XNameAccess > xTableCols( xTableColSup->getColumns(), UNO_QUERY_THROW );
1776*b1cdbd2cSJim Jagielski
1777*b1cdbd2cSJim Jagielski ::rtl::OUString sTableColumnName;
1778*b1cdbd2cSJim Jagielski
1779*b1cdbd2cSJim Jagielski // get the "Name" or (preferred) "RealName" property of the column
1780*b1cdbd2cSJim Jagielski ::rtl::OUString sNamePropertyName( PROPERTY_NAME );
1781*b1cdbd2cSJim Jagielski if ( xInfo->hasPropertyByName( PROPERTY_REALNAME ) )
1782*b1cdbd2cSJim Jagielski sNamePropertyName = PROPERTY_REALNAME;
1783*b1cdbd2cSJim Jagielski OSL_VERIFY( _rxTemplateColumn->getPropertyValue( sNamePropertyName ) >>= sTableColumnName );
1784*b1cdbd2cSJim Jagielski
1785*b1cdbd2cSJim Jagielski if ( !xTableCols->hasByName( sTableColumnName ) )
1786*b1cdbd2cSJim Jagielski return;
1787*b1cdbd2cSJim Jagielski
1788*b1cdbd2cSJim Jagielski Reference< XPropertySet > xTableColumn( xTableCols->getByName( sTableColumnName ), UNO_QUERY_THROW );
1789*b1cdbd2cSJim Jagielski impl_initializeColumnSettings_nothrow( xTableColumn, _rxRowSetColumn );
1790*b1cdbd2cSJim Jagielski }
1791*b1cdbd2cSJim Jagielski catch( const Exception& )
1792*b1cdbd2cSJim Jagielski {
1793*b1cdbd2cSJim Jagielski DBG_UNHANDLED_EXCEPTION();
1794*b1cdbd2cSJim Jagielski }
1795*b1cdbd2cSJim Jagielski }
1796*b1cdbd2cSJim Jagielski
1797*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
execute_NoApprove_NoNewConn(ResettableMutexGuard & _rClearForNotification)1798*b1cdbd2cSJim Jagielski void ORowSet::execute_NoApprove_NoNewConn(ResettableMutexGuard& _rClearForNotification)
1799*b1cdbd2cSJim Jagielski {
1800*b1cdbd2cSJim Jagielski RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "frank.schoenheit@sun.com", "ORowSet::execute_NoApprove_NoNewConn" );
1801*b1cdbd2cSJim Jagielski
1802*b1cdbd2cSJim Jagielski // now we can dispose our old connection
1803*b1cdbd2cSJim Jagielski ::comphelper::disposeComponent(m_xOldConnection);
1804*b1cdbd2cSJim Jagielski m_xOldConnection = NULL;
1805*b1cdbd2cSJim Jagielski
1806*b1cdbd2cSJim Jagielski // do we need a new statement
1807*b1cdbd2cSJim Jagielski if ( m_bCommandFacetsDirty )
1808*b1cdbd2cSJim Jagielski {
1809*b1cdbd2cSJim Jagielski m_xStatement = NULL;
1810*b1cdbd2cSJim Jagielski m_xComposer = NULL;
1811*b1cdbd2cSJim Jagielski
1812*b1cdbd2cSJim Jagielski Reference< XResultSet > xResultSet( impl_prepareAndExecute_throw() );
1813*b1cdbd2cSJim Jagielski
1814*b1cdbd2cSJim Jagielski // let our warnings container forget the reference to the (possibly disposed) old result set
1815*b1cdbd2cSJim Jagielski m_aWarnings.setExternalWarnings( NULL );
1816*b1cdbd2cSJim Jagielski // clear all current warnings
1817*b1cdbd2cSJim Jagielski m_aWarnings.clearWarnings();
1818*b1cdbd2cSJim Jagielski // let the warnings container know about the new "external warnings"
1819*b1cdbd2cSJim Jagielski m_aWarnings.setExternalWarnings( Reference< XWarningsSupplier >( xResultSet, UNO_QUERY ) );
1820*b1cdbd2cSJim Jagielski
1821*b1cdbd2cSJim Jagielski ::rtl::OUString aComposedUpdateTableName;
1822*b1cdbd2cSJim Jagielski if ( m_aUpdateTableName.getLength() )
1823*b1cdbd2cSJim Jagielski aComposedUpdateTableName = composeTableName( m_xActiveConnection->getMetaData(), m_aUpdateCatalogName, m_aUpdateSchemaName, m_aUpdateTableName, sal_False, ::dbtools::eInDataManipulation );
1824*b1cdbd2cSJim Jagielski
1825*b1cdbd2cSJim Jagielski {
1826*b1cdbd2cSJim Jagielski RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "frank.schoenheit@sun.com", "ORowSet::execute_NoApprove_NoNewConn: creating cache" );
1827*b1cdbd2cSJim Jagielski m_pCache = new ORowSetCache( xResultSet, m_xComposer.get(), m_aContext, aComposedUpdateTableName, m_bModified, m_bNew,m_aParameterValueForCache,m_aFilter,m_nMaxRows );
1828*b1cdbd2cSJim Jagielski if ( m_nResultSetConcurrency == ResultSetConcurrency::READ_ONLY )
1829*b1cdbd2cSJim Jagielski {
1830*b1cdbd2cSJim Jagielski m_nPrivileges = Privilege::SELECT;
1831*b1cdbd2cSJim Jagielski m_pCache->m_nPrivileges = Privilege::SELECT;
1832*b1cdbd2cSJim Jagielski }
1833*b1cdbd2cSJim Jagielski m_pCache->setFetchSize(m_nFetchSize);
1834*b1cdbd2cSJim Jagielski m_aCurrentRow = m_pCache->createIterator(this);
1835*b1cdbd2cSJim Jagielski m_bIsInsertRow = sal_False;
1836*b1cdbd2cSJim Jagielski m_aOldRow = m_pCache->registerOldRow();
1837*b1cdbd2cSJim Jagielski }
1838*b1cdbd2cSJim Jagielski
1839*b1cdbd2cSJim Jagielski // get the locale
1840*b1cdbd2cSJim Jagielski // ConfigManager* pConfigMgr = ConfigManager::GetConfigManager();
1841*b1cdbd2cSJim Jagielski Locale aLocale = SvtSysLocale().GetLocaleData().getLocale();
1842*b1cdbd2cSJim Jagielski // pConfigMgr->GetDirectConfigProperty(ConfigManager::LOCALE) >>= aLocale;
1843*b1cdbd2cSJim Jagielski
1844*b1cdbd2cSJim Jagielski // get the numberformatTypes
1845*b1cdbd2cSJim Jagielski OSL_ENSURE(m_xActiveConnection.is(),"No ActiveConnection");
1846*b1cdbd2cSJim Jagielski Reference< XNumberFormatTypes> xNumberFormatTypes;
1847*b1cdbd2cSJim Jagielski Reference< XNumberFormatsSupplier> xNumberFormat = ::dbtools::getNumberFormats(m_xActiveConnection);
1848*b1cdbd2cSJim Jagielski if ( xNumberFormat.is() )
1849*b1cdbd2cSJim Jagielski m_xNumberFormatTypes.set(xNumberFormat->getNumberFormats(),UNO_QUERY);
1850*b1cdbd2cSJim Jagielski
1851*b1cdbd2cSJim Jagielski ::vos::ORef< ::connectivity::OSQLColumns> aColumns = new ::connectivity::OSQLColumns();
1852*b1cdbd2cSJim Jagielski ::std::vector< ::rtl::OUString> aNames;
1853*b1cdbd2cSJim Jagielski ::rtl::OUString aDescription;
1854*b1cdbd2cSJim Jagielski sal_Int32 nFormatKey = 0;
1855*b1cdbd2cSJim Jagielski
1856*b1cdbd2cSJim Jagielski const ::std::map<sal_Int32,sal_Int32>& rKeyColumns = m_pCache->getKeyColumns();
1857*b1cdbd2cSJim Jagielski if(!m_xColumns.is())
1858*b1cdbd2cSJim Jagielski {
1859*b1cdbd2cSJim Jagielski RTL_LOGFILE_CONTEXT_AUTHOR( aColumnCreateLog, "dbaccess", "frank.schoenheit@sun.com", "ORowSet::execute_NoApprove_NoNewConn::creating columns" );
1860*b1cdbd2cSJim Jagielski // use the meta data
1861*b1cdbd2cSJim Jagielski Reference<XResultSetMetaDataSupplier> xMetaSup(m_xStatement,UNO_QUERY);
1862*b1cdbd2cSJim Jagielski try
1863*b1cdbd2cSJim Jagielski {
1864*b1cdbd2cSJim Jagielski Reference<XResultSetMetaData> xMetaData = xMetaSup->getMetaData();
1865*b1cdbd2cSJim Jagielski if ( xMetaData.is() )
1866*b1cdbd2cSJim Jagielski {
1867*b1cdbd2cSJim Jagielski sal_Int32 nCount = xMetaData->getColumnCount();
1868*b1cdbd2cSJim Jagielski m_aDataColumns.reserve(nCount+1);
1869*b1cdbd2cSJim Jagielski aColumns->get().reserve(nCount+1);
1870*b1cdbd2cSJim Jagielski DECLARE_STL_USTRINGACCESS_MAP(int,StringMap);
1871*b1cdbd2cSJim Jagielski StringMap aColumnMap;
1872*b1cdbd2cSJim Jagielski for (sal_Int32 i = 0 ; i < nCount; ++i)
1873*b1cdbd2cSJim Jagielski {
1874*b1cdbd2cSJim Jagielski // retrieve the name of the column
1875*b1cdbd2cSJim Jagielski ::rtl::OUString sName = xMetaData->getColumnName(i + 1);
1876*b1cdbd2cSJim Jagielski // check for duplicate entries
1877*b1cdbd2cSJim Jagielski if(aColumnMap.find(sName) != aColumnMap.end())
1878*b1cdbd2cSJim Jagielski {
1879*b1cdbd2cSJim Jagielski ::rtl::OUString sAlias(sName);
1880*b1cdbd2cSJim Jagielski sal_Int32 searchIndex=1;
1881*b1cdbd2cSJim Jagielski while(aColumnMap.find(sAlias) != aColumnMap.end())
1882*b1cdbd2cSJim Jagielski {
1883*b1cdbd2cSJim Jagielski (sAlias = sName) += ::rtl::OUString::valueOf(searchIndex++);
1884*b1cdbd2cSJim Jagielski }
1885*b1cdbd2cSJim Jagielski sName = sAlias;
1886*b1cdbd2cSJim Jagielski }
1887*b1cdbd2cSJim Jagielski ORowSetDataColumn* pColumn = new ORowSetDataColumn( getMetaData(),
1888*b1cdbd2cSJim Jagielski this,
1889*b1cdbd2cSJim Jagielski this,
1890*b1cdbd2cSJim Jagielski i+1,
1891*b1cdbd2cSJim Jagielski m_xActiveConnection->getMetaData(),
1892*b1cdbd2cSJim Jagielski aDescription,
1893*b1cdbd2cSJim Jagielski ::rtl::OUString(),
1894*b1cdbd2cSJim Jagielski m_aCurrentRow);
1895*b1cdbd2cSJim Jagielski aColumnMap.insert(StringMap::value_type(sName,0));
1896*b1cdbd2cSJim Jagielski aColumns->get().push_back(pColumn);
1897*b1cdbd2cSJim Jagielski pColumn->setName(sName);
1898*b1cdbd2cSJim Jagielski aNames.push_back(sName);
1899*b1cdbd2cSJim Jagielski m_aDataColumns.push_back(pColumn);
1900*b1cdbd2cSJim Jagielski
1901*b1cdbd2cSJim Jagielski pColumn->setFastPropertyValue_NoBroadcast(PROPERTY_ID_ISREADONLY,makeAny(rKeyColumns.find(i+1) != rKeyColumns.end()));
1902*b1cdbd2cSJim Jagielski
1903*b1cdbd2cSJim Jagielski try
1904*b1cdbd2cSJim Jagielski {
1905*b1cdbd2cSJim Jagielski nFormatKey = 0;
1906*b1cdbd2cSJim Jagielski if(m_xNumberFormatTypes.is())
1907*b1cdbd2cSJim Jagielski nFormatKey = ::dbtools::getDefaultNumberFormat(pColumn,m_xNumberFormatTypes,aLocale);
1908*b1cdbd2cSJim Jagielski
1909*b1cdbd2cSJim Jagielski
1910*b1cdbd2cSJim Jagielski pColumn->setFastPropertyValue_NoBroadcast(PROPERTY_ID_NUMBERFORMAT,makeAny(nFormatKey));
1911*b1cdbd2cSJim Jagielski pColumn->setFastPropertyValue_NoBroadcast(PROPERTY_ID_RELATIVEPOSITION,makeAny(sal_Int32(i+1)));
1912*b1cdbd2cSJim Jagielski pColumn->setFastPropertyValue_NoBroadcast(PROPERTY_ID_WIDTH,makeAny(sal_Int32(227)));
1913*b1cdbd2cSJim Jagielski pColumn->setFastPropertyValue_NoBroadcast(PROPERTY_ID_ALIGN,makeAny((sal_Int32)0));
1914*b1cdbd2cSJim Jagielski pColumn->setFastPropertyValue_NoBroadcast(PROPERTY_ID_HIDDEN,::cppu::bool2any(sal_False));
1915*b1cdbd2cSJim Jagielski }
1916*b1cdbd2cSJim Jagielski catch(Exception&)
1917*b1cdbd2cSJim Jagielski {
1918*b1cdbd2cSJim Jagielski }
1919*b1cdbd2cSJim Jagielski }
1920*b1cdbd2cSJim Jagielski }
1921*b1cdbd2cSJim Jagielski }
1922*b1cdbd2cSJim Jagielski catch (SQLException&)
1923*b1cdbd2cSJim Jagielski {
1924*b1cdbd2cSJim Jagielski }
1925*b1cdbd2cSJim Jagielski }
1926*b1cdbd2cSJim Jagielski else
1927*b1cdbd2cSJim Jagielski {
1928*b1cdbd2cSJim Jagielski // create the rowset columns
1929*b1cdbd2cSJim Jagielski Reference< XResultSetMetaData > xMeta( getMetaData(), UNO_QUERY_THROW );
1930*b1cdbd2cSJim Jagielski sal_Int32 nCount = xMeta->getColumnCount();
1931*b1cdbd2cSJim Jagielski m_aDataColumns.reserve(nCount+1);
1932*b1cdbd2cSJim Jagielski aColumns->get().reserve(nCount+1);
1933*b1cdbd2cSJim Jagielski ::std::set< Reference< XPropertySet > > aAllColumns;
1934*b1cdbd2cSJim Jagielski
1935*b1cdbd2cSJim Jagielski for(sal_Int32 i=1; i <= nCount ;++i)
1936*b1cdbd2cSJim Jagielski {
1937*b1cdbd2cSJim Jagielski ::rtl::OUString sName = xMeta->getColumnName(i);
1938*b1cdbd2cSJim Jagielski ::rtl::OUString sColumnLabel = xMeta->getColumnLabel(i);
1939*b1cdbd2cSJim Jagielski
1940*b1cdbd2cSJim Jagielski // retrieve the column number |i|
1941*b1cdbd2cSJim Jagielski Reference<XPropertySet> xColumn;
1942*b1cdbd2cSJim Jagielski {
1943*b1cdbd2cSJim Jagielski sal_Bool bReFetchName = sal_False;
1944*b1cdbd2cSJim Jagielski if (m_xColumns->hasByName(sColumnLabel))
1945*b1cdbd2cSJim Jagielski m_xColumns->getByName(sColumnLabel) >>= xColumn;
1946*b1cdbd2cSJim Jagielski if (!xColumn.is() && m_xColumns->hasByName(sName))
1947*b1cdbd2cSJim Jagielski m_xColumns->getByName(sName) >>= xColumn;
1948*b1cdbd2cSJim Jagielski
1949*b1cdbd2cSJim Jagielski // check if column already in the list we need another
1950*b1cdbd2cSJim Jagielski if ( aAllColumns.find( xColumn ) != aAllColumns.end() )
1951*b1cdbd2cSJim Jagielski {
1952*b1cdbd2cSJim Jagielski xColumn = NULL;
1953*b1cdbd2cSJim Jagielski bReFetchName = sal_True;
1954*b1cdbd2cSJim Jagielski sColumnLabel = ::rtl::OUString();
1955*b1cdbd2cSJim Jagielski }
1956*b1cdbd2cSJim Jagielski if(!xColumn.is())
1957*b1cdbd2cSJim Jagielski {
1958*b1cdbd2cSJim Jagielski // no column found so we could look at the position i
1959*b1cdbd2cSJim Jagielski //bReFetchName = sal_True;
1960*b1cdbd2cSJim Jagielski //sColumnLabel = ::rtl::OUString();
1961*b1cdbd2cSJim Jagielski Reference<XIndexAccess> xIndexAccess(m_xColumns,UNO_QUERY);
1962*b1cdbd2cSJim Jagielski if(xIndexAccess.is() && i <= xIndexAccess->getCount())
1963*b1cdbd2cSJim Jagielski {
1964*b1cdbd2cSJim Jagielski xIndexAccess->getByIndex(i-1) >>= xColumn;
1965*b1cdbd2cSJim Jagielski }
1966*b1cdbd2cSJim Jagielski else
1967*b1cdbd2cSJim Jagielski {
1968*b1cdbd2cSJim Jagielski Sequence< ::rtl::OUString> aSeq = m_xColumns->getElementNames();
1969*b1cdbd2cSJim Jagielski if( i <= aSeq.getLength())
1970*b1cdbd2cSJim Jagielski {
1971*b1cdbd2cSJim Jagielski m_xColumns->getByName(aSeq.getConstArray()[i-1]) >>= xColumn;
1972*b1cdbd2cSJim Jagielski }
1973*b1cdbd2cSJim Jagielski }
1974*b1cdbd2cSJim Jagielski }
1975*b1cdbd2cSJim Jagielski if(bReFetchName && xColumn.is())
1976*b1cdbd2cSJim Jagielski xColumn->getPropertyValue(PROPERTY_NAME) >>= sName;
1977*b1cdbd2cSJim Jagielski aAllColumns.insert( xColumn );
1978*b1cdbd2cSJim Jagielski }
1979*b1cdbd2cSJim Jagielski
1980*b1cdbd2cSJim Jagielski // create a RowSetDataColumn
1981*b1cdbd2cSJim Jagielski {
1982*b1cdbd2cSJim Jagielski Reference<XPropertySetInfo> xInfo = xColumn.is() ? xColumn->getPropertySetInfo() : Reference<XPropertySetInfo>();
1983*b1cdbd2cSJim Jagielski if(xInfo.is() && xInfo->hasPropertyByName(PROPERTY_DESCRIPTION))
1984*b1cdbd2cSJim Jagielski aDescription = comphelper::getString(xColumn->getPropertyValue(PROPERTY_DESCRIPTION));
1985*b1cdbd2cSJim Jagielski
1986*b1cdbd2cSJim Jagielski ::rtl::OUString sParseLabel;
1987*b1cdbd2cSJim Jagielski if ( xColumn.is() )
1988*b1cdbd2cSJim Jagielski {
1989*b1cdbd2cSJim Jagielski xColumn->getPropertyValue(PROPERTY_LABEL) >>= sParseLabel;
1990*b1cdbd2cSJim Jagielski }
1991*b1cdbd2cSJim Jagielski ORowSetDataColumn* pColumn = new ORowSetDataColumn( getMetaData(),
1992*b1cdbd2cSJim Jagielski this,
1993*b1cdbd2cSJim Jagielski this,
1994*b1cdbd2cSJim Jagielski i,
1995*b1cdbd2cSJim Jagielski m_xActiveConnection->getMetaData(),
1996*b1cdbd2cSJim Jagielski aDescription,
1997*b1cdbd2cSJim Jagielski sParseLabel,
1998*b1cdbd2cSJim Jagielski m_aCurrentRow);
1999*b1cdbd2cSJim Jagielski aColumns->get().push_back(pColumn);
2000*b1cdbd2cSJim Jagielski
2001*b1cdbd2cSJim Jagielski pColumn->setFastPropertyValue_NoBroadcast(PROPERTY_ID_ISREADONLY,makeAny(rKeyColumns.find(i) != rKeyColumns.end()));
2002*b1cdbd2cSJim Jagielski
2003*b1cdbd2cSJim Jagielski if(!sColumnLabel.getLength())
2004*b1cdbd2cSJim Jagielski {
2005*b1cdbd2cSJim Jagielski if(xColumn.is())
2006*b1cdbd2cSJim Jagielski xColumn->getPropertyValue(PROPERTY_NAME) >>= sColumnLabel;
2007*b1cdbd2cSJim Jagielski else
2008*b1cdbd2cSJim Jagielski sColumnLabel = DBACORE_RESSTRING( RID_STR_EXPRESSION1 );
2009*b1cdbd2cSJim Jagielski }
2010*b1cdbd2cSJim Jagielski pColumn->setName(sColumnLabel);
2011*b1cdbd2cSJim Jagielski aNames.push_back(sColumnLabel);
2012*b1cdbd2cSJim Jagielski m_aDataColumns.push_back(pColumn);
2013*b1cdbd2cSJim Jagielski
2014*b1cdbd2cSJim Jagielski if ( xColumn.is() )
2015*b1cdbd2cSJim Jagielski impl_initializeColumnSettings_nothrow( xColumn, pColumn );
2016*b1cdbd2cSJim Jagielski }
2017*b1cdbd2cSJim Jagielski }
2018*b1cdbd2cSJim Jagielski }
2019*b1cdbd2cSJim Jagielski // now create the columns we need
2020*b1cdbd2cSJim Jagielski if(m_pColumns)
2021*b1cdbd2cSJim Jagielski m_pColumns->assign(aColumns,aNames);
2022*b1cdbd2cSJim Jagielski else
2023*b1cdbd2cSJim Jagielski {
2024*b1cdbd2cSJim Jagielski Reference<XDatabaseMetaData> xMeta = m_xActiveConnection->getMetaData();
2025*b1cdbd2cSJim Jagielski m_pColumns = new ORowSetDataColumns(xMeta.is() && xMeta->supportsMixedCaseQuotedIdentifiers(),
2026*b1cdbd2cSJim Jagielski aColumns,*this,m_aColumnsMutex,aNames);
2027*b1cdbd2cSJim Jagielski }
2028*b1cdbd2cSJim Jagielski }
2029*b1cdbd2cSJim Jagielski checkCache();
2030*b1cdbd2cSJim Jagielski // notify the rowset listeners
2031*b1cdbd2cSJim Jagielski notifyAllListeners(_rClearForNotification);
2032*b1cdbd2cSJim Jagielski }
2033*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
2034*b1cdbd2cSJim Jagielski // XRowSetApproveBroadcaster
addRowSetApproveListener(const Reference<XRowSetApproveListener> & listener)2035*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::addRowSetApproveListener( const Reference< XRowSetApproveListener >& listener ) throw(RuntimeException)
2036*b1cdbd2cSJim Jagielski {
2037*b1cdbd2cSJim Jagielski ::connectivity::checkDisposed(ORowSet_BASE1::rBHelper.bDisposed);
2038*b1cdbd2cSJim Jagielski
2039*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aColumnsMutex );
2040*b1cdbd2cSJim Jagielski
2041*b1cdbd2cSJim Jagielski m_aApproveListeners.addInterface(listener);
2042*b1cdbd2cSJim Jagielski }
2043*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
removeRowSetApproveListener(const Reference<XRowSetApproveListener> & listener)2044*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::removeRowSetApproveListener( const Reference< XRowSetApproveListener >& listener ) throw(RuntimeException)
2045*b1cdbd2cSJim Jagielski {
2046*b1cdbd2cSJim Jagielski ::connectivity::checkDisposed(ORowSet_BASE1::rBHelper.bDisposed);
2047*b1cdbd2cSJim Jagielski
2048*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aColumnsMutex );
2049*b1cdbd2cSJim Jagielski
2050*b1cdbd2cSJim Jagielski m_aApproveListeners.removeInterface(listener);
2051*b1cdbd2cSJim Jagielski }
2052*b1cdbd2cSJim Jagielski // XRowsChangeBroadcaster
addRowsChangeListener(const Reference<XRowsChangeListener> & listener)2053*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::addRowsChangeListener( const Reference< XRowsChangeListener >& listener ) throw(RuntimeException)
2054*b1cdbd2cSJim Jagielski {
2055*b1cdbd2cSJim Jagielski ::connectivity::checkDisposed(ORowSet_BASE1::rBHelper.bDisposed);
2056*b1cdbd2cSJim Jagielski
2057*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aColumnsMutex );
2058*b1cdbd2cSJim Jagielski
2059*b1cdbd2cSJim Jagielski m_aRowsChangeListener.addInterface(listener);
2060*b1cdbd2cSJim Jagielski }
2061*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
removeRowsChangeListener(const Reference<XRowsChangeListener> & listener)2062*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::removeRowsChangeListener( const Reference< XRowsChangeListener >& listener ) throw(RuntimeException)
2063*b1cdbd2cSJim Jagielski {
2064*b1cdbd2cSJim Jagielski ::connectivity::checkDisposed(ORowSet_BASE1::rBHelper.bDisposed);
2065*b1cdbd2cSJim Jagielski
2066*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aColumnsMutex );
2067*b1cdbd2cSJim Jagielski
2068*b1cdbd2cSJim Jagielski m_aRowsChangeListener.removeInterface(listener);
2069*b1cdbd2cSJim Jagielski }
2070*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
2071*b1cdbd2cSJim Jagielski
2072*b1cdbd2cSJim Jagielski // XResultSetAccess
createResultSet()2073*b1cdbd2cSJim Jagielski Reference< XResultSet > SAL_CALL ORowSet::createResultSet( ) throw(SQLException, RuntimeException)
2074*b1cdbd2cSJim Jagielski {
2075*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aColumnsMutex );
2076*b1cdbd2cSJim Jagielski
2077*b1cdbd2cSJim Jagielski if(m_xStatement.is())
2078*b1cdbd2cSJim Jagielski {
2079*b1cdbd2cSJim Jagielski ORowSetClone* pClone = new ORowSetClone( m_aContext, *this, m_pMutex );
2080*b1cdbd2cSJim Jagielski Reference< XResultSet > xRet(pClone);
2081*b1cdbd2cSJim Jagielski m_aClones.push_back(WeakReferenceHelper(xRet));
2082*b1cdbd2cSJim Jagielski return xRet;
2083*b1cdbd2cSJim Jagielski }
2084*b1cdbd2cSJim Jagielski return Reference< XResultSet >();
2085*b1cdbd2cSJim Jagielski }
2086*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
2087*b1cdbd2cSJim Jagielski
2088*b1cdbd2cSJim Jagielski // ::com::sun::star::util::XCancellable
cancel()2089*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::cancel( ) throw(RuntimeException)
2090*b1cdbd2cSJim Jagielski {
2091*b1cdbd2cSJim Jagielski ::connectivity::checkDisposed(ORowSet_BASE1::rBHelper.bDisposed);
2092*b1cdbd2cSJim Jagielski }
2093*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
2094*b1cdbd2cSJim Jagielski
2095*b1cdbd2cSJim Jagielski // ::com::sun::star::sdbcx::XDeleteRows
deleteRows(const Sequence<Any> & rows)2096*b1cdbd2cSJim Jagielski Sequence< sal_Int32 > SAL_CALL ORowSet::deleteRows( const Sequence< Any >& rows ) throw(SQLException, RuntimeException)
2097*b1cdbd2cSJim Jagielski {
2098*b1cdbd2cSJim Jagielski ::connectivity::checkDisposed(ORowSet_BASE1::rBHelper.bDisposed);
2099*b1cdbd2cSJim Jagielski
2100*b1cdbd2cSJim Jagielski if(!m_pCache || m_nResultSetConcurrency == ResultSetConcurrency::READ_ONLY)
2101*b1cdbd2cSJim Jagielski throwFunctionSequenceException(*this);
2102*b1cdbd2cSJim Jagielski
2103*b1cdbd2cSJim Jagielski ::osl::ResettableMutexGuard aGuard( *m_pMutex );
2104*b1cdbd2cSJim Jagielski
2105*b1cdbd2cSJim Jagielski Sequence<Any> aChangedBookmarks;
2106*b1cdbd2cSJim Jagielski RowsChangeEvent aEvt(*this,RowChangeAction::DELETE,rows.getLength(),aChangedBookmarks);
2107*b1cdbd2cSJim Jagielski // notify the rowset listeners
2108*b1cdbd2cSJim Jagielski notifyAllListenersRowBeforeChange(aGuard,aEvt);
2109*b1cdbd2cSJim Jagielski
2110*b1cdbd2cSJim Jagielski Sequence< sal_Int32 > aResults( rows.getLength() );
2111*b1cdbd2cSJim Jagielski const Any* row = rows.getConstArray();
2112*b1cdbd2cSJim Jagielski const Any* rowEnd = rows.getConstArray() + rows.getLength();
2113*b1cdbd2cSJim Jagielski sal_Int32* result = aResults.getArray();
2114*b1cdbd2cSJim Jagielski for ( ; row != rowEnd; ++row, ++result )
2115*b1cdbd2cSJim Jagielski {
2116*b1cdbd2cSJim Jagielski *result = 0;
2117*b1cdbd2cSJim Jagielski if ( !m_pCache->moveToBookmark( *row ) )
2118*b1cdbd2cSJim Jagielski continue;
2119*b1cdbd2cSJim Jagielski sal_Int32 nDeletePosition = m_pCache->getRow();
2120*b1cdbd2cSJim Jagielski
2121*b1cdbd2cSJim Jagielski // first notify the clones so that they can save their position
2122*b1cdbd2cSJim Jagielski notifyRowSetAndClonesRowDelete( *row );
2123*b1cdbd2cSJim Jagielski
2124*b1cdbd2cSJim Jagielski // now delete the row
2125*b1cdbd2cSJim Jagielski if ( !m_pCache->deleteRow() )
2126*b1cdbd2cSJim Jagielski continue;
2127*b1cdbd2cSJim Jagielski *result = 1;
2128*b1cdbd2cSJim Jagielski // now notify that we have deleted
2129*b1cdbd2cSJim Jagielski notifyRowSetAndClonesRowDeleted( *row, nDeletePosition );
2130*b1cdbd2cSJim Jagielski }
2131*b1cdbd2cSJim Jagielski aEvt.Rows = aResults.getLength();
2132*b1cdbd2cSJim Jagielski
2133*b1cdbd2cSJim Jagielski // we have to check if we stand on the insert row and if so we have to reset it
2134*b1cdbd2cSJim Jagielski ORowSetNotifier aNotifier( this );
2135*b1cdbd2cSJim Jagielski // this will call cancelRowModification on the cache if necessary
2136*b1cdbd2cSJim Jagielski // notification order
2137*b1cdbd2cSJim Jagielski // - rowChanged
2138*b1cdbd2cSJim Jagielski notifyAllListenersRowChanged(aGuard,aEvt);
2139*b1cdbd2cSJim Jagielski
2140*b1cdbd2cSJim Jagielski // - IsModified
2141*b1cdbd2cSJim Jagielski // - IsNew
2142*b1cdbd2cSJim Jagielski aNotifier.fire();
2143*b1cdbd2cSJim Jagielski
2144*b1cdbd2cSJim Jagielski // - RowCount/IsRowCountFinal
2145*b1cdbd2cSJim Jagielski fireRowcount();
2146*b1cdbd2cSJim Jagielski
2147*b1cdbd2cSJim Jagielski return aResults;
2148*b1cdbd2cSJim Jagielski }
2149*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
notifyRowSetAndClonesRowDelete(const Any & _rBookmark)2150*b1cdbd2cSJim Jagielski void ORowSet::notifyRowSetAndClonesRowDelete( const Any& _rBookmark )
2151*b1cdbd2cSJim Jagielski {
2152*b1cdbd2cSJim Jagielski // notify ourself
2153*b1cdbd2cSJim Jagielski onDeleteRow( _rBookmark );
2154*b1cdbd2cSJim Jagielski // notify the clones
2155*b1cdbd2cSJim Jagielski connectivity::OWeakRefArray::iterator aEnd = m_aClones.end();
2156*b1cdbd2cSJim Jagielski for (connectivity::OWeakRefArray::iterator i = m_aClones.begin(); aEnd != i; i++)
2157*b1cdbd2cSJim Jagielski {
2158*b1cdbd2cSJim Jagielski Reference< XUnoTunnel > xTunnel(i->get(),UNO_QUERY);
2159*b1cdbd2cSJim Jagielski if(xTunnel.is())
2160*b1cdbd2cSJim Jagielski {
2161*b1cdbd2cSJim Jagielski ORowSetClone* pClone = reinterpret_cast<ORowSetClone*>(xTunnel->getSomething(ORowSetClone::getUnoTunnelImplementationId()));
2162*b1cdbd2cSJim Jagielski if(pClone)
2163*b1cdbd2cSJim Jagielski pClone->onDeleteRow( _rBookmark );
2164*b1cdbd2cSJim Jagielski }
2165*b1cdbd2cSJim Jagielski }
2166*b1cdbd2cSJim Jagielski }
2167*b1cdbd2cSJim Jagielski //------------------------------------------------------------------------------
notifyRowSetAndClonesRowDeleted(const Any & _rBookmark,sal_Int32 _nPos)2168*b1cdbd2cSJim Jagielski void ORowSet::notifyRowSetAndClonesRowDeleted( const Any& _rBookmark, sal_Int32 _nPos )
2169*b1cdbd2cSJim Jagielski {
2170*b1cdbd2cSJim Jagielski // notify ourself
2171*b1cdbd2cSJim Jagielski onDeletedRow( _rBookmark, _nPos );
2172*b1cdbd2cSJim Jagielski // notify the clones
2173*b1cdbd2cSJim Jagielski connectivity::OWeakRefArray::iterator aEnd = m_aClones.end();
2174*b1cdbd2cSJim Jagielski for (connectivity::OWeakRefArray::iterator i = m_aClones.begin(); aEnd != i; i++)
2175*b1cdbd2cSJim Jagielski {
2176*b1cdbd2cSJim Jagielski Reference< XUnoTunnel > xTunnel(i->get(),UNO_QUERY);
2177*b1cdbd2cSJim Jagielski if(xTunnel.is())
2178*b1cdbd2cSJim Jagielski {
2179*b1cdbd2cSJim Jagielski ORowSetClone* pClone = reinterpret_cast<ORowSetClone*>(xTunnel->getSomething(ORowSetClone::getUnoTunnelImplementationId()));
2180*b1cdbd2cSJim Jagielski if(pClone)
2181*b1cdbd2cSJim Jagielski pClone->onDeletedRow( _rBookmark, _nPos );
2182*b1cdbd2cSJim Jagielski }
2183*b1cdbd2cSJim Jagielski }
2184*b1cdbd2cSJim Jagielski }
2185*b1cdbd2cSJim Jagielski //------------------------------------------------------------------------------
calcConnection(const Reference<XInteractionHandler> & _rxHandler)2186*b1cdbd2cSJim Jagielski Reference< XConnection > ORowSet::calcConnection(const Reference< XInteractionHandler >& _rxHandler) throw( SQLException, RuntimeException )
2187*b1cdbd2cSJim Jagielski {
2188*b1cdbd2cSJim Jagielski MutexGuard aGuard(m_aMutex);
2189*b1cdbd2cSJim Jagielski if (!m_xActiveConnection.is())
2190*b1cdbd2cSJim Jagielski {
2191*b1cdbd2cSJim Jagielski Reference< XConnection > xNewConn;
2192*b1cdbd2cSJim Jagielski if ( m_aDataSourceName.getLength() )
2193*b1cdbd2cSJim Jagielski {
2194*b1cdbd2cSJim Jagielski Reference< XNameAccess > xDatabaseContext(
2195*b1cdbd2cSJim Jagielski m_aContext.createComponent( (::rtl::OUString)SERVICE_SDB_DATABASECONTEXT ),
2196*b1cdbd2cSJim Jagielski UNO_QUERY_THROW );
2197*b1cdbd2cSJim Jagielski try
2198*b1cdbd2cSJim Jagielski {
2199*b1cdbd2cSJim Jagielski Reference< XDataSource > xDataSource( xDatabaseContext->getByName( m_aDataSourceName ), UNO_QUERY_THROW );
2200*b1cdbd2cSJim Jagielski
2201*b1cdbd2cSJim Jagielski // try connecting with the interaction handler
2202*b1cdbd2cSJim Jagielski Reference< XCompletedConnection > xComplConn( xDataSource, UNO_QUERY );
2203*b1cdbd2cSJim Jagielski if ( _rxHandler.is() && xComplConn.is() )
2204*b1cdbd2cSJim Jagielski {
2205*b1cdbd2cSJim Jagielski xNewConn = xComplConn->connectWithCompletion( _rxHandler );
2206*b1cdbd2cSJim Jagielski }
2207*b1cdbd2cSJim Jagielski else
2208*b1cdbd2cSJim Jagielski {
2209*b1cdbd2cSJim Jagielski xNewConn = xDataSource->getConnection( m_aUser, m_aPassword );
2210*b1cdbd2cSJim Jagielski }
2211*b1cdbd2cSJim Jagielski }
2212*b1cdbd2cSJim Jagielski catch ( const SQLException& e )
2213*b1cdbd2cSJim Jagielski {
2214*b1cdbd2cSJim Jagielski throw;
2215*b1cdbd2cSJim Jagielski }
2216*b1cdbd2cSJim Jagielski catch ( const Exception& e )
2217*b1cdbd2cSJim Jagielski {
2218*b1cdbd2cSJim Jagielski Any aError = ::cppu::getCaughtException();
2219*b1cdbd2cSJim Jagielski ::rtl::OUString sMessage = ResourceManager::loadString( RID_NO_SUCH_DATA_SOURCE,
2220*b1cdbd2cSJim Jagielski "$name$", m_aDataSourceName, "$error$", extractExceptionMessage( m_aContext, aError ) );
2221*b1cdbd2cSJim Jagielski ::dbtools::throwGenericSQLException( sMessage, *this );
2222*b1cdbd2cSJim Jagielski }
2223*b1cdbd2cSJim Jagielski }
2224*b1cdbd2cSJim Jagielski setActiveConnection(xNewConn);
2225*b1cdbd2cSJim Jagielski m_bOwnConnection = sal_True;
2226*b1cdbd2cSJim Jagielski }
2227*b1cdbd2cSJim Jagielski return m_xActiveConnection;
2228*b1cdbd2cSJim Jagielski }
2229*b1cdbd2cSJim Jagielski //------------------------------------------------------------------------------
impl_getTables_throw()2230*b1cdbd2cSJim Jagielski Reference< XNameAccess > ORowSet::impl_getTables_throw()
2231*b1cdbd2cSJim Jagielski {
2232*b1cdbd2cSJim Jagielski Reference< XNameAccess > xTables;
2233*b1cdbd2cSJim Jagielski
2234*b1cdbd2cSJim Jagielski Reference< XTablesSupplier > xTablesAccess( m_xActiveConnection, UNO_QUERY );
2235*b1cdbd2cSJim Jagielski if ( xTablesAccess.is() )
2236*b1cdbd2cSJim Jagielski {
2237*b1cdbd2cSJim Jagielski xTables.set( xTablesAccess->getTables(), UNO_QUERY_THROW );
2238*b1cdbd2cSJim Jagielski }
2239*b1cdbd2cSJim Jagielski else if ( m_pTables )
2240*b1cdbd2cSJim Jagielski {
2241*b1cdbd2cSJim Jagielski xTables = m_pTables;
2242*b1cdbd2cSJim Jagielski }
2243*b1cdbd2cSJim Jagielski else
2244*b1cdbd2cSJim Jagielski {
2245*b1cdbd2cSJim Jagielski if ( !m_xActiveConnection.is() )
2246*b1cdbd2cSJim Jagielski throw SQLException(DBA_RES(RID_STR_CONNECTION_INVALID),*this,SQLSTATE_GENERAL,1000,Any() );
2247*b1cdbd2cSJim Jagielski
2248*b1cdbd2cSJim Jagielski sal_Bool bCase = sal_True;
2249*b1cdbd2cSJim Jagielski try
2250*b1cdbd2cSJim Jagielski {
2251*b1cdbd2cSJim Jagielski Reference<XDatabaseMetaData> xMeta = m_xActiveConnection->getMetaData();
2252*b1cdbd2cSJim Jagielski bCase = xMeta.is() && xMeta->supportsMixedCaseQuotedIdentifiers();
2253*b1cdbd2cSJim Jagielski }
2254*b1cdbd2cSJim Jagielski catch(SQLException&)
2255*b1cdbd2cSJim Jagielski {
2256*b1cdbd2cSJim Jagielski DBG_UNHANDLED_EXCEPTION();
2257*b1cdbd2cSJim Jagielski }
2258*b1cdbd2cSJim Jagielski
2259*b1cdbd2cSJim Jagielski m_pTables = new OTableContainer(*this,m_aMutex,m_xActiveConnection,bCase,NULL,NULL,NULL,m_nInAppend);
2260*b1cdbd2cSJim Jagielski xTables = m_pTables;
2261*b1cdbd2cSJim Jagielski Sequence< ::rtl::OUString> aTableFilter(1);
2262*b1cdbd2cSJim Jagielski aTableFilter[0] = ::rtl::OUString::createFromAscii("%");
2263*b1cdbd2cSJim Jagielski m_pTables->construct(aTableFilter,Sequence< ::rtl::OUString>());
2264*b1cdbd2cSJim Jagielski }
2265*b1cdbd2cSJim Jagielski
2266*b1cdbd2cSJim Jagielski return xTables;
2267*b1cdbd2cSJim Jagielski }
2268*b1cdbd2cSJim Jagielski
2269*b1cdbd2cSJim Jagielski //------------------------------------------------------------------------------
impl_resetTables_nothrow()2270*b1cdbd2cSJim Jagielski void ORowSet::impl_resetTables_nothrow()
2271*b1cdbd2cSJim Jagielski {
2272*b1cdbd2cSJim Jagielski if ( !m_pTables )
2273*b1cdbd2cSJim Jagielski return;
2274*b1cdbd2cSJim Jagielski
2275*b1cdbd2cSJim Jagielski try
2276*b1cdbd2cSJim Jagielski {
2277*b1cdbd2cSJim Jagielski m_pTables->dispose();
2278*b1cdbd2cSJim Jagielski }
2279*b1cdbd2cSJim Jagielski catch( const Exception& )
2280*b1cdbd2cSJim Jagielski {
2281*b1cdbd2cSJim Jagielski DBG_UNHANDLED_EXCEPTION();
2282*b1cdbd2cSJim Jagielski }
2283*b1cdbd2cSJim Jagielski
2284*b1cdbd2cSJim Jagielski DELETEZ( m_pTables );
2285*b1cdbd2cSJim Jagielski }
2286*b1cdbd2cSJim Jagielski
2287*b1cdbd2cSJim Jagielski //------------------------------------------------------------------------------
impl_initComposer_throw(::rtl::OUString & _out_rCommandToExecute)2288*b1cdbd2cSJim Jagielski sal_Bool ORowSet::impl_initComposer_throw( ::rtl::OUString& _out_rCommandToExecute )
2289*b1cdbd2cSJim Jagielski {
2290*b1cdbd2cSJim Jagielski sal_Bool bUseEscapeProcessing = impl_buildActiveCommand_throw( );
2291*b1cdbd2cSJim Jagielski _out_rCommandToExecute = m_aActiveCommand;
2292*b1cdbd2cSJim Jagielski if ( !bUseEscapeProcessing )
2293*b1cdbd2cSJim Jagielski return bUseEscapeProcessing;
2294*b1cdbd2cSJim Jagielski
2295*b1cdbd2cSJim Jagielski Reference< XMultiServiceFactory > xFactory( m_xActiveConnection, UNO_QUERY );
2296*b1cdbd2cSJim Jagielski if ( xFactory.is() )
2297*b1cdbd2cSJim Jagielski {
2298*b1cdbd2cSJim Jagielski try
2299*b1cdbd2cSJim Jagielski {
2300*b1cdbd2cSJim Jagielski ::comphelper::disposeComponent( m_xComposer );
2301*b1cdbd2cSJim Jagielski m_xComposer.set( xFactory->createInstance( SERVICE_NAME_SINGLESELECTQUERYCOMPOSER ), UNO_QUERY_THROW );
2302*b1cdbd2cSJim Jagielski }
2303*b1cdbd2cSJim Jagielski catch (const Exception& ) { m_xComposer = NULL; }
2304*b1cdbd2cSJim Jagielski }
2305*b1cdbd2cSJim Jagielski if ( !m_xComposer.is() )
2306*b1cdbd2cSJim Jagielski m_xComposer = new OSingleSelectQueryComposer( impl_getTables_throw(), m_xActiveConnection, m_aContext );
2307*b1cdbd2cSJim Jagielski
2308*b1cdbd2cSJim Jagielski m_xComposer->setCommand( m_aCommand,m_nCommandType );
2309*b1cdbd2cSJim Jagielski m_aActiveCommand = m_xComposer->getQuery();
2310*b1cdbd2cSJim Jagielski
2311*b1cdbd2cSJim Jagielski m_xComposer->setFilter( m_bApplyFilter ? m_aFilter : ::rtl::OUString() );
2312*b1cdbd2cSJim Jagielski m_xComposer->setHavingClause( m_bApplyFilter ? m_aHavingClause : ::rtl::OUString() );
2313*b1cdbd2cSJim Jagielski
2314*b1cdbd2cSJim Jagielski if ( m_bIgnoreResult )
2315*b1cdbd2cSJim Jagielski { // append a "0=1" filter
2316*b1cdbd2cSJim Jagielski // don't simply overwrite an existent filter, this would lead to problems if this existent
2317*b1cdbd2cSJim Jagielski // filter contains paramters (since a keyset may add parameters itself)
2318*b1cdbd2cSJim Jagielski // 2003-12-12 - #23418# - fs@openoffice.org
2319*b1cdbd2cSJim Jagielski m_xComposer->setElementaryQuery( m_xComposer->getQuery( ) );
2320*b1cdbd2cSJim Jagielski m_xComposer->setFilter( ::rtl::OUString::createFromAscii( "0 = 1" ) );
2321*b1cdbd2cSJim Jagielski }
2322*b1cdbd2cSJim Jagielski
2323*b1cdbd2cSJim Jagielski m_xComposer->setOrder( m_aOrder );
2324*b1cdbd2cSJim Jagielski m_xComposer->setGroup( m_aGroupBy );
2325*b1cdbd2cSJim Jagielski
2326*b1cdbd2cSJim Jagielski if ( !m_xColumns.is() )
2327*b1cdbd2cSJim Jagielski {
2328*b1cdbd2cSJim Jagielski Reference< XColumnsSupplier > xCols( m_xComposer, UNO_QUERY_THROW );
2329*b1cdbd2cSJim Jagielski m_xColumns = xCols->getColumns();
2330*b1cdbd2cSJim Jagielski }
2331*b1cdbd2cSJim Jagielski
2332*b1cdbd2cSJim Jagielski impl_initParametersContainer_nothrow();
2333*b1cdbd2cSJim Jagielski
2334*b1cdbd2cSJim Jagielski _out_rCommandToExecute = m_xComposer->getQueryWithSubstitution();
2335*b1cdbd2cSJim Jagielski
2336*b1cdbd2cSJim Jagielski return bUseEscapeProcessing;
2337*b1cdbd2cSJim Jagielski }
2338*b1cdbd2cSJim Jagielski
2339*b1cdbd2cSJim Jagielski //------------------------------------------------------------------------------
impl_buildActiveCommand_throw()2340*b1cdbd2cSJim Jagielski sal_Bool ORowSet::impl_buildActiveCommand_throw()
2341*b1cdbd2cSJim Jagielski {
2342*b1cdbd2cSJim Jagielski // create the sql command
2343*b1cdbd2cSJim Jagielski // from a table name or get the command out of a query (not a view)
2344*b1cdbd2cSJim Jagielski // the last use the command as it is
2345*b1cdbd2cSJim Jagielski sal_Bool bDoEscapeProcessing = m_bUseEscapeProcessing;
2346*b1cdbd2cSJim Jagielski
2347*b1cdbd2cSJim Jagielski m_aActiveCommand = ::rtl::OUString();
2348*b1cdbd2cSJim Jagielski ::rtl::OUString sCommand;
2349*b1cdbd2cSJim Jagielski
2350*b1cdbd2cSJim Jagielski if ( !m_aCommand.getLength() )
2351*b1cdbd2cSJim Jagielski return bDoEscapeProcessing;
2352*b1cdbd2cSJim Jagielski
2353*b1cdbd2cSJim Jagielski switch (m_nCommandType)
2354*b1cdbd2cSJim Jagielski {
2355*b1cdbd2cSJim Jagielski case CommandType::TABLE:
2356*b1cdbd2cSJim Jagielski {
2357*b1cdbd2cSJim Jagielski impl_resetTables_nothrow();
2358*b1cdbd2cSJim Jagielski if ( bDoEscapeProcessing )
2359*b1cdbd2cSJim Jagielski {
2360*b1cdbd2cSJim Jagielski Reference< XNameAccess > xTables( impl_getTables_throw() );
2361*b1cdbd2cSJim Jagielski if ( xTables->hasByName(m_aCommand) )
2362*b1cdbd2cSJim Jagielski {
2363*b1cdbd2cSJim Jagielski /*
2364*b1cdbd2cSJim Jagielski Reference< XPropertySet > xTable;
2365*b1cdbd2cSJim Jagielski try
2366*b1cdbd2cSJim Jagielski {
2367*b1cdbd2cSJim Jagielski xTables->getByName( m_aCommand ) >>= xTable;
2368*b1cdbd2cSJim Jagielski }
2369*b1cdbd2cSJim Jagielski catch(const WrappedTargetException& e)
2370*b1cdbd2cSJim Jagielski {
2371*b1cdbd2cSJim Jagielski SQLException e2;
2372*b1cdbd2cSJim Jagielski if ( e.TargetException >>= e2 )
2373*b1cdbd2cSJim Jagielski throw e2;
2374*b1cdbd2cSJim Jagielski }
2375*b1cdbd2cSJim Jagielski catch(Exception&)
2376*b1cdbd2cSJim Jagielski {
2377*b1cdbd2cSJim Jagielski DBG_UNHANDLED_EXCEPTION();
2378*b1cdbd2cSJim Jagielski }
2379*b1cdbd2cSJim Jagielski
2380*b1cdbd2cSJim Jagielski Reference<XColumnsSupplier> xSup(xTable,UNO_QUERY);
2381*b1cdbd2cSJim Jagielski if ( xSup.is() )
2382*b1cdbd2cSJim Jagielski m_xColumns = xSup->getColumns();
2383*b1cdbd2cSJim Jagielski
2384*b1cdbd2cSJim Jagielski sCommand = rtl::OUString::createFromAscii("SELECT * FROM ");
2385*b1cdbd2cSJim Jagielski ::rtl::OUString sCatalog, sSchema, sTable;
2386*b1cdbd2cSJim Jagielski ::dbtools::qualifiedNameComponents( m_xActiveConnection->getMetaData(), m_aCommand, sCatalog, sSchema, sTable, ::dbtools::eInDataManipulation );
2387*b1cdbd2cSJim Jagielski sCommand += ::dbtools::composeTableNameForSelect( m_xActiveConnection, sCatalog, sSchema, sTable );
2388*b1cdbd2cSJim Jagielski */
2389*b1cdbd2cSJim Jagielski }
2390*b1cdbd2cSJim Jagielski else
2391*b1cdbd2cSJim Jagielski {
2392*b1cdbd2cSJim Jagielski String sMessage( DBACORE_RESSTRING( RID_STR_TABLE_DOES_NOT_EXIST ) );
2393*b1cdbd2cSJim Jagielski sMessage.SearchAndReplaceAscii( "$table$", m_aCommand );
2394*b1cdbd2cSJim Jagielski throwGenericSQLException(sMessage,*this);
2395*b1cdbd2cSJim Jagielski }
2396*b1cdbd2cSJim Jagielski }
2397*b1cdbd2cSJim Jagielski else
2398*b1cdbd2cSJim Jagielski {
2399*b1cdbd2cSJim Jagielski sCommand = rtl::OUString::createFromAscii("SELECT * FROM ");
2400*b1cdbd2cSJim Jagielski ::rtl::OUString sCatalog, sSchema, sTable;
2401*b1cdbd2cSJim Jagielski ::dbtools::qualifiedNameComponents( m_xActiveConnection->getMetaData(), m_aCommand, sCatalog, sSchema, sTable, ::dbtools::eInDataManipulation );
2402*b1cdbd2cSJim Jagielski sCommand += ::dbtools::composeTableNameForSelect( m_xActiveConnection, sCatalog, sSchema, sTable );
2403*b1cdbd2cSJim Jagielski }
2404*b1cdbd2cSJim Jagielski }
2405*b1cdbd2cSJim Jagielski break;
2406*b1cdbd2cSJim Jagielski
2407*b1cdbd2cSJim Jagielski case CommandType::QUERY:
2408*b1cdbd2cSJim Jagielski {
2409*b1cdbd2cSJim Jagielski Reference< XQueriesSupplier > xQueriesAccess(m_xActiveConnection, UNO_QUERY);
2410*b1cdbd2cSJim Jagielski if (xQueriesAccess.is())
2411*b1cdbd2cSJim Jagielski {
2412*b1cdbd2cSJim Jagielski Reference< ::com::sun::star::container::XNameAccess > xQueries(xQueriesAccess->getQueries());
2413*b1cdbd2cSJim Jagielski if (xQueries->hasByName(m_aCommand))
2414*b1cdbd2cSJim Jagielski {
2415*b1cdbd2cSJim Jagielski Reference< XPropertySet > xQuery(xQueries->getByName(m_aCommand),UNO_QUERY);
2416*b1cdbd2cSJim Jagielski OSL_ENSURE(xQuery.is(),"ORowSet::impl_buildActiveCommand_throw: Query is NULL!");
2417*b1cdbd2cSJim Jagielski if ( xQuery.is() )
2418*b1cdbd2cSJim Jagielski {
2419*b1cdbd2cSJim Jagielski xQuery->getPropertyValue(PROPERTY_COMMAND) >>= sCommand;
2420*b1cdbd2cSJim Jagielski xQuery->getPropertyValue(PROPERTY_ESCAPE_PROCESSING) >>= bDoEscapeProcessing;
2421*b1cdbd2cSJim Jagielski if ( bDoEscapeProcessing != m_bUseEscapeProcessing )
2422*b1cdbd2cSJim Jagielski {
2423*b1cdbd2cSJim Jagielski sal_Bool bOldValue = m_bUseEscapeProcessing;
2424*b1cdbd2cSJim Jagielski m_bUseEscapeProcessing = bDoEscapeProcessing;
2425*b1cdbd2cSJim Jagielski fireProperty(PROPERTY_ID_ESCAPE_PROCESSING,bOldValue,bDoEscapeProcessing);
2426*b1cdbd2cSJim Jagielski }
2427*b1cdbd2cSJim Jagielski
2428*b1cdbd2cSJim Jagielski ::rtl::OUString aCatalog,aSchema,aTable;
2429*b1cdbd2cSJim Jagielski xQuery->getPropertyValue(PROPERTY_UPDATE_CATALOGNAME) >>= aCatalog;
2430*b1cdbd2cSJim Jagielski xQuery->getPropertyValue(PROPERTY_UPDATE_SCHEMANAME) >>= aSchema;
2431*b1cdbd2cSJim Jagielski xQuery->getPropertyValue(PROPERTY_UPDATE_TABLENAME) >>= aTable;
2432*b1cdbd2cSJim Jagielski if(aTable.getLength())
2433*b1cdbd2cSJim Jagielski m_aUpdateTableName = composeTableName( m_xActiveConnection->getMetaData(), aCatalog, aSchema, aTable, sal_False, ::dbtools::eInDataManipulation );
2434*b1cdbd2cSJim Jagielski /*
2435*b1cdbd2cSJim Jagielski Reference<XColumnsSupplier> xSup(xQuery,UNO_QUERY);
2436*b1cdbd2cSJim Jagielski if(xSup.is())
2437*b1cdbd2cSJim Jagielski m_xColumns = xSup->getColumns();
2438*b1cdbd2cSJim Jagielski */
2439*b1cdbd2cSJim Jagielski }
2440*b1cdbd2cSJim Jagielski }
2441*b1cdbd2cSJim Jagielski else
2442*b1cdbd2cSJim Jagielski {
2443*b1cdbd2cSJim Jagielski String sMessage( DBACORE_RESSTRING( RID_STR_QUERY_DOES_NOT_EXIST ) );
2444*b1cdbd2cSJim Jagielski sMessage.SearchAndReplaceAscii( "$table$", m_aCommand );
2445*b1cdbd2cSJim Jagielski throwGenericSQLException(sMessage,*this);
2446*b1cdbd2cSJim Jagielski }
2447*b1cdbd2cSJim Jagielski }
2448*b1cdbd2cSJim Jagielski else
2449*b1cdbd2cSJim Jagielski throw SQLException(DBA_RES(RID_STR_NO_XQUERIESSUPPLIER),*this,::rtl::OUString(),0,Any());
2450*b1cdbd2cSJim Jagielski }
2451*b1cdbd2cSJim Jagielski break;
2452*b1cdbd2cSJim Jagielski
2453*b1cdbd2cSJim Jagielski default:
2454*b1cdbd2cSJim Jagielski sCommand = m_aCommand;
2455*b1cdbd2cSJim Jagielski break;
2456*b1cdbd2cSJim Jagielski }
2457*b1cdbd2cSJim Jagielski
2458*b1cdbd2cSJim Jagielski m_aActiveCommand = sCommand;
2459*b1cdbd2cSJim Jagielski
2460*b1cdbd2cSJim Jagielski if ( !m_aActiveCommand.getLength() && !bDoEscapeProcessing )
2461*b1cdbd2cSJim Jagielski ::dbtools::throwSQLException( DBACORE_RESSTRING( RID_STR_NO_SQL_COMMAND ), SQL_FUNCTION_SEQUENCE_ERROR, *this );
2462*b1cdbd2cSJim Jagielski
2463*b1cdbd2cSJim Jagielski return bDoEscapeProcessing;
2464*b1cdbd2cSJim Jagielski }
2465*b1cdbd2cSJim Jagielski
2466*b1cdbd2cSJim Jagielski //------------------------------------------------------------------------------
impl_initParametersContainer_nothrow()2467*b1cdbd2cSJim Jagielski void ORowSet::impl_initParametersContainer_nothrow()
2468*b1cdbd2cSJim Jagielski {
2469*b1cdbd2cSJim Jagielski OSL_PRECOND( !m_pParameters.is(), "ORowSet::impl_initParametersContainer_nothrow: already initialized the parameters!" );
2470*b1cdbd2cSJim Jagielski
2471*b1cdbd2cSJim Jagielski m_pParameters = new param::ParameterWrapperContainer( m_xComposer.get() );
2472*b1cdbd2cSJim Jagielski // copy the premature parameters into the final ones
2473*b1cdbd2cSJim Jagielski size_t nParamCount( ::std::min( m_pParameters->size(), m_aPrematureParamValues.get().size() ) );
2474*b1cdbd2cSJim Jagielski for ( size_t i=0; i<nParamCount; ++i )
2475*b1cdbd2cSJim Jagielski {
2476*b1cdbd2cSJim Jagielski (*m_pParameters)[i] = m_aPrematureParamValues.get()[i];
2477*b1cdbd2cSJim Jagielski }
2478*b1cdbd2cSJim Jagielski }
2479*b1cdbd2cSJim Jagielski
2480*b1cdbd2cSJim Jagielski //------------------------------------------------------------------------------
impl_disposeParametersContainer_nothrow()2481*b1cdbd2cSJim Jagielski void ORowSet::impl_disposeParametersContainer_nothrow()
2482*b1cdbd2cSJim Jagielski {
2483*b1cdbd2cSJim Jagielski if ( !m_pParameters.is() )
2484*b1cdbd2cSJim Jagielski return;
2485*b1cdbd2cSJim Jagielski
2486*b1cdbd2cSJim Jagielski // copy the actual values to our "premature" ones, to preserve them for later use
2487*b1cdbd2cSJim Jagielski size_t nParamCount( m_pParameters->size() );
2488*b1cdbd2cSJim Jagielski m_aPrematureParamValues.get().resize( nParamCount );
2489*b1cdbd2cSJim Jagielski for ( size_t i=0; i<nParamCount; ++i )
2490*b1cdbd2cSJim Jagielski {
2491*b1cdbd2cSJim Jagielski m_aPrematureParamValues.get()[i] = (*m_pParameters)[i];
2492*b1cdbd2cSJim Jagielski }
2493*b1cdbd2cSJim Jagielski
2494*b1cdbd2cSJim Jagielski m_pParameters->dispose();
2495*b1cdbd2cSJim Jagielski m_pParameters = NULL;
2496*b1cdbd2cSJim Jagielski }
2497*b1cdbd2cSJim Jagielski
2498*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
getParameterStorage(sal_Int32 parameterIndex)2499*b1cdbd2cSJim Jagielski ORowSetValue& ORowSet::getParameterStorage(sal_Int32 parameterIndex)
2500*b1cdbd2cSJim Jagielski {
2501*b1cdbd2cSJim Jagielski ::connectivity::checkDisposed( ORowSet_BASE1::rBHelper.bDisposed );
2502*b1cdbd2cSJim Jagielski if ( parameterIndex < 1 )
2503*b1cdbd2cSJim Jagielski throwInvalidIndexException( *this );
2504*b1cdbd2cSJim Jagielski
2505*b1cdbd2cSJim Jagielski if ( m_aParametersSet.size() < (size_t)parameterIndex )
2506*b1cdbd2cSJim Jagielski m_aParametersSet.resize( parameterIndex ,false);
2507*b1cdbd2cSJim Jagielski m_aParametersSet[parameterIndex - 1] = true;
2508*b1cdbd2cSJim Jagielski
2509*b1cdbd2cSJim Jagielski if ( m_aParametersSet.size() < (size_t)parameterIndex )
2510*b1cdbd2cSJim Jagielski m_aParametersSet.resize( parameterIndex ,false);
2511*b1cdbd2cSJim Jagielski m_aParametersSet[parameterIndex - 1] = true;
2512*b1cdbd2cSJim Jagielski
2513*b1cdbd2cSJim Jagielski if ( m_pParameters.is() )
2514*b1cdbd2cSJim Jagielski {
2515*b1cdbd2cSJim Jagielski if ( m_bCommandFacetsDirty )
2516*b1cdbd2cSJim Jagielski // need to rebuild the parameters, since some property which contributes to the
2517*b1cdbd2cSJim Jagielski // complete command, and thus the parameters, changed
2518*b1cdbd2cSJim Jagielski impl_disposeParametersContainer_nothrow();
2519*b1cdbd2cSJim Jagielski if ( m_pParameters.is() )
2520*b1cdbd2cSJim Jagielski {
2521*b1cdbd2cSJim Jagielski if ( (size_t)parameterIndex > m_pParameters->size() )
2522*b1cdbd2cSJim Jagielski throwInvalidIndexException( *this );
2523*b1cdbd2cSJim Jagielski return (*m_pParameters)[ parameterIndex - 1 ];
2524*b1cdbd2cSJim Jagielski }
2525*b1cdbd2cSJim Jagielski }
2526*b1cdbd2cSJim Jagielski
2527*b1cdbd2cSJim Jagielski if ( m_aPrematureParamValues.get().size() < (size_t)parameterIndex )
2528*b1cdbd2cSJim Jagielski m_aPrematureParamValues.get().resize( parameterIndex );
2529*b1cdbd2cSJim Jagielski return m_aPrematureParamValues.get()[ parameterIndex - 1 ];
2530*b1cdbd2cSJim Jagielski }
2531*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
2532*b1cdbd2cSJim Jagielski // XParameters
setNull(sal_Int32 parameterIndex,sal_Int32)2533*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::setNull( sal_Int32 parameterIndex, sal_Int32 /*sqlType*/ ) throw(SQLException, RuntimeException)
2534*b1cdbd2cSJim Jagielski {
2535*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aColumnsMutex );
2536*b1cdbd2cSJim Jagielski
2537*b1cdbd2cSJim Jagielski getParameterStorage( parameterIndex ).setNull();
2538*b1cdbd2cSJim Jagielski }
2539*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
setObjectNull(sal_Int32 parameterIndex,sal_Int32 sqlType,const::rtl::OUString &)2540*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::setObjectNull( sal_Int32 parameterIndex, sal_Int32 sqlType, const ::rtl::OUString& /*typeName*/ ) throw(SQLException, RuntimeException)
2541*b1cdbd2cSJim Jagielski {
2542*b1cdbd2cSJim Jagielski setNull( parameterIndex, sqlType );
2543*b1cdbd2cSJim Jagielski }
2544*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
setParameter(sal_Int32 parameterIndex,const ORowSetValue & x)2545*b1cdbd2cSJim Jagielski void ORowSet::setParameter(sal_Int32 parameterIndex, const ORowSetValue& x)
2546*b1cdbd2cSJim Jagielski {
2547*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aColumnsMutex );
2548*b1cdbd2cSJim Jagielski
2549*b1cdbd2cSJim Jagielski getParameterStorage( parameterIndex ) = x;
2550*b1cdbd2cSJim Jagielski }
2551*b1cdbd2cSJim Jagielski
2552*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
setBoolean(sal_Int32 parameterIndex,sal_Bool x)2553*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::setBoolean( sal_Int32 parameterIndex, sal_Bool x ) throw(SQLException, RuntimeException)
2554*b1cdbd2cSJim Jagielski {
2555*b1cdbd2cSJim Jagielski setParameter(parameterIndex,x);
2556*b1cdbd2cSJim Jagielski }
2557*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
setByte(sal_Int32 parameterIndex,sal_Int8 x)2558*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::setByte( sal_Int32 parameterIndex, sal_Int8 x ) throw(SQLException, RuntimeException)
2559*b1cdbd2cSJim Jagielski {
2560*b1cdbd2cSJim Jagielski setParameter(parameterIndex,x);
2561*b1cdbd2cSJim Jagielski }
2562*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
setShort(sal_Int32 parameterIndex,sal_Int16 x)2563*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::setShort( sal_Int32 parameterIndex, sal_Int16 x ) throw(SQLException, RuntimeException)
2564*b1cdbd2cSJim Jagielski {
2565*b1cdbd2cSJim Jagielski setParameter(parameterIndex,x);
2566*b1cdbd2cSJim Jagielski }
2567*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
setInt(sal_Int32 parameterIndex,sal_Int32 x)2568*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::setInt( sal_Int32 parameterIndex, sal_Int32 x ) throw(SQLException, RuntimeException)
2569*b1cdbd2cSJim Jagielski {
2570*b1cdbd2cSJim Jagielski setParameter(parameterIndex,x);
2571*b1cdbd2cSJim Jagielski }
2572*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
setLong(sal_Int32 parameterIndex,sal_Int64 x)2573*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::setLong( sal_Int32 parameterIndex, sal_Int64 x ) throw(SQLException, RuntimeException)
2574*b1cdbd2cSJim Jagielski {
2575*b1cdbd2cSJim Jagielski setParameter(parameterIndex,x);
2576*b1cdbd2cSJim Jagielski }
2577*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
setFloat(sal_Int32 parameterIndex,float x)2578*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::setFloat( sal_Int32 parameterIndex, float x ) throw(SQLException, RuntimeException)
2579*b1cdbd2cSJim Jagielski {
2580*b1cdbd2cSJim Jagielski setParameter(parameterIndex,x);
2581*b1cdbd2cSJim Jagielski }
2582*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
setDouble(sal_Int32 parameterIndex,double x)2583*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::setDouble( sal_Int32 parameterIndex, double x ) throw(SQLException, RuntimeException)
2584*b1cdbd2cSJim Jagielski {
2585*b1cdbd2cSJim Jagielski setParameter(parameterIndex,x);
2586*b1cdbd2cSJim Jagielski }
2587*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
setString(sal_Int32 parameterIndex,const::rtl::OUString & x)2588*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::setString( sal_Int32 parameterIndex, const ::rtl::OUString& x ) throw(SQLException, RuntimeException)
2589*b1cdbd2cSJim Jagielski {
2590*b1cdbd2cSJim Jagielski setParameter(parameterIndex,x);
2591*b1cdbd2cSJim Jagielski }
2592*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
setBytes(sal_Int32 parameterIndex,const Sequence<sal_Int8> & x)2593*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::setBytes( sal_Int32 parameterIndex, const Sequence< sal_Int8 >& x ) throw(SQLException, RuntimeException)
2594*b1cdbd2cSJim Jagielski {
2595*b1cdbd2cSJim Jagielski setParameter(parameterIndex,x);
2596*b1cdbd2cSJim Jagielski }
2597*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
setDate(sal_Int32 parameterIndex,const::com::sun::star::util::Date & x)2598*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::setDate( sal_Int32 parameterIndex, const ::com::sun::star::util::Date& x ) throw(SQLException, RuntimeException)
2599*b1cdbd2cSJim Jagielski {
2600*b1cdbd2cSJim Jagielski setParameter(parameterIndex,x);
2601*b1cdbd2cSJim Jagielski }
2602*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
setTime(sal_Int32 parameterIndex,const::com::sun::star::util::Time & x)2603*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::setTime( sal_Int32 parameterIndex, const ::com::sun::star::util::Time& x ) throw(SQLException, RuntimeException)
2604*b1cdbd2cSJim Jagielski {
2605*b1cdbd2cSJim Jagielski setParameter(parameterIndex,x);
2606*b1cdbd2cSJim Jagielski }
2607*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
setTimestamp(sal_Int32 parameterIndex,const::com::sun::star::util::DateTime & x)2608*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::setTimestamp( sal_Int32 parameterIndex, const ::com::sun::star::util::DateTime& x ) throw(SQLException, RuntimeException)
2609*b1cdbd2cSJim Jagielski {
2610*b1cdbd2cSJim Jagielski setParameter(parameterIndex,x);
2611*b1cdbd2cSJim Jagielski }
2612*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
setBinaryStream(sal_Int32 parameterIndex,const Reference<::com::sun::star::io::XInputStream> & x,sal_Int32 length)2613*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::setBinaryStream( sal_Int32 parameterIndex, const Reference< ::com::sun::star::io::XInputStream >& x, sal_Int32 length ) throw(SQLException, RuntimeException)
2614*b1cdbd2cSJim Jagielski {
2615*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aColumnsMutex );
2616*b1cdbd2cSJim Jagielski ORowSetValue& rParamValue( getParameterStorage( parameterIndex ) );
2617*b1cdbd2cSJim Jagielski
2618*b1cdbd2cSJim Jagielski try
2619*b1cdbd2cSJim Jagielski {
2620*b1cdbd2cSJim Jagielski Sequence <sal_Int8> aData;
2621*b1cdbd2cSJim Jagielski x->readBytes(aData, length);
2622*b1cdbd2cSJim Jagielski rParamValue = aData;
2623*b1cdbd2cSJim Jagielski x->closeInput();
2624*b1cdbd2cSJim Jagielski }
2625*b1cdbd2cSJim Jagielski catch( Exception& )
2626*b1cdbd2cSJim Jagielski {
2627*b1cdbd2cSJim Jagielski throw SQLException();
2628*b1cdbd2cSJim Jagielski }
2629*b1cdbd2cSJim Jagielski }
2630*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
setCharacterStream(sal_Int32 parameterIndex,const Reference<::com::sun::star::io::XInputStream> & x,sal_Int32 length)2631*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::setCharacterStream( sal_Int32 parameterIndex, const Reference< ::com::sun::star::io::XInputStream >& x, sal_Int32 length ) throw(SQLException, RuntimeException)
2632*b1cdbd2cSJim Jagielski {
2633*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aColumnsMutex );
2634*b1cdbd2cSJim Jagielski ORowSetValue& rParamValue( getParameterStorage( parameterIndex ) );
2635*b1cdbd2cSJim Jagielski try
2636*b1cdbd2cSJim Jagielski {
2637*b1cdbd2cSJim Jagielski Sequence <sal_Int8> aData;
2638*b1cdbd2cSJim Jagielski rtl::OUString aDataStr;
2639*b1cdbd2cSJim Jagielski // the data is given as character data and the length defines the character length
2640*b1cdbd2cSJim Jagielski sal_Int32 nSize = x->readBytes(aData, length * sizeof(sal_Unicode));
2641*b1cdbd2cSJim Jagielski if (nSize / sizeof(sal_Unicode))
2642*b1cdbd2cSJim Jagielski aDataStr = rtl::OUString((sal_Unicode*)aData.getConstArray(), nSize / sizeof(sal_Unicode));
2643*b1cdbd2cSJim Jagielski rParamValue = aDataStr;
2644*b1cdbd2cSJim Jagielski rParamValue.setTypeKind( DataType::LONGVARCHAR );
2645*b1cdbd2cSJim Jagielski x->closeInput();
2646*b1cdbd2cSJim Jagielski }
2647*b1cdbd2cSJim Jagielski catch( Exception& )
2648*b1cdbd2cSJim Jagielski {
2649*b1cdbd2cSJim Jagielski throw SQLException();
2650*b1cdbd2cSJim Jagielski }
2651*b1cdbd2cSJim Jagielski }
2652*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
setObject(sal_Int32 parameterIndex,const Any & x)2653*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::setObject( sal_Int32 parameterIndex, const Any& x ) throw(SQLException, RuntimeException)
2654*b1cdbd2cSJim Jagielski {
2655*b1cdbd2cSJim Jagielski if ( !::dbtools::implSetObject( this, parameterIndex, x ) )
2656*b1cdbd2cSJim Jagielski { // there is no other setXXX call which can handle the value in x
2657*b1cdbd2cSJim Jagielski throw SQLException();
2658*b1cdbd2cSJim Jagielski }
2659*b1cdbd2cSJim Jagielski }
2660*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
setObjectWithInfo(sal_Int32 parameterIndex,const Any & x,sal_Int32 targetSqlType,sal_Int32)2661*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::setObjectWithInfo( sal_Int32 parameterIndex, const Any& x, sal_Int32 targetSqlType, sal_Int32 /*scale*/ ) throw(SQLException, RuntimeException)
2662*b1cdbd2cSJim Jagielski {
2663*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aColumnsMutex );
2664*b1cdbd2cSJim Jagielski ORowSetValue& rParamValue( getParameterStorage( parameterIndex ) );
2665*b1cdbd2cSJim Jagielski setObject( parameterIndex, x );
2666*b1cdbd2cSJim Jagielski rParamValue.setTypeKind( targetSqlType );
2667*b1cdbd2cSJim Jagielski }
2668*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
setRef(sal_Int32,const Reference<XRef> &)2669*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::setRef( sal_Int32 /*parameterIndex*/, const Reference< XRef >& /*x*/ ) throw(SQLException, RuntimeException)
2670*b1cdbd2cSJim Jagielski {
2671*b1cdbd2cSJim Jagielski ::dbtools::throwFeatureNotImplementedException( "XParameters::setRef", *this );
2672*b1cdbd2cSJim Jagielski }
2673*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
setBlob(sal_Int32,const Reference<XBlob> &)2674*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::setBlob( sal_Int32 /*parameterIndex*/, const Reference< XBlob >& /*x*/ ) throw(SQLException, RuntimeException)
2675*b1cdbd2cSJim Jagielski {
2676*b1cdbd2cSJim Jagielski ::dbtools::throwFeatureNotImplementedException( "XParameters::setBlob", *this );
2677*b1cdbd2cSJim Jagielski }
2678*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
setClob(sal_Int32,const Reference<XClob> &)2679*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::setClob( sal_Int32 /*parameterIndex*/, const Reference< XClob >& /*x*/ ) throw(SQLException, RuntimeException)
2680*b1cdbd2cSJim Jagielski {
2681*b1cdbd2cSJim Jagielski ::dbtools::throwFeatureNotImplementedException( "XParameters::setClob", *this );
2682*b1cdbd2cSJim Jagielski }
2683*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
setArray(sal_Int32,const Reference<XArray> &)2684*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::setArray( sal_Int32 /*parameterIndex*/, const Reference< XArray >& /*x*/ ) throw(SQLException, RuntimeException)
2685*b1cdbd2cSJim Jagielski {
2686*b1cdbd2cSJim Jagielski ::dbtools::throwFeatureNotImplementedException( "XParameters::setArray", *this );
2687*b1cdbd2cSJim Jagielski }
2688*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
clearParameters()2689*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::clearParameters( ) throw(SQLException, RuntimeException)
2690*b1cdbd2cSJim Jagielski {
2691*b1cdbd2cSJim Jagielski ::connectivity::checkDisposed(ORowSet_BASE1::rBHelper.bDisposed);
2692*b1cdbd2cSJim Jagielski
2693*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aColumnsMutex );
2694*b1cdbd2cSJim Jagielski
2695*b1cdbd2cSJim Jagielski size_t nParamCount( m_pParameters.is() ? m_pParameters->size() : m_aPrematureParamValues.get().size() );
2696*b1cdbd2cSJim Jagielski for ( size_t i=1; i<=nParamCount; ++i )
2697*b1cdbd2cSJim Jagielski getParameterStorage( (sal_Int32)i ).setNull();
2698*b1cdbd2cSJim Jagielski m_aParametersSet.clear();
2699*b1cdbd2cSJim Jagielski }
2700*b1cdbd2cSJim Jagielski
2701*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
getWarnings()2702*b1cdbd2cSJim Jagielski Any SAL_CALL ORowSet::getWarnings( ) throw (SQLException, RuntimeException)
2703*b1cdbd2cSJim Jagielski {
2704*b1cdbd2cSJim Jagielski return m_aWarnings.getWarnings();
2705*b1cdbd2cSJim Jagielski }
2706*b1cdbd2cSJim Jagielski
2707*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
clearWarnings()2708*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::clearWarnings( ) throw (SQLException, RuntimeException)
2709*b1cdbd2cSJim Jagielski {
2710*b1cdbd2cSJim Jagielski m_aWarnings.clearWarnings();
2711*b1cdbd2cSJim Jagielski }
2712*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
doCancelModification()2713*b1cdbd2cSJim Jagielski void ORowSet::doCancelModification( )
2714*b1cdbd2cSJim Jagielski {
2715*b1cdbd2cSJim Jagielski //OSL_ENSURE( isModification(), "ORowSet::doCancelModification: invalid call (no cache!)!" );
2716*b1cdbd2cSJim Jagielski if ( isModification() )
2717*b1cdbd2cSJim Jagielski {
2718*b1cdbd2cSJim Jagielski // read-only flag restored
2719*b1cdbd2cSJim Jagielski impl_restoreDataColumnsWriteable_throw();
2720*b1cdbd2cSJim Jagielski m_pCache->cancelRowModification();
2721*b1cdbd2cSJim Jagielski }
2722*b1cdbd2cSJim Jagielski m_bModified = sal_False;
2723*b1cdbd2cSJim Jagielski m_bIsInsertRow = sal_False;
2724*b1cdbd2cSJim Jagielski }
2725*b1cdbd2cSJim Jagielski
2726*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
isModification()2727*b1cdbd2cSJim Jagielski sal_Bool ORowSet::isModification( )
2728*b1cdbd2cSJim Jagielski {
2729*b1cdbd2cSJim Jagielski return isNew();
2730*b1cdbd2cSJim Jagielski }
2731*b1cdbd2cSJim Jagielski
2732*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
isModified()2733*b1cdbd2cSJim Jagielski sal_Bool ORowSet::isModified( )
2734*b1cdbd2cSJim Jagielski {
2735*b1cdbd2cSJim Jagielski return m_bModified;
2736*b1cdbd2cSJim Jagielski }
2737*b1cdbd2cSJim Jagielski
2738*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
isNew()2739*b1cdbd2cSJim Jagielski sal_Bool ORowSet::isNew( )
2740*b1cdbd2cSJim Jagielski {
2741*b1cdbd2cSJim Jagielski return m_bNew;
2742*b1cdbd2cSJim Jagielski }
2743*b1cdbd2cSJim Jagielski
2744*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
checkUpdateIterator()2745*b1cdbd2cSJim Jagielski void ORowSet::checkUpdateIterator()
2746*b1cdbd2cSJim Jagielski {
2747*b1cdbd2cSJim Jagielski if(!m_bIsInsertRow)
2748*b1cdbd2cSJim Jagielski {
2749*b1cdbd2cSJim Jagielski m_pCache->setUpdateIterator(m_aCurrentRow);
2750*b1cdbd2cSJim Jagielski m_aCurrentRow = m_pCache->m_aInsertRow;
2751*b1cdbd2cSJim Jagielski m_bIsInsertRow = sal_True;
2752*b1cdbd2cSJim Jagielski }
2753*b1cdbd2cSJim Jagielski }
2754*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
checkUpdateConditions(sal_Int32 columnIndex)2755*b1cdbd2cSJim Jagielski void ORowSet::checkUpdateConditions(sal_Int32 columnIndex)
2756*b1cdbd2cSJim Jagielski {
2757*b1cdbd2cSJim Jagielski checkCache();
2758*b1cdbd2cSJim Jagielski if ( m_nResultSetConcurrency == ResultSetConcurrency::READ_ONLY)
2759*b1cdbd2cSJim Jagielski ::dbtools::throwSQLException( DBACORE_RESSTRING( RID_STR_RESULT_IS_READONLY ), SQL_GENERAL_ERROR, *this );
2760*b1cdbd2cSJim Jagielski
2761*b1cdbd2cSJim Jagielski if ( rowDeleted() )
2762*b1cdbd2cSJim Jagielski ::dbtools::throwSQLException( DBACORE_RESSTRING( RID_STR_ROW_ALREADY_DELETED ), SQL_INVALID_CURSOR_POSITION, *this );
2763*b1cdbd2cSJim Jagielski
2764*b1cdbd2cSJim Jagielski if ( m_aCurrentRow.isNull() )
2765*b1cdbd2cSJim Jagielski ::dbtools::throwSQLException( DBACORE_RESSTRING( RID_STR_INVALID_CURSOR_STATE ), SQL_INVALID_CURSOR_STATE, *this );
2766*b1cdbd2cSJim Jagielski
2767*b1cdbd2cSJim Jagielski if ( columnIndex <= 0 || sal_Int32((*m_aCurrentRow)->get().size()) <= columnIndex )
2768*b1cdbd2cSJim Jagielski ::dbtools::throwSQLException( DBACORE_RESSTRING( RID_STR_INVALID_INDEX ), SQL_INVALID_DESCRIPTOR_INDEX, *this );
2769*b1cdbd2cSJim Jagielski }
2770*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
refreshRow()2771*b1cdbd2cSJim Jagielski void SAL_CALL ORowSet::refreshRow( ) throw(SQLException, RuntimeException)
2772*b1cdbd2cSJim Jagielski {
2773*b1cdbd2cSJim Jagielski
2774*b1cdbd2cSJim Jagielski ORowSetNotifier aNotifier( this );
2775*b1cdbd2cSJim Jagielski // this will call cancelRowModification on the cache if necessary
2776*b1cdbd2cSJim Jagielski
2777*b1cdbd2cSJim Jagielski // notification order:
2778*b1cdbd2cSJim Jagielski if ( m_bModified && m_pCache )
2779*b1cdbd2cSJim Jagielski implCancelRowUpdates( sal_False ); // do _not_ notify the IsModify - will do this ourself below
2780*b1cdbd2cSJim Jagielski
2781*b1cdbd2cSJim Jagielski // - column values
2782*b1cdbd2cSJim Jagielski ORowSetBase::refreshRow();
2783*b1cdbd2cSJim Jagielski
2784*b1cdbd2cSJim Jagielski // - IsModified
2785*b1cdbd2cSJim Jagielski // - IsNew
2786*b1cdbd2cSJim Jagielski aNotifier.fire( );
2787*b1cdbd2cSJim Jagielski }
2788*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
impl_rebuild_throw(::osl::ResettableMutexGuard & _rGuard)2789*b1cdbd2cSJim Jagielski void ORowSet::impl_rebuild_throw(::osl::ResettableMutexGuard& _rGuard)
2790*b1cdbd2cSJim Jagielski {
2791*b1cdbd2cSJim Jagielski Reference< XResultSet > xResultSet( m_xStatement->executeQuery() );
2792*b1cdbd2cSJim Jagielski m_aWarnings.setExternalWarnings( Reference< XWarningsSupplier >( xResultSet, UNO_QUERY ) );
2793*b1cdbd2cSJim Jagielski m_pCache->reset(xResultSet);
2794*b1cdbd2cSJim Jagielski notifyAllListeners(_rGuard);
2795*b1cdbd2cSJim Jagielski }
2796*b1cdbd2cSJim Jagielski // ***********************************************************
2797*b1cdbd2cSJim Jagielski // ORowSetClone
2798*b1cdbd2cSJim Jagielski // ***********************************************************
2799*b1cdbd2cSJim Jagielski DBG_NAME(ORowSetClone);
2800*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
ORowSetClone(const::comphelper::ComponentContext & _rContext,ORowSet & rParent,::osl::Mutex * _pMutex)2801*b1cdbd2cSJim Jagielski ORowSetClone::ORowSetClone( const ::comphelper::ComponentContext& _rContext, ORowSet& rParent, ::osl::Mutex* _pMutex )
2802*b1cdbd2cSJim Jagielski :OSubComponent(m_aMutex, rParent)
2803*b1cdbd2cSJim Jagielski ,ORowSetBase( _rContext, OComponentHelper::rBHelper, _pMutex )
2804*b1cdbd2cSJim Jagielski ,m_pParent(&rParent)
2805*b1cdbd2cSJim Jagielski ,m_nFetchDirection(rParent.m_nFetchDirection)
2806*b1cdbd2cSJim Jagielski ,m_nFetchSize(rParent.m_nFetchSize)
2807*b1cdbd2cSJim Jagielski ,m_bIsBookmarable(sal_True)
2808*b1cdbd2cSJim Jagielski {
2809*b1cdbd2cSJim Jagielski DBG_CTOR(ORowSetClone, NULL);
2810*b1cdbd2cSJim Jagielski
2811*b1cdbd2cSJim Jagielski m_nResultSetType = rParent.m_nResultSetType;
2812*b1cdbd2cSJim Jagielski m_nResultSetConcurrency = ResultSetConcurrency::READ_ONLY;
2813*b1cdbd2cSJim Jagielski m_pMySelf = this;
2814*b1cdbd2cSJim Jagielski m_bClone = sal_True;
2815*b1cdbd2cSJim Jagielski m_bBeforeFirst = rParent.m_bBeforeFirst;
2816*b1cdbd2cSJim Jagielski m_bAfterLast = rParent.m_bAfterLast;
2817*b1cdbd2cSJim Jagielski m_pCache = rParent.m_pCache;
2818*b1cdbd2cSJim Jagielski m_aBookmark = rParent.m_aBookmark;
2819*b1cdbd2cSJim Jagielski m_aCurrentRow = m_pCache->createIterator(this);
2820*b1cdbd2cSJim Jagielski m_xNumberFormatTypes = rParent.m_xNumberFormatTypes;
2821*b1cdbd2cSJim Jagielski
2822*b1cdbd2cSJim Jagielski m_aOldRow = m_pCache->registerOldRow();
2823*b1cdbd2cSJim Jagielski
2824*b1cdbd2cSJim Jagielski ::vos::ORef< ::connectivity::OSQLColumns> aColumns = new ::connectivity::OSQLColumns();
2825*b1cdbd2cSJim Jagielski ::std::vector< ::rtl::OUString> aNames;
2826*b1cdbd2cSJim Jagielski
2827*b1cdbd2cSJim Jagielski ::rtl::OUString aDescription;
2828*b1cdbd2cSJim Jagielski // ConfigManager* pConfigMgr = ConfigManager::GetConfigManager();
2829*b1cdbd2cSJim Jagielski // Locale aLocale;
2830*b1cdbd2cSJim Jagielski // pConfigMgr->GetDirectConfigProperty(ConfigManager::LOCALE) >>= aLocale;
2831*b1cdbd2cSJim Jagielski Locale aLocale = SvtSysLocale().GetLocaleData().getLocale();
2832*b1cdbd2cSJim Jagielski
2833*b1cdbd2cSJim Jagielski if ( rParent.m_pColumns )
2834*b1cdbd2cSJim Jagielski {
2835*b1cdbd2cSJim Jagielski Sequence< ::rtl::OUString> aSeq = rParent.m_pColumns->getElementNames();
2836*b1cdbd2cSJim Jagielski const ::rtl::OUString* pIter = aSeq.getConstArray();
2837*b1cdbd2cSJim Jagielski const ::rtl::OUString* pEnd = pIter + aSeq.getLength();
2838*b1cdbd2cSJim Jagielski aColumns->get().reserve(aSeq.getLength()+1);
2839*b1cdbd2cSJim Jagielski for(sal_Int32 i=1;pIter != pEnd ;++pIter,++i)
2840*b1cdbd2cSJim Jagielski {
2841*b1cdbd2cSJim Jagielski Reference<XPropertySet> xColumn;
2842*b1cdbd2cSJim Jagielski rParent.m_pColumns->getByName(*pIter) >>= xColumn;
2843*b1cdbd2cSJim Jagielski if(xColumn->getPropertySetInfo()->hasPropertyByName(PROPERTY_DESCRIPTION))
2844*b1cdbd2cSJim Jagielski aDescription = comphelper::getString(xColumn->getPropertyValue(PROPERTY_DESCRIPTION));
2845*b1cdbd2cSJim Jagielski
2846*b1cdbd2cSJim Jagielski ::rtl::OUString sParseLabel;
2847*b1cdbd2cSJim Jagielski xColumn->getPropertyValue(PROPERTY_LABEL) >>= sParseLabel;
2848*b1cdbd2cSJim Jagielski ORowSetColumn* pColumn = new ORowSetColumn( rParent.getMetaData(),
2849*b1cdbd2cSJim Jagielski this,
2850*b1cdbd2cSJim Jagielski i,
2851*b1cdbd2cSJim Jagielski rParent.m_xActiveConnection->getMetaData(),
2852*b1cdbd2cSJim Jagielski aDescription,
2853*b1cdbd2cSJim Jagielski sParseLabel,
2854*b1cdbd2cSJim Jagielski m_aCurrentRow);
2855*b1cdbd2cSJim Jagielski aColumns->get().push_back(pColumn);
2856*b1cdbd2cSJim Jagielski pColumn->setName(*pIter);
2857*b1cdbd2cSJim Jagielski aNames.push_back(*pIter);
2858*b1cdbd2cSJim Jagielski m_aDataColumns.push_back(pColumn);
2859*b1cdbd2cSJim Jagielski
2860*b1cdbd2cSJim Jagielski pColumn->setFastPropertyValue_NoBroadcast(PROPERTY_ID_ALIGN,xColumn->getPropertyValue(PROPERTY_ALIGN));
2861*b1cdbd2cSJim Jagielski sal_Int32 nFormatKey = 0;
2862*b1cdbd2cSJim Jagielski xColumn->getPropertyValue(PROPERTY_NUMBERFORMAT) >>= nFormatKey;
2863*b1cdbd2cSJim Jagielski if(!nFormatKey && xColumn.is() && m_xNumberFormatTypes.is())
2864*b1cdbd2cSJim Jagielski nFormatKey = ::dbtools::getDefaultNumberFormat(xColumn,m_xNumberFormatTypes,aLocale);
2865*b1cdbd2cSJim Jagielski pColumn->setFastPropertyValue_NoBroadcast(PROPERTY_ID_NUMBERFORMAT,makeAny(nFormatKey));
2866*b1cdbd2cSJim Jagielski pColumn->setFastPropertyValue_NoBroadcast(PROPERTY_ID_RELATIVEPOSITION,xColumn->getPropertyValue(PROPERTY_RELATIVEPOSITION));
2867*b1cdbd2cSJim Jagielski pColumn->setFastPropertyValue_NoBroadcast(PROPERTY_ID_WIDTH,xColumn->getPropertyValue(PROPERTY_WIDTH));
2868*b1cdbd2cSJim Jagielski pColumn->setFastPropertyValue_NoBroadcast(PROPERTY_ID_HIDDEN,xColumn->getPropertyValue(PROPERTY_HIDDEN));
2869*b1cdbd2cSJim Jagielski pColumn->setFastPropertyValue_NoBroadcast(PROPERTY_ID_CONTROLMODEL,xColumn->getPropertyValue(PROPERTY_CONTROLMODEL));
2870*b1cdbd2cSJim Jagielski pColumn->setFastPropertyValue_NoBroadcast(PROPERTY_ID_HELPTEXT,xColumn->getPropertyValue(PROPERTY_HELPTEXT));
2871*b1cdbd2cSJim Jagielski pColumn->setFastPropertyValue_NoBroadcast(PROPERTY_ID_CONTROLDEFAULT,xColumn->getPropertyValue(PROPERTY_CONTROLDEFAULT));
2872*b1cdbd2cSJim Jagielski
2873*b1cdbd2cSJim Jagielski } // for(sal_Int32 i=1;pIter != pEnd ;++pIter,++i)
2874*b1cdbd2cSJim Jagielski }
2875*b1cdbd2cSJim Jagielski Reference<XDatabaseMetaData> xMeta = rParent.m_xActiveConnection->getMetaData();
2876*b1cdbd2cSJim Jagielski m_pColumns = new ORowSetDataColumns(xMeta.is() && xMeta->supportsMixedCaseQuotedIdentifiers(),
2877*b1cdbd2cSJim Jagielski aColumns,*this,m_aMutex,aNames);
2878*b1cdbd2cSJim Jagielski
2879*b1cdbd2cSJim Jagielski sal_Int32 nRT = PropertyAttribute::READONLY | PropertyAttribute::TRANSIENT;
2880*b1cdbd2cSJim Jagielski
2881*b1cdbd2cSJim Jagielski // sdb.RowSet Properties
2882*b1cdbd2cSJim Jagielski // registerProperty(PROPERTY_CURSORNAME, PROPERTY_ID_CURSORNAME, PropertyAttribute::READONLY, &m_aDataSourceName, ::getCppuType(reinterpret_cast< ::rtl::OUString*>(NULL)));
2883*b1cdbd2cSJim Jagielski registerMayBeVoidProperty(PROPERTY_ACTIVE_CONNECTION,PROPERTY_ID_ACTIVE_CONNECTION, PropertyAttribute::MAYBEVOID|PropertyAttribute::READONLY, &rParent.m_aActiveConnection, ::getCppuType(reinterpret_cast< Reference< XConnection >* >(NULL)));
2884*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_RESULTSETCONCURRENCY, PROPERTY_ID_RESULTSETCONCURRENCY, PropertyAttribute::READONLY, &m_nResultSetConcurrency,::getCppuType(reinterpret_cast< sal_Int32*>(NULL)));
2885*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_RESULTSETTYPE, PROPERTY_ID_RESULTSETTYPE, PropertyAttribute::READONLY, &m_nResultSetType, ::getCppuType(reinterpret_cast< sal_Int32*>(NULL)));
2886*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_FETCHDIRECTION, PROPERTY_ID_FETCHDIRECTION, PropertyAttribute::TRANSIENT, &m_nFetchDirection, ::getCppuType(reinterpret_cast< sal_Int32*>(NULL)));
2887*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_FETCHSIZE, PROPERTY_ID_FETCHSIZE, PropertyAttribute::TRANSIENT, &m_nFetchSize, ::getCppuType(reinterpret_cast< sal_Int32*>(NULL)));
2888*b1cdbd2cSJim Jagielski registerProperty(PROPERTY_ISBOOKMARKABLE, PROPERTY_ID_ISBOOKMARKABLE, nRT, &m_bIsBookmarable, ::getBooleanCppuType());
2889*b1cdbd2cSJim Jagielski }
2890*b1cdbd2cSJim Jagielski
2891*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
~ORowSetClone()2892*b1cdbd2cSJim Jagielski ORowSetClone::~ORowSetClone()
2893*b1cdbd2cSJim Jagielski {
2894*b1cdbd2cSJim Jagielski DBG_DTOR(ORowSetClone, NULL);
2895*b1cdbd2cSJim Jagielski }
2896*b1cdbd2cSJim Jagielski // com::sun::star::XTypeProvider
2897*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
getTypes()2898*b1cdbd2cSJim Jagielski Sequence< Type > ORowSetClone::getTypes() throw (RuntimeException)
2899*b1cdbd2cSJim Jagielski {
2900*b1cdbd2cSJim Jagielski return ::comphelper::concatSequences(OSubComponent::getTypes(),ORowSetBase::getTypes());
2901*b1cdbd2cSJim Jagielski }
2902*b1cdbd2cSJim Jagielski // com::sun::star::XInterface
2903*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
queryInterface(const Type & rType)2904*b1cdbd2cSJim Jagielski Any ORowSetClone::queryInterface( const Type & rType ) throw (RuntimeException)
2905*b1cdbd2cSJim Jagielski {
2906*b1cdbd2cSJim Jagielski Any aRet = ORowSetBase::queryInterface(rType);
2907*b1cdbd2cSJim Jagielski if(!aRet.hasValue())
2908*b1cdbd2cSJim Jagielski aRet = OSubComponent::queryInterface(rType);
2909*b1cdbd2cSJim Jagielski return aRet;
2910*b1cdbd2cSJim Jagielski }
2911*b1cdbd2cSJim Jagielski //------------------------------------------------------------------------------
acquire()2912*b1cdbd2cSJim Jagielski void ORowSetClone::acquire() throw()
2913*b1cdbd2cSJim Jagielski {
2914*b1cdbd2cSJim Jagielski OSubComponent::acquire();
2915*b1cdbd2cSJim Jagielski }
2916*b1cdbd2cSJim Jagielski
2917*b1cdbd2cSJim Jagielski //------------------------------------------------------------------------------
release()2918*b1cdbd2cSJim Jagielski void ORowSetClone::release() throw()
2919*b1cdbd2cSJim Jagielski {
2920*b1cdbd2cSJim Jagielski OSubComponent::release();
2921*b1cdbd2cSJim Jagielski }
2922*b1cdbd2cSJim Jagielski
2923*b1cdbd2cSJim Jagielski // XServiceInfo
2924*b1cdbd2cSJim Jagielski //------------------------------------------------------------------------------
getImplementationName()2925*b1cdbd2cSJim Jagielski rtl::OUString ORowSetClone::getImplementationName( ) throw(RuntimeException)
2926*b1cdbd2cSJim Jagielski {
2927*b1cdbd2cSJim Jagielski return rtl::OUString::createFromAscii("com.sun.star.sdb.ORowSetClone");
2928*b1cdbd2cSJim Jagielski }
2929*b1cdbd2cSJim Jagielski
2930*b1cdbd2cSJim Jagielski //------------------------------------------------------------------------------
supportsService(const::rtl::OUString & _rServiceName)2931*b1cdbd2cSJim Jagielski sal_Bool ORowSetClone::supportsService( const ::rtl::OUString& _rServiceName ) throw (RuntimeException)
2932*b1cdbd2cSJim Jagielski {
2933*b1cdbd2cSJim Jagielski return ::comphelper::findValue(getSupportedServiceNames(), _rServiceName, sal_True).getLength() != 0;
2934*b1cdbd2cSJim Jagielski }
2935*b1cdbd2cSJim Jagielski
2936*b1cdbd2cSJim Jagielski //------------------------------------------------------------------------------
getSupportedServiceNames()2937*b1cdbd2cSJim Jagielski Sequence< ::rtl::OUString > ORowSetClone::getSupportedServiceNames( ) throw (RuntimeException)
2938*b1cdbd2cSJim Jagielski {
2939*b1cdbd2cSJim Jagielski Sequence< ::rtl::OUString > aSNS( 2 );
2940*b1cdbd2cSJim Jagielski aSNS[0] = SERVICE_SDBC_RESULTSET;
2941*b1cdbd2cSJim Jagielski aSNS[1] = SERVICE_SDB_RESULTSET;
2942*b1cdbd2cSJim Jagielski return aSNS;
2943*b1cdbd2cSJim Jagielski }
2944*b1cdbd2cSJim Jagielski
2945*b1cdbd2cSJim Jagielski // OComponentHelper
2946*b1cdbd2cSJim Jagielski //------------------------------------------------------------------------------
disposing()2947*b1cdbd2cSJim Jagielski void ORowSetClone::disposing()
2948*b1cdbd2cSJim Jagielski {
2949*b1cdbd2cSJim Jagielski MutexGuard aGuard( m_aMutex );
2950*b1cdbd2cSJim Jagielski ORowSetBase::disposing();
2951*b1cdbd2cSJim Jagielski
2952*b1cdbd2cSJim Jagielski m_pParent = NULL;
2953*b1cdbd2cSJim Jagielski m_pMutex = &m_aMutex; // this must be done here because someone could hold a ref to us and try to do something
2954*b1cdbd2cSJim Jagielski OSubComponent::disposing();
2955*b1cdbd2cSJim Jagielski }
2956*b1cdbd2cSJim Jagielski
2957*b1cdbd2cSJim Jagielski // XCloseable
2958*b1cdbd2cSJim Jagielski //------------------------------------------------------------------------------
close(void)2959*b1cdbd2cSJim Jagielski void ORowSetClone::close(void) throw( SQLException, RuntimeException )
2960*b1cdbd2cSJim Jagielski {
2961*b1cdbd2cSJim Jagielski {
2962*b1cdbd2cSJim Jagielski MutexGuard aGuard( m_aMutex );
2963*b1cdbd2cSJim Jagielski if (OComponentHelper::rBHelper.bDisposed)
2964*b1cdbd2cSJim Jagielski throw DisposedException();
2965*b1cdbd2cSJim Jagielski }
2966*b1cdbd2cSJim Jagielski dispose();
2967*b1cdbd2cSJim Jagielski }
2968*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
2969*b1cdbd2cSJim Jagielski
2970*b1cdbd2cSJim Jagielski // comphelper::OPropertyArrayUsageHelper
createArrayHelper() const2971*b1cdbd2cSJim Jagielski ::cppu::IPropertyArrayHelper* ORowSetClone::createArrayHelper( ) const
2972*b1cdbd2cSJim Jagielski {
2973*b1cdbd2cSJim Jagielski Sequence< Property > aProps;
2974*b1cdbd2cSJim Jagielski describeProperties(aProps);
2975*b1cdbd2cSJim Jagielski return new ::cppu::OPropertyArrayHelper(aProps);
2976*b1cdbd2cSJim Jagielski }
2977*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
2978*b1cdbd2cSJim Jagielski
2979*b1cdbd2cSJim Jagielski // cppu::OPropertySetHelper
getInfoHelper()2980*b1cdbd2cSJim Jagielski ::cppu::IPropertyArrayHelper& SAL_CALL ORowSetClone::getInfoHelper()
2981*b1cdbd2cSJim Jagielski {
2982*b1cdbd2cSJim Jagielski typedef ::comphelper::OPropertyArrayUsageHelper<ORowSetClone> ORowSetClone_PROP;
2983*b1cdbd2cSJim Jagielski return *ORowSetClone_PROP::getArrayHelper();
2984*b1cdbd2cSJim Jagielski }
2985*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
2986*b1cdbd2cSJim Jagielski //--------------------------------------------------------------------------
getUnoTunnelImplementationId()2987*b1cdbd2cSJim Jagielski Sequence< sal_Int8 > ORowSetClone::getUnoTunnelImplementationId()
2988*b1cdbd2cSJim Jagielski {
2989*b1cdbd2cSJim Jagielski static ::cppu::OImplementationId * pId = 0;
2990*b1cdbd2cSJim Jagielski if (! pId)
2991*b1cdbd2cSJim Jagielski {
2992*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( ::osl::Mutex::getGlobalMutex() );
2993*b1cdbd2cSJim Jagielski if (! pId)
2994*b1cdbd2cSJim Jagielski {
2995*b1cdbd2cSJim Jagielski static ::cppu::OImplementationId aId;
2996*b1cdbd2cSJim Jagielski pId = &aId;
2997*b1cdbd2cSJim Jagielski }
2998*b1cdbd2cSJim Jagielski }
2999*b1cdbd2cSJim Jagielski return pId->getImplementationId();
3000*b1cdbd2cSJim Jagielski }
3001*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
3002*b1cdbd2cSJim Jagielski // com::sun::star::XUnoTunnel
getSomething(const Sequence<sal_Int8> & rId)3003*b1cdbd2cSJim Jagielski sal_Int64 SAL_CALL ORowSetClone::getSomething( const Sequence< sal_Int8 >& rId ) throw(RuntimeException)
3004*b1cdbd2cSJim Jagielski {
3005*b1cdbd2cSJim Jagielski if (rId.getLength() == 16 && 0 == rtl_compareMemory(getUnoTunnelImplementationId().getConstArray(), rId.getConstArray(), 16 ) )
3006*b1cdbd2cSJim Jagielski return reinterpret_cast<sal_Int64>(this);
3007*b1cdbd2cSJim Jagielski
3008*b1cdbd2cSJim Jagielski return 0;
3009*b1cdbd2cSJim Jagielski }
3010*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
setFastPropertyValue_NoBroadcast(sal_Int32 nHandle,const Any & rValue)3011*b1cdbd2cSJim Jagielski void SAL_CALL ORowSetClone::setFastPropertyValue_NoBroadcast(sal_Int32 nHandle,const Any& rValue) throw (Exception)
3012*b1cdbd2cSJim Jagielski {
3013*b1cdbd2cSJim Jagielski if ( nHandle == PROPERTY_ID_FETCHSIZE )
3014*b1cdbd2cSJim Jagielski {
3015*b1cdbd2cSJim Jagielski if ( m_pParent )
3016*b1cdbd2cSJim Jagielski m_pParent->setFastPropertyValue_NoBroadcast( nHandle, rValue );
3017*b1cdbd2cSJim Jagielski }
3018*b1cdbd2cSJim Jagielski
3019*b1cdbd2cSJim Jagielski OPropertyStateContainer::setFastPropertyValue_NoBroadcast(nHandle,rValue);
3020*b1cdbd2cSJim Jagielski }
3021*b1cdbd2cSJim Jagielski
3022*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
doCancelModification()3023*b1cdbd2cSJim Jagielski void ORowSetClone::doCancelModification( )
3024*b1cdbd2cSJim Jagielski {
3025*b1cdbd2cSJim Jagielski //OSL_ENSURE( sal_False, "ORowSetClone::doCancelModification: invalid call!" );
3026*b1cdbd2cSJim Jagielski }
3027*b1cdbd2cSJim Jagielski
3028*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
isModification()3029*b1cdbd2cSJim Jagielski sal_Bool ORowSetClone::isModification( )
3030*b1cdbd2cSJim Jagielski {
3031*b1cdbd2cSJim Jagielski return sal_False;
3032*b1cdbd2cSJim Jagielski }
3033*b1cdbd2cSJim Jagielski
3034*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
isModified()3035*b1cdbd2cSJim Jagielski sal_Bool ORowSetClone::isModified( )
3036*b1cdbd2cSJim Jagielski {
3037*b1cdbd2cSJim Jagielski return sal_False;
3038*b1cdbd2cSJim Jagielski }
3039*b1cdbd2cSJim Jagielski
3040*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
isNew()3041*b1cdbd2cSJim Jagielski sal_Bool ORowSetClone::isNew( )
3042*b1cdbd2cSJim Jagielski {
3043*b1cdbd2cSJim Jagielski return sal_False;
3044*b1cdbd2cSJim Jagielski }
3045*b1cdbd2cSJim Jagielski
3046*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
execute()3047*b1cdbd2cSJim Jagielski void SAL_CALL ORowSetClone::execute( ) throw(SQLException, RuntimeException)
3048*b1cdbd2cSJim Jagielski {
3049*b1cdbd2cSJim Jagielski throwFunctionNotSupportedException( "RowSetClone::XRowSet::execute", *this );
3050*b1cdbd2cSJim Jagielski }
3051*b1cdbd2cSJim Jagielski
3052*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
addRowSetListener(const Reference<XRowSetListener> &)3053*b1cdbd2cSJim Jagielski void SAL_CALL ORowSetClone::addRowSetListener( const Reference< XRowSetListener >& ) throw(RuntimeException)
3054*b1cdbd2cSJim Jagielski {
3055*b1cdbd2cSJim Jagielski throwFunctionNotSupportedException( "RowSetClone::XRowSet", *this );
3056*b1cdbd2cSJim Jagielski }
3057*b1cdbd2cSJim Jagielski
3058*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
removeRowSetListener(const Reference<XRowSetListener> &)3059*b1cdbd2cSJim Jagielski void SAL_CALL ORowSetClone::removeRowSetListener( const Reference< XRowSetListener >& ) throw(RuntimeException)
3060*b1cdbd2cSJim Jagielski {
3061*b1cdbd2cSJim Jagielski throwFunctionNotSupportedException( "RowSetClone::XRowSet", *this );
3062*b1cdbd2cSJim Jagielski }
3063*b1cdbd2cSJim Jagielski
3064*b1cdbd2cSJim Jagielski } // dbaccess
3065