diff --git a/src/main/java/TableExist.java b/src/main/java/TableExist.java new file mode 100644 index 0000000..13ade1c --- /dev/null +++ b/src/main/java/TableExist.java @@ -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(); + } + } +} \ No newline at end of file