LCOV - code coverage report
Current view: top level - connectivity/source/commontools - TColumnsHelper.cxx (source / functions) Hit Total Coverage
Test: commit c8344322a7af75b84dd3ca8f78b05543a976dfd5 Lines: 45 83 54.2 %
Date: 2015-06-13 12:38:46 Functions: 5 10 50.0 %
Legend: Lines: hit not hit

          Line data    Source code
       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 <connectivity/TColumnsHelper.hxx>
      21             : #include <connectivity/sdbcx/VColumn.hxx>
      22             : #include <com/sun/star/sdbc/XRow.hpp>
      23             : #include <com/sun/star/sdbc/XResultSet.hpp>
      24             : #include <com/sun/star/sdbc/DataType.hpp>
      25             : #include <com/sun/star/sdbc/ColumnValue.hpp>
      26             : #include <com/sun/star/sdbcx/KeyType.hpp>
      27             : #include <com/sun/star/sdbcx/XColumnsSupplier.hpp>
      28             : #include <com/sun/star/sdbcx/XKeysSupplier.hpp>
      29             : #include <comphelper/types.hxx>
      30             : #include <connectivity/dbtools.hxx>
      31             : #include "TConnection.hxx"
      32             : #include <connectivity/TTableHelper.hxx>
      33             : #include <comphelper/property.hxx>
      34             : 
      35             : using namespace ::comphelper;
      36             : 
      37             : 
      38             : using namespace connectivity::sdbcx;
      39             : using namespace connectivity;
      40             : using namespace dbtools;
      41             : using namespace ::com::sun::star::uno;
      42             : using namespace ::com::sun::star::beans;
      43             : using namespace ::com::sun::star::sdbcx;
      44             : using namespace ::com::sun::star::sdbc;
      45             : using namespace ::com::sun::star::container;
      46             : using namespace ::com::sun::star::lang;
      47             : 
      48             : namespace connectivity
      49             : {
      50           9 :     class OColumnsHelperImpl
      51             :     {
      52             :     public:
      53           9 :         explicit OColumnsHelperImpl(bool _bCase)
      54           9 :             : m_aColumnInfo(_bCase)
      55             :         {
      56           9 :         }
      57             :         ColumnInformationMap m_aColumnInfo;
      58             :     };
      59             : }
      60             : 
      61       13727 : OColumnsHelper::OColumnsHelper( ::cppu::OWeakObject& _rParent
      62             :                                 ,bool _bCase
      63             :                                 ,::osl::Mutex& _rMutex
      64             :                                 ,const TStringVector &_rVector
      65             :                                 ,bool _bUseHardRef
      66             :             ) : OCollection(_rParent,_bCase,_rMutex,_rVector,false,_bUseHardRef)
      67             :     ,m_pImpl(NULL)
      68       13727 :     ,m_pTable(NULL)
      69             : {
      70       13727 : }
      71             : 
      72       27454 : OColumnsHelper::~OColumnsHelper()
      73             : {
      74       13727 :     delete m_pImpl;
      75       13727 :     m_pImpl = NULL;
      76       13727 : }
      77             : 
      78             : 
      79          43 : sdbcx::ObjectType OColumnsHelper::createObject(const OUString& _rName)
      80             : {
      81             :     OSL_ENSURE(m_pTable,"NO Table set. Error!");
      82          43 :     Reference<XConnection> xConnection = m_pTable->getConnection();
      83             : 
      84          43 :     if ( !m_pImpl )
      85           9 :         m_pImpl = new OColumnsHelperImpl(isCaseSensitive());
      86             : 
      87          43 :     bool bQueryInfo     = true;
      88          43 :     bool bAutoIncrement = false;
      89          43 :     bool bIsCurrency    = false;
      90          43 :     sal_Int32 nDataType     = DataType::OTHER;
      91             : 
      92          43 :     ColumnInformationMap::iterator aFind = m_pImpl->m_aColumnInfo.find(_rName);
      93          43 :     if ( aFind == m_pImpl->m_aColumnInfo.end() ) // we have to fill it
      94             :     {
      95           9 :         OUString sComposedName = ::dbtools::composeTableNameForSelect( xConnection, m_pTable );
      96           9 :         collectColumnInformation(xConnection,sComposedName,OUString("*") ,m_pImpl->m_aColumnInfo);
      97           9 :         aFind = m_pImpl->m_aColumnInfo.find(_rName);
      98             :     }
      99          43 :     if ( aFind != m_pImpl->m_aColumnInfo.end() )
     100             :     {
     101          43 :         bQueryInfo      = false;
     102          43 :         bAutoIncrement  = aFind->second.first.first;
     103          43 :         bIsCurrency     = aFind->second.first.second;
     104          43 :         nDataType       = aFind->second.second;
     105             :     } // if ( aFind != m_pImpl->m_aColumnInfo.end() )
     106             : 
     107          43 :     sdbcx::ObjectType xRet;
     108          43 :     const ColumnDesc* pColDesc = m_pTable->getColumnDescription(_rName);
     109          43 :     if ( pColDesc )
     110             :     {
     111          43 :         Reference<XPropertySet> xPr = m_pTable;
     112          86 :         const Reference<XNameAccess> xPrimaryKeyColumns = getPrimaryKeyColumns_throw(xPr);
     113          43 :         sal_Int32 nField11 = pColDesc->nField11;
     114          43 :         if ( nField11 != ColumnValue::NO_NULLS && xPrimaryKeyColumns.is() && xPrimaryKeyColumns->hasByName(_rName) )
     115             :         {
     116           0 :             nField11 = ColumnValue::NO_NULLS;
     117             :         } // if ( xKeys.is() )
     118          43 :         ::dbtools::OPropertyMap& rPropMap = OMetaConnection::getPropMap();
     119          86 :         OUString aCatalog, aSchema, aTable;
     120          43 :         m_pTable->getPropertyValue(rPropMap.getNameByIndex(PROPERTY_ID_CATALOGNAME)) >>= aCatalog;
     121          43 :         m_pTable->getPropertyValue(rPropMap.getNameByIndex(PROPERTY_ID_SCHEMANAME))  >>= aSchema;
     122          43 :         m_pTable->getPropertyValue(rPropMap.getNameByIndex(PROPERTY_ID_NAME))        >>= aTable;
     123             :         connectivity::sdbcx::OColumn* pRet = new connectivity::sdbcx::OColumn(_rName,
     124             :                                                 pColDesc->aField6,
     125             :                                                 pColDesc->sField13,
     126             :                                                 pColDesc->sField12,
     127             :                                                 nField11,
     128             :                                                 pColDesc->nField7,
     129             :                                                 pColDesc->nField9,
     130             :                                                 pColDesc->nField5,
     131             :                                                 bAutoIncrement,
     132             :                                                 false,
     133             :                                                 bIsCurrency,
     134          43 :                                                 isCaseSensitive(),
     135             :                                                 aCatalog,
     136             :                                                 aSchema,
     137          43 :                                                 aTable);
     138             : 
     139          86 :         xRet = pRet;
     140             :     }
     141             :     else
     142             :     {
     143             : 
     144             :         xRet.set(::dbtools::createSDBCXColumn(  m_pTable,
     145             :                                                 xConnection,
     146             :                                                 _rName,
     147           0 :                                                 isCaseSensitive(),
     148             :                                                 bQueryInfo,
     149             :                                                 bAutoIncrement,
     150             :                                                 bIsCurrency,
     151           0 :                                                 nDataType),UNO_QUERY);
     152             :     }
     153          43 :     return xRet;
     154             : }
     155             : 
     156             : 
     157           0 : void OColumnsHelper::impl_refresh() throw(RuntimeException)
     158             : {
     159           0 :     if ( m_pTable )
     160             :     {
     161           0 :         m_pImpl->m_aColumnInfo.clear();
     162           0 :         m_pTable->refreshColumns();
     163             :     }
     164           0 : }
     165             : 
     166           0 : Reference< XPropertySet > OColumnsHelper::createDescriptor()
     167             : {
     168           0 :     return new OColumn(true);
     169             : }
     170             : 
     171             : // XAppend
     172           0 : sdbcx::ObjectType OColumnsHelper::appendObject( const OUString& _rForName, const Reference< XPropertySet >& descriptor )
     173             : {
     174           0 :     ::osl::MutexGuard aGuard(m_rMutex);
     175             :     OSL_ENSURE(m_pTable,"OColumnsHelper::appendByDescriptor: Table is null!");
     176           0 :     if ( !m_pTable || m_pTable->isNew() )
     177           0 :         return cloneDescriptor( descriptor );
     178             : 
     179           0 :     Reference<XDatabaseMetaData> xMetaData = m_pTable->getConnection()->getMetaData();
     180           0 :     OUString aSql = "ALTER TABLE " +
     181           0 :         ::dbtools::composeTableName( xMetaData, m_pTable, ::dbtools::eInTableDefinitions, false, false, true ) +
     182           0 :         " ADD " +
     183           0 :         ::dbtools::createStandardColumnPart(descriptor,m_pTable->getConnection(),NULL,m_pTable->getTypeCreatePattern());
     184             : 
     185           0 :     Reference< XStatement > xStmt = m_pTable->getConnection()->createStatement(  );
     186           0 :     if ( xStmt.is() )
     187             :     {
     188           0 :         xStmt->execute(aSql);
     189           0 :         ::comphelper::disposeComponent(xStmt);
     190             :     }
     191           0 :     return createObject( _rForName );
     192             : }
     193             : 
     194             : // XDrop
     195           0 : void OColumnsHelper::dropObject(sal_Int32 /*_nPos*/, const OUString& _sElementName)
     196             : {
     197             :     OSL_ENSURE(m_pTable,"OColumnsHelper::dropByName: Table is null!");
     198           0 :     if ( m_pTable && !m_pTable->isNew() )
     199             :     {
     200           0 :         Reference<XDatabaseMetaData> xMetaData = m_pTable->getConnection()->getMetaData();
     201           0 :         OUString aQuote  = xMetaData->getIdentifierQuoteString(  );
     202           0 :         OUString aSql = "ALTER TABLE " +
     203           0 :             ::dbtools::composeTableName( xMetaData, m_pTable, ::dbtools::eInTableDefinitions, false, false, true ) +
     204           0 :             " DROP " +
     205           0 :             ::dbtools::quoteName( aQuote,_sElementName);
     206             : 
     207           0 :         Reference< XStatement > xStmt = m_pTable->getConnection()->createStatement(  );
     208           0 :         if ( xStmt.is() )
     209             :         {
     210           0 :             xStmt->execute(aSql);
     211           0 :             ::comphelper::disposeComponent(xStmt);
     212           0 :         }
     213             :     }
     214           0 : }
     215             : 
     216             : 
     217             : 
     218             : 
     219             : /* vim:set shiftwidth=4 softtabstop=4 expandtab: */

Generated by: LCOV version 1.11