EMPLOYEE CLASS

Author: nonogram999

src/main/java/com/napier/sem/App.java

@@ -3,24 +3,41 @@
 import java.sql.*;
 
 public class App {
+    // Hold the connection for this instance
+    private Connection con = null;
 
-    public static void main(String[] args)
-    {
-            // Create new Application
-            App a = new App();
+    public static void main(String[] args) {
+        // Create new Application
+        App a = new App();
 
-            // Connect to database
-            a.connect();
+        // Connect to database
+        a.connect();
 
-            // Disconnect from database
-            a.disconnect();
-        }
-    private Connection con = null;
+        a.disconnect();
+    }
+    public Employee getEmployee(int id) {
+        try {
+            Statement stmt = con.createStatement();
+            String query =
+                    "SELECT emp_no, first_name, last_name " +
+                            "FROM employees " +
+                            "WHERE emp_no = " + id;
+            ResultSet rs = stmt.executeQuery(query);
+
+            if (!rs.next()) return null;
 
-    public void connect() { /* load driver + DriverManager.getConnection(...) */ }
+            Employee e = new Employee();
+            e.emp_no = rs.getInt("emp_no");
+            e.first_name = rs.getString("first_name");
+            e.last_name = rs.getString("last_name");
+            return e;
+        } catch (SQLException ex) {
+            System.out.println(ex.getMessage());
+            return null;
+        }
+    }
 
-    public void disconnect() { /* close con if not null */ }
-    {
+    public void connect() {
         try {
             // Load Database driver
             Class.forName("com.mysql.cj.jdbc.Driver");
@@ -29,37 +46,39 @@ public void disconnect() { /* close con if not null */ }
             System.exit(-1);
         }
 
-        // Connection to the database
-        Connection con = null;
         int retries = 100;
         for (int i = 0; i < retries; ++i) {
             System.out.println("Connecting to database...");
             try {
                 // Wait a bit for db to start
                 Thread.sleep(30000);
-                // Connect to database
-                con = DriverManager.getConnection("jdbc:mysql://db:3306/employees?allowPublicKeyRetrieval=true&useSSL=false", "root", "example");
+
+                // Connect to database — NOTE: assign to the FIELD, not a local var
+                con = DriverManager.getConnection(
+                        "jdbc:mysql://db:3306/employees?allowPublicKeyRetrieval=true&useSSL=false",
+                        "root",
+                        "example"
+                );
+
                 System.out.println("Successfully connected");
-                // Wait a bit
-                Thread.sleep(10000);
-                // Exit for loop
-                break;
+                return; // success
             } catch (SQLException sqle) {
-                System.out.println("Failed to connect to database attempt " + Integer.toString(i));
+                System.out.println("Failed to connect to database attempt " + i);
                 System.out.println(sqle.getMessage());
             } catch (InterruptedException ie) {
                 System.out.println("Thread interrupted? Should not happen.");
             }
         }
+    }
 
+    public void disconnect() {
         if (con != null) {
             try {
-                // Close connection
                 con.close();
-            } catch (Exception e) {
+                System.out.println("Disconnected");
+            } catch (SQLException e) {
                 System.out.println("Error closing connection to database");
             }
         }
     }
-
-}
+}

src/main/java/com/napier/sem/Employee.java

@@ -0,0 +1,42 @@
+package com.napier.sem;
+
+/**
+ * Represents an employee
+ */
+public class Employee
+{
+    /**
+     * Employee number
+     */
+    public int emp_no;
+
+    /**
+     * Employee's first name
+     */
+    public String first_name;
+
+    /**
+     * Employee's last name
+     */
+    public String last_name;
+
+    /**
+     * Employee's job title
+     */
+    public String title;
+
+    /**
+     * Employee's salary
+     */
+    public int salary;
+
+    /**
+     * Employee's current department
+     */
+    public String dept_name;
+
+    /**
+     * Employee's manager
+     */
+    public String manager;
+}

src/main/java/com/napier/sem/Main.java

@@ -0,0 +1,17 @@
+package com.napier.sem;
+
+//TIP To <b>Run</b> code, press <shortcut actionId="Run"/> or
+// click the <icon src="AllIcons.Actions.Execute"/> icon in the gutter.
+public class Main {
+    public static void main(String[] args) {
+        //TIP Press <shortcut actionId="ShowIntentionActions"/> with your caret at the highlighted text
+        // to see how IntelliJ IDEA suggests fixing it.
+        System.out.printf("Hello and welcome!");
+
+        for (int i = 1; i <= 5; i++) {
+            //TIP Press <shortcut actionId="Debug"/> to start debugging your code. We have set one <icon src="AllIcons.Debugger.Db_set_breakpoint"/> breakpoint
+            // for you, but you can always add more by pressing <shortcut actionId="ToggleLineBreakpoint"/>.
+            System.out.println("i = " + i);
+        }
+    }
+}