· 8 years ago · Feb 25, 2018, 04:22 PM
1package de.fphil.beastapi.MySQL;
2
3import java.sql.Connection;
4import java.sql.DriverManager;
5import java.sql.ResultSet;
6import java.sql.SQLException;
7import java.sql.Statement;
8
9public class MySQLManager {
10
11 private static Connection con;
12
13 public static boolean isConnected ( ) {
14 return con != null;
15 }
16
17 private static String host = "play.cleanbeasts.net";
18 private static String port = "3306";
19 private static String database = "papamama";
20 private static String username = "papamama";
21 private static String password = "papamama";
22
23 public static void connect ( ) {
24 if ( ! isConnected ( ) ) {
25 try {
26 con = DriverManager.getConnection ( "jdbc:mysql://" +
27 host + ":" + port + "/" + database + "?autoReconnect=true" , username ,
28 password );
29 System.out.println ( "CONNECTED" );
30 } catch ( SQLException ex ) {
31 ex.printStackTrace ( );
32 }
33 }
34 }
35
36 public static void disconnect ( ) {
37 try {
38 if ( con != null ) {
39 con.close ( );
40 System.out.println ( "DISCONNECT" );
41 }
42 } catch ( SQLException ex ) {
43 ex.printStackTrace ( );
44 }
45 }
46
47 public static void update ( String qry ) {
48 try {
49 Statement st = con.createStatement ( );
50 st.executeUpdate ( qry );
51 st.close ( );
52 } catch ( SQLException ex ) {
53 connect ( );
54 ex.printStackTrace ( );
55 }
56 }
57
58 public static ResultSet query ( String qry ) {
59 ResultSet rs = null;
60 try {
61 Statement st = con.createStatement ( );
62 rs = st.executeQuery ( qry );
63 } catch ( SQLException ex ) {
64 connect ( );
65 ex.printStackTrace ( );
66 }
67 return rs;
68 }
69
70 public static void createTable ( String table , String data ) {
71 update ( "CREATE TABLE IF NOT EXISTS " + table + "(" + data + ");" );
72 }
73}