利用循环输入表的名字进行删除
import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.*; import org.apache.hadoop.hbase.client.*; import java.io.IOException; import java.util.Scanner; import org.apache.hadoop.hbase.util.Bytes; public class alldelete{ public static Configuration configuration; public static Connection connection; public static Admin admin; public static void main(String[] args)throws IOException{ System.out.println("输入表的数量"); Scanner input2=new Scanner(System.in); int b=input2.nextInt();//输入长度 System.out.println("输入表的名字："); for(int i=0;i<b;i++) { Scanner input1=new Scanner(System.in); String a=input1.next();//输入一个字符串 System.out.println(a); deleteTable(a); } } //建立连接 public static void init(){ configuration = HBaseConfiguration.create(); configuration.set("hbase.rootdir","hdfs://localhost:9000/hbase"); try{ connection = ConnectionFactory.createConnection(configuration); admin = connection.getAdmin(); }catch (IOException e){ e.printStackTrace(); } } //关闭连接 public static void close(){ try{ if(admin != null){ admin.close(); } if(null != connection){ connection.close(); } }catch (IOException e){ e.printStackTrace(); } } public static void deleteTable(String tableName) throws IOException { init(); TableName tn = TableName.valueOf(tableName); if (admin.tableExists(tn)) { admin.disableTable(tn); admin.deleteTable(tn); } close(); System.out.println("删除了表："+tableName); } }