Advertisement
Guest User

Untitled

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