c++访问hbase

Posted 2022-10-13 byxdaz

一、环境配置
1、  安装thrift

按照官网http://thrift.apache.org/要求及步骤配置安装thrift

2、  取出Hbase文件中的Hbase.thrift文件，是用thrift--gen <language> <Thrift filename>产生所需的cpp文件，将gen_cpp文件复制到工程目录下。其中Hbase.cpp是CPP版的thrift文件中的函数，Hbase_types.cpp是CPP版的thrift文件中的结构。

3、  Hbase启动thrift服务./bin/hbase-daemon.sh start thrift                默认监听地址9090

以上步骤做好之后就可使用C++连接hbase并对其中数据库进行操作了

二、操作步骤
1、  创建连接

boost::shared_ptr<TTransport>socket(new TSocket("host",port(int)));

boost::shared_ptr<TTransport>transport(new TBufferedTransport(socket));

boost::shared_ptr<TProtocol>protocol(new TBinaryProtocol(transport));

HbaseClient client(protocol);

transport->open();    失败返回0并抛出TException错误

 

2、  连接成功后，可以通过client调用Hbase.thrift中定义的函数对hbase进行操作

3、  断开连接

transport->close()     失败抛出TException错误

 

三、HbaseClient类中定义的结构及函数