implmeneting crud using JPA

Author: HMahat-ai

docker-compose.yml

@@ -0,0 +1,22 @@
+services:
+  db:
+    container_name: postgres-spring
+    image: postgres
+    environment:
+      POSTGRES_USER: harimahat
+      POSTGRES_PASSWORD: password
+      PGDATA: /data/postgres-spring
+    volumes:
+      - db:/data/postgres-spring
+    ports:
+      - "5432:5432"
+    networks:
+      - db
+    restart: unless-stopped
+
+networks:
+  db:
+    driver: bridge
+volumes:
+  db:
+

pom.xml

@@ -27,6 +27,15 @@
 			<artifactId>spring-boot-starter-test</artifactId>
 			<scope>test</scope>
 		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-data-jpa</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.postgresql</groupId>
+			<artifactId>postgresql</artifactId>
+			<scope>runtime</scope>
+		</dependency>
 	</dependencies>
 
 	<build>

src/main/java/com/harimahat/Main.java

@@ -1,8 +1,11 @@
 package com.harimahat;
 
 import com.harimahat.customer.Customer;
+import com.harimahat.customer.CustomerRepository;
+import org.springframework.boot.CommandLineRunner;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.Bean;
 import org.springframework.web.bind.annotation.*;
 
 import java.util.ArrayList;
@@ -20,6 +23,17 @@ public static void main(String[] args) {
         SpringApplication.run(Main.class, args);
 
     }
+    @Bean
+    CommandLineRunner runner( CustomerRepository customerRepository){
+        return  args -> {
+            Customer alex=  new Customer( "Alex", "[email protected]", 29);
+            Customer john=  new Customer( "John", "[email protected]", 49);
+            Customer alexa=  new Customer( "Alexa", "[email protected]", 19);
+
+            List<Customer>customers= List.of(alex, john, alexa);
+            customerRepository.saveAll(customers);
+        };
+    }
 
 }
 

src/main/java/com/harimahat/customer/Customer.java

@@ -1,31 +1,56 @@
 package com.harimahat.customer;
 
+import jakarta.persistence.*;
+
 /**
  * @Author hari.mahat on 27.7.2023
  * Project learn-spring3
  */
-
+@Entity
 public  class Customer {
+    @Id
+    @SequenceGenerator(
+            name = "customer_id_sequence",
+            sequenceName = "customer_id_sequence"
+    )
+    @GeneratedValue(
+            strategy = GenerationType.SEQUENCE,
+            generator = "customer_id_sequence"
+    )
     private Integer  id;
+    @Column(
+            nullable = false
+    )
     private String name;
+    @Column(
+            nullable = false
+    )
     private String email;
+    @Column(
+            nullable = false
+    )
     private Integer age;
 
-    public Customer(Integer id, String name, String email, Integer age) {
-        this.id = id;
+     public Customer() {
+
+    }
+
+    public Customer( Integer id, String name, String email, Integer age) {
+        this.id=id;
         this.name = name;
         this.email = email;
         this.age = age;
     }
 
-    public Integer getId() {
-        return id;
+    public Customer(String name, String email, Integer age) {
+        this.name = name;
+        this.email = email;
+        this.age = age;
     }
 
-    public void setId(Integer id) {
-        this.id = id;
+    public Integer getId() {
+        return id;
     }
-
     public String getName() {
         return name;
     }

src/main/java/com/harimahat/customer/CustomerController.java

@@ -1,8 +1,6 @@
 package com.harimahat.customer;
 
-import org.springframework.web.bind.annotation.PathVariable;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 
 import java.util.List;
 
@@ -13,6 +11,7 @@
  * Project learn-spring3
  */
 @RestController
+@RequestMapping("api/v1/customers")
 public class CustomerController {
 
     private final CustomerService customerService;
@@ -21,13 +20,29 @@ public CustomerController(CustomerService customerService) {
         this.customerService = customerService;
     }
 
-    @RequestMapping(path = "api/v1/customers",method = GET)
+    @GetMapping
     public List<Customer> getCustomers(){
         return customerService.getAllCustomers();
     }
 
-    @RequestMapping(path = "api/v1/customers/{customerId}", method = GET)
+    @PostMapping
+    public void registerCustomer(@RequestBody CustomerRegistrationRequest customerRegistrationRequest){
+        customerService.addCustomer(customerRegistrationRequest);
+    }
+
+    @GetMapping("/{customerId}")
     public Customer getCustomer(@PathVariable("customerId") Integer customerId){
         return customerService.getCustomerById(customerId);
     }
+
+    @DeleteMapping("/{customerId}")
+    public void deleteCustomer(@PathVariable("customerId") Integer customerId){
+        customerService.deleteCustomerById(customerId);
+    }
+
+    @PutMapping("/{customerId}")
+    public void updateCustomer(@PathVariable("customerId") Integer customerId, @RequestBody CustomerUpdateRequest customerUpdateRequest){
+         customerService.updateCustomerById(customerId, customerUpdateRequest);
+    }
+
 }

src/main/java/com/harimahat/customer/CustomerDao.java

@@ -1,5 +1,7 @@
 package com.harimahat.customer;
 
+import jakarta.persistence.criteria.CriteriaBuilder;
+
 import java.util.List;
 import java.util.Optional;
 
@@ -10,7 +12,20 @@
 
 public interface CustomerDao {
 
-    public List<Customer> selectAllCustomers();
+    List<Customer> selectAllCustomers();
 
     Optional <Customer> selectCustomerById(Integer customerId);
+
+    void insertCustomer( Customer customer);
+
+    void  deleteCustomerById(Integer customerId);
+
+    void  updateCustomer(Customer update);
+
+    boolean existPersonWithEmail(String emailcustomer);
+
+    boolean existPersonWithId(Integer customerId);
+
+
+
 }

src/main/java/com/harimahat/customer/CustomerJPADataAccessService.java

@@ -0,0 +1,55 @@
+package com.harimahat.customer;
+
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+import java.util.Optional;
+
+/**
+ * @Author hari.mahat on 28.7.2023
+ * Project learn-spring3
+ */
+@Repository("jpa")
+public class CustomerJPADataAccessService implements CustomerDao{
+
+    private final CustomerRepository customerRepository;
+
+    public CustomerJPADataAccessService(CustomerRepository customerRepository) {
+        this.customerRepository = customerRepository;
+    }
+
+    @Override
+    public List<Customer> selectAllCustomers() {
+        return customerRepository.findAll();
+    }
+
+    @Override
+    public Optional<Customer> selectCustomerById(Integer customerId) {
+        return customerRepository.findById(customerId);
+    }
+
+    @Override
+    public void insertCustomer(Customer customer) {
+        customerRepository.save(customer);
+    }
+
+    @Override
+    public void deleteCustomerById(Integer customerId) {
+        customerRepository.deleteById(customerId);
+    }
+
+    @Override
+    public void updateCustomer(Customer update) {
+        customerRepository.save(update);
+    }
+
+    @Override
+    public boolean existPersonWithEmail(String email) {
+        return customerRepository.existsCustomerByEmail(email);
+    }
+
+    @Override
+    public boolean  existPersonWithId(Integer customerId) {
+        return customerRepository.existsCustomerById(customerId);
+    }
+}

src/main/java/com/harimahat/customer/CustomerDataAccessService.java renamed to src/main/java/com/harimahat/customer/CustomerListDataAccessService.java

@@ -11,14 +11,14 @@
  * Project learn-spring3
  */
 
-@Repository
-public class CustomerDataAccessService implements  CustomerDao{
+@Repository("list")
+public class CustomerListDataAccessService implements  CustomerDao{
 
 
 
     private final List<Customer> customers ;
 
-    public CustomerDataAccessService() {
+    public CustomerListDataAccessService() {
         this.customers= new ArrayList<>();
         Customer alex=  new Customer(1, "Alex", "[email protected]", 29);
         Customer john=  new Customer(2, "John", "[email protected]", 49);
@@ -39,4 +39,34 @@ public Optional<Customer> selectCustomerById(Integer customerId) {
                 .filter(c -> c.getId().equals(customerId))
                 .findFirst();
     }
+
+    @Override
+    public void insertCustomer(Customer customer) {
+        customers.add(customer);
+    }
+
+    @Override
+    public void deleteCustomerById(Integer customerId) {
+        customers
+                .stream()
+                .filter(c->c.getId().equals(customerId))
+                .findFirst()
+                .ifPresent(customers::remove);
+    }
+
+    @Override
+    public void updateCustomer(Customer update) {
+        customers.add(update);
+    }
+
+    @Override
+    public boolean existPersonWithEmail(String email) {
+        return customers.stream()
+                .anyMatch(customer -> customer.getEmail().equals(email));
+    }
+
+    @Override
+    public boolean existPersonWithId(Integer customerId) {
+        return customers.stream().anyMatch(customer -> customer.getId().equals(customerId));
+    }
 }

src/main/java/com/harimahat/customer/CustomerRegistrationRequest.java

@@ -0,0 +1,11 @@
+package com.harimahat.customer;
+
+/**
+ * @Author hari.mahat on 28.7.2023
+ * Project learn-spring3
+ */
+public record CustomerRegistrationRequest (
+    String name,
+    String email,
+    Integer age
+){};

src/main/java/com/harimahat/customer/CustomerRepository.java

@@ -0,0 +1,13 @@
+package com.harimahat.customer;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+
+/**
+ * @Author hari.mahat on 28.7.2023
+ * Project learn-spring3
+ */
+public interface CustomerRepository extends JpaRepository<Customer, Integer> {
+
+        boolean existsCustomerByEmail(String email);
+        boolean existsCustomerById(Integer id);
+}