mirror/php-adminer
1
0
Fork 0
mirror of https://github.com/vrana/adminer.git synced 2025-08-21 13:51:33 +02:00
Code Issues Releases Wiki Activity

Mongo: Use $this->_conn

Browse Source
This commit is contained in:
Jakub Vrana
2025-03-06 14:10:05 +01:00
parent bddce074fa
commit 049536da90
1 changed files with 7 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
adminer/drivers/mongo.inc.php
View File

@@ -306,7 +306,6 @@ if (isset($_GET["mongo"])) {
public $primary = "_id"; public $primary = "_id";
function select($table, $select, $where, $group, $order = array(), $limit = 1, $page = 0, $print = false) { function select($table, $select, $where, $group, $order = array(), $limit = 1, $page = 0, $print = false) {
global $connection;
$select = ($select == array("*") $select = ($select == array("*")
? array() ? array()
: array_fill_keys($select, 1) : array_fill_keys($select, 1)
@@ -326,7 +325,7 @@ if (isset($_GET["mongo"])) {
$limit = min(200, max(1, (int) $limit)); $limit = min(200, max(1, (int) $limit));
$skip = $page * $limit; $skip = $page * $limit;
try { try {
return new Result($connection->_link->executeQuery("$connection->_db_name.$table", new \MongoDB\Driver\Query($where, array('projection' => $select, 'limit' => $limit, 'skip' => $skip, 'sort' => $sort)))); return new Result($this->_conn->_link->executeQuery("$connection->_db_name.$table", new \MongoDB\Driver\Query($where, array('projection' => $select, 'limit' => $limit, 'skip' => $skip, 'sort' => $sort))));
} catch (Exception $e) { } catch (Exception $e) {
$connection->error = $e->getMessage(); $connection->error = $e->getMessage();
return false; return false;
@@ -334,8 +333,7 @@ if (isset($_GET["mongo"])) {
} }
function update($table, $set, $queryWhere, $limit = 0, $separator = "\n") { function update($table, $set, $queryWhere, $limit = 0, $separator = "\n") {
global $connection; $db = $this->_conn->_db_name;
$db = $connection->_db_name;
$where = sql_query_where_parser($queryWhere); $where = sql_query_where_parser($queryWhere);
$bulk = new \MongoDB\Driver\BulkWrite(array()); $bulk = new \MongoDB\Driver\BulkWrite(array());
if (isset($set['_id'])) { if (isset($set['_id'])) {
@@ -353,27 +351,25 @@ if (isset($_GET["mongo"])) {
$update['$unset'] = $removeFields; $update['$unset'] = $removeFields;
} }
$bulk->update($where, $update, array('upsert' => false)); $bulk->update($where, $update, array('upsert' => false));
return $connection->executeBulkWrite("$db.$table", $bulk, 'getModifiedCount'); return $this->_conn->executeBulkWrite("$db.$table", $bulk, 'getModifiedCount');
} }
function delete($table, $queryWhere, $limit = 0) { function delete($table, $queryWhere, $limit = 0) {
global $connection; $db = $this->_conn->_db_name;
$db = $connection->_db_name;
$where = sql_query_where_parser($queryWhere); $where = sql_query_where_parser($queryWhere);
$bulk = new \MongoDB\Driver\BulkWrite(array()); $bulk = new \MongoDB\Driver\BulkWrite(array());
$bulk->delete($where, array('limit' => $limit)); $bulk->delete($where, array('limit' => $limit));
return $connection->executeBulkWrite("$db.$table", $bulk, 'getDeletedCount'); return $this->_conn->executeBulkWrite("$db.$table", $bulk, 'getDeletedCount');
} }
function insert($table, $set) { function insert($table, $set) {
global $connection; $db = $this->_conn->_db_name;
$db = $connection->_db_name;
$bulk = new \MongoDB\Driver\BulkWrite(array()); $bulk = new \MongoDB\Driver\BulkWrite(array());
if ($set['_id'] == '') { if ($set['_id'] == '') {
unset($set['_id']); unset($set['_id']);
} }
$bulk->insert($set); $bulk->insert($set);
return $connection->executeBulkWrite("$db.$table", $bulk, 'getInsertedCount'); return $this->_conn->executeBulkWrite("$db.$table", $bulk, 'getInsertedCount');
} }
} }