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 "dbase/DTables.hxx"
27cdf0e10cSrcweir #include "dbase/DTable.hxx"
28cdf0e10cSrcweir #include <com/sun/star/sdbc/XRow.hpp>
29cdf0e10cSrcweir #include <com/sun/star/sdbc/XResultSet.hpp>
30cdf0e10cSrcweir #include <com/sun/star/sdbc/ColumnValue.hpp>
31cdf0e10cSrcweir #include <com/sun/star/sdbc/KeyRule.hpp>
32cdf0e10cSrcweir #include <com/sun/star/sdbcx/KeyType.hpp>
33cdf0e10cSrcweir #include "file/FCatalog.hxx"
34cdf0e10cSrcweir #include "file/FConnection.hxx"
35cdf0e10cSrcweir #include <com/sun/star/lang/XUnoTunnel.hpp>
36cdf0e10cSrcweir #include "dbase/DCatalog.hxx"
37cdf0e10cSrcweir #include <comphelper/types.hxx>
38cdf0e10cSrcweir #include "resource/dbase_res.hrc"
39cdf0e10cSrcweir #include "connectivity/dbexception.hxx"
40cdf0e10cSrcweir
41cdf0e10cSrcweir using namespace ::comphelper;
42cdf0e10cSrcweir using namespace connectivity;
43cdf0e10cSrcweir using namespace connectivity::dbase;
44cdf0e10cSrcweir using namespace connectivity::file;
45cdf0e10cSrcweir using namespace ::com::sun::star::uno;
46cdf0e10cSrcweir using namespace ::com::sun::star::beans;
47cdf0e10cSrcweir using namespace ::com::sun::star::sdbcx;
48cdf0e10cSrcweir using namespace ::com::sun::star::sdbc;
49cdf0e10cSrcweir using namespace ::com::sun::star::lang;
50cdf0e10cSrcweir using namespace ::com::sun::star::container;
51cdf0e10cSrcweir namespace starutil = ::com::sun::star::util;
52cdf0e10cSrcweir
createObject(const::rtl::OUString & _rName)53cdf0e10cSrcweir sdbcx::ObjectType ODbaseTables::createObject(const ::rtl::OUString& _rName)
54cdf0e10cSrcweir {
55cdf0e10cSrcweir ::rtl::OUString aName,aSchema;
56cdf0e10cSrcweir ODbaseTable* pRet = new ODbaseTable(this,(ODbaseConnection*)static_cast<OFileCatalog&>(m_rParent).getConnection(),
57cdf0e10cSrcweir _rName,::rtl::OUString::createFromAscii("TABLE"));
58cdf0e10cSrcweir
59cdf0e10cSrcweir sdbcx::ObjectType xRet = pRet;
60cdf0e10cSrcweir pRet->construct();
61cdf0e10cSrcweir return xRet;
62cdf0e10cSrcweir }
63cdf0e10cSrcweir // -------------------------------------------------------------------------
impl_refresh()64cdf0e10cSrcweir void ODbaseTables::impl_refresh( ) throw(RuntimeException)
65cdf0e10cSrcweir {
66cdf0e10cSrcweir static_cast<ODbaseCatalog*>(&m_rParent)->refreshTables();
67cdf0e10cSrcweir }
68cdf0e10cSrcweir // -------------------------------------------------------------------------
createDescriptor()69cdf0e10cSrcweir Reference< XPropertySet > ODbaseTables::createDescriptor()
70cdf0e10cSrcweir {
71cdf0e10cSrcweir return new ODbaseTable(this,(ODbaseConnection*)static_cast<OFileCatalog&>(m_rParent).getConnection());
72cdf0e10cSrcweir }
73cdf0e10cSrcweir typedef connectivity::sdbcx::OCollection ODbaseTables_BASE_BASE;
74cdf0e10cSrcweir // -------------------------------------------------------------------------
75cdf0e10cSrcweir // XAppend
appendObject(const::rtl::OUString & _rForName,const Reference<XPropertySet> & descriptor)76cdf0e10cSrcweir sdbcx::ObjectType ODbaseTables::appendObject( const ::rtl::OUString& _rForName, const Reference< XPropertySet >& descriptor )
77cdf0e10cSrcweir {
78cdf0e10cSrcweir Reference<XUnoTunnel> xTunnel(descriptor,UNO_QUERY);
79cdf0e10cSrcweir if(xTunnel.is())
80cdf0e10cSrcweir {
81cdf0e10cSrcweir ODbaseTable* pTable = reinterpret_cast< ODbaseTable* >( xTunnel->getSomething(ODbaseTable::getUnoTunnelImplementationId()) );
82cdf0e10cSrcweir if(pTable)
83cdf0e10cSrcweir {
84cdf0e10cSrcweir pTable->setPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_NAME),makeAny(_rForName));
85cdf0e10cSrcweir try
86cdf0e10cSrcweir {
87cdf0e10cSrcweir if(!pTable->CreateImpl())
88cdf0e10cSrcweir throw SQLException();
89cdf0e10cSrcweir }
90cdf0e10cSrcweir catch(SQLException&)
91cdf0e10cSrcweir {
92cdf0e10cSrcweir throw;
93cdf0e10cSrcweir }
94cdf0e10cSrcweir catch(Exception&)
95cdf0e10cSrcweir {
96cdf0e10cSrcweir throw SQLException();
97cdf0e10cSrcweir }
98cdf0e10cSrcweir }
99cdf0e10cSrcweir }
100cdf0e10cSrcweir return createObject( _rForName );
101cdf0e10cSrcweir }
102cdf0e10cSrcweir // -------------------------------------------------------------------------
103cdf0e10cSrcweir // XDrop
dropObject(sal_Int32 _nPos,const::rtl::OUString _sElementName)104cdf0e10cSrcweir void ODbaseTables::dropObject(sal_Int32 _nPos,const ::rtl::OUString _sElementName)
105cdf0e10cSrcweir {
106cdf0e10cSrcweir Reference< XUnoTunnel> xTunnel;
107cdf0e10cSrcweir try
108cdf0e10cSrcweir {
109cdf0e10cSrcweir xTunnel.set(getObject(_nPos),UNO_QUERY);
110cdf0e10cSrcweir }
111cdf0e10cSrcweir catch(const Exception&)
112cdf0e10cSrcweir {
113cdf0e10cSrcweir if(ODbaseTable::Drop_Static(ODbaseTable::getEntry(static_cast<OFileCatalog&>(m_rParent).getConnection(),_sElementName),sal_False,NULL))
114cdf0e10cSrcweir return;
115cdf0e10cSrcweir }
116cdf0e10cSrcweir
117cdf0e10cSrcweir if ( xTunnel.is() )
118cdf0e10cSrcweir {
119cdf0e10cSrcweir ODbaseTable* pTable = reinterpret_cast< ODbaseTable* >( xTunnel->getSomething(ODbaseTable::getUnoTunnelImplementationId()) );
120cdf0e10cSrcweir if(pTable)
121cdf0e10cSrcweir pTable->DropImpl();
122cdf0e10cSrcweir }
123cdf0e10cSrcweir else
124cdf0e10cSrcweir {
125cdf0e10cSrcweir const ::rtl::OUString sError( static_cast<OFileCatalog&>(m_rParent).getConnection()->getResources().getResourceStringWithSubstitution(
126cdf0e10cSrcweir STR_TABLE_NOT_DROP,
127cdf0e10cSrcweir "$tablename$", _sElementName
128cdf0e10cSrcweir ) );
129cdf0e10cSrcweir ::dbtools::throwGenericSQLException( sError, NULL );
130cdf0e10cSrcweir }
131cdf0e10cSrcweir }
132cdf0e10cSrcweir // -------------------------------------------------------------------------
queryInterface(const Type & rType)133cdf0e10cSrcweir Any SAL_CALL ODbaseTables::queryInterface( const Type & rType ) throw(RuntimeException)
134cdf0e10cSrcweir {
135cdf0e10cSrcweir typedef sdbcx::OCollection OTables_BASE;
136cdf0e10cSrcweir return OTables_BASE::queryInterface(rType);
137cdf0e10cSrcweir }
138cdf0e10cSrcweir // -----------------------------------------------------------------------------
139cdf0e10cSrcweir
140cdf0e10cSrcweir
141