connectivity/source/drivers/mysql/YViews.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: YViews.cxx,v $
  10  * $Revision: 1.11 $
  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 "mysql/YViews.hxx"
  34 #include "mysql/YTables.hxx"
  35 #include <com/sun/star/sdbc/XRow.hpp>
  36 #include <com/sun/star/sdbc/XResultSet.hpp>
  37 #include <com/sun/star/sdbc/ColumnValue.hpp>
  38 #include <com/sun/star/sdbc/KeyRule.hpp>
  39 #include <com/sun/star/sdbcx/KeyType.hpp>
  40 #include <com/sun/star/sdbcx/CheckOption.hpp>
  41 #include "mysql/YCatalog.hxx"
  42 #include <comphelper/extract.hxx>
  43 #include "connectivity/dbtools.hxx"
  44 #include "connectivity/dbexception.hxx"
  45 #include <cppuhelper/interfacecontainer.h>
  46 #include "connectivity/sdbcx/VView.hxx"
  47 #include <comphelper/types.hxx>
  48 #include "TConnection.hxx"
  49
  50 using namespace ::comphelper;
  51
  52 using namespace ::cppu;
  53 using namespace connectivity;
  54 using namespace connectivity::mysql;
  55 using namespace ::com::sun::star::uno;
  56 using namespace ::com::sun::star::beans;
  57 using namespace ::com::sun::star::sdbcx;
  58 using namespace ::com::sun::star::sdbc;
  59 using namespace ::com::sun::star::container;
  60 using namespace ::com::sun::star::lang;
  61 using namespace dbtools;
  62 typedef connectivity::sdbcx::OCollection OCollection_TYPE;
  63
  64 sdbcx::ObjectType OViews::createObject(const ::rtl::OUString& _rName)
  65 {
  66     ::rtl::OUString sCatalog,sSchema,sTable;
  67     ::dbtools::qualifiedNameComponents(m_xMetaData,
  68                                         _rName,
  69                                         sCatalog,
  70                                         sSchema,
  71                                         sTable,
  72                                         ::dbtools::eInDataManipulation);
  73     return new ::connectivity::sdbcx::OView(isCaseSensitive(),
  74                             sTable,
  75                             m_xMetaData,
  76                             0,
  77                             ::rtl::OUString(),
  78                             sSchema,
  79                             sCatalog
  80                             );
  81 }
  82 // -------------------------------------------------------------------------
  83 void OViews::impl_refresh(  ) throw(RuntimeException)
  84 {
  85     static_cast<OMySQLCatalog&>(m_rParent).refreshTables();
  86 }
  87 // -------------------------------------------------------------------------
  88 void OViews::disposing(void)
  89 {
  90 m_xMetaData.clear();
  91     OCollection::disposing();
  92 }
  93 // -------------------------------------------------------------------------
  94 Reference< XPropertySet > OViews::createDescriptor()
  95 {
  96     Reference<XConnection> xConnection = static_cast<OMySQLCatalog&>(m_rParent).getConnection();
  97     connectivity::sdbcx::OView* pNew = new connectivity::sdbcx::OView(sal_True,xConnection->getMetaData());
  98     return pNew;
  99 }
 100 // -------------------------------------------------------------------------
 101 // XAppend
 102 sdbcx::ObjectType OViews::appendObject( const ::rtl::OUString& _rForName, const Reference< XPropertySet >& descriptor )
 103 {
 104     createView(descriptor);
 105     return createObject( _rForName );
 106 }
 107 // -------------------------------------------------------------------------
 108 // XDrop
 109 void OViews::dropObject(sal_Int32 _nPos,const ::rtl::OUString /*_sElementName*/)
 110 {
 111     if ( m_bInDrop )
 112         return;
 113
 114     Reference< XInterface > xObject( getObject( _nPos ) );
 115     sal_Bool bIsNew = connectivity::sdbcx::ODescriptor::isNew( xObject );
 116     if (!bIsNew)
 117     {
 118         ::rtl::OUString aSql = ::rtl::OUString::createFromAscii("DROP VIEW");
 119
 120         Reference<XPropertySet> xProp(xObject,UNO_QUERY);
 121         aSql += ::dbtools::composeTableName( m_xMetaData, xProp, ::dbtools::eInTableDefinitions, false, false, true );
 122
 123         Reference<XConnection> xConnection = static_cast<OMySQLCatalog&>(m_rParent).getConnection();
 124         Reference< XStatement > xStmt = xConnection->createStatement(  );
 125         xStmt->execute(aSql);
 126         ::comphelper::disposeComponent(xStmt);
 127     }
 128 }
 129 // -----------------------------------------------------------------------------
 130 void OViews::dropByNameImpl(const ::rtl::OUString& elementName)
 131 {
 132     m_bInDrop = sal_True;
 133     OCollection_TYPE::dropByName(elementName);
 134     m_bInDrop = sal_False;
 135 }
 136 // -----------------------------------------------------------------------------
 137 void OViews::createView( const Reference< XPropertySet >& descriptor )
 138 {
 139     Reference<XConnection> xConnection = static_cast<OMySQLCatalog&>(m_rParent).getConnection();
 140
 141     ::rtl::OUString aSql        = ::rtl::OUString::createFromAscii("CREATE VIEW ");
 142     ::rtl::OUString aQuote      = xConnection->getMetaData()->getIdentifierQuoteString(  );
 143     ::rtl::OUString sSchema,sCommand;
 144
 145     aSql += ::dbtools::composeTableName( m_xMetaData, descriptor, ::dbtools::eInTableDefinitions, false, false, true );
 146
 147     aSql += ::rtl::OUString::createFromAscii(" AS ");
 148     descriptor->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_COMMAND)) >>= sCommand;
 149     aSql += sCommand;
 150
 151     Reference< XStatement > xStmt = xConnection->createStatement(  );
 152     if ( xStmt.is() )
 153     {
 154         xStmt->execute(aSql);
 155         ::comphelper::disposeComponent(xStmt);
 156     }
 157
 158     // insert the new view also in the tables collection
 159     OTables* pTables = static_cast<OTables*>(static_cast<OMySQLCatalog&>(m_rParent).getPrivateTables());
 160     if ( pTables )
 161     {
 162         ::rtl::OUString sName = ::dbtools::composeTableName( m_xMetaData, descriptor, ::dbtools::eInDataManipulation, false, false, false );
 163         pTables->appendNew(sName);
 164     }
 165 }