Finished control loop

trtongorm_lab/src/main/java/AccountApp.java

@@ -1,22 +1,16 @@
-import com.j256.ormlite.dao.Dao;
-import com.j256.ormlite.dao.DaoManager;
+
 import com.j256.ormlite.jdbc.JdbcConnectionSource;
 import com.j256.ormlite.support.ConnectionSource;
 
-import java.util.List;
-import java.util.Scanner;
 
 public class AccountApp {
 
     // we are using a MySQl database
     private final static String DATABASE_URL = "jdbc:mysql://localhost:3306/orm_lab?useUnicode=true";
-    // Scanner
-    Console c = new Console();
-
-    private Dao<Account, Integer> accountDao;
+    private Console c = new Console();
 
     public static void main(String[] args) throws Exception {
-        // turn our static method into an instance of Main
+
         new AccountApp().doMain(args);
     }
 
@@ -25,33 +19,23 @@ public class AccountApp {
         try {
             // create our data-source for the database
             connectionSource = new JdbcConnectionSource(DATABASE_URL, "root", "");
-            // setup our  DAOs
 
-            setupDao(connectionSource);
-            DatabaseConnection dbc = new MysqlDriver(connectionSource);
-            MysqlDriver a = new MysqlDriver(connectionSource);;
-            // read, write and delete some data
+            MysqlDriver a = new MysqlDriver(connectionSource);
+
             processData(a);
 
-            System.out.println("\n\nIt seems to have worked\n\n");
         } finally {
-            // destroy the data source which should close underlying connections
+
+            c.print("Good Bye!");
             if (connectionSource != null) {
                 connectionSource.close();
             }
         }
     }
 
-    /**
-     * Read and write some example data.
-     */
     private void processData(MysqlDriver a) throws Exception {
-        //    Service a = new Service (connectionSource){
-
 
         boolean continueMenu =  true;
-        // Create an account interface for a user to interact with the app
-        // CRUD
         System.out.println("Welcome to the account database manager!\n");
 
         while (continueMenu) {
@@ -69,57 +53,15 @@ public class AccountApp {
                 a.inputUpdateMenu();
 
             } else if (input.equals("4")) {
-                // destroy
-                break;
+                    a.readAllAccounts(a.read());
+                    int destroyMe = a.menuDestroy();
+                    a.destroy(a.getById(destroyMe));
 
             } else {
                 continueMenu = false;
             }
 
         }
-
-        // create an instance of Account
-        String name = "Jim Coakley";
-        Account account = new Account(name);
-
-        // persist the account object to the database
-        accountDao.create(account);
-        int id = account.getId();
-        System.out.println(id);
-        // assign a password
-        account.setPassword("_secret");
-        // update the database after changing the object
-        accountDao.update(account);
-        // delete the account
-        accountDao.deleteById(id);
-    }
-
-    /**
-     * Setup our  DAOs
-     */
-    private void setupDao(ConnectionSource connectionSource) throws Exception {
-
-        accountDao = DaoManager.createDao(connectionSource, Account.class);
-
-    }
-
-    private void updateSpecificAccount() {
-
-        // Grabs the account and sets either a new name or password for the account
-
-    }
-
-    private void updateName(int id) {
-
     }
 
-    private void updatePassword(int id) {
-
-    }
-
-    private void deleteAnAccount() {
-
-        // removes the account from the database by ID
-
-    }
 }

trtongorm_lab/src/main/java/Console.java

@@ -9,10 +9,25 @@ public class Console {
         return in.next();
     }
 
+    public void printFormatRead(int id, String name, String pw) {
+        System.out.println(String.format("|%11s| |%15s| |%15s|", id, name, pw));
+    }
+
+    public void readHeader() {
+        System.out.println("Displaying all accounts:\n");
+        System.out.println(String.format("|%11s| |%15s| |%15s|", "ID", "NAME", "PASSWORD"));
+        System.out.println("_________________________________________________");
+    }
+
     public int nextInt() {
         return in.nextInt();
     }
 
+    public int printAndNextInt(String s) {
+        System.out.println(s);
+        return in.nextInt();
+    }
+
     public void print(String s) {
         System.out.println(s);
     }

trtongorm_lab/src/main/java/DatabaseConnection.java

@@ -6,7 +6,7 @@ public interface DatabaseConnection<T> {
 
     public List<T> read() throws Exception;
 
-    public void update(Account a) throws Exception;
+    public void update(T a) throws Exception;
 
     public void destroy(T a) throws Exception;
 }

trtongorm_lab/src/main/java/MysqlDriver.java

@@ -35,7 +35,6 @@ public class MysqlDriver implements DatabaseConnection<Account> {
 
     public void destroy(Account acc) throws Exception {
         a.delete(acc);
-
     }
 
     public Account getById(int id) throws Exception {
@@ -44,16 +43,11 @@ public class MysqlDriver implements DatabaseConnection<Account> {
 
     public void readAllAccounts(List<Account> moo) {
 
-        c.print("Displaying all accounts:\n");
-        c.print(String.format("|%11s| |%15s| |%15s|", "ID", "NAME", "PASSWORD"));
-        c.print("_________________________________________________");
+        c.readHeader();
         for (Account a : moo) {
-            c.print(String.format("|%11d| |%15s| |%15s|", a.getId(), a.getName(), a.getPassword()));
-        }
-
-        c.print("Could not retrieve lists. Goodbye.");
+            c.printFormatRead(a.getId(), a.getName(), a.getPassword());
         }
-
+    }
 
     public Account createNewAccount(){
 
@@ -65,20 +59,23 @@ public class MysqlDriver implements DatabaseConnection<Account> {
         return account;
     }
 
-    public void updatePassword(Account acc, String pw) {
+    public void updatePassword(Account acc, String pw) throws Exception{
         acc.setPassword(pw);
+        a.update(acc);
     }
 
-    public void updateName(Account acc, String name) {
+    public void updateName(Account acc, String name) throws Exception {
         acc.setName(name);
+        a.update(acc);
     }
 
+
     public void inputUpdateMenu() throws Exception {
         String updateInput = c.printAndStrInput("1: Update Name\n"
-                + "2: Update Password");
+                + "2: Update Password"
+                + "Select by number (any other number to return to Main Menu): ");
 
-        c.print("What is the id for the account?");
-        int idUpdating = c.nextInt();
+        int idUpdating = c.printAndNextInt("What is the id for the account?");
 
         Account updateThisAccount = getById(c.nextInt());
 
@@ -94,4 +91,13 @@ public class MysqlDriver implements DatabaseConnection<Account> {
             c.print("Returning to menu...\n");
         }
     }
+
+    public int menuDestroy() throws Exception{
+        int destroyID = c.printAndNextInt("Enter the id you want to destroy: ");
+        if (getById(destroyID) != null) {
+            return destroyID;
+        }
+        return -1;
+    }
+
 }

trtongorm_lab/src/test/java/CrudTest.java

@@ -1,3 +1,6 @@
+import java.util.ArrayList;
+import java.util.List;
+
 public class CrudTest {
 
     // test must be self contained
@@ -15,4 +18,33 @@ public class CrudTest {
 //                a.create(account)
 //    }
 
+    DatabaseConnection<Account> dbc;
+    Service testServ;
+    public CrudTest() {
+
+        dbc = new DatabaseConnection<Account>() {
+            public void create(Account a) {
+
+            }
+
+            public List<Account> read() throws Exception {
+                List<Account> testList = new ArrayList<Account>();
+
+                return testList;
+            }
+
+            public void update(Account a) throws Exception {
+
+            }
+
+            public void destroy(Account a) throws Exception {
+
+            }
+        };
+
+        testServ = new Service(dbc);
+
+
+
+    }
 }