diff --git a/src/main/java/com/alttd/database/Database.java b/src/main/java/com/alttd/database/Database.java
new file mode 100644
index 0000000..42d8fa5
--- /dev/null
+++ b/src/main/java/com/alttd/database/Database.java
@@ -0,0 +1,81 @@
+package com.alttd.database;
+
+import com.alttd.AltitudeParticles;
+import com.alttd.config.DatabaseConfig;
+import com.alttd.util.Logger;
+import org.bukkit.Bukkit;
+
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.SQLException;
+
+public class Database {
+
+    private static Database instance = null;
+    public static Connection connection = null;
+
+    private Database() {
+
+    }
+
+    public static Database getDatabase(){
+        if (instance == null)
+            instance = new Database();
+        return (instance);
+    }
+
+    public void init() {
+        try {
+            openConnection();
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+
+        // Tables
+        createUserPointsTable();
+    }
+
+    /**
+     * Opens the connection if it's not already open.
+     * @throws SQLException If it can't create the connection.
+     */
+    private void openConnection() throws SQLException {
+        if (connection != null && !connection.isClosed()) {
+            return;
+        }
+
+        synchronized (this) {
+            if (connection != null && !connection.isClosed()) {
+                return;
+            }
+            try {
+                Class.forName("com.mysql.cj.jdbc.Driver");
+            } catch (ClassNotFoundException e) {
+                e.printStackTrace();
+            }
+
+            connection = DriverManager.getConnection(
+                    "jdbc:mysql://" + DatabaseConfig.IP + ":" + DatabaseConfig.PORT + "/" + DatabaseConfig.DATABASE_NAME +
+                            "?autoReconnect=true&useSSL=false&allowPublicKeyRetrieval=true",
+                    DatabaseConfig.USERNAME, DatabaseConfig.PASSWORD);
+        }
+    }
+
+    private static void createUserPointsTable() {
+        try {
+            String sql = "CREATE TABLE IF NOT EXISTS active_particles(" +
+                    "uuid VARCHAR(36) NOT NULL, " +
+                    "particle_type VARCHAR(36) NOT NULL, " +
+                    "particle_id VARCHAR(36) NOT NULL, " +
+                    "PRIMARY KEY (uuid, particle_type)" +
+                    ")";
+            connection.prepareStatement(sql).executeUpdate();
+        } catch (SQLException e) {
+            e.printStackTrace();
+            Logger.severe("Error while trying to create user point table");
+            Logger.severe("Shutting down AltitudeParticles");
+            Bukkit.getPluginManager().disablePlugin(AltitudeParticles.getInstance());
+        }
+    }
+
+}
diff --git a/src/main/java/com/alttd/database/Queries.java b/src/main/java/com/alttd/database/Queries.java
new file mode 100644
index 0000000..8ecc247
--- /dev/null
+++ b/src/main/java/com/alttd/database/Queries.java
@@ -0,0 +1,4 @@
+package com.alttd.database;
+
+public class Queries {
+}