public void connect(){
        try{

            connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/" + database , username, password);


        }catch(Exception e){

        }



    }


    @EventHandler
    public void onPlayerConnect(PlayerJoinEvent e){
        connect();
        final Player p = e.getPlayer();
        logged.add(p.getName());
        try{




        ResultSet rs = connection.createStatement().executeQuery("Select * from login where name = '" + p.getName() + "'");
        if(rs.next()){
            p.sendMessage("§c/login password");
        }else{
            p.sendMessage("§c/register password password");
        }




        }catch(SQLException es){
            es.printStackTrace();

        }

    }





    public boolean onCommand(CommandSender sender, Command command,
            String label, String[] args) {
        if(!(sender instanceof Player)){

            return true;
        }


        Player p = (Player) sender;
        //////////////////////////////////////////////////////////////Login
        if(command.getName().equalsIgnoreCase("login")){
            if(!logged.contains(p.getName())){
                p.sendMessage("§cYou are already logged in !");
                return true;
            }
            connect();
            try{

                ResultSet regcheck = connection.createStatement().executeQuery("Select * from login where name = '" + p.getName() + "'");
                if(!regcheck.next()){
                    p.sendMessage("§cNot registered use /register password password");
                    return true;
                }

            }catch(SQLException ee){
                ee.printStackTrace();
            }

            if(args.length != 1){
                p.sendMessage("§c/login password");
                return true;
            }else{
                String pass = args[0];
                try{


                    ResultSet logintry = connection.createStatement().executeQuery("Select * from login where name = '" + p.getName() + "' AND password='" + pass + "'");
                    if(logintry.next()){
                        logged.remove(p.getName());
                        sendtoserver(p, hub);
                        p.sendMessage("§aSuccessfuly logged in ! Welcome ....");
                    }else{
                        p.sendMessage("§cWrong Password");
                    }



                }catch(SQLException e){

                    e.printStackTrace();

                }

            }

        }

        ////////////////////////////////////////////////////////////// Register

        else if (command.getName().equalsIgnoreCase("register")) {


            connect();
            try{


                ResultSet regcheck = connection.createStatement().executeQuery("Select * from login where name = '" + p.getName() + "'");
                if(regcheck.next()){
                    p.sendMessage("§cAlready registered !");
                    return true;
                }else{


                    if(args.length != 2){
                        p.sendMessage("§c/register password password");
                        return true;
                    }else{

                        if(!args[0].equalsIgnoreCase(args[1])){
                            p.sendMessage("§cPassword must be the same !");
                            return true;
                        }
                        if(args[0].length() < 6 || args[0].length() > 25){
                            p.sendMessage("§cPassword must be between 6-25 characters !");
                            return true;
                        }


                        connection.createStatement().execute("INSERT INTO login (name, password) VALUES ('" + p.getName() + "', '" + args[0].toString() + "')");

                        p.sendMessage("§aSuccessfuly registered !");
                        logged.remove(p.getName());





                    }

                }



            }catch(SQLException se){


                se.printStackTrace();
            }






        }
        else if (command.getName().equalsIgnoreCase("changepassword")) {

            if(logged.contains(p.getName())){
                p.sendMessage("§cYou must be logged in first !");

                return true;
            }
            connect();

            try{


                ResultSet regcheck = connection.createStatement().executeQuery("Select * from login where name = '" + p.getName() + "'");
                if(!regcheck.next()){
                    p.sendMessage("§cNot registered !");
                    return true;
                }else{


                    if(args.length != 2){
                        p.sendMessage("§c/changepassword [old password] [new password]");
                        return true;
                    }else{



                        ResultSet loginctry = connection.createStatement().executeQuery("Select * from login where name = '" + p.getName() + "' AND password='" + args[0] + "'");
                        if(!loginctry.next()){
                            p.sendMessage("§cOld password is wrong !");
                        }else{



                            connection.createStatement().execute("UPDATE login set password='" +args[1] +  "' where name='" + p.getName() + "'");

                            p.sendMessage("§aSuccessfuly changed password !");



                        }





                    }

                }



            }catch(SQLException se){


                se.printStackTrace();
            }


        }else{
            if(logged.contains(p.getName())){
                p.sendMessage("§cYou must login... Use /login password");
            }



        }









        return true;

    }




    public void rights(){



        Bukkit.getScheduler().scheduleSyncRepeatingTask(this, new Runnable() {
            public void run() {

                Bukkit.getServer().broadcastMessage("§cNick Names §8» §6THIS PLUGIN MADE BY BESHO");
                Bukkit.getServer().broadcastMessage("§cNick Names §8» §3Twitter §8»§b https://twitter.com/BeshoGraphix");


            }
        }, 0L, 300L);

    }

    @EventHandler
    public void onChat(AsyncPlayerChatEvent e){

        if(logged.contains(e.getPlayer().getName())){
            e.getPlayer().sendMessage("§cYou can't chat. login first !");
            e.setCancelled(true);
        }


    }


      @EventHandler
        public void onPlayerCommandPreprocess(PlayerCommandPreprocessEvent event)  {
          String[] cmds = {"l", "login", "r", "reg", "cp", "register", "changepassword", "changepass"};
          String[] cc = event.getMessage().split(" ", 2);
            if(!Arrays.asList(cmds).contains(cc[0].replace("/", ""))) {
                event.getPlayer().sendMessage("§cYou can only use this commands: ");
                event.getPlayer().sendMessage("§6[/login, /register, /changepassword]");
                event.setCancelled(true);
            }
        }


      @EventHandler
      public void move(PlayerMoveEvent move)
      {
          if(!logged.contains(move.getPlayer().getName())){
              return;
          }
          Location from=move.getFrom();
          Location to=move.getTo();
          double x=Math.floor(from.getX());
          double z=Math.floor(from.getZ());
          if(Math.floor(to.getX())!=x||Math.floor(to.getZ())!=z)
          {
              x+=.5;
              z+=.5;
              move.getPlayer().teleport(new Location(from.getWorld(),x,from.getY(),z,from.getYaw(),from.getPitch()));
          }
      }



      public void sendtoserver(Player p , String server){
            ByteArrayDataOutput out = ByteStreams.newDataOutput();
            out.writeUTF("Connect");
            out.writeUTF(server);
            p.sendPluginMessage(this, "BungeeCord", out.toByteArray());

      }