sc/source/ui/dbgui/dapidata.cxx

   1 /*************************************************************************
   2  *
   3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   4  *
   5  * Copyright 2008 by Sun Microsystems, Inc.
   6  *
   7  * OpenOffice.org - a multi-platform office productivity suite
   8  *
   9  * $RCSfile: dapidata.cxx,v $
  10  * $Revision: 1.12 $
  11  *
  12  * This file is part of OpenOffice.org.
  13  *
  14  * OpenOffice.org is free software: you can redistribute it and/or modify
  15  * it under the terms of the GNU Lesser General Public License version 3
  16  * only, as published by the Free Software Foundation.
  17  *
  18  * OpenOffice.org is distributed in the hope that it will be useful,
  19  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  20  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  21  * GNU Lesser General Public License version 3 for more details
  22  * (a copy is included in the LICENSE file that accompanied this code).
  23  *
  24  * You should have received a copy of the GNU Lesser General Public License
  25  * version 3 along with OpenOffice.org.  If not, see
  26  * <http://www.openoffice.org/license.html>
  27  * for a copy of the LGPLv3 License.
  28  *
  29  ************************************************************************/
  30
  31 // MARKER(update_precomp.py): autogen include statement, do not remove
  32 #include "precompiled_sc.hxx"
  33
  34 #undef SC_DLLIMPLEMENTATION
  35
  36
  37
  38 //------------------------------------------------------------------
  39
  40 #include <tools/debug.hxx>
  41 #include <vcl/waitobj.hxx>
  42 #include <comphelper/processfactory.hxx>
  43
  44 #include <com/sun/star/sheet/DataImportMode.hpp>
  45 #include <com/sun/star/lang/XMultiServiceFactory.hpp>
  46 #include <com/sun/star/sdbcx/XTablesSupplier.hpp>
  47 #include <com/sun/star/sdb/XQueriesSupplier.hpp>
  48 #include <com/sun/star/sdb/XCompletedConnection.hpp>
  49
  50 using namespace com::sun::star;
  51
  52 #include "dapidata.hxx"
  53 #include "scresid.hxx"
  54 #include "sc.hrc"
  55 #include "dapitype.hrc"
  56 #include "miscuno.hxx"
  57 #include "dpsdbtab.hxx"                 // ScImportSourceDesc
  58
  59 //-------------------------------------------------------------------------
  60
  61 #define DP_SERVICE_DBCONTEXT            "com.sun.star.sdb.DatabaseContext"
  62 #define SC_SERVICE_INTHANDLER           "com.sun.star.sdb.InteractionHandler"
  63
  64 //      entries in the "type" ListBox
  65 #define DP_TYPELIST_TABLE       0
  66 #define DP_TYPELIST_QUERY       1
  67 #define DP_TYPELIST_SQL         2
  68 #define DP_TYPELIST_SQLNAT      3
  69
  70 //-------------------------------------------------------------------------
  71
  72 ScDataPilotDatabaseDlg::ScDataPilotDatabaseDlg( Window* pParent ) :
  73     ModalDialog     ( pParent, ScResId( RID_SCDLG_DAPIDATA ) ),
  74     //
  75     aFlFrame        ( this, ScResId( FL_FRAME ) ),
  76     aFtDatabase     ( this, ScResId( FT_DATABASE ) ),
  77     aLbDatabase     ( this, ScResId( LB_DATABASE ) ),
  78     aFtObject       ( this, ScResId( FT_OBJECT ) ),
  79     aCbObject       ( this, ScResId( CB_OBJECT ) ),
  80     aFtType         ( this, ScResId( FT_OBJTYPE ) ),
  81     aLbType         ( this, ScResId( LB_OBJTYPE ) ),
  82     aBtnOk          ( this, ScResId( BTN_OK ) ),
  83     aBtnCancel      ( this, ScResId( BTN_CANCEL ) ),
  84     aBtnHelp        ( this, ScResId( BTN_HELP ) )
  85 {
  86     FreeResource();
  87
  88     WaitObject aWait( this );           // initializing the database service the first time takes a while
  89
  90     try
  91     {
  92         //      get database names
  93
  94         uno::Reference<container::XNameAccess> xContext(
  95                 comphelper::getProcessServiceFactory()->createInstance(
  96                     rtl::OUString::createFromAscii( DP_SERVICE_DBCONTEXT ) ),
  97                 uno::UNO_QUERY);
  98         if (xContext.is())
  99         {
 100             uno::Sequence<rtl::OUString> aNames = xContext->getElementNames();
 101             long nCount = aNames.getLength();
 102             const rtl::OUString* pArray = aNames.getConstArray();
 103             for (long nPos = 0; nPos < nCount; nPos++)
 104             {
 105                 String aName = pArray[nPos];
 106                 aLbDatabase.InsertEntry( aName );
 107             }
 108         }
 109     }
 110     catch(uno::Exception&)
 111     {
 112         DBG_ERROR("exception in database");
 113     }
 114
 115     aLbDatabase.SelectEntryPos( 0 );
 116     aLbType.SelectEntryPos( 0 );
 117
 118     FillObjects();
 119
 120     aLbDatabase.SetSelectHdl( LINK( this, ScDataPilotDatabaseDlg, SelectHdl ) );
 121     aLbType.SetSelectHdl( LINK( this, ScDataPilotDatabaseDlg, SelectHdl ) );
 122 }
 123
 124 ScDataPilotDatabaseDlg::~ScDataPilotDatabaseDlg()
 125 {
 126 }
 127
 128 void ScDataPilotDatabaseDlg::GetValues( ScImportSourceDesc& rDesc )
 129 {
 130     USHORT nSelect = aLbType.GetSelectEntryPos();
 131
 132     rDesc.aDBName = aLbDatabase.GetSelectEntry();
 133     rDesc.aObject = aCbObject.GetText();
 134
 135     if ( !rDesc.aDBName.Len() || !rDesc.aObject.Len() )
 136         rDesc.nType = sheet::DataImportMode_NONE;
 137     else if ( nSelect == DP_TYPELIST_TABLE )
 138         rDesc.nType = sheet::DataImportMode_TABLE;
 139     else if ( nSelect == DP_TYPELIST_QUERY )
 140         rDesc.nType = sheet::DataImportMode_QUERY;
 141     else
 142         rDesc.nType = sheet::DataImportMode_SQL;
 143
 144     rDesc.bNative = ( nSelect == DP_TYPELIST_SQLNAT );
 145 }
 146
 147 IMPL_LINK( ScDataPilotDatabaseDlg, SelectHdl, ListBox*, EMPTYARG )
 148 {
 149     FillObjects();
 150     return 0;
 151 }
 152
 153 void ScDataPilotDatabaseDlg::FillObjects()
 154 {
 155     aCbObject.Clear();
 156
 157     String aDatabaseName = aLbDatabase.GetSelectEntry();
 158     if (!aDatabaseName.Len())
 159         return;
 160
 161     USHORT nSelect = aLbType.GetSelectEntryPos();
 162     if ( nSelect > DP_TYPELIST_QUERY )
 163         return;                                                                 // only tables and queries
 164
 165     try
 166     {
 167         //      open connection (for tables or queries)
 168
 169         uno::Reference<container::XNameAccess> xContext(
 170                 comphelper::getProcessServiceFactory()->createInstance(
 171                     rtl::OUString::createFromAscii( DP_SERVICE_DBCONTEXT ) ),
 172                 uno::UNO_QUERY);
 173         if ( !xContext.is() ) return;
 174
 175         uno::Any aSourceAny = xContext->getByName( aDatabaseName );
 176         uno::Reference<sdb::XCompletedConnection> xSource(
 177                 ScUnoHelpFunctions::AnyToInterface( aSourceAny ), uno::UNO_QUERY );
 178         if ( !xSource.is() ) return;
 179
 180         uno::Reference<task::XInteractionHandler> xHandler(
 181                 comphelper::getProcessServiceFactory()->createInstance(
 182                     rtl::OUString::createFromAscii( SC_SERVICE_INTHANDLER ) ),
 183                 uno::UNO_QUERY);
 184
 185         uno::Reference<sdbc::XConnection> xConnection = xSource->connectWithCompletion( xHandler );
 186
 187         uno::Sequence<rtl::OUString> aNames;
 188         if ( nSelect == DP_TYPELIST_TABLE )
 189         {
 190             //  get all tables
 191
 192             uno::Reference<sdbcx::XTablesSupplier> xTablesSupp( xConnection, uno::UNO_QUERY );
 193             if ( !xTablesSupp.is() ) return;
 194
 195             uno::Reference<container::XNameAccess> xTables = xTablesSupp->getTables();
 196             if ( !xTables.is() ) return;
 197
 198             aNames = xTables->getElementNames();
 199         }
 200         else
 201         {
 202             //  get all queries
 203
 204             uno::Reference<sdb::XQueriesSupplier> xQueriesSupp( xConnection, uno::UNO_QUERY );
 205             if ( !xQueriesSupp.is() ) return;
 206
 207             uno::Reference<container::XNameAccess> xQueries = xQueriesSupp->getQueries();
 208             if ( !xQueries.is() ) return;
 209
 210             aNames = xQueries->getElementNames();
 211         }
 212
 213         //      fill list
 214
 215         long nCount = aNames.getLength();
 216         const rtl::OUString* pArray = aNames.getConstArray();
 217         for( long nPos=0; nPos<nCount; nPos++ )
 218         {
 219             String aName = pArray[nPos];
 220             aCbObject.InsertEntry( aName );
 221         }
 222     }
 223     catch(uno::Exception&)
 224     {
 225         //      #71604# this may happen if an invalid database is selected -> no DBG_ERROR
 226         DBG_WARNING("exception in database");
 227     }
 228 }
 229
 230
 231
 232