connectivity/source/commontools/TIndexes.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: TIndexes.cxx,v $
  10  * $Revision: 1.12.56.1 $
  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 "connectivity/TIndexes.hxx"
  34 #include "connectivity/TIndex.hxx"
  35 #include <com/sun/star/sdbc/XRow.hpp>
  36 #include <com/sun/star/sdbc/XResultSet.hpp>
  37 #include <com/sun/star/sdbc/IndexType.hpp>
  38 #include <connectivity/dbtools.hxx>
  39 #include "connectivity/TTableHelper.hxx"
  40 #include "TConnection.hxx"
  41 #include <comphelper/extract.hxx>
  42 #include <rtl/ustrbuf.hxx>
  43 using namespace connectivity;
  44 using namespace connectivity::sdbcx;
  45 using namespace ::com::sun::star::uno;
  46 using namespace ::com::sun::star::beans;
  47 using namespace ::com::sun::star::sdbcx;
  48 using namespace ::com::sun::star::sdbc;
  49 using namespace ::com::sun::star::container;
  50 using namespace ::com::sun::star::lang;
  51 using namespace cppu;
  52
  53 typedef connectivity::sdbcx::OCollection OCollection_TYPE;
  54 // -----------------------------------------------------------------------------
  55 OIndexesHelper::OIndexesHelper(OTableHelper* _pTable,
  56                  ::osl::Mutex& _rMutex,
  57              const ::std::vector< ::rtl::OUString> &_rVector
  58              )
  59     : OCollection(*_pTable,sal_True,_rMutex,_rVector)
  60     ,m_pTable(_pTable)
  61 {
  62 }
  63 // -----------------------------------------------------------------------------
  64
  65 sdbcx::ObjectType OIndexesHelper::createObject(const ::rtl::OUString& _rName)
  66 {
  67     Reference< XConnection> xConnection = m_pTable->getConnection();
  68     if ( !xConnection.is() )
  69         return NULL;
  70
  71     sdbcx::ObjectType xRet;
  72     ::rtl::OUString aName,aQualifier;
  73     sal_Int32 nLen = _rName.indexOf('.');
  74     if ( nLen != -1 )
  75     {
  76         aQualifier      = _rName.copy(0,nLen);
  77         aName           = _rName.copy(nLen+1);
  78     }
  79     else
  80         aName           = _rName;
  81
  82     ::dbtools::OPropertyMap& rPropMap = OMetaConnection::getPropMap();
  83     ::rtl::OUString aSchema,aTable;
  84     m_pTable->getPropertyValue(rPropMap.getNameByIndex(PROPERTY_ID_SCHEMANAME)) >>= aSchema;
  85     m_pTable->getPropertyValue(rPropMap.getNameByIndex(PROPERTY_ID_NAME))               >>= aTable;
  86
  87     Any aCatalog = m_pTable->getPropertyValue(rPropMap.getNameByIndex(PROPERTY_ID_CATALOGNAME));
  88     Reference< XResultSet > xResult = m_pTable->getMetaData()->getIndexInfo(aCatalog,aSchema,aTable,sal_False,sal_False);
  89
  90     if ( xResult.is() )
  91     {
  92         Reference< XRow > xRow(xResult,UNO_QUERY);
  93         while( xResult->next() )
  94         {
  95             sal_Bool bUnique = !xRow->getBoolean(4);
  96             if((!aQualifier.getLength() || xRow->getString(5) == aQualifier ) && xRow->getString(6) == aName)
  97             {
  98                 sal_Int32 nClustered = xRow->getShort(7);
  99                 sal_Bool bPrimarKeyIndex = sal_False;
 100                 xRow.clear();
 101                 xResult.clear();
 102                 try
 103                 {
 104                     xResult = m_pTable->getMetaData()->getPrimaryKeys(aCatalog,aSchema,aTable);
 105                     xRow.set(xResult,UNO_QUERY);
 106
 107                     if ( xRow.is() && xResult->next() ) // there can be only one primary key
 108                     {
 109                         bPrimarKeyIndex = xRow->getString(6) == aName;
 110                     }
 111                 }
 112                 catch(Exception)
 113                 {
 114                 }
 115                 OIndexHelper* pRet = new OIndexHelper(m_pTable,aName,aQualifier,bUnique,
 116                     bPrimarKeyIndex,
 117                     nClustered == IndexType::CLUSTERED);
 118                 xRet = pRet;
 119                 break;
 120             }
 121         }
 122     }
 123
 124     return xRet;
 125 }
 126 // -------------------------------------------------------------------------
 127 void OIndexesHelper::impl_refresh() throw(RuntimeException)
 128 {
 129     m_pTable->refreshIndexes();
 130 }
 131 // -------------------------------------------------------------------------
 132 Reference< XPropertySet > OIndexesHelper::createDescriptor()
 133 {
 134     return new OIndexHelper(m_pTable);
 135 }
 136 // -------------------------------------------------------------------------
 137 // XAppend
 138 sdbcx::ObjectType OIndexesHelper::appendObject( const ::rtl::OUString& _rForName, const Reference< XPropertySet >& descriptor )
 139 {
 140     Reference< XConnection> xConnection = m_pTable->getConnection();
 141     if ( !xConnection.is() )
 142         return NULL;
 143     if ( m_pTable->isNew() )
 144         return cloneDescriptor( descriptor );
 145
 146     ::dbtools::OPropertyMap& rPropMap = OMetaConnection::getPropMap();
 147     ::rtl::OUStringBuffer aSql( ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("CREATE ")));
 148     ::rtl::OUString aQuote      = m_pTable->getMetaData()->getIdentifierQuoteString(  );
 149     ::rtl::OUString aDot        = ::rtl::OUString::createFromAscii(".");
 150
 151     if(comphelper::getBOOL(descriptor->getPropertyValue(rPropMap.getNameByIndex(PROPERTY_ID_ISUNIQUE))))
 152         aSql.appendAscii("UNIQUE ");
 153     aSql.appendAscii("INDEX ");
 154
 155
 156     ::rtl::OUString aCatalog,aSchema,aTable;
 157     dbtools::qualifiedNameComponents(m_pTable->getMetaData(),m_pTable->getName(),aCatalog,aSchema,aTable,::dbtools::eInDataManipulation);
 158     ::rtl::OUString aComposedName;
 159
 160     aComposedName = dbtools::composeTableName(m_pTable->getMetaData(),aCatalog,aSchema,aTable,sal_True,::dbtools::eInIndexDefinitions);
 161     if ( _rForName.getLength() )
 162     {
 163         aSql.append( ::dbtools::quoteName( aQuote, _rForName ) );
 164         aSql.appendAscii(" ON ");
 165         aSql.append(aComposedName);
 166         aSql.appendAscii(" ( ");
 167
 168         Reference<XColumnsSupplier> xColumnSup(descriptor,UNO_QUERY);
 169         Reference<XIndexAccess> xColumns(xColumnSup->getColumns(),UNO_QUERY);
 170         Reference< XPropertySet > xColProp;
 171         sal_Bool bAddIndexAppendix = ::dbtools::getBooleanDataSourceSetting( m_pTable->getConnection(), "AddIndexAppendix" );
 172         sal_Int32 nCount = xColumns->getCount();
 173         for(sal_Int32 i = 0 ; i < nCount; ++i)
 174         {
 175             xColProp.set(xColumns->getByIndex(i),UNO_QUERY);
 176             aSql.append(::dbtools::quoteName( aQuote,comphelper::getString(xColProp->getPropertyValue(rPropMap.getNameByIndex(PROPERTY_ID_NAME)))));
 177
 178             if ( bAddIndexAppendix )
 179             {
 180
 181                 aSql.appendAscii(any2bool(xColProp->getPropertyValue(rPropMap.getNameByIndex(PROPERTY_ID_ISASCENDING)))
 182                                             ?
 183                                 " ASC"
 184                                             :
 185                                 " DESC");
 186             }
 187             aSql.appendAscii(",");
 188         }
 189         aSql.setCharAt(aSql.getLength()-1,')');
 190     }
 191     else
 192     {
 193         aSql.append(aComposedName);
 194
 195         Reference<XColumnsSupplier> xColumnSup(descriptor,UNO_QUERY);
 196         Reference<XIndexAccess> xColumns(xColumnSup->getColumns(),UNO_QUERY);
 197         Reference< XPropertySet > xColProp;
 198         if(xColumns->getCount() != 1)
 199             throw SQLException();
 200
 201         xColumns->getByIndex(0) >>= xColProp;
 202
 203         aSql.append(aDot);
 204         aSql.append(::dbtools::quoteName( aQuote,comphelper::getString(xColProp->getPropertyValue(rPropMap.getNameByIndex(PROPERTY_ID_NAME)))));
 205     }
 206
 207     Reference< XStatement > xStmt = m_pTable->getConnection()->createStatement(  );
 208     if ( xStmt.is() )
 209     {
 210         ::rtl::OUString sSql = aSql.makeStringAndClear();
 211         xStmt->execute(sSql);
 212         ::comphelper::disposeComponent(xStmt);
 213     }
 214
 215     return createObject( _rForName );
 216 }
 217 // -------------------------------------------------------------------------
 218 // XDrop
 219 void OIndexesHelper::dropObject(sal_Int32 /*_nPos*/,const ::rtl::OUString _sElementName)
 220 {
 221     Reference< XConnection> xConnection = m_pTable->getConnection();
 222     if( xConnection.is() && !m_pTable->isNew())
 223     {
 224         ::rtl::OUString aName,aSchema;
 225         sal_Int32 nLen = _sElementName.indexOf('.');
 226         if(nLen != -1)
 227             aSchema = _sElementName.copy(0,nLen);
 228         aName   = _sElementName.copy(nLen+1);
 229
 230         ::rtl::OUString aSql    = ::rtl::OUString::createFromAscii("DROP INDEX ");
 231
 232         ::rtl::OUString aComposedName = dbtools::composeTableName( m_pTable->getMetaData(), m_pTable, ::dbtools::eInIndexDefinitions, false, false, true );
 233         ::rtl::OUString sIndexName,sTemp;
 234         sIndexName = dbtools::composeTableName( m_pTable->getMetaData(), sTemp, aSchema, aName, sal_True, ::dbtools::eInIndexDefinitions );
 235
 236         aSql += sIndexName
 237                 + ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM(" ON "))
 238                     + aComposedName;
 239
 240         Reference< XStatement > xStmt = m_pTable->getConnection()->createStatement(  );
 241         if ( xStmt.is() )
 242         {
 243             xStmt->execute(aSql);
 244             ::comphelper::disposeComponent(xStmt);
 245         }
 246     }
 247 }
 248 // -----------------------------------------------------------------------------
 249
 250
 251