1 /**************************************************************
2  *
3  * Licensed to the Apache Software Foundation (ASF) under one
4  * or more contributor license agreements.  See the NOTICE file
5  * distributed with this work for additional information
6  * regarding copyright ownership.  The ASF licenses this file
7  * to you under the Apache License, Version 2.0 (the
8  * "License"); you may not use this file except in compliance
9  * with the License.  You may obtain a copy of the License at
10  *
11  *   http://www.apache.org/licenses/LICENSE-2.0
12  *
13  * Unless required by applicable law or agreed to in writing,
14  * software distributed under the License is distributed on an
15  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16  * KIND, either express or implied.  See the License for the
17  * specific language governing permissions and limitations
18  * under the License.
19  *
20  *************************************************************/
21 
22 
23 
24 // MARKER(update_precomp.py): autogen include statement, do not remove
25 #include "precompiled_dbaccess.hxx"
26 
27 #include "connection.hxx"
28 #include "dbastrings.hrc"
29 #include "datasource.hxx"
30 #include "core_resource.hrc"
31 #include "core_resource.hxx"
32 #include "statement.hxx"
33 #include "preparedstatement.hxx"
34 #include "callablestatement.hxx"
35 #include "ContainerMediator.hxx"
36 #include "SingleSelectQueryComposer.hxx"
37 #include "querycomposer.hxx"
38 #include "sdbcoretools.hxx"
39 
40 /** === begin UNO includes === **/
41 #include <com/sun/star/sdb/CommandType.hpp>
42 #include <com/sun/star/sdbc/XDriverAccess.hpp>
43 #include <com/sun/star/sdbcx/XDataDefinitionSupplier.hpp>
44 #include <com/sun/star/reflection/XProxyFactory.hpp>
45 #include <com/sun/star/beans/NamedValue.hpp>
46 /** === end UNO includes === **/
47 #include <connectivity/dbtools.hxx>
48 #include <connectivity/dbmetadata.hxx>
49 #include <connectivity/dbexception.hxx>
50 #include <tools/debug.hxx>
51 #include <tools/diagnose_ex.h>
52 #include <comphelper/extract.hxx>
53 #include <comphelper/uno3.hxx>
54 #include <comphelper/sequence.hxx>
55 #include <cppuhelper/typeprovider.hxx>
56 #include <rtl/logfile.hxx>
57 #include "SharedConnection.hxx"
58 
59 using namespace ::com::sun::star::uno;
60 using namespace ::com::sun::star::lang;
61 using namespace ::com::sun::star::util;
62 using namespace ::com::sun::star::sdb;
63 using namespace ::com::sun::star::sdb::application;
64 using namespace ::com::sun::star::sdbc;
65 using namespace ::com::sun::star::sdbcx;
66 using namespace ::com::sun::star::beans;
67 using namespace ::com::sun::star::reflection;
68 using namespace ::com::sun::star::container;
69 using namespace ::com::sun::star::graphic;
70 using namespace ::osl;
71 using namespace ::comphelper;
72 using namespace ::cppu;
73 using namespace ::dbtools;
74 
75 using ::com::sun::star::sdb::tools::XTableName;
76 using ::com::sun::star::sdb::tools::XObjectNames;
77 using ::com::sun::star::sdb::tools::XDataSourceMetaData;
78 
79 //........................................................................
80 namespace dbaccess
81 {
82 //........................................................................
83 #ifdef IMPLEMENT_GET_IMPLEMENTATION_ID
84 	IMPLEMENT_GET_IMPLEMENTATION_ID( OSharedConnection );
85 #endif
86 
87 //==========================================================================
88 // XServiceInfo
89 //------------------------------------------------------------------------------
getImplementationName()90 rtl::OUString OConnection::getImplementationName(  ) throw(RuntimeException)
91 {
92     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::getImplementationName" );
93 	return rtl::OUString::createFromAscii("com.sun.star.comp.dbaccess.Connection");
94 }
95 //------------------------------------------------------------------------------
supportsService(const::rtl::OUString & _rServiceName)96 sal_Bool OConnection::supportsService( const ::rtl::OUString& _rServiceName ) throw (RuntimeException)
97 {
98     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::supportsService" );
99 	return findValue(getSupportedServiceNames(), _rServiceName, sal_True).getLength() != 0;
100 }
101 
102 //------------------------------------------------------------------------------
getSupportedServiceNames()103 Sequence< ::rtl::OUString > OConnection::getSupportedServiceNames(  ) throw (RuntimeException)
104 {
105     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::getSupportedServiceNames" );
106 	Sequence< ::rtl::OUString > aSupported = OConnectionWrapper::getSupportedServiceNames();
107 
108 	if ( 0 == findValue( aSupported, SERVICE_SDB_CONNECTION, sal_True ).getLength() )
109 	{
110 		sal_Int32 nLen = aSupported.getLength();
111 		aSupported.realloc( nLen + 1 );
112 		aSupported[ nLen ] = SERVICE_SDB_CONNECTION;
113 	}
114 
115 	return aSupported;
116 }
117 
118 // XCloseable
119 //------------------------------------------------------------------------------
close(void)120 void OConnection::close(void) throw( SQLException, RuntimeException )
121 {
122     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::close" );
123 	// being closed is the same as being disposed
124 	dispose();
125 }
126 
127 //------------------------------------------------------------------------------
isClosed(void)128 sal_Bool OConnection::isClosed(void) throw( SQLException, RuntimeException )
129 {
130     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::isClosed" );
131 	MutexGuard aGuard(m_aMutex);
132 	return !m_xMasterConnection.is();
133 }
134 
135 // XConnection
136 //------------------------------------------------------------------------------
createStatement(void)137 Reference< XStatement >  OConnection::createStatement(void) throw( SQLException, RuntimeException )
138 {
139     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::createStatement" );
140 	MutexGuard aGuard(m_aMutex);
141 	checkDisposed();
142 
143 	Reference< XStatement > xStatement;
144 	Reference< XStatement > xMasterStatement = m_xMasterConnection->createStatement();
145 	if ( xMasterStatement.is() )
146 	{
147 		xStatement = new OStatement(this, xMasterStatement);
148 		m_aStatements.push_back(WeakReferenceHelper(xStatement));
149 	}
150 	return xStatement;
151 }
152 //------------------------------------------------------------------------------
prepareStatement(const rtl::OUString & sql)153 Reference< XPreparedStatement >  OConnection::prepareStatement(const rtl::OUString& sql) throw( SQLException, RuntimeException )
154 {
155     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::prepareStatement" );
156 	MutexGuard aGuard(m_aMutex);
157 	checkDisposed();
158 
159 	// TODO convert the SQL to SQL the driver understands
160 	Reference< XPreparedStatement > xStatement;
161 	Reference< XPreparedStatement > xMasterStatement = m_xMasterConnection->prepareStatement(sql);
162 	if ( xMasterStatement.is() )
163 	{
164 		xStatement = new OPreparedStatement(this, xMasterStatement);
165 		m_aStatements.push_back(WeakReferenceHelper(xStatement));
166 	}
167 	return xStatement;
168 }
169 
170 //------------------------------------------------------------------------------
prepareCall(const rtl::OUString & sql)171 Reference< XPreparedStatement >  OConnection::prepareCall(const rtl::OUString& sql) throw( SQLException, RuntimeException )
172 {
173     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::prepareCall" );
174 	MutexGuard aGuard(m_aMutex);
175 	checkDisposed();
176 
177 	Reference< XPreparedStatement > xStatement;
178 	Reference< XPreparedStatement > xMasterStatement = m_xMasterConnection->prepareCall(sql);
179 	if ( xMasterStatement.is() )
180 	{
181 		xStatement = new OCallableStatement(this, xMasterStatement);
182 		m_aStatements.push_back(WeakReferenceHelper(xStatement));
183 	}
184 	return xStatement;
185 }
186 
187 //------------------------------------------------------------------------------
nativeSQL(const rtl::OUString & sql)188 rtl::OUString OConnection::nativeSQL(const rtl::OUString& sql) throw( SQLException, RuntimeException )
189 {
190     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::nativeSQL" );
191 	MutexGuard aGuard(m_aMutex);
192 	checkDisposed();
193 	return m_xMasterConnection->nativeSQL(sql);
194 }
195 
196 //------------------------------------------------------------------------------
setAutoCommit(sal_Bool autoCommit)197 void OConnection::setAutoCommit(sal_Bool autoCommit) throw( SQLException, RuntimeException )
198 {
199     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::setAutoCommit" );
200 	MutexGuard aGuard(m_aMutex);
201 	checkDisposed();
202 	m_xMasterConnection->setAutoCommit(autoCommit);
203 }
204 
205 //------------------------------------------------------------------------------
getAutoCommit(void)206 sal_Bool OConnection::getAutoCommit(void) throw( SQLException, RuntimeException )
207 {
208     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::getAutoCommit" );
209 	MutexGuard aGuard(m_aMutex);
210 	checkDisposed();
211 	return m_xMasterConnection->getAutoCommit();
212 }
213 
214 //------------------------------------------------------------------------------
commit(void)215 void OConnection::commit(void) throw( SQLException, RuntimeException )
216 {
217     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::commit" );
218 	MutexGuard aGuard(m_aMutex);
219 	checkDisposed();
220 	m_xMasterConnection->commit();
221 }
222 
223 //------------------------------------------------------------------------------
rollback(void)224 void OConnection::rollback(void) throw( SQLException, RuntimeException )
225 {
226     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::rollback" );
227 	MutexGuard aGuard(m_aMutex);
228 	checkDisposed();
229 	m_xMasterConnection->rollback();
230 }
231 
232 //------------------------------------------------------------------------------
getMetaData(void)233 Reference< XDatabaseMetaData >  OConnection::getMetaData(void) throw( SQLException, RuntimeException )
234 {
235     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::getMetaData" );
236 	MutexGuard aGuard(m_aMutex);
237 	checkDisposed();
238 	return m_xMasterConnection->getMetaData();
239 }
240 
241 //------------------------------------------------------------------------------
setReadOnly(sal_Bool readOnly)242 void OConnection::setReadOnly(sal_Bool readOnly) throw( SQLException, RuntimeException )
243 {
244     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::setReadOnly" );
245 	MutexGuard aGuard(m_aMutex);
246 	checkDisposed();
247 	m_xMasterConnection->setReadOnly(readOnly);
248 }
249 
250 //------------------------------------------------------------------------------
isReadOnly(void)251 sal_Bool OConnection::isReadOnly(void) throw( SQLException, RuntimeException )
252 {
253     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::isReadOnly" );
254 	MutexGuard aGuard(m_aMutex);
255 	checkDisposed();
256 	return m_xMasterConnection->isReadOnly();
257 }
258 
259 //------------------------------------------------------------------------------
setCatalog(const rtl::OUString & catalog)260 void OConnection::setCatalog(const rtl::OUString& catalog) throw( SQLException, RuntimeException )
261 {
262     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::setCatalog" );
263 	MutexGuard aGuard(m_aMutex);
264 	checkDisposed();
265 	m_xMasterConnection->setCatalog(catalog);
266 }
267 
268 //------------------------------------------------------------------------------
getCatalog(void)269 rtl::OUString OConnection::getCatalog(void) throw( SQLException, RuntimeException )
270 {
271     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::getCatalog" );
272 	MutexGuard aGuard(m_aMutex);
273 	checkDisposed();
274 	return m_xMasterConnection->getCatalog();
275 }
276 
277 //------------------------------------------------------------------------------
setTransactionIsolation(sal_Int32 level)278 void OConnection::setTransactionIsolation(sal_Int32 level) throw( SQLException, RuntimeException )
279 {
280     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::setTransactionIsolation" );
281 	MutexGuard aGuard(m_aMutex);
282 	checkDisposed();
283 	m_xMasterConnection->setTransactionIsolation(level);
284 }
285 
286 //------------------------------------------------------------------------------
getTransactionIsolation(void)287 sal_Int32 OConnection::getTransactionIsolation(void) throw( SQLException, RuntimeException )
288 {
289     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::getTransactionIsolation" );
290 	MutexGuard aGuard(m_aMutex);
291 	checkDisposed();
292 	return m_xMasterConnection->getTransactionIsolation();
293 }
294 
295 //------------------------------------------------------------------------------
getTypeMap(void)296 Reference< XNameAccess >  OConnection::getTypeMap(void) throw( SQLException, RuntimeException )
297 {
298     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::getTypeMap" );
299 	MutexGuard aGuard(m_aMutex);
300 	checkDisposed();
301 	return m_xMasterConnection->getTypeMap();
302 }
303 
304 //------------------------------------------------------------------------------
setTypeMap(const Reference<XNameAccess> & typeMap)305 void OConnection::setTypeMap(const Reference< XNameAccess > & typeMap) throw( SQLException, RuntimeException )
306 {
307     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::setTypeMap" );
308 	MutexGuard aGuard(m_aMutex);
309 	checkDisposed();
310 	m_xMasterConnection->setTypeMap(typeMap);
311 }
312 //==========================================================================
313 //= OConnection
314 //==========================================================================
DBG_NAME(OConnection)315 DBG_NAME(OConnection)
316 //--------------------------------------------------------------------------
317 OConnection::OConnection(ODatabaseSource& _rDB
318 						 , Reference< XConnection >& _rxMaster
319 						 , const Reference< XMultiServiceFactory >& _rxORB)
320 			:OSubComponent(m_aMutex, static_cast< OWeakObject* >(&_rDB))
321 				// as the queries reroute their refcounting to us, this m_aMutex is okey. If the queries
322 				// container would do it's own refcounting, it would have to acquire m_pMutex
323 				// same for tables
324 			,m_aTableFilter(_rDB.m_pImpl->m_aTableFilter)
325 			,m_aTableTypeFilter(_rDB.m_pImpl->m_aTableTypeFilter)
326 			,m_aContext( _rxORB )
327 			,m_xMasterConnection(_rxMaster)
328 			,m_pTables(NULL)
329 			,m_pViews(NULL)
330             ,m_aWarnings( Reference< XWarningsSupplier >( _rxMaster, UNO_QUERY ) )
331             ,m_nInAppend(0)
332 			,m_bSupportsViews(sal_False)
333 			,m_bSupportsUsers(sal_False)
334 			,m_bSupportsGroups(sal_False)
335 {
336     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::OConnection" );
337 	DBG_CTOR(OConnection,NULL);
338 	osl_incrementInterlockedCount(&m_refCount);
339 
340 	try
341 	{
342 		Reference< XProxyFactory > xProxyFactory(
343 				_rxORB->createInstance(::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("com.sun.star.reflection.ProxyFactory"))),UNO_QUERY);
344 		Reference<XAggregation> xAgg = xProxyFactory->createProxy(_rxMaster.get());
345 		setDelegation(xAgg,m_refCount);
346 		DBG_ASSERT(m_xConnection.is(), "OConnection::OConnection : invalid master connection !");
347 	}
348 	catch(const Exception&)
349 	{
350         DBG_UNHANDLED_EXCEPTION();
351 	}
352 
353     m_xTableUIProvider = m_xTableUIProvider.query( m_xMasterConnection );
354 
355 	try
356 	{
357 		m_xQueries = new OQueryContainer(Reference< XNameContainer >(_rDB.getQueryDefinitions( ),UNO_QUERY), this,_rxORB, &m_aWarnings);
358 
359 		sal_Bool bCase = sal_True;
360 		Reference<XDatabaseMetaData> xMeta;
361 		try
362 		{
363 			xMeta = getMetaData();
364 			bCase = xMeta.is() && xMeta->supportsMixedCaseQuotedIdentifiers();
365 		}
366 		catch(SQLException&)
367 		{
368 		}
369 		Reference< XNameContainer > xTableDefinitions(_rDB.getTables(),UNO_QUERY);
370 		m_pTables = new OTableContainer( *this, m_aMutex, this, bCase, xTableDefinitions, this, &m_aWarnings,m_nInAppend );
371 
372 		// check if we supports types
373 		if ( xMeta.is() )
374 		{
375 			Reference<XResultSet> xRes = xMeta->getTableTypes();
376 			if(xRes.is())
377 			{
378 				::rtl::OUString sView(RTL_CONSTASCII_USTRINGPARAM("VIEW"));
379 				Reference<XRow> xRow(xRes,UNO_QUERY);
380 				while(xRes->next())
381 				{
382 					::rtl::OUString sValue = xRow->getString(1);
383 					if( !xRow->wasNull() && sValue == sView)
384 					{
385 						m_bSupportsViews = sal_True;
386 						break;
387 					}
388 				}
389 			}
390 			// some dbs don't support this type so we should ask if a XViewsSupplier is supported
391 			if(!m_bSupportsViews)
392 			{
393 				Reference< XViewsSupplier > xMaster(getMasterTables(),UNO_QUERY);
394 
395 				if (xMaster.is() && xMaster->getViews().is())
396 					m_bSupportsViews = sal_True;
397 			}
398 			if(m_bSupportsViews)
399 			{
400 				m_pViews = new OViewContainer(*this, m_aMutex, this, bCase,this,&m_aWarnings,m_nInAppend);
401 				m_pViews->addContainerListener(m_pTables);
402 				m_pTables->addContainerListener(m_pViews);
403 			}
404 			m_bSupportsUsers = Reference< XUsersSupplier> (getMasterTables(),UNO_QUERY).is();
405 			m_bSupportsGroups = Reference< XGroupsSupplier> (getMasterTables(),UNO_QUERY).is();
406 
407             impl_checkTableQueryNames_nothrow();
408 		}
409 	}
410 	catch(const Exception& )
411 	{
412         DBG_UNHANDLED_EXCEPTION();
413 	}
414 	osl_decrementInterlockedCount( &m_refCount );
415 }
416 
417 //--------------------------------------------------------------------------
~OConnection()418 OConnection::~OConnection()
419 {
420 	delete m_pTables;
421 	delete m_pViews;
422 	DBG_DTOR(OConnection,NULL);
423 }
424 
425 
426 // XWarningsSupplier
427 //--------------------------------------------------------------------------
getWarnings()428 Any SAL_CALL OConnection::getWarnings() throw(SQLException, RuntimeException)
429 {
430     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::getWarnings" );
431 	MutexGuard aGuard(m_aMutex);
432 	checkDisposed();
433     return m_aWarnings.getWarnings();
434 }
435 
436 //--------------------------------------------------------------------------
clearWarnings()437 void SAL_CALL OConnection::clearWarnings(  ) throw(SQLException, RuntimeException)
438 {
439     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::clearWarnings" );
440 	MutexGuard aGuard(m_aMutex);
441 	checkDisposed();
442     m_aWarnings.clearWarnings();
443 }
444 
445 //--------------------------------------------------------------------------
446 namespace
447 {
448     struct CompareTypeByName : public ::std::binary_function< Type, Type, bool >
449     {
operator ()dbaccess::__anon20fe79c20111::CompareTypeByName450         bool operator() ( const Type& _rLHS, const Type& _rRHS ) const
451         {
452             return _rLHS.getTypeName() < _rRHS.getTypeName();
453         }
454     };
455     typedef ::std::set< Type, CompareTypeByName > TypeBag;
456 
lcl_copyTypes(TypeBag & _out_rTypes,const Sequence<Type> & _rTypes)457     void lcl_copyTypes( TypeBag& _out_rTypes, const Sequence< Type >& _rTypes )
458     {
459         ::std::copy( _rTypes.getConstArray(), _rTypes.getConstArray() + _rTypes.getLength(),
460             ::std::insert_iterator< TypeBag >( _out_rTypes, _out_rTypes.begin() ) );
461     }
462 }
463 // com::sun::star::lang::XTypeProvider
464 //--------------------------------------------------------------------------
getTypes()465 Sequence< Type > OConnection::getTypes() throw (RuntimeException)
466 {
467     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::getTypes" );
468     TypeBag aNormalizedTypes;
469 
470     lcl_copyTypes( aNormalizedTypes, OSubComponent::getTypes() );
471     lcl_copyTypes( aNormalizedTypes, OConnection_Base::getTypes() );
472     lcl_copyTypes( aNormalizedTypes, ::connectivity::OConnectionWrapper::getTypes() );
473 
474     if ( !m_bSupportsViews )
475         aNormalizedTypes.erase( XViewsSupplier::static_type() );
476     if ( !m_bSupportsUsers )
477         aNormalizedTypes.erase( XUsersSupplier::static_type() );
478     if ( !m_bSupportsGroups )
479         aNormalizedTypes.erase( XGroupsSupplier::static_type() );
480 
481     Sequence< Type > aSupportedTypes( aNormalizedTypes.size() );
482     ::std::copy( aNormalizedTypes.begin(), aNormalizedTypes.end(), aSupportedTypes.getArray() );
483 	return aSupportedTypes;
484 }
485 
486 //--------------------------------------------------------------------------
getImplementationId()487 Sequence< sal_Int8 > OConnection::getImplementationId() throw (RuntimeException)
488 {
489     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::getImplementationId" );
490 	return getUnoTunnelImplementationId();
491 }
492 
493 // com::sun::star::uno::XInterface
494 //--------------------------------------------------------------------------
queryInterface(const Type & rType)495 Any OConnection::queryInterface( const Type & rType ) throw (RuntimeException)
496 {
497     if ( !m_bSupportsViews && rType.equals( XViewsSupplier::static_type() ) )
498 		return Any();
499 	else if ( !m_bSupportsUsers && rType.equals( XUsersSupplier::static_type() ) )
500 		return Any();
501 	else if ( !m_bSupportsGroups && rType.equals( XGroupsSupplier::static_type() ) )
502 		return Any();
503 	Any aReturn = OSubComponent::queryInterface( rType );
504 	if (!aReturn.hasValue())
505 	{
506 		aReturn = OConnection_Base::queryInterface( rType );
507 		if (!aReturn.hasValue())
508 			aReturn = OConnectionWrapper::queryInterface( rType );
509 	}
510 	return aReturn;
511 }
512 
513 //--------------------------------------------------------------------------
acquire()514 void OConnection::acquire() throw ()
515 {
516     // include this one when you want to see who calls it (call graph)
517     //RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::acquire" );
518 	OSubComponent::acquire();
519 }
520 
521 //--------------------------------------------------------------------------
release()522 void OConnection::release() throw ()
523 {
524     // include this one when you want to see who calls it (call graph)
525     //RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::release" );
526 	OSubComponent::release();
527 }
528 
529 // OSubComponent
530 //------------------------------------------------------------------------------
disposing()531 void OConnection::disposing()
532 {
533     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::disposing" );
534 	MutexGuard aGuard(m_aMutex);
535 
536 	OSubComponent::disposing();
537 	OConnectionWrapper::disposing();
538 
539     OWeakRefArrayIterator aEnd = m_aStatements.end();
540 	for (OWeakRefArrayIterator i = m_aStatements.begin(); aEnd != i; ++i)
541 	{
542 		Reference<XComponent> xComp(i->get(),UNO_QUERY);
543 		::comphelper::disposeComponent(xComp);
544 	}
545 	m_aStatements.clear();
546 	m_xMasterTables = NULL;
547 
548 	if(m_pTables)
549 		m_pTables->dispose();
550 	if(m_pViews)
551 		m_pViews->dispose();
552 
553 	::comphelper::disposeComponent(m_xQueries);
554 
555     OWeakRefArrayIterator aComposerEnd = m_aComposers.end();
556 	for (OWeakRefArrayIterator j = m_aComposers.begin(); aComposerEnd != j; ++j)
557 	{
558 		Reference<XComponent> xComp(j->get(),UNO_QUERY);
559 		::comphelper::disposeComponent(xComp);
560 	}
561 
562 	m_aComposers.clear();
563 
564 	try
565 	{
566 		if (m_xMasterConnection.is())
567 			m_xMasterConnection->close();
568 	}
569 	catch(Exception)
570 	{
571 	}
572 	m_xMasterConnection = NULL;
573 }
574 
575 // XChild
576 //------------------------------------------------------------------------------
getParent(void)577 Reference< XInterface >  OConnection::getParent(void) throw( RuntimeException )
578 {
579     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::getParent" );
580 	MutexGuard aGuard(m_aMutex);
581 	checkDisposed();
582 	return m_xParent;
583 }
584 
585 //------------------------------------------------------------------------------
setParent(const Reference<XInterface> &)586 void OConnection::setParent(const Reference< XInterface > & /*Parent*/) throw( NoSupportException, RuntimeException )
587 {
588     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::setParent" );
589 	throw NoSupportException();
590 }
591 
592 // XSQLQueryComposerFactory
593 //------------------------------------------------------------------------------
createQueryComposer(void)594 Reference< XSQLQueryComposer >  OConnection::createQueryComposer(void) throw( RuntimeException )
595 {
596     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::createQueryComposer" );
597 	MutexGuard aGuard(m_aMutex);
598 	checkDisposed();
599 
600 	//	Reference< XNumberFormatsSupplier >  xSupplier = pParent->getNumberFormatsSupplier();
601 	Reference< XSQLQueryComposer >  xComposer( new OQueryComposer( this ) );
602 	m_aComposers.push_back(WeakReferenceHelper(xComposer));
603 	return xComposer;
604 }
605 // -----------------------------------------------------------------------------
impl_fillTableFilter()606 void OConnection::impl_fillTableFilter()
607 {
608     Reference<XPropertySet> xProp(getParent(),UNO_QUERY);
609     if ( xProp.is() )
610     {
611         xProp->getPropertyValue(PROPERTY_TABLEFILTER)       >>= m_aTableFilter;
612         xProp->getPropertyValue(PROPERTY_TABLETYPEFILTER)   >>= m_aTableTypeFilter;
613     }
614 }
615 
616 // -----------------------------------------------------------------------------
refresh(const Reference<XNameAccess> & _rToBeRefreshed)617 void OConnection::refresh(const Reference< XNameAccess >& _rToBeRefreshed)
618 {
619     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::refresh" );
620 	if ( _rToBeRefreshed == Reference< XNameAccess >(m_pTables) )
621 	{
622 		if (m_pTables && !m_pTables->isInitialized())
623 		{
624             impl_fillTableFilter();
625 			// check if our "master connection" can supply tables
626 			getMasterTables();
627 
628 			if (m_xMasterTables.is() && m_xMasterTables->getTables().is())
629 			{	// yes -> wrap them
630 				m_pTables->construct(m_xMasterTables->getTables(),m_aTableFilter, m_aTableTypeFilter);
631 			}
632 			else
633 			{	// no -> use an own container
634 				m_pTables->construct(m_aTableFilter, m_aTableTypeFilter);
635 			}
636 		}
637 	}
638 	else if ( _rToBeRefreshed == Reference< XNameAccess >(m_pViews) )
639 	{
640 		if (m_pViews && !m_pViews->isInitialized())
641 		{
642             impl_fillTableFilter();
643 			// check if our "master connection" can supply tables
644 			Reference< XViewsSupplier > xMaster(getMasterTables(),UNO_QUERY);
645 
646 			if (xMaster.is() && xMaster->getViews().is())
647 				m_pViews->construct(xMaster->getViews(),m_aTableFilter, m_aTableTypeFilter);
648 			else
649 				m_pViews->construct(m_aTableFilter, m_aTableTypeFilter);
650 		}
651 	}
652 }
653 // -----------------------------------------------------------------------------
654 
655 // XTablesSupplier
656 //------------------------------------------------------------------------------
getTables()657 Reference< XNameAccess >  OConnection::getTables() throw( RuntimeException )
658 {
659     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::getTables" );
660 	MutexGuard aGuard(m_aMutex);
661 	checkDisposed();
662 
663 	refresh(m_pTables);
664 
665 	return m_pTables;
666 }
667 // -----------------------------------------------------------------------------
getViews()668 Reference< XNameAccess > SAL_CALL OConnection::getViews(  ) throw(RuntimeException)
669 {
670     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::getViews" );
671 	MutexGuard aGuard(m_aMutex);
672 	checkDisposed();
673 
674 	refresh(m_pViews);
675 
676 	return m_pViews;
677 }
678 // XQueriesSupplier
679 //------------------------------------------------------------------------------
getQueries(void)680 Reference< XNameAccess >  OConnection::getQueries(void) throw( RuntimeException )
681 {
682     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::getQueries" );
683 	MutexGuard aGuard(m_aMutex);
684 	checkDisposed();
685 
686 	return m_xQueries;
687 }
688 
689 // ::com::sun::star::sdb::XCommandPreparation
690 //------------------------------------------------------------------------------
prepareCommand(const::rtl::OUString & command,sal_Int32 commandType)691 Reference< XPreparedStatement >  SAL_CALL OConnection::prepareCommand( const ::rtl::OUString& command, sal_Int32 commandType ) throw(::com::sun::star::sdbc::SQLException, RuntimeException)
692 {
693     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::prepareCommand" );
694 	MutexGuard aGuard(m_aMutex);
695 	checkDisposed();
696 
697 	rtl::OUString aStatement;
698 	switch (commandType)
699 	{
700 		case CommandType::TABLE:
701 			{
702 				aStatement = ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("SELECT * FROM "));
703 
704                 ::rtl::OUString sCatalog, sSchema, sTable;
705                 ::dbtools::qualifiedNameComponents( getMetaData(), command, sCatalog, sSchema, sTable, ::dbtools::eInDataManipulation );
706                 aStatement += ::dbtools::composeTableNameForSelect( this, sCatalog, sSchema, sTable );
707 			}
708 			break;
709 		case CommandType::QUERY:
710 			if ( m_xQueries->hasByName(command) )
711 			{
712 				Reference< XPropertySet > xQuery(m_xQueries->getByName(command),UNO_QUERY);
713 				xQuery->getPropertyValue(PROPERTY_COMMAND) >>= aStatement;
714 			}
715 			break;
716 		default:
717 			aStatement = command;
718 	}
719 	// TODO EscapeProcessing
720 	return prepareStatement(aStatement);
721 }
722 // -----------------------------------------------------------------------------
createInstance(const::rtl::OUString & _sServiceSpecifier)723 Reference< XInterface > SAL_CALL OConnection::createInstance( const ::rtl::OUString& _sServiceSpecifier ) throw (Exception, RuntimeException)
724 {
725     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::createInstance" );
726 	Reference< XServiceInfo > xRet;
727 	if  (  ( SERVICE_NAME_SINGLESELECTQUERYCOMPOSER == _sServiceSpecifier )
728         || ( _sServiceSpecifier.equalsAscii( "com.sun.star.sdb.SingleSelectQueryAnalyzer" ) )
729         )
730 	{
731 		xRet = new OSingleSelectQueryComposer( getTables(),this, m_aContext );
732 		m_aComposers.push_back(WeakReferenceHelper(xRet));
733 	}
734     else
735     {
736         if ( _sServiceSpecifier.getLength() )
737         {
738             TSupportServices::iterator aFind = m_aSupportServices.find(_sServiceSpecifier);
739             if ( aFind == m_aSupportServices.end() )
740             {
741                 Sequence<Any> aArgs(1);
742                 Reference<XConnection> xMy(this);
743                 aArgs[0] <<= NamedValue(::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("ActiveConnection")),makeAny(xMy));
744                 aFind = m_aSupportServices.insert(TSupportServices::value_type(_sServiceSpecifier,m_aContext.createComponentWithArguments(_sServiceSpecifier,aArgs))).first;
745             }
746             return aFind->second;
747         }
748     }
749 	return Reference< XInterface >(xRet,UNO_QUERY);
750 }
751 // -----------------------------------------------------------------------------
createInstanceWithArguments(const::rtl::OUString & _sServiceSpecifier,const Sequence<Any> &)752 Reference< XInterface > SAL_CALL OConnection::createInstanceWithArguments( const ::rtl::OUString& _sServiceSpecifier, const Sequence< Any >& /*Arguments*/ ) throw (Exception, RuntimeException)
753 {
754     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::createInstanceWithArguments" );
755 	return createInstance(_sServiceSpecifier);
756 }
757 // -----------------------------------------------------------------------------
getAvailableServiceNames()758 Sequence< ::rtl::OUString > SAL_CALL OConnection::getAvailableServiceNames(  ) throw (RuntimeException)
759 {
760     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::getAvailableServiceNames" );
761 	Sequence< ::rtl::OUString > aRet(1);
762 	aRet[0] = SERVICE_NAME_SINGLESELECTQUERYCOMPOSER;
763 	return aRet;
764 }
765 // -----------------------------------------------------------------------------
getMasterTables()766 Reference< XTablesSupplier > OConnection::getMasterTables()
767 {
768     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::getMasterTables" );
769 // check if out "master connection" can supply tables
770 	if(!m_xMasterTables.is())
771 	{
772 		try
773 		{
774 			Reference<XDatabaseMetaData> xMeta = getMetaData();
775 			if ( xMeta.is() )
776 				m_xMasterTables = ::dbtools::getDataDefinitionByURLAndConnection( xMeta->getURL(), m_xMasterConnection, m_aContext.getLegacyServiceFactory() );
777 		}
778 		catch(SQLException&)
779 		{
780 		}
781 	}
782 	return m_xMasterTables;
783 }
784 // -----------------------------------------------------------------------------
785 // XUsersSupplier
getUsers()786 Reference< XNameAccess > SAL_CALL OConnection::getUsers(  ) throw(RuntimeException)
787 {
788     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::getUsers" );
789 	MutexGuard aGuard(m_aMutex);
790 	checkDisposed();
791 
792 	Reference<XUsersSupplier> xUsr(getMasterTables(),UNO_QUERY);
793 	return xUsr.is() ? xUsr->getUsers() : Reference< XNameAccess >();
794 }
795 // -----------------------------------------------------------------------------
796 // XGroupsSupplier
getGroups()797 Reference< XNameAccess > SAL_CALL OConnection::getGroups(  ) throw(RuntimeException)
798 {
799     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::getGroups" );
800 	MutexGuard aGuard(m_aMutex);
801 	checkDisposed();
802 	Reference<XGroupsSupplier> xGrp(getMasterTables(),UNO_QUERY);
803 	return xGrp.is() ? xGrp->getGroups() : Reference< XNameAccess >();
804 }
805 
806 // -----------------------------------------------------------------------------
impl_loadConnectionTools_throw()807 void OConnection::impl_loadConnectionTools_throw()
808 {
809     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::impl_loadConnectionTools_throw" );
810     Sequence< Any > aArguments( 1 );
811     aArguments[0] <<= NamedValue( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( "Connection" ) ), makeAny( Reference< XConnection >( this ) ) );
812 
813     if ( !m_aContext.createComponentWithArguments( "com.sun.star.sdb.tools.ConnectionTools", aArguments, m_xConnectionTools ) )
814         throw RuntimeException( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( "service not registered: com.sun.star.sdb.tools.ConnectionTools" ) ), *this );
815 }
816 
817 // -----------------------------------------------------------------------------
createTableName()818 Reference< XTableName > SAL_CALL OConnection::createTableName(  ) throw (RuntimeException)
819 {
820     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::createTableName" );
821 	MutexGuard aGuard(m_aMutex);
822 	checkDisposed();
823     impl_loadConnectionTools_throw();
824 
825     return m_xConnectionTools->createTableName();
826 }
827 
828 // -----------------------------------------------------------------------------
getObjectNames()829 Reference< XObjectNames > SAL_CALL OConnection::getObjectNames(  ) throw (RuntimeException)
830 {
831     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::getObjectNames" );
832 	MutexGuard aGuard(m_aMutex);
833 	checkDisposed();
834     impl_loadConnectionTools_throw();
835 
836     return m_xConnectionTools->getObjectNames();
837 }
838 
839 // -----------------------------------------------------------------------------
getDataSourceMetaData()840 Reference< XDataSourceMetaData > SAL_CALL OConnection::getDataSourceMetaData(  ) throw (RuntimeException)
841 {
842     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::getDataSourceMetaData" );
843 	MutexGuard aGuard(m_aMutex);
844 	checkDisposed();
845     impl_loadConnectionTools_throw();
846 
847     return m_xConnectionTools->getDataSourceMetaData();
848 }
849 // -----------------------------------------------------------------------------
getFieldsByCommandDescriptor(::sal_Int32 commandType,const::rtl::OUString & command,::com::sun::star::uno::Reference<::com::sun::star::lang::XComponent> & keepFieldsAlive)850 Reference< ::com::sun::star::container::XNameAccess > SAL_CALL OConnection::getFieldsByCommandDescriptor( ::sal_Int32 commandType, const ::rtl::OUString& command, ::com::sun::star::uno::Reference< ::com::sun::star::lang::XComponent >& keepFieldsAlive ) throw (::com::sun::star::sdbc::SQLException, RuntimeException)
851 {
852     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::getFieldsByCommandDescriptor" );
853 	MutexGuard aGuard(m_aMutex);
854 	checkDisposed();
855     impl_loadConnectionTools_throw();
856 
857     return m_xConnectionTools->getFieldsByCommandDescriptor(commandType,command,keepFieldsAlive);
858 }
859 //--------------------------------------------------------------------
getComposer(::sal_Int32 commandType,const::rtl::OUString & command)860 Reference< XSingleSelectQueryComposer > SAL_CALL OConnection::getComposer( ::sal_Int32 commandType, const ::rtl::OUString& command ) throw (::com::sun::star::uno::RuntimeException)
861 {
862     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::getComposer" );
863     MutexGuard aGuard(m_aMutex);
864 	checkDisposed();
865     impl_loadConnectionTools_throw();
866 
867     return m_xConnectionTools->getComposer(commandType,command);
868 }
869 
870 // -----------------------------------------------------------------------------
impl_checkTableQueryNames_nothrow()871 void OConnection::impl_checkTableQueryNames_nothrow()
872 {
873     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::impl_checkTableQueryNames_nothrow" );
874     DatabaseMetaData aMeta( static_cast< XConnection* >( this ) );
875     if ( !aMeta.supportsSubqueriesInFrom() )
876         // nothing to do
877         return;
878 
879     try
880     {
881         Reference< XNameAccess > xTables( getTables() );
882         Sequence< ::rtl::OUString > aTableNames( xTables->getElementNames() );
883         ::std::set< ::rtl::OUString > aSortedTableNames( aTableNames.getConstArray(), aTableNames.getConstArray() + aTableNames.getLength() );
884 
885         Reference< XNameAccess > xQueries( getQueries() );
886         Sequence< ::rtl::OUString > aQueryNames( xQueries->getElementNames() );
887 
888         for (   const ::rtl::OUString* pQueryName = aQueryNames.getConstArray();
889                 pQueryName != aQueryNames.getConstArray() + aQueryNames.getLength();
890                 ++pQueryName
891             )
892         {
893             if ( aSortedTableNames.find( *pQueryName ) != aSortedTableNames.end() )
894             {
895                 ::rtl::OUString sConflictWarning( DBACORE_RESSTRING( RID_STR_CONFLICTING_NAMES ) );
896                 m_aWarnings.appendWarning( sConflictWarning, "01SB0", *this );
897             }
898         }
899     }
900     catch( const Exception& )
901     {
902     	DBG_UNHANDLED_EXCEPTION();
903     }
904 }
905 
906 // -----------------------------------------------------------------------------
getTableIcon(const::rtl::OUString & _TableName,::sal_Int32 _ColorMode)907 Reference< XGraphic > SAL_CALL OConnection::getTableIcon( const ::rtl::OUString& _TableName, ::sal_Int32 _ColorMode ) throw (RuntimeException)
908 {
909     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::getTableIcon" );
910     Reference< XGraphic > xReturn;
911 
912     // ask our aggregate
913     if ( m_xTableUIProvider.is() )
914         xReturn = m_xTableUIProvider->getTableIcon( _TableName, _ColorMode );
915 
916     // ask ourself
917     // well, we don't have own functionality here ...
918     // In the future, we might decide to delegate the complete handling to this interface.
919     // In this case, we would need to load the icon here.
920 
921     return xReturn;
922 }
923 
924 // -----------------------------------------------------------------------------
getTableEditor(const Reference<XDatabaseDocumentUI> & _DocumentUI,const::rtl::OUString & _TableName)925 Reference< XInterface > SAL_CALL OConnection::getTableEditor( const Reference< XDatabaseDocumentUI >& _DocumentUI, const ::rtl::OUString& _TableName ) throw (IllegalArgumentException, WrappedTargetException, RuntimeException)
926 {
927     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dataaccess", "Ocke.Janssen@sun.com", "OConnection::getTableEditor" );
928     Reference< XInterface > xReturn;
929 
930     // ask our aggregate
931     if ( m_xTableUIProvider.is() )
932         xReturn = m_xTableUIProvider->getTableEditor( _DocumentUI, _TableName );
933 
934     // ask ourself
935     // well, we don't have own functionality here ...
936     // In the future, we might decide to delegate the complete handling to this interface.
937     // In this case, we would need to instantiate an css.sdb.TableDesign here.
938 
939     return xReturn;
940 }
941 
942 
943 //........................................................................
944 }	// namespace dbaccess
945 //........................................................................
946 
947