Dry run mode in LM task nhl#125

Author: atomashpolskiy

link-move/src/main/java/com/nhl/link/move/LmTask.java

@@ -49,6 +49,8 @@ public interface LmTask {
 	 * the caller to analyze the results. Currently all task implementations are
 	 * synchronous, so this method returns only on task completion.
 	 *
+	 * Any changes will not be committed to the target datasource.
+	 *
 	 * @since 2.3
 	 */
 	Execution dryRun();
@@ -59,6 +61,8 @@ public interface LmTask {
 	 * all task implementations are synchronous, so this method returns only on
 	 * task completion.
 	 *
+	 * Any changes will not be committed to the target datasource.
+	 *
 	 * @since 2.3
 	 */
 	Execution dryRun(Map<String, ?> params);
@@ -69,6 +73,8 @@ public interface LmTask {
 	 * all task implementations are synchronous, so this method returns only on
 	 * task completion.
 	 *
+	 * Any changes will not be committed to the target datasource.
+	 *
 	 * @since 2.3
 	 */
 	Execution dryRun(SyncToken token);
@@ -79,6 +85,8 @@ public interface LmTask {
 	 * all task implementations are synchronous, so this method returns only on
 	 * task completion.
 	 *
+	 * Any changes will not be committed to the target datasource.
+	 *
 	 * @since 2.3
 	 */
 	Execution dryRun(SyncToken token, Map<String, ?> params);

link-move/src/test/java/com/nhl/link/move/itest/CreateOrUpdate_DryRunIT.java

@@ -0,0 +1,68 @@
+package com.nhl.link.move.itest;
+
+import com.nhl.link.move.Execution;
+import com.nhl.link.move.LmTask;
+import com.nhl.link.move.TimestampToken;
+import com.nhl.link.move.runtime.task.ITaskService;
+import com.nhl.link.move.unit.LmIntegrationTest;
+import com.nhl.link.move.unit.cayenne.t.Etl1t;
+import org.junit.Test;
+
+import java.util.Collections;
+
+import static org.junit.Assert.assertEquals;
+
+public class CreateOrUpdate_DryRunIT extends LmIntegrationTest {
+
+    @Test
+	public void test_WithoutParameters() {
+		LmTask task = etl.service(ITaskService.class).createOrUpdate(Etl1t.class)
+				.sourceExtractor("com/nhl/link/move/itest/etl1_to_etl1t").matchBy(Etl1t.NAME).task();
+
+		srcRunSql("INSERT INTO utest.etl1 (NAME, AGE) VALUES ('a', 3)");
+		srcRunSql("INSERT INTO utest.etl1 (NAME, AGE) VALUES ('b', NULL)");
+
+		Execution e1 = task.dryRun();
+		assertExec(2, 2, 0, 0, e1);
+		assertEquals(0, targetScalar("SELECT count(1) from utest.etl1t"));
+	}
+
+    @Test
+	public void test_WithParameters() {
+		LmTask task = etl.service(ITaskService.class).createOrUpdate(Etl1t.class)
+				.sourceExtractor("com/nhl/link/move/itest/etl1_to_etl1t").matchBy(Etl1t.NAME).task();
+
+		srcRunSql("INSERT INTO utest.etl1 (NAME, AGE) VALUES ('a', 3)");
+		srcRunSql("INSERT INTO utest.etl1 (NAME, AGE) VALUES ('b', NULL)");
+
+		Execution e1 = task.dryRun(Collections.singletonMap("x", "y"));
+		assertExec(2, 2, 0, 0, e1);
+		assertEquals(0, targetScalar("SELECT count(1) from utest.etl1t"));
+	}
+
+    @Test
+	public void test_SyncToken_WithoutParameters() {
+		LmTask task = etl.service(ITaskService.class).createOrUpdate(Etl1t.class)
+				.sourceExtractor("com/nhl/link/move/itest/etl1_to_etl1t").matchBy(Etl1t.NAME).task();
+
+		srcRunSql("INSERT INTO utest.etl1 (NAME, AGE) VALUES ('a', 3)");
+		srcRunSql("INSERT INTO utest.etl1 (NAME, AGE) VALUES ('b', NULL)");
+
+		Execution e1 = task.dryRun(new TimestampToken("token"));
+		assertExec(2, 2, 0, 0, e1);
+		assertEquals(0, targetScalar("SELECT count(1) from utest.etl1t"));
+	}
+
+    @Test
+	public void test_SyncToken_WithParameters() {
+		LmTask task = etl.service(ITaskService.class).createOrUpdate(Etl1t.class)
+				.sourceExtractor("com/nhl/link/move/itest/etl1_to_etl1t").matchBy(Etl1t.NAME).task();
+
+		srcRunSql("INSERT INTO utest.etl1 (NAME, AGE) VALUES ('a', 3)");
+		srcRunSql("INSERT INTO utest.etl1 (NAME, AGE) VALUES ('b', NULL)");
+
+		Execution e1 = task.dryRun(new TimestampToken("token"), Collections.singletonMap("x", "y"));
+		assertExec(2, 2, 0, 0, e1);
+		assertEquals(0, targetScalar("SELECT count(1) from utest.etl1t"));
+	}
+}

link-move/src/test/java/com/nhl/link/move/itest/Delete_DryRunIT.java

@@ -0,0 +1,72 @@
+package com.nhl.link.move.itest;
+
+import com.nhl.link.move.Execution;
+import com.nhl.link.move.LmTask;
+import com.nhl.link.move.TimestampToken;
+import com.nhl.link.move.runtime.task.ITaskService;
+import com.nhl.link.move.unit.LmIntegrationTest;
+import com.nhl.link.move.unit.cayenne.t.Etl1t;
+import org.junit.Test;
+
+import java.util.Collections;
+
+import static org.junit.Assert.assertEquals;
+
+public class Delete_DryRunIT extends LmIntegrationTest {
+
+    @Test
+	public void test_WithoutParameters() {
+		LmTask task = etl.service(ITaskService.class).delete(Etl1t.class)
+				.sourceMatchExtractor("com/nhl/link/move/itest/etl1_to_etl1t").matchBy(Etl1t.NAME).task();
+
+		targetRunSql("INSERT INTO utest.etl1t (NAME, AGE) VALUES ('a', 3)");
+		targetRunSql("INSERT INTO utest.etl1t (NAME, AGE) VALUES ('b', NULL)");
+
+		Execution e1 = task.dryRun();
+		assertExec(0, 0, 0, 2, e1);
+
+		assertEquals(2, targetScalar("SELECT count(1) from utest.etl1t"));
+	}
+
+    @Test
+	public void test_WithParameters() {
+		LmTask task = etl.service(ITaskService.class).delete(Etl1t.class)
+				.sourceMatchExtractor("com/nhl/link/move/itest/etl1_to_etl1t").matchBy(Etl1t.NAME).task();
+
+		targetRunSql("INSERT INTO utest.etl1t (NAME, AGE) VALUES ('a', 3)");
+		targetRunSql("INSERT INTO utest.etl1t (NAME, AGE) VALUES ('b', NULL)");
+
+		Execution e1 = task.dryRun(Collections.singletonMap("x", "y"));
+		assertExec(0, 0, 0, 2, e1);
+
+		assertEquals(2, targetScalar("SELECT count(1) from utest.etl1t"));
+	}
+
+    @Test
+	public void test_SyncToken_WithoutParameters() {
+		LmTask task = etl.service(ITaskService.class).delete(Etl1t.class)
+				.sourceMatchExtractor("com/nhl/link/move/itest/etl1_to_etl1t").matchBy(Etl1t.NAME).task();
+
+		targetRunSql("INSERT INTO utest.etl1t (NAME, AGE) VALUES ('a', 3)");
+		targetRunSql("INSERT INTO utest.etl1t (NAME, AGE) VALUES ('b', NULL)");
+
+		Execution e1 = task.dryRun(new TimestampToken("token"));
+		assertExec(0, 0, 0, 2, e1);
+
+		assertEquals(2, targetScalar("SELECT count(1) from utest.etl1t"));
+	}
+
+    @Test
+	public void test_SyncToken_WithParameters() {
+		LmTask task = etl.service(ITaskService.class).delete(Etl1t.class)
+				.sourceMatchExtractor("com/nhl/link/move/itest/etl1_to_etl1t").matchBy(Etl1t.NAME).task();
+
+		targetRunSql("INSERT INTO utest.etl1t (NAME, AGE) VALUES ('a', 3)");
+		targetRunSql("INSERT INTO utest.etl1t (NAME, AGE) VALUES ('b', NULL)");
+
+		Execution e1 = task.dryRun(new TimestampToken("token"), Collections.singletonMap("x", "y"));
+		assertExec(0, 0, 0, 2, e1);
+
+		assertEquals(2, targetScalar("SELECT count(1) from utest.etl1t"));
+	}
+}