* This provides for some additional compatibility in certain DB2 versions. *
* Responsibilities: *
* With binding enabled, DB2 z/OS will throw an error: *
The statement cannot be executed because a parameter marker has been used
* in an invalid way. DB2 SQL Error: SQLCODE=-418, SQLSTATE=42610
*/
protected ExpressionOperator avgOperator() {
ExpressionOperator operator = disableAllBindingExpression();
ExpressionOperator.average().copyTo(operator);
return operator;
}
/**
* Disable binding support.
* * With binding enabled, DB2 z/OS will throw an error: *
The statement cannot be executed because a parameter marker has been used
* in an invalid way. DB2 SQL Error: SQLCODE=-418, SQLSTATE=42610
*/
protected ExpressionOperator sumOperator() {
ExpressionOperator operator = disableAllBindingExpression();
ExpressionOperator.sum().copyTo(operator);
return operator;
}
/**
* Disable binding support.
* * With binding enabled, DB2 z/OS will throw an error: *
The statement cannot be executed because a parameter marker has been used
* in an invalid way. DB2 SQL Error: SQLCODE=-418, SQLSTATE=42610
*/
protected ExpressionOperator absOperator() {
ExpressionOperator operator = disableAllBindingExpression();
ExpressionOperator.abs().copyTo(operator);
return operator;
}
/**
* DB2 z/OS requires that at least one argument be a known type
* * With binding enabled, DB2 z/OS will throw an error: *
The statement cannot be executed because a parameter marker has been used
* in an invalid way. DB2 SQL Error: SQLCODE=-418, SQLSTATE=42610
*/
@Override
protected ExpressionOperator concatOperator() {
ExpressionOperator operatorS = super.concatOperator();
ExpressionOperator operator = disableAtLeast1BindingExpression();
operatorS.copyTo(operator);
return operator;
}
/**
* DB2 z/OS requires that at least one argument be a known type
* * With binding enabled, DB2 z/OS will throw an error: *
The statement string specified as the object of a PREPARE contains a
* predicate or expression where parameter markers have been used as operands of
* the same operator for example: ? > ?. DB2 SQL Error: SQLCODE=-417, SQLSTATE=42609
*/
protected ExpressionOperator equalOperator() {
ExpressionOperator operator = disableAtLeast1BindingExpression();
ExpressionOperator.equal().copyTo(operator);
return operator;
}
/**
* DB2 z/OS requires that at least one argument be a known type
* * With binding enabled, DB2 z/OS will throw an error: *
The statement string specified as the object of a PREPARE contains a
* predicate or expression where parameter markers have been used as operands of
* the same operator for example: ? > ?. DB2 SQL Error: SQLCODE=-417, SQLSTATE=42609
*/
protected ExpressionOperator notEqualOperator() {
ExpressionOperator operator = disableAtLeast1BindingExpression();
ExpressionOperator.notEqual().copyTo(operator);
return operator;
}
/**
* DB2 z/OS requires that at least one argument be a known type
* * With binding enabled, DB2 z/OS will throw an error: *
The statement string specified as the object of a PREPARE contains a
* predicate or expression where parameter markers have been used as operands of
* the same operator for example: ? > ?. DB2 SQL Error: SQLCODE=-417, SQLSTATE=42609
*/
protected ExpressionOperator greaterThanOperator() {
ExpressionOperator operator = disableAtLeast1BindingExpression();
ExpressionOperator.greaterThan().copyTo(operator);
return operator;
}
/**
* DB2 z/OS requires that at least one argument be a known type
* * With binding enabled, DB2 z/OS will throw an error: *
The statement string specified as the object of a PREPARE contains a
* predicate or expression where parameter markers have been used as operands of
* the same operator for example: ? > ?. DB2 SQL Error: SQLCODE=-417, SQLSTATE=42609
*/
protected ExpressionOperator greaterThanEqualOperator() {
ExpressionOperator operator = disableAtLeast1BindingExpression();
ExpressionOperator.greaterThanEqual().copyTo(operator);
return operator;
}
/**
* DB2 z/OS requires that at least one argument be a known type
* * For ALL, DB2 z/OS will throw an error: *
The statement string specified as the object of a PREPARE contains a
* predicate or expression where parameter markers have been used as operands of
* the same operator for example: ? > ?. DB2 SQL Error: SQLCODE=-417, SQLSTATE=42609
*/
protected ExpressionOperator lessThanOperator() {
ExpressionOperator operator = disableAtLeast1BindingExpression();
ExpressionOperator.lessThan().copyTo(operator);
return operator;
}
/**
* DB2 z/OS requires that at least one argument be a known type
* * With binding enabled, DB2 z/OS will throw an error: *
The statement string specified as the object of a PREPARE contains a
* predicate or expression where parameter markers have been used as operands of
* the same operator for example: ? > ?. DB2 SQL Error: SQLCODE=-417, SQLSTATE=42609
*/
protected ExpressionOperator lessThanEqualOperator() {
ExpressionOperator operator = disableAtLeast1BindingExpression();
ExpressionOperator.lessThanEqual().copyTo(operator);
return operator;
}
/**
* Disable binding support.
* * With binding enabled, DB2 z/OS will throw an error: *
The statement string specified as the object of a PREPARE contains a
* predicate or expression where parameter markers have been used as operands of
* the same operator for example: ? > ?. DB2 SQL Error: SQLCODE=-417, SQLSTATE=42609
*/
protected ExpressionOperator isNullOperator() {
ExpressionOperator operator = disableAllBindingExpression();
ExpressionOperator.isNull().copyTo(operator);
return operator;
}
/**
* Disable binding support.
* * With binding enabled, DB2 z/OS will throw an error: *
The statement string specified as the object of a PREPARE contains a
* predicate or expression where parameter markers have been used as operands of
* the same operator for example: ? > ?. DB2 SQL Error: SQLCODE=-417, SQLSTATE=42609
*/
protected ExpressionOperator isNotNullOperator() {
ExpressionOperator operator = disableAllBindingExpression();
ExpressionOperator.notNull().copyTo(operator);
return operator;
}
/**
* DB2 z/OS requires that at least one argument be a known type
* * With binding enabled, DB2 z/OS will throw an error: *
The statement string specified as the object of a PREPARE contains a
* predicate or expression where parameter markers have been used as operands of
* the same operator for example: ? > ?. DB2 SQL Error: SQLCODE=-417, SQLSTATE=42609
*/
protected ExpressionOperator betweenOperator() {
ExpressionOperator operator = disableAtLeast1BindingExpression();
ExpressionOperator.between().copyTo(operator);
return operator;
}
/**
* DB2 z/OS requires that at least one argument be a known type
* * With binding enabled, DB2 z/OS will throw an error: *
The statement string specified as the object of a PREPARE contains a
* predicate or expression where parameter markers have been used as operands of
* the same operator for example: ? > ?. DB2 SQL Error: SQLCODE=-417, SQLSTATE=42609
*/
protected ExpressionOperator notBetweenOperator() {
ExpressionOperator operator = disableAtLeast1BindingExpression();
ExpressionOperator.notBetween().copyTo(operator);
return operator;
}
/**
* Disable binding support.
* * With all binding enabled, DB2 z/OS will throw an error: *
The statement cannot be executed because a parameter marker has been used
* in an invalid way. DB2 SQL Error: SQLCODE=-418, SQLSTATE=42610
* * With some binding enabled, DB2 z/OS will throw an error: *
The data type, the length, or the value of an argument of a scalar function
* is incorrect. DB2 SQL Error: SQLCODE=-171, SQLSTATE=42815
*/
protected ExpressionOperator locateOperator() {
ExpressionOperator operator = disableAllBindingExpression();
ExpressionOperator.locate().copyTo(operator);
return operator;
}
/**
* Disable binding support.
* * With all binding enabled, DB2 z/OS will throw an error: *
The statement cannot be executed because a parameter marker has been used
* in an invalid way. DB2 SQL Error: SQLCODE=-418, SQLSTATE=42610
* * With some binding enabled, DB2 z/OS will throw an error: *
The data type, the length, or the value of an argument of a scalar function
* is incorrect. DB2 SQL Error: SQLCODE=-171, SQLSTATE=42815
*/
protected ExpressionOperator locate2Operator() {
ExpressionOperator operator = disableAllBindingExpression();
ExpressionOperator.locate2().copyTo(operator);
return operator;
}
/**
* Disable binding support.
* * With all binding enabled, DB2 z/OS will throw an error: *
The statement cannot be executed because a parameter marker has been used
* in an invalid way. DB2 SQL Error: SQLCODE=-418, SQLSTATE=42610
* * With some binding enabled, DB2 z/OS will throw an error: *
The data type, the length, or the value of an argument of a scalar function
* is incorrect. DB2 SQL Error: SQLCODE=-171, SQLSTATE=42815
*/
protected ExpressionOperator modOperator() {
ExpressionOperator operator = disableAllBindingExpression();
ExpressionOperator.mod().copyTo(operator);
return operator;
}
/**
* Disable binding support.
* * With binding enabled, DB2 z/OS will throw an error: *
The statement cannot be executed because a parameter marker has been used
* in an invalid way. DB2 SQL Error: SQLCODE=-418, SQLSTATE=42610
*/
protected ExpressionOperator sqrtOperator() {
ExpressionOperator operator = disableAllBindingExpression();
ExpressionOperator.sqrt().copyTo(operator);
return operator;
}
/**
* Disable binding support.
* * With binding enabled, DB2 z/OS will throw an error: *
The statement cannot be executed because a parameter marker has been used
* in an invalid way. DB2 SQL Error: SQLCODE=-418, SQLSTATE=42610
*/
protected ExpressionOperator trimOperator() {
ExpressionOperator operator = disableAllBindingExpression();
ExpressionOperator.trim().copyTo(operator);
return operator;
}
/**
* Disable binding support.
* * With binding enabled, DB2 z/OS will throw an error: *
The data type, the length, or the value of an argument of a scalar function
* is incorrect. DB2 SQL Error: SQLCODE=-171, SQLSTATE=42815
*/
@Override
protected ExpressionOperator trim2() {
ExpressionOperator operator = disableAllBindingExpression();
ExpressionOperator.trim2().copyTo(operator);
return operator;
}
/**
* Disable binding support.
* * With binding enabled, DB2 z/OS will throw an error: *
The statement cannot be executed because a parameter marker has been used
* in an invalid way. DB2 SQL Error: SQLCODE=-418, SQLSTATE=42610
*/
protected ExpressionOperator ltrimOperator() {
ExpressionOperator operator = disableAllBindingExpression();
ExpressionOperator.leftTrim().copyTo(operator);
return operator;
}
/**
* Disable binding support.
* * With binding enabled, DB2 z/OS will throw an error: *
The data type, the length, or the value of an argument of a scalar function
* is incorrect. DB2 SQL Error: SQLCODE=-171, SQLSTATE=42815
*/
@Override
protected ExpressionOperator ltrim2Operator() {
ExpressionOperator operatorS = super.ltrim2Operator();
ExpressionOperator operator = disableAllBindingExpression();
operatorS.copyTo(operator);
return operator;
}
/**
* Disable binding support.
* * With binding enabled, DB2 z/OS will throw an error: *
The statement cannot be executed because a parameter marker has been used
* in an invalid way. DB2 SQL Error: SQLCODE=-418, SQLSTATE=42610
*/
protected ExpressionOperator rtrimOperator() {
ExpressionOperator operator = disableAllBindingExpression();
ExpressionOperator.rightTrim().copyTo(operator);
return operator;
}
/**
* Disable binding support.
* * With binding enabled, DB2 z/OS will throw an error: *
The data type, the length, or the value of an argument of a scalar function
* is incorrect. DB2 SQL Error: SQLCODE=-171, SQLSTATE=42815
*/
@Override
protected ExpressionOperator rtrim2Operator() {
ExpressionOperator operatorS = super.rtrim2Operator();
ExpressionOperator operator = disableAllBindingExpression();
operatorS.copyTo(operator);
return operator;
}
/**
* DB2 z/OS requires that at least one argument be a known type
* * With binding enabled, DB2 z/OS will throw an error: *
The statement string specified as the object of a PREPARE contains a
* predicate or expression where parameter markers have been used as operands of
* the same operator for example: ? > ?. DB2 SQL Error: SQLCODE=-417, SQLSTATE=42609
*/
protected ExpressionOperator inOperator() {
ExpressionOperator operator = new ExpressionOperator() {
@Override
public void printDuo(Expression first, Expression second, ExpressionSQLPrinter printer) {
if(!printer.getPlatform().shouldBindPartialParameters()) {
super.printDuo(first, second, printer);
return;
}
// If the first argument isn't a Constant/Parameter, this will suffice
if(!first.isValueExpression() || (first.isConstantExpression() && !printer.getPlatform().shouldBindLiterals())) {
super.printDuo(first, second, printer);
return;
}
// Otherwise, we need to inspect the right, collection side of the IN expression
boolean firstBound = true;
if(second instanceof CollectionExpression) {
Object val = ((CollectionExpression) second).getValue();
if (val instanceof Collection) {
firstBound = false;
Collection values = (Collection)val;
for(Object value : values) {
// If the value isn't a Constant/Parameter, this will suffice and the first should bind
if(value instanceof Expression && !((Expression)value).isValueExpression()) {
firstBound = true;
break;
}
// If the value is a Constant and literal binding is disabled, this will suffice and the first should bind
if(value instanceof Expression && ((Expression)value).isConstantExpression() && !printer.getPlatform().shouldBindLiterals()) {
firstBound = true;
break;
}
}
}
}
if(first.isParameterExpression()) {
((ParameterExpression) first).setCanBind(firstBound);
} else if(first.isConstantExpression()) {
((ConstantExpression) first).setCanBind(firstBound);
}
super.printDuo(first, second, printer);
}
@Override
public void printJavaDuo(Expression first, Expression second, ExpressionJavaPrinter printer) {
if(!printer.getPlatform().shouldBindPartialParameters()) {
super.printJavaDuo(first, second, printer);
return;
}
// If the first argument isn't a Constant/Parameter, this will suffice
if(!first.isValueExpression() || (first.isConstantExpression() && !printer.getPlatform().shouldBindLiterals())) {
super.printJavaDuo(first, second, printer);
return;
}
// Otherwise, we need to inspect the right, collection side of the IN expression
boolean firstBound = true;
if(second instanceof CollectionExpression) {
Object val = ((CollectionExpression) second).getValue();
if (val instanceof Collection) {
firstBound = false;
Collection values = (Collection)val;
for(Object value : values) {
// If the value isn't a Constant/Parameter, this will suffice and the first should bind
if(value instanceof Expression && !((Expression)value).isValueExpression()) {
firstBound = true;
break;
}
// If the value is a Constant and literal binding is disabled, this will suffice and the first should bind
if(value instanceof Expression && ((Expression)value).isConstantExpression() && !printer.getPlatform().shouldBindLiterals()) {
firstBound = true;
break;
}
}
}
}
if(first.isParameterExpression()) {
((ParameterExpression) first).setCanBind(firstBound);
} else if(first.isConstantExpression()) {
((ConstantExpression) first).setCanBind(firstBound);
}
super.printJavaDuo(first, second, printer);
}
};
ExpressionOperator.in().copyTo(operator);
return operator;
}
/**
* INTERNAL: Used for sp calls. PostGreSQL uses a different method for executing StoredProcedures than other platforms.
*/
@Override
public String buildProcedureCallString(StoredProcedureCall call, AbstractSession session, AbstractRecord row) {
StringWriter writer = new StringWriter();
writer.write(call.getCallHeader(this));
writer.write(call.getProcedureName());
if (requiresProcedureCallBrackets()) {
writer.write("(");
} else {
writer.write(" ");
}
int indexFirst = call.getFirstParameterIndexForCallString();
int size = call.getParameters().size();
for (int index = indexFirst; index < size; index++) {
String name = call.getProcedureArgumentNames().get(index);
Object parameter = call.getParameters().get(index);
ParameterType parameterType = call.getParameterTypes().get(index);
// If the argument is optional and null, ignore it.
if (!call.hasOptionalArguments() || !call.getOptionalArguments().contains(parameter) || (row.get(parameter) != null)) {
writer.write(getProcedureArgument(name, parameter, parameterType, call, session));
if (DatasourceCall.isOutputParameterType(parameterType)) {
if (requiresProcedureCallOuputToken()) {
writer.write(" ");
writer.write(getOutputProcedureToken());
}
}
if ((index + 1) < call.getParameters().size()) {
writer.write(", ");
}
}
}
if (requiresProcedureCallBrackets()) {
writer.write(")");
}
writer.write(getProcedureCallTail());
return writer.toString();
}
/**
* This method is used to register output parameter on Callable Statements for Stored Procedures
* as each database seems to have a different method.
*/
@Override
public void registerOutputParameter(CallableStatement statement, String name, int jdbcType) throws SQLException {
try {
Class clazz = null;
Method method = null;
String methodName = "registerJccOutParameterAtName";
Class[] methodArgs = new Class[] {String.class, int.class};
Object[] parameters = new Object[] {name, jdbcType};
if (PrivilegedAccessHelper.shouldUsePrivilegedAccess()) {
try {
ClassLoader cl = AccessController.doPrivileged(new PrivilegedGetContextClassLoader(Thread.currentThread()));
clazz = AccessController.doPrivileged(new PrivilegedClassForName(DB2_CALLABLESTATEMENT_CLASS, true, cl));
method = AccessController.doPrivileged(new PrivilegedGetMethod(clazz, methodName, methodArgs, true));
Object o = statement.unwrap(clazz);
AccessController.doPrivileged(new PrivilegedMethodInvoker(method, o, parameters));
} catch (PrivilegedActionException ex) {
if (ex.getCause() instanceof ClassNotFoundException) {
throw (ClassNotFoundException) ex.getCause();
}
throw (RuntimeException) ex.getCause();
}
} else {
ClassLoader cl = PrivilegedAccessHelper.getContextClassLoader(Thread.currentThread());
clazz = PrivilegedAccessHelper.getClassForName(DB2_CALLABLESTATEMENT_CLASS, true, cl);
method = PrivilegedAccessHelper.getMethod(clazz, methodName, methodArgs, true);
Object o = statement.unwrap(clazz);
PrivilegedAccessHelper.invokeMethod(method, o, parameters);
}
} catch (ReflectiveOperationException e) {
AbstractSessionLog.getLog().logThrowable(SessionLog.WARNING, null, e);
//Didn't work, fall back. This most likely still won't work, but the driver exception from there will be helpful.
super.registerOutputParameter(statement, name, jdbcType);
}
}
/**
* This method is used to register output parameter on Callable Statements for Stored Procedures
* as each database seems to have a different method.
*/
@Override
public void registerOutputParameter(CallableStatement statement, String name, int jdbcType, String typeName) throws SQLException {
try {
Class clazz = null;
Method method = null;
String methodName = "registerJccOutParameterAtName";
Class[] methodArgs = new Class[] {String.class, int.class, String.class};
Object[] parameters = new Object[] {name, jdbcType, typeName};
if (PrivilegedAccessHelper.shouldUsePrivilegedAccess()) {
try {
ClassLoader cl = AccessController.doPrivileged(new PrivilegedGetContextClassLoader(Thread.currentThread()));
clazz = AccessController.doPrivileged(new PrivilegedClassForName(DB2_CALLABLESTATEMENT_CLASS, true, cl));
method = AccessController.doPrivileged(new PrivilegedGetMethod(clazz, methodName, methodArgs, true));
Object o = statement.unwrap(clazz);
AccessController.doPrivileged(new PrivilegedMethodInvoker(method, o, parameters));
} catch (PrivilegedActionException ex) {
if (ex.getCause() instanceof ClassNotFoundException) {
throw (ClassNotFoundException) ex.getCause();
}
throw (RuntimeException) ex.getCause();
}
} else {
ClassLoader cl = PrivilegedAccessHelper.getContextClassLoader(Thread.currentThread());
clazz = PrivilegedAccessHelper.getClassForName(DB2_CALLABLESTATEMENT_CLASS, true, cl);
method = PrivilegedAccessHelper.getMethod(clazz, methodName, methodArgs, true);
Object o = statement.unwrap(clazz);
PrivilegedAccessHelper.invokeMethod(method, o, parameters);
}
} catch (ReflectiveOperationException e) {
AbstractSessionLog.getLog().logThrowable(SessionLog.WARNING, null, e);
//Didn't work, fall back. This most likely still won't work, but the driver exception from there will be helpful.
super.registerOutputParameter(statement, name, jdbcType, typeName);
}
}
@Override
public void setParameterValueInDatabaseCall(Object parameter,
CallableStatement statement, String name, AbstractSession session)
throws SQLException {
String methodName = null;
Class[] methodArgs = null;
Object[] parameters = null;
// Process common types first.
if (parameter instanceof String) {
// Check for stream binding of large strings.
if (usesStringBinding() && (((String)parameter).length() > getStringBindingSize())) {
CharArrayReader reader = new CharArrayReader(((String)parameter).toCharArray());
methodName = "setJccCharacterStreamAtName";
methodArgs = new Class[] {String.class, java.io.Reader.class, int.class};
parameters = new Object[] {name, reader, ((String)parameter).length()};
} else {
//TODO find shouldUseGetSetNString() support for DB2/Z
methodName = "setJccStringAtName";
methodArgs = new Class[] {String.class, String.class};
parameters = new Object[] {name, (String) parameter};
}
} else if (parameter instanceof Number) {
Number number = (Number) parameter;
if (number instanceof Integer) {
methodName = "setJccIntAtName";
methodArgs = new Class[] {String.class, int.class};
parameters = new Object[] {name, number.intValue()};
} else if (number instanceof Long) {
methodName = "setJccLongAtName";
methodArgs = new Class[] {String.class, long.class};
parameters = new Object[] {name, number.longValue()};
} else if (number instanceof BigDecimal) {
methodName = "setJccBigDecimalAtName";
methodArgs = new Class[] {String.class, BigDecimal.class};
parameters = new Object[] {name, (BigDecimal) number};
} else if (number instanceof Double) {
methodName = "setJccDoubleAtName";
methodArgs = new Class[] {String.class, double.class};
parameters = new Object[] {name, number.doubleValue()};
} else if (number instanceof Float) {
methodName = "setJccFloatAtName";
methodArgs = new Class[] {String.class, float.class};
parameters = new Object[] {name, number.floatValue()};
} else if (number instanceof Short) {
methodName = "setJccShortAtName";
methodArgs = new Class[] {String.class, short.class};
parameters = new Object[] {name, number.shortValue()};
} else if (number instanceof Byte) {
methodName = "setJccByteAtName";
methodArgs = new Class[] {String.class, byte.class};
parameters = new Object[] {name, number.byteValue()};
} else if (number instanceof BigInteger) {
// Convert to BigDecimal.
methodName = "setJccBigDecimalAtName";
methodArgs = new Class[] {String.class, BigDecimal.class};
parameters = new Object[] {name, new BigDecimal((BigInteger) number)};
} else {
methodName = "setJccObjectAtName";
methodArgs = new Class[] {String.class, Object.class};
parameters = new Object[] {name, parameter};
}
} else if (parameter instanceof java.sql.Date){
methodName = "setJccDateAtName";
methodArgs = new Class[] {String.class, java.sql.Date.class};
parameters = new Object[] {name, (java.sql.Date)parameter};
} else if (parameter instanceof java.time.LocalDate){
// Convert to java.sql.Date
methodName = "setJccDateAtName";
methodArgs = new Class[] {String.class, java.sql.Date.class};
parameters = new Object[] {name, java.sql.Date.valueOf((java.time.LocalDate) parameter)};
} else if (parameter instanceof java.sql.Timestamp){
methodName = "setJccTimestampAtName";
methodArgs = new Class[] {String.class, java.sql.Timestamp.class};
parameters = new Object[] {name, (java.sql.Timestamp)parameter};
} else if (parameter instanceof java.time.LocalDateTime){
// Convert to java.sql.Timestamp
methodName = "setJccTimestampAtName";
methodArgs = new Class[] {String.class, java.sql.Timestamp.class};
parameters = new Object[] {name, java.sql.Timestamp.valueOf((java.time.LocalDateTime) parameter)};
} else if (parameter instanceof java.time.OffsetDateTime) {
// Convert to java.sql.Timestamp
methodName = "setJccTimestampAtName";
methodArgs = new Class[] {String.class, java.sql.Timestamp.class};
parameters = new Object[] {name, java.sql.Timestamp.from(((java.time.OffsetDateTime) parameter).toInstant())};
} else if (parameter instanceof java.sql.Time){
methodName = "setJccTimeAtName";
methodArgs = new Class[] {String.class, java.sql.Time.class};
parameters = new Object[] {name, (java.sql.Time)parameter};
} else if (parameter instanceof java.time.LocalTime){
java.time.LocalTime lt = (java.time.LocalTime) parameter;
java.sql.Timestamp ts = java.sql.Timestamp.valueOf(java.time.LocalDateTime.of(java.time.LocalDate.ofEpochDay(0), lt));
methodName = "setJccTimestampAtName";
methodArgs = new Class[] {String.class, java.sql.Timestamp.class};
parameters = new Object[] {name, ts};
} else if (parameter instanceof java.time.OffsetTime) {
java.time.OffsetTime ot = (java.time.OffsetTime) parameter;
java.sql.Timestamp ts = java.sql.Timestamp.valueOf(java.time.LocalDateTime.of(java.time.LocalDate.ofEpochDay(0), ot.toLocalTime()));
methodName = "setJccTimestampAtName";
methodArgs = new Class[] {String.class, java.sql.Timestamp.class};
parameters = new Object[] {name, ts};
} else if (parameter instanceof Boolean) {
methodName = "setJccBooleanAtName";
methodArgs = new Class[] {String.class, boolean.class};
parameters = new Object[] {name, ((Boolean) parameter).booleanValue()};
} else if (parameter == null) {
// Normally null is passed as a DatabaseField so the type is included, but in some case may be passed directly.
methodName = "setJccNullAtName";
methodArgs = new Class[] {String.class, int.class};
parameters = new Object[] {name, getJDBCType((Class)null)};
} else if (parameter instanceof DatabaseField) {
setNullFromDatabaseField((DatabaseField)parameter, statement, name);
} else if (parameter instanceof byte[]) {
if (usesStreamsForBinding()) {
ByteArrayInputStream inputStream = new ByteArrayInputStream((byte[])parameter);
methodName = "setJccBinaryStreamAtName";
methodArgs = new Class[] {String.class, java.io.InputStream.class, int.class};
parameters = new Object[] {name, inputStream, ((byte[])parameter).length};
} else {
methodName = "setJccBytesAtName";
methodArgs = new Class[] {String.class, byte[].class};
parameters = new Object[] {name, (byte[])parameter};
}
}
// Next process types that need conversion.
else if (parameter instanceof Calendar) {
methodName = "setJccTimestampAtName";
methodArgs = new Class[] {String.class, java.sql.Timestamp.class};
parameters = new Object[] {name, Helper.timestampFromDate(((Calendar)parameter).getTime())};
} else if (parameter.getClass() == ClassConstants.UTILDATE) {
methodName = "setJccTimestampAtName";
methodArgs = new Class[] {String.class, java.sql.Timestamp.class};
parameters = new Object[] {name, Helper.timestampFromDate((java.util.Date) parameter)};
} else if (parameter instanceof Character) {
methodName = "setJccStringAtName";
methodArgs = new Class[] {String.class, String.class};
parameters = new Object[] {name, ((Character)parameter).toString()};
} else if (parameter instanceof char[]) {
methodName = "setJccStringAtName";
methodArgs = new Class[] {String.class, String.class};
parameters = new Object[] {name, new String((char[])parameter)};
} else if (parameter instanceof Character[]) {
methodName = "setJccStringAtName";
methodArgs = new Class[] {String.class, String.class};
parameters = new Object[] {name, (String)convertObject(parameter, ClassConstants.STRING)};
} else if (parameter instanceof Byte[]) {
methodName = "setJccBytesAtName";
methodArgs = new Class[] {String.class, byte[].class};
parameters = new Object[] {name, (byte[])convertObject(parameter, ClassConstants.APBYTE)};
} else if (parameter instanceof SQLXML) {
methodName = "setJccSQLXMLAtName";
methodArgs = new Class[] {String.class, java.sql.SQLXML.class};
parameters = new Object[] {name, (SQLXML) parameter};
} else if (parameter instanceof BindCallCustomParameter) {
((BindCallCustomParameter)(parameter)).set(this, statement, name, session);
} else if (typeConverters != null && typeConverters.containsKey(parameter.getClass())){
StructConverter converter = typeConverters.get(parameter.getClass());
parameter = converter.convertToStruct(parameter, getConnection(session, statement.getConnection()));
methodName = "setJccObjectAtName";
methodArgs = new Class[] {String.class, Object.class};
parameters = new Object[] {name, parameter};
} else {
methodName = "setJccObjectAtName";
methodArgs = new Class[] {String.class, Object.class};
parameters = new Object[] {name, parameter};
}
if(methodName != null) {
try {
Class clazz = null;
Method method = null;
if (PrivilegedAccessHelper.shouldUsePrivilegedAccess()) {
try {
ClassLoader cl = AccessController.doPrivileged(new PrivilegedGetContextClassLoader(Thread.currentThread()));
clazz = AccessController.doPrivileged(new PrivilegedClassForName(DB2_PREPAREDSTATEMENT_CLASS, true, cl));
method = AccessController.doPrivileged(new PrivilegedGetMethod(clazz, methodName, methodArgs, true));
Object o = statement.unwrap(clazz);
AccessController.doPrivileged(new PrivilegedMethodInvoker(method, o, parameters));
} catch (PrivilegedActionException ex) {
if (ex.getCause() instanceof ClassNotFoundException) {
throw (ClassNotFoundException) ex.getCause();
}
throw (RuntimeException) ex.getCause();
}
} else {
ClassLoader cl = PrivilegedAccessHelper.getContextClassLoader(Thread.currentThread());
clazz = PrivilegedAccessHelper.getClassForName(DB2_PREPAREDSTATEMENT_CLASS, true, cl);
method = PrivilegedAccessHelper.getMethod(clazz, methodName, methodArgs, true);
Object o = statement.unwrap(clazz);
PrivilegedAccessHelper.invokeMethod(method, o, parameters);
}
} catch (ReflectiveOperationException e) {
AbstractSessionLog.getLog().logThrowable(SessionLog.WARNING, null, e);
//Didn't work, fall back. This most likely still won't work, but the driver exception from there will be helpful.
super.setParameterValueInDatabaseCall(parameter, statement, name, session);
}
}
}
@Override
protected void setNullFromDatabaseField(DatabaseField databaseField, CallableStatement statement, String name) throws SQLException {
String methodName = null;
Class[] methodArgs = null;
Object[] parameters = null;
if (databaseField instanceof ObjectRelationalDatabaseField) {
ObjectRelationalDatabaseField field = (ObjectRelationalDatabaseField)databaseField;
methodName = "setJccNullAtName";
methodArgs = new Class[] {String.class, int.class, String.class};
parameters = new Object[] {name, field.getSqlType(), field.getSqlTypeName()};
} else {
int jdbcType = getJDBCTypeForSetNull(databaseField);
methodName = "setJccNullAtName";
methodArgs = new Class[] {String.class, int.class};
parameters = new Object[] {name, jdbcType};
}
try {
Class clazz = null;
Method method = null;
if (PrivilegedAccessHelper.shouldUsePrivilegedAccess()) {
try {
ClassLoader cl = AccessController.doPrivileged(new PrivilegedGetContextClassLoader(Thread.currentThread()));
clazz = AccessController.doPrivileged(new PrivilegedClassForName(DB2_PREPAREDSTATEMENT_CLASS, true, cl));
method = AccessController.doPrivileged(new PrivilegedGetMethod(clazz, methodName, methodArgs, true));
Object o = statement.unwrap(clazz);
AccessController.doPrivileged(new PrivilegedMethodInvoker(method, o, parameters));
} catch (PrivilegedActionException ex) {
if (ex.getCause() instanceof ClassNotFoundException) {
throw (ClassNotFoundException) ex.getCause();
}
throw (RuntimeException) ex.getCause();
}
} else {
ClassLoader cl = PrivilegedAccessHelper.getContextClassLoader(Thread.currentThread());
clazz = PrivilegedAccessHelper.getClassForName(DB2_PREPAREDSTATEMENT_CLASS, true, cl);
method = PrivilegedAccessHelper.getMethod(clazz, methodName, methodArgs, true);
Object o = statement.unwrap(clazz);
PrivilegedAccessHelper.invokeMethod(method, o, parameters);
}
} catch (ReflectiveOperationException e) {
AbstractSessionLog.getLog().logThrowable(SessionLog.WARNING, null, e);
//Didn't work, fall back. This most likely still won't work, but the driver exception from there will be helpful.
super.setNullFromDatabaseField(databaseField, statement, name);
}
}
@Override
public Object getParameterValueFromDatabaseCall(CallableStatement statement, String name, AbstractSession session)
throws SQLException {
String methodName = null;
Class[] methodArgs = null;
Object[] parameters = null;
methodName = "getJccObjectAtName";
methodArgs = new Class[] {String.class};
parameters = new Object[] {name};
if(methodName != null) {
try {
Class clazz = null;
Method method = null;
if (PrivilegedAccessHelper.shouldUsePrivilegedAccess()) {
try {
ClassLoader cl = AccessController.doPrivileged(new PrivilegedGetContextClassLoader(Thread.currentThread()));
clazz = AccessController.doPrivileged(new PrivilegedClassForName(DB2_CALLABLESTATEMENT_CLASS, true, cl));
method = AccessController.doPrivileged(new PrivilegedGetMethod(clazz, methodName, methodArgs, true));
Object o = statement.unwrap(clazz);
return AccessController.doPrivileged(new PrivilegedMethodInvoker(method, o, parameters));
} catch (PrivilegedActionException ex) {
if (ex.getCause() instanceof ClassNotFoundException) {
throw (ClassNotFoundException) ex.getCause();
}
throw (RuntimeException) ex.getCause();
}
} else {
ClassLoader cl = PrivilegedAccessHelper.getContextClassLoader(Thread.currentThread());
clazz = PrivilegedAccessHelper.getClassForName(DB2_CALLABLESTATEMENT_CLASS, true, cl);
method = PrivilegedAccessHelper.getMethod(clazz, methodName, methodArgs, true);
Object o = statement.unwrap(clazz);
return PrivilegedAccessHelper.invokeMethod(method, o, parameters);
}
} catch (ReflectiveOperationException e) {
AbstractSessionLog.getLog().logThrowable(SessionLog.WARNING, null, e);
}
}
//Didn't work, fall back. This most likely still won't work, but the driver exception from there will be helpful.
return super.getParameterValueFromDatabaseCall(statement, name, session);
}
}