<?php
$drivers = array();

/** Add a driver
* @param string
* @param string
* @return null
*/
function add_driver($id, $name) {
    global $drivers;
    $drivers[$id] = $name;
}

/*abstract*/ class Min_SQL {
    var $_conn;
    
    /** Create object for performing database operations
    * @param Min_DB
    */
    function __construct($connection) {
        $this->_conn = $connection;
    }
    
    /** Select data from table
    * @param string
    * @param array result of $adminer->selectColumnsProcess()[0]
    * @param array result of $adminer->selectSearchProcess()
    * @param array result of $adminer->selectColumnsProcess()[1]
    * @param array result of $adminer->selectOrderProcess()
    * @param int result of $adminer->selectLimitProcess()
    * @param int index of page starting at zero
    * @param bool whether to print the query
    * @return Min_Result
    */
    function select($table, $select, $where, $group, $order = array(), $limit = 1, $page = 0, $print = false) {
        global $adminer, $jush;
        $is_group = (count($group) < count($select));
        $query = $adminer->selectQueryBuild($select, $where, $group, $order, $limit, $page);
        if (!$query) {
            $query = "SELECT" . limit(
                ($_GET["page"] != "last" && $limit != "" && $group && $is_group && $jush == "sql" ? "SQL_CALC_FOUND_ROWS " : "") . implode(", ", $select) . "\nFROM " . table($table),
                ($where ? "\nWHERE " . implode(" AND ", $where) : "") . ($group && $is_group ? "\nGROUP BY " . implode(", ", $group) : "") . ($order ? "\nORDER BY " . implode(", ", $order) : ""),
                ($limit != "" ? +$limit : null),
                ($page ? $limit * $page : 0),
                "\n"
            );
        }
        $start = microtime(true);
        $return = $this->_conn->query($query);
        if ($print) {
            echo $adminer->selectQuery($query, $start, !$return);
        }
        return $return;
    }
    
    /** Delete data from table
    * @param string
    * @param string " WHERE ..."
    * @param int 0 or 1
    * @return bool
    */
    function delete($table, $queryWhere, $limit = 0) {
        $query = "FROM " . table($table);
        return queries("DELETE" . ($limit ? limit1($table, $query, $queryWhere) : " $query$queryWhere"));
    }
    
    /** Update data in table
    * @param string
    * @param array escaped columns in keys, quoted data in values
    * @param string " WHERE ..."
    * @param int 0 or 1
    * @param string
    * @return bool
    */
    function update($table, $set, $queryWhere, $limit = 0, $separator = "\n") {
        $values = array();
        foreach ($set as $key => $val) {
            $values[] = "$key = $val";
        }
        $query = table($table) . " SET$separator" . implode(",$separator", $values);
        return queries("UPDATE" . ($limit ? limit1($table, $query, $queryWhere, $separator) : " $query$queryWhere"));
    }
    
    /** Insert data into table
    * @param string
    * @param array escaped columns in keys, quoted data in values
    * @return bool
    */
    function insert($table, $set) {
        return queries("INSERT INTO " . table($table) . ($set
            ? " (" . implode(", ", array_keys($set)) . ")\nVALUES (" . implode(", ", $set) . ")"
            : " DEFAULT VALUES"
        ));
    }
    
    /** Insert or update data in table
    * @param string
    * @param array
    * @param array of arrays with escaped columns in keys and quoted data in values
    * @return bool
    */
    /*abstract*/ function insertUpdate($table, $rows, $primary) {
        return false;
    }
    
    /** Begin transaction
    * @return bool
    */
    function begin() {
        return queries("BEGIN");
    }
    
    /** Commit transaction
    * @return bool
    */
    function commit() {
        return queries("COMMIT");
    }
    
    /** Rollback transaction
    * @return bool
    */
    function rollback() {
        return queries("ROLLBACK");
    }
    
    /** Return query with a timeout
    * @param string
    * @param int seconds
    * @return string or null if the driver doesn't support query timeouts
    */
    function slowQuery($query, $timeout) {
    }
    
    /** Convert column to be searchable
    * @param string escaped column name
    * @param array array("op" => , "val" => )
    * @param array
    * @return string
    */
    function convertSearch($idf, $val, $field) {
        return $idf;
    }

    /** Convert value returned by database to actual value
    * @param string
    * @param array
    * @return string
    */
    function value($val, $field) {
        return (method_exists($this->_conn, 'value')
            ? $this->_conn->value($val, $field)
            : (is_resource($val) ? stream_get_contents($val) : $val)
        );
    }

    /** Quote binary string
    * @param string
    * @return string
    */
    function quoteBinary($s) {
        return q($s);
    }
    
    /** Get warnings about the last command
    * @return string HTML
    */
    function warnings() {
        return '';
    }
    
    /** Get help link for table
    * @param string
    * @return string relative URL or null
    */
    function tableHelp($name) {
    }
    
}