Advertisement
Guest User

SQL

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