idk my bff jill

Author: Bradley

admin/pom.xml

@@ -17,4 +17,16 @@
       <scope>test</scope>
     </dependency>
   </dependencies>
+  <build>
+  <plugins>
+    <plugin>
+      <groupId>org.codehaus.mojo</groupId>
+      <artifactId>exec-maven-plugin</artifactId>
+      <version>1.6.0</version>
+      <configuration>
+        <mainClass>merhoo.admin.App</mainClass>
+      </configuration>
+    </plugin>
+  </plugins>
+</build>
 </project>

admin/src/main/java/merhoo/admin/App.java

@@ -1,13 +1,179 @@
 package merhoo.admin;
 
+import java.io.BufferedReader;
+import java.io.InputStreamReader;
+import java.io.IOException;
+
+import java.util.ArrayList;
+import java.util.Map;
+
 /**
- * Hello world!
- *
+ * App is the basic admin app.  For now, all it does is connect to the database
+ * and then disconnect
  */
-public class App 
+public class App
 {
-    public static void main( String[] args )
-    {
-        System.out.println( "Hello World!" );
+  /**
+   * Print the menu for our program
+   */
+  static void menu() {
+    System.out.println("Main Menu");
+    System.out.println("  [T] Create tblData");
+    System.out.println("  [D] Drop tblData");
+    System.out.println("  [1] Query for a specific row");
+    System.out.println("  [*] Query for all rows");
+    System.out.println("  [-] Delete a row");
+    System.out.println("  [+] Insert a new row");
+    System.out.println("  [~] Update a row");
+    System.out.println("  [q] Quit Program");
+    System.out.println("  [?] Help (this message)");
+  }
+  /**
+    * Ask the user to enter a menu option; repeat until we get a valid option
+    *
+    * @param in A BufferedReader, for reading from the keyboard
+    *
+    * @return The character corresponding to the chosen menu option
+    */
+   static char prompt(BufferedReader in) {
+     // The valid actions:
+     String actions = "TD1*-+~q?";
+
+     // We repeat until a valid single-character option is selected
+     while (true) {
+       System.out.print("[" + actions + "] :> ");
+       String action;
+       try {
+          action = in.readLine();
+       } catch (IOException e) {
+          e.printStackTrace();
+          continue;
+       }
+       if (action.length() != 1)
+          continue;
+       if (actions.contains(action)) {
+          return action.charAt(0);
+       }
+       System.out.println("Invalid Command");
+     }
+   }
+
+   /**
+    * Ask the user to enter a String message
+    *
+    * @param in A BufferedReader, for reading from the keyboard
+    * @param message A message to display when asking for input
+    *
+    * @return The string that the user provided.  May be "".
+    */
+   static String getString(BufferedReader in, String message) {
+       String s;
+       try {
+           System.out.print(message + " :> ");
+           s = in.readLine();
+       } catch (IOException e) {
+           e.printStackTrace();
+           return "";
+       }
+       return s;
+   }
+
+   /**
+    * Ask the user to enter an integer
+    *
+    * @param in A BufferedReader, for reading from the keyboard
+    * @param message A message to display when asking for input
+    *
+    * @return The integer that the user provided.  On error, it will be -1
+    */
+   static int getInt(BufferedReader in, String message) {
+       int i = -1;
+       try {
+           System.out.print(message + " :> ");
+           i = Integer.parseInt(in.readLine());
+       } catch (IOException e) {
+           e.printStackTrace();
+       } catch (NumberFormatException e) {
+           e.printStackTrace();
+       }
+       return i;
+     }
+
+  public static void main( String[] args )
+  {
+    Map<String, String> env = System.getenv();
+    String ip = env.get("POSTGRES_IP");
+    String port = env.get("POSTGRES_PORT");
+    String user = env.get("POSTGRES_USER");
+    String pass = env.get("POSTGRES_PASS");
+
+    // Get a fully-configured connection to the database, or exit
+    // immediately
+    Database db = Database.getDatabase(ip, port, user, pass);
+    if (db == null)
+        return;
+    // Start our basic command-line interpreter:
+    BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
+    while (true) {
+        // Get the user's request, and do it
+        //
+        // NB: for better testability, each action should be a separate
+        //     function call
+        char action = prompt(in);
+        if (action == '?') {
+            menu();
+        } else if (action == 'q') {
+            break;
+        } else if (action == 'T') {
+            db.createTable();
+        } else if (action == 'D') {
+            db.dropTable();
+        } else if (action == '1') {
+            int id = getInt(in, "Enter the row ID");
+            if (id == -1)
+                continue;
+            Database.RowData res = db.selectOne(id);
+            if (res != null) {
+                System.out.println("  [" + res.mId + "] " + res.mSubject);
+                System.out.println("  --> " + res.mMessage);
+            }
+        } else if (action == '*') {
+            ArrayList<Database.RowData> res = db.selectAll();
+            if (res == null)
+                continue;
+            System.out.println("  Current Database Contents");
+            System.out.println("  -------------------------");
+            for (Database.RowData rd : res) {
+                System.out.println("  [" + rd.mId + "] " + rd.mSubject);
+            }
+        } else if (action == '-') {
+            int id = getInt(in, "Enter the row ID");
+            if (id == -1)
+                continue;
+            int res = db.deleteRow(id);
+            if (res == -1)
+                continue;
+            System.out.println("  " + res + " rows deleted");
+        } else if (action == '+') {
+            String subject = getString(in, "Enter the subject");
+            String message = getString(in, "Enter the message");
+            if (subject.equals("") || message.equals(""))
+                continue;
+            int res = db.insertRow(subject, message);
+            System.out.println(res + " rows added");
+        } else if (action == '~') {
+            int id = getInt(in, "Enter the row ID :> ");
+            if (id == -1)
+                continue;
+            String newMessage = getString(in, "Enter the new message");
+            int res = db.updateOne(id, newMessage);
+            if (res == -1)
+                continue;
+            System.out.println("  " + res + " rows updated");
+        }
     }
+    // Always remember to disconnect from the database when the program
+    // exits
+    db.disconnect();
+  }
 }