BAEL-3737 Calling Stored Procedures from Spring Data JPA Repositories

spring-boot-modules/spring-boot-jpa/pom.xml

@@ -0,0 +1,61 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+	    <version>2.2.4.RELEASE</version>
+        <relativePath /> <!-- lookup parent from repository -->
+    </parent>
+    <groupId>com.baeldung</groupId>
+    <artifactId>jpa</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+    <name>spring-boot-jpa</name>
+    <description>spring-boot-jpa</description>
+
+    <properties>
+        <java.version>1.8</java.version>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-jdbc</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-jpa</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>com.h2database</groupId>
+            <artifactId>h2</artifactId>
+            <scope>runtime</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+		    <artifactId>spring-boot-starter-test</artifactId>
+		    <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>

spring-boot-modules/spring-boot-jpa/src/main/java/com/baeldung/jpa/SpringBootJpaApplication.java

@@ -0,0 +1,13 @@
+package com.baeldung.jpa;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class SpringBootJpaApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(SpringBootJpaApplication.class, args);
+    }
+
+}

spring-boot-modules/spring-boot-jpa/src/main/java/com/baeldung/jpa/controller/CarController.java

@@ -0,0 +1,27 @@
+package com.baeldung.jpa.controller;
+
+import java.util.List;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import com.baeldung.jpa.entity.Car;
+import com.baeldung.jpa.service.CarService;
+
+@RestController
+public class CarController {
+    @Autowired
+    private CarService carService;
+
+    @GetMapping(path = "/modelcount")
+    public long getTotalCarsByModel(@RequestParam("model") String model) {
+        return carService.getTotalCarsByModel(model);
+    }
+
+    @GetMapping(path = "/carsafteryear")
+    public List<Car> findCarsAfterYear(@RequestParam("year") Integer year) {
+        return carService.findCarsAfterYear(year);
+    }
+}

spring-boot-modules/spring-boot-jpa/src/main/java/com/baeldung/jpa/entity/Car.java

@@ -0,0 +1,34 @@
+package com.baeldung.jpa.entity;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.GenerationType;
+import javax.persistence.Id;
+
+@Entity
+public class Car {
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column
+    private long id;
+
+    @Column
+    private String model;
+
+    @Column
+    private Integer year;
+
+    public long getId() {
+        return id;
+    }
+
+    public String getModel() {
+        return model;
+    }
+
+    public Integer getYear() {
+        return year;
+    }
+
+}

spring-boot-modules/spring-boot-jpa/src/main/java/com/baeldung/jpa/repository/CarRepository.java

@@ -0,0 +1,22 @@
+package com.baeldung.jpa.repository;
+
+import java.util.List;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.jpa.repository.query.Procedure;
+import org.springframework.data.repository.query.Param;
+import org.springframework.stereotype.Repository;
+
+import com.baeldung.jpa.entity.Car;
+
+@Repository
+public interface CarRepository extends JpaRepository<Car, Integer> {
+
+    @Procedure(procedureName = "GET_TOTAL_CARS_BY_MODEL")
+    int getTotalCarsByModel(@Param("model_in") String model);
+
+    @Query(value = "CALL FIND_CARS_AFTER_YEAR(:year_in);", nativeQuery = true)
+    List<Car> findCarsAfterYear(@Param("year_in") Integer year_in);
+
+}

spring-boot-modules/spring-boot-jpa/src/main/java/com/baeldung/jpa/service/CarService.java

@@ -0,0 +1,23 @@
+package com.baeldung.jpa.service;
+
+import java.util.List;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import com.baeldung.jpa.entity.Car;
+import com.baeldung.jpa.repository.CarRepository;
+
+@Service
+public class CarService {
+    @Autowired
+    private CarRepository carRepository;
+
+    public int getTotalCarsByModel(String model) {
+        return carRepository.getTotalCarsByModel(model);
+    }
+
+    public List<Car> findCarsAfterYear(Integer year) {
+        return carRepository.findCarsAfterYear(year);
+    }
+}

spring-boot-modules/spring-boot-jpa/src/main/resources/application.properties

@@ -0,0 +1,17 @@
+
+#spring.jpa.hibernate.ddl-auto=validate
+
+#MySql
+spring.datasource.url=jdbc:mysql://localhost:3306/baeldung
+spring.datasource.username=baeldung
+spring.datasource.password=baeldung
+#spring.datasource.driver-class-name=com.mysql.jdbc.Driver
+#spring.datasource.platform=mysql
+#spring.datasource.initialization-mode=always
+#spring.jpa.properties.hibernate.dialect = org.hibernate.dialect.MySQL5Dialect
+
+
+
+#For debugging 
+#spring.jpa.show-sql = true
+

spring-boot-modules/spring-boot-jpa/src/main/resources/car-mysql.sql

@@ -0,0 +1,27 @@
+DROP TABLE IF EXISTS car;
+
+CREATE TABLE car (id int(10) NOT NULL AUTO_INCREMENT, 
+    model varchar(50) NOT NULL, 
+    year int(4) NOT NULL, 
+    PRIMARY KEY (id));
+ 
+INSERT INTO car (model, year) VALUES ('BMW', 2000);
+INSERT INTO car (model, year) VALUES ('BENZ', 2010);
+INSERT INTO car (model, year) VALUES ('PORCHE', 2005);
+INSERT INTO car (model, year) VALUES ('PORCHE', 2004);
+
+DELIMITER $$
+
+DROP PROCEDURE IF EXISTS FIND_CARS_AFTER_YEAR$$
+CREATE PROCEDURE FIND_CARS_AFTER_YEAR(IN year_in INT)
+BEGIN 
+    SELECT * FROM car WHERE year >= year_in ORDER BY year;
+END$$
+
+DROP PROCEDURE IF EXISTS GET_TOTAL_CARS_BY_MODEL$$
+CREATE PROCEDURE GET_TOTAL_CARS_BY_MODEL(IN model_in VARCHAR(50), OUT count_out INT)
+BEGIN 
+    SELECT COUNT(*) into count_out from car WHERE model = model_in;
+END$$
+
+DELIMITER ;

spring-boot-modules/spring-boot-jpa/src/test/java/com/baeldung/jpa/SpringBootJpaApplicationTests.java

@@ -0,0 +1,13 @@
+package com.baeldung.jpa;
+
+import org.junit.jupiter.api.Test;
+import org.springframework.boot.test.context.SpringBootTest;
+
+@SpringBootTest
+class SpringBootJpaApplicationTests {
+
+    @Test
+    void contextLoads() {
+    }
+
+}