Join the 1-day Testing & QA Summit featuring 15+ Expert Speakers.Register for FREE! Join TestMu Conference

How to use JdbcDatabaseDelegate class of org.testcontainers.jdbc package

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

Source:MysqlTestContainer.java

...6import org.slf4j.LoggerFactory;7import org.testcontainers.containers.MySQLContainer;8import org.testcontainers.containers.output.Slf4jLogConsumer;9import org.testcontainers.ext.ScriptUtils;10import org.testcontainers.jdbc.JdbcDatabaseDelegate;11import org.testcontainers.shaded.org.apache.commons.io.IOUtils;12import org.testcontainers.utility.DockerImageName;1314import com.github.dockerjava.api.model.ExposedPort;15import com.github.dockerjava.api.model.HostConfig;16import com.github.dockerjava.api.model.PortBinding;17import com.github.dockerjava.api.model.Ports;1819import lombok.SneakyThrows;20import lombok.extern.slf4j.Slf4j;2122@Slf4j23public class MysqlTestContainer extends GenericTestContainer<MySQLContainer<?>> {2425	private static final int CONTAINER_MAPPED_PORT = MySQLContainer.MYSQL_PORT;26	private static final String INIT_SCRIPT_PATH = "mysql/mysql-create-objects.sql";27	private static final String RESET_SCRIPT_PATH = "mysql/mysql-reset.sql";28	29	public MysqlTestContainer(String mysqlDockerImage, String dbName, String mysqlUser, String mysqlPassword) {30		this(mysqlDockerImage, dbName, RANDOM_PORT, mysqlUser, mysqlPassword);31	}32	33	public MysqlTestContainer(String mysqlDockerImage, String dbName, int mysqlPort, String mysqlUser, String mysqlPassword) {34		super("MySQL");35		MySQLContainer<?> container = buildContainer(mysqlDockerImage, dbName, mysqlPort, mysqlUser, mysqlPassword);36		setContainer(container);37	}38	39	@SuppressWarnings("resource") // Resource closed by "stop()"40	private MySQLContainer<?> buildContainer(String mysqlDockerImage, String dbName, int mysqlPort, String mysqlUser, String mysqlPassword) {41		MySQLContainer<?> container = (MySQLContainer<?>) new MySQLContainer<>(DockerImageName.parse(mysqlDockerImage))42			.withLogConsumer(new Slf4jLogConsumer(LoggerFactory.getLogger("testcontainers.mysql")))43			.withDatabaseName(dbName)44			.withUsername(mysqlUser)45			.withPassword(mysqlPassword)46			.withInitScript(INIT_SCRIPT_PATH);47		if (!isRandomPort(mysqlPort)) {48			container.withCreateContainerCmdModifier(cmd -> cmd.withHostConfig(49				new HostConfig().withPortBindings(new PortBinding(Ports.Binding.bindPort(mysqlPort), new ExposedPort(CONTAINER_MAPPED_PORT)))));50		}51		return container;52	}5354	@Override55	public void resetContainerData() {56		LOGGER.info("Resetting MySQL data...");57		executeSqlScript(RESET_SCRIPT_PATH);58	}59	60	@SneakyThrows61	public void executeSqlScript(String scriptPath) {62		JdbcDatabaseDelegate jdbcDatabaseDelegate = new JdbcDatabaseDelegate(getContainer(), "");63		URL resource = MysqlTestContainer.class.getClassLoader().getResource(scriptPath);64		String scripts = IOUtils.toString(resource, StandardCharsets.UTF_8);65		ScriptUtils.executeDatabaseScript(jdbcDatabaseDelegate, scriptPath, scripts);66	}67	68	public String getJdbcUrl() {69		return "jdbc:mysql://" + getHost() + ":" + getPort() + "/" + getContainer().getDatabaseName();70	}71
...

Source:AbstractIntegrationTestConfig.java

...6import org.springframework.test.context.DynamicPropertyRegistry;7import org.springframework.test.context.DynamicPropertySource;8import org.testcontainers.containers.MySQLContainer;9import org.testcontainers.ext.ScriptUtils;10import org.testcontainers.jdbc.JdbcDatabaseDelegate;11@ActiveProfiles("test")12@TestMethodOrder(MethodOrderer.OrderAnnotation.class)13@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)14public abstract class AbstractIntegrationTestConfig15{16    private static final MySQLContainer<?> mysql;17    static18    {19        mysql = new MySQLContainer<>("mysql:5.7")20                .withDatabaseName("testDatabase")21                .withUsername("root")22                .withPassword("")23                .withReuse(true);24        mysql.start();25        JdbcDatabaseDelegate jdbcDatabaseDelegate = new JdbcDatabaseDelegate(mysql, "");26        ScriptUtils.runInitScript(jdbcDatabaseDelegate,"data/create-db.sql");27        ScriptUtils.runInitScript(jdbcDatabaseDelegate,"data/truncate-db.sql");28        ScriptUtils.runInitScript(jdbcDatabaseDelegate, "data/insert-data.sql");29    }30    @DynamicPropertySource31    public static void setDatasourceProperties(final DynamicPropertyRegistry registry)32    {33        registry.add("spring.datasource.url", mysql::getJdbcUrl);34        registry.add("spring.datasource.password", mysql::getPassword);35        registry.add("spring.datasource.username", mysql::getUsername);36    }37}...

