connectivity/source/drivers/mysql_jdbc/YTables.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 <mysql/YTables.hxx>
  21 #include <mysql/YViews.hxx>
  22 #include <mysql/YTable.hxx>
  23 #include <com/sun/star/sdbc/XRow.hpp>
  24 #include <com/sun/star/sdbc/XResultSet.hpp>
  25 #include <com/sun/star/sdbcx/Privilege.hpp>
  26 #include <mysql/YCatalog.hxx>
  27 #include <connectivity/dbtools.hxx>
  28 #include <comphelper/types.hxx>
  29 #include <TConnection.hxx>
  30
  31 using namespace ::comphelper;
  32 using namespace connectivity;
  33 using namespace ::cppu;
  34 using namespace connectivity::mysql;
  35 using namespace ::com::sun::star::uno;
  36 using namespace ::com::sun::star::beans;
  37 using namespace ::com::sun::star::sdbcx;
  38 using namespace ::com::sun::star::sdbc;
  39 using namespace ::com::sun::star::container;
  40 using namespace dbtools;
  41
  42 sdbcx::ObjectType OTables::createObject(const OUString& _rName)
  43 {
  44     OUString sCatalog, sSchema, sTable;
  45     ::dbtools::qualifiedNameComponents(m_xMetaData, _rName, sCatalog, sSchema, sTable,
  46                                        ::dbtools::EComposeRule::InDataManipulation);
  47
  48     Sequence<OUString> sTableTypes{
  49         u"VIEW"_ustr, u"TABLE"_ustr, u"%"_ustr
  50     }; // this last one just to be sure to include anything else...
  51
  52     Any aCatalog;
  53     if (!sCatalog.isEmpty())
  54         aCatalog <<= sCatalog;
  55     Reference<XResultSet> xResult = m_xMetaData->getTables(aCatalog, sSchema, sTable, sTableTypes);
  56
  57     sdbcx::ObjectType xRet;
  58     if (xResult.is())
  59     {
  60         Reference<XRow> xRow(xResult, UNO_QUERY);
  61         if (xResult->next()) // there can be only one table with this name
  62         {
  63             sal_Int32 const nPrivileges = Privilege::DROP | Privilege::REFERENCE | Privilege::ALTER
  64                                           | Privilege::CREATE | Privilege::READ | Privilege::DELETE
  65                                           | Privilege::UPDATE | Privilege::INSERT
  66                                           | Privilege::SELECT;
  67
  68             xRet = new OMySQLTable(this, static_cast<OMySQLCatalog&>(m_rParent).getConnection(),
  69                                    sTable, xRow->getString(4), xRow->getString(5), sSchema,
  70                                    sCatalog, nPrivileges);
  71         }
  72         ::comphelper::disposeComponent(xResult);
  73     }
  74
  75     return xRet;
  76 }
  77
  78 void OTables::impl_refresh() { static_cast<OMySQLCatalog&>(m_rParent).refreshTables(); }
  79
  80 void OTables::disposing()
  81 {
  82     m_xMetaData.clear();
  83     OCollection::disposing();
  84 }
  85
  86 Reference<XPropertySet> OTables::createDescriptor()
  87 {
  88     return new OMySQLTable(this, static_cast<OMySQLCatalog&>(m_rParent).getConnection());
  89 }
  90
  91 // XAppend
  92 sdbcx::ObjectType OTables::appendObject(const OUString& _rForName,
  93                                         const Reference<XPropertySet>& descriptor)
  94 {
  95     createTable(descriptor);
  96     return createObject(_rForName);
  97 }
  98
  99 // XDrop
 100 void OTables::dropObject(sal_Int32 _nPos, const OUString& _sElementName)
 101 {
 102     Reference<XInterface> xObject(getObject(_nPos));
 103     bool bIsNew = connectivity::sdbcx::ODescriptor::isNew(xObject);
 104     if (bIsNew)
 105         return;
 106
 107     Reference<XConnection> xConnection = static_cast<OMySQLCatalog&>(m_rParent).getConnection();
 108
 109     OUString sCatalog, sSchema, sTable;
 110     ::dbtools::qualifiedNameComponents(m_xMetaData, _sElementName, sCatalog, sSchema, sTable,
 111                                        ::dbtools::EComposeRule::InDataManipulation);
 112
 113     OUString aSql(u"DROP "_ustr);
 114
 115     Reference<XPropertySet> xProp(xObject, UNO_QUERY);
 116     bool bIsView = xProp.is()
 117                    && ::comphelper::getString(xProp->getPropertyValue(
 118                           OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_TYPE)))
 119                           == "VIEW";
 120     if (bIsView) // here we have a view
 121         aSql += "VIEW ";
 122     else
 123         aSql += "TABLE ";
 124
 125     OUString sComposedName(::dbtools::composeTableName(
 126         m_xMetaData, sCatalog, sSchema, sTable, true, ::dbtools::EComposeRule::InDataManipulation));
 127     aSql += sComposedName;
 128     Reference<XStatement> xStmt = xConnection->createStatement();
 129     if (xStmt.is())
 130     {
 131         xStmt->execute(aSql);
 132         ::comphelper::disposeComponent(xStmt);
 133     }
 134     // if no exception was thrown we must delete it from the views
 135     if (bIsView)
 136     {
 137         OViews* pViews
 138             = static_cast<OViews*>(static_cast<OMySQLCatalog&>(m_rParent).getPrivateViews());
 139         if (pViews && pViews->hasByName(_sElementName))
 140             pViews->dropByNameImpl(_sElementName);
 141     }
 142 }
 143
 144 OUString OTables::adjustSQL(const OUString& _sSql)
 145 {
 146     OUString sSQL = _sSql;
 147     static const char s_sUNSIGNED[] = "UNSIGNED";
 148     sal_Int32 nIndex = sSQL.indexOf(s_sUNSIGNED);
 149     while (nIndex != -1)
 150     {
 151         sal_Int32 nParen = sSQL.indexOf(')', nIndex);
 152         sal_Int32 nPos = nIndex + strlen(s_sUNSIGNED);
 153         OUString sNewUnsigned(sSQL.copy(nPos, nParen - nPos + 1));
 154         sSQL = sSQL.replaceAt(nIndex, strlen(s_sUNSIGNED) + sNewUnsigned.getLength(),
 155                               rtl::Concat2View(sNewUnsigned + s_sUNSIGNED));
 156         nIndex = sSQL.indexOf(s_sUNSIGNED, nIndex + strlen(s_sUNSIGNED) + sNewUnsigned.getLength());
 157     }
 158     return sSQL;
 159 }
 160
 161 void OTables::createTable(const Reference<XPropertySet>& descriptor)
 162 {
 163     const Reference<XConnection> xConnection
 164         = static_cast<OMySQLCatalog&>(m_rParent).getConnection();
 165     const OUString aSql
 166         = adjustSQL(::dbtools::createSqlCreateTableStatement(descriptor, xConnection));
 167     Reference<XStatement> xStmt = xConnection->createStatement();
 168     if (xStmt.is())
 169     {
 170         xStmt->execute(aSql);
 171         ::comphelper::disposeComponent(xStmt);
 172     }
 173 }
 174
 175 void OTables::appendNew(const OUString& _rsNewTable)
 176 {
 177     insertElement(_rsNewTable, nullptr);
 178
 179     // notify our container listeners
 180     ContainerEvent aEvent(static_cast<XContainer*>(this), Any(_rsNewTable), Any(), Any());
 181     OInterfaceIteratorHelper3 aListenerLoop(m_aContainerListeners);
 182     while (aListenerLoop.hasMoreElements())
 183         aListenerLoop.next()->elementInserted(aEvent);
 184 }
 185
 186 OUString OTables::getNameForObject(const sdbcx::ObjectType& _xObject)
 187 {
 188     OSL_ENSURE(_xObject.is(), "OTables::getNameForObject: Object is NULL!");
 189     return ::dbtools::composeTableName(m_xMetaData, _xObject,
 190                                        ::dbtools::EComposeRule::InDataManipulation, false);
 191 }
 192
 193 void OTables::addComment(const Reference<XPropertySet>& descriptor, OUStringBuffer& _rOut)
 194 {
 195     OUString sDesc;
 196     descriptor->getPropertyValue(
 197         OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_DESCRIPTION))
 198         >>= sDesc;
 199     if (!sDesc.isEmpty())
 200     {
 201         _rOut.append(" COMMENT '");
 202         _rOut.append(sDesc);
 203         _rOut.append("'");
 204     }
 205 }
 206
 207 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */