connectivity/source/drivers/calc/CConnection.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 <calc/CConnection.hxx>
  21 #include <calc/CDatabaseMetaData.hxx>
  22 #include <calc/CCatalog.hxx>
  23 #include <calc/CDriver.hxx>
  24 #include <resource/sharedresources.hxx>
  25 #include <com/sun/star/frame/Desktop.hpp>
  26 #include <com/sun/star/sheet/XSpreadsheetDocument.hpp>
  27 #include <tools/urlobj.hxx>
  28 #include <component/CPreparedStatement.hxx>
  29 #include <component/CStatement.hxx>
  30 #include <unotools/pathoptions.hxx>
  31 #include <connectivity/dbexception.hxx>
  32 #include <cppuhelper/exc_hlp.hxx>
  33 #include <strings.hrc>
  34
  35 using namespace connectivity::calc;
  36 using namespace connectivity::file;
  37
  38 typedef connectivity::file::OConnection OConnection_BASE;
  39
  40
  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::lang;
  46 using namespace ::com::sun::star::frame;
  47 using namespace ::com::sun::star::sheet;
  48
  49
  50 OCalcConnection::OCalcConnection(ODriver* _pDriver) : OConnection(_pDriver),m_nDocCount(0)
  51 {
  52     // m_aFilenameExtension is not used
  53 }
  54
  55 OCalcConnection::~OCalcConnection()
  56 {
  57 }
  58
  59 void OCalcConnection::construct(const OUString& url,const Sequence< PropertyValue >& info)
  60 {
  61     //  open file
  62
  63     sal_Int32 nLen = url.indexOf(':');
  64     nLen = url.indexOf(':',nLen+1);
  65
  66     m_aFileName = url.copy(nLen+1); // DSN
  67
  68     INetURLObject aURL;
  69     aURL.SetSmartProtocol(INetProtocol::File);
  70     {
  71         SvtPathOptions aPathOptions;
  72         m_aFileName = aPathOptions.SubstituteVariable(m_aFileName);
  73     }
  74     aURL.SetSmartURL(m_aFileName);
  75     if ( aURL.GetProtocol() == INetProtocol::NotValid )
  76     {
  77         //  don't pass invalid URL to loadComponentFromURL
  78         throw SQLException();
  79     }
  80     m_aFileName = aURL.GetMainURL(INetURLObject::DecodeMechanism::NONE);
  81
  82     m_sPassword.clear();
  83
  84     for (auto& propval : info)
  85     {
  86         if (propval.Name == "password")
  87         {
  88             propval.Value >>= m_sPassword;
  89             break;
  90         }
  91     }
  92     ODocHolder aDocHolder(this); // just to test that the doc can be loaded
  93     acquireDoc();
  94 }
  95
  96 Reference< XSpreadsheetDocument> const & OCalcConnection::acquireDoc()
  97 {
  98     if ( m_xDoc.is() )
  99     {
 100         osl_atomic_increment(&m_nDocCount);
 101         return m_xDoc;
 102     }
 103     //  open read-only as long as updating isn't implemented
 104     Sequence<PropertyValue> aArgs(m_sPassword.isEmpty() ? 2 : 3);
 105     auto pArgs = aArgs.getArray();
 106     pArgs[0].Name = "Hidden";
 107     pArgs[0].Value <<= true;
 108     pArgs[1].Name = "ReadOnly";
 109     pArgs[1].Value <<= true;
 110
 111     if ( !m_sPassword.isEmpty() )
 112     {
 113         pArgs[2].Name = "Password";
 114         pArgs[2].Value <<= m_sPassword;
 115     }
 116
 117     Reference< XDesktop2 > xDesktop = Desktop::create( getDriver()->getComponentContext() );
 118     Reference< XComponent > xComponent;
 119     Any aLoaderException;
 120     try
 121     {
 122         xComponent = xDesktop->loadComponentFromURL(
 123             m_aFileName, u"_blank"_ustr, 0, aArgs );
 124     }
 125     catch( const Exception& )
 126     {
 127         aLoaderException = ::cppu::getCaughtException();
 128     }
 129
 130     m_xDoc.set(xComponent, UNO_QUERY );
 131
 132     //  if the URL is not a spreadsheet document, throw the exception here
 133     //  instead of at the first access to it
 134     if ( !m_xDoc.is() )
 135     {
 136         Any aErrorDetails;
 137         if ( aLoaderException.hasValue() )
 138         {
 139             Exception aLoaderError;
 140             OSL_VERIFY( aLoaderException >>= aLoaderError );
 141
 142             SQLException aDetailException(m_aResources.getResourceStringWithSubstitution(
 143                                               STR_LOAD_FILE_ERROR_MESSAGE, "$exception_type$",
 144                                               aLoaderException.getValueTypeName(),
 145                                               "$error_message$", aLoaderError.Message),
 146                                           {}, {}, 0, {});
 147             aErrorDetails <<= aDetailException;
 148         }
 149
 150         const OUString sError( m_aResources.getResourceStringWithSubstitution(
 151             STR_COULD_NOT_LOAD_FILE,
 152             "$filename$", m_aFileName
 153          ) );
 154         ::dbtools::throwGenericSQLException( sError, *this, aErrorDetails );
 155     }
 156     osl_atomic_increment(&m_nDocCount);
 157     m_xCloseVetoButTerminateListener.set(new CloseVetoButTerminateListener);
 158     m_xCloseVetoButTerminateListener->start(m_xDoc, xDesktop);
 159     return m_xDoc;
 160 }
 161
 162 void OCalcConnection::releaseDoc()
 163 {
 164     if ( osl_atomic_decrement(&m_nDocCount) == 0 )
 165     {
 166         if (m_xCloseVetoButTerminateListener.is())
 167         {
 168             m_xCloseVetoButTerminateListener->stop();   // dispose m_xDoc
 169             m_xCloseVetoButTerminateListener.clear();
 170         }
 171         m_xDoc.clear();
 172     }
 173 }
 174
 175 void OCalcConnection::disposing()
 176 {
 177     ::osl::MutexGuard aGuard(m_aMutex);
 178
 179     m_nDocCount = 0;
 180     if (m_xCloseVetoButTerminateListener.is())
 181     {
 182         m_xCloseVetoButTerminateListener->stop();   // dispose m_xDoc
 183         m_xCloseVetoButTerminateListener.clear();
 184     }
 185     m_xDoc.clear();
 186
 187     OConnection::disposing();
 188 }
 189
 190 // XServiceInfo
 191
 192
 193 IMPLEMENT_SERVICE_INFO(OCalcConnection, u"com.sun.star.sdbc.drivers.calc.Connection"_ustr, u"com.sun.star.sdbc.Connection"_ustr)
 194
 195
 196 Reference< XDatabaseMetaData > SAL_CALL OCalcConnection::getMetaData(  )
 197 {
 198     ::osl::MutexGuard aGuard( m_aMutex );
 199     checkDisposed(OConnection_BASE::rBHelper.bDisposed);
 200
 201
 202     Reference< XDatabaseMetaData > xMetaData = m_xMetaData;
 203     if(!xMetaData.is())
 204     {
 205         xMetaData = new OCalcDatabaseMetaData(this);
 206         m_xMetaData = xMetaData;
 207     }
 208
 209     return xMetaData;
 210 }
 211
 212
 213 css::uno::Reference< XTablesSupplier > OCalcConnection::createCatalog()
 214 {
 215     ::osl::MutexGuard aGuard( m_aMutex );
 216     rtl::Reference< connectivity::sdbcx::OCatalog > xTab = m_xCatalog;
 217     if(!xTab.is())
 218     {
 219         xTab = new OCalcCatalog(this);
 220         m_xCatalog = xTab.get();
 221     }
 222     return xTab;
 223 }
 224
 225
 226 Reference< XStatement > SAL_CALL OCalcConnection::createStatement(  )
 227 {
 228     ::osl::MutexGuard aGuard( m_aMutex );
 229     checkDisposed(OConnection_BASE::rBHelper.bDisposed);
 230
 231
 232     Reference< XStatement > xReturn = new connectivity::component::OComponentStatement(this);
 233     m_aStatements.push_back(WeakReferenceHelper(xReturn));
 234     return xReturn;
 235 }
 236
 237
 238 Reference< XPreparedStatement > SAL_CALL OCalcConnection::prepareStatement( const OUString& sql )
 239 {
 240     ::osl::MutexGuard aGuard( m_aMutex );
 241     checkDisposed(OConnection_BASE::rBHelper.bDisposed);
 242
 243
 244     rtl::Reference<connectivity::component::OComponentPreparedStatement> pStmt = new connectivity::component::OComponentPreparedStatement(this);
 245     pStmt->construct(sql);
 246     m_aStatements.push_back(WeakReferenceHelper(*pStmt));
 247     return pStmt;
 248 }
 249
 250
 251 Reference< XPreparedStatement > SAL_CALL OCalcConnection::prepareCall( const OUString& /*sql*/ )
 252 {
 253     ::osl::MutexGuard aGuard( m_aMutex );
 254     checkDisposed(OConnection_BASE::rBHelper.bDisposed);
 255
 256     ::dbtools::throwFeatureNotImplementedSQLException( u"XConnection::prepareCall"_ustr, *this );
 257 }
 258
 259 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */