Skip to content
Original file line number Diff line number Diff line change
Expand Up @@ -148,7 +148,6 @@ int insertActivity(final int planId, final String startOffset, final String type
return insertActivity(planId, startOffset, type, arguments, admin);
}


int insertActivity(final int planId, final String startOffset, final String arguments, User user) throws SQLException {
try (final var statement = connection.createStatement()) {
final var res = statement
Expand Down Expand Up @@ -294,7 +293,7 @@ void assignPreset(int presetId, int activityId, int planId, String userSession)
}
}

void unassignPreset(int presetId, int activityId, int planId) throws SQLException {
void unassignPreset(int presetId, int activityId, int planId) throws SQLException {
try(final var statement = connection.createStatement()){
statement.execute(
//language=sql
Expand All @@ -305,7 +304,6 @@ void unassignPreset(int presetId, int activityId, int planId) throws SQLExceptio
}
}


int insertConstraint(String name, String definition, User user) throws SQLException {
try(final var statement = connection.createStatement()) {
final var res = statement.executeQuery(
Expand All @@ -325,4 +323,62 @@ WITH metadata(id, owner) AS (
return res.getInt("constraint_id");
}
}

void updatePlanDuration(int planId, String newDuration) throws SQLException {
try(final var statement = connection.createStatement()) {
statement.executeUpdate(
//language=sql
"""
update merlin.plan
set duration = '%s'
where id = %d
""".formatted(newDuration, planId)
);
}
}

int getPlanRevision(int planId) throws SQLException {
try(final var statement = connection.createStatement()) {
final var res = statement.executeQuery(
//language=sql
"""
select revision
from merlin.plan
where id = %d
""".formatted(planId)
);
res.next();
return res.getInt("revision");
}
}

String getPlanStartTime(int planId) throws SQLException {
try(final var statement = connection.createStatement()) {
final var res = statement.executeQuery(
//language=sql
"""
select start_time
from merlin.plan
where id = %d
""".formatted(planId)
);
res.next();
return res.getString("start_time");
}
}

String getPlanDuration(int planId) throws SQLException {
try(final var statement = connection.createStatement()) {
final var res = statement.executeQuery(
//language=sql
"""
select duration
from merlin.plan
where id = %d
""".formatted(planId)
);
res.next();
return res.getString("duration");
}
}
}
Loading
Loading