fix bugs in scedule inserting and array mapping

thelastpickle · Feb 12, 2015 · ee33d35 · ee33d35
1 parent ae5cbe5
commit ee33d35
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/main/java/com/spotify/reaper/storage/postgresql/IStoragePostgreSQL.java b/src/main/java/com/spotify/reaper/storage/postgresql/IStoragePostgreSQL.java
@@ -240,7 +240,7 @@ public RepairSegment getNextFreeRepairSegmentOnRange(@Bind("runId") long runId,
   @Mapper(RepairScheduleMapper.class)
   public RepairSchedule getRepairSchedule(@Bind("id") long repairScheduleId);
 
-  @SqlQuery(SQL_INSERT_REPAIR_SCHEDULE)
+  @SqlUpdate(SQL_INSERT_REPAIR_SCHEDULE)
   @GetGeneratedKeys
   public long insertRepairSchedule(@BindBean RepairSchedule newRepairSchedule);
 

diff --git a/src/main/java/com/spotify/reaper/storage/postgresql/RepairScheduleMapper.java b/src/main/java/com/spotify/reaper/storage/postgresql/RepairScheduleMapper.java
@@ -18,7 +18,6 @@
 import com.spotify.reaper.core.RepairSchedule;
 
 import org.apache.cassandra.repair.RepairParallelism;
-import org.apache.commons.lang.ArrayUtils;
 import org.skife.jdbi.v2.StatementContext;
 import org.skife.jdbi.v2.tweak.ResultSetMapper;
 
@@ -29,7 +28,7 @@ public class RepairScheduleMapper implements ResultSetMapper<RepairSchedule> {
 
   @Override
   public RepairSchedule map(int index, ResultSet r, StatementContext ctx) throws SQLException {
-    Integer[] runHistory = ArrayUtils.toObject((int[]) r.getArray("run_history").getArray());
+    Integer[] runHistory = (Integer[]) r.getArray("run_history").getArray();
     Long[] runHistoryLong;
     if (null != runHistory && runHistory.length > 0) {
       runHistoryLong = new Long[runHistory.length];
@@ -53,4 +52,5 @@ public RepairSchedule map(int index, ResultSet r, StatementContext ctx) throws S
         .pauseTime(RepairRunMapper.getDateTimeOrNull(r, "pause_time"))
         .build(r.getLong("id"));
   }
+
 }