Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package me.guihsilva.nextskyshop.database;
- import java.sql.Connection;
- import java.sql.DriverManager;
- import java.sql.ResultSet;
- import java.sql.SQLException;
- import java.sql.Statement;
- import me.guihsilva.nextskyshop.NextSkyShop;
- public class MySQL {
- private static Connection conn;
- private static String user_a;
- private static String pass_a;
- private static String database_a;
- private static String adress_a;
- private static int port_a;
- public void host(String user, String pass, String database, String adress, int port) {
- user_a = user;
- pass_a = pass;
- database_a = database;
- adress_a = adress;
- port_a = port;
- }
- public static Connection conectar() {
- String conection = "jdbc:mysql://" + adress_a + ":" + port_a + "/" + database_a;
- String user = user_a;
- String pass = pass_a;
- try {
- conn = DriverManager.getConnection(conection, user, pass);
- Statement st = conn.createStatement();
- st.executeUpdate("CREATE TABLE IF NOT EXISTS `lojas` (id INT NOT NULL AUTO_INCREMENT PRIMARY KEY, `jogador` VARCHAR(32) NOT NULL, `local` VARCHAR(200), `status` BOOLEAN, `visitas` DOUBLE);");
- st.executeUpdate("CREATE TABLE IF NOT EXISTS `jogadores` (id INT NOT NULL AUTO_INCREMENT PRIMARY KEY, `jogador` VARCHAR(32) NOT NULL, `recompensas` TEXT, `fertilizar` LONG, `money` BOOLEAN, `chatglobal` BOOLEAN, `recebertpa` BOOLEAN, `recebertell` BOOLEAN, `chatcolor` VARCHAR(2), `registro` LONG, `tag_id` VARCHAR(64));");
- st.executeUpdate("CREATE TABLE IF NOT EXISTS `staff_reputacao` (id INT NOT NULL AUTO_INCREMENT PRIMARY KEY, `jogador` VARCHAR(32) NOT NULL, `positivo` BIGINT, `negativo` BIGINT);");
- NextSkyShop.print("MySQL conectado!!");
- } catch (SQLException e) {
- e.printStackTrace();
- NextSkyShop.print("§cHouve um erro SQL ao conectar-se com o MYSQL, erro: " + e);
- return null;
- }
- return null;
- }
- public static boolean isConnected() {
- boolean available = false;
- if (conn != null) {
- Statement stmt = null;
- ResultSet rs = null;
- try {
- stmt = conn.createStatement();
- rs = stmt.executeQuery("SELECT 1");
- available = true;
- } catch (SQLException e) {
- available = false;
- } finally {
- try {
- if (stmt != null) {
- stmt.close();
- }
- if (rs != null) {
- rs.close();
- }
- } catch (SQLException e) {
- NextSkyShop.print("§cErro ao fechar o statement/result set: " + e);
- }
- rs = null;
- stmt = null;
- }
- }
- return available;
- }
- public static Connection getConn() {
- if (conn == null || !isConnected()) {
- NextSkyShop.print("§cFoi detectado uma conexao invalida ao tentar consultar um dado, tentando reconectar com o banco...");
- conn = null;
- conectar();
- }
- return conn;
- }
- public static void disconnect() {
- conn = null;
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement