Advertisement
Guest User

Untitled

a guest
Jul 17th, 2018
94
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 8.92 KB | None | 0 0
  1. package net.heartnetwork.hubplugin;
  2.  
  3. import org.bukkit.entity.Player;
  4.  
  5. import java.sql.*;
  6.  
  7. public class SqlConnection {
  8.  
  9.     private Connection connection;
  10.     private String urlbase,host,database,user,pass;
  11.  
  12.     public SqlConnection(String urlbase, String host, String database, String user, String pass) {
  13.         this.urlbase = urlbase;
  14.         this.host = host;
  15.         this.database = database;
  16.         this.user = user;
  17.         this.pass = pass;
  18.     }
  19.  
  20.     public void connection(){
  21.         if(!isConnected()){
  22.             try {
  23.                 connection = DriverManager.getConnection(urlbase + host + "/" + database, user, pass);
  24.                 System.out.println("connected ok");
  25.             } catch (SQLException e) {
  26.                 e.printStackTrace();
  27.             }
  28.         }
  29.     }
  30.  
  31.     public void disconnect(){
  32.         if(isConnected()){
  33.             try {
  34.                 connection.close();
  35.                 System.out.println("connected off");
  36.             } catch (SQLException e) {
  37.                 e.printStackTrace();
  38.             }
  39.         }
  40.     }
  41.  
  42.     public void removeRank(String player){
  43.  
  44.         try {
  45.             PreparedStatement rs = connection.prepareStatement("DELETE FROM custom_rank WHERE player = ?");
  46.             rs.setString(1, player);
  47.             rs.executeUpdate();
  48.             rs.close();
  49.  
  50.         } catch (SQLException e) {
  51.             e.printStackTrace();
  52.         }
  53.  
  54.     }
  55.  
  56.     public void setRank(String player, String pseudo, String prefix){
  57.  
  58.         try {
  59.             PreparedStatement rs = connection.prepareStatement("INSERT INTO custom_rank(player,pseudo,prefix) VALUES (?,?,?)");
  60.             rs.setString(1, player);
  61.             rs.setString(2, pseudo);
  62.             rs.setString(3, prefix);
  63.             rs.execute();
  64.             rs.close();
  65.  
  66.         } catch (SQLException e) {
  67.             e.printStackTrace();
  68.         }
  69.  
  70.     }
  71.  
  72.     public String getPseudo(Player player){
  73.         //SELECT
  74.  
  75.         try {
  76.             PreparedStatement q = connection.prepareStatement("SELECT pseudo FROM custom_rank WHERE player = ?");
  77.             q.setString(1, player.getName());
  78.             ResultSet resultat = q.executeQuery();
  79.  
  80.             String pseudo = null;
  81.             while(resultat.next()){
  82.                 pseudo = resultat.getString("pseudo");
  83.  
  84.             }
  85.  
  86.  
  87.             q.close();
  88.             return pseudo;
  89.         } catch (SQLException e) {
  90.             e.printStackTrace();
  91.         }
  92.  
  93.         return "";
  94.     }
  95.  
  96.     public String getPrefix(Player player){
  97.         //SELECT
  98.  
  99.         try {
  100.             PreparedStatement q = connection.prepareStatement("SELECT prefix FROM custom_rank WHERE player = ?");
  101.             q.setString(1, player.getName());
  102.             ResultSet resultat = q.executeQuery();
  103.  
  104.             String prefix = null;
  105.             while(resultat.next()){
  106.                 prefix = resultat.getString("prefix");
  107.  
  108.             }
  109.  
  110.  
  111.             q.close();
  112.             return prefix;
  113.         } catch (SQLException e) {
  114.             e.printStackTrace();
  115.         }
  116.  
  117.         return "";
  118.     }
  119.  
  120.     public void updateRank(String player, String pseudo, String prefix){
  121.  
  122.  
  123.         try {
  124.             PreparedStatement rs = connection.prepareStatement("UPDATE custom_rank SET pseudo = ?, prefix = ? WHERE player = ?");
  125.             rs.setString(1, pseudo);
  126.             rs.setString(2, prefix);
  127.             rs.setString(3, player);
  128.             rs.executeUpdate();
  129.             rs.close();
  130.  
  131.         } catch (SQLException e) {
  132.             e.printStackTrace();
  133.         }
  134.  
  135.     }
  136.  
  137.     public void createAccount(String player, int coins){
  138.  
  139.         try {
  140.             PreparedStatement rs = connection.prepareStatement("INSERT INTO coins(player,coins) VALUES (?,?)");
  141.             rs.setString(1, player);
  142.             rs.setInt(2, coins);
  143.             rs.execute();
  144.             rs.close();
  145.  
  146.         } catch (SQLException e) {
  147.             e.printStackTrace();
  148.         }
  149.  
  150.     }
  151.  
  152.     public void createBooster(String player, int booster){
  153.  
  154.         try {
  155.             PreparedStatement rs = connection.prepareStatement("INSERT INTO boosters_players(player,booster) VALUES (?,?)");
  156.             rs.setString(1, player);
  157.             rs.setInt(2, booster);
  158.             rs.execute();
  159.             rs.close();
  160.  
  161.         } catch (SQLException e) {
  162.             e.printStackTrace();
  163.         }
  164.  
  165.     }
  166.  
  167.     public void addBooster(String player, int booster){
  168.  
  169.  
  170.         try {
  171.  
  172.             int balance = (getBooster(player) + booster);
  173.  
  174.             PreparedStatement rs = connection.prepareStatement("UPDATE boosters_players SET booster = ? WHERE player = ?");
  175.             rs.setInt(1, balance);
  176.             rs.setString(2, player);
  177.             rs.executeUpdate();
  178.             rs.close();
  179.  
  180.         } catch (SQLException e) {
  181.             e.printStackTrace();
  182.         }
  183.  
  184.     }
  185.  
  186.     public void removeBooster(String player, int booster){
  187.  
  188.  
  189.         try {
  190.  
  191.             int balance = (getBooster(player) - booster);
  192.  
  193.             PreparedStatement rs = connection.prepareStatement("UPDATE boosters_players SET booster = ? WHERE player = ?");
  194.             rs.setInt(1, balance);
  195.             rs.setString(2, player);
  196.             rs.executeUpdate();
  197.             rs.close();
  198.  
  199.         } catch (SQLException e) {
  200.             e.printStackTrace();
  201.         }
  202.  
  203.     }
  204.  
  205.     public int getBooster(String player){
  206.         //SELECT
  207.  
  208.         try {
  209.             PreparedStatement q = connection.prepareStatement("SELECT booster FROM boosters_players WHERE player = ?");
  210.             q.setString(1, player);
  211.             ResultSet resultat = q.executeQuery();
  212.  
  213.             int coins = 0;
  214.             while(resultat.next()){
  215.                 coins = resultat.getInt("booster");
  216.  
  217.             }
  218.  
  219.  
  220.             q.close();
  221.             return coins;
  222.         } catch (SQLException e) {
  223.             e.printStackTrace();
  224.         }
  225.  
  226.         return 0;
  227.     }
  228.  
  229.     public boolean hasBooster(String player){
  230.  
  231.         try {
  232.             PreparedStatement q = connection.prepareStatement("SELECT player FROM boosters_players WHERE player = ?");
  233.             q.setString(1, player);
  234.             ResultSet resultat = q.executeQuery();
  235.             boolean hasCoins = resultat.next();
  236.             q.close();
  237.             return hasCoins;
  238.         } catch (SQLException e) {
  239.             e.printStackTrace();
  240.         }
  241.  
  242.         return false;
  243.  
  244.     }
  245.  
  246.     public void addCoins(String player, int coins){
  247.  
  248.  
  249.         try {
  250.  
  251.             int balance = (getCoins(player) + coins);
  252.  
  253.             PreparedStatement rs = connection.prepareStatement("UPDATE coins SET coins = ? WHERE player = ?");
  254.             rs.setInt(1, balance);
  255.             rs.setString(2, player);
  256.             rs.executeUpdate();
  257.             rs.close();
  258.  
  259.         } catch (SQLException e) {
  260.             e.printStackTrace();
  261.         }
  262.  
  263.     }
  264.  
  265.     public void removeCoins(String player, int coins){
  266.  
  267.  
  268.         try {
  269.  
  270.             int balance = (getCoins(player) - coins);
  271.  
  272.             PreparedStatement rs = connection.prepareStatement("UPDATE coins SET coins = ? WHERE player = ?");
  273.             rs.setInt(1, balance);
  274.             rs.setString(2, player);
  275.             rs.executeUpdate();
  276.             rs.close();
  277.  
  278.         } catch (SQLException e) {
  279.             e.printStackTrace();
  280.         }
  281.  
  282.     }
  283.  
  284.     public int getCoins(String player){
  285.         //SELECT
  286.  
  287.         try {
  288.             PreparedStatement q = connection.prepareStatement("SELECT coins FROM coins WHERE player = ?");
  289.             q.setString(1, player);
  290.             ResultSet resultat = q.executeQuery();
  291.  
  292.             int coins = 0;
  293.             while(resultat.next()){
  294.                 coins = resultat.getInt("coins");
  295.  
  296.             }
  297.  
  298.  
  299.             q.close();
  300.             return coins;
  301.         } catch (SQLException e) {
  302.             e.printStackTrace();
  303.         }
  304.  
  305.         return 0;
  306.     }
  307.  
  308.     public boolean hasCoins(String player){
  309.  
  310.         try {
  311.             PreparedStatement q = connection.prepareStatement("SELECT player FROM coins WHERE player = ?");
  312.             q.setString(1, player);
  313.             ResultSet resultat = q.executeQuery();
  314.             boolean hasCoins = resultat.next();
  315.             q.close();
  316.             return hasCoins;
  317.         } catch (SQLException e) {
  318.             e.printStackTrace();
  319.         }
  320.  
  321.         return false;
  322.  
  323.     }
  324.  
  325.     public boolean hasAccount(String player){
  326.         //SELECT
  327.  
  328.         try {
  329.             PreparedStatement q = connection.prepareStatement("SELECT player FROM custom_rank WHERE player = ?");
  330.             q.setString(1, player);
  331.             ResultSet resultat = q.executeQuery();
  332.             boolean hasAccount = resultat.next();
  333.             q.close();
  334.             return hasAccount;
  335.         } catch (SQLException e) {
  336.             e.printStackTrace();
  337.         }
  338.  
  339.         return false;
  340.     }
  341.  
  342.  
  343.     public boolean isConnected(){
  344.         return connection != null;
  345.     }
  346.  
  347. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement