diff --git a/loaders/mysql-loader/src/main/java/com/infernalsuite/asp/loaders/mysql/MysqlLoader.java b/loaders/mysql-loader/src/main/java/com/infernalsuite/asp/loaders/mysql/MysqlLoader.java
index 546a42ce..9e56af24 100644
--- a/loaders/mysql-loader/src/main/java/com/infernalsuite/asp/loaders/mysql/MysqlLoader.java
+++ b/loaders/mysql-loader/src/main/java/com/infernalsuite/asp/loaders/mysql/MysqlLoader.java
@@ -75,6 +75,12 @@ public MysqlLoader(HikariDataSource hikariDataSource) throws SQLException {
         init();
     }
 
+    public void close() {
+        if (source != null && !source.isClosed()) {
+            source.close();
+        }
+    }
+
     @Override
     public void update() throws IOException, NewerStorageException {
         try (Connection con = source.getConnection()) {