From 75609c7c34fa62abed6174ba80fc606728dbdf5c Mon Sep 17 00:00:00 2001 From: fly6516 Date: Wed, 26 Mar 2025 11:19:42 +0800 Subject: [PATCH] =?UTF-8?q?Reapply=20"feat:=20=E6=B7=BB=E5=8A=A0=20TableEx?= =?UTF-8?q?ist=20=E7=B1=BB=E7=94=A8=E4=BA=8E=E6=A3=80=E6=9F=A5=20HBase=20?= =?UTF-8?q?=E8=A1=A8=E6=98=AF=E5=90=A6=E5=AD=98=E5=9C=A8"?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit This reverts commit ac8bc7357da9d6bc2b0868c0fe7afdbd0b16cdb1. --- src/main/java/TableExist.java | 52 +++++++++++++++++++++++++++++++++++ 1 file changed, 52 insertions(+) create mode 100644 src/main/java/TableExist.java 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