Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

How to use withEnv method of org.testcontainers.containers.GenericContainer class

Best Testcontainers-java code snippet using org.testcontainers.containers.GenericContainer.withEnv

Source:StatefulFunctionsRuntimeProcesses.java

...77  private static GenericContainer<?> managerContainer(Network network) {78    return new GenericContainer<>(DockerImageName.parse("apache/flink-statefun:3.0.0"))79        .withNetwork(network)80        .withNetworkAliases("statefun-manager")81        .withEnv("ROLE", "master")82        .withEnv("MASTER_HOST", "statefun-manager")83        .withExposedPorts(8081)84        .withLogConsumer(new Slf4jLogConsumer(LOG))85        .withClasspathResourceMapping(86            "module.yaml", "/opt/statefun/modules/greeter/module.yaml", BindMode.READ_ONLY);87  }88  private static GenericContainer<?> workerContainer(Network network) {89    return new GenericContainer<>(DockerImageName.parse("apache/flink-statefun:3.0.0"))90        .withNetwork(network)91        .withNetworkAliases("statefun-worker")92        .withEnv("ROLE", "worker")93        .withEnv("MASTER_HOST", "statefun-manager")94        .withClasspathResourceMapping(95            "module.yaml", "/opt/statefun/modules/greeter/module.yaml", BindMode.READ_ONLY);96  }97  private static GenericContainer<?> jsonProducerContainer(Network network) {98    return new GenericContainer<>(99            DockerImageName.parse("ververica/statefun-playground-producer:latest"))100        .withNetwork(network)101        .withClasspathResourceMapping(102            "user-logins.txt", "/opt/statefun/user-logins.txt", BindMode.READ_ONLY)103        .withEnv("APP_PATH", "/opt/statefun/user-logins.txt")104        .withEnv("APP_KAFKA_HOST", "kafka:9092")105        .withEnv("APP_KAFKA_TOPIC", "user-logins")106        .withEnv("APP_JSON_PATH", "user_id");107  }108  private static void sleep() throws Exception {109    while (true) {110      Thread.sleep(10000);111    }112  }113}...

Source:AbstractTestcontainers.java

...32                .start();33        // Zookeeper34        zookeeperContainer.withNetwork(network)35                .withNetworkAliases("zookeeper")36                .withEnv("ZOOKEEPER_CLIENT_PORT", "2181")37                .withExposedPorts(2181)38                .waitingFor(Wait.forListeningPort().withStartupTimeout(STARTUP_TIMEOUT))39                .start();40        // Kafka41        kafkaContainer.withNetwork(network)42                .withNetworkAliases("kafka")43                .withExternalZookeeper("zookeeper:2181")44                .withExposedPorts(9092, 9093)45                .start();46        // Schema Registry47        schemaRegistryContainer.withNetwork(network)48                .withNetworkAliases("schema-registry")49                .withEnv("SCHEMA_REGISTRY_KAFKASTORE_BOOTSTRAP_SERVERS", "kafka:9092")50                .withEnv("SCHEMA_REGISTRY_HOST_NAME", "schema-registry")51                .withEnv("SCHEMA_REGISTRY_LISTENERS", "http://0.0.0.0:8081")52                .withExposedPorts(8081)53                .waitingFor(Wait.forListeningPort().withStartupTimeout(STARTUP_TIMEOUT))54                .start();55        // Cassandra56        cassandraContainer.withNetwork(network)57                .withNetworkAliases("cassandra")58                .start();59        // event-service60        eventServiceContainer.withNetwork(network)61                .withNetworkAliases("event-service")62                .withEnv("KAFKA_HOST", "kafka")63                .withEnv("KAFKA_PORT", "9092")64                .withEnv("SCHEMA_REGISTRY_HOST", "schema-registry")65                .withEnv("CASSANDRA_HOST", "cassandra")66                .withEnv("SPRING_ZIPKIN_ENABLED", "false")67                .withExposedPorts(EVENT_SERVICE_EXPOSED_PORT)68                .waitingFor(Wait.forHttp("/actuator/health")69                        .forPort(EVENT_SERVICE_EXPOSED_PORT).forStatusCode(200).withStartupTimeout(STARTUP_TIMEOUT))70                .start();71        registry.add("spring.datasource.url", mySQLContainer::getJdbcUrl);72        registry.add("spring.datasource.username", mySQLContainer::getUsername);73        registry.add("spring.datasource.password", mySQLContainer::getPassword);74        registry.add("spring.jpa.properties.hibernate.dialect.storage_engine", () -> "innodb");75        String schemaRegistryEndpoint = String.format("http://localhost:%s", schemaRegistryContainer.getMappedPort(8081));76        registry.add("spring.cloud.schema-registry-client.endpoint", () -> schemaRegistryEndpoint);77        registry.add("spring.cloud.stream.kafka.binder.brokers", kafkaContainer::getBootstrapServers);78        EVENT_SERVICE_API_URL = String.format("http://localhost:%s/api", eventServiceContainer.getMappedPort(EVENT_SERVICE_EXPOSED_PORT));79    }80}...

Source:ContainerHelper.java

