你的位置:首页 > 软件开发 > 数据库 > 在Eclipse中运行JAVA代码远程操作HBase的示例

在Eclipse中运行JAVA代码远程操作HBase的示例

发布时间:2015-08-26 19:00:06
在Eclipse中运行JAVA代码远程操作HBase的示例 分类: 大数据 2014-03-04 13:47 3762人阅读 评论(2) 收藏 举报 下面是一个在Windows的Eclipse中通过JAVA操作一个Linux上运行的hbase的示例。Hbase的配置需要注意下面 ...

在Eclipse中运行JAVA代码远程操作HBase的示例

分类: 大数据 2014-03-04 13:47 3762人阅读 评论(2) 收藏 举报
            // Hbase获取所有的表信息
            public List getAllTables() {
                List<String> tables = null;
                if (admin != null) {
                    try {
                        HTableDescriptor[] allTable = admin.listTables();
                        if (allTable.length > 0)
                            tables = new ArrayList<String>();
                        for (HTableDescriptor hTableDescriptor : allTable) {
                            tables.add(hTableDescriptor.getNameAsString());
                            System.out.println(hTableDescriptor.getNameAsString());
                        }
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
                return tables;
            }
            // Hbase中往某个表中添加一条记录
            public boolean addOneRecord(String table, String key, String family,
                    String col, byte[] dataIn) {
                HTablePool tp = new HTablePool(cfg, 1000);
                HTable tb = (HTable) tp.getTable(table);
                Put put = new Put(key.getBytes());
                put.add(family.getBytes(), col.getBytes(), dataIn);
                try {
                    tb.put(put);
                    System.out.println("插入数据条" + key + "成功!!!");
                    return true;
                } catch (IOException e) {
                    System.out.println("插入数据条" + key + "失败!!!");
                    return false;
                }
            }
            // Hbase表中记录信息的查询
            public void getValueFromKey(String table, String key) {
                HTablePool tp = new HTablePool(cfg, 1000);
                HTable tb = (HTable) tp.getTable(table);
                Get get = new Get(key.getBytes());
                try {
                    Result rs = tb.get(get);
                    if (rs.raw().length == 0) {
                        System.out.println("不存在关键字为" + key + "的行!!");
                    } else {
                        for (KeyValue kv : rs.raw()) {
                            System.out.println(new String(kv.getKey()) + " "
                                    + new String(kv.getValue()));
                        }
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            // 显示所有数据,通过HTable Scan类获取已有表的信息
            public void getAllData(String tableName) throws Exception {
                HTable table = new HTable(cfg, tableName);
                Scan scan = new Scan();
                ResultScanner rs = table.getScanner(scan);
                for (Result r : rs) {
                    for (KeyValue kv : r.raw()) {
                        System.out.println(new String(kv.getKey())
                                + new String(kv.getValue()));
                    }
                }
            }
            // Hbase表中记录信息的删除
            public boolean deleteRecord(String table, String key) {
                HTablePool tp = new HTablePool(cfg, 1000);
                HTable tb = (HTable) tp.getTable(table);
                Delete de = new Delete(key.getBytes());
                try {
                    tb.delete(de);
                    return true;
                } catch (IOException e) {
                    System.out.println("删除记录" + key + "异常!!!");
                    return false;
                }
            }
            // Hbase中表的删除
            public boolean deleteTable(String table) {
                try {
                    if (admin.tableExists(table)) {
                        admin.disableTable(table);
                        admin.deleteTable(table);
                        System.out.println("删除表" + table + "!!!");
                    }
                    return true;
                } catch (IOException e) {
                    System.out.println("删除表" + table + "异常!!!");
                    return false;
                }
            }
            // 测试函数
            public static void main(String[] args) {
                try {
                    HbaseTest hbase = new HbaseTest();
                    // hbase.createTable("student", "fam1");
                    // hbase.getAllTables();
                    // hbase.addOneRecord("student","id1","fam1","name","Jack".getBytes());
                    // hbase.addOneRecord("student","id1","fam1","address","HZ".getBytes());
                    // hbase.getValueFromKey("student","id1");
                    // hbase.getAllData("student");
                    //hbase.deleteRecord("student", "id1");
                    hbase.deleteTable("student");
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }

原标题:在Eclipse中运行JAVA代码远程操作HBase的示例

关键词:JAVA

*特别声明:以上内容来自于网络收集,著作权属原作者所有,如有侵权,请联系我们: admin#shaoqun.com (#换成@)。