mysql init

Author: LinkTechTips

fsd.conf

@@ -47,6 +47,10 @@ password=disable
 location=Nowhere
 mode=normal
 certificates=cert.txt
+mysqlmode=false
+#sqlurl=jdbc:mysql://主机名或IP地址:端口号/数据库名称
+#sqluser=41857486
+#sqlpassword=74867486
 maxclients=200
 whazzup=whazzup.txt
 whazzupjson=whazzup.json

pom.xml

@@ -80,6 +80,11 @@
             <artifactId>http</artifactId>
             <version>20070405</version>
         </dependency>
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+            <version>8.0.30</version>
+        </dependency>
     </dependencies>
     <build>
         <defaultGoal>compile</defaultGoal>

src/main/java/org/linktechtips/Main.java

@@ -5,6 +5,9 @@
 
 package org.linktechtips;
 
+import org.apache.commons.lang3.StringUtils;
+import org.apache.commons.lang3.math.NumberUtils;
+import org.jetbrains.annotations.NotNull;
 import org.linktechtips.constants.*;
 import org.linktechtips.httpapi.httpApiManage;
 import org.linktechtips.manager.Manage;
@@ -23,9 +26,6 @@
 import org.linktechtips.process.network.ServerInterface;
 import org.linktechtips.process.network.SystemInterface;
 import org.linktechtips.support.Support;
-import org.apache.commons.lang3.StringUtils;
-import org.apache.commons.lang3.math.NumberUtils;
-import org.jetbrains.annotations.NotNull;
 import org.slf4j.Logger;
 
 import java.io.File;
@@ -41,6 +41,7 @@
 import java.nio.file.attribute.BasicFileAttributes;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Objects;
 import java.util.Scanner;
 
 import static org.slf4j.LoggerFactory.getLogger;
@@ -59,13 +60,18 @@ public class Main {
     private String certFile;
     private String whazzupFile;
     private String whazzupjsonFile;
+    private String mysqlmode;
+    private String sqlurl;
+    private String sqluser;
+    private String sqlpassword;
     private long timer;
     private long prevNotify;
     private long prevLagCheck;
     private long certFileStat;
     private int fileOpen;
     private long prevCertCheck;
     private long prevWhazzup;
+
     public Main(String configFile) {
         LOGGER.info("[BetterFSD]: Booting Server");
         pManager = new PMan();
@@ -99,7 +105,7 @@ public Main(String configFile) {
                         service.PlugunVersion()));
                 service.PluginService();
             }
-            LOGGER.info(String.format("[Plugins]: %s plugins loaded successfully",services.size()));
+            LOGGER.info(String.format("[Plugins]: %s plugins loaded successfully", services.size()));
         } catch (MalformedURLException e) {
             LOGGER.error("[Plugins]: Failed to load plugins");
             e.printStackTrace();
@@ -110,8 +116,10 @@ public Main(String configFile) {
         prevWhazzup = Support.mtime();
         fileOpen = 0;
     }
+
     public void close() {
     }
+
     /* Here we do timeout checks. This function is triggered every second to
    reduce the load on the server */
     public void doChecks() {
@@ -396,20 +404,38 @@ private void configure() {
             if ((entry = system.getEntry("systemport")) != null) {
                 systemPort = entry.getInt();
             }
-            if ((entry = system.getEntry("certificates")) != null) {
-                certFile = entry.getData();
+            if ((entry = system.getEntry("mysqlmode")) != null) {
+                mysqlmode = entry.getData();
+                if (Objects.equals(mysqlmode, "false")) {
+                    if ((entry = system.getEntry("certificates")) != null) {
+                        certFile = entry.getData();
+                    }
+                } else if (Objects.equals(mysqlmode, "true")) {
+                    if ((entry = system.getEntry("sqlurl")) != null) {
+                        sqlurl = entry.getData();
+                    }
+                    if ((entry = system.getEntry("sqluser")) != null) {
+                        sqluser = entry.getData();
+                    }
+                    if ((entry = system.getEntry("sqlpassword")) != null) {
+                        sqlpassword = entry.getData();
+                    }
+                }
             }
             if ((entry = system.getEntry("whazzup")) != null) {
                 whazzupFile = entry.getData();
             }
             if ((entry = system.getEntry("whazzupjson")) != null) {
-                whazzupjsonFile= entry.getData();
+                whazzupjsonFile = entry.getData();
             }
-        }
-        configMyServer();
-        readCert();
     }
 
+    configMyServer();
+
+    readCert();
+
+}
+
     void handleCidLine(@NotNull String line) {
         Certificate tempcert;
         int mode, level;
@@ -438,30 +464,34 @@ void handleCidLine(@NotNull String line) {
     }
 
     void readCert() {
-        if (StringUtils.isBlank(certFile)) return;
+        if (Objects.equals(mysqlmode, "false")) {
+            if (StringUtils.isBlank(certFile)) return;
 
-        List<String> lines;
-        File file = new File(certFile);
-        try {
-            lines = Files.readAllLines(Paths.get(certFile), StandardCharsets.UTF_8);
-        } catch (IOException e) {
-            LOGGER.error(String.format("[BetterFSD]: Could not open certificate file '%s'",
-                    file.getAbsolutePath()), e);
-            return;
-        }
+            List<String> lines;
+            File file = new File(certFile);
+            try {
+                lines = Files.readAllLines(Paths.get(certFile), StandardCharsets.UTF_8);
+            } catch (IOException e) {
+                LOGGER.error(String.format("[BetterFSD]: Could not open certificate file '%s'",
+                        file.getAbsolutePath()), e);
+                return;
+            }
 
-        for (Certificate temp : Certificate.certs) {
-            temp.setLiveCheck(0);
-        }
-        LOGGER.info(String.format("[BetterFSD]: Reading certificates from '%s'", certFile));
-        for (String line : lines) {
-            handleCidLine(line);
-        }
-        for (Certificate temp : Certificate.certs) {
-            if (temp.getLiveCheck() == 0) {
-                serverInterface.sendCert("*", ProtocolConstants.CERT_DELETE, temp, null);
-                temp.close();
+            for (Certificate temp : Certificate.certs) {
+                temp.setLiveCheck(0);
+            }
+            LOGGER.info(String.format("[BetterFSD]: Reading certificates from '%s'", certFile));
+            for (String line : lines) {
+                handleCidLine(line);
+            }
+            for (Certificate temp : Certificate.certs) {
+                if (temp.getLiveCheck() == 0) {
+                    serverInterface.sendCert("*", ProtocolConstants.CERT_DELETE, temp, null);
+                    temp.close();
+                }
             }
+        } else if (Objects.equals(mysqlmode, "true")) {
+            //TODO
         }
     }