v 1.0.0

first release

Author: belbix

checker.cfg

@@ -0,0 +1,7 @@
+dbClassName: com.mysql.cj.jdbc.Driver
+dbUrl: jdbc:mysql://localhost:3306/tim?useUnicode=true&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC&useSSL=false&allowPublicKeyRetrieval=true
+dbUser: belbix
+dbPassword: 111111
+loopTime: 10
+dateSelect: select t.date from ticks as t order by t.date desc limit 1
+maxDiff: 100

src/main/resources/logback.xml renamed to logback.xml

@@ -1,5 +1,5 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<configuration debug="true">
+<configuration>
 
     <property name="LOGS" value="./logs" />
 
@@ -33,7 +33,7 @@
         <smtpHost>smtp.gmail.com</smtpHost>
         <smtpPort>587</smtpPort>
         <username>klan.kapkan@gmail.com</username>
-        <password>br00tha7</password>
+        <password>123</password>
         <to>7453635@gmail.com</to>
         <from>klan.kapkan@gmail.com</from>
         <subject>CHECKER: %logger{20} - %m</subject>

pom.xml

@@ -35,7 +35,7 @@
     </dependencies>
 
     <build>
-        <finalName>tim</finalName>
+        <finalName>dbchecker</finalName>
         <plugins>
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>

sh/shutdown.sh

@@ -0,0 +1,5 @@
+#!/bin/bash
+AppPID=`cat ./pid`
+kill $AppPID
+echo Stop app with PID: $AppPID
+rm ./pid

sh/start.bat

@@ -0,0 +1 @@
+ '/C/Program Files/Java/jdk-11.0.1/bin/java' -Xmx256m  -Dlogback.configurationFile=logback.xml -cp dbchecker.jar pro.belbix.dbchecker.Main checker.cfg

sh/startup.sh

@@ -0,0 +1,5 @@
+#!/bin/bash
+nohup java -Xmx128m -Dlogback.configurationFile=logback.xml -cp dbchecker.jar pro.belbix.dbchecker.Main checker.cfg > /dev/null 2>&1 &
+MyPID=$!
+echo Start DB Checker with PID: $MyPID
+echo $MyPID > ./pid

src/main/java/pro/belbix/dbchecker/Config.java

@@ -1,6 +1,15 @@
 package pro.belbix.dbchecker;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.BufferedReader;
+import java.io.FileReader;
+import java.io.IOException;
+import java.lang.reflect.Field;
+
 public class Config {
+    private final static Logger log = LoggerFactory.getLogger(Config.class);
     private static String path;
     private static Config instance;
 
@@ -18,20 +27,54 @@ public static Config getInstance() {
     }
 
     private void init() {
-        if(path == null) return;
+        if (path == null) return;
+        try (BufferedReader br = new BufferedReader(new FileReader(path))) {
+            String s;
+            while ((s = br.readLine()) != null) {
+                readLine(s);
+            }
+        } catch (IOException e) {
+            log.error(e.getMessage(), e);
+        }
+
+    }
+
+    private void readLine(String s) {
+        String[] splt = s.split(":", 2);
+        if (splt.length < 2) throw new IllegalStateException("Wrong config: " + s);
+        String name = splt[0].trim();
+        String value = splt[1].trim();
+
+        try {
+            Field field = this.getClass().getDeclaredField(name);
+            field.setAccessible(true);
+            switch (field.getType().getSimpleName()) {
+                case "String":
+                    field.set(this, value);
+                    break;
+                case "Integer":
+                    field.set(this, Integer.valueOf(value));
+                    break;
+                default:
+                    throw new UnsupportedOperationException("Type not supported: " + field.getType().getSimpleName());
+            }
+
+        } catch (NoSuchFieldException | IllegalAccessException e) {
+            log.error(e.getMessage(), e);
+        }
     }
 
-    public static void setPath(String path){
+    public static void setPath(String path) {
         Config.path = path;
     }
 
     private String dbClassName = "com.mysql.cj.jdbc.Driver";
     private String dbUrl = "jdbc:mysql://localhost:3306/tim?useUnicode=true&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC&useSSL=false&allowPublicKeyRetrieval=true";
     private String dbUser = "belbix";
     private String dbPassword = "111111";
-    private int loopTime = 10;
+    private Integer loopTime = 10;
     private String dateSelect = "select t.date from ticks as t order by t.date desc limit 1";
-    private int maxDiff = 100;
+    private Integer maxDiff = 100;
 
     public String getDbClassName() {
         return dbClassName;

src/main/java/pro/belbix/dbchecker/DBService.java

@@ -36,7 +36,7 @@ private void init() {
         } catch (ClassNotFoundException e) {
             log.error(e.getMessage(), e);
         }
-
+        log.info("Connect to " + config.getDbUrl());
         try {
             conn = DriverManager.getConnection(config.getDbUrl(), config.getDbUser(), config.getDbPassword());
         } catch (SQLException e) {