Advertisement
Guest User

MySQL Integration

a guest
Jan 18th, 2017
133
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 3.17 KB | None | 0 0
  1. package me.bradley.TestingMySQL;
  2.  
  3. import java.sql.Connection;
  4. import java.sql.DriverManager;
  5. import java.sql.PreparedStatement;
  6. import java.sql.ResultSet;
  7. import java.sql.SQLException;
  8. import java.util.ArrayList;
  9. import java.util.List;
  10.  
  11. import org.bukkit.entity.Player;
  12. import org.bukkit.event.EventHandler;
  13. import org.bukkit.event.Listener;
  14. import org.bukkit.event.player.PlayerJoinEvent;
  15. import org.bukkit.plugin.java.JavaPlugin;
  16. import org.bukkit.scheduler.BukkitRunnable;
  17.  
  18. public class Core extends JavaPlugin implements Listener {
  19.  
  20. Connection connection;
  21.  
  22. private Core plugin;
  23. private String username = "sql8154449";
  24. private String password = "hGEl3P6H7K";
  25.  
  26. public void onEnable() {
  27. getServer().getPluginManager().registerEvents(this, this);
  28. plugin = this;
  29. printData();
  30. }
  31.  
  32. private void printData() {
  33. new BukkitRunnable() {
  34. @Override
  35. public void run() {
  36. openConnection();
  37.  
  38. List<String> temp = getNameColumn("name");
  39.  
  40. new BukkitRunnable() {
  41. @Override
  42. public void run() {
  43. if (!temp.isEmpty()) {
  44. for (String name : temp) {
  45. System.out.println("I found the name: " + name);
  46. }
  47. } else {
  48. System.out.println("There were no names :(");
  49. }
  50. }
  51. }.runTask(plugin);
  52. }
  53. }.runTaskAsynchronously(this);
  54. }
  55.  
  56. public synchronized void openConnection() {
  57. try {
  58. connection = DriverManager.getConnection("jdbc:mysql://sql8.freemysqlhosting.net:3306/sql8154449", username,
  59. password);
  60. } catch (SQLException e) {
  61. e.printStackTrace();
  62. }
  63. }
  64.  
  65. public boolean containsElement(String field, String element) {
  66. String query = "SELECT `" + field + "` FROM `testing` WHERE `" + field + "`='" + element + "'";
  67.  
  68. try {
  69. ResultSet res = connection.prepareStatement(query).executeQuery();
  70.  
  71. boolean temp = res.next();
  72. res.close();
  73. return temp;
  74.  
  75. } catch (SQLException e) {
  76. e.printStackTrace();
  77. return true;
  78. }
  79. }
  80.  
  81. public void insertElement(String element, String uuid) {
  82. String query = "INSERT INTO `testing` (`name`, `uuid`) VALUES('" + element + "', '" + uuid + "')";
  83. PreparedStatement p;
  84. try {
  85. p = connection.prepareStatement(query);
  86. p.execute();
  87. p.close();
  88. } catch (SQLException e) {
  89. e.printStackTrace();
  90. }
  91. }
  92.  
  93. public List<String> getNameColumn(String columnName) {
  94. List<String> temp = new ArrayList<String>();
  95.  
  96. String query = "SELECT '" + columnName + "' FROM `testing`";
  97.  
  98. try {
  99. ResultSet res = connection.prepareStatement(query).executeQuery();
  100.  
  101. while (res.next()) {
  102. temp.add(res.getString(columnName));
  103. }
  104. res.close();
  105. } catch (SQLException e) {
  106. e.printStackTrace();
  107. }
  108. return temp;
  109. }
  110.  
  111. //testing that it works :)
  112. @EventHandler
  113. public void onJoin(PlayerJoinEvent e) {
  114. Player player = e.getPlayer();
  115. if (containsElement("name", player.getName())) {
  116. player.sendMessage("I have you! Your UUID is: " + player.getUniqueId().toString());
  117. return;
  118. } else {
  119. insertElement(player.getName(), player.getUniqueId().toString());
  120. player.sendMessage("I didn't have you but now I do! Your UUID is: " + player.getUniqueId().toString());
  121. return;
  122. }
  123. }
  124.  
  125. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement