php连接hive执行sql查询 thrift

php链接hive执行sql语句需要重新安装thrift

编译好的thrift下载地址


安装后启动hive thrift

hadoop@hadoop-master:~$ hive --service hiveserver
hadoop@hadoop-master:~$netstat -nat | grep 10000
tcp6       0      0 :::10000                :::*                    LISTEN   #默认端口

php测试hive代码

#!/usr/bin/php
<?
$GLOBALS['THRIFT_ROOT'] = '/home/hadoop/Thrift/';
require_once $GLOBALS['THRIFT_ROOT'] . 'packages/hive_service/ThriftHive.php';
require_once $GLOBALS['THRIFT_ROOT'] . 'transport/TSocket.php';
require_once $GLOBALS['THRIFT_ROOT'] . 'protocol/TBinaryProtocol.php';

$transport = new TSocket('master', 10000);
$protocol = new TBinaryProtocol($transport);
$client = new ThriftHiveClient($protocol);
$transport->open();

$client->execute('add jar /home/hadoop/hadoop-1.0.1/contrib/hive/lib/hive-contrib-0.8.1.jar');
$client->execute("insert overwrite local directory '/home/hadoop/hive-out' select sum(price) from erp_crstorage");
$transport->close();

?>