SQOOP-807: Verify whether job object can be safely removed prior removing

(Jarek Jarcec Cecho via Cheolsoo Park)

repository/repository-derby/src/main/java/org/apache/sqoop/repository/derby/DerbyRepositoryHandler.java

@@ -717,8 +717,13 @@ public boolean existsJob(long id, Connection conn) {
 
   @Override
   public boolean inUseJob(long jobId, Connection conn) {
-    // TODO(jarcec): This method will need to be upgraded once submission
+    MSubmission submission = findSubmissionLastForJob(jobId, conn);
-    // engine will be in place as we can't remove "running" job.
+
+    // We can't remove running job
+    if(submission.getStatus().isRunning()) {
+      return true;
+    }
+
     return false;
   }
 

repository/repository-derby/src/test/java/org/apache/sqoop/repository/derby/TestConnectionHandling.java

@@ -147,6 +147,16 @@ public void testCreateConnection() throws Exception {
     assertCountForTable("SQOOP.SQ_CONNECTION_INPUT", 8);
   }
 
+  public void testInUseConnection() throws Exception {
+    loadConnections();
+
+    assertFalse(handler.inUseConnection(1, getDerbyConnection()));
+
+    loadJobs();
+
+    assertTrue(handler.inUseConnection(1, getDerbyConnection()));
+  }
+
   public void testUpdateConnection() throws Exception {
     loadConnections();
 

repository/repository-derby/src/test/java/org/apache/sqoop/repository/derby/TestJobHandling.java

@@ -125,6 +125,16 @@ public void testExistsJob() throws Exception {
     assertFalse(handler.existsJob(5, getDerbyConnection()));
   }
 
+  public void testInUseJob() throws Exception {
+    loadJobs();
+    loadSubmissions();
+
+    assertTrue(handler.inUseJob(1, getDerbyConnection()));
+    assertFalse(handler.inUseJob(2, getDerbyConnection()));
+    assertFalse(handler.inUseJob(3, getDerbyConnection()));
+    assertFalse(handler.inUseJob(4, getDerbyConnection()));
+  }
+
   public void testCreateJob() throws Exception {
     MJob job = getJob();