github/jooq
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[jOOQ/jOOQ#8528] Add support for ADD IF NOT EXISTS

Browse Source
This commit is contained in:
Lukas Eder 2019-11-19 15:13:33 +01:00
parent cb8d3f893a
commit 2c5171cc40
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
jOOQ/src/main/java/org/jooq/impl/DDLInterpreter.java
View File

@ -403,6 +403,11 @@ final class DDLInterpreter {
throw unsupportedQuery(query);
}
else if (query.$addColumn() != null) {
if (existing.field(query.$addColumn()) != null)
if (!query.$ifNotExistsColumn())
throw fieldAlreadyExists(query.$addColumn());
else
return;
// TODO: Check if we already have the column
if (query.$addFirst())
@ -438,12 +443,11 @@ final class DDLInterpreter {
else if (query.$alterColumn() != null) {
MutableField existingField = existing.field(query.$alterColumn());
if (existingField == null) {
if (existingField == null)
if (!query.$ifExistsColumn())
throw columnNotExists(query.$alterColumn());
return;
}
else
return;
if (query.$alterColumnNullability() != null)
existingField.type = existingField.type.nullability(query.$alterColumnNullability());
@ -853,7 +857,7 @@ final class DDLInterpreter {
}
private static final DataDefinitionException fieldAlreadyExists(Field<?> field) {
return new DataDefinitionException("Field does not exist: " + field.getQualifiedName());
return new DataDefinitionException("Field already exists: " + field.getQualifiedName());
}
// -------------------------------------------------------------------------