本代码是java链接hbase数据库实例代码,包括增删改查及批量操作、范围查询等,备用.
代码如下:
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CellUtil;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.NamespaceDescriptor;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Delete;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.util.Bytes;
/**
*
* <p>类描述:hbase 增删改查操作 </p>
* <p>创建人:wanghonggang </p>
* <p>创建时间:2018年11月27日 下午3:18:10 </p>
*/
public class HbaseCRUD {
//hbase 链接
static Connection conn;
// 数据库元数据操作对象
static Admin admin;
/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
try {
System.out.println("--------------- 开始! -----------------");
setup();//初始化
createTable();//创建表
insert();//插入数据
update();//更新数据
delete();//删除数据
select();//查询数据
deleteTable();//删除表
closeConnection();//关闭连接
System.out.println("--------------- 结束! -----------------");
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 初始化
* @throws Exception
*/
public static void setup() throws Exception{
System.out.println("--------------- 开始初始化 -----------------");
//取得一个数据库连接的配置参数对象
Co