1.2.0

2021-12-21 05:57:29 +01:00
commit 6b6ebbcd18
99 changed files with 41154 additions and 0 deletions
--- a/V2/src/main/java/de/jatitv/commandguiv2/Bungee/BMySQL.java
+++ b/V2/src/main/java/de/jatitv/commandguiv2/Bungee/BMySQL.java
@@ -0,0 +1,105 @@
+package de.jatitv.commandguiv2.Bungee;
+
+
+
+import net.md_5.bungee.api.plugin.Plugin;
+import net.t2code.lib.Bungee.Lib.messages.Bsend;
+
+import java.sql.*;
+import java.time.ZoneId;
+import java.util.ArrayList;
+import java.util.Calendar;
+
+public class BMySQL {
+    private static Plugin plugin = BMain.plugin;
+    protected static String ip = "localhost";
+    protected static Integer port = 3306;
+    protected static String database;
+    protected static String user = "root";
+    protected static String password = "";
+    protected static String url;
+    protected static Boolean SSL;
+
+    public static void main() {
+        Long long_ = Long.valueOf(System.currentTimeMillis());
+        Calendar now = Calendar.getInstance();
+        ZoneId timeZone = now.getTimeZone().toZoneId();
+        Bsend.debug(plugin, "Server TimeZone is : " + timeZone);
+        url = "jdbc:mysql://" + ip + ":" + port + "/" + database + "?useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=" + timeZone;
+        // Europe/Berlin
+        if (SSL) {
+            url = url + "&useSSL=true";
+        } else url = url + "&useSSL=false";
+        Bsend.debug(plugin, url);
+        try (Connection con = DriverManager.getConnection(url, user, password)) {
+            Statement stmt = con.createStatement();
+            stmt.close();
+            Bsend.console(BMain.prefix + " §2MySQL successfully connected." + " §7- §e" + (System.currentTimeMillis() - long_.longValue()) + "ms");
+        } catch (SQLException ex) {
+            Bsend.console(BMain.prefix + " §4MySQL not connected." + " §7- §e" + (System.currentTimeMillis() - long_.longValue()) + "ms");
+            Bsend.error(plugin, ex.getMessage() + " --- " + (System.currentTimeMillis() - long_.longValue()) + "ms");
+        }
+    }
+
+    public static void query(String query) {
+        try (Connection con = DriverManager.getConnection(url, user, password)) {
+            Statement stmt = con.createStatement();
+            stmt.execute(query);
+            stmt.close();
+        } catch (SQLException ex) {
+            System.err.println(ex.getMessage());
+        }
+    }
+
+
+    public static ArrayList<String> selectAll(String query) {
+        ArrayList<String> Result = new ArrayList<>();
+        try (Connection con = DriverManager.getConnection(url, user, password)) {
+            Statement stmt = con.createStatement();
+            ResultSet rs = stmt.executeQuery(query);
+            int columns = rs.getMetaData().getColumnCount();
+            while (rs.next()) {
+                Result.add(rs.getString(1));
+            }
+            rs.close();
+            stmt.close();
+        } catch (SQLException ex) {
+            System.err.println(ex.getMessage());
+        }
+        return Result;
+    }
+
+    public static String select(String query) {
+        String Ausgabe = "";
+        try (Connection con = DriverManager.getConnection(url, user, password)) {
+            Statement stmt = con.createStatement();
+            ResultSet rs = stmt.executeQuery(query);
+            int columns = rs.getMetaData().getColumnCount();
+            while (rs.next()) {
+                Ausgabe = String.valueOf(rs.getString(1));
+            }
+            rs.close();
+            stmt.close();
+        } catch (SQLException ex) {
+            System.err.println(ex.getMessage());
+        }
+        return Ausgabe;
+    }
+
+    public static int count(String query) {
+        Integer count = 0;
+        try (Connection con = DriverManager.getConnection(url, user, password)) {
+            Statement stmt = con.createStatement();
+            ResultSet rs = stmt.executeQuery(query);
+            int columns = rs.getMetaData().getColumnCount();
+            while (rs.next()) {
+                count++;
+            }
+            rs.close();
+            stmt.close();
+        } catch (SQLException ex) {
+            System.err.println(ex.getMessage());
+        }
+        return count;
+    }
+}