1*b1cdbd2cSJim Jagielski /**************************************************************
2*b1cdbd2cSJim Jagielski *
3*b1cdbd2cSJim Jagielski * Licensed to the Apache Software Foundation (ASF) under one
4*b1cdbd2cSJim Jagielski * or more contributor license agreements. See the NOTICE file
5*b1cdbd2cSJim Jagielski * distributed with this work for additional information
6*b1cdbd2cSJim Jagielski * regarding copyright ownership. The ASF licenses this file
7*b1cdbd2cSJim Jagielski * to you under the Apache License, Version 2.0 (the
8*b1cdbd2cSJim Jagielski * "License"); you may not use this file except in compliance
9*b1cdbd2cSJim Jagielski * with the License. You may obtain a copy of the License at
10*b1cdbd2cSJim Jagielski *
11*b1cdbd2cSJim Jagielski * http://www.apache.org/licenses/LICENSE-2.0
12*b1cdbd2cSJim Jagielski *
13*b1cdbd2cSJim Jagielski * Unless required by applicable law or agreed to in writing,
14*b1cdbd2cSJim Jagielski * software distributed under the License is distributed on an
15*b1cdbd2cSJim Jagielski * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16*b1cdbd2cSJim Jagielski * KIND, either express or implied. See the License for the
17*b1cdbd2cSJim Jagielski * specific language governing permissions and limitations
18*b1cdbd2cSJim Jagielski * under the License.
19*b1cdbd2cSJim Jagielski *
20*b1cdbd2cSJim Jagielski *************************************************************/
21*b1cdbd2cSJim Jagielski
22*b1cdbd2cSJim Jagielski
23*b1cdbd2cSJim Jagielski
24*b1cdbd2cSJim Jagielski // MARKER(update_precomp.py): autogen include statement, do not remove
25*b1cdbd2cSJim Jagielski #include "precompiled_connectivity.hxx"
26*b1cdbd2cSJim Jagielski #include "ado/AColumns.hxx"
27*b1cdbd2cSJim Jagielski #include "ado/AColumn.hxx"
28*b1cdbd2cSJim Jagielski #include "ado/AConnection.hxx"
29*b1cdbd2cSJim Jagielski #include "ado/Awrapado.hxx"
30*b1cdbd2cSJim Jagielski #include <com/sun/star/sdbc/XRow.hpp>
31*b1cdbd2cSJim Jagielski #include <com/sun/star/sdbc/XResultSet.hpp>
32*b1cdbd2cSJim Jagielski #include <com/sun/star/sdbc/DataType.hpp>
33*b1cdbd2cSJim Jagielski #include <com/sun/star/sdbc/ColumnValue.hpp>
34*b1cdbd2cSJim Jagielski #include <comphelper/property.hxx>
35*b1cdbd2cSJim Jagielski #include <comphelper/types.hxx>
36*b1cdbd2cSJim Jagielski #include <connectivity/dbexception.hxx>
37*b1cdbd2cSJim Jagielski #include <algorithm>
38*b1cdbd2cSJim Jagielski #include "resource/ado_res.hrc"
39*b1cdbd2cSJim Jagielski
40*b1cdbd2cSJim Jagielski using namespace connectivity::ado;
41*b1cdbd2cSJim Jagielski using namespace connectivity;
42*b1cdbd2cSJim Jagielski using namespace comphelper;
43*b1cdbd2cSJim Jagielski using namespace com::sun::star::uno;
44*b1cdbd2cSJim Jagielski using namespace com::sun::star::lang;
45*b1cdbd2cSJim Jagielski using namespace com::sun::star::beans;
46*b1cdbd2cSJim Jagielski using namespace com::sun::star::sdbc;
47*b1cdbd2cSJim Jagielski using namespace com::sun::star::container;
48*b1cdbd2cSJim Jagielski
createObject(const::rtl::OUString & _rName)49*b1cdbd2cSJim Jagielski sdbcx::ObjectType OColumns::createObject(const ::rtl::OUString& _rName)
50*b1cdbd2cSJim Jagielski {
51*b1cdbd2cSJim Jagielski return new OAdoColumn(isCaseSensitive(),m_pConnection,m_aCollection.GetItem(_rName));
52*b1cdbd2cSJim Jagielski }
53*b1cdbd2cSJim Jagielski
54*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
impl_refresh()55*b1cdbd2cSJim Jagielski void OColumns::impl_refresh() throw(RuntimeException)
56*b1cdbd2cSJim Jagielski {
57*b1cdbd2cSJim Jagielski m_aCollection.Refresh();
58*b1cdbd2cSJim Jagielski }
59*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
createDescriptor()60*b1cdbd2cSJim Jagielski Reference< XPropertySet > OColumns::createDescriptor()
61*b1cdbd2cSJim Jagielski {
62*b1cdbd2cSJim Jagielski return new OAdoColumn(isCaseSensitive(),m_pConnection);
63*b1cdbd2cSJim Jagielski }
64*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
65*b1cdbd2cSJim Jagielski // XAppend
appendObject(const::rtl::OUString &,const Reference<XPropertySet> & descriptor)66*b1cdbd2cSJim Jagielski sdbcx::ObjectType OColumns::appendObject( const ::rtl::OUString&, const Reference< XPropertySet >& descriptor )
67*b1cdbd2cSJim Jagielski {
68*b1cdbd2cSJim Jagielski OAdoColumn* pColumn = NULL;
69*b1cdbd2cSJim Jagielski Reference< XPropertySet > xColumn;
70*b1cdbd2cSJim Jagielski if ( !getImplementation( pColumn, descriptor ) || pColumn == NULL )
71*b1cdbd2cSJim Jagielski {
72*b1cdbd2cSJim Jagielski // m_pConnection->throwGenericSQLException( STR_INVALID_COLUMN_DESCRIPTOR_ERROR,static_cast<XTypeProvider*>(this) );
73*b1cdbd2cSJim Jagielski pColumn = new OAdoColumn(isCaseSensitive(),m_pConnection);
74*b1cdbd2cSJim Jagielski xColumn = pColumn;
75*b1cdbd2cSJim Jagielski ::comphelper::copyProperties(descriptor,xColumn);
76*b1cdbd2cSJim Jagielski }
77*b1cdbd2cSJim Jagielski
78*b1cdbd2cSJim Jagielski WpADOColumn aColumn = pColumn->getColumnImpl();
79*b1cdbd2cSJim Jagielski
80*b1cdbd2cSJim Jagielski #if OSL_DEBUG_LEVEL > 0
81*b1cdbd2cSJim Jagielski sal_Int32 nPrecision;
82*b1cdbd2cSJim Jagielski sal_Int32 nScale;
83*b1cdbd2cSJim Jagielski sal_Int32 nType;
84*b1cdbd2cSJim Jagielski nPrecision = aColumn.get_Precision();
85*b1cdbd2cSJim Jagielski nScale = aColumn.get_NumericScale();
86*b1cdbd2cSJim Jagielski nType = ADOS::MapADOType2Jdbc(aColumn.get_Type());
87*b1cdbd2cSJim Jagielski #endif
88*b1cdbd2cSJim Jagielski
89*b1cdbd2cSJim Jagielski ::rtl::OUString sTypeName;
90*b1cdbd2cSJim Jagielski pColumn->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_TYPENAME)) >>= sTypeName;
91*b1cdbd2cSJim Jagielski
92*b1cdbd2cSJim Jagielski const OTypeInfoMap* pTypeInfoMap = m_pConnection->getTypeInfo();
93*b1cdbd2cSJim Jagielski ::comphelper::TStringMixEqualFunctor aCase(sal_False);
94*b1cdbd2cSJim Jagielski // search for typeinfo where the typename is equal sTypeName
95*b1cdbd2cSJim Jagielski OTypeInfoMap::const_iterator aFind = ::std::find_if(pTypeInfoMap->begin(),
96*b1cdbd2cSJim Jagielski pTypeInfoMap->end(),
97*b1cdbd2cSJim Jagielski ::std::compose1(
98*b1cdbd2cSJim Jagielski ::std::bind2nd(aCase, sTypeName),
99*b1cdbd2cSJim Jagielski ::std::compose1(
100*b1cdbd2cSJim Jagielski ::std::mem_fun(&OExtendedTypeInfo::getDBName),
101*b1cdbd2cSJim Jagielski ::std::select2nd<OTypeInfoMap::value_type>())
102*b1cdbd2cSJim Jagielski )
103*b1cdbd2cSJim Jagielski
104*b1cdbd2cSJim Jagielski );
105*b1cdbd2cSJim Jagielski
106*b1cdbd2cSJim Jagielski if ( aFind != pTypeInfoMap->end() ) // change column type if necessary
107*b1cdbd2cSJim Jagielski aColumn.put_Type(aFind->first);
108*b1cdbd2cSJim Jagielski
109*b1cdbd2cSJim Jagielski if ( SUCCEEDED(((ADOColumns*)m_aCollection)->Append(OLEVariant(aColumn.get_Name()),aColumn.get_Type(),aColumn.get_DefinedSize())) )
110*b1cdbd2cSJim Jagielski {
111*b1cdbd2cSJim Jagielski WpADOColumn aAddedColumn = m_aCollection.GetItem(OLEVariant(aColumn.get_Name()));
112*b1cdbd2cSJim Jagielski if ( aAddedColumn.IsValid() )
113*b1cdbd2cSJim Jagielski {
114*b1cdbd2cSJim Jagielski sal_Bool bAutoIncrement = sal_False;
115*b1cdbd2cSJim Jagielski pColumn->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_ISAUTOINCREMENT)) >>= bAutoIncrement;
116*b1cdbd2cSJim Jagielski if ( bAutoIncrement )
117*b1cdbd2cSJim Jagielski OTools::putValue( aAddedColumn.get_Properties(), ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("Autoincrement")), bAutoIncrement );
118*b1cdbd2cSJim Jagielski
119*b1cdbd2cSJim Jagielski if ( aFind != pTypeInfoMap->end() && aColumn.get_Type() != aAddedColumn.get_Type() ) // change column type if necessary
120*b1cdbd2cSJim Jagielski aColumn.put_Type(aFind->first);
121*b1cdbd2cSJim Jagielski aAddedColumn.put_Precision(aColumn.get_Precision());
122*b1cdbd2cSJim Jagielski aAddedColumn.put_NumericScale(aColumn.get_NumericScale());
123*b1cdbd2cSJim Jagielski aAddedColumn.put_Attributes(aColumn.get_Attributes());
124*b1cdbd2cSJim Jagielski aAddedColumn.put_SortOrder(aColumn.get_SortOrder());
125*b1cdbd2cSJim Jagielski aAddedColumn.put_RelatedColumn(aColumn.get_RelatedColumn());
126*b1cdbd2cSJim Jagielski }
127*b1cdbd2cSJim Jagielski }
128*b1cdbd2cSJim Jagielski ADOS::ThrowException(*m_pConnection->getConnection(),static_cast<XTypeProvider*>(this));
129*b1cdbd2cSJim Jagielski
130*b1cdbd2cSJim Jagielski return new OAdoColumn(isCaseSensitive(),m_pConnection,pColumn->getColumnImpl());
131*b1cdbd2cSJim Jagielski }
132*b1cdbd2cSJim Jagielski // -------------------------------------------------------------------------
133*b1cdbd2cSJim Jagielski // XDrop
dropObject(sal_Int32,const::rtl::OUString _sElementName)134*b1cdbd2cSJim Jagielski void OColumns::dropObject(sal_Int32 /*_nPos*/,const ::rtl::OUString _sElementName)
135*b1cdbd2cSJim Jagielski {
136*b1cdbd2cSJim Jagielski if(!m_aCollection.Delete(_sElementName))
137*b1cdbd2cSJim Jagielski ADOS::ThrowException(*m_pConnection->getConnection(),static_cast<XTypeProvider*>(this));
138*b1cdbd2cSJim Jagielski }
139*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
140*b1cdbd2cSJim Jagielski
141*b1cdbd2cSJim Jagielski
142*b1cdbd2cSJim Jagielski
143