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
27 #ifndef DBAUI_APPCONTROLLER_HXX
28 #include "AppController.hxx"
29 #endif
30 #ifndef _COMPHELPER_SEQUENCE_HXX_
31 #include <comphelper/sequence.hxx>
32 #endif
33 #ifndef _COMPHELPER_PROPERTY_HXX_
34 #include <comphelper/property.hxx>
35 #endif
36 #ifndef DBACCESS_SHARED_DBUSTRINGS_HRC
37 #include "dbustrings.hrc"
38 #endif
39 #ifndef _COM_SUN_STAR_SDBCX_XDATADESCRIPTORFACTORY_HPP_
40 #include <com/sun/star/sdbcx/XDataDescriptorFactory.hpp>
41 #endif
42 #ifndef _COM_SUN_STAR_SDBCX_XAPPEND_HPP_
43 #include <com/sun/star/sdbcx/XAppend.hpp>
44 #endif
45 #ifndef _COM_SUN_STAR_SDBCX_XCOLUMNSSUPPLIER_HPP_
46 #include <com/sun/star/sdbcx/XColumnsSupplier.hpp>
47 #endif
48 #ifndef _COM_SUN_STAR_SDB_XSINGLESELECTQUERYCOMPOSER_HPP_
49 #include <com/sun/star/sdb/XSingleSelectQueryComposer.hpp>
50 #endif
51 #ifndef _COM_SUN_STAR_CONTAINER_XNAMECONTAINER_HPP_
52 #include <com/sun/star/container/XNameContainer.hpp>
53 #endif
54 #ifndef _COM_SUN_STAR_UNO_XNAMINGSERVICE_HPP_
55 #include <com/sun/star/uno/XNamingService.hpp>
56 #endif
57 #ifndef _COM_SUN_STAR_SDBC_XDATASOURCE_HPP_
58 #include <com/sun/star/sdbc/XDataSource.hpp>
59 #endif
60 #ifndef _COM_SUN_STAR_FRAME_XSTORABLE_HPP_
61 #include <com/sun/star/frame/XStorable.hpp>
62 #endif
63 #ifndef _COM_SUN_STAR_CONTAINER_XCHILD_HPP_
64 #include <com/sun/star/container/XChild.hpp>
65 #endif
66 #ifndef _COM_SUN_STAR_CONTAINER_XHIERARCHICALNAMECONTAINER_HPP_
67 #include <com/sun/star/container/XHierarchicalNameContainer.hpp>
68 #endif
69 #ifndef _COM_SUN_STAR_SDBC_DATATYPE_HPP_
70 #include <com/sun/star/sdbc/DataType.hpp>
71 #endif
72 #ifndef _COM_SUN_STAR_SDB_COMMANDTYPE_HPP_
73 #include <com/sun/star/sdb/CommandType.hpp>
74 #endif
75 #ifndef _COM_SUN_STAR_SDB_XBOOKMARKSSUPPLIER_HPP_
76 #include <com/sun/star/sdb/XBookmarksSupplier.hpp>
77 #endif
78 #ifndef _COM_SUN_STAR_SDB_SQLCONTEXT_HPP_
79 #include <com/sun/star/sdb/SQLContext.hpp>
80 #endif
81 #ifndef _COM_SUN_STAR_SDBCX_XTABLESSUPPLIER_HPP_
82 #include <com/sun/star/sdbcx/XTablesSupplier.hpp>
83 #endif
84 #ifndef _COM_SUN_STAR_SDBCX_XVIEWSSUPPLIER_HPP_
85 #include <com/sun/star/sdbcx/XViewsSupplier.hpp>
86 #endif
87 #ifndef _COM_SUN_STAR_SDB_XQUERYDEFINITIONSSUPPLIER_HPP_
88 #include <com/sun/star/sdb/XQueryDefinitionsSupplier.hpp>
89 #endif
90 #ifndef _COM_SUN_STAR_SDBCX_XDROP_HPP_
91 #include <com/sun/star/sdbcx/XDrop.hpp>
92 #endif
93 #ifndef _TOOLS_DEBUG_HXX
94 #include <tools/debug.hxx>
95 #endif
96 #ifndef _URLOBJ_HXX
97 #include <tools/urlobj.hxx>
98 #endif
99 #ifndef _UNOTOOLS_UCBHELPER_HXX
100 #include <unotools/ucbhelper.hxx>
101 #endif
102 #ifndef DBAUI_DLGSAVE_HXX
103 #include "dlgsave.hxx"
104 #endif
105 #ifndef _COMPHELPER_TYPES_HXX_
106 #include <comphelper/types.hxx>
107 #endif
108 #ifndef _SV_MSGBOX_HXX
109 #include <vcl/msgbox.hxx>
110 #endif
111 #ifndef _CPPUHELPER_TYPEPROVIDER_HXX_
112 #include <cppuhelper/typeprovider.hxx>
113 #endif
114 #ifndef _CPPUHELPER_EXC_HLP_HXX_
115 #include <cppuhelper/exc_hlp.hxx>
116 #endif
117 #ifndef _DBHELPER_DBEXCEPTION_HXX_
118 #include <connectivity/dbexception.hxx>
119 #endif
120 #ifndef _SV_WAITOBJ_HXX
121 #include <vcl/waitobj.hxx>
122 #endif
123 #ifndef _RTL_USTRBUF_HXX_
124 #include <rtl/ustrbuf.hxx>
125 #endif
126 #ifndef DBAUI_APPVIEW_HXX
127 #include "AppView.hxx"
128 #endif
129 #ifndef _SVX_DATACCESSDESCRIPTOR_HXX_
130 #include <svx/dataaccessdescriptor.hxx>
131 #endif
132 #ifndef SVX_DBAOBJECTEX_HXX
133 #include <svx/dbaobjectex.hxx>
134 #endif
135 #ifndef DBACCESS_UI_BROWSER_ID_HXX
136 #include "browserids.hxx"
137 #endif
138 #ifndef _DBAU_REGHELPER_HXX_
139 #include "dbu_reghelper.hxx"
140 #endif
141 #ifndef _DBU_APP_HRC_
142 #include "dbu_app.hrc"
143 #endif
144 #ifndef _SV_MENU_HXX
145 #include <vcl/menu.hxx>
146 #endif
147 #ifndef _COMPHELPER_UNO3_HXX_
148 #include <comphelper/uno3.hxx>
149 #endif
150 #ifndef _SV_SVAPP_HXX //autogen
151 #include <vcl/svapp.hxx>
152 #endif
153 #ifndef _SVLBOXITM_HXX
154 #include <svtools/svlbitm.hxx>
155 #endif
156 #ifndef _DBAUI_LISTVIEWITEMS_HXX_
157 #include "listviewitems.hxx"
158 #endif
159 #ifndef DBAUI_APPDETAILVIEW_HXX
160 #include "AppDetailView.hxx"
161 #endif
162 #ifndef _DBAUI_LINKEDDOCUMENTS_HXX_
163 #include "linkeddocuments.hxx"
164 #endif
165 #ifndef _SV_LSTBOX_HXX
166 #include <vcl/lstbox.hxx>
167 #endif
168 #ifndef _DBHELPER_DBEXCEPTION_HXX_
169 #include <connectivity/dbexception.hxx>
170 #endif
171 #ifndef _CONNECTIVITY_DBTOOLS_HXX_
172 #include <connectivity/dbtools.hxx>
173 #endif
174 #ifndef _DBAUI_SQLMESSAGE_HXX_
175 #include "sqlmessage.hxx"
176 #endif
177 #ifndef _STRING_HXX
178 #include <tools/string.hxx>
179 #endif
180 #ifndef DBAUI_DBEXCHANGE_HXX
181 #include "dbexchange.hxx"
182 #endif
183 #ifndef DBAUI_TOOLS_HXX
184 #include "UITools.hxx"
185 #endif
186 #include <algorithm>
187 #ifndef _SVTREEBOX_HXX
188 #include <svtools/svtreebx.hxx>
189 #endif
190 #ifndef _COM_SUN_STAR_SDB_XREPORTDOCUMENTSSUPPLIER_HPP_
191 #include <com/sun/star/sdb/XReportDocumentsSupplier.hpp>
192 #endif
193 #ifndef _COM_SUN_STAR_SDB_XFORMDOCUMENTSSUPPLIER_HPP_
194 #include <com/sun/star/sdb/XFormDocumentsSupplier.hpp>
195 #endif
196 #ifndef _FILEDLGHELPER_HXX
197 #include <sfx2/filedlghelper.hxx>
198 #endif
199 #ifndef INCLUDED_SVTOOLS_PATHOPTIONS_HXX
200 #include <unotools/pathoptions.hxx>
201 #endif
202 #ifndef _SFX_DOCFILT_HACK_HXX
203 #include <sfx2/docfilt.hxx>
204 #endif
205 #ifndef _SVT_FILEVIEW_HXX
206 #include <svtools/fileview.hxx>
207 #endif
208 #ifndef TOOLS_DIAGNOSE_EX_H
209 #include <tools/diagnose_ex.h>
210 #endif
211 #ifndef DBACCESS_SOURCE_UI_MISC_DEFAULTOBJECTNAMECHECK_HXX
212 #include "defaultobjectnamecheck.hxx"
213 #endif
214 #ifndef _VOS_MUTEX_HXX_
215 #include <vos/mutex.hxx>
216 #endif
217 #include "subcomponentmanager.hxx"
218
219 //........................................................................
220 namespace dbaui
221 {
222 //........................................................................
223 using namespace ::dbtools;
224 using namespace ::svx;
225 using namespace ::svtools;
226 using namespace ::com::sun::star::uno;
227 using namespace ::com::sun::star::task;
228 using namespace ::com::sun::star::beans;
229 using namespace ::com::sun::star::lang;
230 using namespace ::com::sun::star::container;
231 using namespace ::com::sun::star::sdb;
232 using namespace ::com::sun::star::sdbc;
233 using namespace ::com::sun::star::sdbcx;
234 using namespace ::com::sun::star::frame;
235 using namespace ::com::sun::star::ucb;
236 using namespace ::com::sun::star::util;
237
238 // -----------------------------------------------------------------------------
deleteTables(const::std::vector<::rtl::OUString> & _rList)239 void OApplicationController::deleteTables(const ::std::vector< ::rtl::OUString>& _rList)
240 {
241 SharedConnection xConnection( ensureConnection() );
242
243 Reference<XTablesSupplier> xSup(xConnection,UNO_QUERY);
244 OSL_ENSURE(xSup.is(),"OApplicationController::deleteTable: no XTablesSuppier!");
245 if ( xSup.is() )
246 {
247 Reference<XNameAccess> xTables = xSup->getTables();
248 Reference<XDrop> xDrop(xTables,UNO_QUERY);
249 if ( xDrop.is() )
250 {
251 bool bConfirm = true;
252 ::std::vector< ::rtl::OUString>::const_iterator aEnd = _rList.end();
253 for (::std::vector< ::rtl::OUString>::const_iterator aIter = _rList.begin(); aIter != aEnd; ++aIter)
254 {
255 ::rtl::OUString sTableName = *aIter;
256
257 sal_Int32 nResult = RET_YES;
258 if ( bConfirm )
259 nResult = ::dbaui::askForUserAction(getView(),STR_TITLE_CONFIRM_DELETION ,STR_QUERY_DELETE_TABLE,_rList.size() > 1 && (aIter+1) != _rList.end(),sTableName);
260
261 bool bUserConfirmedDelete =
262 ( RET_YES == nResult )
263 || ( RET_ALL == nResult );
264 if ( bUserConfirmedDelete && m_pSubComponentManager->closeSubFrames( sTableName, E_TABLE ) )
265 {
266 SQLExceptionInfo aErrorInfo;
267 try
268 {
269 if ( xTables->hasByName(sTableName) )
270 xDrop->dropByName(sTableName);
271 else
272 {// could be a view
273 Reference<XViewsSupplier> xViewsSup(xConnection,UNO_QUERY);
274
275 Reference<XNameAccess> xViews;
276 if ( xViewsSup.is() )
277 {
278 xViews = xViewsSup->getViews();
279 if ( xViews.is() && xViews->hasByName(sTableName) )
280 {
281 xDrop.set(xViews,UNO_QUERY);
282 if ( xDrop.is() )
283 xDrop->dropByName(sTableName);
284 }
285 }
286 }
287 }
288 catch(SQLContext& e) { aErrorInfo = e; }
289 catch(SQLWarning& e) { aErrorInfo = e; }
290 catch(SQLException& e) { aErrorInfo = e; }
291 catch(WrappedTargetException& e)
292 {
293 SQLException aSql;
294 if(e.TargetException >>= aSql)
295 aErrorInfo = aSql;
296 else
297 OSL_ENSURE(sal_False, "OApplicationController::implDropTable: something strange happended!");
298 }
299 catch( const Exception& )
300 {
301 DBG_UNHANDLED_EXCEPTION();
302 }
303
304 if ( aErrorInfo.isValid() )
305 showError(aErrorInfo);
306
307 if ( RET_ALL == nResult )
308 bConfirm = false;
309 }
310 else
311 break;
312 }
313 }
314 else
315 {
316 String sMessage(ModuleRes(STR_MISSING_TABLES_XDROP));
317 ErrorBox aError(getView(), WB_OK, sMessage);
318 aError.Execute();
319 }
320 }
321 }
322 // -----------------------------------------------------------------------------
deleteObjects(ElementType _eType,const::std::vector<::rtl::OUString> & _rList,bool _bConfirm)323 void OApplicationController::deleteObjects( ElementType _eType, const ::std::vector< ::rtl::OUString>& _rList, bool _bConfirm )
324 {
325 Reference< XNameContainer > xNames( getElements( _eType ), UNO_QUERY );
326 Reference< XHierarchicalNameContainer > xHierarchyName( xNames, UNO_QUERY );
327 if ( xNames.is() )
328 {
329 ByteString sDialogPosition;
330 svtools::QueryDeleteResult_Impl eResult = _bConfirm ? svtools::QUERYDELETE_YES : svtools::QUERYDELETE_ALL;
331
332 // The list of elements to delete is allowed to contain related elements: A given element may
333 // be the ancestor or child of another element from the list.
334 // We want to ensure that ancestors get deleted first, so we normalize the list in this respect.
335 // #i33353# - 2004-09-27 - fs@openoffice.org
336 ::std::set< ::rtl::OUString > aDeleteNames;
337 // Note that this implicitly uses ::std::less< ::rtl::OUString > a comparison operation, which
338 // results in lexicographical order, which is exactly what we need, because "foo" is *before*
339 // any "foo/bar" in this order.
340 ::std::copy(
341 _rList.begin(), _rList.end(),
342 ::std::insert_iterator< ::std::set< ::rtl::OUString > >( aDeleteNames, aDeleteNames.begin() )
343 );
344
345 ::std::set< ::rtl::OUString >::size_type nCount = aDeleteNames.size();
346 for ( ::std::set< ::rtl::OUString >::size_type nObjectsLeft = nCount; !aDeleteNames.empty(); )
347 {
348 ::std::set< ::rtl::OUString >::iterator aThisRound = aDeleteNames.begin();
349
350 if ( eResult != svtools::QUERYDELETE_ALL )
351 {
352 svtools::QueryDeleteDlg_Impl aDlg( getView(), *aThisRound );
353
354 if ( sDialogPosition.Len() )
355 aDlg.SetWindowState( sDialogPosition );
356
357 if ( nObjectsLeft > 1 )
358 aDlg.EnableAllButton();
359
360 if ( aDlg.Execute() == RET_OK )
361 eResult = aDlg.GetResult();
362 else
363 return;
364
365 sDialogPosition = aDlg.GetWindowState( );
366 }
367
368 bool bSuccess = false;
369
370 bool bUserConfirmedDelete =
371 ( eResult == svtools::QUERYDELETE_ALL )
372 || ( eResult == svtools::QUERYDELETE_YES );
373
374 if ( bUserConfirmedDelete
375 && ( ( _eType == E_QUERY ) ? m_pSubComponentManager->closeSubFrames( *aThisRound, _eType ) : true )
376 )
377 {
378 try
379 {
380 if ( xHierarchyName.is() )
381 xHierarchyName->removeByHierarchicalName( *aThisRound );
382 else
383 xNames->removeByName( *aThisRound );
384
385 bSuccess = true;
386
387 // now that we removed the element, care for all it's child elements
388 // which may also be a part of the list
389 // #i33353# - 2004-09-27 - fs@openoffice.org
390 OSL_ENSURE( aThisRound->getLength() - 1 >= 0, "OApplicationController::deleteObjects: empty name?" );
391 ::rtl::OUStringBuffer sSmallestSiblingName( *aThisRound );
392 sSmallestSiblingName.append( (sal_Unicode)( '/' + 1) );
393
394 ::std::set< ::rtl::OUString >::iterator aUpperChildrenBound = aDeleteNames.lower_bound( sSmallestSiblingName.makeStringAndClear() );
395 for ( ::std::set< ::rtl::OUString >::iterator aObsolete = aThisRound;
396 aObsolete != aUpperChildrenBound;
397 )
398 {
399 #if OSL_DEBUG_LEVEL > 0
400 ::rtl::OUString sObsoleteName = *aObsolete;
401 #endif
402 ::std::set< ::rtl::OUString >::iterator aNextObsolete = aObsolete; ++aNextObsolete;
403 aDeleteNames.erase( aObsolete );
404 --nObjectsLeft;
405 aObsolete = aNextObsolete;
406 }
407 }
408 catch(const SQLException&)
409 {
410 showError( SQLExceptionInfo( ::cppu::getCaughtException() ) );
411 }
412 catch(WrappedTargetException& e)
413 {
414 SQLException aSql;
415 if ( e.TargetException >>= aSql )
416 showError( SQLExceptionInfo( e.TargetException ) );
417 else
418 OSL_ENSURE( sal_False, "OApplicationController::deleteObjects: something strange happended!" );
419 }
420 catch( const Exception& )
421 {
422 DBG_UNHANDLED_EXCEPTION();
423 }
424 }
425
426 if ( !bSuccess )
427 {
428 // okay, this object could not be deleted (or the user did not want to delete it),
429 // but continue with the rest
430 aDeleteNames.erase( aThisRound );
431 --nObjectsLeft;
432 }
433 }
434 }
435 }
436 // -----------------------------------------------------------------------------
deleteEntries()437 void OApplicationController::deleteEntries()
438 {
439 ::vos::OGuard aSolarGuard(Application::GetSolarMutex());
440 ::osl::MutexGuard aGuard( getMutex() );
441
442 if ( getContainer() )
443 {
444 ::std::vector< ::rtl::OUString> aList;
445 getSelectionElementNames(aList);
446 ElementType eType = getContainer()->getElementType();
447 switch(eType)
448 {
449 case E_TABLE:
450 deleteTables(aList);
451 break;
452 case E_QUERY:
453 deleteObjects( E_QUERY, aList, true );
454 break;
455 case E_FORM:
456 deleteObjects( E_FORM, aList, true );
457 break;
458 case E_REPORT:
459 deleteObjects( E_REPORT, aList, true );
460 break;
461 case E_NONE:
462 break;
463 }
464 }
465 }
466 // -----------------------------------------------------------------------------
ensureConnection(::dbtools::SQLExceptionInfo * _pErrorInfo)467 const SharedConnection& OApplicationController::ensureConnection( ::dbtools::SQLExceptionInfo* _pErrorInfo )
468 {
469 ::vos::OGuard aSolarGuard(Application::GetSolarMutex());
470 ::osl::MutexGuard aGuard( getMutex() );
471
472 if ( !m_xDataSourceConnection.is() )
473 {
474 WaitObject aWO(getView());
475 String sConnectingContext( ModuleRes( STR_COULDNOTCONNECT_DATASOURCE ) );
476 sConnectingContext.SearchAndReplaceAscii("$name$", getStrippedDatabaseName());
477
478 m_xDataSourceConnection.reset( connect( getDatabaseName(), sConnectingContext, _pErrorInfo ) );
479 if ( m_xDataSourceConnection.is() )
480 {
481 SQLExceptionInfo aError;
482 try
483 {
484 m_xMetaData = m_xDataSourceConnection->getMetaData();
485 }
486 catch( const SQLException& )
487 {
488 aError = ::cppu::getCaughtException();
489 }
490 catch( const Exception& )
491 {
492 DBG_UNHANDLED_EXCEPTION();
493 }
494 if ( aError.isValid() )
495 {
496 if ( _pErrorInfo )
497 {
498 *_pErrorInfo = aError;
499 }
500 else
501 {
502 showError( aError );
503 }
504 }
505 }
506 }
507 return m_xDataSourceConnection;
508 }
509 // -----------------------------------------------------------------------------
isDataSourceReadOnly() const510 sal_Bool OApplicationController::isDataSourceReadOnly() const
511 {
512 Reference<XStorable> xStore(m_xModel,UNO_QUERY);
513 return !xStore.is() || xStore->isReadonly();
514 }
515 // -----------------------------------------------------------------------------
isConnectionReadOnly() const516 sal_Bool OApplicationController::isConnectionReadOnly() const
517 {
518 sal_Bool bIsConnectionReadOnly = sal_True;
519 if ( m_xMetaData.is() )
520 {
521 try
522 {
523 bIsConnectionReadOnly = m_xMetaData->isReadOnly();
524 }
525 catch(const SQLException&)
526 {
527 DBG_UNHANDLED_EXCEPTION();
528 }
529 }
530 // TODO check configuration
531 return bIsConnectionReadOnly;
532 }
533 // -----------------------------------------------------------------------------
getElements(ElementType _eType)534 Reference< XNameAccess > OApplicationController::getElements( ElementType _eType )
535 {
536 Reference< XNameAccess > xElements;
537 try
538 {
539 switch ( _eType )
540 {
541 case E_REPORT:
542 {
543 Reference< XReportDocumentsSupplier > xSupp( m_xModel, UNO_QUERY_THROW );
544 xElements.set( xSupp->getReportDocuments(), UNO_SET_THROW );
545 }
546 break;
547
548 case E_FORM:
549 {
550 Reference< XFormDocumentsSupplier > xSupp( m_xModel, UNO_QUERY_THROW );
551 xElements.set( xSupp->getFormDocuments(), UNO_SET_THROW );
552 }
553 break;
554
555 case E_QUERY:
556 {
557 xElements.set( getQueryDefintions(), UNO_QUERY_THROW );
558 }
559 break;
560
561 case E_TABLE:
562 {
563 if ( m_xDataSourceConnection.is() )
564 {
565 Reference< XTablesSupplier > xSup( getConnection(), UNO_QUERY_THROW );
566 xElements.set( xSup->getTables(), UNO_SET_THROW );
567 }
568 }
569 break;
570
571 default:
572 break;
573 }
574 }
575 catch(const Exception&)
576 {
577 DBG_UNHANDLED_EXCEPTION();
578 }
579
580 return xElements;
581 }
582 // -----------------------------------------------------------------------------
getSelectionElementNames(::std::vector<::rtl::OUString> & _rNames) const583 void OApplicationController::getSelectionElementNames(::std::vector< ::rtl::OUString>& _rNames) const
584 {
585 ::vos::OGuard aSolarGuard( Application::GetSolarMutex() );
586 ::osl::MutexGuard aGuard( getMutex() );
587
588 OSL_ENSURE(getContainer(),"View isn't valid! -> GPF");
589
590 getContainer()->getSelectionElementNames( _rNames );
591 }
592
593 // -----------------------------------------------------------------------------
getDocumentsAccess(ElementType _eType)594 ::std::auto_ptr< OLinkedDocumentsAccess > OApplicationController::getDocumentsAccess( ElementType _eType )
595 {
596 OSL_ENSURE( ( _eType == E_TABLE ) || ( _eType == E_QUERY ) || ( _eType == E_FORM ) || ( _eType == E_REPORT ),
597 "OApplicationController::getDocumentsAccess: only forms and reports are supported here!" );
598
599 SharedConnection xConnection( ensureConnection() );
600 Reference< XNameAccess > xDocContainer;
601
602 if ( ( _eType == E_FORM ) | ( _eType == E_REPORT ) )
603 {
604 xDocContainer.set( getElements( _eType ) );
605 OSL_ENSURE( xDocContainer.is(), "OApplicationController::getDocumentsAccess: invalid container!" );
606 }
607
608 ::std::auto_ptr< OLinkedDocumentsAccess > pDocuments( new OLinkedDocumentsAccess(
609 getView(), this, getORB(), xDocContainer, xConnection, getDatabaseName()
610 ) );
611 return pDocuments;
612 }
613 // -----------------------------------------------------------------------------
copyObject()614 TransferableHelper* OApplicationController::copyObject()
615 {
616 try
617 {
618 ::vos::OGuard aSolarGuard( Application::GetSolarMutex() );
619 ::osl::MutexGuard aGuard( getMutex() );
620
621 ElementType eType = getContainer()->getElementType();
622 TransferableHelper* pData = NULL;
623 switch( eType )
624 {
625 case E_TABLE:
626 case E_QUERY:
627 {
628 SharedConnection xConnection( ensureConnection() );
629 Reference< XDatabaseMetaData> xMetaData;
630 if ( xConnection.is() )
631 xMetaData = xConnection->getMetaData();
632
633 ::rtl::OUString sName = getContainer()->getQualifiedName( NULL );
634 if ( sName.getLength() )
635 {
636 ::rtl::OUString sDataSource = getDatabaseName();
637
638 if ( eType == E_TABLE )
639 {
640 pData = new ODataClipboard(sDataSource, CommandType::TABLE, sName, xConnection, getNumberFormatter(xConnection,getORB()), getORB());
641 }
642 else
643 {
644 pData = new ODataClipboard(sDataSource, CommandType::QUERY, sName, getNumberFormatter(xConnection,getORB()), getORB());
645 }
646 }
647 }
648 break;
649 case E_FORM:
650 case E_REPORT:
651 {
652 ::std::vector< ::rtl::OUString> aList;
653 getSelectionElementNames(aList);
654 Reference< XHierarchicalNameAccess > xElements(getElements(eType),UNO_QUERY);
655 if ( xElements.is() && !aList.empty() )
656 {
657 Reference< XContent> xContent(xElements->getByHierarchicalName(*aList.begin()),UNO_QUERY);
658 pData = new OComponentTransferable( getDatabaseName(), xContent );
659 }
660 }
661 break;
662 default:
663 break;
664 }
665
666 // the owner ship goes to ODataClipboards
667 return pData;
668 }
669 catch(const SQLException&)
670 {
671 showError( SQLExceptionInfo( ::cppu::getCaughtException() ) );
672 }
673 catch( const Exception& )
674 {
675 DBG_UNHANDLED_EXCEPTION();
676 }
677 return NULL;
678 }
679 // -----------------------------------------------------------------------------
paste(ElementType _eType,const::svx::ODataAccessDescriptor & _rPasteData,const String & _sParentFolder,sal_Bool _bMove)680 sal_Bool OApplicationController::paste( ElementType _eType,const ::svx::ODataAccessDescriptor& _rPasteData,const String& _sParentFolder ,sal_Bool _bMove)
681 {
682 try
683 {
684 if ( _eType == E_QUERY )
685 {
686 sal_Int32 nCommandType = CommandType::TABLE;
687 if ( _rPasteData.has(daCommandType) )
688 _rPasteData[daCommandType] >>= nCommandType;
689
690 if ( CommandType::QUERY == nCommandType || CommandType::COMMAND == nCommandType )
691 {
692 // read all nescessary data
693
694 ::rtl::OUString sCommand;
695 sal_Bool bEscapeProcessing = sal_True;
696
697 _rPasteData[daCommand] >>= sCommand;
698 if ( _rPasteData.has(daEscapeProcessing) )
699 _rPasteData[daEscapeProcessing] >>= bEscapeProcessing;
700
701 // plausibility check
702 sal_Bool bValidDescriptor = sal_False;
703 ::rtl::OUString sDataSourceName = _rPasteData.getDataSource();
704 if (CommandType::QUERY == nCommandType)
705 bValidDescriptor = sDataSourceName.getLength() && sCommand.getLength();
706 else if (CommandType::COMMAND == nCommandType)
707 bValidDescriptor = (0 != sCommand.getLength());
708 if (!bValidDescriptor)
709 {
710 DBG_ERROR("OApplicationController::paste: invalid descriptor!");
711 return sal_False;
712 }
713
714 // the target object name (as we'll suggest it to the user)
715 ::rtl::OUString sTargetName;
716 try
717 {
718 if ( CommandType::QUERY == nCommandType )
719 sTargetName = sCommand;
720
721 if ( !sTargetName.getLength() )
722 {
723 String sDefaultName = String( ModuleRes( STR_QRY_TITLE ) );
724 sDefaultName = sDefaultName.GetToken( 0, ' ' );
725
726 Reference< XNameAccess > xQueries( getQueryDefintions(), UNO_QUERY_THROW );
727 sTargetName = ::dbtools::createUniqueName( xQueries, sDefaultName, sal_False );
728 }
729 }
730 catch(const Exception&)
731 {
732 DBG_UNHANDLED_EXCEPTION();
733 }
734
735 Reference< XPropertySet > xQuery;
736 if (CommandType::QUERY == nCommandType)
737 {
738 // need to extract the statement and the escape processing flag from the query object
739 sal_Bool bSuccess = sal_False;
740 try
741 {
742 // the concrete query
743 Reference< XQueryDefinitionsSupplier > xSourceQuerySup(
744 getDataSourceByName( sDataSourceName, getView(), getORB(), NULL ),
745 UNO_QUERY_THROW );
746 Reference< XNameAccess > xQueries( xSourceQuerySup->getQueryDefinitions(), UNO_SET_THROW );
747 if ( xQueries->hasByName( sCommand ) )
748 {
749 xQuery.set( xQueries->getByName(sCommand), UNO_QUERY_THROW );
750 bSuccess = true;
751 }
752 }
753 catch(SQLException&) { throw; } // caught and handled by the outer catch
754 catch( const Exception& )
755 {
756 DBG_UNHANDLED_EXCEPTION();
757 }
758
759 if (!bSuccess)
760 {
761 DBG_ERROR("OApplicationController::paste: could not extract the source query object!");
762 // TODO: maybe this is worth an error message to be displayed to the user ....
763 return sal_False;
764 }
765 }
766
767
768 Reference< XNameContainer > xDestQueries(getQueryDefintions(), UNO_QUERY);
769 Reference< XSingleServiceFactory > xQueryFactory(xDestQueries, UNO_QUERY);
770 if (!xQueryFactory.is())
771 {
772 DBG_ERROR("OApplicationController::paste: invalid destination query container!");
773 return sal_False;
774 }
775
776 // here we have everything needed to create a new query object ...
777 // ... ehm, except a new name
778 ensureConnection();
779
780 DynamicTableOrQueryNameCheck aNameChecker( getConnection(), CommandType::QUERY );
781 ::dbtools::SQLExceptionInfo aDummy;
782 bool bNeedAskForName = ( sCommand.getLength() == 0 )
783 /* we did not have a source name, so the target name was auto-generated */
784 || ( !aNameChecker.isNameValid( sTargetName, aDummy ) );
785 /* name is invalid in the target DB (e.g. because it already
786 has a /table/ with that name) */
787 if ( bNeedAskForName )
788 {
789 OSaveAsDlg aAskForName( getView(),
790 CommandType::QUERY,
791 getORB(),
792 getConnection(),
793 sTargetName,
794 aNameChecker,
795 SAD_ADDITIONAL_DESCRIPTION | SAD_TITLE_PASTE_AS);
796 if ( RET_OK != aAskForName.Execute() )
797 // cancelled by the user
798 return sal_False;
799 sTargetName = aAskForName.getName();
800 }
801
802 // create a new object
803 Reference< XPropertySet > xNewQuery(xQueryFactory->createInstance(), UNO_QUERY);
804 DBG_ASSERT(xNewQuery.is(), "OApplicationController::paste: invalid object created by factory!");
805 if (xNewQuery.is())
806 {
807 // initialize
808 if ( xQuery.is() )
809 ::comphelper::copyProperties(xQuery,xNewQuery);
810 else
811 {
812 xNewQuery->setPropertyValue(PROPERTY_COMMAND,makeAny(sCommand));
813 xNewQuery->setPropertyValue(PROPERTY_ESCAPE_PROCESSING,makeAny(bEscapeProcessing));
814 }
815 // insert
816 xDestQueries->insertByName( sTargetName, makeAny(xNewQuery) );
817 xNewQuery.set(xDestQueries->getByName( sTargetName),UNO_QUERY);
818 if ( xQuery.is() && xNewQuery.is() )
819 {
820 Reference<XColumnsSupplier> xSrcColSup(xQuery,UNO_QUERY);
821 Reference<XColumnsSupplier> xDstColSup(xNewQuery,UNO_QUERY);
822 if ( xSrcColSup.is() && xDstColSup.is() )
823 {
824 Reference<XNameAccess> xSrcNameAccess = xSrcColSup->getColumns();
825 Reference<XNameAccess> xDstNameAccess = xDstColSup->getColumns();
826 Reference<XDataDescriptorFactory> xFac(xDstNameAccess,UNO_QUERY);
827 Reference<XAppend> xAppend(xFac,UNO_QUERY);
828 if ( xSrcNameAccess.is() && xDstNameAccess.is() && xSrcNameAccess->hasElements() && xAppend.is() )
829 {
830 Reference<XPropertySet> xDstProp(xFac->createDataDescriptor());
831
832 Sequence< ::rtl::OUString> aSeq = xSrcNameAccess->getElementNames();
833 const ::rtl::OUString* pIter = aSeq.getConstArray();
834 const ::rtl::OUString* pEnd = pIter + aSeq.getLength();
835 for( ; pIter != pEnd ; ++pIter)
836 {
837 Reference<XPropertySet> xSrcProp(xSrcNameAccess->getByName(*pIter),UNO_QUERY);
838 ::comphelper::copyProperties(xSrcProp,xDstProp);
839 xAppend->appendByDescriptor(xDstProp);
840 }
841 }
842 }
843 }
844 }
845 }
846 else
847 OSL_TRACE("There should be a sequence in it!");
848 return sal_True;
849 }
850 else if ( _rPasteData.has(daComponent) ) // forms or reports
851 {
852 Reference<XContent> xContent;
853 _rPasteData[daComponent] >>= xContent;
854 return insertHierachyElement(_eType,_sParentFolder,Reference<XNameAccess>(xContent,UNO_QUERY).is(),xContent,_bMove);
855 }
856 }
857 catch(const SQLException&) { showError( SQLExceptionInfo( ::cppu::getCaughtException() ) ); }
858 catch(const Exception& )
859 {
860 DBG_UNHANDLED_EXCEPTION();
861 }
862 return sal_False;
863 }
864 // -----------------------------------------------------------------------------
getQueryDefintions() const865 Reference<XNameContainer> OApplicationController::getQueryDefintions() const
866 {
867 Reference<XQueryDefinitionsSupplier> xSet(m_xDataSource,UNO_QUERY);
868 Reference<XNameContainer> xNames;
869 if ( xSet.is() )
870 {
871 xNames.set(xSet->getQueryDefinitions(),UNO_QUERY);
872 }
873 return xNames;
874 }
875 // -----------------------------------------------------------------------------
getSupportedFormats(ElementType _eType,::std::vector<SotFormatStringId> & _rFormatIds) const876 void OApplicationController::getSupportedFormats(ElementType _eType,::std::vector<SotFormatStringId>& _rFormatIds) const
877 {
878 switch( _eType )
879 {
880 case E_TABLE:
881 _rFormatIds.push_back(SOT_FORMATSTR_ID_DBACCESS_TABLE);
882 _rFormatIds.push_back(SOT_FORMAT_RTF);
883 _rFormatIds.push_back(SOT_FORMATSTR_ID_HTML);
884 // run through
885 case E_QUERY:
886 _rFormatIds.push_back(SOT_FORMATSTR_ID_DBACCESS_QUERY);
887 break;
888 default:
889 break;
890 }
891 }
892 // -----------------------------------------------------------------------------
isTableFormat() const893 sal_Bool OApplicationController::isTableFormat() const
894 {
895 return m_aTableCopyHelper.isTableFormat(getViewClipboard());
896 }
897 // -----------------------------------------------------------------------------
898 IMPL_LINK( OApplicationController, OnAsyncDrop, void*, /*NOTINTERESTEDIN*/ )
899 {
900 m_nAsyncDrop = 0;
901 ::vos::OGuard aSolarGuard( Application::GetSolarMutex() );
902 ::osl::MutexGuard aGuard( getMutex() );
903
904
905 if ( m_aAsyncDrop.nType == E_TABLE )
906 {
907 SharedConnection xConnection( ensureConnection() );
908 if ( xConnection.is() )
909 m_aTableCopyHelper.asyncCopyTagTable( m_aAsyncDrop, getDatabaseName(), xConnection );
910 }
911 else
912 {
913 if ( paste(m_aAsyncDrop.nType,m_aAsyncDrop.aDroppedData,m_aAsyncDrop.aUrl,m_aAsyncDrop.nAction == DND_ACTION_MOVE)
914 && m_aAsyncDrop.nAction == DND_ACTION_MOVE )
915 {
916 Reference<XContent> xContent;
917 m_aAsyncDrop.aDroppedData[daComponent] >>= xContent;
918 ::std::vector< ::rtl::OUString> aList;
919 sal_Int32 nIndex = 0;
920 ::rtl::OUString sName = xContent->getIdentifier()->getContentIdentifier();
921 ::rtl::OUString sErase = sName.getToken(0,'/',nIndex); // we don't want to have the "private:forms" part
922 if ( nIndex != -1 )
923 {
924 aList.push_back(sName.copy(sErase.getLength() + 1));
925 deleteObjects( m_aAsyncDrop.nType, aList, false );
926 }
927 }
928 }
929
930 m_aAsyncDrop.aDroppedData.clear();
931
932 return 0L;
933 }
934 //........................................................................
935 } // namespace dbaui
936 //........................................................................
937
938
939