KaneAI - World’s First E2E Software Testing Agent.Signup for Private Beta Join TestMu Conference

How to use PrestoContainer method of org.testcontainers.containers.PrestoContainer class

Best Testcontainers-java code snippet using org.testcontainers.containers.PrestoContainer.PrestoContainer

Source:PrestoConfiguration.java

1package net.boeckling.turbocontainers.modules.jdbc;2import static java.time.temporal.ChronoUnit.SECONDS;3import java.time.Duration;4import net.boeckling.turbocontainers.api.init.Init;5import org.testcontainers.containers.PrestoContainer;6import org.testcontainers.containers.wait.strategy.LogMessageWaitStrategy;7import org.testcontainers.containers.wait.strategy.WaitStrategy;8public class PrestoConfiguration {9  // bugfix for broken wait strategy10  private static final WaitStrategy WAIT_STRATEGY = new LogMessageWaitStrategy()11    .withRegEx(".*======== SERVER STARTED ========.*")12    .withStartupTimeout(Duration.of(60, SECONDS));13  public static final PrestoContainer<?> CONTAINER = Init14    .container(createContainer())15    .with(16      ctx -> {17        try {18          // avoid "No nodes available to run the query" error19          Thread.sleep(5000);20        } catch (InterruptedException e) {21          e.printStackTrace();22        }23        ctx.initScript("db/migration/V1__init.sql");24      }25    );26  private static PrestoContainer<?> createContainer() {27    PrestoContainer<?> presto = new PrestoContainer<>(28      PrestoContainer.IMAGE + ":latest"29    )30      .withDatabaseName("memory")31      .withCommand(32        "/usr/lib/presto/bin/run-presto",33        "-Dsql.default-catalog=memory",34        "-Dsql.default-schema=default"35      );36    presto.setWaitStrategy(WAIT_STRATEGY);37    return presto;38  }39}...

Source:PrestoContainerProvider.java

...3import org.testcontainers.utility.DockerImageName;4/**5 * Factory for Presto containers.6 */7public class PrestoContainerProvider extends JdbcDatabaseContainerProvider {8    public static final String USER_PARAM = "user";9    public static final String PASSWORD_PARAM = "password";10    @Override11    public boolean supports(String databaseType) {12        return databaseType.equals(PrestoContainer.NAME);13    }14    @Override15    public JdbcDatabaseContainer newInstance() {16        return newInstance(PrestoContainer.DEFAULT_TAG);17    }18    @Override19    public JdbcDatabaseContainer newInstance(String tag) {20        return new PrestoContainer(DockerImageName.parse(PrestoContainer.IMAGE).withTag(tag));21    }22    @Override23    public JdbcDatabaseContainer newInstance(ConnectionUrl connectionUrl) {24        return newInstanceFromConnectionUrl(connectionUrl, USER_PARAM, PASSWORD_PARAM);25    }26}...

Source:PrestoContainerTester.java

2 * 3 */4package com.force.formula.sql;5import java.io.IOException;6import org.testcontainers.containers.PrestoContainer;7/**8 * Presto tester that uses a container.  9 * @author stamm10 */11@SuppressWarnings("deprecation") // Presto is replaced with Trino, but Athena is based on Presto for now.12public class PrestoContainerTester extends PrestoStyleContainerTester<PrestoContainer<?>> {13	/**14	 * @throws IOException15	 */16	public PrestoContainerTester() throws IOException {17	}18	@Override19	public String getDbTypeName() {20		return "presto";21	}22	@Override23	protected PrestoContainer<?> constructDb() throws IOException {24		return new PrestoContainer<>("ghcr.io/trinodb/presto");25	}26}...

PrestoContainer

Using AI Code Generation

1import org.testcontainers.containers.PrestoContainer;2import org.testcontainers.containers.output.Slf4jLogConsumer;3import org.testcontainers.utility.DockerImageName;4import org.slf4j.Logger;5import org.slf4j.LoggerFactory;6public class PrestoJdbcExample {7    private static final Logger LOGGER = LoggerFactory.getLogger(PrestoJdbcExample.class);8    public static void main(String[] args) throws Exception {9        try (PrestoContainer presto = new PrestoContainer(DockerImageName.parse("prestosql/presto:latest"))) {10            presto.withLogConsumer(new Slf4jLogConsumer(LOGGER));11            presto.start();12            LOGGER.info("Presto JDBC URL is {}", presto.getJdbcUrl());13            LOGGER.info("Presto CLI is {}", presto.getPrestoCli());14        }15    }16}17import org.testcontainers.containers.PrestoContainer;18import org.testcontainers.containers.output.Slf4jLogConsumer;19import org.testcontainers.utility.DockerImageName;20import org.slf4j.Logger;21import org.slf4j.LoggerFactory;22public class PrestoJdbcExample {23    private static final Logger LOGGER = LoggerFactory.getLogger(PrestoJdbcExample.class);24    public static void main(String[] args) throws Exception {25        try (PrestoContainer presto = new PrestoContainer(DockerImageName.parse("prestosql/presto:latest"))) {26            presto.withLogConsumer(new Slf4jLogConsumer(LOGGER));27            presto.start();28            LOGGER.info("Presto JDBC URL is {}", presto.getJdbcUrl());29            LOGGER.info("Presto CLI is {}", presto.getPrestoCli());30        }31    }32}33import org.testcontainers.containers.PrestoContainer;34import org.testcontainers.containers.output.Slf4jLogConsumer;35import org.testcontainers.utility.DockerImageName;36import org.slf4j.Logger;37import org.slf4j.LoggerFactory;38public class PrestoJdbcExample {39    private static final Logger LOGGER = LoggerFactory.getLogger(PrestoJdbcExample.class);40    public static void main(String[] args) throws Exception {41        try (PrestoContainer

PrestoContainer

Using AI Code Generation

1import org.testcontainers.containers.PrestoContainer;2public class PrestoContainerExample {3    public static void main(String[] args) {4        try (PrestoContainer presto = new PrestoContainer()) {5            presto.start();6            System.out.println(presto.getJdbcUrl());7        }8    }9}10import org.testcontainers.containers.PrestoContainer;11public class PrestoContainerExample {12    public static void main(String[] args) {13        try (PrestoContainer presto = new PrestoContainer()) {14            presto.start();15            System.out.println(presto.getJdbcUrl());16        }17    }18}19import org.testcontainers.containers.PrestoContainer;20public class PrestoContainerExample {21    public static void main(String[] args) {22        try (PrestoContainer presto = new PrestoContainer()) {23            presto.start();24            System.out.println(presto.getJdbcUrl());25        }26    }27}28import org.testcontainers.containers.PrestoContainer;29public class PrestoContainerExample {30    public static void main(String[] args) {31        try (PrestoContainer presto = new PrestoContainer()) {32            presto.start();33            System.out.println(presto.getJdbcUrl());34        }35    }36}37import org.testcontainers.containers.PrestoContainer;38public class PrestoContainerExample {39    public static void main(String[] args) {40        try (PrestoContainer presto = new PrestoContainer()) {41            presto.start();42            System.out.println(presto.getJdbcUrl());43        }44    }45}46import org.testcontainers.containers.PrestoContainer;47public class PrestoContainerExample {48    public static void main(String[] args) {49        try (Prest

PrestoContainer

Using AI Code Generation

1import org.testcontainers.containers.PrestoContainer;2import org.testcontainers.containers.output.Slf4jLogConsumer;3import org.slf4j.Logger;4import org.slf4j.LoggerFactory;5public class Main {6    public static void main(String[] args) {7        Logger logger = LoggerFactory.getLogger(Main.class);8        PrestoContainer prestoContainer = new PrestoContainer();9        prestoContainer.start();10        prestoContainer.followOutput(new Slf4jLogConsumer(logger));11        System.out.println("PrestoContainer started with JDBC URL: " + prestoContainer.getJdbcUrl());12    }13}14import org.testcontainers.containers.PrestoContainer;15import org.testcontainers.containers.output.Slf4jLogConsumer;16import org.slf4j.Logger;17import org.slf4j.LoggerFactory;18public class Main {19    public static void main(String[] args) {20        Logger logger = LoggerFactory.getLogger(Main.class);21        PrestoContainer prestoContainer = new PrestoContainer("prestosql/presto:latest");22        prestoContainer.start();23        prestoContainer.followOutput(new Slf4jLogConsumer(logger));24        System.out.println("PrestoContainer started with JDBC URL: " + prestoContainer.getJdbcUrl());25    }26}27import org.testcontainers.containers.PrestoContainer;28import org.testcontainers.containers.output.Slf4jLogConsumer;29import org.slf4j.Logger;30import org.slf4j.LoggerFactory;31public class Main {32    public static void main(String[] args) {33        Logger logger = LoggerFactory.getLogger(Main.class);34        PrestoContainer prestoContainer = new PrestoContainer("prestosql/presto:latest")35                .withConfigurationOverride("etc/catalog/jdbc.properties", "connector.name=jdbc");36        prestoContainer.start();37        prestoContainer.followOutput(new Slf4jLogConsumer(logger));38        System.out.println("PrestoContainer started with JDBC URL: " + prestoContainer.getJdbcUrl());39    }40}41import org.testcontainers.containers.PrestoContainer;42import org.testcontainers

PrestoContainer

Using AI Code Generation

1import org.testcontainers.containers.PrestoContainer;2import java.sql.Connection;3import java.sql.DriverManager;4import java.sql.ResultSet;5import java.sql.SQLException;6import java.sql.Statement;7import java.util.logging.Level;8import java.util.logging.Logger;9public class PrestoContainerTest {10    private static final Logger LOGGER = Logger.getLogger(PrestoContainerTest.class.getName());11    public static void main(String[] args) {12        try (PrestoContainer prestoContainer = new PrestoContainer()) {13            prestoContainer.start();14            Connection connection = DriverManager.getConnection(prestoContainer.getJdbcUrl(), prestoContainer.getUsername(), prestoContainer.getPassword());15            Statement statement = connection.createStatement();16            ResultSet rs = statement.executeQuery("SELECT 1");17            while (rs.next()) {18                LOGGER.log(Level.INFO, "Result: {0}", rs.getString(1));19            }20        } catch (SQLException ex) {21            LOGGER.log(Level.SEVERE, null, ex);22        }23    }24}25import org.testcontainers.containers.PrestoContainer;26import java.sql.Connection;27import java.sql.DriverManager;28import java.sql.ResultSet;29import java.sql.SQLException;30import java.sql.Statement;31import java.util.logging.Level;32import java.util.logging.Logger;33public class PrestoContainerTest {34    private static final Logger LOGGER = Logger.getLogger(PrestoContainerTest.class.getName());35    public static void main(String[] args) {36        try (PrestoContainer prestoContainer = new PrestoContainer()) {37            prestoContainer.start();38            Connection connection = DriverManager.getConnection(prestoContainer.getJdbcUrl(), prestoContainer.getUsername(), prestoContainer.getPassword());39            Statement statement = connection.createStatement();40            ResultSet rs = statement.executeQuery("SELECT 1");41            while (rs.next()) {42                LOGGER.log(Level.INFO, "Result: {0}", rs.getString(1));43            }44        } catch (SQLException ex) {45            LOGGER.log(Level.SEVERE, null, ex);46        }47    }48}49import org.testcontainers.containers.PrestoContainer;50import java.sql.Connection;51import java.sql.DriverManager;52import java.sql.ResultSet;53import java.sql.SQLException;54import java.sql.Statement;55import java.util.logging.Level;56import java.util.logging.Logger;57public class PrestoContainerTest {

PrestoContainer

Using AI Code Generation

1import org.testcontainers.containers.PrestoContainer;2public class PrestoContainerTest {3    public static void main(String[] args) {4        try (PrestoContainer presto = new PrestoContainer()) {5            presto.start();6            System.out.println(presto.getJdbcUrl());7        }8    }9}10Method Description PrestoContainer() Constructor to initialize the PrestoContainer class. PrestoContainer(DockerImageName dockerImageName) Constructor to initialize the PrestoContainer class with the specified Docker image. PrestoContainer(String dockerImageName) Constructor to initialize the PrestoContainer class with the specified Docker image. getJdbcUrl() Returns the JDBC URL to connect to the running instance of the Presto. getJdbcUrl(String username, String password) Returns the JDBC URL to connect to the running instance of the Presto with the specified username and password. getJdbcDriverInstance() Returns the JDBC driver instance for the running instance of the Presto. getJdbcDriverClass() Returns the JDBC driver class name for the running instance of the Presto. withConfigurationOverride(String configPath, String configContent) Overrides the default configuration of the Presto with the specified configuration file and content. withConfigurationOverride(String configPath, Path configContent) Overrides the default configuration of the Presto with the specified configuration file and content. withConfigurationOverride(String configPath, Supplier<String> configContent) Overrides the default configuration of the Presto with the specified configuration file and content. withServerConfig(String configPath, String configContent) Overrides the default server configuration of the Presto with the specified configuration file and content. withServerConfig(String configPath, Path configContent) Overrides the default server configuration of the Presto with the specified configuration file and content. withServerConfig(String configPath, Supplier<String> configContent) Overrides the default server configuration of the Presto with the specified configuration file and content. withCatalog(String catalog) Adds the specified catalog to the Presto. withCatalog(String catalog, Path catalogProperties) Adds the specified catalog to the Presto with the specified catalog properties. withCatalog(String catalog, Supplier<String> catalogProperties) Adds the specified catalog to the Presto with the specified catalog properties. withConnector(String connector) Adds the specified connector to the Presto. withConnector(String connector,

PrestoContainer

Using AI Code Generation

1import org.testcontainers.containers.PrestoContainer;2public class Example1 {3    public static void main(String[] args) {4        PrestoContainer prestoContainer = new PrestoContainer();5        prestoContainer.start();6        System.out.println("JDBC URL: " + prestoContainer.getJdbcUrl());7        System.out.println("HTTP URL: " + prestoContainer.getHttpUrl());8        prestoContainer.stop();9    }10}

PrestoContainer

Using AI Code Generation

1package org.testcontainers.containers;2import org.junit.jupiter.api.Test;3class PrestoContainerTest {4    void test() {5        try (PrestoContainer presto = new PrestoContainer()) {6            presto.start();7            System.out.println(presto.getJdbcUrl());8        }9    }10}11PrestoContainer class has a method called withConnectorConfig(String connectorName, String config) which can be used

PrestoContainer

Using AI Code Generation

1import org.testcontainers.containers.PrestoContainer;2public class PrestoContainerTest {3    public static void main(String[] args) {4        try (PrestoContainer prestoContainer = new PrestoContainer()) {5            prestoContainer.start();6            System.out.println("Presto Container Started");7            System.out.println("Presto JDBC URL: " + prestoContainer.getJdbcUrl());8            System.out.println("Presto JDBC User: " + prestoContainer.getUsername());9            System.out.println("Presto JDBC Password: " + prestoContainer.getPassword());10        }11    }12}

PrestoContainer

Using AI Code Generation

1package org.testcontainers.containers;2import org.testcontainers.containers.output.OutputFrame;3import org.testcontainers.containers.output.ToStringConsumer;4import org.testcontainers.containers.wait.strategy.Wait;5import org.testcontainers.utility.MountableFile;6import java.sql.Connection;7import java.sql.DriverManager;8import java.sql.ResultSet;9import java.sql.SQLException;10import java.sql.Statement;11import java.util.concurrent.TimeUnit;12import java.util.function.Consumer;13public class PrestoContainer extends GenericContainer<PrestoContainer> {14    public static final int PRESTO_PORT = 8080;15    public static final String PRESTO_DEFAULT_IMAGE_AND_TAG = "prestosql/presto:latest";16    public static final String PRESTO_CONFIG_LOCATION = "/etc/presto";17    private static final String PRESTO_CONFIG_FILE = "config.properties";18    private static final String PRESTO_JVM_CONFIG_FILE = "jvm.config";19    private static final String PRESTO_NODE_PROPERTIES_FILE = "node.properties";20    private static final String PRESTO_CATALOG_FILE = "catalog";21    private static final String PRESTO_CATALOG_LOCATION = PRESTO_CONFIG_LOCATION + "/catalog";22    private static final String PRESTO_CATALOG_RESOURCE_LOCATION = "/docker/presto-init.d/";23    private static final String PRESTO_CATALOG_RESOURCE_FILE = "tpch.properties";24    private static final String PRESTO_CATALOG_MOUNT_LOCATION = PRESTO_CATALOG_LOCATION + "/tpch.properties";25    private static final String PRESTO_QUERY_MAX_MEMORY = "query.max-memory";26    private static final String PRESTO_QUERY_MAX_MEMORY_PER_NODE = "query.max-memory-per-node";27    private static final String PRESTO_QUERY_MAX_TOTAL_MEMORY_PER_NODE = "query.max-total-memory-per-node";28    private static final String PRESTO_MEMORY_PER_NODE = "node-scheduler.max-pending-splits-per-node-per-stage";29    private static final String PRESTO_MEMORY_TOTAL_NODE = "node-scheduler.max-splits-per-node";30    private static final String PRESTO_CATALOG_MOUNT_RESOURCE_LOCATION = PRESTO_CATALOG_RESOURCE_LOCATION + PRESTO_CATALOG_RESOURCE_FILE;31    private static final String PRESTO_JVM_CONFIG_RESOURCE_LOCATION = "/docker/presto-init.d/jvm.config";32    private static final String PRESTO_CONFIG_RESOURCE_LOCATION = "/docker/presto-init.d/config.properties";

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.