3840389aab
2006/07/19 10:35:53 fs 1.12.16.5: RESYNC: (1.15-1.16); FILE MERGED 2006/04/18 13:12:42 oj 1.12.16.4: RESYNC: (1.14-1.15); FILE MERGED 2006/03/21 15:46:20 fs 1.12.16.3: RESYNC: (1.13-1.14); FILE MERGED 2005/09/28 12:37:45 fs 1.12.16.2: RESYNC: (1.12-1.13); FILE MERGED 2005/04/06 07:10:25 fs 1.12.16.1: #i46768# some assertions on the type of connection properties
430 lines
18 KiB
C++
430 lines
18 KiB
C++
/*************************************************************************
|
|
*
|
|
* OpenOffice.org - a multi-platform office productivity suite
|
|
*
|
|
* $RCSfile: YDriver.cxx,v $
|
|
*
|
|
* $Revision: 1.17 $
|
|
*
|
|
* last change: $Author: hr $ $Date: 2006-08-15 10:29:35 $
|
|
*
|
|
* The Contents of this file are made available subject to
|
|
* the terms of GNU Lesser General Public License Version 2.1.
|
|
*
|
|
*
|
|
* GNU Lesser General Public License Version 2.1
|
|
* =============================================
|
|
* Copyright 2005 by Sun Microsystems, Inc.
|
|
* 901 San Antonio Road, Palo Alto, CA 94303, USA
|
|
*
|
|
* This library is free software; you can redistribute it and/or
|
|
* modify it under the terms of the GNU Lesser General Public
|
|
* License version 2.1, as published by the Free Software Foundation.
|
|
*
|
|
* This library 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 for more details.
|
|
*
|
|
* You should have received a copy of the GNU Lesser General Public
|
|
* License along with this library; if not, write to the Free Software
|
|
* Foundation, Inc., 59 Temple Place, Suite 330, Boston,
|
|
* MA 02111-1307 USA
|
|
*
|
|
************************************************************************/
|
|
#ifndef CONNECTIVITY_MYSQL_DRIVER_HXX
|
|
#include "mysql/YDriver.hxx"
|
|
#endif
|
|
#ifndef CONNECTIVITY_MYSQL_CATALOG_HXX
|
|
#include "mysql/YCatalog.hxx"
|
|
#endif
|
|
#ifndef _OSL_DIAGNOSE_H_
|
|
#include <osl/diagnose.h>
|
|
#endif
|
|
#ifndef _DBHELPER_DBEXCEPTION_HXX_
|
|
#include "connectivity/dbexception.hxx"
|
|
#endif
|
|
#ifndef _COM_SUN_STAR_SDBC_XDRIVERACCESS_HPP_
|
|
#include <com/sun/star/sdbc/XDriverAccess.hpp>
|
|
#endif
|
|
#ifndef CONNECTIVITY_CONNECTION_HXX
|
|
#include "TConnection.hxx"
|
|
#endif
|
|
|
|
//........................................................................
|
|
namespace connectivity
|
|
{
|
|
//........................................................................
|
|
using namespace mysql;
|
|
using namespace ::com::sun::star::uno;
|
|
using namespace ::com::sun::star::sdbc;
|
|
using namespace ::com::sun::star::sdbcx;
|
|
using namespace ::com::sun::star::beans;
|
|
using namespace ::com::sun::star::lang;
|
|
|
|
namespace mysql
|
|
{
|
|
Reference< XInterface > SAL_CALL ODriverDelegator_CreateInstance(const Reference< ::com::sun::star::lang::XMultiServiceFactory >& _rxFac) throw( Exception )
|
|
{
|
|
return *(new ODriverDelegator(_rxFac));
|
|
}
|
|
}
|
|
|
|
|
|
//====================================================================
|
|
//= ODriverDelegator
|
|
//====================================================================
|
|
//--------------------------------------------------------------------
|
|
ODriverDelegator::ODriverDelegator(const Reference< XMultiServiceFactory >& _rxFactory)
|
|
: ODriverDelegator_BASE(m_aMutex)
|
|
,m_xFactory(_rxFactory)
|
|
,m_bUseOdbc(sal_True)
|
|
{
|
|
}
|
|
|
|
//--------------------------------------------------------------------
|
|
ODriverDelegator::~ODriverDelegator()
|
|
{
|
|
try
|
|
{
|
|
::comphelper::disposeComponent(m_xODBCDriver);
|
|
TJDBCDrivers::iterator aIter = m_aJdbcDrivers.begin();
|
|
TJDBCDrivers::iterator aEnd = m_aJdbcDrivers.end();
|
|
for ( ;aIter != aEnd;++aIter )
|
|
::comphelper::disposeComponent(aIter->second);
|
|
}
|
|
catch(const Exception&)
|
|
{
|
|
}
|
|
}
|
|
|
|
// --------------------------------------------------------------------------------
|
|
void ODriverDelegator::disposing()
|
|
{
|
|
::osl::MutexGuard aGuard(m_aMutex);
|
|
|
|
|
|
for (TWeakPairVector::iterator i = m_aConnections.begin(); m_aConnections.end() != i; ++i)
|
|
{
|
|
Reference<XInterface > xTemp = i->first.get();
|
|
::comphelper::disposeComponent(xTemp);
|
|
}
|
|
m_aConnections.clear();
|
|
TWeakPairVector().swap(m_aConnections);
|
|
|
|
ODriverDelegator_BASE::disposing();
|
|
}
|
|
|
|
namespace
|
|
{
|
|
sal_Bool isOdbcUrl(const ::rtl::OUString& _sUrl)
|
|
{
|
|
return _sUrl.copy(0,16).equalsAscii("sdbc:mysql:odbc:");
|
|
}
|
|
//--------------------------------------------------------------------
|
|
::rtl::OUString getDriverClass(const Sequence< PropertyValue >& info)
|
|
{
|
|
::rtl::OUString sRet;
|
|
const PropertyValue* pSupported = info.getConstArray();
|
|
const PropertyValue* pEnd = pSupported + info.getLength();
|
|
for (;pSupported != pEnd; ++pSupported)
|
|
if ( !pSupported->Name.compareToAscii("JavaDriverClass") )
|
|
{
|
|
OSL_VERIFY( pSupported->Value >>= sRet );
|
|
break;
|
|
}
|
|
|
|
if ( !sRet.getLength() )
|
|
sRet = ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("com.mysql.jdbc.Driver"));
|
|
return sRet;
|
|
}
|
|
//--------------------------------------------------------------------
|
|
::rtl::OUString transformUrl(const ::rtl::OUString& _sUrl)
|
|
{
|
|
::rtl::OUString sNewUrl = _sUrl.copy(11);
|
|
if ( isOdbcUrl( _sUrl ) )
|
|
sNewUrl = ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("sdbc:")) + sNewUrl;
|
|
else
|
|
{
|
|
sNewUrl = sNewUrl.copy(5);
|
|
|
|
::rtl::OUString sTempUrl = ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("jdbc:mysql://"));
|
|
|
|
sTempUrl += sNewUrl;
|
|
sNewUrl = sTempUrl;
|
|
}
|
|
return sNewUrl;
|
|
}
|
|
//--------------------------------------------------------------------
|
|
Reference< XDriver > lcl_loadDriver(const Reference< XMultiServiceFactory >& _rxFactory,const ::rtl::OUString& _sUrl)
|
|
{
|
|
Reference<XDriverAccess> xDriverAccess(_rxFactory->createInstance(::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("com.sun.star.sdbc.DriverManager")) ),UNO_QUERY);
|
|
OSL_ENSURE(xDriverAccess.is(),"Could not load driver manager!");
|
|
Reference< XDriver > xDriver;
|
|
if ( xDriverAccess.is() )
|
|
xDriver = xDriverAccess->getDriverByURL(_sUrl);
|
|
return xDriver;
|
|
}
|
|
//--------------------------------------------------------------------
|
|
Sequence< PropertyValue > lcl_convertProperties(sal_Bool _bOdbc,const Sequence< PropertyValue >& info)
|
|
{
|
|
::std::vector<PropertyValue> aProps;
|
|
const PropertyValue* pSupported = info.getConstArray();
|
|
const PropertyValue* pEnd = pSupported + info.getLength();
|
|
|
|
aProps.reserve(info.getLength() + 5);
|
|
for (;pSupported != pEnd; ++pSupported)
|
|
{
|
|
aProps.push_back( *pSupported );
|
|
}
|
|
|
|
if ( _bOdbc )
|
|
{
|
|
aProps.push_back( PropertyValue(
|
|
::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("Silent"))
|
|
,0
|
|
,makeAny(sal_True)
|
|
,PropertyState_DIRECT_VALUE) );
|
|
aProps.push_back( PropertyValue(
|
|
::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("PreventGetVersionColumns"))
|
|
,0
|
|
,makeAny(sal_True)
|
|
,PropertyState_DIRECT_VALUE) );
|
|
}
|
|
else
|
|
{
|
|
aProps.push_back( PropertyValue(
|
|
::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("JavaDriverClass"))
|
|
,0
|
|
,makeAny(::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("com.mysql.jdbc.Driver")))
|
|
,PropertyState_DIRECT_VALUE) );
|
|
}
|
|
aProps.push_back( PropertyValue(
|
|
::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("IsAutoRetrievingEnabled"))
|
|
,0
|
|
,makeAny(sal_True)
|
|
,PropertyState_DIRECT_VALUE) );
|
|
aProps.push_back( PropertyValue(
|
|
::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("AutoRetrievingStatement"))
|
|
,0
|
|
,makeAny(::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("SELECT LAST_INSERT_ID()")))
|
|
,PropertyState_DIRECT_VALUE) );
|
|
aProps.push_back( PropertyValue(
|
|
::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("ParameterNameSubstitution"))
|
|
,0
|
|
,makeAny(sal_True)
|
|
,PropertyState_DIRECT_VALUE) );
|
|
PropertyValue* pProps = aProps.empty() ? 0 : &aProps[0];
|
|
return Sequence< PropertyValue >(pProps, aProps.size());
|
|
}
|
|
}
|
|
//--------------------------------------------------------------------
|
|
Reference< XDriver > ODriverDelegator::loadDriver( const ::rtl::OUString& url, const Sequence< PropertyValue >& info )
|
|
{
|
|
Reference< XDriver > xDriver;
|
|
::rtl::OUString sCuttedUrl = transformUrl(url);
|
|
sal_Bool bIsODBC = isOdbcUrl( url );
|
|
if ( bIsODBC )
|
|
{
|
|
if ( !m_xODBCDriver.is() )
|
|
m_xODBCDriver = lcl_loadDriver(m_xFactory,sCuttedUrl);
|
|
xDriver = m_xODBCDriver;
|
|
}
|
|
else
|
|
{
|
|
::rtl::OUString sDriverClass = getDriverClass(info);
|
|
if ( !sDriverClass.getLength() )
|
|
throw SQLException();
|
|
TJDBCDrivers::iterator aFind = m_aJdbcDrivers.find(sDriverClass);
|
|
if ( aFind == m_aJdbcDrivers.end() )
|
|
aFind = m_aJdbcDrivers.insert(TJDBCDrivers::value_type(sDriverClass,lcl_loadDriver(m_xFactory,sCuttedUrl))).first;
|
|
xDriver = aFind->second;
|
|
}
|
|
|
|
return xDriver;
|
|
}
|
|
|
|
//--------------------------------------------------------------------
|
|
Reference< XConnection > SAL_CALL ODriverDelegator::connect( const ::rtl::OUString& url, const Sequence< PropertyValue >& info ) throw (SQLException, RuntimeException)
|
|
{
|
|
Reference< XConnection > xConnection;
|
|
if ( acceptsURL(url) )
|
|
{
|
|
Reference< XDriver > xDriver;
|
|
xDriver = loadDriver(url,info);
|
|
if ( xDriver.is() )
|
|
{
|
|
::rtl::OUString sCuttedUrl = transformUrl(url);
|
|
sal_Bool bIsODBC = isOdbcUrl( url );
|
|
Sequence< PropertyValue > aConvertedProperties = lcl_convertProperties(bIsODBC,info);
|
|
|
|
xConnection = xDriver->connect( sCuttedUrl, aConvertedProperties );
|
|
if ( xConnection.is() )
|
|
{
|
|
OMetaConnection* pMetaConnection = NULL;
|
|
// now we have to set the URL to get the correct answer for metadata()->getURL()
|
|
Reference< XUnoTunnel> xTunnel(xConnection,UNO_QUERY);
|
|
if ( xTunnel.is() )
|
|
{
|
|
pMetaConnection = reinterpret_cast<OMetaConnection*>(xTunnel->getSomething( OMetaConnection::getUnoTunnelImplementationId() ));
|
|
if ( pMetaConnection )
|
|
pMetaConnection->setURL(url);
|
|
}
|
|
m_aConnections.push_back(TWeakPair(WeakReferenceHelper(xConnection),TWeakConnectionPair(WeakReferenceHelper(),pMetaConnection)));
|
|
}
|
|
}
|
|
}
|
|
return xConnection;
|
|
}
|
|
|
|
//--------------------------------------------------------------------
|
|
sal_Bool SAL_CALL ODriverDelegator::acceptsURL( const ::rtl::OUString& url ) throw (SQLException, RuntimeException)
|
|
{
|
|
sal_Bool bOK = sal_False;
|
|
if ( url.getLength() >= 16 )
|
|
{
|
|
::rtl::OUString sPrefix = url.copy(0,16);
|
|
bOK = sPrefix.equalsAscii("sdbc:mysql:odbc:");
|
|
if ( !bOK )
|
|
bOK = sPrefix.equalsAscii("sdbc:mysql:jdbc:");
|
|
}
|
|
return bOK;
|
|
}
|
|
|
|
//--------------------------------------------------------------------
|
|
Sequence< DriverPropertyInfo > SAL_CALL ODriverDelegator::getPropertyInfo( const ::rtl::OUString& url, const Sequence< PropertyValue >& /*info*/ ) throw (SQLException, RuntimeException)
|
|
{
|
|
::std::vector< DriverPropertyInfo > aDriverInfo;
|
|
if ( !acceptsURL(url) )
|
|
return Sequence< DriverPropertyInfo >();
|
|
|
|
sal_Bool bIsODBC = isOdbcUrl( url );
|
|
|
|
Sequence< ::rtl::OUString > aBoolean(2);
|
|
aBoolean[0] = ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("0"));
|
|
aBoolean[1] = ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("1"));
|
|
|
|
|
|
aDriverInfo.push_back(DriverPropertyInfo(
|
|
::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("CharSet"))
|
|
,::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("CharSet of the database."))
|
|
,sal_False
|
|
,::rtl::OUString()
|
|
,Sequence< ::rtl::OUString >())
|
|
);
|
|
aDriverInfo.push_back(DriverPropertyInfo(
|
|
::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("SuppressVersionColumns"))
|
|
,::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("Display version columns (when available)."))
|
|
,sal_False
|
|
,::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("0"))
|
|
,aBoolean)
|
|
);
|
|
if ( !bIsODBC )
|
|
{
|
|
aDriverInfo.push_back(DriverPropertyInfo(
|
|
::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("JavaDriverClass"))
|
|
,::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("The JDBC driver class name."))
|
|
,sal_True
|
|
,::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("com.mysql.jdbc.Driver"))
|
|
,Sequence< ::rtl::OUString >())
|
|
);
|
|
}
|
|
|
|
return Sequence< DriverPropertyInfo >(&aDriverInfo[0],aDriverInfo.size());
|
|
}
|
|
|
|
//--------------------------------------------------------------------
|
|
sal_Int32 SAL_CALL ODriverDelegator::getMajorVersion( ) throw (RuntimeException)
|
|
{
|
|
return 1;
|
|
}
|
|
|
|
//--------------------------------------------------------------------
|
|
sal_Int32 SAL_CALL ODriverDelegator::getMinorVersion( ) throw (RuntimeException)
|
|
{
|
|
return 0;
|
|
}
|
|
|
|
//--------------------------------------------------------------------
|
|
Reference< XTablesSupplier > SAL_CALL ODriverDelegator::getDataDefinitionByConnection( const Reference< XConnection >& connection ) throw (SQLException, RuntimeException)
|
|
{
|
|
::osl::MutexGuard aGuard( m_aMutex );
|
|
checkDisposed(ODriverDelegator_BASE::rBHelper.bDisposed);
|
|
|
|
Reference< XTablesSupplier > xTab;
|
|
Reference< XUnoTunnel> xTunnel(connection,UNO_QUERY);
|
|
if ( xTunnel.is() )
|
|
{
|
|
OMetaConnection* pConnection = reinterpret_cast<OMetaConnection*>(xTunnel->getSomething( OMetaConnection::getUnoTunnelImplementationId() ));
|
|
if ( pConnection )
|
|
{
|
|
TWeakPairVector::iterator aEnd = m_aConnections.end();
|
|
for (TWeakPairVector::iterator i = m_aConnections.begin(); aEnd != i; ++i)
|
|
{
|
|
if ( i->second.second == pConnection )
|
|
{
|
|
xTab = Reference< XTablesSupplier >(i->second.first.get().get(),UNO_QUERY);
|
|
if ( !xTab.is() )
|
|
{
|
|
xTab = new OMySQLCatalog(connection);
|
|
i->second.first = WeakReferenceHelper(xTab);
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
return xTab;
|
|
}
|
|
|
|
//--------------------------------------------------------------------
|
|
Reference< XTablesSupplier > SAL_CALL ODriverDelegator::getDataDefinitionByURL( const ::rtl::OUString& url, const Sequence< PropertyValue >& info ) throw (SQLException, RuntimeException)
|
|
{
|
|
if ( ! acceptsURL(url) )
|
|
::dbtools::throwGenericSQLException(::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("Invalid URL!")) ,*this);
|
|
|
|
return getDataDefinitionByConnection(connect(url,info));
|
|
}
|
|
|
|
// XServiceInfo
|
|
// --------------------------------------------------------------------------------
|
|
//------------------------------------------------------------------------------
|
|
rtl::OUString ODriverDelegator::getImplementationName_Static( ) throw(RuntimeException)
|
|
{
|
|
return rtl::OUString::createFromAscii("org.openoffice.comp.drivers.MySQL.Driver");
|
|
}
|
|
//------------------------------------------------------------------------------
|
|
Sequence< ::rtl::OUString > ODriverDelegator::getSupportedServiceNames_Static( ) throw (RuntimeException)
|
|
{
|
|
Sequence< ::rtl::OUString > aSNS( 2 );
|
|
aSNS[0] = ::rtl::OUString::createFromAscii("com.sun.star.sdbc.Driver");
|
|
aSNS[1] = ::rtl::OUString::createFromAscii("com.sun.star.sdbcx.Driver");
|
|
return aSNS;
|
|
}
|
|
//------------------------------------------------------------------
|
|
::rtl::OUString SAL_CALL ODriverDelegator::getImplementationName( ) throw(RuntimeException)
|
|
{
|
|
return getImplementationName_Static();
|
|
}
|
|
|
|
//------------------------------------------------------------------
|
|
sal_Bool SAL_CALL ODriverDelegator::supportsService( const ::rtl::OUString& _rServiceName ) throw(RuntimeException)
|
|
{
|
|
Sequence< ::rtl::OUString > aSupported(getSupportedServiceNames());
|
|
const ::rtl::OUString* pSupported = aSupported.getConstArray();
|
|
const ::rtl::OUString* pEnd = pSupported + aSupported.getLength();
|
|
for (;pSupported != pEnd && !pSupported->equals(_rServiceName); ++pSupported)
|
|
;
|
|
|
|
return pSupported != pEnd;
|
|
}
|
|
//------------------------------------------------------------------
|
|
Sequence< ::rtl::OUString > SAL_CALL ODriverDelegator::getSupportedServiceNames( ) throw(RuntimeException)
|
|
{
|
|
return getSupportedServiceNames_Static();
|
|
}
|
|
//------------------------------------------------------------------
|
|
//........................................................................
|
|
} // namespace connectivity
|
|
//........................................................................
|