blob: 768f2421760f7b73af282002d777ff54ee0fc0cf [file] [log] [blame]
<?php
/**
* Autogenerated by Thrift Compiler (0.16.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
*/
use Thrift\Base\TBase;
use Thrift\Type\TType;
use Thrift\Type\TMessageType;
use Thrift\Exception\TException;
use Thrift\Exception\TProtocolException;
use Thrift\Protocol\TProtocol;
use Thrift\Protocol\TBinaryProtocolAccelerated;
use Thrift\Exception\TApplicationException;
class TCLIServiceClient implements \TCLIServiceIf
{
protected $input_ = null;
protected $output_ = null;
protected $seqid_ = 0;
public function __construct($input, $output = null)
{
$this->input_ = $input;
$this->output_ = $output ? $output : $input;
}
public function OpenSession(\TOpenSessionReq $req)
{
$this->send_OpenSession($req);
return $this->recv_OpenSession();
}
public function send_OpenSession(\TOpenSessionReq $req)
{
$args = new \TCLIService_OpenSession_args();
$args->req = $req;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel) {
thrift_protocol_write_binary(
$this->output_,
'OpenSession',
TMessageType::CALL,
$args,
$this->seqid_,
$this->output_->isStrictWrite()
);
} else {
$this->output_->writeMessageBegin('OpenSession', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
public function recv_OpenSession()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary(
$this->input_,
'\TCLIService_OpenSession_result',
$this->input_->isStrictRead()
);
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \TCLIService_OpenSession_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("OpenSession failed: unknown result");
}
public function CloseSession(\TCloseSessionReq $req)
{
$this->send_CloseSession($req);
return $this->recv_CloseSession();
}
public function send_CloseSession(\TCloseSessionReq $req)
{
$args = new \TCLIService_CloseSession_args();
$args->req = $req;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel) {
thrift_protocol_write_binary(
$this->output_,
'CloseSession',
TMessageType::CALL,
$args,
$this->seqid_,
$this->output_->isStrictWrite()
);
} else {
$this->output_->writeMessageBegin('CloseSession', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
public function recv_CloseSession()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary(
$this->input_,
'\TCLIService_CloseSession_result',
$this->input_->isStrictRead()
);
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \TCLIService_CloseSession_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("CloseSession failed: unknown result");
}
public function GetInfo(\TGetInfoReq $req)
{
$this->send_GetInfo($req);
return $this->recv_GetInfo();
}
public function send_GetInfo(\TGetInfoReq $req)
{
$args = new \TCLIService_GetInfo_args();
$args->req = $req;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel) {
thrift_protocol_write_binary(
$this->output_,
'GetInfo',
TMessageType::CALL,
$args,
$this->seqid_,
$this->output_->isStrictWrite()
);
} else {
$this->output_->writeMessageBegin('GetInfo', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
public function recv_GetInfo()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary(
$this->input_,
'\TCLIService_GetInfo_result',
$this->input_->isStrictRead()
);
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \TCLIService_GetInfo_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("GetInfo failed: unknown result");
}
public function ExecuteStatement(\TExecuteStatementReq $req)
{
$this->send_ExecuteStatement($req);
return $this->recv_ExecuteStatement();
}
public function send_ExecuteStatement(\TExecuteStatementReq $req)
{
$args = new \TCLIService_ExecuteStatement_args();
$args->req = $req;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel) {
thrift_protocol_write_binary(
$this->output_,
'ExecuteStatement',
TMessageType::CALL,
$args,
$this->seqid_,
$this->output_->isStrictWrite()
);
} else {
$this->output_->writeMessageBegin('ExecuteStatement', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
public function recv_ExecuteStatement()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary(
$this->input_,
'\TCLIService_ExecuteStatement_result',
$this->input_->isStrictRead()
);
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \TCLIService_ExecuteStatement_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("ExecuteStatement failed: unknown result");
}
public function GetTypeInfo(\TGetTypeInfoReq $req)
{
$this->send_GetTypeInfo($req);
return $this->recv_GetTypeInfo();
}
public function send_GetTypeInfo(\TGetTypeInfoReq $req)
{
$args = new \TCLIService_GetTypeInfo_args();
$args->req = $req;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel) {
thrift_protocol_write_binary(
$this->output_,
'GetTypeInfo',
TMessageType::CALL,
$args,
$this->seqid_,
$this->output_->isStrictWrite()
);
} else {
$this->output_->writeMessageBegin('GetTypeInfo', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
public function recv_GetTypeInfo()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary(
$this->input_,
'\TCLIService_GetTypeInfo_result',
$this->input_->isStrictRead()
);
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \TCLIService_GetTypeInfo_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("GetTypeInfo failed: unknown result");
}
public function GetCatalogs(\TGetCatalogsReq $req)
{
$this->send_GetCatalogs($req);
return $this->recv_GetCatalogs();
}
public function send_GetCatalogs(\TGetCatalogsReq $req)
{
$args = new \TCLIService_GetCatalogs_args();
$args->req = $req;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel) {
thrift_protocol_write_binary(
$this->output_,
'GetCatalogs',
TMessageType::CALL,
$args,
$this->seqid_,
$this->output_->isStrictWrite()
);
} else {
$this->output_->writeMessageBegin('GetCatalogs', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
public function recv_GetCatalogs()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary(
$this->input_,
'\TCLIService_GetCatalogs_result',
$this->input_->isStrictRead()
);
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \TCLIService_GetCatalogs_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("GetCatalogs failed: unknown result");
}
public function GetSchemas(\TGetSchemasReq $req)
{
$this->send_GetSchemas($req);
return $this->recv_GetSchemas();
}
public function send_GetSchemas(\TGetSchemasReq $req)
{
$args = new \TCLIService_GetSchemas_args();
$args->req = $req;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel) {
thrift_protocol_write_binary(
$this->output_,
'GetSchemas',
TMessageType::CALL,
$args,
$this->seqid_,
$this->output_->isStrictWrite()
);
} else {
$this->output_->writeMessageBegin('GetSchemas', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
public function recv_GetSchemas()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary(
$this->input_,
'\TCLIService_GetSchemas_result',
$this->input_->isStrictRead()
);
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \TCLIService_GetSchemas_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("GetSchemas failed: unknown result");
}
public function GetTables(\TGetTablesReq $req)
{
$this->send_GetTables($req);
return $this->recv_GetTables();
}
public function send_GetTables(\TGetTablesReq $req)
{
$args = new \TCLIService_GetTables_args();
$args->req = $req;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel) {
thrift_protocol_write_binary(
$this->output_,
'GetTables',
TMessageType::CALL,
$args,
$this->seqid_,
$this->output_->isStrictWrite()
);
} else {
$this->output_->writeMessageBegin('GetTables', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
public function recv_GetTables()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary(
$this->input_,
'\TCLIService_GetTables_result',
$this->input_->isStrictRead()
);
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \TCLIService_GetTables_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("GetTables failed: unknown result");
}
public function GetTableTypes(\TGetTableTypesReq $req)
{
$this->send_GetTableTypes($req);
return $this->recv_GetTableTypes();
}
public function send_GetTableTypes(\TGetTableTypesReq $req)
{
$args = new \TCLIService_GetTableTypes_args();
$args->req = $req;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel) {
thrift_protocol_write_binary(
$this->output_,
'GetTableTypes',
TMessageType::CALL,
$args,
$this->seqid_,
$this->output_->isStrictWrite()
);
} else {
$this->output_->writeMessageBegin('GetTableTypes', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
public function recv_GetTableTypes()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary(
$this->input_,
'\TCLIService_GetTableTypes_result',
$this->input_->isStrictRead()
);
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \TCLIService_GetTableTypes_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("GetTableTypes failed: unknown result");
}
public function GetColumns(\TGetColumnsReq $req)
{
$this->send_GetColumns($req);
return $this->recv_GetColumns();
}
public function send_GetColumns(\TGetColumnsReq $req)
{
$args = new \TCLIService_GetColumns_args();
$args->req = $req;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel) {
thrift_protocol_write_binary(
$this->output_,
'GetColumns',
TMessageType::CALL,
$args,
$this->seqid_,
$this->output_->isStrictWrite()
);
} else {
$this->output_->writeMessageBegin('GetColumns', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
public function recv_GetColumns()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary(
$this->input_,
'\TCLIService_GetColumns_result',
$this->input_->isStrictRead()
);
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \TCLIService_GetColumns_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("GetColumns failed: unknown result");
}
public function GetFunctions(\TGetFunctionsReq $req)
{
$this->send_GetFunctions($req);
return $this->recv_GetFunctions();
}
public function send_GetFunctions(\TGetFunctionsReq $req)
{
$args = new \TCLIService_GetFunctions_args();
$args->req = $req;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel) {
thrift_protocol_write_binary(
$this->output_,
'GetFunctions',
TMessageType::CALL,
$args,
$this->seqid_,
$this->output_->isStrictWrite()
);
} else {
$this->output_->writeMessageBegin('GetFunctions', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
public function recv_GetFunctions()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary(
$this->input_,
'\TCLIService_GetFunctions_result',
$this->input_->isStrictRead()
);
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \TCLIService_GetFunctions_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("GetFunctions failed: unknown result");
}
public function GetPrimaryKeys(\TGetPrimaryKeysReq $req)
{
$this->send_GetPrimaryKeys($req);
return $this->recv_GetPrimaryKeys();
}
public function send_GetPrimaryKeys(\TGetPrimaryKeysReq $req)
{
$args = new \TCLIService_GetPrimaryKeys_args();
$args->req = $req;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel) {
thrift_protocol_write_binary(
$this->output_,
'GetPrimaryKeys',
TMessageType::CALL,
$args,
$this->seqid_,
$this->output_->isStrictWrite()
);
} else {
$this->output_->writeMessageBegin('GetPrimaryKeys', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
public function recv_GetPrimaryKeys()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary(
$this->input_,
'\TCLIService_GetPrimaryKeys_result',
$this->input_->isStrictRead()
);
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \TCLIService_GetPrimaryKeys_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("GetPrimaryKeys failed: unknown result");
}
public function GetCrossReference(\TGetCrossReferenceReq $req)
{
$this->send_GetCrossReference($req);
return $this->recv_GetCrossReference();
}
public function send_GetCrossReference(\TGetCrossReferenceReq $req)
{
$args = new \TCLIService_GetCrossReference_args();
$args->req = $req;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel) {
thrift_protocol_write_binary(
$this->output_,
'GetCrossReference',
TMessageType::CALL,
$args,
$this->seqid_,
$this->output_->isStrictWrite()
);
} else {
$this->output_->writeMessageBegin('GetCrossReference', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
public function recv_GetCrossReference()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary(
$this->input_,
'\TCLIService_GetCrossReference_result',
$this->input_->isStrictRead()
);
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \TCLIService_GetCrossReference_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("GetCrossReference failed: unknown result");
}
public function GetOperationStatus(\TGetOperationStatusReq $req)
{
$this->send_GetOperationStatus($req);
return $this->recv_GetOperationStatus();
}
public function send_GetOperationStatus(\TGetOperationStatusReq $req)
{
$args = new \TCLIService_GetOperationStatus_args();
$args->req = $req;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel) {
thrift_protocol_write_binary(
$this->output_,
'GetOperationStatus',
TMessageType::CALL,
$args,
$this->seqid_,
$this->output_->isStrictWrite()
);
} else {
$this->output_->writeMessageBegin('GetOperationStatus', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
public function recv_GetOperationStatus()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary(
$this->input_,
'\TCLIService_GetOperationStatus_result',
$this->input_->isStrictRead()
);
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \TCLIService_GetOperationStatus_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("GetOperationStatus failed: unknown result");
}
public function CancelOperation(\TCancelOperationReq $req)
{
$this->send_CancelOperation($req);
return $this->recv_CancelOperation();
}
public function send_CancelOperation(\TCancelOperationReq $req)
{
$args = new \TCLIService_CancelOperation_args();
$args->req = $req;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel) {
thrift_protocol_write_binary(
$this->output_,
'CancelOperation',
TMessageType::CALL,
$args,
$this->seqid_,
$this->output_->isStrictWrite()
);
} else {
$this->output_->writeMessageBegin('CancelOperation', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
public function recv_CancelOperation()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary(
$this->input_,
'\TCLIService_CancelOperation_result',
$this->input_->isStrictRead()
);
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \TCLIService_CancelOperation_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("CancelOperation failed: unknown result");
}
public function CloseOperation(\TCloseOperationReq $req)
{
$this->send_CloseOperation($req);
return $this->recv_CloseOperation();
}
public function send_CloseOperation(\TCloseOperationReq $req)
{
$args = new \TCLIService_CloseOperation_args();
$args->req = $req;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel) {
thrift_protocol_write_binary(
$this->output_,
'CloseOperation',
TMessageType::CALL,
$args,
$this->seqid_,
$this->output_->isStrictWrite()
);
} else {
$this->output_->writeMessageBegin('CloseOperation', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
public function recv_CloseOperation()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary(
$this->input_,
'\TCLIService_CloseOperation_result',
$this->input_->isStrictRead()
);
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \TCLIService_CloseOperation_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("CloseOperation failed: unknown result");
}
public function GetResultSetMetadata(\TGetResultSetMetadataReq $req)
{
$this->send_GetResultSetMetadata($req);
return $this->recv_GetResultSetMetadata();
}
public function send_GetResultSetMetadata(\TGetResultSetMetadataReq $req)
{
$args = new \TCLIService_GetResultSetMetadata_args();
$args->req = $req;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel) {
thrift_protocol_write_binary(
$this->output_,
'GetResultSetMetadata',
TMessageType::CALL,
$args,
$this->seqid_,
$this->output_->isStrictWrite()
);
} else {
$this->output_->writeMessageBegin('GetResultSetMetadata', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
public function recv_GetResultSetMetadata()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary(
$this->input_,
'\TCLIService_GetResultSetMetadata_result',
$this->input_->isStrictRead()
);
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \TCLIService_GetResultSetMetadata_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("GetResultSetMetadata failed: unknown result");
}
public function FetchResults(\TFetchResultsReq $req)
{
$this->send_FetchResults($req);
return $this->recv_FetchResults();
}
public function send_FetchResults(\TFetchResultsReq $req)
{
$args = new \TCLIService_FetchResults_args();
$args->req = $req;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel) {
thrift_protocol_write_binary(
$this->output_,
'FetchResults',
TMessageType::CALL,
$args,
$this->seqid_,
$this->output_->isStrictWrite()
);
} else {
$this->output_->writeMessageBegin('FetchResults', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
public function recv_FetchResults()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary(
$this->input_,
'\TCLIService_FetchResults_result',
$this->input_->isStrictRead()
);
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \TCLIService_FetchResults_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("FetchResults failed: unknown result");
}
public function GetDelegationToken(\TGetDelegationTokenReq $req)
{
$this->send_GetDelegationToken($req);
return $this->recv_GetDelegationToken();
}
public function send_GetDelegationToken(\TGetDelegationTokenReq $req)
{
$args = new \TCLIService_GetDelegationToken_args();
$args->req = $req;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel) {
thrift_protocol_write_binary(
$this->output_,
'GetDelegationToken',
TMessageType::CALL,
$args,
$this->seqid_,
$this->output_->isStrictWrite()
);
} else {
$this->output_->writeMessageBegin('GetDelegationToken', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
public function recv_GetDelegationToken()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary(
$this->input_,
'\TCLIService_GetDelegationToken_result',
$this->input_->isStrictRead()
);
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \TCLIService_GetDelegationToken_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("GetDelegationToken failed: unknown result");
}
public function CancelDelegationToken(\TCancelDelegationTokenReq $req)
{
$this->send_CancelDelegationToken($req);
return $this->recv_CancelDelegationToken();
}
public function send_CancelDelegationToken(\TCancelDelegationTokenReq $req)
{
$args = new \TCLIService_CancelDelegationToken_args();
$args->req = $req;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel) {
thrift_protocol_write_binary(
$this->output_,
'CancelDelegationToken',
TMessageType::CALL,
$args,
$this->seqid_,
$this->output_->isStrictWrite()
);
} else {
$this->output_->writeMessageBegin('CancelDelegationToken', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
public function recv_CancelDelegationToken()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary(
$this->input_,
'\TCLIService_CancelDelegationToken_result',
$this->input_->isStrictRead()
);
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \TCLIService_CancelDelegationToken_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("CancelDelegationToken failed: unknown result");
}
public function RenewDelegationToken(\TRenewDelegationTokenReq $req)
{
$this->send_RenewDelegationToken($req);
return $this->recv_RenewDelegationToken();
}
public function send_RenewDelegationToken(\TRenewDelegationTokenReq $req)
{
$args = new \TCLIService_RenewDelegationToken_args();
$args->req = $req;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel) {
thrift_protocol_write_binary(
$this->output_,
'RenewDelegationToken',
TMessageType::CALL,
$args,
$this->seqid_,
$this->output_->isStrictWrite()
);
} else {
$this->output_->writeMessageBegin('RenewDelegationToken', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
public function recv_RenewDelegationToken()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary(
$this->input_,
'\TCLIService_RenewDelegationToken_result',
$this->input_->isStrictRead()
);
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \TCLIService_RenewDelegationToken_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("RenewDelegationToken failed: unknown result");
}
public function GetQueryId(\TGetQueryIdReq $req)
{
$this->send_GetQueryId($req);
return $this->recv_GetQueryId();
}
public function send_GetQueryId(\TGetQueryIdReq $req)
{
$args = new \TCLIService_GetQueryId_args();
$args->req = $req;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel) {
thrift_protocol_write_binary(
$this->output_,
'GetQueryId',
TMessageType::CALL,
$args,
$this->seqid_,
$this->output_->isStrictWrite()
);
} else {
$this->output_->writeMessageBegin('GetQueryId', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
public function recv_GetQueryId()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary(
$this->input_,
'\TCLIService_GetQueryId_result',
$this->input_->isStrictRead()
);
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \TCLIService_GetQueryId_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("GetQueryId failed: unknown result");
}
public function SetClientInfo(\TSetClientInfoReq $req)
{
$this->send_SetClientInfo($req);
return $this->recv_SetClientInfo();
}
public function send_SetClientInfo(\TSetClientInfoReq $req)
{
$args = new \TCLIService_SetClientInfo_args();
$args->req = $req;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel) {
thrift_protocol_write_binary(
$this->output_,
'SetClientInfo',
TMessageType::CALL,
$args,
$this->seqid_,
$this->output_->isStrictWrite()
);
} else {
$this->output_->writeMessageBegin('SetClientInfo', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
public function recv_SetClientInfo()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary(
$this->input_,
'\TCLIService_SetClientInfo_result',
$this->input_->isStrictRead()
);
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \TCLIService_SetClientInfo_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("SetClientInfo failed: unknown result");
}
public function UploadData(\TUploadDataReq $req)
{
$this->send_UploadData($req);
return $this->recv_UploadData();
}
public function send_UploadData(\TUploadDataReq $req)
{
$args = new \TCLIService_UploadData_args();
$args->req = $req;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel) {
thrift_protocol_write_binary(
$this->output_,
'UploadData',
TMessageType::CALL,
$args,
$this->seqid_,
$this->output_->isStrictWrite()
);
} else {
$this->output_->writeMessageBegin('UploadData', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
public function recv_UploadData()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary(
$this->input_,
'\TCLIService_UploadData_result',
$this->input_->isStrictRead()
);
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \TCLIService_UploadData_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("UploadData failed: unknown result");
}
public function DownloadData(\TDownloadDataReq $req)
{
$this->send_DownloadData($req);
return $this->recv_DownloadData();
}
public function send_DownloadData(\TDownloadDataReq $req)
{
$args = new \TCLIService_DownloadData_args();
$args->req = $req;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel) {
thrift_protocol_write_binary(
$this->output_,
'DownloadData',
TMessageType::CALL,
$args,
$this->seqid_,
$this->output_->isStrictWrite()
);
} else {
$this->output_->writeMessageBegin('DownloadData', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
public function recv_DownloadData()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary(
$this->input_,
'\TCLIService_DownloadData_result',
$this->input_->isStrictRead()
);
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \TCLIService_DownloadData_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("DownloadData failed: unknown result");
}
}