1*9b5730f6SAndrew Rist /**************************************************************
2cdf0e10cSrcweir *
3*9b5730f6SAndrew Rist * Licensed to the Apache Software Foundation (ASF) under one
4*9b5730f6SAndrew Rist * or more contributor license agreements. See the NOTICE file
5*9b5730f6SAndrew Rist * distributed with this work for additional information
6*9b5730f6SAndrew Rist * regarding copyright ownership. The ASF licenses this file
7*9b5730f6SAndrew Rist * to you under the Apache License, Version 2.0 (the
8*9b5730f6SAndrew Rist * "License"); you may not use this file except in compliance
9*9b5730f6SAndrew Rist * with the License. You may obtain a copy of the License at
10*9b5730f6SAndrew Rist *
11*9b5730f6SAndrew Rist * http://www.apache.org/licenses/LICENSE-2.0
12*9b5730f6SAndrew Rist *
13*9b5730f6SAndrew Rist * Unless required by applicable law or agreed to in writing,
14*9b5730f6SAndrew Rist * software distributed under the License is distributed on an
15*9b5730f6SAndrew Rist * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16*9b5730f6SAndrew Rist * KIND, either express or implied. See the License for the
17*9b5730f6SAndrew Rist * specific language governing permissions and limitations
18*9b5730f6SAndrew Rist * under the License.
19*9b5730f6SAndrew Rist *
20*9b5730f6SAndrew Rist *************************************************************/
21*9b5730f6SAndrew Rist
22*9b5730f6SAndrew Rist
23cdf0e10cSrcweir
24cdf0e10cSrcweir // MARKER(update_precomp.py): autogen include statement, do not remove
25cdf0e10cSrcweir #include "precompiled_connectivity.hxx"
26cdf0e10cSrcweir #include "connectivity/TColumnsHelper.hxx"
27cdf0e10cSrcweir #include "connectivity/sdbcx/VColumn.hxx"
28cdf0e10cSrcweir #include "connectivity/sdbcx/VColumn.hxx"
29cdf0e10cSrcweir #include <com/sun/star/sdbc/XRow.hpp>
30cdf0e10cSrcweir #include <com/sun/star/sdbc/XResultSet.hpp>
31cdf0e10cSrcweir #include <com/sun/star/sdbc/DataType.hpp>
32cdf0e10cSrcweir #include <com/sun/star/sdbc/ColumnValue.hpp>
33cdf0e10cSrcweir #include <com/sun/star/sdbcx/KeyType.hpp>
34cdf0e10cSrcweir #include <com/sun/star/sdbcx/XColumnsSupplier.hpp>
35cdf0e10cSrcweir #include <com/sun/star/sdbcx/XKeysSupplier.hpp>
36cdf0e10cSrcweir #include <comphelper/types.hxx>
37cdf0e10cSrcweir #include "connectivity/dbtools.hxx"
38cdf0e10cSrcweir #include "TConnection.hxx"
39cdf0e10cSrcweir #include "connectivity/TTableHelper.hxx"
40cdf0e10cSrcweir #include <comphelper/property.hxx>
41cdf0e10cSrcweir
42cdf0e10cSrcweir using namespace ::comphelper;
43cdf0e10cSrcweir
44cdf0e10cSrcweir
45cdf0e10cSrcweir using namespace connectivity::sdbcx;
46cdf0e10cSrcweir using namespace connectivity;
47cdf0e10cSrcweir using namespace dbtools;
48cdf0e10cSrcweir using namespace ::com::sun::star::uno;
49cdf0e10cSrcweir using namespace ::com::sun::star::beans;
50cdf0e10cSrcweir using namespace ::com::sun::star::sdbcx;
51cdf0e10cSrcweir using namespace ::com::sun::star::sdbc;
52cdf0e10cSrcweir using namespace ::com::sun::star::container;
53cdf0e10cSrcweir using namespace ::com::sun::star::lang;
54cdf0e10cSrcweir typedef connectivity::sdbcx::OCollection OCollection_TYPE;
55cdf0e10cSrcweir
56cdf0e10cSrcweir namespace connectivity
57cdf0e10cSrcweir {
58cdf0e10cSrcweir class OColumnsHelperImpl
59cdf0e10cSrcweir {
60cdf0e10cSrcweir public:
OColumnsHelperImpl(sal_Bool _bCase)61cdf0e10cSrcweir OColumnsHelperImpl(sal_Bool _bCase)
62cdf0e10cSrcweir : m_aColumnInfo(_bCase)
63cdf0e10cSrcweir {
64cdf0e10cSrcweir }
65cdf0e10cSrcweir ColumnInformationMap m_aColumnInfo;
66cdf0e10cSrcweir };
67cdf0e10cSrcweir }
68cdf0e10cSrcweir
OColumnsHelper(::cppu::OWeakObject & _rParent,sal_Bool _bCase,::osl::Mutex & _rMutex,const TStringVector & _rVector,sal_Bool _bUseHardRef)69cdf0e10cSrcweir OColumnsHelper::OColumnsHelper( ::cppu::OWeakObject& _rParent
70cdf0e10cSrcweir ,sal_Bool _bCase
71cdf0e10cSrcweir ,::osl::Mutex& _rMutex
72cdf0e10cSrcweir ,const TStringVector &_rVector
73cdf0e10cSrcweir ,sal_Bool _bUseHardRef
74cdf0e10cSrcweir ) : OCollection(_rParent,_bCase,_rMutex,_rVector,sal_False,_bUseHardRef)
75cdf0e10cSrcweir ,m_pImpl(NULL)
76cdf0e10cSrcweir ,m_pTable(NULL)
77cdf0e10cSrcweir {
78cdf0e10cSrcweir }
79cdf0e10cSrcweir // -----------------------------------------------------------------------------
~OColumnsHelper()80cdf0e10cSrcweir OColumnsHelper::~OColumnsHelper()
81cdf0e10cSrcweir {
82cdf0e10cSrcweir delete m_pImpl;
83cdf0e10cSrcweir m_pImpl = NULL;
84cdf0e10cSrcweir }
85cdf0e10cSrcweir // -----------------------------------------------------------------------------
86cdf0e10cSrcweir
createObject(const::rtl::OUString & _rName)87cdf0e10cSrcweir sdbcx::ObjectType OColumnsHelper::createObject(const ::rtl::OUString& _rName)
88cdf0e10cSrcweir {
89cdf0e10cSrcweir OSL_ENSURE(m_pTable,"NO Table set. Error!");
90cdf0e10cSrcweir Reference<XConnection> xConnection = m_pTable->getConnection();
91cdf0e10cSrcweir
92cdf0e10cSrcweir if ( !m_pImpl )
93cdf0e10cSrcweir m_pImpl = new OColumnsHelperImpl(isCaseSensitive());
94cdf0e10cSrcweir
95cdf0e10cSrcweir sal_Bool bQueryInfo = sal_True;
96cdf0e10cSrcweir sal_Bool bAutoIncrement = sal_False;
97cdf0e10cSrcweir sal_Bool bIsCurrency = sal_False;
98cdf0e10cSrcweir sal_Int32 nDataType = DataType::OTHER;
99cdf0e10cSrcweir
100cdf0e10cSrcweir ColumnInformationMap::iterator aFind = m_pImpl->m_aColumnInfo.find(_rName);
101cdf0e10cSrcweir if ( aFind == m_pImpl->m_aColumnInfo.end() ) // we have to fill it
102cdf0e10cSrcweir {
103cdf0e10cSrcweir ::rtl::OUString sComposedName = ::dbtools::composeTableNameForSelect( xConnection, m_pTable );
104cdf0e10cSrcweir collectColumnInformation(xConnection,sComposedName,::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("*")) ,m_pImpl->m_aColumnInfo);
105cdf0e10cSrcweir aFind = m_pImpl->m_aColumnInfo.find(_rName);
106cdf0e10cSrcweir }
107cdf0e10cSrcweir if ( aFind != m_pImpl->m_aColumnInfo.end() )
108cdf0e10cSrcweir {
109cdf0e10cSrcweir bQueryInfo = sal_False;
110cdf0e10cSrcweir bAutoIncrement = aFind->second.first.first;
111cdf0e10cSrcweir bIsCurrency = aFind->second.first.second;
112cdf0e10cSrcweir nDataType = aFind->second.second;
113cdf0e10cSrcweir } // if ( aFind != m_pImpl->m_aColumnInfo.end() )
114cdf0e10cSrcweir
115cdf0e10cSrcweir sdbcx::ObjectType xRet;
116cdf0e10cSrcweir const ColumnDesc* pColDesc = m_pTable->getColumnDescription(_rName);
117cdf0e10cSrcweir if ( pColDesc )
118cdf0e10cSrcweir {
119cdf0e10cSrcweir Reference<XPropertySet> xPr = m_pTable;
120cdf0e10cSrcweir const Reference<XNameAccess> xPrimaryKeyColumns = getPrimaryKeyColumns_throw(xPr);
121cdf0e10cSrcweir sal_Int32 nField11 = pColDesc->nField11;
122cdf0e10cSrcweir if ( nField11 != ColumnValue::NO_NULLS && xPrimaryKeyColumns.is() && xPrimaryKeyColumns->hasByName(_rName) )
123cdf0e10cSrcweir {
124cdf0e10cSrcweir nField11 = ColumnValue::NO_NULLS;
125cdf0e10cSrcweir } // if ( xKeys.is() )
126cdf0e10cSrcweir connectivity::sdbcx::OColumn* pRet = new connectivity::sdbcx::OColumn(_rName,
127cdf0e10cSrcweir pColDesc->aField6,
128cdf0e10cSrcweir pColDesc->sField13,
129cdf0e10cSrcweir pColDesc->sField12,
130cdf0e10cSrcweir nField11,
131cdf0e10cSrcweir pColDesc->nField7,
132cdf0e10cSrcweir pColDesc->nField9,
133cdf0e10cSrcweir pColDesc->nField5,
134cdf0e10cSrcweir bAutoIncrement,
135cdf0e10cSrcweir sal_False,
136cdf0e10cSrcweir bIsCurrency,
137cdf0e10cSrcweir isCaseSensitive());
138cdf0e10cSrcweir
139cdf0e10cSrcweir xRet = pRet;
140cdf0e10cSrcweir }
141cdf0e10cSrcweir else
142cdf0e10cSrcweir {
143cdf0e10cSrcweir
144cdf0e10cSrcweir xRet.set(::dbtools::createSDBCXColumn( m_pTable,
145cdf0e10cSrcweir xConnection,
146cdf0e10cSrcweir _rName,
147cdf0e10cSrcweir isCaseSensitive(),
148cdf0e10cSrcweir bQueryInfo,
149cdf0e10cSrcweir bAutoIncrement,
150cdf0e10cSrcweir bIsCurrency,
151cdf0e10cSrcweir nDataType),UNO_QUERY);
152cdf0e10cSrcweir }
153cdf0e10cSrcweir return xRet;
154cdf0e10cSrcweir }
155cdf0e10cSrcweir
156cdf0e10cSrcweir // -------------------------------------------------------------------------
impl_refresh()157cdf0e10cSrcweir void OColumnsHelper::impl_refresh() throw(RuntimeException)
158cdf0e10cSrcweir {
159cdf0e10cSrcweir if ( m_pTable )
160cdf0e10cSrcweir {
161cdf0e10cSrcweir m_pImpl->m_aColumnInfo.clear();
162cdf0e10cSrcweir m_pTable->refreshColumns();
163cdf0e10cSrcweir }
164cdf0e10cSrcweir }
165cdf0e10cSrcweir // -------------------------------------------------------------------------
createDescriptor()166cdf0e10cSrcweir Reference< XPropertySet > OColumnsHelper::createDescriptor()
167cdf0e10cSrcweir {
168cdf0e10cSrcweir return new OColumn(sal_True);
169cdf0e10cSrcweir }
170cdf0e10cSrcweir // -----------------------------------------------------------------------------
171cdf0e10cSrcweir // XAppend
appendObject(const::rtl::OUString & _rForName,const Reference<XPropertySet> & descriptor)172cdf0e10cSrcweir sdbcx::ObjectType OColumnsHelper::appendObject( const ::rtl::OUString& _rForName, const Reference< XPropertySet >& descriptor )
173cdf0e10cSrcweir {
174cdf0e10cSrcweir ::osl::MutexGuard aGuard(m_rMutex);
175cdf0e10cSrcweir OSL_ENSURE(m_pTable,"OColumnsHelper::appendByDescriptor: Table is null!");
176cdf0e10cSrcweir if ( !m_pTable || m_pTable->isNew() )
177cdf0e10cSrcweir return cloneDescriptor( descriptor );
178cdf0e10cSrcweir
179cdf0e10cSrcweir Reference<XDatabaseMetaData> xMetaData = m_pTable->getConnection()->getMetaData();
180cdf0e10cSrcweir ::rtl::OUString aSql = ::rtl::OUString::createFromAscii("ALTER TABLE ");
181cdf0e10cSrcweir ::rtl::OUString aQuote = xMetaData->getIdentifierQuoteString( );
182cdf0e10cSrcweir
183cdf0e10cSrcweir aSql += ::dbtools::composeTableName( xMetaData, m_pTable, ::dbtools::eInTableDefinitions, false, false, true );
184cdf0e10cSrcweir aSql += ::rtl::OUString::createFromAscii(" ADD ");
185cdf0e10cSrcweir aSql += ::dbtools::createStandardColumnPart(descriptor,m_pTable->getConnection(),NULL,m_pTable->getTypeCreatePattern());
186cdf0e10cSrcweir
187cdf0e10cSrcweir Reference< XStatement > xStmt = m_pTable->getConnection()->createStatement( );
188cdf0e10cSrcweir if ( xStmt.is() )
189cdf0e10cSrcweir {
190cdf0e10cSrcweir xStmt->execute(aSql);
191cdf0e10cSrcweir ::comphelper::disposeComponent(xStmt);
192cdf0e10cSrcweir }
193cdf0e10cSrcweir return createObject( _rForName );
194cdf0e10cSrcweir }
195cdf0e10cSrcweir // -------------------------------------------------------------------------
196cdf0e10cSrcweir // XDrop
dropObject(sal_Int32,const::rtl::OUString _sElementName)197cdf0e10cSrcweir void OColumnsHelper::dropObject(sal_Int32 /*_nPos*/,const ::rtl::OUString _sElementName)
198cdf0e10cSrcweir {
199cdf0e10cSrcweir OSL_ENSURE(m_pTable,"OColumnsHelper::dropByName: Table is null!");
200cdf0e10cSrcweir if ( m_pTable && !m_pTable->isNew() )
201cdf0e10cSrcweir {
202cdf0e10cSrcweir ::rtl::OUString aSql = ::rtl::OUString::createFromAscii("ALTER TABLE ");
203cdf0e10cSrcweir Reference<XDatabaseMetaData> xMetaData = m_pTable->getConnection()->getMetaData();
204cdf0e10cSrcweir ::rtl::OUString aQuote = xMetaData->getIdentifierQuoteString( );
205cdf0e10cSrcweir
206cdf0e10cSrcweir aSql += ::dbtools::composeTableName( xMetaData, m_pTable, ::dbtools::eInTableDefinitions, false, false, true );
207cdf0e10cSrcweir aSql += ::rtl::OUString::createFromAscii(" DROP ");
208cdf0e10cSrcweir aSql += ::dbtools::quoteName( aQuote,_sElementName);
209cdf0e10cSrcweir
210cdf0e10cSrcweir Reference< XStatement > xStmt = m_pTable->getConnection()->createStatement( );
211cdf0e10cSrcweir if ( xStmt.is() )
212cdf0e10cSrcweir {
213cdf0e10cSrcweir xStmt->execute(aSql);
214cdf0e10cSrcweir ::comphelper::disposeComponent(xStmt);
215cdf0e10cSrcweir }
216cdf0e10cSrcweir }
217cdf0e10cSrcweir }
218cdf0e10cSrcweir // -----------------------------------------------------------------------------
219cdf0e10cSrcweir
220cdf0e10cSrcweir
221cdf0e10cSrcweir
222