xref: /trunk/main/sc/source/ui/dbgui/dapidata.cxx (revision b77af630)
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_scui.hxx"
26 
27 #undef SC_DLLIMPLEMENTATION
28 
29 
30 
31 //------------------------------------------------------------------
32 
33 #include <tools/debug.hxx>
34 #include <vcl/waitobj.hxx>
35 #include <comphelper/processfactory.hxx>
36 
37 #include <com/sun/star/sheet/DataImportMode.hpp>
38 #include <com/sun/star/lang/XMultiServiceFactory.hpp>
39 #include <com/sun/star/sdbcx/XTablesSupplier.hpp>
40 #include <com/sun/star/sdb/XQueriesSupplier.hpp>
41 #include <com/sun/star/sdb/XCompletedConnection.hpp>
42 
43 using namespace com::sun::star;
44 
45 #include "dapidata.hxx"
46 #include "scresid.hxx"
47 #include "sc.hrc"
48 #include "dapitype.hrc"
49 #include "miscuno.hxx"
50 #include "dpsdbtab.hxx"			// ScImportSourceDesc
51 
52 //-------------------------------------------------------------------------
53 
54 #define DP_SERVICE_DBCONTEXT		"com.sun.star.sdb.DatabaseContext"
55 #define SC_SERVICE_INTHANDLER		"com.sun.star.task.InteractionHandler"
56 
57 //	entries in the "type" ListBox
58 #define DP_TYPELIST_TABLE	0
59 #define DP_TYPELIST_QUERY	1
60 #define DP_TYPELIST_SQL		2
61 #define DP_TYPELIST_SQLNAT	3
62 
63 //-------------------------------------------------------------------------
64 
65 ScDataPilotDatabaseDlg::ScDataPilotDatabaseDlg( Window* pParent ) :
66 	ModalDialog     ( pParent, ScResId( RID_SCDLG_DAPIDATA ) ),
67 	//
68     aFlFrame        ( this, ScResId( FL_FRAME ) ),
69 	aFtDatabase     ( this, ScResId( FT_DATABASE ) ),
70 	aLbDatabase     ( this, ScResId( LB_DATABASE ) ),
71 	aFtType         ( this, ScResId( FT_OBJTYPE ) ),
72 	aLbType         ( this, ScResId( LB_OBJTYPE ) ),
73 	aFtObject       ( this, ScResId( FT_OBJECT ) ),
74 	aCbObject       ( this, ScResId( CB_OBJECT ) ),
75 	aBtnOk          ( this, ScResId( BTN_OK ) ),
76 	aBtnCancel      ( this, ScResId( BTN_CANCEL ) ),
77 	aBtnHelp        ( this, ScResId( BTN_HELP ) )
78 {
79 	FreeResource();
80 
81 	WaitObject aWait( this );		// initializing the database service the first time takes a while
82 
83 	try
84 	{
85 		//	get database names
86 
87 		uno::Reference<container::XNameAccess> xContext(
88 				comphelper::getProcessServiceFactory()->createInstance(
89 					rtl::OUString::createFromAscii( DP_SERVICE_DBCONTEXT ) ),
90 				uno::UNO_QUERY);
91 		if (xContext.is())
92 		{
93 			uno::Sequence<rtl::OUString> aNames = xContext->getElementNames();
94 			long nCount = aNames.getLength();
95 			const rtl::OUString* pArray = aNames.getConstArray();
96 			for (long nPos = 0; nPos < nCount; nPos++)
97 			{
98 				String aName = pArray[nPos];
99 				aLbDatabase.InsertEntry( aName );
100 			}
101 		}
102 	}
103 	catch(uno::Exception&)
104 	{
105 		DBG_ERROR("exception in database");
106 	}
107 
108 	aLbDatabase.SelectEntryPos( 0 );
109 	aLbType.SelectEntryPos( 0 );
110 
111 	FillObjects();
112 
113 	aLbDatabase.SetSelectHdl( LINK( this, ScDataPilotDatabaseDlg, SelectHdl ) );
114 	aLbType.SetSelectHdl( LINK( this, ScDataPilotDatabaseDlg, SelectHdl ) );
115 }
116 
117 ScDataPilotDatabaseDlg::~ScDataPilotDatabaseDlg()
118 {
119 }
120 
121 void ScDataPilotDatabaseDlg::GetValues( ScImportSourceDesc& rDesc )
122 {
123 	sal_uInt16 nSelect = aLbType.GetSelectEntryPos();
124 
125 	rDesc.aDBName = aLbDatabase.GetSelectEntry();
126 	rDesc.aObject = aCbObject.GetText();
127 
128 	if ( !rDesc.aDBName.Len() || !rDesc.aObject.Len() )
129 		rDesc.nType = sheet::DataImportMode_NONE;
130 	else if ( nSelect == DP_TYPELIST_TABLE )
131 		rDesc.nType = sheet::DataImportMode_TABLE;
132 	else if ( nSelect == DP_TYPELIST_QUERY )
133 		rDesc.nType = sheet::DataImportMode_QUERY;
134 	else
135 		rDesc.nType = sheet::DataImportMode_SQL;
136 
137 	rDesc.bNative = ( nSelect == DP_TYPELIST_SQLNAT );
138 }
139 
140 IMPL_LINK( ScDataPilotDatabaseDlg, SelectHdl, ListBox*, EMPTYARG )
141 {
142 	FillObjects();
143 	return 0;
144 }
145 
146 void ScDataPilotDatabaseDlg::FillObjects()
147 {
148 	aCbObject.Clear();
149 
150 	String aDatabaseName = aLbDatabase.GetSelectEntry();
151 	if (!aDatabaseName.Len())
152 		return;
153 
154 	sal_uInt16 nSelect = aLbType.GetSelectEntryPos();
155 	if ( nSelect > DP_TYPELIST_QUERY )
156 		return;									// only tables and queries
157 
158 	try
159 	{
160 		//	open connection (for tables or queries)
161 
162 		uno::Reference<container::XNameAccess> xContext(
163 				comphelper::getProcessServiceFactory()->createInstance(
164 					rtl::OUString::createFromAscii( DP_SERVICE_DBCONTEXT ) ),
165 				uno::UNO_QUERY);
166 		if ( !xContext.is() ) return;
167 
168 		uno::Any aSourceAny = xContext->getByName( aDatabaseName );
169 		uno::Reference<sdb::XCompletedConnection> xSource(
170 				ScUnoHelpFunctions::AnyToInterface( aSourceAny ), uno::UNO_QUERY );
171 		if ( !xSource.is() ) return;
172 
173 		uno::Reference<task::XInteractionHandler> xHandler(
174 				comphelper::getProcessServiceFactory()->createInstance(
175 					rtl::OUString::createFromAscii( SC_SERVICE_INTHANDLER ) ),
176 				uno::UNO_QUERY);
177 
178 		uno::Reference<sdbc::XConnection> xConnection = xSource->connectWithCompletion( xHandler );
179 
180 		uno::Sequence<rtl::OUString> aNames;
181 		if ( nSelect == DP_TYPELIST_TABLE )
182 		{
183 			//	get all tables
184 
185 			uno::Reference<sdbcx::XTablesSupplier> xTablesSupp( xConnection, uno::UNO_QUERY );
186 			if ( !xTablesSupp.is() ) return;
187 
188 			uno::Reference<container::XNameAccess> xTables = xTablesSupp->getTables();
189 			if ( !xTables.is() ) return;
190 
191 			aNames = xTables->getElementNames();
192 		}
193 		else
194 		{
195 			//	get all queries
196 
197 			uno::Reference<sdb::XQueriesSupplier> xQueriesSupp( xConnection, uno::UNO_QUERY );
198 			if ( !xQueriesSupp.is() ) return;
199 
200 			uno::Reference<container::XNameAccess> xQueries = xQueriesSupp->getQueries();
201 			if ( !xQueries.is() ) return;
202 
203 			aNames = xQueries->getElementNames();
204 		}
205 
206 		//	fill list
207 
208 		long nCount = aNames.getLength();
209 		const rtl::OUString* pArray = aNames.getConstArray();
210 		for( long nPos=0; nPos<nCount; nPos++ )
211 		{
212 			String aName = pArray[nPos];
213 			aCbObject.InsertEntry( aName );
214 		}
215 	}
216 	catch(uno::Exception&)
217 	{
218 		//	#71604# this may happen if an invalid database is selected -> no DBG_ERROR
219 		DBG_WARNING("exception in database");
220 	}
221 }
222 
223 
224 
225 
226