Advertisement
Guest User

Untitled

a guest
Apr 14th, 2017
89
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 2.22 KB | None | 0 0
  1. package nl.kingcrafting.ultrapoints.mangers;
  2.  
  3. import com.zaxxer.hikari.HikariDataSource;
  4. import nl.kingcrafting.ultrapoints.UltraPoints;
  5.  
  6. import java.sql.Connection;
  7. import java.sql.PreparedStatement;
  8. import java.sql.SQLException;
  9. import java.sql.Statement;
  10.  
  11. /**
  12. * Created by Jasper on 14-4-2017.
  13. */
  14. public class DBManager {
  15.  
  16. private UltraPoints plugin;
  17. private HikariDataSource hikari;
  18. private Connection connection;
  19.  
  20.  
  21. private String user,database,ip,password;
  22. private int port;
  23.  
  24.  
  25. public void init() {
  26. plugin = UltraPoints.getPlugin(UltraPoints.class);
  27. setup();
  28. setupHikari();
  29. setupTables();
  30.  
  31. }
  32.  
  33.  
  34. private void setupHikari() {
  35.  
  36. hikari = new HikariDataSource();
  37. hikari.setDataSourceClassName("com.mysql.jdbc.jdbc2.optional.MysqlDataSource");
  38. hikari.addDataSourceProperty("serverName", "127.0.0.1");
  39. hikari.addDataSourceProperty("port", "3306");
  40. hikari.addDataSourceProperty("databaseName", "plugin");
  41. hikari.addDataSourceProperty("user", "root");
  42. hikari.addDataSourceProperty("password", "mijnpassword");
  43. try {
  44. connection = hikari.getConnection();
  45. } catch (SQLException e) {
  46. e.printStackTrace();
  47. }
  48.  
  49.  
  50. }
  51. private void setupTables(){
  52.  
  53. try {
  54.  
  55. Statement statement = connection.createStatement();
  56. statement.executeUpdate("CREATE TABLE IF NOT EXISTS Points(UUID varchar(36), COINS int)");
  57.  
  58. PreparedStatement pre = connection.prepareStatement("INSERT INTO Points VALUES(?,?) ON DUPLICATE KEY UPDATE COINS=?");
  59. pre.setString(1, "567f12bb4e284adbb36f177b296223a4");
  60. pre.setInt(2, 20);
  61. pre.execute();
  62.  
  63.  
  64. } catch (SQLException e){
  65. e.printStackTrace();
  66. }
  67.  
  68. }
  69.  
  70.  
  71. private void setup() {
  72. port = plugin.getConfig().getInt("port");
  73. ip = plugin.getConfig().getString("host");
  74. user = plugin.getConfig().getString("user");
  75. password = plugin.getConfig().getString("password");
  76. database = plugin.getConfig().getString("database");
  77.  
  78. }
  79.  
  80. private void initTables() {
  81. }
  82.  
  83.  
  84. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement