API tools faq
paste
Advertisement
Guest User

Untitled

a guest
Jul 19th, 2018
94
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 18.46 KB | None | 0 0
raw download clone embed print report
  1. package net.heartnetwork.hubplugin;
  2.  
  3. import org.bukkit.entity.Player;
  4.  
  5.  
  6. import java.sql.*;
  7.  
  8.  
  9. public class SqlConnection {
  10.  
  11.  
  12.     private Connection connection;
  13.     private String urlbase,host,database,user,pass;
  14.  
  15.     public SqlConnection(String urlbase, String host, String database, String user, String pass) {
  16.         this.urlbase = urlbase;
  17.         this.host = host;
  18.         this.database = database;
  19.         this.user = user;
  20.         this.pass = pass;
  21.     }
  22.  
  23.     public void connection(){
  24.         if(!isConnected()){
  25.             try {
  26.                 connection = DriverManager.getConnection(urlbase + host + "/" + database, user, pass);
  27.                 System.out.println("connected ok");
  28.             } catch (SQLException e) {
  29.                 e.printStackTrace();
  30.             }
  31.         }
  32.     }
  33.  
  34.     public void disconnect(){
  35.         if(isConnected()){
  36.             try {
  37.                 connection.close();
  38.                 System.out.println("connected off");
  39.             } catch (SQLException e) {
  40.                 e.printStackTrace();
  41.             }
  42.         }
  43.     }
  44.  
  45.     public void removeRank(String player){
  46.  
  47.         try {
  48.             PreparedStatement rs = connection.prepareStatement("DELETE FROM custom_rank WHERE player = ?");
  49.             rs.setString(1, player);
  50.             rs.executeUpdate();
  51.             rs.close();
  52.  
  53.         } catch (SQLException e) {
  54.             e.printStackTrace();
  55.         }
  56.  
  57.     }
  58.  
  59.     public void setRank(String player, String pseudo, String prefix){
  60.  
  61.         try {
  62.             PreparedStatement rs = connection.prepareStatement("INSERT INTO custom_rank(player,pseudo,prefix) VALUES (?,?,?)");
  63.             rs.setString(1, player);
  64.             rs.setString(2, pseudo);
  65.             rs.setString(3, prefix);
  66.             rs.execute();
  67.             rs.close();
  68.  
  69.         } catch (SQLException e) {
  70.             e.printStackTrace();
  71.         }
  72.  
  73.     }
  74.  
  75.     public String getPseudo(Player player){
  76.         //SELECT
  77.  
  78.         try {
  79.             PreparedStatement q = connection.prepareStatement("SELECT pseudo FROM custom_rank WHERE player = ?");
  80.             q.setString(1, player.getName());
  81.             ResultSet resultat = q.executeQuery();
  82.  
  83.             String pseudo = null;
  84.             while(resultat.next()){
  85.                 pseudo = resultat.getString("pseudo");
  86.  
  87.             }
  88.  
  89.  
  90.             q.close();
  91.             return pseudo;
  92.         } catch (SQLException e) {
  93.             e.printStackTrace();
  94.         }
  95.  
  96.         return "";
  97.     }
  98.  
  99.     public String getPrefix(Player player){
  100.         //SELECT
  101.  
  102.         try {
  103.             PreparedStatement q = connection.prepareStatement("SELECT prefix FROM custom_rank WHERE player = ?");
  104.             q.setString(1, player.getName());
  105.             ResultSet resultat = q.executeQuery();
  106.  
  107.             String prefix = null;
  108.             while(resultat.next()){
  109.                 prefix = resultat.getString("prefix");
  110.  
  111.             }
  112.  
  113.  
  114.             q.close();
  115.             return prefix;
  116.         } catch (SQLException e) {
  117.             e.printStackTrace();
  118.         }
  119.  
  120.         return "";
  121.     }
  122.  
  123.     public int getFFARows(){
  124.  
  125.         try{
  126.  
  127.             PreparedStatement rs = connection.prepareStatement("SELECT COUNT(*) FROM boosters_ffarush");
  128.            ResultSet resultatSet = rs.executeQuery();
  129.  
  130.            resultatSet.next();
  131.            int rows = resultatSet.getInt(1);
  132.            System.out.println(rows);
  133.  
  134.            return rows;
  135.  
  136.         } catch(SQLException e){
  137.  
  138.             e.printStackTrace();
  139.  
  140.         }
  141.  
  142.         return 0;
  143.  
  144.     }
  145.  
  146.     public int getRushRows(){
  147.  
  148.         try{
  149.  
  150.             PreparedStatement rs = connection.prepareStatement("SELECT COUNT(*) FROM boosters_rushbrain");
  151.             ResultSet resultatSet = rs.executeQuery();
  152.  
  153.             resultatSet.next();
  154.             int rows = resultatSet.getInt(1);
  155.             System.out.println(rows);
  156.  
  157.             return rows;
  158.  
  159.         } catch(SQLException e){
  160.  
  161.             e.printStackTrace();
  162.  
  163.         }
  164.  
  165.         return 0;
  166.  
  167.     }
  168.  
  169.     public String getFFAPlayerBoost(){
  170.  
  171.         try{
  172.  
  173.             PreparedStatement rs = connection.prepareStatement("SELECT player FROM boosters_ffarush");
  174.             ResultSet resultatSet = rs.executeQuery();
  175.  
  176.             resultatSet.next();
  177.             String rows = resultatSet.getString("player");
  178.             System.out.println(rows);
  179.  
  180.             return rows;
  181.  
  182.         } catch(SQLException e){
  183.  
  184.             e.printStackTrace();
  185.  
  186.         }
  187.  
  188.         return "";
  189.  
  190.     }
  191.  
  192.     public String getRushPlayerBoost(){
  193.  
  194.         try{
  195.  
  196.             PreparedStatement rs = connection.prepareStatement("SELECT player FROM boosters_rushbrain");
  197.             ResultSet resultatSet = rs.executeQuery();
  198.  
  199.             resultatSet.next();
  200.             String rows = resultatSet.getString("player");
  201.             System.out.println(rows);
  202.  
  203.             return rows;
  204.  
  205.         } catch(SQLException e){
  206.  
  207.             e.printStackTrace();
  208.  
  209.         }
  210.  
  211.         return "";
  212.  
  213.     }
  214.  
  215.     public void setFFABooster(String player,  long timestamp){
  216.  
  217.         try {
  218.             PreparedStatement rs = connection.prepareStatement("INSERT INTO boosters_ffarush(player,finishDate, active) VALUES (?,?,?)");
  219.  
  220.  
  221.  
  222.  
  223.  
  224.  
  225.  
  226.  
  227.             rs.setString(1, player);
  228.  
  229.             if(getFFARows() < 2) {
  230.                 rs.setLong(2, ((timestamp / 1000) + 120));
  231.  
  232.             } else {
  233.  
  234.                 rs.setLong(2, ((timestamp / 1000) + 120 * getFFARows()));
  235.  
  236.             }
  237.             if(hasFFABooster()){
  238.  
  239.                 rs.setString(3, "false");
  240.  
  241.             } else {
  242.  
  243.                 rs.setString(3, "true");
  244.  
  245.             }
  246.  
  247.             rs.execute();
  248.             rs.close();
  249.  
  250.         } catch (SQLException e) {
  251.             e.printStackTrace();
  252.         }
  253.  
  254.     }
  255.  
  256.     public void setRushBooster(String player,  long timestamp){
  257.  
  258.         try {
  259.             PreparedStatement rs = connection.prepareStatement("INSERT INTO boosters_rushbrain(player,finishDate, active) VALUES (?,?,?)");
  260.  
  261.  
  262.  
  263.  
  264.  
  265.  
  266.  
  267.  
  268.             rs.setString(1, player);
  269.  
  270.             if(getRushRows() < 2) {
  271.                 rs.setLong(2, ((timestamp / 1000) + 120));
  272.  
  273.             } else {
  274.  
  275.                 rs.setLong(2, ((timestamp / 1000) + 120 * getRushRows()));
  276.  
  277.             }
  278.             if(hasRushBooster()){
  279.  
  280.                 rs.setString(3, "false");
  281.  
  282.             } else {
  283.  
  284.                 rs.setString(3, "true");
  285.  
  286.             }
  287.  
  288.             rs.execute();
  289.             rs.close();
  290.  
  291.         } catch (SQLException e) {
  292.             e.printStackTrace();
  293.         }
  294.  
  295.     }
  296.  
  297.     public void updateRank(String player, String pseudo, String prefix){
  298.  
  299.  
  300.         try {
  301.             PreparedStatement rs = connection.prepareStatement("UPDATE custom_rank SET pseudo = ?, prefix = ? WHERE player = ?");
  302.             rs.setString(1, pseudo);
  303.             rs.setString(2, prefix);
  304.             rs.setString(3, player);
  305.             rs.executeUpdate();
  306.             rs.close();
  307.  
  308.         } catch (SQLException e) {
  309.             e.printStackTrace();
  310.         }
  311.  
  312.     }
  313.  
  314.     public void createAccount(String player, int coins){
  315.  
  316.         try {
  317.             PreparedStatement rs = connection.prepareStatement("INSERT INTO coins(player,coins) VALUES (?,?)");
  318.             rs.setString(1, player);
  319.             rs.setInt(2, coins);
  320.             rs.execute();
  321.             rs.close();
  322.  
  323.         } catch (SQLException e) {
  324.             e.printStackTrace();
  325.         }
  326.  
  327.     }
  328.  
  329.     public void createBooster(String player, int booster){
  330.  
  331.         try {
  332.             PreparedStatement rs = connection.prepareStatement("INSERT INTO boosters_players(player,booster) VALUES (?,?)");
  333.             rs.setString(1, player);
  334.             rs.setInt(2, booster);
  335.             rs.execute();
  336.             rs.close();
  337.  
  338.         } catch (SQLException e) {
  339.             e.printStackTrace();
  340.         }
  341.  
  342.     }
  343.  
  344.     public void addBooster(String player, int booster){
  345.  
  346.  
  347.         try {
  348.  
  349.             int balance = (getBooster(player) + booster);
  350.  
  351.             PreparedStatement rs = connection.prepareStatement("UPDATE boosters_players SET booster = ? WHERE player = ?");
  352.             rs.setInt(1, balance);
  353.             rs.setString(2, player);
  354.             rs.executeUpdate();
  355.             rs.close();
  356.  
  357.         } catch (SQLException e) {
  358.             e.printStackTrace();
  359.         }
  360.  
  361.     }
  362.  
  363.     public void removeBooster(String player, int booster){
  364.  
  365.  
  366.         try {
  367.  
  368.             int balance = (getBooster(player) - booster);
  369.  
  370.             PreparedStatement rs = connection.prepareStatement("UPDATE boosters_players SET booster = ? WHERE player = ?");
  371.             rs.setInt(1, balance);
  372.             rs.setString(2, player);
  373.             rs.executeUpdate();
  374.             rs.close();
  375.  
  376.         } catch (SQLException e) {
  377.             e.printStackTrace();
  378.         }
  379.  
  380.     }
  381.  
  382.     public void removeFFABooster(long timestamp){
  383.  
  384.  
  385.         try {
  386.  
  387.  
  388.  
  389.             PreparedStatement rs = connection.prepareStatement("DELETE FROM boosters_ffarush WHERE finishDate = ?");
  390.             rs.setLong(1, timestamp / 1000);
  391.             rs.executeUpdate();
  392.             rs.close();
  393.  
  394.         } catch (SQLException e) {
  395.             e.printStackTrace();
  396.         }
  397.  
  398.     }
  399.  
  400.     public void removeRushBooster(long timestamp){
  401.  
  402.  
  403.         try {
  404.  
  405.  
  406.  
  407.             PreparedStatement rs = connection.prepareStatement("DELETE FROM boosters_rushbrain WHERE finishDate = ?");
  408.             rs.setLong(1, timestamp / 1000);
  409.             rs.executeUpdate();
  410.             rs.close();
  411.  
  412.         } catch (SQLException e) {
  413.             e.printStackTrace();
  414.         }
  415.  
  416.     }
  417.  
  418.     public void updateBooster(){
  419.  
  420.  
  421.         try {
  422.  
  423.  
  424.  
  425.             PreparedStatement q = connection.prepareStatement("SELECT * FROM boosters_ffarush");
  426.             ResultSet resultat = q.executeQuery();
  427.  
  428.             int i = 0;
  429.  
  430.             if(hasFFABooster()){
  431.  
  432.                 while(i < 1){
  433.  
  434.                     i++;
  435.                     resultat.next();
  436.                     long timestamp = resultat.getLong("finishDate");
  437.                     resultat.close();
  438.  
  439.                     PreparedStatement ps = connection.prepareStatement("UPDATE boosters_ffarush SET active = ? WHERE finishDate = ?");
  440.                     ps.setString(1, "true");
  441.                     ps.setLong(2, timestamp);
  442.                     ps.executeUpdate();
  443.                     ps.close();
  444.  
  445.                 }
  446.  
  447.  
  448.             }
  449.  
  450.         } catch (SQLException e) {
  451.             e.printStackTrace();
  452.         }
  453.  
  454.     }
  455.  
  456.     public void updateRushBooster(){
  457.  
  458.  
  459.         try {
  460.  
  461.  
  462.  
  463.             PreparedStatement q = connection.prepareStatement("SELECT * FROM boosters_rushbrain");
  464.             ResultSet resultat = q.executeQuery();
  465.  
  466.             int i = 0;
  467.  
  468.             if(hasFFABooster()){
  469.  
  470.                 while(i < 1){
  471.  
  472.                     i++;
  473.                     resultat.next();
  474.                     long timestamp = resultat.getLong("finishDate");
  475.                     resultat.close();
  476.  
  477.                     PreparedStatement ps = connection.prepareStatement("UPDATE boosters_rushbrain SET active = ? WHERE finishDate = ?");
  478.                     ps.setString(1, "true");
  479.                     ps.setLong(2, timestamp);
  480.                     ps.executeUpdate();
  481.                     ps.close();
  482.  
  483.                 }
  484.  
  485.  
  486.             }
  487.  
  488.         } catch (SQLException e) {
  489.             e.printStackTrace();
  490.         }
  491.  
  492.     }
  493.  
  494.     public String getFFABooster() {
  495.  
  496.         try {
  497.             PreparedStatement q = connection.prepareStatement("SELECT active FROM boosters_ffarush");
  498.             ResultSet resultat = q.executeQuery();
  499.  
  500.             String coins = "";
  501.  
  502.             int i = 0;
  503.  
  504.             if(hasFFABooster()){
  505.                 while(i < 1){
  506.  
  507.                     i++;
  508.                     resultat.next();
  509.                     coins = resultat.getString("active");
  510.  
  511.                 }
  512.  
  513.             }
  514.  
  515.  
  516.  
  517.  
  518.             q.close();
  519.             return coins;
  520.         } catch (SQLException e) {
  521.             e.printStackTrace();
  522.         }
  523.  
  524.         return "";
  525.  
  526.     }
  527.    
  528.     public String getRushBooster() {
  529.  
  530.         try {
  531.             PreparedStatement q = connection.prepareStatement("SELECT active FROM boosters_rushbrain");
  532.             ResultSet resultat = q.executeQuery();
  533.  
  534.             String coins = "";
  535.  
  536.             int i = 0;
  537.  
  538.             if(hasRushBooster()){
  539.                 while(i < 1){
  540.  
  541.                     i++;
  542.                     resultat.next();
  543.                     coins = resultat.getString("active");
  544.  
  545.                 }
  546.  
  547.             }
  548.  
  549.  
  550.  
  551.  
  552.             q.close();
  553.             return coins;
  554.         } catch (SQLException e) {
  555.             e.printStackTrace();
  556.         }
  557.  
  558.         return "";
  559.  
  560.     }
  561.    
  562.    
  563.  
  564.     public long getFFATimeBooster() {
  565.  
  566.         try {
  567.             PreparedStatement q = connection.prepareStatement("SELECT finishDate FROM boosters_ffarush");
  568.             ResultSet resultat = q.executeQuery();
  569.  
  570.             long coins = 0;
  571.             int i = 0;
  572.  
  573.             if(hasFFABooster()){
  574.                 while(i < 1){
  575.  
  576.                     i++;
  577.                     resultat.next();
  578.                     coins = resultat.getLong("finishDate");
  579.  
  580.                 }
  581.  
  582.             }
  583.  
  584.  
  585.  
  586.  
  587.             q.close();
  588.             return coins;
  589.         } catch (SQLException e) {
  590.             e.printStackTrace();
  591.         }
  592.  
  593.         return 0;
  594.  
  595.     }
  596.  
  597.     public long getRushTimeBooster() {
  598.  
  599.         try {
  600.             PreparedStatement q = connection.prepareStatement("SELECT finishDate FROM boosters_rushbrain");
  601.             ResultSet resultat = q.executeQuery();
  602.  
  603.             long coins = 0;
  604.             int i = 0;
  605.  
  606.             if(hasRushBooster()){
  607.                 while(i < 1){
  608.  
  609.                     i++;
  610.                     resultat.next();
  611.                     coins = resultat.getLong("finishDate");
  612.  
  613.                 }
  614.  
  615.             }
  616.  
  617.  
  618.  
  619.  
  620.             q.close();
  621.             return coins;
  622.         } catch (SQLException e) {
  623.             e.printStackTrace();
  624.         }
  625.  
  626.         return 0;
  627.  
  628.     }
  629.  
  630.     public boolean hasFFABooster(){
  631.  
  632.         try {
  633.             PreparedStatement q = connection.prepareStatement("SELECT * FROM boosters_ffarush");
  634.             ResultSet resultat = q.executeQuery();
  635.             boolean hasCoins = resultat.next();
  636.             q.close();
  637.             return hasCoins;
  638.         } catch (SQLException e) {
  639.             e.printStackTrace();
  640.         }
  641.  
  642.         return false;
  643.  
  644.     }
  645.  
  646.     public boolean hasRushBooster(){
  647.  
  648.         try {
  649.             PreparedStatement q = connection.prepareStatement("SELECT * FROM boosters_rushbrain");
  650.             ResultSet resultat = q.executeQuery();
  651.             boolean hasCoins = resultat.next();
  652.             q.close();
  653.             return hasCoins;
  654.         } catch (SQLException e) {
  655.             e.printStackTrace();
  656.         }
  657.  
  658.         return false;
  659.  
  660.     }
  661.  
  662.     public int getBooster(String player){
  663.         //SELECT
  664.  
  665.         try {
  666.             PreparedStatement q = connection.prepareStatement("SELECT booster FROM boosters_players WHERE player = ?");
  667.             q.setString(1, player);
  668.             ResultSet resultat = q.executeQuery();
  669.  
  670.             int coins = 0;
  671.             while(resultat.next()){
  672.                 coins = resultat.getInt("booster");
  673.  
  674.             }
  675.  
  676.  
  677.             q.close();
  678.             return coins;
  679.         } catch (SQLException e) {
  680.             e.printStackTrace();
  681.         }
  682.  
  683.         return 0;
  684.     }
  685.  
  686.     public boolean hasBooster(String player){
  687.  
  688.         try {
  689.             PreparedStatement q = connection.prepareStatement("SELECT player FROM boosters_players WHERE player = ?");
  690.             q.setString(1, player);
  691.             ResultSet resultat = q.executeQuery();
  692.             boolean hasCoins = resultat.next();
  693.             q.close();
  694.             return hasCoins;
  695.         } catch (SQLException e) {
  696.             e.printStackTrace();
  697.         }
  698.  
  699.         return false;
  700.  
  701.     }
  702.  
  703.     public void addCoins(String player, int coins){
  704.  
  705.  
  706.         try {
  707.  
  708.             int balance = (getCoins(player) + coins);
  709.  
  710.             PreparedStatement rs = connection.prepareStatement("UPDATE coins SET coins = ? WHERE player = ?");
  711.             rs.setInt(1, balance);
  712.             rs.setString(2, player);
  713.             rs.executeUpdate();
  714.             rs.close();
  715.  
  716.         } catch (SQLException e) {
  717.             e.printStackTrace();
  718.         }
  719.  
  720.     }
  721.  
  722.     public void removeCoins(String player, int coins){
  723.  
  724.  
  725.         try {
  726.  
  727.             int balance = (getCoins(player) - coins);
  728.  
  729.             PreparedStatement rs = connection.prepareStatement("UPDATE coins SET coins = ? WHERE player = ?");
  730.             rs.setInt(1, balance);
  731.             rs.setString(2, player);
  732.             rs.executeUpdate();
  733.             rs.close();
  734.  
  735.         } catch (SQLException e) {
  736.             e.printStackTrace();
  737.         }
  738.  
  739.     }
  740.  
  741.     public int getCoins(String player){
  742.         //SELECT
  743.  
  744.         try {
  745.             PreparedStatement q = connection.prepareStatement("SELECT coins FROM coins WHERE player = ?");
  746.             q.setString(1, player);
  747.             ResultSet resultat = q.executeQuery();
  748.  
  749.             int coins = 0;
  750.             while(resultat.next()){
  751.                 coins = resultat.getInt("coins");
  752.  
  753.             }
  754.  
  755.  
  756.             q.close();
  757.             return coins;
  758.         } catch (SQLException e) {
  759.             e.printStackTrace();
  760.         }
  761.  
  762.         return 0;
  763.     }
  764.  
  765.     public boolean hasCoins(String player){
  766.  
  767.         try {
  768.             PreparedStatement q = connection.prepareStatement("SELECT player FROM coins WHERE player = ?");
  769.             q.setString(1, player);
  770.             ResultSet resultat = q.executeQuery();
  771.             boolean hasCoins = resultat.next();
  772.             q.close();
  773.             return hasCoins;
  774.         } catch (SQLException e) {
  775.             e.printStackTrace();
  776.         }
  777.  
  778.         return false;
  779.  
  780.     }
  781.  
  782.     public boolean hasAccount(String player){
  783.         //SELECT
  784.  
  785.         try {
  786.             PreparedStatement q = connection.prepareStatement("SELECT player FROM custom_rank WHERE player = ?");
  787.             q.setString(1, player);
  788.             ResultSet resultat = q.executeQuery();
  789.             boolean hasAccount = resultat.next();
  790.             q.close();
  791.             return hasAccount;
  792.         } catch (SQLException e) {
  793.             e.printStackTrace();
  794.         }
  795.  
  796.         return false;
  797.     }
  798.  
  799.  
  800.     public boolean isConnected(){
  801.         return connection != null;
  802.     }
  803.  
  804. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
Public Pastes
Advertisement
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!