connectivity/source/drivers/ado/ATable.cxx

   1 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
   2 /*
   3  * This file is part of the LibreOffice project.
   4  *
   5  * This Source Code Form is subject to the terms of the Mozilla Public
   6  * License, v. 2.0. If a copy of the MPL was not distributed with this
   7  * file, You can obtain one at http://mozilla.org/MPL/2.0/.
   8  *
   9  * This file incorporates work covered by the following license notice:
  10  *
  11  *   Licensed to the Apache Software Foundation (ASF) under one or more
  12  *   contributor license agreements. See the NOTICE file distributed
  13  *   with this work for additional information regarding copyright
  14  *   ownership. The ASF licenses this file to you under the Apache
  15  *   License, Version 2.0 (the "License"); you may not use this file
  16  *   except in compliance with the License. You may obtain a copy of
  17  *   the License at http://www.apache.org/licenses/LICENSE-2.0 .
  18  */
  19
  20 #include "ado/ATable.hxx"
  21 #include "ado/AIndexes.hxx"
  22 #include "ado/AColumns.hxx"
  23 #include "ado/AColumn.hxx"
  24 #include "ado/AKeys.hxx"
  25 #include "ado/AConnection.hxx"
  26 #include <com/sun/star/sdbc/XRow.hpp>
  27 #include <com/sun/star/sdbc/XResultSet.hpp>
  28 #include <com/sun/star/sdbcx/KeyType.hpp>
  29 #include <com/sun/star/sdbc/KeyRule.hpp>
  30 #include <cppuhelper/typeprovider.hxx>
  31 #include <com/sun/star/lang/DisposedException.hpp>
  32 #include <com/sun/star/sdbc/ColumnValue.hpp>
  33 #include "ado/Awrapado.hxx"
  34 #include <comphelper/sequence.hxx>
  35 #include "TConnection.hxx"
  36 #include <comphelper/types.hxx>
  37
  38 using namespace ::comphelper;
  39
  40 using namespace connectivity;
  41 using namespace connectivity::ado;
  42 using namespace com::sun::star::uno;
  43 using namespace com::sun::star::lang;
  44 using namespace com::sun::star::beans;
  45 using namespace com::sun::star::sdbc;
  46 using namespace com::sun::star::container;
  47
  48 // -------------------------------------------------------------------------
  49 OAdoTable::OAdoTable(sdbcx::OCollection* _pTables,sal_Bool _bCase,OCatalog* _pCatalog,_ADOTable* _pTable)
  50     : OTable_TYPEDEF(_pTables,_bCase)
  51     ,m_pCatalog(_pCatalog)
  52 {
  53     construct();
  54     m_aTable = WpADOTable(_pTable);
  55     //  m_aTable.putref_ParentCatalog(_pCatalog->getCatalog());
  56     fillPropertyValues();
  57
  58 }
  59 // -----------------------------------------------------------------------------
  60 OAdoTable::OAdoTable(sdbcx::OCollection* _pTables,sal_Bool _bCase,OCatalog* _pCatalog)
  61     : OTable_TYPEDEF(_pTables,_bCase)
  62     ,m_pCatalog(_pCatalog)
  63 {
  64     construct();
  65     m_aTable.Create();
  66     m_aTable.putref_ParentCatalog(_pCatalog->getCatalog());
  67
  68 }
  69 // -----------------------------------------------------------------------------
  70 void SAL_CALL OAdoTable::disposing(void)
  71 {
  72     OTable_TYPEDEF::disposing();
  73     m_aTable.clear();
  74 }
  75 // -------------------------------------------------------------------------
  76 void OAdoTable::refreshColumns()
  77 {
  78     TStringVector aVector;
  79
  80     WpADOColumns aColumns;
  81     if ( m_aTable.IsValid() )
  82     {
  83         aColumns = m_aTable.get_Columns();
  84         aColumns.fillElementNames(aVector);
  85     }
  86
  87     if(m_pColumns)
  88         m_pColumns->reFill(aVector);
  89     else
  90         m_pColumns = new OColumns(*this,m_aMutex,aVector,aColumns,isCaseSensitive(),m_pCatalog->getConnection());
  91 }
  92 // -------------------------------------------------------------------------
  93 void OAdoTable::refreshKeys()
  94 {
  95     TStringVector aVector;
  96
  97     WpADOKeys aKeys;
  98     if(m_aTable.IsValid())
  99     {
 100         aKeys = m_aTable.get_Keys();
 101         aKeys.fillElementNames(aVector);
 102     }
 103
 104     if(m_pKeys)
 105         m_pKeys->reFill(aVector);
 106     else
 107         m_pKeys = new OKeys(*this,m_aMutex,aVector,aKeys,isCaseSensitive(),m_pCatalog->getConnection());
 108 }
 109 // -------------------------------------------------------------------------
 110 void OAdoTable::refreshIndexes()
 111 {
 112     TStringVector aVector;
 113
 114     WpADOIndexes aIndexes;
 115     if(m_aTable.IsValid())
 116     {
 117         aIndexes = m_aTable.get_Indexes();
 118         aIndexes.fillElementNames(aVector);
 119     }
 120
 121     if(m_pIndexes)
 122         m_pIndexes->reFill(aVector);
 123     else
 124         m_pIndexes = new OIndexes(*this,m_aMutex,aVector,aIndexes,isCaseSensitive(),m_pCatalog->getConnection());
 125 }
 126 //--------------------------------------------------------------------------
 127 Sequence< sal_Int8 > OAdoTable::getUnoTunnelImplementationId()
 128 {
 129     static ::cppu::OImplementationId * pId = 0;
 130     if (! pId)
 131     {
 132         ::osl::MutexGuard aGuard( ::osl::Mutex::getGlobalMutex() );
 133         if (! pId)
 134         {
 135             static ::cppu::OImplementationId aId;
 136             pId = &aId;
 137         }
 138     }
 139     return pId->getImplementationId();
 140 }
 141
 142 // com::sun::star::lang::XUnoTunnel
 143 //------------------------------------------------------------------
 144 sal_Int64 OAdoTable::getSomething( const Sequence< sal_Int8 > & rId ) throw (RuntimeException)
 145 {
 146     return (rId.getLength() == 16 && 0 == memcmp(getUnoTunnelImplementationId().getConstArray(),  rId.getConstArray(), 16 ) )
 147                 ? reinterpret_cast< sal_Int64 >( this )
 148                 : OTable_TYPEDEF::getSomething(rId);
 149 }
 150 // -------------------------------------------------------------------------
 151 // XRename
 152 void SAL_CALL OAdoTable::rename( const OUString& newName ) throw(SQLException, ElementExistException, RuntimeException)
 153 {
 154     ::osl::MutexGuard aGuard(m_aMutex);
 155     checkDisposed(OTableDescriptor_BASE_TYPEDEF::rBHelper.bDisposed);
 156
 157     m_aTable.put_Name(newName);
 158     ADOS::ThrowException(*(m_pCatalog->getConnection()->getConnection()),*this);
 159
 160     OTable_TYPEDEF::rename(newName);
 161 }
 162 // -----------------------------------------------------------------------------
 163 Reference< XDatabaseMetaData> OAdoTable::getMetaData() const
 164 {
 165     return m_pCatalog->getConnection()->getMetaData();
 166 }
 167 // -------------------------------------------------------------------------
 168 // XAlterTable
 169 void SAL_CALL OAdoTable::alterColumnByName( const OUString& colName, const Reference< XPropertySet >& descriptor ) throw(SQLException, NoSuchElementException, RuntimeException)
 170 {
 171     ::osl::MutexGuard aGuard(m_aMutex);
 172     checkDisposed(OTableDescriptor_BASE_TYPEDEF::rBHelper.bDisposed);
 173
 174     sal_Bool bError = sal_True;
 175     OAdoColumn* pColumn = NULL;
 176     if(::comphelper::getImplementation(pColumn,descriptor) && pColumn != NULL)
 177     {
 178         WpADOColumns aColumns = m_aTable.get_Columns();
 179         bError = !aColumns.Delete(colName);
 180         bError = bError || !aColumns.Append(pColumn->getColumnImpl());
 181     }
 182     if(bError)
 183         ADOS::ThrowException(*(m_pCatalog->getConnection()->getConnection()),*this);
 184
 185     m_pColumns->refresh();
 186     refreshColumns();
 187 }
 188 // -------------------------------------------------------------------------
 189 void SAL_CALL OAdoTable::alterColumnByIndex( sal_Int32 index, const Reference< XPropertySet >& descriptor ) throw(SQLException, ::com::sun::star::lang::IndexOutOfBoundsException, RuntimeException)
 190 {
 191     ::osl::MutexGuard aGuard(m_aMutex);
 192     checkDisposed(OTableDescriptor_BASE_TYPEDEF::rBHelper.bDisposed);
 193
 194     Reference< XPropertySet > xOld;
 195     m_pColumns->getByIndex(index) >>= xOld;
 196     if(xOld.is())
 197         alterColumnByName(getString(xOld->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_NAME))),descriptor);
 198 }
 199 // -------------------------------------------------------------------------
 200 void OAdoTable::setFastPropertyValue_NoBroadcast(sal_Int32 nHandle,const Any& rValue)throw (Exception)
 201 {
 202     if(m_aTable.IsValid())
 203     {
 204         switch(nHandle)
 205         {
 206             case PROPERTY_ID_NAME:
 207                 m_aTable.put_Name(getString(rValue));
 208                 break;
 209
 210             case PROPERTY_ID_TYPE:
 211                 OTools::putValue(   m_aTable.get_Properties(),
 212                                 OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_TYPE),
 213                                 getString(rValue));
 214                 break;
 215
 216             case PROPERTY_ID_DESCRIPTION:
 217                 OTools::putValue(   m_aTable.get_Properties(),
 218                                 OUString("Description"),
 219                                 getString(rValue));
 220                 break;
 221
 222             case PROPERTY_ID_SCHEMANAME:
 223                 break;
 224
 225             default:
 226                                 throw Exception();
 227         }
 228     }
 229     OTable_TYPEDEF::setFastPropertyValue_NoBroadcast(nHandle,rValue);
 230 }
 231 // -------------------------------------------------------------------------
 232 void SAL_CALL OAdoTable::acquire() throw()
 233 {
 234     OTable_TYPEDEF::acquire();
 235 }
 236 // -----------------------------------------------------------------------------
 237 void SAL_CALL OAdoTable::release() throw()
 238 {
 239     OTable_TYPEDEF::release();
 240 }
 241 // -----------------------------------------------------------------------------
 242 OUString SAL_CALL OAdoTable::getName() throw(::com::sun::star::uno::RuntimeException)
 243 {
 244       return m_aTable.get_Name();
 245 }
 246
 247 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */