Renaming spring-data-rest-1 to spring-data-rest-2

spring-data-rest-2/src/main/java/com/baeldung/books/SpringDataRestApplication.java

@@ -0,0 +1,13 @@
+package com.baeldung.books;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class SpringDataRestApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(SpringDataRestApplication.class, args);
+    }
+
+}

spring-data-rest-2/src/main/java/com/baeldung/books/config/DbConfig.java

@@ -0,0 +1,65 @@
+package com.baeldung.books.config;
+
+import java.util.Properties;
+
+import javax.sql.DataSource;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Profile;
+import org.springframework.context.annotation.PropertySource;
+import org.springframework.core.env.Environment;
+import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
+import org.springframework.jdbc.datasource.DriverManagerDataSource;
+import org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean;
+import org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter;
+
+@Configuration
+@EnableJpaRepositories(basePackages = "com.baeldung.books.repositories")
+public class DbConfig {
+
+	@Autowired
+	private Environment env;
+
+	@Bean
+	public DataSource dataSource() {
+		final DriverManagerDataSource dataSource = new DriverManagerDataSource();
+		dataSource.setDriverClassName(env.getProperty("driverClassName"));
+		dataSource.setUrl(env.getProperty("url"));
+		dataSource.setUsername(env.getProperty("user"));
+		dataSource.setPassword(env.getProperty("password"));
+		return dataSource;
+	}
+
+	@Bean
+	public LocalContainerEntityManagerFactoryBean entityManagerFactory() {
+		final LocalContainerEntityManagerFactoryBean em = new LocalContainerEntityManagerFactoryBean();
+		em.setDataSource(dataSource());
+		em.setPackagesToScan(new String[] { "com.baeldung.books.models" });
+		em.setJpaVendorAdapter(new HibernateJpaVendorAdapter());
+		em.setJpaProperties(additionalProperties());
+		return em;
+	}
+
+	final Properties additionalProperties() {
+		final Properties hibernateProperties = new Properties();
+		if (env.getProperty("hibernate.hbm2ddl.auto") != null) {
+			hibernateProperties.setProperty("hibernate.hbm2ddl.auto", env.getProperty("hibernate.hbm2ddl.auto"));
+		}
+		if (env.getProperty("hibernate.dialect") != null) {
+			hibernateProperties.setProperty("hibernate.dialect", env.getProperty("hibernate.dialect"));
+		}
+		if (env.getProperty("hibernate.show_sql") != null) {
+			hibernateProperties.setProperty("hibernate.show_sql", env.getProperty("hibernate.show_sql"));
+		}
+		return hibernateProperties;
+	}
+
+}
+
+@Configuration
+@Profile("h2")
+@PropertySource("classpath:persistence-h2.properties")
+class H2Config {
+}

spring-data-rest-2/src/main/java/com/baeldung/books/config/RestConfig.java

@@ -0,0 +1,21 @@
+package com.baeldung.books.config;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.rest.core.config.RepositoryRestConfiguration;
+import org.springframework.data.rest.core.mapping.ExposureConfiguration;
+import org.springframework.data.rest.webmvc.config.RepositoryRestConfigurer;
+import org.springframework.http.HttpMethod;
+import org.springframework.web.servlet.config.annotation.CorsRegistry;
+
+import com.baeldung.books.models.WebsiteUser;
+
+@Configuration
+public class RestConfig implements RepositoryRestConfigurer {
+
+    @Override
+    public void configureRepositoryRestConfiguration(RepositoryRestConfiguration repositoryRestConfiguration,
+                                                     CorsRegistry cors) {
+        ExposureConfiguration config = repositoryRestConfiguration.getExposureConfiguration();
+        config.forDomainType(WebsiteUser.class).withItemExposure((metadata, httpMethods) -> httpMethods.disable(HttpMethod.PATCH));
+    }
+}

spring-data-rest-2/src/main/java/com/baeldung/books/config/ValidatorEventRegister.java

