MARIJuANA
— DIOS — NO — CREA — NADA — EN — VANO —
Linux instance-20230208-1745 6.8.0-1013-oracle #13~22.04.1-Ubuntu SMP Mon Sep 2 13:02:56 UTC 2024 x86_64
  SOFT : Apache/2.4.52 (Ubuntu) PHP : 8.1.2-1ubuntu2.19
/var/www/guajeru/transparencia/assets/ckfinder/core/connector/php/vendor/microsoft/azure-storage/src/Table/
10.0.0.135

 
[ NAME ] [ SIZE ] [ PERM ] [ DATE ] [ ACT ]
+FILE +DIR
Internal dir drwxr-xr-x 2021-07-19 13:06 R D
Models dir drwxr-xr-x 2021-07-19 13:07 R D
  TableRestProxy.php 56.981 KB -rw-r--r-- 2021-07-19 12:56 R E G D
REQUEST EXIT
* @copyright 2016 Microsoft Corporation * @license https://github.com/azure/azure-storage-php/LICENSE * @link https://github.com/azure/azure-storage-php */ namespace MicrosoftAzure\Storage\Table; use MicrosoftAzure\Storage\Common\Internal\ServiceRestTrait; use MicrosoftAzure\Storage\Common\Internal\Resources; use MicrosoftAzure\Storage\Common\Internal\Validate; use MicrosoftAzure\Storage\Common\Internal\Http\HttpCallContext; use MicrosoftAzure\Storage\Common\Internal\ServiceRestProxy; use MicrosoftAzure\Storage\Common\LocationMode; use MicrosoftAzure\Storage\Table\Internal\ITable; use MicrosoftAzure\Storage\Table\Models\TableServiceOptions; use MicrosoftAzure\Storage\Table\Models\EdmType; use MicrosoftAzure\Storage\Table\Models\Entity; use MicrosoftAzure\Storage\Table\Models\Query; use MicrosoftAzure\Storage\Table\Models\Filters\Filter; use MicrosoftAzure\Storage\Table\Models\Filters\PropertyNameFilter; use MicrosoftAzure\Storage\Table\Models\Filters\ConstantFilter; use MicrosoftAzure\Storage\Table\Models\Filters\UnaryFilter; use MicrosoftAzure\Storage\Table\Models\Filters\BinaryFilter; use MicrosoftAzure\Storage\Table\Models\Filters\QueryStringFilter; use MicrosoftAzure\Storage\Table\Models\GetTableResult; use MicrosoftAzure\Storage\Table\Models\GetTableOptions; use MicrosoftAzure\Storage\Table\Models\GetEntityOptions; use MicrosoftAzure\Storage\Table\Models\TableServiceCreateOptions; use MicrosoftAzure\Storage\Table\Models\QueryTablesOptions; use MicrosoftAzure\Storage\Table\Models\QueryTablesResult; use MicrosoftAzure\Storage\Table\Models\InsertEntityResult; use MicrosoftAzure\Storage\Table\Models\UpdateEntityResult; use MicrosoftAzure\Storage\Table\Models\QueryEntitiesOptions; use MicrosoftAzure\Storage\Table\Models\QueryEntitiesResult; use MicrosoftAzure\Storage\Table\Models\DeleteEntityOptions; use MicrosoftAzure\Storage\Table\Models\GetEntityResult; use MicrosoftAzure\Storage\Table\Models\BatchOperationType; use MicrosoftAzure\Storage\Table\Models\BatchOperationParameterName; use MicrosoftAzure\Storage\Table\Models\BatchResult; use MicrosoftAzure\Storage\Table\Models\TableACL; use MicrosoftAzure\Storage\Common\Internal\Http\HttpFormatter; use MicrosoftAzure\Storage\Table\Internal\IODataReaderWriter; use MicrosoftAzure\Storage\Table\Internal\IMimeReaderWriter; use MicrosoftAzure\Storage\Common\Internal\Serialization\ISerializer; /** * This class constructs HTTP requests and receive HTTP responses for table * service layer. * * @category Microsoft * @package MicrosoftAzure\Storage\Table * @author Azure Storage PHP SDK * @copyright 2016 Microsoft Corporation * @license https://github.com/azure/azure-storage-php/LICENSE * @link https://github.com/azure/azure-storage-php */ class TableRestProxy extends ServiceRestProxy implements ITable { use ServiceRestTrait; /** * @var Internal\IODataReaderWriter */ private $odataSerializer; /** * @var Internal\IMimeReaderWriter */ private $mimeSerializer; /** * Creates contexts for batch operations. * * @param array $operations The batch operations array. * * @return array * * @throws \InvalidArgumentException */ private function createOperationsContexts(array $operations) { $contexts = array(); foreach ($operations as $operation) { $context = null; $type = $operation->getType(); switch ($type) { case BatchOperationType::INSERT_ENTITY_OPERATION: case BatchOperationType::UPDATE_ENTITY_OPERATION: case BatchOperationType::MERGE_ENTITY_OPERATION: case BatchOperationType::INSERT_REPLACE_ENTITY_OPERATION: case BatchOperationType::INSERT_MERGE_ENTITY_OPERATION: $table = $operation->getParameter( BatchOperationParameterName::BP_TABLE ); $entity = $operation->getParameter( BatchOperationParameterName::BP_ENTITY ); $context = $this->getOperationContext($table, $entity, $type); break; case BatchOperationType::DELETE_ENTITY_OPERATION: $table = $operation->getParameter( BatchOperationParameterName::BP_TABLE ); $partitionKey = $operation->getParameter( BatchOperationParameterName::BP_PARTITION_KEY ); $rowKey = $operation->getParameter( BatchOperationParameterName::BP_ROW_KEY ); $etag = $operation->getParameter( BatchOperationParameterName::BP_ETAG ); $options = new DeleteEntityOptions(); $options->setETag($etag); $context = $this->constructDeleteEntityContext( $table, $partitionKey, $rowKey, $options ); break; default: throw new \InvalidArgumentException(); } $contexts[] = $context; } return $contexts; } /** * Creates operation context for the API. * * @param string $table The table name. * @param Entity $entity The entity object. * @param string $type The API type. * * @return \MicrosoftAzure\Storage\Common\Internal\Http\HttpCallContext * * @throws \InvalidArgumentException */ private function getOperationContext($table, Entity $entity, $type) { switch ($type) { case BatchOperationType::INSERT_ENTITY_OPERATION: return $this->constructInsertEntityContext($table, $entity, null); case BatchOperationType::UPDATE_ENTITY_OPERATION: return $this->constructPutOrMergeEntityContext( $table, $entity, Resources::HTTP_PUT, true, null ); case BatchOperationType::MERGE_ENTITY_OPERATION: return $this->constructPutOrMergeEntityContext( $table, $entity, Resources::HTTP_MERGE, true, null ); case BatchOperationType::INSERT_REPLACE_ENTITY_OPERATION: return $this->constructPutOrMergeEntityContext( $table, $entity, Resources::HTTP_PUT, false, null ); case BatchOperationType::INSERT_MERGE_ENTITY_OPERATION: return $this->constructPutOrMergeEntityContext( $table, $entity, Resources::HTTP_MERGE, false, null ); default: throw new \InvalidArgumentException(); } } /** * Creates MIME part body for batch API. * * @param array $operations The batch operations. * @param array $contexts The contexts objects. * * @return array * * @throws \InvalidArgumentException */ private function createBatchRequestBody(array $operations, array $contexts) { $mimeBodyParts = array(); $contentId = 1; $count = count($operations); Validate::isTrue( count($operations) == count($contexts), Resources::INVALID_OC_COUNT_MSG ); for ($i = 0; $i < $count; $i++) { $operation = $operations[$i]; $context = $contexts[$i]; $type = $operation->getType(); switch ($type) { case BatchOperationType::INSERT_ENTITY_OPERATION: case BatchOperationType::UPDATE_ENTITY_OPERATION: case BatchOperationType::MERGE_ENTITY_OPERATION: case BatchOperationType::INSERT_REPLACE_ENTITY_OPERATION: case BatchOperationType::INSERT_MERGE_ENTITY_OPERATION: $contentType = $context->getHeader(Resources::CONTENT_TYPE); $body = $context->getBody(); $contentType .= ';type=entry'; $context->addOptionalHeader(Resources::CONTENT_TYPE, $contentType); // Use mb_strlen instead of strlen to get the length of the string // in bytes instead of the length in chars. $context->addOptionalHeader( Resources::CONTENT_LENGTH, strlen($body) ); break; case BatchOperationType::DELETE_ENTITY_OPERATION: break; default: throw new \InvalidArgumentException(); } $context->addOptionalHeader(Resources::CONTENT_ID, $contentId); $mimeBodyPart = $context->__toString(); $mimeBodyParts[] = $mimeBodyPart; $contentId++; } return $this->mimeSerializer->encodeMimeMultipart($mimeBodyParts); } /** * Constructs HTTP call context for deleteEntity API. * * @param string $table The name of the table. * @param string $partitionKey The entity partition key. * @param string $rowKey The entity row key. * @param DeleteEntityOptions $options The optional parameters. * * @return HttpCallContext */ private function constructDeleteEntityContext( $table, $partitionKey, $rowKey, DeleteEntityOptions $options = null ) { Validate::canCastAsString($table, 'table'); Validate::notNullOrEmpty($table, 'table'); Validate::isTrue(!is_null($partitionKey), Resources::NULL_TABLE_KEY_MSG); Validate::isTrue(!is_null($rowKey), Resources::NULL_TABLE_KEY_MSG); $method = Resources::HTTP_DELETE; $headers = array(); $queryParams = array(); $statusCode = Resources::STATUS_NO_CONTENT; $path = $this->getEntityPath($table, $partitionKey, $rowKey); if (is_null($options)) { $options = new DeleteEntityOptions(); } $etagObj = $options->getETag(); $ETag = !is_null($etagObj); $this->addOptionalHeader( $headers, Resources::IF_MATCH, $ETag ? $etagObj : Resources::ASTERISK ); $this->addOptionalHeader( $headers, Resources::ACCEPT_HEADER, Resources::JSON_CONTENT_TYPE ); $options->setLocationMode(LocationMode::PRIMARY_ONLY); $context = new HttpCallContext(); $context->setHeaders($headers); $context->setMethod($method); $context->setPath($path); $context->setQueryParameters($queryParams); $context->addStatusCode($statusCode); $context->setBody(''); $context->setServiceOptions($options); return $context; } /** * Constructs HTTP call context for updateEntity, mergeEntity, * insertOrReplaceEntity and insertOrMergeEntity. * * @param string $table The table name. * @param Entity $entity The entity instance to use. * @param string $verb The HTTP method. * @param boolean $useETag The flag to include etag or not. * @param TableServiceOptions $options The optional parameters. * * @return HttpCallContext */ private function constructPutOrMergeEntityContext( $table, Entity $entity, $verb, $useETag, TableServiceOptions $options = null ) { Validate::canCastAsString($table, 'table'); Validate::notNullOrEmpty($table, 'table'); Validate::notNullOrEmpty($entity, 'entity'); Validate::isTrue($entity->isValid($msg), $msg); $method = $verb; $headers = array(); $queryParams = array(); $statusCode = Resources::STATUS_NO_CONTENT; $partitionKey = $entity->getPartitionKey(); $rowKey = $entity->getRowKey(); $path = $this->getEntityPath($table, $partitionKey, $rowKey); $body = $this->odataSerializer->getEntity($entity); if (is_null($options)) { $options = new TableServiceOptions(); } if ($useETag) { $etag = $entity->getETag(); $ifMatchValue = is_null($etag) ? Resources::ASTERISK : $etag; $this->addOptionalHeader($headers, Resources::IF_MATCH, $ifMatchValue); } $this->addOptionalHeader( $headers, Resources::CONTENT_TYPE, Resources::JSON_CONTENT_TYPE ); $this->addOptionalHeader( $headers, Resources::ACCEPT_HEADER, Resources::JSON_FULL_METADATA_CONTENT_TYPE ); $options->setLocationMode(LocationMode::PRIMARY_ONLY); $context = new HttpCallContext(); $context->setBody($body); $context->setHeaders($headers); $context->setMethod($method); $context->setPath($path); $context->setQueryParameters($queryParams); $context->addStatusCode($statusCode); $context->setServiceOptions($options); return $context; } /** * Constructs HTTP call context for insertEntity API. * * @param string $table The name of the table. * @param Entity $entity The table entity. * @param TableServiceCreateOptions $options The optional parameters. * * @return HttpCallContext */ private function constructInsertEntityContext( $table, Entity $entity, TableServiceCreateOptions $options = null ) { Validate::canCastAsString($table, 'table'); Validate::notNullOrEmpty($table, 'table'); Validate::notNullOrEmpty($entity, 'entity'); Validate::isTrue($entity->isValid($msg), $msg); $method = Resources::HTTP_POST; $context = new HttpCallContext(); $headers = array(); $queryParams = array(); $statusCode = Resources::STATUS_CREATED; $path = $table; $body = $this->odataSerializer->getEntity($entity); if (is_null($options)) { $options = new TableServiceCreateOptions(); } $this->addOptionalHeader( $headers, Resources::CONTENT_TYPE, Resources::JSON_CONTENT_TYPE ); $this->addOptionalHeader( $headers, Resources::ACCEPT_HEADER, $options->getAccept() ); $this->addOptionalHeader( $headers, Resources::PREFER, $options->getDoesReturnContent() ? Resources::RETURN_CONTENT : null ); $options->setLocationMode(LocationMode::PRIMARY_ONLY); $context->setBody($body); $context->setHeaders($headers); $context->setMethod($method); $context->setPath($path); $context->setQueryParameters($queryParams); $context->addStatusCode($statusCode); $context->setServiceOptions($options); return $context; } /** * Constructs URI path for entity. * * @param string $table The table name. * @param string $partitionKey The entity's partition key. * @param string $rowKey The entity's row key. * * @return string */ private function getEntityPath($table, $partitionKey, $rowKey) { $encodedPK = $this->encodeODataUriValue($partitionKey); $encodedRK = $this->encodeODataUriValue($rowKey); return "$table(PartitionKey='$encodedPK',RowKey='$encodedRK')"; } /** * Creates a promie that does the actual work for update and merge entity * APIs. * * @param string $table The table name. * @param Entity $entity The entity instance to use. * @param string $verb The HTTP method. * @param boolean $useETag The flag to include etag or not. * @param TableServiceOptions $options The optional parameters. * * @return \GuzzleHttp\Promise\PromiseInterface */ private function putOrMergeEntityAsyncImpl( $table, Entity $entity, $verb, $useETag, TableServiceOptions $options = null ) { $context = $this->constructPutOrMergeEntityContext( $table, $entity, $verb, $useETag, $options ); return $this->sendContextAsync($context)->then(function ($response) { return UpdateEntityResult::create( HttpFormatter::formatHeaders($response->getHeaders()) ); }, null); } /** * Builds filter expression * * @param Filter $filter The filter object * * @return string */ private function buildFilterExpression(Filter $filter) { $e = Resources::EMPTY_STRING; $this->buildFilterExpressionRec($filter, $e); return $e; } /** * Builds filter expression * * @param Filter $filter The filter object * @param string &$e The filter expression * * @return string */ private function buildFilterExpressionRec(Filter $filter, &$e) { if (is_null($filter)) { return; } if ($filter instanceof PropertyNameFilter) { $e .= $filter->getPropertyName(); } elseif ($filter instanceof ConstantFilter) { $value = $filter->getValue(); // If the value is null we just append null regardless of the edmType. if (is_null($value)) { $e .= 'null'; } else { $type = $filter->getEdmType(); $e .= EdmType::serializeQueryValue($type, $value); } } elseif ($filter instanceof UnaryFilter) { $e .= $filter->getOperator(); $e .= '('; $this->buildFilterExpressionRec($filter->getOperand(), $e); $e .= ')'; } elseif ($filter instanceof BinaryFilter) { $e .= '('; $this->buildFilterExpressionRec($filter->getLeft(), $e); $e .= ' '; $e .= $filter->getOperator(); $e .= ' '; $this->buildFilterExpressionRec($filter->getRight(), $e); $e .= ')'; } elseif ($filter instanceof QueryStringFilter) { $e .= $filter->getQueryString(); } return $e; } /** * Adds query object to the query parameter array * * @param array $queryParam The URI query parameters * @param Query $query The query object * * @return array */ private function addOptionalQuery(array $queryParam, Query $query) { if (!is_null($query)) { $selectedFields = $query->getSelectFields(); if (!empty($selectedFields)) { $final = $this->encodeODataUriValues($selectedFields); $this->addOptionalQueryParam( $queryParam, Resources::QP_SELECT, implode(',', $final) ); } if (!is_null($query->getTop())) { $final = strval($this->encodeODataUriValue($query->getTop())); $this->addOptionalQueryParam( $queryParam, Resources::QP_TOP, $final ); } if (!is_null($query->getFilter())) { $final = $this->buildFilterExpression($query->getFilter()); $this->addOptionalQueryParam( $queryParam, Resources::QP_FILTER, $final ); } } return $queryParam; } /** * Encodes OData URI values * * @param array $values The OData URL values * * @return array */ private function encodeODataUriValues(array $values) { $list = array(); foreach ($values as $value) { $list[] = $this->encodeODataUriValue($value); } return $list; } /** * Encodes OData URI value * * @param string $value The OData URL value * * @return string */ private function encodeODataUriValue($value) { // Replace each single quote (') with double single quotes ('') not doudle // quotes (") $value = str_replace('\'', '\'\'', $value); // Encode the special URL characters $value = rawurlencode($value); return $value; } /** * Initializes new TableRestProxy object. * * @param string $primaryUri The storage account primary uri. * @param string $secondaryUri The storage account secondary uri. * @param IODataReaderWriter $odataSerializer The odata serializer. * @param IMimeReaderWriter $mimeSerializer The MIME serializer. * @param ISerializer $dataSerializer The data serializer. * @param array $options Array of options to pass to * the service */ public function __construct( $primaryUri, $secondaryUri, IODataReaderWriter $odataSerializer, IMimeReaderWriter $mimeSerializer, ISerializer $dataSerializer, array $options = [] ) { parent::__construct( $primaryUri, $secondaryUri, Resources::EMPTY_STRING, $dataSerializer, $options ); $this->odataSerializer = $odataSerializer; $this->mimeSerializer = $mimeSerializer; } /** * Quries tables in the given storage account. * * @param QueryTablesOptions|string|Filter $options Could be optional * parameters, table prefix * or filter to apply. * * @return QueryTablesResult * * @see https://docs.microsoft.com/en-us/rest/api/storageservices/query-tables */ public function queryTables($options = null) { return $this->queryTablesAsync($options)->wait(); } /** * Creates promise to query the tables in the given storage account. * * @param QueryTablesOptions|string|Filter $options Could be optional * parameters, table prefix * or filter to apply. * * @return \GuzzleHttp\Promise\PromiseInterface * * @see https://docs.microsoft.com/en-us/rest/api/storageservices/query-tables */ public function queryTablesAsync($options = null) { $method = Resources::HTTP_GET; $headers = array(); $postParams = array(); $queryParams = array(); $path = 'Tables'; if (is_null($options)) { $options = new QueryTablesOptions(); } elseif (is_string($options)) { $prefix = $options; $options = new QueryTablesOptions(); $options->setPrefix($prefix); } elseif ($options instanceof Filter) { $filter = $options; $options = new QueryTablesOptions(); $options->setFilter($filter); } $query = $options->getQuery(); $next = $options->getNextTableName(); $prefix = $options->getPrefix(); if (!empty($prefix)) { // Append Max char to end '{' is 1 + 'z' in AsciiTable ==> upperBound // is prefix + '{' $prefixFilter = Filter::applyAnd( Filter::applyGe( Filter::applyPropertyName('TableName'), Filter::applyConstant($prefix, EdmType::STRING) ), Filter::applyLe( Filter::applyPropertyName('TableName'), Filter::applyConstant($prefix . '{', EdmType::STRING) ) ); if (is_null($query)) { $query = new Query(); } if (is_null($query->getFilter())) { // use the prefix filter if the query filter is null $query->setFilter($prefixFilter); } else { // combine and use the prefix filter if the query filter exists $combinedFilter = Filter::applyAnd( $query->getFilter(), $prefixFilter ); $query->setFilter($combinedFilter); } } $queryParams = $this->addOptionalQuery($queryParams, $query); $this->addOptionalQueryParam( $queryParams, Resources::QP_NEXT_TABLE_NAME, $next ); $this->addOptionalHeader( $headers, Resources::ACCEPT_HEADER, $options->getAccept() ); // One can specify the NextTableName option to get table entities starting // from the specified name. However, there appears to be an issue in the // Azure Table service where this does not engage on the server unless // $filter appears in the URL. The current behavior is to just ignore the // NextTableName options, which is not expected or easily detectable. if (array_key_exists(Resources::QP_NEXT_TABLE_NAME, $queryParams) && !array_key_exists(Resources::QP_FILTER, $queryParams) ) { $queryParams[Resources::QP_FILTER] = Resources::EMPTY_STRING; } $odataSerializer = $this->odataSerializer; return $this->sendAsync( $method, $headers, $queryParams, $postParams, $path, Resources::STATUS_OK, Resources::EMPTY_STRING, $options )->then(function ($response) use ($odataSerializer) { $tables = $odataSerializer->parseTableEntries($response->getBody()); return QueryTablesResult::create( HttpFormatter::formatHeaders($response->getHeaders()), $tables ); }, null); } /** * Creates new table in the storage account * * @param string $table The name of the table. * @param TableServiceCreateOptions $options The optional parameters. * * @return \Psr\Http\Message\ResponseInterface * * @see https://docs.microsoft.com/en-us/rest/api/storageservices/create-table */ public function createTable($table, TableServiceCreateOptions $options = null) { return $this->createTableAsync($table, $options)->wait(); } /** * Creates promise to create new table in the storage account * * @param string $table The name of the table. * @param TableServiceCreateOptions $options The optional parameters. * * @return \GuzzleHttp\Promise\PromiseInterface * * @see https://docs.microsoft.com/en-us/rest/api/storageservices/create-table */ public function createTableAsync( $table, TableServiceCreateOptions $options = null ) { Validate::canCastAsString($table, 'table'); Validate::notNullOrEmpty($table, 'table'); $method = Resources::HTTP_POST; $headers = array(); $postParams = array(); $queryParams = array(); $path = 'Tables'; $body = $this->odataSerializer->getTable($table); if (is_null($options)) { $options = new TableServiceCreateOptions(); } $this->addOptionalHeader( $headers, Resources::CONTENT_TYPE, Resources::JSON_CONTENT_TYPE ); $this->addOptionalHeader( $headers, Resources::ACCEPT_HEADER, $options->getAccept() ); $this->addOptionalHeader( $headers, Resources::PREFER, $options->getDoesReturnContent() ? Resources::RETURN_CONTENT : null ); $options->setLocationMode(LocationMode::PRIMARY_ONLY); return $this->sendAsync( $method, $headers, $queryParams, $postParams, $path, Resources::STATUS_CREATED, $body, $options ); } /** * Gets the table. * * @param string $table The name of the table. * @param GetTableOptions $options The optional parameters. * * @return GetTableResult */ public function getTable($table, GetTableOptions $options = null) { return $this->getTableAsync($table, $options)->wait(); } /** * Creates the promise to get the table. * * @param string $table The name of the table. * @param GetTableOptions $options The optional parameters. * * @return \GuzzleHttp\Promise\PromiseInterface */ public function getTableAsync( $table, GetTableOptions $options = null ) { Validate::canCastAsString($table, 'table'); Validate::notNullOrEmpty($table, 'table'); $method = Resources::HTTP_GET; $headers = array(); $postParams = array(); $queryParams = array(); $path = "Tables('$table')"; if (is_null($options)) { $options = new GetTableOptions(); } $this->addOptionalHeader( $headers, Resources::CONTENT_TYPE, Resources::JSON_CONTENT_TYPE ); $this->addOptionalHeader( $headers, Resources::ACCEPT_HEADER, $options->getAccept() ); $odataSerializer = $this->odataSerializer; return $this->sendAsync( $method, $headers, $queryParams, $postParams, $path, Resources::STATUS_OK, Resources::EMPTY_STRING, $options )->then(function ($response) use ($odataSerializer) { return GetTableResult::create($response->getBody(), $odataSerializer); }, null); } /** * Deletes the specified table and any data it contains. * * @param string $table The name of the table. * @param TableServiceOptions $options optional parameters * * @return void * * @see http://msdn.microsoft.com/en-us/library/windowsazure/dd179387.aspx */ public function deleteTable($table, TableServiceOptions $options = null) { $this->deleteTableAsync($table, $options)->wait(); } /** * Creates promise to delete the specified table and any data it contains. * * @param string $table The name of the table. * @param TableServiceOptions $options optional parameters * * @return \GuzzleHttp\Promise\PromiseInterface * * @see http://msdn.microsoft.com/en-us/library/windowsazure/dd179387.aspx */ public function deleteTableAsync( $table, TableServiceOptions$options = null ) { Validate::canCastAsString($table, 'table'); Validate::notNullOrEmpty($table, 'table'); $method = Resources::HTTP_DELETE; $headers = array(); $postParams = array(); $queryParams = array(); $path = "Tables('$table')"; if (is_null($options)) { $options = new TableServiceOptions(); } return $this->sendAsync( $method, $headers, $queryParams, $postParams, $path, Resources::STATUS_NO_CONTENT, Resources::EMPTY_STRING, $options ); } /** * Quries entities for the given table name * * @param string $table The name of * the table. * @param QueryEntitiesOptions|string|Filter $options Coule be optional * parameters, query * string or filter to * apply. * * @return QueryEntitiesResult * * @see https://docs.microsoft.com/en-us/rest/api/storageservices/query-entities */ public function queryEntities($table, $options = null) { return $this->queryEntitiesAsync($table, $options)->wait(); } /** * Quries entities for the given table name * * @param string $table The name of the table. * @param QueryEntitiesOptions|string|Filter $options Coule be optional * parameters, query * string or filter to * apply. * * @return \GuzzleHttp\Promise\PromiseInterface * * @see https://docs.microsoft.com/en-us/rest/api/storageservices/query-entities */ public function queryEntitiesAsync($table, $options = null) { Validate::canCastAsString($table, 'table'); Validate::notNullOrEmpty($table, 'table'); $method = Resources::HTTP_GET; $headers = array(); $postParams = array(); $queryParams = array(); $path = $table; if (is_null($options)) { $options = new QueryEntitiesOptions(); } elseif (is_string($options)) { $queryString = $options; $options = new QueryEntitiesOptions(); $options->setFilter(Filter::applyQueryString($queryString)); } elseif ($options instanceof Filter) { $filter = $options; $options = new QueryEntitiesOptions(); $options->setFilter($filter); } $queryParams = $this->addOptionalQuery($queryParams, $options->getQuery()); $this->addOptionalQueryParam( $queryParams, Resources::QP_NEXT_PK, $options->getNextPartitionKey() ); $this->addOptionalQueryParam( $queryParams, Resources::QP_NEXT_RK, $options->getNextRowKey() ); $this->addOptionalHeader( $headers, Resources::CONTENT_TYPE, Resources::JSON_CONTENT_TYPE ); $this->addOptionalHeader( $headers, Resources::ACCEPT_HEADER, $options->getAccept() ); if (!is_null($options->getQuery())) { $dsHeader = Resources::DATA_SERVICE_VERSION; $maxdsValue = Resources::MAX_DATA_SERVICE_VERSION_VALUE; $fields = $options->getQuery()->getSelectFields(); $hasSelect = !empty($fields); if ($hasSelect) { $this->addOptionalHeader($headers, $dsHeader, $maxdsValue); } } $odataSerializer = $this->odataSerializer; return $this->sendAsync( $method, $headers, $queryParams, $postParams, $path, Resources::STATUS_OK, Resources::EMPTY_STRING, $options )->then(function ($response) use ($odataSerializer) { $entities = $odataSerializer->parseEntities($response->getBody()); return QueryEntitiesResult::create( HttpFormatter::formatHeaders($response->getHeaders()), $entities ); }, null); } /** * Inserts new entity to the table. * * @param string $table name of the table. * @param Entity $entity table entity. * @param TableServiceCreateOptions $options optional parameters. * * @return InsertEntityResult * * @see https://docs.microsoft.com/en-us/rest/api/storageservices/insert-entity */ public function insertEntity( $table, Entity $entity, TableServiceCreateOptions $options = null ) { return $this->insertEntityAsync($table, $entity, $options)->wait(); } /** * Inserts new entity to the table. * * @param string $table name of the table. * @param Entity $entity table entity. * @param TableServiceCreateOptions $options optional parameters. * * @return \GuzzleHttp\Promise\PromiseInterface * * @see https://docs.microsoft.com/en-us/rest/api/storageservices/insert-entity */ public function insertEntityAsync( $table, Entity $entity, TableServiceCreateOptions $options = null ) { $context = $this->constructInsertEntityContext( $table, $entity, $options ); $odataSerializer = $this->odataSerializer; return $this->sendContextAsync($context)->then( function ($response) use ($odataSerializer) { $body = $response->getBody(); $headers = HttpFormatter::formatHeaders($response->getHeaders()); return InsertEntityResult::create( $body, $headers, $odataSerializer ); }, null ); } /** * Updates an existing entity or inserts a new entity if it does not exist * in the table. * * @param string $table name of the table * @param Entity $entity table entity * @param TableServiceOptions $options optional parameters * * @return UpdateEntityResult * * @see http://msdn.microsoft.com/en-us/library/windowsazure/hh452241.aspx */ public function insertOrMergeEntity( $table, Entity $entity, TableServiceOptions $options = null ) { return $this->insertOrMergeEntityAsync($table, $entity, $options)->wait(); } /** * Creates promise to update an existing entity or inserts a new entity if * it does not exist in the table. * * @param string $table name of the table * @param Entity $entity table entity * @param TableServiceOptions $options optional parameters * * @return \GuzzleHttp\Promise\PromiseInterface * * @see http://msdn.microsoft.com/en-us/library/windowsazure/hh452241.aspx */ public function insertOrMergeEntityAsync( $table, Entity $entity, TableServiceOptions $options = null ) { return $this->putOrMergeEntityAsyncImpl( $table, $entity, Resources::HTTP_MERGE, false, $options ); } /** * Replaces an existing entity or inserts a new entity if it does not exist in * the table. * * @param string $table name of the table * @param Entity $entity table entity * @param TableServiceOptions $options optional parameters * * @return UpdateEntityResult * * @see http://msdn.microsoft.com/en-us/library/windowsazure/hh452242.aspx */ public function insertOrReplaceEntity( $table, Entity $entity, TableServiceOptions $options = null ) { return $this->insertOrReplaceEntityAsync( $table, $entity, $options )->wait(); } /** * Creates a promise to replace an existing entity or inserts a new entity if it does not exist in the table. * * @param string $table name of the table * @param Entity $entity table entity * @param TableServiceOptions $options optional parameters * * @return \GuzzleHttp\Promise\PromiseInterface * * @see http://msdn.microsoft.com/en-us/library/windowsazure/hh452242.aspx */ public function insertOrReplaceEntityAsync( $table, Entity $entity, TableServiceOptions $options = null ) { return $this->putOrMergeEntityAsyncImpl( $table, $entity, Resources::HTTP_PUT, false, $options ); } /** * Updates an existing entity in a table. The Update Entity operation replaces * the entire entity and can be used to remove properties. * * @param string $table The table name. * @param Entity $entity The table entity. * @param TableServiceOptions $options The optional parameters. * * @return UpdateEntityResult * * @see http://msdn.microsoft.com/en-us/library/windowsazure/dd179427.aspx */ public function updateEntity( $table, Entity $entity, TableServiceOptions $options = null ) { return $this->updateEntityAsync($table, $entity, $options)->wait(); } /** * Creates promise to update an existing entity in a table. The Update Entity * operation replaces the entire entity and can be used to remove properties. * * @param string $table The table name. * @param Entity $entity The table entity. * @param TableServiceOptions $options The optional parameters. * * @return \GuzzleHttp\Promise\PromiseInterface * * @see http://msdn.microsoft.com/en-us/library/windowsazure/dd179427.aspx */ public function updateEntityAsync( $table, Entity $entity, TableServiceOptions $options = null ) { return $this->putOrMergeEntityAsyncImpl( $table, $entity, Resources::HTTP_PUT, true, $options ); } /** * Updates an existing entity by updating the entity's properties. This operation * does not replace the existing entity, as the updateEntity operation does. * * @param string $table The table name. * @param Entity $entity The table entity. * @param TableServiceOptions $options The optional parameters. * * @return Models\UpdateEntityResult * * @see http://msdn.microsoft.com/en-us/library/windowsazure/dd179392.aspx */ public function mergeEntity( $table, Entity $entity, TableServiceOptions $options = null ) { return $this->mergeEntityAsync($table, $entity, $options)->wait(); } /** * Creates promise to update an existing entity by updating the entity's * properties. This operation does not replace the existing entity, as the * updateEntity operation does. * * @param string $table The table name. * @param Entity $entity The table entity. * @param TableServiceOptions $options The optional parameters. * * @return \GuzzleHttp\Promise\PromiseInterface * * @see http://msdn.microsoft.com/en-us/library/windowsazure/dd179392.aspx */ public function mergeEntityAsync( $table, Entity $entity, TableServiceOptions $options = null ) { return $this->putOrMergeEntityAsyncImpl( $table, $entity, Resources::HTTP_MERGE, true, $options ); } /** * Deletes an existing entity in a table. * * @param string $table The name of the table. * @param string $partitionKey The entity partition key. * @param string $rowKey The entity row key. * @param DeleteEntityOptions $options The optional parameters. * * @return void * * @see http://msdn.microsoft.com/en-us/library/windowsazure/dd135727.aspx */ public function deleteEntity( $table, $partitionKey, $rowKey, DeleteEntityOptions $options = null ) { $this->deleteEntityAsync($table, $partitionKey, $rowKey, $options)->wait(); } /** * Creates promise to delete an existing entity in a table. * * @param string $table The name of the table. * @param string $partitionKey The entity partition key. * @param string $rowKey The entity row key. * @param DeleteEntityOptions $options The optional parameters. * * @return \GuzzleHttp\Promise\PromiseInterface * * @see http://msdn.microsoft.com/en-us/library/windowsazure/dd135727.aspx */ public function deleteEntityAsync( $table, $partitionKey, $rowKey, DeleteEntityOptions $options = null ) { $context = $this->constructDeleteEntityContext(