| /************************************************************** |
| * |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (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.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, |
| * software distributed under the License is distributed on an |
| * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| * KIND, either express or implied. See the License for the |
| * specific language governing permissions and limitations |
| * under the License. |
| * |
| *************************************************************/ |
| |
| |
| |
| // MARKER(update_precomp.py): autogen include statement, do not remove |
| #include "precompiled_connectivity.hxx" |
| |
| #include <cstdarg> |
| #include "java/tools.hxx" |
| #include "java/lang/String.hxx" |
| #include "java/lang/Class.hxx" |
| #include "java/util/Property.hxx" |
| #include <com/sun/star/sdbc/DriverPropertyInfo.hpp> |
| #include <com/sun/star/container/XNameAccess.hpp> |
| #include <connectivity/dbexception.hxx> |
| |
| using namespace connectivity; |
| using namespace ::com::sun::star::uno; |
| using namespace ::com::sun::star::beans; |
| // using namespace ::com::sun::star::sdbcx; |
| using namespace ::com::sun::star::sdbc; |
| using namespace ::com::sun::star::container; |
| using namespace ::com::sun::star::lang; |
| |
| void java_util_Properties::setProperty(const ::rtl::OUString key, const ::rtl::OUString& value) |
| { |
| SDBThreadAttach t; OSL_ENSURE(t.pEnv,"Java Enviroment geloescht worden!"); |
| jobject out(0); |
| |
| { |
| jvalue args[2]; |
| // Parameter konvertieren |
| args[0].l = convertwchar_tToJavaString(t.pEnv,key); |
| args[1].l = convertwchar_tToJavaString(t.pEnv,value); |
| // temporaere Variable initialisieren |
| static const char * cSignature = "(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/Object;"; |
| static const char * cMethodName = "setProperty"; |
| // Java-Call absetzen |
| static jmethodID mID(NULL); |
| obtainMethodId(t.pEnv, cMethodName,cSignature, mID); |
| out = t.pEnv->CallObjectMethod(object, mID, args[0].l,args[1].l); |
| ThrowSQLException(t.pEnv,NULL); |
| t.pEnv->DeleteLocalRef((jstring)args[1].l); |
| t.pEnv->DeleteLocalRef((jstring)args[0].l); |
| ThrowSQLException(t.pEnv,0); |
| if(out) |
| t.pEnv->DeleteLocalRef(out); |
| } //t.pEnv |
| // ACHTUNG: der Aufrufer wird Eigentuemer des zurueckgelieferten Zeigers !!! |
| } |
| jclass java_util_Properties::theClass = 0; |
| |
| java_util_Properties::~java_util_Properties() |
| {} |
| |
| jclass java_util_Properties::getMyClass() const |
| { |
| // die Klasse muss nur einmal geholt werden, daher statisch |
| if( !theClass ) |
| theClass = findMyClass("java/util/Properties"); |
| return theClass; |
| } |
| |
| //-------------------------------------------------------------------------- |
| java_util_Properties::java_util_Properties( ): java_lang_Object( NULL, (jobject)NULL ) |
| { |
| SDBThreadAttach t; |
| if( !t.pEnv ) |
| return; |
| // Java-Call fuer den Konstruktor absetzen |
| // temporaere Variable initialisieren |
| static const char * cSignature = "()V"; |
| jobject tempObj; |
| static jmethodID mID(NULL); |
| obtainMethodId(t.pEnv, "<init>",cSignature, mID); |
| tempObj = t.pEnv->NewObject( getMyClass(), mID); |
| saveRef( t.pEnv, tempObj ); |
| t.pEnv->DeleteLocalRef( tempObj ); |
| } |
| |
| // -------------------------------------------------------------------------------- |
| jstring connectivity::convertwchar_tToJavaString(JNIEnv *pEnv,const ::rtl::OUString& _rTemp) |
| { |
| OSL_ENSURE(pEnv,"Environment is NULL!"); |
| jstring pStr = pEnv->NewString(_rTemp.getStr(), _rTemp.getLength()); |
| pEnv->ExceptionClear(); |
| OSL_ENSURE(pStr,"Could not create a jsstring object!"); |
| return pStr; |
| } |
| |
| // -------------------------------------------------------------------------------- |
| java_util_Properties* connectivity::createStringPropertyArray(const Sequence< PropertyValue >& info ) throw(SQLException, RuntimeException) |
| { |
| java_util_Properties* pProps = new java_util_Properties(); |
| const PropertyValue* pBegin = info.getConstArray(); |
| const PropertyValue* pEnd = pBegin + info.getLength(); |
| |
| for(;pBegin != pEnd;++pBegin) |
| { |
| // this is a special property to find the jdbc driver |
| if ( pBegin->Name.compareToAscii( "JavaDriverClass" ) |
| && pBegin->Name.compareToAscii( "JavaDriverClassPath" ) |
| && pBegin->Name.compareToAscii( "SystemProperties" ) |
| && pBegin->Name.compareToAscii( "CharSet" ) |
| && pBegin->Name.compareToAscii( "AppendTableAliasName" ) |
| && pBegin->Name.compareToAscii( "AddIndexAppendix" ) |
| && pBegin->Name.compareToAscii( "FormsCheckRequiredFields" ) |
| && pBegin->Name.compareToAscii( "GenerateASBeforeCorrelationName" ) |
| && pBegin->Name.compareToAscii( "EscapeDateTime" ) |
| && pBegin->Name.compareToAscii( "ParameterNameSubstitution" ) |
| && pBegin->Name.compareToAscii( "IsPasswordRequired" ) |
| && pBegin->Name.compareToAscii( "IsAutoRetrievingEnabled" ) |
| && pBegin->Name.compareToAscii( "AutoRetrievingStatement" ) |
| && pBegin->Name.compareToAscii( "UseCatalogInSelect" ) |
| && pBegin->Name.compareToAscii( "UseSchemaInSelect" ) |
| && pBegin->Name.compareToAscii( "AutoIncrementCreation" ) |
| && pBegin->Name.compareToAscii( "Extension" ) |
| && pBegin->Name.compareToAscii( "NoNameLengthLimit" ) |
| && pBegin->Name.compareToAscii( "EnableSQL92Check" ) |
| && pBegin->Name.compareToAscii( "EnableOuterJoinEscape" ) |
| && pBegin->Name.compareToAscii( "BooleanComparisonMode" ) |
| && pBegin->Name.compareToAscii( "IgnoreCurrency" ) |
| && pBegin->Name.compareToAscii( "TypeInfoSettings" ) |
| && pBegin->Name.compareToAscii( "IgnoreDriverPrivileges" ) |
| && pBegin->Name.compareToAscii( "ImplicitCatalogRestriction" ) |
| && pBegin->Name.compareToAscii( "ImplicitSchemaRestriction" ) |
| && pBegin->Name.compareToAscii( "SupportsTableCreation" ) |
| && pBegin->Name.compareToAscii( "UseJava" ) |
| && pBegin->Name.compareToAscii( "Authentication" ) |
| && pBegin->Name.compareToAscii( "PreferDosLikeLineEnds" ) |
| && pBegin->Name.compareToAscii( "PrimaryKeySupport" ) |
| && pBegin->Name.compareToAscii( "RespectDriverResultSetType" ) |
| ) |
| { |
| ::rtl::OUString aStr; |
| OSL_VERIFY( pBegin->Value >>= aStr ); |
| pProps->setProperty(pBegin->Name,aStr); |
| } |
| } |
| return pProps; |
| } |
| // -------------------------------------------------------------------------------- |
| ::rtl::OUString connectivity::JavaString2String(JNIEnv *pEnv,jstring _Str) |
| { |
| ::rtl::OUString aStr; |
| if(_Str) |
| { |
| jboolean bCopy(sal_True); |
| const jchar* pChar = pEnv->GetStringChars(_Str,&bCopy); |
| jsize len = pEnv->GetStringLength(_Str); |
| aStr = ::rtl::OUString(pChar,len); |
| |
| if(bCopy) |
| pEnv->ReleaseStringChars(_Str,pChar); |
| pEnv->DeleteLocalRef(_Str); |
| } |
| return aStr; |
| } |
| // -------------------------------------------------------------------------------- |
| jobject connectivity::convertTypeMapToJavaMap(JNIEnv* /*pEnv*/,const Reference< ::com::sun::star::container::XNameAccess > & _rMap) |
| { |
| if ( _rMap.is() ) |
| { |
| ::com::sun::star::uno::Sequence< ::rtl::OUString > aNames = _rMap->getElementNames(); |
| if ( aNames.getLength() > 0 ) |
| ::dbtools::throwFeatureNotImplementedException( "Type maps", NULL ); |
| } |
| return 0; |
| } |
| // ----------------------------------------------------------------------------- |
| sal_Bool connectivity::isExceptionOccured(JNIEnv *pEnv,sal_Bool _bClear) |
| { |
| if ( !pEnv ) |
| return sal_False; |
| |
| jthrowable pThrowable = pEnv->ExceptionOccurred(); |
| sal_Bool bRet = pThrowable != NULL; |
| if ( pThrowable ) |
| { |
| if ( _bClear ) |
| pEnv->ExceptionClear(); |
| #if OSL_DEBUG_LEVEL > 1 |
| if(pEnv->IsInstanceOf(pThrowable,java_sql_SQLException_BASE::st_getMyClass())) |
| { |
| |
| java_sql_SQLException_BASE* pException = new java_sql_SQLException_BASE(pEnv,pThrowable); |
| ::rtl::OUString sError = pException->getMessage(); |
| delete pException; |
| } |
| #else |
| pEnv->DeleteLocalRef(pThrowable); |
| #endif |
| |
| } |
| |
| return bRet; |
| } |
| // ----------------------------------------------------------------------------- |
| jobject connectivity::createByteInputStream(const ::com::sun::star::uno::Reference< ::com::sun::star::io::XInputStream >& x,sal_Int32 length) |
| { |
| SDBThreadAttach t; |
| if( !t.pEnv || !x.is() ) |
| return NULL; |
| // Java-Call fuer den Konstruktor absetzen |
| // temporaere Variable initialisieren |
| jclass clazz = java_lang_Object::findMyClass("java/io/ByteArrayInputStream"); |
| static jmethodID mID(NULL); |
| if ( !mID ) |
| { |
| static const char * cSignature = "([B)V"; |
| mID = t.pEnv->GetMethodID( clazz, "<init>", cSignature ); |
| OSL_ENSURE( mID, cSignature ); |
| if ( !mID ) |
| throw SQLException(); |
| } // if ( !_inout_MethodID ) |
| jbyteArray pByteArray = t.pEnv->NewByteArray(length); |
| Sequence< sal_Int8 > aData; |
| x->readBytes(aData,length); |
| jboolean p = sal_False; |
| rtl_copyMemory(t.pEnv->GetByteArrayElements(pByteArray,&p),aData.getArray(),aData.getLength()); |
| jobject out = t.pEnv->NewObject( clazz, mID,pByteArray); |
| t.pEnv->DeleteLocalRef((jbyteArray)pByteArray); |
| return out; |
| } |
| // ----------------------------------------------------------------------------- |
| jobject connectivity::createCharArrayReader(const ::com::sun::star::uno::Reference< ::com::sun::star::io::XInputStream >& x,sal_Int32 length) |
| { |
| SDBThreadAttach t; |
| if( !t.pEnv || !x.is() ) |
| return NULL; |
| // Java-Call fuer den Konstruktor absetzen |
| // temporaere Variable initialisieren |
| jclass clazz = java_lang_Object::findMyClass("java/io/CharArrayReader"); |
| static jmethodID mID(NULL); |
| if ( !mID ) |
| { |
| static const char * cSignature = "([C)V"; |
| mID = t.pEnv->GetMethodID( clazz, "<init>", cSignature ); |
| OSL_ENSURE( mID, cSignature ); |
| if ( !mID ) |
| throw SQLException(); |
| } // if ( !_inout_MethodID ) |
| jcharArray pCharArray = t.pEnv->NewCharArray(length); |
| Sequence< sal_Int8 > aData; |
| x->readBytes(aData,length); |
| jboolean p = sal_False; |
| rtl_copyMemory(t.pEnv->GetCharArrayElements(pCharArray,&p),aData.getArray(),aData.getLength()); |
| jobject out = t.pEnv->NewObject( clazz, mID,pCharArray); |
| t.pEnv->DeleteLocalRef((jcharArray)pCharArray); |
| return out; |
| } |
| // ----------------------------------------------------------------------------- |
