You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@oozie.apache.org by ry...@apache.org on 2013/09/07 02:25:33 UTC
svn commit: r1520716 [5/5] - in /oozie/trunk: ./
core/src/main/java/org/apache/oozie/
core/src/main/java/org/apache/oozie/command/
core/src/main/java/org/apache/oozie/command/bundle/
core/src/main/java/org/apache/oozie/command/coord/ core/src/main/java...
Modified: oozie/trunk/core/src/test/java/org/apache/oozie/executor/jpa/TestCoordJobsCountNotForPurgeFromParentIdJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/test/java/org/apache/oozie/executor/jpa/TestCoordJobsCountNotForPurgeFromParentIdJPAExecutor.java?rev=1520716&r1=1520715&r2=1520716&view=diff
==============================================================================
--- oozie/trunk/core/src/test/java/org/apache/oozie/executor/jpa/TestCoordJobsCountNotForPurgeFromParentIdJPAExecutor.java (original)
+++ oozie/trunk/core/src/test/java/org/apache/oozie/executor/jpa/TestCoordJobsCountNotForPurgeFromParentIdJPAExecutor.java Sat Sep 7 00:25:30 2013
@@ -22,6 +22,7 @@ import org.apache.oozie.CoordinatorJobBe
import org.apache.oozie.client.CoordinatorJob;
import org.apache.oozie.client.Job;
import org.apache.oozie.command.TestPurgeXCommand;
+import org.apache.oozie.executor.jpa.CoordJobQueryExecutor.CoordJobQuery;
import org.apache.oozie.service.JPAService;
import org.apache.oozie.service.Services;
import org.apache.oozie.test.XDataTestCase;
@@ -59,7 +60,7 @@ public class TestCoordJobsCountNotForPur
CoordinatorJobBean coordJob1 = addRecordToCoordJobTable(CoordinatorJob.Status.SUCCEEDED, false, false);
coordJob1 = TestPurgeXCommand.setLastModifiedTime(coordJob1, "2009-12-01T01:00Z");
coordJob1.setAppName("coord1");
- jpaService.execute(new CoordJobUpdateJPAExecutor(coordJob1));
+ CoordJobQueryExecutor.getInstance().executeUpdate(CoordJobQuery.UPDATE_COORD_JOB, coordJob1);
addRecordToBundleActionTable(bundleJobId, coordJob1.getId(), coordJob1.getAppName(), 0, Job.Status.SUCCEEDED);
days = 1;
assertEquals(0, (long) jpaService.execute(new CoordJobsCountNotForPurgeFromParentIdJPAExecutor(days, bundleJobId)));
@@ -69,7 +70,7 @@ public class TestCoordJobsCountNotForPur
CoordinatorJobBean coordJob2 = addRecordToCoordJobTable(CoordinatorJob.Status.DONEWITHERROR, false, false);
coordJob2 = TestPurgeXCommand.setLastModifiedTime(coordJob2, "2009-11-01T01:00Z");
coordJob2.setAppName("coord2");
- jpaService.execute(new CoordJobUpdateJPAExecutor(coordJob2));
+ CoordJobQueryExecutor.getInstance().executeUpdate(CoordJobQuery.UPDATE_COORD_JOB, coordJob2);
addRecordToBundleActionTable(bundleJobId, coordJob2.getId(), coordJob2.getAppName(), 0, Job.Status.DONEWITHERROR);
days = TestPurgeXCommand.getNumDaysToNotBePurged(coordJob1.getLastModifiedTime());
assertEquals(1, (long) jpaService.execute(new CoordJobsCountNotForPurgeFromParentIdJPAExecutor(days, bundleJobId)));
@@ -79,7 +80,7 @@ public class TestCoordJobsCountNotForPur
CoordinatorJobBean coordJob3 = addRecordToCoordJobTable(CoordinatorJob.Status.FAILED, false, false);
coordJob3 = TestPurgeXCommand.setLastModifiedTime(coordJob3, "2009-10-01T01:00Z");
coordJob3.setAppName("coord3");
- jpaService.execute(new CoordJobUpdateJPAExecutor(coordJob3));
+ CoordJobQueryExecutor.getInstance().executeUpdate(CoordJobQuery.UPDATE_COORD_JOB, coordJob3);
addRecordToBundleActionTable(bundleJobId, coordJob3.getId(), coordJob3.getAppName(), 0, Job.Status.FAILED);
days = TestPurgeXCommand.getNumDaysToNotBePurged(coordJob2.getLastModifiedTime());
assertEquals(2, (long) jpaService.execute(new CoordJobsCountNotForPurgeFromParentIdJPAExecutor(days, bundleJobId)));
@@ -89,7 +90,7 @@ public class TestCoordJobsCountNotForPur
CoordinatorJobBean coordJob4 = addRecordToCoordJobTable(CoordinatorJob.Status.KILLED, false, false);
coordJob4 = TestPurgeXCommand.setLastModifiedTime(coordJob4, "2009-09-01T01:00Z");
coordJob4.setAppName("coord4");
- jpaService.execute(new CoordJobUpdateJPAExecutor(coordJob4));
+ CoordJobQueryExecutor.getInstance().executeUpdate(CoordJobQuery.UPDATE_COORD_JOB, coordJob4);
addRecordToBundleActionTable(bundleJobId, coordJob4.getId(), coordJob4.getAppName(), 0, Job.Status.KILLED);
days = TestPurgeXCommand.getNumDaysToNotBePurged(coordJob3.getLastModifiedTime());
assertEquals(3, (long) jpaService.execute(new CoordJobsCountNotForPurgeFromParentIdJPAExecutor(days, bundleJobId)));
@@ -99,7 +100,7 @@ public class TestCoordJobsCountNotForPur
CoordinatorJobBean coordJob5 = addRecordToCoordJobTable(CoordinatorJob.Status.PAUSED, false, false);
coordJob5 = TestPurgeXCommand.setLastModifiedTime(coordJob5, "2009-08-01T01:00Z");
coordJob5.setAppName("coord5");
- jpaService.execute(new CoordJobUpdateJPAExecutor(coordJob5));
+ CoordJobQueryExecutor.getInstance().executeUpdate(CoordJobQuery.UPDATE_COORD_JOB, coordJob5);
addRecordToBundleActionTable(bundleJobId, coordJob5.getId(), coordJob5.getAppName(), 0, Job.Status.PAUSED);
days = TestPurgeXCommand.getNumDaysToNotBePurged(coordJob4.getLastModifiedTime());
assertEquals(5, (long) jpaService.execute(new CoordJobsCountNotForPurgeFromParentIdJPAExecutor(days, bundleJobId)));
@@ -109,7 +110,7 @@ public class TestCoordJobsCountNotForPur
CoordinatorJobBean coordJob6 = addRecordToCoordJobTable(CoordinatorJob.Status.PAUSEDWITHERROR, false, false);
coordJob5 = TestPurgeXCommand.setLastModifiedTime(coordJob6, "2009-07-01T01:00Z");
coordJob5.setAppName("coord6");
- jpaService.execute(new CoordJobUpdateJPAExecutor(coordJob6));
+ CoordJobQueryExecutor.getInstance().executeUpdate(CoordJobQuery.UPDATE_COORD_JOB, coordJob6);
addRecordToBundleActionTable(bundleJobId, coordJob6.getId(), coordJob6.getAppName(), 0, Job.Status.PAUSEDWITHERROR);
days = TestPurgeXCommand.getNumDaysToNotBePurged(coordJob5.getLastModifiedTime());
assertEquals(6, (long) jpaService.execute(new CoordJobsCountNotForPurgeFromParentIdJPAExecutor(days, bundleJobId)));
@@ -119,7 +120,7 @@ public class TestCoordJobsCountNotForPur
CoordinatorJobBean coordJob7 = addRecordToCoordJobTable(CoordinatorJob.Status.PREMATER, false, false);
coordJob5 = TestPurgeXCommand.setLastModifiedTime(coordJob7, "2009-06-01T01:00Z");
coordJob5.setAppName("coord7");
- jpaService.execute(new CoordJobUpdateJPAExecutor(coordJob6));
+ CoordJobQueryExecutor.getInstance().executeUpdate(CoordJobQuery.UPDATE_COORD_JOB, coordJob6);
addRecordToBundleActionTable(bundleJobId, coordJob7.getId(), coordJob7.getAppName(), 0, Job.Status.PREMATER);
days = TestPurgeXCommand.getNumDaysToNotBePurged(coordJob6.getLastModifiedTime());
assertEquals(7, (long) jpaService.execute(new CoordJobsCountNotForPurgeFromParentIdJPAExecutor(days, bundleJobId)));
@@ -129,7 +130,7 @@ public class TestCoordJobsCountNotForPur
CoordinatorJobBean coordJob8 = addRecordToCoordJobTable(CoordinatorJob.Status.PREP, false, false);
coordJob8 = TestPurgeXCommand.setLastModifiedTime(coordJob8, "2009-05-01T01:00Z");
coordJob8.setAppName("coord8");
- jpaService.execute(new CoordJobUpdateJPAExecutor(coordJob8));
+ CoordJobQueryExecutor.getInstance().executeUpdate(CoordJobQuery.UPDATE_COORD_JOB, coordJob8);
addRecordToBundleActionTable(bundleJobId, coordJob8.getId(), coordJob8.getAppName(), 0, Job.Status.PREP);
days = TestPurgeXCommand.getNumDaysToNotBePurged(coordJob7.getLastModifiedTime());
assertEquals(8, (long) jpaService.execute(new CoordJobsCountNotForPurgeFromParentIdJPAExecutor(days, bundleJobId)));
@@ -139,7 +140,7 @@ public class TestCoordJobsCountNotForPur
CoordinatorJobBean coordJob9 = addRecordToCoordJobTable(CoordinatorJob.Status.PREPPAUSED, false, false);
coordJob9 = TestPurgeXCommand.setLastModifiedTime(coordJob9, "2009-04-01T01:00Z");
coordJob9.setAppName("coord9");
- jpaService.execute(new CoordJobUpdateJPAExecutor(coordJob9));
+ CoordJobQueryExecutor.getInstance().executeUpdate(CoordJobQuery.UPDATE_COORD_JOB, coordJob9);
addRecordToBundleActionTable(bundleJobId, coordJob9.getId(), coordJob9.getAppName(), 0, Job.Status.PREPPAUSED);
days = TestPurgeXCommand.getNumDaysToNotBePurged(coordJob8.getLastModifiedTime());
assertEquals(9, (long) jpaService.execute(new CoordJobsCountNotForPurgeFromParentIdJPAExecutor(days, bundleJobId)));
@@ -149,7 +150,7 @@ public class TestCoordJobsCountNotForPur
CoordinatorJobBean coordJob10 = addRecordToCoordJobTable(CoordinatorJob.Status.PREPSUSPENDED, false, false);
coordJob10 = TestPurgeXCommand.setLastModifiedTime(coordJob10, "2009-03-01T01:00Z");
coordJob10.setAppName("coord10");
- jpaService.execute(new CoordJobUpdateJPAExecutor(coordJob10));
+ CoordJobQueryExecutor.getInstance().executeUpdate(CoordJobQuery.UPDATE_COORD_JOB, coordJob10);
addRecordToBundleActionTable(bundleJobId, coordJob10.getId(), coordJob10.getAppName(), 0, Job.Status.PREPSUSPENDED);
days = TestPurgeXCommand.getNumDaysToNotBePurged(coordJob9.getLastModifiedTime());
assertEquals(10, (long) jpaService.execute(new CoordJobsCountNotForPurgeFromParentIdJPAExecutor(days, bundleJobId)));
@@ -159,7 +160,7 @@ public class TestCoordJobsCountNotForPur
CoordinatorJobBean coordJob11 = addRecordToCoordJobTable(CoordinatorJob.Status.RUNNING, false, false);
coordJob11 = TestPurgeXCommand.setLastModifiedTime(coordJob11, "2009-02-01T01:00Z");
coordJob11.setAppName("coord11");
- jpaService.execute(new CoordJobUpdateJPAExecutor(coordJob11));
+ CoordJobQueryExecutor.getInstance().executeUpdate(CoordJobQuery.UPDATE_COORD_JOB, coordJob11);
addRecordToBundleActionTable(bundleJobId, coordJob11.getId(), coordJob11.getAppName(), 0, Job.Status.RUNNING);
days = TestPurgeXCommand.getNumDaysToNotBePurged(coordJob10.getLastModifiedTime());
assertEquals(11, (long) jpaService.execute(new CoordJobsCountNotForPurgeFromParentIdJPAExecutor(days, bundleJobId)));
@@ -169,7 +170,7 @@ public class TestCoordJobsCountNotForPur
CoordinatorJobBean coordJob12 = addRecordToCoordJobTable(CoordinatorJob.Status.RUNNINGWITHERROR, false, false);
coordJob12 = TestPurgeXCommand.setLastModifiedTime(coordJob12, "2009-01-01T01:00Z");
coordJob12.setAppName("coord12");
- jpaService.execute(new CoordJobUpdateJPAExecutor(coordJob12));
+ CoordJobQueryExecutor.getInstance().executeUpdate(CoordJobQuery.UPDATE_COORD_JOB, coordJob12);
addRecordToBundleActionTable(bundleJobId, coordJob12.getId(), coordJob12.getAppName(), 0, Job.Status.RUNNINGWITHERROR);
days = TestPurgeXCommand.getNumDaysToNotBePurged(coordJob11.getLastModifiedTime());
assertEquals(12, (long) jpaService.execute(new CoordJobsCountNotForPurgeFromParentIdJPAExecutor(days, bundleJobId)));
@@ -179,7 +180,7 @@ public class TestCoordJobsCountNotForPur
CoordinatorJobBean coordJob13 = addRecordToCoordJobTable(CoordinatorJob.Status.SUSPENDED, false, false);
coordJob13 = TestPurgeXCommand.setLastModifiedTime(coordJob13, "2008-12-01T01:00Z");
coordJob13.setAppName("coord13");
- jpaService.execute(new CoordJobUpdateJPAExecutor(coordJob13));
+ CoordJobQueryExecutor.getInstance().executeUpdate(CoordJobQuery.UPDATE_COORD_JOB, coordJob13);
addRecordToBundleActionTable(bundleJobId, coordJob13.getId(), coordJob13.getAppName(), 0, Job.Status.SUSPENDED);
days = TestPurgeXCommand.getNumDaysToNotBePurged(coordJob12.getLastModifiedTime());
assertEquals(13, (long) jpaService.execute(new CoordJobsCountNotForPurgeFromParentIdJPAExecutor(days, bundleJobId)));
@@ -189,7 +190,7 @@ public class TestCoordJobsCountNotForPur
CoordinatorJobBean coordJob14 = addRecordToCoordJobTable(CoordinatorJob.Status.SUSPENDEDWITHERROR, false, false);
coordJob14 = TestPurgeXCommand.setLastModifiedTime(coordJob14, "2008-11-01T01:00Z");
coordJob14.setAppName("coord14");
- jpaService.execute(new CoordJobUpdateJPAExecutor(coordJob14));
+ CoordJobQueryExecutor.getInstance().executeUpdate(CoordJobQuery.UPDATE_COORD_JOB, coordJob14);
addRecordToBundleActionTable(bundleJobId, coordJob14.getId(), coordJob14.getAppName(), 0, Job.Status.SUSPENDEDWITHERROR);
days = TestPurgeXCommand.getNumDaysToNotBePurged(coordJob13.getLastModifiedTime());
assertEquals(14, (long) jpaService.execute(new CoordJobsCountNotForPurgeFromParentIdJPAExecutor(days, bundleJobId)));
Modified: oozie/trunk/core/src/test/java/org/apache/oozie/executor/jpa/TestCoordJobsGetForPurgeJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/test/java/org/apache/oozie/executor/jpa/TestCoordJobsGetForPurgeJPAExecutor.java?rev=1520716&r1=1520715&r2=1520716&view=diff
==============================================================================
--- oozie/trunk/core/src/test/java/org/apache/oozie/executor/jpa/TestCoordJobsGetForPurgeJPAExecutor.java (original)
+++ oozie/trunk/core/src/test/java/org/apache/oozie/executor/jpa/TestCoordJobsGetForPurgeJPAExecutor.java Sat Sep 7 00:25:30 2013
@@ -32,6 +32,7 @@ import org.apache.oozie.CoordinatorJobBe
import org.apache.oozie.client.CoordinatorJob;
import org.apache.oozie.client.OozieClient;
import org.apache.oozie.client.CoordinatorJob.Execution;
+import org.apache.oozie.executor.jpa.CoordJobQueryExecutor.CoordJobQuery;
import org.apache.oozie.local.LocalOozie;
import org.apache.oozie.service.JPAService;
import org.apache.oozie.service.Services;
@@ -74,7 +75,7 @@ public class TestCoordJobsGetForPurgeJPA
CoordinatorJobBean job2 = insertJob(jobId2, CoordinatorJob.Status.SUCCEEDED,
DateUtils.parseDateOozieTZ("2011-01-01T01:00Z"));
job2.setBundleId("some_bundle_parent_id");
- jpaService.execute(new CoordJobUpdateJPAExecutor(job2));
+ CoordJobQueryExecutor.getInstance().executeUpdate(CoordJobQuery.UPDATE_COORD_JOB_BUNDLEID, job2);
CoordJobsGetForPurgeJPAExecutor executor = new CoordJobsGetForPurgeJPAExecutor(10, 50);
List<String> jobList = jpaService.execute(executor);
Modified: oozie/trunk/core/src/test/java/org/apache/oozie/executor/jpa/TestCoordJobsGetFromParentIdJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/test/java/org/apache/oozie/executor/jpa/TestCoordJobsGetFromParentIdJPAExecutor.java?rev=1520716&r1=1520715&r2=1520716&view=diff
==============================================================================
--- oozie/trunk/core/src/test/java/org/apache/oozie/executor/jpa/TestCoordJobsGetFromParentIdJPAExecutor.java (original)
+++ oozie/trunk/core/src/test/java/org/apache/oozie/executor/jpa/TestCoordJobsGetFromParentIdJPAExecutor.java Sat Sep 7 00:25:30 2013
@@ -28,6 +28,7 @@ import org.apache.oozie.CoordinatorJobBe
import org.apache.oozie.client.CoordinatorAction;
import org.apache.oozie.client.CoordinatorJob;
import org.apache.oozie.client.Job;
+import org.apache.oozie.executor.jpa.CoordJobQueryExecutor.CoordJobQuery;
import org.apache.oozie.service.JPAService;
import org.apache.oozie.service.Services;
import org.apache.oozie.test.XDataTestCase;
@@ -62,7 +63,7 @@ public class TestCoordJobsGetFromParentI
CoordinatorJobBean coordJobA1 = addRecordToCoordJobTable(CoordinatorJob.Status.SUCCEEDED, false, false);
CoordinatorJobBean coordJobA2 = addRecordToCoordJobTable(CoordinatorJob.Status.SUCCEEDED, false, false);
coordJobA2.setAppName("something_different");
- jpaService.execute(new CoordJobUpdateJPAExecutor(coordJobA2));
+ CoordJobQueryExecutor.getInstance().executeUpdate(CoordJobQuery.UPDATE_COORD_JOB, coordJobA2);
CoordinatorJobBean coordJobB = addRecordToCoordJobTable(CoordinatorJob.Status.SUCCEEDED, false, false);
CoordinatorActionBean coordActionA1 = addRecordToCoordActionTable(coordJobA1.getId(), 1, CoordinatorAction.Status.SUCCEEDED,
"coord-action-get.xml", 0);
@@ -93,19 +94,19 @@ public class TestCoordJobsGetFromParentI
BundleJobBean bundleJob = addRecordToBundleJobTable(Job.Status.SUCCEEDED, false);
CoordinatorJobBean coordJob1 = addRecordToCoordJobTable(CoordinatorJob.Status.SUCCEEDED, false, false);
coordJob1.setAppName("coordJob1");
- jpaService.execute(new CoordJobUpdateJPAExecutor(coordJob1));
+ CoordJobQueryExecutor.getInstance().executeUpdate(CoordJobQuery.UPDATE_COORD_JOB, coordJob1);
CoordinatorJobBean coordJob2 = addRecordToCoordJobTable(CoordinatorJob.Status.SUCCEEDED, false, false);
coordJob2.setAppName("coordJob2");
- jpaService.execute(new CoordJobUpdateJPAExecutor(coordJob2));
+ CoordJobQueryExecutor.getInstance().executeUpdate(CoordJobQuery.UPDATE_COORD_JOB, coordJob2);
CoordinatorJobBean coordJob3 = addRecordToCoordJobTable(CoordinatorJob.Status.SUCCEEDED, false, false);
coordJob3.setAppName("coordJob3");
- jpaService.execute(new CoordJobUpdateJPAExecutor(coordJob3));
+ CoordJobQueryExecutor.getInstance().executeUpdate(CoordJobQuery.UPDATE_COORD_JOB, coordJob3);
CoordinatorJobBean coordJob4 = addRecordToCoordJobTable(CoordinatorJob.Status.SUCCEEDED, false, false);
coordJob4.setAppName("coordJob4");
- jpaService.execute(new CoordJobUpdateJPAExecutor(coordJob4));
+ CoordJobQueryExecutor.getInstance().executeUpdate(CoordJobQuery.UPDATE_COORD_JOB, coordJob4);
CoordinatorJobBean coordJob5 = addRecordToCoordJobTable(CoordinatorJob.Status.SUCCEEDED, false, false);
coordJob5.setAppName("coordJob5");
- jpaService.execute(new CoordJobUpdateJPAExecutor(coordJob5));
+ CoordJobQueryExecutor.getInstance().executeUpdate(CoordJobQuery.UPDATE_COORD_JOB, coordJob5);
CoordinatorActionBean coordAction1 = addRecordToCoordActionTable(coordJob1.getId(), 1, CoordinatorAction.Status.SUCCEEDED,
"coord-action-get.xml", 0);
CoordinatorActionBean coordAction2 = addRecordToCoordActionTable(coordJob2.getId(), 1, CoordinatorAction.Status.SUCCEEDED,
Modified: oozie/trunk/core/src/test/java/org/apache/oozie/executor/jpa/TestWorkflowActionUpdateJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/test/java/org/apache/oozie/executor/jpa/TestWorkflowActionUpdateJPAExecutor.java?rev=1520716&r1=1520715&r2=1520716&view=diff
==============================================================================
--- oozie/trunk/core/src/test/java/org/apache/oozie/executor/jpa/TestWorkflowActionUpdateJPAExecutor.java (original)
+++ oozie/trunk/core/src/test/java/org/apache/oozie/executor/jpa/TestWorkflowActionUpdateJPAExecutor.java Sat Sep 7 00:25:30 2013
@@ -1,67 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.oozie.executor.jpa;
-
-import org.apache.oozie.WorkflowActionBean;
-import org.apache.oozie.WorkflowJobBean;
-import org.apache.oozie.client.WorkflowAction;
-import org.apache.oozie.client.WorkflowJob;
-import org.apache.oozie.local.LocalOozie;
-import org.apache.oozie.service.JPAService;
-import org.apache.oozie.service.Services;
-import org.apache.oozie.test.XDataTestCase;
-import org.apache.oozie.workflow.WorkflowInstance;
-
-public class TestWorkflowActionUpdateJPAExecutor extends XDataTestCase {
- Services services;
-
- @Override
- protected void setUp() throws Exception {
- super.setUp();
- services = new Services();
- services.init();
- cleanUpDBTables();
- }
-
- @Override
- protected void tearDown() throws Exception {
- services.destroy();
- super.tearDown();
- }
-
- public void testWorkflowActionUpdate() throws Exception {
- WorkflowJobBean job = this.addRecordToWfJobTable(WorkflowJob.Status.RUNNING, WorkflowInstance.Status.RUNNING);
- WorkflowActionBean action = addRecordToWfActionTable(job.getId(), "1", WorkflowAction.Status.PREP);
- _testUpdateAction(action.getId());
- }
-
- private void _testUpdateAction(String actionId) throws Exception {
- JPAService jpaService = Services.get().get(JPAService.class);
- assertNotNull(jpaService);
-
- WorkflowActionGetJPAExecutor actionGetCmd = new WorkflowActionGetJPAExecutor(actionId);
- WorkflowActionBean action1 = jpaService.execute(actionGetCmd);
- action1.setStatus(WorkflowAction.Status.RUNNING);
- WorkflowActionUpdateJPAExecutor wfActionUpdateCmd = new WorkflowActionUpdateJPAExecutor(action1);
- jpaService.execute(wfActionUpdateCmd);
-
- WorkflowActionBean action2 = jpaService.execute(actionGetCmd);
- assertEquals(action2.getStatus(), WorkflowAction.Status.RUNNING);
- }
-
-}
Modified: oozie/trunk/core/src/test/java/org/apache/oozie/executor/jpa/TestWorkflowJobUpdateJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/test/java/org/apache/oozie/executor/jpa/TestWorkflowJobUpdateJPAExecutor.java?rev=1520716&r1=1520715&r2=1520716&view=diff
==============================================================================
--- oozie/trunk/core/src/test/java/org/apache/oozie/executor/jpa/TestWorkflowJobUpdateJPAExecutor.java (original)
+++ oozie/trunk/core/src/test/java/org/apache/oozie/executor/jpa/TestWorkflowJobUpdateJPAExecutor.java Sat Sep 7 00:25:30 2013
@@ -1,72 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.oozie.executor.jpa;
-
-import org.apache.oozie.WorkflowJobBean;
-import org.apache.oozie.client.WorkflowJob;
-import org.apache.oozie.executor.jpa.WorkflowJobGetJPAExecutor;
-import org.apache.oozie.executor.jpa.WorkflowJobUpdateJPAExecutor;
-import org.apache.oozie.service.JPAService;
-import org.apache.oozie.service.Services;
-import org.apache.oozie.test.XDataTestCase;
-import org.apache.oozie.workflow.WorkflowInstance;
-
-public class TestWorkflowJobUpdateJPAExecutor extends XDataTestCase {
- Services services;
-
- @Override
- protected void setUp() throws Exception {
- super.setUp();
- services = new Services();
- services.init();
- cleanUpDBTables();
- }
-
- @Override
- protected void tearDown() throws Exception {
- services.destroy();
- super.tearDown();
- }
-
- public void testWorkflowJobUpdate() throws Exception {
- WorkflowJobBean job = addRecordToWfJobTable(WorkflowJob.Status.PREP, WorkflowInstance.Status.PREP);
-
- JPAService jpaService = Services.get().get(JPAService.class);
- assertNotNull(jpaService);
- WorkflowJobGetJPAExecutor wfGetCmd = new WorkflowJobGetJPAExecutor(job.getId());
- WorkflowJobBean wfBean = jpaService.execute(wfGetCmd);
-
- // first update;
- wfBean.setStatus(WorkflowJob.Status.SUCCEEDED);
- WorkflowJobUpdateJPAExecutor wfUpdateCmd1 = new WorkflowJobUpdateJPAExecutor(wfBean);
- jpaService.execute(wfUpdateCmd1);
- WorkflowJobBean wfBean1 = jpaService.execute(wfGetCmd);
- assertEquals(wfBean1.getId(), job.getId());
- assertEquals(wfBean1.getStatusStr(), "SUCCEEDED");
-
- // second update;
- wfBean.setAppName("test");
- wfBean.setStatus(WorkflowJob.Status.RUNNING);
- WorkflowJobUpdateJPAExecutor wfUpdateCmd2 = new WorkflowJobUpdateJPAExecutor(wfBean);
- jpaService.execute(wfUpdateCmd2);
- WorkflowJobBean wfBean2 = jpaService.execute(wfGetCmd);
- assertEquals(wfBean2.getId(), job.getId());
- assertEquals(wfBean2.getStatusStr(), "RUNNING");
- }
-
-}
Modified: oozie/trunk/core/src/test/java/org/apache/oozie/executor/jpa/TestWorkflowJobsCountNotForPurgeFromWorkflowParentIdJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/test/java/org/apache/oozie/executor/jpa/TestWorkflowJobsCountNotForPurgeFromWorkflowParentIdJPAExecutor.java?rev=1520716&r1=1520715&r2=1520716&view=diff
==============================================================================
--- oozie/trunk/core/src/test/java/org/apache/oozie/executor/jpa/TestWorkflowJobsCountNotForPurgeFromWorkflowParentIdJPAExecutor.java (original)
+++ oozie/trunk/core/src/test/java/org/apache/oozie/executor/jpa/TestWorkflowJobsCountNotForPurgeFromWorkflowParentIdJPAExecutor.java Sat Sep 7 00:25:30 2013
@@ -61,6 +61,7 @@ public class TestWorkflowJobsCountNotFor
days = 1;
assertEquals(0, (long) jpaService.execute(new WorkflowJobsCountNotForPurgeFromWorkflowParentIdJPAExecutor(days, wfJobId)));
days = TestPurgeXCommand.getNumDaysToNotBePurged(subwfJob1.getEndTime());
+ System.out.println("Debug: days " + days);
assertEquals(1, (long) jpaService.execute(new WorkflowJobsCountNotForPurgeFromWorkflowParentIdJPAExecutor(days, wfJobId)));
WorkflowJobBean subwfJob2 = addRecordToWfJobTable(WorkflowJob.Status.FAILED, WorkflowInstance.Status.FAILED, wfJobId);
Modified: oozie/trunk/core/src/test/java/org/apache/oozie/executor/jpa/TestWorkflowJobsGetForPurgeJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/test/java/org/apache/oozie/executor/jpa/TestWorkflowJobsGetForPurgeJPAExecutor.java?rev=1520716&r1=1520715&r2=1520716&view=diff
==============================================================================
--- oozie/trunk/core/src/test/java/org/apache/oozie/executor/jpa/TestWorkflowJobsGetForPurgeJPAExecutor.java (original)
+++ oozie/trunk/core/src/test/java/org/apache/oozie/executor/jpa/TestWorkflowJobsGetForPurgeJPAExecutor.java Sat Sep 7 00:25:30 2013
@@ -21,6 +21,7 @@ import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
+import java.util.Date;
import java.util.List;
import org.apache.hadoop.conf.Configuration;
@@ -28,6 +29,7 @@ import org.apache.hadoop.fs.Path;
import org.apache.oozie.WorkflowJobBean;
import org.apache.oozie.client.OozieClient;
import org.apache.oozie.client.WorkflowJob;
+import org.apache.oozie.executor.jpa.WorkflowJobQueryExecutor.WorkflowJobQuery;
import org.apache.oozie.service.JPAService;
import org.apache.oozie.service.LiteWorkflowStoreService;
import org.apache.oozie.service.Services;
@@ -65,7 +67,8 @@ public class TestWorkflowJobsGetForPurge
WorkflowJobBean job2 = addRecordToWfJobTable(WorkflowJob.Status.FAILED, WorkflowInstance.Status.FAILED);
WorkflowJobBean job3 = addRecordToWfJobTable(WorkflowJob.Status.SUCCEEDED, WorkflowInstance.Status.SUCCEEDED);
job3.setParentId(job1.getId());
- jpaService.execute(new WorkflowJobUpdateJPAExecutor(job3));
+ job3.setLastModifiedTime(new Date());
+ WorkflowJobQueryExecutor.getInstance().executeUpdate(WorkflowJobQuery.UPDATE_WORKFLOW_PARENT_MODIFIED, job3);
List<String> list = new ArrayList<String>();
list.addAll(jpaService.execute(new WorkflowJobsGetForPurgeJPAExecutor(1, 20)));
Modified: oozie/trunk/core/src/test/java/org/apache/oozie/service/TestActionCheckerService.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/test/java/org/apache/oozie/service/TestActionCheckerService.java?rev=1520716&r1=1520715&r2=1520716&view=diff
==============================================================================
--- oozie/trunk/core/src/test/java/org/apache/oozie/service/TestActionCheckerService.java (original)
+++ oozie/trunk/core/src/test/java/org/apache/oozie/service/TestActionCheckerService.java Sat Sep 7 00:25:30 2013
@@ -30,8 +30,9 @@ import org.apache.oozie.client.Coordinat
import org.apache.oozie.client.WorkflowJob;
import org.apache.oozie.client.OozieClient;
import org.apache.oozie.executor.jpa.CoordActionGetJPAExecutor;
-import org.apache.oozie.executor.jpa.WorkflowActionUpdateJPAExecutor;
+import org.apache.oozie.executor.jpa.WorkflowActionQueryExecutor;
import org.apache.oozie.executor.jpa.WorkflowActionsGetForJobJPAExecutor;
+import org.apache.oozie.executor.jpa.WorkflowActionQueryExecutor.WorkflowActionQuery;
import org.apache.oozie.CoordinatorActionBean;
import org.apache.oozie.CoordinatorEngine;
import org.apache.oozie.CoordinatorJobBean;
@@ -191,7 +192,7 @@ public class TestActionCheckerService ex
assertEquals(WorkflowActionBean.Status.RUNNING, action.getStatus());
action.setLastCheckTime(new Date());
- jpaService.execute(new WorkflowActionUpdateJPAExecutor(action));
+ WorkflowActionQueryExecutor.getInstance().executeUpdate(WorkflowActionQuery.UPDATE_ACTION_FOR_LAST_CHECKED_TIME, action);
int actionCheckDelay = 20;
Modified: oozie/trunk/core/src/test/java/org/apache/oozie/service/TestPauseTransitService.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/test/java/org/apache/oozie/service/TestPauseTransitService.java?rev=1520716&r1=1520715&r2=1520716&view=diff
==============================================================================
--- oozie/trunk/core/src/test/java/org/apache/oozie/service/TestPauseTransitService.java (original)
+++ oozie/trunk/core/src/test/java/org/apache/oozie/service/TestPauseTransitService.java Sat Sep 7 00:25:30 2013
@@ -19,7 +19,6 @@ package org.apache.oozie.service;
import java.util.Date;
-import org.apache.hadoop.conf.Configuration;
import org.apache.oozie.BundleActionBean;
import org.apache.oozie.BundleJobBean;
import org.apache.oozie.CoordinatorJobBean;
@@ -27,10 +26,12 @@ import org.apache.oozie.client.Coordinat
import org.apache.oozie.client.Job;
import org.apache.oozie.executor.jpa.BundleActionGetJPAExecutor;
import org.apache.oozie.executor.jpa.BundleJobGetJPAExecutor;
-import org.apache.oozie.executor.jpa.BundleJobUpdateJPAExecutor;
+import org.apache.oozie.executor.jpa.BundleJobQueryExecutor;
+import org.apache.oozie.executor.jpa.CoordJobQueryExecutor;
+import org.apache.oozie.executor.jpa.BundleJobQueryExecutor.BundleJobQuery;
import org.apache.oozie.executor.jpa.CoordJobGetJPAExecutor;
import org.apache.oozie.executor.jpa.CoordJobInsertJPAExecutor;
-import org.apache.oozie.executor.jpa.CoordJobUpdateJPAExecutor;
+import org.apache.oozie.executor.jpa.CoordJobQueryExecutor.CoordJobQuery;
import org.apache.oozie.executor.jpa.JPAExecutorException;
import org.apache.oozie.service.JPAService;
import org.apache.oozie.service.Services;
@@ -72,7 +73,7 @@ public class TestPauseTransitService ext
job.setPauseTime(new Date(new Date().getTime() - 30 * 1000));
job.setKickoffTime(new Date(new Date().getTime() + 3600 * 1000));
- jpaService.execute(new BundleJobUpdateJPAExecutor(job));
+ BundleJobQueryExecutor.getInstance().executeUpdate(BundleJobQuery.UPDATE_BUNDLE_JOB_PAUSE_KICKOFF, job);
Runnable pauseStartRunnable = new PauseTransitRunnable();
pauseStartRunnable.run();
@@ -89,7 +90,7 @@ public class TestPauseTransitService ext
assertEquals(Job.Status.PREPPAUSED, job.getStatus());
job.setPauseTime(new Date(new Date().getTime() + 3600 * 1000));
- jpaService.execute(new BundleJobUpdateJPAExecutor(job));
+ BundleJobQueryExecutor.getInstance().executeUpdate(BundleJobQuery.UPDATE_BUNDLE_JOB_PAUSE_KICKOFF, job);
pauseStartRunnable.run();
@@ -116,7 +117,7 @@ public class TestPauseTransitService ext
job.setPauseTime(new Date(new Date().getTime() - 30 * 1000));
job.setKickoffTime(new Date(new Date().getTime() + 3600 * 1000));
- jpaService.execute(new BundleJobUpdateJPAExecutor(job));
+ BundleJobQueryExecutor.getInstance().executeUpdate(BundleJobQuery.UPDATE_BUNDLE_JOB_PAUSE_KICKOFF, job);
Runnable pauseStartRunnable = new PauseTransitRunnable();
pauseStartRunnable.run();
@@ -133,7 +134,7 @@ public class TestPauseTransitService ext
assertEquals(Job.Status.PREPPAUSED, job.getStatus());
job.setPauseTime(null);
- jpaService.execute(new BundleJobUpdateJPAExecutor(job));
+ BundleJobQueryExecutor.getInstance().executeUpdate(BundleJobQuery.UPDATE_BUNDLE_JOB_PAUSE_KICKOFF, job);
pauseStartRunnable.run();
@@ -160,7 +161,7 @@ public class TestPauseTransitService ext
Date pauseTime = new Date(new Date().getTime() - 30 * 1000);
job.setPauseTime(pauseTime);
- jpaService.execute(new BundleJobUpdateJPAExecutor(job));
+ BundleJobQueryExecutor.getInstance().executeUpdate(BundleJobQuery.UPDATE_BUNDLE_JOB_PAUSE_KICKOFF, job);
BundleActionBean bundleAction1 = this.addRecordToBundleActionTable(job.getId(), "action1", 0, Job.Status.RUNNING);
BundleActionBean bundleAction2 = this.addRecordToBundleActionTable(job.getId(), "action2", 0, Job.Status.RUNNING);
@@ -174,10 +175,12 @@ public class TestPauseTransitService ext
coordJob1.setPauseTime(pauseTime);
coordJob1.setBundleId(job.getId());
- jpaService.execute(new CoordJobUpdateJPAExecutor(coordJob1));
+ CoordJobQueryExecutor.getInstance().executeUpdate(
+ CoordJobQuery.UPDATE_COORD_JOB_BUNDLEID_APPNAMESPACE_PAUSETIME, coordJob1);
coordJob2.setPauseTime(pauseTime);
coordJob2.setBundleId(job.getId());
- jpaService.execute(new CoordJobUpdateJPAExecutor(coordJob2));
+ CoordJobQueryExecutor.getInstance().executeUpdate(
+ CoordJobQuery.UPDATE_COORD_JOB_BUNDLEID_APPNAMESPACE_PAUSETIME, coordJob2);
BundleJobGetJPAExecutor bundleJobGetExecutor = new BundleJobGetJPAExecutor(job.getId());
job = jpaService.execute(bundleJobGetExecutor);
@@ -231,7 +234,7 @@ public class TestPauseTransitService ext
assertNotNull(jpaService);
job.setPauseTime(null);
- jpaService.execute(new BundleJobUpdateJPAExecutor(job));
+ BundleJobQueryExecutor.getInstance().executeUpdate(BundleJobQuery.UPDATE_BUNDLE_JOB_PAUSE_KICKOFF, job);
BundleActionBean bundleAction1 = this.addRecordToBundleActionTable(job.getId(), "action1", 0, Job.Status.PAUSED);
BundleActionBean bundleAction2 = this.addRecordToBundleActionTable(job.getId(), "action2", 0, Job.Status.PAUSED);
@@ -245,10 +248,12 @@ public class TestPauseTransitService ext
coordJob1.setPauseTime(null);
coordJob1.setBundleId(job.getId());
- jpaService.execute(new CoordJobUpdateJPAExecutor(coordJob1));
+ CoordJobQueryExecutor.getInstance().executeUpdate(
+ CoordJobQuery.UPDATE_COORD_JOB_BUNDLEID_APPNAMESPACE_PAUSETIME, coordJob1);
coordJob2.setPauseTime(null);
coordJob2.setBundleId(job.getId());
- jpaService.execute(new CoordJobUpdateJPAExecutor(coordJob2));
+ CoordJobQueryExecutor.getInstance().executeUpdate(
+ CoordJobQuery.UPDATE_COORD_JOB_BUNDLEID_APPNAMESPACE_PAUSETIME, coordJob2);
BundleJobGetJPAExecutor bundleJobGetExecutor = new BundleJobGetJPAExecutor(job.getId());
job = jpaService.execute(bundleJobGetExecutor);
@@ -319,10 +324,12 @@ public class TestPauseTransitService ext
coordJob1.setAppNamespace(SchemaService.COORDINATOR_NAMESPACE_URI_1);
coordJob1.setPauseTime(pauseTime);
- jpaService.execute(new CoordJobUpdateJPAExecutor(coordJob1));
+ CoordJobQueryExecutor.getInstance().executeUpdate(
+ CoordJobQuery.UPDATE_COORD_JOB_BUNDLEID_APPNAMESPACE_PAUSETIME, coordJob1);
coordJob2.setAppNamespace(SchemaService.COORDINATOR_NAMESPACE_URI_1);
coordJob2.setPauseTime(pauseTime);
- jpaService.execute(new CoordJobUpdateJPAExecutor(coordJob2));
+ CoordJobQueryExecutor.getInstance().executeUpdate(
+ CoordJobQuery.UPDATE_COORD_JOB_BUNDLEID_APPNAMESPACE_PAUSETIME, coordJob2);
Runnable pauseStartRunnable = new PauseTransitRunnable();
pauseStartRunnable.run();
@@ -356,7 +363,7 @@ public class TestPauseTransitService ext
assertNotNull(jpaService);
job.setKickoffTime(new Date(new Date().getTime() - 30 * 1000));
- jpaService.execute(new BundleJobUpdateJPAExecutor(job));
+ BundleJobQueryExecutor.getInstance().executeUpdate(BundleJobQuery.UPDATE_BUNDLE_JOB_PAUSE_KICKOFF, job);
Runnable pauseStartRunnable = new PauseTransitRunnable();
pauseStartRunnable.run();
@@ -384,7 +391,7 @@ public class TestPauseTransitService ext
assertNotNull(jpaService);
job.setKickoffTime(new Date(new Date().getTime() - 30 * 1000));
- jpaService.execute(new BundleJobUpdateJPAExecutor(job));
+ BundleJobQueryExecutor.getInstance().executeUpdate(BundleJobQuery.UPDATE_BUNDLE_JOB_PAUSE_KICKOFF, job);
Runnable pauseStartRunnable = new PauseTransitRunnable();
pauseStartRunnable.run();
Modified: oozie/trunk/core/src/test/java/org/apache/oozie/service/TestPurgeService.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/test/java/org/apache/oozie/service/TestPurgeService.java?rev=1520716&r1=1520715&r2=1520716&view=diff
==============================================================================
--- oozie/trunk/core/src/test/java/org/apache/oozie/service/TestPurgeService.java (original)
+++ oozie/trunk/core/src/test/java/org/apache/oozie/service/TestPurgeService.java Sat Sep 7 00:25:30 2013
@@ -49,7 +49,8 @@ import org.apache.oozie.executor.jpa.Coo
import org.apache.oozie.executor.jpa.CoordJobInsertJPAExecutor;
import org.apache.oozie.executor.jpa.JPAExecutorException;
import org.apache.oozie.executor.jpa.WorkflowJobGetJPAExecutor;
-import org.apache.oozie.executor.jpa.WorkflowJobUpdateJPAExecutor;
+import org.apache.oozie.executor.jpa.WorkflowJobQueryExecutor;
+import org.apache.oozie.executor.jpa.WorkflowJobQueryExecutor.WorkflowJobQuery;
import org.apache.oozie.service.PurgeService.PurgeRunnable;
import org.apache.oozie.test.XDataTestCase;
import org.apache.oozie.util.DateUtils;
@@ -122,8 +123,8 @@ public class TestPurgeService extends XD
WorkflowJobBean wfBean = jpaService.execute(wfJobGetCmd);
Date endDate = new Date(System.currentTimeMillis() - 2 * 24 * 60 * 60 * 1000);
wfBean.setEndTime(endDate);
- WorkflowJobUpdateJPAExecutor wfUpdateCmd = new WorkflowJobUpdateJPAExecutor(wfBean);
- jpaService.execute(wfUpdateCmd);
+ wfBean.setLastModifiedTime(new Date());
+ WorkflowJobQueryExecutor.getInstance().executeUpdate(WorkflowJobQuery.UPDATE_WORKFLOW_STATUS_INSTANCE_MOD_END, wfBean);
Runnable purgeRunnable = new PurgeRunnable(1, 1, 1, 100);
purgeRunnable.run();
Modified: oozie/trunk/core/src/test/java/org/apache/oozie/service/TestStatusTransitService.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/test/java/org/apache/oozie/service/TestStatusTransitService.java?rev=1520716&r1=1520715&r2=1520716&view=diff
==============================================================================
--- oozie/trunk/core/src/test/java/org/apache/oozie/service/TestStatusTransitService.java (original)
+++ oozie/trunk/core/src/test/java/org/apache/oozie/service/TestStatusTransitService.java Sat Sep 7 00:25:30 2013
@@ -41,10 +41,10 @@ import org.apache.oozie.executor.jpa.Bun
import org.apache.oozie.executor.jpa.BundleJobGetJPAExecutor;
import org.apache.oozie.executor.jpa.BundleJobInsertJPAExecutor;
import org.apache.oozie.executor.jpa.CoordActionGetJPAExecutor;
-import org.apache.oozie.executor.jpa.CoordActionInsertJPAExecutor;
import org.apache.oozie.executor.jpa.CoordJobGetJPAExecutor;
import org.apache.oozie.executor.jpa.CoordJobInsertJPAExecutor;
-import org.apache.oozie.executor.jpa.CoordJobUpdateJPAExecutor;
+import org.apache.oozie.executor.jpa.CoordJobQueryExecutor;
+import org.apache.oozie.executor.jpa.CoordJobQueryExecutor.CoordJobQuery;
import org.apache.oozie.executor.jpa.JPAExecutorException;
import org.apache.oozie.executor.jpa.WorkflowJobGetJPAExecutor;
import org.apache.oozie.executor.jpa.WorkflowJobInsertJPAExecutor;
@@ -157,7 +157,7 @@ public class TestStatusTransitService ex
final JPAService jpaService = Services.get().get(JPAService.class);
assertNotNull(jpaService);
coordJob.setAppNamespace(SchemaService.COORDINATOR_NAMESPACE_URI_1);
- jpaService.execute(new CoordJobUpdateJPAExecutor(coordJob));
+ CoordJobQueryExecutor.getInstance().executeUpdate(CoordJobQuery.UPDATE_COORD_JOB_APPNAMESPACE, coordJob);
addRecordToCoordActionTable(coordJob.getId(), 1, CoordinatorAction.Status.KILLED, "coord-action-get.xml", 0);
addRecordToCoordActionTable(coordJob.getId(), 2, CoordinatorAction.Status.SUCCEEDED, "coord-action-get.xml", 0);
Modified: oozie/trunk/core/src/test/java/org/apache/oozie/servlet/TestV2SLAServlet.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/test/java/org/apache/oozie/servlet/TestV2SLAServlet.java?rev=1520716&r1=1520715&r2=1520716&view=diff
==============================================================================
--- oozie/trunk/core/src/test/java/org/apache/oozie/servlet/TestV2SLAServlet.java (original)
+++ oozie/trunk/core/src/test/java/org/apache/oozie/servlet/TestV2SLAServlet.java Sat Sep 7 00:25:30 2013
@@ -36,8 +36,8 @@ import org.apache.oozie.client.event.SLA
import org.apache.oozie.client.rest.JsonBean;
import org.apache.oozie.client.rest.JsonTags;
import org.apache.oozie.client.rest.RestConstants;
+import org.apache.oozie.executor.jpa.BatchQueryExecutor;
import org.apache.oozie.executor.jpa.JPAExecutorException;
-import org.apache.oozie.executor.jpa.sla.SLACalculationInsertUpdateJPAExecutor;
import org.apache.oozie.service.JPAService;
import org.apache.oozie.service.Services;
import org.apache.oozie.sla.SLASummaryBean;
@@ -187,8 +187,6 @@ public class TestV2SLAServlet extends Da
nominalTime.add(Calendar.HOUR, 1);
}
- SLACalculationInsertUpdateJPAExecutor writeCmd = new SLACalculationInsertUpdateJPAExecutor(list, null);
- JPAService jpaService = Services.get().get(JPAService.class);
- jpaService.execute(writeCmd);
+ BatchQueryExecutor.getInstance().executeBatchInsertUpdateDelete(list, null, null);
}
}
Modified: oozie/trunk/core/src/test/java/org/apache/oozie/sla/TestSLACalculationJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/test/java/org/apache/oozie/sla/TestSLACalculationJPAExecutor.java?rev=1520716&r1=1520715&r2=1520716&view=diff
==============================================================================
--- oozie/trunk/core/src/test/java/org/apache/oozie/sla/TestSLACalculationJPAExecutor.java (original)
+++ oozie/trunk/core/src/test/java/org/apache/oozie/sla/TestSLACalculationJPAExecutor.java Sat Sep 7 00:25:30 2013
@@ -22,11 +22,15 @@ import java.util.Calendar;
import java.util.Date;
import java.util.List;
+import org.apache.oozie.AppType;
import org.apache.oozie.FaultInjection;
import org.apache.oozie.client.event.SLAEvent.EventStatus;
import org.apache.oozie.client.rest.JsonBean;
import org.apache.oozie.command.SkipCommitFaultInjection;
-import org.apache.oozie.executor.jpa.sla.SLACalculationInsertUpdateJPAExecutor;
+import org.apache.oozie.executor.jpa.BatchQueryExecutor;
+import org.apache.oozie.executor.jpa.BatchQueryExecutor.UpdateEntry;
+import org.apache.oozie.executor.jpa.SLASummaryQueryExecutor;
+import org.apache.oozie.executor.jpa.SLASummaryQueryExecutor.SLASummaryQuery;
import org.apache.oozie.executor.jpa.sla.SLASummaryGetJPAExecutor;
import org.apache.oozie.service.JPAService;
import org.apache.oozie.service.Services;
@@ -82,11 +86,9 @@ public class TestSLACalculationJPAExecut
SLASummaryBean bean2 = _createSLASummaryBean(wfId, "RUNNING", EventStatus.START_MISS, expStart, expEnd, 1000,
actStart, actEnd, 2000, (byte) 1, actEnd);
- List<JsonBean> list = new ArrayList<JsonBean>();
- list.add(bean2);
- SLACalculationInsertUpdateJPAExecutor writeCmd = new SLACalculationInsertUpdateJPAExecutor();
- writeCmd.setInsertList(list);
- jpaService.execute(writeCmd);
+ List<JsonBean> insertList = new ArrayList<JsonBean>();
+ insertList.add(bean2);
+ BatchQueryExecutor.getInstance().executeBatchInsertUpdateDelete(insertList, null, null);
SLASummaryGetJPAExecutor readCmd2 = new SLASummaryGetJPAExecutor(wfId);
SLASummaryBean sBean = jpaService.execute(readCmd2);
@@ -123,21 +125,17 @@ public class TestSLACalculationJPAExecut
Date actStart = new Date();
SLASummaryBean bean2 = _createSLASummaryBean(wfId, "RUNNING", EventStatus.START_MISS, expStart, expEnd, 1000,
actStart, null, 2000, (byte) 0, actStart);
- List<JsonBean> list = new ArrayList<JsonBean>();
- list.add(bean2);
- SLACalculationInsertUpdateJPAExecutor writeCmd = new SLACalculationInsertUpdateJPAExecutor();
- writeCmd.setInsertList(list);
- jpaService.execute(writeCmd);
+ List<JsonBean> insertList = new ArrayList<JsonBean>();
+ insertList.add(bean2);
+ BatchQueryExecutor.getInstance().executeBatchInsertUpdateDelete(insertList, null, null);
// update existing record
Date newDate = new Date();
bean2 = _createSLASummaryBean(wfId, "RUNNING", EventStatus.DURATION_MISS, expStart, expEnd, 1000, actStart,
newDate, 2000, (byte) 1, newDate);
- list = new ArrayList<JsonBean>();
- list.add(bean2);
- writeCmd.setUpdateList(list);
- writeCmd.setInsertList(null);
- jpaService.execute(writeCmd);
+ bean2.setAppType(AppType.WORKFLOW_ACTION);
+ List<UpdateEntry> updateList = new ArrayList<UpdateEntry>();
+ SLASummaryQueryExecutor.getInstance().executeUpdate(SLASummaryQuery.UPDATE_SLA_SUMMARY_ALL, bean2);
SLASummaryGetJPAExecutor readCmd2 = new SLASummaryGetJPAExecutor(wfId);
SLASummaryBean sBean = jpaService.execute(readCmd2);
@@ -171,28 +169,26 @@ public class TestSLACalculationJPAExecut
1000, null, null, 2000, 0, null);
List<JsonBean> list = new ArrayList<JsonBean>();
list.add(bean1);
- SLACalculationInsertUpdateJPAExecutor writeCmd = new SLACalculationInsertUpdateJPAExecutor(list, null);
- jpaService.execute(writeCmd);
+ BatchQueryExecutor.getInstance().executeBatchInsertUpdateDelete(list, null, null);
// update existing record and insert another
Date newDate = new Date();
bean1 = new SLASummaryBean();
bean1.setId(wfId1);
bean1.setActualEnd(newDate);
- List<JsonBean> updateList = new ArrayList<JsonBean>();
- updateList.add(bean1);
+ List<UpdateEntry> updateList = new ArrayList<UpdateEntry>();
+ updateList.add(new UpdateEntry<SLASummaryQuery>(SLASummaryQuery.UPDATE_SLA_SUMMARY_ALL,bean1));
SLASummaryBean bean2 = _createSLASummaryBean(wfId2, "RUNNING", EventStatus.END_MISS, new Date(), new Date(),
1000, null, null, 2000, 0, null);
List<JsonBean> insertList = new ArrayList<JsonBean>();
insertList.add(bean2);
- writeCmd = new SLACalculationInsertUpdateJPAExecutor(insertList, updateList);
// set fault injection to true, so transaction is roll backed
setSystemProperty(FaultInjection.FAULT_INJECTION, "true");
setSystemProperty(SkipCommitFaultInjection.ACTION_FAILOVER_FAULT_INJECTION, "true");
try {
- jpaService.execute(writeCmd);
+ BatchQueryExecutor.getInstance().executeBatchInsertUpdateDelete(insertList, updateList, null);
fail("Expected exception due to commit failure but didn't get any");
}
catch (Exception e) {
Modified: oozie/trunk/core/src/test/java/org/apache/oozie/sla/TestSLACalculatorMemory.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/test/java/org/apache/oozie/sla/TestSLACalculatorMemory.java?rev=1520716&r1=1520715&r2=1520716&view=diff
==============================================================================
--- oozie/trunk/core/src/test/java/org/apache/oozie/sla/TestSLACalculatorMemory.java (original)
+++ oozie/trunk/core/src/test/java/org/apache/oozie/sla/TestSLACalculatorMemory.java Sat Sep 7 00:25:30 2013
@@ -34,11 +34,14 @@ import org.apache.oozie.client.event.SLA
import org.apache.oozie.client.event.JobEvent.EventStatus;
import org.apache.oozie.client.event.SLAEvent.SLAStatus;
import org.apache.oozie.client.rest.JsonBean;
+import org.apache.oozie.executor.jpa.BatchQueryExecutor.UpdateEntry;
import org.apache.oozie.executor.jpa.CoordActionInsertJPAExecutor;
+import org.apache.oozie.executor.jpa.SLASummaryQueryExecutor.SLASummaryQuery;
+import org.apache.oozie.executor.jpa.BatchQueryExecutor;
+import org.apache.oozie.executor.jpa.SLASummaryQueryExecutor;
import org.apache.oozie.executor.jpa.WorkflowActionInsertJPAExecutor;
-import org.apache.oozie.executor.jpa.WorkflowJobInsertJPAExecutor;
-import org.apache.oozie.executor.jpa.WorkflowJobUpdateJPAExecutor;
-import org.apache.oozie.executor.jpa.sla.SLACalculationInsertUpdateJPAExecutor;
+import org.apache.oozie.executor.jpa.WorkflowJobQueryExecutor;
+import org.apache.oozie.executor.jpa.WorkflowJobQueryExecutor.WorkflowJobQuery;
import org.apache.oozie.executor.jpa.sla.SLASummaryGetJPAExecutor;
import org.apache.oozie.service.EventHandlerService;
import org.apache.oozie.service.JPAService;
@@ -117,16 +120,18 @@ public class TestSLACalculatorMemory ext
Date lastModifiedTime = new Date(System.currentTimeMillis() - 5*24*60*60*1000);
calc1.setLastModifiedTime(lastModifiedTime);
- List<JsonBean> list = new ArrayList<JsonBean>();
+ List<UpdateEntry> updateList = new ArrayList<UpdateEntry>();
SLASummaryBean bean = new SLASummaryBean(calc1);
bean.setActualStart(sdf.parse("2011-03-09"));
bean.setActualEnd(sdf.parse("2011-03-10"));
bean.setActualDuration(456);
- list.add(bean);
- list.add(new SLASummaryBean(calc2));
- list.add(new SLASummaryBean(calc3));
+ updateList.add(new UpdateEntry<SLASummaryQuery>(SLASummaryQuery.UPDATE_SLA_SUMMARY_ALL, bean));
+ updateList.add(new UpdateEntry<SLASummaryQuery>(SLASummaryQuery.UPDATE_SLA_SUMMARY_ALL,
+ new SLASummaryBean(calc2)));
+ updateList.add(new UpdateEntry<SLASummaryQuery>(SLASummaryQuery.UPDATE_SLA_SUMMARY_ALL,
+ new SLASummaryBean(calc3)));
- jpaService.execute(new SLACalculationInsertUpdateJPAExecutor(null, list));
+ BatchQueryExecutor.getInstance().executeBatchInsertUpdateDelete(null, updateList, null);
slaCalcMemory = new SLACalculatorMemory();
slaCalcMemory.init(new Configuration(false));
@@ -187,9 +192,7 @@ public class TestSLACalculatorMemory ext
calc1.setLastModifiedTime(new Date());
SLASummaryBean slaSummaryBean = new SLASummaryBean(calc1);
- List<JsonBean> list = new ArrayList<JsonBean>();
- list.add(slaSummaryBean);
- jpaService.execute(new SLACalculationInsertUpdateJPAExecutor(null, list));
+ SLASummaryQueryExecutor.getInstance().executeUpdate(SLASummaryQuery.UPDATE_SLA_SUMMARY_ALL,slaSummaryBean);
SLASummaryBean slaSummary = jpaService.execute(new SLASummaryGetJPAExecutor(jobId1));
@@ -199,8 +202,8 @@ public class TestSLACalculatorMemory ext
wjb.setStatus(WorkflowJob.Status.SUCCEEDED);
wjb.setStartTime(sdf.parse("2012-02-07"));
wjb.setEndTime(sdf.parse("2013-02-07"));
- WorkflowJobInsertJPAExecutor wfInsertCmd = new WorkflowJobInsertJPAExecutor(wjb);
- jpaService.execute(wfInsertCmd);
+ wjb.setLastModifiedTime(new Date());
+ WorkflowJobQueryExecutor.getInstance().insert(wjb);
slaCalcMemory = new SLACalculatorMemory();
slaCalcMemory.init(new Configuration(false));
@@ -220,7 +223,8 @@ public class TestSLACalculatorMemory ext
// Simulate a lost failed event
wjb.setStatus(WorkflowJob.Status.FAILED);
- jpaService.execute(new WorkflowJobUpdateJPAExecutor(wjb));
+ wjb.setLastModifiedTime(new Date());
+ WorkflowJobQueryExecutor.getInstance().executeUpdate(WorkflowJobQuery.UPDATE_WORKFLOW_STATUS_MODTIME, wjb);
// Reset the summary Bean
calc1.setEventProcessed(1);
@@ -228,9 +232,7 @@ public class TestSLACalculatorMemory ext
calc1.setJobStatus(WorkflowJob.Status.RUNNING.name());
slaSummaryBean = new SLASummaryBean(calc1);
- list = new ArrayList<JsonBean>();
- list.add(slaSummaryBean);
- jpaService.execute(new SLACalculationInsertUpdateJPAExecutor(null, list));
+ SLASummaryQueryExecutor.getInstance().executeUpdate(SLASummaryQuery.UPDATE_SLA_SUMMARY_ALL, slaSummaryBean);
slaCalcMemory = new SLACalculatorMemory();
slaCalcMemory.init(new Configuration(false));
@@ -245,7 +247,8 @@ public class TestSLACalculatorMemory ext
// Simulate a lost RUNNING event
wjb.setStatus(WorkflowJob.Status.RUNNING);
- jpaService.execute(new WorkflowJobUpdateJPAExecutor(wjb));
+ wjb.setLastModifiedTime(new Date());
+ WorkflowJobQueryExecutor.getInstance().executeUpdate(WorkflowJobQuery.UPDATE_WORKFLOW_STATUS_MODTIME, wjb);
// Reset the summary Bean
calc1.setEventProcessed(0);
@@ -253,9 +256,7 @@ public class TestSLACalculatorMemory ext
calc1.setJobStatus(null);
slaSummaryBean = new SLASummaryBean(calc1);
- list = new ArrayList<JsonBean>();
- list.add(slaSummaryBean);
- jpaService.execute(new SLACalculationInsertUpdateJPAExecutor(null, list));
+ SLASummaryQueryExecutor.getInstance().executeUpdate(SLASummaryQuery.UPDATE_SLA_SUMMARY_ALL, slaSummaryBean);
slaCalcMemory = new SLACalculatorMemory();
slaCalcMemory.init(new Configuration(false));
@@ -287,9 +288,7 @@ public class TestSLACalculatorMemory ext
calc1.setLastModifiedTime(new Date());
SLASummaryBean slaSummaryBean = new SLASummaryBean(calc1);
- List<JsonBean> list = new ArrayList<JsonBean>();
- list.add(slaSummaryBean);
- jpaService.execute(new SLACalculationInsertUpdateJPAExecutor(null, list));
+ SLASummaryQueryExecutor.getInstance().executeUpdate(SLASummaryQuery.UPDATE_SLA_SUMMARY_ALL, slaSummaryBean);
// Simulate a lost success event
WorkflowActionBean wab = new WorkflowActionBean();
@@ -335,9 +334,7 @@ public class TestSLACalculatorMemory ext
calc1.setLastModifiedTime(new Date());
SLASummaryBean slaSummaryBean = new SLASummaryBean(calc1);
- List<JsonBean> list = new ArrayList<JsonBean>();
- list.add(slaSummaryBean);
- jpaService.execute(new SLACalculationInsertUpdateJPAExecutor(null, list));
+ SLASummaryQueryExecutor.getInstance().executeUpdate(SLASummaryQuery.UPDATE_SLA_SUMMARY_ALL, slaSummaryBean);
// Simulate a lost failed event
CoordinatorActionBean cab = new CoordinatorActionBean();
@@ -350,7 +347,8 @@ public class TestSLACalculatorMemory ext
WorkflowJobBean wjb = new WorkflowJobBean();
wjb.setId("wf_job");
wjb.setStartTime(sdf.parse("2012-02-07"));
- jpaService.execute(new WorkflowJobUpdateJPAExecutor(wjb));
+ wjb.setLastModifiedTime(new Date());
+ WorkflowJobQueryExecutor.getInstance().insert(wjb);
slaCalcMemory = new SLACalculatorMemory();
slaCalcMemory.init(new Configuration(false));
@@ -444,9 +442,7 @@ public class TestSLACalculatorMemory ext
// set back to 1, to make duration event not processed
slaSummary.setEventProcessed(1);
- List<JsonBean> list = new ArrayList<JsonBean>();
- list.add(slaSummary);
- jpaService.execute(new SLACalculationInsertUpdateJPAExecutor(null, list));
+ SLASummaryQueryExecutor.getInstance().executeUpdate(SLASummaryQuery.UPDATE_SLA_SUMMARY_ALL, slaSummary);
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
slaCalcMemory.addJobStatus(jobId, WorkflowJob.Status.SUCCEEDED.toString(), EventStatus.SUCCESS,
@@ -459,9 +455,7 @@ public class TestSLACalculatorMemory ext
ehs.getEventQueue().clear();
slaSummary.setEventProcessed(1);
- list = new ArrayList<JsonBean>();
- list.add(slaSummary);
- jpaService.execute(new SLACalculationInsertUpdateJPAExecutor(null, list));
+ SLASummaryQueryExecutor.getInstance().executeUpdate(SLASummaryQuery.UPDATE_SLA_SUMMARY_ALL, slaSummary);
slaRegBean = _createSLARegistration("job-2", AppType.WORKFLOW_JOB);
slaRegBean.setExpectedStart(new Date(System.currentTimeMillis() - 1 * 1 * 3600 * 1000));
Modified: oozie/trunk/core/src/test/java/org/apache/oozie/sla/TestSLAEventGeneration.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/test/java/org/apache/oozie/sla/TestSLAEventGeneration.java?rev=1520716&r1=1520715&r2=1520716&view=diff
==============================================================================
--- oozie/trunk/core/src/test/java/org/apache/oozie/sla/TestSLAEventGeneration.java (original)
+++ oozie/trunk/core/src/test/java/org/apache/oozie/sla/TestSLAEventGeneration.java Sat Sep 7 00:25:30 2013
@@ -17,10 +17,12 @@
*/
package org.apache.oozie.sla;
+import java.util.ArrayList;
import java.util.Arrays;
import java.util.Calendar;
import java.util.Date;
import java.util.HashSet;
+import java.util.List;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.Path;
@@ -28,13 +30,16 @@ import org.apache.oozie.AppType;
import org.apache.oozie.CoordinatorActionBean;
import org.apache.oozie.CoordinatorJobBean;
import org.apache.oozie.ErrorCode;
+import org.apache.oozie.WorkflowActionBean;
import org.apache.oozie.WorkflowJobBean;
import org.apache.oozie.client.CoordinatorAction;
import org.apache.oozie.client.CoordinatorJob;
import org.apache.oozie.client.OozieClient;
+import org.apache.oozie.client.WorkflowAction;
import org.apache.oozie.client.WorkflowJob;
import org.apache.oozie.client.event.Event;
import org.apache.oozie.client.event.JobEvent;
+import org.apache.oozie.client.event.SLAEvent;
import org.apache.oozie.client.event.SLAEvent.SLAStatus;
import org.apache.oozie.client.event.SLAEvent.EventStatus;
import org.apache.oozie.client.rest.RestConstants;
@@ -50,15 +55,22 @@ import org.apache.oozie.command.wf.Start
import org.apache.oozie.command.wf.SubmitXCommand;
import org.apache.oozie.event.CoordinatorActionEvent;
import org.apache.oozie.event.listener.JobEventListener;
+import org.apache.oozie.executor.jpa.BatchQueryExecutor.UpdateEntry;
import org.apache.oozie.executor.jpa.CoordActionGetJPAExecutor;
-import org.apache.oozie.executor.jpa.CoordActionUpdateJPAExecutor;
+import org.apache.oozie.executor.jpa.CoordActionQueryExecutor;
+import org.apache.oozie.executor.jpa.CoordActionQueryExecutor.CoordActionQuery;
+import org.apache.oozie.executor.jpa.BatchQueryExecutor;
+import org.apache.oozie.executor.jpa.WorkflowActionQueryExecutor.WorkflowActionQuery;
+import org.apache.oozie.executor.jpa.WorkflowActionsGetForJobJPAExecutor;
import org.apache.oozie.executor.jpa.WorkflowJobGetJPAExecutor;
import org.apache.oozie.executor.jpa.WorkflowJobInsertJPAExecutor;
-import org.apache.oozie.executor.jpa.WorkflowJobUpdateJPAExecutor;
+import org.apache.oozie.executor.jpa.WorkflowJobQueryExecutor;
+import org.apache.oozie.executor.jpa.WorkflowJobQueryExecutor.WorkflowJobQuery;
import org.apache.oozie.executor.jpa.sla.SLASummaryGetJPAExecutor;
import org.apache.oozie.service.EventHandlerService;
import org.apache.oozie.service.JPAService;
import org.apache.oozie.service.Services;
+import org.apache.oozie.service.EventHandlerService.EventWorker;
import org.apache.oozie.sla.listener.SLAJobEventListener;
import org.apache.oozie.sla.service.SLAService;
import org.apache.oozie.test.XDataTestCase;
@@ -189,7 +201,7 @@ public class TestSLAEventGeneration exte
WorkflowJobBean wfBean = jpaService.execute(new WorkflowJobGetJPAExecutor(jobId));
// set job status to succeeded, so rerun doesn't fail
wfBean.setStatus(WorkflowJob.Status.SUCCEEDED);
- jpaService.execute(new WorkflowJobUpdateJPAExecutor(wfBean));
+ WorkflowJobQueryExecutor.getInstance().executeUpdate(WorkflowJobQuery.UPDATE_WORKFLOW_STATUS_MODTIME, wfBean);
// change conf for rerun
cal.setTime(new Date());
@@ -267,7 +279,7 @@ public class TestSLAEventGeneration exte
WorkflowJobBean wfBean = jpaService.execute(new WorkflowJobGetJPAExecutor(jobId));
// set job status to succeeded, so rerun doesn't fail
wfBean.setStatus(WorkflowJob.Status.SUCCEEDED);
- jpaService.execute(new WorkflowJobUpdateJPAExecutor(wfBean));
+ WorkflowJobQueryExecutor.getInstance().executeUpdate(WorkflowJobQuery.UPDATE_WORKFLOW_STATUS_MODTIME, wfBean);
// change conf for rerun
cal.setTime(new Date());
@@ -395,8 +407,7 @@ public class TestSLAEventGeneration exte
// test that sla processes the Job Event from Start command
action.setStatus(CoordinatorAction.Status.SUBMITTED);
- final CoordActionUpdateJPAExecutor writeCmd = new CoordActionUpdateJPAExecutor(action);
- jpa.execute(writeCmd);
+ CoordActionQueryExecutor.getInstance().executeUpdate(CoordActionQuery.UPDATE_COORD_ACTION_STATUS_PENDING_TIME, action);
new CoordActionStartXCommand(actionId, getTestUser(), appName, jobId).call();
slaEvent = slas.getSLACalculator().get(actionId);
slaEvent.setEventProcessed(0); //resetting for testing sla event
@@ -438,7 +449,7 @@ public class TestSLAEventGeneration exte
"coord-action-sla1.xml", 0);
// reset dummy externalId set by above test method
action.setExternalId(null);
- jpa.execute(new CoordActionUpdateJPAExecutor(action));
+ CoordActionQueryExecutor.getInstance().executeUpdate(CoordActionQuery.UPDATE_COORD_ACTION, action);
services.get(SLAService.class).addRegistrationEvent(
TestSLAService._createSLARegistration(action.getId(), AppType.COORDINATOR_ACTION));
@@ -560,8 +571,8 @@ public class TestSLAEventGeneration exte
// job must already be killed (test xml) so set some status for KillX to work
JPAService jpaService = Services.get().get(JPAService.class);
WorkflowJobBean wf = jpaService.execute(new WorkflowJobGetJPAExecutor(jobId));
- wf.setStatus(WorkflowJob.Status.FAILED);
- jpaService.execute(new WorkflowJobUpdateJPAExecutor(wf));
+ wf.setStatus(WorkflowJob.Status.RUNNING);
+ WorkflowJobQueryExecutor.getInstance().executeUpdate(WorkflowJobQuery.UPDATE_WORKFLOW_STATUS_MODTIME, wf);
new KillXCommand(jobId).call();
waitForEventGeneration(1000); //wait for wf-action kill event to generate
Thread.sleep(200); //wait for wf job kill event to generate
@@ -573,7 +584,7 @@ public class TestSLAEventGeneration exte
assertNotNull(slaEvent.getActualEnd());
assertEquals(EventStatus.END_MISS, slaEvent.getEventStatus());
assertEquals(SLAStatus.MISS, slaEvent.getSLAStatus());
- assertEquals(WorkflowJob.Status.FAILED.name(), slaEvent.getJobStatus());
+ assertEquals(WorkflowJob.Status.KILLED.name(), slaEvent.getJobStatus());
}
}
Modified: oozie/trunk/core/src/test/java/org/apache/oozie/sla/TestSLARegistrationGetJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/test/java/org/apache/oozie/sla/TestSLARegistrationGetJPAExecutor.java?rev=1520716&r1=1520715&r2=1520716&view=diff
==============================================================================
--- oozie/trunk/core/src/test/java/org/apache/oozie/sla/TestSLARegistrationGetJPAExecutor.java (original)
+++ oozie/trunk/core/src/test/java/org/apache/oozie/sla/TestSLARegistrationGetJPAExecutor.java Sat Sep 7 00:25:30 2013
@@ -23,8 +23,8 @@ import java.util.List;
import org.apache.oozie.AppType;
import org.apache.oozie.client.rest.JsonBean;
+import org.apache.oozie.executor.jpa.BatchQueryExecutor;
import org.apache.oozie.executor.jpa.JPAExecutorException;
-import org.apache.oozie.executor.jpa.sla.SLACalculationInsertUpdateJPAExecutor;
import org.apache.oozie.executor.jpa.sla.SLARegistrationGetJPAExecutor;
import org.apache.oozie.service.JPAService;
import org.apache.oozie.service.Services;
@@ -80,8 +80,7 @@ public class TestSLARegistrationGetJPAEx
assertNotNull(jpaService);
List<JsonBean> insert = new ArrayList<JsonBean>();
insert.add(reg);
- SLACalculationInsertUpdateJPAExecutor slaInsertCmd = new SLACalculationInsertUpdateJPAExecutor(insert, null);
- jpaService.execute(slaInsertCmd);
+ BatchQueryExecutor.getInstance().executeBatchInsertUpdateDelete(insert, null, null);
}
catch (JPAExecutorException je) {
fail("Unable to insert the test sla registration record to table");
Modified: oozie/trunk/core/src/test/java/org/apache/oozie/sla/TestSLARegistrationGetRecordsOnRestartJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/test/java/org/apache/oozie/sla/TestSLARegistrationGetRecordsOnRestartJPAExecutor.java?rev=1520716&r1=1520715&r2=1520716&view=diff
==============================================================================
--- oozie/trunk/core/src/test/java/org/apache/oozie/sla/TestSLARegistrationGetRecordsOnRestartJPAExecutor.java (original)
+++ oozie/trunk/core/src/test/java/org/apache/oozie/sla/TestSLARegistrationGetRecordsOnRestartJPAExecutor.java Sat Sep 7 00:25:30 2013
@@ -22,7 +22,7 @@ import java.util.Date;
import java.util.List;
import org.apache.oozie.client.rest.JsonBean;
-import org.apache.oozie.executor.jpa.sla.SLACalculationInsertUpdateJPAExecutor;
+import org.apache.oozie.executor.jpa.BatchQueryExecutor;
import org.apache.oozie.executor.jpa.sla.SLARegistrationGetOnRestartJPAExecutor;
import org.apache.oozie.service.JPAService;
import org.apache.oozie.service.Services;
@@ -59,8 +59,7 @@ public class TestSLARegistrationGetRecor
JPAService jpaService = Services.get().get(JPAService.class);
List<JsonBean> insert = new ArrayList<JsonBean>();
insert.add(reg);
- SLACalculationInsertUpdateJPAExecutor slaInsertCmd = new SLACalculationInsertUpdateJPAExecutor(insert, null);
- jpaService.execute(slaInsertCmd);
+ BatchQueryExecutor.getInstance().executeBatchInsertUpdateDelete(insert, null, null);
assertNotNull(jpaService);
SLARegistrationGetOnRestartJPAExecutor readCmd = new SLARegistrationGetOnRestartJPAExecutor(jobId);
SLARegistrationBean bean = jpaService.execute(readCmd);
Modified: oozie/trunk/core/src/test/java/org/apache/oozie/sla/TestSLAService.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/test/java/org/apache/oozie/sla/TestSLAService.java?rev=1520716&r1=1520715&r2=1520716&view=diff
==============================================================================
--- oozie/trunk/core/src/test/java/org/apache/oozie/sla/TestSLAService.java (original)
+++ oozie/trunk/core/src/test/java/org/apache/oozie/sla/TestSLAService.java Sat Sep 7 00:25:30 2013
@@ -31,7 +31,8 @@ import org.apache.oozie.client.event.SLA
import org.apache.oozie.client.event.SLAEvent.SLAStatus;
import org.apache.oozie.executor.jpa.WorkflowJobGetJPAExecutor;
import org.apache.oozie.executor.jpa.WorkflowJobInsertJPAExecutor;
-import org.apache.oozie.executor.jpa.WorkflowJobUpdateJPAExecutor;
+import org.apache.oozie.executor.jpa.WorkflowJobQueryExecutor;
+import org.apache.oozie.executor.jpa.WorkflowJobQueryExecutor.WorkflowJobQuery;
import org.apache.oozie.executor.jpa.sla.SLARegistrationGetJPAExecutor;
import org.apache.oozie.executor.jpa.sla.SLASummaryGetJPAExecutor;
import org.apache.oozie.service.EventHandlerService;
@@ -180,7 +181,8 @@ public class TestSLAService extends XDat
WorkflowJobBean job2 = addRecordToWfJobTable(WorkflowJob.Status.SUCCEEDED, WorkflowInstance.Status.SUCCEEDED);
job2.setEndTime(new Date(System.currentTimeMillis() - 1 * 1800 * 1000));
job2.setStartTime(new Date(System.currentTimeMillis() - 1 * 2000 * 1000));
- jpaService.execute(new WorkflowJobUpdateJPAExecutor(job2));
+ job2.setLastModifiedTime(new Date());
+ WorkflowJobQueryExecutor.getInstance().executeUpdate(WorkflowJobQuery.UPDATE_WORKFLOW_STATUS_INSTANCE_MOD_START_END, job2);
sla = _createSLARegistration(job2.getId(), AppType.WORKFLOW_JOB);
sla.setExpectedEnd(new Date(System.currentTimeMillis() - 1 * 1500 * 1000)); // in past but > actual end
sla.setExpectedDuration(100); //unreasonable to cause MISS
Modified: oozie/trunk/core/src/test/java/org/apache/oozie/sla/TestSLASummaryGetOnRestartJPAExecutor.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/test/java/org/apache/oozie/sla/TestSLASummaryGetOnRestartJPAExecutor.java?rev=1520716&r1=1520715&r2=1520716&view=diff
==============================================================================
--- oozie/trunk/core/src/test/java/org/apache/oozie/sla/TestSLASummaryGetOnRestartJPAExecutor.java (original)
+++ oozie/trunk/core/src/test/java/org/apache/oozie/sla/TestSLASummaryGetOnRestartJPAExecutor.java Sat Sep 7 00:25:30 2013
@@ -24,8 +24,8 @@ import java.util.List;
import org.apache.oozie.AppType;
import org.apache.oozie.client.rest.JsonBean;
+import org.apache.oozie.executor.jpa.BatchQueryExecutor;
import org.apache.oozie.executor.jpa.JPAExecutorException;
-import org.apache.oozie.executor.jpa.sla.SLACalculationInsertUpdateJPAExecutor;
import org.apache.oozie.executor.jpa.sla.SLARegistrationGetJPAExecutor;
import org.apache.oozie.executor.jpa.sla.SLASummaryGetJPAExecutor;
import org.apache.oozie.executor.jpa.sla.SLASummaryGetRecordsOnRestartJPAExecutor;
@@ -72,8 +72,7 @@ public class TestSLASummaryGetOnRestartJ
List<JsonBean> insert = new ArrayList<JsonBean>();
insert.add(sla1);
insert.add(sla2);
- SLACalculationInsertUpdateJPAExecutor slaInsertCmd = new SLACalculationInsertUpdateJPAExecutor(insert, null);
- jpaService.execute(slaInsertCmd);
+ BatchQueryExecutor.getInstance().executeBatchInsertUpdateDelete(insert, null, null);
// get all records modified in last 7 days
SLASummaryGetRecordsOnRestartJPAExecutor slaGetOnRestart = new SLASummaryGetRecordsOnRestartJPAExecutor(7);
List<SLASummaryBean> beans = jpaService.execute(slaGetOnRestart);
Modified: oozie/trunk/core/src/test/java/org/apache/oozie/test/XDataTestCase.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/test/java/org/apache/oozie/test/XDataTestCase.java?rev=1520716&r1=1520715&r2=1520716&view=diff
==============================================================================
--- oozie/trunk/core/src/test/java/org/apache/oozie/test/XDataTestCase.java (original)
+++ oozie/trunk/core/src/test/java/org/apache/oozie/test/XDataTestCase.java Sat Sep 7 00:25:30 2013
@@ -32,6 +32,7 @@ import java.util.regex.Matcher;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
+import org.apache.oozie.AppType;
import org.apache.oozie.BundleActionBean;
import org.apache.oozie.BundleJobBean;
import org.apache.oozie.CoordinatorActionBean;
@@ -45,6 +46,8 @@ import org.apache.oozie.client.Coordinat
import org.apache.oozie.client.CoordinatorJob;
import org.apache.oozie.client.CoordinatorJob.Execution;
import org.apache.oozie.client.CoordinatorJob.Timeunit;
+import org.apache.oozie.client.event.SLAEvent.EventStatus;
+import org.apache.oozie.client.event.SLAEvent.SLAStatus;
import org.apache.oozie.client.Job;
import org.apache.oozie.client.OozieClient;
import org.apache.oozie.client.SLAEvent;
@@ -54,16 +57,21 @@ import org.apache.oozie.executor.jpa.Bun
import org.apache.oozie.executor.jpa.BundleJobInsertJPAExecutor;
import org.apache.oozie.executor.jpa.CoordActionGetJPAExecutor;
import org.apache.oozie.executor.jpa.CoordActionInsertJPAExecutor;
-import org.apache.oozie.executor.jpa.CoordActionUpdateJPAExecutor;
+import org.apache.oozie.executor.jpa.CoordActionQueryExecutor;
+import org.apache.oozie.executor.jpa.CoordActionQueryExecutor.CoordActionQuery;
import org.apache.oozie.executor.jpa.CoordJobGetJPAExecutor;
import org.apache.oozie.executor.jpa.CoordJobInsertJPAExecutor;
-import org.apache.oozie.executor.jpa.CoordJobUpdateJPAExecutor;
+import org.apache.oozie.executor.jpa.CoordJobQueryExecutor;
+import org.apache.oozie.executor.jpa.CoordJobQueryExecutor.CoordJobQuery;
import org.apache.oozie.executor.jpa.JPAExecutorException;
import org.apache.oozie.executor.jpa.SLAEventInsertJPAExecutor;
+import org.apache.oozie.executor.jpa.SLARegistrationQueryExecutor;
+import org.apache.oozie.executor.jpa.SLASummaryQueryExecutor;
import org.apache.oozie.executor.jpa.WorkflowActionInsertJPAExecutor;
import org.apache.oozie.executor.jpa.WorkflowJobGetJPAExecutor;
import org.apache.oozie.executor.jpa.WorkflowJobInsertJPAExecutor;
-import org.apache.oozie.executor.jpa.WorkflowJobUpdateJPAExecutor;
+import org.apache.oozie.executor.jpa.WorkflowJobQueryExecutor;
+import org.apache.oozie.executor.jpa.WorkflowJobQueryExecutor.WorkflowJobQuery;
import org.apache.oozie.service.JPAService;
import org.apache.oozie.service.LiteWorkflowStoreService;
import org.apache.oozie.service.Services;
@@ -71,6 +79,8 @@ import org.apache.oozie.service.UUIDServ
import org.apache.oozie.service.UUIDService.ApplicationType;
import org.apache.oozie.service.WorkflowAppService;
import org.apache.oozie.service.WorkflowStoreService;
+import org.apache.oozie.sla.SLARegistrationBean;
+import org.apache.oozie.sla.SLASummaryBean;
import org.apache.oozie.util.DateUtils;
import org.apache.oozie.util.IOUtils;
import org.apache.oozie.util.XConfiguration;
@@ -546,7 +556,7 @@ public abstract class XDataTestCase exte
if (wfId != null) {
WorkflowJobBean wfJob = jpaService.execute(new WorkflowJobGetJPAExecutor(wfId));
wfJob.setParentId(action.getId());
- jpaService.execute(new WorkflowJobUpdateJPAExecutor(wfJob));
+ WorkflowJobQueryExecutor.getInstance().executeUpdate(WorkflowJobQuery.UPDATE_WORKFLOW_PARENT_MODIFIED, wfJob);
}
}
catch (JPAExecutorException je) {
@@ -623,7 +633,7 @@ public abstract class XDataTestCase exte
try {
JPAService jpaService = Services.get().get(JPAService.class);
assertNotNull(jpaService);
- jpaService.execute(new WorkflowJobUpdateJPAExecutor(subwfBean));
+ WorkflowJobQueryExecutor.getInstance().executeUpdate(WorkflowJobQuery.UPDATE_WORKFLOW_PARENT_MODIFIED, subwfBean);
}
catch (JPAExecutorException je) {
je.printStackTrace();
@@ -768,6 +778,80 @@ public abstract class XDataTestCase exte
}
/**
+ * Insert sla summary for test
+ * @param appName application name
+ * @param status sla status
+ * @return
+ * @throws Exception
+ */
+ protected SLASummaryBean addRecordToSLASummaryTable(String appName, SLAStatus status)
+ throws Exception {
+ SLASummaryBean sla = new SLASummaryBean();
+ Date today = new Date();
+ sla.setId(Services.get().get(UUIDService.class).generateId(ApplicationType.COORDINATOR));
+ sla.setAppName(appName);
+ sla.setAppType(AppType.COORDINATOR_JOB);
+ sla.setNominalTime(today);
+ sla.setExpectedStart(today);
+ sla.setExpectedEnd(today);
+ sla.setExpectedDuration(100);
+ sla.setJobStatus("RUNNING");
+ sla.setSLAStatus(status);
+ sla.setEventStatus(EventStatus.START_MET);
+ sla.setLastModifiedTime(today);
+ sla.setUser("oozie");
+ sla.setParentId(Services.get().get(UUIDService.class).generateId(ApplicationType.BUNDLE));
+ sla.setEventProcessed(1);
+ sla.setActualStart(today);
+ sla.setActualEnd(today);
+ sla.setActualDuration(100);
+ try {
+ SLASummaryQueryExecutor.getInstance().insert(sla);
+ }
+ catch (JPAExecutorException je) {
+ je.printStackTrace();
+ fail("Unable to insert the test sla event record to table");
+ throw je;
+ }
+ return sla;
+ }
+
+ /**
+ * Insert sla registration for test
+ * @param appName application name
+ * @param status sla status
+ * @return
+ * @throws Exception
+ */
+ protected SLARegistrationBean addRecordToSLARegistrationTable(String appName, SLAStatus status)
+ throws Exception {
+ SLARegistrationBean sla = new SLARegistrationBean();
+ Date today = new Date();
+ sla.setId(Services.get().get(UUIDService.class).generateId(ApplicationType.COORDINATOR));
+ sla.setAppName(appName);
+ sla.setAppType(AppType.COORDINATOR_JOB);
+ sla.setExpectedDuration(100);
+ sla.setExpectedEnd(today);
+ sla.setExpectedStart(today);
+ sla.setJobData("test-job-data");
+ sla.setNominalTime(today);
+ sla.setNotificationMsg("test-sla-notification-msg");
+ sla.setParentId(Services.get().get(UUIDService.class).generateId(ApplicationType.BUNDLE));
+ sla.setSlaConfig("alert-events");
+ sla.setUpstreamApps("test-upstream-apps");
+ sla.setUser("oozie");
+ try {
+ SLARegistrationQueryExecutor.getInstance().insert(sla);
+ }
+ catch (JPAExecutorException je) {
+ je.printStackTrace();
+ fail("Unable to insert the test sla registration record to table");
+ throw je;
+ }
+ return sla;
+ }
+
+ /**
* Insert bundle job for testing.
*
* @param jobStatus job status
@@ -866,7 +950,7 @@ public abstract class XDataTestCase exte
CoordinatorJobBean coordJob = jpaService.execute(new CoordJobGetJPAExecutor(coordId));
coordJob.setBundleId(jobId);
- jpaService.execute(new CoordJobUpdateJPAExecutor(coordJob));
+ CoordJobQueryExecutor.getInstance().executeUpdate(CoordJobQuery.UPDATE_COORD_JOB_BUNDLEID, coordJob);
}
catch (JPAExecutorException ex) {
ex.printStackTrace();
@@ -1454,14 +1538,14 @@ public abstract class XDataTestCase exte
JPAService jpaService = Services.get().get(JPAService.class);
CoordinatorActionBean action = jpaService.execute(new CoordActionGetJPAExecutor(actionId));
action.setCreatedTime(new Date(actionCreationTime));
- jpaService.execute(new CoordActionUpdateJPAExecutor(action));
+ CoordActionQueryExecutor.getInstance().executeUpdate(CoordActionQuery.UPDATE_COORD_ACTION, action);
}
protected void setMissingDependencies(String actionId, String missingDependencies) throws Exception {
JPAService jpaService = Services.get().get(JPAService.class);
CoordinatorActionBean action = jpaService.execute(new CoordActionGetJPAExecutor(actionId));
action.setMissingDependencies(missingDependencies);
- jpaService.execute(new CoordActionUpdateJPAExecutor(action));
+ CoordActionQueryExecutor.getInstance().executeUpdate(CoordActionQuery.UPDATE_COORD_ACTION, action);
}
protected void modifyCoordForRunning(CoordinatorJobBean coord) throws Exception {
@@ -1469,7 +1553,7 @@ public abstract class XDataTestCase exte
writeToFile(wfXml, getFsTestCaseDir(), "workflow.xml");
String coordXml = coord.getJobXml();
coord.setJobXml(coordXml.replace("hdfs:///tmp/workflows/", getFsTestCaseDir() + "/workflow.xml"));
- Services.get().get(JPAService.class).execute(new CoordJobUpdateJPAExecutor(coord));
+ CoordJobQueryExecutor.getInstance().executeUpdate(CoordJobQuery.UPDATE_COORD_JOB, coord);
}
}
Modified: oozie/trunk/core/src/test/java/org/apache/oozie/test/XTestCase.java
URL: http://svn.apache.org/viewvc/oozie/trunk/core/src/test/java/org/apache/oozie/test/XTestCase.java?rev=1520716&r1=1520715&r2=1520716&view=diff
==============================================================================
--- oozie/trunk/core/src/test/java/org/apache/oozie/test/XTestCase.java (original)
+++ oozie/trunk/core/src/test/java/org/apache/oozie/test/XTestCase.java Sat Sep 7 00:25:30 2013
@@ -58,6 +58,15 @@ import org.apache.oozie.WorkflowActionBe
import org.apache.oozie.WorkflowJobBean;
import org.apache.oozie.dependency.FSURIHandler;
import org.apache.oozie.dependency.HCatURIHandler;
+import org.apache.oozie.executor.jpa.BatchQueryExecutor;
+import org.apache.oozie.executor.jpa.BundleActionQueryExecutor;
+import org.apache.oozie.executor.jpa.BundleJobQueryExecutor;
+import org.apache.oozie.executor.jpa.CoordActionQueryExecutor;
+import org.apache.oozie.executor.jpa.CoordJobQueryExecutor;
+import org.apache.oozie.executor.jpa.SLARegistrationQueryExecutor;
+import org.apache.oozie.executor.jpa.SLASummaryQueryExecutor;
+import org.apache.oozie.executor.jpa.WorkflowActionQueryExecutor;
+import org.apache.oozie.executor.jpa.WorkflowJobQueryExecutor;
import org.apache.oozie.service.ConfigurationService;
import org.apache.oozie.service.HCatAccessorService;
import org.apache.oozie.service.HadoopAccessorService;
@@ -358,6 +367,19 @@ public abstract class XTestCase extends
super.tearDown();
RUNNING_TESTCASES.decrementAndGet();
LAST_TESTCASE_FINISHED.set(System.currentTimeMillis());
+ resetQueryExecutor();
+ }
+
+ private void resetQueryExecutor(){
+ BatchQueryExecutor.destroy();
+ WorkflowJobQueryExecutor.destroy();
+ WorkflowActionQueryExecutor.destroy();
+ CoordJobQueryExecutor.destroy();
+ CoordActionQueryExecutor.destroy();
+ BundleJobQueryExecutor.destroy();
+ BundleActionQueryExecutor.destroy();
+ SLARegistrationQueryExecutor.destroy();
+ SLASummaryQueryExecutor.destroy();
}
/**
Modified: oozie/trunk/release-log.txt
URL: http://svn.apache.org/viewvc/oozie/trunk/release-log.txt?rev=1520716&r1=1520715&r2=1520716&view=diff
==============================================================================
--- oozie/trunk/release-log.txt (original)
+++ oozie/trunk/release-log.txt Sat Sep 7 00:25:30 2013
@@ -1,5 +1,6 @@
-- Oozie 4.1.0 release (trunk - unreleased)
+OOZIE-1499 Update only necessary columns and consolidate JPA Executors (ryota)
OOZIE-1522 SignalX may try to insert transition for a forked node twice (virag)
OOZIE-1461 provide an option to auto-deploy launcher jar onto HDFS system libpath (ryota,virag via virag)
OOZIE-1520 Sequencefile Reader fails to use doas for reading action data file (rohini,mona via mona)