...12    return new FixedHostPortGenericContainer("redis:5.0.6")13        .withFixedExposedPort(36379, 6379)14        .withNetwork(network)15        .withNetworkAliases("redis")16        .withEnv("REDIS_URL", "redis://redis:36379");17  }18  public static GenericContainer postgres(Network network) {19    return new FixedHostPortGenericContainer("postgres:12")20        .withFixedExposedPort(35432, 5432)21        .withEnv("POSTGRES_USER", "connector")22        .withEnv("POSTGRES_PASSWORD", "connector")23        .withEnv("POSTGRES_DB", "connector")24        // this gets emitted twice before the db is ready: once before the init scripts run and once after25        .waitingFor(Wait.forLogMessage(".*database system is ready to accept connections.*\\n", 2))26        .withNetwork(network);27  }28  public static GenericContainer pubsub() {29    int pubsubPort = 8085;30    return new FixedHostPortGenericContainer("google/cloud-sdk:latest")31      .withFixedExposedPort(38085, pubsubPort)32      .withExposedPorts(pubsubPort)33      .withCommand(34        "/bin/sh",35        "-c",36        String.format(37          "gcloud beta emulators pubsub start --project %s --host-port=0.0.0.0:%d",38          "integration-test", pubsubPort)39      )40      .waitingFor(new LogMessageWaitStrategy().withRegEx("(?s).*started.*$"));41  }42  public static GenericContainer settlement(Network network, int port, int connectorPort, Logger logger) {43    Testcontainers.exposeHostPorts(connectorPort);44    GenericContainer container = new GenericContainer<>("interledgerjs/settlement-xrp")45        .withExposedPorts(port)46        .withCreateContainerCmdModifier(e -> e.withPortSpecs())47        .withNetwork(network)48        .withEnv("REDIS_URI", "redis://redis:6379")49        .withEnv("ENGINE_PORT", String.valueOf(port))50        .withEnv("DEBUG", "settlement*")51        .withEnv("CONNECTOR_URL", "http://host.testcontainers.internal:" + connectorPort);52    if (logger != null) {53      container = container.withLogConsumer(new org.testcontainers.containers.output.Slf4jLogConsumer (logger));54    }55    return container;56  }57  public static GenericContainer javaConnector(String version, Optional<Logger> logger) {58    GenericContainer container = new GenericContainer("interledger4j/java-ilpv4-connector:" + version)59      .withExposedPorts(8080)60      .waitingFor(new LogMessageWaitStrategy().withRegEx("(?s).*Started ServerConnector.*$"));61    logger.ifPresent($ -> container.withLogConsumer(new org.testcontainers.containers.output.Slf4jLogConsumer($)));62    return container;63  }64}...

withEnv

Using AI Code Generation

1import org.testcontainers.containers.GenericContainer;2import org.testcontainers.containers.output.Slf4jLogConsumer;3import org.testcontainers.containers.wait.strategy.Wait;4import org.testcontainers.utility.MountableFile;5import java.io.File;6import java.io.IOException;7import java.util.Map;8public class TestContainerExample {9    public static void main(String[] args) throws IOException, InterruptedException {10        GenericContainer container = new GenericContainer("alpine:latest")11                .withCommand("tail", "-f", "/dev/null")12                .withWorkingDirectory("/opt")13                .withFileSystemBind("/tmp", "/opt")14                .withExposedPorts(8080)15                .withEnv("JAVA_OPTS", "-Xms512m -Xmx512m")16                .withEnv("SERVER_PORT", "8080")17                .withEnv("SERVER_HOST", "

withEnv

Using AI Code Generation

1import org.testcontainers.containers.GenericContainer;2public class TestContainerExample {3    public static void main(String[] args) {4        try (GenericContainer container = new GenericContainer("alpine:3.8")) {5            container.withEnv("FOO", "BAR");6            container.start();7        }8    }9}10import org.testcontainers.containers.PostgreSQLContainer;11public class TestContainerExample {12    public static void main(String[] args) {13        try (PostgreSQLContainer container = new PostgreSQLContainer()) {14            container.withEnv("FOO", "BAR");15            container.start();16        }17    }18}19import org.testcontainers.containers.MySQLContainer;20public class TestContainerExample {21    public static void main(String[] args) {22        try (MySQLContainer container = new MySQLContainer()) {23            container.withEnv("FOO", "BAR");24            container.start();25        }26    }27}28import org.testcontainers.containers.MSSQLServerContainer;29public class TestContainerExample {30    public static void main(String[] args) {31        try (MSSQLServerContainer container = new MSSQLServerContainer()) {32            container.withEnv("FOO", "BAR");33            container.start();34        }35    }36}37import org.testcontainers.containers.OracleContainer;38public class TestContainerExample {39    public static void main(String[] args) {40        try (OracleContainer container = new OracleContainer()) {41            container.withEnv("FOO", "BAR");42            container.start();43        }44    }45}46import org.testcontainers.containers.MariaDBContainer;47public class TestContainerExample {48    public static void main(String[] args) {49        try (MariaDBContainer container = new MariaDBContainer()) {50            container.withEnv("FOO", "BAR");51            container.start();52        }53    }54}

withEnv

Using AI Code Generation

1import org.testcontainers.containers.GenericContainer;2public class Test {3    public static void main(String[] args) {4        GenericContainer container = new GenericContainer("ubuntu:14.04")5                .withEnv("MY_ENV_VAR", "my value");6    }7}8import org.testcontainers.containers.GenericContainer;9public class Test {10    public static void main(String[] args) {11        GenericContainer container = new GenericContainer("ubuntu:14.04")12                .withEnv("MY_ENV_VAR", "my value")13                .withEnv("MY_ENV_VAR2", "my value2");14    }15}16import org.testcontainers.containers.GenericContainer;17public class Test {18    public static void main(String[] args) {19        GenericContainer container = new GenericContainer("ubuntu:14.04")20                .withEnv("MY_ENV_VAR", "my value")21                .withEnv("MY_ENV_VAR2", "my value2")22                .withEnv("MY_ENV_VAR3", "my value3");23    }24}25import org.testcontainers.containers.GenericContainer;26public class Test {27    public static void main(String[] args) {28        GenericContainer container = new GenericContainer("ubuntu:14.04")29                .withEnv("MY_ENV_VAR", "my value")30                .withEnv("MY_ENV_VAR2", "my value2")31                .withEnv("MY_ENV_VAR3", "my value3")32                .withEnv("MY_ENV_VAR4", "my value4");33    }34}35import org.testcontainers.containers.GenericContainer;36public class Test {37    public static void main(String[] args) {38        GenericContainer container = new GenericContainer("ubuntu:14.04")39                .withEnv("MY_ENV_VAR", "my value")40                .withEnv("MY_ENV_VAR2", "my value2")41                .withEnv("MY_ENV_VAR3", "my value3")42                .withEnv("MY_ENV_VAR4", "my value4")

withEnv

Using AI Code Generation

1package com.example;2import org.testcontainers.containers.GenericContainer;3public class App {4    public static void main(String[] args) {5        try (GenericContainer container = new GenericContainer("alpine:3.9")6                .withEnv("PATH", "/bin:/usr/bin:/sbin:/usr/sbin:/usr/local/bin:/usr/local/sbin")7                .withCommand("sh", "-c", "env")) {8            container.start();9            String containerLogs = container.getLogs();10            System.out.println(containerLogs);11        }12    }13}14package com.example;15import org.testcontainers.containers.GenericContainer;16public class App {17    public static void main(String[] args) {18        try (GenericContainer container = new GenericContainer("alpine:3.9")19                .withEnv("PATH", "/bin:/usr/bin:/sbin:/usr/sbin:/usr/local/bin:/usr/local/sbin")20                .withCommand("sh", "-c", "env | grep PATH")) {21            container.start();22            String containerLogs = container.getLogs();23            System.out.println(containerLogs);24        }25    }26}27package com.example;28import org.testcontainers.containers.GenericContainer;29public class App {30    public static void main(String[] args) {31        try (GenericContainer container = new GenericContainer("alpine:3.9")32                .withEnv("PATH", "/bin:/usr/bin:/sbin:/usr/sbin:/usr/local/bin:/usr/local/sbin")33                .withCommand("sh", "-c", "env | grep PATH")34                .withEnv("PATH", "/bin:/usr/bin")) {35            container.start();36            String containerLogs = container.getLogs();37            System.out.println(containerLogs);38        }39    }40}

withEnv

Using AI Code Generation

1import org.testcontainers.containers.GenericContainer;2public class EnvVarTest {3    public static void main(String[] args) {4        GenericContainer container = new GenericContainer("alpine:3.8")5                .withEnv("ENV_VAR", "test")6                .withCommand("sh", "-c", "env");7        container.start();8        String logs = container.getLogs();9        System.out.println(logs);10        container.stop();11    }12}

withEnv

Using AI Code Generation

1import org.testcontainers.containers.GenericContainer;2public class TestContainers {3    public static void main(String[] args) {4        GenericContainer container = new GenericContainer("myimage")5            .withEnv("TEST_ENV", "test")6            .withEnv("TEST_ENV_2", "test2");7        container.start();8        System.out.println("Container started");9        container.stop();10    }11}

withEnv

Using AI Code Generation

1import org.testcontainers.containers.GenericContainer;2public class TestContainer {3    public static void main(String[] args) {4        try (GenericContainer container = new GenericContainer("ubuntu:latest")5                .withEnv("MY_ENV_VAR1", "HELLO")6                .withEnv("MY_ENV_VAR2", "WORLD")) {7            container.start();8            System.out.println(container.getLogs());9        }10    }11}12import org.testcontainers.containers.GenericContainer;13public class TestContainer {14    public static void main(String[] args) {15        try (GenericContainer container = new GenericContainer("ubuntu:latest")16                .withEnv("MY_ENV_VAR1", "HELLO")17                .withEnv("MY_ENV_VAR2", "WORLD")) {18            container.start();19            System.out.println(container.getLogs());20        }21    }22}23import org.testcontainers.containers.GenericContainer;24public class TestContainer {25    public static void main(String[] args) {26        try (GenericContainer container = new GenericContainer("ubuntu:latest")

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.