· 6 years ago · Jan 02, 2020, 11:00 PM
1public class MySQL extends JavaPlugin{
2
3 public String databaseName;
4
5 public MySQL(String databaseName) {
6 this.databaseName = databaseName;
7 }
8
9 @Override
10 public void onEnable() {
11 if(!new File(getDataFolder(), "config.yml").exists()) saveDefaultConfig();
12 if(isDisabled()) Bukkit.getPluginManager().disablePlugin(this);
13 }
14
15 public boolean isDisabled() {
16 if(getConfig().getString("mysql").equalsIgnoreCase("false")) {
17 return true;
18 }
19 return false;
20 }
21
22 public void setPlayer(String playerUUID, String target, String targetValue,String tableName) {
23 Connection con = abrirConexao();
24 try {
25 PreparedStatement st = con.prepareStatement
26 ("update "+tableName+" set "+target+" = ? where id = ?");
27 st.setString(1, targetValue);
28 st.setString(2, playerUUID);
29 st.executeUpdate();
30 con.close();
31 } catch (Exception e) {
32 e.printStackTrace();
33 }
34 try {
35 con.close();
36 } catch (SQLException e) {
37 e.printStackTrace();
38 }
39 }
40
41 public void addPlayer(String tableName, String values, String config) {
42 Connection con = abrirConexao();
43 try {
44 PreparedStatement st = con.prepareStatement
45 ("insert into "+tableName+" ("+values+") values ("+config+")");
46 st.executeUpdate();
47 con.close();
48 } catch (Exception e) {
49 e.printStackTrace();
50 }
51 try {
52 con.close();
53 } catch (Exception e) {
54 e.printStackTrace();
55 }
56 }
57
58 public boolean hasPlayer(String tableName, String playerUUID) {
59 Connection con = abrirConexao();
60 try {
61 PreparedStatement st = con.prepareStatement
62 ("select id from "+tableName+" where id=?");
63 st.setString(1, playerUUID);
64 con.close();
65 return st.executeQuery().next();
66 } catch (Exception e) {
67 e.printStackTrace();
68 }
69 try {
70 con.close();
71 } catch (SQLException e) {
72 e.printStackTrace();
73 }
74 return false;
75 }
76
77 public String get(String tableName, String target, String playerUUID) {
78 Connection con = abrirConexao();
79 try {
80 PreparedStatement st = con.prepareStatement
81 ("select "+target+" from "+tableName+" where id=?");
82 st.setString(1, playerUUID);
83 con.close();
84 return String.valueOf(st.executeQuery());
85 } catch (Exception e) {
86 e.printStackTrace();
87 }
88 try {
89 con.close();
90 } catch (SQLException e) {
91 e.printStackTrace();
92 }
93 return null;
94 }
95
96 public void criarTabela(String config, String tableName) {
97 Connection con = abrirConexao();
98 try {
99 PreparedStatement st = con.prepareStatement
100 ("create table if not exists "+tableName.toLowerCase()
101 +"("+config.toLowerCase()+") default charset=utf8;");
102 st.executeUpdate();
103 con.close();
104 } catch (Exception e) {
105 e.printStackTrace();
106 }
107 try {
108 con.close();
109 } catch (SQLException e) {
110 e.printStackTrace();
111 }
112 }
113
114 public Connection abrirConexao() {
115 String host = getConfig().getString("host");
116 String user = getConfig().getString("user");
117 String port = getConfig().getString("port");
118 String password = getConfig().getString("password");
119 String type = "jdbc:mysql://";
120 String url = type+host+":"+port+"/"+databaseName;
121 try {
122 return DriverManager.getConnection(url, user, password);
123 } catch (SQLException e) {
124 e.printStackTrace();
125 }
126 return null;
127 }
128
129 public void criarDatabase() {
130 String host = getConfig().getString("host");
131 String user = getConfig().getString("user");
132 String port = getConfig().getString("port");
133 String password = getConfig().getString("password");
134 String type = "jdbc:mysql://";
135 String url = type+host+":"+port;
136 try {
137 Connection con = DriverManager.getConnection(url, user, password);
138 Statement st = con.createStatement();
139 st.executeUpdate("create database if not exists"+databaseName.toLowerCase());
140 } catch (SQLException e) {
141 e.printStackTrace();
142 }
143 }
144
145}