Skip to content

Commit 4cb9411

Browse files
committed
Override the getUpdateStatement
1 parent 2b759a5 commit 4cb9411

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

flyway-database-timeplus/src/main/java/org/flywaydb/community/database/timeplus/TimeplusDatabase.java

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -166,4 +166,14 @@ public Pair<String, Object> getDeleteStatement(Table table, boolean version, Str
166166
String deleteStatement = "ALTER STREAM " + table + " DELETE WHERE " + this.quote("success") + " = " + this.getBooleanFalse() + " AND " + (version ? this.quote("version") + " = ?" : this.quote("description") + " = ?");
167167
return Pair.of(deleteStatement, filter);
168168
}
169+
170+
@Override
171+
public String getUpdateStatement(Table table) {
172+
return "ALTER STREAM " + table
173+
+ " UPDATE "
174+
+ quote("description") + "=? , "
175+
+ quote("type") + "=? , "
176+
+ quote("checksum") + "=?"
177+
+ " WHERE " + quote("installed_rank") + "=?";
178+
}
169179
}

0 commit comments

Comments
 (0)