@@ -0,0 +1,30 @@
+package com.baeldung.books.config;
+
+import java.util.Arrays;
+import java.util.List;
+import java.util.Map;
+
+import org.springframework.beans.factory.InitializingBean;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.rest.core.event.ValidatingRepositoryEventListener;
+import org.springframework.validation.Validator;
+
+@Configuration
+public class ValidatorEventRegister implements InitializingBean {
+
+    @Autowired
+    ValidatingRepositoryEventListener validatingRepositoryEventListener;
+
+    @Autowired
+    private Map<String, Validator> validators;
+
+    @Override
+    public void afterPropertiesSet() throws Exception {
+        List<String> events = Arrays.asList("beforeCreate", "afterCreate", "beforeSave", "afterSave", "beforeLinkSave", "afterLinkSave", "beforeDelete", "afterDelete");
+
+        for (Map.Entry<String, Validator> entry : validators.entrySet()) {
+            events.stream().filter(p -> entry.getKey().startsWith(p)).findFirst().ifPresent(p -> validatingRepositoryEventListener.addValidator(p, entry.getValue()));
+        }
+    }
+}

spring-data-rest-2/src/main/java/com/baeldung/books/exception/handlers/RestResponseEntityExceptionHandler.java

@@ -0,0 +1,26 @@
+package com.baeldung.books.exception.handlers;
+
+import org.springframework.data.rest.core.RepositoryConstraintViolationException;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.validation.ObjectError;
+import org.springframework.web.bind.annotation.ControllerAdvice;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.context.request.WebRequest;
+import org.springframework.web.servlet.mvc.method.annotation.ResponseEntityExceptionHandler;
+
+import java.util.stream.Collectors;
+
+@ControllerAdvice
+public class RestResponseEntityExceptionHandler extends ResponseEntityExceptionHandler {
+
+    @ExceptionHandler({ RepositoryConstraintViolationException.class })
+    public ResponseEntity<Object> handleAccessDeniedException(Exception ex, WebRequest request) {
+        RepositoryConstraintViolationException nevEx = (RepositoryConstraintViolationException) ex;
+
+        String errors = nevEx.getErrors().getAllErrors().stream().map(ObjectError::toString).collect(Collectors.joining("\n"));
+        return new ResponseEntity<>(errors, new HttpHeaders(), HttpStatus.NOT_ACCEPTABLE);
+    }
+
+}

spring-data-rest-2/src/main/java/com/baeldung/books/models/WebsiteUser.java

@@ -0,0 +1,41 @@
+package com.baeldung.books.models;
+
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.GenerationType;
+import javax.persistence.Id;
+
+@Entity
+public class WebsiteUser {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.AUTO)
+    private long id;
+
+    private String name;
+    private String email;
+
+    public long getId() {
+        return id;
+    }
+
+    public void setId(long id) {
+        this.id = id;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getEmail() {
+        return email;
+    }
+
+    public void setEmail(String email) {
+        this.email = email;
+    }
+}

spring-data-rest-2/src/main/java/com/baeldung/books/repositories/UserRepository.java

@@ -0,0 +1,33 @@
+package com.baeldung.books.repositories;
+
+import org.springframework.data.repository.CrudRepository;
+import org.springframework.data.repository.query.Param;
+import org.springframework.data.rest.core.annotation.RepositoryRestResource;
+import org.springframework.data.rest.core.annotation.RestResource;
+import org.springframework.web.bind.annotation.CrossOrigin;
+
+import com.baeldung.books.models.WebsiteUser;
+
+@CrossOrigin
+@RepositoryRestResource(collectionResourceRel = "users", path = "users")
+public interface UserRepository extends CrudRepository<WebsiteUser, Long> {
+
+    @Override
+    @RestResource(exported = false)
+    void delete(WebsiteUser entity);
+
+    @Override
+    @RestResource(exported = false)
+    void deleteAll();
+
+    @Override
+    @RestResource(exported = false)
+    void deleteAll(Iterable<? extends WebsiteUser> entities);
+
+    @Override
+    @RestResource(exported = false)
+    void deleteById(Long aLong);
+
+    @RestResource(path = "byEmail", rel = "customFindMethod")
+    WebsiteUser findByEmail(@Param("email") String email);
+}

