003 create delivery employee

src/main/java/org/example/controllers/DeliveryEmployeeController.java

@@ -1,9 +1,13 @@
 package org.example.controllers;
 
 import io.swagger.annotations.Api;
+import org.example.exceptions.DoesNotExistException;
+import org.example.exceptions.FailedToCreateException;
+import org.example.models.DeliveryEmployeeRequest;
 import org.example.services.DeliveryEmployeeService;
 
 import javax.ws.rs.GET;
+import javax.ws.rs.POST;
 import javax.ws.rs.Path;
 import javax.ws.rs.Produces;
 import javax.ws.rs.core.MediaType;
@@ -15,6 +19,7 @@
 @Api("Delivery Employee API")
 @Path("/api/DeliveryEmployees")
 public class DeliveryEmployeeController {
+
     DeliveryEmployeeService deliveryEmployeeService;
 
     public DeliveryEmployeeController(
@@ -33,4 +38,26 @@ public Response testConnection() {
             return Response.serverError().build();
         }
     }
+
+    @POST
+    @Produces(MediaType.APPLICATION_JSON)
+    public Response createProduct(
+            final DeliveryEmployeeRequest deliveryEmployeeRequest) {
+        try {
+            return Response
+                    .status(Response.Status.CREATED)
+                    .entity(deliveryEmployeeService.createDeliveryEmployee(
+                            deliveryEmployeeRequest))
+                    .build();
+        } catch (SQLException | FailedToCreateException e) {
+            return Response.serverError().build();
+        } catch (DoesNotExistException e) {
+            return Response.status(Response.Status.BAD_REQUEST)
+                    .entity(e.getMessage()).build();
+        }
+    }
+
 }
+
+
+

src/main/java/org/example/daos/DatabaseConnector.java

@@ -9,7 +9,7 @@ public final class DatabaseConnector {
     private DatabaseConnector() { }
     public static Connection getConnection() throws SQLException {
 
-        if (conn != null && !conn.isClosed()) {
+        if (conn != null && conn.isValid(0)) {
             return conn;
         }
 

src/main/java/org/example/daos/DeliveryEmployeeDao.java

@@ -1,11 +1,10 @@
 package org.example.daos;
 
 import org.example.models.DeliveryEmployee;
+import org.example.models.DeliveryEmployeeRequest;
 
-import java.sql.Connection;
-import java.sql.ResultSet;
-import java.sql.SQLException;
-import java.sql.Statement;
+
+import java.sql.*;
 import java.util.ArrayList;
 import java.util.List;
 
@@ -26,7 +25,7 @@ public List<DeliveryEmployee> getAllDeliveryEmployees()
                         resultSet.getInt("id"),
                         resultSet.getString("name"),
                         resultSet.getDouble("salary"),
-                        resultSet.getInt("bank_acc"),
+                        resultSet.getString("bank_acc"),
                         resultSet.getString("ni")
                 );
                 deliveryEmployees.add(deliveryEmployee);
@@ -35,4 +34,34 @@ public List<DeliveryEmployee> getAllDeliveryEmployees()
 
         return deliveryEmployees;
     }
+
+    public int createDeliveryEmployee(
+            final DeliveryEmployeeRequest deliveryEmployeeRequest)
+            throws SQLException {
+        Connection c =
+                DatabaseConnector.getConnection();
+        String insertStatement =
+                "INSERT INTO DeliveryEmployees "
+                        + "(`name`, salary, bank_acc, ni) VALUES (?,?,?,?);";
+
+        PreparedStatement st =
+                c.prepareStatement(
+                        insertStatement, Statement.RETURN_GENERATED_KEYS);
+
+        st.setString(1, deliveryEmployeeRequest.getName());
+        st.setDouble(2, deliveryEmployeeRequest.getSalary());
+        st.setString(2 + 1, deliveryEmployeeRequest.getBankAccount());
+        st.setString(2 + 2, deliveryEmployeeRequest.getnI());
+
+        st.executeUpdate();
+
+        ResultSet rs = st.getGeneratedKeys();
+
+        if (rs.next()) {
+            return rs.getInt(1);
+        }
+
+        return -1;
+
+    }
 }

src/main/java/org/example/exceptions/DoesNotExistException.java

@@ -0,0 +1,6 @@
+package org.example.exceptions;
+
+public class DoesNotExistException extends Throwable{
+    public DoesNotExistException(final Entity entity){super(entity.getEntity() + " does not exist");
+    }
+}

