Merge pull request #242 from eduardknezovic/java-testcontainers

Java Testcontainers

Author: guy9

.gitignore

@@ -13,3 +13,5 @@ buildNumber.properties
 *.csv
 presto/resources/etc/node.properties
 presto/.docker
+
+!java-testcontainers/gradle/wrapper/*

java-testcontainers/.gitattributes

@@ -0,0 +1,12 @@
+#
+# https://help.github.com/articles/dealing-with-line-endings/
+#
+# Linux start script should use lf
+/gradlew        text eol=lf
+
+# These are Windows script files and should use crlf
+*.bat           text eol=crlf
+
+# Binary files should be left untouched
+*.jar           binary
+

java-testcontainers/.gitignore

@@ -0,0 +1,5 @@
+# Ignore Gradle project-specific cache directory
+.gradle
+
+# Ignore Gradle build output directory
+build

java-testcontainers/README.md

@@ -0,0 +1,40 @@
+
+# Testcontainers for Java
+
+## Install Java
+
+```run
+apt install openjdk-21-jdk
+```
+
+## Verify the installation
+
+```run
+java --version
+```
+
+## Navigate to the project
+
+```run
+cd /root/eduard-scllya-code-samples/scylla-code-samples/java-testcontainers
+```
+
+## Run the program
+
+```run
+./gradlew build
+```
+
+## Expected output
+
+The command above will download the dependencies and run the tests.
+
+After the tests pass, you should see the following output:
+
+```
+#...
+
+ScyllaDBExampleTest > testScyllaDBOperations() PASSED
+
+# ...
+```

java-testcontainers/app/build.gradle

@@ -0,0 +1,56 @@
+/*
+ * This file was generated by the Gradle 'init' task.
+ *
+ * This generated file contains a sample Java application project to get you started.
+ * For more details on building Java & JVM projects, please refer to https://docs.gradle.org/8.12.1/userguide/building_java_projects.html in the Gradle documentation.
+ */
+
+plugins {
+    // Apply the application plugin to add support for building a CLI application in Java.
+    id 'application'
+}
+
+repositories {
+    // Use Maven Central for resolving dependencies.
+    mavenCentral()
+}
+
+dependencies {
+    // Use JUnit Jupiter for testing.
+    testImplementation libs.junit.jupiter
+
+    testRuntimeOnly 'org.junit.platform:junit-platform-launcher'
+
+    // This dependency is used by the application.
+    implementation libs.guava
+
+    // Add the required dependencies for the test
+    testImplementation 'org.testcontainers:scylladb:1.20.5'
+    testImplementation 'com.scylladb:java-driver-core:4.18.1.0'
+    implementation 'ch.qos.logback:logback-classic:1.4.11'
+}
+
+// Apply a specific Java toolchain to ease working on different environments.
+java {
+    toolchain {
+        languageVersion = JavaLanguageVersion.of(21)
+    }
+}
+
+application {
+    // Define the main class for the application.
+    mainClass = 'org.example.App'
+}
+
+tasks.named('test') {
+    // Use JUnit Platform for unit tests.
+    useJUnitPlatform()
+
+    // Add the test logging configuration to get the test results in terminal
+    testLogging { 
+        events "passed", "skipped", "failed"
+        showStandardStreams = true
+        exceptionFormat = 'full' 
+        showCauses = true
+    }
+}

java-testcontainers/app/src/main/java/org/example/App.java

@@ -0,0 +1,14 @@
+/*
+ * This source file was generated by the Gradle 'init' task
+ */
+package org.example;
+
+public class App {
+    public String getGreeting() {
+        return "Hello World!";
+    }
+
+    public static void main(String[] args) {
+        System.out.println(new App().getGreeting());
+    }
+}

java-testcontainers/app/src/test/java/org/example/AppTest.java

@@ -0,0 +1,14 @@
+/*
+ * This source file was generated by the Gradle 'init' task
+ */
+package org.example;
+
+import org.junit.jupiter.api.Test;
+import static org.junit.jupiter.api.Assertions.*;
+
+class AppTest {
+    @Test void appHasAGreeting() {
+        App classUnderTest = new App();
+        assertNotNull(classUnderTest.getGreeting(), "app should have a greeting");
+    }
+}

java-testcontainers/app/src/test/java/org/example/ScyllaDBExampleTest.java

@@ -0,0 +1,67 @@
+import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.testcontainers.scylladb.ScyllaDBContainer;
+import com.datastax.oss.driver.api.core.CqlSession;
+import com.datastax.oss.driver.api.core.cql.ResultSet;
+import com.datastax.oss.driver.api.core.cql.Row;
+
+import java.net.InetSocketAddress;
+import java.util.UUID;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
+
+public class ScyllaDBExampleTest {
+
+    private ScyllaDBContainer scylladb;
+    private CqlSession session;
+
+    @BeforeEach
+    public void setUp() {
+        scylladb = new ScyllaDBContainer("scylladb/scylla:2025.1")
+            .withExposedPorts(9042, 19042);
+        scylladb.start();
+
+        session = CqlSession.builder()
+            .addContactPoint(new InetSocketAddress(scylladb.getHost(), scylladb.getMappedPort(9042)))
+            .withLocalDatacenter("datacenter1")
+            .build();
+
+        session.execute("CREATE KEYSPACE IF NOT EXISTS test_keyspace WITH replication = "
+            + "{'class': 'NetworkTopologyStrategy', 'datacenter1': 1}");
+        session.execute("USE test_keyspace");
+        session.execute("CREATE TABLE IF NOT EXISTS users (id UUID PRIMARY KEY, name text, age int)");
+    }
+
+    @AfterEach
+    public void tearDown() {
+        if (session != null) {
+            session.close();
+        }
+        if (scylladb != null) {
+            scylladb.stop();
+        }
+    }
+
+    @Test
+    public void testScyllaDBOperations() {
+        // Insert sample data
+        UUID user1Id = UUID.randomUUID();
+        UUID user2Id = UUID.randomUUID();
+
+        session.execute("INSERT INTO users (id, name, age) VALUES (?, ?, ?)", user1Id, "John Doe", 30);
+        session.execute("INSERT INTO users (id, name, age) VALUES (?, ?, ?)", user2Id, "Jane Doe", 27);
+
+        // Retrieve and verify the inserted data
+        ResultSet results = session.execute("SELECT * FROM users");
+        int count = 0;
+        for (Row row : results) {
+            assertNotNull(row.getString("name"));
+            assertNotNull(row.getInt("age"));
+            count++;
+        }
+
+        assertEquals(2, count); // Ensure two users are present
+    }
+}