Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package net.myzickzack;
- import java.io.File;
- import java.sql.ResultSet;
- import java.sql.SQLException;
- import org.bukkit.Bukkit;
- import org.bukkit.configuration.file.FileConfiguration;
- import org.bukkit.configuration.file.YamlConfiguration;
- import org.bukkit.event.EventHandler;
- import org.bukkit.event.Listener;
- import org.bukkit.event.player.AsyncPlayerPreLoginEvent;
- import org.bukkit.plugin.java.JavaPlugin;
- public class Main extends JavaPlugin implements Listener {
- private static Main plugin;
- public static MySQL mysql;
- public void onEnable() {
- plugin = this;
- getCommand("coins").setExecutor(new Coins());
- Bukkit.getPluginManager().registerEvents(this, this);
- loadConfig();
- // ConnectMySQL();
- }
- public void loadConfig() {
- File file = new File("plugins//CoinsAPI//config.yml");
- FileConfiguration cfg = this.getConfig();
- if (!file.exists()) {
- cfg.addDefault("mysql.host", "HOST");
- cfg.addDefault("mysql.port", Integer.valueOf(3306));
- cfg.addDefault("mysql.user", "USER");
- cfg.addDefault("mysql.password", "PASSWORD");
- cfg.addDefault("mysql.database", "Coins");
- cfg.options().copyDefaults(true);
- saveConfig();
- }
- }
- public void onDisable() {
- }
- public void ConnectMySQL() {
- File file = new File("plugins//CoinsAPI//config.yml");
- FileConfiguration mcfg = YamlConfiguration.loadConfiguration(file);
- if (file.exists()) {
- String host = mcfg.getString("mysql.host");
- String database = mcfg.getString("mysql.database");
- String user = mcfg.getString("mysql.user");
- String password = mcfg.getString("mysql.password");
- mysql = new MySQL(host, database, user, password);
- mysql.connect();
- mysql.update("CREATE TABLE IF NOT EXISTS coins(name varchar(100) UNIQUE, coins int)");
- Bukkit.broadcastMessage("VERBINDUNG IZ DA");
- } else {
- loadConfig();
- System.out.println("Verbindung konnte nicht hergestellt werden!");
- }
- }
- public static int getCoins(String name) {
- ResultSet rs = Main.mysql.query("SELECT coins FROM coins WHERE name = '" + name + "' LIMIT 1");
- try {
- while (rs.next()) {
- return rs.getInt("coins");
- }
- } catch (SQLException e) {
- }
- return -1;
- }
- public static void setCoins(String name, int amount) {
- Main.mysql.update("UPDATE coins SET coins = " + amount + " WHERE name = '" + name + "'");
- }
- public static boolean isRegistered(String name) {
- ResultSet rs = Main.mysql.query("SELECT * FROM coins WHERE name = '" + name + "' LIMIT 1");
- System.out.println(rs == null);
- try {
- return rs.next();
- } catch (SQLException e) {
- }
- return false;
- }
- public static void register(String name) {
- Main.mysql.update("INSERT INTO coins (name, coins) VALUES ('" + name + "', 0)");
- }
- public static Main getPlugin() {
- return plugin;
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement