FAGGOT

package server.util;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.DriverManager;
import server.model.players.Client;
import server.Server;
import java.io.File;
import java.io.FileWriter;
import java.io.IOException;
import java.util.Date;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import server.Config;
import server.model.players.PlayerHandler;
import java.util.Date;
import java.util.Calendar;
import server.model.items.*;

import server.Config;
import server.Server;
import server.model.npcs.NPCHandler;
import server.util.Misc;
import server.event.*;
import server.model.players.*;


/**
 *
 * @author Ramatronics
 */
public class SQLConnection {

    public String host, database, username, password;
    public Connection conn;
    public Statement statement;
    public ResultSet results;
    public boolean connected;

    public SQLConnection() {

        host = "64.237.33.228:3306";
        database = "devdatas_rspsf";
        username = "devdatas_hs";
        password = "mywayhosting1";

        connected = false;

    }

    public Connection getConnection() {
        return conn;
    }

    public void CreateConnection() {
        try {
            if (conn == null) {
                Class.forName("com.mysql.jdbc.Driver").newInstance();

                this.conn = DriverManager.getConnection(
                        "jdbc:mysql://" + host
                        + "/" + database + "", username, password);

                System.out.println("MySQL Connection Established");
                connected = true;
                this.statement = this.getConnection().createStatement();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }

    }

    public ResultSet query(String s) throws SQLException {
        try {
if (statement == null || statement.isClosed()) {
    conn.close();
    statement = getConnection().createStatement();

}
            if (s.toLowerCase().startsWith("select")) {

                ResultSet rs = statement.executeQuery(s);
                return rs;
            } else {
                statement.executeUpdate(s);
            }
            return null;

        } catch (Exception e) {
                    conn.close();
                    CreateConnection();

            System.out.println("[ATTENTION]: ERROR OCCURED WITH MYSQL QUERY \n \t" + e.toString() + " \nEND OF ERROR!");
            System.out.println(s);
            //e.printStackTrace();
        }
        return null;
    }

    public boolean CheckBAN(Client c) {
        try{
         String query = "SELECT * FROM `bans` WHERE (`username` = '" + c.playerName + "') OR "
                 + "(`ip` = '" + c.connectedFrom + "')";
            ResultSet results = statement.executeQuery(query);
            while (results.next()) {
                return true;
            }
            results.close();
            return false;
        }catch(Exception e){
            //e.printStackTrace();
            return false;
        }
    }

         public boolean itemlog(String player, String action, String item, int itemid, int x, int y, int amt){
    System.out.print(getConnection());


            try {
query("INSERT INTO `server_itemlogs` (`player`, `action`, `item`, `itemid`, `x`, `y`, `Amount`) "
                        + "VALUES ('"+player+"', '" + action + "', '" + item + "', '" + itemid + "', '" + x + "','" + y + "','" + amt + "');");

                return true;
            } catch (Exception e) {

                return false;
         }
    }

             public boolean commandlog(String player, String command, String args){
    System.out.print(getConnection());


            try {
query("INSERT INTO `server_commandlogs` (`player`, `command`, parameters) "
                        + "VALUES ('"+player+"', '" + command + "', '" + args + "');");

                return true;
            } catch (Exception e) {

                return false;
         }
    }





     public boolean chatlogs(String player, String data){
    String result = data.replaceAll("[^\\p{L}\\p{Z}]","");
    System.out.print(getConnection());


            try {
query("INSERT INTO `server_chatlogs` (`player`, `text`) "
                        + "VALUES ('"+player+"','" + result + "');");

                return true;
            } catch (Exception e) {

                return false;
            }
    }
}