+++ /dev/null
-<?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;
- }
-}
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
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):
--- /dev/null
+<?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;
+ }
+}
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
projects / adminer.git / commitdiff