Added basic Constraints-support

Author: JohannesRabauer

CHANGELOG.md

@@ -1,3 +1,7 @@
+# 2.3.0
+
+* Added [Jakarta Bean Validation Constraints](https://jakarta.ee/learn/docs/jakartaee-tutorial/current/beanvalidation/bean-validation/bean-validation.html#_using_jakarta_bean_validation_constraints) with Hibernate validator for entities.
+
 # 2.2.2
 
 * Fixed NPE in EclipseSerializerRegisteringCopier

spring-data-eclipse-store/pom.xml

@@ -54,6 +54,10 @@
 		<org.springframework.boot.version>3.3.4</org.springframework.boot.version>
 		<org.eclipse.store.version>1.4.0</org.eclipse.store.version>
 		<org.eclipse.serializer.version>1.4.0</org.eclipse.serializer.version>
+		<hibernate-validator.version>8.0.1.Final</hibernate-validator.version>
+		<jakarta.el-api.version>6.0.1</jakarta.el-api.version>
+		<expressly.version>6.0.0-M1</expressly.version>
+		<hibernate-core.version>6.6.1.Final</hibernate-core.version>
 	</properties>
 
 	<repositories>
@@ -164,6 +168,31 @@
 				</exclusion>
 			</exclusions>
 		</dependency>
+
+		<dependency>
+			<groupId>jakarta.validation</groupId>
+			<artifactId>jakarta.validation-api</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.hibernate.validator</groupId>
+			<artifactId>hibernate-validator</artifactId>
+			<version>${hibernate-validator.version}</version>
+		</dependency>
+		<dependency>
+			<groupId>org.hibernate.orm</groupId>
+			<artifactId>hibernate-core</artifactId>
+			<version>${hibernate-core.version}</version>
+		</dependency>
+		<dependency>
+			<groupId>jakarta.el</groupId>
+			<artifactId>jakarta.el-api</artifactId>
+			<version>${jakarta.el-api.version}</version>
+		</dependency>
+		<dependency>
+			<groupId>org.glassfish.expressly</groupId>
+			<artifactId>expressly</artifactId>
+			<version>${expressly.version}</version>
+		</dependency>
 
 		<dependency>
 			<groupId>com.googlecode.cqengine</groupId>

spring-data-eclipse-store/src/main/java/software/xdev/spring/data/eclipse/store/repository/support/copier/registering/EclipseSerializerRegisteringCopier.java

@@ -18,8 +18,16 @@
 import java.util.HashMap;
 import java.util.Map;
 import java.util.Queue;
+import java.util.Set;
 import java.util.concurrent.ConcurrentLinkedQueue;
 import java.util.function.Supplier;
+import java.util.stream.Collectors;
+
+import jakarta.validation.ConstraintViolation;
+import jakarta.validation.ConstraintViolationException;
+import jakarta.validation.Validation;
+import jakarta.validation.Validator;
+import jakarta.validation.ValidatorFactory;
 
 import org.eclipse.serializer.persistence.binary.types.Binary;
 import org.eclipse.serializer.persistence.binary.types.BinaryStorer;
@@ -45,6 +53,7 @@ public class EclipseSerializerRegisteringCopier implements AutoCloseable
 	private final Supplier<PersistenceManager<Binary>> persistenceManagerSupplier;
 	private final SupportedChecker supportedChecker;
 	private final RegisteringWorkingCopyAndOriginal register;
+	private final Validator validator;
 
 	public EclipseSerializerRegisteringCopier(
 		final SupportedChecker supportedChecker,
@@ -55,6 +64,9 @@ public EclipseSerializerRegisteringCopier(
 		this.register = register;
 		this.persistenceManagerSupplier = persistenceManagerSupplier;
 		this.persistenceManagers = new ConcurrentLinkedQueue<>();
+		
+		final ValidatorFactory validatorFactory = Validation.buildDefaultValidatorFactory();
+		this.validator = validatorFactory.getValidator();
 	}
 
 	private PersistenceManager<Binary> ensurePersistenceManager()
@@ -138,9 +150,25 @@ private <T> T copy(final T source, final PersistenceManager<Binary> persistenceM
 				{
 					return;
 				}
-				if(copiedObject != null && !this.supportedChecker.isSupported(copiedObject.getClass()))
+				if(copiedObject != null)
 				{
-					throw new DataTypeNotSupportedException(copiedObject.getClass());
+					if(!this.supportedChecker.isSupported(copiedObject.getClass()))
+					{
+						throw new DataTypeNotSupportedException(copiedObject.getClass());
+					}
+					final Set<ConstraintViolation<Object>> violations = this.validator.validate(copiedObject);
+					if(!violations.isEmpty())
+					{
+						final String violationsAsMessage = violations.stream()
+							.map(cv -> cv == null ? "null" : cv.getPropertyPath() + ": " + cv.getMessage())
+							.collect(Collectors.joining(", "));
+						
+						throw new ConstraintViolationException(
+							"Error validating " + copiedObject.getClass().getName() + ":" + System.lineSeparator()
+								+ violationsAsMessage,
+							violations
+						);
+					}
 				}
 				summarizer.incrementCopiedObjectsCount();
 				if(DataTypeUtil.isPrimitiveType(copiedObject.getClass()))