connectivity/source/inc/ado/AConnection.hxx

   1 /*************************************************************************
   2  *
   3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   4  *
   5  * Copyright 2008 by Sun Microsystems, Inc.
   6  *
   7  * OpenOffice.org - a multi-platform office productivity suite
   8  *
   9  * $RCSfile: AConnection.hxx,v $
  10  * $Revision: 1.19 $
  11  *
  12  * This file is part of OpenOffice.org.
  13  *
  14  * OpenOffice.org is free software: you can redistribute it and/or modify
  15  * it under the terms of the GNU Lesser General Public License version 3
  16  * only, as published by the Free Software Foundation.
  17  *
  18  * OpenOffice.org is distributed in the hope that it will be useful,
  19  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  20  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  21  * GNU Lesser General Public License version 3 for more details
  22  * (a copy is included in the LICENSE file that accompanied this code).
  23  *
  24  * You should have received a copy of the GNU Lesser General Public License
  25  * version 3 along with OpenOffice.org.  If not, see
  26  * <http://www.openoffice.org/license.html>
  27  * for a copy of the LGPLv3 License.
  28  *
  29  ************************************************************************/
  30 #ifndef _CONNECTIVITY_ADO_ACONNECTION_HXX_
  31 #define _CONNECTIVITY_ADO_ACONNECTION_HXX_
  32
  33 #include <com/sun/star/sdbc/SQLWarning.hpp>
  34 #include <com/sun/star/sdbcx/XTablesSupplier.hpp>
  35 #include <com/sun/star/beans/PropertyValue.hpp>
  36 #include "OSubComponent.hxx"
  37 #include <map>
  38 #include "connectivity/CommonTools.hxx"
  39 #include "OTypeInfo.hxx"
  40 #include "TConnection.hxx"
  41 #include "ado/Awrapado.hxx"
  42
  43 namespace connectivity
  44 {
  45     namespace ado
  46     {
  47         struct OExtendedTypeInfo
  48         {
  49             ::connectivity::OTypeInfo           aSimpleType;    // the general type info
  50             DataTypeEnum                                        eType;
  51
  52             inline ::rtl::OUString getDBName() const { return aSimpleType.aTypeName; }
  53         };
  54
  55         class WpADOConnection;
  56         class ODriver;
  57         class OCatalog;
  58         typedef ::std::multimap<DataTypeEnum, OExtendedTypeInfo*>               OTypeInfoMap;
  59         typedef connectivity::OMetaConnection                                                   OConnection_BASE;
  60
  61
  62         class OConnection : public OConnection_BASE,
  63                             public connectivity::OSubComponent<OConnection, OConnection_BASE>
  64         {
  65             friend class connectivity::OSubComponent<OConnection, OConnection_BASE>;
  66
  67         protected:
  68             //====================================================================
  69             // Data attributes
  70             //====================================================================
  71             OTypeInfoMap                                m_aTypeInfo;    //      vector containing an entry
  72                                                                                 //  for each row returned by
  73                                                                                 //  DatabaseMetaData.getTypeInfo.
  74             ::com::sun::star::uno::WeakReference< ::com::sun::star::sdbcx::XTablesSupplier>      m_xCatalog;
  75             ODriver*                                    m_pDriver;
  76         private:
  77             WpADOConnection*                    m_pAdoConnection;
  78             OCatalog*                                   m_pCatalog;
  79             sal_Int32                                   m_nEngineType;
  80             sal_Bool                                    m_bClosed;
  81             sal_Bool                                    m_bAutocommit;
  82
  83         protected:
  84             void buildTypeInfo() throw( ::com::sun::star::sdbc::SQLException);
  85         public:
  86
  87             OConnection(ODriver*        _pDriver) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
  88             //  OConnection(const SQLHANDLE _pConnectionHandle);
  89             ~OConnection();
  90             void construct(const ::rtl::OUString& url,const ::com::sun::star::uno::Sequence< ::com::sun::star::beans::PropertyValue >& info);
  91
  92             void closeAllStatements () throw( ::com::sun::star::sdbc::SQLException);
  93
  94             //XUnoTunnel
  95             virtual sal_Int64 SAL_CALL getSomething( const ::com::sun::star::uno::Sequence< sal_Int8 >& aIdentifier ) throw (::com::sun::star::uno::RuntimeException);
  96             static ::com::sun::star::uno::Sequence< sal_Int8 > getUnoTunnelImplementationId();
  97             // XServiceInfo
  98             DECLARE_SERVICE_INFO();
  99             // OComponentHelper
 100             virtual void SAL_CALL disposing(void);
 101             // XInterface
 102             virtual void SAL_CALL release() throw();
 103
 104             // XConnection
 105             virtual ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XStatement > SAL_CALL createStatement(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 106             virtual ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XPreparedStatement > SAL_CALL prepareStatement( const ::rtl::OUString& sql ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 107             virtual ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XPreparedStatement > SAL_CALL prepareCall( const ::rtl::OUString& sql ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 108             virtual ::rtl::OUString SAL_CALL nativeSQL( const ::rtl::OUString& sql ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 109             virtual void SAL_CALL setAutoCommit( sal_Bool autoCommit ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 110             virtual sal_Bool SAL_CALL getAutoCommit(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 111             virtual void SAL_CALL commit(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 112             virtual void SAL_CALL rollback(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 113             virtual sal_Bool SAL_CALL isClosed(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 114             virtual ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XDatabaseMetaData > SAL_CALL getMetaData(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 115             virtual void SAL_CALL setReadOnly( sal_Bool readOnly ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 116             virtual sal_Bool SAL_CALL isReadOnly(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 117             virtual void SAL_CALL setCatalog( const ::rtl::OUString& catalog ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 118             virtual ::rtl::OUString SAL_CALL getCatalog(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 119             virtual void SAL_CALL setTransactionIsolation( sal_Int32 level ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 120             virtual sal_Int32 SAL_CALL getTransactionIsolation(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 121             virtual ::com::sun::star::uno::Reference< ::com::sun::star::container::XNameAccess > SAL_CALL getTypeMap(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 122             virtual void SAL_CALL setTypeMap( const ::com::sun::star::uno::Reference< ::com::sun::star::container::XNameAccess >& typeMap ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 123             // XCloseable
 124             virtual void SAL_CALL close(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 125             // XWarningsSupplier
 126             virtual ::com::sun::star::uno::Any SAL_CALL getWarnings(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 127             virtual void SAL_CALL clearWarnings(  ) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException);
 128             //
 129             WpADOConnection* getConnection() { return m_pAdoConnection; }
 130             void setCatalog(const ::com::sun::star::uno::WeakReference< ::com::sun::star::sdbcx::XTablesSupplier>& _xCat) { m_xCatalog = _xCat; }
 131             void setCatalog(OCatalog* _pCatalog) { m_pCatalog = _pCatalog; }
 132
 133             const OTypeInfoMap* getTypeInfo() const { return &m_aTypeInfo;}
 134             OCatalog* getAdoCatalog() const
 135             {
 136                 if ( m_xCatalog.get().is() )
 137                     return m_pCatalog;
 138                 return NULL;
 139             }
 140
 141             sal_Int32 getEngineType()   const { return m_nEngineType; }
 142             ODriver*  getDriver()               const { return m_pDriver; }
 143
 144             static const OExtendedTypeInfo* getTypeInfoFromType(const OTypeInfoMap& _rTypeInfo,
 145                                DataTypeEnum _nType,
 146                                const ::rtl::OUString& _sTypeName,
 147                                sal_Int32 _nPrecision,
 148                                sal_Int32 _nScale,
 149                                sal_Bool& _brForceToType);
 150         };
 151     }
 152 }
 153 #endif // _CONNECTIVITY_ADO_ACONNECTION_HXX_
 154