xref: /AOO41X/main/dbaccess/source/ui/relationdesign/RelationController.cxx (revision 96de54900b79e13b861fbc62cbf36018b54e21b7)
1 /**************************************************************
2  *
3  * Licensed to the Apache Software Foundation (ASF) under one
4  * or more contributor license agreements.  See the NOTICE file
5  * distributed with this work for additional information
6  * regarding copyright ownership.  The ASF licenses this file
7  * to you under the Apache License, Version 2.0 (the
8  * "License"); you may not use this file except in compliance
9  * with the License.  You may obtain a copy of the License at
10  *
11  *   http://www.apache.org/licenses/LICENSE-2.0
12  *
13  * Unless required by applicable law or agreed to in writing,
14  * software distributed under the License is distributed on an
15  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16  * KIND, either express or implied.  See the License for the
17  * specific language governing permissions and limitations
18  * under the License.
19  *
20  *************************************************************/
21 
22 
23 
24 // MARKER(update_precomp.py): autogen include statement, do not remove
25 #include "precompiled_dbaccess.hxx"
26 #include "dbu_reghelper.hxx"
27 #include <sfx2/sfxsids.hrc>
28 #include "dbu_rel.hrc"
29 #include <vcl/svapp.hxx>
30 #include "browserids.hxx"
31 #include <comphelper/types.hxx>
32 #include "dbustrings.hrc"
33 #include <connectivity/dbtools.hxx>
34 #include <com/sun/star/frame/FrameSearchFlag.hpp>
35 #include <comphelper/extract.hxx>
36 #include <com/sun/star/container/XChild.hpp>
37 #include <com/sun/star/container/XNameContainer.hpp>
38 #include <com/sun/star/sdbcx/XDataDescriptorFactory.hpp>
39 #include <com/sun/star/sdbcx/XTablesSupplier.hpp>
40 #include <com/sun/star/sdbcx/KeyType.hpp>
41 #include <com/sun/star/sdbcx/XDrop.hpp>
42 #include <com/sun/star/sdbcx/XAlterTable.hpp>
43 #include <com/sun/star/sdbcx/XAppend.hpp>
44 #include <com/sun/star/sdbcx/XKeysSupplier.hpp>
45 #include <com/sun/star/sdbcx/XColumnsSupplier.hpp>
46 #include <com/sun/star/sdb/SQLContext.hpp>
47 #include <com/sun/star/sdbc/SQLWarning.hpp>
48 #include <com/sun/star/sdbc/ColumnValue.hpp>
49 #include <com/sun/star/sdbc/XRow.hpp>
50 #include <connectivity/dbexception.hxx>
51 #include <connectivity/dbmetadata.hxx>
52 #include <com/sun/star/ui/dialogs/XExecutableDialog.hpp>
53 #include <comphelper/streamsection.hxx>
54 #include <comphelper/basicio.hxx>
55 #include <comphelper/seqstream.hxx>
56 #include <com/sun/star/io/XActiveDataSource.hpp>
57 #include <com/sun/star/io/XActiveDataSink.hpp>
58 #include "sqlmessage.hxx"
59 #include "RelationController.hxx"
60 #include <vcl/msgbox.hxx>
61 #include "TableWindowData.hxx"
62 #include "dbustrings.hrc"
63 #include "UITools.hxx"
64 #include "RTableConnectionData.hxx"
65 #include "RelationTableView.hxx"
66 #include "RelationDesignView.hxx"
67 #include <tools/debug.hxx>
68 #include <tools/diagnose_ex.h>
69 #include <vcl/waitobj.hxx>
70 #include <osl/thread.hxx>
71 #include <vos/mutex.hxx>
72 
73 
74 #define MAX_THREADS 10
75 
createRegistryInfo_ORelationControl()76 extern "C" void SAL_CALL createRegistryInfo_ORelationControl()
77 {
78     static ::dbaui::OMultiInstanceAutoRegistration< ::dbaui::ORelationController > aAutoRegistration;
79 }
80 
81 
82 using namespace ::com::sun::star::uno;
83 using namespace ::com::sun::star::io;
84 using namespace ::com::sun::star::beans;
85 using namespace ::com::sun::star::frame;
86 using namespace ::com::sun::star::util;
87 using namespace ::com::sun::star::lang;
88 using namespace ::com::sun::star::container;
89 using namespace ::com::sun::star::sdbcx;
90 using namespace ::com::sun::star::sdbc;
91 using namespace ::com::sun::star::sdb;
92 using namespace ::com::sun::star::ui::dialogs;
93 using namespace ::com::sun::star::util;
94 //  using namespace ::com::sun::star::sdbcx;
95 //  using namespace ::connectivity;
96 using namespace ::dbtools;
97 using namespace ::dbaui;
98 using namespace ::comphelper;
99 using namespace ::osl;
100 
101 //------------------------------------------------------------------------------
getImplementationName()102 ::rtl::OUString SAL_CALL ORelationController::getImplementationName() throw( RuntimeException )
103 {
104     return getImplementationName_Static();
105 }
106 
107 //------------------------------------------------------------------------------
getImplementationName_Static()108 ::rtl::OUString ORelationController::getImplementationName_Static() throw( RuntimeException )
109 {
110     return ::rtl::OUString::createFromAscii("org.openoffice.comp.dbu.ORelationDesign");
111 }
112 //------------------------------------------------------------------------------
getSupportedServiceNames_Static(void)113 Sequence< ::rtl::OUString> ORelationController::getSupportedServiceNames_Static(void) throw( RuntimeException )
114 {
115     Sequence< ::rtl::OUString> aSupported(1);
116     aSupported.getArray()[0] = ::rtl::OUString::createFromAscii("com.sun.star.sdb.RelationDesign");
117     return aSupported;
118 }
119 //-------------------------------------------------------------------------
getSupportedServiceNames()120 Sequence< ::rtl::OUString> SAL_CALL ORelationController::getSupportedServiceNames() throw(RuntimeException)
121 {
122     return getSupportedServiceNames_Static();
123 }
124 // -------------------------------------------------------------------------
Create(const Reference<XMultiServiceFactory> & _rxFactory)125 Reference< XInterface > SAL_CALL ORelationController::Create(const Reference<XMultiServiceFactory >& _rxFactory)
126 {
127     return *(new ORelationController(_rxFactory));
128 }
129 DBG_NAME(ORelationController);
130 // -----------------------------------------------------------------------------
ORelationController(const Reference<XMultiServiceFactory> & _rM)131 ORelationController::ORelationController(const Reference< XMultiServiceFactory >& _rM)
132     : OJoinController(_rM)
133     ,m_nThreadEvent(0)
134     ,m_bRelationsPossible(sal_True)
135 {
136     DBG_CTOR(ORelationController,NULL);
137     InvalidateAll();
138 }
139 // -----------------------------------------------------------------------------
~ORelationController()140 ORelationController::~ORelationController()
141 {
142     DBG_DTOR(ORelationController,NULL);
143 }
144 // -----------------------------------------------------------------------------
GetState(sal_uInt16 _nId) const145 FeatureState ORelationController::GetState(sal_uInt16 _nId) const
146 {
147     FeatureState aReturn;
148     aReturn.bEnabled = m_bRelationsPossible;
149     switch (_nId)
150     {
151         case SID_RELATION_ADD_RELATION:
152             aReturn.bEnabled = !m_vTableData.empty() && isConnected() && isEditable();
153             aReturn.bChecked = false;
154             break;
155         case ID_BROWSER_SAVEDOC:
156             aReturn.bEnabled = haveDataSource() && impl_isModified();
157             break;
158         default:
159             aReturn = OJoinController::GetState(_nId);
160             break;
161     }
162     return aReturn;
163 }
164 // -----------------------------------------------------------------------------
Execute(sal_uInt16 _nId,const Sequence<PropertyValue> & aArgs)165 void ORelationController::Execute(sal_uInt16 _nId, const Sequence< PropertyValue >& aArgs)
166 {
167     switch(_nId)
168     {
169         case ID_BROWSER_SAVEDOC:
170             {
171                 OSL_ENSURE(isEditable(),"Slot ID_BROWSER_SAVEDOC should not be enabled!");
172                 if(!::dbaui::checkDataSourceAvailable(::comphelper::getString(getDataSource()->getPropertyValue(PROPERTY_NAME)),getORB()))
173                 {
174                     String aMessage(ModuleRes(STR_DATASOURCE_DELETED));
175                     OSQLWarningBox( getView(), aMessage ).Execute();
176                 }
177                 else
178                 {
179                     // now we save the layout information
180                     //  create the output stream
181                     try
182                     {
183                         if ( haveDataSource() && getDataSource()->getPropertySetInfo()->hasPropertyByName(PROPERTY_LAYOUTINFORMATION) )
184                         {
185                             ::comphelper::NamedValueCollection aWindowsData;
186                             saveTableWindows( aWindowsData );
187                             getDataSource()->setPropertyValue( PROPERTY_LAYOUTINFORMATION, makeAny( aWindowsData.getPropertyValues() ) );
188                             setModified(sal_False);
189                         }
190                     }
191                     catch ( const Exception& )
192                     {
193                         DBG_UNHANDLED_EXCEPTION();
194                     }
195                 }
196             }
197             break;
198         case SID_RELATION_ADD_RELATION:
199             static_cast<ORelationTableView*>(static_cast<ORelationDesignView*>( getView() )->getTableView())->AddNewRelation();
200             break;
201         default:
202             OJoinController::Execute(_nId,aArgs);
203             return;
204     }
205     InvalidateFeature(_nId);
206 }
207 // -----------------------------------------------------------------------------
impl_initialize()208 void ORelationController::impl_initialize()
209 {
210     OJoinController::impl_initialize();
211 
212     if( !getSdbMetaData().supportsRelations() )
213     {// check if this database supports relations
214 
215         setEditable(sal_False);
216         m_bRelationsPossible    = sal_False;
217         {
218             String sTitle(ModuleRes(STR_RELATIONDESIGN));
219             sTitle.Erase(0,3);
220             OSQLMessageBox aDlg(NULL,sTitle,ModuleRes(STR_RELATIONDESIGN_NOT_AVAILABLE));
221             aDlg.Execute();
222         }
223         disconnect();
224         throw SQLException();
225     }
226 
227     if(!m_bRelationsPossible)
228         InvalidateAll();
229 
230     // we need a datasource
231     OSL_ENSURE(haveDataSource(),"ORelationController::initialize: need a datasource!");
232 
233     Reference<XTablesSupplier> xSup(getConnection(),UNO_QUERY);
234     OSL_ENSURE(xSup.is(),"Connection isn't a XTablesSupplier!");
235     if(xSup.is())
236         m_xTables = xSup->getTables();
237     // load the layoutInformation
238     loadLayoutInformation();
239     try
240     {
241         loadData();
242         if ( !m_nThreadEvent )
243             Application::PostUserEvent(LINK(this, ORelationController, OnThreadFinished));
244     }
245     catch( const Exception& )
246     {
247         DBG_UNHANDLED_EXCEPTION();
248     }
249 
250 }
251 // -----------------------------------------------------------------------------
getPrivateTitle() const252 ::rtl::OUString ORelationController::getPrivateTitle( ) const
253 {
254     ::rtl::OUString sName = getDataSourceName();
255     return ::dbaui::getStrippedDatabaseName(getDataSource(),sName);
256 }
257 // -----------------------------------------------------------------------------
Construct(Window * pParent)258 sal_Bool ORelationController::Construct(Window* pParent)
259 {
260     setView( * new ORelationDesignView( pParent, *this, getORB() ) );
261     OJoinController::Construct(pParent);
262     return sal_True;
263 }
264 // -----------------------------------------------------------------------------
saveModified()265 short ORelationController::saveModified()
266 {
267     short nSaved = RET_YES;
268     if(haveDataSource() && isModified())
269     {
270         QueryBox aQry(getView(), ModuleRes(RELATION_DESIGN_SAVEMODIFIED));
271         nSaved = aQry.Execute();
272         if(nSaved == RET_YES)
273             Execute(ID_BROWSER_SAVEDOC,Sequence<PropertyValue>());
274     }
275     return nSaved;
276 }
277 // -----------------------------------------------------------------------------
describeSupportedFeatures()278 void ORelationController::describeSupportedFeatures()
279 {
280     OJoinController::describeSupportedFeatures();
281     implDescribeSupportedFeature( ".uno:DBAddRelation", SID_RELATION_ADD_RELATION, CommandGroup::EDIT );
282 }
283 namespace
284 {
285     class RelationLoader : public ::osl::Thread
286     {
287         DECLARE_STL_MAP(::rtl::OUString,::boost::shared_ptr<OTableWindowData>,::comphelper::UStringMixLess,TTableDataHelper);
288         TTableDataHelper                    m_aTableData;
289         TTableConnectionData                m_vTableConnectionData;
290         const Sequence< ::rtl::OUString>    m_aTableList;
291         ORelationController*                m_pParent;
292         const Reference< XDatabaseMetaData> m_xMetaData;
293         const Reference< XNameAccess >      m_xTables;
294         const sal_Int32                     m_nStartIndex;
295         const sal_Int32                     m_nEndIndex;
296 
297     public:
RelationLoader(ORelationController * _pParent,const Reference<XDatabaseMetaData> & _xMetaData,const Reference<XNameAccess> & _xTables,const Sequence<::rtl::OUString> & _aTableList,const sal_Int32 _nStartIndex,const sal_Int32 _nEndIndex)298         RelationLoader(ORelationController* _pParent
299                         ,const Reference< XDatabaseMetaData>& _xMetaData
300                         ,const Reference< XNameAccess >& _xTables
301                         ,const Sequence< ::rtl::OUString>& _aTableList
302                         ,const sal_Int32 _nStartIndex
303                         ,const sal_Int32 _nEndIndex)
304             :m_aTableData(_xMetaData.is() && _xMetaData->supportsMixedCaseQuotedIdentifiers())
305             ,m_aTableList(_aTableList)
306             ,m_pParent(_pParent)
307             ,m_xMetaData(_xMetaData)
308             ,m_xTables(_xTables)
309             ,m_nStartIndex(_nStartIndex)
310             ,m_nEndIndex(_nEndIndex)
311         {
312         }
313 
314         /// Working method which should be overridden.
315         virtual void SAL_CALL run();
316         virtual void SAL_CALL onTerminated();
317     protected:
~RelationLoader()318         virtual ~RelationLoader(){}
319 
320         void loadTableData(const Any& _aTable);
321     };
322 
run()323     void SAL_CALL RelationLoader::run()
324     {
325         const ::rtl::OUString* pIter = m_aTableList.getConstArray() + m_nStartIndex;
326         for(sal_Int32 i = m_nStartIndex; i < m_nEndIndex;++i,++pIter)
327         {
328             ::rtl::OUString sCatalog,sSchema,sTable;
329             ::dbtools::qualifiedNameComponents(m_xMetaData,
330                                                 *pIter,
331                                                 sCatalog,
332                                                 sSchema,
333                                                 sTable,
334                                                 ::dbtools::eInDataManipulation);
335             Any aCatalog;
336             if ( sCatalog.getLength() )
337                 aCatalog <<= sCatalog;
338 
339             try
340             {
341                 Reference< XResultSet > xResult = m_xMetaData->getImportedKeys(aCatalog, sSchema,sTable);
342                 if ( xResult.is() && xResult->next() )
343                 {
344                     ::comphelper::disposeComponent(xResult);
345                     loadTableData(m_xTables->getByName(*pIter));
346                 } // if ( xResult.is() && xResult->next() )
347             }
348             catch( const Exception& )
349             {
350                 DBG_UNHANDLED_EXCEPTION();
351             }
352         }
353     }
onTerminated()354     void SAL_CALL RelationLoader::onTerminated()
355     {
356         m_pParent->mergeData(m_vTableConnectionData);
357         delete this;
358     }
359 
loadTableData(const Any & _aTable)360     void RelationLoader::loadTableData(const Any& _aTable)
361     {
362         Reference<XPropertySet> xTableProp(_aTable,UNO_QUERY);
363         const ::rtl::OUString sSourceName = ::dbtools::composeTableName( m_xMetaData, xTableProp, ::dbtools::eInTableDefinitions, false, false, false );
364         TTableDataHelper::iterator aFind = m_aTableData.find(sSourceName);
365         bool bNotFound = true, bAdded = false;
366         if ( aFind == m_aTableData.end() )
367         {
368             aFind = m_aTableData.insert(TTableDataHelper::value_type(sSourceName,::boost::shared_ptr<OTableWindowData>(new OTableWindowData(xTableProp,sSourceName, sSourceName)))).first;
369             aFind->second->ShowAll(sal_False);
370             bAdded = true;
371         }
372         TTableWindowData::value_type pReferencingTable = aFind->second;
373         Reference<XIndexAccess> xKeys = pReferencingTable->getKeys();
374         const Reference<XKeysSupplier> xKeySup(xTableProp,UNO_QUERY);
375 
376         if ( !xKeys.is() && xKeySup.is() )
377         {
378             xKeys = xKeySup->getKeys();
379         }
380 
381         if ( xKeys.is() )
382         {
383             Reference<XPropertySet> xKey;
384             const sal_Int32 nCount = xKeys->getCount();
385             for(sal_Int32 i = 0 ; i < nCount ; ++i)
386             {
387                 xKeys->getByIndex(i) >>= xKey;
388                 sal_Int32 nKeyType = 0;
389                 xKey->getPropertyValue(PROPERTY_TYPE) >>= nKeyType;
390                 if ( KeyType::FOREIGN == nKeyType )
391                 {
392                     bNotFound = false;
393                     ::rtl::OUString sReferencedTable;
394                     xKey->getPropertyValue(PROPERTY_REFERENCEDTABLE) >>= sReferencedTable;
395                     //////////////////////////////////////////////////////////////////////
396                     // insert windows
397                     TTableDataHelper::iterator aRefFind = m_aTableData.find(sReferencedTable);
398                     if ( aRefFind == m_aTableData.end() )
399                     {
400                         if ( m_xTables->hasByName(sReferencedTable) )
401                         {
402                             Reference<XPropertySet>  xReferencedTable(m_xTables->getByName(sReferencedTable),UNO_QUERY);
403                             aRefFind = m_aTableData.insert(TTableDataHelper::value_type(sReferencedTable,::boost::shared_ptr<OTableWindowData>(new OTableWindowData(xReferencedTable,sReferencedTable, sReferencedTable)))).first;
404                             aRefFind->second->ShowAll(sal_False);
405                         }
406                         else
407                             continue; // table name could not be found so we do not show this table releation
408                     } // if ( aFind == m_aTableData.end() )
409                     TTableWindowData::value_type pReferencedTable = aRefFind->second;
410 
411                     ::rtl::OUString sKeyName;
412                     xKey->getPropertyValue(PROPERTY_NAME) >>= sKeyName;
413                     //////////////////////////////////////////////////////////////////////
414                     // insert connection
415                     ORelationTableConnectionData* pTabConnData = new ORelationTableConnectionData( pReferencingTable, pReferencedTable, sKeyName );
416                     m_vTableConnectionData.push_back(TTableConnectionData::value_type(pTabConnData));
417                     //////////////////////////////////////////////////////////////////////
418                     // insert columns
419                     const Reference<XColumnsSupplier> xColsSup(xKey,UNO_QUERY);
420                     OSL_ENSURE(xColsSup.is(),"Key is no XColumnsSupplier!");
421                     const Reference<XNameAccess> xColumns       = xColsSup->getColumns();
422                     const Sequence< ::rtl::OUString> aNames = xColumns->getElementNames();
423                     const ::rtl::OUString* pIter    = aNames.getConstArray();
424                     const ::rtl::OUString* pEnd     = pIter + aNames.getLength();
425                     ::rtl::OUString sColumnName,sRelatedName;
426                     for(sal_uInt16 j=0;pIter != pEnd;++pIter,++j)
427                     {
428                         const Reference<XPropertySet> xPropSet(xColumns->getByName(*pIter),UNO_QUERY);
429                         OSL_ENSURE(xPropSet.is(),"Invalid column found in KeyColumns!");
430                         if ( xPropSet.is() )
431                         {
432                             xPropSet->getPropertyValue(PROPERTY_NAME)           >>= sColumnName;
433                             xPropSet->getPropertyValue(PROPERTY_RELATEDCOLUMN)  >>= sRelatedName;
434                         }
435                         pTabConnData->SetConnLine( j, sColumnName, sRelatedName );
436                     }
437                     //////////////////////////////////////////////////////////////////////
438                     // Update/Del-Flags setzen
439                     sal_Int32   nUpdateRule = 0;
440                     sal_Int32   nDeleteRule = 0;
441                     xKey->getPropertyValue(PROPERTY_UPDATERULE) >>= nUpdateRule;
442                     xKey->getPropertyValue(PROPERTY_DELETERULE) >>= nDeleteRule;
443 
444                     pTabConnData->SetUpdateRules( nUpdateRule );
445                     pTabConnData->SetDeleteRules( nDeleteRule );
446 
447                     //////////////////////////////////////////////////////////////////////
448                     // Kardinalitaet setzen
449                     pTabConnData->SetCardinality();
450                 }
451             }
452         } // if ( xKeys.is() )
453     }
454 }
455 
mergeData(const TTableConnectionData & _aConnectionData)456 void ORelationController::mergeData(const TTableConnectionData& _aConnectionData)
457 {
458     ::osl::MutexGuard aGuard( getMutex() );
459 
460     ::std::copy( _aConnectionData.begin(), _aConnectionData.end(), ::std::back_inserter( m_vTableConnectionData ));
461     //const Reference< XDatabaseMetaData> xMetaData = getConnection()->getMetaData();
462     const sal_Bool bCase = sal_True;//xMetaData.is() && xMetaData->supportsMixedCaseQuotedIdentifiers();
463     // here we are finished, so we can collect the table from connection data
464     TTableConnectionData::iterator aConnDataIter = m_vTableConnectionData.begin();
465     TTableConnectionData::iterator aConnDataEnd = m_vTableConnectionData.end();
466     for(;aConnDataIter != aConnDataEnd;++aConnDataIter)
467     {
468         if ( !existsTable((*aConnDataIter)->getReferencingTable()->GetComposedName(),bCase) )
469         {
470             m_vTableData.push_back((*aConnDataIter)->getReferencingTable());
471         }
472         if ( !existsTable((*aConnDataIter)->getReferencedTable()->GetComposedName(),bCase) )
473         {
474             m_vTableData.push_back((*aConnDataIter)->getReferencedTable());
475         }
476     } // for(;aConnDataIter != aConnDataEnd;++aConnDataIter)
477     if ( m_nThreadEvent )
478     {
479         --m_nThreadEvent;
480         if ( !m_nThreadEvent )
481             Application::PostUserEvent(LINK(this, ORelationController, OnThreadFinished));
482     }
483 }
484 // -----------------------------------------------------------------------------
485 IMPL_LINK( ORelationController, OnThreadFinished, void*, /*NOTINTERESTEDIN*/ )
486 {
487     vos::OGuard aSolarGuard( Application::GetSolarMutex() );
488     ::osl::MutexGuard aGuard( getMutex() );
489     try
490     {
491         getView()->initialize();    // show the windows and fill with our informations
492         getView()->Invalidate(INVALIDATE_NOERASE);
493         ClearUndoManager();
494         setModified(sal_False);     // and we are not modified yet
495 
496         if(m_vTableData.empty())
497             Execute(ID_BROWSER_ADDTABLE,Sequence<PropertyValue>());
498     }
499     catch( const Exception& )
500     {
501         DBG_UNHANDLED_EXCEPTION();
502     }
503     m_pWaitObject.reset();
504     return 0L;
505 }
506 // -----------------------------------------------------------------------------
loadData()507 void ORelationController::loadData()
508 {
509     m_pWaitObject.reset( new WaitObject(getView()) );
510     try
511     {
512         if ( !m_xTables.is() )
513             return;
514         DatabaseMetaData aMeta(getConnection());
515         // this may take some time
516         const Reference< XDatabaseMetaData> xMetaData = getConnection()->getMetaData();
517         const Sequence< ::rtl::OUString> aNames = m_xTables->getElementNames();
518         const sal_Int32 nCount = aNames.getLength();
519         if ( aMeta.supportsThreads() )
520         {
521             const sal_Int32 nMaxElements = (nCount / MAX_THREADS) +1;
522             sal_Int32 nStart = 0,nEnd = ::std::min(nMaxElements,nCount);
523             while(nStart != nEnd)
524             {
525                 ++m_nThreadEvent;
526                 RelationLoader* pThread = new RelationLoader(this,xMetaData,m_xTables,aNames,nStart,nEnd);
527                 pThread->createSuspended();
528                 pThread->setPriority(osl_Thread_PriorityBelowNormal);
529                 pThread->resume();
530                 nStart = nEnd;
531                 nEnd += nMaxElements;
532                 nEnd = ::std::min(nEnd,nCount);
533             } // for(;pIter != pEnd;++pIter)
534         } // if ( aMeta.supportsThreads() )
535         else
536         {
537             RelationLoader* pThread = new RelationLoader(this,xMetaData,m_xTables,aNames,0,nCount);
538             pThread->run();
539             pThread->onTerminated();
540         }
541     }
542     catch(SQLException& e)
543     {
544         showError(SQLExceptionInfo(e));
545     }
546     catch(const Exception&)
547     {
548         DBG_UNHANDLED_EXCEPTION();
549     }
550 }
551 // -----------------------------------------------------------------------------
existsTable(const::rtl::OUString & _rComposedTableName,sal_Bool _bCase) const552 TTableWindowData::value_type ORelationController::existsTable(const ::rtl::OUString& _rComposedTableName,sal_Bool _bCase)  const
553 {
554     ::comphelper::UStringMixEqual bCase(_bCase);
555     TTableWindowData::const_iterator aIter = m_vTableData.begin();
556     TTableWindowData::const_iterator aEnd = m_vTableData.end();
557     for(;aIter != aEnd;++aIter)
558     {
559         if(bCase((*aIter)->GetComposedName(),_rComposedTableName))
560             break;
561     }
562     return ( aIter != aEnd) ? *aIter : TTableWindowData::value_type();
563 }
564 // -----------------------------------------------------------------------------
loadLayoutInformation()565 void ORelationController::loadLayoutInformation()
566 {
567     try
568     {
569         OSL_ENSURE(haveDataSource(),"We need a datasource from our connection!");
570         if ( haveDataSource() )
571         {
572             if ( getDataSource()->getPropertySetInfo()->hasPropertyByName(PROPERTY_LAYOUTINFORMATION) )
573             {
574                 Sequence<PropertyValue> aWindows;
575                 getDataSource()->getPropertyValue(PROPERTY_LAYOUTINFORMATION) >>= aWindows;
576                 loadTableWindows(aWindows);
577             }
578         }
579     }
580     catch(Exception&)
581     {
582     }
583 }
584 // -----------------------------------------------------------------------------
reset()585 void ORelationController::reset()
586 {
587     loadLayoutInformation();
588     ODataView* pView = getView();
589     OSL_ENSURE(pView,"No current view!");
590     if(pView)
591     {
592         pView->initialize();
593         pView->Invalidate(INVALIDATE_NOERASE);
594     }
595 }
596 
597 // -----------------------------------------------------------------------------
allowViews() const598 bool ORelationController::allowViews() const
599 {
600     return false;
601 }
602 
603 // -----------------------------------------------------------------------------
allowQueries() const604 bool ORelationController::allowQueries() const
605 {
606     return false;
607 }
608 
609 // -----------------------------------------------------------------------------
610 
611 
612