connectivity/source/drivers/postgresql/pq_driver.cxx

   1 /*************************************************************************
   2  *
   3  *  $RCSfile: pq_driver.cxx,v $
   4  *
   5  *  $Revision: 1.1.2.2 $
   6  *
   7  *  last change: $Author: jbu $ $Date: 2004/05/09 19:47:13 $
   8  *
   9  *  The Contents of this file are made available subject to the terms of
  10  *  either of the following licenses
  11  *
  12  *         - GNU Lesser General Public License Version 2.1
  13  *         - Sun Industry Standards Source License Version 1.1
  14  *
  15  *  Sun Microsystems Inc., October, 2000
  16  *
  17  *  GNU Lesser General Public License Version 2.1
  18  *  =============================================
  19  *  Copyright 2000 by Sun Microsystems, Inc.
  20  *  901 San Antonio Road, Palo Alto, CA 94303, USA
  21  *
  22  *  This library is free software; you can redistribute it and/or
  23  *  modify it under the terms of the GNU Lesser General Public
  24  *  License version 2.1, as published by the Free Software Foundation.
  25  *
  26  *  This library is distributed in the hope that it will be useful,
  27  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  28  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  29  *  Lesser General Public License for more details.
  30  *
  31  *  You should have received a copy of the GNU Lesser General Public
  32  *  License along with this library; if not, write to the Free Software
  33  *  Foundation, Inc., 59 Temple Place, Suite 330, Boston,
  34  *  MA  02111-1307  USA
  35  *
  36  *
  37  *  Sun Industry Standards Source License Version 1.1
  38  *  =================================================
  39  *  The contents of this file are subject to the Sun Industry Standards
  40  *  Source License Version 1.1 (the "License"); You may not use this file
  41  *  except in compliance with the License. You may obtain a copy of the
  42  *  License at http://www.openoffice.org/license.html.
  43  *
  44  *  Software provided under this License is provided on an "AS IS" basis,
  45  *  WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESSED OR IMPLIED, INCLUDING,
  46  *  WITHOUT LIMITATION, WARRANTIES THAT THE SOFTWARE IS FREE OF DEFECTS,
  47  *  MERCHANTABLE, FIT FOR A PARTICULAR PURPOSE, OR NON-INFRINGING.
  48  *  See the License for the specific provisions governing your rights and
  49  *  obligations concerning the Software.
  50  *
  51  *  The Initial Developer of the Original Code is: Joerg Budischewski
  52  *
  53  *   Copyright: 2000 by Sun Microsystems, Inc.
  54  *
  55  *   All Rights Reserved.
  56  *
  57  *   Contributor(s): Joerg Budischewski
  58  *
  59  *
  60  ************************************************************************/
  61
  62 #include <stdio.h>
  63
  64 #include <cppuhelper/factory.hxx>
  65 #include <cppuhelper/compbase1.hxx>
  66 #include <cppuhelper/compbase2.hxx>
  67 #include <cppuhelper/implementationentry.hxx>
  68
  69 #include <com/sun/star/beans/XPropertySet.hpp>
  70
  71 #include "pq_driver.hxx"
  72
  73 using rtl::OUString;
  74 using rtl::OUStringToOString;
  75 using osl::MutexGuard;
  76
  77 using cppu::WeakComponentImplHelper2;
  78
  79 using com::sun::star::lang::XSingleComponentFactory;
  80 using com::sun::star::lang::XServiceInfo;
  81 using com::sun::star::lang::XComponent;
  82
  83 using com::sun::star::uno::RuntimeException;
  84 using com::sun::star::uno::Exception;
  85 using com::sun::star::uno::Sequence;
  86 using com::sun::star::uno::Reference;
  87 using com::sun::star::uno::XInterface;
  88 using com::sun::star::uno::UNO_QUERY;
  89 using com::sun::star::uno::XComponentContext;
  90 using com::sun::star::uno::Any;
  91
  92 using com::sun::star::beans::PropertyValue;
  93 using com::sun::star::beans::XPropertySet;
  94
  95 using com::sun::star::sdbc::XConnection;
  96 using com::sun::star::sdbc::SQLException;
  97 using com::sun::star::sdbc::DriverPropertyInfo;
  98
  99 using com::sun::star::sdbcx::XTablesSupplier;
 100
 101
 102 namespace pq_sdbc_driver
 103 {
 104 #define ASCII_STR(x) OUString( RTL_CONSTASCII_USTRINGPARAM( x ) )
 105
 106 OUString DriverGetImplementationName()
 107 {
 108     static OUString *p;
 109     if (! p )
 110     {
 111         MutexGuard guard( osl::Mutex::getGlobalMutex() );
 112         static OUString instance(
 113             RTL_CONSTASCII_USTRINGPARAM( "org.openoffice.comp.connectivity.pq.Driver" ) );
 114         p = &instance;
 115     }
 116     return *p;
 117 }
 118
 119 Sequence< OUString > DriverGetSupportedServiceNames()
 120 {
 121     static Sequence< OUString > *p;
 122     if( ! p )
 123     {
 124         MutexGuard guard( osl::Mutex::getGlobalMutex() );
 125         OUString tmp( RTL_CONSTASCII_USTRINGPARAM( "com.sun.star.sdbc.Driver" ) );
 126         static Sequence< OUString > instance( &tmp,1 );
 127         p = &instance;
 128     }
 129     return *p;
 130 }
 131
 132 Reference< XConnection > Driver::connect(
 133     const OUString& url,const Sequence< PropertyValue >& info )
 134     throw (SQLException, RuntimeException)
 135 {
 136     if( ! acceptsURL( url ) )  // XDriver spec tells me to do so ...
 137         return Reference< XConnection > ();
 138
 139     Sequence< Any > seq ( 2 );
 140     seq[0] <<= url;
 141     seq[1] <<= info;
 142     return Reference< XConnection> (
 143         m_smgr->createInstanceWithArgumentsAndContext(
 144             OUString(RTL_CONSTASCII_USTRINGPARAM("org.openoffice.comp.connectivity.pq.Connection" ) ),
 145             seq, m_ctx ),
 146         UNO_QUERY );
 147 }
 148
 149 sal_Bool Driver::acceptsURL( const ::rtl::OUString& url )
 150     throw (SQLException, RuntimeException)
 151 {
 152     return url.compareToAscii( RTL_CONSTASCII_STRINGPARAM( "sdbc:postgresql:" ) ) == 0;
 153 }
 154
 155 Sequence< DriverPropertyInfo > Driver::getPropertyInfo(
 156     const OUString& url,const Sequence< PropertyValue >& info )
 157     throw (SQLException, RuntimeException)
 158 {
 159     return Sequence< DriverPropertyInfo > ();
 160 }
 161
 162 sal_Int32  Driver::getMajorVersion(  ) throw (RuntimeException)
 163 {
 164     return PQ_SDBC_MAJOR;
 165 }
 166
 167
 168 sal_Int32 Driver::getMinorVersion(  ) throw (RuntimeException)
 169 {
 170     return PQ_SDBC_MINOR;
 171 }
 172
 173         // XServiceInfo
 174 OUString SAL_CALL Driver::getImplementationName()
 175     throw(::com::sun::star::uno::RuntimeException)
 176 {
 177     return DriverGetImplementationName();
 178 }
 179
 180 sal_Bool Driver::supportsService(const OUString& ServiceName)
 181     throw(::com::sun::star::uno::RuntimeException)
 182 {
 183     Sequence< OUString > serviceNames = DriverGetSupportedServiceNames();
 184     for( int i = 0 ; i < serviceNames.getLength() ; i ++ )
 185         if( serviceNames[i] == ServiceName )
 186             return sal_True;
 187     return sal_False;
 188 }
 189
 190 Sequence< OUString > Driver::getSupportedServiceNames(void)
 191     throw(::com::sun::star::uno::RuntimeException)
 192 {
 193     return DriverGetSupportedServiceNames();
 194 }
 195
 196 // XComponent
 197 void Driver::disposing()
 198 {
 199
 200 }
 201
 202
 203 Reference< XTablesSupplier > Driver::getDataDefinitionByConnection(
 204     const Reference< XConnection >& connection )
 205         throw (SQLException, RuntimeException)
 206 {
 207      return Reference< XTablesSupplier >( connection , UNO_QUERY );
 208 }
 209
 210 Reference< XTablesSupplier > Driver::getDataDefinitionByURL(
 211     const ::rtl::OUString& url, const Sequence< PropertyValue >& info )
 212         throw (SQLException, RuntimeException)
 213 {
 214     return Reference< XTablesSupplier > ( connect( url, info ), UNO_QUERY );
 215 }
 216
 217
 218 Reference< XInterface > DriverCreateInstance( const Reference < XComponentContext > & ctx )
 219 {
 220     Reference< XInterface >  ret = * new Driver( ctx );
 221     return ret;
 222 }
 223
 224
 225
 226
 227 class OOneInstanceComponentFactory :
 228     public MutexHolder,
 229     public WeakComponentImplHelper2< XSingleComponentFactory, XServiceInfo >
 230 {
 231 public:
 232         OOneInstanceComponentFactory(
 233                 const OUString & rImplementationName_,
 234         cppu::ComponentFactoryFunc fptr,
 235                 const Sequence< OUString > & serviceNames,
 236         const Reference< XComponentContext > & defaultContext) :
 237         WeakComponentImplHelper2< XSingleComponentFactory, XServiceInfo >( this->m_mutex ),
 238         m_implName( rImplementationName_ ),
 239         m_create( fptr ),
 240         m_serviceNames( serviceNames ),
 241         m_defaultContext( defaultContext )
 242     {
 243     }
 244
 245     // XSingleComponentFactory
 246     virtual Reference< XInterface > SAL_CALL createInstanceWithContext(
 247         Reference< XComponentContext > const & xContext )
 248         throw (Exception, RuntimeException);
 249     virtual Reference< XInterface > SAL_CALL createInstanceWithArgumentsAndContext(
 250         Sequence< Any > const & rArguments,
 251         Reference< XComponentContext > const & xContext )
 252         throw (Exception, RuntimeException);
 253
 254         // XServiceInfo
 255         OUString SAL_CALL getImplementationName()
 256                 throw(::com::sun::star::uno::RuntimeException)
 257     {
 258         return m_implName;
 259     }
 260     sal_Bool SAL_CALL supportsService(const OUString& ServiceName)
 261                 throw(::com::sun::star::uno::RuntimeException)
 262     {
 263         for( int i = 0 ; i < m_serviceNames.getLength() ; i ++ )
 264             if( m_serviceNames[i] == ServiceName )
 265                 return sal_True;
 266         return sal_False;
 267     }
 268     Sequence< OUString > SAL_CALL getSupportedServiceNames(void)
 269                 throw(::com::sun::star::uno::RuntimeException)
 270     {
 271         return m_serviceNames;
 272     }
 273
 274     // XComponent
 275     virtual void SAL_CALL disposing();
 276
 277 private:
 278         cppu::ComponentFactoryFunc        m_create;
 279         Sequence< OUString >              m_serviceNames;
 280         OUString                                          m_implName;
 281     Reference< XInterface >       m_theInstance;
 282     Reference< XComponentContext > m_defaultContext;
 283 };
 284
 285 Reference< XInterface > OOneInstanceComponentFactory::createInstanceWithArgumentsAndContext(
 286     Sequence< Any > const &rArguments, const Reference< XComponentContext > & ctx )
 287     throw( RuntimeException, Exception )
 288 {
 289     return createInstanceWithContext( ctx );
 290 }
 291
 292 Reference< XInterface > OOneInstanceComponentFactory::createInstanceWithContext(
 293     const Reference< XComponentContext > & ctx )
 294     throw( RuntimeException, Exception )
 295 {
 296     if( ! m_theInstance.is() )
 297     {
 298         // work around the problem in sdbc
 299         Reference< XComponentContext > useCtx = ctx;
 300         if( ! useCtx.is() )
 301             useCtx = m_defaultContext;
 302         Reference< XInterface > theInstance = m_create( useCtx );
 303         MutexGuard guard( osl::Mutex::getGlobalMutex() );
 304         if( ! m_theInstance.is () )
 305         {
 306             m_theInstance = theInstance;
 307         }
 308     }
 309     return m_theInstance;
 310 }
 311
 312 void OOneInstanceComponentFactory::disposing()
 313 {
 314     Reference< XComponent > rComp;
 315     {
 316         MutexGuard guard( osl::Mutex::getGlobalMutex() );
 317         rComp = Reference< XComponent >( m_theInstance, UNO_QUERY );
 318         m_theInstance.clear();
 319     }
 320     if( rComp.is() )
 321         rComp->dispose();
 322 }
 323
 324 //  Reference< XSingleComponentFactory > createOneInstanceComponentFactory(
 325 //      cppu::ComponentFactoryFunc fptr,
 326 //      ::rtl::OUString const & rImplementationName,
 327 //      ::com::sun::star::uno::Sequence< ::rtl::OUString > const & rServiceNames,
 328 //      rtl_ModuleCount * pModCount = 0 )
 329 //      SAL_THROW( () )
 330 //  {
 331 //      return new OOneInstanceComponentFactory( rImplementationName, fptr , rServiceNames);
 332 //  }
 333
 334 }
 335
 336 static struct cppu::ImplementationEntry g_entries[] =
 337 {
 338         {
 339                 pq_sdbc_driver::DriverCreateInstance, pq_sdbc_driver::DriverGetImplementationName,
 340                 pq_sdbc_driver::DriverGetSupportedServiceNames, 0,
 341                 0 , 0
 342         },
 343         { 0, 0, 0, 0, 0, 0 }
 344 };
 345
 346 extern "C"
 347 {
 348
 349 //==================================================================================================
 350 void SAL_CALL component_getImplementationEnvironment(
 351         const sal_Char ** ppEnvTypeName, uno_Environment ** ppEnv )
 352 {
 353         *ppEnvTypeName = CPPU_CURRENT_LANGUAGE_BINDING_NAME;
 354 }
 355 //==================================================================================================
 356 sal_Bool SAL_CALL component_writeInfo(
 357         void * pServiceManager, void * pRegistryKey )
 358 {
 359         return cppu::component_writeInfoHelper( pServiceManager, pRegistryKey, g_entries );
 360 }
 361 //==================================================================================================
 362 void * SAL_CALL component_getFactory(
 363         const sal_Char * pImplName, void * pServiceManager, void * pRegistryKey )
 364 {
 365     // need to extract the defaultcontext, because the way, sdbc
 366     // bypasses the servicemanager, does not allow to use the
 367     // XSingleComponentFactory interface ...
 368         void * pRet = 0;
 369         Reference< XSingleComponentFactory > xFactory;
 370     Reference< XInterface > xSmgr( (XInterface * ) pServiceManager );
 371
 372         for( sal_Int32 i = 0 ; g_entries[i].create ; i ++ )
 373         {
 374                 OUString implName = g_entries[i].getImplementationName();
 375                 if( 0 == implName.compareToAscii( pImplName ) )
 376                 {
 377             Reference< XComponentContext > defaultContext;
 378             Reference< XPropertySet > propSet( xSmgr, UNO_QUERY );
 379             if( propSet.is() )
 380             {
 381                 try
 382                 {
 383                     propSet->getPropertyValue( ASCII_STR( "DefaultContext" ) ) >>= defaultContext;
 384                 }
 385                 catch( com::sun::star::uno::Exception &e )
 386                 {
 387                     // if there is no default context, ignore it
 388                 }
 389             }
 390                         xFactory = new pq_sdbc_driver::OOneInstanceComponentFactory(
 391                                 implName,
 392                                 g_entries[i].create,
 393                                 g_entries[i].getSupportedServiceNames(),
 394                 defaultContext );
 395                 }
 396         }
 397
 398         if( xFactory.is() )
 399         {
 400                 xFactory->acquire();
 401                 pRet = xFactory.get();
 402         }
 403         return pRet;
 404 }
 405
 406 }
 407