19b5730f6SAndrew Rist /**************************************************************
2cdf0e10cSrcweir *
39b5730f6SAndrew Rist * Licensed to the Apache Software Foundation (ASF) under one
49b5730f6SAndrew Rist * or more contributor license agreements. See the NOTICE file
59b5730f6SAndrew Rist * distributed with this work for additional information
69b5730f6SAndrew Rist * regarding copyright ownership. The ASF licenses this file
79b5730f6SAndrew Rist * to you under the Apache License, Version 2.0 (the
89b5730f6SAndrew Rist * "License"); you may not use this file except in compliance
99b5730f6SAndrew Rist * with the License. You may obtain a copy of the License at
109b5730f6SAndrew Rist *
119b5730f6SAndrew Rist * http://www.apache.org/licenses/LICENSE-2.0
129b5730f6SAndrew Rist *
139b5730f6SAndrew Rist * Unless required by applicable law or agreed to in writing,
149b5730f6SAndrew Rist * software distributed under the License is distributed on an
159b5730f6SAndrew Rist * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
169b5730f6SAndrew Rist * KIND, either express or implied. See the License for the
179b5730f6SAndrew Rist * specific language governing permissions and limitations
189b5730f6SAndrew Rist * under the License.
199b5730f6SAndrew Rist *
209b5730f6SAndrew Rist *************************************************************/
219b5730f6SAndrew Rist
229b5730f6SAndrew Rist
23cdf0e10cSrcweir
24cdf0e10cSrcweir // MARKER(update_precomp.py): autogen include statement, do not remove
25cdf0e10cSrcweir #include "precompiled_connectivity.hxx"
26cdf0e10cSrcweir
27cdf0e10cSrcweir #include <stdio.h>
28cdf0e10cSrcweir #include "connectivity/CommonTools.hxx"
29cdf0e10cSrcweir #include "connectivity/dbtools.hxx"
30cdf0e10cSrcweir #include <com/sun/star/util/Date.hpp>
31cdf0e10cSrcweir #include <com/sun/star/util/Time.hpp>
32cdf0e10cSrcweir #include <com/sun/star/util/DateTime.hpp>
33cdf0e10cSrcweir #include <com/sun/star/beans/XPropertySet.hpp>
34cdf0e10cSrcweir #include <com/sun/star/lang/XComponent.hpp>
35cdf0e10cSrcweir #include <comphelper/extract.hxx>
36cdf0e10cSrcweir #include <cppuhelper/interfacecontainer.h>
37cdf0e10cSrcweir #include "TConnection.hxx"
38cdf0e10cSrcweir #include <comphelper/types.hxx>
39cdf0e10cSrcweir #include <com/sun/star/java/XJavaVM.hpp>
40cdf0e10cSrcweir #include <rtl/process.h>
41cdf0e10cSrcweir
42cdf0e10cSrcweir using namespace ::comphelper;
rtl_ascii_toUpperCase(sal_Unicode ch)43cdf0e10cSrcweir inline sal_Unicode rtl_ascii_toUpperCase( sal_Unicode ch )
44cdf0e10cSrcweir {
45cdf0e10cSrcweir return ch >= 0x0061 && ch <= 0x007a ? ch + 0x20 : ch;
46cdf0e10cSrcweir }
47cdf0e10cSrcweir
48cdf0e10cSrcweir namespace connectivity
49cdf0e10cSrcweir {
50cdf0e10cSrcweir using namespace ::com::sun::star::uno;
51cdf0e10cSrcweir using namespace ::com::sun::star::lang;
52cdf0e10cSrcweir using namespace ::com::sun::star::beans;
53cdf0e10cSrcweir using namespace dbtools;
54cdf0e10cSrcweir namespace starjava = com::sun::star::java;
55cdf0e10cSrcweir //------------------------------------------------------------------------------
56cdf0e10cSrcweir const sal_Unicode CHAR_PLACE = '_';
57cdf0e10cSrcweir const sal_Unicode CHAR_WILD = '%';
58cdf0e10cSrcweir // -------------------------------------------------------------------------
match(const sal_Unicode * pWild,const sal_Unicode * pStr,const sal_Unicode cEscape)59cdf0e10cSrcweir sal_Bool match(const sal_Unicode* pWild, const sal_Unicode* pStr, const sal_Unicode cEscape)
60cdf0e10cSrcweir {
61cdf0e10cSrcweir int pos=0;
62cdf0e10cSrcweir int flag=0;
63cdf0e10cSrcweir
64cdf0e10cSrcweir while ( *pWild || flag )
65cdf0e10cSrcweir {
66cdf0e10cSrcweir switch (*pWild)
67cdf0e10cSrcweir {
68cdf0e10cSrcweir case CHAR_PLACE:
69cdf0e10cSrcweir if ( *pStr == 0 )
70cdf0e10cSrcweir return sal_False;
71cdf0e10cSrcweir break;
72cdf0e10cSrcweir default:
73cdf0e10cSrcweir if (*pWild && (*pWild == cEscape) && ((*(pWild+1)== CHAR_PLACE) || (*(pWild+1) == CHAR_WILD)) )
74cdf0e10cSrcweir pWild++;
75cdf0e10cSrcweir if ( rtl_ascii_toUpperCase(*pWild) != rtl_ascii_toUpperCase(*pStr) )
76cdf0e10cSrcweir if ( !pos )
77cdf0e10cSrcweir return sal_False;
78cdf0e10cSrcweir else
79cdf0e10cSrcweir pWild += pos;
80cdf0e10cSrcweir else
81cdf0e10cSrcweir break; // ACHTUNG laeuft unter bestimmten
82cdf0e10cSrcweir // Umstaenden in den nachsten case rein!!
83cdf0e10cSrcweir case CHAR_WILD:
84cdf0e10cSrcweir while ( *pWild == CHAR_WILD )
85cdf0e10cSrcweir pWild++;
86cdf0e10cSrcweir if ( *pWild == 0 )
87cdf0e10cSrcweir return sal_True;
88cdf0e10cSrcweir flag = 1;
89cdf0e10cSrcweir pos = 0;
90cdf0e10cSrcweir if ( *pStr == 0 )
91cdf0e10cSrcweir return ( *pWild == 0 );
92cdf0e10cSrcweir while ( *pStr && *pStr != *pWild )
93cdf0e10cSrcweir {
94cdf0e10cSrcweir if ( *pWild == CHAR_PLACE ) {
95cdf0e10cSrcweir pWild++;
96cdf0e10cSrcweir while ( *pWild == CHAR_WILD )
97cdf0e10cSrcweir pWild++;
98cdf0e10cSrcweir }
99cdf0e10cSrcweir pStr++;
100cdf0e10cSrcweir if ( *pStr == 0 )
101cdf0e10cSrcweir return ( *pWild == 0 );
102cdf0e10cSrcweir }
103cdf0e10cSrcweir break;
104cdf0e10cSrcweir }
105cdf0e10cSrcweir if ( *pWild != 0 )
106cdf0e10cSrcweir pWild++;
107cdf0e10cSrcweir if ( *pStr != 0 )
108cdf0e10cSrcweir pStr++;
109cdf0e10cSrcweir else
110cdf0e10cSrcweir flag = 0;
111cdf0e10cSrcweir if ( flag )
112cdf0e10cSrcweir pos--;
113cdf0e10cSrcweir }
114cdf0e10cSrcweir return ( *pStr == 0 ) && ( *pWild == 0 );
115cdf0e10cSrcweir }
116cdf0e10cSrcweir //------------------------------------------------------------------
toDateString(const::com::sun::star::util::Date & rDate)117cdf0e10cSrcweir rtl::OUString toDateString(const ::com::sun::star::util::Date& rDate)
118cdf0e10cSrcweir {
119cdf0e10cSrcweir sal_Char s[11];
120cdf0e10cSrcweir snprintf(s,
121cdf0e10cSrcweir sizeof(s),
122cdf0e10cSrcweir "%04d-%02d-%02d",
123cdf0e10cSrcweir (int)rDate.Year,
124cdf0e10cSrcweir (int)rDate.Month,
125cdf0e10cSrcweir (int)rDate.Day);
126cdf0e10cSrcweir s[10] = 0;
127cdf0e10cSrcweir return rtl::OUString::createFromAscii(s);
128cdf0e10cSrcweir }
129cdf0e10cSrcweir
130cdf0e10cSrcweir //------------------------------------------------------------------
toTimeString(const::com::sun::star::util::Time & rTime)131cdf0e10cSrcweir rtl::OUString toTimeString(const ::com::sun::star::util::Time& rTime)
132cdf0e10cSrcweir {
133cdf0e10cSrcweir sal_Char s[9];
134cdf0e10cSrcweir snprintf(s,
135cdf0e10cSrcweir sizeof(s),
136cdf0e10cSrcweir "%02d:%02d:%02d",
137cdf0e10cSrcweir (int)rTime.Hours,
138cdf0e10cSrcweir (int)rTime.Minutes,
139cdf0e10cSrcweir (int)rTime.Seconds);
140cdf0e10cSrcweir s[8] = 0;
141cdf0e10cSrcweir return rtl::OUString::createFromAscii(s);
142cdf0e10cSrcweir }
143cdf0e10cSrcweir
144cdf0e10cSrcweir //------------------------------------------------------------------
toDateTimeString(const::com::sun::star::util::DateTime & rDateTime)145cdf0e10cSrcweir rtl::OUString toDateTimeString(const ::com::sun::star::util::DateTime& rDateTime)
146cdf0e10cSrcweir {
147cdf0e10cSrcweir sal_Char s[21];
148cdf0e10cSrcweir snprintf(s,
149cdf0e10cSrcweir sizeof(s),
150cdf0e10cSrcweir "%04d-%02d-%02d %02d:%02d:%02d",
151cdf0e10cSrcweir (int)rDateTime.Year,
152cdf0e10cSrcweir (int)rDateTime.Month,
153cdf0e10cSrcweir (int)rDateTime.Day,
154cdf0e10cSrcweir (int)rDateTime.Hours,
155cdf0e10cSrcweir (int)rDateTime.Minutes,
156cdf0e10cSrcweir (int)rDateTime.Seconds);
157cdf0e10cSrcweir s[20] = 0;
158cdf0e10cSrcweir return rtl::OUString::createFromAscii(s);
159cdf0e10cSrcweir }
160cdf0e10cSrcweir
161cdf0e10cSrcweir
162cdf0e10cSrcweir //--------------------------------------------------------------------------------------------------
toString(const Any & rValue)163cdf0e10cSrcweir rtl::OUString toString(const Any& rValue)
164cdf0e10cSrcweir {
165cdf0e10cSrcweir rtl::OUString aRes;
166cdf0e10cSrcweir TypeClass aDestinationClass = rValue.getValueType().getTypeClass();
167cdf0e10cSrcweir
168cdf0e10cSrcweir switch (aDestinationClass)
169cdf0e10cSrcweir {
170cdf0e10cSrcweir case TypeClass_CHAR:
171cdf0e10cSrcweir aRes = ::rtl::OUString::valueOf(*(sal_Unicode*)rValue.getValue());
172cdf0e10cSrcweir break;
173cdf0e10cSrcweir case TypeClass_FLOAT:
174cdf0e10cSrcweir aRes = ::rtl::OUString::valueOf(*(float*)rValue.getValue());
175cdf0e10cSrcweir break;
176cdf0e10cSrcweir case TypeClass_DOUBLE:
177cdf0e10cSrcweir aRes = ::rtl::OUString::valueOf(*(double*)rValue.getValue());
178cdf0e10cSrcweir break;
179cdf0e10cSrcweir case TypeClass_BOOLEAN:
180cdf0e10cSrcweir aRes = ::rtl::OUString::valueOf((sal_Int32)*(sal_Bool*)rValue.getValue());
181cdf0e10cSrcweir break;
182cdf0e10cSrcweir case TypeClass_BYTE:
183cdf0e10cSrcweir case TypeClass_SHORT:
184cdf0e10cSrcweir case TypeClass_LONG:
185cdf0e10cSrcweir aRes = ::rtl::OUString::valueOf(*(sal_Int32*)rValue.getValue());
186cdf0e10cSrcweir break;
187cdf0e10cSrcweir case TypeClass_HYPER:
188cdf0e10cSrcweir {
189cdf0e10cSrcweir sal_Int64 nValue = 0;
190cdf0e10cSrcweir OSL_VERIFY( rValue >>= nValue );
191cdf0e10cSrcweir aRes = ::rtl::OUString::valueOf(nValue);
192cdf0e10cSrcweir }
193cdf0e10cSrcweir case TypeClass_STRING:
194cdf0e10cSrcweir rValue >>= aRes;
195cdf0e10cSrcweir break;
196cdf0e10cSrcweir case TypeClass_STRUCT:
197cdf0e10cSrcweir if (rValue.getValueType() == ::getCppuType((const ::com::sun::star::util::Date*)0))
198cdf0e10cSrcweir {
199cdf0e10cSrcweir ::com::sun::star::util::Date aDate;
200cdf0e10cSrcweir rValue >>= aDate;
201cdf0e10cSrcweir aRes = toDateString(aDate);
202cdf0e10cSrcweir }
203cdf0e10cSrcweir else if (rValue.getValueType() == ::getCppuType((const ::com::sun::star::util::DateTime*)0))
204cdf0e10cSrcweir {
205cdf0e10cSrcweir ::com::sun::star::util::DateTime aDT;
206cdf0e10cSrcweir rValue >>= aDT;
207cdf0e10cSrcweir aRes = toDateTimeString(aDT);
208cdf0e10cSrcweir }
209cdf0e10cSrcweir else if (rValue.getValueType() == ::getCppuType((const ::com::sun::star::util::Time*)0))
210cdf0e10cSrcweir {
211cdf0e10cSrcweir ::com::sun::star::util::Time aTime;
212cdf0e10cSrcweir rValue >>= aTime;
213cdf0e10cSrcweir aRes = toTimeString(aTime);
214cdf0e10cSrcweir }
215cdf0e10cSrcweir
216cdf0e10cSrcweir break;
217cdf0e10cSrcweir default:
218cdf0e10cSrcweir ;
219cdf0e10cSrcweir }
220cdf0e10cSrcweir return aRes;
221cdf0e10cSrcweir }
222cdf0e10cSrcweir
223cdf0e10cSrcweir // -----------------------------------------------------------------------------
getJavaVM(const Reference<XMultiServiceFactory> & _rxFactory)224cdf0e10cSrcweir ::rtl::Reference< jvmaccess::VirtualMachine > getJavaVM(const Reference<XMultiServiceFactory >& _rxFactory)
225cdf0e10cSrcweir {
226cdf0e10cSrcweir ::rtl::Reference< jvmaccess::VirtualMachine > aRet;
227cdf0e10cSrcweir OSL_ENSURE(_rxFactory.is(),"No XMultiServiceFactory a.v.!");
228cdf0e10cSrcweir if(!_rxFactory.is())
229cdf0e10cSrcweir return aRet;
230cdf0e10cSrcweir
231cdf0e10cSrcweir try
232cdf0e10cSrcweir {
233cdf0e10cSrcweir Reference< starjava::XJavaVM > xVM(_rxFactory->createInstance(
234cdf0e10cSrcweir rtl::OUString::createFromAscii("com.sun.star.java.JavaVirtualMachine")), UNO_QUERY);
235cdf0e10cSrcweir
236cdf0e10cSrcweir OSL_ENSURE(_rxFactory.is(),"InitJava: I have no factory!");
237cdf0e10cSrcweir if (!xVM.is() || !_rxFactory.is())
238cdf0e10cSrcweir throw Exception(); // -2;
239cdf0e10cSrcweir
240cdf0e10cSrcweir Sequence<sal_Int8> processID(16);
241cdf0e10cSrcweir rtl_getGlobalProcessId( (sal_uInt8*) processID.getArray() );
242cdf0e10cSrcweir processID.realloc(17);
243cdf0e10cSrcweir processID[16] = 0;
244cdf0e10cSrcweir
245cdf0e10cSrcweir Any uaJVM = xVM->getJavaVM( processID );
246cdf0e10cSrcweir
247cdf0e10cSrcweir if (!uaJVM.hasValue())
248cdf0e10cSrcweir throw Exception(); // -5
249cdf0e10cSrcweir else
250cdf0e10cSrcweir {
251cdf0e10cSrcweir sal_Int32 nValue = 0;
252cdf0e10cSrcweir jvmaccess::VirtualMachine* pJVM = NULL;
253cdf0e10cSrcweir if ( uaJVM >>= nValue )
254cdf0e10cSrcweir pJVM = reinterpret_cast< jvmaccess::VirtualMachine* > (nValue);
255cdf0e10cSrcweir else
256cdf0e10cSrcweir {
257cdf0e10cSrcweir sal_Int64 nTemp = 0;
258cdf0e10cSrcweir uaJVM >>= nTemp;
259cdf0e10cSrcweir pJVM = reinterpret_cast< jvmaccess::VirtualMachine* > (nTemp);
260cdf0e10cSrcweir }
261cdf0e10cSrcweir aRet = pJVM;
262cdf0e10cSrcweir }
263cdf0e10cSrcweir }
264cdf0e10cSrcweir catch (Exception&)
265cdf0e10cSrcweir {
266cdf0e10cSrcweir }
267cdf0e10cSrcweir
268cdf0e10cSrcweir return aRet;
269cdf0e10cSrcweir }
270cdf0e10cSrcweir //------------------------------------------------------------------------------
existsJavaClassByName(const::rtl::Reference<jvmaccess::VirtualMachine> & _pJVM,const::rtl::OUString & _sClassName)271cdf0e10cSrcweir sal_Bool existsJavaClassByName( const ::rtl::Reference< jvmaccess::VirtualMachine >& _pJVM,const ::rtl::OUString& _sClassName )
272cdf0e10cSrcweir {
273cdf0e10cSrcweir sal_Bool bRet = sal_False;
274cdf0e10cSrcweir #ifdef SOLAR_JAVA
275cdf0e10cSrcweir if ( _pJVM.is() )
276cdf0e10cSrcweir {
277cdf0e10cSrcweir jvmaccess::VirtualMachine::AttachGuard aGuard(_pJVM);
278cdf0e10cSrcweir JNIEnv* pEnv = aGuard.getEnvironment();
279cdf0e10cSrcweir if( pEnv )
280cdf0e10cSrcweir {
281cdf0e10cSrcweir ::rtl::OString sClassName = ::rtl::OUStringToOString(_sClassName, RTL_TEXTENCODING_ASCII_US);
282cdf0e10cSrcweir sClassName = sClassName.replace('.','/');
283*24c56ab9SHerbert Dürr jobject out = pEnv->FindClass( sClassName.getStr());
284cdf0e10cSrcweir bRet = out != NULL;
285cdf0e10cSrcweir pEnv->DeleteLocalRef( out );
286cdf0e10cSrcweir }
287cdf0e10cSrcweir }
288cdf0e10cSrcweir #endif
289cdf0e10cSrcweir return bRet;
290cdf0e10cSrcweir }
291cdf0e10cSrcweir
292cdf0e10cSrcweir }
293cdf0e10cSrcweir
294cdf0e10cSrcweir #include <ctype.h> //isdigit
295cdf0e10cSrcweir namespace dbtools
296cdf0e10cSrcweir {
297cdf0e10cSrcweir //------------------------------------------------------------------
isCharOk(sal_Unicode c,const::rtl::OUString & _rSpecials)298cdf0e10cSrcweir sal_Bool isCharOk(sal_Unicode c,const ::rtl::OUString& _rSpecials)
299cdf0e10cSrcweir {
300cdf0e10cSrcweir
301cdf0e10cSrcweir return ( ((c >= 97) && (c <= 122)) || ((c >= 65) && (c <= 90)) || ((c >= 48) && (c <= 57)) ||
302cdf0e10cSrcweir c == '_' || _rSpecials.indexOf(c) != -1);
303cdf0e10cSrcweir }
304cdf0e10cSrcweir
305cdf0e10cSrcweir //------------------------------------------------------------------------------
isValidSQLName(const::rtl::OUString & rName,const::rtl::OUString & _rSpecials)306cdf0e10cSrcweir sal_Bool isValidSQLName(const ::rtl::OUString& rName,const ::rtl::OUString& _rSpecials)
307cdf0e10cSrcweir {
308cdf0e10cSrcweir // Ueberpruefung auf korrekte Namensgebung im SQL Sinne
309cdf0e10cSrcweir // Dieses ist wichtig fuer Tabellennamen beispielsweise
310cdf0e10cSrcweir const sal_Unicode* pStr = rName.getStr();
311cdf0e10cSrcweir if (*pStr > 127 || isdigit(*pStr))
312cdf0e10cSrcweir return sal_False;
313cdf0e10cSrcweir
314cdf0e10cSrcweir for (; *pStr; ++pStr )
315cdf0e10cSrcweir if(!isCharOk(*pStr,_rSpecials))
316cdf0e10cSrcweir return sal_False;
317cdf0e10cSrcweir
318cdf0e10cSrcweir if ( rName.getLength()
319cdf0e10cSrcweir && ( (rName.toChar() == '_')
320cdf0e10cSrcweir || ( (rName.toChar() >= '0')
321cdf0e10cSrcweir && (rName.toChar() <= '9')
322cdf0e10cSrcweir )
323cdf0e10cSrcweir )
324cdf0e10cSrcweir )
325cdf0e10cSrcweir return sal_False;
326cdf0e10cSrcweir // the SQL-Standard requires the first character to be an alphabetic character, which
327cdf0e10cSrcweir // isn't easy to decide in UniCode ...
328cdf0e10cSrcweir // So we just prohibit the characters which already lead to problems ....
329cdf0e10cSrcweir // 11.04.00 - 74902 - FS
330cdf0e10cSrcweir
331cdf0e10cSrcweir return sal_True;
332cdf0e10cSrcweir }
333cdf0e10cSrcweir //------------------------------------------------------------------
334cdf0e10cSrcweir // Erzeugt einen neuen Namen falls noetig
convertName2SQLName(const::rtl::OUString & rName,const::rtl::OUString & _rSpecials)335cdf0e10cSrcweir ::rtl::OUString convertName2SQLName(const ::rtl::OUString& rName,const ::rtl::OUString& _rSpecials)
336cdf0e10cSrcweir {
337cdf0e10cSrcweir if(isValidSQLName(rName,_rSpecials))
338cdf0e10cSrcweir return rName;
339cdf0e10cSrcweir ::rtl::OUString aNewName(rName);
340cdf0e10cSrcweir const sal_Unicode* pStr = rName.getStr();
341cdf0e10cSrcweir sal_Int32 nLength = rName.getLength();
342cdf0e10cSrcweir sal_Bool bValid(*pStr < 128 && !isdigit(*pStr));
343cdf0e10cSrcweir for (sal_Int32 i=0; bValid && i < nLength; ++pStr,++i )
344cdf0e10cSrcweir if(!isCharOk(*pStr,_rSpecials))
345cdf0e10cSrcweir {
346cdf0e10cSrcweir aNewName = aNewName.replace(*pStr,'_');
347cdf0e10cSrcweir pStr = aNewName.getStr() + i;
348cdf0e10cSrcweir }
349cdf0e10cSrcweir
350cdf0e10cSrcweir if ( !bValid )
351cdf0e10cSrcweir aNewName = ::rtl::OUString();
352cdf0e10cSrcweir
353cdf0e10cSrcweir return aNewName;
354cdf0e10cSrcweir }
355cdf0e10cSrcweir //------------------------------------------------------------------------------
quoteName(const::rtl::OUString & _rQuote,const::rtl::OUString & _rName)356cdf0e10cSrcweir ::rtl::OUString quoteName(const ::rtl::OUString& _rQuote, const ::rtl::OUString& _rName)
357cdf0e10cSrcweir {
358cdf0e10cSrcweir ::rtl::OUString sName = _rName;
359cdf0e10cSrcweir if(_rQuote.getLength() && _rQuote.toChar() != ' ')
360cdf0e10cSrcweir sName = _rQuote + _rName + _rQuote;
361cdf0e10cSrcweir return sName;
362cdf0e10cSrcweir }
363cdf0e10cSrcweir
364cdf0e10cSrcweir
365cdf0e10cSrcweir }
366