Implement pronouns table

src/main/java/wtf/beatrice/nounspicker/NounsPicker.java

@@ -53,7 +53,7 @@ public class NounsPicker extends JavaPlugin
         logger.log("Connecting to database...");
         String dbFilePath = getDataFolder().getAbsolutePath() + File.separator + "db.sqlite";
         DatabaseManager dbManager = new DatabaseManager(dbFilePath);
-        if(dbManager.initialize())
+        if(dbManager.connect() && dbManager.initDb())
         {
             logger.log("Database connection initialized!");
         } else {

src/main/java/wtf/beatrice/nounspicker/utils/DatabaseManager.java

@@ -3,6 +3,7 @@ package wtf.beatrice.nounspicker.utils;
 import java.sql.Connection;
 import java.sql.DriverManager;
 import java.sql.SQLException;
+import java.sql.Statement;
 
 public class DatabaseManager
 {
@@ -18,10 +19,25 @@ public class DatabaseManager
         logger = new ConsoleLogger(getClass());
     }
 
-    public boolean initialize()
+    public boolean connect()
     {
         String url = sqliteURL.replace("%path%", dbPath);
 
+        if(!close()) return false;
+
+        try {
+            dbConnection = DriverManager.getConnection(url);
+            logger.log("Database connection established!");
+            return true;
+        } catch (SQLException e) {
+            logger.err(e.getMessage());
+            return false;
+        }
+
+    }
+
+    public boolean close()
+    {
         if (dbConnection != null)
         {
             try {
@@ -37,16 +53,26 @@ public class DatabaseManager
             dbConnection = null;
         }
 
-
-        try {
-            dbConnection = DriverManager.getConnection(url);
-            logger.log("Database connection established!");
         return true;
+    }
+
+    public boolean initDb()
+    {
+        String sql = "CREATE TABLE IF NOT EXISTS pronouns (" +
+                "player text NOT NULL," +
+                "main_pronoun text," +
+                "secondary_pronoun text" +
+                ");";
+
+        try (Statement stmt = dbConnection.createStatement()) {
+            // create a new table
+            stmt.execute(sql);
         } catch (SQLException e) {
             logger.err(e.getMessage());
             return false;
         }
 
+        return true;
     }
 
 }