Added source code

Author: amrutprabhu

src/main/java/com/amrut/prabhu/bulkdatainsert/Book.java

@@ -0,0 +1,24 @@
+package com.amrut.prabhu.bulkdatainsert;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import javax.persistence.*;
+
+@Data
+@Builder
+@Entity
+@NoArgsConstructor
+@AllArgsConstructor
+public class Book {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.SEQUENCE, generator = "seqGen")
+    @SequenceGenerator(name = "seqGen", sequenceName = "seq", initialValue = 1)
+    private Long id;
+    private String name;
+    private Integer Price;
+
+}

src/main/java/com/amrut/prabhu/bulkdatainsert/BookRepository.java

@@ -0,0 +1,9 @@
+package com.amrut.prabhu.bulkdatainsert;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface BookRepository extends JpaRepository<Book, String> {
+
+}

src/main/java/com/amrut/prabhu/bulkdatainsert/BulkDataInsertApplication.java

@@ -0,0 +1,58 @@
+package com.amrut.prabhu.bulkdatainsert;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.context.event.ApplicationReadyEvent;
+import org.springframework.context.event.EventListener;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.stream.Collectors;
+import java.util.stream.IntStream;
+
+@SpringBootApplication
+public class BulkDataInsertApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(BulkDataInsertApplication.class, args);
+    }
+
+    @Autowired
+    private BookRepository repository;
+
+   @Value("${spring.jpa.properties.hibernate.jdbc.batch_size}")
+    private int batchSize;
+
+    @EventListener(ApplicationReadyEvent.class)
+    public void doSomethingAfterStartup() {
+
+        int totalObjects = 10000;
+
+        long start = System.currentTimeMillis();
+        List<Book> books = IntStream.range(0, totalObjects)
+                .mapToObj(val -> Book.builder()
+                        .name("books" + val)
+                        .Price(val)
+                        .build())
+                .collect(Collectors.toList());
+
+        System.out.println("Finished creating "+totalObjects+" objects in memory in:" + (System.currentTimeMillis() - start)/1000);
+
+        start = System.currentTimeMillis();
+        System.out.println("Inserting ..........");
+
+        for (int i = 0; i < totalObjects; i += batchSize) {
+            if( i+ batchSize > totalObjects){
+                List<Book> books1 = books.subList(i, totalObjects - 1);
+                repository.saveAll(books1);
+                break;
+            }
+            List<Book> books1 = books.subList(i, i + batchSize);
+            repository.saveAll(books1);
+        }
+
+        System.out.println("Finished inserting "+totalObjects+" objects in :" + (System.currentTimeMillis() - start));
+    }
+}

src/main/resources/application.yaml

@@ -0,0 +1,17 @@
+spring:
+  datasource:
+    url: jdbc:mysql://localhost:13306/BOOK_DB?serverTimezone=UTC&cachePrepStmts=true&useServerPrepStmts=true&rewriteBatchedStatements=true
+    username: root
+    password: zZijbfa64LnL2quYCFyH5jcRn2f3iUNLSrfRwiX3
+  jpa:
+   # show-sql: true
+    generate-ddl: true
+    properties:
+      hibernate:
+        jdbc:
+          batch_size: 1000
+#        cache:
+#          use_second_level_cache: true
+#        order_updates: true
+#        order_inserts: true
+#        generate_statistics: true