src/main/java/org/example/exceptions/Entity.java

@@ -0,0 +1,15 @@
+package org.example.exceptions;
+
+public enum Entity {
+    DELIVERYEMPLOYEE("Delivery Employee");
+
+    private final String entity;
+
+    Entity(String entity) {
+        this.entity = entity;
+    }
+
+    public String getEntity() {
+        return entity;
+    }
+}

src/main/java/org/example/exceptions/FailedToCreateException.java

@@ -0,0 +1,7 @@
+package org.example.exceptions;
+
+public class FailedToCreateException extends Throwable {
+    public FailedToCreateException(Entity entity){
+        super(entity.getEntity()+ " has failed to create");
+    }
+}

src/main/java/org/example/exceptions/InvalidException.java

@@ -0,0 +1,9 @@
+package org.example.exceptions;
+
+public class InvalidException extends Throwable {
+
+    public InvalidException(final Entity entity, final String reason){
+        super(entity.getEntity() + " is not valid: " + reason);
+    }
+
+}

src/main/java/org/example/models/DeliveryEmployee.java

@@ -4,11 +4,11 @@ public class DeliveryEmployee {
     private int id;
     private String name;
     private double salary;
-    private int bankAccount;
+    private String bankAccount;
     private String nI;
 
     public DeliveryEmployee(final int id, final String name,
-                            final double salary, final int bankAccount,
+                            final double salary, final String bankAccount,
                             final String nI) {
         this.setId(id);
         this.setName(name);
@@ -41,11 +41,11 @@ public void setSalary(final double salary) {
         this.salary = salary;
     }
 
-    public int getBankAccount() {
+    public String getBankAccount() {
         return bankAccount;
     }
 
-    public void setBankAccount(final int bankAccount) {
+    public void setBankAccount(final String bankAccount) {
         this.bankAccount = bankAccount;
     }
 

src/main/java/org/example/models/DeliveryEmployeeRequest.java

@@ -0,0 +1,56 @@
+package org.example.models;
+
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+public class DeliveryEmployeeRequest {
+    private String name;
+    private double salary;
+    private String bankAccount;
+    private String nI;
+
+    @JsonCreator
+    public DeliveryEmployeeRequest(
+            final @JsonProperty("name") String name,
+            final @JsonProperty("salary") double salary,
+            final @JsonProperty("bankAccount") String bankAccount,
+            final @JsonProperty("nI") String nI) {
+
+        this.name = name;
+        this.salary = salary;
+        this.bankAccount = bankAccount;
+        this.nI = nI;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(final String name) {
+        this.name = name;
+    }
+
+    public double getSalary() {
+        return salary;
+    }
+
+    public void setSalary(final double salary) {
+        this.salary = salary;
+    }
+
+    public String getBankAccount() {
+        return bankAccount;
+    }
+
+    public void setBankAccount(final String bankAccount) {
+        this.bankAccount = bankAccount;
+    }
+
+    public String getnI() {
+        return nI;
+    }
+
+    public void setnI(final String nI) {
+        this.nI = nI;
+    }
+}

src/main/java/org/example/services/DeliveryEmployeeService.java

@@ -1,7 +1,11 @@
 package org.example.services;
 
 import org.example.daos.DeliveryEmployeeDao;
+import org.example.exceptions.DoesNotExistException;
+import org.example.exceptions.FailedToCreateException;
 import org.example.models.DeliveryEmployee;
+import org.example.models.DeliveryEmployeeRequest;
+import org.example.exceptions.Entity;
 
 import java.sql.SQLException;
 import java.util.List;
@@ -19,5 +23,18 @@ public List<DeliveryEmployee> getAllDeliveryEmployees()
         return deliveryEmployeeDao.getAllDeliveryEmployees();
     }
 
+    public int createDeliveryEmployee(
+            final DeliveryEmployeeRequest deliveryEmployeeRequest)
+            throws FailedToCreateException,
+            SQLException, DoesNotExistException {
+        int id = deliveryEmployeeDao
+                .createDeliveryEmployee(deliveryEmployeeRequest);
+
+        if (id == -1) {
+            throw new FailedToCreateException(Entity.DELIVERYEMPLOYEE);
+        }
+        return id;
+    }
+
 
 }