Test your AI Agents with the all-new Agent to Agent Testing Platform.Learn More

How to use ConnectionUrl method of org.testcontainers.jdbc.ConnectionUrl class

Best Testcontainers-java code snippet using org.testcontainers.jdbc.ConnectionUrl.ConnectionUrl

Source:SharedContainerDatabaseDriver.java

...23import org.testcontainers.containers.JdbcDatabaseContainer;24import org.testcontainers.containers.JdbcDatabaseContainerProvider;25import org.testcontainers.delegate.DatabaseDelegate;26import org.testcontainers.ext.ScriptUtils;27import org.testcontainers.jdbc.ConnectionUrl;28import org.testcontainers.jdbc.JdbcDatabaseDelegate;29import org.testcontainers.shaded.org.apache.commons.io.IOUtils;30public class SharedContainerDatabaseDriver implements Driver  {31    private static Logger LOGGER = LoggerFactory.getLogger(SharedContainerDatabaseDriver.class);32    private static final Map<String, Set<Connection>> containerConnections = new ConcurrentHashMap<>();33    private static final Map<String, JdbcDatabaseContainer> jdbcUrlContainerCache = new ConcurrentHashMap<>();34    private static final Set<String> initializedScripts = ConcurrentHashMap.newKeySet();35    private static final String JDBC_WITH_TC_PREFIX = "jdbc:tc:";36    private static final String FILE_PATH_PREFIX = "file:";37    private static final String SQL_DROP_FLYWAY_TABLE_IF_EXISTS = "DROP TABLE IF EXISTS flyway_schema_history";38    private Driver delegate;39    static {40        try {41            LOGGER.info("About to register shared container driver (supporting jdbc:tc) ...");42            DriverManager.registerDriver(new SharedContainerDatabaseDriver());43            LOGGER.info("... success");44        } catch (SQLException e) {45            LOGGER.warn("Failed to register driver", e);46        }47    }48    static JdbcDatabaseContainer getContainer(String jdbcUrl) {49        LOGGER.info("About to fetch container with URL: {}", jdbcUrl);50        return jdbcUrlContainerCache.get(jdbcUrl);51    }52    @Override53    public boolean acceptsURL(String url) throws SQLException {54        return url.startsWith(JDBC_WITH_TC_PREFIX);55    }56    @Override57    public Connection connect(String url, Properties properties) throws SQLException {58        LOGGER.debug("Current cache size: {}", jdbcUrlContainerCache.size());59        if (!acceptsURL(url)) {60            return null;61        }62        ConnectionUrl connectionUrl = ConnectionUrl.newInstance(url);63        String queryString = connectionUrl.getQueryString().orElse("");64        LOGGER.debug("Checking cache for key: {} -> with query: {}", connectionUrl.getDatabaseType(), queryString);65        JdbcDatabaseContainer container = jdbcUrlContainerCache.get(connectionUrl.getDatabaseType());66        if (container == null) {67            LOGGER.debug("... not found -> creating new instance");68            Map<String, String> parameters = connectionUrl.getContainerParameters();69            ServiceLoader<JdbcDatabaseContainerProvider> databaseContainers = ServiceLoader.load(JdbcDatabaseContainerProvider.class);70            for (JdbcDatabaseContainerProvider candidateContainerType : databaseContainers) {71                LOGGER.debug("Probing candidate ({}) for database type: {}", candidateContainerType, connectionUrl.getDatabaseType());72                if (candidateContainerType.supports(connectionUrl.getDatabaseType())) {73                    LOGGER.info("Creating new instance with connection url: {} -> URL: {}", connectionUrl, connectionUrl.getUrl());74                    container = candidateContainerType.newInstance(connectionUrl);75                    container.withTmpFs(connectionUrl.getTmpfsOptions());76                    delegate = container.getJdbcDriverInstance();77                }78            }79            if (container == null) {80                throw new UnsupportedOperationException("Database name " + connectionUrl.getDatabaseType() + " not supported");81            }82            jdbcUrlContainerCache.put(connectionUrl.getDatabaseType(), container);83            container.setParameters(parameters);84            container.start();85            LOGGER.debug("... container started...");86        }87        Connection connection = container.createConnection(queryString);88        LOGGER.debug("Connection to container: {} -> URL {}", connection, connection.getMetaData().getURL());89        DatabaseDelegate databaseDelegate = new JdbcDatabaseDelegate(container, queryString);90        runInitScriptIfRequired(connectionUrl, databaseDelegate);91        runClearFlywayIfRequired(connection);92        runInitFunctionIfRequired(connectionUrl, connection);93        return wrapConnection(connection, container, connectionUrl);94    }95    @Override96    public DriverPropertyInfo[] getPropertyInfo(String url, Properties properties) throws SQLException {97        return this.delegate.getPropertyInfo(url, properties);98    }99    @Override100    public int getMajorVersion() {101        return this.delegate.getMajorVersion();102    }103    @Override104    public int getMinorVersion() {105        return this.delegate.getMinorVersion();106    }107    @Override108    public boolean jdbcCompliant() {109        return this.delegate.jdbcCompliant();110    }111    @Override112    public java.util.logging.Logger getParentLogger() throws SQLFeatureNotSupportedException {113        return this.delegate.getParentLogger();114    }115    public static void killContainers() {116        jdbcUrlContainerCache.values().forEach(JdbcDatabaseContainer::stop);117        jdbcUrlContainerCache.clear();118        containerConnections.clear();119    }120    public static void killContainer(String jdbcUrl) {121        JdbcDatabaseContainer container = jdbcUrlContainerCache.get(jdbcUrl);122        if (container != null) {123            container.stop();124            jdbcUrlContainerCache.remove(jdbcUrl);125            containerConnections.remove(container.getContainerId());126        }127    }128    private void runInitScriptIfRequired(final ConnectionUrl connectionUrl, DatabaseDelegate databaseDelegate) throws SQLException {129        if (connectionUrl.getInitScriptPath().isPresent()) {130            String initScriptPath = connectionUrl.getInitScriptPath().get();131            LOGGER.debug("About to execute script: {}", initScriptPath);132            if (initializedScripts.contains(initScriptPath)) {133                LOGGER.debug("... aborted, already executed");134                return;135            }136            LOGGER.debug("... script execution added to history");137            initializedScripts.add(initScriptPath);138            try {139                URL resource;140                if (initScriptPath.startsWith(FILE_PATH_PREFIX)) {141                    //relative workdir path142                    resource = new URL(initScriptPath);143                } else {144                    //classpath resource145                    resource = Thread.currentThread().getContextClassLoader().getResource(initScriptPath);146                }147                if (resource == null) {148                    LOGGER.warn("Could not load classpath init script: {}", initScriptPath);149                    throw new SQLException("Could not load classpath init script: " + initScriptPath + ". Resource not found.");150                }151                String sql = IOUtils.toString(resource, StandardCharsets.UTF_8);152                LOGGER.debug("Running script {}", sql);153                ScriptUtils.executeDatabaseScript(databaseDelegate, initScriptPath, sql);154            } catch (IOException e) {155                LOGGER.warn("Could not load classpath init script: {}", initScriptPath);156                throw new SQLException("Could not load classpath init script: " + initScriptPath, e);157            } catch (ScriptException e) {158                LOGGER.error("Error while executing init script: {}", initScriptPath, e);159                throw new SQLException("Error while executing init script: " + initScriptPath, e);160            }161        }162    }163    private void runClearFlywayIfRequired(final Connection connection) throws SQLException {164        PreparedStatement preparedStatement = connection.prepareStatement(SQL_DROP_FLYWAY_TABLE_IF_EXISTS);165        preparedStatement.execute();166    }167    private void runInitFunctionIfRequired(final ConnectionUrl connectionUrl, Connection connection) throws SQLException {168        if (connectionUrl.getInitFunction().isPresent()) {169            String className = connectionUrl.getInitFunction().get().getClassName();170            String methodName = connectionUrl.getInitFunction().get().getMethodName();171            try {172                Class<?> initFunctionClazz = Class.forName(className);173                Method method = initFunctionClazz.getMethod(methodName, Connection.class);174                method.invoke(null, connection);175            } catch (ClassNotFoundException | NoSuchMethodException | IllegalAccessException | InvocationTargetException e) {176                LOGGER.error("Error while executing init function: {}::{}", className, methodName, e);177                throw new SQLException("Error while executing init function: " + className + "::" + methodName, e);178            }179        }180    }181    private Connection wrapConnection(final Connection connection, final JdbcDatabaseContainer container, final ConnectionUrl connectionUrl) {182        final boolean isDaemon = connectionUrl.isInDaemonMode();183        Set<Connection> connections = containerConnections.computeIfAbsent(container.getContainerId(), k -> new HashSet<>());184        connections.add(connection);185        final Set<Connection> finalConnections = connections;186        return new SharedConnectionWrapper(connection, () -> {187            finalConnections.remove(connection);188            if (!isDaemon && finalConnections.isEmpty()) {189                container.stop();190                jdbcUrlContainerCache.remove(connectionUrl.getUrl());191            }192        });193    }194}...

Source:PgroongaContainerProvider.java

1package com.frogdevelopment.testcontainers.containers;2import org.testcontainers.containers.JdbcDatabaseContainer;3import org.testcontainers.containers.JdbcDatabaseContainerProvider;4import org.testcontainers.containers.PostgreSQLContainer;5import org.testcontainers.jdbc.ConnectionUrl;6import org.testcontainers.utility.DockerImageName;7/**8 * Factory for pgroonga container, which is PostgreSQL with groonga extension.9 * PGroonga makes PostgreSQL fast full text search platform for all languages!10 */11public class PgroongaContainerProvider extends JdbcDatabaseContainerProvider {12    private static final String NAME = "pgroonga";13    private static final String DEFAULT_TAG = "2.2.7-alpine-13-slim";14    private static final String DEFAULT_IMAGE = "groonga/pgroonga";15    public static final String USER_PARAM = "user";16    public static final String PASSWORD_PARAM = "password";17    @Override18    public boolean supports(String databaseType) {19        return databaseType.equals(NAME);20    }21    @Override22    public JdbcDatabaseContainer newInstance() {23        return newInstance(DEFAULT_TAG);24    }25    @Override26    public JdbcDatabaseContainer newInstance(String tag) {27        return new PostgreSQLContainer(DockerImageName.parse(DEFAULT_IMAGE + ":" + tag).asCompatibleSubstituteFor("postgres"));28    }29    @Override30    public JdbcDatabaseContainer newInstance(ConnectionUrl connectionUrl) {31        return newInstanceFromConnectionUrl(connectionUrl, USER_PARAM, PASSWORD_PARAM);32    }33}...

Source:QuestDbContainerProvider.java

1package io.questdb.testcontainers;2import org.testcontainers.containers.JdbcDatabaseContainer;3import org.testcontainers.containers.JdbcDatabaseContainerProvider;4import org.testcontainers.jdbc.ConnectionUrl;5public class QuestDbContainerProvider extends JdbcDatabaseContainerProvider {6    private static final String USER_PARAM = "user";7    private static final String PASSWORD_PARAM = "password";8    public QuestDbContainerProvider() {9    }10    public boolean supports(String databaseType) {11        return databaseType.equals("questdb");12    }13    public JdbcDatabaseContainer newInstance() {14        return this.newInstance("4.1.5");15    }16    public JdbcDatabaseContainer newInstance(String tag) {17        return new QuestDbContainer("questdb/questdb:" + tag);18    }19    public JdbcDatabaseContainer newInstance(ConnectionUrl connectionUrl) {20        return this.newInstanceFromConnectionUrl(connectionUrl, USER_PARAM, PASSWORD_PARAM);21    }22}...

ConnectionUrl

Using AI Code Generation

1import org.testcontainers.jdbc.ConnectionUrl;2import java.sql.Connection;3import java.sql.DriverManager;4import java.sql.SQLException;5public class 1 {6    public static void main(String[] args) throws SQLException {7        Connection connection = DriverManager.getConnection(ConnectionUrl.forContainer("mysql:8.0.22"));8        System.out.println(connection);9    }10}11import org.testcontainers.jdbc.ConnectionUrl;12import java.sql.Connection;13import java.sql.DriverManager;14import java.sql.SQLException;15public class 2 {16    public static void main(String[] args) throws SQLException {17        Connection connection = DriverManager.getConnection(ConnectionUrl.forContainer("mysql:8.0.22")18                .withDatabaseName("test_db")19                .withUsername("test_user")20                .withPassword("test_password")21                .build());22        System.out.println(connection);23    }24}25import org.testcontainers.jdbc.ConnectionUrl;26import java.sql.Connection;27import java.sql.DriverManager;28import java.sql.SQLException;29public class 3 {30    public static void main(String[] args) throws SQLException {31        Connection connection = DriverManager.getConnection(ConnectionUrl.forContainer("mysql:8.0.22")32                .withDatabaseName("test_db")33                .withUsername("test_user")34                .withPassword("test_password")35                .withInitScript("classpath:init.sql")36                .build());37        System.out.println(connection);38    }39}40import org.testcontainers.jdbc.ConnectionUrl;41import java.sql.Connection;42import java.sql.DriverManager;43import java.sql.SQLException;44public class 4 {45    public static void main(String[] args) throws SQLException {46        Connection connection = DriverManager.getConnection(ConnectionUrl.forContainer("mysql:8.0.22")47                .withDatabaseName("test_db")48                .withUsername("test_user")49                .withPassword("test_password")50                .withInitScript("classpath:init.sql")51                .withInitScript("classpath:init2.sql")52                .build());53        System.out.println(connection);54    }55}56import org.testcontainers.jdbc.ConnectionUrl;57import java.sql.Connection;58import java.sql

ConnectionUrl

Using AI Code Generation

1import org.testcontainers.jdbc.ConnectionUrl;2public class 1 {3    public static void main(String[] args) {4        System.out.println("connectionUrl.getJdbcUrl() = " + connectionUrl.getJdbcUrl());5        System.out.println("connectionUrl.getDatabaseType() = " + connectionUrl.getDatabaseType());6        System.out.println("connectionUrl.getInitScriptPath() = " + connectionUrl.getInitScriptPath());7        System.out.println("connectionUrl.getInitFunction() = " + connectionUrl.getInitFunction());8    }9}10connectionUrl.getDatabaseType() = mysql11connectionUrl.getInitScriptPath() = file:./src/test/resources/sql/init.sql12connectionUrl.getInitFunction() = org.testcontainers.jdbc.ContainerDatabaseDriverTest::initFunction13import org.testcontainers.jdbc.ContainerDatabaseDriver;14import org.testcontainers.jdbc.ConnectionUrl;15import java.sql.Connection;16import java.sql.Driver;17import java.sql.DriverManager;18import java.sql.SQLException;19import java.util.Properties;20public class 2 {21    public static void main(String[] args) throws SQLException {22        Driver driver = new ContainerDatabaseDriver();23        Properties properties = new Properties();24        Connection connection = driver.connect(connectionUrl.getJdbcUrl(), properties);25        System.out.println("connection.getMetaData().getURL() = " + connection.getMetaData().getURL());26        System.out.println("connection.getMetaData().getUserName() = " + connection.getMetaData().getUserName());27    }28}29connection.getMetaData().getUserName() = root30import

ConnectionUrl

Using AI Code Generation

1import org.testcontainers.jdbc.ConnectionUrl;2public class 1 {3    public static void main(String[] args) {4        System.out.println(connectionUrl.getJdbcUrl());5    }6}7import org.testcontainers.jdbc.ConnectionUrl;8public class 2 {9    public static void main(String[] args) {10        System.out.println(connectionUrl.getInitScriptPath());11    }12}13import org.testcontainers.jdbc.ConnectionUrl;14public class 3 {15    public static void main(String[] args) {16        System.out.println(connectionUrl.getDriverClassName());17    }18}19import org.testcontainers.jdbc.ConnectionUrl;20public class 4 {21    public static void main(String[] args) {22        System.out.println(connectionUrl.getDriverConfiguration().getDriverClassName());23    }24}25import org.testcontainers.jdbc.ConnectionUrl;26public class 5 {27    public static void main(String[] args) {28        System.out.println(connectionUrl.getDriverConfiguration().getDatabaseType());29    }30}

ConnectionUrl

Using AI Code Generation

1import org.testcontainers.jdbc.ConnectionUrl;2public class TestContainer {3public static void main(String[] args) {4System.out.println(connectionUrl.getJdbcUrl());5}6}

ConnectionUrl

Using AI Code Generation

1import org.testcontainers.jdbc.ConnectionUrl;2import java.sql.Connection;3import java.sql.DriverManager;4import java.sql.ResultSet;5import java.sql.Statement;6import java.sql.SQLException;7public class TestContainersJDBCConnectionUrl {8    public static void main(String[] args) throws SQLException {9        Connection connection = DriverManager.getConnection(connectionUrl.toString(), connectionUrl.getUsername(), connectionUrl.getPassword());10        Statement statement = connection.createStatement();11        ResultSet resultSet = statement.executeQuery("SELECT 1");12        while (resultSet.next()) {13            System.out.println(resultSet.getInt(1));14        }15    }16}17import org.testcontainers.jdbc.ConnectionUrl;18import java.sql.Connection;19import java.sql.DriverManager;20import java.sql.ResultSet;21import java.sql.Statement;22import java.sql.SQLException;23public class TestContainersJDBCConnectionUrl {24    public static void main(String[] args) throws SQLException {25        Connection connection = DriverManager.getConnection(connectionUrl.toString(), connectionUrl.getUsername(), connectionUrl.getPassword());26        Statement statement = connection.createStatement();27        ResultSet resultSet = statement.executeQuery("SELECT 1");28        while (resultSet.next()) {29            System.out.println(resultSet.getInt(1));30        }31    }32}

ConnectionUrl

Using AI Code Generation

1package org.testcontainers.jdbc;2import java.sql.Connection;3import java.sql.DriverManager;4import java.sql.SQLException;5import java.sql.Statement;6public class ConnectionUrl {7    public static void main(String[] args) throws SQLException {8        Statement statement = connection.createStatement();9        statement.executeUpdate("INSERT INTO person (name, age) VALUES ('name', 25)");10        statement.close();11        connection.close();12    }13}

ConnectionUrl

Using AI Code Generation

1import java.sql.Connection;2import java.sql.DriverManager;3import java.sql.SQLException;4import java.sql.Statement;5import org.testcontainers.containers.JdbcDatabaseContainer;6import org.testcontainers.containers.MySQLContainer;7import org.testcontainers.jdbc.ConnectionUrl;8public class TestContainerConnectionUrl {9    public static void main(String[] args) throws SQLException {10        JdbcDatabaseContainer<?> container = new MySQLContainer<>()11                .withDatabaseName("test")12                .withUsername("test")13                .withPassword("test");14        container.start();15        String containerJdbcUrl = ConnectionUrl.getJdbcUrl("com.mysql.jdbc.Driver", container.getContainerIpAddress(), container.getFirstMappedPort(), "test");16        System.out.println("JDBC URL for the container is " + containerJdbcUrl);17        Connection connection = DriverManager.getConnection(containerJdbcUrl, "test", "test");18        Statement statement = connection.createStatement();19        statement.executeUpdate("CREATE TABLE PERSON (id INTEGER, name VARCHAR(255))");20        statement.executeUpdate("INSERT INTO PERSON VALUES (1, 'test')");21        statement.close();22        connection.close();23        container.stop();24    }25}

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.