+ * In case you can't use the URL support, or need to fine-tune the container, you can instantiate it yourself. + * Note that if you use @Rule, you will be given an isolated container for each test method. + * If you use @ClassRule, you will get on isolated container for all the methods in the test class. + *
+ * + */ +public class TestClassScope { + + @ClassRule + public static CrateDBContainer cratedb = new CrateDBContainer(TestingHelpers.nameFromLabel("5.2")); + + @Test + public void testReadSummits() throws SQLException, IOException { + + // Get JDBC URL to CrateDB instance. + String connectionUrl = cratedb.getJdbcUrl(); + System.out.printf("Connecting to %s%n", connectionUrl); + + // Invoke example test. + Application app = new Application(connectionUrl); + var results = app.querySummitsTable(); + assertResults(results); + } +} diff --git a/testing/testcontainers/java/src/test/java/io/crate/example/testing/TestFunctionScope.java b/testing/testcontainers/java/src/test/java/io/crate/example/testing/TestFunctionScope.java new file mode 100644 index 00000000..59894738 --- /dev/null +++ b/testing/testcontainers/java/src/test/java/io/crate/example/testing/TestFunctionScope.java @@ -0,0 +1,43 @@ +package io.crate.example.testing; + +import io.crate.example.testing.utils.TestingHelpers; +import org.junit.Rule; +import org.junit.Test; +import org.testcontainers.cratedb.CrateDBContainer; + +import java.io.IOException; +import java.sql.SQLException; + +import static io.crate.example.testing.utils.TestingHelpers.assertResults; + + +/** + * Function-scoped testcontainer instance with JUnit 4 @Rule/@ClassRule integration. + *+ * In case you can't use the URL support, or need to fine-tune the container, you can instantiate it yourself. + * Note that if you use @Rule, you will be given an isolated container for each test method. + * If you use @ClassRule, you will get on isolated container for all the methods in the test class. + *
+ * + */ +public class TestFunctionScope { + + @Rule + public CrateDBContainer cratedb = new CrateDBContainer(TestingHelpers.nameFromLabel("5.2")); + + @Test + public void testReadSummits() throws SQLException, IOException { + + // Get JDBC URL to CrateDB instance. + String connectionUrl = cratedb.getJdbcUrl(); + System.out.printf("Connecting to %s%n", connectionUrl); + + // Invoke example test. + Application app = new Application(connectionUrl); + var results = app.querySummitsTable(); + assertResults(results); + } +} diff --git a/testing/testcontainers/java/src/test/java/io/crate/example/testing/TestJdbcUrlScheme.java b/testing/testcontainers/java/src/test/java/io/crate/example/testing/TestJdbcUrlScheme.java new file mode 100644 index 00000000..0b77e7da --- /dev/null +++ b/testing/testcontainers/java/src/test/java/io/crate/example/testing/TestJdbcUrlScheme.java @@ -0,0 +1,79 @@ +package io.crate.example.testing; + +import org.junit.Test; + +import java.io.IOException; +import java.sql.SQLException; + +import static io.crate.example.testing.Application.printResults; +import static io.crate.example.testing.utils.TestingHelpers.assertResults; + + +/** + * Database containers launched via Testcontainers "TC" JDBC URL scheme. + * + */ +public class TestJdbcUrlScheme { + + /** + * Launch container with PostgreSQL 15. + */ + @Test + public void testReadSummitsPostgreSQL() throws SQLException, IOException { + String connectionUrl = "jdbc:tc:postgresql:15:///"; + System.out.printf("Connecting to %s%n", connectionUrl); + + // Invoke example query. + Application app = new Application(connectionUrl, "postgres"); + printResults(app.query("SELECT * FROM information_schema.sql_features LIMIT 3;")); + } + + /** + * Launch container with CrateDB 5.2. + */ + @Test + public void testReadSummitsCrateDB() throws SQLException, IOException { + // NOTE: Please note `jdbc:tc:crate` will not work, only `jdbc:tc:cratedb`. + // => `java.lang.UnsupportedOperationException: Database name crate not supported` + String connectionUrl = "jdbc:tc:cratedb:5.2://localhost/doc?user=crate"; + System.out.printf("Connecting to %s%n", connectionUrl); + + // Invoke example query. + Application app = new Application(connectionUrl); + var results = app.querySummitsTable(); + assertResults(results); + } + + /** + * Launch container with CrateDB 5.2, using daemon mode. + * + */ + @Test + public void testReadSummitsCrateDBWithDaemon() throws SQLException, IOException { + String connectionUrl = "jdbc:tc:cratedb:5.2://localhost/doc?user=crate&TC_DAEMON=true"; + System.out.printf("Connecting to %s%n", connectionUrl); + + // Invoke example query. + Application app = new Application(connectionUrl); + var results = app.querySummitsTable(); + assertResults(results); + } + + /** + * Launch container with CrateDB 5.2, using "Reusable Containers (Experimental)". + * + */ + @Test + public void testReadSummitsCrateDBWithReuse() throws SQLException, IOException { + String connectionUrl = "jdbc:tc:cratedb:5.2://localhost/doc?user=crate&TC_REUSABLE=true"; + System.out.printf("Connecting to %s%n", connectionUrl); + + // Invoke example query. + Application app = new Application(connectionUrl); + var results = app.querySummitsTable(); + assertResults(results); + } +} diff --git a/testing/testcontainers/java/src/test/java/io/crate/example/testing/TestManual.java b/testing/testcontainers/java/src/test/java/io/crate/example/testing/TestManual.java new file mode 100644 index 00000000..10632c39 --- /dev/null +++ b/testing/testcontainers/java/src/test/java/io/crate/example/testing/TestManual.java @@ -0,0 +1,40 @@ +package io.crate.example.testing; + +import io.crate.example.testing.utils.TestingHelpers; +import org.junit.Test; +import org.testcontainers.cratedb.CrateDBContainer; +import org.testcontainers.utility.DockerImageName; + +import java.io.IOException; +import java.sql.SQLException; + +import static io.crate.example.testing.utils.TestingHelpers.assertResults; + + +/** + * Function-scoped testcontainer instance with manual setup/teardown. + * + */ +public class TestManual { + + @Test + public void testReadSummits() throws SQLException, IOException { + // Run CrateDB nightly. + DockerImageName image = TestingHelpers.nameFromLabel("nightly"); + try (CrateDBContainer cratedb = new CrateDBContainer(image)) { + cratedb.start(); + + // Get JDBC URL to CrateDB instance. + String connectionUrl = cratedb.getJdbcUrl(); + System.out.printf("Connecting to %s%n", connectionUrl); + + // Invoke example test. + Application app = new Application(connectionUrl); + var results = app.querySummitsTable(); + assertResults(results); + + // Tear down CrateDB. + cratedb.stop(); + } + } +} diff --git a/testing/testcontainers/java/src/test/java/io/crate/example/testing/TestManualWithLegacyCrateJdbcDriver.java b/testing/testcontainers/java/src/test/java/io/crate/example/testing/TestManualWithLegacyCrateJdbcDriver.java new file mode 100644 index 00000000..923bcc90 --- /dev/null +++ b/testing/testcontainers/java/src/test/java/io/crate/example/testing/TestManualWithLegacyCrateJdbcDriver.java @@ -0,0 +1,125 @@ +package io.crate.example.testing; + +import io.crate.example.testing.utils.TestingHelpers; +import org.junit.Test; +import org.testcontainers.containers.JdbcDatabaseContainer; +import org.testcontainers.containers.wait.strategy.Wait; +import org.testcontainers.utility.DockerImageName; + +import java.io.IOException; +import java.sql.SQLException; + +import static io.crate.example.testing.utils.TestingHelpers.assertResults; + + +/** + * Function-scoped testcontainer instance with manual setup/teardown, using a custom CrateDBContainer which uses + * the legacy CrateDB JDBC driver. + * + */ +public class TestManualWithLegacyCrateJdbcDriver { + + @Test + public void testReadSummits() throws SQLException, IOException { + // Run CrateDB nightly. + DockerImageName image = TestingHelpers.nameFromLabel("nightly"); + try (CrateDBContainerLegacyJdbcDriver cratedb = new CrateDBContainerLegacyJdbcDriver(image)) { + cratedb.start(); + + // Get JDBC URL to CrateDB instance. + String connectionUrl = cratedb.getJdbcUrl(); + System.out.printf("Connecting to %s%n", connectionUrl); + + // Invoke example test. + Application app = new Application(connectionUrl); + var results = app.querySummitsTable(); + assertResults(results); + + // Tear down CrateDB. + cratedb.stop(); + } + } + + static class CrateDBContainerLegacyJdbcDriver extends JdbcDatabaseContainer+ * Sometimes it might be useful to define a container that is only started + * once for several test classes. There is no special support for this use + * case provided by the Testcontainers extension. Instead, this can be + * implemented using the Singleton pattern. + *
+ * + */ +public class TestSharedSingleton { + + private CrateDBContainer cratedb; + + @Before + public void startContainer() { + // Run CrateDB latest. + DockerImageName image = TestingHelpers.nameFromLabel("latest"); + cratedb = new CrateDBContainer(image); + cratedb.start(); + } + + @Test + public void testReadSummits() throws SQLException, IOException { + + // Get JDBC URL to CrateDB instance. + String connectionUrl = cratedb.getJdbcUrl(); + System.out.printf("Connecting to %s%n", connectionUrl); + + // Invoke example test. + Application app = new Application(connectionUrl); + var results = app.querySummitsTable(); + assertResults(results); + } +} diff --git a/testing/testcontainers/java/src/test/java/io/crate/example/testing/TestSharedSingletonEnvironmentVersion.java b/testing/testcontainers/java/src/test/java/io/crate/example/testing/TestSharedSingletonEnvironmentVersion.java new file mode 100644 index 00000000..648d4e76 --- /dev/null +++ b/testing/testcontainers/java/src/test/java/io/crate/example/testing/TestSharedSingletonEnvironmentVersion.java @@ -0,0 +1,50 @@ +package io.crate.example.testing; + +import io.crate.example.testing.utils.TestingHelpers; +import org.junit.Before; +import org.junit.Test; +import org.testcontainers.cratedb.CrateDBContainer; +import org.testcontainers.utility.DockerImageName; + +import java.io.IOException; +import java.sql.SQLException; + +import static io.crate.example.testing.utils.TestingHelpers.assertResults; + + +/** + * Testcontainer instance honoring the `CRATEDB_VERSION` environment variable, + * suitable for running a test matrix on different versions of CrateDB. + *+ * Possible values are: + *