Source:FakeDbTest.java

2import org.springframework.test.context.DynamicPropertyRegistry;3import org.springframework.test.context.DynamicPropertySource;4import org.testcontainers.containers.MySQLContainer;5import org.testcontainers.ext.ScriptUtils;6import org.testcontainers.jdbc.JdbcDatabaseDelegate;7import org.testcontainers.junit.jupiter.Testcontainers;8@Testcontainers9public class FakeDbTest {10    static final MySQLContainer DATABASE = new MySQLContainer();11    static {12        DATABASE.start();13        ScriptUtils.runInitScript(new JdbcDatabaseDelegate(DATABASE,""),14                "ddl.sql");15    }16    @DynamicPropertySource17    static void databaseProperties(DynamicPropertyRegistry registry) {18        registry.add("spring.datasource.url", DATABASE::getJdbcUrl);19        registry.add("spring.datasource.username", DATABASE::getUsername);20        registry.add("spring.datasource.password", DATABASE::getPassword);21    }22}...

JdbcDatabaseDelegate

Using AI Code Generation

1import org.testcontainers.jdbc.JdbcDatabaseDelegate;2import java.sql.Connection;3import java.sql.DriverManager;4import java.sql.SQLException;5import java.sql.Statement;6public class 1 {7    public static void main(String[] args) throws SQLException {8        Statement statement = connection.createStatement();9        statement.execute("SELECT 1");10        connection.close();11    }12}13import org.testcontainers.jdbc.JdbcDatabaseDelegate;14import java.sql.Connection;15import java.sql.DriverManager;16import java.sql.SQLException;17import java.sql.Statement;18public class 2 {19    public static void main(String[] args) throws SQLException {20        Statement statement = connection.createStatement();21        statement.execute("SELECT 1");22        connection.close();23    }24}25import org.testcontainers.jdbc.JdbcDatabaseDelegate;26import java.sql.Connection;27import java.sql.DriverManager;28import java.sql.SQLException;29import java.sql.Statement;30public class 3 {31    public static void main(String[] args) throws SQLException {32        Statement statement = connection.createStatement();33        statement.execute("SELECT 1");34        connection.close();35    }36}37import org.testcontainers.jdbc.JdbcDatabaseDelegate;38import java.sql.Connection;39import java.sql.DriverManager;40import java.sql.SQLException;41import java.sql.Statement;42public class 4 {43    public static void main(String[] args) throws

JdbcDatabaseDelegate

Using AI Code Generation

1import org.testcontainers.jdbc.JdbcDatabaseDelegate;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(jdbcUrl, "username", "password");8        JdbcDatabaseDelegate delegate = new JdbcDatabaseDelegate(connection, "postgresql");9        delegate.execute("SELECT * FROM test");10    }11}12import org.testcontainers.jdbc.JdbcDatabaseContainer;13import java.sql.Connection;14import java.sql.DriverManager;15import java.sql.SQLException;16public class 2 {17    public static void main(String[] args) throws SQLException {18        Connection connection = DriverManager.getConnection(container.getJdbcUrl(), container.getUsername(), container.getPassword());19        connection.createStatement().execute("SELECT * FROM test");20    }21}22import org.testcontainers.jdbc.JdbcDatabaseContainer;23import java.sql.Connection;24import java.sql.DriverManager;25import java.sql.SQLException;26public class 3 {27    public static void main(String[] args) throws SQLException {28        Connection connection = DriverManager.getConnection(container.getJdbcUrl(), container.getUsername(), container.getPassword());29        connection.createStatement().execute("SELECT * FROM test");30    }31}32import org.testcontainers.jdbc.JdbcDatabaseContainer;33import java.sql.Connection;34import java.sql.DriverManager;35import java.sql.SQLException;36public class 4 {37    public static void main(String[] args) throws SQLException {38        Connection connection = DriverManager.getConnection(container.getJdbcUrl(), container.getUsername(), container.getPassword());39        connection.createStatement().execute("SELECT * FROM test");40    }41}

