Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- /*
- *
- * MYSQL Class
- *
- */
- package MYSQL;
- import java.sql.Connection;
- import java.sql.DriverManager;
- import java.sql.ResultSet;
- import java.sql.SQLException;
- import java.sql.Statement;
- import org.bukkit.Bukkit;
- public class MySQL {
- private String host = "host";
- private String user = "username";
- private String pass = "password";
- private String database;
- private Connection con;
- public MySQL(String database) {
- this.database = database;
- connect();
- Bukkit.getScheduler().runTaskAsynchronously(API.getAPI(), new Runnable() {
- @Override
- public void run() {
- createTable();
- }
- });
- }
- public void connect() {
- if (!isConnected()) {
- try {
- con = DriverManager.getConnection("jdbc:mysql://" + getHost() + ":3306/" + getDatabase(), getUser(), getPass());
- } catch (SQLException e) {
- e.printStackTrace();
- }
- }
- }
- public void close() {
- if (isConnected()) {
- try {
- con.close();
- } catch (SQLException e) {
- e.printStackTrace();
- }
- }
- }
- public boolean isConnected() {
- return con != null;
- }
- public void createTable() {
- if (isConnected()) {
- try {
- con.createStatement().executeUpdate(
- "CREATE TABLE IF NOT EXISTS coins(id int NOT NULL AUTO_INCREMENT PRIMARY KEY, UUID varchar(100), NAME varchar(100), Coins varchar(100));");
- } catch (SQLException e) {
- e.printStackTrace();
- }
- }
- }
- public String getHost() {
- return host;
- }
- public String getUser() {
- return user;
- }
- public String getPass() {
- return pass;
- }
- public String getDatabase() {
- return database;
- }
- public void query(String qry) {
- if (isConnected()) {
- try {
- con.createStatement().executeUpdate(qry);
- } catch (SQLException e) {
- e.printStackTrace();
- }
- }
- }
- public ResultSet getResult(String qry) {
- ResultSet rs = null;
- try {
- Statement st = con.createStatement();
- rs = st.executeQuery(qry);
- } catch (SQLException e) {
- connect();
- System.err.println(e);
- }
- return rs;
- }
- }
- /*
- *
- * Stats Class
- *
- */
- package net.SpielBuildAPI;
- import java.sql.ResultSet;
- import java.util.UUID;
- import org.bukkit.entity.Player;
- public class Stats {
- private MySQL mysql;
- public Stats() {
- mysql = new MySQL("kd24963_server");
- };
- public void createAccount(Player p) {
- boolean exist = false;
- try {
- ResultSet rs = mysql.getResult("SELECT Coins FROM coins WHERE UUID='" + p.getUniqueId().toString() + "';");
- while (rs.next()) {
- exist = Boolean.valueOf(true).booleanValue();
- }
- } catch (Exception err) {
- System.err.println(err);
- }
- if (!exist) {
- mysql.query("INSERT INTO coins (UUID,NAME,Coins) values ('" + p.getUniqueId().toString() + "', '"+p.getName()+"', 0);");
- }
- }
- public int getCoins(Player p) {
- int c = 0;
- try {
- java.sql.ResultSet rs = mysql
- .getResult("SELECT Coins FROM coins WHERE UUID='" + p.getUniqueId().toString() + "';");
- while (rs.next()) {
- c = rs.getInt(1);
- }
- } catch (Exception err) {
- System.err.println(err);
- }
- return c;
- }
- public void addCoins(Player p, int add) {
- int c = getCoins(p);
- c += add;
- mysql.query("UPDATE coins SET Coins = " + c + " WHERE UUID='" + p.getUniqueId().toString() + "';");
- }
- public void removeCoins(Player p, int del) {
- int c = getCoins(p);
- c -= del;
- mysql.query("UPDATE coins SET Coins = " + c + " WHERE UUID='" + p.getUniqueId().toString() + "';");
- }
- public void setCoins(Player p, int coins) {
- mysql.query("UPDATE coins SET Coins = " + coins + " WHERE UUID='" + p.getUniqueId().toString() + "';");
- }
- public void createAccount(UUID uuid, String name) {
- boolean exist = false;
- try {
- ResultSet rs = mysql.getResult("SELECT Coins FROM coins WHERE UUID='" + uuid.toString() + "';");
- while (rs.next()) {
- exist = Boolean.valueOf(true).booleanValue();
- }
- } catch (Exception err) {
- System.err.println(err);
- }
- if (!exist) {
- mysql.query("INSERT INTO coins (UUID,NAME,Coins) values ('" + uuid.toString() + "', '"+name+"', 0);");
- }
- }
- public int getCoins(UUID uuid) {
- int c = 0;
- try {
- java.sql.ResultSet rs = mysql
- .getResult("SELECT Coins FROM coins WHERE UUID='" + uuid.toString() + "';");
- while (rs.next()) {
- c = rs.getInt(1);
- }
- } catch (Exception err) {
- System.err.println(err);
- }
- return c;
- }
- public void addCoins(UUID uuid, int add) {
- int c = getCoins(uuid);
- c += add;
- mysql.query("UPDATE coins SET Coins = " + c + " WHERE UUID='" + uuid.toString() + "';");
- }
- public void removeCoins(UUID uuid, int del) {
- int c = getCoins(uuid);
- c -= del;
- mysql.query("UPDATE coins SET Coins = " + c + " WHERE UUID='" + uuid.toString() + "';");
- }
- public void setCoins(UUID uuid, int coins) {
- mysql.query("UPDATE coins SET Coins = " + coins + " WHERE UUID='" + uuid.toString() + "';");
- }
- public int getCoins(String name) {
- int c = 0;
- try {
- java.sql.ResultSet rs = mysql
- .getResult("SELECT Coins FROM coins WHERE NAME='" + name + "';");
- while (rs.next()) {
- c = rs.getInt(1);
- }
- } catch (Exception err) {
- System.err.println(err);
- }
- return c;
- }
- public void addCoins(String name, int add) {
- int c = getCoins(name);
- c += add;
- mysql.query("UPDATE coins SET Coins = " + c + " WHERE NAME='" + name + "';");
- }
- public void removeCoins(String name, int del) {
- int c = getCoins(name);
- c -= del;
- mysql.query("UPDATE coins SET Coins = " + c + " WHERE NAME='" + name + "';");
- }
- public void setCoins(String name, int coins) {
- mysql.query("UPDATE coins SET Coins = " + coins + " WHERE NAME='" + name + "';");
- }
- }
- /*
- *
- * Aufrufen! z.b. in der Main
- *
- */
- private static Stats stats;
- public static Stats getStats() {
- return stats;
- }
- @Override
- public void onEnable() {
- stats = new Stats();
- }
- /*
- *
- * Verwenden BITTE ASYNC
- *
- */
- Main.getStats().getCoins(Player);
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement