From: Jakub Vrana <jakub@vrana.cz>
Date: Thu, 13 Mar 2025 13:27:28 +0000 (+0100)
Subject: MongoDB: Move to plugin
X-Git-Tag: v5.0.5~12
X-Git-Url: https://git.joonet.de/?a=commitdiff_plain;h=078957fe32d2f6c5177acc554a347e4bf2ed88d0;p=adminer.git

MongoDB: Move to plugin
---

diff --git a/adminer/drivers/mongo.inc.php b/adminer/drivers/mongo.inc.php
deleted file mode 100644
index dbc86645..00000000
--- a/adminer/drivers/mongo.inc.php
+++ /dev/null
@@ -1,545 +0,0 @@
-<?php
-namespace Adminer;
-
-$drivers["mongo"] = "MongoDB (alpha)";
-
-if (isset($_GET["mongo"])) {
-	define('Adminer\DRIVER', "mongo");
-
-	if (class_exists('MongoDB\Driver\Manager')) {
-		class Db {
-			public $extension = "MongoDB", $server_info = MONGODB_VERSION, $affected_rows, $error, $last_id;
-			/** @var MongoDB\Driver\Manager */
-			public $_link;
-			public $_db, $_db_name;
-
-			function connect($uri, $options) {
-				$this->_link = new \MongoDB\Driver\Manager($uri, $options);
-				$this->executeDbCommand($options["db"], array('ping' => 1));
-			}
-
-			function executeCommand($command) {
-				return $this->executeDbCommand($this->_db_name);
-			}
-
-			function executeDbCommand($db, $command) {
-				try {
-					return $this->_link->executeCommand($db, new \MongoDB\Driver\Command($command));
-				} catch (Exception $e) {
-					$this->error = $e->getMessage();
-					return array();
-				}
-			}
-
-			function executeBulkWrite($namespace, $bulk, $counter) {
-				try {
-					$results = $this->_link->executeBulkWrite($namespace, $bulk);
-					$this->affected_rows = $results->$counter();
-					return true;
-				} catch (Exception $e) {
-					$this->error = $e->getMessage();
-					return false;
-				}
-			}
-
-			function query($query) {
-				return false;
-			}
-
-			function select_db($database) {
-				$this->_db_name = $database;
-				return true;
-			}
-
-			function quote($string) {
-				return $string;
-			}
-		}
-
-		class Result {
-			public $num_rows;
-			private $rows = array(), $offset = 0, $charset = array();
-
-			function __construct($result) {
-				foreach ($result as $item) {
-					$row = array();
-					foreach ($item as $key => $val) {
-						if (is_a($val, 'MongoDB\BSON\Binary')) {
-							$this->charset[$key] = 63;
-						}
-						$row[$key] =
-							(is_a($val, 'MongoDB\BSON\ObjectID') ? 'MongoDB\BSON\ObjectID("' . "$val\")" :
-							(is_a($val, 'MongoDB\BSON\UTCDatetime') ? $val->toDateTime()->format('Y-m-d H:i:s') :
-							(is_a($val, 'MongoDB\BSON\Binary') ? $val->getData() : //! allow downloading
-							(is_a($val, 'MongoDB\BSON\Regex') ? "$val" :
-							(is_object($val) || is_array($val) ? json_encode($val, 256) : // 256 = JSON_UNESCAPED_UNICODE
-							$val // MongoMinKey, MongoMaxKey
-						)))));
-					}
-					$this->rows[] = $row;
-					foreach ($row as $key => $val) {
-						if (!isset($this->rows[0][$key])) {
-							$this->rows[0][$key] = null;
-						}
-					}
-				}
-				$this->num_rows = count($this->rows);
-			}
-
-			function fetch_assoc() {
-				$row = current($this->rows);
-				if (!$row) {
-					return $row;
-				}
-				$return = array();
-				foreach ($this->rows[0] as $key => $val) {
-					$return[$key] = $row[$key];
-				}
-				next($this->rows);
-				return $return;
-			}
-
-			function fetch_row() {
-				$return = $this->fetch_assoc();
-				if (!$return) {
-					return $return;
-				}
-				return array_values($return);
-			}
-
-			function fetch_field() {
-				$keys = array_keys($this->rows[0]);
-				$name = $keys[$this->offset++];
-				return (object) array(
-					'name' => $name,
-					'charsetnr' => $this->charset[$name],
-				);
-			}
-		}
-
-
-
-		function get_databases($flush) {
-			global $connection;
-			$return = array();
-			foreach ($connection->executeCommand(array('listDatabases' => 1)) as $dbs) {
-				foreach ($dbs->databases as $db) {
-					$return[] = $db->name;
-				}
-			}
-			return $return;
-		}
-
-		function count_tables($databases) {
-			$return = array();
-			return $return;
-		}
-
-		function tables_list() {
-			global $connection;
-			$collections = array();
-			foreach ($connection->executeCommand(array('listCollections' => 1)) as $result) {
-				$collections[$result->name] = 'table';
-			}
-			return $collections;
-		}
-
-		function drop_databases($databases) {
-			return false;
-		}
-
-		function indexes($table, $connection2 = null) {
-			global $connection;
-			$return = array();
-			foreach ($connection->executeCommand(array('listIndexes' => $table)) as $index) {
-				$descs = array();
-				$columns = array();
-				foreach (get_object_vars($index->key) as $column => $type) {
-					$descs[] = ($type == -1 ? '1' : null);
-					$columns[] = $column;
-				}
-				$return[$index->name] = array(
-					"type" => ($index->name == "_id_" ? "PRIMARY" : (isset($index->unique) ? "UNIQUE" : "INDEX")),
-					"columns" => $columns,
-					"lengths" => array(),
-					"descs" => $descs,
-				);
-			}
-			return $return;
-		}
-
-		function fields($table) {
-			global $driver;
-			$fields = fields_from_edit();
-			if (!$fields) {
-				$result = $driver->select($table, array("*"), null, null, array(), 10);
-				if ($result) {
-					while ($row = $result->fetch_assoc()) {
-						foreach ($row as $key => $val) {
-							$row[$key] = null;
-							$fields[$key] = array(
-								"field" => $key,
-								"type" => "string",
-								"null" => ($key != $driver->primary),
-								"auto_increment" => ($key == $driver->primary),
-								"privileges" => array(
-									"insert" => 1,
-									"select" => 1,
-									"update" => 1,
-									"where" => 1,
-									"order" => 1,
-								),
-							);
-						}
-					}
-				}
-			}
-			return $fields;
-		}
-
-		function found_rows($table_status, $where) {
-			global $connection;
-			$where = where_to_query($where);
-			$toArray = $connection->executeCommand(array('count' => $table_status['Name'], 'query' => $where))->toArray();
-			return $toArray[0]->n;
-		}
-
-		function sql_query_where_parser($queryWhere) {
-			$queryWhere = preg_replace('~^\s*WHERE\s*~', "", $queryWhere);
-			while ($queryWhere[0] == "(") {
-				$queryWhere = preg_replace('~^\((.*)\)$~', "$1", $queryWhere);
-			}
-
-			$wheres = explode(' AND ', $queryWhere);
-			$wheresOr = explode(') OR (', $queryWhere);
-			$where = array();
-			foreach ($wheres as $whereStr) {
-				$where[] = trim($whereStr);
-			}
-			if (count($wheresOr) == 1) {
-				$wheresOr = array();
-			} elseif (count($wheresOr) > 1) {
-				$where = array();
-			}
-			return where_to_query($where, $wheresOr);
-		}
-
-		function where_to_query($whereAnd = array(), $whereOr = array()) {
-			global $adminer;
-			$data = array();
-			foreach (array('and' => $whereAnd, 'or' => $whereOr) as $type => $where) {
-				if (is_array($where)) {
-					foreach ($where as $expression) {
-						list($col, $op, $val) = explode(" ", $expression, 3);
-						if ($col == "_id" && preg_match('~^(MongoDB\\\\BSON\\\\ObjectID)\("(.+)"\)$~', $val, $match)) {
-							list(, $class, $val) = $match;
-							$val = new $class($val);
-						}
-						if (!in_array($op, $adminer->operators)) {
-							continue;
-						}
-						if (preg_match('~^\(f\)(.+)~', $op, $match)) {
-							$val = (float) $val;
-							$op = $match[1];
-						} elseif (preg_match('~^\(date\)(.+)~', $op, $match)) {
-							$dateTime = new \DateTime($val);
-							$val = new \MongoDB\BSON\UTCDatetime($dateTime->getTimestamp() * 1000);
-							$op = $match[1];
-						}
-						switch ($op) {
-							case '=':
-								$op = '$eq';
-								break;
-							case '!=':
-								$op = '$ne';
-								break;
-							case '>':
-								$op = '$gt';
-								break;
-							case '<':
-								$op = '$lt';
-								break;
-							case '>=':
-								$op = '$gte';
-								break;
-							case '<=':
-								$op = '$lte';
-								break;
-							case 'regex':
-								$op = '$regex';
-								break;
-							default:
-								continue 2;
-						}
-						if ($type == 'and') {
-							$data['$and'][] = array($col => array($op => $val));
-						} elseif ($type == 'or') {
-							$data['$or'][] = array($col => array($op => $val));
-						}
-					}
-				}
-			}
-			return $data;
-		}
-	}
-
-
-
-	class Driver extends SqlDriver {
-		static $possibleDrivers = array("mongodb");
-		static $jush = "mongo";
-
-		public $editFunctions = array(array("json"));
-
-		public $operators = array(
-			"=",
-			"!=",
-			">",
-			"<",
-			">=",
-			"<=",
-			"regex",
-			"(f)=",
-			"(f)!=",
-			"(f)>",
-			"(f)<",
-			"(f)>=",
-			"(f)<=",
-			"(date)=",
-			"(date)!=",
-			"(date)>",
-			"(date)<",
-			"(date)>=",
-			"(date)<=",
-		);
-
-		public $primary = "_id";
-
-		function select($table, $select, $where, $group, $order = array(), $limit = 1, $page = 0, $print = false) {
-			$select = ($select == array("*")
-				? array()
-				: array_fill_keys($select, 1)
-			);
-			if (count($select) && !isset($select['_id'])) {
-				$select['_id'] = 0;
-			}
-			$where = where_to_query($where);
-			$sort = array();
-			foreach ($order as $val) {
-				$val = preg_replace('~ DESC$~', '', $val, 1, $count);
-				$sort[$val] = ($count ? -1 : 1);
-			}
-			if (isset($_GET['limit']) && is_numeric($_GET['limit']) && $_GET['limit'] > 0) {
-				$limit = $_GET['limit'];
-			}
-			$limit = min(200, max(1, (int) $limit));
-			$skip = $page * $limit;
-			try {
-				return new Result($this->conn->_link->executeQuery($this->conn->_db_name . ".$table", new \MongoDB\Driver\Query($where, array('projection' => $select, 'limit' => $limit, 'skip' => $skip, 'sort' => $sort))));
-			} catch (Exception $e) {
-				$this->conn->error = $e->getMessage();
-				return false;
-			}
-		}
-
-		function update($table, $set, $queryWhere, $limit = 0, $separator = "\n") {
-			$db = $this->conn->_db_name;
-			$where = sql_query_where_parser($queryWhere);
-			$bulk = new \MongoDB\Driver\BulkWrite(array());
-			if (isset($set['_id'])) {
-				unset($set['_id']);
-			}
-			$removeFields = array();
-			foreach ($set as $key => $value) {
-				if ($value == 'NULL') {
-					$removeFields[$key] = 1;
-					unset($set[$key]);
-				}
-			}
-			$update = array('$set' => $set);
-			if (count($removeFields)) {
-				$update['$unset'] = $removeFields;
-			}
-			$bulk->update($where, $update, array('upsert' => false));
-			return $this->conn->executeBulkWrite("$db.$table", $bulk, 'getModifiedCount');
-		}
-
-		function delete($table, $queryWhere, $limit = 0) {
-			$db = $this->conn->_db_name;
-			$where = sql_query_where_parser($queryWhere);
-			$bulk = new \MongoDB\Driver\BulkWrite(array());
-			$bulk->delete($where, array('limit' => $limit));
-			return $this->conn->executeBulkWrite("$db.$table", $bulk, 'getDeletedCount');
-		}
-
-		function insert($table, $set) {
-			$db = $this->conn->_db_name;
-			$bulk = new \MongoDB\Driver\BulkWrite(array());
-			if ($set['_id'] == '') {
-				unset($set['_id']);
-			}
-			$bulk->insert($set);
-			return $this->conn->executeBulkWrite("$db.$table", $bulk, 'getInsertedCount');
-		}
-	}
-
-
-
-	function table($idf) {
-		return $idf;
-	}
-
-	function idf_escape($idf) {
-		return $idf;
-	}
-
-	function table_status($name = "", $fast = false) {
-		$return = array();
-		foreach (tables_list() as $table => $type) {
-			$return[$table] = array("Name" => $table);
-			if ($name == $table) {
-				return $return[$table];
-			}
-		}
-		return $return;
-	}
-
-	function create_database($db, $collation) {
-		return true;
-	}
-
-	function last_id() {
-		global $connection;
-		return $connection->last_id;
-	}
-
-	function error() {
-		global $connection;
-		return h($connection->error);
-	}
-
-	function collations() {
-		return array();
-	}
-
-	function logged_user() {
-		global $adminer;
-		$credentials = $adminer->credentials();
-		return $credentials[1];
-	}
-
-	function connect($credentials) {
-		global $adminer;
-		$connection = new Db;
-		list($server, $username, $password) = $credentials;
-
-		if ($server == "") {
-			$server = "localhost:27017";
-		}
-
-		$options = array();
-		if ($username . $password != "") {
-			$options["username"] = $username;
-			$options["password"] = $password;
-		}
-		$db = $adminer->database();
-		if ($db != "") {
-			$options["db"] = $db;
-		}
-		if (($auth_source = getenv("MONGO_AUTH_SOURCE"))) {
-			$options["authSource"] = $auth_source;
-		}
-		$connection->connect("mongodb://$server", $options);
-		if ($connection->error) {
-			return $connection->error;
-		}
-		return $connection;
-	}
-
-	function alter_indexes($table, $alter) {
-		global $connection;
-		foreach ($alter as $val) {
-			list($type, $name, $set) = $val;
-			if ($set == "DROP") {
-				$return = $connection->_db->command(array("deleteIndexes" => $table, "index" => $name));
-			} else {
-				$columns = array();
-				foreach ($set as $column) {
-					$column = preg_replace('~ DESC$~', '', $column, 1, $count);
-					$columns[$column] = ($count ? -1 : 1);
-				}
-				$return = $connection->_db->selectCollection($table)->ensureIndex($columns, array(
-					"unique" => ($type == "UNIQUE"),
-					"name" => $name,
-					//! "sparse"
-				));
-			}
-			if ($return['errmsg']) {
-				$connection->error = $return['errmsg'];
-				return false;
-			}
-		}
-		return true;
-	}
-
-	function support($feature) {
-		return preg_match("~database|indexes|descidx~", $feature);
-	}
-
-	function db_collation($db, $collations) {
-	}
-
-	function information_schema() {
-	}
-
-	function is_view($table_status) {
-	}
-
-	function convert_field($field) {
-	}
-
-	function unconvert_field($field, $return) {
-		return $return;
-	}
-
-	function foreign_keys($table) {
-		return array();
-	}
-
-	function fk_support($table_status) {
-	}
-
-	function engines() {
-		return array();
-	}
-
-	function alter_table($table, $name, $fields, $foreign, $comment, $engine, $collation, $auto_increment, $partitioning) {
-		global $connection;
-		if ($table == "") {
-			$connection->_db->createCollection($name);
-			return true;
-		}
-	}
-
-	function drop_tables($tables) {
-		global $connection;
-		foreach ($tables as $table) {
-			$response = $connection->_db->selectCollection($table)->drop();
-			if (!$response['ok']) {
-				return false;
-			}
-		}
-		return true;
-	}
-
-	function truncate_tables($tables) {
-		global $connection;
-		foreach ($tables as $table) {
-			$response = $connection->_db->selectCollection($table)->remove();
-			if (!$response['ok']) {
-				return false;
-			}
-		}
-		return true;
-	}
-}
diff --git a/adminer/include/bootstrap.inc.php b/adminer/include/bootstrap.inc.php
index a08acf96..f9f3768f 100644
--- a/adminer/include/bootstrap.inc.php
+++ b/adminer/include/bootstrap.inc.php
@@ -72,7 +72,6 @@ include "../adminer/drivers/sqlite.inc.php";
 include "../adminer/drivers/pgsql.inc.php";
 include "../adminer/drivers/oracle.inc.php";
 include "../adminer/drivers/mssql.inc.php";
