From 0dc78d8a4ef7e5e84897982a20b749ddab496f7a Mon Sep 17 00:00:00 2001
From: fly6516 <fly6516@outlook.com>
Date: Wed, 26 Mar 2025 01:43:13 +0000
Subject: [PATCH] del connect

---
 src/main/java/EmpHBaseClient.java |  8 ++++++-
 src/main/java/MyConnect.java      | 39 -------------------------------
 2 files changed, 7 insertions(+), 40 deletions(-)
 delete mode 100644 src/main/java/MyConnect.java

diff --git a/src/main/java/EmpHBaseClient.java b/src/main/java/EmpHBaseClient.java
index 79d215c..aefaf74 100644
--- a/src/main/java/EmpHBaseClient.java
+++ b/src/main/java/EmpHBaseClient.java
@@ -1,3 +1,9 @@
+
+
+import java.io.BufferedReader;
+import java.io.FileReader;
+import java.io.IOException;
+
 public class EmpHBaseClient {
     private Configuration conf;
     private Connection connection;
@@ -95,7 +101,7 @@ public class EmpHBaseClient {
     // 新增查询ID 7500以上员工方法
     public void findEmployeesWithEmpnoAbove7500() throws IOException {
         Scan scan = new Scan();
-        SingleColumnValueFilter filter = new SingleColumnValueFilter(
+        FilterProtos.SingleColumnValueFilter filter = new SingleColumnValueFilter(
             Bytes.toBytes("empnum"),
             Bytes.toBytes("empno"),
             CompareFilter.CompareOp.GREATER_OR_EQUAL,
diff --git a/src/main/java/MyConnect.java b/src/main/java/MyConnect.java
deleted file mode 100644
index 9edaa07..0000000
--- a/src/main/java/MyConnect.java
+++ /dev/null
@@ -1,39 +0,0 @@
-import org.apache.hadoop.conf.Configuration;
-import org.apache.hadoop.hbase.client.*;
-import java.io.IOException;
-public class MyConnect{
-    public static Configuration configuration;
-    public static Connection connection;
-    public static Admin admin;
-    public static void main(String[] args)throws IOException{
-        init();
-        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