1 /*************************************************************************
2  *
3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
4  *
5  * Copyright 2000, 2010 Oracle and/or its affiliates.
6  *
7  * OpenOffice.org - a multi-platform office productivity suite
8  *
9  * This file is part of OpenOffice.org.
10  *
11  * OpenOffice.org is free software: you can redistribute it and/or modify
12  * it under the terms of the GNU Lesser General Public License version 3
13  * only, as published by the Free Software Foundation.
14  *
15  * OpenOffice.org is distributed in the hope that it will be useful,
16  * but WITHOUT ANY WARRANTY; without even the implied warranty of
17  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
18  * GNU Lesser General Public License version 3 for more details
19  * (a copy is included in the LICENSE file that accompanied this code).
20  *
21  * You should have received a copy of the GNU Lesser General Public License
22  * version 3 along with OpenOffice.org.  If not, see
23  * <http://www.openoffice.org/license.html>
24  * for a copy of the LGPLv3 License.
25  *
26  ************************************************************************/
27 
28 // MARKER(update_precomp.py): autogen include statement, do not remove
29 #include "precompiled_extensions.hxx"
30 
31 #include "abpresid.hrc"
32 #include "abptypes.hxx"
33 #include "componentmodule.hxx"
34 #include "datasourcehandling.hxx"
35 
36 #include <com/sun/star/beans/XPropertySet.hpp>
37 #include <com/sun/star/container/XNameAccess.hpp>
38 #include <com/sun/star/frame/XStorable.hpp>
39 #include <com/sun/star/lang/XComponent.hpp>
40 #include <com/sun/star/lang/XMultiServiceFactory.hpp>
41 #include <com/sun/star/lang/XSingleServiceFactory.hpp>
42 #include <com/sun/star/sdb/SQLContext.hpp>
43 #include <com/sun/star/sdb/XCompletedConnection.hpp>
44 #include <com/sun/star/sdb/XDatabaseRegistrations.hpp>
45 #include <com/sun/star/sdb/XDocumentDataSource.hpp>
46 #include <com/sun/star/sdbc/XConnection.hpp>
47 #include <com/sun/star/sdbcx/XTablesSupplier.hpp>
48 #include <com/sun/star/task/XInteractionHandler.hpp>
49 #include <com/sun/star/uno/XNamingService.hpp>
50 
51 #include <comphelper/interaction.hxx>
52 #include <comphelper/componentcontext.hxx>
53 #include <tools/debug.hxx>
54 #include <tools/diagnose_ex.h>
55 #include <unotools/confignode.hxx>
56 #include <unotools/sharedunocomponent.hxx>
57 #include <vcl/stdtext.hxx>
58 
59 //.........................................................................
60 namespace abp
61 {
62 //.........................................................................
63 
64 	using namespace ::utl;
65 	using namespace ::comphelper;
66 	using namespace ::com::sun::star::uno;
67 	using namespace ::com::sun::star::lang;
68 	using namespace ::com::sun::star::sdb;
69 	using namespace ::com::sun::star::sdbc;
70 	using namespace ::com::sun::star::task;
71 	using namespace ::com::sun::star::beans;
72 	using namespace ::com::sun::star::sdbcx;
73 	using namespace ::com::sun::star::container;
74 	using namespace ::com::sun::star::frame;
75 
76 	//=====================================================================
77 	struct PackageAccessControl { };
78 
79 	//=====================================================================
80     //---------------------------------------------------------------------
81 	static Reference< XNameAccess > lcl_getDataSourceContext( const Reference< XMultiServiceFactory >& _rxORB ) SAL_THROW (( Exception ))
82 	{
83 		Reference< XNameAccess > xContext( _rxORB->createInstance( ::rtl::OUString::createFromAscii( "com.sun.star.sdb.DatabaseContext" ) ), UNO_QUERY );
84 		DBG_ASSERT(xContext.is(), "lcl_getDataSourceContext: could not access the data source context!");
85 		return xContext;
86 	}
87 
88 	//---------------------------------------------------------------------
89 	/// creates a new data source and inserts it into the context
90 	static void lcl_implCreateAndInsert(
91 		const Reference< XMultiServiceFactory >& _rxORB, const ::rtl::OUString& _rName,
92 		Reference< XPropertySet >& /* [out] */ _rxNewDataSource ) SAL_THROW (( ::com::sun::star::uno::Exception ))
93 	{
94 		//.............................................................
95 		// get the data source context
96 		Reference< XNameAccess > xContext = lcl_getDataSourceContext( _rxORB );
97 
98 		DBG_ASSERT( !xContext->hasByName( _rName ), "lcl_implCreateAndInsert: name already used!" );
99         (void)_rName;
100 
101 		//.............................................................
102 		// create a new data source
103 		Reference< XSingleServiceFactory > xFactory( xContext, UNO_QUERY );
104 		Reference< XPropertySet > xNewDataSource;
105 		if (xFactory.is())
106 			xNewDataSource = Reference< XPropertySet >( xFactory->createInstance(), UNO_QUERY );
107 		DBG_ASSERT( xNewDataSource.is(), "lcl_implCreateAndInsert: could not create a new data source!" );
108 
109 		//.............................................................
110 		// insert the data source into the context
111 		Reference< XNamingService > xDynamicContext( xContext, UNO_QUERY );
112 		DBG_ASSERT( xDynamicContext.is(), "lcl_implCreateAndInsert: missing an interface on the context (XNamingService)!" );
113 		if (xDynamicContext.is())
114 		{
115 			//	xDynamicContext->registerObject( _rName, xNewDataSource );
116 			_rxNewDataSource = xNewDataSource;
117 		}
118 	}
119 
120 	//---------------------------------------------------------------------
121 	/// creates and inserts a data source, and sets it's URL property to the string given
122 	static ODataSource lcl_implCreateAndSetURL(
123 		const Reference< XMultiServiceFactory >& _rxORB, const ::rtl::OUString& _rName,
124 		const sal_Char* _pInitialAsciiURL ) SAL_THROW (( ))
125 	{
126 		ODataSource aReturn( _rxORB );
127 		try
128 		{
129 			// create the new data source
130 			Reference< XPropertySet > xNewDataSource;
131 			lcl_implCreateAndInsert( _rxORB, _rName, xNewDataSource );
132 
133 			//.............................................................
134 			// set the URL property
135 			if (xNewDataSource.is())
136 			{
137 				xNewDataSource->setPropertyValue(
138 					::rtl::OUString::createFromAscii( "URL" ),
139 					makeAny( ::rtl::OUString::createFromAscii( _pInitialAsciiURL ) )
140 				);
141 			}
142 
143 			aReturn.setDataSource( xNewDataSource, _rName,PackageAccessControl() );
144 		}
145 		catch(const Exception&)
146 		{
147 			DBG_ERROR( "lcl_implCreateAndSetURL: caught an exception while creating the data source!" );
148 		}
149 
150 		return aReturn;
151 	}
152 	//---------------------------------------------------------------------
153 	void lcl_registerDataSource(
154 		const Reference< XMultiServiceFactory >& _rxORB, const ::rtl::OUString& _sName,
155 		const ::rtl::OUString& _sURL ) SAL_THROW (( ::com::sun::star::uno::Exception ))
156 	{
157         OSL_ENSURE( _sName.getLength(), "lcl_registerDataSource: invalid name!" );
158         OSL_ENSURE( _sURL.getLength(), "lcl_registerDataSource: invalid URL!" );
159         try
160         {
161 
162             ::comphelper::ComponentContext aContext( _rxORB );
163             Reference< XDatabaseRegistrations > xRegistrations(
164                 aContext.createComponent( "com.sun.star.sdb.DatabaseContext" ), UNO_QUERY_THROW );
165 
166 		    if ( xRegistrations->hasRegisteredDatabase( _sName ) )
167                 xRegistrations->changeDatabaseLocation( _sName, _sURL );
168             else
169                 xRegistrations->registerDatabaseLocation( _sName, _sURL );
170         }
171         catch( const Exception& )
172         {
173         	DBG_UNHANDLED_EXCEPTION();
174         }
175 	}
176 
177 	//=====================================================================
178 	//= ODataSourceContextImpl
179 	//=====================================================================
180 	struct ODataSourceContextImpl
181 	{
182 		Reference< XMultiServiceFactory >	xORB;
183 		Reference< XNameAccess >			xContext;			/// the UNO data source context
184 		StringBag							aDataSourceNames;	/// for quicker name checks (without the UNO overhead)
185 
186 		ODataSourceContextImpl( const Reference< XMultiServiceFactory >& _rxORB ) : xORB( _rxORB ) { }
187 		ODataSourceContextImpl( const ODataSourceContextImpl& _rSource )
188 			:xORB		( _rSource.xORB )
189 			,xContext	( _rSource.xContext )
190 		{
191 		}
192 	};
193 
194 	//=====================================================================
195 	//= ODataSourceContext
196 	//=====================================================================
197 	//---------------------------------------------------------------------
198 	ODataSourceContext::ODataSourceContext(const Reference< XMultiServiceFactory >& _rxORB)
199 		:m_pImpl( new ODataSourceContextImpl( _rxORB ) )
200 	{
201 		try
202 		{
203 			// create the UNO context
204 			m_pImpl->xContext = lcl_getDataSourceContext( _rxORB );
205 
206 			if (m_pImpl->xContext.is())
207 			{
208 				// collect the data source names
209 				Sequence< ::rtl::OUString > aDSNames = m_pImpl->xContext->getElementNames();
210 				const ::rtl::OUString* pDSNames = aDSNames.getConstArray();
211 				const ::rtl::OUString* pDSNamesEnd = pDSNames + aDSNames.getLength();
212 
213 				for ( ;pDSNames != pDSNamesEnd; ++pDSNames )
214 					m_pImpl->aDataSourceNames.insert( *pDSNames );
215 			}
216 		}
217 		catch( const Exception& )
218 		{
219 			DBG_ERROR( "ODataSourceContext::ODataSourceContext: caught an exception!" );
220 		}
221 	}
222 
223 	//---------------------------------------------------------------------
224 	::rtl::OUString& ODataSourceContext::disambiguate(::rtl::OUString& _rDataSourceName)
225 	{
226 		::rtl::OUString sCheck( _rDataSourceName );
227 		ConstStringBagIterator aPos = m_pImpl->aDataSourceNames.find( sCheck );
228 
229 		sal_Int32 nPostFix = 1;
230 		while ( ( m_pImpl->aDataSourceNames.end() != aPos ) && ( nPostFix < 65535 ) )
231 		{	// there already is a data source with this name
232 			sCheck = _rDataSourceName;
233 			sCheck += ::rtl::OUString::valueOf( nPostFix++ );
234 
235 			aPos = m_pImpl->aDataSourceNames.find( sCheck );
236 		}
237 
238 		_rDataSourceName = sCheck;
239 		return _rDataSourceName;
240 	}
241 
242 	//---------------------------------------------------------------------
243 	void ODataSourceContext::getDataSourceNames( StringBag& _rNames ) const SAL_THROW (( ))
244 	{
245 		_rNames = m_pImpl->aDataSourceNames;
246 	}
247 
248 	//---------------------------------------------------------------------
249 	ODataSource	ODataSourceContext::createNewLDAP( const ::rtl::OUString& _rName) SAL_THROW (( ))
250 	{
251 		return lcl_implCreateAndSetURL( m_pImpl->xORB, _rName, "sdbc:address:ldap:" );
252 	}
253 
254 	//---------------------------------------------------------------------
255 	ODataSource	ODataSourceContext::createNewMORK( const ::rtl::OUString& _rName) SAL_THROW (( ))
256 	{
257 		return lcl_implCreateAndSetURL( m_pImpl->xORB, _rName, "sdbc:address:mozilla" );
258 	}
259 
260 	//---------------------------------------------------------------------
261 	ODataSource	ODataSourceContext::createNewThunderbird( const ::rtl::OUString& _rName ) SAL_THROW (( ))
262 	{
263 		return lcl_implCreateAndSetURL( m_pImpl->xORB, _rName, "sdbc:address:thunderbird" );
264 	}
265 
266 	//---------------------------------------------------------------------
267 	ODataSource	ODataSourceContext::createNewEvolutionLdap( const ::rtl::OUString& _rName) SAL_THROW (( ))
268 	{
269 		return lcl_implCreateAndSetURL( m_pImpl->xORB, _rName, "sdbc:address:evolution:ldap" );
270 	}
271 	//---------------------------------------------------------------------
272 	ODataSource	ODataSourceContext::createNewEvolutionGroupwise( const ::rtl::OUString& _rName) SAL_THROW (( ))
273 	{
274 		return lcl_implCreateAndSetURL( m_pImpl->xORB, _rName, "sdbc:address:evolution:groupwise" );
275 	}
276 	//---------------------------------------------------------------------
277 	ODataSource	ODataSourceContext::createNewEvolution( const ::rtl::OUString& _rName) SAL_THROW (( ))
278 	{
279 		return lcl_implCreateAndSetURL( m_pImpl->xORB, _rName, "sdbc:address:evolution:local" );
280 	}
281 
282 	//---------------------------------------------------------------------
283 	ODataSource	ODataSourceContext::createNewKab( const ::rtl::OUString& _rName) SAL_THROW (( ))
284 	{
285 		return lcl_implCreateAndSetURL( m_pImpl->xORB, _rName, "sdbc:address:kab" );
286 	}
287 
288 	//---------------------------------------------------------------------
289 	ODataSource	ODataSourceContext::createNewMacab( const ::rtl::OUString& _rName) SAL_THROW (( ))
290 	{
291 		return lcl_implCreateAndSetURL( m_pImpl->xORB, _rName, "sdbc:address:macab" );
292 	}
293 
294 	//---------------------------------------------------------------------
295 	ODataSource	ODataSourceContext::createNewOutlook( const ::rtl::OUString& _rName) SAL_THROW (( ))
296 	{
297 		return lcl_implCreateAndSetURL( m_pImpl->xORB, _rName, "sdbc:address:outlook" );
298 	}
299 
300 	//---------------------------------------------------------------------
301 	ODataSource	ODataSourceContext::createNewOE( const ::rtl::OUString& _rName) SAL_THROW (( ))
302 	{
303 		return lcl_implCreateAndSetURL( m_pImpl->xORB, _rName, "sdbc:address:outlookexp" );
304 	}
305 
306 	//---------------------------------------------------------------------
307 	ODataSource	ODataSourceContext::createNewDBase( const ::rtl::OUString& _rName) SAL_THROW (( ))
308 	{
309 		return lcl_implCreateAndSetURL( m_pImpl->xORB, _rName, "sdbc:dbase:" );
310 	}
311 
312 	//=====================================================================
313 	//= ODataSourceImpl
314 	//=====================================================================
315 	struct ODataSourceImpl
316 	{
317 	public:
318 		Reference< XMultiServiceFactory >		xORB;				/// the service factory
319 		Reference< XPropertySet >				xDataSource;		/// the UNO data source
320         ::utl::SharedUNOComponent< XConnection >
321                                                 xConnection;
322 		StringBag								aTables;			// the cached table names
323 		::rtl::OUString							sName;
324 		sal_Bool								bTablesUpToDate;	// table name cache up-to-date?
325 
326 		ODataSourceImpl( const Reference< XMultiServiceFactory >& _rxORB )
327 			:xORB( _rxORB )
328 			,bTablesUpToDate( sal_False )
329 		{
330 		}
331 
332 		ODataSourceImpl( const ODataSourceImpl& _rSource );
333 	};
334 
335 	//---------------------------------------------------------------------
336 	ODataSourceImpl::ODataSourceImpl( const ODataSourceImpl& _rSource )
337 		:xORB( _rSource.xORB )
338 		,xDataSource( _rSource.xDataSource )
339 		,xConnection( _rSource.xConnection )
340 		,aTables( _rSource.aTables )
341 		,sName( _rSource.sName )
342 		,bTablesUpToDate( _rSource.bTablesUpToDate )
343 	{
344 	}
345 
346 	//=====================================================================
347 	//= ODataSource
348 	//=====================================================================
349 	//---------------------------------------------------------------------
350 	ODataSource::ODataSource( const ODataSource& _rSource )
351 		:m_pImpl( NULL )
352 	{
353 		*this = _rSource;
354 	}
355 
356 	//---------------------------------------------------------------------
357 	ODataSource& ODataSource::operator=( const ODataSource& _rSource )
358 	{
359 		delete m_pImpl;
360 		m_pImpl = new ODataSourceImpl( *_rSource.m_pImpl );
361 
362 		return *this;
363 	}
364 
365 	//---------------------------------------------------------------------
366 	ODataSource::ODataSource( const Reference< XMultiServiceFactory >& _rxORB )
367 		:m_pImpl(new ODataSourceImpl(_rxORB))
368 	{
369 	}
370 
371 	//---------------------------------------------------------------------
372 	ODataSource::~ODataSource( )
373 	{
374 		delete m_pImpl;
375 	}
376 
377 	//---------------------------------------------------------------------
378 	void ODataSource::store() SAL_THROW (( ))
379 	{
380 		if (!isValid())
381 			// nothing to do
382 			return;
383 		try
384 		{
385 			Reference< XDocumentDataSource > xDocAccess( m_pImpl->xDataSource, UNO_QUERY );
386             Reference< XStorable > xStorable;
387             if ( xDocAccess.is() )
388                 xStorable = xStorable.query( xDocAccess->getDatabaseDocument() );
389 			OSL_ENSURE( xStorable.is(),"DataSource is no XStorable!" );
390 			if ( xStorable.is() )
391 				xStorable->storeAsURL(m_pImpl->sName,Sequence<PropertyValue>());
392 		}
393 		catch(const Exception&)
394 		{
395 			DBG_ERROR( "ODataSource::registerDataSource: caught an exception while creating the data source!" );
396 		}
397 	}
398 	//---------------------------------------------------------------------
399 	void ODataSource::registerDataSource( const ::rtl::OUString& _sRegisteredDataSourceName) SAL_THROW (( ))
400 	{
401 		if (!isValid())
402 			// nothing to do
403 			return;
404 
405 		try
406 		{
407 			// invalidate ourself
408 			lcl_registerDataSource(m_pImpl->xORB,_sRegisteredDataSourceName,m_pImpl->sName);
409 		}
410 		catch(const Exception&)
411 		{
412 			DBG_ERROR( "ODataSource::registerDataSource: caught an exception while creating the data source!" );
413 		}
414 	}
415 
416 	//---------------------------------------------------------------------
417 	void ODataSource::setDataSource( const Reference< XPropertySet >& _rxDS,const ::rtl::OUString& _sName, PackageAccessControl )
418 	{
419 		if (m_pImpl->xDataSource.get() == _rxDS.get())
420 			// nothing to do
421 			return;
422 
423 		if ( isConnected() )
424 			disconnect();
425 
426 		m_pImpl->sName = _sName;
427 		m_pImpl->xDataSource = _rxDS;
428 	}
429 
430 	//---------------------------------------------------------------------
431 	void ODataSource::remove() SAL_THROW (( ))
432 	{
433 		if (!isValid())
434 			// nothing to do
435 			return;
436 
437 		try
438 		{
439 			// invalidate ourself
440 			m_pImpl->xDataSource.clear();
441 		}
442 		catch(const Exception&)
443 		{
444 			DBG_ERROR( "ODataSource::remove: caught an exception while creating the data source!" );
445 		}
446 	}
447 
448 	//---------------------------------------------------------------------
449 	sal_Bool ODataSource::rename( const ::rtl::OUString& _rName ) SAL_THROW (( ))
450 	{
451 		if (!isValid())
452 			// nothing to do
453 			return sal_False;
454 
455 		m_pImpl->sName = _rName;
456 		return sal_True;
457 	}
458 
459 	//---------------------------------------------------------------------
460 	::rtl::OUString ODataSource::getName() const SAL_THROW (( ))
461 	{
462 		if ( !isValid() )
463 			return ::rtl::OUString();
464 		return m_pImpl->sName;
465 	}
466 
467 	//---------------------------------------------------------------------
468     bool ODataSource::hasTable( const ::rtl::OUString& _rTableName ) const
469     {
470         if ( !isConnected() )
471             return false;
472 
473         const StringBag& aTables( getTableNames() );
474         return aTables.find( _rTableName ) != aTables.end();
475     }
476 
477 	//---------------------------------------------------------------------
478 	const StringBag& ODataSource::getTableNames() const SAL_THROW (( ))
479 	{
480 		m_pImpl->aTables.clear();
481 		if ( !isConnected() )
482 		{
483 			DBG_ERROR( "ODataSource::getTableNames: not connected!" );
484 		}
485 		else
486 		{
487 			try
488 			{
489 				// get the tables container from the connection
490 				Reference< XTablesSupplier > xSuppTables( m_pImpl->xConnection.getTyped(), UNO_QUERY );
491 				Reference< XNameAccess > xTables;
492 				if ( xSuppTables.is( ) )
493 					xTables = xSuppTables->getTables();
494 				DBG_ASSERT( xTables.is(), "ODataSource::getTableNames: could not retrieve the tables container!" );
495 
496 				// get the names
497 				Sequence< ::rtl::OUString > aTableNames;
498 				if ( xTables.is( ) )
499 					aTableNames = xTables->getElementNames( );
500 
501 				// copy the names
502 				const ::rtl::OUString* pTableNames = aTableNames.getConstArray();
503 				const ::rtl::OUString* pTableNamesEnd = pTableNames + aTableNames.getLength();
504 				for (;pTableNames < pTableNamesEnd; ++pTableNames)
505 					m_pImpl->aTables.insert( *pTableNames );
506 			}
507 			catch(const Exception&)
508 			{
509 			}
510 		}
511 
512 		// now the table cache is up-to-date
513 		m_pImpl->bTablesUpToDate = sal_True;
514 		return m_pImpl->aTables;
515 	}
516 
517 	//---------------------------------------------------------------------
518 	sal_Bool ODataSource::connect( Window* _pMessageParent ) SAL_THROW (( ))
519 	{
520 		if ( isConnected( ) )
521 			// nothing to do
522 			return sal_True;
523 
524 		// ................................................................
525 		// create the interaction handler (needed for authentication and error handling)
526 		static ::rtl::OUString s_sInteractionHandlerServiceName = ::rtl::OUString::createFromAscii("com.sun.star.task.InteractionHandler");
527 		Reference< XInteractionHandler > xInteractions;
528 		try
529 		{
530 			xInteractions = Reference< XInteractionHandler >(
531 				m_pImpl->xORB->createInstance( s_sInteractionHandlerServiceName ),
532 				UNO_QUERY
533 			);
534 		}
535 		catch(const Exception&)
536 		{
537 		}
538 
539 		// ................................................................
540 		// failure to create the interaction handler is a serious issue ...
541 		if (!xInteractions.is())
542 		{
543 			if ( _pMessageParent )
544 				ShowServiceNotAvailableError( _pMessageParent, s_sInteractionHandlerServiceName, sal_True );
545 			return sal_False;
546 		}
547 
548 		// ................................................................
549 		// open the connection
550 		Any aError;
551 		Reference< XConnection > xConnection;
552 		try
553 		{
554 			Reference< XCompletedConnection > xComplConn( m_pImpl->xDataSource, UNO_QUERY );
555 			DBG_ASSERT( xComplConn.is(), "ODataSource::connect: missing the XCompletedConnection interface on the data source!" );
556 			if ( xComplConn.is() )
557 				xConnection = xComplConn->connectWithCompletion( xInteractions );
558 		}
559 		catch( const SQLContext& e ) { aError <<= e; }
560 		catch( const SQLWarning& e ) { aError <<= e; }
561 		catch( const SQLException& e ) { aError <<= e; }
562 		catch( const Exception& )
563 		{
564 			DBG_ERROR( "ODataSource::connect: caught a generic exception!" );
565 		}
566 
567 		// ................................................................
568 		// handle errors
569 		if ( aError.hasValue() && _pMessageParent )
570 		{
571 			try
572 			{
573 				SQLException aException;
574   				aError >>= aException;
575   				if ( !aException.Message.getLength() )
576   				{
577 	    			// prepend some context info
578 					SQLContext aDetailedError;
579 					aDetailedError.Message = String( ModuleRes( RID_STR_NOCONNECTION ) );
580 					aDetailedError.Details = String( ModuleRes( RID_STR_PLEASECHECKSETTINGS ) );
581 					aDetailedError.NextException = aError;
582 					// handle (aka display) the new context info
583 					xInteractions->handle( new OInteractionRequest( makeAny( aDetailedError ) ) );
584   				}
585   				else
586   				{
587   					// handle (aka display) the original error
588 					xInteractions->handle( new OInteractionRequest( makeAny( aException ) ) );
589 				}
590 			}
591 			catch( const Exception& )
592 			{
593 				DBG_ERROR( "ODataSource::connect: caught an exception while trying to display the error!" );
594 			}
595 		}
596 
597 		if ( !xConnection.is() )
598 			return sal_False;
599 
600 		// ................................................................
601 		// success
602 		m_pImpl->xConnection.reset( xConnection );
603 		m_pImpl->aTables.clear();
604 		m_pImpl->bTablesUpToDate = sal_False;
605 
606 		return sal_True;
607 	}
608 
609 	//---------------------------------------------------------------------
610 	void ODataSource::disconnect( ) SAL_THROW (( ))
611 	{
612 		m_pImpl->xConnection.clear();
613 		m_pImpl->aTables.clear();
614 		m_pImpl->bTablesUpToDate = sal_False;
615 	}
616 
617 	//---------------------------------------------------------------------
618 	sal_Bool ODataSource::isConnected( ) const SAL_THROW (( ))
619 	{
620 		return m_pImpl->xConnection.is();
621 	}
622 
623 	//---------------------------------------------------------------------
624 	sal_Bool ODataSource::isValid() const SAL_THROW (( ))
625 	{
626 		return m_pImpl && m_pImpl->xDataSource.is();
627 	}
628 	//---------------------------------------------------------------------
629 	Reference< XPropertySet > ODataSource::getDataSource() const SAL_THROW (( ))
630 	{
631 		return m_pImpl ? m_pImpl->xDataSource : Reference< XPropertySet >();
632 	}
633 
634 //.........................................................................
635 }	// namespace abp
636 //.........................................................................
637 
638