006 get sales by id

src/main/java/org/example/TestApplication.java

@@ -5,33 +5,61 @@
 import io.dropwizard.setup.Environment;
 import io.federecio.dropwizard.swagger.SwaggerBundle;
 import io.federecio.dropwizard.swagger.SwaggerBundleConfiguration;
+
+import org.example.controllers.ClientController;
+import org.example.controllers.ProjectController;
 import org.example.controllers.TestController;
+import org.example.daos.ClientDao;
+import org.example.daos.ProjectDao;
 import org.example.daos.TestDao;
+import org.example.services.ClientService;
+
+import org.example.controllers.EmployeeController;
+import org.example.daos.EmployeeDao;
+import org.example.services.EmployeeService;
+
+import org.example.services.ProjectService;
 import org.example.services.TestService;
 
-public class TestApplication extends Application<TestConfiguration> {
+
+public class TestApplication
+        extends Application<TestConfiguration> {
     public static void main(final String[] args) throws Exception {
         new TestApplication().run(args);
     }
     @Override
     public String getName() {
-        return "Test";
+        return "Git and Run";
     }
+
     @Override
     public void initialize(final Bootstrap<TestConfiguration> bootstrap) {
-        bootstrap.addBundle(new SwaggerBundle<>() {
-            @Override
-            protected SwaggerBundleConfiguration getSwaggerBundleConfiguration(
-                    final TestConfiguration configuration) {
-                return configuration.getSwagger();
+        bootstrap.addBundle(
+                new SwaggerBundle<TestConfiguration>() {
+                    @Override
+                    protected SwaggerBundleConfiguration
+                    getSwaggerBundleConfiguration(
+                            final TestConfiguration
+                                    configuration) {
+                        return configuration.getSwagger();
+                    }
+                });
             }
-        });
-    }
+
     @Override
     public void run(final TestConfiguration configuration,
                     final Environment environment) {
         environment.jersey()
                 .register(new TestController(new TestService(new TestDao())));
+        environment.jersey()
+                .register(new ClientController(
+                        new ClientService(new ClientDao())));
+        environment.jersey()
+                .register(new EmployeeController(
+                        new EmployeeService(new EmployeeDao())));
+        environment.jersey()
+                .register(new ProjectController(
+                        new ProjectService(new ProjectDao())));
     }
 
 }

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

@@ -0,0 +1,33 @@
+package org.example.controllers;
+
+import io.swagger.annotations.Api;
+import org.example.services.ClientService;
+
+import javax.ws.rs.GET;
+import javax.ws.rs.Path;
+import javax.ws.rs.Produces;
+import javax.ws.rs.core.MediaType;
+import javax.ws.rs.core.Response;
+import java.sql.SQLException;
+
+@Api("Client API")
+@Path("/api/clients")
+public class ClientController {
+
+    ClientService clientService;
+
+    public ClientController(final ClientService clientService) {
+        this.clientService = clientService;
+    }
+
+    @GET
+    @Produces(MediaType.APPLICATION_JSON)
+    public Response
+    getClients() {
+        try {
+            return Response.ok().entity(clientService.getAllClients()).build();
+        } catch (SQLException e) {
+            return Response.serverError().build();
+        }
+    }
+}

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

@@ -0,0 +1,63 @@
+package org.example.controllers;
+
+import io.swagger.annotations.Api;
+import org.example.exceptions.DoesNotExistException;
+import org.example.services.EmployeeService;
+
+import javax.ws.rs.GET;
+import javax.ws.rs.Path;
+import javax.ws.rs.PathParam;
+import javax.ws.rs.Produces;
+import javax.ws.rs.core.MediaType;
+import javax.ws.rs.core.Response;
+import java.sql.SQLException;
+
+@Api("Employee Services API")
+@Path("/api/employees")
+public class EmployeeController {
+    private EmployeeService employeeService;
+
+    public EmployeeController(final EmployeeService employeeService) {
+        this.employeeService = employeeService;
+    }
+
+    @GET
+    @Path("/sales")
+    @Produces(MediaType.APPLICATION_JSON)
+    public Response getSalesEmployees() throws SQLException {
+        try {
+            return Response.ok().entity(
+                    employeeService.getAllSalesEmployees()).build();
+        } catch (SQLException e) {
+            return Response.serverError().build();
+        }
+    }
+
+    @GET
+    @Path("/delivery")
+    @Produces(MediaType.APPLICATION_JSON)
+    public Response getDeliveryEmployees() throws SQLException {
+        try {
+            return Response.ok().entity(
+                    employeeService.getAllDeliveryEmployees()).build();
+        } catch (SQLException e) {
+            return Response.serverError().build();
+        }
+    }
+    @GET
+    @Path("sales/{id}")
+    @Produces(MediaType.APPLICATION_JSON)
+    public Response getSalesEmployeeById(final @PathParam("id") int id)
+        throws SQLException {
+        try {
+            return Response.ok().entity(
+                    employeeService.getSalesEmployeeById(id))
+                    .build();
+        } catch (DoesNotExistException e) {
+            return Response.status(Response.Status.NOT_FOUND)
+                    .entity(e.getMessage()).build();
+        } catch (SQLException e) {
+            return Response.serverError().build();
+        }
+    }
+}

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

@@ -0,0 +1,35 @@
+package org.example.controllers;
+
+import io.swagger.annotations.Api;
+import org.example.services.ProjectService;
+
+import javax.ws.rs.GET;
+import javax.ws.rs.Path;
+import javax.ws.rs.Produces;
+import javax.ws.rs.core.MediaType;
+import javax.ws.rs.core.Response;
+import java.sql.SQLException;
+
+@Api("Project API")
+@Path("/api/projects")
+public class ProjectController {
+
+    ProjectService projectService;
+
+    public ProjectController(final ProjectService projectService) {
+        this.projectService = projectService;
+    }
+
+    @GET
+    @Produces(MediaType.APPLICATION_JSON)
+    @Path("/highestValue")
+    public Response
+    getHighestValueProject() {
+        try {
+            return Response.ok().entity(projectService
+                    .getHighestValueProject()).build();
+        } catch (SQLException e) {
+            return Response.serverError().build();
+        }
+    }
+}

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

@@ -0,0 +1,40 @@
+package org.example.daos;
+
+import org.example.models.Client;
+import org.example.models.ProjectRequest;
+
+import java.sql.Connection;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.util.ArrayList;
+import java.util.List;
+
+public class ClientDao {
+
+    public List<Client> getAllClients() throws SQLException {
+        List<Client> clients = new ArrayList<>();
+
+        try (Connection connection = DatabaseConnector.getConnection()) {
+            Statement statement = connection.createStatement();
+
+            ResultSet resultSet = statement.executeQuery(
+                    "SELECT client.id AS 'Client ID', "
+                           + "salesID as 'Sales ID', project.id "
+                            + "AS 'Project ID' "
+                           + "FROM `client` JOIN `project` "
+                           + "ON (client.id = project.clientID);");
+
+            while (resultSet.next()) {
+                Client client = new Client(
+                        resultSet.getInt("Client ID"),
+                        resultSet.getInt("Sales ID"),
+                        new ProjectRequest(
+                                resultSet.getInt("Project ID")));
+
+                clients.add(client);
+            }
+            return clients;
+        }
+    }
+}

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

@@ -0,0 +1,108 @@
+package org.example.daos;
+
+import org.example.models.DeliveryEmployee;
+import org.example.models.SalesEmployee;
+
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.List;
+
+public class EmployeeDao {
+
+    public List<SalesEmployee> getAllSalesEmployees() throws SQLException {
+        List<SalesEmployee> salesEmployees = new ArrayList<>();
+
+        try (Connection connection = DatabaseConnector.getConnection()) {
+            String query =
+                    "SELECT employee.id, name, salary,"
+                            +
+                            "bankNumber, nationalInsurance,commissionRate"
+                            +
+                            " from employee"
+                            +
+                            " join sales"
+                            +
+                            " on employee.id = sales.employeeID;";
+            PreparedStatement statement =
+                    connection.prepareStatement(query);
+            ResultSet resultSet = statement.executeQuery();
+
+            while (resultSet.next()) {
+                salesEmployees.add(new SalesEmployee(
+                        resultSet.getInt("id"),
+                        resultSet.getString("name"),
+                        resultSet.getBigDecimal("salary"),
+                        resultSet.getString("bankNumber"),
+                        resultSet.getString("nationalInsurance"),
+                        resultSet.getFloat("commissionRate")));
+            }
+        }
+        return salesEmployees;
+    }
+
+    public List<DeliveryEmployee> getAllDeliveryEmployees()
+            throws SQLException {
+        List<DeliveryEmployee> deliveryEmployees = new ArrayList<>();
+
+        try (Connection connection = DatabaseConnector.getConnection()) {
+            String query =
+                    "SELECT employee.id, name, "
+                            +
+                            "salary,bankNumber, nationalInsurance "
+                            +
+                            "from employee "
+                            +
+                            "join delivery "
+                            +
+                            "on employee.id = delivery.employeeID;";
+            PreparedStatement statement =
+                    connection.prepareStatement(query);
+            ResultSet resultSet = statement.executeQuery();
+
+            while (resultSet.next()) {
+                deliveryEmployees.add(new DeliveryEmployee(
+                        resultSet.getInt("id"),
+                        resultSet.getString("name"),
+                        resultSet.getBigDecimal("salary"),
+                        resultSet.getString("bankNumber"),
+                        resultSet.getString("nationalInsurance")));
+            }
+        }
+        return deliveryEmployees;
+    }
+    public SalesEmployee getSalesEmployeeById(final int id)
+
+            throws SQLException {
+        try (Connection connection = DatabaseConnector.getConnection()) {
+            String query = "SELECT employee.id, name, salary,"
+                    +
+                    "bankNumber, nationalInsurance,commissionRate "
+                    +
+                    "from employee "
+                    +
+                    "right join sales "
+                    +
+                    "on employee.id = sales.employeeID "
+                    +
+                    "where sales.id = ?;";
+            PreparedStatement statement = connection.prepareStatement(query);
+            statement.setInt(1, id);
+
+            ResultSet resultSet = statement.executeQuery();
+
+            while (resultSet.next()) {
+                return new SalesEmployee(
+                        resultSet.getInt("id"),
+                        resultSet.getString("name"),
+                        resultSet.getBigDecimal("salary"),
+                        resultSet.getString("bankNumber"),
+                        resultSet.getString("nationalInsurance"),
+                        resultSet.getFloat("commissionRate"));
+            }
+        }
+        return null;
+    }
+}

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

@@ -0,0 +1,35 @@
+package org.example.daos;
+
+import org.example.models.Project;
+
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+
+public class ProjectDao {
+
+    public Project getHighestValueProject() throws SQLException {
+        Project project = null;
+        try (Connection connection = DatabaseConnector.getConnection()) {
+            String query =
+                    "SELECT id, projectName, projectValue, "
+                            + "techLeadID, clientID FROM `project` "
+                            + "ORDER BY projectValue desc LIMIT 1;";
+            PreparedStatement statement = connection.prepareStatement(query);
+
+            ResultSet resultSet = statement.executeQuery();
+
+            while (resultSet.next()) {
+                project = new Project(
+                        resultSet.getInt("id"),
+                        resultSet.getString("projectName"),
+                        resultSet.getDouble("projectValue"),
+                        resultSet.getInt("techLeadID"),
+                        resultSet.getInt("clientID")
+                );
+            }
+        }
+        return project;
+    }
+}

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

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