--- /dev/null
+<?php
+$drivers["mongo"] = "MongoDB";
+
+if (isset($_GET["mongo"])) {
+ $possible_drivers = array("mongo");
+ define("DRIVER", "mongo");
+
+ if (class_exists('MongoDB')) {
+ class Min_DB {
+ var $extension = "Mongo", $error, $_link, $_db;
+
+ function connect($server, $username, $password) {
+ global $adminer;
+ $db = $adminer->database();
+ $options = array();
+ if ($username != "") {
+ $options["username"] = $username;
+ $options["password"] = $password;
+ }
+ if ($db != "") {
+ $options["db"] = $db;
+ }
+ try {
+ $this->_link = new MongoClient("mongodb://$server", $options);
+ return true;
+ } catch (Exception $ex) {
+ $this->error = $ex->getMessage();
+ return false;
+ }
+ }
+
+ function query($query) {
+ return false;
+ }
+
+ function select_db($database) {
+ try {
+ $this->_db = $this->_link->selectDB($database);
+ return true;
+ } catch (Exception $ex) {
+ $this->error = $ex->getMessage();
+ return false;
+ }
+ }
+
+ }
+
+ class Min_Result {
+ var $num_rows, $_rows = array(), $_offset = 0, $_charset = array();
+
+ function Min_Result($result) {
+ foreach ($result as $item) {
+ $row = array();
+ foreach ($item as $key => $val) {
+ if (is_a($val, 'MongoBinData')) {
+ $this->_charset[$key] = 63;
+ }
+ $row[$key] =
+ (is_a($val, 'MongoDate') ? gmdate("Y-m-d H:i:s", $val->sec) . " GMT" :
+ (is_a($val, 'MongoBinData') ? $val->bin : //! allow downloading
+ (is_a($val, 'MongoRegex') ? strval($val) :
+ (is_object($val) ? get_class($val) : // MongoMinKey, MongoMaxKey
+ $val
+ ))));
+ }
+ $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],
+ );
+ }
+
+ }
+ }
+
+
+
+ class Min_Driver extends Min_SQL {
+ function select($table, $select, $where, $group, $order, $limit, $page) {
+ global $connection;
+ if ($select == array("*")) {
+ $select = array();
+ } else {
+ $select = array_fill_keys($select, true);
+ }
+ $return = array();
+ foreach ($connection->_db->selectCollection($table)->find(array(), $select) as $val) {
+ $return[] = $val;
+ }
+ return new Min_Result($return);
+ }
+ }
+
+
+
+ function connect() {
+ global $adminer;
+ $connection = new Min_DB;
+ $credentials = $adminer->credentials();
+ if ($connection->connect($credentials[0], $credentials[1], $credentials[2])) {
+ return $connection;
+ }
+ return $connection->error;
+ }
+
+ function error() {
+ global $connection;
+ return h($connection->error);
+ }
+
+ function logged_user() {
+ global $adminer;
+ $credentials = $adminer->credentials();
+ return $credentials[1];
+ }
+
+ function get_databases($flush) {
+ global $connection;
+ $return = array();
+ $dbs = $connection->_link->listDBs();
+ foreach ($dbs['databases'] as $db) {
+ $return[] = $db['name'];
+ }
+ return $return;
+ }
+
+ function collations() {
+ return array();
+ }
+
+ function db_collation($db, $collations) {
+ }
+
+ function count_tables($databases) {
+ return array();
+ }
+
+ function tables_list() {
+ global $connection;
+ return array_fill_keys($connection->_db->getCollectionNames(true), 'table');
+ }
+
+ 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 information_schema() {
+ }
+
+ function is_view($table_status) {
+ }
+
+ function drop_databases($databases) {
+ global $connection;
+ foreach ($databases as $db) {
+ $response = $connection->_link->selectDB($db)->drop();
+ if (!$response['ok']) {
+ return false;
+ }
+ }
+ return true;
+ }
+
+ function indexes($table, $connection2 = null) {
+ global $connection;
+ $return = array();
+ foreach ($connection->_db->selectCollection($table)->getIndexInfo() as $index) {
+ $descs = array();
+ foreach ($index["key"] as $column => $type) {
+ $descs[] = ($type == -1 ? '1' : null);
+ }
+ $return[$index["name"]] = array(
+ "type" => ($index["name"] == "_id_" ? "PRIMARY" : ($index["unique"] ? "UNIQUE" : "INDEX")),
+ "columns" => array_keys($index["key"]),
+ "descs" => $descs,
+ );
+ }
+ return $return;
+ }
+
+ function fields($table) {
+ return array("_id" => array(
+ "field" => "_id",
+ "auto_increment" => true,
+ "privileges" => array("select" => 1, "insert" => 1, "update" => 1),
+ ));
+ }
+
+ function convert_field($field) {
+ }
+
+ function foreign_keys($table) {
+ return array();
+ }
+
+ function fk_support($table_status) {
+ }
+
+ function engines() {
+ return array();
+ }
+
+ function found_rows($table_status, $where) {
+ return null;
+ }
+
+ 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;
+ }
+
+ function table($idf) {
+ return $idf;
+ }
+
+ function idf_escape($idf) {
+ return $idf;
+ }
+
+ function support($feature) {
+ return preg_match("~database|table|indexes~", $feature);
+ }
+
+ $jush = "mongo";
+ $operators = array("=");
+ $functions = array();
+ $grouping = array();
+ $edit_functions = array();
+}
projects / adminer.git / commitdiff