JdbcDatabaseDelegate

Using AI Code Generation

1import org.testcontainers.jdbc.JdbcDatabaseDelegate;2import org.testcontainers.jdbc.ContainerDatabaseDriver;3public class 1 {4    public static void main(String[] args) {5        JdbcDatabaseDelegate delegate = new JdbcDatabaseDelegate(ContainerDatabaseDriver.instance());6        delegate.execute("CREATE TABLE users (id int, name varchar(255))");7        delegate.execute("INSERT INTO users VALUES (1, 'test')");8    }9}10import org.testcontainers.jdbc.JdbcDatabaseDelegate;11import org.testcontainers.jdbc.ContainerDatabaseDriver;12public class 2 {13    public static void main(String[] args) {14        JdbcDatabaseDelegate delegate = new JdbcDatabaseDelegate(ContainerDatabaseDriver.instance());15        delegate.execute("CREATE TABLE users (id int, name varchar(255))");16        delegate.execute("INSERT INTO users VALUES (1, 'test')");17    }18}

JdbcDatabaseDelegate

Using AI Code Generation

1import java.sql.Connection;2import java.sql.ResultSet;3import java.sql.Statement;4import org.testcontainers.jdbc.ContainerDatabaseDriver;5public class JdbcDatabaseDelegateExample {6    public static void main(String[] args) throws Exception {7        ContainerDatabaseDriver containerDatabaseDriver = new ContainerDatabaseDriver();8        Statement statement = connection.createStatement();9        ResultSet resultSet = statement.executeQuery("select * from table");10        while (resultSet.next()) {11            System.out.println(resultSet.getString(1));12        }13    }14}15import java.sql.Connection;16import java.sql.ResultSet;17import java.sql.Statement;18import org.testcontainers.jdbc.ContainerDatabaseDriver;19public class JdbcDatabaseDelegateExample {20    public static void main(String[] args) throws Exception {21        ContainerDatabaseDriver containerDatabaseDriver = new ContainerDatabaseDriver();22        Statement statement = connection.createStatement();23        ResultSet resultSet = statement.executeQuery("select * from table");24        while (resultSet.next()) {25            System.out.println(resultSet.getString(1));26        }27    }28}29import static org.junit.Assert.assertEquals;30import java.sql.Connection;31import java.sql.ResultSet;32import java.sql.SQLException;33import java.sql.Statement;34import org.junit.After;35import org.junit.Before;36import org.junit.Test

JdbcDatabaseDelegate

Using AI Code Generation

