noSql-Hbase-php读写操作hbase数据库的基本方法

<?php

$GLOBALS['THRIFT_ROOT'] = '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( 'localhost',9090 );
$socket->setSendTimeout( 10000 ); // Ten seconds (too long for production,but this is just a demo ;)
$socket->setRecvTimeout( 20000 ); // Twenty seconds
$transport = new TBufferedTransport( $socket );
$protocol = new TBinaryProtocol( $transport );
$client = new HbaseClient( $protocol );

$transport->open();

echo "start ...\r\n";
echo "check table exist\r\n";

$t = 'test_table';
$table = $client->getTableNames();

print_r($table);

/**
foreach ($table as $value){
if($value == $t){
echo "find $t,delete it\r\n";
if($client->isTableEnabled($value)){
echo "disabling $t\r\n";
$client->disableTable($value);
}
echo "deleting $t\r\n";
$client->deleteTable($value);
}
}

echo "Create new table $t\r\n";

$aritcle = new ColumnDescriptor(array('name'=>'aritcle:'));
$author = new ColumnDescriptor(array('name'=>'author:'));
$columns = array($aritcle,$author);

echo "Creating table $t\r\n";
try {
$client->createTable($t,$columns);
} catch (AlreadyExists $ae){
echo "$ae\r\n";
}

**/

echo "Start insert some records\r\n";

$record1 = array(new Mutation(array('column'=>'aritcle:title','value'=>'hello,world!')));
$record2 = array(new Mutation(array('column'=>'aritcle:content','value'=>'welcome to hbase')));

$client->mutateRow($t,'1',$record1);
$client->mutateRow($t,$record2);
/**
echo "In sert 1000 records\r\n";
$time_start = microtime_float();

for ($i=0;$i<10000;$i++){
$record = array(new Mutation(array('column'=>'aritcle:title','value'=>$i)));
$client->mutateRow($t,$i,$record);
}

$time_end = microtime_float();
$time = $time_end - $time_start;

echo "Did nothing in $time seconds\n";

echo "rand read row \r\n";
**/
$row = $client->getRow($t,rand(1,10000));
print_r($row);

$row = $client->getRowWithColumns($t,1,'aritcle:');
print_r($row);

$transport->close();

function microtime_float()
{
list($usec,$sec) = explode(" ",microtime());
return ((float)$usec + (float)$sec);
}

?>

----------------------------------------------------

// 列出hbase 裡的所有 table
69 echo( "listing tables...\n" );
70 $tables = $client->getTableNames();
71 sort( $tables );
72 foreach ( $tables as $name )
73 {
74 echo $name."\n";
75 }
76
77 // 刪除table
78 $name = "test2";
79 if($client->isTableEnabled($name))
80 {
81 echo "关闭".$name."资料表\n";
82 $client->disableTable($name);
83 }
84 echo "刪除中...\n";
85 $client->deleteTable($name);
86 echo "刪除完成";
87
88 // 新增table
89 $columns = array(new ColumnDescriptor(array('name' => 'name:')),
90 new ColumnDescriptor(array('name'=> 'scores:',)));
91 $t = "test2";
92 echo("creating table: {$t}\n");
93 try
94 {
95 $client->createTable( $t,$columns );
96 }
97 catch (AlreadyExists $ae)
98 {
99 echo( "WARN: {$ae->message}\n" );
100 }
101
102 //列出table內的column family
103 $t = "results";
104 echo("column families in {$t}:\n");
105 $descriptors = $client->getColumnDescriptors( $t );
106 asort( $descriptors );