* Purpose: Provides DB2 specific behavior. *
* Responsibilities: *
* With binding enabled, DB2 & 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 binding enabled, Derby will throw an error: *
ERROR 42X34: There is a ? parameter in the select list. This is not allowed.*/ protected ExpressionOperator ascendingOperator() { ExpressionOperator operator = disableAllBindingExpression(); ExpressionOperator.ascending().copyTo(operator); return operator; } /** * Disable binding support. *
* With binding enabled, DB2 & 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 binding enabled, Derby will throw an error: *
ERROR 42X34: There is a ? parameter in the select list. This is not allowed.*/ protected ExpressionOperator descendingOperator() { ExpressionOperator operator = disableAllBindingExpression(); ExpressionOperator.descending().copyTo(operator); return operator; } /** * INTERNAL: * The concat operator is of the form .... VARCHAR (
* With binding enabled, DB2 will throw an error: *
Db2 cannot determine how to implicitly cast the arguments between string and
* numeric data types. DB2 SQL Error: SQLCODE=-245, SQLSTATE=428F5
* * 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
* * With binding enabled, Derby will throw an error: *
ERROR 42X36: The 'COUNT' operator is not allowed to take a ? parameter as an operand.*/ protected ExpressionOperator count() { ExpressionOperator operator = disableAllBindingExpression(); ExpressionOperator.count().copyTo(operator); return operator; } /** * Disable binding support. *
* With binding enabled, DB2 will throw an error: *
Db2 cannot determine how to implicitly cast the arguments between string and
* numeric data types. DB2 SQL Error: SQLCODE=-245, SQLSTATE=428F5
* * 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
* * With binding enabled, Derby will throw an error: *
ERROR 42X36: The 'MAX' operator is not allowed to take a ? parameter as an operand.*/ protected ExpressionOperator max() { ExpressionOperator operator = disableAllBindingExpression(); ExpressionOperator.maximum().copyTo(operator); return operator; } /** * Disable binding support. *
* With binding enabled, DB2 will throw an error: *
Db2 cannot determine how to implicitly cast the arguments between string and
* numeric data types. DB2 SQL Error: SQLCODE=-245, SQLSTATE=428F5
* * 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
* * With binding enabled, Derby will throw an error: *
ERROR 42X36: The 'MIN' operator is not allowed to take a ? parameter as an operand.*/ protected ExpressionOperator min() { ExpressionOperator operator = disableAllBindingExpression(); ExpressionOperator.minimum().copyTo(operator); return operator; } /** * Disable binding support. *
* With binding enabled, DB2 will throw an error: *
Db2 cannot determine how to implicitly cast the arguments between string and
* numeric data types. DB2 SQL Error: SQLCODE=-245, SQLSTATE=428F5
* * With binding enabled, DB2 & 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 binding enabled, Derby will throw an error: *
ERROR 42X34: There is a ? parameter in the select list. This is not allowed.*/ protected ExpressionOperator distinct() { ExpressionOperator operator = disableAllBindingExpression(); ExpressionOperator.distinct().copyTo(operator); return operator; } /** * DB2 does not allow untyped parameter binding for the THEN & ELSE 'result-expressions' of CASE expressions *
* With binding enabled, DB2 & 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
* Examples of places where parameter markers cannot be used:
* * With binding enabled, Derby will throw an error: *
ERROR 42X87: At least one result expression (THEN or ELSE) of the CASE expression must have a known type.
*/
protected ExpressionOperator caseOperator() {
ListExpressionOperator operator = new ListExpressionOperator() {
@Override
public void printCollection(List items, ExpressionSQLPrinter printer) {
if(!printer.getPlatform().shouldBindPartialParameters()) {
super.printCollection(items, printer);
return;
}
// First, calculate all argument binding positions
int i = 0;
int numberOfItems = items.size();
boolean[] argumentBinding = new boolean[numberOfItems + 1];
// Enabled for CASE operator
argumentBinding[i] = true;
i++;
// Enabled for WHEN, but not for THEN
boolean[] separatorsBinding = new boolean[]{true, false};
// Disable for ELSE, but not for END
boolean[] terminationStringsBinding = new boolean[]{false, true};
while (i < numberOfItems - (terminationStringsBinding.length - 1)) {
for (int j = 0; j < separatorsBinding.length; j++) {
argumentBinding[i] = separatorsBinding[j];
i++;
}
}
while (i <= numberOfItems) {
for (int j = 0; j < terminationStringsBinding.length; j++) {
argumentBinding[i] = terminationStringsBinding[j];
i++;
}
}
// Initialize argumentIndices
if (this.argumentIndices == null) {
this.argumentIndices = new int[items.size()];
for (int k = 0; k < this.argumentIndices.length; k++){
this.argumentIndices[k] = k;
}
}
for (int j = 0; j < items.size(); j++) {
final int index = this.argumentIndices[j];
Expression item = items.get(index);
if(item.isParameterExpression()) {
((ParameterExpression) item).setCanBind(argumentBinding[index]);
} else if(item.isConstantExpression()) {
((ConstantExpression) item).setCanBind(argumentBinding[index]);
}
}
super.printCollection(items, printer);
}
@Override
public void printJavaCollection(Vector items, ExpressionJavaPrinter printer) {
if(!printer.getPlatform().shouldBindPartialParameters()) {
super.printJavaCollection(items, printer);
return;
}
// First, calculate all argument binding positions
int i = 0;
int numberOfItems = items.size();
boolean[] argumentBinding = new boolean[numberOfItems + 1];
// Enabled for CASE operator
argumentBinding[i] = true;
i++;
// Enabled for WHEN, but not for THEN
boolean[] separatorsBinding = new boolean[]{true, false};
// Disable for ELSE, but not for END
boolean[] terminationStringsBinding = new boolean[]{false, true};
while (i < numberOfItems - (terminationStringsBinding.length - 1)) {
for (int j = 0; j < separatorsBinding.length; j++) {
argumentBinding[i] = separatorsBinding[j];
i++;
}
}
while (i <= numberOfItems) {
for (int j = 0; j < terminationStringsBinding.length; j++) {
argumentBinding[i] = terminationStringsBinding[j];
i++;
}
}
for (int j = 0; j < items.size(); j++) {
Expression item = items.get(j);
if(item.isParameterExpression()) {
((ParameterExpression) item).setCanBind(argumentBinding[j]);
} else if(item.isConstantExpression()) {
((ConstantExpression) item).setCanBind(argumentBinding[j]);
}
}
super.printJavaCollection(items, printer);
}
};
ExpressionOperator.caseStatement().copyTo(operator);
return operator;
}
/**
* DB2 does not allow untyped parameter binding for the THEN & ELSE 'result-expressions' of CASE expressions
*
* With binding enabled, DB2 & 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
* Examples of places where parameter markers cannot be used:
*
* - In a result-expression in any CASE expression when all the other result-expressions are either NULL or untyped parameter markers
*
*
* With binding enabled, Derby will throw an error:
*
ERROR 42X87: At least one result expression (THEN or ELSE) of the CASE expression must have a known type.
*/
protected ExpressionOperator caseConditionOperator() {
ListExpressionOperator operator = new ListExpressionOperator() {
@Override
public void printCollection(List items, ExpressionSQLPrinter printer) {
if(!printer.getPlatform().shouldBindPartialParameters()) {
super.printCollection(items, printer);
return;
}
// First, calculate all argument binding positions
int i = 0;
int numberOfItems = items.size();
boolean[] argumentBinding = new boolean[numberOfItems + 1];
// Enabled for CASE WHEN operator
argumentBinding[i] = true;
i++;
// Disabled for THEN operator
argumentBinding[i] = false;
i++;
// Enabled for WHEN, but not for THEN
boolean[] separatorsBinding = new boolean[]{true, false};
// Disable for ELSE, but not for END
boolean[] terminationStringsBinding = new boolean[]{false, true};
while (i < numberOfItems - (terminationStringsBinding.length - 1)) {
for (int j = 0; j < separatorsBinding.length; j++) {
argumentBinding[i] = separatorsBinding[j];
i++;
}
}
while (i <= numberOfItems) {
for (int j = 0; j < terminationStringsBinding.length; j++) {
argumentBinding[i] = terminationStringsBinding[j];
i++;
}
}
// Initialize argumentIndices
if (this.argumentIndices == null) {
this.argumentIndices = new int[items.size()];
for (int k = 0; k < this.argumentIndices.length; k++){
this.argumentIndices[k] = k;
}
}
for (int j = 0; j < items.size(); j++) {
final int index = this.argumentIndices[j];
Expression item = items.get(index);
if(item.isParameterExpression()) {
((ParameterExpression) item).setCanBind(argumentBinding[index]);
} else if(item.isConstantExpression()) {
((ConstantExpression) item).setCanBind(argumentBinding[index]);
}
}
super.printCollection(items, printer);
}
@Override
public void printJavaCollection(Vector items, ExpressionJavaPrinter printer) {
if(!printer.getPlatform().shouldBindPartialParameters()) {
super.printJavaCollection(items, printer);
return;
}
// First, calculate all argument binding positions
int i = 0;
int numberOfItems = items.size();
boolean[] argumentBinding = new boolean[numberOfItems + 1];
// Enabled for CASE WHEN operator
argumentBinding[i] = true;
i++;
// Disabled for THEN operator
argumentBinding[i] = false;
i++;
// Enabled for WHEN, but not for THEN
boolean[] separatorsBinding = new boolean[]{true, false};
// Disable for ELSE, but not for END
boolean[] terminationStringsBinding = new boolean[]{false, true};
while (i < numberOfItems - (terminationStringsBinding.length - 1)) {
for (int j = 0; j < separatorsBinding.length; j++) {
argumentBinding[i] = separatorsBinding[j];
i++;
}
}
while (i <= numberOfItems) {
for (int j = 0; j < terminationStringsBinding.length; j++) {
argumentBinding[i] = terminationStringsBinding[j];
i++;
}
}
for (int j = 0; j < items.size(); j++) {
Expression item = items.get(j);
if(item.isParameterExpression()) {
((ParameterExpression) item).setCanBind(argumentBinding[j]);
} else if(item.isConstantExpression()) {
((ConstantExpression) item).setCanBind(argumentBinding[j]);
}
}
super.printJavaCollection(items, printer);
}
};
ExpressionOperator.caseConditionStatement().copyTo(operator);
return operator;
}
/**
* Disable binding support.
*
* With binding enabled, DB2 will throw an error:
*
Db2 cannot determine how to implicitly cast the arguments between string and
* numeric data types. DB2 SQL Error: SQLCODE=-245, SQLSTATE=428F5
*
* 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
*
* With binding enabled, Derby will throw an error:
*
ERROR 42X36: The 'length' operator is not allowed to take a ? parameter as an operand.
*/
protected ExpressionOperator lengthOperator() {
ExpressionOperator operator = disableAllBindingExpression();
ExpressionOperator.length().copyTo(operator);
return operator;
}
/**
* DB2 requires that at least one argument be a known type
*
* With binding enabled, DB2 & 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 binding enabled, Derby will throw an error:
*
ERROR 42X35: It is not allowed for both operands of '=' to be ? parameters.
*/
protected ExpressionOperator nullifOperator() {
ExpressionOperator operator = disableAtLeast1BindingExpression();
ExpressionOperator.nullIf().copyTo(operator);
return operator;
}
/**
* DB2 requires that at least one argument be a known type
*
* With binding enabled, DB2 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 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
*
* With binding enabled, Derby will throw an error:
*
ERROR 42610: All the arguments to the COALESCE/VALUE function cannot be parameters. The function needs at least one argument that is not a parameter.
*/
protected ExpressionOperator coalesceOperator() {
ListExpressionOperator operator = new ListExpressionOperator() {
@Override
public void printCollection(List items, ExpressionSQLPrinter printer) {
if(!printer.getPlatform().shouldBindPartialParameters()) {
super.printCollection(items, printer);
return;
}
// Initialize argumentIndices
if (this.argumentIndices == null) {
this.argumentIndices = new int[items.size()];
for (int i = 0; i < this.argumentIndices.length; i++){
this.argumentIndices[i] = i;
}
}
boolean allBind = true;
for (int i = 0; i < items.size(); i++) {
final int index = this.argumentIndices[i];
Expression item = items.get(index);
boolean shouldBind = true;
// If the item isn't a Constant/Parameter, this will suffice and the rest should bind
if(!item.isValueExpression()) {
allBind = false;
}
if(allBind) {
if(printer.getPlatform().shouldBindLiterals()) {
if((i == (this.argumentIndices.length - 1))) {
// The last parameter has to be disabled
shouldBind = allBind = false;
}
} else {
if(item.isConstantExpression()) {
// The first literal has to be disabled
shouldBind = allBind = false;
} else if((i == (this.argumentIndices.length - 1)) && item.isParameterExpression()) {
// The last parameter has to be disabled
shouldBind = allBind = false;
}
}
}
if(item.isParameterExpression()) {
((ParameterExpression) item).setCanBind(shouldBind);
} else if(item.isConstantExpression()) {
((ConstantExpression) item).setCanBind(shouldBind);
}
}
super.printCollection(items, printer);
}
@Override
public void printJavaCollection(Vector items, ExpressionJavaPrinter printer) {
if(!printer.getPlatform().shouldBindPartialParameters()) {
super.printJavaCollection(items, printer);
return;
}
boolean allBind = true;
for (int i = 0; i < items.size(); i++) {
Expression item = items.get(i);
boolean shouldBind = true;
// If the item isn't a Constant/Parameter, this will suffice and the rest should bind
if(!item.isValueExpression()) {
allBind = false;
}
if(allBind) {
if(printer.getPlatform().shouldBindLiterals()) {
if((i == (items.size() - 1))) {
// The last parameter has to be disabled
shouldBind = allBind = false;
}
} else {
if(item.isConstantExpression()) {
// The first literal has to be disabled
shouldBind = allBind = false;
} else if((i == (items.size() - 1)) && item.isParameterExpression()) {
// The last parameter has to be disabled
shouldBind = allBind = false;
}
}
}
if(item.isParameterExpression()) {
((ParameterExpression) item).setCanBind(shouldBind);
} else if(item.isConstantExpression()) {
((ConstantExpression) item).setCanBind(shouldBind);
}
}
super.printJavaCollection(items, printer);
}
};
ExpressionOperator.coalesce().copyTo(operator);
return operator;
}
/**
* DB2 does not support untyped parameter binding for
*
* With binding enabled, DB2 & 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 trim2() {
ExpressionOperator operator = new ExpressionOperator(){
@Override
public void printCollection(List items, ExpressionSQLPrinter printer) {
if(!printer.getPlatform().shouldBindPartialParameters()) {
super.printCollection(items, printer);
return;
}
// Initialize argumentIndices
if (this.argumentIndices == null) {
this.argumentIndices = new int[items.size()];
for (int i = 0; i < this.argumentIndices.length; i++){
this.argumentIndices[i] = i;
}
}
for (int i = 0; i < items.size(); i++) {
final int index = this.argumentIndices[i];
Expression item = items.get(index);
// Disable the first item, which should be for this operator
if(i == 0) {
if(item.isParameterExpression()) {
((ParameterExpression) item).setCanBind(false);
} else if(item.isConstantExpression()) {
((ConstantExpression) item).setCanBind(false);
}
}
}
super.printCollection(items, printer);
}
@Override
public void printJavaCollection(Vector items, ExpressionJavaPrinter printer) {
if(!printer.getPlatform().shouldBindPartialParameters()) {
super.printJavaCollection(items, printer);
return;
}
for (int i = 0; i < items.size(); i++) {
Expression item = items.get(i);
// Disable the first item, which should be for this operator
if(i == 0) {
if(item.isParameterExpression()) {
((ParameterExpression) item).setCanBind(false);
} else if(item.isConstantExpression()) {
((ConstantExpression) item).setCanBind(false);
}
}
}
super.printJavaCollection(items, printer);
}
};
operator.setType(ExpressionOperator.FunctionOperator);
operator.setSelector(ExpressionOperator.Trim2);
Vector v = org.eclipse.persistence.internal.helper.NonSynchronizedVector.newInstance(5);
v.add("TRIM(");
v.add(" FROM ");
v.add(")");
operator.printsAs(v);
operator.bePrefix();
// Bug 573094
int[] indices = { 1, 0 };
operator.setArgumentIndices(indices);
operator.setNodeClass(ClassConstants.FunctionExpression_Class);
return operator;
}
/**
* DB2 does not support untyped parameter binding for
*
* With binding enabled, DB2 & 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 ltrim2Operator() {
ExpressionOperator operator = new ExpressionOperator(){
@Override
public void printCollection(List items, ExpressionSQLPrinter printer) {
if(!printer.getPlatform().shouldBindPartialParameters()) {
super.printCollection(items, printer);
return;
}
// Initialize argumentIndices
if (this.argumentIndices == null) {
this.argumentIndices = new int[items.size()];
for (int i = 0; i < this.argumentIndices.length; i++){
this.argumentIndices[i] = i;
}
}
for (int i = 0; i < items.size(); i++) {
final int index = this.argumentIndices[i];
Expression item = items.get(index);
// Disable the first item, which should be for this operator
if(i == 0) {
if(item.isParameterExpression()) {
((ParameterExpression) item).setCanBind(false);
} else if(item.isConstantExpression()) {
((ConstantExpression) item).setCanBind(false);
}
}
}
super.printCollection(items, printer);
}
@Override
public void printJavaCollection(Vector items, ExpressionJavaPrinter printer) {
if(!printer.getPlatform().shouldBindPartialParameters()) {
super.printJavaCollection(items, printer);
return;
}
for (int i = 0; i < items.size(); i++) {
Expression item = items.get(i);
// Disable the first item, which should be for this operator
if(i == 0) {
if(item.isParameterExpression()) {
((ParameterExpression) item).setCanBind(false);
} else if(item.isConstantExpression()) {
((ConstantExpression) item).setCanBind(false);
}
}
}
super.printJavaCollection(items, printer);
}
};
operator.setType(ExpressionOperator.FunctionOperator);
operator.setSelector(ExpressionOperator.LeftTrim2);
Vector v = new Vector(5);
v.add("TRIM(LEADING ");
v.add(" FROM ");
v.add(")");
operator.printsAs(v);
operator.bePrefix();
// Bug 573094
int[] indices = { 1, 0 };
operator.setArgumentIndices(indices);
operator.setNodeClass(ClassConstants.FunctionExpression_Class);
return operator;
}
/**
* DB2 does not support untyped parameter binding for
*
* With binding enabled, DB2 & 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 rtrim2Operator() {
ExpressionOperator operator = new ExpressionOperator(){
@Override
public void printCollection(List items, ExpressionSQLPrinter printer) {
if(!printer.getPlatform().shouldBindPartialParameters()) {
super.printCollection(items, printer);
return;
}
// Initialize argumentIndices
if (this.argumentIndices == null) {
this.argumentIndices = new int[items.size()];
for (int i = 0; i < this.argumentIndices.length; i++){
this.argumentIndices[i] = i;
}
}
for (int i = 0; i < items.size(); i++) {
final int index = this.argumentIndices[i];
Expression item = items.get(index);
// Disable the first item, which should be for this operator
if(i == 0) {
if(item.isParameterExpression()) {
((ParameterExpression) item).setCanBind(false);
} else if(item.isConstantExpression()) {
((ConstantExpression) item).setCanBind(false);
}
}
}
super.printCollection(items, printer);
}
@Override
public void printJavaCollection(Vector items, ExpressionJavaPrinter printer) {
if(!printer.getPlatform().shouldBindPartialParameters()) {
super.printJavaCollection(items, printer);
return;
}
for (int i = 0; i < items.size(); i++) {
Expression item = items.get(i);
// Disable the first item, which should be for this operator
if(i == 0) {
if(item.isParameterExpression()) {
((ParameterExpression) item).setCanBind(false);
} else if(item.isConstantExpression()) {
((ConstantExpression) item).setCanBind(false);
}
}
}
super.printJavaCollection(items, printer);
}
};
operator.setType(ExpressionOperator.FunctionOperator);
operator.setSelector(ExpressionOperator.RightTrim2);
Vector v = new Vector(5);
v.add("TRIM(TRAILING ");
v.add(" FROM ");
v.add(")");
operator.printsAs(v);
operator.bePrefix();
// Bug 573094
int[] indices = { 1, 0 };
operator.setArgumentIndices(indices);
operator.setNodeClass(ClassConstants.FunctionExpression_Class);
return operator;
}
@Override
public boolean isDB2() {
return true;
}
/**
* INTERNAL:
* Builds a table of maximum numeric values keyed on java class. This is
* used for type testing but might also be useful to end users attempting to
* sanitize values.
*
* NOTE: BigInteger {@literal &} BigDecimal maximums are dependent upon their
* precision {@literal &} Scale
*/
@Override
public Hashtable maximumNumericValues() {
Hashtable values = new Hashtable();
values.put(Integer.class, Integer.valueOf(Integer.MAX_VALUE));
values.put(Long.class, Long.valueOf(Integer.MAX_VALUE));
values.put(Float.class, Float.valueOf(123456789));
values.put(Double.class, Double.valueOf(Float.MAX_VALUE));
values.put(Short.class, Short.valueOf(Short.MAX_VALUE));
values.put(Byte.class, Byte.valueOf(Byte.MAX_VALUE));
values.put(java.math.BigInteger.class, new java.math.BigInteger("999999999999999"));
values.put(java.math.BigDecimal.class, new java.math.BigDecimal("0.999999999999999"));
return values;
}
/**
* INTERNAL:
* Builds a table of minimum numeric values keyed on java class. This is
* used for type testing but might also be useful to end users attempting to
* sanitize values.
*
* NOTE: BigInteger {@literal &} BigDecimal minimums are dependent upon their
* precision {@literal &} Scale
*/
@Override
public Hashtable minimumNumericValues() {
Hashtable values = new Hashtable();
values.put(Integer.class, Integer.valueOf(Integer.MIN_VALUE));
values.put(Long.class, Long.valueOf(Integer.MIN_VALUE));
values.put(Float.class, Float.valueOf(-123456789));
values.put(Double.class, Double.valueOf(Float.MIN_VALUE));
values.put(Short.class, Short.valueOf(Short.MIN_VALUE));
values.put(Byte.class, Byte.valueOf(Byte.MIN_VALUE));
values.put(java.math.BigInteger.class, new java.math.BigInteger("-999999999999999"));
values.put(java.math.BigDecimal.class, new java.math.BigDecimal("-0.999999999999999"));
return values;
}
/**
* INTERNAL:
* Allow for the platform to ignore exceptions. This is required for DB2
* which throws no-data modified as an exception.
*/
@Override
public boolean shouldIgnoreException(SQLException exception) {
if (exception.getMessage().equals("No data found") || exception.getMessage().equals("No row was found for FETCH, UPDATE or DELETE; or the result of a query is an empty table")
|| (exception.getErrorCode() == 100)) {
return true;
}
return super.shouldIgnoreException(exception);
}
/**
* INTERNAL:
* JDBC defines and outer join syntax, many drivers do not support this. So
* we normally avoid it.
*/
@Override
public boolean shouldUseJDBCOuterJoinSyntax() {
return false;
}
/**
* INTERNAL: Build the identity query for native sequencing.
*/
@Override
public ValueReadQuery buildSelectQueryForIdentity() {
ValueReadQuery selectQuery = new ValueReadQuery();
StringWriter writer = new StringWriter();
writer.write("SELECT IDENTITY_VAL_LOCAL() FROM SYSIBM.SYSDUMMY1");
selectQuery.setSQLString(writer.toString());
return selectQuery;
}
/**
* INTERNAL: Append the receiver's field 'identity' constraint clause to a
* writer.
* Used by table creation with sequencing.
*/
@Override
public void printFieldIdentityClause(Writer writer) throws ValidationException {
try {
writer.write(" GENERATED ALWAYS AS IDENTITY");
} catch (IOException ioException) {
throw ValidationException.fileError(ioException);
}
}
@Override
protected void printFieldTypeSize(Writer writer, FieldDefinition field, FieldTypeDefinition ftd) throws IOException {
super.printFieldTypeSize(writer, field, ftd);
String suffix = ftd.getTypesuffix();
if (suffix != null) {
writer.append(" " + suffix);
}
}
/**
* INTERNAL: Indicates whether the platform supports identity. DB2 does
* through AS IDENTITY field types.
* This is used by sequencing.
*/
@Override
public boolean supportsIdentity() {
return true;
}
/**
* INTERNAL: DB2 supports temp tables.
* This is used by UpdateAllQuerys.
*/
@Override
public boolean supportsGlobalTempTables() {
return true;
}
/**
* INTERNAL: DB2 temp table syntax.
* This is used by UpdateAllQuerys.
*/
@Override
protected String getCreateTempTableSqlPrefix() {
return "DECLARE GLOBAL TEMPORARY TABLE ";
}
/**
* INTERNAL: DB2 temp table syntax.
* This is used by UpdateAllQuerys.
*/
@Override
public DatabaseTable getTempTableForTable(DatabaseTable table) {
DatabaseTable tempTable = super.getTempTableForTable(table);
tempTable.setTableQualifier("session");
return tempTable;
}
/**
* INTERNAL: DB2 temp table syntax.
* This is used by UpdateAllQuerys.
*/
@Override
protected String getCreateTempTableSqlSuffix() {
return " ON COMMIT DELETE ROWS NOT LOGGED";
}
/**
* INTERNAL: DB2 allows LIKE to be used to create temp tables, which avoids having to know the types.
* This is used by UpdateAllQuerys.
*/
@Override
protected String getCreateTempTableSqlBodyForTable(DatabaseTable table) {
return " LIKE " + table.getQualifiedNameDelimited(this);
}
/**
* INTERNAL: DB2 does not support NOWAIT.
*/
@Override
public String getNoWaitString() {
return "";
}
/**
* INTERNAL: DB2 has issues with binding with temp table queries.
* This is used by UpdateAllQuerys.
*/
@Override
public boolean dontBindUpdateAllQueryUsingTempTables() {
return true;
}
/**
* INTERNAL: DB2 does not allow NULL in select clause.
* This is used by UpdateAllQuerys.
*/
@Override
public boolean isNullAllowedInSelectClause() {
return false;
}
/**
* INTERNAL
* DB2 has some issues with using parameters on certain functions and relations.
* This allows statements to disable binding only in these cases.
* If users set casting on, then casting is used instead of dynamic SQL.
*/
@Override
public boolean isDynamicSQLRequiredForFunctions() {
if(shouldForceBindAllParameters()) {
return false;
}
return !isCastRequired();
}
/**
* INTERNAL: DB2 does not allow stand alone, untyped parameter markers in select clause.
* @see org.eclipse.persistence.internal.expressions.ConstantExpression#writeFields(ExpressionSQLPrinter, List, SQLSelectStatement)
* @see org.eclipse.persistence.internal.expressions.ParameterExpression#writeFields(ExpressionSQLPrinter, List, SQLSelectStatement)
*/
@Override
public boolean allowBindingForSelectClause() {
return false;
}
/**
* INTERNAL:
* DB2 requires casting on certain operations, such as the CONCAT function,
* and parameterized queries of the form, ":param = :param". This method
* will write CAST operation to parameters if the type is known.
* This is not used by default, only if isCastRequired is set to true,
* by default dynamic SQL is used to avoid the issue in only the required cases.
*/
@Override
public void writeParameterMarker(Writer writer, ParameterExpression parameter, AbstractRecord record, DatabaseCall call) throws IOException {
String paramaterMarker = "?";
Object type = parameter.getType();
// Update-all query requires casting of null parameter values in select into.
if ((type != null) && (this.isCastRequired || ((call.getQuery() != null) && call.getQuery().isUpdateAllQuery()))) {
BasicTypeHelperImpl typeHelper = BasicTypeHelperImpl.getInstance();
String castType = null;
if (typeHelper.isBooleanType(type) || typeHelper.isByteType(type) || typeHelper.isShortType(type)) {
castType = "SMALLINT";
} else if (typeHelper.isIntType(type)) {
castType = "INTEGER";
} else if (typeHelper.isLongType(type)) {
castType = "BIGINT";
} else if (typeHelper.isFloatType(type)) {
castType = "REAL";
} else if (typeHelper.isDoubleType(type)) {
castType = "DOUBLE";
} else if (typeHelper.isStringType(type)) {
castType = "VARCHAR(" + getCastSizeForVarcharParameter() + ")";
} else if (typeHelper.isCharacterType(type)) {
castType = "CHAR";
}
if (castType != null) {
paramaterMarker = "CAST (? AS " + castType + ")";
}
}
writer.write(paramaterMarker);
}
/**
* INTERNAL:
* DB2 does not seem to allow FOR UPDATE on queries with multiple tables.
* This is only used by testing to exclude these tests.
*/
@Override
public boolean supportsLockingQueriesWithMultipleTables() {
return false;
}
/**
* INTERNAL: DB2 added SEQUENCE support as of (I believe) v8.
*/
@Override
public ValueReadQuery buildSelectQueryForSequenceObject(String qualifiedSeqName, Integer size) {
return new ValueReadQuery("VALUES(NEXT VALUE FOR " + qualifiedSeqName + ")");
}
/**
* INTERNAL: DB2 added SEQUENCE support as of (I believe) v8.
*/
@Override
public boolean supportsSequenceObjects() {
return true;
}
/**
* DB2 disables single parameter usage in ORDER BY clause.
*
* If a parameter marker is used, DB2 & 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
*
* If a parameter marker is used, Derby will throw an error:
*
ERROR 42X34: There is a ? parameter in the select list. This is not allowed.
*/
@Override
public boolean supportsOrderByParameters() {
return false;
}
/**
* INTERNAL: DB2 added SEQUENCE support as of (I believe) v8.
*/
@Override
public boolean isAlterSequenceObjectSupported() {
return true;
}
@Override
public boolean shouldPrintForUpdateClause() {
return false;
}
/**
* INTERNAL:
* Print the SQL representation of the statement on a stream, storing the fields
* in the DatabaseCall. This implementation works MaxRows and FirstResult into the SQL using
* DB2's ROWNUMBER() OVER() to filter values if shouldUseRownumFiltering is true.
*/
@Override
public void printSQLSelectStatement(DatabaseCall call, ExpressionSQLPrinter printer, SQLSelectStatement statement){
int max = 0;
int firstRow = 0;
if (statement.getQuery()!=null){
max = statement.getQuery().getMaxRows();
firstRow = statement.getQuery().getFirstResult();
}
if ( !(this.shouldUseRownumFiltering()) || ( !(max>0) && !(firstRow>0) ) ){
super.printSQLSelectStatement(call, printer, statement);
statement.appendForUpdateClause(printer);
return;
} else if ( max > 0 ){
statement.setUseUniqueFieldAliases(true);
printer.printString("SELECT * FROM (SELECT * FROM (SELECT ");
printer.printString("EL_TEMP.*, ROWNUMBER() OVER() AS EL_ROWNM FROM (");
call.setFields(statement.printSQL(printer));
printer.printString(") AS EL_TEMP) AS EL_TEMP2 WHERE EL_ROWNM <= ");
printer.printParameter(DatabaseCall.MAXROW_FIELD);
printer.printString(") AS EL_TEMP3 WHERE EL_ROWNM > ");
printer.printParameter(DatabaseCall.FIRSTRESULT_FIELD);
// If we have a ForUpdate clause, it must be on the outermost query
statement.appendForUpdateClause(printer);
} else {// firstRow>0
statement.setUseUniqueFieldAliases(true);
printer.printString("SELECT * FROM (SELECT EL_TEMP.*, ROWNUMBER() OVER() AS EL_ROWNM FROM (");
call.setFields(statement.printSQL(printer));
printer.printString(") AS EL_TEMP) AS EL_TEMP2 WHERE EL_ROWNM > ");
printer.printParameter(DatabaseCall.FIRSTRESULT_FIELD);
statement.appendForUpdateClause(printer);
}
call.setIgnoreFirstRowSetting(true);
call.setIgnoreMaxResultsSetting(true);
}
}