| /* |
| * 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.nifi.processors.groovyx; |
| |
| import org.apache.commons.lang3.SystemUtils; |
| import org.apache.nifi.serialization.RecordSetWriterFactory; |
| import org.apache.nifi.serialization.SimpleRecordSchema; |
| import org.apache.nifi.serialization.record.MockRecordParser; |
| import org.apache.nifi.serialization.record.MockRecordWriter; |
| import org.apache.nifi.serialization.record.RecordField; |
| import org.apache.nifi.serialization.record.RecordFieldType; |
| import org.apache.nifi.serialization.record.RecordSchema; |
| import org.apache.nifi.util.MockFlowFile; |
| import org.apache.nifi.util.MockProcessContext; |
| import org.apache.nifi.util.MockProcessorInitializationContext; |
| |
| import org.apache.commons.io.FileUtils; |
| |
| import org.apache.nifi.util.TestRunner; |
| import org.apache.nifi.util.TestRunners; |
| import org.apache.nifi.processor.exception.ProcessException; |
| |
| import org.junit.AfterClass; |
| import org.junit.Assume; |
| import org.junit.BeforeClass; |
| import org.junit.Before; |
| import org.junit.Test; |
| import org.junit.FixMethodOrder; |
| import org.junit.runners.MethodSorters; |
| |
| import java.io.ByteArrayOutputStream; |
| import java.io.File; |
| import java.io.FileInputStream; |
| |
| import java.io.PrintStream; |
| import java.nio.charset.StandardCharsets; |
| |
| import java.util.Arrays; |
| import java.util.List; |
| import java.util.HashMap; |
| |
| import java.sql.DriverManager; |
| import java.sql.Connection; |
| import java.sql.Statement; |
| |
| import static org.junit.Assert.assertEquals; |
| import static org.junit.Assert.assertNotNull; |
| |
| import org.apache.nifi.controller.AbstractControllerService; |
| import org.apache.nifi.dbcp.DBCPService; |
| |
| import org.codehaus.groovy.runtime.ResourceGroovyMethods; |
| |
| import groovy.json.JsonSlurper; |
| import groovy.json.JsonOutput; |
| |
| @FixMethodOrder(MethodSorters.NAME_ASCENDING) |
| public class ExecuteGroovyScriptTest { |
| private final static String DB_LOCATION = "target/db"; |
| |
| protected TestRunner runner; |
| protected static DBCPService dbcp = null; //to make single initialization |
| protected MockRecordParser recordParser = null; |
| protected RecordSetWriterFactory recordWriter = null; |
| protected RecordSchema recordSchema = null; |
| protected ExecuteGroovyScript proc; |
| public final String TEST_RESOURCE_LOCATION = "target/test/resources/groovy/"; |
| private final String TEST_CSV_DATA = "gender,title,first,last\n" |
| + "female,miss,marlene,shaw\n" |
| + "male,mr,todd,graham"; |
| |
| |
| @AfterClass |
| public static void cleanUpAfterClass() throws Exception { |
| try { |
| DriverManager.getConnection("jdbc:derby:" + DB_LOCATION + ";shutdown=true"); |
| } catch (Exception e) { |
| } |
| // remove previous test database, if any |
| final File dbLocation = new File(DB_LOCATION); |
| FileUtils.deleteQuietly(dbLocation); |
| } |
| |
| /** |
| * Copies all scripts to the target directory because when they are compiled they can leave unwanted .class files. |
| * |
| * @throws Exception Any error encountered while testing |
| */ |
| @BeforeClass |
| public static void setupBeforeClass() throws Exception { |
| Assume.assumeTrue("Test only runs on *nix", !SystemUtils.IS_OS_WINDOWS); |
| FileUtils.copyDirectory(new File("src/test/resources"), new File("target/test/resources")); |
| //prepare database connection |
| System.setProperty("derby.stream.error.file", "target" + File.separator + "derby.log"); |
| |
| // remove previous test database, if any |
| final File dbLocation = new File(DB_LOCATION); |
| FileUtils.deleteQuietly(dbLocation); |
| //insert some test data |
| dbcp = new DBCPServiceSimpleImpl(); |
| Connection con = dbcp.getConnection(); |
| Statement stmt = con.createStatement(); |
| try { |
| stmt.execute("drop table mytable"); |
| } catch (Exception e) { |
| } |
| stmt.execute("create table mytable (id integer not null, name varchar(100), scale float, created timestamp, data blob)"); |
| stmt.execute("insert into mytable (id, name, scale, created, data) VALUES (0, 'Joe Smith', 1.0, '1962-09-23 03:23:34.234', null)"); |
| stmt.execute("insert into mytable (id, name, scale, created, data) VALUES (1, 'Carrie Jones', 5.1, '2000-01-01 03:23:34.234', null)"); |
| stmt.close(); |
| con.commit(); |
| con.close(); |
| } |
| |
| @Before |
| public void setup() throws Exception { |
| //init processor |
| proc = new ExecuteGroovyScript(); |
| MockProcessContext context = new MockProcessContext(proc); |
| MockProcessorInitializationContext initContext = new MockProcessorInitializationContext(proc, context); |
| proc.initialize(initContext); |
| |
| assertNotNull(proc.getSupportedPropertyDescriptors()); |
| runner = TestRunners.newTestRunner(proc); |
| runner.addControllerService("dbcp", dbcp, new HashMap<>()); |
| runner.enableControllerService(dbcp); |
| |
| List<RecordField> recordFields = Arrays.asList( |
| new RecordField("id", RecordFieldType.INT.getDataType()), |
| new RecordField("name", RecordFieldType.STRING.getDataType()), |
| new RecordField("code", RecordFieldType.INT.getDataType())); |
| recordSchema = new SimpleRecordSchema(recordFields); |
| |
| recordParser = new MockRecordParser(); |
| recordFields.forEach((r) -> recordParser.addSchemaField(r)); |
| runner.addControllerService("myreader", recordParser, new HashMap<>()); |
| runner.enableControllerService(recordParser); |
| |
| recordWriter = new MockRecordWriter(); |
| runner.addControllerService("mywriter", recordWriter, new HashMap<>()); |
| runner.enableControllerService(recordWriter); |
| } |
| |
| /** |
| * Tests a script that reads content of the flowfile content and stores the value in an attribute of the outgoing flowfile. |
| * |
| * @throws Exception Any error encountered while testing |
| */ |
| @Test |
| public void testReadFlowFileContentAndStoreInFlowFileAttribute() throws Exception { |
| runner.setProperty(proc.SCRIPT_BODY, "def flowFile = session.get(); if(!flowFile)return; flowFile.testAttr = flowFile.read().getText('UTF-8'); REL_SUCCESS << flowFile;"); |
| //runner.setProperty(proc.FAIL_STRATEGY, "rollback"); |
| |
| runner.assertValid(); |
| runner.enqueue("test content".getBytes("UTF-8")); |
| runner.run(); |
| |
| runner.assertAllFlowFilesTransferred(proc.REL_SUCCESS.getName(), 1); |
| final List<MockFlowFile> result = runner.getFlowFilesForRelationship(proc.REL_SUCCESS.getName()); |
| result.get(0).assertAttributeEquals("testAttr", "test content"); |
| } |
| |
| @Test |
| public void test_onTrigger_groovy() throws Exception { |
| runner.setProperty(proc.SCRIPT_FILE, TEST_RESOURCE_LOCATION + "test_onTrigger.groovy"); |
| //runner.setProperty(proc.FAIL_STRATEGY, "rollback"); |
| runner.assertValid(); |
| |
| runner.enqueue("test content".getBytes(StandardCharsets.UTF_8)); |
| runner.run(); |
| runner.assertAllFlowFilesTransferred(proc.REL_SUCCESS.getName(), 1); |
| final List<MockFlowFile> result = runner.getFlowFilesForRelationship(proc.REL_SUCCESS.getName()); |
| result.get(0).assertAttributeEquals("from-content", "test content"); |
| } |
| |
| @Test |
| public void test_onTriggerX_groovy() throws Exception { |
| runner.setProperty(proc.SCRIPT_FILE, TEST_RESOURCE_LOCATION + "test_onTriggerX.groovy"); |
| //runner.setProperty(proc.FAIL_STRATEGY, "rollback"); |
| runner.assertValid(); |
| |
| runner.enqueue("test content".getBytes(StandardCharsets.UTF_8)); |
| runner.run(); |
| runner.assertAllFlowFilesTransferred(proc.REL_SUCCESS.getName(), 1); |
| final List<MockFlowFile> result = runner.getFlowFilesForRelationship(proc.REL_SUCCESS.getName()); |
| result.get(0).assertAttributeEquals("from-content", "test content"); |
| } |
| |
| @Test |
| public void test_onTrigger_changeContent_groovy() throws Exception { |
| runner.setProperty(proc.SCRIPT_FILE, TEST_RESOURCE_LOCATION + "test_onTrigger_changeContent.groovy"); |
| //runner.setProperty(proc.FAIL_STRATEGY, "rollback"); |
| runner.assertValid(); |
| |
| runner.enqueue(TEST_CSV_DATA.getBytes(StandardCharsets.UTF_8)); |
| runner.run(); |
| |
| runner.assertAllFlowFilesTransferred(proc.REL_SUCCESS.getName(), 1); |
| final List<MockFlowFile> result = runner.getFlowFilesForRelationship(proc.REL_SUCCESS.getName()); |
| MockFlowFile resultFile = result.get(0); |
| resultFile.assertAttributeEquals("selected.columns", "first,last"); |
| resultFile.assertContentEquals("Marlene Shaw\nTodd Graham\n"); |
| } |
| |
| @Test |
| public void test_onTrigger_changeContentX_groovy() throws Exception { |
| runner.setProperty(proc.SCRIPT_FILE, TEST_RESOURCE_LOCATION + "test_onTrigger_changeContentX.groovy"); |
| //runner.setProperty(proc.FAIL_STRATEGY, "rollback"); |
| runner.assertValid(); |
| |
| runner.enqueue(TEST_CSV_DATA.getBytes(StandardCharsets.UTF_8)); |
| runner.run(); |
| |
| runner.assertAllFlowFilesTransferred(proc.REL_SUCCESS.getName(), 1); |
| final List<MockFlowFile> result = runner.getFlowFilesForRelationship(proc.REL_SUCCESS.getName()); |
| MockFlowFile resultFile = result.get(0); |
| resultFile.assertAttributeEquals("selected.columns", "first,last"); |
| resultFile.assertContentEquals("Marlene Shaw\nTodd Graham\n"); |
| } |
| |
| @Test |
| public void test_no_input_groovy() throws Exception { |
| runner.setProperty(proc.SCRIPT_FILE, TEST_RESOURCE_LOCATION + "test_no_input.groovy"); |
| //runner.setProperty(proc.FAIL_STRATEGY, "rollback"); |
| runner.assertValid(); |
| runner.run(); |
| runner.assertAllFlowFilesTransferred(proc.REL_SUCCESS.getName(), 1); |
| final List<MockFlowFile> result = runner.getFlowFilesForRelationship(proc.REL_SUCCESS.getName()); |
| MockFlowFile resultFile = result.get(0); |
| resultFile.assertAttributeEquals("filename", "test.txt"); |
| resultFile.assertContentEquals("Test"); |
| } |
| |
| |
| @Test |
| public void test_good_script() throws Exception { |
| runner.setProperty(proc.SCRIPT_BODY, " def ff = session.get(); if(!ff)return; REL_SUCCESS << ff "); |
| runner.assertValid(); |
| } |
| |
| @Test |
| public void test_bad_script() throws Exception { |
| runner.setProperty(proc.SCRIPT_BODY, " { { "); |
| runner.assertNotValid(); |
| } |
| |
| //--------------------------------------------------------- |
| @Test |
| public void test_ctl_01_access() throws Exception { |
| runner.setProperty(proc.SCRIPT_FILE, TEST_RESOURCE_LOCATION + "test_ctl_01_access.groovy"); |
| runner.setProperty("CTL.mydbcp", "dbcp"); //pass dbcp as a service to script |
| runner.assertValid(); |
| |
| runner.run(); |
| |
| runner.assertAllFlowFilesTransferred(proc.REL_SUCCESS.getName(), 1); |
| final List<MockFlowFile> result = runner.getFlowFilesForRelationship(proc.REL_SUCCESS.getName()); |
| MockFlowFile resultFile = result.get(0); |
| resultFile.assertContentEquals("OK", "UTF-8"); |
| } |
| |
| @Test |
| public void test_sql_01_select() throws Exception { |
| runner.setProperty(proc.SCRIPT_FILE, TEST_RESOURCE_LOCATION + "test_sql_01_select.groovy"); |
| runner.setProperty("SQL.mydb", "dbcp"); |
| runner.assertValid(); |
| |
| runner.run(); |
| |
| runner.assertAllFlowFilesTransferred(proc.REL_SUCCESS.getName(), 1); |
| final List<MockFlowFile> result = runner.getFlowFilesForRelationship(proc.REL_SUCCESS.getName()); |
| MockFlowFile resultFile = result.get(0); |
| resultFile.assertAttributeEquals("filename", "test.txt"); |
| resultFile.assertContentEquals("Joe Smith\nCarrie Jones\n", "UTF-8"); |
| } |
| |
| @Test |
| public void test_sql_02_blob_write() throws Exception { |
| runner.setProperty(proc.SCRIPT_FILE, TEST_RESOURCE_LOCATION + "test_sql_02_blob_write.groovy"); |
| runner.setProperty("SQL.mydb", "dbcp"); |
| //runner.setProperty("ID", "0"); |
| runner.assertValid(); |
| |
| runner.enqueue(TEST_CSV_DATA.getBytes(StandardCharsets.UTF_8), map("ID", "0")); |
| runner.run(); |
| |
| runner.assertAllFlowFilesTransferred(proc.REL_SUCCESS.getName(), 1); |
| final List<MockFlowFile> result = runner.getFlowFilesForRelationship(proc.REL_SUCCESS.getName()); |
| MockFlowFile resultFile = result.get(0); |
| resultFile.assertContentEquals(TEST_CSV_DATA.getBytes(StandardCharsets.UTF_8)); |
| //let's check database content in next text case |
| |
| } |
| |
| @Test |
| public void test_sql_03_blob_read() throws Exception { |
| //read blob from database written at previous step and write to flow file |
| runner.setProperty(proc.SCRIPT_FILE, TEST_RESOURCE_LOCATION + "test_sql_03_blob_read.groovy"); |
| runner.setProperty("SQL.mydb", "dbcp"); |
| runner.setProperty("ID", "0"); |
| runner.setValidateExpressionUsage(false); |
| runner.assertValid(); |
| |
| runner.run(); |
| |
| runner.assertAllFlowFilesTransferred(proc.REL_SUCCESS.getName(), 1); |
| final List<MockFlowFile> result = runner.getFlowFilesForRelationship(proc.REL_SUCCESS.getName()); |
| MockFlowFile resultFile = result.get(0); |
| resultFile.assertContentEquals(TEST_CSV_DATA.getBytes(StandardCharsets.UTF_8)); |
| } |
| |
| @Test |
| public void test_sql_04_insert_and_json() throws Exception { |
| //read blob from database written at previous step and write to flow file |
| runner.setProperty(proc.SCRIPT_FILE, TEST_RESOURCE_LOCATION + "test_sql_04_insert_and_json.groovy"); |
| runner.setProperty("SQL.mydb", "dbcp"); |
| runner.setValidateExpressionUsage(false); |
| runner.assertValid(); |
| |
| runner.enqueue(new FileInputStream(TEST_RESOURCE_LOCATION + "test_sql_04_insert_and_json.json")); |
| runner.run(); |
| |
| runner.assertAllFlowFilesTransferred(proc.REL_SUCCESS.getName(), 3); //number of inserted rows |
| final List<MockFlowFile> result = runner.getFlowFilesForRelationship(proc.REL_SUCCESS.getName()); |
| MockFlowFile resultFile = result.get(0); |
| List<String> lines = ResourceGroovyMethods.readLines(new File(TEST_RESOURCE_LOCATION + "test_sql_04_insert_and_json.json"), "UTF-8"); |
| //pass through to&from json before compare |
| resultFile.assertContentEquals(JsonOutput.toJson(new JsonSlurper().parseText(lines.get(1))), "UTF-8"); |
| } |
| |
| @Test |
| public void test_record_reader_writer_access() throws Exception { |
| runner.setProperty(ExecuteGroovyScript.SCRIPT_FILE, TEST_RESOURCE_LOCATION + "test_record_reader_writer.groovy"); |
| runner.setProperty("RecordReader.myreader", "myreader"); //pass myreader as a service to script |
| runner.setProperty("RecordWriter.mywriter", "mywriter"); //pass mywriter as a service to script |
| runner.assertValid(); |
| |
| recordParser.addRecord(1, "A", "XYZ"); |
| runner.enqueue(""); |
| runner.run(); |
| |
| runner.assertAllFlowFilesTransferred(ExecuteGroovyScript.REL_SUCCESS.getName(), 1); |
| final List<MockFlowFile> result = runner.getFlowFilesForRelationship(ExecuteGroovyScript.REL_SUCCESS.getName()); |
| MockFlowFile resultFile = result.get(0); |
| resultFile.assertContentEquals("\"1\",\"A\",\"XYZ\"\n", "UTF-8"); |
| } |
| |
| @Test |
| public void test_filter_01() throws Exception { |
| runner.setProperty(proc.SCRIPT_BODY, "def ff = session.get{it.FILTER=='3'}; if(!ff)return; REL_SUCCESS << ff;"); |
| //runner.setProperty(proc.FAIL_STRATEGY, "rollback"); |
| |
| runner.assertValid(); |
| |
| runner.enqueue("01".getBytes("UTF-8"), map("FILTER", "1")); |
| runner.enqueue("31".getBytes("UTF-8"), map("FILTER", "3")); |
| runner.enqueue("03".getBytes("UTF-8"), map("FILTER", "2")); |
| runner.enqueue("32".getBytes("UTF-8"), map("FILTER", "3")); |
| runner.run(); |
| |
| runner.assertAllFlowFilesTransferred(proc.REL_SUCCESS.getName(), 2); |
| final List<MockFlowFile> result = runner.getFlowFilesForRelationship(proc.REL_SUCCESS.getName()); |
| |
| result.get(0).assertContentEquals("31", "UTF-8"); |
| result.get(1).assertContentEquals("32", "UTF-8"); |
| } |
| |
| @Test |
| public void test_read_01() throws Exception { |
| runner.setProperty(proc.SCRIPT_BODY, "def ff = session.get(); if(!ff)return; assert ff.read().getText('UTF-8')=='1234'; REL_SUCCESS << ff; "); |
| |
| runner.assertValid(); |
| |
| runner.enqueue("1234".getBytes("UTF-8")); |
| runner.run(); |
| |
| runner.assertAllFlowFilesTransferred(proc.REL_SUCCESS.getName(), 1); |
| } |
| |
| @Test |
| public void test_read_02() throws Exception { |
| runner.setProperty(proc.SCRIPT_BODY, "def ff = session.get(); if(!ff)return; ff.read{s-> assert s.getText('UTF-8')=='1234' }; REL_SUCCESS << ff; "); |
| |
| runner.assertValid(); |
| |
| runner.enqueue("1234".getBytes("UTF-8")); |
| runner.run(); |
| |
| runner.assertAllFlowFilesTransferred(proc.REL_SUCCESS.getName(), 1); |
| } |
| |
| @Test |
| public void test_read_03() throws Exception { |
| runner.setProperty(proc.SCRIPT_BODY, "def ff = session.get(); if(!ff)return; ff.read('UTF-8'){r-> assert r.getText()=='1234' }; REL_SUCCESS << ff; "); |
| |
| runner.assertValid(); |
| |
| runner.enqueue("1234".getBytes("UTF-8")); |
| runner.run(); |
| |
| runner.assertAllFlowFilesTransferred(proc.REL_SUCCESS.getName(), 1); |
| } |
| |
| @Test |
| public void test_withInputStream() { |
| runner.setProperty(ExecuteGroovyScript.SCRIPT_BODY, "import java.util.stream.*\n" |
| + "def ff = session.get(); if(!ff)return;\n" |
| + "ff.withInputStream{inputStream -> String r = new BufferedReader(new InputStreamReader(inputStream)).lines()" |
| + ".collect(Collectors.joining(\"\\n\")); assert r=='1234' }; REL_SUCCESS << ff; "); |
| |
| runner.assertValid(); |
| |
| runner.enqueue("1234".getBytes(StandardCharsets.UTF_8)); |
| runner.run(); |
| |
| runner.assertAllFlowFilesTransferred(ExecuteGroovyScript.REL_SUCCESS.getName(), 1); |
| } |
| |
| @Test |
| public void test_withOutputStream() { |
| runner.setProperty(ExecuteGroovyScript.SCRIPT_BODY, "import java.util.stream.*\n" |
| + "def ff = session.get(); if(!ff)return;\n" |
| + "ff.withOutputStream{outputStream -> outputStream.write('5678'.bytes)}; REL_SUCCESS << ff; "); |
| |
| runner.assertValid(); |
| |
| runner.enqueue("1234".getBytes(StandardCharsets.UTF_8)); |
| runner.run(); |
| |
| runner.assertAllFlowFilesTransferred(ExecuteGroovyScript.REL_SUCCESS.getName(), 1); |
| MockFlowFile flowFile = runner.getFlowFilesForRelationship(ExecuteGroovyScript.REL_SUCCESS).get(0); |
| flowFile.assertContentEquals("5678"); |
| } |
| |
| @Test |
| public void test_withReader() { |
| runner.setProperty(ExecuteGroovyScript.SCRIPT_BODY, "import java.util.stream.*\n" |
| + "def ff = session.get(); if(!ff)return;\n" |
| + "ff.withReader('UTF-8'){reader -> String r = new BufferedReader(reader).lines()" |
| + ".collect(Collectors.joining(\"\\n\")); assert r=='1234' }; REL_SUCCESS << ff; "); |
| |
| runner.assertValid(); |
| |
| runner.enqueue("1234".getBytes(StandardCharsets.UTF_8)); |
| runner.run(); |
| |
| runner.assertAllFlowFilesTransferred(ExecuteGroovyScript.REL_SUCCESS.getName(), 1); |
| } |
| |
| @Test |
| public void test_withWriter() throws Exception { |
| runner.setProperty(ExecuteGroovyScript.SCRIPT_BODY, "import java.util.stream.*\n" |
| + "def ff = session.get(); if(!ff)return;\n" |
| + "ff.withWriter('UTF-16LE'){writer -> writer.write('5678')}; REL_SUCCESS << ff; "); |
| |
| runner.assertValid(); |
| |
| runner.enqueue("1234".getBytes(StandardCharsets.UTF_8)); |
| runner.run(); |
| |
| runner.assertAllFlowFilesTransferred(ExecuteGroovyScript.REL_SUCCESS.getName(), 1); |
| MockFlowFile flowFile = runner.getFlowFilesForRelationship(ExecuteGroovyScript.REL_SUCCESS).get(0); |
| flowFile.assertContentEquals("5678".getBytes(StandardCharsets.UTF_16LE)); |
| } |
| |
| @Test |
| public void test_onStart_onStop() throws Exception { |
| runner.setProperty(ExecuteGroovyScript.SCRIPT_FILE, TEST_RESOURCE_LOCATION + "test_onStart_onStop.groovy"); |
| runner.assertValid(); |
| runner.enqueue(""); |
| final PrintStream originalOut = System.out; |
| final ByteArrayOutputStream outContent = new ByteArrayOutputStream(); |
| System.setOut(new PrintStream(outContent)); |
| runner.run(); |
| |
| runner.assertAllFlowFilesTransferred(ExecuteGroovyScript.REL_SUCCESS.getName(), 1); |
| final List<MockFlowFile> result = runner.getFlowFilesForRelationship(ExecuteGroovyScript.REL_SUCCESS.getName()); |
| MockFlowFile resultFile = result.get(0); |
| resultFile.assertAttributeExists("a"); |
| resultFile.assertAttributeEquals("a", "A"); |
| System.setOut(originalOut); |
| assertEquals("onStop invoked successfully\n", outContent.toString()); |
| |
| // Inspect the output visually for onStop, no way to pass back values |
| } |
| |
| @Test |
| public void test_onUnscheduled() throws Exception { |
| runner.setProperty(ExecuteGroovyScript.SCRIPT_FILE, TEST_RESOURCE_LOCATION + "test_onUnscheduled.groovy"); |
| runner.assertValid(); |
| final PrintStream originalOut = System.out; |
| final ByteArrayOutputStream outContent = new ByteArrayOutputStream(); |
| System.setOut(new PrintStream(outContent)); |
| runner.run(); |
| System.setOut(originalOut); |
| assertEquals("onUnscheduled invoked successfully\n", outContent.toString()); |
| } |
| |
| |
| private HashMap<String, String> map(String key, String value) { |
| HashMap<String, String> attrs = new HashMap<>(); |
| attrs.put(key, value); |
| return attrs; |
| } |
| |
| private static class DBCPServiceSimpleImpl extends AbstractControllerService implements DBCPService { |
| |
| @Override |
| public String getIdentifier() { |
| return "dbcp"; |
| } |
| |
| @Override |
| public Connection getConnection() throws ProcessException { |
| try { |
| Class.forName("org.apache.derby.jdbc.EmbeddedDriver"); |
| return DriverManager.getConnection("jdbc:derby:" + DB_LOCATION + ";create=true"); |
| } catch (final Exception e) { |
| throw new ProcessException("getConnection failed: " + e); |
| } |
| } |
| } |
| } |
