xref: /AOO41X/main/connectivity/source/commontools/TKey.cxx (revision cdf0e10c4e3984b49a9502b011690b615761d4a3)
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 
31*cdf0e10cSrcweir 
32*cdf0e10cSrcweir #include "connectivity/TKey.hxx"
33*cdf0e10cSrcweir #include "connectivity/TKeyColumns.hxx"
34*cdf0e10cSrcweir #include <com/sun/star/sdbc/XRow.hpp>
35*cdf0e10cSrcweir #include <com/sun/star/sdbc/XResultSet.hpp>
36*cdf0e10cSrcweir #include "TConnection.hxx"
37*cdf0e10cSrcweir #include "connectivity/TTableHelper.hxx"
38*cdf0e10cSrcweir 
39*cdf0e10cSrcweir using namespace connectivity;
40*cdf0e10cSrcweir using namespace ::com::sun::star::uno;
41*cdf0e10cSrcweir using namespace ::com::sun::star::beans;
42*cdf0e10cSrcweir //	using namespace ::com::sun::star::sdbcx;
43*cdf0e10cSrcweir using namespace ::com::sun::star::sdbc;
44*cdf0e10cSrcweir using namespace ::com::sun::star::container;
45*cdf0e10cSrcweir using namespace ::com::sun::star::lang;
46*cdf0e10cSrcweir // -------------------------------------------------------------------------
47*cdf0e10cSrcweir OTableKeyHelper::OTableKeyHelper(OTableHelper* _pTable) : connectivity::sdbcx::OKey(sal_True)
48*cdf0e10cSrcweir 	,m_pTable(_pTable)
49*cdf0e10cSrcweir {
50*cdf0e10cSrcweir 	construct();
51*cdf0e10cSrcweir }
52*cdf0e10cSrcweir // -------------------------------------------------------------------------
53*cdf0e10cSrcweir OTableKeyHelper::OTableKeyHelper(	OTableHelper* _pTable
54*cdf0e10cSrcweir             ,const ::rtl::OUString& _Name
55*cdf0e10cSrcweir             ,const sdbcx::TKeyProperties& _rProps
56*cdf0e10cSrcweir 			) : connectivity::sdbcx::OKey(_Name,_rProps,sal_True)
57*cdf0e10cSrcweir 				,m_pTable(_pTable)
58*cdf0e10cSrcweir {
59*cdf0e10cSrcweir 	construct();
60*cdf0e10cSrcweir 	refreshColumns();
61*cdf0e10cSrcweir }
62*cdf0e10cSrcweir // -------------------------------------------------------------------------
63*cdf0e10cSrcweir void OTableKeyHelper::refreshColumns()
64*cdf0e10cSrcweir {
65*cdf0e10cSrcweir 	if ( !m_pTable )
66*cdf0e10cSrcweir 		return;
67*cdf0e10cSrcweir 
68*cdf0e10cSrcweir 	::std::vector< ::rtl::OUString> aVector;
69*cdf0e10cSrcweir 	if ( !isNew() )
70*cdf0e10cSrcweir 	{
71*cdf0e10cSrcweir         aVector = m_aProps->m_aKeyColumnNames;
72*cdf0e10cSrcweir         if ( aVector.empty() )
73*cdf0e10cSrcweir 		{
74*cdf0e10cSrcweir 		    ::dbtools::OPropertyMap& rPropMap = OMetaConnection::getPropMap();
75*cdf0e10cSrcweir 		    ::rtl::OUString aSchema,aTable;
76*cdf0e10cSrcweir 		    m_pTable->getPropertyValue(rPropMap.getNameByIndex(PROPERTY_ID_SCHEMANAME))	>>= aSchema;
77*cdf0e10cSrcweir 		    m_pTable->getPropertyValue(rPropMap.getNameByIndex(PROPERTY_ID_NAME))		>>= aTable;
78*cdf0e10cSrcweir 
79*cdf0e10cSrcweir 		    if ( m_Name.getLength() ) // foreign key
80*cdf0e10cSrcweir 		    {
81*cdf0e10cSrcweir 
82*cdf0e10cSrcweir 			    Reference< XResultSet > xResult = m_pTable->getMetaData()->getImportedKeys(m_pTable->getPropertyValue(rPropMap.getNameByIndex(PROPERTY_ID_CATALOGNAME)),
83*cdf0e10cSrcweir 				    aSchema,aTable);
84*cdf0e10cSrcweir 
85*cdf0e10cSrcweir 			    if ( xResult.is() )
86*cdf0e10cSrcweir 			    {
87*cdf0e10cSrcweir 				    Reference< XRow > xRow(xResult,UNO_QUERY);
88*cdf0e10cSrcweir 				    while( xResult->next() )
89*cdf0e10cSrcweir 				    {
90*cdf0e10cSrcweir 					    ::rtl::OUString aForeignKeyColumn = xRow->getString(8);
91*cdf0e10cSrcweir 					    if(xRow->getString(12) == m_Name)
92*cdf0e10cSrcweir 						    aVector.push_back(aForeignKeyColumn);
93*cdf0e10cSrcweir 				    }
94*cdf0e10cSrcweir 			    }
95*cdf0e10cSrcweir 		    }
96*cdf0e10cSrcweir 
97*cdf0e10cSrcweir             if ( aVector.empty() )
98*cdf0e10cSrcweir 		    {
99*cdf0e10cSrcweir 			    const Reference< XResultSet > xResult = m_pTable->getMetaData()->getPrimaryKeys(m_pTable->getPropertyValue(rPropMap.getNameByIndex(PROPERTY_ID_CATALOGNAME)),
100*cdf0e10cSrcweir 				    aSchema,aTable);
101*cdf0e10cSrcweir 
102*cdf0e10cSrcweir 			    if ( xResult.is() )
103*cdf0e10cSrcweir 			    {
104*cdf0e10cSrcweir 				    const Reference< XRow > xRow(xResult,UNO_QUERY);
105*cdf0e10cSrcweir 				    while( xResult->next() )
106*cdf0e10cSrcweir 					    aVector.push_back(xRow->getString(4));
107*cdf0e10cSrcweir 			    } // if ( xResult.is() )
108*cdf0e10cSrcweir             }
109*cdf0e10cSrcweir 		}
110*cdf0e10cSrcweir 	}
111*cdf0e10cSrcweir 
112*cdf0e10cSrcweir 
113*cdf0e10cSrcweir 	if ( m_pColumns )
114*cdf0e10cSrcweir 		m_pColumns ->reFill(aVector);
115*cdf0e10cSrcweir 	else
116*cdf0e10cSrcweir 		m_pColumns	= new OKeyColumnsHelper(this,m_aMutex,aVector);
117*cdf0e10cSrcweir }
118*cdf0e10cSrcweir // -----------------------------------------------------------------------------
119*cdf0e10cSrcweir 
120