docs: update .all-contributorsrc [skip ci]

unit-of-work/README.md

@@ -12,20 +12,20 @@ tags:
 
 ## Intent
 
-When a business transaction is completed, all the updates are sent as one big unit of work to be 
+When a business transaction is completed, all the the updates are sent as one big unit of work to be 
 persisted in one go to minimize database round-trips. 
 
 ## Explanation
 
-Real-world example
+Real world example
 
-> Arms dealer has a database containing weapon information. Merchants all over the town are 
+> We have a database containing student information. Administrators all over the country are 
-> constantly updating this information and it causes a high load on the database server. To make the 
+> constantly updating this information and it causes high load on the database server. To make the 
 > load more manageable we apply to Unit of Work pattern to send many small updates in batches.       
 
 In plain words
 
-> Unit of Work merges many small database updates in a single batch to optimize the number of 
+> Unit of Work merges many small database updates in single batch to optimize the number of 
 > round-trips. 
 
 [MartinFowler.com](https://martinfowler.com/eaaCatalog/unitOfWork.html) says
@@ -35,20 +35,37 @@ In plain words
 
 **Programmatic Example**
 
-Here's the `Weapon` entity that is being persisted in the database.
+Here's the `Student` entity that is being persisted to the database.
 
 ```java
-@Getter
+public class Student {
-@RequiredArgsConstructor
+  private final Integer id;
-public class Weapon {
+  private final String name;
-    private final Integer id;
+  private final String address;
-    private final String name;
+
+  public Student(Integer id, String name, String address) {
+    this.id = id;
+    this.name = name;
+    this.address = address;
+  }
+
+  public String getName() {
+    return name;
+  }
+
+  public Integer getId() {
+    return id;
+  }
+
+  public String getAddress() {
+    return address;
+  }
 }
 ```
 
-The essence of the implementation is the `ArmsDealer` implementing the Unit of Work pattern. 
+The essence of the implementation is the `StudentRepository` implementing the Unit of Work pattern. 
 It maintains a map of database operations (`context`) that need to be done and when `commit` is 
-called it applies them in a single batch.
+called it applies them in single batch.
 
 ```java
 public interface IUnitOfWork<T> {
@@ -67,117 +84,96 @@ public interface IUnitOfWork<T> {
 }
 
 @Slf4j
-@RequiredArgsConstructor
+public class StudentRepository implements IUnitOfWork<Student> {
-public class ArmsDealer implements IUnitOfWork<Weapon> {
 
-    private final Map<String, List<Weapon>> context;
+  private final Map<String, List<Student>> context;
-    private final WeaponDatabase weaponDatabase;
+  private final StudentDatabase studentDatabase;
 
-    @Override
+  public StudentRepository(Map<String, List<Student>> context, StudentDatabase studentDatabase) {
-    public void registerNew(Weapon weapon) {
+    this.context = context;
-        LOGGER.info("Registering {} for insert in context.", weapon.getName());
+    this.studentDatabase = studentDatabase;
-        register(weapon, UnitActions.INSERT.getActionValue());
+  }
+
+  @Override
+  public void registerNew(Student student) {
+    LOGGER.info("Registering {} for insert in context.", student.getName());
+    register(student, IUnitOfWork.INSERT);
+  }
+
+  @Override
+  public void registerModified(Student student) {
+    LOGGER.info("Registering {} for modify in context.", student.getName());
+    register(student, IUnitOfWork.MODIFY);
+
+  }
+
+  @Override
+  public void registerDeleted(Student student) {
+    LOGGER.info("Registering {} for delete in context.", student.getName());
+    register(student, IUnitOfWork.DELETE);
+  }
+
+  private void register(Student student, String operation) {
+    var studentsToOperate = context.get(operation);
+    if (studentsToOperate == null) {
+      studentsToOperate = new ArrayList<>();
+    }
+    studentsToOperate.add(student);
+    context.put(operation, studentsToOperate);
+  }
+
+  @Override
+  public void commit() {
+    if (context == null || context.size() == 0) {
+      return;
+    }
+    LOGGER.info("Commit started");
+    if (context.containsKey(IUnitOfWork.INSERT)) {
+      commitInsert();
     }
 
-    @Override
+    if (context.containsKey(IUnitOfWork.MODIFY)) {
-    public void registerModified(Weapon weapon) {
+      commitModify();
-        LOGGER.info("Registering {} for modify in context.", weapon.getName());
-        register(weapon, UnitActions.MODIFY.getActionValue());
-
     }
-
+    if (context.containsKey(IUnitOfWork.DELETE)) {
-    @Override
+      commitDelete();
-    public void registerDeleted(Weapon weapon) {
-        LOGGER.info("Registering {} for delete in context.", weapon.getName());
-        register(weapon, UnitActions.DELETE.getActionValue());
     }
+    LOGGER.info("Commit finished.");
+  }
 
-    private void register(Weapon weapon, String operation) {
+  private void commitInsert() {
-        var weaponsToOperate = context.get(operation);
+    var studentsToBeInserted = context.get(IUnitOfWork.INSERT);
-        if (weaponsToOperate == null) {
+    for (var student : studentsToBeInserted) {
-            weaponsToOperate = new ArrayList<>();
+      LOGGER.info("Saving {} to database.", student.getName());
-        }
+      studentDatabase.insert(student);
-        weaponsToOperate.add(weapon);
-        context.put(operation, weaponsToOperate);
     }
+  }
 
-    /**
+  private void commitModify() {
-     * All UnitOfWork operations are batched and executed together on commit only.
+    var modifiedStudents = context.get(IUnitOfWork.MODIFY);
-     */
+    for (var student : modifiedStudents) {
-    @Override
+      LOGGER.info("Modifying {} to database.", student.getName());
-    public void commit() {
+      studentDatabase.modify(student);
-        if (context == null || context.size() == 0) {
-            return;
-        }
-        LOGGER.info("Commit started");
-        if (context.containsKey(UnitActions.INSERT.getActionValue())) {
-            commitInsert();
-        }
-
-        if (context.containsKey(UnitActions.MODIFY.getActionValue())) {
-            commitModify();
-        }
-        if (context.containsKey(UnitActions.DELETE.getActionValue())) {
-            commitDelete();
-        }
-        LOGGER.info("Commit finished.");
     }
+  }
 
-    private void commitInsert() {
+  private void commitDelete() {
-        var weaponsToBeInserted = context.get(UnitActions.INSERT.getActionValue());
+    var deletedStudents = context.get(IUnitOfWork.DELETE);
-        for (var weapon : weaponsToBeInserted) {
+    for (var student : deletedStudents) {
-            LOGGER.info("Inserting a new weapon {} to sales rack.", weapon.getName());
+      LOGGER.info("Deleting {} to database.", student.getName());
-            weaponDatabase.insert(weapon);
+      studentDatabase.delete(student);
-        }
-    }
-
-    private void commitModify() {
-        var modifiedWeapons = context.get(UnitActions.MODIFY.getActionValue());
-        for (var weapon : modifiedWeapons) {
-            LOGGER.info("Scheduling {} for modification work.", weapon.getName());
-            weaponDatabase.modify(weapon);
-        }
-    }
-
-    private void commitDelete() {
-        var deletedWeapons = context.get(UnitActions.DELETE.getActionValue());
-        for (var weapon : deletedWeapons) {
-            LOGGER.info("Scrapping {}.", weapon.getName());
-            weaponDatabase.delete(weapon);
-        }
     }
+  }
 }
 ```
 
-Here is how the whole app is put together.
+Finally, here's how we use the `StudentRepository` and `commit` the transaction.
 
 ```java
-// create some weapons
+    studentRepository.registerNew(ram);
-var enchantedHammer = new Weapon(1, "enchanted hammer");
+    studentRepository.registerModified(shyam);
-var brokenGreatSword = new Weapon(2, "broken great sword");
+    studentRepository.registerDeleted(gopi);
-var silverTrident = new Weapon(3, "silver trident");
+    studentRepository.commit();
-
-// create repository
-var weaponRepository = new ArmsDealer(new HashMap<String, List<Weapon>>(), new WeaponDatabase());
-
-// perform operations on the weapons
-weaponRepository.registerNew(enchantedHammer);
-weaponRepository.registerModified(silverTrident);
-weaponRepository.registerDeleted(brokenGreatSword);
-weaponRepository.commit();
-```
-
-Here is the console output.
-
-```
-21:39:21.984 [main] INFO com.iluwatar.unitofwork.ArmsDealer - Registering enchanted hammer for insert in context.
-21:39:21.989 [main] INFO com.iluwatar.unitofwork.ArmsDealer - Registering silver trident for modify in context.
-21:39:21.989 [main] INFO com.iluwatar.unitofwork.ArmsDealer - Registering broken great sword for delete in context.
-21:39:21.989 [main] INFO com.iluwatar.unitofwork.ArmsDealer - Commit started
-21:39:21.989 [main] INFO com.iluwatar.unitofwork.ArmsDealer - Inserting a new weapon enchanted hammer to sales rack.
-21:39:21.989 [main] INFO com.iluwatar.unitofwork.ArmsDealer - Scheduling silver trident for modification work.
-21:39:21.989 [main] INFO com.iluwatar.unitofwork.ArmsDealer - Scrapping broken great sword.
-21:39:21.989 [main] INFO com.iluwatar.unitofwork.ArmsDealer - Commit finished.
 ```
 
 ## Class diagram
@@ -190,7 +186,7 @@ Use the Unit Of Work pattern when
 
 * To optimize the time taken for database transactions.
 * To send changes to database as a unit of work which ensures atomicity of the transaction.
-* To reduce the number of database calls.
+* To reduce number of database calls.
 
 ## Tutorials
 

unit-of-work/etc/unit-of-work.ucls

@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <class-diagram version="1.2.1" icons="true" always-add-relationships="false" generalizations="true" realizations="true" 
   associations="true" dependencies="false" nesting-relationships="true" router="FAN">  
-  <class id="1" language="java" name="com.iluwatar.unitofwork.WeaponDatabase" project="unit-of-work"
+  <class id="1" language="java" name="com.iluwatar.unitofwork.StudentDatabase" project="unit-of-work" 
     file="/unit-of-work/src/main/java/com/iluwatar/unitofwork/StudentDatabase.java" binary="false" corner="BOTTOM_RIGHT">    
     <position height="-1" width="-1" x="170" y="406"/>    
     <display autosize="true" stereotype="true" package="true" initial-value="false" signature="true" 
@@ -28,7 +28,7 @@
       <operations public="true" package="true" protected="true" private="true" static="true"/>    
     </display>  
   </class>  
-  <class id="4" language="java" name="com.iluwatar.unitofwork.ArmsDealer" project="unit-of-work"
+  <class id="4" language="java" name="com.iluwatar.unitofwork.StudentRepository" project="unit-of-work" 
     file="/unit-of-work/src/main/java/com/iluwatar/unitofwork/StudentRepository.java" binary="false" 
     corner="BOTTOM_RIGHT">    
     <position height="-1" width="-1" x="377" y="166"/>    
@@ -38,7 +38,7 @@
       <operations public="true" package="true" protected="true" private="true" static="true"/>    
     </display>  
   </class>  
-  <class id="5" language="java" name="com.iluwatar.unitofwork.Weapon" project="unit-of-work"
+  <class id="5" language="java" name="com.iluwatar.unitofwork.Student" project="unit-of-work" 
     file="/unit-of-work/src/main/java/com/iluwatar/unitofwork/Student.java" binary="false" corner="BOTTOM_RIGHT">    
     <position height="-1" width="-1" x="696" y="130"/>    
     <display autosize="true" stereotype="true" package="true" initial-value="false" signature="true" 

unit-of-work/src/main/java/com/iluwatar/unitofwork/App.java

@@ -27,7 +27,7 @@ import java.util.HashMap;
 import java.util.List;
 
 /**
- * {@link App} Application demonstrating unit of work pattern.
+ * {@link App} Application for managing student data.
  */
 public class App {
   /**
@@ -37,19 +37,17 @@ public class App {
    */
 
   public static void main(String[] args) {
-    // create some weapons
+    var ram = new Student(1, "Ram", "Street 9, Cupertino");
-    var enchantedHammer = new Weapon(1, "enchanted hammer");
+    var shyam = new Student(2, "Shyam", "Z bridge, Pune");
-    var brokenGreatSword = new Weapon(2, "broken great sword");
+    var gopi = new Student(3, "Gopi", "Street 10, Mumbai");
-    var silverTrident = new Weapon(3, "silver trident");
 
-    // create repository
+    var context = new HashMap<String, List<Student>>();
-    var weaponRepository = new ArmsDealer(new HashMap<String, List<Weapon>>(),
+    var studentDatabase = new StudentDatabase();
-            new WeaponDatabase());
+    var studentRepository = new StudentRepository(context, studentDatabase);
 
-    // perform operations on the weapons
+    studentRepository.registerNew(ram);
-    weaponRepository.registerNew(enchantedHammer);
+    studentRepository.registerModified(shyam);
-    weaponRepository.registerModified(silverTrident);
+    studentRepository.registerDeleted(gopi);
-    weaponRepository.registerDeleted(brokenGreatSword);
+    studentRepository.commit();
-    weaponRepository.commit();
   }
 }

unit-of-work/src/main/java/com/iluwatar/unitofwork/Student.java

@@ -27,12 +27,14 @@ import lombok.Getter;
 import lombok.RequiredArgsConstructor;
 
 /**
- * {@link Weapon} is an entity.
+ * {@link Student} is an entity.
  */
 @Getter
 @RequiredArgsConstructor
-public class Weapon {
+public class Student {
 
   private final Integer id;
   private final String name;
+  private final String address;
+
 }

unit-of-work/src/main/java/com/iluwatar/unitofwork/StudentDatabase.java

@@ -24,19 +24,19 @@
 package com.iluwatar.unitofwork;
 
 /**
- * Act as database for weapon records.
+ * Act as Database for student records.
  */
-public class WeaponDatabase {
+public class StudentDatabase {
 
-  public void insert(Weapon weapon) {
+  public void insert(Student student) {
     //Some insert logic to DB
   }
 
-  public void modify(Weapon weapon) {
+  public void modify(Student student) {
     //Some modify logic to DB
   }
 
-  public void delete(Weapon weapon) {
+  public void delete(Student student) {
     //Some delete logic to DB
   }
 }

unit-of-work/src/main/java/com/iluwatar/unitofwork/StudentRepository.java

@@ -30,41 +30,41 @@ import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 
 /**
- * {@link ArmsDealer} Weapon repository that supports unit of work for weapons.
+ * {@link StudentRepository} Student database repository. supports unit of work for student data.
  */
 @Slf4j
 @RequiredArgsConstructor
-public class ArmsDealer implements IUnitOfWork<Weapon> {
+public class StudentRepository implements IUnitOfWork<Student> {
 
-  private final Map<String, List<Weapon>> context;
+  private final Map<String, List<Student>> context;
-  private final WeaponDatabase weaponDatabase;
+  private final StudentDatabase studentDatabase;
 
   @Override
-  public void registerNew(Weapon weapon) {
+  public void registerNew(Student student) {
-    LOGGER.info("Registering {} for insert in context.", weapon.getName());
+    LOGGER.info("Registering {} for insert in context.", student.getName());
-    register(weapon, UnitActions.INSERT.getActionValue());
+    register(student, UnitActions.INSERT.getActionValue());
   }
 
   @Override
-  public void registerModified(Weapon weapon) {
+  public void registerModified(Student student) {
-    LOGGER.info("Registering {} for modify in context.", weapon.getName());
+    LOGGER.info("Registering {} for modify in context.", student.getName());
-    register(weapon, UnitActions.MODIFY.getActionValue());
+    register(student, UnitActions.MODIFY.getActionValue());
 
   }
 
   @Override
-  public void registerDeleted(Weapon weapon) {
+  public void registerDeleted(Student student) {
-    LOGGER.info("Registering {} for delete in context.", weapon.getName());
+    LOGGER.info("Registering {} for delete in context.", student.getName());
-    register(weapon, UnitActions.DELETE.getActionValue());
+    register(student, UnitActions.DELETE.getActionValue());
   }
 
-  private void register(Weapon weapon, String operation) {
+  private void register(Student student, String operation) {
-    var weaponsToOperate = context.get(operation);
+    var studentsToOperate = context.get(operation);
-    if (weaponsToOperate == null) {
+    if (studentsToOperate == null) {
-      weaponsToOperate = new ArrayList<>();
+      studentsToOperate = new ArrayList<>();
     }
-    weaponsToOperate.add(weapon);
+    studentsToOperate.add(student);
-    context.put(operation, weaponsToOperate);
+    context.put(operation, studentsToOperate);
   }
 
   /**
@@ -90,26 +90,26 @@ public class ArmsDealer implements IUnitOfWork<Weapon> {
   }
 
   private void commitInsert() {
-    var weaponsToBeInserted = context.get(UnitActions.INSERT.getActionValue());
+    var studentsToBeInserted = context.get(UnitActions.INSERT.getActionValue());
-    for (var weapon : weaponsToBeInserted) {
+    for (var student : studentsToBeInserted) {
-      LOGGER.info("Inserting a new weapon {} to sales rack.", weapon.getName());
+      LOGGER.info("Saving {} to database.", student.getName());
-      weaponDatabase.insert(weapon);
+      studentDatabase.insert(student);
     }
   }
 
   private void commitModify() {
-    var modifiedWeapons = context.get(UnitActions.MODIFY.getActionValue());
+    var modifiedStudents = context.get(UnitActions.MODIFY.getActionValue());
-    for (var weapon : modifiedWeapons) {
+    for (var student : modifiedStudents) {
-      LOGGER.info("Scheduling {} for modification work.", weapon.getName());
+      LOGGER.info("Modifying {} to database.", student.getName());
-      weaponDatabase.modify(weapon);
+      studentDatabase.modify(student);
     }
   }
 
   private void commitDelete() {
-    var deletedWeapons = context.get(UnitActions.DELETE.getActionValue());
+    var deletedStudents = context.get(UnitActions.DELETE.getActionValue());
-    for (var weapon : deletedWeapons) {
+    for (var student : deletedStudents) {
-      LOGGER.info("Scrapping {}.", weapon.getName());
+      LOGGER.info("Deleting {} to database.", student.getName());
-      weaponDatabase.delete(weapon);
+      studentDatabase.delete(student);
     }
   }
 }

unit-of-work/src/test/java/com/iluwatar/unitofwork/StudentRepositoryTest.java

@@ -36,102 +36,102 @@ import java.util.Map;
 import org.junit.jupiter.api.Test;
 
 /**
- * tests {@link ArmsDealer}
+ * tests {@link StudentRepository}
  */
 
-class ArmsDealerTest {
+class StudentRepositoryTest {
-  private final Weapon weapon1 = new Weapon(1, "battle ram");
+  private final Student student1 = new Student(1, "Ram", "street 9, cupertino");
-  private final Weapon weapon2 = new Weapon(1, "wooden lance");
+  private final Student student2 = new Student(1, "Sham", "Z bridge, pune");
 
-  private final Map<String, List<Weapon>> context = new HashMap<>();
+  private final Map<String, List<Student>> context = new HashMap<>();
-  private final WeaponDatabase weaponDatabase = mock(WeaponDatabase.class);
+  private final StudentDatabase studentDatabase = mock(StudentDatabase.class);
-  private final ArmsDealer armsDealer = new ArmsDealer(context, weaponDatabase);;
+  private final StudentRepository studentRepository = new StudentRepository(context, studentDatabase);;
 
   @Test
   void shouldSaveNewStudentWithoutWritingToDb() {
-    armsDealer.registerNew(weapon1);
+    studentRepository.registerNew(student1);
-    armsDealer.registerNew(weapon2);
+    studentRepository.registerNew(student2);
 
     assertEquals(2, context.get(UnitActions.INSERT.getActionValue()).size());
-    verifyNoMoreInteractions(weaponDatabase);
+    verifyNoMoreInteractions(studentDatabase);
   }
 
   @Test
   void shouldSaveDeletedStudentWithoutWritingToDb() {
-    armsDealer.registerDeleted(weapon1);
+    studentRepository.registerDeleted(student1);
-    armsDealer.registerDeleted(weapon2);
+    studentRepository.registerDeleted(student2);
 
     assertEquals(2, context.get(UnitActions.DELETE.getActionValue()).size());
-    verifyNoMoreInteractions(weaponDatabase);
+    verifyNoMoreInteractions(studentDatabase);
   }
 
   @Test
   void shouldSaveModifiedStudentWithoutWritingToDb() {
-    armsDealer.registerModified(weapon1);
+    studentRepository.registerModified(student1);
-    armsDealer.registerModified(weapon2);
+    studentRepository.registerModified(student2);
 
     assertEquals(2, context.get(UnitActions.MODIFY.getActionValue()).size());
-    verifyNoMoreInteractions(weaponDatabase);
+    verifyNoMoreInteractions(studentDatabase);
   }
 
   @Test
   void shouldSaveAllLocalChangesToDb() {
-    context.put(UnitActions.INSERT.getActionValue(), List.of(weapon1));
+    context.put(UnitActions.INSERT.getActionValue(), List.of(student1));
-    context.put(UnitActions.MODIFY.getActionValue(), List.of(weapon1));
+    context.put(UnitActions.MODIFY.getActionValue(), List.of(student1));
-    context.put(UnitActions.DELETE.getActionValue(), List.of(weapon1));
+    context.put(UnitActions.DELETE.getActionValue(), List.of(student1));
 
-    armsDealer.commit();
+    studentRepository.commit();
 
-    verify(weaponDatabase, times(1)).insert(weapon1);
+    verify(studentDatabase, times(1)).insert(student1);
-    verify(weaponDatabase, times(1)).modify(weapon1);
+    verify(studentDatabase, times(1)).modify(student1);
-    verify(weaponDatabase, times(1)).delete(weapon1);
+    verify(studentDatabase, times(1)).delete(student1);
   }
 
   @Test
   void shouldNotWriteToDbIfContextIsNull() {
-    var weaponRepository = new ArmsDealer(null, weaponDatabase);
+    var studentRepository = new StudentRepository(null, studentDatabase);
 
-    weaponRepository.commit();
+    studentRepository.commit();
 
-    verifyNoMoreInteractions(weaponDatabase);
+    verifyNoMoreInteractions(studentDatabase);
   }
 
   @Test
   void shouldNotWriteToDbIfNothingToCommit() {
-    var weaponRepository = new ArmsDealer(new HashMap<>(), weaponDatabase);
+    var studentRepository = new StudentRepository(new HashMap<>(), studentDatabase);
 
-    weaponRepository.commit();
+    studentRepository.commit();
 
-    verifyNoMoreInteractions(weaponDatabase);
+    verifyNoMoreInteractions(studentDatabase);
   }
 
   @Test
   void shouldNotInsertToDbIfNoRegisteredStudentsToBeCommitted() {
-    context.put(UnitActions.MODIFY.getActionValue(), List.of(weapon1));
+    context.put(UnitActions.MODIFY.getActionValue(), List.of(student1));
-    context.put(UnitActions.DELETE.getActionValue(), List.of(weapon1));
+    context.put(UnitActions.DELETE.getActionValue(), List.of(student1));
 
-    armsDealer.commit();
+    studentRepository.commit();
 
-    verify(weaponDatabase, never()).insert(weapon1);
+    verify(studentDatabase, never()).insert(student1);
   }
 
   @Test
   void shouldNotModifyToDbIfNotRegisteredStudentsToBeCommitted() {
-    context.put(UnitActions.INSERT.getActionValue(), List.of(weapon1));
+    context.put(UnitActions.INSERT.getActionValue(), List.of(student1));
-    context.put(UnitActions.DELETE.getActionValue(), List.of(weapon1));
+    context.put(UnitActions.DELETE.getActionValue(), List.of(student1));
 
-    armsDealer.commit();
+    studentRepository.commit();
 
-    verify(weaponDatabase, never()).modify(weapon1);
+    verify(studentDatabase, never()).modify(student1);
   }
 
   @Test
   void shouldNotDeleteFromDbIfNotRegisteredStudentsToBeCommitted() {
-    context.put(UnitActions.INSERT.getActionValue(), List.of(weapon1));
+    context.put(UnitActions.INSERT.getActionValue(), List.of(student1));
-    context.put(UnitActions.MODIFY.getActionValue(), List.of(weapon1));
+    context.put(UnitActions.MODIFY.getActionValue(), List.of(student1));
 
-    armsDealer.commit();
+    studentRepository.commit();
 
-    verify(weaponDatabase, never()).delete(weapon1);
+    verify(studentDatabase, never()).delete(student1);
   }
 }