HBase基本API(java)操作(增刪改查)
阿新 • • 發佈：2019-01-26
//package hbaseExec2; /* * 建立一個students表,並進行相關操作 */ import java.io.IOException; import java.util.ArrayList; import java.util.List; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.HBaseConfiguration; import org.apache.hadoop.hbase.HColumnDescriptor; import org.apache.hadoop.hbase.HTableDescriptor; import org.apache.hadoop.hbase.KeyValue; import org.apache.hadoop.hbase.client.Delete; import org.apache.hadoop.hbase.client.Get; import org.apache.hadoop.hbase.client.HBaseAdmin; import org.apache.hadoop.hbase.client.HTable; import org.apache.hadoop.hbase.client.Put; import org.apache.hadoop.hbase.client.Result; import org.apache.hadoop.hbase.client.ResultScanner; import org.apache.hadoop.hbase.client.Scan; import org.apache.hadoop.hbase.util.Bytes; public class HBaseJavaAPI { // 宣告靜態配置 private static Configuration conf = null; static { conf = HBaseConfiguration.create(); conf.set("hbase.zookeeper.quorum", "192.168.6.91"); conf.set("hbase.zookeeper.property.clientPort", "2181"); } //判斷表是否存在 private static boolean isExist(String tableName) throws IOException { HBaseAdmin hAdmin = new HBaseAdmin(conf); return hAdmin.tableExists(tableName); } // 建立資料庫表 public static void createTable(String tableName, String[] columnFamilys) throws Exception { // 新建一個數據庫管理員 HBaseAdmin hAdmin = new HBaseAdmin(conf); if (hAdmin.tableExists(tableName)) { System.out.println("表 "+tableName+" 已存在！"); System.exit(0); } else { // 新建一個students表的描述 HTableDescriptor tableDesc = new HTableDescriptor(tableName); // 在描述裡新增列族 for (String columnFamily : columnFamilys) { tableDesc.addFamily(new HColumnDescriptor(columnFamily)); } // 根據配置好的描述建表 hAdmin.createTable(tableDesc); System.out.println("建立表 "+tableName+" 成功!"); } } // 刪除資料庫表 public static void deleteTable(String tableName) throws Exception { // 新建一個數據庫管理員 HBaseAdmin hAdmin = new HBaseAdmin(conf); if (hAdmin.tableExists(tableName)) { // 關閉一個表 hAdmin.disableTable(tableName); hAdmin.deleteTable(tableName); System.out.println("刪除表 "+tableName+" 成功！"); } else { System.out.println("刪除的表 "+tableName+" 不存在！"); System.exit(0); } } // 新增一條資料 public static void addRow(String tableName, String row, String columnFamily, String column, String value) throws Exception { HTable table = new HTable(conf, tableName); Put put = new Put(Bytes.toBytes(row));// 指定行 // 引數分別:列族、列、值 put.add(Bytes.toBytes(columnFamily), Bytes.toBytes(column), Bytes.toBytes(value)); table.put(put); } // 刪除一條(行)資料 public static void delRow(String tableName, String row) throws Exception { HTable table = new HTable(conf, tableName); Delete del = new Delete(Bytes.toBytes(row)); table.delete(del); } // 刪除多條資料 public static void delMultiRows(String tableName, String[] rows) throws Exception { HTable table = new HTable(conf, tableName); List<Delete> delList = new ArrayList<Delete>(); for (String row : rows) { Delete del = new Delete(Bytes.toBytes(row)); delList.add(del); } table.delete(delList); } // 獲取一條資料 public static void getRow(String tableName, String row) throws Exception { HTable table = new HTable(conf, tableName); Get get = new Get(Bytes.toBytes(row)); Result result = table.get(get); // 輸出結果,raw方法返回所有keyvalue陣列 for (KeyValue rowKV : result.raw()) { System.out.print("行名:" + new String(rowKV.getRow()) + " "); System.out.print("時間戳:" + rowKV.getTimestamp() + " "); System.out.print("列族名:" + new String(rowKV.getFamily()) + " "); System.out.print("列名:" + new String(rowKV.getQualifier()) + " "); System.out.println("值:" + new String(rowKV.getValue())); } } // 獲取所有資料 public static void getAllRows(String tableName) throws Exception { HTable table = new HTable(conf, tableName); Scan scan = new Scan(); ResultScanner results = table.getScanner(scan); // 輸出結果 for (Result result : results) { for (KeyValue rowKV : result.raw()) { System.out.print("行名:" + new String(rowKV.getRow()) + " "); System.out.print("時間戳:" + rowKV.getTimestamp() + " "); System.out.print("列族名:" + new String(rowKV.getFamily()) + " "); System.out .print("列名:" + new String(rowKV.getQualifier()) + " "); System.out.println("值:" + new String(rowKV.getValue())); } } } // 主函式 public static void main(String[] args) { try { String tableName = "student"; // 第一步：建立資料庫表：“student” String[] columnFamilys = { "info", "course" }; HBaseJavaAPI.createTable(tableName, columnFamilys); // 第二步：向資料表的新增資料 // 新增第一行資料 if (isExist(tableName)) { HBaseJavaAPI.addRow(tableName, "zpc", "info", "age", "20"); HBaseJavaAPI.addRow(tableName, "zpc", "info", "sex", "boy"); HBaseJavaAPI.addRow(tableName, "zpc", "course", "china", "97"); HBaseJavaAPI.addRow(tableName, "zpc", "course", "math", "128"); HBaseJavaAPI.addRow(tableName, "zpc", "course", "english", "85"); // 新增第二行資料 HBaseJavaAPI.addRow(tableName, "henjun", "info", "age", "19"); HBaseJavaAPI.addRow(tableName, "<span style="font-family: Arial, Helvetica, sans-serif;">henjun</span>", "info", "sex", "boy"); HBaseJavaAPI.addRow(tableName, "henjun", "course", "china","90"); HBaseJavaAPI.addRow(tableName, "henjun", "course", "math","120"); HBaseJavaAPI.addRow(tableName, "henjun", "course", "english","90"); // 新增第三行資料 HBaseJavaAPI.addRow(tableName, "niaopeng", "info", "age", "18"); HBaseJavaAPI.addRow(tableName, "<span style="font-family: Arial, Helvetica, sans-serif;">niaopeng</span>", "info", "sex","girl"); HBaseJavaAPI.addRow(tableName, "niaopeng", "course", "china","100"); HBaseJavaAPI.addRow(tableName, "niaopeng", "course", "math","100"); HBaseJavaAPI.addRow(tableName, "niaopeng", "course", "english","99"); // 第三步：獲取一條資料 System.out.println("**************獲取一條(zpc)資料*************"); HBaseJavaAPI.getRow(tableName, "zpc"); // 第四步：獲取所有資料 System.out.println("**************獲取所有資料***************"); HBaseJavaAPI.getAllRows(tableName); // 第五步：刪除一條資料 System.out.println("************刪除一條(zpc)資料************"); HBaseJavaAPI.delRow(tableName, "zpc"); HBaseJavaAPI.getAllRows(tableName); // 第六步：刪除多條資料 System.out.println("**************刪除多條資料***************"); String rows[] = new String[] { "qingqing","xiaoxue" }; HBaseJavaAPI.delMultiRows(tableName, rows); HBaseJavaAPI.getAllRows(tableName); // 第七步：刪除資料庫 System.out.println("***************刪除資料庫表**************"); HBaseJavaAPI.deleteTable(tableName); System.out.println("表"+tableName+"存在嗎？"+isExist(tableName)); } else { System.out.println(tableName + "此資料庫表不存在！"); } } catch (Exception e) { e.printStackTrace(); } } }