LCOV - code coverage report
Current view: top level - connectivity/source/drivers/file - FConnection.cxx (source / functions) Hit Total Coverage
Test: commit c8344322a7af75b84dd3ca8f78b05543a976dfd5 Lines: 100 203 49.3 %
Date: 2015-06-13 12:38:46 Functions: 13 36 36.1 %
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 <sal/config.h>
      21             : 
      22             : #include <comphelper/processfactory.hxx>
      23             : #include <cppuhelper/typeprovider.hxx>
      24             : #include "file/FConnection.hxx"
      25             : #include "file/FDatabaseMetaData.hxx"
      26             : #include "file/FDriver.hxx"
      27             : #include "file/FStatement.hxx"
      28             : #include "file/FPreparedStatement.hxx"
      29             : #include <com/sun/star/sdbc/ColumnValue.hpp>
      30             : #include <com/sun/star/sdbc/XRow.hpp>
      31             : #include <com/sun/star/lang/DisposedException.hpp>
      32             : #include <com/sun/star/container/XChild.hpp>
      33             : #include <com/sun/star/ucb/XContent.hpp>
      34             : #include <com/sun/star/ucb/XContentIdentifier.hpp>
      35             : #include <tools/urlobj.hxx>
      36             : #include "file/FCatalog.hxx"
      37             : #include <unotools/pathoptions.hxx>
      38             : #include <ucbhelper/content.hxx>
      39             : #include <connectivity/dbcharset.hxx>
      40             : #include <connectivity/dbexception.hxx>
      41             : #include <osl/thread.h>
      42             : #include <osl/nlsupport.h>
      43             : #include "resource/file_res.hrc"
      44             : 
      45             : using namespace connectivity::file;
      46             : using namespace dbtools;
      47             : 
      48             : using namespace com::sun::star::uno;
      49             : using namespace com::sun::star::lang;
      50             : using namespace com::sun::star::beans;
      51             : using namespace com::sun::star::sdbc;
      52             : using namespace com::sun::star::sdbcx;
      53             : using namespace com::sun::star::container;
      54             : using namespace com::sun::star::ucb;
      55             : using namespace ::ucbhelper;
      56             : typedef connectivity::OMetaConnection OConnection_BASE;
      57             : 
      58          38 : OConnection::OConnection(OFileDriver*   _pDriver)
      59             :     : OSubComponent<OConnection, OConnection_BASE>(static_cast<cppu::OWeakObject*>(_pDriver), this)
      60             :     , m_pDriver(_pDriver)
      61             :     , m_bClosed(false)
      62             :     , m_bAutoCommit(false)
      63             :     , m_bReadOnly(false)
      64             :     , m_bShowDeleted(false)
      65             :     , m_bCaseSensitiveExtension( true )
      66             :     , m_bCheckSQL92(false)
      67          38 :     , m_bDefaultTextEncoding(false)
      68             : {
      69          38 :     m_nTextEncoding = RTL_TEXTENCODING_DONTKNOW;
      70          38 : }
      71             : 
      72          74 : OConnection::~OConnection()
      73             : {
      74          37 :     if(!isClosed(  ))
      75           0 :         close();
      76          37 : }
      77             : 
      78        2673 : void SAL_CALL OConnection::release() throw()
      79             : {
      80        2673 :     relase_ChildImpl();
      81        2673 : }
      82             : 
      83             : 
      84          30 : bool OConnection::matchesExtension( const OUString& _rExt ) const
      85             : {
      86          30 :     if ( isCaseSensitveExtension() )
      87          30 :         return ( getExtension() == _rExt );
      88             : 
      89           0 :     OUString sMyExtension( getExtension().toAsciiLowerCase() );
      90           0 :     OUString sExt( _rExt.toAsciiLowerCase() );
      91             : 
      92           0 :     return sMyExtension == sExt;
      93             : }
      94             : 
      95             : 
      96          29 : void OConnection::construct(const OUString& url,const Sequence< PropertyValue >& info)
      97             :     throw( css::sdbc::SQLException,
      98             :            css::uno::RuntimeException,
      99             :            css::uno::DeploymentException)
     100             : {
     101          29 :     osl_atomic_increment( &m_refCount );
     102             : 
     103          29 :     OUString aExt;
     104          29 :     const PropertyValue *pIter  = info.getConstArray();
     105          29 :     const PropertyValue *pEnd    = pIter + info.getLength();
     106         118 :     for(;pIter != pEnd;++pIter)
     107             :     {
     108          89 :         if( pIter->Name == "Extension" )
     109           0 :             OSL_VERIFY( pIter->Value >>= aExt );
     110          89 :         else if( pIter->Name == "CharSet" )
     111             :         {
     112          29 :             OUString sIanaName;
     113          29 :             OSL_VERIFY( pIter->Value >>= sIanaName );
     114             : 
     115          58 :             ::dbtools::OCharsetMap aLookupIanaName;
     116          58 :             ::dbtools::OCharsetMap::const_iterator aLookup = aLookupIanaName.find(sIanaName, ::dbtools::OCharsetMap::IANA());
     117          29 :             if (aLookup != aLookupIanaName.end())
     118          29 :                 m_nTextEncoding = (*aLookup).getEncoding();
     119             :             else
     120          29 :                 m_nTextEncoding = RTL_TEXTENCODING_DONTKNOW;
     121             :         }
     122          60 :         else if( pIter->Name == "ShowDeleted" )
     123             :         {
     124          29 :             OSL_VERIFY( pIter->Value >>= m_bShowDeleted );
     125             :         }
     126          31 :         else if( pIter->Name == "EnableSQL92Check" )
     127             :         {
     128          29 :             pIter->Value >>= m_bCheckSQL92;
     129             :         }
     130             :     } // for(;pIter != pEnd;++pIter)
     131             : 
     132             :     {
     133          29 :         sal_Int32 nLen = url.indexOf(':');
     134          29 :         nLen = url.indexOf(':',nLen+1);
     135          29 :         OUString aDSN(url.copy(nLen+1));
     136             : 
     137          58 :         OUString aFileName = aDSN;
     138          58 :         INetURLObject aURL;
     139          29 :         aURL.SetSmartProtocol(INetProtocol::File);
     140             :         {
     141          29 :             SvtPathOptions aPathOptions;
     142          29 :             aFileName = aPathOptions.SubstituteVariable(aFileName);
     143             :         }
     144             : 
     145          29 :         aURL.SetSmartURL(aFileName);
     146             : 
     147          58 :         setURL(aURL.GetMainURL(INetURLObject::NO_DECODE));
     148             :     }
     149             : 
     150          29 :     if ( m_nTextEncoding == RTL_TEXTENCODING_DONTKNOW )
     151             :     {
     152             :         //m_nTextEncoding = osl_getTextEncodingFromLocale(NULL);
     153          22 :         m_nTextEncoding = osl_getThreadTextEncoding();
     154          22 :         m_bDefaultTextEncoding = true;
     155             :     }
     156             : 
     157          29 :     if ( !aExt.isEmpty() )
     158           0 :         m_aFilenameExtension = aExt;
     159             : 
     160             :     try
     161             :     {
     162          29 :         ::ucbhelper::Content aFile;
     163             :         try
     164             :         {
     165          29 :             aFile = ::ucbhelper::Content(getURL(), Reference< XCommandEnvironment >(), comphelper::getProcessComponentContext());
     166             :         }
     167           0 :         catch(ContentCreationException& e)
     168             :         {
     169           0 :             throwUrlNotValid(getURL(),e.Message);
     170             :         }
     171             : 
     172             :         // set fields to fetch
     173          58 :         Sequence< OUString > aProps(1);
     174          29 :         OUString* pProps = aProps.getArray();
     175          29 :         pProps[ 0 ] = "Title";
     176             : 
     177             :         try
     178             :         {
     179          29 :             if (aFile.isFolder())
     180             :             {
     181          29 :                 m_xDir = aFile.createDynamicCursor(aProps, ::ucbhelper::INCLUDE_DOCUMENTS_ONLY );
     182          29 :                 m_xContent = aFile.get();
     183             :             }
     184           0 :             else if (aFile.isDocument())
     185             :             {
     186           0 :                 Reference<XContent> xParent(Reference<XChild>(aFile.get(),UNO_QUERY)->getParent(),UNO_QUERY);
     187           0 :                 Reference<XContentIdentifier> xIdent = xParent->getIdentifier();
     188           0 :                 m_xContent = xParent;
     189             : 
     190           0 :                 ::ucbhelper::Content aParent(xIdent->getContentIdentifier(), Reference< XCommandEnvironment >(), comphelper::getProcessComponentContext());
     191           0 :                 m_xDir = aParent.createDynamicCursor(aProps, ::ucbhelper::INCLUDE_DOCUMENTS_ONLY );
     192             :             }
     193             :             else
     194             :             {
     195             :                 OSL_FAIL("OConnection::construct: ::ucbhelper::Content isn't a folde nor a document! How that?!");
     196           0 :                 throw SQLException();
     197             :             }
     198             :         }
     199           0 :         catch(Exception& e) // a exception is thrown when no file exists
     200             :         {
     201           0 :             throwUrlNotValid(getURL(),e.Message);
     202             :         }
     203          29 :         if(!m_xDir.is() || !m_xContent.is())
     204           0 :             throwUrlNotValid(getURL(),OUString());
     205             : 
     206          29 :         if (m_aFilenameExtension.indexOf('*') >= 0 || m_aFilenameExtension.indexOf('?') >= 0)
     207          29 :             throw SQLException();
     208             :     }
     209           0 :     catch(const Exception&)
     210             :     {
     211           0 :         osl_atomic_decrement( &m_refCount );
     212           0 :         throw;
     213             :     }
     214             : 
     215          29 :     osl_atomic_decrement( &m_refCount );
     216          29 : }
     217             : // XServiceInfo
     218             : 
     219           0 : IMPLEMENT_SERVICE_INFO(OConnection, "com.sun.star.sdbc.drivers.file.Connection", "com.sun.star.sdbc.Connection")
     220             : 
     221             : 
     222           0 : Reference< XStatement > SAL_CALL OConnection::createStatement(  ) throw(SQLException, RuntimeException, std::exception)
     223             : {
     224           0 :     ::osl::MutexGuard aGuard( m_aMutex );
     225           0 :     checkDisposed(OConnection_BASE::rBHelper.bDisposed);
     226             : 
     227             : 
     228           0 :     Reference< XStatement > xReturn = new OStatement(this);
     229           0 :     m_aStatements.push_back(WeakReferenceHelper(xReturn));
     230           0 :     return xReturn;
     231             : }
     232             : 
     233           0 : Reference< XPreparedStatement > SAL_CALL OConnection::prepareStatement( const OUString& sql ) throw(SQLException, RuntimeException, std::exception)
     234             : {
     235           0 :     ::osl::MutexGuard aGuard( m_aMutex );
     236           0 :     checkDisposed(OConnection_BASE::rBHelper.bDisposed);
     237             : 
     238             : 
     239           0 :     OPreparedStatement* pStmt = new OPreparedStatement(this);
     240           0 :     Reference< XPreparedStatement > xHoldAlive = pStmt;
     241           0 :     pStmt->construct(sql);
     242           0 :     m_aStatements.push_back(WeakReferenceHelper(*pStmt));
     243           0 :     return pStmt;
     244             : }
     245             : 
     246           0 : Reference< XPreparedStatement > SAL_CALL OConnection::prepareCall( const OUString& /*sql*/ ) throw(SQLException, RuntimeException, std::exception)
     247             : {
     248           0 :     throwFeatureNotImplementedSQLException( "XConnection::prepareCall", *this );
     249           0 :     return NULL;
     250             : }
     251             : 
     252           0 : OUString SAL_CALL OConnection::nativeSQL( const OUString& sql ) throw(SQLException, RuntimeException, std::exception)
     253             : {
     254           0 :     return sql;
     255             : }
     256             : 
     257           0 : void SAL_CALL OConnection::setAutoCommit( sal_Bool autoCommit ) throw(SQLException, RuntimeException, std::exception)
     258             : {
     259           0 :     ::osl::MutexGuard aGuard( m_aMutex );
     260           0 :     checkDisposed(OConnection_BASE::rBHelper.bDisposed);
     261             : 
     262           0 :     m_bAutoCommit = autoCommit;
     263           0 : }
     264             : 
     265           0 : sal_Bool SAL_CALL OConnection::getAutoCommit(  ) throw(SQLException, RuntimeException, std::exception)
     266             : {
     267           0 :     ::osl::MutexGuard aGuard( m_aMutex );
     268           0 :     checkDisposed(OConnection_BASE::rBHelper.bDisposed);
     269             : 
     270           0 :     return m_bAutoCommit;
     271             : }
     272             : 
     273           0 : void SAL_CALL OConnection::commit(  ) throw(SQLException, RuntimeException, std::exception)
     274             : {
     275           0 : }
     276             : 
     277           0 : void SAL_CALL OConnection::rollback(  ) throw(SQLException, RuntimeException, std::exception)
     278             : {
     279           0 : }
     280             : 
     281          37 : sal_Bool SAL_CALL OConnection::isClosed(  ) throw(SQLException, RuntimeException, std::exception)
     282             : {
     283          37 :     ::osl::MutexGuard aGuard( m_aMutex );
     284             : 
     285          37 :     return OConnection_BASE::rBHelper.bDisposed;
     286             : }
     287             : 
     288           0 : Reference< XDatabaseMetaData > SAL_CALL OConnection::getMetaData(  ) throw(SQLException, RuntimeException, std::exception)
     289             : {
     290           0 :     ::osl::MutexGuard aGuard( m_aMutex );
     291           0 :     checkDisposed(OConnection_BASE::rBHelper.bDisposed);
     292             : 
     293             : 
     294           0 :     Reference< XDatabaseMetaData > xMetaData = m_xMetaData;
     295           0 :     if(!xMetaData.is())
     296             :     {
     297           0 :         xMetaData = new ODatabaseMetaData(this);
     298           0 :         m_xMetaData = xMetaData;
     299             :     }
     300             : 
     301           0 :     return xMetaData;
     302             : }
     303             : 
     304           0 : void SAL_CALL OConnection::setReadOnly( sal_Bool readOnly ) throw(SQLException, RuntimeException, std::exception)
     305             : {
     306           0 :     ::osl::MutexGuard aGuard( m_aMutex );
     307           0 :     checkDisposed(OConnection_BASE::rBHelper.bDisposed);
     308             : 
     309             : 
     310           0 :     m_bReadOnly = readOnly;
     311           0 : }
     312             : 
     313           0 : sal_Bool SAL_CALL OConnection::isReadOnly(  ) throw(SQLException, RuntimeException, std::exception)
     314             : {
     315           0 :     ::osl::MutexGuard aGuard( m_aMutex );
     316           0 :     checkDisposed(OConnection_BASE::rBHelper.bDisposed);
     317             : 
     318             : 
     319           0 :     return m_bReadOnly;
     320             : }
     321             : 
     322           0 : void SAL_CALL OConnection::setCatalog( const OUString& /*catalog*/ ) throw(SQLException, RuntimeException, std::exception)
     323             : {
     324           0 :     throwFeatureNotImplementedSQLException( "XConnection::setCatalog", *this );
     325           0 : }
     326             : 
     327           0 : OUString SAL_CALL OConnection::getCatalog(  ) throw(SQLException, RuntimeException, std::exception)
     328             : {
     329           0 :     return OUString();
     330             : }
     331             : 
     332           0 : void SAL_CALL OConnection::setTransactionIsolation( sal_Int32 /*level*/ ) throw(SQLException, RuntimeException, std::exception)
     333             : {
     334           0 :     throwFeatureNotImplementedSQLException( "XConnection::setTransactionIsolation", *this );
     335           0 : }
     336             : 
     337           0 : sal_Int32 SAL_CALL OConnection::getTransactionIsolation(  ) throw(SQLException, RuntimeException, std::exception)
     338             : {
     339           0 :     return 0;
     340             : }
     341             : 
     342           0 : Reference< XNameAccess > SAL_CALL OConnection::getTypeMap(  ) throw(SQLException, RuntimeException, std::exception)
     343             : {
     344           0 :     return NULL;
     345             : }
     346             : 
     347           0 : void SAL_CALL OConnection::setTypeMap( const Reference< XNameAccess >& /*typeMap*/ ) throw(SQLException, RuntimeException, std::exception)
     348             : {
     349           0 : }
     350             : 
     351             : // XCloseable
     352          37 : void SAL_CALL OConnection::close(  ) throw(SQLException, RuntimeException, std::exception)
     353             : {
     354             :     {
     355          37 :         ::osl::MutexGuard aGuard( m_aMutex );
     356          37 :         checkDisposed(OConnection_BASE::rBHelper.bDisposed);
     357             : 
     358             :     }
     359          37 :     dispose();
     360          37 : }
     361             : 
     362             : // XWarningsSupplier
     363           2 : Any SAL_CALL OConnection::getWarnings(  ) throw(SQLException, RuntimeException, std::exception)
     364             : {
     365           2 :     return Any();
     366             : }
     367             : 
     368           2 : void SAL_CALL OConnection::clearWarnings(  ) throw(SQLException, RuntimeException, std::exception)
     369             : {
     370           2 : }
     371             : 
     372          37 : void OConnection::disposing()
     373             : {
     374          37 :     ::osl::MutexGuard aGuard(m_aMutex);
     375          37 :     OConnection_BASE::disposing();
     376             : 
     377          37 :     m_bClosed   = true;
     378          37 : m_xDir.clear();
     379          37 : m_xContent.clear();
     380          37 :     m_xCatalog  = WeakReference< XTablesSupplier>();
     381             : 
     382          37 :     dispose_ChildImpl();
     383          37 : }
     384             : 
     385           0 : Reference< XTablesSupplier > OConnection::createCatalog()
     386             : {
     387           0 :     ::osl::MutexGuard aGuard( m_aMutex );
     388           0 :     Reference< XTablesSupplier > xTab = m_xCatalog;
     389           0 :     if(!xTab.is())
     390             :     {
     391           0 :         xTab = new OFileCatalog(this);
     392           0 :         m_xCatalog = xTab;
     393             :     }
     394           0 :     return xTab;
     395             : }
     396             : 
     397         100 : Reference< XDynamicResultSet > OConnection::getDir() const
     398             : {
     399         100 :     Reference<XDynamicResultSet> xContent;
     400         200 :     Sequence< OUString > aProps(1);
     401         100 :     OUString* pProps = aProps.getArray();
     402         100 :     pProps[ 0 ] = "Title";
     403             :     try
     404             :     {
     405         100 :         Reference<XContentIdentifier> xIdent = getContent()->getIdentifier();
     406         200 :         ::ucbhelper::Content aParent(xIdent->getContentIdentifier(), Reference< XCommandEnvironment >(), comphelper::getProcessComponentContext());
     407         200 :         xContent = aParent.createDynamicCursor(aProps, ::ucbhelper::INCLUDE_DOCUMENTS_ONLY );
     408             :     }
     409           0 :     catch(Exception&)
     410             :     {
     411             :     }
     412         200 :     return xContent;
     413             : }
     414             : 
     415          38 : sal_Int64 SAL_CALL OConnection::getSomething( const Sequence< sal_Int8 >& rId ) throw (RuntimeException, std::exception)
     416             : {
     417         152 :     return (rId.getLength() == 16 && 0 == memcmp(getUnoTunnelImplementationId().getConstArray(),  rId.getConstArray(), 16 ) )
     418             :         ? reinterpret_cast< sal_Int64 >( this )
     419         152 :         : (sal_Int64)0;
     420             : }
     421             : 
     422          76 : Sequence< sal_Int8 > OConnection::getUnoTunnelImplementationId()
     423             : {
     424             :     static ::cppu::OImplementationId * pId = 0;
     425          76 :     if (! pId)
     426             :     {
     427          11 :         ::osl::MutexGuard aGuard( ::osl::Mutex::getGlobalMutex() );
     428          11 :         if (! pId)
     429             :         {
     430          11 :             static ::cppu::OImplementationId aId;
     431          11 :             pId = &aId;
     432          11 :         }
     433             :     }
     434          76 :     return pId->getImplementationId();
     435             : }
     436             : 
     437           0 : void OConnection::throwUrlNotValid(const OUString & _rsUrl,const OUString & _rsMessage)
     438             : {
     439           0 :     SQLException aError;
     440           0 :     aError.Message = getResources().getResourceStringWithSubstitution(
     441             :                 STR_NO_VALID_FILE_URL,
     442             :                 "$URL$", _rsUrl
     443           0 :             );
     444             : 
     445           0 :     aError.SQLState = "S1000";
     446           0 :     aError.ErrorCode = 0;
     447           0 :     aError.Context = static_cast< XConnection* >(this);
     448           0 :     if (!_rsMessage.isEmpty())
     449           0 :         aError.NextException <<= SQLException(_rsMessage, aError.Context, OUString(), 0, Any());
     450             : 
     451           0 :     throw aError;
     452             : }
     453             : 
     454             : 
     455             : 
     456             : 
     457             : /* vim:set shiftwidth=4 softtabstop=4 expandtab: */

Generated by: LCOV version 1.11