1import org.testcontainers.jdbc.JdbcDatabaseDelegate;2import org.testcontainers.jdbc.JdbcDatabaseContainer;3import java.sql.Connection;4import java.sql.DriverManager;5import java.sql.SQLException;6import java.sql.Statement;7import org.testcontainers.containers.MySQLContainer;8import org.testcontainers.containers.JdbcDatabaseContainer;9public class Test {10    public static void main(String[] args) throws ClassNotFoundException, SQLException {11        Class.forName("org.testcontainers.jdbc.ContainerDatabaseDriver");12        JdbcDatabaseContainer container = new MySQLContainer();13        container.start();14        Connection connection = DriverManager.getConnection(container.getJdbcUrl(), container.getUsername(), container.getPassword());15        Statement statement = connection.createStatement();16        statement.execute("CREATE TABLE foo (bar INT)");17        statement.execute("INSERT INTO foo VALUES (42)");18        statement.execute("SELECT * FROM foo");19        container.stop();20    }21}22import org.testcontainers.jdbc.JdbcDatabaseDelegate;23import org.testcontainers.jdbc.JdbcDatabaseContainer;24import java.sql.Connection;25import java.sql.DriverManager;26import java.sql.SQLException;27import java.sql.Statement;28import org.testcontainers.containers.MySQLContainer;29import org.testcontainers.containers.JdbcDatabaseContainer;30public class Test {31    public static void main(String[] args) throws ClassNotFoundException, SQLException {32        Class.forName("org.testcontainers.jdbc.ContainerDatabaseDriver");33        JdbcDatabaseContainer container = new MySQLContainer();34        container.start();35        Connection connection = DriverManager.getConnection(container.getJdbcUrl(), container.getUsername(), container.getPassword());36        Statement statement = connection.createStatement();37        statement.execute("CREATE TABLE foo (bar INT)");38        statement.execute("INSERT INTO foo VALUES (42)");39        statement.execute("SELECT * FROM foo");40        container.stop();41    }42}43    at Test.main(Test.java:

JdbcDatabaseDelegate

Using AI Code Generation

1import org.testcontainers.jdbc.JdbcDatabaseDelegate;2import java.sql.Connection;3import java.sql.SQLException;4import java.sql.Statement;5import java.util.Properties;6import java.util.concurrent.TimeUnit;7import org.testcontainers.containers.JdbcDatabaseContainer;8import org.testcontainers.containers.PostgreSQLContainer;9import org.testcontainers.jdbc.ConnectionUrl;10import org.testcontainers.jdbc.ContainerDatabaseDriver;11import org.testcontainers.jdbc.ContainerDatabaseDriverDelegate;12import org.testcontainers.jdbc.ConnectionUrl;13import org.testcontainers.jdbc.ConnectionUrl;14import org.testcontainers.jdbc.ContainerDatabaseDriverDelegate;15import org.testcontainers.jdbc.ConnectionUrl;16import org.testcontainers.jdbc.ConnectionUrl;17import org.testcontainers.jdbc.ContainerDatabaseDriverDelegate;18import org.testcontainers.jdbc.ConnectionUrl;19public class JdbcDatabaseDelegateTest {20    public static void main(String[] args) throws SQLException {21        JdbcDatabaseContainer container = new PostgreSQLContainer();22        container.start();23        Properties properties = new Properties();24        properties.setProperty("user", container.getUsername());25        properties.setProperty("password", container.getPassword());26        Connection connection = container.createConnection(properties);27        ContainerDatabaseDriverDelegate delegate = new ContainerDatabaseDriverDelegate();28        ContainerDatabaseDriver driver = new ContainerDatabaseDriver(delegate);29        Connection connection = driver.connect(connectionUrl.getUrl(), properties);30        delegate.execute("CREATE TABLE test (id INTEGER)");31        delegate.execute("INSERT INTO test VALUES (1)");32        delegate.execute("INSERT INTO test VALUES (2)");33        delegate.execute("INSERT INTO test VALUES (3)");34        delegate.execute("INSERT INTO test VALUES (4)");35        delegate.execute("INSERT INTO test VALUES (5)");36        delegate.execute("INSERT INTO test VALUES (6)");37        delegate.execute("INSERT INTO test VALUES (7)");38        delegate.execute("INSERT INTO test VALUES (8)");39        delegate.execute("INSERT INTO test VALUES (9)");40        delegate.execute("INSERT INTO test VALUES (10)");41        delegate.execute("INSERT INTO test VALUES (11)");42        delegate.execute("INSERT INTO test VALUES (12)");43        delegate.execute("INSERT INTO test VALUES (13)");44        delegate.execute("INSERT INTO test VALUES (14)");45        delegate.execute("INSERT INTO test VALUES (15)");46        delegate.execute("INSERT INTO

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.