353 lines
15 KiB
C++
353 lines
15 KiB
C++
/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
|
|
/*
|
|
* This file is part of the LibreOffice project.
|
|
*
|
|
* This Source Code Form is subject to the terms of the Mozilla Public
|
|
* License, v. 2.0. If a copy of the MPL was not distributed with this
|
|
* file, You can obtain one at http://mozilla.org/MPL/2.0/.
|
|
*
|
|
* This file incorporates work covered by the following license notice:
|
|
*
|
|
* 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 .
|
|
*/
|
|
|
|
#include <java/sql/CallableStatement.hxx>
|
|
#include <java/tools.hxx>
|
|
#include <java/sql/Array.hxx>
|
|
#include <java/sql/Clob.hxx>
|
|
#include <java/sql/Blob.hxx>
|
|
#include <java/sql/Connection.hxx>
|
|
#include <java/sql/Ref.hxx>
|
|
#include <java/sql/Timestamp.hxx>
|
|
#include <cppuhelper/typeprovider.hxx>
|
|
#include <cppuhelper/queryinterface.hxx>
|
|
#include <comphelper/sequence.hxx>
|
|
|
|
#include <string.h>
|
|
|
|
using namespace connectivity;
|
|
using namespace ::com::sun::star::uno;
|
|
using namespace ::com::sun::star::sdbc;
|
|
using namespace ::com::sun::star::container;
|
|
using namespace ::com::sun::star::lang;
|
|
|
|
|
|
IMPLEMENT_SERVICE_INFO(java_sql_CallableStatement,u"com.sun.star.sdbcx.ACallableStatement"_ustr,u"com.sun.star.sdbc.CallableStatement"_ustr);
|
|
|
|
|
|
//************ Class: java.sql.CallableStatement
|
|
|
|
java_sql_CallableStatement::java_sql_CallableStatement( JNIEnv * pEnv, java_sql_Connection& _rCon,const OUString& sql )
|
|
: java_sql_PreparedStatement( pEnv, _rCon, sql )
|
|
{
|
|
}
|
|
|
|
java_sql_CallableStatement::~java_sql_CallableStatement()
|
|
{
|
|
}
|
|
|
|
|
|
Any SAL_CALL java_sql_CallableStatement::queryInterface( const Type & rType )
|
|
{
|
|
Any aRet = java_sql_PreparedStatement::queryInterface(rType);
|
|
return aRet.hasValue() ? aRet : ::cppu::queryInterface(rType,static_cast< css::sdbc::XRow*>(this),static_cast< css::sdbc::XOutParameters*>(this));
|
|
}
|
|
|
|
css::uno::Sequence< css::uno::Type > SAL_CALL java_sql_CallableStatement::getTypes( )
|
|
{
|
|
::cppu::OTypeCollection aTypes( cppu::UnoType<css::sdbc::XRow>::get(),
|
|
cppu::UnoType<css::sdbc::XOutParameters>::get());
|
|
|
|
return ::comphelper::concatSequences(aTypes.getTypes(),java_sql_PreparedStatement::getTypes());
|
|
}
|
|
|
|
sal_Bool SAL_CALL java_sql_CallableStatement::wasNull( )
|
|
{
|
|
SDBThreadAttach t; OSL_ENSURE(t.pEnv,"Java environment has been deleted!");
|
|
createStatement(t.pEnv);
|
|
static jmethodID mID(nullptr);
|
|
return callBooleanMethod( "wasNull", mID );
|
|
}
|
|
|
|
sal_Bool SAL_CALL java_sql_CallableStatement::getBoolean( sal_Int32 columnIndex )
|
|
{
|
|
SDBThreadAttach t; OSL_ENSURE(t.pEnv,"Java environment has been deleted!");
|
|
createStatement(t.pEnv);
|
|
static jmethodID mID(nullptr);
|
|
return callBooleanMethodWithIntArg( "getBoolean", mID,columnIndex );
|
|
}
|
|
sal_Int8 SAL_CALL java_sql_CallableStatement::getByte( sal_Int32 columnIndex )
|
|
{
|
|
SDBThreadAttach t; OSL_ENSURE(t.pEnv,"Java environment has been deleted!");
|
|
createStatement(t.pEnv);
|
|
static jmethodID mID(nullptr);
|
|
jbyte (JNIEnv::* const pCallMethod)( jobject obj, jmethodID methodID, ... ) = &JNIEnv::CallByteMethod;
|
|
return callMethodWithIntArg<jbyte>(pCallMethod,"getByte","(I)B",mID,columnIndex);
|
|
}
|
|
Sequence< sal_Int8 > SAL_CALL java_sql_CallableStatement::getBytes( sal_Int32 columnIndex )
|
|
{
|
|
::osl::MutexGuard aGuard( m_aMutex );
|
|
checkDisposed(java_sql_Statement_BASE::rBHelper.bDisposed);
|
|
Sequence< sal_Int8 > aSeq;
|
|
|
|
SDBThreadAttach t; OSL_ENSURE(t.pEnv,"Java environment has been deleted!");
|
|
createStatement(t.pEnv);
|
|
static jmethodID mID(nullptr);
|
|
jbyteArray out = static_cast<jbyteArray>(callObjectMethodWithIntArg(t.pEnv,"getBytes","(I)[B", mID, columnIndex));
|
|
if (out)
|
|
{
|
|
jboolean p = false;
|
|
aSeq.realloc(t.pEnv->GetArrayLength(out));
|
|
memcpy(aSeq.getArray(),t.pEnv->GetByteArrayElements(out,&p),aSeq.getLength());
|
|
t.pEnv->DeleteLocalRef(out);
|
|
}
|
|
return aSeq;
|
|
}
|
|
css::util::Date SAL_CALL java_sql_CallableStatement::getDate( sal_Int32 columnIndex )
|
|
{
|
|
SDBThreadAttach t; OSL_ENSURE(t.pEnv,"Java environment has been deleted!");
|
|
createStatement(t.pEnv);
|
|
static jmethodID mID(nullptr);
|
|
jobject out = callObjectMethodWithIntArg(t.pEnv,"getDate","(I)Ljava/sql/Date;", mID, columnIndex);
|
|
return out ? static_cast <css::util::Date>(java_sql_Date( t.pEnv, out )) : css::util::Date();
|
|
}
|
|
double SAL_CALL java_sql_CallableStatement::getDouble( sal_Int32 columnIndex )
|
|
{
|
|
SDBThreadAttach t; OSL_ENSURE(t.pEnv,"Java environment has been deleted!");
|
|
createStatement(t.pEnv);
|
|
static jmethodID mID(nullptr);
|
|
double (JNIEnv::* const pCallMethod)( jobject obj, jmethodID methodID, ... ) = &JNIEnv::CallDoubleMethod;
|
|
return callMethodWithIntArg<double>(pCallMethod,"getDouble","(I)D",mID,columnIndex);
|
|
}
|
|
|
|
float SAL_CALL java_sql_CallableStatement::getFloat( sal_Int32 columnIndex )
|
|
{
|
|
SDBThreadAttach t; OSL_ENSURE(t.pEnv,"Java environment has been deleted!");
|
|
createStatement(t.pEnv);
|
|
static jmethodID mID(nullptr);
|
|
jfloat (JNIEnv::* const pCallMethod)( jobject obj, jmethodID methodID, ... ) = &JNIEnv::CallFloatMethod;
|
|
return callMethodWithIntArg<jfloat>(pCallMethod,"getFloat","(I)F",mID,columnIndex);
|
|
}
|
|
|
|
sal_Int32 SAL_CALL java_sql_CallableStatement::getInt( sal_Int32 columnIndex )
|
|
{
|
|
SDBThreadAttach t; OSL_ENSURE(t.pEnv,"Java environment has been deleted!");
|
|
createStatement(t.pEnv);
|
|
static jmethodID mID(nullptr);
|
|
return callIntMethodWithIntArg_ThrowSQL("getInt",mID,columnIndex);
|
|
}
|
|
|
|
sal_Int64 SAL_CALL java_sql_CallableStatement::getLong( sal_Int32 columnIndex )
|
|
{
|
|
SDBThreadAttach t; OSL_ENSURE(t.pEnv,"Java environment has been deleted!");
|
|
createStatement(t.pEnv);
|
|
static jmethodID mID(nullptr);
|
|
jlong (JNIEnv::* const pCallMethod)( jobject obj, jmethodID methodID, ... ) = &JNIEnv::CallLongMethod;
|
|
return callMethodWithIntArg<jlong>(pCallMethod,"getLong","(I)J",mID,columnIndex);
|
|
}
|
|
|
|
Any SAL_CALL java_sql_CallableStatement::getObject( sal_Int32 columnIndex, const Reference< css::container::XNameAccess >& /*typeMap*/ )
|
|
{
|
|
SDBThreadAttach t; OSL_ENSURE(t.pEnv,"Java environment has been deleted!");
|
|
createStatement(t.pEnv);
|
|
static jmethodID mID(nullptr);
|
|
callObjectMethodWithIntArg(t.pEnv,"getObject","(I)Ljava/lang/Object;", mID, columnIndex);
|
|
// WARNING: the caller becomes the owner of the returned pointer
|
|
return Any();
|
|
}
|
|
|
|
sal_Int16 SAL_CALL java_sql_CallableStatement::getShort( sal_Int32 columnIndex )
|
|
{
|
|
SDBThreadAttach t; OSL_ENSURE(t.pEnv,"Java environment has been deleted!");
|
|
createStatement(t.pEnv);
|
|
static jmethodID mID(nullptr);
|
|
jshort (JNIEnv::* const pCallMethod)( jobject obj, jmethodID methodID, ... ) = &JNIEnv::CallShortMethod;
|
|
return callMethodWithIntArg<jshort>(pCallMethod,"getShort","(I)S",mID,columnIndex);
|
|
}
|
|
|
|
OUString SAL_CALL java_sql_CallableStatement::getString( sal_Int32 columnIndex )
|
|
{
|
|
::osl::MutexGuard aGuard( m_aMutex );
|
|
checkDisposed(java_sql_Statement_BASE::rBHelper.bDisposed);
|
|
SDBThreadAttach t; OSL_ENSURE(t.pEnv,"Java environment has been deleted!");
|
|
createStatement(t.pEnv);
|
|
static jmethodID mID(nullptr);
|
|
return callStringMethodWithIntArg("getString",mID,columnIndex);
|
|
}
|
|
|
|
css::util::Time SAL_CALL java_sql_CallableStatement::getTime( sal_Int32 columnIndex )
|
|
{
|
|
SDBThreadAttach t; OSL_ENSURE(t.pEnv,"Java environment has been deleted!");
|
|
createStatement(t.pEnv);
|
|
static jmethodID mID(nullptr);
|
|
jobject out = callObjectMethodWithIntArg(t.pEnv,"getTime","(I)Ljava/sql/Time;", mID, columnIndex);
|
|
// WARNING: the caller becomes the owner of the returned pointer
|
|
return out ? static_cast <css::util::Time> (java_sql_Time( t.pEnv, out )) : css::util::Time();
|
|
}
|
|
|
|
css::util::DateTime SAL_CALL java_sql_CallableStatement::getTimestamp( sal_Int32 columnIndex )
|
|
{
|
|
SDBThreadAttach t; OSL_ENSURE(t.pEnv,"Java environment has been deleted!");
|
|
createStatement(t.pEnv);
|
|
static jmethodID mID(nullptr);
|
|
jobject out = callObjectMethodWithIntArg(t.pEnv,"getTimestamp","(I)Ljava/sql/Timestamp;", mID, columnIndex);
|
|
// WARNING: the caller becomes the owner of the returned pointer
|
|
return out ? static_cast <css::util::DateTime> (java_sql_Timestamp( t.pEnv, out )) : css::util::DateTime();
|
|
}
|
|
|
|
void SAL_CALL java_sql_CallableStatement::registerOutParameter( sal_Int32 parameterIndex, sal_Int32 sqlType, const OUString& typeName )
|
|
{
|
|
::osl::MutexGuard aGuard( m_aMutex );
|
|
checkDisposed(java_sql_Statement_BASE::rBHelper.bDisposed);
|
|
SDBThreadAttach t; OSL_ENSURE(t.pEnv,"Java environment has been deleted!");
|
|
|
|
{
|
|
createStatement(t.pEnv);
|
|
|
|
// initialize temporary variable
|
|
static const char * const cSignature = "(IILjava/lang/String;)V";
|
|
static const char * const cMethodName = "registerOutParameter";
|
|
// execute Java-Call
|
|
static jmethodID mID(nullptr);
|
|
obtainMethodId_throwSQL(t.pEnv, cMethodName,cSignature, mID);
|
|
// Convert Parameter
|
|
jdbc::LocalRef< jstring > str( t.env(),convertwchar_tToJavaString(t.pEnv,typeName));
|
|
t.pEnv->CallVoidMethod( object, mID, parameterIndex,sqlType,str.get());
|
|
ThrowLoggedSQLException( m_aLogger, t.pEnv, *this );
|
|
}
|
|
}
|
|
void SAL_CALL java_sql_CallableStatement::registerNumericOutParameter( sal_Int32 parameterIndex, sal_Int32 sqlType, sal_Int32 scale )
|
|
{
|
|
::osl::MutexGuard aGuard( m_aMutex );
|
|
checkDisposed(java_sql_Statement_BASE::rBHelper.bDisposed);
|
|
SDBThreadAttach t; OSL_ENSURE(t.pEnv,"Java environment has been deleted!");
|
|
|
|
{
|
|
createStatement(t.pEnv);
|
|
// initialize temporary variable
|
|
static const char * const cSignature = "(III)V";
|
|
static const char * const cMethodName = "registerOutParameter";
|
|
// execute Java-Call
|
|
static jmethodID mID(nullptr);
|
|
obtainMethodId_throwSQL(t.pEnv, cMethodName,cSignature, mID);
|
|
t.pEnv->CallVoidMethod( object, mID, parameterIndex,sqlType,scale);
|
|
ThrowLoggedSQLException( m_aLogger, t.pEnv, *this );
|
|
}
|
|
}
|
|
|
|
jclass java_sql_CallableStatement::theClass = nullptr;
|
|
|
|
jclass java_sql_CallableStatement::getMyClass() const
|
|
{
|
|
// the class must be fetched only once, therefore static
|
|
if( !theClass )
|
|
theClass = findMyClass("java/sql/CallableStatement");
|
|
return theClass;
|
|
}
|
|
|
|
Reference< css::io::XInputStream > SAL_CALL java_sql_CallableStatement::getBinaryStream( sal_Int32 columnIndex )
|
|
{
|
|
Reference< css::sdbc::XBlob > xBlob = getBlob(columnIndex);
|
|
return xBlob.is() ? xBlob->getBinaryStream() : Reference< css::io::XInputStream >();
|
|
}
|
|
Reference< css::io::XInputStream > SAL_CALL java_sql_CallableStatement::getCharacterStream( sal_Int32 columnIndex )
|
|
{
|
|
Reference< css::sdbc::XClob > xClob = getClob(columnIndex);
|
|
return xClob.is() ? xClob->getCharacterStream() : Reference< css::io::XInputStream >();
|
|
}
|
|
|
|
Reference< css::sdbc::XArray > SAL_CALL java_sql_CallableStatement::getArray( sal_Int32 columnIndex )
|
|
{
|
|
SDBThreadAttach t; OSL_ENSURE(t.pEnv,"Java environment has been deleted!");
|
|
createStatement(t.pEnv);
|
|
static jmethodID mID(nullptr);
|
|
jobject out = callObjectMethodWithIntArg(t.pEnv,"getArray","(I)Ljava/sql/Array;", mID, columnIndex);
|
|
// WARNING: the caller becomes the owner of the returned pointer
|
|
return out==nullptr ? nullptr : new java_sql_Array( t.pEnv, out );
|
|
}
|
|
|
|
Reference< css::sdbc::XClob > SAL_CALL java_sql_CallableStatement::getClob( sal_Int32 columnIndex )
|
|
{
|
|
SDBThreadAttach t; OSL_ENSURE(t.pEnv,"Java environment has been deleted!");
|
|
createStatement(t.pEnv);
|
|
static jmethodID mID(nullptr);
|
|
jobject out = callObjectMethodWithIntArg(t.pEnv,"getClob","(I)Ljava/sql/Clob;", mID, columnIndex);
|
|
// WARNING: the caller becomes the owner of the returned pointer
|
|
return out==nullptr ? nullptr : new java_sql_Clob( t.pEnv, out );
|
|
}
|
|
Reference< css::sdbc::XBlob > SAL_CALL java_sql_CallableStatement::getBlob( sal_Int32 columnIndex )
|
|
{
|
|
SDBThreadAttach t; OSL_ENSURE(t.pEnv,"Java environment has been deleted!");
|
|
createStatement(t.pEnv);
|
|
static jmethodID mID(nullptr);
|
|
jobject out = callObjectMethodWithIntArg(t.pEnv,"getBlob","(I)Ljava/sql/Blob;", mID, columnIndex);
|
|
// WARNING: the caller becomes the owner of the returned pointer
|
|
return out==nullptr ? nullptr : new java_sql_Blob( t.pEnv, out );
|
|
}
|
|
|
|
Reference< css::sdbc::XRef > SAL_CALL java_sql_CallableStatement::getRef( sal_Int32 columnIndex )
|
|
{
|
|
SDBThreadAttach t; OSL_ENSURE(t.pEnv,"Java environment has been deleted!");
|
|
createStatement(t.pEnv);
|
|
static jmethodID mID(nullptr);
|
|
jobject out = callObjectMethodWithIntArg(t.pEnv,"getRef","(I)Ljava/sql/Ref;", mID, columnIndex);
|
|
// WARNING: the caller becomes the owner of the returned pointer
|
|
return out==nullptr ? nullptr : new java_sql_Ref( t.pEnv, out );
|
|
}
|
|
|
|
void SAL_CALL java_sql_CallableStatement::acquire() noexcept
|
|
{
|
|
java_sql_PreparedStatement::acquire();
|
|
}
|
|
|
|
void SAL_CALL java_sql_CallableStatement::release() noexcept
|
|
{
|
|
java_sql_PreparedStatement::release();
|
|
}
|
|
|
|
void java_sql_CallableStatement::createStatement(JNIEnv* /*_pEnv*/)
|
|
{
|
|
::osl::MutexGuard aGuard( m_aMutex );
|
|
checkDisposed(java_sql_Statement_BASE::rBHelper.bDisposed);
|
|
|
|
SDBThreadAttach t; OSL_ENSURE(t.pEnv,"Java environment has been deleted!");
|
|
if( !t.pEnv || object )
|
|
return;
|
|
|
|
// initialize temporary variable
|
|
static const char * const cMethodName = "prepareCall";
|
|
// execute Java-Call
|
|
jobject out = nullptr;
|
|
// convert Parameter
|
|
jdbc::LocalRef< jstring > str( t.env(),convertwchar_tToJavaString(t.pEnv,m_sSqlStatement));
|
|
|
|
static jmethodID mID = [&]()
|
|
{
|
|
static const char * const cSignature = "(Ljava/lang/String;II)Ljava/sql/CallableStatement;";
|
|
return t.pEnv->GetMethodID( m_pConnection->getMyClass(), cMethodName, cSignature );
|
|
}();
|
|
if( mID ){
|
|
out = t.pEnv->CallObjectMethod( m_pConnection->getJavaObject(), mID, str.get() ,m_nResultSetType,m_nResultSetConcurrency);
|
|
} //mID
|
|
else
|
|
{
|
|
static const char * const cSignature2 = "(Ljava/lang/String;)Ljava/sql/CallableStatement;";
|
|
static jmethodID mID2 = t.pEnv->GetMethodID( m_pConnection->getMyClass(), cMethodName, cSignature2 );OSL_ENSURE(mID2,"Unknown method id!");
|
|
if( mID2 ){
|
|
out = t.pEnv->CallObjectMethod( m_pConnection->getJavaObject(), mID2, str.get() );
|
|
} //mID
|
|
}
|
|
ThrowLoggedSQLException( m_aLogger, t.pEnv, *this );
|
|
|
|
if ( out )
|
|
object = t.pEnv->NewGlobalRef( out );
|
|
}
|
|
|
|
|
|
/* vim:set shiftwidth=4 softtabstop=4 expandtab: */
|