connectivity/source/drivers/firebird/Table.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
  10 #include "Columns.hxx"
  11 #include "Indexes.hxx"
  12 #include "Keys.hxx"
  13 #include "Table.hxx"
  14
  15 #include <TConnection.hxx>
  16
  17 #include <comphelper/sequence.hxx>
  18 #include <connectivity/dbtools.hxx>
  19
  20 #include <com/sun/star/sdbc/ColumnValue.hpp>
  21 #include <com/sun/star/sdbcx/Privilege.hpp>
  22
  23 using namespace ::connectivity;
  24 using namespace ::connectivity::firebird;
  25 using namespace ::connectivity::sdbcx;
  26
  27 using namespace ::osl;
  28
  29 using namespace ::com::sun::star;
  30 using namespace ::com::sun::star::beans;
  31 using namespace ::com::sun::star::container;
  32 using namespace ::com::sun::star::sdbc;
  33 using namespace ::com::sun::star::sdbcx;
  34 using namespace ::com::sun::star::uno;
  35
  36 Table::Table(Tables* pTables,
  37              Mutex& rMutex,
  38              const uno::Reference< XConnection >& rConnection):
  39     OTableHelper(pTables,
  40                  rConnection,
  41                  true),
  42     m_rMutex(rMutex),
  43     m_nPrivileges(0)
  44 {
  45     construct();
  46 }
  47
  48 Table::Table(Tables* pTables,
  49              Mutex& rMutex,
  50              const uno::Reference< XConnection >& rConnection,
  51              const OUString& rName,
  52              const OUString& rType,
  53              const OUString& rDescription):
  54     OTableHelper(pTables,
  55                  rConnection,
  56                  true,
  57                  rName,
  58                  rType,
  59                  rDescription,
  60                  "",
  61                  ""),
  62     m_rMutex(rMutex),
  63     m_nPrivileges(0)
  64 {
  65     construct();
  66 }
  67
  68 void Table::construct()
  69 {
  70     OTableHelper::construct();
  71     if (!isNew())
  72     {
  73         // TODO: get privileges when in non-embedded mode.
  74         m_nPrivileges = Privilege::DROP         |
  75                         Privilege::REFERENCE    |
  76                         Privilege::ALTER        |
  77                         Privilege::CREATE       |
  78                         Privilege::READ         |
  79                         Privilege::DELETE       |
  80                         Privilege::UPDATE       |
  81                         Privilege::INSERT       |
  82                         Privilege::SELECT;
  83         registerProperty(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_PRIVILEGES),
  84                          PROPERTY_ID_PRIVILEGES,
  85                          PropertyAttribute::READONLY,
  86                          &m_nPrivileges,
  87                          cppu::UnoType<decltype(m_nPrivileges)>::get());
  88     }
  89 }
  90 //----- OTableHelper ---------------------------------------------------------
  91 OCollection* Table::createColumns(const TStringVector& rNames)
  92 {
  93     return new Columns(*this,
  94                        m_rMutex,
  95                        rNames);
  96 }
  97
  98 OCollection* Table::createKeys(const TStringVector& rNames)
  99 {
 100     return new Keys(this,
 101                     m_rMutex,
 102                     rNames);
 103 }
 104
 105 OCollection* Table::createIndexes(const TStringVector& rNames)
 106 {
 107     return new Indexes(this,
 108                        m_rMutex,
 109                        rNames);
 110 }
 111
 112 //----- XAlterTable -----------------------------------------------------------
 113 void SAL_CALL Table::alterColumnByName(const OUString& rColName,
 114                                        const uno::Reference< XPropertySet >& rDescriptor)
 115     throw(SQLException, NoSuchElementException, RuntimeException, std::exception)
 116 {
 117     MutexGuard aGuard(m_rMutex);
 118     checkDisposed(WeakComponentImplHelperBase::rBHelper.bDisposed);
 119
 120     uno::Reference< XPropertySet > xColumn(m_pColumns->getByName(rColName), UNO_QUERY);
 121
 122     // sdbcx::Descriptor
 123     const bool bNameChanged = xColumn->getPropertyValue("Name") != rDescriptor->getPropertyValue("Name");
 124     // sdbcx::ColumnDescriptor
 125     const bool bTypeChanged = xColumn->getPropertyValue("Type") != rDescriptor->getPropertyValue("Type");
 126     const bool bTypeNameChanged = xColumn->getPropertyValue("TypeName") != rDescriptor->getPropertyValue("TypeName");
 127     const bool bPrecisionChanged = xColumn->getPropertyValue("Precision") != rDescriptor->getPropertyValue("Precision");
 128     const bool bScaleChanged = xColumn->getPropertyValue("Scale") != rDescriptor->getPropertyValue("Scale");
 129     const bool bIsNullableChanged = xColumn->getPropertyValue("IsNullable") != rDescriptor->getPropertyValue("IsNullable");
 130     const bool bIsAutoIncrementChanged = xColumn->getPropertyValue("IsAutoIncrement") != rDescriptor->getPropertyValue("IsAutoIncrement");
 131     // TODO: remainder -- these are all "optional" so have to detect presence and change.
 132
 133     bool bDefaultChanged = xColumn->getPropertyValue("DefaultValue")
 134                                      != rDescriptor->getPropertyValue("DefaultValue");
 135
 136     // TODO: quote identifiers as needed.
 137     if (bNameChanged)
 138     {
 139         OUString sNewTableName;
 140         rDescriptor->getPropertyValue("Name") >>= sNewTableName;
 141         OUString sSql(getAlterTableColumn(rColName)
 142                                             + " TO \"" + sNewTableName + "\"");
 143
 144         getConnection()->createStatement()->execute(sSql);
 145     }
 146
 147     if (bTypeChanged || bTypeNameChanged || bPrecisionChanged || bScaleChanged)
 148     {
 149         // If bPrecisionChanged this will only succeed if we have increased the
 150         // precision, otherwise an exception is thrown -- however the base
 151         // gui then offers to delete and recreate the column.
 152         OUString sSql(getAlterTableColumn(rColName) + "TYPE " +
 153                 ::dbtools::createStandardTypePart(rDescriptor, getConnection()));
 154         getConnection()->createStatement()->execute(sSql);
 155         // TODO: could cause errors e.g. if incompatible types, deal with them here as appropriate.
 156         // possibly we have to wrap things in Util::evaluateStatusVector.
 157     }
 158
 159     if (bIsNullableChanged)
 160     {
 161         sal_Int32 nNullabble = 0;
 162         rDescriptor->getPropertyValue("IsNullable") >>= nNullabble;
 163
 164         if (nNullabble != ColumnValue::NULLABLE_UNKNOWN)
 165         {
 166
 167             OUString sSql;
 168             // Dirty hack: can't change null directly in sql, we have to fiddle
 169             // the system tables manually.
 170             if (nNullabble == ColumnValue::NULLABLE)
 171             {
 172                 sSql = "UPDATE RDB$RELATION_FIELDS SET RDB$NULL_FLAG = NULL "
 173                        "WHERE RDB$FIELD_NAME = '" + rColName + "' "
 174                        "AND RDB$RELATION_NAME = '" + getName() + "'";
 175             }
 176             else if (nNullabble == ColumnValue::NO_NULLS)
 177             {
 178                 // And if we are making NOT NULL then we have to make sure we have
 179                 // no nulls left in the column.
 180                 OUString sFillNulls("UPDATE \"" + getName() + "\" SET \""
 181                                     + rColName + "\" = 0 "
 182                                     "WHERE \"" + rColName + "\" IS NULL");
 183                 getConnection()->createStatement()->execute(sFillNulls);
 184
 185                 sSql = "UPDATE RDB$RELATION_FIELDS SET RDB$NULL_FLAG = 1 "
 186                        "WHERE RDB$FIELD_NAME = '" + rColName + "' "
 187                        "AND RDB$RELATION_NAME = '" + getName() + "'";
 188             }
 189             getConnection()->createStatement()->execute(sSql);
 190         }
 191         else
 192         {
 193             SAL_WARN("connectivity.firebird", "Attempting to set Nullable to NULLABLE_UNKNOWN");
 194         }
 195     }
 196
 197     if (bIsAutoIncrementChanged)
 198     {
 199         // TODO: changeType
 200     }
 201
 202     if (bDefaultChanged)
 203     {
 204         OUString sOldDefault, sNewDefault;
 205         xColumn->getPropertyValue("DefaultValue") >>= sOldDefault;
 206         rDescriptor->getPropertyValue("DefaultValue") >>= sNewDefault;
 207
 208         OUString sSql;
 209         if (sNewDefault.isEmpty())
 210             sSql = getAlterTableColumn(rColName) + "DROP DEFAULT";
 211         else
 212             sSql = getAlterTableColumn(rColName) + "SET DEFAULT " + sNewDefault;
 213
 214         getConnection()->createStatement()->execute(sSql);
 215     }
 216
 217     m_pColumns->refresh();
 218 }
 219
 220 // ----- XRename --------------------------------------------------------------
 221 void SAL_CALL Table::rename(const OUString& rName)
 222     throw(SQLException, ElementExistException, RuntimeException, std::exception)
 223 {
 224     (void) rName;
 225     throw RuntimeException(); // Firebird doesn't support this.
 226 }
 227
 228 // ----- XInterface -----------------------------------------------------------
 229 Any SAL_CALL Table::queryInterface(const Type& rType)
 230     throw(RuntimeException, std::exception)
 231 {
 232     if (rType.getTypeName() == "com.sun.star.sdbcx.XRename")
 233         return Any();
 234
 235     return OTableHelper::queryInterface(rType);
 236 }
 237
 238 // ----- XTypeProvider --------------------------------------------------------
 239 uno::Sequence< Type > SAL_CALL Table::getTypes()
 240     throw(RuntimeException, std::exception)
 241 {
 242     uno::Sequence< Type > aTypes = OTableHelper::getTypes();
 243
 244     for (int i = 0; i < aTypes.getLength(); i++)
 245     {
 246         if (aTypes[i].getTypeName() == "com.sun.star.sdbcx.XRename")
 247         {
 248             ::comphelper::removeElementAt(aTypes, i);
 249             break;
 250         }
 251     }
 252
 253     return OTableHelper::getTypes();
 254 }
 255
 256 OUString Table::getAlterTableColumn(const OUString& rColumn)
 257 {
 258     return ("ALTER TABLE \"" + getName() + "\" ALTER COLUMN \"" + rColumn + "\" ");
 259 }
 260
 261 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */