Implementation of scenario "Update single existing entity - update all fields of entity at once"

Author: bwajtr

dbscenarios.txt

@@ -2,7 +2,7 @@
 2. Fetch list of entities based on condition
 3. Save new single entity and return primary key
 4. Batch insert multiple entities of same type and return generated keys
-5. Update single existing entity - update one field of the entity
+5. Update single existing entity - update all fields of entity at once
 6. Fetch entity and it's manytoone relation (Company for Employee)
 7. Fetch entity and it's onetomany relation (Employees for Company)
 8. Update entitie's onetomany relation - add two items, update two items and delete one item

src/main/java/com/clevergang/dbtests/Scenarios.java

@@ -1,9 +1,11 @@
 package com.clevergang.dbtests;
 
+import java.math.BigDecimal;
 import java.time.LocalDate;
 import java.util.ArrayList;
 import java.util.List;
 
+import com.clevergang.dbtests.model.Employee;
 import com.clevergang.dbtests.model.Project;
 import com.clevergang.dbtests.service.repository.DataRepository;
 import org.apache.commons.lang3.RandomStringUtils;
@@ -72,9 +74,22 @@ public void scenarioFour() {
     }
 
     /**
-     * Update single existing entity - update one field of the entity
+     * Update single existing entity - update all fields of entity at once
      */
     public void scenarioFive() {
+        // Complete already store entity with all fields set - imagine that this object comes from UI edit dialog,
+        // which is typical scenario
+        Employee employeeToUpdate = new Employee();
+        employeeToUpdate.setPid(1);
+        employeeToUpdate.setDepartmentPid(1);
+        employeeToUpdate.setName("Curt");
+        employeeToUpdate.setSurname("Odegaard");
+        employeeToUpdate.setEmail("curt.odegaard@updated.com");  // <-- this is updated value
+        employeeToUpdate.setSalary(new BigDecimal("15000")); // <-- this is updated value
+
+        // now update the employee in DB
+        repository.updateEmployee(employeeToUpdate);
+
     }
 
     public void scenarioSix() {

src/main/java/com/clevergang/dbtests/service/repository/DataRepository.java

@@ -19,4 +19,5 @@ public interface DataRepository {
 
     List<Integer> insertAllProjects(List<Project> projects);
 
+    void updateEmployee(Employee employeeToUpdate);
 }

src/main/java/com/clevergang/dbtests/service/repository/impl/jdbctemplate/JDBCDataRepositoryImpl.java

@@ -103,7 +103,30 @@ public List<Integer> insertAllProjects(List<Project> projects) {
 
         jdbcTemplate.batchUpdate(insertStatement, paramsList);
 
-        // FIXME JDBCTemplate cannot return IDs for batch update!!
+        // FIXME JDBCTemplate cannot return IDs for every row after batch update!!
         return null;
     }
+
+    @Override
+    public void updateEmployee(Employee employeeToUpdate) {
+        logger.info("Updating employee using JDBC Template");
+
+        String updateStatement = " UPDATE EMPLOYEE SET " +
+            " department_pid = :department_pid, " +
+            " name = :name," +
+            " surname = :surname," +
+            " email = :email," +
+            " salary = :salary" +
+            " WHERE pid = :pid";
+
+        MapSqlParameterSource params = new MapSqlParameterSource();
+        params.addValue("department_pid", employeeToUpdate.getDepartmentPid());
+        params.addValue("name", employeeToUpdate.getName());
+        params.addValue("surname", employeeToUpdate.getSurname());
+        params.addValue("email", employeeToUpdate.getEmail());
+        params.addValue("salary", employeeToUpdate.getSalary());
+        params.addValue("pid", employeeToUpdate.getPid());
+
+        jdbcTemplate.update(updateStatement, params);
+    }
 }

src/main/java/com/clevergang/dbtests/service/repository/impl/jooq/JooqDataRepositoryImpl.java

@@ -9,6 +9,7 @@
 import com.clevergang.dbtests.model.Project;
 import com.clevergang.dbtests.service.repository.DataRepository;
 import com.clevergang.dbtests.service.repository.impl.ImplBasedOn;
+import com.clevergang.dbtests.service.repository.impl.jooq.generated.tables.records.EmployeeRecord;
 import org.jooq.BatchBindStep;
 import org.jooq.DSLContext;
 import org.slf4j.Logger;
@@ -98,5 +99,25 @@ public List<Integer> insertAllProjects(List<Project> projects) {
         return null;
     }
 
+    @Override
+    public void updateEmployee(Employee employeeToUpdate) {
+        logger.info("Updating employee using JOOQ");
+
+        // If the DTO object passed into this method field names match field names in the EmployeeRecord,
+        // then it's easier to use Records when updating all fields of the entity at once:
+        EmployeeRecord record = create.newRecord(EMPLOYEE, employeeToUpdate);
+        create.executeUpdate(record);
+
+        // If the DTO object fields does not match the employee record, then you'll have to use mapping:
+        create.update(EMPLOYEE)
+            .set(EMPLOYEE.DEPARTMENT_PID, employeeToUpdate.getDepartmentPid())
+            .set(EMPLOYEE.NAME, employeeToUpdate.getName())
+            .set(EMPLOYEE.SURNAME, employeeToUpdate.getSurname())
+            .set(EMPLOYEE.EMAIL, employeeToUpdate.getEmail())
+            .set(EMPLOYEE.SALARY, employeeToUpdate.getSalary())
+            .where(EMPLOYEE.PID.eq(employeeToUpdate.getPid())) // <-- Do not forget to add where condition!
+            .execute();
+    }
+
 }