| <?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"); |
| } |
| } |