Branch data Line data Source code
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 <string.h>
21 : : #include "mysql/YTable.hxx"
22 : : #include "mysql/YTables.hxx"
23 : : #include <com/sun/star/sdbc/XRow.hpp>
24 : : #include <com/sun/star/sdbc/XResultSet.hpp>
25 : : #include <com/sun/star/sdbcx/KeyType.hpp>
26 : : #include <com/sun/star/sdbc/KeyRule.hpp>
27 : : #include <cppuhelper/typeprovider.hxx>
28 : : #include <com/sun/star/lang/DisposedException.hpp>
29 : : #include <com/sun/star/sdbc/ColumnValue.hpp>
30 : : #include <com/sun/star/sdbcx/Privilege.hpp>
31 : : #include <comphelper/property.hxx>
32 : : #include <comphelper/extract.hxx>
33 : : #include <comphelper/types.hxx>
34 : : #include "connectivity/dbtools.hxx"
35 : : #include "connectivity/sdbcx/VColumn.hxx"
36 : : #include "connectivity/TKeys.hxx"
37 : : #include "connectivity/TIndexes.hxx"
38 : : #include "connectivity/TColumnsHelper.hxx"
39 : : #include "mysql/YCatalog.hxx"
40 : : #include "mysql/YColumns.hxx"
41 : : #include "TConnection.hxx"
42 : :
43 : :
44 : : using namespace ::comphelper;
45 : : using namespace connectivity::mysql;
46 : : using namespace connectivity::sdbcx;
47 : : using namespace connectivity;
48 : : using namespace ::com::sun::star::uno;
49 : : using namespace ::com::sun::star::beans;
50 : : using namespace ::com::sun::star::sdbcx;
51 : : using namespace ::com::sun::star::sdbc;
52 : : using namespace ::com::sun::star::container;
53 : : using namespace ::com::sun::star::lang;
54 : : namespace connectivity
55 : : {
56 : : namespace mysql
57 : : {
58 : 0 : class OMySQLKeysHelper : public OKeysHelper
59 : : {
60 : : protected:
61 : : // -----------------------------------------------------------------------------
62 : 0 : virtual ::rtl::OUString getDropForeignKey() const
63 : : {
64 : 0 : return ::rtl::OUString(" DROP FOREIGN KEY ");
65 : : }
66 : : public:
67 : 0 : OMySQLKeysHelper( OTableHelper* _pTable,
68 : : ::osl::Mutex& _rMutex,
69 : : const TStringVector& _rVector
70 : 0 : ) : OKeysHelper(_pTable,_rMutex,_rVector){}
71 : :
72 : : };
73 : : }
74 : : }
75 : :
76 : 0 : OMySQLTable::OMySQLTable( sdbcx::OCollection* _pTables,
77 : : const Reference< XConnection >& _xConnection)
78 : 0 : :OTableHelper(_pTables,_xConnection,sal_True)
79 : : {
80 : : // we create a new table here, so we should have all the rights or ;-)
81 : : m_nPrivileges = Privilege::DROP |
82 : : Privilege::REFERENCE |
83 : : Privilege::ALTER |
84 : : Privilege::CREATE |
85 : : Privilege::READ |
86 : : Privilege::DELETE |
87 : : Privilege::UPDATE |
88 : : Privilege::INSERT |
89 : 0 : Privilege::SELECT;
90 : 0 : construct();
91 : 0 : }
92 : : // -------------------------------------------------------------------------
93 : 0 : OMySQLTable::OMySQLTable( sdbcx::OCollection* _pTables,
94 : : const Reference< XConnection >& _xConnection,
95 : : const ::rtl::OUString& _Name,
96 : : const ::rtl::OUString& _Type,
97 : : const ::rtl::OUString& _Description ,
98 : : const ::rtl::OUString& _SchemaName,
99 : : const ::rtl::OUString& _CatalogName,
100 : : sal_Int32 _nPrivileges
101 : : ) : OTableHelper( _pTables,
102 : : _xConnection,
103 : : sal_True,
104 : : _Name,
105 : : _Type,
106 : : _Description,
107 : : _SchemaName,
108 : : _CatalogName)
109 : 0 : , m_nPrivileges(_nPrivileges)
110 : : {
111 : 0 : construct();
112 : 0 : }
113 : : // -------------------------------------------------------------------------
114 : 0 : void OMySQLTable::construct()
115 : : {
116 : 0 : OTableHelper::construct();
117 : 0 : if ( !isNew() )
118 : 0 : registerProperty(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_PRIVILEGES), PROPERTY_ID_PRIVILEGES,PropertyAttribute::READONLY,&m_nPrivileges, ::getCppuType(&m_nPrivileges));
119 : 0 : }
120 : : // -----------------------------------------------------------------------------
121 : 0 : ::cppu::IPropertyArrayHelper* OMySQLTable::createArrayHelper( sal_Int32 /*_nId*/ ) const
122 : : {
123 : 0 : return doCreateArrayHelper();
124 : : }
125 : : // -------------------------------------------------------------------------
126 : 0 : ::cppu::IPropertyArrayHelper & OMySQLTable::getInfoHelper()
127 : : {
128 : 0 : return *static_cast<OMySQLTable_PROP*>(const_cast<OMySQLTable*>(this))->getArrayHelper(isNew() ? 1 : 0);
129 : : }
130 : : // -----------------------------------------------------------------------------
131 : 0 : sdbcx::OCollection* OMySQLTable::createColumns(const TStringVector& _rNames)
132 : : {
133 : 0 : OMySQLColumns* pColumns = new OMySQLColumns(*this,sal_True,m_aMutex,_rNames);
134 : 0 : pColumns->setParent(this);
135 : 0 : return pColumns;
136 : : }
137 : : // -----------------------------------------------------------------------------
138 : 0 : sdbcx::OCollection* OMySQLTable::createKeys(const TStringVector& _rNames)
139 : : {
140 : 0 : return new OMySQLKeysHelper(this,m_aMutex,_rNames);
141 : : }
142 : : // -----------------------------------------------------------------------------
143 : 0 : sdbcx::OCollection* OMySQLTable::createIndexes(const TStringVector& _rNames)
144 : : {
145 : 0 : return new OIndexesHelper(this,m_aMutex,_rNames);
146 : : }
147 : : //--------------------------------------------------------------------------
148 : 0 : Sequence< sal_Int8 > OMySQLTable::getUnoTunnelImplementationId()
149 : : {
150 : : static ::cppu::OImplementationId * pId = 0;
151 : 0 : if (! pId)
152 : : {
153 : 0 : ::osl::MutexGuard aGuard( ::osl::Mutex::getGlobalMutex() );
154 : 0 : if (! pId)
155 : : {
156 : 0 : static ::cppu::OImplementationId aId;
157 : 0 : pId = &aId;
158 : 0 : }
159 : : }
160 : 0 : return pId->getImplementationId();
161 : : }
162 : :
163 : : // com::sun::star::lang::XUnoTunnel
164 : : //------------------------------------------------------------------
165 : 0 : sal_Int64 OMySQLTable::getSomething( const Sequence< sal_Int8 > & rId ) throw (RuntimeException)
166 : : {
167 : 0 : return (rId.getLength() == 16 && 0 == memcmp(getUnoTunnelImplementationId().getConstArray(), rId.getConstArray(), 16 ) )
168 : : ? reinterpret_cast< sal_Int64 >( this )
169 : 0 : : OTable_TYPEDEF::getSomething(rId);
170 : : }
171 : : // -------------------------------------------------------------------------
172 : : // XAlterTable
173 : 0 : void SAL_CALL OMySQLTable::alterColumnByName( const ::rtl::OUString& colName, const Reference< XPropertySet >& descriptor ) throw(SQLException, NoSuchElementException, RuntimeException)
174 : : {
175 : 0 : ::osl::MutexGuard aGuard(m_aMutex);
176 : : checkDisposed(
177 : : #ifdef GCC
178 : : ::connectivity::sdbcx::OTableDescriptor_BASE::rBHelper.bDisposed
179 : : #else
180 : : rBHelper.bDisposed
181 : : #endif
182 : 0 : );
183 : :
184 : 0 : if ( m_pColumns && !m_pColumns->hasByName(colName) )
185 : 0 : throw NoSuchElementException(colName,*this);
186 : :
187 : :
188 : 0 : if ( !isNew() )
189 : : {
190 : : // first we have to check what should be altered
191 : 0 : Reference<XPropertySet> xProp;
192 : 0 : m_pColumns->getByName(colName) >>= xProp;
193 : : // first check the types
194 : 0 : sal_Int32 nOldType = 0,nNewType = 0,nOldPrec = 0,nNewPrec = 0,nOldScale = 0,nNewScale = 0;
195 : :
196 : 0 : ::dbtools::OPropertyMap& rProp = OMetaConnection::getPropMap();
197 : 0 : xProp->getPropertyValue(rProp.getNameByIndex(PROPERTY_ID_TYPE)) >>= nOldType;
198 : 0 : descriptor->getPropertyValue(rProp.getNameByIndex(PROPERTY_ID_TYPE)) >>= nNewType;
199 : : // and precsions and scale
200 : 0 : xProp->getPropertyValue(rProp.getNameByIndex(PROPERTY_ID_PRECISION)) >>= nOldPrec;
201 : 0 : descriptor->getPropertyValue(rProp.getNameByIndex(PROPERTY_ID_PRECISION))>>= nNewPrec;
202 : 0 : xProp->getPropertyValue(rProp.getNameByIndex(PROPERTY_ID_SCALE)) >>= nOldScale;
203 : 0 : descriptor->getPropertyValue(rProp.getNameByIndex(PROPERTY_ID_SCALE)) >>= nNewScale;
204 : : // second: check the "is nullable" value
205 : 0 : sal_Int32 nOldNullable = 0,nNewNullable = 0;
206 : 0 : xProp->getPropertyValue(rProp.getNameByIndex(PROPERTY_ID_ISNULLABLE)) >>= nOldNullable;
207 : 0 : descriptor->getPropertyValue(rProp.getNameByIndex(PROPERTY_ID_ISNULLABLE)) >>= nNewNullable;
208 : :
209 : : // check also the auto_increment
210 : 0 : sal_Bool bOldAutoIncrement = sal_False,bAutoIncrement = sal_False;
211 : 0 : xProp->getPropertyValue(rProp.getNameByIndex(PROPERTY_ID_ISAUTOINCREMENT)) >>= bOldAutoIncrement;
212 : 0 : descriptor->getPropertyValue(rProp.getNameByIndex(PROPERTY_ID_ISAUTOINCREMENT)) >>= bAutoIncrement;
213 : 0 : bool bColumnNameChanged = false;
214 : 0 : ::rtl::OUString sOldDesc,sNewDesc;
215 : 0 : xProp->getPropertyValue(rProp.getNameByIndex(PROPERTY_ID_DESCRIPTION)) >>= sOldDesc;
216 : 0 : descriptor->getPropertyValue(rProp.getNameByIndex(PROPERTY_ID_DESCRIPTION)) >>= sNewDesc;
217 : :
218 : 0 : if ( nOldType != nNewType
219 : : || nOldPrec != nNewPrec
220 : : || nOldScale != nNewScale
221 : : || nNewNullable != nOldNullable
222 : : || bOldAutoIncrement != bAutoIncrement
223 : 0 : || sOldDesc != sNewDesc )
224 : : {
225 : : // special handling because they change dthe type names to distinguish
226 : : // if a column should be an auto_incmrement one
227 : 0 : if ( bOldAutoIncrement != bAutoIncrement )
228 : : {
229 : 0 : ::rtl::OUString sTypeName;
230 : 0 : descriptor->getPropertyValue(rProp.getNameByIndex(PROPERTY_ID_TYPENAME)) >>= sTypeName;
231 : :
232 : 0 : static ::rtl::OUString s_sAutoIncrement("auto_increment");
233 : 0 : if ( bAutoIncrement )
234 : : {
235 : 0 : if ( sTypeName.indexOf(s_sAutoIncrement) == -1 )
236 : : {
237 : 0 : sTypeName += ::rtl::OUString(" ");
238 : 0 : sTypeName += s_sAutoIncrement;
239 : : }
240 : : }
241 : : else
242 : : {
243 : 0 : sal_Int32 nIndex = 0;
244 : 0 : if ( !sTypeName.isEmpty() && (nIndex = sTypeName.indexOf(s_sAutoIncrement)) != -1 )
245 : : {
246 : 0 : sTypeName = sTypeName.copy(0,nIndex);
247 : 0 : descriptor->setPropertyValue(rProp.getNameByIndex(PROPERTY_ID_TYPENAME),makeAny(sTypeName));
248 : : }
249 : 0 : }
250 : : }
251 : 0 : alterColumnType(nNewType,colName,descriptor);
252 : 0 : bColumnNameChanged = true;
253 : : }
254 : :
255 : : // third: check the default values
256 : 0 : ::rtl::OUString sNewDefault,sOldDefault;
257 : 0 : xProp->getPropertyValue(rProp.getNameByIndex(PROPERTY_ID_DEFAULTVALUE)) >>= sOldDefault;
258 : 0 : descriptor->getPropertyValue(rProp.getNameByIndex(PROPERTY_ID_DEFAULTVALUE)) >>= sNewDefault;
259 : :
260 : 0 : if(!sOldDefault.isEmpty())
261 : : {
262 : 0 : dropDefaultValue(colName);
263 : 0 : if(!sNewDefault.isEmpty() && sOldDefault != sNewDefault)
264 : 0 : alterDefaultValue(sNewDefault,colName);
265 : : }
266 : 0 : else if(!sNewDefault.isEmpty())
267 : 0 : alterDefaultValue(sNewDefault,colName);
268 : :
269 : : // now we should look if the name of the column changed
270 : 0 : ::rtl::OUString sNewColumnName;
271 : 0 : descriptor->getPropertyValue(rProp.getNameByIndex(PROPERTY_ID_NAME)) >>= sNewColumnName;
272 : 0 : if ( !sNewColumnName.equalsIgnoreAsciiCase(colName) && !bColumnNameChanged )
273 : : {
274 : 0 : ::rtl::OUString sSql = getAlterTableColumnPart();
275 : 0 : sSql += ::rtl::OUString(" CHANGE ");
276 : 0 : const ::rtl::OUString sQuote = getMetaData()->getIdentifierQuoteString( );
277 : 0 : sSql += ::dbtools::quoteName(sQuote,colName);
278 : 0 : sSql += ::rtl::OUString(" ");
279 : 0 : sSql += OTables::adjustSQL(::dbtools::createStandardColumnPart(descriptor,getConnection(),static_cast<OTables*>(m_pTables),getTypeCreatePattern()));
280 : 0 : executeStatement(sSql);
281 : : }
282 : 0 : m_pColumns->refresh();
283 : : }
284 : : else
285 : : {
286 : 0 : if(m_pColumns)
287 : : {
288 : 0 : m_pColumns->dropByName(colName);
289 : 0 : m_pColumns->appendByDescriptor(descriptor);
290 : : }
291 : 0 : }
292 : :
293 : 0 : }
294 : : // -----------------------------------------------------------------------------
295 : 0 : void OMySQLTable::alterColumnType(sal_Int32 nNewType,const ::rtl::OUString& _rColName, const Reference<XPropertySet>& _xDescriptor)
296 : : {
297 : 0 : ::rtl::OUString sSql = getAlterTableColumnPart();
298 : 0 : sSql += ::rtl::OUString(" CHANGE ");
299 : 0 : const ::rtl::OUString sQuote = getMetaData()->getIdentifierQuoteString( );
300 : 0 : sSql += ::dbtools::quoteName(sQuote,_rColName);
301 : 0 : sSql += ::rtl::OUString(" ");
302 : :
303 : 0 : OColumn* pColumn = new OColumn(sal_True);
304 : 0 : Reference<XPropertySet> xProp = pColumn;
305 : 0 : ::comphelper::copyProperties(_xDescriptor,xProp);
306 : 0 : xProp->setPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_TYPE),makeAny(nNewType));
307 : :
308 : 0 : sSql += OTables::adjustSQL(::dbtools::createStandardColumnPart(xProp,getConnection(),static_cast<OTables*>(m_pTables),getTypeCreatePattern()));
309 : 0 : executeStatement(sSql);
310 : 0 : }
311 : : // -----------------------------------------------------------------------------
312 : 0 : ::rtl::OUString OMySQLTable::getTypeCreatePattern() const
313 : : {
314 : 0 : static const ::rtl::OUString s_sCreatePattern("(M,D)");
315 : 0 : return s_sCreatePattern;
316 : : }
317 : : // -----------------------------------------------------------------------------
318 : 0 : void OMySQLTable::alterDefaultValue(const ::rtl::OUString& _sNewDefault,const ::rtl::OUString& _rColName)
319 : : {
320 : 0 : ::rtl::OUString sSql = getAlterTableColumnPart();
321 : 0 : sSql += ::rtl::OUString(" ALTER ");
322 : :
323 : 0 : const ::rtl::OUString sQuote = getMetaData()->getIdentifierQuoteString( );
324 : 0 : sSql += ::dbtools::quoteName(sQuote,_rColName);
325 : 0 : sSql += ::rtl::OUString(" SET DEFAULT '") + _sNewDefault;
326 : 0 : sSql += ::rtl::OUString("'");
327 : :
328 : 0 : executeStatement(sSql);
329 : 0 : }
330 : : // -----------------------------------------------------------------------------
331 : 0 : void OMySQLTable::dropDefaultValue(const ::rtl::OUString& _rColName)
332 : : {
333 : 0 : ::rtl::OUString sSql = getAlterTableColumnPart();
334 : 0 : sSql += ::rtl::OUString(" ALTER ");
335 : :
336 : 0 : const ::rtl::OUString sQuote = getMetaData()->getIdentifierQuoteString( );
337 : 0 : sSql += ::dbtools::quoteName(sQuote,_rColName);
338 : 0 : sSql += ::rtl::OUString(" DROP DEFAULT");
339 : :
340 : 0 : executeStatement(sSql);
341 : 0 : }
342 : : // -----------------------------------------------------------------------------
343 : 0 : ::rtl::OUString OMySQLTable::getAlterTableColumnPart()
344 : : {
345 : 0 : ::rtl::OUString sSql( "ALTER TABLE " );
346 : 0 : const ::rtl::OUString sQuote = getMetaData()->getIdentifierQuoteString( );
347 : :
348 : : ::rtl::OUString sComposedName(
349 : 0 : ::dbtools::composeTableName( getMetaData(), m_CatalogName, m_SchemaName, m_Name, sal_True, ::dbtools::eInTableDefinitions ) );
350 : 0 : sSql += sComposedName;
351 : :
352 : 0 : return sSql;
353 : : }
354 : : // -----------------------------------------------------------------------------
355 : 0 : void OMySQLTable::executeStatement(const ::rtl::OUString& _rStatement )
356 : : {
357 : 0 : ::rtl::OUString sSQL = _rStatement;
358 : 0 : if(sSQL.lastIndexOf(',') == (sSQL.getLength()-1))
359 : 0 : sSQL = sSQL.replaceAt(sSQL.getLength()-1,1,::rtl::OUString(")"));
360 : :
361 : 0 : Reference< XStatement > xStmt = getConnection()->createStatement( );
362 : 0 : if ( xStmt.is() )
363 : : {
364 : 0 : xStmt->execute(sSQL);
365 : 0 : ::comphelper::disposeComponent(xStmt);
366 : 0 : }
367 : 0 : }
368 : : // -----------------------------------------------------------------------------
369 : 0 : ::rtl::OUString OMySQLTable::getRenameStart() const
370 : : {
371 : 0 : return ::rtl::OUString("RENAME TABLE ");
372 : : }
373 : :
374 : :
375 : :
376 : :
377 : : /* vim:set shiftwidth=4 softtabstop=4 expandtab: */
|
