@Create By Frank */ public class HbaseJavaClientDDLTest { //todo:1-构建连接 Connection conn = null; @Before public void getConnect() throws IOException { //构建配置对象 Configuration conf = HBaseConfiguration.create(); //配置Hbase服务端地址：ZK conf.set(“hbase.zookeeper.quorum”,“node1:2181,node2:2181,node3:2181”); //构建连接实例 conn = ConnectionFactory.createConnection(conf); }

//todo:2-基于连接的方法实现操作 //构建管理员对象 public HBaseAdmin getHbaseAdmin() throws IOException { HBaseAdmin admin = (HBaseAdmin) conn.getAdmin(); return admin; }

@Test public void listNS() throws IOException { HBaseAdmin admin = getHbaseAdmin(); //实现列举NS NamespaceDescriptor[] namespaceDescriptors = admin.listNamespaceDescriptors(); //打印名称 for (NamespaceDescriptor namespaceDescriptor : namespaceDescriptors) { System.out.println(namespaceDescriptor.getName()); } //关闭管理员 admin.close(); }

@Test public void delNs() throws IOException { HBaseAdmin admin = getHbaseAdmin(); admin.deleteNamespace(“heima”); admin.close(); }

@Test public void createNS() throws IOException { HBaseAdmin admin = getHbaseAdmin(); //创建 NamespaceDescriptor descriptor = NamespaceDescriptor .create(“heima”)//指定NS名称 .build(); admin.createNamespace(descriptor); admin.close(); }

@Test public void listTables() throws IOException { HBaseAdmin admin = getHbaseAdmin(); //列举所有表 List tableDescriptors = admin.listTableDescriptors(); //打印表名 for (TableDescriptor tableDescriptor : tableDescriptors) { System.out.println(tableDescriptor.getTableName().getNameAsString()); } admin.close(); }

@Test public void createTb() throws IOException { HBaseAdmin admin = getHbaseAdmin(); //构建表名对象 TableName tbname = TableName.valueOf(“itcast:t1”); //判断表是否存在 if(admin.tableExists(tbname)){ //禁用表 admin.disableTable(tbname); //删除表 admin.deleteTable(tbname); } //构建列族对象 ColumnFamilyDescriptor basic = ColumnFamilyDescriptorBuilder .newBuilder(Bytes.toBytes(“basic”)) .build(); ColumnFamilyDescriptor other = ColumnFamilyDescriptorBuilder .newBuilder(Bytes.toBytes(“other”)) .setMaxVersions(3) .build(); //创建表 TableDescriptor desc = TableDescriptorBuilder .newBuilder(tbname) .setColumnFamily(basic) .setColumnFamily(other) .build(); admin.createTable(desc); admin.close(); }

//todo:3-释放连接 @After public void closeConnect() throws IOException { conn.close(); } }