diff options
author | Pierre Schmitz <pierre@archlinux.de> | 2015-12-20 09:00:55 +0100 |
---|---|---|
committer | Pierre Schmitz <pierre@archlinux.de> | 2015-12-20 09:00:55 +0100 |
commit | a2190ac74dd4d7080b12bab90e552d7aa81209ef (patch) | |
tree | 8b31f38de9882d18df54cf8d9e0de74167a094eb /vendor/ruflin/elastica/lib/Elastica/Bulk/Action.php | |
parent | 15e69f7b20b6596b9148030acce5b59993b95a45 (diff) | |
parent | 257401d8b2cf661adf36c84b0e3fd1cf85e33c22 (diff) |
Merge branch 'mw-1.26'
Diffstat (limited to 'vendor/ruflin/elastica/lib/Elastica/Bulk/Action.php')
-rw-r--r-- | vendor/ruflin/elastica/lib/Elastica/Bulk/Action.php | 45 |
1 files changed, 27 insertions, 18 deletions
diff --git a/vendor/ruflin/elastica/lib/Elastica/Bulk/Action.php b/vendor/ruflin/elastica/lib/Elastica/Bulk/Action.php index 7922ec13..25d02adc 100644 --- a/vendor/ruflin/elastica/lib/Elastica/Bulk/Action.php +++ b/vendor/ruflin/elastica/lib/Elastica/Bulk/Action.php @@ -1,16 +1,15 @@ <?php - namespace Elastica\Bulk; use Elastica\Bulk; -use Elastica\JSON; use Elastica\Index; +use Elastica\JSON; use Elastica\Type; class Action { const OP_TYPE_CREATE = 'create'; - const OP_TYPE_INDEX = 'index'; + const OP_TYPE_INDEX = 'index'; const OP_TYPE_DELETE = 'delete'; const OP_TYPE_UPDATE = 'update'; @@ -21,7 +20,7 @@ class Action self::OP_TYPE_CREATE, self::OP_TYPE_INDEX, self::OP_TYPE_DELETE, - self::OP_TYPE_UPDATE + self::OP_TYPE_UPDATE, ); /** @@ -41,8 +40,8 @@ class Action /** * @param string $opType - * @param array $metadata - * @param array $source + * @param array $metadata + * @param array $source */ public function __construct($opType = self::OP_TYPE_INDEX, array $metadata = array(), array $source = array()) { @@ -53,7 +52,8 @@ class Action /** * @param string $type - * @return \Elastica\Bulk\Action + * + * @return $this */ public function setOpType($type) { @@ -72,7 +72,8 @@ class Action /** * @param array $metadata - * @return \Elastica\Bulk\Action + * + * @return $this */ public function setMetadata(array $metadata) { @@ -99,7 +100,8 @@ class Action /** * @param array $source - * @return \Elastica\Bulk\Action + * + * @return $this */ public function setSource($source) { @@ -126,7 +128,8 @@ class Action /** * @param string|\Elastica\Index $index - * @return \Elastica\Bulk\Action + * + * @return $this */ public function setIndex($index) { @@ -140,7 +143,8 @@ class Action /** * @param string|\Elastica\Type $type - * @return \Elastica\Bulk\Action + * + * @return $this */ public function setType($type) { @@ -155,7 +159,8 @@ class Action /** * @param string $id - * @return \Elastica\Bulk\Action + * + * @return $this */ public function setId($id) { @@ -166,7 +171,8 @@ class Action /** * @param string $routing - * @return \Elastica\Bulk\Action + * + * @return $this */ public function setRouting($routing) { @@ -184,6 +190,7 @@ class Action if ($this->hasSource()) { $data[] = $this->getSource(); } + return $data; } @@ -192,24 +199,26 @@ class Action */ public function toString() { - $string = JSON::stringify($this->getActionMetadata(), JSON_FORCE_OBJECT) . Bulk::DELIMITER; + $string = JSON::stringify($this->getActionMetadata(), JSON_FORCE_OBJECT).Bulk::DELIMITER; if ($this->hasSource()) { $source = $this->getSource(); if (is_string($source)) { - $string.= $source; + $string .= $source; } elseif (is_array($source) && array_key_exists('doc', $source) && is_string($source['doc'])) { $docAsUpsert = (isset($source['doc_as_upsert'])) ? ', "doc_as_upsert": '.$source['doc_as_upsert'] : ''; - $string.= '{"doc": '.$source['doc'].$docAsUpsert.'}'; + $string .= '{"doc": '.$source['doc'].$docAsUpsert.'}'; } else { - $string.= JSON::stringify($source, 'JSON_ELASTICSEARCH'); + $string .= JSON::stringify($source, 'JSON_ELASTICSEARCH'); } - $string.= Bulk::DELIMITER; + $string .= Bulk::DELIMITER; } + return $string; } /** * @param string $opType + * * @return bool */ public static function isValidOpType($opType) |