2001-03-23 09:59:09 +00:00
|
|
|
/*************************************************************************
|
|
|
|
|
*
|
|
|
|
|
* $RCSfile: dsbrowserDnD.cxx,v $
|
|
|
|
|
*
|
2002-04-02 05:45:52 +00:00
|
|
|
* $Revision: 1.38 $
|
2001-03-23 09:59:09 +00:00
|
|
|
*
|
2002-04-02 05:45:52 +00:00
|
|
|
* last change: $Author: oj $ $Date: 2002-04-02 06:45:52 $
|
2001-03-23 09:59:09 +00:00
|
|
|
*
|
|
|
|
|
* The Contents of this file are made available subject to the terms of
|
|
|
|
|
* either of the following licenses
|
|
|
|
|
*
|
|
|
|
|
* - GNU Lesser General Public License Version 2.1
|
|
|
|
|
* - Sun Industry Standards Source License Version 1.1
|
|
|
|
|
*
|
|
|
|
|
* Sun Microsystems Inc., October, 2000
|
|
|
|
|
*
|
|
|
|
|
* GNU Lesser General Public License Version 2.1
|
|
|
|
|
* =============================================
|
|
|
|
|
* Copyright 2000 by Sun Microsystems, Inc.
|
|
|
|
|
* 901 San Antonio Road, Palo Alto, CA 94303, USA
|
|
|
|
|
*
|
|
|
|
|
* This library is free software; you can redistribute it and/or
|
|
|
|
|
* modify it under the terms of the GNU Lesser General Public
|
|
|
|
|
* License version 2.1, as published by the Free Software Foundation.
|
|
|
|
|
*
|
|
|
|
|
* This library is distributed in the hope that it will be useful,
|
|
|
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
|
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
|
|
|
* Lesser General Public License for more details.
|
|
|
|
|
*
|
|
|
|
|
* You should have received a copy of the GNU Lesser General Public
|
|
|
|
|
* License along with this library; if not, write to the Free Software
|
|
|
|
|
* Foundation, Inc., 59 Temple Place, Suite 330, Boston,
|
|
|
|
|
* MA 02111-1307 USA
|
|
|
|
|
*
|
|
|
|
|
*
|
|
|
|
|
* Sun Industry Standards Source License Version 1.1
|
|
|
|
|
* =================================================
|
|
|
|
|
* The contents of this file are subject to the Sun Industry Standards
|
|
|
|
|
* Source License Version 1.1 (the "License"); You may not use this file
|
|
|
|
|
* except in compliance with the License. You may obtain a copy of the
|
|
|
|
|
* License at http://www.openoffice.org/license.html.
|
|
|
|
|
*
|
|
|
|
|
* Software provided under this License is provided on an "AS IS" basis,
|
|
|
|
|
* WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESS OR IMPLIED, INCLUDING,
|
|
|
|
|
* WITHOUT LIMITATION, WARRANTIES THAT THE SOFTWARE IS FREE OF DEFECTS,
|
|
|
|
|
* MERCHANTABLE, FIT FOR A PARTICULAR PURPOSE, OR NON-INFRINGING.
|
|
|
|
|
* See the License for the specific provisions governing your rights and
|
|
|
|
|
* obligations concerning the Software.
|
|
|
|
|
*
|
|
|
|
|
* The Initial Developer of the Original Code is: Sun Microsystems, Inc..
|
|
|
|
|
*
|
|
|
|
|
* Copyright: 2000 by Sun Microsystems, Inc.
|
|
|
|
|
*
|
|
|
|
|
* All Rights Reserved.
|
|
|
|
|
*
|
|
|
|
|
* Contributor(s): _______________________________________
|
|
|
|
|
*
|
|
|
|
|
*
|
|
|
|
|
************************************************************************/
|
|
|
|
|
|
|
|
|
|
#ifndef _SBA_UNODATBR_HXX_
|
|
|
|
|
#include "unodatbr.hxx"
|
|
|
|
|
#endif
|
|
|
|
|
|
|
|
|
|
#ifndef _COM_SUN_STAR_SDB_XQUERIESSUPPLIER_HPP_
|
|
|
|
|
#include <com/sun/star/sdb/XQueriesSupplier.hpp>
|
|
|
|
|
#endif
|
2001-06-22 09:58:46 +00:00
|
|
|
#ifndef _COM_SUN_STAR_SDB_XSQLQUERYCOMPOSERFACTORY_HPP_
|
|
|
|
|
#include <com/sun/star/sdb/XSQLQueryComposerFactory.hpp>
|
|
|
|
|
#endif
|
2001-03-23 09:59:09 +00:00
|
|
|
#ifndef _COM_SUN_STAR_SDB_COMMANDTYPE_HPP_
|
|
|
|
|
#include <com/sun/star/sdb/CommandType.hpp>
|
|
|
|
|
#endif
|
|
|
|
|
#ifndef _COM_SUN_STAR_SDBC_DATATYPE_HPP_
|
|
|
|
|
#include <com/sun/star/sdbc/DataType.hpp>
|
|
|
|
|
#endif
|
|
|
|
|
#ifndef _COM_SUN_STAR_SDBC_XCONNECTION_HPP_
|
|
|
|
|
#include <com/sun/star/sdbc/XConnection.hpp>
|
|
|
|
|
#endif
|
|
|
|
|
#ifndef _COM_SUN_STAR_SDBCX_XTABLESSUPPLIER_HPP_
|
|
|
|
|
#include <com/sun/star/sdbcx/XTablesSupplier.hpp>
|
|
|
|
|
#endif
|
2001-09-25 12:28:23 +00:00
|
|
|
#ifndef _COM_SUN_STAR_SDBCX_XRENAME_HPP_
|
|
|
|
|
#include <com/sun/star/sdbcx/XRename.hpp>
|
|
|
|
|
#endif
|
2001-03-23 09:59:09 +00:00
|
|
|
#ifndef _COM_SUN_STAR_CONTAINER_XNAMECONTAINER_HPP_
|
|
|
|
|
#include <com/sun/star/container/XNameContainer.hpp>
|
|
|
|
|
#endif
|
|
|
|
|
#ifndef _COM_SUN_STAR_SDBC_XRESULTSETMETADATASUPPLIER_HPP_
|
|
|
|
|
#include <com/sun/star/sdbc/XResultSetMetaDataSupplier.hpp>
|
|
|
|
|
#endif
|
2002-03-27 07:18:45 +00:00
|
|
|
#ifndef _COM_SUN_STAR_SDBC_XCOLUMNLOCATE_HPP_
|
|
|
|
|
#include <com/sun/star/sdbc/XColumnLocate.hpp>
|
|
|
|
|
#endif
|
2001-03-23 09:59:09 +00:00
|
|
|
#ifndef _COM_SUN_STAR_SDB_XQUERYDEFINITIONSSUPPLIER_HPP_
|
|
|
|
|
#include <com/sun/star/sdb/XQueryDefinitionsSupplier.hpp>
|
|
|
|
|
#endif
|
|
|
|
|
#ifndef _COM_SUN_STAR_BEANS_PROPERTYVALUE_HPP_
|
|
|
|
|
#include <com/sun/star/beans/PropertyValue.hpp>
|
|
|
|
|
#endif
|
2001-06-01 10:23:46 +00:00
|
|
|
#ifndef _COM_SUN_STAR_SDBC_XPARAMETERS_HPP_
|
|
|
|
|
#include <com/sun/star/sdbc/XParameters.hpp>
|
|
|
|
|
#endif
|
2001-03-23 09:59:09 +00:00
|
|
|
#ifndef _COM_SUN_STAR_LANG_XSINGLESERVICEFACTORY_HPP_
|
|
|
|
|
#include <com/sun/star/lang/XSingleServiceFactory.hpp>
|
|
|
|
|
#endif
|
|
|
|
|
#ifndef _COM_SUN_STAR_SDB_SQLCONTEXT_HPP_
|
|
|
|
|
#include <com/sun/star/sdb/SQLContext.hpp>
|
|
|
|
|
#endif
|
|
|
|
|
#ifndef DBAUI_DBTREEMODEL_HXX
|
|
|
|
|
#include "dbtreemodel.hxx"
|
|
|
|
|
#endif
|
|
|
|
|
#ifndef DBACCESS_UI_DBTREEVIEW_HXX
|
|
|
|
|
#include "dbtreeview.hxx"
|
|
|
|
|
#endif
|
|
|
|
|
#ifndef DBACCESS_SHARED_DBUSTRINGS_HRC
|
|
|
|
|
#include "dbustrings.hrc"
|
|
|
|
|
#endif
|
|
|
|
|
#ifndef _DBU_RESOURCE_HRC_
|
|
|
|
|
#include "dbu_resource.hrc"
|
|
|
|
|
#endif
|
|
|
|
|
#ifndef _DBAUI_MODULE_DBU_HXX_
|
|
|
|
|
#include "moduledbu.hxx"
|
|
|
|
|
#endif
|
|
|
|
|
#ifndef _COMPHELPER_EXTRACT_HXX_
|
|
|
|
|
#include <comphelper/extract.hxx>
|
|
|
|
|
#endif
|
|
|
|
|
#ifndef _DBHELPER_DBEXCEPTION_HXX_
|
|
|
|
|
#include <connectivity/dbexception.hxx>
|
|
|
|
|
#endif
|
2001-06-01 10:23:46 +00:00
|
|
|
#ifndef _CONNECTIVITY_DBTOOLS_HXX_
|
|
|
|
|
#include <connectivity/dbtools.hxx>
|
|
|
|
|
#endif
|
2001-03-23 09:59:09 +00:00
|
|
|
#ifndef DBAUI_DBTREELISTBOX_HXX
|
|
|
|
|
#include "dbtreelistbox.hxx"
|
|
|
|
|
#endif
|
|
|
|
|
#ifndef DBAUI_TOKENWRITER_HXX
|
|
|
|
|
#include "TokenWriter.hxx"
|
|
|
|
|
#endif
|
|
|
|
|
#ifndef DBAUI_DBEXCHANGE_HXX
|
|
|
|
|
#include "dbexchange.hxx"
|
|
|
|
|
#endif
|
|
|
|
|
#ifndef DBAUI_WIZ_COPYTABLEDIALOG_HXX
|
|
|
|
|
#include "WCopyTable.hxx"
|
|
|
|
|
#endif
|
|
|
|
|
#ifndef DBAUI_WIZ_EXTENDPAGES_HXX
|
|
|
|
|
#include "WExtendPages.hxx"
|
|
|
|
|
#endif
|
|
|
|
|
#ifndef DBAUI_WIZ_NAMEMATCHING_HXX
|
|
|
|
|
#include "WNameMatch.hxx"
|
|
|
|
|
#endif
|
|
|
|
|
#ifndef DBAUI_WIZ_COLUMNSELECT_HXX
|
|
|
|
|
#include "WColumnSelect.hxx"
|
|
|
|
|
#endif
|
|
|
|
|
#ifndef DBAUI_ENUMTYPES_HXX
|
|
|
|
|
#include "QEnumTypes.hxx"
|
|
|
|
|
#endif
|
|
|
|
|
#ifndef DBAUI_WIZARD_CPAGE_HXX
|
|
|
|
|
#include "WCPage.hxx"
|
|
|
|
|
#endif
|
|
|
|
|
#ifndef DBAUI_TOOLS_HXX
|
|
|
|
|
#include "UITools.hxx"
|
|
|
|
|
#endif
|
|
|
|
|
#ifndef DBAUI_RTFREADER_HXX
|
|
|
|
|
#include "RtfReader.hxx"
|
|
|
|
|
#endif
|
|
|
|
|
#ifndef DBAUI_HTMLREADER_HXX
|
|
|
|
|
#include "HtmlReader.hxx"
|
|
|
|
|
#endif
|
|
|
|
|
#ifndef DBAUI_DLGSAVE_HXX
|
|
|
|
|
#include "dlgsave.hxx"
|
|
|
|
|
#endif
|
|
|
|
|
#ifndef _SOT_STORAGE_HXX
|
|
|
|
|
#include <sot/storage.hxx>
|
|
|
|
|
#endif
|
2001-04-11 11:58:38 +00:00
|
|
|
#ifndef _SVX_DATACCESSDESCRIPTOR_HXX_
|
|
|
|
|
#include <svx/dataaccessdescriptor.hxx>
|
|
|
|
|
#endif
|
2001-06-22 09:58:46 +00:00
|
|
|
#ifndef _COM_SUN_STAR_TASK_XINTERACTIONHANDLER_HPP_
|
|
|
|
|
#include <com/sun/star/task/XInteractionHandler.hpp>
|
|
|
|
|
#endif
|
2001-07-18 10:34:19 +00:00
|
|
|
#ifndef _DBAUI_LINKEDDOCUMENTS_HXX_
|
|
|
|
|
#include "linkeddocuments.hxx"
|
|
|
|
|
#endif
|
2001-03-23 09:59:09 +00:00
|
|
|
// .........................................................................
|
|
|
|
|
namespace dbaui
|
|
|
|
|
{
|
|
|
|
|
// .........................................................................
|
|
|
|
|
|
|
|
|
|
using namespace ::com::sun::star::uno;
|
|
|
|
|
using namespace ::com::sun::star::sdb;
|
|
|
|
|
using namespace ::com::sun::star::sdbc;
|
|
|
|
|
using namespace ::com::sun::star::sdbcx;
|
|
|
|
|
using namespace ::com::sun::star::beans;
|
|
|
|
|
using namespace ::com::sun::star::util;
|
|
|
|
|
using namespace ::com::sun::star::frame;
|
|
|
|
|
using namespace ::com::sun::star::container;
|
|
|
|
|
using namespace ::com::sun::star::lang;
|
|
|
|
|
using namespace ::com::sun::star::form;
|
|
|
|
|
using namespace ::com::sun::star::io;
|
|
|
|
|
using namespace ::com::sun::star::i18n;
|
2001-06-22 09:58:46 +00:00
|
|
|
using namespace ::com::sun::star::task;
|
2001-03-23 09:59:09 +00:00
|
|
|
using namespace ::com::sun::star::datatransfer;
|
|
|
|
|
using namespace ::dbtools;
|
2001-04-11 11:58:38 +00:00
|
|
|
using namespace ::svx;
|
2001-03-23 09:59:09 +00:00
|
|
|
|
2002-03-27 07:18:45 +00:00
|
|
|
// -----------------------------------------------------------------------------
|
|
|
|
|
#define FILL_PARAM(type,method) \
|
|
|
|
|
{ \
|
|
|
|
|
type nValue = xRow->g##method(i); \
|
|
|
|
|
if ( !xRow->wasNull() ) \
|
|
|
|
|
xParameter->s##method(nPos,nValue); \
|
|
|
|
|
else \
|
|
|
|
|
xParameter->setNull(nPos,aColumnTypes[i]); \
|
|
|
|
|
}
|
|
|
|
|
// -----------------------------------------------------------------------------
|
|
|
|
|
void insertRows(const Reference<XResultSet>& xSrcRs,
|
|
|
|
|
const ::std::vector<sal_Int32>& _rvColumns,
|
|
|
|
|
const Reference<XPropertySet>& _xDestTable,
|
|
|
|
|
const Reference<XDatabaseMetaData>& _xMetaData,
|
|
|
|
|
sal_Bool bIsAutoIncrement,
|
|
|
|
|
const Sequence<Any>& _aSelection) throw(SQLException, RuntimeException)
|
|
|
|
|
{
|
|
|
|
|
Reference< XResultSetMetaDataSupplier> xSrcMetaSup(xSrcRs,UNO_QUERY);
|
|
|
|
|
Reference<XRow> xRow(xSrcRs,UNO_QUERY);
|
|
|
|
|
if(!xSrcRs.is() || !xRow.is())
|
|
|
|
|
return;
|
|
|
|
|
|
|
|
|
|
::rtl::OUString aSql(::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("INSERT INTO ")));
|
|
|
|
|
::rtl::OUString sComposedTableName;
|
|
|
|
|
::dbaui::composeTableName(_xMetaData,_xDestTable,sComposedTableName,sal_True);
|
|
|
|
|
|
|
|
|
|
aSql += sComposedTableName;
|
|
|
|
|
aSql += ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM(" ( "));
|
|
|
|
|
// set values and column names
|
|
|
|
|
::rtl::OUString aValues(RTL_CONSTASCII_USTRINGPARAM(" VALUES ( "));
|
|
|
|
|
static ::rtl::OUString aPara(RTL_CONSTASCII_USTRINGPARAM("?,"));
|
|
|
|
|
static ::rtl::OUString aComma(RTL_CONSTASCII_USTRINGPARAM(","));
|
|
|
|
|
|
|
|
|
|
::rtl::OUString aQuote = _xMetaData->getIdentifierQuoteString();
|
|
|
|
|
|
|
|
|
|
Reference<XColumnsSupplier> xColsSup(_xDestTable,UNO_QUERY);
|
|
|
|
|
OSL_ENSURE(xColsSup.is(),"SbaTableQueryBrowser::insertRows: No columnsSupplier!");
|
|
|
|
|
if(!xColsSup.is())
|
|
|
|
|
return;
|
|
|
|
|
|
|
|
|
|
// we a vector which all types
|
|
|
|
|
Reference< XResultSetMetaData> xMeta = xSrcMetaSup->getMetaData();
|
|
|
|
|
sal_Int32 nCount = xMeta->getColumnCount();
|
|
|
|
|
::std::vector<sal_Int32> aColumnTypes;
|
|
|
|
|
aColumnTypes.reserve(nCount+1);
|
|
|
|
|
aColumnTypes.push_back(-1); // just to avoid a everytime i-1 call
|
|
|
|
|
for(sal_Int32 k=1;k <= nCount;++k)
|
|
|
|
|
aColumnTypes.push_back(xMeta->getColumnType(k));
|
|
|
|
|
|
|
|
|
|
// create sql string and set column types
|
|
|
|
|
Reference<XNameAccess> xNameAccess = xColsSup->getColumns();
|
|
|
|
|
Sequence< ::rtl::OUString> aSeq = xNameAccess->getElementNames();
|
|
|
|
|
const ::rtl::OUString* pBegin = aSeq.getConstArray();
|
|
|
|
|
const ::rtl::OUString* pEnd = pBegin + aSeq.getLength();
|
|
|
|
|
for(;pBegin != pEnd;++pBegin)
|
|
|
|
|
{
|
|
|
|
|
// create the sql string
|
|
|
|
|
aSql += ::dbtools::quoteName( aQuote,*pBegin);
|
|
|
|
|
aSql += aComma;
|
|
|
|
|
aValues += aPara;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
aSql = aSql.replaceAt(aSql.getLength()-1,1,::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM(")")));
|
|
|
|
|
aValues = aValues.replaceAt(aValues.getLength()-1,1,::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM(")")));
|
|
|
|
|
|
|
|
|
|
aSql += aValues;
|
|
|
|
|
// now create,fill and execute the prepared statement
|
|
|
|
|
Reference< XPreparedStatement > xPrep(_xMetaData->getConnection()->prepareStatement(aSql));
|
|
|
|
|
Reference< XParameters > xParameter(xPrep,UNO_QUERY);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
sal_Int32 nRowCount = 0;
|
|
|
|
|
const Any* pSelBegin = _aSelection.getConstArray();
|
|
|
|
|
const Any* pSelEnd = pSelBegin + _aSelection.getLength();
|
|
|
|
|
sal_Bool bUseSelection = _aSelection.getLength() > 0;
|
|
|
|
|
sal_Bool bNext = sal_True;
|
|
|
|
|
do // loop as long as there are more rows or the selection ends
|
|
|
|
|
{
|
|
|
|
|
if ( bUseSelection )
|
|
|
|
|
{
|
|
|
|
|
if ( pSelBegin != pSelEnd )
|
|
|
|
|
{
|
|
|
|
|
sal_Int32 nPos = 0;
|
|
|
|
|
*pSelBegin >>= nPos;
|
|
|
|
|
bNext = xSrcRs->absolute( nPos );
|
|
|
|
|
++pSelBegin;
|
|
|
|
|
}
|
|
|
|
|
else
|
|
|
|
|
bNext = sal_False;
|
|
|
|
|
}
|
|
|
|
|
else
|
|
|
|
|
bNext = xSrcRs->next();
|
|
|
|
|
if ( bNext )
|
|
|
|
|
{
|
|
|
|
|
++nRowCount;
|
|
|
|
|
::std::vector<sal_Int32>::const_iterator aPosIter = _rvColumns.begin();
|
|
|
|
|
for(sal_Int32 i = 1;aPosIter != _rvColumns.end();++aPosIter,++i)
|
|
|
|
|
{
|
|
|
|
|
sal_Int32 nPos = *aPosIter;
|
|
|
|
|
if(nPos == CONTAINER_ENTRY_NOTFOUND)
|
|
|
|
|
continue;
|
|
|
|
|
if(i == 1 && bIsAutoIncrement)
|
|
|
|
|
{
|
|
|
|
|
xParameter->setInt(1,nRowCount);
|
|
|
|
|
continue;
|
|
|
|
|
}
|
|
|
|
|
switch(aColumnTypes[i])
|
|
|
|
|
{
|
|
|
|
|
case DataType::CHAR:
|
|
|
|
|
case DataType::VARCHAR:
|
|
|
|
|
case DataType::LONGVARCHAR:
|
|
|
|
|
FILL_PARAM( ::rtl::OUString, etString)
|
|
|
|
|
break;
|
|
|
|
|
case DataType::DECIMAL:
|
|
|
|
|
case DataType::NUMERIC:
|
|
|
|
|
case DataType::DOUBLE:
|
|
|
|
|
case DataType::REAL:
|
|
|
|
|
FILL_PARAM( double, etDouble)
|
|
|
|
|
break;
|
|
|
|
|
case DataType::BIGINT:
|
|
|
|
|
FILL_PARAM( sal_Int64, etLong)
|
|
|
|
|
break;
|
|
|
|
|
case DataType::FLOAT:
|
|
|
|
|
FILL_PARAM( float, etFloat)
|
|
|
|
|
break;
|
|
|
|
|
case DataType::LONGVARBINARY:
|
|
|
|
|
case DataType::BINARY:
|
|
|
|
|
case DataType::VARBINARY:
|
|
|
|
|
FILL_PARAM( Sequence< sal_Int8 >, etBytes)
|
|
|
|
|
break;
|
|
|
|
|
case DataType::DATE:
|
|
|
|
|
FILL_PARAM( ::com::sun::star::util::Date, etDate)
|
|
|
|
|
break;
|
|
|
|
|
case DataType::TIME:
|
|
|
|
|
FILL_PARAM( ::com::sun::star::util::Time, etTime)
|
|
|
|
|
break;
|
|
|
|
|
case DataType::TIMESTAMP:
|
|
|
|
|
FILL_PARAM( ::com::sun::star::util::DateTime, etTimestamp)
|
|
|
|
|
break;
|
|
|
|
|
case DataType::BIT:
|
|
|
|
|
FILL_PARAM( sal_Bool, etBoolean)
|
|
|
|
|
break;
|
|
|
|
|
case DataType::TINYINT:
|
|
|
|
|
FILL_PARAM( sal_Int8, etByte)
|
|
|
|
|
break;
|
|
|
|
|
case DataType::SMALLINT:
|
|
|
|
|
FILL_PARAM( sal_Int16, etShort)
|
|
|
|
|
break;
|
|
|
|
|
case DataType::INTEGER:
|
|
|
|
|
FILL_PARAM( sal_Int32, etInt)
|
|
|
|
|
break;
|
|
|
|
|
default:
|
|
|
|
|
OSL_ENSURE(0,"Unknown type");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
xPrep->executeUpdate();
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
while( bNext );
|
|
|
|
|
}
|
|
|
|
|
// -----------------------------------------------------------------------------
|
|
|
|
|
Reference<XResultSet> createResultSet( SbaTableQueryBrowser* _pBrowser,sal_Bool bDispose,
|
|
|
|
|
sal_Int32 _nCommandType,Reference<XConnection>& _xSrcConnection,
|
|
|
|
|
const Reference<XPropertySet>& xSourceObject,
|
|
|
|
|
Reference<XStatement> &xStmt,Reference<XPreparedStatement> &xPrepStmt)
|
|
|
|
|
{
|
|
|
|
|
Reference<XResultSet> xSrcRs;
|
|
|
|
|
::rtl::OUString sSql;
|
|
|
|
|
if(_nCommandType == CommandType::TABLE)
|
|
|
|
|
{
|
|
|
|
|
sSql = ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("SELECT "));
|
|
|
|
|
// we need to create the sql stmt with column names
|
|
|
|
|
// otherwise it is possible that names don't match
|
|
|
|
|
::rtl::OUString sQuote = _xSrcConnection->getMetaData()->getIdentifierQuoteString();
|
|
|
|
|
static ::rtl::OUString sComma = ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM(","));
|
|
|
|
|
|
|
|
|
|
Reference<XColumnsSupplier> xSrcColsSup(xSourceObject,UNO_QUERY);
|
|
|
|
|
OSL_ENSURE(xSrcColsSup.is(),"No source columns!");
|
|
|
|
|
Reference<XNameAccess> xNameAccess = xSrcColsSup->getColumns();
|
|
|
|
|
Sequence< ::rtl::OUString> aSeq = xNameAccess->getElementNames();
|
|
|
|
|
const ::rtl::OUString* pBegin = aSeq.getConstArray();
|
|
|
|
|
const ::rtl::OUString* pEnd = pBegin + aSeq.getLength();
|
|
|
|
|
for(;pBegin != pEnd;++pBegin)
|
|
|
|
|
{
|
|
|
|
|
sSql += ::dbtools::quoteName( sQuote,*pBegin);
|
|
|
|
|
sSql += sComma;
|
|
|
|
|
}
|
|
|
|
|
sSql = sSql.replaceAt(sSql.getLength()-1,1,::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM(" ")));
|
|
|
|
|
sSql += ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("FROM "));
|
|
|
|
|
::rtl::OUString sComposedName;
|
|
|
|
|
::dbaui::composeTableName(_xSrcConnection->getMetaData(),xSourceObject,sComposedName,sal_True);
|
|
|
|
|
sSql += sComposedName;
|
|
|
|
|
xStmt = _xSrcConnection->createStatement();
|
|
|
|
|
if( xStmt.is() )
|
|
|
|
|
xSrcRs = xStmt->executeQuery(sSql);
|
|
|
|
|
}
|
|
|
|
|
else
|
|
|
|
|
{
|
|
|
|
|
xSourceObject->getPropertyValue(PROPERTY_COMMAND) >>= sSql;
|
|
|
|
|
xPrepStmt = _xSrcConnection->prepareStatement(sSql);
|
|
|
|
|
if( xPrepStmt.is() )
|
|
|
|
|
{
|
|
|
|
|
// look if we have to fill in some parameters
|
|
|
|
|
// create and fill a composer
|
|
|
|
|
Reference< XSQLQueryComposerFactory > xFactory(_xSrcConnection, UNO_QUERY);
|
|
|
|
|
Reference< XSQLQueryComposer> xComposer;
|
|
|
|
|
if (xFactory.is())
|
|
|
|
|
{
|
|
|
|
|
try
|
|
|
|
|
{
|
|
|
|
|
xComposer = xFactory->createQueryComposer();
|
|
|
|
|
if(xComposer.is())
|
|
|
|
|
{
|
|
|
|
|
xComposer->setQuery(sSql);
|
|
|
|
|
Reference< XInteractionHandler > xHandler(_pBrowser->getORB()->createInstance(::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("com.sun.star.sdb.InteractionHandler"))), UNO_QUERY);
|
|
|
|
|
::dbtools::askForParameters(xComposer,Reference<XParameters>(xPrepStmt,UNO_QUERY),_xSrcConnection,xHandler);
|
|
|
|
|
xSrcRs = xPrepStmt->executeQuery();
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
catch(SQLContext&)
|
|
|
|
|
{
|
|
|
|
|
if(bDispose)
|
|
|
|
|
::comphelper::disposeComponent(_xSrcConnection);
|
|
|
|
|
throw;
|
|
|
|
|
}
|
|
|
|
|
catch(SQLWarning&)
|
|
|
|
|
{
|
|
|
|
|
if(bDispose)
|
|
|
|
|
::comphelper::disposeComponent(_xSrcConnection);
|
|
|
|
|
throw;
|
|
|
|
|
}
|
|
|
|
|
catch(SQLException&)
|
|
|
|
|
{
|
|
|
|
|
if(bDispose)
|
|
|
|
|
::comphelper::disposeComponent(_xSrcConnection);
|
|
|
|
|
throw;
|
|
|
|
|
}
|
|
|
|
|
catch (Exception&)
|
|
|
|
|
{
|
|
|
|
|
xComposer = NULL;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
return xSrcRs;
|
|
|
|
|
}
|
|
|
|
|
|
2001-03-23 09:59:09 +00:00
|
|
|
// -----------------------------------------------------------------------------
|
|
|
|
|
void SbaTableQueryBrowser::implPasteQuery( SvLBoxEntry* _pApplyTo, const TransferableDataHelper& _rPasteData )
|
|
|
|
|
{
|
2001-06-22 09:58:46 +00:00
|
|
|
DBG_ASSERT(etQueryContainer == getEntryType(_pApplyTo) || etQuery == getEntryType(_pApplyTo), "SbaTableQueryBrowser::implPasteQuery: invalid target entry!");
|
2001-03-23 09:59:09 +00:00
|
|
|
try
|
|
|
|
|
{
|
|
|
|
|
sal_Bool bQueryDescriptor = _rPasteData.HasFormat(SOT_FORMATSTR_ID_DBACCESS_QUERY);
|
|
|
|
|
sal_Bool bCommandDescriptor = _rPasteData.HasFormat(SOT_FORMATSTR_ID_DBACCESS_COMMAND);
|
|
|
|
|
if (bQueryDescriptor || bCommandDescriptor)
|
|
|
|
|
{
|
|
|
|
|
DataFlavor aFlavor;
|
|
|
|
|
SotExchange::GetFormatDataFlavor(bQueryDescriptor ? SOT_FORMATSTR_ID_DBACCESS_QUERY : SOT_FORMATSTR_ID_DBACCESS_COMMAND, aFlavor);
|
|
|
|
|
Sequence<PropertyValue> aDescriptor;
|
|
|
|
|
#ifdef DBG_UTIL
|
|
|
|
|
sal_Bool bCorrectFormat =
|
|
|
|
|
#endif
|
|
|
|
|
_rPasteData.GetAny(aFlavor) >>= aDescriptor;
|
|
|
|
|
DBG_ASSERT(bCorrectFormat, "SbaTableQueryBrowser::implPasteQuery: invalid DnD or clipboard format!");
|
|
|
|
|
|
|
|
|
|
::rtl::OUString sDataSourceName;
|
|
|
|
|
sal_Int32 nCommandType = CommandType::QUERY;
|
|
|
|
|
::rtl::OUString sCommand;
|
|
|
|
|
sal_Bool bEscapeProcessing = sal_True;
|
2001-04-11 11:58:38 +00:00
|
|
|
{
|
2002-03-21 06:22:52 +00:00
|
|
|
ODataAccessDescriptor aDesc(aDescriptor);
|
2002-03-27 07:18:45 +00:00
|
|
|
aDesc[daDataSource] >>= sDataSourceName;
|
2002-03-21 06:22:52 +00:00
|
|
|
aDesc[daCommandType] >>= nCommandType;
|
2002-03-27 07:18:45 +00:00
|
|
|
aDesc[daCommand] >>= sCommand;
|
2002-03-21 06:22:52 +00:00
|
|
|
aDesc[daEscapeProcessing] >>= bEscapeProcessing;
|
2001-04-11 11:58:38 +00:00
|
|
|
}
|
2001-03-23 09:59:09 +00:00
|
|
|
|
|
|
|
|
// plausibility check
|
|
|
|
|
sal_Bool bValidDescriptor = sal_False;
|
|
|
|
|
if (CommandType::QUERY == nCommandType)
|
|
|
|
|
bValidDescriptor = sDataSourceName.getLength() && sCommand.getLength();
|
|
|
|
|
else if (CommandType::COMMAND == nCommandType)
|
|
|
|
|
bValidDescriptor = (0 != sCommand.getLength());
|
|
|
|
|
if (!bValidDescriptor)
|
|
|
|
|
{
|
|
|
|
|
DBG_ERROR("SbaTableQueryBrowser::implPasteQuery: invalid descriptor!");
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// three properties we can set only if we have a query object as source
|
|
|
|
|
::rtl::OUString sUpdateTableName;
|
|
|
|
|
::rtl::OUString sUpdateSchemaName;
|
|
|
|
|
::rtl::OUString sUpdateCatalogName;
|
|
|
|
|
|
|
|
|
|
// the target object name (as we'll suggest it to the user)
|
|
|
|
|
String sTargetName;
|
|
|
|
|
if (CommandType::QUERY == nCommandType)
|
|
|
|
|
sTargetName = sCommand;
|
|
|
|
|
|
|
|
|
|
if (CommandType::QUERY == nCommandType)
|
|
|
|
|
{
|
|
|
|
|
// need to extract the statement and the escape processing flag from the query object
|
|
|
|
|
sal_Bool bSuccess = sal_False;
|
|
|
|
|
try
|
|
|
|
|
{
|
|
|
|
|
// the data source to extract the query from
|
|
|
|
|
Reference< XQueryDefinitionsSupplier > xSourceDSQuerySupp;
|
|
|
|
|
m_xDatabaseContext->getByName(sDataSourceName) >>= xSourceDSQuerySupp;
|
|
|
|
|
|
|
|
|
|
// the query container
|
|
|
|
|
Reference< XNameAccess > xQueries;
|
|
|
|
|
if (xSourceDSQuerySupp.is())
|
|
|
|
|
xQueries = xSourceDSQuerySupp->getQueryDefinitions();
|
|
|
|
|
|
|
|
|
|
// the concrete query
|
|
|
|
|
Reference< XPropertySet > xQuery;
|
|
|
|
|
if (xQueries.is())
|
|
|
|
|
xQueries->getByName(sCommand) >>= xQuery;
|
|
|
|
|
|
|
|
|
|
if (xQuery.is())
|
|
|
|
|
{
|
|
|
|
|
// extract all the properties we're interested in
|
|
|
|
|
xQuery->getPropertyValue(PROPERTY_COMMAND) >>= sCommand;
|
|
|
|
|
bEscapeProcessing = ::cppu::any2bool(xQuery->getPropertyValue(PROPERTY_USE_ESCAPE_PROCESSING));
|
|
|
|
|
|
|
|
|
|
xQuery->getPropertyValue(PROPERTY_UPDATE_TABLENAME) >>= sUpdateTableName;
|
|
|
|
|
xQuery->getPropertyValue(PROPERTY_UPDATE_SCHEMANAME) >>= sUpdateSchemaName;
|
|
|
|
|
xQuery->getPropertyValue(PROPERTY_UPDATE_CATALOGNAME) >>= sUpdateCatalogName;
|
|
|
|
|
bSuccess = sal_True;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
catch(SQLException&) { throw; } // caught and handled by the outer catch
|
|
|
|
|
catch(Exception&) { }
|
|
|
|
|
|
|
|
|
|
if (!bSuccess)
|
|
|
|
|
{
|
|
|
|
|
DBG_ERROR("SbaTableQueryBrowser::implPasteQuery: could not extract the source query object!");
|
|
|
|
|
// TODO: maybe this is worth an error message to be displayed to the user ....
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// get the queries container of the destination data source
|
|
|
|
|
if (!ensureEntryObject(_pApplyTo))
|
|
|
|
|
// this is a heavy error ... the name container for the queries could not ne obtained
|
|
|
|
|
return;
|
|
|
|
|
|
2001-06-22 09:58:46 +00:00
|
|
|
// check if the entry is a container else get the parent
|
|
|
|
|
DBTreeListModel::DBTreeListUserData* pQueriesData = NULL;
|
|
|
|
|
if(!isContainer(_pApplyTo))
|
|
|
|
|
pQueriesData = static_cast<DBTreeListModel::DBTreeListUserData*>(m_pTreeView->getListBox()->GetParent(_pApplyTo)->GetUserData());
|
|
|
|
|
else
|
|
|
|
|
pQueriesData = static_cast<DBTreeListModel::DBTreeListUserData*>(_pApplyTo->GetUserData());
|
|
|
|
|
|
2001-03-23 09:59:09 +00:00
|
|
|
Reference< XNameContainer > xDestQueries(pQueriesData->xObject, UNO_QUERY);
|
|
|
|
|
Reference< XSingleServiceFactory > xQueryFactory(xDestQueries, UNO_QUERY);
|
|
|
|
|
if (!xQueryFactory.is())
|
|
|
|
|
{
|
|
|
|
|
DBG_ERROR("SbaTableQueryBrowser::implPasteQuery: invalid destination query container!");
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// here we have everything needed to create a new query object ...
|
|
|
|
|
// ... ehm, except a new name
|
|
|
|
|
OSaveAsDlg aAskForName(getView(), CommandType::QUERY, xDestQueries.get(), Reference< XDatabaseMetaData>(), sTargetName, SAD_ADDITIONAL_DESCRIPTION | SAD_TITLE_PASTE_AS);
|
|
|
|
|
if (RET_OK != aAskForName.Execute())
|
|
|
|
|
// cancelled by the user
|
|
|
|
|
return;
|
|
|
|
|
|
|
|
|
|
sTargetName = aAskForName.getName();
|
|
|
|
|
|
|
|
|
|
// create a new object
|
|
|
|
|
Reference< XPropertySet > xNewQuery(xQueryFactory->createInstance(), UNO_QUERY);
|
|
|
|
|
DBG_ASSERT(xNewQuery.is(), "SbaTableQueryBrowser::implPasteQuery: invalid object created by factory!");
|
|
|
|
|
if (xNewQuery.is())
|
|
|
|
|
{
|
|
|
|
|
// initialize
|
|
|
|
|
xNewQuery->setPropertyValue( PROPERTY_COMMAND, makeAny(sCommand) );
|
|
|
|
|
xNewQuery->setPropertyValue( PROPERTY_USE_ESCAPE_PROCESSING, ::cppu::bool2any(bEscapeProcessing) );
|
|
|
|
|
xNewQuery->setPropertyValue( PROPERTY_UPDATE_TABLENAME, makeAny(sUpdateTableName) );
|
|
|
|
|
xNewQuery->setPropertyValue( PROPERTY_UPDATE_SCHEMANAME, makeAny(sUpdateSchemaName) );
|
|
|
|
|
xNewQuery->setPropertyValue( PROPERTY_UPDATE_CATALOGNAME, makeAny(sUpdateCatalogName) );
|
|
|
|
|
// insert
|
|
|
|
|
xDestQueries->insertByName( sTargetName, makeAny(xNewQuery) );
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
catch(SQLContext& e) { showError(SQLExceptionInfo(e)); }
|
|
|
|
|
catch(SQLWarning& e) { showError(SQLExceptionInfo(e)); }
|
|
|
|
|
catch(SQLException& e) { showError(SQLExceptionInfo(e)); }
|
|
|
|
|
catch(Exception& )
|
|
|
|
|
{
|
|
|
|
|
DBG_ERROR("SbaTableQueryBrowser::implPasteQuery: caught a strange exception!");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// -----------------------------------------------------------------------------
|
|
|
|
|
void SbaTableQueryBrowser::implPasteTable( SvLBoxEntry* _pApplyTo, const TransferableDataHelper& _rPasteData )
|
|
|
|
|
{
|
|
|
|
|
try
|
|
|
|
|
{
|
|
|
|
|
// paste into the tables
|
|
|
|
|
sal_Bool bTableDescriptor = _rPasteData.HasFormat(SOT_FORMATSTR_ID_DBACCESS_TABLE);
|
|
|
|
|
sal_Bool bQueryDescriptor = _rPasteData.HasFormat(SOT_FORMATSTR_ID_DBACCESS_QUERY);
|
|
|
|
|
OSL_ENSURE(!bTableDescriptor || !bQueryDescriptor, "SbaTableQueryBrowser::implPasteTable: suspicious formats (both a table and a query descriptor)!");
|
|
|
|
|
if (bTableDescriptor || bQueryDescriptor)
|
|
|
|
|
{
|
|
|
|
|
DataFlavor aFlavor;
|
|
|
|
|
SotExchange::GetFormatDataFlavor(bTableDescriptor ? SOT_FORMATSTR_ID_DBACCESS_TABLE : SOT_FORMATSTR_ID_DBACCESS_QUERY, aFlavor);
|
|
|
|
|
Sequence<PropertyValue> aSeq;
|
|
|
|
|
#ifdef DBG_UTIL
|
|
|
|
|
sal_Bool bCorrectFormat =
|
|
|
|
|
#endif
|
|
|
|
|
_rPasteData.GetAny(aFlavor) >>= aSeq;
|
|
|
|
|
DBG_ASSERT(bCorrectFormat, "SbaTableQueryBrowser::implPasteTable: invalid DnD or clipboard format!");
|
|
|
|
|
|
|
|
|
|
if(aSeq.getLength())
|
|
|
|
|
{
|
2001-04-26 10:36:16 +00:00
|
|
|
::rtl::OUString aDSName = GetEntryText( m_pTreeView->getListBox()->GetRootLevelParent( _pApplyTo ) );
|
2001-03-23 09:59:09 +00:00
|
|
|
|
|
|
|
|
const PropertyValue* pBegin = aSeq.getConstArray();
|
|
|
|
|
const PropertyValue* pEnd = pBegin + aSeq.getLength();
|
|
|
|
|
|
|
|
|
|
// first get the dest connection
|
|
|
|
|
Reference<XConnection> xDestConnection; // supports the service sdb::connection
|
|
|
|
|
if(!ensureConnection(_pApplyTo, xDestConnection))
|
|
|
|
|
return;
|
|
|
|
|
|
2002-03-21 06:22:52 +00:00
|
|
|
// ask the descriptor for the needed properties
|
|
|
|
|
Reference<XConnection> xSrcConnection; // the source connection
|
|
|
|
|
Reference<XResultSet> xSrcRs; // the source resultset may be empty
|
2001-03-23 09:59:09 +00:00
|
|
|
sal_Int32 nCommandType = CommandType::TABLE;
|
2002-03-21 06:22:52 +00:00
|
|
|
::rtl::OUString sCommand,
|
|
|
|
|
sSrcDataSourceName;
|
|
|
|
|
Sequence< Any > aSelection;
|
2001-03-23 09:59:09 +00:00
|
|
|
{
|
2002-03-21 06:22:52 +00:00
|
|
|
ODataAccessDescriptor aDesc(aSeq);
|
|
|
|
|
aDesc[daDataSource] >>= sSrcDataSourceName;
|
|
|
|
|
aDesc[daCommandType] >>= nCommandType;
|
|
|
|
|
aDesc[daCommand] >>= sCommand;
|
|
|
|
|
aDesc[daConnection] >>= xSrcConnection;
|
|
|
|
|
aDesc[daSelection] >>= aSelection;
|
|
|
|
|
aDesc[daCursor] >>= xSrcRs;
|
2001-03-23 09:59:09 +00:00
|
|
|
}
|
|
|
|
|
|
2002-03-21 06:22:52 +00:00
|
|
|
// check if the source connection is valid
|
2001-03-23 09:59:09 +00:00
|
|
|
sal_Bool bDispose = sal_False;
|
|
|
|
|
if(sSrcDataSourceName == aDSName)
|
|
|
|
|
xSrcConnection = xDestConnection;
|
|
|
|
|
else if(!xSrcConnection.is())
|
|
|
|
|
{
|
2001-03-30 12:42:02 +00:00
|
|
|
Reference< XEventListener> xEvt(static_cast< ::cppu::OWeakObject*>(this), UNO_QUERY);
|
2001-03-23 09:59:09 +00:00
|
|
|
showError(::dbaui::createConnection(sSrcDataSourceName,m_xDatabaseContext,getORB(),xEvt,xSrcConnection));
|
|
|
|
|
bDispose = sal_True;
|
|
|
|
|
}
|
2002-03-21 06:22:52 +00:00
|
|
|
// we need the right container for our type of command
|
2001-03-23 09:59:09 +00:00
|
|
|
Reference<XNameAccess> xNameAccess;
|
|
|
|
|
switch(nCommandType)
|
|
|
|
|
{
|
|
|
|
|
case CommandType::TABLE:
|
|
|
|
|
{
|
|
|
|
|
// only for tables
|
|
|
|
|
Reference<XTablesSupplier> xSup(xSrcConnection,UNO_QUERY);
|
|
|
|
|
if(xSup.is())
|
|
|
|
|
xNameAccess = xSup->getTables();
|
|
|
|
|
}
|
|
|
|
|
break;
|
|
|
|
|
case CommandType::QUERY:
|
|
|
|
|
{
|
|
|
|
|
Reference<XQueriesSupplier> xSup(xSrcConnection,UNO_QUERY);
|
|
|
|
|
if(xSup.is())
|
|
|
|
|
xNameAccess = xSup->getQueries();
|
|
|
|
|
}
|
|
|
|
|
break;
|
2002-03-21 06:22:52 +00:00
|
|
|
default:
|
|
|
|
|
OSL_ENSURE(0,"UNsupported command type found!");
|
2001-03-23 09:59:09 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// check if this name really exists in the name access
|
2002-03-21 06:22:52 +00:00
|
|
|
if ( xNameAccess.is() && xNameAccess->hasByName( sCommand ) )
|
2001-03-23 09:59:09 +00:00
|
|
|
{
|
|
|
|
|
Reference<XPropertySet> xSourceObject;
|
2002-03-21 06:22:52 +00:00
|
|
|
xNameAccess->getByName( sCommand ) >>= xSourceObject;
|
2001-03-23 09:59:09 +00:00
|
|
|
OCopyTableWizard aWizard(getView(),
|
|
|
|
|
xSourceObject,
|
2001-11-15 14:15:05 +00:00
|
|
|
xSrcConnection,
|
2001-03-23 09:59:09 +00:00
|
|
|
xDestConnection,
|
|
|
|
|
getNumberFormatter(),
|
|
|
|
|
getORB());
|
|
|
|
|
OCopyTable* pPage1 = new OCopyTable(&aWizard,COPY, sal_False,OCopyTableWizard::WIZARD_DEF_DATA);
|
|
|
|
|
OWizNameMatching* pPage2 = new OWizNameMatching(&aWizard);
|
|
|
|
|
OWizColumnSelect* pPage3 = new OWizColumnSelect(&aWizard);
|
|
|
|
|
OWizNormalExtend* pPage4 = new OWizNormalExtend(&aWizard);
|
|
|
|
|
|
|
|
|
|
aWizard.AddWizardPage(pPage1);
|
|
|
|
|
aWizard.AddWizardPage(pPage2);
|
|
|
|
|
aWizard.AddWizardPage(pPage3);
|
|
|
|
|
aWizard.AddWizardPage(pPage4);
|
|
|
|
|
aWizard.ActivatePage();
|
|
|
|
|
|
2001-07-26 13:12:01 +00:00
|
|
|
if (aWizard.Execute() == RET_OK)
|
2001-03-23 09:59:09 +00:00
|
|
|
{
|
|
|
|
|
Reference<XPropertySet> xTable;
|
2001-07-02 12:22:11 +00:00
|
|
|
switch(aWizard.getCreateStyle())
|
2001-03-23 09:59:09 +00:00
|
|
|
{
|
|
|
|
|
case OCopyTableWizard::WIZARD_DEF:
|
|
|
|
|
case OCopyTableWizard::WIZARD_DEF_DATA:
|
|
|
|
|
{
|
|
|
|
|
xTable = aWizard.createTable();
|
|
|
|
|
if(!xTable.is())
|
|
|
|
|
break;
|
2001-07-02 12:22:11 +00:00
|
|
|
if(OCopyTableWizard::WIZARD_DEF == aWizard.getCreateStyle())
|
2001-03-23 09:59:09 +00:00
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
case OCopyTableWizard::WIZARD_APPEND_DATA:
|
|
|
|
|
{
|
2001-07-30 05:20:24 +00:00
|
|
|
if(!xTable.is())
|
|
|
|
|
xTable = aWizard.createTable();
|
2001-07-26 13:12:01 +00:00
|
|
|
if(!xTable.is())
|
|
|
|
|
break;
|
|
|
|
|
|
2001-06-22 09:58:46 +00:00
|
|
|
Reference<XStatement> xStmt; // needed to hold a reference to the statement
|
|
|
|
|
Reference<XPreparedStatement> xPrepStmt;// needed to hold a reference to the statement
|
2002-03-21 06:22:52 +00:00
|
|
|
::rtl::OUString sDestName;
|
2001-03-23 09:59:09 +00:00
|
|
|
::dbaui::composeTableName(xDestConnection->getMetaData(),xTable,sDestName,sal_False);
|
2002-03-27 07:18:45 +00:00
|
|
|
|
|
|
|
|
::std::vector<sal_Int32> aColumnMapping = aWizard.GetColumnPositions();
|
2001-03-23 09:59:09 +00:00
|
|
|
// create the sql stmt
|
2002-03-21 06:22:52 +00:00
|
|
|
if ( !xSrcRs.is() ) // if not already exists
|
|
|
|
|
xSrcRs = createResultSet(this,
|
|
|
|
|
bDispose,
|
|
|
|
|
nCommandType,
|
|
|
|
|
xSrcConnection,
|
|
|
|
|
xSourceObject,
|
|
|
|
|
xStmt,
|
|
|
|
|
xPrepStmt);
|
2002-03-27 07:18:45 +00:00
|
|
|
else
|
|
|
|
|
{
|
|
|
|
|
// here I use the ResultSet directly so I have to adjust
|
|
|
|
|
// the column mapping given by the wizard, because the resultset could use
|
|
|
|
|
// another order of the columns
|
|
|
|
|
Reference< XColumnLocate> xLocate(xSrcRs,UNO_QUERY);
|
|
|
|
|
Reference<XColumnsSupplier> xSrcColsSup(xSourceObject,UNO_QUERY);
|
|
|
|
|
OSL_ENSURE(xSrcColsSup.is(),"No source columns!");
|
|
|
|
|
Reference<XNameAccess> xNameAccess = xSrcColsSup->getColumns();
|
|
|
|
|
Sequence< ::rtl::OUString> aSeq = xNameAccess->getElementNames();
|
|
|
|
|
const ::rtl::OUString* pBegin = aSeq.getConstArray();
|
|
|
|
|
const ::rtl::OUString* pEnd = pBegin + aSeq.getLength();
|
|
|
|
|
|
|
|
|
|
::std::vector<sal_Int32> aNewColMapping;
|
|
|
|
|
aNewColMapping.resize( aColumnMapping.size() ,CONTAINER_ENTRY_NOTFOUND);
|
|
|
|
|
|
|
|
|
|
for(sal_Int32 k = 0;pBegin != pEnd;++pBegin,++k)
|
|
|
|
|
{
|
|
|
|
|
sal_Int32 nColPos = xLocate->findColumn(*pBegin) -1;
|
|
|
|
|
if ( nColPos >= 0 )
|
|
|
|
|
// aNewColMapping[k] = aColumnMapping[nColPos];
|
|
|
|
|
aNewColMapping[nColPos] = aColumnMapping[k];
|
|
|
|
|
}
|
|
|
|
|
aColumnMapping = aNewColMapping;
|
|
|
|
|
// position the resultset before the first row
|
|
|
|
|
if ( !xSrcRs->isBeforeFirst() )
|
|
|
|
|
xSrcRs->beforeFirst();
|
|
|
|
|
}
|
2001-06-01 10:23:46 +00:00
|
|
|
// now insert the rows into the new table
|
|
|
|
|
// we couldn't use the rowset here because it could happen that we haven't a primary key
|
2002-03-21 06:22:52 +00:00
|
|
|
insertRows( xSrcRs,
|
2002-03-27 07:18:45 +00:00
|
|
|
aColumnMapping,
|
2002-03-21 06:22:52 +00:00
|
|
|
xTable,
|
|
|
|
|
xDestConnection->getMetaData(),
|
2002-03-27 07:18:45 +00:00
|
|
|
aWizard.SetAutoincrement(),
|
2002-03-21 06:22:52 +00:00
|
|
|
aSelection);
|
2001-03-23 09:59:09 +00:00
|
|
|
}
|
|
|
|
|
break;
|
2001-03-30 07:47:18 +00:00
|
|
|
case OCopyTableWizard::WIZARD_DEF_VIEW:
|
|
|
|
|
xTable = aWizard.createView();
|
|
|
|
|
break;
|
2001-03-23 09:59:09 +00:00
|
|
|
default:
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
if(bDispose)
|
|
|
|
|
::comphelper::disposeComponent(xSrcConnection);
|
|
|
|
|
}
|
|
|
|
|
}
|
2001-07-05 11:46:55 +00:00
|
|
|
else if(_rPasteData.HasFormat(SOT_FORMATSTR_ID_HTML) || _rPasteData.HasFormat(SOT_FORMATSTR_ID_HTML_SIMPLE) || _rPasteData.HasFormat(SOT_FORMAT_RTF))
|
2001-03-23 09:59:09 +00:00
|
|
|
{
|
|
|
|
|
// first get the dest connection
|
|
|
|
|
Reference<XConnection> xDestConnection; // supports the service sdb::connection
|
|
|
|
|
if(!ensureConnection(_pApplyTo, xDestConnection))
|
|
|
|
|
return;
|
|
|
|
|
|
|
|
|
|
SotStorageStreamRef aStream;
|
|
|
|
|
Reference<XEventListener> xEvt;
|
|
|
|
|
ODatabaseImportExport* pImport = NULL;
|
2001-07-05 11:19:25 +00:00
|
|
|
if(_rPasteData.HasFormat(SOT_FORMATSTR_ID_HTML) || _rPasteData.HasFormat(SOT_FORMATSTR_ID_HTML_SIMPLE))
|
2001-03-23 09:59:09 +00:00
|
|
|
{
|
2001-07-05 11:19:25 +00:00
|
|
|
const_cast<TransferableDataHelper&>(_rPasteData).GetSotStorageStream(_rPasteData.HasFormat(SOT_FORMATSTR_ID_HTML) ? SOT_FORMATSTR_ID_HTML : SOT_FORMATSTR_ID_HTML_SIMPLE,aStream);
|
2001-03-23 09:59:09 +00:00
|
|
|
// TODO: why are the GetXXX methods not const???
|
|
|
|
|
|
|
|
|
|
pImport = new OHTMLImportExport(xDestConnection,getNumberFormatter(),getORB());
|
|
|
|
|
}
|
|
|
|
|
else
|
|
|
|
|
{
|
|
|
|
|
const_cast<TransferableDataHelper&>(_rPasteData).GetSotStorageStream(SOT_FORMAT_RTF,aStream);
|
|
|
|
|
// TODO: why are the GetXXX methods not const???
|
|
|
|
|
pImport = new ORTFImportExport(xDestConnection,getNumberFormatter(),getORB());
|
|
|
|
|
}
|
|
|
|
|
xEvt = pImport;
|
|
|
|
|
SvStream* pStream = (SvStream*)(SotStorageStream*)aStream;
|
|
|
|
|
pImport->setStream(pStream);
|
2001-07-16 12:42:36 +00:00
|
|
|
if(!pImport->Read())
|
2002-03-21 06:22:52 +00:00
|
|
|
throw SQLException(String(ModuleRes(STR_NO_TABLE_FORMAT_INSIDE)),*this,::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("S1000")) ,0,Any());
|
2001-03-23 09:59:09 +00:00
|
|
|
}
|
|
|
|
|
else
|
|
|
|
|
DBG_ERROR("SbaTableQueryBrowser::implPasteTable: invalid call (no supported format found)!");
|
|
|
|
|
}
|
|
|
|
|
catch(SQLContext& e) { showError(SQLExceptionInfo(e)); }
|
|
|
|
|
catch(SQLWarning& e) { showError(SQLExceptionInfo(e)); }
|
|
|
|
|
catch(SQLException& e) { showError(SQLExceptionInfo(e)); }
|
|
|
|
|
catch(Exception& )
|
|
|
|
|
{
|
2001-04-03 13:16:03 +00:00
|
|
|
OSL_ENSURE(sal_False, "SbaTableQueryBrowser::implPasteTable: caught a generic exception!");
|
2001-03-23 09:59:09 +00:00
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// -----------------------------------------------------------------------------
|
|
|
|
|
TransferableHelper* SbaTableQueryBrowser::implCopyObject( SvLBoxEntry* _pApplyTo, sal_Int32 _nCommandType, sal_Bool _bAllowConnection )
|
|
|
|
|
{
|
|
|
|
|
try
|
|
|
|
|
{
|
|
|
|
|
::osl::MutexGuard aGuard(m_aEntryMutex);
|
|
|
|
|
Reference<XConnection> xConnection; // supports the service sdb::connection
|
|
|
|
|
if (_bAllowConnection && !ensureConnection(_pApplyTo, xConnection))
|
|
|
|
|
return NULL;
|
|
|
|
|
|
2001-04-26 10:36:16 +00:00
|
|
|
::rtl::OUString aName = GetEntryText( _pApplyTo );
|
|
|
|
|
::rtl::OUString aDSName = GetEntryText( m_pTreeView->getListBox()->GetRootLevelParent( _pApplyTo ) );
|
2001-03-23 09:59:09 +00:00
|
|
|
|
|
|
|
|
// the owner ship goes to ODataClipboard
|
2001-03-28 14:44:58 +00:00
|
|
|
ODataClipboard* pData = new ODataClipboard(aDSName, _nCommandType, aName, xConnection, getNumberFormatter(), getORB());
|
2001-03-23 09:59:09 +00:00
|
|
|
return pData;
|
|
|
|
|
}
|
|
|
|
|
catch(SQLException& e)
|
|
|
|
|
{
|
|
|
|
|
showError(SQLExceptionInfo(e));
|
|
|
|
|
}
|
|
|
|
|
catch(Exception&)
|
|
|
|
|
{
|
|
|
|
|
DBG_ERROR("SbaTableQueryBrowser::implCopyObject: caught a generic exception!");
|
|
|
|
|
}
|
|
|
|
|
return NULL;
|
|
|
|
|
}
|
2001-08-27 05:57:24 +00:00
|
|
|
/// unary_function Functor object for class ZZ returntype is void
|
|
|
|
|
struct DataFlavorExVectorSlotPrec : ::std::unary_function<DataFlavorExVector::value_type,bool>
|
|
|
|
|
{
|
|
|
|
|
SbaTableQueryBrowser::EntryType eEntryType;
|
|
|
|
|
sal_Bool bQueryDrop;
|
|
|
|
|
DataFlavorExVectorSlotPrec(const SbaTableQueryBrowser::EntryType &_eEntryType,sal_Bool _bQueryDrop)
|
|
|
|
|
: eEntryType(_eEntryType)
|
|
|
|
|
, bQueryDrop(_bQueryDrop)
|
|
|
|
|
{
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
inline bool operator()(const DataFlavorExVector::value_type& _aType)
|
|
|
|
|
{
|
|
|
|
|
switch (_aType.mnSotId)
|
|
|
|
|
{
|
|
|
|
|
case SOT_FORMAT_RTF: // RTF data descriptions
|
|
|
|
|
case SOT_FORMATSTR_ID_HTML: // HTML data descriptions
|
|
|
|
|
case SOT_FORMATSTR_ID_HTML_SIMPLE: // HTML data descriptions
|
|
|
|
|
case SOT_FORMATSTR_ID_DBACCESS_TABLE: // table descriptor
|
|
|
|
|
return (SbaTableQueryBrowser::etTableContainer == eEntryType);
|
|
|
|
|
break;
|
|
|
|
|
case SOT_FORMATSTR_ID_DBACCESS_QUERY: // query descriptor
|
|
|
|
|
case SOT_FORMATSTR_ID_DBACCESS_COMMAND: // SQL command
|
|
|
|
|
return ((SbaTableQueryBrowser::etQueryContainer == eEntryType) || ( !bQueryDrop && SbaTableQueryBrowser::etTableContainer == eEntryType));
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
return false;
|
|
|
|
|
}
|
|
|
|
|
};
|
|
|
|
|
|
2001-03-23 09:59:09 +00:00
|
|
|
|
|
|
|
|
// -----------------------------------------------------------------------------
|
|
|
|
|
sal_Int8 SbaTableQueryBrowser::queryDrop( const AcceptDropEvent& _rEvt, const DataFlavorExVector& _rFlavors )
|
|
|
|
|
{
|
|
|
|
|
// check if we're a table or query container
|
|
|
|
|
SvLBoxEntry* pHitEntry = m_pTreeView->getListBox()->GetEntry( _rEvt.maPosPixel );
|
|
|
|
|
|
2002-03-21 06:22:52 +00:00
|
|
|
if ( pHitEntry ) // no drop if no entry was hit ....
|
|
|
|
|
{
|
|
|
|
|
// it must be a container
|
|
|
|
|
EntryType eEntryType = getEntryType( pHitEntry );
|
|
|
|
|
if ( isContainer(eEntryType) )
|
|
|
|
|
{
|
|
|
|
|
// TODO: check if the data source is readonly
|
|
|
|
|
// check for the concrete type
|
|
|
|
|
if(::std::find_if(_rFlavors.begin(),_rFlavors.end(),DataFlavorExVectorSlotPrec(eEntryType,sal_True)) != _rFlavors.end())
|
|
|
|
|
return DND_ACTION_COPY;
|
|
|
|
|
}
|
|
|
|
|
}
|
2001-03-23 09:59:09 +00:00
|
|
|
|
|
|
|
|
return DND_ACTION_NONE;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// -----------------------------------------------------------------------------
|
|
|
|
|
IMPL_LINK( SbaTableQueryBrowser, OnAsyncDrop, void*, NOTINTERESTEDIN )
|
|
|
|
|
{
|
|
|
|
|
m_nAsyncDrop = 0;
|
|
|
|
|
|
|
|
|
|
if (m_aAsyncDrop.bTable)
|
|
|
|
|
implPasteTable(m_aAsyncDrop.pDroppedAt, m_aAsyncDrop.aDroppedData);
|
|
|
|
|
else
|
|
|
|
|
implPasteQuery(m_aAsyncDrop.pDroppedAt, m_aAsyncDrop.aDroppedData);
|
|
|
|
|
|
|
|
|
|
m_aAsyncDrop.aDroppedData = TransferableDataHelper();
|
|
|
|
|
m_aAsyncDrop.pDroppedAt = NULL;
|
|
|
|
|
|
|
|
|
|
return 0L;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// -----------------------------------------------------------------------------
|
|
|
|
|
sal_Int8 SbaTableQueryBrowser::executeDrop( const ExecuteDropEvent& _rEvt )
|
|
|
|
|
{
|
|
|
|
|
SvLBoxEntry* pHitEntry = m_pTreeView->getListBox()->GetEntry( _rEvt.maPosPixel );
|
|
|
|
|
EntryType eEntryType = getEntryType( pHitEntry );
|
|
|
|
|
if (!isContainer(eEntryType))
|
|
|
|
|
{
|
|
|
|
|
DBG_ERROR("SbaTableQueryBrowser::executeDrop: what the hell did queryDrop do?");
|
|
|
|
|
// queryDrop shoud not have allowed us to reach this situation ....
|
|
|
|
|
return DND_ACTION_NONE;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// a TransferableDataHelper for accessing the dropped data
|
|
|
|
|
TransferableDataHelper aDroppedData(_rEvt.maDropEvent.Transferable);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// reset the data of the previous async drop (if any)
|
|
|
|
|
if (m_nAsyncDrop)
|
|
|
|
|
Application::RemoveUserEvent(m_nAsyncDrop);
|
|
|
|
|
m_nAsyncDrop = 0;
|
|
|
|
|
m_aAsyncDrop.aDroppedData = TransferableDataHelper();
|
|
|
|
|
m_aAsyncDrop.pDroppedAt = NULL;
|
|
|
|
|
m_aAsyncDrop.bTable = sal_False;
|
|
|
|
|
|
|
|
|
|
// loop through the available formats and see what we can do ...
|
2001-08-27 05:57:24 +00:00
|
|
|
if(::std::find_if(aDroppedData.GetDataFlavorExVector().begin(),aDroppedData.GetDataFlavorExVector().end(),DataFlavorExVectorSlotPrec(eEntryType,sal_False)) != aDroppedData.GetDataFlavorExVector().end())
|
2001-03-23 09:59:09 +00:00
|
|
|
{
|
|
|
|
|
m_aAsyncDrop.aDroppedData = aDroppedData;
|
|
|
|
|
m_aAsyncDrop.pDroppedAt = pHitEntry;
|
2001-05-14 10:59:28 +00:00
|
|
|
m_aAsyncDrop.bTable = (etTableContainer == eEntryType);
|
2001-03-23 09:59:09 +00:00
|
|
|
|
|
|
|
|
m_nAsyncDrop = Application::PostUserEvent(LINK(this, SbaTableQueryBrowser, OnAsyncDrop));
|
|
|
|
|
return DND_ACTION_COPY;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return DND_ACTION_NONE;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// -----------------------------------------------------------------------------
|
|
|
|
|
sal_Bool SbaTableQueryBrowser::requestDrag( sal_Int8 _nAction, const Point& _rPosPixel )
|
|
|
|
|
{
|
|
|
|
|
// get the affected list entry
|
|
|
|
|
// ensure that the entry which the user clicked at is selected
|
|
|
|
|
SvLBoxEntry* pHitEntry = m_pTreeView->getListBox()->GetEntry( _rPosPixel );
|
|
|
|
|
if (!pHitEntry)
|
|
|
|
|
// no drag of no entry was hit ....
|
|
|
|
|
return sal_False;
|
|
|
|
|
|
|
|
|
|
// it must be a query/table
|
|
|
|
|
EntryType eEntryType = getEntryType( pHitEntry );
|
|
|
|
|
if (!isObject(eEntryType))
|
|
|
|
|
return DND_ACTION_NONE;
|
|
|
|
|
|
2001-06-07 11:53:46 +00:00
|
|
|
if (etBookmark == eEntryType)
|
|
|
|
|
return DND_ACTION_NONE;
|
|
|
|
|
|
2001-05-14 10:59:28 +00:00
|
|
|
TransferableHelper* pTransfer = implCopyObject( pHitEntry, (etTable == eEntryType || etView == eEntryType) ? CommandType::TABLE : CommandType::QUERY);
|
2001-03-23 09:59:09 +00:00
|
|
|
Reference< XTransferable> xEnsureDelete = pTransfer;
|
|
|
|
|
|
|
|
|
|
if (pTransfer)
|
|
|
|
|
pTransfer->StartDrag( m_pTreeView->getListBox(), DND_ACTION_COPY );
|
|
|
|
|
|
|
|
|
|
return NULL != pTransfer;
|
|
|
|
|
}
|
2001-04-06 12:48:34 +00:00
|
|
|
// -----------------------------------------------------------------------------
|
2001-07-17 09:31:50 +00:00
|
|
|
sal_Bool SbaTableQueryBrowser::isTableFormat() const
|
2001-04-06 12:48:34 +00:00
|
|
|
{
|
|
|
|
|
sal_Bool bTableFormat = sal_False;
|
2001-05-07 13:09:01 +00:00
|
|
|
TransferableDataHelper aTransferData(TransferableDataHelper::CreateFromSystemClipboard(getView()));
|
2001-04-06 12:48:34 +00:00
|
|
|
bTableFormat = aTransferData.HasFormat(SOT_FORMATSTR_ID_DBACCESS_TABLE)
|
|
|
|
|
|| aTransferData.HasFormat(SOT_FORMATSTR_ID_DBACCESS_QUERY)
|
|
|
|
|
|| aTransferData.HasFormat(SOT_FORMAT_RTF)
|
2001-07-05 11:46:55 +00:00
|
|
|
|| aTransferData.HasFormat(SOT_FORMATSTR_ID_HTML)
|
|
|
|
|
|| aTransferData.HasFormat(SOT_FORMATSTR_ID_HTML_SIMPLE);
|
2001-05-14 10:59:28 +00:00
|
|
|
|
2001-04-06 12:48:34 +00:00
|
|
|
return bTableFormat;
|
|
|
|
|
}
|
2001-06-01 10:23:46 +00:00
|
|
|
// -----------------------------------------------------------------------------
|
2001-07-18 10:34:19 +00:00
|
|
|
IMPL_LINK(SbaTableQueryBrowser, OnCutEntry, SvLBoxEntry*, _pEntry)
|
|
|
|
|
{
|
|
|
|
|
return 0;
|
|
|
|
|
}
|
|
|
|
|
// -----------------------------------------------------------------------------
|
|
|
|
|
IMPL_LINK(SbaTableQueryBrowser, OnCopyEntry, SvLBoxEntry*, _pEntry)
|
|
|
|
|
{
|
2002-03-21 06:22:52 +00:00
|
|
|
if( isEntryCopyAllowed(_pEntry) )
|
2001-07-18 10:34:19 +00:00
|
|
|
copyEntry(_pEntry);
|
|
|
|
|
return 0;
|
|
|
|
|
}
|
|
|
|
|
// -----------------------------------------------------------------------------
|
|
|
|
|
IMPL_LINK(SbaTableQueryBrowser, OnPasteEntry, SvLBoxEntry*, _pEntry)
|
|
|
|
|
{
|
2002-03-21 06:22:52 +00:00
|
|
|
if ( isEntryPasteAllowed(_pEntry) )
|
2001-07-18 10:34:19 +00:00
|
|
|
pasteEntry(_pEntry);
|
|
|
|
|
return 0;
|
|
|
|
|
}
|
|
|
|
|
// -----------------------------------------------------------------------------
|
2001-09-25 12:28:23 +00:00
|
|
|
IMPL_LINK(SbaTableQueryBrowser, OnEditingEntry, SvLBoxEntry*, _pEntry)
|
|
|
|
|
{
|
|
|
|
|
EntryType eType = getEntryType(_pEntry);
|
|
|
|
|
long nRet = 0;
|
|
|
|
|
switch(eType)
|
|
|
|
|
{
|
|
|
|
|
case etQuery:
|
|
|
|
|
case etView:
|
|
|
|
|
case etTable:
|
|
|
|
|
try
|
|
|
|
|
{
|
|
|
|
|
if(eType == etQuery || isConnectionWriteAble(_pEntry))
|
|
|
|
|
{
|
|
|
|
|
ensureObjectExists(_pEntry);
|
|
|
|
|
DBTreeListModel::DBTreeListUserData* pData = static_cast<DBTreeListModel::DBTreeListUserData*>(_pEntry->GetUserData());
|
|
|
|
|
if(pData && pData->xObject.is())
|
|
|
|
|
{
|
|
|
|
|
Reference<XRename> xRename(pData->xObject,UNO_QUERY);
|
|
|
|
|
if(xRename.is())
|
|
|
|
|
{
|
|
|
|
|
::rtl::OUString sName;
|
|
|
|
|
Reference<XPropertySet> xProp(pData->xObject,UNO_QUERY);
|
|
|
|
|
xProp->getPropertyValue(PROPERTY_NAME) >>= sName;
|
|
|
|
|
m_pTreeView->getListBox()->SetEntryText(_pEntry,sName);
|
|
|
|
|
nRet = 1;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
catch(const Exception&)
|
|
|
|
|
{
|
|
|
|
|
OSL_ENSURE(0,"Exception catched!");
|
|
|
|
|
}
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
return nRet;
|
|
|
|
|
}
|
|
|
|
|
// -----------------------------------------------------------------------------
|
|
|
|
|
IMPL_LINK(SbaTableQueryBrowser, OnEditedEntry, DBTreeEditedEntry*, _aEntry)
|
|
|
|
|
{
|
|
|
|
|
EntryType eType = getEntryType(_aEntry->pEntry);
|
|
|
|
|
::rtl::OUString sOldName;
|
|
|
|
|
long nRet = 0;
|
|
|
|
|
try
|
|
|
|
|
{
|
|
|
|
|
switch(eType)
|
|
|
|
|
{
|
|
|
|
|
case etView:
|
|
|
|
|
case etTable:
|
|
|
|
|
case etQuery:
|
|
|
|
|
if(etQuery == eType || isConnectionWriteAble(_aEntry->pEntry))
|
|
|
|
|
{
|
|
|
|
|
DBTreeListModel::DBTreeListUserData* pData = static_cast<DBTreeListModel::DBTreeListUserData*>(_aEntry->pEntry->GetUserData());
|
|
|
|
|
OSL_ENSURE(pData && pData->xObject.is(),"Error in editing!");
|
|
|
|
|
if(pData && pData->xObject.is())
|
|
|
|
|
{
|
|
|
|
|
::rtl::OUString sName,sSchema,sCatalog;
|
|
|
|
|
::rtl::OUString sNewName = _aEntry->aNewText;
|
|
|
|
|
Reference<XPropertySet> xProp(pData->xObject,UNO_QUERY);
|
|
|
|
|
xProp->getPropertyValue(PROPERTY_NAME) >>= sName;
|
|
|
|
|
Reference<XConnection> xConnection = getConnectionFromEntry(_aEntry->pEntry);
|
|
|
|
|
Reference<XDatabaseMetaData> xMeta = xConnection.is() ? xConnection->getMetaData() : Reference<XDatabaseMetaData>();
|
|
|
|
|
if(etQuery == eType)
|
|
|
|
|
sOldName = sName;
|
|
|
|
|
else
|
|
|
|
|
::dbaui::composeTableName(xMeta,xProp,sOldName,sal_False);
|
|
|
|
|
|
|
|
|
|
if((etQuery == eType || (xMeta.is() && xMeta->storesMixedCaseQuotedIdentifiers())) ? sName != sNewName : !sNewName.equalsIgnoreAsciiCase(sName))
|
|
|
|
|
{
|
|
|
|
|
Reference<XRename> xRename(pData->xObject,UNO_QUERY);
|
|
|
|
|
OSL_ENSURE(xRename.is(),"No Xrename interface!");
|
|
|
|
|
if(xRename.is())
|
|
|
|
|
{
|
|
|
|
|
xRename->rename(sNewName);
|
2002-04-02 05:45:52 +00:00
|
|
|
nRet = 1;
|
2001-09-25 12:28:23 +00:00
|
|
|
if(etQuery != eType)
|
|
|
|
|
{// special handling for tables and views
|
2002-04-02 05:45:52 +00:00
|
|
|
xProp->getPropertyValue(PROPERTY_SCHEMANAME) >>= sSchema;
|
2001-09-25 12:28:23 +00:00
|
|
|
xProp->getPropertyValue(PROPERTY_CATALOGNAME) >>= sCatalog;
|
|
|
|
|
::dbtools::composeTableName(xMeta,sCatalog,sSchema,sNewName,sName,sal_False);
|
|
|
|
|
sOldName = sName;
|
2001-11-12 09:34:55 +00:00
|
|
|
// now check if our datasource has set a tablefilter and if append the new table name to it
|
|
|
|
|
::dbaui::appendToFilter(xConnection,sOldName,getORB(),getView()); // we are not interessted in the return value
|
2001-09-25 12:28:23 +00:00
|
|
|
}
|
2001-11-12 09:34:55 +00:00
|
|
|
else
|
|
|
|
|
sOldName = sNewName;
|
|
|
|
|
|
2001-09-25 12:28:23 +00:00
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
catch(const SQLException& e)
|
|
|
|
|
{
|
|
|
|
|
showError(SQLExceptionInfo(e));
|
|
|
|
|
}
|
|
|
|
|
catch(const ElementExistException& e)
|
|
|
|
|
{
|
2002-03-21 06:22:52 +00:00
|
|
|
static ::rtl::OUString sStatus = ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("S1000"));
|
2001-09-25 12:28:23 +00:00
|
|
|
String sMsg = String(ModuleRes(STR_OBJECT_ALREADY_EXISTS));
|
|
|
|
|
sMsg.SearchAndReplace('#',e.Message);
|
|
|
|
|
showError(SQLExceptionInfo(SQLException(sMsg, e.Context, sStatus, 0, Any())));
|
|
|
|
|
}
|
|
|
|
|
catch(const Exception& )
|
|
|
|
|
{
|
|
|
|
|
OSL_ENSURE(0,"Exception catched!");
|
|
|
|
|
}
|
|
|
|
|
_aEntry->aNewText = sOldName;
|
|
|
|
|
|
|
|
|
|
return nRet;
|
|
|
|
|
}
|
|
|
|
|
// -----------------------------------------------------------------------------
|
2001-07-18 10:34:19 +00:00
|
|
|
IMPL_LINK(SbaTableQueryBrowser, OnDeleteEntry, SvLBoxEntry*, _pEntry)
|
|
|
|
|
{
|
|
|
|
|
EntryType eType = getEntryType(_pEntry);
|
|
|
|
|
switch(eType)
|
|
|
|
|
{
|
|
|
|
|
case etQuery:
|
|
|
|
|
implRemoveQuery(_pEntry);
|
|
|
|
|
break;
|
|
|
|
|
case etView:
|
|
|
|
|
case etTable:
|
|
|
|
|
{
|
|
|
|
|
// check if connection is readonly
|
2001-09-25 12:28:23 +00:00
|
|
|
if(isConnectionWriteAble(_pEntry))
|
2001-07-18 10:34:19 +00:00
|
|
|
implDropTable(_pEntry);
|
|
|
|
|
}
|
|
|
|
|
break;
|
|
|
|
|
case etBookmark:
|
|
|
|
|
{
|
|
|
|
|
// get the container of the bookmarks
|
|
|
|
|
SvLBoxEntry* pContainer = isContainer(_pEntry) ? _pEntry : m_pTreeView->getListBox()->GetParent(_pEntry);
|
|
|
|
|
if (!ensureEntryObject(pContainer))
|
|
|
|
|
break;
|
|
|
|
|
|
|
|
|
|
String sSelectedObject = GetEntryText(_pEntry);
|
|
|
|
|
|
|
|
|
|
DBTreeListModel::DBTreeListUserData* pContainerData = static_cast<DBTreeListModel::DBTreeListUserData*>(pContainer->GetUserData());
|
|
|
|
|
Reference< XNameAccess > xBookmarks(pContainerData->xObject, UNO_QUERY);
|
|
|
|
|
|
|
|
|
|
OLinkedDocumentsAccess aHelper(getView(), getORB(), xBookmarks);
|
|
|
|
|
aHelper.drop(sSelectedObject);
|
|
|
|
|
}
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
|
}
|
|
|
|
|
// -----------------------------------------------------------------------------
|
2002-04-02 05:45:52 +00:00
|
|
|
sal_Bool SbaTableQueryBrowser::isEntryCutAllowed(SvLBoxEntry* _pEntry)
|
2001-07-18 10:34:19 +00:00
|
|
|
{
|
|
|
|
|
// at the momoent this isn't allowed
|
|
|
|
|
return sal_False;
|
|
|
|
|
}
|
|
|
|
|
// -----------------------------------------------------------------------------
|
2002-04-02 05:45:52 +00:00
|
|
|
sal_Bool SbaTableQueryBrowser::isEntryCopyAllowed(SvLBoxEntry* _pEntry)
|
2001-07-18 10:34:19 +00:00
|
|
|
{
|
|
|
|
|
EntryType eType = getEntryType(_pEntry);
|
|
|
|
|
return (eType == etTable || eType == etQuery || eType == etView);
|
|
|
|
|
}
|
|
|
|
|
// -----------------------------------------------------------------------------
|
2002-04-02 05:45:52 +00:00
|
|
|
sal_Bool SbaTableQueryBrowser::isEntryPasteAllowed(SvLBoxEntry* _pEntry)
|
2001-07-18 10:34:19 +00:00
|
|
|
{
|
|
|
|
|
sal_Bool bAllowed = sal_False;
|
|
|
|
|
EntryType eType = getEntryType(_pEntry);
|
|
|
|
|
switch(eType)
|
|
|
|
|
{
|
|
|
|
|
case etQuery:
|
|
|
|
|
case etQueryContainer:
|
|
|
|
|
{
|
|
|
|
|
TransferableDataHelper aTransferData(TransferableDataHelper::CreateFromSystemClipboard(getView()));
|
|
|
|
|
bAllowed = aTransferData.HasFormat(SOT_FORMATSTR_ID_DBACCESS_QUERY);
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
case etView:
|
|
|
|
|
case etTable:
|
|
|
|
|
case etTableContainer:
|
|
|
|
|
{
|
|
|
|
|
// check if connection is readonly
|
2001-09-25 12:28:23 +00:00
|
|
|
bAllowed = isConnectionWriteAble(_pEntry) && isTableFormat();
|
2001-07-18 10:34:19 +00:00
|
|
|
}
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
return bAllowed;
|
|
|
|
|
}
|
|
|
|
|
// -----------------------------------------------------------------------------
|
|
|
|
|
void SbaTableQueryBrowser::cutEntry(SvLBoxEntry* _pEntry)
|
|
|
|
|
{
|
|
|
|
|
}
|
|
|
|
|
// -----------------------------------------------------------------------------
|
|
|
|
|
void SbaTableQueryBrowser::copyEntry(SvLBoxEntry* _pEntry)
|
|
|
|
|
{
|
|
|
|
|
TransferableHelper* pTransfer = NULL;
|
|
|
|
|
Reference< XTransferable> aEnsureDelete;
|
|
|
|
|
EntryType eType = getEntryType(_pEntry);
|
|
|
|
|
pTransfer = implCopyObject( _pEntry, eType == etQuery ? CommandType::QUERY : CommandType::TABLE);
|
|
|
|
|
aEnsureDelete = pTransfer;
|
|
|
|
|
if (pTransfer)
|
|
|
|
|
pTransfer->CopyToClipboard(getView());
|
|
|
|
|
}
|
|
|
|
|
// -----------------------------------------------------------------------------
|
|
|
|
|
void SbaTableQueryBrowser::pasteEntry(SvLBoxEntry* _pEntry)
|
|
|
|
|
{
|
|
|
|
|
TransferableDataHelper aTransferData(TransferableDataHelper::CreateFromSystemClipboard(getView()));
|
|
|
|
|
EntryType eType = getEntryType(_pEntry);
|
|
|
|
|
switch(eType)
|
|
|
|
|
{
|
|
|
|
|
case etQuery:
|
|
|
|
|
case etQueryContainer:
|
|
|
|
|
implPasteQuery(_pEntry, aTransferData);
|
|
|
|
|
break;
|
|
|
|
|
|
|
|
|
|
case etView:
|
|
|
|
|
case etTable:
|
|
|
|
|
case etTableContainer:
|
|
|
|
|
implPasteTable( _pEntry, aTransferData );
|
|
|
|
|
default:
|
|
|
|
|
;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
// -----------------------------------------------------------------------------
|
2001-09-25 12:28:23 +00:00
|
|
|
Reference<XConnection> SbaTableQueryBrowser::getConnectionFromEntry(SvLBoxEntry* _pEntry) const
|
|
|
|
|
{
|
|
|
|
|
DBTreeListModel::DBTreeListUserData* pDSData = NULL;
|
|
|
|
|
DBTreeListModel::DBTreeListUserData* pEntryData = NULL;
|
|
|
|
|
SvLBoxEntry* pDSEntry = NULL;
|
|
|
|
|
pDSEntry = m_pTreeView->getListBox()->GetRootLevelParent(_pEntry);
|
|
|
|
|
pDSData = pDSEntry
|
|
|
|
|
? static_cast<DBTreeListModel::DBTreeListUserData*>(pDSEntry->GetUserData())
|
|
|
|
|
: NULL;
|
|
|
|
|
|
|
|
|
|
sal_Bool bIsConnectionWriteAble = sal_False;
|
|
|
|
|
Reference<XConnection> xCon;
|
|
|
|
|
if(pDSData && pDSData->xObject.is())
|
|
|
|
|
xCon = Reference<XConnection>(pDSData->xObject,UNO_QUERY);
|
|
|
|
|
return xCon;
|
|
|
|
|
}
|
|
|
|
|
// -----------------------------------------------------------------------------
|
|
|
|
|
sal_Bool SbaTableQueryBrowser::isConnectionWriteAble(SvLBoxEntry* _pEntry) const
|
|
|
|
|
{
|
|
|
|
|
// check if connection is readonly
|
|
|
|
|
sal_Bool bIsConnectionWriteAble = sal_False;
|
|
|
|
|
Reference<XConnection> xCon = getConnectionFromEntry(_pEntry);
|
|
|
|
|
if(xCon.is())
|
2001-12-07 12:13:04 +00:00
|
|
|
{
|
|
|
|
|
try
|
|
|
|
|
{
|
|
|
|
|
bIsConnectionWriteAble = !xCon->getMetaData()->isReadOnly();
|
|
|
|
|
}
|
|
|
|
|
catch(SQLException&)
|
|
|
|
|
{
|
|
|
|
|
}
|
|
|
|
|
}
|
2001-09-25 12:28:23 +00:00
|
|
|
return bIsConnectionWriteAble;
|
|
|
|
|
}
|
2001-03-23 09:59:09 +00:00
|
|
|
// .........................................................................
|
|
|
|
|
} // namespace dbaui
|
|
|
|
|
// .........................................................................
|
|
|
|
|
|
|
|
|
|
/*************************************************************************
|
|
|
|
|
* history:
|
|
|
|
|
* $Log: not supported by cvs2svn $
|
2002-01-24 16:43:35 +00:00
|
|
|
* Revision 1.34 2001/12/07 13:13:04 oj
|
|
|
|
|
* #95728# insert try catch
|
|
|
|
|
*
|
2001-12-07 12:13:04 +00:00
|
|
|
* Revision 1.33 2001/11/23 14:51:40 oj
|
|
|
|
|
* #95142# check eState of parser
|
|
|
|
|
*
|
2001-11-23 13:51:40 +00:00
|
|
|
* Revision 1.32 2001/11/15 15:15:05 oj
|
|
|
|
|
* #94820# check type of dest database and adjust if possible
|
|
|
|
|
*
|
2001-11-15 14:15:05 +00:00
|
|
|
* Revision 1.31 2001/11/12 10:34:55 oj
|
|
|
|
|
* #94391# exclude tablefilter and enable schema name again
|
|
|
|
|
*
|
2001-11-12 09:34:55 +00:00
|
|
|
* Revision 1.30 2001/10/08 07:26:29 oj
|
|
|
|
|
* #92786# refcount implemented for connectiondata and sqlexception catched
|
|
|
|
|
*
|
2001-10-08 06:26:32 +00:00
|
|
|
* Revision 1.29 2001/09/25 13:24:38 oj
|
|
|
|
|
* #91719# implementing the XRename handling
|
|
|
|
|
*
|
2001-09-25 12:28:23 +00:00
|
|
|
* Revision 1.28 2001/09/20 12:56:17 oj
|
|
|
|
|
* #92232# fixes for BIGINT type and new property HELPTEXT
|
|
|
|
|
*
|
2001-09-20 11:59:25 +00:00
|
|
|
* Revision 1.27 2001/08/27 06:57:24 oj
|
|
|
|
|
* #90015# some speedup's
|
|
|
|
|
*
|
2001-08-27 05:57:24 +00:00
|
|
|
* Revision 1.26 2001/08/24 06:31:34 oj
|
|
|
|
|
* #90015# code corrcetions for some speedup's
|
|
|
|
|
*
|
2001-08-24 05:40:35 +00:00
|
|
|
* Revision 1.25 2001/07/30 06:20:24 oj
|
|
|
|
|
* #90291# check if table should be appended
|
|
|
|
|
*
|
2001-07-30 05:20:24 +00:00
|
|
|
* Revision 1.24 2001/07/26 14:12:01 oj
|
|
|
|
|
* #90291# check if table should be appended
|
|
|
|
|
*
|
2001-07-26 13:12:01 +00:00
|
|
|
* Revision 1.23 2001/07/19 09:27:12 oj
|
|
|
|
|
* #86186# check parsetree for joins
|
|
|
|
|
*
|
2001-07-19 08:29:22 +00:00
|
|
|
* Revision 1.22 2001/07/18 11:33:57 oj
|
|
|
|
|
* #85664# enable copy/cut/paste/delete keys
|
|
|
|
|
*
|
2001-07-18 10:34:19 +00:00
|
|
|
* Revision 1.21 2001/07/17 10:31:48 oj
|
|
|
|
|
* #89128# look if connection is readonly
|
|
|
|
|
*
|
2001-07-17 09:31:50 +00:00
|
|
|
* Revision 1.20 2001/07/16 13:40:03 oj
|
|
|
|
|
* #89650# check if table was created for html/rtf format
|
|
|
|
|
*
|
2001-07-16 12:42:36 +00:00
|
|
|
* Revision 1.19 2001/07/05 12:46:52 oj
|
|
|
|
|
* #87744# use HTML_SIMPLE
|
|
|
|
|
*
|
2001-07-05 11:46:55 +00:00
|
|
|
* Revision 1.18 2001/07/05 12:19:25 oj
|
|
|
|
|
* #87744# check for right HTML_TYPE
|
|
|
|
|
*
|
2001-07-05 11:19:25 +00:00
|
|
|
* Revision 1.17 2001/07/02 13:22:11 oj
|
|
|
|
|
* #88476# save name of object before recursive call
|
|
|
|
|
*
|
2001-07-02 12:22:11 +00:00
|
|
|
* Revision 1.16 2001/06/22 10:53:59 oj
|
|
|
|
|
* #88455# serveral fixes for parameters
|
|
|
|
|
*
|
2001-06-22 09:58:46 +00:00
|
|
|
* Revision 1.15 2001/06/12 13:19:24 fs
|
|
|
|
|
* #65293# linux ambiguity
|
|
|
|
|
*
|
2001-06-12 12:19:24 +00:00
|
|
|
* Revision 1.14 2001/06/07 12:53:46 fs
|
|
|
|
|
* #87905# don't DnD bookmarks
|
|
|
|
|
*
|
2001-06-07 11:53:46 +00:00
|
|
|
* Revision 1.13 2001/06/01 11:23:45 oj
|
|
|
|
|
* #86520# insert of tabledata corrected
|
|
|
|
|
*
|
2001-06-01 10:23:46 +00:00
|
|
|
* Revision 1.12 2001/05/14 11:58:35 oj
|
|
|
|
|
* #86744# some changes for entries and views
|
|
|
|
|
*
|
2001-05-14 10:59:28 +00:00
|
|
|
* Revision 1.11 2001/05/10 12:24:47 fs
|
|
|
|
|
* the clipboard changes are SUPD-dependent
|
|
|
|
|
*
|
2001-05-10 11:26:23 +00:00
|
|
|
* Revision 1.10 2001/05/07 14:09:00 fs
|
|
|
|
|
* MUST changes regarding the system clipboard access
|
|
|
|
|
*
|
2001-05-07 13:09:01 +00:00
|
|
|
* Revision 1.9 2001/04/26 11:36:16 fs
|
|
|
|
|
* added support for data source associated bookmarks
|
|
|
|
|
*
|
2001-04-26 10:36:16 +00:00
|
|
|
* Revision 1.8 2001/04/11 12:58:38 fs
|
|
|
|
|
* use the ODataAccessDescriptor instead of the dbatools functions
|
|
|
|
|
*
|
2001-04-11 11:58:38 +00:00
|
|
|
* Revision 1.7 2001/04/06 13:48:34 oj
|
|
|
|
|
* #85664# match copy/cut/paste with the right window
|
|
|
|
|
*
|
2001-04-06 12:48:34 +00:00
|
|
|
* Revision 1.6 2001/04/03 14:15:53 fs
|
|
|
|
|
* corrected some wrong OSL_ASSERTs
|
|
|
|
|
*
|
2001-04-03 13:16:03 +00:00
|
|
|
* Revision 1.5 2001/03/30 13:42:02 oj
|
|
|
|
|
* remove <:
|
|
|
|
|
*
|
2001-03-30 12:42:02 +00:00
|
|
|
* Revision 1.4 2001/03/30 08:47:18 oj
|
|
|
|
|
* correct the creation of views
|
|
|
|
|
*
|
2001-03-30 07:47:18 +00:00
|
|
|
* Revision 1.3 2001/03/28 15:44:58 fs
|
|
|
|
|
* changed the ctor of ODataClipboard
|
|
|
|
|
*
|
2001-03-28 14:44:58 +00:00
|
|
|
* Revision 1.2 2001/03/27 07:09:19 oj
|
|
|
|
|
* use of new initialize
|
|
|
|
|
*
|
2001-03-27 06:09:19 +00:00
|
|
|
* Revision 1.1 2001/03/23 10:59:09 fs
|
|
|
|
|
* initial checkin - DnD related implementations for the data source browser controller
|
|
|
|
|
*
|
2001-03-23 09:59:09 +00:00
|
|
|
*
|
|
|
|
|
* Revision 1.0 23.03.01 09:03:17 fs
|
|
|
|
|
************************************************************************/
|
