]> git.mxchange.org Git - jbonuscard-lib.git/commitdiff
Moved exceptions in own package
authorRoland Haeder <roland@mxchange.org>
Fri, 24 Jul 2015 09:29:04 +0000 (11:29 +0200)
committerRoland Haeder <roland@mxchange.org>
Fri, 24 Jul 2015 09:29:04 +0000 (11:29 +0200)
Signed-off-by:Roland Häder <roland@mxchange.org>

16 files changed:
Addressbook/src/org/mxchange/addressbook/BadTokenException.java [deleted file]
Addressbook/src/org/mxchange/addressbook/FrameAlreadyInitializedException.java [deleted file]
Addressbook/src/org/mxchange/addressbook/UnhandledUserChoiceException.java [deleted file]
Addressbook/src/org/mxchange/addressbook/application/AddressbookApplication.java
Addressbook/src/org/mxchange/addressbook/client/Client.java
Addressbook/src/org/mxchange/addressbook/client/console/ConsoleClient.java
Addressbook/src/org/mxchange/addressbook/client/gui/AddressbookFrame.java
Addressbook/src/org/mxchange/addressbook/client/gui/ClientFrame.java
Addressbook/src/org/mxchange/addressbook/client/gui/SwingClient.java
Addressbook/src/org/mxchange/addressbook/database/backend/csv/CsvBackend.java
Addressbook/src/org/mxchange/addressbook/database/backend/csv/CsvDatabaseBackend.java
Addressbook/src/org/mxchange/addressbook/database/frontend/contact/ContactDatabaseFrontend.java
Addressbook/src/org/mxchange/addressbook/exceptions/BadTokenException.java [new file with mode: 0644]
Addressbook/src/org/mxchange/addressbook/exceptions/FrameAlreadyInitializedException.java [new file with mode: 0644]
Addressbook/src/org/mxchange/addressbook/exceptions/UnhandledUserChoiceException.java [new file with mode: 0644]
Addressbook/src/org/mxchange/addressbook/manager/contact/ContactManager.java

diff --git a/Addressbook/src/org/mxchange/addressbook/BadTokenException.java b/Addressbook/src/org/mxchange/addressbook/BadTokenException.java
deleted file mode 100644 (file)
index ce02e50..0000000
+++ /dev/null
@@ -1,29 +0,0 @@
-/*\r
- * Copyright (C) 2015 Roland Haeder\r
- *\r
- * This program is free software: you can redistribute it and/or modify\r
- * it under the terms of the GNU General Public License as published by\r
- * the Free Software Foundation, either version 3 of the License, or\r
- * (at your option) any later version.\r
- *\r
- * This program is distributed in the hope that it will be useful,\r
- * but WITHOUT ANY WARRANTY; without even the implied warranty of\r
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the\r
- * GNU General Public License for more details.\r
- *\r
- * You should have received a copy of the GNU General Public License\r
- * along with this program.  If not, see <http://www.gnu.org/licenses/>.\r
- */\r
-package org.mxchange.addressbook;\r
-\r
-/**\r
- *\r
- * @author Roland Haeder\r
- */\r
-public class BadTokenException extends Exception {\r
-\r
-    public BadTokenException (final String str) {\r
-       super(str);\r
-    }\r
-    \r
-}\r
diff --git a/Addressbook/src/org/mxchange/addressbook/FrameAlreadyInitializedException.java b/Addressbook/src/org/mxchange/addressbook/FrameAlreadyInitializedException.java
deleted file mode 100644 (file)
index 0a4be3c..0000000
+++ /dev/null
@@ -1,32 +0,0 @@
-/*
- * Copyright (C) 2015 Roland Haeder
- *
- * This program is free software: you can redistribute it and/or modify
- * it under the terms of the GNU General Public License as published by
- * the Free Software Foundation, either version 3 of the License, or
- * (at your option) any later version.
- *
- * This program is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
- * GNU General Public License for more details.
- *
- * You should have received a copy of the GNU General Public License
- * along with this program.  If not, see <http://www.gnu.org/licenses/>.
- */
-package org.mxchange.addressbook;
-
-/**
- * This exception is thrown when initFrame() is called twice.
- * 
- * @author Roland Haeder
- */
-public class FrameAlreadyInitializedException extends Exception {
-
-    /**
-     * Default constructor
-     */
-    public FrameAlreadyInitializedException () {
-    }
-    
-}
diff --git a/Addressbook/src/org/mxchange/addressbook/UnhandledUserChoiceException.java b/Addressbook/src/org/mxchange/addressbook/UnhandledUserChoiceException.java
deleted file mode 100644 (file)
index e97f20a..0000000
+++ /dev/null
@@ -1,30 +0,0 @@
-/*\r
- * Copyright (C) 2015 Roland Haeder\r
- *\r
- * This program is free software: you can redistribute it and/or modify\r
- * it under the terms of the GNU General Public License as published by\r
- * the Free Software Foundation, either version 3 of the License, or\r
- * (at your option) any later version.\r
- *\r
- * This program is distributed in the hope that it will be useful,\r
- * but WITHOUT ANY WARRANTY; without even the implied warranty of\r
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the\r
- * GNU General Public License for more details.\r
- *\r
- * You should have received a copy of the GNU General Public License\r
- * along with this program.  If not, see <http://www.gnu.org/licenses/>.\r
- */\r
-package org.mxchange.addressbook;\r
-\r
-/**\r
- * This exception is thrown when the user made a valid choice but it was not\r
- * handled by the program.\r
- * \r
- * @author Roland Haeder\r
- */\r
-public class UnhandledUserChoiceException extends Exception {\r
-\r
-    public UnhandledUserChoiceException (final String message) {\r
-       super(message);\r
-    }\r
-}\r
index eab7e71196b228c18c4a50cc4cc2119add9d4430..a7842b0cf8135ff95c8f8489d00acf67bf7d6c1f 100644 (file)
@@ -18,10 +18,10 @@ package org.mxchange.addressbook.application;
 
 import java.text.MessageFormat;
 import org.mxchange.addressbook.BaseFrameworkSystem;
-import org.mxchange.addressbook.UnhandledUserChoiceException;
 import org.mxchange.addressbook.client.Client;
 import org.mxchange.addressbook.client.console.ConsoleClient;
 import org.mxchange.addressbook.client.gui.SwingClient;
