mirror of
https://github.com/nosqlbench/nosqlbench.git
synced 2025-02-25 18:55:28 -06:00
support JAVA_HOME for integration tests
This commit is contained in:
@@ -19,19 +19,24 @@ package io.nosqlbench.cli.testing;
|
||||
|
||||
import org.junit.Test;
|
||||
|
||||
import java.util.Optional;
|
||||
import java.util.stream.Collectors;
|
||||
|
||||
import static org.assertj.core.api.Assertions.assertThat;
|
||||
|
||||
public class ExitStatusIntegrationTests {
|
||||
|
||||
private final String java = Optional.ofNullable(System.getenv(
|
||||
"JAVA_HOME")).map(v -> v+"/bin/java").orElse("java");
|
||||
|
||||
private final static String JARNAME = "target/nb.jar";
|
||||
@Test
|
||||
public void testExitStatusOnBadParam() {
|
||||
ProcessInvoker invoker = new ProcessInvoker();
|
||||
invoker.setLogDir("logs/test");
|
||||
ProcessResult result = invoker.run("exitstatus_badparam", 15,
|
||||
"java", "-jar", JARNAME, "--logs-dir", "logs/test", "badparam"
|
||||
java, "-jar", JARNAME, "--logs-dir", "logs/test",
|
||||
"badparam"
|
||||
);
|
||||
String stderr = result.getStderrData().stream().collect(Collectors.joining("\n"));
|
||||
assertThat(stderr).contains("unrecognized option:badparam");
|
||||
@@ -43,7 +48,8 @@ public class ExitStatusIntegrationTests {
|
||||
ProcessInvoker invoker = new ProcessInvoker();
|
||||
invoker.setLogDir("logs/test");
|
||||
ProcessResult result = invoker.run("exitstatus_initexception", 15,
|
||||
"java", "-jar", JARNAME, "--logs-dir", "logs/test", "run", "driver=diag", "initdelay=notanumber"
|
||||
java, "-jar", JARNAME, "--logs-dir", "logs/test", "run",
|
||||
"driver=diag", "initdelay=notanumber"
|
||||
);
|
||||
String stderr = result.getStdoutData().stream().collect(Collectors.joining("\n"));
|
||||
assertThat(stderr).contains("Error initializing activity 'ALIAS_UNSET': For input string: \"notanumber\"");
|
||||
@@ -70,7 +76,8 @@ public class ExitStatusIntegrationTests {
|
||||
ProcessInvoker invoker = new ProcessInvoker();
|
||||
invoker.setLogDir("logs/test");
|
||||
ProcessResult result = invoker.run("exitstatus_asyncstoprequest", 30,
|
||||
"java", "-jar", JARNAME, "--logs-dir", "logs/test", "run", "driver=diag", "async=1", "cyclerate=5", "erroroncycle=10", "cycles=2000", "-vvv"
|
||||
java, "-jar", JARNAME, "--logs-dir", "logs/test", "run",
|
||||
"driver=diag", "async=1", "cyclerate=5", "erroroncycle=10", "cycles=2000", "-vvv"
|
||||
);
|
||||
String stdout = result.getStdoutData().stream().collect(Collectors.joining("\n"));
|
||||
assertThat(stdout).contains("Diag was requested to stop on cycle 10");
|
||||
|
||||
@@ -23,19 +23,25 @@ import org.junit.Test;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import java.util.Optional;
|
||||
|
||||
import static org.assertj.core.api.Assertions.assertThat;
|
||||
|
||||
public class NBCliIntegrationTests {
|
||||
|
||||
private final static String JARNAME = "target/nb.jar";
|
||||
private Logger logger = LoggerFactory.getLogger(NBCliIntegrationTests.class);
|
||||
private final String java = Optional.ofNullable(System.getenv(
|
||||
"JAVA_HOME")).map(v -> v+"/bin/java").orElse("java");
|
||||
|
||||
|
||||
@Test
|
||||
public void listWorkloadsTest() {
|
||||
ProcessInvoker invoker = new ProcessInvoker();
|
||||
invoker.setLogDir("logs/test");
|
||||
ProcessResult result = invoker.run("workload-test", 15,
|
||||
"java", "-jar", JARNAME, "--logs-dir", "logs/test", "--list-workloads"
|
||||
java, "-jar", JARNAME, "--logs-dir", "logs/test", "--list" +
|
||||
"-workloads"
|
||||
);
|
||||
System.out.println(result.getStdoutData());
|
||||
System.out.println(result.getStderrData());
|
||||
|
||||
Reference in New Issue
Block a user