spring-data-rest-2/src/main/java/com/baeldung/books/validators/WebsiteUserValidator.java

@@ -0,0 +1,33 @@
+package com.baeldung.books.validators;
+
+import org.springframework.stereotype.Component;
+import org.springframework.validation.Errors;
+import org.springframework.validation.Validator;
+
+import com.baeldung.books.models.WebsiteUser;
+
+@Component("beforeCreateWebsiteUserValidator")
+public class WebsiteUserValidator implements Validator {
+
+    @Override
+    public boolean supports(Class<?> clazz) {
+        return WebsiteUser.class.equals(clazz);
+    }
+
+    @Override
+    public void validate(Object obj, Errors errors) {
+
+        WebsiteUser user = (WebsiteUser) obj;
+        if (checkInputString(user.getName())) {
+            errors.rejectValue("name", "name.empty");
+        }
+
+        if (checkInputString(user.getEmail())) {
+            errors.rejectValue("email", "email.empty");
+        }
+    }
+
+    private boolean checkInputString(String input) {
+        return (input == null || input.trim().length() == 0);
+    }
+}

spring-data-rest-2/src/main/java/com/baeldung/halbrowser/App.java

@@ -0,0 +1,13 @@
+package com.baeldung.halbrowser;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class App {
+
+  public static void main(String[] args) {
+    SpringApplication.run(App.class);
+  }
+
+}

spring-data-rest-2/src/main/java/com/baeldung/halbrowser/config/DBLoader.java

@@ -0,0 +1,109 @@
+package com.baeldung.halbrowser.config;
+
+import java.util.Random;
+import java.util.stream.IntStream;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.ApplicationArguments;
+import org.springframework.boot.ApplicationRunner;
+import org.springframework.stereotype.Component;
+
+import com.baeldung.halbrowser.data.BookRepository;
+import com.baeldung.halbrowser.model.Book;
+
+@Component
+public class DBLoader implements ApplicationRunner {
+
+  private final BookRepository bookRepository;
+
+  @Autowired
+  DBLoader(BookRepository bookRepository){
+    this.bookRepository = bookRepository;
+  }
+
+
+  public void run(ApplicationArguments applicationArguments) throws Exception {
+
+     String[] templates = {
+       "Up and running with %s",
+       "%s Basics",
+       "%s for Beginners",
+       "%s for Neckbeards",
+       "Under the hood: %s",
+       "Discovering %s",
+       "A short guide to %s",
+       "%s with Baeldung"
+     };
+
+     String[] buzzWords = {
+       "Spring REST Data",
+       "Java 9",
+       "Scala",
+       "Groovy",
+       "Hibernate",
+       "Spring HATEOS",
+       "The HAL Browser",
+       "Spring webflux",
+     };
+
+     String[] authorFirstName = {
+       "John %s",
+       "Steve %s",
+       "Samantha %s",
+       "Gale %s",
+       "Tom %s"
+     };
+
+     String[] authorLastName = {
+       "Giles",
+       "Gill",
+       "Smith",
+       "Armstrong"
+     };
+
+     String[] blurbs = {
+       "It was getting dark when the %s %s" ,
+       "Scott was nearly there when he heard that a %s %s",
+       "Diana was a lovable Java coder until the %s %s",
+       "The gripping story of a small %s and the day it %s"
+     };
+
+     String[] blublMiddles = {
+       "distaster",
+       "dog",
+       "cat",
+       "turtle",
+       "hurricane"
+     };
+
+     String[] end = {
+       "hit the school",
+       "memorised pi to 100 decimal places!",
+       "became a world champion armwrestler",
+       "became a Java REST master!!"
+     };
+
+     Random random = new Random();
+
+     IntStream.range(0, 100)
+       .forEach(i -> {
+         String template = templates[i % templates.length];
+         String buzzword = buzzWords[i % buzzWords.length];
+         String blurbStart = blurbs[i % blurbs.length];
+         String middle = blublMiddles[i % blublMiddles.length];
+         String ending = end[i % end.length];
+         String blurb = String.format(blurbStart, middle, ending);
+         String firstName = authorFirstName[i % authorFirstName.length];
+         String lastname = authorLastName[i % authorLastName.length];
+         Book book = new Book(String.format(template, buzzword), String.format(firstName, lastname), blurb, random.nextInt(1000-200) + 200);
+
+         bookRepository.save(book);
+
+         System.out.println(book);
+
+       });
+
+
+
+  }
+}

spring-data-rest-2/src/main/java/com/baeldung/halbrowser/config/RestConfig.java

@@ -0,0 +1,23 @@
+package com.baeldung.halbrowser.config;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Lazy;
+import org.springframework.data.rest.core.event.ValidatingRepositoryEventListener;
+import org.springframework.data.rest.webmvc.config.RepositoryRestConfigurer;
+import org.springframework.validation.Validator;
+
+@Configuration
+public class RestConfig implements RepositoryRestConfigurer {
+
+  //access to global validator
+  @Autowired
+  @Lazy
+  private Validator validator;
+
+  @Override
+  public void configureValidatingRepositoryEventListener(ValidatingRepositoryEventListener validatingListener) {
+    validatingListener.addValidator("beforeCreate", validator );
+    validatingListener.addValidator("beforeSave", validator);
+  }
+}

spring-data-rest-2/src/main/java/com/baeldung/halbrowser/data/BookRepository.java

@@ -0,0 +1,21 @@
+package com.baeldung.halbrowser.data;
+
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.repository.PagingAndSortingRepository;
+import org.springframework.data.repository.query.Param;
+import org.springframework.data.rest.core.annotation.RestResource;
+import org.springframework.stereotype.Repository;
+
+import com.baeldung.halbrowser.model.Book;
+
+@Repository
+public interface BookRepository extends PagingAndSortingRepository<Book, Long> {
+
+  @RestResource(rel = "title-contains", path="title-contains")
+  Page<Book> findByTitleContaining(@Param("query") String query, Pageable page);
+
+  @RestResource(rel = "author-contains", path="author-contains", exported = false)
+  Page<Book> findByAuthorContaining(@Param("query") String query, Pageable page);
+
+}

spring-data-rest-2/src/main/java/com/baeldung/halbrowser/model/Book.java

@@ -0,0 +1,86 @@
+package com.baeldung.halbrowser.model;
+
+import javax.persistence.*;
+import javax.validation.constraints.NotNull;
+
+@Entity
+public class Book {
+
+  @Id
+  @GeneratedValue(strategy = GenerationType.IDENTITY)
+  private long id;
+
+  @NotNull
+  @Column(columnDefinition = "VARCHAR", length = 100)
+  private String title;
+
+  @NotNull
+  @Column(columnDefinition = "VARCHAR", length = 100)
+  private String author;
+
+  @Column(columnDefinition = "VARCHAR", length = 1000)
+  private String blurb;
+
+  private int pages;
+
+  public Book() {
+  }
+
+  public Book(@NotNull String title, @NotNull String author, String blurb, int pages) {
+    this.title = title;
+    this.author = author;
+    this.blurb = blurb;
+    this.pages = pages;
+  }
+
+  public long getId() {
+    return id;
+  }
+
+  public void setId(long id) {
+    this.id = id;
+  }
+
+  public String getTitle() {
+    return title;
+  }
+
+  public void setTitle(String title) {
+    this.title = title;
+  }
+
+  public String getAuthor() {
+    return author;
+  }
+
+  public void setAuthor(String author) {
+    this.author = author;
+  }
+
+  public String getBlurb() {
+    return blurb;
+  }
+
+  public void setBlurb(String blurb) {
+    this.blurb = blurb;
+  }
+
+  public int getPages() {
+    return pages;
+  }
+
+  public void setPages(int pages) {
+    this.pages = pages;
+  }
+
+  @Override
+  public String toString() {
+    return "Book{" +
+      "id=" + id +
+      ", title='" + title + '\'' +
+      ", author='" + author + '\'' +
+      ", blurb='" + blurb + '\'' +
+      ", pages=" + pages +
+      '}';
+  }
+}

