Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Improve support for DB2[z] empty table precondition #5043

Original file line number Diff line number Diff line change
Expand Up @@ -29,14 +29,17 @@ public ValidationErrors validate(TableIsEmptyStatement tableIsEmptyStatement, Da

protected String generateCountSql(TableIsEmptyStatement statement, Database database) {
String tableName = database.escapeTableName(statement.getCatalogName(), statement.getSchemaName(), statement.getTableName());
if (database instanceof HsqlDatabase) {
if (database instanceof HsqlDatabase || database instanceof DB2Database) {
return String.format("SELECT COUNT(1) FROM (VALUES(0)) WHERE EXISTS (SELECT * FROM %s)", tableName);
} else if (database instanceof OracleDatabase || database instanceof MySQLDatabase) {
}
if (database instanceof Db2zDatabase) {
return String.format("SELECT COUNT(1) FROM SYSIBM.SYSDUMMY1 WHERE EXISTS (SELECT * FROM %s)", tableName);
}
if (database instanceof OracleDatabase || database instanceof MySQLDatabase) {
return String.format("SELECT COUNT(1) FROM DUAL WHERE EXISTS (SELECT * FROM %s)", tableName);
} else if (database instanceof FirebirdDatabase) {
}
if (database instanceof FirebirdDatabase) {
return String.format("SELECT COUNT(1) FROM RDB$DATABASE WHERE EXISTS (SELECT * FROM %s)", tableName);
} else if (database instanceof DB2Database) {
return String.format("SELECT COUNT(1) FROM sysibm.sysdummy1 WHERE EXISTS (SELECT * FROM %s)", tableName);
}
return String.format("SELECT COUNT(1) WHERE EXISTS (SELECT * FROM %s)", tableName);
}
Expand All @@ -46,6 +49,4 @@ protected String generateCountSql(TableIsEmptyStatement statement, Database data
public Sql[] generateSql(TableIsEmptyStatement statement, Database database, SqlGeneratorChain sqlGeneratorChain) {
return new Sql[] { new UnparsedSql(generateCountSql(statement, database)) };
}


}