How to use MSSQLR2DBCDatabaseContainerProvider class of org.testcontainers.containers package

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

Source:MSSQLR2DBCDatabaseContainer.java

...9    @Delegate(types = Startable.class)10    private final MSSQLServerContainer<?> container;11    public static ConnectionFactoryOptions getOptions(MSSQLServerContainer<?> container) {12        ConnectionFactoryOptions options = ConnectionFactoryOptions.builder()13            .option(ConnectionFactoryOptions.DRIVER, MSSQLR2DBCDatabaseContainerProvider.DRIVER)14            .build();15        return new MSSQLR2DBCDatabaseContainer(container).configure(options);16    }17    @Override18    public ConnectionFactoryOptions configure(ConnectionFactoryOptions options) {19        return options.mutate()20            .option(ConnectionFactoryOptions.HOST, container.getContainerIpAddress())21            .option(ConnectionFactoryOptions.PORT, container.getMappedPort(MSSQLServerContainer.MS_SQL_SERVER_PORT))22            // TODO enable if/when MSSQLServerContainer adds support for customizing the DB name23            // .option(ConnectionFactoryOptions.DATABASE, container.getDatabasseName())24            .option(ConnectionFactoryOptions.USER, container.getUsername())25            .option(ConnectionFactoryOptions.PASSWORD, container.getPassword())26            .build();27    }...

MSSQLR2DBCDatabaseContainerProvider

Using AI Code Generation

1package com.example;2import java.sql.Connection;3import java.sql.ResultSet;4import java.sql.SQLException;5import java.sql.Statement;6import org.junit.jupiter.api.Test;7import org.testcontainers.containers.MSSQLR2DBCDatabaseContainerProvider;8import org.testcontainers.containers.R2DBCDatabaseContainer;9import org.testcontainers.junit.jupiter.Container;10import org.testcontainers.junit.jupiter.Testcontainers;11import org.testcontainers.utility.DockerImageName;12public class TestcontainersDemo {13    private static final R2DBCDatabaseContainer<?> container = new MSSQLR2DBCDatabaseContainerProvider()14            .newInstance(DockerImageName.parse("mcr.microsoft.com/mssql/rhel/server:2019-latest"));15    void test() throws SQLException {16        Connection connection = container.createConnection("");17        Statement statement = connection.createStatement();18        ResultSet resultSet = statement.executeQuery("SELECT 1");19        resultSet.next();20        System.out.println(resultSet.getInt(1));21    }22}

MSSQLR2DBCDatabaseContainerProvider

Using AI Code Generation

1public class MSSQLServerContainerProvider implements MSSQLR2DBCDatabaseContainerProvider {2  public boolean supports(String databaseType) {3    return "mssql".equals(databaseType);4  }5  public JdbcDatabaseContainer newInstance() {6    return new MSSQLServerContainer();7  }8  public String getDriverClassName() {9    return "com.microsoft.sqlserver.jdbc.SQLServerDriver";10  }11}12public class MSSQLServerContainerProviderTest {13  public void testMSSQLServerContainerProvider() {14    MSSQLServerContainerProvider provider = new MSSQLServerContainerProvider();15    assertTrue(provider.supports("mssql"));16    assertFalse(provider.supports("mysql"));17    assertTrue(provider.newInstance() instanceof MSSQLServerContainer);18    assertEquals("com.microsoft.sqlserver.jdbc.SQLServerDriver", provider.getDriverClassName());19  }20}

MSSQLR2DBCDatabaseContainerProvider

Using AI Code Generation

1import org.testcontainers.containers.MSSQLR2DBCDatabaseContainerProvider;2import org.testcontainers.containers.R2DBCDatabaseContainer;3import org.testcontainers.containers.R2DBCDatabaseContainerProvider;4import java.util.Set;5import static org.testcontainers.containers.MSSQLServerContainer.IMAGE;6public class MSSQLR2DBCDatabaseContainerProvider extends R2DBCDatabaseContainerProvider {7    public boolean supports(String databaseType) {8        return databaseType.equals(IMAGE);9    }10    public R2DBCDatabaseContainer newInstance() {11        return new MSSQLR2DBCDatabaseContainer();12    }13    public Set<String> getProvidedDriverNames() {14        return Set.of("com.microsoft.sqlserver.jdbc.SQLServerDriver");15    }16}17import org.testcontainers.containers.MSSQLR2DBCDatabaseContainerProvider;18import org.springframework.beans.factory.annotation.Autowired;19import org.springframework.boot.test.autoconfigure.data.r2dbc.DataR2dbcTest;20import org.springframework.context.annotation.Bean;21import org.springframework.context.annotation.Configuration;22import org.springframework.r2dbc.connection.R2dbcTransactionManager;23import org.springframework.r2dbc.core.DatabaseClient;24import org.springframework.r2dbc.core.R2dbcEntityTemplate;25import org.springframework.r2dbc.core.R2dbcEntityOperations;26import org.springframework.transaction.ReactiveTransactionManager;27import org.springframework.transaction.reactive.TransactionalOperator;28import io.r2dbc.spi.ConnectionFactory;29public class R2dbcTest {30    private DatabaseClient databaseClient;31    private ConnectionFactory connectionFactory;32    public static class Config {33        public R2dbcEntityOperations r2dbcEntityOperations(ConnectionFactory connectionFactory) {34            return new R2dbcEntityTemplate(connectionFactory);35        }36        public ReactiveTransactionManager transactionManager(ConnectionFactory connectionFactory) {37            return new R2dbcTransactionManager(connectionFactory);38        }39        public TransactionalOperator transactionalOperator(ReactiveTransactionManager transactionManager) {40            return TransactionalOperator.create(transactionManager);41        }42        public R2dbcDatabaseContainerProvider r2dbcDatabaseContainerProvider() {43            return new MSSQLR2DBCDatabaseContainerProvider();44        }45    }

MSSQLR2DBCDatabaseContainerProvider

Using AI Code Generation

1import org.testcontainers.containers.MSSQLR2DBCDatabaseContainerProvider;2public class TestContainerExample {3    public static void main(String[] args) {4        try (MSSQLR2DBCDatabaseContainerProvider container = new MSSQLR2DBCDatabaseContainerProvider()) {5            container.start();6            System.out.println("Connection URL: " + container.getJdbcUrl());7            System.out.println("Connection Username: " + container.getUsername());8            System.out.println("Connection Password: " + container.getPassword());9        }10    }11}12Srinivasan Ranganathan is a software engineer at Microsoft. He has over 20 years of experience in the IT industry. He has worked on various projects in the areas of software development, software testing, and software architecture. He has expertise in various software engineering technologies, including Java, Spring, React, Angular, and SQL Server. He is passionate about software testing and software architecture. He is also a Microsoft Certified Trainer (MCT) and a Microsoft Certified Professional (MCP). He is a regular speaker at various conferences and user groups. He is also the author of several books on software testing and software architecture. View all posts by Srinivasan Ranganathan

MSSQLR2DBCDatabaseContainerProvider

Using AI Code Generation

1MSSQLServerContainerProvider provider = new MSSQLR2DBCDatabaseContainerProvider();2MSSQLServerContainer mssqlServerContainer = provider.newInstance("2017-latest");3mssqlServerContainer.start();4R2dbc r2dbc = R2dbc.builder()5        .url(mssqlServerContainer.getJdbcUrl())6        .username(mssqlServerContainer.getUsername())7        .password(mssqlServerContainer.getPassword())8        .build();9ConnectionFactory connectionFactory = r2dbc.getConnectionFactory();10connectionFactory.create()11        .flatMapMany(connection -> connection.createStatement("SELECT * FROM sysobjects")12                .execute())13        .flatMap(result -> result.map((row, rowMetadata) -> row.get("name")))14        .subscribe(System.out::println);15mssqlServerContainer.stop();

MSSQLR2DBCDatabaseContainerProvider

Using AI Code Generation

1MSSQLR2DBCDatabaseContainerProvider provider = new MSSQLR2DBCDatabaseContainerProvider();2MSSQLR2DBCDatabaseContainer container = provider.createContainer("mcr.microsoft.com/mssql/rhel/server:2019-CU8-ubuntu-18.04");3container.start();4String connectionString = container.getJdbcUrl();5ConnectionFactory connectionFactory = ConnectionFactories.get(connectionString);6Mono<Connection> connectionMono = connectionFactory.create();7Mono<Statement> statementMono = connectionMono.flatMap(connection -> connection.createStatement("SELECT 1"));8Mono<Result> resultMono = statementMono.flatMap(Statement::execute);9Mono<Integer> integerMono = resultMono.flatMap(result -> result.map((row, rowMetadata) -> row.get(0, Integer.class)));10integerMono.subscribe(integer -> System.out.println("Result: " + integer));11connectionMono.flatMap(Connection::close).subscribe();12container.stop();

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.