+import org.mxchange.addressbook.exceptions.UnhandledUserChoiceException;
 import org.mxchange.addressbook.manager.application.ApplicationManager;
 
 /**
index 6e28668d605a3f9d332ac9812123b752a94d6a69..42b7b7cd262730fdcbd9a37812aebc482588f8cc 100644 (file)
@@ -17,7 +17,7 @@
 package org.mxchange.addressbook.client;
 
 import org.mxchange.addressbook.FrameworkInterface;
-import org.mxchange.addressbook.UnhandledUserChoiceException;
+import org.mxchange.addressbook.exceptions.UnhandledUserChoiceException;
 import org.mxchange.addressbook.contact.Contact;
 import org.mxchange.addressbook.menu.item.SelectableMenuItem;
 
index 2015873d861ee58b85e411aa38247596df9caa8b..3f5889922f2d335ce2f82d6b0ee9406af437cf6c 100644 (file)
@@ -19,13 +19,13 @@ package org.mxchange.addressbook.client.console;
 import java.text.MessageFormat;
 import java.util.Arrays;
 import java.util.Scanner;
-import org.mxchange.addressbook.UnhandledUserChoiceException;
 import org.mxchange.addressbook.application.AddressbookApplication;
 import org.mxchange.addressbook.application.Application;
 import org.mxchange.addressbook.client.BaseClient;
 import org.mxchange.addressbook.client.Client;
 import org.mxchange.addressbook.contact.Contact;
 import org.mxchange.addressbook.contact.user.UserContact;
+import org.mxchange.addressbook.exceptions.UnhandledUserChoiceException;
 import org.mxchange.addressbook.menu.Menu;
 import org.mxchange.addressbook.menu.MenuTools;
 import org.mxchange.addressbook.menu.console.ConsoleMenu;
index c0f132fc73134c745269e4533221519bb99f29bb..d03358ccff1c21260f8bdb77daa8d08b381974a2 100644 (file)
@@ -31,9 +31,9 @@ import javax.swing.JMenuBar;
 import javax.swing.JMenuItem;
 import javax.swing.JPanel;
 import org.mxchange.addressbook.BaseFrameworkSystem;
-import org.mxchange.addressbook.FrameAlreadyInitializedException;
 import org.mxchange.addressbook.application.AddressbookApplication;
 import org.mxchange.addressbook.client.Client;
+import org.mxchange.addressbook.exceptions.FrameAlreadyInitializedException;
 
 /**
  *
@@ -146,7 +146,7 @@ public class AddressbookFrame extends BaseFrameworkSystem implements ClientFrame
      * accessible) means that any other object can initialize components which
      * you may not want.
      * 
-     * @throws org.mxchange.addressbook.FrameAlreadyInitializedException If this method has been called twice
+     * @throws org.mxchange.addressbook.exceptions.FrameAlreadyInitializedException If this method has been called twice
      */
     @Override
     public void init () throws FrameAlreadyInitializedException {
index 50395286673446830188da8bd2f9b85e6ca89ab2..389e744d8a813b84207d41954372d23b7fda6179 100644 (file)
@@ -16,9 +16,9 @@
  */
 package org.mxchange.addressbook.client.gui;
 
-import org.mxchange.addressbook.FrameAlreadyInitializedException;
 import org.mxchange.addressbook.FrameworkInterface;
 import org.mxchange.addressbook.client.Client;
+import org.mxchange.addressbook.exceptions.FrameAlreadyInitializedException;
 
 /**
  * An interface for applications with a frame
@@ -43,7 +43,7 @@ public interface ClientFrame extends FrameworkInterface {
     /**
      * Initializes frame
      * 
-     * @throws org.mxchange.addressbook.FrameAlreadyInitializedException If this method has been called twice
+     * @throws org.mxchange.addressbook.exceptions.FrameAlreadyInitializedException If this method has been called twice
      */
     public void init () throws FrameAlreadyInitializedException;
 
index 29fc9a6efa8347f8ca2aa7d53754b46fd522eabb..0914828179e3844ca20acb1e5cb488afc82990b6 100644 (file)
  */
 package org.mxchange.addressbook.client.gui;
 
-import org.mxchange.addressbook.FrameAlreadyInitializedException;
-import org.mxchange.addressbook.UnhandledUserChoiceException;
 import org.mxchange.addressbook.application.Application;
 import org.mxchange.addressbook.client.BaseClient;
 import org.mxchange.addressbook.client.Client;
 import org.mxchange.addressbook.contact.Contact;
+import org.mxchange.addressbook.exceptions.FrameAlreadyInitializedException;
+import org.mxchange.addressbook.exceptions.UnhandledUserChoiceException;
 import org.mxchange.addressbook.menu.Menu;
 import org.mxchange.addressbook.menu.item.SelectableMenuItem;
 
index f310588e0b334cab63ee88602fe400144b416d3f..525f624ac13593f81aa21dde2212e0bfc293bde3 100644 (file)
@@ -1,37 +1,37 @@
-/*\r
- * Copyright (C) 2015 Roland Haeder\r
- *\r
- * This program is free software: you can redistribute it and/or modify\r
- * it under the terms of the GNU General Public License as published by\r
- * the Free Software Foundation, either version 3 of the License, or\r
- * (at your option) any later version.\r
- *\r
- * This program is distributed in the hope that it will be useful,\r
- * but WITHOUT ANY WARRANTY; without even the implied warranty of\r
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the\r
- * GNU General Public License for more details.\r
- *\r
- * You should have received a copy of the GNU General Public License\r
- * along with this program.  If not, see <http://www.gnu.org/licenses/>.\r
- */\r
-package org.mxchange.addressbook.database.backend.csv;\r
-\r
-import java.util.Iterator;\r
-import org.mxchange.addressbook.BadTokenException;\r
-import org.mxchange.addressbook.contact.Contact;\r
-import org.mxchange.addressbook.database.backend.DatabaseBackend;\r
-\r
-/**\r
- *\r
- * @author Roland Haeder\r
- */\r
-public interface CsvBackend extends DatabaseBackend {\r
-\r
-    /**\r
-     * Gets an iterator for contacts\r
-     * \r
-     * @return Iterator for contacts\r
-     * @throws org.mxchange.addressbook.BadTokenException If the CSV token is badly formulated\r
-     */\r
-    public Iterator<Contact> contactIterator () throws BadTokenException;\r
-}\r
+/*
+ * Copyright (C) 2015 Roland Haeder
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+package org.mxchange.addressbook.database.backend.csv;
+
+import java.util.Iterator;
+import org.mxchange.addressbook.contact.Contact;
+import org.mxchange.addressbook.database.backend.DatabaseBackend;
+import org.mxchange.addressbook.exceptions.BadTokenException;
+
+/**
+ *
+ * @author Roland Haeder
+ */
+public interface CsvBackend extends DatabaseBackend {
+
+    /**
+     * Gets an iterator for contacts
+     * 
+     * @return Iterator for contacts
+     * @throws org.mxchange.addressbook.exceptions.BadTokenException If the CSV token is badly formulated
+     */
+    public Iterator<Contact> contactIterator () throws BadTokenException;
+}
index 9f3e8329fbd41f04df9372490969ed228ca76d93..7540254ee2c7c193ecea5265600d76f2e22aff04 100644 (file)
-/*\r
- * Copyright (C) 2015 Roland Haeder\r
- *\r
- * This program is free software: you can redistribute it and/or modify\r
- * it under the terms of the GNU General Public License as published by\r
- * the Free Software Foundation, either version 3 of the License, or\r
- * (at your option) any later version.\r
- *\r
- * This program is distributed in the hope that it will be useful,\r
- * but WITHOUT ANY WARRANTY; without even the implied warranty of\r
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the\r
- * GNU General Public License for more details.\r
- *\r
- * You should have received a copy of the GNU General Public License\r
- * along with this program.  If not, see <http://www.gnu.org/licenses/>.\r
- */\r
-package org.mxchange.addressbook.database.backend.csv;\r
-\r
-import java.io.DataOutput;\r
-import java.io.FileNotFoundException;\r
-import java.io.IOException;\r
-import java.io.RandomAccessFile;\r
-import java.text.MessageFormat;\r
-import java.util.ArrayList;\r
-import java.util.Iterator;\r
-import java.util.List;\r
-import java.util.StringTokenizer;\r
-import org.mxchange.addressbook.BadTokenException;\r
-import org.mxchange.addressbook.contact.Contact;\r
-import org.mxchange.addressbook.contact.book.BookContact;\r
-import org.mxchange.addressbook.contact.user.UserContact;\r
-import org.mxchange.addressbook.database.backend.BaseDatabaseBackend;\r
-import org.mxchange.addressbook.database.storage.Storeable;\r
-import org.mxchange.addressbook.database.storage.csv.StoreableCsv;\r
-\r
-/**\r
- * A database backend with CSV file as storage implementation\r
- * \r
- * @author Roland Haeder\r
- */\r
-public class CsvDatabaseBackend extends BaseDatabaseBackend implements CsvBackend {\r
-    /**\r
-     * Output stream for this storage engine\r
-     */\r
-    private RandomAccessFile storageFile;\r
-\r
-    /**\r
-     * Constructor with table name\r
-     * \r
-     * @param tableName Name of "table"\r
-     */\r
-    public CsvDatabaseBackend (final String tableName) {\r
-       // Debug message\r
-       this.getLogger().debug(MessageFormat.format("Trying to initialize table {0} ...", tableName));\r
-\r
-       // Set table name here, too\r
-       this.setTableName(tableName);\r
-\r
-       // Construct file name\r
-       String fileName = String.format("data/table_%s.csv", tableName);\r
-\r
-       // Debug message\r
-       this.getLogger().debug(MessageFormat.format("Trying to open file {0} ...", fileName));\r
-\r
-       try {\r
-           // Try to initialize the storage (file instance)\r
-           this.storageFile = new RandomAccessFile(fileName, "rw");\r
-       } catch (final FileNotFoundException ex) {\r
-           // Did not work\r
-           this.getLogger().error(MessageFormat.format("File {0} cannot be opened: {1}", fileName, ex.toString()));\r
-           System.exit(1);\r
-       }\r
-\r
-       // Output message\r
-       this.getLogger().debug(MessageFormat.format("Database for {0} has been initialized.", tableName));\r
-    }\r
-\r
-    /**\r
-     * Gets an iterator for contacts\r
-     * \r
-     * @return Iterator for contacts\r
-     * @throws org.mxchange.addressbook.BadTokenException If the underlaying method has found an invalid token\r
-     */\r
-    @Override\r
-    public Iterator<Contact> contactIterator () throws BadTokenException {\r
-       /*\r
-        * Then read the file into RAM (yes, not perfect for >1000 entries ...)\r
-        * and get a List back.\r
-        */\r
-       List<Contact> list = this.readContactList();\r
-\r
-       // Get iterator from list and return it\r
-       return list.iterator();\r
-    }\r
-\r
-    /**\r
-     * Shuts down this backend\r
-     */\r
-    @Override\r
-    public void doShutdown () {\r
-       try {\r
-           // Close file\r
-           this.getStorageFile().close();\r
-       } catch (final IOException ex) {\r
-           this.getLogger().catching(ex);\r
-           System.exit(1);\r
-       }\r
-    }\r
-\r
-    /**\r
-     * Get length of underlaying file\r
-     *\r
-     * @return Length of underlaying file\r
-     */\r
-    @Override\r
-    public long length () {\r
-       long length = 0;\r
-       \r
-       try {\r
-           length = this.getStorageFile().length();\r
-           this.getLogger().debug(MessageFormat.format("length={0}", length));\r
-       } catch (final IOException ex) {\r
-           // Length cannot be determined\r
-           this.getLogger().catching(ex);\r
-           System.exit(1);\r
-       }\r
-       \r
-       // Return result\r
-        this.getLogger().trace(MessageFormat.format("length={0} : EXIT!", length));\r
-       return length;\r
-    }\r
-\r
-    /**\r
-     * Rewinds backend\r
-     */\r
-    @Override\r
-    public void rewind (){\r
-        this.getLogger().trace("CALLED!");\r
-\r
-       try {\r
-           // Rewind underlaying database file\r
-           this.getStorageFile().seek(0);\r
-       } catch (final IOException ex) {\r
-           this.getLogger().catching(ex);\r
-           System.exit(1);\r
-       }\r
-\r
-       this.getLogger().trace("EXIT!");\r
-    }\r
-\r
-    /**\r
-     * Stores given object by "visiting" it\r
-     *\r
-     * @param object An object implementing Storeable\r
-     * @throws java.io.IOException From "inner" class\r
-     */\r
-    @Override\r
-    public void store (final Storeable object) throws IOException {\r
-       // Make sure the instance is there (DataOutput flawor)\r
-       assert(this.storageFile instanceof DataOutput);\r
-\r
-       // Try to cast it, this will fail if the interface is not implemented\r
-       StoreableCsv csv = (StoreableCsv) object;\r
-\r
-       // Now get a string from the object that needs to be stored\r
-       String str = csv.getCsvStringFromStoreableObject();\r
-\r
-       // Debug message\r
-       this.getLogger().debug(MessageFormat.format("str({0})={1}", str.length(), str));\r
-\r
-       // The string is now a valid CSV string\r
-       this.getStorageFile().writeBytes(str);\r
-    }\r
-\r
-    /**\r
-     * Adds given contact to list\r
-     * \r
-     * @param contact Contact instance to add\r
-     * @param list List instance\r
-     */\r
-    private void addContactToList (final Contact contact, final List<Contact> list) {\r
-       // Debug message\r
-       this.getLogger().debug(MessageFormat.format("contact={0}", contact));\r
-\r
-       // Is the contact read?\r
-       if (contact instanceof Contact) {\r
-           // Then add it\r
-           boolean added = list.add(contact);\r
-\r
-           // Debug message\r
-           this.getLogger().debug(MessageFormat.format("contact={0} added={1}", contact, added));\r
-\r
-           // Has it been added?\r
-           if (!added) {\r
-               // Not added\r
-               this.getLogger().warn("Contact object has not been added.");\r
-           }\r
-       }\r
-    }\r
-\r
-    /**\r
-     * Returns storage file\r
-     * \r
-     * @return Storage file instance\r
-     */\r
-    private RandomAccessFile getStorageFile () {\r
-       return this.storageFile;\r
-    }\r
-\r
-    /**\r
-     * Checks whether end of file has been reached\r
-     * \r
-     * @return Whether lines are left to read\r
-     */\r
-    private boolean isEndOfFile () {\r
-       // Default is EOF\r
-       boolean isEof = true;\r
-\r
-       try {\r
-           isEof = (this.getStorageFile().getFilePointer() >= this.length());\r
-       } catch (final IOException ex) {\r
-           // Length cannot be determined\r
-           this.getLogger().catching(ex);\r
-       }\r
-\r
-       // Return status\r
-       this.getLogger().trace(MessageFormat.format("isEof={0} : EXIT!", isEof));\r
-       return isEof;\r
-    }\r
-\r
-    /**\r
-     * Reads the database file, if available, and adds all read lines into\r
-     * the list.\r
-     * \r
-     * @return A list with Contact instances\r
-     */\r
-    private List<Contact> readContactList () throws BadTokenException {\r
-       this.getLogger().trace("CALLED!");\r
-\r
-       // First rewind\r
-       this.rewind();\r
-\r
-       // Get file size and divide it by 140 (possible average length of one line)\r
-       int lines = Math.round(this.length() / 140 + 0.5f);\r
-\r
-       // Debug message\r
-       this.getLogger().debug(MessageFormat.format("lines={0}", lines));\r
-\r
-       // Instance list\r
-       // @TODO The maximum length could be guessed from file size?\r
-       List<Contact> list = new ArrayList<>(lines);\r
-\r
-       // Init variables\r
-       StringTokenizer tokenizer;\r
-       String line;\r
-\r
-       // Read all lines\r
-       while (!this.isEndOfFile()) {\r
-           // Then read a line\r
-           line = this.readLine();\r
-\r
-           // Debug message\r
-           this.getLogger().debug(MessageFormat.format("line={0}", line));\r
-\r
-           // Then tokenize it\r
-           // @TODO Move this into separate method\r
-           tokenizer = new StringTokenizer(line, ";");\r
-\r
-           // Count round\r
-           int count = 0;\r
-\r
-           // Init contact object\r
-           Contact contact = null;\r
-\r
-           // The tokens are now available, so get all\r
-           while (tokenizer.hasMoreElements()) {\r
-               // Get next token\r
-               String token = tokenizer.nextToken();\r
-\r
-               // Debug message\r
-               this.getLogger().debug(MessageFormat.format("token={0}", token));\r
-\r
-               // Verify token, it must have double-quotes on each side\r
-               if ((!token.startsWith("\"")) || (!token.endsWith("\""))) {\r
-                   // Something bad was read\r
-                   throw new BadTokenException(MessageFormat.format("Token {0} has not double-quotes on both ends.", token));\r
-               }\r
-\r
-               // All fine, so remove it\r
-               String strippedToken = token.substring(1, token.length() - 1);\r
-\r
-               // Is the string's content "null"?\r
-               if (strippedToken.equals("null")) {\r
-                   // Debug message\r
-                   this.getLogger().debug(MessageFormat.format("strippedToken={0} - NULL!", strippedToken));\r
-\r
-                   // This needs to be set to null\r
-                   strippedToken = null;\r
-               }\r
-\r
-               // Debug message\r
-               this.getLogger().debug(MessageFormat.format("strippedToken={0}", strippedToken));\r
-\r
-               // Init number/string data values\r
-               String strData = strippedToken;\r
-               Long num = null;\r
-               Boolean bool = null;\r
-               char gender = '?';\r
-               \r
-               // Now, let's try a number check, if no null\r
-               if (strippedToken != null) {\r
-                   // Okay, no null, maybe the string bears a decimal number?\r
-                   try {\r
-                       num = Long.valueOf(strippedToken);\r
-\r
-                       // Debug message\r
-                       this.getLogger().debug(MessageFormat.format("strippedToken={0} - NUMBER!", strippedToken));\r
-                   } catch (final NumberFormatException ex) {\r
-                       // No number, then set default\r
-                       num = null;\r
-                   }\r
-               }\r
-               \r
-               // Now, let's try a boolean check, if no null\r
-               if ((strippedToken != null) && (num == null) && ((strippedToken.equals("true")) || (strippedToken.equals("false")))) {\r
-                   // Debug message\r
-                   this.getLogger().debug(MessageFormat.format("strippedToken={0} - BOOLEAN!", strippedToken));\r
-\r
-                   // parseBoolean() is relaxed, so no exceptions\r
-                   bool = Boolean.valueOf(strippedToken);\r
-               }\r
-               \r
-               // Now, let's try a boolean check, if no null\r
-               if ((strippedToken != null) && (num == null) && (bool == null) && ((strippedToken.equals("M")) || (strippedToken.equals("F")) || (strippedToken.equals("C")))) {\r
-                   // Get first character\r
-                   gender = strippedToken.charAt(0);\r
-               }\r
-\r
-               // Now it depends on the counter which position we need to check\r
-               switch (count) {\r
-                   case 0: // isOwnContact\r
-                       assert((bool instanceof Boolean));\r
-\r
-                       // Debug message\r
-                       this.getLogger().debug(MessageFormat.format("bool={0}", bool));\r
-\r
-                       // Is it own contact?\r
-                       if (true == bool) {\r
-                           // Debug message\r
-                           this.getLogger().debug("Creating UserContact object ...");\r
-\r
-                           // Own entry\r
-                           contact = new UserContact();\r
-                       } else {\r
-                           // Debug message\r
-                           this.getLogger().debug("Creating BookContact object ...");\r
-\r
-                           // Other contact\r
-                           contact = new BookContact();\r
-                       }\r
-                       break;\r
-\r
-                   case 1: // Gender\r
-                       assert(contact instanceof Contact) : "First token was not boolean";\r
-                       assert(gender != '?') : "Gender is not detected.";\r
-\r
-                       // Update data\r
-                       contact.updateNameData(gender, null, null, null);\r
-                       break;\r
-\r
-                   case 2: // Surname\r
-                       assert(contact instanceof Contact) : "First token was not boolean";\r
-                       assert(gender != '?') : "Gender is not detected.";\r
-\r
-                       // Update data\r
-                       contact.updateNameData(gender, strippedToken, null, null);\r
-                       break;\r
-\r
-                   case 3: // Family name\r
-                       assert(contact instanceof Contact) : "First token was not boolean";\r
-                       assert(gender != '?') : "Gender is not detected.";\r
-\r
-                       // Update data\r
-                       contact.updateNameData(gender, null, strippedToken, null);\r
-                       break;\r
-\r
-                   case 4: // Company name\r
-                       assert(contact instanceof Contact) : "First token was not boolean";\r
-                       assert(gender != '?') : "Gender is not detected.";\r
-\r
-                       // Update data\r
-                       contact.updateNameData(gender, null, null, strippedToken);\r
-                       break;\r
-\r
-                   case 5: // Street number\r
-                       assert(contact instanceof Contact) : "First token was not boolean";\r
-\r
-                       // Update data\r
-                       contact.updateAddressData(strippedToken, 0, null, null);\r
-                       break;\r
-\r
-                   case 6: // ZIP code\r
-                       assert(contact instanceof Contact) : "First token was not boolean";\r
-\r
-                       // Update data\r
-                       contact.updateAddressData(null, num, null, null);\r
-                       break;\r
-\r
-                   case 7: // City name\r
-                       assert(contact instanceof Contact) : "First token was not boolean";\r
-\r
-                       // Update data\r
-                       contact.updateAddressData(null, 0, strippedToken, null);\r
-                       break;\r
-\r
-                   case 8: // Country code\r
-                       assert(contact instanceof Contact) : "First token was not boolean";\r
-\r
-                       // Update data\r
-                       contact.updateAddressData(null, 0, null, strippedToken);\r
-                       break;\r
-\r
-                   case 9: // Phone number\r
-                       assert(contact instanceof Contact) : "First token was not boolean";\r
-\r
-                       // Update data\r
-                       contact.updateOtherData(strippedToken, null, null, null, null, null);\r
-                       break;\r
-\r
-                   case 10: // Fax number\r
-                       assert(contact instanceof Contact) : "First token was not boolean";\r
-\r
-                       // Update data\r
-                       contact.updateOtherData(null, strippedToken, null, null, null, null);\r
-                       break;\r
-\r
-                   case 11: // Cellphone number\r
-                       assert(contact instanceof Contact) : "First token was not boolean";\r
-\r
-                       // Update data\r
-                       contact.updateOtherData(null, null, strippedToken, null, null, null);\r
-                       break;\r
-\r
-                   case 12: // Email address\r
-                       assert(contact instanceof Contact) : "First token was not boolean";\r
-\r
-                       // Update data\r
-                       contact.updateOtherData(null, null, null, strippedToken, null, null);\r
-                       break;\r
-\r
-                   case 13: // Birthday\r
-                       assert(contact instanceof Contact) : "First token was not boolean";\r
-\r
-                       // Update data\r
-                       contact.updateOtherData(null, null, null, null, strippedToken, null);\r
-                       break;\r
-\r
-                   case 14: // Birthday\r
-                       assert(contact instanceof Contact) : "First token was not boolean";\r
-\r
-                       // Update data\r
-                       contact.updateOtherData(null, null, null, null, null, strippedToken);\r
-                       break;\r
-\r
-                   default: // New data entry\r
-                       this.getLogger().warn(MessageFormat.format("Will not handle unknown data {0} at index {1}", strippedToken, count));\r
-                       break;\r
-               }\r
-\r
-               // Increment counter for next round\r
-               count++;\r
-           }\r
-\r
-           // Add contact\r
-           this.addContactToList(contact, list);\r
-       }\r
-\r
-       // Return finished list\r
-       this.getLogger().trace(MessageFormat.format("list.size()={0} : EXIT!", list.size()));\r
-       return list;\r
-    }\r
-\r
-    /**\r
-     * Reads a line from file base\r
-     *\r
-     * @return Read line from file\r
-     */\r
-    private String readLine () {\r
-       // Init input\r
-       String input = null;\r
-\r
-       try {\r
-           input = this.getStorageFile().readLine();\r
-       } catch (final IOException ex) {\r
-           this.getLogger().catching(ex);\r
-       }\r
-\r
-       // Return read string or null\r
-       return input;\r
-    }\r
-}\r
+/*
+ * Copyright (C) 2015 Roland Haeder
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+package org.mxchange.addressbook.database.backend.csv;
+
+import java.io.DataOutput;
+import java.io.FileNotFoundException;
+import java.io.IOException;
+import java.io.RandomAccessFile;
+import java.text.MessageFormat;
+import java.util.ArrayList;
+import java.util.Iterator;
+import java.util.List;
+import java.util.StringTokenizer;
+import org.mxchange.addressbook.contact.Contact;
+import org.mxchange.addressbook.contact.book.BookContact;
+import org.mxchange.addressbook.contact.user.UserContact;
+import org.mxchange.addressbook.database.backend.BaseDatabaseBackend;
+import org.mxchange.addressbook.database.storage.Storeable;
+import org.mxchange.addressbook.database.storage.csv.StoreableCsv;
+import org.mxchange.addressbook.exceptions.BadTokenException;
+
+/**
+ * A database backend with CSV file as storage implementation
+ * 
+ * @author Roland Haeder
+ */
+public class CsvDatabaseBackend extends BaseDatabaseBackend implements CsvBackend {
+    /**
+     * Output stream for this storage engine
+     */
+    private RandomAccessFile storageFile;
+
+    /**
+     * Constructor with table name
+     * 
+     * @param tableName Name of "table"
+     */
+    public CsvDatabaseBackend (final String tableName) {
+       // Debug message
+       this.getLogger().debug(MessageFormat.format("Trying to initialize table {0} ...", tableName));
+
+       // Set table name here, too
+       this.setTableName(tableName);
+
+       // Construct file name
+       String fileName = String.format("data/table_%s.csv", tableName);
+
+       // Debug message
+       this.getLogger().debug(MessageFormat.format("Trying to open file {0} ...", fileName));
+
+       try {
+           // Try to initialize the storage (file instance)
+           this.storageFile = new RandomAccessFile(fileName, "rw");
+       } catch (final FileNotFoundException ex) {
+           // Did not work
+           this.getLogger().error(MessageFormat.format("File {0} cannot be opened: {1}", fileName, ex.toString()));
+           System.exit(1);
+       }
+
+       // Output message
+       this.getLogger().debug(MessageFormat.format("Database for {0} has been initialized.", tableName));
+    }
+
+    /**
+     * Gets an iterator for contacts
+     * 
+     * @return Iterator for contacts
+     * @throws org.mxchange.addressbook.exceptions.BadTokenException If the underlaying method has found an invalid token
+     */
+    @Override
+    public Iterator<Contact> contactIterator () throws BadTokenException {
+       /*
+        * Then read the file into RAM (yes, not perfect for >1000 entries ...)
+        * and get a List back.
+        */
+       List<Contact> list = this.readContactList();
+
+       // Get iterator from list and return it
+       return list.iterator();
+    }
+
+    /**
+     * Shuts down this backend
+     */
+    @Override
+    public void doShutdown () {
+       try {
+           // Close file
+           this.getStorageFile().close();
+       } catch (final IOException ex) {
+           this.getLogger().catching(ex);
+           System.exit(1);
+       }
+    }
+
+    /**
+     * Get length of underlaying file
+     *
+     * @return Length of underlaying file
+     */
+    @Override
+    public long length () {
+       long length = 0;
+       
+       try {
+           length = this.getStorageFile().length();
+           this.getLogger().debug(MessageFormat.format("length={0}", length));
+       } catch (final IOException ex) {
+           // Length cannot be determined
+           this.getLogger().catching(ex);
+           System.exit(1);
+       }
+       
+       // Return result
+        this.getLogger().trace(MessageFormat.format("length={0} : EXIT!", length));
+       return length;
+    }
+
+    /**
+     * Rewinds backend
+     */
+    @Override
+    public void rewind (){
+        this.getLogger().trace("CALLED!");
+
+       try {
+           // Rewind underlaying database file
+           this.getStorageFile().seek(0);
+       } catch (final IOException ex) {
+           this.getLogger().catching(ex);
+           System.exit(1);
+       }
+
+       this.getLogger().trace("EXIT!");
+    }
+
+    /**
+     * Stores given object by "visiting" it
+     *
+     * @param object An object implementing Storeable
+     * @throws java.io.IOException From "inner" class
+     */
+    @Override
+    public void store (final Storeable object) throws IOException {
+       // Make sure the instance is there (DataOutput flawor)
+       assert(this.storageFile instanceof DataOutput);
+
+       // Try to cast it, this will fail if the interface is not implemented
+       StoreableCsv csv = (StoreableCsv) object;
+
+       // Now get a string from the object that needs to be stored
+       String str = csv.getCsvStringFromStoreableObject();
+
+       // Debug message
+       this.getLogger().debug(MessageFormat.format("str({0})={1}", str.length(), str));
+
+       // The string is now a valid CSV string
+       this.getStorageFile().writeBytes(str);
+    }
+
+    /**
+     * Adds given contact to list
+     * 
+     * @param contact Contact instance to add
+     * @param list List instance
+     */
+    private void addContactToList (final Contact contact, final List<Contact> list) {
+       // Debug message
+       this.getLogger().debug(MessageFormat.format("contact={0}", contact));
+
+       // Is the contact read?
+       if (contact instanceof Contact) {
+           // Then add it
+           boolean added = list.add(contact);
+
+           // Debug message
+           this.getLogger().debug(MessageFormat.format("contact={0} added={1}", contact, added));
+
+           // Has it been added?
+           if (!added) {
+               // Not added
+               this.getLogger().warn("Contact object has not been added.");
+           }
+       }
+    }
+
+    /**
+     * Returns storage file
+     * 
+     * @return Storage file instance
+     */
+    private RandomAccessFile getStorageFile () {
+       return this.storageFile;
+    }
+
+    /**
+     * Checks whether end of file has been reached
+     * 
+     * @return Whether lines are left to read
+     */
+    private boolean isEndOfFile () {
+       // Default is EOF
+       boolean isEof = true;
+
+       try {
+           isEof = (this.getStorageFile().getFilePointer() >= this.length());
+       } catch (final IOException ex) {
+           // Length cannot be determined
+           this.getLogger().catching(ex);
+       }
+
+       // Return status
+       this.getLogger().trace(MessageFormat.format("isEof={0} : EXIT!", isEof));
+       return isEof;
+    }
+
+    /**
+     * Reads the database file, if available, and adds all read lines into
+     * the list.
+     * 
+     * @return A list with Contact instances
+     */
+    private List<Contact> readContactList () throws BadTokenException {
+       this.getLogger().trace("CALLED!");
+
+       // First rewind
+       this.rewind();
+
+       // Get file size and divide it by 140 (possible average length of one line)
+       int lines = Math.round(this.length() / 140 + 0.5f);
+
+       // Debug message
+       this.getLogger().debug(MessageFormat.format("lines={0}", lines));
+
+       // Instance list
+       // @TODO The maximum length could be guessed from file size?
+       List<Contact> list = new ArrayList<>(lines);
+
+       // Init variables
+       StringTokenizer tokenizer;
+       String line;
+
+       // Read all lines
+       while (!this.isEndOfFile()) {
+           // Then read a line
+           line = this.readLine();
+
+           // Debug message
+           this.getLogger().debug(MessageFormat.format("line={0}", line));
+
+           // Then tokenize it
+           // @TODO Move this into separate method
+           tokenizer = new StringTokenizer(line, ";");
+
+           // Count round
+           int count = 0;
+
+           // Init contact object
+           Contact contact = null;
+
+           // The tokens are now available, so get all
+           while (tokenizer.hasMoreElements()) {
+               // Get next token
+               String token = tokenizer.nextToken();
+
+               // Debug message
+               this.getLogger().debug(MessageFormat.format("token={0}", token));
+
+               // Verify token, it must have double-quotes on each side
+               if ((!token.startsWith("\"")) || (!token.endsWith("\""))) {
+                   // Something bad was read
+                   throw new BadTokenException(MessageFormat.format("Token {0} has not double-quotes on both ends.", token));
+               }
+
+               // All fine, so remove it
+               String strippedToken = token.substring(1, token.length() - 1);
+
+               // Is the string's content "null"?
+               if (strippedToken.equals("null")) {
+                   // Debug message
+                   this.getLogger().debug(MessageFormat.format("strippedToken={0} - NULL!", strippedToken));
+
+                   // This needs to be set to null
+                   strippedToken = null;
+               }
+
+               // Debug message
+               this.getLogger().debug(MessageFormat.format("strippedToken={0}", strippedToken));
+
+               // Init number/string data values
+               String strData = strippedToken;
+               Long num = null;
+               Boolean bool = null;
+               char gender = '?';
+               
+               // Now, let's try a number check, if no null
+               if (strippedToken != null) {
+                   // Okay, no null, maybe the string bears a decimal number?
+                   try {
+                       num = Long.valueOf(strippedToken);
+
+                       // Debug message
+                       this.getLogger().debug(MessageFormat.format("strippedToken={0} - NUMBER!", strippedToken));
+                   } catch (final NumberFormatException ex) {
+                       // No number, then set default
+                       num = null;
+                   }
+               }
+               
+               // Now, let's try a boolean check, if no null
+               if ((strippedToken != null) && (num == null) && ((strippedToken.equals("true")) || (strippedToken.equals("false")))) {
+                   // Debug message
+                   this.getLogger().debug(MessageFormat.format("strippedToken={0} - BOOLEAN!", strippedToken));
+
+                   // parseBoolean() is relaxed, so no exceptions
+                   bool = Boolean.valueOf(strippedToken);
+               }
+               
+               // Now, let's try a boolean check, if no null
+               if ((strippedToken != null) && (num == null) && (bool == null) && ((strippedToken.equals("M")) || (strippedToken.equals("F")) || (strippedToken.equals("C")))) {
+                   // Get first character
+                   gender = strippedToken.charAt(0);
+               }
+
+               // Now it depends on the counter which position we need to check
+               switch (count) {
+                   case 0: // isOwnContact
+                       assert((bool instanceof Boolean));
+
+                       // Debug message
+                       this.getLogger().debug(MessageFormat.format("bool={0}", bool));
+
+                       // Is it own contact?
+                       if (true == bool) {
+                           // Debug message
+                           this.getLogger().debug("Creating UserContact object ...");
+
+                           // Own entry
+                           contact = new UserContact();
+                       } else {
+                           // Debug message
+                           this.getLogger().debug("Creating BookContact object ...");
+
+                           // Other contact
+                           contact = new BookContact();
+                       }
+                       break;
+
+                   case 1: // Gender
+                       assert(contact instanceof Contact) : "First token was not boolean";
+                       assert(gender != '?') : "Gender is not detected.";
+
+                       // Update data
+                       contact.updateNameData(gender, null, null, null);
+                       break;
+
+                   case 2: // Surname
+                       assert(contact instanceof Contact) : "First token was not boolean";
+                       assert(gender != '?') : "Gender is not detected.";
+
+                       // Update data
+                       contact.updateNameData(gender, strippedToken, null, null);
+                       break;
+
+                   case 3: // Family name
+                       assert(contact instanceof Contact) : "First token was not boolean";
+                       assert(gender != '?') : "Gender is not detected.";
+
+                       // Update data
+                       contact.updateNameData(gender, null, strippedToken, null);
+                       break;
+
+                   case 4: // Company name
+                       assert(contact instanceof Contact) : "First token was not boolean";
+                       assert(gender != '?') : "Gender is not detected.";
+
+                       // Update data
+                       contact.updateNameData(gender, null, null, strippedToken);
+                       break;
+
+                   case 5: // Street number
+                       assert(contact instanceof Contact) : "First token was not boolean";
+
+                       // Update data
+                       contact.updateAddressData(strippedToken, 0, null, null);
+                       break;
+
+                   case 6: // ZIP code
+                       assert(contact instanceof Contact) : "First token was not boolean";
+
+                       // Update data
+                       contact.updateAddressData(null, num, null, null);
+                       break;
+
+                   case 7: // City name
+                       assert(contact instanceof Contact) : "First token was not boolean";
+
+                       // Update data
+                       contact.updateAddressData(null, 0, strippedToken, null);
+                       break;
+
+                   case 8: // Country code
+                       assert(contact instanceof Contact) : "First token was not boolean";
+
+                       // Update data
+                       contact.updateAddressData(null, 0, null, strippedToken);
+                       break;
+
+                   case 9: // Phone number
+                       assert(contact instanceof Contact) : "First token was not boolean";
+
+                       // Update data
+                       contact.updateOtherData(strippedToken, null, null, null, null, null);
+                       break;
+
+                   case 10: // Fax number
+                       assert(contact instanceof Contact) : "First token was not boolean";
+
+                       // Update data
+                       contact.updateOtherData(null, strippedToken, null, null, null, null);
+                       break;
+
+                   case 11: // Cellphone number
+                       assert(contact instanceof Contact) : "First token was not boolean";
+
+                       // Update data
+                       contact.updateOtherData(null, null, strippedToken, null, null, null);
+                       break;
+
+                   case 12: // Email address
+                       assert(contact instanceof Contact) : "First token was not boolean";
+
+                       // Update data
+                       contact.updateOtherData(null, null, null, strippedToken, null, null);
+                       break;
+
+                   case 13: // Birthday
+                       assert(contact instanceof Contact) : "First token was not boolean";
+
+                       // Update data
+                       contact.updateOtherData(null, null, null, null, strippedToken, null);
+                       break;
+
+                   case 14: // Birthday
+                       assert(contact instanceof Contact) : "First token was not boolean";
+
+                       // Update data
+                       contact.updateOtherData(null, null, null, null, null, strippedToken);
+                       break;
+
+                   default: // New data entry
+                       this.getLogger().warn(MessageFormat.format("Will not handle unknown data {0} at index {1}", strippedToken, count));
+                       break;
+               }
+
+               // Increment counter for next round
+               count++;
+           }
+
+           // Add contact
+           this.addContactToList(contact, list);
+       }
+
+       // Return finished list
+       this.getLogger().trace(MessageFormat.format("list.size()={0} : EXIT!", list.size()));
+       return list;
+    }
+
+    /**
+     * Reads a line from file base
+     *
+     * @return Read line from file
+     */
+    private String readLine () {
+       // Init input
+       String input = null;
+
+       try {
+           input = this.getStorageFile().readLine();
+       } catch (final IOException ex) {
+           this.getLogger().catching(ex);
+       }
+
+       // Return read string or null
+       return input;
+    }
+}
index df1854c93cb4bd3e601082b3e4d403c378df83a9..c181b8816995b3620e8d9481a125a24fdbb40f8f 100644 (file)
-/*\r
- * Copyright (C) 2015 Roland Haeder\r
- *\r
- * This program is free software: you can redistribute it and/or modify\r
- * it under the terms of the GNU General Public License as published by\r
- * the Free Software Foundation, either version 3 of the License, or\r
- * (at your option) any later version.\r
- *\r
- * This program is distributed in the hope that it will be useful,\r
- * but WITHOUT ANY WARRANTY; without even the implied warranty of\r
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the\r
- * GNU General Public License for more details.\r
- *\r
- * You should have received a copy of the GNU General Public License\r
- * along with this program.  If not, see <http://www.gnu.org/licenses/>.\r
- */\r
-package org.mxchange.addressbook.database.frontend.contact;\r
-\r
-import java.io.IOException;\r
-import java.util.Iterator;\r
-import java.util.List;\r
-import org.mxchange.addressbook.BadTokenException;\r
-import org.mxchange.addressbook.contact.Contact;\r
-import org.mxchange.addressbook.database.backend.csv.CsvBackend;\r
-import org.mxchange.addressbook.database.frontend.BaseDatabaseFrontend;\r
-import org.mxchange.addressbook.database.storage.Storeable;\r
-import org.mxchange.addressbook.manager.contact.ContactManager;\r
-\r
-/**\r
- * Stores and retrieves Contact instances\r
- *\r
- * @author Roland Haeder\r
- */\r
-public class ContactDatabaseFrontend extends BaseDatabaseFrontend implements ContactWrapper {\r
-    /**\r
-     * Constructor which accepts a contact manager\r
-     * @param manager\r
-     */\r
-    public ContactDatabaseFrontend (final ContactManager manager) {\r
-       // Call own constructor\r
-       this();\r
-       \r
-       // Set contact manager\r
-       this.setContactManager(manager);\r
-    }\r
-\r
-    /**\r
-     * Basic constrcutor\r
-     */\r
-    protected ContactDatabaseFrontend () {\r
-       super();\r
-\r
-       // Set "table" name\r
-       this.setTableName("contacts");\r
-\r
-       // Initalize backend\r
-       this.initBackend();\r
-    }\r
-\r
-    /**\r
-     * Shuts down the database layer\r
-     */\r
-    @Override\r
-    public void doShutdown () {\r
-       // Shutdown backend\r
-       this.getBackend().doShutdown();\r
-    }\r
-\r
-    /**\r
-     * Flushes all contact entries to database\r
-     */\r
-    @Override\r
-    public void flushAllContacts () {\r
-       // Get full list\r
-       List<Contact> contacts = this.getContactManager().getList();\r
-\r
-       // Get iterator\r
-       Iterator<Contact> iterator = contacts.iterator();\r
-\r
-       // Rewind backend\r
-       this.getBackend().rewind();\r
-\r
-       // Get all entries\r
-       while (iterator.hasNext()) {\r
-           // Get next entry\r
-           Contact contact = iterator.next();\r
-\r
-           try {\r
-               // Store this entry\r
-               this.getBackend().store((Storeable) contact);\r
-           } catch (final IOException ex) {\r
-               // Should not happen?\r
-               this.getLogger().catching(ex);\r
-               System.exit(1);\r
-           }\r
-       }\r
-    }\r
-\r
-    /**\r
-     * Reads all contacts from database backend and handles them over to the\r
-     * contact manager\r
-     */\r
-    @Override\r
-    public void readAllContacts () {\r
-       // Get iterator and case it\r
-       CsvBackend backend = (CsvBackend) this.getBackend();\r
-       \r
-       // First rewind to beginning\r
-       this.getBackend().rewind();\r
-\r
-       // Get backend iterator\r
-       Iterator<Contact> iterator = null;\r
-       try {\r
-           iterator = backend.contactIterator();\r
-       } catch (final BadTokenException ex) {\r
-           this.getLogger().catching(ex);\r
-           System.exit(1);\r
-       }\r
-\r
-       // Read all entries\r
-       while (iterator.hasNext()) {\r
-           // Get next entry\r
-           Contact contact = iterator.next();\r
-\r
-           // Add contact instance to manager\r
-           this.getContactManager().addContact(contact);\r
-       }\r
-    }\r
-}\r
+/*
+ * Copyright (C) 2015 Roland Haeder
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+package org.mxchange.addressbook.database.frontend.contact;
+
+import java.io.IOException;
+import java.util.Iterator;
+import java.util.List;
+import org.mxchange.addressbook.exceptions.BadTokenException;
+import org.mxchange.addressbook.contact.Contact;
+import org.mxchange.addressbook.database.backend.csv.CsvBackend;
+import org.mxchange.addressbook.database.frontend.BaseDatabaseFrontend;
+import org.mxchange.addressbook.database.storage.Storeable;
+import org.mxchange.addressbook.manager.contact.ContactManager;
+
+/**
+ * Stores and retrieves Contact instances
+ *
+ * @author Roland Haeder
+ */
+public class ContactDatabaseFrontend extends BaseDatabaseFrontend implements ContactWrapper {
+    /**
+     * Constructor which accepts a contact manager
+     * @param manager
+     */
+    public ContactDatabaseFrontend (final ContactManager manager) {
+       // Call own constructor
+       this();
+       
+       // Set contact manager
+       this.setContactManager(manager);
+    }
+
+    /**
+     * Basic constrcutor
+     */
+    protected ContactDatabaseFrontend () {
+       super();
+
+       // Set "table" name
+       this.setTableName("contacts");
+
+       // Initalize backend
+       this.initBackend();
+    }
+
+    /**
+     * Shuts down the database layer
+     */
+    @Override
+    public void doShutdown () {
+       // Shutdown backend
+       this.getBackend().doShutdown();
+    }
+
+    /**
+     * Flushes all contact entries to database
+     */
+    @Override
+    public void flushAllContacts () {
+       // Get full list
+       List<Contact> contacts = this.getContactManager().getList();
+
+       // Get iterator
+       Iterator<Contact> iterator = contacts.iterator();
+
+       // Rewind backend
+       this.getBackend().rewind();
+
+       // Get all entries
+       while (iterator.hasNext()) {
+           // Get next entry
+           Contact contact = iterator.next();
+
+           try {
+               // Store this entry
+               this.getBackend().store((Storeable) contact);
+           } catch (final IOException ex) {
+               // Should not happen?
+               this.getLogger().catching(ex);
+               System.exit(1);
+           }
+       }
+    }
+
+    /**
+     * Reads all contacts from database backend and handles them over to the
+     * contact manager
+     */
+    @Override
+    public void readAllContacts () {
+       // Get iterator and case it
+       CsvBackend backend = (CsvBackend) this.getBackend();
+       
+       // First rewind to beginning
+       this.getBackend().rewind();
+
+       // Get backend iterator
+       Iterator<Contact> iterator = null;
+       try {
+           iterator = backend.contactIterator();
+       } catch (final BadTokenException ex) {
+           this.getLogger().catching(ex);
+           System.exit(1);
+       }
+
+       // Read all entries
+       while (iterator.hasNext()) {
+           // Get next entry
+           Contact contact = iterator.next();
+
+           // Add contact instance to manager
+           this.getContactManager().addContact(contact);
+       }
+    }
+}
diff --git a/Addressbook/src/org/mxchange/addressbook/exceptions/BadTokenException.java b/Addressbook/src/org/mxchange/addressbook/exceptions/BadTokenException.java
new file mode 100644 (file)
index 0000000..ed37c2c
--- /dev/null
@@ -0,0 +1,31 @@
+/*
+ * Copyright (C) 2015 Roland Haeder
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+package org.mxchange.addressbook.exceptions;
+
+/**
+ * This exception is thrown when a token has been badly formated. This may
+ * happen when a CSV file is broken.
+ *
+ * @author Roland Haeder
+ */
+public class BadTokenException extends Exception {
+
+    public BadTokenException (final String str) {
+       super(str);
+    }
+    
+}
diff --git a/Addressbook/src/org/mxchange/addressbook/exceptions/FrameAlreadyInitializedException.java b/Addressbook/src/org/mxchange/addressbook/exceptions/FrameAlreadyInitializedException.java
new file mode 100644 (file)
index 0000000..693ccc2
--- /dev/null
@@ -0,0 +1,32 @@
+/*
+ * Copyright (C) 2015 Roland Haeder
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+package org.mxchange.addressbook.exceptions;
+
+/**
+ * This exception is thrown when initFrame() is called twice.
+ * 
+ * @author Roland Haeder
+ */
+public class FrameAlreadyInitializedException extends Exception {
+
+    /**
+     * Default constructor
+     */
+    public FrameAlreadyInitializedException () {
+    }
+    
+}
diff --git a/Addressbook/src/org/mxchange/addressbook/exceptions/UnhandledUserChoiceException.java b/Addressbook/src/org/mxchange/addressbook/exceptions/UnhandledUserChoiceException.java
new file mode 100644 (file)
index 0000000..b2149bb
--- /dev/null
@@ -0,0 +1,30 @@
+/*
+ * Copyright (C) 2015 Roland Haeder
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+package org.mxchange.addressbook.exceptions;
+
+/**
+ * This exception is thrown when the user made a valid choice but it was not
+ * handled by the program.
+ * 
+ * @author Roland Haeder
+ */
+public class UnhandledUserChoiceException extends Exception {
+
+    public UnhandledUserChoiceException (final String message) {
+       super(message);
+    }
+}
index da2fe32191c7267362e47f9c600e92e73b27ecbf..8dc33aac9a09731f41fc89b86b2a1e03b4c0f678 100644 (file)
@@ -21,11 +21,11 @@ import java.util.ArrayList;
 import java.util.Collections;
 import java.util.Iterator;
 import java.util.List;
-import org.mxchange.addressbook.UnhandledUserChoiceException;
 import org.mxchange.addressbook.client.Client;
 import org.mxchange.addressbook.contact.Contact;
 import org.mxchange.addressbook.database.frontend.contact.ContactDatabaseFrontend;
 import org.mxchange.addressbook.database.frontend.contact.ContactWrapper;
+import org.mxchange.addressbook.exceptions.UnhandledUserChoiceException;
 import org.mxchange.addressbook.manager.BaseManager;
 
 /**