tSqip16y

1package RageTime.MySQL;
2
3import java.sql.Connection;
4import java.sql.DriverManager;
5import java.sql.ResultSet;
6import java.sql.SQLException;
7
8import org.bukkit.Bukkit;
9
10import RageTime.Main.Main;
11
12public class MySQL {
13	public static String username;
14	public static String password;
15	public static String database;
16	public static String host;
17	public static String port;
18
19	public static Connection con;
20
21	//@SuppressWarnings("static-access")
22	@SuppressWarnings("static-access")
23	public static void connect() throws SQLException,
24    ClassNotFoundException {
25		if (!isConnected()) {
26			try {
27				con = DriverManager.getConnection("jdbc:mysql://" + host + ":" + port + "/" + database + "?autoReconnect=true&characterEncoding=latin1", username,password);
28				
29			//	con = DriverManager.getConnection("jdbc:mysql://localhost:3306/Lobby?characterEncoding=latin1", "root","justin1409");
30				Bukkit.getConsoleSender().sendMessage(Main.getInstance().prefix + "MySQL Verbindung aufgebaut!");
31			} catch (SQLException e) {
32				e.printStackTrace();
33			}
34		}
35	}
36
37	@SuppressWarnings("static-access")
38	public static void close() {
39		if (isConnected()) {
40			try {
41				con.close();
42				Bukkit.getConsoleSender().sendMessage(Main.getInstance().prefix + "MySQL Verbindung geschlossen!");
43			} catch (SQLException e) {
44				e.printStackTrace();
45			}
46		}
47	}
48
49	public static boolean isConnected() {
50		return con != null;
51	}
52
53	public static void createTable() {
54		if (isConnected()) {
55			try {
56				con.createStatement().executeUpdate(
57						"CREATE TABLE IF NOT EXISTS Worlds("
58						+ "uid INT NOT NULL AUTO_INCREMENT , "
59						+ "crdate TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP, "
60						+ "deleted BOOLEAN NOT NULL DEFAULT FALSE, "								
61						+ "player varchar(64), "
62						+ "world varchar(64), "
63						+ "PRIMARY KEY (uid));");
64				
65				con.createStatement().executeUpdate(
66						"CREATE TABLE IF NOT EXISTS tasks("
67						+ "uid INT NOT NULL AUTO_INCREMENT , "
68						+ "crdate TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP, "
69						+ "creatorplayer varchar(64), "								
70						+ "acceptedplayer varchar(64), "
71						+ "task varchar(100), "
72						+ "style varchar(100), "
73						+ "priority varchar(100), "
74						+ "a BOOLEAN NOT NULL DEFAULT FALSE, "
75						+ "rdy BOOLEAN NOT NULL DEFAULT FALSE, "
76						+ "PRIMARY KEY (uid));");
77			} catch (SQLException e) {
78				e.printStackTrace();
79			}
80		}
81
82	}
83
84	public static void update(String qry) {
85		if (isConnected()) {
86			try {
87				con.createStatement().executeUpdate(qry);
88			} catch (SQLException e) {
89				e.printStackTrace();
90			}
91		}
92	}
93
94	public static ResultSet getResult(String qry) {
95		if (isConnected()) {
96			try {
97				return con.createStatement().executeQuery(qry);
98			} catch (SQLException e) {
99				e.printStackTrace();
100			}
101		}
102		return null;
103	}
104}
105