1*cdf0e10cSrcweir /************************************************************************* 2*cdf0e10cSrcweir * 3*cdf0e10cSrcweir * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. 4*cdf0e10cSrcweir * 5*cdf0e10cSrcweir * Copyright 2000, 2010 Oracle and/or its affiliates. 6*cdf0e10cSrcweir * 7*cdf0e10cSrcweir * OpenOffice.org - a multi-platform office productivity suite 8*cdf0e10cSrcweir * 9*cdf0e10cSrcweir * This file is part of OpenOffice.org. 10*cdf0e10cSrcweir * 11*cdf0e10cSrcweir * OpenOffice.org is free software: you can redistribute it and/or modify 12*cdf0e10cSrcweir * it under the terms of the GNU Lesser General Public License version 3 13*cdf0e10cSrcweir * only, as published by the Free Software Foundation. 14*cdf0e10cSrcweir * 15*cdf0e10cSrcweir * OpenOffice.org is distributed in the hope that it will be useful, 16*cdf0e10cSrcweir * but WITHOUT ANY WARRANTY; without even the implied warranty of 17*cdf0e10cSrcweir * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 18*cdf0e10cSrcweir * GNU Lesser General Public License version 3 for more details 19*cdf0e10cSrcweir * (a copy is included in the LICENSE file that accompanied this code). 20*cdf0e10cSrcweir * 21*cdf0e10cSrcweir * You should have received a copy of the GNU Lesser General Public License 22*cdf0e10cSrcweir * version 3 along with OpenOffice.org. If not, see 23*cdf0e10cSrcweir * <http://www.openoffice.org/license.html> 24*cdf0e10cSrcweir * for a copy of the LGPLv3 License. 25*cdf0e10cSrcweir * 26*cdf0e10cSrcweir ************************************************************************/ 27*cdf0e10cSrcweir 28*cdf0e10cSrcweir // MARKER(update_precomp.py): autogen include statement, do not remove 29*cdf0e10cSrcweir #include "precompiled_connectivity.hxx" 30*cdf0e10cSrcweir #include "ado/AColumns.hxx" 31*cdf0e10cSrcweir #include "ado/AColumn.hxx" 32*cdf0e10cSrcweir #include "ado/AConnection.hxx" 33*cdf0e10cSrcweir #include "ado/Awrapado.hxx" 34*cdf0e10cSrcweir #include <com/sun/star/sdbc/XRow.hpp> 35*cdf0e10cSrcweir #include <com/sun/star/sdbc/XResultSet.hpp> 36*cdf0e10cSrcweir #include <com/sun/star/sdbc/DataType.hpp> 37*cdf0e10cSrcweir #include <com/sun/star/sdbc/ColumnValue.hpp> 38*cdf0e10cSrcweir #include <comphelper/property.hxx> 39*cdf0e10cSrcweir #include <comphelper/types.hxx> 40*cdf0e10cSrcweir #include <connectivity/dbexception.hxx> 41*cdf0e10cSrcweir #ifdef __MINGW32__ 42*cdf0e10cSrcweir #include <algorithm> 43*cdf0e10cSrcweir #endif 44*cdf0e10cSrcweir #include "resource/ado_res.hrc" 45*cdf0e10cSrcweir 46*cdf0e10cSrcweir using namespace connectivity::ado; 47*cdf0e10cSrcweir using namespace connectivity; 48*cdf0e10cSrcweir using namespace comphelper; 49*cdf0e10cSrcweir using namespace com::sun::star::uno; 50*cdf0e10cSrcweir using namespace com::sun::star::lang; 51*cdf0e10cSrcweir using namespace com::sun::star::beans; 52*cdf0e10cSrcweir using namespace com::sun::star::sdbc; 53*cdf0e10cSrcweir using namespace com::sun::star::container; 54*cdf0e10cSrcweir 55*cdf0e10cSrcweir sdbcx::ObjectType OColumns::createObject(const ::rtl::OUString& _rName) 56*cdf0e10cSrcweir { 57*cdf0e10cSrcweir return new OAdoColumn(isCaseSensitive(),m_pConnection,m_aCollection.GetItem(_rName)); 58*cdf0e10cSrcweir } 59*cdf0e10cSrcweir 60*cdf0e10cSrcweir // ------------------------------------------------------------------------- 61*cdf0e10cSrcweir void OColumns::impl_refresh() throw(RuntimeException) 62*cdf0e10cSrcweir { 63*cdf0e10cSrcweir m_aCollection.Refresh(); 64*cdf0e10cSrcweir } 65*cdf0e10cSrcweir // ------------------------------------------------------------------------- 66*cdf0e10cSrcweir Reference< XPropertySet > OColumns::createDescriptor() 67*cdf0e10cSrcweir { 68*cdf0e10cSrcweir return new OAdoColumn(isCaseSensitive(),m_pConnection); 69*cdf0e10cSrcweir } 70*cdf0e10cSrcweir // ------------------------------------------------------------------------- 71*cdf0e10cSrcweir // XAppend 72*cdf0e10cSrcweir sdbcx::ObjectType OColumns::appendObject( const ::rtl::OUString&, const Reference< XPropertySet >& descriptor ) 73*cdf0e10cSrcweir { 74*cdf0e10cSrcweir OAdoColumn* pColumn = NULL; 75*cdf0e10cSrcweir Reference< XPropertySet > xColumn; 76*cdf0e10cSrcweir if ( !getImplementation( pColumn, descriptor ) || pColumn == NULL ) 77*cdf0e10cSrcweir { 78*cdf0e10cSrcweir // m_pConnection->throwGenericSQLException( STR_INVALID_COLUMN_DESCRIPTOR_ERROR,static_cast<XTypeProvider*>(this) ); 79*cdf0e10cSrcweir pColumn = new OAdoColumn(isCaseSensitive(),m_pConnection); 80*cdf0e10cSrcweir xColumn = pColumn; 81*cdf0e10cSrcweir ::comphelper::copyProperties(descriptor,xColumn); 82*cdf0e10cSrcweir } 83*cdf0e10cSrcweir 84*cdf0e10cSrcweir WpADOColumn aColumn = pColumn->getColumnImpl(); 85*cdf0e10cSrcweir 86*cdf0e10cSrcweir #if OSL_DEBUG_LEVEL > 0 87*cdf0e10cSrcweir sal_Int32 nPrecision; 88*cdf0e10cSrcweir sal_Int32 nScale; 89*cdf0e10cSrcweir sal_Int32 nType; 90*cdf0e10cSrcweir nPrecision = aColumn.get_Precision(); 91*cdf0e10cSrcweir nScale = aColumn.get_NumericScale(); 92*cdf0e10cSrcweir nType = ADOS::MapADOType2Jdbc(aColumn.get_Type()); 93*cdf0e10cSrcweir #endif 94*cdf0e10cSrcweir 95*cdf0e10cSrcweir ::rtl::OUString sTypeName; 96*cdf0e10cSrcweir pColumn->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_TYPENAME)) >>= sTypeName; 97*cdf0e10cSrcweir 98*cdf0e10cSrcweir const OTypeInfoMap* pTypeInfoMap = m_pConnection->getTypeInfo(); 99*cdf0e10cSrcweir ::comphelper::TStringMixEqualFunctor aCase(sal_False); 100*cdf0e10cSrcweir // search for typeinfo where the typename is equal sTypeName 101*cdf0e10cSrcweir OTypeInfoMap::const_iterator aFind = ::std::find_if(pTypeInfoMap->begin(), 102*cdf0e10cSrcweir pTypeInfoMap->end(), 103*cdf0e10cSrcweir ::std::compose1( 104*cdf0e10cSrcweir ::std::bind2nd(aCase, sTypeName), 105*cdf0e10cSrcweir ::std::compose1( 106*cdf0e10cSrcweir ::std::mem_fun(&OExtendedTypeInfo::getDBName), 107*cdf0e10cSrcweir ::std::select2nd<OTypeInfoMap::value_type>()) 108*cdf0e10cSrcweir ) 109*cdf0e10cSrcweir 110*cdf0e10cSrcweir ); 111*cdf0e10cSrcweir 112*cdf0e10cSrcweir if ( aFind != pTypeInfoMap->end() ) // change column type if necessary 113*cdf0e10cSrcweir aColumn.put_Type(aFind->first); 114*cdf0e10cSrcweir 115*cdf0e10cSrcweir if ( SUCCEEDED(((ADOColumns*)m_aCollection)->Append(OLEVariant(aColumn.get_Name()),aColumn.get_Type(),aColumn.get_DefinedSize())) ) 116*cdf0e10cSrcweir { 117*cdf0e10cSrcweir WpADOColumn aAddedColumn = m_aCollection.GetItem(OLEVariant(aColumn.get_Name())); 118*cdf0e10cSrcweir if ( aAddedColumn.IsValid() ) 119*cdf0e10cSrcweir { 120*cdf0e10cSrcweir sal_Bool bAutoIncrement = sal_False; 121*cdf0e10cSrcweir pColumn->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_ISAUTOINCREMENT)) >>= bAutoIncrement; 122*cdf0e10cSrcweir if ( bAutoIncrement ) 123*cdf0e10cSrcweir OTools::putValue( aAddedColumn.get_Properties(), ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("Autoincrement")), bAutoIncrement ); 124*cdf0e10cSrcweir 125*cdf0e10cSrcweir if ( aFind != pTypeInfoMap->end() && aColumn.get_Type() != aAddedColumn.get_Type() ) // change column type if necessary 126*cdf0e10cSrcweir aColumn.put_Type(aFind->first); 127*cdf0e10cSrcweir aAddedColumn.put_Precision(aColumn.get_Precision()); 128*cdf0e10cSrcweir aAddedColumn.put_NumericScale(aColumn.get_NumericScale()); 129*cdf0e10cSrcweir aAddedColumn.put_Attributes(aColumn.get_Attributes()); 130*cdf0e10cSrcweir aAddedColumn.put_SortOrder(aColumn.get_SortOrder()); 131*cdf0e10cSrcweir aAddedColumn.put_RelatedColumn(aColumn.get_RelatedColumn()); 132*cdf0e10cSrcweir } 133*cdf0e10cSrcweir } 134*cdf0e10cSrcweir ADOS::ThrowException(*m_pConnection->getConnection(),static_cast<XTypeProvider*>(this)); 135*cdf0e10cSrcweir 136*cdf0e10cSrcweir return new OAdoColumn(isCaseSensitive(),m_pConnection,pColumn->getColumnImpl()); 137*cdf0e10cSrcweir } 138*cdf0e10cSrcweir // ------------------------------------------------------------------------- 139*cdf0e10cSrcweir // XDrop 140*cdf0e10cSrcweir void OColumns::dropObject(sal_Int32 /*_nPos*/,const ::rtl::OUString _sElementName) 141*cdf0e10cSrcweir { 142*cdf0e10cSrcweir if(!m_aCollection.Delete(_sElementName)) 143*cdf0e10cSrcweir ADOS::ThrowException(*m_pConnection->getConnection(),static_cast<XTypeProvider*>(this)); 144*cdf0e10cSrcweir } 145*cdf0e10cSrcweir // ----------------------------------------------------------------------------- 146*cdf0e10cSrcweir 147*cdf0e10cSrcweir 148*cdf0e10cSrcweir 149