connectivity/source/drivers/dbase/DIndexes.cxx

   1 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
   2 /*************************************************************************
   3  *
   4  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   5  *
   6  * Copyright 2000, 2010 Oracle and/or its affiliates.
   7  *
   8  * OpenOffice.org - a multi-platform office productivity suite
   9  *
  10  * This file is part of OpenOffice.org.
  11  *
  12  * OpenOffice.org is free software: you can redistribute it and/or modify
  13  * it under the terms of the GNU Lesser General Public License version 3
  14  * only, as published by the Free Software Foundation.
  15  *
  16  * OpenOffice.org is distributed in the hope that it will be useful,
  17  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  18  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  19  * GNU Lesser General Public License version 3 for more details
  20  * (a copy is included in the LICENSE file that accompanied this code).
  21  *
  22  * You should have received a copy of the GNU Lesser General Public License
  23  * version 3 along with OpenOffice.org.  If not, see
  24  * <http://www.openoffice.org/license.html>
  25  * for a copy of the LGPLv3 License.
  26  *
  27  ************************************************************************/
  28
  29 #include "dbase/DIndexes.hxx"
  30 #include "dbase/DIndex.hxx"
  31 #include <connectivity/dbexception.hxx>
  32 #include <unotools/ucbhelper.hxx>
  33 #include <comphelper/types.hxx>
  34 #include "resource/dbase_res.hrc"
  35
  36 using namespace ::comphelper;
  37
  38 using namespace utl;
  39 using namespace ::connectivity;
  40 using namespace ::dbtools;
  41 using namespace ::connectivity::dbase;
  42 using namespace ::com::sun::star::uno;
  43 using namespace ::com::sun::star::beans;
  44 using namespace ::com::sun::star::sdbcx;
  45 using namespace ::com::sun::star::sdbc;
  46 using namespace ::com::sun::star::container;
  47 using namespace ::com::sun::star::lang;
  48
  49 sdbcx::ObjectType ODbaseIndexes::createObject(const ::rtl::OUString& _rName)
  50 {
  51     ::rtl::OUString sFile = m_pTable->getConnection()->getURL();
  52     sFile += OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_DELIMITER);
  53     sFile += _rName;
  54     sFile += ::rtl::OUString(".ndx");
  55     if ( !UCBContentHelper::Exists(sFile) )
  56     {
  57         const ::rtl::OUString sError( m_pTable->getConnection()->getResources().getResourceStringWithSubstitution(
  58                 STR_COULD_NOT_LOAD_FILE,
  59                 "$filename$", sFile
  60             ) );
  61         ::dbtools::throwGenericSQLException( sError, *m_pTable );
  62     }
  63
  64     sdbcx::ObjectType xRet;
  65     SvStream* pFileStream = ::connectivity::file::OFileTable::createStream_simpleError(sFile,STREAM_READ | STREAM_NOCREATE| STREAM_SHARE_DENYWRITE);
  66     if(pFileStream)
  67     {
  68         pFileStream->SetNumberFormatInt(NUMBERFORMAT_INT_LITTLEENDIAN);
  69         pFileStream->SetBufferSize(PAGE_SIZE);
  70         ODbaseIndex::NDXHeader aHeader;
  71
  72         pFileStream->Seek(0);
  73         pFileStream->Read(&aHeader,PAGE_SIZE);
  74         delete pFileStream;
  75
  76         ODbaseIndex* pIndex = new ODbaseIndex(m_pTable,aHeader,_rName);
  77         xRet = pIndex;
  78         pIndex->openIndexFile();
  79     }
  80     else
  81     {
  82         const ::rtl::OUString sError( m_pTable->getConnection()->getResources().getResourceStringWithSubstitution(
  83                 STR_COULD_NOT_LOAD_FILE,
  84                 "$filename$", sFile
  85              ) );
  86         ::dbtools::throwGenericSQLException( sError, *m_pTable );
  87     }
  88     return xRet;
  89 }
  90 // -------------------------------------------------------------------------
  91 void ODbaseIndexes::impl_refresh(  ) throw(RuntimeException)
  92 {
  93     if(m_pTable)
  94         m_pTable->refreshIndexes();
  95 }
  96 // -------------------------------------------------------------------------
  97 Reference< XPropertySet > ODbaseIndexes::createDescriptor()
  98 {
  99     return new ODbaseIndex(m_pTable);
 100 }
 101 // -------------------------------------------------------------------------
 102 // XAppend
 103 sdbcx::ObjectType ODbaseIndexes::appendObject( const ::rtl::OUString& _rForName, const Reference< XPropertySet >& descriptor )
 104 {
 105     Reference<XUnoTunnel> xTunnel(descriptor,UNO_QUERY);
 106     if(xTunnel.is())
 107     {
 108         ODbaseIndex* pIndex = reinterpret_cast< ODbaseIndex* >( xTunnel->getSomething(ODbaseIndex::getUnoTunnelImplementationId()) );
 109         if(!pIndex || !pIndex->CreateImpl())
 110             throw SQLException();
 111     }
 112
 113     return createObject( _rForName );
 114 }
 115 // -------------------------------------------------------------------------
 116 // XDrop
 117 void ODbaseIndexes::dropObject(sal_Int32 _nPos,const ::rtl::OUString /*_sElementName*/)
 118 {
 119     Reference< XUnoTunnel> xTunnel(getObject(_nPos),UNO_QUERY);
 120     if ( xTunnel.is() )
 121     {
 122         ODbaseIndex* pIndex = reinterpret_cast< ODbaseIndex* >( xTunnel->getSomething(ODbaseIndex::getUnoTunnelImplementationId()) );
 123         if ( pIndex )
 124             pIndex->DropImpl();
 125     }
 126
 127 }
 128 // -------------------------------------------------------------------------
 129
 130
 131 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */