Merge branch 'master' into master

persistence-modules/core-java-persistence/pom.xml

@@ -60,6 +60,7 @@
     </dependencies>
 
     <properties>
+        <h2.version>1.4.200</h2.version>
         <postgresql.version>42.2.5.jre7</postgresql.version>
         <assertj-core.version>3.10.0</assertj-core.version>
         <commons-dbcp2.version>2.4.0</commons-dbcp2.version>

persistence-modules/core-java-persistence/src/test/java/com/baeldung/genkeys/JdbcInsertIdIntegrationTest.java

@@ -0,0 +1,93 @@
+package com.baeldung.genkeys;
+
+import org.junit.AfterClass;
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+public class JdbcInsertIdIntegrationTest {
+
+    private static final String QUERY = "insert into persons (name) values (?)";
+
+    private static Connection connection;
+
+    @BeforeClass
+    public static void setUp() throws Exception {
+        connection = DriverManager.getConnection("jdbc:h2:mem:generated-keys", "sa", "");
+        connection
+          .createStatement()
+          .execute("create table persons(id bigint auto_increment, name varchar(255))");
+    }
+
+    @AfterClass
+    public static void tearDown() throws SQLException {
+        connection
+          .createStatement()
+          .execute("drop table persons");
+        connection.close();
+    }
+
+    @Test
+    public void givenInsert_whenUsingAutoGenFlag_thenBeAbleToFetchTheIdAfterward() throws SQLException {
+        try (PreparedStatement statement = connection.prepareStatement(QUERY, Statement.RETURN_GENERATED_KEYS)) {
+            statement.setString(1, "Foo");
+            int affectedRows = statement.executeUpdate();
+            assertThat(affectedRows).isPositive();
+
+            try (ResultSet keys = statement.getGeneratedKeys()) {
+                assertThat(keys.next()).isTrue();
+                assertThat(keys.getLong(1)).isGreaterThanOrEqualTo(1);
+            }
+        }
+    }
+
+    @Test
+    public void givenInsert_whenUsingAutoGenFlagViaExecute_thenBeAbleToFetchTheIdAfterward() throws SQLException {
+        try (Statement statement = connection.createStatement()) {
+            String query = "insert into persons (name) values ('Foo')";
+            int affectedRows = statement.executeUpdate(query, Statement.RETURN_GENERATED_KEYS);
+            assertThat(affectedRows).isPositive();
+
+            try (ResultSet keys = statement.getGeneratedKeys()) {
+                assertThat(keys.next()).isTrue();
+                assertThat(keys.getLong(1)).isGreaterThanOrEqualTo(1);
+            }
+        }
+    }
+
+    @Test
+    public void givenInsert_whenUsingReturningCols_thenBeAbleToFetchTheIdAfterward() throws SQLException {
+        try (PreparedStatement statement = connection.prepareStatement(QUERY, new String[] { "id" })) {
+            statement.setString(1, "Foo");
+            int affectedRows = statement.executeUpdate();
+            assertThat(affectedRows).isPositive();
+
+            try (ResultSet keys = statement.getGeneratedKeys()) {
+                assertThat(keys.next()).isTrue();
+                assertThat(keys.getLong(1)).isGreaterThanOrEqualTo(1);
+            }
+        }
+    }
+
+    @Test
+    public void givenInsert_whenUsingReturningColsViaExecute_thenBeAbleToFetchTheIdAfterward() throws SQLException {
+        try (Statement statement = connection.createStatement()) {
+            String query = "insert into persons (name) values ('Foo')";
+            int affectedRows = statement.executeUpdate(query, new String[] { "id" });
+            assertThat(affectedRows).isPositive();
+
+            try (ResultSet keys = statement.getGeneratedKeys()) {
+                assertThat(keys.next()).isTrue();
+                assertThat(keys.getLong(1)).isGreaterThanOrEqualTo(1);
+            }
+        }
+    }
+}

persistence-modules/hibernate-enterprise/pom.xml

@@ -55,6 +55,12 @@
             <artifactId>hibernate-testing</artifactId>
             <version>${hibernate.version}</version>
         </dependency>
+        <dependency>
+            <groupId>net.bytebuddy</groupId>
+            <artifactId>byte-buddy</artifactId>
+            <version>${byte-buddy.version}</version>
+            <scope>test</scope>
+        </dependency>
     </dependencies>
 
     <repositories>

persistence-modules/hibernate-exceptions/pom.xml

@@ -0,0 +1,39 @@
+<?xml version="1.0"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
+    <modelVersion>4.0.0</modelVersion>
+    <artifactId>hibernate-exceptions</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+    <name>hibernate-exceptions</name>
+
+    <parent>
+        <groupId>com.baeldung</groupId>
+        <artifactId>persistence-modules</artifactId>
+        <version>1.0.0-SNAPSHOT</version>
+    </parent>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.hsqldb</groupId>
+            <artifactId>hsqldb</artifactId>
+            <version>${hsqldb.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.hibernate</groupId>
+            <artifactId>hibernate-core</artifactId>
+            <version>${hibernate.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>javax.xml.bind</groupId>
+            <artifactId>jaxb-api</artifactId>
+            <version>${jaxb.version}</version>
+        </dependency>
+    </dependencies>
+
+    <properties>
+        <hsqldb.version>2.4.0</hsqldb.version>
+        <jaxb.version>2.3.0</jaxb.version>
+        <hibernate.version>5.3.7.Final</hibernate.version>
+    </properties>
+
+</project>

persistence-modules/hibernate-exceptions/src/main/java/com/baeldung/hibernate/exception/lazyinitialization/HibernateUtil.java

@@ -0,0 +1,42 @@
+package com.baeldung.hibernate.exception.lazyinitialization;
+
+import java.util.Properties;
+
+import org.hibernate.SessionFactory;
+import org.hibernate.boot.registry.StandardServiceRegistryBuilder;
+import org.hibernate.cfg.Configuration;
+import org.hibernate.cfg.Environment;
+import org.hibernate.service.ServiceRegistry;
+
+import com.baeldung.hibernate.exception.lazyinitialization.entity.Role;
+import com.baeldung.hibernate.exception.lazyinitialization.entity.User;
+
+public class HibernateUtil {
+    private static SessionFactory sessionFactory;
+
+    public static SessionFactory getSessionFactory() {
+        if (sessionFactory == null) {
+            try {
+                Configuration configuration = new Configuration();
+                Properties settings = new Properties();
+                settings.put(Environment.DRIVER, "org.hsqldb.jdbcDriver");
+                settings.put(Environment.URL, "jdbc:hsqldb:mem:userrole");
+                settings.put(Environment.USER, "sa");
+                settings.put(Environment.PASS, "");
+                settings.put(Environment.DIALECT, "org.hibernate.dialect.HSQLDialect");
+                settings.put(Environment.SHOW_SQL, "true");
+                settings.put(Environment.HBM2DDL_AUTO, "update");
+                configuration.setProperties(settings);
+                configuration.addAnnotatedClass(User.class);
+                configuration.addAnnotatedClass(Role.class);
+
+                ServiceRegistry serviceRegistry = new StandardServiceRegistryBuilder()
+                        .applySettings(configuration.getProperties()).build();
+                sessionFactory = configuration.buildSessionFactory(serviceRegistry);
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        }
+        return sessionFactory;
+    }
+}

persistence-modules/hibernate-exceptions/src/main/java/com/baeldung/hibernate/exception/lazyinitialization/entity/Role.java

@@ -0,0 +1,45 @@
+package com.baeldung.hibernate.exception.lazyinitialization.entity;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.GenerationType;
+import javax.persistence.Id;
+import javax.persistence.Table;
+
+@Entity
+@Table(name = "role")
+public class Role {
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "id")
+    private int id;
+
+    @Column(name = "role_name")
+    private String roleName;
+
+    public Role() {
+
+    }
+
+    public Role(String roleName) {
+        this.roleName = roleName;
+    }
+
+    public int getId() {
+        return id;
+    }
+
+    public void setId(int id) {
+        this.id = id;
+    }
+
+    public String getRoleName() {
+        return roleName;
+    }
+
+    public void setRoleName(String roleName) {
+        this.roleName = roleName;
+    }
+
+}

persistence-modules/hibernate-exceptions/src/main/java/com/baeldung/hibernate/exception/lazyinitialization/entity/User.java

@@ -0,0 +1,55 @@
+package com.baeldung.hibernate.exception.lazyinitialization.entity;
+
+import java.util.HashSet;
+import java.util.Set;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.GenerationType;
+import javax.persistence.Id;
+import javax.persistence.JoinColumn;
+import javax.persistence.OneToMany;
+import javax.persistence.Table;
+
+@Entity
+@Table(name = "user")
+public class User {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "id")
+    private int id;
+
+    @Column(name = "first_name")
+    private String firstName;
+
+    @Column(name = "last_name")
+    private String lastName;
+
+    @OneToMany
+    @JoinColumn(name = "user_id")
+    private Set<Role> roles = new HashSet<>();
+
+    public User() {
+
+    }
+
+    public User(String firstName, String lastName) {
+        this.firstName = firstName;
+        this.lastName = lastName;
+    }
+
+    public int getId() {
+        return id;
+    }
+
+    public Set<Role> getRoles() {
+        return roles;
+    }
+
+    public void addRole(Role role) {
+        roles.add(role);
+    }
+
+}

persistence-modules/hibernate-exceptions/src/test/java/com/baeldung/hibernate/exception/lazyinitialization/HibernateNoSessionUnitTest.java

@@ -0,0 +1,85 @@
+package com.baeldung.hibernate.exception.lazyinitialization;
+
+import org.hibernate.LazyInitializationException;
+import org.hibernate.Session;
+import org.hibernate.SessionFactory;
+import org.junit.AfterClass;
+import org.junit.Assert;
+import org.junit.BeforeClass;
+import org.junit.Rule;
+import org.junit.Test;
+import org.junit.rules.ExpectedException;
+
+import com.baeldung.hibernate.exception.lazyinitialization.entity.Role;
+import com.baeldung.hibernate.exception.lazyinitialization.entity.User;
+
+public class HibernateNoSessionUnitTest {
+
+    private static SessionFactory sessionFactory;
+
+    @Rule
+    public ExpectedException thrown = ExpectedException.none();
+
+    @BeforeClass
+    public static void init() {
+        sessionFactory = HibernateUtil.getSessionFactory();
+    }
+
+    @Test
+    public void whenAccessUserRolesInsideSession_thenSuccess() {
+
+        User detachedUser = createUserWithRoles();
+
+        Session session = sessionFactory.openSession();
+        session.beginTransaction();
+
+        User persistentUser = session.find(User.class, detachedUser.getId());
+
+        Assert.assertEquals(2, persistentUser.getRoles().size());
+
+        session.getTransaction().commit();
+        session.close();
+    }
+
+    @Test
+    public void whenAccessUserRolesOutsideSession_thenThrownException() {
+
+        User detachedUser = createUserWithRoles();
+
+        Session session = sessionFactory.openSession();
+        session.beginTransaction();
+
+        User persistentUser = session.find(User.class, detachedUser.getId());
+
+        session.getTransaction().commit();
+        session.close();
+
+        thrown.expect(LazyInitializationException.class);
+        System.out.println(persistentUser.getRoles().size());
+    }
+
+    private User createUserWithRoles() {
+
+        Role admin = new Role("Admin");
+        Role dba = new Role("DBA");
+
+        User user = new User("Bob", "Smith");
+
+        user.addRole(admin);
+        user.addRole(dba);
+
+        Session session = sessionFactory.openSession();
+        session.beginTransaction();
+        user.getRoles().forEach(role -> session.save(role));
+        session.save(user);
+        session.getTransaction().commit();
+        session.close();
+
+        return user;
+    }
+
+    @AfterClass
+    public static void cleanUp() {
+        sessionFactory.close();
+    }
+}

persistence-modules/java-jpa-2/README.md

@@ -13,4 +13,5 @@ This module contains articles about the Java Persistence API (JPA) in Java.
 - [JPA Annotation for the PostgreSQL TEXT Type](https://www.baeldung.com/jpa-annotation-postgresql-text-type)
 - [Mapping a Single Entity to Multiple Tables in JPA](https://www.baeldung.com/jpa-mapping-single-entity-to-multiple-tables)
 - [Constructing a JPA Query Between Unrelated Entities](https://www.baeldung.com/jpa-query-unrelated-entities)
+- [When Does JPA Set the Primary Key](https://www.baeldung.com/jpa-strategies-when-set-primary-key)
 - More articles: [[<-- prev]](/java-jpa)

persistence-modules/java-jpa-2/src/main/java/com/baeldung/jpa/generateidvalue/Admin.java

@@ -0,0 +1,36 @@
+package com.baeldung.jpa.generateidvalue;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.Id;
+import javax.persistence.Table;
+
+@Entity
+@Table(name = "app_admin")
+public class Admin {
+
+    @Id
+    @GeneratedValue
+    private Long id;
+
+    @Column(name = "admin_name")
+    private String name;
+
+    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;
+    }
+
+}

persistence-modules/java-jpa-2/src/main/java/com/baeldung/jpa/generateidvalue/Article.java

@@ -0,0 +1,39 @@
+package com.baeldung.jpa.generateidvalue;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.GenerationType;
+import javax.persistence.Id;
+import javax.persistence.SequenceGenerator;
+import javax.persistence.Table;
+
+@Entity
+@Table(name = "article")
+public class Article {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.SEQUENCE, generator = "article_gen")
+    @SequenceGenerator(name = "article_gen", sequenceName = "article_seq")
+    private Long id;
+
+    @Column(name = "article_name")
+    private String name;
+
+    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;
+    }
+
+}

persistence-modules/java-jpa-2/src/main/java/com/baeldung/jpa/generateidvalue/IdGenerator.java

@@ -0,0 +1,48 @@
+package com.baeldung.jpa.generateidvalue;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.GenerationType;
+import javax.persistence.Id;
+import javax.persistence.Table;
+
+@Table(name = "id_gen")
+@Entity
+public class IdGenerator {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @Column(name = "gen_name")
+    private String gen_name;
+
+    @Column(name = "gen_value")
+    private Long gen_value;
+
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public String getGen_name() {
+        return gen_name;
+    }
+
+    public void setGen_name(String gen_name) {
+        this.gen_name = gen_name;
+    }
+
+    public Long getGen_value() {
+        return gen_value;
+    }
+
+    public void setGen_value(Long gen_value) {
+        this.gen_value = gen_value;
+    }
+
+}

persistence-modules/java-jpa-2/src/main/java/com/baeldung/jpa/generateidvalue/Task.java

@@ -0,0 +1,39 @@
+package com.baeldung.jpa.generateidvalue;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.GenerationType;
+import javax.persistence.Id;
+import javax.persistence.Table;
+import javax.persistence.TableGenerator;
+
+@Entity
+@Table(name = "task")
+public class Task {
+
+    @Id
+    @TableGenerator(name = "id_generator", table = "id_gen", pkColumnName = "gen_name", valueColumnName = "gen_value", pkColumnValue = "task_gen", initialValue = 10000, allocationSize = 10)
+    @GeneratedValue(strategy = GenerationType.TABLE, generator = "id_generator")
+    private Long id;
+
+    @Column(name = "name")
+    private String name;
+
+    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;
+    }
+
+}

persistence-modules/java-jpa-2/src/main/java/com/baeldung/jpa/generateidvalue/User.java

@@ -0,0 +1,37 @@
+package com.baeldung.jpa.generateidvalue;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.GenerationType;
+import javax.persistence.Id;
+import javax.persistence.Table;
+
+@Entity
+@Table(name = "app_user")
+public class User {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @Column(name = "user_name")
+    private String name;
+
+    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;
+    }
+
+}

persistence-modules/java-jpa-2/src/main/resources/META-INF/persistence.xml

@@ -184,4 +184,29 @@
                       value="false" />
         </properties>
     </persistence-unit>
+
+    <persistence-unit name="jpa-h2-primarykey">
+        <provider>org.eclipse.persistence.jpa.PersistenceProvider</provider>
+        <class>com.baeldung.jpa.generateidvalue.Admin</class>
+        <class>com.baeldung.jpa.generateidvalue.Article</class>
+        <class>com.baeldung.jpa.generateidvalue.IdGenerator</class>
+        <class>com.baeldung.jpa.generateidvalue.Task</class>
+        <class>com.baeldung.jpa.generateidvalue.User</class>
+        <exclude-unlisted-classes>true</exclude-unlisted-classes>
+        <properties>
+            <property name="javax.persistence.jdbc.driver"
+                      value="org.h2.Driver" />
+            <property name="javax.persistence.jdbc.url"
+                      value="jdbc:h2:mem:test" />
+            <property name="javax.persistence.jdbc.user" value="sa" />
+            <property name="javax.persistence.jdbc.password" value="" />
+            <property name="javax.persistence.sql-load-script-source"
+                      value="primary_key_generator.sql" />
+            <property name="eclipselink.ddl-generation" value="create-or-extend-tables" />
+            <property name="eclipselink.ddl-generation.output-mode" value="database" />
+            <property name="eclipselink.weaving" value="static" />
+            <property name="eclipselink.logging.level" value="FINE" />
+            <property name="eclipselink.jdbc.allow-native-sql-queries" value="true" />
+        </properties>
+    </persistence-unit>
 </persistence>

persistence-modules/java-jpa-2/src/main/resources/primary_key_generator.sql

@@ -0,0 +1,4 @@
+CREATE SEQUENCE article_seq MINVALUE 1 START WITH 50 INCREMENT BY 50;
+
+INSERT INTO id_gen (gen_name, gen_val) VALUES ('id_generator', 0); 
+INSERT INTO id_gen (gen_name, gen_val) VALUES ('task_gen', 10000);

persistence-modules/java-jpa-2/src/test/java/com/baeldung/jpa/generateidvalue/PrimaryKeyUnitTest.java

@@ -0,0 +1,81 @@
+package com.baeldung.jpa.generateidvalue;
+
+import javax.persistence.EntityManager;
+import javax.persistence.EntityManagerFactory;
+import javax.persistence.Persistence;
+
+import org.junit.Assert;
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+/**
+ * PrimaryKeyGeneratorTest class
+ * 
+ * @author shiwangzhihe@gmail.com
+ */
+public class PrimaryKeyUnitTest {
+    private static EntityManager entityManager;
+
+    @BeforeClass
+    public static void setup() {
+        EntityManagerFactory factory = Persistence.createEntityManagerFactory("jpa-h2-primarykey");
+        entityManager = factory.createEntityManager();
+    }
+
+    @Test
+    public void givenIdentityStrategy_whenCommitTransction_thenReturnPrimaryKey() {
+        User user = new User();
+        user.setName("TestName");
+
+        entityManager.getTransaction()
+            .begin();
+        entityManager.persist(user);
+        Assert.assertNull(user.getId());
+        entityManager.getTransaction()
+            .commit();
+
+        Long expectPrimaryKey = 1L;
+        Assert.assertEquals(expectPrimaryKey, user.getId());
+    }
+
+    @Test
+    public void givenTableStrategy_whenPersist_thenReturnPrimaryKey() {
+        Task task = new Task();
+        task.setName("Test Task");
+
+        entityManager.getTransaction()
+            .begin();
+        entityManager.persist(task);
+        Long expectPrimaryKey = 10000L;
+        Assert.assertEquals(expectPrimaryKey, task.getId());
+
+        entityManager.getTransaction()
+            .commit();
+    }
+
+    @Test
+    public void givenSequenceStrategy_whenPersist_thenReturnPrimaryKey() {
+        Article article = new Article();
+        article.setName("Test Name");
+
+        entityManager.getTransaction()
+            .begin();
+        entityManager.persist(article);
+        Long expectPrimaryKey = 51L;
+        Assert.assertEquals(expectPrimaryKey, article.getId());
+
+        entityManager.getTransaction()
+            .commit();
+    }
+
+    @Test
+    public void givenAutoStrategy_whenPersist_thenReturnPrimaryKey() {
+        Admin admin = new Admin();
+        admin.setName("Test Name");
+
+        entityManager.persist(admin);
+
+        Long expectPrimaryKey = 1L;
+        Assert.assertEquals(expectPrimaryKey, admin.getId());
+    }
+}

persistence-modules/r2dbc/pom.xml

@@ -4,7 +4,7 @@
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <modelVersion>4.0.0</modelVersion>
     <groupId>com.baeldung.examples.r2dbc</groupId>
-    <artifactId>r2dbc-example</artifactId>
+    <artifactId>r2dbc</artifactId>
     <version>0.0.1-SNAPSHOT</version>
     <name>r2dbc</name>
     <description>Sample R2DBC Project</description>

persistence-modules/redis/README.md

@@ -4,3 +4,4 @@
 - [Introduction to Lettuce – the Java Redis Client](https://www.baeldung.com/java-redis-lettuce)
 - [List All Available Redis Keys](https://www.baeldung.com/redis-list-available-keys)
 - [Spring Data Redis’s Property-Based Configuration](https://www.baeldung.com/spring-data-redis-properties)
+- [Delete Everything in Redis](https://www.baeldung.com/redis-delete-data)

persistence-modules/redis/pom.xml

@@ -33,7 +33,8 @@
         <dependency>
             <groupId>redis.clients</groupId>
             <artifactId>jedis</artifactId>
-            </dependency>
+            <version>3.3.0</version>
+        </dependency>
         <dependency>
             <groupId>com.github.kstyrc</groupId>
             <artifactId>embedded-redis</artifactId>

persistence-modules/redis/src/test/java/com/baeldung/redis/deleteeverything/DeleteEverythingInRedisIntegrationTest.java

@@ -0,0 +1,91 @@
+package com.baeldung.redis.deleteeverything;
+
+import org.junit.*;
+import redis.clients.jedis.Jedis;
+import redis.embedded.RedisServer;
+
+import java.io.IOException;
+import java.net.ServerSocket;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNull;
+
+public class DeleteEverythingInRedisIntegrationTest {
+    private Jedis jedis;
+    private RedisServer redisServer;
+    private int port;
+
+    @Before
+    public void setUp() throws IOException {
+
+        // Take an available port
+        ServerSocket s = new ServerSocket(0);
+        port = s.getLocalPort();
+        s.close();
+
+        redisServer = new RedisServer(port);
+        redisServer.start();
+
+        // Configure JEDIS
+        jedis = new Jedis("localhost", port);
+    }
+
+    @After
+    public void destroy() {
+        redisServer.stop();
+    }
+
+    @Test
+    public void whenPutDataIntoRedis_thenCanBeFound() {
+        String key = "key";
+        String value = "value";
+
+        jedis.set(key, value);
+        String received = jedis.get(key);
+
+        assertEquals(value, received);
+    }
+
+    @Test
+    public void whenPutDataIntoRedisAndThenFlush_thenCannotBeFound() {
+        String key = "key";
+        String value = "value";
+
+        jedis.set(key, value);
+
+        jedis.flushDB();
+
+        String received = jedis.get(key);
+
+        assertNull(received);
+    }
+
+    @Test
+    public void whenPutDataIntoMultipleDatabases_thenFlushAllRemovesAll() {
+        // add keys in different databases
+        jedis.select(0);
+        jedis.set("key1", "value1");
+        jedis.select(1);
+        jedis.set("key2", "value2");
+
+        // we'll find the correct keys in the correct dbs
+        jedis.select(0);
+        assertEquals("value1", jedis.get("key1"));
+        assertNull(jedis.get("key2"));
+
+        jedis.select(1);
+        assertEquals("value2", jedis.get("key2"));
+        assertNull(jedis.get("key1"));
+
+        // then, when we flush
+        jedis.flushAll();
+
+        // the keys will have gone
+        jedis.select(0);
+        assertNull(jedis.get("key1"));
+        assertNull(jedis.get("key2"));
+        jedis.select(1);
+        assertNull(jedis.get("key1"));
+        assertNull(jedis.get("key2"));
+    }
+}

persistence-modules/spring-boot-persistence-h2/pom.xml

@@ -40,11 +40,6 @@
             <artifactId>db-util</artifactId>
             <version>${db-util.version}</version>
         </dependency>
-        <dependency>
-            <groupId>net.bytebuddy</groupId>
-            <artifactId>byte-buddy</artifactId>
-            <version>${byte-buddy.version}</version>
-        </dependency>
     </dependencies>
 
     <properties>

persistence-modules/spring-boot-persistence/pom.xml

@@ -77,7 +77,6 @@
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <mockito.version>2.23.0</mockito.version>
         <validation-api.version>2.0.1.Final</validation-api.version>
-        <spring-boot.version>2.1.7.RELEASE</spring-boot.version>
     </properties>
 
 </project>

persistence-modules/spring-data-elasticsearch/pom.xml

@@ -15,13 +15,7 @@
     <dependencies>
         <dependency>
             <groupId>org.springframework</groupId>
-            <artifactId>spring-core</artifactId>
-            <version>${spring.version}</version>
-        </dependency>
-
-        <dependency>
-            <groupId>org.springframework</groupId>
-            <artifactId>spring-context</artifactId>
+            <artifactId>spring-web</artifactId>
             <version>${spring.version}</version>
         </dependency>
 
@@ -36,6 +30,7 @@
             <artifactId>elasticsearch</artifactId>
             <version>${elasticsearch.version}</version>
         </dependency>
+        
         <dependency>
             <groupId>com.alibaba</groupId>
             <artifactId>fastjson</artifactId>
@@ -49,8 +44,8 @@
         </dependency>
 
         <dependency>
-            <groupId>com.vividsolutions</groupId>
-            <artifactId>jts</artifactId>
+            <groupId>org.locationtech.jts</groupId>
+            <artifactId>jts-core</artifactId>
             <version>${jts.version}</version>
             <exclusions>
                 <exclusion>
@@ -60,41 +55,19 @@
             </exclusions>
         </dependency>
 
-        <dependency>
-            <groupId>org.apache.logging.log4j</groupId>
-            <artifactId>log4j-core</artifactId>
-            <version>${log4j.version}</version>
-        </dependency>
-
-        <dependency>
-            <groupId>org.elasticsearch.client</groupId>
-            <artifactId>transport</artifactId>
-            <version>${elasticsearch.version}</version>
-        </dependency>
-
         <dependency>
             <groupId>org.springframework</groupId>
             <artifactId>spring-test</artifactId>
             <version>${spring.version}</version>
             <scope>test</scope>
         </dependency>
-
-        <dependency>
-            <groupId>net.java.dev.jna</groupId>
-            <artifactId>jna</artifactId>
-            <version>${jna.version}</version>
-            <scope>test</scope>
-        </dependency>
     </dependencies>
 
     <properties>
-        <spring-data-elasticsearch.version>3.0.8.RELEASE</spring-data-elasticsearch.version>
-        <jna.version>4.5.2</jna.version>
-        <elasticsearch.version>5.6.0</elasticsearch.version>
+        <spring-data-elasticsearch.version>4.0.0.RELEASE</spring-data-elasticsearch.version>
+        <elasticsearch.version>7.6.2</elasticsearch.version>
         <fastjson.version>1.2.47</fastjson.version>
-        <spatial4j.version>0.6</spatial4j.version>
-        <jts.version>1.13</jts.version>
-        <log4j.version>2.9.1</log4j.version>
+        <spatial4j.version>0.7</spatial4j.version>
+        <jts.version>1.15.0</jts.version>
     </properties>
-
 </project>

persistence-modules/spring-data-elasticsearch/src/main/java/com/baeldung/spring/data/es/config/Config.java

@@ -1,19 +1,13 @@
 package com.baeldung.spring.data.es.config;
 
-import java.net.InetAddress;
-import java.net.UnknownHostException;
-
-import org.elasticsearch.client.Client;
-import org.elasticsearch.client.transport.TransportClient;
-import org.elasticsearch.common.settings.Settings;
-import org.elasticsearch.common.transport.InetSocketTransportAddress;
-import org.elasticsearch.transport.client.PreBuiltTransportClient;
-import org.springframework.beans.factory.annotation.Value;
+import org.elasticsearch.client.RestHighLevelClient;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.ComponentScan;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.data.elasticsearch.client.ClientConfiguration;
+import org.springframework.data.elasticsearch.client.RestClients;
 import org.springframework.data.elasticsearch.core.ElasticsearchOperations;
-import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;
+import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
 import org.springframework.data.elasticsearch.repository.config.EnableElasticsearchRepositories;
 
 @Configuration
@@ -21,30 +15,18 @@ import org.springframework.data.elasticsearch.repository.config.EnableElasticsea
 @ComponentScan(basePackages = { "com.baeldung.spring.data.es.service" })
 public class Config {
 
-    @Value("${elasticsearch.home:/usr/local/Cellar/elasticsearch/5.6.0}")
-    private String elasticsearchHome;
-
-    @Value("${elasticsearch.cluster.name:elasticsearch}")
-    private String clusterName;
-
     @Bean
-    public Client client() {
-        TransportClient client = null;
-        try {
-            final Settings elasticsearchSettings = Settings.builder()
-              .put("client.transport.sniff", true)
-              .put("path.home", elasticsearchHome)
-              .put("cluster.name", clusterName).build();
-            client = new PreBuiltTransportClient(elasticsearchSettings);
-            client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
-        } catch (UnknownHostException e) {
-            e.printStackTrace();
-        }
-        return client;
+    RestHighLevelClient client() {
+        ClientConfiguration clientConfiguration = ClientConfiguration.builder()
+            .connectedTo("localhost:9200")
+            .build();
+
+        return RestClients.create(clientConfiguration)
+            .rest();
     }
 
     @Bean
     public ElasticsearchOperations elasticsearchTemplate() {
-        return new ElasticsearchTemplate(client());
+        return new ElasticsearchRestTemplate(client());
     }
 }

persistence-modules/spring-data-elasticsearch/src/main/java/com/baeldung/spring/data/es/model/Author.java

@@ -1,7 +1,12 @@
 package com.baeldung.spring.data.es.model;
 
+import static org.springframework.data.elasticsearch.annotations.FieldType.Text;
+
+import org.springframework.data.elasticsearch.annotations.Field;
+
 public class Author {
 
+    @Field(type = Text)
     private String name;
 
     public Author() {

persistence-modules/spring-data-elasticsearch/src/main/java/com/baeldung/spring/data/es/service/ArticleService.java

@@ -1,28 +0,0 @@
-package com.baeldung.spring.data.es.service;
-
-import java.util.Optional;
-
-import org.springframework.data.domain.Page;
-import org.springframework.data.domain.Pageable;
-
-import com.baeldung.spring.data.es.model.Article;
-
-public interface ArticleService {
-    Article save(Article article);
-
-    Optional<Article> findOne(String id);
-
-    Iterable<Article> findAll();
-
-    Page<Article> findByAuthorName(String name, Pageable pageable);
-
-    Page<Article> findByAuthorNameUsingCustomQuery(String name, Pageable pageable);
-
-    Page<Article> findByFilteredTagQuery(String tag, Pageable pageable);
-
-    Page<Article> findByAuthorsNameAndFilteredTagQuery(String name, String tag, Pageable pageable);
-
-    long count();
-
-    void delete(Article article);
-}

persistence-modules/spring-data-elasticsearch/src/main/java/com/baeldung/spring/data/es/service/ArticleServiceImpl.java

@@ -1,67 +0,0 @@
-package com.baeldung.spring.data.es.service;
-
-import java.util.Optional;
-
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.data.domain.Page;
-import org.springframework.data.domain.Pageable;
-import org.springframework.stereotype.Service;
-
-import com.baeldung.spring.data.es.model.Article;
-import com.baeldung.spring.data.es.repository.ArticleRepository;
-
-@Service
-public class ArticleServiceImpl implements ArticleService {
-
-    private final ArticleRepository articleRepository;
-    
-    @Autowired
-    public ArticleServiceImpl(ArticleRepository articleRepository) {
-        this.articleRepository = articleRepository;
-    }
-
-    @Override
-    public Article save(Article article) {
-        return articleRepository.save(article);
-    }
-
-    @Override
-    public Optional<Article> findOne(String id) {
-        return articleRepository.findById(id);
-    }
-
-    @Override
-    public Iterable<Article> findAll() {
-        return articleRepository.findAll();
-    }
-
-    @Override
-    public Page<Article> findByAuthorName(String name, Pageable pageable) {
-        return articleRepository.findByAuthorsName(name, pageable);
-    }
-
-    @Override
-    public Page<Article> findByAuthorNameUsingCustomQuery(String name, Pageable pageable) {
-        return articleRepository.findByAuthorsNameUsingCustomQuery(name, pageable);
-    }
-
-    @Override
-    public Page<Article> findByFilteredTagQuery(String tag, Pageable pageable) {
-        return articleRepository.findByFilteredTagQuery(tag, pageable);
-    }
-
-    @Override
-    public Page<Article> findByAuthorsNameAndFilteredTagQuery(String name, String tag, Pageable pageable) {
-        return articleRepository.findByAuthorsNameAndFilteredTagQuery(name, tag, pageable);
-    }
-
-    @Override
-    public long count() {
-        return articleRepository.count();
-    }
-
-    @Override
-    public void delete(Article article) {
-        articleRepository.delete(article);
-    }
-}

persistence-modules/spring-data-elasticsearch/src/test/java/com/baeldung/SpringContextManualTest.java

@@ -8,10 +8,10 @@ import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 import com.baeldung.spring.data.es.config.Config;
 
 /**
+ * This Manual test requires: Elasticsearch instance running on localhost:9200.
  * 
- * This Manual test requires:
- * * Elasticsearch instance running on host
- *
+ * The following docker command can be used: docker run -d --name es762 -p
+ * 9200:9200 -e "discovery.type=single-node" elasticsearch:7.6.2
  */
 @RunWith(SpringJUnit4ClassRunner.class)
 @ContextConfiguration(classes = Config.class)

persistence-modules/spring-data-elasticsearch/src/test/java/com/baeldung/elasticsearch/ElasticSearchManualTest.java

@@ -3,43 +3,48 @@ package com.baeldung.elasticsearch;
 import static org.junit.Assert.assertEquals;
 
 import java.io.IOException;
-import java.net.InetAddress;
 import java.net.UnknownHostException;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Date;
 import java.util.List;
 import java.util.stream.Collectors;
+import java.util.stream.Stream;
+
+import com.alibaba.fastjson.JSON;
 
 import org.elasticsearch.action.DocWriteResponse.Result;
+import org.elasticsearch.action.delete.DeleteRequest;
 import org.elasticsearch.action.delete.DeleteResponse;
+import org.elasticsearch.action.get.GetRequest;
+import org.elasticsearch.action.get.GetResponse;
+import org.elasticsearch.action.index.IndexRequest;
 import org.elasticsearch.action.index.IndexResponse;
+import org.elasticsearch.action.search.SearchRequest;
 import org.elasticsearch.action.search.SearchResponse;
 import org.elasticsearch.action.search.SearchType;
-import org.elasticsearch.client.Client;
-import org.elasticsearch.common.settings.Settings;
-import org.elasticsearch.common.transport.InetSocketTransportAddress;
+import org.elasticsearch.client.RequestOptions;
+import org.elasticsearch.client.RestHighLevelClient;
 import org.elasticsearch.common.xcontent.XContentBuilder;
 import org.elasticsearch.common.xcontent.XContentFactory;
 import org.elasticsearch.common.xcontent.XContentType;
 import org.elasticsearch.index.query.QueryBuilders;
 import org.elasticsearch.search.SearchHit;
-import org.elasticsearch.transport.client.PreBuiltTransportClient;
+import org.elasticsearch.search.builder.SearchSourceBuilder;
 import org.junit.Before;
 import org.junit.Test;
-
-import com.alibaba.fastjson.JSON;
+import org.springframework.data.elasticsearch.client.ClientConfiguration;
+import org.springframework.data.elasticsearch.client.RestClients;
 
 /**
+ * This Manual test requires: Elasticsearch instance running on localhost:9200.
  * 
- * This Manual test requires:
- * * Elasticsearch instance running on host
- * * with cluster name = elasticsearch
- *
+ * The following docker command can be used: docker run -d --name es762 -p
+ * 9200:9200 -e "discovery.type=single-node" elasticsearch:7.6.2
  */
 public class ElasticSearchManualTest {
     private List<Person> listOfPersons = new ArrayList<>();
-    private Client client = null;
+    private RestHighLevelClient client = null;
 
     @Before
     public void setUp() throws UnknownHostException {
@@ -47,115 +52,122 @@ public class ElasticSearchManualTest {
         Person person2 = new Person(25, "Janette Doe", new Date());
         listOfPersons.add(person1);
         listOfPersons.add(person2);
-        
-        client = new PreBuiltTransportClient(Settings.builder().put("client.transport.sniff", true)
-            .put("cluster.name","elasticsearch").build())
-            .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
+
+        ClientConfiguration clientConfiguration = ClientConfiguration.builder()
+            .connectedTo("localhost:9200")
+            .build();
+        client = RestClients.create(clientConfiguration)
+            .rest();
     }
 
     @Test
-    public void givenJsonString_whenJavaObject_thenIndexDocument() {
+    public void givenJsonString_whenJavaObject_thenIndexDocument() throws Exception {
         String jsonObject = "{\"age\":20,\"dateOfBirth\":1471466076564,\"fullName\":\"John Doe\"}";
-        IndexResponse response = client
-          .prepareIndex("people", "Doe")
-          .setSource(jsonObject, XContentType.JSON)
-          .get();
+        IndexRequest request = new IndexRequest("people");
+        request.source(jsonObject, XContentType.JSON);
+
+        IndexResponse response = client.index(request, RequestOptions.DEFAULT);
         String index = response.getIndex();
-        String type = response.getType();
+        long version = response.getVersion();
 
         assertEquals(Result.CREATED, response.getResult());
-        assertEquals(index, "people");
-        assertEquals(type, "Doe");
+        assertEquals(1, version);
+        assertEquals("people", index);
     }
 
     @Test
-    public void givenDocumentId_whenJavaObject_thenDeleteDocument() {
+    public void givenDocumentId_whenJavaObject_thenDeleteDocument() throws Exception {
         String jsonObject = "{\"age\":10,\"dateOfBirth\":1471455886564,\"fullName\":\"Johan Doe\"}";
-        IndexResponse response = client
-          .prepareIndex("people", "Doe")
-          .setSource(jsonObject, XContentType.JSON)
-          .get();
+        IndexRequest indexRequest = new IndexRequest("people");
+        indexRequest.source(jsonObject, XContentType.JSON);
+
+        IndexResponse response = client.index(indexRequest, RequestOptions.DEFAULT);
         String id = response.getId();
-        DeleteResponse deleteResponse = client
-          .prepareDelete("people", "Doe", id)
-          .get();
 
-        assertEquals(Result.DELETED,deleteResponse.getResult());
+        GetRequest getRequest = new GetRequest("people");
+        getRequest.id(id);
+
+        GetResponse getResponse = client.get(getRequest, RequestOptions.DEFAULT);
+        System.out.println(getResponse.getSourceAsString());
+
+        DeleteRequest deleteRequest = new DeleteRequest("people");
+        deleteRequest.id(id);
+
+        DeleteResponse deleteResponse = client.delete(deleteRequest, RequestOptions.DEFAULT);
+
+        assertEquals(Result.DELETED, deleteResponse.getResult());
     }
 
     @Test
-    public void givenSearchRequest_whenMatchAll_thenReturnAllResults() {
-        SearchResponse response = client
-          .prepareSearch()
-          .execute()
-          .actionGet();
-        SearchHit[] searchHits = response
-          .getHits()
-          .getHits();
+    public void givenSearchRequest_whenMatchAll_thenReturnAllResults() throws Exception {
+        SearchRequest searchRequest = new SearchRequest();
+        SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
+        SearchHit[] searchHits = response.getHits()
+            .getHits();
         List<Person> results = Arrays.stream(searchHits)
-          .map(hit -> JSON.parseObject(hit.getSourceAsString(), Person.class))
-          .collect(Collectors.toList());
+            .map(hit -> JSON.parseObject(hit.getSourceAsString(), Person.class))
+            .collect(Collectors.toList());
+
+        results.forEach(System.out::println);
     }
 
     @Test
-    public void givenSearchParameters_thenReturnResults() {
-        SearchResponse response = client
-          .prepareSearch()
-          .setTypes()
-          .setSearchType(SearchType.DFS_QUERY_THEN_FETCH)
-          .setPostFilter(QueryBuilders
-            .rangeQuery("age")
+    public void givenSearchParameters_thenReturnResults() throws Exception {
+        SearchSourceBuilder builder = new SearchSourceBuilder().postFilter(QueryBuilders.rangeQuery("age")
             .from(5)
-            .to(15))
-          .setFrom(0)
-          .setSize(60)
-          .setExplain(true)
-          .execute()
-          .actionGet();
+            .to(15));
 
-        SearchResponse response2 = client
-          .prepareSearch()
-          .setTypes()
-          .setSearchType(SearchType.DFS_QUERY_THEN_FETCH)
-          .setPostFilter(QueryBuilders.simpleQueryStringQuery("+John -Doe OR Janette"))
-          .setFrom(0)
-          .setSize(60)
-          .setExplain(true)
-          .execute()
-          .actionGet();
+        SearchRequest searchRequest = new SearchRequest();
+        searchRequest.searchType(SearchType.DFS_QUERY_THEN_FETCH);
+        searchRequest.source(builder);
+
+        SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
+
+        builder = new SearchSourceBuilder().postFilter(QueryBuilders.simpleQueryStringQuery("+John -Doe OR Janette"));
+
+        searchRequest = new SearchRequest();
+        searchRequest.searchType(SearchType.DFS_QUERY_THEN_FETCH);
+        searchRequest.source(builder);
+
+        SearchResponse response2 = client.search(searchRequest, RequestOptions.DEFAULT);
+
+        builder = new SearchSourceBuilder().postFilter(QueryBuilders.matchQuery("John", "Name*"));
+        searchRequest = new SearchRequest();
+        searchRequest.searchType(SearchType.DFS_QUERY_THEN_FETCH);
+        searchRequest.source(builder);
+
+        SearchResponse response3 = client.search(searchRequest, RequestOptions.DEFAULT);
 
-        SearchResponse response3 = client
-          .prepareSearch()
-          .setTypes()
-          .setSearchType(SearchType.DFS_QUERY_THEN_FETCH)
-          .setPostFilter(QueryBuilders.matchQuery("John", "Name*"))
-          .setFrom(0)
-          .setSize(60)
-          .setExplain(true)
-          .execute()
-          .actionGet();
         response2.getHits();
         response3.getHits();
 
-        final List<Person> results = Arrays.stream(response.getHits().getHits())
-          .map(hit -> JSON.parseObject(hit.getSourceAsString(), Person.class))
-          .collect(Collectors.toList());
+        final List<Person> results = Stream.of(response.getHits()
+            .getHits(),
+            response2.getHits()
+                .getHits(),
+            response3.getHits()
+                .getHits())
+            .flatMap(Arrays::stream)
+            .map(hit -> JSON.parseObject(hit.getSourceAsString(), Person.class))
+            .collect(Collectors.toList());
+
+        results.forEach(System.out::println);
     }
 
     @Test
     public void givenContentBuilder_whenHelpers_thanIndexJson() throws IOException {
-        XContentBuilder builder = XContentFactory
-          .jsonBuilder()
-          .startObject()
-          .field("fullName", "Test")
-          .field("salary", "11500")
-          .field("age", "10")
-          .endObject();
-        IndexResponse response = client
-          .prepareIndex("people", "Doe")
-          .setSource(builder)
-          .get();
+        XContentBuilder builder = XContentFactory.jsonBuilder()
+            .startObject()
+            .field("fullName", "Test")
+            .field("salary", "11500")
+            .field("age", "10")
+            .endObject();
 
-        assertEquals(Result.CREATED, response.getResult());        
+        IndexRequest indexRequest = new IndexRequest("people");
+        indexRequest.source(builder);
+
+        IndexResponse response = client.index(indexRequest, RequestOptions.DEFAULT);
+
+        assertEquals(Result.CREATED, response.getResult());
     }
 }

persistence-modules/spring-data-elasticsearch/src/test/java/com/baeldung/elasticsearch/GeoQueriesManualTest.java

@@ -1,4 +1,5 @@
 package com.baeldung.elasticsearch;
+
 import static org.junit.Assert.assertTrue;
 
 import java.io.IOException;
@@ -7,162 +8,169 @@ import java.util.Arrays;
 import java.util.List;
 import java.util.stream.Collectors;
 
-import org.elasticsearch.action.admin.indices.create.CreateIndexRequest;
+import com.baeldung.spring.data.es.config.Config;
+
+import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest;
+import org.elasticsearch.action.admin.indices.refresh.RefreshRequest;
+import org.elasticsearch.action.index.IndexRequest;
 import org.elasticsearch.action.index.IndexResponse;
+import org.elasticsearch.action.search.SearchRequest;
 import org.elasticsearch.action.search.SearchResponse;
-import org.elasticsearch.client.Client;
+import org.elasticsearch.client.RequestOptions;
+import org.elasticsearch.client.RestHighLevelClient;
+import org.elasticsearch.client.indices.CreateIndexRequest;
 import org.elasticsearch.common.geo.GeoPoint;
 import org.elasticsearch.common.geo.ShapeRelation;
-import org.elasticsearch.common.geo.builders.ShapeBuilders;
+import org.elasticsearch.common.geo.builders.EnvelopeBuilder;
 import org.elasticsearch.common.unit.DistanceUnit;
 import org.elasticsearch.common.xcontent.XContentType;
+import org.elasticsearch.index.query.GeoShapeQueryBuilder;
 import org.elasticsearch.index.query.QueryBuilder;
 import org.elasticsearch.index.query.QueryBuilders;
 import org.elasticsearch.search.SearchHit;
+import org.elasticsearch.search.builder.SearchSourceBuilder;
 import org.junit.After;
 import org.junit.Before;
 import org.junit.Test;
 import org.junit.runner.RunWith;
+import org.locationtech.jts.geom.Coordinate;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;
 import org.springframework.test.context.ContextConfiguration;
 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 
-import com.baeldung.spring.data.es.config.Config;
-import com.vividsolutions.jts.geom.Coordinate;
-
 /**
+ * This Manual test requires: Elasticsearch instance running on localhost:9200.
  * 
- * This Manual test requires:
- * * Elasticsearch instance running on host
- * * with cluster name = elasticsearch
- * * and further configurations
- *
+ * The following docker command can be used: docker run -d --name es762 -p
+ * 9200:9200 -e "discovery.type=single-node" elasticsearch:7.6.2
  */
 @RunWith(SpringJUnit4ClassRunner.class)
 @ContextConfiguration(classes = Config.class)
 public class GeoQueriesManualTest {
 
     private static final String WONDERS_OF_WORLD = "wonders-of-world";
-    private static final String WONDERS = "Wonders";
 
     @Autowired
-    private ElasticsearchTemplate elasticsearchTemplate;
-
-    @Autowired
-    private Client client;
+    private RestHighLevelClient client;
 
     @Before
-    public void setUp() {
-        String jsonObject = "{\"Wonders\":{\"properties\":{\"name\":{\"type\":\"string\",\"index\":\"not_analyzed\"},\"region\":{\"type\":\"geo_shape\",\"tree\":\"quadtree\",\"precision\":\"1m\"},\"location\":{\"type\":\"geo_point\"}}}}";
+    public void setUp() throws Exception {
+        String jsonObject = "{\"properties\":{\"name\":{\"type\":\"text\",\"index\":false},\"region\":{\"type\":\"geo_shape\"},\"location\":{\"type\":\"geo_point\"}}}";
+
         CreateIndexRequest req = new CreateIndexRequest(WONDERS_OF_WORLD);
-        req.mapping(WONDERS, jsonObject, XContentType.JSON);
-        client.admin()
-          .indices()
-          .create(req)
-          .actionGet();
+        req.mapping(jsonObject, XContentType.JSON);
+
+        client.indices()
+            .create(req, RequestOptions.DEFAULT);
     }
 
     @Test
-    public void givenGeoShapeData_whenExecutedGeoShapeQuery_thenResultNonEmpty() throws IOException{
+    public void givenGeoShapeData_whenExecutedGeoShapeQuery_thenResultNonEmpty() throws IOException {
         String jsonObject = "{\"name\":\"Agra\",\"region\":{\"type\":\"envelope\",\"coordinates\":[[75,30.2],[80.1, 25]]}}";
-        IndexResponse response = client.prepareIndex(WONDERS_OF_WORLD, WONDERS)
-          .setSource(jsonObject, XContentType.JSON)
-          .get();
-        
+        IndexRequest indexRequest = new IndexRequest(WONDERS_OF_WORLD);
+        indexRequest.source(jsonObject, XContentType.JSON);
+        IndexResponse response = client.index(indexRequest, RequestOptions.DEFAULT);
+
         String tajMahalId = response.getId();
-        client.admin()
-          .indices()
-          .prepareRefresh(WONDERS_OF_WORLD)
-          .get();
 
-        Coordinate topLeft =new Coordinate(74, 31.2);
-        Coordinate bottomRight =new Coordinate(81.1, 24);
-        QueryBuilder qb = QueryBuilders
-            .geoShapeQuery("region", ShapeBuilders.newEnvelope(topLeft, bottomRight))
-            .relation(ShapeRelation.WITHIN);
+        RefreshRequest refreshRequest = new RefreshRequest(WONDERS_OF_WORLD);
+        client.indices()
+            .refresh(refreshRequest, RequestOptions.DEFAULT);
 
+        Coordinate topLeft = new Coordinate(74, 31.2);
+        Coordinate bottomRight = new Coordinate(81.1, 24);
 
-        SearchResponse searchResponse = client.prepareSearch(WONDERS_OF_WORLD)
-          .setTypes(WONDERS)
-          .setQuery(qb)
-          .execute()
-          .actionGet();
+        GeoShapeQueryBuilder qb = QueryBuilders.geoShapeQuery("region", new EnvelopeBuilder(topLeft, bottomRight).buildGeometry());
+        qb.relation(ShapeRelation.INTERSECTS);
+
+        SearchSourceBuilder source = new SearchSourceBuilder().query(qb);
+        SearchRequest searchRequest = new SearchRequest(WONDERS_OF_WORLD);
+        searchRequest.source(source);
+
+        SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
 
         List<String> ids = Arrays.stream(searchResponse.getHits()
-          .getHits())
-          .map(SearchHit::getId)
-          .collect(Collectors.toList());
+            .getHits())
+            .map(SearchHit::getId)
+            .collect(Collectors.toList());
 
         assertTrue(ids.contains(tajMahalId));
     }
 
     @Test
-    public void givenGeoPointData_whenExecutedGeoBoundingBoxQuery_thenResultNonEmpty() {
+    public void givenGeoPointData_whenExecutedGeoBoundingBoxQuery_thenResultNonEmpty() throws Exception {
         String jsonObject = "{\"name\":\"Pyramids of Giza\",\"location\":[31.131302,29.976480]}";
-        IndexResponse response = client.prepareIndex(WONDERS_OF_WORLD, WONDERS)
-          .setSource(jsonObject, XContentType.JSON)
-          .get();
+
+        IndexRequest indexRequest = new IndexRequest(WONDERS_OF_WORLD);
+        indexRequest.source(jsonObject, XContentType.JSON);
+        IndexResponse response = client.index(indexRequest, RequestOptions.DEFAULT);
+
         String pyramidsOfGizaId = response.getId();
-        client.admin()
-          .indices()
-          .prepareRefresh(WONDERS_OF_WORLD)
-          .get();
+
+        RefreshRequest refreshRequest = new RefreshRequest(WONDERS_OF_WORLD);
+        client.indices()
+            .refresh(refreshRequest, RequestOptions.DEFAULT);
 
         QueryBuilder qb = QueryBuilders.geoBoundingBoxQuery("location")
-            .setCorners(31,30,28,32);
-        
-        SearchResponse searchResponse = client.prepareSearch(WONDERS_OF_WORLD)
-          .setTypes(WONDERS)
-          .setQuery(qb)
-          .execute()
-          .actionGet();
+            .setCorners(31, 30, 28, 32);
+
+        SearchSourceBuilder source = new SearchSourceBuilder().query(qb);
+        SearchRequest searchRequest = new SearchRequest(WONDERS_OF_WORLD);
+        searchRequest.source(source);
+
+        SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
+
         List<String> ids = Arrays.stream(searchResponse.getHits()
-          .getHits())
-          .map(SearchHit::getId)
-          .collect(Collectors.toList());
+            .getHits())
+            .map(SearchHit::getId)
+            .collect(Collectors.toList());
         assertTrue(ids.contains(pyramidsOfGizaId));
     }
 
     @Test
-    public void givenGeoPointData_whenExecutedGeoDistanceQuery_thenResultNonEmpty() {
+    public void givenGeoPointData_whenExecutedGeoDistanceQuery_thenResultNonEmpty() throws Exception {
         String jsonObject = "{\"name\":\"Lighthouse of alexandria\",\"location\":[31.131302,29.976480]}";
-        IndexResponse response = client.prepareIndex(WONDERS_OF_WORLD, WONDERS)
-          .setSource(jsonObject, XContentType.JSON)
-          .get();
+
+        IndexRequest indexRequest = new IndexRequest(WONDERS_OF_WORLD);
+        indexRequest.source(jsonObject, XContentType.JSON);
+        IndexResponse response = client.index(indexRequest, RequestOptions.DEFAULT);
+
         String lighthouseOfAlexandriaId = response.getId();
-        client.admin()
-          .indices()
-          .prepareRefresh(WONDERS_OF_WORLD)
-          .get();
+
+        RefreshRequest refreshRequest = new RefreshRequest(WONDERS_OF_WORLD);
+        client.indices()
+            .refresh(refreshRequest, RequestOptions.DEFAULT);
 
         QueryBuilder qb = QueryBuilders.geoDistanceQuery("location")
-          .point(29.976, 31.131)
-          .distance(10, DistanceUnit.MILES);
+            .point(29.976, 31.131)
+            .distance(10, DistanceUnit.MILES);
+
+        SearchSourceBuilder source = new SearchSourceBuilder().query(qb);
+        SearchRequest searchRequest = new SearchRequest(WONDERS_OF_WORLD);
+        searchRequest.source(source);
+
+        SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
 
-        SearchResponse searchResponse = client.prepareSearch(WONDERS_OF_WORLD)
-          .setTypes(WONDERS)
-          .setQuery(qb)
-          .execute()
-          .actionGet();
         List<String> ids = Arrays.stream(searchResponse.getHits()
-          .getHits())
-          .map(SearchHit::getId)
-          .collect(Collectors.toList());
+            .getHits())
+            .map(SearchHit::getId)
+            .collect(Collectors.toList());
         assertTrue(ids.contains(lighthouseOfAlexandriaId));
     }
 
     @Test
-    public void givenGeoPointData_whenExecutedGeoPolygonQuery_thenResultNonEmpty() {
+    public void givenGeoPointData_whenExecutedGeoPolygonQuery_thenResultNonEmpty() throws Exception {
         String jsonObject = "{\"name\":\"The Great Rann of Kutch\",\"location\":[69.859741,23.733732]}";
-        IndexResponse response = client.prepareIndex(WONDERS_OF_WORLD, WONDERS)
-          .setSource(jsonObject, XContentType.JSON)
-          .get();
+
+        IndexRequest indexRequest = new IndexRequest(WONDERS_OF_WORLD);
+        indexRequest.source(jsonObject, XContentType.JSON);
+        IndexResponse response = client.index(indexRequest, RequestOptions.DEFAULT);
+
         String greatRannOfKutchid = response.getId();
-        client.admin()
-          .indices()
-          .prepareRefresh(WONDERS_OF_WORLD)
-          .get();
+
+        RefreshRequest refreshRequest = new RefreshRequest(WONDERS_OF_WORLD);
+        client.indices()
+            .refresh(refreshRequest, RequestOptions.DEFAULT);
 
         List<GeoPoint> allPoints = new ArrayList<GeoPoint>();
         allPoints.add(new GeoPoint(22.733, 68.859));
@@ -170,20 +178,23 @@ public class GeoQueriesManualTest {
         allPoints.add(new GeoPoint(23, 70.859));
         QueryBuilder qb = QueryBuilders.geoPolygonQuery("location", allPoints);
 
-        SearchResponse searchResponse = client.prepareSearch(WONDERS_OF_WORLD)
-          .setTypes(WONDERS)
-          .setQuery(qb)
-          .execute()
-          .actionGet();
+        SearchSourceBuilder source = new SearchSourceBuilder().query(qb);
+        SearchRequest searchRequest = new SearchRequest(WONDERS_OF_WORLD);
+        searchRequest.source(source);
+
+        SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
+
         List<String> ids = Arrays.stream(searchResponse.getHits()
-          .getHits())
-          .map(SearchHit::getId)
-          .collect(Collectors.toList());
+            .getHits())
+            .map(SearchHit::getId)
+            .collect(Collectors.toList());
         assertTrue(ids.contains(greatRannOfKutchid));
     }
 
     @After
-    public void destroy() {
-        elasticsearchTemplate.deleteIndex(WONDERS_OF_WORLD);
+    public void destroy() throws Exception {
+        DeleteIndexRequest deleteIndex = new DeleteIndexRequest(WONDERS_OF_WORLD);
+        client.indices()
+            .delete(deleteIndex, RequestOptions.DEFAULT);
     }
 }

persistence-modules/spring-data-elasticsearch/src/test/java/com/baeldung/spring/data/es/ElasticSearchManualTest.java

@@ -10,68 +10,71 @@ import static org.junit.Assert.assertNotNull;
 
 import java.util.List;
 
+import com.baeldung.spring.data.es.config.Config;
+import com.baeldung.spring.data.es.model.Article;
+import com.baeldung.spring.data.es.model.Author;
+import com.baeldung.spring.data.es.repository.ArticleRepository;
+
+import org.junit.After;
 import org.junit.Before;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.PageRequest;
-import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;
+import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
+import org.springframework.data.elasticsearch.core.SearchHits;
+import org.springframework.data.elasticsearch.core.mapping.IndexCoordinates;
 import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;
-import org.springframework.data.elasticsearch.core.query.SearchQuery;
+import org.springframework.data.elasticsearch.core.query.Query;
 import org.springframework.test.context.ContextConfiguration;
 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 
-import com.baeldung.spring.data.es.config.Config;
-import com.baeldung.spring.data.es.model.Article;
-import com.baeldung.spring.data.es.model.Author;
-import com.baeldung.spring.data.es.service.ArticleService;
-
 /**
+ * This Manual test requires: Elasticsearch instance running on localhost:9200.
  * 
- * This Manual test requires:
- * * Elasticsearch instance running on host
- * * with cluster name = elasticsearch
- *
+ * The following docker command can be used: docker run -d --name es762 -p
+ * 9200:9200 -e "discovery.type=single-node" elasticsearch:7.6.2
  */
 @RunWith(SpringJUnit4ClassRunner.class)
 @ContextConfiguration(classes = Config.class)
 public class ElasticSearchManualTest {
 
     @Autowired
-    private ElasticsearchTemplate elasticsearchTemplate;
+    private ElasticsearchRestTemplate elasticsearchTemplate;
 
     @Autowired
-    private ArticleService articleService;
+    private ArticleRepository articleRepository;
 
     private final Author johnSmith = new Author("John Smith");
     private final Author johnDoe = new Author("John Doe");
 
     @Before
     public void before() {
-        elasticsearchTemplate.deleteIndex(Article.class);
-        elasticsearchTemplate.createIndex(Article.class);
-        // don't call putMapping() to test the default mappings
-
         Article article = new Article("Spring Data Elasticsearch");
         article.setAuthors(asList(johnSmith, johnDoe));
         article.setTags("elasticsearch", "spring data");
-        articleService.save(article);
+        articleRepository.save(article);
 
         article = new Article("Search engines");
         article.setAuthors(asList(johnDoe));
         article.setTags("search engines", "tutorial");
-        articleService.save(article);
+        articleRepository.save(article);
 
         article = new Article("Second Article About Elasticsearch");
         article.setAuthors(asList(johnSmith));
         article.setTags("elasticsearch", "spring data");
-        articleService.save(article);
+        articleRepository.save(article);
 
         article = new Article("Elasticsearch Tutorial");
         article.setAuthors(asList(johnDoe));
         article.setTags("elasticsearch");
-        articleService.save(article);
+        articleRepository.save(article);
+    }
+
+    @After
+    public void after() {
+        articleRepository.deleteAll();
     }
 
     @Test
@@ -81,82 +84,85 @@ public class ElasticSearchManualTest {
         Article article = new Article("Making Search Elastic");
         article.setAuthors(authors);
 
-        article = articleService.save(article);
+        article = articleRepository.save(article);
         assertNotNull(article.getId());
     }
 
     @Test
     public void givenPersistedArticles_whenSearchByAuthorsName_thenRightFound() {
-
-        final Page<Article> articleByAuthorName = articleService
-          .findByAuthorName(johnSmith.getName(), PageRequest.of(0, 10));
+        final Page<Article> articleByAuthorName = articleRepository.findByAuthorsName(johnSmith.getName(), PageRequest.of(0, 10));
         assertEquals(2L, articleByAuthorName.getTotalElements());
     }
 
     @Test
     public void givenCustomQuery_whenSearchByAuthorsName_thenArticleIsFound() {
-        final Page<Article> articleByAuthorName = articleService.findByAuthorNameUsingCustomQuery("Smith", PageRequest.of(0, 10));
+        final Page<Article> articleByAuthorName = articleRepository.findByAuthorsNameUsingCustomQuery("Smith", PageRequest.of(0, 10));
         assertEquals(2L, articleByAuthorName.getTotalElements());
     }
 
     @Test
     public void givenTagFilterQuery_whenSearchByTag_thenArticleIsFound() {
-        final Page<Article> articleByAuthorName = articleService.findByFilteredTagQuery("elasticsearch", PageRequest.of(0, 10));
+        final Page<Article> articleByAuthorName = articleRepository.findByFilteredTagQuery("elasticsearch", PageRequest.of(0, 10));
         assertEquals(3L, articleByAuthorName.getTotalElements());
     }
 
     @Test
     public void givenTagFilterQuery_whenSearchByAuthorsName_thenArticleIsFound() {
-        final Page<Article> articleByAuthorName = articleService.findByAuthorsNameAndFilteredTagQuery("Doe", "elasticsearch", PageRequest.of(0, 10));
+        final Page<Article> articleByAuthorName = articleRepository.findByAuthorsNameAndFilteredTagQuery("Doe", "elasticsearch", PageRequest.of(0, 10));
         assertEquals(2L, articleByAuthorName.getTotalElements());
     }
 
     @Test
     public void givenPersistedArticles_whenUseRegexQuery_thenRightArticlesFound() {
+        final Query searchQuery = new NativeSearchQueryBuilder().withFilter(regexpQuery("title", ".*data.*"))
+            .build();
 
-        final SearchQuery searchQuery = new NativeSearchQueryBuilder().withFilter(regexpQuery("title", ".*data.*"))
-          .build();
-        final List<Article> articles = elasticsearchTemplate.queryForList(searchQuery, Article.class);
+        final SearchHits<Article> articles = elasticsearchTemplate.search(searchQuery, Article.class, IndexCoordinates.of("blog"));
 
-        assertEquals(1, articles.size());
+        assertEquals(1, articles.getTotalHits());
     }
 
     @Test
     public void givenSavedDoc_whenTitleUpdated_thenCouldFindByUpdatedTitle() {
-        final SearchQuery searchQuery = new NativeSearchQueryBuilder().withQuery(fuzzyQuery("title", "serch")).build();
-        final List<Article> articles = elasticsearchTemplate.queryForList(searchQuery, Article.class);
+        final Query searchQuery = new NativeSearchQueryBuilder().withQuery(fuzzyQuery("title", "serch"))
+            .build();
+        final SearchHits<Article> articles = elasticsearchTemplate.search(searchQuery, Article.class, IndexCoordinates.of("blog"));
 
-        assertEquals(1, articles.size());
+        assertEquals(1, articles.getTotalHits());
 
-        final Article article = articles.get(0);
+        final Article article = articles.getSearchHit(0)
+            .getContent();
         final String newTitle = "Getting started with Search Engines";
         article.setTitle(newTitle);
-        articleService.save(article);
+        articleRepository.save(article);
 
-        assertEquals(newTitle, articleService.findOne(article.getId()).get().getTitle());
+        assertEquals(newTitle, articleRepository.findById(article.getId())
+            .get()
+            .getTitle());
     }
 
     @Test
     public void givenSavedDoc_whenDelete_thenRemovedFromIndex() {
-
         final String articleTitle = "Spring Data Elasticsearch";
 
-        final SearchQuery searchQuery = new NativeSearchQueryBuilder()
-          .withQuery(matchQuery("title", articleTitle).minimumShouldMatch("75%")).build();
-        final List<Article> articles = elasticsearchTemplate.queryForList(searchQuery, Article.class);
-        assertEquals(1, articles.size());
-        final long count = articleService.count();
+        final Query searchQuery = new NativeSearchQueryBuilder().withQuery(matchQuery("title", articleTitle).minimumShouldMatch("75%"))
+            .build();
+        final SearchHits<Article> articles = elasticsearchTemplate.search(searchQuery, Article.class, IndexCoordinates.of("blog"));
 
-        articleService.delete(articles.get(0));
+        assertEquals(1, articles.getTotalHits());
+        final long count = articleRepository.count();
 
-        assertEquals(count - 1, articleService.count());
+        articleRepository.delete(articles.getSearchHit(0)
+            .getContent());
+
+        assertEquals(count - 1, articleRepository.count());
     }
 
     @Test
     public void givenSavedDoc_whenOneTermMatches_thenFindByTitle() {
-        final SearchQuery searchQuery = new NativeSearchQueryBuilder()
-          .withQuery(matchQuery("title", "Search engines").operator(AND)).build();
-        final List<Article> articles = elasticsearchTemplate.queryForList(searchQuery, Article.class);
-        assertEquals(1, articles.size());
+        final Query searchQuery = new NativeSearchQueryBuilder().withQuery(matchQuery("title", "Search engines").operator(AND))
+            .build();
+        final SearchHits<Article> articles = elasticsearchTemplate.search(searchQuery, Article.class, IndexCoordinates.of("blog"));
+        assertEquals(1, articles.getTotalHits());
     }
 }

persistence-modules/spring-data-elasticsearch/src/test/java/com/baeldung/spring/data/es/ElasticSearchQueryManualTest.java

@@ -2,7 +2,6 @@ package com.baeldung.spring.data.es;
 
 import static java.util.Arrays.asList;
 import static java.util.stream.Collectors.toList;
-import static org.elasticsearch.index.query.Operator.AND;
 import static org.elasticsearch.index.query.QueryBuilders.boolQuery;
 import static org.elasticsearch.index.query.QueryBuilders.matchPhraseQuery;
 import static org.elasticsearch.index.query.QueryBuilders.matchQuery;
@@ -14,190 +13,225 @@ import static org.junit.Assert.assertEquals;
 import java.util.List;
 import java.util.Map;
 
+import com.baeldung.spring.data.es.config.Config;
+import com.baeldung.spring.data.es.model.Article;
+import com.baeldung.spring.data.es.model.Author;
+import com.baeldung.spring.data.es.repository.ArticleRepository;
+
 import org.apache.lucene.search.join.ScoreMode;
+import org.elasticsearch.action.search.SearchRequest;
 import org.elasticsearch.action.search.SearchResponse;
-import org.elasticsearch.client.Client;
+import org.elasticsearch.client.RequestOptions;
+import org.elasticsearch.client.RestHighLevelClient;
 import org.elasticsearch.common.unit.Fuzziness;
 import org.elasticsearch.index.query.MultiMatchQueryBuilder;
+import org.elasticsearch.index.query.Operator;
 import org.elasticsearch.index.query.QueryBuilder;
 import org.elasticsearch.search.aggregations.Aggregation;
 import org.elasticsearch.search.aggregations.AggregationBuilders;
+import org.elasticsearch.search.aggregations.BucketOrder;
 import org.elasticsearch.search.aggregations.bucket.MultiBucketsAggregation;
-import org.elasticsearch.search.aggregations.bucket.terms.StringTerms;
-import org.elasticsearch.search.aggregations.bucket.terms.Terms;
+import org.elasticsearch.search.aggregations.bucket.terms.ParsedStringTerms;
 import org.elasticsearch.search.aggregations.bucket.terms.TermsAggregationBuilder;
+import org.elasticsearch.search.builder.SearchSourceBuilder;
+import org.junit.After;
 import org.junit.Before;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;
+import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
+import org.springframework.data.elasticsearch.core.SearchHits;
+import org.springframework.data.elasticsearch.core.mapping.IndexCoordinates;
+import org.springframework.data.elasticsearch.core.query.NativeSearchQuery;
 import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;
-import org.springframework.data.elasticsearch.core.query.SearchQuery;
 import org.springframework.test.context.ContextConfiguration;
 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 
-import com.baeldung.spring.data.es.config.Config;
-import com.baeldung.spring.data.es.model.Article;
-import com.baeldung.spring.data.es.model.Author;
-import com.baeldung.spring.data.es.service.ArticleService;
-
 /**
+ * This Manual test requires: Elasticsearch instance running on localhost:9200.
  * 
- * This Manual test requires:
- * * Elasticsearch instance running on host
- * * with cluster name = elasticsearch
- *
+ * The following docker command can be used: docker run -d --name es762 -p
+ * 9200:9200 -e "discovery.type=single-node" elasticsearch:7.6.2
  */
 @RunWith(SpringJUnit4ClassRunner.class)
 @ContextConfiguration(classes = Config.class)
 public class ElasticSearchQueryManualTest {
 
     @Autowired
-    private ElasticsearchTemplate elasticsearchTemplate;
+    private ElasticsearchRestTemplate elasticsearchTemplate;
 
     @Autowired
-    private ArticleService articleService;
+    private ArticleRepository articleRepository;
 
     @Autowired
-    private Client client;
+    private RestHighLevelClient client;
 
     private final Author johnSmith = new Author("John Smith");
     private final Author johnDoe = new Author("John Doe");
 
     @Before
     public void before() {
-        elasticsearchTemplate.deleteIndex(Article.class);
-        elasticsearchTemplate.createIndex(Article.class);
-        elasticsearchTemplate.putMapping(Article.class);
-        elasticsearchTemplate.refresh(Article.class);
-
         Article article = new Article("Spring Data Elasticsearch");
         article.setAuthors(asList(johnSmith, johnDoe));
         article.setTags("elasticsearch", "spring data");
-        articleService.save(article);
+        articleRepository.save(article);
 
         article = new Article("Search engines");
         article.setAuthors(asList(johnDoe));
         article.setTags("search engines", "tutorial");
-        articleService.save(article);
+        articleRepository.save(article);
 
         article = new Article("Second Article About Elasticsearch");
         article.setAuthors(asList(johnSmith));
         article.setTags("elasticsearch", "spring data");
-        articleService.save(article);
+        articleRepository.save(article);
 
         article = new Article("Elasticsearch Tutorial");
         article.setAuthors(asList(johnDoe));
         article.setTags("elasticsearch");
-        articleService.save(article);
+        articleRepository.save(article);
+    }
+
+    @After
+    public void after() {
+        articleRepository.deleteAll();
     }
 
     @Test
     public void givenFullTitle_whenRunMatchQuery_thenDocIsFound() {
-        final SearchQuery searchQuery = new NativeSearchQueryBuilder()
-          .withQuery(matchQuery("title", "Search engines").operator(AND)).build();
-        final List<Article> articles = elasticsearchTemplate.queryForList(searchQuery, Article.class);
-        assertEquals(1, articles.size());
+        final NativeSearchQuery searchQuery = new NativeSearchQueryBuilder().withQuery(matchQuery("title", "Search engines").operator(Operator.AND))
+            .build();
+        final SearchHits<Article> articles = elasticsearchTemplate.search(searchQuery, Article.class, IndexCoordinates.of("blog"));
+        assertEquals(1, articles.getTotalHits());
     }
 
     @Test
     public void givenOneTermFromTitle_whenRunMatchQuery_thenDocIsFound() {
-        final SearchQuery searchQuery = new NativeSearchQueryBuilder()
-          .withQuery(matchQuery("title", "Engines Solutions")).build();
-        final List<Article> articles = elasticsearchTemplate.queryForList(searchQuery, Article.class);
-        assertEquals(1, articles.size());
-        assertEquals("Search engines", articles.get(0).getTitle());
+        final NativeSearchQuery searchQuery = new NativeSearchQueryBuilder().withQuery(matchQuery("title", "Engines Solutions"))
+            .build();
+
+        final SearchHits<Article> articles = elasticsearchTemplate.search(searchQuery, Article.class, IndexCoordinates.of("blog"));
+
+        assertEquals(1, articles.getTotalHits());
+        assertEquals("Search engines", articles.getSearchHit(0)
+            .getContent()
+            .getTitle());
     }
 
     @Test
     public void givenPartTitle_whenRunMatchQuery_thenDocIsFound() {
-        final SearchQuery searchQuery = new NativeSearchQueryBuilder()
-          .withQuery(matchQuery("title", "elasticsearch data")).build();
-        final List<Article> articles = elasticsearchTemplate.queryForList(searchQuery, Article.class);
-        assertEquals(3, articles.size());
+        final NativeSearchQuery searchQuery = new NativeSearchQueryBuilder().withQuery(matchQuery("title", "elasticsearch data"))
+            .build();
+
+        final SearchHits<Article> articles = elasticsearchTemplate.search(searchQuery, Article.class, IndexCoordinates.of("blog"));
+
+        assertEquals(3, articles.getTotalHits());
     }
 
     @Test
     public void givenFullTitle_whenRunMatchQueryOnVerbatimField_thenDocIsFound() {
-        SearchQuery searchQuery = new NativeSearchQueryBuilder()
-          .withQuery(matchQuery("title.verbatim", "Second Article About Elasticsearch")).build();
-        List<Article> articles = elasticsearchTemplate.queryForList(searchQuery, Article.class);
-        assertEquals(1, articles.size());
+        NativeSearchQuery searchQuery = new NativeSearchQueryBuilder().withQuery(matchQuery("title.verbatim", "Second Article About Elasticsearch"))
+            .build();
+
+        SearchHits<Article> articles = elasticsearchTemplate.search(searchQuery, Article.class, IndexCoordinates.of("blog"));
+
+        assertEquals(1, articles.getTotalHits());
 
         searchQuery = new NativeSearchQueryBuilder().withQuery(matchQuery("title.verbatim", "Second Article About"))
-          .build();
-        articles = elasticsearchTemplate.queryForList(searchQuery, Article.class);
-        assertEquals(0, articles.size());
+            .build();
+
+        articles = elasticsearchTemplate.search(searchQuery, Article.class, IndexCoordinates.of("blog"));
+        assertEquals(0, articles.getTotalHits());
     }
 
     @Test
     public void givenNestedObject_whenQueryByAuthorsName_thenFoundArticlesByThatAuthor() {
         final QueryBuilder builder = nestedQuery("authors", boolQuery().must(termQuery("authors.name", "smith")), ScoreMode.None);
 
-        final SearchQuery searchQuery = new NativeSearchQueryBuilder().withQuery(builder).build();
-        final List<Article> articles = elasticsearchTemplate.queryForList(searchQuery, Article.class);
+        final NativeSearchQuery searchQuery = new NativeSearchQueryBuilder().withQuery(builder)
+            .build();
+        final SearchHits<Article> articles = elasticsearchTemplate.search(searchQuery, Article.class, IndexCoordinates.of("blog"));
 
-        assertEquals(2, articles.size());
+        assertEquals(2, articles.getTotalHits());
     }
 
     @Test
-    public void givenAnalyzedQuery_whenMakeAggregationOnTermCount_thenEachTokenCountsSeparately() {
-        final TermsAggregationBuilder aggregation = AggregationBuilders.terms("top_tags").field("title");
-        final SearchResponse response = client.prepareSearch("blog").setTypes("article").addAggregation(aggregation)
-          .execute().actionGet();
+    public void givenAnalyzedQuery_whenMakeAggregationOnTermCount_thenEachTokenCountsSeparately() throws Exception {
+        final TermsAggregationBuilder aggregation = AggregationBuilders.terms("top_tags")
+            .field("title");
 
-        final Map<String, Aggregation> results = response.getAggregations().asMap();
-        final StringTerms topTags = (StringTerms) results.get("top_tags");
+        final SearchSourceBuilder builder = new SearchSourceBuilder().aggregation(aggregation);
+        final SearchRequest searchRequest = new SearchRequest("blog").source(builder);
 
-        final List<String> keys = topTags.getBuckets().stream()
-          .map(MultiBucketsAggregation.Bucket::getKeyAsString)
-          .sorted()
-          .collect(toList());
+        final SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
+
+        final Map<String, Aggregation> results = response.getAggregations()
+            .asMap();
+        final ParsedStringTerms topTags = (ParsedStringTerms) results.get("top_tags");
+
+        final List<String> keys = topTags.getBuckets()
+            .stream()
+            .map(MultiBucketsAggregation.Bucket::getKeyAsString)
+            .sorted()
+            .collect(toList());
         assertEquals(asList("about", "article", "data", "elasticsearch", "engines", "search", "second", "spring", "tutorial"), keys);
     }
 
     @Test
-    public void givenNotAnalyzedQuery_whenMakeAggregationOnTermCount_thenEachTermCountsIndividually() {
-        final TermsAggregationBuilder aggregation = AggregationBuilders.terms("top_tags").field("tags")
-          .order(Terms.Order.count(false));
-        final SearchResponse response = client.prepareSearch("blog").setTypes("article").addAggregation(aggregation)
-          .execute().actionGet();
+    public void givenNotAnalyzedQuery_whenMakeAggregationOnTermCount_thenEachTermCountsIndividually() throws Exception {
+        final TermsAggregationBuilder aggregation = AggregationBuilders.terms("top_tags")
+            .field("tags")
+            .order(BucketOrder.count(false));
 
-        final Map<String, Aggregation> results = response.getAggregations().asMap();
-        final StringTerms topTags = (StringTerms) results.get("top_tags");
+        final SearchSourceBuilder builder = new SearchSourceBuilder().aggregation(aggregation);
+        final SearchRequest searchRequest = new SearchRequest().indices("blog")
+            .source(builder);
 
-        final List<String> keys = topTags.getBuckets().stream()
-          .map(MultiBucketsAggregation.Bucket::getKeyAsString)
-          .collect(toList());
+        final SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
+
+        final Map<String, Aggregation> results = response.getAggregations()
+            .asMap();
+        final ParsedStringTerms topTags = (ParsedStringTerms) results.get("top_tags");
+
+        final List<String> keys = topTags.getBuckets()
+            .stream()
+            .map(MultiBucketsAggregation.Bucket::getKeyAsString)
+            .collect(toList());
         assertEquals(asList("elasticsearch", "spring data", "search engines", "tutorial"), keys);
     }
 
     @Test
     public void givenNotExactPhrase_whenUseSlop_thenQueryMatches() {
-        final SearchQuery searchQuery = new NativeSearchQueryBuilder()
-          .withQuery(matchPhraseQuery("title", "spring elasticsearch").slop(1)).build();
-        final List<Article> articles = elasticsearchTemplate.queryForList(searchQuery, Article.class);
-        assertEquals(1, articles.size());
+        final NativeSearchQuery searchQuery = new NativeSearchQueryBuilder().withQuery(matchPhraseQuery("title", "spring elasticsearch").slop(1))
+            .build();
+
+        final SearchHits<Article> articles = elasticsearchTemplate.search(searchQuery, Article.class, IndexCoordinates.of("blog"));
+
+        assertEquals(1, articles.getTotalHits());
     }
 
     @Test
     public void givenPhraseWithType_whenUseFuzziness_thenQueryMatches() {
-        final SearchQuery searchQuery = new NativeSearchQueryBuilder()
-          .withQuery(matchQuery("title", "spring date elasticserch").operator(AND).fuzziness(Fuzziness.ONE)
-            .prefixLength(3)).build();
+        final NativeSearchQuery searchQuery = new NativeSearchQueryBuilder().withQuery(matchQuery("title", "spring date elasticserch").operator(Operator.AND)
+            .fuzziness(Fuzziness.ONE)
+            .prefixLength(3))
+            .build();
 
-        final List<Article> articles = elasticsearchTemplate.queryForList(searchQuery, Article.class);
-        assertEquals(1, articles.size());
+        final SearchHits<Article> articles = elasticsearchTemplate.search(searchQuery, Article.class, IndexCoordinates.of("blog"));
+
+        assertEquals(1, articles.getTotalHits());
     }
 
     @Test
     public void givenMultimatchQuery_whenDoSearch_thenAllProvidedFieldsMatch() {
-        final SearchQuery searchQuery = new NativeSearchQueryBuilder()
-          .withQuery(multiMatchQuery("tutorial").field("title").field("tags")
-            .type(MultiMatchQueryBuilder.Type.BEST_FIELDS)).build();
+        final NativeSearchQuery searchQuery = new NativeSearchQueryBuilder().withQuery(multiMatchQuery("tutorial").field("title")
+            .field("tags")
+            .type(MultiMatchQueryBuilder.Type.BEST_FIELDS))
+            .build();
 
-        final List<Article> articles = elasticsearchTemplate.queryForList(searchQuery, Article.class);
-        assertEquals(2, articles.size());
+        final SearchHits<Article> articles = elasticsearchTemplate.search(searchQuery, Article.class, IndexCoordinates.of("blog"));
+
+        assertEquals(2, articles.getTotalHits());
     }
 
     @Test
@@ -205,10 +239,10 @@ public class ElasticSearchQueryManualTest {
         final QueryBuilder builder = boolQuery().must(nestedQuery("authors", boolQuery().must(termQuery("authors.name", "doe")), ScoreMode.None))
             .filter(termQuery("tags", "elasticsearch"));
 
-        final SearchQuery searchQuery = new NativeSearchQueryBuilder().withQuery(builder)
+        final NativeSearchQuery searchQuery = new NativeSearchQueryBuilder().withQuery(builder)
             .build();
-        final List<Article> articles = elasticsearchTemplate.queryForList(searchQuery, Article.class);
+        final SearchHits<Article> articles = elasticsearchTemplate.search(searchQuery, Article.class, IndexCoordinates.of("blog"));
 
-        assertEquals(2, articles.size());
+        assertEquals(2, articles.getTotalHits());
     }
 }

persistence-modules/spring-data-jpa-5/pom.xml

@@ -1,6 +1,7 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+
     <modelVersion>4.0.0</modelVersion>
     <artifactId>spring-data-jpa-5</artifactId>
     <name>spring-data-jpa-5</name>
@@ -11,7 +12,7 @@
         <version>0.0.1-SNAPSHOT</version>
         <relativePath>../../parent-boot-2</relativePath>
     </parent>
-
+    
     <dependencies>
         <dependency>
             <groupId>org.springframework.boot</groupId>
@@ -28,10 +29,43 @@
             <artifactId>spring-boot-starter-data-jdbc</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-cache</artifactId>
+        </dependency>
+      
         <dependency>
             <groupId>com.h2database</groupId>
             <artifactId>h2</artifactId>
         </dependency>
+      
+        <dependency>
+            <groupId>org.mapstruct</groupId>
+            <artifactId>mapstruct-jdk8</artifactId>
+            <version>1.3.1.Final</version>
+            <scope>provided</scope>
+        </dependency>
+      
     </dependencies>
-</project>
 
+    <build>
+        <sourceDirectory>src/main/java</sourceDirectory>
+        <plugins>
+            <plugin>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>3.8.1</version>
+                <configuration>
+                    <source>1.8</source>
+                    <target>1.8</target>
+                    <annotationProcessorPaths>
+                        <path>
+                            <groupId>org.mapstruct</groupId>
+                            <artifactId>mapstruct-processor</artifactId>
+                            <version>1.3.1.Final</version>
+                        </path>
+                    </annotationProcessorPaths>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+</project>

persistence-modules/spring-data-jpa-5/src/main/java/com/baeldung/partialupdate/PartialUpdateApplication.java

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

persistence-modules/spring-data-jpa-5/src/main/java/com/baeldung/partialupdate/model/ContactPhone.java

@@ -0,0 +1,22 @@
+package com.baeldung.partialupdate.model;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.GenerationType;
+import javax.persistence.Id;
+
+@Entity
+public class ContactPhone {
+    @Id 
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    public long id;
+    @Column(nullable=false)
+    public long customerId;
+    public String phone;
+
+    @Override
+    public String toString() {
+       return phone;
+    }
+}

persistence-modules/spring-data-jpa-5/src/main/java/com/baeldung/partialupdate/model/Customer.java

@@ -0,0 +1,23 @@
+package com.baeldung.partialupdate.model;
+
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.GenerationType;
+import javax.persistence.Id;
+
+@Entity
+public class Customer {
+
+    @Id 
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    public long id;
+    public String name;
+    public String phone;
+    //...
+    public String phone99;
+    
+    @Override public String toString() {
+        return String.format("Customer %s, Phone: %s", 
+                this.name, this.phone);
+    }
+}

persistence-modules/spring-data-jpa-5/src/main/java/com/baeldung/partialupdate/model/CustomerDto.java

@@ -0,0 +1,31 @@
+package com.baeldung.partialupdate.model;
+
+public class CustomerDto {
+    private long id;
+    public String name;
+    public String phone;
+    //...
+    private String phone99;
+
+    public CustomerDto(long id) {
+        this.id = id;
+    }
+
+    public CustomerDto(Customer c) {
+        this.id = c.id;
+        this.name = c.name;
+        this.phone = c.phone;
+    }
+
+    public long getId() {
+        return this.id;
+    }
+
+    public Customer convertToEntity() {
+        Customer c = new Customer();
+        c.id = id;
+        c.name = name;
+        c.phone = phone;
+        return c;
+    }
+}

persistence-modules/spring-data-jpa-5/src/main/java/com/baeldung/partialupdate/model/CustomerStructured.java

@@ -0,0 +1,27 @@
+package com.baeldung.partialupdate.model;
+
+import java.util.List;
+
+import javax.persistence.Entity;
+import javax.persistence.FetchType;
+import javax.persistence.GeneratedValue;
+import javax.persistence.GenerationType;
+import javax.persistence.Id;
+import javax.persistence.OneToMany;
+
+@Entity
+public class CustomerStructured {
+
+    @Id 
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    public long id;
+    public String name;
+    @OneToMany(fetch = FetchType.EAGER, targetEntity = ContactPhone.class, mappedBy = "customerId") 
+    public List<ContactPhone> contactPhones;
+
+    @Override public String toString() {
+        return String.format("Customer %s, Phone: %s", 
+          this.name, this.contactPhones.stream()
+          .map(e -> e.toString()).reduce("", String::concat));
+    }
+}

persistence-modules/spring-data-jpa-5/src/main/java/com/baeldung/partialupdate/repository/ContactPhoneRepository.java

@@ -0,0 +1,12 @@
+package com.baeldung.partialupdate.repository;
+
+import org.springframework.data.repository.CrudRepository;
+import org.springframework.stereotype.Repository;
+
+import com.baeldung.partialupdate.model.ContactPhone;
+
+@Repository
+public interface ContactPhoneRepository extends CrudRepository<ContactPhone, Long> {
+    ContactPhone findById(long id);
+    ContactPhone findByCustomerId(long id);
+}

persistence-modules/spring-data-jpa-5/src/main/java/com/baeldung/partialupdate/repository/CustomerRepository.java

@@ -0,0 +1,18 @@
+package com.baeldung.partialupdate.repository;
+
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.CrudRepository;
+import org.springframework.data.repository.query.Param;
+import org.springframework.stereotype.Repository;
+
+import com.baeldung.partialupdate.model.Customer;
+
+@Repository
+public interface CustomerRepository extends CrudRepository<Customer, Long> {
+    Customer findById(long id);
+
+    @Modifying
+    @Query("update Customer u set u.phone = :phone where u.id = :id")
+    void updatePhone(@Param(value = "id") long id, @Param(value = "phone") String phone);
+}

persistence-modules/spring-data-jpa-5/src/main/java/com/baeldung/partialupdate/repository/CustomerStructuredRepository.java

@@ -0,0 +1,11 @@
+package com.baeldung.partialupdate.repository;
+
+import org.springframework.data.repository.CrudRepository;
+import org.springframework.stereotype.Repository;
+
+import com.baeldung.partialupdate.model.CustomerStructured;
+
+@Repository
+public interface CustomerStructuredRepository extends CrudRepository<CustomerStructured, Long> {
+    CustomerStructured findById(long id);
+}

persistence-modules/spring-data-jpa-5/src/main/java/com/baeldung/partialupdate/service/CustomerService.java

@@ -0,0 +1,87 @@
+package com.baeldung.partialupdate.service;
+
+import javax.transaction.Transactional;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import com.baeldung.partialupdate.model.ContactPhone;
+import com.baeldung.partialupdate.model.Customer;
+import com.baeldung.partialupdate.model.CustomerDto;
+import com.baeldung.partialupdate.model.CustomerStructured;
+import com.baeldung.partialupdate.repository.ContactPhoneRepository;
+import com.baeldung.partialupdate.repository.CustomerRepository;
+import com.baeldung.partialupdate.repository.CustomerStructuredRepository;
+import com.baeldung.partialupdate.util.CustomerMapper;
+
+@Service 
+@Transactional
+public class CustomerService {
+
+    @Autowired 
+    CustomerRepository repo;
+    @Autowired 
+    CustomerStructuredRepository repo2;
+    @Autowired 
+    ContactPhoneRepository repo3;
+    @Autowired 
+    CustomerMapper mapper;
+
+    public Customer getCustomer(long id) {
+        return repo.findById(id);
+    }
+
+    public void updateCustomerWithCustomQuery(long id, String phone) {
+        repo.updatePhone(id, phone);
+    }
+
+    public Customer addCustomer(String name) {
+        Customer myCustomer = new Customer();
+        myCustomer.name = name;
+        repo.save(myCustomer);
+        return myCustomer;
+    }
+
+    public Customer updateCustomer(long id, String phone) {
+        Customer myCustomer = repo.findById(id);
+        myCustomer.phone = phone;
+        repo.save(myCustomer);
+        return myCustomer;
+    }
+
+    public Customer addCustomer(CustomerDto dto) {
+        Customer myCustomer = new Customer();
+        mapper.updateCustomerFromDto(dto, myCustomer);
+        repo.save(myCustomer);
+        return myCustomer;
+    }
+
+    public Customer updateCustomer(CustomerDto dto) {
+        Customer myCustomer = repo.findById(dto.getId());
+        mapper.updateCustomerFromDto(dto, myCustomer);
+        repo.save(myCustomer);
+        return myCustomer;
+    }
+
+    public CustomerStructured addCustomerStructured(String name) {
+        CustomerStructured myCustomer = new CustomerStructured();
+        myCustomer.name = name;
+        repo2.save(myCustomer);
+        return myCustomer;
+    }
+
+    public void addCustomerPhone(long customerId, String phone) {
+        ContactPhone myPhone = new ContactPhone();
+        myPhone.phone = phone;
+        myPhone.customerId =  customerId;
+        repo3.save(myPhone);
+    }
+    
+    public CustomerStructured updateCustomerStructured(long id, String name) {
+        CustomerStructured myCustomer = repo2.findById(id);
+        myCustomer.name = name;
+        repo2.save(myCustomer);
+        return myCustomer;
+    }
+
+}

persistence-modules/spring-data-jpa-5/src/main/java/com/baeldung/partialupdate/util/CustomerMapper.java

@@ -0,0 +1,15 @@
+package com.baeldung.partialupdate.util;
+
+import org.mapstruct.BeanMapping;
+import org.mapstruct.Mapper;
+import org.mapstruct.MappingTarget;
+import org.mapstruct.NullValuePropertyMappingStrategy;
+
+import com.baeldung.partialupdate.model.Customer;
+import com.baeldung.partialupdate.model.CustomerDto;
+
+@Mapper(componentModel = "spring")
+public interface CustomerMapper {
+    @BeanMapping(nullValuePropertyMappingStrategy = NullValuePropertyMappingStrategy.IGNORE)
+    void updateCustomerFromDto(CustomerDto dto, @MappingTarget Customer entity);
+}

persistence-modules/spring-data-jpa-5/src/test/java/com/baeldung/partialupdate/PartialUpdateUnitTest.java

@@ -0,0 +1,63 @@
+package com.baeldung.partialupdate;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotEquals;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+
+import com.baeldung.partialupdate.model.Customer;
+import com.baeldung.partialupdate.model.CustomerDto;
+import com.baeldung.partialupdate.model.CustomerStructured;
+import com.baeldung.partialupdate.service.CustomerService;
+
+@RunWith(SpringRunner.class)
+@SpringBootTest(classes = PartialUpdateApplication.class)
+public class PartialUpdateUnitTest {
+
+    @Autowired
+    CustomerService service;
+
+	@Test
+    public void givenCustomer_whenUpdate_thenSuccess() {
+        Customer myCustomer = service.addCustomer("John");
+        myCustomer = service.updateCustomer(myCustomer.id, "+00");
+        assertEquals("+00", myCustomer.phone);
+    }
+
+    @Test
+    public void givenCustomer_whenUpdateWithQuery_thenSuccess() {
+        Customer myCustomer = service.addCustomer("John");
+        service.updateCustomerWithCustomQuery(myCustomer.id, "+88");
+        myCustomer = service.getCustomer(myCustomer.id);
+        assertEquals("+88", myCustomer.phone);
+    }
+
+    @Test
+    public void givenCustomerDto_whenUpdateWithMapper_thenSuccess() {
+        CustomerDto dto = new CustomerDto(new Customer());
+        dto.name = "Johnny";
+        Customer entity = service.addCustomer(dto);
+
+        CustomerDto dto2 = new CustomerDto(entity.id);
+        dto2.phone = "+44";
+        entity = service.updateCustomer(dto2);
+
+        assertEquals("Johnny", entity.name);
+    }
+
+    @Test
+    public void givenCustomerStructured_whenUpdateCustomerPhone_thenSuccess() {
+        CustomerStructured myCustomer = service.addCustomerStructured("John");
+        assertEquals(null, myCustomer.contactPhones);
+
+        service.addCustomerPhone(myCustomer.id, "+44");
+        myCustomer = service.updateCustomerStructured(myCustomer.id, "Mr. John");
+
+        assertNotEquals(null, myCustomer.contactPhones);
+        assertEquals(1, myCustomer.contactPhones.size());
+    }
+}

persistence-modules/spring-data-redis/README.md

@@ -4,7 +4,6 @@
 - [Introduction to Spring Data Redis](https://www.baeldung.com/spring-data-redis-tutorial)
 - [PubSub Messaging with Spring Data Redis](https://www.baeldung.com/spring-data-redis-pub-sub)
 - [An Introduction to Spring Data Redis Reactive](https://www.baeldung.com/spring-data-redis-reactive)
-- [Delete Everything in Redis](https://www.baeldung.com/redis-delete-data)
 
 ### Build the Project with Tests Running
 ```
@@ -15,4 +14,3 @@ mvn clean install
 ```
 mvn test
 ```
-

persistence-modules/spring-data-redis/src/main/java/com/baeldung/spring/data/redis/config/RedisConfig.java

@@ -35,18 +35,6 @@ public class RedisConfig {
         template.setValueSerializer(new GenericToStringSerializer<Object>(Object.class));
         return template;
     }
-    
-    @Bean
-    public LettuceConnectionFactory lettuceConnectionFactory() {
-        return new LettuceConnectionFactory();
-    }
-
-    @Bean(name = "flushRedisTemplate")
-    public RedisTemplate<String, String> flushRedisTemplate() {
-        RedisTemplate<String, String> template = new RedisTemplate<>();
-        template.setConnectionFactory(lettuceConnectionFactory());
-        return template;
-    }
 
     @Bean
     MessageListenerAdapter messageListener() {

persistence-modules/spring-data-redis/src/test/java/com/baeldung/spring/data/redis/delete/RedisFlushDatabaseIntegrationTest.java

@@ -1,92 +0,0 @@
-package com.baeldung.spring.data.redis.delete;
-
-import static org.assertj.core.api.Assertions.assertThat;
-
-import java.io.IOException;
-
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Qualifier;
-import org.springframework.dao.DataAccessException;
-import org.springframework.data.redis.connection.RedisConnection;
-import org.springframework.data.redis.core.RedisCallback;
-import org.springframework.data.redis.core.RedisTemplate;
-import org.springframework.data.redis.core.ValueOperations;
-import org.springframework.test.annotation.DirtiesContext;
-import org.springframework.test.annotation.DirtiesContext.ClassMode;
-import org.springframework.test.context.ContextConfiguration;
-import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
-
-import com.baeldung.spring.data.redis.config.RedisConfig;
-
-import redis.embedded.RedisServer;
-
-@RunWith(SpringJUnit4ClassRunner.class)
-@ContextConfiguration(classes = { RedisConfig.class })
-@DirtiesContext(classMode = ClassMode.BEFORE_CLASS)
-public class RedisFlushDatabaseIntegrationTest {
-
-    private RedisServer redisServer;
-
-    @Autowired
-    @Qualifier("flushRedisTemplate")
-    private RedisTemplate<String, String> flushRedisTemplate;
-
-    @Before
-    public void setup() throws IOException {
-        redisServer = new RedisServer(6390);
-        redisServer.start();
-    }
-
-    @After
-    public void tearDown() {
-        redisServer.stop();
-    }
-
-    @Test
-    public void whenFlushDB_thenAllKeysInDatabaseAreCleared() {
-
-        ValueOperations<String, String> simpleValues = flushRedisTemplate.opsForValue();
-        String key = "key";
-        String value = "value";
-        simpleValues.set(key, value);
-        assertThat(simpleValues.get(key)).isEqualTo(value);
-
-        flushRedisTemplate.execute(new RedisCallback<Void>() {
-
-            @Override
-            public Void doInRedis(RedisConnection connection) throws DataAccessException {
-                connection.flushDb();
-                return null;
-            }
-        });
-
-        assertThat(simpleValues.get(key)).isNull();
-
-    }
-    
-    @Test
-    public void whenFlushAll_thenAllKeysInDatabasesAreCleared() {
-
-        ValueOperations<String, String> simpleValues = flushRedisTemplate.opsForValue();
-        String key = "key";
-        String value = "value";
-        simpleValues.set(key, value);
-        assertThat(simpleValues.get(key)).isEqualTo(value);
-
-        flushRedisTemplate.execute(new RedisCallback<Void>() {
-
-            @Override
-            public Void doInRedis(RedisConnection connection) throws DataAccessException {
-                connection.flushAll();
-                return null;
-            }
-        });
-
-        assertThat(simpleValues.get(key)).isNull();
-
-    }
-}