首先必須與Hbase建立連線
<?php
header ("Content-Type:text/html; charset=utf-8");
//include thrift路徑
$GLOBALS['THRIFT_ROOT'] = '/var/www/hbase/thrift';
require_once( $GLOBALS['THRIFT_ROOT'].'/Thrift.php' );
require_once( $GLOBALS['THRIFT_ROOT'].'/transport/TSocket.php' );
require_once( $GLOBALS['THRIFT_ROOT'].'/transport/TBufferedTransport.php' );
require_once( $GLOBALS['THRIFT_ROOT'].'/protocol/TBinaryProtocol.php' );
require_once( $GLOBALS['THRIFT_ROOT'].'/packages/Hbase/Hbase.php' );
//建立連線
$socket = new TSocket( 'YourIP', 9090 );
$socket->setSendTimeout( 10000 ); // Ten seconds
$socket->setRecvTimeout( 20000 ); // Twenty seconds
$transport = new TBufferedTransport( $socket );
$protocol = new TBinaryProtocol( $transport );
$client = new HbaseClient( $protocol );
//啟動
$transport->open();
//程式碼寫在這邊
$transport->close();
?>
接下來是對資料庫會使用到的基本操作
1.新增資料表
//定義columns 的物件結構，一個Column需要new出一個ColumnDescriptor物件
$columns = array(
new ColumnDescriptor( array(
'name' => 'name:'
) ),
new ColumnDescriptor( array(
'name'=> 'scores:',
) )
);
$t = "test";//Table name
echo( "creating table: {$t}\n" );
try
{
$client->createTable( $t, $columns );
}
catch ( AlreadyExists $ae )
{
echo( "WARN: {$ae->message}\n" );
}
2.查閱所有資料表
echo( "全部的資料表有...\n" );
$tables = $client->getTableNames();
sort( $tables );
foreach ( $tables as $name )
{
echo $name."\n";
}
3.列出 table內的column family
$t = "test";//資料表名稱
echo( "column families in {$t}:\n" );
$descriptors = $client->getColumnDescriptors( $t );
asort( $descriptors );
foreach ( $descriptors as $col )
{
echo( " column: {$col->name}, maxVer: {$col->maxVersions}\n" );
}
4.新增資料
$t = "test"; //Table name
$row = "abc"; //row name
$valid = "apple";
$mutations = array(
new Mutation( array(
'column' => 'nama:',
'value' => $valid
) )
);
$client->mutateRow( $t, $row, $mutations );
echo "新增成功";
5.讀取資料
include "ThriftLib.php";
$table_name = 'test';//Table name
$row_name = 'abc';//row name
$fam_col_name = 'name:';//column name
$arr = $client->get($table_name, $row_name , $fam_col_name);
foreach ( $arr as $k=>$v )
{
//// $k = TCell物件
echo "value = {$v->value} , <br> ";
echo "timestamp = {$v->timestamp} <br>";
}
6.刪除資料表
$name = "test"; //要刪除的資料表
if($client->isTableEnabled($name))
{
echo "關閉".$name."資料表\n";
$client->disableTable($name);
}
echo "刪除中...\n";
$client->deleteTable($name);
echo "刪除完成";
有問題再留言吧＠＠
