Example of spring transaction and async

Author: YogenRaii

spring-trasaction/src/main/java/com/eprogrammerz/examples/spring/springtrasaction/AppRunner.java

@@ -1,29 +1,53 @@
 package com.eprogrammerz.examples.spring.springtrasaction;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.CommandLineRunner;
-import org.springframework.context.ApplicationContext;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.core.task.TaskExecutor;
 import org.springframework.stereotype.Component;
+import org.springframework.util.Assert;
+
+import java.util.List;
 
 @Component
 public class AppRunner implements CommandLineRunner {
-    @Autowired
-    private ApplicationContext appContext;
+    private static final Logger log = LoggerFactory.getLogger(AppRunner.class);
 
     @Autowired
-    private TaskExecutor taskExecutor;
+    private BookingService bookingService;
 
     @Override
     public void run(String... args) throws Exception {
-        Runnable t1 = this.appContext.getBean(SpringTxThread.class);
-        taskExecutor.execute(t1);
+        bookingService.book("yogen", "pratima", "esma");
+
+        List<String> bookings = bookingService.findAllBookings().get();
+        Assert.isTrue(bookings.size() == 3, "Booking should be for 3");
+
+        log.info("Bookings: {}", bookings);
+
+        try {
+            bookingService.book("sabina", "prateema", "yogs");
+        } catch (RuntimeException e) {
+            log.info(" --- this is because 'prateema' violates constraints ----");
+            log.error(e.getMessage());
+        }
+
+        bookings = bookingService.findAllBookings().get();
+        Assert.isTrue(bookings.size() == 3, "Still booking should be for 3");
+
+        log.info("Bookings: {}", bookings);
+
+        try {
+            bookingService.book("sabina", null, "yogs");
+        } catch (RuntimeException e) {
+            log.info(" --- this is because 'null' violates constraints ----");
+            log.error(e.getMessage());
+        }
+        bookings = bookingService.findAllBookings().get();
+        Assert.isTrue(bookings.size() == 3, "Still booking should be for 3");
+
+        log.info("Bookings: {}", bookings);
 
-        Runnable t2 = this.appContext.getBean(SpringTxThread.class);
-        taskExecutor.execute(t2);
 
-        Runnable t3 = this.appContext.getBean(SpringTxThread.class);
-        taskExecutor.execute(t3);
     }
 }

spring-trasaction/src/main/java/com/eprogrammerz/examples/spring/springtrasaction/BookingService.java

@@ -0,0 +1,46 @@
+package com.eprogrammerz.examples.spring.springtrasaction;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+import java.util.concurrent.CompletableFuture;
+
+@Service
+public class BookingService {
+    private final static Logger log = LoggerFactory.getLogger(BookingService.class);
+
+    @Autowired
+    private JdbcTemplate jdbcTemplate;
+
+    /**
+     * Send and forget async method
+     *
+     * @param persons
+     */
+    @Transactional
+//    @Async
+    public void book(String... persons) {
+        for (String person : persons) {
+            log.info("Booking {} in a seat . . .", person);
+            jdbcTemplate.update("insert into BOOKINGS(FIRST_NAME) values(?)", person);
+        }
+    }
+
+    /**
+     * The result should be wrapped in CompleteableFuture for function returning value
+     *
+     * @return
+     */
+    @Async
+    public CompletableFuture<List<String>> findAllBookings() {
+        log.info("Querying bookings . . .");
+        List<String> bookings = jdbcTemplate.query("select FIRST_NAME from BOOKINGS", ((rs, rowNum) -> rs.getString("FIRST_NAME")));
+        return CompletableFuture.completedFuture(bookings);
+    }
+}

spring-trasaction/src/main/java/com/eprogrammerz/examples/spring/springtrasaction/SpringTrasactionApplication.java

@@ -2,8 +2,10 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableAsync;
 
 @SpringBootApplication
+@EnableAsync
 public class SpringTrasactionApplication {
 
 	public static void main(String[] args) {

spring-trasaction/src/main/java/com/eprogrammerz/examples/spring/springtrasaction/SpringTxThread.java

@@ -0,0 +1,2 @@
+drop table BOOKINGS if exists;
+create table BOOKINGS(IID serial, FIRST_NAME varchar(7) NOT NULL);