diff --git a/adminer/drivers/elastic.inc.php b/adminer/drivers/elastic.inc.php index 86192399..ec4fae1d 100644 --- a/adminer/drivers/elastic.inc.php +++ b/adminer/drivers/elastic.inc.php @@ -231,10 +231,10 @@ if (isset($_GET["elastic"])) { function delete($type, $queryWhere, $limit = 0) { //! use $limit $ids = array(); - if (is_array($_GET["where"]) && $_GET["where"]["_id"]) { + if (isset($_GET["where"]["_id"]) && $_GET["where"]["_id"]) { $ids[] = $_GET["where"]["_id"]; } - if (is_array($_POST['check'])) { + if (isset($_POST['check'])) { foreach ($_POST['check'] as $check) { $parts = preg_split('~ *= *~', $check); if (count($parts) == 2) { @@ -245,8 +245,8 @@ if (isset($_GET["elastic"])) { $this->_conn->affected_rows = 0; foreach ($ids as $id) { $query = "{$type}/{$id}"; - $response = $this->_conn->query($query, '{}', 'DELETE'); - if (is_array($response) && $response['found'] == true) { + $response = $this->_conn->query($query, null, 'DELETE'); + if ((isset($response['found']) && $response['found']) || (isset($response['result']) && $response['result'] == 'deleted')) { $this->_conn->affected_rows++; } } @@ -474,7 +474,7 @@ if (isset($_GET["elastic"])) { */ function drop_databases($databases) { global $connection; - return $connection->rootQuery(urlencode(implode(',', $databases)), array(), 'DELETE'); + return $connection->rootQuery(urlencode(implode(',', $databases)), null, 'DELETE'); } /** Alter type @@ -505,7 +505,7 @@ if (isset($_GET["elastic"])) { global $connection; $return = true; foreach ($tables as $table) { //! convert to bulk api - $return = $return && $connection->query(urlencode($table), array(), 'DELETE'); + $return = $return && $connection->query(urlencode($table), null, 'DELETE'); } return $return; }