add test for transaction

Author: Freeongoo

transaction-declarative/.gitignore

@@ -1,4 +1,5 @@
 /src/main/resources/application.properties
+/src/test/resources/application.properties
 /target
 /node_modules
 .gradle

transaction-declarative/pom.xml

@@ -42,6 +42,11 @@
             <artifactId>mysql-connector-java</artifactId>
             <scope>runtime</scope>
         </dependency>
+        <dependency>
+            <groupId>com.h2database</groupId>
+            <artifactId>h2</artifactId>
+            <version>1.4.194</version>
+        </dependency>
     </dependencies>
 
     <properties>

transaction-declarative/readme.md

@@ -1,5 +1,20 @@
-# Installation
+# Example use declarative transaction
 
-1. create database see db.sql
-2. cp src/main/resources/application.properties.dist src/main/resources/application.properties
-3. set db config in application.properties
+For service layer - for class
+
+`/src/main/java/hello/service/transaction/impl/EmployeeServiceImpl.java`
+
+## Configuration
+
+1. cp src/main/resources/application.properties.dist src/main/resources/application.properties
+2. cp src/test/resources/application.properties.dist src/test/resources/application.properties
+
+## Test transaction
+
+### With transaction
+
+`/src/test/java/hello/service/transaction/impl/EmployeeServiceImplTest.java`
+
+### Without transaction
+
+`/src/test/java/hello/service/without_transaction/impl/EmployeeServiceImplTest.java`

transaction-declarative/src/main/java/hello/Application.java

@@ -1,31 +1,11 @@
 package hello;
 
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.context.ApplicationContext;
-import org.springframework.context.ConfigurableApplicationContext;
 
 @SpringBootApplication
 public class Application {
-
-    @Autowired
-    CheckTransaction testJdbcTemplate;
-
     public static void main(String[] args) {
-        ApplicationContext context = SpringApplication.run(Application.class, args);
-
-        CheckTransaction checkTransaction = context.getBean(CheckTransaction.class);
-
-        // run in transaction - if exception - all rollback
-        try {
-            checkTransaction.insertSameEmails();
-        } catch (Exception e) {
-            System.out.println(e);
-        }
-
-        checkTransaction.correctCreateNewEmployee();
-
-        ((ConfigurableApplicationContext) context).close();
+        SpringApplication.run(Application.class, args);
     }
 }

transaction-declarative/src/main/java/hello/CheckTransaction.java

