Added new scenario for removing single entity based on primary key and implemented in all frameworks

Author: bretislav.wajtr

README.md

@@ -47,6 +47,7 @@ These are the scenarios:
 9. Complex select - construct select where conditions based on some boolean conditions + throw in some joins
 10. Call stored procedure/function and process results
 11. Execute query using JDBC simple Statement (not PreparedStatement)
+12. Remove single entity based on primary key
 
 Each scenario has it's implementation in the Scenarios class. See javadoc of [Scenarios](src/main/java/com/clevergang/dbtests/Scenarios.java) methods for more detailed description of each scenario.
 

sql-updates/create-script.sql

@@ -40,8 +40,8 @@ CREATE TABLE Project (
 );
 
 CREATE TABLE ProjectEmployee (
-  project_pid INTEGER REFERENCES Project ON DELETE NO ACTION,
-  employee_pid INTEGER REFERENCES Employee ON DELETE NO ACTION,
+  project_pid INTEGER REFERENCES Project ON DELETE CASCADE,
+  employee_pid INTEGER REFERENCES Employee ON DELETE CASCADE,
   PRIMARY KEY (project_pid, employee_pid)
 );
 

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

@@ -343,6 +343,20 @@ public void executeSimpleStaticStatementScenario() {
         assert output.getName().equals("CleverGang");
         logger.info("Output of scenario 11: {}", output);
     }
+
+    /**
+     * 12. Delete one record by PID
+     * <br/>
+     * Just one of the CRUD operations.
+     */
+    public void removeSingleEntityScenario() {
+        repository.removeProject(2);
+
+        // check some post conditions
+        Integer projectCount = repository.getProjectsCount();
+        assert projectCount == 1;
+    }
+
 }
 
 

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

@@ -28,8 +28,6 @@ public interface DataRepository {
      */
     Company findCompanyUsingSimpleStaticStatement(Integer pid);
 
-
-
     // Departments
 
     /**
@@ -147,4 +145,11 @@ RegisterEmployeeOutput callRegisterEmployee(String name, String surname, String
      * @return Return count of records in Project table
      */
     Integer getProjectsCount();
+
+    /**
+     * Removes project record from database based on primary key
+     * @param pid Primary key of the project to be removed
+     */
+    void removeProject(Integer pid);
+
 }

src/main/java/com/clevergang/dbtests/repository/impl/ebean/EBeanDataRepositoryImpl.java

@@ -75,6 +75,11 @@ public Company findCompanyUsingSimpleStaticStatement(Integer pid) {
         }
     }
 
+    @Override
+    public void removeProject(Integer pid) {
+        ebean.delete(ProjectEntity.class, pid);
+    }
+
     @Override
     public Department findDepartment(Integer pid) {
         DepartmentEntity departmentEntity = ebean.find(DepartmentEntity.class, pid);

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

@@ -101,6 +101,15 @@ public Company findCompanyUsingSimpleStaticStatement(Integer pid) {
         return company;
     }
 
+    @Override
+    public void removeProject(Integer pid) {
+        MapSqlParameterSource params = new MapSqlParameterSource();
+        params.addValue("pid", pid);
+
+        int update = jdbcTemplate.update("DELETE FROM project where pid = :pid", params);
+        assert update == 1;
+    }
+
     @Override
     public Department findDepartment(Integer pid) {
         String query = "SELECT pid, company_pid, name" +

src/main/java/com/clevergang/dbtests/repository/impl/jdbi/JDBIDataRepositoryImpl.java

@@ -69,6 +69,15 @@ public Company findCompanyUsingSimpleStaticStatement(Integer pid) {
         }
     }
 
+    @Override
+    public void removeProject(Integer pid) {
+        try (Handle h = dbi.open()) {
+            h.createStatement("DELETE FROM project WHERE pid = :pid")
+                    .bind("pid", pid)
+                    .execute();
+        }
+    }
+
     @Override
     public Department findDepartment(Integer pid) {
         try (Handle h = dbi.open()) {

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

@@ -89,6 +89,13 @@ public Company findCompanyUsingSimpleStaticStatement(Integer pid) {
         return reference.get();
     }
 
+    @Override
+    public void removeProject(Integer pid) {
+        create.deleteFrom(PROJECT)
+                .where(PROJECT.PID.eq(pid))
+                .execute();
+    }
+
     @Override
     public Department findDepartment(Integer pid) {
         return create.

src/main/java/com/clevergang/dbtests/repository/impl/mybatis/DataRepositoryMapper.java

@@ -44,4 +44,6 @@ public interface DataRepositoryMapper {
     Employee findEmployee(Integer pid);
 
     Project findProject(Integer pid);
+
+    void removeProject(Integer pid);
 }

src/main/java/com/clevergang/dbtests/repository/impl/mybatis/MyBatisDataRepositoryImpl.java

@@ -50,6 +50,11 @@ public Company findCompanyUsingSimpleStaticStatement(Integer pid) {
         return sql.findCompanyStatic(pid);
     }
 
+    @Override
+    public void removeProject(Integer pid) {
+        sql.removeProject(pid);
+    }
+
     @Override
     public Department findDepartment(Integer pid) {
         return sql.findDepartment(pid);