/************************************************************************* * * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. * * Copyright 2000, 2010 Oracle and/or its affiliates. * * OpenOffice.org - a multi-platform office productivity suite * * This file is part of OpenOffice.org. * * OpenOffice.org is free software: you can redistribute it and/or modify * it under the terms of the GNU Lesser General Public License version 3 * only, as published by the Free Software Foundation. * * OpenOffice.org is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU Lesser General Public License version 3 for more details * (a copy is included in the LICENSE file that accompanied this code). * * You should have received a copy of the GNU Lesser General Public License * version 3 along with OpenOffice.org. If not, see * * for a copy of the LGPLv3 License. * ************************************************************************/ // MARKER(update_precomp.py): autogen include statement, do not remove #include "precompiled_dbaccess.hxx" #ifndef _DBAUI_DATASOURCECONNECTOR_HXX_ #include "datasourceconnector.hxx" #endif #ifndef _OSL_DIAGNOSE_H_ #include #endif #ifndef DBACCESS_SHARED_DBUSTRINGS_HRC #include "dbustrings.hrc" #endif #ifndef _COM_SUN_STAR_SDBC_XWARNINGSSUPPLIER_HPP_ #include #endif #ifndef _COM_SUN_STAR_BEANS_XPROPERTYSET_HPP_ #include #endif #ifndef _COM_SUN_STAR_SDB_XCOMPLETEDCONNECTION_HPP_ #include #endif #ifndef _COM_SUN_STAR_TASK_XINTERACTIONHANDLER_HPP_ #include #endif #ifndef _COM_SUN_STAR_FRAME_XMODEL_HPP_ #include #endif #ifndef _COM_SUN_STAR_SDB_SQLCONTEXT_HPP_ #include #endif #ifndef _COM_SUN_STAR_SDBC_SQLWARNING_HPP_ #include #endif #ifndef _OSL_THREAD_H_ #include #endif #ifndef _COMPHELPER_EXTRACT_HXX_ #include #endif #ifndef COMPHELPER_NAMEDVALUECOLLECTION_HXX #include #endif #ifndef _DBHELPER_DBEXCEPTION_HXX_ #include #endif #ifndef _COM_SUN_STAR_SDBC_XDATASOURCE_HPP_ #include #endif #ifndef DBAUI_TOOLS_HXX #include "UITools.hxx" #endif #ifndef _VCL_STDTEXT_HXX #include #endif #ifndef _SV_BUTTON_HXX #include #endif #ifndef SVTOOLS_FILENOTATION_HXX #include #endif #ifndef TOOLS_DIAGNOSE_EX_H #include #endif #ifndef _CPPUHELPER_EXC_HLP_HXX_ #include #endif #ifndef _DBU_MISC_HRC_ #include "dbu_misc.hrc" #endif #include "moduledbu.hxx" //......................................................................... namespace dbaui { //......................................................................... using namespace ::com::sun::star::uno; using namespace ::com::sun::star::lang; using namespace ::com::sun::star::sdb; using namespace ::com::sun::star::sdbc; using namespace ::com::sun::star::task; using namespace ::com::sun::star::beans; using namespace ::com::sun::star::container; using namespace ::com::sun::star::frame; using namespace ::dbtools; using ::svt::OFileNotation; //===================================================================== //= ODatasourceConnector //===================================================================== //--------------------------------------------------------------------- ODatasourceConnector::ODatasourceConnector(const Reference< XMultiServiceFactory >& _rxORB, Window* _pMessageParent) :m_pErrorMessageParent(_pMessageParent) ,m_xORB(_rxORB) { } //--------------------------------------------------------------------- ODatasourceConnector::ODatasourceConnector( const Reference< XMultiServiceFactory >& _rxORB, Window* _pMessageParent, const ::rtl::OUString& _rContextInformation ) :m_pErrorMessageParent(_pMessageParent) ,m_xORB(_rxORB) ,m_sContextInformation( _rContextInformation ) { } //--------------------------------------------------------------------- Reference< XConnection > ODatasourceConnector::connect( const ::rtl::OUString& _rDataSourceName, ::dbtools::SQLExceptionInfo* _pErrorInfo ) const { Reference< XConnection > xConnection; OSL_ENSURE(isValid(), "ODatasourceConnector::connect: invalid object!"); if (!isValid()) return xConnection; // get the data source Reference< XDataSource > xDatasource( getDataSourceByName( _rDataSourceName, m_pErrorMessageParent, m_xORB, _pErrorInfo ), UNO_QUERY ); if ( xDatasource.is() ) xConnection = connect( xDatasource, _pErrorInfo ); return xConnection; } //--------------------------------------------------------------------- Reference< XConnection > ODatasourceConnector::connect(const Reference< XDataSource>& _xDataSource, ::dbtools::SQLExceptionInfo* _pErrorInfo ) const { Reference< XConnection > xConnection; OSL_ENSURE( isValid() && _xDataSource.is(), "ODatasourceConnector::connect: invalid object or argument!" ); if ( !isValid() || !_xDataSource.is() ) return xConnection; // get user/password ::rtl::OUString sPassword, sUser; sal_Bool bPwdRequired = sal_False; Reference xProp(_xDataSource,UNO_QUERY); try { xProp->getPropertyValue(PROPERTY_PASSWORD) >>= sPassword; xProp->getPropertyValue(PROPERTY_ISPASSWORDREQUIRED) >>= bPwdRequired; xProp->getPropertyValue(PROPERTY_USER) >>= sUser; } catch(Exception&) { DBG_UNHANDLED_EXCEPTION(); } // try to connect SQLExceptionInfo aInfo; try { if (bPwdRequired && !sPassword.getLength()) { // password required, but empty -> connect using an interaction handler Reference< XCompletedConnection > xConnectionCompletion( _xDataSource, UNO_QUERY_THROW ); Reference< XModel > xModel( getDataSourceOrModel( _xDataSource ), UNO_QUERY_THROW ); ::comphelper::NamedValueCollection aArgs( xModel->getArgs() ); Reference< XInteractionHandler > xHandler( aArgs.getOrDefault( "InteractionHandler", Reference< XInteractionHandler >() ) ); if ( !xHandler.is() ) { // instantiate the default SDB interaction handler xHandler = Reference< XInteractionHandler >( m_xORB->createInstance( SERVICE_TASK_INTERACTION_HANDLER ), UNO_QUERY ); if ( !xHandler.is() ) ShowServiceNotAvailableError(m_pErrorMessageParent, (::rtl::OUString)SERVICE_TASK_INTERACTION_HANDLER, sal_True); } if ( xHandler.is() ) { xConnection = xConnectionCompletion->connectWithCompletion(xHandler); } } else { xConnection = _xDataSource->getConnection(sUser, sPassword); } } catch( const SQLException& ) { aInfo = ::cppu::getCaughtException(); } catch(const Exception&) { DBG_UNHANDLED_EXCEPTION(); } if ( !aInfo.isValid() ) { // there was no error during connecting, but perhaps a warning? Reference< XWarningsSupplier > xConnectionWarnings( xConnection, UNO_QUERY ); if ( xConnectionWarnings.is() ) { try { Any aWarnings( xConnectionWarnings->getWarnings() ); if ( aWarnings.hasValue() ) { String sMessage( ModuleRes( STR_WARNINGS_DURING_CONNECT ) ); sMessage.SearchAndReplaceAscii( "$buttontext$", Button::GetStandardText( BUTTON_MORE ) ); sMessage = OutputDevice::GetNonMnemonicString( sMessage ); SQLWarning aContext; aContext.Message = sMessage; aContext.NextException = aWarnings; aInfo = aContext; } xConnectionWarnings->clearWarnings(); } catch( const Exception& ) { DBG_UNHANDLED_EXCEPTION(); } } } else { if ( m_sContextInformation.getLength() ) { SQLException aError; aError.Message = m_sContextInformation; aError.NextException = aInfo.get(); aInfo = aError; } } // was there an error? if ( aInfo.isValid() ) { if ( _pErrorInfo ) { *_pErrorInfo = aInfo; } else { showError( aInfo, m_pErrorMessageParent, m_xORB ); } } return xConnection; } //......................................................................... } // namespace dbaui //.........................................................................