· 6 years ago · Jul 12, 2019, 11:50 AM
1package me.DoorMatt47.pBowTp;
2import java.sql.Connection;
3import java.sql.DriverManager;
4import java.sql.PreparedStatement;
5import java.sql.ResultSet;
6import java.sql.Statement;
7
8public class MySQL {
9
10 private Connection conn;
11 private Statement statmt;
12 private PreparedStatement preparedStatement = null;
13
14 public MySQL(String url, String dbName, String user, String pass) {
15 try {
16 Class.forName("com.mysql.jdbc.Driver");
17 conn = DriverManager.getConnection(
18 "jdbc:mysql://" + url + "/" + dbName + "?useUnicode=true&characterEncoding=utf8&autoReconnect=true",user, pass);
19 statmt = conn.createStatement();
20 statmt.execute(
21 "CREATE TABLE IF NOT EXISTS `users_trails` (`user` varchar(16) PRIMARY KEY,"
22 + "`TRAILS` varchar(32) NOT NULL)");
23 Utils.sendMesSucc();
24 } catch (Exception e) {
25 Utils.sendMesWarn();;
26 }
27 }
28
29 public void insert(String user, String TRAILS) {
30 try {
31 PreparedStatement e = conn.prepareStatement(
32 "INSERT INTO users_trails (user,TRAILS) VALUES (?,?) ON DUPLICATE KEY UPDATE TRAILS = ?;");
33 e.setString(1, user);
34 e.setString(2, TRAILS);
35 e.setString(3, TRAILS);
36 e.executeUpdate();
37 } catch (Exception e) {
38 e.printStackTrace();
39 }
40 }
41
42 public String select(String user) {
43 try(PreparedStatement prStat =
44 conn.prepareStatement("SELECT TRAILS FROM users_trails WHERE user = ?;");
45 ResultSet e = preparedStatement.executeQuery();) {
46 prStat.setString(1, user);
47 String trailss = new String();
48 if (e.next()) {
49 trailss = e.getString("TRAILS");
50 e.close();
51 return trailss;
52 }
53 } catch (Exception e) {
54 e.printStackTrace();
55 }
56 return null;
57 }
58}