connectivity/source/drivers/file/FConnection.cxx

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