nJCRAsBz

1package com.bn1ck.lobby.MySQL;
2
3import java.sql.Connection;
4import java.sql.DriverManager;
5import java.sql.ResultSet;
6import java.sql.SQLException;
7import java.sql.Statement;
8
9import com.bn1ck.lobby.main.Files;
10import com.bn1ck.lobby.main.Main;
11
12public class MySQL {
13
14	Main plugin;
15
16	public MySQL(Main plugin) {
17		this.plugin = plugin;
18	}
19
20	public static Connection con;
21
22	public static void connect() {
23		if (!isConnected()) {
24			try {
25				con = DriverManager.getConnection(
26						"jdbc:mysql://" + Files.MySQLfile.getString("MySQL.Host") + ":3306" + "/"
27								+ Files.MySQLfile.getString("MySQL.Database") + "?autoReconnect=true",
28						Files.MySQLfile.getString("MySQL.User"), Files.MySQLfile.getString("MySQL.Password"));
29			} catch (SQLException e) {
30				
31			}
32		}
33	}
34
35	public static void disconnect() {
36		if (isConnected()) {
37			try {
38				con.close();
39			} catch (SQLException e) {
40				
41			}
42		}
43	}
44
45	public static void createTable() {
46		try {
47			con.prepareStatement(
48					"CREATE TABLE IF NOT EXISTS coinsTable (UUID VARCHAR(100), name VARCHAR(20), coins INT(20))")
49					.executeUpdate();
50			con.prepareStatement(
51					"CREATE TABLE IF NOT EXISTS hideTable (UUID VARCHAR(100), name VARCHAR(20), s1 INT(12), s2 INT(12), s3 INT(12), s4 INT(12), s5 INT(12), saveInv INT(12))")
52					.executeUpdate();
53			con.prepareStatement(
54					"CREATE TABLE IF NOT EXISTS livesTable (UUID VARCHAR(100), name VARCHAR(20), lives VARCHAR(550), selectC VARCHAR(20))")
55					.executeUpdate();
56			con.prepareStatement(
57					"CREATE TABLE IF NOT EXISTS particleTable (UUID VARCHAR(100), name VARCHAR(20), particle VARCHAR(550), selectC VARCHAR(20))")
58					.executeUpdate();
59			con.prepareStatement(
60					"CREATE TABLE IF NOT EXISTS balloonTable (UUID VARCHAR(100), name VARCHAR(20), balloon VARCHAR(550), selectC VARCHAR(20))")
61					.executeUpdate();
62			con.prepareStatement(
63					"CREATE TABLE IF NOT EXISTS prefixTable (UUID VARCHAR(100), name VARCHAR(20), prefix VARCHAR(550), selectC VARCHAR(20))")
64					.executeUpdate();
65			con.prepareStatement(
66					"CREATE TABLE IF NOT EXISTS headTable (UUID VARCHAR(100), name VARCHAR(20), head VARCHAR(550), selectC VARCHAR(20))")
67					.executeUpdate();
68			con.prepareStatement(
69					"CREATE TABLE IF NOT EXISTS armorTable (UUID VARCHAR(100), name VARCHAR(20), helmet INT(5), chestplate INT(5), leggings INT(5), boots INT(5))")
70					.executeUpdate();
71			con.prepareStatement(
72					"CREATE TABLE IF NOT EXISTS gadgetsTable (UUID VARCHAR(100), name VARCHAR(20), gadgets VARCHAR(550), selectC VARCHAR(20))")
73					.executeUpdate();
74			con.prepareStatement(
75					"CREATE TABLE IF NOT EXISTS pvpTable (UUID VARCHAR(100), name VARCHAR(20), kills INT(30), death INT(30))")
76					.executeUpdate();
77			con.prepareStatement(
78					"CREATE TABLE IF NOT EXISTS rewardsTable (UUID VARCHAR(100), name VARCHAR(20), date1 VARCHAR(10), date2 VARCHAR(10), date3 VARCHAR(10), date4 VARCHAR(10))")
79					.executeUpdate();
80			con.prepareStatement(
81					"CREATE TABLE IF NOT EXISTS settingsTable (UUID VARCHAR(100), name VARCHAR(20), autonick INT(5), premiumnick INT(5))")
82					.executeUpdate();
83			con.prepareStatement(
84					"CREATE TABLE IF NOT EXISTS settingsTableII (UUID VARCHAR(100), name VARCHAR(20), chat INT(5), speed INT(5), doublejump INT(5), broadcaster INT(5))")
85					.executeUpdate();
86			con.prepareStatement(
87					"CREATE TABLE IF NOT EXISTS petsTable (UUID VARCHAR(100), name VARCHAR(20), pets VARCHAR(550), selectC VARCHAR(20))")
88					.executeUpdate();
89			con.prepareStatement(
90					"CREATE TABLE IF NOT EXISTS winningTable (UUID VARCHAR(100), name VARCHAR(20), ticket INT(20), normal INT(20), legendary INT(20))")
91					.executeUpdate();
92			con.prepareStatement(
93					"CREATE TABLE IF NOT EXISTS termsTable (UUID VARCHAR(100), name VARCHAR(20), terms INT(20))")
94					.executeUpdate();
95		} catch (SQLException e) {
96			
97		}
98	}
99
100	public static boolean isConnected() {
101		return con != null;
102	}
103
104	public void update(String qry) {
105		if (isConnected()) {
106			try {
107				con.createStatement().executeUpdate(qry);
108			} catch (SQLException e) {
109				
110			}
111		}
112	}
113
114	public ResultSet getResult(String qry) {
115		ResultSet rs = null;
116		try {
117			Statement st = con.createStatement();
118			rs = st.executeQuery(qry);
119		} catch (SQLException e) {
120			connect();
121		}
122		return rs;
123	}
124
125	public static Connection getConnection() {
126		return con;
127	}
128
129}