-include "../adminer/drivers/mongo.inc.php";
 include "./include/adminer.inc.php";
 $adminer = (function_exists('adminer_object') ? adminer_object() : new Adminer);
 include "../adminer/drivers/mysql.inc.php"; // must be included as last driver
diff --git a/changes.txt b/changes.txt
index 54323857..e61b82b1 100644
--- a/changes.txt
+++ b/changes.txt
@@ -7,6 +7,7 @@ PostgreSQL PDO: Escape bytea values (bug #218)
 CockroachDB: Display version
 CockroachDB: Recognize unique_rowid() as auto_increment
 MS SQL: Fix editing rows with datetime column in primary key
+MongoDB: Move to plugin
 CSS: Add dark theme
 
 Adminer 5.0.4 (released 2025-03-11):
diff --git a/plugins/drivers/mongo.inc.php b/plugins/drivers/mongo.inc.php
new file mode 100644
index 00000000..a8ef94a2
--- /dev/null
+++ b/plugins/drivers/mongo.inc.php
@@ -0,0 +1,533 @@
+<?php
+namespace Adminer;
+
+add_driver("mongo", "MongoDB (alpha)");
+
+if (isset($_GET["mongo"])) {
+	define('Adminer\DRIVER', "mongo");
+
+	if (class_exists('MongoDB\Driver\Manager')) {
+		class Db {
+			public $extension = "MongoDB", $server_info = MONGODB_VERSION, $affected_rows, $error, $last_id;
+			/** @var MongoDB\Driver\Manager */
+			public $_link;
+			public $_db, $_db_name;
+
+			function connect($uri, $options) {
+				$this->_link = new \MongoDB\Driver\Manager($uri, $options);
+				$this->executeDbCommand($options["db"], array('ping' => 1));
+			}
+
+			function executeCommand($command) {
+				return $this->executeDbCommand($this->_db_name);
+			}
+
+			function executeDbCommand($db, $command) {
+				try {
+					return $this->_link->executeCommand($db, new \MongoDB\Driver\Command($command));
+				} catch (Exception $e) {
+					$this->error = $e->getMessage();
+					return array();
+				}
+			}
+
+			function executeBulkWrite($namespace, $bulk, $counter) {
+				try {
+					$results = $this->_link->executeBulkWrite($namespace, $bulk);
+					$this->affected_rows = $results->$counter();
+					return true;
+				} catch (Exception $e) {
+					$this->error = $e->getMessage();
+					return false;
+				}
+			}
+
+			function query($query) {
+				return false;
+			}
+
+			function select_db($database) {
+				$this->_db_name = $database;
+				return true;
+			}
+
+			function quote($string) {
+				return $string;
+			}
+		}
+
+		class Result {
+			public $num_rows;
+			private $rows = array(), $offset = 0, $charset = array();
+
+			function __construct($result) {
+				foreach ($result as $item) {
+					$row = array();
+					foreach ($item as $key => $val) {
+						if (is_a($val, 'MongoDB\BSON\Binary')) {
+							$this->charset[$key] = 63;
+						}
+						$row[$key] =
+							(is_a($val, 'MongoDB\BSON\ObjectID') ? 'MongoDB\BSON\ObjectID("' . "$val\")" :
+							(is_a($val, 'MongoDB\BSON\UTCDatetime') ? $val->toDateTime()->format('Y-m-d H:i:s') :
+							(is_a($val, 'MongoDB\BSON\Binary') ? $val->getData() : //! allow downloading
+							(is_a($val, 'MongoDB\BSON\Regex') ? "$val" :
+							(is_object($val) || is_array($val) ? json_encode($val, 256) : // 256 = JSON_UNESCAPED_UNICODE
+							$val // MongoMinKey, MongoMaxKey
+						)))));
+					}
+					$this->rows[] = $row;
+					foreach ($row as $key => $val) {
+						if (!isset($this->rows[0][$key])) {
+							$this->rows[0][$key] = null;
+						}
+					}
+				}
+				$this->num_rows = count($this->rows);
+			}
+
+			function fetch_assoc() {
+				$row = current($this->rows);
+				if (!$row) {
+					return $row;
+				}
+				$return = array();
+				foreach ($this->rows[0] as $key => $val) {
+					$return[$key] = $row[$key];
+				}
+				next($this->rows);
+				return $return;
+			}
+
+			function fetch_row() {
+				$return = $this->fetch_assoc();
+				if (!$return) {
+					return $return;
+				}
+				return array_values($return);
+			}
+
+			function fetch_field() {
+				$keys = array_keys($this->rows[0]);
+				$name = $keys[$this->offset++];
+				return (object) array(
+					'name' => $name,
+					'charsetnr' => $this->charset[$name],
+				);
+			}
+		}
+
+
+
+		function get_databases($flush) {
+			$return = array();
+			foreach (connection()->executeCommand(array('listDatabases' => 1)) as $dbs) {
+				foreach ($dbs->databases as $db) {
+					$return[] = $db->name;
+				}
+			}
+			return $return;
+		}
+
+		function count_tables($databases) {
+			$return = array();
+			return $return;
+		}
+
+		function tables_list() {
+			$collections = array();
+			foreach (connection()->executeCommand(array('listCollections' => 1)) as $result) {
+				$collections[$result->name] = 'table';
+			}
+			return $collections;
+		}
+
+		function drop_databases($databases) {
+			return false;
+		}
+
+		function indexes($table, $connection2 = null) {
+			$return = array();
+			foreach (connection()->executeCommand(array('listIndexes' => $table)) as $index) {
+				$descs = array();
+				$columns = array();
+				foreach (get_object_vars($index->key) as $column => $type) {
+					$descs[] = ($type == -1 ? '1' : null);
+					$columns[] = $column;
+				}
+				$return[$index->name] = array(
+					"type" => ($index->name == "_id_" ? "PRIMARY" : (isset($index->unique) ? "UNIQUE" : "INDEX")),
+					"columns" => $columns,
+					"lengths" => array(),
+					"descs" => $descs,
+				);
+			}
+			return $return;
+		}
+
+		function fields($table) {
+			$driver = get_driver();
+			$fields = fields_from_edit();
+			if (!$fields) {
+				$result = $driver->select($table, array("*"), null, null, array(), 10);
+				if ($result) {
+					while ($row = $result->fetch_assoc()) {
+						foreach ($row as $key => $val) {
+							$row[$key] = null;
+							$fields[$key] = array(
+								"field" => $key,
+								"type" => "string",
+								"null" => ($key != $driver->primary),
+								"auto_increment" => ($key == $driver->primary),
+								"privileges" => array(
+									"insert" => 1,
+									"select" => 1,
+									"update" => 1,
+									"where" => 1,
+									"order" => 1,
+								),
+							);
+						}
+					}
+				}
+			}
+			return $fields;
+		}
+
+		function found_rows($table_status, $where) {
+			$where = where_to_query($where);
+			$toArray = connection()->executeCommand(array('count' => $table_status['Name'], 'query' => $where))->toArray();
+			return $toArray[0]->n;
+		}
+
+		function sql_query_where_parser($queryWhere) {
+			$queryWhere = preg_replace('~^\s*WHERE\s*~', "", $queryWhere);
+			while ($queryWhere[0] == "(") {
+				$queryWhere = preg_replace('~^\((.*)\)$~', "$1", $queryWhere);
+			}
+
+			$wheres = explode(' AND ', $queryWhere);
+			$wheresOr = explode(') OR (', $queryWhere);
+			$where = array();
+			foreach ($wheres as $whereStr) {
+				$where[] = trim($whereStr);
+			}
+			if (count($wheresOr) == 1) {
+				$wheresOr = array();
+			} elseif (count($wheresOr) > 1) {
+				$where = array();
+			}
+			return where_to_query($where, $wheresOr);
+		}
+
+		function where_to_query($whereAnd = array(), $whereOr = array()) {
+			$data = array();
+			foreach (array('and' => $whereAnd, 'or' => $whereOr) as $type => $where) {
+				if (is_array($where)) {
+					foreach ($where as $expression) {
+						list($col, $op, $val) = explode(" ", $expression, 3);
+						if ($col == "_id" && preg_match('~^(MongoDB\\\\BSON\\\\ObjectID)\("(.+)"\)$~', $val, $match)) {
+							list(, $class, $val) = $match;
+							$val = new $class($val);
+						}
+						if (!in_array($op, adminer()->operators)) {
+							continue;
+						}
+						if (preg_match('~^\(f\)(.+)~', $op, $match)) {
+							$val = (float) $val;
+							$op = $match[1];
+						} elseif (preg_match('~^\(date\)(.+)~', $op, $match)) {
+							$dateTime = new \DateTime($val);
+							$val = new \MongoDB\BSON\UTCDatetime($dateTime->getTimestamp() * 1000);
+							$op = $match[1];
+						}
+						switch ($op) {
+							case '=':
+								$op = '$eq';
+								break;
+							case '!=':
+								$op = '$ne';
+								break;
+							case '>':
+								$op = '$gt';
+								break;
+							case '<':
+								$op = '$lt';
+								break;
+							case '>=':
+								$op = '$gte';
+								break;
+							case '<=':
+								$op = '$lte';
+								break;
+							case 'regex':
+								$op = '$regex';
+								break;
+							default:
+								continue 2;
+						}
+						if ($type == 'and') {
+							$data['$and'][] = array($col => array($op => $val));
+						} elseif ($type == 'or') {
+							$data['$or'][] = array($col => array($op => $val));
+						}
+					}
+				}
+			}
+			return $data;
+		}
+	}
+
+
+
+	class Driver extends SqlDriver {
+		static $possibleDrivers = array("mongodb");
+		static $jush = "mongo";
+
+		public $editFunctions = array(array("json"));
+
+		public $operators = array(
+			"=",
+			"!=",
+			">",
+			"<",
+			">=",
+			"<=",
+			"regex",
+			"(f)=",
+			"(f)!=",
+			"(f)>",
+			"(f)<",
+			"(f)>=",
+			"(f)<=",
+			"(date)=",
+			"(date)!=",
+			"(date)>",
+			"(date)<",
+			"(date)>=",
+			"(date)<=",
+		);
+
+		public $primary = "_id";
+
+		function select($table, $select, $where, $group, $order = array(), $limit = 1, $page = 0, $print = false) {
+			$select = ($select == array("*")
+				? array()
+				: array_fill_keys($select, 1)
+			);
+			if (count($select) && !isset($select['_id'])) {
+				$select['_id'] = 0;
+			}
+			$where = where_to_query($where);
+			$sort = array();
+			foreach ($order as $val) {
+				$val = preg_replace('~ DESC$~', '', $val, 1, $count);
+				$sort[$val] = ($count ? -1 : 1);
+			}
+			if (isset($_GET['limit']) && is_numeric($_GET['limit']) && $_GET['limit'] > 0) {
+				$limit = $_GET['limit'];
+			}
+			$limit = min(200, max(1, (int) $limit));
+			$skip = $page * $limit;
+			try {
+				return new Result($this->conn->_link->executeQuery($this->conn->_db_name . ".$table", new \MongoDB\Driver\Query($where, array('projection' => $select, 'limit' => $limit, 'skip' => $skip, 'sort' => $sort))));
+			} catch (Exception $e) {
+				$this->conn->error = $e->getMessage();
+				return false;
+			}
+		}
+
+		function update($table, $set, $queryWhere, $limit = 0, $separator = "\n") {
+			$db = $this->conn->_db_name;
+			$where = sql_query_where_parser($queryWhere);
+			$bulk = new \MongoDB\Driver\BulkWrite(array());
+			if (isset($set['_id'])) {
+				unset($set['_id']);
+			}
+			$removeFields = array();
+			foreach ($set as $key => $value) {
+				if ($value == 'NULL') {
+					$removeFields[$key] = 1;
+					unset($set[$key]);
+				}
+			}
+			$update = array('$set' => $set);
+			if (count($removeFields)) {
+				$update['$unset'] = $removeFields;
+			}
+			$bulk->update($where, $update, array('upsert' => false));
+			return $this->conn->executeBulkWrite("$db.$table", $bulk, 'getModifiedCount');
+		}
+
+		function delete($table, $queryWhere, $limit = 0) {
+			$db = $this->conn->_db_name;
+			$where = sql_query_where_parser($queryWhere);
+			$bulk = new \MongoDB\Driver\BulkWrite(array());
+			$bulk->delete($where, array('limit' => $limit));
+			return $this->conn->executeBulkWrite("$db.$table", $bulk, 'getDeletedCount');
+		}
+
+		function insert($table, $set) {
+			$db = $this->conn->_db_name;
+			$bulk = new \MongoDB\Driver\BulkWrite(array());
+			if ($set['_id'] == '') {
+				unset($set['_id']);
+			}
+			$bulk->insert($set);
+			return $this->conn->executeBulkWrite("$db.$table", $bulk, 'getInsertedCount');
+		}
+	}
+
+
+
+	function table($idf) {
+		return $idf;
+	}
+
+	function idf_escape($idf) {
+		return $idf;
+	}
+
+	function table_status($name = "", $fast = false) {
+		$return = array();
+		foreach (tables_list() as $table => $type) {
+			$return[$table] = array("Name" => $table);
+			if ($name == $table) {
+				return $return[$table];
+			}
+		}
+		return $return;
+	}
+
+	function create_database($db, $collation) {
+		return true;
+	}
+
+	function last_id() {
+		return connection()->last_id;
+	}
+
+	function error() {
+		return h(connection()->error);
+	}
+
+	function collations() {
+		return array();
+	}
+
+	function logged_user() {
+		$credentials = adminer()->credentials();
+		return $credentials[1];
+	}
+
+	function connect($credentials) {
+		$connection = new Db;
+		list($server, $username, $password) = $credentials;
+
+		if ($server == "") {
+			$server = "localhost:27017";
+		}
+
+		$options = array();
+		if ($username . $password != "") {
+			$options["username"] = $username;
+			$options["password"] = $password;
+		}
+		$db = adminer()->database();
+		if ($db != "") {
+			$options["db"] = $db;
+		}
+		if (($auth_source = getenv("MONGO_AUTH_SOURCE"))) {
+			$options["authSource"] = $auth_source;
+		}
+		$connection->connect("mongodb://$server", $options);
+		if ($connection->error) {
+			return $connection->error;
+		}
+		return $connection;
+	}
+
+	function alter_indexes($table, $alter) {
+		$connection = connection();
+		foreach ($alter as $val) {
+			list($type, $name, $set) = $val;
+			if ($set == "DROP") {
+				$return = $connection->_db->command(array("deleteIndexes" => $table, "index" => $name));
+			} else {
+				$columns = array();
+				foreach ($set as $column) {
+					$column = preg_replace('~ DESC$~', '', $column, 1, $count);
+					$columns[$column] = ($count ? -1 : 1);
+				}
+				$return = $connection->_db->selectCollection($table)->ensureIndex($columns, array(
+					"unique" => ($type == "UNIQUE"),
+					"name" => $name,
+					//! "sparse"
+				));
+			}
+			if ($return['errmsg']) {
+				$connection->error = $return['errmsg'];
+				return false;
+			}
+		}
+		return true;
+	}
+
+	function support($feature) {
+		return preg_match("~database|indexes|descidx~", $feature);
+	}
+
+	function db_collation($db, $collations) {
+	}
+
+	function information_schema() {
+	}
+
+	function is_view($table_status) {
+	}
+
+	function convert_field($field) {
+	}
+
+	function unconvert_field($field, $return) {
+		return $return;
+	}
+
+	function foreign_keys($table) {
+		return array();
+	}
+
+	function fk_support($table_status) {
+	}
+
+	function engines() {
+		return array();
+	}
+
+	function alter_table($table, $name, $fields, $foreign, $comment, $engine, $collation, $auto_increment, $partitioning) {
+		if ($table == "") {
+			connection()->_db->createCollection($name);
+			return true;
+		}
+	}
+
+	function drop_tables($tables) {
+		foreach ($tables as $table) {
+			$response = connection()->_db->selectCollection($table)->drop();
+			if (!$response['ok']) {
+				return false;
+			}
+		}
+		return true;
+	}
+
+	function truncate_tables($tables) {
+		foreach ($tables as $table) {
+			$response = connection()->_db->selectCollection($table)->remove();
+			if (!$response['ok']) {
+				return false;
+			}
+		}
+		return true;
+	}
+}
diff --git a/readme.txt b/readme.txt
index 3c38fa13..3115a10a 100644
--- a/readme.txt
+++ b/readme.txt
@@ -3,7 +3,8 @@ Adminer Editor - Data manipulation for end-users
 
 https://www.adminer.org/
 
-Supports: MySQL, MariaDB, PostgreSQL, CockroachDB, SQLite, MS SQL, Oracle, MongoDB, Elasticsearch (plugin), SimpleDB (plugin), Firebird (plugin), ClickHouse (plugin)
+Supports: MySQL, MariaDB, PostgreSQL, CockroachDB, SQLite, MS SQL, Oracle
+Plugins for: Elasticsearch, SimpleDB, MongoDB, Firebird, ClickHouse
 Requirements: PHP 5.3+
 
 adminer/index.php - Run development version of Adminer