handlersocket_android中handler_hive hbase handler(5)

Example：

测试库 hstestdb，测试表hstesttbl：

CREATE TABLE `hstesttbl` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `k` char(6) DEFAULT NULL,
  `v` char(6) DEFAULT NULL,
  PRIMARY KEY (`id`),
  KEY `idx_hstesttbl_k` (`k`)
) ENGINE=InnoDB AUTO_INCREMENT=7 DEFAULT CHARSET=utf8;

PHP test Code：

$host       = localhost;
$port       = 9998;
$port_wr    = 9999;
$dbname     = hstestdb;
$table      = hstesttbl;
 
//GET
$hs = new HandlerSocket($host, $port);
if (!($hs->openIndex(1, $dbname, $table, HandlerSocket::PRIMARY, k,v))) {
    echo $hs->getError(), PHP_EOL;
    die();
}
 
$retval = $hs->executeSingle(1, =, array(k1), 1, 0);
var_dump($retval);
 
$retval = $hs->executeMulti(
    array(
        array(1, =, array(k1), 1, 0),
        array(1, =, array(k2), 1, 0)
    )
);
var_dump($retval);
unset($hs);
 
//UPDATE
$hs = new HandlerSocket($host, $port_wr);
if (!($hs->openIndex(2, $dbname, $table, , v))) {
    echo $hs->getError(), PHP_EOL;
    die();
}
 
if ($hs->executeUpdate(2, =, array(k1), array(V1), 1, 0) === false) {
    echo $hs->getError(), PHP_EOL;
    die();
}
 
unset($hs);
 
//INSERT
$hs = new HandlerSocket($host, $port_wr);
if (!($hs->openIndex(3, $dbname, $table, , k,v))) {
    echo $hs->getError(), PHP_EOL;
    die();
}
 
if ($hs->executeInsert(3, array(k2, v2)) === false) {
    echo $hs->getError(), PHP_EOL;
}
if ($hs->executeInsert(3, array(k3, v3)) === false) {
    echo A, $hs->getError(), PHP_EOL;
}
if ($hs->executeInsert(3, array(k4, v4)) === false) {
    echo B, $hs->getError(), PHP_EOL;
}
 
unset($hs);
 
//DELETE
$hs = new HandlerSocket($host, $port_wr);
if (!($hs->openIndex(4, $dbname, $table, , ))) {
    echo $hs->getError(), PHP_EOL;
    die();
}
 
if ($hs->executeDelete(4, =, array(k2)) === false) {
    echo $hs->getError(), PHP_EOL;
    die();
}
?>

本文来自电脑杂谈，转载请注明本文网址：
http://www.pc-fly.com/a/jisuanjixue/article-27115-5.html