public function Delete($get)
 {
     if (isset($get['id']) && is_numeric($get['id'])) {
         $db = new MDB();
         $result = $db->deleteMovie($get['id']);
         if ($result) {
             header('Location: ./?message=delete-success');
         } else {
             header('Location: ./?message=delete-error');
         }
         exit;
     } else {
         header('Location: ./?message=request-error');
         exit;
     }
 }

 function Step2()
 {
     if (isset($_POST['movie-id']) && is_numeric($_POST['movie-id']) && isset($_POST['original-title']) && strlen($_POST['original-title']) > 1 && isset($_POST['english-title'])) {
         $db = new MDB();
         $success = $db->editTitles($_POST['movie-id'], $_POST['original-title'], $_POST['english-title']);
         if ($success) {
             header('Location: ' . WEB_ROOT . '?message=edit-titles-success');
         } else {
             header('Location: ' . WEB_ROOT . '?message=edit-titles-error');
         }
         exit;
     } else {
         header('Location: ' . WEB_ROOT . '?message=edit-titles-error');
         exit;
     }
 }

 public function token($token)
 {
     $id = Model::factory('v1_tokens')->user($token);
     if ($id) {
         self::$user_id = MDB::objectId($id);
         return $this->get();
     }
 }

 function testSetDbInstanceDefault()
 {
     $db =& MDB::connect(DB_DSN, $GLOBALS['DB_OPTIONS']);
     $qt =& new MDB_QueryTool();
     $qt->setDbInstance($db);
     $dbActual =& $qt->getDbInstance();
     $this->assertEqual($db->fetchmode, $dbActual->fetchmode);
 }

 /**
  * Check if the two instances are the same by comparing
  * the fetchMode, since this is the easiest to compare if
  * two objects are the same in PHP4.
  * We can do that since the querytool sets the fetch mode to
  * MDB_FETCHMODE_ASSOC.
  * Not very nice but it works.
  *
  */
 function test_default()
 {
     $db =& MDB::connect(DB_DSN);
     $qt =& new MDB_QueryTool();
     $qt->setDbInstance($db);
     $dbActual =& $qt->getDbInstance();
     $this->assertEquals($db->fetchmode, $dbActual->fetchmode);
 }

 public function remove($user, $id)
 {
     $remove = MDB::objectId($id);
     $remove['user_id'] = MDB::stringId($user);
     $x = $this->collection->remove($remove, array('safe' => true));
     if ($x['n']) {
         return $id;
     }
 }

 public function gen(array $user)
 {
     $id = MDB::stringId($user);
     $tail = base64_encode(hash('sha256', date('Y-m-d') . $id . $user["_id"]->getTimestamp() . $user["_id"]->getInc() . microtime()));
     self::$user_id = MDB::stringId($user);
     self::$token = $id . Model_V1_Tokens::DELIMETER . $tail;
     if ($this->add()) {
         return self::$token;
     }
 }

 /**
  * Connects to the db
  *
  * @return object DB The database object
  * @access private
  */
 function &_db_Connect($dsn)
 {
     $this->_debugMessage('_db_Connect($dsn)');
     if (is_object($this->db)) {
         return $this->db;
     }
     $db =& MDB::connect($dsn);
     $this->_testFatalAbort($db, __FILE__, __LINE__);
     return $db;
 }

 function &getContainer()
 {
     static $container;
     #print "In MDBContainer::getContainer {$this->skip_tests}\n";
     if (!isset($container)) {
         include 'auth_container_mdb_options.php';
         $container = new Auth_Container_MDB($options);
         // Catch if DB connection cannot be made
         $res = $container->_prepare();
     }
     if (!MDB::isConnection($container->db)) {
         $this->markTestSkipped("MDB is not a connection object, check dsn");
     }
     return $container;
 }

 function &getContainer()
 {
     static $container;
     #print "In MDBContainer::getContainer {$this->skip_tests}\n";
     if (!isset($container)) {
         include './auth_container_mdb_options.php';
         $container = new Auth_Container_MDB($options);
         // Catch if DB connection cannot be made
         $res = $container->_prepare();
     }
     if (!MDB::isConnection($container->db)) {
         #print "In MDBContainer::getContainer container->db is error \n";
         $this->skip_tests = true;
         $this->skip_tests_message = "SKIP TEST:MDB is not a connection object, check dsn !!!";
     }
     return $container;
 }

 public function action_mongo()
 {
     MDB::$config = Kohana::$config->load('database')->mongo;
     $config = MDB::config();
     #d::v($config);
     $mongo = MDB::mongo();
     d::v($mongo);
     $db = MDB::db();
     d::cl($db);
     $colle = MDB::collection('test');
     d::cl($colle);
     $data = array('data' => 'test');
     $insert = MDB::insert($data);
     d::v($insert);
     $find = MDB::find();
     d::cl($find);
     d::v(iterator_to_array($find));
     $gridFS = MDB::gridFS();
     d::cl($gridFS);
     $remove = MDB::remove();
     d::v($remove);
 }

    include "trailer.inc";
    exit;
}
if (!isset($search_pos) || $search_pos <= 0) {
    $search_pos = 0;
} elseif ($search_pos >= $total) {
    $search_pos = $total - $total % $search["count"];
}
# Now we set up the "real" query using LIMIT to just get the stuff we want.
$sql = "SELECT E.id, E.create_by, E.name, E.description, E.start_time, R.area_id\n        FROM mrbs_entry E, mrbs_room R\n        WHERE {$sql_pred}\n        AND E.room_id = R.id\n        ORDER BY E.start_time asc";
if ($debug_flag) {
    echo "<p>DEBUG: SQL: <tt> {$sql} </tt><BR>";
}
$types = array('integer', 'text', 'text', 'text', 'integer', 'integer');
$result = $mdb->limitQuery($sql, $types, $search_pos, $search["count"]);
if (MDB::isError($mdb)) {
    fatal_error(0, $result->getMessage() . "\n" . $result->getUserInfo() . "\n");
}
$num_records = $mdb->numRows($result);
$has_prev = $search_pos > 0;
$has_next = $search_pos < $total - $search["count"];
if ($has_prev || $has_next) {
    echo "<B>" . get_vocab("records") . ($search_pos + 1) . get_vocab("through") . ($search_pos + $num_records) . get_vocab("of") . $total . "</B><BR>";
    # display a "Previous" button if necessary
    if ($has_prev) {
        echo "<A HREF=\"search.php?search_str={$search_url}&search_pos=";
        echo max(0, $search_pos - $search["count"]);
        echo "&total={$total}&year={$year}&month={$month}&day={$day}\">";
    }
    echo "<B>" . get_vocab("previous") . "</B>";
    if ($has_prev) {

 /**
  * Change password for user in the storage container
  *
  * @param string Username
  * @param string The new password (plain text)
  */
 function changePassword($username, $password)
 {
     $this->log('Auth_Container_MDB::changePassword() called.', AUTH_LOG_DEBUG);
     $err = $this->_prepare();
     if ($err !== true) {
         return PEAR::raiseError($err->getMessage(), $err->getCode());
     }
     if (isset($this->options['cryptType']) && $this->options['cryptType'] == 'none') {
         $cryptFunction = 'strval';
     } elseif (isset($this->options['cryptType']) && function_exists($this->options['cryptType'])) {
         $cryptFunction = $this->options['cryptType'];
     } else {
         $cryptFunction = 'md5';
     }
     $password = $cryptFunction($password);
     $query = sprintf("UPDATE %s SET %s = %s WHERE %s = %s", $this->options['final_table'], $this->options['final_passwordcol'], $this->db->getTextValue($password), $this->options['final_usernamecol'], $this->db->getTextValue($username));
     // check if there is an optional parameter db_where
     if ($this->options['db_where'] != '') {
         // there is one, so add it to the query
         $query .= " AND " . $this->options['db_where'];
     }
     $this->log('Running SQL against MDB: ' . $query, AUTH_LOG_DEBUG);
     $res = $this->query($query);
     if (MDB::isError($res)) {
         return PEAR::raiseError($res->getMessage(), $res->code);
     }
     return true;
 }

require_once 'PHPUnit/GUI/HTML.php';
define('DB_DSN', 'mysql://root@localhost/mdb_qt');
define('TABLE_USER', 'QueryTool_user');
define('TABLE_ADDRESS', 'QueryTool_address');
define('TABLE_QUESTION', 'question');
define('TABLE_ANSWER', 'answer');
$allTables = array(TABLE_USER, TABLE_ADDRESS, TABLE_QUESTION, TABLE_ANSWER);
require_once 'sql.php';
require_once 'UnitTest.php';
require_once 'Common.php';
//
//  common setup (this actually also does the tearDown, since we have the DROP TABLE queries in the setup too
//
$querytool = new tests_Common();
foreach ($dbStructure[$querytool->db->phptype]['setup'] as $aQuery) {
    if (MDB::isError($ret = $querytool->db->query($aQuery))) {
        //include_once 'Var_Dump.php';
        //var_dump::display($ret);
        die($ret->getUserInfo());
    }
}
//
//  run the test suite
//
require_once 'PHPUnit/GUI/SetupDecorator.php';
$gui = new PHPUnit_GUI_SetupDecorator(new PHPUnit_GUI_HTML());
$gui->getSuitesFromDir(dirname(__FILE__), '.*\\.php', array('UnitTest.php', 'Common.php', 'sql.php', 'index.php'));
$gui->show();
/*
require_once 'Get.php';
require_once 'GetAll.php';

 public static function ExecuteQuery($sql)
 {
     $connection = DBConnectionManager::get_connection(DATABASE_HOST, DATABASE_USER, DATABASE_PASSWORD, DATABASE_NAME);
     $db = MDB::cursor($connection, '');
     return $db->fetchObject($db->query($sql));
 }

<?php

header("Content-type: text/javascript");
require_once '../_includes/main.php';
$db = new MDB();
$imdbIds = $db->getImdbIds();
echo 'Movies.config.imdbIds = "|';
if (isset($imdbIds) && !empty($imdbIds)) {
    foreach ($imdbIds as $id) {
        echo str_pad($id['id'], 7, '0', STR_PAD_LEFT) . '|';
    }
}
echo '";';

 /**
  * Initialize the storage container
  *
  * @param array Array with the storage configuration
  * @return bool true on success, false on failure.
  *
  * @access public
  */
 function init($storageConf)
 {
     parent::init($storageConf);
     if (!MDB::isConnection($this->dbc) && !is_null($this->dsn)) {
         $this->options['optimize'] = 'portability';
         if ($this->function == 'singleton') {
             $dbc =& MDB::singleton($this->dsn, $this->options);
         } else {
             $dbc =& MDB::connect($this->dsn, $this->options);
         }
         if (PEAR::isError($dbc)) {
             $this->stack->push(LIVEUSER_ERROR_INIT_ERROR, 'error', array('container' => 'could not connect: ' . $dbc->getMessage(), 'debug' => $dbc->getUserInfo()));
             return false;
         }
         $this->dbc =& $dbc;
     }
     if (!MDB::isConnection($this->dbc)) {
         $this->stack->push(LIVEUSER_ERROR_INIT_ERROR, 'error', array('container' => 'storage layer configuration missing'));
         return false;
     }
     return true;
 }

 /**
  * Garbage collector.
  *
  * @param    int maxlifetime
  */
 function garbageCollection($maxlifetime)
 {
     $this->flushPreload();
     $query = 'DELETE FROM ' . $this->cache_table . ' WHERE (expires <= ' . time() . ' AND expires > 0) OR changed <= ' . time() - $maxlifetime;
     $res = $this->db->query($query);
     $query = 'SELECT sum(length(cachedata)) as CacheSize FROM ' . $this->cache_table;
     $cachesize = $this->db->getOne($query);
     if (MDB::isError($cachesize)) {
         return new Cache_Error('MDB::query failed: ' . $this->db->errorMessage($cachesize), __FILE__, __LINE__);
     }
     //if cache is to big.
     if ($cachesize > $this->highwater) {
         //find the lowwater mark.
         $query = 'SELECT length(cachedata) as size, changed FROM ' . $this->cache_table . ' ORDER BY changed DESC';
         $res = $this->db->query($query);
         if (MDB::isError($res)) {
             return new Cache_Error('MDB::query failed: ' . $this->db->errorMessage($res), __FILE__, __LINE__);
         }
         $numrows = $this->db->numRows($res);
         $keep_size = 0;
         while ($keep_size < $this->lowwater && $numrows--) {
             $entry = $this->db->fetchInto($res, MDB_FETCHMODE_ASSOC);
             $keep_size += $entry['size'];
         }
         //delete all entries, which were changed before the "lowwater mark"
         $query = 'DELETE FROM ' . $this->cache_table . ' WHERE changed<=' . ($entry['changed'] ? $entry['changed'] : 0);
         $res = $this->db->query($query);
         if (MDB::isError($res)) {
             return new Cache_Error('MDB::query failed: ' . $this->db->errorMessage($res), __FILE__, __LINE__);
         }
     }
 }

 if (!empty($creatormatch)) {
     $sql .= " AND" . sql_syntax_caseless_contains("e.create_by", $creatormatch);
 }
 if ($sortby == "r") {
     # Order by Area, Room, Start date/time
     $sql .= " ORDER BY 9,10,2";
 } else {
     # Order by Start date/time, Area, Room
     $sql .= " ORDER BY 2,9,10";
 }
 if ($debug_flag) {
     echo "<p>DEBUG: SQL: <tt> {$sql} </tt>\n";
 }
 $types = array('integer', 'integer', 'integer', 'text', 'text', 'text', 'text', 'timestamp', 'text', 'text');
 $res = $mdb->query($sql, $types);
 if (MDB::isError($res)) {
     fatal_error(0, $res->getMessage() . "\n" . $res->getUserInfo() . "\n");
 }
 $nmatch = $mdb->numRows($res);
 if ($nmatch == 0) {
     echo "<P><B>" . get_vocab("nothing_found") . "</B>\n";
     $mdb->freeResult($res);
 } else {
     $last_area_room = "";
     $last_date = "";
     echo "<P><B>" . $nmatch . " " . ($nmatch == 1 ? get_vocab("entry_found") : get_vocab("entries_found")) . "</B>\n";
     while ($row = $mdb->fetchInto($res)) {
         if ($summarize & 1) {
             reporton($row, $last_area_room, $last_date, $sortby, $display);
         }
         if ($summarize & 2) {

// Set $db_create to 0 to NOT create the database.
$db_create = 1;
// Communication protocol tu use. For pgsql, you can use 'unix' instead of
// 'tcp' to use Unix Domain Sockets instead of TCP/IP.
$db_protocol = "tcp";
/**************************
* DBMS specific options
***************************/
//****ORACLE*****
// Home directory path where Oracle is installed if it is running in the local machine.
// Default value: value of the environment variable ORACLE_HOME
$oci8_home = "";
/**************************
* End of database settings
***************************/
include_once "MDB.php";
MDB::loadFile("Manager");
$schema_file = "mrbs.schema.xml";
$variables = array("database_name" => $db_database, "database_create" => $db_create);
$dsn = array("phptype" => $dbsys, "username" => $db_login, "password" => $db_password, "hostspec" => $db_host, "protocol" => $db_protocol, "port" => $db_port);
$options = array("HOME" => $oci8_home, "optimize" => 'portability');
$manager = new MDB_manager();
$manager->connect($dsn, $options);
$success = $manager->updateDatabase($schema_file, $schema_file . ".before", $variables);
if (MDB::isError($success)) {
    echo "Error: " . $success->getMessage() . "<BR>";
    echo "Error: " . $success->getUserInfo() . "<BR>";
}
if (count($manager->warnings) > 0) {
    echo "WARNING:<BR>", implode($manager->getWarnings(), "!\n"), "\n";
}