Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package de.teamsoul.main.mysql;
- import java.sql.PreparedStatement;
- import java.sql.ResultSet;
- import java.sql.SQLException;
- public class methoden_coinsystem {
- public static boolean UserExists(String UID) {
- try {
- PreparedStatement ps = mysql.getConnection().prepareStatement("SELECT * FROM CoinSystem WHERE UID = ?");
- ps.setString(1, UID);
- ResultSet rs = ps.executeQuery();
- return rs.next();
- } catch (SQLException e) {
- e.printStackTrace();
- }
- return false;
- }
- public static void addCoins(int Coins, String UID, String Name) {
- if (UserExists(UID)) {
- try {
- PreparedStatement ps_upCoins = mysql.getConnection().prepareStatement("UPDATE CoinSystem SET Coins = Coins + ? WHERE UID = ?");
- ps_upCoins.setInt(1, Coins);
- ps_upCoins.setString(2, UID);
- ps_upCoins.executeUpdate();
- PreparedStatement ps_upName = mysql.getConnection().prepareStatement("UPDATE CoinSystem SET Name = ? WHERE UID = ?");
- ps_upName.setString(1, Name);
- ps_upName.setString(2, UID);
- ps_upName.executeUpdate();
- } catch (SQLException e) {
- e.printStackTrace();
- }
- } else {
- try {
- PreparedStatement ps = mysql.getConnection().prepareStatement("INSERT INTO CoinSystem (Name,UID,Coins,DailyCoinsAvailable) VALUES (?,?,?,?)");
- ps.setString(1, Name);
- ps.setString(2, UID);
- ps.setInt(3, Coins);
- ps.setBoolean(4, true);
- ps.executeUpdate();
- } catch (SQLException e) {
- e.printStackTrace();
- }
- }
- }
- public static void removeCoins(String UID, int Coins) {
- if (UserExists(UID)) {
- try {
- PreparedStatement ps_check = mysql.getConnection().prepareStatement("SELECT Coins FROM CoinSystem WHERE UID = ?");
- ResultSet rs = ps_check.executeQuery();
- if (rs.getInt("Coins") >= Coins) {
- PreparedStatement ps_remove = mysql.getConnection().prepareStatement("UPDATE CoinSystem SET Coins = Coins - ? WHERE UID = ?");
- ps_remove.setInt(1, Coins);
- ps_remove.setString(2, UID);
- ps_remove.executeUpdate();
- }
- } catch (SQLException e) {
- e.printStackTrace();
- }
- }
- }
- public static boolean ifDailyBonusAvailable(String UID) {
- try {
- PreparedStatement ps = mysql.getConnection().prepareStatement("SELECT DailyCoinsAvailable FROM CoinSystem WHERE UID = \"?\"");
- ps.setString(1, UID);
- ResultSet rs = ps.executeQuery();
- return rs.next();
- } catch (SQLException e) {
- e.printStackTrace();
- }
- return false;
- }
- public static void deactivateDailyBonus(String UID) {
- try {
- PreparedStatement ps = mysql.getConnection().prepareStatement("UPDATE `CoinSystem` SET `DailyCoinsAvailable`='0' WHERE UID = ?");
- ps.setString(1, UID);
- ps.executeUpdate();
- } catch (SQLException e) {
- e.printStackTrace();
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement