Reapply "feat: 添加 TableExist 类用于检查 HBase 表是否存在"

This reverts commit ac8bc7357d.
This commit is contained in:
fly6516 2025-03-26 11:19:42 +08:00
parent bc64458cd3
commit 75609c7c34

View File

@ -0,0 +1,52 @@
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;
public class TableExist{
public static Configuration configuration;
public static Connection connection;
public static Admin admin;
public static void main(String[] args)throws IOException{
Scanner sc = new Scanner(System.in);
System.out.print("tableName:");
String tableName = sc.next();
init();
TableName tn = TableName.valueOf(tableName);
if(admin.tableExists(tn)) {
System.out.println("table " + tableName + " does exist!");
} else {
System.out.println("table " + tableName + " don't exist!");
}
close();
}
//建立连接
public static void init(){
//根据 hbase-site.xml文件初始化Configuration 对象
configuration = HBaseConfiguration.create();
try{
//根据 Configuration对象初始化Connection 对象
connection = ConnectionFactory.createConnection(configuration);
//获取Admin 对象实例
admin = connection.getAdmin();
}catch (IOException e){
e.printStackTrace();
}
System.out.println("Connect to HBase successfully!");
}
//关闭连接
public static void close(){
try{
if(admin != null){
admin.close();
}
if(null != connection){
connection.close();
}
}catch (IOException e){
e.printStackTrace();
}
}
}