aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--src/main/java/at/ac/tuwien/sepm/assignment/groupphase/missioncontrol/dao/OperationDatabaseDAO.java9
1 files changed, 8 insertions, 1 deletions
diff --git a/src/main/java/at/ac/tuwien/sepm/assignment/groupphase/missioncontrol/dao/OperationDatabaseDAO.java b/src/main/java/at/ac/tuwien/sepm/assignment/groupphase/missioncontrol/dao/OperationDatabaseDAO.java
index 53682f9..238a2a8 100644
--- a/src/main/java/at/ac/tuwien/sepm/assignment/groupphase/missioncontrol/dao/OperationDatabaseDAO.java
+++ b/src/main/java/at/ac/tuwien/sepm/assignment/groupphase/missioncontrol/dao/OperationDatabaseDAO.java
@@ -114,16 +114,23 @@ public class OperationDatabaseDAO implements OperationDAO {
String sql =
"INSERT INTO VehicleOperation(vehicleId, operationId)"
+ " SELECT version, ? FROM Vehicle WHERE id = ?";
+ String sqlUpdateVehicleStatus =
+ "UPDATE Vehicle SET status = 'ZUM_BERUFUNGSORT' WHERE id = ?";
- try (PreparedStatement pstmt = con.prepareStatement(sql)) {
+ try (PreparedStatement pstmt = con.prepareStatement(sql);
+ PreparedStatement stmtUpdateVehicleStatus =
+ con.prepareStatement(sqlUpdateVehicleStatus)) {
pstmt.setLong(1, operationId);
for (long id : (Iterable<Long>) vehicles.stream().map(Vehicle::id)::iterator) {
pstmt.setLong(2, id);
+ stmtUpdateVehicleStatus.setLong(1, id);
pstmt.addBatch();
+ stmtUpdateVehicleStatus.addBatch();
}
pstmt.executeBatch();
+ stmtUpdateVehicleStatus.executeBatch();
}
}