Added methods for added and removing positions for a given employee. Position...

Added methods for added and removing positions for a given employee. Position information is also gotten when getting employee info.

SchedulerApp/src/main/java/com/example/scheduler_server/Staff.java

@@ -41,12 +41,13 @@ public class Staff {
             myStatement.executeUpdate("insert into Employees (first_name,last_name,isManager,email,phoneNumber,wage)" +
                     " values ('" + firstName + "','" + lastName + "'," + isManager + ",'" + email + "','" +
                     phoneNumber + "'," + wage + ")");
-            ResultSet myRs = myStatement.executeQuery("select * from Employees where first_name='Rafi' and last_name='Zereselasie'");
+            ResultSet myRs = myStatement.executeQuery("select * from Employees where first_name='" + firstName
+                    + "' and last_name='" + lastName + "'");
             if (myRs.last()) {
                 newEmployee = myRs.getString("employee_ID") + "," + myRs.getString("first_name") +
                         "," + myRs.getString("last_name") + "," + myRs.getString("isManager") +
                         "," + myRs.getString("email") + "," + myRs.getString("phoneNumber") +
-                        "," + myRs.getString("wage");
+                        "," + myRs.getString("wage") + ",";
             }
         } catch (Exception exception) {
             exception.printStackTrace();
@@ -63,7 +64,7 @@ public class Staff {
     Description: Removes the employee with the same ID by querying the database.
     Return: none
      */
-    protected int removeEmployee(int ID){
+    protected int removeEmployee(int ID) {
         try {
             Statement myStatement = dbConnection.createStatement();
             myStatement.executeUpdate("delete from Employees where employee_id = " + ID);
@@ -75,6 +76,52 @@ public class Staff {
         return ID;
     }
 
+    protected String addPosition(int ID, String position) {
+        try {
+            System.out.println(ID + " " + position);
+            Statement myStatement = dbConnection.createStatement();
+            ResultSet myRs = myStatement.executeQuery("select positions from Employees where employee_ID=" + ID);
+            myRs.next();
+            if (myRs.getString("positions").isEmpty()) {
+                myStatement.executeUpdate("update Employees set positions='" + position + "' where employee_ID = " + ID);
+            } else {
+                myStatement.executeUpdate("update Employees set positions=concat(positions,'." + position + "') where employee_ID = " + ID);
+            }
+        } catch (Exception exception) {
+            exception.printStackTrace();
+            return "";
+        }
+        return ID + "/" + position;
+    }
+
+    protected String removePosition(int ID, String position) {
+        String removedPosition = "";
+
+        StringBuilder newPositions = new StringBuilder();
+        try {
+            Statement myStatement = dbConnection.createStatement();
+            ResultSet myRs = myStatement.executeQuery("select positions from Employees where employee_ID=" + ID);
+            myRs.next();
+            for (String s : myRs.getString("positions").split("\\.")) {
+                if (!s.equalsIgnoreCase(position)) {
+                    if (newPositions.isEmpty()) {
+                        newPositions.append(s);
+                    } else {
+                        newPositions.append(".").append(s);
+                    }
+                } else {
+                    removedPosition = ID + "/" + position;
+                }
+            }
+            myStatement.executeUpdate("update Employees set positions='" + newPositions + "' where employee_ID = " + ID);
+        } catch (Exception exception) {
+            exception.printStackTrace();
+            return removedPosition;
+        }
+
+        return removedPosition;
+    }
+
     /*
     Name: printEmployees
     Parameters: none
@@ -93,7 +140,8 @@ public class Staff {
                         .append(myRs.getString("isManager")).append(",")
                         .append(myRs.getString("email")).append(",")
                         .append(myRs.getString("phoneNumber")).append(",")
-                        .append(myRs.getString("wage"));
+                        .append(myRs.getString("wage")).append(",")
+                        .append(myRs.getString("positions"));
             }
         } catch (Exception exception) {
             exception.printStackTrace();