108 lines
3.9 KiB
Java
108 lines
3.9 KiB
Java
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 Boolean Enable = false;
|
|
|
|
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;
|
|
}
|
|
}
|