@@ -23,18 +23,14 @@
 
 @Repository
 public class EmployeeDaoImpl extends JdbcDaoSupport implements EmployeeDao {
-    private final String SQL_SELECT_ALL   = "SELECT * FROM employee";
-    private final String SQL_DELETE_BY_ID   = "DELETE FROM employee WHERE id = ?";
-    private final String SQL_SELECT_BY_ID = "SELECT * FROM employee WHERE id = ?";
+    private final String SQL_SELECT_ALL      = "SELECT * FROM employee";
+    private final String SQL_DELETE_BY_ID    = "DELETE FROM employee WHERE id = ?";
+    private final String SQL_SELECT_BY_ID    = "SELECT * FROM employee WHERE id = ?";
     private final String SQL_SELECT_BY_EMAIL = "SELECT * FROM employee WHERE email = ?";
-    private final String SQL_INSERT_NEW   = "INSERT INTO employee (name, email) VALUES (?, ?)";
-
-    private final DataSource dataSource;
+    private final String SQL_INSERT_NEW      = "INSERT INTO employee (name, email) VALUES (?, ?)";
 
     @Autowired
-    public EmployeeDaoImpl(DataSource dataSource) {
-        this.dataSource = dataSource;
-    }
+    DataSource dataSource;
 
     @PostConstruct
     private void initialize(){
@@ -81,7 +77,7 @@ public List<Employee> getAll(){
         List<Employee> result = new ArrayList<>();
         for (Map<String, Object> row : rows) {
             Employee emp = new Employee(
-                    toIntExact((Long)row.get("id")),
+                    toIntExact((Integer)row.get("id")),
                     (String)row.get("name"),
                     (String)row.get("email")
             );

transaction-declarative/src/main/java/hello/dao/impl/EmployeeDaoImpl.java

@@ -1,4 +1,4 @@
-package hello.service;
+package hello.service.transaction;
 
 import hello.model.Employee;
 

transaction-declarative/src/main/java/hello/service/EmployeeService.java renamed to transaction-declarative/src/main/java/hello/service/transaction/EmployeeService.java

@@ -1,15 +1,17 @@
-package hello.service.impl;
+package hello.service.transaction.impl;
 
 import java.util.List;
 
 import hello.dao.EmployeeDao;
 import hello.model.Employee;
-import hello.service.EmployeeService;
+import hello.service.transaction.EmployeeService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.dao.EmptyResultDataAccessException;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
-@Service
+@Service("EmployeeServiceWithTransaction")
+@Transactional
 public class EmployeeServiceImpl implements EmployeeService {
 
     @Autowired

transaction-declarative/src/main/java/hello/service/impl/EmployeeServiceImpl.java renamed to transaction-declarative/src/main/java/hello/service/transaction/impl/EmployeeServiceImpl.java

@@ -0,0 +1,21 @@
+package hello.service.without_transaction;
+
+import hello.model.Employee;
+
+import java.util.List;
+
+public interface EmployeeService {
+    void insert(Employee emp);
+
+    int insertWithReturnInsertedId(Employee emp);
+
+    void insertList(List<Employee> employees);
+
+    List<Employee> getAll();
+
+    Employee getById(int employeeId);
+
+    Employee getByEmail(String email);
+
+    void delete(Employee employee);
+}

transaction-declarative/src/main/java/hello/service/without_transaction/EmployeeService.java

@@ -0,0 +1,62 @@
+package hello.service.without_transaction.impl;
+
+import hello.dao.EmployeeDao;
+import hello.model.Employee;
+import hello.service.without_transaction.EmployeeService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.dao.EmptyResultDataAccessException;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+
+@Service("EmployeeServiceWithoutTransaction")
+public class EmployeeServiceImpl implements EmployeeService {
+
+    @Autowired
+    EmployeeDao employeeDao;
+
+    @Override
+    public void insert(Employee employee) {
+        employeeDao.insert(employee);
+    }
+
+    @Override
+    public int insertWithReturnInsertedId(Employee employee) {
+        return employeeDao.insertWithReturnInsertedId(employee);
+    }
+
+    @Override
+    public void insertList(List<Employee> employees) {
+        employeeDao.insertList(employees);
+    }
+
+    @Override
+    public List<Employee> getAll() {
+        return employeeDao.getAll();
+    }
+
+    @Override
+    public Employee getById(int employeeId) {
+        try {
+            return employeeDao.getById(employeeId);
+        } catch (EmptyResultDataAccessException e) {
+            return null;
+        }
+    }
+
+    @Override
+    public Employee getByEmail(String email) {
+        try {
+            return employeeDao.getByEmail(email);
+        } catch (EmptyResultDataAccessException e) {
+            return null;
+        }
+    }
+
+    @Override
+    public void delete(Employee employee) {
+        employeeDao.delete(employee);
+    }
+
+}

transaction-declarative/src/main/java/hello/service/without_transaction/impl/EmployeeServiceImpl.java

@@ -0,0 +1,69 @@
+package hello.service.transaction.impl;
+
+import hello.model.Employee;
+import hello.service.transaction.EmployeeService;
+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.DuplicateKeyException;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.jdbc.Sql;
+import org.springframework.test.context.jdbc.SqlGroup;
+import org.springframework.test.context.junit4.SpringRunner;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import static org.hamcrest.CoreMatchers.equalTo;
+import static org.hamcrest.Matchers.containsInAnyOrder;
+import static org.junit.Assert.assertThat;
+
+@ContextConfiguration(classes = EmployeeServiceImplTestConfig.class)
+@RunWith(SpringRunner.class)
+@SqlGroup({
+        @Sql("/db.sql"),
+})
+public class EmployeeServiceImplTest {
+    @Autowired
+    @Qualifier("EmployeeServiceWithTransaction")
+    private EmployeeService service;
+
+    @Test
+    public void insertList() {
+        Employee employee1 = new Employee(1, "dd", "[email protected]");
+        Employee employee2 = new Employee(2, "dd2", "[email protected]");
+
+        List<Employee> expectedList = new ArrayList<>();
+        expectedList.add(employee1);
+        expectedList.add(employee2);
+
+        service.insertList(expectedList);
+
+        List<Employee> actualList = service.getAll();
+
+        assertThat(actualList, containsInAnyOrder(expectedList.toArray()));
+    }
+
+    @Test
+    public void insertList_WhenDuplicateByEmail() {
+        String sameEmail = "[email protected]";
+        Employee employee1 = new Employee(1, "dd", sameEmail);
+        Employee employee2 = new Employee(2, "dd2", sameEmail);
+
+        List<Employee> expectedList = new ArrayList<>();
+        expectedList.add(employee1);
+        expectedList.add(employee2);
+
+        // will rollback
+        try {
+            service.insertList(expectedList);
+        } catch (DuplicateKeyException e) {
+            e.printStackTrace();
+        }
+
+        List<Employee> actualList = service.getAll();
+
+        assertThat(actualList, equalTo(new ArrayList<Employee>()));
+    }
+}

transaction-declarative/db.sql renamed to transaction-declarative/src/main/resources/db.sql

@@ -0,0 +1,13 @@
+package hello.service.transaction.impl;
+
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.EnableMBeanExport;
+import org.springframework.jmx.support.RegistrationPolicy;
+
+@Configuration
+@ComponentScan("hello")
+@EnableMBeanExport(registration=RegistrationPolicy.IGNORE_EXISTING)
+public class EmployeeServiceImplTestConfig {
+
+}