版权声明：本文为博主原创文章，未经博主允许不得转载。 https://blog.csdn.net/qq_33202508/article/details/78748454
//建立连接
@Before
public void init() throws IOException{
//加载hbase配置文件
Configuration config=HBaseConfiguration.create();
//指定zookeeper 的通信主机和端口，之前设置环境，host中添加ip 主机名，eclipse中添加配置项jar
config.set(“hbase.zookeeper.quorum”, “master”);
config.set(“hbase.zookeeper.property.clientPort”, “2181”);
//建立连接
con=ConnectionFactory.createConnection(config);
System.out.println(“连接成功”+con);
}
//建表
@Test
public void createTable() throws MasterNotRunningException, ZooKeeperConnectionException, IOException{
//1表管理类 负责表级别的创建删除等操作
// HBaseAdmin admin=new HBaseAdmin(config);
//2通过连接获取表管理类
Admin admin=con.getAdmin();
//3表名管理对象
TableName name=TableName.valueOf(“dyh01”);
HTableDescriptor desc1=new HTableDescriptor(name);
//4创建列族的描述信息,添加列组
HColumnDescriptor fm1=new HColumnDescriptor(“lizu01”);
HColumnDescriptor fm2=new HColumnDescriptor(“lizu02”);
desc1.addFamily(fm1);
desc1.addFamily(fm2);
//5创建表
admin.createTable(desc1);
}
//删表
@Test
public void delet() throws IOException{
//1创建
Admin admin=con.getAdmin();
TableName name=TableName.valueOf("dyh01");
HTableDescriptor dest=new HTableDescriptor(name);
//2.1.禁用
admin.disableTables("dyh01");
//2.2删除
admin.deleteTables("dyh01");
}