spring-data-rest-2/src/main/java/com/baeldung/springdatawebsupport/application/Application.java

@@ -0,0 +1,28 @@
+package com.baeldung.springdatawebsupport.application;
+
+import com.baeldung.springdatawebsupport.application.entities.User;
+import com.baeldung.springdatawebsupport.application.repositories.UserRepository;
+import java.util.stream.Stream;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.Bean;
+
+@SpringBootApplication
+public class Application {
+
+    public static void main(String[] args) {
+        SpringApplication.run(Application.class, args);
+    }
+
+    @Bean
+    CommandLineRunner initialize(UserRepository userRepository) {
+        return args -> {
+            Stream.of("John", "Robert", "Nataly", "Helen", "Mary").forEach(name -> {
+                User user = new User(name);
+                userRepository.save(user);
+            });
+            userRepository.findAll().forEach(System.out::println);
+        };
+    }
+}

spring-data-rest-2/src/main/java/com/baeldung/springdatawebsupport/application/controllers/UserController.java

@@ -0,0 +1,47 @@
+package com.baeldung.springdatawebsupport.application.controllers;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.domain.Sort;
+import org.springframework.data.querydsl.binding.QuerydslPredicate;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RestController;
+
+import com.baeldung.springdatawebsupport.application.entities.User;
+import com.baeldung.springdatawebsupport.application.repositories.UserRepository;
+import com.querydsl.core.types.Predicate;
+
+@RestController
+public class UserController {
+
+    private final UserRepository userRepository;
+
+    @Autowired
+    public UserController(UserRepository userRepository) {
+        this.userRepository = userRepository;
+    }
+
+    @GetMapping("/users/{id}")
+    public User findUserById(@PathVariable("id") User user) {
+        return user;
+    }
+
+    @GetMapping("/users")
+    public Page<User> findAllUsers(Pageable pageable) {
+        return userRepository.findAll(pageable);
+    }
+
+    @GetMapping("/sortedusers")
+    public Page<User> findAllUsersSortedByName() {
+        Pageable pageable = PageRequest.of(0, 5, Sort.by("name"));
+        return userRepository.findAll(pageable);
+    }
+
+    @GetMapping("/filteredusers")
+    public Iterable<User> getUsersByQuerydslPredicate(@QuerydslPredicate(root = User.class) Predicate predicate) {
+        return userRepository.findAll(predicate);
+    }
+}

spring-data-rest-2/src/main/java/com/baeldung/springdatawebsupport/application/entities/User.java

@@ -0,0 +1,38 @@
+package com.baeldung.springdatawebsupport.application.entities;
+
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.GenerationType;
+import javax.persistence.Id;
+import javax.persistence.Table;
+
+@Entity
+@Table(name = "users")
+public class User {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.AUTO)
+    private long id;
+    private final String name;
+
+    public User() {
+        this.name = "";
+    }
+
+    public User(String name) {
+        this.name = name;
+    }
+
+    public long getId() {
+        return id;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    @Override
+    public String toString() {
+        return "User{" + "id=" + id + ", name=" + name + '}';
+    }
+}

spring-data-rest-2/src/main/java/com/baeldung/springdatawebsupport/application/repositories/UserRepository.java

@@ -0,0 +1,12 @@
+package com.baeldung.springdatawebsupport.application.repositories;
+
+import org.springframework.data.querydsl.QuerydslPredicateExecutor;
+import org.springframework.data.repository.PagingAndSortingRepository;
+import org.springframework.stereotype.Repository;
+
+import com.baeldung.springdatawebsupport.application.entities.User;
+
+@Repository
+public interface UserRepository extends PagingAndSortingRepository<User, Long>, QuerydslPredicateExecutor<User> {
+
+}