Advertisement
Guest User

Untitled

a guest
Dec 5th, 2016
80
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 2.99 KB | None | 0 0
  1. SqlConnection
  2.  
  3.  
  4. public SqlConnection(String urlbase, String host, String database, String user, String pass) {
  5. this.urlbase = urlbase;
  6. this.host = host;
  7. this.database = database;
  8. this.user = user;
  9. this.pass = pass;
  10.  
  11. }
  12.  
  13. public void connection() {
  14. if (isConnected()) {
  15. try {
  16. connection = DriverManager.getConnection(urlbase + host + "/" + database, user, pass);
  17. System.out.println("connected ok");
  18. } catch (SQLException e) {
  19. e.printStackTrace();
  20. }
  21. }
  22. }
  23.  
  24. public void disconnect() {
  25. if (isConnected()) {
  26. }
  27. try {
  28. connection.close();
  29. System.out.println("connected off");
  30. } catch (SQLException e) {
  31. e.printStackTrace();
  32. }
  33. }
  34.  
  35. public boolean isConnected() {
  36. return connection != null;
  37. }
  38.  
  39. public void createAccount(Player player) {
  40. if (!hasAccount(player)) {
  41. // INSERT
  42.  
  43. try {
  44. PreparedStatement q = connection
  45. .prepareStatement("INSERT INTO joueurs(uuid,coins,grade) VALUES (?,?,?)");
  46. q.setString(1, player.getUniqueId().toString());
  47. q.setInt(2, 100);
  48. q.setString(3, "joueur");
  49. q.execute();
  50. q.close();
  51. } catch (SQLException e) {
  52. e.printStackTrace();
  53. }
  54.  
  55. }
  56. }
  57.  
  58. public boolean hasAccount(Player player) {
  59. // SELECT
  60.  
  61. try {
  62. PreparedStatement q = connection.prepareStatement("SELECT uuid FROM joueurs WHERE uuid = ?");
  63. q.setString(1, player.getUniqueId().toString());
  64. ResultSet resultat = q.executeQuery();
  65. boolean hasAccount = resultat.next();
  66. q.close();
  67. return hasAccount;
  68. } catch (SQLException e) {
  69. e.printStackTrace();
  70. }
  71.  
  72. return false;
  73. }
  74.  
  75. public int getBalance(Player player) {
  76. // SELECT
  77.  
  78. try {
  79. PreparedStatement q = connection.prepareStatement("SELECT coins FROM joueurs WHERE uuid = ?");
  80. q.setString(1, player.getUniqueId().toString());
  81.  
  82. int balance = 0;
  83. ResultSet rs = q.executeQuery();
  84.  
  85. while (rs.next()) {
  86. balance = rs.getInt("coins");
  87. }
  88.  
  89. q.close();
  90.  
  91. return balance;
  92.  
  93. } catch (SQLException e) {
  94. e.printStackTrace();
  95. }
  96.  
  97. return 0;
  98. }
  99.  
  100. public void addMoney(Player player, int amount) {
  101. // UPDATE
  102.  
  103. int balance = getBalance(player);
  104. int newbalance = balance + amount;
  105.  
  106. try {
  107. PreparedStatement rs = connection.prepareStatement("UPDATE joueurs SET coins = ? WHERE uuid = ?");
  108. rs.setInt(1, newbalance);
  109. rs.setString(2, player.getUniqueId().toString());
  110. rs.executeUpdate();
  111. rs.close();
  112.  
  113. } catch (SQLException e) {
  114. e.printStackTrace();
  115. }
  116.  
  117. }
  118.  
  119. public void removeMoney(Player player, int amount) {
  120. // UPDATE
  121.  
  122. int balance = getBalance(player);
  123. int newbalance = balance - amount;
  124.  
  125. if (newbalance <= 0) {
  126. return;
  127. }
  128.  
  129. try {
  130. PreparedStatement rs = connection.prepareStatement("UPDATE joueurs SET coins = ? WHERE uuid = ?");
  131. rs.setInt(1, newbalance);
  132. rs.setString(2, player.getUniqueId().toString());
  133. rs.executeUpdate();
  134. rs.close();
  135.  
  136. } catch (SQLException e) {
  137. e.printStackTrace();
  138. }
  139. }
  140. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement