Advertisement
LegarsStyler

Untitled

Jan 3rd, 2019
159
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 2.18 KB | None | 0 0
  1.  
  2.         String query = ""
  3.                 + "CREATE TABLE IF NOT EXISTS `minigames`("
  4.                 + "`id` int NOT NULL,"
  5.                 + "`name` text,"
  6.                 + "`displayname` text,"
  7.                 + "PRIMARY KEY(id));"
  8.                
  9.                 + "CREATE TABLE IF NOT EXISTS `minigamesrv`("
  10.                 + "`id` int NOT  NULL,"
  11.                 + "`name` text,"
  12.                 + "`minigamename` text,"
  13.                 + "`serverip` text,"
  14.                 + "`path` text,"
  15.                 + "PRIMARY KEY(id));";
  16.         instance.update(query);
  17.  
  18.  
  19.  
  20. // --------------------------------------------------------
  21.  
  22.  
  23.    
  24.     private int tries;
  25.     public Connection getSQL()
  26.     {
  27.         try
  28.         {
  29.             if(connection == null || connection.isClosed())
  30.             {
  31.                 Class.forName("com.mysql.jdbc.Driver");
  32.                 this.connection = DriverManager.getConnection("jdbc:mysql://" + host + "/" + dbname + "?allowMultiQueries=true", user, pass);
  33.             }
  34.         }
  35.         catch(Exception e)
  36.         {
  37.             System.err.println("! IMPORTANT ! Impossible de se connecter à la base de donnée !");
  38.             tries++;
  39.         }
  40.         if(tries >= 10)
  41.         {
  42.             System.err.println("! Arrêt du plugin !");
  43.             this.getProxy().getPluginManager().unregisterCommands(this);
  44.             this.getProxy().getPluginManager().unregisterListeners(this);
  45.             disable = true;
  46.         }
  47.         return connection;
  48.     }
  49.    
  50.     @SuppressWarnings("unchecked")
  51.     public <T> T getResult(Class<T> object, String query, String table, Object... args)
  52.     {
  53.         if(object.getName().equals(ResultSet.class.getName()))
  54.         {
  55.             try
  56.             {
  57.                 Connection co = getSQL();
  58.                 PreparedStatement stmt = co.prepareStatement(query);
  59.                 for(int i = 1; i <= args.length; i++) stmt.setObject(i, args[i - 1]);
  60.                 ResultSet rs = stmt.executeQuery();
  61.                 return (T) rs;
  62.             }
  63.             catch(SQLException e) { return null; }
  64.         }
  65.         else
  66.         {
  67.             try
  68.             {
  69.                 ResultSet rs = getResult(ResultSet.class, query, null, args);
  70.                 if(rs.next()) return (T) rs.getObject(table);
  71.                 return null;
  72.             }
  73.             catch(SQLException e) { return null; }
  74.         }
  75.     }
  76.    
  77.     public void update(String query, Object... args)
  78.     {
  79.         try
  80.         {
  81.             Connection co = getSQL();
  82.             PreparedStatement stmt = co.prepareStatement("use "+dbname+";"+query);
  83.             for(int i = 0; i < args.length; i++) stmt.setObject(i + 1, args[i]);
  84.             stmt.executeUpdate();
  85.         }
  86.         catch(SQLException e) { e.printStackTrace(); }
  87.     }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement