DATAJDBC-example - basic reading and writing seems to work!.

schauder · schauder · commit 453e00c42cc4 · 2017-11-01T15:03:12.000+01:00
including id used a foreign key and custom conversion!!!
diff --git a/jdbc/basics/src/main/java/example/springdata/jdbc/basics/AggregatesApplication.java b/jdbc/basics/src/main/java/example/springdata/jdbc/basics/AggregatesApplication.java
@@ -16,6 +16,8 @@
 package example.springdata.jdbc.basics;
 
 import javax.sql.DataSource;
+import java.sql.Clob;
+import java.sql.SQLException;
 import java.time.Period;
 import java.util.Collections;
 import java.util.HashMap;
@@ -27,23 +29,29 @@
 import org.springframework.boot.SpringApplication;
 import org.springframework.context.ApplicationListener;
 import org.springframework.context.annotation.Bean;
+import org.springframework.core.convert.ConversionService;
+import org.springframework.core.convert.converter.Converter;
 import org.springframework.data.jdbc.mapping.event.BeforeSave;
+import org.springframework.data.jdbc.mapping.model.ConversionCustomizer;
 import org.springframework.data.jdbc.mapping.model.DefaultNamingStrategy;
 import org.springframework.data.jdbc.mapping.model.JdbcPersistentProperty;
 import org.springframework.data.jdbc.mapping.model.NamingStrategy;
 import org.springframework.data.jdbc.repository.config.EnableJdbcRepositories;
 import org.springframework.jdbc.datasource.embedded.EmbeddedDatabaseBuilder;
 import org.springframework.jdbc.datasource.embedded.EmbeddedDatabaseType;
+import org.springframework.lang.Nullable;
 
 import example.springdata.jdbc.basics.domain.LegoSet;
 import example.springdata.jdbc.basics.domain.LegoSetRepository;
+import example.springdata.jdbc.basics.domain.Manual;
 
 /**
  * Demonstrates non trivial usage of Spring Data JDBC especially handling of collections and references crossing aggregate boundaries.
  * It tries to showcase the following
  * <ul>
  * <li>Custom Names for columns and tables via NamingStrategy</li>
  * <li>Manual id generation</li>
+ * <li>Custom conversions</li>
  * </ul>
  *
  * @author Jens Schauder
@@ -59,10 +67,18 @@ public class AggregatesApplication implements CommandLineRunner {
 	@Override
 	public void run(String... args) throws Exception {
 
+
+		Manual manual = new Manual();
+		manual.setAuthor("Jens Schauder");
+		manual.setText("Just put all the pieces together in the right order");
+
 		LegoSet smallCar = new LegoSet();
 		smallCar.setMinimumAge(Period.ofYears(5));
 		smallCar.setMaximumAge(Period.ofYears(12));
 
+		smallCar.setManual(manual);
+
+
 		Output.list(Collections.singleton(smallCar), "debugging");
 
 		repository.save(smallCar);
@@ -86,14 +102,19 @@ DataSource dataSource() {
 	}
 
 	@Bean
-	public ApplicationListener<?> timeStampingSaveTime() {
+	public ApplicationListener<?> idSetting() {
 
 		return (ApplicationListener<BeforeSave>) event -> {
 
 			Object entity = event.getEntity();
 			if (entity instanceof LegoSet) {
 				LegoSet legoSet = (LegoSet) entity;
 				legoSet.setId(id.incrementAndGet());
+
+				Manual manual = legoSet.getManual();
+				if (manual != null) {
+					manual.setId((long)legoSet.getId());
+				}
 			}
 		};
 	}
@@ -137,4 +158,23 @@ public String getReverseColumnName(JdbcPersistentProperty property) {
 			}
 		};
 	}
+
+	@Bean
+	public ConversionCustomizer conversionCustomizer() {
+		return conversions -> conversions.addConverter(new Converter<Clob, String>() {
+			@Nullable
+			@Override
+			public String convert(Clob clob) {
+
+				try {
+					int length = Math.toIntExact(clob.length());
+					if (length == 0) return "";
+
+					return clob.getSubString(1, length);
+				} catch (SQLException e) {
+					throw new IllegalStateException("Failed to convert CLOB to String.", e);
+				}
+			}
+		});
+	}
 }
diff --git a/jdbc/basics/src/main/java/example/springdata/jdbc/basics/domain/Manual.java b/jdbc/basics/src/main/java/example/springdata/jdbc/basics/domain/Manual.java
@@ -16,6 +16,7 @@
 package example.springdata.jdbc.basics.domain;
 
 import org.springframework.data.annotation.Id;
+import org.springframework.data.annotation.Transient;
 
 import lombok.Data;
 
@@ -26,7 +27,7 @@
 public class Manual {
 
 	@Id
-	private final Long id;
+	private Long id;
 
 	private String author;
 	private String text;
diff --git a/jdbc/pom.xml b/jdbc/pom.xml
@@ -28,7 +28,7 @@
         <dependency>
             <groupId>org.springframework.data</groupId>
             <artifactId>spring-data-jdbc</artifactId>
-            <version>1.0.0.BUILD-SNAPSHOT</version>
+            <version>1.0.0.WIP-SNAPSHOT</version>
         </dependency>
 
         <dependency>
