Fix H2 Server.

Author: DxsSucuk

pom.xml

@@ -7,7 +7,7 @@
     <groupId>de.ree6</groupId>
     <artifactId>Ree6-SQL</artifactId>
     <description>This is the SQL-Module for Ree6!</description>
-    <version>2.2.3</version>
+    <version>2.2.4</version>
 
     <properties>
         <sonar.organization>ree6-applications</sonar.organization>

src/main/java/de/presti/ree6/sql/SQLSession.java

@@ -146,7 +146,7 @@ public SQLSession(SQLConfig config) {
             if (databaseTyp == DatabaseTyp.H2) {
                 try {
                     embeddedDatabaseServer = new H2DatabaseServer();
-                    embeddedDatabaseServer.createServer();
+                    embeddedDatabaseServer.createServer(config.getPort(), config.getPassword(), config.getPath());
                 } catch (Exception exception) {
                     log.error("Couldn't start embedded H2 Database!", exception);
                 }

src/main/java/de/presti/ree6/sql/util/IDatabaseServer.java

@@ -7,12 +7,18 @@ public interface IDatabaseServer {
 
     /**
      * Create the server.
+     *
+     * @param port     The port of the server.
+     * @param password The password of the server.
+     * @param path     The path of the storage file.
+     *
      * @throws Exception If something goes wrong.
      */
-    void createServer() throws Exception;
+    void createServer(int port, String password, String path) throws Exception;
 
     /**
      * Destroy the server.
+     *
      * @throws Exception If something goes wrong.
      */
     void destroyServer() throws Exception;

src/main/java/de/presti/ree6/sql/util/server/H2DatabaseServer.java

@@ -1,5 +1,6 @@
 package de.presti.ree6.sql.util.server;
 
+import de.presti.ree6.sql.SQLSession;
 import de.presti.ree6.sql.util.IDatabaseServer;
 import org.h2.tools.Server;
 
@@ -17,11 +18,18 @@ public class H2DatabaseServer implements IDatabaseServer {
 
     /**
      * Create the server.
+     *
      * @throws SQLException If something goes wrong.
      */
     @Override
-    public void createServer() throws SQLException {
-        server = Server.createTcpServer().start();
+    public void createServer(int port, String password, String path) throws SQLException {
+        String[] args = new String[] { "-tcp", "-tcpAllowOthers", "-ifNotExists", "-tcpPort", String.valueOf(port), "-tcpPassword", password, "-baseDir", path };
+        server = Server.createTcpServer(args).start();
+        if (server.isRunning(true)) {
+            System.out.println("H2-Server started successfully.");
+        } else {
+            System.out.println("H2-Server could not be started.");
+        }
     }
 
     /**