GH-866 - JDBC event publication support for Oracle database.

We now support Oracle as database backend for the JDBC-based EventPublicationRegistry.

Original pull request: GH-868.

Author: DSXVII

spring-modulith-events/spring-modulith-events-jdbc/pom.xml

@@ -116,6 +116,12 @@
 			<scope>test</scope>
 		</dependency>
 
+		<dependency>
+			<groupId>org.testcontainers</groupId>
+			<artifactId>oracle-free</artifactId>
+			<scope>test</scope>
+		</dependency>
+
 		<dependency>
 			<groupId>com.microsoft.sqlserver</groupId>
 			<artifactId>mssql-jdbc</artifactId>
@@ -152,6 +158,12 @@
 			<scope>test</scope>
 		</dependency>
 
+		<dependency>
+			<groupId>com.oracle.database.jdbc</groupId>
+			<artifactId>ojdbc11</artifactId>
+			<scope>test</scope>
+		</dependency>
+
 	</dependencies>
 
 </project>

spring-modulith-events/spring-modulith-events-jdbc/src/main/java/org/springframework/modulith/events/jdbc/DatabaseType.java

@@ -82,6 +82,24 @@ UUID databaseToUUID(Object id) {
 			return UUID.fromString(id.toString());
 		}
 
+		@Override
+		boolean isSchemaSupported() {
+			return false;
+		}
+	},
+
+	ORACLE("oracle", "Oracle") {
+
+		@Override
+		Object uuidToDatabase(UUID id) {
+			return id.toString();
+		}
+
+		@Override
+		UUID databaseToUUID(Object id) {
+			return UUID.fromString(id.toString());
+		}
+
 		@Override
 		boolean isSchemaSupported() {
 			return false;

spring-modulith-events/spring-modulith-events-jdbc/src/main/java/org/springframework/modulith/events/jdbc/JdbcEventPublicationRepository.java

@@ -400,7 +400,7 @@ private TargetEventPublication resultSetToPublication(ResultSet rs) throws SQLEx
 		var completionDate = rs.getTimestamp("COMPLETION_DATE");
 		var publicationDate = rs.getTimestamp("PUBLICATION_DATE").toInstant();
 		var listenerId = rs.getString("LISTENER_ID");
-		var serializedEvent = rs.getString("SERIALIZED_EVENT");
+		var serializedEvent = Optional.ofNullable(rs.getString("SERIALIZED_EVENT")).orElse("");
 
 		return new JdbcEventPublication(id, publicationDate, listenerId,
 				() -> serializer.deserialize(serializedEvent, eventClass),

spring-modulith-events/spring-modulith-events-jdbc/src/main/resources/schema-oracle.sql

@@ -0,0 +1,11 @@
+-- oracle database support 'create xx if not exists' from 23c, lower version should create table and index manually 
+CREATE TABLE IF NOT EXISTS EVENT_PUBLICATION (
+  ID               VARCHAR2(36) NOT NULL,
+  LISTENER_ID      VARCHAR2(512) NOT NULL,
+  EVENT_TYPE       VARCHAR2(512) NOT NULL,
+  SERIALIZED_EVENT VARCHAR2(4000),
+  PUBLICATION_DATE TIMESTAMP(6) NOT NULL,
+  COMPLETION_DATE  TIMESTAMP(6),
+  CONSTRAINT EVENT_PUBLICATION_PK PRIMARY KEY(ID)
+);
+CREATE INDEX IF NOT EXISTS EVENT_PUBLICATION_BY_COMPLETION_DATE_IDX ON EVENT_PUBLICATION (COMPLETION_DATE);

spring-modulith-events/spring-modulith-events-jdbc/src/test/java/org/springframework/modulith/events/jdbc/DatabaseSchemaInitializerIntegrationTests.java

@@ -130,4 +130,8 @@ class MariaDB extends WithInitEnabled {}
 	@Nested
 	@ActiveProfiles("mssql")
 	class MSSQL extends WithInitEnabled {}
+	
+	@Nested
+	@ActiveProfiles("oracle")
+	class Oracle extends WithInitEnabled {}
 }

spring-modulith-events/spring-modulith-events-jdbc/src/test/java/org/springframework/modulith/events/jdbc/JdbcEventPublicationRepositoryIntegrationTests.java

@@ -476,6 +476,14 @@ class MariaDBWithNoDefinedSchemaName extends WithNoDefinedSchemaName {}
 
 	@WithMariaDB
 	class MariaDBWithDeleteCompletion extends WithDeleteCompletion {}
+	
+	// Oracle
+
+	@WithOracle
+	class OracleWithNoDefinedSchemaName extends WithNoDefinedSchemaName {}
+
+	@WithOracle
+	class OracleWithDeleteCompletion extends WithDeleteCompletion {}
 
 	@Value
 	private static final class TestEvent {
@@ -515,4 +523,9 @@ private static final class Sample {}
 	@ActiveProfiles("mssql")
 	@Retention(RetentionPolicy.RUNTIME)
 	@interface WithMssql {}
+	
+	@Nested
+	@ActiveProfiles("oracle")
+	@Retention(RetentionPolicy.RUNTIME)
+	@interface WithOracle {}
 }

spring-modulith-events/spring-modulith-events-jdbc/src/test/resources/application-oracle.properties

@@ -0,0 +1,2 @@
+spring.datasource.url=jdbc:tc:oracle:23-slim-faststart:///events
+spring.datasource.driverClassName=org.testcontainers.jdbc.ContainerDatabaseDriver